Browse Source

配送、签收列表库存品tabs调整

training
kilo 1 year ago
parent
commit
6a891213fb
  1. 3
      blade-service-api/logpm-distribution-api/src/main/java/com/logpm/distribution/vo/DistributionAddvalueVO.java
  2. 15
      blade-service-api/logpm-distribution-api/src/main/java/com/logpm/distribution/vo/DistributionReservationStocklistVO.java
  3. 17
      blade-service/logpm-distribution/src/main/java/com/logpm/distribution/appcontroller/DistributionAddvalueAppController.java
  4. 17
      blade-service/logpm-distribution/src/main/java/com/logpm/distribution/controller/DistributionSignforController.java
  5. 180
      blade-service/logpm-distribution/src/main/java/com/logpm/distribution/controller/DistributionStockArticleController.java
  6. 6
      blade-service/logpm-distribution/src/main/java/com/logpm/distribution/mapper/DistributionAddvalueMapper.java
  7. 17
      blade-service/logpm-distribution/src/main/java/com/logpm/distribution/mapper/DistributionAddvalueMapper.xml
  8. 7
      blade-service/logpm-distribution/src/main/java/com/logpm/distribution/mapper/DistributionAddvaluePackageMapper.xml
  9. 7
      blade-service/logpm-distribution/src/main/java/com/logpm/distribution/mapper/DistributionParcelListMapper.java
  10. 65
      blade-service/logpm-distribution/src/main/java/com/logpm/distribution/mapper/DistributionParcelListMapper.xml
  11. 2
      blade-service/logpm-distribution/src/main/java/com/logpm/distribution/mapper/DistributionReservationMapper.java
  12. 67
      blade-service/logpm-distribution/src/main/java/com/logpm/distribution/mapper/DistributionReservationMapper.xml
  13. 62
      blade-service/logpm-distribution/src/main/java/com/logpm/distribution/mapper/DistributionReservationPackageMapper.xml
  14. 8
      blade-service/logpm-distribution/src/main/java/com/logpm/distribution/mapper/DistributionSignforMapper.java
  15. 25
      blade-service/logpm-distribution/src/main/java/com/logpm/distribution/mapper/DistributionSignforMapper.xml
  16. 7
      blade-service/logpm-distribution/src/main/java/com/logpm/distribution/service/IDistributionAddvalueService.java
  17. 13
      blade-service/logpm-distribution/src/main/java/com/logpm/distribution/service/IDistributionSignforService.java
  18. 9
      blade-service/logpm-distribution/src/main/java/com/logpm/distribution/service/IDistributionStockArticleService.java
  19. 41
      blade-service/logpm-distribution/src/main/java/com/logpm/distribution/service/impl/DistributionAddvalueServiceImpl.java
  20. 2
      blade-service/logpm-distribution/src/main/java/com/logpm/distribution/service/impl/DistributionDeliveryListServiceImpl.java
  21. 15
      blade-service/logpm-distribution/src/main/java/com/logpm/distribution/service/impl/DistributionReservationServiceImpl.java
  22. 46
      blade-service/logpm-distribution/src/main/java/com/logpm/distribution/service/impl/DistributionSignforServiceImpl.java
  23. 109
      blade-service/logpm-distribution/src/main/java/com/logpm/distribution/service/impl/DistributionStockArticleServiceImpl.java

3
blade-service-api/logpm-distribution-api/src/main/java/com/logpm/distribution/vo/DistributionAddvalueVO.java

@ -44,8 +44,11 @@ public class DistributionAddvalueVO extends DistributionAddvalueEntity {
private Integer num;
private Integer floolNum;
private BigDecimal fee;
private Double distance;

15
blade-service-api/logpm-distribution-api/src/main/java/com/logpm/distribution/vo/DistributionReservationStocklistVO.java

@ -21,6 +21,8 @@ import io.swagger.annotations.ApiModelProperty;
import lombok.Data;
import lombok.EqualsAndHashCode;
import java.util.List;
/**
* 预约库存中间表 视图实体类
*
@ -73,6 +75,12 @@ public class DistributionReservationStocklistVO extends DistributionReservationS
@ApiModelProperty(value = "所属商场")
private String shoppingMall;
/**
* 库存品装车数
*/
@ApiModelProperty(value = "库存品装车数")
private Integer loadedinNumber;
/**
* 商场名称
*/
@ -124,4 +132,11 @@ public class DistributionReservationStocklistVO extends DistributionReservationS
@ApiModelProperty(value = "签收时间")
private String signTime;
/**
* 签收时间
*/
@ApiModelProperty(value = "签收时间")
private List<DisStockListDetailVO> detailVOS;
}

17
blade-service/logpm-distribution/src/main/java/com/logpm/distribution/appcontroller/DistributionAddvalueAppController.java

