Merge branch 'dev' into pre-production

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

@@ -56,7 +56,7 @@ public interface LauncherConstant {
 	/**
 	 * nacos test 地址
 	 */
-	String NACOS_TEST_ADDR = "192.168.2.106:8848";
+	String NACOS_TEST_ADDR = "192.168.2.110:8848";
 
 
 	/**
@@ -72,7 +72,7 @@ public interface LauncherConstant {
 	/**
 	 * sentinel test 地址
 	 */
-	String SENTINEL_TEST_ADDR = "192.168.2.106:8858";
+	String SENTINEL_TEST_ADDR = "192.168.2.110:8858";
 
 	/**
 	 * seata dev 地址
@@ -88,7 +88,7 @@ public interface LauncherConstant {
 	/**
 	 * seata test 地址
 	 */
-	String SEATA_TEST_ADDR = "192.168.2.106:8091";
+	String SEATA_TEST_ADDR = "192.168.2.110:8091";
 
 
 	/**

blade-service-api/logpm-basicdata-api/src/main/java/com/logpm/basicdata/entity/BasicdataForwardingUnitEntity.java

@@ -0,0 +1,65 @@
+package com.logpm.basicdata.entity;
+
+import com.baomidou.mybatisplus.annotation.TableName;
+import io.swagger.annotations.ApiModel;
+import io.swagger.annotations.ApiModelProperty;
+import lombok.Data;
+import lombok.EqualsAndHashCode;
+import org.springblade.core.tenant.mp.TenantEntity;
+
+@Data
+@TableName("logpm_basicdata_forwarding_unit")
+@ApiModel(value = "BasicdataForwardingUnit对象", description = "默认仓库发货单位表")
+@EqualsAndHashCode(callSuper = true)
+public class BasicdataForwardingUnitEntity extends TenantEntity {
+
+	/**
+	 * 预留1
+	 */
+	@ApiModelProperty(value = "预留1")
+	private String reserve1;
+	/**
+	 * 预留2
+	 */
+	@ApiModelProperty(value = "预留2")
+	private String reserve2;
+	/**
+	 * 预留3
+	 */
+	@ApiModelProperty(value = "预留3")
+	private String reserve3;
+	/**
+	 * 预留4
+	 */
+	@ApiModelProperty(value = "预留4")
+	private String reserve4;
+	/**
+	 * 预留5
+	 */
+	@ApiModelProperty(value = "预留5")
+	private String reserve5;
+
+
+
+	/**
+	 * 仓库id
+	 */
+	@ApiModelProperty(value = "仓库id")
+	private Long warehouseId;
+
+	@ApiModelProperty(value = "仓库名称")
+	private String warehouseName;
+
+	@ApiModelProperty(value = "用户id")
+	private Long userId;
+
+	/**
+	 * 客户id
+	 */
+	@ApiModelProperty(value = "客户id")
+	private Long clientId;
+
+	@ApiModelProperty(value = "客户名称")
+	private String clientName;
+
+}

blade-service-api/logpm-basicdata-api/src/main/java/com/logpm/basicdata/feign/IBasicdataForwardingUnitClient.java

@@ -0,0 +1,20 @@
+package com.logpm.basicdata.feign;
+
+import org.springblade.common.constant.ModuleNameConstant;
+import org.springframework.cloud.openfeign.FeignClient;
+import org.springframework.web.bind.annotation.GetMapping;
+import org.springframework.web.bind.annotation.RequestParam;
+
+@FeignClient(
+	value = ModuleNameConstant.APPLICATION_BASICDATA_NAME
+)
+public interface IBasicdataForwardingUnitClient {
+
+	String API_PREFIX = "forwardingUnit/client";
+	String TOP = API_PREFIX + "/top";
+
+
+	@GetMapping(API_PREFIX+"/findForwardingUnitByWarehouseId")
+	Long findForwardingUnitByWarehouseIdAndUserId(@RequestParam("warehouseId") Long warehouseId,@RequestParam("userId") Long userId);
+
+}

blade-service-api/logpm-trunkline-api/src/main/java/com/logpm/trunkline/vo/OpenOrderVO.java

