SpmkServiceImpl.java 24.7 KB
Newer Older
yuquan.zhu committed
1 2
package cn.timer.api.controller.spmk;

3
import java.util.ArrayList;
tangzhaoqian committed
4
import java.util.Date;
yuquan.zhu committed
5 6
import java.util.List;

7 8
import javax.validation.Valid;

yuquan.zhu committed
9 10
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.transaction.annotation.Transactional;
11
import org.springframework.validation.BindingResult;
yuquan.zhu committed
12 13 14 15 16 17 18 19 20 21 22 23
import org.springframework.web.bind.annotation.DeleteMapping;
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.PathVariable;
import org.springframework.web.bind.annotation.PostMapping;
import org.springframework.web.bind.annotation.PutMapping;
import org.springframework.web.bind.annotation.RequestBody;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RestController;

import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
import com.baomidou.mybatisplus.core.metadata.IPage;
import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
24
import com.github.xiaoymin.knife4j.annotations.ApiOperationSupport;
yuquan.zhu committed
25 26

import cn.hutool.core.bean.BeanUtil;
tangzhaoqian committed
27
import cn.hutool.core.collection.CollUtil;
28
import cn.hutool.core.lang.Console;
yuquan.zhu committed
29
import cn.hutool.core.util.ObjectUtil;
tangzhaoqian committed
30
import cn.hutool.core.util.StrUtil;
31
import cn.hutool.json.JSONObject;
32
import cn.timer.api.aspect.lang.annotation.BindingResultCtrol;
33 34 35 36
import cn.timer.api.bean.spmk.SpmkApprovalG;
import cn.timer.api.bean.spmk.SpmkApprovalTemplate;
import cn.timer.api.bean.spmk.SpmkApprovalTemplateG;
import cn.timer.api.bean.spmk.SpmkApproveDetail;
37
import cn.timer.api.bean.spmk.SpmkApproveExecuteRecord;
38 39
import cn.timer.api.bean.spmk.SpmkApproveSummary;
import cn.timer.api.bean.spmk.SpmkCustomApproval;
tangzhaoqian committed
40
import cn.timer.api.bean.spmk.SpmkExecutor;
yuquan.zhu committed
41
import cn.timer.api.bean.spmk.SpmkIcon;
42
import cn.timer.api.bean.spmk.SpmkInitiatorConfig;
43
import cn.timer.api.bean.yggl.YgglMainEmp;
yuquan.zhu committed
44 45
import cn.timer.api.config.annotation.CurrentUser;
import cn.timer.api.config.annotation.UserBean;
46 47 48 49 50 51 52 53 54
import cn.timer.api.dao.spmk.SpmkApprovalGMapper;
import cn.timer.api.dao.spmk.SpmkApprovalTemplateGMapper;
import cn.timer.api.dao.spmk.SpmkApprovalTemplateMapper;
import cn.timer.api.dao.spmk.SpmkApproveDetailMapper;
import cn.timer.api.dao.spmk.SpmkApproveExecuteRecordMapper;
import cn.timer.api.dao.spmk.SpmkApproveSummaryMapper;
import cn.timer.api.dao.spmk.SpmkCustomApprovalMapper;
import cn.timer.api.dao.spmk.SpmkExecutorMapper;
import cn.timer.api.dao.spmk.SpmkInitiatorConfigMapper;
55
import cn.timer.api.dao.yggl.YgglMainEmpMapper;
56
import cn.timer.api.dto.spmk.ApprovingDto;
57
import cn.timer.api.dto.spmk.FlowChildren;
58
import cn.timer.api.dto.spmk.FromData;
59
import cn.timer.api.dto.spmk.MySummaryQueryDto;
60
import cn.timer.api.dto.spmk.Router;
61 62 63 64
import cn.timer.api.dto.spmk.SpmkApprovalTemplateDto;
import cn.timer.api.dto.spmk.SpmkApproveDetailDto;
import cn.timer.api.dto.spmk.SpmkApproveSummaryDto;
import cn.timer.api.dto.spmk.SpmkCustomApprovalDto;
65
import cn.timer.api.dto.spmk.SummaryQueryDto;
yuquan.zhu committed
66 67
import cn.timer.api.utils.Result;
import cn.timer.api.utils.ResultUtil;
68
import cn.timer.api.utils.router.RouterUtils;
yuquan.zhu committed
69 70 71 72 73 74 75 76 77 78 79
import io.swagger.annotations.Api;
import io.swagger.annotations.ApiOperation;

