客户重复检测

app/crm/controller/CustomerController.php

@@ -163,7 +163,7 @@ class CustomerController extends BaseController
         $perPage = $request->input('size', 10);
         $where = [
             ['user_id', '=', $userId],
-//            ['corp_abbr', '=', $request->basic_data['corp_abbr']],
+            //['corp_abbr', '=', $request->basic_data['corp_abbr']],
             ['follow_next', '<>', 0],
         ];
 
@@ -306,6 +306,7 @@ class CustomerController extends BaseController
         $contacts = Util::getParam($request, 'contacts');
         $email = Util::getParam($request, 'email');
         $phone = Util::getParam($request, 'phone');
+        $whatsApp = Util::getParam($request, 'WhatsApp', '');
         if (Util::isEmpty($contacts) && Util::isEmpty($email) && Util::isEmpty($phone)) {
             return $this->error(trans('contacts_not_null'));
         }
@@ -314,7 +315,7 @@ class CustomerController extends BaseController
         $corpId = $corpInfo->id;
         $data = [
             'user_id' => $request->user->uid,
-            'corp_abbr' => $corpId,
+            'corp_id' => $corpId,
             'grade' => Util::getParam($request, 'grade', 0),
             'channel_id' => $channel_id,
             'country_id' => $country_id,
@@ -322,7 +323,7 @@ class CustomerController extends BaseController
             'magnitude' => Util::getParam($request, 'magnitude', 0),
             'email' => $email,
             'phone' => $phone,
-            'WhatsApp' => Util::getParam($request, 'WhatsApp', ''),
+            'WhatsApp' => $whatsApp,
             'contacts' => $contacts,
             'describe' => Util::getParam($request, 'describe'),
             'lat' => Util::getParam($request, 'lat', 0),
@@ -335,6 +336,15 @@ class CustomerController extends BaseController
 
         if (Util::isEmpty($id)) {
             $data['enter_user_id'] = $request->user->uid;
+            $distinct = [
+                'email' => $email,
+                'phone' => $phone,
+                'whatsapp' => $whatsApp,
+            ];
+            $dis = (new CustomerService())->distinct($distinct,$corpId);
+            if($dis){
+                return $this->error('客户线索重复，已经有人在跟进');
+            }
             $res = Customer::create($data);
         } else {
             unset($data['grade']);
@@ -506,12 +516,14 @@ class CustomerController extends BaseController
     {
         $customerId = Util::getParam($request, 'customer_id');
         $userId = $request->user->uid;
+        $user = User::where(['id' => $userId])->first();
         if (Util::isEmpty($customerId)) {
             return $this->error(trans('customer_id').trans('not_null'));
         }
         $data = [
             'user_id' => $request->user->uid,
             'obtain' => time(),
+            'corp_id' => $user->corp_id,
         ];
 
         try {
@@ -592,6 +604,7 @@ class CustomerController extends BaseController
             $data = [
                 'user_id' => $user->id,
                 'obtain' => time(),
+                'corp_id' => $user->corp_id,
             ];
             $res = $query->update($data);