blame | 历史 | 补丁 | 提交 | 提交对比 | ignore whitespace
xiangpei
2024-09-05 fb13447f6cc1c85378bf98ab81dbb3e893be949f 
 ycl-server/src/main/java/com/ycl/platform/service/impl/YwPointServiceImpl.java


@@ -17,6 +17,7 @@


import com.ycl.platform.domain.vo.CheckTagVO;


import com.ycl.platform.domain.vo.ReportAuditingRecordVO;


import com.ycl.platform.domain.vo.YwPointVO;


import com.ycl.platform.mapper.TMonitorMapper;


import com.ycl.platform.mapper.YwPeopleMapper;


import com.ycl.platform.mapper.YwPointMapper;


import com.ycl.platform.service.YwPointService;


@@ -34,6 +35,7 @@


import org.springframework.transaction.annotation.Transactional;


import org.springframework.util.Assert;


import org.springframework.util.CollectionUtils;


import org.springframework.util.StringUtils;


import org.springframework.web.multipart.MultipartFile;




import java.io.IOException;


@@ -53,8 +55,7 @@


public class YwPointServiceImpl extends ServiceImpl<YwPointMapper, YwPoint> implements YwPointService {




    private final SysDeptMapper sysDeptMapper;


    private final YwUnitService unitService;


    private final YwPeopleMapper ywPeopleMapper;


    private final TMonitorMapper monitorMapper;




    private static final ExecutorService executorService = new ThreadPoolExecutor(8,


            24,


@@ -324,4 +325,17 @@


            }


        }


    }




    @Override


    public <T extends BaseResult> void setNew(List<T> dataList) {


        List<String> gbList = dataList.stream().map(BaseResult::getNo).collect(Collectors.toList());


        Map<String, BaseResult> pointMap = dataList.stream().collect(Collectors.toMap(BaseResult::getNo, item -> item));


        List<String> dbGBList = monitorMapper.getGBbyGB(gbList);


        for (String gb : dbGBList) {


            BaseResult data = pointMap.get(gb);


            if (Objects.nonNull(data)) {


                data.setNewDevice(Boolean.TRUE);


            }


        }


    }


}