From f4f5d8b8226af1034a3857318a2ce5ffb1e91676 Mon Sep 17 00:00:00 2001 From: lyf66 Date: Fri, 8 Aug 2025 13:59:05 +0800 Subject: [PATCH] =?UTF-8?q?=E6=B8=85=E7=90=86=E5=BA=9F=E5=BC=83=E4=BB=A3?= =?UTF-8?q?=E7=A0=81?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../whdc/controller/AutoCallController.java | 81 +-- .../com/whdc/mapper/AutoCallConfigMapper.java | 11 + .../com/whdc/mapper/WarnCallMapMapper.java | 57 -- .../com/whdc/model/entity/WarnCallMap.java | 73 --- .../com/whdc/service/AutoCallTaskService.java | 522 ------------------ 5 files changed, 28 insertions(+), 716 deletions(-) delete mode 100644 src/main/java/com/whdc/mapper/WarnCallMapMapper.java delete mode 100644 src/main/java/com/whdc/model/entity/WarnCallMap.java delete mode 100644 src/main/java/com/whdc/service/AutoCallTaskService.java diff --git a/src/main/java/com/whdc/controller/AutoCallController.java b/src/main/java/com/whdc/controller/AutoCallController.java index a8a330c..d760f03 100644 --- a/src/main/java/com/whdc/controller/AutoCallController.java +++ b/src/main/java/com/whdc/controller/AutoCallController.java @@ -1,20 +1,15 @@ package com.whdc.controller; -import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper; import com.baomidou.mybatisplus.extension.plugins.pagination.Page; -import com.whdc.mapper.WarningResponderMapper; +import com.whdc.mapper.AutoCallConfigMapper; import com.whdc.model.dto.AutoCallDto; -import com.whdc.model.dto.CallPutDto; import com.whdc.model.dto.FindPageDto; import com.whdc.model.entity.AutoCallPerson; import com.whdc.model.entity.AutoCallTask; -import com.whdc.model.entity.WarnCallMap; -import com.whdc.model.entity.WarningResponder; import com.whdc.service.AutoCallApiService; -import com.whdc.service.AutoCallTaskService; import com.whdc.service.AutoCallTaskService2; +import com.whdc.utils.AICCHelper; import com.whdc.utils.ResultJson; -import com.whdc.utils.SmsHelper; import org.apache.poi.util.IOUtils; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.web.bind.annotation.*; @@ -25,8 +20,6 @@ import java.io.ByteArrayInputStream; import java.io.IOException; import java.net.URLEncoder; import java.text.ParseException; -import java.util.ArrayList; -import java.util.Collections; import java.util.List; /** @@ -39,15 +32,11 @@ public class AutoCallController { @Autowired private AutoCallApiService autoCallApiService; @Autowired - private AutoCallTaskService autoCallTaskService; - @Autowired private AutoCallTaskService2 autoCallTaskService2; - - @GetMapping("/doCallTest") - public ResultJson doCallTest() throws ParseException { - autoCallTaskService.generateFakeCall(); - return ResultJson.ok("resp"); - } + @Autowired + private AICCHelper aiccHelper; + @Autowired + private AutoCallConfigMapper configMapper; @GetMapping("/doGenerateTest2") public ResultJson doGenerateTest2() throws ParseException { @@ -63,21 +52,12 @@ public class AutoCallController { @GetMapping("/getToken") public ResultJson getToken() { - return ResultJson.ok(autoCallTaskService.getToken()); - } - - @GetMapping("/queryTaskResult") - public ResultJson queryTaskResult(@RequestParam("requestId") String requestId, @RequestParam("custId") String custId) { - return ResultJson.ok(autoCallTaskService.queryTaskResult(requestId, custId)); - } - - @PostMapping("/page") - public ResultJson> newList(@RequestBody AutoCallDto dto) { - return ResultJson.ok(autoCallApiService.page(dto)); + return ResultJson.ok(aiccHelper.getToken()); } /** * 查询所有未接通的数据 + * * @return */ @GetMapping("/listCallIsNotPass") @@ -87,6 +67,7 @@ public class AutoCallController { /** * 分页查询所有未接通的数据 + * * @return */ @GetMapping("/listCallIsNotPassPage") @@ -99,19 +80,15 @@ public class AutoCallController { return ResultJson.ok(autoCallApiService.page2(dto)); } - @GetMapping("/listCallIsNotPut") - public ResultJson> listCallIsNotPut() { - return ResultJson.ok(autoCallApiService.listCallIsNotPut()); - } @GetMapping("/isEnable") public ResultJson isEnable() { - return ResultJson.ok(autoCallTaskService.isEnable()); + return ResultJson.ok(configMapper.isEnable()); } @GetMapping("/setEnable") public ResultJson setEnable(@RequestParam("enable") Boolean enable) { - autoCallTaskService.setEnable(enable); + configMapper.setEnable(enable); return ResultJson.ok(true); } @@ -120,30 +97,6 @@ public class AutoCallController { return ResultJson.ok(autoCallTaskService2.manualClose(taskId, personId)); } - /** - * 根据ID关闭预警 - * @param taskId - * @return - */ - @Deprecated - @GetMapping("/setCallIsPut") - public ResultJson setCallIsPut(@RequestParam("taskId") Integer taskId) { - autoCallTaskService.setCallIsPut(taskId); - return ResultJson.ok(true); - } - - /** - * 预警的批量关闭 - * @param dto - * @return - */ - @Deprecated - @PostMapping("/setCallIsPutList") - public ResultJson setCallIsPutList(@RequestBody CallPutDto dto) { - autoCallTaskService.setCallIsPutList(dto); - return ResultJson.ok(true); - } - @PostMapping("/exportPdf") public void exportPDF(@RequestBody AutoCallDto dto, HttpServletResponse response, @@ -165,13 +118,13 @@ public class AutoCallController { if (userAgent != null && userAgent.toLowerCase().contains("firefox")) { // Firefox浏览器 response.setHeader("Content-Disposition", - "attachment; filename*=UTF-8''" + URLEncoder.encode(fileName, "UTF-8")); + "attachment; filename*=UTF-8''" + URLEncoder.encode(fileName, "UTF-8")); } else { // 其他浏览器(Chrome, Edge, Safari等) response.setHeader("Content-Disposition", - "attachment; filename=\"" + new String(fileName.getBytes("GBK"), "ISO-8859-1") + "\""); + "attachment; filename=\"" + new String(fileName.getBytes("GBK"), "ISO-8859-1") + "\""); } - IOUtils.copy(pdfStream,response.getOutputStream()); + IOUtils.copy(pdfStream, response.getOutputStream()); response.flushBuffer(); } catch (IOException e) { throw new RuntimeException(e); @@ -180,7 +133,7 @@ public class AutoCallController { @GetMapping("/getPdf") //{"etm":"2025-08-07","stm":"2025-07-31","page":{"pageNumber":1,"pageSize":20}} - public void getPdf(@RequestParam("stm")String stm, @RequestParam("etm")String etm, HttpServletResponse response, + public void getPdf(@RequestParam("stm") String stm, @RequestParam("etm") String etm, HttpServletResponse response, HttpServletRequest request) { AutoCallDto dto = new AutoCallDto(); dto.setStm(stm); @@ -209,7 +162,7 @@ public class AutoCallController { response.setHeader("Content-Disposition", "attachment; filename=\"" + new String(fileName.getBytes("GBK"), "ISO-8859-1") + "\""); } - IOUtils.copy(pdfStream,response.getOutputStream()); + IOUtils.copy(pdfStream, response.getOutputStream()); response.flushBuffer(); } catch (IOException e) { throw new RuntimeException(e); @@ -217,7 +170,7 @@ public class AutoCallController { } @GetMapping("/newPerson") - public ResultJson newPerson(@RequestParam("taskId")Integer taskId) { + public ResultJson newPerson(@RequestParam("taskId") Integer taskId) { AutoCallTask task = autoCallTaskService2.getTaskMapper().selectById(taskId); return ResultJson.ok(autoCallTaskService2.newPerson(task)); } diff --git a/src/main/java/com/whdc/mapper/AutoCallConfigMapper.java b/src/main/java/com/whdc/mapper/AutoCallConfigMapper.java index e13dcf1..0db7b15 100644 --- a/src/main/java/com/whdc/mapper/AutoCallConfigMapper.java +++ b/src/main/java/com/whdc/mapper/AutoCallConfigMapper.java @@ -18,6 +18,17 @@ public interface AutoCallConfigMapper extends BaseMapper { return config != null && "1".equals(config.getValue()); } + default void setEnable(Boolean enable) { + AutoCallConfig config = new AutoCallConfig(); + config.setKey("enable"); + config.setValue(enable ? "1" : "0"); + update( + config, + new QueryWrapper() + .eq("key", "enable") + ); + } + default boolean isScheduled() { AutoCallConfig config = selectOne( new QueryWrapper() diff --git a/src/main/java/com/whdc/mapper/WarnCallMapMapper.java b/src/main/java/com/whdc/mapper/WarnCallMapMapper.java deleted file mode 100644 index c217b9d..0000000 --- a/src/main/java/com/whdc/mapper/WarnCallMapMapper.java +++ /dev/null @@ -1,57 +0,0 @@ -package com.whdc.mapper; - -import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper; -import com.baomidou.mybatisplus.core.mapper.BaseMapper; -import com.whdc.model.entity.QXWarning; -import com.whdc.model.entity.WarnCallMap; - -import java.util.List; - -/** - * @author lyf - * @since 2025-06-19 - */ -public interface WarnCallMapMapper extends BaseMapper { - List listWarnsThatNotGeneratedWcm(); - - default List listUnGeneratedWcm() { - return selectList( - new QueryWrapper() - .eq("should_generate", 1) - .eq("generated", 0) - .eq("err_step", 0) - .orderByAsc("id") - ); - } - - default List listUnUploadedWcm() { - return selectList( - new QueryWrapper() - .eq("generated", 1) - .eq("uploaded", 0) - .eq("err_step", 0) - .orderByAsc("id") - ); - } - - default List listUnCalledWcm() { - return selectList( - new QueryWrapper() - .eq("uploaded", 1) - .eq("called", 0) - .eq("err_step", 0) - .orderByAsc("id") - ); - } - - default List listCallIsNotPutWcm() { - return selectList( - new QueryWrapper() - .eq("uploaded", 1) - .eq("called", 1) - .eq("call_is_put", 0) - .eq("err_step", 0) - .orderByDesc("id") - ); - } -} diff --git a/src/main/java/com/whdc/model/entity/WarnCallMap.java b/src/main/java/com/whdc/model/entity/WarnCallMap.java deleted file mode 100644 index 7b63acc..0000000 --- a/src/main/java/com/whdc/model/entity/WarnCallMap.java +++ /dev/null @@ -1,73 +0,0 @@ -package com.whdc.model.entity; - -import com.baomidou.mybatisplus.annotation.IdType; -import com.baomidou.mybatisplus.annotation.TableField; -import com.baomidou.mybatisplus.annotation.TableId; -import com.baomidou.mybatisplus.annotation.TableName; -import com.fasterxml.jackson.annotation.JsonFormat; -import lombok.Data; - -import java.util.Date; -import java.util.List; - -/** - * @author lyf - * @since 2025-06-19 - */ -@Data -@TableName("FXKH_TXL.WARN_CALL_MAP") -public class WarnCallMap { - /* - new的时候必填warnId,shouldGenerate,cnnm,requestId,custId,custName,warnName,warnTm,warnLevel,callContent,createTm - 生成autoCall后必填generated - upload后必填uploadRespMsg,uploaded - query后必填callIsPut,called - */ - @TableId(value = "ID", type = IdType.AUTO) - private Integer id; - @TableField(value = "warn_id") - private Integer warnId; //not null - @TableField(value = "should_generate") - private Integer shouldGenerate; //0:不生成，1:生成, not null - @TableField(value = "generated") - private Integer generated; //0:未生成，1:已生成, default 0 - @TableField(value = "uploaded") - private Integer uploaded; //0:未上传，1:已上传, default 0 - @TableField(value = "cnnm") - private String cnnm; - @TableField(value = "upload_resp_msg") - private String uploadRespMsg; - @TableField(value = "request_id") - private String requestId; //任务名，作为参数的taskName - @TableField(value = "cust_id") - private String custId; //联系人id - @TableField(value = "cust_name") - private String custName; //联系人 - @TableField(value = "call_is_put") - private Integer callIsPut; //0:未接通，1:已接通, default 0 - @TableField(value = "called") - private Integer called; //0:未拨打，1:已拨打, default 0 - @TableField(value = "err_step") - private Integer errStep; //0:初始化，1:step1出错, 以此类推,default 0 - - @TableField(value = "warn_name") - private String warnName; - @TableField(value = "warn_tm") - @JsonFormat(pattern = "yyyy-MM-dd HH:mm:ss",timezone = "GMT+8") - private Date warnTm; - @TableField(value = "warn_level") - private String warnLevel; - @TableField(value = "call_content") - private String warnContent; - - @TableField(value = "_create_tm") - @JsonFormat(pattern = "yyyy-MM-dd HH:mm:ss",timezone = "GMT+8") - private Date createTm; - @TableField(value = "_remark") - private String remark; - - - @TableField(exist = false) - private List callList; - -} diff --git a/src/main/java/com/whdc/service/AutoCallTaskService.java b/src/main/java/com/whdc/service/AutoCallTaskService.java deleted file mode 100644 index 12e2120..0000000 --- a/src/main/java/com/whdc/service/AutoCallTaskService.java +++ /dev/null @@ -1,522 +0,0 @@ -package com.whdc.service; - -import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper; -import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper; -import com.whdc.mapper.*; -import com.whdc.model.dto.CallPutDto; -import com.whdc.model.entity.*; -import com.whdc.model.entity.autocall.AICCCallRespDetail; -import com.whdc.model.entity.autocall.AICCCallRespWrapper; -import com.whdc.model.entity.autocall.AICCUploadTask; -import com.whdc.model.entity.autocall.AICCCallRespTask; -import com.whdc.utils.AutoCallHelper; -import com.whdc.utils.SmsHelper; -import lombok.extern.slf4j.Slf4j; -import org.jetbrains.annotations.NotNull; -import org.springframework.beans.factory.annotation.Autowired; -import org.springframework.beans.factory.annotation.Value; -import org.springframework.stereotype.Service; -import org.springframework.transaction.annotation.Transactional; - -import java.text.ParseException; -import java.text.SimpleDateFormat; -import java.util.*; -import java.util.concurrent.atomic.AtomicBoolean; -import java.util.stream.Collectors; - -import static com.whdc.model.entity.AutoCallTask.STATUS_MANUAL_CLOSE; - -/** - * @author lyf - * @since 2025-06-14 - */ -@Service -@Slf4j -public class AutoCallTaskService { - private static final String[] excludeNames = new String[]{"高新", "开发", "自治", "技术", "旅游", "管理", "工业", "产业", "示范"}; - private static final AtomicBoolean isCalling = new AtomicBoolean(false); - - - @Autowired - private AutoCallTaskMapper autoCallTaskMapper; - @Autowired - private WarningResponderMapper warningResponderMapper; - @Autowired - private QXWarningMapper qxWarningMapper; - @Autowired - private AutoCallMapper autoCallMapper; - @Autowired - private AutoCallConfigMapper configMapper; - @Autowired - private WarnCallMapMapper warnCallMapMapper; - @Autowired - private AutoCallHelper autoCallHelper; - @Autowired - private SmsHelper smsHelper; - @Value("${autocall.processId}") - private String processId; - @Value("${autocall.callerGroup}") - private String callerGroup; - @Value("${autocall.secret}") - private String secret; - @Value("${autocall.sysUserId}") - private String sysUserId; - - @Transactional - public void generateFakeCall() throws ParseException { - QXWarning warn = qxWarningMapper.selectOne( - new QueryWrapper() - .orderByDesc("WARNID") - .last("limit 1") - ); - warn.setCtnm("恩施州"); - warn.setCnnm("咸丰，"); - - List wcmList = newWcmByWarn(warn); - WarnCallMap wcm = wcmList.get(0); - wcm.setCreateTm(new Date()); - warnCallMapMapper.insert(wcm); - } - - public void step1GenerateWarnCallMap() { - List warnList = warnCallMapMapper.listWarnsThatNotGeneratedWcm(); - for (QXWarning warn : warnList) { - try { - List wcmList = newWcmByWarn(warn); - for (WarnCallMap wcm : wcmList) { - if (wcm.getCnnm() == null) { - wcm.setErrStep(1); - wcm.setRemark("未找到县区"); - } - wcm.setCreateTm(new Date()); - warnCallMapMapper.insert(wcm); - } - } catch (Exception e) { - log.error("根据预警生成呼叫失败", e); - } - } - } - - public String getToken() { - return autoCallHelper.getToken(); - } - - private @NotNull List newWcmByWarn(QXWarning warn) throws ParseException { - String cnnmStr = warn.getCnnm(); - Integer warnId = warn.getWarnid(); - String warnSignalLevel = warn.getWarnSignalLevel(); - String content = warn.getContent(); - String ctnm = warn.getCtnm(); - Date publishTime = warn.getPublishTime(); - - List wcmList = new ArrayList<>(); - SimpleDateFormat sdf = new SimpleDateFormat("yyyy年MM月dd日HH时mm分"); -// content = "我是省防办智能外呼系统，" + content + "如需咨询请拨打02787221781"; - content = "我是省防办智能外呼系统，" +warn.getCtnm()+sdf.format(warn.getPublishTime()) +"发布暴雨"+warn.getWarnSignalLevel()+"预警信号："+ content + "如需咨询请拨打02787221781，相关信息以短信发送给您。"; - if (cnnmStr == null || cnnmStr.trim().isEmpty()) { - WarnCallMap wcm = newWcm(null, warnId, publishTime, ctnm, warnSignalLevel, content); - wcmList.add(wcm); - return wcmList; - } - String[] cnnms = cnnmStr.trim().split(","); - for (String cnnm : cnnms) { - if (cnnm.isEmpty()) continue; - if (publishTime == null) continue; - - WarnCallMap wcm = newWcm(cnnm, warnId, publishTime, ctnm, warnSignalLevel, content); - wcmList.add(wcm); - } - return wcmList; - } - - private @NotNull WarnCallMap newWcm(String cnnm, Integer warnId, Date publishTime, String ctnm, String warnSignalLevel, String content) throws ParseException { - WarnCallMap wcm = new WarnCallMap(); - wcm.setWarnId(warnId); - wcm.setCnnm(cnnm); - - SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss"); - wcm.setWarnTm(publishTime); - - wcm.setWarnName(String.format("%s%s%s%s预警", sdf.format(publishTime), ctnm, cnnm, warnSignalLevel)); - wcm.setWarnLevel(warnSignalLevel); - wcm.setWarnContent(content); - wcm.setRequestId("hbsl" + new Date().getTime() + cnnm); - - if (isEnable()) { - wcm.setShouldGenerate(1); - } else { - wcm.setShouldGenerate(0); - } - return wcm; - } - - //为什么wcm和autocall的生成要分开：wcm是根据qxwarning生成的，自动呼叫可能会暂停，避免之后开启会根据早时的qxwarning生成wcm进而呼叫 - public void step2GenerateAutoCallByWcm() { - List wcmList = warnCallMapMapper.listUnGeneratedWcm(); - for (WarnCallMap wcm : wcmList) { - List autoCallList = newAutoCall(wcm); - if (autoCallList.size() == 0) { - wcm.setErrStep(2); - wcm.setRemark("未找到责任人"); - warnCallMapMapper.updateById(wcm); - return; - } - - StringBuilder sb = new StringBuilder(); - //将responderId合并为custId - for (AutoCall autoCall : autoCallList) { - sb.append(autoCall.getResponderId()).append("-"); - } - sb.deleteCharAt(sb.length() - 1); - String custId = System.currentTimeMillis() + "-" + sb; - //将responderName合并为custName - sb = new StringBuilder(); - for (AutoCall autoCall : autoCallList) { - sb.append(autoCall.getResponderName()).append(","); - } - sb.deleteCharAt(sb.length() - 1); - String custName = sb.toString(); - wcm.setCustId(custId); - wcm.setCustName(custName); - wcm.setGenerated(1); - - Date now = new Date(); - autoCallList.forEach(a -> { - a.setCreateTm(now); - autoCallMapper.insert(a); - }); - - warnCallMapMapper.updateById(wcm); - } - } - - private @NotNull List newAutoCall(WarnCallMap wcm) { - Integer wcmId = wcm.getId(); - String cnnm = wcm.getCnnm(); - List existList = autoCallMapper.listByWcmIdAndCnnmOrderByLevelAsc(wcmId, cnnm); - if (existList != null && existList.size() > 0) { - return Collections.emptyList(); - } - - return newAutoCall(wcmId, cnnm, wcm.getWarnLevel()); - } - - private @NotNull List newAutoCall(Integer wcmId, String cnnm, String warnLevelStr) { - //处理行政区划和预警级别，橙色预警拨打1，2level的，红色预警只拨打3level的 - List warnLevel = mapWarnSignalLevel(warnLevelStr); - List wrList = listWarningResponderByCnnmAndLevelOrderByLevelAsc(cnnm, warnLevel); - if (wrList.isEmpty()) return Collections.emptyList(); - //处理县区包含高新区、开发区等情况 - doSomethingWith(cnnm, wrList); - //按level从小到大排序 - wrList.sort(Comparator.comparingInt(WarningResponder::getLevel)); - List autoCallList = new ArrayList<>(); - for (WarningResponder wr : wrList) { - Integer wrLevel = wr.getLevel(); - wr.decryptPhone(); - AutoCall autoCall = new AutoCall(); - autoCall.setResponderId(wr.getId()) - .setResponderName(wr.getName()) - .setWcmId(wcmId) - .setLevel(wrLevel) - .setNumber(wr.getPhone()); - autoCallList.add(autoCall); - } - - return autoCallList; - } - - public void step3UploadCallTask() { - if (!isCalling.compareAndSet(false, true)) { - return; - } - - try { - //已提交，提交返回内容为“导入成功”，未拨打 - List wcmList = warnCallMapMapper.listUnUploadedWcm(); - if (wcmList == null || wcmList.isEmpty()) return; - - for (WarnCallMap wcm : wcmList) { - Integer wcmId = wcm.getId(); - List autoCallList = autoCallMapper.listByWcmIdAndCnnmOrderByLevelAsc(wcmId, wcm.getCnnm()); - if (autoCallList == null || autoCallList.isEmpty()) { - wcm.setErrStep(3); - wcm.setRemark("未找到呼叫列表"); - warnCallMapMapper.updateById(wcm); - continue; - } - - List numbers = autoCallList.stream() - .map(AutoCall::getNumber) - .collect(Collectors.toList()); - - AICCUploadTask task = autoCallHelper.newTask( - wcm.getRequestId(), - wcm.getCustId(), - wcm.getCustName(), - wcm.getWarnContent(), - numbers - ); - AICCCallRespWrapper AICCCallRespWrapper = autoCallHelper.apiUploadCallData(task); - - String msg = AICCCallRespWrapper.getResult().getMsg(); - wcm.setUploaded(1); - wcm.setUploadRespMsg(msg); - warnCallMapMapper.updateById(wcm); - - smsHelper.send(numbers, wcm.getWarnContent()); - } - } finally { - isCalling.set(false); - } - } - - public void step4QueryTaskResult() { - List wcmList = warnCallMapMapper.listUnCalledWcm(); - if (wcmList.isEmpty()) return; - - for (WarnCallMap wcm : wcmList) { - Integer wcmId = wcm.getId(); - String requestId = wcm.getRequestId(); - String custId = wcm.getCustId(); - - List autoCallList = autoCallMapper.listByWcmIdAndCnnmOrderByLevelAsc(wcmId, wcm.getCnnm()); - if (autoCallList == null || autoCallList.isEmpty()) { - wcm.setErrStep(4); - wcm.setRemark("未找到呼叫列表"); - warnCallMapMapper.updateById(wcm); - continue; - } - - AICCCallRespWrapper AICCCallRespWrapper = autoCallHelper.apiGetTaskCallDetail(requestId, custId); - if (AICCCallRespWrapper == null || !AICCCallRespWrapper.isSuccess()) { - wcm.setErrStep(4); - wcm.setRemark("请求外呼平台失败"); - warnCallMapMapper.updateById(wcm); - continue; - } - - //任务不存在 - if (AICCCallRespWrapper.getResult() == null - || AICCCallRespWrapper.getResult().getData() == null - || AICCCallRespWrapper.getResult().getData().getRecords() == null - || AICCCallRespWrapper.getResult().getData().getRecords().isEmpty()) { - wcm.setErrStep(4); - wcm.setRemark("外呼平台查询不到任务"); - warnCallMapMapper.updateById(wcm); - continue; - } - - List records = AICCCallRespWrapper.getResult().getData().getRecords(); - boolean anyCalled = true; - boolean anyCallIsPut = false; - for (AICCCallRespDetail.Record record : records) { - if (record.getRemark() == null || record.getRemark().isEmpty()) { - anyCalled = false; - continue; - } - if ("接通".equals(record.getRemark())) anyCallIsPut = true; - AICCCallRespDetail.RawVarListMap rawVarListMap = record.getRawVarListMap(); - String number = rawVarListMap.getNumber(); - AutoCall call = null; - for (AutoCall a : autoCallList) { - if (a.getNumber().equals(number)) { - call = a; - break; - } - } - copyDataFromDetailToAutoCall(record, call, rawVarListMap); - } - if (!records.isEmpty() && anyCalled) { - wcm.setCalled(1); - warnCallMapMapper.updateById(wcm); - } - - for (AutoCall a : autoCallList) { - if (a.getStatus() == null && anyCallIsPut) { - a.setStatus("已呼通其他责任人"); - } - autoCallMapper.updateById(a); - } - if (anyCallIsPut) { - wcm.setCallIsPut(1); - warnCallMapMapper.updateById(wcm); - } - } - } - - public AICCCallRespWrapper queryTaskResult(String requestId, String custId) { - return autoCallHelper.apiGetTaskCallDetail(requestId, custId); - } - - private void copyDataFromDetailToAutoCall(AICCCallRespDetail.Record record, AutoCall call, AICCCallRespDetail.RawVarListMap rawVarListMap) { - if (call != null) { - call.setStatus(record.getRemark()); - call.setTalkTimes(record.getTalkTimes()); - call.setSipTermCause(rawVarListMap.getSipTermCause()); - call.setCaller(rawVarListMap.getCaller()); - - Date d; - long l; - - if (rawVarListMap.getStartringAt() != null) { - d = new Date(); - l = Long.parseLong(rawVarListMap.getStartringAt().substring(0, 13)); - d.setTime(l); - call.setStartringAt(d); - } - - if (rawVarListMap.getConnectedAt() != null) { - d = new Date(); - l = Long.parseLong(rawVarListMap.getConnectedAt().substring(0, 13)); - d.setTime(l); - call.setConnectedAt(d); - } - - if (rawVarListMap.getStartedAt() != null) { - d = new Date(); - l = Long.parseLong(rawVarListMap.getStartedAt()); - d.setTime(l); - call.setStartedAt(d); - } - - if (rawVarListMap.getEndringAt() != null) { - d = new Date(); - l = Long.parseLong(rawVarListMap.getEndringAt().substring(0, 13)); - d.setTime(l); - call.setEndringAt(d); - } - - if (rawVarListMap.getDisconnectedAt() != null) { - d = new Date(); - l = Long.parseLong(rawVarListMap.getDisconnectedAt().substring(0, 13)); - d.setTime(l); - call.setDisconnectedAt(d); - } - - if (rawVarListMap.getStopedAt() != null) { - d = new Date(); - l = Long.parseLong(rawVarListMap.getStopedAt()); - d.setTime(l); - call.setStopedAt(d); - } - - if (rawVarListMap.getLastModify() != null) { - d = new Date(); - l = Long.parseLong(rawVarListMap.getLastModify()); - d.setTime(l); - call.setLastModify(d); - } - } - } - - - private List mapWarnSignalLevel(String warnSignalLevel) { - /** - * 目前需求不区分预警级别，固定查取 1 2 3 4级，全部都呼叫 - */ - List ret = new ArrayList<>(); - ret.add(1); - ret.add(2); - ret.add(3); - ret.add(4); -// if ("红色".equals(warnSignalLevel)) { -// ret.add(3); -// } else { -// ret.add(1); -// ret.add(2); -// } - return ret; - } - - /* - 更新字典，是否开启自动呼叫 - */ - public void setEnable(Boolean enable) { - AutoCallConfig config = new AutoCallConfig(); - config.setKey("enable"); - config.setValue(enable ? "1" : "0"); - configMapper.update( - config, - new QueryWrapper() - .eq("key", "enable") - ); - } - - /* - 查询字典，是否开启自动呼叫 - */ - public boolean isEnable() { - AutoCallConfig config = configMapper.selectOne( - new QueryWrapper() - .eq("key", "enable") - .last("limit 1") - ); - return config != null && "1".equals(config.getValue()); - } - - public void setCallIsPut(Integer wcmId) { - WarnCallMap wcm = warnCallMapMapper.selectById(wcmId); - wcm.setCalled(1); - wcm.setCallIsPut(1); - warnCallMapMapper.updateById(wcm); - } - - /* - 查询字典，是否开启定时任务 - */ - public boolean isScheduled() { - AutoCallConfig config = configMapper.selectOne( - new QueryWrapper() - .eq("key", "schedule") - .last("limit 1") - ); - return config != null && "1".equals(config.getValue()); - } - - private static void doSomethingWith(String cnmm, List wrList) { - //预警包含高新等字符，可跳出 - boolean skip = false; - for (String excludeName : excludeNames) { - if (cnmm.contains(excludeName)) { - skip = true; - break; - } - } - if (skip) { - return; - } - //预警不包含高新等字符，检查人员，保留不包含高新等字符的人员 - Iterator iter = wrList.iterator(); - while (iter.hasNext()) { - WarningResponder autoCall = iter.next(); - boolean anyMatch = false; - for (String excludeName : excludeNames) { - if (autoCall.getCnnm().contains(excludeName)) { - anyMatch = true; - break; - } - } - if (anyMatch) { - iter.remove(); - } - } - } - - private List listWarningResponderByCnnmAndLevelOrderByLevelAsc(String cnnm, List levels) { - return warningResponderMapper.listByCnnmAndLevelOrderByLevelAsc(cnnm, levels); - } - - @Transactional - public void setCallIsPutList(CallPutDto dto) { - LambdaQueryWrapper queryWrapper = new LambdaQueryWrapper<>(); - queryWrapper.in(AutoCallTask::getId,dto.getTaskIds()); - List autoCallTasks = autoCallTaskMapper.selectList(queryWrapper); - for (AutoCallTask autoCallTask : autoCallTasks) { - //告警任务取消 - autoCallTask.setStatus(STATUS_MANUAL_CLOSE); - autoCallTask.setRemark("人工处置"); - autoCallTaskMapper.updateById(autoCallTask); - } - } -}