smartor.git - Gitblit

			@@ -1,18 +1,18 @@
			package com.ruoyi.web.component;

			import com.alibaba.fastjson.JSON;
			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.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.RSAPublicKeyExample;
			import com.ruoyi.common.utils.StringUtils;
			import com.ruoyi.common.utils.http.HttpUtils;
			import com.smartor.common.SendService;
			import com.smartor.config.RobotPhoneUtils;
			import com.smartor.domain.*;
			import com.smartor.mapper.PatArchiveMapper;
			import com.smartor.mapper.ServiceSubtaskMapper;
			@@ -20,7 +20,7 @@
			import com.smartor.service.IBaseSmsaccountService;
			import com.smartor.service.IServiceOutPathService;
			import com.smartor.service.IServiceSubtaskRecordService;
			import com.smartor.service.ISvyTaskTemplateService;
			import com.sun.org.apache.bcel.internal.generic.NEW;
			import lombok.extern.slf4j.Slf4j;
			import org.apache.commons.collections4.CollectionUtils;
			import org.springframework.beans.factory.annotation.Autowired;
			@@ -30,15 +30,13 @@
			import org.springframework.data.redis.listener.RedisMessageListenerContainer;
			import org.springframework.stereotype.Component;

			import java.net.URLEncoder;
			import java.security.MessageDigest;
			import java.time.LocalDateTime;
			import java.time.format.DateTimeFormatter;
			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
			@@ -86,6 +84,9 @@

			@Value("${xhsmsPath}")
			private String xhsmsPath;

			@Value("${visitHosp}")
			private Integer visitHosp;

			// 创建固定大小的线程池
			private static final ExecutorService executorService = Executors.newFixedThreadPool(10);
			@@ -349,10 +350,37 @@
			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));
			String s = null;
			if (visitHosp == 1) {
			//新华的短信发送方式
			Map<String, String> 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) {
			//丽水的短信发送方式
			String address = MsgLSEnum.getAddressByCode(serviceSubtask.getOrgid());
			if (StringUtils.isEmpty(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;
			}
			String dxCode = getDXCode(address, sendMagParam.getPhone(), sendMagParam.getContent(), "", "", MsgLSEnum.getHeaderByCode(serviceSubtask.getOrgid()));
			log.error("---------丽水短信发送结果：{}-------", dxCode);
			ObjectMapper objectMapper = new ObjectMapper();
			Map<String, Object> 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")) {
			ServiceSubtaskRecord serviceSubtaskRecord = new ServiceSubtaskRecord();
			serviceSubtaskRecord.setTaskid(serviceSubtask.getTaskid().toString());
			@@ -506,7 +534,7 @@
			}


			String wxCode = getWXCode(serviceSubtask.getSfzh(), url, serviceSubtask.getTaskName(), serviceSubtask.getTaskDesc(), patArchive.getTelcode(), patArchive.getName(), patArchive.getPatidHis(),wxqqxx);
			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");
			@@ -650,7 +678,7 @@
			return key;
			}

			private String getWXCode(String idcard, String url, String taskName, String taskDesc, String phone, String patientname, String setPatientid,List<String> wxqqxx) {
			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);
			@@ -675,6 +703,32 @@
			return code;
			}


			private String getDXCode(String address, String ShouJiHM, String FaSongNR, String FaSongRID, String FaSongRXM, Map<String, Object> headerMap) {
			Map<String, Object> map = new LinkedHashMap<>();

			Map<String, Object> YeWuXX = new LinkedHashMap<>();
			Map<String, Object> 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("DuanXinXX", DuanXinXX);

			String body = new Gson().toJson(map);

			String result = HttpUtils.sendPost(address, body);
			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 = "";