Oak-Team
/
oak-general-business
9
0
Fork 0
Code Issues Pull Requests Packages Projects Releases 38 Wiki Activity

build

This commit is contained in:
Wang Kejun 2023-09-06 23:18:22 +08:00
parent 3c13b596e9
commit 2dc0b41184
10 changed files with 74 additions and 18 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
es/triggers/index.d.ts vendored
View File

@ -1,2 +1,2 @@
declare const _default: (import("oak-domain").Trigger<import("../oak-app-domain").EntityDict, "message", import("..").BRC> | import("oak-domain").Trigger<import("../oak-app-domain").EntityDict, "address", import("..").RuntimeCxt> | import("oak-domain").Trigger<import("../oak-app-domain").EntityDict, "user", import("..").RuntimeCxt> | import("oak-domain").Trigger<import("../oak-app-domain").EntityDict, "userEntityGrant", import("..").BRC> | import("oak-domain").Trigger<import("../oak-app-domain").EntityDict, "wechatQrCode", import("..").RuntimeCxt> | import("oak-domain").Trigger<import("../oak-app-domain").EntityDict, "notification", import("..").BackendRuntimeContext<import("../oak-app-domain").EntityDict>> | import("oak-domain").Trigger<import("../oak-app-domain").EntityDict, "wechatLogin", import("..").RuntimeCxt> | import("oak-domain").Trigger<import("../oak-app-domain").EntityDict, "application", import("..").RuntimeCxt> | import("oak-domain").Trigger<import("../oak-app-domain").EntityDict, "articleMenu", import("..").BackendRuntimeContext<import("../oak-app-domain").EntityDict>> | import("oak-domain").Trigger<import("../oak-app-domain").EntityDict, "article", import("..").BackendRuntimeContext<import("../oak-app-domain").EntityDict>> | import("oak-domain").Trigger<import("../oak-app-domain").EntityDict, "parasite", import("..").BackendRuntimeContext<import("../oak-app-domain").EntityDict>> | import("oak-domain").Trigger<import("../oak-app-domain").EntityDict, "extraFile", import("..").BackendRuntimeContext<import("../oak-app-domain").EntityDict>>)[];
declare const _default: (import("oak-domain").Trigger<import("../oak-app-domain").EntityDict, "message", import("..").BRC> | import("oak-domain").Trigger<import("../oak-app-domain").EntityDict, "address", import("..").RuntimeCxt> | import("oak-domain").Trigger<import("../oak-app-domain").EntityDict, "user", import("..").RuntimeCxt> | import("oak-domain").Trigger<import("../oak-app-domain").EntityDict, "userEntityGrant", import("..").BRC> | import("oak-domain").Trigger<import("../oak-app-domain").EntityDict, "wechatQrCode", import("..").RuntimeCxt> | import("oak-domain").Trigger<import("../oak-app-domain").EntityDict, "notification", import("..").BackendRuntimeContext<import("../oak-app-domain").EntityDict>> | import("oak-domain").Trigger<import("../oak-app-domain").EntityDict, "wechatLogin", import("..").RuntimeCxt> | import("oak-domain").Trigger<import("../oak-app-domain").EntityDict, "application", import("..").RuntimeCxt> | import("oak-domain").Trigger<import("../oak-app-domain").EntityDict, "articleMenu", import("..").BackendRuntimeContext<import("../oak-app-domain").EntityDict>> | import("oak-domain").Trigger<import("../oak-app-domain").EntityDict, "article", import("..").BackendRuntimeContext<import("../oak-app-domain").EntityDict>> | import("oak-domain").Trigger<import("../oak-app-domain").EntityDict, "parasite", import("..").BackendRuntimeContext<import("../oak-app-domain").EntityDict>>)[];
export default _default;

4
es/triggers/index.js
View File

