1.干线bug修复

blade-service/logpm-patch/src/main/java/com/logpm/patch/jobhandle/DistributionDatarepair.java

@@ -3,26 +3,22 @@ package com.logpm.patch.jobhandle;
 
 import cn.hutool.json.JSONObject;
 import com.logpm.distribution.entity.DistributionParcelListEntity;
-import com.logpm.distribution.entity.DistributionSignforEntity;
 import com.logpm.distribution.feign.IDistributionDeliveryListClient;
 import com.logpm.distribution.feign.IDistributionReservationClient;
 import com.logpm.distribution.feign.IDistributionSignforClient;
 import com.logpm.distribution.feign.IDistrilbutionBillLadingClient;
 import com.logpm.patch.mapper.WarehouseMappingDataMapper;
 import com.logpm.patch.service.ISyncDistributionParcelListService;
+import com.logpm.patch.service.IWarehouseMappingDataService;
 import com.logpm.warehouse.feign.IWarehouseUpdownTypeClient;
 import com.xxl.job.core.biz.model.ReturnT;
 import com.xxl.job.core.handler.annotation.XxlJob;
-import io.jsonwebtoken.lang.Objects;
 import lombok.AllArgsConstructor;
 import lombok.extern.slf4j.Slf4j;
 import org.apache.commons.lang.StringUtils;
-import org.springblade.common.constant.RabbitConstant;
-import org.springblade.common.utils.CommonUtil;
 import org.springblade.core.tool.utils.Func;
 import org.springblade.core.tool.utils.StringUtil;
 import org.springframework.amqp.rabbit.core.RabbitTemplate;
-import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.stereotype.Component;
 
 import java.util.HashMap;
@@ -38,6 +34,7 @@ import java.util.stream.Collectors;
 @Component
 public class DistributionDatarepair {
 
+	private final IWarehouseMappingDataService warehouseMappingDataService;
 
 	private final ISyncDistributionParcelListService iSyncDistributionParcelListService;
 
@@ -339,7 +336,20 @@ public class DistributionDatarepair {
 	@XxlJob("handletrunklineWaybillSignLog")
 	public ReturnT<String> handletrunklineWaybillSignLog(String params) {
 		// 得到当前仓库所有的签收任务
-		Boolean b = distributionSignforClient.handletrunklineWaybillSignLog(params);
+		List<JSONObject> ls = warehouseMappingDataService.findAllDealWithWaybillNo();
+
+		ls.forEach(json -> {
+			Integer id = json.getInt("id");
+			String waybillNo = json.getStr("waybillNo");
+
+			log.info("###################saveBasicdataZero: 当前处理的运单为 waybillNo={}",waybillNo);
+
+			Boolean b = distributionSignforClient.handletrunklineWaybillSignLog(waybillNo);
+
+			warehouseMappingDataService.updateStatusDealwithWaybillById(id);
+		});
+
+
 		return ReturnT.SUCCESS;
 	}
 

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

@@ -61,6 +61,7 @@ public class WaybillCheckListener {
 	))
 	@Transactional(rollbackFor = Exception.class)
 	public void checkWaybillIncomingData(String msg) {
+		try{
 			log.info("#########checkWaybillIncomingData: 运单审核处理收入结算数据 msg={}", msg);
 			JSONObject jsonObject = JSONUtil.parseObj(msg);
 			Long waybillId = jsonObject.getLong("waybillId");
@@ -90,6 +91,9 @@ public class WaybillCheckListener {
 //			createBalanceOrder(waybillEntity);
 //		}
 			log.info("#########checkWaybillIncomingData: 运单审核处理收入结算数据 结束 waybillId={}", waybillId);
+		} catch (Exception e) {
+			log.error("###############checkWaybillIncomingData: 运单审核处理收入结算数据 异常 msg={}", msg, e);
+		}
 	}
 
 	private void createBalanceOrder(WarehouseWaybillEntity waybillEntity) {

blade-service/logpm-warehouse/src/main/java/com/logpm/warehouse/controller/WarehouseWaybillController.java

@@ -16,6 +16,7 @@
  */
 package com.logpm.warehouse.controller;
 
+import cn.hutool.core.collection.CollUtil;
 import com.baomidou.mybatisplus.core.metadata.IPage;
 import com.github.xiaoymin.knife4j.annotations.ApiOperationSupport;
 import com.logpm.basicdata.entity.BasicdataWarehouseEntity;
@@ -314,10 +315,14 @@ public class WarehouseWaybillController extends BladeController {
 		String method = "############pageFinanceWaybillList: ";
 		log.info(method + "请求参数{}", waybillDTO);
 		try{
+
+			List<Long> destinationWarehouseIds1 = waybillDTO.getDestinationWarehouseIds();
+
+			if(CollUtil.isEmpty(destinationWarehouseIds1)){
 				List<Long> destinationWarehouseIds = warehouseClient.getWarehouseIds();
 				//当前登录人选择的仓库
-
 				waybillDTO.setDestinationWarehouseIds(destinationWarehouseIds);
+			}
 
 			IPage<FinanceWaybillVO> pages = warehouseWaybillService.pageFinanceWaybillList(waybillDTO);
 
@@ -338,20 +343,13 @@ public class WarehouseWaybillController extends BladeController {
 	public void financeWaybillListExport(@RequestBody WarehouseWaybillDTO waybillDTO, HttpServletResponse response) {
 		String method = "############financeWaybillListExport: ";
 		log.info(method+"请求参数{}",waybillDTO);
-		List<Long> destinationWarehouseIds = new ArrayList<>();
+		List<Long> destinationWarehouseIds1 = waybillDTO.getDestinationWarehouseIds();
+
+		if(CollUtil.isEmpty(destinationWarehouseIds1)){
+			List<Long> destinationWarehouseIds = warehouseClient.getWarehouseIds();
 			//当前登录人选择的仓库
-		BasicdataWarehouseEntity myCurrentWarehouse = warehouseClient.getMyCurrentWarehouse();
-		if(Objects.isNull(myCurrentWarehouse)){
-			List<BasicdataWarehouseEntity> myWatchWarehouse = warehouseClient.getMyWatchWarehouse();
-			if(!myWatchWarehouse.isEmpty()){
-				myWatchWarehouse.forEach(warehouseEntity -> {
-					destinationWarehouseIds.add(warehouseEntity.getId());
-				});
-			}
-		}else{
-			destinationWarehouseIds.add(myCurrentWarehouse.getId());
-		}
 			waybillDTO.setDestinationWarehouseIds(destinationWarehouseIds);
+		}
 
 		List<FinanceWaybillExportVO> ls = warehouseWaybillService.financeWaybillListExport(waybillDTO);
 		//导出ls