Pump works \0/

Well i still need to check using other liquids than water
Also need to recode to actual put the water somewhere else
Need to make models, and textures
A Gui for the pump to select liquid to pump and set the volume
This commit is contained in:
Rseifert 2013-04-07 03:52:08 -04:00
parent 6939d3ca6f
commit 66a1502bf4
4 changed files with 91 additions and 56 deletions

View file

@ -28,17 +28,17 @@ public class PathfinderCheckerLiquid extends Pathfinder
@Override
public Set<Vector3> getConnectedNodes(Pathfinder finder, Vector3 currentNode)
{
System.out.println("AN:" + currentNode.toString());
//System.out.println("AN:" + currentNode.toString());
Set<Vector3> neighbors = new HashSet<Vector3>();
for (ForgeDirection direction : ForgeDirection.VALID_DIRECTIONS)
{
Vector3 pos = currentNode.clone().modifyPositionFromSide(direction);
System.out.println("AN:" + direction.ordinal() + ":" + pos.toString() + " " + pos.getBlockID(world) + ":" + pos.getBlockMetadata(world));
//System.out.println("AN:" + direction.ordinal() + ":" + pos.toString() + " " + pos.getBlockID(world) + ":" + pos.getBlockMetadata(world));
LiquidStack liquid = FluidHelper.getLiquidFromBlockId(pos.getBlockID(world));
if (liquid != null && (liquid.equals(resource) || resource == null))
if (pos.getBlockID(world) != 0 && liquid != null && (liquid.equals(resource) || resource == null))
{
System.out.println("ADD:" + pos.toString());
//System.out.println("ADD:" + pos.toString());
neighbors.add(pos);
}
}

View file

@ -15,11 +15,11 @@ import universalelectricity.core.path.IPathCallBack;
import universalelectricity.core.path.Pathfinder;
import universalelectricity.core.vector.Vector3;
public class PathfinderFindLiquid extends Pathfinder
public class PathfinderFindHighestSource extends Pathfinder
{
public static int highestY = 0;
public PathfinderFindLiquid(final World world, final LiquidStack resource, final Vector3... ignoreList)
public PathfinderFindHighestSource(final World world, final LiquidStack resource, final Vector3... ignoreList)
{
super(new IPathCallBack()
{
@ -30,7 +30,7 @@ public class PathfinderFindLiquid extends Pathfinder
Vector3 pos = currentNode.clone().modifyPositionFromSide(ForgeDirection.UP);
LiquidStack liquid = FluidHelper.getLiquidFromBlockId(pos.getBlockID(world));
if (liquid != null && (liquid.equals(resource) || resource == null))
if (pos.getBlockID(world) != 0 && liquid != null && (liquid.equals(resource) || resource == null))
{
neighbors.add(pos);
if (pos.intY() > highestY)
@ -44,7 +44,7 @@ public class PathfinderFindLiquid extends Pathfinder
{
pos = currentNode.clone().modifyPositionFromSide(direction);
liquid = FluidHelper.getLiquidFromBlockId(pos.getBlockID(world));
if (liquid != null && (liquid.equals(resource) || resource == null))
if (pos.getBlockID(world) != 0 && liquid != null && (liquid.equals(resource) || resource == null))
{
neighbors.add(pos);
if (pos.intY() > highestY)

View file

@ -10,6 +10,7 @@ import java.util.HashMap;
import java.util.Iterator;
import java.util.List;
import java.util.Map.Entry;
import java.util.Random;
import net.minecraft.block.Block;
import net.minecraft.entity.player.EntityPlayer;
@ -31,6 +32,7 @@ public class TileEntityDrain extends TileEntityFluidDevice implements ITankConta
private HashMap<TileEntityConstructionPump, LiquidStack> requestMap = new HashMap<TileEntityConstructionPump, LiquidStack>();
private List<Vector3> targetSources = new ArrayList<Vector3>();
private List<Vector3> updateQue = new ArrayList<Vector3>();
@Override
public String getMeterReading(EntityPlayer user, ForgeDirection side)
@ -52,65 +54,97 @@ public class TileEntityDrain extends TileEntityFluidDevice implements ITankConta
public void updateEntity()
{
if (!this.worldObj.isRemote && this.ticks % 10 == 0)
if (!this.worldObj.isRemote)
{
this.currentDrains = 0;
/* MAIN LOGIC PATH FOR DRAINING BODIES OF LIQUID */
if (this.drainSources)
if (this.ticks % (200 + new Random().nextInt(100)) == 0 && updateQue.size() > 0 )
{
TileEntity pipe = VectorHelper.getTileEntityFromSide(worldObj, new Vector3(this), this.getFacing().getOpposite());
if (pipe instanceof IFluidNetworkPart)
Iterator pp = this.updateQue.iterator();
while (pp.hasNext())
{
if (this.requestMap.size() > 0)
Vector3 vec = (Vector3) pp.next();
worldObj.markBlockForUpdate(vec.intX(), vec.intY(), vec.intZ());
pp.remove();
}
}
if (this.ticks % 20 == 0)
{
/* CLEANUP MAP */
Iterator mn = this.requestMap.entrySet().iterator();
while (mn.hasNext())
{
Entry<TileEntityConstructionPump, LiquidStack> entry = (Entry<TileEntityConstructionPump, LiquidStack>) mn.next();
TileEntity entity = entry.getKey();
if (entity == null)
{
this.getNextFluidBlock();
mn.remove();
}
else if (entity.isInvalid())
{
mn.remove();
}
}
for (Entry<TileEntityConstructionPump, LiquidStack> request : requestMap.entrySet())
this.currentDrains = 0;
/* MAIN LOGIC PATH FOR DRAINING BODIES OF LIQUID */
if (this.drainSources)
{
TileEntity pipe = VectorHelper.getTileEntityFromSide(worldObj, new Vector3(this), this.getFacing().getOpposite());
if (pipe instanceof IFluidNetworkPart)
{
if (this.requestMap.size() > 0)
{
if (this.currentDrains >= MAX_DRAIN_PER_PROCESS)
this.getNextFluidBlock();
for (Entry<TileEntityConstructionPump, LiquidStack> request : requestMap.entrySet())
{
break;
}
if (((IFluidNetworkPart) pipe).getNetwork().isConnected(request.getKey()) && targetSources.size() > 0)
{
Iterator it = this.targetSources.iterator();
while (it.hasNext())
if (this.currentDrains >= MAX_DRAIN_PER_PROCESS)
{
Vector3 loc = (Vector3) it.next();
if (this.currentDrains >= MAX_DRAIN_PER_PROCESS)
break;
}
if (((IFluidNetworkPart) pipe).getNetwork().isConnected(request.getKey()) && targetSources.size() > 0)
{
Iterator it = this.targetSources.iterator();
int m = 0;
while (it.hasNext())
{
break;
}
if (FluidHelper.isLiquidBlock(this.worldObj, loc))
{
LiquidStack stack = FluidHelper.getLiquidFromBlockId(loc.getBlockID(this.worldObj));
LiquidStack requestStack = request.getValue();
if (stack != null && requestStack != null && (requestStack.isLiquidEqual(stack) || requestStack.itemID == -1))
Vector3 loc = (Vector3) it.next();
if (this.currentDrains >= MAX_DRAIN_PER_PROCESS)
{
if (request.getKey().fill(0, stack, false) > 0)
break;
}
if (FluidHelper.isLiquidBlock(this.worldObj, loc))
{
LiquidStack stack = FluidHelper.getLiquidFromBlockId(loc.getBlockID(this.worldObj));
LiquidStack requestStack = request.getValue();
if (stack != null && requestStack != null && (requestStack.isLiquidEqual(stack) || requestStack.itemID == -1))
{
int requestAmmount = requestStack.amount - request.getKey().fill(0, stack, true);
if (requestAmmount <= 0)
if (request.getKey().fill(0, stack, false) > 0)
{
this.requestMap.remove(request);
}
else
{
request.setValue(FluidHelper.getStack(requestStack, requestAmmount));
}
loc.setBlock(this.worldObj, 0);
this.currentDrains++;
it.remove();
int requestAmmount = requestStack.amount - request.getKey().fill(0, stack, true);
if (requestAmmount <= 0)
{
this.requestMap.remove(request);
}
else
{
request.setValue(FluidHelper.getStack(requestStack, requestAmmount));
}
if (++m >= 3 && !this.updateQue.contains(loc))
{
this.updateQue.add(loc);
}
loc.setBlock(this.worldObj, 0, 0, 2);
this.currentDrains++;
it.remove();
}
}
}
}
}
}
}
}
@ -153,21 +187,23 @@ public class TileEntityDrain extends TileEntityFluidDevice implements ITankConta
this.requestMap.remove(pump);
}
}
public void addVectorToQue(Vector3 vector)
{
if(!this.targetSources.contains(vector))
if (!this.targetSources.contains(vector))
{
this.targetSources.add(vector);
}
}
/**
* Finds more liquid blocks using a path finder to be drained
*/
public void getNextFluidBlock()
{
System.out.println("Before Targets:"+this.targetSources.size());
System.out.println("Before Targets:" + this.targetSources.size());
/* FIND HIGHEST DRAIN POINT FIRST */
PathfinderFindLiquid path = new PathfinderFindLiquid(this.worldObj, null);
PathfinderFindHighestSource path = new PathfinderFindHighestSource(this.worldObj, null);
path.init(new Vector3(this.xCoord + this.getFacing().offsetX, this.yCoord + this.getFacing().offsetY, this.zCoord + this.getFacing().offsetZ));
int y = path.highestY;
@ -181,7 +217,7 @@ public class TileEntityDrain extends TileEntityFluidDevice implements ITankConta
this.targetSources.add(loc);
}
}
System.out.println("Targets:"+this.targetSources.size());
System.out.println("Targets:" + this.targetSources.size());
}
@Override

View file

@ -12,8 +12,7 @@ public class HydraulicNetworkHelper
{
/**
* Invalidates a TileEntity from the electrical network, thereby removing it from all
* electricity network that are adjacent to it.
* Invalidates a TileEntity
*/
public static void invalidate(TileEntity tileEntity)
{