easydo-zcgx/src/main/java/com/qdport/controller/PolicyCaseController.java

package com.qdport.controller;

import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
import com.qdport.entity.PolicyStrive;
import com.qdport.entity.PolicyTodo;
import com.qdport.enums.QDPortEnum;
import com.qdport.modules.system.entity.SysUser;
import com.qdport.modules.system.service.TSysUserService;
import com.qdport.service.PolicyFileService;
import com.qdport.service.PolicyStriveService;
import com.qdport.service.PolicyTodoService;
import com.qdport.service.impl.PolicySystemService;
import com.qdport.util.StringUtil;
import com.qdport.vo.PolicyFileVO;
import com.qdport.vo.PolicyStriveVO;
import lombok.AllArgsConstructor;
import com.qdport.entity.PolicyCase;
import com.qdport.service.PolicyCaseService;
import com.qdport.query.PolicyCaseQuery;
import com.qdport.vo.PolicyCaseVO;
import com.qdport.wrapper.PolicyCaseWrapper;
import org.springframework.beans.BeanUtils;
import org.springframework.transaction.annotation.Transactional;
import org.springframework.web.bind.annotation.*;
import io.swagger.annotations.Api;
import io.swagger.annotations.ApiOperation;
import io.swagger.annotations.ApiParam;
import com.qdport.core.tool.api.R;
import com.qdport.core.tool.utils.Func;
import com.qdport.core.boot.ctrl.QdportController;
import com.baomidou.mybatisplus.core.metadata.IPage;

import javax.validation.Valid;
import java.util.Date;
import java.util.List;
import java.util.Map;

/**
 * 案例分享
 *
 * @author yuheng
 * @since 1.0.0 2024-10-17
 */
@RestController
@RequestMapping("qdport-zcgx/case")
@Api(value = "案例分享", tags = "案例分享")
@AllArgsConstructor
public class PolicyCaseController extends QdportController {
    private final PolicyCaseService policyCaseService;
    private final TSysUserService sysUserService;
    private final PolicySystemService policySystemService;
    private final PolicyFileService policyFileService;
    private final PolicyTodoService policyTodoService;
    private final PolicyStriveService policyStriveService;

    /**
     * 分页
     */
    @GetMapping("page")
    @ApiOperation(value = "分页", notes = "分页")
    public R<IPage<PolicyCaseVO>> page(@Valid PolicyCaseQuery query) {
        IPage<PolicyCaseVO> page = policyCaseService.page(query);
        List<PolicyCaseVO> records = page.getRecords();
        for (PolicyCaseVO model : records) {
            SysUser createUser = sysUserService.getById(model.getCreateId());
            Map<String, String> resultMap = policySystemService.getDeptNameAndCompanyName(createUser.getDeptId());
            model.setDeptName(resultMap.get("deptName"));
            model.setCompanyName(resultMap.get("companyName"));

            List<PolicyFileVO> fileList = policyFileService.getFileList(model.getId().toString(), QDPortEnum.POLICY_FILE_REFTYPE_POLICY_STRIVE.getValue());
            model.setFileList(fileList);

            PolicyStrive strive = policyStriveService.getById(model.getStriveId());
            PolicyStriveVO striveVO = new PolicyStriveVO();
            BeanUtils.copyProperties(strive, striveVO);
            createUser = sysUserService.getById(strive.getCreateId());
            resultMap = policySystemService.getDeptNameAndCompanyName(createUser.getDeptId());
            striveVO.setDeptName(resultMap.get("deptName"));
            striveVO.setCompanyName(resultMap.get("companyName"));

            model.setPolicyStrive(striveVO);
        }
        return R.data(page);
    }

    /**
     * 详情
     */
    @GetMapping("{id}")
    @ApiOperation(value = "详情", notes = "id")
    public R<PolicyCaseVO> get(@PathVariable("id") Long id) {
        PolicyCase entity = policyCaseService.getById(id);
        PolicyCaseVO vo = PolicyCaseWrapper.build().entityVO(entity);

        SysUser createUser = sysUserService.getById(entity.getCreateId());
        Map<String, String> resultMap = policySystemService.getDeptNameAndCompanyName(createUser.getDeptId());
        vo.setDeptName(resultMap.get("deptName"));
        vo.setCompanyName(resultMap.get("companyName"));

        PolicyStrive strive = policyStriveService.getById(entity.getStriveId());
        PolicyStriveVO striveVO = new PolicyStriveVO();
        BeanUtils.copyProperties(strive, striveVO);
        createUser = sysUserService.getById(strive.getCreateId());
        resultMap = policySystemService.getDeptNameAndCompanyName(createUser.getDeptId());
        striveVO.setDeptName(resultMap.get("deptName"));
        striveVO.setCompanyName(resultMap.get("companyName"));


        List<PolicyFileVO> fileList = policyFileService.getFileList(strive.getId().toString(), QDPortEnum.POLICY_FILE_REFTYPE_POLICY_STRIVE.getValue());
        striveVO.setFileList(fileList);
        vo.setPolicyStrive(striveVO);
        return R.data(vo);
    }

    /**
     * 新增
     */
    @PostMapping("/save")
    @ApiOperation(value = "新增", notes = "传入PolicyCase")
    public R save(@RequestBody PolicyCaseVO vo) {
        vo.setStatus(QDPortEnum.POLICY_CASE_STATUS_ACTIVE.getValue());
        policyCaseService.save(vo);
        return R.success("保存成功");
    }

