78 lines
3.1 KiB
C#
78 lines
3.1 KiB
C#
|
using Backend.Services.Implement;
|
|||
|
|
using Microsoft.Extensions.Logging;
|
|||
|
|
using Quartz;
|
|||
|
|
using Repository.BackendRepository.Interface;
|
|||
|
|
using System;
|
|||
|
|
using System.Collections.Generic;
|
|||
|
|
using System.Reflection;
|
|||
|
|
using System.Text;
|
|||
|
|
using System.Threading.Tasks;
|
|||
|
|
|
|||
|
|
namespace BackendWorkerService.Quartz.Jobs
|
|||
|
|
{
|
|||
|
|
/// <summary>
|
|||
|
|
/// 定時將資料表加入派送任務
|
|||
|
|
/// </summary>
|
|||
|
|
[DisallowConcurrentExecution]
|
|||
|
|
class RegularUpdateDBTableJob: IJob
|
|||
|
|
{
|
|||
|
|
private readonly ILogger<RegularUpdateDBTableJob> logger;
|
|||
|
|
private readonly IBackgroundServiceRepository backgroundServiceRepository;
|
|||
|
|
private readonly IBackendRepository backendRepository;
|
|||
|
|
|
|||
|
|
public RegularUpdateDBTableJob(
|
|||
|
|
ILogger<RegularUpdateDBTableJob> logger,
|
|||
|
|
IBackgroundServiceRepository backgroundServiceRepository,
|
|||
|
|
IBackendRepository backendRepository)
|
|||
|
|
{
|
|||
|
|
this.logger = logger;
|
|||
|
|
this.backgroundServiceRepository = backgroundServiceRepository;
|
|||
|
|
this.backendRepository = backendRepository;
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
public async Task Execute(IJobExecutionContext context)
|
|||
|
|
{
|
|||
|
|
try
|
|||
|
|
{
|
|||
|
|
logger.LogInformation("【RegularUpdateDBTableJob】【任務開始】");
|
|||
|
|
|
|||
|
|
//要派送的資料表
|
|||
|
|
List<string> db_tables = new List<string>() { "variable" };
|
|||
|
|
|
|||
|
|
foreach (var db_table in db_tables)
|
|||
|
|
{
|
|||
|
|
try
|
|||
|
|
{
|
|||
|
|
logger.LogInformation("【RegularUpdateDBTableJob】【新增資料表 [{0}] 至派送任務】", db_table);
|
|||
|
|
//取得資料表所有資料
|
|||
|
|
var temp_datas = (await backgroundServiceRepository.GetAllAsync<dynamic>(db_table, ""));
|
|||
|
|
|
|||
|
|
List<Dictionary<string, object>> dicts = new List<Dictionary<string, object>>();
|
|||
|
|
foreach (var temp_data in temp_datas)
|
|||
|
|
{
|
|||
|
|
var dict = new Dictionary<string, object>((IDictionary<string, object>)temp_data);
|
|||
|
|
|
|||
|
|
dicts.Add(dict);
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
await backendRepository.ManualInsertBackgroundServiceTask("", "", db_table, "purge_all_insert", dicts);
|
|||
|
|
|
|||
|
|
logger.LogError("【RegularUpdateDBTableJob】【新增成功 資料表 [{0}] 至派送任務】", db_table);
|
|||
|
|
}
|
|||
|
|
catch(Exception exception)
|
|||
|
|
{
|
|||
|
|
logger.LogError("【RegularUpdateDBTableJob】【新增失敗 資料表 [{0}] 至派送任務】", db_table);
|
|||
|
|
logger.LogError("【RegularUpdateDBTableJob】【新增失敗 資料表 [{0}] 至派送任務】[Exception]：{1}", db_table, exception.ToString());
|
|||
|
|
}
|
|||
|
|
}
|
|||
|
|
}
|
|||
|
|
catch (Exception exception)
|
|||
|
|
{
|
|||
|
|
logger.LogError("【RegularUpdateDBTableJob】【任務失敗】");
|
|||
|
|
logger.LogError("【RegularUpdateDBTableJob】【任務失敗】[Exception]：{0}", exception.ToString());
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
}
|
|||
|
|
}
|
|||
|
|
}
|