LaboratoryRiskManage.Server.git

package com.gkhy.labRiskManage.api.controller.riskReport;
 
import cn.hutool.json.JSONObject;
import com.gkhy.labRiskManage.api.controller.common.BaseController;
import com.gkhy.labRiskManage.api.controller.riskReport.dto.repDto.*;
import com.gkhy.labRiskManage.api.controller.riskReport.dto.respDto.RiskAssessPlanListRespDTO;
import com.gkhy.labRiskManage.api.controller.riskReport.dto.respDto.RiskAssessPlanQueryRespDTO;
import com.gkhy.labRiskManage.api.controller.riskReport.dto.respDto.RiskAssessQueryRespDTO;
import com.gkhy.labRiskManage.application.riskReport.dto.dto.RiskAssessPlanAppQueryDTO;
import com.gkhy.labRiskManage.application.riskReport.service.RiskAccessAppService;
import com.gkhy.labRiskManage.commons.domain.Result;
import com.gkhy.labRiskManage.commons.domain.SearchResult;
import com.gkhy.labRiskManage.commons.enums.ResultCode;
import com.gkhy.labRiskManage.commons.utils.BeanCopyUtils;
import com.gkhy.labRiskManage.domain.riskReport.model.dto.AssessPlanUpdateDTO;
import com.gkhy.labRiskManage.domain.riskReport.model.dto.FactorQueryDTO;
import com.gkhy.labRiskManage.domain.riskReport.service.RiskAssessPlanService;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.util.ObjectUtils;
import org.springframework.web.bind.annotation.*;
 
import java.math.BigDecimal;
 
 
/**
 * 风险评估计划
 */
@RestController
@RequestMapping("risk")
public class RiskAssessPlanController extends BaseController {
 
    @Autowired
    private RiskAccessAppService riskAccessAppService;
 
    @Autowired
    private RiskAssessPlanService riskAssessPlanService;;
 
    /**
     * 风险评估计划 - 插入
     */
    @PostMapping("/insert/insertAssessPlan")
    public Result insertAssessPlan(@RequestBody RiskAssessPlanInsertReqBO assessPlanInsertReqDTO){
 
        Result result = new Result();
        result.setCode(ResultCode.OK);
        result.setMsg("新增成功");
 
        int insertResult = riskAccessAppService.insertAssessPlan(getCurrentUserId(), assessPlanInsertReqDTO);
 
        if (insertResult < 1){
            result.setCode(ResultCode.NOT_OK);
            result.setMsg("新增失败");
        }
        result.setCount(insertResult);
        return result;
    }
 
    /**
     * 风险评估计划 - 查询
     */
    @PostMapping("/select/selectAssessPlanPage")
    public SearchResult<RiskAssessPlanQueryRespDTO> selectAssessPlanPage(@RequestBody RiskAssessPlanQueryReqBO queryReqBO){
        SearchResult result = new SearchResult();
        result.setCode(ResultCode.OK);
        result.setMsg("查询成功");
 
        SearchResult<RiskAssessPlanAppQueryDTO> queryResult = riskAccessAppService.selectAssessPlanPage(getCurrentUserId(), queryReqBO);
        result.setData(BeanCopyUtils.copyRiskAssessPlanQueryResp(queryResult.getData(), RiskAssessPlanQueryRespDTO.class));
 
        result.setPageIndex(queryResult.getPageIndex());
        result.setPageSize(queryResult.getPageSize());
        result.setTotal(queryResult.getTotal());
        result.setCount(queryResult.getTotal().intValue());
 
        return result;
    }
 
 
 
    @PostMapping("/update/appoint")
    public Result appoint(@RequestBody AppointUserReBO appointUserReBO){
 
        Result result = new Result();
        result.setCode(ResultCode.OK);
        result.setMsg("已经重新指定专家");
 
        AssessPlanUpdateDTO assessPlanUpdateDTO = riskAccessAppService.appoint(getCurrentUserId(), appointUserReBO);
        if (ObjectUtils.isEmpty(assessPlanUpdateDTO)){
            result.setCode(ResultCode.NOT_OK);
            result.setMsg("重新指定专家失败");
            return result;
        }
        return result;
    }
 
