结合百度AI模型和分布式设备协同网络的分布式AI聊天室 - OpenHarmony开发者论坛

let obj = {
name:this.name,
message:this.message
}
this.pushData(JSON.stringify(obj))

复制代码

try {
this.kvStore.on('dataChange', distributedKVStore.SubscribeType.SUBSCRIBE_TYPE_REMOTE,
(data: distributedKVStore.ChangeNotification) => {
if ((data.updateEntries.length > 0) || (data.insertEntries.length > 0)) {
callback(data);
console.info('KvStoreModel setDataChangeListener dataChange success');
}
});
} catch (error) {
console.error('KvStoreModel setDataChangeListener on dataChange failed, err= '+JSON.stringify(error));
}

复制代码

checkPermissions(this.context);
async function checkPermissions(context: common.UIAbilityContext) {
let grantStatus: abilityAccessCtrl.GrantStatus = await checkAccessToken();
if (grantStatus !== abilityAccessCtrl.GrantStatus.PERMISSION_GRANTED) {
// Applying for the distributed data synchronization permission.
let atManager: abilityAccessCtrl.AtManager = abilityAccessCtrl.createAtManager();
atManager.requestPermissionsFromUser(context, permissions).then((data) => {
let grantStatus: Array<number> = data.authResults;
let length: number = grantStatus.length;
for (let i: number = 0; i < length; i++) {
if (grantStatus[i] === 0) {
hilog.info(0x0000,'EntryAbility', `checkPermissions request permission ${permissions[i]} success`);
} else {
hilog.error(0x0000,'EntryAbility',
`checkPermissions request fail permission=${permissions[i]}, grantStatus=${grantStatus[i]}`);
return;
}
}
}).catch((err: Error) => {
hilog.error(0x0000,'EntryAbility',
`checkPermissions request permissions failed, err=${JSON.stringify(err)}`);
})
}
}
/**
* Obtains the authorization status.
*
* @returns Grant status.
*/
async function checkAccessToken() {
let atManager = abilityAccessCtrl.createAtManager();
let tokenId: number = 0;
try {
let bundleInfo: bundleManager.BundleInfo = await bundleManager
.getBundleInfoForSelf(bundleManager.BundleFlag.GET_BUNDLE_INFO_WITH_APPLICATION);
let appInfo: bundleManager.ApplicationInfo = bundleInfo.appInfo;
tokenId = appInfo.accessTokenId;
} catch (err) {
hilog.error(0x0000,'EntryAbility',
`checkAccessToken Failed to get bundle info for self. err=${JSON.stringify(err)}`);
}
let grantStatus: abilityAccessCtrl.GrantStatus = abilityAccessCtrl.GrantStatus.PERMISSION_DENIED;
try {
grantStatus = await atManager.checkAccessToken(tokenId, 'ohos.permission.DISTRIBUTED_DATASYNC');
} catch (err) {
hilog.error(0x0000,'EntryAbility',
`checkAccessToken Failed to check access token. err=${JSON.stringify(err)}`);
}
return grantStatus;
}

复制代码

export class BaiduHttpUtils {
text :string = ''
request(question: string){
let httpRequest = http.createHttp();
// 2 发起请求
httpRequest.request(
"https://aip.baidubce.com/oauth/2.0/token?grant_type=client_credentials&client_id=",
{
method: http.RequestMethod.POST,
header: {
"Content-Type": "application/json"
}
}, (err, data: http.HttpResponse) => {
if (err) {
hilog.error(0x0000, 'testTag', 'Failed to request BaiD111u. Cause: %{public}s', JSON.stringify(err) ?? '');
httpRequest.destroy();
} else {
hilog.error(0x0000, 'testTag', 'Request POST BaiDu success. data: %{public}s', JSON.stringify(data.result));
httpRequest.destroy();
// 携带认证信息发起对话请求
let respToken: BaiDuToken = JSON.parse(data.result.toString())
this.chatRequest(respToken.access_token, question)
}
}
)

复制代码

chatRequest(token: string, question: string) {
// 1 createHttp接口创建请求
let httpRequest = http.createHttp();
// 2 发起请求
httpRequest.request(
// 请求地址
"https://aip.baidubce.com/rpc/2.0/ai_custom/v1/wenxinworkshop/chat/yi_34b_chat?access_token=" + token,
{
method: http.RequestMethod.POST,
header: {
"Content-Type": "application/json"
},
extraData: {
"messages": [
{
"role": "user",
"content": question
}
]
}
}, (err, data: http.HttpResponse) => {
if (err) {
hilog.error(0x0000, 'testTag', 'Failed to request BaiDu. Cause: %{public}s', JSON.stringify(err) ?? '');
httpRequest.destroy();
} else {
this.text = JSON.parse(data.result.toString()).result
hilog.error(0x0000, 'testTag', 'Request BaiDu success. data: %{public}s', this.text);
httpRequest.destroy();
}
})
}
}

复制代码