MdpSyncTaskConfigService.cs 28 KB

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