~liusheng/smartor.git

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

			import com.alibaba.fastjson2.JSON;
			import com.fasterxml.jackson.core.JsonProcessingException;
			import com.fasterxml.jackson.databind.ObjectMapper;
			import com.rabbitmq.client.Channel;
			import com.ruoyi.common.core.redis.RedisCache;
			import com.ruoyi.common.enums.ServiceFromEnum;
			import com.ruoyi.common.utils.RSAPublicKeyExample;
			import com.ruoyi.common.utils.StringUtils;
			import com.ruoyi.web.task.PhoneTask;
			import com.smartor.common.SendService;
			@@ -27,7 +29,9 @@
			import org.springframework.stereotype.Component;

			import java.io.IOException;
			import java.util.HashMap;
			import java.util.List;
			import java.util.Map;
			import java.util.concurrent.ExecutorService;
			import java.util.concurrent.Executors;

			@@ -37,6 +41,12 @@

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

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

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

			private static IIvrTaskTemplateService ivrTaskTemplateService;

			@@ -51,6 +61,7 @@
			private static RabbitMqCallPhoneConfig rabbitMqCallPhoneConfig;

			private static RobotPhoneUtils robotPhoneUtils;


			// 创建固定大小的线程池
			private static final ExecutorService executorService = Executors.newFixedThreadPool(10);
			@@ -96,7 +107,7 @@
			*/
			@RabbitListener(queues = "task_queue", concurrency = "50")
			public void phoneVisit(String content, Message message, Channel channel) throws IOException {

			log.error("消息进来了--------------");
			try {
			IvrTaskcallMQ ivrTaskcallMQ = null;

			@@ -118,13 +129,13 @@
			return;
			}

			if (StringUtils.isNotEmpty(ivrTaskcallMQ.getServicefrom())) {
			if (StringUtils.isNotEmpty(ivrTaskcallMQ.getPreachform())) {
			//如何任务发送方式不为空
			String[] split = ivrTaskcallMQ.getServicefrom().split(",");
			String[] split = ivrTaskcallMQ.getPreachform().split(",");
			for (String serviceFrom : split) {
			String descByCode = ServiceFromEnum.getDescByCode(Integer.valueOf(serviceFrom));
			//这里可以考虑用策略模式优化一下，不然太难看了
			if (descByCode.equals("电话")) {

			//通过模板ID获取模板问题
			IvrTaskTemplateVO ivrTaskTemplateVO = new IvrTaskTemplateVO();
			ivrTaskTemplateVO.setID(Long.valueOf(ivrTaskcallMQ.getTemplateid()));
			@@ -134,18 +145,52 @@
			IvrTaskSingle ivrTaskcall = new IvrTaskSingle();
			ivrTaskcall.setTaskid(ivrTaskcallMQ.getTaskid());
			List<IvrTaskSingle> ivrTaskcalls = ivrTaskcallMapper.selectIvrTaskcallList(ivrTaskcall);

			if (descByCode.equals("电话")) {
			for (IvrTaskSingle ivrTaskcall1 : ivrTaskcalls) {
			IvrTask ivrTask = ivrTaskMapper.selectIvrTaskByTaskid(ivrTaskcall1.getTaskid());
			if (StringUtils.isNotEmpty(ivrTask.getSendState()) && ivrTask.getSendState().equals(3) \|\| StringUtils.isNotEmpty(ivrTask.getSendState()) && ivrTask.getSendState().equals(4)) {
			if (ivrTask.getSendState() != null && ivrTask.getSendState() == 3 \|\| ivrTask.getSendState() != null && ivrTask.getSendState() == 4) {
			//如何任务被“暂停”或“终止”
			break;
			}
			//通过多线程的方式去打电话
			executorService.submit(new PhoneTask(ivrTaskcall1, ivrTaskTemplateVO1, redisCache, rabbitMqCallPhoneConfig, message, sendService, phonePath, robotPhoneUtils));
			}
			} else if (descByCode.equals("公众号")) {
			} else if (descByCode.equals("多媒体")) {
			//多媒体
			} else if (descByCode.equals("纸质")) {
			//纸质
			} else if (descByCode.equals("短信")) {
			//短信
			// http://localhost:8099/followvisit/particty?param1=3&param2=348
			//对url中两个参数加密
			RSAPublicKeyExample rsaPublicKeyExample = new RSAPublicKeyExample();
			String taskId = rsaPublicKeyExample.encryptedData(ivrTask1.getTaskid().toString(), pub_key);


			for (IvrTaskSingle ivrTaskSingle : ivrTaskcalls) {
			String patid = rsaPublicKeyExample.encryptedData(ivrTaskSingle.getPatid().toString(), pub_key);
			SendMagParam sendMagParam = new SendMagParam();
			sendMagParam.setType("4");
			sendMagParam.setUrl("192.168.2.10:8099/followvisit/particty?param1=" + taskId + "&param2=" + patid);
			sendService.sendMsg(sendMagParam);
			}
			} else if (descByCode.equals("公众号")) {
			//公众号
			RSAPublicKeyExample rsaPublicKeyExample = new RSAPublicKeyExample();
			String taskId = rsaPublicKeyExample.encryptedData(ivrTask1.getTaskid().toString(), pub_key);
			for (IvrTaskSingle ivrTaskSingle : ivrTaskcalls) {
			String patid = rsaPublicKeyExample.encryptedData(ivrTaskSingle.getPatid().toString(), pub_key);
			SendMagParam sendMagParam = new SendMagParam();
			sendMagParam.setType("5");
			sendMagParam.setUrl(req_path + "/outsideChain?param1=" + taskId + "&param2=" + patid + "&param3=" + ivrTask1.getTaskName());
			log.info("链接完整路径：{}", req_path + "/outsideChain?param1=" + taskId + "&param2=" + patid + "&param3=" + ivrTask1.getTaskName());
			//这个模板ID先写死，后面做成可选
			sendMagParam.setTmpCode("oG3pJHPVWpE81DmZsua_2tKwgJ97r0qz37z56ns7NB4");
			Map map = new HashMap();
			map.put("first", ivrTask1.getTaskName());
			sendMagParam.setContent(JSON.toJSONString(map));
			sendService.sendMsg(sendMagParam);
			}
			}
			//通知 MQ 消息已被接收,可以ACK(从队列中删除)了（这个需要根据业务再去处理ACK）
			channel.basicAck(message.getMessageProperties().getDeliveryTag(), false);