guoyuepeng
/
qa-prevention-gwj
1
0
Fork 3
Code Issues Pull Requests 1 Packages Projects Releases Wiki Activity

1111111

pet
shanao 2024-10-15 18:13:26 +08:00
parent 0698b28d27
commit 9e089fcb62
17 changed files with 266 additions and 266 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

46
src/main/java/com/zcloud/controller/app/AppHiddenController.java
View File

@ -1,25 +1,25 @@
package com.zcloud.controller.app; package com.zcloud.controller.app;
import java.text.SimpleDateFormat; import cn.hutool.crypto.digest.DigestUtil;
import java.util.ArrayList; import com.alibaba.fastjson.JSON;
import java.util.Calendar; import com.alibaba.fastjson.JSONObject;
import java.util.Date; import com.aliyuncs.dysmsapi.model.v20170525.SendSmsResponse;
import java.util.HashMap; import com.zcloud.controller.base.BaseController;
import java.util.List; import com.zcloud.entity.Page;
import java.util.Map; import com.zcloud.entity.PageData;
import java.util.Random;
import java.io.File;
import com.zcloud.controller.bus.HiddenController;
import com.zcloud.service.bus.*; import com.zcloud.service.bus.*;
import com.zcloud.service.hiddenApi.HiddenApiService; import com.zcloud.service.hiddenApi.HiddenApiService;
import com.zcloud.service.hiddenApi.HiddenCheckApiService; import com.zcloud.service.hiddenApi.HiddenCheckApiService;
import com.zcloud.service.hiddenApi.HiddenExamineApiService; import com.zcloud.service.hiddenApi.HiddenExamineApiService;
import com.zcloud.service.inspection.SafetyEnvironmentalService; import com.zcloud.service.inspection.SafetyEnvironmentalService;
import com.zcloud.service.system.DepartmentService;
import com.zcloud.service.system.FHlogService; import com.zcloud.service.system.FHlogService;
import com.zcloud.service.system.UsersService;
import com.zcloud.util.*; import com.zcloud.util.*;
import com.zcloud.util.event.DeviceHiddenEvent; import com.zcloud.util.event.DeviceHiddenEvent;
import com.zcloud.util.message.MessageService; import com.zcloud.util.message.MessageService;
import net.sf.json.JSONArray;
import org.apache.commons.io.FileUtils;
import org.apache.commons.lang.StringUtils; import org.apache.commons.lang.StringUtils;
import org.springframework.beans.factory.annotation.Autowired; import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.context.ApplicationContext; import org.springframework.context.ApplicationContext;
@ -29,27 +29,12 @@ import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RequestParam; import org.springframework.web.bind.annotation.RequestParam;
import org.springframework.web.bind.annotation.ResponseBody; import org.springframework.web.bind.annotation.ResponseBody;
import org.springframework.web.multipart.MultipartFile; import org.springframework.web.multipart.MultipartFile;
import org.springframework.web.servlet.ModelAndView;
import org.apache.commons.io.FileUtils;
import org.apache.fop.fo.flow.PageNumberCitation;
import org.apache.fop.render.afp.modca.PageDescriptor;
import org.apache.shiro.authz.annotation.RequiresPermissions;
import com.alibaba.fastjson.JSON;
import com.alibaba.fastjson.JSONObject;
import com.aliyuncs.dysmsapi.model.v20170525.SendSmsResponse;
import com.zcloud.controller.base.BaseController;
import com.zcloud.entity.Page;
import net.sf.json.JSONArray;
import com.zcloud.entity.PageData;
import com.zcloud.service.system.DepartmentService;
import com.zcloud.service.system.UsersService;
import javax.annotation.Resource; import javax.annotation.Resource;
import javax.servlet.http.HttpServletRequest; import javax.servlet.http.HttpServletRequest;
import javax.tools.Tool; import java.io.File;
import java.text.SimpleDateFormat;
import java.util.*;
/** /**
* 说明：隐患 作者：luoxiaobao 时间：2021-01-04 官网：www.zcloudchina.com * 说明：隐患 作者：luoxiaobao 时间：2021-01-04 官网：www.zcloudchina.com
@ -567,6 +552,7 @@ public class AppHiddenController extends BaseController {
} }
File tempFile = new File(file.getOriginalFilename()); File tempFile = new File(file.getOriginalFilename());
FileUtils.copyInputStreamToFile(file.getInputStream(), tempFile); FileUtils.copyInputStreamToFile(file.getInputStream(), tempFile);
String md5 = DigestUtil.md5Hex(tempFile);
if (!FileUpload.isImage(tempFile)) { if (!FileUpload.isImage(tempFile)) {
tempFile.delete(); tempFile.delete();
map.put("result", "failed"); map.put("result", "failed");
@ -584,8 +570,10 @@ public class AppHiddenController extends BaseController {
Smb.sshSftp(file, fileName, Const.FILEPATHFILE + ffile); Smb.sshSftp(file, fileName, Const.FILEPATHFILE + ffile);
PageData pd = new PageData(); PageData pd = new PageData();
pd.put("IMGFILES_ID", this.get32UUID()); pd.put("IMGFILES_ID", this.get32UUID());
pd.put("MD5", md5);
pd.put("FILEPATH", Const.FILEPATHFILE + ffile + "/" + fileName); pd.put("FILEPATH", Const.FILEPATHFILE + ffile + "/" + fileName);
pd.put("TYPE", TYPE); pd.put("TYPE", TYPE);
pd.put("FOREIGN_KEY", FOREIGN_KEY); pd.put("FOREIGN_KEY", FOREIGN_KEY);
imgFilesService.save(pd); imgFilesService.save(pd);

27
src/main/java/com/zcloud/controller/app/AppImgFilesController.java
View File

@ -1,13 +1,13 @@
package com.zcloud.controller.app; package com.zcloud.controller.app;
import java.io.File; import cn.hutool.crypto.digest.DigestUtil;
import java.util.ArrayList; import com.zcloud.controller.base.BaseController;
import java.util.Date; import com.zcloud.entity.Page;
import java.util.HashMap; import com.zcloud.entity.PageData;
import java.util.List; import com.zcloud.service.bus.ImgFilesService;
import java.util.Map;
import com.zcloud.util.*; import com.zcloud.util.*;
import org.apache.commons.io.FileUtils;
import org.apache.shiro.authz.annotation.RequiresPermissions;
import org.springframework.beans.factory.annotation.Autowired; import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Controller; import org.springframework.stereotype.Controller;
import org.springframework.transaction.annotation.Transactional; import org.springframework.transaction.annotation.Transactional;
@ -16,13 +16,12 @@ import org.springframework.web.bind.annotation.RequestParam;
import org.springframework.web.bind.annotation.ResponseBody; import org.springframework.web.bind.annotation.ResponseBody;
import org.springframework.web.multipart.MultipartFile; import org.springframework.web.multipart.MultipartFile;
import org.springframework.web.servlet.ModelAndView; import org.springframework.web.servlet.ModelAndView;
import org.apache.commons.io.FileUtils;
import org.apache.shiro.authz.annotation.RequiresPermissions;
import com.zcloud.controller.base.BaseController; import java.io.File;
import com.zcloud.entity.Page; import java.util.ArrayList;
import com.zcloud.entity.PageData; import java.util.HashMap;
import com.zcloud.service.bus.ImgFilesService; import java.util.List;
import java.util.Map;
/** /**
* 说明：图片管理 * 说明：图片管理
@ -65,6 +64,7 @@ public class AppImgFilesController extends BaseController {
MultipartFile file = files[i]; MultipartFile file = files[i];
// 保存文件 // 保存文件
File tempFile = new File(file.getOriginalFilename()); File tempFile = new File(file.getOriginalFilename());
String md5 = DigestUtil.md5Hex(tempFile);
FileUtils.copyInputStreamToFile(file.getInputStream(), tempFile); FileUtils.copyInputStreamToFile(file.getInputStream(), tempFile);
if(!FileUpload.isImage(tempFile) && !TYPE.equals("2") && !TYPE.equals("102")) {//四色图改为json文件,不用判断类型 if(!FileUpload.isImage(tempFile) && !TYPE.equals("2") && !TYPE.equals("102")) {//四色图改为json文件,不用判断类型
tempFile.delete(); tempFile.delete();
@ -98,6 +98,7 @@ public class AppImgFilesController extends BaseController {
pd.put("IMGFILES_ID", this.get32UUID()); pd.put("IMGFILES_ID", this.get32UUID());
pd.put("FILEPATH", Const.FILEPATHFILE + pd.getString("CORPINFO_ID") + "/" + ffile + "/" + fileName); pd.put("FILEPATH", Const.FILEPATHFILE + pd.getString("CORPINFO_ID") + "/" + ffile + "/" + fileName);
pd.put("TYPE", TYPE); pd.put("TYPE", TYPE);
pd.put("MD5", md5);
pd.put("FOREIGN_KEY", FOREIGN_KEY); pd.put("FOREIGN_KEY", FOREIGN_KEY);
imgfilesService.save(pd); imgfilesService.save(pd);
} }

26
src/main/java/com/zcloud/controller/bus/VideoController.java
View File

@ -1,11 +1,10 @@
package com.zcloud.controller.bus; package com.zcloud.controller.bus;
import java.util.ArrayList; import com.zcloud.controller.base.BaseController;
import java.util.Date; import com.zcloud.entity.Page;
import java.util.HashMap; import com.zcloud.entity.PageData;
import java.util.List; import com.zcloud.service.bus.VideoService;
import java.util.Map; import com.zcloud.util.*;
import org.apache.shiro.authz.annotation.RequiresPermissions; import org.apache.shiro.authz.annotation.RequiresPermissions;
import org.springframework.beans.factory.annotation.Autowired; import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.beans.factory.annotation.Value; import org.springframework.beans.factory.annotation.Value;
@ -16,18 +15,7 @@ import org.springframework.web.bind.annotation.ResponseBody;
import org.springframework.web.multipart.MultipartFile; import org.springframework.web.multipart.MultipartFile;
import org.springframework.web.servlet.ModelAndView; import org.springframework.web.servlet.ModelAndView;
import com.zcloud.controller.base.BaseController; import java.util.*;
import com.zcloud.entity.Page;
import com.zcloud.entity.PageData;
import com.zcloud.service.bus.VideoService;
import com.zcloud.util.Const;
import com.zcloud.util.DateUtil;
import com.zcloud.util.FileUpload;
import com.zcloud.util.Jurisdiction;
import com.zcloud.util.ObjectExcelView;
import com.zcloud.util.PathUtil;
import com.zcloud.util.Smb;
import com.zcloud.util.Tools;
/** /**
* 说明：视频管理 * 说明：视频管理
@ -155,7 +143,7 @@ public class VideoController extends BaseController {
@RequiresPermissions("video:edit") @RequiresPermissions("video:edit")
@ResponseBody @ResponseBody
public Object goEdit() throws Exception{ public Object goEdit() throws Exception{
Map<String,Object> map = new HashMap<String,Object>(); Map<String,Object> map = new HashMap<>();
String errInfo = "success"; String errInfo = "success";
PageData pd = new PageData(); PageData pd = new PageData();
pd = this.getPageData(); pd = this.getPageData();

10
src/main/java/com/zcloud/controller/inspection/SafetyEnvironmentalController.java
View File

@ -3,11 +3,8 @@ package com.zcloud.controller.inspection;
import com.zcloud.controller.base.BaseController; import com.zcloud.controller.base.BaseController;
import com.zcloud.entity.Page; import com.zcloud.entity.Page;
import com.zcloud.entity.PageData; import com.zcloud.entity.PageData;
import com.zcloud.entity.hotWorkApplication.Color;
import com.zcloud.entity.hotWorkApplication.Node; import com.zcloud.entity.hotWorkApplication.Node;
import com.zcloud.entity.hotWorkApplication.Overseer; import com.zcloud.entity.hotWorkApplication.Overseer;
import com.zcloud.entity.system.Department;
import com.zcloud.entity.system.User;
import com.zcloud.service.bus.HiddenCheckService; import com.zcloud.service.bus.HiddenCheckService;
import com.zcloud.service.bus.HiddenService; import com.zcloud.service.bus.HiddenService;
import com.zcloud.service.bus.NoticeCorpService; import com.zcloud.service.bus.NoticeCorpService;
@ -21,8 +18,6 @@ import com.zcloud.service.system.UsersService;
import com.zcloud.util.*; import com.zcloud.util.*;
import org.apache.commons.lang.StringUtils; import org.apache.commons.lang.StringUtils;
import org.apache.shiro.authz.annotation.RequiresPermissions; import org.apache.shiro.authz.annotation.RequiresPermissions;
import org.apache.shiro.session.Session;
import org.apache.xmlgraphics.xmp.schemas.pdf.PDFAAdapter;
import org.springframework.beans.factory.annotation.Autowired; import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.beans.factory.annotation.Value; import org.springframework.beans.factory.annotation.Value;
import org.springframework.stereotype.Controller; import org.springframework.stereotype.Controller;
@ -34,7 +29,6 @@ import org.springframework.web.servlet.ModelAndView;
import javax.annotation.Resource; import javax.annotation.Resource;
import javax.servlet.http.HttpServletResponse; import javax.servlet.http.HttpServletResponse;
import java.util.*; import java.util.*;
import java.util.stream.Collectors;
/** /**
* 说明：安全环保检查 * 说明：安全环保检查
@ -211,11 +205,11 @@ public class SafetyEnvironmentalController extends BaseController {
@RequiresPermissions("safetyenvironmental:list") @RequiresPermissions("safetyenvironmental:list")
@ResponseBody @ResponseBody
public Object list(Page page) throws Exception { public Object list(Page page) throws Exception {
Map<String, Object> map = new HashMap<String, Object>(); Map<String, Object> map = new HashMap<>();
String errInfo = "success"; String errInfo = "success";
PageData pd = this.getPageData(); PageData pd = this.getPageData();
String KEYWORDS = pd.getString("KEYWORDS"); //关键词检索条件 String KEYWORDS = pd.getString("KEYWORDS"); //关键词检索条件
if (Tools.notEmpty(KEYWORDS)) pd.put("KEYWORDS", KEYWORDS.trim()); pd.put("KEYWORDS", Tools.notEmpty(KEYWORDS) ? KEYWORDS.trim() : "");
pd.put("CORPINFO_ID", Jurisdiction.getCORPINFO_ID()); //企业ID pd.put("CORPINFO_ID", Jurisdiction.getCORPINFO_ID()); //企业ID
// PageData userInfo = new PageData(); // PageData userInfo = new PageData();
// userInfo.put("USER_ID",pd.getString("INSPECTION_ORIGINATOR_ID")); // userInfo.put("USER_ID",pd.getString("INSPECTION_ORIGINATOR_ID"));

1
src/main/java/com/zcloud/controller/inspection/SafetyEnvironmentalExplainController.java
View File

@ -8,7 +8,6 @@ import com.zcloud.service.bus.NoticeCorpUtil;
import com.zcloud.service.inspection.SafetyEnvironmentalExplainService; import com.zcloud.service.inspection.SafetyEnvironmentalExplainService;
import com.zcloud.service.system.DepartmentService; import com.zcloud.service.system.DepartmentService;
import com.zcloud.util.*; import com.zcloud.util.*;
import org.apache.commons.lang.ObjectUtils;
import org.apache.commons.lang.StringUtils; import org.apache.commons.lang.StringUtils;
import org.apache.shiro.authz.annotation.RequiresPermissions; import org.apache.shiro.authz.annotation.RequiresPermissions;
import org.springframework.beans.factory.annotation.Autowired; import org.springframework.beans.factory.annotation.Autowired;

47
src/main/java/com/zcloud/controller/system/LoginController.java
View File

@ -1,50 +1,26 @@
package com.zcloud.controller.system; package com.zcloud.controller.system;
import java.util.*; import com.zcloud.controller.base.BaseController;
import com.zcloud.entity.PageData;
import javax.servlet.http.HttpServletRequest; import com.zcloud.entity.system.User;
import com.zcloud.service.bus.CorpInfoService;
import com.zcloud.service.bus.OffDutyService;
import com.zcloud.service.system.*; import com.zcloud.service.system.*;
import com.zcloud.util.*; import com.zcloud.util.*;
import org.apache.http.HttpEntity; import net.sf.json.JSONObject;
import org.apache.http.client.entity.UrlEncodedFormEntity;
import org.apache.http.client.methods.CloseableHttpResponse;
import org.apache.http.client.methods.HttpPost;
import org.apache.http.entity.ContentType;
import org.apache.http.entity.StringEntity;
import org.apache.http.impl.client.CloseableHttpClient;
import org.apache.http.impl.client.HttpClients;
import org.apache.http.message.BasicNameValuePair;
import org.apache.http.protocol.HTTP;
import org.apache.http.util.EntityUtils;
import org.apache.shiro.SecurityUtils; import org.apache.shiro.SecurityUtils;
import org.apache.shiro.authc.AuthenticationException; import org.apache.shiro.authc.*;
import org.apache.shiro.authc.DisabledAccountException;
import org.apache.shiro.authc.ExcessiveAttemptsException;
import org.apache.shiro.authc.IncorrectCredentialsException;
import org.apache.shiro.authc.LockedAccountException;
import org.apache.shiro.authc.UnknownAccountException;
import org.apache.shiro.authc.UsernamePasswordToken;
import org.apache.shiro.crypto.hash.SimpleHash; import org.apache.shiro.crypto.hash.SimpleHash;
import org.apache.shiro.session.Session; import org.apache.shiro.session.Session;
import org.apache.shiro.subject.Subject; import org.apache.shiro.subject.Subject;
import org.springframework.beans.factory.annotation.Autowired; import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.beans.factory.annotation.Value;
import org.springframework.stereotype.Controller; import org.springframework.stereotype.Controller;
import org.springframework.web.bind.annotation.RequestMapping; import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RequestParam; import org.springframework.web.bind.annotation.RequestParam;
import org.springframework.web.bind.annotation.ResponseBody; import org.springframework.web.bind.annotation.ResponseBody;
import com.alibaba.fastjson.JSON; import javax.servlet.http.HttpServletRequest;
import com.fasterxml.jackson.databind.ObjectMapper; import java.util.*;
import com.zcloud.controller.base.BaseController;
import com.zcloud.entity.PageData;
import com.zcloud.entity.system.Role;
import com.zcloud.entity.system.User;
import com.zcloud.service.bus.CorpInfoService;
import com.zcloud.service.bus.OffDutyService;
import net.sf.json.JSONObject;
/** /**
* 说明：登录处理类 * 说明：登录处理类
@ -177,6 +153,7 @@ public class LoginController extends BaseController {
} catch (AuthenticationException ae) { } catch (AuthenticationException ae) {
errInfo = "usererror"; errInfo = "usererror";
} }
Integer port = SpringUtil.getApplicationContext().getEnvironment().getProperty("server.port", Integer.class);
if (subject.isAuthenticated()) { //验证是否登录成功 if (subject.isAuthenticated()) { //验证是否登录成功
removeSession(USERNAME); removeSession(USERNAME);
@ -201,7 +178,8 @@ public class LoginController extends BaseController {
if (backEndPath.get("result").toString().equals("success")) { if (backEndPath.get("result").toString().equals("success")) {
backEndPath.put("baseImgPath",map.get("baseImgPath").toString()); backEndPath.put("baseImgPath",map.get("baseImgPath").toString());
backEndPath.put("USER_IDENTITY",map.get("USER_IDENTITY").toString()); backEndPath.put("USER_IDENTITY",map.get("USER_IDENTITY").toString());
backEndPath.put("BACKENDADDR", map.get("BACKENDADDR").toString());
backEndPath.put("BACKENDADDR", "http://" + ip + ":" + port + "/");
System.out.println("登录返回参数：" + backEndPath); System.out.println("登录返回参数：" + backEndPath);
return backEndPath; return backEndPath;
} else { } else {
@ -212,6 +190,7 @@ public class LoginController extends BaseController {
return map; return map;
} }
} }
map.put("BACKENDADDR", "http://" + ip + ":" + port + "/");
if ("99".equals(pd.getString("STATUS"))) { if ("99".equals(pd.getString("STATUS"))) {
errInfo = "userlock"; errInfo = "userlock";
map.put("result", "fail"); map.put("result", "fail");

21
src/main/java/com/zcloud/controller/xgf/XgfCorpController.java
View File

@ -1,30 +1,25 @@
package com.zcloud.controller.xgf; package com.zcloud.controller.xgf;
import java.util.*;
import java.util.stream.Collectors;
import com.alibaba.fastjson.JSONObject; import com.alibaba.fastjson.JSONObject;
import com.zcloud.controller.base.BaseController;
import com.zcloud.entity.Page; import com.zcloud.entity.Page;
import com.zcloud.service.bus.CorpInfoService; import com.zcloud.entity.PageData;
import com.zcloud.service.system.DepartmentService; import com.zcloud.service.system.DepartmentService;
import com.zcloud.util.DateUtil;
import com.zcloud.util.HttpClientService;
import com.zcloud.util.Jurisdiction;
import com.zcloud.util.ObjectExcelView; import com.zcloud.util.ObjectExcelView;
import net.sf.json.JSONArray;
import org.apache.shiro.authz.annotation.RequiresPermissions;
import org.springframework.beans.factory.annotation.Autowired; import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.beans.factory.annotation.Value; import org.springframework.beans.factory.annotation.Value;
import org.springframework.web.bind.annotation.RequestMapping; import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.ResponseBody; import org.springframework.web.bind.annotation.ResponseBody;
import org.springframework.web.bind.annotation.RestController; import org.springframework.web.bind.annotation.RestController;
import org.springframework.web.client.RestTemplate; import org.springframework.web.client.RestTemplate;
import com.zcloud.controller.base.BaseController;
import com.zcloud.entity.PageData;
import com.zcloud.util.DateUtil;
import com.zcloud.util.HttpClientService;
import com.zcloud.util.Jurisdiction;
import org.springframework.web.servlet.ModelAndView; import org.springframework.web.servlet.ModelAndView;
import javax.annotation.Resource; import javax.annotation.Resource;
import java.util.*;
import java.util.stream.Collectors;
@RestController @RestController
@RequestMapping("/xgf/corp") @RequestMapping("/xgf/corp")
@ -62,7 +57,7 @@ public class XgfCorpController extends BaseController {
} }
} }
Map result = HttpClientService.doPost(url + "/api/corpinfo/JiTuanTeShulist", pd); Map result = HttpClientService.doPost(url + "/api/corpinfo/JiTuanTeShulist", pd);
// created by liu jun (为了不在相关方连表查询，只能在这里这么写，兼容老数据) // created by liu jun (为了不在相关方连表查询，只能在这里这么写，兼容老数据)
List<HashMap> list = (List<HashMap> )result.get("varList"); List<HashMap> list = (List<HashMap> )result.get("varList");
for (HashMap x : list) { for (HashMap x : list) {
if (x.get("MAIN_DEPARTMENT") != null && x.get("MAIN_DEPARTMENT").toString().contains("]")) { if (x.get("MAIN_DEPARTMENT") != null && x.get("MAIN_DEPARTMENT").toString().contains("]")) {

9
src/main/java/com/zcloud/service/accident/AccidentRecordsService.java
View File

@ -2,6 +2,7 @@ package com.zcloud.service.accident;
import com.zcloud.entity.Page; import com.zcloud.entity.Page;
import com.zcloud.entity.PageData; import com.zcloud.entity.PageData;
import com.zcloud.entity.accident.AccidentRecords;
import org.springframework.web.multipart.MultipartFile; import org.springframework.web.multipart.MultipartFile;
import java.util.List; import java.util.List;
@ -28,16 +29,16 @@ public interface AccidentRecordsService {
/** /**
* 新增 * 新增
* *
* @param pageData 要保存的实体 * @param accidentRecords 要保存的实体
*/ */
void save(PageData pageData); void save(AccidentRecords accidentRecords);
/** /**
* 修改 * 修改
* *
* @param bean 要修改的实体 * @param accidentRecords 要修改的实体
*/ */
void update(PageData pageData); void update(AccidentRecords accidentRecords);
/** /**
* 删除 * 删除

297
src/main/java/com/zcloud/service/inspection/SafetyEnvironmentalService.java
View File

@ -11,158 +11,193 @@ import java.util.List;
* 时间：2022-06-08 * 时间：2022-06-08
* 官网：www.zcloudchina.com * 官网：www.zcloudchina.com
*/ */
public interface SafetyEnvironmentalService{ public interface SafetyEnvironmentalService {
List<PageData> getHiddenCountByDepat (PageData pd) throws Exception; List<PageData> getHiddenCountByDepat(PageData pd) throws Exception;
List<PageData> getHiddenCountByUser (PageData pd) throws Exception;
/**新增
* @param pd
* @throws Exception
*/
public List<PageData> save(PageData pd)throws Exception;
/**删除 List<PageData> getHiddenCountByUser(PageData pd) throws Exception;
* @param pd
* @throws Exception
*/
public void delete(PageData pd)throws Exception;
/**修改 /**
* @param pd * 新增
* @throws Exception *
*/ * @param pd
public List<PageData> edit(PageData pd)throws Exception; * @throws Exception
*/
public List<PageData> save(PageData pd) throws Exception;
/**修改 /**
* @param pd * 删除
* @throws Exception *
*/ * @param pd
public void edieditsttust(PageData pd)throws Exception; //执行考评方法时，将检查状态改成已归档，因为bug6535提出，要是隐患考评完毕，状态应该是8已归档 * @throws Exception
*/
public void delete(PageData pd) throws Exception;
/**列表 /**
* @param page * 修改
* @throws Exception *
*/ * @param pd
public List<PageData> list(Page page)throws Exception; * @throws Exception
*/
public List<PageData> edit(PageData pd) throws Exception;
/**列表(全部) /**
* @param pd * 修改
* @throws Exception *
*/ * @param pd
public List<PageData> listAll(PageData pd)throws Exception; * @throws Exception
*/
public void edieditsttust(PageData pd) throws Exception; //执行考评方法时，将检查状态改成已归档，因为bug6535提出，要是隐患考评完毕，状态应该是8已归档
/**列表(全部) /**
* @param pd * 列表
* @throws Exception *
*/ * @param page 分页数据和条件
public List<PageData> findByyin(PageData pd)throws Exception; * @throws Exception 可能存在的异常
/**通过id获取数据 */
* @param pd List<PageData> list(Page page) throws Exception;
* @throws Exception
*/
public PageData findById(PageData pd)throws Exception;
/**批量删除 /**
* @param pd * 列表(全部)
* @throws Exception *
*/ * @param pd
public void deleteAll(PageData pd)throws Exception; * @throws Exception
*/
public List<PageData> listAll(PageData pd) throws Exception;
/**列表(根据所选ID获取数据) /**
* @param pd * 列表(全部)
* @throws Exception *
*/ * @param pd
List<PageData> findByIds(PageData pd)throws Exception; * @throws Exception
*/
public List<PageData> findByyin(PageData pd) throws Exception;
/** /**
* 更新检查进度状态 * 通过id获取数据
* @param pd *
*/ * @param pd
void editStatus(PageData pd)throws Exception; * @throws Exception
*/
public PageData findById(PageData pd) throws Exception;
PageData findShowById(PageData pd)throws Exception; /**
* 批量删除
*
* @param pd
* @throws Exception
*/
public void deleteAll(PageData pd) throws Exception;
/** /**
* 获取检查所有相关信息 * 列表(根据所选ID获取数据)
* @param pd *
* @return * @param pd
*/ * @throws Exception
PageData findFormById(PageData pd)throws Exception; */
List<PageData> findByIds(PageData pd) throws Exception;
/** /**
* 申辩不成立时归档 * 更新检查进度状态
* @param pd *
* @throws Exception * @param pd
*/ */
void explain(PageData pd)throws Exception; void editStatus(PageData pd) throws Exception;
/** PageData findShowById(PageData pd) throws Exception;
* 分公司安全环保检查考核分数统计
* @param pd
* @return
* @throws Exception
*/
PageData statisticsBranch(PageData pd)throws Exception;
/** /**
* 列表（股份公司安全环保检查考核分数统计） * 获取检查所有相关信息
* @param pd *
* @return * @param pd
* @throws Exception * @return
*/ */
List<PageData> statisticsJointStock(PageData pd) throws Exception; PageData findFormById(PageData pd) throws Exception;
/** /**
* 被检查人签字/申辩数 * 申辩不成立时归档
* @param pd *
* @return * @param pd
* @throws Exception * @throws Exception
*/ */
PageData checkedCount (PageData pd)throws Exception; void explain(PageData pd) throws Exception;
/** /**
* 打回数 * 分公司安全环保检查考核分数统计
* @param pd *
* @return * @param pd
* @throws Exception * @return
*/ * @throws Exception
PageData repulseCount (PageData pd)throws Exception; */
PageData statisticsBranch(PageData pd) throws Exception;
/** /**
* 指派+验收数 * 列表（股份公司安全环保检查考核分数统计）
* @param pd *
* @return * @param pd
* @throws Exception * @return
*/ * @throws Exception
PageData repulseAndCheckCountCount (PageData pd)throws Exception; */
List<PageData> statisticsJointStock(PageData pd) throws Exception;
List<PageData> pleadList(Page page) throws Exception; /**
* 被检查人签字/申辩数
*
* @param pd
* @return
* @throws Exception
*/
PageData checkedCount(PageData pd) throws Exception;
List<PageData> checkList(Page page) ; /**
* 打回数
*
* @param pd
* @return
* @throws Exception
*/
PageData repulseCount(PageData pd) throws Exception;
/** /**
* description: 公司层级工具类 * 指派+验收数
* *
* @param data * @param pd
* @return * @return
* @throws Exception * @throws Exception
*/ */
PageData departmentUtil(PageData data) throws Exception; PageData repulseAndCheckCountCount(PageData pd) throws Exception;
/**
* 获取所有的安全环保信息
* @param pd
* @return
* @throws Exception
*/
List<PageData> statisticsBranchGroupDept(PageData pd) throws Exception;
String getHiddenTotal(Page page); List<PageData> pleadList(Page page) throws Exception;
/**
* 指派+验收数 验收数据错误,原来可以查询已经验收数据 List<PageData> checkList(Page page);
* @param pd
* @return /**
* @throws Exception * description: 公司层级工具类
*/ *
PageData repulseAndCheckCountCountV2 (PageData pd)throws Exception; * @param data
* @return
* @throws Exception
*/
PageData departmentUtil(PageData data) throws Exception;
/**
* 获取所有的安全环保信息
*
* @param pd
* @return
* @throws Exception
*/
List<PageData> statisticsBranchGroupDept(PageData pd) throws Exception;
String getHiddenTotal(Page page);
/**
* 指派+验收数 验收数据错误,原来可以查询已经验收数据
*
* @param pd
* @return
* @throws Exception
*/
PageData repulseAndCheckCountCountV2(PageData pd) throws Exception;
} }

