| | |
| | | import com.alibaba.fastjson2.JSONArray; |
| | | import com.alibaba.fastjson2.JSONObject; |
| | | import com.baomidou.mybatisplus.core.toolkit.Wrappers; |
| | | import com.ruoyi.system.model.TSysAiConfig; |
| | | import com.ruoyi.system.model.TSysAppUser; |
| | | import com.ruoyi.system.model.TSysInspection; |
| | | import com.ruoyi.system.model.TSysInspectionRiskEstimate; |
| | | import com.ruoyi.system.service.TSysAiConfigService; |
| | | import com.ruoyi.system.service.TSysAppUserService; |
| | | import com.ruoyi.system.service.TSysInspectionRiskEstimateService; |
| | | import com.ruoyi.system.service.TSysInspectionService; |
| | | import com.ruoyi.system.model.*; |
| | | import com.ruoyi.system.service.*; |
| | | import com.ruoyi.system.utils.util.AesSimpleUtil; |
| | | import com.ruoyi.system.utils.util.RsaSimpleUtil; |
| | | import com.ruoyi.system.utils.xiMaUtil.AesUtil; |
| | | import lombok.extern.slf4j.Slf4j; |
| | | import org.springframework.beans.factory.annotation.Autowired; |
| | | import org.springframework.util.CollectionUtils; |
| | | import org.springframework.util.StringUtils; |
| | | import org.springframework.web.bind.annotation.PostMapping; |
| | | import org.springframework.web.bind.annotation.RequestBody; |
| | | import org.springframework.web.bind.annotation.RequestMapping; |
| | |
| | | import java.util.ArrayList; |
| | | import java.util.List; |
| | | import java.util.Objects; |
| | | import java.util.stream.Collectors; |
| | | |
| | | /** |
| | | * <p> |
| | |
| | | private TSysAppUserService sysAppUserService; |
| | | @Autowired |
| | | private TSysInspectionRiskEstimateService sysInspectionRiskEstimateService; |
| | | @Autowired |
| | | private TSysChronicDiseaseService sysChronicDiseaseService; |
| | | |
| | | // @PostMapping("/reportReturn") |
| | | // public String reportReturn(String encryptedJson, String signEncryptedJson) throws Exception { |
| | |
| | | JSONObject fingerPulseReport = jsonObject.getJSONObject("finger_pulse_report"); |
| | | JSONArray riskEstimate = fingerPulseReport.getJSONArray("risk_estimate"); |
| | | List<TSysInspectionRiskEstimate> sysInspectionRiskEstimates = new ArrayList<>(); |
| | | // 查询慢性病列表 |
| | | List<TSysChronicDisease> sysChronicDiseases = sysChronicDiseaseService.list(); |
| | | for (int i = 0; i < riskEstimate.size(); i++) { |
| | | JSONObject json = riskEstimate.getJSONObject(i); |
| | | TSysInspectionRiskEstimate sysInspectionRiskEstimate = new TSysInspectionRiskEstimate(); |
| | |
| | | sysInspectionRiskEstimate.setRiskValue(value); |
| | | sysInspectionRiskEstimate.setRiskValueDesc(value_desc); |
| | | sysInspectionRiskEstimates.add(sysInspectionRiskEstimate); |
| | | // 判断是否为慢性病患者 |
| | | if (("中风险".equals(value) || "重风险".equals(value)) && !"急性咽炎".equals(name)){ |
| | | // 使用名称查询慢性病 |
| | | if(CollectionUtils.isEmpty(sysChronicDiseases)){ |
| | | TSysChronicDisease tSysChronicDisease = new TSysChronicDisease(); |
| | | tSysChronicDisease.setChronicName(name); |
| | | sysChronicDiseaseService.save(tSysChronicDisease); |
| | | if(StringUtils.hasLength(sysAppUser.getChronicDiseaseId())){ |
| | | sysAppUser.setChronicDiseaseId(sysAppUser.getChronicDiseaseId() + "," + tSysChronicDisease.getId()); |
| | | }else{ |
| | | sysAppUser.setChronicDiseaseId(tSysChronicDisease.getId()); |
| | | } |
| | | }else{ |
| | | List<TSysChronicDisease> chronicDiseaseList = sysChronicDiseases.stream().filter(t -> t.getChronicName().equals(name)).collect(Collectors.toList()); |
| | | if(CollectionUtils.isEmpty(chronicDiseaseList)){ |
| | | TSysChronicDisease tSysChronicDisease = new TSysChronicDisease(); |
| | | tSysChronicDisease.setChronicName(name); |
| | | sysChronicDiseaseService.save(tSysChronicDisease); |
| | | if(StringUtils.hasLength(sysAppUser.getChronicDiseaseId())){ |
| | | sysAppUser.setChronicDiseaseId(sysAppUser.getChronicDiseaseId() + "," + tSysChronicDisease.getId()); |
| | | }else{ |
| | | sysAppUser.setChronicDiseaseId(tSysChronicDisease.getId()); |
| | | } |
| | | }else { |
| | | TSysChronicDisease tSysChronicDisease = chronicDiseaseList.get(0); |
| | | if(StringUtils.hasLength(sysAppUser.getChronicDiseaseId())){ |
| | | sysAppUser.setChronicDiseaseId(sysAppUser.getChronicDiseaseId() + "," + tSysChronicDisease.getId()); |
| | | }else{ |
| | | sysAppUser.setChronicDiseaseId(tSysChronicDisease.getId()); |
| | | } |
| | | } |
| | | } |
| | | } |
| | | } |
| | | sysAppUserService.updateById(sysAppUser); |
| | | sysInspectionRiskEstimateService.saveBatch(sysInspectionRiskEstimates); |
| | | |
| | | JSONObject response = new JSONObject(); |