拍卖行:添加接口返回和测试框架,调整个别字段
This commit is contained in:
@@ -1,4 +1,8 @@
|
||||
import { Application, BackendSession, ChannelService } from "pinus";
|
||||
import { DEBUG_MAGIC_WORD, STATUS } from "../../../consts";
|
||||
import { ItemReward } from "../../../domain/dbGeneral";
|
||||
import { resResult } from "../../../pubUtils/util";
|
||||
import { genAuction } from "../../../services/auctionService";
|
||||
|
||||
export default function (app: Application) {
|
||||
return new AuctionHandler(app);
|
||||
@@ -11,26 +15,49 @@ export class AuctionHandler {
|
||||
}
|
||||
|
||||
async getAuction(msg: {}, session: BackendSession) {
|
||||
|
||||
return resResult(STATUS.SUCCESS);
|
||||
}
|
||||
|
||||
async offer(msg: { max: boolean }, session: BackendSession) {
|
||||
|
||||
return resResult(STATUS.SUCCESS);
|
||||
}
|
||||
|
||||
async watchLot(msg: { code: string }, session: BackendSession) {
|
||||
|
||||
return resResult(STATUS.SUCCESS);
|
||||
}
|
||||
|
||||
async checkDividend(msg: {}, session: BackendSession) {
|
||||
|
||||
return resResult(STATUS.SUCCESS);
|
||||
}
|
||||
|
||||
async getDividend(msg: {}, session: BackendSession) {
|
||||
|
||||
return resResult(STATUS.SUCCESS);
|
||||
}
|
||||
|
||||
async myOffers(msg: { count: number }, session: BackendSession) {
|
||||
async myOffers(msg: {}, session: BackendSession) {
|
||||
return resResult(STATUS.SUCCESS);
|
||||
}
|
||||
|
||||
async offerRecs(msg: { count: number }, session: BackendSession) {
|
||||
return resResult(STATUS.SUCCESS);
|
||||
}
|
||||
|
||||
// ! 测试接口
|
||||
async debugAddLots(msg: { magicWord: string, sourceType: number, sourceCode: string, rewards: ItemReward[]}, session: BackendSession) {
|
||||
const { magicWord, sourceType, sourceCode, rewards } = msg;
|
||||
if (magicWord !== DEBUG_MAGIC_WORD) {
|
||||
return resResult(STATUS.TOKEN_ERR);
|
||||
}
|
||||
|
||||
const guildCode: string = session.get('guildCode');
|
||||
const serverId: number = session.get('serverId');
|
||||
if (!guildCode) return resResult(STATUS.GUILD_NOT_FOUND)
|
||||
|
||||
const result = await genAuction(guildCode, sourceType, sourceCode, serverId, rewards);
|
||||
if (!result) {
|
||||
return resResult(STATUS.WRONG_PARMS);
|
||||
}
|
||||
|
||||
return resResult(STATUS.SUCCESS, { result });
|
||||
}
|
||||
}
|
||||
|
||||
@@ -13,13 +13,14 @@ import { LotModel, LotParam } from '../db/Lot';
|
||||
* @param {ItemReward[]} rewards
|
||||
*/
|
||||
export async function genAuction(guildCode: string, sourceType: number, sourceCode: string, serverId: number, rewards: ItemReward[]) {
|
||||
const curTime = new Date();
|
||||
const lots: LotParam[] = rewards.map(reward => {
|
||||
const { id, count } = reward;
|
||||
const code = genCode(LOT_CODE_LEN);
|
||||
return {
|
||||
auctionStage: AUCTION_STAGE.DEFAULT, sourceType,
|
||||
sourceCode, serverId, guildCode, code, gid: id, count
|
||||
// maxPrice, begin, end
|
||||
sourceCode, serverId, guildCode, code, gid: id, count,
|
||||
maxPrice: 100, begin: curTime, end: curTime, curPrice: 10, // ! 此行为临时数据
|
||||
}
|
||||
});
|
||||
const result = await LotModel.createRecs(lots);
|
||||
|
||||
Reference in New Issue
Block a user