package com.zcloud.controller.gf; import com.alibaba.fastjson.JSON; 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.gf.GFBreakGroundLogService; import com.zcloud.service.gf.GFBreakGroundService; import com.zcloud.service.gf.GFBreakGroundToMeasuresService; import com.zcloud.util.*; import org.apache.commons.lang.StringUtils; import org.springframework.stereotype.Controller; import org.springframework.transaction.annotation.Transactional; import org.springframework.web.bind.annotation.RequestMapping; import org.springframework.web.bind.annotation.RequestParam; import org.springframework.web.bind.annotation.ResponseBody; import org.springframework.web.multipart.MultipartFile; import javax.annotation.Resource; import java.text.DecimalFormat; import java.util.*; /** * 说明:动土作业 * 作者:fjk * 时间:2021-08-27 * 官网:www.zcloudchina.com */ @Controller @RequestMapping("/app/gfBreakGround") public class AppGFBreakGroundController extends BaseController { @Resource private GFBreakGroundService GFbreakGroundService; @Resource private GFBreakGroundLogService GFbreakGroundLogService; @Resource private GFBreakGroundToMeasuresService GFbreakGroundToMeasuresService; @Resource private SendMessageUtil sendMessageUtil; /**获取编码 * @param * @throws Exception */ @RequestMapping(value="/getCode") @ResponseBody // @LogAnno(menuType= "手机",menuServer= "动土作业",instructionsOperate = "动土作业",instructionsType = "获取编码") public Object getCode() throws Exception{ Map map = new HashMap(); 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 = GFbreakGroundService.getCode(pd); //根据ID读取 String code = "DT"+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( @RequestParam(value="FFILE",required=false) MultipartFile[] files ) throws Exception{ Map map = new HashMap(); String errInfo = "success"; PageData pd = new PageData(); pd = this.getPageData(); pd.put("BREAKGROUND_ID", this.get32UUID()); //主键 pd.put("CREATTIME", DateUtil.date2Str(new Date())); //添加时间 pd.put("ISDELETE", "0"); //是否删除 1-是 0-否 pd.put("OTHER_PROTECTIVE_MEASURES", (StringUtils.isNotBlank(pd.getString("OTHER_PROTECTIVE_MEASURES")) ? pd.getString("OTHER_PROTECTIVE_MEASURES") : "") + ";_;"); pd.put("HAZARD_IDENTIFICATION", (StringUtils.isNotBlank(pd.getString("HAZARD_IDENTIFICATION")) ? pd.getString("HAZARD_IDENTIFICATION") : "") + ";_;"); 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); pd.put("APPLY_USER_SIGNER_PATH", Const.FILEPATHFILE + pd.getString("CORPINFO_ID") + "/" + ffile + "/" + fileName); pd.put("APPLY_USER_SIGNER_TIME", pd.get("SIGNER_TIME")); } GFbreakGroundService.save(pd); GFbreakGroundToMeasuresService.delete(pd); if(pd.get("measuresList")!=null){ List list = (List) JSON.parse(pd.get("measuresList").toString()); for (JSONObject json : list) { PageData measures = new PageData(); measures.put("BREAKGROUNDTOMEASURES_ID", this.get32UUID()); // 主键 measures.put("BREAKGROUND_ID", pd.get("BREAKGROUND_ID")); measures.put("BUS_BREAKGROUND_MEASURES_ID", json.get("BUS_BREAKGROUND_MEASURES_ID")); measures.put("STATUS", json.get("STATUS")); measures.put("ANSWER", json.get("ANSWER")); measures.put("CONFIRM_ID", pd.get("OPERATOR")); measures.put("CONFIRM_NAME", pd.get("ACTION_USER")); GFbreakGroundToMeasuresService.save(measures); } } if(pd.get("APPLY_STATUS").equals("1")) { PageData log = new PageData(); log.put("BREAKGROUNDLOG_ID", this.get32UUID()); log.put("ACTION", "提交申请"); log.put("BREAKGROUND_ID", pd.get("BREAKGROUND_ID")); log.put("CREATOR",pd.get("ACTION_USER")); log.put("CREATTIME", DateUtil.date2Str(new Date())); GFbreakGroundLogService.save(log); // 发短信 PageData mes = new PageData(); mes.put("RECEIVER_ID", pd.get("CONSTRUCTION_USER_ID"));// 收信人userid mes.put("templateCode", "DT_Y01");// 短信模板编码 mes.put("SMSCode", "SMS_227245922");// 短信模板编码 mes.put("CORPINFO_ID", pd.get("CORPINFO_ID"));// 企业id // 参数集合 List paramsList = new ArrayList(); // 第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); } 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 map = new HashMap(); String errInfo = "success"; PageData pd = new PageData(); pd = this.getPageData(); PageData pd2 = new PageData(); pd2 = GFbreakGroundService.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")); GFbreakGroundService.edit(pd2); } 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 map = new HashMap(); String errInfo = "success"; PageData pd = new PageData(); pd = this.getPageData(); PageData pd2 = new PageData(); pd2 = GFbreakGroundService.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")); GFbreakGroundService.edit(pd2); } map.put("result", errInfo); return map; } /**修改 * @param * @throws Exception */ @RequestMapping(value="/editAcceptconfess") @ResponseBody @Transactional public Object editAcceptconfess( @RequestParam(value="FFILE",required=false) MultipartFile[] files ) throws Exception { Map map = new HashMap(); String errInfo = "success"; PageData pd = new PageData(); pd = this.getPageData(); PageData pd2 = new PageData(); pd2 = GFbreakGroundService.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")); GFbreakGroundService.edit(pd2); } map.put("result", errInfo); return map; } /**上传图 * @param * @throws Exception */ @RequestMapping(value="/uploadImg") @ResponseBody @Transactional public Object uploadImg( @RequestParam(value="FFILE",required=false) MultipartFile[] files ) throws Exception{ Map map = new HashMap(); String errInfo = "success"; PageData pd = new PageData(); pd = this.getPageData(); 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); map.put("path", Const.FILEPATHFILE + pd.getString("CORPINFO_ID") + "/" + ffile + "/" + fileName); } map.put("result", errInfo); return map; } /**删除图 * @param * @throws Exception */ @RequestMapping(value="/deleteImg") @ResponseBody @Transactional public Object deleteImg() throws Exception{ Map map = new HashMap(); String errInfo = "success"; PageData pd = new PageData(); pd = this.getPageData(); Smb.deleteFile(pd.getString("path")); map.put("result", errInfo); return map; } /**删除 * @param out * @throws Exception */ @RequestMapping(value="/delete") @ResponseBody public Object delete() throws Exception{ Map map = new HashMap(); String errInfo = "success"; PageData pd = new PageData(); pd = this.getPageData(); GFbreakGroundService.delete(pd); map.put("result", errInfo); //返回结果 return map; } /**修改 * @param * @throws Exception */ @RequestMapping(value="/edit") @ResponseBody @Transactional public Object edit( @RequestParam(value="FFILE",required=false) MultipartFile[] files ) throws Exception{ Map map = new HashMap(); String errInfo = "success"; PageData pd = new PageData(); pd = this.getPageData(); pd.put("OPERATTIME", DateUtil.date2Str(new Date())); //修改时间 pd.put("OTHER_PROTECTIVE_MEASURES", (StringUtils.isNotBlank(pd.getString("OTHER_PROTECTIVE_MEASURES")) ? pd.getString("OTHER_PROTECTIVE_MEASURES") : "") + ";_;"); pd.put("HAZARD_IDENTIFICATION", (StringUtils.isNotBlank(pd.getString("HAZARD_IDENTIFICATION")) ? pd.getString("HAZARD_IDENTIFICATION") : "") + ";_;"); 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); pd.put("APPLY_USER_SIGNER_PATH", Const.FILEPATHFILE + pd.getString("CORPINFO_ID") + "/" + ffile + "/" + fileName); pd.put("APPLY_USER_SIGNER_TIME", pd.get("SIGNER_TIME")); } GFbreakGroundService.edit(pd); GFbreakGroundToMeasuresService.delete(pd); if(pd.get("measuresList")!=null){ List list = (List) JSON.parse(pd.get("measuresList").toString()); for (JSONObject json : list) { PageData measures = new PageData(); measures.put("BREAKGROUNDTOMEASURES_ID", this.get32UUID()); // 主键 measures.put("BREAKGROUND_ID", pd.get("BREAKGROUND_ID")); measures.put("BUS_BREAKGROUND_MEASURES_ID", json.get("BUS_BREAKGROUND_MEASURES_ID")); measures.put("STATUS", json.get("STATUS")); measures.put("ANSWER", json.get("ANSWER")); measures.put("CONFIRM_ID", pd.get("OPERATOR")); measures.put("CONFIRM_NAME", pd.get("ACTION_USER")); GFbreakGroundToMeasuresService.save(measures); } } if(!pd.get("APPLY_STATUS").equals("0")) { PageData log = new PageData(); log.put("BREAKGROUNDLOG_ID", this.get32UUID()); log.put("ACTION", "修改申请,重新提交"); log.put("BREAKGROUND_ID", pd.get("BREAKGROUND_ID")); log.put("CREATOR",pd.get("ACTION_USER")); log.put("CREATTIME", DateUtil.date2Str(new Date())); GFbreakGroundLogService.save(log); // 发短信 PageData mes = new PageData(); mes.put("RECEIVER_ID", pd.get("CONSTRUCTION_USER_ID"));// 收信人userid mes.put("templateCode", "DT_Y01");// 短信模板编码 mes.put("SMSCode", "SMS_227245922");// 短信模板编码 mes.put("CORPINFO_ID", pd.get("CORPINFO_ID"));// 企业id // 参数集合 List paramsList = new ArrayList(); // 第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); } map.put("result", errInfo); return map; } /**修改 * @param * @throws Exception */ @RequestMapping(value="/editStatus") @ResponseBody @Transactional public Object editStatus( @RequestParam(value="FFILE",required=false) MultipartFile[] files ) throws Exception{ Map map = new HashMap(); String errInfo = "success"; PageData pd = new PageData(); pd = this.getPageData(); PageData pd2 = new PageData(); pd2 = GFbreakGroundService.findById(pd); pd2.put("OPERATOR", pd.get("OPERATOR")); //修改人 pd2.put("OPERATTIME", DateUtil.date2Str(new Date())); //修改时间 PageData log = new PageData(); log.put("BREAKGROUNDLOG_ID", this.get32UUID()); // log.put("ACTION", "审核打回"); log.put("BREAKGROUND_ID", pd.get("BREAKGROUND_ID")); log.put("CREATOR",pd.get("ACTION_USER")); log.put("CREATTIME", DateUtil.date2Str(new Date())); String status = pd.get("STATUS").toString(); String 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") + ";_;") : ";_;"); String HAZARD_IDENTIFICATION = (StringUtils.isNotBlank(pd2.getString("HAZARD_IDENTIFICATION")) ? pd2.getString("HAZARD_IDENTIFICATION") : "") + (StringUtils.isNotBlank(pd.getString("HAZARD_IDENTIFICATION")) ? (pd.getString("HAZARD_IDENTIFICATION") + ";_;") : ";_;"); //打回清空数据 pd2.put("OTHER_PROTECTIVE_MEASURES", ""); pd2.put("HAZARD_IDENTIFICATION", ""); switch (status) { 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("CONSTRUCTION_USER_SIGNER_PATH", Const.FILEPATHFILE + pd.getString("CORPINFO_ID") + "/" + ffile + "/" + fileName); pd2.put("CONSTRUCTION_USER_SIGNER_TIME", pd.get("SIGNER_TIME")); pd2.put("CONSTRUCTION_CONTENT", pd.get("CONTENT")); if (pd2.get("PRODUCTION_USER_ID") == null || StringUtils.isBlank(pd2.getString("PRODUCTION_USER_ID"))) { OTHER_PROTECTIVE_MEASURES += ";_;"; HAZARD_IDENTIFICATION += ";_;"; if (pd2.get("SAFETY_USER_ID") == null || StringUtils.isBlank(pd2.getString("SAFETY_USER_ID"))) { OTHER_PROTECTIVE_MEASURES += ";_;"; HAZARD_IDENTIFICATION += ";_;"; if (pd2.get("LEADER_USER_ID") == null || StringUtils.isBlank(pd2.getString("LEADER_USER_ID"))) { OTHER_PROTECTIVE_MEASURES += ";_;"; HAZARD_IDENTIFICATION += ";_;"; } } } pd2.put("OTHER_PROTECTIVE_MEASURES", OTHER_PROTECTIVE_MEASURES); pd2.put("HAZARD_IDENTIFICATION", HAZARD_IDENTIFICATION); pd2.put("APPLY_STATUS", pd.get("APPLY_STATUS")); GFbreakGroundService.edit(pd2); log.put("ACTION", "作业负责单位通过"); // 发短信 this.switchMessages(pd.get("APPLY_STATUS").toString(),pd2); } 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("PRODUCTION_USER_SIGNER_PATH", Const.FILEPATHFILE + pd.getString("CORPINFO_ID") + "/" + ffile + "/" + fileName); pd2.put("PRODUCTION_USER_SIGNER_TIME", pd.get("SIGNER_TIME")); pd2.put("PRODUCTION_CONTENT", pd.get("CONTENT")); if (pd2.get("SAFETY_USER_ID") == null || StringUtils.isBlank(pd2.getString("SAFETY_USER_ID"))) { OTHER_PROTECTIVE_MEASURES += ";_;"; HAZARD_IDENTIFICATION += ";_;"; if (pd2.get("LEADER_USER_ID") == null || StringUtils.isBlank(pd2.getString("LEADER_USER_ID"))) { OTHER_PROTECTIVE_MEASURES += ";_;"; HAZARD_IDENTIFICATION += ";_;"; } } pd2.put("OTHER_PROTECTIVE_MEASURES", OTHER_PROTECTIVE_MEASURES); pd2.put("HAZARD_IDENTIFICATION", HAZARD_IDENTIFICATION); pd2.put("APPLY_STATUS", pd.get("APPLY_STATUS")); GFbreakGroundService.edit(pd2); log.put("ACTION", "所在单位通过"); // 发短信 this.switchMessages(pd.get("APPLY_STATUS").toString(),pd2); } 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("SAFETY_USER_SIGNER_PATH", Const.FILEPATHFILE + pd.getString("CORPINFO_ID") + "/" + ffile + "/" + fileName); pd2.put("SAFETY_USER_SIGNER_TIME", pd.get("SIGNER_TIME")); pd2.put("SAFETY_CONTENT", pd.get("CONTENT")); if (pd2.get("LEADER_USER_ID") == null || StringUtils.isBlank(pd2.getString("LEADER_USER_ID"))) { OTHER_PROTECTIVE_MEASURES += ";_;"; HAZARD_IDENTIFICATION += ";_;"; } pd2.put("OTHER_PROTECTIVE_MEASURES", OTHER_PROTECTIVE_MEASURES); pd2.put("HAZARD_IDENTIFICATION", HAZARD_IDENTIFICATION); pd2.put("APPLY_STATUS", pd.get("APPLY_STATUS")); GFbreakGroundService.edit(pd2); log.put("ACTION", "安全部门通过"); // 发短信 this.switchMessages(pd.get("APPLY_STATUS").toString(),pd2); } break; 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("LEADER_USER_SIGNER_PATH", Const.FILEPATHFILE + pd.getString("CORPINFO_ID") + "/" + ffile + "/" + fileName); pd2.put("LEADER_USER_SIGNER_TIME", pd.get("SIGNER_TIME")); pd2.put("LEADER_CONTENT", pd.get("CONTENT")); pd2.put("OTHER_PROTECTIVE_MEASURES", OTHER_PROTECTIVE_MEASURES); pd2.put("HAZARD_IDENTIFICATION", HAZARD_IDENTIFICATION); pd2.put("APPLY_STATUS", pd.get("APPLY_STATUS")); GFbreakGroundService.edit(pd2); log.put("ACTION", "审批部门通过"); // 发短信 this.switchMessages(pd.get("APPLY_STATUS").toString(),pd2); } 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("OTHER_PROTECTIVE_MEASURES", OTHER_PROTECTIVE_MEASURES); pd2.put("HAZARD_IDENTIFICATION", HAZARD_IDENTIFICATION); pd2.put("APPLY_STATUS", pd.get("APPLY_STATUS")); GFbreakGroundService.edit(pd2); log.put("ACTION", "验收通过"); // 发短信 this.switchMessages(pd.get("APPLY_STATUS").toString(),pd2); } break; case "-2"://作业负责单位 log.put("ACTION", "作业负责单位打回"); pd2.put("APPLY_STATUS", pd.get("APPLY_STATUS")); pd2.put("CONSTRUCTION_CONTENT", pd.get("CONTENT")); GFbreakGroundService.edit(pd2); // 发短信 this.switchMessages(pd.get("APPLY_STATUS").toString(),pd2); break; case "-3"://所在单位打回 log.put("ACTION", "所在单位打回"); pd2.put("APPLY_STATUS", pd.get("APPLY_STATUS")); pd2.put("PRODUCTION_CONTENT", pd.get("CONTENT")); GFbreakGroundService.edit(pd2); // 发短信 this.switchMessages(pd.get("APPLY_STATUS").toString(),pd2); break; case "-4"://安全部门打回 log.put("ACTION", "安全部门打回"); pd2.put("APPLY_STATUS", pd.get("APPLY_STATUS")); pd2.put("SAFETY_CONTENT", pd.get("CONTENT")); GFbreakGroundService.edit(pd2); // 发短信 this.switchMessages(pd.get("APPLY_STATUS").toString(),pd2); break; case "-5"://审批打回 log.put("ACTION", "审批部门打回"); pd2.put("APPLY_STATUS", pd.get("APPLY_STATUS")); pd2.put("LEADER_CONTENT", pd.get("CONTENT")); GFbreakGroundService.edit(pd2); // 发短信 this.switchMessages(pd.get("APPLY_STATUS").toString(),pd2); break; case "-6"://审批打回 log.put("ACTION", "验收人打回"); pd2.put("APPLY_STATUS", pd.get("APPLY_STATUS")); pd2.put("ACCEPT_CONTENT", pd.get("CONTENT")); GFbreakGroundService.edit(pd2); // 发短信 this.switchMessages(pd.get("APPLY_STATUS").toString(),pd2); break; default: break; } GFbreakGroundLogService.save(log); map.put("result", errInfo); return map; } /**列表 * @param page * @throws Exception */ @RequestMapping(value="/jhlist") @ResponseBody public Object jhlist(Page page) throws Exception{ Map map = new HashMap(); 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 varList = GFbreakGroundService.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 map = new HashMap(); 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 varList = GFbreakGroundService.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 map = new HashMap(); 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 varList = GFbreakGroundService.jslist(page); //列出confinedspace列表 map.put("varList", varList); map.put("page", page); map.put("result", errInfo); return map; } /**列表 * @param page * @throws Exception */ @RequestMapping(value="/list") @ResponseBody public Object list(Page page) throws Exception{ Map map = new HashMap(); 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 varList = GFbreakGroundService.list(page); //列出BreakGround列表 map.put("varList", varList); map.put("page", page); map.put("result", errInfo); return map; } /**去修改页面获取数据 * @param * @throws Exception */ @RequestMapping(value="/goAdd") @ResponseBody public Object goAdd() throws Exception{ Map map = new HashMap(); String errInfo = "success"; PageData pd = new PageData(); map.put("measuresList", GFbreakGroundService.listAllMeasures(pd)); map.put("result", errInfo); return map; } /**去修改页面获取数据 * @param * @throws Exception */ @RequestMapping(value="/goEdit") @ResponseBody public Object goEdit() throws Exception{ Map map = new HashMap(); String errInfo = "success"; PageData pd = new PageData(); pd = this.getPageData(); pd = GFbreakGroundService.findById(pd); //根据ID读取 map.put("pd", pd); map.put("measuresList", GFbreakGroundService.listAllMeasures(pd)); map.put("result", errInfo); return map; } /**批量删除 * @param * @throws Exception */ @RequestMapping(value="/deleteAll") @ResponseBody public Object deleteAll() throws Exception{ Map map = new HashMap(); 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(","); GFbreakGroundService.deleteAll(ArrayDATA_IDS); errInfo = "success"; }else{ errInfo = "error"; } map.put("result", errInfo); //返回结果 return map; } /** * 选择短信模板 * @param appStatus 阶段 * @param pd2 参数集合 * @throws Exception */ private void switchMessages(String appStatus, PageData pd2) throws Exception { PageData mes = new PageData(); List paramsList = new ArrayList(); PageData params1 = new PageData(); PageData params2 = new PageData(); PageData params3 = new PageData(); PageData params4 = new PageData(); switch (appStatus) { case "2"://作业负责单位 System.out.println(pd2.get("APPLY_STATUS")); if("2".equals(pd2.get("APPLY_STATUS"))){ mes.put("RECEIVER_ID", pd2.get("PRODUCTION_USER_ID"));// 收信人userid mes.put("templateCode", "DT_Y02");// 短信模板编码 mes.put("SMSCode", "SMS_227245922");// 短信模板编码 mes.put("CORPINFO_ID", pd2.get("CORPINFO_ID"));// 企业id }else if("3".equals(pd2.get("APPLY_STATUS"))){ mes.put("RECEIVER_ID", pd2.get("SAFETY_USER_ID"));// 收信人userid mes.put("templateCode", "DT_Y03");// 短信模板编码 mes.put("SMSCode", "SMS_227245922");// 短信模板编码 mes.put("CORPINFO_ID", pd2.get("CORPINFO_ID"));// 企业id }else if("4".equals(pd2.get("APPLY_STATUS"))){ mes.put("RECEIVER_ID", pd2.get("LEADER_USER_ID"));// 收信人userid mes.put("templateCode", "DT_Y04");// 短信模板编码 mes.put("SMSCode", "SMS_227245922");// 短信模板编码 mes.put("CORPINFO_ID", pd2.get("CORPINFO_ID"));// 企业id }else if("5".equals(pd2.get("APPLY_STATUS"))){ mes.put("RECEIVER_ID", pd2.get("ACCEPT_USER_ID"));// 收信人userid mes.put("templateCode", "DT_Y05");// 短信模板编码 mes.put("SMSCode", "SMS_227245922");// 短信模板编码 mes.put("CORPINFO_ID", pd2.get("CORPINFO_ID"));// 企业id }else if("6".equals(pd2.get("APPLY_STATUS"))){ mes.put("RECEIVER_ID", pd2.get("APPLY_USER_ID"));// 收信人userid mes.put("templateCode", "DT_Y06");// 短信模板编码 mes.put("SMSCode", "SMS_227250920");// 短信模板编码 mes.put("CORPINFO_ID", pd2.get("CORPINFO_ID"));// 企业id } // 发短信 // 第1个参数 params1.put("name", "number");// 存入短信模板中的参数名称 params1.put("value", pd2.get("CHECK_NO"));// 存入上面参数名称所传递的值 paramsList.add(params1); // 第2个参数 params2.put("name", "params1");// 存入短信模板中的参数名称 params2.put("value", "动土作业");// 存入上面参数名称所传递的值 paramsList.add(params2); // 第3个参数 params3.put("name", "params2");// 存入短信模板中的参数名称 params3.put("value", "所在单位");// 存入上面参数名称所传递的值 paramsList.add(params3); // 第4个参数 params4.put("name", "params3");// 存入短信模板中的参数名称 params4.put("value", "审核");// 存入上面参数名称所传递的值 paramsList.add(params4); sendMessageUtil.sendMessages(mes, paramsList); break; case "3"://所在单位 System.out.println(pd2.get("APPLY_STATUS")); if("3".equals(pd2.get("APPLY_STATUS"))){ mes.put("RECEIVER_ID", pd2.get("SAFETY_USER_ID"));// 收信人userid mes.put("templateCode", "DT_Y03");// 短信模板编码 mes.put("SMSCode", "SMS_227245922");// 短信模板编码 mes.put("CORPINFO_ID", pd2.get("CORPINFO_ID"));// 企业id }else if("4".equals(pd2.get("APPLY_STATUS"))){ mes.put("RECEIVER_ID", pd2.get("LEADER_USER_ID"));// 收信人userid mes.put("templateCode", "DT_Y04");// 短信模板编码 mes.put("SMSCode", "SMS_227245922");// 短信模板编码 mes.put("CORPINFO_ID", pd2.get("CORPINFO_ID"));// 企业id }else if("5".equals(pd2.get("APPLY_STATUS"))){ mes.put("RECEIVER_ID", pd2.get("ACCEPT_USER_ID"));// 收信人userid mes.put("templateCode", "DT_Y05");// 短信模板编码 mes.put("SMSCode", "SMS_227245922");// 短信模板编码 mes.put("CORPINFO_ID", pd2.get("CORPINFO_ID"));// 企业id }else if("6".equals(pd2.get("APPLY_STATUS"))){ mes.put("RECEIVER_ID", pd2.get("APPLY_USER_ID"));// 收信人userid mes.put("templateCode", "DT_Y06");// 短信模板编码 mes.put("SMSCode", "SMS_227250920");// 短信模板编码 mes.put("CORPINFO_ID", pd2.get("CORPINFO_ID"));// 企业id } // 发短信 // 第1个参数 params1.put("name", "number");// 存入短信模板中的参数名称 params1.put("value", pd2.get("CHECK_NO"));// 存入上面参数名称所传递的值 paramsList.add(params1); // 第2个参数 params2.put("name", "params1");// 存入短信模板中的参数名称 params2.put("value", "动土作业");// 存入上面参数名称所传递的值 paramsList.add(params2); // 第3个参数 params3.put("name", "params2");// 存入短信模板中的参数名称 params3.put("value", "安全部门");// 存入上面参数名称所传递的值 paramsList.add(params3); // 第4个参数 params4.put("name", "params3");// 存入短信模板中的参数名称 params4.put("value", "审核");// 存入上面参数名称所传递的值 paramsList.add(params4); sendMessageUtil.sendMessages(mes, paramsList); break; case "4"://安全部门 System.out.println(pd2.get("APPLY_STATUS")); if("4".equals(pd2.get("APPLY_STATUS"))){ mes.put("RECEIVER_ID", pd2.get("LEADER_USER_ID"));// 收信人userid mes.put("templateCode", "DT_Y04");// 短信模板编码 mes.put("SMSCode", "SMS_227245922");// 短信模板编码 mes.put("CORPINFO_ID", pd2.get("CORPINFO_ID"));// 企业id }else if("5".equals(pd2.get("APPLY_STATUS"))){ mes.put("RECEIVER_ID", pd2.get("LEADER_USER_ID"));// 收信人userid mes.put("templateCode", "DT_Y05");// 短信模板编码 mes.put("SMSCode", "SMS_227245922");// 短信模板编码 mes.put("CORPINFO_ID", pd2.get("CORPINFO_ID"));// 企业id }else if("6".equals(pd2.get("APPLY_STATUS"))){ mes.put("RECEIVER_ID", pd2.get("ACCEPT_USER_ID"));// 收信人userid mes.put("templateCode", "DT_Y06");// 短信模板编码 mes.put("SMSCode", "SMS_227250920");// 短信模板编码 mes.put("CORPINFO_ID", pd2.get("CORPINFO_ID"));// 企业id } // 发短信 // 第1个参数 params1.put("name", "number");// 存入短信模板中的参数名称 params1.put("value", pd2.get("CHECK_NO"));// 存入上面参数名称所传递的值 paramsList.add(params1); // 第2个参数 params2.put("name", "params1");// 存入短信模板中的参数名称 params2.put("value", "动土作业");// 存入上面参数名称所传递的值 paramsList.add(params2); // 第3个参数 params3.put("name", "params2");// 存入短信模板中的参数名称 params3.put("value", "审批部门");// 存入上面参数名称所传递的值 paramsList.add(params3); // 第4个参数 params4.put("name", "params3");// 存入短信模板中的参数名称 params4.put("value", "审批");// 存入上面参数名称所传递的值 paramsList.add(params4); sendMessageUtil.sendMessages(mes, paramsList); break; case "5"://审批部门 System.out.println(pd2.get("APPLY_STATUS")); if("5".equals(pd2.get("APPLY_STATUS"))){ mes.put("RECEIVER_ID", pd2.get("ACCEPT_USER_ID"));// 收信人userid mes.put("templateCode", "DT_Y05");// 短信模板编码 mes.put("SMSCode", "SMS_227245922");// 短信模板编码 mes.put("CORPINFO_ID", pd2.get("CORPINFO_ID"));// 企业id }else if("6".equals(pd2.get("APPLY_STATUS"))){ mes.put("RECEIVER_ID", pd2.get("APPLY_USER_ID"));// 收信人userid mes.put("templateCode", "DT_Y06");// 短信模板编码 mes.put("SMSCode", "SMS_227250920");// 短信模板编码 mes.put("CORPINFO_ID", pd2.get("CORPINFO_ID"));// 企业id } // 第1个参数 params1.put("name", "number");// 存入短信模板中的参数名称 params1.put("value", pd2.get("CHECK_NO"));// 存入上面参数名称所传递的值 paramsList.add(params1); // 第2个参数 params2.put("name", "params1");// 存入短信模板中的参数名称 params2.put("value", "动土作业");// 存入上面参数名称所传递的值 paramsList.add(params2); // 第3个参数 params3.put("name", "params2");// 存入短信模板中的参数名称 params3.put("value", "验收");// 存入上面参数名称所传递的值 paramsList.add(params3); // 第4个参数 params4.put("name", "params3");// 存入短信模板中的参数名称 params4.put("value", "验收");// 存入上面参数名称所传递的值 paramsList.add(params4); sendMessageUtil.sendMessages(mes, paramsList); break; case "6"://验收人 System.out.println(pd2.get("APPLY_STATUS")); // 发短信 mes.put("RECEIVER_ID", pd2.get("APPLY_USER_ID"));// 收信人userid mes.put("templateCode", "DT_Y06");// 短信模板编码 mes.put("SMSCode", "SMS_227250920");// 短信模板编码 mes.put("CORPINFO_ID", pd2.get("CORPINFO_ID"));// 企业id // 第1个参数 params1.put("name", "number");// 存入短信模板中的参数名称 params1.put("value", pd2.get("CHECK_NO"));// 存入上面参数名称所传递的值 paramsList.add(params1); // 第2个参数 params2.put("name", "type");// 存入短信模板中的参数名称 params2.put("value", "动土作业");// 存入上面参数名称所传递的值 paramsList.add(params2); sendMessageUtil.sendMessages(mes, paramsList); break; case "-2"://作业负责单位 // 发短信 mes.put("RECEIVER_ID", pd2.get("APPLY_USER_ID"));// 收信人userid mes.put("templateCode", "DT_N02");// 短信模板编码 mes.put("SMSCode", "SMS_223580715");// 短信模板编码 mes.put("CORPINFO_ID", pd2.get("CORPINFO_ID"));// 企业id // 第1个参数 params1.put("name", "params1");// 存入短信模板中的参数名称 params1.put("value", pd2.get("CHECK_NO"));// 存入上面参数名称所传递的值 paramsList.add(params1); // 第2个参数 params2.put("name", "params2");// 存入短信模板中的参数名称 params2.put("value", "动土作业");// 存入上面参数名称所传递的值 paramsList.add(params2); // 第3个参数 params3.put("name", "params3");// 存入短信模板中的参数名称 params3.put("value", "作业负责单位");// 存入上面参数名称所传递的值 paramsList.add(params3); sendMessageUtil.sendMessages(mes, paramsList); break; case "-3"://所在单位打回 // 发短信 mes.put("RECEIVER_ID", pd2.get("APPLY_USER_ID"));// 收信人userid mes.put("templateCode", "DT_N03");// 短信模板编码 mes.put("SMSCode", "SMS_223580715");// 短信模板编码 mes.put("CORPINFO_ID", pd2.get("CORPINFO_ID"));// 企业id // 第1个参数 params1.put("name", "params1");// 存入短信模板中的参数名称 params1.put("value", pd2.get("CHECK_NO"));// 存入上面参数名称所传递的值 paramsList.add(params1); // 第2个参数 params2.put("name", "params2");// 存入短信模板中的参数名称 params2.put("value", "动土作业");// 存入上面参数名称所传递的值 paramsList.add(params2); // 第3个参数 params3.put("name", "params3");// 存入短信模板中的参数名称 params3.put("value", "所在单位意见");// 存入上面参数名称所传递的值 paramsList.add(params3); sendMessageUtil.sendMessages(mes, paramsList); break; case "-4"://安全部门打回 // 发短信 mes.put("RECEIVER_ID", pd2.get("APPLY_USER_ID"));// 收信人userid mes.put("templateCode", "DT_N04");// 短信模板编码 mes.put("SMSCode", "SMS_223580715");// 短信模板编码 mes.put("CORPINFO_ID", pd2.get("CORPINFO_ID"));// 企业id // 第1个参数 params1.put("name", "params1");// 存入短信模板中的参数名称 params1.put("value", pd2.get("CHECK_NO"));// 存入上面参数名称所传递的值 paramsList.add(params1); // 第2个参数 params2.put("name", "params2");// 存入短信模板中的参数名称 params2.put("value", "动土作业");// 存入上面参数名称所传递的值 paramsList.add(params2); // 第3个参数 params3.put("name", "params3");// 存入短信模板中的参数名称 params3.put("value", "安全部门");// 存入上面参数名称所传递的值 paramsList.add(params3); sendMessageUtil.sendMessages(mes, paramsList); break; case "-5"://审批打回 // 发短信 mes.put("RECEIVER_ID", pd2.get("APPLY_USER_ID"));// 收信人userid mes.put("templateCode", "DT_N05");// 短信模板编码 mes.put("SMSCode", "SMS_223580715");// 短信模板编码 mes.put("CORPINFO_ID", pd2.get("CORPINFO_ID"));// 企业id // 第1个参数 params1.put("name", "params1");// 存入短信模板中的参数名称 params1.put("value", pd2.get("CHECK_NO"));// 存入上面参数名称所传递的值 paramsList.add(params1); // 第2个参数 params2.put("name", "params2");// 存入短信模板中的参数名称 params2.put("value", "动土作业");// 存入上面参数名称所传递的值 paramsList.add(params2); // 第3个参数 params3.put("name", "params3");// 存入短信模板中的参数名称 params3.put("value", "审批部门");// 存入上面参数名称所传递的值 paramsList.add(params3); sendMessageUtil.sendMessages(mes, paramsList); break; case "-6"://验收打回 // 发短信 mes.put("RECEIVER_ID", pd2.get("APPLY_USER_ID"));// 收信人userid mes.put("templateCode", "DT_N06");// 短信模板编码 mes.put("SMSCode", "SMS_223580715");// 短信模板编码 mes.put("CORPINFO_ID", pd2.get("CORPINFO_ID"));// 企业id // 第1个参数 params1.put("name", "params1");// 存入短信模板中的参数名称 params1.put("value", pd2.get("CHECK_NO"));// 存入上面参数名称所传递的值 paramsList.add(params1); // 第2个参数 params2.put("name", "params2");// 存入短信模板中的参数名称 params2.put("value", "动土作业");// 存入上面参数名称所传递的值 paramsList.add(params2); // 第3个参数 params3.put("name", "params3");// 存入短信模板中的参数名称 params3.put("value", "验收部门");// 存入上面参数名称所传递的值 paramsList.add(params3); sendMessageUtil.sendMessages(mes, paramsList); break; default: break; } } /**待办作业数统计 * @param * @throws Exception */ @RequestMapping(value="/countCheck") @ResponseBody public Object countCheck() throws Exception{ Map map = new HashMap(); String errInfo = "success"; PageData pd = new PageData(); pd = this.getPageData(); PageData count = GFbreakGroundService.countCheck(pd); map.put("result", errInfo); map.put("count", count); return map; } }