Переглянути джерело

人群包从快手后台删除留存记录2

zhaoxian 4 роки тому
батько
коміт
b0baa9a42c

+ 5 - 1
module-job-kuaishou/src/main/java/cn/com/ctop/job/kuaishou/handler/CrowdListQueryJob.java

@@ -59,6 +59,7 @@ public class CrowdListQueryJob {
                         if (!Check.isNull(data)) {
                             JSONArray details = data.getJSONArray("details");
                             if (details.size() > 0) {
+                                List<KuaishouPopulationPackageRel> rellist = new ArrayList<>();
                                 for (int j = 0; j < details.size(); j++) {
                                     JSONObject obj = details.getJSONObject(j);
                                     KuaishouPopulationPackageRel rel = JSONObject.parseObject(obj.toJSONString(), KuaishouPopulationPackageRel.class);
@@ -67,12 +68,15 @@ public class CrowdListQueryJob {
                                         rel.setProjectId(projectId);
                                         rel.setDataStatus(1);
                                         rel.setStatDate(DateUtils.formatDate(new Date()));
-                                        relService.save(rel);
+                                        rellist.add(rel);
                                     } else {
                                         rel.setDataStatus(1);
                                         relMapper.updateStatus(rel);
                                     }
                                 }
+                                if (!Check.isNull(rellist)) {
+                                    relMapper.replaceBatch(rellist);
+                                }
                             }
                         }
                     }

+ 5 - 1
module-kuaishou/src/main/java/cn/com/ctop/kuaishou/modules/ai/service/impl/KuaishouPopulationPackageServiceImpl.java

@@ -292,6 +292,7 @@ public class KuaishouPopulationPackageServiceImpl extends ServiceImpl<KuaishouPo
                             if (!Check.isNull(data)) {
                                 JSONArray details = data.getJSONArray("details");
                                 if (details.size() > 0) {
+                                    List<KuaishouPopulationPackageRel> list = new ArrayList<>();
                                     for (int j = 0; j < details.size(); j++) {
                                         JSONObject obj = details.getJSONObject(j);
                                         KuaishouPopulationPackageRel rel = JSONObject.parseObject(obj.toJSONString(), KuaishouPopulationPackageRel.class);
@@ -300,12 +301,15 @@ public class KuaishouPopulationPackageServiceImpl extends ServiceImpl<KuaishouPo
                                             rel.setProjectId(projectId);
                                             rel.setDataStatus(1);
                                             rel.setStatDate(DateUtils.formatDate(new Date()));
-                                            relService.save(rel);
+                                            list.add(rel);
                                         } else {
                                             rel.setDataStatus(1);
                                             relMapper.updateStatus(rel);
                                         }
                                     }
+                                    if (!Check.isNull(list)) {
+                                        relMapper.replaceBatch(list);
+                                    }
                                 }
                             }
                         }