From 14f2c4fce50c871d84f89d2dca2298e0892b4672 Mon Sep 17 00:00:00 2001
From: zhang <zc857179121@qq.com>
Date: 星期二, 05 五月 2026 08:25:26 +0800
Subject: [PATCH] Merge branch 'rcs_master_1.0' into rcs_master_all
---
zy-acs-cv/src/main/java/com/zy/core/thread/BarcodeThread.java | 68 ++++++++++++++++++++++++++++++++++
1 files changed, 68 insertions(+), 0 deletions(-)
diff --git a/zy-acs-cv/src/main/java/com/zy/core/thread/BarcodeThread.java b/zy-acs-cv/src/main/java/com/zy/core/thread/BarcodeThread.java
new file mode 100644
index 0000000..56455a8
--- /dev/null
+++ b/zy-acs-cv/src/main/java/com/zy/core/thread/BarcodeThread.java
@@ -0,0 +1,68 @@
+package com.zy.core.thread;
+
+import com.alibaba.fastjson.JSONObject;
+import com.zy.acs.framework.common.Cools;
+import com.zy.acs.framework.common.DateUtils;
+import com.zy.common.utils.News;
+import com.zy.core.Slave;
+import com.zy.core.ThreadHandler;
+import com.zy.core.cache.OutputQueue;
+import lombok.Data;
+import lombok.extern.slf4j.Slf4j;
+
+import java.util.Date;
+
+/**
+ * 鏉＄爜鎵弿浠嚎绋�
+ * Created by vincent on 2020/8/4
+ */
+@Data
+@Slf4j
+public class BarcodeThread implements Runnable, ThreadHandler {
+
+ private Slave slave;
+ private StringBuffer barcode = new StringBuffer();
+
+ public BarcodeThread(Slave slave) {
+ this.slave = slave;
+ }
+
+ public String getBarcode() {
+ return barcode.toString();
+ }
+
+ public void setBarcode(String barcode) {
+ this.barcode.delete(0, this.barcode.length());
+ this.barcode.append(barcode);
+ if (!Cools.isEmpty(barcode)) {
+ News.info("Barcode" + " - 1" + " - {}鍙锋潯鐮佸櫒锛屾绱㈡暟鎹細{}", slave.getId(), this.barcode);
+ JSONObject jsonObject = new JSONObject();
+ jsonObject.put("time", DateUtils.convert(new Date(), DateUtils.yyyyMMddHHmmss_F));
+ jsonObject.put("barcode", barcode);
+ if (OutputQueue.BARCODE.size() >= 32) {
+ OutputQueue.BARCODE.poll();
+ }
+ OutputQueue.BARCODE.offer(jsonObject);
+ }
+ }
+
+ public void clearBarcode() {
+ this.barcode = new StringBuffer();
+ }
+
+ @Override
+ public boolean connect() {
+ return false;
+ }
+
+ @Override
+ public void close() {
+
+ }
+
+ @Override
+ public void run() {
+
+ }
+
+}
--
Gitblit v1.9.1