package com.ruoyi.web.component;
|
|
import com.alibaba.fastjson2.JSONObject;
|
import com.fasterxml.jackson.databind.ObjectMapper;
|
import com.google.gson.Gson;
|
import com.ruoyi.common.core.redis.RedisCache;
|
import com.ruoyi.common.enums.ServiceFromEnum;
|
import com.ruoyi.common.enums.WxGZHEnum;
|
import com.ruoyi.common.utils.HttpUtil;
|
import com.ruoyi.common.utils.RSAPublicKeyExample;
|
import com.ruoyi.common.utils.StringUtils;
|
import com.ruoyi.common.utils.http.HttpUtils;
|
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 lombok.extern.slf4j.Slf4j;
|
import org.apache.commons.collections4.CollectionUtils;
|
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.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.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;
|
|
// 创建固定大小的线程池
|
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")) {
|
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<Long> subIds = new ArrayList<>();
|
//临时存没有执行的子任务ID
|
List<Long> 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<ServiceSubtask> 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<String> list = new ArrayList<>();
|
List<ServiceSubtask> 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<ServiceSubtask> selectServiceSubtaskList1 = ivrTaskcallMapper.selectServiceSubtaskList(serviceSubtask1);
|
List<String> 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);
|
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);
|
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);
|
sendMagParam.setContent("【新华医院】您好，邀请您填写出院宣教调查表，请点击" + sendMagParam.getUrl() + "查看。感谢您配合！");
|
}
|
//短信还需要模板
|
Map<String, String> req = new HashMap<>();
|
req.put("phone", sendMagParam.getPhone());
|
req.put("content", sendMagParam.getContent());
|
String s = HttpUtil.postJsonRequest(xhsmsPath, new Gson().toJson(req));
|
if (s.equals("true")) {
|
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.setStartTime(System.currentTimeMillis());
|
serviceSubtaskRecord.setRemark("短信发送成功");
|
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("4");
|
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.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);
|
}
|
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");
|
// sendMagParam.setUrl(ip + ":" + req_path + "/outsideChain?param1=" + taskId + "¶m2=" + patid + "¶m3=" + ivrTask1.getTaskName() + "¶m5=false");
|
// log.info("链接完整路径：{}", ip + ":" + req_path + "/outsideChain?param1=" + taskId + "¶m2=" + patid + "¶m3=" + ivrTask1.getTaskName() + "¶m5=false");
|
// //这个模板ID先写死，后面做成可选
|
// sendMagParam.setTmpCode("oG3pJHPVWpE81DmZsua_2tKwgJ97r0qz37z56ns7NB4");
|
// Map map = new HashMap();
|
// map.put("first", ivrTask1.getTaskName());
|
// sendMagParam.setContent(JSON.toJSONString(map));
|
// sendMagParam.setOpenid(serviceSubtask.getOpenid());
|
// Boolean aBoolean = sendService.sendMsg(sendMagParam);
|
//
|
|
// if (type == 1) {
|
// url = ip + ":" + req_path + "/outsideChain?param1=" + taskId + "¶m2=" + patid + "¶m3=" + URLEncoder.encode(ivrTask1.getTaskName(), StandardCharsets.UTF_8.toString()) + "¶m5=false";
|
// } else if (type == 2) {
|
// url = ip + ":" + req_path + "/outsideChainwt?param1=" + taskId + "¶m2=" + patid + "¶m3=" + URLEncoder.encode(ivrTask1.getTaskName(), StandardCharsets.UTF_8.toString()) + "¶m5=false";
|
// } else if (type == 3) {
|
// url = ip + ":" + req_path + "/outsideChainxj?param1=" + taskId + "¶m2=" + patid + "¶m3=" + URLEncoder.encode(ivrTask1.getTaskName(), StandardCharsets.UTF_8.toString()) + "¶m5=false";
|
// }
|
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
|
List<String> 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.getTaskDesc(), patArchive.getTelcode(), patArchive.getName(), patArchive.getPatidHis(),wxqqxx);
|
Map<String, Object> map = JSONObject.parseObject(wxCode, Map.class);
|
if (!map.isEmpty()) {
|
serviceSubtask.setResult("success");
|
serviceSubtask.setSendstate(3L);
|
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(map.get("msg").toString());
|
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<String, String> 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<String, String> 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<String> 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);
|
String body = new Gson().toJson(xinHuaWXReq);
|
String encode = encode(wxqqxx.get(2).concat(body));
|
log.error("--------encode的值为：{}-----", encode);
|
Map<String, String> 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;
|
}
|
|
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());
|
}
|
}
|
