JxglController.java 81.2 KB
Newer Older
1 2 3
package cn.timer.api.controller.jxgl;

import java.util.List;
4
import java.util.stream.Collectors;
5

tangzhaoqian committed
6 7
import javax.validation.constraints.NotNull;

8 9 10
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.transaction.annotation.Transactional;
import org.springframework.validation.annotation.Validated;
11 12 13
import org.springframework.web.bind.annotation.DeleteMapping;
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.PathVariable;
14
import org.springframework.web.bind.annotation.PostMapping;
15
import org.springframework.web.bind.annotation.PutMapping;
16 17
import org.springframework.web.bind.annotation.RequestBody;
import org.springframework.web.bind.annotation.RequestMapping;
tangzhaoqian committed
18
import org.springframework.web.bind.annotation.RequestParam;
19 20
import org.springframework.web.bind.annotation.RestController;

21
import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
22
import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
tangzhaoqian committed
23
import com.baomidou.mybatisplus.core.conditions.update.UpdateWrapper;
24 25
import com.baomidou.mybatisplus.core.metadata.IPage;
import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
26 27 28
import com.github.xiaoymin.knife4j.annotations.ApiOperationSupport;

import cn.hutool.core.bean.BeanUtil;
29
import cn.hutool.core.collection.CollUtil;
tangzhaoqian committed
30
import cn.hutool.core.collection.CollectionUtil;
31
import cn.hutool.core.collection.ListUtil;
tangzhaoqian committed
32
import cn.hutool.core.lang.Console;
33
import cn.hutool.core.util.ObjectUtil;
34
import cn.timer.api.aspect.lang.annotation.Log;
35
import cn.timer.api.aspect.lang.annotation.Role;
36
import cn.timer.api.aspect.lang.enums.BusinessType;
37 38 39
import cn.timer.api.bean.jxgl.JxglAppraisal;
import cn.timer.api.bean.jxgl.JxglAppraisalAssessment;
import cn.timer.api.bean.jxgl.JxglAppraisalIndicators;
tangzhaoqian committed
40
import cn.timer.api.bean.jxgl.JxglAppraisalIndicatorsAssessment;
41
import cn.timer.api.bean.jxgl.JxglAppraisalIndicatorsT;
42
import cn.timer.api.bean.jxgl.JxglAppraisalItem;
43
import cn.timer.api.bean.jxgl.JxglAppraisalItemT;
44
import cn.timer.api.bean.jxgl.JxglAppraisalLog;
45
import cn.timer.api.bean.jxgl.JxglAppraisalT;
46
import cn.timer.api.bean.jxgl.JxglBasicSetting;
47
import cn.timer.api.bean.jxgl.JxglPerformanceAppraisal;
48
import cn.timer.api.bean.jxgl.JxglPerformanceRating;
49
import cn.timer.api.bean.jxgl.JxglProcessNode;
tangzhaoqian committed
50
import cn.timer.api.bean.qyzx.QyzxEmpEntAsso;
51 52
import cn.timer.api.bean.spmk.SpmkApproveSummary;
import cn.timer.api.bean.yggl.YgglMainEmp;
tangzhaoqian committed
53
import cn.timer.api.bean.zzgl.ZzglBmgwM;
54 55
import cn.timer.api.config.annotation.CurrentUser;
import cn.timer.api.config.annotation.UserBean;
56 57
import cn.timer.api.config.enuminterface.JxglEnumInterface.AppraisalLogType;
import cn.timer.api.config.enuminterface.JxglEnumInterface.AppraisalSts;
tangzhaoqian committed
58
import cn.timer.api.config.enuminterface.JxglEnumInterface.AssessmentType;
59 60
import cn.timer.api.config.enuminterface.JxglEnumInterface.BeingAppraisalSts;
import cn.timer.api.config.enuminterface.JxglEnumInterface.BeingAppraisalType;
61
import cn.timer.api.config.enuminterface.JxglEnumInterface.ExecuteType;
tangzhaoqian committed
62 63
import cn.timer.api.config.enuminterface.JxglEnumInterface.IndicatorsType;
import cn.timer.api.config.enuminterface.JxglEnumInterface.PerformanceAppraisalSts;
64 65
import cn.timer.api.config.enuminterface.JxglEnumInterface.ProcessNodeSts;
import cn.timer.api.config.enuminterface.JxglEnumInterface.ProcessType;
tangzhaoqian committed
66
import cn.timer.api.config.enums.SysRoleType;
67
import cn.timer.api.config.exception.CustomException;
tangzhaoqian committed
68
import cn.timer.api.config.validation.ValidList;
69
import cn.timer.api.controller.jxgl.service.JxglService;
70 71 72
import cn.timer.api.controller.yggl.service.YgglService;
import cn.timer.api.controller.zzgl.service.ZzglBmgwMService;
import cn.timer.api.dao.jxgl.JxglAppraisalAssessmentMapper;
tangzhaoqian committed
73
import cn.timer.api.dao.jxgl.JxglAppraisalIndicatorsAssessmentMapper;
74
import cn.timer.api.dao.jxgl.JxglAppraisalIndicatorsMapper;
75
import cn.timer.api.dao.jxgl.JxglAppraisalIndicatorsTMapper;
76
import cn.timer.api.dao.jxgl.JxglAppraisalItemMapper;
77
import cn.timer.api.dao.jxgl.JxglAppraisalItemTMapper;
78 79
import cn.timer.api.dao.jxgl.JxglAppraisalLogMapper;
import cn.timer.api.dao.jxgl.JxglAppraisalMapper;
80
import cn.timer.api.dao.jxgl.JxglAppraisalTMapper;
81
import cn.timer.api.dao.jxgl.JxglBasicSettingMapper;
82
import cn.timer.api.dao.jxgl.JxglPerformanceAppraisalMapper;
83
import cn.timer.api.dao.jxgl.JxglPerformanceRatingMapper;
84
import cn.timer.api.dao.jxgl.JxglProcessNodeMapper;
tangzhaoqian committed
85
import cn.timer.api.dao.qyzx.QyzxEmpEntAssoMapper;
86
import cn.timer.api.dao.yggl.YgglMainEmpMapper;
tangzhaoqian committed
87 88
import cn.timer.api.dao.zzgl.ZzglBmgwMMapper;
import cn.timer.api.dto.jxgl.AppraisalAssessment;
89 90
import cn.timer.api.dto.jxgl.AppraisalDetail;
import cn.timer.api.dto.jxgl.AppraisalQuery;
tangzhaoqian committed
91 92 93
import cn.timer.api.dto.jxgl.AppraisalReject;
import cn.timer.api.dto.jxgl.AppraisalUpdate;
import cn.timer.api.dto.jxgl.AppraisalUpdateSts;
94
import cn.timer.api.dto.jxgl.BeingAppraisalPerson;
95 96
import cn.timer.api.dto.jxgl.EmpAppraisalQuery;
import cn.timer.api.dto.jxgl.EmpPerformanceQuery;
tangzhaoqian committed
97
import cn.timer.api.dto.jxgl.MyPerformance;
98 99
import cn.timer.api.dto.jxgl.PerformanceAppraisal;
import cn.timer.api.dto.jxgl.PerformanceAppraisalQuery;
100
import cn.timer.api.dto.jxgl.ProcessNode;
101
import cn.timer.api.dto.jxgl.ProcessNodeUpdate;
102 103
import cn.timer.api.utils.Result;
import cn.timer.api.utils.ResultUtil;
104
import cn.timer.api.utils.StreamUtils;
105 106 107 108 109 110
import io.swagger.annotations.Api;
import io.swagger.annotations.ApiOperation;

@Api(tags = "3.1绩效管理")
@RestController
@Transactional(rollbackFor = Exception.class)
111
@RequestMapping(value = "/jxgl", produces = { "application/json", "multipart/form-data" })
112 113 114
public class JxglController {

	@Autowired
tangzhaoqian committed
115 116 117 118 119 120 121 122 123
	private YgglService ygglService;
	
	@Autowired
	private JxglService jxglService;
	
	@Autowired
	private ZzglBmgwMService zzglBmgwMService;
	
	@Autowired
tangzhaoqian committed
124
	private ZzglBmgwMMapper zzglBmgwMMapper;
125

tangzhaoqian committed
126
	@Autowired
127
	private JxglBasicSettingMapper jxglBasicSettingMapper;
128

129 130
	@Autowired
	private JxglPerformanceRatingMapper jxglPerformanceRatingMapper;
131

132 133
	@Autowired
	private JxglAppraisalTMapper jxglAppraisalTMapper;
134

135 136
	@Autowired
	private JxglAppraisalIndicatorsTMapper jxglAppraisalIndicatorsTMapper;
137

138 139
	@Autowired
	private JxglAppraisalItemTMapper jsxglAppraisalItemTMapper;
140

tangzhaoqian committed
141 142
	@Autowired
	private JxglAppraisalAssessmentMapper jxglAppraisalAssessmentMapper;
143

tangzhaoqian committed
144 145
	@Autowired
	private JxglAppraisalIndicatorsAssessmentMapper jxglAppraisalIndicatorsAssessmentMapper;
146 147 148 149 150 151 152 153 154 155 156 157 158 159 160 161 162 163

	@Autowired
	private JxglPerformanceAppraisalMapper jxglPerformanceAppraisalMapper;

	@Autowired
	private JxglAppraisalMapper jxglAppraisalMapper;

	@Autowired
	private JxglAppraisalIndicatorsMapper jxglAppraisalIndicatorsMapper;

	@Autowired
	private JxglAppraisalLogMapper jxglAppraisalLogMapper;

	@Autowired
	private YgglMainEmpMapper ygglMainEmpMapper;
	
	@Autowired
	private JxglProcessNodeMapper jxglProcessNodeMapper;
tangzhaoqian committed
164
	
165 166
	@Autowired
	private JxglAppraisalItemMapper jxglAppraisalItemMapper;
tangzhaoqian committed
167 168 169
	
	@Autowired
	private QyzxEmpEntAssoMapper qyzxEmpEntAssoMapper;
170 171

	// TODO 基础设置
172 173 174 175 176 177
	/**
	 * 新增或编辑-基础设置
	 */
	@PostMapping(value = "/save_basic_setting")
	@ApiOperation(value = "1.新增或编辑-基础设置", httpMethod = "POST", notes = "新增或编辑-审批模板组")
	@ApiOperationSupport(order = 1)
178
	@Role
179 180
	public Result<Object> saveAtg(@CurrentUser UserBean userBean, @Validated @RequestBody JxglBasicSetting basicSetting)
			throws Exception {
181
		Integer orgCode = userBean.getOrgCode();
182

183
		List<JxglPerformanceRating> listPr = basicSetting.getPerformanceRatings();
tangzhaoqian committed
184
		if (CollectionUtil.isNotEmpty(listPr)) {
185
			for (JxglPerformanceRating pr : listPr) {
186
				if (pr.getSectionMaxScore() > basicSetting.getMaxScore()) {
187 188 189
					return ResultUtil.error("区间值不能超过最高分");
				} else if (pr.getSectionMinScore() >= pr.getSectionMaxScore()) {
					return ResultUtil.error("区间值设置不正确");
190 191 192 193
				}
			}
		}
		JxglBasicSetting bS = jxglBasicSettingMapper.selectOne(new QueryWrapper<JxglBasicSetting>().lambda()
194
				.select(JxglBasicSetting::getId).eq(JxglBasicSetting::getOrgCode, orgCode));
195 196 197 198 199
		if (bS != null) {
			// 删除 绩效等级
			jxglPerformanceRatingMapper.delete(new QueryWrapper<JxglPerformanceRating>().lambda()
					.eq(JxglPerformanceRating::getBasicSettingId, bS.getId()));
			// 删除 基础设置
200 201
			jxglBasicSettingMapper
					.delete(new QueryWrapper<JxglBasicSetting>().lambda().eq(JxglBasicSetting::getOrgCode, orgCode));
202
		}
203

204 205
		basicSetting.setOrgCode(orgCode);
		basicSetting.insert();
tangzhaoqian committed
206
		if (CollectionUtil.isNotEmpty(listPr)) {
207 208 209 210 211 212 213
			listPr.stream().forEach(pr -> pr.setBasicSettingId(basicSetting.getId()));
			int i = jxglPerformanceRatingMapper.insertList(listPr);
		}

		return ResultUtil.success();

	}
214
	
215 216 217 218 219 220
	/**
	 * 查询-基础设置
	 */
	@GetMapping(value = "/select_basic_setting")
	@ApiOperation(value = "2.查询-基础设置", httpMethod = "GET", notes = "查询-基础设置")
	@ApiOperationSupport(order = 2)
221 222
	public Result<Object> selectAT(@CurrentUser UserBean userBean) {

223
		JxglBasicSetting bS = jxglService.selectAT(userBean.getOrgCode());
224
		
225
		return ResultUtil.data(bS);
226

227
	}
228 229

