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.Arrays;
|
import java.util.List;
|
import java.util.stream.Collectors;
|
|
@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 keyword, String classifyGrade, List<String> ids) {
|
return baseMapper.selectConfigList(page, state, keyword, classifyGrade, ids);
|
}
|
|
@Override
|
public List<TransactionEvent> selectConfigList(String keyword, String classifyGrade, List<String> ids) {
|
return baseMapper.selectConfigList(keyword, 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()));
|
List<TransactionEvent> transactionEventEntities = baseMapper.queryMatterNameList(keyWord, null);
|
List<String> list = new ArrayList<>();
|
for (TransactionEvent transactionEvent : transactionEventEntities) {
|
if (transactionEvent.getAssociateNames() != null) {
|
String[] associateNames = transactionEvent.getAssociateNames().split(",");
|
for (String associateName : associateNames) {
|
list.add(associateName);
|
}
|
}
|
}
|
List<KeywordEntity> keywordEntityList = new ArrayList<>();
|
|
String[] keywords = list.stream().distinct().collect(Collectors.joining(",")).split(",");//去重
|
for (String keyword : keywords) {
|
if (keyword != null && !keyword.equals("")) {
|
KeywordEntity keywordEntity = new KeywordEntity();
|
keywordEntity.setName(keyword);
|
keywordEntityList.add(keywordEntity);
|
}
|
}
|
queryResults.setKeywordAssociationList(keywordEntityList);
|
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.queryAssociateNamesList(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);
|
List<TransactionEvent> transactionEvents = baseMapper.queryAssociateNamesList(keyWord, null);
|
recommendResult.setTransactionEventList(transactionEventEntities);
|
List<String> list = new ArrayList<>();
|
for (TransactionEvent transactionEvent : transactionEvents) {
|
// 直接返回办事指南名称
|
list.add(transactionEvent.getMatterName());
|
// 遍历关键词列表 可能后面流程更改会遇到暂时保存代码;
|
/* if (transactionEvent.getAssociateNames() != null) {
|
String[] associateNames = transactionEvent.getAssociateNames().split(",");
|
for (String associateName : associateNames) {
|
list.add(associateName);
|
}
|
}*/
|
}
|
String[] keywords = list.stream().distinct().collect(Collectors.joining(",")).split(",");//去重
|
for (String keyword : keywords) {
|
if (keyword != null && !keyword.equals("")) {
|
KeywordEntity keywordEntity = new KeywordEntity();
|
keywordEntity.setName(keyword);
|
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(String keyWord) {
|
if (keyWord!=null&&keyWord!=""){
|
return baseMapper.selectList(new QueryWrapper<TransactionEvent>().lambda().like(TransactionEvent::getMatterName,keyWord));
|
}
|
else {
|
return baseMapper.selectList(new QueryWrapper<TransactionEvent>().lambda());
|
}
|
}
|
}
|
