using Org.BouncyCastle.Asn1.Ocsp;
using Serenity.Data.Schema;
using SqlSugar;
using System;
using System.Collections.Generic;
using System.IO;
using System.Linq;
using System.Net.Http;
using System.Reflection;
using System.Threading.Tasks;
using HT.Cloud.Code;
using HT.Cloud.DataBase;
using HT.Cloud.Domain.FlowManage;
using HT.Cloud.Domain.InfoManage;
using HT.Cloud.Domain.SystemManage;
using HT.Cloud.Domain.SystemOrganize;
using HT.Cloud.Service.InfoManage;
using static iTextSharp.text.pdf.AcroFields;

namespace HT.Cloud.Service.FlowManage
{
	/// <summary>
	/// 创 建：超级管理员
	/// 日 期：2020-07-14 09:18
	/// 描 述：我的流程服务类
	/// </summary>
	public class FlowinstanceService : BaseService<FlowinstanceEntity>, IDenpendency
	{
		public IHttpClientFactory _httpClientFactory { get; set; }
		public MessageService messageApp { get; set; }
		private string flowCreator;
		private string className { get; set; }

		public FlowinstanceService(ISqlSugarClient context) : base(context)
		{
			className = System.Reflection.MethodBase.GetCurrentMethod().DeclaringType.FullName.Split('.')[3].Substring(0, System.Reflection.MethodBase.GetCurrentMethod().DeclaringType.FullName.Split('.')[3].Length - 7);
		}

		#region 获取数据

		public async Task<List<FlowinstanceEntity>> GetList(string keyword = "")
		{
			var query = repository.IQueryable();
			if (!string.IsNullOrEmpty(keyword))
			{
				//此处需修改
				query = query.Where(a => a.F_Code.Contains(keyword) || a.F_CustomName.Contains(keyword));
			}
			return await query.Where(a => a.F_EnabledMark == true).OrderBy(a => a.F_Id, OrderByType.Desc).ToListAsync();
		}

		public async Task<List<FlowInstanceOperationHistory>> QueryHistories(string keyValue)
		{
			return await repository.Db.Queryable<FlowInstanceOperationHistory>().Where(u => u.F_InstanceId == keyValue).OrderBy(u => u.F_CreatorTime).ToListAsync();
		}

		public async Task<List<FlowinstanceEntity>> GetLookList(string keyword = "")
		{
			var query = repository.IQueryable();
			if (!string.IsNullOrEmpty(keyword))
			{
				//此处需修改
				query = query.Where(a => a.F_Code.Contains(keyword) || a.F_CustomName.Contains(keyword));
			}
			query = GetDataPrivilege("a", "", query);
			return await query.Where(a => a.F_EnabledMark == true).OrderBy(a => a.F_Id, OrderByType.Desc).ToListAsync();
		}

		public async Task<List<FlowinstanceEntity>> GetLookList(SoulPage<FlowinstanceEntity> pagination, string type = "", string keyword = "")
		{
			//反格式化显示只能用"等于"，其他不支持
			Dictionary<string, Dictionary<string, string>> dic = new Dictionary<string, Dictionary<string, string>>();
			Dictionary<string, string> enabledTemp = new Dictionary<string, string>();
			enabledTemp.Add("0", "正在运行");
			enabledTemp.Add("1", "审批通过");
			enabledTemp.Add("2", "被撤回");
			enabledTemp.Add("3", "不同意");
			enabledTemp.Add("4", "被驳回");
			dic.Add("F_IsFinish", enabledTemp);
			pagination = ChangeSoulData(dic, pagination);
			var query = repository.IQueryable();
			if (!string.IsNullOrEmpty(keyword))
			{
				//此处需修改
				query = query.Where(a => a.F_Code.Contains(keyword) || a.F_CustomName.Contains(keyword));
			}
			var user = currentuser;
			if (type == "todo")   //待办事项
			{
				query = query.Where(a => ((a.F_MakerList == "1" || a.F_MakerList.Contains(user.UserId))) && (a.F_IsFinish == 0 || a.F_IsFinish == 4) && a.F_ActivityType < 3);
			}
			else if (type == "done")  //已办事项（即我参与过的流程）
			{
				var instances = repository.Db.Queryable<FlowInstanceOperationHistory>().Where(a => a.F_CreatorUserId == user.UserId)
					.Select(a => a.F_InstanceId).Distinct().ToList();
				query = query.Where(a => instances.Contains(a.F_Id));
			}
			else  //我的流程
			{
				query = query.Where(a => a.F_CreatorUserId == user.UserId);
			}
			//权限过滤
			query = GetDataPrivilege("a", "", query);
			return await query.Where(a => a.F_EnabledMark == true).ToPageListAsync(pagination);
		}

		public async Task<FlowinstanceEntity> GetForm(string keyValue)
		{
			var data = await repository.FindEntity(keyValue);
			return data;
		}

		#endregion 获取数据

		public async Task<FlowinstanceEntity> GetLookForm(string keyValue)
		{
			var data = await repository.FindEntity(keyValue);
			return GetFieldsFilterData(data);
		}

		#region 获取各种节点的流程审核者