@Api(tags = "3.0审批模块")
@RestController
@Transactional
@RequestMapping(value = "/spmk",  
produces = { "application/json","multipart/form-data" })
public class SpmkServiceImpl {

	@Autowired
80 81 82 83 84 85 86 87 88 89 90
    private SpmkApprovalTemplateGMapper spmkApprovalTemplateGMapper;
	
	@Autowired
    private SpmkApprovalTemplateMapper spmkApprovalTemplateMapper;
	
	@Autowired
    private SpmkApprovalGMapper spmkApprovalGMapper;
	
	@Autowired
    private SpmkCustomApprovalMapper spmkCustomApprovalMapper;
	
tangzhaoqian committed
91
	//TODO 新增或编辑-审批模板组
92
	/**
93
	 * 新增或编辑-审批模板组
94
	 */
95
	@PostMapping(value = "/save_approval_template_g")
96
	@ApiOperation(value = "1.新增或编辑-审批模板组", httpMethod = "POST", notes = "新增或编辑-审批模板组")
97
	@ApiOperationSupport(order = 1)
98
	public Result<Object> saveAtg(@RequestBody SpmkApprovalTemplateG spmkApprovalTemplateG){
99
		
100
        return spmkApprovalTemplateG.insertOrUpdate() ? ResultUtil.data(spmkApprovalTemplateG, "操作成功!") : ResultUtil.error("操作失败!");
101 102 103 104
		
	}
	
	/**
105
	 * 删除-审批模板组
106
	 */
107
	@DeleteMapping(value = "/delete_approval_template_g/{id}")
108 109
	@ApiOperation(value = "2.删除-审批模板组", httpMethod = "DELETE", notes = "删除-审批模板组")
	@ApiOperationSupport(order = 2)
110
	public Result<Object> deleteAtgById(@PathVariable int id){
111
		
112 113 114 115
		if (spmkApprovalTemplateMapper.selectCount(new QueryWrapper<SpmkApprovalTemplate>().lambda().eq(SpmkApprovalTemplate::getApprovalTemplateGId, id)) > 0 ) 
			return ResultUtil.error("审批模板组存在 模板,不可直接删除!");
		
		
116
        return SpmkApprovalTemplateG.builder().id(id).build().deleteById() ? ResultUtil.success("操作成功!") : ResultUtil.error("没有找到该对象");
117 118 119 120
		
	}
	
	/**
121
	 * 查询列表-审批模板组
122
	 */
123
	@GetMapping(value = "/list_approval_template_g")
124 125
	@ApiOperation(value = "3.查询列表-审批模板组", httpMethod = "GET", notes = "查询列表-审批模板组")
	@ApiOperationSupport(order = 3)
126 127 128
	public Result<Object> selectListAtg(){
        
        return ResultUtil.data(spmkApprovalTemplateGMapper.selectListAtInAtg(),"操作成功!");
129 130
	}
	
131 132 133
	/**
	 * 排序-审批模板组
	 */
tangzhaoqian committed
134
	@PutMapping(value = "/update_approval_template_g")
135 136
	@ApiOperation(value = "4.排序-审批模板组", httpMethod = "PUT", notes = "排序-审批模板组")
	@ApiOperationSupport(order = 4)
tangzhaoqian committed
137
	public Result<Object> ranksAtg(@RequestBody List<SpmkApprovalTemplateG> list){
138 139 140

        return spmkApprovalTemplateGMapper.updateListRandsById(list) ? ResultUtil.success("操作成功!") : ResultUtil.error("操作失败!");
	}
141
	
142 143 144 145 146
	//TODO 审批模板
	/**
	 * 新增或编辑-审批模板
	 */
	@PostMapping(value = "/save_approval_template")
147 148
	@ApiOperation(value = "5.新增或编辑-审批模板", httpMethod = "POST", notes = "新增或编辑-审批模板")
	@ApiOperationSupport(order = 5)
149 150 151 152 153 154 155
	public Result<Object> saveAt(@RequestBody SpmkApprovalTemplateDto spmkApprovalTemplateDto){
		Integer approvalTemplateGId = spmkApprovalTemplateDto.getApprovalTemplateGId();
		if (ObjectUtil.isNull(approvalTemplateGId)) 
			return ResultUtil.error("操作失败!-1");

		SpmkApprovalTemplate at = SpmkApprovalTemplate.builder().build();

156
		// 克隆 SpmkApprovalTemplateDto对象 到 SpmkApprovalTemplate对象,排除属性froms,router
157
		BeanUtil.copyProperties(spmkApprovalTemplateDto, at , "froms","router");
158
		// 序列化 后 写入 SpmkApprovalTemplate对象
159 160 161
		at.setFroms(ObjectUtil.serialize(spmkApprovalTemplateDto.getFroms()));
		at.setRouter(ObjectUtil.serialize(spmkApprovalTemplateDto.getRouter()));
		
162 163 164 165 166 167 168
		if (!at.insertOrUpdate()) 
			return ResultUtil.error("操作失败!-2");
		
		// 清空前端不需要的字段再返回,节省流量
		at.setFroms(null);
		at.setRouter(null);
		return  ResultUtil.data(at, "操作成功!");
169 170
		
	}
171
	
172 173 174 175
	/**
	 * 删除-审批模板
	 */
	@DeleteMapping(value = "/delete_approval_template/{id}")
176 177
	@ApiOperation(value = "6.删除-审批模板", httpMethod = "DELETE", notes = "删除-审批模板")
	@ApiOperationSupport(order = 6)
178 179 180 181 182 183 184 185 186 187
	public Result<Object> deleteAtById(@PathVariable int id){
		
        return SpmkApprovalTemplate.builder().id(id).build().deleteById() ? ResultUtil.success("操作成功!") : ResultUtil.error("没有找到该对象");
		
	}

