From fcb7402f47da0883f7974514b235c728df7ca8ca Mon Sep 17 00:00:00 2001
From: "review512jwy@163.com" <“review512jwy@163.com”>
Date: Wed, 17 Jun 2026 18:54:39 +0800
Subject: [PATCH] =?UTF-8?q?csdj=E6=95=B0=E6=8D=AE=E5=85=A5=E5=BA=93?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../controllers/MainReceiverController.java   | 11 +++++++++-
 .../datacenter/sender/dao/CsdjLogDao.java     | 20 +++++++++++++++++++
 2 files changed, 30 insertions(+), 1 deletion(-)
 create mode 100644 src/main/java/com/techsor/datacenter/sender/dao/CsdjLogDao.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 a0f2d42..0d6ed3f 100644
--- a/src/main/java/com/techsor/datacenter/sender/controllers/MainReceiverController.java
+++ b/src/main/java/com/techsor/datacenter/sender/controllers/MainReceiverController.java
@@ -5,6 +5,7 @@ import com.google.gson.Gson;
 import com.techsor.datacenter.sender.components.CommonOpt;
 import com.techsor.datacenter.sender.config.DataSourceContextHolder;
 import com.techsor.datacenter.sender.constants.CompanyConstants;
+import com.techsor.datacenter.sender.dao.CsdjLogDao;
 import com.techsor.datacenter.sender.entitiy.*;
 import com.techsor.datacenter.sender.entitiy.f10.RedisStreamEntity;
 import com.techsor.datacenter.sender.entitiy.zaiot.ProcessZAIoTRAWEntity;
@@ -75,6 +76,9 @@ public class MainReceiverController {
     @Resource
     private IDataProcessService dataProcessService;
 
+    @Resource
+    private CsdjLogDao csdjLogDao;
+
     @RequestMapping(value = "generic/process", method = RequestMethod.POST)
     public JsonResponse processReceiver(@RequestBody ProcessRAWEntity rawEntity){
         logger.warn("DataSrcCode:{},Content:{}",new Object[]{rawEntity.getDataSrcCode(),rawEntity.getContent()});
@@ -215,7 +219,12 @@ public class MainReceiverController {
         //处理数据，转发数据
         String resultJson="";
         try{
-            //解析数据
+            //存入 csdj_log 表
+            csdjLogDao.insertCsdjLog(
+                csdjEntity.getTerminalId(),
+                csdjEntity.getData(),
+                System.currentTimeMillis()
+            );
         }catch (Exception e){
             logger.error("csdjProcess error", e);
         }
diff --git a/src/main/java/com/techsor/datacenter/sender/dao/CsdjLogDao.java b/src/main/java/com/techsor/datacenter/sender/dao/CsdjLogDao.java
new file mode 100644
index 0000000..d61627f
--- /dev/null
+++ b/src/main/java/com/techsor/datacenter/sender/dao/CsdjLogDao.java
@@ -0,0 +1,20 @@
+
+package com.techsor.datacenter.sender.dao;
+
+import org.springframework.jdbc.core.JdbcTemplate;
+import org.springframework.stereotype.Component;
+
+import jakarta.annotation.Resource;
+
+@Component
+public class CsdjLogDao {
+
+    @Resource
+    private JdbcTemplate jdbcTemplate;
+
+    public void insertCsdjLog(String terminalId, String rawHex, Long createdAt) {
+        String sql = "INSERT INTO csdj_log (terminal_id, raw_hex, created_at) VALUES (?, ?, ?)";
+        jdbcTemplate.update(sql, terminalId, rawHex, createdAt);
+    }
+}
+