		/// <summary>
		/// 驳回
		/// 如果NodeRejectStep不为空，优先使用；否则按照NodeRejectType驳回
		/// </summary>
		/// <returns></returns>
		public async Task<bool> NodeReject(VerificationExtend reqest)
		{
			var user = currentuser;

			FlowinstanceEntity flowInstance = await GetForm(reqest.F_FlowInstanceId);
			flowCreator = flowInstance.F_CreatorUserId;
			FlowRuntime wfruntime = new FlowRuntime(flowInstance);

			string resnode = "";
			resnode = string.IsNullOrEmpty(reqest.NodeRejectStep) ? wfruntime.RejectNode(reqest.NodeRejectType) : reqest.NodeRejectStep;

			var tag = new Tag
			{
				Description = reqest.F_VerificationOpinion,
				Taged = (int)TagState.Reject,
				UserId = user.UserId,
				UserName = user.UserName
			};

			wfruntime.MakeTagNode(wfruntime.currentNodeId, tag);
			flowInstance.F_IsFinish = 4;//4表示驳回（需要申请者重新提交表单）
			repository.Db.Ado.BeginTran();
			if (resnode != "")
			{
				wfruntime.RemoveNode(resnode);
				flowInstance.F_SchemeContent = wfruntime.ToSchemeObj().ToJson();
				flowInstance.F_ActivityId = resnode;
				var prruntime = new FlowRuntime(flowInstance);
				prruntime.MakeTagNode(prruntime.currentNodeId, tag);
				flowInstance.F_PreviousId = prruntime.previousId;
				flowInstance.F_ActivityType = prruntime.GetNodeType(resnode);
				flowInstance.F_ActivityName = prruntime.Nodes[resnode].name;
				if (resnode == wfruntime.startNodeId)
				{
					flowInstance.F_MakerList = flowInstance.F_CreatorUserId;
				}
				else
				{
					flowInstance.F_MakerList = await repository.Db.Queryable<FlowInstanceTransitionHistory>().Where(a => a.F_FromNodeId == resnode && a.F_ToNodeId == prruntime.nextNodeId).OrderBy(a => a.F_CreatorTime, OrderByType.Desc).Select(a => a.F_CreatorUserId).FirstAsync();//当前节点可执行的人信息
				}
				await AddRejectTransHistory(wfruntime, prruntime);
                var formDic = reqest.F_FrmData.ToObject<Dictionary<string, object>>();
                var oldformDic = flowInstance.F_FrmData.ToObject<Dictionary<string, object>>();
                foreach (var item in oldformDic)
                    if (!formDic.ContainsKey(item.Key))
                        formDic.Add(item.Key, item.Value);
                if (flowInstance.F_FrmType == 1)
                {
                    var path = AppDomain.CurrentDomain.RelativeSearchPath ?? AppDomain.CurrentDomain.BaseDirectory;
                    var referencedAssemblies = Directory.GetFiles(path, "*.dll").Select(Assembly.LoadFrom).ToArray();
                    var t = referencedAssemblies
                        .SelectMany(a => a.GetTypes().Where(t => t.FullName.Contains("HT.Cloud.Service.") && t.FullName.Contains("." + flowInstance.F_DbName + "Service"))).First();
                    ICustomerForm icf = (ICustomerForm)GlobalContext.GetRequiredService(t);
                    flowInstance.F_FrmData = formDic.ToJson();
                    await icf.Edit(flowInstance.F_Id, flowInstance.F_FrmData);
                }
                else
                {
                    if (!string.IsNullOrEmpty(flowInstance.F_DbName))
                    {
                        formDic.Add("F_LastModifyUserId", this.currentuser.UserId);
                        formDic.Add("F_LastModifyTime", DateTime.Now);
                        formDic.Add("F_LastModifyUserName", this.currentuser.UserName);
                        flowInstance.F_FrmData = formDic.ToJson();
                        var data = repository.Db.DbMaintenance.GetColumnInfosByTableName(flowInstance.F_DbName, false);
                        List<string> oldID = formDic.Keys.ToList();//原来数据（原来ID）
                        List<string> newID = data.Select(a => a.DbColumnName).ToList();//新增数据（新ID）
                        foreach (var item in oldID.Except(newID))
                            formDic.Remove(item);
                        await repository.Db.Updateable(formDic).AS(flowInstance.F_DbName).WhereColumns(data.FirstOrDefault(a => a.IsPrimarykey).DbColumnName).ExecuteCommandAsync();
                    }
                }
                await repository.Update(flowInstance);
            }
            await repository.Db.Insertable(new FlowInstanceOperationHistory
			{
				F_Id = Utils.GuId(),
				F_InstanceId = reqest.F_FlowInstanceId
				,
				F_CreatorUserId = user.UserId
				,
				F_CreatorUserName = user.UserName
				,
				F_CreatorTime = DateTime.Now
				,
				F_FrmData= flowInstance.F_FrmData
				,
				F_Content = "【"
						  + wfruntime.currentNode.name
						  + "】【" + DateTime.Now.ToString("yyyy-MM-dd HH:mm") + "】驳回,备注："
						  + reqest.F_VerificationOpinion
			}).ExecuteCommandAsync();
			MessageEntity msg = new MessageEntity();
			if (resnode == wfruntime.startNodeId)
			{
				msg.F_MessageInfo = flowInstance.F_CustomName + "--流程驳回";
				var module = repository.Db.Queryable<ModuleEntity>().First(a => a.F_EnCode == className);
				msg.F_Href = module.F_UrlAddress;
				msg.F_HrefTarget = module.F_Target;
				msg.F_ToUserId = flowInstance.F_CreatorUserId;
				msg.F_ToUserName = flowInstance.F_CreatorUserName;
				msg.F_ClickRead = true;
				msg.F_KeyValue = flowInstance.F_Id;
			}
			else
			{
				msg.F_MessageInfo = flowInstance.F_CustomName + "--流程待处理";
				var module = repository.Db.Queryable<ModuleEntity>().First(a => a.F_EnCode == className);
				msg.F_Href = module.F_UrlAddress.Remove(module.F_UrlAddress.Length - 5, 5) + "ToDoFlow";
				msg.F_HrefTarget = module.F_Target;
				msg.F_ToUserId = flowInstance.F_MakerList == "1" ? "" : flowInstance.F_MakerList;
				msg.F_ClickRead = false;
				msg.F_KeyValue = flowInstance.F_Id;
			}
			msg.F_CreatorUserName = currentuser.UserName;
			msg.F_EnabledMark = true;
			msg.F_MessageType = 2;
			var lastmsg = repository.Db.Queryable<MessageEntity>().Where(a => a.F_ClickRead == false && a.F_KeyValue == flowInstance.F_Id).OrderBy(a => a.F_CreatorTime, OrderByType.Desc).First();
			if (lastmsg != null && !await repository.Db.Queryable<MessageHistoryEntity>().Where(a => a.F_MessageId == lastmsg.F_Id).AnyAsync())
			{
				await messageApp.ReadMsgForm(lastmsg.F_Id);
			}
			await messageApp.SubmitForm(msg);
			repository.Db.Ado.CommitTran();

			wfruntime.NotifyThirdParty(_httpClientFactory.CreateClient(), tag);

			return true;
		}

