remove and commit

郑永安

2023-06-19 7a6abd05683528032687c75e80e0bd2030a3e46c

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
141
142
143
144
145
146
147
148
149
150
151
152
153
154
155
156
157
158
159
160
161
162
163
164
165
166
167
168
package com.gkhy.safePlatform.specialWork.service.baseService.impl;
 
import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
import com.gkhy.safePlatform.commons.enums.ResultCodes;
import com.gkhy.safePlatform.commons.exception.BusinessException;
import com.gkhy.safePlatform.specialWork.entity.WorkInfo;
import com.gkhy.safePlatform.specialWork.entity.WorkInfoDO;
import com.gkhy.safePlatform.specialWork.enums.WorkingAbortStatusEnum;
import com.gkhy.safePlatform.specialWork.enums.WorkingAnalysisStatusEnum;
import com.gkhy.safePlatform.specialWork.enums.WorkingStatusEnum;
import com.gkhy.safePlatform.specialWork.model.query.db.*;
import com.gkhy.safePlatform.specialWork.repository.WorkInfoRepository;
import com.gkhy.safePlatform.specialWork.service.baseService.WorkInfoService;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;
 
import java.time.LocalDateTime;
import java.util.List;
 
@Service("workInfoService")
public class WorkInfoServiceImpl extends ServiceImpl<WorkInfoRepository, WorkInfo> implements WorkInfoService {
 
    @Autowired
    private WorkInfoRepository workInfoRepository;
 
    @Override
    public void saveWorkInfo(WorkInfo workInfoEntity) {
        if (workInfoEntity == null) {
            throw new BusinessException(ResultCodes.SERVER_PARAM_NULL);
        }
        int i = workInfoRepository.insertWorkInfo(workInfoEntity);
        if (i != 1) {
            throw new BusinessException(ResultCodes.SERVER_ADD_ERROR);
        }
 
    }
 
    @Override
    public void updateWorkInfoById(WorkInfo workInfoEntity) {
        if (workInfoEntity == null || workInfoEntity.getId() == null) {
            throw new BusinessException(ResultCodes.SERVER_PARAM_NULL);
        }
        int i = workInfoRepository.updateWorkInfoById(workInfoEntity);
        if (i > 1) {
            throw new BusinessException(ResultCodes.SERVER_UPDATE_ERROR);
        }
        if (i == 0) {
            throw new BusinessException(ResultCodes.SERVER_UPDATE_DATA_NO_CHANGE);
        }
    }
 
    @Override
    public List<WorkInfoDO> listWorkInfoByPage(Page<WorkInfoDO> page, WorkPageDBQuery dbQuery) {
        if (page == null || dbQuery == null) {
            throw new BusinessException(ResultCodes.SERVER_PARAM_NULL);
        }
        return workInfoRepository.listWorkInfoDOByPage(page,dbQuery);
    }
 
    @Override
    public List<WorkInfoDO> listWorkInfoMyRefByPage(Page<WorkInfoDO> page, WorkMyRefPageDBQuery dbQuery) {
        if (page == null || dbQuery == null) {
            throw new BusinessException(ResultCodes.SERVER_PARAM_NULL);
        }
        return workInfoRepository.listWorkInfoDOMyRefByPage(page, dbQuery);
    }
 
    @Override
    public long countWorkInfoMyRef(WorkMyRefPageDBQuery dbQuery) {
        if (dbQuery == null) {
            throw new BusinessException(ResultCodes.SERVER_PARAM_NULL);
        }
        return workInfoRepository.countWorkInfoMyRef(dbQuery);
    }
 
    @Override
    public long countWorkInfo(WorkPageDBQuery dbQuery) {
        if (dbQuery == null) {
            throw new BusinessException(ResultCodes.SERVER_PARAM_NULL);
        }
        return workInfoRepository.countWorkInfo(dbQuery);
    }
 
    @Override
    public void updateWorkInfoStatusByWorkId(Long workId, WorkingStatusEnum workingStatusEnum) {
        if (workId == null || workingStatusEnum == null) {
            throw new BusinessException(ResultCodes.SERVER_PARAM_NULL);
        }
        int i = workInfoRepository.updateWorkStatusByWorkId(workId, workingStatusEnum.code);
        if (i != 1) {
            throw new BusinessException(ResultCodes.SERVER_UPDATE_ERROR);
        }
    }
 
    @Override
    public void updateWorkAnalysisStatusByWorkId(Long workId, WorkingAnalysisStatusEnum statusEnum) {
        if (workId == null | statusEnum == null) {
            throw new BusinessException(ResultCodes.SERVER_PARAM_NULL);
        }
        int i = workInfoRepository.updateWorkAnalysisStatusByWorkId(workId, statusEnum.code);
        if (i != 1) {
            throw new BusinessException(ResultCodes.SERVER_UPDATE_ERROR);
        }
    }
 
    @Override
    public List<WorkInfoDO> listWorkInfoGuardianByPage(Page<WorkInfo> page, WorkGuardianPageDBQuery dbQuery) {
        if (page == null || dbQuery == null) {
            throw new BusinessException(ResultCodes.SERVER_PARAM_NULL);
        }
        return workInfoRepository.listWorkInfoGuardianByPage(page,dbQuery);
    }
 
    @Override
    public List<WorkInfoDO> listWorkInfoAcceptByPage(Page<WorkInfo> page, WorkAcceptPageDBQuery dbQuery) {
        if (page == null || dbQuery == null) {
            throw new BusinessException(ResultCodes.SERVER_PARAM_NULL);
        }
        return workInfoRepository.listWorkInfoAcceptByPage(page, dbQuery);
    }
 
    @Override
    public List<WorkInfoDO> listWorkInfoAnalysisByPage(Page<WorkInfo> page, WorkAnalysisPageDBQuery dbQuery) {
        if (page == null || dbQuery == null) {
            throw new BusinessException(ResultCodes.SERVER_PARAM_NULL);
        }
        return workInfoRepository.listWorkInfoAnalysisByPage(page,dbQuery);
    }
 
    @Override
    public Integer countEvertWorkByOptions(WorkCountDbQuery workCountDbQuery) {
        if(workCountDbQuery == null)
            return 0;
        if(workCountDbQuery.getDepIdList() == null || workCountDbQuery.getDepIdList().isEmpty())
            return 0;
        Integer count = workInfoRepository.countByOptions(workCountDbQuery);
        return count;
    }
 
    @Override
    public Integer countAllWorkByDep(Long depId, LocalDateTime startTime, LocalDateTime endTime) {
        if(depId == null || depId < 1)
            return 0;
        return workInfoRepository.countAllWorkByDep(depId,startTime,endTime);
    }
 
    @Override
    public void updateWorkStatusAndAbortStatusByWorkId(Long workId, WorkingStatusEnum workStatus, WorkingAbortStatusEnum abortStatus) {
        if (workId == null || workStatus == null || abortStatus == null) {
            throw new BusinessException(ResultCodes.SERVER_PARAM_NULL);
        }
        int i = workInfoRepository.updateWorkStatusAndAbortStatusByWorkId(workId, workStatus, abortStatus);
        if (i != 1) {
            throw new BusinessException(ResultCodes.SERVER_UPDATE_ERROR);
        }
    }
 
    @Override
    public WorkInfo getWorkByWorkApplyId(Long workApplyId) {
        if(workApplyId == null){
            throw new BusinessException(ResultCodes.SERVER_PARAM_NULL);
        }
        return workInfoRepository.selectOne(new LambdaQueryWrapper<WorkInfo>()
                .eq(WorkInfo::getWorkApplyId,workApplyId));
    }
}