368 lines
12 KiB
TypeScript
368 lines
12 KiB
TypeScript
import DB from "../utils/DB";
|
||
import GameUtil from "../core/GameUtil";
|
||
import PlayerMgr from "./PlayerMgr";
|
||
import Relation from "./Relation";
|
||
import SKDataUtil from "../gear/SKDataUtil";
|
||
import SKLogger from "../gear/SKLogger";
|
||
import { MsgCode } from "../role/EEnum";
|
||
|
||
export default class RelationMgr {
|
||
static shared = new RelationMgr();
|
||
localRelationId: number;
|
||
relationsList: any;
|
||
relationDBTimer: any;
|
||
|
||
constructor() {
|
||
this.localRelationId = 0; //用于关系在未入库时标识用
|
||
this.relationsList = [];
|
||
}
|
||
|
||
init() {
|
||
DB.queryAllRelations((errorcode: any, list: any) => {
|
||
if (errorcode == MsgCode.SUCCESS) {
|
||
for (let rItem of list) {
|
||
let relation = new Relation(this);
|
||
relation.relationId = rItem.relationId;
|
||
try {
|
||
relation.members = SKDataUtil.jsonBy(rItem.members);
|
||
} catch (error) {
|
||
SKLogger.warn(`${relation.relationId}${error}`);
|
||
continue;
|
||
}
|
||
relation.members.forEach((e: any) => {
|
||
relation.memberIds.push(e.playerid);
|
||
});
|
||
relation.createTime = rItem.createTime;
|
||
relation.relationType = rItem.relationType;
|
||
relation.relationName = rItem.relationName;
|
||
relation.status = 1;
|
||
this.relationsList.push(relation);//[rItem.relationId] = relation;
|
||
}
|
||
}
|
||
});
|
||
|
||
DB.getRelationMaxId((errorcode: any, relationId: any) => {
|
||
if (errorcode == MsgCode.SUCCESS) {
|
||
this.localRelationId = relationId;
|
||
if (this.relationDBTimer != null) {
|
||
clearInterval(this.relationDBTimer);
|
||
this.relationDBTimer = null;
|
||
}
|
||
}
|
||
});
|
||
this.relationDBTimer = setInterval(() => {
|
||
DB.getRelationMaxId();
|
||
}, 60 * 1000);
|
||
|
||
}
|
||
|
||
//关系群内操作
|
||
doRelations() {
|
||
}
|
||
|
||
getRelationByMembers(data: any) {
|
||
}
|
||
|
||
applyRelation(player: any, data: any) {
|
||
let checkRes = this.checkRelation(player, data.relationType, data.relationName, data.members);
|
||
if (checkRes == 0) {
|
||
let relation = new Relation(this);
|
||
this.localRelationId = ++this.localRelationId;
|
||
relation.applyRelation(player, this.localRelationId, data.members, data.relationName, data.relationType, 1);
|
||
this.relationsList.push(relation);
|
||
} else {
|
||
player.send('s2c_relation_apply_res', {
|
||
ecode: MsgCode.FAILED,
|
||
errorMsg: checkRes + ''
|
||
});
|
||
}
|
||
}
|
||
|
||
addRelationMember(player: any, data: any) {
|
||
let checkRes = this.checkRelation(player, data.relationType, data.relationName, data.members, data.relationId, 2);
|
||
if (checkRes == 0) {
|
||
let relation = this.relationsList.find((e: any) => {
|
||
return e.relationId = data.relationId;
|
||
})
|
||
if (relation) {
|
||
relation.applyRelation(player, relation.relationId, data.members, relation.relationName, relation.relationType, 2);
|
||
}
|
||
} else {
|
||
player.send('s2c_relation_apply_res', {
|
||
ecode: MsgCode.FAILED,
|
||
errorMsg: checkRes + ''
|
||
});
|
||
}
|
||
}
|
||
/*
|
||
* operateType: 1,新建关系 2,新人加入
|
||
* return 0，成功，1,重名 2，重复创建相同关系 3,人数超过限制 4，成员超过关系人数限制
|
||
*/
|
||
checkRelation(player: any, relation_Type: any, relationName: string = '', members: any = [], relationId: number = -1, operateType: number = 1) {
|
||
if (operateType == 1 && relationName != '') {
|
||
//如果是新关系，需要判断是否已经重名
|
||
let relationIndex = this.relationsList.findIndex((e: any) => {
|
||
return e.relationName == relationName && e.doShow();
|
||
})
|
||
if (relationIndex != -1) {
|
||
//已经有相同的名字了
|
||
return 1;
|
||
}
|
||
}
|
||
//判断是否是重复创建
|
||
let reCreate = this.relationsList.some((e: any) => {
|
||
return e.memberIds.sort().toString() == members.sort().toString();
|
||
});
|
||
|
||
if (reCreate)
|
||
return 2;
|
||
|
||
//判断人数是否超过限制
|
||
if (members.length > GameUtil.relationTypeMembersCount[relation_Type]) {
|
||
//人数超过上限
|
||
return 3;
|
||
}
|
||
|
||
//判断成员已拥有的结拜关系数量
|
||
let checkMaxJoin = members.some((e: any) => {
|
||
let broCount = 0;
|
||
for (var i = 0; i < this.relationsList.length; i++) {
|
||
let relation = this.relationsList[i];
|
||
if (relation.relationId == relationId && relation.doShow()) {
|
||
//已经加入过该关系
|
||
return false;
|
||
} else if (relation_Type == GameUtil.relationType.Brother && relation.hasMember(e) && relation.relationType == GameUtil.relationType.Brother && relation.doShow()) {
|
||
broCount = ++broCount;
|
||
}
|
||
}
|
||
|
||
if (broCount >= 3)
|
||
return true;
|
||
return false;
|
||
|
||
})
|
||
|
||
if (checkMaxJoin)
|
||
return 4; //每人最多同时拥有三个结拜关系
|
||
|
||
//判断是否在线
|
||
members.forEach((e: any): number => {
|
||
let player = PlayerMgr.shared.getPlayerByRoleId(e.playerid);
|
||
if (!player) {
|
||
return 5; //所有成员必须在线
|
||
}
|
||
return 0;
|
||
});
|
||
|
||
//判断成员身上携带银两数
|
||
let lessMoney = members.some((e: any): boolean => {
|
||
let player = PlayerMgr.shared.getPlayerByRoleId(e.playerid);
|
||
if (player) {
|
||
let money = player.GetMoney(0);
|
||
if (money < GameUtil.brotherMoney)
|
||
return true
|
||
}
|
||
return false;
|
||
})
|
||
if (lessMoney) {
|
||
return 6;
|
||
}
|
||
return 0;
|
||
|
||
}
|
||
|
||
confirmRelation(player: any, data: any) {
|
||
let relations = this.relationsList.filter((e: any): boolean => {
|
||
if (e.relationId == data.relationId)
|
||
return true;
|
||
return false;
|
||
});
|
||
|
||
let relation = relations[0];
|
||
relation.confirmRelationApply(player, data.agree);
|
||
}
|
||
|
||
getRelationListByRoleId(player: any, data: any) {
|
||
let relations = this.relationsList.filter((e: any): boolean => {
|
||
if (e.members.some((e: any) => {
|
||
return e.playerid == data.roleId;
|
||
})) {
|
||
return e.relationType == data.relationType && e.doShow();
|
||
}
|
||
return false;
|
||
|
||
});
|
||
let jsonValue = [];
|
||
for (let i = 0; i < relations.length; i++) {
|
||
let relation = relations[i];
|
||
let item = { name: relation.relationName, createTime: relation.createTime, members: SKDataUtil.toJson(relation.members,"{}"), relationType: relation.relationType, relationId: relation.relationId };
|
||
jsonValue.push(item);
|
||
}
|
||
let str = SKDataUtil.toJson(jsonValue,"[]");
|
||
player.send('s2c_relation_List', {
|
||
ecode: MsgCode.SUCCESS,
|
||
relationList: str,
|
||
operationType: data.operationType
|
||
});
|
||
}
|
||
|
||
leaveRelation(player: any, data: any) {
|
||
let relation = this.relationsList.find((e: any) => {
|
||
if (e.members.some((e: any) => {
|
||
return e.playerid == data.roleId;
|
||
})) {
|
||
return e.relationId == data.relationId;
|
||
}
|
||
return false;
|
||
});
|
||
if (relation) {
|
||
relation.leaveRelation(data);
|
||
}
|
||
}
|
||
|
||
deleteRelation(relation: any, relationList: any) {
|
||
let m_index = -1;
|
||
let relationDel = relationList.find((e: any, index: any) => {
|
||
if (e.relationId == relation.relationId)
|
||
m_index = index;
|
||
return true;
|
||
});
|
||
|
||
if (relationDel && m_index != -1) {
|
||
relationList.splice(m_index, 1);
|
||
relationDel = null;
|
||
}
|
||
}
|
||
|
||
|
||
deleteTempRelationByPlayer(roleid: any) {
|
||
let tempRelationList: any = [];
|
||
this.relationsList.forEach((e: any, index: any): boolean => {
|
||
let r = false;
|
||
if (e.members.some((e: any): boolean => {
|
||
return e.playerid == roleid;
|
||
})) {
|
||
r = (e.status == -1 ? true : false);
|
||
if (r) {
|
||
let relation = { relation: e, index: index };
|
||
tempRelationList.push(relation);
|
||
}
|
||
return r;
|
||
} else {
|
||
return r;
|
||
}
|
||
});
|
||
|
||
if (tempRelationList.length > 0) {
|
||
tempRelationList.forEach((e: any) => {
|
||
e.relation.members.every((t: any) => {
|
||
let p = PlayerMgr.shared.getPlayerByRoleId(t.playerid);
|
||
if (p) {
|
||
p.send('s2c_relation_reject', {
|
||
rejectRoleId: roleid,
|
||
relationId: e.relation.relationId
|
||
});
|
||
}
|
||
return true;
|
||
});
|
||
|
||
this.relationsList.splice(e.index, 1);
|
||
e.relation = null;
|
||
});
|
||
}
|
||
}
|
||
|
||
rejectRelation(player: any, data: any) {
|
||
|
||
let m_index = -1;
|
||
let relationDel = this.relationsList.find((e: any, index: any): boolean => {
|
||
if (e.relationId == data.relationId) {
|
||
m_index = index;
|
||
return true;
|
||
}
|
||
return false;
|
||
});
|
||
|
||
if (relationDel) {
|
||
/*
|
||
relationDel.members.array.forEach(e =>{
|
||
let p = PlayerMgr.shared.getPlayerByRoleId(e.playerid);
|
||
if(p){
|
||
p.send('s2c_relation_reject',{
|
||
rejectRoleId: data.roldId,
|
||
relationId:relationDel.relationId
|
||
});
|
||
}
|
||
|
||
if(relationDel.newMembersIds.length > 0){
|
||
|
||
}
|
||
});
|
||
|
||
*/
|
||
let memberList = relationDel.members;
|
||
for (let i = memberList.length - 1; i >= 0; i--) {
|
||
let item = memberList[i];
|
||
let p = PlayerMgr.shared.getPlayerByRoleId(item.playerid);
|
||
if (p) {
|
||
p.send('s2c_relation_reject', {
|
||
rejectRoleId: data.roldId,
|
||
relationId: relationDel.relationId
|
||
});
|
||
}
|
||
|
||
//删除新加的用户
|
||
if (relationDel.newMembersIds.length > 0) {
|
||
let index = relationDel.newMembersIds.indexOf(item.playerid);
|
||
if (index != -1) {
|
||
memberList.splice(i, 1);
|
||
}
|
||
}
|
||
}
|
||
|
||
if (relationDel.newMembersIds.length > 0) {
|
||
let memberIds = relationDel.memberIds;
|
||
for (var i = memberIds.length - 1; i >= 0; i--) {
|
||
|
||
//删除新加的用户
|
||
if (relationDel.newMembersIds.length > 0) {
|
||
let index = relationDel.newMembersIds.indexOf(memberIds[i]);
|
||
if (index != -1) {
|
||
memberIds.splice(index, 1);
|
||
}
|
||
}
|
||
}
|
||
|
||
relationDel.newMembersIds = [];
|
||
|
||
}
|
||
|
||
if (relationDel.status == -1) {
|
||
this.relationsList.splice(m_index, 1);
|
||
relationDel = null;
|
||
}
|
||
}
|
||
|
||
}
|
||
|
||
update(dt: number) {
|
||
if (dt % (1000 * 60) == 0) {
|
||
this.saveData();
|
||
}
|
||
}
|
||
|
||
saveData() {
|
||
let dbList = this.relationsList.filter((e: any) => {
|
||
return e.doDB();
|
||
});
|
||
|
||
dbList.forEach((e: any) => {
|
||
e.saveData();
|
||
});
|
||
}
|
||
|
||
joinRelation(relationId: any, player: any) {
|
||
}
|
||
|
||
}
|