		/// <summary>
		/// 节点审核
		/// </summary>
		/// <param name="instanceId"></param>
		/// <returns></returns>
		public async Task<bool> NodeVerification(VerificationExtend request)
		{
			var user = currentuser;
			var instanceId = request.F_FlowInstanceId;

			var tag = new Tag
			{
				UserName = user.UserName,
				UserId = user.UserId,
				Description = request.F_VerificationOpinion,
				Taged = Int32.Parse(request.F_VerificationFinally)
			};
			FlowinstanceEntity flowInstance = await GetForm(instanceId);
			flowCreator = flowInstance.F_CreatorUserId;
			FlowInstanceOperationHistory flowInstanceOperationHistory = new FlowInstanceOperationHistory
			{
				F_Id = Utils.GuId(),
				F_InstanceId = instanceId,
				F_CreatorUserId = tag.UserId,
				F_CreatorUserName = tag.UserName,
				F_CreatorTime = DateTime.Now
			};//操作记录
			FlowRuntime wfruntime = new FlowRuntime(flowInstance);
			repository.Db.Ado.BeginTran();

			#region 会签

			if (flowInstance.F_ActivityType == 0)//当前节点是会签节点
			{
				//会签时的【当前节点】一直是会签开始节点
				//TODO: 标记会签节点的状态，这个地方感觉怪怪的
				wfruntime.MakeTagNode(wfruntime.currentNodeId, tag);

				string canCheckId = ""; //寻找当前登录用户可审核的节点Id
				foreach (string fromForkStartNodeId in wfruntime.FromNodeLines[wfruntime.currentNodeId].Select(u => u.to))
				{
					var fromForkStartNode = wfruntime.Nodes[fromForkStartNodeId];  //与会前开始节点直接连接的节点
					canCheckId = GetOneForkLineCanCheckNodeId(fromForkStartNode, wfruntime, tag);
					if (!string.IsNullOrEmpty(canCheckId)) break;
				}

				if (canCheckId == "")
				{
					throw (new Exception("审核异常,找不到审核节点"));
				}

				flowInstanceOperationHistory.F_Content = "【" + wfruntime.Nodes[canCheckId].name
														   + "】【" + DateTime.Now.ToString("yyyy-MM-dd HH:mm")
														   + "】" + (tag.Taged == 1 ? "同意" : "不同意") + ",备注："
														   + tag.Description;

				wfruntime.MakeTagNode(canCheckId, tag); //标记审核节点状态
				string res = wfruntime.NodeConfluence(canCheckId, tag);
				if (res == TagState.No.ToString("D"))
				{
					flowInstance.F_IsFinish = 3;
				}
				else if (!string.IsNullOrEmpty(res))
				{
					flowInstance.F_PreviousId = flowInstance.F_ActivityId;
					flowInstance.F_ActivityId = wfruntime.nextNodeId;
					flowInstance.F_ActivityType = wfruntime.nextNodeType;
					flowInstance.F_ActivityName = wfruntime.nextNode.name;
					flowInstance.F_IsFinish = (wfruntime.nextNodeType == 4 ? 1 : 0);
					flowInstance.F_MakerList = wfruntime.nextNodeType == 4 ? "" : GetNextMakers(wfruntime, request);
					await AddTransHistory(wfruntime);
				}
				else
				{
					//会签过程中，需要更新用户
					flowInstance.F_MakerList = GetForkNodeMakers(wfruntime, wfruntime.currentNodeId);
					await AddTransHistory(wfruntime);
				}
			}

			#endregion 会签

			#region 一般审核

			else
			{
				wfruntime.MakeTagNode(wfruntime.currentNodeId, tag);
				if (tag.Taged == (int)TagState.Ok)
				{
                    var roleIds = user.RoleId.Split(',');
                    if (wfruntime.currentNode.setInfo.NodeDesignate == Setinfo.MORE_USER_MANAGER && roleIds.Intersect(wfruntime.currentNode.setInfo.NodeDesignateData.roles).Count() == 0)
                    {
                        flowInstance.F_MakerList = GetNodeMarkers(wfruntime.currentNode);
                    }
                    else
                    {
                        flowInstance.F_PreviousId = flowInstance.F_ActivityId;
                        flowInstance.F_ActivityId = wfruntime.nextNodeId;
                        flowInstance.F_ActivityType = wfruntime.nextNodeType;
                        flowInstance.F_ActivityName = wfruntime.nextNode.name;
                        flowInstance.F_IsFinish = (wfruntime.nextNodeType == 4 ? 1 : 0);
                        flowInstance.F_MakerList = (wfruntime.GetNextNodeType() != 4 ? GetNextMakers(wfruntime, request) : "");
                    }
                    await AddTransHistory(wfruntime);
                }
                else
				{
					flowInstance.F_IsFinish = 3; //表示该节点不同意
				}
				flowInstanceOperationHistory.F_Content = "【" + wfruntime.currentNode.name
														   + "】【" + DateTime.Now.ToString("yyyy-MM-dd HH:mm")
														   + "】" + (tag.Taged == 1 ? "同意" : "不同意") + ",备注："
														   + tag.Description;
			}

			#endregion 一般审核

			wfruntime.RemoveNode(wfruntime.nextNodeId);
			flowInstance.F_SchemeContent = wfruntime.ToSchemeObj().ToJson();
            var formDic = request.F_FrmData.ToObject<Dictionary<string, object>>();
            var oldformDic = flowInstance.F_FrmData.ToObject<Dictionary<string, object>>();
            foreach (var item in oldformDic)
                if (!formDic.ContainsKey(item.Key))
                    formDic.Add(item.Key, item.Value);
            if (flowInstance.F_FrmType == 1)
            {
                var path = AppDomain.CurrentDomain.RelativeSearchPath ?? AppDomain.CurrentDomain.BaseDirectory;
                var referencedAssemblies = Directory.GetFiles(path, "*.dll").Select(Assembly.LoadFrom).ToArray();
                var t = referencedAssemblies
                    .SelectMany(a => a.GetTypes().Where(t => t.FullName.Contains("HT.Cloud.Service.") && t.FullName.Contains("." + flowInstance.F_DbName + "Service"))).First();
                ICustomerForm icf = (ICustomerForm)GlobalContext.GetRequiredService(t);
                flowInstance.F_FrmData = formDic.ToJson();
                await icf.Edit(flowInstance.F_Id, flowInstance.F_FrmData);
            }
            else
            {
                if (!string.IsNullOrEmpty(flowInstance.F_DbName))
                {
                    formDic.TryAdd("F_LastModifyUserId", this.currentuser.UserId);
                    formDic.TryAdd("F_LastModifyTime", DateTime.Now);
                    formDic.TryAdd("F_LastModifyUserName", this.currentuser.UserName);
                    flowInstance.F_FrmData = formDic.ToJson();
                    var data = repository.Db.DbMaintenance.GetColumnInfosByTableName(flowInstance.F_DbName, false);
                    List<string> oldID = formDic.Keys.ToList();//原来数据（原来ID）
                    List<string> newID = data.Select(a => a.DbColumnName).ToList();//新增数据（新ID）
                    foreach (var item in oldID.Except(newID))
                        formDic.Remove(item);
                    await repository.Db.Updateable(formDic).AS(flowInstance.F_DbName).WhereColumns(data.FirstOrDefault(a => a.IsPrimarykey).DbColumnName).ExecuteCommandAsync();
                }
            }
            await repository.Update(flowInstance);
            flowInstanceOperationHistory.F_FrmData = flowInstance.F_FrmData;
			await repository.Db.Updateable(flowInstance).IgnoreColumns(ignoreAllNullColumns: true).ExecuteCommandAsync();
			await repository.Db.Insertable(flowInstanceOperationHistory).ExecuteCommandAsync();
			MessageEntity msg = new MessageEntity();
			msg.F_CreatorUserName = currentuser.UserName;
			msg.F_EnabledMark = true;
			if (flowInstance.F_IsFinish == 1)
			{
				msg.F_MessageInfo = flowInstance.F_CustomName + "--流程已完成";
				var module = repository.Db.Queryable<ModuleEntity>().First(a => a.F_EnCode == className);
				msg.F_Href = module.F_UrlAddress;
				msg.F_HrefTarget = module.F_Target;
				msg.F_ToUserId = flowInstance.F_CreatorUserId;
				msg.F_ClickRead = true;
				msg.F_KeyValue = flowInstance.F_Id;
			}
			else if (flowInstance.F_IsFinish == 3)
			{
				msg.F_MessageInfo = flowInstance.F_CustomName + "--流程已终止";
				var module = repository.Db.Queryable<ModuleEntity>().First(a => a.F_EnCode == className);
				msg.F_Href = module.F_UrlAddress;
				msg.F_HrefTarget = module.F_Target;
				var makerList = repository.Db.Queryable<FlowInstanceOperationHistory>().Where(a => a.F_InstanceId == flowInstance.F_Id && a.F_CreatorUserId != currentuser.UserId).Select(a => a.F_CreatorUserId).Distinct().ToList();
				msg.F_ToUserId = flowInstance.F_CreatorUserId;
				msg.F_ClickRead = true;
				msg.F_KeyValue = flowInstance.F_Id;
			}
			else
			{
				msg.F_MessageInfo = flowInstance.F_CustomName + "--流程待处理";
				var module = repository.Db.Queryable<ModuleEntity>().First(a => a.F_EnCode == className);
				msg.F_Href = module.F_UrlAddress.Remove(module.F_UrlAddress.Length - 5, 5) + "ToDoFlow";
				msg.F_HrefTarget = module.F_Target;
				msg.F_ToUserId = flowInstance.F_MakerList == "1" ? "" : flowInstance.F_MakerList;
				msg.F_ClickRead = false;
				msg.F_KeyValue = flowInstance.F_Id;
			}
			msg.F_MessageType = 2;
			var lastmsg = repository.Db.Queryable<MessageEntity>().Where(a => a.F_ClickRead == false && a.F_KeyValue == flowInstance.F_Id).OrderBy(a => a.F_CreatorTime, OrderByType.Desc).First();
			if (lastmsg != null && !await repository.Db.Queryable<MessageHistoryEntity>().Where(a => a.F_MessageId == lastmsg.F_Id).AnyAsync())
			{
				await messageApp.ReadMsgForm(lastmsg.F_Id);
			}
			await messageApp.SubmitForm(msg);
			repository.Db.Ado.CommitTran();

			wfruntime.NotifyThirdParty(_httpClientFactory.CreateClient(), tag);
			return true;
		}

