1.新增首页库内数据接口

2.库内数据作业维护订单包件上去

blade-biz-common/src/main/java/org/springblade/common/constant/broadcast/FanoutConstants.java

@@ -55,4 +55,102 @@ public abstract class FanoutConstants {
 	}
 
 
+
+	//仓库
+	public interface warehouse {
+
+
+		//打托
+		interface TRAYTYPE{
+
+			//交换机
+			String EXCHANGE = "fanout.warehouse.traytype" + ModuleNameConstant.DEVAUTH;
+
+			interface QUEUE {
+
+				String TRAYTYPE_MESSAGE = "fanout.warehouse.traytype.distribution.traytypemessage" + ModuleNameConstant.DEVAUTH;
+
+			}
+
+		}
+
+
+//		//解托
+//		interface UNBINDTRAY{
+//
+//			//交换机
+//			String EXCHANGE = "fanout.warehouse.unbindtray" + ModuleNameConstant.DEVAUTH;
+//
+//			interface QUEUE {
+//
+//				String UNBINDTRAY_INFO = "fanout.warehouse.unbindtray.distribution.unbindtrayINFO" + ModuleNameConstant.DEVAUTH;
+//
+//			}
+//
+//		}
+//
+//
+//		//移托
+//		interface MOVETRAY{
+//
+//			//交换机
+//			String EXCHANGE = "fanout.warehouse.movetray" + ModuleNameConstant.DEVAUTH;
+//
+//			interface QUEUE {
+//
+//				String MOVETRAY_INFO = "fanout.warehouse.movetray.distribution.movetrayInfo" + ModuleNameConstant.DEVAUTH;
+//
+//			}
+//
+//		}
+
+
+
+		//上架
+		interface ALLOCATION{
+
+			//交换机
+			String EXCHANGE = "fanout.warehouse.upshelf" + ModuleNameConstant.DEVAUTH;
+
+			interface QUEUE {
+
+				String ALLOCATION_MESSAGE = "fanout.warehouse.upshelf.distribution.allocationmessage" + ModuleNameConstant.DEVAUTH;
+
+			}
+
+		}
+
+
+//		//下架
+//		interface DOWNSHELF{
+//
+//			//交换机
+//			String EXCHANGE = "fanout.warehouse.downshelf" + ModuleNameConstant.DEVAUTH;
+//
+//			interface QUEUE {
+//
+//				String DOWNSHELF_INFO = "fanout.warehouse.downshelf.distribution.downshelfInfo" + ModuleNameConstant.DEVAUTH;
+//
+//			}
+//
+//		}
+//
+//
+//		//移库
+//		interface MOVEALLOCATION{
+//
+//			//交换机
+//			String EXCHANGE = "fanout.warehouse.moveallocation" + ModuleNameConstant.DEVAUTH;
+//
+//			interface QUEUE {
+//
+//				String MOVEALLOCATION_INFO = "fanout.warehouse.moveallocation.distribution.moveallocationInfo" + ModuleNameConstant.DEVAUTH;
+//
+//			}
+//
+//		}
+
+
+	}
+
 }

blade-biz-common/src/main/java/org/springblade/common/utils/CommonUtil.java

@@ -172,6 +172,17 @@ public class CommonUtil {
 		return null;
 	}
 
+	public static Date getDayStart(){
+		Calendar calendar = Calendar.getInstance();
+		calendar.setTime(new Date());
+		// 将时分秒,毫秒域清零
+		calendar.set(Calendar.HOUR_OF_DAY, 23);
+		calendar.set(Calendar.MINUTE, 59);
+		calendar.set(Calendar.SECOND, 59);
+		calendar.set(Calendar.MILLISECOND, 999);
+		return calendar.getTime();
+	}
+
 	public static Date getDayEnd(){
 		Calendar calendar = Calendar.getInstance();
 		calendar.setTime(new Date());
@@ -183,6 +194,23 @@ public class CommonUtil {
 		return calendar.getTime();
 	}
 
+	public static Date getMonthDayStart(){
+		//获取一个Calendar对象
+		Calendar cal = Calendar.getInstance();
+		//获取当前时间
+		cal.setTime(new Date());
+		//获取当前月
+		cal.add(Calendar.MONTH, 0);
+		//获取当前月的最后一天
+		cal.set(Calendar.DAY_OF_MONTH, 1);
+		cal.set(Calendar.HOUR_OF_DAY, 0);
+		cal.set(Calendar.MINUTE, 0);
+		cal.set(Calendar.SECOND, 0);
+		cal.set(Calendar.MILLISECOND, 0);
+		//得到当前月的最后一天
+		Date preMonth=cal.getTime();
+		return preMonth;
+	}
 	public static Date getMonthDayEnd(){
 		//获取一个Calendar对象
 		Calendar cal = Calendar.getInstance();

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

@@ -198,4 +198,5 @@ public interface IDistributionParcelListClient {
 
 	@PostMapping(API_PREFIX + "/findALLNoUpShelfPackageByOrderCodeList")
 	List<DistributionParcelListEntity> findALLNoUpShelfPackageByOrderCodeList(@RequestBody FindParamterDTO findParamterDTO);
+
 }

blade-service/logpm-distribution/src/main/java/com/logpm/distribution/config/RabbitMqConfiguration.java

@@ -7,8 +7,6 @@ import org.springframework.amqp.core.*;
 import org.springframework.amqp.rabbit.connection.ConnectionFactory;
 import org.springframework.amqp.rabbit.connection.CorrelationData;
 import org.springframework.amqp.rabbit.core.RabbitTemplate;
-import org.springframework.amqp.rabbit.retry.MessageRecoverer;
-import org.springframework.amqp.rabbit.retry.RepublishMessageRecoverer;
 import org.springframework.context.annotation.Bean;
 import org.springframework.context.annotation.Configuration;
 
@@ -69,10 +67,10 @@ public class RabbitMqConfiguration {
 	 * @param rabbitTemplate
 	 * @return
 	 */
-	@Bean
-	public MessageRecoverer republishMessageRecoverer(RabbitTemplate rabbitTemplate){
-		return new RepublishMessageRecoverer(rabbitTemplate, RabbitConstant.DISTRIBUTION_ERROR_EXCHANGE, RabbitConstant.DISTRIBUTION_ERROR_ROUTING);
-	}
+//	@Bean
+//	public MessageRecoverer republishMessageRecoverer(RabbitTemplate rabbitTemplate){
+//		return new RepublishMessageRecoverer(rabbitTemplate, RabbitConstant.DISTRIBUTION_ERROR_EXCHANGE, RabbitConstant.DISTRIBUTION_ERROR_ROUTING);
+//	}
 
 
 	/**

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

@@ -288,4 +288,12 @@ public interface DistributionParcelListMapper extends BaseMapper<DistributionPar
 	List<DistributionParcelListEntity> findALLNoUpShelfPackageByOrderCodeList(@Param("orderCodeList") List<String> orderCodeList, @Param("warehouseId") Long warehouseId);
 
     List<String> findOrderCodesByOrderPackageCodes(@Param("orderPackageCodes") List<String> orderPackageCodes, @Param("warehouseId") Long warehouseId);
+
+    String findAllTraysByNoParcelListIds(@Param("parcelListIdList") List<Long> parcelListIdList,@Param("orderCode") String orderCode);
+
+	void clearPalletByIds(@Param("clearTrayList") List<Long> clearTrayList);
+
+	String findAllAllocationByNoParcelListIds(@Param("parcelListIdList") List<Long> parcelListIdList, @Param("orderCode") String orderCode);
+
+	void clearAllocationByIds(@Param("clearTrayList") List<Long> clearTrayList);
 }

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

@@ -1794,4 +1794,49 @@
         group by ldpl.order_code
     </select>
 
+    <select id="findAllTraysByNoParcelListIds" resultType="String">
+        select GROUP_CONCAT(DISTINCT pallet)
+        from logpm_distribution_parcel_list
+        where 1=1
+        and order_code = #{orderCode}
+        and pallet != ''
+        and pallet is not null
+        and id not in
+        <foreach collection="parcelListIdList" item="item" open="(" separator="," close=")">
+            #{item}
+        </foreach>
+    </select>
+
+    <update id="clearPalletByIds" >
+        update logpm_distribution_parcel_list
+        set pallet = null
+        where id in
+        <foreach collection="clearTrayList" item="item" open="(" separator="," close=")">
+            #{item}
+        </foreach>
+    </update>
+
+    <select id="findAllAllocationByNoParcelListIds" resultType="String">
+        select GROUP_CONCAT(DISTINCT goods_allocation)
+        from logpm_distribution_parcel_list
+        where 1=1
+        and order_code = #{orderCode}
+        and goods_allocation != ''
+        and goods_allocation is not null
+        and id not in
+        <foreach collection="parcelListIdList" item="item" open="(" separator="," close=")">
+            #{item}
+        </foreach>
+    </select>
+
+    <update id="clearAllocationByIds" >
+        update logpm_distribution_parcel_list
+        set goods_allocation = null,
+            order_package_grounding_status = '10'
+        where id in
+        <foreach collection="clearTrayList" item="item" open="(" separator="," close=")">
+            #{item}
+        </foreach>
+    </update>
+
 </mapper>

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

@@ -208,4 +208,9 @@ public interface DistributionStockArticleMapper extends BaseMapper<DistributionS
 	 * @return
 	 */
 	List<DistributionSignforStockArticleVO> signforListDetail(@Param("orderId") Long id);
+
+    void clearTraysByIds(@Param("ids") List<Long> clearTraysStockArticleIdList);
+
+	void clearAllocationByIds(@Param("ids") List<Long> clearAllocationStockArticleIdList);
+
 }

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

@@ -1515,5 +1515,23 @@
         ldrs.reservation_id
     </select>
 
+    <update id="clearTraysByIds" >
+        update logpm_distribution_stock_article
+        set trays = null
+        where id in
+        <foreach collection="ids" item="item" index="index" open="(" close=")" separator=",">
+            #{item}
+        </foreach>
+    </update>
+
+    <update id="clearAllocationByIds" >
+        update logpm_distribution_stock_article
+        set allocation = null,
+            grounding_status = '10'
+        where id in
+        <foreach collection="ids" item="item" index="index" open="(" close=")" separator=",">
+            #{item}
+        </foreach>
+    </update>
 
 </mapper>

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

@@ -57,4 +57,8 @@ public interface DistributionStockListInfoMapper extends BaseMapper<Distribution
     IPage<DistributionStockListInfoEntity> getStockListInfo(IPage<DistributionStockListInfoEntity> page,@Param("par") Map<String, Object> distributionStockListInfo);
 
     List<String> getAllOrderPackageCodes(@Param("incomingBatch") String incomingBatch, @Param("sku") String sku, @Param("mallId") Long mallId, @Param("warehouseId") Long warehouseId);
+
+    String findAllTraysByNoParcelListIdsAndStockListId(@Param("parcelListIds") List<Long> parcelListIds, @Param("stockListId") Long stockListId);
+
+	String findAllAllocationByNoParcelListIdsAndStockListId(@Param("parcelListIds") List<Long> parcelListIds, @Param("stockListId") Long stockListId);
 }

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

@@ -116,4 +116,34 @@
         AND is_deleted = 0
     </select>
 
+    <select id="findAllTraysByNoParcelListIdsAndStockListId" resultType="String">
+        select GROUP_CONCAT(DISTINCT ldpl.pallet)
+        from logpm_distribution_stock_list_info ldsli
+        left join logpm_distribution_parcel_list ldpl on ldpl.id = ldsli.parcel_list_id
+        where ldsli.stock_list_id = #{stockListId}
+        and ldsli.is_deleted = 0
+        and ldpl.is_deleted = 0
+        and ldpl.pallet != ''
+        and ldpl.pallet is not null
+        and ldsli.parcel_list_id not in
+        <foreach collection="parcelListIds" item="item" separator="," open="(" close=")">
+            #{item}
+        </foreach>
+    </select>
+
+    <select id="findAllAllocationByNoParcelListIdsAndStockListId" resultType="String" >
+        select GROUP_CONCAT(DISTINCT ldpl.goods_allocation)
+        from logpm_distribution_stock_list_info ldsli
+        left join logpm_distribution_parcel_list ldpl on ldpl.id = ldsli.parcel_list_id
+        where ldsli.stock_list_id = #{stockListId}
+        and ldsli.is_deleted = 0
+        and ldpl.is_deleted = 0
+        and ldpl.goods_allocation != ''
+        and ldpl.goods_allocation is not null
+        and ldsli.parcel_list_id not in
+        <foreach collection="parcelListIds" item="item" separator="," open="(" close=")">
+            #{item}
+        </foreach>
+    </select>
+
 </mapper>

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

@@ -156,4 +156,8 @@ public interface DistributionStockListMapper extends BaseMapper<DistributionStoc
 	IPage<DistributionStockListAllocationVO> listAllocationOrder(IPage<Object> page, @Param("param") DistributionStockListEntity distributionStockListEntity);
 
 	List<DistributionStockListEntity> getListByMarketIdAndSku(@Param("mallId")Long mallId, @Param("sku")String sku, @Param("warehouseId")Long warehouseId);
+
+    void clearTraysByIds(@Param("stockListIds") List<Long> clearTrayStockListIds);
+
+	void clearAllocationByIds(@Param("stockListIds") List<Long> clearAllocationStockListIds);
 }

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

@@ -616,4 +616,22 @@
           and ldsl.warehouse_id = #{warehouseId}
     </select>
 
+    <update id="clearTraysByIds" >
+        update logpm_distribution_stock_list
+        set tray_name = null
+        where id in
+        <foreach collection="stockListIds" item="stockListId" open="(" separator="," close=")">
+            #{stockListId}
+        </foreach>
+    </update>
+
+    <update id="clearAllocationByIds" >
+        update logpm_distribution_stock_list
+        set storage_location = null
+        where id in
+        <foreach collection="stockListIds" item="stockListId" open="(" separator="," close=")">
+            #{stockListId}
+        </foreach>
+    </update>
+
 </mapper>

blade-service/logpm-distribution/src/main/java/com/logpm/distribution/service/IDistributionParcelListService.java

@@ -246,4 +246,12 @@ public interface IDistributionParcelListService extends BaseService<Distribution
 	List<DistributionParcelListEntity> findALLNoUpShelfPackageByOrderCodeList(List<String> orderCodeList, Long warehouseId);
 
 	List<String> findOrderCodesByOrderPackageCodes(List<String> orderPackageCodes, Long warehouseId);
+
+    String findAllTraysByNoParcelListIds(List<Long> parcelListIdList,String orderCode);
+
+	void clearPalletByIds(List<Long> clearTrayList);
+
+	String findAllAllocationByNoParcelListIds(List<Long> parcelListIdList, String orderCode);
+
+	void clearAllocationByIds(List<Long> clearTrayList);
 }

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

@@ -299,4 +299,8 @@ public interface IDistributionStockArticleService extends BaseService<Distributi
 	 */
 	List<DistributionSignforStockArticleVO> signforListDetail(Long id);
 
+    void clearTraysByIds(List<Long> clearTraysStockArticleIdList);
+
+	void clearAllocationByIds(List<Long> clearAllocationStockArticleIdList);
+
 }

blade-service/logpm-distribution/src/main/java/com/logpm/distribution/service/IDistributionStockListInfoService.java

@@ -60,4 +60,8 @@ public interface IDistributionStockListInfoService extends BaseService<Distribut
 
     List<String> getAllOrderPackageCodes(String incomingBatch, String sku, Long mallId, Long warehouseId);
 
+    String findAllTraysByNoParcelListIdsAndStockListId(List<Long> parcelListIds, Long stockListId);
+
+	String findAllAllocationByNoParcelListIdsAndStockListId(List<Long> parcelListIds, Long stockListId);
+
 }

blade-service/logpm-distribution/src/main/java/com/logpm/distribution/service/IDistributionStockListService.java

@@ -214,6 +214,11 @@ public interface IDistributionStockListService extends BaseService<DistributionS
 	 */
 	R findStockListAllocation(String sourceType, Long marketId, String materielCode);
 
+    void clearTraysByIds(List<Long> clearTrayStockListIds);
+
+	void clearAllocationByIds(List<Long> clearAllocationStockListIds);
+
+
 
 //	/**
 //	 * 查询库存品详情

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

