BN089-BS开发框架MVC4版/source20131023/Zephyr.Net/Zephyr.WorkFlow/Engine/BpmContextData.cs

这里只显示每个文件的开头 60 行。登录后可以解锁完整代码。

微信扫码关注公众号，代码整理好后第一时间通知你。

using System;
using System.Collections.Generic;
using System.Collections;
using System.Data;
using System.Reflection;
using Zephyr.Data;

namespace Zephyr.WorkFlow
{
    public partial class BpmContext
    {
        private int save<T>(T model) where T : IModel
        {
            model.UpdateDate = DateTime.Now;
            model.UpdatePerson = _currentActor;
            var rows = _db.Update<T>(typeof(T).Name, model).AutoMap(x => x.Id).Where(x => x.Id).Execute();

            if (rows == 0)
            {
                model.CreateDate = DateTime.Now;
                model.CreatePerson = _currentActor;
            }
            rows = _db.Insert<T>(typeof(T).Name, model).AutoMap(x => x.Id).Execute();

            return rows;
        }

        private wf_processDefinition loadDataProcessDefinition(string processDefinitionName)
        {
            var dataProcessDefinition = _db.Sql(@"
select top 1 * 
from wf_processDefinition 
where name=@0 
order by version desc"
                , processDefinitionName)
                .QuerySingle<wf_processDefinition>();
            return dataProcessDefinition;
        }

        private wf_processDefinition loadDataProcessDefinition(int processDefinitionId)
        {
            var dataProcessDefinition = _db.Sql(@"
select * 
from wf_processDefinition 
where Id=@0 ", processDefinitionId)
                .QuerySingle<wf_processDefinition>();
            return dataProcessDefinition;
        }

        private wf_processInstance loadDataProcessInstance(int processInstanceId)
        {
            var dataProcessInstance = _db.Sql(@"
select * 
from wf_processInstance 
where Id=@0 ", processInstanceId)
             .QuerySingle<wf_processInstance>();

            return dataProcessInstance;
        }