From 362c723474825f421333cdd6ede703e4235a3925 Mon Sep 17 00:00:00 2001 From: "review512jwy@163.com" <“review512jwy@163.com”> Date: Tue, 12 May 2026 16:34:03 +0800 Subject: [PATCH] =?UTF-8?q?csdj=E6=95=B0=E6=8D=AE=E6=8E=A5=E6=94=B6?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../sender/controllers/MainReceiverController.java | 13 +++++++++++++ .../datacenter/sender/entitiy/CsdjEntity.java | 12 ++++++++++++ 2 files changed, 25 insertions(+) create mode 100644 src/main/java/com/techsor/datacenter/sender/entitiy/CsdjEntity.java diff --git a/src/main/java/com/techsor/datacenter/sender/controllers/MainReceiverController.java b/src/main/java/com/techsor/datacenter/sender/controllers/MainReceiverController.java index 2c865dc..a0f2d42 100644 --- a/src/main/java/com/techsor/datacenter/sender/controllers/MainReceiverController.java +++ b/src/main/java/com/techsor/datacenter/sender/controllers/MainReceiverController.java @@ -209,6 +209,19 @@ public class MainReceiverController { return JsonResponse.buildSuccess(resultJson); } + @RequestMapping(value = "generic/csdj", method = RequestMethod.POST) + public JsonResponse csdjProcess(@RequestBody CsdjEntity csdjEntity){ + logger.info("csdj data:{}", JSON.toJSONString(csdjEntity)); + //处理数据,转发数据 + String resultJson=""; + try{ + //解析数据 + }catch (Exception e){ + logger.error("csdjProcess error", e); + } + return JsonResponse.buildSuccess(resultJson); + } + @RequestMapping(value = "generic/mockJsonData", method = RequestMethod.POST) public JsonResponse mockJsonData(@RequestBody ProcessRAWEntity rawEntity){ logger.warn("Received: "+new Gson().toJson(rawEntity)); diff --git a/src/main/java/com/techsor/datacenter/sender/entitiy/CsdjEntity.java b/src/main/java/com/techsor/datacenter/sender/entitiy/CsdjEntity.java new file mode 100644 index 0000000..bef7281 --- /dev/null +++ b/src/main/java/com/techsor/datacenter/sender/entitiy/CsdjEntity.java @@ -0,0 +1,12 @@ +package com.techsor.datacenter.sender.entitiy; + +import lombok.Data; + +import java.io.Serializable; + +@Data +public class CsdjEntity implements Serializable { + private String terminalId; + private String ts; + private String data; +}