@@ -260,7 +271,7 @@
lists: [],
qdjl_lists: [],
admins: {cityAry: [], countyAry: [], bizAry: [], list: []},
- show_info: {levelAry: [], offlineSourcesAry: []},
+ show_info: {levelAry: [], offlineSourcesAry: [], wxqyAry: []},
of2Ary: [],
},
mounted: function () {
diff --git a/api/controllers/plan/Temp.php b/api/controllers/plan/Temp.php
index f8da015c..7971d31a 100644
--- a/api/controllers/plan/Temp.php
+++ b/api/controllers/plan/Temp.php
@@ -16,6 +16,80 @@ class Temp extends HD_Controller
$this->log_file = 'temp.log';
}
+ /**
+ * Notes:更新战败客户到店
+ * Created on: 2022/3/09 11:58
+ * Created by: dengbw
+ * https://liche-api-dev.xiaoyu.com/plan/temp/receiver_customers_wxqy
+ * https://api.liche.cn/plan/temp/receiver_customers_wxqy
+ */
+ public function receiver_customers_wxqy()
+ {
+ $this->load->model('app/app_lichene_qy_log_model', 'mdWechatqyLog');
+ $this->load->model('receiver/receiver_customers_model', 'mdCustomers');
+ $this->load->model('app/licheb/App_licheb_users_model', 'mdUsers');
+ $this->load->library('wx_qyapi', ['app' => 'lichene']);
+ $param = $this->input->get();
+ $param['page'] = intval($param['page']);
+ $param['size'] = intval($param['size']);
+ !$param['size'] && $param['size'] = 2;
+ !$param['page'] && $param['page'] = 1;
+ $counts = intval($param['counts']);
+ ob_start(); //打开缓冲区
+ $where = ["change_type<>" => 'edit_external_contact'];
+ $res = $this->mdWechatqyLog->select($where, 'c_time ASC', $param['page'], $param['size']);
+ if (!$res) {
+ echo '
本次更新完成了：';
+ echo '
成功更新
' . $counts . ' 条';
+ echo '
点击将再次更新>>>';
+ exit;
+ }
+ $log = array();
+ foreach ($res as $key => $value) {
+ if ($value['userid'] && $value['external_userid']) {
+ $re_wx = $this->wx_qyapi->get_external_contact(array('url' => 'user_get', 'userid' => $value['userid']));
+ if ($re_wx['errcode'] == 0 && $re_wx['mobile']) {//获取企业成员手机
+ $re_use = $this->mdUsers->get(array('mobile' => $re_wx['mobile']));
+ $biz_id = intval($re_use['biz_id']);
+ if ($biz_id) {
+ $re_wx = $this->wx_qyapi->get_external_contact(array('url' => 'get', 'external_userid' => $value['external_userid']));
+ if ($re_wx['errcode'] == 0) {
+ $follow_user = [];
+ foreach ($re_wx['follow_user'] as $key => $val) {
+ if ($val['userid'] == $value['userid']) {//找出当前企业员工
+ $follow_user = $val;
+ break;
+ }
+ }
+ $remark_mobiles = $follow_user['remark_mobiles'];//用户手机
+ if ($remark_mobiles && $remark_mobiles != '[]' && is_array($remark_mobiles)) {
+ $mobile = $remark_mobiles[0];//取第一个手机号
+ if ($mobile) {
+ if ($value['change_type'] == 'add_external_contact') {//新增
+ $wxqy = 1;
+ } else {//删除
+ $wxqy = -1;
+ }
+ $ret = $this->mdCustomers->update(['wxqy' => $wxqy], ['mobile' => $mobile, 'biz_id' => $biz_id]);
+ if ($ret == 1) {
+ $log[] = ['mobile' => $mobile, 'biz_id' => $biz_id, 'wxqy' => $wxqy];
+ $counts++;
+ }
+ }
+ }
+ }
+ }
+ }
+ }
+ }
+ echo '
成功更新：';
+ $log && print_r($log);
+ echo '
数据库获取：';
+ echo json_encode($res, JSON_UNESCAPED_UNICODE);
+ header('refresh:3;url=/plan/temp/receiver_customers_wxqy?counts=' . $counts . '&size=' . $param['size'] . '&page=' . ($param['page'] + 1));
+ ob_end_flush();//输出全部内容到浏览器
+ }
+
/**
* Notes:更新战败客户到店
* Created on: 2022/3/09 11:58
diff --git a/api/controllers/wechat/Lichene.php b/api/controllers/wechat/Lichene.php
index 5c08eb3e..131ba4aa 100644
--- a/api/controllers/wechat/Lichene.php
+++ b/api/controllers/wechat/Lichene.php
@@ -82,21 +82,52 @@ Class Lichene extends HD_Controller
if ($re_msg['ChangeType']) {
$change_type = $this->mdWechatqyLog->change_type($re_msg['ChangeType']);
$userid = $re_msg['UserID'];
- if ($change_type && $userid) {//只记录现有的
- $this->load->model('app/licheb/App_licheb_users_model', 'mdUsers');
- $re_use = $this->mdUsers->get(['userid' => $userid]);
- if (!$re_use) {//企业成员关连狸车宝用户
+ $ExternalUserID = $re_msg['ExternalUserID'];
+ if ($change_type) {//只记录现有的
+ if ($userid) {//企业成员
+ $this->load->model('app/licheb/App_licheb_users_model', 'mdUsers');
$this->load->library('wx_qyapi', ['app' => 'lichene']);
- $re_wx = $this->wx_qyapi->get_external_contact(array('url' => 'user_get', 'userid' => $userid));
- if ($re_wx['errcode'] == 0 && $re_wx['mobile']) {//获取企业成员手机
- $re_use = $this->mdUsers->get(array('mobile' => $re_wx['mobile']));
- if ($re_use) {//userid与手机绑定关连
- $this->mdUsers->update(['userid' => $userid], ['id' => $re_use['id']]);
+ $re_use = $this->mdUsers->get(['userid' => $userid]);
+ if (!$re_use) {//企业成员关连狸车宝用户
+ $re_wx = $this->wx_qyapi->get_external_contact(array('url' => 'user_get', 'userid' => $userid));
+ if ($re_wx['errcode'] == 0 && $re_wx['mobile']) {//获取企业成员手机
+ $re_use = $this->mdUsers->get(array('mobile' => $re_wx['mobile']));
+ if ($re_use) {//userid与手机绑定关连
+ $this->mdUsers->update(['userid' => $userid], ['id' => $re_use['id']]);
+ }
+ }
+ }
+ $re_msg['log_id'] = $this->mdWechatqyLog->add(['external_userid' => $ExternalUserID, 'userid' => $userid,
+ 'change_type' => $re_msg['ChangeType'], 'remark' => $change_type, 'c_time' => $re_msg['CreateTime']]);
+ $wxqy = 0;
+ if ($re_msg['ChangeType'] == 'add_external_contact') {//新增
+ $wxqy = 1;
+ } else if ($re_msg['ChangeType'] == 'del_external_contact' || $re_msg['ChangeType'] == 'del_follow_user') {//删除
+ $wxqy = -1;
+ }
+ if ($wxqy && $re_use && $ExternalUserID) {//查找关连企微客户
+ $re_wx = $this->wx_qyapi->get_external_contact(array('url' => 'get', 'external_userid' => $ExternalUserID));
+ if ($re_wx['errcode'] == 0) {
+ $follow_user = [];
+ foreach ($re_wx['follow_user'] as $key => $val) {
+ if ($val['userid'] == $userid) {//找出当前企业员工
+ $follow_user = $val;
+ break;
+ }
+ }
+ $remark_mobiles = $follow_user['remark_mobiles'];//用户手机
+ if ($remark_mobiles && $remark_mobiles != '[]' && is_array($remark_mobiles)) {
+ $mobile = $remark_mobiles[0];//取第一个手机号
+ $biz_id = intval($re_use['biz_id']);
+ if ($mobile && $biz_id) {
+ $this->load->model('receiver/receiver_customers_model', 'mdCustomers');
+ $ret = $this->mdCustomers->update(['wxqy' => $wxqy], ['mobile' => $mobile, 'biz_id' => $biz_id]);
+ $ret && $re_msg['wxqy'] = $wxqy . '_' . $mobile . '_' . $biz_id;
+ }
+ }
}
}
}
- $re_msg['log_id'] = $this->mdWechatqyLog->add(['external_userid' => $re_msg['ExternalUserID'], 'userid' => $userid,
- 'change_type' => $re_msg['ChangeType'], 'remark' => $change_type, 'c_time' => $re_msg['CreateTime']]);
}
}
debug_log('qymsg_sMsg:' . json_encode($re_msg, JSON_UNESCAPED_UNICODE), $this->log_file);
diff --git a/common/models/receiver/Receiver_customers_model.php b/common/models/receiver/Receiver_customers_model.php
index b11d22b6..9ff3252e 100644
--- a/common/models/receiver/Receiver_customers_model.php
+++ b/common/models/receiver/Receiver_customers_model.php
@@ -92,6 +92,23 @@ class Receiver_customers_model extends HD_Model
}
}
+ /**
+ * Notes:企微好友状态
+ * Created on: 2022/5/10 10:00
+ * Created by: dengbw
+ * @param int $id
+ * @return array|mixed
+ */
+ public function wxqyAry($id)
+ {
+ $arr = [0 => '未添加', 1 => '已添加', -1 => '删除'];
+ if (strlen($id)) {
+ return $arr[$id];
+ } else {
+ return $arr;
+ }
+ }
+
public function count_order($where)
{
return $this->select_order($where, '', '', '', '', 1);
diff --git a/home/controllers/h5/Persona.php b/home/controllers/h5/Persona.php
index b56e8a13..c7867fca 100644
--- a/home/controllers/h5/Persona.php
+++ b/home/controllers/h5/Persona.php
@@ -224,7 +224,7 @@ class Persona extends CI_Controller
if ($mobile && $biz_id) {//有手机号查找客户是否已存在
$re_cus = $this->mdCustomers->get(['biz_id' => $biz_id, 'mobile' => $mobile, 'status<>' => -1]);
if ($re_cus) {//已存客户绑定操作,不带入现有标签中
- $result = $this->mdCustomers->update(['unionid' => $userInfo['unionid']], ['id' => $re_cus['id']]);
+ $result = $this->mdCustomers->update(['unionid' => $userInfo['unionid'], 'wxqy' => 1], ['id' => $re_cus['id']]);
} else {//创建新客户
$this->load->model("biz/biz_model", 'mdBiz');
$re_biz = $this->mdBiz->get(['id' => $biz_id, 'status' => 1]);
@@ -240,6 +240,7 @@ class Persona extends CI_Controller
'city_id' => $city_id,
'county_id' => $county_id,
'unionid' => $userInfo['unionid'],
+ 'wxqy' => 1,
'of_id' => $params['of_id'],
'of2_id' => $params['of2_id'],
'cf_title' => '自有资源',