浏览代码

销售线索-外呼机器人导入电话记录

yangzian 2 年之前
父节点
当前提交
6a89e59c54

+ 22 - 0
ruixuan-salesLeads/src/main/java/com.ruixuan.salesLeads/service/impl/SaleClueCallRecordServiceImpl.java

@@ -1,12 +1,14 @@
 package com.ruixuan.salesLeads.service.impl;
 package com.ruixuan.salesLeads.service.impl;
 
 
 import com.alibaba.fastjson.JSON;
 import com.alibaba.fastjson.JSON;
+import com.alibaba.fastjson.JSONArray;
 import com.alibaba.fastjson.JSONObject;
 import com.alibaba.fastjson.JSONObject;
 import com.ruixuan.common.core.domain.ResultResponse;
 import com.ruixuan.common.core.domain.ResultResponse;
 import com.ruixuan.common.utils.PageUtils;
 import com.ruixuan.common.utils.PageUtils;
 import com.ruixuan.common.utils.StringUtils;
 import com.ruixuan.common.utils.StringUtils;
 import com.ruixuan.salesLeads.mapper.SaleClueCallRecordMapper;
 import com.ruixuan.salesLeads.mapper.SaleClueCallRecordMapper;
 import com.ruixuan.salesLeads.mapper.SaleClueCallResultMapper;
 import com.ruixuan.salesLeads.mapper.SaleClueCallResultMapper;
+import com.ruixuan.salesLeads.mapper.SaleClueInfoMapper;
 import com.ruixuan.salesLeads.mapper.TestMapper;
 import com.ruixuan.salesLeads.mapper.TestMapper;
 import com.ruixuan.salesLeads.pojo.SaleClueCallResultPojo;
 import com.ruixuan.salesLeads.pojo.SaleClueCallResultPojo;
 import com.ruixuan.salesLeads.pojo.TestPojo;
 import com.ruixuan.salesLeads.pojo.TestPojo;
@@ -15,6 +17,7 @@ import com.ruixuan.salesLeads.service.ITestService;
 import lombok.extern.slf4j.Slf4j;
 import lombok.extern.slf4j.Slf4j;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.stereotype.Service;
 import org.springframework.stereotype.Service;
+import org.springframework.transaction.interceptor.TransactionAspectSupport;
 
 
 import java.util.List;
 import java.util.List;
 
 
@@ -37,6 +40,8 @@ public class SaleClueCallRecordServiceImpl implements ISaleClueCallRecordService
     @Autowired
     @Autowired
     private SaleClueCallResultMapper saleClueCallResultMapper;
     private SaleClueCallResultMapper saleClueCallResultMapper;
 
 
+    @Autowired
+    private SaleClueInfoMapper saleClueInfoMapper;
 
 
     /**
     /**
      *
      *
@@ -57,6 +62,23 @@ public class SaleClueCallRecordServiceImpl implements ISaleClueCallRecordService
             log.info("callBackUrl-----type----{}----->>>{}","importPhone",json);
             log.info("callBackUrl-----type----{}----->>>{}","importPhone",json);
             //保存 导入号码的 回调信息
             //保存 导入号码的 回调信息
             saleClueCallRecordMapper.addSaleCallRecord(json.toJSONString());
             saleClueCallRecordMapper.addSaleCallRecord(json.toJSONString());
+
+            JSONArray array = json.getJSONArray("error");
+            if (!array.isEmpty()){
+                log.info("销售线索导入失败------》》》》{}",array);
+            }
+
+            JSONArray success = json.getJSONArray("success");
+            if (!success.isEmpty()){
+                for (Object obj : success) {
+                    JSONObject jsonObject = (JSONObject) JSONObject.toJSON(obj);
+                    //修改线索的导入记录状态
+                    saleClueInfoMapper.updateSaleClueImportPhoneFlag(Long.valueOf(jsonObject.getString("id")),1);
+                    log.info("销售线索导入成功,修改线索导入状态------线索id》》》》{}",jsonObject.getString("id"));
+                }
+            }
+
+
             return ResultResponse.successMsg("callBackUrl--->>>导入号码回调信息成功",json);
             return ResultResponse.successMsg("callBackUrl--->>>导入号码回调信息成功",json);
         }
         }
         log.info("callBackUrl-----type----{}----->>>{}","phoneResult",json);
         log.info("callBackUrl-----type----{}----->>>{}","phoneResult",json);

+ 3 - 2
ruixuan-salesLeads/src/main/java/com.ruixuan.salesLeads/service/impl/TelephoneRobotServiceImpl.java

@@ -33,6 +33,7 @@ import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.beans.factory.annotation.Value;
 import org.springframework.beans.factory.annotation.Value;
 import org.springframework.stereotype.Service;
 import org.springframework.stereotype.Service;
 import org.springframework.transaction.annotation.Transactional;
 import org.springframework.transaction.annotation.Transactional;
+import org.springframework.transaction.interceptor.TransactionAspectSupport;
 import org.springframework.web.multipart.MultipartFile;
 import org.springframework.web.multipart.MultipartFile;
 
 
 import java.util.*;
 import java.util.*;
@@ -129,6 +130,7 @@ public class TelephoneRobotServiceImpl implements ITelephoneRobotService {
             //销售线索id查询
             //销售线索id查询
             SaleRecordVo saleInfo = saleClueInfoMapper.selectSaleClueInfoById(sellerId.intValue());
             SaleRecordVo saleInfo = saleClueInfoMapper.selectSaleClueInfoById(sellerId.intValue());
             if (saleInfo == null){
             if (saleInfo == null){
+                //TransactionAspectSupport.currentTransactionStatus().setRollbackOnly();
                 log.info("销售线索查询为空或已导入过联系方式---》》》线索id---{}",sellerId);
                 log.info("销售线索查询为空或已导入过联系方式---》》》线索id---{}",sellerId);
                 continue;
                 continue;
             }
             }
@@ -138,8 +140,6 @@ public class TelephoneRobotServiceImpl implements ITelephoneRobotService {
             param.put("companyName",saleInfo.getSellerName());
             param.put("companyName",saleInfo.getSellerName());
             param.put("phone",saleInfo.getTelephone());
             param.put("phone",saleInfo.getTelephone());
             param.put("website","");
             param.put("website","");
-            //修改线索的导入记录状态
-            saleClueInfoMapper.updateSaleClueImportPhoneFlag(sellerId,1);
 
 
             customerList.add(param);
             customerList.add(param);
         }
         }
@@ -171,6 +171,7 @@ public class TelephoneRobotServiceImpl implements ITelephoneRobotService {
         //更新最新的记录 用户信息
         //更新最新的记录 用户信息
         //1分钟只能调取导入接口一次 所以可以保证最新的记录就是刚通过回调接口回来的数据信息
         //1分钟只能调取导入接口一次 所以可以保证最新的记录就是刚通过回调接口回来的数据信息
         saleClueCallRecordMapper.updateCallRecordUser(userId,flowCode);
         saleClueCallRecordMapper.updateCallRecordUser(userId,flowCode);
+
         log.info("------更新操作用户-------");
         log.info("------更新操作用户-------");
         //查询 最新的记录
         //查询 最新的记录
         SaleClueCallRecordPojo recordPojo = saleClueCallRecordMapper.selectCallRecordInfo();
         SaleClueCallRecordPojo recordPojo = saleClueCallRecordMapper.selectCallRecordInfo();