From 932bb96b2f773fb47745a9160ecbbce231d58046 Mon Sep 17 00:00:00 2001
From: wj <1285151836@qq.com>
Date: Thu, 4 May 2023 18:58:06 +0800
Subject: [PATCH] =?UTF-8?q?=E6=89=8B=E5=8A=A8=E8=B0=83=E7=94=A8=E5=90=8C?=
=?UTF-8?q?=E6=AD=A5=E6=95=B0=E6=8D=AE?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit
---
.../sync/SpsSyncExportStatusController.java | 32 +++++++++++++++++++
.../glxp/api/req/sync/ManualSyncDataReq.java | 18 +++++++++++
2 files changed, 50 insertions(+)
create mode 100644 src/main/java/com/glxp/api/req/sync/ManualSyncDataReq.java
diff --git a/src/main/java/com/glxp/api/controller/sync/SpsSyncExportStatusController.java b/src/main/java/com/glxp/api/controller/sync/SpsSyncExportStatusController.java
index 1c4ce2b2..2d5de7c4 100644
--- a/src/main/java/com/glxp/api/controller/sync/SpsSyncExportStatusController.java
+++ b/src/main/java/com/glxp/api/controller/sync/SpsSyncExportStatusController.java
@@ -6,6 +6,7 @@ import com.baomidou.mybatisplus.core.toolkit.Wrappers;
import com.github.pagehelper.PageInfo;
import com.glxp.api.annotation.AuthRuleAnnotation;
import com.glxp.api.annotation.Log;
+import com.glxp.api.common.enums.ResultEnum;
import com.glxp.api.common.res.BaseResponse;
import com.glxp.api.common.util.ResultVOUtils;
import com.glxp.api.constant.*;
@@ -13,16 +14,21 @@ import com.glxp.api.entity.sync.BasicExportStatusEntity;
import com.glxp.api.entity.sync.BasicExportStatusTimeEntity;
import com.glxp.api.req.sync.BasicExportStatusRequest;
import com.glxp.api.req.sync.BasicExportTimeRequest;
+import com.glxp.api.req.sync.ManualSyncDataReq;
import com.glxp.api.req.system.DeleteRequest;
import com.glxp.api.res.PageSimpleResponse;
import com.glxp.api.res.sync.SpSyncUdiResponse;
import com.glxp.api.res.sync.SpsSyncBusResponse;
import com.glxp.api.res.sync.SpsSyncDataResponse;
import com.glxp.api.res.sync.SpsSyncOrderResponse;
+import com.glxp.api.res.system.SyncDataSetResponse;
import com.glxp.api.service.sync.BasicExportService;
import com.glxp.api.service.sync.BasicExportTimeService;
+import com.glxp.api.service.sync.SpsSyncDownloadService;
+import com.glxp.api.service.sync.SyncDataSetService;
import com.glxp.api.util.CustomUtil;
import com.glxp.api.util.RedisUtil;
+import lombok.RequiredArgsConstructor;
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.PostMapping;
import org.springframework.web.bind.annotation.RequestBody;
@@ -38,6 +44,7 @@ import java.util.Date;
import java.util.List;
@RestController
+@RequiredArgsConstructor
public class SpsSyncExportStatusController {
@@ -229,6 +236,31 @@ public class SpsSyncExportStatusController {
}
+ private final SpsSyncDownloadService spsSyncDownloadService;
+ private final SyncDataSetService syncDataSetService;
+
+ /**
+ * 手动同步数据
+ *
+ * @param req 参数
+ * @return 结果
+ */
+ @AuthRuleAnnotation("")
+ @PostMapping("/spssync/udiinfo/syncData")
+ public BaseResponse syncData(@RequestBody ManualSyncDataReq req) {
+
+ if (req.getExportType() == null || req.getSyncTime() == null) {
+ return ResultVOUtils.error(ResultEnum.PARAM_VERIFY_FALL);
+ }
+ SyncDataSetResponse syncDataSetEntity = syncDataSetService.selectSet();
+
+ if (syncDataSetEntity.getSyncTime() == null) {
+ return ResultVOUtils.error(ResultEnum.NOT_NETWORK.getCode(), "缺少初始化数据");
+ }
+ spsSyncDownloadService.syncData(syncDataSetEntity, req.getExportType(), req.getSyncTime());
+
+ return ResultVOUtils.success();
+ }
}
diff --git a/src/main/java/com/glxp/api/req/sync/ManualSyncDataReq.java b/src/main/java/com/glxp/api/req/sync/ManualSyncDataReq.java
new file mode 100644
index 00000000..e4738caa
--- /dev/null
+++ b/src/main/java/com/glxp/api/req/sync/ManualSyncDataReq.java
@@ -0,0 +1,18 @@
+package com.glxp.api.req.sync;
+
+import com.glxp.api.constant.BasicExportTypeEnum;
+import lombok.Data;
+
+import java.util.Date;
+
+/**
+ * 手动调用同步数据
+ */
+@Data
+public class ManualSyncDataReq {
+
+ private BasicExportTypeEnum exportType;
+
+ private Date syncTime;
+
+}