自动化立库仓库-WCS系统
blame | 历史 | 补丁 | 提交 | 提交对比 | ignore whitespace
cpT
2025-06-22 87b052cbd5bb44bf90ac4e9c4aeaf1cdcf5acf63 
 src/main/java/com/zy/core/thread/SiemensDevpThread.java


@@ -5,18 +5,23 @@


import HslCommunication.Profinet.Siemens.SiemensPLCS;


import HslCommunication.Profinet.Siemens.SiemensS7Net;


import com.alibaba.fastjson.JSON;


import com.core.common.Cools;


import com.core.common.DateUtils;


import com.core.common.SpringUtils;


import com.core.exception.CoolException;


import com.zy.asrs.entity.BasDevp;


import com.zy.asrs.service.BasDevpService;


import com.zy.core.DevpThread;


import com.zy.core.News;


import com.zy.core.cache.MessageQueue;


import com.zy.core.cache.OutputQueue;


import com.zy.core.cache.SlaveConnection;


import com.zy.core.enums.IoModeType;


import com.zy.core.enums.SlaveType;


import com.zy.core.model.DevpSlave;


import com.zy.core.model.Task;


import com.zy.core.model.protocol.StaProtocol;


import io.swagger.models.auth.In;


import lombok.Data;


import lombok.extern.slf4j.Slf4j;




