using JinYuan.Models;
using System;
using System.Collections.Generic;
using System.IO;
using System.Linq;
using System.Text;
using System.Threading;
using System.Threading.Tasks;
namespace JinYuan.Helper
{
///
/// 日志操作类
///
public class LogHelper
{
private static object singleLock = new object();
///
/// log日志文件路径
///
public static string logFilePath = string.Empty;
public static LogHelper _instance = null;
public static LogHelper Instance
{
get
{
if (_instance == null)
{
lock (singleLock)
{
if (_instance == null)
{
_instance = new LogHelper();
}
}
}
return _instance;
}
}
///
/// 初始化
///
///
public void InitLog(string configPath)
{
logFilePath = configPath;
if (!Directory.Exists(logFilePath))
{
Directory.CreateDirectory(logFilePath);
}
//if (!File.Exists(logFilePath))
//{
// File.Create(logFilePath).Close();
//}
}
///
/// 写日志文件数据库日志文件
///
/// 消息
public void WriteError(string message)
{
AddLog(message, "Error");
}
public void WriteEX(Exception ex)
{
AddLog(ex.Message + "\r\n" + ex.InnerException + "\r\n" + ex.StackTrace + "\r\n" + ex.Source, "SysErrorLog");
}
public void WriteEX(string ErrorName,Exception ex)
{
AddLog(ErrorName+ "\r\n"+ex.Message + "\r\n" + ex.InnerException + "\r\n" + ex.StackTrace + "\r\n" + ex.Source, "SysErrorLog");
}
///
/// 写日志文件数据库日志文件
///
/// 消息
/// 日志存储目录名称
public void WriteError(Exception ex, string direName)
{
AddLog(ex.Message + "\r\n" + ex.InnerException + "\r\n" + ex.StackTrace + "\r\n" + ex.Source, direName);
}
///
/// /
///
///
///
public void WriteError(string message, string direName)
{
AddLog(message, direName);
}
///
/// 写日志文件数据库日志文件
///
/// 消息
public void WriteLog(string message)
{
AddLog(message, "Info");
}
///
/// 写日志文件数据库日志文件
///
/// 消息
/// 日志存储目录名称
public void WriteLog(string message, string direName)
{
AddLog(message, direName);
}
///
/// 写日志文件数据库日志文件
///
/// 消息
/// 日志存储目录名称
private void AddLog(string message, string direName)
{
string fileLog = logFilePath;
if (fileLog == "")
{
return;
}
try
{
var applicationName = direName;
//从宿主配置文件中获取日志文件全路径
//所有的接口日志文件放在一个目录下面，跟web站点的目录分开
//日志文件一天放一个，按日期分开
if (string.IsNullOrEmpty(applicationName))
{
applicationName = "Log";
}
string logFullPath = fileLog + applicationName;
if (!Directory.Exists(logFullPath))
{
Directory.CreateDirectory(logFullPath);
}
//只保留30天的日志
var deletePath = $@"{logFullPath}\{DateTime.Now.AddDays(-30):yyyyMMddHH}.txt";
if (File.Exists(deletePath))
{
File.Delete(deletePath);
}
logFullPath = $@"{logFullPath}\{DateTime.Now:yyyyMMddHH}.txt";
if (!File.Exists(logFullPath))
{
using (var fs = new FileStream(logFullPath, FileMode.Create, FileAccess.Write))
{
StreamWriter sw = new StreamWriter(fs);
sw.Close();
fs.Close();
}
}
using (StreamWriter writer = new StreamWriter(logFullPath, true))
{
writer.WriteLine(DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss"));
writer.WriteLine(message);
writer.WriteLine(Environment.NewLine);
}
}
catch
{
// ignored
}
}
///
/// 轴位置日志类
///
public class PrintMotorLog
{
private static readonly Thread WriteThread;
private static readonly Queue MsgQueue;//先进先出集合
public static readonly object FileLock;
private static readonly string FilePath = "D:\\LOCAL\\轴位置修改记录(查看文件就复制到副本到桌面！！！)\\";
static PrintMotorLog()
{
FileLock = new object();//文件锁
WriteThread = new Thread(WriteMsg);
MsgQueue = new Queue();
WriteThread.Start();
}
public static void LogInfo(string BegionTime, string MotorDescribe, string IndxDescribe, string FrontIndx, string NewIndx)
{
Monitor.Enter(MsgQueue);
string strData = BegionTime + ","
+ MotorDescribe + ","
+ IndxDescribe + ","
+ FrontIndx + ","
+ NewIndx + ",";
MsgQueue.Enqueue(strData);
Monitor.Exit(MsgQueue);
}
private static void WriteMsg()
{
while (true)
{
Thread.Sleep(10);
if (MsgQueue.Count > 0)
{
Monitor.Enter(MsgQueue);
string msg = MsgQueue.Dequeue();
Monitor.Exit(MsgQueue);
Monitor.Enter(FileLock);
if (!Directory.Exists(FilePath))
{
Directory.CreateDirectory(FilePath);
}
string strFilename = FilePath + "轴位置修改_" + System.DateTime.Now.ToString("yyyyMMdd") + ".csv";
//用默认编码和缓冲区大小，为指定的文件初始化 StreamWriter 类的一个新实例。 如果该文件存在，则可以将其覆盖或向其追加。 如果该文件不存在，则此构造函数将创建一个新文件。
try
{
if (!File.Exists(strFilename))
{
//文件标头 19
string strProInfoFileHead = @"日期时间,轴描述,位置描述,位置修改前,当前位置";
StreamWriter sw = new StreamWriter(strFilename, true, UnicodeEncoding.GetEncoding("GB2312"));
sw.WriteLine(strProInfoFileHead);
sw.Flush();
sw.Close();
sw.Dispose();
}
StreamWriter se = new StreamWriter(strFilename, true, UnicodeEncoding.GetEncoding("GB2312"));
se.WriteLine(msg);
se.Flush();
se.Close();
se.Dispose();
}
catch (Exception)
{
}
Monitor.Exit(FileLock);
if (GetFileSize(strFilename) > 1024 * 5)
{
CopyToBak(strFilename);
}
}
}
}
private static long GetFileSize(string fileName)
{
long strRe = 0;
if (File.Exists(fileName))
{
Monitor.Enter(FileLock);
try
{
var myFs = new FileStream(fileName, FileMode.Open);
strRe = myFs.Length / 1024;
myFs.Close();
myFs.Dispose();
}
catch (Exception)
{
}
Monitor.Exit(FileLock);
}
return strRe;
}
private static void CopyToBak(string sFileName)
{
int fileCount = 0;
string sBakName = "";
Monitor.Enter(FileLock);
try
{
do
{
fileCount++;
sBakName = sFileName + "." + fileCount + ".BAK";
}
while (File.Exists(sBakName));
File.Copy(sFileName, sBakName);
File.Delete(sFileName);
}
catch (Exception)
{
}
Monitor.Exit(FileLock);
}
}
}
}