Merge remote-tracking branch 'origin/master'

hx-purchase/src/main/java/com/fjhx/purchase/controller/purchase/PurchaseController.java

@@ -40,6 +40,14 @@ public class PurchaseController {
     }
 
     /**
+     * 采购分页 维多利亚
+     */
+    @PostMapping("/pageByWdly")
+    public Page<PurchaseVo> pageByWdly(@RequestBody PurchaseSelectDto dto) {
+        return purchaseService.getPageByWdly(dto);
+    }
+
+    /**
      * 采购明细
      */
     @PostMapping("/detail")

hx-purchase/src/main/java/com/fjhx/purchase/entity/purchase/vo/PurchaseVo.java

@@ -1,6 +1,5 @@
 package com.fjhx.purchase.entity.purchase.vo;
 
-import com.baomidou.mybatisplus.annotation.TableField;
 import com.fjhx.purchase.entity.purchase.po.Purchase;
 import lombok.Getter;
 import lombok.Setter;
@@ -8,7 +7,7 @@ import lombok.Setter;
 /**
  * 采购列表查询返回值实体
  *
- * @author 
+ * @author
  * @since 2023-04-06
  */
 @Getter
@@ -16,4 +15,9 @@ import lombok.Setter;
 public class PurchaseVo extends Purchase {
 
     private String supplyName;
+
+    /**
+     * 到货状态
+     */
+    private Integer arrivalStatus;
 }

hx-purchase/src/main/java/com/fjhx/purchase/entity/subscribe/vo/SubscribeDetailVo.java

@@ -4,13 +4,12 @@ import com.fjhx.purchase.entity.subscribe.po.SubscribeDetail;
 import lombok.Getter;
 import lombok.Setter;
 
-import java.math.BigDecimal;
 import java.util.Date;
 
 /**
  * 申购单列表查询返回值实体
  *
- * @author 
+ * @author
  * @since 2023-04-03
  */
 @Getter
@@ -47,7 +46,9 @@ public class SubscribeDetailVo extends SubscribeDetail {
      */
     private String purchaseCount;
 
-    /**维多利亚扩展json*/
+    /**
+     * 维多利亚扩展json
+     */
     private String victoriatouristJson;
 
     /**
@@ -59,4 +60,9 @@ public class SubscribeDetailVo extends SubscribeDetail {
      * 收货仓库ID
      */
     private Long putWarehouseId;
+
+    /**
+     * 产品类型定义
+     */
+    private Integer productDefinition;
 }

hx-purchase/src/main/java/com/fjhx/purchase/service/purchase/PurchaseService.java

@@ -1,11 +1,11 @@
 package com.fjhx.purchase.service.purchase;
 
-import com.fjhx.purchase.entity.purchase.po.Purchase;
-import com.ruoyi.common.core.service.BaseService;
 import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
-import com.fjhx.purchase.entity.purchase.vo.PurchaseVo;
-import com.fjhx.purchase.entity.purchase.dto.PurchaseSelectDto;
 import com.fjhx.purchase.entity.purchase.dto.PurchaseDto;
+import com.fjhx.purchase.entity.purchase.dto.PurchaseSelectDto;
+import com.fjhx.purchase.entity.purchase.po.Purchase;
+import com.fjhx.purchase.entity.purchase.vo.PurchaseVo;
+import com.ruoyi.common.core.service.BaseService;
 
 import java.util.List;
 
@@ -15,7 +15,7 @@ import java.util.List;
  * 采购 服务类
  * </p>
  *
