DataService.java 24 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481
  1. package com.fdkankan.manage.service.impl;
  2. import cn.dev33.satoken.stp.StpUtil;
  3. import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
  4. import com.fdkankan.manage.entity.JyUser;
  5. import com.fdkankan.manage.entity.User;
  6. import com.fdkankan.manage.mapper.IDataMapper;
  7. import com.fdkankan.manage.service.*;
  8. import com.fdkankan.manage.util.Dateutils;
  9. import com.fdkankan.manage.vo.response.*;
  10. import org.apache.commons.lang3.StringUtils;
  11. import org.apache.poi.ss.formula.functions.Count;
  12. import org.springframework.beans.factory.annotation.Autowired;
  13. import org.springframework.stereotype.Service;
  14. import javax.annotation.Resource;
  15. import java.util.*;
  16. @Service
  17. public class DataService implements IDataService {
  18. static String dayFormat = "%Y-%m-%d";
  19. static String mouthFormat = "%Y-%m";
  20. static String yearFormat = "%Y";
  21. @Autowired
  22. IDataMapper dataMapper;
  23. @Autowired
  24. IUserService userService;
  25. @Autowired
  26. ISceneProService sceneProService;
  27. @Autowired
  28. IJyUserPlatformService jyUserPlatformService;
  29. @Autowired
  30. IJyUserService jyUserService;
  31. @Override
  32. public UserTotalVo getUserTotal() {
  33. UserTotalVo totalVo = new UserTotalVo();
  34. Long totalUserCount = dataMapper.totalUserCount("t_user",0);
  35. Long preMonthAddCount = dataMapper.preMonthAddCount("t_user",0);
  36. Long todayAddCount = dataMapper.todayAddCount("t_user",0);
  37. Long todayActiveCount = dataMapper.todayActiveCount();
  38. totalVo.setTotalUserCount(totalUserCount);
  39. totalVo.setPreMonthAddCount(preMonthAddCount);
  40. totalVo.setTodayAddCount(todayAddCount);
  41. totalVo.setTodayActiveCount(todayActiveCount);
  42. return totalVo;
  43. }
  44. @Override
  45. public SceneTotalVo sceneTotal() {
  46. Integer loginPlatformId = jyUserPlatformService.getLoginPlatformId();
  47. List<Long> userIds = new ArrayList<>();
  48. if(loginPlatformId != null) {
  49. userIds = jyUserService.getByUserIdPlatform(loginPlatformId);
  50. }else {
  51. JyUser jyUser = jyUserService.getBySysId(StpUtil.getLoginId());
  52. if(jyUser == null){
  53. return new SceneTotalVo();
  54. }
  55. userIds.add(jyUser.getUserId());
  56. }
  57. SceneTotalVo totalVo = new SceneTotalVo();
  58. Long totalSceneCount = dataMapper.totalUserCount("t_scene_pro",1,userIds) + dataMapper.totalUserCount("t_scene_plus",0,userIds);
  59. Long preMonthAddCount = dataMapper.preMonthAddCount("t_scene_pro",1,userIds) + dataMapper.preMonthAddCount("t_scene_plus",0,userIds);
  60. Long todayAddCount = dataMapper.todayAddCount("t_scene_pro",1,userIds) + dataMapper.todayAddCount("t_scene_plus",0,userIds);
  61. totalVo.setTotalSceneCount(totalSceneCount);
  62. totalVo.setPreMonthAddCount(preMonthAddCount);
  63. totalVo.setTodayAddCount(todayAddCount);
  64. return totalVo;
  65. }
  66. @Override
  67. public OrderTotalVo orderTotal() {
  68. Long preMonthPowCount = dataMapper.preMonthAddCount("t_increment_order",2);
  69. Long preMonthDownCount = dataMapper.preMonthAddCount("t_download_order",2);
  70. Long preMonthPartCount = dataMapper.preMonthAddCount("t_order",3);
  71. OrderTotalVo totalVo = new OrderTotalVo();
  72. totalVo.setPreMonThPowCount(preMonthPowCount);
  73. totalVo.setPreMonThDownCount(preMonthDownCount);
  74. totalVo.setPreMonThPartCount(preMonthPartCount);
  75. return totalVo;
  76. }
  77. @Override
  78. public List<DataGroupByCount> userTrend(Integer type,Integer dataType,String startTime,String endTime) {
  79. startTime = Dateutils.formatStartTime(startTime);
  80. endTime = Dateutils.formatEndTime(endTime);
  81. List<DataGroupByCount> dataList = new ArrayList<>();
  82. List<DataGroupByCount> result = new ArrayList<>();
  83. int rule = Dateutils.DAY;
  84. String tb = "t_user";
  85. if(dataType == 2){
  86. tb = "t_login_log";
  87. }
  88. switch (type){
  89. case 0 :
  90. dataList = dataMapper.userDataGroupBy(tb, dayFormat, startTime, endTime);
  91. break;
  92. case 1 :
  93. rule = Dateutils.WEEK;
  94. dataList = dataMapper.userDataGroupByWeek(tb,startTime,endTime);
  95. break;
  96. case 2 :
  97. rule = Dateutils.MONTH;
  98. dataList = dataMapper.userDataGroupBy(tb,mouthFormat,startTime,endTime);
  99. break;
  100. }
  101. Long totalCount = 0L;
  102. if(dataType == 1){ //累加
  103. LambdaQueryWrapper<User> wrapper = new LambdaQueryWrapper<>();
  104. wrapper.lt(User::getCreateTime,startTime);
  105. totalCount = userService.count(wrapper);
  106. }
  107. //查询从开始时间到结束时间为止所有天数,月份,不存在结果补零
  108. HashMap<String,Long> map = new HashMap<>();
  109. dataList.forEach(entity -> map.put(entity.getGroupKey(),entity.getCount()));
  110. List<String> dates = Dateutils.findDatesStr(Dateutils.getDate(startTime), Dateutils.getDate(endTime),rule );
  111. setListData(result,map,dates,dataType,totalCount);
  112. return result;
  113. }
  114. @Override
  115. public HashMap<String, Object> orderTrend(Integer type,Integer dataType,String startTime,String endTime) {
  116. startTime = Dateutils.formatStartTime(startTime);
  117. endTime = Dateutils.formatEndTime(endTime);
  118. HashMap<String,Object> map = new HashMap<>();
  119. if(dataType == 1){
  120. return getAmountSumOrder(map,type,startTime,endTime);
  121. }
  122. List<DataGroupByCount> incrementOrderList = new ArrayList<>();
  123. List<DataGroupByCount> downOrderList = new ArrayList<>();
  124. List<DataGroupByCount> partOrderList = new ArrayList<>();
  125. List<DataGroupByCount> incrementOrderResultList = new ArrayList<>();
  126. List<DataGroupByCount> downOrderResultList = new ArrayList<>();
  127. List<DataGroupByCount> partOrderResultList = new ArrayList<>();
  128. int rule = Dateutils.DAY;
  129. switch (type){
  130. case 0 :
  131. incrementOrderList = dataMapper.userDataGroupBy("t_increment_order",dayFormat,startTime,endTime);
  132. downOrderList = dataMapper.userDataGroupBy("t_download_order",dayFormat,startTime,endTime);
  133. partOrderList = dataMapper.userDataGroupBy("t_order",dayFormat,startTime,endTime);
  134. break;
  135. case 1 :
  136. rule = Dateutils.WEEK;
  137. incrementOrderList = dataMapper.userDataGroupByWeek("t_increment_order",startTime,endTime);
  138. downOrderList = dataMapper.userDataGroupByWeek("t_download_order",startTime,endTime);
  139. partOrderList = dataMapper.userDataGroupByWeek("t_order",startTime,endTime);
  140. break;
  141. case 2 :
  142. rule = Dateutils.MONTH;
  143. incrementOrderList = dataMapper.userDataGroupBy("t_increment_order",mouthFormat,startTime,endTime);
  144. downOrderList = dataMapper.userDataGroupBy("t_download_order",mouthFormat,startTime,endTime);
  145. partOrderList = dataMapper.userDataGroupBy("t_order",mouthFormat,startTime,endTime);
  146. break;
  147. }
  148. //查询从开始时间到结束时间为止所有天数,月份,不存在结果补零
  149. HashMap<String,Long> incrementMap = new HashMap<>();
  150. HashMap<String,Long> downOrderMap = new HashMap<>();
  151. HashMap<String,Long> partMap = new HashMap<>();
  152. incrementOrderList.forEach(entity -> incrementMap.put(entity.getGroupKey(),entity.getCount()));
  153. downOrderList.forEach(entity -> downOrderMap.put(entity.getGroupKey(),entity.getCount()));
  154. partOrderList.forEach(entity -> partMap.put(entity.getGroupKey(),entity.getCount()));
  155. List<String> dates = Dateutils.findDatesStr(Dateutils.getDate(startTime), Dateutils.getDate(endTime),rule );
  156. for (String date : dates) {
  157. DataGroupByCount groupByCount = new DataGroupByCount();
  158. groupByCount.setGroupKey(date);
  159. groupByCount.setCount(incrementMap.get(date)== null ?0 :incrementMap.get(date));
  160. incrementOrderResultList.add(groupByCount);
  161. DataGroupByCount groupByCount2 = new DataGroupByCount();
  162. groupByCount2.setGroupKey(date);
  163. groupByCount2.setCount(downOrderMap.get(date)== null ?0 :downOrderMap.get(date));
  164. downOrderResultList.add(groupByCount2);
  165. DataGroupByCount groupByCount3 = new DataGroupByCount();
  166. groupByCount3.setGroupKey(date);
  167. groupByCount3.setCount(partMap.get(date)== null ?0 :partMap.get(date));
  168. partOrderResultList.add(groupByCount3);
  169. }
  170. map.put("incrementOrder",incrementOrderResultList);
  171. map.put("downOrder",downOrderResultList);
  172. map.put("partOrder",partOrderResultList);
  173. return map;
  174. }
  175. private HashMap<String, Object> getAmountSumOrder(HashMap<String,Object> map,Integer type, String startTime, String endTime) {
  176. List<DataGroupBySum> incrementOrderList = new ArrayList<>();
  177. List<DataGroupBySum> downOrderList = new ArrayList<>();
  178. List<DataGroupBySum> partOrderList = new ArrayList<>();
  179. List<DataGroupBySum> incrementOrderResultList = new ArrayList<>();
  180. List<DataGroupBySum> downOrderResultList = new ArrayList<>();
  181. List<DataGroupBySum> partOrderResultList = new ArrayList<>();
  182. int rule = Dateutils.DAY;
  183. switch (type){
  184. case 0 :
  185. incrementOrderList = dataMapper.userDataSumGroupBy("t_increment_order",dayFormat,startTime,endTime);
  186. downOrderList = dataMapper.userDataSumGroupBy("t_download_order",dayFormat,startTime,endTime);
  187. partOrderList = dataMapper.userDataSumGroupBy("t_order",dayFormat,startTime,endTime);
  188. break;
  189. case 1 :
  190. rule = Dateutils.WEEK;
  191. incrementOrderList = dataMapper.userDataSumGroupByWeek("t_increment_order",startTime,endTime);
  192. downOrderList = dataMapper.userDataSumGroupByWeek("t_download_order",startTime,endTime);
  193. partOrderList = dataMapper.userDataSumGroupByWeek("t_order",startTime,endTime);
  194. break;
  195. case 2 :
  196. rule = Dateutils.MONTH;
  197. incrementOrderList = dataMapper.userDataSumGroupBy("t_increment_order",mouthFormat,startTime,endTime);
  198. downOrderList = dataMapper.userDataSumGroupBy("t_download_order",mouthFormat,startTime,endTime);
  199. partOrderList = dataMapper.userDataSumGroupBy("t_order",mouthFormat,startTime,endTime);
  200. break;
  201. }
  202. //查询从开始时间到结束时间为止所有天数,月份,不存在结果补零
  203. HashMap<String,String> incrementMap = new HashMap<>();
  204. HashMap<String,String> downOrderMap = new HashMap<>();
  205. HashMap<String,String> partMap = new HashMap<>();
  206. incrementOrderList.forEach(entity -> incrementMap.put(entity.getGroupKey(),entity.getCount()));
  207. downOrderList.forEach(entity -> downOrderMap.put(entity.getGroupKey(),entity.getCount()));
  208. partOrderList.forEach(entity -> partMap.put(entity.getGroupKey(),entity.getCount()));
  209. List<String> dates = Dateutils.findDatesStr(Dateutils.getDate(startTime), Dateutils.getDate(endTime),rule );
  210. for (String date : dates) {
  211. DataGroupBySum groupByCount = new DataGroupBySum();
  212. groupByCount.setGroupKey(date);
  213. groupByCount.setCount(incrementMap.get(date)== null ?"0" :incrementMap.get(date));
  214. incrementOrderResultList.add(groupByCount);
  215. DataGroupBySum groupByCount2 = new DataGroupBySum();
  216. groupByCount2.setGroupKey(date);
  217. groupByCount2.setCount(downOrderMap.get(date)== null ?"0" :downOrderMap.get(date));
  218. downOrderResultList.add(groupByCount2);
  219. DataGroupBySum groupByCount3 = new DataGroupBySum();
  220. groupByCount3.setGroupKey(date);
  221. groupByCount3.setCount(partMap.get(date)== null ?"0" :partMap.get(date));
  222. partOrderResultList.add(groupByCount3);
  223. }
  224. map.put("incrementOrder",incrementOrderResultList);
  225. map.put("downOrder",downOrderResultList);
  226. map.put("partOrder",partOrderResultList);
  227. return map;
  228. }
  229. @Override
  230. public HashMap<String, List<DataGroupByCount>> sceneTrend(Integer type,Integer dataType,String startTime,String endTime) {
  231. startTime = Dateutils.formatStartTime(startTime);
  232. endTime = Dateutils.formatEndTime(endTime);
  233. Integer loginPlatformId = jyUserPlatformService.getLoginPlatformId();
  234. List<Long> userIds = new ArrayList<>();
  235. if(loginPlatformId != null) {
  236. userIds = jyUserService.getByUserIdPlatform(loginPlatformId);
  237. }else {
  238. JyUser jyUser = jyUserService.getBySysId(StpUtil.getLoginId());
  239. if(jyUser == null){
  240. return new HashMap<>();
  241. }
  242. userIds.add(jyUser.getUserId());
  243. }
  244. HashMap<String,List<DataGroupByCount>> map = new HashMap<>();
  245. List<DataGroupByCount> kkList = new ArrayList<>();
  246. List<DataGroupByCount> kjList = new ArrayList<>();
  247. List<DataGroupByCount> ssList = new ArrayList<>();
  248. List<DataGroupByCount> ssObjList = new ArrayList<>();
  249. List<DataGroupByCount> sgList = new ArrayList<>();
  250. List<DataGroupByCount> sgObjList = new ArrayList<>();
  251. List<DataGroupByCount> yzlList = new ArrayList<>();
  252. List<DataGroupByCount> proList = new ArrayList<>();
  253. List<DataGroupByCount> plusList = new ArrayList<>();
  254. List<DataGroupByCount> proObjList = new ArrayList<>();
  255. List<DataGroupByCount> plusObjList = new ArrayList<>();
  256. List<DataGroupByCount> yzlDataList = new ArrayList<>();
  257. int rule = Dateutils.DAY;
  258. switch (type){
  259. case 0 :
  260. proList = dataMapper.sceneGroupBy("t_scene_pro",dayFormat,startTime,endTime,userIds,null);
  261. plusList = dataMapper.sceneGroupBy("t_scene_plus",dayFormat,startTime,endTime,userIds,null);
  262. proObjList = dataMapper.sceneObjGroupBy("t_scene_pro",dayFormat,startTime,endTime,userIds,null);
  263. plusObjList = dataMapper.sceneObjGroupBy("t_scene_plus",dayFormat,startTime,endTime,userIds,null);
  264. yzlDataList = dataMapper.sceneGroupBy("t_scene_plus",dayFormat,startTime,endTime,userIds,"yzl");
  265. break;
  266. case 1 :
  267. rule = Dateutils.WEEK;
  268. proList = dataMapper.sceneGroupByWeek("t_scene_pro",startTime,endTime,userIds,null);
  269. plusList = dataMapper.sceneGroupByWeek("t_scene_plus",startTime,endTime,userIds,null);
  270. proObjList = dataMapper.sceneObjGroupByWeek("t_scene_pro",startTime,endTime,userIds,null);
  271. plusObjList = dataMapper.sceneObjGroupByWeek("t_scene_plus",startTime,endTime,userIds,null);
  272. yzlDataList = dataMapper.sceneGroupByWeek("t_scene_plus",startTime,endTime,userIds,"yzl");
  273. break;
  274. case 2 :
  275. rule = Dateutils.MONTH;
  276. proList = dataMapper.sceneGroupBy("t_scene_pro",mouthFormat,startTime,endTime,userIds,null);
  277. plusList = dataMapper.sceneGroupBy("t_scene_plus",mouthFormat,startTime,endTime,userIds,null);
  278. proObjList = dataMapper.sceneObjGroupBy("t_scene_pro",mouthFormat,startTime,endTime,userIds,null);
  279. plusObjList = dataMapper.sceneObjGroupBy("t_scene_plus",mouthFormat,startTime,endTime,userIds,null);
  280. yzlDataList = dataMapper.sceneGroupBy("t_scene_plus",mouthFormat,startTime,endTime,userIds,"yzl");
  281. break;
  282. }
  283. HashMap<String, Long> kkMap = new HashMap<>();
  284. HashMap<String, Long> kjMap = new HashMap<>();
  285. HashMap<String, Long> ssMap = new HashMap<>();
  286. HashMap<String, Long> ssObjMap = new HashMap<>();
  287. HashMap<String, Long> sgMap = new HashMap<>();
  288. HashMap<String, Long> sgObjMap = new HashMap<>();
  289. HashMap<String, Long> yzlMap = new HashMap<>();
  290. for (DataGroupByCount dataGroupByCount : proList) {
  291. if(dataGroupByCount.getGroupKey2().equals("3")){ //看见
  292. kjMap.merge(dataGroupByCount.getGroupKey(),dataGroupByCount.getCount(), Long:: sum);
  293. }
  294. if(dataGroupByCount.getGroupKey2().equals("4")){ //深时
  295. ssMap.merge(dataGroupByCount.getGroupKey(),dataGroupByCount.getCount(), Long:: sum);
  296. }
  297. if(dataGroupByCount.getGroupKey2().equals("5")){ //深时
  298. sgMap.merge(dataGroupByCount.getGroupKey(),dataGroupByCount.getCount(), Long:: sum);
  299. }
  300. if(Arrays.asList("1","2","12","13","14").contains(dataGroupByCount.getGroupKey2())){ //看看
  301. kkMap.merge(dataGroupByCount.getGroupKey(),dataGroupByCount.getCount(), Long:: sum);
  302. }
  303. }
  304. for (DataGroupByCount dataGroupByCount : plusList) {
  305. if(dataGroupByCount.getGroupKey2().equals("3")){ //看见
  306. kjMap.merge(dataGroupByCount.getGroupKey(),dataGroupByCount.getCount(), Long:: sum);
  307. }
  308. if(dataGroupByCount.getGroupKey2().equals("4")){ //深时
  309. ssMap.merge(dataGroupByCount.getGroupKey(),dataGroupByCount.getCount(), Long:: sum);
  310. }
  311. if(dataGroupByCount.getGroupKey2().equals("5")){ //深时
  312. sgMap.merge(dataGroupByCount.getGroupKey(),dataGroupByCount.getCount(), Long:: sum);
  313. }
  314. if(Arrays.asList("1","2","12","13","14").contains(dataGroupByCount.getGroupKey2())){ //看看
  315. kkMap.merge(dataGroupByCount.getGroupKey(),dataGroupByCount.getCount(), Long:: sum);
  316. }
  317. }
  318. for (DataGroupByCount dataGroupByCount : proObjList) {
  319. if(dataGroupByCount.getGroupKey2().equals("4")){ //深时
  320. ssObjMap.merge(dataGroupByCount.getGroupKey(),dataGroupByCount.getCount(), Long:: sum);
  321. }
  322. if(dataGroupByCount.getGroupKey2().equals("5")){ //深时
  323. sgObjMap.merge(dataGroupByCount.getGroupKey(),dataGroupByCount.getCount(), Long:: sum);
  324. }
  325. }
  326. for (DataGroupByCount dataGroupByCount : plusObjList) {
  327. if(dataGroupByCount.getGroupKey2().equals("4")){ //深时
  328. ssObjMap.merge(dataGroupByCount.getGroupKey(),dataGroupByCount.getCount(), Long:: sum);
  329. }
  330. if(dataGroupByCount.getGroupKey2().equals("5")){ //深时
  331. sgObjMap.merge(dataGroupByCount.getGroupKey(),dataGroupByCount.getCount(), Long:: sum);
  332. }
  333. }
  334. for (DataGroupByCount dataGroupByCount : yzlDataList) {
  335. yzlMap.merge(dataGroupByCount.getGroupKey(),dataGroupByCount.getCount(), Long:: sum);
  336. }
  337. Long kkCount = 0L;
  338. Long KjCount = 0L;
  339. Long ssCount = 0L;
  340. Long ssObjCount = 0L;
  341. Long sgCount = 0L;
  342. Long sgObjCount = 0L;
  343. Long yzlCount = 0L;
  344. if(dataType == 1){
  345. kkCount = sceneProService.getKkCount(Arrays.asList("1","2","12","13","14"),startTime,userIds,null);
  346. KjCount = sceneProService.getKkCount(Arrays.asList("3"),startTime,userIds,null);
  347. ssCount = sceneProService.getSsCount(Arrays.asList("4"),startTime,userIds);
  348. ssObjCount = sceneProService.getSsObjCount(Arrays.asList("4"),startTime,userIds);
  349. sgCount = sceneProService.getSsCount(Arrays.asList("5"),startTime,userIds);
  350. sgObjCount = sceneProService.getSsObjCount(Arrays.asList("5"),startTime,userIds);
  351. yzlCount = sceneProService.getKkCount(Arrays.asList("1"),startTime,userIds,"yzl");
  352. }
  353. List<String> dates = Dateutils.findDatesStr(Dateutils.getDate(startTime), Dateutils.getDate(endTime),rule );
  354. setListData(kkList,kkMap,dates,dataType,kkCount);
  355. setListData(kjList,kjMap,dates,dataType,KjCount);
  356. setListData(ssList,ssMap,dates,dataType,ssCount);
  357. setListData(ssObjList,ssObjMap,dates,dataType,ssObjCount);
  358. setListData(sgList,sgMap,dates,dataType,sgCount);
  359. setListData(sgObjList,sgObjMap,dates,dataType,sgObjCount);
  360. setListData(yzlList,yzlMap,dates,dataType,yzlCount);
  361. map.put("kkList",kkList);
  362. map.put("kjList",kjList);
  363. map.put("ssList",ssList);
  364. map.put("ssobjList",ssObjList);
  365. map.put("sgList",sgList);
  366. map.put("sgobjList",sgObjList);
  367. map.put("yzlList",yzlList);
  368. return map;
  369. }
  370. private void setListData(List<DataGroupByCount> kkList, HashMap<String, Long> kkMap, List<String> dates,Integer dataType,Long totalCount) {
  371. for (String key : dates) {
  372. DataGroupByCount newCount = new DataGroupByCount();
  373. newCount.setGroupKey(key);
  374. Long count = kkMap.get(key) == null ? 0L : kkMap.get(key);
  375. if(dataType == 1){
  376. count += totalCount;
  377. totalCount = count;
  378. }
  379. newCount.setCount(count);
  380. kkList.add(newCount);
  381. }
  382. }
  383. private void setListData(List<DataGroupByCount> kkList, HashMap<String, Long> kkMap, List<String> dates) {
  384. for (String key : dates) {
  385. DataGroupByCount newCount = new DataGroupByCount();
  386. newCount.setGroupKey(key);
  387. Long count = kkMap.get(key) == null ? 0L : kkMap.get(key);
  388. newCount.setCount(count);
  389. kkList.add(newCount);
  390. }
  391. }
  392. @Override
  393. public HashMap<String, Object> cameraTrend(Integer type, String startTime, String endTime) {
  394. startTime = Dateutils.formatStartTime(startTime);
  395. endTime = Dateutils.formatEndTime(endTime);
  396. HashMap<String,Object> map = new HashMap<>();
  397. List<DataGroupByCount> allList = new ArrayList<>();
  398. List<DataGroupByCount> kkList = new ArrayList<>();
  399. List<DataGroupByCount> kjList = new ArrayList<>();
  400. List<DataGroupByCount> ssList = new ArrayList<>();
  401. List<DataGroupByCount> sgList = new ArrayList<>();
  402. int rule = Dateutils.DAY;
  403. switch (type){
  404. case 0 :
  405. allList = dataMapper.sceneOutTimeGroupBy("t_camera_detail",dayFormat,startTime,endTime);
  406. break;
  407. case 1 :
  408. rule = Dateutils.WEEK;
  409. allList = dataMapper.sceneOutTimeGroupByWeek("t_camera_detail",startTime,endTime);
  410. break;
  411. case 2 :
  412. rule = Dateutils.MONTH;
  413. allList = dataMapper.sceneOutTimeGroupBy("t_camera_detail",mouthFormat,startTime,endTime);
  414. break;
  415. }
  416. HashMap<String, Long> kkMap = new HashMap<>();
  417. HashMap<String, Long> kjMap = new HashMap<>();
  418. HashMap<String, Long> ssMap = new HashMap<>();
  419. HashMap<String, Long> sgMap = new HashMap<>();
  420. for (DataGroupByCount dataGroupByCount : allList) {
  421. if(dataGroupByCount.getGroupKey2().equals("9")){ //看见
  422. kjMap.merge(dataGroupByCount.getGroupKey(),dataGroupByCount.getCount(), Long:: sum);
  423. }
  424. if(dataGroupByCount.getGroupKey2().equals("10")){ //深时
  425. ssMap.merge(dataGroupByCount.getGroupKey(),dataGroupByCount.getCount(), Long:: sum);
  426. }
  427. if(dataGroupByCount.getGroupKey2().equals("11")){ //深时
  428. sgMap.merge(dataGroupByCount.getGroupKey(),dataGroupByCount.getCount(), Long:: sum);
  429. }
  430. if(Arrays.asList("1").contains(dataGroupByCount.getGroupKey2())){ //看看
  431. kkMap.merge(dataGroupByCount.getGroupKey(),dataGroupByCount.getCount(), Long:: sum);
  432. }
  433. }
  434. List<String> dates = Dateutils.findDatesStr(Dateutils.getDate(startTime), Dateutils.getDate(endTime),rule );
  435. setListData(kkList,kkMap,dates);
  436. setListData(kjList,kjMap,dates);
  437. setListData(ssList,ssMap,dates);
  438. setListData(sgList,sgMap,dates);
  439. map.put("kkList",kkList);
  440. map.put("kjList",kjList);
  441. map.put("ssList",ssList);
  442. map.put("sgList",sgList);
  443. return map;
  444. }
  445. }