From 6ce277dd8b689b2b9d07cc88fee47de4981b719e Mon Sep 17 00:00:00 2001 From: yufenghao <3508605349@qq.com> Date: Fri, 7 Nov 2025 09:54:51 +0800 Subject: [PATCH] =?UTF-8?q?=E5=B7=A5=E4=BD=9C=E5=8F=B0=E6=8E=A5=E5=8F=A3?= =?UTF-8?q?=E6=8F=92=E5=85=A5=E4=BC=98=E5=8C=96?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../serviceImpl/coin/GoldDetailServiceImpl.java | 1 - .../serviceImpl/coin/StatisticsServiceImpl.java | 24 ++--- src/main/resources/mapper/StatisticsMapper.xml | 109 ++++++++++++++++++++- 3 files changed, 118 insertions(+), 16 deletions(-) diff --git a/src/main/java/com/example/demo/serviceImpl/coin/GoldDetailServiceImpl.java b/src/main/java/com/example/demo/serviceImpl/coin/GoldDetailServiceImpl.java index a6d5ddb..a633796 100644 --- a/src/main/java/com/example/demo/serviceImpl/coin/GoldDetailServiceImpl.java +++ b/src/main/java/com/example/demo/serviceImpl/coin/GoldDetailServiceImpl.java @@ -79,7 +79,6 @@ public class GoldDetailServiceImpl implements GoldDetailService { public Gold sumGold(Integer pageNum, Integer pageSize, GoldDetail goldDetail) { Gold gold = new Gold(); //获取订单列表 - PageHelper.startPage(1, 500000); List goldDetails = goldDetailMapper.getGoldDetail(goldDetail); // List goldDetails=goldDetailMapper.getGoldDetail1(1,500000,goldDetail); diff --git a/src/main/java/com/example/demo/serviceImpl/coin/StatisticsServiceImpl.java b/src/main/java/com/example/demo/serviceImpl/coin/StatisticsServiceImpl.java index ae87cfa..92b4b90 100644 --- a/src/main/java/com/example/demo/serviceImpl/coin/StatisticsServiceImpl.java +++ b/src/main/java/com/example/demo/serviceImpl/coin/StatisticsServiceImpl.java @@ -39,9 +39,9 @@ public class StatisticsServiceImpl implements StatisticsService { LocalDate today = LocalDate.now(); //取当天日期 List list = statisticsMapper.listPart1All(today); - if (!list.isEmpty()) { - statisticsMapper.batchInsertPart1(list); - } +// if (!list.isEmpty()) { +// statisticsMapper.batchInsertPart1(list); +// } } /* @@ -58,9 +58,9 @@ public class StatisticsServiceImpl implements StatisticsService { .atZone(ZoneId.systemDefault()) .toInstant()); List list = statisticsMapper.listPart2All(start, end,today); - if (!list.isEmpty()) { - statisticsMapper.batchInsertPart2(list); - } +// if (!list.isEmpty()) { +// statisticsMapper.batchInsertPart2(list); +// } } @@ -78,9 +78,9 @@ public class StatisticsServiceImpl implements StatisticsService { .atZone(ZoneId.systemDefault()) .toInstant()); List list = statisticsMapper.listYearAll(yearStart, end, today); - if (!list.isEmpty()) { - statisticsMapper.batchInsertYear(list); - } +// if (!list.isEmpty()) { +// statisticsMapper.batchInsertYear(list); +// } } @@ -91,9 +91,9 @@ public class StatisticsServiceImpl implements StatisticsService { @Scheduled(cron = "0 30 0 * * ?") // 修改为每天 00:30 执行 public void runDailyTaskPart2() { List list = statisticsMapper.listPart2RangeAll(); - if (!list.isEmpty()) { - statisticsMapper.batchInsertPart2(list); - } +// if (!list.isEmpty()) { +// statisticsMapper.batchInsertPart2(list); +// } } } diff --git a/src/main/resources/mapper/StatisticsMapper.xml b/src/main/resources/mapper/StatisticsMapper.xml index cc03837..acd30ce 100644 --- a/src/main/resources/mapper/StatisticsMapper.xml +++ b/src/main/resources/mapper/StatisticsMapper.xml @@ -2,7 +2,7 @@ - + + + INSERT INTO statistics ( + market, current_datetime, + current_gold, daily_change, + current_permanent, current_free_june, + current_free_december, current_task + ) VALUES + + ( + #{s.market}, #{s.currentDatetime}, + #{s.currentGold}, #{s.dailyChange}, + #{s.currentPermanent}, #{s.currentFreeJune}, + #{s.currentFreeDecember}, #{s.currentTask} + ) + + ON DUPLICATE KEY UPDATE + current_gold = VALUES(current_gold), + daily_change = VALUES(daily_change), + current_permanent = VALUES(current_permanent), + current_free_june = VALUES(current_free_june), + current_free_december = VALUES(current_free_december), + current_task = VALUES(current_task) - + + + 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 + + ( + #{s.market}, #{s.currentDatetime}, + #{s.recharge}, #{s.money}, + #{s.consumePermanent}, #{s.consumeFreeJune}, + #{s.consumeFreeDecember}, #{s.consumeTask}, + #{s.refundPermanent}, #{s.refundFreeJune}, + #{s.refundFreeDecember}, #{s.refundTask}, + #{s.rechargeNum}, #{s.firstRecharge} + ) + + ON DUPLICATE KEY UPDATE + recharge = VALUES(recharge), + money = VALUES(money), + consume_permanent = VALUES(consume_permanent), + consume_free_june = VALUES(consume_free_june), + consume_free_december = VALUES(consume_free_december), + consume_task = VALUES(consume_task), + refund_permanent = VALUES(refund_permanent), + refund_free_june = VALUES(refund_free_june), + refund_free_december = VALUES(refund_free_december), + refund_task = VALUES(refund_task), + recharge_num = VALUES(recharge_num), + first_recharge = VALUES(first_recharge) - + + + INSERT INTO statistics ( + market, current_datetime, + yearly_recharge, + yearly_money, + yearly_consume, + yearly_refund, + yearly_recharge_num + ) VALUES + + ( + #{s.market}, #{s.currentDatetime}, + #{s.yearlyRecharge}, + #{s.yearlyMoney}, + #{s.yearlyConsume}, + #{s.yearlyRefund}, + #{s.yearlyRechargeNum} + ) + + ON DUPLICATE KEY UPDATE + yearly_recharge = VALUES(yearly_recharge), + yearly_money = VALUES(yearly_money), + yearly_consume = VALUES(yearly_consume), + yearly_refund = VALUES(yearly_refund), + yearly_recharge_num = VALUES(yearly_recharge_num) @@ -144,6 +228,25 @@ where m.name IS NOT NULL GROUP BY market +