From 61cd8da46195e98f3acaf1586956c1d7f2234070 Mon Sep 17 00:00:00 2001
From: zhanghl <253316343@qq.com>
Date: 星期四, 17 四月 2025 18:45:25 +0800
Subject: [PATCH] 增加日志表基础代码
---
aps-modules/aps-job/src/main/java/com/aps/job/service/impl/ApsWorkOrderJobServiceImpl.java | 20 +++++++++++++++-----
aps-modules/aps-job/src/main/resources/mapper/job/ApsWorkOrderJobLogMapper.xml | 2 +-
2 files changed, 16 insertions(+), 6 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 479c502..2c23280 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
@@ -19,6 +19,7 @@
import com.aps.job.mapper.ApsWorkOrderJobMapper;
import com.aps.job.domain.ApsWorkOrderJob;
import com.aps.job.service.IApsWorkOrderJobService;
+import org.springframework.transaction.annotation.Transactional;
import org.springframework.web.client.RestTemplate;
/**
@@ -120,13 +121,14 @@
}
+ @Transactional
@Override
public void batchInsertApsWorkOrderJob(ApsWorkOrderJobParam param) {
HttpHeaders headers = new HttpHeaders();
headers.setContentType(MediaType.APPLICATION_JSON);
- Integer PageIndex = 1;
- Integer PageSize = 500;
+ Integer PageIndex = 3;
+ Integer PageSize = 600;
Boolean continueFlag = true;
/* while (continueFlag){*/
@@ -136,11 +138,11 @@
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)
+ log.setCreateTime(DateUtils.getNowDate());
+ jobLogMapper.insertApsWorkOrderJobLog(log);
if (response.getStatusCode().is2xxSuccessful()) {
JSONObject responseBodyJson = JSONObject.parseObject(response.getBody());
if ("200".equals(responseBodyJson.getString("status"))) {
@@ -160,7 +162,15 @@
}
apsWorkOrderJobMapper.batchInsertApsWorkOrderJob(jobs);
}
+ log.setResult("success");
+ }else{
+ log.setResponseData(response.getBody());
}
}
+ else {
+ log.setResponseData(response.getBody());
+ log.setResult("request fail");
+ }
+ jobLogMapper.updateApsWorkOrderJobLog(log);
}
}
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
index 080e5f3..867b048 100644
--- a/aps-modules/aps-job/src/main/resources/mapper/job/ApsWorkOrderJobLogMapper.xml
+++ b/aps-modules/aps-job/src/main/resources/mapper/job/ApsWorkOrderJobLogMapper.xml
@@ -56,7 +56,7 @@
<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="createTime != null">#{createTime},</if>
<if test="updateTime != null">#{updateTime},</if>
</trim>
</insert>
--
Gitblit v1.9.3