8
src/main/java/com/zcloud/service/inspection/impl/SafetyEnvironmentalServiceImpl.java
View File

@ -466,9 +466,11 @@ public class SafetyEnvironmentalServiceImpl implements SafetyEnvironmentalServic
return hiddenList; return hiddenList;
} }
/**列表 /**
* @param page * 列表
* @throws Exception *
* @param page 分页数据和条件
* @throws Exception 可能存在的异常
*/ */
public List<PageData> list(Page page)throws Exception{ public List<PageData> list(Page page)throws Exception{
return safetyenvironmentalMapper.datalistPage(page); return safetyenvironmentalMapper.datalistPage(page);

3
src/main/java/com/zcloud/service/mkmj/impl/MkmjAreaServiceImpl.java
View File

@ -4,7 +4,6 @@ import com.zcloud.entity.Page;
import com.zcloud.entity.PageData; import com.zcloud.entity.PageData;
import com.zcloud.mapper.datasource.mkmj.MkmjAreaGateMapper; import com.zcloud.mapper.datasource.mkmj.MkmjAreaGateMapper;
import com.zcloud.mapper.datasource.mkmj.MkmjAreaMapper; import com.zcloud.mapper.datasource.mkmj.MkmjAreaMapper;
import com.zcloud.service.map.util.ReturnMap;
import com.zcloud.service.mkmj.MkmjAreaService; import com.zcloud.service.mkmj.MkmjAreaService;
import com.zcloud.util.UuidUtil; import com.zcloud.util.UuidUtil;
import org.springframework.beans.factory.annotation.Autowired; import org.springframework.beans.factory.annotation.Autowired;
@ -60,7 +59,7 @@ public class MkmjAreaServiceImpl implements MkmjAreaService {
* @throws Exception * @throws Exception
*/ */
public Object delete(PageData pd)throws Exception{ public Object delete(PageData pd)throws Exception{
Map<String,Object> map = new HashMap<String,Object>(); Map<String,Object> map = new HashMap<>();
String errInfo = "success"; String errInfo = "success";
//校验区域下是否还存在区域 存在则不让删除 //校验区域下是否还存在区域 存在则不让删除
List<PageData> childList = mkmjAreaMapper.findByChild(pd); List<PageData> childList = mkmjAreaMapper.findByChild(pd);

8
src/main/resources/application-dev.properties
View File

@ -2,10 +2,16 @@ datasource.no1.driver-class-name: com.mysql.cj.jdbc.Driver
datasource.no1.url=jdbc:mysql://39.101.130.96:33068/qa-gwj-prevention?serverTimezone=UTC&useSSL=false&useUnicode=true&characterEncoding=utf-8 datasource.no1.url=jdbc:mysql://39.101.130.96:33068/qa-gwj-prevention?serverTimezone=UTC&useSSL=false&useUnicode=true&characterEncoding=utf-8
datasource.no1.username=dev datasource.no1.username=dev
datasource.no1.password=Zykj@dev123456 datasource.no1.password=Zykj@dev123456
#datasource.no1.url=jdbc:mysql://127.0.0.1:3306/qa-gwj-prevention?serverTimezone=UTC&useSSL=false&useUnicode=true&characterEncoding=utf-8
#datasource.no1.username=root
#datasource.no1.password=123456
datasource.no2.driver-class-name: com.mysql.cj.jdbc.Driver datasource.no2.driver-class-name: com.mysql.cj.jdbc.Driver
datasource.no2.url=jdbc:mysql://39.101.130.96:33068/qa-gwj-regulatory?serverTimezone=UTC&useSSL=false&useUnicode=true&characterEncoding=utf-8 datasource.no2.url=jdbc:mysql://39.101.130.96:33068/qa-gwj-regulatory?serverTimezone=UTC&useSSL=false&useUnicode=true&characterEncoding=utf-8
datasource.no2.username=dev datasource.no2.username=dev
datasource.no2.password=Zykj@dev123456 datasource.no2.password=Zykj@dev123456
#datasource.no2.url=jdbc:mysql://127.0.0.1:3306/qa-gwj-regulatory?serverTimezone=UTC&useSSL=false&useUnicode=true&characterEncoding=utf-8
#datasource.no2.username=root
#datasource.no2.password=123456
#druid??? #druid???
@ -71,7 +77,7 @@ smb.basePath=/mnt/wwag/file/
#Mq\u914D\u7F6E #Mq\u914D\u7F6E
rocketmq.consumer.group2=edu-admin-edit rocketmq.consumer.group2=edu-admin-edit
rocketmq.consumer.group1=edu-admin-add rocketmq.consumer.group1=edu-admin-add
rocketmq.name-server=172.24.151.22:9876 rocketmq.name-server=127.0.0.1:9876
rocketmq.producer.group=libmiddle rocketmq.producer.group=libmiddle
rocketmq.producer.send-message-timeout=3000 rocketmq.producer.send-message-timeout=3000
rocketmq.producer.compress-message-body-threshold=4096 rocketmq.producer.compress-message-body-threshold=4096

3
src/main/resources/mybatis/datasource/bus/HiddenMapper.xml
View File

@ -1237,7 +1237,8 @@
) )
</if> --> </if> -->
<if test="SELFUSERID != null and SELFUSERID != ''"> <if test="SELFUSERID != null and SELFUSERID != ''">
and (select count(1) from BUS_HIDDENCHECK bh where bh.USER_ID=#{SELFUSERID} and bh.HIDDEN_ID=f.HIDDEN_ID )>0 and (select count(1) from BUS_HIDDENCHECK bh where bh.USER_ID=#{SELFUSERID}
and bh.HIDDEN_ID=f.HIDDEN_ID )>0
</if> </if>
<if test="CORPINFO_ID != null and CORPINFO_ID != ''"> <if test="CORPINFO_ID != null and CORPINFO_ID != ''">
and f.CORPINFO_ID =#{CORPINFO_ID} and f.CORPINFO_ID =#{CORPINFO_ID}

6
src/main/resources/mybatis/datasource/bus/ImgFilesMapper.xml
View File

@ -27,7 +27,8 @@
TYPE, TYPE,
FOREIGN_KEY, FOREIGN_KEY,
FILE_NAME, FILE_NAME,
IMGFILES_ID IMGFILES_ID,
MD5
</sql> </sql>
<!-- 字段值 --> <!-- 字段值 -->
@ -36,7 +37,8 @@
#{TYPE}, #{TYPE},
#{FOREIGN_KEY}, #{FOREIGN_KEY},
#{FILE_NAME}, #{FILE_NAME},
#{IMGFILES_ID} #{IMGFILES_ID},
#{MD5}
</sql> </sql>
<!-- 新增--> <!-- 新增-->

2
src/main/resources/mybatis/datasource/inspection/SafetyEnvironmentalExplainMapper.xml
View File

@ -191,7 +191,7 @@
and se.CORPINFO_ID = #{pd.CORPINFO_ID} and se.CORPINFO_ID = #{pd.CORPINFO_ID}
</if> </if>
GROUP BY se.INSPECTION_ID GROUP BY se.INSPECTION_ID
ORDER BY se.CREATTIME DESC ORDER BY se.INSPECTION_TIME_START DESC
</select> </select>
<!-- 列表(全部) --> <!-- 列表(全部) -->

2
src/main/resources/mybatis/datasource/inspection/SafetyEnvironmentalInspectorMapper.xml
View File

@ -137,7 +137,7 @@
<include refid="Field"></include> <include refid="Field"></include>
from from
<include refid="tableName"></include> f <include refid="tableName"></include> f
LEFT JOIN BUS_INSPECTION_SAFETYENVIRONMENTAL se ON se.INSPECTION_ID = f.INSPECTION_ID INNER JOIN BUS_INSPECTION_SAFETYENVIRONMENTAL se ON se.INSPECTION_ID = f.INSPECTION_ID
LEFT JOIN VI_USER_ALL iou ON iou.USER_ID = se.INSPECTION_ORIGINATOR_ID LEFT JOIN VI_USER_ALL iou ON iou.USER_ID = se.INSPECTION_ORIGINATOR_ID
LEFT JOIN VI_DEPARTMENT_ALL iod ON iod.DEPARTMENT_ID = iou.DEPARTMENT_ID LEFT JOIN VI_DEPARTMENT_ALL iod ON iod.DEPARTMENT_ID = iou.DEPARTMENT_ID
LEFT JOIN OA_DEPARTMENT isd ON isd.DEPARTMENT_ID = se.INSPECTED_DEPARTMENT_ID LEFT JOIN OA_DEPARTMENT isd ON isd.DEPARTMENT_ID = se.INSPECTED_DEPARTMENT_ID

16
src/main/resources/mybatis/datasource/inspection/SafetyEnvironmentalMapper.xml
View File

@ -240,9 +240,9 @@
IFNULL(GROUP_CONCAT(REPLACE(siu.USER_ID,'/',',')),'') AS INSPECTION_USER_ID, IFNULL(GROUP_CONCAT(REPLACE(siu.USER_ID,'/',',')),'') AS INSPECTION_USER_ID,
IFNULL(GROUP_CONCAT( DISTINCT siu.NAME),'') AS INSPECTION_USER_NAME, IFNULL(GROUP_CONCAT( DISTINCT siu.NAME),'') AS INSPECTION_USER_NAME,
CASE WHEN IFNULL(f.INSPECTION_TYPE_OTHER, '') = '' THEN d.NAME ELSE f.INSPECTION_TYPE_OTHER END INSPECTION_TYPE_NAME, CASE WHEN IFNULL(f.INSPECTION_TYPE_OTHER, '') = '' THEN d.NAME ELSE f.INSPECTION_TYPE_OTHER END INSPECTION_TYPE_NAME,
<include refid="Field"></include> <include refid="Field"/>
from from
<include refid="tableName"></include> f <include refid="tableName"/> f
LEFT JOIN bus_hidden h on h.FOREIGN_ID = f.INSPECTION_ID and h.isdelete ='0' LEFT JOIN bus_hidden h on h.FOREIGN_ID = f.INSPECTION_ID and h.isdelete ='0'
LEFT JOIN vi_user_all iou ON iou.USER_ID = f.INSPECTION_ORIGINATOR_ID LEFT JOIN vi_user_all iou ON iou.USER_ID = f.INSPECTION_ORIGINATOR_ID
LEFT JOIN OA_DEPARTMENT ild ON ild.DEPARTMENT_ID = f.INSPECTION_LEADDEPARTMENT_ID LEFT JOIN OA_DEPARTMENT ild ON ild.DEPARTMENT_ID = f.INSPECTION_LEADDEPARTMENT_ID
@ -339,6 +339,16 @@
OR iod.NAME LIKE CONCAT(CONCAT('%', #{pd.KEYWORDS}),'%') OR iod.NAME LIKE CONCAT(CONCAT('%', #{pd.KEYWORDS}),'%')
) )
</if> </if>
<!-- 2021/10/9 同步监管端搜索字段 -->
<if test="pd.INSPECTION_USER_NAME != null and pd.INSPECTION_USER_NAME != ''">
and REPLACE(siu.NAME,'/',',') LIKE CONCAT(CONCAT('%', #{pd.INSPECTION_USER_NAME}),'%')
</if>
<if test="pd.INSPECTION_USER_PHONE != null and pd.INSPECTION_USER_PHONE != ''">
and REPLACE(siu.PHONE,'/',',') LIKE CONCAT(CONCAT('%', #{pd.INSPECTION_USER_PHONE}),'%')
</if>
<if test="pd.INSPECTION_CASE != null and pd.INSPECTION_CASE != ''"><!-- 检查情况 -->
and biss.SITUATION like CONCAT('%', #{pd.INSPECTION_CASE}, '%')
</if>
GROUP BY f.INSPECTION_ID GROUP BY f.INSPECTION_ID
ORDER BY f.CREATTIME DESC ORDER BY f.CREATTIME DESC
</select> </select>
@ -711,7 +721,7 @@
) )
</if> </if>
GROUP BY f.INSPECTION_ID GROUP BY f.INSPECTION_ID
ORDER BY f.CREATTIME DESC ORDER BY f.INSPECTION_TIME_END DESC
</select> </select>
<select id="statisticsBranchGroupDept" parameterType="pd" resultType="pd"> <select id="statisticsBranchGroupDept" parameterType="pd" resultType="pd">