@@ -23,8 +23,15 @@ public class OpenOrderVO implements Serializable {
 	private Long destinationWarehouseId;//目的仓Id
 
 	private String destination;//到站
+	private String destinationCode;//到站编码
 	private List<String> destinationArray;//到站
 
+	private Long shipperClientId;//发货单位clientId
+	private String shipper;//发货单位
+	private String shipperName;//发货人
+	private String shipperMobile;//发货人电话
+	private String shipperAddress;//发货单位地址
+
 	private Long consigneeClientId;//收货单位clientId
 	private String consignee;//收货单位
 	private String consigneeName;//收货人

blade-service/logpm-basicdata/src/main/java/com/logpm/basicdata/feign/BasicdataForwardingUnitClient.java

@@ -0,0 +1,31 @@
+package com.logpm.basicdata.feign;
+
+import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
+import com.logpm.basicdata.entity.BasicdataForwardingUnitEntity;
+import com.logpm.basicdata.service.IBasicdataForwardingUnitService;
+import lombok.AllArgsConstructor;
+import org.springframework.web.bind.annotation.RestController;
+import springfox.documentation.annotations.ApiIgnore;
+
+import java.util.Objects;
+
+@ApiIgnore()
+@RestController
+@AllArgsConstructor
+public class BasicdataForwardingUnitClient implements IBasicdataForwardingUnitClient{
+
+	private final IBasicdataForwardingUnitService basicdataForwardingUnitService;
+
+	@Override
+	public Long findForwardingUnitByWarehouseIdAndUserId(Long warehouseId, Long userId) {
+		QueryWrapper<BasicdataForwardingUnitEntity> queryWrapper = new QueryWrapper<>();
+		queryWrapper.eq("warehouse_id",warehouseId)
+			.eq("user_id",userId);
+
+		BasicdataForwardingUnitEntity forwardingUnitEntity = basicdataForwardingUnitService.getOne(queryWrapper);
+		if(!Objects.isNull(forwardingUnitEntity)){
+			return forwardingUnitEntity.getClientId();
+		}
+		return null;
+	}
+}

blade-service/logpm-basicdata/src/main/java/com/logpm/basicdata/mapper/BasicdataForwardingUnitMapper.java

@@ -0,0 +1,11 @@
+package com.logpm.basicdata.mapper;
+
+import com.baomidou.mybatisplus.core.mapper.BaseMapper;
+import com.logpm.basicdata.entity.BasicdataForwardingUnitEntity;
+import org.apache.ibatis.annotations.Mapper;
+
+@Mapper
+public interface BasicdataForwardingUnitMapper extends BaseMapper<BasicdataForwardingUnitEntity> {
+
+
+}

blade-service/logpm-basicdata/src/main/java/com/logpm/basicdata/service/IBasicdataForwardingUnitService.java

@@ -0,0 +1,7 @@
+package com.logpm.basicdata.service;
+
+import com.logpm.basicdata.entity.BasicdataForwardingUnitEntity;
+import org.springblade.core.mp.base.BaseService;
+
+public interface IBasicdataForwardingUnitService extends BaseService<BasicdataForwardingUnitEntity> {
+}

blade-service/logpm-basicdata/src/main/java/com/logpm/basicdata/service/impl/BasicdataForwardingUnitServiceImpl.java

@@ -0,0 +1,16 @@
+package com.logpm.basicdata.service.impl;
+
+import com.logpm.basicdata.entity.BasicdataForwardingUnitEntity;
+import com.logpm.basicdata.mapper.BasicdataForwardingUnitMapper;
+import com.logpm.basicdata.service.IBasicdataForwardingUnitService;
+import lombok.AllArgsConstructor;
+import lombok.extern.slf4j.Slf4j;
+import org.springblade.core.mp.base.BaseServiceImpl;
+import org.springframework.stereotype.Service;
+
+@Slf4j
+@Service
+@AllArgsConstructor
+public class BasicdataForwardingUnitServiceImpl extends BaseServiceImpl<BasicdataForwardingUnitMapper, BasicdataForwardingUnitEntity> implements IBasicdataForwardingUnitService {
+
+}

blade-service/logpm-distribution/src/main/resources/application-test.yml

@@ -12,10 +12,10 @@ server:
 spring:
   #rabbitmq配置
   rabbitmq:
-    host: 192.168.2.106
+    host: 192.168.2.110
     port: 5672
     username: admin
-    password: admin@1234.
+    password: Slwk@123654
     #虚拟host 可以不设置,使用server默认host
     virtual-host: /
     #确认消息已发送到队列(Queue)

blade-service/logpm-factory/src/main/resources/application-test.yml

@@ -31,10 +31,10 @@ spring:
           password: ${blade.datasource.factory.slave.password}
   #rabbitmq配置
   rabbitmq:
-    host: 192.168.2.106
+    host: 192.168.2.110
     port: 5672
     username: admin
-    password: admin@1234.
+    password: Slwk@123654
     #虚拟host 可以不设置,使用server默认host
     virtual-host: /
     #确认消息已发送到队列(Queue)

blade-service/logpm-trunkline/src/main/java/com/logpm/trunkline/mapper/TrunklineAdvanceDetailMapper.xml

@@ -13,7 +13,7 @@
         select ltad.id id,
                ltad.warehouse_id warehouseId,
                ltad.warehouse_name warehouseName,
-               ltad.waybill_no waybillNo,
+               lta.waybill_no waybillNo,
                ltad.order_code orderCode,
                lta.train_number trainNumber,
                ltad.package_status packageStatus,

blade-service/logpm-trunkline/src/main/java/com/logpm/trunkline/mapper/TrunklineCarsLoadMapper.xml

@@ -354,6 +354,7 @@
         <if test="param.type != null and param.type == 2">
             and ltcl.load_status != '0'
         </if>
+        order by ltcl.create_time desc
     </select>
 
     <select id="carsLoadPageList" resultType="com.logpm.trunkline.vo.TrunklineCarsLoadVO">

blade-service/logpm-trunkline/src/main/java/com/logpm/trunkline/mapper/TrunklineCarsLoadScanMapper.xml

@@ -222,6 +222,7 @@
         where ltcls.load_id = #{loadId}
         and ltcls.warehouse_id = #{warehouseId}
         and ltcls.final_node_id is null
+        and ltcls.scan_status = '1'
     </select>
 
     <update id="updateFinalNodeIdById">

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

@@ -74,6 +74,7 @@ public class OpenOrderServiceImpl implements IOpenOrderService {
 	private final ITrunklineWaybillPackageService trunklineWaybillPackageService;
 	private final IBasicMaterialClient basicMaterialClient;
 	private final IBasicdataBrandClient basicdataBrandClient;
+	private final IBasicdataForwardingUnitClient basicdataForwardingUnitClient;
 
 	@Override
 	public IPage<TrunklineAdvanceVO> advancePageList(AdvanceDTO advanceDTO) {
@@ -130,8 +131,18 @@ public class OpenOrderServiceImpl implements IOpenOrderService {
 		openOrderVO.setDepartureWarehouseName(basicdataWarehouseEntity.getName());
 		openOrderVO.setDepartureWarehouseId(warehouseId);
 		openOrderVO.setTotalNum(totalNum);
-
-		//发货单位 TODO
+		//发货单位
+		Long shipperId = basicdataForwardingUnitClient.findForwardingUnitByWarehouseIdAndUserId(warehouseId,AuthUtil.getUserId());
+		if(!Objects.isNull(shipperId)){
+			BasicdataClientEntity basicdataClientEntity = basicdataClientClient.findEntityById(shipperId);
+			if(!Objects.isNull(basicdataClientEntity)){
+				openOrderVO.setShipperClientId(shipperId);
+				openOrderVO.setShipper(basicdataClientEntity.getClientName());
+				openOrderVO.setShipperName(basicdataClientEntity.getLinkman());
+				openOrderVO.setShipperMobile(basicdataClientEntity.getPhone());
+				openOrderVO.setShipperAddress(basicdataClientEntity.getDetailedly());
+			}
+		}
 
 
 		//收货单位-----根据三方商场找到对应的clientId
@@ -151,20 +162,22 @@ public class OpenOrderServiceImpl implements IOpenOrderService {
 			destinationArray.add(bladeRegionProvinceId);
 			destinationArray.add(bladeRegionCityId);
 			String name = regionFeign.getName(bladeRegionCityId);
+			String areaId = bladeRegionCityId;
 			if(!StringUtil.isBlank(badeRegionAreaId)){
 				destinationArray.add(badeRegionAreaId);
 				name = regionFeign.getName(badeRegionAreaId);
+				areaId = badeRegionAreaId;
 			}
 
 			openOrderVO.setDestination(name);
+			openOrderVO.setDestinationCode(areaId);
 			openOrderVO.setDestinationArray(destinationArray);
 
 			openOrderVO.setDefaultPayWay(basicdataClientEntity.getDefaultPaymentMethods());
 
 			//查询目的仓数据
-			List<BasicdataStorageServicesEntity> storageServicesEntities = basicdataStorageServicesClient.findBySendWarehouseIdAndClientId(warehouseId,clientId);
-			if(!storageServicesEntities.isEmpty()){
-				BasicdataStorageServicesEntity basicdataStorageServicesEntity = storageServicesEntities.get(0);
+			BasicdataStorageServicesEntity basicdataStorageServicesEntity = basicdataStorageServicesClient.findEntityBySendWarehouseIdAndClientId(warehouseId, clientId);
+			if(!Objects.isNull(basicdataStorageServicesEntity)){
 				openOrderVO.setDestinationWarehouseId(basicdataStorageServicesEntity.getServeWarehouseId());
 				openOrderVO.setDestinationWarehouseName(basicdataStorageServicesEntity.getServeWarehouseName());
 			}

blade-service/logpm-warehouse/src/main/resources/application-test.yml

@@ -31,10 +31,10 @@ spring:
           password: ${blade.datasource.warehouse.slave.password}
   #rabbitmq配置
   rabbitmq:
-    host: 192.168.2.106
+    host: 192.168.2.110
     port: 5672
     username: admin
-    password: admin@1234.
+    password: Slwk@123654
     #虚拟host 可以不设置,使用server默认host
     virtual-host: /
     #确认消息已发送到队列(Queue)