using Castle.ActiveRecord; using NHibernate.Criterion; using System; using System.Text; namespace BizCom { [ActiveRecord("CE_ErpDataSendOrderInfo")] public class CeErpDataSendOrderInfo : ComBase { [PrimaryKey(PrimaryKeyType.Native)] public int ID { get; set; } private string _ctid = ""; /// ///订单编号 /// [Property] public string ctid { get { return _ctid; } set { _ctid = value; } } private bool _isSync = false; /// ///是否同步过 /// [Property] public bool isSync { get { return _isSync; } set { _isSync = value; } } private string _errorBack = ""; /// ///失败信息 /// [Property] public string errorBack { get { return _errorBack; } set { _errorBack = value; } } [Property] public DateTime? updateTime { get; set; } private string _dataJson = ""; /// ///信息 /// [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)); } } }