From 30d8e227e8d823b6c38c3b9c90ac2df03b63befe Mon Sep 17 00:00:00 2001 From: admin <weikou2014> Date: 星期二, 25 二月 2025 16:41:22 +0800 Subject: [PATCH] 淘宝转链接口更新 --- fanli/src/main/java/com/yeshi/fanli/job/UserSystemCouponJob.java | 144 ++++++++++++++++++++++++----------------------- 1 files changed, 74 insertions(+), 70 deletions(-) diff --git a/fanli/src/main/java/com/yeshi/fanli/job/UserSystemCouponJob.java b/fanli/src/main/java/com/yeshi/fanli/job/UserSystemCouponJob.java index ec731fb..5fb092b 100644 --- a/fanli/src/main/java/com/yeshi/fanli/job/UserSystemCouponJob.java +++ b/fanli/src/main/java/com/yeshi/fanli/job/UserSystemCouponJob.java @@ -1,70 +1,74 @@ -package com.yeshi.fanli.job; - -import java.math.BigDecimal; -import java.util.Collections; -import java.util.Date; -import java.util.List; - -import javax.annotation.Resource; - -import org.springframework.scheduling.annotation.Scheduled; -import org.springframework.stereotype.Component; - -import com.yeshi.fanli.entity.bus.tlj.UserTaoLiJinGiveRecord; -import com.yeshi.fanli.entity.bus.user.UserSystemCouponGiveRecord; -import com.yeshi.fanli.entity.taobao.ShareHotGoods; -import com.yeshi.fanli.entity.taobao.TLJBuyGoods; -import com.yeshi.fanli.entity.taobao.TaoBaoGoodsBrief; -import com.yeshi.fanli.entity.taobao.TaoBaoUnionConfig; -import com.yeshi.fanli.entity.taobao.TaoKeAppInfo; -import com.yeshi.fanli.exception.taobao.TaobaoGoodsDownException; -import com.yeshi.fanli.log.LogHelper; -import com.yeshi.fanli.service.inter.taobao.ShareHotGoodsService; -import com.yeshi.fanli.service.inter.taobao.TLJBuyGoodsService; -import com.yeshi.fanli.service.inter.taobao.TaoBaoUnionConfigService; -import com.yeshi.fanli.service.inter.taobao.dataoke.DaTaoKeGoodsDetailService; -import com.yeshi.fanli.service.inter.tlj.UserTaoLiJinGiveRecordService; -import com.yeshi.fanli.service.inter.tlj.UserTaoLiJinOriginService; -import com.yeshi.fanli.service.inter.user.UserSystemCouponGiveRecordService; -import com.yeshi.fanli.util.Constant; -import com.yeshi.fanli.util.TaoBaoConstant; -import com.yeshi.fanli.util.TimeUtil; -import com.yeshi.fanli.util.taobao.TaoBaoUtil; -import com.yeshi.fanli.util.taobao.TaoKeApiUtil; - -@Component -public class UserSystemCouponJob { - - @Resource - private UserSystemCouponGiveRecordService userSystemCouponGiveRecordService; - - - /** - * 姣忓ぉ00:10 璧犻�侀��鍥炲凡杩囨湡娣樼ぜ閲� - */ - @Scheduled(cron = "0 10 0 * * ? ") - public void giveSendBack() { - if (!Constant.IS_TASK) - return; - - for (int i = 0; i < 100; i++) { - List<UserSystemCouponGiveRecord> overdueList = userSystemCouponGiveRecordService.overdueList(500); - if (overdueList == null || overdueList.size() == 0) { - break; - } - - for (UserSystemCouponGiveRecord record: overdueList) { -// try { -// userTaoLiJinOriginService.giveSendBack(record.getGiveUid(), record.getAmount()); -// // 鏇存柊璁板綍 -// UserTaoLiJinGiveRecord updateRecord = new UserTaoLiJinGiveRecord(); -// updateRecord.setId(record.getId()); -// updateRecord.setState(UserTaoLiJinGiveRecord.STATE_OVERDUE); -// userTaoLiJinGiveRecordService.updateByPrimaryKeySelective(updateRecord); -// } catch (Exception e) { -// e.printStackTrace(); -// } - } - } - } -} +package com.yeshi.fanli.job; + +import java.util.List; + +import javax.annotation.Resource; + +import org.springframework.scheduling.annotation.Scheduled; +import org.springframework.stereotype.Component; + +import com.yeshi.fanli.entity.bus.user.UserSystemCoupon; +import com.yeshi.fanli.entity.bus.user.UserSystemCouponGiveRecord; +import com.yeshi.fanli.log.LogHelper; +import com.yeshi.fanli.service.inter.user.UserSystemCouponGiveRecordService; +import com.yeshi.fanli.service.inter.user.UserSystemCouponService; +import com.yeshi.fanli.util.Constant; + +@Component +public class UserSystemCouponJob { + + @Resource + private UserSystemCouponGiveRecordService userSystemCouponGiveRecordService; + + @Resource + private UserSystemCouponService userSystemCouponService; + + /** + * 姣忓ぉ涓�涓皬鏃舵洿鏂板埜 + */ + @Scheduled(cron = "0 0 0/1 * * ? ") + public void updateCouponInfo() { + if (!Constant.IS_TASK) + return; + + // 1銆佽禒閫侀��鍥炲埜 + giveSendBack(); + + // 2銆佸埜澶辨晥 + updateInvalid(); + } + + /** + * 璧犻�侀��鍥炲埜 + */ + public void giveSendBack() { + try { + for (int i = 0; i < 100; i++) { + List<UserSystemCouponGiveRecord> overdueList = userSystemCouponGiveRecordService.overdueList(500); + if (overdueList == null || overdueList.size() == 0) { + break; + } + userSystemCouponService.sendBackGiveCoupon(overdueList); + } + } catch (Exception e) { + LogHelper.errorDetailInfo(e); + } + } + + /** + * 鏇存柊鍒稿け鏁� + */ + public void updateInvalid() { + try { + for (int i = 0; i < 100; i++) { + List<UserSystemCoupon> list = userSystemCouponService.getCounponNowInvalid(500); + if (list == null || list.size() == 0) { + break; + } + userSystemCouponService.updateCounponInvalid(list); + } + } catch (Exception e) { + LogHelper.errorDetailInfo(e); + } + } +} -- Gitblit v1.8.0