Merge remote-tracking branch 'origin/master'

master
wanghao 3 months ago
commit b2447e0d7b

@ -24,7 +24,7 @@ import java.util.List;
/** /**
* *
* 访:/mes/orderInfo * 访:/wms/orderInfo
* *
* @author Yinq * @author Yinq
* @date 2025-01-09 * @date 2025-01-09

@ -103,4 +103,14 @@ public class WmsAllocateOrderController extends BaseController {
@PathVariable Long[] aoIds) { @PathVariable Long[] aoIds) {
return toAjax(wmsAllocateOrderService.deleteWithValidByIds(List.of(aoIds), true)); return toAjax(wmsAllocateOrderService.deleteWithValidByIds(List.of(aoIds), true));
} }
/**
*
* @param bo
* @return
*/
@PutMapping("/approveAllocateOrder")
public R<Integer> approveAllocateOrder(@RequestBody WmsAllocateOrderBo bo) {
return R.ok(wmsAllocateOrderService.approveAllocateOrder(bo));
}
} }

@ -107,7 +107,7 @@ public class WmsAllocateOrder{
*/ */
private String tenantId; private String tenantId;
@TableField(fill = FieldFill.INSERT) @TableField(fill = FieldFill.INSERT)
private String createBy; private Long createBy;
/** /**
* *
@ -119,7 +119,7 @@ public class WmsAllocateOrder{
* *
*/ */
@TableField(fill = FieldFill.INSERT_UPDATE) @TableField(fill = FieldFill.INSERT_UPDATE)
private String updateBy; private Long updateBy;
/** /**
* *

@ -61,8 +61,12 @@ public class WmsAllocateOrderDetail {
* id * id
*/ */
private String tenantId; private String tenantId;
/**
*
*/
@TableField(fill = FieldFill.INSERT) @TableField(fill = FieldFill.INSERT)
private String createBy; private Long createBy;
/** /**
* *
@ -74,7 +78,7 @@ public class WmsAllocateOrderDetail {
* *
*/ */
@TableField(fill = FieldFill.INSERT_UPDATE) @TableField(fill = FieldFill.INSERT_UPDATE)
private String updateBy; private Long updateBy;
/** /**
* *

@ -1,13 +1,14 @@
package org.dromara.wms.domain; package org.dromara.wms.domain;
import org.dromara.common.tenant.core.TenantEntity; import com.baomidou.mybatisplus.annotation.IdType;
import com.baomidou.mybatisplus.annotation.*; import com.baomidou.mybatisplus.annotation.TableId;
import com.baomidou.mybatisplus.annotation.TableName;
import lombok.Data; import lombok.Data;
import lombok.EqualsAndHashCode; import lombok.EqualsAndHashCode;
import java.util.Date; import org.dromara.common.tenant.core.TenantEntity;
import com.fasterxml.jackson.annotation.JsonFormat;
import java.io.Serial; import java.io.Serial;
import java.util.Date;
/** /**
* wms_allocate_task * wms_allocate_task
@ -26,6 +27,7 @@ public class WmsAllocateTask extends TenantEntity {
/** /**
* *
*/ */
@TableId(value = "allocate_task_id", type = IdType.AUTO)
private Long allocateTaskId; private Long allocateTaskId;
/** /**

@ -65,4 +65,12 @@ public interface IWmsAllocateOrderService {
* @return * @return
*/ */
Boolean deleteWithValidByIds(Collection<Long> ids, Boolean isValid); Boolean deleteWithValidByIds(Collection<Long> ids, Boolean isValid);
/**
*
*
* @param bo
* @return
*/
Integer approveAllocateOrder(WmsAllocateOrderBo bo);
} }

