收藏客户

application/api_broker/controller/CollectUser.php

@@ -55,19 +55,28 @@ class CollectUser extends Basic
         }
 
 
-        if($params["status"] == 1){
-            //收藏
+        //先判断是否已经存在数据
+        $field = 'id,status';
+        $get_params['agents_id']     = $params["agents_id"];
+        $get_params['user_id']      = $params["user_id"];
+        $res = $this->aCollectUser->getCollectUser($field,$get_params);
+
+        if($res && (count($res) == 1)){//如果存在
+            if($res[0]['status'] != $params["status"] ){//如果存在-并且状态一致   不作处理 不一致则更新状态
+                $insert["id"]       = $res[0]['id'];
+                $insert["status"]   = $params["status"];
+                $res = $this->aCollectUser->updateCollectUser($insert);//int(1)
+            }else{
+                $res = true ;
+            }
+        }else{//不存在则新增数据
+            if(count($res) > 1){
+                $this->aCollectUser->updateStatus($params["agents_id"],$params["user_id"]);
+            }
             $insert["agents_id"]    = $params['agents_id'];
             $insert["user_id"]     = $params['user_id'];
             $insert["status"]       = 1;
-            $is_saved = $this->aCollectUser->getCollectUser('id',$insert);
-            if($is_saved){
-                return $this->response("200", "成功");
-            }
-            $res = $this->aCollectUser->saveCollectUser($insert);
-        }else{
-            //取消收藏
-            $res = $this->aCollectUser->updateStatus($params['agents_id'],$params['user_id']);
+            $res = $this->aCollectUser->saveCollectUser($insert);//int(1)
         }
 
         if ($res) {

application/model/ACollectUser.php

@@ -85,7 +85,7 @@ class ACollectUser extends Model
     {
         $result = $this->where(['agents_id'=>$agents_id,'user_id'=>$user_id])->update(['status'=>2]);
         //dump($this->getLastSql());
-        big_log($this->getLastSql());
+        // big_log($this->getLastSql());
         return $result;
     }