【工作中心】去重

nflg_project_dev/nflg-technology/src/main/java/com/nflg/product/technology/service/ProcessWorkCenterService.java

@@ -1,7 +1,6 @@
 package com.nflg.product.technology.service;
 
-import cn.hutool.core.convert.Convert;
-import cn.hutool.core.lang.TypeReference;
+import com.alibaba.fastjson.JSON;
 import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
 import com.baomidou.mybatisplus.core.metadata.IPage;
 import com.baomidou.mybatisplus.core.toolkit.IdWorker;
@@ -16,6 +15,7 @@ import com.nflg.product.technology.pojo.dto.sap.SapResult;
 import com.nflg.product.technology.pojo.entity.ProcessWorkCenterEntity;
 import com.nflg.product.technology.pojo.query.ProcessWorkCenterQuery;
 import com.nflg.product.technology.pojo.vo.ProcessWorkCenterVO;
+import lombok.extern.slf4j.Slf4j;
 import nflg.product.common.constant.STATE;
 import nflg.product.common.vo.ResultVO;
 import org.apache.commons.lang3.StringUtils;
@@ -24,14 +24,15 @@ import org.springframework.transaction.annotation.Transactional;
 import org.springframework.util.CollectionUtils;
 
 import javax.annotation.Resource;
-import java.math.BigDecimal;
 import java.util.*;
+import java.util.stream.Collectors;
 
 /**
  * 工艺管理-工作中心(BomTechnologyWorkCenter)表服务实现类
  *
  * @author makejava
  */
+@Slf4j
 @Service
 public class ProcessWorkCenterService extends ServiceImpl<ProcessWorkCenterMapper, ProcessWorkCenterEntity> {
 
@@ -70,7 +71,9 @@ public class ProcessWorkCenterService extends ServiceImpl<ProcessWorkCenterMappe
             }
 
             if (!CollectionUtils.isEmpty(tOut)) {
-
+                log.info("工作中心SAP数据：{}", JSON.toJSONString(tOut));
+                // 只过滤出作业类型是：1000 人工的工作中心数据（一般情况下同一工厂同一工作中心存5条，作业类型 1000 2000 3000 4000 空，取一条即可）
+                tOut = tOut.stream().filter(add -> "1000".equals(add.get("LSTAR"))).collect(Collectors.toList());
                 List<ProcessWorkCenterEntity> addList = new ArrayList<>(tOut.size());
                 tOut.forEach(out -> {
                     ProcessWorkCenterEntity add = new ProcessWorkCenterEntity();