    /**
     * 风险评估计划 - 修改
     */
    @PostMapping("/update/updateAssessPlan")
    public Result updateAssessPlan(@RequestBody RiskAssessPlanUpdateReqBO updateReqBO){
 
        Result result = new Result();
        result.setCode(ResultCode.OK);
        result.setMsg("修改成功");
 
        int updateResult = riskAccessAppService.updateAssessPlan(getCurrentUserId(), updateReqBO);
 
        if (updateResult < 1){
            result.setCode(ResultCode.NOT_OK);
            result.setMsg("修改失败");
        }
        result.setCount(updateResult);
        return result;
    }
 
    /**
     * 风险评估计划 - 删除
     */
    @PostMapping("/delete/deleteAssessPlan")
    public Result deleteAssessPlan(@RequestBody JSONObject jsonObject){
 
        Result result = new Result();
        result.setCode(ResultCode.OK);
        result.setMsg("删除成功");
 
        int deleteResult = riskAccessAppService.deleteAssessPlan(getCurrentUserId(), jsonObject.getLong("id"));
 
        if (deleteResult < 1){
            result.setCode(ResultCode.NOT_OK);
            result.setMsg("删除失败");
        }
        result.setCount(deleteResult);
        return result;
    }
 
    /**
     * 风险评估计划 - 派发任务
     */
    @PostMapping("/update/sellAssessPlan")
    public Result sellAssessPlan(@RequestBody JSONObject jsonObject){
 
        Result result = new Result();
        result.setCode(ResultCode.OK);
        result.setMsg("派发任务成功");
 
        int updateResult = riskAccessAppService.sellAssessPlan(getCurrentUserId(), jsonObject.getLong("id"));
 
        if (updateResult < 1){
            result.setCode(ResultCode.NOT_OK);
            result.setMsg("派发任务失败");
        }
        result.setCount(updateResult);
        return result;
    }
 
    /**
     * 风险评估计划 - 辨识专家拒绝
     */
    @PostMapping("/update/identificationRefuse")
    public Result identificationRefuse(@RequestBody JSONObject jsonObject){
 
        Result result = new Result();
        result.setCode(ResultCode.OK);
        result.setMsg("已拒绝辨识任务");
 
        AssessPlanUpdateDTO assessPlanUpdateDTO = riskAccessAppService.identificationRefuse(getCurrentUserId(), jsonObject.getLong("id"));
        if (ObjectUtils.isEmpty(assessPlanUpdateDTO)){
            result.setCode(ResultCode.NOT_OK);
            result.setMsg("拒绝辨识任务失败");
            return result;
        }
        return result;
    }
 
    /**
     * 风险评估计划 - 修改辨识方法
     */
    @PostMapping("/update/identificationUpdateMethod")
    public Result identificationUpdateMethod(@RequestBody MethodUpdateReqDTO updateReqDTO){
 
        Result result = new Result();
        result.setCode(ResultCode.OK);
        result.setMsg("修改辨识方法成功");
 
        AssessPlanUpdateDTO assessPlanUpdateDTO = riskAccessAppService.identificationUpdateMethod(getCurrentUserId(),updateReqDTO);
        if (ObjectUtils.isEmpty(assessPlanUpdateDTO)){
            result.setCode(ResultCode.NOT_OK);
            result.setMsg("修改辨识方法失败");
            return result;
        }
        return result;
    }
    /**
     * 风险评估计划 - 辨识
     */
    @PostMapping("/update/identification")
    public Result identification(@RequestBody RiskAssessPlanIdentificationInsertReqBO identificationReqBO){
 
        Result result = new Result();
        result.setCode(ResultCode.OK);
        result.setMsg("辨识成功");
 
        FactorQueryDTO identification = riskAccessAppService.identification(getCurrentUserId(), identificationReqBO);
 
        result.setData(identification);
        return result;
    }
 
