From 89b6bdd9f66948d2fd9ae5eefd66988c6887e87f Mon Sep 17 00:00:00 2001 From: dengbw Date: Tue, 21 Jun 2022 17:11:10 +0800 Subject: [PATCH] owners_621 --- api/controllers/plan/Liche.php | 73 +++++++++++++++++++++++++++++++- api/controllers/plan/Plan.php | 1 + api/controllers/plan/Temp.php | 75 +++++++++++++++++++++++++++++++++ home/controllers/h5/Persona.php | 9 +++- 4 files changed, 155 insertions(+), 3 deletions(-) diff --git a/api/controllers/plan/Liche.php b/api/controllers/plan/Liche.php index 61be9d4f..f566245e 100644 --- a/api/controllers/plan/Liche.php +++ b/api/controllers/plan/Liche.php @@ -12,6 +12,75 @@ class Liche extends HD_Controller parent::__construct(); } + /** + * Notes:更新车主企业微信 + * Created on: 2022/6/21 16:00 + * Created by: dengbw + * https://liche-api-dev.xiaoyu.com/plan/liche/owners_wxqy?rds=1 + * https://api.liche.cn/plan/liche/owners_wxqy + */ + public function owners_wxqy() + { + $params = $this->input->get(); + $size = 100;//每次最多处理多少条 + $rds = intval($this->input->get('rds')); + $redis = &load_cache('redis'); + $redisKey = 'update_owners_wxqy_c_time'; + if ($rds) { + $redis->delete($redisKey); + } + $c_time = $redis->get($redisKey); + !$c_time && $c_time = strtotime(date('Y-m-d') . ' 00:00:00'); + $log = []; + $this->load->model('app/app_lichene_qy_log_model', 'mdWechatqyLog'); + $this->load->model('app/app_lichene_qy_model', 'mdWechatqy'); + $this->load->model('receiver/receiver_owners_model', 'mdOwners'); + $this->load->model('app/liche/app_liche_users_model', 'mdUsers'); + $res = $this->mdWechatqyLog->select(["c_time>=" => $c_time, "change_type in('add_external_contact','edit_external_contact')" => null] + , 'c_time asc', 1, $size, 'change_type,external_userid,c_time'); + if (!$res) { + if ($params['rds']) { + echo '1执行到当前c_time：' . date('Y-m-d H:i:s', $c_time) . '暂无数据'; + } + return; + } + foreach ($res as $key => $value) { + $c_time = $value['c_time']; + if ($value['external_userid']) { + $re_qy = $this->mdWechatqy->get(['external_userid' => $value['external_userid']]); + $mobile = $re_qy['mobile']; + $type = 1; + if (!$mobile && $re_qy['unionid']) { + $re_use = $this->mdUsers->get(['unionid' => $re_qy['unionid']]); + if ($re_use['mobile']) { + $type = 2; + $mobile = $re_use['mobile']; + } + } + if ($mobile) { + $re_own = $this->mdOwners->get(['mobile' => $mobile]); + if ($re_own) { + $this->mdOwners->update(['wxqy' => 1], ['id' => $re_own['id']]); + if ($params['rds']) { + $log[] = ['mobile' => $mobile, 'type' => $type]; + } + } + } + } + } + $redis->save($redisKey, $c_time); + if ($params['rds']) { + echo '
2执行到当前c_time：' . date('Y-m-d H:i:s', $c_time); + echo '
成功新增：
'; + if ($log) { + echo json_encode($log, JSON_UNESCAPED_UNICODE); + echo '
'; + } + echo '数据库获取：
'; + echo json_encode($res, JSON_UNESCAPED_UNICODE); + } + } + /** * Notes:新增车主信息 * Created on: 2022/6/14 17:15 @@ -78,7 +147,9 @@ class Liche extends HD_Controller } else { $data['c_time'] = time(); $id = $this->mdOwners->add($data); - $id && $log[] = ['id' => $id, 'name' => $data['name'], 'mobile' => $data['mobile']]; + if ($id && $params['rds']) { + $log[] = ['id' => $id, 'name' => $data['name'], 'mobile' => $data['mobile']]; + } } } $redis->save($redisKey, $c_time); diff --git a/api/controllers/plan/Plan.php b/api/controllers/plan/Plan.php index 34e31a02..b2ea8f9e 100644 --- a/api/controllers/plan/Plan.php +++ b/api/controllers/plan/Plan.php @@ -38,6 +38,7 @@ class Plan extends CI_Controller $plan[] = array('url' => base_url(array('plan', 'licheb', 'users_log')), 'interval' => 2);//顾问日志 $plan[] = array('url' => base_url(array('plan', 'liche', 'add_owners')), 'interval' => 5);//新增车主 + $plan[] = array('url' => base_url(array('plan', 'liche', 'owners_wxqy')), 'interval' => 60);//更新车主企业微信 $plan[] = array('url' => base_url(array('plan', 'items', 'stock_log')), 'interval' => 5);//库存车辆日志 diff --git a/api/controllers/plan/Temp.php b/api/controllers/plan/Temp.php index 3b1da2b0..5b63a18a 100644 --- a/api/controllers/plan/Temp.php +++ b/api/controllers/plan/Temp.php @@ -16,6 +16,81 @@ class Temp extends HD_Controller $this->log_file = 'temp.log'; } + /** + * Notes:车主企业微信/城市 + * Created on: 2022/6/21 11:58 + * Created by: dengbw + * https://liche-api-dev.xiaoyu.com/plan/temp/receiver_owners_wxqy + * https://api.liche.cn/plan/temp/receiver_owners_wxqy + */ + public function receiver_owners_wxqy() + { + $this->load->model('receiver/receiver_owners_model', 'mdOwners'); + $mobile = '1113860199646'; + $ret = $this->mdOwners->update(['wxqy' => 1], ['mobile' => $mobile]); + print_r($ret); + exit; + $this->load->model('receiver/order/receiver_orders_v2_model', 'mdOrders'); + $this->load->model("biz/biz_model", 'mdBiz'); + $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'); + $param = $this->input->get(); + $param['page'] = intval($param['page']); + $param['size'] = intval($param['size']); + !$param['size'] && $param['size'] = 100; + !$param['page'] && $param['page'] = 1; + $counts = intval($param['counts']); + ob_start(); //打开缓冲区 + $res = $this->mdOwners->select(['status>=' => 0], 'id asc', $param['page'], $param['size'], 'id,o_id,mobile'); + if (!$res) { + echo '
本次更新完成了：'; + echo '

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

