评价转换

application/index/service/BrokerService.php

@@ -19,6 +19,7 @@ use app\model\ADistrict;
 use app\model\AOperatingRecords;
 use app\model\ASite;
 use app\model\AuthGroupSite;
+use app\model\Evaluate;
 use app\model\GHousesToAgents;
 use app\model\GOperatingRecords;
 use app\model\OMarchInModel;
@@ -52,8 +53,10 @@ class BrokerService
         $select_where['name'] = $data['name'];
         $select_where['site_id'] = $data['site_id'];
         if (empty($data['id'])) {
+            $select_where['status'] = 0;
             $select_where['phone'] = ['<>', $data['phone']];
         } else {
+            $select_where['status'] = 0;
             $select_where['id'] = ['<>', $data['id']];
         }
         $check_id = $this->m_agent->getAgentsByWhere($select_where, 'id');
@@ -341,20 +344,24 @@ class BrokerService
 
                     unset($data['id']);
                     $data['password_md5'] = $agent_old[0]['password'];
+                    $data['img'] = $agent_old[0]['img'];
                     $id = $this->m_agent->saveAgent($data); //普通转勤
                     $this->transferUserHouse($id, $agent_old[0]['id'], $operation_id, $data);
+                    $this->transferEvaluate($id, $agent_old[0]['id']);
                 } else {
                     $agent_old[0]['status'] = 3;
                     unset($agent_old[0]['id']);
                     $this->m_agent->saveAgent($agent_old[0]);  //新增一条转勤状态
 
                     $data['id'] = $agent_old[0]['id'];     //将原来的id作为新的
+                    $data['img'] = $agent_old[0]['img'];
                     $id = $this->m_agent->saveAgent($data);
                 }
             } else {
                 $this->m_agent->saveAgent(['id'=>$agent_old[0]['id'], 'status'=>3]);  //将原来的设置为转勤状态
-                $this->m_agent->saveAgent(['id'=>$transfer_agent, 'status'=>0]);  //将原来转勤状态处理为正常
+                $this->m_agent->saveAgent(['id'=>$transfer_agent, 'status'=>0, 'img'=>$agent_old[0]['img']]);  //将原来转勤状态处理为正常
                 $this->transferUserHouse($transfer_agent, $agent_old[0]['id'], $operation_id, $data);
+                $this->transferEvaluate($transfer_agent, $agent_old[0]['id']);
                 $id = $transfer_agent;
             }
 
@@ -383,17 +390,19 @@ class BrokerService
         $m_user = new Users();
         $update_user = $update_house = [];
         $user_id_arr = $m_user->getUserByWhereColumn(['agent_id' => $change_old_id], 'id');
-        foreach ($user_id_arr as $k => $v) {
+        $referrer_id_arr = $m_user->getUserByWhereColumn(['referrer_id' => $change_old_id, 'referrer_source'=>20], 'id');
+
+        $user_id = array_merge($user_id_arr, $referrer_id_arr);
+        foreach ($user_id as $k => $v) {
             $update_user[$k]['id'] = $v;
             $update_user[$k]['agent_id'] = $id;
         }
-
-        $record_data['user_id'] = empty($user_id_arr) ? "" : implode(',', $user_id_arr);
+        $record_data['user_id'] = empty($user_id) ? "" : implode(',', $user_id);
 
         $m_house = new GHousesToAgents();
         $house_where['is_del'] = 0;
         $house_where['agents_id'] = $change_old_id;
-        $house_where['type'] = ['in', '2,3'];
+//        $house_where['type'] = ['in', '2,3'];
         $house_id_arr = $m_house->getAgentHouseOne('id', $house_where);
 
         foreach ($house_id_arr as $k => $v) {
@@ -454,5 +463,16 @@ class BrokerService
         return true;
     }
 
+    /**
+     * 转换评价
+     *
+     * @param $agent_id
+     * @param $change_old_id
+     * @return Evaluate
+     */
+    public function transferEvaluate($agent_id, $change_old_id){
+        $m_evaluate = new Evaluate();
+        return $m_evaluate->updateData(['agents_id'=>$agent_id], ['agents_id'=>$change_old_id]);
+    }
 
 }
\ No newline at end of file

application/model/Evaluate.php

@@ -193,4 +193,13 @@ class Evaluate extends Model
         //dump($this->getLastSql());
         return $result;
     }
+
+    /**
+     * @param $data
+     * @param $where
+     * @return Evaluate
+     */
+    public function updateData($data, $where) {
+        return $this->where($where)->update($data);
+    }
 }