From b192b2f041eff93bb084bf70877af88ae0667dec Mon Sep 17 00:00:00 2001
From: zhanghl <253316343@qq.com>
Date: 星期四, 17 四月 2025 17:52:42 +0800
Subject: [PATCH] [update]工单同步类 补充 process_status 字段
---
aps-modules/aps-job/src/main/java/com/aps/job/service/impl/ApsWorkOrderJobServiceImpl.java | 62 +++++++++++++++++++++++++++++++
1 files changed, 62 insertions(+), 0 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 82927a6..703500c 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
@@ -1,12 +1,24 @@
package com.aps.job.service.impl;
+import java.util.ArrayList;
import java.util.List;
+
+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 org.springframework.beans.factory.annotation.Value;
import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.http.HttpEntity;
+import org.springframework.http.HttpHeaders;
+import org.springframework.http.MediaType;
+import org.springframework.http.ResponseEntity;
import org.springframework.stereotype.Service;
import com.aps.job.mapper.ApsWorkOrderJobMapper;
import com.aps.job.domain.ApsWorkOrderJob;
import com.aps.job.service.IApsWorkOrderJobService;
+import org.springframework.web.client.RestTemplate;
/**
* 宸ュ崟鍚屾Service涓氬姟灞傚鐞�
@@ -19,6 +31,16 @@
{
@Autowired
private ApsWorkOrderJobMapper apsWorkOrderJobMapper;
+
+ /**
+ * 鑾峰彇璁㈠崟鎺ュ彛
+ * */
+ @Value("${u9.workOrderJobUrl}")
+ private String getWorkOrderUrl;
+
+ @Autowired
+ private RestTemplate restTemplate;
+
/**
* 鏌ヨ宸ュ崟鍚屾
@@ -93,4 +115,44 @@
{
return apsWorkOrderJobMapper.deleteApsWorkOrderJobById(id);
}
+
+
+ @Override
+ public void batchInsertApsWorkOrderJob() {
+
+ 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);
+ }
+
+ }
+
+ }
+ /* }*/
+ }
}
--
Gitblit v1.9.3