angelo
/
java-retail-app
3
0
Fork 1
Code Issues Pull Requests Packages Projects Releases Wiki Activity

Compare commits

base: angelo:c5d604224650b8fe7e8f63e80bd25f8d94f47a64
Branches Tags
angelo:master
angelo:test
angelo:dev
angelo:online
angelo:feat_shared_reg
..
compare: angelo:52660426630963a1184670355dbdc71b8b96fb25
Branches Tags
angelo:test
angelo:dev
angelo:online
angelo:feat_shared_reg
angelo:master

No commits in common. "c5d604224650b8fe7e8f63e80bd25f8d94f47a64" and "52660426630963a1184670355dbdc71b8b96fb25" have entirely different histories.
c5d6042246 ... 5266042663

13 changed files with 300 additions and 70 deletions
Show Stats Expand all files Collapse all files

47
bd-business/bd-business-bonus/src/main/java/com/hzs/bonus/bonus/provider/MemberSettleBonusProvider.java
View File

@ -30,22 +30,27 @@ import java.util.List;
public class MemberSettleBonusProvider implements IMemberSettleBonusApi {
@Autowired
private ICuMemberMonthAchieveService iCuMemberMonthAchieveService;
private ICuMemberMonthAchieveService cuMemberMonthAchieveService;
@Autowired
private IBonusSettleService iBonusSettleService;
private IBonusSettleService bonusSettleService;
@Autowired
private IBonusGrantService iBonusGrantService;
private ICuMemberBonusService cuMemberBonusService;
@Autowired
private ICuMemberBonusService iCuMemberBonusService;
private IBonusGrantService bonusGrantService;
@Autowired
private ICuMemberAchieveService iCuMemberAchieveService;
private ICuMemberAchieveService cuMemberAchieveService;
@Autowired
private ICuMemberRetailLogService iCuMemberRetailLogService;
private ICuMemberRetailLogService cuMemberRetailLogService;
@Override
public R<Boolean> calculateCumberBonusBySecond(String orderCode) {
try {
iBonusSettleService.calculateCumberBonusBySecond(orderCode);
bonusSettleService.calculateCumberBonusBySecond(orderCode);
} catch (Exception e) {
return R.fail();
}
@ -64,7 +69,7 @@ public class MemberSettleBonusProvider implements IMemberSettleBonusApi {
@Override
public void backupsSettleBonusEveryday() {
iCuMemberBonusService.backupsSettleBonusEveryday();
cuMemberBonusService.backupsSettleBonusEveryday();
}
class BonusCalculateBonus extends Thread {
@ -77,53 +82,55 @@ public class MemberSettleBonusProvider implements IMemberSettleBonusApi {
@Override
public void run() {
if (DateUtils.compareDateBefore(settleDate, DateUtils.parseStringToDate("2023-09-04"))) {
return;
}
Date settleEndDate = DateUtils.afterDate(1, ChronoUnit.DAYS, settleDate);
log.info("奖金结算开始, 结算时间：{}", DateUtils.parseDateToStr(DateUtils.YYYY_MM_DD, settleDate));
log.info("奖金结算完成,结算时间：{}", DateUtils.parseDateToStr(DateUtils.YYYY_MM_DD, settleDate));
// 奖金结算
try {
iCuMemberBonusService.autoCalculateBonus(settleDate, settleEndDate);
log.info("奖金结算结束");
cuMemberBonusService.autoCalculateBonus(settleDate, settleEndDate);
} catch (Exception e) {
log.error("奖金结算异常,结算时间：{}", DateUtils.parseDateToStr(DateUtils.YYYY_MM_DD, settleDate), e);
log.info("BonusCalculateBonus error: ", e);
}
}
}
@Override
public void insertCuMemberAchieveByEveryDay() {
iCuMemberMonthAchieveService.insertCuMemberAchieveByEveryDay(DateUtils.beforeDate(1, ChronoUnit.DAYS));
cuMemberMonthAchieveService.insertCuMemberAchieveByEveryDay(DateUtils.beforeDate(1, ChronoUnit.DAYS));
}
@Override
public void autoPublishBonus() {
iBonusGrantService.publishBonusByPeriodEveryDay();
bonusGrantService.publishBonusByPeriodEveryDay();
}
@Override
public void autoGrantBonus() {
iBonusGrantService.grantWithdrawBonusByPeriodEveryDay();
bonusGrantService.grantWithdrawBonusByPeriodEveryDay();
}
@Override
public Boolean chargeBackSaOrder(SaOrder saOrder) {
return iCuMemberAchieveService.chargeBackSaOrder(saOrder);
return cuMemberAchieveService.chargeBackSaOrder(saOrder);
}
@Override
public void calculateCuMemberRetailRangeBonusBySaOrder() {
List<CuMemberRetailLog> cuMemberRetailLogs = iCuMemberRetailLogService.queryCuMemberRetailLog();
List<CuMemberRetailLog> cuMemberRetailLogs = cuMemberRetailLogService.queryCuMemberRetailLog();
if (cuMemberRetailLogs.size() > 0) {
List<CuMemberRetailLog> successLogList = new ArrayList<>();
try {
for (CuMemberRetailLog cuMemberRetailLog : cuMemberRetailLogs) {
iBonusSettleService.calculateCuMemberRetailRangeBonusBySaOrder(cuMemberRetailLog.getOrderCode());
bonusSettleService.calculateCuMemberRetailRangeBonusBySaOrder(cuMemberRetailLog.getOrderCode());
successLogList.add(cuMemberRetailLog);
}
} catch (Exception e) {
e.printStackTrace();
} finally {
if (successLogList.size() > 0) {
iCuMemberRetailLogService.updateCuMemberRetailLogByList(successLogList);
cuMemberRetailLogService.updateCuMemberRetailLogByList(successLogList);
}
}
}
@ -131,6 +138,6 @@ public class MemberSettleBonusProvider implements IMemberSettleBonusApi {
@Override
public R<CuMemberRetail> queryValidateBoxOrAchieve(Long pkMember) {
return R.ok(iBonusSettleService.queryValidateBoxOrAchieve(pkMember));
return R.ok(bonusSettleService.queryValidateBoxOrAchieve(pkMember));
}
}

3
bd-common/bd-common-domain/src/main/java/com/hzs/common/domain/third/sms/TSmsRecord.java
View File

@ -15,6 +15,9 @@ import java.util.Date;
/**
* 短信发送记录
*
* @author hzs
* @since 2023-03-08
*/
@Data
@EqualsAndHashCode(callSuper = true)

91
bd-third/src/main/java/com/hzs/third/job/BonusSettleJob.java
View File

@ -6,13 +6,19 @@ import com.xxl.job.core.handler.annotation.XxlJob;
import lombok.extern.slf4j.Slf4j;
import org.apache.dubbo.config.annotation.DubboReference;
import org.springframework.boot.autoconfigure.condition.ConditionalOnProperty;
import org.springframework.scheduling.annotation.Scheduled;
import org.springframework.stereotype.Component;
import java.time.temporal.ChronoUnit;
import java.util.Date;
/**
* 每日奖金计算定时任务
* @description: 每日奖金计算定时任务
* @author: sui q
* @time: 2023/4/10 14:19
* @classname: BonusSettleJob
* @package_name: com.hzs.third.job
* version 1.0.0
*/
@Component
@Slf4j
@ -20,124 +26,173 @@ import java.util.Date;
public class BonusSettleJob {
@DubboReference
IMemberSettleBonusApi iMemberSettleBonusApi;
private IMemberSettleBonusApi memberBonusSettleApi;
/**
* 奖金每天自动结算,计算前一天奖金
*
* @return: void
* @Author: sui q
* @Date: 2023/3/4 13:48
*/
@XxlJob("backSettleBonus")
// @Scheduled(cron = "10 8 10 * * ?")
public void backupsSettleBonusEveryday() {
log.info("开始进行奖金结算");
iMemberSettleBonusApi.backupsSettleBonusEveryday();
memberBonusSettleApi.backupsSettleBonusEveryday();
}
/**
* 奖金每天自动结算,计算前一天奖金
*
* @return: void
* @Author: sui q
* @Date: 2023/3/4 13:48
*/
@XxlJob("autoSettleBonus")
// @Scheduled(cron = "10 8 10 * * ?")
public void autoSettleBonusEveryday() {
Date startDate = DateUtils.beforeDate(7, ChronoUnit.DAYS, DateUtils.currentDate());
log.info("开始进行奖金结算");
iMemberSettleBonusApi.autoCalculateBonus(startDate);
memberBonusSettleApi.autoCalculateBonus(startDate);
}
/**
* 奖金每天自动结算,计算前一天奖金
*
* @return: void
* @Author: sui q
* @Date: 2023/3/4 13:48
*/
@XxlJob("autoSettleBonus1")
public void autoSettleBonusEveryday1() {
Date startDate = DateUtils.beforeDate(6, ChronoUnit.DAYS, DateUtils.currentDate());
log.info("开始进行奖金结算");
iMemberSettleBonusApi.autoCalculateBonus(startDate);
memberBonusSettleApi.autoCalculateBonus(startDate);
}
/**
* 奖金每天自动结算,计算前一天奖金
*
* @return: void
* @Author: sui q
* @Date: 2023/3/4 13:48
*/
@XxlJob("autoSettleBonus2")
public void autoSettleBonusEveryday2() {
Date startDate = DateUtils.beforeDate(5, ChronoUnit.DAYS, DateUtils.currentDate());
log.info("开始进行奖金结算");
iMemberSettleBonusApi.autoCalculateBonus(startDate);
memberBonusSettleApi.autoCalculateBonus(startDate);
}
/**
* 奖金每天自动结算,计算前一天奖金
*
* @return: void
* @Author: sui q
* @Date: 2023/3/4 13:48
*/
@XxlJob("autoSettleBonus3")
public void autoSettleBonusEveryday3() {
Date startDate = DateUtils.beforeDate(4, ChronoUnit.DAYS, DateUtils.currentDate());
log.info("开始进行奖金结算");
iMemberSettleBonusApi.autoCalculateBonus(startDate);
memberBonusSettleApi.autoCalculateBonus(startDate);
}
/**
* 奖金每天自动结算,计算前一天奖金
*
* @return: void
* @Author: sui q
* @Date: 2023/3/4 13:48
*/
@XxlJob("autoSettleBonus4")
// @Scheduled(cron = "10 6 11 * * ?")
public void autoSettleBonusEveryday4() {
Date startDate = DateUtils.beforeDate(3, ChronoUnit.DAYS, DateUtils.currentDate());
log.info("开始进行奖金结算");
iMemberSettleBonusApi.autoCalculateBonus(startDate);
memberBonusSettleApi.autoCalculateBonus(startDate);
}
/**
* 奖金每天自动结算,计算前一天奖金
*
* @return: void
* @Author: sui q
* @Date: 2023/3/4 13:48
*/
@XxlJob("autoSettleBonus5")
public void autoSettleBonusEveryday5() {
Date startDate = DateUtils.beforeDate(2, ChronoUnit.DAYS, DateUtils.currentDate());
log.info("开始进行奖金结算");
iMemberSettleBonusApi.autoCalculateBonus(startDate);
memberBonusSettleApi.autoCalculateBonus(startDate);
}
/**
* 奖金每天自动结算,计算前一天奖金
*
* @return: void
* @Author: sui q
* @Date: 2023/3/4 13:48
*/
@XxlJob("autoSettleBonus6")
public void autoSettleBonusEveryday6() {
Date startDate = DateUtils.beforeDate(1, ChronoUnit.DAYS, DateUtils.currentDate());
log.info("开始进行奖金结算");
iMemberSettleBonusApi.autoCalculateBonus(startDate);
memberBonusSettleApi.autoCalculateBonus(startDate);
}
/*
* 自动公布奖金
* @description: 自动公布奖金
* @author: sui q
* @date: 2023/4/24 14:26
* @param: null null
**/
@XxlJob("autoPublishBonus")
public void autoPublishBonusEveryday() {
log.info("开始进行奖金公布");
iMemberSettleBonusApi.autoPublishBonus();
memberBonusSettleApi.autoPublishBonus();
log.info("奖金公布完成");
}
/*
* 自动发放奖金
* @description: 自动发放奖金
* @author: sui q
* @date: 2023/4/24 14:26
* @param: null null
**/
@XxlJob("autoGrantBonus")
// @Scheduled(cron = "10 42 13 * * ?")
public void autoGrantBonusEveryday() {
log.info("开始进行奖金发放");
iMemberSettleBonusApi.autoGrantBonus();
memberBonusSettleApi.autoGrantBonus();
log.info("奖金发放完成");
}
/*
* 自动结算每日业绩，每月业绩，用于统计分析
* @description: 自动结算每日业绩，每月业绩，用于统计分析
* @author: sui q
* @date: 2023/9/1 9:53
* @param: null null
**/
@XxlJob("autoSettleMember")
// @Scheduled(cron = "50 55 15 * * ?")
public void autoSettleMemberAchieveEveryday() {
log.info("开始进行会员业绩计算");
iMemberSettleBonusApi.insertCuMemberAchieveByEveryDay();
memberBonusSettleApi.insertCuMemberAchieveByEveryDay();
}
/*
* 自动结算每日业绩，每月业绩，用于统计分析
* @description: 自动结算每日业绩，每月业绩，用于统计分析
* @author: sui q
* @date: 2023/9/1 9:53
* @param: null null
**/
@XxlJob("autoSecondBonus")
public void autoSettleMemberBonusBySecond() {
log.info("开始进行会员业绩计算");
iMemberSettleBonusApi.calculateCuMemberRetailRangeBonusBySaOrder();
memberBonusSettleApi.calculateCuMemberRetailRangeBonusBySaOrder();
}
}

13
bd-third/src/main/java/com/hzs/third/job/CuMemberJob.java
View File

@ -9,6 +9,12 @@ import org.springframework.stereotype.Component;
/**
* 会员模块定时任务
*
* @Description:
* @Author: ljc
* @Time: 2023/4/11 19:11
* @Classname: CuMemberJob
* @Package_name: com.hzs.member.job
*/
@ConditionalOnProperty(name = "xxl-job.start", havingValue = "true")
@Component
@ -16,22 +22,23 @@ import org.springframework.stereotype.Component;
public class CuMemberJob {
@DubboReference
IMemberJobServiceApi iMemberJobServiceApi;
IMemberJobServiceApi memberJobServiceApi;
/**
* 定时插入账户详情数据
*/
@XxlJob("insertAccountDetail")
public void insertAccountDetail() {
iMemberJobServiceApi.insertAccountDetail();
memberJobServiceApi.insertAccountDetail();
}
/**
* 自动提现
*/
@XxlJob("automaticWithdrawal")
public void automaticWithdrawal() {
iMemberJobServiceApi.automaticWithdrawal();
memberJobServiceApi.automaticWithdrawal();
}
}

70
bd-third/src/main/java/com/hzs/third/job/MemberJob.java
View File

@ -10,6 +10,7 @@ import com.hzs.member.statis.ICuBonusStatisServiceApi;
import com.hzs.member.statis.ICuBonusVertexStatisServiceApi;
import com.hzs.report.stat.IMemberReportServiceApi;
import com.hzs.retail.member.IMemberRetailApi;
import com.hzs.system.config.IBdBarCodeServiceApi;
import com.xxl.job.core.handler.annotation.XxlJob;
import lombok.extern.slf4j.Slf4j;
import org.apache.dubbo.config.annotation.DubboReference;
@ -19,22 +20,32 @@ import org.springframework.stereotype.Component;
import java.time.temporal.ChronoUnit;
import java.util.Date;
/**
* @BelongsProject: hzs_cloud
* @BelongsPackage: com.hzs.third.job
* @Author: yh
* @CreateTime: 2023-04-27 09:31
* @Description:
* @Version: 1.0
*/
@ConditionalOnProperty(name = "xxl-job.start", havingValue = "true")
@Component
@Slf4j
public class MemberJob {
@DubboReference
IMemberServiceApi iMemberServiceApi;
@DubboReference
IMemberRetailApi iMemberRetailApi;
IMemberServiceApi memberServiceApi;
@DubboReference
ICuBonusStatisServiceApi iCuBonusStatisServiceApi;
@DubboReference
ICuBonusVertexStatisServiceApi iCuBonusVertexStatisServiceApi;
@DubboReference
IBdBarCodeServiceApi iBdBarCodeServiceApi;
@DubboReference
ICuMemberRetailRegionServiceApi iCuMemberRetailRegionServiceApi;
@DubboReference
IMemberRetailApi iMemberRetailApi;
@DubboReference
IAcRetailPickLogServiceApi iAcRetailPickLogServiceApi;
@DubboReference
IMemberReportServiceApi iMemberReportServiceApi;
@ -72,7 +83,11 @@ public class MemberJob {
}
/**
* 重算7天内奖金拨比
* @description: 重算7天内奖金拨比
* @author: zhang jing
* @date: 2023/12/11 10:45
* @param: []
* @return: void
**/
@XxlJob("rerun-bonus-statis")
public void rerunCuBonusStatis() {
@ -94,7 +109,11 @@ public class MemberJob {
}
/**
* 7天重算顶点奖金拨比统计
* @description: 7天重算顶点奖金拨比统计
* @author: zhang jing
* @date: 2024/8/15 10:29
* @param: []
* @return: void
**/
@XxlJob("rerun-bonus-vertex-statis")
public void rerunCuBonusVertexStatis() {
@ -115,18 +134,35 @@ public class MemberJob {
}
}
/**
* 定时清除未使用的会员编号
*/
@XxlJob("clear-member-empty-code")
public void clearMemberEmptyCode() {
log.info("clear-member-empty-code 开始执行!");
Integer dataCount = iMemberServiceApi.clearMemberEmptyCode().getData();
Integer dataCount = memberServiceApi.clearMemberEmptyCode().getData();
log.info("clear-member-empty-code 开始结束! 共处理：{}", dataCount);
}
/**
* 定时修改到期的零售区域
* 定时初始化条形码配置
*/
@XxlJob("updatWarehouseLogJob")
public void updatWarehouseLogJob() {
/**
* 查询初始化条形码配置,将当前尾号初始化为初始尾号
*/
iBdBarCodeServiceApi.updatWarehouseLog();
}
/**
* @description: 定时修改到期的零售区域
* @author: zhang jing
* @date: 2024/12/30 14:25
* @param: []
* @return: void
**/
@XxlJob("retail-region")
public void retailRegion() {
@ -155,7 +191,11 @@ public class MemberJob {
}
/**
* 每月10号处理上个月提货赠送活动满足活动规则的数据
* @description: 每月10号处理上个月提货赠送活动满足活动规则的数据
* @author: zhang jing
* @date: 2025/2/6 10:59
* @param: []
* @return: void
**/
@XxlJob("deliveryLog")
public void deliveryLog() {
@ -163,7 +203,11 @@ public class MemberJob {
}
/**
* 统计直推会员金额业绩盒数
* @description: 统计直推会员金额业绩盒数
* @author: zhang jing
* @date: 2025/2/12 16:09
* @param: []
* @return: void
**/
@XxlJob("sta-smount-box")
public void pushAmountBoxmethod() {
@ -171,7 +215,11 @@ public class MemberJob {
}
/**
* 重算7天统计直推会员金额业绩盒数
* @description: 重算7天统计直推会员金额业绩盒数
* @author: zhang jing
* @date: 2023/12/11 10:45
* @param: []
* @return: void
**/
@XxlJob("repeat-sta-smount-box")
public void repeatPushAmountBoxmethod() {
@ -183,7 +231,9 @@ public class MemberJob {
String startDateStr = (DateUtils.parseDateToStr(DateUtils.YYYY_MM_DD, endDate));
//重算前6天的数据
iMemberReportServiceApi.repeatPushAmountBoxmethod(startDateStr, endDateStr);
}
}

6
bd-third/src/main/java/com/hzs/third/job/OrderJob.java
View File

@ -1,6 +1,8 @@
package com.hzs.third.job;
import com.hzs.member.account.IMemberJobServiceApi;
import com.hzs.sale.order.ISaOrderServiceApi;
import com.hzs.system.base.ICurrencyServiceApi;
import com.xxl.job.core.handler.annotation.XxlJob;
import lombok.extern.slf4j.Slf4j;
import org.apache.dubbo.config.annotation.DubboReference;
@ -13,14 +15,14 @@ import org.springframework.stereotype.Component;
public class OrderJob {
@DubboReference
ISaOrderServiceApi iSaOrderServiceApi;
ISaOrderServiceApi orderServiceApi;
/**
* 定时关单 订单三十分钟未支付自动关闭
*/
@XxlJob("autoCloseOrder")
public void timingCloseOrder() {
iSaOrderServiceApi.closeOrder();
orderServiceApi.closeOrder();
}
}

12
bd-third/src/main/java/com/hzs/third/job/ScmJob.java
View File

@ -8,7 +8,12 @@ import org.springframework.boot.autoconfigure.condition.ConditionalOnProperty;
import org.springframework.stereotype.Component;
/**
* 供应链定时任务
* @description: 供应链定时任务
* @author: sui q
* @time: 2024/2/21 15:45
* @classname: ScmJob
* @package_name: com.hzs.third.job
* version 1.0.0
*/
@Slf4j
@ConditionalOnProperty(name = "xxl-job.start", havingValue = "true")
@ -16,13 +21,14 @@ import org.springframework.stereotype.Component;
public class ScmJob {
@DubboReference
IScmBillServiceApi iScmBillServiceApi;
private IScmBillServiceApi scmBillServiceApi;
/**
* 更新单据号初始化值
*/
// @Scheduled(cron = "0 54 15 * * ?")
@XxlJob("updateBillNo")
public void updateBillNo() {
iScmBillServiceApi.updateScmBillNoNextValue();
scmBillServiceApi.updateScmBillNoNextValue();
}
}

76
bd-third/src/main/java/com/hzs/third/job/SmsJob.java Normal file
View File

@ -0,0 +1,76 @@
package com.hzs.third.job;
import cn.hutool.core.collection.CollectionUtil;
import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
import com.hzs.common.core.constant.MagicNumberConstants;
import com.hzs.common.core.constant.SystemFieldConstants;
import com.hzs.common.core.enums.ESmsSendResult;
import com.hzs.common.core.enums.ESmsSendStatus;
import com.hzs.common.core.enums.ESmsSendType;
import com.hzs.common.domain.third.sms.TSmsRecord;
import com.hzs.third.sms.service.ITSmsRecordService;
import com.hzs.third.sms.util.SmsUtil;
import com.xxl.job.core.handler.annotation.XxlJob;
import lombok.extern.slf4j.Slf4j;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.boot.autoconfigure.condition.ConditionalOnProperty;
import org.springframework.stereotype.Component;
import java.util.Date;
import java.util.List;
/**
* @Description: 短信定时任务
* @Author: jiang chao
* @Time: 2023/3/11 16:22
* @Classname: SmsJob
* @PackageName: com.hzs.third.job
*/
@Slf4j
@ConditionalOnProperty(name = "xxl-job.start", havingValue = "true")
@Component
public class SmsJob {
@Autowired
private ITSmsRecordService itSmsRecordService;
/**
* 定时发送短信
*/
// @Scheduled(cron = "0 * * * * ?")
@XxlJob("sendSms")
public void sendSms() {
log.info("定时发送短信任务开始!");
Date date = new Date();
QueryWrapper<TSmsRecord> queryWrapper = new QueryWrapper<>();
queryWrapper.eq("SEND_TYPE", ESmsSendType.SCHEDULED.getValue());
queryWrapper.eq("SEND_STATUS", ESmsSendStatus.NOT_SEND.getValue());
queryWrapper.le("SEND_TIME", date);
queryWrapper.orderByAsc(SystemFieldConstants.CREATION_TIME);
List<TSmsRecord> list = itSmsRecordService.list(queryWrapper);
if (CollectionUtil.isNotEmpty(list)) {
log.info("本次共需要发送短信{}条", list.size());
for (TSmsRecord tSmsRecord : list) {
String str = SmsUtil.sendSms(tSmsRecord.getPhone(), tSmsRecord.getContent());
if (null == str) {
// 发送成功
tSmsRecord.setSendResult(ESmsSendResult.SUCCESS.getValue());
} else {
tSmsRecord.setSendResult(ESmsSendResult.FAIL.getValue());
}
tSmsRecord.setSendStatus(ESmsSendStatus.SEND.getValue());
tSmsRecord.setPkModified(MagicNumberConstants.PK_ADMIN);
tSmsRecord.setModifiedTime(date);
itSmsRecordService.updateById(tSmsRecord);
}
} else {
log.info("本次没有需要发送的短信");
}
log.info("定时发送短信任务结束!");
}
}

21
bd-third/src/main/java/com/hzs/third/job/WaresJob.java
View File

@ -4,18 +4,27 @@ import com.hzs.sale.wares.IWaresServiceApi;
import com.xxl.job.core.handler.annotation.XxlJob;
import lombok.extern.slf4j.Slf4j;
import org.apache.dubbo.config.annotation.DubboReference;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.boot.autoconfigure.condition.ConditionalOnProperty;
import org.springframework.stereotype.Component;
import java.util.Date;
/**
* @BelongsProject: hzs_cloud
* @BelongsPackage: com.hzs.third.job
* @Author: yh
* @CreateTime: 2023-06-01 10:44
* @Description: TODO
* @Version: 1.0
*/
@Slf4j
@ConditionalOnProperty(name = "xxl-job.start", havingValue = "true")
@Component
public class WaresJob {
@DubboReference
IWaresServiceApi iWaresServiceApi;
private IWaresServiceApi waresServiceApi;
/**
* 商品自动上下架
@ -23,12 +32,14 @@ public class WaresJob {
@XxlJob("waresAutoLoadingJob")
public void waresAutoLoadingJob() {
// 修改符合 时间条件商品上架
// 获取当前时间
/**
* 获取当前时间
*/
Date currentTime = new Date();
// 自动上架
iWaresServiceApi.updateByAutoStartAndAutoStart(currentTime);
waresServiceApi.updateByAutoStartAndAutoStart(currentTime);
// 定时自动下架
iWaresServiceApi.updateByAutoStartAndAutoEnd(currentTime);
waresServiceApi.updateByAutoStartAndAutoEnd(currentTime);
}
/**
@ -37,6 +48,6 @@ public class WaresJob {
@XxlJob("waresPreSaleJob")
public void waresPreSaleJob() {
// 修改商品预售状态
iWaresServiceApi.waresPreSale();
waresServiceApi.waresPreSale();
}
}

6
bd-third/src/main/java/com/hzs/third/sms/controller/manage/SmsRecordController.java
View File

@ -20,7 +20,11 @@ import javax.servlet.http.HttpServletResponse;
import java.util.List;
/**
* 短信发送记录
* @Description: 短信发送记录
* @Author: jiang chao
* @Time: 2023/3/9 16:10
* @Classname: SmsRecordController
* @PackageName: com.hzs.third.sms.controller
*/
@RestController
@RequestMapping("/manage/sms-record/")

3
bd-third/src/main/java/com/hzs/third/sms/mapper/TSmsRecordMapper.java
View File

@ -10,6 +10,9 @@ import java.util.List;
/**
* 短信发送记录 Mapper 接口
*
* @author hzs
* @since 2023-03-08
*/
public interface TSmsRecordMapper extends BaseMapper<TSmsRecord> {

3
bd-third/src/main/java/com/hzs/third/sms/service/ITSmsRecordService.java
View File

@ -10,6 +10,9 @@ import java.util.List;
/**
* 短信发送记录 服务类
*
* @author hzs
* @since 2023-03-08
*/
public interface ITSmsRecordService extends IService<TSmsRecord> {

7
bd-third/src/main/java/com/hzs/third/sms/service/impl/TSmsRecordServiceImpl.java
View File

@ -26,6 +26,9 @@ import java.util.*;
/**
* 短信发送记录 服务实现类
*
* @author hzs
* @since 2023-03-08
*/
@Service
public class TSmsRecordServiceImpl extends ServiceImpl<TSmsRecordMapper, TSmsRecord> implements ITSmsRecordService {
@ -34,9 +37,9 @@ public class TSmsRecordServiceImpl extends ServiceImpl<TSmsRecordMapper, TSmsRec
private ITSmsTemplateService itSmsTemplateService;
@DubboReference
IMemberServiceApi iMemberServiceApi;
private IMemberServiceApi iMemberServiceApi;
@DubboReference
ISaOrderServiceApi iSaOrderServiceApi;
private ISaOrderServiceApi iSaOrderServiceApi;
@Override
public List<TSmsRecordExt> queryList(SmsRecordQueryParam param, Integer pkCountry) {