@ -9,7 +9,6 @@ import applicationTriggers from './application';
import articleMenuTriggers from './articleMenu';
import article from './article';
import parasiteTriggers from './parasite';
import extraFileTriggers from './extraFile';
export default [
...applicationTriggers,
...addressTriggers,
@ -22,5 +21,6 @@ export default [
...articleMenuTriggers,
...article,
...parasiteTriggers,
...extraFileTriggers,
// todo 等实现了再放开
// ...extraFileTriggers,
];

25
es/types/Uploader.d.ts vendored
View File

@ -11,11 +11,28 @@ export default interface Uploader<ED extends EntityDict & BaseEntityDict, Cxt ex
*/
formUploadMeta: (extraFile: EntityDict['extraFile']['OpSchema'], context: Cxt) => Promise<void>;
/**
* 前台在生成extraFile返回之后调用此函数，进行对文件的真正上传
* 上传成功后，OSS服务器尽量使用通过后台回调服务器的方式去确认上传，若OSS不提供此能力则由前台调用confirmUploadFn去通知后台（实现者尽量不要调用）
* 上传失败，调用uploadFailureFn进行数据的处理
* 前台在生成extraFile返回之后调用此函数，获得上传OSS的相应参数
* 上传成功后，OSS服务器尽量使用通过后台回调服务器的方式去确认上传，若OSS不提供此能力则将autoInform置为false，前台主动在上传成功之后去更新
* @param extraFile
* @returns
*/
upload: (extraFile: EntityDict['extraFile']['OpSchema'], confirmUploadFn: () => Promise<void>, uploadFailureFn: (reason: string) => Promise<void>) => Promise<void>;
getUploadInfo: (extraFile: EntityDict['extraFile']['OpSchema']) => {
name: string;
uploadUrl: string;
formData: Record<string, any>;
autoInform: boolean;
};
/**
* 后台对upload是否成功不确定的文件，向OSS发起主动确认
* @param extraFile
* @returns 是否已经上传OSS成功
*/
checkWhetherSuccess: (extraFile: EntityDict['extraFile']['OpSchema'], context: Cxt) => Promise<boolean>;
/**
* 后台向OSS发起删除命令
* @param extraFile
* @param context
* @returns
*/
removeFile: (extraFile: EntityDict['extraFile']['OpSchema'], context: Cxt) => Promise<void>;
}

4
es/utils/uploader/qiniu.d.ts vendored
View File

@ -6,5 +6,7 @@ import { OpSchema } from '../../oak-app-domain/ExtraFile/Schema';
export default class Qiniu<ED extends EntityDict & BaseEntityDict, Cxt extends BackendRuntimeContext<ED>> implements Uploader<ED, Cxt> {
name: string;
formUploadMeta(extraFile: OpSchema, context: Cxt): Promise<void>;
upload(extraFile: OpSchema, confirmUploadFn: () => Promise<void>, uploadFailureFn: (reason: string) => Promise<void>): Promise<void>;
getUploadInfo(extraFile: OpSchema): any;
checkWhetherSuccess(extraFile: OpSchema, context: Cxt): Promise<boolean>;
removeFile(extraFile: OpSchema, context: Cxt): Promise<void>;
}

10
es/utils/uploader/qiniu.js
View File

