|
...
|
...
|
@@ -26,37 +26,41 @@ public class CommandClient { |
|
|
|
socket = new Socket("192.168.1.107", 9002);
|
|
|
|
logger.info("socket通讯创建连接成功");
|
|
|
|
op = socket.getOutputStream();
|
|
|
|
//xml字节流
|
|
|
|
byte[]xBody =xmlBody.getBytes("GB2312");
|
|
|
|
//包头
|
|
|
|
byte[] head = new byte[4];
|
|
|
|
head[0]=(byte)0xE2;
|
|
|
|
head[1]=(byte)0x5C;
|
|
|
|
head[2]=(byte)0x4B;
|
|
|
|
head[3]=(byte)0x89;
|
|
|
|
byte[]packge = intToByte4((40+xBody.length));
|
|
|
|
//消息类型
|
|
|
|
byte[] mType = new byte[1];
|
|
|
|
mType[0] = (byte)0x22;
|
|
|
|
byte[]station ="4257010001".getBytes("ASCII");
|
|
|
|
byte[]aisle ="4257011005".getBytes("ASCII");
|
|
|
|
byte[]eType ="E".getBytes("ASCII");
|
|
|
|
//场站号
|
|
|
|
byte[]station =info.getAreaid().getBytes("ASCII");
|
|
|
|
//通道号
|
|
|
|
byte[]aisle =info.getChnlno().getBytes("ASCII");
|
|
|
|
//进出标识
|
|
|
|
byte[]eType =info.getIetype().getBytes("ASCII");
|
|
|
|
//标识符
|
|
|
|
byte[] bwFlag = new byte[4];
|
|
|
|
bwFlag[0]=(byte)0xFF;
|
|
|
|
bwFlag[1]=(byte)0xFF;
|
|
|
|
bwFlag[2]=(byte)0xFF;
|
|
|
|
bwFlag[3]=(byte)0xFF;
|
|
|
|
//xml字节流长度
|
|
|
|
byte[]xmlLength = intToByte4(xBody.length);
|
|
|
|
//包尾
|
|
|
|
byte[]end = new byte[2];
|
|
|
|
end[0]=(byte)0xFF;
|
|
|
|
end[1]=(byte)0xFF;
|
|
|
|
byte[]b1 = byteMerger(head,packge);
|
|
|
|
byte[]b2 = byteMerger(mType,station);
|
|
|
|
byte[]b3 = byteMerger(aisle,eType);
|
|
|
|
byte[]b4 = byteMerger(bwFlag, xmlLength);
|
|
|
|
byte[]b5 = byteMerger(xBody, end);
|
|
|
|
byte[]b6 = byteMerger(b1,b2);
|
|
|
|
byte[]b7 = byteMerger(b3,b4);
|
|
|
|
byte[]b8 = byteMerger(b5,b6);
|
|
|
|
byte[]b9 = byteMerger(b7,b8);
|
|
|
|
op.write(b9);
|
|
|
|
//总长
|
|
|
|
byte [] packge = intToByte4((head.length+xBody.length+mType.length+station.length+aisle.length+eType
|
|
|
|
.length+bwFlag.length+xmlLength.length+end.length));
|
|
|
|
byte[]allByte = byteMergerAll(head,packge,mType,station,aisle,eType,bwFlag,xmlLength,xBody,end);
|
|
|
|
op.write(allByte);
|
|
|
|
op.flush();
|
|
|
|
op.close();
|
|
|
|
logger.info("发送完毕");
|
|
|
|
socket.close();
|
|
...
|
...
|
@@ -70,15 +74,24 @@ public class CommandClient { |
|
|
|
|
|
|
|
|
|
|
|
}
|
|
|
|
/**
|
|
|
|
* @Param info 卡口采集信息
|
|
|
|
* @Param flag 放行标识
|
|
|
|
* */
|
|
|
|
private static String getXmlInfo(GatherInfo info,String flag) {
|
|
|
|
String message = null;
|
|
|
|
if ("11".equals(flag)){
|
|
|
|
message="直接放行";
|
|
|
|
}else{
|
|
|
|
message = "禁止通行，载重比对不在可控范围";
|
|
|
|
}
|
|
|
|
StringBuffer buffer = new StringBuffer();
|
|
|
|
buffer.append("<?xml version='1.0' encoding='GB2312' ?>");
|
|
|
|
buffer.append("<COMMAND_INFO AREA_ID="+info.getAreaid()+" CHNL_NO="+info.getChnlno()+" I_E_TYPE="+info
|
|
|
|
.getIetype()+" SEQ_NO="+info.getSeqno()+">");
|
|
|
|
buffer.append("<CHECK_RESULT>11000000000000000000</CHECK_RESULT><OP_HINT>数据不完整</OP_HINT>");
|
|
|
|
buffer.append("<COMMAND_INFO AREA_ID=\""+info.getAreaid()+"\" CHNL_NO=\""+info.getChnlno()+"\" I_E_TYPE=\""+info
|
|
|
|
.getIetype()+"\" SEQ_NO=\""+info.getSeqno()+"\">");
|
|
|
|
buffer.append("<CHECK_RESULT>"+flag+"000000000000000000</CHECK_RESULT><OP_HINT>"+message+"</OP_HINT>");
|
|
|
|
buffer.append("<SEAL>");
|
|
|
|
buffer.append("<ESEAL_ID></ESEAL_ID>");
|
|
|
|
buffer.append("<SEAL_KEY></SEAL_KEY>");
|
|
|
|
buffer.append("<ESEAL_ID>"+info.getEsealid()+"</ESEAL_ID>");
|
|
|
|
buffer.append("<SEAL_KEY>"+info.getSealkey()+"</SEAL_KEY>");
|
|
|
|
buffer.append("<OPEN_TIMES></OPEN_TIMES>");
|
|
|
|
buffer.append("<ESEAL_IC_NO></ESEAL_IC_NO>");
|
|
|
|
buffer.append("</SEAL>");
|
|
...
|
...
|
@@ -88,7 +101,7 @@ public class CommandClient { |
|
|
|
}
|
|
|
|
|
|
|
|
//int转byte
|
|
|
|
public static byte[] intToByte4(int i) {
|
|
|
|
private static byte[] intToByte4(int i) {
|
|
|
|
byte[] targets = new byte[4];
|
|
|
|
//低位到高位
|
|
|
|
targets[0] = (byte) (i & 0xFF);
|
|
...
|
...
|
@@ -98,15 +111,8 @@ public class CommandClient { |
|
|
|
return targets;
|
|
|
|
}
|
|
|
|
|
|
|
|
//合并两个byte数组
|
|
|
|
public static byte[] byteMerger(byte[] bt1, byte[] bt2) {
|
|
|
|
byte[] bt3 = new byte[bt1.length + bt2.length];
|
|
|
|
System.arraycopy(bt1, 0, bt3, 0, bt1.length);
|
|
|
|
System.arraycopy(bt2, 0, bt3, bt1.length, bt2.length);
|
|
|
|
return bt3;
|
|
|
|
}
|
|
|
|
//byte转int
|
|
|
|
public static int byteArrayToInt(byte[] bytes) {
|
|
|
|
private static int byteArrayToInt(byte[] bytes) {
|
|
|
|
int value = 0;
|
|
|
|
// 由高位到低位
|
|
|
|
for (int i = 0; i < 4; i++) {
|
|
...
|
...
|
@@ -116,4 +122,19 @@ public class CommandClient { |
|
|
|
return value;
|
|
|
|
}
|
|
|
|
|
|
|
|
private static byte[] byteMergerAll(byte[]... values) {
|
|
|
|
int length_byte = 0;
|
|
|
|
for (int i = 0; i < values.length; i++) {
|
|
|
|
length_byte += values[i].length;
|
|
|
|
}
|
|
|
|
byte[] all_byte = new byte[length_byte];
|
|
|
|
int countLength = 0;
|
|
|
|
for (int i = 0; i < values.length; i++) {
|
|
|
|
byte[] b = values[i];
|
|
|
|
System.arraycopy(b, 0, all_byte, countLength, b.length);
|
|
|
|
countLength += b.length;
|
|
|
|
}
|
|
|
|
return all_byte;
|
|
|
|
}
|
|
|
|
|
|
|
|
} |
...
|
...
|
|
