Merge remote-tracking branch 'origin/dev' into dev

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

@@ -266,6 +266,18 @@ public class DistributionSignforStockArticleVO implements Serializable {
 	@ApiModelProperty(value = "签收时间")
 	private Date signinTime;
 
+	/**
+	 * 签收ID
+	 */
+	@ApiModelProperty(value = "签收ID")
+	private Date signforId;
+
+	/**
+	 * 配送ID
+	 */
+	@ApiModelProperty(value = "配送ID")
+	private Date deliveryId;
+
 
 	/**
 	 * 创建时间

blade-service-api/logpm-statisticsdata-api/src/main/java/com/logpm/statistics/entity/StatisticsDistributionPackageEntity.java

@@ -84,6 +84,12 @@ public class StatisticsDistributionPackageEntity extends TenantEntity {
 	@ApiModelProperty(value = "品类名称")
 	private String productName;
 
+	/**
+	 * 品类名称
+	 */
+	@ApiModelProperty(value = "品类Id")
+	private String productId;
+
 	/**
 	 * 件数
 	 */

blade-service-api/logpm-statisticsdata-api/src/main/java/com/logpm/statistics/entity/StatisticsTrunklinePackageEntity.java

@@ -83,6 +83,12 @@ public class StatisticsTrunklinePackageEntity extends TenantEntity {
 	@ApiModelProperty(value = "品类名称")
 	private String productName;
 
+	/**
+	 * 品类名称
+	 */
+	@ApiModelProperty(value = "品类id")
+	private String productId;
+
 	/**
 	 * 件数
 	 */

blade-service-api/logpm-statisticsdata-api/src/main/java/com/logpm/statistics/entity/StatisticsWarehousePackageEntity.java

@@ -84,6 +84,12 @@ public class StatisticsWarehousePackageEntity extends TenantEntity {
 	@ApiModelProperty(value = "品类名称")
 	private String productName;
 
+	/**
+	 * 品类名称
+	 */
+	@ApiModelProperty(value = "品类id")
+	private String productId;
+
 	/**
 	 * 件数
 	 */

blade-service/logpm-distribution/src/main/java/com/logpm/distribution/api/DistributionDeliveryAppController.java

@@ -137,7 +137,13 @@ public class DistributionDeliveryAppController {
 	@ApiOperationSupport(order = 6)
 	@ApiOperation(value = "装车扫描", notes = "传入DistrilbutionloadingscanDTO")
 	public R loadingscan(@Valid @RequestBody DistrilbutionloadingscanDTO distrilbutionloadingscanDTO) {
-		R msg = distributionDeliveryListService.loadingscan(distrilbutionloadingscanDTO);
+		R msg = null;
+		try{
+			 msg = distributionDeliveryListService.loadingscan(distrilbutionloadingscanDTO);
+
+		}catch (Exception e){
+			e.printStackTrace();
+		}
 
 		return msg;
 	}

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

@@ -543,7 +543,7 @@
         LEFT JOIN logpm_warehouse_tray_goods lwtg on lwtg.association_id = ldpl.id and lwtg.association_type = '3'
         LEFT JOIN logpm_warehouse_tray lwt on lwtg.tray_id = lwt.id
         <where>
-            ldsi.stockup_id =#{id} and ldpl.order_package_code is not null and ldsi.stock_status != 4
+            ldsi.stockup_id =#{id} and ldpl.order_package_code is not null and ldsi.stock_status != 4 AND ldrp.packet_bar_status != 2
         </where>
     </select>
     <select id="getPageVOList" resultType="com.logpm.distribution.entity.DistributionParcelListEntity">

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

@@ -1492,7 +1492,9 @@
         lds.sjsigning_time AS sjsigningTime,
         lddl.train_number AS trainNumber,
         lddl.vehicle_name AS vehicleName,
-        lddl.driver_name AS driverName
+        lddl.driver_name AS driverName,
+        lds.id AS signforId,
+        lds.delivery_id AS deliveryId
         FROM
         logpm_distribution_reservation_stockarticle AS ldrs
         LEFT JOIN logpm_distribution_reservation AS ldr ON ldrs.reservation_id = ldr.id

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

@@ -1020,6 +1020,7 @@
             ldsi.stockup_id = #{ id }
             AND ldsi.is_deleted = 0
             AND ldsi.stock_status != 4
+            AND ldrs.stock_article_status != 2
         </where>
 
     </select>

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

@@ -577,6 +577,8 @@ public class DistributionDeliveryListServiceImpl extends BaseServiceImpl<Distrib
 	@Transactional(isolation = Isolation.READ_COMMITTED, rollbackFor = Exception.class)
 //	synchronized
 	public R loadingscan(DistrilbutionloadingscanDTO distrilbutionloadingscanDTO) {
+
+
 		//查询该包件是否能够从库存品包件表中查到
 		String now = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss").format(new Date());
 
@@ -642,6 +644,9 @@ public class DistributionDeliveryListServiceImpl extends BaseServiceImpl<Distrib
 			if (Func.isEmpty(parcelList)) {
 				return Resp.scanFail("系统无编码", "系统无编码");
 			}
+			if (parcelList.getConditions().equals(2)) {
+				return Resp.scanFail("此包件不是订制品", "此包件不是订制品");
+			}
 			if (!Objects.isNull(parcelList)) {
 				if (OrderPackageStatusConstant.yiqianshou.getValue().equals(parcelList.getOrderPackageStatus())) {
 					return Resp.scanFail("包件已签收", "包件已签收");
@@ -787,21 +792,17 @@ public class DistributionDeliveryListServiceImpl extends BaseServiceImpl<Distrib
 					if (shangpeiFlag) {
 						List<DistributionReservationEntity> reservationEntities = reservationEntityList.stream().filter(r -> Func.isNotEmpty(r.getConsignee()) && r.getConsignee().equals(stockArticleEntity.getCustomerName()) && r.getDeliveryAddress().equals(stockArticleEntity.getCustomerAddress()) && r.getDeliveryPhone().equals(stockArticleEntity.getCustomerTelephone()) && r.getMallName().equals(stockArticleEntity.getMallName()) && r.getId().equals(distrilbutionloadingscanDTO.getReservationId())).collect(Collectors.toList());
 						//查看是否存在满足条件的预约单
-						reservationEntities = reservationEntities.stream().filter(r -> r.getReceivingUnit().equals(stockArticleEntity.getConsigneeUnit()) && r.getMallName().equals(stockArticleEntity.getMallName())).collect(Collectors.toList());
+						boolean flag = reservationEntityList.stream().anyMatch(r -> Func.isNotEmpty(r.getConsignee()) && r.getConsignee().equals(stockArticleEntity.getCustomerName()) && r.getDeliveryAddress().equals(stockArticleEntity.getCustomerAddress()) && r.getDeliveryPhone().equals(stockArticleEntity.getCustomerTelephone()) && r.getMallName().equals(stockArticleEntity.getMallName()) && r.getId().equals(distrilbutionloadingscanDTO.getReservationId()));
 
 						//存在多个，操作人指定具体客户即可
-						if (!reservationEntities.isEmpty() && reservationEntities.size() == 1) {
-							if (Func.isEmpty(distrilbutionloadingscanDTO.getReservationId())) {
-								log.info("异常装车未指定客户");
-								return Resp.scanFail("请指定客户进行异常装车", "请指定客户进行异常装车");
-							}
+						if ( reservationEntities.size() == 1  && flag) {
 							return R.fail(5000, "异常装车");
-//						return Resp.scanFail("装车失败","程序出错，请联系彪桑");
 						} else {
-							if (parcelListEntity.getConditions() == 2) {
-								return Resp.scanFail("此包件不是订制品", "此包件不是订制品");
-
-							} else {
+							if (flag){
+								if (reservationEntities.isEmpty()){
+									return Resp.scanFail("请指定客户进行异常装车", "请指定客户进行异常装车");
+								}
+							}else {
 								return Resp.scanFail("窜货", "窜货");
 							}
 						}
@@ -810,15 +811,18 @@ public class DistributionDeliveryListServiceImpl extends BaseServiceImpl<Distrib
 						if (shangpeiFlag) {
 							List<DistributionReservationEntity> reservationEntities = reservationEntityList.stream().filter(r -> r.getReceivingUnit().equals(stockArticleEntity.getConsigneeUnit()) && r.getMallName().equals(stockArticleEntity.getMallName()) && r.getId().equals(distrilbutionloadingscanDTO.getReservationId())).collect(Collectors.toList());
 							//查询是否满足商配异常装车
-							boolean flag = reservationEntities.stream().anyMatch(r -> r.getReceivingUnit().equals(stockArticleEntity.getConsigneeUnit()) && r.getMallName().equals(stockArticleEntity.getMallName()));
-							if (flag){
+							boolean flag = reservationEntityList.stream().anyMatch(r -> r.getReceivingUnit().equals(stockArticleEntity.getConsigneeUnit()) && r.getMallName().equals(stockArticleEntity.getMallName()));
+							if (reservationEntities.size() == 1 && flag){
 								return R.fail(5000, "异常装车");
 
 							}else {
-								if (Func.isEmpty(distrilbutionloadingscanDTO.getReservationId())){
-									return Resp.scanFail("请指定客户进行异常装车", "请指定客户进行异常装车");
+								if (flag){
+									if (reservationEntities.isEmpty()){
+										return Resp.scanFail("请指定客户进行异常装车", "请指定客户进行异常装车");
+									}
 								}else {
 									return Resp.scanFail("窜货", "窜货");
+
 								}
 							}
 						} else {

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

@@ -2589,7 +2589,12 @@ public class DistributionReservationServiceImpl extends BaseServiceImpl<Distribu
 			//查询备货任务
 			DistributionStockupEntity stockupEntity = distributionStockupMapper.selectById(distributionStockupInfoEntities.get(0).getStockupId());
 			if (Func.isNotEmpty(stockupEntity)) {
-				if (stockupEntity.getAssignStatus().equals(StockAssignStatusConstant.weizhipai.getValue())) {
+				//查询此备货任务有多少
+				List<DistributionStockupInfoEntity> entityList = distributionStockupInfoService.list(Wrappers.<DistributionStockupInfoEntity>query().lambda()
+					.eq(DistributionStockupInfoEntity::getStockupId, stockupEntity.getId())
+					.ne(DistributionStockupInfoEntity::getStockStatus, "4")
+				);
+				if (stockupEntity.getAssignStatus().equals(StockAssignStatusConstant.weizhipai.getValue()) && entityList.size() == 1) {
 					//物理删除关于预约的所有信息
 					distributionReservationStocklistMapper.deleteReservationStocklist(reservationEntity.getId());
 					distributionReservationPackageMapper.deleteReservationPackage(reservationEntity.getId());

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

@@ -310,8 +310,6 @@ public class DistributionStockupServiceImpl extends BaseServiceImpl<Distribution
 			//商  市
 			return baseMapper.pageList(page, distributionStockupEntity);
 		}
-
-
 	}
 
 	@Override

blade-service/logpm-statisticsdata/src/main/java/com/logpm/statistics/listener/mq/WaybillFanoutListener.java

@@ -87,6 +87,7 @@ public class WaybillFanoutListener {
 			statisticsTrunklinePackageEntity.setOrderCode(json.getStr("orderCode"));
 			statisticsTrunklinePackageEntity.setOrderPackageCode(json.getStr("orderPackageCode"));
 			statisticsTrunklinePackageEntity.setProductName(json.getStr("productName"));
+			statisticsTrunklinePackageEntity.setProductId(json.getStr("productId"));
 			statisticsTrunklinePackageEntity.setTotalNum(json.getInt("totalNum"));
 			statisticsTrunklinePackageEntity.setTotalWeight(totalWeight);
 			statisticsTrunklinePackageEntity.setTotalVolume(totalVolume);
@@ -135,6 +136,7 @@ public class WaybillFanoutListener {
 			statisticsWarehousePackageEntity.setOrderCode(json.getStr("orderCode"));
 			statisticsWarehousePackageEntity.setOrderPackageCode(json.getStr("orderPackageCode"));
 			statisticsWarehousePackageEntity.setProductName(json.getStr("productName"));
+			statisticsWarehousePackageEntity.setProductId(json.getStr("productId"));
 			statisticsWarehousePackageEntity.setTotalNum(json.getInt("totalNum"));
 			statisticsWarehousePackageEntity.setTotalWeight(totalWeight);
 			statisticsWarehousePackageEntity.setTotalVolume(totalVolume);
@@ -170,6 +172,7 @@ public class WaybillFanoutListener {
 			statisticsDistributionPackageEntity.setOrderCode(json.getStr("orderCode"));
 			statisticsDistributionPackageEntity.setOrderPackageCode(json.getStr("orderPackageCode"));
 			statisticsDistributionPackageEntity.setProductName(json.getStr("productName"));
+			statisticsDistributionPackageEntity.setProductId(json.getStr("productId"));
 			statisticsDistributionPackageEntity.setTotalNum(json.getInt("totalNum"));
 			statisticsDistributionPackageEntity.setTotalWeight(totalWeight);
 			statisticsDistributionPackageEntity.setTotalVolume(totalVolume);

blade-service/logpm-trunkline/src/main/java/com/logpm/trunkline/service/impl/OpenOrderAsyncServiceImpl.java

@@ -552,6 +552,7 @@ public class OpenOrderAsyncServiceImpl implements IOpenOrderAsyncService {
 				json.put("orderPackageCode",detail.getProductName());
 				json.put("orderCode",waybillNo);
 				json.put("productName",detail.getProductName());
+				json.put("productId",detail.getProductId());
 				json.put("totalNum",num);
 				json.put("totalWeight",detail.getWeight());
 				json.put("totalVolume",detail.getVolume());