init 2/14

kimi

2020-02-14 fa24d347d4c5a796297184f9957b0582dc52c66e

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
package com.highdatas.mdm.service.impl;
 
import com.baomidou.mybatisplus.mapper.EntityWrapper;
import com.baomidou.mybatisplus.mapper.Wrapper;
import com.highdatas.mdm.entity.Flows;
import com.highdatas.mdm.entity.Maintain;
import com.highdatas.mdm.entity.MaintainDetail;
import com.highdatas.mdm.entity.TUser;
import com.highdatas.mdm.pojo.ActivitiBusinessType;
import com.highdatas.mdm.pojo.ActivitiStatus;
import com.highdatas.mdm.pojo.Page;
import com.highdatas.mdm.pojo.Result;
import com.highdatas.mdm.service.*;
import com.highdatas.mdm.service.act.*;
import org.apache.commons.lang3.StringUtils;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;
 
import javax.servlet.http.HttpSession;
import java.util.*;
import java.util.stream.Collectors;
 
/**
 * @author kimi
 * @description
 * @date 2019-12-17 10:48
 */
 
@Service
public class ActivitiServiceImpl implements ActivitiService{
    @Autowired
    IdentityService identityService;
    @Autowired
    IMaintainService maintainService;
 
    @Autowired
    IMaintainDetailService maintainDetailService;
 
    @Autowired
    TaskService taskService;
 
    @Autowired
    IFlowsService flowsService;
 
    @Autowired
    ITUserService userService;
 
    @Autowired
    HistoryService historyService;
 
    @Autowired
    RepositoryService repositoryService;
 
    @Autowired
    RuntimeService runtimeService;
 
 
    @Override
    public Flows start(String key, HttpSession session, String maintainId, ActivitiBusinessType type) {
        identityService.setSession( session);
        Flows flows = new Flows();
        String id = UUID.randomUUID().toString().replaceAll("-", "");
        flows.setId(id);
        flows.setBusinessId(maintainId);
        flows.setBusinessType(type);
        flows.setStatus(ActivitiStatus.working);
        HashMap<String, Object> variableMap = new HashMap<>();
        variableMap.put("reasson", "申请审批");
        String workflowId = identityService.startProcess(id, key, null, variableMap);
        flows.setWorkflowId(workflowId);
        flows.setCreateTime(new Date());
        TUser user = (TUser) session.getAttribute("user");
        String user_id = user.getUserId();
        flows.setUserId(user_id);
        boolean inserted = flowsService.insert(flows);
        if (inserted) {
            return flows;
        } else {
            return null;
        }
    }
 
    @Override
    public Result todoTask(HttpSession session, String tableName, Integer pageNo, Integer pageSize) {
        taskService.setSession(session);
        List<String> todoTask = taskService.getTodoTask();
        if (todoTask.size() == 0) {
            return Result.success(null);
        }
 
        Wrapper<Flows> flowsWrapper = new EntityWrapper<Flows>().in("workflow_id", todoTask).eq("business_type", ActivitiBusinessType.maintain);
        flowsWrapper.orderBy("create_time desc");
        List<Flows> records = flowsService.selectList(flowsWrapper);
 
        List<Flows> result = new ArrayList<>();
 
        if (!StringUtils.isEmpty(tableName)) {
            records = records.stream()
                    .filter(flows -> maintainService.selectById(flows.getBusinessId()) != null)
                    .filter(flows -> maintainService.selectById(flows.getBusinessId()).getTableName().equalsIgnoreCase(tableName)).collect(Collectors.toList());
        }
        Page page = new Page(records.size());
        page.setPageNo(pageNo);
        if (pageSize != null) {
            page.setPageSize(pageSize);
        }
        records = records.stream().skip(page.getBeginRecordNo_1()).limit(pageSize).collect(Collectors.toList());
 
        for (Flows flow : records) {
            String userId = flow.getUserId();
            TUser user = userService.selectOne(new EntityWrapper<TUser>().eq("user_id", userId));
            if (user == null) {
                continue;
            }
            flow.setUserId(user.getUserName());
 
            String businessId = flow.getBusinessId();
            int recordCount = maintainDetailService.selectCount(new EntityWrapper<MaintainDetail>().eq("parent_id", businessId));
 
            if (!StringUtils.isEmpty(tableName)) {
                Maintain maintain = maintainService.selectById(businessId);
                if (maintain == null) {
                    continue;
                }
                if (!maintain.getTableName().equalsIgnoreCase(tableName)) {
                    continue;
                }
                flow.setRecordCount(recordCount);
            }
            result.add(flow);
        }
 
        com.baomidou.mybatisplus.plugins.Page<Flows> flowPages = new com.baomidou.mybatisplus.plugins.Page<>();
        flowPages.setRecords(records);
        flowPages.setSize(pageSize);
        flowPages.setCurrent(pageNo);
        flowPages.setTotal(page.getRecordCount());
        return Result.success(flowPages);
    }
}