Procházet zdrojové kódy

Merge remote-tracking branch 'origin/test' into test

zhaoxian před 3 roky
rodič
revize
7f1f37ec3d

Rozdílová data souboru nebyla zobrazena, protože soubor je příliš velký
+ 15 - 0
ruixuan-admin/src/main/resources/application-dev.yml


+ 23 - 0
ruixuan-salesLeads/src/main/java/com.ruixuan.salesLeads/constant/RobotConstant.java

@@ -0,0 +1,23 @@
+package com.ruixuan.salesLeads.constant;
+
+/**
+ * 外呼机器人
+ * 2022/7/1
+ **/
+public class RobotConstant {
+
+    /**
+     * api请求前缀
+     */
+    public static final String REQUEST_PREFIX = "http://jiqiren-external-api.weiwenjia.com";
+
+    /**
+     * 刷新token
+     */
+    public static final String REFRESH_TOKEN = REQUEST_PREFIX+"/api/v1/authorize";
+
+
+
+
+
+}

+ 23 - 0
ruixuan-salesLeads/src/main/java/com.ruixuan.salesLeads/controller/SaleClueInfoController.java

@@ -2,11 +2,14 @@ package com.ruixuan.salesLeads.controller;
 
 
 import com.alibaba.excel.util.ConverterUtils;
+import com.alibaba.fastjson.JSONObject;
 import com.ruixuan.common.core.controller.BaseController;
 import com.ruixuan.common.core.domain.ResultResponse;
+import com.ruixuan.common.core.redis.RedisCache;
 import com.ruixuan.common.utils.DateUtils;
 import com.ruixuan.common.utils.StringUtils;
 import com.ruixuan.common.utils.file.FileTypeUtils;
+import com.ruixuan.common.utils.http.HttpUtil;
 import com.ruixuan.salesLeads.listener.ImportExcelListener;
 import com.ruixuan.salesLeads.pojo.SaleClueInfoPojo;
 import com.ruixuan.salesLeads.pojo.SaleClueRecordInfoPojo;
@@ -15,13 +18,16 @@ import com.ruixuan.salesLeads.pojo.vo.SaleRecordVo;
 import com.ruixuan.salesLeads.pojo.vo.SaleTaskInfoVo;
 import com.ruixuan.salesLeads.service.ISaleClueInfoService;
 import com.ruixuan.salesLeads.service.ITestService;
+import com.ruixuan.salesLeads.service.impl.TelephoneRobotServiceImpl;
 import io.swagger.annotations.*;
 import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.beans.factory.annotation.Value;
 import org.springframework.web.bind.annotation.*;
 import org.springframework.web.multipart.MultipartFile;
 
 import java.io.File;
 import java.util.*;
+import java.util.concurrent.TimeUnit;
 import java.util.stream.Collectors;
 
 /**
@@ -44,6 +50,10 @@ public class SaleClueInfoController extends BaseController {
     private ISaleClueInfoService saleClueInfoServiceImpl;
 
 
+    @Autowired
+    private TelephoneRobotServiceImpl telephoneRobotService;
+
+
 
 
 
@@ -220,6 +230,19 @@ public class SaleClueInfoController extends BaseController {
 
 
 
+    @ApiOperation(value = "外呼机器人-获取token",notes = "外呼机器人-获取token")
+    @PostMapping(value = "/getTelephoneRobotToken")
+    public ResultResponse getTelephoneRobotToken(){
+        JSONObject jsonObject = telephoneRobotService.getTelephoneRobotToken();
+        return ResultResponse.successMsg("外呼机器人获取token成功",jsonObject);
+    }
+
+
+
+
+
+
+
 
 
 }

+ 24 - 0
ruixuan-salesLeads/src/main/java/com.ruixuan.salesLeads/service/ITelephoneRobotService.java

@@ -0,0 +1,24 @@
+package com.ruixuan.salesLeads.service;
+
+import com.alibaba.fastjson.JSONObject;
+import com.ruixuan.common.core.domain.ResultResponse;
+import com.ruixuan.salesLeads.pojo.SaleClueInfoPojo;
+import com.ruixuan.salesLeads.pojo.SaleClueRecordInfoPojo;
+import org.springframework.web.multipart.MultipartFile;
+
+import java.util.List;
+
+/**
+ * ***************************************************
+ *
+ * @Auther: zianY
+ * @Descipion: 外呼机器人api
+ * @CreateDate: 2022-07-01
+ * ****************************************************
+ */
+public interface ITelephoneRobotService {
+
+
+    JSONObject getTelephoneRobotToken();
+
+}