    /**
     * 风险评估计划 - 辨识修改
     */
    @PostMapping("/update/updateIdentification")
    public Result updateIdentification(@RequestBody RiskAssessPlanIdentificationUpdateReqBO updateReqBO){
 
        Result result = new Result();
        result.setCode(ResultCode.OK);
        result.setMsg("辨识修改成功");
 
        FactorQueryDTO identification = riskAccessAppService.updateIdentification(getCurrentUserId(), updateReqBO);
 
        result.setData(identification);
        return result;
    }
 
    /**
     * 风险评估计划 - 辨识删除
     */
    @PostMapping("/delete/deleteIdentification")
    public Result deleteIdentification(@RequestBody RiskAssessPlanIdentificationDeleteReqBO deleteReqBO){
 
        Result result = new Result();
        result.setCode(ResultCode.OK);
        result.setMsg("辨识删除成功");
 
        int updateResult = riskAccessAppService.deleteIdentification(getCurrentUserId(), deleteReqBO);
 
        if (updateResult < 1){
            result.setCode(ResultCode.NOT_OK);
            result.setMsg("辨识删除失败");
        }
        result.setCount(updateResult);
        return result;
    }
 
    /**
     * 风险评估计划 - 辨识结果提交
     */
    @PostMapping("/update/identificationSubmit")
    public Result identificationSubmit(@RequestBody JSONObject jsonObject){
 
        Result result = new Result();
        result.setCode(ResultCode.OK);
        result.setMsg("辨识结果提交成功");
 
        int updateResult = riskAccessAppService.identificationSubmit(getCurrentUserId(), jsonObject.getLong("id"));
 
        if (updateResult < 1){
            result.setCode(ResultCode.NOT_OK);
            result.setMsg("辨识结果提交失败");
        }
        result.setCount(updateResult);
        return result;
    }
 
    /**
     * 风险评估计划 - 评价
     */
    @PostMapping("/update/evaluate")
    public Result evaluate(@RequestBody RiskAssessPlanEvaluateInsertReqBO evaluateReqBO){
 
        Result result = new Result();
        result.setCode(ResultCode.OK);
        result.setMsg("评价成功");
 
        FactorQueryDTO evaluate = riskAccessAppService.evaluate(getCurrentUserId(), evaluateReqBO);
 
        result.setData(evaluate);
        return result;
    }
 
    /**
     * 风险评估计划 - 评价专家拒绝
     */
    @PostMapping("/update/evaluateRefuse")
    public Result evaluateRefuse(@RequestBody JSONObject jsonObject){
 
        Result result = new Result();
        result.setCode(ResultCode.OK);
        result.setMsg("已拒绝评价任务");
 
        AssessPlanUpdateDTO assessPlanUpdateDTO = riskAccessAppService.evaluateRefuse(getCurrentUserId(), jsonObject.getLong("id"));
 
        if (ObjectUtils.isEmpty(assessPlanUpdateDTO)){
            result.setCode(ResultCode.NOT_OK);
            result.setMsg("拒绝辨识任务失败");
            return result;
        }
        return result;
    }
 
    /**
     * 风险评估计划 - 评价方法修改
     */
    @PostMapping("/update/evaluateUpdateMethod")
    public Result evaluateUpdateMethod(@RequestBody MethodUpdateReqDTO updateReqDTO){
 
        Result result = new Result();
        result.setCode(ResultCode.OK);
        result.setMsg("修改评价方法成功");
 
        AssessPlanUpdateDTO assessPlanUpdateDTO = riskAccessAppService.evaluateUpdateMethod(getCurrentUserId(),updateReqDTO);
        if (ObjectUtils.isEmpty(assessPlanUpdateDTO)){
            result.setCode(ResultCode.NOT_OK);
            result.setMsg("修改评价方法失败");
            return result;
        }
        return result;
    }
    /**
     * 风险评估计划 - 评价修改
     */
    @PostMapping("/update/updateEvaluate")
    public Result updateEvaluate(@RequestBody RiskAssessPlanEvaluateUpdateReqBO updateReqBO){
 
        Result result = new Result();
        result.setCode(ResultCode.OK);
        result.setMsg("评价修改成功");
 
        FactorQueryDTO factorQueryDTO = riskAccessAppService.updateEvaluate(getCurrentUserId(), updateReqBO);
 
        result.setData(factorQueryDTO);
        return result;
    }
 
