From 50da1f165cc96d49d72694606920b77c74e1747c Mon Sep 17 00:00:00 2001
From: jiazx0107@163.com <jiazx0107@163.com>
Date: 星期四, 04 一月 2024 10:57:26 +0800
Subject: [PATCH] 调整KFKA数据推送测试2
---
src/main/java/com/fzzy/api/utils/ContextUtil.java | 54 +++++++++++++++++++++++++++++++++++++++++++++++++++---
1 files changed, 51 insertions(+), 3 deletions(-)
diff --git a/src/main/java/com/fzzy/api/utils/ContextUtil.java b/src/main/java/com/fzzy/api/utils/ContextUtil.java
index cc8cafe..b2233a5 100644
--- a/src/main/java/com/fzzy/api/utils/ContextUtil.java
+++ b/src/main/java/com/fzzy/api/utils/ContextUtil.java
@@ -3,15 +3,20 @@
import com.fzzy.api.Constant;
import org.apache.commons.lang.StringUtils;
import org.apache.commons.lang.time.DateUtils;
+import org.apache.commons.lang3.time.DateFormatUtils;
-import java.util.Calendar;
-import java.util.Date;
-import java.util.UUID;
+import java.util.*;
/**
*
*/
public class ContextUtil {
+
+
+ /**
+ * 鍏ㄥ眬鍛戒护ID
+ */
+ public static Map<String, Integer> contextOrderId = new HashMap<>();
public static String getUUID() {
@@ -147,4 +152,47 @@
public static String getServerKey(String ip, Integer port) {
return ip + ":" + port;
}
+
+
+ /**
+ * 鏍规嵁鍙傛暟鐢熸垚 鎵ц鍛戒护鐨勭紦瀛楰EY
+ *
+ * @param companyId
+ * @param serId
+ * @param bizType
+ * @return
+ */
+ public static final String buildExeOrderId(String companyId, String serId, String bizType) {
+ Integer start = contextOrderId.get("ORDER_ID") == null ? 5000 : contextOrderId.get("ORDER_ID");
+
+ contextOrderId.put("ORDER_ID", start + 1);
+
+ return start + "";
+ }
+
+ /**
+ * 璁惧ID鐢熸垚瑙勫垯
+ *
+ * @param companyId
+ * @param depotId
+ * @param passCode
+ * @return
+ */
+ public static final String buildDeviceId(String companyId, String depotId, int passCode) {
+ return companyId + "_" + depotId + "_" + passCode;
+ }
+
+ public static String buildDeviceStatusKey(String companyId, String serId, String passCode) {
+ if (null == passCode) passCode = "NULL";
+ return companyId + "_" + serId + "_STATUS_" + passCode;
+ }
+
+ public static String buildDeviceStatusKey(String companyId, String serId, int passCode) {
+ return companyId + "_" + serId + "_STATUS_" + passCode;
+ }
+
+
+ public static String getDefaultBatchId() {
+ return DateFormatUtils.format(new Date(), "yyyyMMddHHmm");
+ }
}
--
Gitblit v1.9.3