22
schangxiang@126.com
2025-08-23 cea8c2b4129aead2c796153738690b00366c3bb6
22
已添加21个文件
已修改4个文件
1599 ■■■■■ 文件已修改
DEmon/iWareCommon/bin/Debug/iWareCommon.dll 补丁 | 查看 | 原始文档 | blame | 历史
DEmon/iWareCommon/bin/Debug/iWareCommon.pdb 补丁 | 查看 | 原始文档 | blame | 历史
DEmon/iWareCommon/obj/Debug/iWareCommon.dll 补丁 | 查看 | 原始文档 | blame | 历史
DEmon/iWareCommon/obj/Debug/iWareCommon.pdb 补丁 | 查看 | 原始文档 | blame | 历史
DEmon/iWareLog/LOG/Dao/AlertDao.cs 64 ●●●●● 补丁 | 查看 | 原始文档 | blame | 历史
DEmon/iWareLog/LOG/Dao/FailSentMessageDao.cs 64 ●●●●● 补丁 | 查看 | 原始文档 | blame | 历史
DEmon/iWareLog/LOG/Dao/InOutStorageDetailDao.cs 64 ●●●●● 补丁 | 查看 | 原始文档 | blame | 历史
DEmon/iWareLog/LOG/Dao/OperationDao.cs 64 ●●●●● 补丁 | 查看 | 原始文档 | blame | 历史
DEmon/iWareLog/LOG/Dao/ReceiveMsgLogDao.cs 64 ●●●●● 补丁 | 查看 | 原始文档 | blame | 历史
DEmon/iWareLog/LOG/Dao/SendMsgLogDao.cs 64 ●●●●● 补丁 | 查看 | 原始文档 | blame | 历史
DEmon/iWareLog/LOG/Entity/AlertEntity.cs 138 ●●●●● 补丁 | 查看 | 原始文档 | blame | 历史
DEmon/iWareLog/LOG/Entity/FailSentMessageEntity.cs 132 ●●●●● 补丁 | 查看 | 原始文档 | blame | 历史
DEmon/iWareLog/LOG/Entity/InOutStorageDetailEntity.cs 150 ●●●●● 补丁 | 查看 | 原始文档 | blame | 历史
DEmon/iWareLog/LOG/Entity/OperationEntity.cs 138 ●●●●● 补丁 | 查看 | 原始文档 | blame | 历史
DEmon/iWareLog/LOG/Entity/ReceiveMsgLogEntity.cs 113 ●●●●● 补丁 | 查看 | 原始文档 | blame | 历史
DEmon/iWareLog/LOG/Entity/SendMsgLogEntity.cs 115 ●●●●● 补丁 | 查看 | 原始文档 | blame | 历史
DEmon/iWareLog/LOG/EnumType/EInOutStorageType.cs 17 ●●●●● 补丁 | 查看 | 原始文档 | blame | 历史
DEmon/iWareLog/LOG/EnumType/EReceiveType.cs 15 ●●●●● 补丁 | 查看 | 原始文档 | blame | 历史
DEmon/iWareLog/LOG/EnumType/_system~.ini 补丁 | 查看 | 原始文档 | blame | 历史
DEmon/iWareLog/LOG/Service/AlertService.cs 40 ●●●●● 补丁 | 查看 | 原始文档 | blame | 历史
DEmon/iWareLog/LOG/Service/FailSentMessageService.cs 185 ●●●●● 补丁 | 查看 | 原始文档 | blame | 历史
DEmon/iWareLog/LOG/Service/InOutStorageDetailService.cs 36 ●●●●● 补丁 | 查看 | 原始文档 | blame | 历史
DEmon/iWareLog/LOG/Service/OperationService.cs 61 ●●●●● 补丁 | 查看 | 原始文档 | blame | 历史
DEmon/iWareLog/LOG/Service/ReceiveMsgLogService.cs 38 ●●●●● 补丁 | 查看 | 原始文档 | blame | 历史
DEmon/iWareLog/LOG/Service/SendMsgLogService.cs 37 ●●●●● 补丁 | 查看 | 原始文档 | blame | 历史
DEmon/iWareCommon/bin/Debug/iWareCommon.dll
Binary files differ
DEmon/iWareCommon/bin/Debug/iWareCommon.pdb
Binary files differ
DEmon/iWareCommon/obj/Debug/iWareCommon.dll
Binary files differ
DEmon/iWareCommon/obj/Debug/iWareCommon.pdb
Binary files differ
DEmon/iWareLog/LOG/Dao/AlertDao.cs
¶Ô±ÈÐÂÎļþ
@@ -0,0 +1,64 @@
using iWareCommon.Common.Dao;
using iWareLog.LOG.Entity;
using iWareLog.ORM;
using System.Collections.Generic;
using System.Linq;
namespace iWareLog.LOG.Dao
{
    public class AlertDao : CommonDao<AlertEntity, DEVAlert>
    {
         private static object Lock = new object();
         private AlertDao() { }
         private static AlertDao Instance = null;
        /// <summary>
        /// èŽ·å–å•ä¾‹çš„æ–¹æ³•
        /// </summary>
        /// <returns>log服务的单例实体</returns>
         public static AlertDao GetInstance()
        {
            if (Instance == null)
            {
                lock (Lock)
                {
                    if (Instance == null)
                    {
                        Instance = new AlertDao();
                    }
                }
            }
            return Instance;
        }
         protected override string GetColumnName(string name)
         {
             return AlertEntity.GetColumnName(name);
         }
         protected override string GetTableName()
         {
             return AlertEntity.GetTableName();
         }
         protected override AlertEntity ToEntity(DEVAlert receive)
         {
             return new AlertEntity(receive);
         }
         protected override DEVAlert ToOrm(AlertEntity receive)
         {
             return receive.ToOrm();
         }
         protected override List<string> GetColumnNames()
         {
             return AlertEntity.GetColumnMap().Keys.ToList();
         }
    }
}
DEmon/iWareLog/LOG/Dao/FailSentMessageDao.cs
¶Ô±ÈÐÂÎļþ
@@ -0,0 +1,64 @@
using iWareCommon.Common.Dao;
using iWareLog.LOG.Entity;
using iWareLog.ORM;
using System.Collections.Generic;
using System.Linq;
namespace iWareLog.LOG.Dao
{
    public class FailSentMessageDao : CommonDao<FailSentMessageEntity, LOGERRORFailSentMessage>
    {
         private static object Lock = new object();
         private FailSentMessageDao() { }
         private static FailSentMessageDao Instance = null;
        /// <summary>
        /// èŽ·å–å•ä¾‹çš„æ–¹æ³•
        /// </summary>
        /// <returns>log服务的单例实体</returns>
         public static FailSentMessageDao GetInstance()
        {
            if (Instance == null)
            {
                lock (Lock)
                {
                    if (Instance == null)
                    {
                        Instance = new FailSentMessageDao();
                    }
                }
            }
            return Instance;
        }
         protected override string GetColumnName(string name)
         {
             return FailSentMessageEntity.GetColumnName(name);
         }
         protected override string GetTableName()
         {
             return FailSentMessageEntity.GetTableName();
         }
         protected override FailSentMessageEntity ToEntity(LOGERRORFailSentMessage receive)
         {
             return new FailSentMessageEntity(receive);
         }
         protected override LOGERRORFailSentMessage ToOrm(FailSentMessageEntity receive)
         {
             return receive.ToOrm();
         }
         protected override List<string> GetColumnNames()
         {
             return FailSentMessageEntity.GetColumnMap().Keys.ToList();
         }
    }
}
DEmon/iWareLog/LOG/Dao/InOutStorageDetailDao.cs
¶Ô±ÈÐÂÎļþ
@@ -0,0 +1,64 @@
using iWareCommon.Common.Dao;
using iWareLog.LOG.Entity;
using iWareLog.ORM;
using System.Collections.Generic;
using System.Linq;
namespace iWareLog.LOG.Dao
{
    public class InOutStorageDetailDao : CommonDao<InOutStorageDetailEntity, InOutStorageDetail>
    {
         private static object Lock = new object();
         private InOutStorageDetailDao() { }
         private static InOutStorageDetailDao Instance = null;
        /// <summary>
        /// èŽ·å–å•ä¾‹çš„æ–¹æ³•
        /// </summary>
        /// <returns>log服务的单例实体</returns>
         public static InOutStorageDetailDao GetInstance()
        {
            if (Instance == null)
            {
                lock (Lock)
                {
                    if (Instance == null)
                    {
                        Instance = new InOutStorageDetailDao();
                    }
                }
            }
            return Instance;
        }
         protected override string GetColumnName(string name)
         {
             return InOutStorageDetailEntity.GetColumnName(name);
         }
         protected override string GetTableName()
         {
             return InOutStorageDetailEntity.GetTableName();
         }
         protected override InOutStorageDetailEntity ToEntity(InOutStorageDetail receive)
         {
             return new InOutStorageDetailEntity(receive);
         }
         protected override InOutStorageDetail ToOrm(InOutStorageDetailEntity receive)
         {
             return receive.ToOrm();
         }
         protected override List<string> GetColumnNames()
         {
             return InOutStorageDetailEntity.GetColumnMap().Keys.ToList();
         }
    }
}
DEmon/iWareLog/LOG/Dao/OperationDao.cs
¶Ô±ÈÐÂÎļþ
@@ -0,0 +1,64 @@
using iWareCommon.Common.Dao;
using iWareLog.LOG.Entity;
using iWareLog.ORM;
using System.Collections.Generic;
using System.Linq;
namespace iWareLog.LOG.Dao
{
    public class OperationDao : CommonDao<OperationEntity, LOGOperation>
    {
         private static object Lock = new object();
         private OperationDao() { }
         private static OperationDao Instance = null;
        /// <summary>
        /// èŽ·å–å•ä¾‹çš„æ–¹æ³•
        /// </summary>
        /// <returns>log服务的单例实体</returns>
         public static OperationDao GetInstance()
        {
            if (Instance == null)
            {
                lock (Lock)
                {
                    if (Instance == null)
                    {
                        Instance = new OperationDao();
                    }
                }
            }
            return Instance;
        }
         protected override string GetColumnName(string name)
         {
             return OperationEntity.GetColumnName(name);
         }
         protected override string GetTableName()
         {
             return OperationEntity.GetTableName();
         }
         protected override OperationEntity ToEntity(LOGOperation receive)
         {
             return new OperationEntity(receive);
         }
         protected override LOGOperation ToOrm(OperationEntity receive)
         {
             return receive.ToOrm();
         }
         protected override List<string> GetColumnNames()
         {
             return OperationEntity.GetColumnMap().Keys.ToList();
         }
    }
}
DEmon/iWareLog/LOG/Dao/ReceiveMsgLogDao.cs
¶Ô±ÈÐÂÎļþ
@@ -0,0 +1,64 @@
using iWareCommon.Common.Dao;
using iWareLog.LOG.Entity;
using iWareLog.ORM;
using System.Collections.Generic;
using System.Linq;
namespace iWareLog.LOG.Dao
{
    public class ReceiveMsgLogDao : CommonDao<ReceiveMsgLogEntity, LOGReceiveMsgLog>
    {
         private static object Lock = new object();
         private ReceiveMsgLogDao() { }
         private static ReceiveMsgLogDao Instance = null;
        /// <summary>
        /// èŽ·å–å•ä¾‹çš„æ–¹æ³•
        /// </summary>
        /// <returns>log服务的单例实体</returns>
         public static ReceiveMsgLogDao GetInstance()
        {
            if (Instance == null)
            {
                lock (Lock)
                {
                    if (Instance == null)
                    {
                        Instance = new ReceiveMsgLogDao();
                    }
                }
            }
            return Instance;
        }
         protected override string GetColumnName(string name)
         {
             return ReceiveMsgLogEntity.GetColumnName(name);
         }
         protected override string GetTableName()
         {
             return ReceiveMsgLogEntity.GetTableName();
         }
         protected override ReceiveMsgLogEntity ToEntity(LOGReceiveMsgLog receive)
         {
             return new ReceiveMsgLogEntity(receive);
         }
         protected override LOGReceiveMsgLog ToOrm(ReceiveMsgLogEntity receive)
         {
             return receive.ToOrm();
         }
         protected override List<string> GetColumnNames()
         {
             return ReceiveMsgLogEntity.GetColumnMap().Keys.ToList();
         }
    }
}
DEmon/iWareLog/LOG/Dao/SendMsgLogDao.cs
¶Ô±ÈÐÂÎļþ
@@ -0,0 +1,64 @@
using iWareCommon.Common.Dao;
using iWareLog.LOG.Entity;
using iWareLog.ORM;
using System.Collections.Generic;
using System.Linq;
namespace iWareLog.LOG.Dao
{
    public class SendMsgLogDao: CommonDao<SendMsgLogEntity, LOGSendMsgLog>
    {
         private static object Lock = new object();
         private SendMsgLogDao() { }
         private static SendMsgLogDao Instance = null;
        /// <summary>
        /// èŽ·å–å•ä¾‹çš„æ–¹æ³•
        /// </summary>
        /// <returns>LOG服务的单例实体</returns>
         public static SendMsgLogDao GetInstance()
        {
            if (Instance == null)
            {
                lock (Lock)
                {
                    if (Instance == null)
                    {
                        Instance = new SendMsgLogDao();
                    }
                }
            }
            return Instance;
        }
         protected override string GetColumnName(string name)
         {
             return SendMsgLogEntity.GetColumnName(name);
         }
         protected override string GetTableName()
         {
             return SendMsgLogEntity.GetTableName();
         }
         protected override SendMsgLogEntity ToEntity(LOGSendMsgLog send)
         {
             return new SendMsgLogEntity(send);
         }
         protected override LOGSendMsgLog ToOrm(SendMsgLogEntity send)
         {
             return send.ToOrm();
         }
         protected override List<string> GetColumnNames()
         {
             return SendMsgLogEntity.GetColumnMap().Keys.ToList();
         }
    }
}
DEmon/iWareLog/LOG/Entity/AlertEntity.cs
¶Ô±ÈÐÂÎļþ
@@ -0,0 +1,138 @@
using iWareCommon.Utils;
using iWareLog.ORM;
using System;
using System.Collections.Generic;
using System.Linq;
using System.Text;
using System.Threading.Tasks;
using iWareCommon.Common.Entity;
namespace iWareLog.LOG.Entity
{
    public class AlertEntity : ICommonEntity<DEVAlert>
    {
        /// <summary>
        /// 1主键
        /// </summary>
        public int Id { get; set; }
        /// <summary>
        /// 2小车名称
        /// </summary>
        public string Name { get; set; }
        /// <summary>
        /// 3提示类型
        /// </summary>
        public int Type { get; set; }
        /// <summary>
        /// 4设备id
        /// </summary>
        public string EquipId { get; set; }
        /// <summary>
        /// 5提示代码
        /// </summary>
        public string AlertCode{ get; set; }
        /// <summary>
        /// 6提示名称
        /// </summary>
        public string AlertName { get; set; }
        /// <summary>
        /// 7是否消警
        /// </summary>
        public int IsFinished { get; set; }
        /// <summary>
        /// 8事件代码
        /// </summary>
        public int EventCode { get; set; }
        /// <summary>
        /// 9创建时间
        /// </summary>
        public DateTime CreateTime { get; set; }
        /// <summary>
        /// 10结束事件
        /// </summary>
        public DateTime FinishTime { get; set; }
        /// <summary>
        /// æ— å‚构造
        /// </summary>
        public AlertEntity() {  }
        /// <summary>
        /// æœ‰å‚构造
        /// </summary>
        /// <param name="alert">orm印射的类</param>
        public AlertEntity(DEVAlert alert)
        {
            EntityPropHelper<AlertEntity, DEVAlert>.CopyProp(alert, this, GetColumnMap());
        }
        /// <summary>
        /// å°†å¯¹è±¡è½¬æ¢æˆORM中的类型
        /// </summary>
        /// <returns>Orm中的BASEShift类型</returns>
        public DEVAlert ToOrm()
        {
            DEVAlert alert = new DEVAlert();
            EntityPropHelper<AlertEntity, DEVAlert>.CopyProp(this, alert, GetColumnMap());
            return alert;
        }
        ///<summary>
        /// èŽ·å–è‡ªå®šä¹‰è§’è‰²ç±»ä¸­çš„å­—æ®µåä¸ºé”®ï¼Œorm中对象的字段名为值的字段
        /// </summary>
        /// <returns></returns>
        public static Dictionary<string, string> GetColumnMap()
        {
            return new Dictionary<string, string>()
            {
                {"Id", "id"},
                {"Name", "name"},
                {"Type", "type"},
                {"EquipId", "equipid"},
                {"AlertCode", "alertcode"},
                {"AlertName", "alertname"},
                {"IsFinished", "isfinished"},
                {"EventCode","eventcode"},
                {"CreateTime","createtime"},
                {"FinishTime","finishtime"}
            };
        }
        /// <summary>
        /// æ ¹æ®ShiftEntity的字段转BASEShift的字段
        /// </summary>
        /// <param name="name">ShiftEntity的字段</param>
        /// <returns>BASEShift</returns>
        public static string GetColumnName(string name)
        {
            var columnMap = GetColumnMap();
            return columnMap.ContainsKey(name) ? columnMap[name] : name;
        }
        /// <summary>
        /// èŽ·å–ShiftEntity对应的表名
        /// </summary>
        /// <returns>表名</returns>
        public static string GetTableName()
        {
            return "[dbo].[DEVAlert]";
        }
    }
}
DEmon/iWareLog/LOG/Entity/FailSentMessageEntity.cs
¶Ô±ÈÐÂÎļþ
@@ -0,0 +1,132 @@
using iWareCommon.Utils;
using iWareLog.ORM;
using System;
using System.Collections.Generic;
using System.Linq;
using System.Text;
using System.Threading.Tasks;
using iWareCommon.Common.Entity;
namespace iWareLog.LOG.Entity
{
    public class FailSentMessageEntity : ICommonEntity<LOGERRORFailSentMessage>
    {
        /// <summary>
        /// 1主键
        /// </summary>
        public int Id { get; set; }
        /// <summary>
        /// 2提交地址
        /// </summary>
        public string Url { get; set; }
        /// <summary>
        /// 3请求字符串
        /// </summary>
        public string RequestStr { get; set; }
        /// <summary>
        /// 4重试次数
        /// </summary>
        public int RetryTimes { get; set; }
        /// <summary>
        /// 5是否ok,0为未成功,1为成功
        /// </summary>
        public int IsOk { get; set; }
        /// <summary>
        /// 6是否发送邮件:0为未发送,1为已发送
        /// </summary>
        public int IsMailed { get; set; }
        /// <summary>
        /// 7创建时间
        /// </summary>
        public DateTime CreateTime { get; set; }
        /// <summary>
        /// 8结束事件
        /// </summary>
        public DateTime FinishTime { get; set; }
        /// <summary>
        /// 9错误消息
        /// </summary>
        public string ResMsg { get; set; }
        /// <summary>
        /// æ— å‚构造
        /// </summary>
        public FailSentMessageEntity() {  }
        /// <summary>
        /// æœ‰å‚构造
        /// </summary>
        /// <param name="alert">orm印射的类</param>
        public FailSentMessageEntity(LOGERRORFailSentMessage alert)
        {
            EntityPropHelper<FailSentMessageEntity, LOGERRORFailSentMessage>.CopyProp(alert, this, GetColumnMap());
        }
        /// <summary>
        /// å°†å¯¹è±¡è½¬æ¢æˆORM中的类型
        /// </summary>
        /// <returns>Orm中的BASEShift类型</returns>
        public LOGERRORFailSentMessage ToOrm()
        {
            LOGERRORFailSentMessage alert = new LOGERRORFailSentMessage();
            EntityPropHelper<FailSentMessageEntity, LOGERRORFailSentMessage>.CopyProp(this, alert, GetColumnMap());
            return alert;
        }
        ///<summary>
        /// èŽ·å–è‡ªå®šä¹‰è§’è‰²ç±»ä¸­çš„å­—æ®µåä¸ºé”®ï¼Œorm中对象的字段名为值的字段
        /// </summary>
        /// <returns></returns>
        public static Dictionary<string, string> GetColumnMap()
        {
            return new Dictionary<string, string>()
            {
                {"Id", "id"},
                {"Url", "url"},
                {"RequestStr", "requeststr"},
                {"RetryTimes", "retrytimes"},
                {"IsOk", "isok"},
                {"IsMailed", "ismailed"},
                {"CreateTime", "createtime"},
                {"UpdateTime","updatetime"},
                {"ResMsg","resmsg"}
            };
        }
        /// <summary>
        /// æ ¹æ®ShiftEntity的字段转BASEShift的字段
        /// </summary>
        /// <param name="name">ShiftEntity的字段</param>
        /// <returns>BASEShift</returns>
        public static string GetColumnName(string name)
        {
            var columnMap = GetColumnMap();
            return columnMap.ContainsKey(name) ? columnMap[name] : name;
        }
        /// <summary>
        /// èŽ·å–ShiftEntity对应的表名
        /// </summary>
        /// <returns>表名</returns>
        public static string GetTableName()
        {
            return "[dbo].[LOGERRORFailSentMessage]";
        }
    }
}
DEmon/iWareLog/LOG/Entity/InOutStorageDetailEntity.cs
¶Ô±ÈÐÂÎļþ
@@ -0,0 +1,150 @@
using iWareCommon.Utils;
using iWareLog.ORM;
using System;
using System.Collections.Generic;
using System.Linq;
using System.Text;
using System.Threading.Tasks;
using iWareCommon.Common.Entity;
namespace iWareLog.LOG.Entity
{
    public class InOutStorageDetailEntity : ICommonEntity<InOutStorageDetail>
    {
        /// <summary>
        /// 1主键
        /// </summary>
        public int Id { get; set; }
        /// <summary>
        /// 2库位类型id
        /// </summary>
        public int FormPlaceId { get; set; }
        /// <summary>
        /// 3库位代码
        /// </summary>
        public string FromPlaceCode { get; set; }
        /// <summary>
        /// 4库位类型id
        /// </summary>
        public int ToPlaceId { get; set; }
        /// <summary>
        /// 5库位代码
        /// </summary>
        public string ToPlaceCode { get; set; }
        /// <summary>
        /// 6出入库时间
        /// </summary>
        public DateTime CreateTime { get; set; }
        /// <summary>
        /// 7修改时间
        /// </summary>
        public DateTime UpdateTime { get; set; }
        /// <summary>
        /// 8操作类型,1为入库,2为出库
        /// </summary>
        public int Type { get; set; }
        /// <summary>
        /// 9设备id
        /// </summary>
        public int EquipId { get; set; }
        /// <summary>
        /// 10设备名称
        /// </summary>
        public string EquipName { get; set; }
        /// <summary>
        /// 11物料id
        /// </summary>
        public int MaterialId { get; set; }
        /// <summary>
        /// 12物料号
        /// </summary>
        public string MaterialCode { get; set; }
        /// <summary>
        /// æ— å‚构造
        /// </summary>
        public InOutStorageDetailEntity() {  }
        /// <summary>
        /// æœ‰å‚构造
        /// </summary>
        /// <param name="alert">orm印射的类</param>
        public InOutStorageDetailEntity(InOutStorageDetail alert)
        {
            EntityPropHelper<InOutStorageDetailEntity, InOutStorageDetail>.CopyProp(alert, this, GetColumnMap());
        }
        /// <summary>
        /// å°†å¯¹è±¡è½¬æ¢æˆORM中的类型
        /// </summary>
        /// <returns>Orm中的BASEShift类型</returns>
        public InOutStorageDetail ToOrm()
        {
            InOutStorageDetail alert = new InOutStorageDetail();
            EntityPropHelper<InOutStorageDetailEntity, InOutStorageDetail>.CopyProp(this, alert, GetColumnMap());
            return alert;
        }
        ///<summary>
        /// èŽ·å–è‡ªå®šä¹‰è§’è‰²ç±»ä¸­çš„å­—æ®µåä¸ºé”®ï¼Œorm中对象的字段名为值的字段
        /// </summary>
        /// <returns></returns>
        public static Dictionary<string, string> GetColumnMap()
        {
            return new Dictionary<string, string>()
            {
                {"Id", "id"},
                {"FormPlaceId", "formplaceid"},
                {"FromPlaceCode", "fromplacecode"},
                {"ToPlaceId", "toplaceid"},
                {"ToPlaceCode", "toplacecode"},
                {"CreateTime", "createtime"},
                {"UpdateTime", "updatetime"},
                {"EquipId","equipid"},
                {"EquipName","equipname"},
                {"MaterialId", "materialid"},
                {"MaterialCode","materialcode"},
                {"Type","type"}
            };
        }
        /// <summary>
        /// æ ¹æ®ShiftEntity的字段转BASEShift的字段
        /// </summary>
        /// <param name="name">ShiftEntity的字段</param>
        /// <returns>BASEShift</returns>
        public static string GetColumnName(string name)
        {
            var columnMap = GetColumnMap();
            return columnMap.ContainsKey(name) ? columnMap[name] : name;
        }
        /// <summary>
        /// èŽ·å–ShiftEntity对应的表名
        /// </summary>
        /// <returns>表名</returns>
        public static string GetTableName()
        {
            return "[dbo].[InOutStorageDetail]";
        }
    }
}
DEmon/iWareLog/LOG/Entity/OperationEntity.cs
¶Ô±ÈÐÂÎļþ
@@ -0,0 +1,138 @@
using iWareCommon.Utils;
using iWareLog.ORM;
using System;
using System.Collections.Generic;
using System.Linq;
using System.Text;
using System.Threading.Tasks;
using iWareCommon.Common.Entity;
namespace iWareLog.LOG.Entity
{
    public class OperationEntity : ICommonEntity<LOGOperation>
    {
        /// <summary>
        /// 1主键
        /// </summary>
        public int Id { get; set; }
        /// <summary>
        /// 2
        /// </summary>
        public int WbLogType { get; set; }
        /// <summary>
        /// 3
        /// </summary>
        public DateTime WbLogDate { get; set; }
        /// <summary>
        /// 4
        /// </summary>
        public string WbLogacCount { get; set; }
        /// <summary>
        /// 5
        /// </summary>
        public string WbUserName { get; set; }
        /// <summary>
        /// 6
        /// </summary>
        public string WbUserIpaddress { get; set; }
        /// <summary>
        /// 7
        /// </summary>
        public string WbLogTxt { get; set; }
        /// <summary>
        /// 8
        /// </summary>
        public string Log_backup1 { get; set; }
        /// <summary>
        /// 9
        /// </summary>
        public string Log_backup2 { get; set; }
        /// <summary>
        /// 10
        /// </summary>
        public string Log_backup3 { get; set; }
        /// <summary>
        /// æ— å‚构造
        /// </summary>
        public OperationEntity() {  }
        /// <summary>
        /// æœ‰å‚构造
        /// </summary>
        /// <param name="alert">orm印射的类</param>
        public OperationEntity(LOGOperation alert)
        {
            EntityPropHelper<OperationEntity, LOGOperation>.CopyProp(alert, this, GetColumnMap());
        }
        /// <summary>
        /// å°†å¯¹è±¡è½¬æ¢æˆORM中的类型
        /// </summary>
        /// <returns>Orm中的BASEShift类型</returns>
        public LOGOperation ToOrm()
        {
            LOGOperation alert = new LOGOperation();
            EntityPropHelper<OperationEntity, LOGOperation>.CopyProp(this, alert, GetColumnMap());
            return alert;
        }
        ///<summary>
        /// èŽ·å–è‡ªå®šä¹‰è§’è‰²ç±»ä¸­çš„å­—æ®µåä¸ºé”®ï¼Œorm中对象的字段名为值的字段
        /// </summary>
        /// <returns></returns>
        public static Dictionary<string, string> GetColumnMap()
        {
            return new Dictionary<string, string>()
            {
                {"Id", "wbdatalogid"},
                {"WbLogType", "wblogtype"},
                {"WbLogDate", "wblogdate"},
                {"WbLogacCount", "wblogaccount"},
                {"WbUserName", "wbusername"},
                {"WbUserIpaddress", "wbuseripaddress"},
                {"WbLogTxt", "wblogtxt"},
                {"Log_backup1","log_backup1"},
                {"Log_backup2","log_backup2"},
                {"Log_backup3","log_backup3"}
            };
        }
        /// <summary>
        /// æ ¹æ®ShiftEntity的字段转BASEShift的字段
        /// </summary>
        /// <param name="name">ShiftEntity的字段</param>
        /// <returns>BASEShift</returns>
        public static string GetColumnName(string name)
        {
            var columnMap = GetColumnMap();
            return columnMap.ContainsKey(name) ? columnMap[name] : name;
        }
        /// <summary>
        /// èŽ·å–ShiftEntity对应的表名
        /// </summary>
        /// <returns>表名</returns>
        public static string GetTableName()
        {
            return "[dbo].[LOGOperation]";
        }
    }
}
DEmon/iWareLog/LOG/Entity/ReceiveMsgLogEntity.cs
¶Ô±ÈÐÂÎļþ
@@ -0,0 +1,113 @@
using iWareCommon.Common.Entity;
using iWareCommon.Utils;
using iWareLog.ORM;
using System;
using System.Collections.Generic;
namespace iWareLog.LOG.Entity
{
    public class ReceiveMsgLogEntity : ICommonEntity<LOGReceiveMsgLog>
    {
        /// <summary>
        /// æŽ¥å—信息日志主键
        /// </summary>
        public int Id { get; set; }
        /// <summary>
        /// æŽ¥å—类型,0为wip,1为rcs, 2为人工发送
        /// </summary>
        public int Type { get; set; }
        /// <summary>
        /// è°ƒç”¨æŽ¥å£åç§°
        /// </summary>
        public string InterfaceName { get; set; }
        /// <summary>
        /// è¯·æ±‚字符串
        /// </summary>
        public string RequestStr { get; set; }
        /// <summary>
        /// åº”答字符串
        /// </summary>
        public string ResponseStr { get; set; }
        /// <summary>
        /// è¯·æ±‚æ—¶é—´
        /// </summary>
        public DateTime ReceiveTime { get; set; }
        /// <summary>
        /// å¤‡æ³¨
        /// </summary>
        public string Remark { get; set; }
        /// <summary>
        /// æž„造函数
        /// </summary>
        public ReceiveMsgLogEntity() { }
        /// <summary>
        /// æž„造函数
        /// </summary>
        /// <param name="receive">orm中的模型</param>
        public ReceiveMsgLogEntity(LOGReceiveMsgLog receive)
        {
            EntityPropHelper<ReceiveMsgLogEntity, LOGReceiveMsgLog>.CopyProp(receive, this, GetColumnMap());
        }
        /// <summary>
        /// èŽ·å–è‡ªå®šä¹‰ç±»ReceiveMsgLogEntity的字段名为键,ORM对象中字段名为值的字段
        /// </summary>
        /// <returns></returns>
        public static Dictionary<string, string> GetColumnMap()
        {
            return new Dictionary<string, string>()
            {
                {"Id", "id"},
                {"Type", "type"},
                {"InterfaceName", "interfacename"},
                {"RequestStr", "requeststr"},
                {"ResponseStr", "responsestr"},
                {"ReceiveTime","receivetime"},
                {"Remark","remark"}
            };
        }
        /// <summary>
        /// å°†ReceiveMsgLogEntity实体转化为orm里面的LOGReceiveMsgLog模型
        /// </summary>
        /// <returns>orm中的LOGReceiveMsgLog模型</returns>
        public LOGReceiveMsgLog ToOrm()
        {
            var receive = new LOGReceiveMsgLog();
            EntityPropHelper<ReceiveMsgLogEntity, LOGReceiveMsgLog>.CopyProp(this, receive, GetColumnMap());
            return receive;
        }
        /// <summary>
        /// æ ¹æ®ReceiveMsgLogEntity的字段转LOGReceiveMsgLog的字段
        /// </summary>
        /// <param name="name">ReceiveMsgLogEntity的字段</param>
        /// <returns>LOGReceiveMsgLog</returns>
        public static string GetColumnName(string name)
        {
            var columnMap = GetColumnMap();
            return columnMap.ContainsKey(name) ? columnMap[name] : name;
        }
        /// <summary>
        /// èŽ·å–ReceiveMsgLogEntity对应的表名
        /// </summary>
        /// <returns>LOGReceiveMsgLog</returns>
        public static string GetTableName()
        {
            return "[dbo].[LOGReceiveMsgLog]";
        }
    }
}
DEmon/iWareLog/LOG/Entity/SendMsgLogEntity.cs
¶Ô±ÈÐÂÎļþ
@@ -0,0 +1,115 @@
using iWareCommon.Common.Entity;
using iWareCommon.Utils;
using iWareLog.ORM;
using System;
using System.Collections.Generic;
namespace iWareLog.LOG.Entity
{
    public class SendMsgLogEntity : ICommonEntity<LOGSendMsgLog>
    {
        /// <summary>
        /// æŽ¥å—信息日志主键
        /// </summary>
        public int Id { get; set; }
        /// <summary>
        /// è°ƒç”¨æŽ¥å£åç§°
        /// </summary>
        public string InterfaceName { get; set; }
        /// <summary>
        /// è¯·æ±‚字符串
        /// </summary>
        public string RequestStr { get; set; }
        /// <summary>
        /// åº”答字符串
        /// </summary>
        public string ResponseStr { get; set; }
        /// <summary>
        /// å‘送时间
        /// </summary>
        public DateTime SendTime { get; set; }
        /// <summary>
        /// å¤‡æ³¨
        /// </summary>
        public string Remark { get; set; }
        /// <summary>
        /// æž„造函数
        /// </summary>
        public SendMsgLogEntity() { }
        /// <summary>
        /// æŽ¥å—类型,0为wip,1为rcs, 2为人工发送
        /// </summary>
        public int Type { get; set; }
        /// <summary>
        /// æž„造函数
        /// </summary>
        /// <param name="receive">orm中的模型</param>
        public SendMsgLogEntity(LOGSendMsgLog send)
        {
            EntityPropHelper<SendMsgLogEntity, LOGSendMsgLog>.CopyProp(send, this, GetColumnMap());
        }
        /// <summary>
        /// èŽ·å–è‡ªå®šä¹‰ç±»SendMsgLogEntity的字段名为键,ORM对象中字段名为值的字段
        /// </summary>
        /// <returns></returns>
        public static Dictionary<string, string> GetColumnMap()
        {
            return new Dictionary<string, string>()
            {
                {"Id", "id"},
                {"Type", "type"},
                {"InterfaceName", "interfacename"},
                {"RequestStr", "requeststr"},
                {"ResponseStr", "responsestr"},
                {"SendTime","sendtime"},
                {"Remark","remark"}
            };
        }
        /// <summary>
        /// å°†SendMsgLogEntity实体转化为orm里面的LOGSendMsgLog模型
        /// </summary>
        /// <returns>orm中的LOGReceiveMsgLog模型</returns>
        public LOGSendMsgLog ToOrm()
        {
            var send = new LOGSendMsgLog();
            EntityPropHelper<SendMsgLogEntity, LOGSendMsgLog>.CopyProp(this, send, GetColumnMap());
            return send;
        }
        /// <summary>
        /// æ ¹æ®SendMsgLogEntity的字段转LOGSendMsgLog的字段
        /// </summary>
        /// <param name="name">SendMsgLogEntity的字段</param>
        /// <returns>LOGSendMsgLog</returns>
        public static string GetColumnName(string name)
        {
            var columnMap = GetColumnMap();
            return columnMap.ContainsKey(name) ? columnMap[name] : name;
        }
        /// <summary>
        /// èŽ·å–SendMsgLogEntity对应的表名
        /// </summary>
        /// <returns>LOGSendMsgLog</returns>
        public static string GetTableName()
        {
            return "[dbo].[LOGSendMsgLog]";
        }
    }
}
DEmon/iWareLog/LOG/EnumType/EInOutStorageType.cs
¶Ô±ÈÐÂÎļþ
@@ -0,0 +1,17 @@
using System;
using System.Collections.Generic;
using System.Linq;
using System.Text;
using System.Threading.Tasks;
namespace iWareLog.LOG.EnumType
{
    public enum EInOutStorageType
    {
        å…¥åº“ = 0,
        å‡ºåº“ = 1,
        ç§»åº“ = 2,
        é€€åº“ = 3
    }
}
DEmon/iWareLog/LOG/EnumType/EReceiveType.cs
¶Ô±ÈÐÂÎļþ
@@ -0,0 +1,15 @@
using System;
using System.Collections.Generic;
using System.Linq;
using System.Text;
using System.Threading.Tasks;
namespace iWareLog.LOG.EnumType
{
    public enum EReceiveType
    {
        wip,
        rcs,
        äººå·¥å‘送
    }
}
DEmon/iWareLog/LOG/EnumType/_system~.ini
DEmon/iWareLog/LOG/Service/AlertService.cs
¶Ô±ÈÐÂÎļþ
@@ -0,0 +1,40 @@
using iWareLog.ORM;
using iWareLog.LOG.Entity;
using iWareLog.LOG.Dao;
using iWareCommon.Common.Service;
namespace iWareLog.LOG.Service
{
    public class AlertService : CommonService<AlertEntity, DEVAlert, DbModelLog>
    {
           private static object Lock = new object();
           private AlertService() : base(AlertDao.GetInstance()) { }
           private static AlertService Instance = null;
        /// <summary>
        /// èŽ·å–å•ä¾‹çš„æ–¹æ³•
        /// </summary>
        /// <returns>log服务的单例实体</returns>
           public static AlertService GetInstance()
        {
            if (Instance == null)
            {
                lock (Lock)
                {
                    if (Instance == null)
                    {
                        Instance = new AlertService();
                    }
                }
            }
            return Instance;
        }
    }
}
DEmon/iWareLog/LOG/Service/FailSentMessageService.cs
¶Ô±ÈÐÂÎļþ
@@ -0,0 +1,185 @@
using iWareLog.ORM;
using iWareLog.LOG.Entity;
using iWareLog.LOG.Dao;
using iWareCommon.Common.Service;
using iWareCommon.Utils;
using System;
using iWareCommon.Common.EnumType;
using Newtonsoft.Json;
using iWareLog.Properties;
using iWareCommon.Common.Entity;
using System.Linq;
namespace iWareLog.LOG.Service
{
    public class FailSentMessageService : CommonService<FailSentMessageEntity, LOGERRORFailSentMessage, DbModelLog>
    {
           private static object Lock = new object();
           private FailSentMessageService() : base(FailSentMessageDao.GetInstance()) { }
           private static FailSentMessageService Instance = null;
        /// <summary>
        /// èŽ·å–å•ä¾‹çš„æ–¹æ³•
        /// </summary>
        /// <returns>log服务的单例实体</returns>
           public static FailSentMessageService GetInstance()
        {
            if (Instance == null)
            {
                lock (Lock)
                {
                    if (Instance == null)
                    {
                        Instance = new FailSentMessageService();
                    }
                }
            }
            return Instance;
        }
           /// <summary>
           /// é‡æ–°å‘送
           /// </summary>
           /// <param name="message"></param>
           /// <param name="msg"></param>
           /// <returns></returns>
           public bool ReSend(int id, out string msg)
           {
               using (var dbModel = new DbModelLog())
               {
                   try
                   {
                       msg = "";
                       var url = "";
                       var message = dbModel.LOGERRORFailSentMessages.FirstOrDefault(x => x.id == id);
                       if (message == null)
                       {
                           msg = string.Format("没有找到id为{0}的记录", id);
                           return false;
                       }
                       switch (message.url)
                       {
                           case "pushstatusforpreheating":
                           case "pushstatusforheatstorage":
                           case "pushstatusforbufferfeed":
                           case "preheatstoragefinish":
                           case "pushstatusforft":
                           case "pushstatusforecmfeedbyrcs":
                           case "pushstatusforecmblankingbyrcs":
                           case "pushstatusforheattrans":
                           case "pushstatusforartificialqualityinspection":
                           case "heatstoroutbindrfid":
                           case "heatstoroutbindfinish":
                           case "pushstatusforbuffertrans":
                               url = Resources.WipUrl + @"/";
                               break;
                           case "syncmaterialinfo":
                           case "materialstatemodify":
                           case "getloadingtablestatus":
                           case "getecmtablestatus":
                           case "businessexception":
                           case "equipwarn":
                           case "equipstatus":
                           case "agvrealtimelocation":
                           case "outstoragecompleted":
                           case "movestoragecompleted":
                           case "bufferlayingoffcompleted":
                           case "artificialwarehousing":
                           case "processcardforwcs":
                           case "resetprocesscardprintqueue":
                               url = Resources.WipUrl2 + @"/";
                               break;
                           case "reparsetask":
                               break;
                       }
                       var responseStr = HttpHelper.GetHttpResponse(url + message.url, JsonConvert.DeserializeObject(message.requeststr), 5000);
                       var resFormat = JsonConvert.DeserializeObject<ResEntity>(responseStr);
                       message.isok = resFormat.resCode == "00000" ? (int)EYesOrNo.是 : (int)EYesOrNo.否;
                       message.updatetime = DateTime.Now;
                       message.retrytimes += 1;
                       dbModel.SaveChanges();
                       if (message.isok == (int)EYesOrNo.否)
                       {
                           msg = resFormat.resMsg;
                       }
                       return message.isok == (int)EYesOrNo.是;
                   }
                   catch (Exception ex)
                   {
                       msg = ex.Message;
                       var message = dbModel.LOGERRORFailSentMessages.FirstOrDefault(x => x.id == id);
                       message.isok = (int)EYesOrNo.否;
                       message.updatetime = DateTime.Now;
                       message.retrytimes += 1;
                       dbModel.SaveChanges();
                       LogTextHelper.WriteLog(Resources.LogDir, this.ToString(), "ReSend", msg);
                       return false;
                   }
               }
           }
           public bool PushBusinessException(int id, out string msg)
           {
               using (var dbModel2 = new DbModelLog())
               {
                   try
                   {
                       msg = "";
                       var message = dbModel2.LOGERRORFailSentMessages.FirstOrDefault(x => x.id == id);
                       if (message == null)
                       {
                           msg = string.Format("没有找到id为{0}的记录", id);
                           return false;
                       }
                       var requestBody = new
                       {
                           sysCode = "WCS",
                           taskNo = StringHelper.GetValue(message.requeststr, "taskNo"),
                           processCardNumber = StringHelper.GetValue(message.requeststr, "processCardNumber"),
                           exceptionCode = "001",
                           exceptionMsg = message.resmsg,
                           timestamp = DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss")
                       };
                       var responseStr = HttpHelper.GetHttpResponse(Resources.WipUrl2 + @"/businessexception", requestBody, 5000);
                       LogTextHelper.WriteLine(Resources.LogDir, "PushBusinessException:responseStr = {0}", responseStr);
                       return true;
                   }
                   catch (Exception ex)
                   {
                       msg = ex.Message;
                       LogTextHelper.WriteLog(Resources.LogDir, this.ToString(), "PushBusinessException", msg);
                       return false;
                   }
               }
           }
    }
}
DEmon/iWareLog/LOG/Service/InOutStorageDetailService.cs
¶Ô±ÈÐÂÎļþ
@@ -0,0 +1,36 @@
using iWareLog.ORM;
using iWareLog.LOG.Entity;
using iWareLog.LOG.Dao;
using iWareCommon.Common.Service;
namespace iWareLog.LOG.Service
{
    public class InOutStorageDetailService : CommonService<InOutStorageDetailEntity, InOutStorageDetail, DbModelLog>
    {
           private static object Lock = new object();
           private InOutStorageDetailService() : base(InOutStorageDetailDao.GetInstance()) { }
           private static InOutStorageDetailService Instance = null;
        /// <summary>
        /// èŽ·å–å•ä¾‹çš„æ–¹æ³•
        /// </summary>
        /// <returns>log服务的单例实体</returns>
        public static InOutStorageDetailService GetInstance()
        {
            if (Instance == null)
            {
                lock (Lock)
                {
                    if (Instance == null)
                    {
                        Instance = new InOutStorageDetailService();
                    }
                }
            }
            return Instance;
        }
    }
}
DEmon/iWareLog/LOG/Service/OperationService.cs
¶Ô±ÈÐÂÎļþ
@@ -0,0 +1,61 @@
using iWareLog.ORM;
using iWareLog.LOG.Entity;
using iWareLog.LOG.Dao;
using iWareCommon.Common.Service;
using iWareCommon.Utils;
using iWareLog.Properties;
using System;
namespace iWareLog.LOG.Service
{
    public class OperationService : CommonService<OperationEntity, LOGOperation, DbModelLog>
    {
           private static object Lock = new object();
           private OperationService() : base(OperationDao.GetInstance()) { }
           private static OperationService Instance = null;
        /// <summary>
        /// èŽ·å–å•ä¾‹çš„æ–¹æ³•
        /// </summary>
        /// <returns>log服务的单例实体</returns>
           public static OperationService GetInstance()
        {
            if (Instance == null)
            {
                lock (Lock)
                {
                    if (Instance == null)
                    {
                        Instance = new OperationService();
                    }
                }
            }
            return Instance;
        }
           /// <summary>
           /// å†™å…¥æ—¥å¿—
           /// </summary>
           /// <param name="tt_new"></param>
           /// <returns></returns>
           public void Save(OperationEntity dateLog)
           {
               try
               {
                   using (DbModelLog ml = new DbModelLog())
                   {
                       ml.LOGOperations.Add(dateLog.ToOrm());
                       ml.SaveChanges();
                   }
               }
               catch (Exception ex)
               {
                LogTextHelper.WriteLog(Resources.LogDir, this.ToString(), "Save", ex.Message);
               }
           }
    }
}
DEmon/iWareLog/LOG/Service/ReceiveMsgLogService.cs
¶Ô±ÈÐÂÎļþ
@@ -0,0 +1,38 @@
using iWareLog.ORM;
using iWareLog.LOG.Entity;
using iWareLog.LOG.Dao;
using iWareCommon.Common.Service;
namespace iWareLog.LOG.Service
{
    public class ReceiveMsgLogService : CommonService<ReceiveMsgLogEntity, LOGReceiveMsgLog, DbModelLog>
    {
           private static object Lock = new object();
           private ReceiveMsgLogService() : base(ReceiveMsgLogDao.GetInstance()) { }
           private static ReceiveMsgLogService Instance = null;
        /// <summary>
        /// èŽ·å–å•ä¾‹çš„æ–¹æ³•
        /// </summary>
        /// <returns>log服务的单例实体</returns>
           public static ReceiveMsgLogService GetInstance()
        {
            if (Instance == null)
            {
                lock (Lock)
                {
                    if (Instance == null)
                    {
                        Instance = new ReceiveMsgLogService();
                    }
                }
            }
            return Instance;
        }
    }
}
DEmon/iWareLog/LOG/Service/SendMsgLogService.cs
¶Ô±ÈÐÂÎļþ
@@ -0,0 +1,37 @@
using iWareLog.LOG.Dao;
using iWareLog.LOG.Entity;
using iWareLog.ORM;
using iWareCommon.Common.Service;
namespace iWareLog.LOG.Service
{
    public class SendMsgLogService : CommonService<SendMsgLogEntity, LOGSendMsgLog, DbModelLog>
    {
         private static object Lock = new object();
         private SendMsgLogService() : base(SendMsgLogDao.GetInstance()) { }
         private static SendMsgLogService Instance = null;
        /// <summary>
        /// èŽ·å–å•ä¾‹çš„æ–¹æ³•
        /// </summary>
        /// <returns>log服务的单例实体</returns>
         public static SendMsgLogService GetInstance()
        {
            if (Instance == null)
            {
                lock (Lock)
                {
                    if (Instance == null)
                    {
                        Instance = new SendMsgLogService();
                    }
                }
            }
            return Instance;
        }
    }
}