#

luxiaotao1123

2020-08-14 d7ffd5ba5ecb61a930b30c664b1e5efc27760b07

 src/main/java/com/zy/core/thread/CrnThread.java

@@ -4,8 +4,10 @@
import HslCommunication.Core.Types.OperateResultExOne;
import HslCommunication.Profinet.Siemens.SiemensPLCS;
import HslCommunication.Profinet.Siemens.SiemensS7Net;
import com.alibaba.fastjson.JSON;
import com.zy.core.ThreadHandler;
import com.zy.core.cache.MessageQueue;
import com.zy.core.enums.CrnTaskModeType;
import com.zy.core.enums.SlaveType;
import com.zy.core.model.CrnSlave;
import com.zy.core.model.Task;
@@ -28,6 +30,7 @@

    public CrnThread(CrnSlave slave) {
        this.slave = slave;
        this.connect();
    }

    @Override
@@ -43,20 +46,34 @@
                switch (step) {
                    // 读数据
                    case 1:
                        readStatus();   // 读取状态
                        readStatus();
                        break;
                    // 写入数据
                    case 2:
                        CrnCommand command = (CrnCommand) task.getData();
                        break;
                    case 3:
                        write((CrnCommand) task.getData());
                        break;
                    // 复位
                    case 4:
                    case 3:
                        CrnCommand command = (CrnCommand) task.getData();
                        if (null == command) {
                            command = new CrnCommand();
                        }
                        command.setCrnNo(slave.getId()); // 堆垛机编号
                        command.setTaskNo((short) 0); // 工作号
                        command.setAckFinish((short) 1);  // 任务完成确认位
                        command.setTaskMode(CrnTaskModeType.NONE); // 任务模式:  库位移转
                        command.setSourcePosX((short)0);     // 源库位排
                        command.setSourcePosY((short)0);     // 源库位列
                        command.setSourcePosZ((short)0);     // 源库位层
                        command.setDestinationPosX((short)0);     // 目标库位排
                        command.setDestinationPosY((short)0);     // 目标库位列
                        command.setDestinationPosZ((short)0);     // 目标库位层
                        write(command);
                        break;
                    default:
                        break;
                }
                Thread.sleep(3000);
                Thread.sleep(500);
            } catch (Exception e) {
                e.printStackTrace();
            }
@@ -85,7 +102,7 @@
     * 读取状态
     */
    private void readStatus(){
        OperateResultExOne<byte[]> result = siemensNet.Read("DB8.18", (short) 10);
        OperateResultExOne<byte[]> result = siemensNet.Read("DB8.18", (short) 46);
        if (result.IsSuccess) {
            if (null == crnProtocol) {
                crnProtocol = new CrnProtocol();
@@ -118,13 +135,33 @@
    /**
     * 写入数据
     */
    private void write(){

    private void write(CrnCommand command){
        if (null == command) {
            log.error("堆垛机写入命令为空");
            return;
        }
        command.setCrnNo(slave.getId());
        short[] array = new short[9];
        array[0] = command.getAckFinish();
        array[1] = command.getTaskNo();
        array[2] = command.getTaskMode();
        array[3] = command.getSourcePosX();
        array[4] = command.getSourcePosY();
        array[5] = command.getSourcePosZ();
        array[6] = command.getDestinationPosX();
        array[7] = command.getDestinationPosY();
        array[8] = command.getDestinationPosZ();
        OperateResult result = siemensNet.Write("DB8.0", array);
        if (result.IsSuccess) {
            readStatus();
        } else {
            log.error("写入堆垛机plc数据失败 ===>> [id:{}] [ip:{}] [port:{}] [rack:{}] [slot:{}]", slave.getId(), slave.getIp(), slave.getPort(), slave.getRack(), slave.getSlot());
        }
    }

    @Override
    public void close() {

        siemensNet.ConnectClose();
    }

    public CrnProtocol getCrnProtocol(){
@@ -133,4 +170,30 @@
        }
        return this.crnProtocol;
    }


    /******************************************************************************************/
    /**************************************** 测试专用 *****************************************/
    /*****************************************************************************************/
    public static void main(String[] args) {
        CrnSlave slave = new CrnSlave();
        CrnThread crnThread = new CrnThread(slave);
        crnThread.readStatus();
        System.out.println(JSON.toJSONString(crnThread.crnProtocol));
        // 写
        CrnCommand command = new CrnCommand();
        command.setCrnNo(slave.getId()); // 堆垛机编号
        command.setTaskNo((short) 0); // 工作号
        command.setAckFinish((short) 1);  // 任务完成确认位
        command.setTaskMode(CrnTaskModeType.NONE); // 任务模式:  库位移转
        command.setSourcePosX((short)0);     // 源库位排
        command.setSourcePosY((short)0);     // 源库位列
        command.setSourcePosZ((short)0);     // 源库位层
        command.setDestinationPosX((short)0);     // 目标库位排
        command.setDestinationPosY((short)0);     // 目标库位列
        command.setDestinationPosZ((short)0);     // 目标库位层
        crnThread.write(command);

    }

}