1746 lines
74 KiB
Java
1746 lines
74 KiB
Java
package com.zcloud.controller.gf;
|
||
|
||
import com.alibaba.fastjson.JSON;
|
||
import com.alibaba.fastjson.JSONObject;
|
||
import com.zcloud.controller.base.BaseController;
|
||
import com.zcloud.dto.TenCorpConst;
|
||
import com.zcloud.dto.TenCorpDto;
|
||
import com.zcloud.entity.Page;
|
||
import com.zcloud.entity.PageData;
|
||
import com.zcloud.service.bus.NoticeCorpService;
|
||
import com.zcloud.service.gf.*;
|
||
import com.zcloud.service.mq.SendMessageService;
|
||
import com.zcloud.util.*;
|
||
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.*;
|
||
import org.springframework.web.multipart.MultipartFile;
|
||
import org.springframework.web.multipart.MultipartRequest;
|
||
|
||
import javax.annotation.Resource;
|
||
import java.text.DecimalFormat;
|
||
import java.text.ParseException;
|
||
import java.text.SimpleDateFormat;
|
||
import java.util.*;
|
||
|
||
/**
|
||
* 说明：高空作业
|
||
* 作者：luoxiaobao
|
||
* 时间：2021-08-31
|
||
* 官网：www.zcloudchina.com
|
||
*/
|
||
@Controller
|
||
@RequestMapping("/app/gfConfinedSpace")
|
||
public class AppGFConfinedSpaceController extends BaseController {
|
||
|
||
@Resource
|
||
private GFConfinedSpaceService GFconfinedspaceService;
|
||
@Resource
|
||
private GFConfinedSpaceLogService GFconfinedspaceLogService;
|
||
@Resource
|
||
private GFConfinedSpaceToMeasuresService GFconfinedspaceToMeasuresService;
|
||
@Resource
|
||
private GFConfinedSpaceGasService GFconfinedspaceGasService;
|
||
@Autowired
|
||
private GFConfinedSpaceAcceptUserService confinedspaceacceptuserService;
|
||
@Autowired
|
||
private GFConfinedSpaceGasWHService confinedspacegaswhService;
|
||
@Autowired
|
||
private SendMessageUtil sendMessageUtil;
|
||
@Autowired
|
||
private Smb smb;
|
||
|
||
@Resource
|
||
private SendMessageService mqClient;
|
||
@Autowired
|
||
private NoticeCorpService noticeCorpService;
|
||
/**获取编码
|
||
* @param
|
||
* @throws Exception
|
||
*/
|
||
@RequestMapping(value="/getCode")
|
||
@ResponseBody
|
||
public Object getCode() throws Exception{
|
||
Map<String,Object> map = new HashMap<String,Object>();
|
||
String errInfo = "success";
|
||
PageData pd = new PageData();
|
||
pd = this.getPageData();
|
||
Calendar calendar = Calendar.getInstance();
|
||
DecimalFormat dft=new DecimalFormat("00");
|
||
int year = calendar.get(Calendar.YEAR);
|
||
String month = dft.format(calendar.get(Calendar.MONTH) + 1);
|
||
String day = dft.format(calendar.get(Calendar.DAY_OF_MONTH));
|
||
pd.put("CREATDATE",year + "-" + month + "-" + day);
|
||
pd = GFconfinedspaceService.getCode(pd); //根据ID读取
|
||
String code = "YX"+year + month + day + dft.format((Integer.parseInt(pd.get("code").toString())+1));
|
||
map.put("code", code);
|
||
map.put("result", errInfo);
|
||
return map;
|
||
}
|
||
|
||
/**新增
|
||
* @param
|
||
* @throws Exception
|
||
*/
|
||
@RequestMapping(value="/add")
|
||
@ResponseBody
|
||
@Transactional
|
||
public Object add() throws Exception{
|
||
Map<String,Object> map = new HashMap<String,Object>();
|
||
String errInfo = "success";
|
||
PageData pd = new PageData();
|
||
pd = this.getPageData();
|
||
PageData pd2 = new PageData();
|
||
Calendar calendar = Calendar.getInstance();
|
||
DecimalFormat dft=new DecimalFormat("00");
|
||
int year = calendar.get(Calendar.YEAR);
|
||
String month = dft.format(calendar.get(Calendar.MONTH) + 1);
|
||
String day = dft.format(calendar.get(Calendar.DAY_OF_MONTH));
|
||
pd2.put("CREATDATE",year + "-" + month + "-" + day);
|
||
pd2.put("CORPINFO_ID",pd.get("CORPINFO_ID"));
|
||
pd2 = GFconfinedspaceService.getCode(pd2); //根据ID读取
|
||
String code = "YX"+year + month + day + dft.format((Integer.parseInt(pd2.get("code").toString())+1));
|
||
pd = this.getPageData();
|
||
pd.put("CHECK_NO", code);
|
||
pd.put("CONFINEDSPACE_ID", this.get32UUID()); //主键
|
||
pd.put("CREATTIME", DateUtil.date2Str(new Date())); //添加时间
|
||
pd.put("OPERATTIME", DateUtil.date2Str(new Date())); //修改时间
|
||
pd.put("ISDELETE", "0"); //是否删除 1-是 0-否
|
||
GFconfinedspaceService.save(pd);
|
||
|
||
if(pd.get("APPLY_STATUS").equals("1")) {
|
||
PageData log = new PageData();
|
||
log.put("CONFINEDSPACELOG_ID", this.get32UUID());
|
||
log.put("ACTION", "提交申请");
|
||
log.put("CONFINEDSPACE_ID", pd.get("CONFINEDSPACE_ID"));
|
||
log.put("CREATOR",pd.get("ACTION_USER"));
|
||
log.put("CREATTIME", DateUtil.date2Str(new Date()));
|
||
GFconfinedspaceLogService.save(log);
|
||
|
||
// 发短信
|
||
PageData mes = new PageData();
|
||
mes.put("RECEIVER_ID", pd.get("CONFIRM_USER_ID"));// 收信人userid
|
||
mes.put("templateCode", "YX_Y01");// 短信模板编码
|
||
mes.put("SMSCode", "SMS_227245922");// 短信模板编码
|
||
mes.put("CORPINFO_ID", pd.get("CORPINFO_ID"));// 企业id
|
||
// 参数集合
|
||
List<PageData> paramsList = new ArrayList<PageData>();
|
||
// 第1个参数
|
||
PageData params1 = new PageData();
|
||
params1.put("name", "number");// 存入短信模板中的参数名称
|
||
params1.put("value", pd.get("CHECK_NO"));// 存入上面参数名称所传递的值
|
||
paramsList.add(params1);
|
||
// 第2个参数
|
||
PageData params2 = new PageData();
|
||
params2.put("name", "params1");// 存入短信模板中的参数名称
|
||
params2.put("value", "有限空间作业");// 存入上面参数名称所传递的值
|
||
paramsList.add(params2);
|
||
// 第3个参数
|
||
PageData params3 = new PageData();
|
||
params3.put("name", "params2");// 存入短信模板中的参数名称
|
||
params3.put("value", "作业单位确认");// 存入上面参数名称所传递的值
|
||
paramsList.add(params3);
|
||
// 第4个参数
|
||
PageData params4 = new PageData();
|
||
params4.put("name", "params3");// 存入短信模板中的参数名称
|
||
params4.put("value", "确认");// 存入上面参数名称所传递的值
|
||
paramsList.add(params4);
|
||
sendMessageUtil.sendMessages(mes, paramsList);
|
||
// 发短信
|
||
|
||
PageData mes1 = new PageData();
|
||
mes1.put("RECEIVER_ID", pd.get("ANALYZE_USER_ID"));// 收信人userid
|
||
mes1.put("templateCode", "YX_QT");// 短信模板编码
|
||
mes1.put("SMSCode", "SMS_223540753");// 短信模板编码
|
||
mes1.put("CORPINFO_ID", pd.get("CORPINFO_ID"));// 企业id
|
||
// 参数集合
|
||
List<PageData> paramsList1 = new ArrayList<PageData>();
|
||
// 第1个参数
|
||
PageData params5 = new PageData();
|
||
params5.put("name", "params1");// 存入短信模板中的参数名称
|
||
params5.put("value", pd.get("CHECK_NO"));// 存入上面参数名称所传递的值
|
||
paramsList1.add(params5);
|
||
// 第2个参数
|
||
PageData params6 = new PageData();
|
||
params6.put("name", "params2");// 存入短信模板中的参数名称
|
||
params6.put("value", "有限空间作业");// 存入上面参数名称所传递的值
|
||
paramsList1.add(params6);
|
||
sendMessageUtil.sendMessages(mes1, paramsList1);
|
||
}
|
||
TenCorpDto tenCorpDto = new TenCorpDto();
|
||
tenCorpDto.setTopic("eightWork");
|
||
tenCorpDto.setMark(pd.getString("CONFINEDSPACE_ID"));
|
||
tenCorpDto.setMessage(TenCorpConst.confinedSpace);
|
||
tenCorpDto.setTime_stamp(pd.getString("WORK_START_DATE") + ":00:000");
|
||
tenCorpDto.setData(pd);
|
||
tenCorpDto.setMark_name("CONFINEDSPACE_ID");
|
||
mqClient.SendDelayQueue(tenCorpDto);
|
||
this.sendNotice(pd);
|
||
map.put("result", errInfo);
|
||
return map;
|
||
}
|
||
|
||
/**
|
||
* 发送通知公告
|
||
* @param pageData
|
||
*/
|
||
public void sendNotice(PageData pageData) {
|
||
try{
|
||
PageData confinedspace = GFconfinedspaceService.findById(pageData);
|
||
String confinedspaceState = confinedspace.getString("APPLY_STATUS"); //状态
|
||
if(confinedspace != null){
|
||
if(confinedspaceState.equals("1")){ //作业负责人待审核
|
||
PageData mes = new PageData();
|
||
mes.put("BIANMA","PROCESS_WORK_001");
|
||
mes.put("SENDER_ID", "系统管理员"); // 发送人员ID
|
||
mes.put("SENDER_NAME", "1"); // 发送人员姓名
|
||
mes.put("SYNOPSIS", "友情提示：有一条受限空间作业待确认"); // 站内信标题
|
||
mes.put("CORPINFO_ID", confinedspace.get("CORPINFO_ID"));// 企业id
|
||
mes.put("RECEIVER_ID", confinedspace.get("CONFIRM_USER_ID")); // 接收人员ID
|
||
PageData content = new PageData();
|
||
content.put("number", confinedspace.getString("CHECK_NO"));// 作业编号
|
||
content.put("params1", "受限空间申请作业"); // 作业名称
|
||
content.put("params2", "作业负责人确认");
|
||
content.put("params3", "确认");// 作业操作
|
||
mes.put("CONTENT", content);// 站内信内容
|
||
noticeCorpService.sendNotice(mes);
|
||
//受限空间气体分析发站内信
|
||
mes.put("BIANMA","PROCESS_WORK_001");
|
||
mes.put("SENDER_ID", "系统管理员"); // 发送人员ID
|
||
mes.put("SENDER_NAME", "1"); // 发送人员姓名
|
||
mes.put("SYNOPSIS", "友情提示：有一条受限空间作业待进行气体分析"); // 站内信标题
|
||
mes.put("CORPINFO_ID", confinedspace.get("CORPINFO_ID"));// 企业id
|
||
mes.put("RECEIVER_ID", confinedspace.get("ANALYZE_USER_ID")); // 接收人员ID
|
||
content.put("number", confinedspace.getString("CHECK_NO"));// 作业编号
|
||
content.put("params1", "受限空间申请作业"); // 作业名称
|
||
content.put("params2", "气体分析");
|
||
content.put("params3", "进行气体分析");// 作业操作
|
||
mes.put("CONTENT", content);// 站内信内容
|
||
noticeCorpService.sendNotice(mes);
|
||
//受限空间安全交底人发站内信
|
||
mes.put("BIANMA","PROCESS_WORK_001");
|
||
mes.put("SENDER_ID", "系统管理员"); // 发送人员ID
|
||
mes.put("SENDER_NAME", "1"); // 发送人员姓名
|
||
mes.put("SYNOPSIS", "友情提示：有一条受限空间作业待签字"); // 站内信标题
|
||
mes.put("CORPINFO_ID", confinedspace.get("CORPINFO_ID"));// 企业id
|
||
mes.put("RECEIVER_ID", confinedspace.get("CONFESS_USER_ID")); // 接收人员ID
|
||
content.put("number", confinedspace.getString("CHECK_NO"));// 作业编号
|
||
content.put("params1", "受限空间申请作业"); // 作业名称
|
||
content.put("params2", "安全交底人签字");
|
||
content.put("params3", "签字");// 作业操作
|
||
mes.put("CONTENT", content);// 站内信内容
|
||
noticeCorpService.sendNotice(mes);
|
||
//受限空间接收交底人发站内信
|
||
mes.put("BIANMA","PROCESS_WORK_001");
|
||
mes.put("SENDER_ID", "系统管理员"); // 发送人员ID
|
||
mes.put("SENDER_NAME", "1"); // 发送人员姓名
|
||
mes.put("SYNOPSIS", "友情提示：有一条受限空间作业待签字"); // 站内信标题
|
||
mes.put("CORPINFO_ID", confinedspace.get("CORPINFO_ID"));// 企业id
|
||
mes.put("RECEIVER_ID", confinedspace.get("ACCEPT_CONFESS_USER_ID")); // 接收人员ID
|
||
content.put("number", confinedspace.getString("CHECK_NO"));// 作业编号
|
||
content.put("params1", "受限空间申请作业"); // 作业名称
|
||
content.put("params2", "接受交底人签字");
|
||
content.put("params3", "签字");// 作业操作
|
||
mes.put("CONTENT", content);// 站内信内容
|
||
noticeCorpService.sendNotice(mes);
|
||
} else if(confinedspaceState.equals("4")){ //所在单位待审核
|
||
PageData mes = new PageData();
|
||
mes.put("BIANMA","PROCESS_WORK_001");
|
||
mes.put("SENDER_ID", "系统管理员"); // 发送人员ID
|
||
mes.put("SENDER_NAME", "1"); // 发送人员姓名
|
||
mes.put("SYNOPSIS", "友情提示：有一条受限空间作业待审核"); // 站内信标题
|
||
mes.put("CORPINFO_ID", confinedspace.get("CORPINFO_ID"));// 企业id
|
||
mes.put("RECEIVER_ID", confinedspace.get("APPROVE_USER_ID")); // 接收人员ID
|
||
PageData content = new PageData();
|
||
content.put("number", confinedspace.getString("CHECK_NO"));// 作业编号
|
||
content.put("params1", "有限空间申请作业"); // 作业名称
|
||
content.put("params2", "所在单位待审核");
|
||
content.put("params3", "审核");// 作业操作
|
||
mes.put("CONTENT", content);// 站内信内容
|
||
noticeCorpService.sendNotice(mes);
|
||
} else if(confinedspaceState.equals("5")){ //待验收
|
||
if (confinedspace.get("GUARDIAN_USER_SIGNER_PATH") == null) {
|
||
PageData mes = new PageData();
|
||
mes.put("BIANMA","PROCESS_WORK_001");
|
||
mes.put("SENDER_ID", "系统管理员"); // 发送人员ID
|
||
mes.put("SENDER_NAME", "1"); // 发送人员姓名
|
||
mes.put("SYNOPSIS", "友情提示：有一条有限空间作业待验收"); // 站内信标题
|
||
mes.put("CORPINFO_ID", confinedspace.get("CORPINFO_ID"));// 企业id
|
||
mes.put("RECEIVER_ID", confinedspace.get("ACCEPT_USER_ID")); // 接收人员ID
|
||
PageData content = new PageData();
|
||
content.put("number", confinedspace.getString("CHECK_NO"));// 作业编号
|
||
content.put("params1", "有限空间申请作业"); // 作业名称
|
||
content.put("params2", "作业待验收");
|
||
content.put("params3", "验收");// 作业操作
|
||
mes.put("CONTENT", content);// 站内信内容
|
||
noticeCorpService.sendNotice(mes);
|
||
//受限空间监护人发站内信
|
||
mes.put("BIANMA","PROCESS_WORK_001");
|
||
mes.put("SENDER_ID", "系统管理员"); // 发送人员ID
|
||
mes.put("SENDER_NAME", "1"); // 发送人员姓名
|
||
mes.put("SYNOPSIS", "友情提示：有一条受限空间作业待签字"); // 站内信标题
|
||
mes.put("CORPINFO_ID", confinedspace.get("CORPINFO_ID"));// 企业id
|
||
mes.put("RECEIVER_ID", confinedspace.get("GUARDIAN_USER_ID")); // 接收人员ID
|
||
content.put("number", confinedspace.getString("CHECK_NO"));// 作业编号
|
||
content.put("params1", "受限空间申请作业"); // 作业名称
|
||
content.put("params2", "监护人签字");
|
||
content.put("params3", "签字");// 作业操作
|
||
mes.put("CONTENT", content);// 站内信内容
|
||
noticeCorpService.sendNotice(mes);
|
||
}
|
||
}
|
||
}
|
||
|
||
if(confinedspaceState.equals("-4")){ //作业负责人审核打回发站内信
|
||
PageData mes = new PageData();
|
||
mes.put("BIANMA","PROCESS_WORK_001");
|
||
mes.put("SENDER_ID", "系统管理员"); // 发送人员ID
|
||
mes.put("SENDER_NAME", "1"); // 发送人员姓名
|
||
mes.put("SYNOPSIS", "友情提示：有一条受限空间作业打回待处理"); // 站内信标题
|
||
mes.put("CORPINFO_ID", confinedspace.get("CORPINFO_ID"));// 企业id
|
||
mes.put("RECEIVER_ID", confinedspace.getString("CREATOR")); // 接收人员ID
|
||
PageData content = new PageData();
|
||
content.put("number", confinedspace.getString("CHECK_NO"));// 作业编号
|
||
content.put("params1", "受限空间申请作业"); // 作业名称
|
||
content.put("params2", "受限空间申请管理");
|
||
content.put("params3", "处理");// 作业操作
|
||
mes.put("CONTENT", content);// 站内信内容
|
||
noticeCorpService.sendNotice(mes);
|
||
} else if(confinedspaceState.equals("-5")){ //所在单位审核打回
|
||
PageData mes = new PageData();
|
||
mes.put("BIANMA","PROCESS_WORK_001");
|
||
mes.put("SENDER_ID", "系统管理员"); // 发送人员ID
|
||
mes.put("SENDER_NAME", "1"); // 发送人员姓名
|
||
mes.put("SYNOPSIS", "友情提示：有一条受限空间作业打回待处理"); // 站内信标题
|
||
mes.put("CORPINFO_ID", confinedspace.get("CORPINFO_ID"));// 企业id
|
||
mes.put("RECEIVER_ID", confinedspace.getString("CREATOR")); // 接收人员ID
|
||
PageData content = new PageData();
|
||
content.put("number", confinedspace.getString("CHECK_NO"));// 作业编号
|
||
content.put("params1", "受限空间申请作业"); // 作业名称
|
||
content.put("params2", "受限空间申请管理");
|
||
content.put("params3", "处理");// 作业操作
|
||
mes.put("CONTENT", content);// 站内信内容
|
||
noticeCorpService.sendNotice(mes);
|
||
} else if (confinedspaceState.equals("-6")) {
|
||
PageData mes = new PageData();
|
||
mes.put("BIANMA","PROCESS_WORK_001");
|
||
mes.put("SENDER_ID", "系统管理员"); // 发送人员ID
|
||
mes.put("SENDER_NAME", "1"); // 发送人员姓名
|
||
mes.put("SYNOPSIS", "友情提示：有一条受限空间作业打回待处理"); // 站内信标题
|
||
mes.put("CORPINFO_ID", confinedspace.get("CORPINFO_ID"));// 企业id
|
||
mes.put("RECEIVER_ID", confinedspace.getString("CREATOR")); // 接收人员ID
|
||
PageData content = new PageData();
|
||
content.put("number", confinedspace.getString("CHECK_NO"));// 作业编号
|
||
content.put("params1", "受限空间申请作业"); // 作业名称
|
||
content.put("params2", "受限空间申请管理");
|
||
content.put("params3", "处理");// 作业操作
|
||
mes.put("CONTENT", content);// 站内信内容
|
||
noticeCorpService.sendNotice(mes);
|
||
}
|
||
}catch (Exception e){
|
||
// FHLOG.save("动火审批", "发送站内信失败！");
|
||
|
||
}
|
||
|
||
|
||
}
|
||
|
||
/**删除
|
||
* @param
|
||
* @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();
|
||
GFconfinedspaceService.delete(pd);
|
||
map.put("result", errInfo); //返回结果
|
||
return map;
|
||
}
|
||
|
||
|
||
/**作废
|
||
* @param
|
||
* @throws Exception
|
||
*/
|
||
@PostMapping(value="/cancel")
|
||
@ResponseBody
|
||
public void cancel(@RequestBody PageData pd) throws Exception{
|
||
Map<String,String> map = new HashMap<String,String>();
|
||
String errInfo = "success";
|
||
System.out.println(JSONObject.toJSONString(pd));
|
||
PageData cpd = new PageData();
|
||
cpd = GFconfinedspaceService.findById(pd);
|
||
if(cpd!=null && cpd.size()>0 && cpd.getString("ANALYZE_TIME") != null && cpd.getString("GUARDIAN_USER_SIGNER_TIME") != null){
|
||
// String WORK_START_DATE = pd.getString("WORK_START_DATE");
|
||
// String ANALYZE_TIME = cpd.getString("ANALYZE_TIME");
|
||
// String GUARDIAN_USER_SIGNER_TIME = cpd.getString("GUARDIAN_USER_SIGNER_TIME");
|
||
// SimpleDateFormat format = new SimpleDateFormat("yyyy-MM-dd HH:mm");
|
||
// System.out.println(WORK_START_DATE);
|
||
// System.out.println(ANALYZE_TIME);
|
||
// System.out.println("-------------123----------");
|
||
// try {
|
||
// Date date1 = format.parse(WORK_START_DATE);
|
||
// Date date2 = format.parse(ANALYZE_TIME);
|
||
// Date date3 = format.parse(GUARDIAN_USER_SIGNER_TIME);
|
||
// long workTime = date1.getTime();
|
||
// long analyzeTime = date2.getTime();
|
||
// long signtime = date3.getTime();
|
||
// System.out.println(workTime - analyzeTime);
|
||
// System.out.println(analyzeTime - workTime);
|
||
// if (workTime - analyzeTime >= 0 && workTime - signtime >= 0) {
|
||
return;
|
||
// } else {
|
||
// pd.put("APPLY_STATUS",-99);
|
||
// confinedspaceService.cancel(pd);
|
||
// // 发短信
|
||
// PageData mes = new PageData();
|
||
// mes.put("RECEIVER_ID", pd.get("CONFIRM_USER_ID"));// 收信人userid
|
||
// mes.put("templateCode", "YX_ZF");// 短信模板编码
|
||
// mes.put("SMSCode", "SMS_462060039");// 短信模板编码
|
||
// mes.put("CORPINFO_ID", pd.get("CORPINFO_ID"));// 企业id
|
||
// // 参数集合
|
||
// List<PageData> paramsList = new ArrayList<PageData>();
|
||
// // 第1个参数
|
||
// PageData params1 = new PageData();
|
||
// params1.put("name", "number");// 存入短信模板中的参数名称
|
||
// params1.put("value", pd.get("CHECK_NO"));// 存入上面参数名称所传递的值
|
||
// paramsList.add(params1);
|
||
// // 第2个参数
|
||
// PageData params2 = new PageData();
|
||
// params2.put("name", "params1");// 存入短信模板中的参数名称
|
||
// params2.put("value", "有限空间作业");// 存入上面参数名称所传递的值
|
||
// paramsList.add(params2);
|
||
// sendMessageUtil.sendMessages(mes, paramsList);
|
||
// }
|
||
// } catch (ParseException e) {
|
||
// e.printStackTrace();
|
||
// }
|
||
}else if (cpd!=null && cpd.size()>0 && cpd.getString("ANALYZE_TIME") == null){
|
||
pd.put("APPLY_STATUS",-98);
|
||
GFconfinedspaceService.cancel(pd);
|
||
PageData pd2 = new PageData();
|
||
pd2 = GFconfinedspaceService.checkno(pd);
|
||
PageData pd3 = new PageData();
|
||
pd3.put("CHECK_NO",pd2.getString("CHECK_NO"));
|
||
pd3.put("CORPINFO_ID",pd.getString("CORPINFO_ID"));
|
||
GFconfinedspaceService.editSpecialwork(pd3);
|
||
GFconfinedspaceService.editSpecialwork1(pd3);
|
||
GFconfinedspaceService.editSpecialwork2(pd3);
|
||
GFconfinedspaceService.editSpecialwork3(pd3);
|
||
GFconfinedspaceService.editSpecialwork4(pd3);
|
||
GFconfinedspaceService.editSpecialwork5(pd3);
|
||
GFconfinedspaceService.editSpecialwork6(pd3);
|
||
GFconfinedspaceService.editSpecialwork7(pd3);
|
||
PageData mes = new PageData();
|
||
mes.put("RECEIVER_ID", pd.get("CONFIRM_USER_ID"));// 收信人userid
|
||
mes.put("templateCode", "YX_ZF1");// 短信模板编码
|
||
mes.put("SMSCode", "SMS_462060039");// 短信模板编码
|
||
mes.put("CORPINFO_ID", pd.get("CORPINFO_ID"));// 企业id
|
||
// 参数集合
|
||
List<PageData> paramsList = new ArrayList<PageData>();
|
||
// 第1个参数
|
||
PageData params1 = new PageData();
|
||
params1.put("name", "number");// 存入短信模板中的参数名称
|
||
params1.put("value", pd.get("CHECK_NO"));// 存入上面参数名称所传递的值
|
||
paramsList.add(params1);
|
||
// 第2个参数
|
||
PageData params2 = new PageData();
|
||
params2.put("name", "params1");// 存入短信模板中的参数名称
|
||
params2.put("value", "受限空间作业");// 存入上面参数名称所传递的值
|
||
paramsList.add(params2);
|
||
sendMessageUtil.sendMessages(mes, paramsList);
|
||
}else if (cpd!=null && cpd.size()>0 && cpd.getString("ANALYZE_TIME") != null && cpd.getString("GUARDIAN_USER_SIGNER_TIME") == null){
|
||
pd.put("APPLY_STATUS",-99);
|
||
GFconfinedspaceService.cancel(pd);
|
||
PageData pd2 = new PageData();
|
||
pd2 = GFconfinedspaceService.checkno(pd);
|
||
PageData pd3 = new PageData();
|
||
pd3.put("CHECK_NO",pd2.getString("CHECK_NO"));
|
||
pd3.put("CORPINFO_ID",pd.getString("CORPINFO_ID"));
|
||
GFconfinedspaceService.editSpecialwork(pd3);
|
||
GFconfinedspaceService.editSpecialwork1(pd3);
|
||
GFconfinedspaceService.editSpecialwork2(pd3);
|
||
GFconfinedspaceService.editSpecialwork3(pd3);
|
||
GFconfinedspaceService.editSpecialwork4(pd3);
|
||
GFconfinedspaceService.editSpecialwork5(pd3);
|
||
GFconfinedspaceService.editSpecialwork6(pd3);
|
||
GFconfinedspaceService.editSpecialwork7(pd3);
|
||
PageData mes = new PageData();
|
||
mes.put("RECEIVER_ID", pd.get("CONFIRM_USER_ID"));// 收信人userid
|
||
mes.put("templateCode", "YX_ZF2");// 短信模板编码
|
||
mes.put("SMSCode", "SMS_462060039");// 短信模板编码
|
||
mes.put("CORPINFO_ID", pd.get("CORPINFO_ID"));// 企业id
|
||
// 参数集合
|
||
List<PageData> paramsList = new ArrayList<PageData>();
|
||
// 第1个参数
|
||
PageData params1 = new PageData();
|
||
params1.put("name", "number");// 存入短信模板中的参数名称
|
||
params1.put("value", pd.get("CHECK_NO"));// 存入上面参数名称所传递的值
|
||
paramsList.add(params1);
|
||
// 第2个参数
|
||
PageData params2 = new PageData();
|
||
params2.put("name", "params1");// 存入短信模板中的参数名称
|
||
params2.put("value", "受限空间作业");// 存入上面参数名称所传递的值
|
||
paramsList.add(params2);
|
||
sendMessageUtil.sendMessages(mes, paramsList);
|
||
}
|
||
map.put("result", errInfo); //返回结果
|
||
return ;
|
||
}
|
||
|
||
|
||
/**修改
|
||
* @param
|
||
* @throws Exception
|
||
*/
|
||
@RequestMapping(value="/edit")
|
||
@ResponseBody
|
||
@Transactional
|
||
public Object edit() throws Exception{
|
||
Map<String,Object> map = new HashMap<String,Object>();
|
||
String errInfo = "success";
|
||
PageData pd = new PageData();
|
||
pd = this.getPageData();
|
||
GFconfinedspaceService.edit(pd);
|
||
if(pd.get("APPLY_STATUS").equals("1")) {
|
||
PageData log = new PageData();
|
||
log.put("CONFINEDSPACELOG_ID", this.get32UUID());
|
||
log.put("ACTION", "提交申请");
|
||
log.put("CONFINEDSPACE_ID", pd.get("CONFINEDSPACE_ID"));
|
||
log.put("CREATOR",pd.get("ACTION_USER"));
|
||
log.put("CREATTIME", DateUtil.date2Str(new Date()));
|
||
GFconfinedspaceLogService.save(log);
|
||
|
||
|
||
// 发短信
|
||
PageData mes = new PageData();
|
||
mes.put("RECEIVER_ID", pd.get("CONFIRM_USER_ID"));// 收信人userid
|
||
mes.put("templateCode", "YX_Y01");// 短信模板编码
|
||
mes.put("SMSCode", "SMS_227245922");// 短信模板编码
|
||
mes.put("CORPINFO_ID", pd.get("CORPINFO_ID"));// 企业id
|
||
// 参数集合
|
||
List<PageData> paramsList = new ArrayList<PageData>();
|
||
// 第1个参数
|
||
PageData params1 = new PageData();
|
||
params1.put("name", "number");// 存入短信模板中的参数名称
|
||
params1.put("value", pd.get("CHECK_NO"));// 存入上面参数名称所传递的值
|
||
paramsList.add(params1);
|
||
// 第2个参数
|
||
PageData params2 = new PageData();
|
||
params2.put("name", "params1");// 存入短信模板中的参数名称
|
||
params2.put("value", "有限空间作业");// 存入上面参数名称所传递的值
|
||
paramsList.add(params2);
|
||
// 第3个参数
|
||
PageData params3 = new PageData();
|
||
params3.put("name", "params2");// 存入短信模板中的参数名称
|
||
params3.put("value", "作业单位确认");// 存入上面参数名称所传递的值
|
||
paramsList.add(params3);
|
||
// 第4个参数
|
||
PageData params4 = new PageData();
|
||
params4.put("name", "params3");// 存入短信模板中的参数名称
|
||
params4.put("value", "确认");// 存入上面参数名称所传递的值
|
||
paramsList.add(params4);
|
||
sendMessageUtil.sendMessages(mes, paramsList);
|
||
}
|
||
TenCorpDto tenCorpDto = new TenCorpDto();
|
||
tenCorpDto.setTopic("eightWork");
|
||
tenCorpDto.setMark(pd.getString("CONFINEDSPACE_ID"));
|
||
tenCorpDto.setMessage(TenCorpConst.confinedSpace);
|
||
tenCorpDto.setTime_stamp(pd.getString("WORK_START_DATE") + ":00:000");
|
||
tenCorpDto.setData(pd);
|
||
tenCorpDto.setMark_name("CONFINEDSPACE_ID");
|
||
mqClient.SendDelayQueue(tenCorpDto);
|
||
map.put("result", errInfo);
|
||
return map;
|
||
}
|
||
|
||
/**修改
|
||
* @param
|
||
* @throws Exception
|
||
*/
|
||
@RequestMapping(value="/editGuardian")
|
||
@ResponseBody
|
||
@Transactional
|
||
public Object editGuardian(
|
||
@RequestParam(value="FFILE",required=false) MultipartFile[] files
|
||
) throws Exception{
|
||
Map<String,Object> map = new HashMap<String,Object>();
|
||
String errInfo = "success";
|
||
PageData pd = new PageData();
|
||
pd = this.getPageData();
|
||
PageData pd2 = new PageData();
|
||
pd2 = GFconfinedspaceService.findById(pd);
|
||
pd2.put("OPERATOR", pd.get("OPERATOR")); //修改人
|
||
pd2.put("OPERATTIME", DateUtil.date2Str(new Date())); //修改时间
|
||
if (files != null && files.length > 0) {
|
||
MultipartFile file = files[0];
|
||
|
||
String ffile = DateUtil.getDays();
|
||
String fileName = this.get32UUID()+file.getOriginalFilename().substring(file.getOriginalFilename().lastIndexOf("."));
|
||
smb.sshSftp(file, fileName, Const.FILEPATHFILE + pd.getString("CORPINFO_ID") + "/" + ffile);
|
||
|
||
pd2.put("GUARDIAN_USER_SIGNER_PATH", Const.FILEPATHFILE + pd.getString("CORPINFO_ID") + "/" + ffile + "/" + fileName);
|
||
pd2.put("GUARDIAN_USER_SIGNER_TIME", pd.get("SIGNER_TIME"));
|
||
// pd2.put("GUARDIAN_CONTENT", pd.get("CONTENT"));
|
||
// pd2.put("APPLY_STATUS", pd.get("APPLY_STATUS"));
|
||
GFconfinedspaceService.edit(pd2);
|
||
}
|
||
|
||
if(pd.get("APPLY_STATUS").equals("1")) {
|
||
PageData log = new PageData();
|
||
log.put("CONFINEDSPACELOG_ID", this.get32UUID());
|
||
log.put("ACTION", "提交申请");
|
||
log.put("CONFINEDSPACE_ID", pd.get("CONFINEDSPACE_ID"));
|
||
log.put("CREATOR",pd.get("ACTION_USER"));
|
||
log.put("CREATTIME", DateUtil.date2Str(new Date()));
|
||
GFconfinedspaceLogService.save(log);
|
||
|
||
|
||
// // 发短信
|
||
// PageData mes = new PageData();
|
||
// mes.put("RECEIVER_ID", pd.get("CONFIRM_USER_ID"));// 收信人userid
|
||
// mes.put("templateCode", "YX_Y01");// 短信模板编码
|
||
// mes.put("SMSCode", "SMS_227245922");// 短信模板编码
|
||
// mes.put("CORPINFO_ID", pd.get("CORPINFO_ID"));// 企业id
|
||
// // 参数集合
|
||
// List<PageData> paramsList = new ArrayList<PageData>();
|
||
// // 第1个参数
|
||
// PageData params1 = new PageData();
|
||
// params1.put("name", "number");// 存入短信模板中的参数名称
|
||
// params1.put("value", pd.get("CHECK_NO"));// 存入上面参数名称所传递的值
|
||
// paramsList.add(params1);
|
||
// // 第2个参数
|
||
// PageData params2 = new PageData();
|
||
// params2.put("name", "params1");// 存入短信模板中的参数名称
|
||
// params2.put("value", "有限空间作业");// 存入上面参数名称所传递的值
|
||
// paramsList.add(params2);
|
||
// // 第3个参数
|
||
// PageData params3 = new PageData();
|
||
// params3.put("name", "params2");// 存入短信模板中的参数名称
|
||
// params3.put("value", "作业单位确认");// 存入上面参数名称所传递的值
|
||
// paramsList.add(params3);
|
||
// // 第4个参数
|
||
// PageData params4 = new PageData();
|
||
// params4.put("name", "params3");// 存入短信模板中的参数名称
|
||
// params4.put("value", "确认");// 存入上面参数名称所传递的值
|
||
// paramsList.add(params4);
|
||
// sendMessageUtil.sendMessages(mes, paramsList);
|
||
}
|
||
this.sendNotice(pd);
|
||
map.put("result", errInfo);
|
||
return map;
|
||
}
|
||
/**修改
|
||
* @param
|
||
* @throws Exception
|
||
*/
|
||
@RequestMapping(value="/editConfess")
|
||
@ResponseBody
|
||
@Transactional
|
||
public Object editConfess(
|
||
@RequestParam(value="FFILE",required=false) MultipartFile[] files
|
||
) throws Exception{
|
||
Map<String,Object> map = new HashMap<String,Object>();
|
||
String errInfo = "success";
|
||
PageData pd = new PageData();
|
||
pd = this.getPageData();
|
||
PageData pd2 = new PageData();
|
||
pd2 = GFconfinedspaceService.findById(pd);
|
||
pd2.put("OPERATOR", pd.get("OPERATOR")); //修改人
|
||
pd2.put("OPERATTIME", DateUtil.date2Str(new Date())); //修改时间
|
||
if (files != null && files.length > 0) {
|
||
MultipartFile file = files[0];
|
||
|
||
String ffile = DateUtil.getDays();
|
||
String fileName = this.get32UUID()+file.getOriginalFilename().substring(file.getOriginalFilename().lastIndexOf("."));
|
||
smb.sshSftp(file, fileName, Const.FILEPATHFILE + pd.getString("CORPINFO_ID") + "/" + ffile);
|
||
|
||
pd2.put("CONFESS_USER_SIGNER_PATH", Const.FILEPATHFILE + pd.getString("CORPINFO_ID") + "/" + ffile + "/" + fileName);
|
||
pd2.put("CONFESS_USER_SIGNER_TIME", pd.get("SIGNER_TIME"));
|
||
// pd2.put("GUARDIAN_CONTENT", pd.get("CONTENT"));
|
||
// pd2.put("APPLY_STATUS", pd.get("APPLY_STATUS"));
|
||
GFconfinedspaceService.edit(pd2);
|
||
}
|
||
map.put("result", errInfo);
|
||
return map;
|
||
}
|
||
// /**修改
|
||
// * @param
|
||
// * @throws Exception
|
||
// */
|
||
// @RequestMapping(value="/editAcceptconfess")
|
||
// @ResponseBody
|
||
// @Transactional
|
||
// @LogAnno(menuType= "手机",menuServer= "受限空间",instructionsOperate = "受限空间",instructionsType = "接受交底人签字")
|
||
// public Object editAcceptconfess(
|
||
// @RequestParam(value="FFILE",required=false) MultipartFile[] files
|
||
// ) throws Exception {
|
||
// Map<String, Object> map = new HashMap<String, Object>();
|
||
// String errInfo = "success";
|
||
// PageData pd = new PageData();
|
||
// pd = this.getPageData();
|
||
// PageData pd2 = new PageData();
|
||
// pd2 = confinedspaceService.findById(pd);
|
||
// pd2.put("OPERATOR", pd.get("OPERATOR")); //修改人
|
||
// pd2.put("OPERATTIME", DateUtil.date2Str(new Date())); //修改时间
|
||
// if (files != null && files.length > 0) {
|
||
// MultipartFile file = files[0];
|
||
//
|
||
// String ffile = DateUtil.getDays();
|
||
// String fileName = this.get32UUID() + file.getOriginalFilename().substring(file.getOriginalFilename().lastIndexOf("."));
|
||
// smb.sshSftp(file, fileName, Const.FILEPATHFILE + pd.getString("CORPINFO_ID") + "/" + ffile);
|
||
// pd2.put("ACCEPT_CONFESS_USER_SIGNER_PATH", Const.FILEPATHFILE + pd.getString("CORPINFO_ID") + "/" + ffile + "/" + fileName);
|
||
// pd2.put("ACCEPT_CONFESS_USER_SIGNER_TIME", pd.get("SIGNER_TIME"));
|
||
// confinedspaceacceptuserService.edit(pd2);
|
||
// }
|
||
// map.put("result", errInfo);
|
||
// return map;
|
||
// }
|
||
|
||
/**修改
|
||
* @param
|
||
* @throws Exception
|
||
*/
|
||
@RequestMapping(value="/editAcceptconfess")
|
||
@ResponseBody
|
||
@Transactional
|
||
public Object editAcceptconfess(MultipartRequest request) throws Exception {
|
||
Map<String, Object> map = new HashMap<String, Object>();
|
||
String errInfo = "success";
|
||
PageData pd = new PageData();
|
||
pd = this.getPageData();
|
||
PageData pd2 = new PageData();
|
||
pd2 = GFconfinedspaceService.findById(pd);
|
||
pd2.put("OPERATOR", pd.get("OPERATOR")); //修改人
|
||
pd2.put("OPERATTIME", DateUtil.date2Str(new Date())); //修改时间
|
||
|
||
List<MultipartFile> fileList = new ArrayList<MultipartFile>();
|
||
String signertime = "";
|
||
String SIGNTIME[] = pd.getString("SIGNTIME").split(",");
|
||
|
||
for (int i = 0; i < SIGNTIME.length; i++) {
|
||
signertime = SIGNTIME[i];
|
||
fileList.add(request.getFile("file"+i));
|
||
MultipartFile[] fileArr = new MultipartFile[fileList.size()];
|
||
saveImg(fileList.toArray(fileArr),signertime,pd.getString("CONFINEDSPACE_ID"),pd.getString("CORPINFO_ID"),pd.getString("ACCEPT_CONFESS_USER_ID"),pd.getString("ACCEPT_CONFESS_DEPARTMENT_ID"));
|
||
fileList.clear();
|
||
}
|
||
|
||
map.put("result", errInfo);
|
||
return map;
|
||
}
|
||
|
||
/**修改(单个文件上传接口)
|
||
* @param
|
||
* @throws Exception
|
||
*/
|
||
@RequestMapping(value="/singleUpload/editAcceptconfess")
|
||
@ResponseBody
|
||
@Transactional
|
||
public Object suEditAcceptconfess(MultipartRequest request) throws Exception {
|
||
Map<String, Object> map = new HashMap<String, Object>();
|
||
String errInfo = "success";
|
||
PageData pd = new PageData();
|
||
pd = this.getPageData();
|
||
PageData pd2 = new PageData();
|
||
pd2 = GFconfinedspaceService.findById(pd);
|
||
pd2.put("OPERATOR", pd.get("OPERATOR")); //修改人
|
||
pd2.put("OPERATTIME", DateUtil.date2Str(new Date())); //修改时间
|
||
|
||
List<MultipartFile> fileList = new ArrayList<MultipartFile>();
|
||
String signertime = "";
|
||
String SIGNTIME = pd.getString("SIGNTIME");
|
||
|
||
signertime = SIGNTIME;
|
||
fileList.add(request.getFile("file"));
|
||
MultipartFile[] fileArr = new MultipartFile[fileList.size()];
|
||
saveImg(fileList.toArray(fileArr),signertime,pd.getString("CONFINEDSPACE_ID"),pd.getString("CORPINFO_ID"),pd.getString("ACCEPT_CONFESS_USER_ID"),pd.getString("ACCEPT_CONFESS_DEPARTMENT_ID"));
|
||
fileList.clear();
|
||
|
||
map.put("result", errInfo);
|
||
return map;
|
||
}
|
||
private void saveImg(MultipartFile[] files,String signertime, String CONFINEDSPACE_ID, String CORPINFO_ID, String ACCEPT_CONFESS_USER_ID, String ACCEPT_CONFESS_DEPARTMENT_ID) throws Exception{
|
||
if (files != null && files.length > 0) {
|
||
for (int i = 0; i < files.length; i++) {
|
||
PageData pd = new PageData();
|
||
pd = this.getPageData();
|
||
MultipartFile file = files[i];
|
||
String ffile = DateUtil.getDays();
|
||
String fileName;
|
||
if (file.getOriginalFilename() == null) {
|
||
fileName = ".PNG";
|
||
} else {
|
||
fileName = this.get32UUID()+file.getOriginalFilename().substring(file.getOriginalFilename().lastIndexOf("."));
|
||
}
|
||
smb.sshSftp(file, fileName,Const.FILEPATHFILE + CORPINFO_ID + "/" + ffile);
|
||
pd.put("ACCEPT_CONFESS_USER_SIGNER_TIME", signertime);
|
||
pd.put("ACCEPT_CONFESS_ID", this.get32UUID());
|
||
pd.put("OPERATOR", pd.get("OPERATOR")); //修改人
|
||
pd.put("OPERATTIME", DateUtil.date2Str(new Date())); //修改时间
|
||
pd.put("ACCEPT_CONFESS_USER_SIGNER_PATH", Const.FILEPATHFILE + CORPINFO_ID + "/" + ffile + "/" + fileName);
|
||
pd.put("ISDELETE", '0');
|
||
pd.put("CORPINFO_ID", CORPINFO_ID);
|
||
pd.put("CONFINEDSPACE_ID", CONFINEDSPACE_ID);
|
||
pd.put("ACCEPT_CONFESS_USER_ID", ACCEPT_CONFESS_USER_ID);
|
||
pd.put("ACCEPT_CONFESS_DEPARTMENT_ID", ACCEPT_CONFESS_DEPARTMENT_ID);
|
||
pd.put("ACCEPT_USER_ID","");
|
||
pd.put("ACCEPT_DEPARTMENT_ID", "");
|
||
confinedspaceacceptuserService.save(pd);
|
||
}
|
||
}
|
||
}
|
||
|
||
@RequestMapping(value="/editAcceptStatus")
|
||
@ResponseBody
|
||
@Transactional
|
||
public Object editAcceptStatus(MultipartRequest request) throws Exception{
|
||
Map<String,Object> map = new HashMap<String,Object>();
|
||
String errInfo = "success";
|
||
PageData pd = new PageData();
|
||
pd = this.getPageData();
|
||
PageData pd2 = new PageData();
|
||
pd2 = GFconfinedspaceService.findById(pd);
|
||
pd2.put("OPERATOR", pd.get("OPERATOR")); //修改人
|
||
pd2.put("OPERATTIME", DateUtil.date2Str(new Date())); //修改时间
|
||
PageData log = new PageData();
|
||
log.put("CONFINEDSPACELOG_ID", this.get32UUID());
|
||
// log.put("ACTION", "审核打回");
|
||
log.put("CONFINEDSPACE_ID", pd.get("CONFINEDSPACE_ID"));
|
||
log.put("CREATOR",pd.get("ACTION_USER"));
|
||
log.put("CREATTIME", DateUtil.date2Str(new Date()));
|
||
|
||
String status = pd.get("STATUS").toString();
|
||
if ("2".equals(status) || "3".equals(status) || "4".equals(status) || "5".equals(status)) {
|
||
pd2.put("OTHER_PROTECTIVE_MEASURES", (StringUtils.isNotBlank(pd2.getString("OTHER_PROTECTIVE_MEASURES")) ? pd2.getString("OTHER_PROTECTIVE_MEASURES") : "") +
|
||
(StringUtils.isNotBlank(pd.getString("OTHER_PROTECTIVE_MEASURES")) ? (pd.getString("OTHER_PROTECTIVE_MEASURES") + ";_;") : ";_;"));
|
||
} else if ("-2".equals(status) || "-3".equals(status) || "-4".equals(status) || "-5".equals(status) || "-6".equals(status)) {
|
||
//打回清空数据
|
||
pd2.put("OTHER_PROTECTIVE_MEASURES", "");
|
||
}
|
||
|
||
switch (status) {
|
||
case "6"://验收人
|
||
|
||
List<MultipartFile> fileList = new ArrayList<MultipartFile>();
|
||
String signertime = "";
|
||
String SIGNTIME[] = pd.getString("SIGNTIME").split(",");
|
||
|
||
for (int i = 0; i < SIGNTIME.length; i++) {
|
||
signertime = SIGNTIME[i];
|
||
fileList.add(request.getFile("file"+i));
|
||
MultipartFile[] fileArr = new MultipartFile[fileList.size()];
|
||
saveAcceptImg(fileList.toArray(fileArr),signertime,pd.getString("CONFINEDSPACE_ID"),pd.getString("CORPINFO_ID"),pd.getString("ACCEPT_USER_ID"),pd.getString("ACCEPT_DEPARTMENT_ID"));
|
||
fileList.clear();
|
||
}
|
||
|
||
pd2.put("APPLY_STATUS", pd.get("APPLY_STATUS"));
|
||
pd2.put("ACCEPT_CONTENT", pd.get("CONTENT"));
|
||
GFconfinedspaceService.edit(pd2);
|
||
log.put("ACTION", "验收通过");
|
||
|
||
// 发短信
|
||
PageData mes = new PageData();
|
||
mes.put("RECEIVER_ID", pd2.get("APPLY_USER_ID"));// 收信人userid
|
||
mes.put("templateCode", "YX_Y06");// 短信模板编码
|
||
mes.put("SMSCode", "SMS_227250920");// 短信模板编码
|
||
mes.put("CORPINFO_ID", pd2.get("CORPINFO_ID"));// 企业id
|
||
// 参数集合
|
||
List<PageData> paramsList = new ArrayList<PageData>();
|
||
// 第1个参数
|
||
PageData params1 = new PageData();
|
||
params1.put("name", "number");// 存入短信模板中的参数名称
|
||
params1.put("value", pd2.get("CHECK_NO"));// 存入上面参数名称所传递的值
|
||
paramsList.add(params1);
|
||
// 第2个参数
|
||
PageData params2 = new PageData();
|
||
params2.put("name", "type");// 存入短信模板中的参数名称
|
||
params2.put("value", "有限空间作业");// 存入上面参数名称所传递的值
|
||
paramsList.add(params2);
|
||
sendMessageUtil.sendMessages(mes, paramsList);
|
||
break;
|
||
case "-6"://验收人打回
|
||
log.put("ACTION", "验收人打回");
|
||
pd2.put("APPLY_STATUS", pd.get("APPLY_STATUS"));
|
||
pd2.put("ACCEPT_CONTENT", pd.get("CONTENT"));
|
||
GFconfinedspaceService.edit(pd2);
|
||
|
||
// 发短信
|
||
PageData mes4 = new PageData();
|
||
mes4.put("RECEIVER_ID", pd2.get("APPLY_USER_ID"));// 收信人userid
|
||
mes4.put("templateCode", "YX_N06");// 短信模板编码
|
||
mes4.put("SMSCode", "SMS_223580715");// 短信模板编码
|
||
mes4.put("CORPINFO_ID", pd2.get("CORPINFO_ID"));// 企业id
|
||
// 参数集合
|
||
List<PageData> paramsList4 = new ArrayList<PageData>();
|
||
// 第1个参数
|
||
PageData params13 = new PageData();
|
||
params13.put("name", "params1");// 存入短信模板中的参数名称
|
||
params13.put("value", pd2.get("CHECK_NO"));// 存入上面参数名称所传递的值
|
||
paramsList4.add(params13);
|
||
// 第2个参数
|
||
PageData params14 = new PageData();
|
||
params14.put("name", "params2");// 存入短信模板中的参数名称
|
||
params14.put("value", "有限空间作业");// 存入上面参数名称所传递的值
|
||
paramsList4.add(params14);
|
||
// 第3个参数
|
||
PageData params15 = new PageData();
|
||
params15.put("name", "params3");// 存入短信模板中的参数名称
|
||
params15.put("value", "验收人");// 存入上面参数名称所传递的值
|
||
paramsList4.add(params15);
|
||
sendMessageUtil.sendMessages(mes4, paramsList4);
|
||
break;
|
||
default:
|
||
break;
|
||
}
|
||
GFconfinedspaceLogService.save(log);
|
||
this.sendNotice(pd);
|
||
map.put("result", errInfo);
|
||
return map;
|
||
}
|
||
|
||
@RequestMapping(value="/singleUpload/editAcceptStatus")
|
||
@ResponseBody
|
||
@Transactional
|
||
public Object suEditAcceptStatus(MultipartRequest request) throws Exception{
|
||
Map<String,Object> map = new HashMap<String,Object>();
|
||
String errInfo = "success";
|
||
PageData pd = new PageData();
|
||
pd = this.getPageData();
|
||
PageData pd2 = new PageData();
|
||
pd2 = GFconfinedspaceService.findById(pd);
|
||
pd2.put("OPERATOR", pd.get("OPERATOR")); //修改人
|
||
pd2.put("OPERATTIME", DateUtil.date2Str(new Date())); //修改时间
|
||
PageData log = new PageData();
|
||
log.put("CONFINEDSPACELOG_ID", this.get32UUID());
|
||
// log.put("ACTION", "审核打回");
|
||
log.put("CONFINEDSPACE_ID", pd.get("CONFINEDSPACE_ID"));
|
||
log.put("CREATOR",pd.get("ACTION_USER"));
|
||
log.put("CREATTIME", DateUtil.date2Str(new Date()));
|
||
|
||
String status = pd.get("STATUS").toString();
|
||
if ("2".equals(status) || "3".equals(status) || "4".equals(status) || "5".equals(status)) {
|
||
pd2.put("OTHER_PROTECTIVE_MEASURES", (StringUtils.isNotBlank(pd2.getString("OTHER_PROTECTIVE_MEASURES")) ? pd2.getString("OTHER_PROTECTIVE_MEASURES") : "") +
|
||
(StringUtils.isNotBlank(pd.getString("OTHER_PROTECTIVE_MEASURES")) ? (pd.getString("OTHER_PROTECTIVE_MEASURES") + ";_;") : ";_;"));
|
||
} else if ("-2".equals(status) || "-3".equals(status) || "-4".equals(status) || "-5".equals(status) || "-6".equals(status)) {
|
||
//打回清空数据
|
||
pd2.put("OTHER_PROTECTIVE_MEASURES", "");
|
||
}
|
||
|
||
switch (status) {
|
||
case "6"://验收人
|
||
|
||
List<MultipartFile> fileList = new ArrayList<MultipartFile>();
|
||
String signertime = "";
|
||
String SIGNTIME = pd.getString("SIGNTIME");
|
||
|
||
|
||
signertime = SIGNTIME;
|
||
fileList.add(request.getFile("file"));
|
||
MultipartFile[] fileArr = new MultipartFile[fileList.size()];
|
||
saveAcceptImg(fileList.toArray(fileArr),signertime,pd.getString("CONFINEDSPACE_ID"),pd.getString("CORPINFO_ID"),pd.getString("ACCEPT_USER_ID"),pd.getString("ACCEPT_DEPARTMENT_ID"));
|
||
fileList.clear();
|
||
|
||
|
||
pd2.put("APPLY_STATUS", pd.get("APPLY_STATUS"));
|
||
pd2.put("ACCEPT_CONTENT", pd.get("CONTENT"));
|
||
GFconfinedspaceService.edit(pd2);
|
||
log.put("ACTION", "验收通过");
|
||
|
||
// 发短信
|
||
PageData mes = new PageData();
|
||
mes.put("RECEIVER_ID", pd2.get("APPLY_USER_ID"));// 收信人userid
|
||
mes.put("templateCode", "YX_Y06");// 短信模板编码
|
||
mes.put("SMSCode", "SMS_227250920");// 短信模板编码
|
||
mes.put("CORPINFO_ID", pd2.get("CORPINFO_ID"));// 企业id
|
||
// 参数集合
|
||
List<PageData> paramsList = new ArrayList<PageData>();
|
||
// 第1个参数
|
||
PageData params1 = new PageData();
|
||
params1.put("name", "number");// 存入短信模板中的参数名称
|
||
params1.put("value", pd2.get("CHECK_NO"));// 存入上面参数名称所传递的值
|
||
paramsList.add(params1);
|
||
// 第2个参数
|
||
PageData params2 = new PageData();
|
||
params2.put("name", "type");// 存入短信模板中的参数名称
|
||
params2.put("value", "有限空间作业");// 存入上面参数名称所传递的值
|
||
paramsList.add(params2);
|
||
sendMessageUtil.sendMessages(mes, paramsList);
|
||
break;
|
||
case "-6"://验收人打回
|
||
log.put("ACTION", "验收人打回");
|
||
pd2.put("APPLY_STATUS", pd.get("APPLY_STATUS"));
|
||
pd2.put("ACCEPT_CONTENT", pd.get("CONTENT"));
|
||
GFconfinedspaceService.edit(pd2);
|
||
|
||
// 发短信
|
||
PageData mes4 = new PageData();
|
||
mes4.put("RECEIVER_ID", pd2.get("APPLY_USER_ID"));// 收信人userid
|
||
mes4.put("templateCode", "YX_N06");// 短信模板编码
|
||
mes4.put("SMSCode", "SMS_223580715");// 短信模板编码
|
||
mes4.put("CORPINFO_ID", pd2.get("CORPINFO_ID"));// 企业id
|
||
// 参数集合
|
||
List<PageData> paramsList4 = new ArrayList<PageData>();
|
||
// 第1个参数
|
||
PageData params13 = new PageData();
|
||
params13.put("name", "params1");// 存入短信模板中的参数名称
|
||
params13.put("value", pd2.get("CHECK_NO"));// 存入上面参数名称所传递的值
|
||
paramsList4.add(params13);
|
||
// 第2个参数
|
||
PageData params14 = new PageData();
|
||
params14.put("name", "params2");// 存入短信模板中的参数名称
|
||
params14.put("value", "有限空间作业");// 存入上面参数名称所传递的值
|
||
paramsList4.add(params14);
|
||
// 第3个参数
|
||
PageData params15 = new PageData();
|
||
params15.put("name", "params3");// 存入短信模板中的参数名称
|
||
params15.put("value", "验收人");// 存入上面参数名称所传递的值
|
||
paramsList4.add(params15);
|
||
sendMessageUtil.sendMessages(mes4, paramsList4);
|
||
break;
|
||
default:
|
||
break;
|
||
}
|
||
GFconfinedspaceLogService.save(log);
|
||
this.sendNotice(pd);
|
||
map.put("result", errInfo);
|
||
return map;
|
||
}
|
||
|
||
private void saveAcceptImg(MultipartFile[] files,String signertime, String CONFINEDSPACE_ID, String CORPINFO_ID, String ACCEPT_USER_ID, String ACCEPT_DEPARTMENT_ID) throws Exception{
|
||
if (files != null && files.length > 0) {
|
||
for (int i = 0; i < files.length; i++) {
|
||
PageData cpd = new PageData();
|
||
cpd = this.getPageData();
|
||
MultipartFile file = files[i];
|
||
String ffile = DateUtil.getDays();
|
||
String fileName = this.get32UUID()+file.getOriginalFilename().substring(file.getOriginalFilename().lastIndexOf("."));
|
||
smb.sshSftp(file, fileName,Const.FILEPATHFILE + CORPINFO_ID + "/" + ffile);
|
||
cpd.put("ACCEPT_USER_SIGNER_TIME", signertime);
|
||
cpd.put("ACCEPT_CONFESS_ID", this.get32UUID());
|
||
cpd.put("OPERATOR", cpd.get("OPERATOR")); //修改人
|
||
cpd.put("OPERATTIME", DateUtil.date2Str(new Date())); //修改时间
|
||
cpd.put("ACCEPT_USER_SIGNER_PATH", Const.FILEPATHFILE + CORPINFO_ID + "/" + ffile + "/" + fileName);
|
||
cpd.put("ISDELETE", '0');
|
||
cpd.put("CORPINFO_ID", CORPINFO_ID);
|
||
cpd.put("CONFINEDSPACE_ID", CONFINEDSPACE_ID);
|
||
cpd.put("ACCEPT_USER_ID", ACCEPT_USER_ID);
|
||
cpd.put("ACCEPT_CONFESS_DEPARTMENT_ID", "");
|
||
cpd.put("ACCEPT_CONFESS_USER_ID", "");
|
||
cpd.put("ACCEPT_DEPARTMENT_ID", ACCEPT_DEPARTMENT_ID);
|
||
confinedspaceacceptuserService.save(cpd);
|
||
}
|
||
}
|
||
}
|
||
|
||
|
||
|
||
/**修改
|
||
* @param
|
||
* @throws Exception
|
||
*/
|
||
@RequestMapping(value="/editStatus")
|
||
@ResponseBody
|
||
@Transactional
|
||
public Object editStatus(
|
||
@RequestParam(value="FFILE",required=false) MultipartFile[] files
|
||
) throws Exception{
|
||
Map<String,Object> map = new HashMap<String,Object>();
|
||
String errInfo = "success";
|
||
PageData pd = new PageData();
|
||
pd = this.getPageData();
|
||
PageData pd2 = new PageData();
|
||
pd2 = GFconfinedspaceService.findById(pd);
|
||
pd2.put("OPERATOR", pd.get("OPERATOR")); //修改人
|
||
pd2.put("OPERATTIME", DateUtil.date2Str(new Date())); //修改时间
|
||
PageData log = new PageData();
|
||
log.put("CONFINEDSPACELOG_ID", this.get32UUID());
|
||
// log.put("ACTION", "审核打回");
|
||
log.put("CONFINEDSPACE_ID", pd.get("CONFINEDSPACE_ID"));
|
||
log.put("CREATOR",pd.get("ACTION_USER"));
|
||
log.put("CREATTIME", DateUtil.date2Str(new Date()));
|
||
|
||
String status = pd.get("STATUS").toString();
|
||
if ("2".equals(status) || "3".equals(status) || "4".equals(status) || "5".equals(status)) {
|
||
pd2.put("OTHER_PROTECTIVE_MEASURES", (StringUtils.isNotBlank(pd2.getString("OTHER_PROTECTIVE_MEASURES")) ? pd2.getString("OTHER_PROTECTIVE_MEASURES") : "") +
|
||
(StringUtils.isNotBlank(pd.getString("OTHER_PROTECTIVE_MEASURES")) ? (pd.getString("OTHER_PROTECTIVE_MEASURES") + ";_;") : ";_;"));
|
||
} else if ("-2".equals(status) || "-3".equals(status) || "-4".equals(status) || "-5".equals(status) || "-6".equals(status)) {
|
||
//打回清空数据
|
||
pd2.put("OTHER_PROTECTIVE_MEASURES", "");
|
||
}
|
||
|
||
switch (status) {
|
||
case "4"://确认
|
||
if (files != null && files.length > 0) {
|
||
MultipartFile file = files[0];
|
||
|
||
String ffile = DateUtil.getDays();
|
||
String fileName = this.get32UUID()+file.getOriginalFilename().substring(file.getOriginalFilename().lastIndexOf("."));
|
||
smb.sshSftp(file, fileName, Const.FILEPATHFILE + pd.getString("CORPINFO_ID") + "/" + ffile);
|
||
|
||
pd2.put("CONFIRM_USER_SIGNER_PATH", Const.FILEPATHFILE + pd.getString("CORPINFO_ID") + "/" + ffile + "/" + fileName);
|
||
pd2.put("CONFIRM_USER_SIGNER_TIME", pd.get("SIGNER_TIME"));
|
||
pd2.put("CONFIRM_CONTENT", pd.get("CONTENT"));
|
||
pd2.put("APPLY_STATUS", pd.get("APPLY_STATUS"));
|
||
|
||
pd2.put("ANALYZE_DEPARTMENT_ID", pd.get("ANALYZE_DEPARTMENT_ID"));
|
||
pd2.put("ANALYZE_USER_ID", pd.get("ANALYZE_USER_ID"));
|
||
pd2.put("CONFESS_DEPARTMENT_ID", pd.get("CONFESS_DEPARTMENT_ID"));
|
||
pd2.put("CONFESS_USER_ID", pd.get("CONFESS_USER_ID"));
|
||
pd2.put("ACCEPT_CONFESS_DEPARTMENT_ID", pd.get("ACCEPT_CONFESS_DEPARTMENT_ID"));
|
||
pd2.put("ACCEPT_CONFESS_USER_ID", pd.get("ACCEPT_CONFESS_USER_ID"));
|
||
pd2.put("EDUCATE_USER", pd.get("EDUCATE_USER"));
|
||
GFconfinedspaceService.edit(pd2);
|
||
GFconfinedspaceToMeasuresService.delete(pd2);
|
||
List<JSONObject> list = (List<JSONObject>) JSON.parse(pd.get("measuresList").toString());
|
||
for (JSONObject json : list) {
|
||
PageData measures = new PageData();
|
||
measures.put("CONFINEDSPACETOMEASURES_ID", this.get32UUID()); // 主键
|
||
measures.put("CONFINEDSPACE_ID", pd2.get("CONFINEDSPACE_ID"));
|
||
measures.put("BUS_CONFINEDSPACE_MEASURES_ID", json.get("BUS_CONFINEDSPACE_MEASURES_ID"));
|
||
measures.put("ANSWER1", json.get("ANSWER1"));
|
||
measures.put("ANSWER2", json.get("ANSWER2"));
|
||
measures.put("ANSWER3", json.get("ANSWER3"));
|
||
measures.put("STATUS", json.get("STATUS"));
|
||
measures.put("CONFIRM_ID", pd.get("OPERATOR"));
|
||
measures.put("CONFIRM_NAME", pd.get("ACTION_USER"));
|
||
GFconfinedspaceToMeasuresService.save(measures);
|
||
}
|
||
|
||
log.put("ACTION", "作业单位通过");
|
||
|
||
|
||
// 发短信
|
||
PageData mes = new PageData();
|
||
mes.put("RECEIVER_ID", pd2.get("APPROVE_USER_ID"));// 收信人userid
|
||
mes.put("templateCode", "YX_Y04");// 短信模板编码
|
||
mes.put("SMSCode", "SMS_227245922");// 短信模板编码
|
||
mes.put("CORPINFO_ID", pd2.get("CORPINFO_ID"));// 企业id
|
||
// 参数集合
|
||
List<PageData> paramsList = new ArrayList<PageData>();
|
||
// 第1个参数
|
||
PageData params1 = new PageData();
|
||
params1.put("name", "number");// 存入短信模板中的参数名称
|
||
params1.put("value", pd2.get("CHECK_NO"));// 存入上面参数名称所传递的值
|
||
paramsList.add(params1);
|
||
// 第2个参数
|
||
PageData params2 = new PageData();
|
||
params2.put("name", "params1");// 存入短信模板中的参数名称
|
||
params2.put("value", "有限空间作业");// 存入上面参数名称所传递的值
|
||
paramsList.add(params2);
|
||
// 第3个参数
|
||
PageData params3 = new PageData();
|
||
params3.put("name", "params2");// 存入短信模板中的参数名称
|
||
params3.put("value", "所在单位");// 存入上面参数名称所传递的值
|
||
paramsList.add(params3);
|
||
// 第4个参数
|
||
PageData params4 = new PageData();
|
||
params4.put("name", "params3");// 存入短信模板中的参数名称
|
||
params4.put("value", "审批");// 存入上面参数名称所传递的值
|
||
paramsList.add(params4);
|
||
sendMessageUtil.sendMessages(mes, paramsList);
|
||
TenCorpDto tenCorpDto = new TenCorpDto();
|
||
tenCorpDto.setTopic("eightWork");
|
||
tenCorpDto.setMark(pd.getString("CONFINEDSPACE_ID"));
|
||
tenCorpDto.setMessage(TenCorpConst.confinedSpace);
|
||
tenCorpDto.setTime_stamp(pd.getString("WORK_START_DATE") + ":00:000");
|
||
tenCorpDto.setData(pd);
|
||
tenCorpDto.setMark_name("CONFINEDSPACE_ID");
|
||
mqClient.SendDelayQueue(tenCorpDto);
|
||
}
|
||
break;
|
||
|
||
case "3"://监护人确认
|
||
if (files != null && files.length > 0) {
|
||
MultipartFile file = files[0];
|
||
|
||
String ffile = DateUtil.getDays();
|
||
String fileName = this.get32UUID()+file.getOriginalFilename().substring(file.getOriginalFilename().lastIndexOf("."));
|
||
smb.sshSftp(file, fileName, Const.FILEPATHFILE + pd.getString("CORPINFO_ID") + "/" + ffile);
|
||
|
||
pd2.put("GUARDIAN_USER_SIGNER_PATH", Const.FILEPATHFILE + pd.getString("CORPINFO_ID") + "/" + ffile + "/" + fileName);
|
||
pd2.put("GUARDIAN_USER_SIGNER_TIME", pd.get("SIGNER_TIME"));
|
||
// pd2.put("GUARDIAN_CONTENT", pd.get("CONTENT"));
|
||
// pd2.put("APPLY_STATUS", pd.get("APPLY_STATUS"));
|
||
GFconfinedspaceService.edit(pd2);
|
||
log.put("ACTION", "监护人确认通过");
|
||
}
|
||
return map;
|
||
|
||
//
|
||
//
|
||
// // 发短信
|
||
// PageData mes = new PageData();
|
||
// mes.put("RECEIVER_ID", pd2.get("AUDIT_USER_ID"));// 收信人userid
|
||
// mes.put("templateCode", "SMS_227250904");// 短信模板编码
|
||
// mes.put("CORPINFO_ID", pd2.get("CORPINFO_ID"));// 企业id
|
||
// // 参数集合
|
||
// List<PageData> paramsList = new ArrayList<PageData>();
|
||
// // 第1个参数
|
||
// PageData params1 = new PageData();
|
||
// params1.put("name", "number");// 存入短信模板中的参数名称
|
||
// params1.put("value", pd2.get("CHECK_NO"));// 存入上面参数名称所传递的值
|
||
// paramsList.add(params1);
|
||
// // 第2个参数
|
||
// PageData params2 = new PageData();
|
||
// params2.put("name", "params1");// 存入短信模板中的参数名称
|
||
// params2.put("value", "有限空间作业");// 存入上面参数名称所传递的值
|
||
// paramsList.add(params2);
|
||
// // 第3个参数
|
||
// PageData params3 = new PageData();
|
||
// params3.put("name", "params2");// 存入短信模板中的参数名称
|
||
// params3.put("value", "审核部门审核");// 存入上面参数名称所传递的值
|
||
// paramsList.add(params3);
|
||
// // 第4个参数
|
||
// PageData params4 = new PageData();
|
||
// params4.put("name", "params3");// 存入短信模板中的参数名称
|
||
// params4.put("value", "审核");// 存入上面参数名称所传递的值
|
||
// paramsList.add(params4);
|
||
// sendMessageUtil.sendMessages(mes, paramsList);
|
||
// }
|
||
// break;
|
||
//
|
||
// case "4"://审核
|
||
// if (files != null && files.length > 0) {
|
||
// MultipartFile file = files[0];
|
||
//
|
||
// String ffile = DateUtil.getDays();
|
||
// String fileName = this.get32UUID()+file.getOriginalFilename().substring(file.getOriginalFilename().lastIndexOf("."));
|
||
// smb.sshSftp(file, fileName, Const.FILEPATHFILE + pd.getString("CORPINFO_ID") + "/" + ffile);
|
||
//
|
||
// pd2.put("AUDIT_USER_SIGNER_PATH", Const.FILEPATHFILE + pd.getString("CORPINFO_ID") + "/" + ffile + "/" + fileName);
|
||
// pd2.put("AUDIT_USER_SIGNER_TIME", pd.get("SIGNER_TIME"));
|
||
// pd2.put("AUDIT_CONTENT", pd.get("CONTENT"));
|
||
// pd2.put("APPLY_STATUS", pd.get("APPLY_STATUS"));
|
||
// GFconfinedspaceService.edit(pd2);
|
||
// log.put("ACTION", "审核通过");
|
||
//
|
||
// // 发短信
|
||
// PageData mes = new PageData();
|
||
// mes.put("RECEIVER_ID", pd2.get("APPROVE_USER_ID"));// 收信人userid
|
||
// mes.put("templateCode", "SMS_227250904");// 短信模板编码
|
||
// mes.put("CORPINFO_ID", pd2.get("CORPINFO_ID"));// 企业id
|
||
// // 参数集合
|
||
// List<PageData> paramsList = new ArrayList<PageData>();
|
||
// // 第1个参数
|
||
// PageData params1 = new PageData();
|
||
// params1.put("name", "number");// 存入短信模板中的参数名称
|
||
// params1.put("value", pd2.get("CHECK_NO"));// 存入上面参数名称所传递的值
|
||
// paramsList.add(params1);
|
||
// // 第2个参数
|
||
// PageData params2 = new PageData();
|
||
// params2.put("name", "params1");// 存入短信模板中的参数名称
|
||
// params2.put("value", "有限空间作业");// 存入上面参数名称所传递的值
|
||
// paramsList.add(params2);
|
||
// // 第3个参数
|
||
// PageData params3 = new PageData();
|
||
// params3.put("name", "params2");// 存入短信模板中的参数名称
|
||
// params3.put("value", "审批人审批");// 存入上面参数名称所传递的值
|
||
// paramsList.add(params3);
|
||
// // 第4个参数
|
||
// PageData params4 = new PageData();
|
||
// params4.put("name", "params3");// 存入短信模板中的参数名称
|
||
// params4.put("value", "审批");// 存入上面参数名称所传递的值
|
||
// paramsList.add(params4);
|
||
// sendMessageUtil.sendMessages(mes, paramsList);
|
||
//
|
||
// case "2"://接受交底人确认
|
||
// if (files != null && files.length > 0) {
|
||
// MultipartFile file = files[0];
|
||
//
|
||
// String ffile = DateUtil.getDays();
|
||
// String fileName = this.get32UUID()+file.getOriginalFilename().substring(file.getOriginalFilename().lastIndexOf("."));
|
||
// smb.sshSftp(file, fileName, Const.FILEPATHFILE + pd.getString("CORPINFO_ID") + "/" + ffile);
|
||
//
|
||
// pd2.put("ACCEPT_CONFESS_USER_SIGNER_PATH", Const.FILEPATHFILE + pd.getString("CORPINFO_ID") + "/" + ffile + "/" + fileName);
|
||
// pd2.put("ACCEPT_CONFESS_USER_SIGNER_TIME", pd.get("SIGNER_TIME"));
|
||
//// pd2.put("GUARDIAN_CONTENT", pd.get("CONTENT"));
|
||
// pd2.put("APPLY_STATUS", pd.get("APPLY_STATUS"));
|
||
// GFconfinedspaceService.edit(pd2);
|
||
// log.put("ACTION", "接受交底人确认");
|
||
// }
|
||
// return map;
|
||
// case "7"://安全交底人确认
|
||
// if (files != null && files.length > 0) {
|
||
// MultipartFile file = files[0];
|
||
//
|
||
// String ffile = DateUtil.getDays();
|
||
// String fileName = this.get32UUID()+file.getOriginalFilename().substring(file.getOriginalFilename().lastIndexOf("."));
|
||
// smb.sshSftp(file, fileName, Const.FILEPATHFILE + pd.getString("CORPINFO_ID") + "/" + ffile);
|
||
//
|
||
// pd2.put("CONFESS_USER_SIGNER_PATH", Const.FILEPATHFILE + pd.getString("CORPINFO_ID") + "/" + ffile + "/" + fileName);
|
||
// pd2.put("CONFESS_USER_SIGNER_TIME", pd.get("SIGNER_TIME"));
|
||
//// pd2.put("GUARDIAN_CONTENT", pd.get("CONTENT"));
|
||
// pd2.put("APPLY_STATUS", pd.get("APPLY_STATUS"));
|
||
// GFconfinedspaceService.edit(pd2);
|
||
// log.put("ACTION", "安全交底人确认");
|
||
// }
|
||
// return map;
|
||
|
||
case "5"://所在单位确认
|
||
if (files != null && files.length > 0) {
|
||
MultipartFile file = files[0];
|
||
|
||
String ffile = DateUtil.getDays();
|
||
String fileName = this.get32UUID()+file.getOriginalFilename().substring(file.getOriginalFilename().lastIndexOf("."));
|
||
smb.sshSftp(file, fileName, Const.FILEPATHFILE + pd.getString("CORPINFO_ID") + "/" + ffile);
|
||
|
||
pd2.put("APPROVE_USER_SIGNER_PATH", Const.FILEPATHFILE + pd.getString("CORPINFO_ID") + "/" + ffile + "/" + fileName);
|
||
pd2.put("APPROVE_USER_SIGNER_TIME", pd.get("SIGNER_TIME"));
|
||
pd2.put("APPROVE_CONTENT", pd.get("CONTENT"));
|
||
pd2.put("APPLY_STATUS", pd.get("APPLY_STATUS"));
|
||
GFconfinedspaceService.edit(pd2);
|
||
log.put("ACTION", "所在单位审批通过");
|
||
|
||
|
||
// 发短信
|
||
PageData mes = new PageData();
|
||
mes.put("RECEIVER_ID", pd2.get("ACCEPT_USER_ID"));// 收信人userid
|
||
mes.put("templateCode", "YX_Y05");// 短信模板编码
|
||
mes.put("SMSCode", "SMS_227245922");// 短信模板编码
|
||
mes.put("CORPINFO_ID", pd2.get("CORPINFO_ID"));// 企业id
|
||
// 参数集合
|
||
List<PageData> paramsList = new ArrayList<PageData>();
|
||
// 第1个参数
|
||
PageData params1 = new PageData();
|
||
params1.put("name", "number");// 存入短信模板中的参数名称
|
||
params1.put("value", pd2.get("CHECK_NO"));// 存入上面参数名称所传递的值
|
||
paramsList.add(params1);
|
||
// 第2个参数
|
||
PageData params2 = new PageData();
|
||
params2.put("name", "params1");// 存入短信模板中的参数名称
|
||
params2.put("value", "有限空间作业");// 存入上面参数名称所传递的值
|
||
paramsList.add(params2);
|
||
// 第3个参数
|
||
PageData params3 = new PageData();
|
||
params3.put("name", "params2");// 存入短信模板中的参数名称
|
||
params3.put("value", "验收");// 存入上面参数名称所传递的值
|
||
paramsList.add(params3);
|
||
// 第4个参数
|
||
PageData params4 = new PageData();
|
||
params4.put("name", "params3");// 存入短信模板中的参数名称
|
||
params4.put("value", "验收");// 存入上面参数名称所传递的值
|
||
paramsList.add(params4);
|
||
sendMessageUtil.sendMessages(mes, paramsList);
|
||
|
||
// // 发短信
|
||
// PageData mes1 = new PageData();
|
||
// mes1.put("RECEIVER_ID", pd2.get("ANALYZE_USER_ID"));// 收信人userid
|
||
// mes1.put("templateCode", "YX_QT");// 短信模板编码
|
||
// mes1.put("SMSCode", "SMS_223540753");// 短信模板编码
|
||
// mes1.put("CORPINFO_ID", pd2.get("CORPINFO_ID"));// 企业id
|
||
// // 参数集合
|
||
// List<PageData> paramsList1 = new ArrayList<PageData>();
|
||
// // 第1个参数
|
||
// PageData params5 = new PageData();
|
||
// params5.put("name", "params1");// 存入短信模板中的参数名称
|
||
// params5.put("value", pd2.get("CHECK_NO"));// 存入上面参数名称所传递的值
|
||
// paramsList1.add(params5);
|
||
// // 第2个参数
|
||
// PageData params6 = new PageData();
|
||
// params6.put("name", "params2");// 存入短信模板中的参数名称
|
||
// params6.put("value", "有限空间作业");// 存入上面参数名称所传递的值
|
||
// paramsList1.add(params6);
|
||
// sendMessageUtil.sendMessages(mes1, paramsList1);
|
||
}
|
||
break;
|
||
|
||
case "6"://验收人
|
||
if (files != null && files.length > 0) {
|
||
MultipartFile file = files[0];
|
||
|
||
String ffile = DateUtil.getDays();
|
||
String fileName = this.get32UUID()+file.getOriginalFilename().substring(file.getOriginalFilename().lastIndexOf("."));
|
||
smb.sshSftp(file, fileName, Const.FILEPATHFILE + pd.getString("CORPINFO_ID") + "/" + ffile);
|
||
|
||
pd2.put("ACCEPT_USER_SIGNER_PATH", Const.FILEPATHFILE + pd.getString("CORPINFO_ID") + "/" + ffile + "/" + fileName);
|
||
pd2.put("ACCEPT_USER_SIGNER_TIME", pd.get("SIGNER_TIME"));
|
||
pd2.put("ACCEPT_CONTENT", pd.get("CONTENT"));
|
||
pd2.put("APPLY_STATUS", pd.get("APPLY_STATUS"));
|
||
GFconfinedspaceService.edit(pd2);
|
||
log.put("ACTION", "验收通过");
|
||
|
||
// 发短信
|
||
PageData mes = new PageData();
|
||
mes.put("RECEIVER_ID", pd2.get("APPLY_USER_ID"));// 收信人userid
|
||
mes.put("templateCode", "YX_Y06");// 短信模板编码
|
||
mes.put("SMSCode", "SMS_227250920");// 短信模板编码
|
||
mes.put("CORPINFO_ID", pd2.get("CORPINFO_ID"));// 企业id
|
||
// 参数集合
|
||
List<PageData> paramsList = new ArrayList<PageData>();
|
||
// 第1个参数
|
||
PageData params1 = new PageData();
|
||
params1.put("name", "number");// 存入短信模板中的参数名称
|
||
params1.put("value", pd2.get("CHECK_NO"));// 存入上面参数名称所传递的值
|
||
paramsList.add(params1);
|
||
// 第2个参数
|
||
PageData params2 = new PageData();
|
||
params2.put("name", "type");// 存入短信模板中的参数名称
|
||
params2.put("value", "有限空间作业");// 存入上面参数名称所传递的值
|
||
paramsList.add(params2);
|
||
sendMessageUtil.sendMessages(mes, paramsList);
|
||
}
|
||
break;
|
||
case "-4"://确认打回
|
||
log.put("ACTION", "作业单位打回");
|
||
pd2.put("APPLY_STATUS", pd.get("APPLY_STATUS"));
|
||
pd2.put("CONFIRM_CONTENT", pd.get("CONTENT"));
|
||
GFconfinedspaceService.edit(pd2);
|
||
|
||
// 发短信
|
||
PageData mes = new PageData();
|
||
mes.put("RECEIVER_ID", pd2.get("APPLY_USER_ID"));// 收信人userid
|
||
mes.put("templateCode", "YX_N04");// 短信模板编码
|
||
mes.put("SMSCode", "SMS_223580715");// 短信模板编码
|
||
mes.put("CORPINFO_ID", pd2.get("CORPINFO_ID"));// 企业id
|
||
// 参数集合
|
||
List<PageData> paramsList = new ArrayList<PageData>();
|
||
// 第1个参数
|
||
PageData params1 = new PageData();
|
||
params1.put("name", "params1");// 存入短信模板中的参数名称
|
||
params1.put("value", pd2.get("CHECK_NO"));// 存入上面参数名称所传递的值
|
||
paramsList.add(params1);
|
||
// 第2个参数
|
||
PageData params2 = new PageData();
|
||
params2.put("name", "params2");// 存入短信模板中的参数名称
|
||
params2.put("value", "有限空间作业");// 存入上面参数名称所传递的值
|
||
paramsList.add(params2);
|
||
// 第3个参数
|
||
PageData params3 = new PageData();
|
||
params3.put("name", "params3");// 存入短信模板中的参数名称
|
||
params3.put("value", "作业单位确认");// 存入上面参数名称所传递的值
|
||
paramsList.add(params3);
|
||
sendMessageUtil.sendMessages(mes, paramsList);
|
||
break;
|
||
// case "-3"://监护人确认打回
|
||
// log.put("ACTION", "监护人打回");
|
||
// pd2.put("APPLY_STATUS", pd.get("APPLY_STATUS"));
|
||
// pd2.put("GUARDIAN_CONTENT", pd.get("CONTENT"));
|
||
// GFconfinedspaceService.edit(pd2);
|
||
//
|
||
// // 发短信
|
||
// PageData mes1 = new PageData();
|
||
// mes1.put("RECEIVER_ID", pd2.get("APPLY_USER_ID"));// 收信人userid
|
||
// mes1.put("templateCode", "SMS_223585680");// 短信模板编码
|
||
// mes1.put("CORPINFO_ID", pd2.get("CORPINFO_ID"));// 企业id
|
||
// // 参数集合
|
||
// List<PageData> paramsList1 = new ArrayList<PageData>();
|
||
// // 第1个参数
|
||
// PageData params4 = new PageData();
|
||
// params4.put("name", "params1");// 存入短信模板中的参数名称
|
||
// params4.put("value", pd2.get("CHECK_NO"));// 存入上面参数名称所传递的值
|
||
// paramsList1.add(params4);
|
||
// // 第2个参数
|
||
// PageData params5 = new PageData();
|
||
// params5.put("name", "params2");// 存入短信模板中的参数名称
|
||
// params5.put("value", "有限空间作业");// 存入上面参数名称所传递的值
|
||
// paramsList1.add(params5);
|
||
// // 第3个参数
|
||
// PageData params6 = new PageData();
|
||
// params6.put("name", "params3");// 存入短信模板中的参数名称
|
||
// params6.put("value", "监护人确认");// 存入上面参数名称所传递的值
|
||
// paramsList1.add(params6);
|
||
// sendMessageUtil.sendMessages(mes1, paramsList1);
|
||
// break;
|
||
// case "-4"://审核部门打回
|
||
// log.put("ACTION", "审核打回");
|
||
// pd2.put("APPLY_STATUS", pd.get("APPLY_STATUS"));
|
||
// pd2.put("AUDIT_CONTENT", pd.get("CONTENT"));
|
||
// GFconfinedspaceService.edit(pd2);
|
||
//
|
||
// // 发短信
|
||
// PageData mes2 = new PageData();
|
||
// mes2.put("RECEIVER_ID", pd2.get("APPLY_USER_ID"));// 收信人userid
|
||
// mes2.put("templateCode", "SMS_223585680");// 短信模板编码
|
||
// mes2.put("CORPINFO_ID", pd2.get("CORPINFO_ID"));// 企业id
|
||
// // 参数集合
|
||
// List<PageData> paramsList2 = new ArrayList<PageData>();
|
||
// // 第1个参数
|
||
// PageData params7 = new PageData();
|
||
// params7.put("name", "params1");// 存入短信模板中的参数名称
|
||
// params7.put("value", pd2.get("CHECK_NO"));// 存入上面参数名称所传递的值
|
||
// paramsList2.add(params7);
|
||
// // 第2个参数
|
||
// PageData params8 = new PageData();
|
||
// params8.put("name", "params2");// 存入短信模板中的参数名称
|
||
// params8.put("value", "有限空间作业");// 存入上面参数名称所传递的值
|
||
// paramsList2.add(params8);
|
||
// // 第3个参数
|
||
// PageData params9 = new PageData();
|
||
// params9.put("name", "params3");// 存入短信模板中的参数名称
|
||
// params9.put("value", "审核部门审核");// 存入上面参数名称所传递的值
|
||
// paramsList2.add(params9);
|
||
// sendMessageUtil.sendMessages(mes2, paramsList2);
|
||
// break;
|
||
case "-5"://所在单位打回
|
||
log.put("ACTION", "所在单位打回");
|
||
pd2.put("APPLY_STATUS", pd.get("APPLY_STATUS"));
|
||
pd2.put("APPROVE_CONTENT", pd.get("CONTENT"));
|
||
GFconfinedspaceService.edit(pd2);
|
||
|
||
// 发短信
|
||
PageData mes3 = new PageData();
|
||
mes3.put("RECEIVER_ID", pd2.get("APPLY_USER_ID"));// 收信人userid
|
||
mes3.put("templateCode", "YX_N05");// 短信模板编码
|
||
mes3.put("SMSCode", "SMS_223580715");// 短信模板编码
|
||
mes3.put("CORPINFO_ID", pd2.get("CORPINFO_ID"));// 企业id
|
||
// 参数集合
|
||
List<PageData> paramsList3 = new ArrayList<PageData>();
|
||
// 第1个参数
|
||
PageData params10 = new PageData();
|
||
params10.put("name", "params1");// 存入短信模板中的参数名称
|
||
params10.put("value", pd2.get("CHECK_NO"));// 存入上面参数名称所传递的值
|
||
paramsList3.add(params10);
|
||
// 第2个参数
|
||
PageData params11 = new PageData();
|
||
params11.put("name", "params2");// 存入短信模板中的参数名称
|
||
params11.put("value", "有限空间作业");// 存入上面参数名称所传递的值
|
||
paramsList3.add(params11);
|
||
// 第3个参数
|
||
PageData params12 = new PageData();
|
||
params12.put("name", "params3");// 存入短信模板中的参数名称
|
||
params12.put("value", "所在单位");// 存入上面参数名称所传递的值
|
||
paramsList3.add(params12);
|
||
sendMessageUtil.sendMessages(mes3, paramsList3);
|
||
break;
|
||
case "-6"://验收人打回
|
||
log.put("ACTION", "验收人打回");
|
||
pd2.put("APPLY_STATUS", pd.get("APPLY_STATUS"));
|
||
pd2.put("ACCEPT_CONTENT", pd.get("CONTENT"));
|
||
GFconfinedspaceService.edit(pd2);
|
||
|
||
// 发短信
|
||
PageData mes4 = new PageData();
|
||
mes4.put("RECEIVER_ID", pd2.get("APPLY_USER_ID"));// 收信人userid
|
||
mes4.put("templateCode", "YX_N06");// 短信模板编码
|
||
mes4.put("SMSCode", "SMS_223580715");// 短信模板编码
|
||
mes4.put("CORPINFO_ID", pd2.get("CORPINFO_ID"));// 企业id
|
||
// 参数集合
|
||
List<PageData> paramsList4 = new ArrayList<PageData>();
|
||
// 第1个参数
|
||
PageData params13 = new PageData();
|
||
params13.put("name", "params1");// 存入短信模板中的参数名称
|
||
params13.put("value", pd2.get("CHECK_NO"));// 存入上面参数名称所传递的值
|
||
paramsList4.add(params13);
|
||
// 第2个参数
|
||
PageData params14 = new PageData();
|
||
params14.put("name", "params2");// 存入短信模板中的参数名称
|
||
params14.put("value", "有限空间作业");// 存入上面参数名称所传递的值
|
||
paramsList4.add(params14);
|
||
// 第3个参数
|
||
PageData params15 = new PageData();
|
||
params15.put("name", "params3");// 存入短信模板中的参数名称
|
||
params15.put("value", "验收人");// 存入上面参数名称所传递的值
|
||
paramsList4.add(params15);
|
||
sendMessageUtil.sendMessages(mes4, paramsList4);
|
||
break;
|
||
default:
|
||
break;
|
||
}
|
||
GFconfinedspaceLogService.save(log);
|
||
this.sendNotice(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 = GFconfinedspaceService.list(page); //列出confinedspace列表
|
||
map.put("varList", varList);
|
||
map.put("page", page);
|
||
map.put("result", errInfo);
|
||
return map;
|
||
}
|
||
|
||
|
||
|
||
/**去修改页面获取数据
|
||
* @param
|
||
* @throws Exception
|
||
*/
|
||
@RequestMapping(value="/gasEdit")
|
||
@ResponseBody
|
||
public Object gasEdit() throws Exception{
|
||
Map<String,Object> map = new HashMap<String,Object>();
|
||
String errInfo = "success";
|
||
PageData pd = new PageData();
|
||
pd = this.getPageData();
|
||
pd = GFconfinedspaceGasService.gasEdit(pd); //根据ID读取
|
||
map.put("pd", pd);
|
||
map.put("result", errInfo);
|
||
return map;
|
||
}
|
||
|
||
/**列表
|
||
* @param page
|
||
* @throws Exception
|
||
*/
|
||
@RequestMapping(value="/jhlist")
|
||
@ResponseBody
|
||
public Object jhlist(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 = GFconfinedspaceService.jhlist(page); //列出confinedspace列表
|
||
map.put("varList", varList);
|
||
map.put("page", page);
|
||
map.put("result", errInfo);
|
||
return map;
|
||
}
|
||
/**列表
|
||
* @param page
|
||
* @throws Exception
|
||
*/
|
||
@RequestMapping(value="/aqlist")
|
||
@ResponseBody
|
||
public Object aqlist(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 = GFconfinedspaceService.aqlist(page); //列出confinedspace列表
|
||
map.put("varList", varList);
|
||
map.put("page", page);
|
||
map.put("result", errInfo);
|
||
return map;
|
||
}
|
||
/**列表
|
||
* @param page
|
||
* @throws Exception
|
||
*/
|
||
@RequestMapping(value="/jslist")
|
||
@ResponseBody
|
||
public Object jslist(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 = GFconfinedspaceService.jslist(page); //列出confinedspace列表
|
||
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 = GFconfinedspaceService.findById(pd); //根据ID读取
|
||
map.put("measuresList", GFconfinedspaceService.listAllMeasures(pd));
|
||
map.put("gasList", GFconfinedspaceGasService.listAll(pd));
|
||
map.put("imgList",confinedspaceacceptuserService.findByIds(pd));
|
||
map.put("imgList1",confinedspaceacceptuserService.findById(pd));
|
||
|
||
map.put("pd", pd);
|
||
map.put("result", errInfo);
|
||
return map;
|
||
}
|
||
|
||
/**去修改页面获取数据
|
||
* @param
|
||
* @throws Exception
|
||
*/
|
||
@RequestMapping(value="/gas/list")
|
||
@ResponseBody
|
||
public Object gasList() throws Exception{
|
||
Map<String,Object> map = new HashMap<String,Object>();
|
||
String errInfo = "success";
|
||
PageData pd = new PageData();
|
||
pd = this.getPageData();
|
||
List<PageData> varList = GFconfinedspaceGasService.listAll(pd); //列出confinedspace列表
|
||
map.put("varList", varList);
|
||
map.put("result", errInfo);
|
||
return map;
|
||
}
|
||
|
||
/**去修改页面获取数据
|
||
* @param
|
||
* @throws Exception
|
||
*/
|
||
@RequestMapping(value="/gas/delete")
|
||
@ResponseBody
|
||
public Object gasDel() throws Exception{
|
||
Map<String,String> map = new HashMap<String,String>();
|
||
String errInfo = "success";
|
||
PageData pd = new PageData();
|
||
pd = this.getPageData();
|
||
GFconfinedspaceGasService.delete(pd);
|
||
map.put("result", errInfo); //返回结果
|
||
return map;
|
||
}
|
||
|
||
/**去修改页面获取数据
|
||
* @param
|
||
* @throws Exception
|
||
*/
|
||
@RequestMapping(value="/gas/save")
|
||
@ResponseBody
|
||
public Object gasSave() throws Exception{
|
||
Map<String,String> map = new HashMap<String,String>();
|
||
String errInfo = "success";
|
||
PageData pd = new PageData();
|
||
pd = this.getPageData();
|
||
pd.put("CONFINEDSPACEGAS_ID", this.get32UUID()); //主键
|
||
pd.put("ISDELETE", "0"); //是否删除 1-是 0-否
|
||
pd.put("OPERATTIME", DateUtil.date2Str(new Date())); //修改时间
|
||
GFconfinedspaceGasService.save(pd);
|
||
confinedspacegaswhService.edittime(pd);
|
||
map.put("result", errInfo); //返回结果
|
||
return map;
|
||
}
|
||
|
||
|
||
/**待办作业数统计
|
||
* @param
|
||
* @throws Exception
|
||
*/
|
||
@RequestMapping(value="/countCheck")
|
||
@ResponseBody
|
||
public Object countCheck() throws Exception{
|
||
Map<String,Object> map = new HashMap<String,Object>();
|
||
String errInfo = "success";
|
||
PageData pd = new PageData();
|
||
pd = this.getPageData();
|
||
PageData count = GFconfinedspaceService.countCheck(pd);
|
||
map.put("result", errInfo);
|
||
map.put("count", count);
|
||
return map;
|
||
}
|
||
}
|