@ -3,7 +3,15 @@ export default class Qiniu {
async formUploadMeta(extraFile, context) {
throw new Error('method not implemented');
}
async upload(extraFile, confirmUploadFn, uploadFailureFn) {
getUploadInfo(extraFile) {
throw new Error('method not implemented');
return {};
}
async checkWhetherSuccess(extraFile, context) {
throw new Error('method not implemented');
return false;
}
async removeFile(extraFile, context) {
throw new Error('method not implemented');
}
}

2
lib/triggers/index.d.ts vendored
View File

@ -1,2 +1,2 @@
declare const _default: (import("oak-domain").Trigger<import("../oak-app-domain").EntityDict, "message", import("..").BRC> | import("oak-domain").Trigger<import("../oak-app-domain").EntityDict, "address", import("..").RuntimeCxt> | import("oak-domain").Trigger<import("../oak-app-domain").EntityDict, "user", import("..").RuntimeCxt> | import("oak-domain").Trigger<import("../oak-app-domain").EntityDict, "userEntityGrant", import("..").BRC> | import("oak-domain").Trigger<import("../oak-app-domain").EntityDict, "wechatQrCode", import("..").RuntimeCxt> | import("oak-domain").Trigger<import("../oak-app-domain").EntityDict, "notification", import("..").BackendRuntimeContext<import("../oak-app-domain").EntityDict>> | import("oak-domain").Trigger<import("../oak-app-domain").EntityDict, "wechatLogin", import("..").RuntimeCxt> | import("oak-domain").Trigger<import("../oak-app-domain").EntityDict, "application", import("..").RuntimeCxt> | import("oak-domain").Trigger<import("../oak-app-domain").EntityDict, "articleMenu", import("..").BackendRuntimeContext<import("../oak-app-domain").EntityDict>> | import("oak-domain").Trigger<import("../oak-app-domain").EntityDict, "article", import("..").BackendRuntimeContext<import("../oak-app-domain").EntityDict>> | import("oak-domain").Trigger<import("../oak-app-domain").EntityDict, "parasite", import("..").BackendRuntimeContext<import("../oak-app-domain").EntityDict>> | import("oak-domain").Trigger<import("../oak-app-domain").EntityDict, "extraFile", import("..").BackendRuntimeContext<import("../oak-app-domain").EntityDict>>)[];
declare const _default: (import("oak-domain").Trigger<import("../oak-app-domain").EntityDict, "message", import("..").BRC> | import("oak-domain").Trigger<import("../oak-app-domain").EntityDict, "address", import("..").RuntimeCxt> | import("oak-domain").Trigger<import("../oak-app-domain").EntityDict, "user", import("..").RuntimeCxt> | import("oak-domain").Trigger<import("../oak-app-domain").EntityDict, "userEntityGrant", import("..").BRC> | import("oak-domain").Trigger<import("../oak-app-domain").EntityDict, "wechatQrCode", import("..").RuntimeCxt> | import("oak-domain").Trigger<import("../oak-app-domain").EntityDict, "notification", import("..").BackendRuntimeContext<import("../oak-app-domain").EntityDict>> | import("oak-domain").Trigger<import("../oak-app-domain").EntityDict, "wechatLogin", import("..").RuntimeCxt> | import("oak-domain").Trigger<import("../oak-app-domain").EntityDict, "application", import("..").RuntimeCxt> | import("oak-domain").Trigger<import("../oak-app-domain").EntityDict, "articleMenu", import("..").BackendRuntimeContext<import("../oak-app-domain").EntityDict>> | import("oak-domain").Trigger<import("../oak-app-domain").EntityDict, "article", import("..").BackendRuntimeContext<import("../oak-app-domain").EntityDict>> | import("oak-domain").Trigger<import("../oak-app-domain").EntityDict, "parasite", import("..").BackendRuntimeContext<import("../oak-app-domain").EntityDict>>)[];
export default _default;

3
lib/triggers/index.js
View File

@ -12,5 +12,4 @@ var application_1 = tslib_1.__importDefault(require("./application"));
var articleMenu_1 = tslib_1.__importDefault(require("./articleMenu"));
var article_1 = tslib_1.__importDefault(require("./article"));
var parasite_1 = tslib_1.__importDefault(require("./parasite"));
var extraFile_1 = tslib_1.__importDefault(require("./extraFile"));
exports.default = tslib_1.__spreadArray(tslib_1.__spreadArray(tslib_1.__spreadArray(tslib_1.__spreadArray(tslib_1.__spreadArray(tslib_1.__spreadArray(tslib_1.__spreadArray(tslib_1.__spreadArray(tslib_1.__spreadArray(tslib_1.__spreadArray(tslib_1.__spreadArray(tslib_1.__spreadArray([], tslib_1.__read(application_1.default), false), tslib_1.__read(address_1.default), false), tslib_1.__read(user_1.default), false), tslib_1.__read(userEntityGrant_1.default), false), tslib_1.__read(wechatQrCode_1.default), false), tslib_1.__read(message_1.default), false), tslib_1.__read(notification_1.default), false), tslib_1.__read(wechatLogin_1.default), false), tslib_1.__read(articleMenu_1.default), false), tslib_1.__read(article_1.default), false), tslib_1.__read(parasite_1.default), false), tslib_1.__read(extraFile_1.default), false);
exports.default = tslib_1.__spreadArray(tslib_1.__spreadArray(tslib_1.__spreadArray(tslib_1.__spreadArray(tslib_1.__spreadArray(tslib_1.__spreadArray(tslib_1.__spreadArray(tslib_1.__spreadArray(tslib_1.__spreadArray(tslib_1.__spreadArray(tslib_1.__spreadArray([], tslib_1.__read(application_1.default), false), tslib_1.__read(address_1.default), false), tslib_1.__read(user_1.default), false), tslib_1.__read(userEntityGrant_1.default), false), tslib_1.__read(wechatQrCode_1.default), false), tslib_1.__read(message_1.default), false), tslib_1.__read(notification_1.default), false), tslib_1.__read(wechatLogin_1.default), false), tslib_1.__read(articleMenu_1.default), false), tslib_1.__read(article_1.default), false), tslib_1.__read(parasite_1.default), false);

25
lib/types/Uploader.d.ts vendored
View File

@ -11,11 +11,28 @@ export default interface Uploader<ED extends EntityDict & BaseEntityDict, Cxt ex
*/
formUploadMeta: (extraFile: EntityDict['extraFile']['OpSchema'], context: Cxt) => Promise<void>;
/**
* 前台在生成extraFile返回之后调用此函数，进行对文件的真正上传
* 上传成功后，OSS服务器尽量使用通过后台回调服务器的方式去确认上传，若OSS不提供此能力则由前台调用confirmUploadFn去通知后台（实现者尽量不要调用）
* 上传失败，调用uploadFailureFn进行数据的处理
* 前台在生成extraFile返回之后调用此函数，获得上传OSS的相应参数
* 上传成功后，OSS服务器尽量使用通过后台回调服务器的方式去确认上传，若OSS不提供此能力则将autoInform置为false，前台主动在上传成功之后去更新
* @param extraFile
* @returns
*/
upload: (extraFile: EntityDict['extraFile']['OpSchema'], confirmUploadFn: () => Promise<void>, uploadFailureFn: (reason: string) => Promise<void>) => Promise<void>;
getUploadInfo: (extraFile: EntityDict['extraFile']['OpSchema']) => {
name: string;
uploadUrl: string;
formData: Record<string, any>;
autoInform: boolean;
};
/**
* 后台对upload是否成功不确定的文件，向OSS发起主动确认
* @param extraFile
* @returns 是否已经上传OSS成功
*/
checkWhetherSuccess: (extraFile: EntityDict['extraFile']['OpSchema'], context: Cxt) => Promise<boolean>;
/**
* 后台向OSS发起删除命令
* @param extraFile
* @param context
* @returns
*/
removeFile: (extraFile: EntityDict['extraFile']['OpSchema'], context: Cxt) => Promise<void>;
}

