|
|
@@ -98,6 +98,15 @@ public class TelephoneRobotServiceImpl implements ITelephoneRobotService {
|
|
|
|
|
|
|
|
|
|
|
|
+ /**
|
|
|
+ *
|
|
|
+ * @description: 外呼机器人-导入号码
|
|
|
+ *
|
|
|
+ * @param sellerIds
|
|
|
+ * @param userId
|
|
|
+ * @return: com.ruixuan.common.core.domain.ResultResponse
|
|
|
+ * @author: zianY
|
|
|
+ */
|
|
|
@Override
|
|
|
public ResultResponse importRobotTelephone(List<Long> sellerIds,String userId){
|
|
|
Map<String,String> headers = new HashMap<>();
|
|
|
@@ -119,38 +128,53 @@ public class TelephoneRobotServiceImpl implements ITelephoneRobotService {
|
|
|
customerList.add(param);
|
|
|
}
|
|
|
result.put("customerList",customerList);
|
|
|
-
|
|
|
//headers.put("Auth-Token","eyJ0eXAiOiJKV1QiLCJhbGciOiJIUzI1NiJ9.eyJhdWQiOiJndW95YW5saW5nIiwiZXhwIjoxNjU4MTMyMjEyfQ.OyhpastRRzBxAlSc8JOfdxO3rK3NG592U3Qlh752xDQ");
|
|
|
-
|
|
|
JSONObject tokenObj = redisCache.getCacheObject("salesLeads:robotToken:str");
|
|
|
if (!StringUtils.isEmpty(tokenObj)){
|
|
|
log.info("导入时获取redis中的token信息----->>>{}",tokenObj);
|
|
|
- headers.put("Auth-Token",tokenObj.getString("token"));
|
|
|
+
|
|
|
}else {
|
|
|
- getTelephoneRobotToken();
|
|
|
+ tokenObj = getTelephoneRobotToken();
|
|
|
log.info("导入时redis中的token信息已失效,重新获取token----->>>{}");
|
|
|
}
|
|
|
+ headers.put("Auth-Token",JSONObject.parseObject(tokenObj.getString("data")).getString("token"));
|
|
|
String content = HttpUtil.httpPostRequest(RobotConstant.CUSTOMER_IMPORT,result,headers);
|
|
|
JSONObject jsonObject = JSONObject.parseObject(content);
|
|
|
if (!"0".equals(jsonObject.getString("code"))){
|
|
|
- return ResultResponse.error("导入数据接口异常======>>>>>"+jsonObject);
|
|
|
+ log.info("导入数据接口异常======>>>>>{}"+jsonObject);
|
|
|
+ return ResultResponse.error("第三方接口异常,请稍候再试");
|
|
|
}
|
|
|
|
|
|
-
|
|
|
//更新记录 用户
|
|
|
saleClueCallRecordMapper.updateCallRecordUser(userId);
|
|
|
+ JSONArray success = jsonObject.getJSONArray("success");
|
|
|
+ JSONArray error = jsonObject.getJSONArray("error");
|
|
|
+ return ResultResponse.successMsg("本次导入记录,成功"+success.size()+"条;失败"+error.size()+"条。",null);
|
|
|
+ }
|
|
|
|
|
|
- //查询导入回调记录
|
|
|
- SaleClueCallRecordPojo callRecordPojo = saleClueCallRecordMapper.getSaleClueCallRecordInfo();
|
|
|
- String record = callRecordPojo.getContent();
|
|
|
- JSONObject recordJson = JSONObject.parseObject(record);
|
|
|
- JSONArray success = recordJson.getJSONArray("success");
|
|
|
- JSONArray error = recordJson.getJSONArray("error");
|
|
|
-
|
|
|
- Map<String,Object> map = new HashMap();
|
|
|
- map.put("successList",success);
|
|
|
- map.put("errorList",error);
|
|
|
- return ResultResponse.successMsg("导入记录查询成功。",map);
|
|
|
+
|
|
|
+
|
|
|
+ /**
|
|
|
+ *
|
|
|
+ * @description: 外呼记录查询
|
|
|
+ *
|
|
|
+ * @param
|
|
|
+ * @return: com.ruixuan.common.core.domain.ResultResponse
|
|
|
+ * @author: zianY
|
|
|
+ */
|
|
|
+ @Override
|
|
|
+ public ResultResponse getRobotTelephoneRecordList(){
|
|
|
+
|
|
|
+ PageUtils.startPage();
|
|
|
+ //查询导入记录
|
|
|
+ List<SaleClueCallRecordPojo> callRecordList = saleClueCallRecordMapper.getSaleClueCallRecordInfo();
|
|
|
+ for (SaleClueCallRecordPojo recordPojo : callRecordList) {
|
|
|
+ String record = recordPojo.getContent();
|
|
|
+ JSONObject recordJson = JSONObject.parseObject(record);
|
|
|
+ recordPojo.setSuccessList(recordJson.getJSONArray("success"));
|
|
|
+ recordPojo.setErrorList(recordJson.getJSONArray("error"));
|
|
|
+ }
|
|
|
+ return ResultResponse.successMsg("查询导入记录成功。",callRecordList);
|
|
|
}
|
|
|
|
|
|
|