郑永安
2023-06-19 59e91a4e9ddaf23cebb12993c774aa899ab22d16
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
175
176
177
178
179
180
181
182
183
184
185
186
187
188
189
190
191
192
193
194
195
196
197
198
199
200
201
202
203
204
205
206
207
208
209
210
211
212
213
214
215
216
217
218
219
220
221
222
223
224
225
226
227
228
229
230
231
232
233
234
235
236
237
238
239
240
241
242
243
244
245
246
247
248
249
250
251
252
253
254
255
256
257
258
package com.gk.firework.Controller;
 
import com.alibaba.fastjson.JSONObject;
import com.gk.firework.Controller.Base.BaseController;
import com.gk.firework.Domain.*;
import com.gk.firework.Domain.Enum.EnterpriseSafetySupervision;
import com.gk.firework.Domain.Enum.ErrorCode;
import com.gk.firework.Domain.Utils.*;
import com.gk.firework.Domain.Utils.Properties;
import com.gk.firework.Domain.Vo.RegisterVo;
import com.gk.firework.Service.*;
import io.swagger.annotations.Api;
import io.swagger.annotations.ApiImplicitParam;
import io.swagger.annotations.ApiImplicitParams;
import io.swagger.annotations.ApiOperation;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.validation.BindingResult;
import org.springframework.validation.FieldError;
import org.springframework.validation.annotation.Validated;
import org.springframework.web.bind.annotation.*;
import org.springframework.web.multipart.MultipartFile;
 
import java.util.*;
import java.util.stream.Collectors;
 
import static com.gk.firework.Domain.Enum.ErrorCode.ERROR_10001;
 
/**
 * @author : jingjy
 * @date : 2021/6/24 16:52
 */
@Api(tags = "注册信息")
@RequestMapping("/register")
@RestController
public class RegisterController extends BaseController {
 
    /** 未审核 **/
    private final Byte REVIEW_INCOMPLETE = 0;
    /** 审核通过 **/
    private final Byte REVIEW_APPROVE = 1;
    /** 审核拒绝 **/
    private final Byte REVIEW_REJECTION = 2;
 
    @Autowired
    private RegisterService registerService;
    @Autowired
    private EnterpriseResourceService enterpriseResourceService;
    @Autowired
    private EnterpriseService enterpriseService;
    @Autowired
    private UserService userService;
    @Autowired
    private BlackListService blackListService;
 
    @PostMapping("/add")
    public Msg addRegisterInfo(@Validated RegisterVo registerVo, BindingResult bindingResult){
        if (registerVo == null){
            return new Msg(ErrorCode.ERROR_10001);
        }
 
        if (bindingResult.hasErrors()) {
            StringBuilder stringBuilder = new StringBuilder();
            for (String s : bindingResult.getFieldErrors().stream()
                    .map(FieldError::getDefaultMessage).collect(Collectors.toList())) {
                stringBuilder.append(s);
                stringBuilder.append(",");
            }
            return new Msg(ErrorCode.ERROR_10002,stringBuilder.toString());
        }
 
        boolean isSupervision = false;
        for (EnterpriseSafetySupervision e : EnterpriseSafetySupervision.values()){
            if (registerVo.getType().equals(e.getMsg())){
                isSupervision = true;
            }
        }
 
        if (!isSupervision){
            return new Msg(ErrorCode.ERROR_10004,"企业类型无效");
        }
 
        if ((boolean)isEnterpriseNameExist(registerVo.getEnterprisename()).getResult()){
            return new Msg(ErrorCode.ERROR_10004,"企业名称已存在");
        }
 
        if ((boolean)isEnterpriseNumberExist(registerVo.getEnterprisenumber()).getResult()){
            return new Msg(ErrorCode.ERROR_10004,"企业编码已存在");
        }
 
        RegisterInfo registerInfo = BeanUtils.copy(registerVo,RegisterInfo.class);
        registerInfo.setCreatedat(new Date());
 
        registerService.save(registerInfo);
 
        Map<String,MultipartFile[]> map = new HashMap<>(8);
        map.put(RegisterVo.BUSINESS,registerVo.getBusinessLicense());
        map.put(RegisterVo.ID_CARD,registerVo.getIdCard());
        map.put(RegisterVo.LEGAL_PERSON,registerVo.getLegalPersonFile());
        map.put(RegisterVo.OPERATION,registerVo.getOperationQualification());
        map.put(RegisterVo.ESCORT_COMPANY,registerVo.getEscortCompany());
        map.put(RegisterVo.INSURANCE,registerVo.getInsurance());
        map.put(RegisterVo.PRODUCTION,registerVo.getSafetyProduction());
        Msg msg = uploadFiles(map,registerInfo);
        if (!msg.getCode().equals(ErrorCode.SUCCESS.getMsg())){
            return msg;
        }
 
        return success();
    }
 
