diff --git a/src/main/java/com/customization/htxc/cgty/UpdateDt1Cmd.java b/src/main/java/com/customization/htxc/cgty/UpdateDt1Cmd.java new file mode 100644 index 0000000..aa9e38a --- /dev/null +++ b/src/main/java/com/customization/htxc/cgty/UpdateDt1Cmd.java @@ -0,0 +1,161 @@ +package com.customization.htxc.cgty; + +import com.engine.core.cfg.annotation.CommandDynamicProxy; +import com.engine.core.interceptor.AbstractCommandProxy; +import com.engine.core.interceptor.Command; +import com.engine.integration.util.StringUtils; +import com.engine.workflow.cmd.requestForm.RequestSubmitCmd; +import com.engine.workflow.entity.requestForm.RequestOperationResultBean; +import weaver.conn.RecordSet; +import weaver.conn.RecordSetTrans; +import weaver.general.BaseBean; +import weaver.general.Util; +import weaver.interfaces.htsc.comInfo.PropBean; + +import javax.servlet.http.HttpServletRequest; +import java.time.Duration; +import java.time.LocalDateTime; +import java.time.format.DateTimeFormatter; +import java.util.ArrayList; +import java.util.Map; +import java.util.Objects; + +/** + * @Title: ecology-9 + * @Company: 泛微软件 + * @author: K1810027 + * @version: 1.0 + * @CreateDate: 2022-08-18 16:55 + * @Description:这个是用来修改采购的7条流程分送出来的自由节点处理人更新到采购项目的明细表1 + * @ModifyLog: + **/ +@CommandDynamicProxy(target = RequestSubmitCmd.class, desc = "流程提交处理业务") +public class UpdateDt1Cmd extends AbstractCommandProxy> { + private static ArrayList unnumberList = new ArrayList(); + private static ArrayList nodeList = new ArrayList(); + static{ + unnumberList.add("zbhb"); + unnumberList.add("zbqs"); + unnumberList.add("swtp"); + unnumberList.add("jzxtpqs"); + unnumberList.add("jzxtphb"); + unnumberList.add("jzxcsqs"); + unnumberList.add("jzxcshb"); + nodeList.add("zbhb_fs"); + nodeList.add("zbqs_fs"); + nodeList.add("swtp_fs"); + nodeList.add("jzxtpqs_fs"); + nodeList.add("jzxtphb_fs"); + nodeList.add("jzxcsqs_fs"); + nodeList.add("jzxcshb_fs"); + } + @Override + public Map execute(Command> targetCommand) { + RequestSubmitCmd requestSubmitCmd = (RequestSubmitCmd) targetCommand; + HttpServletRequest request = requestSubmitCmd.getRequest();//从request中可以取到参数，不用以前的方法了 + String requestId = Util.null2String(request.getParameter("requestid")); + String workflowId = Util.null2String(request.getParameter("workflowid")); + String nodeType = Util.null2String(request.getParameter("nodetype")); + String nodeId = Util.null2String(request.getParameter("nodeid")); + String src = Util.null2String(request.getParameter("src")); + String remark = Util.HTMLtoTxt(Util.null2String(request.getParameter("remark"))).trim(); + String operator = Util.null2String(request.getParameter("f_weaver_belongto_userid")); + String requestName = Util.null2String(request.getParameter("requestname")); +// String requestId="5650648"; +// String workflowId = "56528"; +// String nodeId = "80561"; +// String src = "submit"; + BaseBean bb = new BaseBean(); + bb.writeLog("UpdateDt1Cmd-src"+src); + bb.writeLog("UpdateDt1Cmd-requestname"+requestName); + //执行标准的业务处理 + Map result = nextExecute(targetCommand); + try{ + RequestOperationResultBean resultBean = (RequestOperationResultBean) result.get("data"); + String executeResult = resultBean.getType().name(); +// String executeResult = "SUCCESS"; + RecordSet rs = new RecordSet(); + String sql = "select * from workflow_base where id = "+workflowId; + bb.writeLog("UpdateDt1Cmd-sql"+sql); + rs.execute(sql); + rs.next(); + String unnumber = rs.getString("unnumber"); + String nodeSql = "select nodename,unnumber from workflow_nodebase where id = "+nodeId; + rs.execute(nodeSql); + bb.writeLog("UpdateDt1Cmd-nodeSql"+nodeSql); + rs.next(); +// String nodename = rs.getString("nodename"); + String nodename = "会签"; + String nodeUnnumber = rs.getString("unnumber"); + if("SUCCESS".equals(executeResult) && "submit".equals(src)){ + bb.writeLog("UpdateDt1Cmd-executeResult"+executeResult); + bb.writeLog("UpdateDt1Cmd-src"+src); + if(unnumberList.contains(unnumber)&&nodeList.contains(nodeUnnumber)){ + bb.writeLog("UpdateDt1Cmd-unnumber"+unnumber); + bb.writeLog("UpdateDt1Cmd-nodename"+nodename); + ArrayList userList = new ArrayList(); + String currentoperatorSql = "select * from workflow_currentoperator where requestid = '"+requestId+"' and nodeid < 0 and (agenttype =0 or agenttype =2) and isremark = 0"; + rs.execute(currentoperatorSql); + bb.writeLog("UpdateDt1Cmd-currentoperatorSql"+currentoperatorSql); + String curTime = ""; + while(rs.next()){ + userList.add(rs.getString("userid")); + curTime = rs.getString("receivedate") +" "+rs.getString("receivetime"); + bb.writeLog("无数据curTime"+curTime); + } + bb.writeLog("有数据curTime "+curTime); + String users = StringUtils.join(userList, ","); + //当前处理时长，通过 + String dqclsc = getdqclsc(curTime); + bb.writeLog("UpdateDt1Cmd-dqclsc"+dqclsc); + String dt1Sql = "select * from uf_cgxq_dt1 where lcmc = "+requestId; + bb.writeLog("UpdateDt1Cmd-dt1Sql"+dt1Sql); + rs.execute(dt1Sql); + if(rs.next()){ + String updateDt1Sql = "update uf_cgxq_dt1 set dqcljd ='"+nodename+"',dqclr= '"+users+"',dqclsc='"+dqclsc+"',dqjdqssj='"+curTime+"' where lcmc = "+requestId; + bb.writeLog("UpdateDt1Cmd-updateDt1Sql"+updateDt1Sql); + rs.execute(updateDt1Sql); + } + } + } + + }catch (Exception e){ + e.printStackTrace(); + } + return result; + } + public String getHour(String ngrq){ + //计算总时长 + + LocalDateTime now = LocalDateTime.now(); + LocalDateTime newngrq = LocalDateTime.parse(ngrq, DateTimeFormatter.ofPattern("yyyy-MM-dd HH:mm")); + Duration between = Duration.between( newngrq,now); + long hours = between.toHours(); + String zsc = ""; + long hour = hours % 24; + if(hours>=24){ + long day = between.toDays(); + zsc = day + "天"+hour+"小时"; + }else{ + zsc = hour+"小时"; + } + return zsc; + } + public String getdqclsc(String ngrq){ + //计算总时长 + + LocalDateTime now = LocalDateTime.now(); + LocalDateTime newngrq = LocalDateTime.parse(ngrq, DateTimeFormatter.ofPattern("yyyy-MM-dd HH:mm:ss")); + Duration between = Duration.between( newngrq,now); + long hours = between.toHours(); + String zsc = ""; + long hour = hours % 24; + if(hours>=24){ + long day = between.toDays(); + zsc = day + "天"+hour+"小时"; + }else{ + zsc = hour+"小时"; + } + return zsc; + } +} diff --git a/src/main/java/com/customization/htxc/contract/ContractApprovalSaveCmd.java b/src/main/java/com/customization/htxc/contract/ContractApprovalSaveCmd.java new file mode 100644 index 0000000..8ff23ee --- /dev/null +++ b/src/main/java/com/customization/htxc/contract/ContractApprovalSaveCmd.java @@ -0,0 +1,73 @@ +package com.customization.htxc.contract; + +import com.engine.core.cfg.annotation.CommandDynamicProxy; +import com.engine.core.interceptor.AbstractCommandProxy; +import com.engine.core.interceptor.Command; +import com.engine.htxc.commonutil.log.CustomizeLog; +import com.engine.htxc.contract.service.impl.ContractServiceImpl; +import com.engine.workflow.cmd.requestForm.RequestSubmitCmd; +import com.engine.workflow.entity.requestForm.RequestOperationResultBean; +import org.apache.commons.lang3.StringUtils; +import weaver.general.Util; +import weaver.interfaces.htsc.comInfo.PropBean; +import javax.servlet.http.HttpServletRequest; +import java.util.HashMap; +import java.util.Map; + +/** + *

总部合同审批CMD类

+ * 监听拟稿节点数据，保存将requestid插入建模 + * @author K1810015 + * @version 1.0.0 + * @ClassName ContractApprovalSaveCmd.java + * @createTime 2022年08月31日 23:26:00 + */ +@CommandDynamicProxy(target = RequestSubmitCmd.class, desc = "总部合同报销触发") +public class ContractApprovalSaveCmd extends AbstractCommandProxy> { + + @Override + public Map execute(Command> command) { + RequestSubmitCmd requestSubmitCmd = (RequestSubmitCmd) command; + HttpServletRequest request = requestSubmitCmd.getRequest(); + PropBean pp = new PropBean(); + //总部审批流程 workflowid + String approvalWorkflowId = pp.getPropName("constract.approval.workflowid"); + //获取代理对象 + String requestid = Util.null2String(request.getParameter("requestid")); + String workflowid = Util.null2String(request.getParameter("workflowid")); + String nodetype = Util.null2String(request.getParameter("nodetype")); + String src = Util.null2String(request.getParameter("src")); + //执行标准的业务处理 + Map result = nextExecute(command); + RequestOperationResultBean resultBean = (RequestOperationResultBean) result.get("data"); + //流程处理结果 + String type = Util.null2String(resultBean.getType()); + //判断为拟稿节点 + if (StringUtils.isNotBlank(approvalWorkflowId) + && workflowid.equals(approvalWorkflowId) + && "0".equals(nodetype)) { + CustomizeLog.printLog("查看参数："+type+"--"+src + ); + if ("SUCCESS".equalsIgnoreCase(type) && "save".equalsIgnoreCase(src)) { + //保存 终止 + String code = ""; + CustomizeLog.printLog("合同审批流程创建节点"); + if ("save".equalsIgnoreCase(src)) { + //保存的requestid未生成 + Map submitParams = resultBean.getSubmitParams(); + if ("-1".equals(requestid)) { + requestid = Util.null2String(submitParams.get("requestid")); + } + CustomizeLog.printLog("合同审批流程创建节点参数"+requestid); + if(Util.getIntValue(requestid)>0){ + Map linkmap=new HashMap<>(1); + linkmap.put("requestid",requestid); + new ContractServiceImpl().linkMode(null,linkmap); + } + + } + } + } + return result; + } +} diff --git a/src/main/java/com/customization/htxc/jzxcshb/InsertCgsqxmDt1Cmd.java b/src/main/java/com/customization/htxc/jzxcshb/InsertCgsqxmDt1Cmd.java new file mode 100644 index 0000000..fad3ec4 --- /dev/null +++ b/src/main/java/com/customization/htxc/jzxcshb/InsertCgsqxmDt1Cmd.java @@ -0,0 +1,94 @@ +package com.customization.htxc.jzxcshb; + +import com.engine.core.cfg.annotation.CommandDynamicProxy; +import com.engine.core.interceptor.AbstractCommandProxy; +import com.engine.core.interceptor.Command; +import com.engine.workflow.cmd.requestForm.RequestSubmitCmd; +import com.engine.workflow.entity.requestForm.RequestOperationResultBean; +import weaver.conn.RecordSet; +import weaver.conn.RecordSetTrans; +import weaver.general.BaseBean; +import weaver.general.Util; +import weaver.interfaces.htsc.comInfo.PropBean; + +import javax.servlet.http.HttpServletRequest; +import java.util.Map; +import java.util.Objects; + +/** + * 将招标请示的数据保存到采购项目明细表一 + */ +@CommandDynamicProxy(target = RequestSubmitCmd.class, desc = "流程提交处理业务") +public class InsertCgsqxmDt1Cmd extends AbstractCommandProxy> { + + @Override + public Map execute(Command> targetCommand) { + RequestSubmitCmd requestSubmitCmd = (RequestSubmitCmd) targetCommand; + HttpServletRequest request = requestSubmitCmd.getRequest();//从request中可以取到参数，不用以前的方法了 + String requestid = Util.null2String(request.getParameter("requestid")); + String workflowid = Util.null2String(request.getParameter("workflowid")); + String nodetype = Util.null2String(request.getParameter("nodetype")); + String nodeid = Util.null2String(request.getParameter("nodeid")); + String src = Util.null2String(request.getParameter("src")); + String remark = Util.HTMLtoTxt(Util.null2String(request.getParameter("remark"))).trim(); + String operator = Util.null2String(request.getParameter("f_weaver_belongto_userid")); + String requestname = Util.null2String(request.getParameter("requestname")); + BaseBean bb = new BaseBean(); + bb.writeLog("竞争性磋商汇报拟稿src"+src); + bb.writeLog("竞争性磋商汇报拟稿requestname"+requestname); + //执行标准的业务处理 + Map result = nextExecute(targetCommand); + try{ + + RequestOperationResultBean resultBean = (RequestOperationResultBean) result.get("data"); + String executeResult = resultBean.getType().name(); + RecordSet rs = new RecordSet(); + String sql = "select * from workflow_base where id = "+workflowid; + rs.execute(sql); + rs.next(); + String unnumber = rs.getString("unnumber"); + bb.writeLog("竞争性磋商汇报拟稿unnumber"+unnumber); + PropBean pb = new PropBean(); + String zbqsTable = pb.getPropName("jzxcshb_table"); + String nodeUnNumber = pb.getNodeUnNumberByid(nodeid); + bb.writeLog("竞争性磋商汇报拟稿nodeUnNumber"+nodeUnNumber); + String zbqsNg = pb.getPropName("jzxcshb_ng"); + bb.writeLog("竞争性磋商汇报拟稿zbqs_ng"+zbqsNg); + if("SUCCESS".equals(executeResult) && "submit".equals(src)){ + if(Objects.equals("jzxcshb",unnumber) && Objects.equals(nodeUnNumber,zbqsNg)){ + RecordSetTrans rst = new RecordSetTrans(); + String mainSql = "select * from " + zbqsTable+" where requestid = "+requestid; + rs.execute(mainSql); + if(rs.next()){ + String xmid = rs.getString("jmid"); + String ngr = rs.getString("ngr"); + String szbm = rs.getString("szbm"); + String ngrq = rs.getString("ngrq"); + bb.writeLog("竞争性磋商汇报拟稿jmid"+xmid); + String selectSql = "select * from uf_cgxq_dt1 where lcmc = "+requestid; + rs.execute(selectSql); + if(!rs.next()){ + RecordSet rs1 = new RecordSet(); + String selectByRequsetId = "select * from uf_cgxq_dt1 where lcmc = ?"; + rs1.executeQuery(selectByRequsetId,requestid); + if(!rs1.next()) { + String dt1Sql = "insert into uf_cgxq_dt1 (mainid,lcmc,lclx,lczt,sqr,sqbm,sqsj)values('" + xmid + "','" + requestid + "','" + 5 + "','" + 0 + "','" + ngr + "','" + szbm + "','" + ngrq + "')"; + bb.writeLog("竞争性磋商汇报拟稿dt1Sql" + dt1Sql); + try { + rst.execute(dt1Sql); + } catch (Exception e) { + e.printStackTrace(); + } + } + } + } + } + } + + }catch (Exception e){ + + } + return result; + } +} + diff --git a/src/main/java/com/customization/htxc/jzxcshb/StopUpdateStatus.java b/src/main/java/com/customization/htxc/jzxcshb/StopUpdateStatus.java new file mode 100644 index 0000000..b99d4ec --- /dev/null +++ b/src/main/java/com/customization/htxc/jzxcshb/StopUpdateStatus.java @@ -0,0 +1,65 @@ +package com.customization.htxc.jzxcshb; + +import com.engine.core.cfg.annotation.CommandDynamicProxy; +import com.engine.core.interceptor.AbstractCommandProxy; +import com.engine.core.interceptor.Command; +import com.engine.workflow.cmd.requestForm.RequestSubmitCmd; +import com.engine.workflow.entity.requestForm.RequestOperationResultBean; +import weaver.conn.RecordSet; +import weaver.general.Util; +import weaver.interfaces.htsc.GlobatTools.JAVATools; +import weaver.interfaces.htsc.comInfo.PropBean; + +import javax.servlet.http.HttpServletRequest; +import java.util.Map; +import java.util.Objects; + +/** + * 如果流程被退回拟稿，则将采购项目dt1中的流程状态置为已终止（2） + */ +@CommandDynamicProxy(target = RequestSubmitCmd.class, desc = "流程提交处理业务") +public class StopUpdateStatus extends AbstractCommandProxy> { + + @Override + public Map execute(Command> targetCommand) { + RequestSubmitCmd requestSubmitCmd = (RequestSubmitCmd) targetCommand; + HttpServletRequest request = requestSubmitCmd.getRequest();//从request中可以取到参数，不用以前的方法了 + String requestid = Util.null2String(request.getParameter("requestid")); + String workflowid = Util.null2String(request.getParameter("workflowid")); + String nodetype = Util.null2String(request.getParameter("nodetype")); + String nodeid = Util.null2String(request.getParameter("nodeid")); + String src = Util.null2String(request.getParameter("src")); + JAVATools.writelog("招标汇报src测试终止"+src); + String remark = Util.HTMLtoTxt(Util.null2String(request.getParameter("remark"))).trim(); + String operator = Util.null2String(request.getParameter("f_weaver_belongto_userid")); + //执行标准的业务处理 + Map result = nextExecute(targetCommand); + RequestOperationResultBean resultBean = (RequestOperationResultBean) result.get("data"); + String executeResult = resultBean.getType().name(); + RecordSet rs = new RecordSet(); + String sql = "select * from workflow_base where id = "+workflowid; + rs.execute(sql); + rs.next(); + PropBean pb = new PropBean(); + String zbqsTable = pb.getPropName("jzxcshb_table"); + String unnumber = rs.getString("unnumber"); + JAVATools.writelog("招标汇报测试终止unnumber"+unnumber); + sql = "select * from workflow_requestbase where requestid = "+requestid; + rs.execute(sql); + rs.next(); + String isstopped = rs.getString("isstopped"); + JAVATools.writelog("招标汇报测试终止isstopped"+isstopped); + if("SUCCESS".equals(executeResult) && "1".equals(isstopped)){ + if(Objects.equals("jzxcshb",unnumber) ){ + String mainSql = "select * from " + zbqsTable+" where requestid = "+requestid; + rs.execute(mainSql); + if(rs.next()){ + String xmid = rs.getString("jmid"); + String upsql = "update uf_cgxq_dt1 set lczt = 2,dqcljd='',dqclr='',dqclsc='',zsc='',dqjdqssj='' where mainid = "+xmid + " and lcmc = "+ requestid; + rs.execute(upsql); + } + } + } + return result; + } +} diff --git a/src/main/java/com/customization/htxc/jzxcsqs/InsertCgsqxmDt1Cmd.java b/src/main/java/com/customization/htxc/jzxcsqs/InsertCgsqxmDt1Cmd.java new file mode 100644 index 0000000..273526c --- /dev/null +++ b/src/main/java/com/customization/htxc/jzxcsqs/InsertCgsqxmDt1Cmd.java @@ -0,0 +1,94 @@ +package com.customization.htxc.jzxcsqs; + +import com.engine.core.cfg.annotation.CommandDynamicProxy; +import com.engine.core.interceptor.AbstractCommandProxy; +import com.engine.core.interceptor.Command; +import com.engine.workflow.cmd.requestForm.RequestSubmitCmd; +import com.engine.workflow.entity.requestForm.RequestOperationResultBean; +import weaver.conn.RecordSet; +import weaver.conn.RecordSetTrans; +import weaver.general.BaseBean; +import weaver.general.Util; +import weaver.interfaces.htsc.comInfo.PropBean; + +import javax.servlet.http.HttpServletRequest; +import java.util.Map; +import java.util.Objects; + +/** + * 将招标请示的数据保存到采购项目明细表一 + */ +@CommandDynamicProxy(target = RequestSubmitCmd.class, desc = "流程提交处理业务") +public class InsertCgsqxmDt1Cmd extends AbstractCommandProxy> { + + @Override + public Map execute(Command> targetCommand) { + RequestSubmitCmd requestSubmitCmd = (RequestSubmitCmd) targetCommand; + HttpServletRequest request = requestSubmitCmd.getRequest();//从request中可以取到参数，不用以前的方法了 + String requestid = Util.null2String(request.getParameter("requestid")); + String workflowid = Util.null2String(request.getParameter("workflowid")); + String nodetype = Util.null2String(request.getParameter("nodetype")); + String nodeid = Util.null2String(request.getParameter("nodeid")); + String src = Util.null2String(request.getParameter("src")); + String remark = Util.HTMLtoTxt(Util.null2String(request.getParameter("remark"))).trim(); + String operator = Util.null2String(request.getParameter("f_weaver_belongto_userid")); + String requestname = Util.null2String(request.getParameter("requestname")); + BaseBean bb = new BaseBean(); + bb.writeLog("竞争性磋商请示拟稿src"+src); + bb.writeLog("竞争性磋商请示拟稿requestname"+requestname); + //执行标准的业务处理 + Map result = nextExecute(targetCommand); + try{ + + RequestOperationResultBean resultBean = (RequestOperationResultBean) result.get("data"); + String executeResult = resultBean.getType().name(); + RecordSet rs = new RecordSet(); + String sql = "select * from workflow_base where id = "+workflowid; + rs.execute(sql); + rs.next(); + String unnumber = rs.getString("unnumber"); + bb.writeLog("竞争性磋商请示拟稿unnumber"+unnumber); + PropBean pb = new PropBean(); + String zbqsTable = pb.getPropName("jzxcsqs_table"); + String nodeUnNumber = pb.getNodeUnNumberByid(nodeid); + bb.writeLog("竞争性磋商请示拟稿nodeUnNumber"+nodeUnNumber); + String zbqsNg = pb.getPropName("jzxcsqs_ng"); + bb.writeLog("竞争性磋商请示拟稿zbqs_ng"+zbqsNg); + if("SUCCESS".equals(executeResult) && "submit".equals(src)){ + if(Objects.equals("jzxcsqs",unnumber) && Objects.equals(nodeUnNumber,zbqsNg)){ + RecordSetTrans rst = new RecordSetTrans(); + String mainSql = "select * from " + zbqsTable+" where requestid = "+requestid; + rs.execute(mainSql); + if(rs.next()){ + String xmid = rs.getString("jmid"); + String ngr = rs.getString("ngr"); + String szbm = rs.getString("szbm"); + String ngrq = rs.getString("ngrq"); + bb.writeLog("竞争性磋商请示拟稿jmid"+xmid); + String selectSql = "select * from uf_cgxq_dt1 where lcmc = "+requestid; + rs.execute(selectSql); + if(!rs.next()){ + RecordSet rs1 = new RecordSet(); + String selectByRequsetId = "select * from uf_cgxq_dt1 where lcmc = ?"; + rs1.executeQuery(selectByRequsetId,requestid); + if(!rs1.next()) { + String dt1Sql = "insert into uf_cgxq_dt1 (mainid,lcmc,lclx,lczt,sqr,sqbm,sqsj)values('" + xmid + "','" + requestid + "','" + 4 + "','" + 0 + "','" + ngr + "','" + szbm + "','" + ngrq + "')"; + bb.writeLog("竞争性磋商请示拟稿dt1Sql" + dt1Sql); + try { + rst.execute(dt1Sql); + } catch (Exception e) { + e.printStackTrace(); + } + } + } + } + } + } + + }catch (Exception e){ + + } + return result; + } +} + diff --git a/src/main/java/com/customization/htxc/jzxcsqs/StopUpdateStatus.java b/src/main/java/com/customization/htxc/jzxcsqs/StopUpdateStatus.java new file mode 100644 index 0000000..9c3deb2 --- /dev/null +++ b/src/main/java/com/customization/htxc/jzxcsqs/StopUpdateStatus.java @@ -0,0 +1,65 @@ +package com.customization.htxc.jzxcsqs; + +import com.engine.core.cfg.annotation.CommandDynamicProxy; +import com.engine.core.interceptor.AbstractCommandProxy; +import com.engine.core.interceptor.Command; +import com.engine.workflow.cmd.requestForm.RequestSubmitCmd; +import com.engine.workflow.entity.requestForm.RequestOperationResultBean; +import weaver.conn.RecordSet; +import weaver.general.Util; +import weaver.interfaces.htsc.GlobatTools.JAVATools; +import weaver.interfaces.htsc.comInfo.PropBean; + +import javax.servlet.http.HttpServletRequest; +import java.util.Map; +import java.util.Objects; + +/** + * 如果流程被退回拟稿，则将采购项目dt1中的流程状态置为已终止（2） + */ +@CommandDynamicProxy(target = RequestSubmitCmd.class, desc = "流程提交处理业务") +public class StopUpdateStatus extends AbstractCommandProxy> { + + @Override + public Map execute(Command> targetCommand) { + RequestSubmitCmd requestSubmitCmd = (RequestSubmitCmd) targetCommand; + HttpServletRequest request = requestSubmitCmd.getRequest();//从request中可以取到参数，不用以前的方法了 + String requestid = Util.null2String(request.getParameter("requestid")); + String workflowid = Util.null2String(request.getParameter("workflowid")); + String nodetype = Util.null2String(request.getParameter("nodetype")); + String nodeid = Util.null2String(request.getParameter("nodeid")); + String src = Util.null2String(request.getParameter("src")); + JAVATools.writelog("招标汇报src测试终止"+src); + String remark = Util.HTMLtoTxt(Util.null2String(request.getParameter("remark"))).trim(); + String operator = Util.null2String(request.getParameter("f_weaver_belongto_userid")); + //执行标准的业务处理 + Map result = nextExecute(targetCommand); + RequestOperationResultBean resultBean = (RequestOperationResultBean) result.get("data"); + String executeResult = resultBean.getType().name(); + RecordSet rs = new RecordSet(); + String sql = "select * from workflow_base where id = "+workflowid; + rs.execute(sql); + rs.next(); + PropBean pb = new PropBean(); + String zbqsTable = pb.getPropName("jzxcsqs_table"); + String unnumber = rs.getString("unnumber"); + JAVATools.writelog("招标汇报测试终止unnumber"+unnumber); + sql = "select * from workflow_requestbase where requestid = "+requestid; + rs.execute(sql); + rs.next(); + String isstopped = rs.getString("isstopped"); + JAVATools.writelog("招标汇报测试终止isstopped"+isstopped); + if("SUCCESS".equals(executeResult) && "1".equals(isstopped)){ + if(Objects.equals("jzxcsqs",unnumber) ){ + String mainSql = "select * from " + zbqsTable+" where requestid = "+requestid; + rs.execute(mainSql); + if(rs.next()){ + String xmid = rs.getString("jmid"); + String upsql = "update uf_cgxq_dt1 set lczt = 2 where mainid = "+xmid + " and lcmc = "+ requestid; + rs.execute(upsql); + } + } + } + return result; + } +} diff --git a/src/main/java/com/customization/htxc/jzxtphb/InsertCgsqxmDt1Cmd.java b/src/main/java/com/customization/htxc/jzxtphb/InsertCgsqxmDt1Cmd.java new file mode 100644 index 0000000..cc5c9bc --- /dev/null +++ b/src/main/java/com/customization/htxc/jzxtphb/InsertCgsqxmDt1Cmd.java @@ -0,0 +1,94 @@ +package com.customization.htxc.jzxtphb; + +import com.engine.core.cfg.annotation.CommandDynamicProxy; +import com.engine.core.interceptor.AbstractCommandProxy; +import com.engine.core.interceptor.Command; +import com.engine.workflow.cmd.requestForm.RequestSubmitCmd; +import com.engine.workflow.entity.requestForm.RequestOperationResultBean; +import weaver.conn.RecordSet; +import weaver.conn.RecordSetTrans; +import weaver.general.BaseBean; +import weaver.general.Util; +import weaver.interfaces.htsc.comInfo.PropBean; + +import javax.servlet.http.HttpServletRequest; +import java.util.Map; +import java.util.Objects; + +/** + * 将招标请示的数据保存到采购项目明细表一 + */ +@CommandDynamicProxy(target = RequestSubmitCmd.class, desc = "流程提交处理业务") +public class InsertCgsqxmDt1Cmd extends AbstractCommandProxy> { + + @Override + public Map execute(Command> targetCommand) { + RequestSubmitCmd requestSubmitCmd = (RequestSubmitCmd) targetCommand; + HttpServletRequest request = requestSubmitCmd.getRequest();//从request中可以取到参数，不用以前的方法了 + String requestid = Util.null2String(request.getParameter("requestid")); + String workflowid = Util.null2String(request.getParameter("workflowid")); + String nodetype = Util.null2String(request.getParameter("nodetype")); + String nodeid = Util.null2String(request.getParameter("nodeid")); + String src = Util.null2String(request.getParameter("src")); + String remark = Util.HTMLtoTxt(Util.null2String(request.getParameter("remark"))).trim(); + String operator = Util.null2String(request.getParameter("f_weaver_belongto_userid")); + String requestname = Util.null2String(request.getParameter("requestname")); + BaseBean bb = new BaseBean(); + bb.writeLog("竞争性谈判汇报拟稿src"+src); + bb.writeLog("竞争性谈判汇报拟稿requestname"+requestname); + //执行标准的业务处理 + Map result = nextExecute(targetCommand); + try{ + + RequestOperationResultBean resultBean = (RequestOperationResultBean) result.get("data"); + String executeResult = resultBean.getType().name(); + RecordSet rs = new RecordSet(); + String sql = "select * from workflow_base where id = "+workflowid; + rs.execute(sql); + rs.next(); + String unnumber = rs.getString("unnumber"); + bb.writeLog("竞争性谈判汇报拟稿unnumber"+unnumber); + PropBean pb = new PropBean(); + String zbqsTable = pb.getPropName("jzxtphb_table"); + String nodeUnNumber = pb.getNodeUnNumberByid(nodeid); + bb.writeLog("竞争性谈判汇报拟稿nodeUnNumber"+nodeUnNumber); + String zbqsNg = pb.getPropName("jzxtphb_ng"); + bb.writeLog("竞争性谈判汇报拟稿zbqs_ng"+zbqsNg); + if("SUCCESS".equals(executeResult) && "submit".equals(src)){ + if(Objects.equals("jzxtphb",unnumber) && Objects.equals(nodeUnNumber,zbqsNg)){ + RecordSetTrans rst = new RecordSetTrans(); + String mainSql = "select * from " + zbqsTable+" where requestid = "+requestid; + rs.execute(mainSql); + if(rs.next()){ + String xmid = rs.getString("jmid"); + String ngr = rs.getString("ngr"); + String szbm = rs.getString("szbm"); + String ngrq = rs.getString("ngrq"); + bb.writeLog("竞争性谈判汇报拟稿jmid"+xmid); + String selectSql = "select * from uf_cgxq_dt1 where lcmc = "+requestid; + rs.execute(selectSql); + if(!rs.next()){ + RecordSet rs1 = new RecordSet(); + String selectByRequsetId = "select * from uf_cgxq_dt1 where lcmc = ?"; + rs1.executeQuery(selectByRequsetId,requestid); + if(!rs1.next()) { + String dt1Sql = "insert into uf_cgxq_dt1 (mainid,lcmc,lclx,lczt,sqr,sqbm,sqsj)values('" + xmid + "','" + requestid + "','" + 3 + "','" + 0 + "','" + ngr + "','" + szbm + "','" + ngrq + "')"; + bb.writeLog("竞争性谈判汇报拟稿dt1Sql" + dt1Sql); + try { + rst.execute(dt1Sql); + } catch (Exception e) { + e.printStackTrace(); + } + } + } + } + } + } + + }catch (Exception e){ + + } + return result; + } +} + diff --git a/src/main/java/com/customization/htxc/jzxtphb/StopUpdateStatus.java b/src/main/java/com/customization/htxc/jzxtphb/StopUpdateStatus.java new file mode 100644 index 0000000..1e41044 --- /dev/null +++ b/src/main/java/com/customization/htxc/jzxtphb/StopUpdateStatus.java @@ -0,0 +1,76 @@ +package com.customization.htxc.jzxtphb; + +import com.engine.core.cfg.annotation.CommandDynamicProxy; +import com.engine.core.interceptor.AbstractCommandProxy; +import com.engine.core.interceptor.Command; +import com.engine.workflow.cmd.requestForm.RequestSubmitCmd; +import com.engine.workflow.entity.requestForm.RequestOperationResultBean; +import weaver.conn.RecordSet; +import weaver.general.Util; +import weaver.interfaces.htsc.GlobatTools.JAVATools; +import weaver.interfaces.htsc.comInfo.PropBean; + +import javax.servlet.http.HttpServletRequest; +import java.util.Map; +import java.util.Objects; + +/* @Title: ecology-9 + * @Company: 泛微软件 + * @author: K1810027 + * @version: 1.0 + * @CreateDate: 2022-08-19 + * @Description: 竞争性谈判汇报如果流程被退回拟稿，则将采购项目dt1中的流程状态置为已终止（2） + * @ModifyLog: + **/ +@CommandDynamicProxy(target = RequestSubmitCmd.class, desc = "流程提交处理业务") +public class StopUpdateStatus extends AbstractCommandProxy> { + + @Override + public Map execute(Command> targetCommand) { + RequestSubmitCmd requestSubmitCmd = (RequestSubmitCmd) targetCommand; + HttpServletRequest request = requestSubmitCmd.getRequest();//从request中可以取到参数，不用以前的方法了 + String requestid = Util.null2String(request.getParameter("requestid")); + String workflowid = Util.null2String(request.getParameter("workflowid")); + String nodeType = Util.null2String(request.getParameter("nodetype")); + String nodeId = Util.null2String(request.getParameter("nodeid")); + String src = Util.null2String(request.getParameter("src")); + JAVATools.writelog("招标汇报src测试终止"+src); + String remark = Util.HTMLtoTxt(Util.null2String(request.getParameter("remark"))).trim(); + String operator = Util.null2String(request.getParameter("f_weaver_belongto_userid")); + //执行标准的业务处理 + Map result = nextExecute(targetCommand); + RequestOperationResultBean resultBean = (RequestOperationResultBean) result.get("data"); + String executeResult = resultBean.getType().name(); + RecordSet rs = new RecordSet(); + RecordSet nodeRs = new RecordSet(); + String sql = "select * from workflow_base where id = "+workflowid; + rs.execute(sql); + rs.next(); + PropBean pb = new PropBean(); + String zbqsTable = pb.getPropName("jzxtphb_table"); + String unnumber = rs.getString("unnumber"); + JAVATools.writelog("招标汇报测试终止unnumber"+unnumber); + sql = "select * from workflow_requestbase where requestid = "+requestid; + rs.execute(sql); + rs.next(); + String isstopped = rs.getString("isstopped"); + JAVATools.writelog("招标汇报测试终止isstopped"+isstopped); + String nodeSql = "select * from workflow_nodebase where id = "+nodeId; + nodeRs.execute(nodeSql); + nodeRs.next(); + String nodeName = nodeRs.getString("nodename"); + //dqcljd，dqclr,dqclsc,zsc,dqjdqssj + if("SUCCESS".equals(executeResult) && "1".equals(isstopped)){ + if(Objects.equals("jzxtphb",unnumber) ){ + String mainSql = "select * from " + zbqsTable+" where requestid = "+requestid; + rs.execute(mainSql); + if(rs.next()){ + String xmid = rs.getString("jmid"); + String upsql = "update uf_cgxq_dt1 set lczt = 2,dqcljd='',dqclr='',dqclsc='',zsc='',dqjdqssj='' where mainid = "+xmid + " and lcmc = "+ requestid; + rs.execute(upsql); + } + } + } + return result; + } +} diff --git a/src/main/java/com/customization/htxc/jzxtpqs/InsertCgsqxmDt1Cmd.java b/src/main/java/com/customization/htxc/jzxtpqs/InsertCgsqxmDt1Cmd.java new file mode 100644 index 0000000..9e05e0a --- /dev/null +++ b/src/main/java/com/customization/htxc/jzxtpqs/InsertCgsqxmDt1Cmd.java @@ -0,0 +1,95 @@ +package com.customization.htxc.jzxtpqs; + +import com.engine.core.cfg.annotation.CommandDynamicProxy; +import com.engine.core.interceptor.AbstractCommandProxy; +import com.engine.core.interceptor.Command; +import com.engine.workflow.cmd.requestForm.RequestSubmitCmd; +import com.engine.workflow.entity.requestForm.RequestOperationResultBean; +import weaver.conn.RecordSet; +import weaver.conn.RecordSetTrans; +import weaver.general.BaseBean; +import weaver.general.Util; +import weaver.interfaces.htsc.comInfo.PropBean; + +import javax.servlet.http.HttpServletRequest; +import java.util.Map; +import java.util.Objects; + +/** + * 将招标请示的数据保存到采购项目明细表一 + */ +@CommandDynamicProxy(target = RequestSubmitCmd.class, desc = "流程提交处理业务") +public class InsertCgsqxmDt1Cmd extends AbstractCommandProxy> { + + @Override + public Map execute(Command> targetCommand) { + RequestSubmitCmd requestSubmitCmd = (RequestSubmitCmd) targetCommand; + HttpServletRequest request = requestSubmitCmd.getRequest();//从request中可以取到参数，不用以前的方法了 + String requestid = Util.null2String(request.getParameter("requestid")); + String workflowid = Util.null2String(request.getParameter("workflowid")); + String nodetype = Util.null2String(request.getParameter("nodetype")); + String nodeid = Util.null2String(request.getParameter("nodeid")); + String src = Util.null2String(request.getParameter("src")); + String remark = Util.HTMLtoTxt(Util.null2String(request.getParameter("remark"))).trim(); + String operator = Util.null2String(request.getParameter("f_weaver_belongto_userid")); + String requestname = Util.null2String(request.getParameter("requestname")); + BaseBean bb = new BaseBean(); + bb.writeLog("竞争性谈判请示拟稿src"+src); + bb.writeLog("竞争性谈判请示拟稿requestname"+requestname); + //执行标准的业务处理 + Map result = nextExecute(targetCommand); + try{ + + RequestOperationResultBean resultBean = (RequestOperationResultBean) result.get("data"); + String executeResult = resultBean.getType().name(); + RecordSet rs = new RecordSet(); + String sql = "select * from workflow_base where id = "+workflowid; + rs.execute(sql); + rs.next(); + String unnumber = rs.getString("unnumber"); + bb.writeLog("竞争性谈判请示拟稿unnumber"+unnumber); + PropBean pb = new PropBean(); + String zbqsTable = pb.getPropName("jzxtpqs_table"); + String nodeUnNumber = pb.getNodeUnNumberByid(nodeid); + bb.writeLog("竞争性谈判请示拟稿nodeUnNumber"+nodeUnNumber); + String zbqsNg = pb.getPropName("jzxtpqs_ng"); + bb.writeLog("竞争性谈判请示拟稿zbqs_ng"+zbqsNg); + if("SUCCESS".equals(executeResult) && "submit".equals(src)){ + if(Objects.equals("jzxtpqs",unnumber) && Objects.equals(nodeUnNumber,zbqsNg)){ + RecordSetTrans rst = new RecordSetTrans(); + String mainSql = "select * from " + zbqsTable+" where requestid = "+requestid; + rs.execute(mainSql); + if(rs.next()){ + String xmid = rs.getString("jmid"); + //ngr,szbm,ngrq + String ngr = rs.getString("ngr"); + String szbm = rs.getString("szbm"); + String ngrq = rs.getString("ngrq"); + bb.writeLog("竞争性谈判请示拟稿jmid"+xmid); + String selectSql = "select * from uf_cgxq_dt1 where lcmc = "+requestid; + rs.execute(selectSql); + if(!rs.next()){ + RecordSet rs1 = new RecordSet(); + String selectByRequsetId = "select * from uf_cgxq_dt1 where lcmc = ?"; + rs1.executeQuery(selectByRequsetId,requestid); + if(!rs1.next()) { + String dt1Sql = "insert into uf_cgxq_dt1 (mainid,lcmc,lclx,lczt,sqr,sqbm,sqsj)values('" + xmid + "','" + requestid + "','" + 2 + "','" + 0 + "','" + ngr + "','" + szbm + "','" + ngrq + "')"; + bb.writeLog("竞争性谈判请示拟稿dt1Sql" + dt1Sql); + try { + rst.execute(dt1Sql); + } catch (Exception e) { + e.printStackTrace(); + } + } + } + } + } + } + + }catch (Exception e){ + + } + return result; + } +} + diff --git a/src/main/java/com/customization/htxc/jzxtpqs/StopUpdateStatus.java b/src/main/java/com/customization/htxc/jzxtpqs/StopUpdateStatus.java new file mode 100644 index 0000000..b04d346 --- /dev/null +++ b/src/main/java/com/customization/htxc/jzxtpqs/StopUpdateStatus.java @@ -0,0 +1,65 @@ +package com.customization.htxc.jzxtpqs; + +import com.engine.core.cfg.annotation.CommandDynamicProxy; +import com.engine.core.interceptor.AbstractCommandProxy; +import com.engine.core.interceptor.Command; +import com.engine.workflow.cmd.requestForm.RequestSubmitCmd; +import com.engine.workflow.entity.requestForm.RequestOperationResultBean; +import weaver.conn.RecordSet; +import weaver.general.Util; +import weaver.interfaces.htsc.GlobatTools.JAVATools; +import weaver.interfaces.htsc.comInfo.PropBean; + +import javax.servlet.http.HttpServletRequest; +import java.util.Map; +import java.util.Objects; + +/** + * 如果流程被退回拟稿，则将采购项目dt1中的流程状态置为已终止（2） + */ +@CommandDynamicProxy(target = RequestSubmitCmd.class, desc = "流程提交处理业务") +public class StopUpdateStatus extends AbstractCommandProxy> { + + @Override + public Map execute(Command> targetCommand) { + RequestSubmitCmd requestSubmitCmd = (RequestSubmitCmd) targetCommand; + HttpServletRequest request = requestSubmitCmd.getRequest();//从request中可以取到参数，不用以前的方法了 + String requestid = Util.null2String(request.getParameter("requestid")); + String workflowid = Util.null2String(request.getParameter("workflowid")); + String nodetype = Util.null2String(request.getParameter("nodetype")); + String nodeid = Util.null2String(request.getParameter("nodeid")); + String src = Util.null2String(request.getParameter("src")); + JAVATools.writelog("招标汇报src测试终止"+src); + String remark = Util.HTMLtoTxt(Util.null2String(request.getParameter("remark"))).trim(); + String operator = Util.null2String(request.getParameter("f_weaver_belongto_userid")); + //执行标准的业务处理 + Map result = nextExecute(targetCommand); + RequestOperationResultBean resultBean = (RequestOperationResultBean) result.get("data"); + String executeResult = resultBean.getType().name(); + RecordSet rs = new RecordSet(); + String sql = "select * from workflow_base where id = "+workflowid; + rs.execute(sql); + rs.next(); + PropBean pb = new PropBean(); + String zbqsTable = pb.getPropName("jzxtpqs_table"); + String unnumber = rs.getString("unnumber"); + JAVATools.writelog("招标汇报测试终止unnumber"+unnumber); + sql = "select * from workflow_requestbase where requestid = "+requestid; + rs.execute(sql); + rs.next(); + String isstopped = rs.getString("isstopped"); + JAVATools.writelog("招标汇报测试终止isstopped"+isstopped); + if("SUCCESS".equals(executeResult) && "1".equals(isstopped)){ + if(Objects.equals("jzxtpqs",unnumber) ){ + String mainSql = "select * from " + zbqsTable+" where requestid = "+requestid; + rs.execute(mainSql); + if(rs.next()){ + String xmid = rs.getString("jmid"); + String upsql = "update uf_cgxq_dt1 set lczt = 2 where mainid = "+xmid + " and lcmc = "+ requestid; + rs.execute(upsql); + } + } + } + return result; + } +} diff --git a/src/main/java/com/customization/htxc/swtp/InsertCgsqxmDt1Cmd.java b/src/main/java/com/customization/htxc/swtp/InsertCgsqxmDt1Cmd.java new file mode 100644 index 0000000..e8b5dd9 --- /dev/null +++ b/src/main/java/com/customization/htxc/swtp/InsertCgsqxmDt1Cmd.java @@ -0,0 +1,95 @@ +package com.customization.htxc.swtp; + +import com.engine.core.cfg.annotation.CommandDynamicProxy; +import com.engine.core.interceptor.AbstractCommandProxy; +import com.engine.core.interceptor.Command; +import com.engine.workflow.cmd.requestForm.RequestSubmitCmd; +import com.engine.workflow.entity.requestForm.RequestOperationResultBean; +import weaver.conn.RecordSet; +import weaver.conn.RecordSetTrans; +import weaver.general.BaseBean; +import weaver.general.Util; +import weaver.interfaces.htsc.comInfo.PropBean; + +import javax.servlet.http.HttpServletRequest; +import java.util.Map; +import java.util.Objects; + +/** + * 将招标请示的数据保存到采购项目明细表一 + */ +@CommandDynamicProxy(target = RequestSubmitCmd.class, desc = "流程提交处理业务") +public class InsertCgsqxmDt1Cmd extends AbstractCommandProxy> { + + @Override + public Map execute(Command> targetCommand) { + RequestSubmitCmd requestSubmitCmd = (RequestSubmitCmd) targetCommand; + HttpServletRequest request = requestSubmitCmd.getRequest();//从request中可以取到参数，不用以前的方法了 + String requestid = Util.null2String(request.getParameter("requestid")); + String workflowid = Util.null2String(request.getParameter("workflowid")); + String nodetype = Util.null2String(request.getParameter("nodetype")); + String nodeid = Util.null2String(request.getParameter("nodeid")); + String src = Util.null2String(request.getParameter("src")); + String remark = Util.HTMLtoTxt(Util.null2String(request.getParameter("remark"))).trim(); + String operator = Util.null2String(request.getParameter("f_weaver_belongto_userid")); + String requestname = Util.null2String(request.getParameter("requestname")); + BaseBean bb = new BaseBean(); + bb.writeLog("商务谈判拟稿src"+src); + bb.writeLog("商务谈判拟稿requestname"+requestname); + //执行标准的业务处理 + Map result = nextExecute(targetCommand); + try{ + + RequestOperationResultBean resultBean = (RequestOperationResultBean) result.get("data"); + String executeResult = resultBean.getType().name(); + RecordSet rs = new RecordSet(); + String sql = "select * from workflow_base where id = "+workflowid; + rs.execute(sql); + rs.next(); + String unnumber = rs.getString("unnumber"); + bb.writeLog("商务谈判拟稿unnumber"+unnumber); + PropBean pb = new PropBean(); + String zbqsTable = pb.getPropName("swtp_table"); + String nodeUnNumber = pb.getNodeUnNumberByid(nodeid); + bb.writeLog("商务谈判拟稿nodeUnNumber"+nodeUnNumber); + String zbqsNg = pb.getPropName("swtp_ng"); + bb.writeLog("商务谈判拟稿swtp_ng"+zbqsNg); + if("SUCCESS".equals(executeResult) && "submit".equals(src)){ + if(Objects.equals("swtp",unnumber) && Objects.equals(nodeUnNumber,zbqsNg)){ + RecordSetTrans rst = new RecordSetTrans(); + String mainSql = "select * from " + zbqsTable+" where requestid = "+requestid; + rs.execute(mainSql); + if(rs.next()){ + String xmid = rs.getString("jmid"); + String ngr = rs.getString("ngr"); + String szbm = rs.getString("szbm"); + String ngrq = rs.getString("ngrq"); + bb.writeLog("商务谈判拟稿jmid"+xmid); + String selectSql = "select * from uf_cgxq_dt1 where lcmc = "+requestid; + rs.execute(selectSql); + if(!rs.next()){ + RecordSet rs1 = new RecordSet(); + String selectByRequsetId = "select * from uf_cgxq_dt1 where lcmc = ?"; + rs1.executeQuery(selectByRequsetId,requestid); + if(!rs1.next()) { + String dt1Sql = "insert into uf_cgxq_dt1 (mainid,lcmc,lclx,lczt,sqr,sqbm,sqsj)values('" + xmid + "','" + requestid + "','" + 6 + "','" + 0 + "','" + ngr + "','" + szbm + "','" + ngrq + "')"; + bb.writeLog("商务谈判拟稿dt1Sql" + dt1Sql); + try { + + rst.execute(dt1Sql); + } catch (Exception e) { + e.printStackTrace(); + } + } + } + } + } + } + + }catch (Exception e){ + + } + return result; + } +} + diff --git a/src/main/java/com/customization/htxc/swtp/StopUpdateStatus.java b/src/main/java/com/customization/htxc/swtp/StopUpdateStatus.java new file mode 100644 index 0000000..0c55ce9 --- /dev/null +++ b/src/main/java/com/customization/htxc/swtp/StopUpdateStatus.java @@ -0,0 +1,61 @@ +package com.customization.htxc.swtp; + +import com.engine.core.cfg.annotation.CommandDynamicProxy; +import com.engine.core.interceptor.AbstractCommandProxy; +import com.engine.core.interceptor.Command; +import com.engine.workflow.cmd.requestForm.RequestSubmitCmd; +import com.engine.workflow.entity.requestForm.RequestOperationResultBean; +import weaver.conn.RecordSet; +import weaver.general.Util; +import weaver.interfaces.htsc.comInfo.PropBean; + +import javax.servlet.http.HttpServletRequest; +import java.util.Map; +import java.util.Objects; + +/** + * 如果流程被退回拟稿，则将采购项目dt1中的流程状态置为已终止（2） + */ +@CommandDynamicProxy(target = RequestSubmitCmd.class, desc = "流程提交处理业务") +public class StopUpdateStatus extends AbstractCommandProxy> { + + @Override + public Map execute(Command> targetCommand) { + RequestSubmitCmd requestSubmitCmd = (RequestSubmitCmd) targetCommand; + HttpServletRequest request = requestSubmitCmd.getRequest();//从request中可以取到参数，不用以前的方法了 + String requestid = Util.null2String(request.getParameter("requestid")); + String workflowid = Util.null2String(request.getParameter("workflowid")); + String nodetype = Util.null2String(request.getParameter("nodetype")); + String nodeid = Util.null2String(request.getParameter("nodeid")); + String src = Util.null2String(request.getParameter("src")); + String remark = Util.HTMLtoTxt(Util.null2String(request.getParameter("remark"))).trim(); + String operator = Util.null2String(request.getParameter("f_weaver_belongto_userid")); + //执行标准的业务处理 + Map result = nextExecute(targetCommand); + RequestOperationResultBean resultBean = (RequestOperationResultBean) result.get("data"); + String executeResult = resultBean.getType().name(); + RecordSet rs = new RecordSet(); + String sql = "select * from workflow_base where id = "+workflowid; + rs.execute(sql); + rs.next(); + PropBean pb = new PropBean(); + String zbqsTable = pb.getPropName("swtp_table"); + String unnumber = rs.getString("unnumber"); + sql = "select * from workflow_requestbase where requestid = "+requestid; + rs.execute(sql); + rs.next(); + String isstopped = rs.getString("isstopped"); + if("SUCCESS".equals(executeResult) && "1".equals(isstopped)){ + if(Objects.equals("swtp",unnumber) ){ + String mainSql = "select * from " + zbqsTable+" where requestid = "+requestid; + rs.execute(mainSql); + if(rs.next()){ + String xmid = rs.getString("jmid"); + String upsql = "update uf_cgxq_dt1 set lczt = 2 where mainid = "+xmid + " and lcmc = "+ requestid; + rs.execute(upsql); + } + } + } + return result; + } +} diff --git a/src/main/java/com/customization/htxc/zbhb/InsertCgsqxmDt1Cmd.java b/src/main/java/com/customization/htxc/zbhb/InsertCgsqxmDt1Cmd.java new file mode 100644 index 0000000..8c2332c --- /dev/null +++ b/src/main/java/com/customization/htxc/zbhb/InsertCgsqxmDt1Cmd.java @@ -0,0 +1,94 @@ +package com.customization.htxc.zbhb; + +import com.engine.core.cfg.annotation.CommandDynamicProxy; +import com.engine.core.interceptor.AbstractCommandProxy; +import com.engine.core.interceptor.Command; +import com.engine.workflow.cmd.requestForm.RequestSubmitCmd; +import com.engine.workflow.entity.requestForm.RequestOperationResultBean; +import weaver.conn.RecordSet; +import weaver.conn.RecordSetTrans; +import weaver.general.BaseBean; +import weaver.general.Util; +import weaver.interfaces.htsc.comInfo.PropBean; + +import javax.servlet.http.HttpServletRequest; +import java.util.Map; +import java.util.Objects; + +/** + * 将招标请示的数据保存到采购项目明细表一 + */ +@CommandDynamicProxy(target = RequestSubmitCmd.class, desc = "流程提交处理业务") +public class InsertCgsqxmDt1Cmd extends AbstractCommandProxy> { + + @Override + public Map execute(Command> targetCommand) { + RequestSubmitCmd requestSubmitCmd = (RequestSubmitCmd) targetCommand; + HttpServletRequest request = requestSubmitCmd.getRequest();//从request中可以取到参数，不用以前的方法了 + String requestid = Util.null2String(request.getParameter("requestid")); + String workflowid = Util.null2String(request.getParameter("workflowid")); + String nodetype = Util.null2String(request.getParameter("nodetype")); + String nodeid = Util.null2String(request.getParameter("nodeid")); + String src = Util.null2String(request.getParameter("src")); + String remark = Util.HTMLtoTxt(Util.null2String(request.getParameter("remark"))).trim(); + String operator = Util.null2String(request.getParameter("f_weaver_belongto_userid")); + String requestname = Util.null2String(request.getParameter("requestname")); + BaseBean bb = new BaseBean(); + bb.writeLog("招标汇报拟稿src"+src); + bb.writeLog("招标汇报拟稿requestname"+requestname); + //执行标准的业务处理 + Map result = nextExecute(targetCommand); + try{ + + RequestOperationResultBean resultBean = (RequestOperationResultBean) result.get("data"); + String executeResult = resultBean.getType().name(); + RecordSet rs = new RecordSet(); + String sql = "select * from workflow_base where id = "+workflowid; + rs.execute(sql); + rs.next(); + String unnumber = rs.getString("unnumber"); + bb.writeLog("招标汇报拟稿unnumber"+unnumber); + PropBean pb = new PropBean(); + String zbqsTable = pb.getPropName("zbhb_table"); + String nodeUnNumber = pb.getNodeUnNumberByid(nodeid); + bb.writeLog("招标汇报拟稿nodeUnNumber"+nodeUnNumber); + String zbqsNg = pb.getPropName("zbhb_ng"); + bb.writeLog("招标汇报拟稿zbqs_ng"+zbqsNg); + if("SUCCESS".equals(executeResult) && "submit".equals(src)){ + if(Objects.equals("zbhb",unnumber) && Objects.equals(nodeUnNumber,zbqsNg)){ + RecordSetTrans rst = new RecordSetTrans(); + String mainSql = "select * from " + zbqsTable+" where requestid = "+requestid; + rs.execute(mainSql); + if(rs.next()){ + String xmid = rs.getString("jmid"); + String ngr = rs.getString("ngr"); + String szbm = rs.getString("szbm"); + String ngrq = rs.getString("ngrq"); + bb.writeLog("招标汇报拟稿jmid"+xmid); + String selectSql = "select * from uf_cgxq_dt1 where lcmc = "+requestid; + rs.execute(selectSql); + if(!rs.next()){ + RecordSet rs1 = new RecordSet(); + String selectByRequsetId = "select * from uf_cgxq_dt1 where lcmc = ?"; + rs1.executeQuery(selectByRequsetId,requestid); + if(!rs1.next()) { + String dt1Sql = "insert into uf_cgxq_dt1 (mainid,lcmc,lclx,lczt,sqr,sqbm,sqsj)values('" + xmid + "','" + requestid + "','" + 1 + "','" + 0 + "','" + ngr + "','" + szbm + "','" + ngrq + "')"; + bb.writeLog("招标汇报拟稿dt1Sql" + dt1Sql); + try { + rst.execute(dt1Sql); + } catch (Exception e) { + e.printStackTrace(); + } + } + } + } + } + } + + }catch (Exception e){ + + } + return result; + } +} + diff --git a/src/main/java/com/customization/htxc/zbhb/StopUpdateStatus.java b/src/main/java/com/customization/htxc/zbhb/StopUpdateStatus.java new file mode 100644 index 0000000..a0b5160 --- /dev/null +++ b/src/main/java/com/customization/htxc/zbhb/StopUpdateStatus.java @@ -0,0 +1,65 @@ +package com.customization.htxc.zbhb; + +import com.engine.core.cfg.annotation.CommandDynamicProxy; +import com.engine.core.interceptor.AbstractCommandProxy; +import com.engine.core.interceptor.Command; +import com.engine.workflow.cmd.requestForm.RequestSubmitCmd; +import com.engine.workflow.entity.requestForm.RequestOperationResultBean; +import weaver.conn.RecordSet; +import weaver.general.Util; +import weaver.interfaces.htsc.GlobatTools.JAVATools; +import weaver.interfaces.htsc.comInfo.PropBean; + +import javax.servlet.http.HttpServletRequest; +import java.util.Map; +import java.util.Objects; + +/** + * 如果流程被退回拟稿，则将采购项目dt1中的流程状态置为已终止（2） + */ +@CommandDynamicProxy(target = RequestSubmitCmd.class, desc = "流程提交处理业务") +public class StopUpdateStatus extends AbstractCommandProxy> { + + @Override + public Map execute(Command> targetCommand) { + RequestSubmitCmd requestSubmitCmd = (RequestSubmitCmd) targetCommand; + HttpServletRequest request = requestSubmitCmd.getRequest();//从request中可以取到参数，不用以前的方法了 + String requestid = Util.null2String(request.getParameter("requestid")); + String workflowid = Util.null2String(request.getParameter("workflowid")); + String nodetype = Util.null2String(request.getParameter("nodetype")); + String nodeid = Util.null2String(request.getParameter("nodeid")); + String src = Util.null2String(request.getParameter("src")); + JAVATools.writelog("招标汇报src测试终止"+src); + String remark = Util.HTMLtoTxt(Util.null2String(request.getParameter("remark"))).trim(); + String operator = Util.null2String(request.getParameter("f_weaver_belongto_userid")); + //执行标准的业务处理 + Map result = nextExecute(targetCommand); + RequestOperationResultBean resultBean = (RequestOperationResultBean) result.get("data"); + String executeResult = resultBean.getType().name(); + RecordSet rs = new RecordSet(); + String sql = "select * from workflow_base where id = "+workflowid; + rs.execute(sql); + rs.next(); + PropBean pb = new PropBean(); + String zbqsTable = pb.getPropName("zbhb_table"); + String unnumber = rs.getString("unnumber"); + JAVATools.writelog("招标汇报测试终止unnumber"+unnumber); + sql = "select * from workflow_requestbase where requestid = "+requestid; + rs.execute(sql); + rs.next(); + String isstopped = rs.getString("isstopped"); + JAVATools.writelog("招标汇报测试终止isstopped"+isstopped); + if("SUCCESS".equals(executeResult) && "1".equals(isstopped)){ + if(Objects.equals("zbhb",unnumber) ){ + String mainSql = "select * from " + zbqsTable+" where requestid = "+requestid; + rs.execute(mainSql); + if(rs.next()){ + String xmid = rs.getString("jmid"); + String upsql = "update uf_cgxq_dt1 set lczt = 2 where mainid = "+xmid + " and lcmc = "+ requestid; + rs.execute(upsql); + } + } + } + return result; + } +} diff --git a/src/main/java/com/customization/htxc/zbqs/InsertCgsqxmDt1Cmd.java b/src/main/java/com/customization/htxc/zbqs/InsertCgsqxmDt1Cmd.java new file mode 100644 index 0000000..c3aada2 --- /dev/null +++ b/src/main/java/com/customization/htxc/zbqs/InsertCgsqxmDt1Cmd.java @@ -0,0 +1,93 @@ +package com.customization.htxc.zbqs; + +import com.engine.core.cfg.annotation.CommandDynamicProxy; +import com.engine.core.interceptor.AbstractCommandProxy; +import com.engine.core.interceptor.Command; +import com.engine.workflow.cmd.requestForm.RequestSubmitCmd; +import com.engine.workflow.entity.requestForm.RequestOperationResultBean; +import weaver.conn.RecordSet; +import weaver.conn.RecordSetTrans; +import weaver.general.BaseBean; +import weaver.general.Util; +import weaver.interfaces.htsc.comInfo.PropBean; + +import javax.servlet.http.HttpServletRequest; +import java.util.Map; +import java.util.Objects; + +/** + * 将招标请示的数据保存到采购项目明细表一 + */ +@CommandDynamicProxy(target = RequestSubmitCmd.class, desc = "流程提交处理业务") +public class InsertCgsqxmDt1Cmd extends AbstractCommandProxy> { + + @Override + public Map execute(Command> targetCommand) { + RequestSubmitCmd requestSubmitCmd = (RequestSubmitCmd) targetCommand; + HttpServletRequest request = requestSubmitCmd.getRequest();//从request中可以取到参数，不用以前的方法了 + String requestid = Util.null2String(request.getParameter("requestid")); + String workflowid = Util.null2String(request.getParameter("workflowid")); + String nodetype = Util.null2String(request.getParameter("nodetype")); + String nodeid = Util.null2String(request.getParameter("nodeid")); + String src = Util.null2String(request.getParameter("src")); + String remark = Util.HTMLtoTxt(Util.null2String(request.getParameter("remark"))).trim(); + String operator = Util.null2String(request.getParameter("f_weaver_belongto_userid")); + String requestname = Util.null2String(request.getParameter("requestname")); + BaseBean bb = new BaseBean(); + + bb.writeLog("招标请示拟稿src"+src); + bb.writeLog("招标请示拟稿requestname"+requestname); + //执行标准的业务处理 + Map result = nextExecute(targetCommand); + try{ + + RequestOperationResultBean resultBean = (RequestOperationResultBean) result.get("data"); + String executeResult = resultBean.getType().name(); + RecordSet rs = new RecordSet(); + String sql = "select * from workflow_base where id = "+workflowid; + rs.execute(sql); + rs.next(); + String unnumber = rs.getString("unnumber"); + bb.writeLog("招标请示拟稿unnumber"+unnumber); + PropBean pb = new PropBean(); + String zbqsTable = pb.getPropName("zbqs_table"); + String nodeUnNumber = pb.getNodeUnNumberByid(nodeid); + bb.writeLog("招标请示拟稿nodeUnNumber"+nodeUnNumber); + String zbqsNg = pb.getPropName("zbqs_ng"); + bb.writeLog("招标请示拟稿zbqs_ng"+zbqsNg); + if("SUCCESS".equals(executeResult) && "submit".equals(src)){ + if(Objects.equals("zbqs",unnumber) && Objects.equals(nodeUnNumber,zbqsNg)){ + RecordSetTrans rst = new RecordSetTrans(); + String mainSql = "select * from " + zbqsTable+" where requestid = "+requestid; + rs.execute(mainSql); + if(rs.next()){ + String xmid = rs.getString("jmid"); + String ngr = rs.getString("ngr"); + String szbm = rs.getString("szbm"); + String ngrq = rs.getString("ngrq"); + bb.writeLog("招标请示拟稿jmid"+xmid); + RecordSet rs1 = new RecordSet(); + String selectByRequsetId = "select * from uf_cgxq_dt1 where lcmc = ?"; + rs1.executeQuery(selectByRequsetId,requestid); + if(!rs1.next()){ + String dt1Sql = "insert into uf_cgxq_dt1 (mainid,lcmc,lclx,lczt,sqr,sqbm,sqsj)values('"+xmid+"','"+requestid+"','"+0+"','"+0+"','"+ngr+"','"+szbm+"','"+ngrq+"')"; + bb.writeLog("招标请示拟稿dt1Sql"+dt1Sql); + try { + rst.execute(dt1Sql); + } catch (Exception e) { + e.printStackTrace(); + } + } + + + } + } + } + + }catch (Exception e){ + + } + return result; + } +} + diff --git a/src/main/java/com/customization/htxc/zbqs/StopUpdateStatus.java b/src/main/java/com/customization/htxc/zbqs/StopUpdateStatus.java new file mode 100644 index 0000000..bf0d76f --- /dev/null +++ b/src/main/java/com/customization/htxc/zbqs/StopUpdateStatus.java @@ -0,0 +1,65 @@ +package com.customization.htxc.zbqs; + +import com.engine.core.cfg.annotation.CommandDynamicProxy; +import com.engine.core.interceptor.AbstractCommandProxy; +import com.engine.core.interceptor.Command; +import com.engine.workflow.cmd.requestForm.RequestSubmitCmd; +import com.engine.workflow.entity.requestForm.RequestOperationResultBean; +import weaver.conn.RecordSet; +import weaver.general.Util; +import weaver.interfaces.htsc.GlobatTools.JAVATools; +import weaver.interfaces.htsc.comInfo.PropBean; + +import javax.servlet.http.HttpServletRequest; +import java.util.Map; +import java.util.Objects; + +/** + * 如果流程被退回拟稿，则将采购项目dt1中的流程状态置为已终止（2） + */ +@CommandDynamicProxy(target = RequestSubmitCmd.class, desc = "流程提交处理业务") +public class StopUpdateStatus extends AbstractCommandProxy> { + + @Override + public Map execute(Command> targetCommand) { + RequestSubmitCmd requestSubmitCmd = (RequestSubmitCmd) targetCommand; + HttpServletRequest request = requestSubmitCmd.getRequest();//从request中可以取到参数，不用以前的方法了 + String requestid = Util.null2String(request.getParameter("requestid")); + String workflowid = Util.null2String(request.getParameter("workflowid")); + String nodetype = Util.null2String(request.getParameter("nodetype")); + String nodeid = Util.null2String(request.getParameter("nodeid")); + String src = Util.null2String(request.getParameter("src")); + JAVATools.writelog("招标请示测试终止src"+src); + String remark = Util.HTMLtoTxt(Util.null2String(request.getParameter("remark"))).trim(); + String operator = Util.null2String(request.getParameter("f_weaver_belongto_userid")); + //执行标准的业务处理 + Map result = nextExecute(targetCommand); + RequestOperationResultBean resultBean = (RequestOperationResultBean) result.get("data"); + String executeResult = resultBean.getType().name(); + RecordSet rs = new RecordSet(); + String sql = "select * from workflow_base where id = "+workflowid; + rs.execute(sql); + rs.next(); + PropBean pb = new PropBean(); + String zbqsTable = pb.getPropName("zbqs_table"); + String unnumber = rs.getString("unnumber"); + JAVATools.writelog("招标请示测试终止unnumber"+unnumber); + sql = "select * from workflow_requestbase where requestid = "+requestid; + rs.execute(sql); + rs.next(); + String isstopped = rs.getString("isstopped"); + JAVATools.writelog("招标汇报测试终止isstopped"+isstopped); + if("SUCCESS".equals(executeResult) && "1".equals(isstopped)){ + if(Objects.equals("zbqs",unnumber) ){ + String mainSql = "select * from " + zbqsTable+" where requestid = "+requestid; + rs.execute(mainSql); + if(rs.next()){ + String xmid = rs.getString("jmid"); + String upsql = "update uf_cgxq_dt1 set lczt = 2 where mainid = "+xmid+" and lcmc = "+requestid; + rs.execute(upsql); + } + } + } + return result; + } +}