| | |
|---|
| | | package cn.gistack.sm.intelligentCall.service.impl; |
|---|
| | | |
|---|
| | | import cn.gistack.sm.intelligentCall.constant.CallConstant; |
|---|
| | | import cn.gistack.sm.intelligentCall.service.CallService; |
|---|
| | | import com.alibaba.fastjson.JSONArray; |
|---|
| | | import com.alibaba.fastjson.JSONObject; |
|---|
| | | import lombok.extern.slf4j.Slf4j; |
|---|
| | | import org.apache.commons.lang3.RandomUtils; |
|---|
| | | import org.apache.commons.lang3.StringUtils; |
|---|
| | | import org.springframework.beans.factory.annotation.Autowired; |
|---|
| | | import org.springframework.http.HttpEntity; |
|---|
| | | import org.springframework.http.HttpHeaders; |
|---|
| | | import org.springframework.http.HttpStatus; |
|---|
| | | import org.springframework.http.ResponseEntity; |
|---|
| | | import org.springframework.stereotype.Service; |
|---|
| | | import org.springframework.util.DigestUtils; |
|---|
| | | import org.springframework.web.client.RestTemplate; |
|---|
| | | import javax.annotation.Resource; |
|---|
| | | import java.time.LocalDateTime; |
|---|
| | | import java.time.format.DateTimeFormatter; |
|---|
| | | import java.util.List; |
|---|
| | | import java.util.Map; |
|---|
| | | |
|---|
| | | @Slf4j |
|---|
| | | @Service |
|---|
| | | public class CallServiceImpl { |
|---|
| | | public class CallServiceImpl implements CallService { |
|---|
| | | |
|---|
| | | @Autowired |
|---|
| | | private RestTemplate restTemplate; |
|---|
| | | |
|---|
| | | // @Value("${dial.task.url}") |
|---|
| | | private String url = CallConstant.HOST; |
|---|
| | | |
|---|
| | | // @Value("${dial.task.empId}") |
|---|
| | | private String empId = CallConstant.empId; |
|---|
| | | |
|---|
| | | // @Value("${dial.task.appId}") |
|---|
| | | private String appId = CallConstant.AppKey; |
|---|
| | | |
|---|
| | | // @Value("${dial.task.appSecret}") |
|---|
| | | private String appSecret = CallConstant.AppSecret; |
|---|
| | | |
|---|
| | | // @Value("${dial.task.scenesId}") |
|---|
| | | private String scenesId = CallConstant.scenesId; |
|---|
| | | |
|---|
| | | // @Value("${dial.task.callingNumbers}") |
|---|
| | | private String callingNumbers = CallConstant.callingNumbers; |
|---|
| | | |
|---|
| | | private static final String CONTENT_TYPE = "application/json; charset=UTF-8"; |
|---|
| | | private static final String ACCEPT_TYPE = "application/json"; |
|---|
| | | private static final String ACCEPT_ENCODING = "gzip"; |
|---|
| | | |
|---|
| | | private final static String CREATE_TASK_URL = "/api/task/createTask.json"; |
|---|
| | | private final static String CALL_DETAIL_URL = "/api/task/callDetail.json"; |
|---|
| | | |
|---|
| | | @Override |
|---|
| | | public void createTask(List<Map<String, String>> params) { |
|---|
| | | String requestUrl = url + CREATE_TASK_URL; |
|---|
| | | LocalDateTime now = LocalDateTime.now(); |
|---|
| | | String timestamp = now.format(DateTimeFormatter.ofPattern("yyyy-MM-dd HH:mm:ss SSS")); |
|---|
| | | String transId = generateTransId(now); |
|---|
| | | String taskName = now.format(DateTimeFormatter.ofPattern("yyyy年MM月dd日HH:mm")) + "智能外呼"; |
|---|
| | | String[] numbers = StringUtils.split(callingNumbers,","); |
|---|
| | | String taskScheduleTime = LocalDateTime.now().plusHours(1).format(DateTimeFormatter.ofPattern("yyyy-MM-dd HH:mm:ss")); |
|---|
| | | JSONArray arr = getCalleeInfo(params); |
|---|
| | | HttpHeaders httpHeaders = new HttpHeaders(); |
|---|
| | | httpHeaders.add("Content-Type", CONTENT_TYPE); |
|---|
| | | httpHeaders.add("Accept", ACCEPT_TYPE); |
|---|
| | | httpHeaders.add("Accept-Encoding", ACCEPT_ENCODING); |
|---|
| | | JSONObject paramJson = new JSONObject(); |
|---|
| | | paramJson.put("taskName", taskName); |
|---|
| | | paramJson.put("scenesId", scenesId); |
|---|
| | | paramJson.put("callingNumbers", numbers); |
|---|
| | | paramJson.put("taskScheduleTime", taskScheduleTime); |
|---|
| | | paramJson.put("calleeData", arr); |
|---|
| | | paramJson.put("empId", empId); |
|---|
| | | String token = getToken(appId, timestamp, transId, appSecret, paramJson.toJSONString()); |
|---|
| | | JSONObject headerJson = new JSONObject(); |
|---|
| | | headerJson.put("appId", appId); |
|---|
| | | headerJson.put("timestamp", timestamp); |
|---|
| | | headerJson.put("transId", transId); |
|---|
| | | headerJson.put("token", token); |
|---|
| | | JSONObject bodyJson = new JSONObject(); |
|---|
| | | bodyJson.put("head", headerJson); |
|---|
| | | bodyJson.put("body", paramJson); |
|---|
| | | HttpEntity<String> stringHttpEntity = new HttpEntity<>(bodyJson.toJSONString(), httpHeaders); |
|---|
| | | log.info("创建超汛限智能外呼任务请求参数：{}", bodyJson.toJSONString()); |
|---|
| | | ResponseEntity<String> response = restTemplate.postForEntity(requestUrl, stringHttpEntity, String.class); |
|---|
| | | log.info("创建外呼任务请求结果：{}", response); |
|---|
| | | if (response.getStatusCode() != HttpStatus.OK) { |
|---|
| | | log.error("创建智能外呼任务失败：{}", response.getStatusCode()); |
|---|
| | | } |
|---|
| | | } |
|---|
| | | |
|---|
| | | @Override |
|---|
| | | public Object getCallDetail(String taskId, String calleeNumber) { |
|---|
| | | String requestUrl = url + CALL_DETAIL_URL; |
|---|
| | | LocalDateTime now = LocalDateTime.now(); |
|---|
| | | String timestamp = now.format(DateTimeFormatter.ofPattern("yyyy-MM-dd HH:mm:ss SSS")); |
|---|
| | | String transId = generateTransId(now); |
|---|
| | | HttpHeaders httpHeaders = new HttpHeaders(); |
|---|
| | | httpHeaders.add("Content-Type", CONTENT_TYPE); |
|---|
| | | httpHeaders.add("Accept", ACCEPT_TYPE); |
|---|
| | | httpHeaders.add("Accept-Encoding", ACCEPT_ENCODING); |
|---|
| | | JSONObject paramJson = new JSONObject(); |
|---|
| | | paramJson.put("taskId", taskId); |
|---|
| | | paramJson.put("calleeNumber", calleeNumber); |
|---|
| | | JSONObject bodyJson = new JSONObject(); |
|---|
| | | bodyJson.put("head", getHeadJson(appId, timestamp, transId, appSecret, paramJson.toJSONString())); |
|---|
| | | bodyJson.put("body", paramJson); |
|---|
| | | HttpEntity<String> stringHttpEntity = new HttpEntity<>(bodyJson.toJSONString(), httpHeaders); |
|---|
| | | ResponseEntity<String> response = restTemplate.postForEntity(requestUrl, stringHttpEntity, String.class); |
|---|
| | | log.info(response.toString()); |
|---|
| | | if (response.getStatusCode() == HttpStatus.OK) { |
|---|
| | | JSONObject responseJson = (JSONObject) JSONObject.parse(response.getBody()); |
|---|
| | | assert responseJson != null; |
|---|
| | | // return JSONObject.parseObject(responseJson.getString("data"), CallBackDetailVO.class); |
|---|
| | | return responseJson.getString("data"); |
|---|
| | | } |
|---|
| | | return null; |
|---|
| | | } |
|---|
| | | |
|---|
| | | private String getToken(String appId, String timestamp, String transId, String appSecret, String body) { |
|---|
| | | String sb = "appId" + appId + "timestamp" + timestamp + "transId" + transId + body + appSecret; |
|---|
| | | return DigestUtils.md5DigestAsHex(sb.getBytes()); |
|---|
| | | } |
|---|
| | | |
|---|
| | | private JSONObject getHeadJson(String appId, String timestamp, String transId, String appSecret, String body) { |
|---|
| | | String token = getToken(appId, timestamp, transId, appSecret, body); |
|---|
| | | JSONObject headerJson = new JSONObject(); |
|---|
| | | headerJson.put("appId", appId); |
|---|
| | | headerJson.put("timestamp", timestamp); |
|---|
| | | headerJson.put("transId", transId); |
|---|
| | | headerJson.put("token", token); |
|---|
| | | return headerJson; |
|---|
| | | } |
|---|
| | | |
|---|
| | | private String generateTransId(LocalDateTime now) { |
|---|
| | | String s = "000000" + RandomUtils.nextLong(0, 999999); |
|---|
| | | String randomStr = StringUtils.substring(s, -6); |
|---|
| | | return now.format(DateTimeFormatter.ofPattern("yyyyMMddHHmmssSSS")) + randomStr; |
|---|
| | | } |
|---|
| | | |
|---|
| | | /** |
|---|
| | | * 封装被呼人对象 |
|---|
| | | * @param params 被呼人信息 |
|---|
| | | * @return 被呼人数组 |
|---|
| | | */ |
|---|
| | | private JSONArray getCalleeInfo(List<Map<String, String>> params) { |
|---|
| | | JSONArray arr = new JSONArray(); |
|---|
| | | params.forEach(map -> { |
|---|
| | | String phone = map.get("phone"); |
|---|
| | | String name = map.get("name"); |
|---|
| | | String code = map.get("code"); |
|---|
| | | String userName = map.get("userName"); |
|---|
| | | String userId = map.get("userId"); |
|---|
| | | String over = map.get("over"); |
|---|
| | | if (StringUtils.isNotEmpty(phone) && StringUtils.isNotEmpty(name)) { |
|---|
| | | JSONObject json = new JSONObject(); |
|---|
| | | json.put("被叫号码", phone); |
|---|
| | | json.put("水库名称", name); |
|---|
| | | json.put("水库编码", code); |
|---|
| | | json.put("用户名", userName); |
|---|
| | | json.put("用户id", userId); |
|---|
| | | json.put("超汛限多少米", over); |
|---|
| | | arr.add(json); |
|---|
| | | } |
|---|
| | | }); |
|---|
| | | return arr; |
|---|
| | | } |
|---|
| | | } |
|---|
