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;
    }
}