@@ -1297,6 +1297,26 @@ public class DistributionParcelListServiceImpl extends BaseServiceImpl<Distribut
 		return baseMapper.findOrderCodesByOrderPackageCodes(orderPackageCodes,warehouseId);
 	}
 
+	@Override
+	public String findAllTraysByNoParcelListIds(List<Long> parcelListIdList,String orderCode) {
+		return baseMapper.findAllTraysByNoParcelListIds(parcelListIdList,orderCode);
+	}
+
+	@Override
+	public void clearPalletByIds(List<Long> clearTrayList) {
+		baseMapper.clearPalletByIds(clearTrayList);
+	}
+
+	@Override
+	public String findAllAllocationByNoParcelListIds(List<Long> parcelListIdList, String orderCode) {
+		return baseMapper.findAllAllocationByNoParcelListIds(parcelListIdList,orderCode);
+	}
+
+	@Override
+	public void clearAllocationByIds(List<Long> clearTrayList) {
+		baseMapper.clearAllocationByIds(clearTrayList);
+	}
+
 
 	private JSONObject handleLogJSONObject(BasicdataWarehouseEntity warehouse, BladeUser user, String orderPackageCode, String content, Integer node) {
 		JSONObject trunklinePackageTrackLog = new JSONObject();

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

@@ -2723,6 +2723,16 @@ public class DistributionStockArticleServiceImpl extends BaseServiceImpl<Distrib
 		return baseMapper.signforListDetail(id);
 	}
 
+	@Override
+	public void clearTraysByIds(List<Long> clearTraysStockArticleIdList) {
+		baseMapper.clearTraysByIds(clearTraysStockArticleIdList);
+	}
+
+	@Override
+	public void clearAllocationByIds(List<Long> clearAllocationStockArticleIdList) {
+		baseMapper.clearAllocationByIds(clearAllocationStockArticleIdList);
+	}
+
 	@Override
 	public R findEditCustomerLog(Long orderId) {
 

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

@@ -16,7 +16,6 @@
  */
 package com.logpm.distribution.service.impl;
 
-import com.baomidou.mybatisplus.core.conditions.Wrapper;
 import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
 import com.baomidou.mybatisplus.core.metadata.IPage;
 import com.logpm.distribution.entity.DistributionStockListInfoEntity;
@@ -89,4 +88,14 @@ public class DistributionStockListInfoServiceImpl extends BaseServiceImpl<Distri
 		return baseMapper.getAllOrderPackageCodes(incomingBatch,sku,mallId,warehouseId);
 	}
 
+	@Override
+	public String findAllTraysByNoParcelListIdsAndStockListId(List<Long> parcelListIds, Long stockListId) {
+		return baseMapper.findAllTraysByNoParcelListIdsAndStockListId(parcelListIds,stockListId);
+	}
+
+	@Override
+	public String findAllAllocationByNoParcelListIdsAndStockListId(List<Long> parcelListIds, Long stockListId) {
+		return baseMapper.findAllAllocationByNoParcelListIdsAndStockListId(parcelListIds,stockListId);
+	}
+
 }

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

@@ -918,6 +918,16 @@ public class DistributionStockListServiceImpl extends BaseServiceImpl<Distributi
 		return null;
 	}
 