- * @author 
+ * @author
  * @since 2023-04-06
  */
 public interface PurchaseService extends BaseService<Purchase> {
@@ -26,6 +26,11 @@ public interface PurchaseService extends BaseService<Purchase> {
     Page<PurchaseVo> getPage(PurchaseSelectDto dto);
 
     /**
+     * 采购分页 维多利亚
+     */
+    Page<PurchaseVo> getPageByWdly(PurchaseSelectDto dto);
+
+    /**
      * 采购明细
      */
     PurchaseVo detail(Long id);
@@ -47,6 +52,7 @@ public interface PurchaseService extends BaseService<Purchase> {
 
     /**
      * 根据供应商查询采购合同
+     *
      * @param supplyId
      * @return
      */

hx-purchase/src/main/java/com/fjhx/purchase/service/purchase/impl/PurchaseServiceImpl.java

@@ -15,6 +15,7 @@ import com.fjhx.common.service.documentary.GetDocumentaryBusinessTemplate;
 import com.fjhx.customer.service.customer.CustomerService;
 import com.fjhx.item.entity.product.vo.ProductInfoVo;
 import com.fjhx.item.service.product.ProductInfoService;
+import com.fjhx.purchase.entity.arrival.po.Arrival;
 import com.fjhx.purchase.entity.invoice.vo.InvoiceDetailsVo;
 import com.fjhx.purchase.entity.pay.vo.PayDetailVo;
 import com.fjhx.purchase.entity.purchase.bo.PurchaseDocumentaryBo;
@@ -27,6 +28,7 @@ import com.fjhx.purchase.entity.purchase.vo.PurchaseDocumentaryVo;
 import com.fjhx.purchase.entity.purchase.vo.PurchaseVo;
 import com.fjhx.purchase.mapper.purchase.PurchaseMapper;
 import com.fjhx.purchase.service.arrival.ArrivalDetailService;
+import com.fjhx.purchase.service.arrival.ArrivalService;
 import com.fjhx.purchase.service.invoice.InvoiceDetailsService;
 import com.fjhx.purchase.service.pay.PayDetailService;
 import com.fjhx.purchase.service.purchase.PurchaseDetailService;
@@ -34,6 +36,8 @@ import com.fjhx.purchase.service.purchase.PurchaseService;
 import com.fjhx.purchase.util.code.CodeEnum;
 import com.fjhx.supply.entity.supplier.po.SupplierInfo;
 import com.fjhx.supply.service.supplier.SupplierInfoService;
+import com.fjhx.wms.entity.warehouse.po.Warehouse;
+import com.fjhx.wms.service.warehouse.WarehouseService;
 import com.obs.services.internal.ServiceException;
 import com.ruoyi.common.core.domain.BaseSelectDto;
 import com.ruoyi.common.utils.PageUtils;
@@ -44,6 +48,7 @@ import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.stereotype.Service;
 
 import java.math.BigDecimal;
+import java.util.ArrayList;
 import java.util.List;
 import java.util.Map;
 import java.util.stream.Collectors;
@@ -82,6 +87,10 @@ public class PurchaseServiceImpl extends ServiceImpl<PurchaseMapper, Purchase>
 
     @Autowired
     private CustomerService customerService;
+    @Autowired
+    WarehouseService warehouseService;
+    @Autowired
+    ArrivalService arrivalService;
 
     /**
      * 列表
@@ -93,25 +102,80 @@ public class PurchaseServiceImpl extends ServiceImpl<PurchaseMapper, Purchase>
     public Page<PurchaseVo> getPage(PurchaseSelectDto dto) {
         IWrapper<Purchase> wrapper = getWrapper();
         wrapper.orderByDesc("p", Purchase::getCreateTime);
-        if(ObjectUtils.isNotEmpty(dto.getPurchaseStatus())){
-            wrapper.eq("p",Purchase::getPurchaseStatus,dto.getPurchaseStatus());
+        if (ObjectUtils.isNotEmpty(dto.getPurchaseStatus())) {
+            wrapper.eq("p", Purchase::getPurchaseStatus, dto.getPurchaseStatus());
         }
-        if(ObjectUtils.isNotEmpty(dto.getArrivalStatus())){
-            wrapper.eq("p",Purchase::getArrivalStatus,dto.getArrivalStatus());
+        if (ObjectUtils.isNotEmpty(dto.getArrivalStatus())) {
+            wrapper.eq("p", Purchase::getArrivalStatus, dto.getArrivalStatus());
         }
-        if(ObjectUtils.isNotEmpty(dto.getPayStatus())){
-            wrapper.eq("p",Purchase::getPayStatus,dto.getPayStatus());
+        if (ObjectUtils.isNotEmpty(dto.getPayStatus())) {
+            wrapper.eq("p", Purchase::getPayStatus, dto.getPayStatus());
         }
+        wrapper.eq("p", Purchase::getCode, dto.getKeyword());//根据采购单号关键字搜索
         Page<PurchaseVo> page = this.baseMapper.getPage(dto.getPage(), wrapper);
         List<PurchaseVo> list = page.getRecords();
-        if(CollectionUtils.isNotEmpty(list)){
+        if (CollectionUtils.isNotEmpty(list)) {
             List<Long> supplyIds = list.stream().map(PurchaseVo::getSupplyId).collect(Collectors.toList());
-            List<SupplierInfo> supplierInfoList = supplierInfoService.list(Wrappers.<SupplierInfo>query().lambda().in(SupplierInfo::getId,supplyIds));
-            Map<Long,List<SupplierInfo>> supplyMap = supplierInfoList.stream().distinct().collect(Collectors.groupingBy(SupplierInfo::getId));
-            if(MapUtils.isNotEmpty(supplyMap)){
-                for(PurchaseVo p:list){
-                    List<SupplierInfo> supplys = supplyMap.getOrDefault(p.getSupplyId(),null);
-                    p.setSupplyName(supplys==null?null:supplys.get(0).getName());
+            List<SupplierInfo> supplierInfoList = supplierInfoService.list(Wrappers.<SupplierInfo>query().lambda().in(SupplierInfo::getId, supplyIds));
+            Map<Long, List<SupplierInfo>> supplyMap = supplierInfoList.stream().distinct().collect(Collectors.groupingBy(SupplierInfo::getId));
+            if (MapUtils.isNotEmpty(supplyMap)) {
+                for (PurchaseVo p : list) {
+                    List<SupplierInfo> supplys = supplyMap.getOrDefault(p.getSupplyId(), null);
+                    p.setSupplyName(supplys == null ? null : supplys.get(0).getName());
+                }
+            }
+        }
+        return page;
+    }
+
+    @Override
+    public Page<PurchaseVo> getPageByWdly(PurchaseSelectDto dto) {
+        Page<PurchaseVo> page = getPage(dto);
+        List<PurchaseVo> list = page.getRecords();
+        if (CollectionUtils.isNotEmpty(list)) {
+            //维多利亚 赋值收货仓库名称
+            List<Long> wids = new ArrayList<>();
+            for (PurchaseVo purchaseVo : list) {
+                String victoriatouristJson = purchaseVo.getVictoriatouristJson();
+                if (ObjectUtils.isNotEmpty(victoriatouristJson)) {
+                    JSONObject json = JSONObject.parseObject(victoriatouristJson);
+                    wids.add(json.getLong("receiptWarehouseId"));
+                }
+            }
+            if (ObjectUtils.isEmpty(wids)) {
+                return page;
+            }
+            List<Warehouse> warehouses = warehouseService.listByIds(wids);
+            Map<Long, String> warehousesMap = warehouses.stream().collect(Collectors.toMap(Warehouse::getId, Warehouse::getName));
+            for (PurchaseVo purchaseVo : list) {
+                String victoriatouristJson = purchaseVo.getVictoriatouristJson();
+                if (ObjectUtils.isNotEmpty(victoriatouristJson)) {
+                    JSONObject json = JSONObject.parseObject(victoriatouristJson);
+                    String warehouseName = warehousesMap.get(json.getLong("receiptWarehouseId"));
+                    json.put("receiptWarehouseName", warehouseName);
+                    purchaseVo.setVictoriatouristJson(json.toJSONString());
+                }
+            }
+            //赋值到货状态
+            List<Long> pids = list.stream().map(PurchaseVo::getId).collect(Collectors.toList());
+            List<Arrival> arrivalList = arrivalService.list(q -> q.in(Arrival::getPurchaseId, pids));
+            Map<Long, List<Arrival>> arrivalMap = arrivalList.stream().collect(Collectors.groupingBy(Arrival::getPurchaseId));
+            for (PurchaseVo purchaseVo : list) {
+                List<Arrival> list1 = arrivalMap.get(purchaseVo.getId());
+                if(ObjectUtils.isEmpty(list1)){
+                    purchaseVo.setArrivalStatus(0);
+                    continue;
+                }
+                List<Arrival> arrivalCount = list1.stream().filter(q -> q.equals(1)).collect(Collectors.toList());
+                if(arrivalCount.size()==0){
+                    //未到货
+                    purchaseVo.setArrivalStatus(0);
+                }else if(arrivalCount.size()<=list1.size()){
+                    //部分到货
+                    purchaseVo.setArrivalStatus(1);
+                }else{
+                    //完全到货
+                    purchaseVo.setArrivalStatus(2);
                 }
             }
         }
@@ -120,13 +184,14 @@ public class PurchaseServiceImpl extends ServiceImpl<PurchaseMapper, Purchase>
 
     /**
      * 详情
+     *
      * @param id
      * @return
      */
     @Override
     public PurchaseVo detail(Long id) {
         Purchase purchase = this.getById(id);
-        if(ObjectUtils.isEmpty(purchase)){
+        if (ObjectUtils.isEmpty(purchase)) {
             throw new ServiceException("采购单不存在");
         }
         //查询出供应商名称
@@ -135,18 +200,18 @@ public class PurchaseServiceImpl extends ServiceImpl<PurchaseMapper, Purchase>
         result.setSupplyName(info.getName());
         //查询出采购明细列表
         List<PurchaseDetail> purchaseDetailList = purchaseDetailService.
-                list(Wrappers.<PurchaseDetail>query().lambda().eq(PurchaseDetail::getPurchaseId,id));
+                list(Wrappers.<PurchaseDetail>query().lambda().eq(PurchaseDetail::getPurchaseId, id));
         //查询出产品
-        if(CollectionUtils.isNotEmpty(purchaseDetailList)){
+        if (CollectionUtils.isNotEmpty(purchaseDetailList)) {
             List<Long> productIds = purchaseDetailList.stream().map(PurchaseDetail::getBussinessId).collect(Collectors.toList());
             List<ProductInfoVo> productInfos = productInfoService.getListByProductIds(productIds);
-            Map<Long,List<ProductInfoVo>> productMap = productInfos.stream().distinct().collect(Collectors.groupingBy(ProductInfoVo::getId));
-            if(MapUtils.isNotEmpty(productMap)){
-                for(PurchaseDetail p:purchaseDetailList){
+            Map<Long, List<ProductInfoVo>> productMap = productInfos.stream().distinct().collect(Collectors.groupingBy(ProductInfoVo::getId));
+            if (MapUtils.isNotEmpty(productMap)) {
+                for (PurchaseDetail p : purchaseDetailList) {
                     //查询出到货总量
-                    BigDecimal sumArrivalCount = arrivalDetailService.getSumCount(p.getId(),p.getBussinessId());
+                    BigDecimal sumArrivalCount = arrivalDetailService.getSumCount(p.getId(), p.getBussinessId());
                     p.setSumArrivalCount(sumArrivalCount);
-                    List<ProductInfoVo> productInfoVos = productMap.getOrDefault(p.getBussinessId(),null);
+                    List<ProductInfoVo> productInfoVos = productMap.getOrDefault(p.getBussinessId(), null);
                     ProductInfoVo vo = productInfoVos.get(0);
                     p.setProductCode(vo.getCode());
                     p.setProductName(vo.getName());
@@ -163,6 +228,7 @@ public class PurchaseServiceImpl extends ServiceImpl<PurchaseMapper, Purchase>
 
     /**
      * 采购新增
+     *
      * @param purchase
      */
     @Override
@@ -172,8 +238,8 @@ public class PurchaseServiceImpl extends ServiceImpl<PurchaseMapper, Purchase>
         purchase.setCode(CodeEnum.PURCHASE.getCode());
         purchase.setPurchaseStatus(PurchaseStatusEnum.UNDER_REVIEW.getKey());
         purchaseService.save(purchase);
-        if(CollectionUtils.isNotEmpty(purchase.getPurchaseDetailList())){
-            for(PurchaseDetail s : purchase.getPurchaseDetailList()){
+        if (CollectionUtils.isNotEmpty(purchase.getPurchaseDetailList())) {
+            for (PurchaseDetail s : purchase.getPurchaseDetailList()) {
                 s.setPurchaseId(purchase.getId());
             }
             purchaseDetailService.saveBatch(purchase.getPurchaseDetailList());
@@ -192,6 +258,7 @@ public class PurchaseServiceImpl extends ServiceImpl<PurchaseMapper, Purchase>
 
     /**
      * 根据供应商查询采购合同
+     *
      * @param supplyId
      * @return
      */

hx-purchase/src/main/java/com/fjhx/purchase/service/subscribe/impl/SubscribeDetailServiceImpl.java

@@ -21,7 +21,6 @@ import com.fjhx.wms.service.warehouse.WarehouseService;
 import com.obs.services.internal.ServiceException;
 import com.ruoyi.common.utils.StringUtils;
 import com.ruoyi.common.utils.wrapper.IWrapper;
-import com.ruoyi.common.utils.wrapper.SqlField;
 import org.apache.commons.collections4.MapUtils;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.stereotype.Service;
@@ -80,8 +79,8 @@ public class SubscribeDetailServiceImpl extends ServiceImpl<SubscribeDetailMappe
         if (CollectionUtils.isNotEmpty(productIds)) {
             wrapper.in("t1", SubscribeDetail::getBussinessId, productIds);
         }
-        if(StringUtils.isNotEmpty(dto.getKeyword())){
-            wrapper.like("t2", Subscribe::getCode,dto.getKeyword());
+        if (StringUtils.isNotEmpty(dto.getKeyword())) {
+            wrapper.like("t2", Subscribe::getCode, dto.getKeyword());
         }
         wrapper.orderByDesc("t1", SubscribeDetail::getCreateTime);
         Page<SubscribeDetailVo> page = this.baseMapper.getPage(dto.getPage(), wrapper);
@@ -96,6 +95,7 @@ public class SubscribeDetailServiceImpl extends ServiceImpl<SubscribeDetailMappe
                     s.setProductType(vo.getType());
                     s.setProductCategory(vo.getClassifyName());
                     s.setProductUnit(vo.getUnit());
+                    s.setProductDefinition(vo.getDefinition());
                 }
             }
         }

hx-sale/src/main/java/com/fjhx/sale/flow/PurchaseFlowByWdly.java

@@ -1,17 +1,23 @@
 package com.fjhx.sale.flow;
 
 import com.alibaba.fastjson.JSONObject;
+import com.baomidou.dynamic.datasource.toolkit.DynamicDataSourceContextHolder;
 import com.baomidou.mybatisplus.core.toolkit.CollectionUtils;
 import com.baomidou.mybatisplus.core.toolkit.ObjectUtils;
 import com.baomidou.mybatisplus.core.toolkit.Wrappers;
+import com.fjhx.common.constant.SourceConstant;
 import com.fjhx.flow.core.FlowDelegate;
 import com.fjhx.purchase.entity.purchase.enums.PurchaseDataResourceEnum;
 import com.fjhx.purchase.entity.purchase.enums.PurchaseDetailStatusEnum;
 import com.fjhx.purchase.entity.purchase.enums.PurchaseStatusEnum;
 import com.fjhx.purchase.entity.purchase.po.Purchase;
 import com.fjhx.purchase.entity.purchase.po.PurchaseDetail;
+import com.fjhx.purchase.entity.subscribe.po.Subscribe;
+import com.fjhx.purchase.entity.subscribe.po.SubscribeDetail;
 import com.fjhx.purchase.service.purchase.PurchaseDetailService;
 import com.fjhx.purchase.service.purchase.PurchaseService;
+import com.fjhx.purchase.service.subscribe.SubscribeDetailService;
+import com.fjhx.purchase.service.subscribe.SubscribeService;
 import com.fjhx.purchase.util.code.CodeEnum;
 import com.fjhx.sale.entity.contract.po.ContractProduct;
 import com.fjhx.sale.service.contract.ContractProductService;
@@ -36,6 +42,16 @@ public class PurchaseFlowByWdly extends FlowDelegate {
     @Autowired
     private PurchaseFlow purchaseFlow;
 
+    @Autowired
+    private PurchaseService purchaseService;
+
+    @Autowired
+    private PurchaseDetailService purchaseDetailService;
+    @Autowired
+    private SubscribeService subscribeService;
+    @Autowired
+    private SubscribeDetailService subscribeDetailService;
+
     @Override
     public String getFlowKey() {
         return "wdly_purchase";
@@ -49,7 +65,44 @@ public class PurchaseFlowByWdly extends FlowDelegate {
      */
     @Override
     public Long start(Long flowId, JSONObject submitData) {
-        return purchaseFlow.start(flowId,submitData);
+        DynamicDataSourceContextHolder.push(SourceConstant.PURCHASE);
+        Purchase purchase = submitData.toJavaObject(Purchase.class);
+        purchase.setCode(CodeEnum.PURCHASE.getCode());
+        purchase.setPurchaseStatus(PurchaseStatusEnum.UNDER_REVIEW.getKey());
+        purchaseService.save(purchase);
+        List<PurchaseDetail> purchaseDetailList = purchase.getPurchaseDetailList();
+        if(CollectionUtils.isNotEmpty(purchaseDetailList)){
+            for(PurchaseDetail s : purchaseDetailList){
+                s.setPurchaseId(purchase.getId());
+            }
+            purchaseDetailService.saveBatch(purchaseDetailList);
+        }
+        //根据申购明细id去申购单获取仓库id 名称
+        if(ObjectUtils.isEmpty(purchaseDetailList)){
+            return purchase.getId();
+        }
+        PurchaseDetail purchaseDetail = purchaseDetailList.get(0);
+        SubscribeDetail subscribeDetail = subscribeDetailService.getById(purchaseDetail.getSubscribeDetailId());
+        if(ObjectUtils.isEmpty(subscribeDetail)){
+            return purchase.getId();
+        }
+        Subscribe subscribe = subscribeService.getById(subscribeDetail.getSubscribeId());
+        if(ObjectUtils.isEmpty(subscribe)){
+            return purchase.getId();
+        }
+        String victoriatouristJson = subscribe.getVictoriatouristJson();
+        if(ObjectUtils.isNotEmpty(victoriatouristJson)) {
+            JSONObject json = JSONObject.parseObject(victoriatouristJson);
+            Long receiptWarehouseId = json.getLong("receiptWarehouseId");
+
+            String victoriatouristJson1 = purchase.getVictoriatouristJson();
+            JSONObject json1 = JSONObject.parseObject(victoriatouristJson1);
+            json1.put("receiptWarehouseId",receiptWarehouseId);
+            purchase.setVictoriatouristJson(json1.toJSONString());
+            purchaseService.save(purchase);
+        }
+        DynamicDataSourceContextHolder.poll();
+        return purchase.getId();
     }
 
     /**

hx-victoriatourist/src/main/java/com/fjhx/victoriatourist/controller/stock/StockTransferController.java

@@ -1,5 +1,6 @@
 package com.fjhx.victoriatourist.controller.stock;
 
+import com.fjhx.wms.entity.stock.dto.StockDto;
 import org.springframework.web.bind.annotation.*;
 import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
 import com.fjhx.victoriatourist.entity.stock.vo.StockTransferVo;
@@ -70,4 +71,12 @@ public class StockTransferController {
         stockTransferService.receive(stockTransferDto);
     }
 
+    /**
+     * 调仓 重构用不是维多利亚的
+     */
+    @PostMapping("/addSt")
+    public void stockTransfer(@RequestBody StockTransferDto stockTransferDto) {
+        stockTransferService.stockTransfer(stockTransferDto);
+    }
+
 }

hx-victoriatourist/src/main/java/com/fjhx/victoriatourist/entity/stock/vo/StockTransferDetailsVo.java

@@ -4,6 +4,8 @@ import com.fjhx.victoriatourist.entity.stock.po.StockTransferDetails;
 import lombok.Getter;
 import lombok.Setter;
 
+import java.math.BigDecimal;
+
 /**
  * 调仓明细列表查询返回值实体
  *
@@ -27,4 +29,36 @@ public class StockTransferDetailsVo extends StockTransferDetails {
      */
     private String productSpec;
 
+    /**
+     * 产品单位
+     */
+    private String productUnit;
+
+    /**出入库编号*/
+    private String code;
+
+    /**
+     * 调出仓库名称
+     */
+    private String outWarehouseName;
+
+    /**
+     * 调入仓库名称
+     */
+    private String inWarehouseName;
+
+    /**
+     * 调入仓库id
+     */
+    private Long inWarehouseId;
+
+    /**
+     * 调出仓库id
+     */
+    private Long outWarehouseId;
+
+    /**调仓数量*/
+    private BigDecimal quantity;
+
+
 }

hx-victoriatourist/src/main/java/com/fjhx/victoriatourist/service/stock/StockTransferService.java

@@ -1,10 +1,12 @@
 package com.fjhx.victoriatourist.service.stock;
 
+import com.baomidou.dynamic.datasource.annotation.DSTransactional;
 import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
 import com.fjhx.victoriatourist.entity.stock.dto.StockTransferDto;
 import com.fjhx.victoriatourist.entity.stock.dto.StockTransferSelectDto;
 import com.fjhx.victoriatourist.entity.stock.po.StockTransfer;
 import com.fjhx.victoriatourist.entity.stock.vo.StockTransferVo;
+import com.fjhx.wms.entity.stock.dto.StockDto;
 import com.ruoyi.common.core.service.BaseService;
 
 
@@ -48,4 +50,5 @@ public interface StockTransferService extends BaseService<StockTransfer> {
      */
     void receive(StockTransferDto stockTransferDto);
 
+    void stockTransfer(StockTransferDto stockTransferDto);
 }

hx-victoriatourist/src/main/java/com/fjhx/victoriatourist/service/stock/impl/StockTransferDetailsServiceImpl.java

@@ -1,16 +1,20 @@
 package com.fjhx.victoriatourist.service.stock.impl;
 
+import cn.hutool.core.bean.BeanUtil;
+import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
+import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
+import com.fjhx.item.service.product.ProductInfoService;
+import com.fjhx.victoriatourist.entity.stock.dto.StockTransferDetailsDto;
+import com.fjhx.victoriatourist.entity.stock.dto.StockTransferDetailsSelectDto;
 import com.fjhx.victoriatourist.entity.stock.po.StockTransferDetails;
+import com.fjhx.victoriatourist.entity.stock.vo.StockTransferDetailsVo;
 import com.fjhx.victoriatourist.mapper.stock.StockTransferDetailsMapper;
 import com.fjhx.victoriatourist.service.stock.StockTransferDetailsService;
-import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
-import org.springframework.stereotype.Service;
-import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
-import com.fjhx.victoriatourist.entity.stock.vo.StockTransferDetailsVo;
-import com.fjhx.victoriatourist.entity.stock.dto.StockTransferDetailsSelectDto;
+import com.fjhx.wms.entity.stock.vo.StockVo;
+import com.fjhx.wms.service.warehouse.WarehouseService;
 import com.ruoyi.common.utils.wrapper.IWrapper;
-import com.fjhx.victoriatourist.entity.stock.dto.StockTransferDetailsDto;
-import cn.hutool.core.bean.BeanUtil;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.stereotype.Service;
 
 
 /**
@@ -18,17 +22,35 @@ import cn.hutool.core.bean.BeanUtil;
  * 调仓明细 服务实现类
  * </p>
  *
- * @author 
+ * @author
  * @since 2023-04-17
  */
 @Service
 public class StockTransferDetailsServiceImpl extends ServiceImpl<StockTransferDetailsMapper, StockTransferDetails> implements StockTransferDetailsService {
+    @Autowired
+    ProductInfoService productInfoService;
+    @Autowired
+    WarehouseService warehouseService;
 
     @Override
     public Page<StockTransferDetailsVo> getPage(StockTransferDetailsSelectDto dto) {
         IWrapper<StockTransferDetails> wrapper = getWrapper();
         wrapper.orderByDesc("std", StockTransferDetails::getId);
         Page<StockTransferDetailsVo> page = this.baseMapper.getPage(dto.getPage(), wrapper);
+        //赋值产品信息
+        productInfoService.attributeAssign(page.getRecords(), StockTransferDetailsVo::getProductId, (item, productInfo) -> {
+            item.setProductCode(productInfo.getCode());
+            item.setProductUnit(productInfo.getUnit());
+            item.setProductName(productInfo.getName());
+            item.setProductSpec(productInfo.getSpec());
+        });
+        //赋值仓库名称
+        warehouseService.attributeAssign(page.getRecords(), StockTransferDetailsVo::getInWarehouseId, (item, warehouse) -> {
+            item.setInWarehouseName(warehouse.getName());
+        });
+        warehouseService.attributeAssign(page.getRecords(), StockTransferDetailsVo::getOutWarehouseId, (item, warehouse) -> {
+            item.setOutWarehouseName(warehouse.getName());
+        });
         return page;
     }
 

hx-victoriatourist/src/main/java/com/fjhx/victoriatourist/service/stock/impl/StockTransferServiceImpl.java

@@ -3,11 +3,9 @@ package com.fjhx.victoriatourist.service.stock.impl;
 import cn.hutool.core.bean.BeanUtil;
 import cn.hutool.core.util.ObjectUtil;
 import com.baomidou.dynamic.datasource.annotation.DSTransactional;
-import com.baomidou.dynamic.datasource.toolkit.DynamicDataSourceContextHolder;
 import com.baomidou.mybatisplus.core.toolkit.IdWorker;
 import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
 import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
-import com.fjhx.common.constant.SourceConstant;
 import com.fjhx.item.service.product.ProductInfoService;
 import com.fjhx.victoriatourist.entity.abnormal.po.AbnormalInfo;
 import com.fjhx.victoriatourist.entity.stock.dto.StockTransferDto;
@@ -20,7 +18,9 @@ import com.fjhx.victoriatourist.mapper.stock.StockTransferMapper;
 import com.fjhx.victoriatourist.service.abnormal.AbnormalInfoService;
 import com.fjhx.victoriatourist.service.stock.StockTransferDetailsService;
 import com.fjhx.victoriatourist.service.stock.StockTransferService;
+import com.fjhx.victoriatourist.utils.Assert;
 import com.fjhx.victoriatourist.utils.CodeEnum;
+import com.fjhx.wms.entity.stock.dto.StockDto;
 import com.fjhx.wms.entity.stock.emums.JournalType;
 import com.fjhx.wms.entity.stock.po.Stock;
 import com.fjhx.wms.entity.stock.po.StockJournal;
@@ -110,6 +110,10 @@ public class StockTransferServiceImpl extends ServiceImpl<StockTransferMapper, S
     @Transactional(rollbackFor = Exception.class)
     @Override
     public void add(StockTransferDto stockTransferDto) {
+        Assert.notEmpty(stockTransferDto.getOutWarehouseId(),"出库仓库不能为空");
+        Assert.notEmpty(stockTransferDto.getInWarehouseId(),"入库仓库不能为空");
+        Assert.notEmpty(stockTransferDto.getStockTransferDetailsList(),"调仓明细不能为空");
+
         stockTransferDto.setCode(CodeEnum.STOCK_TRANSFER.getCode());
         stockTransferDto.setType(1);
         stockTransferDto.setInStatus(0);
@@ -203,4 +207,59 @@ public class StockTransferServiceImpl extends ServiceImpl<StockTransferMapper, S
         }
     }
 
+    @Override
+    @DSTransactional
+    public void stockTransfer(StockTransferDto stockTransferDto) {
+        Assert.notEmpty(stockTransferDto.getOutWarehouseId(),"出库仓库不能为空");
+        Assert.notEmpty(stockTransferDto.getInWarehouseId(),"入库仓库不能为空");
+        Assert.notEmpty(stockTransferDto.getStockTransferDetailsList(),"调仓明细不能为空");
+
+        stockTransferDto.setCode(CodeEnum.STOCK_TRANSFER.getCode());
+        stockTransferDto.setType(1);
+        stockTransferDto.setInStatus(0);
+        this.save(stockTransferDto);
+        List<StockTransferDetails> stockTransferDetailsList = stockTransferDto.getStockTransferDetailsList();
+        for (StockTransferDetails stockTransferDetails : stockTransferDetailsList) {
+            stockTransferDetails.setStockTransferId(stockTransferDto.getId());
+        }
+        stockTransferDetailsService.saveBatch(stockTransferDetailsList);
+
+        List<Stock> stockList = new ArrayList<>();
+        for (StockTransferDetails stockTransferDetails : stockTransferDetailsList) {
+            Stock stock = new Stock();
+            stock.setProductId(stockTransferDetails.getProductId());
+            stock.setQuantity(stockTransferDetails.getOutQuantity());
+            stockList.add(stock);
+        }
+
+        //创建出库记录
+        StockJournal stockJournal = new StockJournal();
+        stockJournal.setCode(CodeEnum.STOCK_TRANSFER.getCode());
+        stockJournal.setOpType(2);//出库
+        stockJournal.setType(JournalType.ADJUSTING_OUT.getDetailType());//调仓入库
+        stockJournal.setWarehouseId(stockTransferDto.getOutWarehouseId());
+//        stockJournal.setToWarehouseId(stockDto.getToWarehouseId());
+        //保存出入库记录
+        stockJournalService.save(stockJournal);
+        //操作库存
+        List<StockJournalDetails> stockJournalDetailsList = stockService.ModifyInventory(stockJournal.getId(), 2, stockList, stockTransferDto.getOutWarehouseId());
+        //保存出入库明细
+        stockJournalDetailsService.saveBatch(stockJournalDetailsList);
+
+        //创建入库记录
+        StockJournal stockJournal1 = new StockJournal();
+        stockJournal1.setCode(com.fjhx.wms.utils.CodeEnum.STOCK_TRANSFER.getCode());
+        stockJournal1.setOpType(1);//入库
+        stockJournal1.setType(JournalType.ADJUSTING_IN.getDetailType());//调仓出库
+        stockJournal1.setWarehouseId(stockTransferDto.getInWarehouseId());
+//        stockJournal1.setToWarehouseId(stockDto.getToWarehouseId());
+        //保存出入库记录
+        stockJournalService.save(stockJournal1);
+
+        //入库操作
+        List<StockJournalDetails> stockJournalDetailsList1 = stockService.ModifyInventory(stockJournal1.getId(), 1, stockList, stockTransferDto.getInWarehouseId());
+        //保存出入库明细
+        stockJournalDetailsService.saveBatch(stockJournalDetailsList1);
+    }
+
 }

hx-victoriatourist/src/main/resources/mapper/stock/StockTransferDetailsMapper.xml

@@ -2,7 +2,7 @@
 <!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" "http://mybatis.org/dtd/mybatis-3-mapper.dtd">
 <mapper namespace="com.fjhx.victoriatourist.mapper.stock.StockTransferDetailsMapper">
     <select id="getPage" resultType="com.fjhx.victoriatourist.entity.stock.vo.StockTransferDetailsVo">
-        select
+        SELECT
             std.id,
             std.stock_transfer_id,
             std.product_id,
@@ -11,8 +11,13 @@
             std.create_user,
             std.create_time,
             std.update_user,
-            std.update_time
-        from stock_transfer_details std
+            std.update_time,
+            st.`code`,
+            st.in_warehouse_id,
+            st.out_warehouse_id
+        FROM
+            stock_transfer st
+                LEFT JOIN stock_transfer_details std ON std.stock_transfer_id = st.id
             ${ew.customSqlSegment}
     </select>
 

hx-wms/src/main/java/com/fjhx/wms/controller/stock/StockController.java

@@ -78,14 +78,6 @@ public class StockController {
     }
 
     /**
-     * 调仓
-     */
-    @PostMapping("/stockTransfer")
-    public void stockTransfer(@RequestBody StockDto stockDto) {
-        stockService.stockTransfer(stockDto);
-    }
-
-    /**
      * 库存删除
      */
     @PostMapping("/delete")

hx-wms/src/main/java/com/fjhx/wms/service/stock/StockService.java

@@ -54,11 +54,6 @@ public interface StockService extends BaseService<Stock> {
     void edit(StockDto stockDto);
 
     /**
-     * 调仓
-     */
-    void stockTransfer(StockDto stockDto);
-
-    /**
      * 库存删除
      */
     void delete(Long id);

hx-wms/src/main/java/com/fjhx/wms/service/stock/impl/StockServiceImpl.java

@@ -219,39 +219,6 @@ public class StockServiceImpl extends ServiceImpl<StockMapper, Stock> implements
     }
 
     @Override
-    @DSTransactional
-    public void stockTransfer(StockDto stockDto) {
-        //创建出库记录
-        StockJournal stockJournal = new StockJournal();
-        stockJournal.setCode(CodeEnum.STOCK_TRANSFER.getCode());
-        stockJournal.setOpType(2);//出库
-        stockJournal.setType(JournalType.ADJUSTING_OUT.getDetailType());//调仓入库
-        stockJournal.setWarehouseId(stockDto.getWarehouseId());
-        stockJournal.setToWarehouseId(stockDto.getToWarehouseId());
-        //保存出入库记录
-        stockJournalService.save(stockJournal);
-        //操作库存
-        List<StockJournalDetails> stockJournalDetailsList = ModifyInventory(stockJournal.getId(), 2, stockDto.getList(), stockDto.getWarehouseId());
-        //保存出入库明细
-        stockJournalDetailsService.saveBatch(stockJournalDetailsList);
-
-        //创建入库记录
-        StockJournal stockJournal1 = new StockJournal();
-        stockJournal1.setCode(CodeEnum.STOCK_TRANSFER.getCode());
-        stockJournal1.setOpType(1);//入库
-        stockJournal1.setType(JournalType.ADJUSTING_IN.getDetailType());//调仓出库
-        stockJournal1.setWarehouseId(stockDto.getWarehouseId());
-        stockJournal1.setToWarehouseId(stockDto.getToWarehouseId());
-        //保存出入库记录
-        stockJournalService.save(stockJournal1);
-
-        //入库操作
-        List<StockJournalDetails> stockJournalDetailsList1 = ModifyInventory(stockJournal1.getId(), 1, stockDto.getList(), stockDto.getToWarehouseId());
-        //保存出入库明细
-        stockJournalDetailsService.saveBatch(stockJournalDetailsList1);
-    }
-
-    @Override
     public void delete(Long id) {
         this.removeById(id);
     }