Browse Source

达人失败数据接口

zhaoxian 2 năm trước cách đây
mục cha
commit
af7c12d199

+ 9 - 0
ruixuan-live/src/main/java/com/ruixuan/isc/controller/KuaishouPromoterController.java

@@ -82,6 +82,15 @@ public class KuaishouPromoterController extends BaseController {
     /**
      * 获取快手达人信息
      */
+    @GetMapping(value = "/supplementInfo")
+    @ApiOperation(value = "补全失败的数据")
+    public String supplementInfo() {
+        return kuaishouPromoterService.supplementInfo();
+    }
+
+    /**
+     * 获取快手达人信息
+     */
     @GetMapping(value = "/getPromoterInfo")
     @ApiOperation(value = "获取快手达人短视频信息")
     public AjaxResult getPromoterInfo(@ApiParam("达人ID") @RequestParam(value = "promoterId", required = true) Long promoterId) {

+ 2 - 0
ruixuan-live/src/main/java/com/ruixuan/isc/mapper/KuaishouPromoterMapper.java

@@ -69,4 +69,6 @@ public interface KuaishouPromoterMapper {
     void updateKuaishouPromoterByPromoterId(KuaishouPromoter promoters);
 
     List<KuaishouPromoter> selectAllPromoterList(@Param("promoterId") Long promoterId, @Param("promoterNickName") String promoterNickName, @Param("parameter") String parameter, @Param("orderBy") String orderBy);
+
+    List<KuaishouPromoter> getFailInfo();
 }

+ 2 - 0
ruixuan-live/src/main/java/com/ruixuan/isc/service/IKuaishouPromoterService.java

@@ -62,4 +62,6 @@ public interface IKuaishouPromoterService {
     JSONObject getgetMonthPromoterTotal(List<Long> userList, String start, String end);
 
     List<KuaishouPromoter> selectKuaishouPromoterList2(Long promoterId, String promoterNickName, String parameter, String orderBy);
+
+    String supplementInfo();
 }

+ 30 - 12
ruixuan-live/src/main/java/com/ruixuan/isc/service/impl/KuaishouPromoterServiceImpl.java

@@ -123,8 +123,7 @@ public class KuaishouPromoterServiceImpl implements IKuaishouPromoterService {
                     @Override
                     public void run() {
                         try {
-                            //              demo:PromoterId:1424128656
-                            editPromoter(promoter.getId(), promoter.getPromoterId());
+                            editPromoter(promoter.getId(), promoter.getPromoterId(), true);
                         } catch (Exception e) {
                             e.printStackTrace();
                         }
@@ -163,23 +162,24 @@ public class KuaishouPromoterServiceImpl implements IKuaishouPromoterService {
             promoter.setUserName(sysUser.getNickName());
         }
         int i = kuaishouPromoterMapper.insertKuaishouPromoter(promoter);
-        //              demoPromoterId:1424128656
-        editPromoter(promoter.getId(), promoter.getPromoterId());
+        editPromoter(promoter.getId(), promoter.getPromoterId(), true);
         return i;
     }
 
     /**
      * 同步更新数据
      */
-    private void editPromoter(Long id, Long promoterId) {
+    private void editPromoter(Long id, Long promoterId, boolean flag) {
         try {
-            /*缓存标记,每日第一次访问调用该接口,更新达人部分(昵称,省市,粉丝,总销售,头像等)数据*/
-            String key = DateUtils.getDate() + "_" + id + "_" + promoterId;
-            String value = (String) redisUtil.get(key);
-            if (Check.isNotNull(value) && "1".equals(value)) {
-                return;
+            if (flag) {
+                /*缓存标记,每日第一次访问调用该接口,更新达人部分(昵称,省市,粉丝,总销售,头像等)数据*/
+                String key = DateUtils.getDate() + "_" + id + "_" + promoterId;
+                String value = (String) redisUtil.get(key);
+                if (Check.isNotNull(value) && "1".equals(value)) {
+                    return;
+                }
+                redisUtil.set(key, "1", 60 * 60 * 24);
             }
-            redisUtil.set(key, "1", 60 * 60 * 24);
 
             /*更新达人数据*/
             Map<String, Object> param = new HashMap<>();
@@ -206,6 +206,23 @@ public class KuaishouPromoterServiceImpl implements IKuaishouPromoterService {
         }
     }
 
+    @Override
+    public String supplementInfo() {
+        List<KuaishouPromoter> list = kuaishouPromoterMapper.getFailInfo();
+        Thread thread = new Thread() {
+            @Override
+            public void run() {
+                try {
+                    list.forEach(kuaishouPromoter -> editPromoter(kuaishouPromoter.getId(), kuaishouPromoter.getPromoterId(), false));
+                } catch (Exception e) {
+                    e.printStackTrace();
+                }
+            }
+        };
+        thread.start();
+        return "共计" + list.size() + "条,数据补充中...";
+    }
+
     /**
      * 修改快手达人 信息
      *
@@ -247,7 +264,7 @@ public class KuaishouPromoterServiceImpl implements IKuaishouPromoterService {
                     @Override
                     public void run() {
                         try {
-                            editPromoter(promoter.getId(), promoter.getPromoterId());
+                            editPromoter(promoter.getId(), promoter.getPromoterId(), true);
                         } catch (Exception e) {
                             e.printStackTrace();
                         }
@@ -297,4 +314,5 @@ public class KuaishouPromoterServiceImpl implements IKuaishouPromoterService {
     public JSONObject getgetMonthPromoterTotal(List<Long> userList, String start, String end) {
         return kuaishouPromoterMapper.getgetMonthPromoterTotal(userList, start, end);
     }
+
 }

+ 5 - 0
ruixuan-live/src/main/resources/mapper/isc/KuaishouPromoterMapper.xml

@@ -134,6 +134,11 @@
         where id = #{id}
     </select>
 
+    <select id="getFailInfo" resultMap="KuaishouPromoterResult">
+        <include refid="selectKuaishouPromoterVo"/>
+        where promoter_nick_name = '' or promoter_nick_name is null
+    </select>
+
     <select id="selectPromoterIdList" resultType="Long">
         select promoter_id
         from kuaishou_promoter