Merge remote-tracking branch 'origin/master'

wangfei

2025-04-21 09402133807b1e774e658a13ad365b2e6efca25b

 hangzhoumesParent/moduleService/CacheGlassModule/src/main/java/com/mes/job/OpcEdgTask.java

New file
@@ -0,0 +1,77 @@
package com.mes.job;

import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
import com.kangaroohy.milo.model.ReadWriteEntity;
import com.kangaroohy.milo.service.MiloService;
import com.mes.glassinfo.entity.GlassInfo;
import com.mes.glassinfo.service.GlassInfoService;
import lombok.extern.slf4j.Slf4j;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.scheduling.annotation.Scheduled;
import org.springframework.stereotype.Component;
import org.springframework.util.StringUtils;

import javax.annotation.Resource;
import java.util.ArrayList;
import java.util.List;

/**
 * @Author : zhoush
 * @Date: 2024/10/10 8:05
 * @Description:
 */
@Component
@Slf4j
public class OpcEdgTask {


    @Autowired(required = false)
    MiloService miloService;

    @Resource
    GlassInfoService glassInfoService;


    @Scheduled(fixedDelay = 2000)
    public void startOneEdgTask() throws Exception {
        startEdgTaskChild("01");
    }

    @Scheduled(fixedDelay = 2000)
    public void startTwoEdgTask() throws Exception {
        startEdgTaskChild("02");
    }

    private void startEdgTaskChild(String cell) throws Exception {
        ReadWriteEntity request = miloService.readFromOpcUa("MB04.MB04.request" + cell);
        if (null == request || "0".equals(request.getValue() + "")) {
            log.info("未收到玻璃请求，结束本次任务");
            return;
        }
        ReadWriteEntity glassIdEntity = miloService.readFromOpcUa("MB04.MB04.plc_glass_id_" + cell);

        if (null == glassIdEntity || StringUtils.isEmpty(glassIdEntity.getValue() + "")) {
            log.info("有请求但玻璃id为空，结束本次任务");
            return;
        }
        String glassId = glassIdEntity.getValue() + "";
        log.info("获取到{}线的玻璃id:{}", cell, glassId);
        GlassInfo glassInfo = glassInfoService.getOne(new LambdaQueryWrapper<GlassInfo>().eq(GlassInfo::getGlassId, glassId).last("limit 1"));

        List<ReadWriteEntity> ualist = new ArrayList<>();
        miloService.writeToOpcUa(generateReadWriteEntity("MB04.MB04.mes_glass_Id_" + cell, glassId));
        ualist.add(generateReadWriteEntity("MB04.MB04.width" + cell, (int) Math.max(glassInfo.getWidth() * 10, glassInfo.getHeight() * 10)));
        ualist.add(generateReadWriteEntity("MB04.MB04.height" + cell, (int) Math.min(glassInfo.getWidth() * 10, glassInfo.getHeight() * 10)));
        ualist.add(generateReadWriteEntity("MB04.MB04.thickness" + cell, (int) glassInfo.getThickness() * 10));
        miloService.writeToOpcWord(ualist);
    }

    private ReadWriteEntity generateReadWriteEntity(String identifier, Object value) {
        return ReadWriteEntity.builder()
                .identifier(identifier)
                //Kep中是Long类型，即：Int32，Java中的int类型
                .value(value)
                .build();
    }

}