package com.ruoyi.quartz.task; import com.alibaba.fastjson2.JSONObject; import com.fasterxml.jackson.databind.JsonNode; import com.fasterxml.jackson.databind.ObjectMapper; import com.google.common.reflect.TypeToken; import com.google.gson.Gson; import com.google.gson.JsonArray; import com.google.gson.JsonObject; import com.ruoyi.common.core.redis.RedisCache; import com.ruoyi.common.enums.MsgLSEnum; import com.ruoyi.common.enums.ServiceFromEnum; import com.ruoyi.common.enums.VisitSendStateEnum; import com.ruoyi.common.enums.WxGZHEnum; import com.ruoyi.common.exception.base.BaseException; import com.ruoyi.common.utils.HttpUtil; import com.ruoyi.common.utils.OkHttpExample; import com.ruoyi.common.utils.RSAPublicKeyExample; import com.ruoyi.common.utils.StringUtils; import com.ruoyi.common.utils.http.HttpUtils; import com.smartor.common.LSHospTokenUtil; import com.smartor.domain.*; import com.smartor.mapper.ServiceSubtaskMapper; import com.smartor.mapper.ServiceTaskMapper; import com.smartor.mapper.SysUserImportMapper; import com.smartor.service.*; import lombok.extern.slf4j.Slf4j; import org.apache.commons.collections4.CollectionUtils; import org.apache.commons.lang3.ObjectUtils; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.beans.factory.annotation.Value; import org.springframework.stereotype.Component; import org.springframework.transaction.PlatformTransactionManager; import org.springframework.transaction.annotation.Transactional; import java.io.File; import java.io.FileWriter; import java.io.IOException; import java.lang.reflect.Type; import java.net.URLEncoder; import java.nio.charset.StandardCharsets; import java.nio.file.Files; import java.nio.file.Paths; import java.security.MessageDigest; import java.text.ParseException; import java.text.SimpleDateFormat; import java.time.LocalDate; import java.time.LocalDateTime; import java.time.LocalTime; import java.time.ZoneId; import java.time.format.DateTimeFormatter; import java.util.*; import java.util.stream.Collectors; import static cn.hutool.core.convert.Convert.toHex; /** * 定时任务调度测试 * * @author ruoyi */ @Slf4j @Component("ryTask") public class RyTask { @Autowired private IServiceThirdDataService iServiceThirdDataService; @Autowired private IServiceOutPathService iServiceOutPathService; @Autowired private IServiceSubtaskAnswerService serviceSubtaskAnswerService; @Autowired private IPatMedInhospService iPatMedInhospService; @Autowired private IPatMedOuthospService iPatMedOuthospService; @Autowired private IPatMedOperationService iPatMedOperationService; @Autowired private IServiceSubtaskService iServiceSubtaskService; @Autowired private IServicePatientTempService iServicePatientTempService; @Autowired private IHNGatherPatArchiveService ihnGatherPatArchiveService; @Autowired private SysUserImportMapper sysUserImportMapper; @Value("${localIP}") private String localIP; @Value("${xhsmsPath}") private String xhsmsPath; @Value("${pub_key}") private String pub_key; @Value("${req_path}") private String req_path; @Value("${visitHosp}") private Integer visitHosp; @Autowired private ServiceTaskMapper serviceTaskMapper; @Autowired private ServiceSubtaskMapper serviceSubtaskMapper; @Autowired private RedisCache redisCache; @Autowired private IServiceSubtaskRecordService serviceSubtaskRecordService; @Autowired IBaseSmsaccountService baseSmsaccountService; @Autowired IPatArchiveService patArchiveService; @Autowired IPatMedOuthospService patMedOuthospService; @Autowired ISvyTaskTemplateService svyTaskTemplateService; @Autowired IIvrTaskTemplateService iIvrTaskTemplateService; @Autowired IXHGatherPatArchiveService ixhGatherPatArchiveService; @Value("${appid}") private String appid; @Value("${server.port}") private String port; @Value("${spring.profiles.active}") private String active; public void ryMultipleParams(String s, Boolean b, Long l, Double d, Integer i) { System.out.println(StringUtils.format("执行多参方法： 字符串类型{}，布尔类型{}，长整型{}，浮点型{}，整形{}", s, b, l, d, i)); } public void ryParams(String params) { System.out.println("执行有参方法：" + params); } public void ryNoParams() { System.out.println("执行无参方法"); } public void importData() { String filePath = "C:\\Users\\86176\\Desktop\\新建文本文档 4.txt"; // 替换为你的文件路径 try { // 读取文件内容 String jsonContent = new String(Files.readAllBytes(Paths.get(filePath)), StandardCharsets.UTF_8); // 创建ObjectMapper对象 ObjectMapper objectMapper = new ObjectMapper(); // 解析JSON为JsonNode JsonNode rootNode = objectMapper.readTree(jsonContent); // 获取resultList JsonNode resultListNode = rootNode.path("results").path("resultList"); // 遍历resultList中的每个对象 for (JsonNode item : resultListNode) { SysUserImport person = objectMapper.treeToValue(item, SysUserImport.class); person.setStaffPhoto(""); sysUserImportMapper.insertSysUserImport(person); } } catch (IOException e) { e.printStackTrace(); } } public void analysisData() { System.out.println("---------------------------"); //数据解析 ServiceThirdData serviceThirdData = new ServiceThirdData(); serviceThirdData.setDataType("ADT^A03"); serviceThirdData.setIsDeal(0); serviceThirdData.setCreateTime(new Date()); iServiceThirdDataService.queryList(serviceThirdData); } /** * 定时处理外链的数据 */ public void runServiceSubTaskAnswer() { serviceSubtaskAnswerService.saveQuestionAnswer(null, 0L); } /** * 处理HIS数据采集 * 定时任务：采集患者信息、出院、门诊数据 */ public void dealHisData() { log.info("【dealHisData】开始执行HIS数据采集任务"); // 获取昨天0点到今天0点的时间范围 LocalDateTime todayZero = LocalDateTime.now().with(LocalTime.MIN); LocalDateTime yesterdayZero = todayZero.minusDays(1); log.info("【dealHisData】采集时间范围：{} ~ {}", yesterdayZero, todayZero); if (active.trim().equals("xh")) { try { // 采集入院数据 log.info("【dealHisData】新华开始采集入院数据"); ixhGatherPatArchiveService.getInHospDataGather("0", yesterdayZero, todayZero); log.info("【dealHisData】新华入院数据采集完成"); // 采集出院数据 log.info("【dealHisData】新华开始采集出院数据"); ixhGatherPatArchiveService.getInHospDataGather("1", yesterdayZero, todayZero); log.info("【dealHisData】新华出院数据采集完成"); } catch (Exception e) { log.error("【dealHisData】新华数据采集异常", e); } } else if (active.trim().equals("hn")) { try { // 河南数据采集 HnDataGatherVO hnDataGatherVO = new HnDataGatherVO(); log.info("【dealHisData】河南开始采集数据"); ihnGatherPatArchiveService.hnDataGather(hnDataGatherVO); log.info("【dealHisData】河南结束采集数据"); } catch (Exception e) { log.error("【dealHisData】河南数据采集异常", e); } } } /** * 这个只是新华临时使用，平时用不到 */ public void dealHisData2() { //将患者信息、出入院数据全部采集 // 指定的开始日期 LocalDate endDate = LocalDate.of(2025, 3, 3); // 当前日期 LocalDate currentDate = LocalDate.now(); // 定义日期格式 DateTimeFormatter formatter = DateTimeFormatter.ofPattern("yyyy-MM-dd "); // 从开始日期到当前日期逐天打印 for (LocalDate date = endDate; !date.isAfter(currentDate); date = date.plusDays(1)) { System.out.println(date.format(formatter)); ixhGatherPatArchiveService.getInHospDataGather("0", date.minusDays(1).atStartOfDay(), date.atStartOfDay()); ixhGatherPatArchiveService.getInHospDataGather("1", date.minusDays(1).atStartOfDay(), date.atStartOfDay()); } } /** * 处理患者信息，进入子任务表 */ public void dealOutHospInfo() { if (port.equals("8095")) { //出院表 iPatMedInhospService.dealOutHospInfo(); //门诊表 if (visitHosp != 1) { iPatMedOuthospService.dealOutpatientInfo(); } } } /** * 处理手术信息，进入子任务表 */ public void dealOperationInfo() { if (port.equals("8095")) iPatMedOperationService.dealOperationInfo(); } /** * 处理患者信息，进入子任务表(微信小程序) */ public void dealOutHospInfoXHC() { if (port.equals("8095")) { PatMedInhosp patMedInhosp = new PatMedInhosp(); //获取未处理的数据 List servicePatientTemps = iServicePatientTempService.selectServicePatientTempList(new ServicePatientTemp()); } } /** * 长期任务执行 */ public void longTaskSend() { //获取任务信息 ServiceTask st = new ServiceTask(); st.setDelFlag("0"); st.setLongTask(1); List serviceTasks = serviceTaskMapper.selectServiceTaskList(st); log.info("【longTaskSend】获取到{}个长期任务", serviceTasks.size()); for (ServiceTask serviceTask : serviceTasks) { CommonTaskcallMQ commonTaskcallMQ = new CommonTaskcallMQ(); commonTaskcallMQ.setTaskid(serviceTask.getTaskid()); commonTaskcallMQ.setPreachform(serviceTask.getPreachform()); commonTaskcallMQ.setSendType("2"); sfHandlle(commonTaskcallMQ, localIP); } } /** * 判断日期是否是今天 * * @param date * @return */ public boolean isDateToday(Date date) { if (date == null) { return false; } // 将 Date 转为 LocalDate LocalDate localDate = date.toInstant().atZone(ZoneId.systemDefault()).toLocalDate(); // 获取今天的 LocalDate LocalDate today = LocalDate.now(); // 如果日期早于或等于今天，返回 true return !localDate.isAfter(today); } public void sfHandlle(CommonTaskcallMQ commonTaskcallMQ, String ip) { log.info("【sfHandlle】开始处理任务，任务ID：{}", commonTaskcallMQ.getTaskid()); //判断一下commonTaskcallMQ中的stopstate是否与ivr_task中的一致，不一致，则说明是暂停了 ServiceTask ivrTask1 = serviceTaskMapper.selectServiceTaskByTaskid(commonTaskcallMQ.getTaskid()); if (StringUtils.isNotEmpty(commonTaskcallMQ.getPreachform())) { //如何任务发送方式不为空 String[] split = commonTaskcallMQ.getPreachform().split(","); log.info("【sfHandlle】任务发送方式：{}", Arrays.toString(split)); for (String serviceFrom : split) { String descByCode = ServiceFromEnum.getDescByCode(Integer.valueOf(serviceFrom)); //通过任务ID拿到患者信息 ServiceSubtaskVO ivrTaskcall = new ServiceSubtaskVO(); ivrTaskcall.setTaskid(commonTaskcallMQ.getTaskid()); ivrTaskcall.setSendstate(2L); List subtaskList = iServiceSubtaskService.selectServiceSubtaskList(ivrTaskcall); //丽水有的医院还没法做长期任务随访 List subtaskList2 = new ArrayList<>(); if (visitHosp == 2) { for (ServiceSubtask serviceSubtask : subtaskList) { Boolean b = VisitSendStateEnum.getDescByCode(serviceSubtask.getOrgid()); if (b) subtaskList2.add(serviceSubtask); } subtaskList = subtaskList2; } // 按照 endtime 离当前时间最近的排序 List selectServiceSubtaskList = subtaskList.stream().sorted(Comparator.comparing(subtask -> Math.abs(subtask.getEndtime().getTime() - new Date().getTime()))).collect(Collectors.toList()); if (descByCode.equals("电话")) { String value = ""; List list = new ArrayList<>(); for (ServiceSubtask serviceSubtask : selectServiceSubtaskList) { ServiceTask ivrTask = serviceTaskMapper.selectServiceTaskByTaskid(serviceSubtask.getTaskid()); if (ivrTask.getSendState() != null && ivrTask.getSendState() == 3 || ivrTask.getSendState() != null && ivrTask.getSendState() == 4) { //如何任务被"暂停"或"终止" break; } if (org.apache.commons.lang3.StringUtils.isEmpty(serviceSubtask.getPhone())) { serviceSubtask.setRemark("手机号为空"); serviceSubtask.setSendstate(4L); serviceSubtask.setResult("error"); // serviceSubtask.setFinishtime(new Date()); serviceSubtaskMapper.updateServiceSubtask(serviceSubtask); continue; } boolean dateToday = isDateToday(serviceSubtask.getLongSendTime()); //说明是立即发送(先把消息放到cache-0中， displayNo不知道怎么配置) if (dateToday) { list.add(serviceSubtask.getId().toString()); //在子任务表里记录一下 String uuid = UUID.randomUUID().toString(); serviceSubtask.setResult("success"); serviceSubtask.setRemark("长期任务，电话进入队列成功"); serviceSubtask.setGuid(uuid); serviceSubtaskMapper.updateServiceSubtask(serviceSubtask); //任务发送记录 ServiceSubtaskRecord serviceSubtaskRecord = new ServiceSubtaskRecord(); serviceSubtaskRecord.setTaskid(serviceSubtask.getTaskid().toString()); serviceSubtaskRecord.setSubtaskId(serviceSubtask.getId()); serviceSubtaskRecord.setUuid(uuid); serviceSubtaskRecord.setTasktype(serviceSubtask.getType()); serviceSubtaskRecord.setPreachform("3"); serviceSubtaskRecord.setStartTime(System.currentTimeMillis()); serviceSubtaskRecord.setRemark("长期任务，电话进入队列成功"); serviceSubtaskRecordService.insertServiceSubtaskRecord(serviceSubtaskRecord); } } //将要执行的放到缓存中 if (list.size() > 0) { // redisCache.setCacheListLeft("cache-0", list); redisCache.setCacheListLeftAndDistinct("cache-0", list); log.info("【sfHandlle】电话任务已加入队列，数量：{}", list.size()); } } else if (descByCode.equals("多媒体")) { //多媒体 } else if (descByCode.equals("纸质")) { //纸质 } else if (descByCode.equals("微信小程序")) { //微信小程序 log.info("【sfHandlle】处理微信小程序任务，任务信息：{}", ivrTask1); if (ObjectUtils.isNotEmpty(ivrTask1) && ivrTask1.getPatCycle() == 1) { //说明该任务的患者是循环执行的 ServiceSubtaskVO serviceSubtaskVO = new ServiceSubtaskVO(); serviceSubtaskVO.setTaskid(ivrTask1.getTaskid()); List serviceSubtaskList = serviceSubtaskMapper.selectServiceSubtaskList(serviceSubtaskVO); //这里需要根据身份证去重 List serviceSubtaskListFilter = new ArrayList<>(); aa: for (ServiceSubtask serviceSubtask : serviceSubtaskList) { for (ServiceSubtask ss : serviceSubtaskListFilter) { if (ss.getSfzh().equals(serviceSubtask.getSfzh())) { continue aa; } } serviceSubtaskListFilter.add(serviceSubtask); } for (ServiceSubtask serviceSubtask : serviceSubtaskListFilter) { //将子任务ID删除 、sendstate改成3 serviceSubtask.setSendstate(3L); serviceSubtask.setId(null); serviceSubtask.setFinishtime(null); serviceSubtask.setCreateTime(new Date()); serviceSubtask.setUpdateTime(new Date()); //处理重复新增问题，先查一下今天是不是有新增过，新增过就不新增了 ServiceSubtaskVO ssvo = new ServiceSubtaskVO(); LocalDate today = LocalDate.now(); LocalTime startOfDay = LocalTime.of(0, 0, 0); LocalTime endOfDay = LocalTime.of(23, 59, 59); Date startOfDayDate = Date.from(today.atTime(startOfDay).atZone(ZoneId.systemDefault()).toInstant()); Date endOfDayDate = Date.from(today.atTime(endOfDay).atZone(ZoneId.systemDefault()).toInstant()); ssvo.setCreateStartTime(startOfDayDate); ssvo.setCreateEndTime(endOfDayDate); ssvo.setCreateBy(serviceSubtask.getCreateBy()); ssvo.setSendname(serviceSubtask.getSendname()); ssvo.setSfzh(serviceSubtask.getSfzh()); List serviceSubtaskListByCreateTime = serviceSubtaskMapper.selectServiceSubtaskListByCreateTime(ssvo); if (CollectionUtils.isEmpty(serviceSubtaskListByCreateTime)) serviceSubtaskMapper.insertServiceSubtask(serviceSubtask); } } } else if (descByCode.equals("短信")) { RSAPublicKeyExample rsaPublicKeyExample = new RSAPublicKeyExample(); String taskId = rsaPublicKeyExample.encryptedData(ivrTask1.getTaskid().toString(), pub_key); for (ServiceSubtask serviceSubtask : selectServiceSubtaskList) { log.info("【sfHandlle】处理短信长期任务，患者ID：{}", serviceSubtask.getPatid()); boolean dateToday = isDateToday(serviceSubtask.getLongSendTime()); if (dateToday) { try { //先判断患者是不是还要发送 PatArchive patArchive = patArchiveService.selectPatArchiveByPatid(serviceSubtask.getPatid()); if (!Objects.isNull(patArchive) && patArchive.getNotrequiredFlag() == "1") { //不需要发送 serviceSubtask.setResult("error"); serviceSubtask.setRemark(patArchive.getNotrequiredreason()); serviceSubtask.setSendstate(4L); // serviceSubtask.setFinishtime(new Date()); iServiceSubtaskService.insertServiceSubtask(serviceSubtask); continue; } String patid = rsaPublicKeyExample.encryptedData(serviceSubtask.getPatid().toString(), pub_key); String subId = rsaPublicKeyExample.encryptedData(serviceSubtask.getId().toString(), pub_key); SendMagParam sendMagParam = new SendMagParam(); sendMagParam.setType("4"); ServiceOutPath serviceOutPath = new ServiceOutPath(); serviceOutPath.setParam1(taskId); serviceOutPath.setParam2(patid); serviceOutPath.setParam3(ivrTask1.getTaskName()); serviceOutPath.setParam6(subId); serviceOutPath.setCreateTime(new Date()); iServiceOutPathService.insertServiceOutPath(serviceOutPath); String format = String.format("%03X", serviceOutPath.getId()); serviceOutPath.setRadix(format); serviceOutPath.setUpdateTime(new Date()); iServiceOutPathService.updateServiceOutPath(serviceOutPath); sendMagParam.setPhone(serviceSubtask.getPhone()); sendMagParam.setUrl(ip + ":" + req_path + "/wt?p=" + format); sendMagParam.setContent("【新华医院】您好，邀请您填写出院调查表，请点击" + sendMagParam.getUrl() + "填写。感谢您配合！"); String isSuccess = null; if (visitHosp == 1) { Map req = new HashMap<>(); req.put("phone", sendMagParam.getPhone()); req.put("content", sendMagParam.getContent()); isSuccess = HttpUtil.postJsonRequest(xhsmsPath, new Gson().toJson(req)); } else if (visitHosp == 2) { //丽水的短信发送方式 Map map = MsgLSEnum.getAddressByCode(serviceSubtask.getOrgid()); String token = LSHospTokenUtil.getToken(serviceSubtask.getOrgid()); if (ObjectUtils.isNotEmpty(map) && StringUtils.isEmpty(map.get("address"))) { ServiceSubtask ss = new ServiceSubtask(); ss.setResult("error"); ss.setRemark("短信发送失败,该机构没有配置短信地址"); ss.setSendstate(5L); ss.setId(serviceSubtask.getId()); // ss.setFinishtime(new Date()); serviceSubtaskMapper.updateServiceSubtask(ss); continue; } log.info("【sfHandlle】丽水短信发送，地址：{}，参数：{}，机构ID：{}", map.get("address"), sendMagParam, serviceSubtask.getOrgid()); String dxCode = getDXCode(map.get("address"), sendMagParam.getPhone(), sendMagParam.getContent(), map.get("sendPersonId"), map.get("sendPersonName"), MsgLSEnum.getHeaderByCode(serviceSubtask.getOrgid()), token); log.info("【sfHandlle】丽水短信发送结果：{}", dxCode); ObjectMapper objectMapper = new ObjectMapper(); Map textParam = objectMapper.readValue(dxCode, Map.class); String code = textParam.get("Code").toString(); if (code.equals("0")) { isSuccess = "true"; } } //任务发送记录 ServiceSubtaskRecord serviceSubtaskRecord = new ServiceSubtaskRecord(); serviceSubtaskRecord.setTaskid(serviceSubtask.getTaskid().toString()); serviceSubtaskRecord.setUuid(UUID.randomUUID().toString()); serviceSubtaskRecord.setTasktype(serviceSubtask.getType()); serviceSubtaskRecord.setPreachform("4"); serviceSubtaskRecord.setStartTime(System.currentTimeMillis()); serviceSubtaskRecord.setResult("success"); if (StringUtils.isNotEmpty(isSuccess) && !isSuccess.equals("true")) serviceSubtaskRecord.setResult("error"); serviceSubtaskRecordService.insertServiceSubtaskRecord(serviceSubtaskRecord); //发送完成后，修改状态 serviceSubtask.setSendstate(3L); if (StringUtils.isNotEmpty(isSuccess) && !isSuccess.equals("true")) { serviceSubtask.setResult("success"); serviceSubtask.setRemark("短信发送成功"); } else { serviceSubtask.setResult("error"); serviceSubtask.setSendstate(5L); serviceSubtask.setRemark("短信发送失败"); } iServiceSubtaskService.updateServiceSubtask(serviceSubtask); } catch (Exception e) { String guid = UUID.randomUUID().toString(); log.error("【sfHandlle】长期任务短信发送失败，原因：{}，GUID：{}", e.getMessage(), guid); serviceSubtask.setResult("error"); serviceSubtask.setRemark("系统错误"); serviceSubtask.setSendstate(5L); serviceSubtask.setGuid(guid); iServiceSubtaskService.updateServiceSubtask(serviceSubtask); } } } } else if (descByCode.equals("公众号")) { log.info("【sfHandlle】处理公众号任务，任务信息：{}", ivrTask1); //公众号 RSAPublicKeyExample rsaPublicKeyExample = new RSAPublicKeyExample(); String taskId = rsaPublicKeyExample.encryptedData(ivrTask1.getTaskid().toString(), pub_key); for (ServiceSubtask serviceSubtask : selectServiceSubtaskList) { boolean dateToday = isDateToday(serviceSubtask.getLongSendTime()); if (dateToday) { try { //先判断患者是不是还要发送 PatArchive patArchive = patArchiveService.selectPatArchiveByPatid(serviceSubtask.getPatid()); if (!Objects.isNull(patArchive) && patArchive.getNotrequiredFlag() == "1") { //不需要发送 serviceSubtask.setResult("error"); serviceSubtask.setRemark(patArchive.getNotrequiredreason()); serviceSubtask.setSendstate(4L); iServiceSubtaskService.insertServiceSubtask(serviceSubtask); continue; } String patid = rsaPublicKeyExample.encryptedData(serviceSubtask.getPatid().toString(), pub_key); String url = null; url = ip + ":" + req_path + "/outsideChainwt?param1=" + taskId + "¶m2=" + patid + "¶m3=" + URLEncoder.encode(ivrTask1.getTaskName(), StandardCharsets.UTF_8.toString()) + "¶m5=false"; //获取微信公众号请求信息根据机构ID List wxqqxx = WxGZHEnum.getDescByCode(patArchive.getOrgid()); if (CollectionUtils.isEmpty(wxqqxx) || wxqqxx.size() < 4) { ServiceSubtask ss = new ServiceSubtask(); ss.setResult("error"); ss.setRemark("该机构的公众号配置信息不全，无法通过公众号发送"); ss.setSendstate(5L); ss.setId(serviceSubtask.getId()); serviceSubtaskMapper.updateServiceSubtask(ss); continue; } if (StringUtils.isEmpty(patArchive.getPatidHis())) { ServiceSubtask ss = new ServiceSubtask(); ss.setResult("error"); ss.setRemark("公众号发送失败,his系统的患者id为空"); ss.setSendstate(5L); ss.setId(serviceSubtask.getId()); serviceSubtaskMapper.updateServiceSubtask(ss); continue; } String wxCode = getWXCode(serviceSubtask.getSfzh(), url, serviceSubtask.getTaskName(), serviceSubtask.getTaskDesc(), patArchive.getTelcode(), serviceSubtask.getSendname(), patArchive.getPatidHis(), wxqqxx); Map map = JSONObject.parseObject(wxCode, Map.class); //任务发送记录 ServiceSubtaskRecord serviceSubtaskRecord = new ServiceSubtaskRecord(); serviceSubtaskRecord.setTaskid(serviceSubtask.getTaskid().toString()); serviceSubtaskRecord.setUuid(UUID.randomUUID().toString()); serviceSubtaskRecord.setTasktype(serviceSubtask.getType()); serviceSubtaskRecord.setPreachform("4"); serviceSubtaskRecord.setStartTime(System.currentTimeMillis()); serviceSubtaskRecord.setResult("success"); if (!map.isEmpty() && (Boolean) map.get("succ") == false) serviceSubtaskRecord.setResult("error"); serviceSubtaskRecordService.insertServiceSubtaskRecord(serviceSubtaskRecord); //发送完成后，修改状态 serviceSubtask.setSendstate(3L); if ((Boolean) map.get("succ") == true) { serviceSubtask.setResult("success"); } else { log.error("【sfHandlle】公众号发送失败，患者信息：{}，错误信息：{}", serviceSubtask, map.get("msg")); serviceSubtask.setResult("error"); serviceSubtask.setSendstate(5L); serviceSubtask.setRemark(map.get("msg").toString()); } iServiceSubtaskService.updateServiceSubtask(serviceSubtask); } catch (Exception e) { String guid = UUID.randomUUID().toString(); log.error("【sfHandlle】长期任务公众号发送失败，原因：{}，GUID：{}", e.getMessage(), guid); serviceSubtask.setResult("error"); serviceSubtask.setRemark("系统错误"); serviceSubtask.setSendstate(5L); serviceSubtask.setGuid(guid); iServiceSubtaskService.updateServiceSubtask(serviceSubtask); } } } } //通知 MQ 消息已被接收,可以ACK(从队列中删除)了 （这个需要根据业务再去处理ACK） } } } private String getKey() { Map map = new HashMap<>(); for (int i = 0; i < 6; i++) { Boolean aBoolean = redisCache.hasKey("cache-" + i); if (!aBoolean) { redisCache.setCacheObject("cache-" + i, ""); map.put("cache-" + i, ""); } else { map.put("cache-" + i, redisCache.getCacheObject("cache-" + i)); } } String key = null; String value = ""; for (Map.Entry entry : map.entrySet()) { if (StringUtils.isEmpty(value)) { value = entry.getValue(); key = entry.getKey(); } else { if (entry.getValue().split(",").length < value.split(",").length) { value = entry.getValue(); key = entry.getKey(); } } } return key; } private String getDXCode(String address, String ShouJiHM, String FaSongNR, String FaSongRID, String FaSongRXM, Map headerMap, String token) { Map map = new LinkedHashMap<>(); Map YeWuXX = new LinkedHashMap<>(); Map DuanXinXX = new LinkedHashMap<>(); DuanXinXX.put("ShouJiHM", ShouJiHM); DuanXinXX.put("FaSongNR", FaSongNR); DuanXinXX.put("FaSongRID", FaSongRID); DuanXinXX.put("FaSongRXM", FaSongRXM); YeWuXX.put("DuanXinXX", DuanXinXX); map.put("XiaoXiTou", headerMap); map.put("YeWuXX", YeWuXX); String body = new Gson().toJson(map); // String result = HttpUtils.sendPost(address, body); String result = null; try { result = OkHttpExample.sendPostRequest(address, body, token); } catch (IOException e) { e.printStackTrace(); } log.info("【getDXCode】短信发送结果：{}", result); JSONObject jsonObject = JSONObject.parseObject(result); String code = (String) jsonObject.toString(); return code; } private String getWXCode(String idcard, String url, String taskName, String taskDesc, String phone, String setPatientname, String setPatientid, List wxqqxx) { XinHuaWXReq xinHuaWXReq = new XinHuaWXReq(); xinHuaWXReq.setIdcard(idcard); xinHuaWXReq.setUrl(url); xinHuaWXReq.setPatientid(setPatientid); xinHuaWXReq.setPatientname(setPatientname); xinHuaWXReq.setMobile(phone); xinHuaWXReq.setMedcardno(null); xinHuaWXReq.setTitlename(taskName); xinHuaWXReq.setContent(taskDesc); xinHuaWXReq.setAppid(wxqqxx.get(1)); log.info("【getWXCode】微信公众号请求参数：{}", xinHuaWXReq); String body = new Gson().toJson(xinHuaWXReq); String encode = encode(wxqqxx.get(2).concat(body)); Map headerMap = new HashMap<>(); headerMap.put("sign", encode); String result = HttpUtils.sendPostByHeader(wxqqxx.get(3), body, headerMap); JSONObject jsonObject = JSONObject.parseObject(result); String code = (String) jsonObject.toString(); return code; } public String encode(String arg) { if (arg == null) { arg = ""; } MessageDigest md5 = null; try { md5 = MessageDigest.getInstance("MD5"); md5.update(arg.getBytes("UTF-8")); } catch (Exception e) { e.printStackTrace(); } return toHex(md5.digest()); } }