|
@@ -20,6 +20,7 @@ import org.springblade.core.mp.support.Query;
|
|
|
import org.springblade.core.secure.utils.SecureUtil;
|
|
import org.springblade.core.secure.utils.SecureUtil;
|
|
|
import org.springblade.core.tool.api.R;
|
|
import org.springblade.core.tool.api.R;
|
|
|
import org.springblade.core.tool.utils.Func;
|
|
import org.springblade.core.tool.utils.Func;
|
|
|
|
|
+import org.springblade.core.tool.utils.ObjectUtil;
|
|
|
import org.springblade.deliver.goods.entity.Delivery;
|
|
import org.springblade.deliver.goods.entity.Delivery;
|
|
|
import org.springblade.deliver.goods.enums.DeliveryEnum;
|
|
import org.springblade.deliver.goods.enums.DeliveryEnum;
|
|
|
import org.springblade.deliver.goods.enums.DeliveryStatusEnum;
|
|
import org.springblade.deliver.goods.enums.DeliveryStatusEnum;
|
|
@@ -28,6 +29,7 @@ import org.springblade.deliver.goods.service.IDeliveryFilesService;
|
|
|
import org.springblade.deliver.goods.service.IDeliveryItemsService;
|
|
import org.springblade.deliver.goods.service.IDeliveryItemsService;
|
|
|
import org.springblade.deliver.goods.service.IDeliveryService;
|
|
import org.springblade.deliver.goods.service.IDeliveryService;
|
|
|
import org.springblade.deliver.goods.vo.DeliveryVO;
|
|
import org.springblade.deliver.goods.vo.DeliveryVO;
|
|
|
|
|
+import org.springblade.purchase.sales.entity.Order;
|
|
|
import org.springblade.system.user.entity.User;
|
|
import org.springblade.system.user.entity.User;
|
|
|
import org.springblade.system.user.feign.IUserClient;
|
|
import org.springblade.system.user.feign.IUserClient;
|
|
|
import org.springframework.web.bind.annotation.*;
|
|
import org.springframework.web.bind.annotation.*;
|
|
@@ -94,42 +96,76 @@ public class AllotController extends BladeController {
|
|
|
lambdaQueryWrapper.orderByDesc(Delivery::getId);
|
|
lambdaQueryWrapper.orderByDesc(Delivery::getId);
|
|
|
IPage<Delivery> pages = deliveryService.page(Condition.getPage(query), lambdaQueryWrapper);
|
|
IPage<Delivery> pages = deliveryService.page(Condition.getPage(query), lambdaQueryWrapper);
|
|
|
if (CollectionUtils.isNotEmpty(pages.getRecords())){
|
|
if (CollectionUtils.isNotEmpty(pages.getRecords())){
|
|
|
|
|
+
|
|
|
|
|
+ String corpIds = "";//客户拼接
|
|
|
|
|
+ String salesCompanyIds = "";//销售公司
|
|
|
|
|
+ String createUserIds = "";//创建人
|
|
|
|
|
+ String updateUserIds = "";//修改人
|
|
|
|
|
+ String storageIds = "";//仓库
|
|
|
|
|
+ String allotStorageIds = "";//调拨仓库
|
|
|
|
|
+
|
|
|
|
|
+ for (Delivery deliverys : pages.getRecords()){
|
|
|
|
|
+ if (ObjectUtil.isNotEmpty(deliverys.getCorpId())){
|
|
|
|
|
+ corpIds = corpIds + deliverys.getCorpId() + ",";
|
|
|
|
|
+ }
|
|
|
|
|
+ if (ObjectUtil.isNotEmpty(deliverys.getCorpId())){
|
|
|
|
|
+ salesCompanyIds = salesCompanyIds + deliverys.getSalesCompany() + ",";
|
|
|
|
|
+ }
|
|
|
|
|
+ if (ObjectUtil.isNotEmpty(deliverys.getCreateUser())){
|
|
|
|
|
+ createUserIds = createUserIds + deliverys.getCreateUser() + ",";
|
|
|
|
|
+ }
|
|
|
|
|
+ if (ObjectUtil.isNotEmpty(deliverys.getUpdateUser())){
|
|
|
|
|
+ updateUserIds = updateUserIds + deliverys.getUpdateUser() + ",";
|
|
|
|
|
+ }
|
|
|
|
|
+ if (ObjectUtil.isNotEmpty(deliverys.getStorageId())){
|
|
|
|
|
+ storageIds = storageIds + deliverys.getStorageId() + ",";
|
|
|
|
|
+ }
|
|
|
|
|
+ if (ObjectUtil.isNotEmpty(deliverys.getStorageId())){
|
|
|
|
|
+ allotStorageIds = allotStorageIds + deliverys.getAllotStorageId() + ",";
|
|
|
|
|
+ }
|
|
|
|
|
+ }
|
|
|
|
|
+
|
|
|
|
|
+ List<CorpsDesc> corpList = corpsDescClient.selectByCorpIds(corpIds);
|
|
|
|
|
+ List<CorpsDesc> salesCompanyList = corpsDescClient.selectByCorpIds(salesCompanyIds);
|
|
|
|
|
+ List<User> createUserList = iUserClient.selectUserIds(createUserIds);
|
|
|
|
|
+ List<User> updateUserList = iUserClient.selectUserIds(updateUserIds);
|
|
|
|
|
+ List<StorageDesc> storageList = iStorageClient.selectStorageIds(storageIds);
|
|
|
|
|
+ List<StorageDesc> allotStorageList = iStorageClient.selectStorageIds(allotStorageIds);
|
|
|
|
|
+
|
|
|
pages.getRecords().forEach(item ->{
|
|
pages.getRecords().forEach(item ->{
|
|
|
- if (item.getCorpId() != null){
|
|
|
|
|
- R<CorpsDesc> corpMessage = corpsDescClient.getCorpMessage(item.getCorpId());
|
|
|
|
|
- if (corpMessage.isSuccess() && corpMessage.getData() != null){
|
|
|
|
|
- item.setCorpsName(corpMessage.getData().getCname());
|
|
|
|
|
|
|
+ if (item.getCorpId() != null) {
|
|
|
|
|
+ if (ObjectUtil.isNotEmpty(corpList)) {
|
|
|
|
|
+ item.setCorpsName(corpList.stream().filter(e -> e.getId().equals(item.getCorpId())).findFirst().get().getCname());
|
|
|
}
|
|
}
|
|
|
}
|
|
}
|
|
|
if (item.getSalesCompany() != null){
|
|
if (item.getSalesCompany() != null){
|
|
|
- R<CorpsDesc> corpMessage = corpsDescClient.getCorpMessage(item.getSalesCompany());
|
|
|
|
|
- if (corpMessage.isSuccess() && corpMessage.getData() != null){
|
|
|
|
|
- item.setSalesCompanyName(corpMessage.getData().getCname());
|
|
|
|
|
|
|
+ if (ObjectUtil.isNotEmpty(salesCompanyList)) {
|
|
|
|
|
+ item.setSalesCompanyName(salesCompanyList.stream().filter(e -> e.getId().equals(item.getSalesCompany())).findFirst().get().getCname());
|
|
|
}
|
|
}
|
|
|
}
|
|
}
|
|
|
- R<User> user = iUserClient.userInfoById(item.getCreateUser());
|
|
|
|
|
- if (user.isSuccess() && user.getData() != null){
|
|
|
|
|
- item.setCreateUserName(user.getData().getName());
|
|
|
|
|
|
|
+ //制单人名字
|
|
|
|
|
+ if(item.getCreateUser()!=null)
|
|
|
|
|
+ {
|
|
|
|
|
+ if (ObjectUtil.isNotEmpty(createUserList)) {
|
|
|
|
|
+ item.setCreateUserName(createUserList.stream().filter(e -> e.getId().equals(item.getCreateUser())).findFirst().get().getRealName());
|
|
|
|
|
+ }
|
|
|
}
|
|
}
|
|
|
-
|
|
|
|
|
- R<User> user1 = iUserClient.userInfoById(item.getUpdateUser());
|
|
|
|
|
- if (user1.isSuccess() && user1.getData() != null){
|
|
|
|
|
- item.setCreateUserName(user1.getData().getName());
|
|
|
|
|
|
|
+ //修改制单人名字
|
|
|
|
|
+ if(item.getUpdateUser()!=null)
|
|
|
|
|
+ {
|
|
|
|
|
+ if (ObjectUtil.isNotEmpty(updateUserList)) {
|
|
|
|
|
+ item.setUpdateUserName(updateUserList.stream().filter(e -> e.getId().equals(item.getUpdateUser())).findFirst().get().getRealName());
|
|
|
|
|
+ }
|
|
|
}
|
|
}
|
|
|
- //仓库信息
|
|
|
|
|
if (item.getStorageId() != null){
|
|
if (item.getStorageId() != null){
|
|
|
- StorageDesc storageDesc = iStorageClient.findById(item.getStorageId());
|
|
|
|
|
- if(storageDesc!=null)
|
|
|
|
|
- {
|
|
|
|
|
- item.setStorageName(storageDesc.getCname());
|
|
|
|
|
|
|
+ if (ObjectUtil.isNotEmpty(storageList)){
|
|
|
|
|
+ item.setStorageName((storageList.stream().filter(e -> e.getId().equals(item.getStorageId()))).findFirst().get().getCname());
|
|
|
}
|
|
}
|
|
|
}
|
|
}
|
|
|
//调拨仓库信息
|
|
//调拨仓库信息
|
|
|
if (item.getAllotStorageId() != null){
|
|
if (item.getAllotStorageId() != null){
|
|
|
- StorageDesc allotStorageId = iStorageClient.findById(item.getAllotStorageId());
|
|
|
|
|
- if(allotStorageId!=null)
|
|
|
|
|
- {
|
|
|
|
|
- item.setAllotStorageName(allotStorageId.getCname());
|
|
|
|
|
|
|
+ if (ObjectUtil.isNotEmpty(allotStorageList)){
|
|
|
|
|
+ item.setAllotStorageName((allotStorageList.stream().filter(e -> e.getId().equals(item.getAllotStorageId()))).findFirst().get().getCname());
|
|
|
}
|
|
}
|
|
|
}
|
|
}
|
|
|
if (item.getTradeType().equals(OrderTypeEnum.DEALER.getType())){
|
|
if (item.getTradeType().equals(OrderTypeEnum.DEALER.getType())){
|