4
lib/utils/uploader/qiniu.d.ts vendored
View File

@ -6,5 +6,7 @@ import { OpSchema } from '../../oak-app-domain/ExtraFile/Schema';
export default class Qiniu<ED extends EntityDict & BaseEntityDict, Cxt extends BackendRuntimeContext<ED>> implements Uploader<ED, Cxt> {
name: string;
formUploadMeta(extraFile: OpSchema, context: Cxt): Promise<void>;
upload(extraFile: OpSchema, confirmUploadFn: () => Promise<void>, uploadFailureFn: (reason: string) => Promise<void>): Promise<void>;
getUploadInfo(extraFile: OpSchema): any;
checkWhetherSuccess(extraFile: OpSchema, context: Cxt): Promise<boolean>;
removeFile(extraFile: OpSchema, context: Cxt): Promise<void>;
}

13
lib/utils/uploader/qiniu.js
View File

@ -12,7 +12,18 @@ var Qiniu = /** @class */ (function () {
});
});
};
Qiniu.prototype.upload = function (extraFile, confirmUploadFn, uploadFailureFn) {
Qiniu.prototype.getUploadInfo = function (extraFile) {
throw new Error('method not implemented');
return {};
};
Qiniu.prototype.checkWhetherSuccess = function (extraFile, context) {
return tslib_1.__awaiter(this, void 0, void 0, function () {
return tslib_1.__generator(this, function (_a) {
throw new Error('method not implemented');
});
});
};
Qiniu.prototype.removeFile = function (extraFile, context) {
return tslib_1.__awaiter(this, void 0, void 0, function () {
return tslib_1.__generator(this, function (_a) {
throw new Error('method not implemented');