package com.gkhy.labRiskManage.api.controller.riskReport;
|
|
import cn.hutool.json.JSONObject;
|
import com.gkhy.labRiskManage.api.controller.basic.dto.respDto.BasicRiskUnitListRespDTO;
|
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.RiskUnitListQueryRespDTO;
|
import com.gkhy.labRiskManage.api.controller.riskReport.dto.respDto.RiskUnitQueryRespDTO;
|
import com.gkhy.labRiskManage.application.basic.dto.dto.BasicRiskUnitAppListDTO;
|
import com.gkhy.labRiskManage.application.riskReport.dto.dto.RiskUnitAppQueryDTO;
|
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 org.springframework.beans.factory.annotation.Autowired;
|
import org.springframework.security.core.Authentication;
|
import org.springframework.web.bind.annotation.*;
|
|
|
/**
|
* 实验风险单元
|
*/
|
@RestController
|
@RequestMapping("risk")
|
public class RiskUnitController extends BaseController {
|
|
@Autowired
|
private RiskAccessAppService riskAccessAppService;
|
|
/**
|
* 实验风险单元 - 插入
|
*/
|
@PostMapping("/insert/insertRiskUnit")
|
public Result insertRiskUnit(@RequestBody RiskUnitInsertReqBO riskUnitInsertReqBO) {
|
|
Result result = new Result();
|
result.setCode(ResultCode.OK);
|
result.setMsg("新增成功");
|
|
int insertResult = riskAccessAppService.insertRiskUnit(getCurrentUserId(), riskUnitInsertReqBO);
|
|
if (insertResult < 1){
|
result.setCode(ResultCode.NOT_OK);
|
result.setMsg("新增失败");
|
}
|
result.setCount(insertResult);
|
return result;
|
}
|
|
/**
|
* 固有风险单元 - 插入
|
*/
|
@PostMapping("/insert/insertInherentRiskUnit")
|
public Result insertInherentRiskUnit(@RequestBody InherentRiskUnitInsertReqBO insertReqBO){
|
|
Result result = new Result();
|
result.setCode(ResultCode.OK);
|
result.setMsg("新增成功");
|
|
int insertResult = riskAccessAppService.insertInherentRiskUnit(getCurrentUserId(), insertReqBO);
|
|
if (insertResult < 1){
|
result.setCode(ResultCode.NOT_OK);
|
result.setMsg("新增失败");
|
}
|
result.setCount(insertResult);
|
return result;
|
}
|
|
/**
|
* 风险单元管理 - 分页查询
|
*/
|
@PostMapping("/select/selectRiskUnitPage")
|
public SearchResult<RiskUnitQueryRespDTO> selectRiskUnitPage(@RequestBody RiskUnitQueryReqBO queryReqBO){
|
SearchResult result = new SearchResult();
|
result.setCode(ResultCode.OK);
|
result.setMsg("查询成功");
|
|
SearchResult<RiskUnitAppQueryDTO> queryResult = riskAccessAppService.selectRiskUnitPage(getCurrentUserId(), queryReqBO);
|
result.setData(BeanCopyUtils.copyExperimentRiskUnitListQueryResp(queryResult.getData(), RiskUnitQueryRespDTO.class));
|
|
result.setPageIndex(queryResult.getPageIndex());
|
result.setPageSize(queryResult.getPageSize());
|
result.setTotal(queryResult.getTotal());
|
result.setCount(queryResult.getTotal().intValue());
|
|
return result;
|
}
|
|
/**
|
* 风险单元管理 - 修改
|
*/
|
@PostMapping("/update/updateRiskUnit")
|
public Result updateRiskUnit(@RequestBody RiskUnitUpdateReqBO updateReqBO){
|
|
Result result = new Result();
|
result.setCode(ResultCode.OK);
|
result.setMsg("修改成功");
|
|
int updateResult = riskAccessAppService.updateRiskUnit(getCurrentUserId(), updateReqBO);
|
|
if (updateResult < 1){
|
result.setCode(ResultCode.NOT_OK);
|
result.setMsg("修改失败");
|
}
|
result.setCount(updateResult);
|
return result;
|
}
|
|
/**
|
* 风险单元管理 - 删除
|
*/
|
@PostMapping("/delete/deleteRiskUnit")
|
public Result deleteRiskUnit(@RequestBody JSONObject jsonObject){
|
|
Result result = new Result();
|
result.setCode(ResultCode.OK);
|
result.setMsg("删除成功");
|
|
int deleteResult = riskAccessAppService.deleteRiskUnit(getCurrentUserId(), jsonObject.getLong("id"));
|
|
if (deleteResult < 1){
|
result.setCode(ResultCode.NOT_OK);
|
result.setMsg("删除失败");
|
}
|
result.setCount(deleteResult);
|
return result;
|
}
|
|
/**
|
* 单元管理 - 列表查询
|
*/
|
@GetMapping("/select/listRiskUnit")
|
public SearchResult<RiskUnitListQueryRespDTO> listRiskUnit(){
|
SearchResult result = new SearchResult();
|
result.setCode(ResultCode.OK);
|
result.setMsg("查询成功");
|
|
SearchResult<RiskUnitListQueryRespDTO> searchResult = riskAccessAppService.listRiskUnit(getCurrentUserId());
|
|
result.setData(searchResult.getData());
|
result.setCount(searchResult.getCount());
|
|
return result;
|
}
|
|
/**
|
* 单元管理 - 列表查询 todo --此接口改为Post RiskUnitListReqBO参数，根据实验id查询风险单元
|
*/
|
@PostMapping("/select/listRiskUnitByExperiment")
|
public SearchResult<RiskUnitListQueryRespDTO> listRiskUnitByExperiment(@RequestBody RiskUnitListReqBO reqBO){
|
SearchResult result = new SearchResult();
|
result.setCode(ResultCode.OK);
|
result.setMsg("查询成功");
|
|
SearchResult<RiskUnitListQueryRespDTO> searchResult = riskAccessAppService.listRiskUnitByExperiment(getCurrentUserId(), reqBO);
|
|
result.setData(searchResult.getData());
|
result.setCount(searchResult.getCount());
|
|
return result;
|
}
|
}
|
