guoyuepeng
/
qa-prevention-gwj
1
0
Fork 3
Code Issues Pull Requests 1 Packages Projects Releases Wiki Activity
qa-prevention-gwj/src/main/java/com/zcloud/controller/keyProjects/app/AppKeyprojectCheckControlle...

421 lines
15 KiB
Java
Raw Normal View History

初始化
2023-11-07 09:32:12 +08:00
package com.zcloud.controller.keyProjects.app;
import com.alibaba.fastjson.JSON;
import com.alibaba.fastjson.JSONArray;
import com.alibaba.fastjson.JSONObject;
import com.zcloud.controller.base.BaseController;
import com.zcloud.entity.Page;
import com.zcloud.entity.PageData;
import com.zcloud.service.bus.ImgFilesService;
import com.zcloud.service.keyProjects.*;
import com.zcloud.util.DateUtil;
import com.zcloud.util.SendSmsUtil;
import com.zcloud.util.Tools;
import com.zcloud.util.UuidUtil;
import org.apache.commons.lang.StringUtils;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Controller;
import org.springframework.transaction.annotation.Transactional;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.ResponseBody;
import java.util.*;
/**
* 说明：重点工程检查
* 作者：luoxiaobao
* 时间：2022-09-19
* 官网：www.zcloudchina.com
*/
@Controller
@RequestMapping("/app/keyprojectcheck")
public class AppKeyprojectCheckController extends BaseController {
@Autowired
private KeyprojectCheckService keyprojectcheckService;
@Autowired
private KeyprojectCheckInfoService keyprojectcheckInfoService;
@Autowired
private KeyprojectHiddenService keyprojectHiddenService;
@Autowired
private ImgFilesService imgFilesService;
@Autowired
private OutSourcedService outsourcedService;
@Autowired
private PersonnelManagementService personnelmanagementService;
初始化
2023-11-08 08:53:50 +08:00
@Autowired
private KeyprojectPunishService keyprojectpunishService;
初始化
2023-11-07 09:32:12 +08:00
/**新增
* @param
* @throws Exception
*/
@RequestMapping(value="/add")
@ResponseBody
public Object add() throws Exception{
Map<String,Object> map = new HashMap<String,Object>();
String errInfo = "success";
PageData pd = new PageData();
pd = this.getPageData();
pd.put("KEYPROJECTCHECK_ID", this.get32UUID()); //主键
pd.put("CREATTIME", DateUtil.date2Str(new Date())); //添加时间
pd.put("OPERATTIME", DateUtil.date2Str(new Date())); //修改时间
pd.put("ISDELETE", 0); //是否删除
fix:重点工程检查企业端来源不正确的问题
2023-11-14 10:57:54 +08:00
pd.put("SOURCE", 2); //企业2
初始化
2023-11-07 09:32:12 +08:00
keyprojectcheckService.save(pd);
String currentTime = DateUtil.date2Str(new Date());
if (Tools.notEmpty(pd.getString("SITUATIONJSON"))) {
List<JSONObject> list = (List<JSONObject>) JSON.parse(pd.getString("SITUATIONJSON"));
String time = currentTime;
for (JSONObject json : list) {
PageData situationPd = new PageData();
situationPd.put("KEYPROJECTCHECKINFO_ID", UuidUtil.get32UUID()); //主键
situationPd.put("KEYPROJECTCHECK_ID", pd.getString("KEYPROJECTCHECK_ID")); //检查ID
situationPd.put("SITUATION", json.get("SITUATION")); //检查情况
situationPd.put("ISDELETE", "0"); //是否删除(0:有效 1：删除)
situationPd.put("CREATOR", pd.getString("CREATOR")); //添加人
situationPd.put("CREATTIME", time); //添加时间
situationPd.put("OPERATOR", pd.getString("OPERATOR")); //修改人
situationPd.put("OPERATTIME", time); //修改时间
keyprojectcheckInfoService.save(situationPd);
time = DateUtil.calculateDateSecond(time, 1);
}
}
调整处罚短信接口逻辑
2023-11-16 17:20:16 +08:00
Boolean boo = false; // 增加开关控制
初始化
2023-11-07 09:32:12 +08:00
if (Tools.notEmpty(pd.getString("HIDDENJSON"))) {
调整处罚短信接口逻辑
2023-11-16 17:20:16 +08:00
boo = true;
初始化
2023-11-07 09:32:12 +08:00
List<PageData> hiddenList = new ArrayList<PageData>();
List<JSONObject> list = (List<JSONObject>) JSON.parse(pd.getString("HIDDENJSON"));
String time = currentTime;
for (JSONObject json : list) {
PageData hidden = new PageData();
hidden.put("HIDDEN_ID", UuidUtil.get32UUID()); //主键
hidden.put("FOREIGN_ID", pd.getString("KEYPROJECTCHECK_ID")); //外键ID
hidden.put("HIDDENDESCR", json.getString("HIDDENDESCR")); //隐患描述
hidden.put("HIDDENPART", json.getString("HIDDENPART")); //隐患部位
hidden.put("HIDDENLEVEL", json.getString("HIDDENLEVEL")); //隐患级别
hidden.put("HIDDENTYPE", json.getString("HIDDENTYPE")); //隐患类型1
hidden.put("HIDDENTYPE2", json.getString("HIDDENTYPE2")); //隐患类型2
hidden.put("LONGITUDE", json.getString("LONGITUDE")); //隐患位置经度
hidden.put("LATITUDE", json.getString("LATITUDE")); //隐患位置纬度
hidden.put("DISCOVERYTIME", json.getString("DISCOVERYTIME")); //隐患发现时间
hidden.put("HIDDENFINDDEPT", json.getString("HIDDENFINDDEPT")); //隐患发现部门（隐患责任人部门）
hidden.put("RECTIFICATIONTYPE", json.getString("RECTIFICATIONTYPE")); //隐患处置
hidden.put("RECTIFICATIONDEADLINE", json.getString("RECTIFICATIONDEADLINE")); //整改期限
hidden.put("RECTIFYDESCR", json.getString("RECTIFYDESCR")); //整改描述
hidden.put("RECTIFICATIONDEPT", json.getString("RECTIFICATIONDEPT")); //整改部门
hidden.put("RECTIFICATIONOR", json.getString("RECTIFICATIONOR")); //整改人
hidden.put("CREATOR", pd.getString("CREATOR")); //发现人（隐患责任人）
hidden.put("SOURCE", json.getString("SOURCE")); //隐患来源
hidden.put("STATE", "1"); //隐患状态 100-安全环保检查暂存的隐患（流程完转0）
hidden.put("CREATTIME", time); //发现时间
hidden.put("CORPINFO_ID", pd.getString("CORPINFO_ID")); //企业ID
hidden.put("ISDELETE", "0"); //是否删除(0:有效 1：删除)
hidden.put("POSITIONDESC",json.getString("POSITIONDESC"));// 隐患位置描述
keyprojectHiddenService.save(hidden);
hiddenList.add(hidden);
time = DateUtil.calculateDateSecond(time, 1);
}
pd.put("hiddenList", hiddenList);
}
try {
//这里发送短信 通知 先判断重点工程是否要求发短信, 不发直接过，发的话 找到对应人以及对应手机号 发送对应模板短信啊
PageData outSource = new PageData();
outSource.put("OUTSOURCED_ID",pd.getString("OUTSOURCED_ID"));
outSource = outsourcedService.findById(outSource);
if(StringUtils.isNotBlank(outSource.getString("IS_SMS"))&&StringUtils.equals("0",outSource.getString("IS_SMS"))){
//发送短信 pd中 PERSONNELMANAGEMENT_ID 对应 `qa-gwj-regulatory`.`BUS_PERSONNELMANAGEMENT` 表中 PERSONNELMANAGEMENT_ID 获取到 PHONENUM 手机号字段 发送短信
PageData person = new PageData();
person.put("PERSONNELMANAGEMENT_ID",pd.getString("PERSONNELMANAGEMENT_ID"));
person = personnelmanagementService.findById(person);
// outSource.get("OUTSOURCED_NAME")
JSONArray jsonArray = new JSONArray();
//接受返回结果
JSONObject records = new JSONObject();
//定义替换参数
JSONObject tpContent = new JSONObject();
tpContent.put("OUTSOURCEDNAME",outSource.getString("OUTSOURCED_NAME"));
records = SendSmsUtil.getRecords(person.getString("PHONENUM"),tpContent);
jsonArray.add(records);
SendSmsUtil.sendSms("121451",jsonArray,null);
调整处罚短信接口逻辑
2023-11-16 17:20:16 +08:00
//发送罚款待处理 上文开关控制这里发送不
if(boo){
List<JSONObject> jsonList = (List<JSONObject>) JSON.parse(pd.getString("HIDDENJSON"));
String PUNISHTHEPERSON = keyprojectHiddenService.getPUNISHTHEPERSON(pd);
if (!Tools.isEmpty(PUNISHTHEPERSON)) {
PageData selectPageData = new PageData();
String[] split = PUNISHTHEPERSON.split(",");
selectPageData.put("ids", split);
List<String> list = keyprojectHiddenService.getPhone(selectPageData);
for (JSONObject json : jsonList) {
for(String phone:list) {
JSONArray jsonBrray = new JSONArray();
//接受返回结果
JSONObject recordsB = new JSONObject();
//定义替换参数
JSONObject tpContentB = new JSONObject();
tpContentB.put("HIDDENDESCR",json.getString("HIDDENDESCR")); //隐患描述
if(StringUtils.isNotBlank(phone)){
recordsB = SendSmsUtil.getRecords(phone,tpContentB);
jsonBrray.add(recordsB);
SendSmsUtil.sendSms("121487",jsonBrray,null);
}
}
}
}
}
初始化
2023-11-07 09:32:12 +08:00
}
}catch (Exception e){
e.printStackTrace();
}finally {
map.put("pd", pd);
map.put("result", errInfo);
}
return map;
}
/**删除
初始化
2023-11-08 08:53:50 +08:00
* @param
初始化
2023-11-07 09:32:12 +08:00
* @throws Exception
*/
@RequestMapping(value="/delete")
@ResponseBody
public Object delete() throws Exception{
Map<String,String> map = new HashMap<String,String>();
String errInfo = "success";
PageData pd = new PageData();
pd = this.getPageData();
keyprojectcheckService.delete(pd);
map.put("result", errInfo); //返回结果
return map;
}
/**修改
* @param
* @throws Exception
*/
@RequestMapping(value="/edit")
@ResponseBody
public Object edit() throws Exception{
Map<String,Object> map = new HashMap<String,Object>();
String errInfo = "success";
PageData pd = new PageData();
pd = this.getPageData();
keyprojectcheckService.edit(pd);
map.put("result", errInfo);
return map;
}
/**列表
* @param page
* @throws Exception
*/
@RequestMapping(value="/list")
@ResponseBody
public Object list(Page page) throws Exception{
Map<String,Object> map = new HashMap<String,Object>();
String errInfo = "success";
PageData pd = new PageData();
pd = this.getPageData();
String KEYWORDS = pd.getString("KEYWORDS"); //关键词检索条件
if(Tools.notEmpty(KEYWORDS))pd.put("KEYWORDS", KEYWORDS.trim());
page.setPd(pd);
List<PageData> varList = keyprojectcheckService.list(page); //列出KeyprojectCheck列表
map.put("varList", varList);
map.put("page", page);
map.put("result", errInfo);
return map;
}
/**去修改页面获取数据
* @param
* @throws Exception
*/
@RequestMapping(value="/goEdit")
@ResponseBody
public Object goEdit() throws Exception{
Map<String,Object> map = new HashMap<String,Object>();
String errInfo = "success";
PageData pd = new PageData();
pd = this.getPageData();
pd = keyprojectcheckService.findById(pd); //根据ID读取
List<PageData> situationList = keyprojectcheckInfoService.listAll(pd);
pd.put("FOREIGN_ID", pd.getString("KEYPROJECTCHECK_ID"));
pd.put("hiddenList", keyprojectHiddenService.listAllInspection(pd));
pd.put("situationList", situationList);
map.put("pd", pd);
map.put("result", errInfo);
return map;
}
/**去隐患页面获取数据
* @param
* @throws Exception
*/
@RequestMapping(value="/listHidden")
@ResponseBody
public Object listHidden(Page page) throws Exception{
Map<String,Object> map = new HashMap<String,Object>();
String errInfo = "success";
PageData pd = new PageData();
pd = this.getPageData();
String KEYWORDS = pd.getString("KEYWORDS"); //关键词检索条件
if(Tools.notEmpty(KEYWORDS))pd.put("KEYWORDS", KEYWORDS.trim());
page.setPd(pd);
List<PageData> varList = keyprojectHiddenService.list(page); //列出KeyprojectCheck列表
map.put("varList", varList);
map.put("page", page);
map.put("result", errInfo);
return map;
}
/**去隐患页面获取数据
* @param
* @throws Exception
*/
@RequestMapping(value="/findHidden")
@ResponseBody
public Object findHidden() throws Exception{
Map<String,Object> map = new HashMap<String,Object>();
String errInfo = "success";
PageData pd = new PageData();
pd = this.getPageData();
pd = keyprojectHiddenService.findById(pd); //根据ID读取
PageData pd2 = new PageData();
pd2.put("FOREIGN_KEY",pd.getString("HIDDEN_ID"));
pd2.put("TYPE",3); //隐患图片
pd.put("hiddenImgs", imgFilesService.listAll(pd2));
if(imgFilesService.listAll(pd2).size()==0){
pd2.put("TYPE",114); //AI隐患图片
pd.put("hiddenImgs", imgFilesService.listAll(pd2));
}
pd2.put("TYPE",102); //隐患视频
pd.put("hiddenVideos", imgFilesService.listAll(pd2));
pd2.put("TYPE",4);
pd.put("zgImgs", imgFilesService.listAll(pd2));//整改图片
pd2.put("TYPE",5);
pd.put("ysImgs", imgFilesService.listAll(pd2));//整改图片
初始化
2023-11-08 08:53:50 +08:00
PageData findTicketData = new PageData();
findTicketData.put("HIDDEN_ID",pd.getString("HIDDEN_ID"));
pd.put("punishForm",keyprojectpunishService.findById(findTicketData));
初始化
2023-11-07 09:32:12 +08:00
map.put("pd", pd);
map.put("result", errInfo);
return map;
}
/**验收
* @param
* @throws Exception
*/
@RequestMapping(value="/check")
@ResponseBody
@Transactional
public Object check() throws Exception{
Map<String,Object> map = new HashMap<String,Object>();
String errInfo = "success";
PageData pd = new PageData();
pd = this.getPageData();
pd.put("STATE", 4);
keyprojectHiddenService.editstate(pd);
map.put("result", errInfo);
return map;
}
/**修改处罚状态
* @param
* @throws Exception
*/
@RequestMapping(value="/editHiddenIspunish")
@ResponseBody
@Transactional
public Object editHiddenIspunish() throws Exception{
Map<String,Object> map = new HashMap<String,Object>();
String errInfo = "success";
PageData pd = new PageData();
pd = this.getPageData();
keyprojectHiddenService.editstate(pd);
map.put("result", errInfo);
return map;
}
/**批量删除
* @param
* @throws Exception
*/
@RequestMapping(value="/deleteAll")
@ResponseBody
public Object deleteAll() throws Exception{
Map<String,Object> map = new HashMap<String,Object>();
String errInfo = "success";
PageData pd = new PageData();
pd = this.getPageData();
String DATA_IDS = pd.getString("DATA_IDS");
if(Tools.notEmpty(DATA_IDS)){
String ArrayDATA_IDS[] = DATA_IDS.split(",");
keyprojectcheckService.deleteAll(ArrayDATA_IDS);
errInfo = "success";
}else{
errInfo = "fail";
}
map.put("result", errInfo); //返回结果
return map;
}
/**去隐患页面获取数据
* @param
* @throws Exception
*/
@RequestMapping(value="/keyProjectCount")
@ResponseBody
public Object keyProjectCount() throws Exception{
Map<String,Object> map = new HashMap<String,Object>();
String errInfo = "success";
PageData pd = new PageData();
pd = this.getPageData();
String UserId = pd.getString("UserId");
if(!StringUtils.equals("1",UserId)){
String CORPINFO_ID = pd.getString("CORPINFO_ID");
if(!StringUtils.equals(CORPINFO_ID,"1e6dbbe16004402f8d2c0e52afd9a676")&&!StringUtils.equals(CORPINFO_ID,"3a854eefa7894e06aaa1a2611bca80f6")&&
!StringUtils.equals(CORPINFO_ID,"020578a4c1f04bc692ee25145c2efbe5")&&!StringUtils.equals(CORPINFO_ID,"90966974de3c4b83aca6f8fd6432d5c2")){
pd.put("DeptId",outsourcedService.getDeptId(UserId));
}
}
pd = keyprojectHiddenService.keyprojectcount(pd); //根据ID读取
map.put("pd", pd);
map.put("result", errInfo);
return map;
}
初始化
2023-11-08 08:53:50 +08:00
/**重点工程处罚列表 包含 未选择处罚结果的隐患 已下发处罚但为反馈的隐患 不处罚的隐患
* @param page
* @throws Exception
*/
@RequestMapping(value="/punishlist")
@ResponseBody
public Object punishlist(Page page) throws Exception{
Map<String,Object> map = new HashMap<String,Object>();
String errInfo = "success";
PageData pd = new PageData();
pd = this.getPageData();
String KEYWORDS = pd.getString("KEYWORDS"); //关键词检索条件
if(Tools.notEmpty(KEYWORDS))pd.put("KEYWORDS", KEYWORDS.trim());
page.setPd(pd);
List<PageData> varList = keyprojectHiddenService.getpunishlist(page); //列出KeyprojectCheck列表
map.put("varList", varList);
map.put("page", page);
map.put("result", errInfo);
return map;
}
初始化
2023-11-07 09:32:12 +08:00
}