package com.dg.core.service.impl;
|
|
|
import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
|
import com.baomidou.mybatisplus.core.metadata.IPage;
|
import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
|
import com.dg.core.db.gen.entity.*;
|
import com.dg.core.db.gen.mapper.AutomessageTransactionEventInterviewMapper;
|
import com.dg.core.db.gen.mapper.KeywordMapper;
|
import com.dg.core.db.gen.mapper.OrganizationChartMapper;
|
import com.dg.core.db.gen.mapper.TransactionEventMapper;
|
import com.dg.core.db.manual.pojo.QueryResults;
|
import com.dg.core.db.manual.pojo.RecommendResult;
|
import com.dg.core.db.manual.pojo.Search;
|
import com.dg.core.service.ITransactionEventService;
|
|
import org.springframework.stereotype.Service;
|
|
import javax.annotation.Resource;
|
import java.time.LocalDate;
|
import java.time.LocalDateTime;
|
import java.time.format.DateTimeFormatter;
|
import java.util.ArrayList;
|
import java.util.List;
|
|
@Service
|
public class TransactionEventImpl extends ServiceImpl<TransactionEventMapper, TransactionEvent> implements ITransactionEventService {
|
|
@Resource
|
private OrganizationChartMapper organizationChartMapper;
|
|
@Resource
|
private KeywordMapper keywordMapper;
|
|
@Resource
|
private AutomessageTransactionEventInterviewMapper automessageTransactionEventInterviewMapper;
|
|
@Override
|
public TransactionEvent selectConfigData(String Id,SysUser sysUser) {
|
TransactionEvent transactionEvent = baseMapper.selectConfigData(Id);
|
//如果当前没有登录用户则不增加浏览次数
|
if (sysUser!=null){
|
LocalDateTime startTime = LocalDate.now().atTime(0, 0, 0);
|
LocalDateTime endTime = LocalDate.now().atTime(23, 59, 59);
|
AutomessageTransactionEventInterview automessageTransactionEventInterview = automessageTransactionEventInterviewMapper.selectOne(new QueryWrapper<AutomessageTransactionEventInterview>()
|
.lambda().eq(AutomessageTransactionEventInterview::getTransactionEventId, Id)
|
.eq(AutomessageTransactionEventInterview::getUserId, sysUser.getUserId())
|
.orderByDesc(AutomessageTransactionEventInterview::getInterviewTime)
|
.last("limit 1"));
|
transactionEvent.setQueryTime(LocalDateTime.now());
|
//判断上次访问时间是不是今天 如果是今天不增加浏览次数
|
if (automessageTransactionEventInterview==null||(!(transactionEvent.getQueryTime().isAfter(startTime)&&transactionEvent.getQueryTime().isBefore(endTime)))) {
|
transactionEvent.setBrowseNum(transactionEvent.getBrowseNum()+1);
|
baseMapper.updateById(transactionEvent);
|
AutomessageTransactionEventInterview automessageTransactionEventInterviewNew =
|
new AutomessageTransactionEventInterview();
|
automessageTransactionEventInterviewNew.setTransactionEventId(Integer.valueOf(Id));
|
automessageTransactionEventInterviewNew.setUserId(new Long(sysUser.getUserId()));
|
automessageTransactionEventInterviewNew.setInterviewTime(LocalDateTime.now());
|
automessageTransactionEventInterviewMapper.insert(automessageTransactionEventInterviewNew);
|
}
|
}
|
return transactionEvent;
|
}
|
|
@Override
|
public List<TransactionEvent> selectConfigList(IPage<TransactionEvent> page, Integer state,
|
String matterAndUser, String classifyGrade,List<String> ids) {
|
return baseMapper.selectConfigList(page, state, matterAndUser, classifyGrade,ids);
|
}
|
|
@Override
|
public int insertConfig(TransactionEvent entity) {
|
return baseMapper.insertConfig(entity);
|
}
|
|
@Override
|
public int updateConfig(TransactionEvent entity) {
|
return baseMapper.updateConfig(entity);
|
}
|
|
@Override
|
public int deleteConfigById(String Id) {
|
return baseMapper.deleteConfigById(Id);
|
}
|
|
@Override
|
public int countNum(String matterAndUser,String classifyGrade,List<String> ids) {
|
return baseMapper.countNum( matterAndUser, classifyGrade, ids);
|
}
|
|
@Override
|
public QueryResults queryMatterNameList(IPage<Search> page,Integer state, Integer recommendSize,String keyWord) {
|
QueryResults queryResults = new QueryResults();
|
List<Search> searches = baseMapper.selectSearch(page, state, keyWord);
|
queryResults.setSearchList(searches);
|
List<Search> searchesAssociate = baseMapper.selectSearchAssociate(page, recommendSize, keyWord);
|
queryResults.setTransactionEventList(searchesAssociate);
|
queryResults.setKeywordEntityList( keywordMapper.selectByName(keyWord));
|
queryResults.setTotal((baseMapper.selectSearch(keyWord).size())+(baseMapper.selectSearchAssociate(keyWord).size()));
|
return queryResults;
|
}
|
|
@Override
|
public QueryResults queryMatterNameList(String keyWord) {
|
QueryResults queryResults = new QueryResults();
|
List<Search> searches = baseMapper.selectSearchList(keyWord);
|
for (Search search:searches) {
|
search.setTransactionEventList(baseMapper.queryMatterNameList(keyWord,search.getClassifyId().toString()));
|
}
|
queryResults.setSearchList(searches);
|
List<Search> searchesAssociate = baseMapper.selectSearchAssociateDistinct(keyWord);
|
for (Search search:searchesAssociate) {
|
search.setTransactionEventList(baseMapper.queryMatterNameList(keyWord,search.getClassifyId().toString()));
|
}
|
queryResults.setTransactionEventList(searchesAssociate);
|
queryResults.setKeywordEntityList( keywordMapper.selectByName(keyWord));
|
return queryResults;
|
}
|
|
|
@Override
|
public RecommendResult smartConsulting(String keyWord){
|
RecommendResult recommendResult=new RecommendResult();
|
List<KeywordEntity> keywordEntityList=new ArrayList<>();
|
List<TransactionEvent> transactionEventEntities = baseMapper.queryMatterNameList(keyWord,null);
|
recommendResult.setTransactionEventList(transactionEventEntities);
|
for (TransactionEvent transactionEvent: transactionEventEntities) {
|
if (transactionEvent.getAssociateNames()!=null) {
|
String[] associateNames = transactionEvent.getAssociateNames().split(",");
|
for (String associateName : associateNames) {
|
KeywordEntity keywordEntity = new KeywordEntity();
|
keywordEntity.setName(associateName);
|
keywordEntityList.add(keywordEntity);
|
}
|
}
|
}
|
recommendResult.setKeywordEntityList(keywordEntityList);
|
List<OrganizationChartEntity> organizationChartEntities = organizationChartMapper.selectByKeyWord(keyWord);
|
recommendResult.setOrganizationChartEntityList(organizationChartEntities);
|
return recommendResult;
|
}
|
|
@Override
|
public String selectDataIfExist(String departmentId, String matterName) {
|
return baseMapper.selectDataIfExist(departmentId,matterName);
|
}
|
|
@Override
|
public List<String> selectclassifyId(String classifyId) {
|
return baseMapper.selectclassifyId(classifyId);
|
}
|
|
|
@Override
|
public int countNumByMatterName(String matterName) {
|
return baseMapper.countNumByMatterName(matterName);
|
}
|
|
@Override
|
public List<TransactionEvent> queryByClassifyIdList(String classifyId,Integer departmentId) {
|
return baseMapper.queryByClassifyIdList(classifyId,departmentId);
|
}
|
|
@Override
|
public List<TransactionEvent> queryByClassifyIdList(IPage<TransactionEvent> page, Integer state,String classifyId,Integer departmentId) {
|
return baseMapper.queryByClassifyIdList(page,state,classifyId,departmentId);
|
}
|
|
@Override
|
public List<TransactionEvent> queryByQueryTime() {
|
List<TransactionEvent> transactionEvents = baseMapper.selectList(new QueryWrapper<TransactionEvent>().lambda().orderByDesc(TransactionEvent::getQueryTime));
|
return transactionEvents;
|
}
|
|
@Override
|
public List<TransactionEvent> queryByBrowseNum() {
|
List<TransactionEvent> transactionEvents = baseMapper.selectList(new QueryWrapper<TransactionEvent>().lambda().orderByDesc(TransactionEvent::getBrowseNum));
|
return transactionEvents;
|
}
|
|
@Override
|
public TransactionEvent sumTransactionNum() {
|
return baseMapper.sumTransactionNum();
|
}
|
|
@Override
|
public int countNumByClassifyIdList(String classifyId, Integer departmentId) {
|
return baseMapper.countNumByClassifyIdList(classifyId,departmentId);
|
}
|
|
@Override
|
public List<TransactionEvent> selectList(){
|
return baseMapper.selectList(new QueryWrapper<TransactionEvent>().lambda());
|
}
|
}
|