@ -1,8 +1,5 @@
package org.dromara.wms.service.impl; package org.dromara.wms.service.impl;
import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
import com.baomidou.mybatisplus.core.toolkit.Wrappers;
import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
import com.baomidou.mybatisplus.extension.plugins.pagination.Page; import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
import com.github.yulichang.toolkit.JoinWrappers; import com.github.yulichang.toolkit.JoinWrappers;
import com.github.yulichang.wrapper.MPJLambdaWrapper; import com.github.yulichang.wrapper.MPJLambdaWrapper;
@ -11,7 +8,6 @@ import org.dromara.common.core.utils.MapstructUtils;
import org.dromara.common.core.utils.StringUtils; import org.dromara.common.core.utils.StringUtils;
import org.dromara.common.mybatis.core.page.PageQuery; import org.dromara.common.mybatis.core.page.PageQuery;
import org.dromara.common.mybatis.core.page.TableDataInfo; import org.dromara.common.mybatis.core.page.TableDataInfo;
import org.dromara.common.satoken.utils.LoginHelper;
import org.dromara.wms.domain.BaseMaterialInfo; import org.dromara.wms.domain.BaseMaterialInfo;
import org.dromara.wms.domain.WmsAllocateOrderDetail; import org.dromara.wms.domain.WmsAllocateOrderDetail;
import org.dromara.wms.domain.bo.WmsAllocateOrderDetailBo; import org.dromara.wms.domain.bo.WmsAllocateOrderDetailBo;
@ -58,7 +54,7 @@ public class WmsAllocateOrderDetailServiceImpl implements IWmsAllocateOrderDetai
@Override @Override
public TableDataInfo<WmsAllocateOrderDetailVo> queryPageList(WmsAllocateOrderDetailBo bo, PageQuery pageQuery) { public TableDataInfo<WmsAllocateOrderDetailVo> queryPageList(WmsAllocateOrderDetailBo bo, PageQuery pageQuery) {
// LambdaQueryWrapper<WmsAllocateOrderDetail> lqw = buildQueryWrapper(bo); // LambdaQueryWrapper<WmsAllocateOrderDetail> lqw = buildQueryWrapper(bo);
MPJLambdaWrapper<WmsAllocateOrderDetail> lqw = buildJoinQueryWrapper(bo); MPJLambdaWrapper<WmsAllocateOrderDetail> lqw = buildQueryWrapper(bo);
Page<WmsAllocateOrderDetailVo> result = baseMapper.selectVoPage(pageQuery.build(), lqw); Page<WmsAllocateOrderDetailVo> result = baseMapper.selectVoPage(pageQuery.build(), lqw);
return TableDataInfo.build(result); return TableDataInfo.build(result);
} }
@ -71,34 +67,27 @@ public class WmsAllocateOrderDetailServiceImpl implements IWmsAllocateOrderDetai
*/ */
@Override @Override
public List<WmsAllocateOrderDetailVo> queryList(WmsAllocateOrderDetailBo bo) { public List<WmsAllocateOrderDetailVo> queryList(WmsAllocateOrderDetailBo bo) {
MPJLambdaWrapper<WmsAllocateOrderDetail> lqw = buildJoinQueryWrapper(bo); MPJLambdaWrapper<WmsAllocateOrderDetail> lqw = buildQueryWrapper(bo);
return baseMapper.selectVoList(lqw); return baseMapper.selectVoList(lqw);
} }
private MPJLambdaWrapper<WmsAllocateOrderDetail> buildQueryWrapper(WmsAllocateOrderDetailBo bo) {
Map<String, Object> params = bo.getParams();
MPJLambdaWrapper<WmsAllocateOrderDetail> lqw = JoinWrappers.lambda(WmsAllocateOrderDetail.class);
lqw.eq(bo.getAoDId() != null, WmsAllocateOrderDetail::getAoDId, bo.getAoDId()); private MPJLambdaWrapper<WmsAllocateOrderDetail> buildQueryWrapper(WmsAllocateOrderDetailBo bo) {
lqw.eq(StringUtils.isNotBlank(bo.getAllocateCode()), WmsAllocateOrderDetail::getAllocateCode, bo.getAllocateCode());
lqw.eq(bo.getMaterialId() != null, WmsAllocateOrderDetail::getMaterialId, bo.getMaterialId());
lqw.eq(bo.getAllocateOrderQty() != null, WmsAllocateOrderDetail::getAllocateOrderQty, bo.getAllocateOrderQty());
lqw.eq(StringUtils.isNotBlank(bo.getErpSynchronousStatus()), WmsAllocateOrderDetail::getErpSynchronousStatus, bo.getErpSynchronousStatus());
lqw.eq(bo.getErpSynchronousQty() != null, WmsAllocateOrderDetail::getErpSynchronousQty, bo.getErpSynchronousQty());
return lqw;
}
private MPJLambdaWrapper<WmsAllocateOrderDetail> buildJoinQueryWrapper(WmsAllocateOrderDetailBo bo) {
Map<String, Object> params = bo.getParams(); Map<String, Object> params = bo.getParams();
MPJLambdaWrapper<WmsAllocateOrderDetail> lqw = JoinWrappers.lambda(WmsAllocateOrderDetail.class) MPJLambdaWrapper<WmsAllocateOrderDetail> lqw = JoinWrappers.lambda(WmsAllocateOrderDetail.class)
.selectAll(WmsAllocateOrderDetail.class) .selectAll(WmsAllocateOrderDetail.class)
.select(BaseMaterialInfo::getMaterialCode,BaseMaterialInfo::getMaterialName)
.leftJoin(BaseMaterialInfo.class,BaseMaterialInfo::getMaterialId,WmsAllocateOrderDetail::getMaterialId); // 关联查询
lqw.eq(bo.getAoDId() != null, WmsAllocateOrderDetail::getAoDId, bo.getAoDId()); .select(BaseMaterialInfo::getMaterialCode, BaseMaterialInfo::getMaterialName)
lqw.eq(StringUtils.isNotBlank(bo.getAllocateCode()), WmsAllocateOrderDetail::getAllocateCode, bo.getAllocateCode()); .leftJoin(BaseMaterialInfo.class, BaseMaterialInfo::getMaterialId, WmsAllocateOrderDetail::getMaterialId)
lqw.eq(bo.getMaterialId() != null, WmsAllocateOrderDetail::getMaterialId, bo.getMaterialId());
lqw.eq(bo.getAllocateOrderQty() != null, WmsAllocateOrderDetail::getAllocateOrderQty, bo.getAllocateOrderQty()); .eq(bo.getAoDId() != null, WmsAllocateOrderDetail::getAoDId, bo.getAoDId())
lqw.eq(StringUtils.isNotBlank(bo.getErpSynchronousStatus()), WmsAllocateOrderDetail::getErpSynchronousStatus, bo.getErpSynchronousStatus()); .eq(StringUtils.isNotBlank(bo.getAllocateCode()), WmsAllocateOrderDetail::getAllocateCode, bo.getAllocateCode())
lqw.eq(bo.getErpSynchronousQty() != null, WmsAllocateOrderDetail::getErpSynchronousQty, bo.getErpSynchronousQty()).orderByDesc(WmsAllocateOrderDetail::getCreateTime); .eq(bo.getMaterialId() != null, WmsAllocateOrderDetail::getMaterialId, bo.getMaterialId())
.eq(bo.getAllocateOrderQty() != null, WmsAllocateOrderDetail::getAllocateOrderQty, bo.getAllocateOrderQty())
.eq(StringUtils.isNotBlank(bo.getErpSynchronousStatus()), WmsAllocateOrderDetail::getErpSynchronousStatus, bo.getErpSynchronousStatus())
.eq(bo.getErpSynchronousQty() != null, WmsAllocateOrderDetail::getErpSynchronousQty, bo.getErpSynchronousQty())
.orderByDesc(WmsAllocateOrderDetail::getCreateTime);
return lqw; return lqw;
} }
@ -109,14 +98,14 @@ public class WmsAllocateOrderDetailServiceImpl implements IWmsAllocateOrderDetai
* @return * @return
*/ */
@Override @Override
@Transactional(rollbackFor = Exception.class) @Transactional( rollbackFor = Exception.class )
public Boolean insertByBo(List<WmsAllocateOrderDetailBo> bo) { public Boolean insertByBo(List<WmsAllocateOrderDetailBo> bo) {
int i = 0; int i = 0;
for (WmsAllocateOrderDetailBo detailBo : bo) { for (WmsAllocateOrderDetailBo detailBo : bo) {
WmsAllocateOrderDetail add = MapstructUtils.convert(detailBo, WmsAllocateOrderDetail.class); WmsAllocateOrderDetail add = MapstructUtils.convert(detailBo, WmsAllocateOrderDetail.class);
/* add.setCreateBy(LoginHelper.getUsername()); /* add.setCreateBy(LoginHelper.getUsername());
add.setTenantId(LoginHelper.getTenantId());*/ add.setTenantId(LoginHelper.getTenantId());*/
i = baseMapper.insert(add); i = baseMapper.insert(add);
} }
// int i = baseMapper.insertDetails(list); // int i = baseMapper.insertDetails(list);
return i > 0; return i > 0;
@ -132,14 +121,13 @@ public class WmsAllocateOrderDetailServiceImpl implements IWmsAllocateOrderDetai
public Boolean updateByBo(WmsAllocateOrderDetailBo bo) { public Boolean updateByBo(WmsAllocateOrderDetailBo bo) {
WmsAllocateOrderDetail update = MapstructUtils.convert(bo, WmsAllocateOrderDetail.class); WmsAllocateOrderDetail update = MapstructUtils.convert(bo, WmsAllocateOrderDetail.class);
validEntityBeforeSave(update); validEntityBeforeSave(update);
update.setUpdateBy(LoginHelper.getUsername());
return baseMapper.updateById(update) > 0; return baseMapper.updateById(update) > 0;
} }
/** /**
* *
*/ */
private void validEntityBeforeSave(WmsAllocateOrderDetail entity) { private void validEntityBeforeSave(WmsAllocateOrderDetail entity){
//TODO 做一些数据校验,如唯一约束 //TODO 做一些数据校验,如唯一约束
} }
@ -152,7 +140,7 @@ public class WmsAllocateOrderDetailServiceImpl implements IWmsAllocateOrderDetai
*/ */
@Override @Override
public Boolean deleteWithValidByIds(Collection<Long> ids, Boolean isValid) { public Boolean deleteWithValidByIds(Collection<Long> ids, Boolean isValid) {
if (isValid) { if(isValid){
//TODO 做一些业务上的校验,判断是否需要校验 //TODO 做一些业务上的校验,判断是否需要校验
} }
return baseMapper.deleteByIds(ids) > 0; return baseMapper.deleteByIds(ids) > 0;

@ -200,7 +200,6 @@ public class WmsAllocateOrderServiceImpl implements IWmsAllocateOrderService {
public Boolean updateByBo(WmsAllocateOrderBo bo) { public Boolean updateByBo(WmsAllocateOrderBo bo) {
WmsAllocateOrder update = MapstructUtils.convert(bo, WmsAllocateOrder.class); WmsAllocateOrder update = MapstructUtils.convert(bo, WmsAllocateOrder.class);
validEntityBeforeSave(update); validEntityBeforeSave(update);
update.setUpdateBy(LoginHelper.getUsername());
return baseMapper.updateById(update) > 0; return baseMapper.updateById(update) > 0;
} }
@ -225,4 +224,21 @@ public class WmsAllocateOrderServiceImpl implements IWmsAllocateOrderService {
} }
return baseMapper.deleteByIds(ids) > 0; return baseMapper.deleteByIds(ids) > 0;
} }
/**
*
*
* @param bo
* @return
*/
@Override
public Integer approveAllocateOrder(WmsAllocateOrderBo bo) {
String username = LoginHelper.getUsername();
WmsAllocateOrder update = MapstructUtils.convert(bo, WmsAllocateOrder.class);
validEntityBeforeSave(update);
update.setAuditTime(new Date());
update.setAuditBy(username);
int rows = baseMapper.updateById(update);
return rows;
}
} }

