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);
|
}
|
}
|
|
|
}
|