SaleClueInfoController.java 12 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284
  1. package com.ruixuan.salesLeads.controller;
  2. import com.alibaba.excel.util.ConverterUtils;
  3. import com.alibaba.fastjson.JSONObject;
  4. import com.ruixuan.common.annotation.RateLimiter;
  5. import com.ruixuan.common.core.controller.BaseController;
  6. import com.ruixuan.common.core.domain.ResultResponse;
  7. import com.ruixuan.common.core.redis.RedisCache;
  8. import com.ruixuan.common.utils.DateUtils;
  9. import com.ruixuan.common.utils.StringUtils;
  10. import com.ruixuan.common.utils.file.FileTypeUtils;
  11. import com.ruixuan.common.utils.http.HttpUtil;
  12. import com.ruixuan.salesLeads.listener.ImportExcelListener;
  13. import com.ruixuan.salesLeads.pojo.SaleClueCallRecordPojo;
  14. import com.ruixuan.salesLeads.pojo.SaleClueInfoPojo;
  15. import com.ruixuan.salesLeads.pojo.SaleClueRecordInfoPojo;
  16. import com.ruixuan.salesLeads.pojo.TestPojo;
  17. import com.ruixuan.salesLeads.pojo.vo.SaleRecordVo;
  18. import com.ruixuan.salesLeads.pojo.vo.SaleTaskInfoVo;
  19. import com.ruixuan.salesLeads.service.ISaleClueCallRecordService;
  20. import com.ruixuan.salesLeads.service.ISaleClueInfoService;
  21. import com.ruixuan.salesLeads.service.ITestService;
  22. import com.ruixuan.salesLeads.service.impl.TelephoneRobotServiceImpl;
  23. import io.swagger.annotations.*;
  24. import lombok.extern.slf4j.Slf4j;
  25. import org.springframework.beans.factory.annotation.Autowired;
  26. import org.springframework.beans.factory.annotation.Value;
  27. import org.springframework.web.bind.annotation.*;
  28. import org.springframework.web.multipart.MultipartFile;
  29. import java.io.File;
  30. import java.util.*;
  31. import java.util.concurrent.TimeUnit;
  32. import java.util.stream.Collectors;
  33. /**
  34. * ***************************************************
  35. *
  36. * @Auther: zianY
  37. * @Descipion: 销售线索
  38. * @CreateDate: 2022-05-19
  39. * ****************************************************
  40. */
  41. @Slf4j
  42. @Api(tags = "销售线索",description = "saleClueInfoController")
  43. @RestController
  44. @RequestMapping("sale/saleClueInfoController")
  45. public class SaleClueInfoController extends BaseController {
  46. @Autowired
  47. private ISaleClueInfoService saleClueInfoServiceImpl;
  48. @Autowired
  49. private TelephoneRobotServiceImpl telephoneRobotService;
  50. @ApiOperation(value = "销售线索上传",notes = "swagger不支持上传,请使用postman上传,支持form-data。文件绑定参数为file")
  51. @PostMapping(value = "/importSaleExcelOrCsv")
  52. public ResultResponse importSaleExcelOrCsv(
  53. @ApiParam("文件数组") @RequestParam("file") MultipartFile file,
  54. @ApiParam("销售线索类型1:50W低潜;2:50W中高潜;3:200W高潜;4:200W-500w;5:500W") @RequestParam("salesLeadsType") int salesLeadsType,
  55. @ApiParam("年-月") @RequestParam("uploadDate") String uploadDate,
  56. @ApiParam("创建人") @RequestParam("createUserId") Long createUserId
  57. ) throws Exception{
  58. if (file.isEmpty()){
  59. return ResultResponse.error("文件不能为空,请选择文件!");
  60. }
  61. if (!FileTypeUtils.fileNameSuffix(file)){
  62. return ResultResponse.error("请上传正确格式的文件,支持扩展名.xls;.xlsx;.csv");
  63. }
  64. Long year = DateUtils.strDateToInt(uploadDate);
  65. return saleClueInfoServiceImpl.importSaleExcelOrCsv(file,salesLeadsType,year,createUserId);
  66. }
  67. @ApiOperation(value = "销售线索列表查询",notes = "销售线索列表查询,查询条件为空时,所对应的字段可以不传。")
  68. @GetMapping(value = "/selectSaleClueInfoList")
  69. public ResultResponse<List<SaleClueInfoPojo>> selectSaleClueInfoList(
  70. @ApiParam("卖家昵称") @RequestParam(value = "sellerName",required = false) String sellerName,
  71. @ApiParam("年-月") @RequestParam(value = "uploadDate", required = false) String uploadDate,
  72. @ApiParam("是否分配销售 0-否 1-是") @RequestParam(value = "distributionSaleFlag",required = false)String distributionSaleFlag,
  73. @ApiParam("行业id") @RequestParam(value = "industryId",required = false)String industryId,
  74. @ApiParam("粉丝量级 1:0~50w 2:50W~200W 3:200W~500W 4:500W以上") @RequestParam(value = "fansType",required = false)String fansType,
  75. @ApiParam("状态 1-未开始 2-进行中 3-已结束") @RequestParam(value = "state",required = false)String state,
  76. @ApiParam("状态 1-未开始 2-进行中 3-已结束") @RequestParam(value = "salesLeadsType",required = false)String salesLeadsType,
  77. @ApiParam("当前用户id") @RequestParam(value = "userId",required = false) Long userId) throws Exception{
  78. return saleClueInfoServiceImpl.selectSaleClueInfoList(sellerName,
  79. StringUtils.isEmpty(uploadDate) ? null : DateUtils.strDateToInt(uploadDate),
  80. distributionSaleFlag,industryId,fansType,state,salesLeadsType, userId);
  81. }
  82. @ApiOperation(value = "销售线索-分配-显示数据信息",notes = "销售线索-分配-显示数据信息(可以传多个卖家id)")
  83. @GetMapping(value = "/selectSaleClueInfoBySellers")
  84. public ResultResponse<List<SaleClueInfoPojo>> selectSaleClueInfoBySellers(
  85. @ApiParam(value = "卖家ids") @RequestParam(value = "sellerIds") List<String> sellerIds){
  86. List<Long> longList = sellerIds.stream().map(sellerId -> Long.parseLong(sellerId.trim())).collect(Collectors.toList());
  87. return saleClueInfoServiceImpl.selectSaleClueInfoBySellers(longList);
  88. }
  89. @ApiOperation(value = "销售线索-分配",notes = "销售线索-分配-(可以传多个卖家id)")
  90. @PostMapping(value = "/saleClueDistribution")
  91. public ResultResponse saleClueDistribution(
  92. @ApiParam(value = "卖家ids") @RequestParam(value = "sellerIds") String sellerIds,
  93. @ApiParam(value = "销售id") @RequestParam(value = "saleId") Long saleId,
  94. @ApiParam(value = "创建人id") @RequestParam(value = "createUserId") Long createUserId){
  95. List<String> sellerList = Arrays.asList(StringUtils.split(sellerIds,","));
  96. return saleClueInfoServiceImpl.saleClueDistribution(sellerList,saleId,createUserId);
  97. }
  98. @ApiOperation(value = "销售线索-转面销",notes = "销售线索-转面销")
  99. @PostMapping(value = "/saleClueToOffline")
  100. public ResultResponse saleClueToOffline(@ApiParam(value = "卖家id") @RequestParam(value = "sellerId") Long sellerId,
  101. //@ApiParam(value = "类型1-电销 2-面销") @RequestParam(value = "offlineSaleFlag") String offlineSaleFlag,
  102. @ApiParam(value = "销售id") @RequestParam(value = "saleId") Long saleId,
  103. @ApiParam(value = "创建人id") @RequestParam(value = "createUserId") Long createUserId){
  104. return saleClueInfoServiceImpl.saleClueToOffline(sellerId, 2,saleId,createUserId);
  105. }
  106. @ApiOperation(value = "销售线索任务列表查询",notes = "销售线索任务列表查询")
  107. @GetMapping(value = "/selectSaleClueTaskList")
  108. public ResultResponse<List<SaleClueInfoPojo>> selectSaleClueTaskList(
  109. @ApiParam("模糊查询") @RequestParam(value = "sellerName",required = false) String sellerName,
  110. @ApiParam("状态 1-未开始 2-进行中 3-已结束") @RequestParam(value = "state",required = false)Integer state,
  111. @ApiParam("当前用户id") @RequestParam(value = "userId") Long userId){
  112. return saleClueInfoServiceImpl.selectSaleClueTaskList(sellerName,state, userId);
  113. }
  114. @ApiOperation(value = "销售线索任务-查询用户代办以及本周完成的数量汇总",notes = "complete-本周完成数量;noStarted-我的待办")
  115. @GetMapping(value = "/getTaskNumber")
  116. public ResultResponse getTaskNumber(@ApiParam("当前用户id") @RequestParam(value = "userId") Long userId){
  117. return saleClueInfoServiceImpl.getTaskNumber(userId);
  118. }
  119. @ApiOperation(value = "销售线索任务-回显线索详情",notes = "回显线索详情")
  120. @GetMapping(value = "/getSaleTaskInfoBySellerId")
  121. public ResultResponse<SaleTaskInfoVo> getSaleTaskInfoBySellerId(@ApiParam("卖家id") @RequestParam(value = "sellerId") Long sellerId){
  122. return saleClueInfoServiceImpl.getSaleTaskInfoBySellerId(sellerId);
  123. }
  124. @ApiOperation(value = "销售线索任务-新增跟进记录",notes = "销售线索任务-新增跟进记录")
  125. @PostMapping(value = "/insertSaleTaskRecord")
  126. public ResultResponse insertSaleTaskRecord(SaleClueRecordInfoPojo recordInfoPojo){
  127. return saleClueInfoServiceImpl.insertSaleTaskRecord(recordInfoPojo);
  128. }
  129. @ApiOperation(value = "销售线索-基础-根据角色显示销售线索分类",notes = "销售线索-基础-根据角色显示销售线索分类(销售线索类型1:50W低潜;2:50W中高潜3:200W高潜4:200W-500w5:500W)")
  130. @GetMapping(value = "/getSaleTypeByRoleCode")
  131. public ResultResponse getSaleTypeByRoleCode(@ApiParam("角色code") @RequestParam(value = "roleCode") String roleCode){
  132. List<Map<String,String>> resultList = new ArrayList<>();
  133. Map<String,String> map1 = new HashMap<>();
  134. map1.put("salesLeadsType","1");
  135. map1.put("salesLeadsName","50W低潜");
  136. Map<String,String> map2 = new HashMap<>();
  137. map2.put("salesLeadsType","2");
  138. map2.put("salesLeadsName","50W中高潜");
  139. Map<String,String> map3 = new HashMap<>();
  140. map3.put("salesLeadsType","3");
  141. map3.put("salesLeadsName","200W高潜");
  142. Map<String,String> map4 = new HashMap<>();
  143. map4.put("salesLeadsType","4");
  144. map4.put("salesLeadsName","200W-500w");
  145. Map<String,String> map5 = new HashMap<>();
  146. map5.put("salesLeadsType","5");
  147. map5.put("salesLeadsName","500W");
  148. resultList.add(map1);
  149. resultList.add(map2);
  150. resultList.add(map3);
  151. resultList.add(map4);
  152. resultList.add(map5);
  153. //电销
  154. //50w 排第一个
  155. //面销
  156. if (roleCode.contains("facePin")){
  157. resultList.remove(map3);
  158. //200W 排第一个
  159. resultList.add(0,map3);
  160. }
  161. return ResultResponse.successMsg("查询成功",resultList);
  162. }
  163. @ApiOperation(value = "外呼机器人-获取token",notes = "外呼机器人-获取token")
  164. @PostMapping(value = "/getTelephoneRobotToken")
  165. public ResultResponse getTelephoneRobotToken(){
  166. JSONObject jsonObject = telephoneRobotService.getTelephoneRobotToken();
  167. return ResultResponse.successMsg("外呼机器人获取token成功",jsonObject);
  168. }
  169. @Autowired
  170. private ISaleClueCallRecordService saleClueCallRecordService;
  171. @ApiOperation(value = "回调地址",notes = "回调地址")
  172. @PostMapping(value = "/robotCallbackUrl")
  173. public ResultResponse robotCallbackUrl(@RequestBody JSONObject json){
  174. log.info("=======推送数据信息开始========");
  175. return saleClueCallRecordService.saveClueCallInfo(json);
  176. }
  177. @ApiOperation(value = "外呼机器人-导入号码",notes = "外呼机器人-导入号码")
  178. //@RateLimiter(count = 1)
  179. @PostMapping(value = "/importRobotTelephone")
  180. public ResultResponse importRobotTelephone(@ApiParam(value = "卖家ids") @RequestParam(value = "sellerIds") List<Long> sellerIds,
  181. @ApiParam(value = "用户id") @RequestParam(value = "userId") String userId) throws Exception {
  182. if (sellerIds.size() > 5000){
  183. return ResultResponse.error("单次最大导入号码数量不能超过5000条!");
  184. }
  185. return telephoneRobotService.importRobotTelephone(sellerIds,userId);
  186. }
  187. @ApiOperation(value = "外呼机器人-外呼记录查询",notes = "外呼机器人-外呼记录查询")
  188. @GetMapping(value = "/getRobotTelephoneRecordList")
  189. public ResultResponse<List<SaleClueCallRecordPojo>> getRobotTelephoneRecordList(){
  190. return telephoneRobotService.getRobotTelephoneRecordList();
  191. }
  192. }