点击将再次更新>>>'; + exit; + } + $log = array(); + foreach ($res as $key => $value) { + $update = ''; + if ($value['o_id']) {//查找门店城市 + $re_ord = $this->mdOrders->get(['id' => $value['o_id']]); + if ($re_ord['biz_id']) { + $re_biz = $this->mdBiz->get(['id' => $re_ord['biz_id']]); + if ($re_biz) { + $update['province_id'] = $re_biz['province_id']; + $update['city_id'] = $re_biz['city_id']; + $update['county_id'] = $re_biz['county_id']; + } + } + } + if ($value['mobile']) {//查找企微 + $re_qy = $this->mdWechatqy->get(['mobile' => $value['mobile']]); + if ($re_qy) { + $update['wxqy'] = 1; + } else { + $re_use = $this->mdUsers->get(['mobile' => $value['mobile'], 'status<>' => -1]); + if ($re_use['unionid']) { + $re_qy = $this->mdWechatqy->get(['unionid' => $re_use['unionid']]); + $re_qy && $update['wxqy'] = 1; + } + } + } + if ($update) { + $this->mdOwners->update($update, ['id' => $value['id']]); + $log[] = array_merge($update, ['mobile' => $value['mobile']]); + $counts++; + } + } + echo '
成功更新：'; + if ($log) { + echo json_encode($log, JSON_UNESCAPED_UNICODE); + } + echo '

数据库获取：'; + echo json_encode($res, JSON_UNESCAPED_UNICODE); + header('refresh:3;url=/plan/temp/receiver_owners_wxqy?counts=' . $counts . '&size=' . $param['size'] . '&page=' . ($param['page'] + 1)); + ob_end_flush();//输出全部内容到浏览器 + } + /** * Notes:加车主（状态交易完成） * Created on: 2022/5/27 11:58 diff --git a/home/controllers/h5/Persona.php b/home/controllers/h5/Persona.php index 841f7f57..5f8b21e3 100644 --- a/home/controllers/h5/Persona.php +++ b/home/controllers/h5/Persona.php @@ -229,8 +229,13 @@ class Persona extends CI_Controller $c_id = $userInfo['c_id']; $result = $re_cus = ''; if ($c_id) {//已存在客户,更新资料 - $up_data = ['of_id' => $params['of_id'], 'of2_id' => $params['of2_id'], 'buddy_type' => $params['buddy_type'] - , 'wxqy' => 1]; + $up_data = ['of_id' => $params['of_id'], 'of2_id' => $params['of2_id'], 'buddy_type' => $params['buddy_type']]; + $re_cus2 = $this->mdCustomers->get(['id' => $c_id, 'status<>' => -1]); + if (!$re_cus2) { + $this->show_json(200, '客户不存在'); + } + $re_cus2['wxqy'] != 1 && $up_data['wxqy'] = 1; + !$re_cus2['unionid'] && $up_data['unionid'] = $userInfo['unionid']; $result = $this->mdCustomers->update($up_data, ['id' => $c_id]); $this->customers_entity->add_log($c_id, $userInfo['admin_id'], $userInfo['admin_name'], '修改用户基本信息'); } else {