清除数据

schangxiang@126.com

2024-09-06 19c66ffe3a8d2a2e784ba54cefc6f2566135bafa

清除数据

 DataCapture/iWare_SCADA_DataCapture/iWare_SCADA_BusinessLogical/DataCaptureHandlerV2/DeleteDataHandler.cs

@@ -74,6 +74,8 @@

                        ClearDataHandler.Delete_WorkPieceLog(7);

                        ClearDataHandler.Delete_AccessInterfaceLogForRequest(7);

                        Log4NetHelper.WriteInfoLog(logType, $"定时删除表数据成功：");
                    }
                    catch (Exception ex)

 DataCapture/iWare_SCADA_DataCapture/iWare_SCADA_BusinessLogical/Utils/ClearDataHandler.cs

@@ -64,5 +64,33 @@
        }



        /// <summary>
        /// ç§»é™¤XX天前的 WorkPieceLog æ•°æ®
        /// </summary>
        /// <param name="edm"></param>
        public static void Delete_AccessInterfaceLogForRequest(int days)
        {
            try
            {
                using (DbModel edm = new DbModel())
                {
                    var queryTime = DateTime.Now.AddDays(-days);

                    var removeList = edm.AccessInterfaceLogForRequest.Where(x => x.CreatedTime <= queryTime).ToList();
                    if (removeList != null && removeList.Count > 0)
                    {
                        edm.AccessInterfaceLogForRequest.RemoveRange(removeList);
                    }
                    edm.SaveChanges();
                }
            }
            catch (Exception ex)
            {
                Log4NetHelper.WriteErrorLog(LogType.DeleteData, "移除XX天前的 AccessInterfaceLogForRequest æ•°æ® å‡ºçŽ°å¼‚常", ex);
            }
        }


    }
}

 DataCapture/iWare_SCADA_DataCapture/iWare_SCADA_Model/TableModel/AccessInterfaceLogForRequest.cs

¶Ô±ÈÐÂÎļþ
@@ -0,0 +1,73 @@
namespace iWare_SCADA_Model
{
    using System;
    using System.Collections.Generic;
    using System.ComponentModel.DataAnnotations;
    using System.ComponentModel.DataAnnotations.Schema;
    using System.Data.Entity.Spatial;

    [Table("AccessInterfaceLogForRequest")]
    public partial class AccessInterfaceLogForRequest
    {
        [Key]
        [Column(Order = 0)]
        [DatabaseGenerated(DatabaseGeneratedOption.None)]
        public long Id { get; set; }

        [Key]
        [Column(Order = 1)]
        [DatabaseGenerated(DatabaseGeneratedOption.None)]
        public int Action { get; set; }

        [StringLength(200)]
        public string OperateAddress { get; set; }

        [StringLength(200)]
        public string OperateUserId { get; set; }

        [StringLength(200)]
        public string OperateUserName { get; set; }

        [StringLength(50)]
        public string IPAddress { get; set; }

        [StringLength(200)]
        public string Param1 { get; set; }

        [StringLength(200)]
        public string Param2 { get; set; }

        [StringLength(200)]
        public string Param3 { get; set; }

        public string ParaJSON { get; set; }

        public string ResultJson { get; set; }

        public string Keys { get; set; }

        public DateTimeOffset? CreatedTime { get; set; }

        public DateTimeOffset? UpdatedTime { get; set; }

        public long? CreatedUserId { get; set; }

        [StringLength(50)]
        public string CreatedUserName { get; set; }

        public long? UpdatedUserId { get; set; }

        [StringLength(50)]
        public string UpdatedUserName { get; set; }

        [Key]
        [Column(Order = 2)]
        public bool IsDeleted { get; set; }

        [StringLength(255)]
        public string WorkPieceID { get; set; }

        [StringLength(255)]
        public string WorkingProcedureCurrent { get; set; }
    }
}

 DataCapture/iWare_SCADA_DataCapture/iWare_SCADA_Model/TableModel/DbModel.cs

@@ -1,8 +1,5 @@
using iWare_SCADA_Model.TableModel;
using System;
using System.ComponentModel.DataAnnotations.Schema;
using System.Data.Entity;
using System.Linq;

namespace iWare_SCADA_Model
{
@@ -13,6 +10,7 @@
        {
        }

        public virtual DbSet<AccessInterfaceLogForRequest> AccessInterfaceLogForRequest { get; set; }
        public virtual DbSet<DataCaptureColumnConfig> DataCaptureColumnConfig { get; set; }
        public virtual DbSet<DataCaptureConfig> DataCaptureConfig { get; set; }
        public virtual DbSet<EquipmentBaseInfo> EquipmentBaseInfo { get; set; }

 DataCapture/iWare_SCADA_DataCapture/iWare_SCADA_Model/iWare_SCADA_Model.csproj

@@ -99,6 +99,7 @@
    <Compile Include="TableModel\WorkPieceLog.cs" />
    <Compile Include="TableModel\WorkPieceProcess.cs" />
    <Compile Include="TableModel\ThreadStatusMonitor.cs" />
    <Compile Include="TableModel\AccessInterfaceLogForRequest.cs" />
  </ItemGroup>
  <ItemGroup>
    <None Include="App.Config" />