	// TODO 考核模板
230 231 232 233 234 235
	/**
	 * 新增或编辑-考核模板
	 */
	@PostMapping(value = "/save_appraisal_t")
	@ApiOperation(value = "3.新增或编辑-考核模板", httpMethod = "POST", notes = "新增或编辑-考核模板")
	@ApiOperationSupport(order = 3)
236
	@Role
237 238 239 240 241
	public Result<Object> saveAtg(@CurrentUser UserBean userBean, @Validated @RequestBody JxglAppraisalT jxglAppraisalT)
			throws Exception {

		if (jxglAppraisalT.getId() != null && jxglAppraisalT.selectCount(
				new QueryWrapper<JxglAppraisalT>().lambda().eq(JxglAppraisalT::getId, jxglAppraisalT.getId())) > 0) {
242
			jxglAppraisalT.updateById();
243
		} else {
244
			jxglAppraisalT.setOrgCode(userBean.getOrgCode());
245 246 247
			jxglAppraisalT.insert();
		}
		LambdaQueryWrapper<JxglAppraisalIndicatorsT> q = new QueryWrapper<JxglAppraisalIndicatorsT>().lambda()
248 249 250 251 252
				.eq(JxglAppraisalIndicatorsT::getAppraisalTId, jxglAppraisalT.getId());

		List<JxglAppraisalIndicatorsT> listAIT = jxglAppraisalIndicatorsTMapper
				.selectList(q.select(JxglAppraisalIndicatorsT::getId));

tangzhaoqian committed
253
		List<Integer> listAITId = CollectionUtil.isNotEmpty(listAIT)
254 255 256
				? listAIT.stream().map(JxglAppraisalIndicatorsT::getId).collect(Collectors.toList())
				: null;

257 258 259
		// 删除 原 考核指标模板
		jxglAppraisalIndicatorsTMapper.delete(q);
		// 删除 原 考核项模板
tangzhaoqian committed
260
		if (CollectionUtil.isNotEmpty(listAITId)) {
261 262 263
			jsxglAppraisalItemTMapper.delete(new QueryWrapper<JxglAppraisalItemT>().lambda()
					.in(JxglAppraisalItemT::getAppraisalIndicatorsTId, listAITId));
		}
264

265
		List<JxglAppraisalIndicatorsT> aITs = jxglAppraisalT.getAppraisalIndicatorsTs();
266
		
tangzhaoqian committed
267
		if (CollectionUtil.isNotEmpty(aITs)) {
268
			
tangzhaoqian committed
269
//			Integer weightSum = 0;
270 271 272 273 274
			for (JxglAppraisalIndicatorsT aIT : aITs) {
				
				if (aIT.getType() == null) {
					throw new CustomException("指标类型未设置");
				}
275
				Integer weightNum = aIT.getWeight() == null ? 0 : aIT.getWeight();
tangzhaoqian committed
276
//				weightSum += weightNum;
277 278
				
				aIT.setWeight(weightNum);
279 280 281 282 283 284 285 286 287 288 289
				aIT.setAppraisalTId(jxglAppraisalT.getId());
				// 新增 考核指标模板
				if (aIT.insert()) {
					List<JxglAppraisalItemT> aItemTs = aIT.getAppraisalItemTs();
					if (aItemTs != null && aItemTs.size() > 0) {
						// 批量新增 考核项模板
						aItemTs.stream().forEach(aItemT -> aItemT.setAppraisalIndicatorsTId(aIT.getId()));
						int c = jsxglAppraisalItemTMapper.insertList(aItemTs);
					}
				} else {
					throw new Exception();
290
				}
291

292
			}
293
			
tangzhaoqian committed
294 295
//			if (!weightSum.equals(100))
//				throw new CustomException("权重总和要等于 100%");
296
			
297 298
		}
		return ResultUtil.success();
299
	}
300

301 302 303
	/**
	 * 查询-考核模板-列表
	 */
tangzhaoqian committed
304 305
	@PostMapping(value = "/selects_appraisal_t")
	@ApiOperation(value = "4.查询-考核模板-列表", httpMethod = "POST", notes = "查询-考核模板-列表")
306
	@ApiOperationSupport(order = 4)
307 308 309 310 311
	public Result<Object> selectListAT(@CurrentUser UserBean userBean, @RequestBody cn.timer.api.utils.Page page) {

		IPage<JxglAppraisalT> p = new Page<JxglAppraisalT>(page.getCurrentPage(), page.getTotalPage());

		IPage<JxglAppraisalT> pageAT = jxglAppraisalTMapper.selectPage(p,
312 313 314 315
				new QueryWrapper<JxglAppraisalT>().lambda()
				.eq(JxglAppraisalT::getOrgCode, userBean.getOrgCode())
				.orderByDesc(JxglAppraisalT::getId)
				);
316

317
		List<JxglAppraisalT> listAT = pageAT.getRecords();
318

319
		return ResultUtil.data(pageAT, listAT);
320

321
	}
322

323 324 325 326 327 328
	/**
	 * 查询-考核模板-详情
	 */
	@GetMapping(value = "/selects_appraisal_t/{id}")
	@ApiOperation(value = "5.查询-考核模板-详情", httpMethod = "GET", notes = "查询-考核模板-详情")
	@ApiOperationSupport(order = 5)
329
	@Role
330 331
	public Result<Object> selectAT(@CurrentUser UserBean userBean, @PathVariable Integer id) {

332
		JxglAppraisalT aT = jxglAppraisalTMapper.selectDetailById(id);
333

334
		return ResultUtil.data(aT);
335

336
	}
337

338 339 340 341 342 343
	/**
	 * 删除-考核模板
	 */
	@DeleteMapping(value = "/del_appraisal_t/{id}")
	@ApiOperation(value = "6.删除-考核模板", httpMethod = "DELETE", notes = "删除-考核模板")
	@ApiOperationSupport(order = 6)
344
	@Role
345 346 347
	public Result<Object> delAT(@CurrentUser UserBean userBean, @PathVariable Integer id) throws Exception {

		jxglAppraisalTMapper.delete(new QueryWrapper<JxglAppraisalT>().lambda().eq(JxglAppraisalT::getId, id)
348
				.eq(JxglAppraisalT::getOrgCode, userBean.getOrgCode()));
349 350

		return ResultUtil.success();
351

352
	}
353

354 355 356 357 358 359
	/**
	 * 新增-绩效考核
	 */
	@PostMapping(value = "/save_performance_appraisal")
	@ApiOperation(value = "7.新增-绩效考核", httpMethod = "POST", notes = "新增-绩效考核")
	@ApiOperationSupport(order = 7)
360 361
	public Result<Object> savePA(@CurrentUser UserBean userBean,
			@Validated @RequestBody PerformanceAppraisal performanceAppraisal) throws Exception {
362
		Integer orgCode = userBean.getOrgCode();
363
		JxglPerformanceAppraisal pA = JxglPerformanceAppraisal.builder().build();
364
		BeanUtil.copyProperties(performanceAppraisal, pA, "processNode", "beingAppraisalPerson");
365

366 367
		List<ProcessNode> listPN = performanceAppraisal.getProcessNode();
		List<BeingAppraisalPerson> listBAP = performanceAppraisal.getBeingAppraisalPerson();
368
		pA.setSts(PerformanceAppraisalSts.TARGET_SETING.getType());
tangzhaoqian committed
369 370 371
		pA.setOrgCode(orgCode);
		pA.setProcessNode(ObjectUtil.serialize(listPN));
		pA.setBeingAppraisalPerson(ObjectUtil.serialize(listBAP));
372

373
		// 被考核人员
374
		List<Integer> listEmpId = listBAP.stream()
375 376 377
				.filter(bAP -> BeingAppraisalType.EMPLOYEE.getType().equals(bAP.getType())
						&& BeingAppraisalSts.NEED.getType().equals(bAP.getSts()))
				.map(BeingAppraisalPerson::getId).collect(Collectors.toList());
378

379 380
		// 被考核部门id
		List<Integer> listDeptId = listBAP.stream()
381 382
				.filter(bAP -> BeingAppraisalType.DEPARTMENT.getType().equals(bAP.getType()))
				.map(BeingAppraisalPerson::getId).collect(Collectors.toList());
383
		List<YgglMainEmp> listEmp2 = ListUtil.toList();
384
		
385 386 387
		for (Integer deptId : listDeptId) {
			CollUtil.addAll(listEmp2, zzglBmgwMService.selectOtherlistent(userBean.getOrgCode(), deptId));
		}
tangzhaoqian committed
388
		if (CollectionUtil.isNotEmpty(listEmp2)) {
389
			// 员工信息数据 去重
390 391
			List<Integer> listEmp2Id = listEmp2.stream().filter(StreamUtils.distinctByKey(e -> e.getEmpNum()))
					.map(YgglMainEmp::getEmpNum).collect(Collectors.toList());
392 393 394
			// 合并 集合
			CollUtil.addAll(listEmpId, listEmp2Id);
		}
395

396 397
		// 无需被考核人id
		List<Integer> listNotEmpId = listBAP.stream()
398 399 400 401
				.filter(bAP -> BeingAppraisalType.EMPLOYEE.getType().equals(bAP.getType())
						&& BeingAppraisalSts.NOT_NEED.getType().equals(bAP.getSts()))
				.map(BeingAppraisalPerson::getId).collect(Collectors.toList());

402 403
		// 去重+过滤掉 无需被考核人id
		listEmpId = listEmpId.stream().filter(e -> !listNotEmpId.contains(e)).distinct().collect(Collectors.toList());
404
		pA.setAppraisalPersonNum(listEmpId.size());
405
		// 新增 绩效考核
406
		pA.insert();
407 408 409 410 411
		// 考核模板
		JxglAppraisalT aT = jxglAppraisalTMapper.selectById(performanceAppraisal.getAppraisalTId());
		if (aT == null) {
			throw new CustomException("考核模板不存在");
		}
412

413 414 415 416 417
		JxglProcessNode processNode = JxglProcessNode.builder().build();
		JxglAppraisal appraisal = JxglAppraisal.builder().build();
		JxglAppraisalIndicators appraisalIndicators = JxglAppraisalIndicators.builder().build();
		JxglAppraisalItem appraisalItem = JxglAppraisalItem.builder().build();
		JxglAppraisalLog appraisalLog = JxglAppraisalLog.builder().build();
418 419

		System.out.println("listEmpId----" + listEmpId);
420 421 422 423
		for (Integer bAP : listEmpId) {
			// 考核
			appraisal.setPerformanceAppraisalId(pA.getId());
			appraisal.setEmpNum(bAP);
424
			appraisal.setIsEdit(aT.getIsEdit());
425 426 427 428 429 430
			appraisal.setName(aT.getName());
			appraisal.setAppraisalExplain(aT.getAppraisalExplain());
			appraisal.setSts(AppraisalSts.TARGET_FILL_IN.getType());
			// 新增 考核
			appraisal.insert();
			System.out.println("新增 考核:" + appraisal);
431

432 433 434 435 436 437 438 439 440 441 442 443 444
			List<Integer> pNWeights = listPN.stream().filter(p -> p.getProcessType() == 2 || p.getProcessType() == 3 ).map(ProcessNode::getWeight).collect(Collectors.toList());
			Integer sum = 0;
			
			for (Integer w : pNWeights) {
				if (w < 0) {
					throw new CustomException("评分权重不能小于0");
				}
				sum += w;
			}
			if (sum != 100) {
				throw new CustomException("权重总和必须等于100");
			}
			
445 446 447 448 449 450 451 452 453 454 455
			listPN.stream().forEach(pN -> {
				Integer executeType = pN.getExecuteType();
				// 流程节点
				processNode.setAppraisalId(appraisal.getId());
				processNode.setExecuteType(executeType);
				processNode.setLeaderTier(pN.getLeaderTier());
				processNode.setName(ExecuteType.getName(executeType));
				Integer processType = pN.getProcessType();
				processNode.setProcessType(processType);
				if (ProcessType.TARGET_FILL_IN.getType().equals(processType)) {
					processNode.setSts(ProcessNodeSts.IN_EXECUTION.getType());
456
				} else {
457 458 459
					processNode.setSts(ProcessNodeSts.NON_EXECUTION.getType());
				}
				processNode.setWeight(pN.getWeight());
460

461 462
				if (ExecuteType.BEING_APPRAISAL_PERSON.getType().equals(executeType)) {
					processNode.setExecutorId(bAP);
463
				} else if (ExecuteType.LEADER.getType().equals(executeType)) {
tangzhaoqian committed
464 465 466 467 468 469 470 471 472 473 474 475 476 477 478 479 480 481 482 483

					Integer leaderId = ygglService.selectLeaderEmpNumById(userBean.getOrgCode(), bAP, pN.getLeaderTier());
					Console.log("bAP:"+bAP);
					Console.log("leaderTier:"+pN.getLeaderTier());
					Console.log("leaderId:"+leaderId);
					if (leaderId == null) {
						
						QyzxEmpEntAsso eEA = qyzxEmpEntAssoMapper.selectOne(new QueryWrapper<QyzxEmpEntAsso>().lambda()
								.select(QyzxEmpEntAsso::getEmpNum)
								.eq(QyzxEmpEntAsso::getOrgCode, orgCode)
								.eq(QyzxEmpEntAsso::getUserType, SysRoleType.U_TYPE_ADMIN.getType()));
				
						leaderId = eEA != null ? eEA.getEmpNum() : null;
						// 当 该企业无管理员时 报错
						if (leaderId == null) {
							throw new CustomException("该企业不存在管理员,请联系客服");
						}
					}
					
					processNode.setExecutorId(leaderId);
484
				} else if (ExecuteType.SPECIFIED_MEMBER.getType().equals(executeType)) {
485 486 487 488 489
					processNode.setExecutorId(pN.getExecutorId());
				}
				// 新增 流程节点
				processNode.insert();
				System.out.println("新增 流程节点:" + processNode);
490

491
			});
492 493 494 495 496 497 498 499 500

			List<JxglAppraisalIndicatorsT> listAIT = jxglAppraisalIndicatorsTMapper
					.selectList(new QueryWrapper<JxglAppraisalIndicatorsT>().lambda()
							.eq(JxglAppraisalIndicatorsT::getAppraisalTId, aT.getId())
							.ne(aT.getIsUseFixd() == 1, JxglAppraisalIndicatorsT::getType,
									IndicatorsType.FIXATION.getType())
							.ne(aT.getIsUseNotFixd() == 1, JxglAppraisalIndicatorsT::getType,
									IndicatorsType.NOT_FIXATION.getType()));

501
			if (CollectionUtil.isEmpty(listAIT)) {
502 503
				throw new CustomException("考核指标不存在");
			}
504

505
			listAIT.stream().forEach(aIT -> {
506 507 508 509 510 511 512 513 514 515 516
				// 考核指标
				BeanUtil.copyProperties(aIT, appraisalIndicators, "appraisalId", "createTime", "updateTime");
				appraisalIndicators.setAppraisalId(appraisal.getId());
				// 新增 考核指标
				appraisalIndicators.insert();
//				System.out.println("新增 考核指标:" + appraisalIndicators);

				List<JxglAppraisalItemT> listAItemT = jsxglAppraisalItemTMapper
						.selectList(new QueryWrapper<JxglAppraisalItemT>().lambda()
								.eq(JxglAppraisalItemT::getAppraisalIndicatorsTId, aIT.getId()));

tangzhaoqian committed
517
				if (CollectionUtil.isNotEmpty(listAItemT)) {
518 519 520 521 522 523 524 525 526 527
					listAItemT.stream().forEach(aItemT -> {
						BeanUtil.copyProperties(aItemT, appraisalItem, "appraisalIndicatorsTId");
						appraisalItem.setAppraisalIndicatorsId(appraisalIndicators.getId());

						// 新增 考核项
						appraisalItem.insert();
//						System.out.println("新增 考核项:" + appraisalItem);
					});
				}

528
			});
529

tangzhaoqian committed
530 531 532 533
//			YgglMainEmp yME = ygglMainEmpMapper.selectOne(new QueryWrapper<YgglMainEmp>().lambda()
//					.select(YgglMainEmp::getName)
//					.eq(YgglMainEmp::getOrgCode, orgCode)
//					.eq(YgglMainEmp::getEmpNum, bAP));
534

535 536
			appraisalLog.setAppraisalId(appraisal.getId());
			appraisalLog.setExecutorId(bAP);
537
			appraisalLog.setExecutorName(userBean.getUserInfo().getName());
538 539 540
			appraisalLog.setType(AppraisalLogType.START.getType());
			appraisalLog.insert();
		}
541

542 543
		return ResultUtil.success();
	}
544

545
	/**
tangzhaoqian committed
546 547 548 549 550 551
	 * 删除-绩效考核
	 */
	@DeleteMapping(value = "/delete_performance_appraisal/{id}")
	@ApiOperation(value = "8.删除-绩效考核", httpMethod = "DELETE", notes = "删除-绩效考核")
	@ApiOperationSupport(order = 8)
	@Role
552 553 554 555 556 557
	public Result<Object> deletePA(@CurrentUser UserBean userBean, @PathVariable Integer id) {

		JxglPerformanceAppraisal pA = jxglPerformanceAppraisalMapper
				.selectOne(new QueryWrapper<JxglPerformanceAppraisal>().lambda().eq(JxglPerformanceAppraisal::getId, id)
						.eq(JxglPerformanceAppraisal::getOrgCode, userBean.getOrgCode()));

tangzhaoqian committed
558 559 560
		if (pA == null) {
			return ResultUtil.error("绩效考核不存在");
		}
561

tangzhaoqian committed
562 563
		List<Integer> aIds = CollUtil.toList();
		List<Integer> aIIds = CollUtil.toList();
564

tangzhaoqian committed
565
		List<JxglAppraisal> listA = jxglAppraisalMapper.selectList(new QueryWrapper<JxglAppraisal>().lambda()
566 567
				.select(JxglAppraisal::getId).eq(JxglAppraisal::getPerformanceAppraisalId, pA.getId()));

tangzhaoqian committed
568
		aIds = CollectionUtil.isNotEmpty(listA) ? listA.stream().map(JxglAppraisal::getId).collect(Collectors.toList())
569 570
				: aIds;

tangzhaoqian committed
571 572
		// 删除 绩效考核
		jxglPerformanceAppraisalMapper.deleteById(id);
573

574
		if (CollectionUtil.isNotEmpty(aIds)) {
575

tangzhaoqian committed
576 577
			// 批量删除 考核
			jxglAppraisalMapper.deleteBatchIds(aIds);
578

tangzhaoqian committed
579 580 581 582 583 584 585 586 587 588 589 590
			// 批量删除 流程节点
			jxglProcessNodeMapper.delete(new QueryWrapper<JxglProcessNode>().lambda()
					.eq(aIds.size() == 1, JxglProcessNode::getAppraisalId, aIds)
					.in(aIds.size() > 1, JxglProcessNode::getAppraisalId, aIds));
			// 批量删除 考核评定
			jxglAppraisalAssessmentMapper.delete(new QueryWrapper<JxglAppraisalAssessment>().lambda()
					.eq(aIds.size() == 1, JxglAppraisalAssessment::getAppraisalId, aIds)
					.in(aIds.size() > 1, JxglAppraisalAssessment::getAppraisalId, aIds));
			// 批量删除 考核记录
			jxglAppraisalLogMapper.delete(new QueryWrapper<JxglAppraisalLog>().lambda()
					.eq(aIds.size() == 1, JxglAppraisalLog::getAppraisalId, aIds)
					.in(aIds.size() > 1, JxglAppraisalLog::getAppraisalId, aIds));
591 592 593 594 595 596

			List<JxglAppraisalIndicators> listAI = jxglAppraisalIndicatorsMapper.selectList(
					new QueryWrapper<JxglAppraisalIndicators>().lambda().select(JxglAppraisalIndicators::getId)
							.eq(aIds.size() == 1, JxglAppraisalIndicators::getAppraisalId, aIds)
							.in(aIds.size() > 1, JxglAppraisalIndicators::getAppraisalId, aIds));

tangzhaoqian committed
597
			aIIds = CollectionUtil.isNotEmpty(listAI) 
598 599 600
					? listAI.stream().map(JxglAppraisalIndicators::getId).collect(Collectors.toList())
					: aIIds;

tangzhaoqian committed
601
			if (aIIds.size() > 0) {
602

tangzhaoqian committed
603
				jxglAppraisalIndicatorsMapper.deleteBatchIds(aIIds);
604

tangzhaoqian committed
605
				// 批量删除 考核指标评定
606 607
				jxglAppraisalIndicatorsAssessmentMapper.delete(new QueryWrapper<JxglAppraisalIndicatorsAssessment>()
						.lambda()
tangzhaoqian committed
608 609
						.eq(aIds.size() == 1, JxglAppraisalIndicatorsAssessment::getAppraisalIndicatorsId, aIIds)
						.in(aIds.size() > 1, JxglAppraisalIndicatorsAssessment::getAppraisalIndicatorsId, aIIds));
610

tangzhaoqian committed
611 612 613 614
				// 批量删除 考核项
				jxglAppraisalItemMapper.delete(new QueryWrapper<JxglAppraisalItem>().lambda()
						.eq(aIds.size() == 1, JxglAppraisalItem::getAppraisalIndicatorsId, aIIds)
						.in(aIds.size() > 1, JxglAppraisalItem::getAppraisalIndicatorsId, aIIds));
615

tangzhaoqian committed
616 617
			}
		}
618

tangzhaoqian committed
619 620
		return ResultUtil.success();
	}
621

tangzhaoqian committed
622 623 624 625
	/**
	 * 修改-绩效管理状态
	 */
	@PostMapping(value = "/update_performance_appraisal_sts")
tangzhaoqian committed
626 627
	@ApiOperation(value = "9.修改-绩效管理状态", httpMethod = "POST", notes = "修改-绩效管理状态")
	@ApiOperationSupport(order = 9)
628 629 630 631 632 633 634 635
	public Result<Object> updatePAS(@CurrentUser UserBean userBean,
			@Validated @RequestBody AppraisalUpdateSts appraisalUpdateSts) {

		JxglPerformanceAppraisal performanceAppraisal = jxglPerformanceAppraisalMapper
				.selectOne(new QueryWrapper<JxglPerformanceAppraisal>().lambda()
						.eq(JxglPerformanceAppraisal::getId, appraisalUpdateSts.getId())
						.eq(JxglPerformanceAppraisal::getSts, appraisalUpdateSts.getSts()));

tangzhaoqian committed
636
		if (performanceAppraisal == null && appraisalUpdateSts.getSts() != PerformanceAppraisalSts.PERFORMANCE_ARCHIVE.getType()) {
tangzhaoqian committed
637 638
			return ResultUtil.error("绩效考核不存在");
		}
639
		
tangzhaoqian committed
640
		if (performanceAppraisal.getSts() == PerformanceAppraisalSts.TERMINATION_ASSESSMENT.getType()) {
641 642 643 644 645 646
			// 修改 绩效考核状态
			jxglPerformanceAppraisalMapper
					.updateById(JxglPerformanceAppraisal.builder()
							.id(appraisalUpdateSts.getId())
							.sts(PerformanceAppraisalSts.PERFORMANCE_ARCHIVE.getType())
							.build());
647
			return ResultUtil.success();
tangzhaoqian committed
648
		}
649

tangzhaoqian committed
650
		Integer sts = null;
651
		Integer id = performanceAppraisal.getId();
652

653
		List<JxglAppraisal> listA = CollUtil.toList();
654
		List<Integer> aIds = CollUtil.toList();
655 656
		List<JxglProcessNode> listPN = CollUtil.toList();
		List<Integer> pNIds = CollUtil.toList();
657

tangzhaoqian committed
658 659 660
		switch (performanceAppraisal.getSts()) {
		case 0:
			sts = PerformanceAppraisalSts.PERFORMANCE_SCORE.getType();
661

662
			listA = jxglAppraisalMapper.selectList(new QueryWrapper<JxglAppraisal>().lambda()
663 664
					.select(JxglAppraisal::getId).eq(JxglAppraisal::getPerformanceAppraisalId, id));

tangzhaoqian committed
665
			if (CollectionUtil.isNotEmpty(listA)) {
666
				aIds = listA.stream().map(JxglAppraisal::getId).collect(Collectors.toList());
667 668 669 670 671 672

				listPN = jxglProcessNodeMapper.selectList(
						new QueryWrapper<JxglProcessNode>().lambda().in(JxglProcessNode::getAppraisalId, aIds)
								.eq(JxglProcessNode::getProcessType, ProcessType.TARGET_CONFIRMED.getType())
								.eq(JxglProcessNode::getSts, ProcessNodeSts.EXECUTED.getType()));

tangzhaoqian committed
673
				if (CollectionUtil.isNotEmpty(listPN)) {
674
					aIds = listPN.stream().map(JxglProcessNode::getAppraisalId).collect(Collectors.toList());
675 676 677 678 679

					listPN = jxglProcessNodeMapper.selectList(
							new QueryWrapper<JxglProcessNode>().lambda().in(JxglProcessNode::getAppraisalId, aIds)
									.eq(JxglProcessNode::getProcessType, ProcessType.SELF_ASSESSMENT.getType())
									.eq(JxglProcessNode::getSts, ProcessNodeSts.NON_EXECUTION.getType()));
tangzhaoqian committed
680
					if (CollectionUtil.isNotEmpty(listPN)) {
681 682
						pNIds = listPN.stream().map(JxglProcessNode::getId).collect(Collectors.toList());
						aIds = listPN.stream().map(JxglProcessNode::getAppraisalId).collect(Collectors.toList());
683 684 685 686 687 688 689

						JxglProcessNode.builder().sts(ProcessNodeSts.IN_EXECUTION.getType()).build().update(
								new UpdateWrapper<JxglProcessNode>().lambda().in(JxglProcessNode::getId, pNIds));

						JxglAppraisal.builder().sts(AppraisalSts.SELF_ASSESSMENT.getType()).build()
								.update(new UpdateWrapper<JxglAppraisal>().lambda().in(JxglAppraisal::getId, aIds));

690 691 692
					}
				}
			}
693

tangzhaoqian committed
694 695 696
			break;
		case 1:
			sts = PerformanceAppraisalSts.RESULT_VERIFICATION.getType();
697

698
			listA = jxglAppraisalMapper.selectList(new QueryWrapper<JxglAppraisal>().lambda()
699 700
					.select(JxglAppraisal::getId).eq(JxglAppraisal::getPerformanceAppraisalId, id));

tangzhaoqian committed
701
			if (CollectionUtil.isNotEmpty(listA)) {
702
				aIds = listA.stream().map(JxglAppraisal::getId).collect(Collectors.toList());
703 704 705 706 707 708

				listPN = jxglProcessNodeMapper.selectList(
						new QueryWrapper<JxglProcessNode>().lambda().in(JxglProcessNode::getAppraisalId, aIds)
								.eq(JxglProcessNode::getProcessType, ProcessType.SUPERIOR_SCORE.getType())
								.eq(JxglProcessNode::getSts, ProcessNodeSts.EXECUTED.getType()));

tangzhaoqian committed
709
				if (CollectionUtil.isNotEmpty(listPN)) {
710
					aIds = listPN.stream().map(JxglProcessNode::getAppraisalId).collect(Collectors.toList());
711 712 713 714 715

					listPN = jxglProcessNodeMapper.selectList(
							new QueryWrapper<JxglProcessNode>().lambda().in(JxglProcessNode::getAppraisalId, aIds)
									.eq(JxglProcessNode::getProcessType, ProcessType.RESULT_VERIFICATION.getType())
									.eq(JxglProcessNode::getSts, ProcessNodeSts.NON_EXECUTION.getType()));
tangzhaoqian committed
716
					if (CollectionUtil.isNotEmpty(listPN)) {
717 718
						pNIds = listPN.stream().map(JxglProcessNode::getId).collect(Collectors.toList());
						aIds = listPN.stream().map(JxglProcessNode::getAppraisalId).collect(Collectors.toList());
719 720 721 722 723 724 725

						JxglProcessNode.builder().sts(ProcessNodeSts.IN_EXECUTION.getType()).build().update(
								new UpdateWrapper<JxglProcessNode>().lambda().in(JxglProcessNode::getId, pNIds));

						JxglAppraisal.builder().sts(AppraisalSts.RESULT_VERIFICATION.getType()).build()
								.update(new UpdateWrapper<JxglAppraisal>().lambda().in(JxglAppraisal::getId, aIds));

726 727 728
					}
				}
			}
tangzhaoqian committed
729 730 731
			break;
		case 2:
			sts = PerformanceAppraisalSts.PERFORMANCE_ARCHIVE.getType();
732

733
			listA = jxglAppraisalMapper.selectList(new QueryWrapper<JxglAppraisal>().lambda()
734 735
					.select(JxglAppraisal::getId).eq(JxglAppraisal::getPerformanceAppraisalId, id));

tangzhaoqian committed
736
			if (CollectionUtil.isNotEmpty(listA)) {
737
				aIds = listA.stream().map(JxglAppraisal::getId).collect(Collectors.toList());
738 739 740 741

				listPN = jxglProcessNodeMapper.selectList(
						new QueryWrapper<JxglProcessNode>().lambda().in(JxglProcessNode::getAppraisalId, aIds)
								.eq(JxglProcessNode::getProcessType, ProcessType.RESULT_VERIFICATION.getType())
742
								.in(JxglProcessNode::getSts, ProcessNodeSts.NON_EXECUTION.getType(),ProcessNodeSts.IN_EXECUTION.getType()));
743

tangzhaoqian committed
744
				if (CollectionUtil.isNotEmpty(listPN)) {
745
					throw new CustomException("所有考核 确认结果后才能 归档");
746 747
				}
			}
tangzhaoqian committed
748
			break;
749 750 751 752 753 754 755 756 757 758 759 760 761 762 763 764 765 766 767 768 769 770 771 772 773 774 775 776
		case 3:
			// 修改 考核状态
			jxglAppraisalMapper.update(
					JxglAppraisal.builder().performanceAppraisalId(id).sts(AppraisalSts.PERFORMANCE_ARCHIVE.getType()).build(),
					new UpdateWrapper<JxglAppraisal>().lambda()
							.eq(JxglAppraisal::getPerformanceAppraisalId, id)
					);
			
			List<JxglAppraisal> listAppraisal = jxglAppraisalMapper.selectList(new QueryWrapper<JxglAppraisal>().lambda()
					.select(JxglAppraisal::getId)
					.eq(JxglAppraisal::getPerformanceAppraisalId, performanceAppraisal.getId()));
			
			if (CollectionUtil.isNotEmpty(listAppraisal)) {
				
				List<Integer> aIds2 = listAppraisal.stream().map(JxglAppraisal::getId).collect(Collectors.toList());
				if (CollectionUtil.isNotEmpty(aIds2)) {
					JxglAppraisalLog appraisalLog = JxglAppraisalLog.builder().build();
					aIds2.forEach(aId -> {
						appraisalLog.setId(null);
						appraisalLog.setAppraisalId(aId);
						appraisalLog.setExecutorId(userBean.getEmpNum());
						appraisalLog.setExecutorName(userBean.getUserInfo().getName());
						appraisalLog.setType(AppraisalLogType.PERFORMANCE_ARCHIVE.getType());
						appraisalLog.insert();
					});
				}
			}
			break;
tangzhaoqian committed
777 778 779
		default:
			break;
		}
780

tangzhaoqian committed
781
		// 修改 绩效考核状态
782 783 784
		jxglPerformanceAppraisalMapper
				.updateById(JxglPerformanceAppraisal.builder().id(appraisalUpdateSts.getId()).sts(sts).build());

785 786 787 788 789 790 791
		return ResultUtil.success();
	}
	