		//会签时，获取一条会签分支上面是否有用户可审核的节点
		private string GetOneForkLineCanCheckNodeId(FlowNode fromForkStartNode, FlowRuntime wfruntime, Tag tag)
		{
			string canCheckId = "";
			var node = fromForkStartNode;
			do  //沿一条分支线路执行，直到遇到会签结束节点
			{
				var makerList = GetNodeMarkers(node);

				if (node.setInfo.Taged == null && !string.IsNullOrEmpty(makerList) && makerList.Split(',').Any(one => tag.UserId == one))
				{
					canCheckId = node.id;
					break;
				}

				node = wfruntime.GetNextNode(node.id);
			} while (node.type != FlowNode.JOIN);

			return canCheckId;
		}

		/// <summary>
		/// 寻找下一步的执行人
		/// 一般用于本节点审核完成后，修改流程实例的当前执行人，可以做到通知等功能
		/// </summary>
		/// <returns></returns>
		private string GetNextMakers(FlowRuntime wfruntime, NodeDesignateEntity request = null)
		{
			string makerList = "";
			if (wfruntime.nextNodeId == "-1")
			{
				throw (new Exception("无法寻找到下一个节点"));
			}
			if (wfruntime.nextNodeType == 0)//如果是会签节点
			{
				makerList = GetForkNodeMakers(wfruntime, wfruntime.nextNodeId);
			}
			else if (wfruntime.nextNode.setInfo.NodeDesignate == Setinfo.RUNTIME_SPECIAL_ROLE)
			{ //如果是运行时指定角色
				if (wfruntime.nextNode.setInfo.NodeDesignate != request.NodeDesignateType)
				{
					throw new Exception("前端提交的节点权限类型异常，请检查流程");
				}
				var users = new List<string>();
				foreach (var item in request.NodeDesignates)
				{
					var temps = repository.Db.Queryable<UserEntity>().Where(a => a.F_RoleId.Contains(item) && a.F_EnabledMark == true && a.F_DeleteMark == false).Select(a => a.F_Id).ToList();
					if (temps != null && temps.Count > 0)
					{
						users.AddRange(temps);
					}
				}
				makerList = JsonHelper.ArrayToString(users.Distinct().ToList(), makerList);
			}
			else if (wfruntime.nextNode.setInfo.NodeDesignate == Setinfo.RUNTIME_SPECIAL_USER)
			{  //如果是运行时指定用户
				if (wfruntime.nextNode.setInfo.NodeDesignate != request.NodeDesignateType)
				{
					throw new Exception("前端提交的节点权限类型异常，请检查流程");
				}
				makerList = JsonHelper.ArrayToString(request.NodeDesignates, makerList);
			}
			else
			{
				makerList = GetNodeMarkers(wfruntime.nextNode);
				if (string.IsNullOrEmpty(makerList))
				{
					throw (new Exception("无法寻找到节点的审核者,请查看流程设计是否有问题!"));
				}
			}

			return makerList;
		}

		/// <summary>
		/// 获取会签开始节点的所有可执行者
		/// </summary>
		/// <param name="forkNodeId">会签开始节点</param>
		/// <returns></returns>
		private string GetForkNodeMakers(FlowRuntime wfruntime, string forkNodeId)
		{
			string makerList = "";
			foreach (string fromForkStartNodeId in wfruntime.FromNodeLines[forkNodeId].Select(u => u.to))
			{
				var fromForkStartNode = wfruntime.Nodes[fromForkStartNodeId]; //与会前开始节点直接连接的节点
				if (makerList != "")
				{
					makerList += ",";
				}

				makerList += GetOneForkLineMakers(fromForkStartNode, wfruntime);
			}

			return makerList;
		}

		//获取会签一条线上的审核者,该审核者应该是已审核过的节点的下一个人
		private string GetOneForkLineMakers(FlowNode fromForkStartNode, FlowRuntime wfruntime)
		{
			string markers = "";
			var node = fromForkStartNode;
			do  //沿一条分支线路执行，直到遇到第一个没有审核的节点
			{
				if (node.setInfo != null && node.setInfo.Taged != null)
				{
					if (node.type != FlowNode.FORK && node.setInfo.Taged != (int)TagState.Ok)  //如果节点是不同意或驳回，则不用再找了
					{
						break;
					}
					node = wfruntime.GetNextNode(node.id);  //下一个节点
					continue;
				}
				var marker = GetNodeMarkers(node);
				if (marker == "")
				{
					throw (new Exception($"节点{node.name}没有审核者,请检查!"));
				}
				if (marker == "1")
				{
					throw (new Exception($"节点{node.name}是会签节点，不能用所有人,请检查!"));
				}

				if (markers != "")
				{
					markers += ",";
				}
				markers += marker;
				break;
			} while (node.type != FlowNode.JOIN);

			return markers;
		}

		/// <summary>
		/// 寻找该节点执行人
		/// </summary>
		/// <param name="node"></param>
		/// <returns></returns>
		private string GetNodeMarkers(FlowNode node)
		{
			string makerList = "";

			if (node.setInfo != null)
			{
				if (node.setInfo.NodeDesignate == Setinfo.ALL_USER)//所有成员
				{
					makerList = "1";
				}
				else if (node.setInfo.NodeDesignate == Setinfo.SPECIAL_USER)//指定成员
				{
					makerList = JsonHelper.ArrayToString(node.setInfo.NodeDesignateData.users, makerList);
				}
				else if (node.setInfo.NodeDesignate == Setinfo.SPECIAL_ROLE)  //指定角色
				{
					List<UserEntity> list = new List<UserEntity>();
					List<string> users = new List<string>();
					foreach (var item in node.setInfo.NodeDesignateData.roles)
					{
						var temp = repository.Db.Queryable<UserEntity>().Where(a => a.F_RoleId.Contains(item)).ToList();
						var tempList = new List<UserEntity>();
						if (node.setInfo.NodeDesignateData.currentDepart)
						{
							var currentDepartment = repository.Db.Queryable<UserEntity>().InSingle(flowCreator).F_OrganizeId.Split(',').ToList();
							foreach (var user in temp)
							{
								var nextCurrentDepartment = user.F_OrganizeId.Split(',').ToList();
								if (TextHelper.IsArrayIntersection(currentDepartment, nextCurrentDepartment))
								{
									tempList.Add(user);
								}
							}
						}
						else
						{
							tempList = temp;
						}
						var tempFinal = tempList.Select(a => a.F_Id).ToList();
						users.AddRange(tempFinal);
					}
					users = users.Distinct().ToList();
					makerList = JsonHelper.ArrayToString(users, makerList);
				}
                else if (node.setInfo.NodeDesignate == Setinfo.DEPARTMENT_MANAGER)//部门负责人
                {
                    var orgs = node.setInfo.NodeDesignateData.orgs;
                    if (node.setInfo.NodeDesignateData.currentDepart)
                    {
                        var temp = repository.Db.Queryable<UserEntity>().InSingle(flowCreator);
                        orgs = temp.F_OrganizeId.Split(',');
                    }
                    var managers = repository.Db.Queryable<OrganizeEntity>().Where(a => orgs.Contains(a.F_Id) && !string.IsNullOrEmpty(a.F_ManagerId)).Select(a => a.F_ManagerId).ToList();
                    makerList = JsonHelper.ArrayToString(managers, makerList);
                }
                else if (node.setInfo.NodeDesignate == Setinfo.USER_MANAGER || node.setInfo.NodeDesignate == Setinfo.MORE_USER_MANAGER)//直属上级、直属上级多级负责人
                {
                    var temp = repository.Db.Queryable<UserEntity>().InSingle(currentuser.UserId);
                    if (temp != null)
                    {
                        makerList = temp.F_ManagerId;
                    }
                }
                else if (node.setInfo.NodeDesignate == Setinfo.RUNTIME_SPECIAL_ROLE || node.setInfo.NodeDesignate == Setinfo.RUNTIME_SPECIAL_USER)
                {
					//如果是运行时选定的用户，则暂不处理。由上个节点审批时选定
				}
			}
			else  //如果没有设置节点信息，默认所有人都可以审核
			{
				makerList = "1";
			}
			return makerList;
		}

