csdj数据入库

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

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