using Furion.JsonSerialization;
|
using Newtonsoft.Json;
|
using OfficeOpenXml.FormulaParsing.Excel.Functions.Text;
|
using Quartz;
|
using System;
|
using System.Collections.Generic;
|
using System.IO;
|
using System.Runtime.Serialization.Json;
|
using System.Security.Policy;
|
using System.Text;
|
using System.Threading;
|
using System.Threading.Tasks;
|
using WIDESEA_Entity.DomainModels.Equipment;
|
using WIDESEA_Services.Services;
|
using WIDESEA_WCS.Jobs;
|
using WIDESEA_WCS.JobsPart.AGV;
|
using WIDESEA_WCS.SchedulerExecute.AGV;
|
using WIDESEA_WCS.WCSClient;
|
using static FreeSql.Internal.GlobalFilter;
|
|
namespace WIDESEA_WCS
|
{
|
/// <summary>
|
/// AGV调度
|
/// </summary>
|
[DisallowConcurrentExecution]
|
public class AGVJob : JobBase, IJob
|
{
|
private static object lockObj1 = 0;
|
public Task Execute(IJobExecutionContext context)
|
{
|
try
|
{
|
ExecuteJob(context, DoAction);
|
}
|
catch { }
|
return Task.FromResult(string.Empty);
|
}
|
|
|
private void DoAction(IJobExecutionContext context)
|
{
|
lock (lockObj1)
|
{
|
if (lockObj1.ToString() == "0")
|
{
|
try
|
{
|
lockObj1 = 1;
|
Task task = Task.Run(() =>
|
{
|
List<string> AGVS = new List<string> { "组装AGV调度", "正极AGV调度", "负极AGV调度" };
|
while (true)
|
{
|
foreach (var item in AGVS)
|
{
|
PLCClient pLCClient = WCSService.Clients.Find(v => v.PLCName == item);
|
if (pLCClient == null)
|
{
|
continue;
|
}
|
AGVSchedulerExecute.SendAGVTask1(pLCClient);
|
}
|
Thread.Sleep(200);
|
}
|
});
|
|
Task.Run(() =>
|
{
|
while (true)
|
{
|
try
|
{
|
string date = DateTime.Now.ToString("yyyy-MM-dd");
|
string json = File.ReadAllText(AppContext.BaseDirectory + "modified_data.json", Encoding.UTF8);
|
var logstime = JsonConvert.DeserializeObject<timelist>(json);
|
if (date != logstime.logtime)
|
{
|
logstime.logtime = date;
|
string modifiedJson = JsonConvert.SerializeObject(logstime);
|
File.WriteAllText("modified_data.json", modifiedJson);
|
string folderPath = Path.Combine(AppDomain.CurrentDomain.BaseDirectory, "logs");
|
DateTime tenDaysAgo = DateTime.Now.AddDays(-7); // 获取当前时间的七天之前的日期
|
|
DeleteFilesAndFolders(folderPath, tenDaysAgo);
|
}
|
|
Thread.Sleep(1000 * 60 * 60 * 24);
|
}
|
catch
|
{
|
Thread.Sleep(1000 * 60 * 60);
|
}
|
}
|
});
|
}
|
catch (Exception ex)
|
{
|
lockObj1 = 0;
|
throw new Exception(ex.Message);
|
}
|
}
|
}
|
|
// 清楚7日以上的Logs日志记录
|
//try
|
//{
|
// List<string> AGVS = new List<string> { "组装AGV调度", "正极AGV调度", "负极AGV调度", "组装AGV调度" };
|
// //foreach (var item in AGVS)
|
// {
|
// //PLCClient pLCClient = WCSService.Clients.Find(v => v.PLCName == item);
|
// //if (pLCClient == null)
|
// //{
|
// // continue;
|
// //}
|
// PLCClient pLCClient = context.JobDetail.JobDataMap["JobParams"] as PLCClient;
|
// AGVSchedulerExecute.SendAGVTask1(pLCClient);
|
// }
|
// //string date = DateTime.Now.ToString("yyyy-MM-dd");
|
// //string json = File.ReadAllText(AppContext.BaseDirectory + "modified_data.json", Encoding.UTF8);
|
// //var logstime = JsonConvert.DeserializeObject<timelist>(json);
|
// //if (date != logstime.logtime)
|
// //{
|
// // logstime.logtime = date;
|
// // string modifiedJson = JsonConvert.SerializeObject(logstime);
|
// // File.WriteAllText("modified_data.json", modifiedJson);
|
// // string folderPath = Path.Combine(AppDomain.CurrentDomain.BaseDirectory, "logs");
|
// // DateTime tenDaysAgo = DateTime.Now.AddDays(-7); // 获取当前时间的七天之前的日期
|
|
// // DeleteFilesAndFolders(folderPath, tenDaysAgo);
|
// //}
|
//}
|
//catch (Exception ex)
|
//{
|
// throw new Exception(ex.Message);
|
//}
|
}
|
|
static void DeleteFilesAndFolders(string path, DateTime dateTime)
|
{
|
DirectoryInfo directory = new DirectoryInfo(path);
|
|
foreach (FileSystemInfo fileOrFolder in directory.GetFileSystemInfos())
|
{
|
if ((fileOrFolder is FileInfo && ((DateTime)((FileInfo)fileOrFolder).LastWriteTime < dateTime)) ||
|
(fileOrFolder is DirectoryInfo && ((DirectoryInfo)fileOrFolder).CreationTime < dateTime))
|
{
|
try
|
{
|
if (fileOrFolder is FileInfo)
|
{
|
((FileInfo)fileOrFolder).Delete();
|
}
|
else if (fileOrFolder is DirectoryInfo)
|
{
|
DeleteFilesAndFolders(fileOrFolder.FullName, dateTime);
|
((DirectoryInfo)fileOrFolder).Delete(true);
|
}
|
}
|
catch (Exception ex)
|
{
|
Console.WriteLine("无法删除文件或文件夹: " + fileOrFolder.FullName + "\n错误信息: " + ex.Message);
|
}
|
}
|
}
|
}
|
}
|
|
public class timelist {
|
public string MM { get; set; }
|
//日志删除过滤时间
|
public string logtime { get; set; }
|
|
}
|
}
|
