From 9de3b06f53fbcd01997cdaa57fc2302a535f7089 Mon Sep 17 00:00:00 2001
From: =?UTF-8?q?=E5=BC=A0=E8=90=8C?= <494089941@qq.com>
Date: Fri, 3 Mar 2023 18:33:36 +0800
Subject: [PATCH] =?UTF-8?q?=E5=BE=85=E5=8A=9E=E4=BA=8B=E9=A1=B9=E6=B7=BB?=
 =?UTF-8?q?=E5=8A=A0=E8=AE=B0=E5=BD=95=E6=B7=BB=E5=8A=A0?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 application/crm/controller/Business.php | 15 +++++++++++++++
 application/crm/controller/Message.php  |  7 ++++++-
 application/crm/logic/MessageLogic.php  |  2 +-
 3 files changed, 22 insertions(+), 2 deletions(-)

diff --git a/application/crm/controller/Business.php b/application/crm/controller/Business.php
index d6473d6..f5d8b28 100644
--- a/application/crm/controller/Business.php
+++ b/application/crm/controller/Business.php
@@ -628,6 +628,21 @@ class Business extends ApiCommon
                     'customer_ids' => ',' . $businessInfo['customer_id'] . ','
                 ]);
 
+                # 删除待办事项的关联数据
+                db('crm_dealt_relation')->where(['types' => ['eq', 'crm_business'], 'types_id' => ['eq', $data['business_id']]])->delete();
+                # 创建待办事项的关联数据
+                $checkUserIds = db('crm_business')->where('business_id', $data['business_id'])->value('check_user_id');
+                $checkUserIdArray = stringToArray($checkUserIds);
+                $dealtData = [];
+                foreach ($checkUserIdArray AS $kk => $vv) {
+                    $dealtData[] = [
+                        'types'    => 'crm_business',
+                        'types_id' => $data['business_id'],
+                        'user_id'  => $vv
+                    ];
+                }
+                if (!empty($dealtData)) db('crm_dealt_relation')->insertAll($dealtData);
+
                 //推进记录添加
                 $temp['status_id'] = $status_id ?: 0;
                 $temp['is_end'] = $businessInfo['is_end'] ?: 0;
diff --git a/application/crm/controller/Message.php b/application/crm/controller/Message.php
index 79e220f..356fa0b 100644
--- a/application/crm/controller/Message.php
+++ b/application/crm/controller/Message.php
@@ -735,7 +735,7 @@ class Message extends ApiCommon
         }
 
         # 处理待审核合同、回款、发票
-        if (in_array($type, ['checkContract', 'checkReceivables', 'checkInvoice'])) {
+        if (in_array($type, ['checkContract', 'checkReceivables', 'checkInvoice','checkBusiness'])) {
             $where['check_status'] = ['lt', '2'];
             $where['check_user_id'] = ['like', ',%' . $userId . '%,'];
 
@@ -754,6 +754,11 @@ class Message extends ApiCommon
                 $invoiceId = !empty($typeId) ? $typeId : Db::name('crm_invoice')->where($where)->column('invoice_id');
                 db('crm_dealt_relation')->where('user_id', $userId)->where('types', 'crm_invoice')->whereIn('types_id', $invoiceId)->delete();
             }
+            # 商机
+            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();
+            }
 
         }
 
diff --git a/application/crm/logic/MessageLogic.php b/application/crm/logic/MessageLogic.php
index da2d9e8..e4fbd05 100644
--- a/application/crm/logic/MessageLogic.php
+++ b/application/crm/logic/MessageLogic.php
@@ -248,7 +248,7 @@ class MessageLogic extends Common
                     # 待审核、审核中
                     $param['check_status']  = ['lt', 2];
                     $param['check_user_id'] = ['like', '%,'. $param['user_id'] .',%'];
-                    # 要提醒的发票ID
+                    # 要提醒的商机ID
                     $businessIdArray = db('crm_dealt_relation')->where(['types' => ['eq', 'crm_business'], 'user_id' => ['eq', $param['user_id']]])->column('types_id');
                     $param['businessIdArray'] = !empty($businessIdArray) ? $businessIdArray : -1;
                     $param['dealt'] = 1;