From c1bc6bfcf545f3e665b522996681ed57c931160d Mon Sep 17 00:00:00 2001
From: geekgeekrun <geekgeekrun>
Date: Mon, 30 Sep 2024 09:26:57 +0800
Subject: [PATCH] insert BossInfoChangeLog to db

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

diff --git a/packages/sqlite-plugin/src/handlers.ts b/packages/sqlite-plugin/src/handlers.ts
index 5b9b8be..c7000a2 100644
--- a/packages/sqlite-plugin/src/handlers.ts
+++ b/packages/sqlite-plugin/src/handlers.ts
@@ -5,11 +5,48 @@ import { CompanyInfo } from "./entity/CompanyInfo";
 import { JobInfo } from "./entity/JobInfo";
 import { parseCompanyScale, parseSalary } from "./utils/parser";
 import { ChatStartupLog } from "./entity/ChatStartupLog";
+import { BossInfoChangeLog } from "./entity/BossInfoChangeLog";
+
+function getBossInfoIfIsEqual (savedOne, currentOne) {
+  if (savedOne === currentOne) {
+    return true
+  }
+  if ((savedOne !== null && currentOne === null) ||
+    (savedOne === null && currentOne !== null)) {
+    return false;
+  }
+  if (
+    ['__ggr_encryptBrandId', 'brandName', 'title', 'name'].some(key => savedOne[key] !== currentOne[key])
+  ) {
+    return false
+  }
+  return true
+}
 
 export async function saveJobInfoFromRecommendPage(ds: DataSource, _jobInfo) {
   const { bossInfo, brandComInfo, jobInfo } = _jobInfo;
 
+  bossInfo['__ggr_encryptBrandId'] = brandComInfo.encryptBrandId
   //#region boss
+  // get origin
+  const bossInfoChangeLogRepository = ds.getRepository(BossInfoChangeLog)
+  let lastSavedBossInfo
+  try {
+    lastSavedBossInfo = JSON.parse((await bossInfoChangeLogRepository.findOne({
+      where: { encryptBossId: jobInfo.encryptUserId },
+      order: { updateTime: "DESC" },
+    })).dataAsJson);
+  } catch {
+    lastSavedBossInfo = null
+  }
+  const isBossInfoEqual = getBossInfoIfIsEqual(lastSavedBossInfo, bossInfo)
+  if (!isBossInfoEqual) {
+    const changeLog = new BossInfoChangeLog()
+    changeLog.dataAsJson = JSON.stringify(bossInfo)
+    changeLog.encryptBossId = jobInfo.encryptUserId
+    changeLog.updateTime = new Date()
+    await bossInfoChangeLogRepository.save(changeLog)
+  }
   const boss = new BossInfo();
   boss.encryptBossId = jobInfo.encryptUserId;
   boss.encryptCompanyId = brandComInfo.encryptBrandId;