hrms-bangkok/hrms-api-backend
7
0
Fork 0
Code Issues Pull requests Projects Releases Packages 7 Wiki Activity Actions

Linear Flow (PlacementService) #224
All checks were successful
Build & Deploy Placement Service / build (push) Successful in 1m55s
Details

Browse source
This commit is contained in:
harid 2026-06-18 18:32:06 +07:00
parent 35179d8cfc
commit e926866918
5 changed files with 319 additions and 244 deletions
Download patch file Download diff file Expand all files Collapse all files

264
BMA.EHR.Placement.Service/Controllers/PlacementAppointmentController.cs
View file

@ -1041,24 +1041,32 @@ namespace BMA.EHR.Placement.Service.Controllers
remark = r.remark, remark = r.remark,
}).ToList(); }).ToList();
var baseAPIOrg = _configuration["API"]; #region Old: Circular Flow
var apiUrlOrg = $"{baseAPIOrg}/org/command/excexute/salary-current"; // var baseAPIOrg = _configuration["API"];
using (var client = new HttpClient()) // var apiUrlOrg = $"{baseAPIOrg}/org/command/excexute/salary-current";
{ // using (var client = new HttpClient())
client.DefaultRequestHeaders.Authorization = new AuthenticationHeaderValue("Bearer", token.Replace("Bearer ", "")); // {
client.DefaultRequestHeaders.Add("api-key", _configuration["API_KEY"]); // client.DefaultRequestHeaders.Authorization = new AuthenticationHeaderValue("Bearer", token.Replace("Bearer ", ""));
var _res = await client.PostAsJsonAsync(apiUrlOrg, new // client.DefaultRequestHeaders.Add("api-key", _configuration["API_KEY"]);
{ // var _res = await client.PostAsJsonAsync(apiUrlOrg, new
data = resultData, // {
}); // data = resultData,
var _result = await _res.Content.ReadAsStringAsync(); // });
if (_res.IsSuccessStatusCode) // var _result = await _res.Content.ReadAsStringAsync();
{ // if (_res.IsSuccessStatusCode)
data.ForEach(profile => profile.Status = "DONE"); // {
await _context.SaveChangesAsync(); // data.ForEach(profile => profile.Status = "DONE");
} // await _context.SaveChangesAsync();
} // }
return Success(); // }
#endregion
// New: Linear Flow - Task #224 ปรับให้เป็น process ที่ควรบันทึกตามลำดับ
data.ForEach(profile => profile.Status = "DONE");
await _context.SaveChangesAsync();
// Return resultData for Node to process directly (Linear Flow)
return Success(resultData);
} }
/// <summary> /// <summary>
@ -1257,24 +1265,32 @@ namespace BMA.EHR.Placement.Service.Controllers
remark = r.remark, remark = r.remark,
}).ToList(); }).ToList();
var baseAPIOrg = _configuration["API"]; #region Old: Circular Flow
var apiUrlOrg = $"{baseAPIOrg}/org/command/excexute/salary-current"; // var baseAPIOrg = _configuration["API"];
using (var client = new HttpClient()) // var apiUrlOrg = $"{baseAPIOrg}/org/command/excexute/salary-current";
{ // using (var client = new HttpClient())
client.DefaultRequestHeaders.Authorization = new AuthenticationHeaderValue("Bearer", token.Replace("Bearer ", "")); // {
client.DefaultRequestHeaders.Add("api-key", _configuration["API_KEY"]); // client.DefaultRequestHeaders.Authorization = new AuthenticationHeaderValue("Bearer", token.Replace("Bearer ", ""));
var _res = await client.PostAsJsonAsync(apiUrlOrg, new // client.DefaultRequestHeaders.Add("api-key", _configuration["API_KEY"]);
{ // var _res = await client.PostAsJsonAsync(apiUrlOrg, new
data = resultData, // {
}); // data = resultData,
var _result = await _res.Content.ReadAsStringAsync(); // });
if (_res.IsSuccessStatusCode) // var _result = await _res.Content.ReadAsStringAsync();
{ // if (_res.IsSuccessStatusCode)
data.ForEach(profile => profile.Status = "DONE"); // {
await _context.SaveChangesAsync(); // data.ForEach(profile => profile.Status = "DONE");
} // await _context.SaveChangesAsync();
} // }
return Success(); // }
#endregion
// New: Linear Flow - Task #224 ปรับให้เป็น process ที่ควรบันทึกตามลำดับ
data.ForEach(profile => profile.Status = "DONE");
await _context.SaveChangesAsync();
// Return resultData for Node to process directly (Linear Flow)
return Success(resultData);
} }
/// <summary> /// <summary>
@ -1457,24 +1473,32 @@ namespace BMA.EHR.Placement.Service.Controllers
remark = r.remark, remark = r.remark,
}).ToList(); }).ToList();
var baseAPIOrg = _configuration["API"]; #region Old: Circular Flow
var apiUrlOrg = $"{baseAPIOrg}/org/command/excexute/salary-employee-current"; // var baseAPIOrg = _configuration["API"];
using (var client = new HttpClient()) // var apiUrlOrg = $"{baseAPIOrg}/org/command/excexute/salary-employee-current";
{ // using (var client = new HttpClient())
client.DefaultRequestHeaders.Authorization = new AuthenticationHeaderValue("Bearer", token.Replace("Bearer ", "")); // {
client.DefaultRequestHeaders.Add("api-key", _configuration["API_KEY"]); // client.DefaultRequestHeaders.Authorization = new AuthenticationHeaderValue("Bearer", token.Replace("Bearer ", ""));
var _res = await client.PostAsJsonAsync(apiUrlOrg, new // client.DefaultRequestHeaders.Add("api-key", _configuration["API_KEY"]);
{ // var _res = await client.PostAsJsonAsync(apiUrlOrg, new
data = resultData, // {
}); // data = resultData,
var _result = await _res.Content.ReadAsStringAsync(); // });
if (_res.IsSuccessStatusCode) // var _result = await _res.Content.ReadAsStringAsync();
{ // if (_res.IsSuccessStatusCode)
data.ForEach(profile => profile.Status = "DONE"); // {
await _context.SaveChangesAsync(); // data.ForEach(profile => profile.Status = "DONE");
} // await _context.SaveChangesAsync();
} // }
return Success(); // }
#endregion
// New: Linear Flow - Task #224 ปรับให้เป็น process ที่ควรบันทึกตามลำดับ
data.ForEach(profile => profile.Status = "DONE");
await _context.SaveChangesAsync();
// Return resultData for Node to process directly (Linear Flow)
return Success(resultData);
} }
/// <summary> /// <summary>
@ -1662,24 +1686,32 @@ namespace BMA.EHR.Placement.Service.Controllers
remark = r.remark, remark = r.remark,
}).ToList(); }).ToList();
var baseAPIOrg = _configuration["API"]; #region Old: Circular Flow
var apiUrlOrg = $"{baseAPIOrg}/org/command/excexute/salary-employee-current"; // var baseAPIOrg = _configuration["API"];
using (var client = new HttpClient()) // var apiUrlOrg = $"{baseAPIOrg}/org/command/excexute/salary-employee-current";
{ // using (var client = new HttpClient())
client.DefaultRequestHeaders.Authorization = new AuthenticationHeaderValue("Bearer", token.Replace("Bearer ", "")); // {
client.DefaultRequestHeaders.Add("api-key", _configuration["API_KEY"]); // client.DefaultRequestHeaders.Authorization = new AuthenticationHeaderValue("Bearer", token.Replace("Bearer ", ""));
var _res = await client.PostAsJsonAsync(apiUrlOrg, new // client.DefaultRequestHeaders.Add("api-key", _configuration["API_KEY"]);
{ // var _res = await client.PostAsJsonAsync(apiUrlOrg, new
data = resultData, // {
}); // data = resultData,
var _result = await _res.Content.ReadAsStringAsync(); // });
if (_res.IsSuccessStatusCode) // var _result = await _res.Content.ReadAsStringAsync();
{ // if (_res.IsSuccessStatusCode)
data.ForEach(profile => profile.Status = "DONE"); // {
await _context.SaveChangesAsync(); // data.ForEach(profile => profile.Status = "DONE");
} // await _context.SaveChangesAsync();
} // }
return Success(); // }
#endregion
// New: Linear Flow - Task #224 ปรับให้เป็น process ที่ควรบันทึกตามลำดับ
data.ForEach(profile => profile.Status = "DONE");
await _context.SaveChangesAsync();
// Return resultData for Node to process directly (Linear Flow)
return Success(resultData);
} }
/// <summary> /// <summary>
@ -1890,24 +1922,32 @@ namespace BMA.EHR.Placement.Service.Controllers
remark = r.remark, remark = r.remark,
}).ToList(); }).ToList();
var baseAPIOrg = _configuration["API"]; #region Old: Circular Flow
var apiUrlOrg = $"{baseAPIOrg}/org/command/excexute/salary-current"; // var baseAPIOrg = _configuration["API"];
using (var client = new HttpClient()) // var apiUrlOrg = $"{baseAPIOrg}/org/command/excexute/salary-current";
{ // using (var client = new HttpClient())
client.DefaultRequestHeaders.Authorization = new AuthenticationHeaderValue("Bearer", token.Replace("Bearer ", "")); // {
client.DefaultRequestHeaders.Add("api-key", _configuration["API_KEY"]); // client.DefaultRequestHeaders.Authorization = new AuthenticationHeaderValue("Bearer", token.Replace("Bearer ", ""));
var _res = await client.PostAsJsonAsync(apiUrlOrg, new // client.DefaultRequestHeaders.Add("api-key", _configuration["API_KEY"]);
{ // var _res = await client.PostAsJsonAsync(apiUrlOrg, new
data = resultData, // {
}); // data = resultData,
var _result = await _res.Content.ReadAsStringAsync(); // });
if (_res.IsSuccessStatusCode) // var _result = await _res.Content.ReadAsStringAsync();
{ // if (_res.IsSuccessStatusCode)
data.ForEach(profile => profile.Status = "DONE"); // {
await _context.SaveChangesAsync(); // data.ForEach(profile => profile.Status = "DONE");
} // await _context.SaveChangesAsync();
} // }
return Success(); // }
#endregion
// New: Linear Flow - Task #224 ปรับให้เป็น process ที่ควรบันทึกตามลำดับ
data.ForEach(profile => profile.Status = "DONE");
await _context.SaveChangesAsync();
// Return resultData for Node to process directly (Linear Flow)
return Success(resultData);
} }
/// <summary> /// <summary>
@ -2053,24 +2093,32 @@ namespace BMA.EHR.Placement.Service.Controllers
remark = r.remark, remark = r.remark,
}).ToList(); }).ToList();
var baseAPIOrg = _configuration["API"]; #region Old: Circular Flow
var apiUrlOrg = $"{baseAPIOrg}/org/command/excexute/salary-current"; // var baseAPIOrg = _configuration["API"];
using (var client = new HttpClient()) // var apiUrlOrg = $"{baseAPIOrg}/org/command/excexute/salary-current";
{ // using (var client = new HttpClient())
client.DefaultRequestHeaders.Authorization = new AuthenticationHeaderValue("Bearer", token.Replace("Bearer ", "")); // {
client.DefaultRequestHeaders.Add("api-key", _configuration["API_KEY"]); // client.DefaultRequestHeaders.Authorization = new AuthenticationHeaderValue("Bearer", token.Replace("Bearer ", ""));
var _res = await client.PostAsJsonAsync(apiUrlOrg, new // client.DefaultRequestHeaders.Add("api-key", _configuration["API_KEY"]);
{ // var _res = await client.PostAsJsonAsync(apiUrlOrg, new
data = resultData, // {
}); // data = resultData,
var _result = await _res.Content.ReadAsStringAsync(); // });
if (_res.IsSuccessStatusCode) // var _result = await _res.Content.ReadAsStringAsync();
{ // if (_res.IsSuccessStatusCode)
data.ForEach(profile => profile.Status = "DONE"); // {
await _context.SaveChangesAsync(); // data.ForEach(profile => profile.Status = "DONE");
} // await _context.SaveChangesAsync();
} // }
return Success(); // }
#endregion
// New: Linear Flow - Task #224 ปรับให้เป็น process ที่ควรบันทึกตามลำดับ
data.ForEach(profile => profile.Status = "DONE");
await _context.SaveChangesAsync();
// Return resultData for Node to process directly (Linear Flow)
return Success(resultData);
} }
} }
} }

