newcpms/master/src/main/java/com/ruoyi/project/pssr/controller/TPssrApproveController.java

package com.ruoyi.project.pssr.controller;

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.framework.web.controller.BaseController;
import com.ruoyi.framework.web.domain.AjaxResult;
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
 *
 * @author ssy
 * @date 2024-09-18
 */
@RestController
@RequestMapping("/pssr/approve")
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) {
        startPage();
        List<TPssrApprove> list = tPssrApproveService.selectTPssrApproveList(tPssrApprove);
        return getDataTable(list);
    }

    /**
     * 导出pssr审批管理列表
     */
    @PreAuthorize("@ss.hasPermi('pssr:approve:export')")
    @Log(title = "pssr审批管理", businessType = BusinessType.EXPORT)
    @GetMapping("/export")
    public AjaxResult export(TPssrApprove tPssrApprove) {
        List<TPssrApprove> list = tPssrApproveService.selectTPssrApproveList(tPssrApprove);
        ExcelUtil<TPssrApprove> util = new ExcelUtil<TPssrApprove>(TPssrApprove.class);
        return util.exportExcel(list, "approve");
    }

    /**
     * 获取pssr审批管理详细信息
     */
    @PreAuthorize("@ss.hasPermi('pssr:approve:query')")
    @GetMapping(value = "/{approveId}")
    public AjaxResult getInfo(@PathVariable("approveId") Long approveId) {
        return AjaxResult.success(tPssrApproveService.selectTPssrApproveById(approveId));
    }

    /**
     * 新增pssr审批管理
     */
    @PreAuthorize("@ss.hasPermi('pssr:approve:add')")
    @Log(title = "pssr审批管理", businessType = BusinessType.INSERT)
    @PostMapping
    public AjaxResult add(@RequestBody TPssrApprove tPssrApprove) {
        return toAjax(tPssrApproveService.insertTPssrApprove(tPssrApprove));
    }

    /**
     * 修改pssr审批管理
     */
    @PreAuthorize("@ss.hasPermi('pssr:approve:edit')")
    @Log(title = "pssr审批管理", businessType = BusinessType.UPDATE)
    @PutMapping
    public AjaxResult edit(@RequestBody TPssrApprove tPssrApprove) {
        return toAjax(tPssrApproveService.updateTPssrApprove(tPssrApprove));
    }

    /**
     * 删除pssr审批管理
     */
    @PreAuthorize("@ss.hasPermi('pssr:approve:remove')")
    @Log(title = "pssr审批管理", businessType = BusinessType.DELETE)
    @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);
        tPssrSubcontent.setApproveStatus(1L);
        tPssrSubcontentService.updateTPssrSubcontent(tPssrSubcontent);
        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);
    }
}