		/// <summary>
		/// 判定节点需要选择执行人或执行角色
		/// </summary>
		/// <param name="request"></param>
		/// <exception cref="Exception"></exception>
		private void CheckNodeDesignate(NodeDesignateEntity request)
		{
			if ((request.NodeDesignateType == Setinfo.RUNTIME_SPECIAL_ROLE
				 || request.NodeDesignateType == Setinfo.RUNTIME_SPECIAL_USER) && request.NodeDesignates.Length == 0)
			{
				throw new Exception("下个节点需要选择执行人或执行角色");
			}
		}

		/// <summary>
		/// 返回用于处理流程节点
		/// </summary>
		/// <param name="id"></param>
		/// <returns></returns>
		public async Task<FlowinstanceEntity> GetForVerification(string id)
		{
			var flowinstance = await GetForm(id);
			var runtime = new FlowRuntime(flowinstance);
			if (runtime.nextNodeType != -1 && runtime.nextNode != null && runtime.nextNode.setInfo != null && runtime.nextNodeType != 4)
			{
				flowinstance.NextNodeDesignateType = runtime.nextNode.setInfo.NodeDesignate;
				if (flowinstance.NextNodeDesignateType == Setinfo.SPECIAL_USER)
				{
					flowinstance.NextNodeDesignates = runtime.nextNode.setInfo.NodeDesignateData.users;
					flowinstance.NextMakerName = string.Join(',', repository.Db.Queryable<UserEntity>().Where(a => flowinstance.NextNodeDesignates.Contains(a.F_Id)).Select(a => a.F_RealName).ToList());
				}
				else if (flowinstance.NextNodeDesignateType == Setinfo.SPECIAL_ROLE)
				{
					flowinstance.NextNodeDesignates = runtime.nextNode.setInfo.NodeDesignateData.roles;
					List<UserEntity> list = new List<UserEntity>();
					List<string> users = new List<string>();
					foreach (var item in flowinstance.NextNodeDesignates)
					{
						var temp = repository.Db.Queryable<UserEntity>().Where(a => a.F_RoleId.Contains(item)).ToList();
						var tempList = new List<UserEntity>();
						if (runtime.nextNode.setInfo.NodeDesignateData.currentDepart)
						{
                            var currentDepartment = repository.Db.Queryable<UserEntity>().InSingle(flowinstance.F_CreatorUserId).F_OrganizeId.Split(',').ToList();
                            foreach (var user in temp)
							{
								var nextCurrentDepartment = user.F_OrganizeId.Split(',').ToList();
								if (TextHelper.IsArrayIntersection(currentDepartment, nextCurrentDepartment))
								{
									tempList.Add(user);
								}
							}
						}
						else
						{
							tempList = temp;
						}
						var tempFinal = tempList.Select(a => a.F_Id).ToList();
						users.AddRange(tempFinal);
					}
					users = users.Distinct().ToList();
					flowinstance.NextMakerName = string.Join(',', repository.Db.Queryable<UserEntity>().Where(a => users.Contains(a.F_Id)).Select(a => a.F_RealName).ToList());
				}
                else if (flowinstance.NextNodeDesignateType == Setinfo.DEPARTMENT_MANAGER)//部门负责人
                {
                    var orgs = runtime.nextNode.setInfo.NodeDesignateData.orgs;
                    if (runtime.nextNode.setInfo.NodeDesignateData.currentDepart)
                    {
                        var userEntity = repository.Db.Queryable<UserEntity>().InSingle(flowinstance.F_CreatorUserId);
                        orgs = userEntity.F_OrganizeId.Split(',');
                    }
                    var departments = repository.Db.Queryable<OrganizeEntity>().Where(a => orgs.Contains(a.F_Id) && !string.IsNullOrEmpty(a.F_ManagerId)).Select(a => a.F_ManagerId).ToList();
                    var departmentNames = repository.Db.Queryable<UserEntity>().Where(a => departments.Contains(a.F_Id)).Select(a => a.F_RealName).ToList();
                    flowinstance.NextMakerName = string.Join(',', departmentNames);
                }
                else if (flowinstance.NextNodeDesignateType == Setinfo.USER_MANAGER || flowinstance.NextNodeDesignateType == Setinfo.MORE_USER_MANAGER)//直属上级、直属上级多级负责人
                {
                    var userEntity = repository.Db.Queryable<UserEntity>().InSingle(currentuser.UserId);
                    if (userEntity != null)
                    {
                        var manager = repository.Db.Queryable<UserEntity>().InSingle(userEntity.F_ManagerId);
                        flowinstance.NextMakerName = manager?.F_RealName;
                    }
                }
            }
            if (runtime.currentNode != null && runtime.currentNode.setInfo != null && runtime.currentNodeType != 4)
			{
				flowinstance.CurrentNodeDesignateType = runtime.currentNode.setInfo.NodeDesignate;
                var roles = runtime.currentNode.setInfo.NodeDesignateData.roles;
                var currentRoles = currentuser.RoleId.Split(",");
                if (flowinstance.CurrentNodeDesignateType == Setinfo.MORE_USER_MANAGER && currentRoles.Intersect(roles).Count() == 0)
                {
                    var userEntity = repository.Db.Queryable<UserEntity>().InSingle(currentuser.UserId);
                    if (userEntity != null)
                    {
                        var manager = repository.Db.Queryable<UserEntity>().InSingle(userEntity.F_ManagerId);
                        flowinstance.NextMakerName = manager?.F_RealName;
                    }
                }
                if (flowinstance.F_MakerList != "1" && !string.IsNullOrEmpty(flowinstance.F_MakerList))
				{
					var temps = flowinstance.F_MakerList.Split(',');
					flowinstance.CurrentMakerName = string.Join(',', repository.Db.Queryable<UserEntity>().Where(a => temps.Contains(a.F_Id)).Select(a => a.F_RealName).ToList());
				}
				else
				{
					flowinstance.CurrentMakerName = "所有人";
				}
				var formDatas = flowinstance.F_FrmContentData.Split(',');
				var formlist = new List<string>();
				if (runtime.currentNode.setInfo.CanWriteFormItemIds!=null)
					foreach (var item in runtime.currentNode.setInfo.CanWriteFormItemIds)
						formlist.Add(formDatas[item.ToInt()]);
				flowinstance.CanWriteFormItems = formlist.ToArray();
			}
			return flowinstance;
		}

