众泰项目新迁

郑永安

2023-09-19 69185134fcfaf913ea45f1255677225a2cc311a4

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
package com.gk.hotwork.doublePrevention.service.baseService.impl;
 
import com.baomidou.mybatisplus.core.metadata.IPage;
import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
import com.gk.hotwork.Domain.Enum.ResultCodes;
import com.gk.hotwork.Domain.Exception.BusinessException;
import com.gk.hotwork.doublePrevention.entity.PreventDangerCheckTaskUnit;
import com.gk.hotwork.doublePrevention.entity.dto.req.PreventDangerCheckTaskUnitQueryReqDTO;
import com.gk.hotwork.doublePrevention.repository.PreventDangerCheckTaskUnitRepository;
import com.gk.hotwork.doublePrevention.repository.param.PreventDangerCheckTaskUnitDeleteParams;
import com.gk.hotwork.doublePrevention.repository.param.PreventDangerCheckTaskUnitUpdateParams;
import com.gk.hotwork.doublePrevention.service.baseService.PreventDangerCheckTaskUnitService;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;
 
import java.util.List;
 
@Service("PreventDangerCheckTaskUnitService")
public class PreventDangerCheckTaskUnitServiceImpl
        extends ServiceImpl<PreventDangerCheckTaskUnitRepository, PreventDangerCheckTaskUnit> implements PreventDangerCheckTaskUnitService {
 
    @Autowired
    private PreventDangerCheckTaskUnitRepository preventDangerCheckTaskUnitRepository;
 
    /**
     * 隐患排查任务单元-分页查询
     */
    @Override
    public IPage<PreventDangerCheckTaskUnit> getTaskUnitPage(Page<Object> page, PreventDangerCheckTaskUnitQueryReqDTO taskUnitQueryReqDTO) {
 
        return preventDangerCheckTaskUnitRepository.getTaskUnitPage(page, taskUnitQueryReqDTO);
    }
 
    /**
     * 隐患排查任务单元-通过名称查询单元信息
     */
    @Override
    public PreventDangerCheckTaskUnit getTaskUnitByName(String taskUnitName) {
        return preventDangerCheckTaskUnitRepository.getTaskUnitByName(taskUnitName);
    }
 
    /**
     * 隐患排查任务单元-新增
     */
    @Override
    public int saveTaskUnit(PreventDangerCheckTaskUnit taskUnit) {
        int insertResult = preventDangerCheckTaskUnitRepository.insert(taskUnit);
        if (insertResult == 0){
            throw new BusinessException(ResultCodes.SERVER_ADD_ERROR);
        }
        return insertResult;
    }
 
    /**
     * 隐患排查任务单元-修改
     */
    @Override
    public int updateTaskUnit(PreventDangerCheckTaskUnitUpdateParams updateParams) {
        int i = preventDangerCheckTaskUnitRepository.updateTaskUnit(updateParams);
        if (i == 0) {
            throw new BusinessException(ResultCodes.SERVER_UPDATE_ERROR);
        }
        return i;
    }
    /**
     * 隐患排查任务单元-删除
     */
    @Override
    public int deleteTaskUnit(PreventDangerCheckTaskUnitDeleteParams deleteParams) {
        int i = preventDangerCheckTaskUnitRepository.deleteTaskUnit(deleteParams);
        if (i == 0) {
            throw new BusinessException(ResultCodes.SERVER_UPDATE_ERROR);
        }
        return i;
    }
 
    /**
     * 隐患排查任务单元-
     * 根据名称修改关联作业id
     */
    @Override
    public PreventDangerCheckTaskUnit updateWorkIdByUnitName(String taskUnitName, Long checkWorkId) {
 
        return preventDangerCheckTaskUnitRepository.updateWorkIdByUnitName(taskUnitName, checkWorkId);
    }
 
    /**
     * 隐患排查任务单元-
     * 根据workId 查询
     */
    @Override
    public PreventDangerCheckTaskUnit getTaskUnitByWorkId(Long workId) {
        return preventDangerCheckTaskUnitRepository.getTaskUnitByWorkId(workId);
    }
 
    /**
     * 隐患排查任务单元-重置关联任务单元workId
     * 根据taskUnitName
     */
    @Override
    public void deleteWorkIdByUnitName(String taskUnitName) {
        int result = preventDangerCheckTaskUnitRepository.deleteWorkIdByUnitName(taskUnitName);
        if (result == 0) {
            throw new BusinessException(ResultCodes.SERVER_UPDATE_ERROR);
        }
    }
 
    /**
     * 隐患排查任务单元-根据Id查询
     */
    @Override
    public PreventDangerCheckTaskUnit getTaskUnitById(Long id) {
        return preventDangerCheckTaskUnitRepository.getTaskUnitById(id);
    }
 
    /**
     * 隐患排查任务单元-
     * 根据unitId 修改 workId
     */
    @Override
    public void updateWorkIdByUnitId(Long taskUnitId, Long checkWorkId , String checkWorkUuid) {
        preventDangerCheckTaskUnitRepository.updateWorkIdByUnitId(taskUnitId, checkWorkId ,checkWorkUuid);
    }
 
    /**
     * 隐患作业id,重置与任务单元的关联
     */
    @Override
    public void deleteByWorkId(Long workId) {
        int result = preventDangerCheckTaskUnitRepository.deleteByWorkId(workId);
        if (result == 0) {
            throw new BusinessException(ResultCodes.SERVER_UPDATE_ERROR);
        }
    }
    /**
     * 隐患排查任务单元-任务单元列表
     */
    @Override
    public List<PreventDangerCheckTaskUnit> listTaskUnit() {
        return preventDangerCheckTaskUnitRepository.listTaskUnit();
    }
}