From e39a81088860c2f865dcca7d49fd39e494b2bbad Mon Sep 17 00:00:00 2001 From: dengbw Date: Thu, 31 Mar 2022 11:40:27 +0800 Subject: [PATCH] stock_331 --- api/controllers/plan/Items.php | 91 +++++++++++++++++++ api/controllers/plan/Licheb.php | 84 ----------------- api/controllers/plan/Plan.php | 1 + api/controllers/plan/Temp.php | 84 +++++++++++++++++ common/models/items/Items_stock_log_model.php | 18 ++++ 5 files changed, 194 insertions(+), 84 deletions(-) create mode 100644 api/controllers/plan/Items.php create mode 100644 common/models/items/Items_stock_log_model.php diff --git a/api/controllers/plan/Items.php b/api/controllers/plan/Items.php new file mode 100644 index 00000000..1d6ee85f --- /dev/null +++ b/api/controllers/plan/Items.php @@ -0,0 +1,91 @@ +log_file = 'items.log'; + } + + /** + * Notes:库存车辆_日志 + * Created on: 2021/10/19 17:15 + * Created by: dengbw + * https://liche-api-dev.xiaoyu.com/plan/items/stock_log?sd=1 + * https://api.liche.cn/plan/items/stock_log + */ + public function stock_log() + { + $params = $this->input->get(); + $hour = date('H.i'); + if (($hour > 23.30 && $hour < 23.59) || $params['sd']) { + if ($params['sd']) { + echo "开始执行库存车辆日志[{$hour}]"; + } + } else { + echo '[23:30]过后才会开始执行库存车辆日志[' . $hour . ']'; + return; + } + $this->load->model('items/items_stock_log_model', 'mdItemsStockLog'); + $this->load->model('items/items_model', 'mdItems'); + $this->load->model('items/items_transfer_model', 'mdTransfer'); + $size = 150;//每次最多处理多少条 + $rds = intval($this->input->get('rds')); + $redis = &load_cache('redis'); + $redisKey = 'items_stock_log_item_id'; + $log_date = date('Y-m-d'); + $re_v = $this->mdItemsStockLog->get(array('log_date' => $log_date));//查找当天是否有数据 + if (!$re_v || $rds) { + $redis->delete($redisKey); + } + $item_id = $redis->get($redisKey); + !$item_id && $item_id = 0; + $log = []; + $where = ['id >' => $item_id, 'biz_id >' => 0, 'status>' => 0, 'bill_time' => '0000-00-00 00:00:00']; + $res_ite = $this->mdItems->select($where, 'id asc', 1, $size, 'id,brand_id,s_id,biz_id,in_time'); + if (!$res_ite) { + echo '执行到当前车辆id：' . $item_id . '暂无数据'; + return; + } + $addDate = []; + foreach ($res_ite as $key => $value) { + $item_id = $value['id']; + $re_ite = $this->mdItemsStockLog->get(array('log_date' => $log_date, 'item_id' => $value['id'])); + if (!$re_ite) {//判断当天是否已加入 + $in_time = $value['in_time']; + //查找调拨接车的门店 + $re_tra = $this->mdTransfer->max('in_time', ["item_id" => $item_id, 'status' => 2, 'biz_id' => $value['biz_id']]); + $re_tra['in_time'] && $in_time = $re_tra['in_time'];//有调拨的接车时间，就是入库日期 + $stay_days = round((time() - strtotime($in_time)) / 3600 / 24); + $addDate[] = ['item_id' => $item_id, 'brand_id' => $value['brand_id'], 's_id' => $value['s_id'], + 'biz_id' => $value['biz_id'], 'in_time' => $in_time, 'log_date' => $log_date, 'stay_days' => $stay_days, 'c_time' => time()]; + $log[] = array('item_id' => $item_id, 'stay_days' => $stay_days, 'in_time' => $in_time); + } + } + if ($addDate && count($addDate)) { + $this->mdItemsStockLog->add_batch($addDate); + } + $redis->save($redisKey, $item_id);//保存最后客户id + if ($params['sd']) { + echo '
执行到当前客户id：' . $redis->get($redisKey); + echo '日期：' . json_encode(array('log_date' => $log_date), JSON_UNESCAPED_UNICODE); + echo '
成功新增：
'; + if ($log) { + echo json_encode($log, JSON_UNESCAPED_UNICODE); + echo '
'; + } + echo '数据库获取：
'; + echo json_encode($res_ite, JSON_UNESCAPED_UNICODE); + } + } + +} \ No newline at end of file diff --git a/api/controllers/plan/Licheb.php b/api/controllers/plan/Licheb.php index 0ff3bc95..125dcf76 100644 --- a/api/controllers/plan/Licheb.php +++ b/api/controllers/plan/Licheb.php @@ -18,90 +18,6 @@ class Licheb extends HD_Controller $this->load->model('receiver/receiver_customers_visit_model', 'mdCustomersVisit'); } - /** - * Notes:更新车辆调拨状态 - * Created on: 2022/2/28 17:15 - * Created by: dengbw - * https://liche-api-dev.xiaoyu.com/plan/licheb/inventory_log - * https://api.liche.cn/plan/licheb/inventory_log - */ - public function inventory_log() - { - $params = $this->input->get(); - $size = 100;//每次最多处理多少条 - $rds = intval($this->input->get('rds')); - $redis = &load_cache('redis'); - $redisKey = 'inventory_log_id'; - $id = $redis->get($redisKey); - !$id && $id = 0; - if ($rds) {//手动清除缓存 - $id = 0; - $redis->delete($redisKey); - } - $log = array(); - $this->load->model('items/Items_inventory_log_model', 'mdInventoryLog'); - $this->load->model('items/items_model', 'mdItems'); - $where = array('id >' => $id, 'status' => 0); - $res_log = $this->mdInventoryLog->select($where, 'id asc', 1, $size, 'id,item_id,biz_id,addr_id'); - if (!$res_log) { - echo '执行到当前id：' . $id . '暂无数据'; - $redis->delete($redisKey); - return; - } - foreach ($res_log as $key => $value) { - $id = $value['id']; - $res_item = $this->mdItems->get(['id' => $value['item_id']]); - if ($res_item) { - $status = ''; - if ($res_item['bill_time'] != '0000-00-00 00:00:00') {//已售 - $status = -2; - } else if ($res_item['biz_id'] != $value['biz_id'] || $res_item['addr_id'] != $value['addr_id']) {//已调拨 - $status = -1; - } - if ($status) { - $ret = $this->mdInventoryLog->update(['status' => $status], ['id' => $id]); - if ($ret) { - $log[] = array('id' => $id, 'status' => $status); - } - } - } - } - $redis->save($redisKey, $id);//保存最后id - if ($params['sd']) { - echo '
执行到当前id：' . $id; - echo '
成功更新：
'; - if ($log) { - echo json_encode($log, JSON_UNESCAPED_UNICODE); - echo '
'; - } - echo '数据库获取：
'; - echo json_encode($res_log, JSON_UNESCAPED_UNICODE); - } - } - - /** - * Notes:更新车辆调拨异常 - * Created on: 2022/1/4 13:53 - * Created by: dengbw - * https://liche-api-dev.xiaoyu.com/plan/licheb/transfer_abnormal - * https://api.liche.cn/plan/licheb/transfer_abnormal - */ - public function transfer_abnormal() - { - $this->load->model('items/items_transfer_model', 'mdTransfer'); - $params = $this->input->get(); - $ret = ''; - if ($params['id']) { - $abnormal = intval($params['abnormal']); - $ret = $this->mdTransfer->update(['abnormal' => $abnormal], ['id' => $params['id']]); - } - if ($ret) { - echo "更新异常成功_{$params['id']}_$abnormal"; - } else { - echo "更新异常失败"; - } - } - /** * Notes:给销售发送待回访短信 * Created on: 2021/10/19 17:15 diff --git a/api/controllers/plan/Plan.php b/api/controllers/plan/Plan.php index 82096a21..e564e619 100644 --- a/api/controllers/plan/Plan.php +++ b/api/controllers/plan/Plan.php @@ -34,6 +34,7 @@ class Plan extends CI_Controller $plan[] = array('url' => base_url(array('plan', 'licheb', 'visit_sales_sms')), 'interval' => 1);//给销售发送待回访短信 $plan[] = array('url' => base_url(array('plan', 'licheb', 'customer_manager_sms')), 'interval' => 1);//给店长发送待分配短信 $plan[] = array('url' => base_url(array('plan', 'licheb', 'customer_manager_sms')), 'interval' => 1);//给店长发送待分配短信 + $plan[] = array('url' => base_url(array('plan', 'items', 'stock_log')), 'interval' => 10);//库存车辆日志 $plan[] = array('url' => base_url(array('plan', 'biz', 'settle')), 'interval' => 1); $plan[] = array('url' => base_url(array('plan', 'order', 'up_old_status')), 'interval' => 30); //更新旧订单状态 diff --git a/api/controllers/plan/Temp.php b/api/controllers/plan/Temp.php index c3bcb898..7e909350 100644 --- a/api/controllers/plan/Temp.php +++ b/api/controllers/plan/Temp.php @@ -16,6 +16,90 @@ class Temp extends HD_Controller $this->log_file = 'temp.log'; } + /** + * Notes:更新车辆调拨状态 + * Created on: 2022/2/28 17:15 + * Created by: dengbw + * https://liche-api-dev.xiaoyu.com/plan/licheb/inventory_log + * https://api.liche.cn/plan/licheb/inventory_log + */ + public function inventory_log() + { + $params = $this->input->get(); + $size = 100;//每次最多处理多少条 + $rds = intval($this->input->get('rds')); + $redis = &load_cache('redis'); + $redisKey = 'inventory_log_id'; + $id = $redis->get($redisKey); + !$id && $id = 0; + if ($rds) {//手动清除缓存 + $id = 0; + $redis->delete($redisKey); + } + $log = array(); + $this->load->model('items/Items_inventory_log_model', 'mdInventoryLog'); + $this->load->model('items/items_model', 'mdItems'); + $where = array('id >' => $id, 'status' => 0); + $res_log = $this->mdInventoryLog->select($where, 'id asc', 1, $size, 'id,item_id,biz_id,addr_id'); + if (!$res_log) { + echo '执行到当前id：' . $id . '暂无数据'; + $redis->delete($redisKey); + return; + } + foreach ($res_log as $key => $value) { + $id = $value['id']; + $res_item = $this->mdItems->get(['id' => $value['item_id']]); + if ($res_item) { + $status = ''; + if ($res_item['bill_time'] != '0000-00-00 00:00:00') {//已售 + $status = -2; + } else if ($res_item['biz_id'] != $value['biz_id'] || $res_item['addr_id'] != $value['addr_id']) {//已调拨 + $status = -1; + } + if ($status) { + $ret = $this->mdInventoryLog->update(['status' => $status], ['id' => $id]); + if ($ret) { + $log[] = array('id' => $id, 'status' => $status); + } + } + } + } + $redis->save($redisKey, $id);//保存最后id + if ($params['sd']) { + echo '
执行到当前id：' . $id; + echo '
成功更新：
'; + if ($log) { + echo json_encode($log, JSON_UNESCAPED_UNICODE); + echo '
'; + } + echo '数据库获取：
'; + echo json_encode($res_log, JSON_UNESCAPED_UNICODE); + } + } + + /** + * Notes:更新车辆调拨异常 + * Created on: 2022/1/4 13:53 + * Created by: dengbw + * https://liche-api-dev.xiaoyu.com/plan/licheb/transfer_abnormal + * https://api.liche.cn/plan/licheb/transfer_abnormal + */ + public function transfer_abnormal() + { + $this->load->model('items/items_transfer_model', 'mdTransfer'); + $params = $this->input->get(); + $ret = ''; + if ($params['id']) { + $abnormal = intval($params['abnormal']); + $ret = $this->mdTransfer->update(['abnormal' => $abnormal], ['id' => $params['id']]); + } + if ($ret) { + echo "更新异常成功_{$params['id']}_$abnormal"; + } else { + echo "更新异常失败"; + } + } + /** * Notes:更新客户初始销售 * Created on: 2022/3/09 11:58 diff --git a/common/models/items/Items_stock_log_model.php b/common/models/items/Items_stock_log_model.php new file mode 100644 index 00000000..e1db0bdd --- /dev/null +++ b/common/models/items/Items_stock_log_model.php @@ -0,0 +1,18 @@ +table_name, 'default'); + } + +} \ No newline at end of file