using System; using System.Collections.Generic; using System.Data; using System.Linq; using System.Text; using System.Web; using System.Web.Mvc; using DSWeb.Areas.CommMng.Models; using Microsoft.Practices.EnterpriseLibrary.Data; using DSWeb.TruckMng.Helper; using HcUtility.Comm; using DSWeb.TruckMng.Helper.Repository; using DSWeb.Areas.Import.Models.XXH; using System.Data.Common; using DSWeb.EntityDA; using DSWeb.Areas.OA.Models.WorkFlow; using System.Data.SqlClient; using WebSqlHelper; using DSWeb.TruckMng.Comm.Cookie; using DSWeb.Areas.Mobile.DAL; using DSWeb.MvcShipping.DAL.MsSysParamSet; using DSWeb.Areas.MvcShipping.Helper; using DSWeb.Areas.SysMng.DAL.SysTask; namespace DSWeb.Areas.CommMng.DAL { public class WorkFlowDAL { #region [操作工作流] 开始工作流过程 static public Resultmb WorkFlowStart(string WorkFlowName, string BSNO, string USERID,string BILLNO) { var strSql = new StringBuilder(); var result = new Resultmb(); var _r = WorkFlowDAL.GetWorkFlowmb(WorkFlowName, USERID); WorkFlowmb _workflow = new WorkFlowmb(); if (_r.Success) _workflow = (WorkFlowmb)_r.Data; else { result.Success = false; result.Message = _r.Message; return result; } var workflowID = _workflow.GID; var TYPENO = _workflow.TYPE; var AutoFinish = _workflow.isAuto; var islast = false; if (AutoFinish == "1") islast = true; if (AutoFinish == "0")//不是自动审核通过 { strSql.Append(" if (select bsno from workflow_using where bsno='" + BSNO + "' and TYPENO=" + TYPENO + ") is NULL "); strSql.Append(" insert into workflow_using ([BSNO],[WORKFLOWID],[STEPNO],[PreviousSTEPID],[CurrentID],[rejector_id],[reject_time],[FINISHED] "); strSql.Append(" ,[ISDELETE],[DELETEUSER],[DELETETIME],[Reason],[OP],[TYPENO],CREATETIME) values('" + BSNO + "','" + workflowID + "', "); strSql.Append(" dbo.[GetNextStep]('" + workflowID + "','" + BSNO + "','1'),'0','1',null,null,0,null,null,null,null,'" + USERID + "'," + TYPENO + ",getdate()) "); strSql.Append(" else update workflow_using set stepno=dbo.[GetNextStep]('" + workflowID + "','" + BSNO + "','1'),currentid=1,op='" + USERID + "',finished='0',workflowid='" + workflowID + "' "); strSql.Append(" where bsno='" + BSNO + "' and TYPENO=" + TYPENO + " "); } else {//自动审核通过的 strSql.Append(" if (select bsno from workflow_using where bsno='" + BSNO + "' and TYPENO=" + TYPENO + ") is NULL "); strSql.Append(" insert into workflow_using ([BSNO],[WORKFLOWID],[STEPNO],[PreviousSTEPID],[CurrentID],[rejector_id],[reject_time],[FINISHED] "); strSql.Append(" ,[ISDELETE],[DELETEUSER],[DELETETIME],[Reason],[OP],[TYPENO],CREATETIME) values('" + BSNO + "','" + workflowID + "', "); strSql.Append(" dbo.[GetNextStep]('" + workflowID + "','" + BSNO + "','1'),'0','1',null,null,1,null,null,null,null,'" + USERID + "'," + TYPENO + ",getdate()) "); strSql.Append(" else update workflow_using set stepno=0,currentid=0,op='" + USERID + "',finished=1,workflowid='" + workflowID + "' "); strSql.Append(" where bsno='" + BSNO + "' and TYPENO=" + TYPENO + " "); } return setWorkFlowStart(strSql, workflowID, USERID, BSNO, islast,BILLNO); } private static Resultmb setWorkFlowStart(StringBuilder strSql, string WORKFLOWID, string OP, string BSNO, Boolean islast,string BILLNO) { var _count = 0; var _Result = new Resultmb(); Database db = DatabaseFactory.CreateDatabase(); try { _count = db.ExecuteNonQuery(CommandType.Text, strSql.ToString()); } catch (Exception ee) { _Result.Success = false; _Result.Message = ee.Message; return _Result; } if (_count == 0) { _Result.Success = false; _Result.Message = "没有影响数据，可能是已经提交或未设置工作流"; } else { _Result.Success = true; _Result.Message = "新工作流程产生成功"; _Result.totalCount = _count; _Result.islast = islast; } var cookies = new Cookies(); var WorkflowMsg = cookies.getCookie(CookieConstant.WorkflowMsg);//启用消息提示 if (WorkflowMsg == "1") { var RECEIVER = GetAuditor(WORKFLOWID, "1"); //向每个审核人发送消息 foreach (var _RC in RECEIVER) { //var _Message = StartMessage(WORKFLOWID, OP, _RC.GID, BSNO,BILLNO); //SaveMessage(_Message); } } return _Result; } static public Resultmb WorkFlowStart(string WorkFlowName, string BSNO, string USERID, string BILLNO, string GID, string URL, string workflowidstr = "",string MSG="") { var strSql = new StringBuilder(); var workflowID = ""; var TYPENO = ""; var AutoFinish = "0"; var _Result = new Resultmb(); var _workflow = new WorkFlowmb(); if (workflowidstr == "" || workflowidstr == "no") { var _r = GetWorkFlowmb(WorkFlowName, USERID); if (_r.Success) _workflow = (WorkFlowmb)_r.Data; else { _Result.Success = false; _Result.Message = _r.Message; return _Result; } workflowID = _workflow.GID; TYPENO = _workflow.TYPE; AutoFinish = _workflow.isAuto; } else { _workflow = GetWorkFlow(workflowidstr)[0]; workflowID = _workflow.GID; TYPENO = _workflow.TYPE; AutoFinish = _workflow.isAuto; } if (workflowID == "") { _Result.Success = false; _Result.Message = "该工作流程还未设置工作流，请联系管理员"; return _Result; } var islast = false; if (AutoFinish == "1") islast = true; if (islast == false)//不是自动审核通过 { strSql.Append(" if (select bsno from workflow_using where bsno='" + BSNO + "' and TYPENO=" + TYPENO + ") is NULL "); strSql.Append(" insert into workflow_using ([BSNO],[WORKFLOWID],[STEPNO],[PreviousSTEPID],[CurrentID],[rejector_id],[reject_time],[FINISHED] "); strSql.Append(" ,[ISDELETE],[DELETEUSER],[DELETETIME],[Reason],[OP],[TYPENO],CREATETIME) values('" + BSNO + "','" + workflowID + "', "); strSql.Append(" dbo.[GetNextStep]('" + workflowID + "','" + BSNO + "','1'),'0','1',null,null,0,null,null,null,null,'" + USERID + "'," + TYPENO + ",getdate()) "); strSql.Append(" else update workflow_using set stepno=dbo.[GetNextStep]('" + workflowID + "','" + BSNO + "','1'),currentid=1,op='" + USERID + "',finished='0',workflowid='" + workflowID + "' "); strSql.Append(" where bsno='" + BSNO + "' and TYPENO=" + TYPENO + " "); } else { strSql.Append(" if (select bsno from workflow_using where bsno='" + BSNO + "' and TYPENO=" + TYPENO + ") is NULL "); strSql.Append(" insert into workflow_using ([BSNO],[WORKFLOWID],[STEPNO],[PreviousSTEPID],[CurrentID],[rejector_id],[reject_time],[FINISHED] "); strSql.Append(" ,[ISDELETE],[DELETEUSER],[DELETETIME],[Reason],[OP],[TYPENO],CREATETIME) values('" + BSNO + "','" + workflowID + "', "); strSql.Append(" dbo.[GetNextStep]('" + workflowID + "','" + BSNO + "','1'),'0','1',null,null,1,null,null,null,null,'" + USERID + "'," + TYPENO + ",getdate()) "); strSql.Append(" else update workflow_using set stepno=0,currentid=0,op='" + USERID + "',finished=1,workflowid='" + workflowID + "' "); strSql.Append(" where bsno='" + BSNO + "' and TYPENO=" + TYPENO + " "); } return setWorkFlowStart(strSql, workflowID, USERID, BSNO, islast, BILLNO, GID, URL,MSG); } private static Resultmb setWorkFlowStart(StringBuilder strSql, string WORKFLOWID, string OP, string BSNO, Boolean islast, string BILLNO, string GID, string URL,string MSG="") { var _count = 0; var _Result = new Resultmb(); Database db = DatabaseFactory.CreateDatabase(); try { _count = db.ExecuteNonQuery(CommandType.Text, strSql.ToString()); } catch (Exception ee) { _Result.Success = false; _Result.Message = ee.Message; } if (_count == 0) { _Result.Success = false; _Result.Message = "没有影响数据，可能是已经提交或未设置工作流"; } else { _Result.Success = true; _Result.Message = "新工作流程产生成功"; _Result.totalCount = _count; _Result.islast = islast; } var cookies = new Cookies(); var WorkflowMsg = cookies.getCookie(CookieConstant.WorkflowMsg);//启用消息提示 if (WorkflowMsg == "1") { var RECEIVER = GetAuditor(WORKFLOWID, "1"); //向每个审核人发送消息 foreach (var _RC in RECEIVER) { //var _Message = StartMessage(WORKFLOWID, OP, _RC.GID, BSNO, BILLNO, GID, URL,MSG); //SaveMessage(_Message); } } return _Result; } /// /// 撤回工作流 会清空这个BSNO的workflow_using数据 /// /// /// /// /// static public Resultmb WorkFlowReset(string WorkFlowName, string BSNO, string USERID) { var strSql = new StringBuilder(); var workflowID = GetBSNOWorkFlowID(WorkFlowName, BSNO)[0].GID; if (workflowID == "") { var Result = new Resultmb(); Result.Success = true; Result.Message = ""; return Result; } //strSql.Append(" delete from [workflow_using] where cargo_id in( " + cargo_id + ")"); strSql.Append(" delete from workflow_using where bsno='" + BSNO + "' and workflowid='" + workflowID + "'"); //strSql.Append(" from import_cargo where id in( " + cargo_id + ")"); //return setWorkFlowStart(strSql, workflowID, "", BSNO,false);//ExecuteNonQuery var _Result = new Resultmb(); Database db = DatabaseFactory.CreateDatabase(); try { _Result.totalCount = db.ExecuteNonQuery(CommandType.Text, strSql.ToString()); } catch (Exception ee) { _Result.Success = false; _Result.Message = ee.Message; } return _Result; } #endregion #region [查询]通过工作流名字和员工编号查找工作流编号 List GetWorkFlowID(string NAME, string USERID) static public List GetWorkFlowID(string NAME, string USERID) { var strSql = new StringBuilder(); //strSql.Append(" select [dbo].[GetWorkFlowID]('" + NAME + "','" + USERID + "') workflowid, "); //strSql.Append(" ( select name from workflow where gid= [dbo].[GetWorkFlowID]('" + NAME + "','" + USERID + "') ) name,(select type from workflow where gid= [dbo].[GetWorkFlowID]('" + NAME + "','" + USERID + "') ) type "); strSql.Append(" declare @workflowID varchar(50) "); strSql.Append(" set @workflowID = [dbo].[GetWorkFlowID]('" + NAME + "','" + USERID + "') "); strSql.Append(" select @workflowID workflowid, "); strSql.Append(" [NAME] name,type "); strSql.Append(" ,case when(select count(*) from workflow_step where (workflowid = @workflowID "); strSql.Append(" and groupid = 0))> 0 then 1 else 0 end isAuto ");//如果能自动完成 则isAuto=1 strSql.Append(" from workflow where gid = @workflowID "); return SetWorkFlowID(strSql); } static public List GetWorkFlow(string WorkFlowID) { var strSql = new StringBuilder(); strSql.Append(" select GID workflowid, "); strSql.Append(" [NAME] name, type"); strSql.Append(" ,case when(select count(*) from workflow_step where (workflowid = '" + WorkFlowID + "' "); strSql.Append(" and groupid = 0))> 0 then 1 else 0 end isAuto ");//如果能自动完成 则isAuto=1 strSql.Append(" from workflow where GID='" + WorkFlowID + "'"); return SetWorkFlowID(strSql); } static public List GetBSNOWorkFlowID(string NAME, string BSNO) { var strSql = new StringBuilder(); //strSql.Append(" select [dbo].[GetBSNOWorkFlowID]('" + NAME + "','" + BSNO + "') workflowid, "); //strSql.Append(" '" + NAME + "' as name,(select type from workflow where gid= [dbo].[GetBSNOWorkFlowID]('" + NAME + "','" + BSNO + "') ) type "); //strSql.Append(" ,case when(select count(*) from workflow_step where (workflowid = [dbo].[GetBSNOWorkFlowID]('" + NAME + "','" + BSNO + "') "); //strSql.Append(" and groupid = 0))> 0 then 1 else 0 end isAuto ");//如果能自动完成 则isAuto=1 //return SetWorkFlowID(strSql); strSql.Append(" declare @workflowid varchar(50) "); strSql.Append(" set @workflowid = [dbo].[GetBSNOWorkFlowID]('" + NAME + "','" + BSNO + "') "); strSql.Append(" select @workflowid workflowid, "); strSql.Append(" '" + NAME + "' as name,(select type from workflow where gid= @workflowid ) type "); strSql.Append(" ,case when(select count(*) from workflow_step where (workflowid = @workflowid "); strSql.Append(" and groupid = 0))> 0 then 1 else 0 end isAuto ");//如果能自动完成 则isAuto=1 return SetWorkFlowID(strSql); } static public List GetBSNOWorkFlowID(string NAME, string BSNO, DbTransaction tran) { var strSql = new StringBuilder(); //strSql.Append(" select [dbo].[GetBSNOWorkFlowID]('" + NAME + "','" + BSNO + "') workflowid, "); //strSql.Append(" '" + NAME + "' as name,(select type from workflow where gid= [dbo].[GetBSNOWorkFlowID]('" + NAME + "','" + BSNO + "') ) type "); //strSql.Append(" ,case when(select count(*) from workflow_step where (workflowid = [dbo].[GetBSNOWorkFlowID]('" + NAME + "','" + BSNO + "') "); //strSql.Append(" and groupid = 0))> 0 then 1 else 0 end isAuto ");//如果能自动完成 则isAuto=1 //return SetWorkFlowID(strSql); strSql.Append(" declare @workflowid varchar(50) "); strSql.Append(" set @workflowid = [dbo].[GetBSNOWorkFlowID]('" + NAME + "','" + BSNO + "') "); strSql.Append(" select @workflowid workflowid, "); strSql.Append(" '" + NAME + "' as name,(select type from workflow where gid= @workflowid ) type "); strSql.Append(" ,case when(select count(*) from workflow_step where (workflowid = @workflowid "); strSql.Append(" and groupid = 0))> 0 then 1 else 0 end isAuto ");//如果能自动完成 则isAuto=1 return SetWorkFlowID(strSql,tran); } private static List SetWorkFlowID(StringBuilder strSql) { var bodyList = new List(); Database db = DatabaseFactory.CreateDatabase(); using (IDataReader reader = db.ExecuteReader(CommandType.Text, strSql.ToString())) { while (reader.Read()) { WorkFlowmb data = new WorkFlowmb(); #region Set DB data to Object data.GID = Convert.ToString(reader["WORKFLOWID"]); data.NAME = Convert.ToString(reader["NAME"]); data.TYPE = Convert.ToString(reader["type"]); data.isAuto = Convert.ToString(reader["isAuto"]); #endregion bodyList.Add(data); } reader.Close(); } return bodyList; } private static List SetWorkFlowID(StringBuilder strSql, DbTransaction tran) { var bodyList = new List(); Database db = DatabaseFactory.CreateDatabase(); using (IDataReader reader = db.ExecuteReader(tran, CommandType.Text, strSql.ToString())) { while (reader.Read()) { WorkFlowmb data = new WorkFlowmb(); #region Set DB data to Object data.GID = Convert.ToString(reader["WORKFLOWID"]); data.NAME = Convert.ToString(reader["NAME"]); data.TYPE = Convert.ToString(reader["type"]); data.isAuto = Convert.ToString(reader["isAuto"]); #endregion bodyList.Add(data); } reader.Close(); } return bodyList; } static public DBResult GetWorkFlowmb(string NAME, string USERID) { var result = new DBResult(); var _r = GetWorkFlowID(NAME, USERID); if (_r.Count > 0) { result.Success = true; result.Data = _r[0]; } else { result.SetErrorInfo($"未找到可用的工作流，请确认已为该用户所在的公司设定这个类型的工作流。参考信息：《工作流类型：{NAME},用户ID：{USERID}》"); } return result; } #endregion #region [查询]通过WORKFLOWID查找workflow_step的内容 /* static public List GetWorkFlowStep(string WorkFlowName, string UserID) { var strSql = new StringBuilder(); strSql.Append(" select * from workflow_step where WORKFLOWID = "); strSql.Append(" dbo.getworkflowid('" + WorkFlowName + "','" + UserID + "') "); strSql.Append(" and AUDITOR='" + UserID + "' order by STEPNO"); return SetWorkFlowStep(strSql); }*/ static public List GetWorkFlowStep(string WORKFLOWID, string UserID) { var strSql = new StringBuilder(); strSql.Append(" select * from workflow_step where WORKFLOWID = '" + WORKFLOWID + "' "); strSql.Append(" and AUDITOR='" + UserID + "' order by STEPNO"); return SetWorkFlowStep(strSql); } private static List SetWorkFlowStep(StringBuilder strSql) { var bodyList = new List(); Database db = DatabaseFactory.CreateDatabase(); using (IDataReader reader = db.ExecuteReader(CommandType.Text, strSql.ToString())) { while (reader.Read()) { DSWeb.Areas.CommMng.Models.WorkFlowStepmb data = new DSWeb.Areas.CommMng.Models.WorkFlowStepmb(); #region Set DB data to Object data.GID = Convert.ToString(reader["GID"]); data.NAME = Convert.ToString(reader["NAME"]); data.STEPNO = Convert.ToString(reader["STEPNO"]); data.NEEDALLPASS = Convert.ToString(reader["NEEDALLPASS"]); data.ISMUST = Convert.ToString(reader["ISMUST"]); data.ISLAST = Convert.ToString(reader["ISLAST"]); #endregion bodyList.Add(data); } reader.Close(); } return bodyList; } #endregion #region [查询]获取该用户，在该工作流中 目前可以操作的业务编号列表 //// /// /// [查询] 获取该用户，在该工作流中 目前可以操作的业务编号列表 不指定步骤组号 /// /// /// /// static public List GetWorkFlowBSNOList(string WorkFlowID, string USERID) { var strSql = new StringBuilder(); strSql.Append(" select BSNO,WORKFLOWID,STEPNO from workflow_using where workflowid='" + WorkFlowID + "' and stepno in( "); strSql.Append(" select stepno from workflow_step where WORKFLOWID = '" + WorkFlowID + "' and AUDITOR = '" + USERID + "') "); return SetWorkFlowState(strSql); } /// /// [查询] 获取该用户，在该工作流中 目前可以操作的业务编号列表 指定步骤组号 /// /// /// /// /// static public List GetWorkFlowBSNOList(string WorkFlowID, int StepNo, string USERID) { var strSql = new StringBuilder(); strSql.Append(" select BSNO,WORKFLOWID,STEPNO from workflow_using where workflowid='" + WorkFlowID + "' and stepno in( "); strSql.Append(" select stepno from workflow_step where WORKFLOWID = '" + WorkFlowID + "' and AUDITOR = '" + USERID + "') and stepno=" + StepNo.ToString() + " "); return SetWorkFlowState(strSql); } static public List GetWorkFlowBSNOListByName(string WorkFlowName, string USERID) { var strSql = new StringBuilder(); strSql.Append(" declare @workflowID varchar(50) "); strSql.Append(" set @workflowID = [dbo].[GetWorkFlowID]('" + WorkFlowName + "','" + USERID + "') "); strSql.Append(" select BSNO,WORKFLOWID,STEPNO from workflow_using where workflowid=@workflowID and stepno in( "); strSql.Append(" select stepno from workflow_step where WORKFLOWID = @workflowID and AUDITOR = '" + USERID + "') "); return SetWorkFlowState(strSql); } static public List GetWorkFlowBSNOListByName(string WorkFlowName, int StepNo, string USERID) { var strSql = new StringBuilder(); strSql.Append(" declare @workflowID varchar(50) "); strSql.Append(" set @workflowID = [dbo].[GetWorkFlowID]('" + WorkFlowName + "','" + USERID + "') "); strSql.Append(" select BSNO,WORKFLOWID,STEPNO from workflow_using where workflowid=@workflowID and stepno in( "); strSql.Append(" select stepno from workflow_step where WORKFLOWID = @workflowID and AUDITOR = '" + USERID + "') and stepno=" + StepNo.ToString() + " "); return SetWorkFlowState(strSql); } private static List SetWorkFlowState(StringBuilder strSql) { var bodyList = new List(); Database db = DatabaseFactory.CreateDatabase(); using (IDataReader reader = db.ExecuteReader(CommandType.Text, strSql.ToString())) { while (reader.Read()) { WorkFlow_Usingmb data = new WorkFlow_Usingmb(); #region Set DB data to Object data.BSNO = Convert.ToString(reader["BSNO"]); data.WORKFLOWID = Convert.ToString(reader["WORKFLOWID"]); data.STEPNO = Convert.ToString(reader["STEPNO"]);/* data.REJECTOR_ID = Convert.ToString(reader["REJECTOR_ID"]); data.REJECT_TIME = Convert.ToString(reader["REJECT_TIME"]); data.FINISHED = Convert.ToString(reader["FINISHED"]); data.ISDELETE = Convert.ToString(reader["ISDELETE"]); data.DELETEUSER = Convert.ToString(reader["DELETEUSER"]); data.DELETETIME = Convert.ToString(reader["DELETETIME"]);*/ #endregion bodyList.Add(data); } reader.Close(); } return bodyList; } #endregion #region [查询]根据业务BSNO获取工作流状态 static public List GetBSNOWorkFlow(string WORKFLOWID, string BSNO) { var strSql = new StringBuilder(); strSql.Append(" select name,wd.stepno,wd.groupid,wd.auditor,u.showname,wd.billno from "); strSql.Append(" (select *, ROW_NUMBER() over(partition by groupid,stepno order by createtime ) as rowNum "); strSql.Append(" from workflow_step where workflowid='" + WORKFLOWID + "' "); strSql.Append(" ) ranked "); strSql.Append(" left join workflow_do wd on (wd.workflowid='" + WORKFLOWID + "' and wd.isdelete is null) "); strSql.Append(" and wd.stepno=ranked.stepno and wd.billno='" + BSNO + "' "); strSql.Append(" left join [user] U on u.gid=wd.auditor and wd.groupid=ranked.groupid "); strSql.Append(" where ranked.rowNum <= 1 "); strSql.Append(" order by ranked.groupid,ranked.stepno, ranked.createtime "); return SetBSNOWorkFlow(strSql); } static public List GetBSNOWorkFlow(string WORKFLOWID, string BSNO, DbTransaction tran) { var strSql = new StringBuilder(); strSql.Append(" select name,wd.stepno,wd.groupid,wd.auditor,u.showname,wd.billno from "); strSql.Append(" (select *, ROW_NUMBER() over(partition by groupid,stepno order by createtime ) as rowNum "); strSql.Append(" from workflow_step where workflowid='" + WORKFLOWID + "' "); strSql.Append(" ) ranked "); strSql.Append(" left join workflow_do wd on (wd.workflowid='" + WORKFLOWID + "' and wd.isdelete is null) "); strSql.Append(" and wd.stepno=ranked.stepno and wd.billno='" + BSNO + "' "); strSql.Append(" left join [user] U on u.gid=wd.auditor and wd.groupid=ranked.groupid "); strSql.Append(" where ranked.rowNum <= 1 "); strSql.Append(" order by ranked.groupid,ranked.stepno, ranked.createtime "); return SetBSNOWorkFlow(strSql, tran); } static public List GetBSNOGROUPID(string WORKFLOWID, string BSNO) { var strSql = new StringBuilder(); strSql.Append(" select '' name,stepno,currentid GROUPID,'' auditor,'' showname,bsno billno "); strSql.Append(" from workflow_using where WORKFLOWID='" + WORKFLOWID + "' "); strSql.Append(" and bsno='" + BSNO + "' "); return SetBSNOWorkFlow(strSql); } /// /// 看工作流目前的步骤组 可以用来查看工作流是否在审核流程中 /// /// /// /// static public List GetBSNOGROUPID(string WORKFLOWID, string BSNO, DbTransaction tran) { var strSql = new StringBuilder(); strSql.Append(" select '' name,stepno,currentid GROUPID,'' auditor,'' showname,bsno billno "); strSql.Append(" from workflow_using where WORKFLOWID='" + WORKFLOWID + "' "); strSql.Append(" and bsno='" + BSNO + "' "); return SetBSNOWorkFlow(strSql, tran); } /// /// 看一个BSNO在指定WORKFLOWID的工作流中 是否处于已被审核过的状态 /// 返回true 表示存在一个“具有 这个bsno 这个WORKFLOWID的 finished=0(还未结束) 的workflow_using记录” /// 而且存在至少一个“workflow_do.audittime大于workflow_using.createtime”的workflow_do /// /// /// /// static public bool GetBSNOWORKFLOWIDinAudit(string WORKFLOWID, string BSNO) { var strSql = new StringBuilder(); strSql.Append(" select (select count (*) from workflow_do where Billno=workflow_using.BSNO and workflowid=workflow_using.workflowid and audittime>=workflow_using.createtime) name,stepno,currentid GROUPID,'' auditor,'' showname,bsno billno from workflow_using where FINISHED = 0 and bsno = '" + BSNO + "' and workflowid = '" + WORKFLOWID + "' "); var resultlist = SetBSNOWorkFlow(strSql); if (resultlist.Count <= 0) return false; else { var result = resultlist[0]; if (Convert.ToInt32(result.NAME) > 0) { return true; } else return false; } } private static List SetBSNOWorkFlow(StringBuilder strSql) { var bodyList = new List(); Database db = DatabaseFactory.CreateDatabase(); using (IDataReader reader = db.ExecuteReader(CommandType.Text, strSql.ToString())) { while (reader.Read()) { BSNOWorkFlowStatemb data = new BSNOWorkFlowStatemb(); #region Set DB data to Object data.NAME = Convert.ToString(reader["NAME"]); data.STEPNO = Convert.ToString(reader["STEPNO"]); data.GROUPID = Convert.ToString(reader["GROUPID"]); data.AUDITOR = Convert.ToString(reader["AUDITOR"]); data.SHOWNAME = Convert.ToString(reader["SHOWNAME"]); data.BILLNO = Convert.ToString(reader["BILLNO"]); #endregion bodyList.Add(data); } reader.Close(); } return bodyList; } private static List SetBSNOWorkFlow(StringBuilder strSql, DbTransaction tran) { var bodyList = new List(); Database db = DatabaseFactory.CreateDatabase(); using (IDataReader reader = db.ExecuteReader(tran, CommandType.Text, strSql.ToString())) { while (reader.Read()) { BSNOWorkFlowStatemb data = new BSNOWorkFlowStatemb(); #region Set DB data to Object data.NAME = Convert.ToString(reader["NAME"]); data.STEPNO = Convert.ToString(reader["STEPNO"]); data.GROUPID = Convert.ToString(reader["GROUPID"]); data.AUDITOR = Convert.ToString(reader["AUDITOR"]); data.SHOWNAME = Convert.ToString(reader["SHOWNAME"]); data.BILLNO = Convert.ToString(reader["BILLNO"]); #endregion bodyList.Add(data); } reader.Close(); } return bodyList; } #endregion #region [操作工作流] 插入workflowDo表(工作流动作,推进工作流向下流动) static public Resultmb InsertWorkFlowDo(string WORKFLOWNAME, string BSNO, string USERID,string BILLNO) { var strSql = new StringBuilder(); var WorkFlowID = GetBSNOWorkFlowID(WORKFLOWNAME, BSNO)[0].GID; var _state = GetBSNOGROUPID(WorkFlowID, BSNO)[0]; var STEPNO = _state.STEPNO; var GROUPID = _state.GROUPID; strSql.Append(" select power(2,stepno) stepno_2,stepno,groupid,islast from workflow_step "); strSql.Append(" where workflowid='" + WorkFlowID + "' "); strSql.Append(" and auditor='" + USERID + "' and groupid=" + GROUPID + " and (select " + STEPNO + "&power(2,stepno))>0 "); var StepList = GetWorkFlowStepNO(strSql); if (StepList.Count == 0) { var result = new Resultmb(); result.Success = false; result.Message = result.Message + ("无权限进行审核 ");//工作流代码[" + WorkFlowID + "] 业务编号[" + BSNO + "]"); return result; } var islast = WorkFlowDAL.GetWorkFlowFinal_BSNO(WorkFlowID, GROUPID, BSNO, USERID); return DoInsertWorkFlowDo(WorkFlowID, USERID, BSNO, islast, StepList,BILLNO); } static public Resultmb InsertWorkFlowDo(string WORKFLOWNAME, string BSNO, string USERID, string BILLNO, string GID, string URL) { var strSql = new StringBuilder(); var WorkFlowID = GetBSNOWorkFlowID(WORKFLOWNAME, BSNO)[0].GID; if (WorkFlowID == "") { var _Result = new Resultmb(); _Result.Success = false; _Result.Message = ""; return _Result; } var _state = GetBSNOGROUPID(WorkFlowID, BSNO)[0]; var STEPNO = _state.STEPNO; var GROUPID = _state.GROUPID; strSql.Append(" select power(2,stepno) stepno_2,stepno,groupid,islast from workflow_step "); strSql.Append(" where workflowid='" + WorkFlowID + "' "); strSql.Append(" and auditor='" + USERID + "' and groupid=" + GROUPID + " and (select " + STEPNO + "&power(2,stepno))>0 "); var StepList = GetWorkFlowStepNO(strSql); if (StepList.Count == 0) { var result = new Resultmb(); result.Success = false; result.Message = result.Message + ("无权限进行审核 ");//工作流代码[" + WorkFlowID + "] 业务编号[" + BSNO + "]"); return result; } var islast = WorkFlowDAL.GetWorkFlowFinal_BSNO(WorkFlowID, GROUPID, BSNO, USERID); return DoInsertWorkFlowDo(WorkFlowID, USERID, BSNO, islast, StepList, BILLNO, GID, URL); } static public Resultmb InsertWorkFlowDo(string WORKFLOWNAME, string BSNO, string USERID, DbTransaction tran,string BILLNO) { var strSql = new StringBuilder(); var WorkFlowID = GetBSNOWorkFlowID(WORKFLOWNAME, BSNO,tran)[0].GID; var _state = GetBSNOGROUPID(WorkFlowID, BSNO, tran)[0]; var STEPNO = _state.STEPNO; var GROUPID = _state.GROUPID; strSql.Append(" select power(2,stepno) stepno_2,stepno,groupid,islast from workflow_step "); strSql.Append(" where workflowid='" + WorkFlowID + "' "); strSql.Append(" and auditor='" + USERID + "' and groupid=" + GROUPID + " and (select " + STEPNO + "&power(2,stepno))>0 "); var StepList = GetWorkFlowStepNO(strSql); if (StepList.Count == 0) { var result = new Resultmb(); result.Success = false; result.Message = result.Message + ("无权限进行审核 ");//工作流代码[" + WorkFlowID + "] 业务编号[" + BSNO + "]"); return result; } var islast = WorkFlowDAL.GetWorkFlowFinal_BSNO(WorkFlowID, GROUPID, BSNO, USERID, tran); return DoInsertWorkFlowDo(WorkFlowID, USERID, BSNO, islast, StepList, tran,BILLNO); } static public Resultmb InsertWorkFlowDo(string WORKFLOWNAME, string BSNO, string USERID, DbTransaction tran, string BILLNO, string GID, string URL) { var strSql = new StringBuilder(); var WorkFlowID = GetBSNOWorkFlowID(WORKFLOWNAME, BSNO,tran)[0].GID; if (WorkFlowID == "") { var result = new Resultmb(); result.Success = false; result.Message = result.Message + ("无权限进行审核 ");//工作流代码[" + WorkFlowID + "] 业务编号[" + BSNO + "]"); return result; } else { var _state = GetBSNOGROUPID(WorkFlowID, BSNO, tran)[0]; var STEPNO = _state.STEPNO; var GROUPID = _state.GROUPID; strSql.Append(" select power(2,stepno) stepno_2,stepno,groupid,islast from workflow_step "); strSql.Append(" where workflowid='" + WorkFlowID + "' "); strSql.Append(" and auditor='" + USERID + "' and groupid=" + GROUPID + " and (select " + STEPNO + "&power(2,stepno))>0 "); var StepList = GetWorkFlowStepNO(strSql); if (StepList.Count == 0) { var result = new Resultmb(); result.Success = false; result.Message = result.Message + ("无权限进行审核 ");//工作流代码[" + WorkFlowID + "] 业务编号[" + BSNO + "]"); return result; } var islast = WorkFlowDAL.GetWorkFlowFinal_BSNO(WorkFlowID, GROUPID, BSNO, USERID, tran); return DoInsertWorkFlowDo(WorkFlowID, USERID, BSNO, islast, StepList, tran, BILLNO, GID, URL); } } private static List GetWorkFlowStepNO(StringBuilder strSql) { //var headList = new List(); Database db = DatabaseFactory.CreateDatabase(); var bodyList = new List(); using (IDataReader reader = db.ExecuteReader(CommandType.Text, strSql.ToString())) { while (reader.Read()) { DSWeb.Areas.CommMng.Models.WorkFlowStepmb data = new DSWeb.Areas.CommMng.Models.WorkFlowStepmb(); #region Set DB data to Object data.STEPNO = Convert.ToString(reader["STEPNO"]); data.GROUPID = Convert.ToString(reader["GROUPID"]); data.ISLAST = Convert.ToString(reader["ISLAST"]); #endregion bodyList.Add(data); } reader.Close(); } return bodyList; } /* private static int DoInsertWorkFlowDo(string WorkFlowName, string DEPTGID, string USERID, string BSNO, List StepList) { var _count = 0; var islast = 0; for(int i=0;i StepList,string BILLNO) { var result = new Resultmb(); var _count = 0; for (int i = 0; i < StepList.Count; i++) { var stepno = StepList[i].STEPNO; var GROUPID = StepList[i].GROUPID; Database db = DatabaseFactory.CreateDatabase(); var strSql = new StringBuilder(); strSql.Append(" declare @WorkFlowID varchar(50) "); strSql.Append(" set @WorkFlowID='" + WORKFLOWID + "' "); strSql.Append(" insert into workflow_do (GID,workflowid,stepid,billno,auditor,audittime,stepno,isallfinish,GROUPID "); strSql.Append(" ,isfinish,BSNO,feeid,feestatus,DOQUERYSQL,isdelete,deletestep,deleteoperator,deletestepno,operator,applicant) ");//// strSql.Append(" select newid(),workflowid,gid,'" + BSNO + "',auditor,getdate(),stepno,islast,GROUPID "); strSql.Append(" ,0,'','','','','0','','','','',''");//// strSql.Append(" from workflow_step where workflowid=@WorkFlowID "); strSql.Append(" and auditor='" + USERID + "' and stepno ='" + stepno + "' and groupid='" + GROUPID + "' "); result = PushUsing(WORKFLOWID, BSNO, USERID, stepno, GROUPID, islast,BILLNO); if (result.Success != true) {//推进workflow_using的状态 result.Message = result.Message + (" 工作流代码[" + WORKFLOWID + "] 业务编号[" + BSNO + "] 步骤组代码[" + GROUPID + "] 步骤代码[" + stepno + "]"); break; } try {//向workflow_do写入操作日志 _count = _count + db.ExecuteNonQuery(CommandType.Text, strSql.ToString()); } catch (Exception ee) { result.Success = false; result.Message = "写入日志出错 " + ee.Message + " 工作流代码[" + WORKFLOWID + "] 业务编号[" + BSNO + "] 步骤组代码[" + GROUPID + "] 步骤代码[" + stepno + "]"; break; } } if (result.Success == false) { return result; } else { result.Message = "全部成功"; result.islast = islast; return result; } //return islast; } //2 private static Resultmb DoInsertWorkFlowDo(string WORKFLOWID, string USERID, string BSNO, Boolean islast , List StepList, string BILLNO, string GID, string URL) { var result = new Resultmb(); var _count = 0; Database db = DatabaseFactory.CreateDatabase(); //using (var conn = db.CreateConnection()) //{ //conn.Open(); //var tran = conn.BeginTransaction(); for (int i = 0; i < StepList.Count; i++) { var stepno = StepList[i].STEPNO; var GROUPID = StepList[i].GROUPID; var strSql = new StringBuilder(); strSql.Append(" declare @WorkFlowID varchar(50) "); strSql.Append(" set @WorkFlowID='" + WORKFLOWID + "' "); strSql.Append(" insert into workflow_do (GID,workflowid,stepid,billno,auditor,audittime,stepno,isallfinish,GROUPID "); strSql.Append(" ,isfinish,BSNO,feeid,feestatus,DOQUERYSQL,isdelete,deletestep,deleteoperator,deletestepno,operator,applicant) ");//// strSql.Append(" select newid(),workflowid,gid,'" + BSNO + "',auditor,getdate(),stepno,islast,GROUPID "); strSql.Append(" ,0,'','','','','0','','','','',''");//// strSql.Append(" from workflow_step where workflowid=@WorkFlowID "); strSql.Append(" and auditor='" + USERID + "' and stepno ='" + stepno + "' and groupid='" + GROUPID + "' "); result = PushUsing(WORKFLOWID, BSNO, USERID, stepno, GROUPID, islast, BILLNO, GID, URL); if (result.Success != true) {//推进workflow_using的状态 result.Message = result.Message + (" 工作流代码[" + WORKFLOWID + "] 业务编号[" + BSNO + "] 步骤组代码[" + GROUPID + "] 步骤代码[" + stepno + "]"); break; } try {//向workflow_do写入操作日志 _count = _count + db.ExecuteNonQuery(CommandType.Text, strSql.ToString()); //db.ExecuteNonQuery(cmdupdate, tran); } catch (Exception ee) { result.Success = false; result.Message = "写入日志出错 " + ee.Message + " 工作流代码[" + WORKFLOWID + "] 业务编号[" + BSNO + "] 步骤组代码[" + GROUPID + "] 步骤代码[" + stepno + "]"; break; } } if (result.Success == false) { //tran.Rollback(); return result; } else { //tran.Commit(); result.Message = "全部成功"; result.islast = islast; return result; } //} //return islast; } //3 含事务 private static Resultmb DoInsertWorkFlowDo(string WORKFLOWID, string USERID, string BSNO, Boolean islast , List StepList, DbTransaction tran,string BILLNO) { var result = new Resultmb(); var _count = 0; for (int i = 0; i < StepList.Count; i++) { var stepno = StepList[i].STEPNO; var GROUPID = StepList[i].GROUPID; Database db = DatabaseFactory.CreateDatabase(); var strSql = new StringBuilder(); strSql.Append(" declare @WorkFlowID varchar(50) "); strSql.Append(" set @WorkFlowID='" + WORKFLOWID + "' "); strSql.Append(" insert into workflow_do (GID,workflowid,stepid,billno,auditor,audittime,stepno,isallfinish,GROUPID "); strSql.Append(" ,isfinish,BSNO,feeid,feestatus,DOQUERYSQL,isdelete,deletestep,deleteoperator,deletestepno,operator,applicant) ");//// strSql.Append(" select newid(),workflowid,gid,'" + BSNO + "',auditor,getdate(),stepno,islast,GROUPID "); strSql.Append(" ,0,'','','','','0','','','','',''");//// strSql.Append(" from workflow_step where workflowid=@WorkFlowID "); strSql.Append(" and auditor='" + USERID + "' and stepno ='" + stepno + "' and groupid='" + GROUPID + "' "); result = PushUsing(WORKFLOWID, BSNO, USERID, stepno, GROUPID, islast, tran,BILLNO); if (result.Success != true) {//推进workflow_using的状态 result.Message = result.Message + (" 工作流代码[" + WORKFLOWID + "] 业务编号[" + BSNO + "] 步骤组代码[" + GROUPID + "] 步骤代码[" + stepno + "]"); break; } try {//向workflow_do写入操作日志 _count = _count + db.ExecuteNonQuery(CommandType.Text, strSql.ToString()); } catch (Exception ee) { result.Success = false; result.Message = "写入日志出错 " + ee.Message + " 工作流代码[" + WORKFLOWID + "] 业务编号[" + BSNO + "] 步骤组代码[" + GROUPID + "] 步骤代码[" + stepno + "]"; break; } } if (result.Success == false) { return result; } else { result.Message = "全部成功"; result.islast = islast; return result; } //return islast; } private static Resultmb DoInsertWorkFlowDo(string WORKFLOWID, string USERID, string BSNO, Boolean islast , List StepList, DbTransaction tran, string BILLNO, string GID, string URL) { var result = new Resultmb(); var _count = 0; for (int i = 0; i < StepList.Count; i++) { var stepno = StepList[i].STEPNO; var GROUPID = StepList[i].GROUPID; Database db = DatabaseFactory.CreateDatabase(); var strSql = new StringBuilder(); strSql.Append(" declare @WorkFlowID varchar(50) "); strSql.Append(" set @WorkFlowID='" + WORKFLOWID + "' "); strSql.Append(" insert into workflow_do (GID,workflowid,stepid,billno,auditor,audittime,stepno,isallfinish,GROUPID "); strSql.Append(" ,isfinish,BSNO,feeid,feestatus,DOQUERYSQL,isdelete,deletestep,deleteoperator,deletestepno,operator,applicant) ");//// strSql.Append(" select newid(),workflowid,gid,'" + BSNO + "',auditor,getdate(),stepno,islast,GROUPID "); strSql.Append(" ,0,'','','','','0','','','','',''");//// strSql.Append(" from workflow_step where workflowid=@WorkFlowID "); strSql.Append(" and auditor='" + USERID + "' and stepno ='" + stepno + "' and groupid='" + GROUPID + "' "); result = PushUsing(WORKFLOWID, BSNO, USERID, stepno, GROUPID, islast, tran, BILLNO, GID, URL); if (result.Success != true) {//推进workflow_using的状态 result.Message = result.Message + (" 工作流代码[" + WORKFLOWID + "] 业务编号[" + BSNO + "] 步骤组代码[" + GROUPID + "] 步骤代码[" + stepno + "]"); break; } try {//向workflow_do写入操作日志 _count = _count + db.ExecuteNonQuery(CommandType.Text, strSql.ToString()); } catch (Exception ee) { result.Success = false; result.Message = "写入日志出错 " + ee.Message + " 工作流代码[" + WORKFLOWID + "] 业务编号[" + BSNO + "] 步骤组代码[" + GROUPID + "] 步骤代码[" + stepno + "]"; break; } } if (result.Success == false) { return result; } else { result.Message = "全部成功"; result.islast = islast; return result; } //return islast; } static private Resultmb PushUsing(string WORKFLOWID, string BSNO, string USERID, string STEPNO, string GROUPID, Boolean islast,string BILLNO) {//将操作记入WorkFlow_Using 如果该groupid的步骤都执行完毕，推进至下一阶段 var _result = new Resultmb(); var stepno = 0; var strSql_0 = new StringBuilder();//如果using的stepno集合中包含stepno 则将其去除 var strSql = new StringBuilder(); var strSql_2 = new StringBuilder(); strSql_0.Append(" select (select stepno from workflow_using "); strSql_0.Append(" where WORKFLOWID='" + WORKFLOWID + "' and bsno='" + BSNO + "') & power(2," + STEPNO + ") stepno "); Database db = DatabaseFactory.CreateDatabase(); using (IDataReader reader = db.ExecuteReader(CommandType.Text, strSql_0.ToString())) { while (reader.Read()) { stepno = Convert.ToInt32(reader["stepno"]); } reader.Close(); } if (stepno > 0) { //strSql.Append(" begin "); strSql.Append(" update workflow_using set "); strSql.Append(" stepno=stepno-power(2," + STEPNO + "),currentid=" + GROUPID + " "); strSql.Append(" where WORKFLOWID='" + WORKFLOWID + "' and bsno='" + BSNO + "' "); //strSql.Append(" end "); using (SqlTransaction sqlTran = SqlHelper.BeginTransaction(SqlHelper.ConnectionStringLocalTransaction)) { //Database db = DatabaseFactory.CreateDatabase(); var _count = SqlHelper.ExecuteNonQuery(sqlTran, CommandType.Text, strSql.ToString(), null); if (_count <= 0) { _result.Success = false; _result.Message = "推进工作流出错 "; sqlTran.Rollback(); return _result; } else { sqlTran.Commit(); } } } Database db3 = DatabaseFactory.CreateDatabase(); strSql_2.Append(" select stepno from workflow_using "); strSql_2.Append(" where WORKFLOWID='" + WORKFLOWID + "' and bsno='" + BSNO + "' "); using (IDataReader reader = db3.ExecuteReader(CommandType.Text, strSql_2.ToString())) { while (reader.Read()) { stepno = Convert.ToInt32(reader["stepno"]); } reader.Close(); } using (SqlTransaction sqlTran = SqlHelper.BeginTransaction(SqlHelper.ConnectionStringLocalTransaction)) { if (_result.Success == true && stepno == 0) {//如果本步骤全都执行完了 var nextGROUPID = GetNextGROUP(WORKFLOWID, STEPNO, GROUPID, USERID); strSql = new StringBuilder(); strSql.Append(" update workflow_using set stepno=dbo.getnextstep('" + WORKFLOWID + "','" + BSNO + "'," + nextGROUPID + "),"); strSql.Append(" currentid=" + nextGROUPID); if (islast) { strSql.Append(" ,finished=1 "); } else { strSql.Append(" ,finished=0 "); } strSql.Append(" where WORKFLOWID='" + WORKFLOWID + "'"); strSql.Append(" and bsno='" + BSNO + "' "); //Database db = DatabaseFactory.CreateDatabase(); try { var _count = SqlHelper.ExecuteNonQuery(sqlTran, CommandType.Text, strSql.ToString()); //db.ExecuteNonQuery(CommandType.Text, strSql.ToString());//CommandType.Text, , tran sqlTran.Commit(); } catch (Exception ee) { _result.Success = false; _result.Message = "推进步骤组出错 " + ee.Message; sqlTran.Rollback(); } //var message=new SYSMessagemb(); //message.NAME=WORKFLOWID; PushMessage(WORKFLOWID, BSNO, nextGROUPID.ToString(),BILLNO); } else { PassMessage(WORKFLOWID, BSNO, GROUPID, USERID); } } return _result; } static private Resultmb PushUsing(string WORKFLOWID, string BSNO, string USERID, string STEPNO, string GROUPID, Boolean islast, string BILLNO, string GID, string URL) {//将操作记入WorkFlow_Using 如果该groupid的步骤都执行完毕，推进至下一阶段 var _result = new Resultmb(); var stepno = 0; var strSql_0 = new StringBuilder();//如果using的stepno集合中包含stepno 则将其去除 var strSql = new StringBuilder(); var strSql_2 = new StringBuilder(); strSql_0.Append(" select (select stepno from workflow_using "); strSql_0.Append(" where WORKFLOWID='" + WORKFLOWID + "' and bsno='" + BSNO + "') & power(2," + STEPNO + ") stepno "); Database db = DatabaseFactory.CreateDatabase(); using (IDataReader reader = db.ExecuteReader(CommandType.Text, strSql_0.ToString())) { while (reader.Read()) { stepno = Convert.ToInt32(reader["stepno"]); } reader.Close(); } if (stepno > 0) { //strSql.Append(" begin "); strSql.Append(" update workflow_using set "); strSql.Append(" stepno=stepno-power(2," + STEPNO + "),currentid=" + GROUPID + " "); strSql.Append(" where WORKFLOWID='" + WORKFLOWID + "' and bsno='" + BSNO + "' "); //strSql.Append(" end "); using (SqlTransaction sqlTran = SqlHelper.BeginTransaction(SqlHelper.ConnectionStringLocalTransaction)) { //Database db = DatabaseFactory.CreateDatabase(); var _count = SqlHelper.ExecuteNonQuery(sqlTran, CommandType.Text, strSql.ToString(), null); if (_count <= 0) { _result.Success = false; _result.Message = "推进工作流出错 "; sqlTran.Rollback(); return _result; } else { sqlTran.Commit(); } } } Database db3 = DatabaseFactory.CreateDatabase(); strSql_2.Append(" select stepno from workflow_using "); strSql_2.Append(" where WORKFLOWID='" + WORKFLOWID + "' and bsno='" + BSNO + "' "); using (IDataReader reader = db3.ExecuteReader(CommandType.Text, strSql_2.ToString())) { while (reader.Read()) { stepno = Convert.ToInt32(reader["stepno"]); } reader.Close(); } using (SqlTransaction sqlTran = SqlHelper.BeginTransaction(SqlHelper.ConnectionStringLocalTransaction)) { if (_result.Success == true && stepno == 0) {//如果本步骤全都执行完了 var nextGROUPID = GetNextGROUP(WORKFLOWID, STEPNO, GROUPID, USERID); strSql = new StringBuilder(); strSql.Append(" update workflow_using set stepno=dbo.getnextstep('" + WORKFLOWID + "','" + BSNO + "'," + nextGROUPID + "),"); strSql.Append(" currentid=" + nextGROUPID); if (islast) { strSql.Append(" ,finished=1 "); } else { strSql.Append(" ,finished=0 "); } strSql.Append(" where WORKFLOWID='" + WORKFLOWID + "'"); strSql.Append(" and bsno='" + BSNO + "' "); //Database db = DatabaseFactory.CreateDatabase(); try { var _count = SqlHelper.ExecuteNonQuery(sqlTran, CommandType.Text, strSql.ToString()); //db.ExecuteNonQuery(CommandType.Text, strSql.ToString());//CommandType.Text, , tran sqlTran.Commit(); } catch (Exception ee) { _result.Success = false; _result.Message = "推进步骤组出错 " + ee.Message; sqlTran.Rollback(); } if (_result.Success == true) { if (islast) { RepeatMessage(WORKFLOWID, BSNO, nextGROUPID.ToString(), USERID, BILLNO, GID, URL); } else { PushMessage(WORKFLOWID, BSNO, nextGROUPID.ToString(), BILLNO, GID, URL); } } } else { PassMessage(WORKFLOWID, BSNO, GROUPID, USERID, BILLNO, GID, URL); } } return _result; } static private Resultmb PushUsing(string WORKFLOWID, string BSNO, string USERID, string STEPNO, string GROUPID , Boolean islast, DbTransaction tran,string BILLNO) {//将操作记入WorkFlow_Using 如果该groupid的步骤都执行完毕，推进至下一阶段 var _result = new Resultmb(); var stepno = 0; var strSql_0 = new StringBuilder();//如果using的stepno集合中包含stepno 则将其去除 var strSql = new StringBuilder(); var strSql_2 = new StringBuilder(); strSql_0.Append(" select (select stepno from workflow_using "); strSql_0.Append(" where WORKFLOWID='" + WORKFLOWID + "' and bsno='" + BSNO + "') & power(2," + STEPNO + ") stepno "); Database db = DatabaseFactory.CreateDatabase(); using (IDataReader reader = db.ExecuteReader(tran, CommandType.Text, strSql_0.ToString())) { while (reader.Read()) { stepno = Convert.ToInt32(reader["stepno"]); } reader.Close(); } if (stepno > 0) { //strSql.Append(" begin "); strSql.Append(" update workflow_using set "); strSql.Append(" stepno=stepno-power(2," + STEPNO + "),currentid=" + GROUPID + " "); strSql.Append(" where WORKFLOWID='" + WORKFLOWID + "' and bsno='" + BSNO + "' "); //strSql.Append(" end "); //using (SqlTransaction sqlTran = SqlHelper.BeginTransaction(SqlHelper.ConnectionStringLocalTransaction)) //{ Database db2 = DatabaseFactory.CreateDatabase(); //db.ExecuteNonQuery(cmdupdate, tran) var _count = db2.ExecuteNonQuery(tran, CommandType.Text, strSql.ToString()); //SqlHelper.ExecuteNonQuery(tran, CommandType.Text, strSql.ToString(), null); if (_count <= 0) { _result.Success = false; _result.Message = "推进工作流出错 "; //sqlTran.Rollback(); return _result; } else { //sqlTran.Commit(); } //} } Database db3 = DatabaseFactory.CreateDatabase(); strSql_2.Append(" select stepno from workflow_using "); strSql_2.Append(" where WORKFLOWID='" + WORKFLOWID + "' and bsno='" + BSNO + "' "); using (IDataReader reader = db3.ExecuteReader(tran, CommandType.Text, strSql_2.ToString())) { while (reader.Read()) { stepno = Convert.ToInt32(reader["stepno"]); } reader.Close(); } //using (SqlTransaction sqlTran = SqlHelper.BeginTransaction(SqlHelper.ConnectionStringLocalTransaction)) { if (_result.Success == true && stepno == 0) {//如果本步骤全都执行完了 var nextGROUPID = GetNextGROUP(WORKFLOWID, STEPNO, GROUPID, USERID); strSql = new StringBuilder(); strSql.Append(" update workflow_using set stepno=dbo.getnextstep('" + WORKFLOWID + "','" + BSNO + "'," + nextGROUPID + "),"); strSql.Append(" currentid=" + nextGROUPID); if (islast) { strSql.Append(" ,finished=1 "); } else { strSql.Append(" ,finished=0 "); } strSql.Append(" where WORKFLOWID='" + WORKFLOWID + "'"); strSql.Append(" and bsno='" + BSNO + "' "); //Database db = DatabaseFactory.CreateDatabase(); try { Database db4 = DatabaseFactory.CreateDatabase(); var _count = db4.ExecuteNonQuery(tran, CommandType.Text, strSql.ToString()); //SqlHelper.ExecuteNonQuery(sqlTran, CommandType.Text, strSql.ToString()); //db.ExecuteNonQuery(CommandType.Text, strSql.ToString());//CommandType.Text, , tran //sqlTran.Commit(); } catch (Exception ee) { _result.Success = false; _result.Message = "推进步骤组出错 " + ee.Message; //sqlTran.Rollback(); } //var message=new SYSMessagemb(); //message.NAME=WORKFLOWID; PushMessage(WORKFLOWID, BSNO, nextGROUPID.ToString(),BILLNO); } else { PassMessage(WORKFLOWID, BSNO, GROUPID, USERID); } } return _result; } static private Resultmb PushUsing(string WORKFLOWID, string BSNO, string USERID, string STEPNO, string GROUPID , Boolean islast, DbTransaction tran, string BILLNO, string GID, string URL) {//将操作记入WorkFlow_Using 如果该groupid的步骤都执行完毕，推进至下一阶段 var _result = new Resultmb(); var stepno = 0; var strSql_0 = new StringBuilder();//如果using的stepno集合中包含stepno 则将其去除 var strSql = new StringBuilder(); var strSql_2 = new StringBuilder(); strSql_0.Append(" select (select stepno from workflow_using "); strSql_0.Append(" where WORKFLOWID='" + WORKFLOWID + "' and bsno='" + BSNO + "') & power(2," + STEPNO + ") stepno "); Database db = DatabaseFactory.CreateDatabase(); using (IDataReader reader = db.ExecuteReader(tran, CommandType.Text, strSql_0.ToString())) { while (reader.Read()) { stepno = Convert.ToInt32(reader["stepno"]); } reader.Close(); } if (stepno > 0) { //strSql.Append(" begin "); strSql.Append(" update workflow_using set "); strSql.Append(" stepno=stepno-power(2," + STEPNO + "),currentid=" + GROUPID + " "); strSql.Append(" where WORKFLOWID='" + WORKFLOWID + "' and bsno='" + BSNO + "' "); //strSql.Append(" end "); //using (SqlTransaction sqlTran = SqlHelper.BeginTransaction(SqlHelper.ConnectionStringLocalTransaction)) //{ Database db2 = DatabaseFactory.CreateDatabase(); //db.ExecuteNonQuery(cmdupdate, tran) var _count = db2.ExecuteNonQuery(tran, CommandType.Text, strSql.ToString()); //SqlHelper.ExecuteNonQuery(tran, CommandType.Text, strSql.ToString(), null); if (_count <= 0) { _result.Success = false; _result.Message = "推进工作流出错 "; //sqlTran.Rollback(); return _result; } else { //sqlTran.Commit(); } //} } Database db3 = DatabaseFactory.CreateDatabase(); strSql_2.Append(" select stepno from workflow_using "); strSql_2.Append(" where WORKFLOWID='" + WORKFLOWID + "' and bsno='" + BSNO + "' "); using (IDataReader reader = db3.ExecuteReader(tran, CommandType.Text, strSql_2.ToString())) { while (reader.Read()) { stepno = Convert.ToInt32(reader["stepno"]); } reader.Close(); } //using (SqlTransaction sqlTran = SqlHelper.BeginTransaction(SqlHelper.ConnectionStringLocalTransaction)) { if (_result.Success == true && stepno == 0) {//如果本步骤全都执行完了 var nextGROUPID = GetNextGROUP(WORKFLOWID, STEPNO, GROUPID, USERID, tran); strSql = new StringBuilder(); strSql.Append(" update workflow_using set stepno=dbo.getnextstep('" + WORKFLOWID + "','" + BSNO + "'," + nextGROUPID + "),"); strSql.Append(" currentid=" + nextGROUPID); if (islast) { strSql.Append(" ,finished=1 "); } else { strSql.Append(" ,finished=0 "); } strSql.Append(" where WORKFLOWID='" + WORKFLOWID + "'"); strSql.Append(" and bsno='" + BSNO + "' "); //Database db = DatabaseFactory.CreateDatabase(); try { Database db4 = DatabaseFactory.CreateDatabase(); var _count = db4.ExecuteNonQuery(tran, CommandType.Text, strSql.ToString()); //SqlHelper.ExecuteNonQuery(sqlTran, CommandType.Text, strSql.ToString()); //db.ExecuteNonQuery(CommandType.Text, strSql.ToString());//CommandType.Text, , tran //sqlTran.Commit(); } catch (Exception ee) { _result.Success = false; _result.Message = "推进步骤组出错 " + ee.Message; //sqlTran.Rollback(); } //var message=new SYSMessagemb(); //message.NAME=WORKFLOWID; PushMessage(WORKFLOWID, BSNO, nextGROUPID.ToString(), BILLNO, GID, URL, tran); } else { PassMessage(WORKFLOWID, BSNO, GROUPID, USERID, BILLNO, GID, URL); } } return _result; } static private int GetNextGROUP(string WORKFLOWID, string STEPNO, string GROUPID, string USERID) { var strSql = new StringBuilder(); var Ns = 0; strSql.Append(" select isnull((case nextgroup when '' then 0 else nextgroup end),0) as nextgroup from workflow_step "); strSql.Append(" where WORKFLOWID='" + WORKFLOWID + "'"); strSql.Append(" and groupid=" + GROUPID + " and stepno=" + STEPNO + " and auditor='" + USERID + "' "); Database db = DatabaseFactory.CreateDatabase(); using (IDataReader reader = db.ExecuteReader(CommandType.Text, strSql.ToString())) { while (reader.Read()) { Ns = Convert.ToInt32(reader["nextgroup"]); } reader.Close(); } return Ns; } static private int GetNextGROUP(string WORKFLOWID, string STEPNO, string GROUPID, string USERID, DbTransaction tran) { var strSql = new StringBuilder(); var Ns = 0; strSql.Append(" select isnull((case nextgroup when '' then 0 else nextgroup end),0) as nextgroup from workflow_step "); strSql.Append(" where WORKFLOWID='" + WORKFLOWID + "'"); strSql.Append(" and groupid=" + GROUPID + " and stepno=" + STEPNO + " and auditor='" + USERID + "' "); Database db = DatabaseFactory.CreateDatabase(); using (IDataReader reader = db.ExecuteReader(tran, CommandType.Text, strSql.ToString())) { while (reader.Read()) { Ns = Convert.ToInt32(reader["nextgroup"]); } reader.Close(); } return Ns; } #endregion #region [更改工作流]添加、修改和删除workflow_step时，对现有workflow_using做相应操作 #region 查询是否能够修改using和是否能够修改step static public CanChangemb GetCanChange(string GID)//参数为workflow_step的GID { var strSql = new StringBuilder(); strSql.Append(" declare @STEPNO int "); strSql.Append(" declare @WORKFLOWID varchar(50) "); strSql.Append(" declare @USERID varchar(50) declare @UsingCount int declare @StepCount int"); strSql.Append(" declare @GROUPID varchar(50) declare @changeusing bit declare @changeStep bit "); strSql.Append(" set @STEPNO=(select STEPNO from workflow_step where gid='" + GID + "') "); strSql.Append(" set @WORKFLOWID=(select WORKFLOWID from workflow_step where gid='" + GID + "') "); strSql.Append(" set @USERID=(select auditor from workflow_step where gid='" + GID + "') "); strSql.Append(" set @GROUPID=(select GROUPID from workflow_step where gid='" + GID + "') "); strSql.Append(" set @USingCount=(select count(*) [count] from workflow_using "); strSql.Append(" where workflowid=@WORKFLOWID and STEPNO=power(2,@STEPNO) ) "); strSql.Append(" set @StepCount=(select count(*) [count] from workflow_step "); strSql.Append(" where workflowid=@WORKFLOWID and STEPNO=power(2,@STEPNO) and auditor<>@USERID )"); strSql.Append(" if @USingCount>0 begin "); strSql.Append(" set @changeusing=0 "); strSql.Append(" set @changeStep=0 "); strSql.Append(" end else if @StepCount>0 "); strSql.Append(" begin "); strSql.Append(" set @changeusing=0 "); strSql.Append(" set @changeStep=1 "); strSql.Append(" END else "); strSql.Append(" begin "); strSql.Append(" set @changeusing=1 "); strSql.Append(" set @changeStep=1"); strSql.Append(" end "); strSql.Append(" select @changeusing changeusing,@changeStep changeStep "); return SetCanChange(strSql.ToString()); } static private CanChangemb SetCanChange(string strSql)//参数为workflow_step的GID { Database db = DatabaseFactory.CreateDatabase(); var bodyList = new List(); using (IDataReader reader = db.ExecuteReader(CommandType.Text, strSql.ToString())) { while (reader.Read()) { CanChangemb data = new CanChangemb(); #region Set DB data to Object var ChangeStep = Convert.ToString(reader["ChangeStep"]); var ChangeUsing = Convert.ToString(reader["ChangeUsing"]); if (ChangeStep == "True") { data.ChangeStep = true; } else data.ChangeStep = false; if (ChangeUsing == "True") { data.ChangeUsing = true; } else data.ChangeUsing = false; //data.ChangeStep = Convert.ToBoolean(reader["ChangeStep"]); //data.ChangeUsing = Convert.ToBoolean(reader["ChangeUsing"]); #endregion bodyList.Add(data); } reader.Close(); } return bodyList[0]; } #endregion #region 增加workflow_step static public Resultmb InsertStep(string WORKFLOWID, string USERID, string STEPNO, string GROUPID) { //workflowid,groupid相同的workflow_using数据列，合并新的stepno进入workflow_using.stepno //类似驳回操作 var _result = new Resultmb(); var strSql = new StringBuilder();//如果using的stepno集合中包含stepno 则将其去除 strSql.Append(" if ((select count(*) from workflow_step ");//但如果有同步骤号的其他权限，则不改变当前状态 strSql.Append(" where WORKFLOWID='" + WORKFLOWID + "' and STEPNO ='" + STEPNO + "' and auditor<>'" + USERID + "' )=0) begin "); strSql.Append(" update workflow_using set "); strSql.Append(" stepno=stepno|power(2," + STEPNO + "),currentid='" + GROUPID + "' "); strSql.Append(" where bsno in (select bsno from workflow_using where workflowid='" + WORKFLOWID + "' and currentid='" + GROUPID + "') and (stepno & power(2," + STEPNO + ")=0) "); strSql.Append(" end "); Database db = DatabaseFactory.CreateDatabase(); try { var _count = db.ExecuteNonQuery(CommandType.Text, strSql.ToString()); } catch (Exception ee) { _result.Success = false; _result.Message = "插入新步骤出错 " + ee.Message; } return _result; } #endregion #region 删除workflow_step static public Resultmb DelStep(string GID)//(string WORKFLOWID, string USERID, string STEPNO, string GROUPID) {//删除工作步骤 类似推进工作流 var result = new Resultmb(); var _CanChange = GetCanChange(GID); var strSql = new StringBuilder(); if (_CanChange.ChangeStep == false) { result.Success = false; result.Message = "不能修改，还有业务等待此步骤审核，请将这些业务审核通过或完全撤回后再修改"; } else { //首先删除workflow_step 用此结果设定返回值 strSql.Append(" delete from workflow_step where gid='" + GID + "' "); //根据情况判断是否修改using表 if (_CanChange.ChangeUsing == true) { strSql.Append(" declare @STEPNO varchar "); strSql.Append(" declare @WORKFLOWID varchar "); strSql.Append(" declare @USERID varchar "); strSql.Append(" declare @GROUPID varchar "); strSql.Append(" set @STEPNO=select STEPNO from workflow_step where gid='" + GID + "' "); strSql.Append(" set @WORKFLOWID=select WORKFLOWID from workflow_step where gid='" + GID + "' "); strSql.Append(" set @USERID=select auditor from workflow_step where gid='" + GID + "' "); strSql.Append(" set @GROUPID=select GROUPID from workflow_step where gid='" + GID + "' "); strSql.Append(" update workflow_using set "); strSql.Append(" stepno=stepno-power(2,@STEPNO),currentid=@GROUPID "); strSql.Append(" where workflowid=@WORKFLOWID "); strSql.Append(" and currentid=@GROUPID "); } } Database db = DatabaseFactory.CreateDatabase(); try { var _count = db.ExecuteNonQuery(CommandType.Text, strSql.ToString()); result.Success = true; result.totalCount = _count; result.Message = ""; } catch (Exception ee) { result.Success = false; result.Message = "插入新步骤出错 " + ee.Message; } return result; } #endregion #region 查询是否能够修改workflow_userPath static public Boolean GetCanChange_UserPath(string USERID, string TYPENO, string NewWorkFlowID)//参数为workflow_step的GID { var strSql = new StringBuilder(); strSql.Append(" declare @USERID varchar(50) "); strSql.Append(" declare @TYPE int "); strSql.Append(" ,@NewWorkFlowID varchar(50) "); strSql.Append(" set @USERID='" + USERID + "' "); strSql.Append(" if (select count(*) from workflow_userpath where USERID=@USERID and WORKFLOWTYPENO='" + TYPENO + "')=0 "); strSql.Append(" BEGIN "); strSql.Append(" if (select count(*) from workflow where type='" + TYPENO + "' and ISdefault=1)=0 begin select 1 CanEdit "); strSql.Append(" end else if (select count(*) from workflow_using where OP='" + USERID + "' "); strSql.Append(" and workflowid in(select WorkflowID from workflow_userPath where USERID=@USERID and WORKFLOWTYPENO='" + TYPENO + "') and finished=0)>0 "); strSql.Append(" begin select 0 CanEdit end else begin select 1 CanEdit end "); strSql.Append(" END else BEGIN "); strSql.Append(" if (select count(*) from workflow_using where OP='" + USERID + "' "); strSql.Append(" and workflowid in(select WorkflowID from workflow_userPath where USERID=@USERID and WORKFLOWTYPENO='" + TYPENO + "') and finished=0)>0 "); strSql.Append(" begin select 0 CanEdit end else begin select 1 CanEdit end END "); return SetCanChange_UserPath(strSql.ToString()); } static private Boolean SetCanChange_UserPath(string strSql)//参数为workflow_step的GID { Database db = DatabaseFactory.CreateDatabase(); var bodyList = new List(); using (IDataReader reader = db.ExecuteReader(CommandType.Text, strSql.ToString())) { while (reader.Read()) { CanChangemb data = new CanChangemb(); #region Set DB data to Object //var ChangeStep = Convert.ToString(reader["ChangeStep"]); var ChangeUsing = Convert.ToString(reader["CanEdit"]); /*if (ChangeStep == "True") { data.ChangeStep = true; } else data.ChangeStep = false;*/ if (ChangeUsing == "1") { data.ChangeUsing = true; } else data.ChangeUsing = false; //data.ChangeStep = Convert.ToBoolean(reader["ChangeStep"]); //data.ChangeUsing = Convert.ToBoolean(reader["ChangeUsing"]); #endregion bodyList.Add(data); } reader.Close(); } return bodyList[0].ChangeUsing; } #endregion #endregion #region [操作工作流]工作流驳回 如果驳回后回到最初状态，则清空这个BSNO的workflow_using数据 static public Resultmb DeleteWorkFlowDo(string WORKFLOWNAME, string BSNO, string USERID, string Reason) { //20150304 首先判断是否有权限进行驳回 //判断依据为workflow_do里面存在未删除的记录 其 workflowid billno(bsno)与当前值相同 ,stepno 和groupid与该用户有交集 //或此userid对此workflowid有允许自动通过的权限 Database db = DatabaseFactory.CreateDatabase(); using (DbConnection connection = db.CreateConnection()) { connection.Open(); try { var _sql = " select * from workflow_do where (ISDELETE IS NULL OR ISDELETE=0) and "; _sql = _sql + " Billno='" + BSNO + "' and workflowid=[dbo].[GetWorkFlowID]('" + WORKFLOWNAME + "','" + USERID + "') and "; _sql = _sql + " Auditor='" + USERID + "' "; _sql = _sql + " union all select gid,'','','','','','','','','','','','','','','','','','','' "; _sql = _sql + " from workflow_step where WORKFLOWID=[dbo].[GetWorkFlowID]('" + WORKFLOWNAME + "','" + USERID + "') "; _sql = _sql + " and auditor='" + USERID + "' and GROUPID='0' "; //20150319 增加逻辑 //曾经自动审核通过的业务，在自动审核完成后业务流程发生了改变，改为人工审核。 //这时不再有“具有自动审核权限”的人，同时由于自动通过，也没有审核记录，因此按原逻辑是无法驳回的 //增加逻辑是：此业务已完结，而且此人在此工作流中具有审核权限，则有查询结果，即允许驳回。 _sql = _sql + " union all select s.gid,'','','','','','','','','','','','','','','','','','','' "; _sql = _sql + " from workflow_step S left join workflow_using U on s.WORKFLOWID=u.WORKFLOWID and u.bsno='" + BSNO + "' and U.finished=1"; _sql = _sql + " where s.WORKFLOWID=[dbo].[GetWorkFlowID]('" + WORKFLOWNAME + "','" + USERID + "') "; _sql = _sql + " and auditor='" + USERID + "' "; var objcount = db.ExecuteScalar(CommandType.Text, _sql); var _count = Convert.ToString(objcount); if (string.IsNullOrEmpty(_count)) { var _Result = new Resultmb(); _Result.Success = false; _Result.Message = "该用户没有权限驳回此业务"; return _Result; } } catch (Exception exception) { var _Result = new Resultmb(); _Result.Success = false; _Result.Message = "查询workflow_do出错:" + exception.Message; return _Result; } } var strSql = new StringBuilder(); var workflowID = GetBSNOWorkFlowID(WORKFLOWNAME, BSNO)[0].GID; strSql.Append(" declare @WorkFlowID varchar(50),@GROUPID varchar(50) "); strSql.Append(" set @WorkFlowID='" + workflowID + "' "); //strSql.Append(" delete from workflow_do where workflowid=@WorkFlowID and auditor='" + USERID + "' and billno='" + BSNO + "'"); strSql.Append(" update workflow_do set isdelete=1, deletestep=stepno, audittime=dbo.trimtime(getdate()),auditor='" + USERID + "'"); strSql.Append(" where workflowid=@WorkFlowID and billno='" + BSNO + "' and isdelete is null"); strSql.Append(" insert into workflow_do (GID,workflowid,stepid,billno,auditor,audittime,isdelete,deletestep,BSNO,FEEID,FEESTATUS,DOQUERYSQL,STEPNO,ISFINISH,DELETEOPERATOR,DELETESTEPNO,OPERATOR,ISALLFINISH,APPLICANT,GROUPID) "); strSql.Append(" select newid(),workflowid,gid,'" + BSNO + "',auditor,getdate(),1,stepno,'','','','','',0,'','','',0,'','' "); strSql.Append(" from workflow_step where workflowid=@WorkFlowID and groupid=dbo.getmingroupid_2('" + workflowID + "','" + USERID + "') "); strSql.Append(" and auditor='" + USERID + "'"); strSql.Append(" delete from workflow_using where workflowid='" + workflowID + "' and bsno='" + BSNO + "' "); //strSql.Append(" set @GROUPID=dbo.GetMinGroupID_2('" + workflowID + "','" + USERID + "') "); //strSql.Append(" update workflow_using set stepno=dbo.GetNextStep('" + workflowID + "','"+BSNO +"',@GROUPID),currentid=0, "); //strSql.Append(" reject_time=getdate(),reason=isnull(reason,'')+'" + Reason + "'+';',finished=0 "); //strSql.Append(" where workflowid=@WorkFlowID and bsno='" + BSNO + "' "); //RefuseMessage(workflowID, BSNO, USERID, Reason); //return DoDeleteWorkFlowDo(strSql.ToString()); var _r = DoDeleteWorkFlowDo(strSql.ToString()); if (_r.Success == true) { RefuseMessage(workflowID, BSNO, USERID, Reason); } return _r; } static public Resultmb DeleteWorkFlowDo(string WORKFLOWNAME, string BSNO, string USERID, string Reason, string BILLNO, string GID, string URL, string WORKFLOWID = "") { //20150304 首先判断是否有权限进行驳回 //判断依据为workflow_do里面存在未删除的记录 其 workflowid billno(bsno)与当前值相同 ,stepno 和groupid与该用户有交集 //或此userid对此workflowid有允许自动通过的权限 if (WORKFLOWID == "" || WORKFLOWID == "no") WORKFLOWID = GetBSNOWorkFlowID(WORKFLOWNAME, BSNO)[0].GID; if (WORKFLOWID == "") { var _Result = new Resultmb(); _Result.Success = false; _Result.Message = ""; return _Result; } Database db = DatabaseFactory.CreateDatabase(); using (DbConnection connection = db.CreateConnection()) { connection.Open(); try { if (WORKFLOWID != "no" && WORKFLOWID != "") { var _sql = " select * from workflow_do where (ISDELETE IS NULL OR ISDELETE=0) and "; _sql = _sql + " Billno='" + BSNO + "' and workflowid='" + WORKFLOWID + "'and "; _sql = _sql + " Auditor='" + USERID + "' "; _sql = _sql + " union all select gid,'','','','','','','','','','','','','','','','','','','' "; _sql = _sql + " from workflow_step where WORKFLOWID='" + WORKFLOWID + "' "; _sql = _sql + " and auditor='" + USERID + "' and GROUPID='0' "; //20150319 增加逻辑 //曾经自动审核通过的业务，在自动审核完成后业务流程发生了改变，改为人工审核。 //这时不再有“具有自动审核权限”的人，同时由于自动通过，也没有审核记录，因此按原逻辑是无法驳回的 //增加逻辑是：此业务已完结，而且此人在此工作流中具有审核权限，则有查询结果，即允许驳回。 _sql = _sql + " union all select s.gid,'','','','','','','','','','','','','','','','','','','' "; _sql = _sql + " from workflow_step S left join workflow_using U on s.WORKFLOWID=u.WORKFLOWID and u.bsno='" + BSNO + "' and U.finished=1"; _sql = _sql + " where s.WORKFLOWID='" + WORKFLOWID + "' "; _sql = _sql + " and auditor='" + USERID + "' "; var objcount = db.ExecuteScalar(CommandType.Text, _sql); var _count = Convert.ToString(objcount); if (string.IsNullOrEmpty(_count)) { var _Result = new Resultmb(); _Result.Success = false; _Result.Message = "该用户没有权限驳回此业务"; return _Result; } } else { var _sql = " select * from workflow_do where (ISDELETE IS NULL OR ISDELETE=0) and "; _sql = _sql + " Billno='" + BSNO + "' and workflowid=[dbo].[GetWorkFlowID]('" + WORKFLOWNAME + "','" + USERID + "') and "; _sql = _sql + " Auditor='" + USERID + "' "; _sql = _sql + " union all select gid,'','','','','','','','','','','','','','','','','','','' "; _sql = _sql + " from workflow_step where WORKFLOWID=[dbo].[GetWorkFlowID]('" + WORKFLOWNAME + "','" + USERID + "') "; _sql = _sql + " and auditor='" + USERID + "' and GROUPID='0' ";//20170802hxt 20200629dy //20150319 增加逻辑 //曾经自动审核通过的业务，在自动审核完成后业务流程发生了改变，改为人工审核。 //这时不再有“具有自动审核权限”的人，同时由于自动通过，也没有审核记录，因此按原逻辑是无法驳回的 //增加逻辑是：此业务已完结，而且此人在此工作流中具有审核权限，则有查询结果，即允许驳回。 _sql = _sql + " union all select s.gid,'','','','','','','','','','','','','','','','','','','' "; _sql = _sql + " from workflow_step S left join workflow_using U on s.WORKFLOWID=u.WORKFLOWID and u.bsno='" + BSNO + "' and U.finished=1"; _sql = _sql + " where s.WORKFLOWID=[dbo].[GetWorkFlowID]('" + WORKFLOWNAME + "','" + USERID + "') "; _sql = _sql + " and auditor='" + USERID + "' "; var objcount = db.ExecuteScalar(CommandType.Text, _sql); var _count = Convert.ToString(objcount); if (string.IsNullOrEmpty(_count)) { var _Result = new Resultmb(); _Result.Success = false; _Result.Message = "该用户没有权限驳回此业务"; return _Result; } } } catch (Exception exception) { var _Result = new Resultmb(); _Result.Success = false; _Result.Message = "查询workflow_do出错:" + exception.Message; return _Result; } } var strSql = new StringBuilder(); var workflowID = WORKFLOWID; if (workflowID == "no" || WORKFLOWID == "") workflowID = GetBSNOWorkFlowID(WORKFLOWNAME, BSNO)[0].GID; strSql.Append(" declare @WorkFlowID varchar(50),@GROUPID varchar(50) "); strSql.Append(" set @WorkFlowID='" + workflowID + "' "); //strSql.Append(" delete from workflow_do where workflowid=@WorkFlowID and auditor='" + USERID + "' and billno='" + BSNO + "'"); strSql.Append(" update workflow_do set isdelete=1, deletestep=stepno, audittime=dbo.trimtime(getdate()),auditor='" + USERID + "'"); strSql.Append(" where workflowid=@WorkFlowID and billno='" + BSNO + "' and isdelete is null"); strSql.Append(" insert into workflow_do (GID,workflowid,stepid,billno,auditor,audittime,isdelete,deletestep,BSNO,FEEID,FEESTATUS,DOQUERYSQL,STEPNO,ISFINISH,DELETEOPERATOR,DELETESTEPNO,OPERATOR,ISALLFINISH,APPLICANT,GROUPID) "); strSql.Append(" select newid(),workflowid,gid,'" + BSNO + "',auditor,getdate(),1,stepno,'','','','','',0,'','','',0,'','' "); strSql.Append(" from workflow_step where workflowid=@WorkFlowID and groupid=dbo.getmingroupid_2('" + workflowID + "','" + USERID + "') "); strSql.Append(" and auditor='" + USERID + "'"); strSql.Append(" delete from workflow_using where workflowid='" + workflowID + "' and bsno='" + BSNO + "' "); //strSql.Append(" set @GROUPID=dbo.GetMinGroupID_2('" + workflowID + "','" + USERID + "') "); //strSql.Append(" update workflow_using set stepno=dbo.GetNextStep('" + workflowID + "','" + BSNO + "',@GROUPID),currentid=0, "); //strSql.Append(" reject_time=getdate(),reason=isnull(reason,'')+'" + Reason + "'+';',finished=0 "); //strSql.Append(" where workflowid=@WorkFlowID and bsno='" + BSNO + "' "); var _r = DoDeleteWorkFlowDo(strSql.ToString()); if (_r.Success == true) { RefuseMessage(workflowID, BSNO, USERID, Reason, BILLNO, GID, URL); } return _r; } private static Resultmb DoDeleteWorkFlowDo(string strSql) { Database db = DatabaseFactory.CreateDatabase(); using (var conn = db.CreateConnection()) { conn.Open(); var tran = conn.BeginTransaction(); var result = new Resultmb(); try { db.ExecuteNonQuery(CommandType.Text, strSql); } catch (Exception ee) { result.Success = false; result.Message = "撤销workflow_do工作流日志 " + ee.Message; tran.Rollback(); } if (result.Success == true) { tran.Commit(); } return result; } } #endregion #region 判断工作流权限是否为最终 /* public static int GetWorkFlowFinal(string WorkFlowName, string DEPTGID, string USERID) {// var strSql = new StringBuilder(); strSql.Append(" select count(*) [Count] from workflow_step "); strSql.Append(" where workflowid=dbo.getworkflowid('" + WorkFlowName + "','" + DEPTGID + "') "); strSql.Append(" and auditor='" + USERID + "' and islast=1 "); return SetWorkFlowFinal(strSql); }*/ public static Boolean GetAutoFinish(string WORKFLOWID, string USERID) { var strSql = new StringBuilder(); strSql.Append(" select count(*) count from workflow_step where "); strSql.Append(" (workflowid='" + WORKFLOWID + "' and groupid=0) "); //有人在步骤组0有权驳回 存在步骤组0的人步骤，该工作流可视为提交即自动通过 //或者 ////自己有权在第一步审核通过 //strSql.Append(" or ( workflowid='" + WORKFLOWID + "' and groupid=1 and auditor='" + USERID + "' and islast=1)"); if (SetWorkFlowFinal(strSql) == 0) { return false; } else { return true; }//允许自动审核通过 } public static Boolean GetWorkFlowFinal_BSNO(string WORKFLOWID, string GROUPID, string BSNO, string USERID) { //20170117 改成在当前步骤组内该用户是否具备最终审核权限 //var WORKFLOWID = GetBSNOWorkFlowID(WorkFlowName, BSNO)[0].GID; //var GROUPIDList = GetBSNOGROUPID(WORKFLOWID, BSNO); //if (GROUPIDList.Count == 0) //{ // return false; //} //var GROUPID = GetBSNOGROUPID(WORKFLOWID, BSNO)[0].GROUPID; var strSql = new StringBuilder(); strSql.Append(" declare @LASTCOUNT int "); strSql.Append(" set @LASTCOUNT=( select count(*) [Count] from workflow_step "); strSql.Append(" where workflowid ='" + WORKFLOWID + "' "); strSql.Append(" and auditor='" + USERID + "' and groupid='" + GROUPID + "' and islast=1 )"); //strSql.Append(" if (@LASTCOUNT=0) begin"); //strSql.Append(" set @LASTCOUNT=( select count(*) [Count] from workflow_step "); //strSql.Append(" where workflowid =(select dbo.GetBSNOWorkflowid('" + WorkFlowName + "','" + BSNO + "'))) "); //strSql.Append(" if (@LASTCOUNT=0) begin select 1 [count] end else begin select 0 [count] end "); //strSql.Append(" end else begin select @LASTCOUNT [Count] end"); strSql.Append(" select @LASTCOUNT as Count "); //if (SetWorkFlowFinal(strSql) > 1) if (SetWorkFlowFinal(strSql) > 0) { return true; } else { return false; } } public static Boolean GetWorkFlowFinal_BSNO(string WORKFLOWID, string GROUPID, string BSNO, string USERID, DbTransaction tran) { //20170117 改成在当前步骤组内该用户是否具备最终审核权限 //var WORKFLOWID = GetBSNOWorkFlowID(WorkFlowName, BSNO)[0].GID; //var GROUPIDList = GetBSNOGROUPID(WORKFLOWID, BSNO, tran); //if (GROUPIDList.Count == 0) //{ // return false; //} //var GROUPID = GetBSNOGROUPID(WORKFLOWID, BSNO, tran)[0].GROUPID; var strSql = new StringBuilder(); strSql.Append(" declare @LASTCOUNT int "); strSql.Append(" set @LASTCOUNT=( select count(*) [Count] from workflow_step "); strSql.Append(" where workflowid ='" + WORKFLOWID + "' "); strSql.Append(" and auditor='" + USERID + "' and groupid='" + GROUPID + "' and islast=1 )"); //strSql.Append(" if (@LASTCOUNT=0) begin"); //strSql.Append(" set @LASTCOUNT=( select count(*) [Count] from workflow_step "); //strSql.Append(" where workflowid =(select dbo.GetBSNOWorkflowid('" + WorkFlowName + "','" + BSNO + "'))) "); //strSql.Append(" if (@LASTCOUNT=0) begin select 1 [count] end else begin select 0 [count] end "); //strSql.Append(" end else begin select @LASTCOUNT [Count] end"); strSql.Append(" select @LASTCOUNT as Count "); //if (SetWorkFlowFinal(strSql) > 1) if (SetWorkFlowFinal(strSql) > 0) { return true; } else { return false; } } public static Boolean GetWorkFlowFinal_BSNO(string WorkFlowName, string BSNO, string USERID) { //20170117 改成在当前步骤组内该用户是否具备最终审核权限 var WORKFLOWID = GetBSNOWorkFlowID(WorkFlowName, BSNO)[0].GID; var GROUPIDList = GetBSNOGROUPID(WORKFLOWID, BSNO); if (GROUPIDList.Count == 0) { return false; } var GROUPID = GetBSNOGROUPID(WORKFLOWID, BSNO)[0].GROUPID; var strSql = new StringBuilder(); strSql.Append(" declare @LASTCOUNT int "); strSql.Append(" set @LASTCOUNT=( select count(*) [Count] from workflow_step "); strSql.Append(" where workflowid ='" + WORKFLOWID + "' "); strSql.Append(" and auditor='" + USERID + "' and groupid='" + GROUPID + "' and islast=1 )"); //strSql.Append(" if (@LASTCOUNT=0) begin"); //strSql.Append(" set @LASTCOUNT=( select count(*) [Count] from workflow_step "); //strSql.Append(" where workflowid =(select dbo.GetBSNOWorkflowid('" + WorkFlowName + "','" + BSNO + "'))) "); //strSql.Append(" if (@LASTCOUNT=0) begin select 1 [count] end else begin select 0 [count] end "); //strSql.Append(" end else begin select @LASTCOUNT [Count] end"); strSql.Append(" select @LASTCOUNT as Count "); //if (SetWorkFlowFinal(strSql) > 1) if (SetWorkFlowFinal(strSql) > 0) { return true; } else { return false; } } public static Boolean GetWorkFlowFinal_BSNO(string WorkFlowName, string BSNO, string USERID, DbTransaction tran) { //20170117 改成在当前步骤组内该用户是否具备最终审核权限 var WORKFLOWID = GetBSNOWorkFlowID(WorkFlowName, BSNO)[0].GID; var GROUPIDList = GetBSNOGROUPID(WORKFLOWID, BSNO, tran); if (GROUPIDList.Count == 0) { return false; } var GROUPID = GetBSNOGROUPID(WORKFLOWID, BSNO, tran)[0].GROUPID; var strSql = new StringBuilder(); strSql.Append(" declare @LASTCOUNT int "); strSql.Append(" set @LASTCOUNT=( select count(*) [Count] from workflow_step "); strSql.Append(" where workflowid ='" + WORKFLOWID + "' "); strSql.Append(" and auditor='" + USERID + "' and groupid='" + GROUPID + "' and islast=1 )"); //strSql.Append(" if (@LASTCOUNT=0) begin"); //strSql.Append(" set @LASTCOUNT=( select count(*) [Count] from workflow_step "); //strSql.Append(" where workflowid =(select dbo.GetBSNOWorkflowid('" + WorkFlowName + "','" + BSNO + "'))) "); //strSql.Append(" if (@LASTCOUNT=0) begin select 1 [count] end else begin select 0 [count] end "); //strSql.Append(" end else begin select @LASTCOUNT [Count] end"); strSql.Append(" select @LASTCOUNT as Count "); //if (SetWorkFlowFinal(strSql) > 1) if (SetWorkFlowFinal(strSql) > 0) { return true; } else { return false; } } private static int SetWorkFlowFinal(StringBuilder strSql) { var Count = 0; Database db = DatabaseFactory.CreateDatabase(); using (IDataReader reader = db.ExecuteReader(CommandType.Text, strSql.ToString())) { while (reader.Read()) { Count = Convert.ToInt32(reader["Count"]); } reader.Close(); } return Count; } #endregion #region 从workflow_using表删除(工作流状态删除) /* static public int GetWorkFlowDo(string WorkFlowName, string DEPTGID, string BSNO) { var strSql = new StringBuilder(); strSql.Append(" declare @WorkFlowID varchar(50) "); strSql.Append(" set @WorkFlowID=(select dbo.getworkflowid('" + WorkFlowName + "','" + DEPTGID + "')) "); strSql.Append(" select count(*) [count] from workflow_do "); strSql.Append(" where workflowid=@WorkFlowID and bsno='" + BSNO + "' and isdelete is null "); return SetWorkFlowDo(strSql.ToString()); }*/ //通过bsno和workflowid判断该业务是否存在未删除的操作记录 //如果存在(返回值大于0)，一般来说上位操作将会据此禁止对此业务的修改。 static public int GetWorkFlowDo(string WORKFLOWID, string BSNO) { var strSql = new StringBuilder(); strSql.Append(" declare @WorkFlowID varchar(50) "); strSql.Append(" set @WorkFlowID='" + WORKFLOWID + "' "); strSql.Append(" select count(*) [count] from workflow_do "); strSql.Append(" where workflowid=@WorkFlowID and bsno='" + BSNO + "' and isdelete is null "); return SetWorkFlowDo(strSql.ToString()); } private static int SetWorkFlowDo(string strSql) { var _count = 0; Database db = DatabaseFactory.CreateDatabase(); using (IDataReader reader = db.ExecuteReader(CommandType.Text, strSql.ToString())) { while (reader.Read()) { _count = Convert.ToInt32(reader["count"]); } reader.Close(); } return _count; } static public Resultmb DeleteWorkFlowUsing(string WorkFlowName, string BSNO, string USERID) { var strSql = new StringBuilder(); strSql.Append(" declare @WorkFlowID varchar(50),@GROUPID varchar(50) "); strSql.Append(" set @WorkFlowID=(select dbo.getworkflowid('" + WorkFlowName + "','" + BSNO + "')) "); strSql.Append(" if (select count(*) from workflow_do where workflowid=@WorkFlowID and bsno='" + BSNO + "' and isdelete is null)=0"); strSql.Append(" begin delete workflow_using "); strSql.Append(" where workflowid=@WorkFlowID and bsno='" + BSNO + "' end");//select '1' as candel //strSql.Append(" else begin select '0' as candel end"); return DoDeleteWorkFlowUsing(strSql.ToString()); }/* static public int DeleteWorkFlowUsing(string WORKFLOWID, string BSNO) { var strSql = new StringBuilder(); strSql.Append(" declare @WorkFlowID varchar(50),@GROUPID varchar(50) "); strSql.Append(" set @WorkFlowID='" + WORKFLOWID + "' "); strSql.Append(" if (select count(*) from workflow_do where workflowid=@WorkFlowID and bsno='" + BSNO + "' and isdelete is null)=0"); strSql.Append(" begin delete workflow_using "); strSql.Append(" where workflowid=@WorkFlowID and bsno='" + BSNO + "' select '1' as candel end"); strSql.Append(" else begin select '0' as candel end"); return DoDeleteWorkFlowUsing(strSql.ToString()); }*/ private static Resultmb DoDeleteWorkFlowUsing(string strSql) { var result = new Resultmb(); Database db = DatabaseFactory.CreateDatabase(); try { db.ExecuteNonQuery(CommandType.Text, strSql.ToString()); } catch (Exception ee) { result.Success = false; result.Message = "删除workflow_using出错" + ee.Message; } return result; } #endregion #region 通过workflowid和groupid来取得需要通知的操作人 static public List GetAuditor(string WORKFLOWID, string GROUPID) { var strSql = new StringBuilder(); strSql.Append(" select ws.auditor,u.showname from workflow_step ws left join [user] u on u.gid=ws.auditor "); strSql.Append(" where workflowid='" + WORKFLOWID + "' and groupid=" + GROUPID + " "); return SetAuditor(strSql.ToString()); } static public List GetAuditor(string WORKFLOWID, string GROUPID, DbTransaction tran) { var strSql = new StringBuilder(); strSql.Append(" select ws.auditor,u.showname from workflow_step ws left join [user] u on u.gid=ws.auditor "); strSql.Append(" where workflowid='" + WORKFLOWID + "' and groupid=" + GROUPID + " "); return SetAuditor(strSql.ToString()); } static public List GetSender(string WORKFLOWID, string BSNO) { var strSql = new StringBuilder(); strSql.Append(" select wu.OP auditor,u.showname from workflow_using wu left join [user] u on u.gid=wu.OP "); strSql.Append(" where workflowid='" + WORKFLOWID + "' and BSNO='" + BSNO + "' "); return SetAuditor(strSql.ToString()); } private static List SetAuditor(string strSql) { var bodyList = new List(); Database db = DatabaseFactory.CreateDatabase(); using (IDataReader reader = db.ExecuteReader(CommandType.Text, strSql.ToString())) { while (reader.Read()) { Auditormb data = new Auditormb(); data.GID = Convert.ToString(reader["auditor"]); data.NAME = Convert.ToString(reader["showname"]); bodyList.Add(data); } reader.Close(); } return bodyList; } private static List SetAuditor(string strSql, DbTransaction tran) { var bodyList = new List(); Database db = DatabaseFactory.CreateDatabase(); using (IDataReader reader = db.ExecuteReader(tran, CommandType.Text, strSql.ToString())) { while (reader.Read()) { Auditormb data = new Auditormb(); data.GID = Convert.ToString(reader["auditor"]); data.NAME = Convert.ToString(reader["showname"]); bodyList.Add(data); } reader.Close(); } return bodyList; } #endregion #region 审核通过时通知发起人 static public int PassMessage(string WORKFLOWID, string BSNO, string GROUDPID, string Auditor) { //var strSql = new StringBuilder(); var _count = 0; /* var strSql = new StringBuilder(); //Message.RECEIVER = Auditor.GID; strSql.Append(" declare @WORKFLOWID varchar(50),@OP varchar(50),@BSNO varchar(50),@CURRENTID varchar(50),@STEPNAME varchar(100) "); strSql.Append(" set @WORKFLOWID ='" + WORKFLOWID + "'"); strSql.Append(" set @OP = (select OP from workflow_using where workflowid='" + WORKFLOWID + "' and bsno='" + BSNO + "')"); strSql.Append(" set @BSNO = '"+BSNO+"'"); strSql.Append(" set @CURRENTID = '" + GROUDPID + "'"); strSql.Append(" set @STEPNAME = (select top 1 description from workflow_step where workflowid=@workflowid and auditor='" + Auditor + "' and groupid='" + GROUDPID + "')"); strSql.Append(" select newid() GID,(select [name] from workflow_type where typeno=(select [type] from workflow where gid=@WORKFLOWID)) [name] "); strSql.Append(" ,(select DESCRIPTION from workflow where gid=@WORKFLOWID) description,getdate() createtime,0 isread,0 readcount, "); strSql.Append(" ((select showname from [user] where gid='" + Auditor + "')+' 审核了['+(select DESCRIPTION from workflow "); strSql.Append(" where gid=@WORKFLOWID)+']'+' 单号:'+@BSNO+' 步骤:'+@STEPNAME+'') messagecontent,null lastreadtime,@OP receiver, "); strSql.Append(" 0 [type],(select top 1 TASKURL from workflow_step where workflowid=@WORKFLOWID and auditor='" + Auditor ); strSql.Append(" ' and GROUPID=@CURRENTID)+'?BSNO='+@BSNO taskurl,@BSNO taskid,0 isdelete,null deleteuser,null deletetime,0 [number],2 recvtype "); var _message = SetInsertMessage(strSql); if (SaveMessage(_message)) { _count = 1; } * */ return _count; } static public int PassMessage(string WORKFLOWID, string BSNO, string GROUDPID, string Auditor, string BILLNO, string GID, string URL) { //var strSql = new StringBuilder(); var _count = 0; /* var strSql = new StringBuilder(); //Message.RECEIVER = Auditor.GID; strSql.Append(" declare @WORKFLOWID varchar(50),@OP varchar(50),@BSNO varchar(50),@BILLNO varchar(50),@CURRENTID varchar(50),@STEPNAME varchar(100) "); strSql.Append(" set @WORKFLOWID ='" + WORKFLOWID + "'"); strSql.Append(" set @OP = (select OP from workflow_using where workflowid='" + WORKFLOWID + "' and bsno='" + BSNO + "')"); strSql.Append(" set @BSNO = '" + BSNO + "'"); strSql.Append(" set @BILLNO = '" + BILLNO + "'"); strSql.Append(" set @CURRENTID = '" + GROUDPID + "'"); strSql.Append(" set @STEPNAME = (select top 1 description from workflow_step where workflowid=@workflowid and auditor='" + Auditor + "' and groupid='" + GROUDPID + "')"); strSql.Append(" delete from sys_message where name=(select [name] from workflow_type where typeno=(select [type] from workflow where gid=@WORKFLOWID)) and taskid='" + GID + "' and isread=0 "); strSql.Append(" select newid() GID,(select [name] from workflow_type where typeno=(select [type] from workflow where gid=@WORKFLOWID)) [name] "); strSql.Append(" ,(select DESCRIPTION from workflow where gid=@WORKFLOWID) description,getdate() createtime,0 isread,0 readcount, "); strSql.Append(" ((select showname from [user] where gid='" + Auditor + "')+' 审核了['+(select DESCRIPTION from workflow "); strSql.Append(" where gid=@WORKFLOWID)+']'+' 单号:'+@BILLNO+' 步骤:'+@STEPNAME+'') messagecontent,null lastreadtime,@OP receiver, "); strSql.Append(" 0 [type],'"+URL+"' taskurl,'"+GID+"' taskid,0 isdelete,null deleteuser,null deletetime,0 [number],2 recvtype "); var _message = SetInsertMessage(strSql, BILLNO, GID, URL ); if (SaveMessage(_message)) { _count = 1; } * */ return _count; } #endregion #region 提交时通知审核人 static public int StartMessage(string WORKFLOWID, string OP, string RECEIVER, string BSNO,string BILLNO) { var _count = 0; var cookies = new Cookies(); var WorkflowMsg = cookies.getCookie(CookieConstant.WorkflowMsg);//启用消息提示 if (WorkflowMsg == "1") { var strSql = new StringBuilder(); strSql.Append(" select newid() GID,(select top 1 [name] from workflow_type where typeno=(select [type] from workflow where gid='" + WORKFLOWID + "')) [name] "); strSql.Append(" ,(select DESCRIPTION from workflow where gid='" + WORKFLOWID + "') description,getdate() createtime,0 isread,0 readcount, "); strSql.Append(" ((select showname from [user] where gid='" + OP + "')+' 提交了['+(select DESCRIPTION from workflow where gid='" + WORKFLOWID + "')+']'+' 单号:" + BILLNO + "') messagecontent,null lastreadtime,'" + RECEIVER + "' receiver, "); strSql.Append(" 0 [type],(select top 1 TASKURL from workflow_step where workflowid='" + WORKFLOWID + "' and auditor='" + RECEIVER + "' and GROUPID=1)+'?BSNO='+'" + BSNO + "' taskurl,'" + BSNO + "' taskid,null isdelete,null deleteuser,null deletetime,0 [number],2 recvtype "); var _message = SetInsertMessage(strSql); if (SaveMessage(_message)) { _count = 1; } } return _count; } private static SYSMessagemb SetInsertMessage(StringBuilder strSql) { var data = new SYSMessagemb(); Database db = DatabaseFactory.CreateDatabase(); try { using (IDataReader reader = db.ExecuteReader(CommandType.Text, strSql.ToString())) { while (reader.Read()) { data.GID = Convert.ToString(reader["GID"]); data.NAME = Convert.ToString(reader["NAME"]); data.DESCRIPTION = Convert.ToString(reader["DESCRIPTION"]); data.CREATETIME = Convert.ToString(reader["CREATETIME"]); data.ISREAD = Convert.ToString(reader["ISREAD"]); data.READCOUNT = Convert.ToString(reader["READCOUNT"]); data.MESSAGECONTENT = Convert.ToString(reader["MESSAGECONTENT"]); data.LASTREADTIME = Convert.ToString(reader["LASTREADTIME"]); data.RECEIVER = Convert.ToString(reader["RECEIVER"]); data.TYPE = Convert.ToString(reader["TYPE"]); data.TASKURL = Convert.ToString(reader["TASKURL"]); data.TASKID = Convert.ToString(reader["TASKID"]); data.ISDELETE = Convert.ToString(reader["ISDELETE"]); data.DELETEUSER = Convert.ToString(reader["DELETEUSER"]); data.DELETETIME = Convert.ToString(reader["DELETETIME"]); data.NUMBER = Convert.ToString(reader["NUMBER"]); data.RECVTYPE = Convert.ToString(reader["RECVTYPE"]); data.ISSEND ="0"; } reader.Close(); } } catch (Exception ee) { var _Result = new DBResult(); _Result.Success = false; _Result.Message = ee.Message; return data; } return data; } static public int StartMessage(string WORKFLOWID, string OP, string RECEIVER, string BSNO, string BILLNO, string GID, string URL,string MSG="") { var _count = 0; var cookies = new Cookies(); var WorkflowMsg = cookies.getCookie(CookieConstant.WorkflowMsg);//启用消息提示 if (WorkflowMsg == "1") { var strSql = new StringBuilder(); //strSql.Append(" delete from sys_message where name=(select top 1 [name] from workflow_type where typeno=(select [type] from workflow where gid='" + WORKFLOWID + "')) and taskid='" + GID + "' and RECEIVER='" + RECEIVER + "' and isread=0 "); strSql.Append(" select newid() GID,(select top 1 [name] from workflow_type where typeno=(select [type] from workflow where gid='" + WORKFLOWID + "')) [name] "); strSql.Append(" ,(select DESCRIPTION from workflow where gid='" + WORKFLOWID + "') description,getdate() createtime,0 isread,0 readcount, "); strSql.Append(" ((select showname from [user] where gid='" + OP + "')+' 提交了['+(select DESCRIPTION from workflow where gid='" + WORKFLOWID + "')+']'+'，单号:" + BILLNO +","+MSG+"') messagecontent,null lastreadtime,'" + RECEIVER + "' receiver, "); strSql.Append(" 0 [type],'" + URL + "' taskurl,'" + GID + "' taskid,null isdelete,null deleteuser,null deletetime,0 [number],2 recvtype "); var _message = SetInsertMessage(strSql, BILLNO, GID, URL); if (SaveMessage(_message)) { _count = 1; } } return _count; } private static SYSMessagemb SetInsertMessage(StringBuilder strSql, string BILLNO, string GID, string URL) { var data = new SYSMessagemb(); Database db = DatabaseFactory.CreateDatabase(); using (IDataReader reader = db.ExecuteReader(CommandType.Text, strSql.ToString())) { while (reader.Read()) { data.GID = Convert.ToString(reader["GID"]); data.NAME = Convert.ToString(reader["NAME"]); data.DESCRIPTION = Convert.ToString(reader["DESCRIPTION"]); data.CREATETIME = Convert.ToString(reader["CREATETIME"]); data.ISREAD = Convert.ToString(reader["ISREAD"]); data.READCOUNT = Convert.ToString(reader["READCOUNT"]); data.MESSAGECONTENT = Convert.ToString(reader["MESSAGECONTENT"]); data.LASTREADTIME = Convert.ToString(reader["LASTREADTIME"]); data.RECEIVER = Convert.ToString(reader["RECEIVER"]); data.TYPE = Convert.ToString(reader["TYPE"]); data.TASKURL = URL; data.TASKID = GID; data.ISDELETE = Convert.ToString(reader["ISDELETE"]); data.DELETEUSER = Convert.ToString(reader["DELETEUSER"]); data.DELETETIME = Convert.ToString(reader["DELETETIME"]); data.NUMBER = Convert.ToString(reader["NUMBER"]); data.RECVTYPE = Convert.ToString(reader["RECVTYPE"]); data.ISSEND ="0"; } reader.Close(); } return data; } private static SYSMessagemb SetInsertMessage(StringBuilder strSql, string BILLNO, string GID, string URL, DbTransaction tran) { var data = new SYSMessagemb(); Database db = DatabaseFactory.CreateDatabase(); using (IDataReader reader = db.ExecuteReader(tran, CommandType.Text, strSql.ToString())) { while (reader.Read()) { data.GID = Convert.ToString(reader["GID"]); data.NAME = Convert.ToString(reader["NAME"]); data.DESCRIPTION = Convert.ToString(reader["DESCRIPTION"]); data.CREATETIME = Convert.ToString(reader["CREATETIME"]); data.ISREAD = Convert.ToString(reader["ISREAD"]); data.READCOUNT = Convert.ToString(reader["READCOUNT"]); data.MESSAGECONTENT = Convert.ToString(reader["MESSAGECONTENT"]); data.LASTREADTIME = Convert.ToString(reader["LASTREADTIME"]); data.RECEIVER = Convert.ToString(reader["RECEIVER"]); data.TYPE = Convert.ToString(reader["TYPE"]); data.TASKURL = URL; data.TASKID = GID; data.ISDELETE = Convert.ToString(reader["ISDELETE"]); data.DELETEUSER = Convert.ToString(reader["DELETEUSER"]); data.DELETETIME = Convert.ToString(reader["DELETETIME"]); data.NUMBER = Convert.ToString(reader["NUMBER"]); data.RECVTYPE = Convert.ToString(reader["RECVTYPE"]); data.ISSEND ="0"; } reader.Close(); } return data; } #endregion #region 审核步骤组 通过时 通知下一步审核人 static public int PushMessage(string WORKFLOWID, string BSNO, string GROUDPID,string BILLNO) { //var strSql = new StringBuilder(); var _count = 0; var cookies = new Cookies(); var WorkflowMsg = cookies.getCookie(CookieConstant.WorkflowMsg);//启用消息提示 if (WorkflowMsg == null) { return 0; } if (WorkflowMsg == "1") { var UserName = cookies.getCookie(CookieConstant.UserId);//登录组织 //var strSql = new StringBuilder(); var AuditorList = GetAuditor(WORKFLOWID, GROUDPID);//取得待通知人列表 foreach (var Auditor in AuditorList) { var strSql = new StringBuilder(); //Message.RECEIVER = Auditor.GID; strSql.Append(" declare @WORKFLOWID varchar(50),@OP varchar(50),@BSNO varchar(50),@CURRENTID varchar(50) "); strSql.Append(" set @WORKFLOWID ='" + WORKFLOWID + "'"); strSql.Append(" set @OP = '" + UserName + "'"); strSql.Append(" set @BSNO = '" + BSNO + "'"); strSql.Append(" set @CURRENTID = '" + GROUDPID + "'"); strSql.Append(" select newid() GID,(select [name] from workflow_type where typeno=(select [type] from workflow where gid=@WORKFLOWID)) [name] "); strSql.Append(" ,(select DESCRIPTION from workflow where gid=@WORKFLOWID) description,getdate() createtime,0 isread,0 readcount, "); strSql.Append(" ((select showname from [user] where gid=@OP)+' 提交了['+(select DESCRIPTION from workflow where gid=@WORKFLOWID)+']'+' 单号:'+@BSNO+'') messagecontent,null lastreadtime,'" + Auditor.GID + "' receiver, "); strSql.Append(" 0 [type],(select top 1 TASKURL from workflow_step where workflowid=@WORKFLOWID and auditor='" + Auditor.GID + "' and GROUPID=@CURRENTID)+'?BSNO='+@BSNO taskurl,@BSNO taskid,0 isdelete,null deleteuser,null deletetime,0 [number],2 recvtype "); var _message = SetInsertMessage(strSql); if (SaveMessage(_message)) { _count = _count + 1; } } } return _count; } static public int PushMessage(string WORKFLOWID, string BSNO, string GROUDPID, string BILLNO, string GID, string URL) { //var strSql = new StringBuilder(); var _count = 0; var cookies = new Cookies(); var WorkflowMsg = cookies.getCookie(CookieConstant.WorkflowMsg);//启用消息提示 if (WorkflowMsg == "1") { var UserName = cookies.getCookie(CookieConstant.UserId);//登录组织 //var strSql = new StringBuilder(); var AuditorList = GetAuditor(WORKFLOWID, GROUDPID);//取得待通知人列表 此处应为 foreach (var Auditor in AuditorList) { var strSql = new StringBuilder(); //Message.RECEIVER = Auditor.GID; strSql.Append(" declare @WORKFLOWID varchar(50),@OP varchar(50),@BSNO varchar(50),@BILLNO varchar(50),@CURRENTID varchar(50) "); strSql.Append(" set @WORKFLOWID ='" + WORKFLOWID + "'"); strSql.Append(" set @OP = '" + UserName + "'"); strSql.Append(" set @BSNO = '" + BSNO + "'"); strSql.Append(" set @BILLNO = '" + BILLNO + "'"); strSql.Append(" set @CURRENTID = '" + GROUDPID + "'"); //strSql.Append(" delete from sys_message where name=(select [name] from workflow_type where typeno=(select [type] from workflow where gid=@WORKFLOWID)) and taskid='" + GID + "' and isread=0 "); strSql.Append(" select newid() GID,(select [name] from workflow_type where typeno=(select [type] from workflow where gid=@WORKFLOWID)) [name] "); strSql.Append(" ,(select DESCRIPTION from workflow where gid=@WORKFLOWID) description,getdate() createtime,0 isread,0 readcount, "); strSql.Append(" ((select showname from [user] where gid=@OP)+' 提交了['+(select DESCRIPTION from workflow where gid=@WORKFLOWID)+']'+' 单号:'+@BILLNO+'') messagecontent,null lastreadtime,'" + Auditor.GID + "' receiver, "); strSql.Append(" 0 [type],(select top 1 TASKURL from workflow_step where workflowid=@WORKFLOWID and auditor='" + Auditor.GID + "' and GROUPID=@CURRENTID)+'?BSNO='+@BSNO taskurl,@BSNO taskid,0 isdelete,null deleteuser,null deletetime,0 [number],2 recvtype "); var _message = SetInsertMessage(strSql, BILLNO, GID, URL); if (SaveMessage(_message)) { _count = _count + 1; } } } return _count; } static public int PushMessage(string WORKFLOWID, string BSNO, string GROUDPID, string BILLNO, string GID, string URL, DbTransaction tran) { //var strSql = new StringBuilder(); var _count = 0; var cookies = new Cookies(); var WorkflowMsg = cookies.getCookie(CookieConstant.WorkflowMsg);//启用消息提示 if (WorkflowMsg == "1") { var UserName = cookies.getCookie(CookieConstant.UserId);//登录组织 //var strSql = new StringBuilder(); var AuditorList = GetAuditor(WORKFLOWID, GROUDPID, tran);//取得待通知人列表 此处应为 foreach (var Auditor in AuditorList) { var strSql = new StringBuilder(); //Message.RECEIVER = Auditor.GID; strSql.Append(" declare @WORKFLOWID varchar(50),@OP varchar(50),@BSNO varchar(50),@BILLNO varchar(50),@CURRENTID varchar(50) "); strSql.Append(" set @WORKFLOWID ='" + WORKFLOWID + "'"); strSql.Append(" set @OP = '" + UserName + "'"); strSql.Append(" set @BSNO = '" + BSNO + "'"); strSql.Append(" set @BILLNO = '" + BILLNO + "'"); strSql.Append(" set @CURRENTID = '" + GROUDPID + "'"); //strSql.Append(" delete from sys_message where name=(select [name] from workflow_type where typeno=(select [type] from workflow where gid=@WORKFLOWID)) and taskid='" + GID + "' and isread=0 "); strSql.Append(" select newid() GID,(select [name] from workflow_type where typeno=(select [type] from workflow where gid=@WORKFLOWID)) [name] "); strSql.Append(" ,(select DESCRIPTION from workflow where gid=@WORKFLOWID) description,getdate() createtime,0 isread,0 readcount, "); strSql.Append(" ((select showname from [user] where gid=@OP)+' 提交了['+(select DESCRIPTION from workflow where gid=@WORKFLOWID)+']'+' 单号:'+@BILLNO+'') messagecontent,null lastreadtime,'" + Auditor.GID + "' receiver, "); strSql.Append(" 0 [type],(select top 1 TASKURL from workflow_step where workflowid=@WORKFLOWID and auditor='" + Auditor.GID + "' and GROUPID=@CURRENTID)+'?BSNO='+@BSNO taskurl,@BSNO taskid,0 isdelete,null deleteuser,null deletetime,0 [number],2 recvtype "); var _message = SetInsertMessage(strSql, BILLNO, GID, URL, tran); if (SaveMessage(_message)) { _count = _count + 1; } } } return _count; } static public int RepeatMessage(string WORKFLOWID, string BSNO, string GROUDPID, string auditor_GID, string BILLNO, string GID, string URL) { //var strSql = new StringBuilder(); //var strSql = new StringBuilder(); var _count = 0; var cookies = new Cookies(); var WorkflowMsg = cookies.getCookie(CookieConstant.WorkflowMsg);//启用消息提示 if (WorkflowMsg == "1") { var SenderList = GetSender(WORKFLOWID, BSNO);//取得待通知人列表 此处应为该工作流的提交人 foreach (var Sender in SenderList) { var strSql = new StringBuilder(); //Message.RECEIVER = Auditor.GID; strSql.Append(" declare @WORKFLOWID varchar(50),@BSNO varchar(50),@CURRENTID varchar(50) "); strSql.Append(" set @WORKFLOWID ='" + WORKFLOWID + "'"); //strSql.Append(" set @OP = '" + Sender.GID + "'"); strSql.Append(" set @BSNO = '" + BILLNO + "'"); strSql.Append(" set @CURRENTID = '" + GROUDPID + "'"); //strSql.Append(" delete from sys_message where name=(select [name] from workflow_type where typeno=(select [type] from workflow where gid=@WORKFLOWID)) and taskid='" + GID + "' and isread=0 "); strSql.Append(" select newid() GID,(select [name] from workflow_type where typeno=(select [type] from workflow where gid=@WORKFLOWID)) [name] "); strSql.Append(" ,(select DESCRIPTION from workflow where gid=@WORKFLOWID) description,getdate() createtime,0 isread,0 readcount, "); strSql.Append(" ((select showname from [user] where gid='" + auditor_GID + "')+' 通过了['+(select DESCRIPTION from workflow where gid=@WORKFLOWID)+']'+' 单号:'+@BSNO+'') messagecontent,null lastreadtime,'" + Sender.GID + "' receiver, "); strSql.Append(" 0 [type],'" + URL + "' taskurl,@BSNO taskid,0 isdelete,null deleteuser,null deletetime,0 [number],2 recvtype "); var _message = SetInsertMessage(strSql, BILLNO, GID, URL); if (SaveMessage(_message)) { _count = _count + 1; } } } return _count; } #endregion #region 驳回时通知发起人 static public int RefuseMessage(string WORKFLOWID, string BSNO, string RefuseID, string Reason) { var _count = 0; var cookies = new Cookies(); var WorkflowMsg = cookies.getCookie(CookieConstant.WorkflowMsg);//启用消息提示 if (WorkflowMsg == "1") { var strSql = new StringBuilder(); strSql.Append(" declare @WORKFLOWID varchar(50),@OP varchar(50),@BSNO varchar(50) "); strSql.Append(" set @WORKFLOWID = '" + WORKFLOWID + "'"); strSql.Append(" set @OP = (select OP from workflow_using where workflowid='" + WORKFLOWID + "' and bsno='" + BSNO + "')"); strSql.Append(" set @BSNO = '" + BSNO + "'"); strSql.Append(" select newid() GID,(select top 1 [name] from workflow_type where typeno=(select [type] from workflow where gid=@WORKFLOWID)) [name] "); strSql.Append(" ,(select DESCRIPTION from workflow where gid=@WORKFLOWID) description,getdate() createtime,0 isread,0 readcount, "); strSql.Append(" ((select showname from [user] where gid='" + RefuseID + "')+' 驳回了['+(select DESCRIPTION from workflow where gid=@WORKFLOWID)+'] "); strSql.Append(" 原因'+'" + Reason + "') messagecontent,null lastreadtime,@OP receiver, "); strSql.Append(" 0 [type],(select top 1 TASKURL from workflow_step where workflowid=@WORKFLOWID and auditor='" + RefuseID + "' )+'?BSNO='+@BSNO taskurl,@BSNO taskid,0 isdelete,null deleteuser,null deletetime,0 [number],2 recvtype "); var _message = SetInsertMessage(strSql); if (SaveMessage(_message)) { _count = 1; } } return _count; } static public int RefuseMessage(string WORKFLOWID, string BSNO, string RefuseID, string Reason, string BILLNO, string GID, string URL) { var _count = 0; var cookies = new Cookies(); var WorkflowMsg = cookies.getCookie(CookieConstant.WorkflowMsg);//启用消息提示 if (WorkflowMsg == "1") { var strSql = new StringBuilder(); strSql.Append(" declare @WORKFLOWID varchar(50),@OP varchar(50),@BSNO varchar(50) "); strSql.Append(" set @WORKFLOWID = '" + WORKFLOWID + "'"); strSql.Append(" set @OP = (select OP from workflow_using where workflowid='" + WORKFLOWID + "' and bsno='" + BSNO + "')"); strSql.Append(" set @BSNO = '" + BSNO + "'"); //strSql.Append(" delete from sys_message where name=(select top 1 [name] from workflow_type where typeno=(select [type] from workflow where gid=@WORKFLOWID)) and taskid='" + GID + "' and isread=0 "); strSql.Append(" select newid() GID,(select top 1 [name] from workflow_type where typeno=(select [type] from workflow where gid=@WORKFLOWID)) [name] "); strSql.Append(" ,(select DESCRIPTION from workflow where gid=@WORKFLOWID) description,getdate() createtime,0 isread,0 readcount, "); strSql.Append(" ((select showname from [user] where gid='" + RefuseID + "')+' 驳回了['+(select DESCRIPTION from workflow where gid=@WORKFLOWID)+'] 单号:" + BILLNO + ", "); strSql.Append(" 原因'+'" + Reason + "') messagecontent,null lastreadtime,@OP receiver, "); strSql.Append(" 0 [type],'" + URL + "' taskurl,'" + GID + "' taskid,0 isdelete,null deleteuser,null deletetime,0 [number],2 recvtype "); var _message = SetInsertMessage(strSql, BILLNO, GID, URL); if (SaveMessage(_message)) { _count = 1; } } return _count; } #endregion #region 保存信息 public static Boolean SaveMessage(SYSMessagemb Message) { var head = Message; head.DbOperationType = DbOperationType.DbotIns; head.ModelUIStatus = "I"; var modb = new ModelObjectRepository(); DBResult result = modb.Save(head); T_ALL_DA T_ALL_DA = new EntityDA.T_ALL_DA(); var CT = T_ALL_DA.GetStrSQL("CT", "select count(*) CT from user_msg_set WHERE USERID='" + Message.RECEIVER + "' and WORKFLOWTYPE_NAME='" + Message.NAME + "'"); if (CT == "0") { var USEDINGDINGMSG = MsSysParamSetDAL.GetData("PARAMNAME='USEDINGDINGMSG'").PARAMVALUE; if (USEDINGDINGMSG == "1") { DingTalkHelper.SendMessage(Message.RECEIVER, Message.MESSAGECONTENT); } try { bool suessce = new ChatHub().SendMessage(head.RECEIVER, head.GID); } catch (Exception e) { } } //刷新父窗口上的父节点 var jsonRespose = new JsonResponse { Success = result.Success, Message = result.Message, Data = "" }; return jsonRespose.Success; } #endregion #region 通用 提交 撤回 审核 驳回 #region 提交审核和撤销审核 目前是固化状态的方式，将来期望改成与任务状态联动的形式 /// /// AuditInfomb的参数包括 /// /// /// /// public static DBResult SubmitAudit(AuditInfomb AuditInfo,string extracmd="") { var result = new DBResult(); Database db = DatabaseFactory.CreateDatabase(); using (var conn = db.CreateConnection()) { conn.Open(); var tran = conn.BeginTransaction(); try { Resultmb WorkResult = WorkFlowDAL.WorkFlowStart(AuditInfo.WORKFLOWNAME, AuditInfo.BSNO, AuditInfo.USERID, AuditInfo.BSNO, AuditInfo.BSNO,""); if (WorkResult.Success) { result = ChangeBillWorkflow(AuditInfo, tran, WorkResult.islast, db, extracmd); if (result.Success == true) { tran.Commit(); result.Message = "提交审核成功!"; } else { //tran.Rollback(); //result.Success = false; //result.Message = "提交审核错误!"; result.Message = "提交审核错误!" + result.Message; } } } catch (Exception) { tran.Rollback(); result.Success = false; result.Message = "提交审核错误，请重试或联系系统管理员"; return result; } } return result; } public static DBResult SubmitAuditBack(AuditInfomb AuditInfo, string extracmd="") { var result = new DBResult(); Database db = DatabaseFactory.CreateDatabase(); using (var conn = db.CreateConnection()) { conn.Open(); var tran = conn.BeginTransaction(); try { Resultmb WorkResult = WorkFlowDAL.WorkFlowReset(AuditInfo.WORKFLOWNAME, AuditInfo.BSNO, AuditInfo.USERID); result = ChangeBillWorkflow(AuditInfo, tran, WorkResult.islast, db, extracmd); if (result.Success == true) { tran.Commit(); result.Message = "撤回提交成功!"; } else { //tran.Rollback(); //result.Success = false; //result.Message = "提交审核错误!"; result.Message = "已经审核或部分审核 不允许撤回!" + result.Message; } } catch (Exception) { tran.Rollback(); result.Success = false; result.Message = "提交审核错误，请重试或联系系统管理员"; return result; } } return result; } #endregion #region 审核或驳回 public static DBResult Audit(AuditInfomb AuditInfo, string extracmd="") { var result = new DBResult(); Database db = DatabaseFactory.CreateDatabase(); using (var conn = db.CreateConnection()) { conn.Open(); try { if (AuditInfo.BSNOArray.Count()>0) { foreach (var BSNO in AuditInfo.BSNOArray) { var tran = conn.BeginTransaction(); Resultmb WorkResult = WorkFlowDAL.InsertWorkFlowDo(AuditInfo.WORKFLOWNAME, BSNO, AuditInfo.USERID, tran,BSNO); if (WorkResult.Success) { result = ChangeBillWorkflow(AuditInfo, tran, WorkResult.islast, db, extracmd); if (result.Success == true) { tran.Commit(); result.Message = "审核通过!"; } else { //tran.Rollback(); //result.Success = false; //result.Message = "提交审核错误!"; result.Message = "审核失败!" + result.Message; } } else { tran.Rollback(); result.Success = false; result.Message = WorkResult.Message; } } } result = new DBResult(); result.Success = true; result.Message = "审核通过"; } catch (Exception e) { result.Success = false; result.Message = "审核出现错误，请重试或联系系统管理员："+e.Message; return result; } } result.Success = true; result.Message = "审核通过"; return result; } /// /// 在extracmd里面写 reason = '驳回理由' ,并给REASON参数传递一次驳回理由 /// /// /// /// public static DBResult AuditBack(AuditInfomb AuditInfo, string extracmd,string REASON) { var result = new DBResult(); Database db = DatabaseFactory.CreateDatabase(); using (var conn = db.CreateConnection()) { conn.Open(); try { if (AuditInfo.BSNOArray.Count() > 0) { foreach (var BSNO in AuditInfo.BSNOArray) { var tran = conn.BeginTransaction(); Resultmb WorkResult = WorkFlowDAL.DeleteWorkFlowDo(AuditInfo.WORKFLOWNAME, BSNO, AuditInfo.USERID, REASON ); if (WorkResult.Success) { result = ChangeBillWorkflow(AuditInfo, tran, WorkResult.islast, db, extracmd); if (result.Success == true) { tran.Commit(); result.Message = "驳回成功!"; } else { //tran.Rollback(); //result.Success = false; //result.Message = "提交审核错误!"; result.Message = "驳回失败!" + result.Message; } } else { tran.Rollback(); result.Success = false; result.Message = WorkResult.Message; } } } result = new DBResult(); result.Success = true; result.Message = "驳回成功"; } catch (Exception e) { result.Success = false; result.Message = "驳回出现错误，请重试或联系系统管理员：" + e.Message; return result; } } result.Success = true; result.Message = "驳回成功"; return result; } #endregion /// /// 实际修改业务的状态 /// /// /// /// /// /// private static DBResult ChangeBillWorkflow(AuditInfomb AuditInfo, DbTransaction tran, bool islast, Database db, string extracmd="") { var result = new DBResult(true, "", null); try { var cmdupdate_base = "update {0} set {1}={2} where {3} in({4}) and {5}={6}"; if (!string.IsNullOrEmpty(extracmd.Trim())) { cmdupdate_base = "update {0} set {1}={2},"+ extracmd + " where {3} in({4}) and {5}={6}"; } var cmdupdate = ""; if (islast == true) {//update tablename set STATEFIELDNAME=TOSTATE where BSNOFIELDNAME=BSNO and STATEFIELDNAME=FROMSTATE cmdupdate = string.Format(cmdupdate_base , AuditInfo.TABLENAME , AuditInfo.STATEFIELDNAME, AuditInfo.LASTSTATE , AuditInfo.BSNOFIELDNAME, AuditInfo.BSNOListStr , AuditInfo.STATEFIELDNAME, AuditInfo.FROMSTATE ); } else { cmdupdate = string.Format(cmdupdate_base , AuditInfo.TABLENAME , AuditInfo.STATEFIELDNAME, AuditInfo.TOSTATE , AuditInfo.BSNOFIELDNAME, AuditInfo.BSNOListStr , AuditInfo.STATEFIELDNAME, AuditInfo.FROMSTATE ); } DbCommand dc = db.GetSqlStringCommand(cmdupdate); db.ExecuteNonQuery(dc, tran); return result; } catch (Exception e) { tran.Rollback(); result.Success = false; result.Message = e.Message; return result; } } #endregion } }