From 09ad3af7d18cc9e4186e1a9775eb446579ad5f8d Mon Sep 17 00:00:00 2001
From: zhanghl <253316343@qq.com>
Date: 星期四, 17 四月 2025 18:37:38 +0800
Subject: [PATCH] 增加日志表基础代码

---
 aps-modules/aps-job/src/main/java/com/aps/job/service/impl/ApsWorkOrderJobServiceImpl.java |   13 +++++-
 aps-modules/aps-job/src/main/resources/mapper/job/ApsWorkOrderJobLogMapper.xml             |   89 ++++++++++++++++++++++++++++++++++++++++++++
 2 files changed, 99 insertions(+), 3 deletions(-)

diff --git a/aps-modules/aps-job/src/main/java/com/aps/job/service/impl/ApsWorkOrderJobServiceImpl.java b/aps-modules/aps-job/src/main/java/com/aps/job/service/impl/ApsWorkOrderJobServiceImpl.java
index 6ff0aa6..479c502 100644
--- a/aps-modules/aps-job/src/main/java/com/aps/job/service/impl/ApsWorkOrderJobServiceImpl.java
+++ b/aps-modules/aps-job/src/main/java/com/aps/job/service/impl/ApsWorkOrderJobServiceImpl.java
@@ -6,6 +6,7 @@
 import com.alibaba.fastjson.JSONArray;
 import com.alibaba.fastjson.JSONObject;
 import com.aps.common.core.utils.DateUtils;
+import com.aps.job.domain.ApsWorkOrderJobLog;
 import com.aps.job.mapper.ApsWorkOrderJobLogMapper;
 import com.aps.job.param.ApsWorkOrderJobParam;
 import org.springframework.beans.factory.annotation.Value;
@@ -128,9 +129,18 @@
         Integer PageSize = 500;
         Boolean continueFlag = true;
         /*  while (continueFlag){*/
+
+        ApsWorkOrderJobLog log = new ApsWorkOrderJobLog();
+
         String requestString = JSONObject.toJSONString(param);
         HttpEntity<String> request = new HttpEntity<>(requestString, headers);
         ResponseEntity<String> response = restTemplate.postForEntity(getWorkOrderUrl, request, String.class);
+        log.setRequestData(requestString);
+        log.setResponseData(response.getBody());
+        log.setPageNum(Long.valueOf(PageIndex));
+        log.setPageCount(Long.valueOf(PageSize));
+        log.setCreateTime();
+        jobLogMapper.insertApsWorkOrderJobLog(log)
         if (response.getStatusCode().is2xxSuccessful()) {
             JSONObject responseBodyJson = JSONObject.parseObject(response.getBody());
             if ("200".equals(responseBodyJson.getString("status"))) {
@@ -150,10 +160,7 @@
                     }
                     apsWorkOrderJobMapper.batchInsertApsWorkOrderJob(jobs);
                 }
-
             }
-
         }
-
     }
 }
