From 5d1b933b0814565fd4095dea7519dd5389582082 Mon Sep 17 00:00:00 2001
From: Administrator <Administrator@S0ZHK00LKCA6OYY>
Date: 星期五, 09 十一月 2018 18:47:26 +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