Prechádzať zdrojové kódy

add
mqtt信息发送

lifang 3 týždňov pred
rodič
commit
97014a2ab4

+ 4 - 2
nb-service/app-doctor/src/main/java/com/nb/app/doctor/controller/EvalController.java

@@ -10,6 +10,7 @@ import com.nb.core.entity.GenericEntity;
 import com.nb.core.result.R;
 import com.nb.web.api.dto.EvalBatchDTO;
 import com.nb.web.api.entity.BusEvaluationEntity;
+import com.nb.web.api.entity.BusHospitalConfigEntity;
 import com.nb.web.api.feign.IClinicEvalClient;
 import com.nb.web.api.feign.IHospitalConfigClient;
 import io.swagger.annotations.Api;
@@ -21,6 +22,7 @@ import org.springframework.web.bind.annotation.*;
 
 import java.util.LinkedList;
 import java.util.List;
+import java.util.Optional;
 
 /**
  * @author lifang
@@ -75,8 +77,8 @@ public class EvalController {
 
     @PostMapping("/config/{tenantId}")
     @ApiOperation("获取评价信息配置项")
-    public R config(@PathVariable("tenantId") String tenantId){
-        return R.success(configClient.getEvalConfig(tenantId));
+    public R<BusHospitalConfigEntity> config(@PathVariable("tenantId") String tenantId){
+        return R.success(Optional.ofNullable(configClient.getEvalConfig(tenantId)).orElse(new BusHospitalConfigEntity()));
     }
 
     @PostMapping("/batch")

+ 2 - 2
nb-service/app-doctor/src/main/java/com/nb/app/doctor/controller/UserController.java

@@ -41,8 +41,8 @@ public class UserController {
     @PostMapping("/consult/{userId}")
     @ApiOperation("查询医生咨询设置")
     public R<AppUserConsultConfigEntity> getConsultConfig(@PathVariable("userId") String userId){
-        return R.success(consultConfigService.getOne(new QueryWrapper<AppUserConsultConfigEntity>().lambda()
-                .eq(AppUserConsultConfigEntity::getUserId,userId)));
+        return R.success(Optional.ofNullable(consultConfigService.getOne(new QueryWrapper<AppUserConsultConfigEntity>().lambda()
+                .eq(AppUserConsultConfigEntity::getUserId,userId))).orElse(new AppUserConsultConfigEntity()));
     }
 
     @PostMapping("/consult/edit")

+ 1 - 0
nb-service/web-service/src/main/java/com/nb/web/service/bus/service/LocalBusEvaluationService.java

@@ -178,6 +178,7 @@ public class LocalBusEvaluationService extends BaseService<BusEvaluationMapper,
             BusClinicEntity clinic = clinicService.getById(clinicId);
             clinic.setLastBadEval(adverseReactions);
             clinic.setEvalTime(Optional.ofNullable(entity.getEvaluateTime()).orElse(new Date()));
+            clinic.setAbnormal(StrUtil.isNotEmpty(adverseReactions));
             clinicService.updateById(clinic);
             if(CharSequenceUtil.isNotBlank(entity.getPatientId())){
                 wsPublishUtils.publishPatientMonitor(entity.getPatientId(),entity.getTenantId());