package com.gk.firework.Controller;
|
|
import com.alibaba.fastjson.JSONArray;
|
import com.alibaba.fastjson.JSONObject;
|
import com.gk.firework.Controller.Base.BaseController;
|
import com.gk.firework.Domain.*;
|
import com.gk.firework.Domain.Utils.*;
|
import com.gk.firework.Domain.Vo.EnterpriseVo;
|
import com.gk.firework.Domain.Vo.PatrolOrderVo;
|
import com.gk.firework.Service.*;
|
import com.sun.org.apache.xpath.internal.operations.Bool;
|
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.beans.factory.annotation.Value;
|
import org.springframework.util.MultiValueMap;
|
import org.springframework.web.bind.annotation.*;
|
import org.springframework.web.multipart.MultipartFile;
|
import org.springframework.web.multipart.support.StandardMultipartHttpServletRequest;
|
|
import java.io.File;
|
import java.io.FileInputStream;
|
import java.io.InputStream;
|
import java.text.SimpleDateFormat;
|
import java.util.ArrayList;
|
import java.util.Date;
|
import java.util.HashMap;
|
import java.util.List;
|
|
|
@Api(tags = "安全巡检接口")
|
@RestController
|
public class PatrolController extends BaseController{
|
@Value("${patrolPath}")
|
private String patrolPath; //配置文件配置的物理保存地址
|
@Value("${patrolUrl}")
|
private String patrolUrl; //配置文件配置的url
|
|
@Autowired
|
PatrolOrderService patrolOrderService;
|
@Autowired
|
PatrolDetailService patrolDetailService;
|
@Autowired
|
SelfCheckService selfCheckService;
|
@Autowired
|
EnterpriseService enterpriseService;
|
@Autowired
|
UserService userService;
|
@Autowired
|
ExcelExportService excelExportService;
|
|
@GetMapping("/getEnterpriseVo")
|
@ApiOperation(value = "根据企业编号获取巡检企业信息",response = Msg.class)
|
@ApiImplicitParams({
|
@ApiImplicitParam(name = "enterprisenumber",value = "单位编号"),
|
})
|
public Msg getEnterpriseVo(EnterpriseVo enterpriseVo){
|
Msg msg = new Msg();
|
msg.setCode("200");
|
msg.setMessage("success");
|
|
EnterpriseVo enterprise = enterpriseService.selctSimpleByNumber(enterpriseVo.getEnterprisenumber());
|
List<PatrolOrderVo> patrolOrderVos = patrolOrderService.selectListByEnterprise(enterprise.getEnterprisename(),getUser().getUsername());
|
enterprise.setPatrolOrderVos(patrolOrderVos);
|
if (enterprise != null) {
|
msg.setResult(enterprise);
|
return msg;
|
}else {
|
msg.setCode("999");
|
msg.setMessage("未找到该企业");
|
return msg;
|
}
|
}
|
|
@GetMapping("/getSelfCheck")
|
@ApiOperation(value = "根据企业类型获取检查内容",response = Msg.class)
|
public Msg getSelfCheck(SelfCheckInfo selfCheck){
|
Msg msg = new Msg();
|
msg.setCode("200");
|
msg.setMessage("success");
|
|
List<SelfCheckInfo> selfChecks = selfCheckService.selctByType(selfCheck.getType());
|
if (selfChecks.size() > 0) {
|
msg.setResult(selfChecks);
|
return msg;
|
}else {
|
msg.setCode("999");
|
msg.setMessage("未找到该检查内容");
|
return msg;
|
}
|
}
|
|
@ApiOperation(value = "上传图片",notes = "上传图片")
|
@ApiImplicitParams({
|
@ApiImplicitParam(paramType="query",name = "files",value = "文件"),
|
})
|
@PostMapping("/uploadPic")
|
@ResponseBody
|
public Msg uploadPic(StandardMultipartHttpServletRequest req){
|
Msg msg = new Msg();
|
msg.setCode("200");
|
msg.setMessage("success");
|
|
MultiValueMap<String, MultipartFile> multipartFiles = req.getMultiFileMap();
|
MultipartFile picFile = multipartFiles.get("files").get(0);
|
if (null == picFile){
|
msg.setCode("404");
|
msg.setMessage("上传文件为空");
|
}else {
|
try {
|
String picmame = UploadUtil.uploadFile(picFile,patrolPath);
|
msg.setResult(patrolUrl+picmame);
|
}catch (Exception e){
|
e.printStackTrace();
|
msg.setCode("500");
|
msg.setMessage("上传失败");
|
}
|
}
|
return msg;
|
}
|
|
@ApiOperation(value = "提交检查内容",notes = "提交检查内容")
|
@ApiImplicitParams({
|
@ApiImplicitParam(name = "enterpriseId",value = "企业id"),
|
@ApiImplicitParam(name = "userId",value = "用户id"),
|
@ApiImplicitParam(name = "createdby",value = "用户名"),
|
@ApiImplicitParam(name = "checkcontent",value = "检查内容"),
|
@ApiImplicitParam(name = "content",value = "检查内容"),
|
@ApiImplicitParam(name = "standard",value = "参考判断"),
|
@ApiImplicitParam(name = "choose",value = "选项"),
|
@ApiImplicitParam(name = "reason",value = "理由"),
|
@ApiImplicitParam(name = "baforepath",value = "整改前图片"),
|
@ApiImplicitParam(name = "ismend",value = "是否整改"),
|
})
|
@PostMapping("/submitPatrol")
|
@ResponseBody
|
public Msg submitPatrol(@RequestBody JSONObject jsonObject){
|
Msg msg = new Msg();
|
msg.setCode("200");
|
msg.setMessage("success");
|
|
Long enterpriseId = jsonObject.getLong("enterpriseId");
|
Long userId = jsonObject.getLong("userId");
|
String createdby = jsonObject.getString("createdby");
|
JSONArray jsonArray = jsonObject.getJSONArray("checkcontent");
|
|
PatrolOrderInfo patrolOrderInfo = new PatrolOrderInfo();
|
patrolOrderInfo.setUserid(userId);
|
patrolOrderInfo.setCompanyid(enterpriseId);
|
patrolOrderInfo.setCreatedby(createdby);
|
patrolOrderInfo.setCreateddate(new Date());
|
patrolOrderInfo.setModifiedby(createdby);
|
patrolOrderInfo.setModifieddate(new Date());
|
patrolOrderService.save(patrolOrderInfo);
|
|
List<PatrolDetailInfo> patrolDetailInfoList = new ArrayList<>();
|
Byte ismend = 1;
|
for (int i = 0; i < jsonArray.size(); i++){
|
JSONObject patrolDetail = jsonArray.getJSONObject(i);
|
PatrolDetailInfo patrolDetailInfo = new PatrolDetailInfo();
|
patrolDetailInfo.setOrderid(patrolOrderInfo.getId());
|
patrolDetailInfo.setContent(patrolDetail.getString("content"));
|
patrolDetailInfo.setStandard(patrolDetail.getString("standard"));
|
patrolDetailInfo.setChoose(patrolDetail.getString("choose"));
|
patrolDetailInfo.setReason(patrolDetail.getString("reason"));
|
patrolDetailInfo.setBeforepath(patrolDetail.getString("baforepath"));
|
patrolDetailInfo.setIsmend(patrolDetail.getByte("ismend"));
|
patrolDetailInfo.setCreatedby(createdby);
|
patrolDetailInfo.setCreateddate(new Date());
|
patrolDetailInfo.setModifiedby(createdby);
|
patrolDetailInfo.setModifieddate(new Date());
|
if (patrolDetailInfo.getIsmend() == 0){
|
ismend = 0;
|
}
|
patrolDetailInfoList.add(patrolDetailInfo);
|
}
|
patrolDetailService.saveBatch(patrolDetailInfoList);
|
patrolOrderInfo.setIsmend(ismend);
|
patrolOrderService.updateById(patrolOrderInfo);
|
|
return msg;
|
}
|
|
@GetMapping("/selfCheck")
|
@ApiOperation(value = "获取自定义检查内容",response = Msg.class)
|
@ApiImplicitParams({
|
@ApiImplicitParam(name = "pageIndex",value = "当前页码"),
|
@ApiImplicitParam(name = "pageSize",value = "每页行数"),
|
@ApiImplicitParam(name = "sort",value = "排序规则"),
|
@ApiImplicitParam(name = "order",value = "排序字段"),
|
@ApiImplicitParam(name = "type",value = "检查类型"),
|
@ApiImplicitParam(name = "content",value = "检查内容"),
|
})
|
public Msg getSelfCheckList(@RequestParam(defaultValue = "0") Integer pageIndex, @RequestParam(defaultValue = "10") Integer pageSize, String sort, String order,
|
String type, String content){
|
Msg msg = new Msg();
|
msg.setCode("200");
|
msg.setMessage("success");
|
|
PageInfo pageInfo = new PageInfo(pageIndex, pageSize,sort,order);
|
HashMap<String, Object> condition = new HashMap<String, Object>();
|
|
if (StringUtils.isNotBlank(type)) {
|
condition.put("type", type.trim());
|
}
|
|
if (StringUtils.isNotBlank(content)) {
|
condition.put("content", content.trim());
|
}
|
|
pageInfo.setCondition(condition);
|
selfCheckService.selectDataGrid(pageInfo);
|
msg.setResult(pageInfo);
|
return msg;
|
}
|
|
@PostMapping("/selfCheck")
|
@ApiOperation(value = "添加自定义检查内容",response = Msg.class)
|
public Msg addSelfCheckList(@RequestBody SelfCheckInfo selfCheckInfo){
|
Msg msg = new Msg();
|
msg.setCode("200");
|
msg.setMessage("success");
|
|
if (StringUtils.isBlank(selfCheckInfo.getType())){
|
msg.setCode("999");
|
msg.setMessage("检查类型不能为空");
|
return msg;
|
}else if (StringUtils.isBlank(selfCheckInfo.getContent())){
|
msg.setCode("999");
|
msg.setMessage("检查内容不能为空");
|
return msg;
|
}else if (StringUtils.isBlank(selfCheckInfo.getStandard())){
|
msg.setCode("999");
|
msg.setMessage("参考判断不能为空");
|
return msg;
|
}
|
selfCheckInfo.setCreatedby(getUser().getUsername());
|
selfCheckInfo.setModifiedby(getUser().getUsername());
|
selfCheckInfo.setCreateddate(new Date());
|
selfCheckInfo.setModifieddate(new Date());
|
selfCheckInfo.setIsdel((byte)0);
|
selfCheckService.save(selfCheckInfo);
|
return msg;
|
}
|
|
@PostMapping("/putselfCheck")
|
@ApiOperation(value = "修改自定义检查内容",response = Msg.class)
|
public Msg editSelfCheckList(@RequestBody SelfCheckInfo selfCheckInfo){
|
Msg msg = new Msg();
|
msg.setCode("200");
|
msg.setMessage("success");
|
|
if (StringUtils.isBlank(selfCheckInfo.getType())){
|
msg.setCode("999");
|
msg.setMessage("检查类型不能为空");
|
return msg;
|
}else if (StringUtils.isBlank(selfCheckInfo.getContent())){
|
msg.setCode("999");
|
msg.setMessage("检查内容不能为空");
|
return msg;
|
}else if (StringUtils.isBlank(selfCheckInfo.getStandard())){
|
msg.setCode("999");
|
msg.setMessage("参考判断不能为空");
|
return msg;
|
}
|
selfCheckInfo.setModifiedby(getUser().getUsername());
|
selfCheckInfo.setModifieddate(new Date());
|
selfCheckService.updateById(selfCheckInfo);
|
return msg;
|
}
|
|
@PostMapping("/delselfCheck")
|
@ApiOperation(value = "删除自定义检查内容",response = Msg.class)
|
public Msg delSelfCheckList(@RequestBody JSONObject jsonObject){
|
Msg msg = new Msg();
|
msg.setCode("200");
|
msg.setMessage("success");
|
Long id = jsonObject.getLong("id");
|
SelfCheckInfo selfCheckInfo = selfCheckService.getById(id);
|
if (selfCheckInfo != null){
|
selfCheckInfo.setIsdel((byte)1);
|
selfCheckInfo.setModifiedby(getUser().getUsername());
|
selfCheckInfo.setModifieddate(new Date());
|
selfCheckService.updateById(selfCheckInfo);
|
return msg;
|
}else {
|
msg.setCode("999");
|
msg.setMessage("未找到检查内容");
|
return msg;
|
}
|
}
|
|
@PostMapping("/selfChecks")
|
@ApiOperation(value = "删除自定义检查内容",response = Msg.class)
|
public Msg bashDelSelfCheckList(@RequestBody JSONObject jsonObject){
|
Msg msg = new Msg();
|
msg.setCode("200");
|
msg.setMessage("success");
|
JSONArray ids = jsonObject.getJSONArray("ids");
|
List<Long> idList = ids.toJavaList(Long.class);
|
List<SelfCheckInfo> selfCheckInfoList = selfCheckService.selectByIds(idList);
|
if (selfCheckInfoList != null && selfCheckInfoList.size() > 0){
|
for (SelfCheckInfo selfCheckInfo : selfCheckInfoList) {
|
selfCheckInfo.setIsdel((byte)1);
|
selfCheckInfo.setModifiedby(getUser().getUsername());
|
selfCheckInfo.setModifieddate(new Date());
|
selfCheckService.updateById(selfCheckInfo);
|
}
|
return msg;
|
}else {
|
msg.setCode("999");
|
msg.setMessage("未找到检查内容");
|
return msg;
|
}
|
}
|
|
@PostMapping("/importSelfCheck")
|
@ApiOperation(value = "导入自定义检查内容",response = Msg.class)
|
@ApiImplicitParams({
|
@ApiImplicitParam(name = "file",value = "文件",required = true),
|
})
|
public Msg addSelfCheckList(MultipartFile file){
|
Msg msg = new Msg();
|
msg.setCode("200");
|
msg.setMessage("success");
|
|
String filesave ="";
|
try {
|
SimpleDateFormat sdf = new SimpleDateFormat( "yyyyMMddHHmmssSSS" );
|
if (file == null)
|
{
|
msg.setCode("404");
|
msg.setMessage("未找到上传文件");
|
return msg;
|
}
|
|
long size = file.getSize();
|
if(0 == size)
|
{
|
msg.setCode("404");
|
msg.setMessage("上传文件大小为空");
|
return msg;
|
}
|
|
if(!FileOptUtils.isDirExists(patrolPath)){
|
msg.setCode("500");
|
msg.setMessage("发生错误或不为目录");
|
return msg;
|
}
|
|
filesave = patrolPath + getUser().getUsername() + "_" + sdf.format(new Date()) +".xlsx";
|
|
file.transferTo(new File(filesave));
|
InputStream in = new FileInputStream(filesave);
|
String name = file.getOriginalFilename();
|
Boolean isExcel2007 = name.substring(name.lastIndexOf(".") + 1).endsWith("xlsx")? true:false;
|
BooleanReason blret = excelExportService.imporSelfCheckExcel(in,getUser().getUsername(),isExcel2007);
|
if(blret.getValue().equals(false))
|
{
|
msg.setCode("500");
|
msg.setMessage(blret.getResultmsg());
|
return msg;
|
}
|
} catch (Exception e) {
|
e.printStackTrace();
|
msg.setCode("500");
|
msg.setMessage("导入发生错误");
|
return msg;
|
}
|
|
return msg;
|
}
|
|
@GetMapping("/patrolOrder")
|
@ApiOperation(value = "获取安全巡检记录",response = Msg.class)
|
@ApiImplicitParams({
|
@ApiImplicitParam(name = "pageIndex",value = "当前页码"),
|
@ApiImplicitParam(name = "pageSize",value = "每页行数"),
|
@ApiImplicitParam(name = "sort",value = "排序规则"),
|
@ApiImplicitParam(name = "order",value = "排序字段"),
|
|
@ApiImplicitParam(name = "starttime",value = "开始时间"),
|
@ApiImplicitParam(name = "endtime",value = "结束时间"),
|
@ApiImplicitParam(name = "enterprisetype",value = "企业类型"),
|
@ApiImplicitParam(name = "enterprisename",value = "企业名称"),
|
@ApiImplicitParam(name = "checkname",value = "检查人"),
|
|
@ApiImplicitParam(name = "ismend",value = "是否整改"),
|
@ApiImplicitParam(name = "province",value = "省份"),
|
@ApiImplicitParam(name = "city",value = "城市"),
|
@ApiImplicitParam(name = "area",value = "区县"),
|
@ApiImplicitParam(name = "town",value = "乡镇"),
|
@ApiImplicitParam(name = "community",value = "社区"),
|
})
|
public Msg getPatrolOrderList(@RequestParam(defaultValue = "0") Integer pageIndex, @RequestParam(defaultValue = "10") Integer pageSize, String sort, String order,
|
String starttime, String endtime, String enterprisename, String checkname, String enterprisetype,
|
String province, String city, String area, String town, String community, Byte ismend){
|
Msg msg = new Msg();
|
msg.setCode("200");
|
msg.setMessage("success");
|
|
PageInfo pageInfo = new PageInfo(pageIndex, pageSize,sort,order);
|
HashMap<String, Object> condition = new HashMap<String, Object>();
|
|
if (StringUtils.isNotBlank(starttime)) {
|
condition.put("starttime", starttime.trim());
|
}
|
|
if (StringUtils.isNotBlank(endtime)) {
|
condition.put("endtime", endtime.trim());
|
}
|
|
if (StringUtils.isNotBlank(enterprisename)) {
|
condition.put("enterprisename", enterprisename.trim());
|
}
|
|
if (StringUtils.isNotBlank(checkname)) {
|
condition.put("checkname", checkname.trim());
|
}
|
|
if (StringUtils.isNotBlank(enterprisetype)) {
|
condition.put("enterprisetype", enterprisetype.trim());
|
}
|
|
if (ismend != null){
|
condition.put("ismend",ismend);
|
}
|
|
UserInfo userInfo = userService.getById(getUser().getId());
|
if (userInfo.getCompanyid() != null){
|
Enterprise enterprise = enterpriseService.getById(userInfo.getCompanyid());
|
condition.put("enterprisename", enterprise.getEnterprisename());
|
}else if (userInfo.getType() == 3){
|
condition.put("province",userInfo.getProvince());
|
condition.put("city",userInfo.getCity());
|
condition.put("area",userInfo.getArea());
|
condition.put("town",userInfo.getTown());
|
condition.put("community",userInfo.getCommunity());
|
}
|
|
if (StringUtils.isNotBlank(province) && condition.get("province") == null) {
|
condition.put("province", province.trim());
|
if (StringUtils.isNotBlank(city)) {
|
condition.put("city", city.trim());
|
}
|
|
if (StringUtils.isNotBlank(area)) {
|
condition.put("area", area.trim());
|
}
|
|
if (StringUtils.isNotBlank(town)) {
|
condition.put("town", town.trim());
|
}
|
|
if (StringUtils.isNotBlank(community)) {
|
condition.put("community", community.trim());
|
}
|
}
|
|
pageInfo.setCondition(condition);
|
|
patrolOrderService.selectDataGrid(pageInfo);
|
|
msg.setResult(pageInfo);
|
return msg;
|
}
|
|
@GetMapping("/patrolDetail")
|
@ApiOperation(value = "获取安全巡检明细",response = Msg.class)
|
@ApiImplicitParams({
|
@ApiImplicitParam(name = "pageIndex",value = "当前页码"),
|
@ApiImplicitParam(name = "pageSize",value = "每页行数"),
|
@ApiImplicitParam(name = "sort",value = "排序规则"),
|
@ApiImplicitParam(name = "order",value = "排序字段"),
|
@ApiImplicitParam(name = "orderid",value = "订单id"),
|
@ApiImplicitParam(name = "ismend",value = "是否整改"),
|
})
|
public Msg getpatrolDetailList(@RequestParam(defaultValue = "0") Integer pageIndex, @RequestParam(defaultValue = "10") Integer pageSize, String sort, String order,
|
Long orderid, Byte ismend){
|
Msg msg = new Msg();
|
msg.setCode("200");
|
msg.setMessage("success");
|
|
PageInfo pageInfo = new PageInfo(pageIndex, pageSize,sort,order);
|
HashMap<String, Object> condition = new HashMap<String, Object>();
|
|
if (orderid != null) {
|
condition.put("orderid", orderid);
|
}
|
|
if (ismend != null) {
|
condition.put("ismend", ismend);
|
}
|
|
pageInfo.setCondition(condition);
|
|
patrolDetailService.selectDataGrid(pageInfo);
|
msg.setResult(pageInfo);
|
return msg;
|
}
|
|
@PostMapping("/mendPatrol")
|
@ApiOperation(value = "上报整改",response = Msg.class)
|
@ApiImplicitParams({
|
@ApiImplicitParam(name = "id",value = "单据id"),
|
@ApiImplicitParam(name = "file",value = "整改后图片文件"),
|
@ApiImplicitParam(name = "ismend",value = "是否整改"),
|
})
|
public Msg mendPatrol(Long id, MultipartFile file, Byte ismend) throws Exception {
|
Msg msg = new Msg();
|
msg.setCode("200");
|
msg.setMessage("success");
|
|
if (id == null){
|
msg.setCode("999");
|
msg.setMessage("单据id不能为空");
|
return msg;
|
}
|
PatrolDetailInfo patrolDetailInfo = patrolDetailService.getById(id);
|
if (patrolDetailInfo == null){
|
msg.setCode("999");
|
msg.setMessage("未找到单据");
|
return msg;
|
}
|
if (file != null){
|
String origincontract = UploadUtil.uploadFile(file,patrolPath);
|
patrolDetailInfo.setAfterpath(patrolUrl+origincontract);
|
}
|
if (ismend != null){
|
patrolDetailInfo.setIsmend(ismend);
|
}
|
patrolDetailService.updateById(patrolDetailInfo);
|
|
//查看所有detail 全为已整改 则修改order为已整改
|
int isNotMend = patrolDetailService.selectIsNotMend(patrolDetailInfo.getOrderid());
|
if (isNotMend == 0){
|
PatrolOrderInfo patrolOrderInfo = patrolOrderService.getById(patrolDetailInfo.getOrderid());
|
if (patrolOrderInfo != null){
|
patrolOrderInfo.setIsmend((byte)1);
|
patrolOrderService.updateById(patrolOrderInfo);
|
}
|
}
|
|
return msg;
|
}
|
|
@PostMapping("/appMendPatrol")
|
@ApiOperation(value = "APP上报整改",response = Msg.class)
|
@ApiImplicitParams({
|
@ApiImplicitParam(name = "id",value = "单据id"),
|
@ApiImplicitParam(name = "afterpath",value = "整改后图片文件"),
|
@ApiImplicitParam(name = "ismend",value = "是否整改"),
|
})
|
public Msg mendPatrol(Long id, String afterpath, Byte ismend) throws Exception {
|
Msg msg = new Msg();
|
msg.setCode("200");
|
msg.setMessage("success");
|
|
if (id == null){
|
msg.setCode("999");
|
msg.setMessage("单据id不能为空");
|
return msg;
|
}
|
PatrolDetailInfo patrolDetailInfo = patrolDetailService.getById(id);
|
if (patrolDetailInfo == null){
|
msg.setCode("999");
|
msg.setMessage("未找到单据");
|
return msg;
|
}
|
|
patrolDetailInfo.setAfterpath(afterpath);
|
|
if (ismend != null){
|
patrolDetailInfo.setIsmend(ismend);
|
}
|
patrolDetailService.updateById(patrolDetailInfo);
|
|
//查看所有detail 全为已整改 则修改order为已整改
|
int isNotMend = patrolDetailService.selectIsNotMend(patrolDetailInfo.getOrderid());
|
if (isNotMend == 0){
|
PatrolOrderInfo patrolOrderInfo = patrolOrderService.getById(patrolDetailInfo.getOrderid());
|
if (patrolOrderInfo != null){
|
patrolOrderInfo.setIsmend((byte)1);
|
patrolOrderService.updateById(patrolOrderInfo);
|
}
|
}
|
|
return msg;
|
}
|
|
}
|
