超市支付退款feign、executor

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

+package com.liquidnet.service.feign.platform.api;
+
+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 = "FeignPlatformApiClient",
+        path = "platform",
+        url = "${liquidnet.service.platform.url}",
+        fallback = FallbackFactory.Default.class
+)
+public interface FeignPlatformApiClient {
+
+    @GetMapping("refund/overtimeRefund")
+    ResponseDto<String> overtimeRefund();
+
+}

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

@@ -3,6 +3,7 @@ package com.liquidnet.service.executor.main.handler;
 import com.liquidnet.commons.lang.util.JsonUtils;
 import com.liquidnet.service.base.ResponseDto;
 import com.liquidnet.service.feign.kylin.task.FeignPlatformAlipayBackClient;
+import com.liquidnet.service.feign.platform.api.FeignPlatformApiClient;
 import com.liquidnet.service.feign.platform.task.FeignPlatformCandyTaskClient;
 import com.xxl.job.core.biz.model.ReturnT;
 import com.xxl.job.core.handler.annotation.XxlJob;
@@ -22,6 +23,24 @@ public class PlatformTaskHandler {
     private FeignPlatformAlipayBackClient feignPlatformAlipayBackClient;
     @Autowired
     private FeignPlatformCandyTaskClient feignPlatformCandyTaskClient;
+    @Autowired
+    FeignPlatformApiClient feignPlatformApiClient;
+
+    @XxlJob(value = "sev-platform:overtimeRefund")
+    public ReturnT<String> overtimeRefund() {
+        try {
+            String result = feignPlatformApiClient.overtimeRefund().getData();
+            log.info("overtimeRefund：结果："+result);
+            ReturnT<String> success = ReturnT.SUCCESS;
+            success.setMsg(result);
+            return success;
+        } catch (Exception e) {
+            log.error("exception of handler:{}", e.getMessage(), e);
+            ReturnT<String> fail = ReturnT.FAIL;
+            fail.setMsg(e.getLocalizedMessage());
+            return fail;
+        }
+    }
 
     @XxlJob(value = "sev-platform:alipayActiveCallbackHandler")
     public ReturnT<String> alipayActiveCallbackHandler() {

liquidnet-bus-service/liquidnet-service-platform/liquidnet-service-platform-impl/src/main/java/com/liquidnet/service/platform/service/refund/OrderRefundsCallbackServiceImpl.java

 package com.liquidnet.service.platform.service.refund;
 
-import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
-import com.baomidou.mybatisplus.core.conditions.update.UpdateWrapper;
 import com.baomidou.mybatisplus.core.toolkit.Wrappers;
 import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
 import com.liquidnet.client.admin.zhengzai.kylin.utils.TaobaoTicketUtils;
@@ -13,9 +11,10 @@ import com.liquidnet.service.kylin.dto.vo.mongo.KylinOrderTicketVo;
 import com.liquidnet.service.kylin.dto.vo.mongo.KylinPerformanceVo;
 import com.liquidnet.service.kylin.dto.vo.returns.KylinOrderRefundsVo;
 import com.liquidnet.service.kylin.entity.KylinOrderRefunds;
-import com.liquidnet.service.kylin.entity.KylinOrderTicketStatus;
 import com.liquidnet.service.kylin.entity.KylinOrderTickets;
-import com.liquidnet.service.kylin.mapper.*;
+import com.liquidnet.service.kylin.mapper.KylinOrderRefundsMapper;
+import com.liquidnet.service.kylin.mapper.KylinOrderTicketStatusMapper;
+import com.liquidnet.service.kylin.mapper.KylinOrderTicketsMapper;
 import com.liquidnet.service.kylin.service.IKylinOrderRefundsService;
 import com.liquidnet.service.platform.utils.DataUtils;
 import com.mongodb.BasicDBObject;