Refactored BUIO

This commit is contained in:
Treeku
2014-05-16 08:01:27 +01:00
parent 212d2cf38c
commit e763da8d61
5 changed files with 214 additions and 227 deletions
+184 -113
View File
@@ -22,67 +22,129 @@
package resources.objects.building;
import java.io.Serializable;
import java.util.Map;
import java.util.Vector;
import java.util.concurrent.atomic.AtomicReference;
import org.apache.mina.core.buffer.IoBuffer;
import main.NGECore;
import resources.common.OutOfBand;
import resources.datatables.DisplayType;
import resources.datatables.Options;
import resources.objects.ObjectMessageBuilder;
import resources.objects.cell.CellObject;
import resources.objects.creature.CreatureObject;
import resources.objects.tangible.TangibleObject;
import com.sleepycat.persist.model.Entity;
import com.sleepycat.persist.model.NotPersistent;
import engine.clientdata.ClientFileManager;
import engine.clientdata.visitors.PortalVisitor;
import engine.clients.Client;
import engine.resources.objects.Baseline;
import engine.resources.objects.IPersistent;
import engine.resources.scene.Planet;
import engine.resources.scene.Point3D;
import engine.resources.scene.Quaternion;
@Entity(version=6)
public class BuildingObject extends TangibleObject implements IPersistent, Serializable {
private static final long serialVersionUID = 1L;
@NotPersistent
private transient BuildingMessageBuilder messageBuilder;
private float maintenanceAmount = 0;
private int BMR = 0;
private String deedTemplate="";
private boolean residency=false;
private byte privacy=(byte)0;
public static byte PRIVATE = (byte)0;
public static byte PUBLIC = (byte)1;
private short maximumStorageCapacity=0;
private Vector<Long> entryList = new Vector<Long>(); // Preferably the OIDs should be stored, because of name changes
private Vector<Long> entryList = new Vector<Long>();
private Vector<Long> banList = new Vector<Long>();
public static final byte PRIVATE = (byte) 0;
public static final byte PUBLIC = (byte) 1;
public BuildingObject(long objectID, Planet planet, Point3D position, Quaternion orientation, String Template) {
super(objectID, planet, position, orientation, Template);
messageBuilder = new BuildingMessageBuilder(this);
this.setConditionDamage(100);
getBaseline(3).set("volume", 255);
setOptionsBitmask(Options.INVULNERABLE);
setConditionDamage(100);
setMaximumCondition(4320);
setStaticObject(true);
}
public BuildingObject() {
super();
messageBuilder = new BuildingMessageBuilder(this);
this.setConditionDamage(100);
getBaseline(3).set("volume", 255);
setOptionsBitmask(Options.INVULNERABLE);
setConditionDamage(100);
setMaximumCondition(4320);
setStaticObject(true);
}
@Override
public void initAfterDBLoad() {
super.init();
defendersList = new Vector<TangibleObject>();
getBaseline(3).set("volume", 255);
setOptionsBitmask(Options.INVULNERABLE);
setConditionDamage(100);
setMaximumCondition(4320);
}
@Override
public Baseline getOtherVariables() {
Baseline baseline = super.getOtherVariables();
baseline.put("maintainanceAmount", (float) 0);
baseline.put("baseMaintenanceRate", 0);
baseline.put("deedTemplate", "");
baseline.put("residency", false);
baseline.put("privacy", (byte) 0);
baseline.put("maximumStorageCapacity", (short) 0);
return baseline;
}
@Override
public Baseline getBaseline3() {
Baseline baseline = super.getBaseline3();
return baseline;
}
@Override
public Baseline getBaseline6() {
Baseline baseline = super.getBaseline6();
return baseline;
}
@Override
public Baseline getBaseline8() {
Baseline baseline = super.getBaseline8();
return baseline;
}
@Override
public Baseline getBaseline9() {
Baseline baseline = super.getBaseline9();
return baseline;
}
public Vector<CellObject> getCells() {
final Vector<CellObject> cells = new Vector<CellObject>();
this.viewChildren(this, true, false, (obj) -> {
if (obj instanceof CellObject) {
cells.add((CellObject) obj);
}
});
return cells;
}
public CellObject getCellByCellNumber(final int cellNumber) {
final AtomicReference<CellObject> ref = new AtomicReference<CellObject>();
synchronized(objectMutex) {
this.viewChildren(this, true, false, (obj) -> {
if(obj instanceof CellObject && ((CellObject) obj).getCellNumber() == cellNumber)
if (obj instanceof CellObject && ((CellObject) obj).getCellNumber() == cellNumber) {
ref.set((CellObject) obj);
}
});
}
return ref.get();
}
public int getCellNumberByObjectId(long objectId) {
@@ -98,168 +160,177 @@ public class BuildingObject extends TangibleObject implements IPersistent, Seria
}
public float getMaintenanceAmount() {
return maintenanceAmount;
return (float) otherVariables.get("maintenanceAmount");
}
public void setMaintenanceAmount(float maintenanceAmount) {
this.maintenanceAmount = maintenanceAmount;
}
public void setDeedTemplate(String deedTemplate){
this.deedTemplate = deedTemplate;
}
public String getDeedTemplate(){
return this.deedTemplate;
}
public String getBuildingName() {
return this.getCustomName();
}
public void setBuildingName(String buildingName, CreatureObject owner) {
//owner.getClient().getSession().write(messageBuilder.buildCustomNameDelta(this,buildingName));
this.setCustomName(buildingName);
((CreatureObject)owner).sendSystemMessage("Structure renamed.", (byte) 0);
otherVariables.set("maintenanceAmount", maintenanceAmount);
}
public int getBMR() {
return BMR;
return (int) otherVariables.get("baseMaintenanceRate");
}
public void setBMR(int BMR) {
this.BMR = BMR;
otherVariables.set("baseMaintenanceRate", BMR);
}
public String getDeedTemplate(){
return (String) otherVariables.get("deedTemplate");
}
public void setDeedTemplate(String deedTemplate){
otherVariables.set("deedTemplate", deedTemplate);
}
public String getBuildingName() {
return getCustomName();
}
public void setBuildingName(String buildingName, CreatureObject owner) {
setCustomName(buildingName);
((CreatureObject) owner).sendSystemMessage("Structure renamed.", DisplayType.Broadcast);
}
public boolean getResidency(){
return (boolean) otherVariables.get("residency");
}
public void setResidency(CreatureObject owner){
owner.sendSystemMessage("@player_structure:declared_residency", (byte) 1);
residency = true;
}
public boolean getResidency(){
return this.residency;
otherVariables.set("residency", true);
}
public byte getPrivacy() {
return privacy;
return (byte) otherVariables.get("privacy");
}
public String getPrivacyString() {
if (privacy==PRIVATE)
return "private";
if (privacy==PUBLIC)
return "public";
return "42";
switch (getPrivacy()) {
case PRIVATE:
return "private";
case PUBLIC:
return "public";
default:
return "42";
}
}
public void setPrivacy(byte privacy) {
this.privacy = privacy;
otherVariables.set("residency", privacy);
}
public Vector<TangibleObject> getItemsList() {
Vector<TangibleObject> items = new Vector<TangibleObject>();
getCells().forEach(c -> c.viewChildren(c, true, false, (item) -> {
if(!(item instanceof CreatureObject) && item.getTemplate() != "object/tangible/terminal/shared_terminal_player_structure.iff"
&& item.getTemplate() != "object/tangible/terminal/shared_terminal_city.iff"
&& item.getTemplate() != "object/tangible/terminal/shared_terminal_city_vote.iff")
&& item.getTemplate() != "object/tangible/terminal/shared_terminal_city.iff"
&& item.getTemplate() != "object/tangible/terminal/shared_terminal_city_vote.iff") {
items.add((TangibleObject) item);
}
}));
return items;
}
public short getMaximumStorageCapacity() {
return maximumStorageCapacity;
}
public void setMaximumStorageCapacity(short maximumStorageCapacity) {
this.maximumStorageCapacity = maximumStorageCapacity;
return (byte) otherVariables.get("maximumStorageCapacity");
}
public void setPermissionEntry(String name,CreatureObject owner){
public void setMaximumStorageCapacity(short maximumStorageCapacity) {
otherVariables.set("maximumStorageCapacity", maximumStorageCapacity);
}
public void setPermissionEntry(String name, CreatureObject owner){
Vector<String> entryListFirstNames = new Vector<String>();
for (long oid : entryList){
for (long oid : entryList) {
String firstName = NGECore.getInstance().characterService.getPlayerFirstName(oid);
entryListFirstNames.add(firstName);
}
entryListFirstNames.add("Peter");
entryListFirstNames.add("Jackson");
owner.getClient().getSession().write(messageBuilder.buildPermissionListCreate(entryListFirstNames, name));
}
public void setPermissionBan(String name,CreatureObject owner){
public void setPermissionBan(String name, CreatureObject owner){
Vector<String> banListFirstNames = new Vector<String>();
for (long oid : banList){
for (long oid : banList) {
String firstName = NGECore.getInstance().characterService.getPlayerFirstName(oid);
banListFirstNames.add(firstName);
}
}
banListFirstNames.add("Peter");
banListFirstNames.add("Smith");
owner.getClient().getSession().write(messageBuilder.buildPermissionListCreate(banListFirstNames, name));
}
public void addPlayerToEntryList(CreatureObject owner,long oid, String firstName){
public void addPlayerToEntryList(CreatureObject owner, long oid, String firstName){
if (!entryList.contains(oid)){
this.entryList.add(oid);
owner.sendSystemMessage(firstName+ " added to the list.", (byte)1); // player_added %NO added to the list.
entryList.add(oid);
owner.sendSystemMessage(OutOfBand.ProsePackage("@player_structure:player_removed", "TO", NGECore.getInstance().objectService.getObject(oid).getCustomName()), DisplayType.Screen);
}
}
public void removePlayerFromEntryList(CreatureObject owner,long oid, String firstName){
public void removePlayerFromEntryList(CreatureObject owner, long oid, String firstName){
if (entryList.contains(oid)){
this.entryList.remove(oid);
owner.sendSystemMessage(firstName+ " removed to the list.", (byte)1); // player_removed %NO removed from the list.
entryList.remove(oid);
owner.sendSystemMessage(OutOfBand.ProsePackage("@player_structure:player_removed", "TO", NGECore.getInstance().objectService.getObject(oid).getCustomName()), DisplayType.Screen);
}
}
public void addPlayerToBanList(CreatureObject owner,long oid, String firstName){
public void addPlayerToBanList(CreatureObject owner, long oid, String firstName){
if (!banList.contains(oid)){
this.banList.add(oid);
owner.sendSystemMessage(firstName+ " added to the list.", (byte)1);
banList.add(oid);
owner.sendSystemMessage(OutOfBand.ProsePackage("@player_structure:player_removed", "TO", NGECore.getInstance().objectService.getObject(oid).getCustomName()), DisplayType.Screen);
}
}
public void removePlayerFromBanList(CreatureObject owner,long oid, String firstName){
public void removePlayerFromBanList(CreatureObject owner, long oid, String firstName){
if (banList.contains(oid)){
this.banList.remove(oid);
owner.sendSystemMessage(firstName+ " removed to the list.", (byte)1);
banList.remove(oid);
owner.sendSystemMessage(OutOfBand.ProsePackage("@player_structure:player_removed", "TO", NGECore.getInstance().objectService.getObject(oid).getCustomName()), DisplayType.Screen);
}
}
@Override
public void notifyClients(IoBuffer buffer, boolean notifySelf) {
notifyObservers(buffer, false);
}
@Override
public ObjectMessageBuilder getMessageBuilder() {
synchronized(objectMutex) {
if (messageBuilder == null) {
messageBuilder = new BuildingMessageBuilder(this);
}
return messageBuilder;
}
}
@Override
public void sendBaselines(Client destination) {
if(destination == null || destination.getSession() == null) {
System.out.println("NULL session");
return;
if (destination != null && destination.getSession() != null) {
destination.getSession().write(getBaseline(3).getBaseline());
destination.getSession().write(getBaseline(6).getBaseline());
Client parent = ((getGrandparent() == null) ? null : getGrandparent().getClient());
if (parent != null && destination == parent) {
destination.getSession().write(getBaseline(8).getBaseline());
destination.getSession().write(getBaseline(9).getBaseline());
}
}
destination.getSession().write(messageBuilder.buildBaseline3());
destination.getSession().write(messageBuilder.buildBaseline6());
destination.getSession().write(messageBuilder.buildBaseline8());
destination.getSession().write(messageBuilder.buildBaseline9());
}
public Vector<CellObject> getCells() {
final Vector<CellObject> cells = new Vector<CellObject>();
this.viewChildren(this, true, false, (obj) -> {
if(obj instanceof CellObject)
cells.add((CellObject) obj);
});
return cells;
}
@Override
public void initAfterDBLoad() {
super.init();
messageBuilder = new BuildingMessageBuilder(this);
defendersList = new Vector<TangibleObject>();
}
public ObjectMessageBuilder getMessageBuilder() {
return messageBuilder;
public void sendListDelta(byte viewType, short updateType, IoBuffer buffer) {
super.sendListDelta(viewType, updateType, buffer);
}
}