From e4ee46557cffc21be597d017a0d16f8e310f6077 Mon Sep 17 00:00:00 2001
From: admin <weikou2014>
Date: 星期一, 23 三月 2020 10:39:03 +0800
Subject: [PATCH] 团队奖励到账

---
 fanli/src/main/java/com/yeshi/fanli/service/impl/order/OrderProcessServiceImpl.java |   28 ++++++++++++++++++++++++++++
 1 files changed, 28 insertions(+), 0 deletions(-)

diff --git a/fanli/src/main/java/com/yeshi/fanli/service/impl/order/OrderProcessServiceImpl.java b/fanli/src/main/java/com/yeshi/fanli/service/impl/order/OrderProcessServiceImpl.java
index b789f96..81fc96c 100644
--- a/fanli/src/main/java/com/yeshi/fanli/service/impl/order/OrderProcessServiceImpl.java
+++ b/fanli/src/main/java/com/yeshi/fanli/service/impl/order/OrderProcessServiceImpl.java
@@ -73,6 +73,7 @@
 import com.yeshi.fanli.service.inter.order.LostOrderService;
 import com.yeshi.fanli.service.inter.order.OrderMoneySettleService;
 import com.yeshi.fanli.service.inter.order.OrderProcessService;
+import com.yeshi.fanli.service.inter.order.OrderTeamRewardService;
 import com.yeshi.fanli.service.inter.order.jd.JDOrderService;
 import com.yeshi.fanli.service.inter.order.pdd.PDDOrderService;
 import com.yeshi.fanli.service.inter.order.tb.TaoBaoOrderService;
@@ -165,6 +166,9 @@
 
 	@Resource
 	private HongBaoV2AddManager hongBaoV2AddManager;
+
+	@Resource
+	private OrderTeamRewardService orderTeamRewardService;
 
 	/**
 	 * 鏄惁鏄垎浜鍗�
@@ -1339,4 +1343,28 @@
 		return false;
 	}
 
+	@Override
+	public void fanliOrderTeamReward() {
+		Date time = new Date();
+		long count = orderTeamRewardService.countCanSettleUid(time);
+		int pageSize = 500;
+		int page = (int) (count % pageSize == 0 ? count / pageSize : count / pageSize + 1);
+		List<Long> uidList = new ArrayList<>();
+		for (int i = 0; i < page; i++) {
+			List<Long> list = orderTeamRewardService.listCanSettleUid(time, i + 1, pageSize);
+			if (list != null && list.size() > 0)
+				uidList.addAll(list);
+		}
+		// 娣诲姞鍒伴槦鍒�
+		if (uidList != null)
+			for (Long uid : uidList)
+				if (!Constant.IS_TEST)
+					CMQManager.getInstance().addFanLiOrderTeamRewardMsg(uid);
+	}
+
+	@Override
+	public void fanliOrderTeamReward(Long uid) throws OrderMoneySettleException {
+		orderMoneySettleService.orderTeamRewardSettle(uid);
+	}
+
 }

--
Gitblit v1.8.0