From 7e0c39b083de1c6f6aba49909b63d177e3f7ea3e Mon Sep 17 00:00:00 2001
From: Administrator <Administrator@S0ZHK00LKCA6OYY>
Date: 星期三, 31 十月 2018 15:49:14 +0800
Subject: [PATCH] 订单爬取时间调整
---
fanli/src/main/java/com/yeshi/fanli/job/UpdateOrderJob.java | 23 +++++++++++++++++++++++
1 files changed, 23 insertions(+), 0 deletions(-)
diff --git a/fanli/src/main/java/com/yeshi/fanli/job/UpdateOrderJob.java b/fanli/src/main/java/com/yeshi/fanli/job/UpdateOrderJob.java
index c24cf96..87a3f5f 100644
--- a/fanli/src/main/java/com/yeshi/fanli/job/UpdateOrderJob.java
+++ b/fanli/src/main/java/com/yeshi/fanli/job/UpdateOrderJob.java
@@ -27,6 +27,8 @@
import com.yeshi.fanli.service.inter.taobao.TaoBaoWeiQuanOrderService;
import com.yeshi.fanli.util.CMQManager;
import com.yeshi.fanli.util.Constant;
+import com.yeshi.fanli.util.RedisManager;
+import com.yeshi.fanli.util.StringUtil;
import com.yeshi.fanli.util.TimeUtil;
import com.yeshi.fanli.util.taobao.TaoBao110Util;
import com.yeshi.fanli.util.taobao.TaoBaoOrderUtil;
@@ -68,6 +70,9 @@
@Resource
private DataMonitorService dataMonitorService;
+
+ @Resource
+ private RedisManager redisManager;
private void updateOrder(long startTime, long endTime) {
List<TaoBaoUnionConfig> configList = taoBaoUnionConfigService.getConfigByTypeCache(PidUser.TYPE_FANLI_ANDROID);
@@ -122,7 +127,25 @@
while (its.hasNext()) {
String key = its.next();
List<TaoBaoOrder> orders = map.get(key);
+ String redisKey = "addorderqueue-" + key;
+ // redis鍋氶鐜囬檺鍒�
+ try {
+ if (!StringUtil.isNullOrEmpty(redisManager.getCommonString(redisKey))) {
+ continue;
+ }
+
+ } catch (Exception e) {
+
+ }
+
CMQManager.getInstance().addTaoBaoOrderMsg(key, orders);
+
+ try {
+ // 6灏忔椂鍐呬笉鍐嶅鐞�
+ redisManager.cacheCommonString(redisKey, "1", 60 * 60 * 6);
+ } catch (Exception e) {
+
+ }
}
}
} catch (Exception e) {
--
Gitblit v1.8.0