commit

PddServer/src/main/java/org/ta/pddserver/config/PddApplicationRunner.java

+package org.ta.pddserver.config;
+
+import jakarta.annotation.Resource;
+import lombok.extern.slf4j.Slf4j;
+import org.springframework.boot.ApplicationArguments;
+import org.springframework.boot.ApplicationRunner;
+import org.springframework.stereotype.Component;
+import org.ta.pddserver.service.impl.LogsPddIoImpl;
+import org.ta.pddserver.utils.PddHttpTool;
+
+@Slf4j
+@Component
+public class PddApplicationRunner implements ApplicationRunner {
+    @Resource
+    private LogsPddIoImpl logsPddIoImpl;
+
+    @Override
+    public void run(ApplicationArguments args) throws Exception {
+        log.info("注入注册PDD-HTTP 日志保存工具");
+        PddHttpTool.setLogsToolService(logsPddIoImpl);
+    }
+}

PddServer/src/main/java/org/ta/pddserver/entity/LogsPddIoEntity.java

+package org.ta.pddserver.entity;
+
+import com.baomidou.mybatisplus.annotation.TableField;
+import com.baomidou.mybatisplus.annotation.TableId;
+import com.baomidou.mybatisplus.annotation.TableName;
+import lombok.Data;
+
+import java.util.Date;
+
+@Data
+@TableName("logs_pdd_io")
+public class LogsPddIoEntity {
+
+
+    @TableId(value = "uid")
+    private String uid;
+
+    @TableField(value = "created")
+    private Date created;
+
+    @TableField(value = "remarks")
+    private String remarks;
+
+    @TableField(value = "action")
+    private String action;
+
+    @TableField(value = "req")
+    private String req;
+
+    @TableField(value = "resp")
+    private String resp;
+
+}

PddServer/src/main/java/org/ta/pddserver/mapper/LogsPddIoMapper.java

+package org.ta.pddserver.mapper;
+
+import com.baomidou.mybatisplus.core.mapper.BaseMapper;
+import org.apache.ibatis.annotations.Mapper;
+import org.ta.pddserver.entity.LogsPddIoEntity;
+
+@Mapper
+public interface LogsPddIoMapper extends BaseMapper<LogsPddIoEntity> {
+
+}

PddServer/src/main/java/org/ta/pddserver/service/LogsPddIoService.java

+package org.ta.pddserver.service;
+
+import com.baomidou.mybatisplus.extension.service.IService;
+import org.ta.pddserver.entity.LogsPddIoEntity;
+
+public interface LogsPddIoService extends IService<LogsPddIoEntity> {
+
+
+}

PddServer/src/main/java/org/ta/pddserver/service/impl/LogsPddIoImpl.java

+package org.ta.pddserver.service.impl;
+
+
+import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
+import org.springframework.stereotype.Service;
+import org.ta.pddserver.entity.LogsPddIoEntity;
+import org.ta.pddserver.mapper.LogsPddIoMapper;
+import org.ta.pddserver.service.LogsPddIoService;
+
+@Service
+public class LogsPddIoImpl extends ServiceImpl<LogsPddIoMapper, LogsPddIoEntity> implements LogsPddIoService {
+
+}
\ No newline at end of file

PddServer/src/main/java/org/ta/pddserver/utils/PddHttpTool.java

@@ -9,8 +9,11 @@ import org.springframework.http.ResponseEntity;
 import org.springframework.util.MultiValueMap;
 import org.springframework.web.client.RestTemplate;
 import org.ta.pddserver.config.PddAPIConfig;
+import org.ta.pddserver.entity.LogsPddIoEntity;
 import org.ta.pddserver.model.pddjy.request.JYBaseRequestModel;
 import org.ta.pddserver.model.pddlg.request.LGBaseModel;
+import org.ta.pddserver.service.LogsPddIoService;
+import org.ta.pddserver.service.impl.LogsPddIoImpl;
 
 import java.util.HashMap;
 import java.util.Map;
@@ -19,6 +22,11 @@ import java.util.Map;
 @Slf4j
 public class PddHttpTool {
 
+    private static LogsPddIoImpl logsPddIoImpl;
+
+    public static void setLogsToolService(LogsPddIoImpl impl) {
+        logsPddIoImpl = impl;
+    }
 
     public static String postRequest(JYBaseRequestModel request) {
 
@@ -50,6 +58,13 @@ public class PddHttpTool {
         RestTemplate restTemplate = new RestTemplate();
         ResponseEntity<String> resp = restTemplate.postForEntity(PddAPIConfig.URL, requestEntity, String.class);
         log.info("RESP:{}", resp.getBody());
+        if (logsPddIoImpl != null) {
+            LogsPddIoEntity logsPddIoEntity = new LogsPddIoEntity();
+            logsPddIoEntity.setAction("JY");
+            logsPddIoEntity.setReq(JSONObject.toJSONString(requestObj));
+            logsPddIoEntity.setResp(resp.getBody());
+            logsPddIoImpl.save(logsPddIoEntity);
+        }
         return resp.getBody();
     }
 
@@ -65,6 +80,13 @@ public class PddHttpTool {
         RestTemplate restTemplate = new RestTemplate();
         ResponseEntity<String> resp = restTemplate.postForEntity(PddAPIConfig.URL_GD, requestEntity, String.class);
         log.info("RESP:{}", resp.getBody());
+        if (logsPddIoImpl != null) {
+            LogsPddIoEntity logsPddIoEntity = new LogsPddIoEntity();
+            logsPddIoEntity.setAction("GD");
+            logsPddIoEntity.setReq(JSONObject.toJSONString(requestObj));
+            logsPddIoEntity.setResp(resp.getBody());
+            logsPddIoImpl.save(logsPddIoEntity);
+        }
         return resp.getBody();
     }
 }