feat(wms): 物料调拨单

dev
wanghao 1 week ago
parent 015b0fa0ff
commit c0b80cf2c5

@ -0,0 +1,116 @@
package org.dromara.wms.controller;
import java.util.List;
import lombok.RequiredArgsConstructor;
import jakarta.servlet.http.HttpServletResponse;
import jakarta.validation.constraints.*;
import cn.dev33.satoken.annotation.SaCheckPermission;
import org.springframework.web.bind.annotation.*;
import org.springframework.validation.annotation.Validated;
import org.dromara.common.idempotent.annotation.RepeatSubmit;
import org.dromara.common.log.annotation.Log;
import org.dromara.common.web.core.BaseController;
import org.dromara.common.mybatis.core.page.PageQuery;
import org.dromara.common.core.domain.R;
import org.dromara.common.core.validate.AddGroup;
import org.dromara.common.core.validate.EditGroup;
import org.dromara.common.log.enums.BusinessType;
import org.dromara.common.excel.utils.ExcelUtil;
import org.dromara.wms.domain.vo.WmsMaterialTransferBillsVo;
import org.dromara.wms.domain.bo.WmsMaterialTransferBillsBo;
import org.dromara.wms.service.IWmsMaterialTransferBillsService;
import org.dromara.common.mybatis.core.page.TableDataInfo;
/**
*
* 访:/wms/materialTransferBills
*
* @author Yinq
* @date 2025-12-08
*/
@Validated
@RequiredArgsConstructor
@RestController
@RequestMapping("/materialTransferBills")
public class WmsMaterialTransferBillsController extends BaseController {
private final IWmsMaterialTransferBillsService wmsMaterialTransferBillsService;
/**
*
*/
@SaCheckPermission("wms:materialTransferBills:list")
@GetMapping("/list")
public TableDataInfo<WmsMaterialTransferBillsVo> list(WmsMaterialTransferBillsBo bo, PageQuery pageQuery) {
return wmsMaterialTransferBillsService.queryPageList(bo, pageQuery);
}
/**
*
*/
@SaCheckPermission("wms:materialTransferBills:export")
@Log(title = "物料调拨单", businessType = BusinessType.EXPORT)
@PostMapping("/export")
public void export(WmsMaterialTransferBillsBo bo, HttpServletResponse response) {
List<WmsMaterialTransferBillsVo> list = wmsMaterialTransferBillsService.queryList(bo);
ExcelUtil.exportExcel(list, "物料调拨单", WmsMaterialTransferBillsVo.class, response);
}
/**
*
*
* @param transferBillsId
*/
@SaCheckPermission("wms:materialTransferBills:query")
@GetMapping("/{transferBillsId}")
public R<WmsMaterialTransferBillsVo> getInfo(@NotNull(message = "主键不能为空")
@PathVariable("transferBillsId") Long transferBillsId) {
return R.ok(wmsMaterialTransferBillsService.queryById(transferBillsId));
}
/**
*
*/
@SaCheckPermission("wms:materialTransferBills:add")
@Log(title = "物料调拨单", businessType = BusinessType.INSERT)
@RepeatSubmit()
@PostMapping()
public R<Void> add(@Validated(AddGroup.class) @RequestBody WmsMaterialTransferBillsBo bo) {
return toAjax(wmsMaterialTransferBillsService.insertByBo(bo));
}
/**
*
*/
@SaCheckPermission("wms:materialTransferBills:edit")
@Log(title = "物料调拨单", businessType = BusinessType.UPDATE)
@RepeatSubmit()
@PutMapping()
public R<Void> edit(@Validated(EditGroup.class) @RequestBody WmsMaterialTransferBillsBo bo) {
return toAjax(wmsMaterialTransferBillsService.updateByBo(bo));
}
/**
*
*
* @param transferBillsIds
*/
@SaCheckPermission("wms:materialTransferBills:remove")
@Log(title = "物料调拨单", businessType = BusinessType.DELETE)
@DeleteMapping("/{transferBillsIds}")
public R<Void> remove(@NotEmpty(message = "主键不能为空")
@PathVariable("transferBillsIds") Long[] transferBillsIds) {
return toAjax(wmsMaterialTransferBillsService.deleteWithValidByIds(List.of(transferBillsIds), true));
}
/**
*
*/
@GetMapping("/getWmsMaterialTransferBillsList")
public R<List<WmsMaterialTransferBillsVo>> getWmsMaterialTransferBillsList(WmsMaterialTransferBillsBo bo) {
List<WmsMaterialTransferBillsVo> list = wmsMaterialTransferBillsService.queryList(bo);
return R.ok(list);
}
}