141
BMA.EHR.Placement.Service/Controllers/PlacementController.cs
View file

@ -2645,9 +2645,6 @@ namespace BMA.EHR.Placement.Service.Controllers
.Where(x => req.refIds.Select(x => x.refId).Contains(x.Id.ToString())) .Where(x => req.refIds.Select(x => x.refId).Contains(x.Id.ToString()))
.ToListAsync(); .ToListAsync();
// Task #224 ปรับให้เป็น process ที่ควรบันทึกตามลำดับ
data.ForEach(profile => profile.PlacementStatus = "DONE");
await _context.SaveChangesAsync();
var resultData = (from p in data var resultData = (from p in data
join r in req.refIds join r in req.refIds
@ -2692,24 +2689,32 @@ namespace BMA.EHR.Placement.Service.Controllers
remark = r.remark, remark = r.remark,
}).ToList(); }).ToList();
var baseAPIOrg = _configuration["API"]; #region Old: Circular Flow
var apiUrlOrg = $"{baseAPIOrg}/org/command/excexute/salary-current"; // var baseAPIOrg = _configuration["API"];
using (var client = new HttpClient()) // var apiUrlOrg = $"{baseAPIOrg}/org/command/excexute/salary-current";
{ // using (var client = new HttpClient())
client.DefaultRequestHeaders.Authorization = new AuthenticationHeaderValue("Bearer", token.Replace("Bearer ", "")); // {
client.DefaultRequestHeaders.Add("api-key", _configuration["API_KEY"]); // client.DefaultRequestHeaders.Authorization = new AuthenticationHeaderValue("Bearer", token.Replace("Bearer ", ""));
var _res = await client.PostAsJsonAsync(apiUrlOrg, new // client.DefaultRequestHeaders.Add("api-key", _configuration["API_KEY"]);
{ // var _res = await client.PostAsJsonAsync(apiUrlOrg, new
data = resultData, // {
}); // data = resultData,
//// var _result = await _res.Content.ReadAsStringAsync(); // });
//// if (_res.IsSuccessStatusCode) // //// var _result = await _res.Content.ReadAsStringAsync();
//// { // //// if (_res.IsSuccessStatusCode)
//// data.ForEach(profile => profile.PlacementStatus = "DONE"); // //// {
//// await _context.SaveChangesAsync(); // //// data.ForEach(profile => profile.PlacementStatus = "DONE");
//// } // //// await _context.SaveChangesAsync();
} // //// }
return Success(); // }
#endregion
// New: Linear Flow - Task #224 ปรับให้เป็น process ที่ควรบันทึกตามลำดับ
data.ForEach(profile => profile.PlacementStatus = "DONE");
await _context.SaveChangesAsync();
// Return resultData for Node to process directly (Linear Flow)
return Success(resultData);
} }
/// <summary> /// <summary>
@ -2890,9 +2895,6 @@ namespace BMA.EHR.Placement.Service.Controllers
.Where(x => req.refIds.Select(x => x.refId).Contains(x.Id.ToString())) .Where(x => req.refIds.Select(x => x.refId).Contains(x.Id.ToString()))
.ToListAsync(); .ToListAsync();
// Task #224 ปรับให้เป็น process ที่ควรบันทึกตามลำดับ
data.ForEach(profile => profile.PlacementStatus = "DONE");
await _context.SaveChangesAsync();
var resultData = (from p in data var resultData = (from p in data
join r in req.refIds join r in req.refIds
@ -2937,24 +2939,32 @@ namespace BMA.EHR.Placement.Service.Controllers
remark = r.remark, remark = r.remark,
}).ToList(); }).ToList();
var baseAPIOrg = _configuration["API"]; #region Old: Circular Flow
var apiUrlOrg = $"{baseAPIOrg}/org/command/excexute/salary-current"; // var baseAPIOrg = _configuration["API"];
using (var client = new HttpClient()) // var apiUrlOrg = $"{baseAPIOrg}/org/command/excexute/salary-current";
{ // using (var client = new HttpClient())
client.DefaultRequestHeaders.Authorization = new AuthenticationHeaderValue("Bearer", token.Replace("Bearer ", "")); // {
client.DefaultRequestHeaders.Add("api-key", _configuration["API_KEY"]); // client.DefaultRequestHeaders.Authorization = new AuthenticationHeaderValue("Bearer", token.Replace("Bearer ", ""));
var _res = await client.PostAsJsonAsync(apiUrlOrg, new // client.DefaultRequestHeaders.Add("api-key", _configuration["API_KEY"]);
{ // var _res = await client.PostAsJsonAsync(apiUrlOrg, new
data = resultData, // {
}); // data = resultData,
//// var _result = await _res.Content.ReadAsStringAsync(); // });
//// if (_res.IsSuccessStatusCode) // //// var _result = await _res.Content.ReadAsStringAsync();
//// { // //// if (_res.IsSuccessStatusCode)
//// data.ForEach(profile => profile.PlacementStatus = "DONE"); // //// {
//// await _context.SaveChangesAsync(); // //// data.ForEach(profile => profile.PlacementStatus = "DONE");
//// } // //// await _context.SaveChangesAsync();
} // //// }
return Success(); // }
#endregion
// New: Linear Flow - Task #224 ปรับให้เป็น process ที่ควรบันทึกตามลำดับ
data.ForEach(profile => profile.PlacementStatus = "DONE");
await _context.SaveChangesAsync();
// Return resultData for Node to process directly (Linear Flow)
return Success(resultData);
} }
/// <summary> /// <summary>
@ -3120,9 +3130,6 @@ namespace BMA.EHR.Placement.Service.Controllers
.Where(x => req.refIds.Select(x => x.refId).Contains(x.Id.ToString())) .Where(x => req.refIds.Select(x => x.refId).Contains(x.Id.ToString()))
.ToListAsync(); .ToListAsync();
// Task #224 ปรับให้เป็น process ที่ควรบันทึกตามลำดับ
data.ForEach(profile => profile.PlacementStatus = "DONE");
await _context.SaveChangesAsync();
var resultData = (from p in data var resultData = (from p in data
join r in req.refIds join r in req.refIds
@ -3165,24 +3172,32 @@ namespace BMA.EHR.Placement.Service.Controllers
remark = r.remark, remark = r.remark,
}).ToList(); }).ToList();
var baseAPIOrg = _configuration["API"]; #region Old: Circular Flow
var apiUrlOrg = $"{baseAPIOrg}/org/command/excexute/salary-current"; // var baseAPIOrg = _configuration["API"];
using (var client = new HttpClient()) // var apiUrlOrg = $"{baseAPIOrg}/org/command/excexute/salary-current";
{ // using (var client = new HttpClient())
client.DefaultRequestHeaders.Authorization = new AuthenticationHeaderValue("Bearer", token.Replace("Bearer ", "")); // {
client.DefaultRequestHeaders.Add("api-key", _configuration["API_KEY"]); // client.DefaultRequestHeaders.Authorization = new AuthenticationHeaderValue("Bearer", token.Replace("Bearer ", ""));
var _res = await client.PostAsJsonAsync(apiUrlOrg, new // client.DefaultRequestHeaders.Add("api-key", _configuration["API_KEY"]);
{ // var _res = await client.PostAsJsonAsync(apiUrlOrg, new
data = resultData, // {
}); // data = resultData,
//// var _result = await _res.Content.ReadAsStringAsync(); // });
//// if (_res.IsSuccessStatusCode) // //// var _result = await _res.Content.ReadAsStringAsync();
//// { // //// if (_res.IsSuccessStatusCode)
//// data.ForEach(profile => profile.PlacementStatus = "DONE"); // //// {
//// await _context.SaveChangesAsync(); // //// data.ForEach(profile => profile.PlacementStatus = "DONE");
//// } // //// await _context.SaveChangesAsync();
} // //// }
return Success(); // }
#endregion
// New: Linear Flow - Task #224 ปรับให้เป็น process ที่ควรบันทึกตามลำดับ
data.ForEach(profile => profile.PlacementStatus = "DONE");
await _context.SaveChangesAsync();
// Return resultData for Node to process directly (Linear Flow)
return Success(resultData);
} }
/// <summary> /// <summary>

