浏览代码

医健宝需求变更,配置加载方式修改

吴树波 4 周之前
父节点
当前提交
dc121c564a

+ 19 - 0
fs-qw-task/src/main/java/com/fs/app/controller/CommonController.java

@@ -2,18 +2,21 @@ package com.fs.app.controller;
 
 
 import cn.hutool.core.date.DateUtil;
+import com.alibaba.fastjson.JSON;
 import com.fs.app.taskService.QwExternalContactRatingService;
 import com.fs.app.taskService.SopLogsChatTaskService;
 import com.fs.app.taskService.SopLogsTaskService;
 import com.fs.app.taskService.SopWxLogsService;
 import com.fs.common.core.domain.R;
 import com.fs.common.core.domain.ResponseResult;
+import com.fs.company.service.ICompanyTrafficRecordService;
 import com.fs.course.mapper.FsCourseWatchLogMapper;
 import com.fs.course.param.newfs.FsUserCourseAddCompanyUserParam;
 import com.fs.course.service.*;
 import com.fs.his.domain.FsUser;
 import com.fs.his.service.IFsInquiryOrderService;
 import com.fs.his.utils.qrcode.QRCodeUtils;
+import com.fs.hisStore.config.MedicalMallConfig;
 import com.fs.qw.domain.QwCompany;
 import com.fs.qw.mapper.QwExternalContactMapper;
 import com.fs.qw.service.IQwCompanyService;
@@ -26,6 +29,8 @@ import com.fs.sop.mapper.SopUserLogsMapper;
 import com.fs.sop.service.*;
 import com.fs.sop.vo.QwSopLogsDoSendListTVO;
 import com.fs.store.service.IFsUserCourseCountService;
+import com.fs.system.domain.SysConfig;
+import com.fs.system.service.ISysConfigService;
 import io.swagger.annotations.Api;
 import lombok.extern.slf4j.Slf4j;
 import org.springframework.beans.factory.annotation.Autowired;
@@ -108,6 +113,10 @@ public class CommonController {
 
     @Autowired
     private IFsCourseLinkService iFsCourseLinkService;
+    @Autowired
+    private ISysConfigService configService;
+    @Autowired
+    private ICompanyTrafficRecordService companyTrafficRecordService;
 
     /**
     * 发官方通连
@@ -298,4 +307,14 @@ public class CommonController {
         }
         return R.ok();
     }
+    @PostMapping("/updateFlow")
+    public R updateFlow(){
+        SysConfig config = configService.selectConfigByConfigKey("medicalMall.func.switch");
+        MedicalMallConfig medicalMallConfig = JSON.parseObject(config.getConfigValue(), MedicalMallConfig.class);
+        log.info("是否更新流量:{}", medicalMallConfig.isStatics());
+        if(medicalMallConfig.isStatics()) {
+            companyTrafficRecordService.refreshTraffic();
+        }
+        return R.ok();
+    }
 }

+ 3 - 1
fs-qw-task/src/main/java/com/fs/app/task/qwTask.java

@@ -391,7 +391,9 @@ public class qwTask {
     public void refreshTraffic(){
         SysConfig config = configService.selectConfigByConfigKey("medicalMall.func.switch");
         MedicalMallConfig medicalMallConfig = JSON.parseObject(config.getConfigValue(), MedicalMallConfig.class);
-        if(medicalMallConfig.isStatics())
+        log.info("是否更新流量:{}", medicalMallConfig.isStatics());
+        if(medicalMallConfig.isStatics()) {
             companyTrafficRecordService.refreshTraffic();
+        }
     }
 }

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

@@ -122,7 +122,7 @@ public class CompanyTrafficRecordServiceImpl extends ServiceImpl<CompanyTrafficR
                 .withSecond(59);
         //根据fs_course_traffic_log表获取公司昨天流量
         Long trafficAmountYesterday = fsCourseTrafficLogMapper.sumTrafficByCompanyYesterday(companyTrafficRecord.getCompanyId(), DateUtil.formatLocalDateTime(startTime), DateUtil.formatLocalDateTime(endTime));
-        if (trafficAmountYesterday != null && trafficAmountYesterday < 0) {
+        if (trafficAmountYesterday != null && trafficAmountYesterday > 0) {
             //判断是否已经更新当天流量
 //            CompanyTrafficRecordLog todayRecodeLog =  companyTrafficRecordLogService.selectTodayRecord(companyTrafficRecord.getCompanyId());
 //            if(todayRecodeLog != null){