From 9a24f2802a3d6fe3e82c05e52f2880d65ad04dcf Mon Sep 17 00:00:00 2001
From: yujian <yujian>
Date: 星期一, 29 四月 2019 08:59:47 +0800
Subject: [PATCH] Merge branch 'div_develop' into master_develop

---
 fanli/src/main/java/com/yeshi/fanli/job/UpdateDaTaoKeJob.java |   30 ++++++++++++++++++++++++------
 1 files changed, 24 insertions(+), 6 deletions(-)

diff --git a/fanli/src/main/java/com/yeshi/fanli/job/UpdateDaTaoKeJob.java b/fanli/src/main/java/com/yeshi/fanli/job/UpdateDaTaoKeJob.java
index b69a1d4..c5e1e9e 100644
--- a/fanli/src/main/java/com/yeshi/fanli/job/UpdateDaTaoKeJob.java
+++ b/fanli/src/main/java/com/yeshi/fanli/job/UpdateDaTaoKeJob.java
@@ -13,6 +13,7 @@
 import com.yeshi.fanli.entity.taobao.TaoBaoGoodsBrief;
 import com.yeshi.fanli.log.LogHelper;
 import com.yeshi.fanli.service.inter.lable.QualityFactoryService;
+import com.yeshi.fanli.service.inter.taobao.dataoke.DaTaoKeGoodsService;
 import com.yeshi.fanli.util.Constant;
 import com.yeshi.fanli.util.taobao.DaTaoKeUtil;
 
@@ -23,22 +24,24 @@
 @Component
 public class UpdateDaTaoKeJob {
 
-	
 	@Resource
 	private QualityFactoryService qualityFactoryService;
+
+	@Resource
+	private DaTaoKeGoodsService daTaoKeGoodsService;
 
 	// 涓ゅ皬鏃舵墽琛屼竴娆� 瀵瑰晢鍝佷俊鎭繘琛屾洿鏂�
 	@Scheduled(cron = "0 0 0/2 * * ?")
 	public void doUpdateJob() {
-		
+
 		if (!Constant.IS_TASK)
 			return;
-		
+
 		List<TaoBaoGoodsBrief> listgoods = DaTaoKeUtil.getDingDongQiang();
 		if (listgoods == null || listgoods.size() == 0) {
 			return;
 		}
-		
+
 		try {
 			/* 鎿嶄綔浜猴細 寮�鍙戣处鍙� */
 			AdminUser admin = new AdminUser(2L);
@@ -50,7 +53,7 @@
 			autoRule.setEndWeight(3000);
 			autoRule.setGoodsSource(QualityFactory.SOURCE_TAOBAO_DATAOKE);
 			qualityFactoryService.autoInsertOrUpadateStorage(listgoods, null, autoRule);
-	
+
 		} catch (Exception e) {
 			try {
 				LogHelper.errorDetailInfo(e);
@@ -58,7 +61,22 @@
 				e1.printStackTrace();
 			}
 		}
-		
+
+	}
+
+	@Scheduled(cron = "0 0/20 * * * ? ")
+	public void doSyncJob() {
+		if (!Constant.IS_TASK)
+			return;
+		try {
+			daTaoKeGoodsService.startSyncGoods();
+		} catch (Exception e) {
+			try {
+				LogHelper.errorDetailInfo(e);
+			} catch (Exception e1) {
+				e1.printStackTrace();
+			}
+		}
 	}
 
 }

--
Gitblit v1.8.0