	/**
	 * id查询-审批模板
	 */
	@GetMapping(value = "/select_approval_template")
188 189
	@ApiOperation(value = "7.id查询-审批模板", httpMethod = "GET", notes = "id查询-审批模板")
	@ApiOperationSupport(order = 7)
190 191 192 193 194 195 196 197 198
	public Result<Object> selectAtById(@PathVariable int id){
        
        return ResultUtil.data(SpmkApprovalTemplate.builder().id(id).build().selectById(),"操作成功!");
        
	}
	
	/**
	 * 排序-审批模板
	 */
tangzhaoqian committed
199
	@PutMapping(value = "/update_approval_template")
200 201
	@ApiOperation(value = "8.查询列表-审批模板组", httpMethod = "PUT", notes = "查询列表-审批模板组")
	@ApiOperationSupport(order = 8)
tangzhaoqian committed
202
	public Result<Object> ranksAt(@RequestBody List<SpmkApprovalTemplate> list){
203 204 205 206

        return spmkApprovalTemplateMapper.updateListRandsById(list) ? ResultUtil.success("操作成功!") : ResultUtil.error("操作失败!");
	
	}
207 208
	
	
209 210
	
	//TODO 审批组
211
	/**
212
	 * 新增或编辑-审批组
213
	 */
214
	@PostMapping(value = "/save_approval_g")
215 216
	@ApiOperation(value = "9.新增或编辑-审批组", httpMethod = "POST", notes = "新增或编辑-审批组")
	@ApiOperationSupport(order = 9)
217 218
	public Result<Object> saveAg(@CurrentUser UserBean userBean,@RequestBody SpmkApprovalG spmkApprovalG){
		spmkApprovalG.setOrgCode(userBean.getOrgCode());
219
		return spmkApprovalG.insertOrUpdate() ? ResultUtil.data(spmkApprovalG, "操作成功!") : ResultUtil.error("操作失败!");
220
		
221 222 223 224 225 226
	}
	