	/**
	 * 终止-绩效考核
	 */
	@PutMapping(value = "/termination_performance_appraisal")
tangzhaoqian committed
792 793
	@ApiOperation(value = "10.终止-绩效考核", httpMethod = "PUT", notes = "终止-绩效考核")
	@ApiOperationSupport(order = 10)
tangzhaoqian committed
794 795
	@Role
	@Log(title = "终止-绩效考核")
796 797 798 799 800 801 802 803 804 805 806 807 808 809 810 811 812
	public Result<Object> terminationPA(@CurrentUser UserBean userBean,@NotNull @RequestParam Integer id) {

		JxglPerformanceAppraisal performanceAppraisal = jxglPerformanceAppraisalMapper
				.selectOne(new QueryWrapper<JxglPerformanceAppraisal>().lambda()
						.eq(JxglPerformanceAppraisal::getId, id));

		if (performanceAppraisal == null) {
			return ResultUtil.error("绩效考核不存在");
		}
		if (performanceAppraisal.getSts() == PerformanceAppraisalSts.TERMINATION_ASSESSMENT.getType()) {
			return ResultUtil.error("考核已终止");
		}

		// 修改 绩效考核状态
		jxglPerformanceAppraisalMapper
				.updateById(JxglPerformanceAppraisal.builder().id(id).sts(PerformanceAppraisalSts.TERMINATION_ASSESSMENT.getType()).build());

813
		// 修改 考核状态
814
		jxglAppraisalMapper.update(
815
				JxglAppraisal.builder().performanceAppraisalId(id).sts(AppraisalSts.TERMINATION_ASSESSMENT.getType()).build(),
816
				new UpdateWrapper<JxglAppraisal>().lambda()
817 818
						.eq(JxglAppraisal::getPerformanceAppraisalId, id)
						);
819 820 821 822 823 824 825 826 827
		
		List<JxglAppraisal> listAppraisal = jxglAppraisalMapper.selectList(new QueryWrapper<JxglAppraisal>().lambda()
				.select(JxglAppraisal::getId)
				.eq(JxglAppraisal::getPerformanceAppraisalId, performanceAppraisal.getId()));
		
		if (CollectionUtil.isNotEmpty(listAppraisal)) {
			
			List<Integer> aIds = listAppraisal.stream().map(JxglAppraisal::getId).collect(Collectors.toList());
			if (CollectionUtil.isNotEmpty(aIds)) {
828
				JxglAppraisalLog appraisalLog = JxglAppraisalLog.builder().build();
829
				aIds.forEach(aId -> {
830
					appraisalLog.setId(null);
831 832 833 834 835 836 837 838 839
					appraisalLog.setAppraisalId(aId);
					appraisalLog.setExecutorId(userBean.getEmpNum());
					appraisalLog.setExecutorName(userBean.getUserInfo().getName());
					appraisalLog.setType(AppraisalLogType.TERMINATION_ASSESSMENT.getType());
					appraisalLog.insert();
				});
			}
		}
		
840
		return ResultUtil.success();
tangzhaoqian committed
841
	}
842

tangzhaoqian committed
843 844 845 846
	/**
	 * 删除-所有-绩效考核
	 */
	@DeleteMapping(value = "/delete_all_pa")
847 848 849
	@ApiOperation(value = "99.删除-所有-绩效考核", httpMethod = "DELETE", notes = "删除-所有-绩效考核")
	@ApiOperationSupport(order = 99)
	@Role
850 851 852 853 854 855 856 857 858 859 860
	public Result<Object> deleteAllPA(@CurrentUser UserBean userBean) {

		jxglPerformanceAppraisalMapper.delete(null);
		jxglAppraisalMapper.delete(null);
		jxglProcessNodeMapper.delete(null);
		jxglAppraisalAssessmentMapper.delete(null);
		jxglAppraisalLogMapper.delete(null);
		jxglAppraisalIndicatorsMapper.delete(null);
		jxglAppraisalIndicatorsAssessmentMapper.delete(null);
		jxglAppraisalItemMapper.delete(null);

tangzhaoqian committed
861 862
		return ResultUtil.success("删除-所有-绩效考核");
	}
863

tangzhaoqian committed
864
	/**
865
	 * 查询-绩效考核-列表-归档
866
	 */
867
	@PostMapping(value = "/selects_performance_appraisal_archive")
tangzhaoqian committed
868 869
	@ApiOperation(value = "11.查询-绩效考核-列表-归档", httpMethod = "POST", notes = "查询-绩效考核-列表-归档")
	@ApiOperationSupport(order = 11)
870
	@Role
871 872 873 874 875
	public Result<Object> selectsPAArchive(@CurrentUser UserBean userBean,
			@RequestBody PerformanceAppraisalQuery query) {

		IPage<SpmkApproveSummary> page = new Page<SpmkApproveSummary>(query.getCurrentPage(), query.getTotalPage());

876
		query.setOrgCode(userBean.getOrgCode());
877

878
		IPage<JxglPerformanceAppraisal> pagePA = jxglPerformanceAppraisalMapper.selectArchiveListByQuery(page, query);
879

880 881
		List<JxglPerformanceAppraisal> listPA = pagePA.getRecords();

882
		return ResultUtil.data(pagePA, listPA);
883
	}
884

885 886 887 888
	/**
	 * 查询-绩效考核-列表-非归档
	 */
	@PostMapping(value = "/selects_performance_appraisal")
tangzhaoqian committed
889 890
	@ApiOperation(value = "12.查询-绩效考核-列表-非归档", httpMethod = "POST", notes = "查询-绩效考核-列表-非归档")
	@ApiOperationSupport(order = 12)
891
	@Role
892 893 894 895
	public Result<Object> selectsPA(@CurrentUser UserBean userBean, @RequestBody PerformanceAppraisalQuery query) {

		IPage<SpmkApproveSummary> page = new Page<SpmkApproveSummary>(query.getCurrentPage(), query.getTotalPage());

896
		query.setOrgCode(userBean.getOrgCode());
897

898
		IPage<JxglPerformanceAppraisal> pagePA = jxglPerformanceAppraisalMapper.selectListByQuery(page, query);
899

900 901
		List<JxglPerformanceAppraisal> listPA = pagePA.getRecords();

902
		return ResultUtil.data(pagePA, listPA);
903
	}
904

905 906 907 908
	/**
	 * 查询-考核-列表
	 */
	@PostMapping(value = "/selects_appraisal")
tangzhaoqian committed
909 910
	@ApiOperation(value = "13.查询-考核-列表", httpMethod = "POST", notes = "查询-考核-列表")
	@ApiOperationSupport(order = 13)
911
	@Role
912 913 914
	public Result<Object> selectsA(@CurrentUser UserBean userBean, @RequestBody AppraisalQuery query) {

		IPage<JxglAppraisal> page = new Page<JxglAppraisal>(query.getCurrentPage(), query.getTotalPage());
915
		query.setOrgCode(userBean.getOrgCode());
916 917 918 919 920 921 922 923 924 925 926 927 928 929 930 931 932
		
		List<Integer> empNums = CollUtil.toList();
		
		if (query.getBmId() != null) {
			List<YgglMainEmp> usersQuery = zzglBmgwMService.selectOtherlistent(userBean.getOrgCode(), query.getBmId());
			if (usersQuery != null) {
				empNums = usersQuery.stream().map(YgglMainEmp::getEmpNum).collect(Collectors.toList());
			}else {
				return ResultUtil.data(null);
			}
			
			if (empNums == null || empNums.size() == 0) {
				return ResultUtil.data(null);
			}
		}
		
		query.setEmpNums(empNums);
933

934
		IPage<JxglAppraisal> pageA = jxglAppraisalMapper.selectListByQuery(page, query);
935

936 937
		List<JxglAppraisal> listPA = pageA.getRecords();

938 939
		return ResultUtil.data(pageA, listPA);

940
	}
941

942 943 944 945
	/**
	 * 查询-考核-详情
	 */
	@GetMapping(value = "/select_appraisal/{id}")
tangzhaoqian committed
946 947
	@ApiOperation(value = "14.查询-考核-详情", httpMethod = "GET", notes = "查询-考核-详情")
	@ApiOperationSupport(order = 14)
948 949
	public Result<Object> selectA(@CurrentUser UserBean userBean, @PathVariable Integer id) {

950
		AppraisalDetail aD = jxglAppraisalMapper.selectDetailById(userBean.getOrgCode(), id);
951

tangzhaoqian committed
952
		if (aD != null) {
953 954 955 956
			JxglPerformanceAppraisal pA = jxglPerformanceAppraisalMapper
					.selectOne(new QueryWrapper<JxglPerformanceAppraisal>().lambda().eq(JxglPerformanceAppraisal::getId,
							aD.getPerformanceAppraisalId()));

957 958
			
			
tangzhaoqian committed
959 960
			if (pA != null && pA.getIsVisible() == 0) {
				return ResultUtil.data(aD);
961
			} else {
tangzhaoqian committed
962 963
				List<JxglAppraisalAssessment> listAA = aD.getAppraisalAssessments();
				if (listAA != null) {
964 965
					listAA = listAA.stream().filter(a -> !userBean.getEmpNum().equals(a.getAssessorId()))
							.collect(Collectors.toList());
tangzhaoqian committed
966 967 968 969
					aD.setAppraisalAssessments(listAA);
				}
			}
		}
970

971
		return ResultUtil.data(aD);
972

973
	}
974

975 976 977 978
	/**
	 * 修改-流程执行人-转派
	 */
	@PutMapping(value = "/update_process_node")
tangzhaoqian committed
979 980
	@ApiOperation(value = "15.修改-流程执行人-转派", httpMethod = "PUT", notes = "修改-流程执行人-转派")
	@ApiOperationSupport(order = 15)
981
	@Role
982 983 984
	public Result<Object> updatePN(@CurrentUser UserBean userBean,
			@Validated @RequestBody ProcessNodeUpdate processNodeUpdate) {

tangzhaoqian committed
985
		JxglAppraisal appraisal = jxglAppraisalMapper.selectOne(new QueryWrapper<JxglAppraisal>().lambda()
986 987
				.eq(JxglAppraisal::getId, processNodeUpdate.getAppraisalId()).select(JxglAppraisal::getId));

tangzhaoqian committed
988
		if (appraisal == null) {
989
			return ResultUtil.error("考核不存在");
tangzhaoqian committed
990
		}
991

tangzhaoqian committed
992
		Integer count = jxglAppraisalMapper.selectCount(new QueryWrapper<JxglAppraisal>().lambda()
993 994
				.eq(JxglAppraisal::getId, processNodeUpdate.getAppraisalId()).in(JxglAppraisal::getSts,
						AppraisalSts.ASSESSMENT_COMPLETE.getType(), AppraisalSts.TERMINATION_ASSESSMENT.getType(),
995
						AppraisalSts.PERFORMANCE_ARCHIVE.getType()));
996

tangzhaoqian committed
997
		if (count > 0) {
998 999
			return ResultUtil.error("考核已结束");
		}
1000

tangzhaoqian committed
1001 1002 1003
		count = jxglProcessNodeMapper.selectCount(new QueryWrapper<JxglProcessNode>().lambda()
				.eq(JxglProcessNode::getAppraisalId, processNodeUpdate.getAppraisalId())
				.ne(JxglProcessNode::getSts, ProcessNodeSts.EXECUTED.getType()));
1004

tangzhaoqian committed
1005 1006 1007
		if (count <= 0) {
			return ResultUtil.error("流程已执行,无法更改");
		}
1008

1009 1010
		JxglProcessNode pN = JxglProcessNode.builder().build();
		BeanUtil.copyProperties(processNodeUpdate, pN);
1011

1012
		pN.updateById();
1013

1014 1015
		return ResultUtil.data(pN);
	}
1016

1017 1018 1019 1020
	/**
	 * 终止-考核
	 */
	@PutMapping(value = "/termination_assessment")
tangzhaoqian committed
1021 1022
	@ApiOperation(value = "16.终止-考核", httpMethod = "PUT", notes = "终止-考核")
	@ApiOperationSupport(order = 16)
1023
	@Role
tangzhaoqian committed
1024
	@Log(title = "终止-考核")
1025 1026
	public Result<Object> terminationAssessment(@CurrentUser UserBean userBean, @NotNull @RequestParam Integer id) {

tangzhaoqian committed
1027
		JxglAppraisal appraisal = jxglAppraisalMapper.selectById(id);
1028

tangzhaoqian committed
1029
		if (appraisal == null) {
1030 1031
			return ResultUtil.error("考核不存在");
		} else if (appraisal.getSts() <= AppraisalSts.RESULT_VERIFICATION.getType()) {
tangzhaoqian committed
1032
			JxglAppraisal.builder().id(id).sts(AppraisalSts.TERMINATION_ASSESSMENT.getType()).build().updateById();
1033 1034 1035 1036 1037 1038 1039
			
			JxglAppraisalLog appraisalLog = JxglAppraisalLog.builder().build();
			appraisalLog.setAppraisalId(appraisal.getId());
			appraisalLog.setExecutorId(userBean.getEmpNum());
			appraisalLog.setExecutorName(userBean.getUserInfo().getName());
			appraisalLog.setType(AppraisalLogType.TERMINATION_ASSESSMENT.getType());
			appraisalLog.insert();
1040
		} else if (appraisal.getSts() == AppraisalSts.ASSESSMENT_COMPLETE.getType()) {
tangzhaoqian committed
1041
			return ResultUtil.error("考核已完成,无法终止");
1042
		} else if (appraisal.getSts() == AppraisalSts.TERMINATION_ASSESSMENT.getType()) {
tangzhaoqian committed
1043
			return ResultUtil.error("考核已终止,无法重复终止");
1044
		} else if (appraisal.getSts() == AppraisalSts.PERFORMANCE_ARCHIVE.getType()) {
tangzhaoqian committed
1045 1046
			return ResultUtil.error("考核已归档,无法终止");
		}
1047
		return ResultUtil.success();
1048
	}
1049

1050
	/**
1051
	 * 查询-绩效管理-员工绩效-汇总
1052 1053
	 */
	@PostMapping(value = "/selects_emp_performance")
tangzhaoqian committed
1054 1055
	@ApiOperation(value = "17.查询-绩效管理-员工绩效-汇总", httpMethod = "POST", notes = " 查询-绩效管理-员工绩效-汇总")
	@ApiOperationSupport(order = 17)
1056
	@Role
1057 1058 1059
	public Result<Object> selectsEP(@CurrentUser UserBean userBean, @RequestBody EmpPerformanceQuery query) {

		IPage<JxglAppraisal> page = new Page<JxglAppraisal>(query.getCurrentPage(), query.getTotalPage());
1060
		query.setOrgCode(userBean.getOrgCode());
1061 1062 1063 1064 1065
		
		List<Integer> empNums = CollUtil.toList();
		
		if (query.getBmId() != null) {
			List<YgglMainEmp> usersQuery = zzglBmgwMService.selectOtherlistent(userBean.getOrgCode(), query.getBmId());
1066
			if (CollectionUtil.isNotEmpty(usersQuery)) {
1067 1068 1069 1070 1071
				empNums = usersQuery.stream().map(YgglMainEmp::getEmpNum).collect(Collectors.toList());
			}else {
				return ResultUtil.data(null);
			}
			
1072
			if (CollectionUtil.isEmpty(empNums)) {
1073 1074 1075 1076 1077
				return ResultUtil.data(null);
			}
		}
		
		query.setEmpNums(empNums);
1078

1079
		IPage<JxglAppraisal> pageA = jxglAppraisalMapper.selectListEmpByQuery(page, query);
1080

1081 1082
		List<JxglAppraisal> listA = pageA.getRecords();

1083 1084
		return ResultUtil.data(pageA, listA);

1085
	}
1086

1087 1088 1089 1090
	/**
	 * 查询-某员工考核-列表
	 */
	@PostMapping(value = "/selects_emp_appraisal")
tangzhaoqian committed
1091 1092
	@ApiOperation(value = "18.查询-某员工考核-列表", httpMethod = "POST", notes = "查询-某员工考核-列表")
	@ApiOperationSupport(order = 18)
1093
	@Role
1094 1095 1096 1097
	public Result<Object> selectsEA(@CurrentUser UserBean userBean,@Validated @RequestBody EmpAppraisalQuery query) {

		IPage<JxglPerformanceAppraisal> page = new Page<JxglPerformanceAppraisal>(query.getCurrentPage(),
				query.getTotalPage());
1098
		query.setOrgCode(userBean.getOrgCode());
1099

1100
		IPage<JxglPerformanceAppraisal> pagePA = jxglPerformanceAppraisalMapper.selectListEmpByQuery(page, query);
1101

1102 1103
		List<JxglPerformanceAppraisal> listPA = pagePA.getRecords();

1104 1105
		return ResultUtil.data(pagePA, listPA);

1106
	}
1107 1108 1109 1110 1111
	
