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 {