客方同步到新表

application/api_broker/controller/Broker.php

@@ -19,6 +19,7 @@ use app\api_broker\service\OrderLogService;
 use app\api_broker\service\RedisCacheService;
 use app\api_broker\service\VipService;
 use app\extra\RedisExt;
+use app\index\service\UserAgentService;
 use app\index\service\UserService;
 use app\model\AAgents;
 use app\model\ABindingDevice;
@@ -1175,4 +1176,6 @@ class Broker extends Basic
         $data                   = $this->a_agents->getAgentDistrictId("a.id,a.name,a.site_id,b.name", $get_params);
         return $this->response("200", "成功", $data);
     }
+
+
 }
\ No newline at end of file

application/api_broker/controller/User.php

@@ -8,8 +8,10 @@ use app\api_broker\service\ClientService;
 use app\api_broker\service\UserExpiredTimeService;
 use app\api_broker\service\VipService;
 use app\index\service\OfficeUserLogService;
+use app\index\service\UserAgentService;
 use app\index\service\UserLogService;
 use app\index\service\UserService;
+use app\index\service\UserSiteService;
 use app\model\AAgents;
 use app\model\GOperatingRecords;
 use app\model\ULabels;
@@ -902,4 +904,33 @@ class User extends Basic
     }
 
 
+
+    /**
+     * 客方同步到新表
+     * @return bool
+     */
+    public function moveHouseAgent()
+    {
+        ini_set('memory_limit', '500M'); //内存限制
+        set_time_limit(0); //
+        $s_user_agent = new UserAgentService();
+        $res = $s_user_agent->moveHouse();
+        return $res;
+    }
+
+
+    /**
+     * 站点同步到新表
+     * @return bool
+     */
+    public function moveHouseSiteId()
+    {
+        ini_set('memory_limit', '500M'); //内存限制
+        set_time_limit(0);
+
+        $s = new UserSiteService();
+        $res = $s->moveUserSite();
+        return $res;
+    }
+
 }
\ No newline at end of file

application/index/controller/ImageDepot.php

@@ -170,13 +170,14 @@ class ImageDepot extends Basic
     }
 
 
-    public function ceshi()
+    public function moveHouse()
     {
         // $s = new PositionService();
         // // $res =  $s->getPositionDistance('31.067059,121.518854','31.079655,121.51713');
         // $res =  $s->getPositionDistance('31.170841,121.463858','31.17265,121.464914');
         // dump($res);
-
+        ini_set('memory_limit', '500M'); //内存限制
+        set_time_limit(0); //
         $s_user_agent = new UserAgentService();
         $res = $s_user_agent->moveHouse();
 

application/index/service/UserAgentService.php

@@ -104,6 +104,9 @@ class UserAgentService
      * 处理老数据
      */
     public function moveHouse(){
+        ini_set('memory_limit', '500M'); //内存限制
+        set_time_limit(0); //
+
         $limit = 1000;
 
         $user_count = $this->moveHouseCount();
@@ -114,7 +117,7 @@ class UserAgentService
             $res =  $this->moveHouseSaveData($page,$limit);
             big_log($res);
         }
-        return;
+        return true;
     }
 
     /**
@@ -132,6 +135,13 @@ class UserAgentService
             $site_ids = explode(',', $v['site_id']);
             foreach ($site_ids as $k1 => $v1) {
                 // dump($v1);exit;
+                $is_save = $this->isSaveEd($v['user_id'],$v['agent_id'],$v['site_id']);
+                big_log('检查是否已经存在数据！');
+                big_log($is_save);
+                if($is_save){
+                    big_log('存在跳出循环！');
+                    continue;
+                }
                 $a = [];
                 $a['user_id'] = $v['user_id'];
                 $a['site_id'] = $v1;
@@ -146,6 +156,24 @@ class UserAgentService
         return $user_insert;
     }
 
+    /**
+     * 查询当前关系是否已经存在
+     * @param $user_id
+     * @param $agent_id
+     * @param $site_id
+     * @return false|\PDOStatement|string|\think\Collection
+     */
+    public function isSaveEd($user_id,$agent_id,$site_id){
+        $params = [];
+        $params["user_id"] = $user_id;
+        $params["site_id"] = $site_id;
+        $params["agent_id"] = $agent_id;
+        $m_user_agent = new UserAgentModel();
+        $field = 'user_id';
+        $res = $m_user_agent->selectUser($field,$params);
+        return $res;
+    }
+
     /*
      * 符合要求的客户数量
      */

application/route.php

@@ -956,6 +956,10 @@ Route::group('broker', [
     'getOpenList' => ['api_broker/PayLogOpen/getOpenList', ['method' => 'GET|POST']],
     'openCheck'   => ['api_broker/PayLogOpen/openCheck', ['method' => 'GET|POST']],
 
+
+    'moveHouseAgent'   => ['api_broker/User/moveHouseAgent', ['method' => 'GET|POST']],//客方同步到新表
+    'moveHouseSiteId'   => ['api_broker/User/moveHouseSiteId', ['method' => 'GET|POST']],//站点同步到新表
+
 ]);
 
 Route::group('search', [