	/**
	 * 查询-我的绩效-考核我的-列表
	 */
	@PostMapping(value = "/selects_my_appraisal")
tangzhaoqian committed
1112 1113
	@ApiOperation(value = "19.查询-我的绩效-考核我的-列表", httpMethod = "POST", notes = "查询-我的绩效-考核我的-列表")
	@ApiOperationSupport(order = 19)
1114 1115 1116 1117 1118 1119 1120 1121 1122 1123 1124 1125 1126 1127
	public Result<Object> selectsMA(@CurrentUser UserBean userBean,@Validated @RequestBody EmpAppraisalQuery query) {
		
		IPage<JxglPerformanceAppraisal> page = new Page<JxglPerformanceAppraisal>(query.getCurrentPage(),
				query.getTotalPage());
		query.setOrgCode(userBean.getOrgCode());
		query.setId(userBean.getEmpNum());
		
		IPage<JxglPerformanceAppraisal> pagePA = jxglPerformanceAppraisalMapper.selectListEmpByQuery(page, query);
		
		List<JxglPerformanceAppraisal> listPA = pagePA.getRecords();
		
		return ResultUtil.data(pagePA, listPA);
		
	}
1128

1129 1130 1131 1132
	/**
	 * 查询-绩效考核-方案
	 */
	@GetMapping(value = "/selects_performance_appraisal/{id}")
tangzhaoqian committed
1133 1134
	@ApiOperation(value = "20.查询-绩效考核-方案", httpMethod = "GET", notes = "查询-绩效考核-方案")
	@ApiOperationSupport(order = 20)
1135
	@Role
1136 1137
	public Result<Object> selectPA(@CurrentUser UserBean userBean, @PathVariable Integer id) {

1138 1139 1140 1141
		JxglPerformanceAppraisal pA = jxglPerformanceAppraisalMapper.selectById(id);
		if (pA == null) {
			return ResultUtil.error("方案不存在");
		}
1142 1143 1144 1145 1146 1147 1148 1149 1150
		PerformanceAppraisal paDto = PerformanceAppraisal.builder()
				.name(pA.getName())
				.period(pA.getPeriod())
				.appraisalStartTime(pA.getAppraisalStartTime())
				.appraisalEndTime(pA.getAppraisalEndTime())
				.isVisible(pA.getIsVisible())
				.scope(pA.getScope())
				.appraisalTName(pA.getAppraisalTName())
				.appraisalTId(pA.getAppraisalTId())
1151
				.processNode(ObjectUtil.deserialize(pA.getProcessNode()))
1152 1153
				.beingAppraisalPerson(ObjectUtil.deserialize(pA.getBeingAppraisalPerson()))
				.build();
1154

1155 1156
		return ResultUtil.data(paDto);
	}
1157

tangzhaoqian committed
1158
	/**
1159
	 * 查询-目标待填写/目标待确认/评分/结果待确认-列表
tangzhaoqian committed
1160 1161
	 */
	@PostMapping(value = "/selects_my_performance")
tangzhaoqian committed
1162 1163
	@ApiOperation(value = "21.查询-目标待填写/目标待确认/评分/结果待确认-列表", httpMethod = "POST", notes = "查询")
	@ApiOperationSupport(order = 21)
1164 1165
	public Result<Object> selects(@CurrentUser UserBean userBean,@Validated @RequestBody MyPerformance query) {

tangzhaoqian committed
1166 1167 1168
		IPage<JxglPerformanceAppraisal> page = new Page<JxglPerformanceAppraisal>(query.getCurrentPage(),query.getTotalPage());
		query.setOrgCode(userBean.getOrgCode());
		query.setId(userBean.getEmpNum());
1169 1170 1171 1172 1173 1174
		
		// 当查询的数据不为  2评分,清空 节点状态
		if (query.getSts() != 2) {
			query.setNoteSts(null);
		}
		
tangzhaoqian committed
1175
		IPage<JxglPerformanceAppraisal> pagePA = jxglPerformanceAppraisalMapper.selectMyByQuery(page, query);
1176

tangzhaoqian committed
1177 1178
		List<JxglPerformanceAppraisal> listPA = pagePA.getRecords();

1179 1180
		return ResultUtil.data(pagePA, listPA);

tangzhaoqian committed
1181
	}
1182 1183 1184 1185 1186
	
