From 62a447d89331aee1feae7724c7616aa1bb2cfe79 Mon Sep 17 00:00:00 2001
From: admin <weikou2014>
Date: 星期三, 16 十月 2024 14:28:37 +0800
Subject: [PATCH] 将CMQ替换为rabbitmq
---
fanli/src/main/java/com/yeshi/fanli/service/manger/order/OrderMoneyStatisticManager.java | 442 +++++++++++++++++++++++++++---------------------------
1 files changed, 221 insertions(+), 221 deletions(-)
diff --git a/fanli/src/main/java/com/yeshi/fanli/service/manger/order/OrderMoneyStatisticManager.java b/fanli/src/main/java/com/yeshi/fanli/service/manger/order/OrderMoneyStatisticManager.java
index 18407d8..daa9a69 100644
--- a/fanli/src/main/java/com/yeshi/fanli/service/manger/order/OrderMoneyStatisticManager.java
+++ b/fanli/src/main/java/com/yeshi/fanli/service/manger/order/OrderMoneyStatisticManager.java
@@ -1,221 +1,221 @@
-package com.yeshi.fanli.service.manger.order;
-
-import java.math.BigDecimal;
-import java.util.Date;
-import java.util.HashMap;
-import java.util.HashSet;
-import java.util.Iterator;
-import java.util.List;
-import java.util.Map;
-import java.util.Set;
-
-import javax.annotation.Resource;
-
-import org.springframework.stereotype.Component;
-
-import com.yeshi.fanli.dao.mybatis.order.UserOrderDailyStatisticDTO;
-import com.yeshi.fanli.dao.mybatis.order.UserOrderDailyStatisticMapper;
-import com.yeshi.fanli.entity.bus.user.ThreeSaleDetail;
-import com.yeshi.fanli.entity.order.OrderMoneyDailyCount;
-import com.yeshi.fanli.entity.order.SourceTypeEnum;
-import com.yeshi.fanli.entity.order.dividents.TeamDividentsSourceOrderUserMap;
-import com.yeshi.fanli.service.inter.order.OrderMoneyDailyCountService;
-import com.yeshi.fanli.service.inter.user.invite.ThreeSaleDetailService;
-import org.yeshi.utils.TimeUtil;
-
-@Component
-public class OrderMoneyStatisticManager {
-
- @Resource
- private UserOrderDailyStatisticMapper userOrderDailyStatisticMapper;
-
- @Resource
- private OrderMoneyDailyCountService orderMoneyDailyCountService;
-
- @Resource
- private ThreeSaleDetailService threeSaleDetailService;
-
- private static SourceTypeEnum getSourceTypeByDesc(String name) {
- for (SourceTypeEnum type : SourceTypeEnum.values()) {
- if (type.getDesc().equalsIgnoreCase(name))
- return type;
- }
- return null;
- }
-
- /**
- * 鍚屾鑷喘涓庡垎浜禋鐩稿叧鏁版嵁
- * @Title: syncFanliAndShareData
- * @Description:
- * @param startTime
- * @param endTime
- * void 杩斿洖绫诲瀷
- * @throws
- */
- public void syncFanliAndShareData(Date startTime, Date endTime) {
- List<UserOrderDailyStatisticDTO> dtoList = userOrderDailyStatisticMapper
- .listFanLiAndShareByPlaceOrderTime(startTime, endTime);
-
- for (UserOrderDailyStatisticDTO dto : dtoList) {
- OrderMoneyDailyCount count = new OrderMoneyDailyCount();
- count.setUid(dto.getUid());
- count.setCountDay(new Date(TimeUtil.convertToTimeTemp(dto.getDay(), "yyyy-MM-dd")));
- if (dto.getMoney() != null)
- count.setIncome(
- dto.getMoney().setScale(2, BigDecimal.ROUND_HALF_UP).multiply(new BigDecimal(100)).intValue());
- count.setOrderNum(dto.getOrderCount());
- count.setSourceType(getSourceTypeByDesc(dto.getType()));
- count.setYearMonth(
- TimeUtil.getGernalTime(TimeUtil.convertToTimeTemp(dto.getDay(), "yyyy-MM-dd"), "yyyy-MM"));
- orderMoneyDailyCountService.saveDailyCount(count);
- }
- }
-
- /**
- * 鍚屾鍥㈤槦璁㈠崟鐩稿叧鏁版嵁锛�1绾�/2绾э級
- * @Title: syncTeamData
- * @Description:
- * @param startTime
- * @param endTime
- * void 杩斿洖绫诲瀷
- * @throws
- */
- public void syncTeamData(Date startTime, Date endTime) {
- List<UserOrderDailyStatisticDTO> dtoList = userOrderDailyStatisticMapper.listTeamByPlaceOrderTime(startTime,
- endTime);
-
- for (UserOrderDailyStatisticDTO dto : dtoList) {
- OrderMoneyDailyCount count = new OrderMoneyDailyCount();
- count.setUid(dto.getUid());
- count.setCountDay(new Date(TimeUtil.convertToTimeTemp(dto.getDay(), "yyyy-MM-dd")));
- if (dto.getMoney() != null)
- count.setIncomeTeam(
- dto.getMoney().setScale(2, BigDecimal.ROUND_HALF_UP).multiply(new BigDecimal(100)).intValue());
- count.setOrderNumTeam(dto.getOrderCount());
- count.setSourceType(getSourceTypeByDesc(dto.getType()));
- count.setYearMonth(
- TimeUtil.getGernalTime(TimeUtil.convertToTimeTemp(dto.getDay(), "yyyy-MM-dd"), "yyyy-MM"));
- orderMoneyDailyCountService.saveDailyCount(count);
- }
- }
-
- /**
- * 鍚屾璁㈠崟鏁伴噺鐩稿叧鏁版嵁
- * @Title: syncOrderNum
- * @Description:
- * @param minTime
- * @param maxTime
- * void 杩斿洖绫诲瀷
- * @throws
- */
- // 鍚屾璁㈠崟鏁伴噺鏁版嵁
- public void syncOrderNum(Date minTime, Date maxTime) {
- List<UserOrderDailyStatisticDTO> dtoList = userOrderDailyStatisticMapper.listOrderCountByPlaceOrderTime(minTime,
- maxTime);
- Set<Long> uidSets = new HashSet<>();
- // 缁熻浠婂ぉ鐨勬暟鎹�
- for (UserOrderDailyStatisticDTO dto : dtoList) {
- uidSets.add(dto.getUid());
- }
-
- Map<Long, List<ThreeSaleDetail>> bossMap = new HashMap<>();
-
- Map<String, Integer> countMap = new HashMap<>();
-
- // 鑱氬悎鏁版嵁
- for (UserOrderDailyStatisticDTO dto : dtoList) {
- if (bossMap.get(dto.getUid()) == null) {
- List<ThreeSaleDetail> list = threeSaleDetailService.listByWorkerUid(dto.getUid());
- bossMap.put(dto.getUid(), list);
- }
- List<ThreeSaleDetail> tsList = bossMap.get(dto.getUid());
- if (tsList != null)
- for (ThreeSaleDetail tsd : tsList) {
- String key = tsd.getBossUid() + "#" + dto.getDay() + "#";
- if (tsd.getLevel() < 3)
- key += tsd.getLevel();
- else
- key += 3;
- if (countMap.get(key) == null)
- countMap.put(key, 0);
- countMap.put(key, countMap.get(key) + dto.getOrderCount());
- }
-
- }
-
- // 鎻掑叆鏁版嵁
- for (Iterator<String> its = countMap.keySet().iterator(); its.hasNext();) {
- String key = its.next();
- String uid = key.split("#")[0];
- String day = key.split("#")[1];
- int level = Integer.parseInt(key.split("#")[2]);
-
- OrderMoneyDailyCount count = new OrderMoneyDailyCount();
- count.setUid(Long.parseLong(uid));
- count.setCountDay(new Date(TimeUtil.convertToTimeTemp(day, "yyyy-MM-dd")));
- if (level == 1)
- count.setDirectOrderNum(countMap.get(key));
- else if (level == 2)
- count.setInDirectOrderNum(countMap.get(key));
- else
- count.setBeyondOrderNum(countMap.get(key));
-
- count.setYearMonth(TimeUtil.getGernalTime(TimeUtil.convertToTimeTemp(day, "yyyy-MM-dd"), "yyyy-MM"));
- orderMoneyDailyCountService.saveDailyCount(count);
-
- }
-
- }
-
- /**
- * 鍚屾鍒嗙孩璁㈠崟缁熻鏁版嵁
- * @Title: syncDividents
- * @Description:
- * @param minTime
- * @param maxTime
- * void 杩斿洖绫诲瀷
- * @throws
- */
- public void syncDividents(Date minTime, Date maxTime) {
- List<UserOrderDailyStatisticDTO> list = userOrderDailyStatisticMapper.listDividentsOrderByCreateTime(minTime,
- maxTime);
-
- List<UserOrderDailyStatisticDTO> countList = userOrderDailyStatisticMapper
- .listDividentsOrderCountByCreateTime(minTime, maxTime);
- Map<String, Integer> countMap = new HashMap<>();
- for (UserOrderDailyStatisticDTO dto : countList) {
- countMap.put(dto.getDay() + "#" + dto.getUid(), dto.getOrderCount());
- }
-
- if (list != null)
- for (UserOrderDailyStatisticDTO dto : list) {
- OrderMoneyDailyCount count = new OrderMoneyDailyCount();
- count.setUid(dto.getUid());
- count.setCountDay(new Date(TimeUtil.convertToTimeTemp(dto.getDay(), "yyyy-MM-dd")));
- if (Integer.parseInt(dto.getType()) == TeamDividentsSourceOrderUserMap.TYPE_TEAM_DIVIDENTS) {
- count.setTeamReward(dto.getMoney().setScale(2, BigDecimal.ROUND_HALF_UP)
- .multiply(new BigDecimal(100)).intValue());
- count.setTeamRewardNum(dto.getOrderCount());
- } else {
- count.setTeamSubsidy(dto.getMoney().setScale(2, BigDecimal.ROUND_HALF_UP)
- .multiply(new BigDecimal(100)).intValue());
- count.setTeamSubsidyNum(dto.getOrderCount());
- }
-
- Integer totalCount = countMap.get(dto.getDay() + "#" + dto.getUid());
- if(totalCount!=null){
- count.setTeamDividentsOrderNum(totalCount);
- }
-
- count.setYearMonth(
- TimeUtil.getGernalTime(TimeUtil.convertToTimeTemp(dto.getDay(), "yyyy-MM-dd"), "yyyy-MM"));
- if (dto.getDay().equalsIgnoreCase("2020-05-03") && dto.getUid() == 389677L) {
- System.out.println(dto);
- }
-
- orderMoneyDailyCountService.saveDailyCount(count);
-
- }
- }
-
-}
+package com.yeshi.fanli.service.manger.order;
+
+import java.math.BigDecimal;
+import java.util.Date;
+import java.util.HashMap;
+import java.util.HashSet;
+import java.util.Iterator;
+import java.util.List;
+import java.util.Map;
+import java.util.Set;
+
+import javax.annotation.Resource;
+
+import org.springframework.stereotype.Component;
+
+import com.yeshi.fanli.dao.mybatis.order.UserOrderDailyStatisticDTO;
+import com.yeshi.fanli.dao.mybatis.order.UserOrderDailyStatisticMapper;
+import com.yeshi.fanli.entity.bus.user.ThreeSaleDetail;
+import com.yeshi.fanli.entity.order.OrderMoneyDailyCount;
+import com.yeshi.fanli.entity.order.SourceTypeEnum;
+import com.yeshi.fanli.entity.order.dividents.TeamDividentsSourceOrderUserMap;
+import com.yeshi.fanli.service.inter.order.OrderMoneyDailyCountService;
+import com.yeshi.fanli.service.inter.user.invite.ThreeSaleDetailService;
+import org.yeshi.utils.TimeUtil;
+
+@Component
+public class OrderMoneyStatisticManager {
+
+ @Resource
+ private UserOrderDailyStatisticMapper userOrderDailyStatisticMapper;
+
+ @Resource
+ private OrderMoneyDailyCountService orderMoneyDailyCountService;
+
+ @Resource
+ private ThreeSaleDetailService threeSaleDetailService;
+
+ private static SourceTypeEnum getSourceTypeByDesc(String name) {
+ for (SourceTypeEnum type : SourceTypeEnum.values()) {
+ if (type.getDesc().equalsIgnoreCase(name))
+ return type;
+ }
+ return null;
+ }
+
+ /**
+ * 鍚屾鑷喘涓庡垎浜禋鐩稿叧鏁版嵁
+ * @Title: syncFanliAndShareData
+ * @Description:
+ * @param startTime
+ * @param endTime
+ * void 杩斿洖绫诲瀷
+ * @throws
+ */
+ public void syncFanliAndShareData(Date startTime, Date endTime) {
+ List<UserOrderDailyStatisticDTO> dtoList = userOrderDailyStatisticMapper
+ .listFanLiAndShareByPlaceOrderTime(startTime, endTime);
+
+ for (UserOrderDailyStatisticDTO dto : dtoList) {
+ OrderMoneyDailyCount count = new OrderMoneyDailyCount();
+ count.setUid(dto.getUid());
+ count.setCountDay(new Date(TimeUtil.convertToTimeTemp(dto.getDay(), "yyyy-MM-dd")));
+ if (dto.getMoney() != null)
+ count.setIncome(
+ dto.getMoney().setScale(2, BigDecimal.ROUND_HALF_UP).multiply(new BigDecimal(100)).intValue());
+ count.setOrderNum(dto.getOrderCount());
+ count.setSourceType(getSourceTypeByDesc(dto.getType()));
+ count.setYearMonth(
+ TimeUtil.getGernalTime(TimeUtil.convertToTimeTemp(dto.getDay(), "yyyy-MM-dd"), "yyyy-MM"));
+ orderMoneyDailyCountService.saveDailyCount(count);
+ }
+ }
+
+ /**
+ * 鍚屾鍥㈤槦璁㈠崟鐩稿叧鏁版嵁锛�1绾�/2绾э級
+ * @Title: syncTeamData
+ * @Description:
+ * @param startTime
+ * @param endTime
+ * void 杩斿洖绫诲瀷
+ * @throws
+ */
+ public void syncTeamData(Date startTime, Date endTime) {
+ List<UserOrderDailyStatisticDTO> dtoList = userOrderDailyStatisticMapper.listTeamByPlaceOrderTime(startTime,
+ endTime);
+
+ for (UserOrderDailyStatisticDTO dto : dtoList) {
+ OrderMoneyDailyCount count = new OrderMoneyDailyCount();
+ count.setUid(dto.getUid());
+ count.setCountDay(new Date(TimeUtil.convertToTimeTemp(dto.getDay(), "yyyy-MM-dd")));
+ if (dto.getMoney() != null)
+ count.setIncomeTeam(
+ dto.getMoney().setScale(2, BigDecimal.ROUND_HALF_UP).multiply(new BigDecimal(100)).intValue());
+ count.setOrderNumTeam(dto.getOrderCount());
+ count.setSourceType(getSourceTypeByDesc(dto.getType()));
+ count.setYearMonth(
+ TimeUtil.getGernalTime(TimeUtil.convertToTimeTemp(dto.getDay(), "yyyy-MM-dd"), "yyyy-MM"));
+ orderMoneyDailyCountService.saveDailyCount(count);
+ }
+ }
+
+ /**
+ * 鍚屾璁㈠崟鏁伴噺鐩稿叧鏁版嵁
+ * @Title: syncOrderNum
+ * @Description:
+ * @param minTime
+ * @param maxTime
+ * void 杩斿洖绫诲瀷
+ * @throws
+ */
+ // 鍚屾璁㈠崟鏁伴噺鏁版嵁
+ public void syncOrderNum(Date minTime, Date maxTime) {
+ List<UserOrderDailyStatisticDTO> dtoList = userOrderDailyStatisticMapper.listOrderCountByPlaceOrderTime(minTime,
+ maxTime);
+ Set<Long> uidSets = new HashSet<>();
+ // 缁熻浠婂ぉ鐨勬暟鎹�
+ for (UserOrderDailyStatisticDTO dto : dtoList) {
+ uidSets.add(dto.getUid());
+ }
+
+ Map<Long, List<ThreeSaleDetail>> bossMap = new HashMap<>();
+
+ Map<String, Integer> countMap = new HashMap<>();
+
+ // 鑱氬悎鏁版嵁
+ for (UserOrderDailyStatisticDTO dto : dtoList) {
+ if (bossMap.get(dto.getUid()) == null) {
+ List<ThreeSaleDetail> list = threeSaleDetailService.listByWorkerUid(dto.getUid());
+ bossMap.put(dto.getUid(), list);
+ }
+ List<ThreeSaleDetail> tsList = bossMap.get(dto.getUid());
+ if (tsList != null)
+ for (ThreeSaleDetail tsd : tsList) {
+ String key = tsd.getBossUid() + "#" + dto.getDay() + "#";
+ if (tsd.getLevel() < 3)
+ key += tsd.getLevel();
+ else
+ key += 3;
+ if (countMap.get(key) == null)
+ countMap.put(key, 0);
+ countMap.put(key, countMap.get(key) + dto.getOrderCount());
+ }
+
+ }
+
+ // 鎻掑叆鏁版嵁
+ for (Iterator<String> its = countMap.keySet().iterator(); its.hasNext();) {
+ String key = its.next();
+ String uid = key.split("#")[0];
+ String day = key.split("#")[1];
+ int level = Integer.parseInt(key.split("#")[2]);
+
+ OrderMoneyDailyCount count = new OrderMoneyDailyCount();
+ count.setUid(Long.parseLong(uid));
+ count.setCountDay(new Date(TimeUtil.convertToTimeTemp(day, "yyyy-MM-dd")));
+ if (level == 1)
+ count.setDirectOrderNum(countMap.get(key));
+ else if (level == 2)
+ count.setInDirectOrderNum(countMap.get(key));
+ else
+ count.setBeyondOrderNum(countMap.get(key));
+
+ count.setYearMonth(TimeUtil.getGernalTime(TimeUtil.convertToTimeTemp(day, "yyyy-MM-dd"), "yyyy-MM"));
+ orderMoneyDailyCountService.saveDailyCount(count);
+
+ }
+
+ }
+
+ /**
+ * 鍚屾鍒嗙孩璁㈠崟缁熻鏁版嵁
+ * @Title: syncDividents
+ * @Description:
+ * @param minTime
+ * @param maxTime
+ * void 杩斿洖绫诲瀷
+ * @throws
+ */
+ public void syncDividents(Date minTime, Date maxTime) {
+ List<UserOrderDailyStatisticDTO> list = userOrderDailyStatisticMapper.listDividentsOrderByCreateTime(minTime,
+ maxTime);
+
+ List<UserOrderDailyStatisticDTO> countList = userOrderDailyStatisticMapper
+ .listDividentsOrderCountByCreateTime(minTime, maxTime);
+ Map<String, Integer> countMap = new HashMap<>();
+ for (UserOrderDailyStatisticDTO dto : countList) {
+ countMap.put(dto.getDay() + "#" + dto.getUid(), dto.getOrderCount());
+ }
+
+ if (list != null)
+ for (UserOrderDailyStatisticDTO dto : list) {
+ OrderMoneyDailyCount count = new OrderMoneyDailyCount();
+ count.setUid(dto.getUid());
+ count.setCountDay(new Date(TimeUtil.convertToTimeTemp(dto.getDay(), "yyyy-MM-dd")));
+ if (Integer.parseInt(dto.getType()) == TeamDividentsSourceOrderUserMap.TYPE_TEAM_DIVIDENTS) {
+ count.setTeamReward(dto.getMoney().setScale(2, BigDecimal.ROUND_HALF_UP)
+ .multiply(new BigDecimal(100)).intValue());
+ count.setTeamRewardNum(dto.getOrderCount());
+ } else {
+ count.setTeamSubsidy(dto.getMoney().setScale(2, BigDecimal.ROUND_HALF_UP)
+ .multiply(new BigDecimal(100)).intValue());
+ count.setTeamSubsidyNum(dto.getOrderCount());
+ }
+
+ Integer totalCount = countMap.get(dto.getDay() + "#" + dto.getUid());
+ if(totalCount!=null){
+ count.setTeamDividentsOrderNum(totalCount);
+ }
+
+ count.setYearMonth(
+ TimeUtil.getGernalTime(TimeUtil.convertToTimeTemp(dto.getDay(), "yyyy-MM-dd"), "yyyy-MM"));
+ if (dto.getDay().equalsIgnoreCase("2020-05-03") && dto.getUid() == 389677L) {
+ System.out.println(dto);
+ }
+
+ orderMoneyDailyCountService.saveDailyCount(count);
+
+ }
+ }
+
+}
--
Gitblit v1.8.0