MonthlyCustomersController.java 24 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574
  1. package com.kmall.admin.controller.statistics;
  2. import com.kmall.admin.dao.statistics.MonthlyCustomersDao;
  3. import com.kmall.admin.dao.statistics.WechatFollowersDao;
  4. import com.kmall.admin.entity.MonthlySalesGrowthEntity;
  5. import com.kmall.admin.entity.ProductStoreRelaEntity;
  6. import com.kmall.admin.entity.WechatFollowersEntity;
  7. import com.kmall.admin.fromcomm.entity.SysUserEntity;
  8. import com.kmall.admin.service.statistics.MonthlyCustomersService;
  9. import com.kmall.admin.utils.ParamUtils;
  10. import com.kmall.admin.utils.ShiroUtils;
  11. import com.kmall.common.utils.R;
  12. import com.kmall.common.utils.excel.ExcelExport;
  13. import com.kmall.common.utils.excel.ExcelUtil;
  14. import org.apache.shiro.SecurityUtils;
  15. import org.springframework.beans.factory.annotation.Autowired;
  16. import org.springframework.web.bind.annotation.RequestMapping;
  17. import org.springframework.web.bind.annotation.RequestParam;
  18. import org.springframework.web.bind.annotation.RestController;
  19. import javax.servlet.http.HttpServletRequest;
  20. import javax.servlet.http.HttpServletResponse;
  21. import java.math.BigDecimal;
  22. import java.math.RoundingMode;
  23. import java.text.ParseException;
  24. import java.text.SimpleDateFormat;
  25. import java.util.*;
  26. /**
  27. * @author zhangchuangbiao
  28. * @version 1.0
  29. * 2020-09-01 14:35
  30. */
  31. @RestController
  32. @RequestMapping("/monthly")
  33. public class MonthlyCustomersController {
  34. @Autowired
  35. private MonthlyCustomersService monthlyCustomersService;
  36. @Autowired
  37. private ExcelUtil excelUtil;
  38. @Autowired
  39. private MonthlyCustomersDao monthlyCustomersDao;
  40. @Autowired
  41. private WechatFollowersDao wechatFollowersDao;
  42. private void calculateDifferentMonth(List<String> monthList, String startMonth, String endMonth) throws ParseException {
  43. SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM");
  44. Calendar bef = Calendar.getInstance();
  45. Calendar aft = Calendar.getInstance();
  46. bef.setTime(sdf.parse(startMonth));
  47. aft.setTime(sdf.parse(endMonth));
  48. do {
  49. monthList.add(sdf.format(bef.getTime()));
  50. bef.add(Calendar.MONTH, 1);
  51. }
  52. while (bef.compareTo(aft) <= 0);
  53. }
  54. /**
  55. * 每月销售额查询
  56. * @param startMonth
  57. * @param endMonth
  58. * @return
  59. */
  60. @RequestMapping("/customersQuery")
  61. public R queryMonthlyCustomers(@RequestParam("startMonth") String startMonth, @RequestParam("endMonth") String endMonth) {
  62. List<String> dateList = new ArrayList<>();
  63. Map<String, Object> returnMap = new HashMap<>();
  64. try {
  65. calculateDifferentMonth(dateList, startMonth, endMonth);
  66. } catch (ParseException e) {
  67. e.printStackTrace();
  68. }
  69. try {
  70. String merchSn = null;
  71. SysUserEntity sysUser = (SysUserEntity) SecurityUtils.getSubject().getPrincipal();
  72. if(!"1".equals(sysUser.getRoleType())){
  73. merchSn = sysUser.getMerchSn();
  74. }
  75. Map<String,Object> map = monthlyCustomersService.queryMonthlyCustomers(startMonth,endMonth,merchSn);
  76. returnMap.put("dateList", dateList);
  77. returnMap.putAll(map);
  78. } catch (Exception e) {
  79. e.printStackTrace();
  80. return R.error(e.getMessage());
  81. }
  82. return R.ok(returnMap);
  83. }
  84. /**
  85. * 每月销售额销售量导出
  86. * @param params
  87. * @param response
  88. * @param request
  89. * @return
  90. */
  91. @RequestMapping("/monthlySalesGrowthExport")
  92. public R monthlySalesGrowthExport(@RequestParam Map<String, Object> params, HttpServletResponse response, HttpServletRequest request) {
  93. ParamUtils.setQueryPowerByRoleType(params, "storeId", "merchSn", "thirdPartyMerchCode");
  94. if (Objects.isNull(params.get("startMonth")) || "".equals(params.get("startMonth"))){
  95. return R.error("请先选择开始时间");
  96. }
  97. if (Objects.isNull(params.get("endMonth")) || "".equals(params.get("endMonth"))){
  98. return R.error("请先选择结束时间");
  99. }
  100. String merchSn = null;
  101. SysUserEntity sysUser = (SysUserEntity) SecurityUtils.getSubject().getPrincipal();
  102. if(!"1".equals(sysUser.getRoleType())){
  103. merchSn = sysUser.getMerchSn();
  104. }
  105. List<MonthlySalesGrowthEntity> monthlySalesGrowthEntities = monthlyCustomersDao.queryMonthlyCustomers((String) params.get("startMonth"), (String) params.get("endMonth"), merchSn);
  106. ExcelExport ee = new ExcelExport("Monthly Sales Growth");
  107. String[] header = new String[]{"序号","商户编号","商户名称","销售额","销售数量","年-月"};
  108. List<Map<String, Object>> list = new ArrayList<>();
  109. int count = 1;
  110. if (monthlySalesGrowthEntities!=null && monthlySalesGrowthEntities.size()>0) {
  111. for (MonthlySalesGrowthEntity monthlySalesGrowthEntity : monthlySalesGrowthEntities) {
  112. LinkedHashMap<String, Object> map = new LinkedHashMap<>();
  113. map.put("OrderNumber",count++);
  114. map.put("MerchSn",monthlySalesGrowthEntity.getMerchSn());
  115. map.put("MerchName",monthlySalesGrowthEntity.getMerchName());
  116. map.put("TotalSales",monthlySalesGrowthEntity.getTotalSales());
  117. map.put("TotalNumber",monthlySalesGrowthEntity.getTotalNumber());
  118. map.put("YearAndMonth",monthlySalesGrowthEntity.getYearAndMonth());
  119. list.add(map);
  120. }
  121. }
  122. ee.addSheetByMap("Monthly Sales Growth", list, header);
  123. ee.export(response);
  124. return R.ok();
  125. }
  126. /**
  127. * 导出销售额销售数客单数客单价
  128. * @param params
  129. * @param response
  130. * @param request
  131. * @return
  132. */
  133. @RequestMapping("/monthlySalesGrowthExport2")
  134. public R monthlySalesGrowthExport2(@RequestParam Map<String, Object> params, HttpServletResponse response, HttpServletRequest request) {
  135. ParamUtils.setQueryPowerByRoleType(params, "storeId", "merchSn", "thirdPartyMerchCode");
  136. if (Objects.isNull(params.get("startMonth")) || "".equals(params.get("startMonth"))){
  137. return R.error("请先选择开始时间");
  138. }
  139. if (Objects.isNull(params.get("endMonth")) || "".equals(params.get("endMonth"))){
  140. return R.error("请先选择结束时间");
  141. }
  142. String merchSn = null;
  143. SysUserEntity sysUser = (SysUserEntity) SecurityUtils.getSubject().getPrincipal();
  144. if(!"1".equals(sysUser.getRoleType())){
  145. merchSn = sysUser.getMerchSn();
  146. }
  147. List<MonthlySalesGrowthEntity> monthlySalesGrowthEntities = monthlyCustomersDao.queryMonthlyCustomers((String) params.get("startMonth"), (String) params.get("endMonth"), merchSn);
  148. ExcelExport ee = new ExcelExport("Monthly Customers&Avg Basket");
  149. String[] header = new String[]{"序号","商户编号","商户名称","销售额","销售数量","客户数","客单价","年-月"};
  150. List<Map<String, Object>> list = new ArrayList<>();
  151. int count = 1;
  152. if (monthlySalesGrowthEntities!=null && monthlySalesGrowthEntities.size()>0) {
  153. for (MonthlySalesGrowthEntity monthlySalesGrowthEntity : monthlySalesGrowthEntities) {
  154. LinkedHashMap<String, Object> map = new LinkedHashMap<>();
  155. map.put("OrderNumber",count++);
  156. map.put("MerchSn",monthlySalesGrowthEntity.getMerchSn());
  157. map.put("MerchName",monthlySalesGrowthEntity.getMerchName());
  158. map.put("TotalSales",monthlySalesGrowthEntity.getTotalSales());
  159. map.put("TotalNumber",monthlySalesGrowthEntity.getTotalNumber());
  160. map.put("TotalCustomers",monthlySalesGrowthEntity.getTotalCustomers());
  161. String avgBasketSale = new BigDecimal(monthlySalesGrowthEntity.getTotalSales()).divide(new BigDecimal(monthlySalesGrowthEntity.getTotalNumber()),3, RoundingMode.HALF_UP).toString();
  162. map.put("avgBasketSale",avgBasketSale);
  163. map.put("YearAndMonth",monthlySalesGrowthEntity.getYearAndMonth());
  164. list.add(map);
  165. }
  166. }
  167. ee.addSheetByMap("Monthly Customers&Avg Basket", list, header);
  168. ee.export(response);
  169. return R.ok();
  170. }
  171. /**
  172. * 销售前10的产品
  173. * @param month
  174. * @param week
  175. * @return
  176. */
  177. @RequestMapping("/top10ForProduct")
  178. public R top10ForProduct(@RequestParam("month") String month, @RequestParam("week") String week){
  179. String merchSn = null;
  180. SysUserEntity sysUser = (SysUserEntity) SecurityUtils.getSubject().getPrincipal();
  181. if(!"1".equals(sysUser.getRoleType())){
  182. merchSn = sysUser.getMerchSn();
  183. }
  184. Map<String,Object> map = monthlyCustomersService.top10ForProduct(month,week,merchSn);
  185. return R.ok(map);
  186. }
  187. /**
  188. * 销售前10的品牌/供应商的商品
  189. * @param startDate
  190. * @param endDate
  191. * @return
  192. */
  193. @RequestMapping("/top10ByBrandAndSupplier")
  194. public R top10ByBrandAndSupplier(@RequestParam("startDate") String startDate,
  195. @RequestParam("endDate") String endDate){
  196. String merchSn = null;
  197. SysUserEntity sysUser = (SysUserEntity) SecurityUtils.getSubject().getPrincipal();
  198. if(!"1".equals(sysUser.getRoleType())){
  199. merchSn = sysUser.getMerchSn();
  200. }
  201. Map<String,Object> map = monthlyCustomersService.top10ByBrandAndSupplier(startDate,endDate,merchSn);
  202. return R.ok(map);
  203. }
  204. @RequestMapping("/top10ByBrandAndSupplierExport")
  205. public R top10ByBrandAndSupplierExport(@RequestParam("startDate") String startDate,
  206. @RequestParam("endDate") String endDate, HttpServletResponse response, HttpServletRequest request){
  207. String merchSn = null;
  208. SysUserEntity sysUser = (SysUserEntity) SecurityUtils.getSubject().getPrincipal();
  209. if(!"1".equals(sysUser.getRoleType())){
  210. merchSn = sysUser.getMerchSn();
  211. }
  212. Map<String,Object> map = monthlyCustomersService.top10ByBrandAndSupplier(startDate,endDate,merchSn);
  213. List<MonthlySalesGrowthEntity> top10ByBrand = (List<MonthlySalesGrowthEntity>) map.get("top10ByBrand");
  214. List<MonthlySalesGrowthEntity> top10BySupplier = (List<MonthlySalesGrowthEntity>) map.get("top10BySupplier");
  215. ExcelExport ee = new ExcelExport("产品销量前10");
  216. String[] header1 = new String[]{"序号","商户名称","品牌","产品规格","销售数量"};
  217. String[] header2 = new String[]{"序号","商户名称","供应商","产品规格","销售数量"};
  218. List<Map<String, Object>> list1 = new ArrayList<>();
  219. List<Map<String, Object>> list2 = new ArrayList<>();
  220. int count = 1;
  221. if (top10ByBrand!=null && top10ByBrand.size()>0) {
  222. for (MonthlySalesGrowthEntity monthlySalesGrowthEntity : top10ByBrand) {
  223. LinkedHashMap<String, Object> tempMap = new LinkedHashMap<>();
  224. tempMap.put("OrderNumber",count++);
  225. tempMap.put("MerchName",monthlySalesGrowthEntity.getMerchName());
  226. tempMap.put("Brand",monthlySalesGrowthEntity.getBrand());
  227. tempMap.put("GoodsSpecificationNameValue",monthlySalesGrowthEntity.getGoodsSpecificationNameValue());
  228. tempMap.put("sales",monthlySalesGrowthEntity.getSales());
  229. list1.add(tempMap);
  230. }
  231. }
  232. count=1;
  233. if (top10BySupplier!=null && top10BySupplier.size()>0) {
  234. for (MonthlySalesGrowthEntity monthlySalesGrowthEntity : top10BySupplier) {
  235. LinkedHashMap<String, Object> tempMap = new LinkedHashMap<>();
  236. tempMap.put("OrderNumber",count++);
  237. tempMap.put("MerchName",monthlySalesGrowthEntity.getMerchName());
  238. tempMap.put("Supplier",monthlySalesGrowthEntity.getSupplier());
  239. tempMap.put("GoodsSpecificationNameValue",monthlySalesGrowthEntity.getGoodsSpecificationNameValue());
  240. tempMap.put("sales",monthlySalesGrowthEntity.getSales());
  241. list2.add(tempMap);
  242. }
  243. }
  244. ee.addSheetByMap("top10ByBrand", list1, header1);
  245. ee.addSheetByMap("top10BySupplier", list2, header2);
  246. ee.export(response);
  247. return R.ok(map);
  248. }
  249. /**
  250. * 每周销售额销售量图表查询
  251. * @param startWeek
  252. * @param endWeek
  253. * @return
  254. * @throws ParseException
  255. */
  256. @RequestMapping("/customersQueryByWeek")
  257. public R queryWeeklyCustomers(@RequestParam("startWeek") String startWeek, @RequestParam("endWeek") String endWeek) throws ParseException {
  258. List<String> dateList = new ArrayList<>();
  259. try {
  260. calculateDifferentWeek(dateList, startWeek, endWeek);
  261. } catch (ParseException e) {
  262. e.printStackTrace();
  263. }
  264. String merchSn = null;
  265. SysUserEntity sysUser = (SysUserEntity) SecurityUtils.getSubject().getPrincipal();
  266. if(!"1".equals(sysUser.getRoleType())){
  267. merchSn = sysUser.getMerchSn();
  268. }
  269. SimpleDateFormat weekSdf = new SimpleDateFormat("yyyy");
  270. SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd");
  271. Calendar bef = Calendar.getInstance();
  272. Calendar aft = Calendar.getInstance();
  273. bef.setFirstDayOfWeek(Calendar.MONDAY);
  274. aft.setFirstDayOfWeek(Calendar.MONDAY);
  275. bef.setTime(sdf.parse(startWeek));
  276. aft.setTime(sdf.parse(endWeek));
  277. int befWeek = bef.get(Calendar.WEEK_OF_YEAR);
  278. int aftWeek = aft.get(Calendar.WEEK_OF_YEAR);
  279. if(befWeek<10){
  280. startWeek =weekSdf.format(bef.getTime())+"-0"+befWeek;
  281. }else{
  282. startWeek =weekSdf.format(bef.getTime())+"-"+befWeek;
  283. }
  284. if(aftWeek<10){
  285. endWeek =weekSdf.format(aft.getTime())+"-0"+aftWeek;
  286. }else{
  287. endWeek =weekSdf.format(aft.getTime())+"-"+aftWeek;
  288. }
  289. Map<String,Object> map = monthlyCustomersService.queryWeeklyCustomers(startWeek,endWeek,merchSn);
  290. Map<String, Object> returnMap = new HashMap<>();
  291. returnMap.put("dateList", dateList);
  292. returnMap.putAll(map);
  293. return R.ok(returnMap);
  294. }
  295. @RequestMapping("/weeklySalesSummaryExport")
  296. public R weeklySalesSummaryExport(@RequestParam Map<String, Object> params, HttpServletResponse response, HttpServletRequest request) throws ParseException {
  297. ParamUtils.setQueryPowerByRoleType(params, "storeId", "merchSn", "thirdPartyMerchCode");
  298. if (Objects.isNull(params.get("startWeek"))){
  299. return R.error("请先选择开始时间");
  300. }
  301. if (Objects.isNull(params.get("endWeek"))){
  302. return R.error("请先选择结束时间");
  303. }
  304. String startWeek = (String) params.get("startWeek");
  305. String endWeek = (String) params.get("endWeek");
  306. String merchSn = null;
  307. SysUserEntity sysUser = (SysUserEntity) SecurityUtils.getSubject().getPrincipal();
  308. if(!"1".equals(sysUser.getRoleType())){
  309. merchSn = sysUser.getMerchSn();
  310. }
  311. SimpleDateFormat weekSdf = new SimpleDateFormat("yyyy");
  312. SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd");
  313. Calendar bef = Calendar.getInstance();
  314. Calendar aft = Calendar.getInstance();
  315. bef.setFirstDayOfWeek(Calendar.MONDAY);
  316. aft.setFirstDayOfWeek(Calendar.MONDAY);
  317. bef.setTime(sdf.parse(startWeek));
  318. aft.setTime(sdf.parse(endWeek));
  319. int befWeek = bef.get(Calendar.WEEK_OF_YEAR);
  320. int aftWeek = aft.get(Calendar.WEEK_OF_YEAR);
  321. if(befWeek<10){
  322. startWeek =weekSdf.format(bef.getTime())+"-0"+befWeek;
  323. }else{
  324. startWeek =weekSdf.format(bef.getTime())+"-"+befWeek;
  325. }
  326. if(aftWeek<10){
  327. endWeek =weekSdf.format(aft.getTime())+"-0"+aftWeek;
  328. }else{
  329. endWeek =weekSdf.format(aft.getTime())+"-"+aftWeek;
  330. }
  331. List<MonthlySalesGrowthEntity> monthlySalesGrowthEntities = monthlyCustomersDao.queryWeeklyCustomers(startWeek, endWeek, merchSn);
  332. ExcelExport ee = new ExcelExport("Weekly Sales Summary");
  333. String[] header = new String[]{"序号","商户编号","商户名称","销售额","销售数量","年-周"};
  334. List<Map<String, Object>> list = new ArrayList<>();
  335. int count = 1;
  336. if (monthlySalesGrowthEntities!=null && monthlySalesGrowthEntities.size()>0) {
  337. for (MonthlySalesGrowthEntity monthlySalesGrowthEntity : monthlySalesGrowthEntities) {
  338. LinkedHashMap<String, Object> map = new LinkedHashMap<>();
  339. map.put("OrderNumber",count++);
  340. map.put("MerchSn",monthlySalesGrowthEntity.getMerchSn());
  341. map.put("MerchName",monthlySalesGrowthEntity.getMerchName());
  342. map.put("TotalSales",monthlySalesGrowthEntity.getTotalSales());
  343. map.put("TotalNumber",monthlySalesGrowthEntity.getTotalNumber());
  344. map.put("YearAndWeek",monthlySalesGrowthEntity.getYearAndWeek());
  345. list.add(map);
  346. }
  347. }
  348. ee.addSheetByMap("Weekly Sales Summary", list, header);
  349. ee.export(response);
  350. return R.ok();
  351. }
  352. private void calculateDifferentWeek(List<String> weekList, String startWeek, String endWeek) throws ParseException {
  353. SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd");
  354. SimpleDateFormat weekSdf = new SimpleDateFormat("yyyy");
  355. Calendar bef = Calendar.getInstance();
  356. Calendar aft = Calendar.getInstance();
  357. bef.setFirstDayOfWeek(Calendar.MONDAY);
  358. aft.setFirstDayOfWeek(Calendar.MONDAY);
  359. bef.setTime(sdf.parse(startWeek));
  360. aft.setTime(sdf.parse(endWeek));
  361. do {
  362. int i = bef.get(Calendar.WEEK_OF_YEAR);
  363. if (i<10){
  364. weekList.add(weekSdf.format(bef.getTime())+"-0"+i);
  365. }else{
  366. weekList.add(weekSdf.format(bef.getTime())+"-"+i);
  367. }
  368. bef.set(Calendar.DAY_OF_MONTH,bef.get(Calendar.DAY_OF_MONTH)+7); //给当前时间增加一周
  369. }
  370. while (bef.compareTo(aft) <= 0);
  371. }
  372. /**
  373. * 每月微信好友图表查询
  374. * @param startMonth
  375. * @param endMonth
  376. * @return
  377. */
  378. @RequestMapping("/queryMonthlyWechatFollowers")
  379. public R queryMonthlyWechatFollowers(@RequestParam("startMonth") String startMonth, @RequestParam("endMonth") String endMonth) {
  380. List<String> dateList = new ArrayList<>();
  381. Map<String, Object> returnMap = new HashMap<>();
  382. try {
  383. calculateDifferentMonth(dateList, startMonth, endMonth);
  384. } catch (ParseException e) {
  385. e.printStackTrace();
  386. }
  387. try {
  388. String merchSn = null;
  389. SysUserEntity sysUser = (SysUserEntity) SecurityUtils.getSubject().getPrincipal();
  390. if(!"1".equals(sysUser.getRoleType())){
  391. merchSn = sysUser.getMerchSn();
  392. }
  393. Map<String,Object> map = monthlyCustomersService.queryMonthlyWechatFollowers(startMonth,endMonth,merchSn);
  394. returnMap.put("dateList", dateList);
  395. returnMap.putAll(map);
  396. } catch (Exception e) {
  397. e.printStackTrace();
  398. return R.error(e.getMessage());
  399. }
  400. return R.ok(returnMap);
  401. }
  402. /**
  403. * 添加微信好友数据
  404. * @param wechatFollowers
  405. * @return
  406. */
  407. @RequestMapping("/addWechatFollowers")
  408. public R addWechatFollowers( @RequestParam("wechatFollowers") Integer wechatFollowers) {
  409. try {
  410. String merchSn = null;
  411. SysUserEntity sysUser = (SysUserEntity) SecurityUtils.getSubject().getPrincipal();
  412. if(!"1".equals(sysUser.getRoleType())){
  413. merchSn = sysUser.getMerchSn();
  414. }
  415. WechatFollowersEntity wechatFollowersEntity = new WechatFollowersEntity();
  416. wechatFollowersEntity.setCreaterSn(ShiroUtils.getUserId().toString());
  417. wechatFollowersEntity.setCreateTime(new Date());
  418. wechatFollowersEntity.setWechatFollowers(wechatFollowers);
  419. wechatFollowersEntity.setMerchSn(merchSn);
  420. monthlyCustomersService.addWechatFollowers(wechatFollowersEntity);
  421. } catch (Exception e) {
  422. e.printStackTrace();
  423. return R.error(e.getMessage());
  424. }
  425. return R.ok("添加成功");
  426. }
  427. @RequestMapping("/wechatFollowersGrowthExport")
  428. public R wechatFollowersGrowthExport(@RequestParam Map<String, Object> params, HttpServletResponse response, HttpServletRequest request) {
  429. ParamUtils.setQueryPowerByRoleType(params, "storeId", "merchSn", "thirdPartyMerchCode");
  430. if (Objects.isNull(params.get("startMonth")) || "".equals(params.get("startMonth"))){
  431. return R.error("请先选择开始时间");
  432. }
  433. if (Objects.isNull(params.get("endMonth")) || "".equals(params.get("endMonth"))){
  434. return R.error("请先选择结束时间");
  435. }
  436. String merchSn = null;
  437. SysUserEntity sysUser = (SysUserEntity) SecurityUtils.getSubject().getPrincipal();
  438. if(!"1".equals(sysUser.getRoleType())){
  439. merchSn = sysUser.getMerchSn();
  440. }
  441. List<WechatFollowersEntity> wechatFollowersEntities = wechatFollowersDao.queryMonthlyWechatFollowers((String) params.get("startMonth"), (String) params.get("endMonth"), merchSn);
  442. ExcelExport ee = new ExcelExport("Wechat Followers Growth");
  443. String[] header = new String[]{"序号","商户编号","好友数量","年-月"};
  444. List<Map<String, Object>> list = new ArrayList<>();
  445. int count = 1;
  446. if (wechatFollowersEntities!=null && wechatFollowersEntities.size()>0) {
  447. for (WechatFollowersEntity wechatFollowersEntity : wechatFollowersEntities) {
  448. LinkedHashMap<String, Object> map = new LinkedHashMap<>();
  449. map.put("OrderNumber",count++);
  450. map.put("MerchSn",wechatFollowersEntity.getMerchSn());
  451. map.put("WechatFollowers",wechatFollowersEntity.getWechatFollowers());
  452. map.put("YearAndMonth",wechatFollowersEntity.getYearAndMonth());
  453. list.add(map);
  454. }
  455. }
  456. ee.addSheetByMap("Wechat Followers Growth", list, header);
  457. ee.export(response);
  458. return R.ok();
  459. }
  460. /**
  461. * 品牌销售数量
  462. * @param startDate
  463. * @param endDate
  464. * @return
  465. */
  466. @RequestMapping("/salesByCategory")
  467. public R salesByCategory(@RequestParam("startDate") String startDate, @RequestParam("endDate") String endDate){
  468. String merchSn = null;
  469. SysUserEntity sysUser = (SysUserEntity) SecurityUtils.getSubject().getPrincipal();
  470. if(!"1".equals(sysUser.getRoleType())){
  471. merchSn = sysUser.getMerchSn();
  472. }
  473. return R.ok().put("list",monthlyCustomersService.salesByCategory(startDate,endDate,merchSn));
  474. }
  475. /**
  476. * 每月品牌销售数量查询
  477. * @param startMonth
  478. * @param endMonth
  479. * @return
  480. */
  481. @RequestMapping("/monthlyCategory")
  482. public R monthlyCategory(@RequestParam("startMonth") String startMonth, @RequestParam("endMonth") String endMonth) {
  483. List<String> dateList = new ArrayList<>();
  484. Map<String, Object> returnMap = new HashMap<>();
  485. try {
  486. calculateDifferentMonth(dateList, startMonth, endMonth);
  487. } catch (ParseException e) {
  488. e.printStackTrace();
  489. }
  490. try {
  491. String merchSn = null;
  492. SysUserEntity sysUser = (SysUserEntity) SecurityUtils.getSubject().getPrincipal();
  493. if(!"1".equals(sysUser.getRoleType())){
  494. merchSn = sysUser.getMerchSn();
  495. }
  496. Map<String,Object> map = monthlyCustomersService.monthlyCategory(startMonth,endMonth,merchSn);
  497. returnMap.put("dateList", dateList);
  498. returnMap.putAll(map);
  499. } catch (Exception e) {
  500. e.printStackTrace();
  501. return R.error(e.getMessage());
  502. }
  503. return R.ok(returnMap);
  504. }
  505. }