java/haizhentong.git

			@@ -1,29 +1,27 @@
			package com.ruoyi.web.controller.api;

			import com.alibaba.fastjson2.JSONArray;
			import com.alibaba.fastjson2.JSONObject;
			import com.baomidou.mybatisplus.core.toolkit.Wrappers;
			import com.ruoyi.common.core.domain.R;
			import com.ruoyi.common.redis.service.RedisService;
			import com.ruoyi.framework.web.service.SysLoginService;
			import com.ruoyi.framework.web.service.TokenService;
			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.utils.util.AesSimpleUtil;
			import com.ruoyi.system.utils.util.RsaSimpleUtil;
			import com.ruoyi.system.utils.wx.model.WeixinProperties;
			import com.ruoyi.system.utils.wx.tools.WxAppletTools;
			import com.ruoyi.system.utils.xiMaUtil.AesUtil;
			import lombok.extern.slf4j.Slf4j;
			import org.springframework.beans.factory.annotation.Autowired;
			import org.springframework.web.bind.annotation.PostMapping;
			import org.springframework.web.bind.annotation.RequestMapping;
			import org.springframework.web.bind.annotation.RestController;
			import org.springframework.web.client.RestTemplate;

			import javax.annotation.Resource;
			import java.util.ArrayList;
			import java.util.List;

			/**
			* <p>
			@@ -42,91 +40,94 @@
			private TSysAiConfigService sysAiConfigService;
			@Autowired
			private TSysInspectionService sysInspectionService;
			@Autowired
			private TSysAppUserService sysAppUserService;
			@Autowired
			private TSysInspectionRiskEstimateService sysInspectionRiskEstimateService;

			@PostMapping("/reportReturn")
			public String reportReturn(String encryptedJson, String signEncryptedJson) throws Exception {
			TSysAiConfig sysAiConfig = sysAiConfigService.getById(1);
			// 应用AES秘钥
			String aesKey = sysAiConfig.getAesKey();
			// 平台RSA公钥
			String rsaPublicKey = sysAiConfig.getRsaPublicKey();

			// 1. 先解密
			String source = AesSimpleUtil.decrypt(encryptedJson, aesKey);
			System.out.println("AI问诊回调数据=====："+ source);
			JSONObject jsonObject = JSONObject.parseObject(source);

			// 2. 再验证签名
			String signSource = String.format("%s_%s",
			jsonObject.getString("thirdId"),
			jsonObject.getString("time"));
			boolean verify = RsaSimpleUtil.verify(signSource, signEncryptedJson, rsaPublicKey);
			if (!verify) {
			return "error";
			}
			// 3. 验证成功，则仅仅业务保存并返回success字符串
			/**
			* {
			* "returnType": 1,
			* "name": "张三",
			* "phone": "13344445555",
			* "email": null,
			* "sex": 1,
			* "age": 42,
			* "time": "2023-03-08 08:23:13",
			* "pdf": "https://labelsys-images.oss-cn-hangzhou.aliyuncs.com/tongueFile/check/2023/03/87d76220-085e-4d2e-9fd7-9f5a01da1940.pdf",
			* "healthIndex": 100.0,
			* "constitutionNames": "气虚",
			* "symptomName": "胃气虚证",
			* "thirdId": "13344445555",
			* "tongueFeature": "正常人舌色，舌质淡红润泽。舌苔呈现白色。",
			* "faceFeature": "面部颜色暗沉。"
			* }
			*/

			Integer returnType = jsonObject.getInteger("returnType");
			String name = jsonObject.getString("name");
			String phone = jsonObject.getString("phone");
			String email = jsonObject.getString("email");
			Integer sex = jsonObject.getInteger("sex");
			Integer age = jsonObject.getInteger("age");
			String time = jsonObject.getString("time");
			String pdf = jsonObject.getString("pdf");
			Double healthIndex = jsonObject.getDouble("healthIndex");
			String constitutionNames = jsonObject.getString("constitutionNames");
			String symptomName = jsonObject.getString("symptomName");
			String thirdId = jsonObject.getString("thirdId");
			String tongueFeature = jsonObject.getString("tongueFeature");
			String faceFeature = jsonObject.getString("faceFeature");

			if(returnType == 2){
			log.info("用户["+phone+"]检测失败");
			}

			long count = sysInspectionService.count(Wrappers.lambdaQuery(TSysInspection.class)
			.eq(TSysInspection::getPersonPhone, phone)
			.eq(TSysInspection::getCheckTime, time));
			if (count == 0) {
			TSysInspection sysInspection = new TSysInspection();
			sysInspection.setPersonName(name);
			sysInspection.setPersonPhone(phone);
			sysInspection.setPersonSex(sex);
			sysInspection.setPersonAge(age);
			sysInspection.setCheckTime(time);
			sysInspection.setPdfUrl(pdf);
			sysInspection.setHealthIndex(healthIndex);
			sysInspection.setConstitutionNames(constitutionNames);
			sysInspection.setSymptomName(symptomName);
			sysInspection.setTongueFeature(tongueFeature);
			sysInspection.setFaceFeature(faceFeature);
			sysInspection.setAppUserId(thirdId);
			sysInspection.setInspectionType(2);
			sysInspection.setIsPay(0);
			sysInspectionService.save(sysInspection);
			}

			return "success";
			}
			// @PostMapping("/reportReturn")
			// public String reportReturn(String encryptedJson, String signEncryptedJson) throws Exception {
			// TSysAiConfig sysAiConfig = sysAiConfigService.getById(1);
			// // 应用AES秘钥
			// String aesKey = sysAiConfig.getAesKey();
			// // 平台RSA公钥
			// String rsaPublicKey = sysAiConfig.getRsaPublicKey();
			//
			// // 1. 先解密
			// String source = AesSimpleUtil.decrypt(encryptedJson, aesKey);
			// System.out.println("AI问诊回调数据=====："+ source);
			// JSONObject jsonObject = JSONObject.parseObject(source);
			//
			// // 2. 再验证签名
			// String signSource = String.format("%s_%s",
			// jsonObject.getString("thirdId"),
			// jsonObject.getString("time"));
			// boolean verify = RsaSimpleUtil.verify(signSource, signEncryptedJson, rsaPublicKey);
			// if (!verify) {
			// return "error";
			// }
			// // 3. 验证成功，则仅仅业务保存并返回success字符串
			// /**
			// * {
			// * "returnType": 1,
			// * "name": "张三",
			// * "phone": "13344445555",
			// * "email": null,
			// * "sex": 1,
			// * "age": 42,
			// * "time": "2023-03-08 08:23:13",
			// * "pdf": "https://labelsys-images.oss-cn-hangzhou.aliyuncs.com/tongueFile/check/2023/03/87d76220-085e-4d2e-9fd7-9f5a01da1940.pdf",
			// * "healthIndex": 100.0,
			// * "constitutionNames": "气虚",
			// * "symptomName": "胃气虚证",
			// * "thirdId": "13344445555",
			// * "tongueFeature": "正常人舌色，舌质淡红润泽。舌苔呈现白色。",
			// * "faceFeature": "面部颜色暗沉。"
			// * }
			// */
			//
			// Integer returnType = jsonObject.getInteger("returnType");
			// String name = jsonObject.getString("name");
			// String phone = jsonObject.getString("phone");
			// String email = jsonObject.getString("email");
			// Integer sex = jsonObject.getInteger("sex");
			// Integer age = jsonObject.getInteger("age");
			// String time = jsonObject.getString("time");
			// String pdf = jsonObject.getString("pdf");
			// Double healthIndex = jsonObject.getDouble("healthIndex");
			// String constitutionNames = jsonObject.getString("constitutionNames");
			// String symptomName = jsonObject.getString("symptomName");
			// String thirdId = jsonObject.getString("thirdId");
			// String tongueFeature = jsonObject.getString("tongueFeature");
			// String faceFeature = jsonObject.getString("faceFeature");
			//
			// if(returnType == 2){
			// log.info("用户["+phone+"]检测失败");
			// }
			//
			// long count = sysInspectionService.count(Wrappers.lambdaQuery(TSysInspection.class)
			// .eq(TSysInspection::getPersonPhone, phone)
			// .eq(TSysInspection::getCheckTime, time));
			// if (count == 0) {
			// TSysInspection sysInspection = new TSysInspection();
			// sysInspection.setPersonName(name);
			// sysInspection.setPersonPhone(phone);
			// sysInspection.setPersonSex(sex);
			// sysInspection.setPersonAge(age);
			// sysInspection.setCheckTime(time);
			// sysInspection.setPdfUrl(pdf);
			// sysInspection.setHealthIndex(healthIndex);
			// sysInspection.setConstitutionNames(constitutionNames);
			// sysInspection.setSymptomName(symptomName);
			// sysInspection.setTongueFeature(tongueFeature);
			// sysInspection.setFaceFeature(faceFeature);
			// sysInspection.setAppUserId(thirdId);
			// sysInspection.setInspectionType(2);
			// sysInspection.setIsPay(0);
			// sysInspectionService.save(sysInspection);
			// }
			// return "success";
			// }



			@@ -149,6 +150,69 @@
			@PostMapping("/xiMaDoubleScreenReportPush")
			public JSONObject xiMaDoubleScreenReportPush(JSONObject jsonObject) throws Exception {
			log.info("双屏仪报告推送:{}",jsonObject);
			// 主体信息
			String reportTime = jsonObject.getString("report_time");
			String report_print_url = jsonObject.getString("report_print_url");
			String present_history = jsonObject.getString("present_history");
			String tcm_syndrome = jsonObject.getString("tcm_syndrome");
			String disease_history_memo = jsonObject.getString("disease_history_memo");
			String western_medicine_diagnosis = jsonObject.getString("western_medicine_diagnosis");

			TSysInspection sysInspection = new TSysInspection();
			sysInspection.setCheckTime(reportTime);
			sysInspection.setReportPrintUrl(report_print_url);
			sysInspection.setPresentHistory(present_history);
			sysInspection.setTcmSyndrome(tcm_syndrome);
			sysInspection.setDiseaseHistoryMemo(disease_history_memo);
			sysInspection.setWesternMedicineDiagnosis(western_medicine_diagnosis);

			// 用户信息
			JSONObject userInfo = jsonObject.getJSONObject("user_info");
			Long id = userInfo.getLong("id");
			String phone = userInfo.getString("phone");
			String user_name = userInfo.getString("user_name");
			Long device_account_id = userInfo.getLong("device_account_id");
			String sex = userInfo.getString("sex");
			String age = userInfo.getString("age");

			sysInspection.setThreeUserId(id);
			sysInspection.setPhone(phone);
			sysInspection.setNickName(user_name);
			sysInspection.setSex("男".equals(sex) ? 1 : 2);
			sysInspection.setAge(Integer.parseInt(age));
			sysInspection.setDeviceAccountId(device_account_id);
			sysInspection.setInspectionType(3);

			// 通过手机号查询小程序用户
			TSysAppUser sysAppUser = sysAppUserService.getOne(Wrappers.lambdaQuery(TSysAppUser.class)
			.eq(TSysAppUser::getPhone, phone)
			.last("LIMIT 1"));
			if(sysAppUser != null){
			sysInspection.setAppUserId(sysAppUser.getId());
			sysInspection.setClinicId(sysAppUser.getClinicId());
			}

			sysInspectionService.save(sysInspection);

			// 指脉结果
			JSONObject fingerPulseReport = jsonObject.getJSONObject("finger_pulse_report");
			JSONArray riskEstimate = fingerPulseReport.getJSONArray("risk_estimate");
			List<TSysInspectionRiskEstimate> sysInspectionRiskEstimates = new ArrayList<>();
			for (int i = 0; i < riskEstimate.size(); i++) {
			JSONObject json = riskEstimate.getJSONObject(i);
			TSysInspectionRiskEstimate sysInspectionRiskEstimate = new TSysInspectionRiskEstimate();
			sysInspectionRiskEstimate.setInspectionId(sysInspection.getId());
			String name = json.getString("name");
			String link_url = json.getString("link_url");
			String value = json.getString("value");
			String value_desc = json.getString("value_desc");
			sysInspectionRiskEstimate.setRiskName(name);
			sysInspectionRiskEstimate.setRiskLinkUrl(link_url);
			sysInspectionRiskEstimate.setRiskValue(value);
			sysInspectionRiskEstimate.setRiskValueDesc(value_desc);
			sysInspectionRiskEstimates.add(sysInspectionRiskEstimate);
			}
			sysInspectionRiskEstimateService.saveBatch(sysInspectionRiskEstimates);

			JSONObject response = new JSONObject();
			response.put("error_code",0);