1234567891011121314151617181920212223242526272829303132333435363738394041424344454647484950515253 |
- using EInk.Dtos;
- using EInk.Models;
- using EInk.Tools;
- using Newtonsoft.Json;
- using SqlSugar;
- namespace EInk.TaskThread
- {
- public class DeleteDBRecordThread
- {
- private readonly ISqlSugarClient _db;
- private int daysago;
- public DeleteDBRecordThread(ISqlSugarClient db, int daysago)
- {
- _db = db;
- this.daysago = daysago;
- }
- public void DeleteThreadStart()
- {
- Thread t = new Thread(DeleteTask);
- t.Start(_db);
- }
- static void DeleteTask(Object db)
- {
- ISqlSugarClient _db = (ISqlSugarClient)db;
- while (true)
- {
- try
- {
- DateTime now = DateTime.Now;
- if (now.Hour==8 && now.Minute==0)
- {
- _db.Deleteable<Lot2Lot3Model>().Where(x => x.create_time < now.AddDays(-2)).ExecuteCommand();
- LogerHelper.RecordLogTxt("DeleteTask");
- }
- }
- catch (Exception ex)
- {
- LogerHelper.RecordLogTxt("DeleteTask," + ex.Message);
- }
- finally
- {
- Thread.Sleep(1000 * 60);
- }
- }
- }
- }
- }
|