|
|
@@ -1,6 +1,5 @@
|
|
|
package com.kxs.store.biz.service.impl;
|
|
|
|
|
|
-import cn.hutool.core.bean.BeanUtil;
|
|
|
import cn.hutool.core.util.StrUtil;
|
|
|
import com.baomidou.mybatisplus.core.metadata.IPage;
|
|
|
import com.baomidou.mybatisplus.core.toolkit.Wrappers;
|
|
|
@@ -12,23 +11,20 @@ import com.kxs.common.core.exception.GlobalCustomerException;
|
|
|
import com.kxs.common.core.util.R;
|
|
|
import com.kxs.common.core.util.RetOps;
|
|
|
import com.kxs.common.security.util.SecurityUtils;
|
|
|
+import com.kxs.product.api.feign.RemoteKxsProductService;
|
|
|
import com.kxs.store.api.dto.kxsapp.store.StoreSearchListDTO;
|
|
|
import com.kxs.store.api.model.*;
|
|
|
-import com.kxs.store.api.vo.kxsapp.store.StoreBrandListVO;
|
|
|
import com.kxs.store.api.vo.kxsapp.store.StoreDataVO;
|
|
|
import com.kxs.store.api.vo.kxsapp.store.StoreListVO;
|
|
|
import com.kxs.store.api.vo.kxsapp.store.StoreSearchListVO;
|
|
|
-import com.kxs.store.biz.constant.enums.MachineOrderEnum;
|
|
|
import com.kxs.store.biz.constant.enums.MachineOrderStatusEnum;
|
|
|
import com.kxs.store.biz.mapper.*;
|
|
|
import com.kxs.store.biz.service.KxsWarehouseService;
|
|
|
import com.kxs.user.api.feign.RemoteKxsUserService;
|
|
|
import com.kxs.user.api.model.KxsUser;
|
|
|
import lombok.RequiredArgsConstructor;
|
|
|
-import org.checkerframework.checker.units.qual.K;
|
|
|
import org.springframework.stereotype.Service;
|
|
|
|
|
|
-import java.util.ArrayList;
|
|
|
import java.util.List;
|
|
|
|
|
|
/**
|
|
|
@@ -51,6 +47,7 @@ public class KxsWarehouseServiceImpl extends ServiceImpl<KxsWarehouseMapper, Kxs
|
|
|
private final KxsWarehouseMapper kxsWarehouseMapper;
|
|
|
|
|
|
private final RemoteKxsUserService remoteKxsUserService;
|
|
|
+ private final RemoteKxsProductService remoteKxsProductService;
|
|
|
|
|
|
@Override
|
|
|
public IPage<StoreSearchListVO> searchList(Page<StoreSearchListVO> page, StoreSearchListDTO param) {
|
|
|
@@ -68,15 +65,26 @@ public class KxsWarehouseServiceImpl extends ServiceImpl<KxsWarehouseMapper, Kxs
|
|
|
}
|
|
|
|
|
|
@Override
|
|
|
- public List<StoreListVO> userStoreList() {
|
|
|
+ public List<StoreListVO> userStoreList(Integer reqType) {
|
|
|
Long userId = SecurityUtils.getUser().getId();
|
|
|
List<StoreListVO> storeListVOS = baseMapper.userStoreList(userId);
|
|
|
for (StoreListVO storeListVO : storeListVOS) {
|
|
|
- //待发货
|
|
|
- Long unSendCount = kxsMachineApplyMapper.selectCount(Wrappers.<KxsMachineApply>lambdaQuery()
|
|
|
- .eq(KxsMachineApply::getStatus, MachineOrderStatusEnum.UNDER_REVIEW.getType())
|
|
|
- .eq(KxsMachineApply::getWarehouseId, storeListVO.getId()));
|
|
|
- storeListVO.setUnfilledTotal(unSendCount.intValue());
|
|
|
+ if(reqType == 0){
|
|
|
+ //待发货
|
|
|
+ Long unSendCount = kxsMachineApplyMapper.selectCount(Wrappers.<KxsMachineApply>lambdaQuery()
|
|
|
+ .eq(KxsMachineApply::getStatus, MachineOrderStatusEnum.UNDER_REVIEW.getType())
|
|
|
+ .eq(KxsMachineApply::getWarehouseId, storeListVO.getId()));
|
|
|
+ storeListVO.setUnfilledTotal(unSendCount.intValue());
|
|
|
+ }
|
|
|
+ if(reqType == 1){
|
|
|
+ //查询仓库库存
|
|
|
+ KxsWarehouseStock warehouseStock = kxsWarehouseStockMapper.selectOne(Wrappers.<KxsWarehouseStock>lambdaQuery()
|
|
|
+ .eq(KxsWarehouseStock::getWarehouseId, storeListVO.getId()));
|
|
|
+ storeListVO.setStockNum(warehouseStock.getStockNum());
|
|
|
+ //查询预发机数量
|
|
|
+ Long preMachineCount = kxsMachineAdvanceMapper.selectWarehouseUserCount(storeListVO.getId());
|
|
|
+ storeListVO.setPrePosNum(preMachineCount.intValue());
|
|
|
+ }
|
|
|
}
|
|
|
return storeListVOS;
|
|
|
}
|