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();
			@@ -698,7 +699,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 +715,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 +748,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) {
			@@ -771,13 +777,10 @@
			//获取微信公众号请求信息根据机构ID
			List<String> wxqqxx = WxGZHEnum.getDescByCode(patArchive.getOrgid());
			//市一医院不校验
			if(active.equals("hzszlyy")){

			}else {
			if (CollectionUtils.isEmpty(wxqqxx) \|\| wxqqxx.size() < 4) {
			setSuccessPreachForm(serviceSubtask, sendPreachform, "【公众号】该机构的公众号配置信息不全，无法通过公众号发送", "4");
			return;
			}
			if (CollectionUtils.isEmpty(wxqqxx) \|\| wxqqxx.size() < 4) {
			setSuccessPreachForm(serviceSubtask, sendPreachform, "【公众号】该机构的公众号配置信息不全，无法通过公众号发送", "4");
			return;
			}

			if (StringUtils.isEmpty(patArchive.getPatidHis())) {
			@@ -789,22 +792,21 @@
			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); **/
			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); **/

			String sendMsg = "";
			sendMsg = smsUtils.sendChat(url, patArchive.getTelcode(), serviceSubtask.getSfzh());
			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);