| | |
| | | import cn.gistack.alerts.sms.entity.SmsRecord; |
| | | import cn.gistack.alerts.sms.entity.SmsResult; |
| | | import cn.gistack.alerts.sms.entity.SmsTemplate; |
| | | import cn.gistack.alerts.sms.excel.SendRainSmsExcel; |
| | | import cn.gistack.alerts.sms.service.ISmsRecordService; |
| | | import cn.gistack.alerts.sms.service.ISmsResultService; |
| | | import cn.gistack.alerts.sms.service.ISmsTemplateService; |
| | |
| | | import cn.gistack.common.cache.CacheNames; |
| | | import cn.gistack.sm.intelligentCall.entity.CallNotFillRecord; |
| | | import cn.gistack.sm.intelligentCall.feign.OutCallClient; |
| | | import cn.gistack.sm.sjztmd.feign.IAttResManagePersonClient; |
| | | import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper; |
| | | import com.baomidou.mybatisplus.core.toolkit.IdWorker; |
| | | import org.jetbrains.annotations.NotNull; |
| | |
| | | |
| | | @Autowired |
| | | private OutCallClient outCallClient; |
| | | |
| | | @Autowired |
| | | private IAttResManagePersonClient attResManagePersonClient; |
| | | |
| | | /** |
| | | * 发送 xx 变量模板短信 |
| | |
| | | // 获取任务id |
| | | String redisByTaskId = bladeRedis.get(MinConstant.is_send_prefix + map.get("callId").toString()); |
| | | // 如果为null,并且不能匹配,加入发送短信集合 |
| | | if (redisByTaskId == null || !StringUtil.equalsIgnoreCase(redisByTaskId, taskId)) { |
| | | if (redisByTaskId == null) { |
| | | newList.add(map); |
| | | } |
| | | } |
| | |
| | | // 没有,已过期 |
| | | return map; |
| | | } |
| | | |
| | | /** |
| | | * 导入表格发送降雨短信 |
| | | * @param list 导入的excel 集合数据 |
| | | * @param startTime 短信内容填报起始时间 |
| | | * @param endTime 短信内容填报截止时间 |
| | | * @return |
| | | */ |
| | | @Override |
| | | public Object importSendRainSms(List<SendRainSmsExcel> list,String startTime,String endTime) { |
| | | // 获取水库个数 |
| | | Integer size = list.size(); |
| | | // 通过水库代码获取巡查责任人及技术责任人手机号 |
| | | // Set<String> personList = attResManagePersonClient.getPersonListByWaterCodeList(list); |
| | | |
| | | |
| | | // 返回 |
| | | return null; |
| | | } |
| | | } |