66
BMA.EHR.Placement.Service/Controllers/PlacementOfficerController.cs
View file

@ -760,16 +760,6 @@ namespace BMA.EHR.Placement.Service.Controllers
.Where(x => req.refIds.Select(x => x.refId).Contains(x.Id.ToString())) .Where(x => req.refIds.Select(x => x.refId).Contains(x.Id.ToString()))
.ToListAsync(); .ToListAsync();
// Task #224 ปรับให้เป็น process ที่ควรบันทึกตามลำดับ
var firstRef = req.refIds.FirstOrDefault();
var commandNoText = firstRef != null ? $"{firstRef.commandNo}/{firstRef.commandYear.ToThaiYear()}" : null;
foreach (var profile in data)
{
profile.Status = "DONE";
profile.commandNo = commandNoText;
}
await _context.SaveChangesAsync();
var resultData = (from p in data var resultData = (from p in data
join r in req.refIds join r in req.refIds
on p.Id.ToString() equals r.refId on p.Id.ToString() equals r.refId
@ -811,28 +801,42 @@ namespace BMA.EHR.Placement.Service.Controllers
remark = r.remark, remark = r.remark,
}).ToList(); }).ToList();
var baseAPIOrg = _configuration["API"]; #region Old: Circular Flow
var apiUrlOrg = $"{baseAPIOrg}/org/command/excexute/salary"; // var baseAPIOrg = _configuration["API"];
using (var client = new HttpClient()) // var apiUrlOrg = $"{baseAPIOrg}/org/command/excexute/salary";
// using (var client = new HttpClient())
// {
// client.DefaultRequestHeaders.Authorization = new AuthenticationHeaderValue("Bearer", token.Replace("Bearer ", ""));
// client.DefaultRequestHeaders.Add("api-key", _configuration["API_KEY"]);
// var _res = await client.PostAsJsonAsync(apiUrlOrg, new
// {
// data = resultData,
// });
// //// var _result = await _res.Content.ReadAsStringAsync();
// //// if (_res.IsSuccessStatusCode)
// //// {
// //// foreach (var profile in data)
// //// {
// //// profile.Status = "DONE";
// //// profile.commandNo = resultData.Count > 0 ? $"{resultData[0].commandNo}/{resultData[0].commandYear.ToThaiYear()}" : null;
// //// }
// //// await _context.SaveChangesAsync();
// //// }
// }
#endregion
// New: Linear Flow - Task #224 ปรับให้เป็น process ที่ควรบันทึกตามลำดับ
var firstRef = req.refIds.FirstOrDefault();
var commandNoText = firstRef != null ? $"{firstRef.commandNo}/{firstRef.commandYear.ToThaiYear()}" : null;
data.ForEach(profile =>
{ {
client.DefaultRequestHeaders.Authorization = new AuthenticationHeaderValue("Bearer", token.Replace("Bearer ", "")); profile.Status = "DONE";
client.DefaultRequestHeaders.Add("api-key", _configuration["API_KEY"]); profile.commandNo = commandNoText;
var _res = await client.PostAsJsonAsync(apiUrlOrg, new });
{ await _context.SaveChangesAsync();
data = resultData,
}); // Return resultData for Node to process directly (Linear Flow)
//// var _result = await _res.Content.ReadAsStringAsync(); return Success(resultData);
//// if (_res.IsSuccessStatusCode)
//// {
//// foreach (var profile in data)
//// {
//// profile.Status = "DONE";
//// profile.commandNo = resultData.Count > 0 ? $"{resultData[0].commandNo}/{resultData[0].commandYear.ToThaiYear()}" : null;
//// }
//// await _context.SaveChangesAsync();
//// }
}
return Success();
} }
} }
} }

