From e3819aca2480fda8fe90640569b42b882de57a49 Mon Sep 17 00:00:00 2001
From: Administrator <Administrator@S0ZHK00LKCA6OYY>
Date: 星期三, 31 十月 2018 12:34:08 +0800
Subject: [PATCH] 订单处理逻辑变更（不处理6小时内处理过的订单）
---
fanli/src/main/java/com/yeshi/fanli/service/impl/taobao/TaoBaoOrderServiceImpl.java | 42 ++++++++++++++++++++++++++++++++----------
1 files changed, 32 insertions(+), 10 deletions(-)
diff --git a/fanli/src/main/java/com/yeshi/fanli/service/impl/taobao/TaoBaoOrderServiceImpl.java b/fanli/src/main/java/com/yeshi/fanli/service/impl/taobao/TaoBaoOrderServiceImpl.java
index 8756443..8855334 100644
--- a/fanli/src/main/java/com/yeshi/fanli/service/impl/taobao/TaoBaoOrderServiceImpl.java
+++ b/fanli/src/main/java/com/yeshi/fanli/service/impl/taobao/TaoBaoOrderServiceImpl.java
@@ -14,6 +14,8 @@
import com.yeshi.fanli.entity.admin.ReslutOrder;
import com.yeshi.fanli.entity.taobao.TaoBaoOrder;
import com.yeshi.fanli.service.inter.taobao.TaoBaoOrderService;
+import com.yeshi.fanli.util.RedisManager;
+import com.yeshi.fanli.util.StringUtil;
import com.yeshi.fanli.util.taobao.TaoBaoOrderUtil;
@Service
@@ -21,6 +23,9 @@
@Resource
private TaoBaoOrderMapper taoBaoOrderMapper;
+
+ @Resource
+ private RedisManager redisManager;
@Override
public void addTaoBaoOrderList(List<TaoBaoOrder> list) {
@@ -30,7 +35,24 @@
Iterator<String> its = map.keySet().iterator();
while (its.hasNext()) {
String orderId = its.next();
+ String key = "doorder-" + orderId;
+ // redis鍋氶鐜囬檺鍒�
+ try {
+ if (!StringUtil.isNullOrEmpty(redisManager.getCommonString(key))) {
+ continue;
+ }
+
+ } catch (Exception e) {
+
+ }
addTaoBaoOrder(orderId, map.get(orderId));
+ try {
+ // 6灏忔椂鍐呬笉鍐嶅鐞�
+ redisManager.cacheCommonString(key, "1", 60 * 60 * 6);
+ } catch (Exception e) {
+
+ }
+
}
}
@@ -61,31 +83,31 @@
}
}
-
@Override
public List<TaoBaoOrder> getTaoBaoOrderByOrderId(String orderId) {
return taoBaoOrderMapper.selectTaoBaoOrderByOrderId(orderId);
}
@Override
- public List<ReslutOrder> queryJoinHongBao (int start, int count, String key,
- String startTime,String endTime,Integer type,Integer days) throws Exception{
+ public List<ReslutOrder> queryJoinHongBao(int start, int count, String key, String startTime, String endTime,
+ Integer type, Integer days) throws Exception {
return taoBaoOrderMapper.queryJoinHongBao(start, count, key, startTime, endTime, type, days);
}
-
+
@Override
- public int countQueryJoinHongBao(String key, String startTime,String endTime,Integer type,Integer days)throws Exception {
+ public int countQueryJoinHongBao(String key, String startTime, String endTime, Integer type, Integer days)
+ throws Exception {
return taoBaoOrderMapper.countQueryJoinHongBao(key, startTime, endTime, type, days);
}
-
+
@Override
- public double countEstimate(String date)throws Exception {
+ public double countEstimate(String date) throws Exception {
return taoBaoOrderMapper.countEstimate(date);
}
-
+
@Override
- public List<TaoBaoOrder> getStateByOrderIdAndPayment(String orderId, String payment )throws Exception {
+ public List<TaoBaoOrder> getStateByOrderIdAndPayment(String orderId, String payment) throws Exception {
return taoBaoOrderMapper.getStateByOrderIdAndPayment(orderId, payment);
}
-
+
}
--
Gitblit v1.8.0