分解装备 穿戴或卸载装备 装备打孔 宝石镶嵌 宝石合成 宝石卸下
This commit is contained in:
@@ -1,14 +1,17 @@
|
||||
import { Application, BackendSession } from "pinus";
|
||||
import { resResult } from "../../../pubUtils/util";
|
||||
import { STATUS, EQUIP_STRENGTHEN_TYPE, CURRENCY_BY_TYPE, CURRENCY_TYPE, HERO_SYSTEM_TYPE } from "../../../consts";
|
||||
import { addItems, handleCost } from "../../../services/rewardService";
|
||||
import { gameData } from "../../../pubUtils/data";
|
||||
import { STATUS, EQUIP_STRENGTHEN_TYPE, CURRENCY_BY_TYPE, CURRENCY_TYPE, HERO_SYSTEM_TYPE, CONSUME_TYPE, GOOD_TYPE } from "../../../consts";
|
||||
import { ItemInter } from "../../../pubUtils/interface";
|
||||
import { resResult, parseReward } from "../../../pubUtils/util";
|
||||
import { addItems, handleCost } from "../../../services/rewardService";
|
||||
import { EquipModel } from "../../../db/Equip";
|
||||
import { GOOD_TYPE } from "../../../consts/consts";
|
||||
import { HeroModel, EPlace } from "../../../db/Hero";
|
||||
import Role from "../../../db/Role";
|
||||
import { calPlayerCeAndSave } from "../../../services/playerCeService";
|
||||
import { getGoodById, gameData } from "../../../pubUtils/data";
|
||||
import { EQUIP } from "../../../pubUtils/dicParam";
|
||||
import { ITID } from "../../../consts/constModules/itemConst";
|
||||
import { SSL_OP_SSLEAY_080_CLIENT_DH_BUG } from "constants";
|
||||
const _ = require('underscore');
|
||||
|
||||
export default function(app: Application) {
|
||||
return new EquipHandler(app);
|
||||
@@ -35,7 +38,7 @@ export class EquipHandler {
|
||||
cost.concat(targetGood.composeMaterial);
|
||||
let specialMaterial = targetGood.specialMaterial;
|
||||
let costCount = 0;
|
||||
let equips = await EquipModel.getEquips(roleId, originalEquip);
|
||||
let equips = await EquipModel.getEquips(originalEquip);
|
||||
for(let {id, seqId} of equips) {
|
||||
if(specialMaterial.ids.includes(id)) {
|
||||
costCount++;
|
||||
@@ -138,34 +141,147 @@ export class EquipHandler {
|
||||
public async reStrengthen(msg: { }, session: BackendSession) {
|
||||
|
||||
}
|
||||
//===================================================================
|
||||
//TODO 分解装备
|
||||
public async decomposeEquips(msg: { }, session: BackendSession) {
|
||||
|
||||
//分解装备
|
||||
public async decomposeEquip(msg: { originalEquip: Array<number> }, session: BackendSession) {
|
||||
let { originalEquip } = msg;
|
||||
let roleId: string = session.get('roleId');
|
||||
let roleName: string = session.get('roleName');
|
||||
let sid: string = session.get('sid');
|
||||
let equips = await EquipModel.getEquips(originalEquip);
|
||||
if (equips.length < originalEquip.length)
|
||||
return resResult(STATUS.EQUIP_NOT_FIND);
|
||||
let goods:Array<{id:number, count:number}> = [];
|
||||
for (let equip of equips) {
|
||||
if (!!equip.hid)
|
||||
return resResult(STATUS.EQUIP_IS_EQUIPED_NOT_DECOMPOSE);
|
||||
let goodInfo = getGoodById(equip.id);
|
||||
if (!goodInfo)
|
||||
return resResult(STATUS.EQUIP_NOT_FIND);
|
||||
goods.concat(goodInfo.decomposeItem);
|
||||
}
|
||||
let uids = [{uid: roleId, sid}];
|
||||
await EquipModel.deleteEquips(originalEquip);
|
||||
this.app.get('channelService').pushMessageByUids('onEquipDel', resResult(STATUS.SUCCESS, [originalEquip]), uids);
|
||||
let result = await addItems(roleId, roleName, sid, goods);
|
||||
return resResult(STATUS.SUCCESS,{goods:result});
|
||||
}
|
||||
|
||||
//TODO 穿戴装备
|
||||
public async wearEquips(msg: { }, session: BackendSession) {
|
||||
|
||||
//穿戴或卸载装备 1-穿上装备 2-脱下装备
|
||||
public async putOnOrOff(msg: {eid: number, hid: number, type: number}, session: BackendSession) {
|
||||
let { eid, hid, type } = msg;
|
||||
let roleId: string = session.get('roleId');
|
||||
let roleName: string = session.get('roleName');
|
||||
let sid: string = session.get('sid');
|
||||
let equip = await EquipModel.getEquip(eid);
|
||||
let returnEquips:Array<{seqId:number, id:number, hid:number, ePlaceId:number}>;
|
||||
let goodInfo = getGoodById(equip.id);
|
||||
let obj = ITID.get(goodInfo.itid);
|
||||
let ePlaceId = obj.type;
|
||||
if (type == 1) {
|
||||
if (!!equip.hid)
|
||||
return resResult(STATUS.EQUIP_IS_EQUIPED);
|
||||
let hero = await HeroModel.getHeroAndEquip(roleId, hid);
|
||||
if (!hero)
|
||||
return resResult(STATUS.HERO_NOT_FIND);
|
||||
//修改数据库TODO
|
||||
|
||||
} else if (type == 2) {
|
||||
if (!equip.hid)
|
||||
return resResult(STATUS.EQUIP_NOT_EQUIPED);
|
||||
//修改数据库TODO
|
||||
}
|
||||
}
|
||||
|
||||
//TODO 卸下装备
|
||||
public async removeEquips(msg: { }, session: BackendSession) {
|
||||
|
||||
//装备打孔
|
||||
public async digHole(msg: {eid: number, id: number}, session: BackendSession) {
|
||||
let { eid, id } = msg;
|
||||
let roleId: string = session.get('roleId');
|
||||
let roleName: string = session.get('roleName');
|
||||
let sid: string = session.get('sid');
|
||||
let equip = await EquipModel.getEquip(eid);
|
||||
let index = _.indexOf(equip.holes, {id});
|
||||
if (index > 0)
|
||||
return resResult(STATUS.EQUIP_HOLE_NOT_FIND);
|
||||
if (equip.holes[index].isOpen)
|
||||
return resResult(STATUS.EQUIP_HOLE_IS_DUG);
|
||||
let consumes:Array<{id: number, count: number}> = [];
|
||||
if (id == 1) {
|
||||
consumes = parseReward(EQUIP.EQUIP_ONE_HOLE);
|
||||
} else if (id == 2) {
|
||||
consumes = parseReward(EQUIP.EQUIP_TWO_HOLE);
|
||||
} else if (id == 3) {
|
||||
consumes = parseReward(EQUIP.EQUIP_THREE_HOLE);
|
||||
}
|
||||
let result = await handleCost(roleId, sid, consumes);
|
||||
if (!result)
|
||||
return resResult(STATUS.JEWEL_IS_NOT_FIND);
|
||||
equip.holes[index].isOpen = true;
|
||||
await EquipModel.updateEquipInfo(eid, {holes: equip.holes});
|
||||
return resResult(STATUS.SUCCESS,{curEquip:{seqId: eid, holes: equip.holes}});
|
||||
}
|
||||
|
||||
//TODO 装备打孔
|
||||
public async unlockEquipHole(msg: { }, session: BackendSession) {
|
||||
|
||||
//宝石镶嵌
|
||||
public async fillHole(msg: {eid: number, id: number, jewel: number}, session: BackendSession) {
|
||||
let { eid, id, jewel} = msg;
|
||||
let roleId: string = session.get('roleId');
|
||||
let sid: string = session.get('sid');
|
||||
let consumes:Array<{id: number, count: number}> = [];
|
||||
let equip = await EquipModel.getEquip(eid);
|
||||
let index = _.indexOf(equip.holes, {id});
|
||||
if (index > 0)
|
||||
return resResult(STATUS.EQUIP_HOLE_NOT_FIND);
|
||||
if (equip.holes[index].isOpen)
|
||||
return resResult(STATUS.EQUIP_HOLE_IS_DUG);
|
||||
consumes.push({id: jewel, count: 1});
|
||||
let result = await handleCost(roleId, sid, consumes);
|
||||
if (!result)
|
||||
return resResult(STATUS.JEWEL_IS_NOT_FIND);
|
||||
equip.holes[index].jewel = jewel;
|
||||
await EquipModel.updateEquipInfo(eid, {holes: equip.holes});
|
||||
return resResult(STATUS.SUCCESS,{curEquip:{seqId: eid, holes: equip.holes}});
|
||||
}
|
||||
|
||||
//TODO 宝石镶嵌
|
||||
public async setEquipGemstone(msg: { }, session: BackendSession) {
|
||||
|
||||
//宝石合成
|
||||
public async composeJewel(msg: {jewel: number, count: number, consumes: Array<{id:number, count:number}>}, session: BackendSession) {
|
||||
let { count, consumes, jewel} = msg;
|
||||
let roleId: string = session.get('roleId');
|
||||
let roleName: string = session.get('roleName');
|
||||
let sid: string = session.get('sid');
|
||||
let goodInfo = getGoodById(jewel);
|
||||
let {type} = ITID.get(goodInfo.itid);
|
||||
if (type != CONSUME_TYPE.JEWEL)
|
||||
return resResult(STATUS.WRONG_PARMS);
|
||||
if (!goodInfo.composeMaterial)
|
||||
return resResult(STATUS.WRONG_PARMS);
|
||||
//检查宝石消耗是否合法TODO
|
||||
for (let {id, count} of goodInfo.composeMaterial) {
|
||||
|
||||
}
|
||||
let res = await handleCost(roleId, sid, consumes);
|
||||
if (!res)
|
||||
return resResult(STATUS.BATTLE_CONSUMES_NOT_ENOUGH);
|
||||
let result = await addItems(roleId, roleName, sid, [{id: jewel, count: count}]);
|
||||
return resResult(STATUS.SUCCESS,{goods:result});
|
||||
}
|
||||
|
||||
//TODO 宝石合成
|
||||
public async composeGemstone(msg: { }, session: BackendSession) {
|
||||
|
||||
//宝石卸下
|
||||
public async putOffHole(msg: {eid: number, id: number}, session: BackendSession) {
|
||||
let { eid, id} = msg;
|
||||
let roleId: string = session.get('roleId');
|
||||
let roleName: string = session.get('roleName');
|
||||
let sid: string = session.get('sid');
|
||||
let goods:Array<{id: number, count: number}> = [];
|
||||
let equip = await EquipModel.getEquip(eid);
|
||||
let index = _.indexOf(equip.holes, {id});
|
||||
if (index > 0)
|
||||
return resResult(STATUS.EQUIP_HOLE_NOT_FIND);
|
||||
if (equip.holes[index].isOpen)
|
||||
return resResult(STATUS.EQUIP_HOLE_IS_DUG);
|
||||
goods.push({id: equip.holes[index].jewel, count: 1});
|
||||
equip.holes[index].jewel = 0;
|
||||
await EquipModel.updateEquipInfo(eid, {holes: equip.holes});
|
||||
let result = await addItems(roleId, roleName, sid, goods);
|
||||
return resResult(STATUS.SUCCESS,{curEquip:{seqId: eid, holes: equip.holes, goods: result}});
|
||||
}
|
||||
}
|
||||
@@ -21,14 +21,14 @@ export class HeroHandler {
|
||||
|
||||
private channelService: ChannelService = this.app.get('channelService');
|
||||
|
||||
public async test(msg: { id: number, count: number, seqId:number}, session: BackendSession) {
|
||||
public async test(msg: { id: number, count: number, seqId:number, type:number}, session: BackendSession) {
|
||||
let roleId: string = session.get('roleId');
|
||||
let roleName: string = session.get('roleName');
|
||||
let sid: string = session.get('sid');
|
||||
|
||||
let {id, count, seqId} = msg;
|
||||
let {id, count, seqId, type} = msg;
|
||||
|
||||
let result = await handleCost(roleId, sid, [{id, count, seqId}] );
|
||||
let result = await handleCost(roleId, sid, [{id, count, seqId, type}] );
|
||||
//let result = await addItems(roleId, roleName, sid, [{id, count}] );
|
||||
if(!result) {
|
||||
return resResult(STATUS.BATTLE_CONSUMES_NOT_ENOUGH);
|
||||
|
||||
@@ -145,7 +145,7 @@ export async function handleCost(roleId: string, sid: string, goods: Array<ItemI
|
||||
}
|
||||
//检查装备是否存在
|
||||
if (!!equips.length) {
|
||||
let resEquips = await EquipModel.getEquips(roleId, equips);
|
||||
let resEquips = await EquipModel.getEquips(equips);
|
||||
if (resEquips.length < equips.length)
|
||||
return false;
|
||||
}
|
||||
@@ -158,7 +158,7 @@ export async function handleCost(roleId: string, sid: string, goods: Array<ItemI
|
||||
|
||||
//删除装备
|
||||
if (!!equips.length) {
|
||||
await EquipModel.deleteEquips(roleId, equips);
|
||||
await EquipModel.deleteEquips(equips);
|
||||
pinus.app.get('channelService').pushMessageByUids('onEquipDel', resResult(STATUS.SUCCESS, {equips}), uids);
|
||||
}
|
||||
|
||||
|
||||
Reference in New Issue
Block a user