From 020d940ae4e16f55f69cef3dd4c8dc0b9764af07 Mon Sep 17 00:00:00 2001
From: yujian <yujian@123.com>
Date: 星期三, 26 六月 2019 10:59:48 +0800
Subject: [PATCH] 邀请对应奖励红包加入版本区分
---
fanli/src/main/java/com/yeshi/fanli/job/UpdateTaoBaoGoodsJob.java | 42 ++++++++++++++++++++++++++++++++++--------
1 files changed, 34 insertions(+), 8 deletions(-)
diff --git a/fanli/src/main/java/com/yeshi/fanli/job/UpdateTaoBaoGoodsJob.java b/fanli/src/main/java/com/yeshi/fanli/job/UpdateTaoBaoGoodsJob.java
index 571ab16..e8c0c6c 100644
--- a/fanli/src/main/java/com/yeshi/fanli/job/UpdateTaoBaoGoodsJob.java
+++ b/fanli/src/main/java/com/yeshi/fanli/job/UpdateTaoBaoGoodsJob.java
@@ -11,11 +11,14 @@
import com.yeshi.fanli.exception.ActivityException;
import com.yeshi.fanli.log.LogHelper;
import com.yeshi.fanli.service.inter.activity.ActivityService;
+import com.yeshi.fanli.service.inter.brand.BrandClassShopService;
import com.yeshi.fanli.service.inter.goods.TaoBaoGoodsBriefService;
import com.yeshi.fanli.service.inter.lable.LabelService;
import com.yeshi.fanli.service.inter.lable.QualityFactoryService;
import com.yeshi.fanli.service.inter.lable.QualityFlashSaleService;
+import com.yeshi.fanli.service.inter.taobao.TaoBaoGoodsActivityService;
import com.yeshi.fanli.service.inter.taobao.TaoBaoGoodsUpdateService;
+import com.yeshi.fanli.util.BeanUtil;
import com.yeshi.fanli.util.CMQManager;
import com.yeshi.fanli.util.Constant;
@@ -46,6 +49,12 @@
@Resource
private QualityFlashSaleService qualityFlashSaleService;
+
+ @Resource
+ private BrandClassShopService brandClassShopService;
+
+ @Resource
+ private TaoBaoGoodsActivityService taoBaoGoodsActivityService;
// 鍔ㄦ�佸晢鍝佹洿鏂� 锛�1涓皬鏃舵洿鏂�
@Scheduled(cron = "0 0 */1 * * ?")
@@ -99,21 +108,20 @@
taoBaoGoodsUpdateService.deleteOutOfDate();
}
-
/**
* 鏇存柊瓒呰繃4涓皬鏃舵湭鏇存柊鐨勫晢鍝�
*/
- //1涓皬鏃舵洿鏂�
+ // 1涓皬鏃舵洿鏂�
@Scheduled(cron = "0 0 1/1 * * ? ")
- public void addNeddUpdateTaoBaoGoods() {
- if (!Constant.IS_TASK)
+ public void addNeedUpdateTaoBaoGoods() {
+ if (!Constant.IS_TASK)
return;
-
+
List<Long> list = taoBaoGoodsUpdateService.listNeedUpdateGoodsId(0, 2000, 4);
if (list == null || list.size() == 0) {
return;
}
-
+
for (Long id : list) {
try {
CMQManager.getInstance().addNeedUpdateTaoBaoGoodsId(id);
@@ -128,7 +136,6 @@
*/
@Scheduled(cron = "0 15 0/6 * * ? ")
public void removeFlashSaleGoods() {
-
if (!Constant.IS_TASK) {
return;
}
@@ -143,8 +150,27 @@
}
} catch (Exception e) {
- LogHelper.errorDetailInfo(e);
+ LogHelper.errorDetailInfo(e);
}
}
+ // 鏇存柊鍝佺墝鍟嗗搧锛屾瘡澶╂棭涓�6鐐规墽琛屼竴娆�
+ @Scheduled(cron = "0 0 6 * * ? ")
+ public void updateBrandGoods() {
+ if (!Constant.IS_TASK)
+ return;
+ brandClassShopService.updateShopGoods();
+ }
+
+ /**
+ * 姣忓皬鏃舵洿鏂颁竴娆�
+ */
+ @Scheduled(cron = "0 0 0/1 * * ?")
+ public void update618() {
+ if (!Constant.IS_TASK)
+ return;
+ LogHelper.test("鏇存柊618鍟嗗搧");
+ taoBaoGoodsActivityService.sysncS618Goods();
+ }
+
}
--
Gitblit v1.8.0