~liusheng/smartor.git

			@@ -19,6 +19,7 @@
			import com.smartor.mapper.SvyTaskSingleMapper;
			import com.smartor.service.*;
			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;
			@@ -162,72 +163,116 @@
			if (StringUtils.isNotEmpty(commonTaskcallMQ.getPreachform())) {
			//如何任务发送方式不为空
			String[] split = commonTaskcallMQ.getPreachform().split(",");
			System.out.println("split的值为：" + 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));
			//这里可以考虑用策略模式优化一下，不然太难看了

			// //通过模板ID获取模板问题
			// IvrTaskTemplateVO ivrTaskTemplateVO = new IvrTaskTemplateVO();
			// ivrTaskTemplateVO.setId(Long.valueOf(commonTaskcallMQ.getTemplateid()));
			// IvrTaskTemplateVO ivrTaskTemplateVO1 = ivrTaskTemplateService.selectInfoByCondition(ivrTaskTemplateVO);
			if (isSend == true) {
			break aa;
			}

			//通过任务ID拿到患者信息
			ServiceSubtaskVO ivrTaskcall = new ServiceSubtaskVO();
			ivrTaskcall.setTaskid(commonTaskcallMQ.getTaskid());
			ivrTaskcall.setSendstate(1L);
			List<ServiceSubtask> selectServiceSubtaskList = ivrTaskcallMapper.selectServiceSubtaskList(ivrTaskcall);
			if (descByCode.equals("电话")) {
			for (ServiceSubtask serviceSubtask : selectServiceSubtaskList) {
			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")) {
			//说明是立即发送
			String value = redisCache.getCacheObject("cache-0");
			ServiceSubtaskVO serviceSubtask1 = new ServiceSubtaskVO();
			serviceSubtask1.setTaskid(commonTaskcallMQ.getTaskid());
			List<ServiceSubtask> selectServiceSubtaskList1 = ivrTaskcallMapper.selectServiceSubtaskList(serviceSubtask1);
			for (ServiceSubtask serviceSubtask2 : selectServiceSubtaskList1) {
			if (StringUtils.isEmpty(value)) {
			value = "," + serviceSubtask2.getId().toString() + ",";
			} else {
			if (!value.contains("," + serviceSubtask2.getId().toString()))
			value = value + "," + serviceSubtask2.getId().toString() + ",";
			}
			}
			redisCache.setCacheObject("cache-0", value);
			} else {
			//非立即发送
			String value = redisCache.getCacheObject(key);
			ServiceSubtaskVO serviceSubtask1 = new ServiceSubtaskVO();
			serviceSubtask1.setTaskid(commonTaskcallMQ.getTaskid());
			List<ServiceSubtask> selectServiceSubtaskList1 = ivrTaskcallMapper.selectServiceSubtaskList(serviceSubtask1);
			for (ServiceSubtask serviceSubtask2 : selectServiceSubtaskList1) {
			if (StringUtils.isEmpty(value)) {
			value = "," + serviceSubtask2.getId().toString() + ",";
			} else {
			value = value + "," + serviceSubtask2.getId().toString() + ",";
			}
			}
			redisCache.setCacheObject(key, value);
			//先判断一下，subIds是否为空，如果不为空，只执行subIds里的患者
			if (CollectionUtils.isNotEmpty(subIds)) {
			boolean contains = subIds.contains(serviceSubtask.getId());
			//如果contains不为true,说明当前的患者已经发送成功，直接循环下一个人就行
			if (!contains) continue;
			}

			//任务发送记录（这个代码应该写在phoneTask中，先写在这，后面再改）
			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")) {
			//说明是立即发送
			String value = redisCache.getCacheObject("cache-0");
			ServiceSubtaskVO serviceSubtask1 = new ServiceSubtaskVO();
			serviceSubtask1.setTaskid(commonTaskcallMQ.getTaskid());
			List<ServiceSubtask> selectServiceSubtaskList1 = ivrTaskcallMapper.selectServiceSubtaskList(serviceSubtask1);
			for (ServiceSubtask serviceSubtask2 : selectServiceSubtaskList1) {
			if (StringUtils.isEmpty(value)) {
			value = "," + serviceSubtask2.getId().toString() + ",";
			} else {
			if (!value.contains("," + serviceSubtask2.getId().toString()))
			value = value + "," + serviceSubtask2.getId().toString() + ",";
			}
			}
			redisCache.setCacheObject("cache-0", value);
			} else {
			//非立即发送
			String value = redisCache.getCacheObject(key);
			ServiceSubtaskVO serviceSubtask1 = new ServiceSubtaskVO();
			serviceSubtask1.setTaskid(commonTaskcallMQ.getTaskid());
			List<ServiceSubtask> selectServiceSubtaskList1 = ivrTaskcallMapper.selectServiceSubtaskList(serviceSubtask1);
			for (ServiceSubtask serviceSubtask2 : selectServiceSubtaskList1) {
			if (StringUtils.isEmpty(value)) {
			value = "," + serviceSubtask2.getId().toString() + ",";
			} else {
			value = value + "," + serviceSubtask2.getId().toString() + ",";
			}
			}
			redisCache.setCacheObject(key, value);
			}
			} 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(6L);
			serviceSubtask.setFinishtime(new Date());
			serviceSubtaskMapper.updateServiceSubtask(serviceSubtask);

			//任务发送记录
			ServiceSubtaskRecord serviceSubtaskRecord = new ServiceSubtaskRecord();
			serviceSubtaskRecord.setTaskid(serviceSubtask.getTaskid().toString());
			serviceSubtaskRecord.setUuid(UUID.randomUUID().toString());
			serviceSubtaskRecord.setUuid(uuid);
			serviceSubtaskRecord.setTasktype(serviceSubtask.getType());
			serviceSubtaskRecord.setPreachform("3");
			serviceSubtaskRecord.setStartTime(System.currentTimeMillis());
			serviceSubtaskRecord.setRemark("电话发送成功");
			serviceSubtaskRecordService.insertServiceSubtaskRecord(serviceSubtaskRecord);

			// //通过多线程的方式去打电话
			// executorService.submit(new PhoneTask(serviceSubtask, ivrTaskTemplateVO1, redisCache, sendService, phonePath, robotPhoneUtils));
			}
			if (CollectionUtils.isEmpty(lssubIds)) {
			//如果“临时子任务”为空，说明全发送完了
			isSend = true;
			}
			//将子任务ID清空，将“临时子任务”数据放到 “子任务” 中
			subIds.clear();
			subIds.addAll(lssubIds);
			lssubIds.clear();
			} else if (descByCode.equals("多媒体")) {
			//多媒体
			continue;
			@@ -242,6 +287,13 @@
			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);
			SendMagParam sendMagParam = new SendMagParam();
			@@ -255,27 +307,64 @@
			}
			Boolean aBoolean = sendService.sendMsg(sendMagParam);

			//任务发送记录
			if (!aBoolean) {
			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.setResult(aBoolean == true ? "success" : "error");
			serviceSubtaskMapper.updateServiceSubtask(serviceSubtask);
			serviceSubtaskRecord.setRemark("短信发送失败");
			log.error("短信发送失败：{}", e.getMessage());
			lssubIds.add(serviceSubtask.getId());
			serviceSubtaskRecordService.insertServiceSubtaskRecord(serviceSubtaskRecord);
			} catch (UnsupportedEncodingException e) {
			String guid = UUID.randomUUID().toString();
			log.error("短信任务，发送失败原因：{},{}", e.getMessage(), guid);
			serviceSubtask.setResult("error");
			serviceSubtask.setRemark("系统错误（任务）");
			serviceSubtask.setGuid(guid);
			serviceSubtask.setSendstate(4L);
			serviceSubtask.setFinishtime(new Date());
			serviceSubtaskMapper.insertServiceSubtask(serviceSubtask);
			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();
			} else if (descByCode.equals("公众号")) {
			//公众号
			RSAPublicKeyExample rsaPublicKeyExample = new RSAPublicKeyExample();
			@@ -310,39 +399,79 @@
			serviceSubtask.setResult("success");
			serviceSubtask.setSendstate(3L);
			if ((Boolean) map.get("succ") == false) {
			serviceSubtask.setResult("error");
			serviceSubtask.setRemark(map.get("msg").toString());
			serviceSubtask.setSendstate(5L);
			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.setResult("success");
			if ((Boolean) map.get("succ") == false) {
			serviceSubtaskRecord.setResult("error");
			}
			serviceSubtaskMapper.updateServiceSubtask(serviceSubtask);
			serviceSubtaskRecord.setRemark("公众号发送失败");
			log.error("公众号发送失败：{}", e.getMessage());
			lssubIds.add(serviceSubtask.getId());
			serviceSubtaskRecordService.insertServiceSubtaskRecord(serviceSubtaskRecord);
			} catch (Exception e) {
			String guid = UUID.randomUUID().toString();
			log.error("公众号任务，发送失败原因：{},{}", e.getMessage(), guid);
			serviceSubtask.setResult("error");
			serviceSubtask.setRemark("系统错误（任务）");
			serviceSubtask.setGuid(guid);
			serviceSubtask.setSendstate(5L);
			serviceSubtask.setFinishtime(new Date());
			serviceSubtaskMapper.updateServiceSubtask(serviceSubtask);
			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);
			}
			}
			}

			}

			// /**