diff --git a/aps-modules/aps-job/src/main/resources/mapper/job/ApsWorkOrderJobLogMapper.xml b/aps-modules/aps-job/src/main/resources/mapper/job/ApsWorkOrderJobLogMapper.xml
new file mode 100644
index 0000000..080e5f3
--- /dev/null
+++ b/aps-modules/aps-job/src/main/resources/mapper/job/ApsWorkOrderJobLogMapper.xml
@@ -0,0 +1,89 @@
+<?xml version="1.0" encoding="UTF-8" ?>
+<!DOCTYPE mapper
+PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN"
+"http://mybatis.org/dtd/mybatis-3-mapper.dtd">
+<mapper namespace="com.aps.job.mapper.ApsWorkOrderJobLogMapper">
+    
+    <resultMap type="ApsWorkOrderJobLog" id="ApsWorkOrderJobLogResult">
+        <result property="id"    column="id"    />
+        <result property="pageNum"    column="page_num"    />
+        <result property="pageCount"    column="page_count"    />
+        <result property="responseData"    column="response_data"    />
+        <result property="result"    column="result"    />
+        <result property="orderId"    column="order_id"    />
+        <result property="requestData"    column="request_data"    />
+        <result property="createTime"    column="create_time"    />
+        <result property="updateTime"    column="update_time"    />
+    </resultMap>
+
+    <sql id="selectApsWorkOrderJobLogVo">
+        select id, page_num, page_count, response_data, result, order_id, request_data,create_time,  update_time  from aps_work_order_job_log
+    </sql>
+
+    <select id="selectApsWorkOrderJobLogList" parameterType="ApsWorkOrderJobLog" resultMap="ApsWorkOrderJobLogResult">
+        <include refid="selectApsWorkOrderJobLogVo"/>
+        <where>  
+            <if test="pageNum != null "> and page_num = #{pageNum}</if>
+            <if test="pageCount != null "> and page_count = #{pageCount}</if>
+            <if test="responseData != null  and responseData != ''"> and response_data = #{responseData}</if>
+            <if test="result != null  and result != ''"> and result = #{result}</if>
+            <if test="orderId != null  and orderId != ''"> and order_id = #{orderId}</if>
+            <if test="requestData != null  and requestData != ''"> and request_data = #{requestData}</if>
+        </where>
+    </select>
+    
+    <select id="selectApsWorkOrderJobLogById" parameterType="Long" resultMap="ApsWorkOrderJobLogResult">
+        <include refid="selectApsWorkOrderJobLogVo"/>
+        where id = #{id}
+    </select>
+
+    <insert id="insertApsWorkOrderJobLog" parameterType="ApsWorkOrderJobLog" useGeneratedKeys="true" keyProperty="id">
+        insert into aps_work_order_job_log
+        <trim prefix="(" suffix=")" suffixOverrides=",">
+            <if test="pageNum != null">page_num,</if>
+            <if test="pageCount != null">page_count,</if>
+            <if test="responseData != null">response_data,</if>
+            <if test="result != null">result,</if>
+            <if test="orderId != null">order_id,</if>
+            <if test="requestData != null">request_data,</if>
+            <if test="createTime != null">create_time,</if>
+            <if test="updateTime != null">update_time,</if>
+         </trim>
+        <trim prefix="values (" suffix=")" suffixOverrides=",">
+            <if test="pageNum != null">#{pageNum},</if>
+            <if test="pageCount != null">#{pageCount},</if>
+            <if test="responseData != null">#{responseData},</if>
+            <if test="result != null">#{result},</if>
+            <if test="orderId != null">#{orderId},</if>
+            <if test="requestData != null">#{requestData},</if>
+            <if test="createBy != null">#{createBy},</if>
+            <if test="updateTime != null">#{updateTime},</if>
+         </trim>
+    </insert>
+
+    <update id="updateApsWorkOrderJobLog" parameterType="ApsWorkOrderJobLog">
+        update aps_work_order_job_log
+        <trim prefix="SET" suffixOverrides=",">
+            <if test="pageNum != null">page_num = #{pageNum},</if>
+            <if test="pageCount != null">page_count = #{pageCount},</if>
+            <if test="responseData != null">response_data = #{responseData},</if>
+            <if test="result != null">result = #{result},</if>
+            <if test="orderId != null">order_id = #{orderId},</if>
+            <if test="requestData != null">request_data = #{requestData},</if>
+            <if test="createTime != null">create_time = #{createTime},</if>
+            <if test="updateTime != null">update_time = #{updateTime},</if>
+        </trim>
+        where id = #{id}
+    </update>
+
+    <delete id="deleteApsWorkOrderJobLogById" parameterType="Long">
+        delete from aps_work_order_job_log where id = #{id}
+    </delete>
+
+    <delete id="deleteApsWorkOrderJobLogByIds" parameterType="String">
+        delete from aps_work_order_job_log where id in 
+        <foreach item="id" collection="array" open="(" separator="," close=")">
+            #{id}
+        </foreach>
+    </delete>
+</mapper>
\ No newline at end of file

--
Gitblit v1.9.3