hbwri/skjcmanager.git

			@@ -90,7 +90,6 @@
			private OutCallClient outCallClient;



			/**
			* 短信发送数据组装
			*
			@@ -136,6 +135,7 @@

			/**
			* 列名数据转换
			*
			* @param jsonArray 告警动态数据
			* @param columnsList 告警动态内容 key
			* @param smsRequestTemplate 消息发送对象
			@@ -291,11 +291,11 @@
			}
			// 返回数据
			return list;

			}

			/**
			* 拼接列数据设置告警人员信息
			*
			* @param jsonArray 告警动态数据
			* @param columnsList 告警动态内容 key
			* @param alarmRuleDetail 告警人角色ids
			@@ -346,6 +346,7 @@

			/**
			* 获取告警人员信息
			*
			* @param jsonArray 接口水库相关数据
			* @param columnsList 模板对应列key
			* @param alarmRuleDetail 告警人员角色ids
			@@ -407,6 +408,7 @@

			/**
			* 告警内容拼接处理
			*
			* @param jsonArray 数据
			* @param i 第几个
			* @param split key 值
			@@ -480,6 +482,7 @@

			/**
			* 保存告警记录信息
			*
			* @param list
			* @param alarmRule 告警规则
			* @param uuid 临时id
			@@ -518,6 +521,7 @@

			/**
			* 查询告警人员信息
			*
			* @param res_cd 水库 guid
			* @param roleIds 角色ids
			* @return
			@@ -554,11 +558,12 @@

			/**
			* 依次添加巡查责任人，技术责任人信息
			*
			* @param list
			* @param isPhone 是否保护电话
			*/
			public void addPatrolTechnologyInfo(List<String> list,Boolean isPhone) {
			// 查询巡查责任人姓名，技术责任人姓名信息
			// 根据水库id查询巡查责任人姓名，技术责任人姓名信息
			List<PersonVO> personVOList = attResManagePersonClient.getPersonListByResGuid(list.get(1),"4,5");
			if (personVOList.size()>0) {
			String xczrr = "-";
			@@ -585,6 +590,7 @@

			/**
			* 拼接市县水利部人员姓名及联系方式
			*
			* @param list
			*/
			public void addCityCountyBusinessPersonInfo(List<String> list) {
			@@ -605,6 +611,7 @@

			/**
			* 依次添加行政责任人,主管部门责任人,技术责任人,巡查责任人信息
			*
			* @param list
			* @param personTypes
			*/
			@@ -690,6 +697,7 @@

			/**
			* 保存站内信记录信息
			*
			* @param smsRequestTemplate
			* @param alarmRule
			* @return
			@@ -756,9 +764,9 @@
			}



			/**
			* 保存站内信记录（水库合并）
			*
			* @param smsRequestTemplate
			* @param alarmRule
			* @return
			@@ -777,7 +785,8 @@
			Temp temp = new Temp();
			temp.setPhone(list.get(1));
			temp.setReservoirCode(list.get(0));
			temp.setReservoirName(list.get(3));
			temp.setReservoirName(list.get(2));
			temp.setCdNm(list.get(3));
			temp.setAlarmRecordId(list.get(list.size()-1));
			// 放入临时集合
			tempList.add(temp);
			@@ -787,63 +796,39 @@
			Map<String, List<Temp>> listMap = tempList.stream().collect(Collectors.groupingBy(Temp::getPhone));


			listMap.forEach((s, temps) -> {
			StringBuilder builder = new StringBuilder();
			StringBuilder smsRecordBuilder = new StringBuilder();
			builder.append(s).append(",");
			// 站内信其实不用分组，与短信发送结构保持一致，
			List<List<Temp>> lists = Lists.partition(new ArrayList<>(temps), 7000);
			for (List<Temp> list : lists) {
			List<AlarmRecordDetailVO> alarmRecordDetailList = new ArrayList<>();
			// 设置站内信记录信息
			listMap.forEach((phone, temps) -> {
			MessageRecord messageRecord = new MessageRecord();

			// 遍历
			for (Temp temp : list) {
			builder.append(temp.getReservoirName()).append("，");
			smsRecordBuilder.append(temp.getReservoirName()).append("，");
			AlarmRecordDetailVO alarmRecordDetail = new AlarmRecordDetailVO();
			alarmRecordDetail.setReservoirNumber(temp.getReservoirCode());
			alarmRecordDetail.setAlarmRecordId(Long.parseLong(temp.getAlarmRecordId()));
			alarmRecordDetail.setAlarmMode("站内信");
			alarmRecordDetail.setPhone(temp.getPhone());
			alarmRecordDetail.setReservoirName(temp.getReservoirName());
			// 加入集合
			alarmRecordDetailList.add(alarmRecordDetail);
			}


			String row = builder.substring(0, builder.length() - 1);
			// 组装数据
			String[] titleArr = smsRequestTemplate.getTitle().split(",");
			String[][] dyns = new String[2][titleArr.length];
			dyns[0] = titleArr;
			dyns[1] = row.split(",");
			// 内容处理
			String str = smsTemplate.getContent().replaceAll("\\{.+?\\}", "%s");
			// 短信内容拼接（完成发送的结果信息）
			String substring = smsRecordBuilder.substring(0, smsRecordBuilder.length() - 1);
			// 格式转换
			String format = String.format(str, substring.split(","));


			messageRecord.setTheme(alarmRule.getRuleName());
			messageRecord.setSender(AuthUtil.getUserId().toString());
			messageRecord.setSource("智能告警");
			messageRecord.setStatus(0);
			messageRecord.setRecipient(phone);

			// 删除最后一个告警记录id
			list.remove(list.size() - 1);
			// 删除 0 水库编码
			list.remove(0);

			// 设置手机号
			// messageRecord.setRecipient(list.get(0));
			messageRecord.setContent(format);
			// 放入集合
			StringBuilder builder = new StringBuilder();
			Map<String, List<Temp>> resCollect = temps.stream().collect(Collectors.groupingBy(Temp::getReservoirCode));
			List<String> contentList = new ArrayList<>();
			resCollect.forEach((resCode, contentTemp) -> {
			List<String> cdNmList = new ArrayList<>();
			//凤凰水库（测点12170062992），大新众水库（测点12170063012、测点12170062998）
			//因为只能按编号分组，名称会有重复，所以拿第一条数据的名称就行
			String resName = contentTemp.get(0).getReservoirName();
			contentTemp.forEach(info -> {
			//把测站加进测站集合里
			cdNmList.add("测点" + info.getCdNm());
			});
			String cdNameListStr = String.join("、", cdNmList);
			contentList.add(StringUtil.format("{}({})", resName, cdNameListStr));
			});
			String contentListStr = String.join("，", contentList);
			//需要填充的数据
			List<String> fillList = new ArrayList<>();
			fillList.add(contentListStr);
			String sendContent = contentConvert(smsTemplate.getContent(), fillList);
			messageRecord.setContent(sendContent);

			messageRecordList.add(messageRecord);

			}
			});

			// 保存告警记录详情信息
			@@ -856,9 +841,84 @@
			}


			public Map<String, Object> saveInStationInfoMergeNoCd(SmsRequestTemplate smsRequestTemplate, AlarmRule alarmRule) {

			// 取出数据
			SMSSendRequest request = new SMSSendRequest();
			SmsTemplate smsTemplate = smsRequestTemplate.getSmsTemplate();
			request.setTemplateId(smsTemplate.getTemplateId());
			List<List<String>> templateContent = smsRequestTemplate.getTemplateContent();

			List<MessageRecord> messageRecordList = new ArrayList<>();
			List<Temp> tempList = new ArrayList<>();
			// 合并数据
			for (List<String> list : templateContent) {
			Temp temp = new Temp();
			temp.setPhone(list.get(1));
			temp.setReservoirCode(list.get(0));
			temp.setReservoirName(list.get(2));
			temp.setAlarmRecordId(list.get(list.size() - 1));
			// 放入临时集合
			tempList.add(temp);
			}

			// 按手机号分组
			Map<String, List<Temp>> listMap = tempList.stream().collect(Collectors.groupingBy(Temp::getPhone));


			listMap.forEach((phone, temps) -> {
			MessageRecord messageRecord = new MessageRecord();

			messageRecord.setTheme(alarmRule.getRuleName());
			messageRecord.setSender(AuthUtil.getUserId().toString());
			messageRecord.setSource("智能告警");
			messageRecord.setStatus(0);
			messageRecord.setRecipient(phone);
			List<String> contentList = new ArrayList<>();
			//因为只能按编号分组，名称会有重复，所以拿第一条数据的名称就行
			temps.forEach(info -> {
			//把水库加进集合
			contentList.add(info.getReservoirName());
			});
			String contentListStr = String.join("，", contentList);
			//需要填充的数据
			List<String> fillList = new ArrayList<>();
			fillList.add(contentListStr);
			String sendContent = contentConvert(smsTemplate.getContent(), fillList);
			messageRecord.setContent(sendContent);
			messageRecordList.add(messageRecord);
			});

			// 保存告警记录详情信息
			if (smsRequestTemplate.getIsSendStation()) {
			saveMessageRecord(messageRecordList);
			}
			Map<String, Object> map = new HashMap<>(2);
			// 返回
			return map;

			}


			/**
			* 把填充内容补充到模板中
			*
			* @param templateString 模板
			* @param strList 填充内容集合
			* @return
			*/
			private String contentConvert(String templateString, List<String> strList) {

			//把{}转换成%s
			String formatTemplate = templateString.replaceAll("\\{.+?\\}", "%s");
			String content = String.format(formatTemplate, strList.toArray());
			return content;
			}


			/**
			* 保存站内信记录信息
			*
			* @param messageRecordList
			*/
			public void saveMessageRecord(List<MessageRecord> messageRecordList) {
			@@ -893,6 +953,7 @@

			/**
			* 新增测试信息
			*
			* @param messageRecordList
			*/
			private void addSendMsgTest(List<MessageRecord> messageRecordList) {
			@@ -909,6 +970,7 @@

			/**
			* 创建告警外呼任务
			*
			* @param smsRequestTemplate
			* @return
			*/
			@@ -939,4 +1001,6 @@
			// 创建外呼任务
			return outCallClient.createOutCallTaskByAlarm(map);
			}


			}