package com.zy.asrs.utils;

import com.alibaba.fastjson.JSON;
import com.zy.core.cache.MessageQueue;
import com.zy.core.cache.SlaveConnection;
import com.zy.core.enums.SlaveType;
import com.zy.core.model.ErrMsg;
import com.zy.core.model.Task;
import com.zy.core.thread.LedThread;
import lombok.extern.slf4j.Slf4j;

@Slf4j
public class LedErrorThreadUtil {

    /**
     * 检测货架码
     */
    public static void ledErrorThread(String msg,Integer ledId,String area){
        try{
            LedThread ledThread = (LedThread) SlaveConnection.get(SlaveType.Led, ledId);
            if (ledThread != null) {
                ErrMsg errMsg1 = new ErrMsg();
                errMsg1.setErrMsg(msg);
                errMsg1.setArea(area);
                MessageQueue.offer(SlaveType.Led, ledId, new Task(5, errMsg1));
            }
        } catch (Exception e){
            log.error("入库失败!电视机信息更新失败！！！ledId：{}；msg：{}",ledId, msg);
        }
    }


}