	/**
	 * 查询-我的绩效-已处理-列表
	 */
	@PostMapping(value = "/selects_my_performance_processed")
tangzhaoqian committed
1187 1188
	@ApiOperation(value = "22.查询-我的绩效-已处理-列表", httpMethod = "POST", notes = "查询")
	@ApiOperationSupport(order = 22)
1189
	public Result<Object> selectsP(@CurrentUser UserBean userBean, @Validated @RequestBody MyPerformance query) {
1190 1191 1192 1193 1194 1195 1196 1197 1198 1199 1200 1201

		IPage<JxglPerformanceAppraisal> page = new Page<JxglPerformanceAppraisal>(query.getCurrentPage(),query.getTotalPage());
		query.setOrgCode(userBean.getOrgCode());
		query.setId(userBean.getEmpNum());
		
		IPage<JxglPerformanceAppraisal> pagePA = jxglPerformanceAppraisalMapper.selectMyProcessedByQuery(page, query);

		List<JxglPerformanceAppraisal> listPA = pagePA.getRecords();

		return ResultUtil.data(pagePA, listPA);

	}
1202

tangzhaoqian committed
1203 1204 1205 1206
	/**
	 * 目标填写-保存
	 */
	@PostMapping(value = "/save_target_fill")
tangzhaoqian committed
1207 1208
	@ApiOperation(value = "23.目标填写-保存", httpMethod = "POST", notes = "目标填写-保存")
	@ApiOperationSupport(order = 23)
1209 1210 1211
	public Result<Object> saveTF(@CurrentUser UserBean userBean, @RequestBody AppraisalUpdate appraisalUpdate)
			throws Exception {

tangzhaoqian committed
1212
		Integer id = appraisalUpdate.getId();
1213

tangzhaoqian committed
1214
		Integer count2 = jxglAppraisalMapper.selectCount(new QueryWrapper<JxglAppraisal>().lambda()
1215 1216 1217
				.eq(JxglAppraisal::getId, id).in(JxglAppraisal::getSts, AppraisalSts.ASSESSMENT_COMPLETE.getType(),
						AppraisalSts.TERMINATION_ASSESSMENT.getType(), AppraisalSts.PERFORMANCE_ARCHIVE.getType()));

tangzhaoqian committed
1218 1219 1220
		if (count2 > 0) {
			return ResultUtil.error("考核已结束");
		}
1221 1222 1223 1224

		JxglAppraisal appraisal = jxglAppraisalMapper.selectOne(
				new QueryWrapper<JxglAppraisal>().lambda().eq(JxglAppraisal::getId, id).select(JxglAppraisal::getId));

tangzhaoqian committed
1225
		if (appraisal == null) {
1226
			return ResultUtil.error("考核不存在");
tangzhaoqian committed
1227
		}
1228 1229 1230 1231

		JxglProcessNode processNode = jxglProcessNodeMapper.selectOne(
				new QueryWrapper<JxglProcessNode>().lambda().eq(JxglProcessNode::getAppraisalId, appraisal.getId())
						.eq(JxglProcessNode::getSts, ProcessNodeSts.IN_EXECUTION.getType()));
tangzhaoqian committed
1232 1233 1234
		if (processNode == null) {
			return ResultUtil.error("流程不存在");
		}
1235

tangzhaoqian committed
1236
		if (ProcessType.TARGET_FILL_IN.getType() == processNode.getProcessType()) {
1237

tangzhaoqian committed
1238
			if (!userBean.getEmpNum().equals(processNode.getExecutorId())) {
1239
				return ResultUtil.error("无权限操作该流程");
tangzhaoqian committed
1240
			}
1241 1242

		} else {
tangzhaoqian committed
1243 1244
			return ResultUtil.error("流程状态异常");
		}
1245

1246
		// 查找 非固定 考核指标
1247
		List<JxglAppraisalIndicators> listAI = jxglAppraisalIndicatorsMapper
1248 1249 1250
				.selectList(new QueryWrapper<JxglAppraisalIndicators>().lambda().select(JxglAppraisalIndicators::getId,
						JxglAppraisalIndicators::getWeight,
						JxglAppraisalIndicators::getIsEditWeight)
1251 1252 1253
						.eq(JxglAppraisalIndicators::getType, IndicatorsType.NOT_FIXATION.getType())
						.eq(JxglAppraisalIndicators::getAppraisalId, id));

tangzhaoqian committed
1254
		List<Integer> appraisalIndicatorIds = listAI != null && listAI.size() > 0
1255 1256 1257
				? listAI.stream().map(JxglAppraisalIndicators::getId).collect(Collectors.toList())
				: null;

1258
		if (appraisalIndicatorIds != null) {
1259

1260 1261 1262 1263
			// 删除 考核项
			jxglAppraisalItemMapper.delete(new QueryWrapper<JxglAppraisalItem>().lambda()
					.in(JxglAppraisalItem::getAppraisalIndicatorsId, appraisalIndicatorIds));
		}
1264

tangzhaoqian committed
1265 1266
		// 删除 考核指标
		jxglAppraisalIndicatorsMapper.delete(new QueryWrapper<JxglAppraisalIndicators>().lambda()
1267
				.eq(JxglAppraisalIndicators::getType, IndicatorsType.NOT_FIXATION.getType())
tangzhaoqian committed
1268
				.eq(JxglAppraisalIndicators::getAppraisalId, id));
1269 1270

		List<JxglAppraisalIndicators> listAI2 = appraisalUpdate.getAppraisalIndicators();
tangzhaoqian committed
1271
		
tangzhaoqian committed
1272
		if (listAI2 != null && listAI2.size() > 0) {
1273 1274 1275 1276 1277 1278 1279 1280 1281 1282
			listAI2.forEach(aI -> {
				aI.setAppraisalId(id);
				aI.setType(IndicatorsType.NOT_FIXATION.getType());
				if (aI.insert()) {
					List<JxglAppraisalItem> listAItem = aI.getAppraisalItems();
					if (listAItem != null && listAItem.size() > 0) {
						for (JxglAppraisalItem aItem : listAItem) {
							aItem.setAppraisalIndicatorsId(aI.getId());
							aItem.insert();
						}
tangzhaoqian committed
1283
					}
1284 1285
				} else {
					throw new CustomException("保存异常");
tangzhaoqian committed
1286
				}
1287 1288

			});
1289 1290
		}
		
1291

tangzhaoqian committed
1292 1293
		return ResultUtil.success();
	}
1294

tangzhaoqian committed
1295 1296 1297 1298
	/**
	 * 目标填写-提交
	 */
	@PostMapping(value = "/submit_target_fill")
tangzhaoqian committed
1299 1300
	@ApiOperation(value = "24.目标填写-提交", httpMethod = "POST", notes = "目标填写-提交")
	@ApiOperationSupport(order = 24)
1301 1302
	public Result<Object> submitTF(@CurrentUser UserBean userBean, @RequestParam Integer id) {

tangzhaoqian committed
1303
		Integer count2 = jxglAppraisalMapper.selectCount(new QueryWrapper<JxglAppraisal>().lambda()
1304 1305 1306
				.eq(JxglAppraisal::getId, id).in(JxglAppraisal::getSts, AppraisalSts.ASSESSMENT_COMPLETE.getType(),
						AppraisalSts.TERMINATION_ASSESSMENT.getType(), AppraisalSts.PERFORMANCE_ARCHIVE.getType()));

tangzhaoqian committed
1307 1308 1309
		if (count2 > 0) {
			return ResultUtil.error("考核已结束");
		}
1310 1311 1312 1313

		JxglAppraisal appraisal = jxglAppraisalMapper.selectOne(
				new QueryWrapper<JxglAppraisal>().lambda().eq(JxglAppraisal::getId, id).select(JxglAppraisal::getId));

tangzhaoqian committed
1314 1315 1316
		if (appraisal == null) {
			return ResultUtil.error("考核不存在");
		}
1317 1318 1319 1320

		JxglProcessNode processNode = jxglProcessNodeMapper.selectOne(
				new QueryWrapper<JxglProcessNode>().lambda().eq(JxglProcessNode::getAppraisalId, appraisal.getId())
						.eq(JxglProcessNode::getSts, ProcessNodeSts.IN_EXECUTION.getType()));
tangzhaoqian committed
1321 1322 1323
		if (processNode == null) {
			return ResultUtil.error("流程不存在");
		}
1324

tangzhaoqian committed
1325
		if (ProcessType.TARGET_FILL_IN.getType() == processNode.getProcessType()) {
1326

tangzhaoqian committed
1327
			if (!userBean.getEmpNum().equals(processNode.getExecutorId())) {
1328
				return ResultUtil.error("无权限操作该流程");
tangzhaoqian committed
1329
			}
1330 1331 1332 1333 1334

			List<JxglAppraisalIndicators> listAI = jxglAppraisalIndicatorsMapper
					.selectList(new QueryWrapper<JxglAppraisalIndicators>().lambda()
							.eq(JxglAppraisalIndicators::getAppraisalId, appraisal.getId()));

tangzhaoqian committed
1335
			if (CollectionUtil.isEmpty(listAI)) {
tangzhaoqian committed
1336 1337
				return ResultUtil.error("考核指标不能为空");
			}
1338 1339
			List<Integer> listWeight = listAI.stream().map(JxglAppraisalIndicators::getWeight)
					.collect(Collectors.toList());
tangzhaoqian committed
1340 1341 1342
			Integer weightSum = 0;
			if (listWeight != null && listWeight.size() > 0) {
				for (Integer i : listWeight) {
1343
					i = i == null ? 0 : i;
tangzhaoqian committed
1344 1345 1346 1347 1348 1349
					weightSum += i;
				}
				if (!weightSum.equals(100))
					return ResultUtil.error("权重总和要等于 100%");
			}
			// 修改 目标填写 状态
1350 1351 1352 1353 1354
			JxglProcessNode.builder().sts(ProcessNodeSts.EXECUTED.getType()).build()
					.update(new UpdateWrapper<JxglProcessNode>().lambda()
							.eq(JxglProcessNode::getAppraisalId, appraisal.getId())
							.eq(JxglProcessNode::getSts, ProcessNodeSts.IN_EXECUTION.getType()));

tangzhaoqian committed
1355
			// 修改 下一个节点状态
1356 1357 1358 1359 1360 1361 1362 1363
			JxglProcessNode.builder().sts(ProcessNodeSts.IN_EXECUTION.getType()).build()
					.update(new UpdateWrapper<JxglProcessNode>().lambda()
							.eq(JxglProcessNode::getAppraisalId, appraisal.getId())
							.eq(JxglProcessNode::getProcessType, ProcessType.TARGET_CONFIRMED.getType()));

			jxglAppraisalMapper
					.updateById(JxglAppraisal.builder().id(id).sts(AppraisalSts.TARGET_CONFIRMED.getType()).build());

tangzhaoqian committed
1364 1365 1366 1367 1368 1369
			JxglAppraisalLog appraisalLog = JxglAppraisalLog.builder().build();
			appraisalLog.setAppraisalId(appraisal.getId());
			appraisalLog.setExecutorId(userBean.getEmpNum());
			appraisalLog.setExecutorName(userBean.getUserInfo().getName());
			appraisalLog.setType(AppraisalLogType.TARGET_FILL_IN.getType());
			appraisalLog.insert();
1370 1371

		} else {
tangzhaoqian committed
1372 1373 1374 1375 1376
			return ResultUtil.error("流程状态异常");
		}

		return ResultUtil.success();
	}
1377

tangzhaoqian committed
1378 1379 1380 1381
	/**
	 * 目标确认-同意
	 */
	@PostMapping(value = "/update_target_confirmed")
tangzhaoqian committed
1382 1383
	@ApiOperation(value = "25.目标确认-同意", httpMethod = "POST", notes = "目标确认-同意")
	@ApiOperationSupport(order = 25)
1384 1385
	public Result<Object> updateTC(@CurrentUser UserBean userBean, @RequestParam Integer id) {

tangzhaoqian committed
1386
		Integer count2 = jxglAppraisalMapper.selectCount(new QueryWrapper<JxglAppraisal>().lambda()
1387 1388 1389
				.eq(JxglAppraisal::getId, id).in(JxglAppraisal::getSts, AppraisalSts.ASSESSMENT_COMPLETE.getType(),
						AppraisalSts.TERMINATION_ASSESSMENT.getType(), AppraisalSts.PERFORMANCE_ARCHIVE.getType()));

tangzhaoqian committed
1390 1391 1392
		if (count2 > 0) {
			return ResultUtil.error("考核已结束");
		}
1393

tangzhaoqian committed
1394
		JxglAppraisal appraisal = jxglAppraisalMapper.selectOne(new QueryWrapper<JxglAppraisal>().lambda()
1395 1396
				.eq(JxglAppraisal::getId, id).select(JxglAppraisal::getId, JxglAppraisal::getPerformanceAppraisalId));

tangzhaoqian committed
1397
		if (appraisal == null) {
1398
			return ResultUtil.error("考核不存在");
tangzhaoqian committed
1399
		}
1400 1401 1402 1403

		JxglProcessNode processNode = jxglProcessNodeMapper.selectOne(
				new QueryWrapper<JxglProcessNode>().lambda().eq(JxglProcessNode::getAppraisalId, appraisal.getId())
						.eq(JxglProcessNode::getSts, ProcessNodeSts.IN_EXECUTION.getType()));
tangzhaoqian committed
1404 1405 1406
		if (processNode == null) {
			return ResultUtil.error("流程不存在");
		}
1407

tangzhaoqian committed
1408
		if (ProcessType.TARGET_CONFIRMED.getType() == processNode.getProcessType()) {
1409

tangzhaoqian committed
1410
			if (!userBean.getEmpNum().equals(processNode.getExecutorId())) {
1411
				return ResultUtil.error("无权限操作该流程");
tangzhaoqian committed
1412 1413
			}

1414 1415 1416 1417 1418 1419 1420
			// 修改 目标确认 状态
			JxglProcessNode.builder().sts(ProcessNodeSts.EXECUTED.getType()).build()
					.update(new UpdateWrapper<JxglProcessNode>().lambda()
							.eq(JxglProcessNode::getAppraisalId, appraisal.getId())
							.eq(JxglProcessNode::getSts, ProcessNodeSts.IN_EXECUTION.getType()));
			JxglPerformanceAppraisal pA = jxglPerformanceAppraisalMapper
					.selectById(appraisal.getPerformanceAppraisalId());
tangzhaoqian committed
1421 1422
			if (pA != null && pA.getSts() > PerformanceAppraisalSts.TARGET_SETING.getType()) {
				// 修改 下一个节点状态
1423 1424 1425 1426 1427 1428 1429
				JxglProcessNode.builder().sts(ProcessNodeSts.IN_EXECUTION.getType()).build()
						.update(new UpdateWrapper<JxglProcessNode>().lambda()
								.eq(JxglProcessNode::getAppraisalId, appraisal.getId())
								.eq(JxglProcessNode::getProcessType, ProcessType.SELF_ASSESSMENT.getType()));

				jxglAppraisalMapper.updateById(JxglAppraisal.builder().id(appraisal.getId())
						.sts(AppraisalSts.SELF_ASSESSMENT.getType()).build());
tangzhaoqian committed
1430
			}
1431

tangzhaoqian committed
1432 1433 1434 1435 1436 1437
			JxglAppraisalLog appraisalLog = JxglAppraisalLog.builder().build();
			appraisalLog.setAppraisalId(appraisal.getId());
			appraisalLog.setExecutorId(userBean.getEmpNum());
			appraisalLog.setExecutorName(userBean.getUserInfo().getName());
			appraisalLog.setType(AppraisalLogType.TARGET_CONFIRMED.getType());
			appraisalLog.insert();
1438
		} else {
tangzhaoqian committed
1439 1440 1441 1442
			return ResultUtil.error("流程状态异常");
		}

		return ResultUtil.success();
1443

tangzhaoqian committed
1444
	}
1445

tangzhaoqian committed
1446 1447 1448 1449
	/**
	 * 目标确认-驳回目标
	 */
	@PostMapping(value = "/update_target_confirmed_reject")
tangzhaoqian committed
1450 1451
	@ApiOperation(value = "26.目标确认-驳回目标", httpMethod = "POST", notes = "目标确认-驳回目标")
	@ApiOperationSupport(order = 26)
1452 1453 1454 1455 1456 1457 1458
	public Result<Object> updateTCR(@CurrentUser UserBean userBean, @RequestBody AppraisalReject appraisalReject) {

		Integer count2 = jxglAppraisalMapper.selectCount(
				new QueryWrapper<JxglAppraisal>().lambda().eq(JxglAppraisal::getId, appraisalReject.getId()).in(
						JxglAppraisal::getSts, AppraisalSts.ASSESSMENT_COMPLETE.getType(),
						AppraisalSts.TERMINATION_ASSESSMENT.getType(), AppraisalSts.PERFORMANCE_ARCHIVE.getType()));

tangzhaoqian committed
1459 1460 1461
		if (count2 > 0) {
			return ResultUtil.error("考核已结束");
		}
1462

tangzhaoqian committed
1463
		JxglAppraisal appraisal = jxglAppraisalMapper.selectOne(new QueryWrapper<JxglAppraisal>().lambda()
1464 1465
				.eq(JxglAppraisal::getId, appraisalReject.getId()).select(JxglAppraisal::getId));

tangzhaoqian committed
1466
		if (appraisal == null) {
1467
			return ResultUtil.error("考核不存在");
tangzhaoqian committed
1468
		}
1469 1470 1471 1472 1473

		JxglProcessNode processNode = jxglProcessNodeMapper.selectOne(
				new QueryWrapper<JxglProcessNode>().lambda().eq(JxglProcessNode::getAppraisalId, appraisal.getId())
						.eq(JxglProcessNode::getSts, ProcessNodeSts.IN_EXECUTION.getType()));

tangzhaoqian committed
1474 1475 1476
		if (processNode == null) {
			return ResultUtil.error("流程不存在");
		}
1477

tangzhaoqian committed
1478
		if (ProcessType.TARGET_CONFIRMED.getType() == processNode.getProcessType()) {
1479

tangzhaoqian committed
1480
			if (!userBean.getEmpNum().equals(processNode.getExecutorId())) {
1481
				return ResultUtil.error("无权限操作该流程");
tangzhaoqian committed
1482 1483
			}

1484 1485 1486 1487 1488 1489 1490 1491 1492 1493 1494 1495 1496
			// 修改 目标确认 状态
			JxglProcessNode.builder().sts(ProcessNodeSts.NON_EXECUTION.getType()).build()
					.update(new UpdateWrapper<JxglProcessNode>().lambda()
							.eq(JxglProcessNode::getAppraisalId, appraisal.getId())
							.in(JxglProcessNode::getProcessType, ProcessType.TARGET_CONFIRMED.getType()));

			JxglProcessNode.builder().sts(ProcessNodeSts.IN_EXECUTION.getType()).build()
					.update(new UpdateWrapper<JxglProcessNode>().lambda()
							.eq(JxglProcessNode::getAppraisalId, appraisal.getId())
							.eq(JxglProcessNode::getProcessType, ProcessType.TARGET_FILL_IN.getType()));

			jxglAppraisalMapper.updateById(
					JxglAppraisal.builder().id(appraisal.getId()).sts(AppraisalSts.TARGET_FILL_IN.getType()).build());
tangzhaoqian committed
1497 1498 1499 1500 1501 1502 1503 1504

			JxglAppraisalLog appraisalLog = JxglAppraisalLog.builder().build();
			appraisalLog.setRemarks(appraisalReject.getRejectReason());
			appraisalLog.setAppraisalId(appraisal.getId());
			appraisalLog.setExecutorId(userBean.getEmpNum());
			appraisalLog.setExecutorName(userBean.getUserInfo().getName());
			appraisalLog.setType(AppraisalLogType.TARGET_DISMISS.getType());
			appraisalLog.insert();
1505 1506

		} else {
tangzhaoqian committed
1507 1508 1509 1510
			return ResultUtil.error("流程状态异常");
		}

		return ResultUtil.success();
1511

tangzhaoqian committed
1512
	}
1513

tangzhaoqian committed
1514
	/**
tangzhaoqian committed
1515
	 * 评价 -驳回目标
tangzhaoqian committed
1516 1517
	 */
	@PostMapping(value = "/update_superior_score_reject")
tangzhaoqian committed
1518 1519
	@ApiOperation(value = "27.评价 -驳回目标", httpMethod = "POST", notes = "评价 -驳回目标")
	@ApiOperationSupport(order = 27)
1520 1521 1522 1523 1524 1525 1526
	public Result<Object> updateSSR(@CurrentUser UserBean userBean, @RequestBody AppraisalReject appraisalReject) {

		Integer count2 = jxglAppraisalMapper.selectCount(
				new QueryWrapper<JxglAppraisal>().lambda().eq(JxglAppraisal::getId, appraisalReject.getId()).in(
						JxglAppraisal::getSts, AppraisalSts.ASSESSMENT_COMPLETE.getType(),
						AppraisalSts.TERMINATION_ASSESSMENT.getType(), AppraisalSts.PERFORMANCE_ARCHIVE.getType()));

tangzhaoqian committed
1527 1528 1529
		if (count2 > 0) {
			return ResultUtil.error("考核已结束");
		}
1530

tangzhaoqian committed
1531
		JxglAppraisal appraisal = jxglAppraisalMapper.selectOne(new QueryWrapper<JxglAppraisal>().lambda()
1532 1533
				.eq(JxglAppraisal::getId, appraisalReject.getId()).select(JxglAppraisal::getId));

tangzhaoqian committed
1534
		if (appraisal == null) {
1535
			return ResultUtil.error("考核不存在");
tangzhaoqian committed
1536
		}
1537 1538 1539 1540

		JxglProcessNode processNode = jxglProcessNodeMapper.selectOne(
				new QueryWrapper<JxglProcessNode>().lambda().eq(JxglProcessNode::getAppraisalId, appraisal.getId())
						.eq(JxglProcessNode::getSts, ProcessNodeSts.IN_EXECUTION.getType()));
tangzhaoqian committed
1541 1542 1543
		if (processNode == null) {
			return ResultUtil.error("流程不存在");
		}
1544

tangzhaoqian committed
1545 1546 1547
		if (!userBean.getEmpNum().equals(processNode.getExecutorId())) {
			return ResultUtil.error("无权限操作该流程");
		}
tangzhaoqian committed
1548

tangzhaoqian committed
1549 1550 1551 1552 1553 1554 1555 1556
		// 修改 目标确认 状态
		JxglProcessNode.builder().sts(ProcessNodeSts.NON_EXECUTION.getType()).build()
				.update(new UpdateWrapper<JxglProcessNode>().lambda()
						.eq(JxglProcessNode::getAppraisalId, appraisal.getId()).in(JxglProcessNode::getProcessType,
								ProcessType.TARGET_CONFIRMED.getType(),
								ProcessType.SELF_ASSESSMENT.getType(),
								ProcessType.SUPERIOR_SCORE.getType()
								));
1557

tangzhaoqian committed
1558 1559 1560 1561
		JxglProcessNode.builder().sts(ProcessNodeSts.IN_EXECUTION.getType()).build()
				.update(new UpdateWrapper<JxglProcessNode>().lambda()
						.eq(JxglProcessNode::getAppraisalId, appraisal.getId())
						.eq(JxglProcessNode::getProcessType, ProcessType.TARGET_FILL_IN.getType()));
tangzhaoqian committed
1562

tangzhaoqian committed
1563 1564 1565 1566
		// 删除 考核评定-自评
		jxglAppraisalAssessmentMapper.delete(new QueryWrapper<JxglAppraisalAssessment>().lambda()
				.eq(JxglAppraisalAssessment::getAppraisalId, appraisal.getId())
				.eq(JxglAppraisalAssessment::getType, AssessmentType.SELF_ASSESSMENT.getType()));
1567

tangzhaoqian committed
1568 1569 1570 1571 1572 1573 1574 1575 1576 1577
		List<JxglAppraisalIndicators> listAI = jxglAppraisalIndicatorsMapper.selectList(
				new QueryWrapper<JxglAppraisalIndicators>().lambda().select(JxglAppraisalIndicators::getId)
						.eq(JxglAppraisalIndicators::getAppraisalId, appraisal.getId()));
		List<Integer> listAIId = CollectionUtil.isNotEmpty(listAI)
				? listAI.stream().map(JxglAppraisalIndicators::getId).collect(Collectors.toList())
				: null;
		// 删除 考核指标评定-自评
		jxglAppraisalIndicatorsAssessmentMapper.delete(new QueryWrapper<JxglAppraisalIndicatorsAssessment>()
				.lambda().in(JxglAppraisalIndicatorsAssessment::getAppraisalIndicatorsId, listAIId)
				.eq(JxglAppraisalIndicatorsAssessment::getType, AssessmentType.SELF_ASSESSMENT.getType()));
1578

tangzhaoqian committed
1579 1580
		jxglAppraisalMapper.updateById(
				JxglAppraisal.builder().id(appraisal.getId()).sts(AppraisalSts.TARGET_FILL_IN.getType()).build());
1581

tangzhaoqian committed
1582 1583 1584 1585 1586 1587 1588
		JxglAppraisalLog appraisalLog = JxglAppraisalLog.builder().build();
		appraisalLog.setRemarks(appraisalReject.getRejectReason());
		appraisalLog.setAppraisalId(appraisal.getId());
		appraisalLog.setExecutorId(userBean.getEmpNum());
		appraisalLog.setExecutorName(userBean.getUserInfo().getName());
		appraisalLog.setType(AppraisalLogType.TARGET_DISMISS.getType());
		appraisalLog.insert();
tangzhaoqian committed
1589 1590

		return ResultUtil.success();
1591

tangzhaoqian committed
1592
	}
1593

tangzhaoqian committed
1594 1595 1596 1597
	/**
	 * 上级评价 -驳回评分
	 */
	@PostMapping(value = "/update_superior_reject_score")
tangzhaoqian committed
1598 1599
	@ApiOperation(value = "28.上级评价 -驳回评分", httpMethod = "POST", notes = "上级评价 -驳回评分")
	@ApiOperationSupport(order = 28)
1600 1601 1602 1603 1604 1605 1606
	public Result<Object> updateSRS(@CurrentUser UserBean userBean,@Validated @RequestBody AppraisalReject appraisalReject) {

		Integer count2 = jxglAppraisalMapper.selectCount(
				new QueryWrapper<JxglAppraisal>().lambda().eq(JxglAppraisal::getId, appraisalReject.getId()).in(
						JxglAppraisal::getSts, AppraisalSts.ASSESSMENT_COMPLETE.getType(),
						AppraisalSts.TERMINATION_ASSESSMENT.getType(), AppraisalSts.PERFORMANCE_ARCHIVE.getType()));

tangzhaoqian committed
1607 1608 1609
		if (count2 > 0) {
			return ResultUtil.error("考核已结束");
		}
1610

tangzhaoqian committed
1611
		JxglAppraisal appraisal = jxglAppraisalMapper.selectOne(new QueryWrapper<JxglAppraisal>().lambda()
1612 1613
				.eq(JxglAppraisal::getId, appraisalReject.getId()).select(JxglAppraisal::getId));

tangzhaoqian committed
1614
		if (appraisal == null) {
1615
			return ResultUtil.error("考核不存在");
tangzhaoqian committed
1616
		}
1617 1618 1619 1620

		JxglProcessNode processNode = jxglProcessNodeMapper.selectOne(
				new QueryWrapper<JxglProcessNode>().lambda().eq(JxglProcessNode::getAppraisalId, appraisal.getId())
						.eq(JxglProcessNode::getSts, ProcessNodeSts.IN_EXECUTION.getType()));
tangzhaoqian committed
1621 1622 1623
		if (processNode == null) {
			return ResultUtil.error("流程不存在");
		}
1624

tangzhaoqian committed
1625
		if (ProcessType.SUPERIOR_SCORE.getType() == processNode.getProcessType()) {
1626

tangzhaoqian committed
1627
			if (!userBean.getEmpNum().equals(processNode.getExecutorId())) {
1628
				return ResultUtil.error("无权限操作该流程");
tangzhaoqian committed
1629 1630
			}

1631 1632 1633 1634 1635 1636
			// 修改 状态
			JxglProcessNode.builder().sts(ProcessNodeSts.NON_EXECUTION.getType()).build()
					.update(new UpdateWrapper<JxglProcessNode>().lambda()
							.eq(JxglProcessNode::getAppraisalId, appraisal.getId())
							.eq(JxglProcessNode::getProcessType, ProcessType.SUPERIOR_SCORE.getType()));

tangzhaoqian committed
1637
			// 修改 上一个节点状态
1638 1639 1640 1641 1642
			JxglProcessNode.builder().sts(ProcessNodeSts.IN_EXECUTION.getType()).build()
					.update(new UpdateWrapper<JxglProcessNode>().lambda()
							.eq(JxglProcessNode::getAppraisalId, appraisal.getId())
							.eq(JxglProcessNode::getProcessType, ProcessType.SELF_ASSESSMENT.getType()));

tangzhaoqian committed
1643 1644 1645 1646
			// 删除 考核评定-自评
			jxglAppraisalAssessmentMapper.delete(new QueryWrapper<JxglAppraisalAssessment>().lambda()
					.eq(JxglAppraisalAssessment::getAppraisalId, appraisal.getId())
					.eq(JxglAppraisalAssessment::getType, AssessmentType.SELF_ASSESSMENT.getType()));
1647 1648 1649 1650 1651 1652 1653

			List<JxglAppraisalIndicators> listAI = jxglAppraisalIndicatorsMapper.selectList(
					new QueryWrapper<JxglAppraisalIndicators>().lambda().select(JxglAppraisalIndicators::getId)
							.eq(JxglAppraisalIndicators::getAppraisalId, appraisal.getId()));
			List<Integer> listAIId = listAI != null && listAI.size() > 0
					? listAI.stream().map(JxglAppraisalIndicators::getId).collect(Collectors.toList())
					: null;
tangzhaoqian committed
1654
			// 删除 考核指标评定-自评
1655 1656
			jxglAppraisalIndicatorsAssessmentMapper.delete(new QueryWrapper<JxglAppraisalIndicatorsAssessment>()
					.lambda().in(JxglAppraisalIndicatorsAssessment::getAppraisalIndicatorsId, listAIId)
tangzhaoqian committed
1657
					.eq(JxglAppraisalIndicatorsAssessment::getType, AssessmentType.SELF_ASSESSMENT.getType()));
1658 1659 1660 1661

			jxglAppraisalMapper.updateById(
					JxglAppraisal.builder().id(appraisal.getId()).sts(AppraisalSts.SELF_ASSESSMENT.getType()).build());

tangzhaoqian committed
1662 1663 1664 1665 1666 1667 1668
			JxglAppraisalLog appraisalLog = JxglAppraisalLog.builder().build();
			appraisalLog.setRemarks(appraisalReject.getRejectReason());
			appraisalLog.setAppraisalId(appraisal.getId());
			appraisalLog.setExecutorId(userBean.getEmpNum());
			appraisalLog.setExecutorName(userBean.getUserInfo().getName());
			appraisalLog.setType(AppraisalLogType.SCORE_DISMISS.getType());
			appraisalLog.insert();
1669 1670

		} else {
tangzhaoqian committed
1671 1672 1673 1674
			return ResultUtil.error("流程状态异常");
		}

		return ResultUtil.success();
1675

tangzhaoqian committed
1676
	}
1677

tangzhaoqian committed
1678
	/**
1679
	 * 评分提交
tangzhaoqian committed
1680 1681
	 */
	@PostMapping(value = "/save_score")
tangzhaoqian committed
1682 1683
	@ApiOperation(value = "29.评分提交", httpMethod = "POST", notes = "评分提交")
	@ApiOperationSupport(order = 29)
tangzhaoqian committed
1684
	@Log(title = "评分提交")
1685
	public Result<Object> saveScore(@CurrentUser UserBean userBean,
1686
			@Validated @RequestBody ValidList<AppraisalAssessment> appraisalAssessments) throws Exception{
1687

tangzhaoqian committed
1688
		Integer appraisalId = appraisalAssessments.get(0).getAppraisalId();
1689 1690 1691 1692 1693 1694 1695

		Integer count = jxglAppraisalMapper
				.selectCount(new QueryWrapper<JxglAppraisal>().lambda().eq(JxglAppraisal::getId, appraisalId).in(
						JxglAppraisal::getSts, AppraisalSts.ASSESSMENT_COMPLETE.getType(),
						AppraisalSts.TERMINATION_ASSESSMENT.getType(), AppraisalSts.PERFORMANCE_ARCHIVE.getType()));

		if (count > 0) {
tangzhaoqian committed
1696 1697
			return ResultUtil.error("考核已结束");
		}
1698 1699 1700 1701 1702

		JxglAppraisal appraisal = jxglAppraisalMapper
				.selectOne(new QueryWrapper<JxglAppraisal>().lambda().eq(JxglAppraisal::getId, appraisalId)
						.select(JxglAppraisal::getId, JxglAppraisal::getPerformanceAppraisalId));

tangzhaoqian committed
1703
		if (appraisal == null) {
1704
			return ResultUtil.error("考核不存在");
tangzhaoqian committed
1705
		}
1706 1707 1708 1709

		JxglProcessNode processNode = jxglProcessNodeMapper.selectOne(
				new QueryWrapper<JxglProcessNode>().lambda().eq(JxglProcessNode::getAppraisalId, appraisal.getId())
						.eq(JxglProcessNode::getSts, ProcessNodeSts.IN_EXECUTION.getType()));
tangzhaoqian committed
1710 1711 1712
		if (processNode == null) {
			return ResultUtil.error("流程不存在");
		}
1713 1714
		
		JxglBasicSetting bS = jxglService.selectAT(userBean.getOrgCode());
1715

1716
		Integer maxScore = bS.getMaxScore();
1717 1718 1719
		if (ProcessType.SELF_ASSESSMENT.getType() == processNode.getProcessType()
				|| ProcessType.SUPERIOR_SCORE.getType() == processNode.getProcessType()) {

tangzhaoqian committed
1720
			if (!userBean.getEmpNum().equals(processNode.getExecutorId())) {
1721
				return ResultUtil.error("无权限操作该流程");
tangzhaoqian committed
1722 1723
			}

1724 1725 1726 1727
			boolean hasAppraisalAssessment = false;
			
			for (AppraisalAssessment a : appraisalAssessments) {

tangzhaoqian committed
1728
				Integer type =  processNode.getProcessType();
1729

1730 1731 1732 1733 1734
						
				if (Double.valueOf(a.getScore()) > maxScore) {
					throw new CustomException("评分值不能大于最高分");
				}
						
tangzhaoqian committed
1735
				if (a.getAppraisalIndicatorsId() != null) {
1736 1737
					JxglAppraisalIndicatorsAssessment.builder().appraisalIndicatorsId(a.getAppraisalIndicatorsId())
							.assessorId(userBean.getEmpNum()).assessorName(userBean.getUserInfo().getName())
1738 1739 1740
							.score(a.getScore()).remarks(a.getRemarks())
							.type(ProcessType.SELF_ASSESSMENT.getType() == processNode.getProcessType() ? AssessmentType.SELF_ASSESSMENT.getType() : AssessmentType.SUPERIOR_SCORE.getType())
							.build().insert();
1741 1742 1743

				} else {
					JxglAppraisalAssessment.builder().appraisalId(a.getAppraisalId()).assessorId(userBean.getEmpNum())
1744
							.assessorName(userBean.getUserInfo().getName()).comprehensiveScore(Double.valueOf(a.getScore()))
1745 1746 1747 1748
							.remarks(a.getRemarks())
							.type(ProcessType.SELF_ASSESSMENT.getType() == processNode.getProcessType() ? AssessmentType.SELF_ASSESSMENT.getType() : AssessmentType.SUPERIOR_SCORE.getType())
							.level(a.getLevel())
							.build().insert();
1749

1750
					hasAppraisalAssessment = true;
tangzhaoqian committed
1751
				}
1752

1753 1754 1755 1756 1757
			};
			
			if (!hasAppraisalAssessment) {
				throw new CustomException("必须填写综合评分");
			}
tangzhaoqian committed
1758

1759 1760 1761 1762 1763 1764
			// 修改 状态
			JxglProcessNode.builder().sts(ProcessNodeSts.EXECUTED.getType()).build()
					.update(new UpdateWrapper<JxglProcessNode>().lambda()
							.eq(JxglProcessNode::getAppraisalId, appraisal.getId())
							.eq(JxglProcessNode::getSts, ProcessNodeSts.IN_EXECUTION.getType()));

1765 1766 1767 1768 1769 1770 1771 1772 1773 1774 1775 1776 1777
			if (ProcessType.SELF_ASSESSMENT.getType() == processNode.getProcessType()) {
				JxglProcessNode.builder().sts(ProcessNodeSts.IN_EXECUTION.getType()).build()
				.update(new UpdateWrapper<JxglProcessNode>().lambda()
						.eq(JxglProcessNode::getAppraisalId, appraisal.getId())
						.eq(JxglProcessNode::getProcessType, ProcessType.SUPERIOR_SCORE.getType()));
				
				jxglAppraisalMapper.updateById(JxglAppraisal.builder().id(appraisal.getId())
							.sts(AppraisalSts.SUPERIOR_SCORE.getType()).build());
				
			}else if(ProcessType.SUPERIOR_SCORE.getType() == processNode.getProcessType()) {
				
				JxglPerformanceAppraisal pA = jxglPerformanceAppraisalMapper
						.selectById(appraisal.getPerformanceAppraisalId());
1778

1779
				if (pA != null && pA.getSts() > PerformanceAppraisalSts.PERFORMANCE_SCORE.getType()) {
1780

1781 1782 1783 1784 1785
					JxglProcessNode.builder().sts(ProcessNodeSts.IN_EXECUTION.getType()).build()
					.update(new UpdateWrapper<JxglProcessNode>().lambda()
							.eq(JxglProcessNode::getAppraisalId, appraisal.getId())
							.eq(JxglProcessNode::getProcessType, ProcessType.RESULT_VERIFICATION.getType()));
					
1786
					jxglAppraisalMapper.updateById(JxglAppraisal.builder().id(appraisal.getId())
1787 1788
								.sts(AppraisalSts.RESULT_VERIFICATION.getType()).build());
					
1789
				}
1790
				
tangzhaoqian committed
1791
				// 算 总评分 ---- 自评权重*自评综合分 + 上级评分权重*上级综合评分 = 总评分
1792 1793 1794
				List<JxglProcessNode> listProcessNode = jxglProcessNodeMapper.selectList(new QueryWrapper<JxglProcessNode>().lambda()
						.select(JxglProcessNode::getWeight,JxglProcessNode::getProcessType)
						.orderByAsc(JxglProcessNode::getProcessType)
tangzhaoqian committed
1795 1796 1797 1798
						.eq(JxglProcessNode::getAppraisalId, appraisal.getId())
						.in(JxglProcessNode::getProcessType, 
								ProcessType.SELF_ASSESSMENT.getType()
								,ProcessType.SUPERIOR_SCORE.getType()));
1799 1800 1801
			
				List<JxglAppraisalAssessment> listAppraisalAssessment = jxglAppraisalAssessmentMapper.selectList(new QueryWrapper<JxglAppraisalAssessment>().lambda()
						.select(JxglAppraisalAssessment::getType,JxglAppraisalAssessment::getComprehensiveScore)
tangzhaoqian committed
1802
						.eq(JxglAppraisalAssessment::getAppraisalId, appraisal.getId())
1803 1804 1805 1806 1807 1808 1809 1810 1811
						.orderByAsc(JxglAppraisalAssessment::getType)
						);
				Double selfAssessment = 0D;
				Double superiorAssessment = 0D;
				
				Integer aWeights = 0;
				Integer bWeights = 0;
				Double total = 0D;
				String level = null;
tangzhaoqian committed
1812
				
tangzhaoqian committed
1813
				if (CollectionUtil.isNotEmpty(listProcessNode)) {
1814 1815 1816 1817 1818
					aWeights = listProcessNode.stream().filter(p -> p.getProcessType() == ProcessType.SELF_ASSESSMENT.getType()).map(JxglProcessNode::getWeight).findFirst().orElse(null);
					bWeights = listProcessNode.stream().filter(p -> p.getProcessType() == ProcessType.SUPERIOR_SCORE.getType()).map(JxglProcessNode::getWeight).findFirst().orElse(null);
					
				}
				
tangzhaoqian committed
1819
				if (CollectionUtil.isNotEmpty(listAppraisalAssessment)) {
1820 1821 1822 1823 1824 1825
					selfAssessment = listAppraisalAssessment.stream().filter(a -> a.getType() == AssessmentType.SELF_ASSESSMENT.getType()).map(JxglAppraisalAssessment::getComprehensiveScore).findFirst().orElse(null) ;
					superiorAssessment = listAppraisalAssessment.stream().filter(a -> a.getType() == AssessmentType.SUPERIOR_SCORE.getType()).map(JxglAppraisalAssessment::getComprehensiveScore).findFirst().orElse(null);
				
				}
				
				if (selfAssessment != null && superiorAssessment != null) {
tangzhaoqian committed
1826 1827 1828
					Integer min = 0;
					Integer max = 0;
					
1829
					total = aWeights*0.01*selfAssessment + bWeights*0.01*superiorAssessment;
tangzhaoqian committed
1830 1831 1832 1833 1834
					System.out.println(total);
					System.out.println(aWeights);
					System.out.println(selfAssessment);
					System.out.println(bWeights);
					System.out.println(superiorAssessment);
1835 1836 1837
					
					List<JxglPerformanceRating> listPR = bS.getPerformanceRatings();
					for (JxglPerformanceRating pR : listPR) {
1838 1839 1840
						min = min <= pR.getSectionMinScore() ? pR.getSectionMinScore() : min;
						max = max >= pR.getSectionMaxScore() ? pR.getSectionMaxScore() : max;
						level = pR.getSectionMinScore() < total && total <= pR.getSectionMaxScore()   ? pR.getName() : null;
1841
					}
1842 1843 1844 1845
					
					System.out.println(min);
					System.out.println(max);
					System.out.println(level);
tangzhaoqian committed
1846 1847 1848 1849 1850 1851 1852 1853 1854 1855 1856 1857
					if (level == null) {
						for (JxglPerformanceRating pR : listPR) {
							if (total < min && pR.getSectionMinScore().equals(min)) {
								level = pR.getName();
								break;
							}
							if (total > max && pR.getSectionMaxScore().equals(max)) {
								level = pR.getName();
								break;
							}
						}
					}
1858
					System.out.println(level);
1859 1860 1861 1862 1863 1864 1865 1866
					
					// 更新 考核-总分 等级
					jxglAppraisalMapper.updateById(JxglAppraisal.builder().id(appraisal.getId())
							.total(total).level(level).build());
				}else {
					throw new CustomException("评分数据存在异常");
				}
				
tangzhaoqian committed
1867
			}
1868
			
tangzhaoqian committed
1869 1870 1871 1872
			JxglAppraisalLog appraisalLog = JxglAppraisalLog.builder().build();
			appraisalLog.setAppraisalId(appraisal.getId());
			appraisalLog.setExecutorId(userBean.getEmpNum());
			appraisalLog.setExecutorName(userBean.getUserInfo().getName());
1873 1874 1875
			appraisalLog.setType(ProcessType.SELF_ASSESSMENT.getType() == processNode.getProcessType()
					? AppraisalLogType.SELF_ASSESSMENT.getType()
					: AppraisalLogType.SUPERIOR_SCORE.getType());
tangzhaoqian committed
1876
			appraisalLog.insert();
1877 1878

		} else {
tangzhaoqian committed
1879 1880 1881 1882 1883
			return ResultUtil.error("流程状态异常");
		}

		return ResultUtil.success();
	}
1884

tangzhaoqian committed
1885 1886 1887 1888
	/**
	 * 结果确认-确认
	 */
	@PostMapping(value = "/result_verification")
tangzhaoqian committed
1889 1890
	@ApiOperation(value = "30.结果确认-确认", httpMethod = "POST", notes = "结果确认-确认")
	@ApiOperationSupport(order = 30)
1891 1892 1893 1894 1895 1896 1897
	public Result<Object> resultVerification(@CurrentUser UserBean userBean, @RequestParam Integer id) {

		Integer count = jxglAppraisalMapper.selectCount(new QueryWrapper<JxglAppraisal>().lambda()
				.eq(JxglAppraisal::getId, id).in(JxglAppraisal::getSts, AppraisalSts.ASSESSMENT_COMPLETE.getType(),
						AppraisalSts.TERMINATION_ASSESSMENT.getType(), AppraisalSts.PERFORMANCE_ARCHIVE.getType()));

		if (count > 0) {
tangzhaoqian committed
1898 1899
			return ResultUtil.error("考核已结束");
		}
1900 1901 1902 1903

		JxglAppraisal appraisal = jxglAppraisalMapper.selectOne(
				new QueryWrapper<JxglAppraisal>().lambda().eq(JxglAppraisal::getId, id).select(JxglAppraisal::getId));

tangzhaoqian committed
1904
		if (appraisal == null) {
1905
			return ResultUtil.error("考核不存在");
tangzhaoqian committed
1906
		}
1907 1908 1909 1910

		JxglProcessNode processNode = jxglProcessNodeMapper.selectOne(
				new QueryWrapper<JxglProcessNode>().lambda().eq(JxglProcessNode::getAppraisalId, appraisal.getId())
						.eq(JxglProcessNode::getSts, ProcessNodeSts.IN_EXECUTION.getType()));
tangzhaoqian committed
1911 1912 1913
		if (processNode == null) {
			return ResultUtil.error("流程不存在");
		}
1914

tangzhaoqian committed
1915
		if (ProcessType.RESULT_VERIFICATION.getType() == processNode.getProcessType()) {
1916

tangzhaoqian committed
1917
			if (!userBean.getEmpNum().equals(processNode.getExecutorId())) {
1918
				return ResultUtil.error("无权限操作该流程");
tangzhaoqian committed
1919
			}
1920 1921 1922 1923 1924 1925 1926

			// 修改 状态
			JxglProcessNode.builder().sts(ProcessNodeSts.EXECUTED.getType()).build()
					.update(new UpdateWrapper<JxglProcessNode>().lambda()
							.eq(JxglProcessNode::getAppraisalId, appraisal.getId())
							.eq(JxglProcessNode::getSts, ProcessNodeSts.IN_EXECUTION.getType()));

1927
			jxglAppraisalMapper.updateById(JxglAppraisal.builder().id(id).sts(AppraisalSts.ASSESSMENT_COMPLETE.getType()).build());
1928

tangzhaoqian committed
1929 1930 1931 1932 1933 1934
			JxglAppraisalLog appraisalLog = JxglAppraisalLog.builder().build();
			appraisalLog.setAppraisalId(appraisal.getId());
			appraisalLog.setExecutorId(userBean.getEmpNum());
			appraisalLog.setExecutorName(userBean.getUserInfo().getName());
			appraisalLog.setType(AppraisalLogType.RESULT_VERIFICATION.getType());
			appraisalLog.insert();
1935 1936

		} else {
tangzhaoqian committed
1937 1938 1939 1940 1941
			return ResultUtil.error("流程状态异常");
		}

		return ResultUtil.success();
	}
1942

tangzhaoqian committed
1943 1944 1945 1946
	/**
	 * 结果确认-改分
	 */
	@PostMapping(value = "/change_score")
tangzhaoqian committed
1947 1948
	@ApiOperation(value = "31.结果确认-改分", httpMethod = "POST", notes = "结果确认-改分")
	@ApiOperationSupport(order = 31)
1949
	@Log(title = "绩效管理-结果确认-改分", businessType = BusinessType.UPDATE)
1950 1951 1952
	public Result<Object> changeScore(@CurrentUser UserBean userBean,
			@Validated @RequestBody AppraisalAssessment appraisalAssessment) {

tangzhaoqian committed
1953
		Integer count2 = jxglAppraisalMapper.selectCount(new QueryWrapper<JxglAppraisal>().lambda()
1954 1955
				.eq(JxglAppraisal::getId, appraisalAssessment.getAppraisalId()).in(JxglAppraisal::getSts,
						AppraisalSts.ASSESSMENT_COMPLETE.getType(), AppraisalSts.TERMINATION_ASSESSMENT.getType(),
tangzhaoqian committed
1956
						AppraisalSts.PERFORMANCE_ARCHIVE.getType()));
1957

tangzhaoqian committed
1958 1959 1960
		if (count2 > 0) {
			return ResultUtil.error("考核已结束");
		}
1961

tangzhaoqian committed
1962
		JxglAppraisal appraisal = jxglAppraisalMapper.selectOne(new QueryWrapper<JxglAppraisal>().lambda()
1963 1964
				.eq(JxglAppraisal::getId, appraisalAssessment.getAppraisalId()).select(JxglAppraisal::getId));

tangzhaoqian committed
1965
		if (appraisal == null) {
1966
			return ResultUtil.error("考核不存在");
tangzhaoqian committed
1967
		}
1968 1969 1970 1971

		JxglProcessNode processNode = jxglProcessNodeMapper.selectOne(
				new QueryWrapper<JxglProcessNode>().lambda().eq(JxglProcessNode::getAppraisalId, appraisal.getId())
						.eq(JxglProcessNode::getSts, ProcessNodeSts.IN_EXECUTION.getType()));
tangzhaoqian committed
1972 1973 1974
		if (processNode == null) {
			return ResultUtil.error("流程不存在");
		}
1975 1976 1977 1978 1979 1980 1981
		
		JxglBasicSetting bS = jxglService.selectAT(userBean.getOrgCode());

		Integer maxScore = bS.getMaxScore();
		if (Double.valueOf(appraisalAssessment.getScore()) > maxScore) {
			throw new CustomException("评分值不能大于最高分");
		}
1982

tangzhaoqian committed
1983
		if (ProcessType.RESULT_VERIFICATION.getType() == processNode.getProcessType()) {
1984

tangzhaoqian committed
1985
			if (!userBean.getEmpNum().equals(processNode.getExecutorId())) {
1986
				return ResultUtil.error("无权限操作该流程");
tangzhaoqian committed
1987
			}
1988 1989 1990 1991
			
			// 更新 考核-总分 等级
			jxglAppraisalMapper.updateById(JxglAppraisal.builder().id(appraisal.getId())
					.total(Double.valueOf(appraisalAssessment.getScore())).level(appraisalAssessment.getLevel()).build());
1992

tangzhaoqian committed
1993 1994 1995 1996 1997 1998 1999
			JxglAppraisalLog appraisalLog = JxglAppraisalLog.builder().build();
			appraisalLog.setRemarks(appraisalAssessment.getRemarks());
			appraisalLog.setAppraisalId(appraisal.getId());
			appraisalLog.setExecutorId(userBean.getEmpNum());
			appraisalLog.setExecutorName(userBean.getUserInfo().getName());
			appraisalLog.setType(AppraisalLogType.UPDATE_SCORE.getType());
			appraisalLog.insert();
2000 2001

		} else {
tangzhaoqian committed
2002 2003 2004 2005 2006
			return ResultUtil.error("流程状态异常");
		}

		return ResultUtil.success();
	}
2007

tangzhaoqian committed
2008 2009 2010 2011
	/**
	 * 查询-我的绩效-员工绩效
	 */
	@PostMapping(value = "/selects_my_emp_performance")
tangzhaoqian committed
2012 2013
	@ApiOperation(value = "32.查询-我的绩效-员工绩效", httpMethod = "POST", notes = "查询-我的绩效-员工绩效")
	@ApiOperationSupport(order = 32)
2014
	@Log(title = "绩效管理-查询-我的绩效-员工绩效")
2015
	public Result<Object> selectsMEP(@CurrentUser UserBean userBean, @RequestBody EmpPerformanceQuery query) {
tangzhaoqian committed
2016 2017
		Integer orgCode = userBean.getOrgCode();
		Integer empNum = userBean.getEmpNum();
2018
		IPage<JxglAppraisal> page = new Page<JxglAppraisal>(query.getCurrentPage(), query.getTotalPage());
tangzhaoqian committed
2019
		query.setOrgCode(orgCode);
2020

2021 2022 2023 2024 2025
		List<ZzglBmgwM> listBM = zzglBmgwMMapper.selectList(new QueryWrapper<ZzglBmgwM>().lambda()
				.select(ZzglBmgwM::getId)
				.eq(ZzglBmgwM::getOrgCode, userBean.getOrgCode())
				.eq(ZzglBmgwM::getLeader, empNum));
		System.out.println("listBM-----"+ listBM);
tangzhaoqian committed
2026 2027 2028 2029
		ZzglBmgwM ZzglBmgwM = CollUtil.getFirst(listBM);
		if (ZzglBmgwM == null) {
			return ResultUtil.success();
		}
2030

tangzhaoqian committed
2031
		List<YgglMainEmp> users = zzglBmgwMService.selectOtherlistent(orgCode, ZzglBmgwM.getId());
2032
		List<Integer> empNums = CollUtil.toList();
tangzhaoqian committed
2033
		if (CollectionUtil.isNotEmpty(empNums)) {
tangzhaoqian committed
2034 2035
			empNums = users.stream().map(YgglMainEmp::getEmpNum).collect(Collectors.toList());
		}
2036 2037 2038
		
		if (query.getBmId() != null) {
			List<YgglMainEmp> usersQuery = zzglBmgwMService.selectOtherlistent(orgCode, query.getBmId());
tangzhaoqian committed
2039
			if (CollectionUtil.isNotEmpty(empNums)) {
2040 2041 2042 2043 2044 2045 2046
				List<Integer> empNumsQuery = usersQuery.stream().map(YgglMainEmp::getEmpNum).collect(Collectors.toList());
				empNums = empNums.stream().filter(e -> empNumsQuery.contains(e)).collect(Collectors.toList());
			}else {
				return ResultUtil.data(null);
			}
		}
		
tangzhaoqian committed
2047
		if (CollectionUtil.isNotEmpty(empNums)) {
2048 2049 2050
			return ResultUtil.data(null);
		}
		
tangzhaoqian committed
2051 2052
		query.setEmpNums(empNums);
		IPage<JxglAppraisal> pageA = jxglAppraisalMapper.selectMyEmpByQuery(page, query);
2053

tangzhaoqian committed
2054 2055
		List<JxglAppraisal> listA = pageA.getRecords();

2056 2057
		return ResultUtil.data(pageA, listA);

tangzhaoqian committed
2058
	}
2059
}