|
|
@@ -17,7 +17,7 @@
|
|
|
package org.springblade.client.service.impl;
|
|
|
|
|
|
import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
|
|
|
-import com.baomidou.mybatisplus.core.toolkit.StringUtils;
|
|
|
+import com.baomidou.mybatisplus.core.toolkit.CollectionUtils;
|
|
|
import lombok.AllArgsConstructor;
|
|
|
import org.springblade.client.entity.StorageDesc;
|
|
|
import org.springblade.client.entity.StorageType;
|
|
|
@@ -26,12 +26,16 @@ import org.springblade.client.vo.StorageDescVO;
|
|
|
import org.springblade.client.mapper.StorageDescMapper;
|
|
|
import org.springblade.client.service.IStorageDescService;
|
|
|
import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
|
|
|
+import org.springblade.core.mp.support.Condition;
|
|
|
+import org.springblade.core.mp.support.Query;
|
|
|
import org.springblade.core.secure.utils.SecureUtil;
|
|
|
import org.springframework.stereotype.Service;
|
|
|
import com.baomidou.mybatisplus.core.metadata.IPage;
|
|
|
import org.springframework.transaction.annotation.Transactional;
|
|
|
|
|
|
+import java.util.ArrayList;
|
|
|
import java.util.Date;
|
|
|
+import java.util.List;
|
|
|
|
|
|
/**
|
|
|
* 库区表 服务实现类
|
|
|
@@ -65,7 +69,7 @@ public class StorageDescServiceImpl extends ServiceImpl<StorageDescMapper, Stora
|
|
|
baseMapper.updateById(storageDesc);
|
|
|
}
|
|
|
//保存库区和仓库对应关系
|
|
|
- boolean b = storageTypeDescService.saveMessage(storageDesc.getId(), storageDesc.getStorageId(), SecureUtil.getTenantId());
|
|
|
+ boolean b = storageTypeDescService.saveMessage(storageDesc.getId(), storageDesc.getStorageTypeId(), SecureUtil.getTenantId());
|
|
|
return storageDesc;
|
|
|
}
|
|
|
|
|
|
@@ -75,12 +79,51 @@ public class StorageDescServiceImpl extends ServiceImpl<StorageDescMapper, Stora
|
|
|
//获取库区和仓库对应表
|
|
|
StorageTypeDesc storageId = storageTypeDescService.getOne(new QueryWrapper<StorageTypeDesc>().eq("storage_id", desc.getId()));
|
|
|
if (storageId != null){
|
|
|
+ desc.setStorageTypeId(storageId.getStorageTypeId());
|
|
|
StorageType storageType = storageTypeService.getById(storageId.getStorageTypeId());
|
|
|
if (storageType != null){
|
|
|
- desc.setStorageName(storageType.getCname());
|
|
|
+ desc.setStorageTypeName(storageType.getCname());
|
|
|
}
|
|
|
}
|
|
|
- return storageDesc;
|
|
|
+ return desc;
|
|
|
}
|
|
|
|
|
|
+ @Override
|
|
|
+ public IPage<StorageDesc> pageMessage(StorageDesc storageDesc, Query query) {
|
|
|
+ List<StorageDesc> storageDescList = new ArrayList<>();
|
|
|
+ //判断仓库参数是否为空
|
|
|
+ if (storageDesc.getStorageTypeId() != null){
|
|
|
+ //查询仓库与库区对应表获取库区id
|
|
|
+ List<StorageTypeDesc> list = storageTypeDescService.list(new QueryWrapper<StorageTypeDesc>().eq("storage_type_id", storageDesc.getStorageTypeId())
|
|
|
+ .eq("status", 0));
|
|
|
+ //判断list是否为空,不为空获取库区id加其他条件查询库区信息
|
|
|
+ if (CollectionUtils.isNotEmpty(list)){
|
|
|
+ for (StorageTypeDesc storageTypeDesc : list) {
|
|
|
+ storageDesc.setId(storageTypeDesc.getStorageId());
|
|
|
+ List<StorageDesc> storageDescs = baseMapper.selectList(new QueryWrapper<StorageDesc>().setEntity(storageDesc));
|
|
|
+ if (CollectionUtils.isNotEmpty(storageDescs)){
|
|
|
+ storageDescs.stream().forEach(item ->{
|
|
|
+ item.setStorageTypeId(storageDesc.getStorageTypeId());
|
|
|
+ });
|
|
|
+ storageDescList.addAll(storageDescs);
|
|
|
+ }
|
|
|
+ }
|
|
|
+ }
|
|
|
+ }else {
|
|
|
+ storageDescList = baseMapper.selectList(new QueryWrapper<StorageDesc>().setEntity(storageDesc));
|
|
|
+ if (CollectionUtils.isNotEmpty(storageDescList)){
|
|
|
+ storageDescList.stream().forEach(item ->{
|
|
|
+ StorageTypeDesc typeDesc = storageTypeDescService.getOne(new QueryWrapper<StorageTypeDesc>().eq("storage_id", item.getId())
|
|
|
+ .eq("status", 0));
|
|
|
+ if (typeDesc != null){
|
|
|
+ item.setStorageTypeId(typeDesc.getStorageTypeId());
|
|
|
+ }
|
|
|
+ });
|
|
|
+ }
|
|
|
+ }
|
|
|
+ IPage<StorageDesc> page = Condition.getPage(query);
|
|
|
+ return page.setRecords(storageDescList);
|
|
|
+ }
|
|
|
+
|
|
|
+
|
|
|
}
|