@ -78,7 +78,7 @@ public class WmsMaterialTransferRecordController extends BaseController {
@RepeatSubmit()
@PostMapping()
public R<Void> add(@Validated(AddGroup.class) @RequestBody List<WmsMaterialTransferRecord> bo) {
return toAjax(wmsMaterialTransferRecordService.insertByBo(bo));
return toAjax(wmsMaterialTransferRecordService.insertByBo(null,bo));
}
/**

@ -0,0 +1,62 @@
package org.dromara.wms.domain;
import org.dromara.common.tenant.core.TenantEntity;
import com.baomidou.mybatisplus.annotation.*;
import lombok.Data;
import lombok.EqualsAndHashCode;
import java.io.Serial;
/**
* wms_material_transfer_bills
*
* @author Yinq
* @date 2025-12-08
*/
@Data
@EqualsAndHashCode(callSuper = true)
@TableName("wms_material_transfer_bills")
public class WmsMaterialTransferBills extends TenantEntity {
@Serial
private static final long serialVersionUID = 1L;
/**
* ID
*/
@TableId(value = "transfer_bills_id", type = IdType.AUTO)
private Long transferBillsId;
/**
*
*/
private String transferBillsCode;
/**
*
*/
private Long transferOutStoreId;
/**
*
*/
private Long transferInStoreId;
/**
*
*/
private String billsStatus;
/**
*
*/
private String remark;
/**
* 0 1
*/
@TableLogic
private String delFlag;
}

@ -85,5 +85,5 @@ public class WmsMaterialTransferRecord extends TenantEntity {
*
*/
private String productSpe;
private Long transferBillsId;
}

@ -0,0 +1,58 @@
package org.dromara.wms.domain.bo;
import org.dromara.wms.domain.WmsMaterialTransferBills;
import org.dromara.common.mybatis.core.domain.BaseEntity;
import org.dromara.common.core.validate.AddGroup;
import org.dromara.common.core.validate.EditGroup;
import io.github.linpeilie.annotations.AutoMapper;
import lombok.Data;
import lombok.EqualsAndHashCode;
import jakarta.validation.constraints.*;
import org.dromara.wms.domain.WmsMaterialTransferRecord;
import java.util.List;
/**
* wms_material_transfer_bills
*
* @author Yinq
* @date 2025-12-08
*/
@Data
@EqualsAndHashCode(callSuper = true)
@AutoMapper(target = WmsMaterialTransferBills.class, reverseConvertGenerate = false)
public class WmsMaterialTransferBillsBo extends BaseEntity {
/**
* ID
*/
@NotNull(message = "调拨记录ID不能为空", groups = { EditGroup.class })
private Long transferBillsId;
/**
*
*/
private String transferBillsCode;
/**
*
*/
private Long transferOutStoreId;
/**
*
*/
private Long transferInStoreId;
/**
*
*/
private String billsStatus;
/**
*
*/
private String remark;
List<WmsMaterialTransferRecord> list;
}

@ -72,6 +72,6 @@ public class WmsMaterialTransferRecordBo extends BaseEntity {
*
*/
private String productSpe;
private Long transferBillsId;
}

@ -0,0 +1,111 @@
package org.dromara.wms.domain.vo;
import org.dromara.wms.domain.WmsMaterialTransferBills;
import cn.idev.excel.annotation.ExcelIgnoreUnannotated;
import cn.idev.excel.annotation.ExcelProperty;
import org.dromara.common.excel.annotation.ExcelDictFormat;
import org.dromara.common.excel.convert.ExcelDictConvert;
import io.github.linpeilie.annotations.AutoMapper;
import lombok.Data;
import java.io.Serial;
import java.io.Serializable;
import java.util.Date;
/**
* wms_material_transfer_bills
*
* @author Yinq
* @date 2025-12-08
*/
@Data
@ExcelIgnoreUnannotated
@AutoMapper(target = WmsMaterialTransferBills.class)
public class WmsMaterialTransferBillsVo implements Serializable {
@Serial
private static final long serialVersionUID = 1L;
/**
* ID
*/
@ExcelProperty(value = "调拨记录ID")
private Long transferBillsId;
/**
*
*/
@ExcelProperty(value = "调拨单号")
private String transferBillsCode;
/**
*
*/
@ExcelProperty(value = "调出仓库")
private Long transferOutStoreId;
/**
*
*/
@ExcelProperty(value = "调入仓库")
private Long transferInStoreId;
/**
*
*/
@ExcelProperty(value = "状态")
private String billsStatus;
/**
*
*/
@ExcelProperty(value = "备注")
private String remark;
/**
*
*/
@ExcelProperty(value = "租户编号")
private String tenantId;
/**
* 0 1
*/
@ExcelProperty(value = "删除标志", converter = ExcelDictConvert.class)
@ExcelDictFormat(readConverterExp = "0=代表存在,1=代表删除")
private String delFlag;
/**
*
*/
@ExcelProperty(value = "创建部门")
private Long createDept;
/**
*
*/
@ExcelProperty(value = "创建人")
private Long createBy;
/**
*
*/
@ExcelProperty(value = "创建时间")
private Date createTime;
/**
*
*/
@ExcelProperty(value = "更新人")
private Long updateBy;
/**
*
*/
@ExcelProperty(value = "更新时间")
private Date updateTime;
}

@ -0,0 +1,37 @@
package org.dromara.wms.mapper;
import java.util.List;
import com.github.yulichang.wrapper.MPJLambdaWrapper;
import com.baomidou.mybatisplus.core.toolkit.Constants;
import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
import org.apache.ibatis.annotations.Param;
import org.dromara.wms.domain.WmsMaterialTransferBills;
import org.dromara.wms.domain.vo.WmsMaterialTransferBillsVo;
import org.dromara.common.mybatis.core.mapper.BaseMapperPlus;
/**
* Mapper
*
* @author Yinq
* @date 2025-12-08
*/
public interface WmsMaterialTransferBillsMapper extends BaseMapperPlus<WmsMaterialTransferBills, WmsMaterialTransferBillsVo> {
/**
*
*
* @param page
* @param queryWrapper
* @return
*/
public Page<WmsMaterialTransferBillsVo> selectCustomWmsMaterialTransferBillsVoList(@Param("page") Page<WmsMaterialTransferBillsVo> page, @Param(Constants.WRAPPER) MPJLambdaWrapper<WmsMaterialTransferBills> queryWrapper);
/**
*
*
* @param queryWrapper
* @return
*/
public List<WmsMaterialTransferBillsVo> selectCustomWmsMaterialTransferBillsVoList(@Param(Constants.WRAPPER) MPJLambdaWrapper<WmsMaterialTransferBills> queryWrapper);
}

@ -0,0 +1,69 @@
package org.dromara.wms.service;
import org.dromara.wms.domain.WmsMaterialTransferBills;
import org.dromara.wms.domain.vo.WmsMaterialTransferBillsVo;
import org.dromara.wms.domain.bo.WmsMaterialTransferBillsBo;
import org.dromara.common.mybatis.core.page.TableDataInfo;
import org.dromara.common.mybatis.core.page.PageQuery;
import java.util.Collection;
import java.util.List;
/**
* Service
*
* @author Yinq
* @date 2025-12-08
*/
public interface IWmsMaterialTransferBillsService {
/**
*
*
* @param transferBillsId
* @return
*/
WmsMaterialTransferBillsVo queryById(Long transferBillsId);
/**
*
*
* @param bo
* @param pageQuery
* @return
*/
TableDataInfo<WmsMaterialTransferBillsVo> queryPageList(WmsMaterialTransferBillsBo bo, PageQuery pageQuery);
/**
*
*
* @param bo
* @return
*/
List<WmsMaterialTransferBillsVo> queryList(WmsMaterialTransferBillsBo bo);
/**
*
*
* @param bo
* @return
*/
Boolean insertByBo(WmsMaterialTransferBillsBo bo);
/**
*
*
* @param bo
* @return
*/
Boolean updateByBo(WmsMaterialTransferBillsBo bo);
/**
*
*
* @param ids
* @param isValid
* @return
*/
Boolean deleteWithValidByIds(Collection<Long> ids, Boolean isValid);
}

@ -48,7 +48,7 @@ public interface IWmsMaterialTransferRecordService {
* @param bo
* @return
*/
Boolean insertByBo(List<WmsMaterialTransferRecord> bo);
Boolean insertByBo(Long transferBillsId,List<WmsMaterialTransferRecord> bo);
/**
*

@ -26,6 +26,7 @@ import org.dromara.wms.service.IWmsInventoryDetailsService;
import org.dromara.workflow.api.RemoteWorkflowService;
import org.dromara.workflow.api.domain.RemoteStartProcess;
import org.dromara.workflow.api.event.ProcessEvent;
import org.springframework.beans.factory.parsing.BeanEntry;
import org.springframework.context.event.EventListener;
import org.springframework.stereotype.Service;
@ -45,7 +46,6 @@ public class WmsInStockBillServiceImpl implements IWmsInStockBillService {
private final WmsInStockDetailsMapper wmsInStockDetailsMapper;
private final IWmsInventoryDetailsService inventoryService;
// private final IWmsWarehouseInfoService warehouseService;
private final WmsInventoryLedgerMapper wmsInventoryLedgerMapper;
@DubboReference
private RemoteCodeRuleService remoteCodeRuleService;
@DubboReference(timeout = 30000)//超时时间
@ -113,7 +113,6 @@ public class WmsInStockBillServiceImpl implements IWmsInStockBillService {
@Override
public Boolean insertByBo(WmsInStockBillBo bo) {
WmsInStockBill add = MapstructUtils.convert(bo, WmsInStockBill.class);
String inStockType = add.getInStockType();
add.setInStockCode(remoteCodeRuleService.selectCodeRuleCode("1005"));// 物料入库编码
add.setInStockBillStatus("3");
boolean flag = baseMapper.insert(add) > 0;//插入主表
@ -125,45 +124,17 @@ public class WmsInStockBillServiceImpl implements IWmsInStockBillService {
inStockDetailsList.forEach(item -> {
item.setInStockBillId(inStockBillId); // 设置入库单明细的入库单ID
item.setProjectId(projectId); // 关联项目
Double inStockAmount = item.getInStockAmount();
Double inventoryTableAmount = 0.0;// 库存表数量
// 构建库存明细
WmsInventoryDetailsBo inventory = new WmsInventoryDetailsBo();
inventory.setWarehouseId(item.getWarehouseId());
inventory.setProjectId(projectId);
inventory.setBatchNumber(item.getBatchNumber());
inventory.setMaterielId(item.getMaterialId());
inventory.setUnitPrice(item.getUnitPrice());
// 查询相同项目 相同仓库 相同批次 相同单价的物料
WmsInventoryDetails queryInventory = inventoryService.queryInventory(inventory);
if (queryInventory != null) {
WmsInventoryDetailsBo inventoryUpdate = new WmsInventoryDetailsBo();
inventoryUpdate.setInventoryDetailsId(queryInventory.getInventoryDetailsId());
inventoryTableAmount = queryInventory.getInventoryAmount() ;
inventoryUpdate.setInventoryAmount(inventoryTableAmount+ inStockAmount);
inventoryService.updateByBo(inventoryUpdate); // 更新库存数量
} else {
inventory.setUnitName(item.getUnitName());
inventory.setInventoryAmount(inStockAmount);
inventory.setStartInventoryAmount(inStockAmount); // 初始库存数量
inventoryService.insertByBo(inventory);
}
//库存变动
WmsInventoryLedger wmsInventoryLedger = new WmsInventoryLedger();
wmsInventoryLedger.setWarehouseId(item.getWarehouseId());
wmsInventoryLedger.setBatchNumber(item.getBatchNumber());
wmsInventoryLedger.setMaterielId(item.getMaterialId());
wmsInventoryLedger.setChangeType(inStockType);//变动类型
wmsInventoryLedger.setLedgerState("1");
wmsInventoryLedger.setChangeAmount(inStockAmount);
wmsInventoryLedger.setInventoryAmount(inventoryTableAmount);
wmsInventoryLedgers.add(wmsInventoryLedger);
inventoryService.inStoreAddInventoryAmount(
item.getWarehouseId(),
projectId,
item.getBatchNumber(),
item.getMaterialId(),
item.getUnitPrice(),
item.getUnitName(),
item.getInStockAmount(),add.getInStockType());
});
wmsInStockDetailsMapper.insert(inStockDetailsList); //插入子表
wmsInventoryLedgerMapper.insert(wmsInventoryLedgers);
}
return flag;
}

@ -12,10 +12,12 @@ import org.dromara.common.mybatis.core.page.TableDataInfo;
import org.dromara.common.satoken.utils.LoginHelper;
import org.dromara.wms.domain.WmsBaseProduct;
import org.dromara.wms.domain.WmsInventoryDetails;
import org.dromara.wms.domain.WmsInventoryLedger;
import org.dromara.wms.domain.WmsWarehouseInfo;
import org.dromara.wms.domain.bo.WmsInventoryDetailsBo;
import org.dromara.wms.domain.vo.WmsInventoryDetailsVo;
import org.dromara.wms.mapper.WmsInventoryDetailsMapper;
import org.dromara.wms.mapper.WmsInventoryLedgerMapper;
import org.dromara.wms.service.IWmsInventoryDetailsService;
import org.springframework.stereotype.Service;
@ -33,6 +35,7 @@ import java.util.List;
public class WmsInventoryDetailsServiceImpl implements IWmsInventoryDetailsService {
private final WmsInventoryDetailsMapper baseMapper;
private final WmsInventoryLedgerMapper wmsInventoryLedgerMapper;
/**
*
@ -96,7 +99,6 @@ public class WmsInventoryDetailsServiceImpl implements IWmsInventoryDetailsServi
return baseMapper.selectVoList(lqw);
}
private MPJLambdaWrapper<WmsInventoryDetails> buildQueryWrapper(WmsInventoryDetailsBo bo) {
// Map<String, Object> params = bo.getParams();
MPJLambdaWrapper<WmsInventoryDetails> lqw = JoinWrappers.lambda(WmsInventoryDetails.class)
@ -148,7 +150,6 @@ public class WmsInventoryDetailsServiceImpl implements IWmsInventoryDetailsServi
return baseMapper.updateById(update) > 0;
}
/**
*
*
@ -161,22 +162,6 @@ public class WmsInventoryDetailsServiceImpl implements IWmsInventoryDetailsServi
return baseMapper.deleteByIds(ids) > 0;
}
@Override
public WmsInventoryDetails queryInventory(WmsInventoryDetailsBo bo) {
MPJLambdaWrapper<WmsInventoryDetails> lqw = JoinWrappers.lambda(WmsInventoryDetails.class)
.selectAll(WmsInventoryDetails.class)
.eq(WmsInventoryDetails::getDelFlag, "0")
.eq(StringUtils.isNotBlank(bo.getLocationCode()), WmsInventoryDetails::getLocationCode, bo.getLocationCode())
.eq(bo.getWarehouseId() != null, WmsInventoryDetails::getWarehouseId, bo.getWarehouseId())
.eq(bo.getMaterielId() != null, WmsInventoryDetails::getMaterielId, bo.getMaterielId())
.eq(bo.getProjectId() != null, WmsInventoryDetails::getProjectId, bo.getProjectId())
.eq(StringUtils.isNotBlank(bo.getBatchNumber()), WmsInventoryDetails::getBatchNumber, bo.getBatchNumber())
.eq(bo.getUnitPrice() != null, WmsInventoryDetails::getUnitPrice, bo.getUnitPrice());
return baseMapper.selectOne(lqw);
}
@Override
public Double workUpdateInventory(Long inventoryDetailsId, Double disposalQty) {
@ -210,4 +195,72 @@ public class WmsInventoryDetailsServiceImpl implements IWmsInventoryDetailsServi
public Boolean workAddUpdateInventory(WmsInventoryDetails inventoryDetails) {
return baseMapper.workAddUpdateInventory(inventoryDetails) > 0;
}
/**
*
*
* @param warehouseId ID
* @param projectId ID
* @param batchNumber
* @param materialId ID
* @param unitPrice
* @param unitName
* @param inStockAmount
* @return
*/
@Override
public Boolean inStoreAddInventoryAmount(Long warehouseId, Long projectId, String batchNumber, Long materialId,
Double unitPrice, String unitName, Double inStockAmount, String changeType) {
WmsInventoryDetailsBo inventory = new WmsInventoryDetailsBo();
inventory.setWarehouseId(warehouseId);
inventory.setProjectId(projectId);
inventory.setBatchNumber(batchNumber);
inventory.setMaterielId(materialId);
inventory.setUnitPrice(unitPrice);
// 查询相同项目 相同仓库 相同批次 相同单价的物料
WmsInventoryDetails queryInventory = queryInventory(inventory);
Double inventoryTableAmount = 0.0;
if (queryInventory != null) {
inventoryTableAmount = queryInventory.getInventoryAmount();
baseMapper.updateTableById(queryInventory.getInventoryDetailsId(), inStockAmount, DateUtils.getNowDate(), LoginHelper.getUserId()); // 更新库存数量
} else {
inventory.setUnitName(unitName);
inventory.setInventoryAmount(inStockAmount);
inventory.setStartInventoryAmount(inStockAmount);
this.insertByBo(inventory);
}
//库存变动
WmsInventoryLedger wmsInventoryLedger = new WmsInventoryLedger();
wmsInventoryLedger.setWarehouseId(warehouseId);
wmsInventoryLedger.setBatchNumber(batchNumber);
wmsInventoryLedger.setMaterielId(materialId);
wmsInventoryLedger.setChangeType(changeType);//变动类型
wmsInventoryLedger.setLedgerState("1");
wmsInventoryLedger.setChangeAmount(inStockAmount);
wmsInventoryLedger.setInventoryAmount(inventoryTableAmount);
wmsInventoryLedgerMapper.insert(wmsInventoryLedger);
return true;
}
/**
*
*
* @param bo
* @return
*/
@Override
public WmsInventoryDetails queryInventory(WmsInventoryDetailsBo bo) {
MPJLambdaWrapper<WmsInventoryDetails> lqw = JoinWrappers.lambda(WmsInventoryDetails.class)
.selectAll(WmsInventoryDetails.class)
.eq(WmsInventoryDetails::getDelFlag, "0")
.eq(StringUtils.isNotBlank(bo.getLocationCode()), WmsInventoryDetails::getLocationCode, bo.getLocationCode())
.eq(bo.getWarehouseId() != null, WmsInventoryDetails::getWarehouseId, bo.getWarehouseId())
.eq(bo.getMaterielId() != null, WmsInventoryDetails::getMaterielId, bo.getMaterielId())
.eq(bo.getProjectId() != null, WmsInventoryDetails::getProjectId, bo.getProjectId())
.eq(StringUtils.isNotBlank(bo.getBatchNumber()), WmsInventoryDetails::getBatchNumber, bo.getBatchNumber())
.eq(bo.getUnitPrice() != null, WmsInventoryDetails::getUnitPrice, bo.getUnitPrice());
return baseMapper.selectOne(lqw);
}
}

@ -0,0 +1,147 @@
package org.dromara.wms.service.impl;
import org.apache.dubbo.config.annotation.DubboReference;
import org.dromara.common.core.utils.MapstructUtils;
import org.dromara.common.core.utils.StringUtils;
import org.dromara.common.mybatis.core.page.TableDataInfo;
import org.dromara.common.mybatis.core.page.PageQuery;
import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
import com.github.yulichang.toolkit.JoinWrappers;
import com.github.yulichang.wrapper.MPJLambdaWrapper;
import com.baomidou.mybatisplus.core.toolkit.Wrappers;
import lombok.RequiredArgsConstructor;
import org.dromara.system.api.RemoteCodeRuleService;
import org.dromara.wms.service.IWmsMaterialTransferRecordService;
import org.springframework.stereotype.Service;
import org.dromara.wms.domain.bo.WmsMaterialTransferBillsBo;
import org.dromara.wms.domain.vo.WmsMaterialTransferBillsVo;
import org.dromara.wms.domain.WmsMaterialTransferBills;
import org.dromara.wms.mapper.WmsMaterialTransferBillsMapper;
import org.dromara.wms.service.IWmsMaterialTransferBillsService;
import java.util.List;
import java.util.Map;
import java.util.Collection;
/**
* Service
*
* @author Yinq
* @date 2025-12-08
*/
@RequiredArgsConstructor
@Service
public class WmsMaterialTransferBillsServiceImpl implements IWmsMaterialTransferBillsService {
private final WmsMaterialTransferBillsMapper baseMapper;
/**
*
*
* @param transferBillsId
* @return
*/
@Override
public WmsMaterialTransferBillsVo queryById(Long transferBillsId){
return baseMapper.selectVoById(transferBillsId);
}
/**
*
*
* @param bo
* @param pageQuery
* @return
*/
@Override
public TableDataInfo<WmsMaterialTransferBillsVo> queryPageList(WmsMaterialTransferBillsBo bo, PageQuery pageQuery) {
MPJLambdaWrapper<WmsMaterialTransferBills> lqw = buildQueryWrapper(bo);
Page<WmsMaterialTransferBillsVo> result = baseMapper.selectVoPage(pageQuery.build(), lqw);
return TableDataInfo.build(result);
}
/**
*
*
* @param bo
* @return
*/
@Override
public List<WmsMaterialTransferBillsVo> queryList(WmsMaterialTransferBillsBo bo) {
MPJLambdaWrapper<WmsMaterialTransferBills> lqw = buildQueryWrapper(bo);
return baseMapper.selectVoList(lqw);
}
private MPJLambdaWrapper<WmsMaterialTransferBills> buildQueryWrapper(WmsMaterialTransferBillsBo bo) {
Map<String, Object> params = bo.getParams();
MPJLambdaWrapper<WmsMaterialTransferBills> lqw = JoinWrappers.lambda(WmsMaterialTransferBills.class)
.selectAll(WmsMaterialTransferBills.class)
.eq(WmsMaterialTransferBills::getDelFlag, "0")
.eq(bo.getTransferOutStoreId() != null, WmsMaterialTransferBills::getTransferOutStoreId, bo.getTransferOutStoreId())
.eq(bo.getTransferInStoreId() != null, WmsMaterialTransferBills::getTransferInStoreId, bo.getTransferInStoreId())
.eq(StringUtils.isNotBlank(bo.getBillsStatus()), WmsMaterialTransferBills::getBillsStatus, bo.getBillsStatus())
.between(params.get("beginCreateTime") != null && params.get("endCreateTime") != null,
WmsMaterialTransferBills::getCreateTime ,params.get("beginCreateTime"), params.get("endCreateTime"))
;
return lqw;
}
@DubboReference
private RemoteCodeRuleService remoteCodeRuleService;
private final IWmsMaterialTransferRecordService wmsMaterialTransferRecordService;
/**
*
*
* @param bo
* @return
*/
@Override
public Boolean insertByBo(WmsMaterialTransferBillsBo bo) {
WmsMaterialTransferBills add = MapstructUtils.convert(bo, WmsMaterialTransferBills.class);
add.setTransferBillsCode(remoteCodeRuleService.selectCodeRuleCode("wms_1003"));
validEntityBeforeSave(add);
boolean flag = baseMapper.insert(add) > 0;
if (flag) {
Long transferBillsId = add.getTransferBillsId();
bo.setTransferBillsId(transferBillsId);
wmsMaterialTransferRecordService.insertByBo(transferBillsId,bo.getList());
}
return flag;
}
/**
*
*
* @param bo
* @return
*/
@Override
public Boolean updateByBo(WmsMaterialTransferBillsBo bo) {
WmsMaterialTransferBills update = MapstructUtils.convert(bo, WmsMaterialTransferBills.class);
validEntityBeforeSave(update);
return baseMapper.updateById(update) > 0;
}
/**
*
*/
private void validEntityBeforeSave(WmsMaterialTransferBills entity){
//TODO 做一些数据校验,如唯一约束
}
/**
*
*
* @param ids
* @param isValid
* @return
*/
@Override
public Boolean deleteWithValidByIds(Collection<Long> ids, Boolean isValid) {
if(isValid){
//TODO 做一些业务上的校验,判断是否需要校验
}
return baseMapper.deleteByIds(ids) > 0;
}
}

@ -35,6 +35,7 @@ public class WmsMaterialTransferRecordServiceImpl implements IWmsMaterialTransfe
private final WmsMaterialTransferRecordMapper baseMapper;
private final WmsInventoryDetailsMapper wmsInventoryDetailsMapper;
/**
*
*
@ -77,6 +78,7 @@ public class WmsMaterialTransferRecordServiceImpl implements IWmsMaterialTransfe
MPJLambdaWrapper<WmsMaterialTransferRecord> lqw = JoinWrappers.lambda(WmsMaterialTransferRecord.class)
.selectAll(WmsMaterialTransferRecord.class)
.eq(WmsMaterialTransferRecord::getDelFlag, "0")
.eq(bo.getTransferBillsId() != null, WmsMaterialTransferRecord::getTransferBillsId, bo.getTransferBillsId())
.eq(bo.getMaterielId() != null, WmsMaterialTransferRecord::getMaterielId, bo.getMaterielId())
.eq(StringUtils.isNotBlank(bo.getBatchNumber()), WmsMaterialTransferRecord::getBatchNumber, bo.getBatchNumber())
.eq(bo.getTransferOutStoreId() != null, WmsMaterialTransferRecord::getTransferOutStoreId, bo.getTransferOutStoreId())
@ -95,12 +97,11 @@ public class WmsMaterialTransferRecordServiceImpl implements IWmsMaterialTransfe
* @return
*/
@Override
public Boolean insertByBo(List<WmsMaterialTransferRecord> bo) {
public Boolean insertByBo(Long transferBillsId, List<WmsMaterialTransferRecord> bo) {
baseMapper.insert(bo);
// 修改库存
bo.forEach(record -> {
// Long transferOutStoreId = record.getTransferOutStoreId();
record.setTransferBillsId(transferBillsId);// 调拨单ID
Long inventoryDetailsId = record.getInventoryDetailsId(); // 库存ID
Double transferQty = record.getTransferQty(); // 调拨数量
// 库存验证
@ -120,16 +121,13 @@ public class WmsMaterialTransferRecordServiceImpl implements IWmsMaterialTransfe
// 入库库存增加
WmsInventoryDetails inDetails = new WmsInventoryDetails();
inDetails.setInventoryAmount(transferQty);// 入库数量
inDetails.setWarehouseId(record.getTransferInStoreId()); //仓库
inDetails.setInventoryDetailsId(null);
inDetails.setWarehouseId(record.getTransferInStoreId()); //仓库id
inDetails.setMaterielId(inventoryDetails.getMaterielId());
inDetails.setUnitPrice(inventoryDetails.getUnitPrice());
inDetails.setBatchNumber(record.getBatchNumber());
inDetails.setUnitName(record.getUnitName());
// inDetails
wmsInventoryDetailsMapper.insert(inDetails);
});
return true;
@ -148,7 +146,6 @@ public class WmsMaterialTransferRecordServiceImpl implements IWmsMaterialTransfe
}
/**
*
*

@ -0,0 +1,14 @@
<?xml version="1.0" encoding="UTF-8" ?>
<!DOCTYPE mapper
PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN"
"http://mybatis.org/dtd/mybatis-3-mapper.dtd">
<mapper namespace="org.dromara.wms.mapper.WmsMaterialTransferBillsMapper">
<resultMap type="org.dromara.wms.domain.vo.WmsMaterialTransferBillsVo" id="WmsMaterialTransferBillsResult">
</resultMap>
<select id="selectCustomWmsMaterialTransferBillsVoList" resultMap="WmsMaterialTransferBillsResult">
select transfer_bills_id, transfer_bills_code, transfer_out_store_id, transfer_in_store_id, bills_status, remark, tenant_id, del_flag, create_dept, create_by, create_time, update_by, update_time from wms_material_transfer_bills t
${ew.getCustomSqlSegment}
</select>
</mapper>
Loading…
Cancel
Save