增加登陆验证码，24小时流量统计

springboot-backend/src/main/java/com/admin/common/dto/CaptchaVerifyDto.java

@@ -0,0 +1,18 @@
+package com.admin.common.dto;
+
+import cloud.tianai.captcha.validator.common.model.dto.ImageCaptchaTrack;
+import lombok.Data;
+
+import javax.validation.constraints.NotBlank;
+
+/**
+ * 验证码验证请求DTO
+ */
+@Data
+public class CaptchaVerifyDto {
+
+    private String id;
+
+    private ImageCaptchaTrack data;
+
+}

springboot-backend/src/main/java/com/admin/common/dto/LoginDto.java

@@ -14,4 +14,7 @@ public class LoginDto {
     @NotBlank(message = "密码不能为空")
     private String password;
 
+    private String captchaId;
+
+
 }

springboot-backend/src/main/java/com/admin/common/dto/UserPackageDto.java

@@ -1,5 +1,6 @@
 package com.admin.common.dto;
 
+import com.admin.entity.StatisticsFlow;
 import lombok.Data;
 
 import java.util.List;
@@ -24,6 +25,11 @@ public class UserPackageDto {
      * 用户转发列表
      */
     private List<UserForwardDetailDto> forwards;
+
+    /**
+     * 用户转发列表
+     */
+    private List<StatisticsFlow> statisticsFlows;
     
     /**
      * 用户基本信息

springboot-backend/src/main/java/com/admin/common/task/ResetFlowAsync.java

@@ -48,7 +48,7 @@ public class ResetFlowAsync {
      * - 不会影响DelayQueueManager的到期任务对status等其他字段的更新
      * - 避免了并发修改导致的数据覆盖问题
      */
-    @Scheduled(cron = "0 0 0 * * ?")
+    @Scheduled(cron = "5 0 0 * * ?")
     public void reset_flow(){
         log.info("开始执行流量重置任务");
         

springboot-backend/src/main/java/com/admin/common/task/StatisticsFlowAsync.java

@@ -0,0 +1,75 @@
+package com.admin.common.task;
+
+
+import com.admin.entity.StatisticsFlow;
+import com.admin.entity.User;
+import com.admin.service.StatisticsFlowService;
+import com.admin.service.UserService;
+import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
+import lombok.extern.slf4j.Slf4j;
+import org.springframework.context.annotation.Configuration;
+import org.springframework.scheduling.annotation.EnableScheduling;
+import org.springframework.scheduling.annotation.Scheduled;
+
+import javax.annotation.PostConstruct;
+import javax.annotation.Resource;
+import java.time.LocalDateTime;
+import java.time.format.DateTimeFormatter;
+import java.util.ArrayList;
+import java.util.List;
+
+@Slf4j
+@Configuration
+@EnableScheduling
+public class StatisticsFlowAsync {
+
+    @Resource
+    UserService userService;
+
+    @Resource
+    StatisticsFlowService statisticsFlowService;
+
+    @Scheduled(cron = "0 0 * * * ?")
+    public void statistics_flow() {
+        LocalDateTime currentHour = LocalDateTime.now().withMinute(0).withSecond(0).withNano(0);
+        String hourString = currentHour.format(DateTimeFormatter.ofPattern("HH:mm"));
+
+        List<User> list = userService.list();
+        List<StatisticsFlow> statisticsFlowList = new ArrayList<>();
+
+        for (User user : list) {
+            long currentFlow = user.getInFlow() + user.getOutFlow();
+
+            // 从数据库获取上一次记录
+            StatisticsFlow lastFlowRecord = statisticsFlowService.getOne(
+                    new LambdaQueryWrapper<StatisticsFlow>()
+                            .eq(StatisticsFlow::getUserId, user.getId()) 
+                            .orderByDesc(StatisticsFlow::getId)         
+                            .last("LIMIT 1")                     
+            );
+
+            long currentTotalFlow = currentFlow;
+            long incrementFlow = currentTotalFlow;
+            
+            if (lastFlowRecord != null) {
+                long lastTotalFlow = lastFlowRecord.getTotalFlow();
+                incrementFlow = currentTotalFlow - lastTotalFlow;
+                
+                if (incrementFlow < 0) {
+                    incrementFlow = currentTotalFlow; 
+                }
+            }
+
+            StatisticsFlow statisticsFlow = new StatisticsFlow();
+            statisticsFlow.setUserId(user.getId());
+            statisticsFlow.setFlow(incrementFlow);        
+            statisticsFlow.setTotalFlow(currentTotalFlow); 
+            statisticsFlow.setTime(hourString);
+
+            statisticsFlowList.add(statisticsFlow);
+        }
+
+        statisticsFlowService.saveBatch(statisticsFlowList);
+    }
+
+}