|
|
@@ -130,7 +130,7 @@ namespace TeamAAS_VP.Data
|
|
|
{
|
|
|
UserId = userId,
|
|
|
Success = true,
|
|
|
- Time = DateTime.Now,
|
|
|
+ Time = DateTime.UtcNow,
|
|
|
Message = "Set as current user"
|
|
|
};
|
|
|
|
|
|
@@ -150,7 +150,7 @@ namespace TeamAAS_VP.Data
|
|
|
{
|
|
|
UserId = user.Id,
|
|
|
Success = true,
|
|
|
- Time = DateTime.Now,
|
|
|
+ Time = DateTime.UtcNow,
|
|
|
Message = user.UserName
|
|
|
};
|
|
|
await RecordUserLoginAsync(rec);
|
|
|
@@ -194,7 +194,7 @@ namespace TeamAAS_VP.Data
|
|
|
public async Task RecordUserLoginAsync(UserLoginRecord record)
|
|
|
{
|
|
|
if (record == null) throw new ArgumentNullException(nameof(record));
|
|
|
- if (record.Time == default(DateTime)) record.Time = DateTime.Now;
|
|
|
+ if (record.Time == default(DateTime)) record.Time = DateTime.UtcNow;
|
|
|
await _db.Insertable(record).ExecuteCommandAsync();
|
|
|
}
|
|
|
|
|
|
@@ -401,9 +401,9 @@ namespace TeamAAS_VP.Data
|
|
|
public async Task<int> GetTodayProductionAsync(string productName)
|
|
|
{
|
|
|
//今天的起始时间
|
|
|
- var todayStart = DateTime.Now.Date;
|
|
|
+ var todayStart = DateTime.UtcNow.Date;
|
|
|
//今天的结束时间
|
|
|
- var todayEnd = DateTime.Now.Date;
|
|
|
+ var todayEnd = DateTime.UtcNow.Date;
|
|
|
todayEnd = todayEnd.AddDays(1);
|
|
|
//按照产品名称和时间范围查询生产记录的总数
|
|
|
var total = await _db.Queryable<ProductionRecord>()
|
|
|
@@ -419,8 +419,8 @@ namespace TeamAAS_VP.Data
|
|
|
/// <returns></returns>
|
|
|
public async Task<int> GetLastHourProductionAsync(string productName)
|
|
|
{
|
|
|
- var lastHourStart = DateTime.Now.AddHours(-1);
|
|
|
- var lastHourEnd = DateTime.Now;
|
|
|
+ var lastHourStart = DateTime.UtcNow.AddHours(-1);
|
|
|
+ var lastHourEnd = DateTime.UtcNow;
|
|
|
//按照产品名称和时间范围查询生产记录的总数
|
|
|
var total = await _db.Queryable<ProductionRecord>()
|
|
|
.Where(r => r.ProductName == productName && r.Timestamp >= lastHourStart && r.Timestamp < lastHourEnd)
|
|
|
@@ -436,9 +436,9 @@ namespace TeamAAS_VP.Data
|
|
|
public async Task<int> GetNGProductionAsync(string productName)
|
|
|
{
|
|
|
//今天的起始时间
|
|
|
- var todayStart = DateTime.Now.Date;
|
|
|
+ var todayStart = DateTime.UtcNow.Date;
|
|
|
//今天的结束时间
|
|
|
- var todayEnd = DateTime.Now.Date;
|
|
|
+ var todayEnd = DateTime.UtcNow.Date;
|
|
|
todayEnd = todayEnd.AddDays(1);
|
|
|
//按照产品名称和时间范围查询生产记录的总数
|
|
|
var total = await _db.Queryable<ProductionRecord>()
|
|
|
@@ -455,7 +455,7 @@ namespace TeamAAS_VP.Data
|
|
|
public Task<int> GetCurrentMonthProductionAsync(string productName)
|
|
|
{
|
|
|
|
|
|
- var now = DateTime.Now;
|
|
|
+ var now = DateTime.UtcNow;
|
|
|
var monthStart = new DateTime(now.Year, now.Month, 1);
|
|
|
var monthEnd = monthStart.AddMonths(1);
|
|
|
//按照产品名称和时间范围查询生产记录的总数
|
|
|
@@ -472,7 +472,7 @@ namespace TeamAAS_VP.Data
|
|
|
/// <returns></returns>
|
|
|
public Task<int> GetCurrentWeekProductionAsync(string productName)
|
|
|
{
|
|
|
- var now = DateTime.Now;
|
|
|
+ var now = DateTime.UtcNow;
|
|
|
var weekStart = FirstDayOfWeek(now);
|
|
|
var weekEnd = weekStart.AddDays(7);
|
|
|
//按照产品名称和时间范围查询生产记录的总数
|
|
|
@@ -545,7 +545,7 @@ namespace TeamAAS_VP.Data
|
|
|
/// <returns></returns>
|
|
|
public async Task<Dictionary<DateTime, Dictionary<string, int>>> GetMonthlyProductionByDayAndCategoryAsync(string productName)
|
|
|
{
|
|
|
- var now = DateTime.Now;
|
|
|
+ var now = DateTime.UtcNow;
|
|
|
var monthStart = new DateTime(now.Year, now.Month, 1);
|
|
|
var monthEnd = monthStart.AddMonths(1);
|
|
|
var list = await _db.Queryable<ProductionRecord>()
|
|
|
@@ -570,7 +570,7 @@ namespace TeamAAS_VP.Data
|
|
|
/// <returns></returns>
|
|
|
public async Task<Dictionary<int, Dictionary<string, int>>> GetWeeklyProductionByDayAndCategoryAsync(string productName)
|
|
|
{
|
|
|
- var now = DateTime.Now;
|
|
|
+ var now = DateTime.UtcNow;
|
|
|
var weekStart = FirstDayOfWeek(now);
|
|
|
var weekEnd = weekStart.AddDays(7);
|
|
|
var list = await _db.Queryable<ProductionRecord>()
|
|
|
@@ -594,7 +594,7 @@ namespace TeamAAS_VP.Data
|
|
|
/// <returns></returns>
|
|
|
public async Task<Dictionary<int, Dictionary<string, int>>> GetDailyProductionByHourAndCategoryAsync(string productName)
|
|
|
{
|
|
|
- var now = DateTime.Now;
|
|
|
+ var now = DateTime.UtcNow;
|
|
|
var dayStart = now.Date;
|
|
|
var dayEnd = dayStart.AddDays(1);
|
|
|
var list = await _db.Queryable<ProductionRecord>()
|
|
|
@@ -637,7 +637,7 @@ namespace TeamAAS_VP.Data
|
|
|
public async Task RecordAlarmAsync(AlarmRecord alarm)
|
|
|
{
|
|
|
if (alarm == null) throw new ArgumentNullException(nameof(alarm));
|
|
|
- if (alarm.Time == default(DateTime)) alarm.Time = DateTime.Now;
|
|
|
+ if (alarm.Time == default(DateTime)) alarm.Time = DateTime.UtcNow;
|
|
|
await _db.Insertable(alarm).ExecuteCommandAsync();
|
|
|
}
|
|
|
|
|
|
@@ -670,7 +670,7 @@ namespace TeamAAS_VP.Data
|
|
|
try
|
|
|
{
|
|
|
if (result == null) throw new ArgumentNullException(nameof(result));
|
|
|
- if (result.Timestamp == default(DateTime)) result.Timestamp = DateTime.Now;
|
|
|
+ if (result.Timestamp == default(DateTime)) result.Timestamp = DateTime.UtcNow;
|
|
|
await _db.Insertable(result).ExecuteCommandAsync();
|
|
|
}
|
|
|
catch (Exception)
|
|
|
@@ -724,7 +724,7 @@ namespace TeamAAS_VP.Data
|
|
|
public async Task RecordScrewFeederBatchAsync(ScrewFeederBatchRecord record)
|
|
|
{
|
|
|
if (record == null) throw new ArgumentNullException(nameof(record));
|
|
|
- if (record.ChangeTime == default(DateTime)) record.ChangeTime = DateTime.Now;
|
|
|
+ if (record.ChangeTime == default(DateTime)) record.ChangeTime = DateTime.UtcNow;
|
|
|
record.Id = record.Id == Guid.Empty ? Guid.NewGuid() : record.Id;
|
|
|
await _db.Insertable(record).ExecuteCommandAsync();
|
|
|
}
|
|
|
@@ -798,7 +798,7 @@ namespace TeamAAS_VP.Data
|
|
|
public async Task RecordPhotoCaptureAsync(PhotoCaptureRecord record)
|
|
|
{
|
|
|
if (record == null) throw new ArgumentNullException(nameof(record));
|
|
|
- if (record.CaptureTime == default(DateTime)) record.CaptureTime = DateTime.Now;
|
|
|
+ if (record.CaptureTime == default(DateTime)) record.CaptureTime = DateTime.UtcNow;
|
|
|
record.Id = record.Id == Guid.Empty ? Guid.NewGuid() : record.Id;
|
|
|
await _db.Insertable(record).ExecuteCommandAsync();
|
|
|
}
|
|
|
@@ -852,7 +852,7 @@ namespace TeamAAS_VP.Data
|
|
|
public async Task RecordHeadChangeAsync(HeadChangeRecord record)
|
|
|
{
|
|
|
if (record == null) throw new ArgumentNullException(nameof(record));
|
|
|
- if (record.ChangeTime == default(DateTime)) record.ChangeTime = DateTime.Now;
|
|
|
+ if (record.ChangeTime == default(DateTime)) record.ChangeTime = DateTime.UtcNow;
|
|
|
record.Id = record.Id == Guid.Empty ? Guid.NewGuid() : record.Id;
|
|
|
await _db.Insertable(record).ExecuteCommandAsync();
|
|
|
}
|
|
|
@@ -916,7 +916,7 @@ namespace TeamAAS_VP.Data
|
|
|
{
|
|
|
var newRec = new HeadChangeRecord
|
|
|
{
|
|
|
- ChangeTime = DateTime.Now,
|
|
|
+ ChangeTime = DateTime.UtcNow,
|
|
|
HeadBatchNumber = string.Empty,
|
|
|
CurrentLockCount = 1,
|
|
|
OperatorName = operatorName
|
|
|
@@ -949,7 +949,7 @@ namespace TeamAAS_VP.Data
|
|
|
public async Task RecordNozzleChangeAsync(NozzleChangeRecord record)
|
|
|
{
|
|
|
if (record == null) throw new ArgumentNullException(nameof(record));
|
|
|
- if (record.ChangeTime == default(DateTime)) record.ChangeTime = DateTime.Now;
|
|
|
+ if (record.ChangeTime == default(DateTime)) record.ChangeTime = DateTime.UtcNow;
|
|
|
record.Id = record.Id == Guid.Empty ? Guid.NewGuid() : record.Id;
|
|
|
await _db.Insertable(record).ExecuteCommandAsync();
|
|
|
}
|
|
|
@@ -996,7 +996,7 @@ namespace TeamAAS_VP.Data
|
|
|
{
|
|
|
var newRec = new NozzleChangeRecord
|
|
|
{
|
|
|
- ChangeTime = DateTime.Now,
|
|
|
+ ChangeTime = DateTime.UtcNow,
|
|
|
NozzleBatchNumber = string.Empty,
|
|
|
CurrentLockCount = 1,
|
|
|
OperatorName = operatorName
|
|
|
@@ -1046,7 +1046,7 @@ namespace TeamAAS_VP.Data
|
|
|
{
|
|
|
var record = new NozzleChangeRecord
|
|
|
{
|
|
|
- ChangeTime = DateTime.Now.AddMinutes(-i * 10),
|
|
|
+ ChangeTime = DateTime.UtcNow.AddMinutes(-i * 10),
|
|
|
NozzleBatchNumber = $"Batch-{i}",
|
|
|
CurrentLockCount = i,
|
|
|
OperatorName = $"Operator-{i}"
|
|
|
@@ -1059,7 +1059,7 @@ namespace TeamAAS_VP.Data
|
|
|
{
|
|
|
var record = new HeadChangeRecord
|
|
|
{
|
|
|
- ChangeTime = DateTime.Now.AddMinutes(-i * 15),
|
|
|
+ ChangeTime = DateTime.UtcNow.AddMinutes(-i * 15),
|
|
|
HeadBatchNumber = $"HeadBatch-{i}",
|
|
|
CurrentLockCount = i,
|
|
|
OperatorName = $"HeadOperator-{i}"
|
|
|
@@ -1072,7 +1072,7 @@ namespace TeamAAS_VP.Data
|
|
|
{
|
|
|
var record = new ScrewFeederBatchRecord
|
|
|
{
|
|
|
- ChangeTime = DateTime.Now.AddMinutes(-i * 20),
|
|
|
+ ChangeTime = DateTime.UtcNow.AddMinutes(-i * 20),
|
|
|
BatchNumber = $"ScrewBatch-{i}",
|
|
|
FeederNumber = i + 1
|
|
|
};
|
|
|
@@ -1088,7 +1088,7 @@ namespace TeamAAS_VP.Data
|
|
|
ProductName = "产品1",
|
|
|
Category = (i % 2 == 0) ? "OK" : "NG",
|
|
|
Quantity = 1,
|
|
|
- Timestamp = DateTime.Now.AddMinutes(-i * 5),
|
|
|
+ Timestamp = DateTime.UtcNow.AddMinutes(-i * 5),
|
|
|
UserName = "TestUser",
|
|
|
Remark = $"TotalSeconds:1.10"
|
|
|
};
|
|
|
@@ -1101,7 +1101,7 @@ namespace TeamAAS_VP.Data
|
|
|
var result = new LockResult(i % 4, $"PN-{i % 5}", 10.5f, 0.3f, (i % 3 != 0))
|
|
|
{
|
|
|
ProductName = "产品1",
|
|
|
- Timestamp = DateTime.Now.AddMinutes(-i * 3),
|
|
|
+ Timestamp = DateTime.UtcNow.AddMinutes(-i * 3),
|
|
|
};
|
|
|
await RecordLockResultAsync(result);
|
|
|
}
|
|
|
@@ -1118,7 +1118,7 @@ namespace TeamAAS_VP.Data
|
|
|
CameraName = $"下相机",
|
|
|
ProductSN = $"SN-{i}",
|
|
|
IsSuccess = (i % 2 == 0),
|
|
|
- CaptureTime = DateTime.Now.AddMinutes(-i * 7),
|
|
|
+ CaptureTime = DateTime.UtcNow.AddMinutes(-i * 7),
|
|
|
ImagePath = $"/images/photo_{i}.jpg"
|
|
|
};
|
|
|
await RecordPhotoCaptureAsync(record);
|
|
|
@@ -1155,9 +1155,9 @@ namespace TeamAAS_VP.Data
|
|
|
public async Task<int> GetThrowNumberAsync()
|
|
|
{
|
|
|
//今天的起始时间
|
|
|
- var todayStart = DateTime.Now.Date;
|
|
|
+ var todayStart = DateTime.UtcNow.Date;
|
|
|
//今天的结束时间
|
|
|
- var todayEnd = DateTime.Now.Date;
|
|
|
+ var todayEnd = DateTime.UtcNow.Date;
|
|
|
todayEnd = todayEnd.AddDays(1);
|
|
|
//按照时间范围查询抛料的总数
|
|
|
var total = await _db.Queryable<ThrowRecord>()
|
|
|
@@ -1173,9 +1173,9 @@ namespace TeamAAS_VP.Data
|
|
|
public async Task ResetThrowNumberAsync()
|
|
|
{
|
|
|
//今天的起始时间
|
|
|
- var todayStart = DateTime.Now.Date;
|
|
|
+ var todayStart = DateTime.UtcNow.Date;
|
|
|
//今天的结束时间
|
|
|
- var todayEnd = DateTime.Now.Date;
|
|
|
+ var todayEnd = DateTime.UtcNow.Date;
|
|
|
todayEnd = todayEnd.AddDays(1);
|
|
|
await _db.Deleteable<ThrowRecord>().Where(r => r.DayTime >= todayStart && r.DayTime < todayEnd).ExecuteCommandAsync();
|
|
|
}
|
|
|
@@ -1245,18 +1245,25 @@ namespace TeamAAS_VP.Data
|
|
|
}
|
|
|
|
|
|
/// <summary>
|
|
|
- /// 通过产品的编码和颜色查询产品的名称
|
|
|
+ /// 通过产品的编码和颜色查询产品
|
|
|
/// </summary>
|
|
|
/// <param name="code"></param>
|
|
|
/// <returns></returns>
|
|
|
- public async Task<string> QueryProductFromMesAsync(string code, string color)
|
|
|
+ public async Task<ProductWithMes> QueryProductFromMesAsync(string code, string color)
|
|
|
{
|
|
|
var v = await _db.Queryable<ProductWithMes>().Where(r => r.ProductCode == code && r.ProductColor == color).FirstAsync();
|
|
|
- if (v == null || v.ProductName == null)
|
|
|
- {
|
|
|
- return "";
|
|
|
- }
|
|
|
- return v.ProductName;
|
|
|
+ return v;
|
|
|
+ }
|
|
|
+
|
|
|
+ /// <summary>
|
|
|
+ /// 通过产品名称的查询产品
|
|
|
+ /// </summary>
|
|
|
+ /// <param name="code"></param>
|
|
|
+ /// <returns></returns>
|
|
|
+ public async Task<ProductWithMes> QueryProductFromMesAsync(string name)
|
|
|
+ {
|
|
|
+ var v = await _db.Queryable<ProductWithMes>().Where(r => r.ProductName == name).FirstAsync();
|
|
|
+ return v;
|
|
|
}
|
|
|
#endregion
|
|
|
}
|