diff --git a/src/main/java/com/example/demo/controller/coin/WorkbenchController.java b/src/main/java/com/example/demo/controller/coin/WorkbenchController.java index 7e5d3da..2f6e514 100644 --- a/src/main/java/com/example/demo/controller/coin/WorkbenchController.java +++ b/src/main/java/com/example/demo/controller/coin/WorkbenchController.java @@ -57,7 +57,7 @@ public class WorkbenchController { List markets = workbenchService.getAdminMarket(account); WorkbenchCard result; //判断是否是总部 - if (markets != null && markets.contains("1")) { + if (markets != null && markets.contains("总部")||markets.contains("研发部")) { result = workbenchService.getCardCache(markets);//走缓存,拿全部市场的缓存数据 } else { result = workbenchService.getCard(markets);//不走缓存,计算卡片属性 @@ -71,7 +71,7 @@ public class WorkbenchController { @PostMapping("getGraph") public ResponseEntity graph1(@RequestBody WorkbenchCard workbench, @AuthenticationPrincipal Admin admin) { String account = admin.getAccount(); - List markets = generalService.getAdminMarket(account); + List markets = workbenchService.getAdminMarket(account); workbench.setMarkets(markets); diff --git a/src/main/java/com/example/demo/mapper/coin/StatisticsMapper.java b/src/main/java/com/example/demo/mapper/coin/StatisticsMapper.java index e8747d5..875f7c4 100644 --- a/src/main/java/com/example/demo/mapper/coin/StatisticsMapper.java +++ b/src/main/java/com/example/demo/mapper/coin/StatisticsMapper.java @@ -24,49 +24,17 @@ public interface StatisticsMapper { //批量查询 List selectByMarketsAndDate(@Param("markets") List markets, @Param("startDate") Date startDate, @Param("endDate") Date endDate); - //根据地区、审核状态、起止时间查询订单表数据 - List findByMarketAndAuditStatus(@Param("market") String market, - @Param("auditStatusList") List auditStatusList, - @Param("startTime") Date startTime, - @Param("endTime") Date endTime); - //获取某地区当前永久金币余量 - Integer sumCurrentPermanentGold(@Param("market") String market); - //获取某地区当前六月免费金币余量 - Integer sumCurrentFreeJune(@Param("market") String market); - //获取某地区当前永久金币余量 - Integer sumCurrentFreeDecember(@Param("market") String market); - //获取某地区当前永久金币余量 - Integer sumCurrentTaskGold(@Param("market") String market); + //计算该天充值人数 Integer countRechargeNum( @Param("market") String market, @Param("startTime") Date startTime, @Param("endTime") Date endTime); - //计算该天首充人数 - Integer countFirstRecharge( - @Param("market") String market, - @Param("startTime") Date startTime, - @Param("endTime") Date endTime); - //新增part1统计数据 - void insertPart1(Statistics statistics); - //更新part1统计数据 - void updatePart1(Statistics statistics); - //新增part2统计数据 - void insertPart2(Statistics statistics); - //更新part2统计数据 - void updatePart2(Statistics statistics); - //新增年度统计数据 - void insertYear(Statistics statistics); - //更新年度统计数据 - void updateYear(Statistics statistics); + //获取某地区某时间所在日期的数据(仅一条) Statistics selectByMarketAndDate(@Param("market") String market, @Param("startDate") Date startDate, @Param("endDate") Date endDate); - //获取某地区某时间段的统计数据(仅一条) - Statistics selectSumByMarketAndDate(@Param("market") String market, - @Param("startDate") Date startDate, - @Param("endDate") Date endDate); // 一次查 所有地区 Part1(余量) List listPart1All(@Param("today") LocalDate today); diff --git a/src/main/java/com/example/demo/serviceImpl/coin/GeneralServiceImpl.java b/src/main/java/com/example/demo/serviceImpl/coin/GeneralServiceImpl.java index b4d2048..7879ce8 100644 --- a/src/main/java/com/example/demo/serviceImpl/coin/GeneralServiceImpl.java +++ b/src/main/java/com/example/demo/serviceImpl/coin/GeneralServiceImpl.java @@ -130,7 +130,7 @@ public class GeneralServiceImpl implements GeneralService { } List list = Arrays.asList(market.split(",")); //判断是否是总部 - if (list != null && list.contains("1")) { + if (list != null && list.contains("总部")||list.contains("研发部")) { List allMarkets = getMarket(); // 获取所有地区 allMarkets.remove("1"); // 先移除可能存在的总部 allMarkets.add(0, "1"); // 将总部添加到列表第一位 diff --git a/src/main/java/com/example/demo/serviceImpl/coin/WorkbenchServiceImpl.java b/src/main/java/com/example/demo/serviceImpl/coin/WorkbenchServiceImpl.java index f9d8c7b..ef80e2b 100644 --- a/src/main/java/com/example/demo/serviceImpl/coin/WorkbenchServiceImpl.java +++ b/src/main/java/com/example/demo/serviceImpl/coin/WorkbenchServiceImpl.java @@ -60,10 +60,10 @@ public class WorkbenchServiceImpl implements WorkbenchService { } List list = Arrays.asList(market.split(",")); //判断是否是总部 - if (list != null && list.contains("1")) { + if (list != null && list.contains("总部")||market.equals("研发部")) { List allMarkets = workBenchMapper.getMarket(); // 获取所有地区 - allMarkets.remove("1"); // 先移除可能存在的总部 - allMarkets.add(0, "1"); // 将总部添加到列表第一位 + allMarkets.remove("总部"); // 先移除可能存在的总部 + allMarkets.add(0, "总部"); // 将总部添加到列表第一位 list = allMarkets; // 更新list } return list; @@ -130,6 +130,7 @@ public class WorkbenchServiceImpl implements WorkbenchService { //没缓存获取新数据并存入缓存 try { //获取新的工作台数据 + markets = workBenchMapper.getMarket(); WorkbenchCard freshData = getCard(markets); //存入缓存,一小时后过期(与统计表更新时间对应) redisTemplate.opsForValue().set(CACHE_KEY, freshData, 1, java.util.concurrent.TimeUnit.HOURS); diff --git a/src/main/resources/mapper/StatisticsMapper.xml b/src/main/resources/mapper/StatisticsMapper.xml index 557bbb5..5c45b3b 100644 --- a/src/main/resources/mapper/StatisticsMapper.xml +++ b/src/main/resources/mapper/StatisticsMapper.xml @@ -1,60 +1,7 @@ - - - INSERT INTO statistics ( - market, current_datetime, - recharge, money, - consume_permanent, consume_free_june, - consume_free_december, consume_task, - refund_permanent, refund_free_june, - refund_free_december,refund_task, - recharge_num, first_recharge - ) VALUES ( - #{market}, #{currentDatetime}, - #{recharge}, #{money}, - #{consumePermanent}, #{consumeFreeJune}, - #{consumeFreeDecember}, #{consumeTask}, - #{refundPermanent}, #{refundFreeJune}, - #{refundFreeDecember}, #{refundTask}, - #{rechargeNum}, #{firstRecharge} - ) - - - - INSERT INTO statistics ( - market, current_datetime, - current_gold, daily_change, - current_permanent, current_free_june, - current_free_december, current_task - ) VALUES ( - #{market}, #{currentDatetime}, - #{currentGold}, #{dailyChange}, - #{currentPermanent}, #{currentFreeJune}, - #{currentFreeDecember}, #{currentTask} - - ) - - - - INSERT INTO statistics ( - market, current_datetime, - yearly_recharge, - yearly_money, - yearly_consume, - yearly_refund, - yearly_recharge_num - - ) VALUES ( - #{market}, #{currentDatetime}, - #{yearlyRecharge},#{yearlyMoney}, - #{yearlyConsume},#{yearlyRefund}, - #{yearlyRechargeNum} - - ) - INSERT INTO statistics ( @@ -136,66 +83,7 @@ yearly_recharge_num = VALUES(yearly_recharge_num) - - - UPDATE statistics - SET - recharge = #{recharge}, - money = #{money}, - consume_permanent = #{consumePermanent}, - consume_free_june = #{consumeFreeJune}, - consume_free_december = #{consumeFreeDecember}, - consume_task = #{consumeTask}, - refund_permanent = #{refundPermanent}, - refund_free_june = #{refundFreeJune}, - refund_free_december = #{refundFreeDecember}, - refund_task = #{refundTask}, - recharge_num = #{rechargeNum}, - first_recharge = #{firstRecharge} - - ,update_time = #{updateTime} - - WHERE market = #{market} and current_datetime = #{currentDatetime} - - - - update statistics - SET - current_gold = #{currentGold}, - daily_change = #{dailyChange}, - current_permanent = #{currentPermanent}, - current_free_june = #{currentFreeJune}, - current_free_december = #{currentFreeDecember}, - current_task = #{currentTask} - WHERE market = #{market} and current_datetime = #{currentDatetime} - - - - update statistics - SET - yearly_recharge=#{yearlyRecharge}, - yearly_money=#{yearlyMoney}, - yearly_consume=#{yearlyConsume}, - yearly_refund=#{yearlyRefund}, - yearly_recharge_num=#{yearlyRechargeNum} - WHERE market = #{market} and current_datetime = #{currentDatetime} - - - - - - + - - - - - diff --git a/src/main/resources/mapper/WorkBenchMapper.xml b/src/main/resources/mapper/WorkBenchMapper.xml index 52e417c..e9de162 100644 --- a/src/main/resources/mapper/WorkBenchMapper.xml +++ b/src/main/resources/mapper/WorkBenchMapper.xml @@ -132,6 +132,6 @@