Merge remote-tracking branch 'origin/main'

This commit is contained in:
liuzhaotian
2024-07-03 11:45:13 +08:00
15 changed files with 105 additions and 47 deletions
@@ -75,6 +75,7 @@ public interface GoodsMapper extends BaseMapperX<GoodsDO> {
// 删板材,批量 // 删板材,批量
void updateDeletedById(@Param("ids") List<Long> ids, @Param("deleted") Integer deleted, @Param("organId") Long organId); void updateDeletedById(@Param("ids") List<Long> ids, @Param("deleted") Integer deleted, @Param("organId") Long organId);
void deletedById(@Param("ids") List<Long> ids, @Param("organId") Long organId);
IPage<OrderGoodsResp> selectGoods(@Param("page") IPage page,@Param("goodsIds") List<Long> goodsIds,@Param("organId") Long organId); IPage<OrderGoodsResp> selectGoods(@Param("page") IPage page,@Param("goodsIds") List<Long> goodsIds,@Param("organId") Long organId);
@@ -53,6 +53,12 @@ public interface OrderBodyMapper extends BaseMapperX<OrderBodyDO> {
.eq(OrderBodyDO::getId, id) .eq(OrderBodyDO::getId, id)
.eq(OrderBodyDO::getOrganId, organId)); .eq(OrderBodyDO::getOrganId, organId));
} }
default int deletedById(Long id, Long organId) {
return delete(new LambdaUpdateWrapper<OrderBodyDO>()
.eq(OrderBodyDO::getId, id)
.eq(OrderBodyDO::getOrganId, organId));
}
// 控制是否删除,进行查询 // 控制是否删除,进行查询
default List<OrderBodyDO> selectList(Long orderId, Integer deleted, Long organId) { default List<OrderBodyDO> selectList(Long orderId, Integer deleted, Long organId) {
@@ -43,4 +43,9 @@ public interface OrderGroupMapper extends BaseMapperX<OrderGroupDO> {
.eq(OrderGroupDO::getBodyId, id) .eq(OrderGroupDO::getBodyId, id)
.eq(OrderGroupDO::getOrganId, organId)); .eq(OrderGroupDO::getOrganId, organId));
} }
default int deletedById(Long id, Long organId) {
return delete(new LambdaUpdateWrapper<OrderGroupDO>()
.eq(OrderGroupDO::getBodyId, id)
.eq(OrderGroupDO::getOrganId, organId));
}
} }
@@ -53,4 +53,10 @@ public interface OrderItemMapper extends BaseMapperX<OrderItemDO> {
List<PrintOrderPackReqVO> selectPackList(@Param("orderIds") List<Long> orderIds, @Param("organId") Long organId); List<PrintOrderPackReqVO> selectPackList(@Param("orderIds") List<Long> orderIds, @Param("organId") Long organId);
default int deleteByBodyId(Long bodyId, Long organId) {
return delete(new LambdaQueryWrapperX<OrderItemDO>()
.eq(OrderItemDO::getBodyId, bodyId)
.eq(OrderItemDO::getOrganId, organId));
}
} }
@@ -64,6 +64,7 @@ public interface OrderPartsMapper extends BaseMapperX<OrderPartsDO> {
} }
void updateDeletedById(@Param("partsIds") List<Long> partsIds, @Param("deleted") Integer deleted, @Param("organId") Long organId); void updateDeletedById(@Param("partsIds") List<Long> partsIds, @Param("deleted") Integer deleted, @Param("organId") Long organId);
void deletedById(@Param("partsIds") List<Long> partsIds, @Param("organId") Long organId);
List<PrintOrderPartsRespVO> selectPartList( @Param("orderIds") List<Long> orderIds,@Param("organId") Long organId); List<PrintOrderPartsRespVO> selectPartList( @Param("orderIds") List<Long> orderIds,@Param("organId") Long organId);
@@ -133,5 +133,6 @@ public interface PlateMapper extends BaseMapperX<PlateDO> {
List<OrderIds> selectOrderIds(@Param("orderIds") List<Long> orderIds,@Param("organId") Long organId); List<OrderIds> selectOrderIds(@Param("orderIds") List<Long> orderIds,@Param("organId") Long organId);
void deletedById(@Param("plateIds") List<Long> plateIds, @Param("organId") Long organId);
} }
@@ -219,11 +219,11 @@ public class OrderServiceImpl implements OrderService {
orderProcessMapper.updateOrderDeleted(orderId, OrderDeletedEnum.NOT_DELETED.getStatus(), SecurityFrameworkUtils.getLoginUser().getOrganId()); orderProcessMapper.updateOrderDeleted(orderId, OrderDeletedEnum.NOT_DELETED.getStatus(), SecurityFrameworkUtils.getLoginUser().getOrganId());
processStepMapper.updateOrderDeleted(orderId, OrderDeletedEnum.NOT_DELETED.getStatus(), SecurityFrameworkUtils.getLoginUser().getOrganId()); processStepMapper.updateOrderDeleted(orderId, OrderDeletedEnum.NOT_DELETED.getStatus(), SecurityFrameworkUtils.getLoginUser().getOrganId());
if (orderDO.getStatus() == OrderStatusEnum.EMPTY.getStatus() ) { // if (orderDO.getStatus() == OrderStatusEnum.EMPTY.getStatus()) {
if (orderBodyMapper.selectCountByOrderId(orderId, SecurityFrameworkUtils.getLoginUser().getOrganId(), OrderDeletedEnum.NOT_DELETED.getStatus()) == 0) { // if (orderBodyMapper.selectCountByOrderId(orderId, SecurityFrameworkUtils.getLoginUser().getOrganId(), OrderDeletedEnum.NOT_DELETED.getStatus()) == 0) {
orderMapper.updateOrderStatus(orderId, OrderStatusEnum.NEW_ORDER.getStatus(), SecurityFrameworkUtils.getLoginUser().getOrganId()); // orderMapper.updateOrderStatus(orderId, OrderStatusEnum.NEW_ORDER.getStatus(), SecurityFrameworkUtils.getLoginUser().getOrganId());
} // }
} // }
} }
@@ -264,6 +264,7 @@ public class OrderServiceImpl implements OrderService {
return index; return index;
} }
@Override @Override
public List<OrderBodyRespVO> getOrderBody(Long orderId) { public List<OrderBodyRespVO> getOrderBody(Long orderId) {
// 判断生产单是否删除 // 判断生产单是否删除
@@ -343,14 +344,16 @@ public class OrderServiceImpl implements OrderService {
bodyIds.forEach(bodyId -> { bodyIds.forEach(bodyId -> {
// 校验存在 // 校验存在
validateOrderBodyExists(orderId, bodyId, SecurityFrameworkUtils.getLoginUser().getOrganId()); validateOrderBodyExists(orderId, bodyId, SecurityFrameworkUtils.getLoginUser().getOrganId());
// 删除 // 物理删除
// orderBodyMapper.deleteAllByOrderId(orderId, bodyId); 物理删除 // orderBodyMapper.updateDeletedById(bodyId, OrderDeletedEnum.DELETED.getStatus(), SecurityFrameworkUtils.getLoginUser().getOrganId());
orderBodyMapper.updateDeletedById(bodyId, OrderDeletedEnum.DELETED.getStatus(), SecurityFrameworkUtils.getLoginUser().getOrganId()); orderBodyMapper.deletedById(bodyId, SecurityFrameworkUtils.getLoginUser().getOrganId()); // 柜体
orderGroupMapper.updateDeletedById(bodyId, OrderDeletedEnum.DELETED.getStatus(), SecurityFrameworkUtils.getLoginUser().getOrganId()); // orderGroupMapper.updateDeletedById(bodyId, OrderDeletedEnum.DELETED.getStatus(), SecurityFrameworkUtils.getLoginUser().getOrganId());
orderGroupMapper.deletedById(bodyId, SecurityFrameworkUtils.getLoginUser().getOrganId()); // 加工组
// 先查再改 // 先查再改
List<Long> plateDOList = plateMapper.selectPlateIdListByBodyId(bodyId, SecurityFrameworkUtils.getLoginUser().getOrganId()); List<Long> plateDOList = plateMapper.selectPlateIdListByBodyId(bodyId, SecurityFrameworkUtils.getLoginUser().getOrganId());
// 删除小板 // (删除小板) 小板变为删除状态
plateMapper.updateDeletedById(plateDOList, OrderDeletedEnum.DELETED.getStatus(), SecurityFrameworkUtils.getLoginUser().getOrganId()); plateMapper.updateDeletedById(plateDOList, OrderDeletedEnum.DELETED.getStatus(), SecurityFrameworkUtils.getLoginUser().getOrganId());
// 删除大板 // 删除大板
List<PlateGoodsIdVO> goodsIdList = plateMapper.selectPlateGoodsListByList(plateDOList, orderId, SecurityFrameworkUtils.getLoginUser().getOrganId()); List<PlateGoodsIdVO> goodsIdList = plateMapper.selectPlateGoodsListByList(plateDOList, orderId, SecurityFrameworkUtils.getLoginUser().getOrganId());
@@ -365,10 +368,15 @@ public class OrderServiceImpl implements OrderService {
goodsIdDeleted.add(k); goodsIdDeleted.add(k);
}); });
if (goodsIdDeleted.size() > 0) { if (goodsIdDeleted.size() > 0) {
goodsMapper.updateDeletedById(goodsIdDeleted, OrderDeletedEnum.DELETED.getStatus(), SecurityFrameworkUtils.getLoginUser().getOrganId()); // goodsMapper.updateDeletedById(goodsIdDeleted, OrderDeletedEnum.DELETED.getStatus(), SecurityFrameworkUtils.getLoginUser().getOrganId());
goodsMapper.deletedById(goodsIdDeleted, SecurityFrameworkUtils.getLoginUser().getOrganId());
} }
List<Long> partsList = orderPartsMapper.selectPartsIdListByBodyId(bodyId, SecurityFrameworkUtils.getLoginUser().getOrganId()); List<Long> partsList = orderPartsMapper.selectPartsIdListByBodyId(bodyId, SecurityFrameworkUtils.getLoginUser().getOrganId()); // 配件
orderPartsMapper.updateDeletedById(partsList, OrderDeletedEnum.DELETED.getStatus(), SecurityFrameworkUtils.getLoginUser().getOrganId()); // orderPartsMapper.updateDeletedById(partsList, OrderDeletedEnum.DELETED.getStatus(), SecurityFrameworkUtils.getLoginUser().getOrganId());
orderPartsMapper.deletedById(partsList, SecurityFrameworkUtils.getLoginUser().getOrganId());
plateMapper.deletedById(plateDOList, SecurityFrameworkUtils.getLoginUser().getOrganId());
orderItemMapper.deleteByBodyId(bodyId, SecurityFrameworkUtils.getLoginUser().getOrganId());
}); });
} }
// 生产单柜体数量判断 // 生产单柜体数量判断
@@ -528,6 +536,7 @@ public class OrderServiceImpl implements OrderService {
} }
return true; return true;
} }
// 业务员是否存在 // 业务员是否存在
private void validateSalesmanOrderNoExists(String salesman, Long organId) { private void validateSalesmanOrderNoExists(String salesman, Long organId) {
if (adminUserApi.validateUser(salesman, organId).getData() == null) { if (adminUserApi.validateUser(salesman, organId).getData() == null) {
@@ -52,7 +52,14 @@
</foreach> </foreach>
AND organ_id = #{organId} AND organ_id = #{organId}
</update> </update>
<delete id="deletedById">
DELETE FROM order_goods
WHERE id IN
<foreach item="id" collection="ids" open="(" separator="," close=")">
#{id}
</foreach>
AND organ_id = #{organId}
</delete>
<select id="selectGoods" resultType="com.cf.imes.module.executor.controller.admin.plan.vo.OrderGoodsResp" parameterType="map"> <select id="selectGoods" resultType="com.cf.imes.module.executor.controller.admin.plan.vo.OrderGoodsResp" parameterType="map">
@@ -46,15 +46,15 @@
<select id="selectPartAll" <select id="selectPartAll"
resultType="com.cf.imes.module.executor.controller.admin.orderParts.vo.PartGoodsRespVO"> resultType="com.cf.imes.module.executor.controller.admin.orderParts.vo.PartGoodsRespVO">
SELECT DISTINCT SELECT DISTINCT
a.id, -- a.id,
a.name, a.name,
a.brand, a.brand,
a.model, a.model,
a.spec, a.spec,
a.unit, a.unit,
a.price, -- a.price,
a.remark, a.remark,
b.num SUM(b.num) AS num
FROM FROM
order_parts a order_parts a
LEFT JOIN LEFT JOIN
@@ -63,6 +63,7 @@
b.order_id = #{orderId} b.order_id = #{orderId}
AND b.organ_id = #{organId} AND b.organ_id = #{organId}
AND a.deleted = #{deleted} AND a.deleted = #{deleted}
GROUP BY a.name, a.brand, a.model, a.spec, a.unit, a.remark
</select> </select>
@@ -74,7 +75,14 @@
#{partsId} #{partsId}
</foreach>AND organ_id = #{organId} </foreach>AND organ_id = #{organId}
</update> </update>
<delete id="deletedById">
DELETE FROM order_parts
WHERE id IN
<foreach collection="partsIds" item="partsId" open="(" separator="," close=")">
#{partsId}
</foreach>
AND organ_id = #{organId}
</delete>
<select id="selectPartList" <select id="selectPartList"
resultType="com.cf.imes.module.executor.controller.admin.plan.saveOptimize.PrintOrderPartsRespVO"> resultType="com.cf.imes.module.executor.controller.admin.plan.saveOptimize.PrintOrderPartsRespVO">
@@ -278,6 +278,16 @@
</foreach> </foreach>
AND organ_id = #{organId} AND organ_id = #{organId}
</update> </update>
<delete id="deletedById">
DELETE FROM order_plate
WHERE id IN
<foreach collection="plateIds" item="plateId" open="(" separator="," close=")">
#{plateId}
</foreach>
AND organ_id = #{organId}
</delete>
<select id="countPlateByOrderId" resultType="java.lang.Integer"> <select id="countPlateByOrderId" resultType="java.lang.Integer">
SELECT count(*) FROM order_plate SELECT count(*) FROM order_plate
WHERE order_id = #{orderId} AND organ_id = #{organId} AND deleted = #{deleted} WHERE order_id = #{orderId} AND organ_id = #{organId} AND deleted = #{deleted}
@@ -33,7 +33,7 @@ import javax.annotation.Resource;
import javax.servlet.http.HttpServletResponse; import javax.servlet.http.HttpServletResponse;
import javax.validation.Valid; import javax.validation.Valid;
@Tag(name = "管理后台 - 板材信息表 plate") @Tag(name = "管理后台 - 板材库管理")
@RestController @RestController
@RequestMapping("/manage/plate") @RequestMapping("/manage/plate")
@Validated @Validated
@@ -43,7 +43,7 @@ public class PlateController {
private PlateService plateService; private PlateService plateService;
@PostMapping("/create") @PostMapping("/create")
@Operation(summary = "创建板材信息表 plate_{N}") @Operation(summary = "创建板材信息")
// @PreAuthorize("@ss.hasPermission('manage:plate:create')") // @PreAuthorize("@ss.hasPermission('manage:plate:create')")
@PreAuthorize("@ss.hasAnyPermissions('manage:plate:create','base:plate:create')") @PreAuthorize("@ss.hasAnyPermissions('manage:plate:create','base:plate:create')")
public CommonResult<Long> createPlate(@Valid @RequestBody PlateSaveReqVO createReqVO) { public CommonResult<Long> createPlate(@Valid @RequestBody PlateSaveReqVO createReqVO) {
@@ -51,7 +51,7 @@ public class PlateController {
} }
@PutMapping("/update") @PutMapping("/update")
@Operation(summary = "更新板材信息表 plate_{N}") @Operation(summary = "更新板材信息")
// @PreAuthorize("@ss.hasPermission('manage:plate:update')") // @PreAuthorize("@ss.hasPermission('manage:plate:update')")
@PreAuthorize("@ss.hasAnyPermissions('manage:plate:update','base:plate:update')") @PreAuthorize("@ss.hasAnyPermissions('manage:plate:update','base:plate:update')")
public CommonResult<Boolean> updatePlate(@Valid @RequestBody PlateSaveReqVO updateReqVO) { public CommonResult<Boolean> updatePlate(@Valid @RequestBody PlateSaveReqVO updateReqVO) {
@@ -60,7 +60,7 @@ public class PlateController {
} }
@DeleteMapping("/delete") @DeleteMapping("/delete")
@Operation(summary = "删除板材信息表 plate_{N}") @Operation(summary = "删除板材信息")
@Parameters({ @Parameters({
@Parameter(name = "id", description = "编号", required = true), @Parameter(name = "id", description = "编号", required = true),
@Parameter(name = "organId", description = "板材所属组织ID") @Parameter(name = "organId", description = "板材所属组织ID")
@@ -74,7 +74,7 @@ public class PlateController {
} }
@GetMapping("/get") @GetMapping("/get")
@Operation(summary = "获得板材信息表 plate_{N}") @Operation(summary = "获得板材信息")
@Parameter(name = "id", description = "编号", required = true, example = "1024") @Parameter(name = "id", description = "编号", required = true, example = "1024")
// @PreAuthorize("@ss.hasPermission('manage:plate:query')") // @PreAuthorize("@ss.hasPermission('manage:plate:query')")
@PreAuthorize("@ss.hasAnyPermissions('manage:plate:query','base:plate:query')") @PreAuthorize("@ss.hasAnyPermissions('manage:plate:query','base:plate:query')")
@@ -84,7 +84,7 @@ public class PlateController {
} }
@GetMapping("/page") @GetMapping("/page")
@Operation(summary = "获得板材信息表 plate_{N}分页") @Operation(summary = "获得板材信息分页")
// @PreAuthorize("@ss.hasPermission('manage:plate:query')") // @PreAuthorize("@ss.hasPermission('manage:plate:query')")
@PreAuthorize("@ss.hasAnyPermissions('manage:plate:query','base:plate:query')") @PreAuthorize("@ss.hasAnyPermissions('manage:plate:query','base:plate:query')")
public CommonResult<PageResult<PlateRespVO>> getPlatePage(@Valid PlatePageReqVO pageReqVO) { public CommonResult<PageResult<PlateRespVO>> getPlatePage(@Valid PlatePageReqVO pageReqVO) {
@@ -37,7 +37,6 @@ public class PlateImportExcelVO {
private String color; private String color;
@ExcelProperty("纹理") @ExcelProperty("纹理")
@NotEmpty(message = "纹路不能为空,填 有 无")
private String texture; private String texture;
@ExcelProperty("宽度") @ExcelProperty("宽度")
@@ -30,7 +30,6 @@ public class PlateSaveReqVO {
private String color; private String color;
@Schema(description = "纹理", requiredMode = Schema.RequiredMode.REQUIRED) @Schema(description = "纹理", requiredMode = Schema.RequiredMode.REQUIRED)
@NotEmpty(message = "纹理路不能为空")
private Boolean texture; private Boolean texture;
@Schema(description = "宽度", requiredMode = Schema.RequiredMode.REQUIRED) @Schema(description = "宽度", requiredMode = Schema.RequiredMode.REQUIRED)
@@ -3,6 +3,7 @@ package com.cf.imes.module.manage.service.plate;
import cn.hutool.core.collection.CollUtil; import cn.hutool.core.collection.CollUtil;
import com.cf.imes.framework.common.exception.util.ServiceExceptionUtil; import com.cf.imes.framework.common.exception.util.ServiceExceptionUtil;
import com.cf.imes.framework.common.pojo.CommonResult; import com.cf.imes.framework.common.pojo.CommonResult;
import com.cf.imes.framework.organ.core.aop.OrganIgnore;
import com.cf.imes.framework.organ.core.context.OrganContextHolder; import com.cf.imes.framework.organ.core.context.OrganContextHolder;
import com.cf.imes.module.manage.controller.admin.plate.vo.plate.PlateImportExcelVO; import com.cf.imes.module.manage.controller.admin.plate.vo.plate.PlateImportExcelVO;
import com.cf.imes.module.manage.controller.admin.plate.vo.plate.PlateImportRespVO; import com.cf.imes.module.manage.controller.admin.plate.vo.plate.PlateImportRespVO;
@@ -43,6 +44,7 @@ public class PlateServiceImpl implements PlateService {
private OrganApi organApi; private OrganApi organApi;
@Override @Override
@OrganIgnore
public Long createPlate(PlateSaveReqVO createReqVO) { public Long createPlate(PlateSaveReqVO createReqVO) {
PlateDO plate = BeanUtils.toBean(createReqVO, PlateDO.class); PlateDO plate = BeanUtils.toBean(createReqVO, PlateDO.class);
if (createReqVO.getOrganId() != null && createReqVO.getOrganId() != 0 ){ if (createReqVO.getOrganId() != null && createReqVO.getOrganId() != 0 ){
@@ -62,6 +64,7 @@ public class PlateServiceImpl implements PlateService {
} }
@Override @Override
@OrganIgnore
@Transactional(rollbackFor = Exception.class) @Transactional(rollbackFor = Exception.class)
public void updatePlate(PlateSaveReqVO updateReqVO) { public void updatePlate(PlateSaveReqVO updateReqVO) {
// 更新 判断是否有组织id // 更新 判断是否有组织id
@@ -77,6 +80,7 @@ public class PlateServiceImpl implements PlateService {
} }
@Override @Override
@OrganIgnore
@Transactional(rollbackFor = Exception.class) @Transactional(rollbackFor = Exception.class)
public void deletePlate(Long id,Long organId) { public void deletePlate(Long id,Long organId) {
if (organId == null || organId == 0){ if (organId == null || organId == 0){
@@ -105,6 +109,7 @@ public class PlateServiceImpl implements PlateService {
} }
@Override @Override
@OrganIgnore
public PageResult<PlateDO> getPlatePage(PlatePageReqVO pageReqVO) { public PageResult<PlateDO> getPlatePage(PlatePageReqVO pageReqVO) {
if (pageReqVO.getOrganId() == null || pageReqVO.getOrganId() == 0){ if (pageReqVO.getOrganId() == null || pageReqVO.getOrganId() == 0){
pageReqVO.setOrganId(OrganContextHolder.getOrganId()); pageReqVO.setOrganId(OrganContextHolder.getOrganId());
@@ -114,9 +119,10 @@ public class PlateServiceImpl implements PlateService {
@Override @Override
@OrganIgnore
@Transactional(rollbackFor = Exception.class) // 添加事务,异常则回滚所有导入 @Transactional(rollbackFor = Exception.class) // 添加事务,异常则回滚所有导入
public PlateImportRespVO importPlateList(List<PlateImportExcelVO> importPlates, boolean isUpdateSupport , Long organId) { public PlateImportRespVO importPlateList(List<PlateImportExcelVO> importPlates, boolean isUpdateSupport , Long organId) {
System.out.println(" importPlates " + importPlates); // System.out.println(" importPlates " + importPlates);
// if (CollUtil.isEmpty(importPlates)) { // if (CollUtil.isEmpty(importPlates)) {
// throw ServiceExceptionUtil.exception(ErrorCodeConstants.PLATE_IMPORT_LIST_IS_EMPTY); // throw ServiceExceptionUtil.exception(ErrorCodeConstants.PLATE_IMPORT_LIST_IS_EMPTY);
// } // }