diff --git a/src/test/java/com/whdc/utils/AutoCallHelperTest.java b/src/test/java/com/whdc/utils/AutoCallHelperTest.java new file mode 100644 index 0000000..ab7c1ae --- /dev/null +++ b/src/test/java/com/whdc/utils/AutoCallHelperTest.java @@ -0,0 +1,217 @@ +package com.whdc.utils; + + +import com.alibaba.fastjson.JSON; +import com.google.common.collect.Lists; +import com.whdc.model.entity.AutoCallPerson; +import com.whdc.model.entity.AutoCallTask; +import com.whdc.model.entity.autocall.AICCCallRespDetail; +import com.whdc.model.entity.autocall.AICCCallRespTask; +import com.whdc.model.entity.autocall.AICCCallRespWrapper; +import com.whdc.model.entity.autocall.AICCUploadTask; +import org.slf4j.Logger; +import org.slf4j.LoggerFactory; + +import java.io.UnsupportedEncodingException; +import java.security.GeneralSecurityException; +import java.text.ParseException; +import java.text.SimpleDateFormat; +import java.util.ArrayList; +import java.util.Collections; +import java.util.Date; +import java.util.List; + +class AICCHelperTest { + private static final Logger LOG = LoggerFactory.getLogger(AICCHelperTest.class); + + public static void main(String[] args) throws InterruptedException, ParseException, GeneralSecurityException, UnsupportedEncodingException { + AICCHelper helper = new AICCHelper(); + helper.setProcessId("1935233125932101634"); + helper.setCallerGroup("02759325005"); + helper.setSecret("yxt@2024-1234567"); + helper.setSysUserId("HBSL01"); + + long millis = System.currentTimeMillis(); + Date now = new Date(millis); + + AutoCallTask task = new AutoCallTask(); + task.setId(1); + task.setWarnId(1); + task.setStatus(1); + task.setWarnName("测试预警"); + task.setWarnTm(now); + task.setWarnLevel("橙色"); + task.setCreateTm(now); + + AutoCallPerson person = new AutoCallPerson(); + person.setId(0); + person.setTaskId(1); + String uniqueId = millis + "-0"; + person.setUploadRequestId(uniqueId); + person.setUploadCustId(uniqueId); + person.setUploadCustName("李"); + person.setUploadContent("测试测试测试，这是第一个联系人"); + person.setUploadNumber("15671545233"); + person.setStatus(0); + person.setLevel(1); + person.setCreateTm(now); + + task.setCallList(new ArrayList<>()); + task.getCallList().add(person); + + AICCUploadTask uploadTask = new AICCUploadTask(); + uploadTask.setTaskName(person.getUploadRequestId()); + uploadTask.setProcessId("1935233125932101634"); + uploadTask.setCallerGroup("02759325005"); + uploadTask.setRequestId(person.getUploadRequestId()); + uploadTask.genMutiTimeRange(); + AICCUploadTask.Cust param = AICCUploadTask.Cust.builder() + .setCustName(person.getUploadCustName()) + .setCustId(person.getUploadCustId()) + .setContent(person.getUploadContent()) + .set_numbers(Collections.singletonList(person.getUploadNumber())) + .build(); + uploadTask.setParam(Lists.newArrayList(param)); + + uploadTask.setCalleeType(1); + uploadTask.setRepeatTimes(1); + uploadTask.setAutoCall("0"); + uploadTask.setSpanSeconds(10); + + LOG.info("上传外呼任务: {}", JSON.toJSONString(uploadTask)); + AICCCallRespWrapper AICCCallRespWrapper = helper.apiUploadCallData(uploadTask); + String msg = AICCCallRespWrapper.getResult().getMsg(); + person.setUploadRespMsg(msg); + LOG.info("上传外呼任务结果: {}", JSON.toJSONString(AICCCallRespWrapper)); + + int pendingDuration = 60 * 1000 * 2; + int loopGap = 1000; + SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss"); + while (true) { + Thread.sleep(loopGap); + pendingDuration -= loopGap; + if (pendingDuration <= 0) break; + + AICCCallRespWrapper detail = helper.apiGetTaskCallDetail(person.getUploadRequestId(), ""); + LOG.info("外呼任务详情: {}", JSON.toJSONString(detail)); + List records = detail.getResult().getData().getRecords(); + if (records.isEmpty()) continue; + + AICCCallRespDetail.Record record = records.get(0); + String dialRemark = record.getRemark(); + boolean done = false; + if ("接通".equals(dialRemark)) { + done = true; + } else if (records.size() > 1) { + done = true; + } + + if (done) { + person.setDetailRemark(dialRemark); + person.setDetailTalkTimes(record.getTalkTimes()); + AICCCallRespDetail.RawVarListMap rawVarListMap = record.getRawVarListMap(); + person.setDetailSipTermCause(rawVarListMap.getSipTermCause()); + + Date d; + long l; + if (rawVarListMap.getStartringAt() != null) { + d = new Date(); + l = Long.parseLong(rawVarListMap.getStartringAt().substring(0, 13)); + d.setTime(l); + person.setDetailStartringAt(d); + } + + if (rawVarListMap.getConnectedAt() != null) { + d = new Date(); + l = Long.parseLong(rawVarListMap.getConnectedAt().substring(0, 13)); + d.setTime(l); + person.setDetailConnectedAt(d); + } + + if (rawVarListMap.getStartedAt() != null) { + d = new Date(); + l = Long.parseLong(rawVarListMap.getStartedAt()); + d.setTime(l); + person.setDetailStartedAt(d); + } + + if (rawVarListMap.getEndringAt() != null) { + d = new Date(); + l = Long.parseLong(rawVarListMap.getEndringAt().substring(0, 13)); + d.setTime(l); + person.setDetailEndringAt(d); + } + + if (rawVarListMap.getDisconnectedAt() != null) { + d = new Date(); + l = Long.parseLong(rawVarListMap.getDisconnectedAt().substring(0, 13)); + d.setTime(l); + person.setDetailDisconnectedAt(d); + } + + if (rawVarListMap.getStopedAt() != null) { + d = new Date(); + l = Long.parseLong(rawVarListMap.getStopedAt()); + d.setTime(l); + person.setDetailStopedAt(d); + } + + if (rawVarListMap.getLastModify() != null) { + d = new Date(); + l = Long.parseLong(rawVarListMap.getLastModify()); + d.setTime(l); + person.setDetailLastModify(d); + } + + LOG.info("外呼任务完成: {}", JSON.toJSONString(uploadTask)); + break; + } + } + if (pendingDuration <= 0) { + person.setDetailRemark("超时"); + } + } + + public static void main2(String[] args) throws GeneralSecurityException, UnsupportedEncodingException { + AICCHelper helper = new AICCHelper(); + helper.setProcessId("1935233125932101634"); + helper.setCallerGroup("02759325005"); + helper.setSecret("yxt@2024-1234567"); + helper.setSysUserId("HBSL01"); + String token = "eyJhbGciOiJIUzI1NiIsInR5cCI6IkpXVCJ9.eyJ1c2VybmFtZSI6IkhCU0wwMSIsInRlbmFudElkIjoiOTYzOTM2NTE3IiwiZXhwIjoxNzUyMTU0NTE0fQ.R4Yg7OhZek9YbJ7xGj2rQTe_YY0KLPQDM2zRebLkRdY"; + + String prefix = System.currentTimeMillis() + ""; + + AICCUploadTask task = new AICCUploadTask(); + task.setTaskName("requestId" + prefix); + task.setProcessId("1935233125932101634"); + task.setCallerGroup("02759325005"); + task.setRequestId("requestId" + prefix); + task.genMutiTimeRange(); + AICCUploadTask.Cust param1 = AICCUploadTask.Cust.builder() + .setCustName("秦") + .setCustId("秦" + prefix) + .setContent("测试测试测试，这是第一个联系人") + .set_numbers(Collections.singletonList("13933930962")) + .build(); + AICCUploadTask.Cust param2 = AICCUploadTask.Cust.builder() + .setCustName("李") + .setCustId("李" + prefix) + .setContent("测试测试测试，这是第二个联系人") + .set_numbers(Collections.singletonList("15671545233")) + .build(); + task.setParam(Lists.newArrayList(param1, param2)); + + AICCCallRespWrapper AICCCallRespWrapper = helper.apiUploadCallData(task); + String msg = AICCCallRespWrapper.getResult().getMsg(); + System.out.println(msg); + } + + + class Cust { + private String custName; + private String custId; + private String content; + private String number; + } +} \ No newline at end of file