From 69b416f276a51bb679d03d2fa978d208e4d61ff3 Mon Sep 17 00:00:00 2001 From: dengbw Date: Mon, 5 Sep 2022 15:44:57 +0800 Subject: [PATCH] temp_905 --- api/controllers/plan/Temp.php | 110 ++++++++++++++++++++++++++++++++++ 1 file changed, 110 insertions(+) diff --git a/api/controllers/plan/Temp.php b/api/controllers/plan/Temp.php index be3565a4..d75e3314 100644 --- a/api/controllers/plan/Temp.php +++ b/api/controllers/plan/Temp.php @@ -16,6 +16,116 @@ class Temp extends HD_Controller $this->log_file = 'temp.log'; } + /** + * Notes:更新客户初始销售 + * Created on: 2022/7/26 11:58 + * Created by: dengbw + * https://liche-api-dev.xiaoyu.com/plan/temp/add_owners + * https://api.liche.cn/plan/temp/add_owners + */ + public function add_owners() + { + $this->load->model('receiver/order/receiver_orders_v2_model', 'mdOrders'); + $this->load->model('receiver/order/receiver_order_agents_model', 'mdOrdersAgents'); + $this->load->model('app/liche/app_liche_users_model', 'mdUsers'); + $this->load->model('receiver/receiver_owners_model', 'mdOwners'); + $this->load->model('app/app_lichene_qy_model', 'mdWechatqy'); + $this->load->model('app/app_different_qy_model', 'mdDifferentQy'); + $this->load->model("biz/biz_model", 'mdBiz'); + $param = $this->input->get(); + $param['page'] = intval($param['page']); + $param['size'] = intval($param['size']); + !$param['size'] && $param['size'] = 50; + !$param['page'] && $param['page'] = 1; + $counts = intval($param['counts']); + ob_start(); //打开缓冲区 + $t1 = 'lc_receiver_orders_v2'; + $t2 = 'lc_receiver_order_status'; + $where = ["{$t2}.c_time=" => 0, "{$t1}.status>=" => 0, "{$t1}.owner_name<>" => '', "{$t1}.owner_mobile<>" => '', + "{$t2}.pid_status" => 5, "{$t2}.status" => 1]; + $having = "total >= 1"; + $orderby = "{$t2}.id asc"; + $fileds = "{$t1}.id,{$t1}.brand_id,{$t1}.s_id,{$t1}.v_id,{$t1}.owner_name,{$t1}.owner_mobile,{$t1}.order_time,{$t1}.ck_time + ,{$t1}.bill_time,{$t1}.info_json,{$t1}.biz_id,{$t2}.c_time"; + $res = $this->mdOrders->selectOrders($where, $orderby, $param['page'], $param['size'], '', $fileds, $having); + if (!$res) { + echo '
本次更新车主完成了：'; + echo '

成功更新 ' . $counts . ' 条'; + echo '

点击将再次更新车主>>>'; + exit; + } + $log = array(); + $str_o_ids = implode(',', array_unique(array_column($res, 'id'))); + $map_agents = $this->mdOrdersAgents->map('o_id', 'car_num', ["o_id in({$str_o_ids})" => null]); + $str_mobiles = implode(',', array_unique(array_column($res, 'owner_mobile'))); + $map_users = $this->mdUsers->map('mobile', 'id', ["mobile in({$str_mobiles})" => null]); + foreach ($res as $key => $value) { + $c_time = $value['c_time']; + $birth_day = '0000-00-00'; + $sex = 0; + if ($value['info_json']) { + $info_json = json_decode($value['info_json'], true); + if ($info_json['c_owner_cardid']) { + $cardid = $info_json['c_owner_cardid']; + $birth_day = date('Y-m-d', strtotime(substr($cardid, 6, 8))); + $sex = substr($cardid, -2, 1) % 2 == 0 ? 2 : 1; //1为男 2为女 + } + } + $uid = intval($map_users[$value['owner_mobile']]); + $car_num = $map_agents[$value['id']] ? $map_agents[$value['id']] : ''; + $ck_time = $value['ck_time'] != '0000-00-00 00:00:00' ? $value['ck_time'] : $value['bill_time']; + $data = ['o_id' => $value['id'], 'uid' => $uid, 'name' => $value['owner_name'], 'mobile' => $value['owner_mobile'], + 'birth_day' => $birth_day, 'sex' => $sex, 'brand_id' => $value['brand_id'], 's_id' => $value['s_id'], + 'v_id' => $value['v_id'], 'order_time' => $value['order_time'], 'ck_time' => $ck_time, 'car_num' => $car_num]; + $biz_type = 0; + if ($value['biz_id']) { + $re_biz = $this->mdBiz->get(['id' => $value['biz_id']]); + if ($re_biz) { + $biz_type = $re_biz['type']; + $data['province_id'] = $re_biz['province_id']; + $data['city_id'] = $re_biz['city_id']; + $data['county_id'] = $re_biz['county_id']; + } + } + if ($value['owner_mobile']) {//查找企微 + if ($biz_type == 5) {//异业店 + $re_qy = $this->mdDifferentQy->get(['mobile' => $value['owner_mobile']]); + $re_qy && $data['wxqy'] = 1; + } else { + $re_qy = $this->mdWechatqy->get(['mobile' => $value['owner_mobile']]); + if ($re_qy) { + $data['wxqy'] = 1; + } else { + $re_use = $this->mdUsers->get(['mobile' => $value['owner_mobile'], 'status<>' => -1]); + if ($re_use['unionid']) { + $re_qy = $this->mdWechatqy->get(['unionid' => $re_use['unionid']]); + $re_qy && $data['wxqy'] = 1; + } + } + } + } + $re = $this->mdOwners->get(['o_id' => $value['id']]); + if ($re) { + $data['u_time'] = $re['u_time']; + $this->mdOwners->update($data, ['id' => $re['id']]); + } else { + $data['c_time'] = time(); + $data['u_time'] = '0000-00-00 00:00:00'; + $id = $this->mdOwners->add($data); + if ($id) { + $log[] = ['id' => $id, 'name' => $data['name'], 'mobile' => $data['mobile']]; + $counts++; + } + } + } + echo '
成功更新：'; + $log && print_r($log); + echo '

数据库获取：'; + echo json_encode($res, JSON_UNESCAPED_UNICODE); + header('refresh:3;url=/plan/temp/add_owners?counts=' . $counts . '&size=' . $param['size'] . '&page=' . ($param['page'] + 1)); + ob_end_flush();//输出全部内容到浏览器 + } + /** * Notes:更新客户初始销售 * Created on: 2022/7/26 11:58