openharmony/applications_app_samples
1
0
Fork 0
mirror of https://gitee.com/openharmony/applications_app_samples synced 2024-11-23 16:40:08 +00:00
Code Issues Actions Packages Projects Releases Wiki Activity

!4666 【Sample】修复KvStore数据不同步问题

Browse Source 
Merge pull request !4666 from 张宏/kvstore
This commit is contained in:
openharmony_ci 2024-08-01 11:49:58 +00:00 committed by Gitee
commit a4f568363a
No known key found for this signature in database
GPG Key ID: 173E9B9CA92EEF8F
1 changed files with 25 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

31
code/SuperFeature/DistributedAppDev/Kvstore/entry/src/main/ets/model/KvStoreModel.ets
View File

@ -13,13 +13,17 @@
* limitations under the License.
*/
import distributedData from '@ohos.data.distributedKVStore'
import common from '@ohos.app.ability.common'
import Logger from '../util/Logger'
import distributedData from '@ohos.data.distributedKVStore';
import common from '@ohos.app.ability.common';
import Logger from '../util/Logger';
import { Callback } from '@ohos.base';
import distributedDeviceManager from '@ohos.distributedDeviceManager';
const STORE_ID = 'etskvstore'
const TAG = 'KvStoreModel'
const STORE_ID = 'etskvstore';
const TAG = 'KvStoreModel';
const mode = distributedData.SyncMode.PUSH_PULL;
let context: common.Context = getContext(this);
let devManager: distributedDeviceManager.DeviceManager;
export class KvStoreModel {
private kvManager?: distributedData.KVManager = undefined;
@ -49,7 +53,7 @@ export class KvStoreModel {
createIfMissing: true,
encrypt: false,
backup: false,
autoSync: true,
autoSync: false,
kvStoreType: distributedData.KVStoreType.SINGLE_VERSION,
securityLevel: distributedData.SecurityLevel.S1,
}
@ -72,6 +76,21 @@ export class KvStoreModel {
value
).then((data) => {
Logger.debug(TAG, `kvStore.put ${key} finished, data= ${JSON.stringify(data)}`);
try {
devManager = distributedDeviceManager.createDeviceManager(context.applicationInfo.name);
let deviceIds: string[] = [];
if (devManager != null) {
let devices = devManager.getAvailableDeviceListSync();
for (let i = 0; i < devices.length; i++) {
deviceIds[i] = devices[i].networkId as string;
}
}
if (this.kvStore != null) {
this.kvStore.sync(deviceIds, mode, 1000);
}
} catch (err) {
Logger.error('createDeviceManager errCode:' + err.code + ',errMessage:' + err.message);
}
}).catch((err: object) => {
Logger.debug(TAG, `kvStore.put ${key} failed, ${JSON.stringify(err)}`);
})