From 14517ce7ca0f414ef5377849e239545967fd82e3 Mon Sep 17 00:00:00 2001
From: geekgeekrun <geekgeekrun>
Date: Mon, 30 Sep 2024 09:32:59 +0800
Subject: [PATCH] insert CompanyInfoChangeLog to db

---
 packages/sqlite-plugin/src/handlers.ts | 43 ++++++++++++++++++++++++++
 1 file changed, 43 insertions(+)

diff --git a/packages/sqlite-plugin/src/handlers.ts b/packages/sqlite-plugin/src/handlers.ts
index c7000a2..786d924 100644
--- a/packages/sqlite-plugin/src/handlers.ts
+++ b/packages/sqlite-plugin/src/handlers.ts
@@ -6,6 +6,7 @@ import { JobInfo } from "./entity/JobInfo";
 import { parseCompanyScale, parseSalary } from "./utils/parser";
 import { ChatStartupLog } from "./entity/ChatStartupLog";
 import { BossInfoChangeLog } from "./entity/BossInfoChangeLog";
+import { CompanyInfoChangeLog } from "./entity/CompanyInfoChangeLog";
 
 function getBossInfoIfIsEqual (savedOne, currentOne) {
   if (savedOne === currentOne) {
@@ -23,6 +24,28 @@ function getBossInfoIfIsEqual (savedOne, currentOne) {
   return true
 }
 
+function getCompanyInfoIfIsEqual (savedOne, currentOne) {
+  if (savedOne === currentOne) {
+    return true
+  }
+  if (
+    (savedOne !== null && currentOne === null) ||
+    (savedOne === null && currentOne !== null)
+  ) {
+    return false;
+  }
+  if (['brandName', 'stage', 'scale', 'industry', 'introduce'].some(key => savedOne[key] !== currentOne[key])) {
+    return false;
+  }
+  if (
+    [...currentOne.labels ?? []].sort().join('-') !==
+    [...savedOne.labels ?? []].sort().join('-')
+  ) {
+    return false
+  }
+  return true;
+}
+
 export async function saveJobInfoFromRecommendPage(ds: DataSource, _jobInfo) {
   const { bossInfo, brandComInfo, jobInfo } = _jobInfo;
 
@@ -58,6 +81,26 @@ export async function saveJobInfoFromRecommendPage(ds: DataSource, _jobInfo) {
   //#endregion
 
   //#region company
+  // get origin
+  const companyInfoChangeLogRepository = ds.getRepository(CompanyInfoChangeLog)
+  let lastSavedCompanyInfo
+  try {
+    lastSavedCompanyInfo = JSON.parse((await companyInfoChangeLogRepository.findOne({
+      where: { encryptCompanyId: brandComInfo.encryptBrandId },
+      order: { updateTime: "DESC" },
+    })).dataAsJson);
+  } catch {
+    lastSavedCompanyInfo = null
+  }
+  const isCompanyInfoEqual = getCompanyInfoIfIsEqual(lastSavedCompanyInfo, brandComInfo)
+  if (!isCompanyInfoEqual) {
+    const changeLog = new CompanyInfoChangeLog()
+    changeLog.dataAsJson = JSON.stringify(brandComInfo)
+    changeLog.encryptCompanyId = brandComInfo.encryptBrandId
+    changeLog.updateTime = new Date()
+    await companyInfoChangeLogRepository.save(changeLog)
+  }
+
   const company = new CompanyInfo();
   company.encryptCompanyId = brandComInfo.encryptBrandId;
   company.brandName = brandComInfo.brandName;