2/

src/main/java/com/glxp/api/service/thrsys/impl/ThrProductsServiceImpl.java

@@ -333,10 +333,12 @@ public class ThrProductsServiceImpl extends ServiceImpl<ThrProductsDao, ThrProdu
         String lastUploadTime = (String) redisUtil.get("THR_PI_UPLOAD_TIME");
         String currentTime = MsDateUtil.formatDateTime(new Date());
         if (StrUtil.isNotEmpty(lastUploadTime)) {
+            log.error("开始上传 信息 1");
             //获取耗材字典最新维护数据
             FilterUdiRelRequest filterUdiRelRequest = new FilterUdiRelRequest();
             filterUdiRelRequest.setLastUpdateTime(lastUploadTime);
             List<UdiRelevanceResponse> udiRelevanceResponses = udiRelevanceService.filterUdiJoinSup(filterUdiRelRequest);
+            log.error("开始上传 信息 1.22222",udiRelevanceResponses);
             if (CollUtil.isNotEmpty(udiRelevanceResponses)) {
                 List<UdiRelevanceResponse> filteredList = udiRelevanceResponses.stream()
                         .filter(item ->
@@ -352,7 +354,9 @@ public class ThrProductsServiceImpl extends ServiceImpl<ThrProductsDao, ThrProdu
                         )
                         .collect(Collectors.toList());
 //                List<List<UdiRelevanceResponse>> splitList = CustomUtil.splitList(filteredList, 10);
+                log.error("开始上传 信息 2222",filteredList);
                 for (UdiRelevanceResponse udiRelevanceResponse : filteredList) {
+                    log.error("开始上传 信息 333");
                     BaseResponse baseResponse = postThrProduct(udiRelevanceResponse, thrSystemDetailEntity.getThirdSysFk());
                     if (baseResponse.getCode() != 20000) {
                         log.error(udiRelevanceResponse.getNameCode() + "," + udiRelevanceResponse.getId() + "第三方产品信息上传失败：" + baseResponse.getMessage());