เพิ่ม import data in base
This commit is contained in:
AnandaTon
parent
547a02187d
commit
0ca15769f8
1 changed files with 513 additions and 0 deletions
|
|
@ -19,15 +19,27 @@ import HttpSuccess from "../interfaces/http-success";
|
|||
import HttpError from "../interfaces/http-error";
|
||||
import HttpStatusCode from "../interfaces/http-status";
|
||||
import { UseInterceptors } from "@nestjs/common";
|
||||
import { Profile } from "../entities/Profile";
|
||||
import { FileInterceptor } from "@nestjs/platform-express";
|
||||
import * as xlsx from "xlsx";
|
||||
import { ProfileEducation } from "../entities/ProfileEducation";
|
||||
import { ProfileSalary } from "../entities/ProfileSalary";
|
||||
import { ProfileFamilyCouple } from "../entities/ProfileFamilyCouple";
|
||||
import { ProfileFamilyMother } from "../entities/ProfileFamilyMother";
|
||||
import { ProfileFamilyFather } from "../entities/ProfileFamilyFather";
|
||||
import { ProfileEmployee } from "../entities/ProfileEmployee";
|
||||
|
||||
@Route("api/v1/org/upload")
|
||||
@Tags("UPLOAD")
|
||||
@Security("bearerAuth")
|
||||
export class ImportDataController extends Controller {
|
||||
private educationRepository = AppDataSource.getRepository(ProfileEducation);
|
||||
private profileFamilyCoupleRepository = AppDataSource.getRepository(ProfileFamilyCouple);
|
||||
private profileFamilyMotherRepository = AppDataSource.getRepository(ProfileFamilyMother);
|
||||
private profileFamilyFatherRepository = AppDataSource.getRepository(ProfileFamilyFather);
|
||||
private salaryRepository = AppDataSource.getRepository(ProfileSalary);
|
||||
private profileRepo = AppDataSource.getRepository(Profile);
|
||||
private profileEmpRepo = AppDataSource.getRepository(ProfileEmployee);
|
||||
/**
|
||||
* API upload EDU
|
||||
*
|
||||
|
|
@ -81,4 +93,505 @@ export class ImportDataController extends Controller {
|
|||
}),
|
||||
);
|
||||
}
|
||||
/**
|
||||
*
|
||||
* @param id
|
||||
* @param file
|
||||
* @param request
|
||||
* @returns
|
||||
*/
|
||||
@Post("uploadSQL")
|
||||
@UseInterceptors(FileInterceptor("file"))
|
||||
async UploadFileSQL(
|
||||
@UploadedFile() file: Express.Multer.File,
|
||||
// @Request() request: { user: Record<string, any> },
|
||||
) {
|
||||
const workbook = xlsx.read(file.buffer, { type: "buffer" });
|
||||
const sheetName = workbook.SheetNames[0]; // Assuming we're reading the first sheet
|
||||
const sheet = workbook.Sheets[sheetName];
|
||||
const getProFile = xlsx.utils.sheet_to_json(sheet);
|
||||
let profiles: any = [];
|
||||
await Promise.all(
|
||||
getProFile.map(async (item: any) => {
|
||||
// Create a new Profile entity and assign fields from the parsed data
|
||||
|
||||
const profile = new ProfileEmployee();
|
||||
// Check if the profile already exists
|
||||
const existingProfile = await this.profileEmpRepo.findOne({
|
||||
where: { id: item["id"] },
|
||||
});
|
||||
// If profile exists, skip saving
|
||||
if (existingProfile) {
|
||||
return;
|
||||
}
|
||||
// Assign fields from the item to the profile entity
|
||||
profile.id = item["id"];
|
||||
// profile.createdAt = item["createdUserId"] == "NULL" ? null : new Date(item["createdAt"]);
|
||||
profile.createdUserId = item["createdUserId"] == "NULL" ? null : item["createdUserId"];
|
||||
// profile.lastUpdatedAt =
|
||||
// item["createdUserId"] == "NULL" ? null : new Date(item["lastUpdatedAt"]);
|
||||
profile.lastUpdateUserId =
|
||||
item["lastUpdateUserId"] == "NULL" ? null : item["lastUpdateUserId"];
|
||||
profile.createdFullName =
|
||||
item["createdFullName"] == "NULL" ? null : item["createdFullName"];
|
||||
profile.lastUpdateFullName =
|
||||
item["lastUpdateFullName"] == "NULL" ? null : item["lastUpdateFullName"];
|
||||
profile.prefix = item["prefix"] == "NULL" ? null : item["prefix"];
|
||||
profile.firstName = item["firstName"] == "NULL" ? null : item["firstName"];
|
||||
profile.lastName = item["lastName"] == "NULL" ? null : item["lastName"];
|
||||
profile.citizenId = item["citizenId"] == "NULL" ? null : item["citizenId"];
|
||||
profile.position = item["position"] == "NULL" ? null : item["position"];
|
||||
profile.posLevelId = item["posLevelId"] == "NULL" ? null : item["posLevelId"];
|
||||
profile.posTypeId = item["posTypeId"] == "NULL" ? null : item["posTypeId"];
|
||||
profile.email = item["email"] == "NULL" ? null : item["email"];
|
||||
profile.phone = item["phone"] == "NULL" ? null : item["phone"];
|
||||
profile.keycloak = item["keycloak"] == "NULL" ? null : item["keycloak"];
|
||||
profile.isProbation = item["isProbation"] == "NULL" ? null : item["isProbation"];
|
||||
// profile.dateRetire = item["dateRetire"] == "NULL" ? null : new Date(item["dateRetire"]);
|
||||
// profile.birthDate = item["birthDate"] == "NULL" ? null : new Date(item["birthDate"]);
|
||||
profile.salaryLevel = item["salaryLevel"] == "NULL" ? null : item["salaryLevel"];
|
||||
profile.ethnicity = item["ethnicity"] == "NULL" ? null : item["ethnicity"];
|
||||
profile.telephoneNumber =
|
||||
item["telephoneNumber"] == "NULL" ? null : item["telephoneNumber"];
|
||||
profile.group = item["group"] == "NULL" ? null : item["group"];
|
||||
profile.gender = item["gender"] == "NULL" ? null : item["gender"];
|
||||
profile.relationship = item["relationship"] == "NULL" ? null : item["relationship"];
|
||||
profile.religion = item["religion"] == "NULL" ? null : item["religion"];
|
||||
profile.bloodGroup = item["bloodGroup"] == "NULL" ? null : item["bloodGroup"];
|
||||
profile.rank = item["rank"] == "NULL" ? null : item["rank"];
|
||||
profile.employeeClass = item["employeeClass"] == "NULL" ? null : item["employeeClass"];
|
||||
profile.avatar = item["avatar"] == "NULL" ? null : item["avatar"];
|
||||
// profile.dateRetireLaw =
|
||||
// item["dateRetireLaw"] == "NULL" ? null : new Date(item["dateRetireLaw"]);
|
||||
profile.registrationAddress =
|
||||
item["registrationAddress"] == "NULL" ? null : item["registrationAddress"];
|
||||
profile.registrationProvinceId =
|
||||
item["registrationProvinceId"] == "NULL" ? null : item["registrationProvinceId"];
|
||||
profile.registrationDistrictId =
|
||||
item["registrationDistrictId"] == "NULL" ? null : item["registrationDistrictId"];
|
||||
profile.registrationSubDistrictId =
|
||||
item["registrationSubDistrictId"] == "NULL" ? null : item["registrationSubDistrictId"];
|
||||
profile.registrationZipCode =
|
||||
item["registrationZipCode"] == "NULL" ? null : item["registrationZipCode"];
|
||||
profile.currentAddress = item["currentAddress"] == "NULL" ? null : item["currentAddress"];
|
||||
profile.currentProvinceId =
|
||||
item["currentProvinceId"] == "NULL" ? null : item["currentProvinceId"];
|
||||
profile.currentDistrictId =
|
||||
item["currentDistrictId"] == "NULL" ? null : item["currentDistrictId"];
|
||||
profile.currentSubDistrictId =
|
||||
item["currentSubDistrictId"] == "NULL" ? null : item["currentSubDistrictId"];
|
||||
profile.currentZipCode = item["currentZipCode"] == "NULL" ? null : item["currentZipCode"];
|
||||
profile.avatarName = item["avatarName"] == "NULL" ? null : item["avatarName"];
|
||||
profile.nationality = item["nationality"] == "NULL" ? null : item["nationality"];
|
||||
// profile.dateAppoint = item["dateAppoint"] == "NULL" ? null : new Date(item["dateAppoint"]);
|
||||
// profile.dateStart = item["dateStart"] == "NULL" ? null : new Date(item["dateStart"]);
|
||||
profile.govAgeAbsent = item["govAgeAbsent"] == "NULL" ? null : item["govAgeAbsent"];
|
||||
profile.govAgePlus = item["govAgePlus"] == "NULL" ? null : item["govAgePlus"];
|
||||
profile.reasonSameDate = item["reasonSameDate"] == "NULL" ? null : item["reasonSameDate"];
|
||||
profiles.push(profile);
|
||||
}),
|
||||
);
|
||||
await this.profileEmpRepo.save(profiles);
|
||||
return new HttpSuccess(getProFile);
|
||||
}
|
||||
|
||||
@Post("uploadSQLEdu")
|
||||
@UseInterceptors(FileInterceptor("file"))
|
||||
async UploadFileSQLEdu(
|
||||
@UploadedFile() file: Express.Multer.File,
|
||||
// @Request() request: { user: Record<string, any> },
|
||||
) {
|
||||
const workbook = xlsx.read(file.buffer, { type: "buffer" });
|
||||
const sheetName = workbook.SheetNames[0]; // Assuming we're reading the first sheet
|
||||
const sheet = workbook.Sheets[sheetName];
|
||||
const getProFile = xlsx.utils.sheet_to_json(sheet);
|
||||
let profiles: any = [];
|
||||
await Promise.all(
|
||||
getProFile.map(async (item: any) => {
|
||||
// Create a new Profile entity and assign fields from the parsed data
|
||||
|
||||
const profile = new ProfileEducation();
|
||||
// Check if the profile already exists
|
||||
const existingProfile = await this.educationRepository.findOne({
|
||||
where: { id: item["id"] },
|
||||
});
|
||||
// If profile exists, skip saving
|
||||
if (existingProfile) {
|
||||
return;
|
||||
}
|
||||
// Assign fields from the item to the profile entit
|
||||
|
||||
profile.id = item["id"] == "NULL" ? null : item["id"];
|
||||
// profile.createdAt = item["createdAt"] == "NULL" ? null : new Date(item["createdAt"]);
|
||||
profile.createdUserId = item["createdUserId"] == "NULL" ? null : item["createdUserId"];
|
||||
// profile.lastUpdatedAt =
|
||||
// item["lastUpdatedAt"] == "NULL" ? null : new Date(item["lastUpdatedAt"]);
|
||||
profile.lastUpdateUserId =
|
||||
item["lastUpdateUserId"] == "NULL" ? null : item["lastUpdateUserId"];
|
||||
profile.createdFullName =
|
||||
item["createdFullName"] == "NULL" ? null : item["createdFullName"];
|
||||
profile.lastUpdateFullName =
|
||||
item["lastUpdateFullName"] == "NULL" ? null : item["lastUpdateFullName"];
|
||||
profile.profileId = item["profileId"] == "NULL" ? null : item["profileId"];
|
||||
profile.country = item["country"] == "NULL" ? null : item["country"];
|
||||
profile.degree = item["degree"] == "NULL" ? null : item["degree"];
|
||||
profile.duration = item["duration"] == "NULL" ? null : item["duration"];
|
||||
profile.durationYear = item["durationYear"] == "NULL" ? null : item["durationYear"];
|
||||
profile.field = item["field"] == "NULL" ? null : item["field"];
|
||||
// profile.finishDate = item["finishDate"] == "NULL" ? null : new Date(item["finishDate"]);
|
||||
profile.fundName = item["fundName"] == "NULL" ? null : item["fundName"];
|
||||
profile.gpa = item["gpa"] == "NULL" ? null : item["gpa"];
|
||||
profile.institute = item["institute"] == "NULL" ? null : item["institute"];
|
||||
profile.other = item["other"] == "NULL" ? null : item["other"];
|
||||
// profile.startDate = item["startDate"] == "NULL" ? null : new Date(item["startDate"]);
|
||||
// profile.endDate = item["endDate"] == "NULL" ? null : new Date(item["endDate"]);
|
||||
profile.educationLevel = item["educationLevel"] == "NULL" ? null : item["educationLevel"];
|
||||
profile.educationLevelId =
|
||||
item["educationLevelId"] == "NULL" ? null : item["educationLevelId"];
|
||||
profile.positionPath = item["positionPath"] == "NULL" ? null : item["positionPath"];
|
||||
profile.positionPathId = item["positionPathId"] == "NULL" ? null : item["positionPathId"];
|
||||
profile.isDate = item["isDate"] == "NULL" ? null : item["isDate"];
|
||||
profile.isEducation = item["isEducation"] == "NULL" ? null : item["isEducation"];
|
||||
profile.note = item["note"] == "NULL" ? null : item["note"];
|
||||
profile.profileEmployeeId =
|
||||
item["profileEmployeeId"] == "NULL" ? null : item["profileEmployeeId"];
|
||||
|
||||
profiles.push(profile);
|
||||
}),
|
||||
);
|
||||
await this.educationRepository.save(profiles);
|
||||
return new HttpSuccess(getProFile);
|
||||
}
|
||||
|
||||
@Post("uploadSQL-Officer")
|
||||
@UseInterceptors(FileInterceptor("file"))
|
||||
async UploadFileSqlOfficer(
|
||||
@UploadedFile() file: Express.Multer.File,
|
||||
// @Request() request: { user: Record<string, any> },
|
||||
) {
|
||||
const workbook = xlsx.read(file.buffer, { type: "buffer" });
|
||||
const sheetName = workbook.SheetNames[0]; // Assuming we're reading the first sheet
|
||||
const sheet = workbook.Sheets[sheetName];
|
||||
const getProFile = xlsx.utils.sheet_to_json(sheet);
|
||||
let profiles: any = [];
|
||||
await Promise.all(
|
||||
getProFile.map(async (item: any) => {
|
||||
// Create a new Profile entity and assign fields from the parsed data
|
||||
|
||||
const profile = new Profile();
|
||||
// Check if the profile already exists
|
||||
const existingProfile = await this.profileRepo.findOne({
|
||||
where: { id: item["id"] },
|
||||
});
|
||||
// If profile exists, skip saving
|
||||
if (existingProfile) {
|
||||
return;
|
||||
}
|
||||
// Assign fields from the item to the profile entit
|
||||
|
||||
profile.id = item["id"] == "NULL" ? null : item["id"];
|
||||
// profile.createdAt = item["createdAt"] == "NULL" ? null : new Date(item["createdAt"]);
|
||||
profile.createdUserId = item["createdUserId"] == "NULL" ? null : item["createdUserId"];
|
||||
// profile.lastUpdatedAt =
|
||||
// item["lastUpdatedAt"] == "NULL" ? null : new Date(item["lastUpdatedAt"]);
|
||||
profile.lastUpdateUserId =
|
||||
item["lastUpdateUserId"] == "NULL" ? null : item["lastUpdateUserId"];
|
||||
profile.createdFullName =
|
||||
item["createdFullName"] == "NULL" ? null : item["createdFullName"];
|
||||
profile.lastUpdateFullName =
|
||||
item["lastUpdateFullName"] == "NULL" ? null : item["lastUpdateFullName"];
|
||||
profile.prefix = item["prefix"] == "NULL" ? null : item["prefix"];
|
||||
profile.firstName = item["firstName"] == "NULL" ? null : item["firstName"];
|
||||
profile.lastName = item["lastName"] == "NULL" ? null : item["lastName"];
|
||||
profile.citizenId = item["citizenId"] == "NULL" ? null : item["citizenId"];
|
||||
profile.position = item["position"] == "NULL" ? null : item["position"];
|
||||
profile.posTypeId = item["posTypeId"] == "NULL" ? null : item["posTypeId"];
|
||||
profile.posLevelId = item["posLevelId"] == "NULL" ? null : item["posLevelId"];
|
||||
profile.keycloak = item["keycloak"] == "NULL" ? null : item["keycloak"];
|
||||
profile.email = item["email"] == "NULL" ? null : item["email"];
|
||||
profile.phone = item["phone"] == "NULL" ? null : item["phone"];
|
||||
profile.isProbation = item["isProbation"] == "NULL" ? null : item["isProbation"];
|
||||
// profile.dateRetire = item["dateRetire"] == "NULL" ? null : new Date(item["dateRetire"]);
|
||||
// profile.birthDate = item["birthDate"] == "NULL" ? null : new Date(item["birthDate"]);
|
||||
profile.rank = item["rank"] == "NULL" ? null : item["rank"];
|
||||
profile.isLeave = item["isLeave"] == "NULL" ? null : item["isLeave"];
|
||||
// profile.dateAppoint = item["dateAppoint"] == "NULL" ? null : new Date(item["dateAppoint"]);
|
||||
// profile.dateStart = item["dateStart"] == "NULL" ? null : new Date(item["dateStart"]);
|
||||
profile.govAgeAbsent = item["govAgeAbsent"] == "NULL" ? null : item["govAgeAbsent"];
|
||||
profile.govAgePlus = item["govAgePlus"] == "NULL" ? null : item["govAgePlus"];
|
||||
profile.reasonSameDate = item["reasonSameDate"] == "NULL" ? null : item["reasonSameDate"];
|
||||
profile.ethnicity = item["ethnicity"] == "NULL" ? null : item["ethnicity"];
|
||||
profile.telephoneNumber =
|
||||
item["telephoneNumber"] == "NULL" ? null : item["telephoneNumber"];
|
||||
profile.nationality = item["nationality"] == "NULL" ? null : item["nationality"];
|
||||
profile.gender = item["gender"] == "NULL" ? null : item["gender"];
|
||||
profile.relationship = item["relationship"] == "NULL" ? null : item["relationship"];
|
||||
profile.religion = item["religion"] == "NULL" ? null : item["religion"];
|
||||
profile.bloodGroup = item["bloodGroup"] == "NULL" ? null : item["bloodGroup"];
|
||||
profile.registrationAddress =
|
||||
item["registrationAddress"] == "NULL" ? null : item["registrationAddress"];
|
||||
profile.registrationProvinceId =
|
||||
item["registrationProvinceId"] == "NULL" ? null : item["registrationProvinceId"];
|
||||
profile.registrationDistrictId =
|
||||
item["registrationDistrictId"] == "NULL" ? null : item["registrationDistrictId"];
|
||||
profile.registrationSubDistrictId =
|
||||
item["registrationSubDistrictId"] == "NULL" ? null : item["registrationSubDistrictId"];
|
||||
profile.registrationZipCode =
|
||||
item["registrationZipCode"] == "NULL" ? null : item["registrationZipCode"];
|
||||
profile.currentAddress = item["currentAddress"] == "NULL" ? null : item["currentAddress"];
|
||||
profile.currentProvinceId =
|
||||
item["currentProvinceId"] == "NULL" ? null : item["currentProvinceId"];
|
||||
profile.currentDistrictId =
|
||||
item["currentDistrictId"] == "NULL" ? null : item["currentDistrictId"];
|
||||
profile.currentSubDistrictId =
|
||||
item["currentSubDistrictId"] == "NULL" ? null : item["currentSubDistrictId"];
|
||||
profile.currentZipCode = item["currentZipCode"] == "NULL" ? null : item["currentZipCode"];
|
||||
profile.avatar = item["avatar"] == "NULL" ? null : item["avatar"];
|
||||
profile.avatarName = item["avatarName"] == "NULL" ? null : item["avatarName"];
|
||||
// profile.dateRetireLaw =
|
||||
// item["dateRetireLaw"] == "NULL" ? null : new Date(item["dateRetireLaw"]);
|
||||
profile.leaveReason = item["leaveReason"] == "NULL" ? null : item["leaveReason"];
|
||||
profile.dutyTimeId = item["dutyTimeId"] == "NULL" ? null : item["dutyTimeId"];
|
||||
// profile.dutyTimeEffectiveDate =
|
||||
// item["dutyTimeEffectiveDate"] == "NULL" ? null : new Date(item["dutyTimeEffectiveDate"]);
|
||||
|
||||
profiles.push(profile);
|
||||
}),
|
||||
);
|
||||
await this.profileRepo.save(profiles);
|
||||
return new HttpSuccess(getProFile);
|
||||
}
|
||||
|
||||
@Post("uploadSQLFamilly-Father")
|
||||
@UseInterceptors(FileInterceptor("file"))
|
||||
async UploadFileSQLFamilly(
|
||||
@UploadedFile() file: Express.Multer.File,
|
||||
// @Request() request: { user: Record<string, any> },
|
||||
) {
|
||||
const workbook = xlsx.read(file.buffer, { type: "buffer" });
|
||||
const sheetName = workbook.SheetNames[0]; // Assuming we're reading the first sheet
|
||||
const sheet = workbook.Sheets[sheetName];
|
||||
const getProFile = xlsx.utils.sheet_to_json(sheet);
|
||||
let profiles: any = [];
|
||||
await Promise.all(
|
||||
getProFile.map(async (item: any) => {
|
||||
// Create a new Profile entity and assign fields from the parsed data
|
||||
|
||||
const profile = new ProfileFamilyFather();
|
||||
// Check if the profile already exists
|
||||
const existingProfile = await this.profileFamilyFatherRepository.findOne({
|
||||
where: { id: item["id"] },
|
||||
});
|
||||
// If profile exists, skip saving
|
||||
if (existingProfile) {
|
||||
return;
|
||||
}
|
||||
// Assign fields from the item to the profile entit
|
||||
|
||||
profile.id = item["id"] == "NULL" ? null : item["id"];
|
||||
// profile.createdAt = item["createdAt"] == "NULL" ? null : new Date(item["createdAt"]);
|
||||
profile.createdUserId = item["createdUserId"] == "NULL" ? null : item["createdUserId"];
|
||||
// profile.lastUpdatedAt =
|
||||
// item["lastUpdatedAt"] == "NULL" ? null : new Date(item["lastUpdatedAt"]);
|
||||
profile.lastUpdateUserId =
|
||||
item["lastUpdateUserId"] == "NULL" ? null : item["lastUpdateUserId"];
|
||||
profile.createdFullName =
|
||||
item["createdFullName"] == "NULL" ? null : item["createdFullName"];
|
||||
profile.lastUpdateFullName =
|
||||
item["lastUpdateFullName"] == "NULL" ? null : item["lastUpdateFullName"];
|
||||
profile.fatherPrefix = item["fatherPrefix"] == "NULL" ? null : item["fatherPrefix"];
|
||||
profile.fatherFirstName =
|
||||
item["fatherFirstName"] == "NULL" ? null : item["fatherFirstName"];
|
||||
profile.fatherLastName = item["fatherLastName"] == "NULL" ? null : item["fatherLastName"];
|
||||
profile.fatherCareer = item["fatherCareer"] == "NULL" ? null : item["fatherCareer"];
|
||||
profile.fatherCitizenId =
|
||||
item["fatherCitizenId"] == "NULL" ? null : item["fatherCitizenId"];
|
||||
profile.fatherLive = item["fatherLive"] == "NULL" ? null : item["fatherLive"];
|
||||
profile.profileId = item["profileId"] == "NULL" ? null : item["profileId"];
|
||||
profile.profileEmployeeId =
|
||||
item["profileEmployeeId"] == "NULL" ? null : item["profileEmployeeId"];
|
||||
profiles.push(profile);
|
||||
}),
|
||||
);
|
||||
await this.profileFamilyFatherRepository.save(profiles);
|
||||
return new HttpSuccess(getProFile);
|
||||
}
|
||||
|
||||
@Post("uploadSQLFamilly-Mother")
|
||||
@UseInterceptors(FileInterceptor("file"))
|
||||
async UploadFileSQLFamillyMother(
|
||||
@UploadedFile() file: Express.Multer.File,
|
||||
// @Request() request: { user: Record<string, any> },
|
||||
) {
|
||||
const workbook = xlsx.read(file.buffer, { type: "buffer" });
|
||||
const sheetName = workbook.SheetNames[0]; // Assuming we're reading the first sheet
|
||||
const sheet = workbook.Sheets[sheetName];
|
||||
const getProFile = xlsx.utils.sheet_to_json(sheet);
|
||||
let profiles: any = [];
|
||||
await Promise.all(
|
||||
getProFile.map(async (item: any) => {
|
||||
// Create a new Profile entity and assign fields from the parsed data
|
||||
|
||||
const profile = new ProfileFamilyMother();
|
||||
// Check if the profile already exists
|
||||
const existingProfile = await this.profileFamilyMotherRepository.findOne({
|
||||
where: { id: item["id"] },
|
||||
});
|
||||
// If profile exists, skip saving
|
||||
if (existingProfile) {
|
||||
return;
|
||||
}
|
||||
// Assign fields from the item to the profile entit
|
||||
|
||||
profile.id = item["id"] == "NULL" ? null : item["id"];
|
||||
// profile.createdAt = item["createdAt"] == "NULL" ? null : new Date(item["createdAt"]);
|
||||
profile.createdUserId = item["createdUserId"] == "NULL" ? null : item["createdUserId"];
|
||||
// profile.lastUpdatedAt =
|
||||
// item["lastUpdatedAt"] == "NULL" ? null : new Date(item["lastUpdatedAt"]);
|
||||
profile.lastUpdateUserId =
|
||||
item["lastUpdateUserId"] == "NULL" ? null : item["lastUpdateUserId"];
|
||||
profile.createdFullName =
|
||||
item["createdFullName"] == "NULL" ? null : item["createdFullName"];
|
||||
profile.lastUpdateFullName =
|
||||
item["lastUpdateFullName"] == "NULL" ? null : item["lastUpdateFullName"];
|
||||
profile.motherPrefix = item["motherPrefix"] == "NULL" ? null : item["motherPrefix"];
|
||||
profile.motherFirstName =
|
||||
item["motherFirstName"] == "NULL" ? null : item["motherFirstName"];
|
||||
profile.motherLastName = item["motherLastName"] == "NULL" ? null : item["motherLastName"];
|
||||
profile.motherCareer = item["motherCareer"] == "NULL" ? null : item["motherCareer"];
|
||||
profile.motherCitizenId =
|
||||
item["motherCitizenId"] == "NULL" ? null : item["motherCitizenId"];
|
||||
profile.motherLive = item["motherLive"] == "NULL" ? null : item["motherLive"];
|
||||
profile.profileId = item["profileId"] == "NULL" ? null : item["profileId"];
|
||||
profile.profileEmployeeId =
|
||||
item["profileEmployeeId"] == "NULL" ? null : item["profileEmployeeId"];
|
||||
profiles.push(profile);
|
||||
}),
|
||||
);
|
||||
await this.profileFamilyMotherRepository.save(profiles);
|
||||
return new HttpSuccess(getProFile);
|
||||
}
|
||||
|
||||
@Post("uploadSQLFamilly-Couple")
|
||||
@UseInterceptors(FileInterceptor("file"))
|
||||
async UploadFileSQLFamillyCouple(
|
||||
@UploadedFile() file: Express.Multer.File,
|
||||
// @Request() request: { user: Record<string, any> },
|
||||
) {
|
||||
const workbook = xlsx.read(file.buffer, { type: "buffer" });
|
||||
const sheetName = workbook.SheetNames[0]; // Assuming we're reading the first sheet
|
||||
const sheet = workbook.Sheets[sheetName];
|
||||
const getProFile = xlsx.utils.sheet_to_json(sheet);
|
||||
let profiles: any = [];
|
||||
await Promise.all(
|
||||
getProFile.map(async (item: any) => {
|
||||
// Create a new Profile entity and assign fields from the parsed data
|
||||
|
||||
const profile = new ProfileFamilyCouple();
|
||||
// Check if the profile already exists
|
||||
const existingProfile = await this.profileFamilyCoupleRepository.findOne({
|
||||
where: { id: item["id"] },
|
||||
});
|
||||
// If profile exists, skip saving
|
||||
if (existingProfile) {
|
||||
return;
|
||||
}
|
||||
// Assign fields from the item to the profile entit
|
||||
|
||||
profile.id = item["id"] == "NULL" ? null : item["id"];
|
||||
// profile.createdAt = item["createdAt"] == "NULL" ? null : new Date(item["createdAt"]);
|
||||
profile.createdUserId = item["createdUserId"] == "NULL" ? null : item["createdUserId"];
|
||||
// profile.lastUpdatedAt =
|
||||
// item["lastUpdatedAt"] == "NULL" ? null : new Date(item["lastUpdatedAt"]);
|
||||
profile.lastUpdateUserId =
|
||||
item["lastUpdateUserId"] == "NULL" ? null : item["lastUpdateUserId"];
|
||||
profile.createdFullName =
|
||||
item["createdFullName"] == "NULL" ? null : item["createdFullName"];
|
||||
profile.lastUpdateFullName =
|
||||
item["lastUpdateFullName"] == "NULL" ? null : item["lastUpdateFullName"];
|
||||
profile.couple = item["couple"] == "NULL" ? null : item["couple"];
|
||||
profile.couplePrefix = item["couplePrefix"] == "NULL" ? null : item["couplePrefix"];
|
||||
profile.coupleFirstName =
|
||||
item["coupleFirstName"] == "NULL" ? null : item["coupleFirstName"];
|
||||
profile.coupleLastName = item["coupleLastName"] == "NULL" ? null : item["coupleLastName"];
|
||||
profile.coupleLastNameOld =
|
||||
item["coupleLastNameOld"] == "NULL" ? null : item["coupleLastNameOld"];
|
||||
profile.coupleCareer = item["coupleCareer"] == "NULL" ? null : item["coupleCareer"];
|
||||
profile.coupleCitizenId =
|
||||
item["coupleCitizenId"] == "NULL" ? null : item["coupleCitizenId"];
|
||||
profile.coupleLive = item["coupleLive"] == "NULL" ? null : item["coupleLive"];
|
||||
profile.relationship = item["relationship"] == "NULL" ? null : item["relationship"];
|
||||
profile.profileId = item["profileId"] == "NULL" ? null : item["profileId"];
|
||||
profile.profileEmployeeId =
|
||||
item["profileEmployeeId"] == "NULL" ? null : item["profileEmployeeId"];
|
||||
profiles.push(profile);
|
||||
}),
|
||||
);
|
||||
await this.profileFamilyCoupleRepository.save(profiles);
|
||||
return new HttpSuccess(getProFile);
|
||||
}
|
||||
|
||||
@Post("uploadSQLSalary")
|
||||
@UseInterceptors(FileInterceptor("file"))
|
||||
async UploadFileSQLSalary(
|
||||
@UploadedFile() file: Express.Multer.File,
|
||||
// @Request() request: { user: Record<string, any> },
|
||||
) {
|
||||
const workbook = xlsx.read(file.buffer, { type: "buffer" });
|
||||
let profiles: any = [];
|
||||
let allData: any[] = [];
|
||||
for (const sheetName of workbook.SheetNames) {
|
||||
const sheet = workbook.Sheets[sheetName];
|
||||
const getProFile = xlsx.utils.sheet_to_json(sheet);
|
||||
|
||||
await Promise.all(
|
||||
getProFile.map(async (item: any) => {
|
||||
const profile = new ProfileSalary();
|
||||
const existingProfile = await this.salaryRepository.findOne({
|
||||
where: { id: item["id"] },
|
||||
});
|
||||
if (existingProfile) {
|
||||
return;
|
||||
}
|
||||
profile.id = item["id"] == "NULL" ? null : item["id"];
|
||||
// profile.createdAt = item["createdAt"] == "NULL" ? null : new Date(item["createdAt"]);
|
||||
profile.createdUserId = item["createdUserId"] == "NULL" ? null : item["createdUserId"];
|
||||
// profile.lastUpdatedAt =
|
||||
// item["lastUpdatedAt"] == "NULL" ? null : new Date(item["lastUpdatedAt"]);
|
||||
profile.lastUpdateUserId =
|
||||
item["lastUpdateUserId"] == "NULL" ? null : item["lastUpdateUserId"];
|
||||
profile.createdFullName =
|
||||
item["createdFullName"] == "NULL" ? null : item["createdFullName"];
|
||||
profile.lastUpdateFullName =
|
||||
item["lastUpdateFullName"] == "NULL" ? null : item["lastUpdateFullName"];
|
||||
// profile.date = item["date"] == "NULL" ? null : new Date(item["date"]);
|
||||
profile.amount = item["amount"] == "NULL" ? null : item["amount"];
|
||||
profile.positionSalaryAmount =
|
||||
item["positionSalaryAmount"] == "NULL" ? null : item["positionSalaryAmount"];
|
||||
profile.mouthSalaryAmount =
|
||||
item["mouthSalaryAmount"] == "NULL" ? null : item["mouthSalaryAmount"];
|
||||
profile.profileId = item["profileId"] == "NULL" ? null : item["profileId"];
|
||||
profile.refCommandNo = item["refCommandNo"] == "NULL" ? null : item["refCommandNo"];
|
||||
profile.posNo = item["posNo"] == "NULL" ? null : item["posNo"];
|
||||
profile.position = item["position"] == "NULL" ? null : item["position"];
|
||||
profile.positionLine = item["positionLine"] == "NULL" ? null : item["positionLine"];
|
||||
profile.positionPathSide =
|
||||
item["positionPathSide"] == "NULL" ? null : item["positionPathSide"];
|
||||
profile.positionExecutive =
|
||||
item["positionExecutive"] == "NULL" ? null : item["positionExecutive"];
|
||||
profile.positionType = item["positionType"] == "NULL" ? null : item["positionType"];
|
||||
profile.positionLevel = item["positionLevel"] == "NULL" ? null : item["positionLevel"];
|
||||
profile.templateDoc = item["templateDoc"] == "NULL" ? null : item["templateDoc"];
|
||||
profile.order = item["order"] == "NULL" ? null : item["order"];
|
||||
profile.profileEmployeeId =
|
||||
item["profileEmployeeId"] == "NULL" ? null : item["profileEmployeeId"];
|
||||
profiles.push(profile);
|
||||
}),
|
||||
);
|
||||
|
||||
allData = allData.concat(getProFile);
|
||||
}
|
||||
await this.salaryRepository.save(profiles);
|
||||
return new HttpSuccess(allData);
|
||||
}
|
||||
}
|
||||
|
|
|
|||
Loading…
Add table
Add a link
Reference in a new issue