فهرست منبع

七院医生定时更新更改,数据一直性定时加上评分

shiyue 3 سال پیش
والد
کامیت
d5a51441b3

+ 9 - 3
src/main/java/com/diagbot/facade/data/ABasDoctorInfoFacade.java

@@ -33,9 +33,15 @@ public class ABasDoctorInfoFacade extends BasDoctorInfoServiceImpl {
      * 同步历史数据
      */
     public void executeDoctorPast() {
-        String sql="select * from v_gy_zgxx_ys";
-        List<BasDoctorInfo> basDeptInfoList = tzDBConn.getBasDoctorInfo(sql);
-        execute(basDeptInfoList);
+        try{
+            String sql="select * from v_gy_zgxx_ys";
+            List<BasDoctorInfo> basDeptInfoList = tzDBConn.getBasDoctorInfo(sql);
+            execute(basDeptInfoList);
+            aMedAbnormalInfoFacade.saveAbnormalInfo("医生信息更新","",JSON.toJSONString(basDeptInfoList), "", "");
+        }catch (Exception e){
+
+        }
+
 
     }
     /**

+ 2 - 2
src/main/java/com/diagbot/facade/data/ABehospitalInfoFacade.java

@@ -144,8 +144,7 @@ public class ABehospitalInfoFacade extends BehospitalInfoServiceImpl {
         behospitalInfoList.stream().forEach(s -> {
             BehospitalInfo behospitalInfo = this.getOne(new QueryWrapper<BehospitalInfo>()
                     .eq("behospital_code", s.getBehospitalCode())
-                    .eq("hospital_id", s.getHospitalId())
-                    .eq("is_deleted",IsDeleteEnum.N), false);
+                    .eq("hospital_id", s.getHospitalId()));
             //判断doctorId是否为数字,不为数字的情况下采用之前的doctorId
             Pattern pattern = Pattern.compile("-?[0-9]+\\.?[0-9]*");
             Matcher isNum = pattern.matcher(StringUtils.isNotEmpty(s.getDoctorId())?s.getDoctorId():"-");
@@ -153,6 +152,7 @@ public class ABehospitalInfoFacade extends BehospitalInfoServiceImpl {
                 if (!isNum.matches()){
                     s.setDoctorId(StringUtils.isNotEmpty(behospitalInfo.getDoctorId())?behospitalInfo.getDoctorId():"-");
                 }
+                s.setIsDeleted("N");
                 s.setGmtModified(new Date());
                 s.setQcTypeId(initQcTypeId(s));
                 updateE.add(s);

+ 9 - 0
src/main/java/com/diagbot/facade/data/SendDataDealFacade.java

@@ -3,7 +3,9 @@ package com.diagbot.facade.data;
 
 import com.alibaba.fastjson.JSON;
 import com.diagbot.entity.*;
+import com.diagbot.facade.BehospitalInfoFacade;
 import com.diagbot.util.TZDBConn;
+import com.diagbot.vo.AnalyzeRunVO;
 import com.google.common.collect.Lists;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.stereotype.Component;
@@ -30,6 +32,8 @@ public class SendDataDealFacade {
     private AMedicalRecordFacade aMedicalRecordFacade;
     @Autowired
     private AMedAbnormalInfoFacade aMedAbnormalInfoFacade;
+    @Autowired
+    BehospitalInfoFacade behospitalInfoFacade;
 
     private TZDBConn tzDBConn = new TZDBConn();
 
@@ -61,6 +65,11 @@ public class SendDataDealFacade {
         sendInfo(code);
         sendDataDealADoctorAdvice(code);
         sendDataDealAMedicalRecord(code);
+        AnalyzeRunVO analyzeRunVO = new AnalyzeRunVO();
+        analyzeRunVO.setHospitalId(Long.valueOf("14"));
+        analyzeRunVO.setBehospitalCode(code);
+        analyzeRunVO.setIsPlacefile("1");
+        behospitalInfoFacade.analyzeApi(analyzeRunVO);
     }
 
     /**

+ 2 - 2
src/main/java/com/diagbot/task/DoctorTask.java

@@ -65,8 +65,8 @@ public class DoctorTask implements SchedulingConfigurer {
             public Date nextExecutionTime(TriggerContext triggerContext) {
                 //2.1 从数据库获取执行周期
                 task = sysTaskCronFacade.getOne(new QueryWrapper<SysTaskCron>()
-                        .eq("cron_code", "dcotor_task"), false);
-                String cron = "0 0 23 * * ? ";
+                        .eq("cron_code", "doctor_task"), false);
+                String cron = "0 0 24 * * ? ";
                 //2.2 合法性校验.
                 if (null != task && StringUtil.isNotBlank(task.getCron())) {
                     cron = task.getCron();

+ 8 - 2
src/main/java/com/diagbot/web/DataController.java

@@ -56,11 +56,17 @@ public class DataController {
     @Autowired
     private OldDataFacade oldDataFacade;
 
+//    @ApiOperation(value = "数据引擎-获取医院所有在职医生的基本信息")
+//    @PostMapping("/sendDoctorInfos")
+//    @SysLogger("sendDoctorInfos")
+//    public RespDTO sendDoctorInfos(@RequestBody List<ABasDoctorInfoVO> list){
+//        return aBasDoctorInfoFacade.executeDoctor(list);
+//    }
     @ApiOperation(value = "数据引擎-获取医院所有在职医生的基本信息")
     @PostMapping("/sendDoctorInfos")
     @SysLogger("sendDoctorInfos")
-    public RespDTO sendDoctorInfos(@RequestBody List<ABasDoctorInfoVO> list){
-        return aBasDoctorInfoFacade.executeDoctor(list);
+    public void sendDoctorInfos(){
+         aBasDoctorInfoFacade.executeDoctorPast();
     }
 
     @ApiOperation(value = "数据引擎-获取医院所有有效科室的基本信息")