qdintc/intc-cloud
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

fix: 取消生产环境下的额外定时任务。

Browse Source
This commit is contained in:
tianyongbao
2025-12-24 10:42:48 +08:00
parent 6b881934f4
commit 202931087b
4 changed files with 1 additions and 227 deletions
Download Patch File Download Diff File Expand all files Collapse all files

81
intc-api/intc-api-invest/src/main/java/com/intc/api/invest/RemoteInvestProdService.java
View File

@@ -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();
}

69
intc-api/intc-api-invest/src/main/java/com/intc/api/invest/factory/RemoteInvestProdFallbackFactory.java
View File

@@ -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<RemoteInvestProdService>
{
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("投资服务调用获取申购结果失败");
}
};
}
}

1
intc-api/intc-api-invest/src/main/resources/META-INF/spring/org.springframework.boot.autoconfigure.AutoConfiguration.imports
View File

@@ -1,2 +1 @@
com.intc.api.invest.factory.RemoteInvestFallbackFactory com.intc.api.invest.factory.RemoteInvestFallbackFactory
com.intc.api.invest.factory.RemoteInvestProdFallbackFactory

75
intc-modules/intc-job/src/main/java/com/intc/job/task/InvestProdJobTask.java
View File

@@ -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() +")=================================");
}
}