使用数据日志(sys_LogData)保存数据同步标记
案例:每天从Oracle数据库抓取数据同步到SqlServer数据库
C# 全选
#region 使用数据日志保存数据同步标记
/// <summary>
/// 每天同步一次
/// </summary>
/// <returns></returns>
private string GetSyncKey()
{
var key = "OracleERP:" + DateTime.Today.ToString();
return key;
}
/// <summary>
/// 今天是否数据同步,查找标记
/// </summary>
/// <returns></returns>
private bool IsSyncToday()
{
var key = GetSyncKey();
return new dalLogData(_Loginer).HasKey(key);
}
/// <summary>
/// 添加同步标记
/// </summary>
private void AddSyncLog()
{
var key = GetSyncKey();
if (!DatabaseProvider.SystemDatabase.GetQueryable<sys_LogData>().Any(x => x.row_id == key))
{
var log = new sys_LogData
{
row_id = key,
data_value = "同步ERP数据",
key_value = key,
log_content = "同步ERP数据",
log_user = _Loginer.Account,
log_type = "OracleERP",
ts = DateTime.Now,
};
DatabaseProvider.SystemDatabase.Add(log);
}
}
/// <summary>
/// 添加同步日志
/// </summary>
/// <param name="keyValue"></param>
/// <param name="content"></param>
private void AddSyncLog(string keyValue, string content)
{
try
{
var log = new sys_LogData
{
row_id = IdHelper.GetId(),
log_content = content,
log_user = _Loginer.Account,
log_type = "Sync",
key_value = keyValue,
ts = DateTime.Now,
};
DatabaseProvider.SystemDatabase.Add(log);
}
catch
{
}
}
#endregion版权声明:本文为开发框架文库发布内容,转载请附上原文出处连接
NewDoc C/S框架网





