smartor.git - Gitblit

			@@ -24,6 +24,7 @@
			import com.ruoyi.system.service.ISysDeptService;
			import com.smartor.common.LSHospTokenUtil;
			import com.smartor.common.MtSubmitSmUtil;
			import com.smartor.common.QwenLLMUtil;
			import com.smartor.domain.*;
			import com.smartor.domain.entity.ServiceSubtaskEntity;
			import com.smartor.mapper.*;
			@@ -34,6 +35,7 @@
			import org.springframework.beans.factory.annotation.Autowired;
			import org.springframework.beans.factory.annotation.Value;
			import org.springframework.stereotype.Component;
			import org.springframework.web.bind.annotation.RequestParam;

			import java.io.IOException;
			import java.net.URLEncoder;
			@@ -685,6 +687,86 @@
			}

			/**
			* 长期任务发送
			*/
			public void longTaskSendTest(Long subId) {
			//获取任务信息
			ServiceTask st = new ServiceTask();
			st.setDelFlag("0");
			st.setLongTask(1);
			List<ServiceTask> serviceTasks = serviceTaskMapper.selectServiceTaskList(st);
			log.info("【longTaskSend】获取到{}个长期任务", serviceTasks.size());
			for (ServiceTask serviceTask : serviceTasks) {
			CommonTaskcallMQ commonTaskcallMQ = new CommonTaskcallMQ();
			commonTaskcallMQ.setTaskid(serviceTask.getTaskid());
			commonTaskcallMQ.setPreachform(serviceTask.getPreachform());
			commonTaskcallMQ.setSendType("2");

			//通过任务ID拿到患者信息,并且随访时间得是今天之前的
			ServiceSubtaskEntity serviceSubtaskVO = new ServiceSubtaskEntity();
			serviceSubtaskVO.setTaskid(commonTaskcallMQ.getTaskid());
			serviceSubtaskVO.setSendstate(2L);
			serviceSubtaskVO.setIsVisitAgain(1);
			serviceSubtaskVO.setSubId(subId);
			serviceSubtaskVO.setVisitTime(new Date());
			List<ServiceSubtask> selectServiceSubtaskList = serviceSubtaskMapper.queryServiceSubtaskList(serviceSubtaskVO);
			for (ServiceSubtask serviceSubtask : selectServiceSubtaskList) {
			sfHandlle(serviceSubtask);
			}
			}
			}

			/**
			* 处理补偿任务
			*/
			public void compensateTaskTest(Long subId) {
			//获取到sendstate=3 并且 visit_time为小于等于今天的subtask
			ServiceSubtaskEntity serviceSubtaskVO = new ServiceSubtaskEntity();
			serviceSubtaskVO.setSendstate(3L);
			serviceSubtaskVO.setSubId(subId);
			serviceSubtaskVO.setVisitTime(new Date());
			List<ServiceSubtask> serviceSubtaskList = serviceSubtaskMapper.getCompensateServiceSubtaskList(serviceSubtaskVO);
			for (ServiceSubtask serviceSubtask : serviceSubtaskList) {
			//根据当前的执行方式，获取下一种执行方式
			ServiceSubtaskPreachform serviceSubtaskPreachform = new ServiceSubtaskPreachform();
			serviceSubtaskPreachform.setTaskid(serviceSubtask.getTaskid());
			serviceSubtaskPreachform.setSubid(serviceSubtask.getId());
			serviceSubtaskPreachform.setOrgid(serviceSubtask.getOrgid());
			List<ServiceSubtaskPreachform> serviceSubtaskPreachforms = serviceSubtaskPreachformMapper.selectServiceSubtaskPreachformList(serviceSubtaskPreachform);
			//获取当前执行方式的序号
			Optional<Long> currentSort = serviceSubtaskPreachforms.stream().filter(item -> serviceSubtask.getCurrentPreachform().equals(item.getPreachform())).map(ServiceSubtaskPreachform::getSort).findFirst();
			Optional<Long> id = serviceSubtaskPreachforms.stream().filter(item -> serviceSubtask.getCurrentPreachform().equals(item.getPreachform())).map(ServiceSubtaskPreachform::getId).findFirst();
			if (currentSort.isPresent()) {
			//1先检查一下，是不是有执行状态是完成的（怕之前已经有完的了，没有将servuce_subtask的状态改成功，这里再检查一下）
			boolean finishState = serviceSubtaskPreachforms.stream().allMatch(item -> item.getSendstate().equals("9"));
			if (finishState) {
			serviceSubtask.setSendstate(6L);
			serviceSubtaskMapper.updateServiceSubtask(serviceSubtask);
			continue;
			}

			//2判断一下，当前的sort是不是等于需要执行的总个数，如果等于的话，说明是最后一个，直接将servuce_subtask的状态改成5，执行失败就行了
			Long cs = currentSort.get();
			if (cs.equals(serviceSubtaskPreachforms.size())) {
			serviceSubtask.setSendstate(7L);
			serviceSubtask.setRemark("处理补偿任务,当前处理最后补偿，全部执行失败（超时）");

			serviceSubtaskMapper.updateServiceSubtask(serviceSubtask);
			//修改发送方式的状态为失败
			serviceSubtaskPreachform.setSendstate("5");
			serviceSubtaskPreachform.setId(id.get());

			serviceSubtaskPreachformMapper.updateServiceSubtaskPreachform(serviceSubtaskPreachform);
			continue;
			}

			//3.不是最后一个，获取到下一个执行方式(因为都是在今天执行，那就直接发出去就完了)
			sfHandlle(serviceSubtask);
			}
			}
			}

			/**
			* 设置失败任务默认值,并将失败任务重新置为成功
			* <p>
			* *@param failDay (失败天数：距离当前日期失败天数)
			@@ -828,6 +910,7 @@
			serviceOutPath.setParam3(ivrTask1.getTaskName());
			serviceOutPath.setParam6(subId);
			serviceOutPath.setCreateTime(new Date());
			serviceOutPath.setOrgid(serviceSubtask.getOrgid());
			iServiceOutPathService.insertServiceOutPath(serviceOutPath);
			String format = String.format("%03X", serviceOutPath.getId());
			serviceOutPath.setRadix(format);
			@@ -971,6 +1054,7 @@
			//任务发送记录
			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");
			@@ -1028,8 +1112,6 @@
			if (active.equals("hzszlyy")) {
			//处理中文乱码问题
			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);
			}
			@@ -1346,9 +1428,7 @@
			//serviceSubtask.setRemark("setSuccessPreachForm方法，当前的preachform已经是最后一个了，全部执行失败");
			serviceSubtaskMapper.updateServiceSubtask(serviceSubtask);
			return true;

			}

			}
			} else {
			log.error("【定时任务中该患者没有查询到属于他的发送方式，subid：{},prechform:{},orgid:{}】", serviceSubtask.getId(), preachform, serviceSubtask.getOrgid());
			@@ -1413,4 +1493,8 @@
			return serviceTaskMap;
			}

			public int qwenLLMTest(String questionText, String voiceText,String value,String regexText) {
			int result = QwenLLMUtil.matchRegex(questionText, voiceText, value, regexText);
			return result;
			}
			}