+	@Override
+	public void clearTraysByIds(List<Long> clearTrayStockListIds) {
+		baseMapper.clearTraysByIds(clearTrayStockListIds);
+	}
+
+	@Override
+	public void clearAllocationByIds(List<Long> clearAllocationStockListIds) {
+		baseMapper.clearAllocationByIds(clearAllocationStockListIds);
+	}
+
 
 	@Override
 	public OrderPackgeCodeDataVO showInventorySourcePackageCode(String incomingBatch, Long packageIds) throws Exception {

blade-service/logpm-report/src/main/java/com/logpm/report/controller/WarehouseIndexController.java

@@ -0,0 +1,272 @@
+package com.logpm.report.controller;
+
+import com.github.xiaoymin.knife4j.annotations.ApiOperationSupport;
+import com.logpm.basicdata.entity.BasicdataWarehouseEntity;
+import com.logpm.basicdata.feign.IBasicdataWarehouseClient;
+import com.logpm.report.dto.IndexDTO;
+import com.logpm.report.service.IWarehouseIndexService;
+import com.logpm.report.vo.*;
+import io.swagger.annotations.Api;
+import io.swagger.annotations.ApiOperation;
+import lombok.AllArgsConstructor;
+import lombok.extern.log4j.Log4j2;
+import org.springblade.common.exception.CustomerException;
+import org.springblade.core.tool.api.R;
+import org.springframework.web.bind.annotation.*;
+
+import java.util.ArrayList;
+import java.util.List;
+import java.util.Objects;
+
+@Log4j2
+@RestController
+@AllArgsConstructor
+@RequestMapping("/warehouseIndex")
+@Api(value = "仓库首页控制类", tags = "仓库首页数据")
+public class WarehouseIndexController {
+
+	private IBasicdataWarehouseClient warehouseClient;
+	private IWarehouseIndexService warehouseIndexService;
+
+	@ResponseBody
+	@PostMapping("/openOrderData")
+	@ApiOperationSupport(order = 1)
+	@ApiOperation(value = "开单数据", notes = "传入indexDTO")
+	public R openOrderData(@RequestBody IndexDTO indexDTO) {
+		String method = "###########openOrderData: ";
+		log.info(method+"indexDTO={}",indexDTO);
+
+		try{
+			List<Long> warehouseIds = new ArrayList<>();
+			//当前登录人选择的仓库
+			BasicdataWarehouseEntity myCurrentWarehouse = warehouseClient.getMyCurrentWarehouse();
+			if(Objects.isNull(myCurrentWarehouse)){
+				List<BasicdataWarehouseEntity> myWatchWarehouse = warehouseClient.getMyWatchWarehouse();
+				myWatchWarehouse.forEach(warehouseEntity -> {
+					warehouseIds.add(warehouseEntity.getId());
+				});
+			}else{
+				warehouseIds.add(myCurrentWarehouse.getId());
+			}
+			indexDTO.setWarehouseIds(warehouseIds);
+
+			//查询订制品打托列表
+			IndexOpenOrderDataVO indexOpenOrderDataVO = warehouseIndexService.openOrderData(indexDTO);
+			return R.data(indexOpenOrderDataVO);
+		}catch (CustomerException e){
+			log.warn(e.message);
+			return R.fail(e.code,e.message);
+		}catch (Exception e){
+			log.error(method+"系统异常，联系管理员",e);
+			return R.fail(500,"系统异常，联系管理员");
+		}
+	}
+
+
+	@ResponseBody
+	@PostMapping("/openOrderIncome")
+	@ApiOperationSupport(order = 1)
+	@ApiOperation(value = "开单收入数据", notes = "传入indexDTO")
+	public R openOrderIncome(@RequestBody IndexDTO indexDTO) {
+		String method = "###########openOrderIncome: ";
+		log.info(method+"indexDTO={}",indexDTO);
+
+		try{
+			List<Long> warehouseIds = new ArrayList<>();
+			//当前登录人选择的仓库
+			BasicdataWarehouseEntity myCurrentWarehouse = warehouseClient.getMyCurrentWarehouse();
+			if(Objects.isNull(myCurrentWarehouse)){
+				List<BasicdataWarehouseEntity> myWatchWarehouse = warehouseClient.getMyWatchWarehouse();
+				myWatchWarehouse.forEach(warehouseEntity -> {
+					warehouseIds.add(warehouseEntity.getId());
+				});
+			}else{
+				warehouseIds.add(myCurrentWarehouse.getId());
+			}
+			indexDTO.setWarehouseIds(warehouseIds);
+
+			//查询订制品打托列表
+			IndexOpenOrderIncomeVO indexOpenOrderIncomeVO = warehouseIndexService.openOrderIncome(indexDTO);
+			return R.data(indexOpenOrderIncomeVO);
+		}catch (CustomerException e){
+			log.warn(e.message);
+			return R.fail(e.code,e.message);
+		}catch (Exception e){
+			log.error(method+"系统异常，联系管理员",e);
+			return R.fail(500,"系统异常，联系管理员");
+		}
+	}
+
+
+	@ResponseBody
+	@PostMapping("/handOrderData")
+	@ApiOperationSupport(order = 1)
+	@ApiOperation(value = "当前在库数据", notes = "传入indexDTO")
+	public R handOrderData(@RequestBody IndexDTO indexDTO) {
+		String method = "###########handOrderData: ";
+		log.info(method+"indexDTO={}",indexDTO);
+
+		try{
+			List<Long> warehouseIds = new ArrayList<>();
+			//当前登录人选择的仓库
+			BasicdataWarehouseEntity myCurrentWarehouse = warehouseClient.getMyCurrentWarehouse();
+			if(Objects.isNull(myCurrentWarehouse)){
+				List<BasicdataWarehouseEntity> myWatchWarehouse = warehouseClient.getMyWatchWarehouse();
+				myWatchWarehouse.forEach(warehouseEntity -> {
+					warehouseIds.add(warehouseEntity.getId());
+				});
+			}else{
+				warehouseIds.add(myCurrentWarehouse.getId());
+			}
+			indexDTO.setWarehouseIds(warehouseIds);
+
+			//查询订制品打托列表
+			IndexHandOrderDataVO indexHandOrderDataVO = warehouseIndexService.handOrderData(indexDTO);
+			return R.data(indexHandOrderDataVO);
+		}catch (CustomerException e){
+			log.warn(e.message);
+			return R.fail(e.code,e.message);
+		}catch (Exception e){
+			log.error(method+"系统异常，联系管理员",e);
+			return R.fail(500,"系统异常，联系管理员");
+		}
+	}
+
+	@ResponseBody
+	@PostMapping("/allocationData")
+	@ApiOperationSupport(order = 1)
+	@ApiOperation(value = "库位数据", notes = "传入indexDTO")
+	public R allocationData(@RequestBody IndexDTO indexDTO) {
+		String method = "###########allocationData: ";
+		log.info(method+"indexDTO={}",indexDTO);
+
+		try{
+			List<Long> warehouseIds = new ArrayList<>();
+			//当前登录人选择的仓库
+			BasicdataWarehouseEntity myCurrentWarehouse = warehouseClient.getMyCurrentWarehouse();
+			if(Objects.isNull(myCurrentWarehouse)){
+				List<BasicdataWarehouseEntity> myWatchWarehouse = warehouseClient.getMyWatchWarehouse();
+				myWatchWarehouse.forEach(warehouseEntity -> {
+					warehouseIds.add(warehouseEntity.getId());
+				});
+			}else{
+				warehouseIds.add(myCurrentWarehouse.getId());
+			}
+			indexDTO.setWarehouseIds(warehouseIds);
+
+			//查询订制品打托列表
+			IndexAllocationDataVO indexAllocationDataVO = warehouseIndexService.allocationData(indexDTO);
+			return R.data(indexAllocationDataVO);
+		}catch (CustomerException e){
+			log.warn(e.message);
+			return R.fail(e.code,e.message);
+		}catch (Exception e){
+			log.error(method+"系统异常，联系管理员",e);
+			return R.fail(500,"系统异常，联系管理员");
+		}
+	}
+
+	@ResponseBody
+	@PostMapping("/trunklineHandOrderData")
+	@ApiOperationSupport(order = 1)
+	@ApiOperation(value = "干线待发运数据", notes = "传入indexDTO")
+	public R trunklineHandOrderData(@RequestBody IndexDTO indexDTO) {
+		String method = "###########trunklineHandOrderData: ";
+		log.info(method+"indexDTO={}",indexDTO);
+
+		try{
+			List<Long> warehouseIds = new ArrayList<>();
+			//当前登录人选择的仓库
+			BasicdataWarehouseEntity myCurrentWarehouse = warehouseClient.getMyCurrentWarehouse();
+			if(Objects.isNull(myCurrentWarehouse)){
+				List<BasicdataWarehouseEntity> myWatchWarehouse = warehouseClient.getMyWatchWarehouse();
+				myWatchWarehouse.forEach(warehouseEntity -> {
+					warehouseIds.add(warehouseEntity.getId());
+				});
+			}else{
+				warehouseIds.add(myCurrentWarehouse.getId());
+			}
+			indexDTO.setWarehouseIds(warehouseIds);
+
+			//查询订制品打托列表
+			IndexTrunklineHandOrderDataVO indexTrunklineHandOrderDataVO = warehouseIndexService.trunklineHandOrderData(indexDTO);
+			return R.data(indexTrunklineHandOrderDataVO);
+		}catch (CustomerException e){
+			log.warn(e.message);
+			return R.fail(e.code,e.message);
+		}catch (Exception e){
+			log.error(method+"系统异常，联系管理员",e);
+			return R.fail(500,"系统异常，联系管理员");
+		}
+	}
+
+	@ResponseBody
+	@PostMapping("/trunklineCarsData")
+	@ApiOperationSupport(order = 1)
+	@ApiOperation(value = "干线车次数据", notes = "传入indexDTO")
+	public R trunklineCarsData(@RequestBody IndexDTO indexDTO) {
+		String method = "###########trunklineCarsData: ";
+		log.info(method+"indexDTO={}",indexDTO);
+
+		try{
+			List<Long> warehouseIds = new ArrayList<>();
+			//当前登录人选择的仓库
+			BasicdataWarehouseEntity myCurrentWarehouse = warehouseClient.getMyCurrentWarehouse();
+			if(Objects.isNull(myCurrentWarehouse)){
+				List<BasicdataWarehouseEntity> myWatchWarehouse = warehouseClient.getMyWatchWarehouse();
+				myWatchWarehouse.forEach(warehouseEntity -> {
+					warehouseIds.add(warehouseEntity.getId());
+				});
+			}else{
+				warehouseIds.add(myCurrentWarehouse.getId());
+			}
+			indexDTO.setWarehouseIds(warehouseIds);
+
+			//查询订制品打托列表
+			IndexTrunklineCarsDataVO indexTrunklineCarsDataVO = warehouseIndexService.trunklineCarsData(indexDTO);
+			return R.data(indexTrunklineCarsDataVO);
+		}catch (CustomerException e){
+			log.warn(e.message);
+			return R.fail(e.code,e.message);
+		}catch (Exception e){
+			log.error(method+"系统异常，联系管理员",e);
+			return R.fail(500,"系统异常，联系管理员");
+		}
+	}
+
+	@ResponseBody
+	@PostMapping("/unloadAbnormalData")
+	@ApiOperationSupport(order = 1)
+	@ApiOperation(value = "卸车异常数据", notes = "传入indexDTO")
+	public R unloadAbnormalData(@RequestBody IndexDTO indexDTO) {
+		String method = "###########unloadAbnormalData: ";
+		log.info(method+"indexDTO={}",indexDTO);
+
+		try{
+			List<Long> warehouseIds = new ArrayList<>();
+			//当前登录人选择的仓库
+			BasicdataWarehouseEntity myCurrentWarehouse = warehouseClient.getMyCurrentWarehouse();
+			if(Objects.isNull(myCurrentWarehouse)){
+				List<BasicdataWarehouseEntity> myWatchWarehouse = warehouseClient.getMyWatchWarehouse();
+				myWatchWarehouse.forEach(warehouseEntity -> {
+					warehouseIds.add(warehouseEntity.getId());
+				});
+			}else{
+				warehouseIds.add(myCurrentWarehouse.getId());
+			}
+			indexDTO.setWarehouseIds(warehouseIds);
+
+			//查询订制品打托列表
+			IndexUnloadAbnormalDataVO indexUnloadAbnormalDataVO = warehouseIndexService.unloadAbnormalData(indexDTO);
+			return R.data(indexUnloadAbnormalDataVO);
+		}catch (CustomerException e){
+			log.warn(e.message);
+			return R.fail(e.code,e.message);
+		}catch (Exception e){
+			log.error(method+"系统异常，联系管理员",e);
+			return R.fail(500,"系统异常，联系管理员");
+		}
+	}
+
+
+}

blade-service/logpm-report/src/main/java/com/logpm/report/dto/IndexDTO.java

@@ -0,0 +1,16 @@
+package com.logpm.report.dto;
+
+import lombok.Data;
+
+import java.io.Serializable;
+import java.util.Date;
+import java.util.List;
+
+@Data
+public class IndexDTO implements Serializable {
+
+	private List<Long> warehouseIds;
+	private Date startDate;
+	private Date endDate;
+
+}

blade-service/logpm-report/src/main/java/com/logpm/report/mapper/WarehouseIndexMapper.java

@@ -0,0 +1,42 @@
+package com.logpm.report.mapper;
+
+import com.alibaba.fastjson.JSONObject;
+import com.logpm.report.dto.IndexDTO;
+import com.logpm.report.vo.IndexHandOrderDataVO;
+import com.logpm.report.vo.IndexTrunklineCarsDataVO;
+import org.apache.ibatis.annotations.Mapper;
+import org.apache.ibatis.annotations.Param;
+
+import java.math.BigDecimal;
+
+@Mapper
+public interface WarehouseIndexMapper {
+
+	int findTotalNum(@Param("param") IndexDTO indexDTO);
+
+	BigDecimal findTotalFee(@Param("param") IndexDTO indexDTO);
+
+	JSONObject findFeeByDate(@Param("param") IndexDTO indexDTO);
+
+	IndexHandOrderDataVO handOrderData(@Param("param") IndexDTO indexDTO);
+
+	Integer findHandStockListNum(@Param("param") IndexDTO indexDTO);
+
+	Integer findTrayNum(@Param("param") IndexDTO indexDTO);
+
+	Integer findTotalAllocationNum(@Param("param") IndexDTO indexDTO);
+
+	Integer findUseAllocationNum(@Param("param") IndexDTO indexDTO);
+
+	Integer findUpshelfNum(@Param("param") IndexDTO indexDTO);
+
+	JSONObject findPackageTrunklineHandOrderData(@Param("param") IndexDTO indexDTO);
+
+	JSONObject findZeroTrunklineHandOrderData(@Param("param") IndexDTO indexDTO);
+
+	IndexTrunklineCarsDataVO trunklineCarsData(@Param("param") IndexDTO indexDTO);
+
+	JSONObject findAbnormalData(@Param("param") IndexDTO indexDTO);
+
+	Integer findUnloadNum(@Param("param") IndexDTO indexDTO);
+}

blade-service/logpm-report/src/main/java/com/logpm/report/mapper/WarehouseIndexMapper.xml

@@ -0,0 +1,204 @@
+<?xml version="1.0" encoding="UTF-8"?>
+<!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" "http://mybatis.org/dtd/mybatis-3-mapper.dtd">
+<mapper namespace="com.logpm.report.mapper.WarehouseIndexMapper">
+
+    <select id="findTotalNum" resultType="int">
+        select IFNULL(count(id),0)
+        from logpm_warehouse_waybill
+        where 1=1
+        <if test="param.startDate != null">
+            and create_time &gt;= #{param.startDate}
+        </if>
+        <if test="param.endDate != null">
+            and create_time &lt;= #{param.endDate}
+        </if>
+        and departure_warehouse_id in
+        <foreach collection="param.warehouseIds" item="item" open="(" separator="," close=")">
+            #{item}
+        </foreach>
+    </select>
+
+
+    <select id="findTotalFee" resultType="java.math.BigDecimal">
+        select IFNULL(sum(IFNULL(x_pay,0)+IFNULL(d_pay,0)+IFNULL(y_pay,0)+IFNULL(h_pay,0)),0)
+        from logpm_warehouse_waybill
+        where 1=1
+        and departure_warehouse_id in
+        <foreach collection="param.warehouseIds" item="item" open="(" separator="," close=")">
+            #{item}
+        </foreach>
+    </select>
+
+    <select id="findFeeByDate" resultType="com.alibaba.fastjson.JSONObject">
+        select IFNULL(sum(IFNULL(x_pay,0)+IFNULL(d_pay,0)+IFNULL(y_pay,0)+IFNULL(h_pay,0)),0) fee,
+               IFNULL(sum(IFNULL(total_freight,0)),0) trunklineFee,
+                IFNULL(sum(IFNULL(storage_fee,0)),0) warehouseFee,
+                IFNULL(sum(IFNULL(delivery_fee,0)),0) distributionFee,
+                IFNULL(sum(IFNULL(pickup_fee,0)),0) billladingFee,
+                IFNULL(sum(IFNULL(install_fee,0)),0) installFee
+        from logpm_warehouse_waybill
+        where 1=1
+        <if test="param.startDate != null">
+            and create_time &gt;= #{param.startDate}
+        </if>
+        <if test="param.endDate != null">
+            and create_time &lt;= #{param.endDate}
+        </if>
+        and departure_warehouse_id in
+        <foreach collection="param.warehouseIds" item="item" open="(" separator="," close=")">
+            #{item}
+        </foreach>
+    </select>
+
+
+    <select id="handOrderData" resultType="com.logpm.report.vo.IndexHandOrderDataVO">
+        select IFNULL(sum(hand_quantity),0) totalNum,
+               IFNULL(SUM(IF(is_zero=1,hand_quantity,0)),0) zeroNum,
+               IFNULL(SUM(IF(type_service='1',hand_quantity,0)),0) mallNum,
+               IFNULL(SUM(IF(type_service='2',hand_quantity,0)),0) cityNum,
+               IFNULL(SUM(IF(type_service='3',hand_quantity,0)),0) billNum,
+               IFNULL(SUM(IF(type_service='4',hand_quantity,0)),0) thirdTransferNum
+        from logpm_distribution_stock_article
+        WHERE 1=1
+        and warehouse_id in
+        <foreach collection="param.warehouseIds" item="item" open="(" separator="," close=")">
+            #{item}
+        </foreach>
+    </select>
+
+    <select id="findHandStockListNum" resultType="int">
+        select IFNULL(sum(quantity_stock),0)
+        from logpm_distribution_stock_list
+        where 1=1
+        and warehouse_id in
+        <foreach collection="param.warehouseIds" item="item" open="(" separator="," close=")">
+            #{item}
+        </foreach>
+    </select>
+
+    <select id="findTrayNum" resultType="int">
+        select IFNULL(sum(num),0)
+        from logpm_warehouse_tray_goods
+        where 1=1
+        and warehouse_id in
+        <foreach collection="param.warehouseIds" item="item" open="(" separator="," close=")">
+            #{item}
+        </foreach>
+    </select>
+
+    <select id="findTotalAllocationNum" resultType="int">
+        select IFNULL(count(id),0)
+        from logpm_warehouse_goods_allocation
+        where 1=1
+        and is_deleted = 0
+        and enable_status = 1
+        and warehouse_id in
+        <foreach collection="param.warehouseIds" item="item" open="(" separator="," close=")">
+            #{item}
+        </foreach>
+    </select>
+
+    <select id="findUseAllocationNum" resultType="int">
+        select IFNULL(count(id),0)
+        from logpm_warehouse_updown_type
+        where 1=1
+        and is_deleted = 0
+        and warehouse_id in
+        <foreach collection="param.warehouseIds" item="item" open="(" separator="," close=")">
+            #{item}
+        </foreach>
+    </select>
+
+    <select id="findUpshelfNum" resultType="int">
+        select IFNULL(sum(num),0)
+        from logpm_warehouse_updown_goods
+        where 1=1
+        and warehouse_id in
+        <foreach collection="param.warehouseIds" item="item" open="(" separator="," close=")">
+            #{item}
+        </foreach>
+    </select>
+
+    <select id="findPackageTrunklineHandOrderData" resultType="com.alibaba.fastjson.JSONObject">
+        select IFNULL(count(distinct lww.id),0) waybillNum,
+                IFNULL(sum(ldpl.quantity),0) handleNum,
+                IFNULL(sum(ldpl.weight),0) handleWeight,
+                IFNULL(sum(ldpl.volume),0) handleVolume
+        from logpm_distribution_parcel_list ldpl
+        left join logpm_distribution_stock_article ldsa on ldsa.id = ldpl.stock_article_id
+        left join logpm_warehouse_waybill lww on ldpl.waybill_number = lww.waybill_no and lww.departure_warehouse_id = ldpl.warehouse_id
+        where 1=1
+        and ldsa.is_zero = 0
+        and ldpl.order_package_status = '20'
+        and ldpl.warehouse_id in
+        <foreach collection="param.warehouseIds" item="item" open="(" separator="," close=")">
+            #{item}
+        </foreach>
+    </select>
+
+    <select id="findZeroTrunklineHandOrderData" resultType="com.alibaba.fastjson.JSONObject">
+        select IFNULL(count(distinct lww.waybill_no),0) waybillNum,
+                IFNULL(sum(ldsa.hand_quantity),0) handleNum,
+               0 handleWeight,
+               0 handleVolume
+        from logpm_distribution_stock_article ldsa
+        left join logpm_warehouse_waybill lww on lww.departure_warehouse_id = ldsa.warehouse_id and lww.waybill_no = ldsa.order_code
+        where 1=1
+        and ldsa.hand_quantity > 0
+        and ldsa.is_zero = 1
+        and ldsa.warehouse_id in
+        <foreach collection="param.warehouseIds" item="item" open="(" separator="," close=")">
+            #{item}
+        </foreach>
+    </select>
+
+    <select id="trunklineCarsData" resultType="com.logpm.report.vo.IndexTrunklineCarsDataVO">
+        select IFNULL(count(distinct load_id),0) totalNum,
+               IFNULL(sum(if(node_status = '0',1,0)),0) inTransitNum,
+               IFNULL(sum(if(node_status != '0',1,0)),0) workNum,
+               IFNULL(sum(if(unload_status != '0',1,0)),0) unloadNum
+        from logpm_trunkline_cars_load_line
+        where 1=1
+        and is_deleted = 0
+        and node_id in
+        <foreach collection="param.warehouseIds" item="item" open="(" separator="," close=")">
+            #{item}
+        </foreach>
+    </select>
+
+    <select id="findAbnormalData" resultType="com.alibaba.fastjson.JSONObject">
+        select IFNULL(count(id),0) sendNum,
+               IFNULL(sum(abnormal_status),0) dealNum
+        from logpm_aftersales_abnormal_record
+        where 1=1
+        <if test="param.startDate != null">
+            and create_time &gt;= #{param.startDate}
+        </if>
+          <if test="param.endDate != null">
+            and create_time &lt;= #{param.endDate}
+          </if>
+        and warehouse_id in
+        <foreach collection="param.warehouseIds" item="item" open="(" separator="," close=")">
+            #{item}
+        </foreach>
+    </select>
+
+    <select id="findUnloadNum" resultType="int">
+        select IFNULL(sum(unload_number),0)
+        from logpm_trunkline_cars_load_line
+        where 1=1
+        and is_deleted = 0
+        and unload_status != '0'
+        <if test="param.startDate != null">
+            and unload_date &gt;= #{param.startDate}
+        </if>
+          <if test="param.endDate != null">
+            and unload_date &lt;= #{param.endDate}
+          </if>
+        and node_id in
+        <foreach collection="param.warehouseIds" item="item" open="(" separator="," close=")">
+            #{item}
+        </foreach>
+    </select>
+
+</mapper>

blade-service/logpm-report/src/main/java/com/logpm/report/service/IWarehouseIndexService.java

@@ -0,0 +1,21 @@
+package com.logpm.report.service;
+
+import com.logpm.report.dto.IndexDTO;
+import com.logpm.report.vo.*;
+
+public interface IWarehouseIndexService {
+	IndexOpenOrderDataVO openOrderData(IndexDTO indexDTO);
+
+	IndexOpenOrderIncomeVO openOrderIncome(IndexDTO indexDTO);
+
+	IndexHandOrderDataVO handOrderData(IndexDTO indexDTO);
+
+	IndexAllocationDataVO allocationData(IndexDTO indexDTO);
+
+	IndexTrunklineHandOrderDataVO trunklineHandOrderData(IndexDTO indexDTO);
+
+	IndexTrunklineCarsDataVO trunklineCarsData(IndexDTO indexDTO);
+
+	IndexUnloadAbnormalDataVO unloadAbnormalData(IndexDTO indexDTO);
+
+}

blade-service/logpm-report/src/main/java/com/logpm/report/service/impl/WarehouseIndexServiceImpl.java

@@ -0,0 +1,239 @@
+package com.logpm.report.service.impl;
+
+import com.alibaba.fastjson.JSONObject;
+import com.logpm.report.dto.IndexDTO;
+import com.logpm.report.mapper.WarehouseIndexMapper;
+import com.logpm.report.service.IWarehouseIndexService;
+import com.logpm.report.vo.*;
+import lombok.AllArgsConstructor;
+import lombok.extern.slf4j.Slf4j;
+import org.springblade.common.utils.CommonUtil;
+import org.springframework.stereotype.Service;
+
+import java.math.BigDecimal;
+import java.util.Calendar;
+import java.util.Date;
+import java.util.List;
+
+@Slf4j
+@Service
+@AllArgsConstructor
+public class WarehouseIndexServiceImpl implements IWarehouseIndexService {
+
+	private WarehouseIndexMapper warehouseIndexMapper;
+
+	@Override
+	public IndexOpenOrderDataVO openOrderData(IndexDTO indexDTO) {
+		List<Long> warehouseIds = indexDTO.getWarehouseIds();
+		IndexOpenOrderDataVO indexOpenOrderDataVO = new IndexOpenOrderDataVO();
+		if(warehouseIds.isEmpty()){
+			return indexOpenOrderDataVO;
+		}
+
+		indexOpenOrderDataVO.setTotalNum(warehouseIndexMapper.findTotalNum(indexDTO));
+		Calendar calendar = Calendar.getInstance();
+		calendar.set(Calendar.HOUR_OF_DAY, 0);
+		calendar.set(Calendar.MINUTE, 0);
+		calendar.set(Calendar.SECOND, 0);
+		calendar.set(Calendar.MILLISECOND, 0);
+		Date dayStart = calendar.getTime();
+		calendar.set(Calendar.HOUR_OF_DAY, 23);
+		calendar.set(Calendar.MINUTE, 59);
+		calendar.set(Calendar.SECOND, 59);
+		calendar.set(Calendar.MILLISECOND, 999);
+		Date dayEnd = calendar.getTime();
+		indexDTO.setStartDate(dayStart);
+		indexDTO.setEndDate(dayEnd);
+		indexOpenOrderDataVO.setDayNum(warehouseIndexMapper.findTotalNum(indexDTO));
+		// 设置日为1，以获取当前月的第一天
+		calendar.set(Calendar.DAY_OF_MONTH, 1);
+		// 将小时、分钟、秒和毫秒设置为0，确保获取的是完整的第一天
+		calendar.set(Calendar.HOUR_OF_DAY, 0);
+		calendar.set(Calendar.MINUTE, 0);
+		calendar.set(Calendar.SECOND, 0);
+		calendar.set(Calendar.MILLISECOND, 0);
+		Date firstDayOfMonth = calendar.getTime(); // 获取第一天
+
+		// 获取下个月的第一天
+		calendar.add(Calendar.MONTH, 1);
+		// 再将日减1，以得到当前月的最后一天
+		calendar.set(Calendar.DAY_OF_MONTH, 1);
+		calendar.add(Calendar.DATE, -1);
+		// 同样确保时间部分为0
+		calendar.set(Calendar.HOUR_OF_DAY, 23);
+		calendar.set(Calendar.MINUTE, 59);
+		calendar.set(Calendar.SECOND, 59);
+		calendar.set(Calendar.MILLISECOND, 999);
+		Date lastDayOfMonth = calendar.getTime(); // 获取最后一天
+		indexDTO.setStartDate(firstDayOfMonth);
+		indexDTO.setEndDate(lastDayOfMonth);
+		indexOpenOrderDataVO.setMonthNum(warehouseIndexMapper.findTotalNum(indexDTO));
+
+		return indexOpenOrderDataVO;
+	}
+
+	@Override
+	public IndexOpenOrderIncomeVO openOrderIncome(IndexDTO indexDTO) {
+		List<Long> warehouseIds = indexDTO.getWarehouseIds();
+		IndexOpenOrderIncomeVO indexOpenOrderIncomeVO = new IndexOpenOrderIncomeVO();
+		if(warehouseIds.isEmpty()){
+			return indexOpenOrderIncomeVO;
+		}
+		//总收入
+		indexOpenOrderIncomeVO.setTotalFee(warehouseIndexMapper.findTotalFee(indexDTO));
+		//获取当天的开始时间
+		indexDTO.setStartDate(CommonUtil.getDayStart());
+		indexDTO.setEndDate(CommonUtil.getDayEnd());
+		JSONObject incomeDay = warehouseIndexMapper.findFeeByDate(indexDTO);
+		indexOpenOrderIncomeVO.setDayFee(incomeDay.getBigDecimal("fee"));
+		indexOpenOrderIncomeVO.setDayBillladingFee(incomeDay.getBigDecimal("billladingFee"));
+		indexOpenOrderIncomeVO.setDayInstallFee(incomeDay.getBigDecimal("installFee"));
+		indexOpenOrderIncomeVO.setDayTrunklineFee(incomeDay.getBigDecimal("trunklineFee"));
+		indexOpenOrderIncomeVO.setDayWarehouseFee(incomeDay.getBigDecimal("warehouseFee"));
+		indexOpenOrderIncomeVO.setDayDistributionFee(incomeDay.getBigDecimal("distributionFee"));
+		//获取当月的开始时间
+		indexDTO.setStartDate(CommonUtil.getMonthDayStart());
+		indexDTO.setEndDate(CommonUtil.getMonthDayEnd());
+		JSONObject incomeMonth = warehouseIndexMapper.findFeeByDate(indexDTO);
+		indexOpenOrderIncomeVO.setMonthFee(incomeMonth.getBigDecimal("fee"));
+		indexOpenOrderIncomeVO.setMonthBillladingFee(incomeMonth.getBigDecimal("billladingFee"));
+		indexOpenOrderIncomeVO.setMonthInstallFee(incomeMonth.getBigDecimal("installFee"));
+		indexOpenOrderIncomeVO.setMonthTrunklineFee(incomeMonth.getBigDecimal("trunklineFee"));
+		indexOpenOrderIncomeVO.setMonthWarehouseFee(incomeMonth.getBigDecimal("warehouseFee"));
+		indexOpenOrderIncomeVO.setMonthDistributionFee(incomeMonth.getBigDecimal("distributionFee"));
+
+		return indexOpenOrderIncomeVO;
+	}
+
+	@Override
+	public IndexHandOrderDataVO handOrderData(IndexDTO indexDTO) {
+		List<Long> warehouseIds = indexDTO.getWarehouseIds();
+		IndexHandOrderDataVO indexHandOrderDataVO = new IndexHandOrderDataVO();
+		if(warehouseIds.isEmpty()){
+			return indexHandOrderDataVO;
+		}
+		//当前在库的数据 订制品 零担
+		indexHandOrderDataVO = warehouseIndexMapper.handOrderData(indexDTO);
+		//当前在库的库存品
+		Integer stockListNum = warehouseIndexMapper.findHandStockListNum(indexDTO);
+		indexHandOrderDataVO.setTotalNum(indexHandOrderDataVO.getTotalNum() + stockListNum);
+
+		//已打托数量
+		Integer trayNum = warehouseIndexMapper.findTrayNum(indexDTO);
+		indexHandOrderDataVO.setTrayNum(trayNum);
+
+		return indexHandOrderDataVO;
+	}
+
+	@Override
+	public IndexAllocationDataVO allocationData(IndexDTO indexDTO) {
+		List<Long> warehouseIds = indexDTO.getWarehouseIds();
+		IndexAllocationDataVO indexAllocationDataVO = new IndexAllocationDataVO();
+		if(warehouseIds.isEmpty()){
+			return indexAllocationDataVO;
+		}
+		//当前在库的数据 订制品 零担
+		IndexHandOrderDataVO indexHandOrderDataVO = warehouseIndexMapper.handOrderData(indexDTO);
+		//当前在库的库存品
+		Integer stockListNum = warehouseIndexMapper.findHandStockListNum(indexDTO);
+		Integer totalNum = indexHandOrderDataVO.getTotalNum() + stockListNum;
+
+		//查询库位总数
+		Integer totalAllocationNum = warehouseIndexMapper.findTotalAllocationNum(indexDTO);
+		//已使用库位数
+		Integer useAllocationNum = warehouseIndexMapper.findUseAllocationNum(indexDTO);
+		//已上架件数
+		Integer upshelfNum = warehouseIndexMapper.findUpshelfNum(indexDTO);
+
+		indexAllocationDataVO.setTotalNum(totalAllocationNum);
+		indexAllocationDataVO.setUseNum(useAllocationNum);
+		indexAllocationDataVO.setNullNum(totalAllocationNum - useAllocationNum);
+		indexAllocationDataVO.setUpshelfNum(upshelfNum);
+		indexAllocationDataVO.setNoUpshelfNum(totalNum-upshelfNum);
+
+		return indexAllocationDataVO;
+	}
+
+	@Override
+	public IndexTrunklineHandOrderDataVO trunklineHandOrderData(IndexDTO indexDTO) {
+		List<Long> warehouseIds = indexDTO.getWarehouseIds();
+		IndexTrunklineHandOrderDataVO indexTrunklineHandOrderDataVO = new IndexTrunklineHandOrderDataVO();
+		if(warehouseIds.isEmpty()){
+			return indexTrunklineHandOrderDataVO;
+		}
+
+		//订制品
+		JSONObject packageJson = warehouseIndexMapper.findPackageTrunklineHandOrderData(indexDTO);
+		Integer packageWaybillNum = packageJson.getInteger("waybillNum");
+		Integer packageHandleNum = packageJson.getInteger("handleNum");
+		BigDecimal packageHandleWeight = packageJson.getBigDecimal("handleWeight");
+		BigDecimal packageHandleVolume = packageJson.getBigDecimal("handleVolume");
+		//零担
+		JSONObject zeroJson = warehouseIndexMapper.findZeroTrunklineHandOrderData(indexDTO);
+		Integer zeroWaybillNum = zeroJson.getInteger("waybillNum");
+		Integer zeroHandleNum = zeroJson.getInteger("handleNum");
+		BigDecimal zeroHandleWeight = zeroJson.getBigDecimal("handleWeight");
+		BigDecimal zeroHandleVolume = zeroJson.getBigDecimal("handleVolume");
+
+		indexTrunklineHandOrderDataVO.setWaybillNum(packageWaybillNum + zeroWaybillNum);
+		indexTrunklineHandOrderDataVO.setHandleNum(packageHandleNum + zeroHandleNum);
+		indexTrunklineHandOrderDataVO.setHandleWeight(packageHandleWeight.add(zeroHandleWeight));
+		indexTrunklineHandOrderDataVO.setHandleVolume(packageHandleVolume.add(zeroHandleVolume));
+
+		return indexTrunklineHandOrderDataVO;
+	}
+
+	@Override
+	public IndexTrunklineCarsDataVO trunklineCarsData(IndexDTO indexDTO) {
+		List<Long> warehouseIds = indexDTO.getWarehouseIds();
+		IndexTrunklineCarsDataVO indexTrunklineCarsDataVO = new IndexTrunklineCarsDataVO();
+		if(warehouseIds.isEmpty()){
+			return indexTrunklineCarsDataVO;
+		}
+
+		indexTrunklineCarsDataVO = warehouseIndexMapper.trunklineCarsData(indexDTO);
+
+		return indexTrunklineCarsDataVO;
+	}
+
+	@Override
+	public IndexUnloadAbnormalDataVO unloadAbnormalData(IndexDTO indexDTO) {
+		List<Long> warehouseIds = indexDTO.getWarehouseIds();
+		IndexUnloadAbnormalDataVO indexUnloadAbnormalDataVO = new IndexUnloadAbnormalDataVO();
+		if(warehouseIds.isEmpty()){
+			return indexUnloadAbnormalDataVO;
+		}
+
+		indexDTO.setStartDate(CommonUtil.getDayStart());
+		indexDTO.setEndDate(CommonUtil.getDayEnd());
+		JSONObject dayJson = warehouseIndexMapper.findAbnormalData(indexDTO);
+		Integer sendDayNum = dayJson.getInteger("sendNum");
+		Integer dealDayNum = dayJson.getInteger("dealNum");
+		Integer unloadDayNum = warehouseIndexMapper.findUnloadNum(indexDTO);
+		indexUnloadAbnormalDataVO.setSendDayNum(sendDayNum);
+		indexUnloadAbnormalDataVO.setNoDealDayNum(sendDayNum - dealDayNum);
+		indexUnloadAbnormalDataVO.setUnloadDayNum(unloadDayNum);
+		BigDecimal dayRate = BigDecimal.ZERO;
+		if(!unloadDayNum.equals(0)){
+			dayRate = new BigDecimal(sendDayNum).divide(new BigDecimal(unloadDayNum), 4, BigDecimal.ROUND_HALF_UP).multiply(new BigDecimal(100));
+		}
+		indexUnloadAbnormalDataVO.setAbnormalDayRate(dayRate);
+
+		indexDTO.setStartDate(CommonUtil.getMonthDayStart());
+		indexDTO.setEndDate(CommonUtil.getMonthDayEnd());
+		JSONObject monthJson = warehouseIndexMapper.findAbnormalData(indexDTO);
+		Integer sendMonthNum = monthJson.getInteger("sendNum");
+		Integer dealMonthNum = monthJson.getInteger("dealNum");
+		Integer unloadMonthNum = warehouseIndexMapper.findUnloadNum(indexDTO);
+		indexUnloadAbnormalDataVO.setSendMonthNum(sendMonthNum);
+		indexUnloadAbnormalDataVO.setNoDealMonthNum(sendMonthNum - dealMonthNum);
+		indexUnloadAbnormalDataVO.setUnloadMonthNum(unloadMonthNum);
+		BigDecimal monthRate = BigDecimal.ZERO;
+		if(!unloadMonthNum.equals(0)){
+			monthRate = new BigDecimal(sendMonthNum).divide(new BigDecimal(unloadMonthNum),4, BigDecimal.ROUND_HALF_UP).multiply(new BigDecimal(100));
+		}
+		indexUnloadAbnormalDataVO.setAbnormalMonthRate(monthRate);
+
+		return indexUnloadAbnormalDataVO;
+	}
+}

blade-service/logpm-report/src/main/java/com/logpm/report/vo/IndexAllocationDataVO.java

@@ -0,0 +1,16 @@
+package com.logpm.report.vo;
+
+import lombok.Data;
+
+import java.io.Serializable;
+
+@Data
+public class IndexAllocationDataVO implements Serializable {
+
+	private Integer totalNum = 0;
+	private Integer useNum = 0;
+	private Integer nullNum = 0;
+	private Integer upshelfNum = 0;
+	private Integer noUpshelfNum = 0;
+
+}

blade-service/logpm-report/src/main/java/com/logpm/report/vo/IndexHandOrderDataVO.java

@@ -0,0 +1,18 @@
+package com.logpm.report.vo;
+
+import lombok.Data;
+
+import java.io.Serializable;
+
+@Data
+public class IndexHandOrderDataVO implements Serializable {
+
+	private Integer totalNum = 0;
+	private Integer zeroNum = 0;
+	private Integer thirdTransferNum = 0;
+	private Integer mallNum = 0;
+	private Integer cityNum = 0;
+	private Integer billNum = 0;
+	private Integer trayNum = 0;
+
+}

blade-service/logpm-report/src/main/java/com/logpm/report/vo/IndexOpenOrderDataVO.java

@@ -0,0 +1,15 @@
+package com.logpm.report.vo;
+
+import lombok.Data;
+
+import java.io.Serializable;
+
+@Data
+public class IndexOpenOrderDataVO implements Serializable {
+
+
+	private int totalNum = 0;
+	private int monthNum = 0;
+	private int dayNum = 0;
+
+}

blade-service/logpm-report/src/main/java/com/logpm/report/vo/IndexOpenOrderIncomeVO.java

@@ -0,0 +1,26 @@
+package com.logpm.report.vo;
+
+import lombok.Data;
+
+import java.io.Serializable;
+import java.math.BigDecimal;
+
+@Data
+public class IndexOpenOrderIncomeVO implements Serializable {
+
+	private BigDecimal totalFee = BigDecimal.ZERO;
+	private BigDecimal monthFee = BigDecimal.ZERO;
+	private BigDecimal monthTrunklineFee = BigDecimal.ZERO;
+	private BigDecimal monthWarehouseFee = BigDecimal.ZERO;
+	private BigDecimal monthDistributionFee = BigDecimal.ZERO;
+	private BigDecimal monthBillladingFee = BigDecimal.ZERO;
+	private BigDecimal monthInstallFee = BigDecimal.ZERO;
+	private BigDecimal dayFee = BigDecimal.ZERO;
+	private BigDecimal dayTrunklineFee = BigDecimal.ZERO;
+	private BigDecimal dayWarehouseFee = BigDecimal.ZERO;
+	private BigDecimal dayDistributionFee = BigDecimal.ZERO;
+	private BigDecimal dayBillladingFee = BigDecimal.ZERO;
+	private BigDecimal dayInstallFee = BigDecimal.ZERO;
+
+
+}

blade-service/logpm-report/src/main/java/com/logpm/report/vo/IndexTrunklineCarsDataVO.java

@@ -0,0 +1,16 @@
+package com.logpm.report.vo;
+
+import lombok.Data;
+
+import java.io.Serializable;
+
+@Data
+public class IndexTrunklineCarsDataVO implements Serializable {
+
+	private Integer totalNum = 0;
+	private Integer inTransitNum = 0;
+	private Integer workNum = 0;
+	private Integer unloadNum = 0;
+
+
+}

blade-service/logpm-report/src/main/java/com/logpm/report/vo/IndexTrunklineHandOrderDataVO.java

@@ -0,0 +1,16 @@
+package com.logpm.report.vo;
+
+import lombok.Data;
+
+import java.io.Serializable;
+import java.math.BigDecimal;
+
+@Data
+public class IndexTrunklineHandOrderDataVO implements Serializable {
+
+	private Integer waybillNum = 0;
+	private Integer handleNum = 0;
+	private BigDecimal handleWeight = BigDecimal.ZERO;
+	private BigDecimal handleVolume = BigDecimal.ZERO;
+
+}

blade-service/logpm-report/src/main/java/com/logpm/report/vo/IndexUnloadAbnormalDataVO.java

@@ -0,0 +1,21 @@
+package com.logpm.report.vo;
+
+import lombok.Data;
+
+import java.io.Serializable;
+import java.math.BigDecimal;
+
+@Data
+public class IndexUnloadAbnormalDataVO implements Serializable {
+
+	private Integer sendDayNum = 0;
+	private Integer noDealDayNum = 0;
+	private Integer unloadDayNum = 0;
+	private BigDecimal abnormalDayRate = BigDecimal.ZERO;
+
+	private Integer sendMonthNum = 0;
+	private Integer noDealMonthNum = 0;
+	private Integer unloadMonthNum = 0;
+	private BigDecimal abnormalMonthRate = BigDecimal.ZERO;
+
+}

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

@@ -1,10 +1,13 @@
 package com.logpm.trunkline.service.impl;
 
+import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
 import com.logpm.trunkline.entity.TrunklineCarsLoadEntity;
 import com.logpm.trunkline.entity.TrunklineCarsLoadLineEntity;
 import com.logpm.trunkline.entity.TrunklineCarsLoadLogEntity;
+import com.logpm.trunkline.entity.TrunklineCarsLoadScanEntity;
 import com.logpm.trunkline.mapper.TrunklineCarsLoadLogMapper;
 import com.logpm.trunkline.service.ITrunklineCarsLoadLogService;
+import com.logpm.trunkline.service.ITrunklineCarsLoadScanService;
 import lombok.AllArgsConstructor;
 import lombok.extern.slf4j.Slf4j;
 import org.springblade.common.constant.carsload.CarsLoadLogTypeConstant;
@@ -14,12 +17,16 @@ import org.springblade.core.secure.utils.AuthUtil;
 import org.springframework.stereotype.Service;
 
 import java.util.Date;
+import java.util.List;
 import java.util.Objects;
 
 @Slf4j
 @Service
 @AllArgsConstructor
 public class TrunklineCarsLoadLogServiceImpl extends BaseServiceImpl<TrunklineCarsLoadLogMapper, TrunklineCarsLoadLogEntity> implements ITrunklineCarsLoadLogService {
+
+	private final ITrunklineCarsLoadScanService carsLoadScanService;
+
 	@Override
 	public void saveLog(TrunklineCarsLoadEntity carsLoadEntity, TrunklineCarsLoadLineEntity carsLoadLineEntity, int cardLoadType) {
 		String nodeName = null;
@@ -34,6 +41,7 @@ public class TrunklineCarsLoadLogServiceImpl extends BaseServiceImpl<TrunklineCa
 			startDate = carsLoadLineEntity.getStartDate();
 			nodeId = carsLoadLineEntity.getNodeId();
 		}
+		Long loadId = carsLoadEntity.getId();
 		String carsNo = carsLoadEntity.getCarsNo();
 		String carNumber = carsLoadEntity.getCarNumber();
 		String driverName = carsLoadEntity.getDriverName();
@@ -44,7 +52,7 @@ public class TrunklineCarsLoadLogServiceImpl extends BaseServiceImpl<TrunklineCa
 		TrunklineCarsLoadLogEntity carsLoadLogEntity = new TrunklineCarsLoadLogEntity();
 		carsLoadLogEntity.setNodeId(nodeId);
 		carsLoadLogEntity.setNodeName(nodeName);
-		carsLoadLogEntity.setLoadId(carsLoadEntity.getId());
+		carsLoadLogEntity.setLoadId(loadId);
 		carsLoadLogEntity.setLoadCode(carsNo);
 		carsLoadLogEntity.setCarNumber(carNumber);
 		carsLoadLogEntity.setDriverName(driverName);
@@ -117,6 +125,26 @@ public class TrunklineCarsLoadLogServiceImpl extends BaseServiceImpl<TrunklineCa
 				content = "【"+nodeName+"】终点卸车，车次号："+carsNo+"，车牌号："+carNumber+"，司机姓名："+driverName+
 					"，司机手机号："+driverMobile+"，终点卸车时间："+ now;
 				break;
+			case 16:
+				QueryWrapper<TrunklineCarsLoadScanEntity> queryWrapper = new QueryWrapper<>();
+				queryWrapper.eq("load_id",loadId)
+					.eq("scan_status","3");
+				List<TrunklineCarsLoadScanEntity> list = carsLoadScanService.list(queryWrapper);
+				Integer signNum = 0;
+				if(!list.isEmpty()){
+					signNum = list.size();
+				}
+				content = "【"+nodeName+"】三方中转签收，车次号："+carsNo+"，车牌号："+carNumber+"，司机姓名："+driverName+
+					"，司机手机号："+driverMobile+"，签收件数："+ signNum + "/" + realLoadingNumber + "件";
+				break;
+			case 17:
+				content = "【"+nodeName+"】三方中转结算，车次号："+carsNo+"，车牌号："+carNumber+"，司机姓名："+driverName+
+					"，司机手机号："+driverMobile+"，结算时间："+ now;
+				break;
+			case 18:
+				content = "【"+nodeName+"】直发商家签收，车次号："+carsNo+"，车牌号："+carNumber+"，司机姓名："+driverName+
+					"，司机手机号："+driverMobile+"，签收时间："+ now;
+				break;
 			default:
 				content = "【"+nodeName+"】其他日志，车次号："+carsNo+"，车牌号："+carNumber+"，司机姓名："+driverName+
 					"，司机手机号："+driverMobile;
@@ -124,6 +152,21 @@ public class TrunklineCarsLoadLogServiceImpl extends BaseServiceImpl<TrunklineCa
 		carsLoadLogEntity.setContent(content);
 		carsLoadLogEntity.setType(cardLoadType);
 		carsLoadLogEntity.setCreateUserName(AuthUtil.getNickName());
-		save(carsLoadLogEntity);
+
+		if(CarsLoadLogTypeConstant.TRIPARTITE_TRANSFER_SIGN.getValue().equals(cardLoadType)){
+			QueryWrapper<TrunklineCarsLoadLogEntity> qw = new QueryWrapper<>();
+			qw.eq("node_id",nodeId)
+				.eq("load_id",loadId)
+				.eq("type",cardLoadType);
+			TrunklineCarsLoadLogEntity carsLoadLogEntity1 = baseMapper.selectOne(qw);
+			if(Objects.isNull(carsLoadLogEntity1)){
+				save(carsLoadLogEntity);
+			}else{
+				carsLoadLogEntity1.setContent(content);
+				updateById(carsLoadLogEntity1);
+			}
+		}else{
+			save(carsLoadLogEntity);
+		}
 	}
 }

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