		#endregion 获取各种节点的流程审核者

		#region 提交数据

		/// <summary>
		/// 添加扭转记录
		/// </summary>
		private async Task AddTransHistory(FlowRuntime wfruntime)
		{
			var tag = currentuser;
			await repository.Db.Insertable(new FlowInstanceTransitionHistory
			{
				F_Id = Utils.GuId(),
				F_InstanceId = wfruntime.flowInstanceId,
				F_CreatorUserId = tag.UserId,
				F_CreatorTime = DateTime.Now,
				F_CreatorUserName = tag.UserName,
				F_FromNodeId = wfruntime.currentNodeId,
				F_FromNodeName = wfruntime.currentNode.name,
				F_FromNodeType = wfruntime.currentNodeType,
				F_ToNodeId = wfruntime.nextNodeId,
				F_ToNodeName = wfruntime.nextNode.name,
				F_ToNodeType = wfruntime.nextNodeType,
				F_IsFinish = wfruntime.nextNodeType == 4 ? true : false,
				F_TransitionSate = false
			}).ExecuteCommandAsync();
		}

		/// <summary>
		/// 添加扭转记录
		/// </summary>
		private async Task AddRejectTransHistory(FlowRuntime wfruntime, FlowRuntime prruntime)
		{
			var tag = currentuser;
			await repository.Db.Insertable(new FlowInstanceTransitionHistory
			{
				F_Id = Utils.GuId(),
				F_InstanceId = wfruntime.flowInstanceId,
				F_CreatorUserId = tag.UserId,
				F_CreatorTime = DateTime.Now,
				F_CreatorUserName = tag.UserName,
				F_FromNodeId = wfruntime.currentNodeId,
				F_FromNodeName = wfruntime.currentNode.name,
				F_FromNodeType = wfruntime.currentNodeType,
				F_ToNodeId = prruntime.currentNodeId,
				F_ToNodeName = prruntime.currentNode.name,
				F_ToNodeType = prruntime.currentNodeType,
				F_IsFinish = false,
				F_TransitionSate = false
			}).ExecuteCommandAsync();
		}

		public async Task Verification(VerificationExtend entity)
		{
			bool isReject = TagState.Reject.Equals((TagState)Int32.Parse(entity.F_VerificationFinally));
			if (isReject)  //驳回
			{
				await NodeReject(entity);
			}
			else
			{
				await NodeVerification(entity);
			}
		}

		public async Task CreateInstance(FlowinstanceEntity entity)
		{
			var nodeDesignate = new NodeDesignateEntity();
			nodeDesignate.NodeDesignates = entity.NextNodeDesignates;
			nodeDesignate.NodeDesignateType = entity.NextNodeDesignateType;
			CheckNodeDesignate(nodeDesignate);
			entity.F_EnabledMark = true;
			FlowschemeEntity scheme = null;
			if (!string.IsNullOrEmpty(entity.F_SchemeId))
			{
				scheme = await repository.Db.Queryable<FlowschemeEntity>().InSingleAsync(entity.F_SchemeId);
			}
			if (scheme == null)
			{
				throw new Exception("该流程模板已不存在，请重新设计流程");
			}
			entity.F_SchemeContent = scheme.F_SchemeContent;
			var form = await repository.Db.Queryable<FormEntity>().InSingleAsync(scheme.F_FrmId);
			if (form == null)
			{
				throw new Exception("该流程模板对应的表单已不存在，请重新设计流程");
			}

			entity.F_FrmContentData = form.F_ContentData;
			entity.F_FrmContent = form.F_Content;
			entity.F_FrmContentParse = form.F_ContentParse;
			entity.F_FrmType = form.F_FrmType;
			entity.F_FrmId = form.F_Id;
			Dictionary<string, string> dic = JsonHelper.ToObject<Dictionary<string, string>>(entity.F_FrmData);
			if (!dic.ContainsKey("申请人"))
			{
				dic.Add("申请人", currentuser.UserId);
			}
			if (!dic.ContainsKey("所属部门"))
			{
				dic.Add("所属部门", currentuser.OrganizeId);
			}
			entity.F_FrmData = dic.ToJson();
			entity.F_InstanceSchemeId = "";
			entity.F_DbName = form.F_WebId;
			if (entity.F_FrmType ==0)
				entity.F_DbName = form.F_DbName;
			entity.F_FlowLevel = 0;
			entity.Create();
			flowCreator = currentuser.UserId;
			//创建运行实例
			var wfruntime = new FlowRuntime(entity);
			var user = currentuser;

			#region 根据运行实例改变当前节点状态

			entity.F_ActivityId = wfruntime.nextNodeId;
			entity.F_ActivityType = wfruntime.GetNextNodeType();
			entity.F_ActivityName = wfruntime.nextNode.name;
			entity.F_PreviousId = wfruntime.currentNodeId;
			entity.F_CreatorUserName = user.UserName;
			entity.F_MakerList = (wfruntime.GetNextNodeType() != 4 ? GetNextMakers(wfruntime, nodeDesignate) : "");
			entity.F_IsFinish = (wfruntime.GetNextNodeType() == 4 ? 1 : 0);
			repository.Db.Ado.BeginTran();

			wfruntime.flowInstanceId = entity.F_Id;
			//复杂表单提交
			if (entity.F_FrmType == 1)
			{
				var path = AppDomain.CurrentDomain.RelativeSearchPath ?? AppDomain.CurrentDomain.BaseDirectory;
				var referencedAssemblies = Directory.GetFiles(path, "*.dll").Select(Assembly.LoadFrom).ToArray();
				var t = referencedAssemblies
					.SelectMany(a => a.GetTypes().Where(t => t.FullName.Contains("HT.Cloud.Service.") && t.FullName.Contains("." + entity.F_DbName + "Service"))).First();
				ICustomerForm icf = (ICustomerForm)GlobalContext.GetRequiredService(t);
				await icf.Add(entity.F_Id, entity.F_FrmData);
			}
			else
			{
				if (!string.IsNullOrEmpty(entity.F_DbName))
				{
					var formDic = entity.F_FrmData.ToObject<Dictionary<string, object>>();
                    formDic.TryAdd("F_CreatorUserId", this.currentuser.UserId);
                    formDic.TryAdd("F_CreatorTime", DateTime.Now);
                    formDic.TryAdd("F_CreatorUserName", this.currentuser.UserName);
                    formDic.TryAdd("F_Id", Utils.GuId());
                    entity.F_FrmData = formDic.ToJson();
                    var data = repository.Db.DbMaintenance.GetColumnInfosByTableName(entity.F_DbName, false);
                    List<string> oldID = formDic.Keys.ToList();//原来数据（原来ID）
                    List<string> newID = data.Select(a => a.DbColumnName).ToList();//新增数据（新ID）
                    foreach (var item in oldID.Except(newID))
                        formDic.Remove(item);
                    await repository.Db.Insertable(formDic).AS(entity.F_DbName).ExecuteCommandAsync();
				}
			}
			await repository.Db.Insertable(entity).ExecuteCommandAsync();

			#endregion 根据运行实例改变当前节点状态

			#region 流程操作记录

			FlowInstanceOperationHistory processOperationHistoryEntity = new FlowInstanceOperationHistory
			{
				F_Id = Utils.GuId(),
				F_InstanceId = entity.F_Id,
				F_CreatorUserId = entity.F_CreatorUserId,
				F_CreatorUserName = entity.F_CreatorUserName,
				F_CreatorTime = entity.F_CreatorTime,
				F_FrmData = entity.F_FrmData,
				F_Content = "【创建】"
						  + entity.F_CreatorUserName
						  + "创建了一个流程【"
						  + entity.F_Code + "/"
						  + entity.F_CustomName + "】"
			};
			await repository.Db.Insertable(processOperationHistoryEntity).ExecuteCommandAsync();

			#endregion 流程操作记录

			await AddTransHistory(wfruntime);

			MessageEntity msg = new MessageEntity();
			msg.F_CreatorUserName = currentuser.UserName;
			msg.F_EnabledMark = true;
			if (entity.F_IsFinish == 1)
			{
				msg.F_MessageInfo = entity.F_CustomName + "--流程已完成";
				var module = repository.Db.Queryable<ModuleEntity>().First(a => a.F_EnCode == className);
				msg.F_Href = module.F_UrlAddress;
				msg.F_HrefTarget = module.F_Target;
				msg.F_ClickRead = true;
				msg.F_KeyValue = entity.F_Id;
			}
			else if (entity.F_IsFinish == 3)
			{
				msg.F_MessageInfo = entity.F_CustomName + "--流程已终止";
				var module = repository.Db.Queryable<ModuleEntity>().First(a => a.F_EnCode == className);
				msg.F_Href = module.F_UrlAddress;
				msg.F_HrefTarget = module.F_Target;
				var makerList = repository.Db.Queryable<FlowInstanceOperationHistory>().Where(a => a.F_InstanceId == entity.F_Id && a.F_CreatorUserId != currentuser.UserId).Select(a => a.F_CreatorUserId).Distinct().ToList();
				msg.F_ToUserId = entity.F_CreatorUserId;
				msg.F_ClickRead = true;
				msg.F_KeyValue = entity.F_Id;
			}
			else
			{
				msg.F_MessageInfo = entity.F_CustomName + "--流程待处理";
				var module = repository.Db.Queryable<ModuleEntity>().First(a => a.F_EnCode == className);
				msg.F_Href = module.F_UrlAddress.Remove(module.F_UrlAddress.Length - 5, 5) + "ToDoFlow";
				msg.F_HrefTarget = module.F_Target;
				msg.F_ClickRead = false;
				msg.F_KeyValue = entity.F_Id;
			}
			msg.F_MessageType = 2;
			msg.F_ToUserId = entity.F_MakerList == "1" ? "" : entity.F_MakerList;
			var lastmsg = repository.Db.Queryable<MessageEntity>().Where(a => a.F_ClickRead == false && a.F_KeyValue == entity.F_Id).OrderBy(a => a.F_CreatorTime, OrderByType.Desc).First();
			if (lastmsg != null && !await repository.Db.Queryable<MessageHistoryEntity>().Where(a => a.F_MessageId == lastmsg.F_Id).AnyAsync())
			{
				await messageApp.ReadMsgForm(lastmsg.F_Id);
			}
			await messageApp.SubmitForm(msg);
			repository.Db.Ado.CommitTran();
		}