46
BMA.EHR.Placement.Service/Controllers/PlacementRepatriationController.cs
View file

@ -623,9 +623,6 @@ namespace BMA.EHR.Placement.Service.Controllers
var data = await _context.PlacementRepatriations var data = await _context.PlacementRepatriations
.Where(x => req.refIds.Select(x => x.refId).Contains(x.Id.ToString())) .Where(x => req.refIds.Select(x => x.refId).Contains(x.Id.ToString()))
.ToListAsync(); .ToListAsync();
// Task #224 ปรับให้เป็น process ที่ควรบันทึกตามลำดับ
data.ForEach(profile => profile.Status = "DONE");
await _context.SaveChangesAsync();
string? _null = null; string? _null = null;
var resultData = (from p in data var resultData = (from p in data
@ -668,25 +665,32 @@ namespace BMA.EHR.Placement.Service.Controllers
commandName = r.commandName, commandName = r.commandName,
remark = r.remark, remark = r.remark,
}).ToList(); }).ToList();
#region Old: Circular Flow
// var baseAPIOrg = _configuration["API"];
// var apiUrlOrg = $"{baseAPIOrg}/org/command/excexute/salary";
// using (var client = new HttpClient())
// {
// client.DefaultRequestHeaders.Authorization = new AuthenticationHeaderValue("Bearer", token.Replace("Bearer ", ""));
// client.DefaultRequestHeaders.Add("api-key", _configuration["API_KEY"]);
// var _res = await client.PostAsJsonAsync(apiUrlOrg, new
// {
// data = resultData,
// });
// // // var _result = await _res.Content.ReadAsStringAsync();
// // // if (_res.IsSuccessStatusCode)
// // // {
// // // data.ForEach(profile => profile.Status = "DONE");
// // // await _context.SaveChangesAsync();
// // // }
// }
#endregion
var baseAPIOrg = _configuration["API"]; // New: Linear Flow - Task #224ปรับให้เป็น process ที่ควรบันทึกตามลำดับ
var apiUrlOrg = $"{baseAPIOrg}/org/command/excexute/salary"; data.ForEach(profile => profile.Status = "DONE");
using (var client = new HttpClient()) await _context.SaveChangesAsync();
{
client.DefaultRequestHeaders.Authorization = new AuthenticationHeaderValue("Bearer", token.Replace("Bearer ", "")); // Return resultData for Node to process directly (Linear Flow)
client.DefaultRequestHeaders.Add("api-key", _configuration["API_KEY"]); return Success(resultData);
var _res = await client.PostAsJsonAsync(apiUrlOrg, new
{
data = resultData,
});
// // var _result = await _res.Content.ReadAsStringAsync();
// // if (_res.IsSuccessStatusCode)
// // {
// // data.ForEach(profile => profile.Status = "DONE");
// // await _context.SaveChangesAsync();
// // }
}
return Success();
} }
} }
} }

