| | |
| | | import com.baomidou.mybatisplus.core.toolkit.StringUtils; |
| | | import com.chinaztt.mes.basic.entity.Warehouse; |
| | | import com.chinaztt.mes.basic.service.LocationService; |
| | | import com.chinaztt.mes.basic.service.WarehouseService; |
| | | |
| | | import java.util.ArrayList; |
| | | import java.util.List; |
| | | import java.util.Map; |
| | | import java.util.stream.Collectors; |
| | | |
| | | /** |
| | | * @author ZTT |
| | |
| | | List<LocationData> list = new ArrayList<>(); |
| | | |
| | | private LocationService locationService; |
| | | private Map<String, Warehouse> warehouseMap; |
| | | |
| | | public LocationUploadListener(LocationService locationService, Map<String, Warehouse> warehouseMap) { |
| | | public LocationUploadListener(LocationService locationService) { |
| | | this.locationService = locationService; |
| | | this.warehouseMap = warehouseMap; |
| | | } |
| | | |
| | | @Override |
| | | public void invoke(LocationData data, AnalysisContext analysisContext) { |
| | | |
| | | if (StringUtils.isBlank(data.getWarehouseName())) { |
| | | throw new RuntimeException("缺少仓库名称"); |
| | | } |
| | | if (null == warehouseMap.get(data.getWarehouseName())) { |
| | | throw new RuntimeException("请填写正确的库位"); |
| | | } |
| | | Warehouse warehouse = warehouseMap.get(data.getWarehouseName()); |
| | | data.setFactoryId(warehouse.getFactoryId()); |
| | | data.setLocGroup(warehouse.getId()); |
| | | list.add(data); |
| | | if (list.size() >= BATCH_COUNT) { |
| | | save(); |