@@ -2028,6 +2028,8 @@ public class TrunklineCarsLoadServiceImpl extends BaseServiceImpl<TrunklineCarsL
 		trunklineCarsLoadScanService.updateScanStatusByLoadId(loadId, "3", new Date());
 
 		try {
+			trunklineCarsLoadLogService.saveLog(carsLoadEntity, null, CarsLoadLogTypeConstant.TRIPARTITE_TRANSFER_SIGN.getValue());
+
 			List<String> orderPackageCodes = trunklineCarsLoadScanService.findSignListOrderPackageCodes(loadId);
 
 			String content = "包件在" + warehouseEntity.getName() + "被三方中转整车签收";
@@ -2065,6 +2067,8 @@ public class TrunklineCarsLoadServiceImpl extends BaseServiceImpl<TrunklineCarsL
 		carsLoadEntity.setSettlementPersonId(AuthUtil.getUserId());
 		updateById(carsLoadEntity);
 
+		trunklineCarsLoadLogService.saveLog(carsLoadEntity, null, CarsLoadLogTypeConstant.TRIPARTITE_TRANSFER_SETTLEMENT.getValue());
+
 		return R.success("结算成功");
 	}
 

blade-service/logpm-warehouse/src/main/java/com/logpm/warehouse/mapper/WarehouseWaybillMapper.java

