From 11000bf4837f245824d88fc786e0ec8991f46b9e Mon Sep 17 00:00:00 2001
From: zhanghl <253316343@qq.com>
Date: 星期四, 17 四月 2025 18:25:09 +0800
Subject: [PATCH] 增加日志表基础代码
---
aps-modules/aps-job/src/main/java/com/aps/job/service/impl/ApsWorkOrderJobServiceImpl.java | 63 ++++++++++++++++---------------
1 files changed, 32 insertions(+), 31 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 703500c..6ff0aa6 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,8 +6,8 @@
import com.alibaba.fastjson.JSONArray;
import com.alibaba.fastjson.JSONObject;
import com.aps.common.core.utils.DateUtils;
-import com.aps.common.core.utils.StringUtils;
-import jakarta.annotation.Resource;
+import com.aps.job.mapper.ApsWorkOrderJobLogMapper;
+import com.aps.job.param.ApsWorkOrderJobParam;
import org.springframework.beans.factory.annotation.Value;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.http.HttpEntity;
@@ -41,6 +41,8 @@
@Autowired
private RestTemplate restTemplate;
+ @Autowired
+ private ApsWorkOrderJobLogMapper jobLogMapper;
/**
* 鏌ヨ宸ュ崟鍚屾
@@ -118,41 +120,40 @@
@Override
- public void batchInsertApsWorkOrderJob() {
+ public void batchInsertApsWorkOrderJob(ApsWorkOrderJobParam param) {
HttpHeaders headers = new HttpHeaders();
headers.setContentType(MediaType.APPLICATION_JSON);
- Integer PageIndex=1;
- Integer PageSize=500;
- Boolean continueFlag=true;
- /* while (continueFlag){*/
- JSONObject requestBody = new JSONObject();
- requestBody.put("PageIndex", PageIndex);
- requestBody.put("PageSize", PageSize);
- HttpEntity<String> request = new HttpEntity<>(requestBody.toJSONString(), headers);
- ResponseEntity<String> response = restTemplate.postForEntity(getWorkOrderUrl, request, String.class);
- if (response.getStatusCode().is2xxSuccessful()) {
- JSONObject responseBodyJson = JSONObject.parseObject(response.getBody());
- if("200".equals(responseBodyJson.getString("status"))){
- JSONArray result = responseBodyJson.getJSONArray("data");
- if (result!=null){
- List<ApsWorkOrderJob> jobs = new ArrayList<>();
- for (int i = 0; i < result.size(); i++) {
- ApsWorkOrderJob order = result.getObject(i, ApsWorkOrderJob.class);
- JSONObject jsonObject = result.getJSONObject(i);
- order.setOrderId(jsonObject.get("ID").toString());
- order.setCreateTime(DateUtils.getNowDate());
- order.setPageIndex(i);
- order.setPageNum(PageIndex);
- order.setDelFlag("0");
- jobs.add(order);
- }
- apsWorkOrderJobMapper.batchInsertApsWorkOrderJob(jobs);
+ Integer PageIndex = 1;
+ Integer PageSize = 500;
+ Boolean continueFlag = true;
+ /* while (continueFlag){*/
+ String requestString = JSONObject.toJSONString(param);
+ HttpEntity<String> request = new HttpEntity<>(requestString, headers);
+ ResponseEntity<String> response = restTemplate.postForEntity(getWorkOrderUrl, request, String.class);
+ if (response.getStatusCode().is2xxSuccessful()) {
+ JSONObject responseBodyJson = JSONObject.parseObject(response.getBody());
+ if ("200".equals(responseBodyJson.getString("status"))) {
+ JSONArray result = responseBodyJson.getJSONArray("data");
+ if (result != null) {
+ List<ApsWorkOrderJob> jobs = new ArrayList<>();
+ for (int i = 0; i < result.size(); i++) {
+ ApsWorkOrderJob order = result.getObject(i, ApsWorkOrderJob.class);
+ JSONObject jsonObject = result.getJSONObject(i);
+ order.setOrderId(jsonObject.get("ID").toString());
+ order.setCreateTime(DateUtils.getNowDate());
+ order.setPageIndex(i);
+ order.setPageNum(PageIndex);
+ order.setDelFlag("0");
+ order.setProcessStatus("0");
+ jobs.add(order);
}
-
+ apsWorkOrderJobMapper.batchInsertApsWorkOrderJob(jobs);
}
}
- /* }*/
+
+ }
+
}
}
--
Gitblit v1.9.3