|
@@ -1,24 +1,29 @@
|
|
|
package com.ruoyi.project.pssr.controller;
|
|
|
|
|
|
-import java.util.List;
|
|
|
-import org.springframework.security.access.prepost.PreAuthorize;
|
|
|
-import org.springframework.beans.factory.annotation.Autowired;
|
|
|
-import org.springframework.web.bind.annotation.GetMapping;
|
|
|
-import org.springframework.web.bind.annotation.PostMapping;
|
|
|
-import org.springframework.web.bind.annotation.PutMapping;
|
|
|
-import org.springframework.web.bind.annotation.DeleteMapping;
|
|
|
-import org.springframework.web.bind.annotation.PathVariable;
|
|
|
-import org.springframework.web.bind.annotation.RequestBody;
|
|
|
-import org.springframework.web.bind.annotation.RequestMapping;
|
|
|
-import org.springframework.web.bind.annotation.RestController;
|
|
|
+import com.ruoyi.common.utils.DateUtils;
|
|
|
+import com.ruoyi.common.utils.poi.ExcelUtil;
|
|
|
import com.ruoyi.framework.aspectj.lang.annotation.Log;
|
|
|
import com.ruoyi.framework.aspectj.lang.enums.BusinessType;
|
|
|
-import com.ruoyi.project.pssr.domain.TPssrApprove;
|
|
|
-import com.ruoyi.project.pssr.service.ITPssrApproveService;
|
|
|
import com.ruoyi.framework.web.controller.BaseController;
|
|
|
import com.ruoyi.framework.web.domain.AjaxResult;
|
|
|
-import com.ruoyi.common.utils.poi.ExcelUtil;
|
|
|
import com.ruoyi.framework.web.page.TableDataInfo;
|
|
|
+import com.ruoyi.project.pssr.domain.TPssrApprove;
|
|
|
+import com.ruoyi.project.pssr.domain.TPssrOverhaulExchanger;
|
|
|
+import com.ruoyi.project.pssr.domain.TPssrSubcontent;
|
|
|
+import com.ruoyi.project.pssr.service.*;
|
|
|
+import com.ruoyi.project.system.mapper.SysUserMapper;
|
|
|
+import org.activiti.engine.RuntimeService;
|
|
|
+import org.activiti.engine.TaskService;
|
|
|
+import org.activiti.engine.impl.identity.Authentication;
|
|
|
+import org.activiti.engine.runtime.ProcessInstance;
|
|
|
+import org.springframework.beans.factory.annotation.Autowired;
|
|
|
+import org.springframework.security.access.prepost.PreAuthorize;
|
|
|
+import org.springframework.web.bind.annotation.*;
|
|
|
+
|
|
|
+import java.util.Date;
|
|
|
+import java.util.HashMap;
|
|
|
+import java.util.List;
|
|
|
+import java.util.Map;
|
|
|
|
|
|
/**
|
|
|
* pssr审批管理Controller
|
|
@@ -28,18 +33,47 @@ import com.ruoyi.framework.web.page.TableDataInfo;
|
|
|
*/
|
|
|
@RestController
|
|
|
@RequestMapping("/pssr/approve")
|
|
|
-public class TPssrApproveController extends BaseController
|
|
|
-{
|
|
|
+public class TPssrApproveController extends BaseController {
|
|
|
+
|
|
|
+ @Autowired
|
|
|
+ private SysUserMapper userMapper;
|
|
|
+
|
|
|
+ @Autowired
|
|
|
+ private RuntimeService runtimeService;
|
|
|
+
|
|
|
+ @Autowired
|
|
|
+ private TaskService taskService;
|
|
|
+
|
|
|
@Autowired
|
|
|
private ITPssrApproveService tPssrApproveService;
|
|
|
|
|
|
+ @Autowired
|
|
|
+ private ITPssrSubcontentService tPssrSubcontentService;
|
|
|
+
|
|
|
+ @Autowired
|
|
|
+ private ITPssrOverhaulExchangerService tPssrOverhaulExchangerService;
|
|
|
+
|
|
|
+ @Autowired
|
|
|
+ private ITPssrOverhaulFilterService tPssrOverhaulFilterService;
|
|
|
+
|
|
|
+ @Autowired
|
|
|
+ private ITPssrOverhaulPipeService tPssrOverhaulPipeService;
|
|
|
+
|
|
|
+ @Autowired
|
|
|
+ private ITPssrOverhaulTowerService tPssrOverhaulTowerService;
|
|
|
+
|
|
|
+ @Autowired
|
|
|
+ private ITPssrOverhaulPumpService tPssrOverhaulPumpService;
|
|
|
+
|
|
|
+ @Autowired
|
|
|
+ private ITPssrOverhaulValveService tPssrOverhaulValveService;
|
|
|
+
|
|
|
/**
|
|
|
* 查询pssr审批管理列表
|
|
|
*/
|
|
|
@PreAuthorize("@ss.hasPermi('pssr:approve:list')")
|
|
|
@GetMapping("/list")
|
|
|
- public TableDataInfo list(TPssrApprove tPssrApprove)
|
|
|
- {
|
|
|
+ public TableDataInfo list(TPssrApprove tPssrApprove) {
|
|
|
startPage();
|
|
|
List<TPssrApprove> list = tPssrApproveService.selectTPssrApproveList(tPssrApprove);
|
|
|
return getDataTable(list);
|
|
@@ -51,8 +85,7 @@ public class TPssrApproveController extends BaseController
|
|
|
@PreAuthorize("@ss.hasPermi('pssr:approve:export')")
|
|
|
@Log(title = "pssr审批管理", businessType = BusinessType.EXPORT)
|
|
|
@GetMapping("/export")
|
|
|
- public AjaxResult export(TPssrApprove tPssrApprove)
|
|
|
- {
|
|
|
+ public AjaxResult export(TPssrApprove tPssrApprove) {
|
|
|
List<TPssrApprove> list = tPssrApproveService.selectTPssrApproveList(tPssrApprove);
|
|
|
ExcelUtil<TPssrApprove> util = new ExcelUtil<TPssrApprove>(TPssrApprove.class);
|
|
|
return util.exportExcel(list, "approve");
|
|
@@ -63,8 +96,7 @@ public class TPssrApproveController extends BaseController
|
|
|
*/
|
|
|
@PreAuthorize("@ss.hasPermi('pssr:approve:query')")
|
|
|
@GetMapping(value = "/{approveId}")
|
|
|
- public AjaxResult getInfo(@PathVariable("approveId") Long approveId)
|
|
|
- {
|
|
|
+ public AjaxResult getInfo(@PathVariable("approveId") Long approveId) {
|
|
|
return AjaxResult.success(tPssrApproveService.selectTPssrApproveById(approveId));
|
|
|
}
|
|
|
|
|
@@ -74,8 +106,7 @@ public class TPssrApproveController extends BaseController
|
|
|
@PreAuthorize("@ss.hasPermi('pssr:approve:add')")
|
|
|
@Log(title = "pssr审批管理", businessType = BusinessType.INSERT)
|
|
|
@PostMapping
|
|
|
- public AjaxResult add(@RequestBody TPssrApprove tPssrApprove)
|
|
|
- {
|
|
|
+ public AjaxResult add(@RequestBody TPssrApprove tPssrApprove) {
|
|
|
return toAjax(tPssrApproveService.insertTPssrApprove(tPssrApprove));
|
|
|
}
|
|
|
|
|
@@ -85,8 +116,7 @@ public class TPssrApproveController extends BaseController
|
|
|
@PreAuthorize("@ss.hasPermi('pssr:approve:edit')")
|
|
|
@Log(title = "pssr审批管理", businessType = BusinessType.UPDATE)
|
|
|
@PutMapping
|
|
|
- public AjaxResult edit(@RequestBody TPssrApprove tPssrApprove)
|
|
|
- {
|
|
|
+ public AjaxResult edit(@RequestBody TPssrApprove tPssrApprove) {
|
|
|
return toAjax(tPssrApproveService.updateTPssrApprove(tPssrApprove));
|
|
|
}
|
|
|
|
|
@@ -95,9 +125,105 @@ public class TPssrApproveController extends BaseController
|
|
|
*/
|
|
|
@PreAuthorize("@ss.hasPermi('pssr:approve:remove')")
|
|
|
@Log(title = "pssr审批管理", businessType = BusinessType.DELETE)
|
|
|
- @DeleteMapping("/{approveIds}")
|
|
|
- public AjaxResult remove(@PathVariable Long[] approveIds)
|
|
|
- {
|
|
|
+ @DeleteMapping("/{approveIds}")
|
|
|
+ public AjaxResult remove(@PathVariable Long[] approveIds) {
|
|
|
return toAjax(tPssrApproveService.deleteTPssrApproveByIds(approveIds));
|
|
|
}
|
|
|
+
|
|
|
+ @Log(title = "pssr发起审批", businessType = BusinessType.INSERT)
|
|
|
+ @PostMapping("/doPssrApprove/{subId}")
|
|
|
+ public AjaxResult doApprove(@PathVariable Long subId) {
|
|
|
+ TPssrSubcontent tPssrSubcontent = tPssrSubcontentService.selectTPssrSubcontentById(subId);
|
|
|
+ switch (tPssrSubcontent.getSerialNumber()) {
|
|
|
+ case "01":
|
|
|
+ do01Approve(tPssrSubcontent);
|
|
|
+ break;
|
|
|
+ case "02":
|
|
|
+ break;
|
|
|
+ case "03":
|
|
|
+ break;
|
|
|
+ case "04":
|
|
|
+ break;
|
|
|
+ case "05":
|
|
|
+ break;
|
|
|
+ case "06":
|
|
|
+ break;
|
|
|
+ case "07":
|
|
|
+ break;
|
|
|
+ case "08":
|
|
|
+ break;
|
|
|
+ case "09":
|
|
|
+ break;
|
|
|
+ case "10":
|
|
|
+ break;
|
|
|
+ case "11":
|
|
|
+ break;
|
|
|
+ case "12":
|
|
|
+ break;
|
|
|
+ case "13":
|
|
|
+ break;
|
|
|
+ case "14":
|
|
|
+ break;
|
|
|
+ case "15":
|
|
|
+ break;
|
|
|
+ case "16":
|
|
|
+ break;
|
|
|
+ case "17":
|
|
|
+ break;
|
|
|
+ case "18":
|
|
|
+ break;
|
|
|
+ case "19":
|
|
|
+ break;
|
|
|
+ case "20":
|
|
|
+ break;
|
|
|
+ case "21":
|
|
|
+ break;
|
|
|
+ case "22":
|
|
|
+ break;
|
|
|
+ case "23":
|
|
|
+ break;
|
|
|
+ case "24":
|
|
|
+ break;
|
|
|
+ case "25":
|
|
|
+ break;
|
|
|
+ case "26":
|
|
|
+ break;
|
|
|
+ case "27":
|
|
|
+ break;
|
|
|
+ case "28":
|
|
|
+ break;
|
|
|
+
|
|
|
+ }
|
|
|
+ return AjaxResult.success();
|
|
|
+ }
|
|
|
+
|
|
|
+ // 检修项目审批流程发起申请
|
|
|
+ public void do01Approve(TPssrSubcontent sub) {
|
|
|
+ String userId = getUserId().toString();
|
|
|
+ //新增审批数据
|
|
|
+ TPssrApprove approve = new TPssrApprove();
|
|
|
+ approve.setSubId(sub.getId());
|
|
|
+ approve.setApNo(DateUtils.dateTimeNow() + userId);
|
|
|
+ approve.setApproveStatus("0");
|
|
|
+ approve.setSubCharge(sub.getConfirm());
|
|
|
+ approve.setCreaterCode(userId);
|
|
|
+ approve.setCreatedate(new Date());
|
|
|
+ tPssrApproveService.insertTPssrApprove(approve);
|
|
|
+
|
|
|
+ //查询所有确认人
|
|
|
+ TPssrOverhaulExchanger tPssrOverhaulExchanger = tPssrOverhaulExchangerService.selectAllConfirmedPersonBySubId(sub.getId());
|
|
|
+ String confirmers = tPssrOverhaulExchanger.getConfirmedPerson();
|
|
|
+ // 开始申请流程
|
|
|
+ long businessKey = approve.getApproveId();
|
|
|
+ //开始工作流、监听
|
|
|
+ Authentication.setAuthenticatedUserId(userId);//设置当前申请人
|
|
|
+ Map<String, Object> variables = new HashMap<>();
|
|
|
+ variables.put("applyUser", userId);
|
|
|
+ variables.put("confirmUsers", confirmers);
|
|
|
+ variables.put("chargePerson", sub.getConfirm());
|
|
|
+ //采用key来启动流程定义并设置流程变量,返回流程实例
|
|
|
+ ProcessInstance pi = runtimeService.startProcessInstanceByKey("pssr1confirm", String.valueOf(businessKey), variables);
|
|
|
+ approve.setProcessId(pi.getProcessInstanceId());
|
|
|
+ tPssrApproveService.updateTPssrApprove(approve);
|
|
|
+ }
|
|
|
}
|