Method setValues

src/app/service/service_worker/value.ts:82–169

(params: TSetValuesParams)

  // 批量设置
  async setValues(params: TSetValuesParams) {
    const { uuid, keyValuePairs, isReplace } = params;
    const id = params.id || "";
    const ts = params.ts || 0;
    const valueSender = params.valueSender || {
      runFlag: "user",
      tabId: -2,
    };
    // 查询出脚本
    const script = await this.scriptDAO.get(uuid);
    if (!script) {
      throw new Error("script not found");
    }
    // 查询老的值
    const storageName = getStorageName(script);
    let oldValueRecord: ValueStore = {};
    const cacheKey = `${CACHE_KEY_SET_VALUE}${storageName}`;
    const entries = [] as ValueUpdateDataREntry[];
    const _flag = await stackAsyncTask<boolean>(cacheKey, async () => {
      let valueModel: Value | undefined = await this.valueDAO.get(storageName);
      if (!valueModel) {
        const now = Date.now();
        const dataModel: ValueStore = {};
        for (const [key, rTyped1] of keyValuePairs) {
          const value = decodeRValue(rTyped1);
          if (value !== undefined) {
            dataModel[key] = value;
            entries.push([key, rTyped1, R_UNDEFINED]);
          }
        }
        // 即使是空 dataModel 也进行更新
        // 由于没entries, valueUpdated 是 false, 但 valueDAO 会有一个空的 valueModel 记录 updatetime
        valueModel = {
          uuid: uuid,
          storageName: storageName,
          data: dataModel,
          createtime: ts ? Math.min(ts, now) : now,
          updatetime: ts ? Math.min(ts, now) : now,
        };
      } else {
        let changed = false;
        let dataModel = (oldValueRecord = valueModel.data);
        dataModel = { ...dataModel }; // 每次储存使用新参考
        const containedKeys = new Set<string>();
        for (const [key, rTyped1] of keyValuePairs) {
          containedKeys.add(key);
          const value = decodeRValue(rTyped1);
          const oldValue = dataModel[key];
          if (oldValue === value) continue;
          changed = true;
          if (value === undefined) {
            delete dataModel[key];
          } else {
            dataModel[key] = value;
          }
          const rTyped2 = encodeRValue(oldValue);
          entries.push([key, rTyped1, rTyped2]);
        }