@@ -68,4 +68,5 @@ public interface WarehouseWaybillMapper extends BaseMapper<WarehouseWaybillEntit
 	List<WarehouseWaybillEntity> findWaybillBilllByWaybillNos(@Param("waybillNos") List<String> waybillNos);
 
     List<ExportWarehouseWaybillVO> exportWaybillList(@Param("param") WarehouseWaybillDTO waybillDTO);
+
 }

blade-service/logpm-warehouse/src/main/java/com/logpm/warehouse/service/ISendFanoutService.java

@@ -0,0 +1,7 @@
+package com.logpm.warehouse.service;
+
+import org.springblade.common.model.FanoutMsg;
+
+public interface ISendFanoutService {
+	void sendFanoutMsg(FanoutMsg fanoutMsg);
+}

blade-service/logpm-warehouse/src/main/java/com/logpm/warehouse/service/IWarehouseWaybillService.java

@@ -80,4 +80,5 @@ public interface IWarehouseWaybillService extends BaseService<WarehouseWaybillEn
 	List<WarehouseWaybillEntity> findWaybillBilllByWaybillNos(List<String> waybillNos);
 
     List<ExportWarehouseWaybillVO> exportWaybillList(WarehouseWaybillDTO waybillDTO);
+
 }

blade-service/logpm-warehouse/src/main/java/com/logpm/warehouse/service/impl/SendFanoutServiceImpl.java

@@ -0,0 +1,27 @@
+package com.logpm.warehouse.service.impl;
+
+import com.logpm.warehouse.service.ISendFanoutService;
+import lombok.AllArgsConstructor;
+import lombok.extern.slf4j.Slf4j;
+import org.springblade.common.model.FanoutMsg;
+import org.springframework.amqp.rabbit.core.RabbitTemplate;
+import org.springframework.stereotype.Service;
+
+@Service
+@AllArgsConstructor
+@Slf4j
+public class SendFanoutServiceImpl implements ISendFanoutService {
+
+	private final RabbitTemplate rabbitTemplate;
+
+//	@Retryable(value = Exception.class, maxAttempts = 3, backoff = @Backoff(value = 3000, multiplier = 1.5))
+	@Override
+	public void sendFanoutMsg(FanoutMsg fanoutMsg) {
+
+		rabbitTemplate.convertAndSend(fanoutMsg.getExchange(),null, fanoutMsg.getMsg(), message -> {
+			message.getMessageProperties().setHeader("x-delay", 1000);
+			return message;
+		});
+
+	}
+}

blade-service/logpm-warehouse/src/main/java/com/logpm/warehouse/service/impl/WarehouseUpdownGoodsServiceImpl.java

@@ -174,7 +174,7 @@ public class WarehouseUpdownGoodsServiceImpl extends BaseServiceImpl<WarehouseUp
 			updownGoodsLogEntities.add(warehouseUpdownGoodsLogEntity);
 
 
-			parcelListEntity.setOrderPackageGroundingStatus("20");
+//			parcelListEntity.setOrderPackageGroundingStatus("20");
 
 		});
 

blade-service/logpm-warehouse/src/main/java/com/logpm/warehouse/service/impl/WarehouseUpdownTypeServiceImpl.java

@@ -23,7 +23,9 @@ import com.logpm.warehouse.vo.*;
 import lombok.AllArgsConstructor;
 import lombok.extern.log4j.Log4j2;
 import org.springblade.common.constant.TenantNum;
+import org.springblade.common.constant.broadcast.FanoutConstants;
 import org.springblade.common.exception.CustomerException;
+import org.springblade.common.model.FanoutMsg;
 import org.springblade.core.mp.base.BaseServiceImpl;
 import org.springblade.core.tool.api.R;
 import org.springblade.core.tool.utils.BeanUtil;
@@ -58,6 +60,7 @@ public class WarehouseUpdownTypeServiceImpl extends BaseServiceImpl<WarehouseUpd
 	private final IWarehouseUpdownGoodsLogService warehouseUpdownGoodsLogService;
 	private final IBasicdataWarehouseClient warehouseClient;
 	private final IDistributionStockListInfoClient distributionStockListInfoClient;
+	private final ISendFanoutService sendFanoutService;
 
 	@Override
 	public boolean packageChangeStock(List<String> orderPackageCodes) {
@@ -941,6 +944,7 @@ public class WarehouseUpdownTypeServiceImpl extends BaseServiceImpl<WarehouseUpd
 		}
 		String enableStatus = goodsAllocationEntity.getEnableStatus();
 		Long goodsShelfId = goodsAllocationEntity.getGoodsShelfId();
+		String qrCode = goodsAllocationEntity.getQrCode();
 		if ("2".equals(enableStatus)) {
 			log.warn("##############upShelfPackage: 库位已被禁用 allocationId={}", allocationId);
 			return R.fail(403, "库位已被禁用");
@@ -1009,6 +1013,35 @@ public class WarehouseUpdownTypeServiceImpl extends BaseServiceImpl<WarehouseUpd
 		//更新货位缓存
 		warehouseGoodsAllocationClient.updateAllocationCache(allocationId.toString());
 
+
+		try{
+
+			//把parcelListEntityList通过conditions进行分组，conditions作为key
+			Map<Integer, List<DistributionParcelListEntity>> map = parcelListEntityList.stream().collect(Collectors.groupingBy(DistributionParcelListEntity::getConditions));
+
+			map.keySet().forEach(conditions -> {
+				List<DistributionParcelListEntity> list = map.get(conditions);
+				JSONObject jsonObject = new JSONObject();
+				jsonObject.put("dataType",1);
+				jsonObject.put("conditions",conditions);
+				jsonObject.put("operation",3);
+				//把list中所有元素的orderPackageCode提取出来存入一个List<String>
+				List<String> orderPackageCodes = list.stream().map(DistributionParcelListEntity::getOrderPackageCode).collect(Collectors.toList());
+
+				jsonObject.put("orderPackageCodes",orderPackageCodes);
+				jsonObject.put("warehouseId",warehouseId);
+				jsonObject.put("allocationName",qrCode);
+
+				FanoutMsg fanoutMsg = FanoutMsg.builder().exchange(FanoutConstants.warehouse.ALLOCATION.EXCHANGE).msg(jsonObject.toJSONString()).build();
+
+				sendFanoutService.sendFanoutMsg(fanoutMsg);
+			});
+
+		}catch (Exception e){
+			log.warn("###########upShelfPackage: 发送打托广播失败");
+		}
+
+
 //		for (UpShelfPackageDTO upShelfPackageDTO : upShelfPackageList) {
 //			String orderPackageCode = upShelfPackageDTO.getOrderPackageCode();
 //			log.info("##############upShelfPackage: 当前处理的包件码 orderPackageCode={}", orderPackageCode);
@@ -1159,6 +1192,7 @@ public class WarehouseUpdownTypeServiceImpl extends BaseServiceImpl<WarehouseUpd
 			return R.fail(403, "库位不存在");
 		}
 		String enableStatus = goodsAllocationEntity.getEnableStatus();
+		String qrCode = goodsAllocationEntity.getQrCode();
 		Long goodsShelfId = goodsAllocationEntity.getGoodsShelfId();
 		if ("2".equals(enableStatus)) {
 			log.warn("##############upShelfOrder: 库位已被禁用 allocationId={}", allocationId);
@@ -1203,9 +1237,12 @@ public class WarehouseUpdownTypeServiceImpl extends BaseServiceImpl<WarehouseUpd
 		}
 		//
 		bindingAllocationAndZeroOrderAndLog(upShelfZeroOrderList, updownTypeEntity, remark);
+
+		List<String> orderCodes = new ArrayList<>();
 		for (UpShelfZeroOrderDTO upShelfZeroOrderDTO : upShelfZeroOrderList) {
 			num = num + upShelfZeroOrderDTO.getEnterNum();
-			updateZeroOrderGroundingStatus(upShelfZeroOrderDTO.getOrderCode(), warehouseId);
+			orderCodes.add(upShelfZeroOrderDTO.getOrderCode());
+//			updateZeroOrderGroundingStatus(upShelfZeroOrderDTO.getOrderCode(), warehouseId);
 		}
 		updateUpdownTypeNum(updownTypeEntity);
 
@@ -1225,6 +1262,24 @@ public class WarehouseUpdownTypeServiceImpl extends BaseServiceImpl<WarehouseUpd
 		}
 		//更新货位缓存
 		warehouseGoodsAllocationClient.updateAllocationCache(allocationId.toString());
+
+		try{
+			JSONObject jsonObject = new JSONObject();
+			jsonObject.put("dataType",2);
+			jsonObject.put("operation",3);
+			jsonObject.put("orderCodes",orderCodes);
+			jsonObject.put("warehouseId",warehouseId);
+			jsonObject.put("allocationName",qrCode);
+
+			FanoutMsg fanoutMsg = FanoutMsg.builder().exchange(FanoutConstants.warehouse.ALLOCATION.EXCHANGE).msg(jsonObject.toJSONString()).build();
+
+			sendFanoutService.sendFanoutMsg(fanoutMsg);
+
+		}catch (Exception e){
+			log.warn("###########upShelfPackage: 发送打托广播失败");
+		}
+
+
 		return Resp.scanSuccess("上架成功", "成功上架" + num + "条");
 	}
 
@@ -1316,6 +1371,7 @@ public class WarehouseUpdownTypeServiceImpl extends BaseServiceImpl<WarehouseUpd
 			return R.fail(403, "库位不存在");
 		}
 		String enableStatus = goodsAllocationEntity.getEnableStatus();
+		String qrCode = goodsAllocationEntity.getQrCode();
 		Long goodsShelfId = goodsAllocationEntity.getGoodsShelfId();
 		if ("2".equals(enableStatus)) {
 			log.warn("##############upShelfOrder: 库位已被禁用 allocationId={}", allocationId);
@@ -1380,6 +1436,36 @@ public class WarehouseUpdownTypeServiceImpl extends BaseServiceImpl<WarehouseUpd
 		if (s.length() > 0) {
 			msg = msg + s + "超出输入数量,或输入数量为0,请输入正确数量再进行操作";
 		}
+
+		try{
+
+			List<Long> stockListIds = new ArrayList<>();
+			upShelfStockList.forEach(upShelfStockDTO -> {
+				String materialCode = upShelfStockDTO.getMaterialCode();
+				String incomingBatch = upShelfStockDTO.getIncomingBatch();
+				Long marketId = upShelfStockDTO.getMarketId();
+				DistributionStockListEntity stockListEntity = distributionStockListClient.getEntityByMarketIdAndMaterialCodeAndIncomingBatch(marketId, materialCode, incomingBatch, warehouseId);
+				if(!Objects.isNull(stockListEntity)){
+					stockListIds.add(stockListEntity.getId());
+				}
+			});
+
+
+			JSONObject jsonObject = new JSONObject();
+			jsonObject.put("dataType",3);
+			jsonObject.put("operation",3);
+			jsonObject.put("stockListIds",stockListIds);
+			jsonObject.put("warehouseId",warehouseId);
+			jsonObject.put("allocationName",qrCode);
+
+			FanoutMsg fanoutMsg = FanoutMsg.builder().exchange(FanoutConstants.warehouse.ALLOCATION.EXCHANGE).msg(jsonObject.toJSONString()).build();
+
+			sendFanoutService.sendFanoutMsg(fanoutMsg);
+		}catch (Exception e){
+			log.warn("###########saveTrayTypeByOrderPackageCode: 发送打托广播失败");
+		}
+
+
 		return Resp.scanSuccess(msg, "成功上架" + num + "件");
 	}
 