@ -84,7 +84,7 @@ public class DistributionAddvalueAppController {
}
/**
* 扫描接口
* 保存增值服务
*/
@PostMapping("/saveAddvalueInfo")
@ApiOperationSupport(order = 1)
@ -96,7 +96,7 @@ public class DistributionAddvalueAppController {
/**
* 扫描接口
* 编辑保存
*/
@PostMapping("/updateAddvalueInfo")
@ApiOperationSupport(order = 1)
@ -121,6 +121,19 @@ public class DistributionAddvalueAppController {
/**
* 查询编辑增值服务数据
*/
@PostMapping("/addvalueInfo")
@ApiOperationSupport(order = 1)
@ApiOperation(value = "查询增值服务列表", notes = "DistributionAppDeliveryListDTO")
public R addvalueInfo(@Valid @RequestBody DistributionAppAddvalueDTO distributionAppAddvalueDTO) {
R r =distributionAddvalueService.addvalueInfo(distributionAppAddvalueDTO);
return r;
}
}

17
blade-service/logpm-distribution/src/main/java/com/logpm/distribution/controller/DistributionSignforController.java

@ -19,14 +19,13 @@ package com.logpm.distribution.controller;
import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
import com.baomidou.mybatisplus.core.metadata.IPage;
import com.github.xiaoymin.knife4j.annotations.ApiOperationSupport;
import com.logpm.distribution.dto.DistributionReservationStocklistDTO;
import com.logpm.distribution.dto.DistributionSignforDTO;
import com.logpm.distribution.entity.DistributionSignforEntity;
import com.logpm.distribution.excel.DistributionSignforExcel;
import com.logpm.distribution.service.IDistributionReservationService;
import com.logpm.distribution.service.IDistributionSignforService;
import com.logpm.distribution.vo.DistributionParcelListVO;
import com.logpm.distribution.vo.DistributionSignforVO;
import com.logpm.distribution.vo.DistributionSignforsnmbVO;
import com.logpm.distribution.vo.*;
import io.swagger.annotations.Api;
import io.swagger.annotations.ApiOperation;
import io.swagger.annotations.ApiParam;
@ -107,6 +106,18 @@ public class DistributionSignforController extends BladeController {
return R.data(distributionSignforsnmbVO);
}
/**
* 签收详情包件信息
*/
@GetMapping("/signforInventoryList")
@ApiOperationSupport(order = 1)
@ApiOperation(value = "详情", notes = "传入distributionSignfor")
public R<List<DistributionReservationStocklistVO>> signforInventoryList(Long signforId) {
List<DistributionReservationStocklistVO> distributionReservationStocklistDTOS= distributionSignforService.signforInventoryList(signforId);
return R.data(distributionReservationStocklistDTOS);
}
/**
* 签收管理 分页
*/

180
blade-service/logpm-distribution/src/main/java/com/logpm/distribution/controller/DistributionStockArticleController.java

@ -124,91 +124,98 @@ public class DistributionStockArticleController extends BladeController {
@ApiOperationSupport(order = 2)
@ApiOperation(value = "分页", notes = "传入distributionStockArticle")
public R<IPage<DistributionStockArticleVO>> selectStockArticleInfoList(@ApiIgnore @RequestParam Map<String, Object> distributionStockArticle, Query query) {
BasicdataWarehouseEntity myCurrentWarehouse = warehouseClient.getMyCurrentWarehouse();
if (Func.isEmpty(myCurrentWarehouse)){
return R.fail("无仓库信息!!!");
}
Object orderCodeNum = distributionStockArticle.get("orderCodeNum");
distributionStockArticle.remove("orderCodeNum");
Object waybillNum = distributionStockArticle.get("waybillNum");
Object o = distributionStockArticle.get("orderCode");
distributionStockArticle.remove("orderCode");
Object o2 = distributionStockArticle.get("startDate");
Object o1 = distributionStockArticle.get("entDate");
String orderIds = (String) distributionStockArticle.get("orderIds");
String customerName = (String) distributionStockArticle.get("customerName");
String reservationStatus = (String) distributionStockArticle.get("reservationStatus");
String warehouseEntryTime = (String) distributionStockArticle.get("warehouseEntryTime");
String customerTelephone = (String) distributionStockArticle.get("customerTelephone");
String completeSet = (String) distributionStockArticle.get("completeSet");
String freezeStatus = (String) distributionStockArticle.get("freezeStatus");
Object d = distributionStockArticle.get("id");
distributionStockArticle.remove("id");
distributionStockArticle.remove("startDate");
distributionStockArticle.remove("entDate");
distributionStockArticle.remove("orderIds");
// distributionStockArticle.remove("pageSize");
// distributionStockArticle.remove("currentPage");
// distributionStockArticle.remove("total");
QueryWrapper<DistributionStockArticleEntity> queryWrapper = Condition.getQueryWrapper(distributionStockArticle, DistributionStockArticleEntity.class);
LambdaQueryWrapper<DistributionStockArticleEntity> lambda = Wrappers.<DistributionStockArticleEntity>query().lambda();
queryWrapper.ne("reservation_status","30");
queryWrapper.lambda().eq(DistributionStockArticleEntity::getWarehouseId,myCurrentWarehouse.getId());
if(Func.isNotEmpty(o)){
queryWrapper.in("order_code",String.valueOf(o).split(","));
}
if(Func.isNotEmpty(reservationStatus)){
queryWrapper.eq("reservation_status",reservationStatus);
}
if(Func.isNotEmpty(warehouseEntryTime)){
queryWrapper.apply("datediff(warehouse_entry_time,{0} ) = 0",warehouseEntryTime);
}
if(Func.isNotEmpty(freezeStatus)){
queryWrapper.eq("freeze_status",freezeStatus);
}
if(Func.isNotEmpty(completeSet)){
queryWrapper.eq("complete_set",completeSet);
}
if(ObjectUtil.isNotEmpty(d)){
queryWrapper.in("id",String.valueOf(d).split(","));
}
if(ObjectUtil.isNotEmpty(o2)){
queryWrapper.between("warehouse_entry_time",o2,o1);
}
if(Func.isNotEmpty(orderIds)){
queryWrapper.notIn(Func.isNotEmpty(orderIds),"id",Func.toLongList(orderIds));
}
R r = distributionStockArticleService.selectStockArticleInfoList(distributionStockArticle,query);
// BasicdataWarehouseEntity myCurrentWarehouse = warehouseClient.getMyCurrentWarehouse();
// if (Func.isEmpty(myCurrentWarehouse)){
// return R.fail("无仓库信息!!!");
// }
// Object orderCodeNum = distributionStockArticle.get("orderCodeNum");
// distributionStockArticle.remove("orderCodeNum");
// Object waybillNum = distributionStockArticle.get("waybillNum");
// Object o = distributionStockArticle.get("orderCode");
// distributionStockArticle.remove("orderCode");
// Object o2 = distributionStockArticle.get("startDate");
// Object o1 = distributionStockArticle.get("entDate");
// String orderIds = (String) distributionStockArticle.get("orderIds");
// String customerName = (String) distributionStockArticle.get("customerName");
// String reservationStatus = (String) distributionStockArticle.get("reservationStatus");
// String warehouseEntryTime = (String) distributionStockArticle.get("warehouseEntryTime");
// String customerTelephone = (String) distributionStockArticle.get("customerTelephone");
// String completeSet = (String) distributionStockArticle.get("completeSet");
// String freezeStatus = (String) distributionStockArticle.get("freezeStatus");
// Object d = distributionStockArticle.get("id");
// distributionStockArticle.remove("id");
// distributionStockArticle.remove("startDate");
// distributionStockArticle.remove("entDate");
// distributionStockArticle.remove("orderIds");
//// distributionStockArticle.remove("pageSize");
//// distributionStockArticle.remove("currentPage");
//// distributionStockArticle.remove("total");
// QueryWrapper<DistributionStockArticleEntity> queryWrapper = Condition.getQueryWrapper(distributionStockArticle, DistributionStockArticleEntity.class);
// LambdaQueryWrapper<DistributionStockArticleEntity> lambda = Wrappers.<DistributionStockArticleEntity>query().lambda();
// queryWrapper.ne("reservation_status","30");
// queryWrapper.lambda().eq(DistributionStockArticleEntity::getWarehouseId,myCurrentWarehouse.getId());
// if(Func.isNotEmpty(o)){
// queryWrapper.in("order_code",String.valueOf(o).split(","));
// }
// if(Func.isNotEmpty(reservationStatus)){
// queryWrapper.eq("reservation_status",reservationStatus);
// }
// if(Func.isNotEmpty(warehouseEntryTime)){
// queryWrapper.apply("datediff(warehouse_entry_time,{0} ) = 0",warehouseEntryTime);
// }
// if(Func.isNotEmpty(freezeStatus)){
// queryWrapper.eq("freeze_status",freezeStatus);
// }
// if(Func.isNotEmpty(completeSet)){
// queryWrapper.eq("complete_set",completeSet);
// }
// if(ObjectUtil.isNotEmpty(d)){
// queryWrapper.in("id",String.valueOf(d).split(","));
// }
// if(ObjectUtil.isNotEmpty(o2)){
// queryWrapper.between("warehouse_entry_time",o2,o1);
// }
// if(Func.isNotEmpty(orderIds)){
// queryWrapper.notIn("id",Func.toLongList(orderIds));
// queryWrapper.notIn(Func.isNotEmpty(orderIds),"id",Func.toLongList(orderIds));
// }
if(Func.isNotEmpty(customerName)){
queryWrapper.like("customer_name",customerName);
}
if(Func.isNotEmpty(customerTelephone)){
queryWrapper.like("customer_telephone",customerTelephone);
}
if(Func.isNotEmpty(orderCodeNum)){
String anumbering = orderCodeNum.toString();
List<String> list = CommonUtil.stringNum(anumbering);
if(list.size() > 1){
queryWrapper.in("order_code",list);
}else{
queryWrapper.like("order_code",anumbering);
}
}
if(Func.isNotEmpty(waybillNum)){
String waybill = waybillNum.toString();
List<String> list = CommonUtil.stringNum(waybill);
if(list.size() > 1){
queryWrapper.in("waybill_number",list);
}else{
queryWrapper.like("waybill_number",waybill);
}
}
queryWrapper.in("order_status",aaa);
IPage<DistributionStockArticleEntity> pages = distributionStockArticleService.page(Condition.getPage(query), queryWrapper);
IPage<DistributionStockArticleVO> distributionStockArticleVOIPage = distributionStockArticleService.handlePackage(DistributionStockArticleWrapper.build().pageVO(pages));
return R.data(distributionStockArticleVOIPage);
//// if(Func.isNotEmpty(orderIds)){
//// queryWrapper.notIn("id",Func.toLongList(orderIds));
//// }
// if(Func.isNotEmpty(customerName)){
// queryWrapper.like("customer_name",customerName);
// }
// if(Func.isNotEmpty(customerTelephone)){
// queryWrapper.like("customer_telephone",customerTelephone);
// }
// if(Func.isNotEmpty(orderCodeNum)){
// String anumbering = orderCodeNum.toString();
// List<String> list = CommonUtil.stringNum(anumbering);
// if(list.size() > 1){
// queryWrapper.in("order_code",list);
// }else{
// queryWrapper.like("order_code",anumbering);
// }
// }
// if(Func.isNotEmpty(waybillNum)){
// String waybill = waybillNum.toString();
// List<String> list = CommonUtil.stringNum(waybill);
// if(list.size() > 1){
// queryWrapper.in("waybill_number",list);
// }else{
// queryWrapper.like("waybill_number",waybill);
// }
// }
// queryWrapper.in("order_status",aaa);
// IPage<DistributionStockArticleEntity> pages = distributionStockArticleService.page(Condition.getPage(query), queryWrapper);
// IPage<DistributionStockArticleVO> distributionStockArticleVOIPage = distributionStockArticleService.handlePackage(DistributionStockArticleWrapper.build().pageVO(pages));
return r;
}
@ -220,7 +227,10 @@ public class DistributionStockArticleController extends BladeController {
@ApiOperationSupport(order = 2)
@ApiOperation(value = "分页", notes = "传入distributionStockArticle")
public R<IPage<DistributionStockArticleVO>> clientList(@ApiIgnore DistributionStockArticleVO distributionStockArticle, Query query) {
BasicdataWarehouseEntity myCurrentWarehouse = warehouseClient.getMyCurrentWarehouse();
if (Func.isEmpty(myCurrentWarehouse)){
return R.fail("无仓库信息!!!");
}
//获取当前登录人仓库
// List<BasicdataWarehouseEntity> myWatchWarehouse = warehouseClient.getMyWatchWarehouse();
// List<Long> collect = myWatchWarehouse.stream()
@ -231,7 +241,7 @@ public class DistributionStockArticleController extends BladeController {
DistributionStockArticleWrapper.build().pageVO(pages);
return R.data( DistributionStockArticleWrapper.build().pageVO(pages));
return R.data(DistributionStockArticleWrapper.build().pageVO(pages));
}

6
blade-service/logpm-distribution/src/main/java/com/logpm/distribution/mapper/DistributionAddvalueMapper.java

@ -67,6 +67,12 @@ public interface DistributionAddvalueMapper extends BaseMapper<DistributionAddva
*/
void deleteAddvalue(@Param("reservationId") Long reservationId,@Param("addvalueType") String addvalueType);
/**
* 查询增值服务列表
* @param reservationId
*/
List<DistributionAddvalueVO> addvalueInfo(@Param("reservationId")Long reservationId);
// /**
// * 删除增值服务
// * @param reservationId

17
blade-service/logpm-distribution/src/main/java/com/logpm/distribution/mapper/DistributionAddvalueMapper.xml

@ -24,6 +24,23 @@
<result column="reserve5" property="reserve5"/>
<result column="fee" property="fee"/>
</resultMap>
<select id="addvalueInfo" resultType="com.logpm.distribution.vo.DistributionAddvalueVO">
SELECT DISTINCT
lda.addvalue_id,
group_concat(DISTINCT ldad.fee) AS fee,
group_concat(DISTINCT ldad.num) AS num,
group_concat(DISTINCT ldad.flool_num) AS floolNum,
group_concat(DISTINCT ldad.distance) AS distance,
group_concat( ldap.id SEPARATOR ',' ) AS packageListIds
FROM
logpm_distribution_addvalue lda
INNER JOIN logpm_distribution_addvalue_detail ldad ON lda.id = ldad.addvalue_id
INNER JOIN logpm_distribution_addvalue_package ldap ON ldad.id = ldap.addvalue_detail_id
WHERE lda.ref_id = #{reservationId}
GROUP BY
lda.id
</select>
<delete id="deleteAddvalue">
DELETE FROM logpm_distribution_addvalue WHERE ref_id = #{reservationId} and addvalue_id = #{addvalueType}
</delete>

7
blade-service/logpm-distribution/src/main/java/com/logpm/distribution/mapper/DistributionAddvaluePackageMapper.xml

@ -35,18 +35,13 @@
DELETE FROM logpm_diatribution_addvalue_package WHERE reservation_id = #{reservationId} and addvalue_detail_id = #{addvalueDetailId}
</delete>
<delete id="deleteAddvaluePackage">
DELETE FROM logpm_diatribution_addvalue_package WHERE reservation_id = #{reservationId} and package_id = #{packageId}
DELETE FROM logpm_diatribution_addvalue_package WHERE reservation_id = #{reservationId} and package_id = #{packageId}
</delete>
<select id="selectDistributionAddvaluePackagePage" resultMap="distributionAddvaluePackageResultMap">
select * from logpm_distribution_addvalue_package where is_deleted = 0
</select>
<select id="exportDistributionAddvaluePackage"
resultType="com.logpm.distribution.excel.DistributionAddvaluePackageExcel">
SELECT * FROM logpm_distribution_addvalue_package ${ew.customSqlSegment}
</select>
</mapper>

7
blade-service/logpm-distribution/src/main/java/com/logpm/distribution/mapper/DistributionParcelListMapper.java

@ -93,4 +93,11 @@ public interface DistributionParcelListMapper extends BaseMapper<DistributionPar
List<DistributionParcelListEntity> findALLNoUpShelfPackageByOrderCode(@Param("orderCode") String orderCode,@Param("orderCode") Long warehouseId);
IPage<DistributionParcelListEntity> pageOweList(IPage<Object> page,@Param("param") DistributionParcelListDTO parcelListEntity);
/**
* 查询包件信息包含库位和托盘信息
* @param id
* @return
*/
List<DistributionParcelListEntity> getPackageList(@Param("stockArticleId") Long id);
}

65
blade-service/logpm-distribution/src/main/java/com/logpm/distribution/mapper/DistributionParcelListMapper.xml

@ -379,5 +379,70 @@
</where>
GROUP BY ldpl.id
</select>
<select id="getPackageList" resultType="com.logpm.distribution.entity.DistributionParcelListEntity">
SELECT
ldpl.id,
ldpl.tenant_id,
ldpl.create_user,
ldpl.create_time,
ldpl.update_user,
ldpl.update_time,
ldpl.status,
ldpl.is_deleted,
ldpl.create_dept,
ldpl.reserve1,
ldpl.reserve2,
ldpl.reserve3,
ldpl.reserve4,
ldpl.reserve5,
ldpl.warehouse_id,
ldpl.warehouse,
ldpl.conditions,
ldpl.order_package_code,
ldpl.cargo_title,
ldpl.shelf_title,
lwtg.tray_code AS pallet,
lwug.allocation_title AS goodsAllocation,
ldpl.firsts_code,
ldpl.firsts,
ldpl.second_code,
ldpl.second,
ldpl.third_code,
ldpl.third_product,
ldpl.quantity,
ldpl.train_number,
ldpl.stock_article_id,
ldpl.order_code,
ldpl.service_number,
ldpl.material_id,
ldpl.material_name,
ldpl.material_code,
ldpl.material_unit,
ldpl.brand_id,
ldpl.brand_name,
ldpl.order_package_status,
ldpl.order_package_freeze_status,
ldpl.order_package_grounding_status,
ldpl.order_package_stockup_status,
ldpl.order_package_reservation_status,
ldpl.order_package_loading_status,
ldpl.waybill_number,
ldpl.waybill_id,
ldpl.warehouse_entry_time_end,
ldpl.dealer_name,
ldpl.dealer_code,
ldpl.send_warehouse_id,
ldpl.send_warehouse_name,
ldpl.accept_warehouse_id,
ldpl.accept_warehouse_name,
ldpl.order_package_delivery_status
FROM
logpm_distribution_parcel_list AS ldpl
LEFT JOIN logpm_warehouse_tray_goods AS lwtg ON ldpl.id = lwtg.association_id AND lwtg.association_type = 3
LEFT JOIN logpm_warehouse_updown_goods AS lwug ON ldpl.id = lwtg.association_id AND lwtg.association_type = 3
WHERE
ldpl.stock_article_id = #{stockArticleId} and ldpl.order_package_reservation_status in ('10','20')
</select>
</mapper>

2
blade-service/logpm-distribution/src/main/java/com/logpm/distribution/mapper/DistributionReservationMapper.java

@ -134,7 +134,7 @@ public interface DistributionReservationMapper extends BaseMapper<DistributionRe
* @param id1
* @return
*/
List<DistributionReservationPackageEntity> selectPackageByReservationAndStockArticle(@Param("reservationId") Long id,@Param("stockArticleId") Long id1);
List<DistributionParcelListEntity> selectPackageByReservationAndStockArticle(@Param("reservationId") Long id,@Param("stockArticleId") Long id1);
/**
* 查询预约的订单中间表

67
blade-service/logpm-distribution/src/main/java/com/logpm/distribution/mapper/DistributionReservationMapper.xml

@ -593,22 +593,75 @@
</where>
</select>
<select id="selectPackageByReservationAndStockArticle"
resultType="com.logpm.distribution.entity.DistributionReservationPackageEntity">
resultType="com.logpm.distribution.entity.DistributionParcelListEntity">
SELECT
ldpl.reservation_id,
ldpl.id,
ldpl.tenant_id,
ldpl.create_user,
ldpl.create_time,
ldpl.update_user,
ldpl.update_time,
ldpl.STATUS,
ldpl.is_deleted,
ldpl.create_dept,
ldpl.reserve1,
ldpl.reserve2,
ldpl.reserve3,
ldpl.reserve4,
ldpl.reserve5,
ldpl.warehouse_id,
ldpl.warehouse,
ldpl.conditions,
ldpl.order_package_code,
ldpl.cargo_title,
ldpl.shelf_title,
lwtg.tray_code AS pallet,
lwug.allocation_title AS goodsAllocation,
ldpl.firsts_code,
ldpl.firsts,
ldpl.second_code,
ldpl.SECOND,
ldpl.third_code,
ldpl.third_product,
ldpl.quantity,
ldpl.train_number,
ldpl.stock_article_id,
ldpl.parce_list_id,
ldpl.packet_bar_status
ldpl.order_code,
ldpl.service_number,
ldpl.material_id,
ldpl.material_name,
ldpl.material_code,
ldpl.material_unit,
ldpl.brand_id,
ldpl.brand_name,
ldpl.order_package_status,
ldpl.order_package_freeze_status,
ldpl.order_package_grounding_status,
ldpl.order_package_stockup_status,
ldpl.order_package_reservation_status,
ldpl.order_package_loading_status,
ldpl.waybill_number,
ldpl.waybill_id,
ldpl.warehouse_entry_time_end,
ldpl.dealer_name,
ldpl.dealer_code,
ldpl.send_warehouse_id,
ldpl.send_warehouse_name,
ldpl.accept_warehouse_id,
ldpl.accept_warehouse_name,
ldpl.order_package_delivery_status
FROM
logpm_distribution_reservation_package AS ldpl
logpm_distribution_reservation_package AS ldrp
LEFT JOIN logpm_distribution_parcel_list AS ldpl ON ldpl.id = ldrp.parce_list_id
LEFT JOIN logpm_warehouse_tray_goods AS lwtg ON ldpl.id = lwtg.association_id and lwtg.association_type = 3
LEFT JOIN logpm_warehouse_updown_goods AS lwug ON ldpl.id = lwug.association_id and lwug.association_type = 3
<where>
and packet_bar_status != 2
<if test="reservationId !=null and reservationId!= ''">
and ldpl.reservation_id = #{reservationId}
and ldrp.reservation_id = #{reservationId}
</if>
<if test="stockArticleId !=null and stockArticleId!= ''">
and ldpl.stock_article_id = #{stockArticleId}
and ldrp.stock_article_id = #{stockArticleId}
</if>
</where>
</select>

62
blade-service/logpm-distribution/src/main/java/com/logpm/distribution/mapper/DistributionReservationPackageMapper.xml

@ -86,10 +86,66 @@ WHERE
<select id="getReservationPackageList" resultType="com.logpm.distribution.entity.DistributionParcelListEntity">
SELECT
ldpl.*
ldpl.id,
ldpl.tenant_id,
ldpl.create_user,
ldpl.create_time,
ldpl.update_user,
ldpl.update_time,
ldpl.STATUS,
ldpl.is_deleted,
ldpl.create_dept,
ldpl.reserve1,
ldpl.reserve2,
ldpl.reserve3,
ldpl.reserve4,
ldpl.reserve5,
ldpl.warehouse_id,
ldpl.warehouse,
ldpl.conditions,
ldpl.order_package_code,
ldpl.cargo_title,
ldpl.shelf_title,
lwtg.tray_code AS pallet,
lwug.allocation_title AS goodsAllocation,
ldpl.firsts_code,
ldpl.firsts,
ldpl.second_code,
ldpl.SECOND,
ldpl.third_code,
ldpl.third_product,
ldpl.quantity,
ldpl.train_number,
ldpl.stock_article_id,
ldpl.order_code,
ldpl.service_number,
ldpl.material_id,
ldpl.material_name,
ldpl.material_code,
ldpl.material_unit,
ldpl.brand_id,
ldpl.brand_name,
ldpl.order_package_status,
ldpl.order_package_freeze_status,
ldpl.order_package_grounding_status,
ldpl.order_package_stockup_status,
ldpl.order_package_reservation_status,
ldpl.order_package_loading_status,
ldpl.waybill_number,
ldpl.waybill_id,
ldpl.warehouse_entry_time_end,
ldpl.dealer_name,
ldpl.dealer_code,
ldpl.send_warehouse_id,
ldpl.send_warehouse_name,
ldpl.accept_warehouse_id,
ldpl.accept_warehouse_name,
ldpl.order_package_delivery_status
FROM
`logpm_distribution_reservation_package` ldrp
INNER JOIN logpm_distribution_parcel_list ldpl ON ldrp.parce_list_id = ldpl.id
logpm_distribution_reservation_package AS ldrp
LEFT JOIN logpm_distribution_parcel_list AS ldpl ON ldpl.id = ldrp.parce_list_id
LEFT JOIN logpm_warehouse_tray_goods AS lwtg ON ldpl.id = lwtg.association_id and lwtg.association_type = 3
LEFT JOIN logpm_warehouse_updown_goods AS lwug ON ldpl.id = lwug.association_id and lwug.association_type = 3
<where>
ldrp.packet_bar_status != 2
<if test="id != '' and id !=null">

8
blade-service/logpm-distribution/src/main/java/com/logpm/distribution/mapper/DistributionSignforMapper.java

@ -24,6 +24,7 @@ import com.logpm.distribution.dto.app.DistributionAppDeliveryListDTO;
import com.logpm.distribution.entity.DistributionParcelListEntity;
import com.logpm.distribution.entity.DistributionSignforEntity;
import com.logpm.distribution.excel.DistributionSignforExcel;
import com.logpm.distribution.vo.DistributionReservationStocklistVO;
import com.logpm.distribution.vo.DistributionSignforVO;
import com.logpm.distribution.vo.DistributionStockArticleVO;
import com.logpm.distribution.vo.app.DistributionAppDeliveryListVO;
@ -210,4 +211,11 @@ public interface DistributionSignforMapper extends BaseMapper<DistributionSignfo
* @return
*/
List<DistributionParcelListEntity> getSignforPackageList(@Param("reservationId") Long reservationId);
/**
*
* @param signforId
* @return
*/
List<DistributionReservationStocklistVO> selectInventory(@Param("signforId")Long signforId);
}

25
blade-service/logpm-distribution/src/main/java/com/logpm/distribution/mapper/DistributionSignforMapper.xml

@ -839,4 +839,29 @@
LEFT JOIN logpm_distribution_parcel_list AS ldpl ON ldrp.parce_list_id = ldpl.id
where ldrp.reservation_id = #{reservationId} and ldrp.packet_bar_status in ('1','3')
</select>
<select id="selectInventory" resultType="com.logpm.distribution.vo.DistributionReservationStocklistVO">
SELECT
ldrs.reservation_num AS reservationNum,
ldsl.description_goods AS descriptionGoods,
ldsl.cargo_number AS cargoNumber,
ldsl.cargo_norms AS cargoNorms,
ldsl.cargo_unit AS cargoUnit,
lds.loadedin_number AS loadedinNumber,
lds.signee_name AS signeeName,
ldrs.loading_status AS loadingStatus,
ldrs.signing_status AS signingStatus,
lds.sjsigning_time AS sjsigningTime,
ldsl.sku AS sku,
lds.reservation_id AS reservationId,
ldrs.stocklist_id As stocklistId
FROM
logpm_distribution_signfor AS lds
LEFT JOIN logpm_distribution_reservation_stocklist AS ldrs ON lds.reservation_id = ldrs.reservation_id
AND ldrs.stock_list_status IN ( '1', '3' )
LEFT JOIN logpm_distribution_stock_list AS ldsl ON ldrs.stocklist_id = ldsl.id
WHERE
lds.id = #{signforId}
</select>
</mapper>

7
blade-service/logpm-distribution/src/main/java/com/logpm/distribution/service/IDistributionAddvalueService.java

@ -96,4 +96,11 @@ public interface IDistributionAddvalueService extends IService<DistributionAddva
* @return
*/
R editAddvalueInfo(DistributionAppAddvalueDTO distributionAppAddvalueDTO);
/**
* 查询增值服务整体列表信息
* @param distributionAppAddvalueDTO
* @return
*/
R addvalueInfo(DistributionAppAddvalueDTO distributionAppAddvalueDTO);
}

13
blade-service/logpm-distribution/src/main/java/com/logpm/distribution/service/IDistributionSignforService.java

@ -19,14 +19,13 @@ package com.logpm.distribution.service;
import com.baomidou.mybatisplus.core.conditions.Wrapper;
import com.logpm.distribution.bean.Resp;
import com.baomidou.mybatisplus.core.metadata.IPage;
import com.logpm.distribution.dto.DistributionReservationStocklistDTO;
import com.logpm.distribution.dto.DistributionSignforDTO;
import com.logpm.distribution.dto.DistrilbutionAppsignforDTO;
import com.logpm.distribution.dto.app.DistributionAppDeliveryListDTO;
import com.logpm.distribution.entity.DistributionSignforEntity;
import com.logpm.distribution.excel.DistributionSignforExcel;
import com.logpm.distribution.vo.DistributionParcelListVO;
import com.logpm.distribution.vo.DistributionSignforVO;
import com.logpm.distribution.vo.DistributionSignforsnmbVO;
import com.logpm.distribution.vo.*;
import com.logpm.distribution.vo.app.DistributionAppDeliveryListVO;
import com.logpm.distribution.vo.app.DistributionAppParcelListVO;
import com.logpm.distribution.vo.app.DistributionAppSignforVO;
@ -136,4 +135,12 @@ public interface IDistributionSignforService extends BaseService<DistributionSig
* @return
*/
List<DistributionParcelListVO> signforPackageList(Long signforId);
/**
* 查询该签收列表的库存品信息
* @param signforId
* @return
*/
List<DistributionReservationStocklistVO> signforInventoryList(Long signforId);
}