    /**
     * 风险评估计划 - 评价删除
     */
    @PostMapping("/delete/deleteEvaluate")
    public Result deleteEvaluate(@RequestBody RiskAssessPlanEvaluateDeleteReqBO deleteReqBO){
 
        Result result = new Result();
        result.setCode(ResultCode.OK);
        result.setMsg("评价删除成功");
 
        int updateResult = riskAccessAppService.deleteEvaluate(getCurrentUserId(), deleteReqBO);
 
        if (updateResult < 1){
            result.setCode(ResultCode.NOT_OK);
            result.setMsg("评价删除失败");
        }
        result.setCount(updateResult);
        return result;
    }
 
    /**
     * 风险评估计划 - 评价结果提交
     */
    @PostMapping("/update/evaluateSubmit")
    public Result evaluateSubmit(@RequestBody JSONObject jsonObject){
 
        Result result = new Result();
        result.setCode(ResultCode.OK);
        result.setMsg("评价结果提交成功");
 
        int updateResult = riskAccessAppService.evaluateSubmit(getCurrentUserId(), jsonObject.getLong("id"));
 
        if (updateResult < 1){
            result.setCode(ResultCode.NOT_OK);
            result.setMsg("评价结果提交失败");
        }
 
        result.setCount(updateResult);
        return result;
    }
 
    /**
     * 风险评估计划 - 重新指定专家
     */
    @PostMapping("/update/appointNew")
    public Result appointNew(@RequestBody AppointUserTypeReBO appointUserReBO){
 
        Result result = new Result();
        result.setCode(ResultCode.OK);
        result.setMsg("已经重新指定专家");
 
        int i = riskAssessPlanService.appointNew(getCurrentUserId(), appointUserReBO);
        if (i < 1){
            result.setCode(ResultCode.NOT_OK);
            result.setMsg("重新指定专家失败");
            return result;
        }
        return result;
    }
 
 
 
 
    /**
     * 风险辨识与评价 - 查询
     */
    @PostMapping("/select/selectAssessPage")
    public SearchResult<RiskAssessQueryRespDTO> selectAssessPage(@RequestBody RiskAssessQueryReqBO queryReqBO){
 
        SearchResult result = new SearchResult();
        result.setCode(ResultCode.OK);
        result.setMsg("查询成功");
 
        SearchResult<RiskAssessQueryRespDTO> queryResult = riskAccessAppService.selectAssessPage(getCurrentUserId(), queryReqBO);
 
        result.setData(BeanCopyUtils.copyRiskAssessQueryResp(queryResult.getData(), RiskAssessQueryRespDTO.class));
        result.setPageIndex(queryResult.getPageIndex());
        result.setPageSize(queryResult.getPageSize());
        result.setCount(queryResult.getCount());
        result.setTotal(queryResult.getTotal());
 
        return result;
    }
 
    /**
     * 评估计划 - 列表查询
     */
    @GetMapping("/select/listAssessPlan")
    public SearchResult<RiskAssessPlanListRespDTO> listAssessPlan(){
        SearchResult result = new SearchResult();
        result.setCode(ResultCode.OK);
        result.setMsg("查询成功");
 
        SearchResult<RiskAssessPlanListRespDTO> searchResult = riskAccessAppService.listAssessPlan();
 
        result.setData(searchResult.getData());
        result.setCount(searchResult.getCount());
 
        return result;
    }
    /**
     * 评估计划 - 风险值计算
     */
    @PostMapping("/select/riskValue")
    public Result riskValue(@RequestBody RiskValueReqBO valueReqBO){
        Result result = new Result();
        result.setCode(ResultCode.OK);
        result.setMsg("计算成功");
 
        BigDecimal riskValue = riskAccessAppService.riskValue(valueReqBO);
 
        result.setData(riskValue);
 
        return result;
    }
}