医健宝-2025年9月16日11:34:43 2025年9月17手动更新余额后恢复定时任务

fs-service/src/main/java/com/fs/company/service/impl/CompanyTrafficRecordServiceImpl.java

@@ -18,12 +18,18 @@ import com.fs.system.domain.SysConfig;
 import com.fs.system.service.ISysConfigService;
 import lombok.extern.slf4j.Slf4j;
 import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.data.redis.connection.RedisConnection;
+import org.springframework.data.redis.core.Cursor;
+import org.springframework.data.redis.core.ScanOptions;
 import org.springframework.scheduling.annotation.Scheduled;
 import org.springframework.stereotype.Service;
 import org.springframework.transaction.annotation.Transactional;
 
 import javax.annotation.PostConstruct;
 import java.time.LocalDate;
+import java.time.YearMonth;
+import java.time.format.DateTimeFormatter;
+import java.util.ArrayList;
 import java.util.Date;
 import java.util.List;
 
@@ -73,7 +79,7 @@ public class CompanyTrafficRecordServiceImpl extends ServiceImpl<CompanyTrafficR
         }
     }
 
-    @Scheduled(cron = "0 0 0 * * ?")
+    //@Scheduled(cron = "0 0 0 * * ?")
     public void refreshTraffic() {
         log.info("【定时更新流量】：{}", "开始");
         List<CompanyTrafficRecord> companyTrafficRecords = baseMapper.selectList(new LambdaQueryWrapper<>());

fs-service/src/main/java/com/fs/course/service/impl/FsUserCourseVideoServiceImpl.java

@@ -816,9 +816,9 @@ public class FsUserCourseVideoServiceImpl implements IFsUserCourseVideoService
                 // 直接插入或更新
 //                logger.error("zyp \n【插入或更新流量】：{}",trafficLog);
                 fsCourseTrafficLogMapper.insertOrUpdateTrafficLog(trafficLog);
+                //扣除流量
+                asyncDeductTraffic(company, roundedResult/1024);
             }
-            //扣除流量
-            asyncDeductTraffic(company, roundedResult/1024);
         } catch (Exception e) {
             e.printStackTrace();
             // 打印参数param和异常信息
@@ -2691,15 +2691,15 @@ public class FsUserCourseVideoServiceImpl implements IFsUserCourseVideoService
             long roundedResult = result.multiply(longAsBigDecimal).setScale(0, RoundingMode.HALF_UP).longValue();
             trafficLog.setInternetTraffic(roundedResult);
 
+            //扣除流量
+            Company company = companyMapper.selectCompanyById(param.getCompanyId());
             // 处理 UUID 为空的情况
             if (StringUtils.isNotEmpty(trafficLog.getUuId())) {
                 // 直接插入或更新
 //                logger.error("zyp \n【插入或更新流量】：{}",trafficLog);
                 fsCourseTrafficLogMapper.insertOrUpdateTrafficLog(trafficLog);
+                asyncDeductTraffic(company, roundedResult/1024);
             }
-            //扣除流量
-            Company company = companyMapper.selectCompanyById(param.getCompanyId());
-            asyncDeductTraffic(company, roundedResult/1024);
         } catch (Exception e) {
             e.printStackTrace();
             // 打印参数param和异常信息