Procházet zdrojové kódy

set init seq for sync

guoziyun před 10 měsíci
rodič
revize
1470d3b245

+ 1 - 0
oms/ecosystem.config.js

@@ -116,6 +116,7 @@ module.exports = {
         NODE_ENV: "production",
         MONGO_URI: "mongodb://oms:oms123.@localhost:27717/omsdb", // 使用 localhost 访问宿主机上映射的 Docker 容器
         REMOTE_SYNC_MONGO_URI: "mongodb://coloring:coloring123.@hk.jccytech.cn:7881?authSource=admin",
+        INIT_SEQ: 7368116,
         CLICKHOUSE_HOST: "http://localhost:8123", // 使用 localhost 访问宿主机上映射的 Docker 容器
         CLICKHOUSE_DATABASE: "omsdb", // ClickHouse数据库名
         CLICKHOUSE_USER: "ckuser", // ClickHouse用户

+ 2 - 1
oms/services/cron-jobs/sync/sync-service.js

@@ -8,6 +8,7 @@ const localdb = "omsdb"; // 本地的数据库
  * sync from remote
  */
 async function run() {
+  const INIT_SEQ = process.env.INIT_SEQ || 7368116,
   const MONGO_URI = process.env.MONGO_URI || "mongodb://oms:oms123.@localhost:27717/omsdb?authSource=admin";
   const REMOTE_SYNC_MONGO_URI = process.env.REMOTE_SYNC_MONGO_URI || "mongodb://coloring:coloring123.@hk.jccytech.cn:7881?authSource=admin";
   const localClient = await new MongoClient(MONGO_URI).connect();
@@ -24,7 +25,7 @@ async function run() {
   let seq = -1;
   let seqDoc = await SyncSeq.findOne();
   if (seqDoc) seq = seqDoc.seq;
-  else seqDoc = new SyncSeq({});
+  else seqDoc = new SyncSeq({seq: INIT_SEQ});
 
   let count, localtb, remotetb, localdoc, remotedoc;
   setTimeout(async function cycleRun() {