gengby
2 years ago
12 changed files with 158 additions and 611 deletions
@ -1,243 +0,0 @@ |
|||
package org.nl.acs.auto.run; |
|||
|
|||
import cn.hutool.core.util.ObjectUtil; |
|||
import cn.hutool.core.util.StrUtil; |
|||
import lombok.extern.slf4j.Slf4j; |
|||
import org.nl.acs.AcsConfig; |
|||
import org.nl.acs.agv.server.NDCAgvService; |
|||
import org.nl.acs.device.service.DeviceService; |
|||
import org.nl.acs.device_driver.basedriver.agv.ndctwo.AgvNdcTwoDeviceDriver; |
|||
import org.nl.acs.ext.wms.service.AcsToWmsService; |
|||
import org.nl.acs.ext.wms.service.impl.AcsToWmsServiceImpl; |
|||
import org.nl.acs.instruction.service.InstructionService; |
|||
import org.nl.acs.instruction.service.dto.Instruction; |
|||
import org.nl.acs.instruction.service.impl.InstructionServiceImpl; |
|||
import org.nl.acs.opc.Device; |
|||
import org.nl.acs.opc.DeviceAppService; |
|||
import org.nl.modules.system.service.ParamService; |
|||
import org.nl.modules.system.service.impl.ParamServiceImpl; |
|||
import org.nl.modules.wql.util.SpringContextHolder; |
|||
import org.springframework.beans.factory.annotation.Autowired; |
|||
import org.springframework.stereotype.Component; |
|||
|
|||
import java.io.DataInputStream; |
|||
import java.io.DataOutputStream; |
|||
import java.io.IOException; |
|||
import java.net.Socket; |
|||
import java.util.Date; |
|||
|
|||
import static org.nl.acs.agv.server.impl.NDCAgvServiceImpl.Bytes2HexString; |
|||
|
|||
|
|||
@Slf4j |
|||
@Component |
|||
public class TwoNDC2SocketConnectionAutoRun extends AbstractAutoRunnable { |
|||
|
|||
Socket s; |
|||
String ip = "192.168.46.225"; |
|||
int port = 1234; |
|||
static DataOutputStream dos; |
|||
static DataInputStream dis; |
|||
private int recordTimeOut = 10000; |
|||
private Date recordTime; |
|||
String[] ERROR = new String[]{ |
|||
"货叉尖部传感器触发", "S300传感器触发", "载货状态改变", "急停按钮触发", "触边开关出发", "需要复位", |
|||
"停在充电位", "取货失败", "放货失败", "轮子打滑", "没有动作码不能进入站点", "取货时有货", "丢失定位", |
|||
"抬叉停止"}; |
|||
boolean bConnected = true; |
|||
|
|||
boolean isReConnect = false; |
|||
|
|||
@Autowired |
|||
ParamService paramService; |
|||
@Autowired |
|||
AutoRunService autoRunService; |
|||
|
|||
|
|||
public TwoNDC2SocketConnectionAutoRun() { |
|||
this.recordTime = new Date((new Date()).getTime() - (long) this.recordTimeOut); |
|||
} |
|||
|
|||
public String getCode() { |
|||
return TwoNDC2SocketConnectionAutoRun.class.getSimpleName(); |
|||
} |
|||
|
|||
public String getName() { |
|||
return "2楼2区域AGV系统"; |
|||
} |
|||
|
|||
public void autoRun() { |
|||
|
|||
try { |
|||
System.out.println("2楼2区域AGV系统链接开始"); |
|||
ParamService paramService = SpringContextHolder.getBean(ParamServiceImpl.class); |
|||
InstructionService instructionService = SpringContextHolder.getBean(InstructionServiceImpl.class); |
|||
AcsToWmsService acsToWmsService = SpringContextHolder.getBean(AcsToWmsServiceImpl.class); |
|||
NDCAgvService ndcAgvService = SpringContextHolder.getBean(NDCAgvService.class); |
|||
DeviceAppService deviceAppService = SpringContextHolder.getBean(DeviceAppService.class); |
|||
DeviceService deviceService = SpringContextHolder.getBean(DeviceService.class); |
|||
ip = paramService.findByCode(AcsConfig.AGVURL22).getValue(); |
|||
port = Integer.parseInt(paramService.findByCode(AcsConfig.AGVPORT22).getValue()); |
|||
byte[] b = new byte[1028]; |
|||
s = new Socket(ip, port); |
|||
System.out.println("2楼2区域AGV链接成功"); |
|||
dos = new DataOutputStream(s.getOutputStream()); |
|||
dis = new DataInputStream(s.getInputStream()); |
|||
|
|||
while (bConnected) { |
|||
int count = dis.read(b); |
|||
|
|||
if (count == -1) { |
|||
break; |
|||
} |
|||
|
|||
int[] arr = new int[count]; |
|||
StringBuffer bs = new StringBuffer(); |
|||
|
|||
for (int i = 0; i < count; i++) { |
|||
int temp = b[i]; |
|||
if (temp < 0) |
|||
temp += 256; |
|||
arr[i] = temp; |
|||
StringBuffer bs1 = new StringBuffer("0"); |
|||
bs.append(temp < 16 ? bs1.append(Integer.toHexString(temp)) : Integer.toHexString(temp)); |
|||
} |
|||
|
|||
System.out.println("收到请求参数：" + bs); |
|||
boolean flag = false; |
|||
if (arr[8] * 256 + arr[9] == 0x73) { |
|||
byte[] data = null; |
|||
System.out.println("接收agv上报信息：" + bs); |
|||
//执行阶段
|
|||
int phase = arr[16] * 256 + arr[17]; |
|||
// agv任务号
|
|||
int index = arr[12] * 256 + arr[13]; |
|||
//任务号
|
|||
int ikey = arr[26] * 256 + arr[27]; |
|||
//站点号
|
|||
int agvaddr = arr[18] * 256 + arr[19]; |
|||
//车号
|
|||
int carno = arr[20]; |
|||
Instruction inst = null; |
|||
if (ikey != 0) { |
|||
inst = instructionService.findByCodeFromCache(String.valueOf(ikey)); |
|||
} |
|||
log.info("接收agv上报信息：" + bs); |
|||
log.info("接收agv上报信息：" + "phase--" + phase + " index--" + index + " ikey--" + ikey + " agvaddr--" + agvaddr + " Car--" + carno); |
|||
Device device = null; |
|||
String device_code = null; |
|||
String old_device_code = null; |
|||
String emptyNum = null; |
|||
if (agvaddr != 0) { |
|||
old_device_code = deviceService.queryDeviceCodeByAddress(agvaddr); |
|||
if (StrUtil.contains(old_device_code, "-")) { |
|||
String[] point = old_device_code.split("-"); |
|||
device_code = point[0]; |
|||
} else if (StrUtil.contains(old_device_code, ".")) { |
|||
String[] point = old_device_code.split("\\."); |
|||
device_code = point[0]; |
|||
emptyNum = point[1]; |
|||
} else { |
|||
device_code = old_device_code; |
|||
} |
|||
device = deviceAppService.findDeviceByCode(device_code); |
|||
} |
|||
|
|||
AgvNdcTwoDeviceDriver agvNdcTwoDeviceDriver; |
|||
//开始任务
|
|||
if (phase == 0x01) { |
|||
if (!ObjectUtil.isEmpty(inst)) { |
|||
inst.setInstruction_status("1"); |
|||
inst.setAgv_jobno(String.valueOf(index)); |
|||
inst.setSend_status("1"); |
|||
instructionService.update(inst); |
|||
data = ndcAgvService.sendAgvTwoModeInst(phase, index, 0); |
|||
} |
|||
flag = true; |
|||
} |
|||
//任务完毕
|
|||
//（无车id及状态）
|
|||
else if (phase == 0x14) { |
|||
if (ObjectUtil.isEmpty(inst)) { |
|||
log.info("未找到指令号{}对应的指令", ikey); |
|||
break; |
|||
} |
|||
inst.setInstruction_status("2"); |
|||
instructionService.finish(inst); |
|||
data = ndcAgvService.sendAgvTwoModeInst(phase, index, 0); |
|||
} |
|||
//请求删除任务
|
|||
//(需要WCS反馈)
|
|||
else if (phase == 0x30) { |
|||
if (ObjectUtil.isEmpty(inst)) { |
|||
log.info("未找到指令号{}对应的指令", ikey); |
|||
break; |
|||
} |
|||
data = ndcAgvService.sendAgvTwoModeInst(0x8F, index, 0); |
|||
} |
|||
//任务删除确认
|
|||
//(需要WCS反馈)
|
|||
else if (phase == 0xFF) { |
|||
if (ObjectUtil.isEmpty(inst)) { |
|||
log.info("未找到指令号{}对应的指令", ikey); |
|||
break; |
|||
} |
|||
instructionService.cancelNOSendAgv(inst.getInstruction_id()); |
|||
data = ndcAgvService.sendAgvTwoModeInst(phase, index, 0); |
|||
} else { |
|||
//上报异常信息
|
|||
//（不需要WCS反馈）
|
|||
if(phase == 0x67){ |
|||
device = deviceAppService.findDeviceByCode(Integer.toString(arr[27])); |
|||
} else { |
|||
device = deviceAppService.findDeviceByCode(Integer.toString(arr[20])); |
|||
} |
|||
if (device.getDeviceDriver() instanceof AgvNdcTwoDeviceDriver) { |
|||
agvNdcTwoDeviceDriver = (AgvNdcTwoDeviceDriver) device.getDeviceDriver(); |
|||
agvNdcTwoDeviceDriver.processSocket(arr); |
|||
} |
|||
} |
|||
if (!ObjectUtil.isEmpty(data)) { |
|||
write(data); |
|||
} |
|||
|
|||
} else { |
|||
System.out.println("agv上报不是0073类型动作，不处理"); |
|||
} |
|||
} |
|||
|
|||
} catch (Exception e) { |
|||
|
|||
|
|||
} finally { |
|||
|
|||
|
|||
} |
|||
|
|||
} |
|||
|
|||
|
|||
@Override |
|||
public void stop() { |
|||
super.after(); |
|||
try { |
|||
s.close(); |
|||
} catch (Exception e) { |
|||
e.printStackTrace(); |
|||
} |
|||
} |
|||
|
|||
|
|||
public static void write(byte[] b) { |
|||
try { |
|||
log.info("下发agv数据:" + Bytes2HexString(b)); |
|||
System.out.println("下发agv数据:" + Bytes2HexString(b)); |
|||
dos.write(b); |
|||
dos.flush(); |
|||
} catch (IOException e) { |
|||
// TODO Auto-generated catch block
|
|||
e.printStackTrace(); |
|||
} |
|||
|
|||
} |
|||
} |
|||
@ -1,245 +0,0 @@ |
|||
package org.nl.acs.auto.run; |
|||
|
|||
import cn.hutool.core.util.ObjectUtil; |
|||
import cn.hutool.core.util.StrUtil; |
|||
import lombok.extern.slf4j.Slf4j; |
|||
import org.nl.acs.AcsConfig; |
|||
import org.nl.acs.agv.server.NDCAgvService; |
|||
import org.nl.acs.device.service.DeviceService; |
|||
import org.nl.acs.device_driver.basedriver.agv.ndcone.AgvNdcOneDeviceDriver; |
|||
import org.nl.acs.device_driver.basedriver.agv.ndctwo.AgvNdcTwoDeviceDriver; |
|||
import org.nl.acs.ext.wms.service.AcsToWmsService; |
|||
import org.nl.acs.ext.wms.service.impl.AcsToWmsServiceImpl; |
|||
import org.nl.acs.instruction.service.InstructionService; |
|||
import org.nl.acs.instruction.service.dto.Instruction; |
|||
import org.nl.acs.instruction.service.impl.InstructionServiceImpl; |
|||
import org.nl.acs.opc.Device; |
|||
import org.nl.acs.opc.DeviceAppService; |
|||
import org.nl.modules.system.service.ParamService; |
|||
import org.nl.modules.system.service.impl.ParamServiceImpl; |
|||
import org.nl.modules.wql.util.SpringContextHolder; |
|||
import org.springframework.beans.factory.annotation.Autowired; |
|||
import org.springframework.stereotype.Component; |
|||
|
|||
import java.io.DataInputStream; |
|||
import java.io.DataOutputStream; |
|||
import java.io.IOException; |
|||
import java.net.Socket; |
|||
import java.util.Date; |
|||
import java.util.List; |
|||
|
|||
import static org.nl.acs.agv.server.impl.NDCAgvServiceImpl.Bytes2HexString; |
|||
|
|||
|
|||
@Slf4j |
|||
@Component |
|||
public class TwoNDCSocketConnectionAutoRun extends AbstractAutoRunnable { |
|||
|
|||
Socket s; |
|||
String ip = "192.168.46.225"; |
|||
int port = 1234; |
|||
static DataOutputStream dos; |
|||
static DataInputStream dis; |
|||
private int recordTimeOut = 10000; |
|||
private Date recordTime; |
|||
String[] ERROR = new String[]{ |
|||
"货叉尖部传感器触发", "S300传感器触发", "载货状态改变", "急停按钮触发", "触边开关出发", "需要复位", |
|||
"停在充电位", "取货失败", "放货失败", "轮子打滑", "没有动作码不能进入站点", "取货时有货", "丢失定位", |
|||
"抬叉停止"}; |
|||
boolean bConnected = true; |
|||
|
|||
boolean isReConnect = false; |
|||
|
|||
@Autowired |
|||
ParamService paramService; |
|||
@Autowired |
|||
AutoRunService autoRunService; |
|||
|
|||
|
|||
public TwoNDCSocketConnectionAutoRun() { |
|||
this.recordTime = new Date((new Date()).getTime() - (long) this.recordTimeOut); |
|||
} |
|||
|
|||
public String getCode() { |
|||
return TwoNDCSocketConnectionAutoRun.class.getSimpleName(); |
|||
} |
|||
|
|||
public String getName() { |
|||
return "2楼1区域AGV系统"; |
|||
} |
|||
|
|||
public void autoRun() { |
|||
|
|||
try { |
|||
System.out.println("2楼1区域AGV系统链接开始"); |
|||
ParamService paramService = SpringContextHolder.getBean(ParamServiceImpl.class); |
|||
InstructionService instructionService = SpringContextHolder.getBean(InstructionServiceImpl.class); |
|||
AcsToWmsService acsToWmsService = SpringContextHolder.getBean(AcsToWmsServiceImpl.class); |
|||
NDCAgvService ndcAgvService = SpringContextHolder.getBean(NDCAgvService.class); |
|||
DeviceAppService deviceAppService = SpringContextHolder.getBean(DeviceAppService.class); |
|||
DeviceService deviceService = SpringContextHolder.getBean(DeviceService.class); |
|||
ip = paramService.findByCode(AcsConfig.AGVURL).getValue(); |
|||
port = Integer.parseInt(paramService.findByCode(AcsConfig.AGVPORT).getValue()); |
|||
byte[] b = new byte[1028]; |
|||
s = new Socket(ip, port); |
|||
System.out.println("2楼1区域Agv链接成功"); |
|||
dos = new DataOutputStream(s.getOutputStream()); |
|||
dis = new DataInputStream(s.getInputStream()); |
|||
|
|||
while (bConnected) { |
|||
int count = dis.read(b); |
|||
|
|||
if (count == -1) { |
|||
break; |
|||
} |
|||
|
|||
int[] arr = new int[count]; |
|||
StringBuffer bs = new StringBuffer(); |
|||
|
|||
for (int i = 0; i < count; i++) { |
|||
int temp = b[i]; |
|||
if (temp < 0) |
|||
temp += 256; |
|||
arr[i] = temp; |
|||
StringBuffer bs1 = new StringBuffer("0"); |
|||
bs.append(temp < 16 ? bs1.append(Integer.toHexString(temp)) : Integer.toHexString(temp)); |
|||
} |
|||
|
|||
System.out.println("收到请求参数：" + bs); |
|||
boolean flag = false; |
|||
if (arr[8] * 256 + arr[9] == 0x73) { |
|||
byte[] data = null; |
|||
System.out.println("接收agv上报信息：" + bs); |
|||
//执行阶段
|
|||
int phase = arr[16] * 256 + arr[17]; |
|||
// agv任务号
|
|||
int index = arr[12] * 256 + arr[13]; |
|||
//任务号
|
|||
int ikey = arr[26] * 256 + arr[27]; |
|||
//站点号
|
|||
int agvaddr = arr[18] * 256 + arr[19]; |
|||
//车号
|
|||
int carno = arr[20]; |
|||
Instruction inst = null; |
|||
if (ikey != 0) { |
|||
inst = instructionService.findByCodeFromCache(String.valueOf(ikey)); |
|||
} |
|||
log.info("接收agv上报信息：" + bs); |
|||
log.info("接收agv上报信息：" + "phase--" + phase + " index--" + index + " ikey--" + ikey + " agvaddr--" + agvaddr + " Car--" + carno); |
|||
Device device = null; |
|||
String device_code = null; |
|||
String old_device_code = null; |
|||
String emptyNum = null; |
|||
if (agvaddr != 0) { |
|||
old_device_code = deviceService.queryDeviceCodeByAddress(agvaddr); |
|||
if (StrUtil.contains(old_device_code, "-")) { |
|||
String[] point = old_device_code.split("-"); |
|||
device_code = point[0]; |
|||
} else if (StrUtil.contains(old_device_code, ".")) { |
|||
String[] point = old_device_code.split("\\."); |
|||
device_code = point[0]; |
|||
emptyNum = point[1]; |
|||
} else { |
|||
device_code = old_device_code; |
|||
} |
|||
device = deviceAppService.findDeviceByCode(device_code); |
|||
} |
|||
|
|||
AgvNdcTwoDeviceDriver agvNdcTwoDeviceDriver; |
|||
//开始任务
|
|||
if (phase == 0x01) { |
|||
if (!ObjectUtil.isEmpty(inst)) { |
|||
inst.setInstruction_status("1"); |
|||
inst.setAgv_jobno(String.valueOf(index)); |
|||
inst.setSend_status("1"); |
|||
instructionService.update(inst); |
|||
data = ndcAgvService.sendAgvTwoModeInst(phase, index, 0); |
|||
} |
|||
flag = true; |
|||
} |
|||
//任务完毕
|
|||
//（无车id及状态）
|
|||
else if (phase == 0x14) { |
|||
if (ObjectUtil.isEmpty(inst)) { |
|||
log.info("未找到指令号{}对应的指令", ikey); |
|||
break; |
|||
} |
|||
inst.setInstruction_status("2"); |
|||
instructionService.finish(inst); |
|||
data = ndcAgvService.sendAgvTwoModeInst(phase, index, 0); |
|||
} |
|||
//请求删除任务
|
|||
//(需要WCS反馈)
|
|||
else if (phase == 0x30) { |
|||
if (ObjectUtil.isEmpty(inst)) { |
|||
log.info("未找到指令号{}对应的指令", ikey); |
|||
break; |
|||
} |
|||
data = ndcAgvService.sendAgvTwoModeInst(0x8F, index, 0); |
|||
} |
|||
//任务删除确认
|
|||
//(需要WCS反馈)
|
|||
else if (phase == 0xFF) { |
|||
if (ObjectUtil.isEmpty(inst)) { |
|||
log.info("未找到指令号{}对应的指令", ikey); |
|||
break; |
|||
} |
|||
instructionService.cancelNOSendAgv(inst.getInstruction_id()); |
|||
data = ndcAgvService.sendAgvTwoModeInst(phase, index, 0); |
|||
} else { |
|||
//上报异常信息
|
|||
//（不需要WCS反馈）
|
|||
if(phase == 0x67){ |
|||
device = deviceAppService.findDeviceByCode(Integer.toString(arr[27])); |
|||
} else { |
|||
device = deviceAppService.findDeviceByCode(Integer.toString(arr[20])); |
|||
} |
|||
if (device.getDeviceDriver() instanceof AgvNdcTwoDeviceDriver) { |
|||
agvNdcTwoDeviceDriver = (AgvNdcTwoDeviceDriver) device.getDeviceDriver(); |
|||
agvNdcTwoDeviceDriver.processSocket(arr); |
|||
} |
|||
} |
|||
if (!ObjectUtil.isEmpty(data)) { |
|||
write(data); |
|||
} |
|||
|
|||
} else { |
|||
System.out.println("agv上报不是0073类型动作，不处理"); |
|||
} |
|||
} |
|||
|
|||
} catch (Exception e) { |
|||
|
|||
|
|||
} finally { |
|||
|
|||
|
|||
} |
|||
|
|||
} |
|||
|
|||
|
|||
@Override |
|||
public void stop() { |
|||
super.after(); |
|||
try { |
|||
s.close(); |
|||
} catch (Exception e) { |
|||
e.printStackTrace(); |
|||
} |
|||
} |
|||
|
|||
|
|||
public static void write(byte[] b) { |
|||
try { |
|||
log.info("下发agv数据:" + Bytes2HexString(b)); |
|||
System.out.println("下发agv数据:" + Bytes2HexString(b)); |
|||
dos.write(b); |
|||
dos.flush(); |
|||
} catch (IOException e) { |
|||
// TODO Auto-generated catch block
|
|||
e.printStackTrace(); |
|||
} |
|||
|
|||
} |
|||
} |
|||
Loading…
Reference in new issue