MdpSyncTaskConfigService.cs 29 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679
  1. using Admin.NET.Plugin.AiDOP.Dto.DataPlatform;
  2. using Admin.NET.Plugin.AiDOP.Entity.DataPlatform;
  3. using Admin.NET.Plugin.AiDOP.Order;
  4. namespace Admin.NET.Plugin.AiDOP.DataPlatform;
  5. /// <summary>
  6. /// 数据中台同步配置中心 API。
  7. /// </summary>
  8. [ApiDescriptionSettings(Order = 323, Description = "数据中台同步配置中心")]
  9. [Route("api/DataPlatform")]
  10. [NonUnify]
  11. public class MdpSyncTaskConfigService : IDynamicApiController, ITransient
  12. {
  13. private static readonly HashSet<string> ProtectedTaskCodes = new(StringComparer.OrdinalIgnoreCase)
  14. {
  15. "S1_MDP_SYNC_TRANSFORM",
  16. "S2_MDP_SYNC_TRANSFORM",
  17. "S3_MDP_SYNC_TRANSFORM",
  18. "S4_MDP_SYNC_TRANSFORM",
  19. "S5_MDP_SYNC_TRANSFORM",
  20. "S5_PURCHASE_RECEIPT_INBOUND",
  21. "S6_MDP_SYNC_TRANSFORM",
  22. "S6_IPQC_INSPECTION_INBOUND",
  23. "S7_MDP_SYNC_TRANSFORM",
  24. "S7_PRODUCTION_RECEIPT_INBOUND"
  25. };
  26. private readonly ISqlSugarClient _db;
  27. private readonly UserManager _userManager;
  28. public MdpSyncTaskConfigService(ISqlSugarClient db, UserManager userManager)
  29. {
  30. _db = db;
  31. _userManager = userManager;
  32. }
  33. [DisplayName("同步任务列表")]
  34. [HttpGet("sync-tasks")]
  35. public async Task<object> GetList([FromQuery] MdpSyncTaskListQuery input)
  36. {
  37. var tenantId = _userManager.TenantId;
  38. var page = input.Page <= 0 ? 1 : input.Page;
  39. var pageSize = input.PageSize <= 0 ? 10 : input.PageSize;
  40. var offset = (page - 1) * pageSize;
  41. var where = new List<string> { "(t.tenant_id = @TenantId OR t.tenant_id = 0)", "t.status = 1" };
  42. var pars = new List<SugarParameter> { new("@TenantId", tenantId) };
  43. if (!string.IsNullOrWhiteSpace(input.Keyword))
  44. {
  45. where.Add("(t.task_code LIKE @Keyword OR t.task_name LIKE @Keyword OR t.business_domain_name LIKE @Keyword)");
  46. pars.Add(new SugarParameter("@Keyword", $"%{input.Keyword.Trim()}%"));
  47. }
  48. if (!string.IsNullOrWhiteSpace(input.BusinessDomainCode))
  49. {
  50. where.Add("t.business_domain_code = @BusinessDomainCode");
  51. pars.Add(new SugarParameter("@BusinessDomainCode", input.BusinessDomainCode.Trim()));
  52. }
  53. if (input.Status.HasValue)
  54. {
  55. where[1] = "t.status = @Status";
  56. pars.Add(new SugarParameter("@Status", input.Status.Value));
  57. }
  58. var whereSql = string.Join(" AND ", where);
  59. var total = await _db.Ado.GetIntAsync($"SELECT COUNT(1) FROM mdp_sync_task t WHERE {whereSql}", pars);
  60. var list = await _db.Ado.SqlQueryAsync<MdpSyncTaskListRow>(
  61. $"""
  62. SELECT t.id AS Id, t.tenant_id AS TenantId, t.task_code AS TaskCode, t.task_name AS TaskName,
  63. t.task_type AS TaskType, t.business_domain_code AS BusinessDomainCode,
  64. t.business_domain_name AS BusinessDomainName, t.consumer_modules AS ConsumerModules,
  65. t.source_system_code AS SourceSystemCode, t.service_key AS ServiceKey,
  66. t.job_code AS JobCode, t.schedule_job_id AS ScheduleJobId, t.status AS Status,
  67. t.config_version AS ConfigVersion, t.description AS Description,
  68. sch.schedule_mode AS ScheduleMode,
  69. IFNULL(sch.auto_enabled, 1) AS AutoEnabled,
  70. IFNULL(sch.manual_enabled, 1) AS ManualEnabled,
  71. run.status AS LastRunStatus, run.start_time AS LastRunTime
  72. FROM mdp_sync_task t
  73. LEFT JOIN mdp_sync_task_schedule sch
  74. ON sch.tenant_id = t.tenant_id AND sch.task_code = t.task_code
  75. LEFT JOIN (
  76. SELECT job_code, MAX(start_time) AS last_run_time
  77. FROM mdp_transform_run_log
  78. WHERE {MdpMonitorService.BuildMdpRunLogTenantWhere(tenantId)}
  79. GROUP BY job_code
  80. ) latest ON latest.job_code = IFNULL(t.job_code, t.task_code)
  81. LEFT JOIN mdp_transform_run_log run
  82. ON run.job_code = latest.job_code AND run.start_time = latest.last_run_time
  83. WHERE {whereSql}
  84. ORDER BY t.task_code
  85. LIMIT {pageSize} OFFSET {offset}
  86. """,
  87. pars);
  88. return new { total, page, pageSize, list };
  89. }
  90. [DisplayName("同步任务详情")]
  91. [HttpGet("sync-tasks/{id:long}")]
  92. public async Task<object> GetDetail(long id)
  93. {
  94. var tenantId = _userManager.TenantId;
  95. var row = await _db.Ado.SqlQuerySingleAsync<MdpSyncTaskListRow>(
  96. $"""
  97. SELECT t.id AS Id, t.tenant_id AS TenantId, t.task_code AS TaskCode, t.task_name AS TaskName,
  98. t.task_type AS TaskType, t.business_domain_code AS BusinessDomainCode,
  99. t.business_domain_name AS BusinessDomainName, t.consumer_modules AS ConsumerModules,
  100. t.source_system_code AS SourceSystemCode, t.service_key AS ServiceKey,
  101. t.job_code AS JobCode, t.schedule_job_id AS ScheduleJobId, t.status AS Status,
  102. t.config_version AS ConfigVersion, t.description AS Description,
  103. sch.schedule_mode AS ScheduleMode,
  104. IFNULL(sch.auto_enabled, 1) AS AutoEnabled,
  105. IFNULL(sch.manual_enabled, 1) AS ManualEnabled,
  106. run.status AS LastRunStatus, run.start_time AS LastRunTime
  107. FROM mdp_sync_task t
  108. LEFT JOIN mdp_sync_task_schedule sch
  109. ON sch.tenant_id = t.tenant_id AND sch.task_code = t.task_code
  110. LEFT JOIN (
  111. SELECT job_code, MAX(start_time) AS last_run_time
  112. FROM mdp_transform_run_log
  113. WHERE {MdpMonitorService.BuildMdpRunLogTenantWhere(tenantId)}
  114. GROUP BY job_code
  115. ) latest ON latest.job_code = IFNULL(t.job_code, t.task_code)
  116. LEFT JOIN mdp_transform_run_log run
  117. ON run.job_code = latest.job_code AND run.start_time = latest.last_run_time
  118. WHERE t.id = @Id AND (t.tenant_id = @TenantId OR t.tenant_id = 0)
  119. LIMIT 1
  120. """,
  121. new SugarParameter("@Id", id),
  122. new SugarParameter("@TenantId", tenantId));
  123. if (row == null)
  124. throw Oops.Oh("同步任务不存在");
  125. return row;
  126. }
  127. [DisplayName("新增同步任务")]
  128. [HttpPost("sync-tasks")]
  129. public async Task<object> Create([FromBody] MdpSyncTaskUpsertInput input)
  130. {
  131. ValidateUpsert(input);
  132. var tenantId = _userManager.TenantId;
  133. var exists = await _db.Queryable<MdpSyncTask>()
  134. .Where(u => u.TenantId == tenantId && u.TaskCode == input.TaskCode.Trim())
  135. .AnyAsync();
  136. if (exists)
  137. throw Oops.Oh("任务编码已存在");
  138. var entity = MapUpsert(input, tenantId);
  139. entity.ConfigVersion = 1;
  140. entity.CreateTime = DateTime.Now;
  141. entity.UpdateTime = DateTime.Now;
  142. var id = await _db.Insertable(entity).ExecuteReturnBigIdentityAsync();
  143. await EnsureDefaultScheduleAsync(tenantId, entity.TaskCode, entity.ScheduleJobId);
  144. return new { id };
  145. }
  146. [DisplayName("更新同步任务")]
  147. [HttpPut("sync-tasks/{id:long}")]
  148. public async Task<object> Update(long id, [FromBody] MdpSyncTaskUpsertInput input)
  149. {
  150. ValidateUpsert(input);
  151. var tenantId = _userManager.TenantId;
  152. var entity = await FindEditableTaskAsync(id, tenantId);
  153. entity.TaskName = input.TaskName.Trim();
  154. entity.TaskType = string.IsNullOrWhiteSpace(input.TaskType) ? "SERVICE_SYNC" : input.TaskType.Trim();
  155. entity.BusinessDomainCode = input.BusinessDomainCode?.Trim();
  156. entity.BusinessDomainName = input.BusinessDomainName?.Trim();
  157. entity.ConsumerModules = input.ConsumerModules?.Trim();
  158. entity.SourceSystemCode = input.SourceSystemCode?.Trim();
  159. entity.ServiceKey = input.ServiceKey?.Trim();
  160. entity.JobCode = string.IsNullOrWhiteSpace(input.JobCode) ? input.TaskCode.Trim() : input.JobCode.Trim();
  161. entity.ScheduleJobId = input.ScheduleJobId?.Trim();
  162. entity.Status = input.Status <= 0 ? 0 : 1;
  163. entity.OwnerRole = input.OwnerRole?.Trim();
  164. entity.Description = input.Description?.Trim();
  165. entity.ConfigVersion += 1;
  166. entity.UpdateTime = DateTime.Now;
  167. if (!ProtectedTaskCodes.Contains(entity.TaskCode))
  168. entity.TaskCode = input.TaskCode.Trim();
  169. await _db.Updateable(entity).ExecuteCommandAsync();
  170. await SyncScheduleJobIdAsync(entity.TenantId, entity.TaskCode, entity.ScheduleJobId);
  171. return new { id = entity.Id };
  172. }
  173. [DisplayName("删除同步任务")]
  174. [HttpDelete("sync-tasks/{id:long}")]
  175. public async Task<object> Delete(long id)
  176. {
  177. var tenantId = _userManager.TenantId;
  178. var entity = await FindEditableTaskAsync(id, tenantId);
  179. if (ProtectedTaskCodes.Contains(entity.TaskCode) && entity.TenantId == 0)
  180. throw Oops.Oh("内置 MDP 同步任务不允许删除");
  181. entity.Status = 0;
  182. entity.UpdateTime = DateTime.Now;
  183. await _db.Updateable(entity).UpdateColumns(u => new { u.Status, u.UpdateTime }).ExecuteCommandAsync();
  184. return new { id };
  185. }
  186. [DisplayName("同步任务步骤列表")]
  187. [HttpGet("sync-tasks/{taskCode}/steps")]
  188. public async Task<object> GetSteps(string taskCode)
  189. {
  190. var tenantId = _userManager.TenantId;
  191. await EnsureTaskExistsAsync(taskCode, tenantId);
  192. var steps = await _db.Queryable<MdpSyncTaskStep>()
  193. .Where(u => u.TaskCode == taskCode && (u.TenantId == tenantId || u.TenantId == 0))
  194. .OrderBy(u => u.SortOrder)
  195. .ToListAsync();
  196. return steps.Select(MapStepRow).ToList();
  197. }
  198. [DisplayName("保存同步任务步骤")]
  199. [HttpPut("sync-tasks/{taskCode}/steps")]
  200. public async Task<object> SaveSteps(string taskCode, [FromBody] List<MdpSyncTaskStepRow> input)
  201. {
  202. var tenantId = _userManager.TenantId;
  203. var task = await EnsureTaskExistsAsync(taskCode, tenantId);
  204. var rows = input ?? new List<MdpSyncTaskStepRow>();
  205. var now = DateTime.Now;
  206. foreach (var row in rows)
  207. {
  208. if (string.IsNullOrWhiteSpace(row.StepCode) || string.IsNullOrWhiteSpace(row.StepName))
  209. throw Oops.Oh("步骤编码和名称不能为空");
  210. var stage = string.IsNullOrWhiteSpace(row.StageType) ? row.StepCode.Trim() : row.StageType.Trim();
  211. if (row.Enabled && Admin.NET.Plugin.AiDOP.DataPlatform.FileImport.MdpExcelValidation.IsPullStage(stage, row.StepCode))
  212. {
  213. if (!string.IsNullOrWhiteSpace(task.SourceSystemCode))
  214. {
  215. var src = await _db.Queryable<MdpSource>().FirstAsync(x => x.SourceCode == task.SourceSystemCode);
  216. if (src != null && string.Equals(src.SourceType, "FILE_EXCEL", StringComparison.OrdinalIgnoreCase))
  217. throw Oops.Oh("FILE_EXCEL 实体不得登记 Pull/Extract 步骤,请使用文件导入接口");
  218. }
  219. }
  220. var entity = await _db.Queryable<MdpSyncTaskStep>()
  221. .Where(u => u.TaskCode == taskCode && u.StepCode == row.StepCode && (u.TenantId == tenantId || u.TenantId == 0))
  222. .FirstAsync();
  223. if (entity == null)
  224. {
  225. entity = new MdpSyncTaskStep
  226. {
  227. TenantId = task.TenantId == 0 ? 0 : tenantId,
  228. TaskCode = taskCode,
  229. StepCode = row.StepCode.Trim(),
  230. StepName = row.StepName.Trim(),
  231. StageType = string.IsNullOrWhiteSpace(row.StageType) ? row.StepCode.Trim() : row.StageType.Trim(),
  232. ServiceMethodKey = row.ServiceMethodKey?.Trim(),
  233. Enabled = row.Enabled ? 1 : 0,
  234. SortOrder = row.SortOrder,
  235. Description = row.Description?.Trim(),
  236. CreateTime = now,
  237. UpdateTime = now
  238. };
  239. await _db.Insertable(entity).ExecuteCommandAsync();
  240. }
  241. else
  242. {
  243. entity.StepName = row.StepName.Trim();
  244. entity.StageType = string.IsNullOrWhiteSpace(row.StageType) ? row.StepCode.Trim() : row.StageType.Trim();
  245. entity.ServiceMethodKey = row.ServiceMethodKey?.Trim();
  246. entity.Enabled = row.Enabled ? 1 : 0;
  247. entity.SortOrder = row.SortOrder;
  248. entity.Description = row.Description?.Trim();
  249. entity.UpdateTime = now;
  250. await _db.Updateable(entity).ExecuteCommandAsync();
  251. }
  252. }
  253. task.ConfigVersion += 1;
  254. task.UpdateTime = now;
  255. await _db.Updateable(task).UpdateColumns(u => new { u.ConfigVersion, u.UpdateTime }).ExecuteCommandAsync();
  256. return new { count = rows.Count };
  257. }
  258. [DisplayName("同步任务调度配置")]
  259. [HttpGet("sync-tasks/{taskCode}/schedule")]
  260. public async Task<object> GetSchedule(string taskCode)
  261. {
  262. var tenantId = _userManager.TenantId;
  263. await EnsureTaskExistsAsync(taskCode, tenantId);
  264. var schedule = await FindScheduleAsync(taskCode, tenantId);
  265. if (schedule == null)
  266. return new MdpSyncTaskScheduleRow { TaskCode = taskCode, ScheduleMode = "CRON" };
  267. return MapScheduleRow(schedule);
  268. }
  269. [DisplayName("保存同步任务调度配置")]
  270. [HttpPut("sync-tasks/{taskCode}/schedule")]
  271. public async Task<object> SaveSchedule(string taskCode, [FromBody] MdpSyncTaskScheduleRow input)
  272. {
  273. var tenantId = _userManager.TenantId;
  274. var task = await EnsureTaskExistsAsync(taskCode, tenantId);
  275. var schedule = await FindScheduleAsync(taskCode, tenantId);
  276. var now = DateTime.Now;
  277. if (schedule == null)
  278. {
  279. schedule = new MdpSyncTaskSchedule
  280. {
  281. TenantId = task.TenantId == 0 ? 0 : tenantId,
  282. TaskCode = taskCode,
  283. CreateTime = now,
  284. UpdateTime = now
  285. };
  286. }
  287. schedule.ScheduleJobId = input.ScheduleJobId?.Trim() ?? task.ScheduleJobId;
  288. schedule.ScheduleMode = string.IsNullOrWhiteSpace(input.ScheduleMode) ? "CRON" : input.ScheduleMode.Trim();
  289. schedule.CronExpr = input.CronExpr?.Trim();
  290. schedule.CronDesc = input.CronDesc?.Trim();
  291. schedule.Timezone = string.IsNullOrWhiteSpace(input.Timezone) ? "Asia/Shanghai" : input.Timezone.Trim();
  292. schedule.AutoEnabled = input.AutoEnabled ? 1 : 0;
  293. schedule.ManualEnabled = input.ManualEnabled ? 1 : 0;
  294. schedule.RetryEnabled = input.RetryEnabled ? 1 : 0;
  295. schedule.MaxRetryCount = input.MaxRetryCount <= 0 ? 3 : input.MaxRetryCount;
  296. schedule.RetryIntervalSeconds = input.RetryIntervalSeconds <= 0 ? 300 : input.RetryIntervalSeconds;
  297. schedule.TimeoutSeconds = input.TimeoutSeconds <= 0 ? 3600 : input.TimeoutSeconds;
  298. schedule.MisfirePolicy = input.MisfirePolicy?.Trim();
  299. schedule.SyncWindowType = string.IsNullOrWhiteSpace(input.SyncWindowType) ? "FULL" : input.SyncWindowType.Trim();
  300. schedule.SyncWindowValue = input.SyncWindowValue?.Trim();
  301. schedule.LastScheduleTime = input.LastScheduleTime;
  302. schedule.NextScheduleTime = input.NextScheduleTime;
  303. schedule.AdminJobConfigJson = input.AdminJobConfigJson;
  304. schedule.Description = input.Description?.Trim();
  305. schedule.UpdateTime = now;
  306. if (schedule.Id <= 0)
  307. await _db.Insertable(schedule).ExecuteCommandAsync();
  308. else
  309. await _db.Updateable(schedule).ExecuteCommandAsync();
  310. task.ScheduleJobId = schedule.ScheduleJobId;
  311. task.ConfigVersion += 1;
  312. task.UpdateTime = now;
  313. await _db.Updateable(task).UpdateColumns(u => new { u.ScheduleJobId, u.ConfigVersion, u.UpdateTime }).ExecuteCommandAsync();
  314. return MapScheduleRow(schedule);
  315. }
  316. [DisplayName("同步 Admin.NET 调度快照")]
  317. [HttpPost("sync-tasks/{taskCode}/schedule/sync-admin-job")]
  318. public async Task<object> SyncAdminJob(string taskCode)
  319. {
  320. var tenantId = _userManager.TenantId;
  321. var task = await EnsureTaskExistsAsync(taskCode, tenantId);
  322. var schedule = await FindScheduleAsync(taskCode, tenantId) ?? new MdpSyncTaskSchedule
  323. {
  324. TenantId = task.TenantId == 0 ? 0 : tenantId,
  325. TaskCode = taskCode,
  326. ScheduleJobId = task.ScheduleJobId,
  327. ScheduleMode = "CRON",
  328. CreateTime = DateTime.Now,
  329. UpdateTime = DateTime.Now
  330. };
  331. schedule.AdminJobConfigJson = System.Text.Json.JsonSerializer.Serialize(new
  332. {
  333. scheduleJobId = schedule.ScheduleJobId ?? task.ScheduleJobId,
  334. message = "第一阶段仅保存 Admin.NET Job 绑定快照,不写回底层 Cron 配置。"
  335. });
  336. schedule.UpdateTime = DateTime.Now;
  337. if (schedule.Id <= 0)
  338. await _db.Insertable(schedule).ExecuteCommandAsync();
  339. else
  340. await _db.Updateable(schedule).UpdateColumns(u => new { u.AdminJobConfigJson, u.UpdateTime }).ExecuteCommandAsync();
  341. return new
  342. {
  343. taskCode,
  344. scheduleJobId = schedule.ScheduleJobId ?? task.ScheduleJobId,
  345. adminJobConfigJson = schedule.AdminJobConfigJson
  346. };
  347. }
  348. private async Task<MdpSyncTask> EnsureTaskExistsAsync(string taskCode, long tenantId)
  349. {
  350. if (string.IsNullOrWhiteSpace(taskCode))
  351. throw Oops.Oh("任务编码不能为空");
  352. var task = await _db.Queryable<MdpSyncTask>()
  353. .Where(u => u.TaskCode == taskCode && (u.TenantId == tenantId || u.TenantId == 0) && u.Status == 1)
  354. .OrderBy(u => u.TenantId, OrderByType.Desc)
  355. .FirstAsync();
  356. if (task == null)
  357. throw Oops.Oh("同步任务不存在");
  358. return task;
  359. }
  360. private async Task<MdpSyncTask> FindEditableTaskAsync(long id, long tenantId)
  361. {
  362. var entity = await _db.Queryable<MdpSyncTask>()
  363. .Where(u => u.Id == id && (u.TenantId == tenantId || u.TenantId == 0))
  364. .FirstAsync();
  365. if (entity == null)
  366. throw Oops.Oh("同步任务不存在");
  367. return entity;
  368. }
  369. private async Task<MdpSyncTaskSchedule?> FindScheduleAsync(string taskCode, long tenantId) =>
  370. await _db.Queryable<MdpSyncTaskSchedule>()
  371. .Where(u => u.TaskCode == taskCode && (u.TenantId == tenantId || u.TenantId == 0))
  372. .OrderBy(u => u.TenantId, OrderByType.Desc)
  373. .FirstAsync();
  374. private async Task EnsureDefaultScheduleAsync(long tenantId, string taskCode, string? scheduleJobId)
  375. {
  376. var exists = await _db.Queryable<MdpSyncTaskSchedule>()
  377. .Where(u => u.TaskCode == taskCode && (u.TenantId == tenantId || u.TenantId == 0))
  378. .AnyAsync();
  379. if (exists)
  380. return;
  381. await _db.Insertable(new MdpSyncTaskSchedule
  382. {
  383. TenantId = tenantId,
  384. TaskCode = taskCode,
  385. ScheduleJobId = scheduleJobId,
  386. ScheduleMode = "CRON",
  387. CronDesc = "按 Admin.NET 任务调度执行",
  388. AutoEnabled = 1,
  389. ManualEnabled = 1,
  390. RetryEnabled = 1,
  391. MaxRetryCount = 3,
  392. RetryIntervalSeconds = 300,
  393. TimeoutSeconds = 3600,
  394. SyncWindowType = "FULL",
  395. CreateTime = DateTime.Now,
  396. UpdateTime = DateTime.Now
  397. }).ExecuteCommandAsync();
  398. }
  399. private async Task SyncScheduleJobIdAsync(long tenantId, string taskCode, string? scheduleJobId)
  400. {
  401. var schedule = await FindScheduleAsync(taskCode, tenantId);
  402. if (schedule == null)
  403. {
  404. await EnsureDefaultScheduleAsync(tenantId, taskCode, scheduleJobId);
  405. return;
  406. }
  407. schedule.ScheduleJobId = scheduleJobId;
  408. schedule.UpdateTime = DateTime.Now;
  409. await _db.Updateable(schedule).UpdateColumns(u => new { u.ScheduleJobId, u.UpdateTime }).ExecuteCommandAsync();
  410. }
  411. private static void ValidateUpsert(MdpSyncTaskUpsertInput input)
  412. {
  413. if (string.IsNullOrWhiteSpace(input.TaskCode))
  414. throw Oops.Oh("任务编码不能为空");
  415. if (string.IsNullOrWhiteSpace(input.TaskName))
  416. throw Oops.Oh("任务名称不能为空");
  417. }
  418. private static MdpSyncTask MapUpsert(MdpSyncTaskUpsertInput input, long tenantId) =>
  419. new()
  420. {
  421. TenantId = tenantId,
  422. TaskCode = input.TaskCode.Trim(),
  423. TaskName = input.TaskName.Trim(),
  424. TaskType = string.IsNullOrWhiteSpace(input.TaskType) ? "SERVICE_SYNC" : input.TaskType.Trim(),
  425. BusinessDomainCode = input.BusinessDomainCode?.Trim(),
  426. BusinessDomainName = input.BusinessDomainName?.Trim(),
  427. ConsumerModules = input.ConsumerModules?.Trim(),
  428. SourceSystemCode = input.SourceSystemCode?.Trim(),
  429. ServiceKey = input.ServiceKey?.Trim(),
  430. JobCode = string.IsNullOrWhiteSpace(input.JobCode) ? input.TaskCode.Trim() : input.JobCode.Trim(),
  431. ScheduleJobId = input.ScheduleJobId?.Trim(),
  432. Status = input.Status <= 0 ? 0 : 1,
  433. OwnerRole = input.OwnerRole?.Trim(),
  434. Description = input.Description?.Trim()
  435. };
  436. private static MdpSyncTaskStepRow MapStepRow(MdpSyncTaskStep step) =>
  437. new()
  438. {
  439. Id = step.Id,
  440. StepCode = step.StepCode,
  441. StepName = step.StepName,
  442. StageType = step.StageType,
  443. ServiceMethodKey = step.ServiceMethodKey,
  444. Enabled = step.Enabled != 0,
  445. SortOrder = step.SortOrder,
  446. Description = step.Description
  447. };
  448. private static MdpSyncTaskScheduleRow MapScheduleRow(MdpSyncTaskSchedule schedule) =>
  449. new()
  450. {
  451. TaskCode = schedule.TaskCode,
  452. ScheduleJobId = schedule.ScheduleJobId,
  453. ScheduleMode = schedule.ScheduleMode,
  454. CronExpr = schedule.CronExpr,
  455. CronDesc = schedule.CronDesc,
  456. Timezone = schedule.Timezone,
  457. AutoEnabled = schedule.AutoEnabled != 0,
  458. ManualEnabled = schedule.ManualEnabled != 0,
  459. RetryEnabled = schedule.RetryEnabled != 0,
  460. MaxRetryCount = schedule.MaxRetryCount,
  461. RetryIntervalSeconds = schedule.RetryIntervalSeconds,
  462. TimeoutSeconds = schedule.TimeoutSeconds,
  463. MisfirePolicy = schedule.MisfirePolicy,
  464. SyncWindowType = schedule.SyncWindowType,
  465. SyncWindowValue = schedule.SyncWindowValue,
  466. LastScheduleTime = schedule.LastScheduleTime,
  467. NextScheduleTime = schedule.NextScheduleTime,
  468. AdminJobConfigJson = schedule.AdminJobConfigJson,
  469. Description = schedule.Description
  470. };
  471. [DisplayName("任务参数列表")]
  472. [HttpGet("sync-tasks/{taskCode}/params")]
  473. public async Task<object> GetParams(string taskCode)
  474. {
  475. var tenantId = _userManager.TenantId;
  476. var list = await _db.Queryable<MdpSyncTaskParam>()
  477. .Where(u => u.TaskCode == taskCode && (u.TenantId == tenantId || u.TenantId == 0))
  478. .OrderBy(u => u.SortOrder)
  479. .ToListAsync();
  480. return new
  481. {
  482. list = list.Select(p => new
  483. {
  484. p.Id,
  485. p.TaskCode,
  486. p.ScopeType,
  487. p.ScopeCode,
  488. p.ParamKey,
  489. p.ParamName,
  490. p.ParamType,
  491. p.ParamValue,
  492. p.DefaultValue,
  493. required = p.Required != 0,
  494. editable = p.Editable != 0,
  495. p.SortOrder,
  496. p.Description
  497. })
  498. };
  499. }
  500. [DisplayName("保存任务参数")]
  501. [HttpPut("sync-tasks/{taskCode}/params")]
  502. public async Task<object> SaveParams(string taskCode, [FromBody] List<MdpSyncTaskParamSaveItem> items)
  503. {
  504. var tenantId = _userManager.TenantId;
  505. items ??= [];
  506. await _db.Deleteable<MdpSyncTaskParam>()
  507. .Where(u => u.TaskCode == taskCode && u.TenantId == tenantId)
  508. .ExecuteCommandAsync();
  509. var now = DateTime.Now;
  510. var rows = items.Where(x => !string.IsNullOrWhiteSpace(x.ParamKey)).Select((x, i) => new MdpSyncTaskParam
  511. {
  512. TenantId = tenantId,
  513. TaskCode = taskCode,
  514. ScopeType = string.IsNullOrWhiteSpace(x.ScopeType) ? "TASK" : x.ScopeType.Trim(),
  515. ScopeCode = x.ScopeCode?.Trim() ?? "",
  516. ParamKey = x.ParamKey.Trim(),
  517. ParamName = string.IsNullOrWhiteSpace(x.ParamName) ? x.ParamKey.Trim() : x.ParamName.Trim(),
  518. ParamType = string.IsNullOrWhiteSpace(x.ParamType) ? "STRING" : x.ParamType.Trim(),
  519. ParamValue = x.ParamValue,
  520. DefaultValue = x.DefaultValue,
  521. Required = x.Required ? (byte)1 : (byte)0,
  522. Editable = x.Editable ? (byte)1 : (byte)0,
  523. SortOrder = x.SortOrder > 0 ? x.SortOrder : i + 1,
  524. Description = x.Description,
  525. CreateTime = now,
  526. UpdateTime = now
  527. }).ToList();
  528. if (rows.Count > 0)
  529. await _db.Insertable(rows).ExecuteCommandAsync();
  530. return new { ok = true, count = rows.Count };
  531. }
  532. [DisplayName("任务公式列表")]
  533. [HttpGet("sync-tasks/{taskCode}/formulas")]
  534. public async Task<object> GetFormulas(string taskCode)
  535. {
  536. var tenantId = _userManager.TenantId;
  537. var list = await _db.Queryable<MdpSyncTaskFormula>()
  538. .Where(u => u.TaskCode == taskCode && (u.TenantId == tenantId || u.TenantId == 0))
  539. .OrderBy(u => u.SortOrder)
  540. .ToListAsync();
  541. return new
  542. {
  543. list = list.Select(f => new
  544. {
  545. f.Id,
  546. f.TaskCode,
  547. f.StepCode,
  548. f.FormulaCode,
  549. f.FormulaName,
  550. f.MetricCode,
  551. f.FormulaExpr,
  552. f.FormulaPreview,
  553. f.Direction,
  554. f.YellowThreshold,
  555. f.RedThreshold,
  556. f.VersionNo,
  557. enabled = f.IsEnabled != 0,
  558. f.SortOrder,
  559. f.Description
  560. })
  561. };
  562. }
  563. [DisplayName("保存任务公式")]
  564. [HttpPut("sync-tasks/{taskCode}/formulas")]
  565. public async Task<object> SaveFormulas(string taskCode, [FromBody] List<MdpSyncTaskFormulaSaveItem> items)
  566. {
  567. var tenantId = _userManager.TenantId;
  568. items ??= [];
  569. await _db.Deleteable<MdpSyncTaskFormula>()
  570. .Where(u => u.TaskCode == taskCode && u.TenantId == tenantId)
  571. .ExecuteCommandAsync();
  572. var now = DateTime.Now;
  573. var rows = items.Where(x => !string.IsNullOrWhiteSpace(x.FormulaCode)).Select((x, i) => new MdpSyncTaskFormula
  574. {
  575. TenantId = tenantId,
  576. TaskCode = taskCode,
  577. StepCode = x.StepCode,
  578. FormulaCode = x.FormulaCode.Trim(),
  579. FormulaName = string.IsNullOrWhiteSpace(x.FormulaName) ? x.FormulaCode.Trim() : x.FormulaName.Trim(),
  580. MetricCode = x.MetricCode,
  581. FormulaExpr = x.FormulaExpr,
  582. FormulaPreview = x.FormulaPreview,
  583. Direction = string.IsNullOrWhiteSpace(x.Direction) ? "higher_is_better" : x.Direction.Trim(),
  584. YellowThreshold = x.YellowThreshold,
  585. RedThreshold = x.RedThreshold,
  586. VersionNo = x.VersionNo > 0 ? x.VersionNo : 1,
  587. IsEnabled = x.Enabled ? (byte)1 : (byte)0,
  588. SortOrder = x.SortOrder > 0 ? x.SortOrder : i + 1,
  589. Description = x.Description,
  590. CreateTime = now,
  591. UpdateTime = now
  592. }).ToList();
  593. if (rows.Count > 0)
  594. await _db.Insertable(rows).ExecuteCommandAsync();
  595. return new { ok = true, count = rows.Count };
  596. }
  597. }
  598. public class MdpSyncTaskParamSaveItem
  599. {
  600. public string? ScopeType { get; set; }
  601. public string? ScopeCode { get; set; }
  602. public string ParamKey { get; set; } = string.Empty;
  603. public string? ParamName { get; set; }
  604. public string? ParamType { get; set; }
  605. public string? ParamValue { get; set; }
  606. public string? DefaultValue { get; set; }
  607. public bool Required { get; set; }
  608. public bool Editable { get; set; } = true;
  609. public int SortOrder { get; set; }
  610. public string? Description { get; set; }
  611. }
  612. public class MdpSyncTaskFormulaSaveItem
  613. {
  614. public string? StepCode { get; set; }
  615. public string FormulaCode { get; set; } = string.Empty;
  616. public string? FormulaName { get; set; }
  617. public string? MetricCode { get; set; }
  618. public string? FormulaExpr { get; set; }
  619. public string? FormulaPreview { get; set; }
  620. public string? Direction { get; set; }
  621. public decimal? YellowThreshold { get; set; }
  622. public decimal? RedThreshold { get; set; }
  623. public int VersionNo { get; set; } = 1;
  624. public bool Enabled { get; set; } = true;
  625. public int SortOrder { get; set; }
  626. public string? Description { get; set; }
  627. }