看课流量单位为Byte,添加定时任务启动日志输出

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

@@ -72,6 +72,7 @@ public class CompanyTrafficRecordServiceImpl extends ServiceImpl<CompanyTrafficR
 
     @Scheduled(cron = "0 0 0 * * ?")
     public void refreshTraffic() {
+        log.info("【定时更新流量】：{}", "开始");
         List<CompanyTrafficRecord> companyTrafficRecords = baseMapper.selectList(new LambdaQueryWrapper<>());
         for (CompanyTrafficRecord companyTrafficRecord : companyTrafficRecords) {
             doReduce(companyTrafficRecord,"定时更新扣除流量");
@@ -95,6 +96,7 @@ public class CompanyTrafficRecordServiceImpl extends ServiceImpl<CompanyTrafficR
             }
             long trafficAmount = companyTrafficRecord.getBalance() - balance;
             companyTrafficRecord.setBalance(balance);
+            log.info("【更新流量】：{}", "部门ID:" + companyTrafficRecord.getDeptId() +"公司ID:" + companyTrafficRecord.getCompanyId() +  "消耗流量:" + balance+"剩余流量:"+trafficAmount);
             if (trafficAmount != 0) {
                 baseMapper.updateById(CompanyTrafficRecord.builder()
                         .id(companyTrafficRecord.getId())

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

@@ -813,7 +813,7 @@ public class FsUserCourseVideoServiceImpl implements IFsUserCourseVideoService
                 fsCourseTrafficLogMapper.insertOrUpdateTrafficLog(trafficLog);
             }
             //扣除流量
-            asyncDeductTraffic(company, roundedResult);
+            asyncDeductTraffic(company, roundedResult/1024);
         } catch (Exception e) {
             e.printStackTrace();
             // 打印参数param和异常信息
@@ -2672,6 +2672,9 @@ public class FsUserCourseVideoServiceImpl implements IFsUserCourseVideoService
 //                logger.error("zyp \n【插入或更新流量】：{}",trafficLog);
                 fsCourseTrafficLogMapper.insertOrUpdateTrafficLog(trafficLog);
             }
+            //扣除流量
+            Company company = companyMapper.selectCompanyById(param.getCompanyId());
+            asyncDeductTraffic(company, roundedResult/1024);
         } catch (Exception e) {
             e.printStackTrace();
             // 打印参数param和异常信息