+券发放JOB调度;

liquidnet-bus-feign/liquidnet-api-feign-platform/src/main/java/com/liquidnet/service/feign/platform/task/FeignPlatformCandyTaskClient.java

+package com.liquidnet.service.feign.platform.task;
+
+import com.liquidnet.service.base.ResponseDto;
+import feign.hystrix.FallbackFactory;
+import org.springframework.cloud.openfeign.FeignClient;
+import org.springframework.stereotype.Component;
+import org.springframework.web.bind.annotation.PutMapping;
+
+@Component
+@FeignClient(
+        name = "liquidnet-service-platform",
+        contextId = "FeignPlatformCandyTaskClient",
+        path = "platform",
+        fallback = FallbackFactory.Default.class
+)
+public interface FeignPlatformCandyTaskClient {
+
+    @PutMapping("/candy/task/issue/coupons")
+    ResponseDto<String> issueCoupons();
+}

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

 package com.liquidnet.service.executor.main.handler;
 
+import com.liquidnet.service.base.ResponseDto;
 import com.liquidnet.service.feign.kylin.task.FeignPlatformAlipayBackClient;
+import com.liquidnet.service.feign.platform.task.FeignPlatformCandyTaskClient;
 import com.xxl.job.core.biz.model.ReturnT;
 import com.xxl.job.core.handler.annotation.XxlJob;
 import org.slf4j.Logger;
@@ -17,6 +19,8 @@ public class PlatformTaskHandler {
 
     @Autowired
     private FeignPlatformAlipayBackClient feignPlatformAlipayBackClient;
+    @Autowired
+    private FeignPlatformCandyTaskClient feignPlatformCandyTaskClient;
 
     @XxlJob(value = "sev-platform:alipayActiveCallbackHandler")
     public ReturnT<String> alipayActiveCallbackHandler() {
@@ -29,4 +33,15 @@ public class PlatformTaskHandler {
         }
     }
 
+    @XxlJob(value = "sev-platform:candyCouponIssuanceHandler")
+    public ReturnT<String> candyCouponIssuanceHandler() {
+        try {
+            ResponseDto<String> dto = feignPlatformCandyTaskClient.issueCoupons();
+            log.info("result of handler:{}", dto.toJson());
+            return ReturnT.SUCCESS;
+        } catch (Exception e) {
+            log.error("exception of handler:{}", e.getMessage(), e);
+            return ReturnT.FAIL;
+        }
+    }
 }