diff --git a/api/controllers/plan/Temp.php b/api/controllers/plan/Temp.php
index 84d97318..be3565a4 100644
--- a/api/controllers/plan/Temp.php
+++ b/api/controllers/plan/Temp.php
@@ -16,6 +16,88 @@ 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/receiver_customer_sales
+ * https://api.liche.cn/plan/temp/receiver_customer_sales
+ */
+ public function receiver_customer_sales()
+ {
+ $this->load->model('receiver/receiver_customers_model', 'mdCustomers');
+ $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(); //打开缓冲区
+ $where = array("admin_id>" => 0);
+ $res = $this->mdCustomers->select($where, 'id ASC', $param['page'], $param['size'], 'id,admin_id,sales_id');
+ if (!$res) {
+ echo '
本次更新客户初始销售完成了:';
+ echo '
成功更新 ' . $counts . ' 条';
+ echo '
点击将再次更新客户初始销售>>>';
+ exit;
+ }
+ $log = array();
+ foreach ($res as $key => $value) {
+ if (!$value['sales_id']) {
+ $this->mdCustomers->update(['sales_id' => $value['admin_id']], ['id' => $value['id']]);
+ $log[] = array('id' => $value['id'], 'sales_id' => $value['admin_id']);
+ $counts++;
+ }
+ }
+ echo '
成功更新:';
+ $log && print_r($log);
+ echo '
数据库获取:';
+ echo json_encode($res, JSON_UNESCAPED_UNICODE);
+ header('refresh:3;url=/plan/temp/receiver_customer_sales?counts=' . $counts . '&size=' . $param['size'] . '&page=' . ($param['page'] + 1));
+ ob_end_flush();//输出全部内容到浏览器
+ }
+
+ /**
+ * Notes:更新订单初始销售
+ * Created on: 2022/7/26 11:58
+ * Created by: dengbw
+ * https://liche-api-dev.xiaoyu.com/plan/temp/receiver_ordersv2_sales
+ * https://api.liche.cn/plan/temp/receiver_ordersv2_sales
+ */
+ public function receiver_ordersv2_sales()
+ {
+ $this->load->model('receiver/order/receiver_orders_v2_model', 'mdOrdersV2');
+ $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(); //打开缓冲区
+ $where = array("sale_id>" => 0);
+ $res = $this->mdOrdersV2->select($where, 'id ASC', $param['page'], $param['size'], 'id,admin_id,sale_id');
+ if (!$res) {
+ echo '
本次更新订单初始销售完成了:';
+ echo '
成功更新 ' . $counts . ' 条';
+ echo '
点击将再次更新订单初始销售>>>';
+ exit;
+ }
+ $log = array();
+ foreach ($res as $key => $value) {
+ if (!$value['admin_id']) {
+ $this->mdOrdersV2->update(['admin_id' => $value['sale_id']], ['id' => $value['id']]);
+ $log[] = array('id' => $value['id'], 'admin_id' => $value['sale_id']);
+ $counts++;
+ }
+ }
+ echo '
成功更新:';
+ $log && print_r($log);
+ echo '
数据库获取:';
+ echo json_encode($res, JSON_UNESCAPED_UNICODE);
+ header('refresh:3;url=/plan/temp/receiver_ordersv2_sales?counts=' . $counts . '&size=' . $param['size'] . '&page=' . ($param['page'] + 1));
+ ob_end_flush();//输出全部内容到浏览器
+ }
+
/**
* Notes:更新顾问日志
* Created on: 2022/7/11 11:58
@@ -737,47 +819,6 @@ class Temp extends HD_Controller
}
}
- /**
- * Notes:更新客户初始销售
- * Created on: 2022/3/09 11:58
- * Created by: dengbw
- * https://liche-api-dev.xiaoyu.com/plan/temp/receiver_customer_sales
- * https://api.liche.cn/plan/temp/receiver_customer_sales
- */
- public function receiver_customer_sales()
- {
- $this->load->model('receiver/receiver_customers_model', 'mdCustomers');
- $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(); //打开缓冲区
- $where = array("admin_id>" => 0);
- $res = $this->mdCustomers->select($where, 'id ASC', $param['page'], $param['size'], 'id,admin_id,sales_id');
- if (!$res) {
- echo '
本次更新客户初始销售完成了:';
- echo '
成功更新 ' . $counts . ' 条';
- echo '
点击将再次更新客户初始销售>>>';
- exit;
- }
- $log = array();
- foreach ($res as $key => $value) {
- if (!$value['sales_id']) {
- $this->mdCustomers->update(['sales_id' => $value['admin_id']], ['id' => $value['id']]);
- $log[] = array('id' => $value['id'], 'sales_id' => $value['admin_id']);
- $counts++;
- }
- }
- echo '
成功更新:';
- $log && print_r($log);
- echo '
数据库获取:';
- echo json_encode($res, JSON_UNESCAPED_UNICODE);
- header('refresh:3;url=/plan/temp/receiver_customer_sales?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/wxapp/licheb/CusorderV2.php b/api/controllers/wxapp/licheb/CusorderV2.php
index 6f74e81e..71e661ed 100644
--- a/api/controllers/wxapp/licheb/CusorderV2.php
+++ b/api/controllers/wxapp/licheb/CusorderV2.php
@@ -283,6 +283,7 @@ class CusorderV2 extends Wxapp{
'name' => $name ? $name : $row['name'],
'mobile' => $mobile ? $mobile : $row['mobile'],
'biz_id' => $this->biz_id,
+ 'admin_id' => $this->session['uid'],
'sale_id' => $this->session['uid'],
'c_time' => time()
];