xuhy
2026-01-19 738a55d37d125c4bd626f4cd445300d884c95e3a
ruoyi-applet/src/main/java/com/ruoyi/web/controller/api/H5AICallbackController.java
@@ -3,19 +3,15 @@
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;
@@ -25,6 +21,7 @@
import java.util.ArrayList;
import java.util.List;
import java.util.Objects;
import java.util.stream.Collectors;
/**
 * <p>
@@ -47,6 +44,8 @@
    private TSysAppUserService sysAppUserService;
    @Autowired
    private TSysInspectionRiskEstimateService sysInspectionRiskEstimateService;
    @Autowired
    private TSysChronicDiseaseService sysChronicDiseaseService;
//    @PostMapping("/reportReturn")
//    public String reportReturn(String encryptedJson, String signEncryptedJson) throws Exception {
@@ -270,6 +269,8 @@
        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();
@@ -283,7 +284,41 @@
            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();