客方 新增 编辑 查询

application/index/service/UserAgentService.php

@@ -9,7 +9,7 @@
 namespace app\index\service;
 
 
-use app\model\UserAgent;
+use app\model\UserAgentModel;
 use app\model\Users;
 
 class UserAgentService
@@ -20,35 +20,62 @@ class UserAgentService
     public function __construct()
     {
         $this->m_user = new Users();
-        $this->m_user_agent = new UserAgent();
+        $this->m_user_agent = new UserAgentModel();
     }
 
 
+    /**
+     * 新增客方
+     * @param $agent_id
+     * @param $user_id
+     * @param $site_id
+     * @return bool
+     */
     public function addUserAgent($agent_id,$user_id,$site_id)
     {
-        $user_info = $this->user->getUserById($field = 'referrer_id', $user_id);
-        if($user_info['referrer_id'] > 0){
+        $user_agent_info = $this->findUserAgent($agent_id,$user_id,$site_id);
+        if($user_agent_info){
             return false;
         }
+        $params['user_id']=$user_id;
+        $params['site_id']=$site_id;
+        $params['agent_id']=$agent_id;
+        $add_res = $this->m_user_agent->saveUserAgent($params);
         return true;
     }
 
+    /**
+     * 查询客方
+     * @param $agent_id
+     * @param $user_id
+     * @param $site_id
+     * @return array|bool|false|\PDOStatement|string|\think\Model
+     */
     public function findUserAgent($agent_id,$user_id,$site_id)
     {
-        $user_info = $this->user->getUserById($field = 'referrer_id', $user_id);
-        if($user_info['referrer_id'] > 0){
+        $params['user_id']=$user_id;
+        $params['site_id']=$site_id;
+        $params['agent_id']=$agent_id;
+        $field = 'a.id,a.user_id,a.site_id,a.agent_id,c.name,c.phone';
+        $user_agent_info = $this->m_user_agent->getUserAgent($field,$params);
+        if(!$user_agent_info){
             return false;
         }
-        return true;
+        return $user_agent_info;
     }
 
+    /**
+     * 修改客方
+     * @param $agent_id
+     * @param $user_id
+     * @param $site_id
+     */
     public function changeUserAgent($agent_id,$user_id,$site_id)
     {
-        $user_info = $this->user->getUserById($field = 'referrer_id', $user_id);
-        if($user_info['referrer_id'] > 0){
-            return false;
-        }
-        return true;
+        $where['user_id']=$user_id;
+        $where['site_id']=$site_id;
+        $params['agent_id']=$agent_id;
+        $change_res = $this->m_user_agent->updateUserAgent($where,$params);
     }
 
 }
\ No newline at end of file

application/model/USpreadUser.php

@@ -20,7 +20,6 @@ class USpreadUser extends Model
 
     /**
      * 查询数据
-     * 朱伟 2018-11-21 10:41:44
      */
     public function getSpreadUser($field,$params,$where_or)
     {
@@ -33,17 +32,6 @@ class USpreadUser extends Model
         return $result;
     }
 
-    /**
-     * 更新数据
-     * 朱伟 2018-11-21 10:41:44
-     */
-    public function updateSpreadUser($params)
-    {
-        $result = $this->update($params);
-        //dump($this->getLastSql());
-        return $result;
-
-    }
 
 
 }

application/model/UserAgentModel.php

@@ -21,19 +21,23 @@ class UserAgentModel extends Model
         $time = date("Y-m-d H:i:s", time());
         $data['create_time'] = $time;
         $data['update_time'] = $time;
+        $data['is_del'] = 0;
         return $this->db_ ->insert($data);
     }
 
     /**
      * 查询数据
      */
-    public function getUserAgent($field,$params,$where_or)
+    public function getUserAgent($field,$params)
     {
+        $params["is_del"] = 0;
         $result = $this->db_
             ->field($field)
+            ->alias('a')
+            ->join('u_users b', 'a.user_id = b.id', 'left')
+            ->join('a_agents c', 'a.agent_id = c.id', 'left')
             ->where($params)
-            ->whereOr($where_or)
-            ->select();
+            ->find();
         //echo $this->getLastSql();
         return $result;
     }
@@ -41,9 +45,9 @@ class UserAgentModel extends Model
     /**
      * 更新数据
      */
-    public function updateUserAgent($params)
+    public function updateUserAgent($where,$params)
     {
-        $result = $this->db_ ->update($params);
+        $result = $this->db_ ->where($where)->update($params);
         //dump($this->getLastSql());
         return $result;