+ 98 - 0
ruixuan-salesLeads/src/main/java/com.ruixuan.salesLeads/service/impl/TelephoneRobotServiceImpl.java

@@ -0,0 +1,98 @@
+package com.ruixuan.salesLeads.service.impl;
+
+import com.alibaba.excel.EasyExcel;
+import com.alibaba.fastjson.JSONObject;
+import com.github.pagehelper.PageInfo;
+import com.ruixuan.common.core.domain.ResultResponse;
+import com.ruixuan.common.core.page.TableDataInfo;
+import com.ruixuan.common.core.redis.RedisCache;
+import com.ruixuan.common.utils.DateUtils;
+import com.ruixuan.common.utils.PageUtils;
+import com.ruixuan.common.utils.StringUtils;
+import com.ruixuan.common.utils.file.FileTypeUtils;
+import com.ruixuan.common.utils.http.HttpUtil;
+import com.ruixuan.salesLeads.constant.RobotConstant;
+import com.ruixuan.salesLeads.listener.ImportExcelListener;
+import com.ruixuan.salesLeads.mapper.SaleClueDistributionInfoMapper;
+import com.ruixuan.salesLeads.mapper.SaleClueInfoMapper;
+import com.ruixuan.salesLeads.mapper.SaleClueRecordInfoMapper;
+import com.ruixuan.salesLeads.mapper.SaleQuotaInfoMapper;
+import com.ruixuan.salesLeads.pojo.SaleClueDistributionInfoPojo;
+import com.ruixuan.salesLeads.pojo.SaleClueInfoPojo;
+import com.ruixuan.salesLeads.pojo.SaleClueRecordInfoPojo;
+import com.ruixuan.salesLeads.pojo.SaleQuotaInfoPojo;
+import com.ruixuan.salesLeads.pojo.vo.SaleRecordVo;
+import com.ruixuan.salesLeads.pojo.vo.SaleTaskInfoVo;
+import com.ruixuan.salesLeads.service.ISaleClueInfoService;
+import com.ruixuan.salesLeads.service.ITelephoneRobotService;
+import com.ruixuan.salesLeads.utils.CsvImportUtil;
+import com.ruixuan.system.domain.SysAreaInfo;
+import com.ruixuan.system.domain.SysIndustryInfo;
+import com.ruixuan.system.mapper.SysAreaInfoMapper;
+import com.ruixuan.system.mapper.SysIndustryInfoMapper;
+import lombok.extern.slf4j.Slf4j;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.beans.factory.annotation.Value;
+import org.springframework.stereotype.Service;
+import org.springframework.web.multipart.MultipartFile;
+
+import java.util.ArrayList;
+import java.util.HashMap;
+import java.util.List;
+import java.util.Map;
+import java.util.concurrent.TimeUnit;
+
+/**
+ * ***************************************************
+ *
+ * @Auther: zianY
+ * @Descipion: 外呼机器人api
+ * @CreateDate: 2022-07-01
+ * ****************************************************
+ */
+@Service
+@Slf4j
+public class TelephoneRobotServiceImpl implements ITelephoneRobotService {
+
+    @Value("${telephoneRobot.appKey}")
+    private String rebotAppkey;
+    @Value("${telephoneRobot.secret}")
+    private String rebotSecret;
+
+    @Autowired
+    private RedisCache redisCache;
+
+
+    /**
+     *
+     * @description: 外呼机器人获取token
+     *
+     * @param
+     * @return: com.ruixuan.common.core.domain.ResultResponse
+     * @author: zianY
+     */
+    @Override
+    public JSONObject getTelephoneRobotToken(){
+
+        JSONObject tokenObj = redisCache.getCacheObject("salesLeads:robotToken:str");
+        if (!StringUtils.isEmpty(tokenObj)){
+            log.info("外呼机器人获取redis中的token信息----->>>{}",tokenObj);
+            return tokenObj;
+        }
+        Map<String,Object> params = new HashMap<>();
+        params.put("appKey",rebotAppkey);
+        params.put("secret",rebotSecret);
+        /*Map<String,String> headers = new HashMap<>();
+        params.put("Auth-Token",);
+*/
+        String content = HttpUtil.httpPostRequest(RobotConstant.REFRESH_TOKEN,params,null);
+        JSONObject jsonObject = JSONObject.parseObject(content);
+        redisCache.setCacheObject("salesLeads:robotToken:str",jsonObject,2, TimeUnit.HOURS);
+        log.info("外呼机器人获取token信息----->>>{}",jsonObject);
+        return jsonObject;
+    }
+
+
+
+
+}