using BP.DA; using BP.Sys; using BP.WF; using System; using System.Collections.Generic; using System.Data; using System.Linq; using System.Text; using System.Threading.Tasks; namespace BP.Demo { public class DoEvn : BP.Sys.Base.EventBase { public override void Do() { switch (this.EventSource) { //同步创建类表单 WorkArrive case EventListNode.SendSuccess://工作到达时 this.SucessInfo = "执行成功."; try { if (this.NodeID ==2105) { updateFrm(); } } catch (Exception ex) { this.SucessInfo = "err@对应流程数据未成功同步。"; BP.DA.Log.DebugWriteError(ex.Message); } break; //同步创建类表单 case EventListNode.WorkArrive://工作到达时 this.SucessInfo = "执行成功."; try { updateFrm(); } catch (Exception ex) { this.SucessInfo = "err@对应流程数据未成功同步。"; BP.DA.Log.DebugWriteError(ex.Message); } break; } //throw new NotImplementedException(); } public void updateFrm() { //获取流程信息 GenerWorkFlow gwf = new GenerWorkFlow(this.WorkID); Flow fl = new Flow(gwf.FlowNo); Node nd = new Node(gwf.NodeID); //审批流程 string[] flowAttr = { "002", "021" }; if (Array.IndexOf(flowAttr, gwf.FlowNo) >= 0) { try { string empsHuiqian = "";//获取会签处理人员 string empsShengHe = "";//获取审核处理人员 string empsJiaoDui = "";//获取校对处理人员 string empsPiZhun = "";//获取批准处理人员 string[] massArr = { "008", "009", "029" };//质量要点流程编号集合 //获取主表数据 string ptable = BP.DA.DBAccess.RunSQLReturnString("select PTable from WF_Flow where No='" + gwf.FlowNo + "'"); BP.WF.GERpt hisGERpt = new BP.WF.GERpt(ptable); GERpt rpt = hisGERpt; rpt.OID = gwf.WorkID; rpt.RetrieveFromDBSources(); string lcbh = rpt.GetValStrByKey("LCBH");//跳转前流程编号 string bfoid = rpt.GetValStrByKey("BFOID"); //之前OID if (DataType.IsNullOrEmpty(lcbh)) { throw new Exception("err@跳转流程编号为空，请检查"); } //技术协议与质量要点审批 if (gwf.FlowNo == "002") { string zlydbh = rpt.GetValStrByKey("ZLYDBH");//质量要点编号 string jsbzxybh = rpt.GetValStrByKey("JSBZXYBH"); //技术协议编号 empsHuiqian = BP.DA.DBAccess.RunSQLReturnString("select wm_concat(emptot) from ND2TRACK where workID =" + gwf.WorkID + " AND ndfrom IN('201', '205') AND ACTIONTYPE != 22"); empsShengHe = BP.DA.DBAccess.RunSQLReturnString("select wm_concat(emptot) from ND2TRACK where workID =" + gwf.WorkID + " AND ndfrom IN('203') AND ACTIONTYPE != 22"); empsJiaoDui = BP.DA.DBAccess.RunSQLReturnString("select EmpName from wf_generworkerlist where WorkID=" + gwf.WorkID + " AND FK_Node IN('206')"); empsPiZhun = BP.DA.DBAccess.RunSQLReturnString("select EmpName from wf_generworkerlist where WorkID=" + gwf.WorkID + " AND FK_Node IN('207')"); ptable = BP.DA.DBAccess.RunSQLReturnString("select PTable from WF_Flow where No=" + lcbh + ""); BP.WF.GERpt hisGERpt2 = new BP.WF.GERpt(ptable); GERpt rpt2 = hisGERpt2; rpt2.OID = gwf.WorkID; rpt2.RetrieveFromDBSources(); string sh = rpt2.GetValStrByKey("SH");//审核 string xd = rpt2.GetValStrByKey("XD");//校对 string pz = rpt2.GetValStrByKey("PZ");//批准 ptable = BP.DA.DBAccess.RunSQLReturnString("select PTable from WF_Flow where No=" + lcbh + ""); //更新主表字段 if (DataType.IsNullOrEmpty(sh) && DataType.IsNullOrEmpty(xd) && DataType.IsNullOrEmpty(pz)) { if (Array.IndexOf(massArr, lcbh) >= 0) { string hq = rpt2.GetValStrByKey("HQ"); BP.DA.DBAccess.RunSQL("update " + ptable + " set SH = '" + empsShengHe + "', XD = '" + empsJiaoDui + "', PZ = '" + empsPiZhun + "',HQ = '" + empsHuiqian + "' WHERE OID=" + bfoid + ""); } else { BP.DA.DBAccess.RunSQL("update " + ptable + " set SH = '" + empsShengHe + "', XD = '" + empsJiaoDui + "', PZ = '" + empsPiZhun + "' WHERE OID=" + bfoid + ""); } } //更新对应履历表明细表 string dtlNo = BP.DA.DBAccess.RunSQLReturnString("SELECT PTable from Sys_MapDtl WHERE FK_MapData = " + ptable + " AND Name LIKE '%履历表%'"); if (dtlNo == "" || dtlNo == null) { this.SucessInfo = "err@对应流程" + lcbh + "的履历表未查询到，履历表未同步数据。"; BP.DA.Log.DebugWriteError(this.SucessInfo); } int num = BP.DA.DBAccess.RunSQLReturnValInt("select oid from " + dtlNo + " WHERE RefPK = " + bfoid); string starter = BP.DA.DBAccess.RunSQLReturnString("select startername from wf_generworkflow where workid =" + bfoid); starter = starter + ","; if (num == 0) { BP.DA.DBAccess.RunSQL("INSERT INTO " + dtlNo + " (BZSHR, PZR,) VALUES(" + starter + empsShengHe + ", " + empsPiZhun + ""); } } //工艺卡审批 if (gwf.FlowNo == "021") { empsShengHe = BP.DA.DBAccess.RunSQLReturnString("SELECT EmptoT FROM ND21TRACK WHERE WorkID=" + gwf.WorkID + " AND ndfrom ='2101'AND ndto = '2102' "); empsJiaoDui = BP.DA.DBAccess.RunSQLReturnString("select wm_concat(emptot) from ND21TRACK where workID =" + gwf.WorkID + " AND ndfrom ='2103' AND ACTIONTYPE != 22"); empsPiZhun = BP.DA.DBAccess.RunSQLReturnString("select EmpName from wf_generworkerlist where WorkID=" + gwf.WorkID + " AND FK_Node = '2105'"); ptable = BP.DA.DBAccess.RunSQLReturnString("select PTable from WF_Flow where No=" + lcbh + ""); BP.WF.GERpt hisGERpt2 = new BP.WF.GERpt(ptable); GERpt rpt2 = hisGERpt2; rpt2.OID = gwf.WorkID; rpt2.RetrieveFromDBSources(); string sh = rpt2.GetValStrByKey("RIVIEWER");//审核 string xd = rpt2.GetValStrByKey("APPROVER");//校对 string pz = rpt2.GetValStrByKey("PROOFREADER");//批准 string pc_NO = rpt2.GetValStrByKey("RC_NO");//工艺卡编号 string qp_NO = rpt2.GetValStrByKey("QP_NO");//质量要点编号 ptable = BP.DA.DBAccess.RunSQLReturnString("select PTable from WF_Flow where No=" + lcbh + ""); if (DataType.IsNullOrEmpty(sh) && DataType.IsNullOrEmpty(xd) && DataType.IsNullOrEmpty(pz)) { BP.DA.DBAccess.RunSQL("update " + ptable + " set RIVIEWER = '" + empsShengHe + "', PROOFREADER = '" + empsJiaoDui + "', APPROVER= '" + empsPiZhun + "' WHERE OID=" + bfoid + ""); } //更新对应工艺卡履历表明细表 string dtlNo = BP.DA.DBAccess.RunSQLReturnString("SELECT PTable from Sys_MapDtl WHERE FK_MapData = " + ptable + " AND Name LIKE '%履历表%'"); if (dtlNo == "" || dtlNo == null) { this.SucessInfo = "err@对应流程" + lcbh + "的履历表未查询到，履历表未同步数据。"; BP.DA.Log.DebugWriteError(this.SucessInfo); } int num = BP.DA.DBAccess.RunSQLReturnValInt("select oid from " + dtlNo + " WHERE RefPK = " + bfoid); string starter = BP.DA.DBAccess.RunSQLReturnString("select startername from wf_generworkflow where workid =" + bfoid); starter = starter + ","; if (num == 0) { BP.DA.DBAccess.RunSQL("INSERT INTO " + dtlNo + " (RC_NO, QP_NO,) VALUES(" + pc_NO + ", " + qp_NO + ""); } } } catch (Exception ex) { BP.DA.Log.DebugWriteError(ex.Message); } } } } }