From 4a74644a0eb502707647844c791007b6ffff6b63 Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?=E5=BC=A0=E8=90=8C?= <494089941@qq.com> Date: Tue, 7 Mar 2023 10:06:37 +0800 Subject: [PATCH] =?UTF-8?q?=E6=96=B0=E5=95=86=E6=9C=BA=E6=8F=90=E9=86=92?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- application/admin/model/Message.php | 15 ++++++++++++--- application/crm/controller/Message.php | 25 ++++++++++++++++++++++--- application/crm/model/Business.php | 25 +++++++++++++++++++++++++ 3 files changed, 59 insertions(+), 6 deletions(-) diff --git a/application/admin/model/Message.php b/application/admin/model/Message.php index 306f58a..2719292 100644 --- a/application/admin/model/Message.php +++ b/application/admin/model/Message.php @@ -279,17 +279,21 @@ class Message extends Common */ const CUSTOMER_CHECK_PASS = 59; /** - * 客户待审批 + * 商机推进待审批 */ const BUSINESS_ADVANCE_CHECK_TO_DO = 60; /** - * 客户待审批 + * 商机推进待审批 */ const BUSINESS_ADVANCE_CHECK_REJECT = 61; /** - * 客户待审批 + * 商机推进待审批 */ const BUSINESS_ADVANCE_CHECK_PASS = 62; + /** + * 新商机 + */ + const BUSINESS_NEW = 63; /** * 消息类型 @@ -401,6 +405,9 @@ class Message extends Common 32 => [ 'template' => '{from_user} 将您添加为线索 {title} 的成员。', ], + 63 => [ + 'template' => '{from_user} 创建了新的商机', + ] ]; /** @@ -454,6 +461,7 @@ class Message extends Common self::BUSINESS_ADVANCE_CHECK_TO_DO, self::BUSINESS_ADVANCE_CHECK_REJECT, self::BUSINESS_ADVANCE_CHECK_PASS, + self::BUSINESS_NEW, ], 'jxc' => [ self::PURCHASE_TO_DO, @@ -627,6 +635,7 @@ class Message extends Common case self::BUSINESS_ADVANCE_CHECK_TO_DO: case self::BUSINESS_ADVANCE_CHECK_REJECT: case self::BUSINESS_ADVANCE_CHECK_PASS: + case self::BUSINESS_NEW: return BusinessModel::where(['business_id' => $data['action_id']])->value('name') ?: ''; // 采购单 diff --git a/application/crm/controller/Message.php b/application/crm/controller/Message.php index cdf188f..ccfc0fd 100644 --- a/application/crm/controller/Message.php +++ b/application/crm/controller/Message.php @@ -613,6 +613,8 @@ class Message extends ApiCommon if ($isSub) { $param['owner_user_id'] = array('in', getSubUserId(false)); } + $businessIdArray = db('crm_dealt_relation')->where(['types' => ['eq', 'crm_business_new'], 'user_id' => ['eq', $param['user_id']]])->column('types_id'); + $param['businessIdArray'] = !empty($businessIdArray) ? $businessIdArray : -1; $data = $businessModel->getDataList($param); // p($contractModel->getLastSql()); if ($types == 'list') { @@ -774,7 +776,7 @@ class Message extends ApiCommon } # 处理待审核合同、回款、发票 - if (in_array($type, ['checkContract', 'checkReceivables', 'checkInvoice', 'checkBusiness'])) { + if (in_array($type, ['checkContract', 'checkReceivables', 'checkInvoice', 'checkBusiness','checkCustomerCheck','new_business'])) { $where['check_status'] = ['lt', '2']; $where['check_user_id'] = ['like', ',%' . $userId . '%,']; @@ -795,8 +797,19 @@ class Message extends ApiCommon } # 商机 if ($type == 'checkBusiness') { - $invoiceId = !empty($typeId) ? $typeId : Db::name('crm_business')->where($where)->column('business_id'); - db('crm_dealt_relation')->where('user_id', $userId)->where('types', 'crm_business')->whereIn('types_id', $invoiceId)->delete(); + $businessId = !empty($typeId) ? $typeId : Db::name('crm_business')->where($where)->column('business_id'); + db('crm_dealt_relation')->where('user_id', $userId)->where('types', 'crm_business')->whereIn('types_id', $businessId)->delete(); + } + # 客户捞取 + if ($type == 'checkCustomerCheck') { + $customerCheckId = !empty($typeId) ? $typeId : Db::name('crm_customer_check')->where($where)->column('customer_check_id'); + db('crm_dealt_relation')->where('user_id', $userId)->where('types', 'crm_customer_check')->whereIn('types_id', $customerCheckId)->delete(); + } + + # 新商机 + if ($type == 'new_business') { + $newBusinessId = !empty($typeId) ? $typeId : Db::name('crm_business')->where($where)->column('business_id'); + db('crm_dealt_relation')->where('user_id', $userId)->where('types', 'crm_business_new')->whereIn('types_id', $newBusinessId)->delete(); } } @@ -884,6 +897,9 @@ class Message extends ApiCommon cache::rm('visitContractCount' . $userId); cache::rm('endContractCount' . $userId); cache::rm('remindCustomerCount' . $userId); + cache::rm('checkCustomerCheckCount' . $userId); + cache::rm('checkBusinessCount' . $userId); + cache::rm('newBusinessCount' . $userId); cache::rm('todayLeadsTime' . $userId); cache::rm('todayCustomerTime' . $userId); @@ -898,6 +914,9 @@ class Message extends ApiCommon cache::rm('visitContractTime' . $userId); cache::rm('endContractTime' . $userId); cache::rm('remindCustomerTime' . $userId); + cache::rm('checkCustomerCheckTime' . $userId); + cache::rm('checkBusinessTime' . $userId); + cache::rm('newBusinessTime' . $userId); return resultArray(['data' => '操作成功！']); } } \ No newline at end of file diff --git a/application/crm/model/Business.php b/application/crm/model/Business.php index d2caf71..1c7e92d 100644 --- a/application/crm/model/Business.php +++ b/application/crm/model/Business.php @@ -6,6 +6,7 @@ // +---------------------------------------------------------------------- namespace app\crm\model; +use app\admin\model\Message; use app\admin\traits\FieldVerificationTrait; use think\Db; use app\admin\model\Common; @@ -394,6 +395,30 @@ class Business extends Common } } + //站内信 + $send_user_id = stringToArray(getUserSuperior($param['create_user_id'])); + (new Message())->send( + Message::CUSTOMER_CHECK_TO_DO, + [ + 'title' => $param['name'], + 'action_id' => $this->business_id + ], + $send_user_id + ); + + $data = []; + $data['business_id'] = $this->business_id; + # 创建待办事项的关联数据 + $dealtData = []; + foreach ($send_user_id as $kk => $vv) { + $dealtData[] = [ + 'types' => 'crm_business_new', + 'types_id' => $data['business_id'], + 'user_id' => $vv + ]; + } + if (!empty($dealtData)) db('crm_dealt_relation')->insertAll($dealtData); + # 设置今日需联系商机 if (!empty($param['next_time']) && $param['next_time'] >= strtotime(date('Y-m-d 00:00:00'))) $param['is_dealt'] = 0;