@@ -1542,11 +1628,179 @@ public class WarehouseUpdownTypeServiceImpl extends BaseServiceImpl<WarehouseUpd
 				warehouseUpdownGoodsLogEntity.setWarehouseId(updownTypeEntity.getWarehouseId());
 				updownGoodsLogEntities.add(warehouseUpdownGoodsLogEntity);
 
-				parcelListEntity.setOrderPackageGroundingStatus("10");
+//				parcelListEntity.setOrderPackageGroundingStatus("10");
+
+			});
+
+//			updownParcelEntities.addAll(parcelListEntities);
+
+		});
+
+		removeByIds(toNullUpdownTypeIds);
+		if (!updateAllocationIds.isEmpty()) {
+			basicdataGoodsAllocationClient.updateListAllocationStatus(updateAllocationIds, "1");
+		}
+		if (!deleteTrayAllocationList.isEmpty()) {
+			warehouseTaryAllocationService.removeBatchByIds(deleteTrayAllocationList);
+		}
+
+		updateUpdownTypeList.forEach(this::updateUpdownTypeNum);
+
+		warehouseUpdownGoodsLogService.saveBatch(updownGoodsLogEntities);
+
+//		distributionParcelListClient.updateList(updownParcelEntities);
+
+		map.keySet().forEach(allocationId -> {
+			warehouseGoodsAllocationClient.updateAllocationCache(allocationId.toString());
+		});
+
+		for (String orderCode : orderSet) {
+			distributionStockArticleClient.updateOrderInfo(orderCode, warehouseId);
+		}
+
+		num = num + updownGoodsLogEntities.size();
+		try{
+
+			//把parcelListEntityList中所有元素的conditions作为key进行分组成一个Map
+			Map<Integer, List<DistributionParcelListEntity>> listMap = parcelListEntityList.stream().collect(Collectors.groupingBy(DistributionParcelListEntity::getConditions));
+
+			listMap.keySet().forEach(conditions -> {
+				List<DistributionParcelListEntity> ls = listMap.get(conditions);
+				JSONObject jsonObject = new JSONObject();
+				jsonObject.put("dataType",1);
+				jsonObject.put("conditions",conditions);
+				jsonObject.put("operation",4);
+				//把ls中所有元素的orderPackageCode放入一个List
+				List<String> orderPackageCodes = ls.stream().map(DistributionParcelListEntity::getOrderPackageCode).collect(Collectors.toList());
+
+				jsonObject.put("orderPackageCodes",orderPackageCodes);
+				jsonObject.put("warehouseId",warehouseId);
+
+				FanoutMsg fanoutMsg = FanoutMsg.builder().exchange(FanoutConstants.warehouse.ALLOCATION.EXCHANGE).msg(jsonObject.toJSONString()).build();
+
+				sendFanoutService.sendFanoutMsg(fanoutMsg);
+
+			});
+
+
+		}catch (Exception e){
+			log.warn("###########saveTrayTypeByOrderPackageCode: 发送打托广播失败");
+		}
+
+		return Resp.scanSuccess("下架成功", "成功下架" + num + "件");
+	}
+
+
+	private R downPackageNoFanout(List<UpShelfPackageDTO> upShelfPackageList, Long warehouseId, String remark) {
+		int num = 0;
+		Set<String> orderSet = new HashSet<>();
+
+		//把upShelfPackageList中的orderPackageCde提取到List中
+		List<String> orderPackageCodeList = upShelfPackageList.stream().map(UpShelfPackageDTO::getOrderPackageCode).collect(Collectors.toList());
+		QueryWrapper<WarehouseUpdownGoodsEntity> queryWrapper = new QueryWrapper<>();
+		queryWrapper.eq("association_type", "3")
+			.eq("warehouse_id", warehouseId)
+			.in("association_value", orderPackageCodeList);
+		List<WarehouseUpdownGoodsEntity> updownGoodsEntities = warehouseUpdownGoodsService.list(queryWrapper);
+
+		//把updownGoodsEntities的association_value提取到一个List中
+		List<String> associationValueList = updownGoodsEntities.stream().map(WarehouseUpdownGoodsEntity::getAssociationValue).collect(Collectors.toList());
+
+		FindParamterDTO findParamterDTO = new FindParamterDTO();
+		findParamterDTO.setOrderPackageCodeList(associationValueList);
+		findParamterDTO.setWarehouseId(warehouseId);
+		List<DistributionParcelListEntity> parcelListEntityList = distributionParcelListClient.findListByOrderPackageCodeList(findParamterDTO);
+		//把parcelListEntityList转化成orderPackageCode为key的Map
+		Map<String, DistributionParcelListEntity> parcelListEntityMap = parcelListEntityList.stream().collect(Collectors.toMap(DistributionParcelListEntity::getOrderPackageCode, Function.identity()));
+
+		//把updownGoodsEntities通过allocatiionId进行分组
+		Map<Long, List<WarehouseUpdownGoodsEntity>> map = updownGoodsEntities.stream().collect(Collectors.groupingBy(WarehouseUpdownGoodsEntity::getAllocationId));
+
+		List<Long> allocationIds = new ArrayList<>(map.keySet());
+
+		QueryWrapper<WarehouseUpdownTypeEntity> updownTypeEntityQueryWrapper = new QueryWrapper<>();
+		updownTypeEntityQueryWrapper.in("allocation_id", allocationIds)
+			.eq("is_deleted", 0);
+		List<WarehouseUpdownTypeEntity> updownTypeList = list(updownTypeEntityQueryWrapper);
+		//把updownTypeList转化成allocationId为key的Map
+		Map<Long, WarehouseUpdownTypeEntity> updownTypeMap = updownTypeList.stream().collect(Collectors.toMap(WarehouseUpdownTypeEntity::getAllocationId, Function.identity()));
+
+		List<Long> toNullUpdownTypeIds = new ArrayList<>();
+		List<Long> updateAllocationIds = new ArrayList<>();
+		List<WarehouseTaryAllocationEntity> deleteTrayAllocationList = new ArrayList<>();
+		List<WarehouseUpdownTypeEntity> updateUpdownTypeList = new ArrayList<>();
+		List<WarehouseUpdownGoodsLogEntity> updownGoodsLogEntities = new ArrayList<>();
+		List<DistributionParcelListEntity> updownParcelEntities = new ArrayList<>();
+
+		map.keySet().forEach(allocationId -> {
+			QueryWrapper<WarehouseTaryAllocationEntity> taryAllocationEntityQueryWrapper = new QueryWrapper<>();
+			taryAllocationEntityQueryWrapper.eq("allocation_id", allocationId)
+				.eq("is_deleted", 0);
+			WarehouseTaryAllocationEntity taryAllocationEntity = warehouseTaryAllocationService.getOne(taryAllocationEntityQueryWrapper);
+			List<WarehouseUpdownGoodsEntity> updownGoodsEntities1 = map.get(allocationId);
+			List<String> orderPackageCodes = updownGoodsEntities1.stream().map(WarehouseUpdownGoodsEntity::getAssociationValue).collect(Collectors.toList());
+			if (!Objects.isNull(taryAllocationEntity)) {
+				warehouseTrayTypeService.downPackageByOrderPackageCodeList(orderPackageCodes, remark, warehouseId);
+			}
+			WarehouseUpdownTypeEntity updownTypeEntity = updownTypeMap.get(allocationId);
+			Long updownTypeId = updownTypeEntity.getId();
+			//把updownGoodsEntities1的id提取到List中
+			List<Long> updownGoodsIds = updownGoodsEntities1.stream().map(WarehouseUpdownGoodsEntity::getId).collect(Collectors.toList());
+
+			Integer residue = warehouseUpdownGoodsService.deleteByUpdownGoodsIds(updownGoodsIds, updownTypeEntity.getId());
+			if (residue == 0) {
+				//删除上架方式
+				toNullUpdownTypeIds.add(updownTypeId);
+				//修改库位状态为空闲
+				updateAllocationIds.add(allocationId);
+//				basicdataGoodsAllocationClient.updateAllocationStatus(allocationId, "1");
+				//如果有托盘还要删除托盘与库位的绑定
+				if (!Objects.isNull(taryAllocationEntity)) {
+					deleteTrayAllocationList.add(taryAllocationEntity);
+//					warehouseTaryAllocationService.deleteById(taryAllocationEntity);
+				}
+			} else {
+				updateUpdownTypeList.add(updownTypeEntity);
+			}
+
+			List<DistributionParcelListEntity> parcelListEntities = new ArrayList<>();
+			orderPackageCodes.forEach(orderPackageCode -> {
+				DistributionParcelListEntity parcelListEntity = parcelListEntityMap.get(orderPackageCode);
+				if (!Objects.isNull(parcelListEntity)) {
+					parcelListEntities.add(parcelListEntity);
+				}
+			});
+
+			parcelListEntities.forEach(parcelListEntity -> {
+				orderSet.add(parcelListEntity.getOrderCode());
+				WarehouseUpdownGoodsLogEntity warehouseUpdownGoodsLogEntity = new WarehouseUpdownGoodsLogEntity();
+				warehouseUpdownGoodsLogEntity.setCreateUser(1714696768639311873L);
+				warehouseUpdownGoodsLogEntity.setUpdateUser(1714696768639311873L);
+				warehouseUpdownGoodsLogEntity.setCreateDept(1649331096241836033L);
+				warehouseUpdownGoodsLogEntity.setTenantId(TenantNum.HUITONGCODE);
+				warehouseUpdownGoodsLogEntity.setUpdownTypeId(updownTypeEntity.getId());
+				warehouseUpdownGoodsLogEntity.setAreaId(updownTypeEntity.getAreaId());
+				warehouseUpdownGoodsLogEntity.setAreaTitle(updownTypeEntity.getAreaTitle());
+				warehouseUpdownGoodsLogEntity.setShelfId(updownTypeEntity.getShelfId());
+				warehouseUpdownGoodsLogEntity.setShelfTitle(updownTypeEntity.getShelfTitle());
+				warehouseUpdownGoodsLogEntity.setAllocationId(updownTypeEntity.getAllocationId());
+				warehouseUpdownGoodsLogEntity.setAllocationTitle(updownTypeEntity.getAllocationTitle());
+				warehouseUpdownGoodsLogEntity.setPositionCode(updownTypeEntity.getPositionCode());
+				warehouseUpdownGoodsLogEntity.setBindingType("2");
+				warehouseUpdownGoodsLogEntity.setIsAlltrays(0);
+				warehouseUpdownGoodsLogEntity.setAssociationId(parcelListEntity.getId());
+				warehouseUpdownGoodsLogEntity.setAssociationValue(parcelListEntity.getOrderPackageCode());
+				warehouseUpdownGoodsLogEntity.setAssociationType("3");
+				warehouseUpdownGoodsLogEntity.setNum(1);
+				warehouseUpdownGoodsLogEntity.setRemark(remark);
+				warehouseUpdownGoodsLogEntity.setWarehouseId(updownTypeEntity.getWarehouseId());
+				updownGoodsLogEntities.add(warehouseUpdownGoodsLogEntity);
+
+//				parcelListEntity.setOrderPackageGroundingStatus("10");
 
 			});
 
-			updownParcelEntities.addAll(parcelListEntities);
+//			updownParcelEntities.addAll(parcelListEntities);
 
 		});
 
@@ -1562,7 +1816,7 @@ public class WarehouseUpdownTypeServiceImpl extends BaseServiceImpl<WarehouseUpd
 
 		warehouseUpdownGoodsLogService.saveBatch(updownGoodsLogEntities);
 
-		distributionParcelListClient.updateList(updownParcelEntities);
+//		distributionParcelListClient.updateList(updownParcelEntities);
 
 		map.keySet().forEach(allocationId -> {
 			warehouseGoodsAllocationClient.updateAllocationCache(allocationId.toString());
@@ -1572,11 +1826,12 @@ public class WarehouseUpdownTypeServiceImpl extends BaseServiceImpl<WarehouseUpd
 			distributionStockArticleClient.updateOrderInfo(orderCode, warehouseId);
 		}
 
-		num = num + updownParcelEntities.size();
+		num = num + updownGoodsLogEntities.size();
 
 		return Resp.scanSuccess("下架成功", "成功下架" + num + "件");
 	}
 
+
 	@Override
 	public R downDeliveryPackage(List<UpShelfPackageDTO> upShelfPackageList, Long warehouseId) {
 		int num = 0;
@@ -1636,6 +1891,7 @@ public class WarehouseUpdownTypeServiceImpl extends BaseServiceImpl<WarehouseUpd
 	public R downPackageOrDelTray(List<UpShelfPackageDTO> upShelfPackageList, Long warehouseId, String remark) {
 		int num = 0;
 		Set<String> orderSet = new TreeSet<>();
+		List<String> orderPackageCodes = new ArrayList<>();
 		for (UpShelfPackageDTO upShelfPackageDTO : upShelfPackageList) {
 			String orderPackageCode = upShelfPackageDTO.getOrderPackageCode();
 			//查询包件在哪个库位上
@@ -1686,16 +1942,50 @@ public class WarehouseUpdownTypeServiceImpl extends BaseServiceImpl<WarehouseUpd
 				}
 			}
 			warehouseUpdownGoodsLogService.saveAllocationAndPackage(updownTypeEntity, parcelListEntity, "2", 0, remark);
-			updatePackageGroundingStatus(orderPackageCode, "10", warehouseId);
+//			updatePackageGroundingStatus(orderPackageCode, "10", warehouseId);
 			updateUpdownTypeNum(updownTypeEntity);
 
 			orderSet.add(orderCode);
 			num = num + quantity;
+			orderPackageCodes.add(orderPackageCode);
 			warehouseGoodsAllocationClient.updateAllocationCache(allocationId.toString());
 		}
 
-		for (String orderCode : orderSet) {
-			distributionStockArticleClient.updateOrderInfo(orderCode, warehouseId);
+//		for (String orderCode : orderSet) {
+//			distributionStockArticleClient.updateOrderInfo(orderCode, warehouseId);
+//		}
+
+		try{
+
+			FindParamterDTO findParamterDTO = new FindParamterDTO();
+			findParamterDTO.setOrderCodeList(orderPackageCodes);
+			findParamterDTO.setWarehouseId(warehouseId);
+			List<DistributionParcelListEntity> parcelListEntityList = distributionParcelListClient.findListByOrderPackageCodeList(findParamterDTO);
+
+			//把parcelListEntityList中所有元素的conditions作为key进行分组成一个Map
+			Map<Integer, List<DistributionParcelListEntity>> listMap = parcelListEntityList.stream().collect(Collectors.groupingBy(DistributionParcelListEntity::getConditions));
+
+			listMap.keySet().forEach(conditions -> {
+				List<DistributionParcelListEntity> ls = listMap.get(conditions);
+				JSONObject jsonObject = new JSONObject();
+				jsonObject.put("dataType",1);
+				jsonObject.put("conditions",conditions);
+				jsonObject.put("operation",4);
+				//把ls中所有元素的orderPackageCode放入一个List
+				List<String> packageCodes = ls.stream().map(DistributionParcelListEntity::getOrderPackageCode).collect(Collectors.toList());
+
+				jsonObject.put("orderPackageCodes",packageCodes);
+				jsonObject.put("warehouseId",warehouseId);
+
+				FanoutMsg fanoutMsg = FanoutMsg.builder().exchange(FanoutConstants.warehouse.ALLOCATION.EXCHANGE).msg(jsonObject.toJSONString()).build();
+
+				sendFanoutService.sendFanoutMsg(fanoutMsg);
+
+			});
+
+
+		}catch (Exception e){
+			log.warn("###########saveTrayTypeByOrderPackageCode: 发送打托广播失败");
 		}
 
 		return Resp.scanSuccess("下架成功", "成功下架" + num + "件");
@@ -1779,14 +2069,36 @@ public class WarehouseUpdownTypeServiceImpl extends BaseServiceImpl<WarehouseUpd
 					}
 				}
 				warehouseUpdownGoodsLogService.saveAllocationAndPackage(updownTypeEntity, parcelListEntity, "2", 0, remark);