46
BMA.EHR.Placement.Service/Controllers/PlacementTransferController.cs
View file

@ -1148,9 +1148,6 @@ namespace BMA.EHR.Placement.Service.Controllers
var data = await _context.PlacementTransfers var data = await _context.PlacementTransfers
.Where(x => req.refIds.Select(x => x.refId).Contains(x.Id.ToString())) .Where(x => req.refIds.Select(x => x.refId).Contains(x.Id.ToString()))
.ToListAsync(); .ToListAsync();
// Task #224 ปรับให้เป็น process ที่ควรบันทึกตามลำดับ
data.ForEach(profile => profile.Status = "DONE");
await _context.SaveChangesAsync();
var resultData = (from p in data var resultData = (from p in data
join r in req.refIds join r in req.refIds
@ -1194,24 +1191,31 @@ namespace BMA.EHR.Placement.Service.Controllers
remark = r.remark, remark = r.remark,
}).ToList(); }).ToList();
var baseAPIOrg = _configuration["API"]; #region Old: Circular Flow
var apiUrlOrg = $"{baseAPIOrg}/org/command/excexute/salary"; // var baseAPIOrg = _configuration["API"];
using (var client = new HttpClient()) // var apiUrlOrg = $"{baseAPIOrg}/org/command/excexute/salary";
{ // using (var client = new HttpClient())
client.DefaultRequestHeaders.Authorization = new AuthenticationHeaderValue("Bearer", token.Replace("Bearer ", "")); // {
client.DefaultRequestHeaders.Add("api-key", _configuration["API_KEY"]); // client.DefaultRequestHeaders.Authorization = new AuthenticationHeaderValue("Bearer", token.Replace("Bearer ", ""));
var _res = await client.PostAsJsonAsync(apiUrlOrg, new // client.DefaultRequestHeaders.Add("api-key", _configuration["API_KEY"]);
{ // var _res = await client.PostAsJsonAsync(apiUrlOrg, new
data = resultData, // {
}); // data = resultData,
// // var _result = await _res.Content.ReadAsStringAsync(); // });
// // if (_res.IsSuccessStatusCode) // // // var _result = await _res.Content.ReadAsStringAsync();
// // { // // // if (_res.IsSuccessStatusCode)
// // data.ForEach(profile => profile.Status = "DONE"); // // // {
// // await _context.SaveChangesAsync(); // // // data.ForEach(profile => profile.Status = "DONE");
// // } // // // await _context.SaveChangesAsync();
} // // // }
return Success(); // }
#endregion
// New: Linear Flow - Task #224 ปรับให้เป็น process ที่ควรบันทึกตามลำดับ
data.ForEach(profile => profile.Status = "DONE");
// Return resultData for Node to process directly (Linear Flow)
return Success(resultData);
} }