smartor.git - Gitblit

			@@ -11,6 +11,7 @@
			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;
			@@ -472,11 +473,11 @@
			* 处理补偿任务
			*/
			public void compensateTask() {
			//获取到sendstate=3 并且 visit_time为今天的subtask
			//获取到sendstate=3 并且 visit_time为小于等于今天的subtask
			ServiceSubtaskVO serviceSubtaskVO = new ServiceSubtaskVO();
			serviceSubtaskVO.setSendstate(3L);
			serviceSubtaskVO.setVisitTime(new Date());
			List<ServiceSubtask> serviceSubtaskList = serviceSubtaskMapper.selectServiceSubtaskList(serviceSubtaskVO);
			List<ServiceSubtask> serviceSubtaskList = serviceSubtaskMapper.getCompensateServiceSubtaskList(serviceSubtaskVO);
			for (ServiceSubtask serviceSubtask : serviceSubtaskList) {
			//根据当前的执行方式，获取下一种执行方式
			ServiceSubtaskPreachform serviceSubtaskPreachform = new ServiceSubtaskPreachform();
			@@ -668,7 +669,9 @@
			} else if (heLibrary.getHetype().equals("2")) {
			//通知
			sendMagParam.setPhone(serviceSubtask.getPhone());
			sendMagParam.setContent(heLibrary.getPreachcontent());
			// 替换文本内容中的变量
			String content = getObject(serviceSubtask, heLibrary.getPreachcontent());
			sendMagParam.setContent(content);
			}

			}
			@@ -698,7 +701,7 @@
			log.info("-----------map的值为：{}", msgInfo);
			String token = LSHospTokenUtil.getToken(serviceSubtask.getOrgid(), msgInfo.get("tokenUrl"));
			if (ObjectUtils.isNotEmpty(msgInfo) && StringUtils.isEmpty(msgInfo.get("address"))) {
			setSuccessPreachForm(serviceSubtask, sendPreachform, "短信发送失败,该机构没有配置短信地址, 时间:" + now , "5");
			setSuccessPreachForm(serviceSubtask, sendPreachform, "短信发送失败,该机构没有配置短信地址, 时间:" + now, "5");
			return;
			}
			log.info("【sfHandlle】丽水短信发送，地址：{}，参数：{}，机构ID：{}", msgInfo.get("address"), sendMagParam, serviceSubtask.getOrgid());
			@@ -714,8 +717,13 @@
			log.info("sltd进来了吗？{} ,---sendMagParam.getContent()的参数为：{}", active, sendMagParam.getContent());
			//省立同德的短信发送方式
			String data = MessageSend.sendMsg(sendMagParam.getContent(), "6", sendMagParam.getPhone(), LocalDateTime.now().format(DateTimeFormatter.ofPattern("yyyyMMddHHmmss")));
			if (StringUtils.isNotEmpty(data) && data.contains("result=0")) {
			isSuccess = "true";
			if (StringUtils.isNotEmpty(data)) {
			ObjectMapper mapper = new ObjectMapper();
			JsonNode root = mapper.readTree(data);
			String status = root.get("result").get(0).get("status").asText();
			if (status.equals("00000")) {
			isSuccess = "true";
			}
			}
			} else if (active.equals("hzszlyy")) {//市一医院
			String content = sendMagParam.getContent().replace("【新华医院】", "");
			@@ -742,11 +750,11 @@
			serviceSubtask.setSendstate(3L);
			if (StringUtils.isNotEmpty(isSuccess) && isSuccess.equals("true")) {
			serviceSubtask.setResult("success");
			serviceSubtask.setRemark("短信发送成功");
			serviceSubtask.setRemark(serviceSubtask.getRemark() + "," + "短信发送成功");
			setSuccessPreachForm(serviceSubtask, sendPreachform, "短信发送成功", "2");
			} else {
			serviceSubtask.setResult("error");
			serviceSubtask.setRemark("短信发送失败" + now);
			serviceSubtask.setRemark(serviceSubtask.getRemark() + "," +"短信发送失败" + now);
			setSuccessPreachForm(serviceSubtask, sendPreachform, "短信发送失败" + now, "5");
			}
			} catch (Exception e) {
			@@ -770,6 +778,8 @@

			//获取微信公众号请求信息根据机构ID
			List<String> wxqqxx = WxGZHEnum.getDescByCode(patArchive.getOrgid());
			//市一医院不校验

			if (CollectionUtils.isEmpty(wxqqxx) \|\| wxqqxx.size() < 4) {
			setSuccessPreachForm(serviceSubtask, sendPreachform, "【公众号】该机构的公众号配置信息不全，无法通过公众号发送", "4");
			return;
			@@ -780,9 +790,26 @@
			return;
			}
			String wxCode = "";
			if (active.equals("hzszlyy")) {//市一医院
			String urlTemp = "http://192.200.54.14:5003/sfjk/SendMessage?sfzh=" + serviceSubtask.getSfzh() + "&title=您好，邀请您填写出院调查表，请点击填写。&content=您好，邀请您填写出院调查表，请点击填写。&phone=" + patArchive.getTelcode() + "&url=" + url + "&key=ff76f8904f5f32b5ee1739e8ea46e60g";
			HttpUtils.sendGet(urlTemp);
			//市一医院
			if (active.equals("hzszlyy")) {
			//处理中文乱码问题
			/**String title = URLEncoder.encode("您好，邀请您填写出院调查表，请点击填写。", StandardCharsets.UTF_8.toString());
			String content = URLEncoder.encode("您好，邀请您填写出院调查表，请点击填写。", StandardCharsets.UTF_8.toString());
			String encodedUrl = URLEncoder.encode(url, StandardCharsets.UTF_8.toString());
			String urlTemp = "http://192.200.54.14:5003/sfjk/SendMessage?sfzh=" + serviceSubtask.getSfzh() +
			"&title=" + title +
			"&content=" + content +
			"&phone=" + patArchive.getTelcode() +
			"&url=" + encodedUrl +
			"&key=ff76f8904f5f32b5ee1739e8ea46e60g";
			// HttpUtils.sendGet(urlTemp);
			String sendMsg = "";
			sendMsg = HttpUtils.sendPost(urlTemp);
			log.info(sendMsg); **/

			wxCode = smsUtils.sendChat(url, patArchive.getTelcode(), serviceSubtask.getSfzh());
			log.info(wxCode);

			} else {
			wxCode = getWXCode(serviceSubtask.getSfzh(), url, serviceSubtask.getTaskName(), serviceSubtask.getTaskDesc(), patArchive.getTelcode(), serviceSubtask.getSendname(), patArchive.getPatidHis(), wxqqxx);
			}
			@@ -1084,4 +1111,47 @@
			serviceSubtaskMapper.updateServiceSubtask(serviceSubtask);
			return true;
			}

			/**
			* 通配符变量替换
			*
			* @param serviceSubtask
			* @param scriptContent
			* @return
			*/
			private String getObject(ServiceSubtask serviceSubtask, String scriptContent) {
			Map<String, Map<String, String>> param = getParam(serviceSubtask.getTaskid());
			for (Map<String, String> map : param.values()) {
			for (String key : map.keySet()) {
			scriptContent = scriptContent.replace(key, StringUtils.isNotEmpty(map.get(key)) ? map.get(key) : "");
			}
			}
			if (StringUtils.isEmpty(scriptContent)) {
			return scriptContent;
			}
			scriptContent = scriptContent.replace("${name}", StringUtils.isNotEmpty(serviceSubtask.getSendname()) ? serviceSubtask.getSendname() : "");
			scriptContent = scriptContent.replace("${dzz}", StringUtils.isNotEmpty(serviceSubtask.getAddr()) ? serviceSubtask.getAddr() : "");
			scriptContent = scriptContent.replace("${phone}", StringUtils.isNotEmpty(serviceSubtask.getTelcode()) ? serviceSubtask.getTelcode() : "");

			return scriptContent;
			}

			/**
			* 获取任务里的通配符
			*
			* @param taskId
			* @return
			*/
			private Map<String, Map<String, String>> getParam(Long taskId) {
			ServiceTask serviceTask = serviceTaskMapper.selectServiceTaskByTaskid(taskId);
			ObjectMapper objectMapper = new ObjectMapper();
			Map<String, Map<String, String>> serviceTaskMap = null;
			try {
			serviceTaskMap = objectMapper.readValue(serviceTask.getTextParam(), Map.class);
			} catch (JsonProcessingException e) {
			e.printStackTrace();
			}
			return serviceTaskMap;
			}

			}