@ -1,6 +1,7 @@
package com.baiye.module.service.impl ;
import cn.hutool.core.collection.CollUtil ;
import cn.hutool.core.collection.ListUtil ;
import cn.hutool.core.date.DateUtil ;
import cn.hutool.json.JSONArray ;
import cn.hutool.json.JSONObject ;
@ -8,17 +9,13 @@ import cn.hutool.json.JSONUtil;
import com.baiye.constant.DefaultNumberConstants ;
import com.baiye.exception.BadRequestException ;
import com.baiye.feign.OrganizeClient ;
import com.baiye.feign.ReportClient ;
import com.baiye.feign.TaskClient ;
import com.baiye.feign.UserClient ;
import com.baiye.model.dto.* ;
import com.baiye.model.vo.ResSourceLabel ;
import com.baiye.module.dao.ClueJpa ;
import com.baiye.module.dao.ClueMiddleRepository ;
import com.baiye.module.dao.ClueRecordRepository ;
import com.baiye.module.dao.ClueRepository ;
import com.baiye.module.entity.Clue ;
import com.baiye.module.entity.ClueMiddle ;
import com.baiye.module.entity.ClueRecord ;
import com.baiye.module.entity.Task ;
import com.baiye.module.dao.* ;
import com.baiye.module.entity.* ;
import com.baiye.module.entity.vo.BaseExcelVo ;
import com.baiye.module.service.ClueService ;
import com.baiye.module.service.dto.* ;
@ -38,6 +35,7 @@ import org.springframework.transaction.annotation.Transactional;
import javax.servlet.http.HttpServletResponse ;
import java.text.SimpleDateFormat ;
import java.util.* ;
import java.util.function.Function ;
import java.util.stream.Collectors ;
@Service
@ -53,6 +51,9 @@ public class ClueServiceImpl implements ClueService {
private final OrganizeClient organizeClient ;
private final RedisUtils redisUtils ;
private final TaskClient taskClient ;
private final ReportClient reportClient ;
private final UserClient userClient ;
private final ConductRecordRepository conductRecordRepository ;
private static SimpleDateFormat timeOne = new SimpleDateFormat ( "yyyyMMddHHmmssSSS" ) ;
@ -69,6 +70,8 @@ public class ClueServiceImpl implements ClueService {
clueMiddle . setTaskId ( taskId ) ;
clueMiddle . setMemberStatus ( DefaultNumberConstants . ZERO_NUMBER ) ;
clueMiddle . setOptimisticVersion ( DefaultNumberConstants . ZERO_NUMBER ) ;
clueMiddle . setClueStage ( DefaultNumberConstants . ZERO_NUMBER ) ;
clueMiddle . setClueCallStatus ( DefaultNumberConstants . ZERO_NUMBER ) ;
clueMiddleRepository . save ( clueMiddle ) ;
}
} catch ( Exception e ) {
@ -145,7 +148,7 @@ public class ClueServiceImpl implements ClueService {
}
}
}
return new ResponseEntity < > ( HttpStatus . OK ) ;
return new ResponseEntity < > ( null , HttpStatus . OK ) ;
}
/ * *
@ -156,6 +159,16 @@ public class ClueServiceImpl implements ClueService {
if ( clueQueryCriteria . getMemberId ( ) ! = null ) {
List < ClueDto > clueDtoList = clueJpa . getClueList ( clueQueryCriteria , pageable ) ;
Long count = clueJpa . getCount ( clueQueryCriteria ) ;
//查询线索记录
Set < Long > clueIdList = clueDtoList . stream ( ) . map ( ct - > ct . getId ( ) ) . collect ( Collectors . toSet ( ) ) ;
List < ConductRecord > conductRecords = conductRecordRepository . findByClueIdIn ( clueIdList ) ;
Map < Long , String > map = new HashMap < > ( ) ;
if ( CollUtil . isNotEmpty ( conductRecords ) ) {
List < ConductRecord > sortConductRecord = conductRecords . stream ( ) . sorted ( Comparator . comparing ( ConductRecord : : getCreateTime ) ) . collect ( Collectors . toList ( ) ) ;
for ( ConductRecord conductRecord : sortConductRecord ) {
map . put ( conductRecord . getClueId ( ) , conductRecord . getRecordInfo ( ) ) ;
}
}
// 列表中查询标签信息 和 axb请求字段
for ( ClueDto clueDto : clueDtoList ) {
String taskNameKey = "task:name:" + clueDto . getTaskId ( ) ;
@ -167,6 +180,9 @@ public class ClueServiceImpl implements ClueService {
str = body . get ( "taskName" ) . get ( 0 ) ;
}
clueDto . setTaskName ( str ) ;
if ( CollUtil . isNotEmpty ( map ) & & map . containsKey ( clueDto . getId ( ) ) ) {
clueDto . setClueRecord ( map . get ( clueDto . getId ( ) ) ) ;
}
}
return PageUtil . toPage ( clueDtoList , count ) ;
}
@ -180,9 +196,16 @@ public class ClueServiceImpl implements ClueService {
public List < ClueDto > query ( ClueQueryCriteria clueQueryCriteria ) {
if ( clueQueryCriteria . getMemberId ( ) ! = null ) {
List < ClueDto > clueDtoList = clueJpa . getClueList ( clueQueryCriteria , null ) ;
Set < Long > memberIds = clueDtoList . stream ( ) . map ( ca - > ca . getMemberId ( ) ) . collect ( Collectors . toSet ( ) ) ;
Map < Long , String > userNickNameMap = userClient . findById ( memberIds ) ;
// id查询(详情查询)时返回标签信息
if ( clueQueryCriteria . getId ( ) ! = null ) {
for ( ClueDto clueDto : clueDtoList ) {
//查询分配人的用户名称
Long memberId = clueDto . getMemberId ( ) ;
if ( memberId ! = null & & userNickNameMap . containsKey ( memberId ) ) {
clueDto . setDistributeUserName ( userNickNameMap . get ( memberId ) ) ;
}
//循环查库，
clueDto . setIsRedis ( 0 ) ;
Map < String , List < String > > mapList = organizeClient . getLabel ( clueDto ) . getBody ( ) ;
@ -232,6 +255,8 @@ public class ClueServiceImpl implements ClueService {
@Override
@Transactional ( rollbackFor = Exception . class )
public void update ( ClueMiddle clueMiddle ) {
//更新通话状态时不加锁
if ( clueMiddle . getClueCallStatus ( ) = = null ) {
//乐观锁,不用jpa查询(jpa有缓存这个坑)
if ( clueMiddle . getOptimisticVersion ( ) ! = null ) {
Integer version = clueMiddleRepository . lookUpOptimisticVersion ( clueMiddle . getClueId ( ) ) ;
@ -239,6 +264,7 @@ public class ClueServiceImpl implements ClueService {
throw new BadRequestException ( "刷新后重试" ) ;
}
}
}
ClueMiddle clueMiddleOne = clueMiddleRepository . findById ( clueMiddle . getClueId ( ) ) . orElseGet ( ClueMiddle : : new ) ;
if ( clueMiddle . getSourceLabel ( ) ! = null ) {
List < String > sourceLabelList = clueMiddle . getSourceLabel ( ) ;
@ -252,6 +278,12 @@ public class ClueServiceImpl implements ClueService {
if ( StringUtils . isNotBlank ( clueMiddle . getRemark ( ) ) ) {
clueMiddleOne . setRemark ( clueMiddle . getRemark ( ) ) ;
}
if ( clueMiddle . getClueStage ( ) ! = null ) {
clueMiddleOne . setClueStage ( clueMiddle . getClueStage ( ) ) ;
}
if ( clueMiddle . getClueCallStatus ( ) ! = null ) {
clueMiddleOne . setClueCallStatus ( clueMiddle . getClueCallStatus ( ) ) ;
}
clueMiddleOne . setOptimisticVersion ( clueMiddle . getOptimisticVersion ( ) + 1 ) ;
clueMiddleRepository . save ( clueMiddleOne ) ;
}
@ -264,6 +296,9 @@ public class ClueServiceImpl implements ClueService {
public void updateBatchMember ( ClueQueryCriteria clueQueryCriteria ) {
List < Long > clueIdList = clueQueryCriteria . getClueIdList ( ) ;
List < Long > userIdList = clueQueryCriteria . getUserIdList ( ) ;
if ( CollUtil . isEmpty ( clueIdList ) | | CollUtil . isEmpty ( userIdList ) ) {
throw new BadRequestException ( "资源和指派人不能为空，请选择后重试" ) ;
}
//Map<Long, List<Long>>：
List < Map < Long , List < Long > > > maps = AverageDataUtil . averageData ( clueIdList , userIdList ) ;
//批量更新组员信息
@ -377,13 +412,9 @@ public class ClueServiceImpl implements ClueService {
}
}
/ * *
* 查 询 资 源 公 海
* /
@Override
public Map < String , Object > queryCluePool ( ClueQueryCriteria clueQueryCriteria , Pageable pageable ) {
if ( clueQueryCriteria . getMemberId ( ) ! = null ) {
Set < Long > taskSet = new HashSet < > ( ) ;
TaskQueryCriteria taskQueryCriteria = new TaskQueryCriteria ( ) ;
taskQueryCriteria . setCreateBy ( clueQueryCriteria . getMemberId ( ) ) ;
taskQueryCriteria . setTaskType ( 1 ) ;
@ -394,6 +425,88 @@ public class ClueServiceImpl implements ClueService {
if ( clueQueryCriteria . getTaskId ( ) ! = null ) {
taskQueryCriteria . setId ( clueQueryCriteria . getTaskId ( ) ) ;
}
Map < String , Object > clueList = findClueList ( taskQueryCriteria , clueQueryCriteria , pageable ) ;
return clueList ;
} else {
log . info ( "========================用户id为空============================" ) ;
throw new BadRequestException ( "刷新后重试" ) ;
}
}
@Override
public Object withdrawSource ( List < Long > clueIds ) {
if ( CollUtil . isNotEmpty ( clueIds ) ) {
// 查询已打过电话的
List < Long > list = reportClient . getTurnOnIds ( clueIds ) . getData ( ) ;
if ( CollUtil . isNotEmpty ( list ) ) {
//过滤掉打过电话的线索ID
clueIds = clueIds . stream ( ) . filter ( num - > ! list . contains ( num ) ) . collect ( Collectors . toList ( ) ) ;
}
if ( CollUtil . isNotEmpty ( clueIds ) ) {
List < ClueMiddle > clueList = new ArrayList < > ( ) ;
List < ClueMiddle > clueAll = clueMiddleRepository . findAllById ( clueIds ) ;
for ( ClueMiddle clueMiddle : clueAll ) {
clueMiddle . setSourceLabel ( null ) ;
clueMiddle . setOptimisticVersion ( 0 ) ;
clueMiddle . setRemark ( null ) ;
clueMiddle . setMemberStatus ( 0 ) ;
clueMiddle . setMemberId ( null ) ;
clueMiddle . setOrganizeId ( null ) ;
clueMiddle . setClueStage ( 0 ) ;
clueList . add ( clueMiddle ) ;
}
clueMiddleRepository . saveAll ( clueList ) ;
}
}
return new ResponseEntity < > ( HttpStatus . OK ) ;
}
@Override
public Object findCompanyClue ( ClueQueryCriteria clueQueryCriteria , Pageable pageable ) {
TaskQueryCriteria taskQueryCriteria = new TaskQueryCriteria ( ) ;
taskQueryCriteria . setCreateBy ( clueQueryCriteria . getUserId ( ) ) ;
if ( clueQueryCriteria . getTaskName ( ) ! = null ) {
taskQueryCriteria . setBlurry ( clueQueryCriteria . getTaskName ( ) ) ;
}
Map < String , Object > clueList = findClueList ( taskQueryCriteria , clueQueryCriteria , pageable ) ;
return clueList ;
}
/ * *
* 分 页 查 询 任 务
*
* @param clueQueryCriteria 条 件
* @param pageable 分 页
* @return
* /
private Map < String , Object > findClueList ( TaskQueryCriteria taskQueryCriteria , ClueQueryCriteria clueQueryCriteria , Pageable pageable ) {
//获取所有任务id
Set < Long > taskIds = findTaskId ( taskQueryCriteria ) ;
if ( CollUtil . isNotEmpty ( taskIds ) ) {
List < Clue > clueAll = clueJpa . findClue ( taskIds , pageable , clueQueryCriteria ) ;
Set < Long > memberIds = clueAll . stream ( ) . map ( ca - > ca . getMemberId ( ) ) . collect ( Collectors . toSet ( ) ) ;
Map < Long , String > userNickNameMap = userClient . findById ( memberIds ) ;
for ( Clue clue : clueAll ) {
//获取缓存中任务名称
String str = findTaskName ( clue . getTaskId ( ) ) ;
clue . setTaskName ( str ) ;
//查询分配人的用户名称
Long memberId = clue . getMemberId ( ) ;
if ( memberId ! = null & & userNickNameMap . containsKey ( memberId ) ) {
clue . setDistributeUserName ( userNickNameMap . get ( memberId ) ) ;
}
}
Long count = clueJpa . getTaskCount ( taskIds , clueQueryCriteria ) ;
return PageUtil . toPage ( clueAll , count ) ;
}
return PageUtil . toPage ( new ArrayList < > ( ) , 0 ) ;
}
/ * *
* 获 取 任 务 id 集 合
* /
private Set < Long > findTaskId ( TaskQueryCriteria taskQueryCriteria ) {
Set < Long > taskSet = new HashSet < > ( ) ;
Object body = taskClient . query ( taskQueryCriteria ) . getBody ( ) ;
JSONArray taskList = JSONUtil . parseArray ( body ) ;
if ( CollUtil . isNotEmpty ( taskList ) ) {
@ -402,29 +515,24 @@ public class ClueServiceImpl implements ClueService {
long taskId = Long . parseLong ( String . valueOf ( task . get ( "id" ) ) ) ;
taskSet . add ( taskId ) ;
}
List < Clue > clueAll = clueJpa . findClue ( taskSet , pageable ) ;
for ( Clue clue : clueAll ) {
String taskNameKey = "task:name:" + clue . getTaskId ( ) ;
}
return taskSet ;
}
/ * *
* 获 取 缓 存 中 任 务 名 称
* /
private String findTaskName ( Long taskId ) {
String taskNameKey = "task:name:" + taskId ;
String str = ( String ) redisUtils . get ( taskNameKey ) ;
if ( str = = null | | str . equals ( "null" ) | | StringUtils . isBlank ( str ) ) {
//设置空,取值判断空
ClueDto clueDto = new ClueDto ( ) ;
clueDto . setIsRedis ( 1 ) ;
clueDto . setTaskId ( clue . getTaskId ( ) ) ;
clueDto . setTaskId ( ) ;
Map < String , List < String > > nameMap = organizeClient . getLabel ( clueDto ) . getBody ( ) ;
str = nameMap . get ( "taskName" ) . get ( 0 ) ;
}
clue . setTaskName ( str ) ;
}
Long count = clueJpa . getTaskCount ( taskSet ) ;
return PageUtil . toPage ( clueAll , count ) ;
return str ;
}
return PageUtil . toPage ( new ArrayList < > ( ) , 0 ) ;
} else {
log . info ( "========================用户id为空============================" ) ;
throw new BadRequestException ( "刷新后重试" ) ;
}
}
}
bynt
2 years ago