From 0418009a980927b95b78bac3f89a215f4ad0f10b Mon Sep 17 00:00:00 2001 From: lccsw <1127794702@qq.com> Date: Tue, 29 Mar 2022 17:15:59 +0800 Subject: [PATCH] add-plan-up_order --- api/controllers/plan/Biz.php | 3 +- api/controllers/plan/Order.php | 73 ++++++++++++++++++- api/controllers/plan/Plan.php | 2 + .../libraries/receiver/Order_datas_entity.php | 48 ++++++------ 4 files changed, 98 insertions(+), 28 deletions(-) diff --git a/api/controllers/plan/Biz.php b/api/controllers/plan/Biz.php index 49a0fbc5..52c5403a 100644 --- a/api/controllers/plan/Biz.php +++ b/api/controllers/plan/Biz.php @@ -99,8 +99,7 @@ class Biz extends HD_Controller $fields = "$t1.*"; $where = [ "$t1.year" => date('Y',strtotime("last month")), - //"$t1.month" => date('m',strtotime('last month')), - "$t1.month" => date('m'), + "$t1.month" => intval(date('m',strtotime('last day of - 1 months'))), "$t2.id is null" => null ]; diff --git a/api/controllers/plan/Order.php b/api/controllers/plan/Order.php index 0b868ca4..38c62ddf 100644 --- a/api/controllers/plan/Order.php +++ b/api/controllers/plan/Order.php @@ -2,13 +2,18 @@ defined('BASEPATH') OR exit('No direct script access allowed'); class Order extends CI_Controller{ - + + private $log_dir = "licheb"; + private $log_file = "order_v2.log"; public function __construct() { parent::__construct(); $this->load->model('receiver/order/receiver_orders_model'); $this->load->model('receiver/order/receiver_orders_v2_model'); + $this->load->model('receiver/order/receiver_order_status_model'); + + $this->load->model('app/liche/app_liche_orders_model'); } public function index(){ @@ -98,4 +103,70 @@ class Order extends CI_Controller{ } } + public function up_pay_status(){ + $page = $this->input->get('page'); + $size = $this->input->get('size'); + !$page && $page = 1; + !$size && $size = 20; + + $where = [ + 'id>=' => 10000, + 'status>=' => 0 + ]; + $rows = $this->receiver_orders_v2_model->select($where,'id asc',$page,$size); + if($rows){ + foreach($rows as $key => $val){ + $if_pay = $this->app_liche_orders_model->count(['o_id'=>$val['id'],'status'=>1]); + $s_row = $this->receiver_order_status_model->count(['o_id'=>$val['id'],'pid_status'=>0,'status'=>1]); + if($if_pay && !$s_row){ + $data = [ + 'o_id' => $val['id'], + 'pid_status' => 0, + 'status' => 1, + 'c_time' => time() + ]; + $res = $this->receiver_order_status_model->add($data); + echo "update o_id:{$val['id']}
"; + }else{ + echo "undo o_id:{$val['id']}
"; + } + } + }else{ + echo 'finish'; + } + } + + //更新旧订单数据状态 + public function up_old_status(){ + $size = $this->input->get('size'); + !$size && $size = 20; + + $t1 = 'lc_receiver_orders_v2'; + $t2 = 'lc_receiver_orders'; + + $fields = "$t1.*"; + $where = [ + "$t1.id<" => 10000, + "$t1.status" => 0, + "$t2.status" => 6 + ]; + + $this->db->from("$t1"); + $this->db->join("$t2", "$t2.id=$t1.id",'left'); + + $this->db->select($fields); + $this->db->where($where); + $this->db->order_by("$t1.id asc"); + $this->db->limit($size); + $rows = $this->db->get()->result_array(); + if($rows){ + foreach($rows as $key=>$val){ + $res = $this->receiver_orders_v2_model->update(['status'=>1],['id'=>$val['id']]); + $str = "更新订单状态:{$val['id']}"; + debug_log($str,$this->log_file,$this->log_dir); + } + }else{ + echo "no data"; + } + } } diff --git a/api/controllers/plan/Plan.php b/api/controllers/plan/Plan.php index 9162fbbf..82096a21 100644 --- a/api/controllers/plan/Plan.php +++ b/api/controllers/plan/Plan.php @@ -33,8 +33,10 @@ class Plan extends CI_Controller $plan[] = array('url' => base_url(array('plan', 'licheb', 'customer_level')), 'interval' => 1);//更新客户等级 $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', 'biz', 'settle')), 'interval' => 1); + $plan[] = array('url' => base_url(array('plan', 'order', 'up_old_status')), 'interval' => 30); //更新旧订单状态 $this->plan = $plan; } diff --git a/common/libraries/receiver/Order_datas_entity.php b/common/libraries/receiver/Order_datas_entity.php index f810f7bf..4242158c 100644 --- a/common/libraries/receiver/Order_datas_entity.php +++ b/common/libraries/receiver/Order_datas_entity.php @@ -74,35 +74,33 @@ class Order_datas_entity{ ]; $check_data = $this->ci->app_checkdata_model->map('type','',$where,'','','','id,cf_id,type,ifcheck'); foreach ($result as $key=>$item) { - if($o_data[$key] || $o_data['cardidb']){ - $result[$key]['up_status'] = 1; - $ifcheck = $check_data[$item['type']][0]['ifcheck']; - $imgs = []; - if($key=='ins_img'||$key=='other_img'){ - $img_data = json_decode($o_data[$key],true); - if(is_array($img_data)){ - foreach ($img_data as $v) { - $imgs[] = build_qiniu_image_url($v); - } - } - }else{ - $imgs[] = build_qiniu_image_url($o_data[$key]); - if($key=='cardida' && $o_data['cardidb']){ - $imgs[1] = build_qiniu_image_url($o_data['cardidb']); + $result[$key]['up_status'] = 1; + $ifcheck = $check_data[$item['type']][0]['ifcheck']; + $imgs = []; + if($key=='ins_img'||$key=='other_img'){ + $img_data = json_decode($o_data[$key],true); + if(is_array($img_data)){ + foreach ($img_data as $v) { + $imgs[] = build_qiniu_image_url($v); } } - $result[$key]['imgs'] = $imgs; - if($ifcheck==1){ - $result[$key]['status_cn'] = '已通过'; - $result[$key]['status'] = 1; - }elseif($ifcheck==-1){ - $result[$key]['status_cn'] = '未通过'; - $result[$key]['status'] = -1; - }else{ - $result[$key]['status_cn'] = '未审核'; - $result[$key]['status'] = 0; + }else{ + $o_data[$key] && $imgs[] = build_qiniu_image_url($o_data[$key]); + if($key=='cardida' && $o_data['cardidb']){ + $imgs[1] = build_qiniu_image_url($o_data['cardidb']); } } + $result[$key]['imgs'] = $imgs; + if($ifcheck==1){ + $result[$key]['status_cn'] = '已通过'; + $result[$key]['status'] = 1; + }elseif($ifcheck==-1){ + $result[$key]['status_cn'] = '未通过'; + $result[$key]['status'] = -1; + }else{ + $result[$key]['status_cn'] = '未审核'; + $result[$key]['status'] = 0; + } } return $result; }