-				if (isOrNo) {
-					updatePackageGroundingStatus(orderPackageCode, "10", warehouseId);
-				}
+
 				updateUpdownTypeNum(updownTypeEntity);
 
-				orderSet.add(orderCode);
+//				orderSet.add(orderCode);
 				num = num + quantity;
 				warehouseGoodsAllocationClient.updateAllocationCache(allocationId.toString());
+
+
+				if (isOrNo) {
+//					updatePackageGroundingStatus(orderPackageCode, "10", warehouseId);
+					try{
+						JSONObject jsonObject = new JSONObject();
+						jsonObject.put("dataType",1);
+						jsonObject.put("operation",4);
+						jsonObject.put("conditions",parcelListEntity.getConditions());
+						List<String> orderPackageCodes = new ArrayList<>();
+						orderPackageCodes.add(orderPackageCode);
+						jsonObject.put("orderPackageCodes",orderPackageCodes);
+						jsonObject.put("warehouseId",warehouseId);
+
+						FanoutMsg fanoutMsg = FanoutMsg.builder().exchange(FanoutConstants.warehouse.ALLOCATION.EXCHANGE).msg(jsonObject.toJSONString()).build();
+
+						sendFanoutService.sendFanoutMsg(fanoutMsg);
+					}catch (Exception e){
+						log.warn("###########saveTrayTypeByOrderPackageCode: 发送打托广播失败");
+					}
+
+
+				}
+
 			}
 
 		}
@@ -1794,16 +2106,16 @@ public class WarehouseUpdownTypeServiceImpl extends BaseServiceImpl<WarehouseUpd
 //		for (String orderCode : orderSet) {
 //			distributionStockArticleClient.updateOrderInfo(orderCode, warehouseId);
 //		}
-		List<String> orders = new ArrayList<>(orderSet);
-		if (orders.isEmpty()) {
-			return Resp.scanSuccess("下架成功", "成功下架" + num + "件");
-		}
+//		List<String> orders = new ArrayList<>(orderSet);
+//		if (orders.isEmpty()) {
+//			return Resp.scanSuccess("下架成功", "成功下架" + num + "件");
+//		}
 
-		OrderPackageDTO orderPackageDTO1 = new OrderPackageDTO();
-		orderPackageDTO1.setWarehouseId(warehouseId);
-		orderPackageDTO1.setStrings(orders);
-		distributionStockArticleClient.updateOrdersInfo(orderPackageDTO1);
-		log.info(">>>>> T downPackageAndDelTrayAndIsUpdate end");
+//		OrderPackageDTO orderPackageDTO1 = new OrderPackageDTO();
+//		orderPackageDTO1.setWarehouseId(warehouseId);
+//		orderPackageDTO1.setStrings(orders);
+//		distributionStockArticleClient.updateOrdersInfo(orderPackageDTO1);
+//		log.info(">>>>> T downPackageAndDelTrayAndIsUpdate end");
 
 		return Resp.scanSuccess("下架成功", "成功下架" + num + "件");
 	}
@@ -1819,6 +2131,10 @@ public class WarehouseUpdownTypeServiceImpl extends BaseServiceImpl<WarehouseUpd
 			String orderCode = upShelfZeroOrderDTO.getOrderCode();//订单号
 			Long allocationId = upShelfZeroOrderDTO.getAllocationId();//库位id
 			Integer enterNum = upShelfZeroOrderDTO.getEnterNum();//下架数量
+
+			BasicdataGoodsAllocationEntity goodsAllocationEntity = basicdataGoodsAllocationClient.getEntityByAllocationId(allocationId);
+			String qrCode = goodsAllocationEntity.getQrCode();
+
 			BasicdataTrayEntity trayEntity = warehouseTaryAllocationService.getTrayByAllocationId(allocationId);
 			QueryWrapper<WarehouseUpdownGoodsEntity> queryWrapper = new QueryWrapper<>();
 			queryWrapper.eq("association_value", orderCode)
@@ -1856,6 +2172,26 @@ public class WarehouseUpdownTypeServiceImpl extends BaseServiceImpl<WarehouseUpd
 					removeById(updownTypeId);
 					//修改库位状态为空闲
 					basicdataGoodsAllocationClient.updateAllocationStatus(allocationId, "1");
+
+
+					try{
+						JSONObject jsonObject = new JSONObject();
+						jsonObject.put("dataType",2);
+						jsonObject.put("operation",4);
+						List<String> orderCodes = new ArrayList<>();
+						orderCodes.add(orderCode);
+						jsonObject.put("orderCodes",orderCodes);
+						jsonObject.put("warehouseId",warehouseId);
+						jsonObject.put("allocationName",qrCode);
+
+						FanoutMsg fanoutMsg = FanoutMsg.builder().exchange(FanoutConstants.warehouse.ALLOCATION.EXCHANGE).msg(jsonObject.toJSONString()).build();
+
+						sendFanoutService.sendFanoutMsg(fanoutMsg);
+					}catch (Exception e){
+						log.warn("###########saveTrayTypeByOrderPackageCode: 发送打托广播失败");
+					}
+
+
 				}
 				saveUpdownGoodsLog(updownGoodsList, "2", 0, remark, warehouseId);
 				updateUpdownTypeNum(updownTypeEntity);
@@ -1872,7 +2208,7 @@ public class WarehouseUpdownTypeServiceImpl extends BaseServiceImpl<WarehouseUpd
 				//存入日志
 				saveUpdownGoodsLogPart(updownGoodsList, enterNum, "2", 0, remark + "部分", updownTypeEntity.getWarehouseId());
 			}
-			updateZeroOrderGroundingStatus(orderCode, warehouseId);
+//			updateZeroOrderGroundingStatus(orderCode, warehouseId);
 			updateUpdownTypeNum(updownTypeEntity);
 			allNum = allNum + enterNum;
 			//更新货位缓存
@@ -1924,6 +2260,10 @@ public class WarehouseUpdownTypeServiceImpl extends BaseServiceImpl<WarehouseUpd
 				continue;
 			}
 			String incomingBatch = upShelfStockDTO.getIncomingBatch();
+
+			BasicdataGoodsAllocationEntity goodsAllocationEntity = basicdataGoodsAllocationClient.getEntityByAllocationId(allocationId);
+			String qrCode = goodsAllocationEntity.getQrCode();
+
 			BasicdataTrayEntity trayEntity = warehouseTaryAllocationService.getTrayByAllocationId(allocationId);
 
 			QueryWrapper<WarehouseUpdownGoodsEntity> queryWrapper = new QueryWrapper<>();
@@ -1971,6 +2311,29 @@ public class WarehouseUpdownTypeServiceImpl extends BaseServiceImpl<WarehouseUpd
 					removeById(updownTypeId);
 					//修改库位状态为空闲
 					basicdataGoodsAllocationClient.updateAllocationStatus(allocationId, "1");
+
+					try{
+
+						DistributionStockListEntity stockListEntity = distributionStockListClient.getEntityByMarketIdAndMaterialCodeAndIncomingBatch(marketId, materialCode, incomingBatch, warehouseId);
+
+
+						JSONObject jsonObject = new JSONObject();
+						jsonObject.put("dataType",3);
+						jsonObject.put("operation",4);
+						List<Long> stockListIds = new ArrayList<>();
+						stockListIds.add(stockListEntity.getId());
+						jsonObject.put("stockListIds",stockListIds);
+						jsonObject.put("warehouseId",warehouseId);
+						jsonObject.put("allocationName",qrCode);
+
+						FanoutMsg fanoutMsg = FanoutMsg.builder().exchange(FanoutConstants.warehouse.ALLOCATION.EXCHANGE).msg(jsonObject.toJSONString()).build();
+
+						sendFanoutService.sendFanoutMsg(fanoutMsg);
+					}catch (Exception e){
+						log.warn("###########saveTrayTypeByOrderPackageCode: 发送打托广播失败");
+					}
+
+
 				}
 				//更新货位缓存
 				warehouseGoodsAllocationClient.updateAllocationCache(allocationId.toString());
@@ -2018,11 +2381,14 @@ public class WarehouseUpdownTypeServiceImpl extends BaseServiceImpl<WarehouseUpd
 			.eq("is_deleted", 0);
 		WarehouseUpdownTypeEntity updownTypeEntity = baseMapper.selectOne(updownTypeEntityQueryWrapper);
 		//	Long updownTypeId = updownTypeEntity.getId();
-//		BasicdataGoodsAllocationEntity goodsAllocationEntity = basicdataGoodsAllocationClient.getEntityByAllocationId(allocationId);
-//		if(Objects.isNull(goodsAllocationEntity)){
-//			log.warn("#################downTrayCode: 库位信息不存在 allocationId={}",allocationId);
-//			return R.fail(403,"库位信息不存在");
-//		}
+		BasicdataGoodsAllocationEntity goodsAllocationEntity = basicdataGoodsAllocationClient.getEntityByAllocationId(allocationId);
+		if(Objects.isNull(goodsAllocationEntity)){
+			log.warn("#################downTrayCode: 库位信息不存在 allocationId={}",allocationId);
+			return R.fail(403,"库位信息不存在");
+		}
+		String qrCode = goodsAllocationEntity.getQrCode();
+
+
 //		Long wid = goodsAllocationEntity.getWarehouseId();
 //		if(!wid.equals(warehouseId)){
 //			log.warn("#################downTrayCode: 库位不在当前仓 allocationId={}",allocationId);
@@ -2045,23 +2411,95 @@ public class WarehouseUpdownTypeServiceImpl extends BaseServiceImpl<WarehouseUpd
 		//修改状态
 		Set<String> setOrder = new TreeSet<>();
 		for (WarehouseUpdownGoodsEntity updownGoodsEntity : updownGoodsList) {
-			String associationType = updownGoodsEntity.getAssociationType();
-			String associationValue = updownGoodsEntity.getAssociationValue();
+//			String associationType = updownGoodsEntity.getAssociationType();
+//			String associationValue = updownGoodsEntity.getAssociationValue();
 			Integer num = updownGoodsEntity.getNum();
-			if ("1".equals(associationType)) {
-				updateZeroOrderGroundingStatus(associationValue, warehouseId);
-			} else if ("3".equals(associationType)) {
-				DistributionParcelListEntity parcelListEntity = distributionParcelListClient.findByPacketBarCodeAndWarehouseId(associationValue, warehouseId);
-				updatePackageGroundingStatus(associationValue, "10", warehouseId);
-				setOrder.add(parcelListEntity.getOrderCode());
-			}
+//			if ("1".equals(associationType)) {
+//				updateZeroOrderGroundingStatus(associationValue, warehouseId);
+//			} else if ("3".equals(associationType)) {
+//				DistributionParcelListEntity parcelListEntity = distributionParcelListClient.findByPacketBarCodeAndWarehouseId(associationValue, warehouseId);
+//				updatePackageGroundingStatus(associationValue, "10", warehouseId);
+//				setOrder.add(parcelListEntity.getOrderCode());
+//			}
 			allNum = allNum + num;
 		}
 
