演出预告列表任务配置

liquidnet-bus-feign/liquidnet-api-feign-kylin/src/main/java/com/liquidnet/service/feign/kylin/api/FeignKylinForChimeClient.java

@@ -52,4 +52,8 @@ public interface FeignKylinForChimeClient {
     ResponseDto<KylinPerformanceVo> getDetail(
             @RequestParam("performancesId") String performancesId
     );
+
+
+    @GetMapping("inner/setNoticeIds")
+    ResponseDto<HashMap<String,Object>> setNoticeIds();
 }

liquidnet-bus-service/liquidnet-service-executor-all/liquidnet-service-executor-main/src/main/java/com/liquidnet/service/executor/main/handler/KylinTaskHandler.java

 package com.liquidnet.service.executor.main.handler;
 
+import com.liquidnet.service.feign.kylin.api.FeignKylinForChimeClient;
 import com.liquidnet.service.feign.kylin.task.FeignPlatformTaskClient;
 import com.xxl.job.core.context.XxlJobHelper;
 import com.xxl.job.core.handler.annotation.XxlJob;
@@ -19,6 +20,9 @@ public class KylinTaskHandler {
     @Autowired
     private FeignPlatformTaskClient feignPlatformTaskClient;
 
+    @Autowired
+    private FeignKylinForChimeClient feignKylinForChimeClient;
+
     @XxlJob(value = "sev-platform:checkOrderTimeHandler")
     public void checkOrderTimeHandler() {
         try {
@@ -68,4 +72,14 @@ public class KylinTaskHandler {
             XxlJobHelper.handleFail();
         }
     }
+
+    @XxlJob(value = "sev-platform:setNoticeIds")
+    public void setNoticeIds() {
+        try {
+            XxlJobHelper.handleSuccess("结果：" + feignKylinForChimeClient.setNoticeIds().getData());
+        } catch (Exception e) {
+            XxlJobHelper.log(e);
+            XxlJobHelper.handleFail();
+        }
+    }
 }

liquidnet-bus-service/liquidnet-service-kylin/liquidnet-service-kylin-impl/src/main/java/com/liquidnet/service/kylin/controller/InnerController.java

@@ -68,11 +68,11 @@ public class InnerController {
         }
     }
 
-    @GetMapping("setRedisIds")
+    @GetMapping("/setNoticeIds")
     @ApiOperation("演出预告列表定时任务")
-    public void setRedisIds(){
-        HashMap<String,Object> map = kylinPerformancesService.setRedisIds();
-        log.debug("演出预告列表"+map);
+    public ResponseDto<HashMap<String,Object>> setNoticeIds(){
+        HashMap<String, Object> map = kylinPerformancesService.setNoticeIds();
+        return ResponseDto.success(map);
     }
 
 }

liquidnet-bus-service/liquidnet-service-kylin/liquidnet-service-kylin-impl/src/main/java/com/liquidnet/service/kylin/service/impl/KylinPerformancesServiceImpl.java

@@ -175,8 +175,8 @@ public class KylinPerformancesServiceImpl implements IKylinPerformancesService {
         return newList;
     }
 
-    public HashMap<String,Object> setRedisIds() {
-        return dataUtils.setRedisIds();
+    public HashMap<String,Object> setNoticeIds() {
+        return dataUtils.setNoticeIds();
     }
 
     private List<KylinPerformanceVo> mergeRoadList(List<KylinPerformanceVo> performanceList) {

liquidnet-bus-service/liquidnet-service-kylin/liquidnet-service-kylin-impl/src/main/java/com/liquidnet/service/kylin/utils/DataUtils.java

@@ -462,7 +462,7 @@ public class DataUtils {
     }
 
     //执行脚本
-    public HashMap<String, Object> setRedisIds() {
+    public HashMap<String, Object> setNoticeIds() {
         // 固定条件
         Query query = getCommonWhere();
         // 排序