Jelajahi Sumber

Merge branch 'master' into test

yumeng 3 tahun lalu
induk
melakukan
ca9aee784e

+ 7 - 5
jeecg-boot-module-system/src/main/java/org/jeecg/modules/ctop/controller/ProjectMemberController.java

@@ -192,10 +192,12 @@ public class ProjectMemberController {
                 Map<Long, List<JSONObject>> accountMap = userAllocationService.getAccountListByProjectList(projectList);
                 for (int i = 0; i < projectList.size(); i++) {
                     JSONObject project = projectList.get(i);
-                    List<JSONObject> accountList = accountMap.get(project.getLong("projectId"));
-                    if (!Check.isNull(accountList)) {
-                        project.put("accountList", accountList);
-                        haveList.add(project);
+                    if (!Check.isNull(project)) {
+                        List<JSONObject> accountList = accountMap.get(project.getLong("projectId"));
+                        if (!Check.isNull(accountList)) {
+                            project.put("accountList", accountList);
+                            haveList.add(project);
+                        }
                     }
                 }
             }
@@ -326,7 +328,7 @@ public class ProjectMemberController {
                 throw new Exception("请选择项目");
             }
             Project project = projectService.getById(projectId);
-            if(Check.isNull(project)){
+            if (Check.isNull(project)) {
                 throw new Exception("项目不存在");
             }
             JSONArray memberArr = jsonObject.getJSONArray("memberArr");

+ 7 - 4
module-common/src/main/java/cn/com/ctop/common/module/service/impl/UserAllocationServiceImpl.java

@@ -3,6 +3,7 @@ package cn.com.ctop.common.module.service.impl;
 import cn.com.ctop.common.module.entity.UserAllocation;
 import cn.com.ctop.common.module.mapper.UserAllocationMapper;
 import cn.com.ctop.common.module.service.IUserAllocationService;
+import cn.com.ctop.common.module.utils.Check;
 import cn.com.ctop.common.module.utils.CtopAdConstant;
 import cn.com.ctop.common.module.utils.ResultMapUtils;
 import cn.com.ctop.common.module.utils.StatusCode;
@@ -169,8 +170,10 @@ public class UserAllocationServiceImpl extends ServiceImpl<UserAllocationMapper,
         List list = new ArrayList();
         for (int i = 0; i < projectList.size(); i++) {
             JSONObject jsonObject = projectList.get(i);
-            list.add(jsonObject.getLong("projectId"));
-            map.put(jsonObject.getLong("projectId"), new ArrayList<>());
+            if (!Check.isNull(jsonObject)) {
+                list.add(jsonObject.getLong("projectId"));
+                map.put(jsonObject.getLong("projectId"), new ArrayList<>());
+            }
         }
         List<JSONObject> jsonList = userAllocationMapper.getAccountListByProjectList(list);
         for (int i = 0; i < jsonList.size(); i++) {
@@ -209,8 +212,8 @@ public class UserAllocationServiceImpl extends ServiceImpl<UserAllocationMapper,
 
     @Override
     public boolean updateProjectStrategyStatus(Long accountId, Integer projectStrategy) {
-        int num  = userAllocationMapper.updateProjectStrategyStatus(accountId, projectStrategy);
-        return num>0;
+        int num = userAllocationMapper.updateProjectStrategyStatus(accountId, projectStrategy);
+        return num > 0;
     }
 
     @Override

+ 4 - 4
module-job-kuaishou/src/main/java/cn/com/ctop/job/kuaishou/handler/KuaishouDimensionCreateJob.java

@@ -32,15 +32,15 @@ public class KuaishouDimensionCreateJob {
     @Value("${xxl-job.requestUrl}")
     private String jobUrl;
 
-    @XxlJob("createUnit")
-    public void createUnit() throws Exception {
+    @XxlJob("dimensionCreateUnit")
+    public void dimensionCreateUnit() throws Exception {
         QueryWrapper<KuaiShouDimensionStrategy> queryWrapper = new QueryWrapper<>();
         queryWrapper.eq("strategy_status", 0);
         List<KuaiShouDimensionStrategy> list = strategyService.list(queryWrapper);
         if (Check.isNull(list)) {
             return;
         }
-        String url = jobUrl + "/dimension/kuaiShouDimensionAccount/createUnit";
+        String url = jobUrl + "/jeecg-boot/dimension/kuaiShouDimensionAccount/createUnit";
         for (KuaiShouDimensionStrategy strategy : list) {
             try {
                 Map<String, Object> requestMap = new HashMap<>();
@@ -59,7 +59,7 @@ public class KuaishouDimensionCreateJob {
             log.info("暂无待提交创意账户");
             return;
         }
-        String url = jobUrl + "/dimension/kuaiShouDimensionCreative/againCreateCreative";
+        String url = jobUrl + "/jeecg-boot/dimension/kuaiShouDimensionCreative/againCreateCreative";
         for (int i = 0; i < accountIds.size(); i++) {
             Long accountId = accountIds.get(i);
             try {

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

@@ -170,7 +170,9 @@ public class KuaishouAppPackageServiceImpl extends ServiceImpl<KuaishouAppPackag
             return Result.error("数据异常,重复的应用标记:" + errVersion.substring(0, errVersion.length() - 1));
         }
         appPackageMapper.replaceBatch(appList);
-        kuaishouMaterialPoolOperationRecordService.addRecord(JSONObject.parseObject(JSONObject.toJSONString(appList)).toJavaObject(JSONObject.class), "/importAppExcel", 3, "add");
+        for (KuaishouAppPackage aPackage : appList) {
+            kuaishouMaterialPoolOperationRecordService.addRecord(JSONObject.parseObject(JSONObject.toJSONString(aPackage)).toJavaObject(JSONObject.class), "/importAppExcel", 3, "add");
+        }
         return Result.ok("文件导入成功");
     }
 

+ 7 - 4
module-kuaishou/src/main/java/cn/com/ctop/kuaishou/modules/batch/mapper/xml/KuaiShouVideoGetMapper.xml

@@ -317,11 +317,14 @@
     </select>
 
     <select id="getAccountIds" resultType="com.alibaba.fastjson.JSONObject">
-        SELECT account_id 'accountId',DATE_FORMAT(DATE_SUB(NOW(),INTERVAL 65 MINUTE), '%Y-%m-%d %H:%i:%s') 'startDate'
-        FROM ctop_kuaishou_video_get
+        SELECT t1.account_id 'accountId',DATE_FORMAT(DATE_SUB(NOW(),INTERVAL 15 MINUTE), '%Y-%m-%d %H:%i:%s') 'startDate'
+        FROM ctop_kuaishou_video_get t1
+                 LEFT JOIN ctop_user_allocation t2 ON t1.account_id = t2.account_id
         where channel_type = 1
-          and status = 0
-        GROUP BY account_id
+          AND t2.account_status = 0
+          AND t1.status = 0
+          AND t1.stat_date >=DATE_FORMAT(DATE_SUB(NOW(),INTERVAL 2 DAY), '%Y-%m-%d')
+        GROUP BY t1.account_id
     </select>
 
     <select id="queryPhotoIdsByProjectAndMd5" resultType="java.lang.String">

+ 1 - 1
module-kuaishou/src/main/java/cn/com/ctop/kuaishou/modules/dimension/controller/KuaiShouDimensionAccountController.java

@@ -57,7 +57,7 @@ public class KuaiShouDimensionAccountController {
 
     @Autowired
     private ICtopOauthTokenService oauthTokenService;
-    static ExecutorService accountService = Executors.newFixedThreadPool(2);
+    static ExecutorService accountService = Executors.newFixedThreadPool(5);
 
 
     /**

+ 1 - 1
module-kuaishou/src/main/java/cn/com/ctop/kuaishou/modules/dimension/service/impl/KuaiShouDimensionUnitServiceImpl.java

@@ -53,7 +53,7 @@ public class KuaiShouDimensionUnitServiceImpl extends ServiceImpl<KuaiShouDimens
         unitQueryWrapper.eq("account_id", accountId);
         unitQueryWrapper.eq("submit_status", 1);
         unitQueryWrapper.orderByAsc("create_time");
-        unitQueryWrapper.last("limit 50");
+        unitQueryWrapper.last("limit 10");
         List<KuaiShouDimensionUnit> kuaiShouDimensionUnits = dimensionUnitMapper.selectList(unitQueryWrapper);
         if (Check.isNull(kuaiShouDimensionUnits)) {
             return;