mirror of
https://github.com/Kiritow/OpenComputerScripts.git
synced 2024-03-22 13:10:46 +08:00
Update transport system
This commit is contained in:
parent
79b82f3f8c
commit
eabe7757d5
73
libevent.lua
73
libevent.lua
|
|
@ -1,5 +1,6 @@
|
|||
require("checkarg")
|
||||
local event=require("event")
|
||||
local uuid=require("uuid")
|
||||
|
||||
local internal_evtb={}
|
||||
|
||||
|
|
@ -113,7 +114,11 @@ local function doEventTranslate(raw_event)
|
|||
t["address"]=a
|
||||
t["signalName"]=b
|
||||
t["signalValue"]=c
|
||||
else -- Unknown Event
|
||||
-- libevent events
|
||||
elseif(name=="EventBus_NewEvent") then
|
||||
t["id"]=a
|
||||
-- Unknown Event
|
||||
else
|
||||
if(canEventTranslate(name)) then -- Try Translate
|
||||
doEventCustomTranslate(raw_event,t)
|
||||
else -- Cannot Translate
|
||||
|
|
@ -200,3 +205,69 @@ function RemoveTimer(TimerID)
|
|||
checknumber(TimerID)
|
||||
return event.cancel(TimerID)
|
||||
end
|
||||
|
||||
--- EventBus: Queued event bus.
|
||||
--- Notice that event bus can only handle event packages.
|
||||
function CreateEventBus()
|
||||
return
|
||||
{
|
||||
listeners={},
|
||||
events={},
|
||||
id=uuid.next()
|
||||
}
|
||||
end
|
||||
|
||||
function EventBusListen(t,event_name)
|
||||
checktable(t)
|
||||
checkstring(event_name)
|
||||
table.insert(t.listeners,
|
||||
AddEventListener(event_name,
|
||||
function(epack)
|
||||
table.insert(t.events,epack)
|
||||
event.push("EventBus_NewEvent",t.id)
|
||||
end
|
||||
)
|
||||
)
|
||||
end
|
||||
|
||||
function GetNextEvent(t,wait_second)
|
||||
checktable(t)
|
||||
if(wait_second~=nil) then
|
||||
checknumber(wait_second)
|
||||
end
|
||||
|
||||
if(t.events[1]~=nil) then
|
||||
local e=t.events[1]
|
||||
table.remove(t.events,1)
|
||||
return e
|
||||
elseif(wait_second~=nil) then
|
||||
if(wait_second<0) then
|
||||
while true do
|
||||
local ev=WaitEvent("EventBus_NewEvent")
|
||||
if(ev.id==t.id) then
|
||||
break
|
||||
end
|
||||
end
|
||||
else
|
||||
local ev=WaitEvent("EventBus_NewEvent",wait_second)
|
||||
if(ev==nil) then
|
||||
return nil
|
||||
elseif(ev.id~=t.id) then
|
||||
return nil
|
||||
end
|
||||
end
|
||||
|
||||
local e=t.events[1]
|
||||
table.remove(t.events,1)
|
||||
return e
|
||||
else
|
||||
return nil
|
||||
end
|
||||
end
|
||||
|
||||
function DestroyEventBus(t)
|
||||
for k,v in pairs(t.listeners) do
|
||||
RemoveEventListener(v)
|
||||
end
|
||||
end
|
||||
|
||||
|
|
|
|||
|
|
@ -2,7 +2,61 @@ local component=require("component")
|
|||
require("libevent")
|
||||
require("util")
|
||||
|
||||
--- Auto Configure
|
||||
local network_card = proxy("modem")
|
||||
|
||||
local function checkDevice()
|
||||
print("Checking Devices...")
|
||||
|
||||
local function doCheckDevice(device)
|
||||
if(device==nil) then
|
||||
error("Some device is nil. Please double check your configure.")
|
||||
end
|
||||
end
|
||||
|
||||
doCheckDevice(network_card)
|
||||
|
||||
print("Device check pass.")
|
||||
end
|
||||
|
||||
local idt={}
|
||||
|
||||
local function getNextID()
|
||||
local nextid=1
|
||||
for k,v in pairs(idt) do
|
||||
if(v>nextid) then nextid=v+1 end
|
||||
end
|
||||
return nextid
|
||||
end
|
||||
|
||||
local function main()
|
||||
checkDevice()
|
||||
|
||||
network_card.open(10010)
|
||||
|
||||
print("Center Started. Press Ctrl+C to stop.")
|
||||
|
||||
while true do
|
||||
local e=WaitEvent()
|
||||
if(e~=nil) then
|
||||
if(e.event=="modem_message" and e.data[1]=="TSCM") then
|
||||
if(e.data[2]=="req") then
|
||||
if(e.data[3]=="store") then
|
||||
local id=getNextID()
|
||||
network_card.send(e.senderAddress,10011,"TSCM","ack","pass",id)
|
||||
print("NextID: ",id)
|
||||
end
|
||||
end
|
||||
elseif(e.event=="interrupted") then
|
||||
break
|
||||
end
|
||||
end
|
||||
end
|
||||
|
||||
network_card.close(10010)
|
||||
end
|
||||
|
||||
print("Transport System Center Started.")
|
||||
print("Author: Kiritow")
|
||||
main()
|
||||
print("Transport System Center Stopped.")
|
||||
|
|
@ -1,5 +1,6 @@
|
|||
local component=require("component")
|
||||
local sides=require("sides")
|
||||
local thread=require("thread")
|
||||
require("libevent")
|
||||
require("util")
|
||||
|
||||
|
|
@ -26,12 +27,13 @@ local load_box_side
|
|||
local unload_box_side
|
||||
local loading=0 -- 0 Free 1 Ready 2 Processing
|
||||
local unloading=0
|
||||
local lockway=0 -- 0 Free 1 Loading 2 Unloading
|
||||
|
||||
|
||||
-- Value: 1 Green 2 Blinking Yello 3 Yello 4 Blinking Red 5 Red
|
||||
-- Value: 1 Green 2 Blinking Yellow 3 Yellow 4 Blinking Red 5 Red
|
||||
local green=1
|
||||
local byello=2
|
||||
local yello=3
|
||||
local byellow=2
|
||||
local yellow=3
|
||||
local bred=4
|
||||
local red=5
|
||||
|
||||
|
|
@ -76,14 +78,23 @@ local function checkDevice()
|
|||
checkSigName("BInCtrl")
|
||||
checkSigName("LoadCartCtrl")
|
||||
checkSigName("LoadBoxCtrl")
|
||||
checkSigName("LoadLamp")
|
||||
checkSigName("UnloadCartCtrl")
|
||||
checkSigName("UnloadBoxCtrl")
|
||||
checkSigName("UnloadLamp")
|
||||
checkSigName("OutCtrl")
|
||||
checkSigName("OutSwitchCtrl")
|
||||
|
||||
t=digital_receiver.getSignalNames()
|
||||
checkSigName("LoadCartSig")
|
||||
checkSigName("UnloadCartSig")
|
||||
local function checkSigNameX(name)
|
||||
checkSigName(name)
|
||||
if(digital_receiver.getAspect(name)~=red) then
|
||||
error("CheckSigNameX: Failed to check cart signals. Value must be red while initializing.")
|
||||
end
|
||||
end
|
||||
|
||||
checkSigNameX("LoadCartSig")
|
||||
checkSigNameX("UnloadCartSig")
|
||||
|
||||
local function checkRoutingTable(device)
|
||||
if(device.getRoutingTableTitle()==false) then
|
||||
|
|
@ -147,6 +158,8 @@ local function resetDevice()
|
|||
print("Reseting Devices...")
|
||||
|
||||
digital_controller.setEveryAspect(red)
|
||||
setSignal("UnloadBoxCtrl",green) --- Lock unload box.
|
||||
setSignal("LoadLamp",green)
|
||||
|
||||
route_ab_load.setRoutingTable({})
|
||||
route_ba_load.setRoutingTable({})
|
||||
|
|
@ -156,6 +169,13 @@ local function resetDevice()
|
|||
print("Device reset done.")
|
||||
end
|
||||
|
||||
local function setLoadLamp(sigcolor)
|
||||
setSignal("LoadLamp",sigcolor)
|
||||
end
|
||||
|
||||
local function setUnloadLamp(sigcolor)
|
||||
setSignal("UnloadLamp",sigcolor)
|
||||
end
|
||||
|
||||
local function lockLoadChest()
|
||||
setSignal("LoadBoxCtrl",green)
|
||||
|
|
@ -165,6 +185,127 @@ local function unlockLoadChest()
|
|||
setSignal("LoadBoxCtrl",red)
|
||||
end
|
||||
|
||||
local function lockUnloadChest()
|
||||
setSignal("UnloadBoxCtrl",green)
|
||||
end
|
||||
|
||||
local function unlockUnloadChest()
|
||||
setSignal("UnloadBoxCtrl",red)
|
||||
end
|
||||
|
||||
|
||||
local function getNewTransID(cnt)
|
||||
print("Getting new transfer id...")
|
||||
network_card.open(10011)
|
||||
network_card.broadcast(10010,"TSCM","req","store",cnt)
|
||||
e=WaitEvent("modem_message",10)
|
||||
local ret
|
||||
if(e~=nil and e.data[1]=="TSCM" and e.data[2]=="ack" and e.data[3]=="pass") then
|
||||
ret=e.data[4]
|
||||
else
|
||||
ret=nil
|
||||
end
|
||||
network_card.close(10011)
|
||||
return ret
|
||||
end
|
||||
|
||||
local function SetTicket(Dest)
|
||||
routing_track.setDestination(Dest)
|
||||
end
|
||||
|
||||
local function doLoadWork(item_cnt)
|
||||
print("LoadWork: Ready.")
|
||||
local id=getNewTransID(item_cnt)
|
||||
if(id==nil) then
|
||||
print("LoadWork: Failed to get new transID.")
|
||||
print("LoadWork: item rollback started.")
|
||||
|
||||
setLoadLamp(byellow)
|
||||
local sz=load_transposer.getInventorySize(sides.down)
|
||||
local cnt=1
|
||||
for i=1,sz,1 do
|
||||
if(load_transposer.getStackInSlot(sides.down,i)~=nil) then
|
||||
load_transposer.transferItem(sides.down,load_box_side)
|
||||
cnt=cnt+1
|
||||
end
|
||||
end
|
||||
|
||||
print("LoadWork: item rollback finished.")
|
||||
loading=0
|
||||
setLoadLamp(green)
|
||||
unlockLoadChest()
|
||||
else
|
||||
id=math.ceil(id)
|
||||
print("LoadWork: Transfer id got.")
|
||||
print("LoadWork: Setting routing table...")
|
||||
local trainid="TC_" .. tostring(id)
|
||||
local routestr="Dest=" .. trainid
|
||||
print("LoadWork: ",routestr)
|
||||
local routetb={[1]=routestr}
|
||||
route_ab_load.setRoutingTable(routetb)
|
||||
route_ba_load.setRoutingTable(routetb)
|
||||
|
||||
local backtrainid="TR_" .. tostring(id)
|
||||
|
||||
print("LoadWork: Routing table set.")
|
||||
|
||||
local bus=CreateEventBus()
|
||||
EventBusListen(bus,"minecart")
|
||||
|
||||
local function trigger()
|
||||
setSignal("LoadCartCtrl",green)
|
||||
os.sleep(0.5)
|
||||
setSignal("LoadCartCtrl",red)
|
||||
end
|
||||
|
||||
local function lockOutWay()
|
||||
while(lockway~=0) do
|
||||
os.sleep(1)
|
||||
end
|
||||
lockway=1
|
||||
end
|
||||
|
||||
local function unlockOutWay()
|
||||
lockway=0
|
||||
end
|
||||
|
||||
while true do
|
||||
local e=GetNextEvent(bus)
|
||||
if(e.event=="minecart") then
|
||||
print("LoadWork: Minecart arrived. Start Loading...")
|
||||
if(e.minecartType=="locomotive_creative") then
|
||||
print("LoadWork: Skipping locomotive.")
|
||||
print("LoadWork: Try locking outway...")
|
||||
lockOutWay()
|
||||
print("LoadWork: Outway locked.")
|
||||
SetTicket(backtrainid)
|
||||
setLoadLamp(red)
|
||||
elseif(e.minecartType=="cart_chest") then
|
||||
print("LoadWork: Filling chest cart...")
|
||||
while(digital_receiver.getAspect("LoadCartSig")==red) do
|
||||
os.sleep(1)
|
||||
end
|
||||
print("LoadWork: Chest cart filled.")
|
||||
trigger()
|
||||
elseif(e.minecartType=="cart_worldspike_admin") then
|
||||
print("LoadWork: Found world spike. Finish.")
|
||||
trigger()
|
||||
unlockOutWay()
|
||||
break
|
||||
else
|
||||
print("LoadWork: Skipping unknown cart_type: " .. e.minecartType)
|
||||
trigger()
|
||||
end
|
||||
end
|
||||
end
|
||||
|
||||
DestroyEventBus(bus)
|
||||
|
||||
--- Clean Up
|
||||
setLoadLamp(green)
|
||||
unlockLoadChest()
|
||||
end
|
||||
end
|
||||
|
||||
local function startLoad()
|
||||
if(loading>0) then
|
||||
|
|
@ -182,13 +323,49 @@ local function startLoad()
|
|||
end
|
||||
end
|
||||
|
||||
print("startLoad: " .. cnt-1 .. " item transferred.")
|
||||
unlockLoadChest()
|
||||
print("startLoad: " .. cnt-1 .. " item transferred to internal chest")
|
||||
loading=1
|
||||
thread.create(doLoadWork,cnt);
|
||||
|
||||
setLoadLamp(yellow)
|
||||
print("Info: You items have been submitted.")
|
||||
end
|
||||
|
||||
local function storeMain()
|
||||
setLoadLamp(byellow)
|
||||
print("Please put your items to inbox.")
|
||||
print("Once you finished it, press enter")
|
||||
io.read()
|
||||
print("Start loading...")
|
||||
startLoad()
|
||||
end
|
||||
|
||||
local function main()
|
||||
checkDevice()
|
||||
resetDevice()
|
||||
|
||||
while true do
|
||||
print(
|
||||
"-------------\n" ..
|
||||
"Action List\n" ..
|
||||
"1 Store items\n" ..
|
||||
"2 Get items\n" ..
|
||||
"3 Exit\n" ..
|
||||
"-------------"
|
||||
)
|
||||
local id=io.read("*num")
|
||||
io.read()
|
||||
if(id==1) then
|
||||
storeMain()
|
||||
elseif(id==2) then
|
||||
getMain()
|
||||
elseif(id==3) then
|
||||
break
|
||||
end
|
||||
end
|
||||
|
||||
resetDevice()
|
||||
unlockUnloadChest()
|
||||
end
|
||||
|
||||
print("Transport System Client Started.")
|
||||
|
|
|
|||
Loading…
Reference in New Issue
Block a user