@ -530,6 +530,12 @@ if("1".equals(bo.getInstockType())){ // 工单类型(1采购订单)
//TODO 做一些数据校验,如唯一约束 //TODO 做一些数据校验,如唯一约束
} }
/**
*
*
* @param bo
* @return
*/
@Override @Override
public Integer approveInstockOrder(WmsInstockOrderBo bo) { public Integer approveInstockOrder(WmsInstockOrderBo bo) {
String username = LoginHelper.getUsername(); String username = LoginHelper.getUsername();

@ -20,7 +20,7 @@
* *
</if> </if>
from prod_order_info t from prod_order_info t
left join base_material_info bmi on bmi.material_id = t.material_id left join base_material_info_copy1 bmi on bmi.material_id = t.material_id
left join prod_base_prod_line_info pli on t.dispatch_type = 1 and pli.prod_line_id = t.dispatch_id left join prod_base_prod_line_info pli on t.dispatch_type = 1 and pli.prod_line_id = t.dispatch_id
left join prod_base_route rt on t.dispatch_type = 2 and rt.route_id = t.dispatch_id left join prod_base_route rt on t.dispatch_type = 2 and rt.route_id = t.dispatch_id
left join prod_base_process_info pi on t.dispatch_type = 3 and pi.process_id = t.dispatch_id left join prod_base_process_info pi on t.dispatch_type = 3 and pi.process_id = t.dispatch_id

Loading…
Cancel
Save