erp/BizCom/Dao/CeErpDataSendOrderInfo.cs

using Castle.ActiveRecord;
using NHibernate.Criterion;
using System;
using System.Text;

namespace BizCom
{
    [ActiveRecord("CE_ErpDataSendOrderInfo")]
    public class CeErpDataSendOrderInfo : ComBase<CeErpDataSendOrderInfo>
    {

        [PrimaryKey(PrimaryKeyType.Native)]
        public int ID { get; set; }

        private string _ctid = "";
        /// <summary>
        ///订单编号
        /// </summary>
        [Property]
        public string ctid
        {
            get { return _ctid; }
            set { _ctid = value; }
        }


        private bool _isSync = false;

        /// <summary>
        ///是否同步过
        /// </summary>
        [Property]
        public bool isSync
        {
            get { return _isSync; }
            set { _isSync = value; }
        }

        private string _errorBack = "";
        /// <summary>
        ///失败信息
        /// </summary>
        [Property]
        public string errorBack
        {
            get { return _errorBack; }
            set { _errorBack = value; }
        }
        [Property]
        public DateTime? updateTime { get; set; }

        private string _dataJson = "";
        /// <summary>
        ///信息
        /// </summary>
        [Property]
        public string dataJson
        {
            get { return _dataJson; }
            set { _dataJson = value; }
        }

        public static CeErpDataSendOrderInfo GetByCtid(string ctid)
        {
            return FindFirst(Expression.Sql(string.Format("ctid='{0}'", ctid)));
        }

        public static void createObject(string ctid)
        {
            if (ctid == null || ctid.Length == 0)
            {
                return;
            }
            CeErpDataSendOrderInfo ceErpDataSendOrderInfo = GetByCtid(ctid);
            if (ceErpDataSendOrderInfo == null)
            {
                ceErpDataSendOrderInfo = new CeErpDataSendOrderInfo();
                ceErpDataSendOrderInfo.ctid = ctid;
                ceErpDataSendOrderInfo.Create();
            }
            else
            {
                ceErpDataSendOrderInfo.isSync = false;
                ceErpDataSendOrderInfo.Update();
            }
        }

        public static void updateAsync(string ctid, string json)
        {
            ExecuteNonQuery(string.Format("update CE_ErpDataSendOrderInfo set isSync=1,dataJson='{1}',errorBack='',updateTime=GETDATE() where ctid='{0}'", ctid, json));
        }

        public static void updateError(string ctid, string errmsg, string json)
        {
            ExecuteNonQuery(string.Format("update CE_ErpDataSendOrderInfo set errorBack='{1}',dataJson='{2}',updateTime=GETDATE() where ctid='{0}'", ctid, errmsg, json));
        }
    }
}