记得上下班打卡 | git大法好,push需谨慎

Commit c59e76e1 authored by jiangxiulong's avatar jiangxiulong

doTask

parent 70a5e9b8
...@@ -4,6 +4,7 @@ import com.liquidnet.service.base.ResponseDto; ...@@ -4,6 +4,7 @@ import com.liquidnet.service.base.ResponseDto;
import feign.hystrix.FallbackFactory; import feign.hystrix.FallbackFactory;
import org.springframework.cloud.openfeign.FeignClient; import org.springframework.cloud.openfeign.FeignClient;
import org.springframework.stereotype.Component; import org.springframework.stereotype.Component;
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.PutMapping; import org.springframework.web.bind.annotation.PutMapping;
@Component @Component
...@@ -27,4 +28,7 @@ public interface FeignPlatformCandyTaskClient { ...@@ -27,4 +28,7 @@ public interface FeignPlatformCandyTaskClient {
@PutMapping("ccoupon/task/due/user") @PutMapping("ccoupon/task/due/user")
ResponseDto<String> dueProcessForUser(); ResponseDto<String> dueProcessForUser();
@GetMapping("followDoTask/doTask")
ResponseDto doTask();
} }
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.GetMapping;
@Component
@FeignClient(
name = "liquidnet-service-platform",
contextId = "FeignPlatformTaskClient",
path = "platform",
url = "${liquidnet.service.platform.url}",
fallback = FallbackFactory.Default.class
)
public interface FeignPlatformTaskClient {
@GetMapping("followDoTask/doTask")
ResponseDto doTask();
}
...@@ -4,7 +4,6 @@ import com.liquidnet.commons.lang.util.JsonUtils; ...@@ -4,7 +4,6 @@ import com.liquidnet.commons.lang.util.JsonUtils;
import com.liquidnet.service.base.ResponseDto; import com.liquidnet.service.base.ResponseDto;
import com.liquidnet.service.feign.kylin.task.FeignPlatformAlipayBackClient; import com.liquidnet.service.feign.kylin.task.FeignPlatformAlipayBackClient;
import com.liquidnet.service.feign.platform.task.FeignPlatformCandyTaskClient; import com.liquidnet.service.feign.platform.task.FeignPlatformCandyTaskClient;
import com.liquidnet.service.feign.platform.task.FeignPlatformTaskClient;
import com.xxl.job.core.biz.model.ReturnT; import com.xxl.job.core.biz.model.ReturnT;
import com.xxl.job.core.handler.annotation.XxlJob; import com.xxl.job.core.handler.annotation.XxlJob;
import org.slf4j.Logger; import org.slf4j.Logger;
...@@ -23,8 +22,6 @@ public class PlatformTaskHandler { ...@@ -23,8 +22,6 @@ public class PlatformTaskHandler {
private FeignPlatformAlipayBackClient feignPlatformAlipayBackClient; private FeignPlatformAlipayBackClient feignPlatformAlipayBackClient;
@Autowired @Autowired
private FeignPlatformCandyTaskClient feignPlatformCandyTaskClient; private FeignPlatformCandyTaskClient feignPlatformCandyTaskClient;
@Autowired
private FeignPlatformTaskClient feignPlatformTaskClient;
@XxlJob(value = "sev-platform:alipayActiveCallbackHandler") @XxlJob(value = "sev-platform:alipayActiveCallbackHandler")
public ReturnT<String> alipayActiveCallbackHandler() { public ReturnT<String> alipayActiveCallbackHandler() {
...@@ -118,7 +115,7 @@ public class PlatformTaskHandler { ...@@ -118,7 +115,7 @@ public class PlatformTaskHandler {
@XxlJob(value = "sev-platform:followDoTask") @XxlJob(value = "sev-platform:followDoTask")
public ReturnT<String> followDoTask() { public ReturnT<String> followDoTask() {
try { try {
ResponseDto<String> dto = feignPlatformTaskClient.doTask(); ResponseDto<String> dto = feignPlatformCandyTaskClient.doTask();
String dtoStr = JsonUtils.toJson(dto); String dtoStr = JsonUtils.toJson(dto);
log.info("result of handler:{}", dtoStr); log.info("result of handler:{}", dtoStr);
ReturnT<String> success = ReturnT.SUCCESS; ReturnT<String> success = ReturnT.SUCCESS;
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment