using HH.WMS.Entitys.Autobom; using HH.WMS.Entitys.Basic; using HH.WMS.Entitys.Common; using HW.DAL; using HW.Utility.Data; using System; using System.Collections.Generic; using System.Data; using System.Data.Common; using System.Linq; using System.Text; using System.Threading.Tasks; namespace DataAynchronization.HW.DAL { /// /// 包装规格表数据处理层 /// /// /// [HanHe(XDL)] CREATED 2018/09/08 public class TN_AB_PACK_SPECDAL : BaseDAL { #region 获取包装规格表集合 /// /// 根据表名获取包装规格表集合 /// /// 表名 /// 包装规格集合 /// [HanHe(XDL)] CREATED 2018/09/08 public List GetPackSpecList(string tableName) { string sql = @"SELECT top 500 CN_GUID ,CN_S_ITEM_CODE ,CN_S_PACK_NAME ,CN_S_PACK_NUM ,CN_S_CODE_SUFFIX ,CN_S_STATUS ,CN_S_CREATOR ,CN_S_CREATOR_BY ,S.CN_T_CREATE ,CN_S_MODIFY ,CN_S_MODIFY_BY ,CN_T_MODIFY FROM TN_AB_B_SYNCH_LOG L LEFT JOIN TN_AB_PACK_SPEC S ON L.CN_S_GUID=S.CN_GUID WHERE L.CN_S_TABLE_NAME='" + tableName + "' AND L.CN_N_OP_FLAG IN (1,2)"; DbCommand cmd = DataAccess.GetSqlStringCommand(sql); List list = DataAccessExtensive.ExecuteListEntity(this.DataAccess, cmd, SetEntity); return list; } /// /// 设置实体的各列 /// private void SetEntity(TN_AB_PACK_SPECEntity entity, IDataReader reader) { SetEntityUti(entity, "CN_GUID", "CN_GUID", reader); SetEntityUti(entity, "CN_S_ITEM_CODE", "CN_S_ITEM_CODE", reader); SetEntityUti(entity, "CN_S_PACK_NAME", "CN_S_PACK_NAME", reader); SetEntityUti(entity, "CN_S_PACK_NUM", "CN_S_PACK_NUM", reader); SetEntityUti(entity, "CN_S_CODE_SUFFIX", "CN_S_CODE_SUFFIX", reader); SetEntityUti(entity, "CN_S_STATUS", "CN_S_STATUS", reader); SetEntityUti(entity, "CN_S_CREATOR", "CN_S_CREATOR", reader); SetEntityUti(entity, "CN_S_CREATOR_BY", "CN_S_CREATOR_BY", reader); SetEntityUti(entity, "CN_T_CREATE", "CN_T_CREATE", reader); SetEntityUti(entity, "CN_S_MODIFY", "CN_S_MODIFY", reader); SetEntityUti(entity, "CN_S_MODIFY_BY", "CN_S_MODIFY_BY", reader); SetEntityUti(entity, "CN_T_MODIFY", "CN_T_MODIFY", reader); } #endregion public SqlExecuteResult RemoveSynchLogData(string ArrayGuid) { StringBuilder sb = new StringBuilder(); sb.Append("DELETE FROM TN_AB_B_SYNCH_LOG WHERE CN_S_GUID in (" + ArrayGuid + ")"); DbCommand cmd = DataAccess.GetSqlStringCommand(sb.ToString()); return ExecuteCommand(cmd, null); } } }