9
blade-service/logpm-distribution/src/main/java/com/logpm/distribution/service/IDistributionStockArticleService.java

@ -24,6 +24,7 @@ import com.logpm.distribution.excel.DistributionStockArticleExcel;
import com.logpm.distribution.vo.DistributionStockArticleVO;
import com.logpm.distribution.vo.OrderPackgeCodeDataVO;
import org.springblade.core.mp.base.BaseService;
import org.springblade.core.mp.support.Query;
import org.springblade.core.tool.api.R;
import javax.servlet.http.HttpServletResponse;
@ -126,4 +127,12 @@ public interface IDistributionStockArticleService extends BaseService<Distributi
void updateGroundingStatus(String orderCode, String groundingStatus);
IPage<DistributionStockArticleEntity> pageListOwe(IPage<Object> page,Map<String, Object> distributionStockArticle);
/**
* 订单列表
* @param distributionStockArticle
* @param query
* @return
*/
R selectStockArticleInfoList(Map<String, Object> distributionStockArticle, Query query);
}

41
blade-service/logpm-distribution/src/main/java/com/logpm/distribution/service/impl/DistributionAddvalueServiceImpl.java

@ -16,6 +16,7 @@
*/
package com.logpm.distribution.service.impl;
import com.alibaba.druid.sql.visitor.functions.If;
import com.baomidou.mybatisplus.core.toolkit.Wrappers;
import com.logpm.distribution.bean.Res;
import com.logpm.distribution.bean.Resp;
@ -320,53 +321,44 @@ public class DistributionAddvalueServiceImpl extends BaseServiceImpl<Distributio
DistributionAddvalueDetailEntity addvalueDetailEntity = distributionAddvalueDetailService.getOne(Wrappers.<DistributionAddvalueDetailEntity>query().lambda()
.eq(DistributionAddvalueDetailEntity::getAddvalueId, distributionAddvalueEntity.getId()));
distributionAddvalueMapper.deleteAddvalue(distributionAppAddvalueDTO.getReservationId(),distributionAppAddvalueDTO.getAddvalueType());
distributionAddvalueMapper.deleteAddvalue(distributionAppAddvalueDTO.getReservationId(), distributionAppAddvalueDTO.getAddvalueType());
distributionAddvalueDetailMapper.deleteAddvalueDetail(distributionAddvalueEntity.getId());
distributionAddvaluePackageMapper.deleteAddvaluePackageList(distributionAppAddvalueDTO.getReservationId(),addvalueDetailEntity.getId());
}else {
distributionAddvaluePackageMapper.deleteAddvaluePackageList(distributionAppAddvalueDTO.getReservationId(), addvalueDetailEntity.getId());
} else {
// 查询出原来的包件信息
DistributionAddvalueVO addvalueVO = distributionAddvalueMapper.selectReservationAddvalue(distributionAppAddvalueDTO.getReservationId(), distributionAppAddvalueDTO.getAddvalueType());
String packageListIds = addvalueVO.getPackageListIds();
if (Func.isNotEmpty(packageListIds)){
if (Func.isNotEmpty(packageListIds)) {
List<DistributionAddvaluePackageEntity> distributionAddvaluePackageEntities = distributionAddvaluePackageService.listByIds(Func.toLongList(packageListIds));
Map<Long, List<DistributionAddvaluePackageEntity>> oldPackageList = distributionAddvaluePackageEntities.stream().collect(Collectors.groupingBy(DistributionAddvaluePackageEntity::getPackageId));
Map<Long, List<DistributionAddvaluePackageEntity>> newPackageList = packageEntityList.stream().collect(Collectors.groupingBy(DistributionAddvaluePackageEntity::getPackageId));
newPackageList.forEach((k,v)->{
if (Func.isEmpty(oldPackageList.get(k))){
newPackageList.forEach((k, v) -> {
if (Func.isEmpty(oldPackageList.get(k))) {
//从老的包件中无法进行获取,这里进行包件的新增
DistributionAddvaluePackageEntity distributionAddvaluePackageEntity = v.get(0);
distributionAddvaluePackageEntity.setAddvalueDetailId(distributionAddvaluePackageEntities.get(0).getAddvalueDetailId());
distributionAddvaluePackageService.save(distributionAddvaluePackageEntity);
}else {
} else {
//存在不进行维护
oldPackageList.remove(k);
}
});
if (Func.isEmpty(oldPackageList)){
if (Func.isEmpty(oldPackageList)) {
//进行删除,这里删除的时候需要考虑是否删除增值服务项,是否删除整个关于该客户的增值服务信息
oldPackageList.forEach((m,n)->{
oldPackageList.forEach((m, n) -> {
//进行删除
DistributionAddvaluePackageEntity distributionAddvaluePackageEntity = n.get(0);
distributionAddvaluePackageMapper.deleteAddvaluePackage(distributionAddvaluePackageEntity.getReservationId(),distributionAddvaluePackageEntity.getPackageId());
distributionAddvaluePackageMapper.deleteAddvaluePackage(distributionAddvaluePackageEntity.getReservationId(), distributionAddvaluePackageEntity.getPackageId());
});
}
}
}
return Resp.scanSuccess("保存成功", "保存成功");
}
return null;
}
@Override
public R editAddvalueInfo(DistributionAppAddvalueDTO distributionAppAddvalueDTO) {
DistributionAddvalueVO addvalueVO = distributionAddvalueMapper.selectReservationAddvalue(distributionAppAddvalueDTO.getReservationId(), distributionAppAddvalueDTO.getAddvalueType());
@ -380,4 +372,11 @@ public class DistributionAddvalueServiceImpl extends BaseServiceImpl<Distributio
return R.data(addvalueVO);
}
@Override
public R addvalueInfo(DistributionAppAddvalueDTO distributionAppAddvalueDTO) {
List<DistributionAddvalueVO> addvalueInfo= distributionAddvalueMapper.addvalueInfo(distributionAppAddvalueDTO.getReservationId());
addvalueInfo.stream().filter(a->Func.isNotEmpty(a.getPackageListIds())).forEach(a-> a.setPackageEntityList(distributionAddvaluePackageService.listByIds(Func.toLongList(a.getPackageListIds()))));
return R.data(addvalueInfo);
}
}

2
blade-service/logpm-distribution/src/main/java/com/logpm/distribution/service/impl/DistributionDeliveryListServiceImpl.java

@ -2978,7 +2978,7 @@ public class DistributionDeliveryListServiceImpl extends BaseServiceImpl<Distrib
//修改主表状态
distributionDeliveryListEntity.setDeliveryStatus(DeliveryStatusConstant.peisongzhong.getValue());
baseMapper.updateById(distributionDeliveryListEntity);
//TODO 提示装车件数
return R.status(b);
}

15
blade-service/logpm-distribution/src/main/java/com/logpm/distribution/service/impl/DistributionReservationServiceImpl.java

@ -226,9 +226,10 @@ public class DistributionReservationServiceImpl extends BaseServiceImpl<Distribu
List<DistributionStockArticleVO> stockArticleVOS = DistributionStockArticleWrapper.build().listVO(stockArticleEntityList);
stockArticleVOS.forEach(s -> {
//查询出这个订单在这个预约计划的选择情况
List<DistributionReservationPackageEntity> packageEntityList = distributionReservationMapper.selectPackageByReservationAndStockArticle(reservationId, s.getId());
List<DistributionParcelListVO> packageList = distributionReservationPackageService.getStockArticlePackageList(packageEntityList);
s.setPackageList(packageList);
List<DistributionParcelListEntity> packageEntityList = distributionReservationMapper.selectPackageByReservationAndStockArticle(reservationId, s.getId());
// List<DistributionParcelListVO> packageList = distributionReservationPackageService.getStockArticlePackageList(packageEntityList);
List<DistributionParcelListVO> parcelListVOS = DistributionParcelListWrapper.build().listVO(packageEntityList);
s.setPackageList(parcelListVOS);
});
reservationVO.setStockArticleList(stockArticleVOS);
return R.data(reservationVO);
@ -466,7 +467,9 @@ public class DistributionReservationServiceImpl extends BaseServiceImpl<Distribu
String s = String.join(",", serviceNumber);
reservationEntity.setServiceNumber(s);
reservationEntity.setReservationStatus(ReservationStatusConstant.daiqueren.getValue());
reservationEntity.setServeType(distributionReservationDTO.getServeType());
if (Func.isNotEmpty(distributionReservationDTO.getServeType())){
reservationEntity.setServeType(distributionReservationDTO.getServeType());
}
// reservationEntity.setReservationNum(stockArticleCount.get());
reservationEntity.setReservationStockListNum(stockListCount.get());
//————————————————————————————————2023-08-31——————————————————————————————————————————
@ -2073,7 +2076,9 @@ public class DistributionReservationServiceImpl extends BaseServiceImpl<Distribu
}
reservationEntity.setReservationStatus(distributionReservationDTO.getReservationStatus());
reservationEntity.setOrderSource(ReservationOrderSourceConstant.zijian.getValue());
reservationEntity.setServeType(distributionReservationDTO.getServeType());
if (Func.isNotEmpty(distributionReservationDTO.getServeType())){
reservationEntity.setServeType(distributionReservationDTO.getServeType());
}
// reservationEntity.setReservationNum(stockArticleCount.get());
reservationEntity.setReservationStockListNum(stockListCount.get());
reservationEntity.setLoadingStatus(ReservationLoadingStatusConstant.daizhuangche.getValue());

46
blade-service/logpm-distribution/src/main/java/com/logpm/distribution/service/impl/DistributionSignforServiceImpl.java

@ -27,20 +27,15 @@ import com.logpm.basicdata.entity.BasicdataWarehouseEntity;
import com.logpm.basicdata.feign.IBasicdataDriverArteryClient;
import com.logpm.basicdata.feign.IBasicdataWarehouseClient;
import com.logpm.distribution.bean.Resp;
import com.logpm.distribution.dto.DistributionDeliverySelfDTO;
import com.logpm.distribution.dto.DistributionReservationPackageDTO;
import com.logpm.distribution.dto.DistributionSignforDTO;
import com.logpm.distribution.dto.DistrilbutionAppsignforDTO;
import com.logpm.distribution.dto.*;
import com.logpm.distribution.dto.app.DistributionAppDeliveryListDTO;
import com.logpm.distribution.entity.*;
import com.logpm.distribution.excel.DistributionSignforExcel;
import com.logpm.distribution.mapper.*;
import com.logpm.distribution.service.*;
import com.logpm.distribution.vo.DistributionParcelListVO;
import com.logpm.distribution.vo.DistributionSignforVO;
import com.logpm.distribution.vo.DistributionSignforsnmbVO;
import com.logpm.distribution.vo.DistributionStockArticleVO;
import com.logpm.distribution.vo.*;
import com.logpm.distribution.vo.app.*;
import com.logpm.distribution.wrapper.DistributionDisStockListWrapper;
import com.logpm.distribution.wrapper.DistributionParcelListWrapper;
import lombok.AllArgsConstructor;
import lombok.extern.slf4j.Slf4j;
@ -53,6 +48,8 @@ import org.springblade.common.constant.loading.LoadingIsInsertConstant;
import org.springblade.common.constant.loading.LoadingStatusConstant;
import org.springblade.common.constant.orderpackage.OrderPackageLoadingStatusConstant;
import org.springblade.common.constant.orderpackage.OrderPackageStatusConstant;
import org.springblade.common.constant.reservation.ReservationInventoryLoadingStatusConstant;
import org.springblade.common.constant.reservation.ReservationInventorySigningStatusConstant;
import org.springblade.common.constant.reservation.ReservationLoadingStatusConstant;
import org.springblade.common.constant.reservation.ReservationSigningStatusConstant;
import org.springblade.common.constant.signing.SignforDriverSigningStatusConstant;
@ -1341,5 +1338,38 @@ public class DistributionSignforServiceImpl extends BaseServiceImpl<Distribution
return parcelListVOS;
}
@Override
public List<DistributionReservationStocklistVO> signforInventoryList(Long signforId) {
List<DistributionReservationStocklistVO> distributionReservationStocklistVOS = distributionSignforMapper.selectInventory(signforId);
distributionReservationStocklistVOS.forEach(i->{
List<DisStockListDetailEntity> list = disStockListDetailService.list(Wrappers.<DisStockListDetailEntity>query().lambda().eq(DisStockListDetailEntity::getReservationId, i.getReservationId()).eq(DisStockListDetailEntity::getStockListId, i.getStocklistId()));
switch (i.getLoadingStatus()){
case "10":
i.setLoadingStatusName(ReservationInventoryLoadingStatusConstant.weizhuangche.getName());
break;
case "20":
i.setLoadingStatusName(ReservationInventoryLoadingStatusConstant.bufenzhuangche.getName());
break;
case "30":
i.setLoadingStatusName(ReservationInventoryLoadingStatusConstant.yizhuangche.getName());
break;
}
switch (i.getSigningStatus()){
case "10":
i.setSigningStatusName(ReservationInventorySigningStatusConstant.weiqianshou.getName());
break;
case "20":
i.setSigningStatusName(ReservationInventorySigningStatusConstant.bufenqianshou.getName());
break;
case "30":
i.setSigningStatusName(ReservationInventorySigningStatusConstant.yiqianshou.getName());;
}
i.setDetailVOS(DistributionDisStockListWrapper.build().listVO(list));
});
return distributionReservationStocklistVOS;
}
}