    @PostMapping("/saveDone")
    @ApiOperation(value = "新增", notes = "传入PolicyCase")
    @Transactional(rollbackFor = Exception.class)
    public R saveDone(@RequestBody PolicyCaseVO vo) {
        vo.setStatus(QDPortEnum.POLICY_CASE_STATUS_DONE.getValue());
        policyCaseService.save(vo);
        return R.success("保存成功");
    }

    @PostMapping("/saveApprove")
    @ApiOperation(value = "新增并且提交", notes = "传入PolicyCase")
    @Transactional(rollbackFor = Exception.class)
    public R saveApprove(@RequestBody PolicyCaseVO vo) {
        if (StringUtil.isEmpty(vo.getId())) {
            vo.setStatus(QDPortEnum.POLICY_CASE_STATUS_APPROVE.getValue());
            policyCaseService.save(vo);
        } else {
            vo.setStatus(QDPortEnum.POLICY_CASE_STATUS_APPROVE.getValue());
            policyCaseService.update(vo);
        }
        PolicyStrive strive = policyStriveService.getById(vo.getStriveId());
        PolicyStriveVO striveVO = new PolicyStriveVO();
        BeanUtils.copyProperties(strive, striveVO);
        vo.setPolicyStrive(striveVO);

        policyTodoService.save(vo);
        return R.success("新增并且提交成功");
    }

    /**
     * 修改
     */
    @PostMapping("/update")
    public R update(@RequestBody @Valid PolicyCaseVO vo) {
        policyCaseService.update(vo);
        return R.success("更新成功");
    }

    @PostMapping("/withdraw")
    @Transactional(rollbackFor = Exception.class)
    public R withdraw(@RequestBody @Valid PolicyCaseVO vo) {
        vo.setStatus(QDPortEnum.POLICY_CASE_STATUS_ACTIVE.getValue());
        vo.setUpdateTime(new Date());
        policyCaseService.updateById(vo);

        QueryWrapper<PolicyTodo> todoQueryWrapper = new QueryWrapper<>();
        todoQueryWrapper.eq("REF_ID", vo.getId());
        todoQueryWrapper.eq("REF_TYPE", QDPortEnum.POLICY_TODO_REFTYPE_POLICY_CASE.getValue());
        todoQueryWrapper.eq("TODO_USER_ID", 1);
        todoQueryWrapper.eq("TODO_TYPE", QDPortEnum.POLICY_TODO_TYPE_APPROVE.getValue());
        todoQueryWrapper.eq("STATUS", QDPortEnum.POLICY_TODO_STATUS_ACTIVE.getValue());
        PolicyTodo todo = new PolicyTodo();
        todo.setStatus(QDPortEnum.POLICY_TODO_STATUS_CANCEL.getValue());
        policyTodoService.update(todo, todoQueryWrapper);
        return R.success("撤回成功");
    }

    @PostMapping("/approve")
    @Transactional(rollbackFor = Exception.class)
    public R approve(@RequestBody @Valid PolicyCaseVO vo) {
        vo.setStatus(QDPortEnum.POLICY_CASE_STATUS_DONE.getValue());
        vo.setUpdateTime(new Date());
        policyCaseService.updateById(vo);

        QueryWrapper<PolicyTodo> todoQueryWrapper = new QueryWrapper<>();
        todoQueryWrapper.eq("REF_ID", vo.getId());
        todoQueryWrapper.eq("REF_TYPE", QDPortEnum.POLICY_TODO_REFTYPE_POLICY_CASE.getValue());
        todoQueryWrapper.eq("TODO_USER_ID", 1);
        todoQueryWrapper.eq("TODO_TYPE", QDPortEnum.POLICY_TODO_TYPE_APPROVE.getValue());
        todoQueryWrapper.eq("STATUS", QDPortEnum.POLICY_TODO_STATUS_ACTIVE.getValue());
        PolicyTodo todo = new PolicyTodo();
        todo.setStatus(QDPortEnum.POLICY_TODO_STATUS_DONE.getValue());
        policyTodoService.update(todo, todoQueryWrapper);

        return R.success("更新成功");
    }

    @PostMapping("/refuse")
    @Transactional(rollbackFor = Exception.class)
    public R refuse(@RequestBody @Valid PolicyCaseVO vo) {
        vo.setStatus(QDPortEnum.POLICY_CASE_STATUS_INACTIVE.getValue());
        vo.setUpdateTime(new Date());
        policyCaseService.updateById(vo);

        QueryWrapper<PolicyTodo> todoQueryWrapper = new QueryWrapper<>();
        todoQueryWrapper.eq("REF_ID", vo.getId());
        todoQueryWrapper.eq("REF_TYPE", QDPortEnum.POLICY_TODO_REFTYPE_POLICY_CASE.getValue());
        todoQueryWrapper.eq("TODO_USER_ID", 1);
        todoQueryWrapper.eq("TODO_TYPE", QDPortEnum.POLICY_TODO_TYPE_APPROVE.getValue());
        todoQueryWrapper.eq("STATUS", QDPortEnum.POLICY_TODO_STATUS_ACTIVE.getValue());
        PolicyTodo todo = new PolicyTodo();
        todo.setStatus(QDPortEnum.POLICY_TODO_STATUS_DONE.getValue());
        policyTodoService.update(todo, todoQueryWrapper);

        return R.success("更新成功");
    }

    /**
     * 删除
     */
    @PostMapping("/remove")
    @ApiOperation(value = "逻辑删除", notes = "传入ids")
    public R delete(@ApiParam(value = "主键集合", required = true) @RequestParam(name = "ids") String ids) {
        List<Long> idList = Func.toLongList(ids);
        policyCaseService.delete(idList);
        return R.success("删除成功");
    }
}