	/**
	 * 删除-审批组
	 */
	@DeleteMapping(value = "/delete_approval_g/{id}")
227 228
	@ApiOperation(value = "10.删除-审批组", httpMethod = "DELETE", notes = "删除-审批组")
	@ApiOperationSupport(order = 10)
229 230
	public Result<Object> deleteAgById(@PathVariable int id){
		
231 232 233
		if (spmkCustomApprovalMapper.selectCount(new QueryWrapper<SpmkCustomApproval>().lambda().eq(SpmkCustomApproval::getApprovalGId, id)) > 0 ) 
			return ResultUtil.error("审批组存在 自定义审批,不可直接删除!");
		
234
        return SpmkApprovalG.builder().id(id).build().deleteById() ? ResultUtil.success("操作成功!") : ResultUtil.error("没有找到该对象");
235 236 237
		
	}
	
238 239 240 241
	/**
	 * 查询列表-审批组
	 */
	@GetMapping(value = "/list_approval_g")
242 243
	@ApiOperation(value = "11.查询列表-审批组", httpMethod = "GET", notes = "查询列表-审批组")
	@ApiOperationSupport(order = 11)
244 245 246
	public Result<Object> selectListAg(@CurrentUser UserBean userBean){
		
        return ResultUtil.data(spmkApprovalGMapper.selectListAgInCa(userBean.getOrgCode(), userBean.getEmpNum()),"操作成功!");
247
	
248
	}
249
	
250 251 252
	/**
	 * 排序-审批组
	 */
tangzhaoqian committed
253
	@PutMapping(value = "/update_approval_g")
254 255
	@ApiOperation(value = "12.排序-审批组", httpMethod = "PUT", notes = "排序-审批组")
	@ApiOperationSupport(order = 12)
tangzhaoqian committed
256
	public Result<Object> ranksAg(@RequestBody List<SpmkApprovalG> list){
257 258
        return spmkApprovalGMapper.updateListRandsById(list) ? ResultUtil.success("操作成功!") : ResultUtil.error("操作失败!");
	}
259
	
260
	//TODO 自定义审批
261
	
262 263 264 265
	/**
	 * 新增或编辑-自定义审批
	 */
	@PostMapping(value = "/save_custom_approval")
266 267
	@ApiOperation(value = "13.新增或编辑-自定义审批", httpMethod = "POST", notes = "新增或编辑-自定义审批")
	@ApiOperationSupport(order = 13)
268 269 270 271 272 273 274 275 276 277 278 279 280 281 282 283 284 285 286
	@Transactional(rollbackFor = Exception.class)
	public Result<Object> saveCa(@RequestBody SpmkCustomApprovalDto spmkCustomApprovalDto) throws Exception{
		Integer approvalGId = spmkCustomApprovalDto.getApprovalGId();
		if (ObjectUtil.isNull(approvalGId)) 
			return ResultUtil.error("操作失败!-1");

		SpmkCustomApproval ca = SpmkCustomApproval.builder().build();

		BeanUtil.copyProperties(spmkCustomApprovalDto, ca , "froms","router","initiatorConfigs");
		ca.setFroms(ObjectUtil.serialize(spmkCustomApprovalDto.getFroms()));
		ca.setRouter(ObjectUtil.serialize(spmkCustomApprovalDto.getRouter()));
		
		if (!ca.insertOrUpdate())
			return ResultUtil.error("操作失败!-2");
		
		Integer id = ca.getId();
		Console.log("自定义审批id: " + id);
		List<SpmkInitiatorConfig> listIc = spmkCustomApprovalDto.getInitiatorConfigs();

287 288 289 290 291 292 293 294 295
		if (listIc != null && listIc.size() > 0) {
			for (int i = 0, n = listIc.size(); i < n; i++) {
				listIc.get(i).setCustomApprovalId(id);
			}
			if (!spmkInitiatorConfigMapper.insertList(listIc)) {
				// 手动抛出异常,事务回滚
				throw new Exception();
			}
			
296
		}
297 298
		
		SpmkInitiatorConfig.builder().build().delete(new QueryWrapper<SpmkInitiatorConfig>().lambda().eq(SpmkInitiatorConfig::getCustomApprovalId, id));
299 300 301 302 303 304 305 306

		//  
		/**
		 * 注意: 为保证该api的原子性 要加 事务处理 回滚(方法注解-@Transactional(rollbackFor = Exception.class))
		 * 1.删除	历史的  SpmkInitiatorConfig-审批发起人配置,
		 * 2.新增	最新的 SpmkInitiatorConfig-审批发起人配置,
		 * 3.新增 SpmkCustomApproval-自定义审批
		 */
307 308 309 310 311

		// 清空前端不需要的字段再返回,节省流量
		ca.setFroms(null);
		ca.setRouter(null);
		return ResultUtil.data(ca, "操作成功!");
312 313
		
	}
314
	
315 316
	/**
	 * 删除-自定义审批
317
	 * @throws Exception 
318 319
	 */
	@DeleteMapping(value = "/delete_custom_approval/{id}")
320
	@ApiOperation(value = "14.删除-自定义审批", httpMethod = "DELETE", notes = "删除-自定义审批")
321
	@Transactional(rollbackFor = Exception.class)
322
	@ApiOperationSupport(order = 14)
323 324 325 326 327 328 329 330
	public Result<Object> deleteCaById(@PathVariable int id) throws Exception{
		SpmkInitiatorConfig.builder().build().delete(new QueryWrapper<SpmkInitiatorConfig>().lambda().eq(SpmkInitiatorConfig::getCustomApprovalId, id));
        
		if (!SpmkCustomApproval.builder().id(id).build().deleteById()) {
			throw new Exception();
		}
		
		return  ResultUtil.success("操作成功!");
331 332 333 334 335 336
		
	}