109
blade-service/logpm-distribution/src/main/java/com/logpm/distribution/service/impl/DistributionStockArticleServiceImpl.java

@ -18,6 +18,7 @@ package com.logpm.distribution.service.impl;
import com.alibaba.fastjson.JSONObject;
import com.baomidou.mybatisplus.core.conditions.Wrapper;
import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
import com.baomidou.mybatisplus.core.metadata.IPage;
import com.baomidou.mybatisplus.core.toolkit.ObjectUtils;
@ -36,6 +37,7 @@ import com.logpm.distribution.entity.*;
import com.logpm.distribution.excel.DistributionStockArticleExcel;
import com.logpm.distribution.mapper.DistributionAddvalueMapper;
import com.logpm.distribution.mapper.DistributionDeliveryListMapper;
import com.logpm.distribution.mapper.DistributionParcelListMapper;
import com.logpm.distribution.mapper.DistributionStockArticleMapper;
import com.logpm.distribution.service.*;
import com.logpm.distribution.vo.DistributionParcelListVO;
@ -56,6 +58,7 @@ import org.springblade.common.utils.TemplateUtil;
import org.springblade.core.log.exception.ServiceException;
import org.springblade.core.mp.base.BaseServiceImpl;
import org.springblade.core.mp.support.Condition;
import org.springblade.core.mp.support.Query;
import org.springblade.core.secure.BladeUser;
import org.springblade.core.secure.utils.AuthUtil;
import org.springblade.core.tool.api.R;
@ -106,6 +109,7 @@ public class DistributionStockArticleServiceImpl extends BaseServiceImpl<Distrib
private final DistributionAddvalueMapper distributionAddvalueMapper;
private final IDistributionParcelListService distributionParcelListService;
private final DistributionParcelListMapper distributionParcelListMapper;
private final IDistributionParcelDetailsService distributionParcelDetailsService;
private final IBasicMaterialClient basicMaterialClient;
@ -536,7 +540,6 @@ public class DistributionStockArticleServiceImpl extends BaseServiceImpl<Distrib
throw new ServiceException("参数错误");
}
for (String id : idArray) {
DistributionStockArticleQRCodeVO orderNoList = baseMapper.getOrderNoList(null, id);
Map<String, Object> map = JSONObject.parseObject(JSONObject.toJSONString(orderNoList), Map.class);
@ -554,11 +557,18 @@ public class DistributionStockArticleServiceImpl extends BaseServiceImpl<Distrib
@Override
public IPage<DistributionStockArticleVO> handlePackage(IPage<DistributionStockArticleVO> pageVO) {
pageVO.getRecords().forEach(s->{
List<DistributionParcelListEntity> parcelListEntityList = distributionParcelListService.getBaseMapper().selectList(Wrappers.<DistributionParcelListEntity>query().lambda()
.eq(DistributionParcelListEntity::getStockArticleId, s.getId())
.ne(DistributionParcelListEntity::getOrderPackageReservationStatus, OrderPackageReservationStatusConstant.yiyueyue.getValue()));
s.setParcelListVOS(DistributionParcelListWrapper.build().listVO(parcelListEntityList));
HashSet<String> str = new HashSet<>();
// List<DistributionParcelListEntity> parcelListEntityList = distributionParcelListService.getBaseMapper().selectList(Wrappers.<DistributionParcelListEntity>query().lambda()
// .eq(DistributionParcelListEntity::getStockArticleId, s.getId())
// .ne(DistributionParcelListEntity::getOrderPackageReservationStatus, OrderPackageReservationStatusConstant.yiyueyue.getValue()));
List<DistributionParcelListEntity> parcelListEntities = distributionParcelListMapper.getPackageList(s.getId());
Set<String> allocation = parcelListEntities.stream().filter(p -> Func.isNotEmpty(p.getGoodsAllocation())).distinct().map(DistributionParcelListEntity::getGoodsAllocation).collect(Collectors.toSet());
Set<String> tray = parcelListEntities.stream().filter(p -> Func.isNotEmpty(p.getPallet())).distinct().map(DistributionParcelListEntity::getPallet).collect(Collectors.toSet());
s.setAllocation(String.join(",",allocation));
s.setTrays(String.join(",",tray));
s.setParcelListVOS(DistributionParcelListWrapper.build().listVO(parcelListEntities));
});
return pageVO;
}
@ -682,6 +692,95 @@ public class DistributionStockArticleServiceImpl extends BaseServiceImpl<Distrib
return distributionStockArticleEntityIPage;
}
@Override
public R selectStockArticleInfoList(Map<String, Object> distributionStockArticle, Query query) {
// IPage<Object> page = Condition.getPage(query);
BasicdataWarehouseEntity myCurrentWarehouse = warehouseClient.getMyCurrentWarehouse();
if (Func.isEmpty(myCurrentWarehouse)){
return R.fail("无仓库信息!!!");
}
Object orderCodeNum = distributionStockArticle.get("orderCodeNum");
distributionStockArticle.remove("orderCodeNum");
Object waybillNum = distributionStockArticle.get("waybillNum");
Object o = distributionStockArticle.get("orderCode");
distributionStockArticle.remove("orderCode");
Object o2 = distributionStockArticle.get("startDate");
Object o1 = distributionStockArticle.get("entDate");
String orderIds = (String) distributionStockArticle.get("orderIds");
String customerName = (String) distributionStockArticle.get("customerName");
String reservationStatus = (String) distributionStockArticle.get("reservationStatus");
String warehouseEntryTime = (String) distributionStockArticle.get("warehouseEntryTime");
String customerTelephone = (String) distributionStockArticle.get("customerTelephone");
String completeSet = (String) distributionStockArticle.get("completeSet");
String freezeStatus = (String) distributionStockArticle.get("freezeStatus");
Object d = distributionStockArticle.get("id");
distributionStockArticle.remove("id");
distributionStockArticle.remove("startDate");
distributionStockArticle.remove("entDate");
distributionStockArticle.remove("orderIds");
// distributionStockArticle.remove("pageSize");
// distributionStockArticle.remove("currentPage");
// distributionStockArticle.remove("total");
QueryWrapper<DistributionStockArticleEntity> queryWrapper = Condition.getQueryWrapper(distributionStockArticle, DistributionStockArticleEntity.class);
LambdaQueryWrapper<DistributionStockArticleEntity> lambda = Wrappers.<DistributionStockArticleEntity>query().lambda();
queryWrapper.ne("reservation_status","30");
queryWrapper.lambda().eq(DistributionStockArticleEntity::getWarehouseId,myCurrentWarehouse.getId());
if(Func.isNotEmpty(o)){
queryWrapper.in("order_code",String.valueOf(o).split(","));
}
if(Func.isNotEmpty(reservationStatus)){
queryWrapper.eq("reservation_status",reservationStatus);
}
if(Func.isNotEmpty(warehouseEntryTime)){
queryWrapper.apply("datediff(warehouse_entry_time,{0} ) = 0",warehouseEntryTime);
}
if(Func.isNotEmpty(freezeStatus)){
queryWrapper.eq("freeze_status",freezeStatus);
}
if(Func.isNotEmpty(completeSet)){
queryWrapper.eq("complete_set",completeSet);
}
if(ObjectUtil.isNotEmpty(d)){
queryWrapper.in("id",String.valueOf(d).split(","));
}
if(ObjectUtil.isNotEmpty(o2)){
queryWrapper.between("warehouse_entry_time",o2,o1);
}
if(Func.isNotEmpty(orderIds)){
queryWrapper.notIn(Func.isNotEmpty(orderIds),"id",Func.toLongList(orderIds));
}
// if(Func.isNotEmpty(orderIds)){
// queryWrapper.notIn("id",Func.toLongList(orderIds));
// }
if(Func.isNotEmpty(customerName)){
queryWrapper.like("customer_name",customerName);
}
if(Func.isNotEmpty(customerTelephone)){
queryWrapper.like("customer_telephone",customerTelephone);
}
if(Func.isNotEmpty(orderCodeNum)){
String anumbering = orderCodeNum.toString();
List<String> list = CommonUtil.stringNum(anumbering);
if(list.size() > 1){
queryWrapper.in("order_code",list);
}else{
queryWrapper.like("order_code",anumbering);
}
}
if(Func.isNotEmpty(waybillNum)){
String waybill = waybillNum.toString();
List<String> list = CommonUtil.stringNum(waybill);
if(list.size() > 1){
queryWrapper.in("waybill_number",list);
}else{
queryWrapper.like("waybill_number",waybill);
}
}
IPage<DistributionStockArticleEntity> pages = this.page(Condition.getPage(query), queryWrapper);
IPage<DistributionStockArticleVO> distributionStockArticleVOIPage = this.handlePackage(DistributionStockArticleWrapper.build().pageVO(pages));
return R.data(distributionStockArticleVOIPage);
}
@Override
public DistributionStockArticleEntity findStockArticleByOrderCodeAndWarehouseId(String orderCode, Long warehouseId) {
QueryWrapper<DistributionStockArticleEntity> queryWrapper = new QueryWrapper<>();

Loading…
Cancel
Save