| | |
|---|
| | | @Override |
|---|
| | | public void removeTableUpdateWcs(List<WorkstationWcs> updateWcsList) { |
|---|
| | | Map<Long, WorkstationWcs> current = new HashMap<>(); |
|---|
| | | |
|---|
| | | //删除时序数据库中的表 |
|---|
| | | updateWcsList.stream().filter(it -> Func.isNotEmpty(it.getUsageId())).peek(it -> current.put(it.getWorkstationId(),it)).map(it ->{ |
|---|
| | | return this.workstationWcsService.getOne(Lambda.<WorkstationWcs>eq(WorkstationWcs::getWorkstationId, it.getWorkstationId()).eq(WorkstationWcs::getCollectSettingItem, it.getCollectSettingItem()).ne(WorkstationWcs::getDataType, WcsDataTypeEnums.WcsDataType.OTHER.getCode())); |
|---|
| | | }) .filter(Func::notNull) |
|---|
