package com.whyc.service;
|
|
import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
|
import com.baomidou.mybatisplus.core.toolkit.Wrappers;
|
import com.github.pagehelper.PageHelper;
|
import com.github.pagehelper.PageInfo;
|
import com.whyc.dto.Response;
|
import com.whyc.mapper.WorkflowMainMapper;
|
import com.whyc.pojo.UserInf;
|
import com.whyc.pojo.WorkflowLink;
|
import com.whyc.pojo.WorkflowMain;
|
import com.whyc.util.ActionUtil;
|
import org.springframework.beans.factory.annotation.Autowired;
|
import org.springframework.stereotype.Service;
|
|
import javax.annotation.Resource;
|
import javax.servlet.ServletContext;
|
import java.text.SimpleDateFormat;
|
import java.util.*;
|
import java.util.stream.Collectors;
|
|
@Service
|
public class WorkflowMainService {
|
|
@Resource
|
private WorkflowMainMapper mapper;
|
|
@Autowired
|
private WorkflowLinkService linkService;
|
|
/**
|
* 分派单号:
|
* */
|
public String getNextOrderId(String typeName) {
|
ServletContext application = ActionUtil.getApplication();
|
List<String> orderIdList = (List) application.getAttribute("orderIdList");
|
if(orderIdList == null){
|
orderIdList = new LinkedList<>();
|
}
|
String nextSequence = "";
|
QueryWrapper<WorkflowMain> wrapper = Wrappers.query();
|
|
String orderId = "FG-"+typeName+"-";
|
String ymd = new SimpleDateFormat("yyyyMMdd").format(new Date());
|
orderId = orderId+ymd+"-";
|
//先查询是否缓存中是否存在前缀相同的单号,有的话存起来
|
List<Integer> sequenceList = new LinkedList<>();
|
sequenceList.add(0);
|
for (String item : orderIdList) {
|
if(item.startsWith(orderId)){
|
String sequence = item.split("-")[3];
|
sequenceList.add(Integer.parseInt(sequence));
|
}
|
}
|
wrapper.likeRight("order_id",orderId).orderByDesc("order_id").last(" limit 1");
|
WorkflowMain workflowMain = mapper.selectOne(wrapper);
|
if(workflowMain != null){
|
String sequence = workflowMain.getOrderId().split("-")[3];
|
sequenceList.add(Integer.parseInt(sequence));
|
}
|
Integer maxSequence = sequenceList.stream().max(Comparator.comparing(Integer::intValue)).get();
|
nextSequence = String.format("%05d", maxSequence+1);
|
String nextOrderId = orderId + nextSequence;
|
//加入缓存中
|
orderIdList.add(nextOrderId);
|
application.setAttribute("orderIdList",orderIdList);
|
return nextOrderId;
|
}
|
|
public void add(WorkflowMain main) {
|
mapper.insert(main);
|
}
|
|
public void addBatch(List<WorkflowMain> workflowMainList) {
|
mapper.insertBatchSomeColumn(workflowMainList);
|
}
|
|
|
public WorkflowMain getBaseInfo(Integer mainId) {
|
return mapper.getBaseInfo(mainId);
|
}
|
|
public List<WorkflowLink> getAssignReply(Integer mainId) {
|
QueryWrapper<WorkflowLink> wrapper = Wrappers.query();
|
//wrapper.eq("main_id",mainId)
|
//return linkMapper.
|
return null;
|
}
|
|
public void updateStatus(Integer id, Integer status,String endReason,Date endTime) {
|
WorkflowMain main = new WorkflowMain(id,status,endReason,endTime);
|
mapper.updateById(main);
|
}
|
|
/**
|
*
|
* @param userId
|
* @param type
|
* @see com.whyc.constant.WorkflowEnum
|
*
|
* @return
|
*/
|
public Response<Map<Integer,Integer>> getOwnStatistics(int userId, int type) {
|
Map<Integer,Integer> statistics = new HashMap<>();
|
statistics.put(1,0);
|
statistics.put(2,0);
|
statistics.put(3,0);
|
statistics.put(4,0);
|
QueryWrapper<WorkflowMain> query = Wrappers.query();
|
query.eq("create_user_id",userId);
|
List<WorkflowMain> mains = mapper.selectList(query);
|
Map<Integer, List<WorkflowMain>> statusListMap = mains.stream().collect(Collectors.groupingBy(WorkflowMain::getStatus));
|
Set<Integer> statusSet = statusListMap.keySet();
|
for (Integer status : statusSet) {
|
statistics.put(status,statusListMap.get(status).size());
|
}
|
return new Response<Map<Integer,Integer>>().set(1,statistics);
|
}
|
|
public Response<PageInfo<WorkflowMain>> ownListPage(int userId, int type, int status, int pageNum, int pageSize) {
|
PageHelper.startPage(pageNum,pageSize);
|
List<WorkflowMain> mains = getOwnListByUserAndType(userId,type,status);
|
PageInfo<WorkflowMain> pageInfo = new PageInfo<>(mains);
|
return new Response<PageInfo<WorkflowMain>>().set(1,pageInfo);
|
}
|
|
private List<WorkflowMain> getOwnListByUserAndType(int userId, int type, int status) {
|
QueryWrapper<WorkflowMain> query = Wrappers.query();
|
query.eq("create_user_id",userId).eq("type",type).eq("status",status);
|
return mapper.selectList(query);
|
}
|
|
public Response<Map<Integer,Integer>> getReceivedStatistics(int type, UserInf user) {
|
Map<Integer,Integer> statisticsMap = linkService.getReceivedStatistics(type,user);
|
return new Response<Map<Integer,Integer>>().set(1,statisticsMap);
|
}
|
|
public Response<PageInfo<WorkflowMain>> getReceivedListPage(int type, int status, UserInf user, int pageNum, int pageSize) {
|
PageHelper.startPage(pageNum,pageSize);
|
List<WorkflowMain> mains = getReceivedListByUserAndType(user,type,status);
|
PageInfo<WorkflowMain> pageInfo = new PageInfo<>(mains);
|
return new Response<PageInfo<WorkflowMain>>().set(1,pageInfo);
|
}
|
|
private List<WorkflowMain> getReceivedListByUserAndType(UserInf user, int type, int status) {
|
return mapper.getReceivedListByUserAndType(user,type,status);
|
}
|
}
|
