linfeng
/
training_data
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

Compare commits

base: linfeng:6ee6c10f5f8383d27acb6cf962813b772583ff01
Branches Tags
linfeng:main
..
compare: linfeng:0a3b4a596f4a9a05999afdbf578f79bc732627cb
Branches Tags
linfeng:main

No commits in common. "6ee6c10f5f8383d27acb6cf962813b772583ff01" and "0a3b4a596f4a9a05999afdbf578f79bc732627cb" have entirely different histories.
6ee6c10f5f ... 0a3b4a596f

1 changed files with 21 additions and 22 deletions
Show Stats Expand all files Collapse all files

43
apps/server/src/models/base/base.service.ts
View File

@ -30,7 +30,6 @@ export class BaseService<
A extends DelegateArgs<D> = DelegateArgs<D>,
R extends DelegateReturnTypes<D> = DelegateReturnTypes<D>,
> {
[x: string]: any;
protected ORDER_INTERVAL = 100;
/**
* Initializes the BaseService with the specified model.
@ -153,27 +152,27 @@ export class BaseService<
* @example
* const newUser = await service.create({ data: { name: 'John Doe' } });
*/
// async create(args: A['create'], params?: any): Promise<R['create']> {
// try {
// if (this.enableOrder && !(args as any).data.order) {
// // 查找当前最大的 order 值
// const maxOrderItem = (await this.getModel(params?.tx).findFirst({
// orderBy: { order: 'desc' },
// })) as any;
// // 设置新记录的 order 值
// const newOrder = maxOrderItem
// ? maxOrderItem.order + this.ORDER_INTERVAL
// : 1;
// // 将 order 添加到创建参数中
// (args as any).data.order = newOrder;
// }
// return this.getModel(params?.tx).create(args as any) as Promise<
// R['create']
// >;
// } catch (error) {
// this.handleError(error, 'create');
// }
// }
async create(args: A['create'], params?: any): Promise<R['create']> {
try {
if (this.enableOrder && !(args as any).data.order) {
// 查找当前最大的 order 值
const maxOrderItem = (await this.getModel(params?.tx).findFirst({
orderBy: { order: 'desc' },
})) as any;
// 设置新记录的 order 值
const newOrder = maxOrderItem
? maxOrderItem.order + this.ORDER_INTERVAL
: 1;
// 将 order 添加到创建参数中
(args as any).data.order = newOrder;
}
return this.getModel(params?.tx).create(args as any) as Promise<
R['create']
>;
} catch (error) {
this.handleError(error, 'create');
}
}
/**
* Creates multiple new records with the given data.