@@ -39,23 +44,30 @@


    private SiemensS7Net siemensS7Net;


    private Map<Integer, StaProtocol> station = new ConcurrentHashMap<>();


    private short heartBeatVal = 1;


    public static final ArrayList<Integer> staNos = new ArrayList<Integer>() {{


        add(100);add(101);add(102);add(103);add(104);add(105);add(106);add(107);add(108);add(109);


        add(110);add(111);add(112);add(113);add(114);add(115);add(116);add(117);add(118);add(119);


        add(120);add(121);add(122);add(123);add(124);add(125);add(126);add(127);add(128);add(129);


        add(130);add(131);add(132);add(133);add(134);add(135);add(136);add(137);add(138);add(139);


        add(140);add(141);add(142);add(143);add(144);add(145);add(146);add(147);add(148);add(149);


        add(150);add(151);add(152);add(153);add(154);add(155);add(156);add(157);add(158);add(159);


        add(160);add(161);add(162);add(163);add(164);add(165);add(166);add(167);add(168);add(169);


        add(170);add(171);add(172);add(173);add(174);add(175);add(176);add(177);add(178);add(179);


        add(180);add(181);add(182);add(183);add(184);add(185);add(186);add(187);add(188);add(189);


        add(190);add(191);add(192);


    private boolean result = false;


    public static final ArrayList<Integer> staNos1 = new ArrayList<Integer>() {{


        add(100);add(101);add(102);add(103);add(104);add(105);add(106);add(107);


        add(108);add(109);add(110);add(111);add(112);add(113);add(114);add(115);


    }};




    public IoModeType ioMode = IoModeType.NONE;


    public static final ArrayList<Integer> staNos2 = new ArrayList<Integer>() {{


        add(116);add(117);add(118);add(119);add(120);


        add(121);add(122);add(123);add(124);add(125);add(126);add(127);add(128);add(129);add(130);


        add(131);add(132);add(133);


    }};




    public SiemensDevpThread(DevpSlave slave) {


        this.slave = slave;


    }




    private ArrayList<Integer> getStaNo() {


        switch (slave.getId()) {


            case 1:


                return staNos1;


            case 2:


                return staNos2;


            default:


                throw new CoolException("服务器异常");


        }


    }




    @Override


@@ -74,10 +86,10 @@


                    case 1:


                        read();


                        break;


                    // 写数据 ID+目标站


                    case 2:


                        write((StaProtocol)task.getData());


                        break;


//                    // 写数据 ID+目标站


//                    case 2:


//                        write((StaProtocol)task.getData());


//                        break;


                    default:


                        break;


                }


@@ -93,7 +105,7 @@




    @Override


    public boolean connect() {


        boolean result = false;


        result = false;


        siemensS7Net = new SiemensS7Net(SiemensPLCS.S1200, slave.getIp());


        siemensS7Net.setRack(slave.getRack().byteValue());


        siemensS7Net.setSlot(slave.getSlot().byteValue());


@@ -114,11 +126,11 @@


     * 读取状态 ====> 整块plc


     */


    private void read() throws InterruptedException {


//        // 更新入出库模式


//        updateIoMode();


        OperateResultExOne<byte[]> result = siemensS7Net.Read("DB100.0", (short) 166);


        ArrayList<Integer> staNos = getStaNo();


        int staNoSize = staNos.size();


        OperateResultExOne<byte[]> result = siemensS7Net.Read("DB128.0", (short) (staNoSize*4));


        if (result.IsSuccess) {


            for (int i = 0; i < 83; i++) {


            for (int i = 0; i < staNoSize; i++) {


                Integer siteId = staNos.get(i); // 站点编号


                StaProtocol staProtocol = station.get(siteId);


                if (null == staProtocol) {


@@ -126,88 +138,12 @@


                    staProtocol.setSiteId(siteId);


                    station.put(siteId, staProtocol);


                }


                staProtocol.setWorkNo(siemensS7Net.getByteTransform().TransInt16(result.Content, i*2));     // 工作号


            }


        }


        Thread.sleep(200);


        OperateResultExOne<byte[]> result0 = siemensS7Net.Read("DB101.0", (short) 166);


        if (result0.IsSuccess) {


            for (int i = 0; i < 83; i++) {


                Integer siteId = staNos.get(i); // 站点编号


                StaProtocol staProtocol = station.get(siteId);


                if (null == staProtocol) {


                    staProtocol = new StaProtocol();


                    staProtocol.setSiteId(siteId);


                    station.put(siteId, staProtocol);


                }


                staProtocol.setStaNo(siemensS7Net.getByteTransform().TransInt16(result0.Content, i*2));   // 目标站


            }


        }


        Thread.sleep(200);


        OperateResultExOne<byte[]> result1 = siemensS7Net.Read("DB102.0", (short) 166);


        if (result1.IsSuccess) {


            for (int i = 0; i < 83; i++) {


                Integer siteId = staNos.get(i); // 站点编号


                boolean[] status = siemensS7Net.getByteTransform().TransBool(result1.Content, i*2, 1);


                StaProtocol staProtocol = station.get(siteId);


                staProtocol.setAutoing(status[0]);  // 自动


                staProtocol.setLoading(status[1]);  // 有物


                staProtocol.setInEnable(status[2]); // 可入


                staProtocol.setOutEnable(status[3]);// 可出


                staProtocol.setEmptyMk(status[4]);  // 空板信号


                staProtocol.setFullPlt(status[5]);  // 满托盘


                staProtocol.setHigh(status[6]);     // 高库位


                staProtocol.setLow(status[7]);      // 低库位




                if (!staProtocol.isPakMk() && !staProtocol.isLoading()) {


                    staProtocol.setPakMk(true);


                }


                staProtocol.setWorkNo(siemensS7Net.getByteTransform().TransUInt32(result.Content, i*4));     // 工作号


            }


        }




        Thread.sleep(200);


        OperateResultExOne<byte[]> result3 = siemensS7Net.Read("DB300.0", (short) 10);


        if (result3.IsSuccess) {


//            Integer siteId = staNos.get(i); // 站点编号


            Integer siteId = 0;


            for (int i = 0; i < 5; i++) {


                switch (i){


                    case 0:


                        siteId = 100;


                        break;


                    case 1:


                        siteId = 102;


                        break;


                    case 2:


                        siteId = 104;


                        break;


                    case 3:


                        siteId = 106;


                        break;


                    case 4:


                        siteId = 108;


                        break;


                }


                StaProtocol staProtocol = station.get(siteId);


                if (null == staProtocol) {


                    staProtocol = new StaProtocol();


                    staProtocol.setSiteId(siteId);


                    station.put(siteId, staProtocol);


                }


                short value = siemensS7Net.getByteTransform().TransInt16(result3.Content, i*2);


                staProtocol.setInQty(value);     // 入库暂存数


            }


        }




//        OperateResultExOne<Short> result2 = siemensS7Net.ReadInt16("DB200.0");


//        if (result2.IsSuccess) {


//            this.ioMode = IoModeType.get(result2.Content);


//        }




        if (result.IsSuccess && result0.IsSuccess && result1.IsSuccess) {




        if (result.IsSuccess) {


            OutputQueue.DEVP.offer(MessageFormat.format("【{0}】[id:{1}] <<<<< 实时数据更新成功",DateUtils.convert(new Date()), slave.getId()));




            // 根据实时信息更新数据库


            try {


                List<BasDevp> basDevps = new ArrayList<>();


@@ -216,9 +152,13 @@


                    basDevps.add(staProtocol.toSqlModel());


                }




                BasDevpService basDevpService = SpringUtils.getBean(BasDevpService.class);


                if (null != basDevpService && !basDevpService.updateBatchById(basDevps)) {


                    throw new Exception("更新数据库数据失败");


                try{


                    BasDevpService basDevpService = SpringUtils.getBean(BasDevpService.class);


                    if (null != basDevpService && !basDevpService.updateBatchById(basDevps)) {


                        throw new Exception("更新数据库数据失败");


                    }


                } catch (Exception e){


                    log.error("更新数据库数据失败 ===>> [id:{}] [ip:{}] [port:{}] [rack:{}] [slot:{}]", slave.getId(), slave.getIp(), slave.getPort(), slave.getRack(), slave.getSlot());


                }


            } catch (Exception e) {


                e.printStackTrace();


@@ -239,10 +179,28 @@


        if (null == staProtocol) {


            return;


        }


        ArrayList<Integer> staNos = getStaNo();


        int index = staNos.indexOf(staProtocol.getSiteId());


        OperateResult write = siemensS7Net.Write("DB100." + index*2, staProtocol.getWorkNo());    // 工作号


        Thread.sleep(500);


        OperateResult write1 = siemensS7Net.Write("DB101." + index*2, staProtocol.getStaNo());    // 目标站


//        int[] array = new int[2];


//        array[0] = staProtocol.getWorkNo();


//        array[1] = staProtocol.getStaNo();


//        OperateResult write = siemensS7Net.Write("DB100." + index*8, array);




        OperateResult write = null;


        OperateResult write1 = null;


        //任务下发次数


        int writeCount = 0;


        do {


            write1 = siemensS7Net.Write("DB100." + (index*6+4), staProtocol.getStaNo().shortValue());    // 目标站


//            Thread.sleep(500);


            write = siemensS7Net.Write("DB100." + index*6, staProtocol.getWorkNo());    // 工作号


            if(write.IsSuccess || write1.IsSuccess){


                writeCount=6;


            }else {


                writeCount++;


                log.error("写入输送线命令后读取失败。输送线plc编号={}，站点数据={},写入次数={}", slave.getId(), JSON.toJSON(staProtocol), writeCount);


            }


        }while (writeCount<5);




        if (!write.IsSuccess || !write1.IsSuccess) {


            staProtocol = station.get(staProtocol.getSiteId());


@@ -254,16 +212,6 @@


        } else {


            OutputQueue.DEVP.offer(MessageFormat.format("【{0}】 输送线命令下发 [id:{1}] >>>>> {2}", DateUtils.convert(new Date()), slave.getId(), JSON.toJSON(staProtocol)));


            log.info("输送线命令下发 [id:{}] >>>>> 命令下发： {}",  slave.getId(), JSON.toJSON(staProtocol));


        }


    }




    // 更新入出库模式


    private void updateIoMode() throws InterruptedException {


        if (this.ioMode != IoModeType.NONE) {


            if (!siemensS7Net.Write("DB200", this.ioMode.id).IsSuccess) {


                OutputQueue.DEVP.offer(MessageFormat.format("【{0}】写入输送线1F入出库模式失败。输送线plc编号={1}", slave.getId()));


                log.error("写入输送线1F入出库模式失败。输送线plc编号={}", slave.getId());


            }


        }


    }




@@ -299,37 +247,8 @@


    }




    public static void main(String[] args) {


        System.out.println(staNos.indexOf(129));


        System.out.println(staNos.size());


        for (int i = 0; i<staNos.size(); i++) {


//            System.out.println(i*2);


//            System.out.println(i*2 + 200);


//            System.out.println(i);


        }


        int index = staNos.indexOf(128);


        System.out.println(index*2);


        System.out.println(index*2 + 200);




    }




//    public static void main(String[] args) throws Exception {


//        DevpSlave slave = new DevpSlave();


//        slave.setIp("192.168.2.125");


//        SiemensDevpThread devpThread = new SiemensDevpThread(slave);


//        devpThread.connect();


//        devpThread.read();


//        // 写


//        StaProtocol staProtocol = devpThread.getStation().get(1);


//        staProtocol.setWorkNo((short) 232);


//        staProtocol.setStaNo((short) 6);


//        staProtocol.setAutoing(true);


//        staProtocol.setEmptyMk(true);


//        staProtocol.setInEnable(true);


//        devpThread.write(staProtocol);


//        System.out.println("----------------------------------------");


//        // 读


//        devpThread.read();


//        System.out.println(JSON.toJSONString(devpThread.station));


//


//    }




}