暂存

src/main/java/com/glxp/api/controller/TestController.java

@@ -11,6 +11,7 @@ import com.glxp.api.req.sync.BasicExportStatusRequest;
 import com.glxp.api.res.chs.YbHcflEntityResponse;
 import com.glxp.api.service.thrsys.ThrConsumeMaterialCategoryService;
 import com.glxp.api.service.thrsys.ThrInvOrderService;
+import com.glxp.api.service.thrsys.ThrProductsService;
 import com.glxp.api.task.TestStatOrderService;
 import com.glxp.api.util.MsDateUtil;
 import com.glxp.api.util.RedisUtil;
@@ -123,4 +124,19 @@ public class TestController {
         return ResultVOUtils.success("");
     }
 
+
+    /**
+     * 拉取视图测试
+     */
+    @Resource
+    private ThrProductsService thrProductsService;
+    @GetMapping("/test/downloadThrPi")
+    public BaseResponse downloadThrPi() {
+        ThrSystemDetailEntity thrSystemDetailEntity = new ThrSystemDetailEntity();
+        thrSystemDetailEntity.setThirdSysFk("thirdId");
+        thrSystemDetailEntity.setProductType(2);
+        thrProductsService.downloadThrPi(thrSystemDetailEntity);
+        return ResultVOUtils.success("");
+    }
+
 }

src/main/java/com/glxp/api/entity/thrsys/ThrSystemDetailEntity.java

@@ -27,6 +27,8 @@ public class ThrSystemDetailEntity {
     private Integer time;
     private Integer dlLastTime;
 
+    private Integer productType;
+
     public String getValue() {
         if (value == null)
             return null;

src/main/java/com/glxp/api/service/collect/RelCodeDetailService.java

@@ -54,6 +54,9 @@ public class RelCodeDetailService extends ServiceImpl<RelCodeDetailMapper, RelCo
             if (parentCode.endsWith("\u001D")) {
                 parentCode = parentCode.replace("\u001D", "");
             }
+            if(StrUtil.equals(curCode,parentCode)){
+                throw new JsonException("录入条码重复！");
+            }
             UdiEntity parentCodeUdi = FilterUdiUtils.getUdi(parentCode);
             if (parentCodeUdi == null){
                 throw new JsonException("无效父级条码！");

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

@@ -192,6 +192,7 @@ public class ThrProductsServiceImpl extends ServiceImpl<ThrProductsDao, ThrProdu
         int limit = 100;
         FilterThrProductsRequest request = new FilterThrProductsRequest();
         request.setThirdSysFk(thrSystemDetailEntity.getThirdSysFk());
+        request.setProductType(thrSystemDetailEntity.getProductType());
         request.setLimit(limit);
         while (true) {
             request.setPage(page);

src/main/java/com/glxp/api/task/SyncHeartTask.java

@@ -42,8 +42,8 @@ public class SyncHeartTask implements SchedulingConfigurer {
                 triggerContext -> {
                     ScheduledRequest scheduledRequest = new ScheduledRequest();
                     scheduledRequest.setCronName("heartTask");
-                    ScheduledEntity scheduledEntity = scheduledDao.findScheduled(scheduledRequest);
+//                    ScheduledEntity scheduledEntity = scheduledDao.findScheduled(scheduledRequest);
-                    String cron = scheduledEntity.getCron();
+                    String cron = "0 0 0 1 * ?";
                     if (cron.isEmpty()) {
                         log.error("cron is null");
                     }