		public async Task UpdateInstance(FlowinstanceEntity entity)
		{
			var nodeDesignate = new NodeDesignateEntity();
			nodeDesignate.NodeDesignates = entity.NextNodeDesignates;
			nodeDesignate.NodeDesignateType = entity.NextNodeDesignateType;
			CheckNodeDesignate(nodeDesignate);
			FlowschemeEntity scheme = null;
			if (!string.IsNullOrEmpty(entity.F_SchemeId))
			{
				scheme = await repository.Db.Queryable<FlowschemeEntity>().InSingleAsync(entity.F_SchemeId);
			}
			if (scheme == null)
			{
				throw new Exception("该流程模板已不存在，请重新设计流程");
			}
			entity.F_SchemeContent = scheme.F_SchemeContent;
			var form = await repository.Db.Queryable<FormEntity>().InSingleAsync(scheme.F_FrmId);
			if (form == null)
			{
				throw new Exception("该流程模板对应的表单已不存在，请重新设计流程");
			}
			Dictionary<string, string> dic = JsonHelper.ToObject<Dictionary<string, string>>(entity.F_FrmData);
			if (!dic.ContainsKey("申请人"))
			{
				dic.Add("申请人", currentuser.UserId);
			}
			if (!dic.ContainsKey("所属部门"))
			{
				dic.Add("所属部门", currentuser.OrganizeId);
			}
			entity.F_FrmData = dic.ToJson();
			var oldEntity = await repository.FindEntity(entity.F_Id);
            var wfruntime = new FlowRuntime(oldEntity);
			entity.F_FrmContentData = form.F_ContentData;
			entity.F_FrmContentParse = form.F_ContentParse;
			entity.F_FrmType = form.F_FrmType;
			entity.F_FrmId = form.F_Id;
			entity.F_InstanceSchemeId = "";
			entity.F_DbName = form.F_WebId;
			if (entity.F_FrmType == 0)
				entity.F_DbName = form.F_DbName;
			entity.F_FlowLevel = 0;
			flowCreator = currentuser.UserId;
			//创建运行实例
			wfruntime = new FlowRuntime(entity);

			var user = currentuser;

			#region 根据运行实例改变当前节点状态

			entity.F_ActivityId = wfruntime.nextNodeId;
			entity.F_ActivityType = wfruntime.GetNextNodeType();
			entity.F_ActivityName = wfruntime.nextNode.name;
			entity.F_PreviousId = wfruntime.currentNodeId;
			entity.F_CreatorUserName = user.UserName;
			entity.F_MakerList = (wfruntime.GetNextNodeType() != 4 ? GetNextMakers(wfruntime, nodeDesignate) : "");
			entity.F_IsFinish = (wfruntime.GetNextNodeType() == 4 ? 1 : 0);
            var formDic = entity.F_FrmData.ToObject<Dictionary<string, object>>();
            var oldformDic = oldEntity.F_FrmData.ToObject<Dictionary<string, object>>();
            foreach (var item in oldformDic)
                if (!formDic.ContainsKey(item.Key))
                    formDic.Add(item.Key, item.Value);
            repository.Db.Ado.BeginTran();
			wfruntime.flowInstanceId = entity.F_Id;
			//复杂表单提交
			if (entity.F_FrmType == 1)
			{
				var path = AppDomain.CurrentDomain.RelativeSearchPath ?? AppDomain.CurrentDomain.BaseDirectory;
				var referencedAssemblies = Directory.GetFiles(path, "*.dll").Select(Assembly.LoadFrom).ToArray();
				var t = referencedAssemblies
					.SelectMany(a => a.GetTypes().Where(t => t.FullName.Contains("HT.Cloud.Service.") && t.FullName.Contains("." + entity.F_DbName + "Service"))).First();
				ICustomerForm icf = (ICustomerForm)GlobalContext.GetRequiredService(t);
                entity.F_FrmData = formDic.ToJson();
                await icf.Edit(entity.F_Id, formDic.ToJson());
			}
			else
			{
				if (!string.IsNullOrEmpty(entity.F_DbName))
				{
                    formDic.TryAdd("F_LastModifyUserId", this.currentuser.UserId);
                    formDic.TryAdd("F_LastModifyTime", DateTime.Now);
                    formDic.TryAdd("F_LastModifyUserName", this.currentuser.UserName);
                    entity.F_FrmData = formDic.ToJson();
                    var data = repository.Db.DbMaintenance.GetColumnInfosByTableName(entity.F_DbName, false);
                    List<string> oldID = formDic.Keys.ToList();//原来数据（原来ID）
                    List<string> newID = data.Select(a => a.DbColumnName).ToList();//新增数据（新ID）
                    foreach (var item in oldID.Except(newID))
                        formDic.Remove(item);
                    await repository.Db.Updateable(formDic).AS(entity.F_DbName).WhereColumns(data.FirstOrDefault(a=>a.IsPrimarykey).DbColumnName).ExecuteCommandAsync();
				}
			}
			await repository.Db.Updateable(entity).IgnoreColumns(ignoreAllNullColumns: true).ExecuteCommandAsync();

			#endregion 根据运行实例改变当前节点状态

			#region 流程操作记录

			FlowInstanceOperationHistory processOperationHistoryEntity = new FlowInstanceOperationHistory
			{
				F_Id = Utils.GuId(),
				F_InstanceId = entity.F_Id,
				F_CreatorUserId = user.UserId,
				F_CreatorUserName = entity.F_CreatorUserName,
				F_CreatorTime = DateTime.Now,
				F_FrmData= entity.F_FrmData,
				F_Content = "【修改】"
						  + entity.F_CreatorUserName
						  + "修改了一个流程【"
						  + entity.F_Code + "/"
						  + entity.F_CustomName + "】"
			};
			await repository.Db.Insertable(processOperationHistoryEntity).ExecuteCommandAsync();

			#endregion 流程操作记录

			await AddTransHistory(wfruntime);

			MessageEntity msg = new MessageEntity();
			msg.F_CreatorUserName = currentuser.UserName;
			msg.F_EnabledMark = true;
			if (entity.F_IsFinish == 1)
			{
				msg.F_MessageInfo = entity.F_CustomName + "--流程已完成";
				var module = repository.Db.Queryable<ModuleEntity>().First(a => a.F_EnCode == className);
				msg.F_Href = module.F_UrlAddress;
				msg.F_HrefTarget = module.F_Target;
				msg.F_ClickRead = true;
				msg.F_KeyValue = entity.F_Id;
			}
			else if (entity.F_IsFinish == 3)
			{
				msg.F_MessageInfo = entity.F_CustomName + "--流程已终止";
				var module = repository.Db.Queryable<ModuleEntity>().First(a => a.F_EnCode == className);
				msg.F_Href = module.F_UrlAddress;
				msg.F_HrefTarget = module.F_Target;
				var makerList = repository.Db.Queryable<FlowInstanceOperationHistory>().Where(a => a.F_InstanceId == entity.F_Id && a.F_CreatorUserId != currentuser.UserId).Select(a => a.F_CreatorUserId).Distinct().ToList();
				msg.F_ToUserId = entity.F_CreatorUserId;
				msg.F_ClickRead = true;
				msg.F_KeyValue = entity.F_Id;
			}
			else
			{
				msg.F_MessageInfo = entity.F_CustomName + "--流程待处理";
				var module = repository.Db.Queryable<ModuleEntity>().First(a => a.F_EnCode == className);
				msg.F_Href = module.F_UrlAddress.Remove(module.F_UrlAddress.Length - 5, 5) + "ToDoFlow";
				msg.F_HrefTarget = module.F_Target;
				msg.F_ClickRead = false;
				msg.F_KeyValue = entity.F_Id;
			}
			msg.F_MessageType = 2;
			msg.F_ToUserId = entity.F_MakerList == "1" ? "" : entity.F_MakerList;
			var lastmsg = repository.Db.Queryable<MessageEntity>().Where(a => a.F_ClickRead == false && a.F_KeyValue == entity.F_Id).OrderBy(a => a.F_CreatorTime, OrderByType.Desc).First();
			if (lastmsg != null && !await repository.Db.Queryable<MessageHistoryEntity>().Where(a => a.F_MessageId == lastmsg.F_Id).AnyAsync())
			{
				await messageApp.ReadMsgForm(lastmsg.F_Id);
			}
			await messageApp.SubmitForm(msg);
			repository.Db.Ado.CommitTran();
			msg.F_ClickRead = false;
			msg.F_KeyValue = entity.F_Id;
		}

