下载国家库企业信息修改

api-admin/src/main/java/com/glxp/sale/admin/thread/didl/AsyncCompanyDlService.java

@@ -30,6 +30,8 @@ public class AsyncCompanyDlService {
     RedisUtil redisUtil;
     @Resource
     BasicExportService basicExportService;
+    @Resource
+    AsyncDiDlHelper asyncDiDlHelper;
 
     public String getPath() {
         SystemParamConfigEntity systemParamConfigEntity = systemParamConfigService.selectByParamKey("share_folder");
@@ -41,8 +43,6 @@ public class AsyncCompanyDlService {
     public void asyncDiByTime(String updateTime) {
         SystemParamConfigEntity systemParamConfigEntity = systemParamConfigService.selectByParamKey("sync_upstream_enable");
         if (systemParamConfigEntity.getParamValue().equals("1")) {
-
-            AsyncDiDlHelper asyncDiDlHelper = new AsyncDiDlHelper();
             List<UdiCompanyEntity> mUdiCompanyEntities = new ArrayList<>();
             int page = 1;
             int limit = 300;

api-admin/src/main/java/com/glxp/sale/admin/thread/didl/AsyncDiDlService.java

@@ -34,7 +34,8 @@ public class AsyncDiDlService {
     RedisUtil redisUtil;
     @Resource
     BasicExportService basicExportService;
-
+    @Resource
+    AsyncDiDlHelper asyncDiDlHelper;
     private static final Logger logger = LoggerFactory.getLogger(AsyncDiDlService.class);
 
     public void dlSyncUdi(String updateTime) {
@@ -43,7 +44,6 @@ public class AsyncDiDlService {
 
         //更新DI信息
         if (systemParamConfigEntity.getParamValue().equals("1")) {
-            AsyncDiDlHelper asyncDiDlHelper = new AsyncDiDlHelper();
             List<ProductInfoEntity> mProductInfoEntities = new ArrayList<>();
             int page = 1;
             int limit = 300;