迁移至svn

zhao

2021-07-19 8347f2fbddbd25369359dcb2da1233ac48a19fdc

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
using HH.WMS.Entitys.Algorithm;
using HH.WMS.Entitys.Basic;
using HH.WMS.Entitys.Common;
using HW.DAL;
using System;
using System.Collections.Generic;
using System.Linq;
using System.Text;
 
namespace HW.BLL
{
    /// <summary>
    /// 同步记录表业务逻辑层
    /// </summary>
    /// <returns></returns>
    /// <history>[HanHe(XDL)] CREATED 2018/06/12</history>
    public class TN_AB_B_SYNCH_LOGBLL : BaseBLL
    {
        #region 根据表名获取同步记录集合
        /// <summary>
        /// 根据表名获取同步记录集合
        /// </summary>
        /// <param name="tableName">表名</param>
        /// <returns>同步记录集合</returns>
        /// <history>[HanHe(XDL)] CREATED 2018/06/12</history>
        public List<TN_AB_B_SYNCH_LOGEntity> GetsynchLogList(string tableName)
        {
            return CreateDAL<TN_AB_B_SYNCH_LOGDAL>().GetsynchLogList(tableName);
        }
        #endregion
 
        #region 获取需要删除的数据
        /// <summary>
        /// 获取需要删除的数据
        /// </summary>
        /// <returns></returns>
        /// <history>[HanHe(XDL)] CREATED 2018/06/13</history>
        public List<TN_AB_B_SYNCH_LOGEntity> GetRemoveDataList()
        {
            return CreateDAL<TN_AB_B_SYNCH_LOGDAL>().GetRemoveDataList();
        }
        #endregion
 
        #region 根据仓库编码删除
        /// <summary>
        /// 根据仓库编码删除
        /// </summary>
        /// <typeparam name="T"></typeparam>
        /// <param name="fieldValue">字段值</param>
        /// <param name="fieldName">字段名称</param>
        /// <param name="collectionName">表名</param>
        /// <returns></returns>
        /// <history>[HanHe(XDL)] CREATED 2018/06/13</history>
        public bool RemoveDataByCode<T>(string fieldValue, string fieldName, string collectionName)
        {
            return CreateDAL<TN_AB_B_SYNCH_LOGDAL>().RemoveDataByCode<T>(fieldValue, fieldName, collectionName);
        }
        #endregion
 
        #region 删除中间表标识为已删除的数据
        /// <summary>
        /// 删除中间表标识为已删除的数据
        /// </summary>
        /// <param name="stockRemoveList"></param>
        /// <param name="tableName"></param>
        /// <history>[HanHe(XDL)] CREATED 2018/06/13</history>
        public SqlExecuteResult RemoveData(List<TN_AB_B_SYNCH_LOGEntity> stockRemoveList, string tableName)
        {
           return CreateDAL<TN_AB_B_SYNCH_LOGDAL>().RemoveData(stockRemoveList, tableName);
        }
        #endregion
 
        #region 判断mongo中是否存在该条记录
        /// <summary>
        /// 判断mongo中是否存在该条记录
        /// </summary>
        /// <typeparam name="T"></typeparam>
        /// <param name="fieldValue">字段值</param>
        /// <param name="fieldName">字段名称</param>
        /// <param name="collectionName">表名</param>
        /// <returns></returns>
        /// <history>[HanHe(XDL)] CREATED 2018/06/13</history>
        public bool IsExistsMongo<T>(string fieldValue, string fieldName, string collectionName)
        {
            return CreateDAL<TN_AB_B_SYNCH_LOGDAL>().IsExistsMongo<T>(fieldValue, fieldName, collectionName);
        }
        #endregion
 
        #region 新增一个集合到mongo数据库
        /// <summary>
        /// 新增一个集合到mongo数据库
        /// </summary>
        /// <typeparam name="T">实体类</typeparam>
        /// <param name="lstEntity">实体类集合数据</param>
        /// <param name="CollectionName">对象名称</param>
        /// <returns></returns>
        /// <history>[HanHe(XDL)] CREATED 2018/06/13</history>
        public bool AddList<T>(List<T> lstEntity, string collectionName)
        {
            return CreateDAL<TN_AB_B_SYNCH_LOGDAL>().AddList<T>(lstEntity, collectionName);
        }
        #endregion
 
        #region 删除已同步数据
        /// <summary>
        /// 删除已同步数据
        /// </summary>
        /// <param name="tableName">集合名称</param>
        /// <returns></returns>
        public SqlExecuteResult RemoveSynchLogData(string tableName)
        {
            return CreateDAL<TN_AB_B_SYNCH_LOGDAL>().RemoveSynchLogData(tableName);
        }
        #endregion
 
        public List<TN_AB_B_SYNCH_LOGEntity> GetSynchDataList()
        {
            return CreateDAL<TN_AB_B_SYNCH_LOGDAL>().GetSynchDataList();
        }
 
        public void ClearMongo(string date)
        {
            CreateDAL<TN_AB_B_SYNCH_LOGDAL>().ClearMongo(date);
        }
 
        public bool ClearMongoCollection(string collectionName)
        {
          return  CreateDAL<TN_AB_B_SYNCH_LOGDAL>().ClearMongoCollection(collectionName);
        }
 
        public bool IsExistsMongoSafty<T>(TN_AB_B_ITEM_SAFETYEntity tN_AB_B_ITEM_SAFETYEntity, string collectionName)
        {
            return CreateDAL<TN_AB_B_SYNCH_LOGDAL>().IsExistsMongoSafty<T>(tN_AB_B_ITEM_SAFETYEntity, collectionName);
        }
 
        public bool RemoveDataByCodeSafty<T>(TN_AB_B_ITEM_SAFETYEntity tN_AB_B_ITEM_SAFETYEntity, string collectionName)
        {
            return CreateDAL<TN_AB_B_SYNCH_LOGDAL>().RemoveDataByCodeSafty<T>(tN_AB_B_ITEM_SAFETYEntity, collectionName);
        }
    }
}