From a1c01c3b1df1034eecd0e35a0bf75cf0a2bf5d92 Mon Sep 17 00:00:00 2001
From: admin <weikou2014>
Date: 星期一, 03 六月 2019 14:27:58 +0800
Subject: [PATCH] 精选库更新改为1个小时更新2000条数据
---
fanli/src/main/java/com/yeshi/fanli/service/impl/order/CommonOrderServiceImpl.java | 43 ++++++++++++++++++++++++++++++-------------
1 files changed, 30 insertions(+), 13 deletions(-)
diff --git a/fanli/src/main/java/com/yeshi/fanli/service/impl/order/CommonOrderServiceImpl.java b/fanli/src/main/java/com/yeshi/fanli/service/impl/order/CommonOrderServiceImpl.java
index 1de9e6a..69bc0db 100644
--- a/fanli/src/main/java/com/yeshi/fanli/service/impl/order/CommonOrderServiceImpl.java
+++ b/fanli/src/main/java/com/yeshi/fanli/service/impl/order/CommonOrderServiceImpl.java
@@ -17,18 +17,21 @@
import com.yeshi.fanli.dao.mybatis.order.CommonOrderGoodsMapper;
import com.yeshi.fanli.dao.mybatis.order.CommonOrderMapper;
+import com.yeshi.fanli.dao.mybatis.order.CommonOrderTradeIdMapMapper;
import com.yeshi.fanli.dao.mybatis.taobao.TaoBaoWeiQuanOrderMapper;
import com.yeshi.fanli.entity.bus.user.HongBaoV2;
import com.yeshi.fanli.entity.bus.user.UserInfo;
import com.yeshi.fanli.entity.bus.user.UserSystemCouponRecord;
import com.yeshi.fanli.entity.order.CommonOrder;
import com.yeshi.fanli.entity.order.CommonOrderGoods;
+import com.yeshi.fanli.entity.order.CommonOrderTradeIdMap;
import com.yeshi.fanli.entity.system.SystemCoupon.CouponTypeEnum;
import com.yeshi.fanli.entity.taobao.TaoBaoGoodsBrief;
import com.yeshi.fanli.entity.taobao.TaoBaoOrder;
import com.yeshi.fanli.entity.taobao.TaoBaoWeiQuanOrder;
import com.yeshi.fanli.exception.order.CommonOrderException;
import com.yeshi.fanli.exception.taobao.TaobaoGoodsDownException;
+import com.yeshi.fanli.log.LogHelper;
import com.yeshi.fanli.service.inter.common.JumpDetailV2Service;
import com.yeshi.fanli.service.inter.config.ConfigService;
import com.yeshi.fanli.service.inter.config.SystemCouponService;
@@ -78,6 +81,9 @@
@Resource
private HongBaoV2Service hongBaoV2Service;
+
+ @Resource
+ private CommonOrderTradeIdMapMapper commonOrderTradeIdMapMapper;
// 濂栧姳璁㈠崟鍥剧墖
public final static String PIC_REWARD = "http://img.flqapp.com/resource/order/order_state_reward.png";
@@ -597,6 +603,7 @@
taoBaoGoods = TaoKeApiUtil.getSimpleGoodsInfo(taoBaoOrder.getAuctionId());
} catch (TaobaoGoodsDownException e) {
e.printStackTrace();
+ LogHelper.errorDetailInfo(e, "AUCTIONID:"+taoBaoOrder.getAuctionId(), "");
taoBaoGoods = TaoBaoUtil.getSimpleGoodsBrief(taoBaoOrder.getAuctionId());
}
if (taoBaoGoods != null) {
@@ -613,6 +620,10 @@
commonOrder.setStateWholeOrder(wholeOrderState);
commonOrderMapper.insertSelective(commonOrder);
+ // 鎻掑叆鏄犲皠锛屼繚璇佷氦鏄揑D鐨勫畬鏁存��
+ commonOrderTradeIdMapMapper.insertSelective(
+ new CommonOrderTradeIdMap(commonOrder.getId(), commonOrder.getTradeId(), new Date(),commonOrder.getSourceType()));
+
commonOrderList.add(commonOrder);
continue;
} else {// 淇敼
@@ -622,19 +633,25 @@
continue;
}
CommonOrder newCommonOrder = TaoBaoOrderUtil.convert(taoBaoOrder);
- CommonOrder updateCommonOrder = new CommonOrder(commonOrder.getId());
- updateCommonOrder.seteIncome(newCommonOrder.geteIncome());
- updateCommonOrder.setEstimate(newCommonOrder.getEstimate());
- updateCommonOrder.setPayment(newCommonOrder.getPayment());
- updateCommonOrder.setSettlement(newCommonOrder.getSettlement());
- updateCommonOrder.setSettleTime(newCommonOrder.getSettleTime());
- updateCommonOrder.setState(newCommonOrder.getState());
- updateCommonOrder.setStateWholeOrder(wholeOrderState);
- updateCommonOrder.setUpdateTime(new Date());
- updateCommonOrder.setTradeId(newCommonOrder.getTradeId());
- commonOrderMapper.updateByPrimaryKeySelective(updateCommonOrder);
- commonOrderList.add(commonOrderMapper.selectByPrimaryKey(updateCommonOrder.getId()));
- continue;
+
+ // 浜ゆ槗ID涓�鑷存墠淇敼
+ if (commonOrder.getTradeId() != null
+ && commonOrder.getTradeId().equalsIgnoreCase(newCommonOrder.getTradeId())) {
+
+ CommonOrder updateCommonOrder = new CommonOrder(commonOrder.getId());
+ updateCommonOrder.seteIncome(newCommonOrder.geteIncome());
+ updateCommonOrder.setEstimate(newCommonOrder.getEstimate());
+ updateCommonOrder.setPayment(newCommonOrder.getPayment());
+ updateCommonOrder.setSettlement(newCommonOrder.getSettlement());
+ updateCommonOrder.setSettleTime(newCommonOrder.getSettleTime());
+ updateCommonOrder.setState(newCommonOrder.getState());
+ updateCommonOrder.setStateWholeOrder(wholeOrderState);
+ updateCommonOrder.setUpdateTime(new Date());
+ updateCommonOrder.setTradeId(newCommonOrder.getTradeId());
+ commonOrderMapper.updateByPrimaryKeySelective(updateCommonOrder);
+ commonOrderList.add(commonOrderMapper.selectByPrimaryKey(updateCommonOrder.getId()));
+ } else
+ commonOrderList.add(commonOrder);
}
}
return commonOrderList;
--
Gitblit v1.8.0