package com.gk.firework.Controller;
|
|
import com.gk.firework.Controller.Base.BaseController;
|
import com.gk.firework.Domain.SelfCheckReport;
|
import com.gk.firework.Domain.Utils.JsonUtils;
|
import com.gk.firework.Domain.Utils.Msg;
|
import com.gk.firework.Domain.Vo.SelfCheckReportSearchVo;
|
import com.gk.firework.Domain.Vo.SelfCheckReportVo;
|
import com.gk.firework.Service.SelfCheckReportService;
|
import io.swagger.annotations.Api;
|
import io.swagger.annotations.ApiImplicitParam;
|
import io.swagger.annotations.ApiImplicitParams;
|
import io.swagger.annotations.ApiOperation;
|
import org.springframework.beans.factory.annotation.Autowired;
|
import org.springframework.web.bind.annotation.*;
|
|
import java.util.Date;
|
import java.util.HashMap;
|
import java.util.List;
|
import java.util.Map;
|
|
@Api(tags = "隐患自查情况报送接口")
|
@RequestMapping("/selfcheckreport")
|
@RestController
|
public class SelfCheckReportController extends BaseController {
|
|
@Autowired
|
private SelfCheckReportService selfCheckReportService;
|
|
@ApiOperation(value = "创建新的报告",httpMethod="POST")
|
@ApiImplicitParams({
|
@ApiImplicitParam(name = "yhlevel",value = "隐患等级,1-一般隐患，2-重大隐患",defaultValue = "1",required = true),
|
@ApiImplicitParam(name = "status",value = "隐患状态，1-未整改，2-已整改",defaultValue = "1",required = true),
|
@ApiImplicitParam(name = "price",value = "整改资金，单位（RMB元），支持小数点后2位（RMB分）",defaultValue = "0.00",required = true),
|
@ApiImplicitParam(name = "chargeperson",value = "责任人名字",defaultValue = "",required = true),
|
@ApiImplicitParam(name = "endtime",value = "整改期限，YY-MM-DD HH:MM:SS",required = true),
|
@ApiImplicitParam(name = "yhdesc",value = "隐患描述",required = true),
|
@ApiImplicitParam(name = "solution",value = "整改措施",required = true)
|
})
|
@PostMapping( "/new")
|
public Object newReport(@RequestBody SelfCheckReportVo reportVo){
|
Msg msg = new Msg();
|
msg.setCode("400");
|
Long companyId = getUser().getCompanyid();
|
if(companyId > 0){
|
reportVo.setEid(companyId);
|
if(selfCheckReportService.createNewReport(reportVo) > 0){
|
msg.setCode("200");
|
msg.setResult(1);
|
}else {
|
msg.setCode("301");
|
msg.setMessage("新增报送记录出错");
|
}
|
}else {
|
msg.setCode("301");
|
msg.setMessage("权限错误");
|
}
|
return msg;
|
}
|
|
@ApiOperation(value = "根据隐患ID查找报告",httpMethod="GET")
|
@ApiImplicitParam(name = "id",value = "隐患ID",required = true,defaultValue = "0")
|
@RequestMapping(value = "/find/one",method = RequestMethod.GET)
|
public Object findById(@RequestParam(name = "id",required = true) Long id){
|
Msg msg = new Msg();
|
msg.setCode("400");
|
SelfCheckReport report = selfCheckReportService.getSelfCheckReportById(id);
|
if(report!=null){
|
if(getUser().getCompanyid()==null || getUser().getCompanyid().longValue()<=0 || getUser().getCompanyid().equals(report.getEid())){
|
msg.setResult(report);
|
msg.setCode("200");
|
}else {
|
msg.setMessage("权限错误");
|
}
|
}else {
|
msg.setMessage("未找到记录");
|
}
|
return msg;
|
}
|
|
@ApiOperation(value = "查找报告列表",httpMethod="POST",notes = "查询条件优先级别：企业ID查找 > 企业名称查找 > 省市区查找")
|
@RequestMapping(value = "/find/list",method = RequestMethod.POST)
|
@ApiImplicitParams({
|
@ApiImplicitParam(name = "eid",value = "企业ID",required = false),
|
@ApiImplicitParam(name = "ename",value = "企业名称",required = false),
|
@ApiImplicitParam(name = "status",value = "隐患状态，1-未整改，2-已整改",required = false,defaultValue = "0"),
|
@ApiImplicitParam(name = "yhlevel",value = "隐患等级,1-一般隐患，2-重大隐患",required = false,defaultValue = "0"),
|
@ApiImplicitParam(name = "startTime",value = "查询起始时间 YY-MM-DD HH:MM:SS",required = false),
|
@ApiImplicitParam(name = "endTime",value = "查询截止时间 YY-MM-DD HH:MM:SS",required = false),
|
@ApiImplicitParam(name = "province",value = "省份",required = false),
|
@ApiImplicitParam(name = "city",value = "市",required = false),
|
@ApiImplicitParam(name = "district",value = "区",required = false),
|
@ApiImplicitParam(name = "street",value = "街道",required = false),
|
@ApiImplicitParam(name = "committee",value = "居委会",required = false),
|
@ApiImplicitParam(name = "page",value = "当前页码",required = true,defaultValue = "1"),
|
@ApiImplicitParam(name = "pageSize",value = "每页条目数",required = true,defaultValue = "20")
|
})
|
public Object findList(@RequestBody SelfCheckReportSearchVo searchVo){
|
Msg msg = new Msg();
|
msg.setCode("400");
|
//参数校验
|
if(searchVo.getStartTime() != null && searchVo.getEndTime() != null){
|
if(searchVo.getStartTime().after(searchVo.getEndTime()) ){
|
msg.setMessage("时间区间错误");
|
return msg;
|
}
|
}
|
if(searchVo.getStatus() == null || searchVo.getStatus() <0 || searchVo.getStatus() >2) {
|
searchVo.setStatus((byte)0);
|
}
|
if(searchVo.getYhlevel() == null ||searchVo.getYhlevel() <0 ||searchVo.getYhlevel() >2){
|
searchVo.setYhlevel((byte)0);
|
}
|
//企业用户登录查自己
|
if(getUser().getCompanyid()!= null && getUser().getCompanyid().longValue()>0){
|
searchVo.setEid(getUser().getCompanyid());
|
}
|
List<SelfCheckReport> list = selfCheckReportService.findSelfCheckReportListWithAllCondition(searchVo);
|
if(list!=null && list.size()>0){
|
msg.setCode("200");
|
msg.setResult(list);
|
Map<String,Object> rs = new HashMap();
|
rs.put("totalCount",searchVo.getTotalCount());
|
rs.put("page",searchVo.getPage());
|
rs.put("pageSize",searchVo.getPageSize());
|
msg.setMessage(JsonUtils.toJson(rs));
|
}else {
|
msg.setCode("200");
|
msg.setMessage("未找到结果");
|
}
|
return msg;
|
}
|
|
@ApiOperation(value = "更新报告",httpMethod="POST")
|
@ApiImplicitParams({
|
@ApiImplicitParam(name = "id",value = "隐患ID",required = true),
|
@ApiImplicitParam(name = "yhlevel",value = "隐患等级,1-一般隐患，2-重大隐患",defaultValue = "1",required = false),
|
@ApiImplicitParam(name = "status",value = "隐患状态，1-未整改，2-已整改",defaultValue = "1",required = false),
|
@ApiImplicitParam(name = "price",value = "整改资金，单位（RMB元），支持小数点后2位（RMB分）",defaultValue = "0.00",required = false),
|
@ApiImplicitParam(name = "chargeperson",value = "责任人名字",defaultValue = "",required = false),
|
@ApiImplicitParam(name = "endtime",value = "整改期限，YY-MM-DD HH:MM:SS",required = false),
|
@ApiImplicitParam(name = "yhdesc",value = "隐患描述",required = false),
|
@ApiImplicitParam(name = "solution",value = "整改措施",required = false)
|
})
|
@PostMapping("/update")
|
public Object updateReport(@RequestBody SelfCheckReportVo reportVo){
|
Msg msg = new Msg();
|
msg.setCode("400");
|
if(getUser().getCompanyid()!=null && getUser().getCompanyid().longValue() != reportVo.getEid().longValue()){
|
msg.setMessage("权限错误");
|
return msg;
|
}
|
if(reportVo.getEid().longValue()>0 && reportVo.getId().longValue() >0){
|
int updateResult = selfCheckReportService.updateSelfCheckReport(reportVo);
|
if(updateResult > 0){
|
msg.setCode("200");
|
}else {
|
msg.setMessage("参数错误");
|
}
|
}else {
|
msg.setMessage("参数缺失");
|
}
|
return msg;
|
}
|
|
}
|