-		for (String orderCode : setOrder) {
-			distributionStockArticleClient.updateOrderInfo(orderCode, warehouseId);
+//		for (String orderCode : setOrder) {
+//			distributionStockArticleClient.updateOrderInfo(orderCode, warehouseId);
+//		}
+
+		try{
+			//把updownGoodsList通过associationType进行分组associationType作为key
+			Map<String, List<WarehouseUpdownGoodsEntity>> map = updownGoodsList.stream().collect(Collectors.groupingBy(WarehouseUpdownGoodsEntity::getAssociationType));
+			map.keySet().forEach(associationType -> {
+				List<WarehouseUpdownGoodsEntity> updownGoodsEntities = map.get(associationType);
+				//把updownGoodsEntities中所有元素的associationValue放入一个List
+				List<String> associationValues = updownGoodsEntities.stream().map(WarehouseUpdownGoodsEntity::getAssociationValue).collect(Collectors.toList());
+
+				if("1".equals(associationType)){
+					JSONObject jsonObject = new JSONObject();
+					jsonObject.put("dataType",2);
+					jsonObject.put("operation",4);
+					jsonObject.put("orderCodes",associationValues);
+					jsonObject.put("warehouseId",warehouseId);
+					jsonObject.put("allocationName",qrCode);
+
+					FanoutMsg fanoutMsg = FanoutMsg.builder().exchange(FanoutConstants.warehouse.ALLOCATION.EXCHANGE).msg(jsonObject.toJSONString()).build();
+
+					sendFanoutService.sendFanoutMsg(fanoutMsg);
+				}else if("3".equals(associationType)){
+					FindParamterDTO findParamterDTO = new FindParamterDTO();
+					findParamterDTO.setOrderPackageCodeList(associationValues);
+					findParamterDTO.setWarehouseId(warehouseId);
+					List<DistributionParcelListEntity> listEntityList = distributionParcelListClient.findListByOrderPackageCodeList(findParamterDTO);
+					//把listEntityList通过conditions进行分组
+					Map<Integer, List<DistributionParcelListEntity>> map1 = listEntityList.stream().collect(Collectors.groupingBy(DistributionParcelListEntity::getConditions));
+					map1.keySet().forEach(conditions -> {
+						List<DistributionParcelListEntity> parcelListEntityList = map1.get(conditions);
+						//把parcelListEntityList中所有元素的orderPackageCodes放入一个List
+						List<String> orderPackageCodes = parcelListEntityList.stream().map(DistributionParcelListEntity::getOrderPackageCode).collect(Collectors.toList());
+						JSONObject jsonObject = new JSONObject();
+						jsonObject.put("dataType",1);
+						jsonObject.put("conditions",conditions);
+						jsonObject.put("operation",4);
+						jsonObject.put("orderPackageCodes",orderPackageCodes);
+						jsonObject.put("warehouseId",warehouseId);
+
+						FanoutMsg fanoutMsg = FanoutMsg.builder().exchange(FanoutConstants.warehouse.ALLOCATION.EXCHANGE).msg(jsonObject.toJSONString()).build();
+
+						sendFanoutService.sendFanoutMsg(fanoutMsg);
+					});
+				}else if("4".equals(associationType)){
+					List<Long> stockListIds = new ArrayList<>();
+					updownGoodsEntities.forEach(updownGoodsEntity -> {
+						String materialCode = updownGoodsEntity.getAssociationValue();
+						String incomingBatch = updownGoodsEntity.getIncomingBatch();
+						Long marketId = updownGoodsEntity.getMarketId();
+
+						DistributionStockListEntity stockListEntity = distributionStockListClient.getEntityByMarketIdAndMaterialCodeAndIncomingBatch(marketId, materialCode, incomingBatch, warehouseId);
+						if(!Objects.isNull(stockListEntity)){
+							stockListIds.add(stockListEntity.getId());
+						}
+
+					});
+					JSONObject jsonObject = new JSONObject();
+					jsonObject.put("dataType",3);
+					jsonObject.put("operation",4);
+					jsonObject.put("stockListIds",stockListIds);
+					jsonObject.put("warehouseId",warehouseId);
+					jsonObject.put("allocationName",qrCode);
+
+					FanoutMsg fanoutMsg = FanoutMsg.builder().exchange(FanoutConstants.warehouse.ALLOCATION.EXCHANGE).msg(jsonObject.toJSONString()).build();
+
+					sendFanoutService.sendFanoutMsg(fanoutMsg);
+				}
+			});
+		}catch (Exception e){
+			log.warn("################downAllocation: 下架库位存入广播失败");
 		}
 
+
+
 		//修改库位状态
 		basicdataGoodsAllocationClient.updateAllocationStatus(allocationId, "1");
 
@@ -2166,6 +2604,7 @@ public class WarehouseUpdownTypeServiceImpl extends BaseServiceImpl<WarehouseUpd
 
 		//上架新的库位
 		upShelfPackage(upShelfPackageList, allocationId, warehouseId, remark + "上架");
+
 		//更新货位缓存
 		warehouseGoodsAllocationClient.updateAllocationCache(allocationId.toString());
 		return Resp.scanSuccess("移库成功", "移库成功");
@@ -2519,20 +2958,22 @@ public class WarehouseUpdownTypeServiceImpl extends BaseServiceImpl<WarehouseUpd
 		BasicdataTrayEntity trayEntity = warehouseTaryAllocationService.getTrayByAllocationId(allocationId);
 		if (Objects.isNull(trayEntity)) {
 			//没有托盘就直接修改库位数据
-			//修改绑定数据的库位信息到新库位
-			changeUpdownGoodsToNewAllocation(list, targetAllocationId, updownTypeEntity);
+
 			//下架原库位的所有货物
 			downAllocation(allocationId, warehouseId);
 
-			for (WarehouseUpdownGoodsEntity updownGoodsEntity : list) {
-				String associationType = updownGoodsEntity.getAssociationType();
-				String associationValue = updownGoodsEntity.getAssociationValue();
-				if ("1".equals(associationType)) {
-					updateZeroOrderGroundingStatus(associationValue, warehouseId);
-				} else if ("3".equals(associationType)) {
-					updatePackageGroundingStatus(associationValue, "20", warehouseId);
-				}
-			}
+			//修改绑定数据的库位信息到新库位
+			changeUpdownGoodsToNewAllocation(list, targetAllocationId, updownTypeEntity);
+
+//			for (WarehouseUpdownGoodsEntity updownGoodsEntity : list) {
+//				String associationType = updownGoodsEntity.getAssociationType();
+//				String associationValue = updownGoodsEntity.getAssociationValue();
+//				if ("1".equals(associationType)) {
+//					updateZeroOrderGroundingStatus(associationValue, warehouseId);
+//				} else if ("3".equals(associationType)) {
+//					updatePackageGroundingStatus(associationValue, "20", warehouseId);
+//				}
+//			}
 		} else {
 			String trayCode = trayEntity.getPalletCode();
 			moveAllocationByTrayCode(trayCode, targetAllocationId, warehouseId);
@@ -2664,6 +3105,7 @@ public class WarehouseUpdownTypeServiceImpl extends BaseServiceImpl<WarehouseUpd
 		}
 		String enableStatus = goodsAllocationEntity.getEnableStatus();
 		Long goodsShelfId = goodsAllocationEntity.getGoodsShelfId();
+		String qrCode = goodsAllocationEntity.getQrCode();
 		if ("2".equals(enableStatus)) {
 			log.warn("##############changeUpdownGoodsToNewAllocation: 库位已被禁用 allocationId={}", allocationId);
 			throw new CustomerException(403, "库位已被禁用");
@@ -2721,6 +3163,81 @@ public class WarehouseUpdownTypeServiceImpl extends BaseServiceImpl<WarehouseUpd
 		basicdataGoodsAllocationClient.updateAllocationStatus(allocationId, "2");
 
 		saveUpdownGoodsLog(newList, "1", 0, "移库:整库移库上架", targetUpdownTypeEntity.getWarehouseId());
+
+		try{
+
+			//把trayGoodsList通过associationType进行分组，associationType作为key的Map
+			Map<String, List<WarehouseUpdownGoodsEntity>> map = list.stream().collect(Collectors.groupingBy(WarehouseUpdownGoodsEntity::getAssociationType));
+
+			map.keySet().forEach(associationType -> {
+				List<WarehouseUpdownGoodsEntity> updownGoodsEntities = map.get(associationType);
+				//把trayGoodsEntities中所有元素的associationValue存入一个List集合
+				List<String> associationValues = updownGoodsEntities.stream().map(WarehouseUpdownGoodsEntity::getAssociationValue).collect(Collectors.toList());
+
+				if("1".equals(associationType)){
+					JSONObject jsonObject = new JSONObject();
+					jsonObject.put("dataType",2);
+					jsonObject.put("operation",3);
+					jsonObject.put("orderCodes",associationValues);
+					jsonObject.put("warehouseId",wid);
+					jsonObject.put("allocationName",qrCode);
+
+					FanoutMsg fanoutMsg = FanoutMsg.builder().exchange(FanoutConstants.warehouse.ALLOCATION.EXCHANGE).msg(jsonObject.toJSONString()).build();
+
+					sendFanoutService.sendFanoutMsg(fanoutMsg);
+				}else if ("3".equals(associationType)){
+					FindParamterDTO findParamterDTO = new FindParamterDTO();
+					findParamterDTO.setOrderPackageCodeList(associationValues);
+					findParamterDTO.setWarehouseId(wid);
+					List<DistributionParcelListEntity> parcelListEntityList = distributionParcelListClient.findListByOrderPackageCodeList(findParamterDTO);
+					//把parcelListEntityList通过conditions进行分组，conditions作为key的Map
+					Map<Integer, List<DistributionParcelListEntity>> parcelListEntityMap = parcelListEntityList.stream().collect(Collectors.groupingBy(DistributionParcelListEntity::getConditions));
+
+					parcelListEntityMap.keySet().forEach(conditions -> {
+						List<DistributionParcelListEntity> parcelListEntities = parcelListEntityMap.get(conditions);
+						JSONObject jsonObject = new JSONObject();
+						jsonObject.put("dataType",1);
+						jsonObject.put("operation",3);
+						jsonObject.put("conditions",conditions);
+						jsonObject.put("orderPackageCodes",associationValues);
+						jsonObject.put("warehouseId",wid);
+						jsonObject.put("allocationName",qrCode);
+
+						FanoutMsg fanoutMsg = FanoutMsg.builder().exchange(FanoutConstants.warehouse.ALLOCATION.EXCHANGE).msg(jsonObject.toJSONString()).build();
+
+						sendFanoutService.sendFanoutMsg(fanoutMsg);
+
+					});
+				}else if ("4".equals(associationType)){
+					List<Long> stockListIds = new ArrayList<>();
+					updownGoodsEntities.forEach(updownGoodsEntity -> {
+						String materialCode = updownGoodsEntity.getAssociationValue();
+						String incomingBatch = updownGoodsEntity.getIncomingBatch();
+						Long marketId = updownGoodsEntity.getMarketId();
+						DistributionStockListEntity stockListEntity = distributionStockListClient.getEntityByMarketIdAndMaterialCodeAndIncomingBatch(marketId, incomingBatch, materialCode, wid);
+						if(!Objects.isNull(stockListEntity)){
+							stockListIds.add(stockListEntity.getId());
+						}
+					});
+
+					JSONObject jsonObject = new JSONObject();
+					jsonObject.put("dataType",3);
+					jsonObject.put("operation",3);
+					jsonObject.put("stockListIds",stockListIds);
+					jsonObject.put("warehouseId",wid);
+					jsonObject.put("allocationName",qrCode);
+
+					FanoutMsg fanoutMsg = FanoutMsg.builder().exchange(FanoutConstants.warehouse.ALLOCATION.EXCHANGE).msg(jsonObject.toJSONString()).build();
+
+					sendFanoutService.sendFanoutMsg(fanoutMsg);
+
+				}
+
+			});
+		}catch (Exception e){
+			log.warn("###########saveTrayTypeByOrderPackageCode: 发送打托广播失败");
+		}
+
 	}
 
 
@@ -2935,6 +3452,7 @@ public class WarehouseUpdownTypeServiceImpl extends BaseServiceImpl<WarehouseUpd
 
 	private R saveTrayGoodsToAllocation(WarehouseTrayTypeEntity trayTypeEntity, BasicdataGoodsAllocationEntity goodsAllocationEntity, BasicdataGoodsShelfEntity goodsShelfEntity, BasicdataGoodsAreaEntity goodsAreaEntity, Long warehouseId) {
 		Long allocationId = goodsAllocationEntity.getId();
+		String qrCode = goodsAllocationEntity.getQrCode();
 		Long shelfId = goodsShelfEntity.getId();
 		Long areaId = goodsAreaEntity.getId();
 		QueryWrapper<WarehouseUpdownTypeEntity> updownTypeQueryWrapper = new QueryWrapper<>();
@@ -2955,16 +3473,16 @@ public class WarehouseUpdownTypeServiceImpl extends BaseServiceImpl<WarehouseUpd
 		//把托盘绑定关系转成货位绑定关系
 		changeTrayGoodsToUpdownGoodsAndLog(trayGoodsList, updownTypeEntity);
 
-		for (WarehouseTrayGoodsEntity trayGoodsEntity : trayGoodsList) {
-			String associationType = trayGoodsEntity.getAssociationType();
-			if ("3".equals(associationType)) {
-				String orderPackageCode = trayGoodsEntity.getAssociationValue();
-				updatePackageGroundingStatus(orderPackageCode, "20", warehouseId);
-			} else if ("1".equals(associationType)) {
-				String orderCode = trayGoodsEntity.getAssociationValue();
-				updateZeroOrderGroundingStatus(orderCode, warehouseId);
-			}
-		}
+//		for (WarehouseTrayGoodsEntity trayGoodsEntity : trayGoodsList) {
+//			String associationType = trayGoodsEntity.getAssociationType();
+//			if ("3".equals(associationType)) {
+//				String orderPackageCode = trayGoodsEntity.getAssociationValue();
+//				updatePackageGroundingStatus(orderPackageCode, "20", warehouseId);
+//			} else if ("1".equals(associationType)) {
+//				String orderCode = trayGoodsEntity.getAssociationValue();
+//				updateZeroOrderGroundingStatus(orderCode, warehouseId);
+//			}
+//		}
 
 		//绑定托盘与库位关系
 		WarehouseTaryAllocationEntity taryAllocationEntity = new WarehouseTaryAllocationEntity();
@@ -2985,6 +3503,83 @@ public class WarehouseUpdownTypeServiceImpl extends BaseServiceImpl<WarehouseUpd
 		Integer stockNum = trayTypeEntity.getStockNum();
 		Integer totalNum = trayTypeEntity.getTotalNum();
 		Integer total = stockNum + totalNum;
+
+
+		try{
+
+			//把trayGoodsList通过associationType进行分组，associationType作为key的Map
+			Map<String, List<WarehouseTrayGoodsEntity>> map = trayGoodsList.stream().collect(Collectors.groupingBy(WarehouseTrayGoodsEntity::getAssociationType));
+
+			map.keySet().forEach(associationType -> {
+				List<WarehouseTrayGoodsEntity> trayGoodsEntities = map.get(associationType);
+				//把trayGoodsEntities中所有元素的associationValue存入一个List集合
+				List<String> associationValues = trayGoodsEntities.stream().map(WarehouseTrayGoodsEntity::getAssociationValue).collect(Collectors.toList());
+
+				if("1".equals(associationType)){
+					JSONObject jsonObject = new JSONObject();
+					jsonObject.put("dataType",2);
+					jsonObject.put("operation",3);
+					jsonObject.put("orderCodes",associationValues);
+					jsonObject.put("warehouseId",warehouseId);
+					jsonObject.put("allocationName",qrCode);
+
+					FanoutMsg fanoutMsg = FanoutMsg.builder().exchange(FanoutConstants.warehouse.ALLOCATION.EXCHANGE).msg(jsonObject.toJSONString()).build();
+
+					sendFanoutService.sendFanoutMsg(fanoutMsg);
+				}else if ("3".equals(associationType)){
+					FindParamterDTO findParamterDTO = new FindParamterDTO();
+					findParamterDTO.setOrderPackageCodeList(associationValues);
+					findParamterDTO.setWarehouseId(warehouseId);
+					List<DistributionParcelListEntity> parcelListEntityList = distributionParcelListClient.findListByOrderPackageCodeList(findParamterDTO);
+					//把parcelListEntityList通过conditions进行分组，conditions作为key的Map
+					Map<Integer, List<DistributionParcelListEntity>> parcelListEntityMap = parcelListEntityList.stream().collect(Collectors.groupingBy(DistributionParcelListEntity::getConditions));
+
+					parcelListEntityMap.keySet().forEach(conditions -> {
+						List<DistributionParcelListEntity> parcelListEntities = parcelListEntityMap.get(conditions);
+						JSONObject jsonObject = new JSONObject();
+						jsonObject.put("dataType",1);
+						jsonObject.put("operation",3);
+						jsonObject.put("conditions",conditions);
+						jsonObject.put("orderPackageCodes",associationValues);
+						jsonObject.put("warehouseId",warehouseId);
+						jsonObject.put("allocationName",qrCode);
+
+						FanoutMsg fanoutMsg = FanoutMsg.builder().exchange(FanoutConstants.warehouse.ALLOCATION.EXCHANGE).msg(jsonObject.toJSONString()).build();
+
+						sendFanoutService.sendFanoutMsg(fanoutMsg);
+
+					});
+				}else if ("4".equals(associationType)){
+					List<Long> stockListIds = new ArrayList<>();
+					trayGoodsEntities.forEach(trayGoodsEntity -> {
+						String materialCode = trayGoodsEntity.getAssociationValue();
+						String incomingBatch = trayGoodsEntity.getIncomingBatch();
+						Long marketId = trayGoodsEntity.getMarketId();
+						DistributionStockListEntity stockListEntity = distributionStockListClient.getEntityByMarketIdAndMaterialCodeAndIncomingBatch(marketId, incomingBatch, materialCode, warehouseId);
+						if(!Objects.isNull(stockListEntity)){
+							stockListIds.add(stockListEntity.getId());
+						}
+					});
+
+					JSONObject jsonObject = new JSONObject();
+					jsonObject.put("dataType",3);
+					jsonObject.put("operation",3);
+					jsonObject.put("stockListIds",stockListIds);
+					jsonObject.put("warehouseId",warehouseId);
+					jsonObject.put("allocationName",qrCode);
+
+					FanoutMsg fanoutMsg = FanoutMsg.builder().exchange(FanoutConstants.warehouse.ALLOCATION.EXCHANGE).msg(jsonObject.toJSONString()).build();
+
+					sendFanoutService.sendFanoutMsg(fanoutMsg);
+
+				}
+
+			});
+		}catch (Exception e){
+			log.warn("###########saveTrayTypeByOrderPackageCode: 发送打托广播失败");
+		}
+
+
 		return Resp.scanSuccess("上架成功", "整托上架成功" + total + "件");
 	}
 
@@ -3098,7 +3693,7 @@ public class WarehouseUpdownTypeServiceImpl extends BaseServiceImpl<WarehouseUpd
 		//货物和库位绑定
 		warehouseUpdownGoodsService.bindingAllocationAndPackageList(updownTypeEntity, parcelListEntities, "1", 0, remrk);
 
-		distributionParcelListClient.updateList(parcelListEntities);
+//		distributionParcelListClient.updateList(parcelListEntities);
 
 		//修改上架方式上的数据
 		updateUpdownTypeNum(updownTypeEntity);

blade-service/logpm-warehouse/src/main/java/com/logpm/warehouse/service/impl/WarehouseWaybillServiceImpl.java

@@ -27,10 +27,7 @@ import com.logpm.oldproject.entity.WayBillEntity;
 import com.logpm.oldproject.entity.WaybillDesEntity;
 import com.logpm.oldproject.feign.IWayBillClient;
 import com.logpm.oldproject.feign.IWaybillDesClient;
-import com.logpm.warehouse.dto.ProductDTO;
-import com.logpm.warehouse.dto.SplitOrderDTO;
-import com.logpm.warehouse.dto.WarehouseWaybillDTO;
-import com.logpm.warehouse.dto.WaybillDTO;
+import com.logpm.warehouse.dto.*;
 import com.logpm.warehouse.entity.WarehouseWayBillDetail;
 import com.logpm.warehouse.entity.WarehouseWaybillEntity;
 import com.logpm.warehouse.excel.WarehouseWaybillExcel;
@@ -880,6 +877,7 @@ public class WarehouseWaybillServiceImpl extends BaseServiceImpl<WarehouseWaybil
 		return list;
 	}
 
+
 	private PrintPreviewVO buildPrintWallet(WarehouseWaybillEntity warehouseWaybillEntity, List<WarehouseWayBillDetail> warehouseWayBillDetails, BasicPrintTemplateEntity template) throws Exception {
 		PrintPreviewVO printPreviewVO = new PrintPreviewVO();
 		String html = TemplateUtil.getTemplateByUrl(template.getTemplateUrl());