		public async Task DeleteForm(string keyValue)
		{
			var ids = keyValue.Split(',');
			await repository.Update(a => ids.Contains(a.F_Id), a => new FlowinstanceEntity
			{
				F_EnabledMark = false
			});
		}

		public async Task CancleForm(string keyValue)
		{
			var user = currentuser;

			FlowinstanceEntity flowInstance = await GetForm(keyValue);
			flowCreator = flowInstance.F_CreatorUserId;

			FlowRuntime wfruntime = new FlowRuntime(flowInstance);

			string resnode = "";
			resnode = wfruntime.RejectNode("1");

			var tag = new Tag
			{
				Description = "流程撤回",
				Taged = (int)TagState.Reject,
				UserId = user.UserId,
				UserName = user.UserName
			};

			wfruntime.MakeTagNode(wfruntime.currentNodeId, tag);
			flowInstance.F_IsFinish = 2;//2表示撤回（需要申请者重新提交表单）
			repository.Db.Ado.BeginTran();
			if (resnode != "")
			{
				wfruntime.RemoveNode(resnode);
				flowInstance.F_SchemeContent = wfruntime.ToSchemeObj().ToJson();
				flowInstance.F_ActivityId = resnode;
				var prruntime = new FlowRuntime(flowInstance);
				prruntime.MakeTagNode(prruntime.currentNodeId, tag);
				flowInstance.F_PreviousId = prruntime.previousId;
				flowInstance.F_ActivityType = prruntime.GetNodeType(resnode);
				flowInstance.F_ActivityName = prruntime.Nodes[resnode].name;
				if (resnode == wfruntime.startNodeId)
				{
					flowInstance.F_MakerList = flowInstance.F_CreatorUserId;
				}
				else
				{
					flowInstance.F_MakerList = await repository.Db.Queryable<FlowInstanceTransitionHistory>().Where(a => a.F_FromNodeId == resnode && a.F_ToNodeId == prruntime.nextNodeId).OrderBy(a => a.F_CreatorTime, OrderByType.Desc).Select(a => a.F_CreatorUserId).FirstAsync();//当前节点可执行的人信息
				}
				await AddRejectTransHistory(wfruntime, prruntime);
				await repository.Update(flowInstance);
			}
			await repository.Db.Insertable(new FlowInstanceOperationHistory
			{
				F_Id = Utils.GuId(),
				F_InstanceId = keyValue
				,
				F_CreatorUserId = user.UserId
				,
				F_CreatorUserName = user.UserName
				,
				F_CreatorTime = DateTime.Now
				,
				F_FrmData = flowInstance.F_FrmData
				,
				F_Content = "【"
						  + wfruntime.currentNode.name
						  + "】【" + DateTime.Now.ToString("yyyy-MM-dd HH:mm") + "】撤回,备注：流程撤回"
			}).ExecuteCommandAsync();
			repository.Db.Ado.CommitTran();
			wfruntime.NotifyThirdParty(_httpClientFactory.CreateClient(), tag);
		}

		#endregion 提交数据
	}
}