From 202931087ba103d90caea58d0610196741a4b2b5 Mon Sep 17 00:00:00 2001 From: tianyongbao Date: Wed, 24 Dec 2025 10:42:48 +0800 Subject: [PATCH] =?UTF-8?q?fix:=20=E5=8F=96=E6=B6=88=E7=94=9F=E4=BA=A7?= =?UTF-8?q?=E7=8E=AF=E5=A2=83=E4=B8=8B=E7=9A=84=E9=A2=9D=E5=A4=96=E5=AE=9A?= =?UTF-8?q?=E6=97=B6=E4=BB=BB=E5=8A=A1=E3=80=82?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../api/invest/RemoteInvestProdService.java | 81 ------------------- .../RemoteInvestProdFallbackFactory.java | 69 ---------------- ...ot.autoconfigure.AutoConfiguration.imports | 3 +- .../com/intc/job/task/InvestProdJobTask.java | 75 ----------------- 4 files changed, 1 insertion(+), 227 deletions(-) delete mode 100644 intc-api/intc-api-invest/src/main/java/com/intc/api/invest/RemoteInvestProdService.java delete mode 100644 intc-api/intc-api-invest/src/main/java/com/intc/api/invest/factory/RemoteInvestProdFallbackFactory.java delete mode 100644 intc-modules/intc-job/src/main/java/com/intc/job/task/InvestProdJobTask.java diff --git a/intc-api/intc-api-invest/src/main/java/com/intc/api/invest/RemoteInvestProdService.java b/intc-api/intc-api-invest/src/main/java/com/intc/api/invest/RemoteInvestProdService.java deleted file mode 100644 index 4de5a1a..0000000 --- a/intc-api/intc-api-invest/src/main/java/com/intc/api/invest/RemoteInvestProdService.java +++ /dev/null @@ -1,81 +0,0 @@ -package com.intc.api.invest; - -import com.intc.common.core.constant.ServiceNameConstants; -import com.intc.common.core.domain.R; -import org.springframework.cloud.openfeign.FeignClient; -import org.springframework.web.bind.annotation.RequestMapping; -import org.springframework.web.bind.annotation.RequestMethod; - -/** - * 基础服务 - * - * @author YaphetS - */ -@FeignClient(contextId = "remoteInvestProdService", value = ServiceNameConstants.INTC_INVEST_PROD, fallbackFactory = com.intc.api.invest.factory.RemoteInvestProdFallbackFactory.class) -public interface RemoteInvestProdService -{ - /** - * 生成未出信用卡账单数据 - * - * @return 结果 - */ - @RequestMapping(value = "/job/generateUnpaidCreditBill",method = RequestMethod.POST) - public R generateUnpaidCreditBillTask(); - - /** - * 更新未出信用卡分期账单入账数据 - * - * @return 结果 - */ - @RequestMapping(value = "/job/updateUnpaidInstallmentData",method = RequestMethod.POST) - public R updateUnpaidInstallmentDataTask(); - - /** - * 生成未出投资账单数据 - * - * @return 结果 - */ - @RequestMapping(value = "/job/generateFutureStocksBill",method = RequestMethod.POST) - public R generateFutureStocksBill(); - - /** - * 批量修改用户随机预约的时间 - * - * @return 结果 - */ - @RequestMapping(value = "/job/updateUserMinuteBatch",method = RequestMethod.POST) - public R updateUserMinuteBatch(); - - /** - * 11点期间，每分钟执行一次批量获得旅行奖励 - * - * @return 结果 - */ - @RequestMapping(value = "/job/getTravelRewardBatch",method = RequestMethod.POST) - public R getTravelRewardBatch(); - - /** - * 9点期间，每分钟执行一次预约茅台 - * - * @return 结果 - */ - @RequestMapping(value = "/job/reservationBatchTask",method = RequestMethod.POST) - public R reservationBatchTask(); - - /** - * 更新茅台版本，门店列表，预约商品列表 - * - * @return 结果 - */ - @RequestMapping(value = "/job/refreshAll",method = RequestMethod.POST) - public R refreshAll(); - - /** - * 18.05分获取申购结果 - * - * @return 结果 - */ - @RequestMapping(value = "/job/appointmentResults",method = RequestMethod.POST) - public R appointmentResults(); - -} diff --git a/intc-api/intc-api-invest/src/main/java/com/intc/api/invest/factory/RemoteInvestProdFallbackFactory.java b/intc-api/intc-api-invest/src/main/java/com/intc/api/invest/factory/RemoteInvestProdFallbackFactory.java deleted file mode 100644 index e0e7dd6..0000000 --- a/intc-api/intc-api-invest/src/main/java/com/intc/api/invest/factory/RemoteInvestProdFallbackFactory.java +++ /dev/null @@ -1,69 +0,0 @@ -package com.intc.api.invest.factory; - -import com.intc.api.invest.RemoteInvestProdService; -import com.intc.common.core.domain.R; -import org.slf4j.Logger; -import org.slf4j.LoggerFactory; -import org.springframework.cloud.openfeign.FallbackFactory; -import org.springframework.stereotype.Component; - -/** - * 用户服务降级处理 - * - * @author ruoyi - */ -@Component -public class RemoteInvestProdFallbackFactory implements FallbackFactory -{ - private static final Logger log = LoggerFactory.getLogger(RemoteInvestProdFallbackFactory.class); - - @Override - public RemoteInvestProdService create(Throwable throwable) - { - log.error("投资服务调用失败:{}", throwable.getMessage()); - return new RemoteInvestProdService() - { - - @Override - public R generateUnpaidCreditBillTask() { - return R.fail("投资服务调用生成未出信用卡账单数据失败"); - } - - @Override - public R updateUnpaidInstallmentDataTask() { - return R.fail("投资服务调用更新未出信用卡分期账单入账数据失败"); - } - - @Override - public R generateFutureStocksBill() { - return R.fail("投资服务调用生成未出投资账单数据失败"); - } - - @Override - public R updateUserMinuteBatch() { - return R.fail("投资服务调用批量修改用户随机预约的时间失败"); - } - - @Override - public R getTravelRewardBatch() { - return R.fail("投资服务调用每分钟执行一次批量获得旅行奖励失败"); - } - - @Override - public R reservationBatchTask() { - return R.fail("投资服务调用每分钟执行一次预约茅台失败"); - } - - @Override - public R refreshAll() { - return R.fail("投资服务调用更新茅台版本、门店列表、预约商品列表失败"); - } - - @Override - public R appointmentResults() { - return R.fail("投资服务调用获取申购结果失败"); - } - - }; - } -} diff --git a/intc-api/intc-api-invest/src/main/resources/META-INF/spring/org.springframework.boot.autoconfigure.AutoConfiguration.imports b/intc-api/intc-api-invest/src/main/resources/META-INF/spring/org.springframework.boot.autoconfigure.AutoConfiguration.imports index d2ba9bf..f3b6629 100644 --- a/intc-api/intc-api-invest/src/main/resources/META-INF/spring/org.springframework.boot.autoconfigure.AutoConfiguration.imports +++ b/intc-api/intc-api-invest/src/main/resources/META-INF/spring/org.springframework.boot.autoconfigure.AutoConfiguration.imports @@ -1,2 +1 @@ -com.intc.api.invest.factory.RemoteInvestFallbackFactory -com.intc.api.invest.factory.RemoteInvestProdFallbackFactory \ No newline at end of file +com.intc.api.invest.factory.RemoteInvestFallbackFactory \ No newline at end of file diff --git a/intc-modules/intc-job/src/main/java/com/intc/job/task/InvestProdJobTask.java b/intc-modules/intc-job/src/main/java/com/intc/job/task/InvestProdJobTask.java deleted file mode 100644 index 390bac9..0000000 --- a/intc-modules/intc-job/src/main/java/com/intc/job/task/InvestProdJobTask.java +++ /dev/null @@ -1,75 +0,0 @@ -package com.intc.job.task; - -import com.intc.api.invest.RemoteInvestProdService; -import com.intc.common.core.utils.DateUtils; -import org.springframework.beans.factory.annotation.Autowired; -import org.springframework.stereotype.Component; - -/** - * 照明平台定时任务 - * - * @author ruoyi - */ -@Component("investProdJobTask") -public class InvestProdJobTask -{ - @Autowired - private RemoteInvestProdService remoteInvestProdService; - - /**生成未出信用卡账单数据*/ - public void generateUnpaidCreditBillTask(){ - System.out.println("================================开始生成未出账单数据("+ DateUtils.getTime() +")================================="); - remoteInvestProdService.generateUnpaidCreditBillTask(); - System.out.println("================================结束生成未出账单据("+ DateUtils.getTime() +")================================="); - } - - /**未出信用卡分期账单入账数据*/ - public void updateUnpaidInstallmentDataTask(){ - System.out.println("================================开始更新未出信用卡分期账单入账数据("+ DateUtils.getTime() +")================================="); - remoteInvestProdService.updateUnpaidInstallmentDataTask(); - System.out.println("================================结束更新未出信用卡分期账单入账拟数据("+ DateUtils.getTime() +")================================="); - } - - /**生成未出投资账单数据*/ - public void generateFutureStocksBill(){ - System.out.println("================================开始生成未出账单数据("+ DateUtils.getTime() +")================================="); - remoteInvestProdService.generateFutureStocksBill(); - System.out.println("================================结束生成未出账单据("+ DateUtils.getTime() +")================================="); - } - - /**批量修改用户随机预约的时间*/ - public void updateUserMinuteBatch(){ - System.out.println("================================开始批量修改用户随机预约的时间("+ DateUtils.getTime() +")================================="); - remoteInvestProdService.updateUserMinuteBatch(); - System.out.println("================================结束批量修改用户随机预约的时间("+ DateUtils.getTime() +")================================="); - } - - /**每分钟执行一次批量获得旅行奖励*/ - public void getTravelRewardBatch(){ - System.out.println("================================开始每分钟执行一次批量获得旅行奖励("+ DateUtils.getTime() +")================================="); - remoteInvestProdService.getTravelRewardBatch(); - System.out.println("================================结束每分钟执行一次批量获得旅行奖励("+ DateUtils.getTime() +")================================="); - } - - /**每分钟执行一次预约茅台*/ - public void reservationBatchTask(){ - System.out.println("================================开始每分钟执行一次预约茅台("+ DateUtils.getTime() +")================================="); - remoteInvestProdService.reservationBatchTask(); - System.out.println("================================结束每分钟执行一次预约茅台("+ DateUtils.getTime() +")================================="); - } - - /**更新茅台版本，门店列表，预约商品列表*/ - public void refreshAll(){ - System.out.println("================================开始更新茅台版本，门店列表，预约商品列表("+ DateUtils.getTime() +")================================="); - remoteInvestProdService.refreshAll(); - System.out.println("================================结束更新茅台版本，门店列表，预约商品列表("+ DateUtils.getTime() +")================================="); - } - - /**获取申购结果*/ - public void appointmentResults(){ - System.out.println("================================开始获取申购结果("+ DateUtils.getTime() +")================================="); - remoteInvestProdService.appointmentResults(); - System.out.println("================================结束获取申购结果("+ DateUtils.getTime() +")================================="); - } - -}