From 81da61b828e29b7745e1382dfbbaeb685dc083ef Mon Sep 17 00:00:00 2001
From: admin <weikou2014>
Date: 星期二, 23 一月 2024 17:17:55 +0800
Subject: [PATCH] 抖音转链修改
---
fanli/src/main/java/com/yeshi/fanli/service/manger/user/UserTeamStatisticManager.java | 463 +++++++++++++++++++++++++++------------------------------
1 files changed, 218 insertions(+), 245 deletions(-)
diff --git a/fanli/src/main/java/com/yeshi/fanli/service/manger/user/UserTeamStatisticManager.java b/fanli/src/main/java/com/yeshi/fanli/service/manger/user/UserTeamStatisticManager.java
index 3e6366d..40dea00 100644
--- a/fanli/src/main/java/com/yeshi/fanli/service/manger/user/UserTeamStatisticManager.java
+++ b/fanli/src/main/java/com/yeshi/fanli/service/manger/user/UserTeamStatisticManager.java
@@ -1,245 +1,218 @@
-package com.yeshi.fanli.service.manger.user;
-
-import java.util.ArrayList;
-import java.util.Date;
-import java.util.HashMap;
-import java.util.List;
-import java.util.Map;
-
-import javax.annotation.Resource;
-
-import org.springframework.stereotype.Component;
-
-import com.yeshi.fanli.entity.bus.user.ThreeSale;
-import com.yeshi.fanli.entity.bus.user.ThreeSaleDetail;
-import com.yeshi.fanli.entity.bus.user.invite.TeamDailyRecord;
-import com.yeshi.fanli.entity.bus.user.vip.UserLevelEnum;
-import com.yeshi.fanli.entity.bus.user.vip.UserVIPPreInfo;
-import com.yeshi.fanli.exception.user.TeamDailyRecordException;
-import com.yeshi.fanli.service.inter.user.invite.TeamDailyRecordService;
-import com.yeshi.fanli.service.inter.user.invite.ThreeSaleDetailService;
-import com.yeshi.fanli.service.inter.user.invite.ThreeSaleSerivce;
-import com.yeshi.fanli.service.inter.user.vip.UserVIPPreInfoService;
-import com.yeshi.fanli.util.TimeUtil;
-
-/**
- * 鍥㈤槦鎴愬憳缁熻
- * @author Administrator
- *
- */
-@Component
-public class UserTeamStatisticManager {
-
- @Resource
- private UserVIPPreInfoService userVIPPreInfoService;
-
- @Resource
- private ThreeSaleDetailService threeSaleDetailService;
-
- @Resource
- private TeamDailyRecordService teamDailyRecordService;
-
- @Resource
- private ThreeSaleSerivce threeSaleSerivce;
-
- /**
- * 鐢ㄦ埛绛夌骇鍗囩骇
- * @Title: userUpgraded
- * @Description:
- * @param uid
- * @param level
- * @param date
- * void 杩斿洖绫诲瀷
- * @throws
- */
- public void userUpgraded(Long uid, UserLevelEnum level, Date date) {
-
- // 鏇存柊涓�绾�,浜岀骇,浜岀骇澶栧搷搴旂殑绛夌骇鎻愬崌
-
- // 缁熻
-
- }
-
- /**
- * 鍚屾浼氬憳淇℃伅锛堜竴绾�/浜岀骇/浜岀骇澶栵級
- * @Title: statisticVIPData
- * @Description:
- * @param minTime
- * @param maxTime
- * @return
- * int 杩斿洖绫诲瀷
- * @throws
- */
- public void syncVIPData(Date minTime, Date maxTime) {
-
- List<UserVIPPreInfo> totalList = new ArrayList<>();
-
- long count = userVIPPreInfoService.countByProcess(UserLevelEnum.highVIP.getLevel(), minTime, maxTime);
- int pageSize = 1000;
- int page = (int) (count % pageSize == 0 ? count / pageSize : count / pageSize + 1);
- for (int i = 0; i < page; i++) {
- List<UserVIPPreInfo> list = userVIPPreInfoService.listByProcess(UserLevelEnum.highVIP.getLevel(), minTime,
- maxTime, i + 1, pageSize);
- if (list != null)
- totalList.addAll(list);
- }
-
- count = userVIPPreInfoService.countByProcess(UserLevelEnum.superVIP.getLevel(), minTime, maxTime);
- page = (int) (count % pageSize == 0 ? count / pageSize : count / pageSize + 1);
- for (int i = 0; i < page; i++) {
- List<UserVIPPreInfo> list = userVIPPreInfoService.listByProcess(UserLevelEnum.superVIP.getLevel(), minTime,
- maxTime, i + 1, pageSize);
- if (list != null)
- totalList.addAll(list);
- }
-
- Map<String, Integer> map = new HashMap<>();
-
- for (UserVIPPreInfo vipPre : totalList) {
- String day = TimeUtil.getGernalTime(vipPre.getCreateTime().getTime(), "yyyy-MM-dd");
- List<ThreeSaleDetail> list = threeSaleDetailService.listByWorkerUid(vipPre.getUid());
- for (ThreeSaleDetail ts : list) {
- String key = ts.getBossUid() + "#" + day + "#" + vipPre.getProcess() + "#";
- if (ts.getLevel() == 1) {
- key += "1";
- } else if (ts.getLevel() == 2) {
- key += "2";
- } else {
- key += "3";
- }
-
- if (map.get(key) == null) {
- map.put(key, 0);
- }
-
- map.put(key, map.get(key) + 1);
- }
- }
-
- for (java.util.Iterator<String> its = map.keySet().iterator(); its.hasNext();) {
- String key = its.next();
- Long uid = Long.parseLong(key.split("#")[0]);
- String day = key.split("#")[1];
- int process = Integer.parseInt(key.split("#")[2]);
- int level = Integer.parseInt(key.split("#")[3]);
-
- TeamDailyRecord record = new TeamDailyRecord();
- record.setUid(uid);
- record.setCountDay(new Date(TimeUtil.convertToTimeTemp(day, "yyyy-MM-dd")));
- if (level == 1) {
- String tempKey = uid + "#" + day + "#" + UserLevelEnum.highVIP.getLevel() + "#" + level;
- record.setFirstHighVIP(map.get(tempKey));
-
- tempKey = uid + "#" + day + "#" + UserLevelEnum.superVIP.getLevel() + "#" + level;
- record.setFirstSuperVIP(map.get(tempKey));
-
- } else if (level == 2) {
-
- String tempKey = uid + "#" + day + "#" + UserLevelEnum.highVIP.getLevel() + "#" + level;
- record.setSecondHighVIP(map.get(tempKey));
-
- tempKey = uid + "#" + day + "#" + UserLevelEnum.superVIP.getLevel() + "#" + level;
- record.setSecondSuperVIP(map.get(tempKey));
-
- } else {
- String tempKey = uid + "#" + day + "#" + UserLevelEnum.highVIP.getLevel() + "#" + level;
- record.setBeyondHighVIP(map.get(tempKey));
-
- tempKey = uid + "#" + day + "#" + UserLevelEnum.superVIP.getLevel() + "#" + level;
- record.setBeyondSuperVIP(map.get(tempKey));
- }
- // 淇濆瓨
- try {
- teamDailyRecordService.save(record);
- } catch (TeamDailyRecordException e) {
- e.printStackTrace();
- }
-
- }
-
- }
-
- /**
- * 鍚屾娉ㄥ唽淇℃伅
- * @Title: syncRegisterData
- * @Description:
- * @param minTime
- * @param maxTime
- * void 杩斿洖绫诲瀷
- * @throws
- */
- public void syncInviteData(Date minTime, Date maxTime) {
- List<ThreeSale> totalList = new ArrayList<>();
- long count = threeSaleSerivce.countAll(minTime, maxTime);
- int pageSize = 1000;
- int page = (int) (count % pageSize == 0 ? count / pageSize : count / pageSize + 1);
- for (int i = 0; i < page; i++) {
- List<ThreeSale> list = threeSaleSerivce.listAll(minTime, maxTime, i + 1, pageSize);
- if (list != null)
- totalList.addAll(list);
- }
-
- Map<String, Integer> map = new HashMap<>();
-
- for (ThreeSale threeSale : totalList) {
- String day = TimeUtil.getGernalTime(threeSale.getSucceedTime(), "yyyy-MM-dd");
- List<ThreeSaleDetail> list = threeSaleDetailService.listByWorkerUid(threeSale.getWorker().getId());
- for (ThreeSaleDetail ts : list) {
- String key = ts.getBossUid() + "#" + day + "#";
- if (ts.getLevel() == 1) {
- key += "1";
- } else if (ts.getLevel() == 2) {
- key += "2";
- } else {
- key += "3";
- }
-
- if (map.get(key) == null) {
- map.put(key, 0);
- }
-
- map.put(key, map.get(key) + 1);
- }
- }
-
- for (java.util.Iterator<String> its = map.keySet().iterator(); its.hasNext();) {
- String key = its.next();
- Long uid = Long.parseLong(key.split("#")[0]);
- String day = key.split("#")[1];
- int level = Integer.parseInt(key.split("#")[2]);
-
- TeamDailyRecord record = new TeamDailyRecord();
- record.setUid(uid);
- record.setCountDay(new Date(TimeUtil.convertToTimeTemp(day, "yyyy-MM-dd")));
- if (level == 1) {
- record.setFirstDaRen(map.get(key));
- } else if (level == 2) {
- record.setSecondDaRen(map.get(key));
- } else {
- record.setBeyondDaRen(map.get(key));
- }
- // 淇濆瓨
- try {
- teamDailyRecordService.save(record);
- } catch (TeamDailyRecordException e) {
- e.printStackTrace();
- }
-
- }
-
- }
-
- /**
- * 閭�璇锋垚鍔�
- * @Title: inviteSuccess
- * @Description:
- * @param uid 琚個璇蜂汉鐢ㄦ埛ID
- * @param date
- * void 杩斿洖绫诲瀷
- * @throws
- */
- public void inviteSuccess(Long uid, Date date) {
-
- }
-
-}
+package com.yeshi.fanli.service.manger.user;
+
+import java.util.ArrayList;
+import java.util.Date;
+import java.util.HashMap;
+import java.util.List;
+import java.util.Map;
+
+import javax.annotation.Resource;
+
+import org.springframework.stereotype.Component;
+
+import com.yeshi.fanli.entity.bus.user.ThreeSale;
+import com.yeshi.fanli.entity.bus.user.ThreeSaleDetail;
+import com.yeshi.fanli.entity.bus.user.invite.TeamDailyRecord;
+import com.yeshi.fanli.entity.bus.user.vip.UserLevelEnum;
+import com.yeshi.fanli.entity.bus.user.vip.UserVIPPreInfo;
+import com.yeshi.fanli.exception.user.TeamDailyRecordException;
+import com.yeshi.fanli.service.inter.user.invite.TeamDailyRecordService;
+import com.yeshi.fanli.service.inter.user.invite.ThreeSaleDetailService;
+import com.yeshi.fanli.service.inter.user.invite.ThreeSaleSerivce;
+import com.yeshi.fanli.service.inter.user.vip.UserVIPPreInfoService;
+import org.yeshi.utils.TimeUtil;
+
+/**
+ * 鍥㈤槦鎴愬憳缁熻
+ * @author Administrator
+ *
+ */
+@Component
+public class UserTeamStatisticManager {
+
+ @Resource
+ private UserVIPPreInfoService userVIPPreInfoService;
+
+ @Resource
+ private ThreeSaleDetailService threeSaleDetailService;
+
+ @Resource
+ private TeamDailyRecordService teamDailyRecordService;
+
+ @Resource
+ private ThreeSaleSerivce threeSaleSerivce;
+
+
+ /**
+ * 鍚屾浼氬憳淇℃伅锛堜竴绾�/浜岀骇/浜岀骇澶栵級
+ * @Title: statisticVIPData
+ * @Description:
+ * @param minTime
+ * @param maxTime
+ * @return
+ * int 杩斿洖绫诲瀷
+ * @throws
+ */
+ public void syncVIPData(Date minTime, Date maxTime) {
+
+ List<UserVIPPreInfo> totalList = new ArrayList<>();
+
+ long count = userVIPPreInfoService.countByProcess(UserLevelEnum.highVIP.getLevel(), minTime, maxTime);
+ int pageSize = 1000;
+ int page = (int) (count % pageSize == 0 ? count / pageSize : count / pageSize + 1);
+ for (int i = 0; i < page; i++) {
+ List<UserVIPPreInfo> list = userVIPPreInfoService.listByProcess(UserLevelEnum.highVIP.getLevel(), minTime,
+ maxTime, i + 1, pageSize);
+ if (list != null)
+ totalList.addAll(list);
+ }
+
+ count = userVIPPreInfoService.countByProcess(UserLevelEnum.superVIP.getLevel(), minTime, maxTime);
+ page = (int) (count % pageSize == 0 ? count / pageSize : count / pageSize + 1);
+ for (int i = 0; i < page; i++) {
+ List<UserVIPPreInfo> list = userVIPPreInfoService.listByProcess(UserLevelEnum.superVIP.getLevel(), minTime,
+ maxTime, i + 1, pageSize);
+ if (list != null)
+ totalList.addAll(list);
+ }
+
+ Map<String, Integer> map = new HashMap<>();
+
+ for (UserVIPPreInfo vipPre : totalList) {
+ String day = TimeUtil.getGernalTime(vipPre.getCreateTime().getTime(), "yyyy-MM-dd");
+ List<ThreeSaleDetail> list = threeSaleDetailService.listByWorkerUid(vipPre.getUid());
+ for (ThreeSaleDetail ts : list) {
+ String key = ts.getBossUid() + "#" + day + "#" + vipPre.getProcess() + "#";
+ if (ts.getLevel() == 1) {
+ key += "1";
+ } else if (ts.getLevel() == 2) {
+ key += "2";
+ } else {
+ key += "3";
+ }
+
+ if (map.get(key) == null) {
+ map.put(key, 0);
+ }
+
+ map.put(key, map.get(key) + 1);
+ }
+ }
+
+ for (java.util.Iterator<String> its = map.keySet().iterator(); its.hasNext();) {
+ String key = its.next();
+ Long uid = Long.parseLong(key.split("#")[0]);
+ String day = key.split("#")[1];
+ int process = Integer.parseInt(key.split("#")[2]);
+ int level = Integer.parseInt(key.split("#")[3]);
+
+ TeamDailyRecord record = new TeamDailyRecord();
+ record.setUid(uid);
+ record.setCountDay(new Date(TimeUtil.convertToTimeTemp(day, "yyyy-MM-dd")));
+ if (level == 1) {
+ String tempKey = uid + "#" + day + "#" + UserLevelEnum.highVIP.getLevel() + "#" + level;
+ record.setFirstHighVIP(map.get(tempKey));
+
+ tempKey = uid + "#" + day + "#" + UserLevelEnum.superVIP.getLevel() + "#" + level;
+ record.setFirstSuperVIP(map.get(tempKey));
+
+ } else if (level == 2) {
+
+ String tempKey = uid + "#" + day + "#" + UserLevelEnum.highVIP.getLevel() + "#" + level;
+ record.setSecondHighVIP(map.get(tempKey));
+
+ tempKey = uid + "#" + day + "#" + UserLevelEnum.superVIP.getLevel() + "#" + level;
+ record.setSecondSuperVIP(map.get(tempKey));
+
+ } else {
+ String tempKey = uid + "#" + day + "#" + UserLevelEnum.highVIP.getLevel() + "#" + level;
+ record.setBeyondHighVIP(map.get(tempKey));
+
+ tempKey = uid + "#" + day + "#" + UserLevelEnum.superVIP.getLevel() + "#" + level;
+ record.setBeyondSuperVIP(map.get(tempKey));
+ }
+ // 淇濆瓨
+ try {
+ teamDailyRecordService.save(record);
+ } catch (TeamDailyRecordException e) {
+ e.printStackTrace();
+ }
+
+ }
+
+ }
+
+ /**
+ * 鍚屾娉ㄥ唽淇℃伅
+ * @Title: syncRegisterData
+ * @Description:
+ * @param minTime
+ * @param maxTime
+ * void 杩斿洖绫诲瀷
+ * @throws
+ */
+ public void syncInviteAndTotalData(Date minTime, Date maxTime) {
+ List<ThreeSale> totalList = new ArrayList<>();
+ long count = threeSaleSerivce.countAll(minTime, maxTime);
+ int pageSize = 1000;
+ int page = (int) (count % pageSize == 0 ? count / pageSize : count / pageSize + 1);
+ for (int i = 0; i < page; i++) {
+ List<ThreeSale> list = threeSaleSerivce.listAll(minTime, maxTime, i + 1, pageSize);
+ if (list != null)
+ totalList.addAll(list);
+ }
+
+ Map<String, Integer> map = new HashMap<>();
+
+ for (ThreeSale threeSale : totalList) {
+ String day = TimeUtil.getGernalTime(threeSale.getSucceedTime(), "yyyy-MM-dd");
+ List<ThreeSaleDetail> list = threeSaleDetailService.listByWorkerUid(threeSale.getWorker().getId());
+ for (ThreeSaleDetail ts : list) {
+ String key = ts.getBossUid() + "#" + day + "#";
+ if (ts.getLevel() == 1) {
+ key += "1";
+ } else if (ts.getLevel() == 2) {
+ key += "2";
+ } else {
+ key += "3";
+ }
+
+ if (map.get(key) == null) {
+ map.put(key, 0);
+ }
+
+ map.put(key, map.get(key) + 1);
+ }
+ }
+
+ for (java.util.Iterator<String> its = map.keySet().iterator(); its.hasNext();) {
+ String key = its.next();
+ Long uid = Long.parseLong(key.split("#")[0]);
+ String day = key.split("#")[1];
+ int level = Integer.parseInt(key.split("#")[2]);
+
+ TeamDailyRecord record = new TeamDailyRecord();
+ record.setUid(uid);
+ record.setCountDay(new Date(TimeUtil.convertToTimeTemp(day, "yyyy-MM-dd")));
+ if (level == 1) {
+ record.setFirstDaRen(map.get(key));
+ record.setFirstNum(map.get(key));
+ } else if (level == 2) {
+ record.setSecondDaRen(map.get(key));
+ record.setSecondNum(map.get(key));
+ } else {
+ record.setBeyondDaRen(map.get(key));
+ record.setBeyondNum(map.get(key));
+ }
+ // 淇濆瓨
+ try {
+ teamDailyRecordService.save(record);
+ } catch (TeamDailyRecordException e) {
+ e.printStackTrace();
+ }
+
+ }
+
+ }
+
+}
--
Gitblit v1.8.0