	/**
	 * id查询-自定义审批
	 */
337 338 339
	@GetMapping(value = "/select_custom_approval/{id}")
	@ApiOperation(value = "15.id查询-自定义审批", httpMethod = "GET", notes = "id查询-自定义审批")
	@ApiOperationSupport(order = 15)
340
	public Result<Object> selectCaById(@PathVariable int id){
341 342
		SpmkCustomApproval ca = SpmkCustomApproval.builder().id(id).build().selectById();
		SpmkCustomApprovalDto caD = SpmkCustomApprovalDto.builder()
tangzhaoqian committed
343
				.froms(ObjectUtil.unserialize(ca.getFroms()))
344 345 346 347 348
				.router(ObjectUtil.unserialize(ca.getRouter()))
				.build();
		BeanUtil.copyProperties(ca, caD,"froms","router");
		
        return ResultUtil.data(caD,"操作成功!");
349
	}
350
	
351 352 353
	/**
	 * 排序-自定义审批
	 */
tangzhaoqian committed
354
	@PutMapping(value = "/update_custom_approval")
355 356
	@ApiOperation(value = "16.排序-自定义审批", httpMethod = "PUT", notes = "排序-自定义审批")
	@ApiOperationSupport(order = 16)
tangzhaoqian committed
357
	public Result<Object> ranksCa(@RequestBody List<SpmkCustomApproval> list){
358 359
        return spmkCustomApprovalMapper.updateListRandsById(list) ? ResultUtil.success("操作成功!") : ResultUtil.error("操作失败!");
	}
360
	
361 362 363 364 365 366 367 368 369 370 371
	@Autowired
	private SpmkApproveSummaryMapper spmkApproveSummaryMapper;
	@Autowired
	private SpmkApproveDetailMapper spmkApproveDetailMapper;
	@Autowired
	private SpmkApproveExecuteRecordMapper spmkApproveExecuteRecordMapper;
	@Autowired
	private SpmkExecutorMapper spmkExecutorMapper;
	@Autowired
	private SpmkInitiatorConfigMapper spmkInitiatorConfigMapper;
	
372 373
	private boolean ISFIRST = true; // 第一次启动审批流程
	
374 375 376
	// TODO 审批汇总(发起审批)
	/**
	 * 发起审批
377
	 * @throws Exception 
378 379
	 */
	@PostMapping(value = "/start_approval")
380 381 382
	@ApiOperation(value = "17.发起审批", httpMethod = "POST", notes = "发起审批")
	@ApiOperationSupport(order = 17)
	@Transactional(rollbackFor = Exception.class)
383 384 385 386 387 388 389 390 391 392
	@BindingResultCtrol(title = "发起审批")
	public Result<Object> saveCa(@CurrentUser UserBean userBean,@Valid @RequestBody SpmkApproveSummaryDto spmkApproveSummaryDto,BindingResult bindingResult) throws Exception{
			
			YgglMainEmp ygglMainEmp = YgglMainEmp.builder().build().selectOne(new QueryWrapper<YgglMainEmp>()
					.lambda()
					.select(YgglMainEmp::getHeadUrl,YgglMainEmp::getName)
					.eq(YgglMainEmp::getEmpNum, userBean.getEmpNum()));
			
			if (ygglMainEmp == null) 
				return ResultUtil.error("发起人异常!");
393 394
			
			List<Router> listRouter = new ArrayList<Router>();
395
			listRouter.add(spmkApproveSummaryDto.getRouter());
396 397
			JSONObject jSONObject = spmkApproveSummaryDto.getRequestData()
					.put("orgCode", FromData.builder().value(String.valueOf(userBean.getOrgCode())).build())
tangzhaoqian committed
398
					.put("initiator", FromData.builder().value(spmkApproveSummaryDto.getInitiator()).build())
399
					.put("headUrl", FromData.builder().value(ygglMainEmp.getHeadUrl()).build())
tangzhaoqian committed
400
					.put("id", FromData.builder().value(StrUtil.toString(userBean.getEmpNum())).build());
401 402 403
			RouterUtils.NextNode(listRouter, jSONObject, ISFIRST);
			List<FlowChildren> listFlowChildren = new ArrayList<FlowChildren>();
			RouterUtils.getIsFlowChildren(listRouter,listFlowChildren);
404
			
405 406 407 408 409 410 411 412 413 414
			// 当前审批人
			String currentApprover = jSONObject.getStr("current_approver");
			// 封装 审批汇总
			SpmkApproveSummary as = SpmkApproveSummary
					.builder()
					.orgCode(userBean.getOrgCode())
					.empNum(userBean.getEmpNum())
					.title(spmkApproveSummaryDto.getTitle())
					.initiator(spmkApproveSummaryDto.getInitiator())
					.approveName(spmkApproveSummaryDto.getApproveName())
415
					.assoType(spmkApproveSummaryDto.getAssoType())
416
					.sts(0)
417
					.currentApprover(currentApprover).build();
418
			
419 420 421
			if (!as.insert()) {
				return ResultUtil.error("操作失败!");
			}
422
			
423 424 425
			// 插入记录
			RouterUtils.insertogExecuteRecord(listFlowChildren, as.getId());
			
426 427 428 429 430
			// 封装 审批详情
			SpmkApproveDetail ad = SpmkApproveDetail.builder().build();
			ad.setApproveSummaryId(as.getId());
			ad.setName(spmkApproveSummaryDto.getTitle());
			ad.setRequestData(ObjectUtil.serialize(spmkApproveSummaryDto.getRequestData()));
431
			ad.setFroms(ObjectUtil.serialize((List<JSONObject>)spmkApproveSummaryDto.getFroms()));
432 433
			ad.setRouter(ObjectUtil.serialize(listRouter.get(0)));
			ad.setFlowChildren(ObjectUtil.serialize(listFlowChildren));
434
			
435 436
			if (!ad.insert()) 
				throw new Exception();
437
			
438
			return ResultUtil.success("操作成功!");
439 440 441
			
	}
	
442 443 444 445 446 447 448 449 450 451
	//TODO 审批汇总
	@PostMapping(value = "/select_approve_summary")
	@ApiOperation(value = "18.审批汇总", httpMethod = "POST", notes = "审批汇总")
	@ApiOperationSupport(order = 18)
	public Result<Object> selectAs(@CurrentUser UserBean userBean, @RequestBody SummaryQueryDto summaryQueryDto) {

			IPage<SpmkApproveSummary> page = new Page<SpmkApproveSummary>(
				summaryQueryDto.getCurrentPage() == null ? 1 : summaryQueryDto.getCurrentPage(),
				summaryQueryDto.getTotalPage() == null ? 10 : summaryQueryDto.getTotalPage());
			summaryQueryDto.setOrgCode(userBean.getOrgCode());
452 453 454
			
			Integer deptId = summaryQueryDto.getDeptId();
			List<YgglMainEmp> listYgglMainEmp = RouterUtils.selectOtherlistent(userBean.getOrgCode(), deptId);
tangzhaoqian committed
455

456 457 458 459 460 461 462 463 464 465
			if (deptId != null && (listYgglMainEmp == null || listYgglMainEmp.size() == 0)) {
				return ResultUtil.data(new ArrayList<SpmkApproveSummary>(), "操作成功!");
			}
			
			List<Integer> empNums = new ArrayList<Integer>();
			for (YgglMainEmp ygglMainEmp : listYgglMainEmp) {
				empNums.add(ygglMainEmp.getEmpNum());
			}
			summaryQueryDto.setEmpNums(empNums);
			
466
			// 缺-部门id 搜索
467 468 469
			IPage<SpmkApproveSummary> pageAs = spmkApproveSummaryMapper.selectPageByQuery(page, summaryQueryDto);
			
			List<SpmkApproveSummary> listAs = pageAs.getRecords();
470
			
471
			return ResultUtil.data(pageAs, listAs, "操作成功!");
472
	}
473
	
474 475 476 477 478 479 480
	//TODO 审批详情
	/**
	 * 审批详情
	 */
	@GetMapping(value = "/select_approve_detail/{id}")
	@ApiOperation(value = "19.审批详情", httpMethod = "GET", notes = "审批详情")
	@ApiOperationSupport(order = 19)
tangzhaoqian committed
481
	public Result<Object> selectAd(@PathVariable(required = true) Integer id) {
482 483 484
		
		SpmkApproveDetail ad = spmkApproveDetailMapper.selectOne(new QueryWrapper<SpmkApproveDetail>().lambda().eq(SpmkApproveDetail::getApproveSummaryId, id));
		SpmkApproveDetailDto adD = SpmkApproveDetailDto.builder().build();
485
		List<SpmkApproveExecuteRecord> listAer = spmkApproveExecuteRecordMapper.selectListByAsId(id);
486
		BeanUtil.copyProperties(ad, adD, "requestData","froms","router","spmkApproveExecuteRecord");
tangzhaoqian committed
487
		
488
		adD.setRequestData(ObjectUtil.unserialize(ad.getRequestData()));
tangzhaoqian committed
489 490 491
		adD.setFroms(ObjectUtil.unserialize(ad.getFroms()));
		adD.setRouter(ObjectUtil.unserialize(ad.getRouter()));
		adD.setFlowChildren(ObjectUtil.unserialize(ad.getFlowChildren()));
492
		adD.setApproveExecuteRecord(listAer);
493 494 495
		
		return ResultUtil.data(adD, "操作成功!");
	}
496
	
497 498 499 500 501 502 503 504 505 506 507 508 509 510
	//TODO 撤销审批
	/**
	 * 撤销审批
	 */
	@PutMapping(value = "/revoke_approval/{id}")
	@ApiOperation(value = "22.撤销审批", httpMethod = "PUT", notes = "撤销审批")
	@Transactional(rollbackFor = Exception.class)
	@ApiOperationSupport(order = 22)
	public Result<Object> revokeApproval(@PathVariable Integer id) throws Exception {
		
		return SpmkApproveSummary.builder().id(id).endTime(new Date()).sts(1).build().updateById() ? 
				ResultUtil.success("操作成功!") : ResultUtil.error("操作失败!");
	}
	
511 512 513 514 515 516
	//TODO 审批人审批
	/**
	 * 审批人审批
	 */
	@PostMapping(value = "/approving")
	@ApiOperation(value = "20.审批人审批", httpMethod = "POST", notes = "审批人审批")
tangzhaoqian committed
517 518
	@Transactional(rollbackFor = Exception.class)
	@ApiOperationSupport(order = 20)
519 520
//	@BindingResultCtrol(title = "审批人审批")
	public Result<Object> approving(@Valid @RequestBody ApprovingDto approvingDto, BindingResult bindingResult) throws Exception {
521 522 523 524 525
		SpmkApproveDetail ad = SpmkApproveDetail.builder().build()
		.selectOne(new QueryWrapper<SpmkApproveDetail>()
				.lambda()
				.eq(SpmkApproveDetail::getApproveSummaryId, approvingDto.getAsId()));
		
526 527 528 529 530
		// 查询 SpmkApproveSummary 状态
		SpmkApproveSummary aSummary = spmkApproveSummaryMapper.selectOne(new QueryWrapper<SpmkApproveSummary>().lambda()
				.select(SpmkApproveSummary::getSts)
				.eq(SpmkApproveSummary::getId, approvingDto.getAsId()));
		
531
		if (aSummary.getSts() == 1 || aSummary.getSts() == 2 || aSummary.getSts() == 3) {
532 533 534 535
			return ResultUtil.error("该审批已结束!");
		}
		
		// 查询该 审批的状态 是否为 1 审批中 
tangzhaoqian committed
536 537 538 539 540 541 542 543
		Integer count = SpmkExecutor.builder().build().selectCount(new QueryWrapper<SpmkExecutor>().lambda()
				.eq(SpmkExecutor::getId, approvingDto.getExecutorId())
				.eq(SpmkExecutor::getSts, "1"));
		
		if (count == 0) {
			return ResultUtil.error("您已审批过!");
		}
		
544
		if (aSummary.getSts() == 0) {
tangzhaoqian committed
545
			List<FlowChildren> listFlowChildren = ObjectUtil.unserialize(ad.getFlowChildren());
546 547 548 549 550 551
			RouterUtils.approving(
					listFlowChildren, 
					approvingDto.getAsId(), 
					approvingDto.getExecuteRecordId(), 
					approvingDto.getExecutorId(), 
					approvingDto.getOpinion(),
552 553 554
					approvingDto.getSts(),
					approvingDto.getUser()
					);
555 556 557
			
			System.out.println(listFlowChildren);
			// 更新 flowChildren
tangzhaoqian committed
558
			SpmkApproveDetail.builder().id(ad.getId()).flowChildren(ObjectUtil.serialize(listFlowChildren)).build().updateById();
559 560 561 562 563 564 565 566 567
			FlowChildren fc = CollUtil.getLast(listFlowChildren);
			if (fc.getExecute() == "2") {
				// 查询 SpmkApproveSummary 状态
				aSummary = spmkApproveSummaryMapper.selectOne(new QueryWrapper<SpmkApproveSummary>().lambda()
						.select(SpmkApproveSummary::getSts)
						.eq(SpmkApproveSummary::getId, approvingDto.getAsId()));
				if (aSummary.getSts() != 3) {
					SpmkApproveSummary.builder().id(approvingDto.getAsId()).endTime(new Date()).sts(2).build().updateById();
				}
tangzhaoqian committed
568
			}
569 570 571 572 573 574
			
		}else {
			return ResultUtil.error("该审批已结束!");
		}
		return ResultUtil.data(null, "操作成功!");
	}
575
	
576 577 578 579 580 581
	//TODO 我审批的/抄送我的
	/**
	 * 查询列表-我审批的/抄送我的-分页
	 */
	@PostMapping(value = "/select_my_approve")
	@ApiOperation(value = "21.查询列表-我审批的/抄送我的-分页", httpMethod = "POST", notes = "查询列表-我审批的-关键字、审批状态、发起时间-分页")
tangzhaoqian committed
582
	@ApiOperationSupport(order = 21)
583 584 585 586 587 588 589 590 591 592 593 594 595
	public Result<Object> selectMyAs(@CurrentUser UserBean userBean, @RequestBody MySummaryQueryDto mySummaryQueryDto) {
			IPage<SpmkApproveSummary> page = new Page<SpmkApproveSummary>(
				mySummaryQueryDto.getCurrentPage() == null ? 1 : mySummaryQueryDto.getCurrentPage(),
				mySummaryQueryDto.getTotalPage() == null ? 10 : mySummaryQueryDto.getTotalPage());
			mySummaryQueryDto.setOrgCode(userBean.getOrgCode());
			mySummaryQueryDto.setEmpNum(userBean.getEmpNum());
			// 缺-部门id 搜索
			IPage<SpmkApproveSummary> pageAs = spmkApproveSummaryMapper.selectPageByQueryForEmpNum(page, mySummaryQueryDto);
			
			List<SpmkApproveSummary> listAs = pageAs.getRecords();
			
			return ResultUtil.data(pageAs, listAs, "操作成功!");
	}
596
	
597 598 599 600 601
	/**
	 * 删除-审批汇总、审批详情、审批执行记录、审批执行人记录 所有数据
	 */
	@DeleteMapping(value = "/delete_approval_data")
	@ApiOperation(value = "90.(开发使用)删除-审批数据", httpMethod = "DELETE", notes = "审批汇总、审批详情、审批执行记录、审批执行人记录 所有数据")
tangzhaoqian committed
602
	@ApiOperationSupport(order = 90)
603 604 605 606 607 608
	public Result<Object> deleteApprovalData(@CurrentUser UserBean userBean){
		
		spmkApproveSummaryMapper.delete(null);
		spmkApproveDetailMapper.delete(null);
		spmkApproveExecuteRecordMapper.delete(null);
		spmkExecutorMapper.delete(null);
tangzhaoqian committed
609
		System.out.println("删除-审批汇总、审批详情、审批执行记录、审批执行人记录 所有数据 完成!");
610 611
		return ResultUtil.data(null, "操作成功!");
	}
612
	
tangzhaoqian committed
613 614 615 616 617 618 619 620 621 622 623
	//TODO 审批图标列表
	@GetMapping(value = "/icon")
	@ApiOperation(value = "99.图标列表", httpMethod = "GET", notes = "接口发布说明")
	@ApiOperationSupport(order = 99)
	public Result<List<SpmkIcon>> selectListIcon(@CurrentUser UserBean userBean){
		
		List<SpmkIcon> spmkIcons = SpmkIcon.builder().build().selectAll();
		
		return ResultUtil.data(spmkIcons,"获取图标列表成功");
	}
	
yuquan.zhu committed
624 625

}