    @ApiOperation(value = "注册信息审核", httpMethod = "POST")
    @ApiImplicitParams({
            @ApiImplicitParam(name = "id", value = "注册信息id",required = true),
            @ApiImplicitParam(name = "reviewResult",value = "审核结果(1.审核通过;2.审核驳回)",required = true),
            @ApiImplicitParam(name = "reviewContent",value = "审核意见"),
    })
    @PostMapping("/review")
    public Msg reviewRegister(@RequestBody JSONObject object){
        Long id = object.getLong("id");
        Byte reviewResult = object.getByte("reviewResult");
        String reviewContent = object.getString("reviewContent").trim();
        if (id == null || reviewResult == null){
            return new Msg(ErrorCode.ERROR_10001);
        }
        if (reviewResult.equals(REVIEW_INCOMPLETE)){
            return new Msg(ErrorCode.ERROR_10004);
        }else if (!(reviewResult.equals(REVIEW_REJECTION)||reviewResult.equals(REVIEW_APPROVE))){
            return new Msg(ErrorCode.ERROR_10004);
        }
 
        UserInfo userInfo = userService.getById(getUser().getId());
        //普通用户
        int normalUser = 3;
        if (userInfo.getType() == normalUser){
            return new Msg(ErrorCode.ERROR_70001);
        }
        RegisterInfo registerInfo = registerService.getById(id);
        if (registerInfo == null){
            return new Msg(ErrorCode.ERROR_50001);
        }
        if ((boolean)isEnterpriseNameExist(registerInfo.getEnterprisename()).getResult()){
            return new Msg(ErrorCode.ERROR_10004,"企业名称已存在");
        }
 
        if ((boolean)isEnterpriseNumberExist(registerInfo.getEnterprisenumber()).getResult()){
            return new Msg(ErrorCode.ERROR_10004,"企业编码已存在");
        }
 
        registerInfo.setReviewresult(reviewResult);
        registerInfo.setReviewat(new Date());
        registerInfo.setReviewer(getUser().getId().toString());
        registerInfo.setReviewcontent(reviewContent);
        registerService.updateById(registerInfo);
        if (reviewResult.equals(REVIEW_APPROVE)){
            //创建企业账户
            enterpriseService.addEnterpriseByRegister(registerInfo,userInfo);
        }
        return success();
    }
 
    /**
     * @Description: 根据企业名称判断企业是否存在
     */
    @GetMapping("/isNameExist")
    @ApiOperation(value = "企业名称是否存在", httpMethod = "GET")
    @ApiImplicitParam(name = "enterpriseName", value = "企业名称", required = true)
    public Msg isEnterpriseNameExist(@RequestParam("enterpriseName")String enterpriseName){
        if (StringUtils.isBlank(enterpriseName.trim())){
            return new Msg(ERROR_10001);
        }
        boolean flag = true;
        Enterprise enterprise = enterpriseService.selectEnterpriseByName(enterpriseName);
        if (enterprise == null){
            flag = false;
            return success(flag);
        }
        BlackList blackList = blackListService.getByEnterprisenumber(enterprise.getEnterprisenumber());
        if (blackList != null) flag = false;
        return success(flag);
 
    }
 
    /**
     * @Description: 根据企业编码判断企业是否存在
     */
    @GetMapping("/isNumberExist")
    @ApiOperation(value = "企业编码是否存在", httpMethod = "GET")
    @ApiImplicitParam(name = "enterpriseNumber", value = "企业编码", required = true)
    public Msg isEnterpriseNumberExist(@RequestParam("enterpriseNumber")String enterpriseNumber){
        if (StringUtils.isBlank(enterpriseNumber.trim())){
            return new Msg(ERROR_10001);
        }
        boolean flag = true;
        Enterprise enterprise = enterpriseService.selectEnterpriseByNumber(enterpriseNumber);
        if (enterprise == null){
            flag = false;
        }
        return success(flag);
    }
 
    @GetMapping("/review")
    public Msg getWaitReviewData(@RequestParam(value = "name", required = false) String name,
                                  @RequestParam(value = "type", required = false) String type,
                                  @RequestParam(value = "reviewResult", required = false) Integer reviewResult,
                                  @RequestParam(defaultValue = "0") Integer pageIndex,
                                  @RequestParam(defaultValue = "10") Integer pageSize,
                                  String sort, String order){
        Msg msg = new Msg(true);
 
        PageInfo pageInfo = new PageInfo(pageIndex, pageSize,sort,order);
        Map<String, Object> condition = new HashMap<>(4);
        if (StringUtils.isNotBlank(name)) {
            condition.put("name", name);
        }
        if (StringUtils.isNotBlank(type)) {
            condition.put("type", type);
        }
        if (reviewResult != null ){
            condition.put("reviewResult", reviewResult);
        }
        UserInfo userInfo = userService.getById(getUser().getId());
 
        pageInfo.setCondition(condition);
        registerService.selectDataGrid(pageInfo);
        msg.setResult(pageInfo);
        return msg;
    }
 
    private Msg uploadFiles(Map<String, MultipartFile[]> map, RegisterInfo registerInfo) {
        List<EnterpriseResource> adds = new ArrayList<>();
        try {
            for (Map.Entry<String, MultipartFile[]>entry : map.entrySet()){
                MultipartFile[] files = entry.getValue();
                if (files != null && files.length > 0) {
                    for (MultipartFile file : files) {
                        String name = UploadUtil.uploadFile(file, Properties.enterprisePath);
                        EnterpriseResource er = new EnterpriseResource();
                        er.setTabletype(entry.getKey());
                        er.setFilename(file.getOriginalFilename());
                        er.setUrl(Properties.enterprise + name);
                        er.setCreatetime(new Date());
                        er.setCreatebyname(registerInfo.getEnterprisename());
                        er.setBelongid(registerInfo.getId());
                        er.setValidflag(true);
                        adds.add(er);
                    }
                }
            }
            //执行
            enterpriseResourceService.saveBatch(adds);
            return success();
 
        } catch (Exception e) {
            return new Msg(ErrorCode.ERROR_40001,"文件上传失败");
        }
 
    }
}