yuangb/jinko.yikatong
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

fix 代码调试

Browse Source
This commit is contained in:
liguoyang
2024-03-30 22:45:11 +08:00
parent 4e17364f4d
commit 342a014dca
1 changed files with 9 additions and 19 deletions
Download Patch File Download Diff File Expand all files Collapse all files

28
Src/Dlhis.ScheduledTask/Jobs/MealSupplementHandlerJob.cs
View File

@@ -105,14 +105,6 @@ public class MealSupplementHandlerJob : BaseJob
}, 5); }, 5);
//更新餐补信息为成功(同步成功)
await DbContext.Updateable<MealSupplementRecordEntity>()
.SetColumns(x => x.Status == MealSupplementStatusEnumtype.Sucess)
.SetColumns(x => x.Sync == true)
.SetColumns(x => x.ModifiedTime == DateTime.Now)
.Where(x => x.UniqueId == mealSupplement.UniqueId)
.ExecuteCommandAsync();
var r = await _jinkoJIPService.SyncMealSupplementRecordsAsync(new List<SyncMealSupplementRecordRequest> var r = await _jinkoJIPService.SyncMealSupplementRecordsAsync(new List<SyncMealSupplementRecordRequest>
{ {
new() new()
@@ -123,8 +115,11 @@ public class MealSupplementHandlerJob : BaseJob
} }
}); });
//更新餐补信息为成功(同步成功)
await DbContext.Updateable<MealSupplementRecordEntity>() await DbContext.Updateable<MealSupplementRecordEntity>()
.SetColumns(x => x.Result == r) .SetColumns(x => x.Result == r)
.SetColumns(x => x.Status == MealSupplementStatusEnumtype.Sucess)
.SetColumns(x => x.Sync == true)
.SetColumns(x => x.ModifiedTime == DateTime.Now) .SetColumns(x => x.ModifiedTime == DateTime.Now)
.Where(x => x.UniqueId == mealSupplement.UniqueId) .Where(x => x.UniqueId == mealSupplement.UniqueId)
.ExecuteCommandAsync(); .ExecuteCommandAsync();
@@ -137,7 +132,7 @@ public class MealSupplementHandlerJob : BaseJob
await DbContext.Updateable<MealSupplementRecordEntity>() await DbContext.Updateable<MealSupplementRecordEntity>()
.SetColumns(x => x.Status == MealSupplementStatusEnumtype.Error) .SetColumns(x => x.Status == MealSupplementStatusEnumtype.Error)
.SetColumns(x => x.Result == ex.Message) .SetColumns(x => x.Result == ex.Message + " " + ex.StackTrace)
.SetColumns(x => x.ModifiedTime == DateTime.Now) .SetColumns(x => x.ModifiedTime == DateTime.Now)
.Where(x => x.UniqueId == mealSupplement.UniqueId) .Where(x => x.UniqueId == mealSupplement.UniqueId)
.ExecuteCommandAsync(); .ExecuteCommandAsync();
@@ -154,21 +149,13 @@ public class MealSupplementHandlerJob : BaseJob
{ {
Code = mealSupplement.Code, Code = mealSupplement.Code,
Amount = mealSupplement.Amount, Amount = mealSupplement.Amount,
Date = mealSupplement.Date, Date = mealSupplement.Date.Date,
Remark = mealSupplement.Remark, Remark = mealSupplement.Remark,
UniqueId = mealSupplement.UniqueId, UniqueId = mealSupplement.UniqueId,
}); });
(hnResponse == null || hnResponse.Code != 200).ThrowIfTrue("海宁餐补写入失败:" + hnResponse?.Message); (hnResponse == null || hnResponse.Code != 200).ThrowIfTrue("海宁餐补写入失败:" + hnResponse?.Message);
//更新餐补信息为成功(同步成功)
await DbContext.Updateable<MealSupplementRecordEntity>()
.SetColumns(x => x.Status == MealSupplementStatusEnumtype.Sucess)
.SetColumns(x => x.Sync == true)
.SetColumns(x => x.ModifiedTime == DateTime.Now)
.Where(x => x.UniqueId == mealSupplement.UniqueId)
.ExecuteCommandAsync();
var r = await _jinkoJIPService.SyncMealSupplementRecordsAsync(new List<SyncMealSupplementRecordRequest> var r = await _jinkoJIPService.SyncMealSupplementRecordsAsync(new List<SyncMealSupplementRecordRequest>
{ {
new() new()
@@ -179,8 +166,11 @@ public class MealSupplementHandlerJob : BaseJob
} }
}); });
//更新餐补信息为成功(同步成功)
await DbContext.Updateable<MealSupplementRecordEntity>() await DbContext.Updateable<MealSupplementRecordEntity>()
.SetColumns(x => x.Result == r) .SetColumns(x => x.Result == r)
.SetColumns(x => x.Status == MealSupplementStatusEnumtype.Sucess)
.SetColumns(x => x.Sync == true)
.SetColumns(x => x.ModifiedTime == DateTime.Now) .SetColumns(x => x.ModifiedTime == DateTime.Now)
.Where(x => x.UniqueId == mealSupplement.UniqueId) .Where(x => x.UniqueId == mealSupplement.UniqueId)
.ExecuteCommandAsync(); .ExecuteCommandAsync();
@@ -193,7 +183,7 @@ public class MealSupplementHandlerJob : BaseJob
await DbContext.Updateable<MealSupplementRecordEntity>() await DbContext.Updateable<MealSupplementRecordEntity>()
.SetColumns(x => x.Status == MealSupplementStatusEnumtype.Error) .SetColumns(x => x.Status == MealSupplementStatusEnumtype.Error)
.SetColumns(x => x.Result == ex.Message) .SetColumns(x => x.Result == ex.Message + " " + ex.StackTrace)
.SetColumns(x => x.ModifiedTime == DateTime.Now) .SetColumns(x => x.ModifiedTime == DateTime.Now)
.Where(x => x.UniqueId == mealSupplement.UniqueId) .Where(x => x.UniqueId == mealSupplement.UniqueId)
.ExecuteCommandAsync(); .ExecuteCommandAsync();