250 lines
18 KiB
C#
250 lines
18 KiB
C#
using HRM.BO;
|
|
using HRM.DA;
|
|
using Ease.Core.DataAccess;
|
|
using Ease.Core.Model;
|
|
using Ease.Core.Utility;
|
|
using System;
|
|
using System.Collections.Generic;
|
|
using System.Data;
|
|
using NPOI.SS.Formula.Functions;
|
|
using System.Text;
|
|
using Microsoft.Data.SqlClient;
|
|
using System.Linq;
|
|
using Azure;
|
|
using System.Runtime.ConstrainedExecution;
|
|
using static iTextSharp.text.pdf.AcroFields;
|
|
using System.Net;
|
|
using System.Security.Policy;
|
|
using static Org.BouncyCastle.Math.EC.ECCurve;
|
|
using System.Net.Http;
|
|
using Newtonsoft.Json.Linq;
|
|
using System.Net.Http.Headers;
|
|
using System.Threading.Tasks;
|
|
using iTextSharp.text.pdf.qrcode;
|
|
using Newtonsoft.Json;
|
|
using iTextSharp.text;
|
|
using Azure.Core;
|
|
|
|
namespace HRM.DA
|
|
{
|
|
public class ApiIntegrationService : IApiIntegrationService
|
|
{
|
|
private readonly HttpClient _httpClient;
|
|
//string tokenUrl = "https://oauthasservices-c4badc49a.ap1.hana.ondemand.com/oauth2/api/v1/token?grant_type=client_credentials";
|
|
//string clientId = "SF-Payroll";
|
|
//string clientSecret = "Berger@2024";
|
|
//string masterDataUrl = "https://e200367-iflmap.hcisbt.ap1.hana.ondemand.com/http/BergerPayroll/MaterData";
|
|
//string compensationDataUrl = "https://e200367-iflmap.hcisbt.ap1.hana.ondemand.com/http/BergerPayroll/CompensationData";
|
|
|
|
string tokenUrl = "https://oauthasservices-c3caaf40c.ap1.hana.ondemand.com/oauth2/api/v1/token?grant_type=client_credentials";
|
|
string clientId = "SF-Payroll";
|
|
string clientSecret = "Berger@24";
|
|
string masterDataUrl = "https://l200836-iflmap.hcisbp.ap1.hana.ondemand.com/http/BergerPayroll/MasterData";
|
|
string compensationDataUrl = "https://l200836-iflmap.hcisbp.ap1.hana.ondemand.com/http/BergerPayroll/CompensationData";
|
|
|
|
public ApiIntegrationService(HttpClient httpClient)
|
|
{
|
|
_httpClient = httpClient;
|
|
}
|
|
|
|
public async Task<Token> GetAccessTokenAsync()
|
|
{
|
|
Token token = null;
|
|
try
|
|
{
|
|
//using (var httpClient = new HttpClient())
|
|
//{
|
|
var request = new HttpRequestMessage(HttpMethod.Post, tokenUrl);
|
|
var authHeaderValue = Convert.ToBase64String(System.Text.Encoding.ASCII.GetBytes($"{clientId}:{clientSecret}"));
|
|
request.Headers.Authorization = new AuthenticationHeaderValue("Basic", authHeaderValue);
|
|
request.Content = new StringContent("", Encoding.UTF8, "application/x-www-form-urlencoded");
|
|
// httpClient.Timeout = TimeSpan.FromMinutes(10);
|
|
using (var response = await _httpClient.SendAsync(request))
|
|
{
|
|
if (response.StatusCode == System.Net.HttpStatusCode.OK)
|
|
{
|
|
string responseString = await response.Content.ReadAsStringAsync();
|
|
token = JsonConvert.DeserializeObject<Token>(responseString);
|
|
}
|
|
else
|
|
{
|
|
throw new Exception($"Failed to retrieve access token. Status code: {response.StatusCode}, Response: {await response.Content.ReadAsStringAsync()}");
|
|
}
|
|
}
|
|
// }
|
|
|
|
return token;
|
|
}
|
|
catch (Exception ex)
|
|
{
|
|
throw new Exception("An error occurred while retrieving the access token.", ex);
|
|
}
|
|
}
|
|
|
|
public async Task<DataIntegrationHeader> GetMasterDataAsync(string accessToken)
|
|
{
|
|
DataIntegrationHeader header = new DataIntegrationHeader();
|
|
header.Items = new List<DataIntegration>();
|
|
try
|
|
{
|
|
using (var httpClient = new HttpClient())
|
|
{
|
|
//var client = new HttpClient();
|
|
httpClient.DefaultRequestHeaders.Add("Authorization", "Bearer " +accessToken);
|
|
httpClient.Timeout = TimeSpan.FromMinutes(10);
|
|
var responseContent = await httpClient.GetStringAsync(masterDataUrl);
|
|
|
|
// var request = new HttpRequestMessage(HttpMethod.Get, masterDataUrl);
|
|
// request.Headers.Authorization = new AuthenticationHeaderValue("Bearer", accessToken);
|
|
//// request.Content = new StringContent("", Encoding.UTF8, "application/x-www-form-urlencoded");
|
|
// httpClient.Timeout = TimeSpan.FromMinutes(10);
|
|
//using (var response = await httpClient.SendAsync(request))
|
|
//{
|
|
if (responseContent != null)
|
|
{
|
|
// string responseContent = await response.Content.ReadAsStringAsync();
|
|
// DataTable dataTable = JsonConvert.DeserializeObject<DataTable>(responseContent);
|
|
// var root = JsonConvert.DeserializeObject<object>(responseContent);
|
|
var jsonObject = JObject.Parse(responseContent);
|
|
var items = jsonObject["row"];
|
|
DataTable dataTable = (DataTable)JsonConvert.DeserializeObject(items.ToString(), (typeof(DataTable)));
|
|
|
|
foreach (DataRow odRow in dataTable.Rows)
|
|
{
|
|
DataIntegration dataIntegration = new DataIntegration();
|
|
dataIntegration.EmployeeNo = !string.IsNullOrEmpty(odRow["EMPLOYEE_NO"].ToString()) ? odRow["EMPLOYEE_NO"].ToString() : string.Empty;
|
|
dataIntegration.EmployeeName = !string.IsNullOrEmpty(odRow["EMPLOYEE_NAME"].ToString()) ? odRow["EMPLOYEE_NAME"].ToString() : string.Empty;
|
|
dataIntegration.DesignationCode = !string.IsNullOrEmpty(odRow["DESIGNATION_CODE"].ToString()) ? odRow["DESIGNATION_CODE"].ToString() : string.Empty;
|
|
dataIntegration.Designation = !string.IsNullOrEmpty(odRow["DESIGNATION_NAME"].ToString()) ? odRow["DESIGNATION_NAME"].ToString() : string.Empty;
|
|
dataIntegration.DateOfBirth = !string.IsNullOrEmpty(odRow["DATE_OF_BIRTH"].ToString()) ? odRow["DATE_OF_BIRTH"].ToString() : string.Empty;
|
|
dataIntegration.DateOfJoining = !string.IsNullOrEmpty(odRow["DATE_OF_JOINING"].ToString()) ? odRow["DATE_OF_JOINING"].ToString() : string.Empty;
|
|
dataIntegration.DiscontinueDateRegion = !string.IsNullOrEmpty(odRow["DISCONTINUE_DATE_REGION"].ToString()) ? odRow["DISCONTINUE_DATE_REGION"].ToString() : string.Empty;
|
|
dataIntegration.ConfirmationDate = !string.IsNullOrEmpty(odRow["CONFIRMATION_DATE"].ToString()) ? odRow["CONFIRMATION_DATE"].ToString() : string.Empty;
|
|
dataIntegration.CategoryCode = !string.IsNullOrEmpty(odRow["CATEGORY_CODE"].ToString()) ? odRow["CATEGORY_CODE"].ToString() : string.Empty;
|
|
dataIntegration.Category = !string.IsNullOrEmpty(odRow["CATEGORY_NAME"].ToString()) ? odRow["CATEGORY_NAME"].ToString() : string.Empty;
|
|
dataIntegration.ReligionCode = !string.IsNullOrEmpty(odRow["RELIGION_CODE"].ToString()) ? odRow["RELIGION_CODE"].ToString() : string.Empty;
|
|
dataIntegration.Religion = !string.IsNullOrEmpty(odRow["RELIGION_NAME"].ToString()) ? odRow["RELIGION_NAME"].ToString() : string.Empty;
|
|
dataIntegration.MaritalStatus = !string.IsNullOrEmpty(odRow["MARITAL_STATUS"].ToString()) ? odRow["MARITAL_STATUS"].ToString() : string.Empty;
|
|
dataIntegration.Gender = !string.IsNullOrEmpty(odRow["GENDER"].ToString()) ? odRow["GENDER"].ToString() : string.Empty;
|
|
dataIntegration.TIN = !string.IsNullOrEmpty(odRow["TIN"].ToString()) ? odRow["TIN"].ToString() : string.Empty;
|
|
dataIntegration.PayScaleLevelCode = !string.IsNullOrEmpty(odRow["GRADE_CODE"].ToString()) ? odRow["GRADE_CODE"].ToString() : string.Empty;
|
|
dataIntegration.PayScaleLevel = !string.IsNullOrEmpty(odRow["GRADE_NAME"].ToString()) ? odRow["GRADE_NAME"].ToString() : string.Empty;
|
|
dataIntegration.GradeCode = !string.IsNullOrEmpty(odRow["Pay_Scale_Level_Code"].ToString()) ? odRow["Pay_Scale_Level_Code"].ToString() : string.Empty;
|
|
dataIntegration.Grade = !string.IsNullOrEmpty(odRow["Pay_Scale_Level"].ToString()) ? odRow["Pay_Scale_Level"].ToString() : string.Empty;
|
|
dataIntegration.IsForeignExpatriate = !string.IsNullOrEmpty(odRow["IS_FOREIGN_EXPATRIATE"].ToString()) ? odRow["IS_FOREIGN_EXPATRIATE"].ToString() : string.Empty;
|
|
dataIntegration.PFMembership = !string.IsNullOrEmpty(odRow["IS_PF_MEMBER"].ToString()) ? odRow["IS_PF_MEMBER"].ToString() : string.Empty;
|
|
dataIntegration.DivisionCode = !string.IsNullOrEmpty(odRow["DIVISION_CODE"].ToString()) ? odRow["DIVISION_CODE"].ToString() : string.Empty;
|
|
dataIntegration.Division = !string.IsNullOrEmpty(odRow["DIVISION_NAME"].ToString()) ? odRow["DIVISION_NAME"].ToString() : string.Empty;
|
|
dataIntegration.DepartmentCode = !string.IsNullOrEmpty(odRow["DEPARTMENT_CODE"].ToString()) ? odRow["DEPARTMENT_CODE"].ToString() : string.Empty;
|
|
dataIntegration.Department = !string.IsNullOrEmpty(odRow["DEPARTMENT_NAME"].ToString()) ? odRow["DEPARTMENT_NAME"].ToString() : string.Empty;
|
|
dataIntegration.SubDepartmentCode = !string.IsNullOrEmpty(odRow["SUB_DEPARTMENT_CODE"].ToString()) ? odRow["SUB_DEPARTMENT_CODE"].ToString() : string.Empty;
|
|
dataIntegration.SubDepartment = !string.IsNullOrEmpty(odRow["SUB_DEPARTMENT_NAME"].ToString()) ? odRow["SUB_DEPARTMENT_NAME"].ToString() : string.Empty;
|
|
dataIntegration.SectionCode = !string.IsNullOrEmpty(odRow["SECTION_CODE"].ToString()) ? odRow["SECTION_CODE"].ToString() : string.Empty;
|
|
dataIntegration.Section = !string.IsNullOrEmpty(odRow["SECTION_NAME"].ToString()) ? odRow["SECTION_NAME"].ToString() : string.Empty;
|
|
dataIntegration.LocationCode = !string.IsNullOrEmpty(odRow["LOCATION_CODE"].ToString()) ? odRow["LOCATION_CODE"].ToString() : string.Empty;
|
|
dataIntegration.Location = !string.IsNullOrEmpty(odRow["LOCATION_NAME"].ToString()) ? odRow["LOCATION_NAME"].ToString() : string.Empty;
|
|
dataIntegration.ZoneCode = !string.IsNullOrEmpty(odRow["ZONE_CODE"].ToString()) ? odRow["ZONE_CODE"].ToString() : string.Empty;
|
|
dataIntegration.Zone = !string.IsNullOrEmpty(odRow["ZONE_NAME"].ToString()) ? odRow["ZONE_NAME"].ToString() : string.Empty;
|
|
dataIntegration.RegionCode = !string.IsNullOrEmpty(odRow["REGION_CODE"].ToString()) ? odRow["REGION_CODE"].ToString() : string.Empty;
|
|
dataIntegration.RegionName = !string.IsNullOrEmpty(odRow["REGION_NAME"].ToString()) ? odRow["REGION_NAME"].ToString() : string.Empty;
|
|
dataIntegration.CostCenterCode = !string.IsNullOrEmpty(odRow["COST_CENTER_CODE"].ToString()) ? odRow["COST_CENTER_CODE"].ToString() : string.Empty;
|
|
dataIntegration.CostCenterName = !string.IsNullOrEmpty(odRow["COST_CENTER_NAME"].ToString()) ? odRow["COST_CENTER_NAME"].ToString() : string.Empty;
|
|
dataIntegration.AssignmentChangeDate = !string.IsNullOrEmpty(odRow["LIFE_CYCLE_EFFECT_DATE"].ToString()) ? odRow["LIFE_CYCLE_EFFECT_DATE"].ToString() : string.Empty;
|
|
dataIntegration.LIFE_CYCLE_EVENT = !string.IsNullOrEmpty(odRow["LIFE_CYCLE_EVENT"].ToString()) ? odRow["LIFE_CYCLE_EVENT"].ToString() : string.Empty;
|
|
dataIntegration.SalaryBankCode = !string.IsNullOrEmpty(odRow["EMPLOYEE_BANK_CODE"].ToString()) ? odRow["EMPLOYEE_BANK_CODE"].ToString() : string.Empty;
|
|
dataIntegration.SalaryBank = !string.IsNullOrEmpty(odRow["EMPLOYEE_BANK_NAME"].ToString()) ? odRow["EMPLOYEE_BANK_NAME"].ToString() : string.Empty;
|
|
dataIntegration.SalaryBranchCode = !string.IsNullOrEmpty(odRow["EMPLOYEE_BRANCH_CODE"].ToString()) ? odRow["EMPLOYEE_BRANCH_CODE"].ToString() : string.Empty;
|
|
dataIntegration.SalaryBranch = !string.IsNullOrEmpty(odRow["EMPLOYEE_BRANCH_NAME"].ToString()) ? odRow["EMPLOYEE_BRANCH_NAME"].ToString() : string.Empty;
|
|
dataIntegration.SalaryAccountNumber = !string.IsNullOrEmpty(odRow["EMPLOYEE_ACCOUNT_NUMBER"].ToString()) ? odRow["EMPLOYEE_ACCOUNT_NUMBER"].ToString() : string.Empty;
|
|
dataIntegration.SALARY_ACCOUNT_EFFECT_DATE = !string.IsNullOrEmpty(odRow["EMPLOYEE_ACCOUNT_EFFECT_DATE"].ToString()) ? odRow["EMPLOYEE_ACCOUNT_EFFECT_DATE"].ToString() : string.Empty;
|
|
dataIntegration.BasicSalaryEffectDate= !string.IsNullOrEmpty(odRow["COMPENSATION_EFFECT_DATE"].ToString()) ? odRow["COMPENSATION_EFFECT_DATE"].ToString() : string.Empty;
|
|
dataIntegration.BasicSalary = !string.IsNullOrEmpty(odRow["BASIC_SALARY"].ToString()) ? odRow["BASIC_SALARY"].ToString() : string.Empty;
|
|
dataIntegration.GrossSalary = !string.IsNullOrEmpty(odRow["GROSS_SALARY"].ToString()) ? odRow["GROSS_SALARY"].ToString() : string.Empty;
|
|
dataIntegration.SALARY_CHANGE_TYPE = !string.IsNullOrEmpty(odRow["COMPENSATION_EVENT"].ToString()) ? odRow["COMPENSATION_EVENT"].ToString() : string.Empty;
|
|
dataIntegration.Company = !string.IsNullOrEmpty(odRow["COMPANY_NAME"].ToString()) ? odRow["COMPANY_NAME"].ToString() : string.Empty;
|
|
dataIntegration.CompanyCode = !string.IsNullOrEmpty(odRow["COMPANY_CODE"].ToString()) ? odRow["COMPANY_CODE"].ToString() : string.Empty;
|
|
dataIntegration.EmailAddress = !string.IsNullOrEmpty(odRow["EMAIL_ADDRESS"].ToString()) ? odRow["EMAIL_ADDRESS"].ToString() : string.Empty;
|
|
dataIntegration.MobileNo = !string.IsNullOrEmpty(odRow["MOBILE_NUMBER"].ToString()) ? odRow["MOBILE_NUMBER"].ToString() : string.Empty;
|
|
header.Items.Add(dataIntegration);
|
|
}
|
|
|
|
}
|
|
else
|
|
{
|
|
//throw new Exception($"Failed to retrieve master data. Status code: {response.StatusCode}, Response: {await response.Content.ReadAsStringAsync()}");
|
|
throw new Exception($"Failed to retrieve master data");
|
|
}
|
|
// }
|
|
}
|
|
|
|
return header;
|
|
}
|
|
catch (Exception ex)
|
|
{
|
|
throw new Exception("Failed to retrieve master data. Please try again after a few minutes.", ex);
|
|
}
|
|
}
|
|
|
|
public async Task<IndividualAllowanceModel> GetConpensationDataAsync(string accessToken)
|
|
{
|
|
DataIntergrationIndividualAllowanceHeader header = new DataIntergrationIndividualAllowanceHeader();
|
|
var data = new IndividualAllowanceModel();
|
|
try
|
|
{
|
|
using (var httpClient = new HttpClient())
|
|
{
|
|
var request = new HttpRequestMessage(HttpMethod.Get, compensationDataUrl);
|
|
request.Headers.Authorization = new AuthenticationHeaderValue("Bearer", accessToken);
|
|
request.Content = new StringContent("", Encoding.UTF8, "application/x-www-form-urlencoded");
|
|
|
|
using (var response = await _httpClient.SendAsync(request))
|
|
{
|
|
if (response.IsSuccessStatusCode)
|
|
{
|
|
string responseContent = await response.Content.ReadAsStringAsync();
|
|
var jsonObject = JObject.Parse(responseContent);
|
|
JArray items = (JArray)jsonObject["row"];
|
|
data.row = new List<EmployeeData>();
|
|
foreach (JToken item in items)
|
|
{
|
|
EmployeeData empData= new EmployeeData();
|
|
empData.EMPLOYEE_NO = (string)item["EMPLOYEE_NO"];
|
|
empData.COMP_DATA = new List<compdata>();
|
|
|
|
// Example: Accessing COMP_DATA array if it exists
|
|
if (item["COMP_DATA"] != null)
|
|
{
|
|
JArray compDataArray = (JArray)item["COMP_DATA"];
|
|
foreach (JToken compData in compDataArray)
|
|
{
|
|
var compdata = new compdata();
|
|
compdata.ITEM_CODE = (string)compData["ITEM_CODE"];
|
|
compdata.ITEM_NAME = (string)compData["ITEM_NAME"];
|
|
compdata.AMOUNT = (string)compData["AMOUNT"];
|
|
compdata.FROM_DATE = (string)compData["FROM_DATE"];
|
|
compdata.TO_DATE = (string)compData["TO_DATE"];
|
|
empData.COMP_DATA.Add(compdata);
|
|
}
|
|
}
|
|
data.row.Add(empData);
|
|
}
|
|
|
|
//var obj = root.;
|
|
}
|
|
else
|
|
{
|
|
throw new Exception($"Failed to retrieve compensation data. Status code: {response.StatusCode}, Response: {await response.Content.ReadAsStringAsync()}");
|
|
}
|
|
}
|
|
}
|
|
|
|
return data;
|
|
}
|
|
catch (Exception ex)
|
|
{
|
|
throw new Exception("An error occurred while retrieving the master data.", ex);
|
|
}
|
|
}
|
|
|
|
}
|
|
} |