From efba42a325e1cf71c1d0f7a6ac46a0141c23443a Mon Sep 17 00:00:00 2001
From: admin <weikou2014>
Date: 星期二, 12 三月 2019 16:25:11 +0800
Subject: [PATCH] 增加序列化
---
fanli/src/main/java/com/yeshi/fanli/service/impl/order/PidOrderServiceImpl.java | 110 +++++++++++-------------------------------------------
1 files changed, 23 insertions(+), 87 deletions(-)
diff --git a/fanli/src/main/java/com/yeshi/fanli/service/impl/order/PidOrderServiceImpl.java b/fanli/src/main/java/com/yeshi/fanli/service/impl/order/PidOrderServiceImpl.java
index 7cbc72c..f81960c 100644
--- a/fanli/src/main/java/com/yeshi/fanli/service/impl/order/PidOrderServiceImpl.java
+++ b/fanli/src/main/java/com/yeshi/fanli/service/impl/order/PidOrderServiceImpl.java
@@ -13,7 +13,6 @@
import org.springframework.stereotype.Service;
import org.springframework.transaction.annotation.Transactional;
-import com.yeshi.fanli.dao.mybatis.AccountDetailsMapper;
import com.yeshi.fanli.dao.mybatis.AccountMessageMapper;
import com.yeshi.fanli.dao.mybatis.HongBaoManageMapper;
import com.yeshi.fanli.dao.mybatis.PidOrderMapper;
@@ -23,7 +22,6 @@
import com.yeshi.fanli.dao.mybatis.share.PidUserMapper;
import com.yeshi.fanli.dao.mybatis.taobao.TaoBaoOrderMapper;
import com.yeshi.fanli.dao.order.PidOrderDao;
-import com.yeshi.fanli.entity.bus.user.AccountDetails;
import com.yeshi.fanli.entity.bus.user.HongBao;
import com.yeshi.fanli.entity.bus.user.HongBaoManage;
import com.yeshi.fanli.entity.bus.user.UserInfo;
@@ -31,17 +29,18 @@
import com.yeshi.fanli.entity.taobao.PidUser;
import com.yeshi.fanli.entity.taobao.TaoBaoOrder;
import com.yeshi.fanli.entity.taobao.TaoBaoUnionConfig;
+import com.yeshi.fanli.exception.share.UserShareGoodsRecordException;
import com.yeshi.fanli.log.LogHelper;
import com.yeshi.fanli.service.inter.hongbao.HongBaoManageService;
import com.yeshi.fanli.service.inter.order.PidOrderService;
import com.yeshi.fanli.service.inter.taobao.TaoBaoUnionConfigService;
import com.yeshi.fanli.service.inter.user.UserNotificationService;
+import com.yeshi.fanli.service.inter.user.UserShareGoodsGroupService;
import com.yeshi.fanli.util.CMQManager;
import com.yeshi.fanli.util.Constant;
import com.yeshi.fanli.util.MoneyBigDecimalUtil;
import com.yeshi.fanli.util.RedisManager;
import com.yeshi.fanli.util.StringUtil;
-import com.yeshi.fanli.util.factory.AccountDetailsFactory;
import com.yeshi.fanli.util.factory.HongBaoFactory;
import com.yeshi.fanli.util.taobao.TaoBaoOrderUtil;
@@ -61,9 +60,6 @@
@Resource
private UserInfoMapper userInfoMapper;
-
- @Resource
- private AccountDetailsMapper accountDetailsMapper;
@Resource
private AccountMessageMapper accountMessageMapper;
@@ -91,6 +87,9 @@
// @Resource
// private LostOrderService lostOrderService;
+
+ @Resource
+ private UserShareGoodsGroupService userShareGoodsGroupService;
@Override
@Transactional
@@ -257,7 +256,8 @@
// 鍙湅鏈夌敤鎴稩d鐨勬儏鍐�
if (orders.get(0).getUserInfo() != null) {
// 鏍规嵁绗竴涓殑璁㈠崟鍒涘缓鏃堕棿鏉ョ‘瀹氳繑鍒╂瘮渚�
- BigDecimal rate = hongBaoManageService.getShareRate(orders.get(0).getOrderCreateTime().getTime());
+ BigDecimal rate = hongBaoManageService.getShareRate(orders.get(0).getOrderCreateTime().getTime())
+ .divide(new BigDecimal("100"));
List<HongBao> hbList = hongBaoMapper.selectByOrderId(orderId);
if (hbList.size() <= 0) {// 杩樻病鏈夊姞鍏ョ孩鍖�
// 鍔犲叆绾㈠寘
@@ -288,14 +288,19 @@
}
hongBaoMapper.insertSelective(hongBao);
-
+
+ //缁熻鍒嗕韩璁㈠崟鐨勬暟鎹�
try {
- // 绗笁鏂规彁鎴愯鍗曡缁熻鐨勯�氱煡
- userNotificationService.tiChengStatisticed(hongBao.getUserInfo().getId(),
- hongBao.getOrderId(), hongBao.getMoney());
- } catch (Exception e) {
-
+ hongBao.setAuctionId(order.getAuctionId());
+ userShareGoodsGroupService.updateOrderRecord(hongBao);
+ } catch (UserShareGoodsRecordException e1) {
+ try {
+ LogHelper.errorDetailInfo(e1);
+ } catch (Exception e) {
+ e.printStackTrace();
+ }
}
+
PidOrder updatePidOrder = new PidOrder();
updatePidOrder.setId(order.getId());
@@ -322,12 +327,7 @@
hongBao2.setOrderId(order.getOrderId());
hongBaoMapper.insertSelective(hongBao2);
- try {
- // 绗笁鏂规彁鎴愯鍗曡缁熻鐨勯�氱煡
- userNotificationService.tiChengStatisticed(hongBao2.getUserInfo().getId(),
- hongBao2.getOrderId(), hongBao2.getMoney());
- } catch (Exception e) {
- }
+
}
@@ -350,12 +350,6 @@
hongBao3.setOrderId(order.getOrderId());
hongBaoMapper.insertSelective(hongBao3);
- try {
- // 绗笁鏂规彁鎴愯鍗曡缁熻鐨勯�氱煡
- userNotificationService.tiChengStatisticed(hongBao3.getUserInfo().getId(),
- hongBao3.getOrderId(), hongBao3.getMoney());
- } catch (Exception e) {
- }
}
}
}
@@ -456,22 +450,6 @@
// 缁撶畻鍒拌处鎴�
@Override
- public void balanceOrder() {
- // 鑾峰彇鍒拌鏈�25鏃ュ彲缁撶畻鐨勮鍗�
- List<PidOrder> list = pidOrderMapper.getCanBalanceList(1000);
- if (list != null) {
- Map<String, List<PidOrder>> map = parseOrderMap(list);
- Iterator<String> its = map.keySet().iterator();
- while (its.hasNext()) {
- String orderId = its.next();
- List<PidOrder> orders = map.get(orderId);
- for (int i = 0; i < orders.size(); i++)
- balanceOrder(orders.get(i));
- }
- }
- }
-
- @Override
public void compareOrderAndHongBao() {
List<PidOrder> list = pidOrderMapper.selectByState("璁㈠崟浠樻", 100);
list.addAll(pidOrderMapper.selectByState("璁㈠崟缁撶畻", 100));
@@ -501,39 +479,6 @@
}
}
- @Transactional
- @Override
- public void balanceOrder(PidOrder pidOrder) {
- if (pidOrder.getHongBao() == null)
- return;
- // 鏌ユ壘绾㈠寘
- HongBao hongBao = hongBaoMapper.selectByPrimaryKey(pidOrder.getHongBao().getId());
- if (hongBao.getState() == HongBao.STATE_SHIXIAO || hongBao.getState() == HongBao.STATE_YILINGQU)
- return;
-
- HongBao updateHongBao = new HongBao();
- updateHongBao.setId(hongBao.getId());
- updateHongBao.setGetTime(System.currentTimeMillis());
- updateHongBao.setState(HongBao.STATE_YILINGQU);
- hongBaoMapper.updateByPrimaryKeySelective(updateHongBao);
-
- // 鍔犲叆鐢ㄦ埛浣欓
- userInfoMapper.addHongBaoByUid(hongBao.getUserInfo().getId(), hongBao.getMoney());
- // 鍔犲叆璐︽埛鏄庣粏
- AccountDetails ad = AccountDetailsFactory.create("+" + hongBao.getMoney(), AccountDetailsFactory.SHARE_GOODS,
- null, null, hongBao.getUserInfo());
- accountDetailsMapper.insertSelective(ad);
- try {
- userNotificationService.tiChengRecieved(hongBao.getUserInfo().getId(), hongBao.getMoney());
- } catch (Exception e) {
- }
-
- PidOrder updatePidOrder = new PidOrder();
- updatePidOrder.setId(pidOrder.getId());
- updatePidOrder.setAccountBalance(true);
- updatePidOrder.setAccountBalanceTime(new Date());
- pidOrderMapper.updateByPrimaryKeySelective(updatePidOrder);
- }
@Override
public void weiQuan(String orderId) {
@@ -565,10 +510,10 @@
hongBaoMapper.updateByPrimaryKeySelective(updateHongBao);
// 澶勭悊閫�娆�
userInfoMapper.subHongBaoByUid(hongBao.getUserInfo().getId(), hongBao.getMoney());
- // 娣诲姞璧勯噾鏄庣粏
- AccountDetails ad = AccountDetailsFactory.create("-" + hongBao.getMoney(),
- AccountDetailsFactory.SHARE_GOODS_DRAWBACK, null, null, hongBao.getUserInfo());
- accountDetailsMapper.insertSelective(ad);
+
+
+
+
// 缁存潈閫氱煡
try {
@@ -592,11 +537,6 @@
hongBaoMapper.updateByPrimaryKeySelective(updateChildHongBao);
// 澶勭悊閫�娆�
userInfoMapper.subHongBaoByUid(cb.getUserInfo().getId(), cb.getMoney());
- // 娣诲姞璧勯噾鏄庣粏
- AccountDetails ad = AccountDetailsFactory.create("-" + cb.getMoney(),
- AccountDetailsFactory.SHARE_GOODS_DRAWBACK, null, null,
- cb.getUserInfo());
- accountDetailsMapper.insertSelective(ad);
// 缁存潈閫氱煡
try {
@@ -654,10 +594,6 @@
hongBaoMapper.updateByPrimaryKeySelective(updateChildHongBao);
// 澶勭悊閫�娆�
userInfoMapper.subHongBaoByUid(cb.getUserInfo().getId(), cb.getMoney());
- // 娣诲姞璧勯噾鏄庣粏
- AccountDetails ad = AccountDetailsFactory.create("-" + cb.getMoney(),
- AccountDetailsFactory.SHARE_GOODS_DRAWBACK, null, null, cb.getUserInfo());
- accountDetailsMapper.insertSelective(ad);
// 缁存潈閫氱煡
try {
--
Gitblit v1.8.0