heheng
2025-11-20 5b60b28f6c9556ad438f55fe57c8d3edc32716ae
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
169
170
171
172
173
174
package com.gkhy.exam.system.service.impl;
 
import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
import com.gkhy.exam.common.api.CommonPage;
import com.gkhy.exam.common.api.CommonResult;
import com.gkhy.exam.common.exception.ApiException;
import com.gkhy.exam.common.utils.PageUtils;
import com.gkhy.exam.common.utils.SecurityUtils;
import com.gkhy.exam.system.domain.ContractReview;
import com.gkhy.exam.system.domain.ContractReviewMess;
import com.gkhy.exam.system.domain.ContractReviewMessb;
import com.gkhy.exam.system.domain.ContractReviewRequire;
import com.gkhy.exam.system.mapper.ContractReviewMapper;
import com.gkhy.exam.system.mapper.ContractReviewMessMapper;
import com.gkhy.exam.system.mapper.ContractReviewRequireMapper;
import com.gkhy.exam.system.service.ContractReviewService;
import org.apache.tomcat.websocket.AuthenticationException;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;
import org.springframework.transaction.annotation.Transactional;
 
import java.time.LocalDateTime;
import java.util.ArrayList;
import java.util.List;
import java.util.Map;
import java.util.stream.Collectors;
 
@Service
public class ContractReviewServiceImpl extends ServiceImpl<ContractReviewMapper, ContractReview> implements ContractReviewService {
 
    @Autowired
    private ContractReviewMapper contractReviewMapper;
 
    @Autowired
    private ContractReviewMessMapper contractReviewMessMapper;
 
    @Autowired
    private ContractReviewRequireMapper contractReviewRequireMapper;
 
 
    @Override
    public CommonPage selectContractReviewList(ContractReview contractReview) {
        if (!SecurityUtils.adminUser()){
            if (contractReview.getCompanyId()==null){
                throw new ApiException("非管理员操作,查询条件不可为空");
            }
        }
        PageUtils.startPage();
        List<ContractReview> contractReviews = contractReviewMapper.selectReviewList(contractReview);
        for (ContractReview review : contractReviews) {
            List<ContractReviewMess> contractReviewMesses = contractReviewMessMapper.selectByReviewId(review.getId());
            List<ContractReviewRequire> contractReviewRequires = contractReviewRequireMapper.selectByReviewId(review.getId());
            review.setReviewMesses(contractReviewMesses);
            review.setContractReviewRequires(contractReviewRequires);
        }
        return CommonPage.restPage(contractReviews);
    }
 
    @Override
    @Transactional
    public CommonResult insertContractReview(ContractReview contractReview) {
        if(contractReview.getType().equals(1)){
            Integer i = contractReviewMapper.selectByContractId(contractReview.getContractId());
            if (i>0){
                return CommonResult.failed("请勿重复添加数据");
            }
        }
        List<ContractReviewMess> reviewMesses = contractReview.getReviewMesses();
        List<ContractReviewRequire> contractReviewRequires = contractReview.getContractReviewRequires();
        contractReview.setCreateBy(SecurityUtils.getUsername());
        contractReview.setCreateTime(LocalDateTime.now());
        int insert = contractReviewMapper.insert(contractReview);
        if (insert>0){
            Integer reviewId = contractReview.getId();
 
            // 批量插入ContractReviewMess
            for (ContractReviewMess reviewMess : reviewMesses) {
                reviewMess.setReviewId(reviewId);
            }
            contractReviewMessMapper.insertMesses(reviewMesses);
 
            // 收集所有ContractReviewMessb
            List<ContractReviewMessb> allMessbs = new ArrayList<>();
            for (ContractReviewMess reviewMess : reviewMesses) {
                List<ContractReviewMessb> contractReviewMessbs = reviewMess.getContractReviewMessbs();
                if (contractReviewMessbs != null && !contractReviewMessbs.isEmpty()) {
                    for (ContractReviewMessb contractReviewMessb : contractReviewMessbs) {
                        contractReviewMessb.setMessId(reviewMess.getId());
                    }
                    allMessbs.addAll(contractReviewMessbs);
                }
            }
            // 批量插入ContractReviewMessb
            if (!allMessbs.isEmpty()) {
                contractReviewMessMapper.insertMessbs(allMessbs);
            }
 
            // 批量插入ContractReviewRequire
            for (ContractReviewRequire contractReviewRequire : contractReviewRequires) {
                contractReviewRequire.setReviewId(reviewId);
            }
            contractReviewRequireMapper.insertRequires(contractReviewRequires);
        }
        return CommonResult.success();
    }
 
    @Override
    @Transactional
    public CommonResult updateContractReview(ContractReview contractReview) {
        try {
            List<ContractReviewMess> reviewMesses = contractReview.getReviewMesses();
            List<ContractReviewRequire> contractReviewRequires = contractReview.getContractReviewRequires();
            // 更新主表信息
            contractReview.setUpdateBy(SecurityUtils.getUsername());
            contractReview.setUpdateTime(LocalDateTime.now());
            int i = contractReviewMapper.updateById(contractReview);
            if (i > 0) {
                Integer reviewId = contractReview.getId();
                // 删除旧的关联数据
                contractReviewMessMapper.deleteByReviewId(reviewId);
                contractReviewRequireMapper.deleteByReviewId(reviewId);
                // 插入新的ContractReviewMess数据并处理其子项
                if (reviewMesses != null && !reviewMesses.isEmpty()) {
                    // 设置reviewId并插入主表数据
                    for (ContractReviewMess reviewMess : reviewMesses) {
                        reviewMess.setReviewId(reviewId);
                    }
                    contractReviewMessMapper.insertMesses(reviewMesses);
                    // 处理ContractReviewMessb子项
                    List<ContractReviewMessb> allMessbs = new ArrayList<>();
                    for (ContractReviewMess reviewMess : reviewMesses) {
                        List<ContractReviewMessb> contractReviewMessbs = reviewMess.getContractReviewMessbs();
                        if (contractReviewMessbs != null && !contractReviewMessbs.isEmpty()) {
                            for (ContractReviewMessb contractReviewMessb : contractReviewMessbs) {
                                contractReviewMessb.setMessId(reviewMess.getId());
                            }
                            allMessbs.addAll(contractReviewMessbs);
                        }
                    }
                    // 批量插入ContractReviewMessb
                    if (!allMessbs.isEmpty()) {
                        contractReviewMessMapper.insertMessbs(allMessbs);
                    }
                }
                // 插入新的ContractReviewRequire数据
                if (contractReviewRequires != null && !contractReviewRequires.isEmpty()) {
                    for (ContractReviewRequire contractReviewRequire : contractReviewRequires) {
                        contractReviewRequire.setReviewId(reviewId);
                    }
                    contractReviewRequireMapper.insertRequires(contractReviewRequires);
                }
            }
            return CommonResult.success();
        } catch (Exception e) {
            // 记录日志
            log.error("更新合同评审失败", e);
            return CommonResult.failed("更新失败");
        }
    }
 
    @Override
    public CommonResult deletedContractReview(Integer reviewId) {
        ContractReview contractReview = new ContractReview();
        contractReview.setDelFlag(2);
        contractReview.setUpdateBy(SecurityUtils.getUsername());
        contractReview.setUpdateTime(LocalDateTime.now());
        contractReview.setId(reviewId);
        int i = contractReviewMapper.updateById(contractReview);
        if (i>0){
            return CommonResult.success();
        }
        return CommonResult.failed();
    }
}