package com.ruoyi.web.component; import afu.org.checkerframework.checker.oigj.qual.O; import com.alibaba.fastjson2.JSONObject; import com.fasterxml.jackson.databind.ObjectMapper; import com.google.gson.Gson; import com.google.gson.GsonBuilder; import com.ruoyi.common.core.redis.RedisCache; import com.ruoyi.common.enums.MsgLSEnum; import com.ruoyi.common.enums.ServiceFromEnum; 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.PatArchiveMapper; import com.smartor.mapper.ServiceSubtaskMapper; import com.smartor.mapper.ServiceTaskMapper; import com.smartor.service.IBaseSmsaccountService; import com.smartor.service.IServiceOutPathService; import com.smartor.service.IServiceSubtaskRecordService; import com.sun.org.apache.bcel.internal.generic.NEW; 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.data.redis.connection.Message; import org.springframework.data.redis.listener.KeyExpirationEventMessageListener; import org.springframework.data.redis.listener.RedisMessageListenerContainer; import org.springframework.stereotype.Component; import java.io.IOException; import java.security.MessageDigest; import java.util.*; import java.util.concurrent.ExecutorService; import java.util.concurrent.Executors; import java.util.concurrent.TimeUnit; import static cn.hutool.core.convert.Convert.numberToWord; import static cn.hutool.core.convert.Convert.toHex; @Slf4j @Component//监听此队列 public class RedisMqReceiver extends KeyExpirationEventMessageListener { @Value("${phonePath}") private String phonePath; @Value("${pub_key}") private String pub_key; @Value("${localIP}") private String localIP; @Value("${req_path}") private String req_path; @Autowired private IServiceOutPathService iServiceOutPathService; @Autowired private ServiceSubtaskMapper ivrTaskcallMapper; @Autowired private ServiceTaskMapper ivrTaskMapper; @Autowired private PatArchiveMapper patArchiveMapper; @Autowired private RedisCache redisCache; @Autowired private ServiceTaskMapper svyTaskMapper; @Autowired private ServiceSubtaskMapper serviceSubtaskMapper; @Autowired private IServiceSubtaskRecordService serviceSubtaskRecordService; @Autowired IBaseSmsaccountService baseSmsaccountService; @Value("${xhsmsPath}") private String xhsmsPath; @Value("${visitHosp}") private Integer visitHosp; @Value("${server.port}") private String port; // 创建固定大小的线程池 private static final ExecutorService executorService = Executors.newFixedThreadPool(10); public RedisMqReceiver(RedisMessageListenerContainer listenerContainer) { super(listenerContainer); } @Override public void onMessage(Message message, byte[] pattern) { log.info("监听Redis key过期，key：{}，channel：{}", message.toString(), new String(pattern)); String ip = localIP; log.error("本机的网络IP为:{}", ip); String content = message.toString(); //判断是不是任务信息，如果不是，直接返回，不需要执行 if (!content.contains("taskid") || !port.equals("8095")) { log.error("不是任务信息"); return; } CommonTaskcallMQ commonTaskcallMQ = null; try { ObjectMapper mapper = new ObjectMapper(); if (!content.startsWith("{")) { commonTaskcallMQ = mapper.readValue("{" + content + "}", CommonTaskcallMQ.class); } else { commonTaskcallMQ = mapper.readValue(content, CommonTaskcallMQ.class); } if (commonTaskcallMQ != null) tsakHandle(commonTaskcallMQ, ip, commonTaskcallMQ.getTaskType()); //处理完成，移除redis redisCache.deleteObject(message.toString()); //将状态改成完成 ServiceTask serviceTask = new ServiceTask(); serviceTask.setTaskid(Long.valueOf(commonTaskcallMQ.getTaskid())); serviceTask.setSendState(5L); serviceTask.setFail(1L); svyTaskMapper.updateServiceTask(serviceTask); } catch (Exception e) { Integer integer = redisCache.getCacheObject(commonTaskcallMQ.getTaskid().toString()); if (integer != null && integer == 3) { redisCache.deleteObject(message.toString()); ServiceTask serviceTask = new ServiceTask(); serviceTask.setTaskid(Long.valueOf(commonTaskcallMQ.getTaskid().toString())); serviceTask.setFail(0L); svyTaskMapper.updateServiceTask(serviceTask); //将消息从队列中删除 } else if (integer == null) { redisCache.setCacheObject(commonTaskcallMQ.getTaskid().toString(), 1, 120, TimeUnit.MINUTES); } else { redisCache.setCacheObject(commonTaskcallMQ.getTaskid().toString(), integer + 1, 120, TimeUnit.MINUTES); } log.error("============消费失败,尝试消息补发再次消费!============== {}", e.getMessage()); redisCache.setCacheObject(message.toString(), message.toString(), 60, TimeUnit.SECONDS); } } /** * 任务处理 * * @param commonTaskcallMQ */ public void tsakHandle(CommonTaskcallMQ commonTaskcallMQ, String ip, Integer type) { log.error("进任务了吗？{}", commonTaskcallMQ); //判断一下commonTaskcallMQ中的stopstate是否与ivr_task中的一致，不一致，则说明是暂停了 ServiceTask ivrTask1 = ivrTaskMapper.selectServiceTaskByTaskid(commonTaskcallMQ.getTaskid()); // if (ivrTask1.getStopState() != commonTaskcallMQ.getStopState()) { // //将消息从队列中剔除 // return; // } if (StringUtils.isNotEmpty(commonTaskcallMQ.getPreachform())) { //如何任务发送方式不为空 String[] split = commonTaskcallMQ.getPreachform().split(","); log.error("split的值为：{}", split); //定义一个集合，用与存没有执行的子任务ID List subIds = new ArrayList<>(); //临时存没有执行的子任务ID List lssubIds = new ArrayList<>(); //是否将全部患者者发送完 Boolean isSend = false; aa: for (String serviceFrom : split) { String descByCode = ServiceFromEnum.getDescByCode(Integer.valueOf(serviceFrom)); if (isSend == true) { break aa; } //通过任务ID拿到患者信息 ServiceSubtaskVO ivrTaskcall = new ServiceSubtaskVO(); ivrTaskcall.setTaskid(commonTaskcallMQ.getTaskid()); ivrTaskcall.setSendstate(1L); List selectServiceSubtaskList = ivrTaskcallMapper.selectServiceSubtaskList(ivrTaskcall); if (CollectionUtils.isEmpty(selectServiceSubtaskList)) { continue; } if (descByCode.equals("电话")) { for (ServiceSubtask serviceSubtask : selectServiceSubtaskList) { //先判断一下，subIds是否为空，如果不为空，只执行subIds里的患者 if (CollectionUtils.isNotEmpty(subIds)) { boolean contains = subIds.contains(serviceSubtask.getId()); //如果contains不为true,说明当前的患者已经发送成功，直接循环下一个人就行 if (!contains) continue; } try { ServiceTask ivrTask = ivrTaskMapper.selectServiceTaskByTaskid(serviceSubtask.getTaskid()); if (ivrTask.getSendState() != null && ivrTask.getSendState() == 3 || ivrTask.getSendState() != null && ivrTask.getSendState() == 4) { //如何任务被“暂停”或“终止” break; } //获取到value值最少的key String key = getKey(); if (commonTaskcallMQ.getSendType().equals("2")) { //说明是立即发送 ServiceSubtaskVO serviceSubtask1 = new ServiceSubtaskVO(); serviceSubtask1.setTaskid(commonTaskcallMQ.getTaskid()); log.error("缓存中serviceSubtask1的值为：{}", serviceSubtask1); List list = new ArrayList<>(); List selectServiceSubtaskList1 = ivrTaskcallMapper.selectServiceSubtaskList(serviceSubtask1); for (ServiceSubtask serviceSubtask2 : selectServiceSubtaskList1) { list.add(serviceSubtask2.getId().toString()); } log.error("缓存中cache-0的值为：{}", list); // redisCache.setCacheListLeft("cache-0", list); redisCache.setCacheListLeftAndDistinct("cache-0", list); } else { //非立即发送 ServiceSubtaskVO serviceSubtask1 = new ServiceSubtaskVO(); serviceSubtask1.setTaskid(commonTaskcallMQ.getTaskid()); List selectServiceSubtaskList1 = ivrTaskcallMapper.selectServiceSubtaskList(serviceSubtask1); List list = new ArrayList<>(); for (ServiceSubtask serviceSubtask2 : selectServiceSubtaskList1) { list.add(serviceSubtask2.getId().toString()); } // redisCache.setCacheListLeft(key, list); redisCache.setCacheListLeftAndDistinct(key, list); } } catch (Exception exception) { ServiceSubtaskRecord serviceSubtaskRecord = new ServiceSubtaskRecord(); serviceSubtaskRecord.setTaskid(serviceSubtask.getTaskid().toString()); serviceSubtaskRecord.setSubtaskId(serviceSubtask.getId()); serviceSubtaskRecord.setUuid(UUID.randomUUID().toString()); serviceSubtaskRecord.setTasktype(serviceSubtask.getType()); serviceSubtaskRecord.setPreachform("3"); serviceSubtaskRecord.setResult("fail"); serviceSubtaskRecord.setStartTime(System.currentTimeMillis()); serviceSubtaskRecord.setRemark("队列任务电话发送失败"); log.error("队列任务电话发送失败：{}", exception.getMessage()); lssubIds.add(serviceSubtask.getId()); serviceSubtaskRecordService.insertServiceSubtaskRecord(serviceSubtaskRecord); continue; } //在子任务表里记录一下 String uuid = UUID.randomUUID().toString(); serviceSubtask.setResult("success"); serviceSubtask.setRemark("队列任务电话发送成功"); serviceSubtask.setGuid(uuid); serviceSubtask.setSendstate(3L); serviceSubtask.setFinishtime(new Date()); 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 (CollectionUtils.isEmpty(lssubIds)) { //如果“临时子任务”为空，说明全发送完了 isSend = true; } //将子任务ID清空，将“临时子任务”数据 放到 “子任务” 中 subIds.clear(); subIds.addAll(lssubIds); lssubIds.clear(); } else if (descByCode.equals("多媒体")) { //多媒体 continue; } else if (descByCode.equals("纸质")) { //纸质 continue; } else if (descByCode.equals("短信")) { //短信 //对url中两个参数加密 RSAPublicKeyExample rsaPublicKeyExample = new RSAPublicKeyExample(); String taskId = rsaPublicKeyExample.encryptedData(ivrTask1.getTaskid().toString(), pub_key); for (ServiceSubtask serviceSubtask : selectServiceSubtaskList) { //先判断一下，subIds是否为空，如果不为空，只执行subIds里的患者 if (CollectionUtils.isNotEmpty(subIds)) { boolean contains = subIds.contains(serviceSubtask.getId()); //如果contains不为true,说明当前的患者已经发送成功，直接循环下一个人就行 if (!contains) continue; } try { 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"); if (type == 1) { //随访 ServiceOutPath serviceOutPath = new ServiceOutPath(); serviceOutPath.setParam1(taskId); serviceOutPath.setParam2(patid); serviceOutPath.setParam6(subId); serviceOutPath.setCreateTime(new Date()); iServiceOutPathService.insertServiceOutPath(serviceOutPath); // sendMagParam.setUrl(ip + ":" + req_path + "/followvisit/particty?param1=" + taskId + "¶m2=" + patid + "¶m5=false"); //转成16进制 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 + "/sf?p=" + format); if (serviceSubtask.getOrgid().equals("47255004333112711A1001")) { sendMagParam.setContent("【景宁畲族自治县人民医院】您好，邀请您填写出院宣教调查表，请点击" + sendMagParam.getUrl() + "查看。感谢您配合！"); } else if (serviceSubtask.getOrgid().equals("47255004333112711A1001")) { sendMagParam.setContent("【丽水中医院】您好，邀请您填写出院宣教调查表，请点击" + sendMagParam.getUrl() + "查看。感谢您配合！"); } else sendMagParam.setContent("【新华医院】您好，邀请您填写出院随访调查表，请点击" + sendMagParam.getUrl() + "填写。感谢您配合！"); } else if (type == 2) { //问券（问题） ServiceOutPath serviceOutPath = new ServiceOutPath(); serviceOutPath.setParam1(taskId); serviceOutPath.setParam2(patid); serviceOutPath.setParam6(subId); // serviceOutPath.setParam3(URLEncoder.encode(ivrTask1.getTaskName(), StandardCharsets.UTF_8.toString())); serviceOutPath.setParam3(ivrTask1.getTaskName()); 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.setUrl(ip + ":" + req_path + "/outsideChainwt?param1=" + taskId + "¶m2=" + patid + "¶m3=" + URLEncoder.encode(ivrTask1.getTaskName(), StandardCharsets.UTF_8.toString()) + "¶m5=false"); sendMagParam.setPhone(serviceSubtask.getPhone()); sendMagParam.setUrl(ip + ":" + req_path + "/wt?p=" + format); if (serviceSubtask.getOrgid().equals("47255004333112711A1001")) { sendMagParam.setContent("【景宁畲族自治县人民医院】您好，邀请您填写出院宣教调查表，请点击" + sendMagParam.getUrl() + "查看。感谢您配合！"); } else if (serviceSubtask.getOrgid().equals("47255004333112711A1001")) { sendMagParam.setContent("【丽水中医院】您好，邀请您填写出院宣教调查表，请点击" + sendMagParam.getUrl() + "查看。感谢您配合！"); } else sendMagParam.setContent("【新华医院】您好，邀请您填写出院调查表，请点击" + sendMagParam.getUrl() + "填写。感谢您配合！"); } else if (type == 3) { //宣教 ServiceOutPath serviceOutPath = new ServiceOutPath(); serviceOutPath.setParam1(taskId); serviceOutPath.setParam2(patid); serviceOutPath.setParam6(subId); // serviceOutPath.setParam3(URLEncoder.encode(ivrTask1.getTaskName(), StandardCharsets.UTF_8.toString())); serviceOutPath.setParam3(ivrTask1.getTaskName()); 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.setUrl(ip + ":" + req_path + "/outsideChainxj?param1=" + taskId + "¶m2=" + patid + "¶m3=" + URLEncoder.encode(ivrTask1.getTaskName(), StandardCharsets.UTF_8.toString()) + "¶m5=false"); sendMagParam.setPhone(serviceSubtask.getPhone()); sendMagParam.setUrl(ip + ":" + req_path + "/xj?p=" + format); if (serviceSubtask.getOrgid().equals("47255004333112711A1001")) { sendMagParam.setContent("【景宁畲族自治县人民医院】您好，邀请您填写出院宣教调查表，请点击" + sendMagParam.getUrl() + "查看。感谢您配合！"); } else if (serviceSubtask.getOrgid().equals("47255004333112711A1001")) { sendMagParam.setContent("【丽水中医院】您好，邀请您填写出院宣教调查表，请点击" + sendMagParam.getUrl() + "查看。感谢您配合！"); } else sendMagParam.setContent("【新华医院】您好，邀请您填写出院宣教调查表，请点击" + sendMagParam.getUrl() + "查看。感谢您配合！"); } //短信还需要模板 String s = null; if (visitHosp == 1) { //新华的短信发送方式 Map req = new HashMap<>(); req.put("phone", sendMagParam.getPhone()); req.put("content", sendMagParam.getContent()); s = HttpUtil.postJsonRequest(xhsmsPath, new Gson().toJson(req)); } else if (visitHosp == 2) { //丽水的短信发送方式 Map map = MsgLSEnum.getAddressByCode(serviceSubtask.getOrgid()); String token = LSHospTokenUtil.getToken(serviceSubtask.getOrgid()); log.error("-----------token的值为：{}", token); 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.error("---------mq丽水短信发送入参address：{}, sendMagParam:{}, orgid:{}-------", 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.error("---------丽水短信发送结果：{}-------", dxCode); ObjectMapper objectMapper = new ObjectMapper(); Map textParam = objectMapper.readValue(dxCode, Map.class); String code = textParam.get("Code").toString(); if (code.equals("0")) { s = "true"; } else { throw new BaseException(null); } } if (s.equals("true")) { //在子任务表里记录一下 log.error("serviceSubtask保存成功了吗？：{}", s); String uuid = UUID.randomUUID().toString(); serviceSubtask.setResult("success"); serviceSubtask.setRemark("短信发送成功"); serviceSubtask.setGuid(uuid); serviceSubtask.setSendstate(3L); serviceSubtask.setFinishtime(new Date()); 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("5"); serviceSubtaskRecord.setStartTime(System.currentTimeMillis()); serviceSubtaskRecord.setResult("success"); serviceSubtaskRecord.setRemark("短信发送成功"); serviceSubtaskRecordService.insertServiceSubtaskRecord(serviceSubtaskRecord); log.error("serviceSubtaskRecord保存成功了吗？：{}", serviceSubtaskRecord); } } catch (Exception e) { ServiceSubtaskRecord serviceSubtaskRecord = new ServiceSubtaskRecord(); serviceSubtaskRecord.setTaskid(serviceSubtask.getTaskid().toString()); serviceSubtaskRecord.setSubtaskId(serviceSubtask.getId()); serviceSubtaskRecord.setUuid(UUID.randomUUID().toString()); serviceSubtaskRecord.setTasktype(serviceSubtask.getType()); serviceSubtaskRecord.setPreachform("4"); serviceSubtaskRecord.setResult("fail"); serviceSubtaskRecord.setStartTime(System.currentTimeMillis()); serviceSubtaskRecord.setRemark("短信发送失败"); log.error("短信发送失败：{}", e.getMessage()); lssubIds.add(serviceSubtask.getId()); serviceSubtaskRecordService.insertServiceSubtaskRecord(serviceSubtaskRecord); continue; } } if (CollectionUtils.isEmpty(lssubIds)) { //如果“临时子任务”为空，说明全发送完了 isSend = true; } //将子任务ID清空，将“临时子任务”数据 放到 “子任务” 中 subIds.clear(); subIds.addAll(lssubIds); lssubIds.clear(); } else if (descByCode.equals("公众号")) { //公众号 RSAPublicKeyExample rsaPublicKeyExample = new RSAPublicKeyExample(); String taskId = rsaPublicKeyExample.encryptedData(ivrTask1.getTaskid().toString(), pub_key); for (ServiceSubtask serviceSubtask : selectServiceSubtaskList) { String patid = rsaPublicKeyExample.encryptedData(serviceSubtask.getPatid().toString(), pub_key); try { SendMagParam sendMagParam = new SendMagParam(); sendMagParam.setType("5"); String url = null; Boolean aBoolean = false; if (type == 1) { //随访 ServiceOutPath serviceOutPath = new ServiceOutPath(); serviceOutPath.setParam1(taskId); serviceOutPath.setParam2(patid); serviceOutPath.setCreateTime(new Date()); iServiceOutPathService.insertServiceOutPath(serviceOutPath); String format = String.format("%03X", serviceOutPath.getId()); serviceOutPath.setRadix(format); serviceOutPath.setUpdateTime(new Date()); iServiceOutPathService.updateServiceOutPath(serviceOutPath); url = ip + ":" + req_path + "/sf?p=" + format; } else if (type == 2) { //问券 ServiceOutPath serviceOutPath = new ServiceOutPath(); serviceOutPath.setParam1(taskId); serviceOutPath.setParam2(patid); // serviceOutPath.setParam3(URLEncoder.encode(ivrTask1.getTaskName(), StandardCharsets.UTF_8.toString())); serviceOutPath.setParam3(ivrTask1.getTaskName()); serviceOutPath.setCreateTime(new Date()); iServiceOutPathService.insertServiceOutPath(serviceOutPath); String format = String.format("%03X", serviceOutPath.getId()); serviceOutPath.setRadix(format); serviceOutPath.setUpdateTime(new Date()); iServiceOutPathService.updateServiceOutPath(serviceOutPath); url = ip + ":" + req_path + "/wt?p=" + format; } else if (type == 3) { //宣教 ServiceOutPath serviceOutPath = new ServiceOutPath(); serviceOutPath.setParam1(taskId); serviceOutPath.setParam2(patid); serviceOutPath.setParam3(ivrTask1.getTaskName()); serviceOutPath.setCreateTime(new Date()); iServiceOutPathService.insertServiceOutPath(serviceOutPath); String format = String.format("%03X", serviceOutPath.getId()); serviceOutPath.setRadix(format); serviceOutPath.setUpdateTime(new Date()); iServiceOutPathService.updateServiceOutPath(serviceOutPath); url = ip + ":" + req_path + "/xj?p=" + format; } PatArchive patArchive = patArchiveMapper.selectPatArchiveByPatid(serviceSubtask.getPatid()); if (StringUtils.isEmpty(patArchive.getPatidHis())) { ServiceSubtask ss = new ServiceSubtask(); ss.setResult("error"); ss.setRemark("公众号发送失败,his系统的患者id为空"); ss.setSendstate(5L); ss.setId(serviceSubtask.getId()); ss.setFinishtime(new Date()); serviceSubtaskMapper.updateServiceSubtask(ss); continue; } //获取微信公众号请求信息根据机构ID log.error("获取微信公众号请求信息根据机构ID：{}", patArchive.getOrgid()); 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()); ss.setFinishtime(new Date()); serviceSubtaskMapper.updateServiceSubtask(ss); continue; } String wxCode = getWXCode(serviceSubtask.getSfzh(), url, serviceSubtask.getTaskName(), serviceSubtask.getTaskName(), patArchive.getTelcode(), patArchive.getName(), patArchive.getPatidHis(), wxqqxx); log.error("wxCode的值为:{}", wxCode); Map map = JSONObject.parseObject(wxCode, Map.class); log.error("map的值为:{}", map); if (!map.isEmpty()) { serviceSubtask.setResult("success"); serviceSubtask.setSendstate(3L); log.error("aBoolean的值为:{}", aBoolean); if (map.get("succ").toString().equals("true")) { aBoolean = true; } if (aBoolean == false) { ServiceSubtaskRecord serviceSubtaskRecord = new ServiceSubtaskRecord(); serviceSubtaskRecord.setTaskid(serviceSubtask.getTaskid().toString()); serviceSubtaskRecord.setSubtaskId(serviceSubtask.getId()); serviceSubtaskRecord.setUuid(UUID.randomUUID().toString()); serviceSubtaskRecord.setTasktype(serviceSubtask.getType()); serviceSubtaskRecord.setPreachform("5"); serviceSubtaskRecord.setStartTime(System.currentTimeMillis()); serviceSubtaskRecord.setRemark(ObjectUtils.isNotEmpty(map.get("msg")) ? map.get("msg").toString() : null); lssubIds.add(serviceSubtask.getId()); serviceSubtaskRecordService.insertServiceSubtaskRecord(serviceSubtaskRecord); continue; } } } catch (Exception e) { ServiceSubtaskRecord serviceSubtaskRecord = new ServiceSubtaskRecord(); serviceSubtaskRecord.setTaskid(serviceSubtask.getTaskid().toString()); serviceSubtaskRecord.setSubtaskId(serviceSubtask.getId()); serviceSubtaskRecord.setUuid(UUID.randomUUID().toString()); serviceSubtaskRecord.setTasktype(serviceSubtask.getType()); serviceSubtaskRecord.setPreachform("5"); serviceSubtaskRecord.setResult("fail"); serviceSubtaskRecord.setStartTime(System.currentTimeMillis()); serviceSubtaskRecord.setRemark("公众号发送失败"); log.error("公众号发送失败：{}", e.getMessage()); lssubIds.add(serviceSubtask.getId()); serviceSubtaskRecordService.insertServiceSubtaskRecord(serviceSubtaskRecord); continue; } //在子任务表里记录一下 String uuid = UUID.randomUUID().toString(); serviceSubtask.setResult("success"); serviceSubtask.setRemark("公众号发送成功"); serviceSubtask.setGuid(uuid); serviceSubtask.setSendstate(3L); serviceSubtask.setFinishtime(new Date()); serviceSubtaskMapper.updateServiceSubtask(serviceSubtask); //任务发送记录 ServiceSubtaskRecord serviceSubtaskRecord = new ServiceSubtaskRecord(); serviceSubtaskRecord.setTaskid(serviceSubtask.getTaskid().toString()); serviceSubtaskRecord.setUuid(uuid); serviceSubtaskRecord.setTasktype(serviceSubtask.getType()); serviceSubtaskRecord.setPreachform("5"); serviceSubtaskRecord.setStartTime(System.currentTimeMillis()); serviceSubtaskRecord.setResult("success"); serviceSubtaskRecord.setRemark("公众号发送成功"); serviceSubtaskRecordService.insertServiceSubtaskRecord(serviceSubtaskRecord); } if (CollectionUtils.isEmpty(lssubIds)) { //如果“临时子任务”为空，说明全发送完了 isSend = true; } //将子任务ID清空，将“临时子任务”数据 放到 “子任务” 中 subIds.clear(); subIds.addAll(lssubIds); lssubIds.clear(); } //通知 MQ 消息已被接收,可以ACK(从队列中删除)了 （这个需要根据业务再去处理ACK） } if (CollectionUtils.isNotEmpty(subIds)) { //如果全部的发送方式都发完了，还有是未发送的,需要去subTask表中，记录一下，发送失败 for (Long id : subIds) { ServiceSubtask serviceSubtask = new ServiceSubtask(); serviceSubtask.setResult("error"); serviceSubtask.setRemark("发送失败"); serviceSubtask.setSendstate(5L); serviceSubtask.setId(id); serviceSubtask.setFinishtime(new Date()); serviceSubtaskMapper.updateServiceSubtask(serviceSubtask); } } } } // /** // * 机器人第一句话语音 // * concurrency = "50" 并发数为50 // */ // @RabbitListener(queues = "ob_queue", concurrency = "50") // public void obVisit(String content, Message message, Channel channel) throws IOException { // try { // IvrTaskcallPhoneMQ commonTaskcallMQ = null; // ObjectMapper mapper = new ObjectMapper(); // commonTaskcallMQ = mapper.readValue(content, IvrTaskcallPhoneMQ.class); // //判断患者是否已经接电话 // String str = redisCache.getCacheObject(commonTaskcallMQ.getUuid() + "state_id"); // System.out.println("-----------------" + str); // if (StringUtils.isNotEmpty(str) && str.equals("0")) { // //患者已经接听了电话 // new PhoneUtils().ttsPlayback(commonTaskcallMQ.getScript(), commonTaskcallMQ.getUuid()); // } else if (StringUtils.isNotEmpty(str) && str.equals("-10")) { // //这个说明,已经打了指定遍数还是没有人接，可以将消息从队列中移除了 // channel.basicAck(message.getMessageProperties().getDeliveryTag(), false); // return; // } else { // //进行队列尾部，进行下一次校验 //// channel.basicRecover(false); // channel.basicReject(message.getMessageProperties().getDeliveryTag(), true); // System.out.println("++++++++++++++++++++++" + str); // return; // } // //通知 MQ 消息已被接收,可以ACK(从队列中删除)了 （这个需要根据业务再去处理ACK） // channel.basicAck(message.getMessageProperties().getDeliveryTag(), false); // } catch (Exception e) { // log.error("============消费失败,尝试消息补发再次消费!=============="); // log.error(e.getMessage()); // channel.basicReject(message.getMessageProperties().getDeliveryTag(), true); // } // } 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 getWXCode(String idcard, String url, String taskName, String taskDesc, String phone, String patientname, String setPatientid, List wxqqxx) { XinHuaWXReq xinHuaWXReq = new XinHuaWXReq(); xinHuaWXReq.setIdcard(idcard); xinHuaWXReq.setUrl(url); xinHuaWXReq.setPatientid(setPatientid); xinHuaWXReq.setPatientname(patientname); xinHuaWXReq.setMobile(phone); xinHuaWXReq.setMedcardno(null); xinHuaWXReq.setTitlename(taskName); xinHuaWXReq.setContent(taskDesc); xinHuaWXReq.setAppid(wxqqxx.get(1)); log.error("-----微信公众号的出参为----：{}", xinHuaWXReq); // new Gson().toJson(xinHuaWXReq); GsonBuilder gb = new GsonBuilder(); gb.disableHtmlEscaping(); String body = gb.create().toJson(xinHuaWXReq); log.error("encode的入参为wxqqxx ：{}, body:{}", wxqqxx.get(2), body); String encode = encode(wxqqxx.get(2).concat(body)); log.error("--------encode的值为：{}-----", encode); Map headerMap = new HashMap<>(); headerMap.put("sign", encode); String result = HttpUtils.sendPostByHeader(wxqqxx.get(3), body, headerMap); log.error("--------result的值为：{}-----", result); JSONObject jsonObject = JSONObject.parseObject(result); String code = (String) jsonObject.toString(); return code; } 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.error("--------result的值为：{}-----", result); 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()); } }