Prechádzať zdrojové kódy

添加自动创建定时任务

songyh 4 rokov pred
rodič
commit
b8183cb764

+ 1 - 1
jeecg-boot-bytedance/src/main/java/org/jeecg/modules/bytedance/advertise/service/IAiBytedanceAdvertiserStrategyService.java

@@ -94,7 +94,7 @@ public interface IAiBytedanceAdvertiserStrategyService extends IService<AiByteda
      */
     Result<AiBytedanceAdvertiserStrategy> addBytedanceStrategy(AiBytedanceAdvertiserStrategy aiBytedanceAdvertiserStrategy);
 
-    AiBytedanceAdvertiserStrategy getByAccountId(Long accountId,Integer status);
+    List<AiBytedanceAdvertiserStrategy> getByAccountId(Long accountId,Integer status);
 
     void customCreativeSupplement(AiBytedanceAdvertiserStrategy strategy, Integer hour);
 }

+ 3 - 3
jeecg-boot-bytedance/src/main/java/org/jeecg/modules/bytedance/advertise/service/impl/AiBytedanceAdvertiserStrategyServiceImpl.java

@@ -1155,7 +1155,7 @@ public class AiBytedanceAdvertiserStrategyServiceImpl extends ServiceImpl<AiByte
     }
 
     @Override
-    public AiBytedanceAdvertiserStrategy getByAccountId(Long accountId,Integer status) {
+    public List<AiBytedanceAdvertiserStrategy> getByAccountId(Long accountId,Integer status) {
         QueryWrapper<AiBytedanceAdvertiserStrategy> queryWrapper = new QueryWrapper<>();
         if(null!=accountId){
             queryWrapper.eq("account_id",accountId);
@@ -1163,8 +1163,8 @@ public class AiBytedanceAdvertiserStrategyServiceImpl extends ServiceImpl<AiByte
         if(null!=status){
             queryWrapper.eq("status",status);
         }
-        queryWrapper.orderByDesc("id").last("limit 1");
-        return this.getOne(queryWrapper);
+        queryWrapper.orderByDesc("id");
+        return this.list(queryWrapper);
     }
 
     @Autowired

+ 17 - 7
jeecg-boot-module-system/src/main/java/org/jeecg/modules/bytedance/advertise/controller/AiBytedanceAdvertiserStrategyController.java

@@ -315,12 +315,23 @@ public class AiBytedanceAdvertiserStrategyController {
 	@GetMapping("testCreateCreativeLimit")
 	public Map<String, Object> testCreateCreativeLimit(Long accountId, Integer hour) {
 		Map<String, Object> result = new HashMap<>();
-		AiBytedanceAdvertiserStrategy strategy = aiBytedanceAdvertiserStrategyService.getByAccountId(accountId,0);
-		if (strategy == null) {
+		List<AiBytedanceAdvertiserStrategy> strategys = aiBytedanceAdvertiserStrategyService.getByAccountId(accountId,0);
+//		aiBytedanceAdvertiserStrategyService.customCreativeSupplement(strategy, hour);
+		ResultMapUtils.setResultMap(result, StatusCode.COMMON_SUCCESS);
+		return result;
+	}
+
+	@GetMapping("autoCreateCreative")
+	public Map<String, Object> autoCreateCreative(Integer hour) {
+		Map<String, Object> result = new HashMap<>();
+		List<AiBytedanceAdvertiserStrategy> strategys = aiBytedanceAdvertiserStrategyService.getByAccountId(null,0);
+		if (strategys == null||strategys.isEmpty()) {
 			ResultMapUtils.setResultMap(result, StatusCode.COMMON_PARAM_ERROR);
 			return result;
 		}
-		aiBytedanceAdvertiserStrategyService.customCreativeSupplement(strategy, hour);
+		strategys.forEach(strategy -> {
+			aiBytedanceAdvertiserStrategyService.customCreativeSupplement(strategy, hour);
+		});
 		ResultMapUtils.setResultMap(result, StatusCode.COMMON_SUCCESS);
 		return result;
 	}
@@ -331,17 +342,16 @@ public class AiBytedanceAdvertiserStrategyController {
 
 	/**
 	 *
-	 * @description:根据下载链接获取应用包名
+	 * 根据下载链接获取应用包名
 	 *
 	 * @param downloadType 类型
 	 * @param urlPath 下载链接
-	 * @return: org.jeecg.common.api.vo.Result
-	 * @author: zianY
+	 * @return org.jeecg.common.api.vo.Result
+	 * @author zianY
 	 */
 	@ApiOperation(value="根据下载链接获取应用包名", notes="根据下载链接获取应用包名")
 	@GetMapping(value = "/getPackageNameByUrl")
 	public Result getPackageNameByUrl(@RequestParam("downloadType") String downloadType,@RequestParam("urlPath") String urlPath) {
-
 		try {
 			Map map = new HashMap();
 			//根据下载链接上传附件