From 14c5e9a65caab9d127243e3db1cf96cad2483130 Mon Sep 17 00:00:00 2001
From: =?UTF-8?q?=E9=83=91=E6=98=8E=E6=A2=81?= <2429105222@qq.com>
Date: Mon, 10 Jul 2023 17:14:36 +0800
Subject: [PATCH] =?UTF-8?q?=E9=80=89=E5=85=A5di=E5=9B=BD=E5=AE=B6=E5=BA=93?=
 =?UTF-8?q?=E6=9F=A5=E8=AF=A2?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../controller/basic/UdiSyncController.java   | 26 ++++++++++++++++++-
 1 file changed, 25 insertions(+), 1 deletion(-)

diff --git a/src/main/java/com/glxp/api/controller/basic/UdiSyncController.java b/src/main/java/com/glxp/api/controller/basic/UdiSyncController.java
index cb08b1e63..ea2531cc6 100644
--- a/src/main/java/com/glxp/api/controller/basic/UdiSyncController.java
+++ b/src/main/java/com/glxp/api/controller/basic/UdiSyncController.java
@@ -150,7 +150,31 @@ public class UdiSyncController {
         productInfoFilterRequest.setNameCode(filterUdiInfoRequest.getNameCode());
         productInfoFilterRequest.setPage(filterUdiInfoRequest.getPage());
         productInfoFilterRequest.setLimit(filterUdiInfoRequest.getLimit());
-        return spGetHttpClient.getSyncDi(productInfoFilterRequest);
+        try {
+            BaseResponse<PageSimpleResponse<ProductInfoEntity>> udiDlDeviceResponse = syncUdiService.filterUdi(productInfoFilterRequest);
+            if (udiDlDeviceResponse.getCode() != 20000) {
+                return udiDlDeviceResponse;
+            }
+            if (CollUtil.isEmpty(udiDlDeviceResponse.getData().getList())) {
+                BaseResponse<List<ProductInfoEntity>> listBaseResponse = asyncDiDlHelper.dlByDiRes(filterUdiInfoRequest.getNameCode());
+
+                if (listBaseResponse.getCode() == 20000) {
+                    List<ProductInfoEntity> productInfoEntityList = listBaseResponse.getData();
+                    if (CollUtil.isNotEmpty(productInfoEntityList)) {
+                        productInfoService.insertProductInfos(productInfoEntityList);
+                        udiDlDeviceResponse = syncUdiService.filterUdi(productInfoFilterRequest);
+                    } else {
+                        ResultVOUtils.error(500, "未查询到该产品DI");
+                    }
+                } else {
+                    return listBaseResponse;
+                }
+            }
+            return udiDlDeviceResponse;
+        } catch (Exception e) {
+            e.printStackTrace();
+            return ResultVOUtils.error(500, "连接UDI数据下载服务出错！");
+        }
     }
 
     @AuthRuleAnnotation("")