Browse Source

Merge branch 'dev' into chenglong

dist.1.3.0
chenlong 9 months ago
parent
commit
9b8142f60d
  1. 14
      blade-biz-common/src/main/java/org/springblade/common/annotations/ChangeAsync.java
  2. 22
      blade-biz-common/src/main/java/org/springblade/common/annotations/LocalServerUser.java
  3. 15
      blade-biz-common/src/main/java/org/springblade/common/annotations/LogpmAsync.java
  4. 11
      blade-biz-common/src/main/java/org/springblade/common/annotations/RepeatSubmit.java
  5. 10
      blade-biz-common/src/main/java/org/springblade/common/cache/CacheNames.java
  6. 37
      blade-biz-common/src/main/java/org/springblade/common/component/MockLoginService.java
  7. 1
      blade-biz-common/src/main/java/org/springblade/common/constant/CodeNumConstant.java
  8. 13
      blade-biz-common/src/main/java/org/springblade/common/constant/CommonBroadCastMqConstant.java
  9. 3
      blade-biz-common/src/main/java/org/springblade/common/constant/DictBizConstant.java
  10. 6
      blade-biz-common/src/main/java/org/springblade/common/constant/IncomingTypeEnum.java
  11. 59
      blade-biz-common/src/main/java/org/springblade/common/constant/LauncherConstant.java
  12. 30
      blade-biz-common/src/main/java/org/springblade/common/constant/ModuleNameConstant.java
  13. 20
      blade-biz-common/src/main/java/org/springblade/common/constant/OldSystemDataPushConfig.java
  14. 86
      blade-biz-common/src/main/java/org/springblade/common/constant/RabbitConstant.java
  15. 11
      blade-biz-common/src/main/java/org/springblade/common/constant/RedisKeyConstant.java
  16. 50
      blade-biz-common/src/main/java/org/springblade/common/constant/WaybillStatusEnum.java
  17. 111
      blade-biz-common/src/main/java/org/springblade/common/constant/WorkNodeEnums.java
  18. 44
      blade-biz-common/src/main/java/org/springblade/common/constant/basiccode/BasicCodeShowConstant.java
  19. 68
      blade-biz-common/src/main/java/org/springblade/common/constant/basiccode/BasicCodeTypeConstant.java
  20. 177
      blade-biz-common/src/main/java/org/springblade/common/constant/broadcast/FanoutConstants.java
  21. 7
      blade-biz-common/src/main/java/org/springblade/common/constant/carsload/CarsLoadLogTypeConstant.java
  22. 96
      blade-biz-common/src/main/java/org/springblade/common/constant/factorydata/FactoryDataConstants.java
  23. 46
      blade-biz-common/src/main/java/org/springblade/common/constant/loading/LoadScanSigningTypeStatusConstant.java
  24. 2
      blade-biz-common/src/main/java/org/springblade/common/launch/LauncherServiceImpl.java
  25. 60
      blade-biz-common/src/main/java/org/springblade/common/model/BroadcastNodeData.java
  26. 14
      blade-biz-common/src/main/java/org/springblade/common/model/FanoutMsg.java
  27. 28
      blade-biz-common/src/main/java/org/springblade/common/utils/CommonUtil.java
  28. 27
      blade-biz-common/src/main/java/org/springblade/common/utils/FileLogsUtil.java
  29. 30
      blade-biz-common/src/main/java/org/springblade/common/utils/StringSplitUtil.java
  30. 26
      blade-biz-common/src/main/java/org/springblade/common/utils/TokenUtil.java
  31. 36
      blade-biz-common/src/main/java/org/springblade/common/wrapper/CustomHttpServletRequestWrapper.java
  32. 3
      blade-ops/blade-xxljob-admin/Dockerfile
  33. 1
      blade-ops/blade-xxljob-admin/src/main/java/com/xxl/job/admin/JobAdminApplication.java
  34. 4
      blade-service-api/logpm-aftersales-api/src/main/java/com/logpm/aftersales/entity/AftersaleSurveyRecordEntity.java
  35. 14
      blade-service-api/logpm-aftersales-api/src/main/java/com/logpm/aftersales/entity/AftersalesAbnormalPackageEntity.java
  36. 8
      blade-service-api/logpm-aftersales-api/src/main/java/com/logpm/aftersales/entity/AftersalesAbnormalRecordEntity.java
  37. 5
      blade-service-api/logpm-aftersales-api/src/main/java/com/logpm/aftersales/entity/AftersalesWorkOrderEntity.java
  38. 13
      blade-service-api/logpm-aftersales-api/src/main/java/com/logpm/aftersales/feign/IAftersalesAbnormalRecordClient.java
  39. 10
      blade-service-api/logpm-aftersales-api/src/main/java/com/logpm/aftersales/feign/IAftersalesWorkOrderClient.java
  40. 1
      blade-service-api/logpm-aftersales-api/src/main/java/com/logpm/aftersales/vo/AftersalesDeliverVO.java
  41. 2
      blade-service-api/logpm-aftersales-api/src/main/java/com/logpm/aftersales/vo/AftersalesProcessorVO.java
  42. 7
      blade-service-api/logpm-aftersales-api/src/main/java/com/logpm/aftersales/vo/AftersalesWorkOrderVO.java
  43. 15
      blade-service-api/logpm-basic-api/src/main/java/com/logpm/basic/entity/BasicTenantCodeEntity.java
  44. 4
      blade-service-api/logpm-basic-api/src/main/java/com/logpm/basic/feign/IBasicTenantCodeClient.java
  45. 28
      blade-service-api/logpm-basic-api/src/main/java/com/logpm/basic/vo/TableSetVo.java
  46. 5
      blade-service-api/logpm-basicdata-api/src/main/java/com/logpm/basicdata/entity/BasicdataClientEntity.java
  47. 5
      blade-service-api/logpm-basicdata-api/src/main/java/com/logpm/basicdata/entity/BasicdataFactoryCategoryEntity.java
  48. 4
      blade-service-api/logpm-basicdata-api/src/main/java/com/logpm/basicdata/entity/BasicdataPriceCategoryWarehouseEntity.java
  49. 4
      blade-service-api/logpm-basicdata-api/src/main/java/com/logpm/basicdata/entity/BasicdataPriceTemplateEntity.java
  50. 22
      blade-service-api/logpm-basicdata-api/src/main/java/com/logpm/basicdata/feign/IBasicdataClientClient.java
  51. 6
      blade-service-api/logpm-basicdata-api/src/main/java/com/logpm/basicdata/feign/IBasicdataCodeClient.java
  52. 3
      blade-service-api/logpm-basicdata-api/src/main/java/com/logpm/basicdata/feign/IBasicdataDriverArteryClient.java
  53. 26
      blade-service-api/logpm-basicdata-api/src/main/java/com/logpm/basicdata/feign/IBasicdataFactoryCategoryClient.java
  54. 3
      blade-service-api/logpm-basicdata-api/src/main/java/com/logpm/basicdata/feign/IBasicdataGoodsAllocationClient.java
  55. 9
      blade-service-api/logpm-basicdata-api/src/main/java/com/logpm/basicdata/feign/IBasicdataPriceClient.java
  56. 11
      blade-service-api/logpm-basicdata-api/src/main/java/com/logpm/basicdata/feign/IBasicdataTrayClient.java
  57. 4
      blade-service-api/logpm-basicdata-api/src/main/java/com/logpm/basicdata/feign/IBasicdataTripartiteMallClient.java
  58. 39
      blade-service-api/logpm-basicdata-api/src/main/java/com/logpm/basicdata/vo/BasicdatPriceApiVO.java
  59. 2
      blade-service-api/logpm-basicdata-api/src/main/java/com/logpm/basicdata/vo/BasicdataDriverArteryVO.java
  60. 5
      blade-service-api/logpm-basicdata-api/src/main/java/com/logpm/basicdata/vo/BasicdataPriceBasicUpdateVO.java
  61. 47
      blade-service-api/logpm-basicdata-api/src/main/java/com/logpm/basicdata/vo/BasicdataPriceImportVO.java
  62. 6
      blade-service-api/logpm-basicdata-api/src/main/java/com/logpm/basicdata/vo/BasicdataPricePageVO.java
  63. 3
      blade-service-api/logpm-basicdata-api/src/main/java/com/logpm/basicdata/vo/BasicdataTrayVO.java
  64. 5
      blade-service-api/logpm-basicdata-api/src/main/java/com/logpm/basicdata/vo/ClientInfoVO.java
  65. 50
      blade-service-api/logpm-basicdata-api/src/main/java/com/logpm/basicdata/vo/PriceDispatchAddClientVO.java
  66. 4
      blade-service-api/logpm-basicdata-api/src/main/java/com/logpm/basicdata/vo/PriceWarehouseBasicVO.java
  67. 18
      blade-service-api/logpm-business-api/pom.xml
  68. 12
      blade-service-api/logpm-business-api/src/main/java/com/logpm/business/dto/BusinessPreListDTO.java
  69. 12
      blade-service-api/logpm-business-api/src/main/java/com/logpm/business/dto/BusinessPreOrderDTO.java
  70. 33
      blade-service-api/logpm-business-api/src/main/java/com/logpm/business/dto/BusinessSanDTO.java
  71. 269
      blade-service-api/logpm-business-api/src/main/java/com/logpm/business/entity/BusinessPreOrderEntity.java
  72. 28
      blade-service-api/logpm-business-api/src/main/java/com/logpm/business/feign/IBusinessPreOrderClient.java
  73. 14
      blade-service-api/logpm-business-api/src/main/java/com/logpm/business/vo/BusinessPreOrderVO.java
  74. 28
      blade-service-api/logpm-business-api/src/main/java/com/logpm/business/vo/DistributionBusinessPreCarDetalPackageVO.java
  75. 42
      blade-service-api/logpm-business-api/src/main/java/com/logpm/business/vo/DistributionBusinessPreCarDetalVO.java
  76. 28
      blade-service-api/logpm-business-api/src/main/java/com/logpm/business/vo/DistributionBusinessPreCarNumberVO.java
  77. 16
      blade-service-api/logpm-business-api/src/main/java/com/logpm/business/vo/DistributionBusinessPreCarNumerPageQueryVO.java
  78. 34
      blade-service-api/logpm-business-api/src/main/java/com/logpm/business/vo/DistributionBusinessPreCarNumerPageVO.java
  79. 35
      blade-service-api/logpm-business-api/src/main/java/com/logpm/business/vo/DistributionBusinessPreCarOrderDetalVO.java
  80. 28
      blade-service-api/logpm-business-api/src/main/java/com/logpm/business/vo/DistributionBusinessPreOrderListVO.java
  81. 19
      blade-service-api/logpm-distribution-api/src/main/java/com/logpm/distribution/dto/FindParamterDTO.java
  82. 14
      blade-service-api/logpm-distribution-api/src/main/java/com/logpm/distribution/dto/OrderPackageDTO.java
  83. 48
      blade-service-api/logpm-distribution-api/src/main/java/com/logpm/distribution/entity/DistributionAddvaluePackageEntity.java
  84. 6
      blade-service-api/logpm-distribution-api/src/main/java/com/logpm/distribution/entity/DistributionBillLadingScanEntity.java
  85. 8
      blade-service-api/logpm-distribution-api/src/main/java/com/logpm/distribution/entity/DistributionLoadscanAbnormalEntity.java
  86. 7
      blade-service-api/logpm-distribution-api/src/main/java/com/logpm/distribution/entity/DistributionLoadscanEntity.java
  87. 6
      blade-service-api/logpm-distribution-api/src/main/java/com/logpm/distribution/entity/DistributionLoadscaninvnEntity.java
  88. 21
      blade-service-api/logpm-distribution-api/src/main/java/com/logpm/distribution/entity/DistributionParcelListEntity.java
  89. 7
      blade-service-api/logpm-distribution-api/src/main/java/com/logpm/distribution/entity/DistributionReservationEntity.java
  90. 7
      blade-service-api/logpm-distribution-api/src/main/java/com/logpm/distribution/entity/DistributionReservationPackageEntity.java
  91. 12
      blade-service-api/logpm-distribution-api/src/main/java/com/logpm/distribution/entity/DistributionStockArticleEntity.java
  92. 8
      blade-service-api/logpm-distribution-api/src/main/java/com/logpm/distribution/entity/DistributionStockEntity.java
  93. 18
      blade-service-api/logpm-distribution-api/src/main/java/com/logpm/distribution/entity/DistrilbutionBillLadingEntity.java
  94. 6
      blade-service-api/logpm-distribution-api/src/main/java/com/logpm/distribution/feign/IDistributionDeliveryListClient.java
  95. 156
      blade-service-api/logpm-distribution-api/src/main/java/com/logpm/distribution/feign/IDistributionParcelListClient.java
  96. 2
      blade-service-api/logpm-distribution-api/src/main/java/com/logpm/distribution/feign/IDistributionReservationClient.java
  97. 15
      blade-service-api/logpm-distribution-api/src/main/java/com/logpm/distribution/feign/IDistributionSignforClient.java
  98. 103
      blade-service-api/logpm-distribution-api/src/main/java/com/logpm/distribution/feign/IDistributionStockArticleClient.java
  99. 2
      blade-service-api/logpm-distribution-api/src/main/java/com/logpm/distribution/feign/IDistributionStockClient.java
  100. 15
      blade-service-api/logpm-distribution-api/src/main/java/com/logpm/distribution/feign/IDistrilbutionBillLadingClient.java
  101. Some files were not shown because too many files have changed in this diff Show More

14
blade-biz-common/src/main/java/org/springblade/common/annotations/ChangeAsync.java

@ -0,0 +1,14 @@
package org.springblade.common.annotations;
import org.springframework.scheduling.annotation.Async;
import java.lang.annotation.ElementType;
import java.lang.annotation.Retention;
import java.lang.annotation.RetentionPolicy;
import java.lang.annotation.Target;
@Target({ElementType.TYPE, ElementType.METHOD})
@Retention(RetentionPolicy.RUNTIME)
public @interface ChangeAsync {
String value() default "";
}

22
blade-biz-common/src/main/java/org/springblade/common/annotations/LocalServerUser.java

@ -0,0 +1,22 @@
package org.springblade.common.annotations;
import java.lang.annotation.ElementType;
import java.lang.annotation.Retention;
import java.lang.annotation.RetentionPolicy;
import java.lang.annotation.Target;
/**
* 特俗标记
*/
@Retention(RetentionPolicy.RUNTIME)
@Target({ ElementType.METHOD})
public @interface LocalServerUser {
/**
* 匹配值
* factory:工厂系统
* 6278683: 租户
* factory-data: 租户
* @return
*/
String ds() default "";
}

15
blade-biz-common/src/main/java/org/springblade/common/annotations/LogpmAsync.java

@ -0,0 +1,15 @@
package org.springblade.common.annotations;
import org.springframework.scheduling.annotation.Async;
import java.lang.annotation.ElementType;
import java.lang.annotation.Retention;
import java.lang.annotation.RetentionPolicy;
import java.lang.annotation.Target;
@Target({ElementType.TYPE, ElementType.METHOD})
@Retention(RetentionPolicy.RUNTIME)
@Async("asyncExecutor")
public @interface LogpmAsync {
String value();
}

11
blade-biz-common/src/main/java/org/springblade/common/annotations/RepeatSubmit.java

@ -0,0 +1,11 @@
package org.springblade.common.annotations;
import java.lang.annotation.ElementType;
import java.lang.annotation.Retention;
import java.lang.annotation.RetentionPolicy;
import java.lang.annotation.Target;
@Target({ElementType.METHOD})
@Retention(RetentionPolicy.RUNTIME)
public @interface RepeatSubmit {
}

10
blade-biz-common/src/main/java/org/springblade/common/cache/CacheNames.java vendored

@ -78,4 +78,14 @@ public interface CacheNames {
* 用户能操作的仓库
*/
String USER_WAREHOUSE_OWN = "logpm:user:warehouse:own:";
/**
* 模拟登录缓存对象
*/
String LOCAL_SERVER_USER = "logpm:user:local:user:";
/**
* 模拟登录缓存对象
*/
String USER_TABLE_SET = "user:table:set:";
}

37
blade-biz-common/src/main/java/org/springblade/common/component/MockLoginService.java

@ -0,0 +1,37 @@
package org.springblade.common.component;
import cn.hutool.http.HttpRequest;
import cn.hutool.http.HttpResponse;
import com.alibaba.fastjson.JSONObject;
import lombok.AllArgsConstructor;
import org.springblade.common.constant.LauncherConstant;
import org.springframework.core.env.Environment;
import org.springframework.stereotype.Component;
import java.util.HashMap;
import java.util.Map;
import java.util.Objects;
@Component
@AllArgsConstructor
public class MockLoginService {
private final Environment environment;
public JSONObject mockToken(String tenantId,String account) {
String url = "http://" + LauncherConstant.loginAddr(Objects.requireNonNull(environment.getActiveProfiles()[0])) + "/blade-auth/oauth/token";
HttpRequest urlRequest = HttpRequest.post(url);
// urlRequest.header("Authorization", "Basic c2FiZXI6c2FiZXJfc2VjcmV0");
urlRequest.header("Authorization", "Basic bG9jYWw6bG9jYWxfc2VjcmV0");
urlRequest.header("Tenant-Id", "627683");
Map<String, Object> params = new HashMap<>();
params.put("grant_type", "local_server");
params.put("scope", "all");
params.put("username", account);
params.put("tenantId", tenantId);
HttpResponse execute = urlRequest.form(params).execute();
String body = execute.body();
JSONObject jsonObject = JSONObject.parseObject(body);
return jsonObject;
}
}

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

@ -16,5 +16,6 @@ public class CodeNumConstant {
public final static int TRUNKLINE_CARS_LOAD = 12;//干线配载批次号
public final static int TRUNKLINE_TRIPARTITE_LOAD = 13;//干线三方中转批次号
public final static int TRUNKLINE_LOAD_SIGN = 14;//干线直发商家签收单号
public final static int BALANCE_ORDER = 15;//结算单号
}

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

@ -0,0 +1,13 @@
package org.springblade.common.constant;
public class CommonBroadCastMqConstant {
//--------------------开单交换机
public static final String OPEN_WAYBILL_BROADCAST_EXCHANGE = "trunkline.openWaybill.broadcast.exchange"+ModuleNameConstant.DEVAUTH;
public static final String OPEN_WAYBILL_BROADCAST_QUEUE = "open_waybill_broadcast_queue"+ModuleNameConstant.DEVAUTH;
public static final String UPDATE_WAYBILL_BROADCAST_QUEUE = "update_waybill_broadcast_queue"+ModuleNameConstant.DEVAUTH;
}

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

@ -94,6 +94,7 @@ public class DictBizConstant {
// --------------2023-08-24 ---------------------
public static final String RESERVATION_LIST_LOADING_STATUS = "reservation_loading_status";//预约装车状态
public static final String RESERVATION_SIGNFOR_STATUS = "reservation_signfor_status";//预约签收状态
public static final String YES_NO = "yes_no";//预约签收状态
// --------------2023-09-01 ---------------------
public static final String ORDER_PACKAGE_LOADING_STATUS = "order_package_loading_status";//预约签收状态
@ -113,6 +114,8 @@ public class DictBizConstant {
public static final String OPEN_ORDER_URGENCY = "open_order_urgency";
public static final String OPEN_ORDER_RECEIPT = "open_order_receipt";
public static final String OPEN_ORDER_TRANSPORT_TYPE = "open_order_transport_type";
public static final String OPEN_ORDER_CHARGE_TYPE = "open_order_charge_type";
public static final String EDIT_WAYBILL_REASON_TYPE = "edit_waybill_reason_type";
/* 异常工单状态 */
public static final String PC_WORK_ORDER = "pc_work_order"; //PC工单异常类型

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

@ -15,13 +15,13 @@ public enum IncomingTypeEnum {
UNLOAD_TRAY_INCOMING(8, "托盘卸车入库"),
UNLOAD_TRAY_ONE(9, "卸分一体"),
OPEN_TO_IN(10, "开单及入库"),
FACTORY_TO_INCOMING(11, "工厂推送数据入库");
FACTORY_TO_INCOMING(11, "工厂推送数据入库"),
SUPPLE_INCOMING(12, "数据补录入库"),
ABNORMAL_INCOMING(13, "异常列表入库");
private Integer code;
private String value;
IncomingTypeEnum(Integer code, String value) {
this.code = code;
this.value = value;

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

@ -90,6 +90,37 @@ public interface LauncherConstant {
*/
String SEATA_TEST_ADDR = "192.168.2.110:8091";
/**
* 本地登录 dev地址
*/
String APPLICATION_DEV_LOGIN_ADDR = "127.0.0.1:13000";
/**
* 本地登录 test地址
*/
String APPLICATION_TEST_LOGIN_ADDR = "192.168.2.110:9999";
/**
* 本地登录 pord地址
*/
String APPLICATION_PROD_LOGIN_ADDR = "172.16.128.147:8888";
/**
* elk dev 地址
*/
String ELK_DEV_ADDR = "192.168.2.46:9000";
/**
* elk prod 地址
*/
String ELK_PROD_ADDR = "172.30.0.72:9000";
/**
* elk test 地址
*/
String ELK_TEST_ADDR = "192.168.2.110:9002";
/**
* dbuuo提供者
@ -221,4 +252,32 @@ public interface LauncherConstant {
}
}
static String loginAddr(String profile) {
switch (profile) {
case (AppConstant.DEV_CODE):
return APPLICATION_DEV_LOGIN_ADDR;
case (AppConstant.TEST_CODE):
return APPLICATION_TEST_LOGIN_ADDR;
default:
return APPLICATION_PROD_LOGIN_ADDR;
}
}
/**
* 动态获取elk地址
*
* @param profile 环境变量
* @return addr
*/
static String elkAddr(String profile) {
switch (profile) {
case (AppConstant.PROD_CODE):
return ELK_PROD_ADDR;
case (AppConstant.TEST_CODE):
return ELK_TEST_ADDR;
default:
return ELK_DEV_ADDR;
}
}
}

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

@ -79,6 +79,11 @@ public interface ModuleNameConstant {
*/
String APPLICATION_REPORT_NAME = "logpm-report" + DEVAUTH;
/**
* 报表模块
*/
String APPLICATION_STATISTICSDATA_NAME = "logpm-statisticsdata" + DEVAUTH;
/**
* 数据共享模块
*/
@ -97,6 +102,26 @@ public interface ModuleNameConstant {
* 志邦工厂数据模块
*/
String LOGPM_FACTORY_DATA_ZBOM_NAME = "logpm-factory-data-zbom" + DEVAUTH;
/**
* 索菲亚工厂数据模块
*/
String LOGPM_FACTORY_DATA_SUOFEIYA_NAME = "logpm-factory-data-suofeiya" + DEVAUTH;
/**
* 我乐工厂数据模块
*/
String LOGPM_FACTORY_DATA_OLO_NAME = "logpm-factory-data-olo" + DEVAUTH;
/**
* 林氏工厂数据模块
*/
String LOGPM_FACTORY_DATA_LINSY_NAME = "logpm-factory-data-linsy" + DEVAUTH;
/**
* 曼好家工厂数据模块
*/
String LOGPM_FACTORY_DATA_MWH_NAME = "logpm-factory-data-mwh" + DEVAUTH;
/**
* 金牌工厂数据模块
*/
String LOGPM_FACTORY_DATA_JINPAI_NAME = "logpm-factory-data-jinpai" + DEVAUTH;
/**
* 诗尼曼工厂数据模块
*/
@ -110,4 +135,9 @@ public interface ModuleNameConstant {
*/
String LOGPM_FACTORY_DATA_OPPEIN_NAME = "logpm-factory-data-oppein" + DEVAUTH;
/**
* 商家模块
*/
String LOGPM_BUSINESS_NAME = "logpm-business" + DEVAUTH;
}

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

@ -76,14 +76,30 @@ public class OldSystemDataPushConfig {
// 宜宾仓
warehourseIds.add("146");
// 攀枝花
warehourseIds.add("32");
// 万州仓
warehourseIds.add("50");
//广元仓
warehourseIds.add("40");
//广元仓
warehourseIds.add("40");
//双流金牌基地仓
warehourseIds.add("55");
//茂名仓
warehourseIds.add("152");
}
public static List<String> getWarehourseIdList(){
public static List<String> getWarehourseIdList() {
return warehourseIds;
}
}

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

@ -33,15 +33,18 @@ public interface RabbitConstant {
/**
* 新系统推送信息
*/
String NEW_SYSTEM_RECEIVE_INFO_QUEUE = "new_system_receive_info_queue"+ ModuleNameConstant.DEVAUTH;
String NEW_SYSTEM_RECEIVE_INFO_EXCHANGE = "new_system_receive_info_exchange"+ ModuleNameConstant.DEVAUTH;
String NEW_SYSTEM_RECEIVE_INFO_ROUTING = "new_system_receive_info_routing"+ ModuleNameConstant.DEVAUTH;
String NEW_SYSTEM_RECEIVE_INFO_QUEUE = "new_system_receive_info_queue" + ModuleNameConstant.DEVAUTH;
String NEW_SYSTEM_RECEIVE_INFO_EXCHANGE = "new_system_receive_info_exchange" + ModuleNameConstant.DEVAUTH;
String NEW_SYSTEM_RECEIVE_INFO_ROUTING = "new_system_receive_info_routing" + ModuleNameConstant.DEVAUTH;
/**
* 卸车完成确认
*/
String UNLOAD_CAR_COM_INFO_QUEUE = "unload_car_com_info_quere";
String UNLOAD_CAR_COM_INFO_EXCHANGE = "unload_car_com_info_exchange" + ModuleNameConstant.DEVAUTH;
String UNLOAD_CAR_COM_INFO_ROUTING = "unload_car_com_info_routing ";
String HWY_UNLOAD_CAR_COM_INFO_QUEUE = "hwy_unload_car_com_info_quere";
String HWY_UNLOAD_CAR_COM_INFO_EXCHANGE = "hwy_unload_car_com_info_exchange" + ModuleNameConstant.DEVAUTH;
String HWY_UNLOAD_CAR_COM_INFO_ROUTING = "hwy_unload_car_com_info_routing ";
String WAYBILL_DATA_QUEUE = "waybill_data_queue" + ModuleNameConstant.DEVAUTH;
@ -105,6 +108,16 @@ public interface RabbitConstant {
/****************文员复合签收推送老系统队列 end *************************/
/****************文员自提复合签收推送老系统队列 start *************************/
String BILL_CLERK_CHECK_PUSH_DATA_QUEUE = "bill_clerk_check_push_data_queue" + ModuleNameConstant.DEVAUTH;
String BILL_CLERK_CHECK_PUSH_DATA_EXCHANGE = "bill_clerk_check_push_data_exchange" + ModuleNameConstant.DEVAUTH;
String BILL_CLERK_CHECK_PUSH_DATA_ROUTING = "bill_clerk_check_push_data_routing" + ModuleNameConstant.DEVAUTH;
/****************文员自提复合签收推送老系统队列 end *************************/
/****************包件状态变化 start*************************************************/
String ORDER_PACKAGE_STATUS_INFO_QUEUE = "order_package_status_info_queue" + ModuleNameConstant.DEVAUTH;
@ -123,8 +136,6 @@ public interface RabbitConstant {
/***************************************梦天签收扫描数据推送 end************************************************/
/****************************************梦天签收复核数据推送 start***********************************************/
String MT_BUSINESS_DATA_CLERK_CHECK_2_FACTORY_QUEUE = "mt_business_data_clerk_check_2_factory_queue" + ModuleNameConstant.DEVAUTH;
String MT_BUSINESS_DATA_CLERK_CHECK_2_FACTORY_EXCHANGE = "mt_business_data_clerk_check_2_factory_exchange" + ModuleNameConstant.DEVAUTH;
@ -160,4 +171,69 @@ public interface RabbitConstant {
String OPEN_ORDER_LOAD_SCAN_ROUTING = "open_order_load_scan_routing" + ModuleNameConstant.DEVAUTH;
/****************库内入库推送商家数据start *************************/
/****************库内入库推送商家数据end *************************/
/****************创建商家配送计划 start *************************/
String BUSINESS_PRE_CONVERSION_DATA_QUEUE = "business_pre_conversion_data_queue" + ModuleNameConstant.DEVAUTH;
String BUSINESS_PRE_CONVERSION_DATA_EXCHANGE = "business_pre_conversion_data_exchange" + ModuleNameConstant.DEVAUTH;
String BUSINESS_PRE_CONVERSION_DATA_ROUTING = "business_pre_conversion_data_routing" + ModuleNameConstant.DEVAUTH;
/****************创建商家配送计划end *************************/
//新系统订单状态消息队列配置
String HWY_ORDER_STATUS_QUEUE = "hwy_order_status_queue" + ModuleNameConstant.DEVAUTH;
String HWY_ORDER_STATUS_EXCHANGE = "hwy_order_status_exchange" + ModuleNameConstant.DEVAUTH;
String HWY_ORDER_STATUS_ROUTING = "hwy_order_status_routing" + ModuleNameConstant.DEVAUTH;
/****************商家入库完结 start *************************/
String BUSINESS_IN_CONVERSION_DATA_QUEUE = "business_in_conversion_data_queue" + ModuleNameConstant.DEVAUTH;
String BUSINESS_IN_CONVERSION_DATA_EXCHANGE = "business_in_conversion_data_exchange" + ModuleNameConstant.DEVAUTH;
String BUSINESS_IN_CONVERSION_DATA_ROUTING = "business_in_conversion_data_routing" + ModuleNameConstant.DEVAUTH;
/****************商家入库完结 end *************************/
/****************老系统推送打托数据 start *************************/
String OLD_TRAY_TYPE_QUEUE = "old_tray_type_queue" + ModuleNameConstant.DEVAUTH;
String OLD_TRAY_TYPE_EXCHANGE = "old_tray_type_exchange" + ModuleNameConstant.DEVAUTH;
String OLD_TRAY_TYPE_ROUTING = "old_tray_type_routing" + ModuleNameConstant.DEVAUTH;
/****************老系统推送打托数据 start *************************/
/****************自提扫描信息处理 start *************************/
String SELF_PICKUP_SCAN_QUEUE = "self_pickup_scan_queue" + ModuleNameConstant.DEVAUTH;
String SELF_PICKUP_SCAN_EXCHANGE = "self_pickup_scan_exchange" + ModuleNameConstant.DEVAUTH;
String SELF_PICKUP_SCAN_ROUTING = "self_pickup_scan_routing" + ModuleNameConstant.DEVAUTH;
/****************自提扫描信息处理 start *************************/
/****************推送安装平台 start *************************/
String PUSH_INSTALL_PLATFORM_QUEUE = "push_install_platform_queue" + ModuleNameConstant.DEVAUTH;
String PUSH_INSTALL_PLATFORM_EXCHANGE = "push_install_platform_exchange" + ModuleNameConstant.DEVAUTH;
String PUSH_INSTALL_PLATFORM_ROUTING = "push_install_platform_routing" + ModuleNameConstant.DEVAUTH;
/****************推送安装平台 start *************************/
}

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

@ -19,7 +19,16 @@ public class RedisKeyConstant {
public static final String TASK_QUEST_CHILD_KEY ="cache:task-quest-child-key:";
public static final String BASIC_DATA_WAREHOUSE_LIST_KEY ="cache:basic-data-warehouse-list:";
public static final String USER_NAME_PHONE_KEY ="cache:user:id:";
public static final String FINAL_CLIENT_CODE ="final:client:code:";
/**
* 商家端预入库车次数量缓存
*/
public static final String BUSINESS_IN_CARNUMBER ="business:in:carnumber:";
/**
* 异常件数
*/
public static final String BUSINESS_INEXCE_CARNUMBER ="business:inexce:carnumber:";
}

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

@ -0,0 +1,50 @@
package org.springblade.common.constant;
public enum WaybillStatusEnum {
BUFENRUKU("10", "部分入库"),
RUKU("20", "入库"),
BUFENZHONGZHUAN("30", "部分中转"),
ZHONGZHAUN("40", "中转"),
MUDICANGBUFENDAODA("50", "目的仓部分到达"),
MUDICANGDAODA("60", "目的仓到达"),
PEISOSNGBUFENZHUANGCHE("70", "配送部分装车"),
PEISONGZHUANGCHE("80", "配送装车"),
BUFENQIANSHOU("90", "部分签收"),
QIANSHOU("100", "已签收");
private String code;
private String value;
public String getCode() {
return code;
}
public void setCode(String code) {
this.code = code;
}
public String getValue() {
return value;
}
public void setValue(String value) {
this.value = value;
}
WaybillStatusEnum(String code, String value) {
this.code = code;
this.value = value;
}
public static String getValue(String code) {
for (WaybillStatusEnum value : WaybillStatusEnum.values()) {
if (value.getCode().equals(code)) {
return value.getValue();
}
}
return null;
}
}

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

@ -13,35 +13,70 @@ import java.io.Serializable;
@Getter
public enum WorkNodeEnums implements Serializable {
INITIAL_DATA_ENTRY(10, "数据入库"),
INITIAL_WAREHOUSE_ENTRY(20, "始发仓入库"),
BILLING(30, "开单"),
INITIAL_WAREHOUSE_LOADING(40, "装车"),
CANCEL_INITIAL_WAREHOUSE_LOADING(50, "取消装车"),
INITIAL_WAREHOUSE_DEPART(60, "始发仓发车"),
CANCEL_INITIAL_WAREHOUSE_DEPART(70, "始发仓取消发车"),
NET_ARRIVE_CAR(80,"网点到车"),
CANCEL_NET_ARRIVE_CAR(90,"网点取消到车"),
UNLOAD_INCOMING_WAREHOUSE(100,"卸车入库"),
TRANSFER_WAREHOUSE_UNLOADING(110, "卸车确认"),
TRANSFER_WAREHOUSE_DEPART(120, "网点发车"),
CANEL_TRANSFER_WAREHOUSE_DEPART(130, "网点取消发车"),
FINAL_NET_ARRIVE_CAR(140,"终点到车"),
CANCEL_FINAL_NET_ARRIVE_CAR(150,"终点取消到车"),
SIGN_DIRECT_SHIPPER(160,"直发商家签收"),
END_WAREHOUSE_UNLOADING(170, "末端仓卸车确认"),
TRIPARTITE_TRANSFER_DEPART(180, "三方中转发车"),
CANCEL_TRIPARTITE_TRANSFER_DEPART(190, "三方中转取消发车"),
ARRICE_TRIPARTITE_TRANSFER_DEPART(200, "三方中转到达"),
SIGN_TRIPARTITE_TRANSFER_DEPART(210, "三方中转签收"),
SORTING_TRAYS(220, "分拣打托"),
UN_SORTING_TRAYS(230, "包件解托"),
PUTAWAY(240, "上架"),
DELIST(250, "下架"),
STOCKING_OPERATION(260, "备货作业"),
DISTRIBUTION_LOADING(270, "配送装车"),
DISTRIBUTION_SIGN_FOR(280, "配送签收"),
CLERK_REVIEW(290, "文员复核");
INITIAL_DATA_ENTRY(101010, "数据入库"),
INITIAL_WAREHOUSE_ENTRY(101020, "始发仓入库"),
BILLING(102010, "开单"),
CHANGE_ORDER(102020, "改单"),
REVIEW_ORDER(102030, "审单"),
LOADING_PLAN(103010, "配载计划"),
CANCEL_LOADING_PLAN(103015, "取消配载计划"),
INITIAL_WAREHOUSE_LOADING(103020, "装车"),
CANCEL_INITIAL_WAREHOUSE_LOADING(103030, "取消装车"),
INITIAL_WAREHOUSE_DEPART(103040, "始发仓发车"),
CANCEL_INITIAL_WAREHOUSE_DEPART(103050, "始发仓取消发车"),
NET_ARRIVE_CAR(103060,"网点到车"),
CANCEL_NET_ARRIVE_CAR(103070,"网点取消到车"),
TRANSFER_WAREHOUSE_DEPART(103080, "网点发车"),
CANEL_TRANSFER_WAREHOUSE_DEPART(103090, "网点取消发车"),
FINAL_NET_ARRIVE_CAR(1030100,"终点到车"),
CANCEL_FINAL_NET_ARRIVE_CAR(1030110,"终点取消到车"),
TRIPARTITE_TRANSFER_DEPART(104010, "三方中转发车"),
CANCEL_TRIPARTITE_TRANSFER_DEPART(104020, "三方中转取消发车"),
ARRICE_TRIPARTITE_TRANSFER_DEPART(104030, "三方中转到达"),
SIGN_TRIPARTITE_TRANSFER_DEPART(104040, "三方中转签收"),
UNLOAD_INCOMING_WAREHOUSE(105010,"卸车入库"),
TRANSFER_WAREHOUSE_UNLOADING(105020, "卸车确认"),
SIGN_DIRECT_SHIPPER(105030,"直发商家签收"),
END_WAREHOUSE_UNLOADING(105040, "末端仓卸车确认"),
SORTING_TRAYS(201010, "分拣打托"),
UN_SORTING_TRAYS(201020, "包件解托"),
PUTAWAY(201030, "上架"),
DELIST(201040, "下架"),
STOCKING_OPERATION(201050, "备货作业"),
STOCKING_AREA_SHELVING(201060, "备货区上架"),
SPLIT_SHIPPING_ORDER(201070, "运单拆单"),
EMPTY_PALLET(201080, "托盘空置"),
STOCK_TRANSFER(201090, "转库存"),
CANCEL_STOCK_TRANSFER(201090, "取消转库存"),
PACKAGE_TRANSFER(2010100, "转包件"),
SPLIT_ORDER(2010110, "拆单"),
INVENTORY_STOCKING(2010120, "库存品入库"),
PLANNED_RESERVATION(301010, "计划预约"),
PLAN_DELIVERY(301020, "计划配送"),
CANCEL_DELIVERY(301030, "计划取消"),
PLAN_BILLOFLADING(301040, "计划自提"),
CANCEL_BILLOFLADING(301050, "取消自提"),
SIGN_BILLOFLADING(301050, "自提签收"),
PLAN_DISTRIBUTION(301060, "计划配车"),
CANCEL_DISTRIBUTION(301070, "取消配车"),
DISTRIBUTION_LOADING(302010, "配送装车"),
DISTRIBUTION_ABNORMAL_LOADING(302020, "异常装车"),
DISTRIBUTION_CANCEL_LOADING(302030, "取消装车"),
DISTRIBUTION_CAR_START(302040, "配送发车"),
DISTRIBUTION_CAR_ARRIVED(302050, "配送到达"),
DISTRIBUTION_SIGN_FOR(302060, "配送签收"),
DISTRIBUTION_RETENTION(302070, "配送滞留"),
DISTRIBUTION_ABNORMAL_SIGN_FOR(302080, "异常签收"),
DISTRIBUTION_FAIL(302090, "配送失败"),
CLERK_REVIEW(303010, "文员复核");
private Integer code;
private String value;
@ -51,4 +86,22 @@ public enum WorkNodeEnums implements Serializable {
this.value = value;
}
public static String getValue(Integer code) {
for (WorkNodeEnums value : WorkNodeEnums.values()) {
if (value.getCode().equals(code)) {
return value.getValue();
}
}
return null;
}
public static WorkNodeEnums getByCode(Integer code){
for (WorkNodeEnums value : WorkNodeEnums.values()) {
if (value.getCode().equals(code)) {
return value;
}
}
return null;
}
}

44
blade-biz-common/src/main/java/org/springblade/common/constant/basiccode/BasicCodeShowConstant.java

@ -0,0 +1,44 @@
package org.springblade.common.constant.basiccode;
import lombok.Data;
/**
* 租户编码姐
* 类型码表
*/
public enum BasicCodeShowConstant {
/**
* 二维码
*/
QR_CODE("qr_code",1),
/**
* 条形码
*/
BAR_CODE("bar_code",2);
/**
* 状态
*/
private String name;
/**
*
*/
private Integer value;
BasicCodeShowConstant(String name, Integer value) {
this.name = name;
this.value = value;
}
public String getName() {
return name;
}
public Integer getValue() {
return value;
}
}

68
blade-biz-common/src/main/java/org/springblade/common/constant/basiccode/BasicCodeTypeConstant.java

@ -0,0 +1,68 @@
package org.springblade.common.constant.basiccode;
/**
* 租户编码姐
* 类型码表
*/
public enum BasicCodeTypeConstant {
waybill_code("运单码","1"),
ORDER_CODE("订单码","2"),
ORDER_PACKAGE_CODE("包件码","3"),
// 仓库码
WAREHOUSE_CODE("仓库码","4"),
// 货区码
AREA_CODE("货区码","5"),
// 货架码
SHELF_CODE("货架码","6"),
// 货位码
POSITION_CODE("货位码","7"),
// 托盘码
TRAY_CODE("托盘码","8"),
// 客户编码
CLIENT_CODE("客户编码","9"),
// 提货单 配载计划 三方中转 直发商家签收单
// 提货单码
PICKUP_CODE("提货单码","10"),
// 配载计划码
ALLOCATION_CODE("配载计划码","11"),
// 三方中转码
THIRD_TRANSFER_CODE("三方中转码","12"),
// 直发商家签收单码
DIRECT_SIGN_CODE("直发商家签收单码","13"),
//配送计划 自提单 预约单 备货码
DELIVERY_PLAN_CODE("配送计划码","20"),
// 自提单码
PICKUP_ORDER_CODE("自提单码","21"),
// 预约单码
APPOINTMENT_CODE("预约单码","22"),
// 备货码
STOCK_CODE("备货码","23");
/**
* 状态
*/
private String name;
/**
*
*/
private String value;
BasicCodeTypeConstant(String name, String value) {
this.name = name;
this.value = value;
}
public String getName() {
return name;
}
public String getValue() {
return value;
}
}

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

@ -0,0 +1,177 @@
package org.springblade.common.constant.broadcast;
import org.springblade.common.constant.ModuleNameConstant;
/**
* 广播常量
*/
public abstract class FanoutConstants {
//干线
public interface trunkline {
//开单
interface OPENWAYBILL{
//交换机
String EXCHANGE = "fanout.trunkline.openWaybill" + ModuleNameConstant.DEVAUTH;
interface QUEUE {
String STATISTICSDATA_CREATEPACKAGEINFO = "fanout.trunkline.openWaybill.statisticsdata.createPackageinfo" + ModuleNameConstant.DEVAUTH;
// 开单检测数据 --商家端
String SEND_BUSINESS_DATA_BY_OPENWAYBILL_DATA = "fanout.trunkline.openWaybill.send_business_data.open" + ModuleNameConstant.DEVAUTH;
// 改单数据 --商家端
}
}
//改单
interface UPDATEWAYBILL{
//交换机
String EXCHANGE = "fanout.trunkline.updatewaybill" + ModuleNameConstant.DEVAUTH;
interface QUEUE {
String STATISTICSDATA_UPDATEPACKAGEINFO = "fanout.trunkline.updatewaybill.statisticsdata.updatePackageinfo" + ModuleNameConstant.DEVAUTH;
String SEND_BUSINESS_DATA_BY_UPDATEWAYBILL_DATA = "fanout.trunkline.openWaybill.send_business_data.update" + ModuleNameConstant.DEVAUTH;
}
}
//包件日志
interface PACKAGNODE{
//交换机
String EXCHANGE = "fanout.trunkline.packagenode" + ModuleNameConstant.DEVAUTH;
interface QUEUE {
String PACKAGE_SIGN = "fanout.trunkline.packagenode.statisticsdata.packagesign" + ModuleNameConstant.DEVAUTH;
String PACKAGE_INCOMING = "fanout.trunkline.packagenode.statisticsdata.packageincoming" + ModuleNameConstant.DEVAUTH;
}
}
}
//仓库
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;
//
// }
//
// }
}
/**
* 配送
*/
public interface distribution {
interface signfor{
String EXCHANGE = "fanout.distribution.signfor" + ModuleNameConstant.DEVAUTH;
interface QUEUE {
String FACTORY_NODE_WORK_DISTRIBUTION_SIGNFOR_QUERY = "fanout.factory.nodework.distribution.signforquery"+ ModuleNameConstant.DEVAUTH;
}
}
}
}

7
blade-biz-common/src/main/java/org/springblade/common/constant/carsload/CarsLoadLogTypeConstant.java

@ -21,7 +21,12 @@ public enum CarsLoadLogTypeConstant {
CANCEL_NET_START_CARS_LOAD("网点取消发车",12),
END_ARRIVE_CARS_LOAD("终点到达",13),
CANCEL_END_ARRIVE_CARS_LOAD("终点取消到达",14),
END_UNLOAD_CARS_LOAD("终点卸车",15);
END_UNLOAD_CARS_LOAD("终点卸车",15),
TRIPARTITE_TRANSFER_SIGN("三方中转签收",16),
TRIPARTITE_TRANSFER_SETTLEMENT("三方中转结算",17),
SEND_DIRECTLY_SIGN("直发商家签收",18),
SEND_DIRECTLY_SIGNPHOTO("直发商家签收图片",19),
TRIPARTITE_TRANSFER_SIGNPHOTO("三方中转签收图片",20);
/**
* 描述

96
blade-biz-common/src/main/java/org/springblade/common/constant/factorydata/FactoryDataConstants.java

@ -12,6 +12,11 @@ public abstract class FactoryDataConstants {
String DELAYED = "true";
/**
* 如果不需要 ""
*/
String DEVAUTH = "";
/**
* 定义交换机
*/
@ -20,16 +25,23 @@ public abstract class FactoryDataConstants {
/**
* 作业节点数据推送
*/
String NODE_DATA_PUSH = "factory.data.exchange.topic.nodeDataPush";
String NODE_DATA_PUSH_DELAYED = "factory.data.exchange.topic.nodeDataPushDelayed";
String NODE_DATA_PUSH = "factory.data.exchange.topic.nodeDataPush" + DEVAUTH;
/**
* 推送节点数据延时推送
*/
String NODE_DATA_PUSH_DELAYED = "factory.data.exchange.topic.nodeDataPushDelayed" + DEVAUTH;
/**
* 工厂订单数据
*/
String FACTORY_ORDER = "factory.data.exchange.topic.factoryOrder";
String FACTORY_ORDER = "factory.data.exchange.topic.factoryOrder" + DEVAUTH;
/**
* 工厂数据转暂存单
*/
String ADVANCE_ORDER = "factory.data.exchange.topic.advanceOrder";
String ADVANCE_ORDER = "factory.data.exchange.topic.advanceOrder" + DEVAUTH;
/**
* 工厂数据转暂存单-欧派
*/
String ADVANCE_ORDER_OUPAI = "factory.data.exchange.topic.advanceOrder.oupai" + DEVAUTH;
}
@ -42,25 +54,53 @@ public abstract class FactoryDataConstants {
/**
* 工厂数据转暂存单
*/
String ADVANCE_ORDER = "factory.data.queue.advanceOrder";
String ADVANCE_ORDER = "factory.data.queue.advanceOrder" + DEVAUTH;
/**
* 工厂数据转暂存单
*/
String ADVANCE_ORDER_OUPAI = "factory.data.queue.advanceOrder.oupai" + DEVAUTH;
/**
* 志邦作业节点数据推送
*/
String ZBOM_NODE_DATA_PUSH = "factory.data.queue.zbom.nodeDataPush";
String ZBOM_FACTORY_ORDER = "factory.data.queue.zbom.factoryOrder";
String ZBOM_NODE_DATA_PUSH = "factory.data.queue.zbom.nodeDataPush" + DEVAUTH;
String ZBOM_FACTORY_ORDER = "factory.data.queue.zbom.factoryOrder" + DEVAUTH;
/**
* 索菲亚工厂订单
*/
String SFY_NODE_DATA_PUSH = "factory.data.queue.sfy.nodeDataPush" + DEVAUTH;
String SFY_FACTORY_ORDER = "factory.data.queue.sfy.factoryOrder" + DEVAUTH;
/**
* 我乐工厂订单
*/
String OLO_NODE_DATA_PUSH = "factory.data.queue.olo.nodeDataPush" + DEVAUTH;
String OLO_FACTORY_ORDER = "factory.data.queue.olo.factoryOrder" + DEVAUTH;
/**
* 林氏工厂订单
*/
String LINSY_NODE_DATA_PUSH = "factory.data.queue.linsy.nodeDataPush" + DEVAUTH;
String LINSY_FACTORY_ORDER = "factory.data.queue.linsy.factoryOrder" + DEVAUTH;
/**
* 曼好家工厂订单
*/
String MWH_FACTORY_ORDER = "factory.data.queue.mwh.factoryOrder" + DEVAUTH;
/**
* 金牌工厂订单
*/
String JP_NODE_DATA_PUSH = "factory.data.queue.jp.nodeDataPush" + DEVAUTH;
String JP_FACTORY_ORDER = "factory.data.queue.jp.factoryOrder" + DEVAUTH;
/**
* 皮阿诺作业节点数据推送
*/
String PIANO_NODE_DATA_PUSH = "factory.data.queue.piano.nodeDataPush";
String PIANO_NODE_DATA_PUSH = "factory.data.queue.piano.nodeDataPush" + DEVAUTH;
/**
* 梦天作业节点数据推送
*/
String MENGTIAN_NODE_DATA_PUSH = "factory.data.queue.mengtian.nodeDataPush";
String MENGTIAN_NODE_DATA_PUSH = "factory.data.queue.mengtian.nodeDataPush" + DEVAUTH;
/**
* 欧派作业节点数据推送
*/
String OPPEIN_NODE_DATA_PUSH = "factory.data.queue.oppein.nodeDataPush";
String OPPEIN_NODE_DATA_PUSH = "factory.data.queue.oppein.nodeDataPush" + DEVAUTH;
}
/**
@ -70,24 +110,48 @@ public abstract class FactoryDataConstants {
/**
* 工厂数据转暂存单
*/
String ADVANCE_ORDER = "advanceOrder";
String ADVANCE_ORDER = "advanceOrder" + DEVAUTH;
/**
* 志邦作业节点数据推送
*/
String ZBOM_NODE_DATA_PUSH = "zbom.nodeDataPush";
String ZBOM_FACTORY_ORDER = "zbom.factoryOrder";
String ZBOM_NODE_DATA_PUSH = "zbom.nodeDataPush" + DEVAUTH;
String ZBOM_FACTORY_ORDER = "zbom.factoryOrder" + DEVAUTH;
/**
* 索菲亚工厂订单
*/
String SFY_NODE_DATA_PUSH = "sfy.nodeDataPush" + DEVAUTH;
String SFY_FACTORY_ORDER = "sfy.factoryOrder" + DEVAUTH;
/**
* 我乐工厂订单
*/
String OLO_NODE_DATA_PUSH = "olo.nodeDataPush" + DEVAUTH;
String OLO_FACTORY_ORDER = "olo.factoryOrder" + DEVAUTH;
/**
* 林氏工厂订单
*/
String LINSY_NODE_DATA_PUSH = "linsy.nodeDataPush" + DEVAUTH;
String LINSY_FACTORY_ORDER = "linsy.factoryOrder" + DEVAUTH;
/**
* 曼好家工厂订单
*/
String MWH_FACTORY_ORDER = "mwh.factoryOrder" + DEVAUTH;
/**
* 金牌工厂订单
*/
String JP_NODE_DATA_PUSH = "jp.nodeDataPush" + DEVAUTH;
String JP_FACTORY_ORDER = "jp.factoryOrder" + DEVAUTH;
/**
* 皮阿诺作业节点数据推送
*/
String PIANO_NODE_DATA_PUSH = "piano.nodeDataPush";
String PIANO_NODE_DATA_PUSH = "piano.nodeDataPush" + DEVAUTH;
/**
* 梦天作业节点数据推送
*/
String MENGTIAN_NODE_DATA_PUSH = "mengtian.nodeDataPush";
String MENGTIAN_NODE_DATA_PUSH = "mengtian.nodeDataPush" + DEVAUTH;
/**
* 欧派作业节点数据推送
*/
String OPPEIN_NODE_DATA_PUSH = "oppein.nodeDataPush";
String OPPEIN_NODE_DATA_PUSH = "oppein.nodeDataPush" + DEVAUTH;
}
}

46
blade-biz-common/src/main/java/org/springblade/common/constant/loading/LoadScanSigningTypeStatusConstant.java

@ -0,0 +1,46 @@
package org.springblade.common.constant.loading;
/**
* 订单冻结状态枚举
* 对应码表 freeze_status
* @author pref
*/
public enum LoadScanSigningTypeStatusConstant {
sijiqianshou("司机扫描签收",1),
sijipiliangqianshou("司机批量签收",2),
wenyuanpiliangqianshou("文员批量签收",3);
/**
* 状态
*/
private String name;
/**
*
*/
private Integer value;
private LoadScanSigningTypeStatusConstant(String name, Integer value) {
this.name = name;
this.value = value;
}
public String getName() {
return name;
}
public void setName(String name) {
this.name = name;
}
public Integer getValue() {
return value;
}
public void setValue(Integer value) {
this.value = value;
}
}

2
blade-biz-common/src/main/java/org/springblade/common/launch/LauncherServiceImpl.java

@ -40,6 +40,8 @@ public class LauncherServiceImpl implements LauncherService {
PropsUtil.setProperty(props, "spring.cloud.nacos.discovery.server-addr", LauncherConstant.nacosAddr(profile));
PropsUtil.setProperty(props, "spring.cloud.nacos.config.server-addr", LauncherConstant.nacosAddr(profile));
// 开启elk日志
PropsUtil.setProperty(props, "blade.log.elk.destination", LauncherConstant.elkAddr(profile));

60
blade-biz-common/src/main/java/org/springblade/common/model/BroadcastNodeData.java

@ -0,0 +1,60 @@
package org.springblade.common.model;
import com.alibaba.fastjson.JSONObject;
/**
* 节点作业数据传输对象
*/
public class BroadcastNodeData extends JSONObject {
/**
* 当前作业租户ID
*/
private String tenantId;
/**
* 作业人名称
*/
private String userName;
/**
* 操作时间
*/
private String operationTime;
public String getTenantId() {
return tenantId;
}
public void setTenantId(String tenantId) {
this.tenantId = tenantId;
}
public String getUserName() {
return userName;
}
public void setUserName(String userName) {
this.userName = userName;
}
public String getOperationTime() {
return operationTime;
}
public void setOperationTime(String operationTime) {
this.operationTime = operationTime;
}
@Override
public String toJSONString() {
// 需要 将当前类的属性增加的到json的输出
this.put("tenantId", tenantId);
this.put("userName", userName);
this.put("operationTime", operationTime);
return super.toJSONString();
}
}

14
blade-biz-common/src/main/java/org/springblade/common/model/FanoutMsg.java

@ -0,0 +1,14 @@
package org.springblade.common.model;
import lombok.Builder;
import lombok.Data;
import java.io.Serializable;
@Builder
@Data
public class FanoutMsg implements Serializable {
private String msg;
private String exchange;
}

28
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();

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

@ -1,11 +1,17 @@
package org.springblade.common.utils;
import cn.hutool.core.lang.UUID;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springblade.common.constant.CommonConstant;
import java.io.*;
import java.io.BufferedReader;
import java.io.File;
import java.io.FileWriter;
import java.io.IOException;
import java.io.InputStreamReader;
import java.io.Writer;
import java.net.HttpURLConnection;
import java.net.URL;
import java.util.Calendar;
@ -29,16 +35,17 @@ public class FileLogsUtil {
String imgPath = CommonConstant.SYSTEMFILEPATH + "logs/";
//根据当前时间 按照 年/月/日 创建一个文件
// 根据当前时间 按照 年/月/日 创建一个文件
imgPath = imgPath + dataString;
// 判断文件夹是否存在
// 判断文件夹是否存在
File imgPathFile = new File(imgPath);
if (!imgPathFile.exists()) {
imgPathFile.mkdirs();
}
// 按照年-月-日 创建一个字符串
String fileName = System.currentTimeMillis() + ".log";
// 使用 uuid 作为文件名 确保文件唯一
String fileName = UUID.randomUUID().toString() + ".log";
Writer writer = null;
try {
@ -67,7 +74,7 @@ public class FileLogsUtil {
public static String loadFileContent(String urlString) {
try {
log.info(">>>> 开始下载 {}",urlString);
log.info(">>>> 开始下载 {}", urlString);
URL url = new URL(urlString);
HttpURLConnection connection = (HttpURLConnection) url.openConnection();
connection.setRequestMethod("GET");
@ -78,7 +85,7 @@ public class FileLogsUtil {
content.append(inputLine);
}
in.close();
log.info(">>>> 结束下载 {}",urlString);
log.info(">>>> 结束下载 {}", urlString);
return content.toString();
} catch (Exception e) {
e.printStackTrace();
@ -90,12 +97,12 @@ public class FileLogsUtil {
StringBuilder stringBuffer = new StringBuilder();
Calendar calendar = Calendar.getInstance();
calendar.setTime(date); //放入Date类型数据
//获取年份
calendar.setTime(date); // 放入Date类型数据
// 获取年份
stringBuffer.append(calendar.get(Calendar.YEAR)).append("/");
//获取月份
// 获取月份
stringBuffer.append(calendar.get(Calendar.MONTH) + 1).append("/");
//获取日份
// 获取日份
stringBuffer.append(calendar.get(Calendar.DATE)).append("/");
return stringBuffer.toString();

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

@ -0,0 +1,30 @@
package org.springblade.common.utils;
import org.apache.logging.log4j.util.Strings;
import java.util.Arrays;
import java.util.List;
import java.util.Objects;
import java.util.stream.Collectors;
public class StringSplitUtil {
public static List<String> StringSplitToList(String string) {
List<String> strs = null;
if (!Objects.isNull(string)) {
String str = string;
if (Strings.isNotBlank(str)) {
if (str.indexOf(",") > 0) {
//存在中文逗号
str = str.replaceAll(",", ",");
}
strs = Arrays.stream(str.split(",")).collect(Collectors.toList());
}
}
return strs;
}
}

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

@ -37,31 +37,5 @@ public class TokenUtil {
return token;
}
// public static boolean verify(String token){
// /**
// * @desc 验证token,通过返回true
// * @params [token]需要校验的串
// **/
// try {
// Algorithm algorithm = Algorithm.HMAC256(TOKEN_SECRET);
// JWTVerifier verifier = JWT.require(algorithm).build();
// DecodedJWT jwt = verifier.verify(token);
// return true;
// }catch (Exception e){
// e.printStackTrace();
// return false;
// }
// }
public static void main(String[] args) throws NoSuchAlgorithmException {
// String username ="zhangsan";
// String password = "123";
// String token = token(username,password,"23123123");
// System.out.println(token);
// boolean b = verify("eyJhbGciOiJIUzI1NiIsInR5cCI6IkpXVCJ9.eyJwYXNzd22yZCI6IjEyMyIsImV4cCI6MTU3ODE5NzQxMywidXNlcm5hbWUiOiJ6aGFuZ3NhbiJ9.IyTZT0tISQQZhGhsNuaqHGV8LD7idjUYjn3MGbulmJg");
// System.out.println(b);
String s = MD5Utils.encodeHexString("123456".getBytes(StandardCharsets.UTF_8));
s = MD5Utils.md5Hex("123456".getBytes(StandardCharsets.UTF_8));
System.out.println(s);
}
}

36
blade-biz-common/src/main/java/org/springblade/common/wrapper/CustomHttpServletRequestWrapper.java

@ -0,0 +1,36 @@
package org.springblade.common.wrapper;
import org.springframework.http.HttpHeaders;
import javax.servlet.http.HttpServletRequest;
import javax.servlet.http.HttpServletRequestWrapper;
import java.util.*;
public class CustomHttpServletRequestWrapper extends HttpServletRequestWrapper {
private final HttpHeaders headers;
public CustomHttpServletRequestWrapper(HttpServletRequest request) {
super(request);
headers = new HttpHeaders();
}
@Override
public String getHeader(String name) {
String headerValue = headers.getFirst(name);
return headerValue != null ? headerValue : super.getHeader(name);
}
@Override
public Enumeration<String> getHeaderNames() {
List<String> names = Collections.list(super.getHeaderNames());
headers.forEach((key, value) -> names.add(key));
return Collections.enumeration(names);
}
// 其他需要覆盖的方法...
public void addHeader(String name, String value) {
headers.add(name, value);
}
}

3
blade-ops/blade-xxljob-admin/Dockerfile

@ -1,4 +1,5 @@
FROM bladex/alpine-java:openjdk8-openj9_cn_slim
FROM 192.168.2.110:7777/hwy/hwy_base:v1.0
MAINTAINER bladejava@qq.com

1
blade-ops/blade-xxljob-admin/src/main/java/com/xxl/job/admin/JobAdminApplication.java

@ -12,7 +12,6 @@ public class JobAdminApplication {
public static void main(String[] args) {
BladeApplication.run(LauncherConstant.APPLICATION_XXLJOB_ADMIN_NAME, JobAdminApplication.class, args);
}

4
blade-service-api/logpm-aftersales-api/src/main/java/com/logpm/aftersales/entity/AftersaleSurveyRecordEntity.java

@ -127,5 +127,9 @@ public class AftersaleSurveyRecordEntity extends TenantEntity {
* 处理方ID
*/
private Long processorId;
/**
* 处理方名称
*/
private String processorName;
}

14
blade-service-api/logpm-aftersales-api/src/main/java/com/logpm/aftersales/entity/AftersalesAbnormalPackageEntity.java

@ -127,6 +127,18 @@ public class AftersalesAbnormalPackageEntity extends TenantEntity {
*/
@ApiModelProperty(value = "物料编码(库存品)")
private String cargoNumber;
/**
* 一级品
*/
@ApiModelProperty(value = "一级品")
private String first;
/**
* 二级品
*/
@ApiModelProperty(value = "二级品")
private String secondary;
/**
* 入库批次号库存品)
*/
@ -143,4 +155,6 @@ public class AftersalesAbnormalPackageEntity extends TenantEntity {
@ApiModelProperty(value = "关联工单ID")
private Long relatedWorkOrdersId;
private Integer packageFinish;
}

8
blade-service-api/logpm-aftersales-api/src/main/java/com/logpm/aftersales/entity/AftersalesAbnormalRecordEntity.java

@ -42,10 +42,10 @@ public class AftersalesAbnormalRecordEntity extends TenantEntity {
private String carType;
@ApiModelProperty(name = "上报仓库id",notes = "")
private Long upWarehouseId;
private Long warehouseId;
@ApiModelProperty(name = "上报仓库名称",notes = "")
private String upWarehouseName;
private String warehouseName;
@ApiModelProperty(name = "车次号",notes = "")
private String carsNo;
@ -70,6 +70,9 @@ public class AftersalesAbnormalRecordEntity extends TenantEntity {
@ApiModelProperty(name = "异常状态 0待处理 1完结",notes = "")
private Integer abnormalStatus;
@ApiModelProperty(name = "发起工单状态 0未发起 1已发起",notes = "")
private Integer sendOrderStatus;
@ApiModelProperty(name = "上报时间",notes = "")
private Date upTime;
@ -94,4 +97,5 @@ public class AftersalesAbnormalRecordEntity extends TenantEntity {
private Integer associationType;
}

5
blade-service-api/logpm-aftersales-api/src/main/java/com/logpm/aftersales/entity/AftersalesWorkOrderEntity.java

@ -293,6 +293,11 @@ public class AftersalesWorkOrderEntity extends TenantEntity {
* 离职状态
*/
private boolean departStatus;
private Integer packageFinish;
/**
* 金额总和
*/

13
blade-service-api/logpm-aftersales-api/src/main/java/com/logpm/aftersales/feign/IAftersalesAbnormalRecordClient.java

@ -16,14 +16,17 @@
*/
package com.logpm.aftersales.feign;
import com.alibaba.fastjson.JSONObject;
import com.logpm.aftersales.entity.AftersalesAbnormalRecordEntity;
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.PostMapping;
import org.springframework.web.bind.annotation.RequestBody;
import org.springframework.web.bind.annotation.RequestParam;
import java.util.List;
import java.util.Map;
/**
* 货位 Feign接口类
@ -43,7 +46,15 @@ public interface IAftersalesAbnormalRecordClient {
void addAbnormalRecord(@RequestBody AftersalesAbnormalRecordEntity warehouseAbnormalRecordEntity);
@GetMapping(API_PREFIX+"/findAbnormalList")
List<AftersalesAbnormalRecordEntity> findAbnormalList(String carsNo);
List<AftersalesAbnormalRecordEntity> findAbnormalList(@RequestParam("carsNo") String carsNo);
@GetMapping(API_PREFIX+"/findListByCarsNoAndUpWarehouseId")
JSONObject findListByCarsNoAndUpWarehouseId(@RequestParam("carsNo") String carsNo, @RequestParam("warehouseId") Long warehouseId);
@GetMapping(API_PREFIX+"/findOrderPackageAndAbnormalStatus")
List<AftersalesAbnormalRecordEntity> findOrderPackageAndAbnormalStatus(@RequestParam("orderPackageCode") String orderPackageCode, @RequestParam("abnormalStatus") String abnormalStatus);
@PostMapping(API_PREFIX+"/updateList")
void updateList(@RequestBody List<AftersalesAbnormalRecordEntity> abnormalRecordEntities);
}

10
blade-service-api/logpm-aftersales-api/src/main/java/com/logpm/aftersales/feign/IAftersalesWorkOrderClient.java

@ -36,6 +36,7 @@ public interface IAftersalesWorkOrderClient {
String API_PREFIX = "/work/client";
String TOP = API_PREFIX + "/top";
String UPDATEWORKORDERSTATUS = API_PREFIX + "/updateWorkOrderStatus";
/**
* 获取客服异常工单列表
@ -47,4 +48,13 @@ public interface IAftersalesWorkOrderClient {
@GetMapping(TOP)
BladePage<AftersalesWorkOrderEntity> top(@RequestParam("current") Integer current, @RequestParam("size") Integer size);
/**
* 修改异常工单上的数据
* @param orderPackageCode 包件码
* @param packageFinish 目前默认传 1
* @return
*/
@GetMapping(UPDATEWORKORDERSTATUS)
Boolean updateWorkOrderStatus(@RequestParam("warehouseId") Long warehouseId,@RequestParam("orderPackageCode") String orderPackageCode, @RequestParam("packageFinish") Integer packageFinish);
}

1
blade-service-api/logpm-aftersales-api/src/main/java/com/logpm/aftersales/vo/AftersalesDeliverVO.java

@ -11,4 +11,5 @@ public class AftersalesDeliverVO {
private Date taskTime; //配送时间
private String driverName; //配送司机
private String vehicleName; //车牌
private Long id; //车次ID
}

2
blade-service-api/logpm-aftersales-api/src/main/java/com/logpm/aftersales/vo/AftersalesProcessorVO.java

@ -32,4 +32,6 @@ import lombok.EqualsAndHashCode;
public class AftersalesProcessorVO extends AftersalesProcessorEntity {
private static final long serialVersionUID = 1L;
}

7
blade-service-api/logpm-aftersales-api/src/main/java/com/logpm/aftersales/vo/AftersalesWorkOrderVO.java

@ -32,7 +32,6 @@ import java.util.List;
@Data
@EqualsAndHashCode(callSuper = true)
public class AftersalesWorkOrderVO extends AftersalesWorkOrderEntity {
private static final long serialVersionUID = 1L;
/**
* 工单名称
*/
@ -101,4 +100,10 @@ public class AftersalesWorkOrderVO extends AftersalesWorkOrderEntity {
private String ids;
private String typeServiceName;
/**
* 是否能申述
* 0 不能 1 可以申述
*/
private Integer canRepresentations;
}

15
blade-service-api/logpm-basic-api/src/main/java/com/logpm/basic/entity/BasicTenantCodeEntity.java

@ -39,13 +39,7 @@ import java.io.Serializable;
public class BasicTenantCodeEntity extends TenantEntity implements Serializable{
private static final long serialVersionUID = 1L;
// /**
// * 主键
// */
// @JsonSerialize(using = ToStringSerializer.class)
// @ApiModelProperty(value = "主键")
// @TableId(value = "id", type = IdType.ASSIGN_ID)
// private Long id;
/**
* 编码类型
@ -53,7 +47,7 @@ public class BasicTenantCodeEntity extends TenantEntity implements Serializable
@JsonSerialize(using = ToStringSerializer.class)
@ApiModelProperty(value = "编码类型")
@TableField(value = "code_type")
private Integer codeType;
private String codeType;
/**
* 编码展示类型
@ -63,7 +57,6 @@ public class BasicTenantCodeEntity extends TenantEntity implements Serializable
@TableField(value = "show_type")
private Integer showType;
// private Integer isDeleted;
/***
* 编码
@ -72,6 +65,10 @@ public class BasicTenantCodeEntity extends TenantEntity implements Serializable
@ApiModelProperty(value = "编码")
private String code;
@JsonSerialize(using = ToStringSerializer.class)
@ApiModelProperty(value = "简称")
private String desName;
@ApiModelProperty(value = "预留1")
private String reserve1;
/**

4
blade-service-api/logpm-basic-api/src/main/java/com/logpm/basic/feign/IBasicTenantCodeClient.java

@ -64,5 +64,9 @@ public interface IBasicTenantCodeClient {
*/
@GetMapping(TOP+"/shelfCode")
String shelfCode(@RequestParam String tenantId,@RequestParam String codeType);
@GetMapping(TOP+"/findBasicTenantCodeByCodeAndShowType")
BasicTenantCodeEntity findBasicTenantCodeByCodeAndShowType(@RequestParam("codeType") String codeType,@RequestParam("showType")Integer showType);
}

28
blade-service-api/logpm-basic-api/src/main/java/com/logpm/basic/vo/TableSetVo.java

@ -0,0 +1,28 @@
package com.logpm.basic.vo;
import io.swagger.annotations.ApiModel;
import io.swagger.annotations.ApiModelProperty;
import lombok.Data;
import java.io.Serializable;
/**
* 前端页面 表格字段保存对象
*/
@Data
@ApiModel(value = "TableSetVo", description = "表格设置对象")
public class TableSetVo implements Serializable {
/**
* 表格key
*/
@ApiModelProperty(value = "表格key")
private String tableKey;
/**
* 表格表头设置内容
*/
@ApiModelProperty(value = "表格设置内容")
private String tableSetCongig;
}

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

@ -138,7 +138,6 @@ public class BasicdataClientEntity extends TenantEntity {
* 客户类型;1 C端 2 B端
*/
@ApiModelProperty(value = "客户类型;1 C端 2 B端")
@TableField(exist = false)
private Integer typeService;
/**
@ -206,13 +205,13 @@ public class BasicdataClientEntity extends TenantEntity {
* 合同开始时间
*/
@ApiModelProperty(value = "合同开始时间")
@JsonFormat(shape = JsonFormat.Shape.STRING, pattern="yyyy-MM-dd HH:mm:ss", timezone = "GMT+8")
@JsonFormat(shape = JsonFormat.Shape.STRING, pattern="yyyy-MM-dd", timezone = "GMT+8")
private Date contractStartTime;
/**
* 合同结束时间
*/
@ApiModelProperty(value = "合同结束时间")
@JsonFormat(shape = JsonFormat.Shape.STRING, pattern="yyyy-MM-dd HH:mm:ss", timezone = "GMT+8")
@JsonFormat(shape = JsonFormat.Shape.STRING, pattern="yyyy-MM-dd", timezone = "GMT+8")
private Date contractEntTime;
@ApiModelProperty(value = "默认付款方式 1现付 2到付 3月结 4回付 5内部结算 ")

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

@ -58,8 +58,13 @@ public class BasicdataFactoryCategoryEntity extends TenantEntity {
@ApiModelProperty(value = "品牌名称")
private String brand;
@ApiModelProperty(value = "物料名称")
private String materielName;
@ApiModelProperty(value = "品牌id")
private Long brandId;
}

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

@ -60,8 +60,10 @@ public class BasicdataPriceCategoryWarehouseEntity extends TenantEntity {
private Double withinThirtyPrice;
@ApiModelProperty(value = "30-60天")
private Double betweenThirtySixtyPrice;
@ApiModelProperty(value = "60天外")
@ApiModelProperty(value = "60-90天外")
private Double beyondSixtyPrice;
@ApiModelProperty(value = "90天外")
private Double beyondNinetyPrice;
@ApiModelProperty(value = "上限价格")
private Double maximumPrice;
@ApiModelProperty(value = "操作/装卸费")

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

@ -104,6 +104,8 @@ public class BasicdataPriceTemplateEntity extends TenantEntity {
private String warehousePieceCategory;
@ApiModelProperty(value = "仓储-附加费计价单位")
private Integer warehouseSubjoinFeeUnit;
@ApiModelProperty(value = "仓储-是否附加费")
private Integer warehouseIsAddFee;
@ApiModelProperty(value = "仓储-是否有管理费")
private Integer warehouseIsManageFee;
@ApiModelProperty(value = "仓储-是否有操作/装卸费")
@ -130,6 +132,8 @@ public class BasicdataPriceTemplateEntity extends TenantEntity {
private String dispatchWeightCategory;
@ApiModelProperty(value = "配送-是否按品类附加费计费")
private Integer dispatchIsCategorySubjoin;
@ApiModelProperty(value = "配送-是否附加费")
private Integer dispatchIsAddFee;
@ApiModelProperty(value = "配送-是否有分货费")
private Integer dispatchIsSortFee;
@ApiModelProperty(value = "配送-是否有操作/装卸费")

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

@ -19,6 +19,7 @@ package com.logpm.basicdata.feign;
import com.alibaba.fastjson.JSONObject;
import com.logpm.basicdata.entity.BasicdataClientEntity;
import com.logpm.basicdata.entity.BasicdataClientUserEntity;
import com.logpm.basicdata.vo.BasicdataClientVO;
import org.springblade.common.constant.ModuleNameConstant;
import org.springblade.core.mp.support.BladePage;
import org.springframework.cloud.openfeign.FeignClient;
@ -73,7 +74,10 @@ public interface IBasicdataClientClient {
List<BasicdataClientUserEntity> getBasicdataClientUserEntityListByUserId(@RequestParam("userId") Long userId);
@GetMapping(API_PREFIX+"/findEntityById")
BasicdataClientEntity findEntityById(@RequestParam Long clientId);
BasicdataClientEntity findEntityById(@RequestParam Long clientId);
@GetMapping(API_PREFIX+"/findEntityVoById")
BasicdataClientVO findEntityVoById(@RequestParam Long clientId);
@PostMapping(API_PREFIX+"/addReturnId")
Long addReturnId(@RequestBody BasicdataClientEntity basicdataClientEntity);
@ -88,4 +92,20 @@ public interface IBasicdataClientClient {
*/
@GetMapping(API_PREFIX+"/getMallById")
BasicdataClientEntity getMallById(Long mallId);
/**
* 根据名称查询客户
* @param consigneeUnit
* @return
*/
@GetMapping(API_PREFIX+"/getClientByName")
List<BasicdataClientEntity> getClientByName(String consigneeUnit);
/**
* 查询多个ID客户信息
* @param clientIds
* @return
*/
@GetMapping(API_PREFIX+"/findEntityByIds")
List<BasicdataClientEntity> findEntityByIds(@RequestParam List<Long> clientIds);
}

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

@ -5,6 +5,8 @@ import org.springframework.cloud.openfeign.FeignClient;
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.RequestParam;
import java.util.List;
@FeignClient(
value = ModuleNameConstant.APPLICATION_BASICDATA_NAME
)
@ -15,4 +17,8 @@ public interface IBasicdataCodeClient {
@GetMapping(API_PREFIX+"/getCodeByType")
String getCodeByType(@RequestParam Integer type,@RequestParam String warehouseCode,@RequestParam String orderCode);
@GetMapping(API_PREFIX+"/getBatchPackageCodeByType")
List<String> getBatchPackageCodeByType(@RequestParam String warehouseCode, @RequestParam String orderCode,@RequestParam Integer num);
}

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

@ -60,4 +60,7 @@ public interface IBasicdataDriverArteryClient {
@GetMapping(API_PREFIX+"/findDriverListByName")
List<JSONObject> findDriverListByName(@RequestParam String driverName);
@GetMapping(API_PREFIX+"/getDriverArteryById")
BasicdataDriverArteryEntity getDriverArteryById(Long id);
}

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

@ -4,6 +4,8 @@ import com.logpm.basicdata.entity.BasicdataFactoryCategoryEntity;
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.PostMapping;
import org.springframework.web.bind.annotation.RequestBody;
import org.springframework.web.bind.annotation.RequestParam;
@FeignClient(
@ -17,4 +19,28 @@ public interface IBasicdataFactoryCategoryClient {
@GetMapping(API_PREFIX+"/findEntityByAdvanceDetailIds")
BasicdataFactoryCategoryEntity findEntityByAdvanceDetailIds(@RequestParam("current") Integer current, @RequestParam("size") Integer size);
/**
* 查询结算订制品结算品类
* entity
* @return
*/
@PostMapping(API_PREFIX+"/findEntityByThreeCategory")
BasicdataFactoryCategoryEntity findEntityByThreeCategory(@RequestBody BasicdataFactoryCategoryEntity entity);
/**
* 查询库存品结算品类
* @param entity2
* @return
*/
@PostMapping(API_PREFIX+"/findEntityByMaterielName")
BasicdataFactoryCategoryEntity findEntityByMaterielName(@RequestBody BasicdataFactoryCategoryEntity entity2);
/**
*
* @param entity3
* @return
*/
@PostMapping(API_PREFIX+"/findEntityByCategoryName")
BasicdataFactoryCategoryEntity findEntityByCategoryName(@RequestBody BasicdataFactoryCategoryEntity entity3);
}

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

@ -72,4 +72,7 @@ public interface IBasicdataGoodsAllocationClient {
@GetMapping(API_PREFIX+"/findStockUpAllocationById")
BasicdataGoodsAllocationEntity findStockUpAllocationById(@RequestParam Long warehouseId,@RequestParam Long stockUpAllocationId);
@PostMapping(API_PREFIX+"/updateListAllocationStatus")
void updateListAllocationStatus(@RequestParam List<Long> updateAllocationIds, @RequestParam String allocationStatus);
}

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

@ -18,11 +18,14 @@ package com.logpm.basicdata.feign;
import com.logpm.basicdata.vo.BasicdatPriceApiVO;
import com.logpm.basicdata.vo.PriceClientVO;
import com.logpm.basicdata.vo.PriceDispatchAddClientVO;
import org.springblade.common.constant.ModuleNameConstant;
import org.springframework.cloud.openfeign.FeignClient;
import org.springframework.web.bind.annotation.PostMapping;
import org.springframework.web.bind.annotation.RequestBody;
import java.util.List;
/**
* 基础价格体系 Feign接口类
*
@ -36,8 +39,12 @@ public interface IBasicdataPriceClient {
String API_PREFIX = "/basicdataPrice/client";
String PRICE = API_PREFIX + "/pirce";
String DISPATCH_ADD_PRICE = API_PREFIX + "/dispatchAddPrice";
@PostMapping(PRICE)
PriceClientVO pirce(@RequestBody BasicdatPriceApiVO param);
PriceClientVO price(@RequestBody BasicdatPriceApiVO param);
@PostMapping(DISPATCH_ADD_PRICE)
List<PriceDispatchAddClientVO> dispatchAddPrice(@RequestBody BasicdatPriceApiVO param);
}

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

@ -71,4 +71,15 @@ public interface IBasicdataTrayClient {
@GetMapping(API_PREFIX+"/getTrayByTrayNo")
BasicdataTrayEntity getTrayByTrayNo(@RequestParam String trayNo);
/**
* 查询托盘
* @param positions
* @return
*/
@GetMapping(API_PREFIX+"/findByTrayName")
BasicdataTrayEntity findByTrayName(@RequestParam String positions);
@PostMapping(API_PREFIX+"/updateTrayStatusByTrayIds")
void updateTrayStatusByTrayIds(@RequestParam List<Long> trayIds, @RequestParam int trayStatus);
}

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

@ -51,5 +51,9 @@ public interface IBasicdataTripartiteMallClient {
@GetMapping(GETNAMEBRAND)
Long getClientIdByNameAndBrand(@RequestParam String name, @RequestParam String brand);
@GetMapping(API_PREFIX+"/getClientIdByNameAndBrandAndCode")
Long getClientIdByNameAndBrandAndCode(@RequestParam String name, @RequestParam String code,@RequestParam String brand);
@GetMapping(API_PREFIX+"/findEntityByDealerNameAndDealerCodeAndBrand")
BasicdataTripartiteMallEntity findEntityByDealerNameAndDealerCodeAndBrand(@RequestParam String dealerName, @RequestParam String dealerCode, @RequestParam String brand);
}

39
blade-service-api/logpm-basicdata-api/src/main/java/com/logpm/basicdata/vo/BasicdatPriceApiVO.java

@ -16,11 +16,11 @@
*/
package com.logpm.basicdata.vo;
import com.logpm.basicdata.enums.PriceBizTypeApiEnums;
import io.swagger.annotations.ApiModelProperty;
import lombok.Builder;
import lombok.Data;
import javax.validation.constraints.NotEmpty;
import javax.validation.constraints.NotNull;
import java.io.Serializable;
/**
@ -29,31 +29,32 @@ import java.io.Serializable;
* @author cyz
* @since 2023-06-08
*/
@Builder
@Data
public class BasicdatPriceApiVO implements Serializable {
private static final long serialVersionUID = 1L;
/**
* 客户id
*/
@NotEmpty(message = "客户id不能为空")
@ApiModelProperty(value = "客户id")
private String clientId;
/**
* 品牌id
*/
@NotEmpty(message = "品牌id不能为空")
@ApiModelProperty(value = "品牌id")
private String brandId;
/**
* 发货单位id
*/
@ApiModelProperty(value = "日期")
private String time;
@ApiModelProperty(value = "发货单位id")
private String sendOrgId;
/**
* 始发地
*/
private String startAreaId;
/**
* 目的地
*/
private String endAreaId;
@ApiModelProperty(value = "始发地省份id")
private Long startProvinceId;
@ApiModelProperty(value = "始发地城市id")
private Long startCityId;
@ApiModelProperty(value = "始发地区县id")
private Long startCountyId;
@ApiModelProperty(value = "目的地省份id")
private Long endProvinceId;
@ApiModelProperty(value = "目的地城市id")
private Long endCityId;
@ApiModelProperty(value = "目的地区县id")
private Long endCountyId;
}

2
blade-service-api/logpm-basicdata-api/src/main/java/com/logpm/basicdata/vo/BasicdataDriverArteryVO.java

@ -42,6 +42,8 @@ public class BasicdataDriverArteryVO extends BasicdataDriverArteryEntity {
@ApiModelProperty(value = "车辆信息")
private String bindVehicles;
private String carNumbers;
/**
* 司机关联车辆列表
*/

5
blade-service-api/logpm-basicdata-api/src/main/java/com/logpm/basicdata/vo/BasicdataPriceBasicUpdateVO.java

@ -33,12 +33,15 @@ import java.util.Date;
public class BasicdataPriceBasicUpdateVO implements Serializable {
private static final long serialVersionUID = 1L;
@NotNull(message = "修改数据id不能为空")
@ApiModelProperty(value = "id")
private Long id;
@NotNull(message = "模板不能为空")
@ApiModelProperty(value = "模板id")
private Long templateId;
@ApiModelProperty(value = "客户id")
private Long clientId;
@ApiModelProperty(value = "品牌id")
private Long brandId;
@NotNull(message = "生效时间不能为空")
@ApiModelProperty(value = "生效时间")
private Date effectiveTime;

47
blade-service-api/logpm-basicdata-api/src/main/java/com/logpm/basicdata/vo/BasicdataPriceImportVO.java

@ -0,0 +1,47 @@
/*
* Copyright (c) 2018-2028, Chill Zhuang All rights reserved.
*
* Redistribution and use in source and binary forms, with or without
* modification, are permitted provided that the following conditions are met:
*
* Redistributions of source code must retain the above copyright notice,
* this list of conditions and the following disclaimer.
* Redistributions in binary form must reproduce the above copyright
* notice, this list of conditions and the following disclaimer in the
* documentation and/or other materials provided with the distribution.
* Neither the name of the dreamlu.net developer nor the names of its
* contributors may be used to endorse or promote products derived from
* this software without specific prior written permission.
* Author: Chill 庄骞 (smallchill@163.com)
*/
package com.logpm.basicdata.vo;
import com.baomidou.mybatisplus.annotation.TableName;
import com.logpm.basicdata.entity.BasicdataPriceEntity;
import io.swagger.annotations.ApiModel;
import io.swagger.annotations.ApiModelProperty;
import lombok.Data;
import lombok.EqualsAndHashCode;
import org.springblade.core.tenant.mp.TenantEntity;
import java.util.Date;
/**
* 基础价格表 实体类
*
* @author zqb
* @since 2024-04-02
*/
@Data
@ApiModel(value = "BasicdataPrice对象", description = "基础价格表")
@EqualsAndHashCode(callSuper = true)
public class BasicdataPriceImportVO extends BasicdataPriceEntity {
@ApiModelProperty(value = "客户名称")
private String clientName;
@ApiModelProperty(value = "客户编码")
private String clientCode;
@ApiModelProperty(value = "品牌名称")
private String brandName;
}

6
blade-service-api/logpm-basicdata-api/src/main/java/com/logpm/basicdata/vo/BasicdataPricePageVO.java

@ -45,6 +45,9 @@ public class BasicdataPricePageVO implements Serializable {
@ApiModelProperty(value = "品牌id")
private String brandId;
@ApiModelProperty(value = "客户id")
private String clientId;
@ApiModelProperty(value = "价格模板id")
private String templateId;
@ -54,6 +57,9 @@ public class BasicdataPricePageVO implements Serializable {
@ApiModelProperty(value = "维护状态")
private String maintenanceStatus;
@ApiModelProperty(value = "生效状态")
private String effectiveStatus;
@ApiModelProperty(value = "修改时间")
private String updateTime;

3
blade-service-api/logpm-basicdata-api/src/main/java/com/logpm/basicdata/vo/BasicdataTrayVO.java

@ -49,4 +49,7 @@ public class BasicdataTrayVO extends BasicdataTrayEntity {
@ApiModelProperty(value = "打托方式显示")
private String trayTypeString;
@ApiModelProperty(value = "串货条件")
private String filterValue;
}

5
blade-service-api/logpm-basicdata-api/src/main/java/com/logpm/basicdata/vo/ClientInfoVO.java

@ -9,8 +9,13 @@ public class ClientInfoVO implements Serializable {
private Long clientId;
private String clientName;
private String provinceId;
private String cityId;
private String areaId;
private String linkMan;
private String linkPhone;
private String linkAddress;
private Integer defaultPayWay;
private Long brandId;
}

50
blade-service-api/logpm-basicdata-api/src/main/java/com/logpm/basicdata/vo/PriceDispatchAddClientVO.java

@ -0,0 +1,50 @@
/*
* Copyright (c) 2018-2028, Chill Zhuang All rights reserved.
*
* Redistribution and use in source and binary forms, with or without
* modification, are permitted provided that the following conditions are met:
*
* Redistributions of source code must retain the above copyright notice,
* this list of conditions and the following disclaimer.
* Redistributions in binary form must reproduce the above copyright
* notice, this list of conditions and the following disclaimer in the
* documentation and/or other materials provided with the distribution.
* Neither the name of the dreamlu.net developer nor the names of its
* contributors may be used to endorse or promote products derived from
* this software without specific prior written permission.
* Author: Chill 庄骞 (smallchill@163.com)
*/
package com.logpm.basicdata.vo;
import io.swagger.annotations.ApiModelProperty;
import lombok.Builder;
import lombok.Data;
import java.io.Serializable;
/**
* 基础价格按品类计费 视图实体类
*
* @author zqb
* @since 2024-04-02
*/
@Builder
@Data
public class PriceDispatchAddClientVO implements Serializable {
private static final long serialVersionUID = 1L;
@ApiModelProperty(value = "品类id")
private Long categoryId;
@ApiModelProperty(value = "分货费")
private Double sortPrice;
@ApiModelProperty(value = "装卸费")
private Double handlingPrice;
@ApiModelProperty(value = "平移费")
private Double relocationPrice;
@ApiModelProperty(value = "上楼费")
private Double upstairsDeliveryPrice;
@ApiModelProperty(value = "配送-上楼费免费楼层")
private Integer dispatchStairsCarryingCharge;
}

4
blade-service-api/logpm-basicdata-api/src/main/java/com/logpm/basicdata/vo/PriceWarehouseBasicVO.java

@ -38,8 +38,10 @@ public class PriceWarehouseBasicVO implements Serializable {
private Double withinThirtyPrice;
@ApiModelProperty(value = "30-60天")
private Double betweenThirtySixtyPrice;
@ApiModelProperty(value = "60天")
@ApiModelProperty(value = "60-90天")
private Double beyondSixtyPrice;
@ApiModelProperty(value = "90天外")
private Double beyondNinetyPrice;
@ApiModelProperty(value = "上限价格")
private Double maximumPrice;

18
blade-service-api/logpm-business-api/pom.xml

@ -0,0 +1,18 @@
<?xml version="1.0" encoding="UTF-8"?>
<project xmlns="http://maven.apache.org/POM/4.0.0"
xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
<modelVersion>4.0.0</modelVersion>
<parent>
<groupId>org.springblade</groupId>
<artifactId>blade-service-api</artifactId>
<version>3.2.0.RELEASE</version>
</parent>
<groupId>org.springblade</groupId>
<artifactId>logpm-business-api</artifactId>
<version>3.2.0.RELEASE</version>
</project>

12
blade-service-api/logpm-business-api/src/main/java/com/logpm/business/dto/BusinessPreListDTO.java

@ -0,0 +1,12 @@
package com.logpm.business.dto;
import lombok.Data;
@Data
public class BusinessPreListDTO {
private String reservationCode;
private Integer inWarehouse;
}

12
blade-service-api/logpm-business-api/src/main/java/com/logpm/business/dto/BusinessPreOrderDTO.java

@ -0,0 +1,12 @@
package com.logpm.business.dto;
import com.logpm.business.entity.BusinessPreOrderEntity;
/**
*
*/
public class BusinessPreOrderDTO extends BusinessPreOrderEntity {
}

33
blade-service-api/logpm-business-api/src/main/java/com/logpm/business/dto/BusinessSanDTO.java

@ -0,0 +1,33 @@
package com.logpm.business.dto;
import io.swagger.annotations.ApiModelProperty;
import lombok.Data;
import org.springframework.web.bind.annotation.RequestParam;
@Data
public class BusinessSanDTO {
@ApiModelProperty(value = "配送车次")
private String distrCarNumber;
@ApiModelProperty(value = "包间码")
String orderPackageCode;
@ApiModelProperty(value = "预约单号")
String reservationCode;
@ApiModelProperty(value = "异常入库 0 正常 1 异常")
private Integer inWarehouseException;
@ApiModelProperty(value = "仓库id")
private Long warehouseId;//仓库id
@ApiModelProperty(value = "仓库名称")
private String warehouseName;//仓库
@ApiModelProperty(value = "入库类型 1提货扫描入库 2直接入库 3批量入库 4 按车次号入库 5按订单入库")
private Integer incomingType;//入库类型 1提货扫描入库 2直接入库 3批量入库 4 按车次号入库 5按订单入库
@ApiModelProperty(value = "托盘码")
private String trayCode;//托盘码
@ApiModelProperty(value = "打托方式")
private String trayType;//打托方式
}

269
blade-service-api/logpm-business-api/src/main/java/com/logpm/business/entity/BusinessPreOrderEntity.java

@ -0,0 +1,269 @@
/*
* Copyright (c) 2018-2028, Chill Zhuang All rights reserved.
*
* Redistribution and use in source and binary forms, with or without
* modification, are permitted provided that the following conditions are met:
*
* Redistributions of source code must retain the above copyright notice,
* this list of conditions and the following disclaimer.
* Redistributions in binary form must reproduce the above copyright
* notice, this list of conditions and the following disclaimer in the
* documentation and/or other materials provided with the distribution.
* Neither the name of the dreamlu.net developer nor the names of its
* contributors may be used to endorse or promote products derived from
* this software without specific prior written permission.
* Author: Chill 庄骞 (smallchill@163.com)
*/
package com.logpm.business.entity;
import com.baomidou.mybatisplus.annotation.TableName;
import com.fasterxml.jackson.annotation.JsonFormat;
import io.swagger.annotations.ApiModel;
import io.swagger.annotations.ApiModelProperty;
import lombok.Data;
import lombok.EqualsAndHashCode;
import org.springblade.core.tenant.mp.TenantEntity;
import java.math.BigDecimal;
import java.util.Date;
/**
* 商场转换预处理 实体类
*
* @author cyz
* @since 2023-06-13
*/
@Data
@TableName("logpm_business_pre_order")
@ApiModel(value = "DistributionBusinessPreOrder对象", description = "商场转换预处理实体")
@EqualsAndHashCode(callSuper = true)
public class BusinessPreOrderEntity 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;
/**
* 订单自编号
*/
@ApiModelProperty(value = "订单自编号")
private String orderCode;
/**
* 配送车牌
*/
@ApiModelProperty(value = "配送车牌")
private String vehicleName;
/**
* 配送司机
*/
@ApiModelProperty(value = "配送司机")
private String driverName;
/**
* 仓库
*/
@ApiModelProperty(value = "仓库")
private String warehouse;
@ApiModelProperty(value = "仓库ID")
private Long warehouseId;
/**
* 包件类型 1 定制品 2 库存品 3零担
*/
@ApiModelProperty(value = "状态")
private Integer conditions;
/**
* 包条码
*/
@ApiModelProperty(value = "包条码")
private String orderPackageCode;
/**
* 货位信息
*/
@ApiModelProperty(value = "货位信息")
private String goodsAllocation;
/**
* 所在托盘
*/
@ApiModelProperty(value = "所在托盘")
private String pallet;
/**
* 一级品
*/
@ApiModelProperty(value = "一级品")
private String firsts;
/**
* 二级品
*/
@ApiModelProperty(value = "二级品")
private String second;
/**
* 三级品
*/
@ApiModelProperty(value = "三级品")
private String thirdProduct;
/**
* 入库时间
*/
@ApiModelProperty(value = "入库时间")
@JsonFormat(locale = "zh", timezone = "GMT+8", pattern = "yyyy-MM-dd HH:mm:ss")
private Date warehouseEntryTimeEnd;
/**
* 运单号
*/
@ApiModelProperty(value = "运单号")
private String waybillNumber;
/**
* 运单ID
*/
@ApiModelProperty(value = "运单ID")
private Long waybillId;
/**
* 物料Id
*/
@ApiModelProperty(value = "物料ID")
private Long materialId;
/**
* 物料名称
*/
@ApiModelProperty(value = "物料名称")
private String materialName;
/**
* 物料编号
*/
@ApiModelProperty(value = "物料编号")
private String materialCode;
/**
* 物料单位
*/
@ApiModelProperty(value = "物料单位")
private String materialUnit;
/**
* 数量
*/
@ApiModelProperty(value = "数量")
private Integer quantity;
/**
* 车次号
*/
@ApiModelProperty(value = "车次号")
private String trainNumber;
/**
* 在库订单ID
*/
@ApiModelProperty(value = "在库订单ID")
private Long stockArticleId;
/**
* 服务号
*/
@ApiModelProperty(value = "服务号")
private String serviceNumber;
/**
* 品牌ID
*/
@ApiModelProperty(value = "品牌ID")
private Long brandId;
/**
* 品牌名称
*/
@ApiModelProperty(value = "品牌名称")
private String brandName;
/**
* 包件状态
*/
@ApiModelProperty(value = "包件状态")
private String orderPackageStatus;
@ApiModelProperty(value = "经销商名称")
private String dealerName;
@ApiModelProperty(value = "经销商编码")
private String dealerCode;
@ApiModelProperty(value = "发站仓ID")
private Long sendWarehouseId;
@ApiModelProperty(value = "发站仓ID")
private String sendWarehouseName;
@ApiModelProperty(value = "收站仓ID")
private Long acceptWarehouseId;
@ApiModelProperty(value = "收站仓ID")
private String acceptWarehouseName;
@ApiModelProperty(value = "装车状态")
private String orderPackageLoadingStatus;
@ApiModelProperty(value = "重量")
private BigDecimal weight;//重量
@ApiModelProperty(value = "体积")
private BigDecimal volume;//体积
@ApiModelProperty(value = "是否中转")
private Integer isTransfer;//是否中转
@ApiModelProperty(value = "暂存单id")
private Long advanceId;//暂存单id
@ApiModelProperty(value = "配送车次号")
private String distrCarNumber;
@ApiModelProperty(value = "预约单号")
private String reservationCode;
@ApiModelProperty(value = "是否入库 0 没有入库 1 已入库")
private Integer inWarehouse;//
@ApiModelProperty(value = "来源租户")
private String fromTenantId;
@ApiModelProperty(value = "操作状态 0 正常操作 1.补录操作")
private Integer operationStatus;
@ApiModelProperty(value = "发车时间")
private String taskTime;
// /**
// * 配送状态
// */
// @ApiModelProperty(value = "配送状态")
// private String orderPackageStatus;
}

28
blade-service-api/logpm-business-api/src/main/java/com/logpm/business/feign/IBusinessPreOrderClient.java

@ -0,0 +1,28 @@
package com.logpm.business.feign;
import com.logpm.business.entity.BusinessPreOrderEntity;
import org.apache.ibatis.annotations.Param;
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.PostMapping;
import org.springframework.web.bind.annotation.RequestBody;
import org.springframework.web.bind.annotation.RequestParam;
import java.util.List;
@FeignClient(
value = ModuleNameConstant.LOGPM_BUSINESS_NAME
)
public interface IBusinessPreOrderClient {
String API_PREFIX = "/client";
String INORDERBYORDERPACKAGECODE = API_PREFIX + "/inOrderByOrderPackageCode";
String SAVEOTHERDATABASENEW = API_PREFIX + "/saveOtherDataBaseNew";
@GetMapping(INORDERBYORDERPACKAGECODE)
Integer inOrderByOrderPackageCode(@RequestParam("orderPackageCode") String orderPackageCode, @RequestParam("carNum") String carNum);
@PostMapping(SAVEOTHERDATABASENEW)
void saveOtherDataBaseNew(@RequestParam("userId") String tenantId, @RequestBody List<BusinessPreOrderEntity> dataResult, @RequestParam("mallName") String mallName);
}

14
blade-service-api/logpm-business-api/src/main/java/com/logpm/business/vo/BusinessPreOrderVO.java

@ -0,0 +1,14 @@
package com.logpm.business.vo;
import com.logpm.business.entity.BusinessPreOrderEntity;
import lombok.Data;
/**
*
*/
@Data
public class BusinessPreOrderVO extends BusinessPreOrderEntity {
}

28
blade-service-api/logpm-business-api/src/main/java/com/logpm/business/vo/DistributionBusinessPreCarDetalPackageVO.java

@ -0,0 +1,28 @@
package com.logpm.business.vo;
import io.swagger.annotations.ApiModelProperty;
import lombok.Data;
@Data
public class DistributionBusinessPreCarDetalPackageVO {
@ApiModelProperty(value = "包条码")
private String orderPackageCode;
@ApiModelProperty(value = "一级品")
private String firsts;
@ApiModelProperty(value = "二级品")
private String second;
@ApiModelProperty(value = "三级品")
private String third_product;
@ApiModelProperty(value = "物料名称")
private String materialName;
@ApiModelProperty(value = "运单号")
private String waybillNumber;
@ApiModelProperty(value = "订单号")
private String orderCode;
@ApiModelProperty(value = "是否入库 0 没有入库 1 已入库")
private Integer inWarehouse;
@ApiModelProperty(value = "操作状态 0 正常操作 1.补录操作")
private Integer operationStatus;
}

42
blade-service-api/logpm-business-api/src/main/java/com/logpm/business/vo/DistributionBusinessPreCarDetalVO.java

@ -0,0 +1,42 @@
package com.logpm.business.vo;
import io.swagger.annotations.ApiModelProperty;
import lombok.Data;
import java.util.List;
@Data
public class DistributionBusinessPreCarDetalVO {
@ApiModelProperty(value = "配送车次")
private String distrCarNumber;
@ApiModelProperty(value = "配送司机")
private String driverName;
@ApiModelProperty(value = "配送车辆")
private String vehicleName;
@ApiModelProperty(value = "配送日期")
private String taskTime;
@ApiModelProperty(value = "订单总数")
private Integer orderCount;
@ApiModelProperty(value = "计划件数")
private Integer orderPackageCodeCount;
@ApiModelProperty(value = "装车件数")
private Integer loadCarCount;
@ApiModelProperty(value = "入库件数")
private Integer inWarehouseCount;
@ApiModelProperty(value = "车次订单列表")
private List<DistributionBusinessPreCarOrderDetalVO> distributionBusinessPreCarOrderDetalVOList;
}

28
blade-service-api/logpm-business-api/src/main/java/com/logpm/business/vo/DistributionBusinessPreCarNumberVO.java

@ -0,0 +1,28 @@
package com.logpm.business.vo;
import io.swagger.annotations.ApiModelProperty;
import lombok.Data;
@Data
public class DistributionBusinessPreCarNumberVO {
@ApiModelProperty(value = "配送车次")
private String distrCarNumber;
@ApiModelProperty(value = "运单号")
private String waybillNumber;
@ApiModelProperty(value = "订单号")
private String orderCode;
@ApiModelProperty(value = "总件数")
private Integer totalNum;
@ApiModelProperty(value = "入库件数")
private Integer inNum;
@ApiModelProperty(value = "待入库件数")
private Integer restNum;
}

16
blade-service-api/logpm-business-api/src/main/java/com/logpm/business/vo/DistributionBusinessPreCarNumerPageQueryVO.java

@ -0,0 +1,16 @@
package com.logpm.business.vo;
import io.swagger.annotations.ApiModelProperty;
import lombok.Data;
@Data
public class DistributionBusinessPreCarNumerPageQueryVO {
@ApiModelProperty(value = "开始时间")
private String taskTimeStart;
@ApiModelProperty(value = "结束时间")
private String taskTimeEnd;
@ApiModelProperty(value = "订单号")
private String orderCode;
@ApiModelProperty(value = "配送车次号")
private String distrCarNumber;
}

34
blade-service-api/logpm-business-api/src/main/java/com/logpm/business/vo/DistributionBusinessPreCarNumerPageVO.java

@ -0,0 +1,34 @@
package com.logpm.business.vo;
import io.swagger.annotations.ApiModelProperty;
import lombok.Data;
@Data
public class DistributionBusinessPreCarNumerPageVO {
@ApiModelProperty(value = "配送车次")
private String distrCarNumber;
@ApiModelProperty(value = "配送司机")
private String driverName;
@ApiModelProperty(value = "配送车辆")
private String vehicleName;
@ApiModelProperty(value = "配送日期")
private String taskTime;
@ApiModelProperty(value = "订单总数")
private Integer orderCount;
@ApiModelProperty(value = "计划件数")
private Integer orderPackageCodeCount;
@ApiModelProperty(value = "装车件数")
private Integer loadCarCount;
@ApiModelProperty(value = "入库件数")
private Integer inWarehouseCount;
}

35
blade-service-api/logpm-business-api/src/main/java/com/logpm/business/vo/DistributionBusinessPreCarOrderDetalVO.java

@ -0,0 +1,35 @@
package com.logpm.business.vo;
import io.swagger.annotations.ApiModelProperty;
import lombok.Data;
import java.util.List;
@Data
public class DistributionBusinessPreCarOrderDetalVO {
/**
* 订单自编号
*/
@ApiModelProperty(value = "订单自编号")
private String orderCode;
/**
* 运单号
*/
@ApiModelProperty(value = "运单号")
private String waybillNumber;
@ApiModelProperty(value = "计划件数")
private Integer orderPackageCodeCount;
@ApiModelProperty(value = "装车件数")
private Integer loadCarCount;
@ApiModelProperty(value = "入库件数")
private Integer inWarehouseCount;
@ApiModelProperty(value = "异常入库件数")
private Integer inWarehouseExceCount;
@ApiModelProperty(value = "包件列表")
private List<DistributionBusinessPreCarDetalPackageVO> distributionBusinessPreCarDetalPackageList;
}

28
blade-service-api/logpm-business-api/src/main/java/com/logpm/business/vo/DistributionBusinessPreOrderListVO.java

@ -0,0 +1,28 @@
package com.logpm.business.vo;
import lombok.Data;
import java.io.Serializable;
import java.util.List;
@Data
public class DistributionBusinessPreOrderListVO implements Serializable {
/**
* 总数
*/
private Integer sumNum;
/**
* 入库数量
*/
private Integer inNum;
/**
* 列表数据
*/
private List<BusinessPreOrderVO> list;
}

19
blade-service-api/logpm-distribution-api/src/main/java/com/logpm/distribution/dto/FindParamterDTO.java

@ -0,0 +1,19 @@
package com.logpm.distribution.dto;
import lombok.Data;
import java.io.Serializable;
import java.util.List;
import java.util.Set;
@Data
public class FindParamterDTO implements Serializable {
private Set<String> orderCodeSet;
private Long warehouseId;
private List<String> orderPackageCodeList;
private List<String> orderCodeList;
}

14
blade-service-api/logpm-distribution-api/src/main/java/com/logpm/distribution/dto/OrderPackageDTO.java

@ -0,0 +1,14 @@
package com.logpm.distribution.dto;
import lombok.Data;
import java.io.Serializable;
import java.util.List;
@Data
public class OrderPackageDTO implements Serializable {
private List<String> strings;
private Long warehouseId;
}

48
blade-service-api/logpm-distribution-api/src/main/java/com/logpm/distribution/entity/DistributionAddvaluePackageEntity.java

@ -20,6 +20,8 @@ import com.baomidou.mybatisplus.annotation.TableName;
import lombok.Data;
import io.swagger.annotations.ApiModel;
import io.swagger.annotations.ApiModelProperty;
import java.math.BigDecimal;
import java.util.Date;
import com.baomidou.mybatisplus.annotation.IdType;
import com.baomidou.mybatisplus.annotation.TableId;
@ -137,4 +139,50 @@ public class DistributionAddvaluePackageEntity extends TenantEntity implements S
private String recordType;
/**
* 总数量
*/
@ApiModelProperty(value = "客户ID")
private Long clientId;
/**
* 总数量
*/
@ApiModelProperty(value = "客户名称")
private String clientName;
/**
* 总数量
*/
@ApiModelProperty(value = "客户ID")
private Long brandId;
/**
* 总数量
*/
@ApiModelProperty(value = "客户名称")
private String brandName;
/**
* 单价
*/
@ApiModelProperty(value = "单价")
private BigDecimal unitPrice;
/**
* 费用
*/
@ApiModelProperty(value = "费用")
private BigDecimal fee;
/**
* 扫描操作人
*/
@ApiModelProperty(value = "扫描操作人")
private String scanUserName;
}

6
blade-service-api/logpm-distribution-api/src/main/java/com/logpm/distribution/entity/DistributionBillLadingScanEntity.java

@ -69,4 +69,10 @@ public class DistributionBillLadingScanEntity extends BaseEntity {
@ApiModelProperty(value = "库存品id")
private Long stockListId;
@ApiModelProperty(value = "仓库Id")
private Long warehouseId;
@ApiModelProperty(value = "扫描操作人")
private String scanUser;
}

8
blade-service-api/logpm-distribution-api/src/main/java/com/logpm/distribution/entity/DistributionLoadscanAbnormalEntity.java

@ -105,7 +105,13 @@ public class DistributionLoadscanAbnormalEntity extends TenantEntity {
* 仓库Id
*/
@ApiModelProperty(value = "仓库Id")
private String warehouseId;
private Long warehouseId;
/**
* 扫描记录ID
*/
@ApiModelProperty(value = "扫描记录ID")
private Long loadingId;
/**
* 仓库名称
*/

7
blade-service-api/logpm-distribution-api/src/main/java/com/logpm/distribution/entity/DistributionLoadscanEntity.java

@ -348,9 +348,16 @@ public class DistributionLoadscanEntity extends TenantEntity {
@ApiModelProperty(value = "是否异常装车 1-否 2-是")
private Integer isAbnormalLoading;
/**
* 是否异常装车 1- 2-
*/
@ApiModelProperty(value = "是否异常装车 1-否 2-是")
private Integer isZero;
/**
* 签收方式
*/
@ApiModelProperty(value = "签收方式")
private Integer signforType;
}

6
blade-service-api/logpm-distribution-api/src/main/java/com/logpm/distribution/entity/DistributionLoadscaninvnEntity.java

@ -335,4 +335,10 @@ public class DistributionLoadscaninvnEntity extends TenantEntity {
@ApiModelProperty(value = "是否一键签收(1-不是,2-是)")
private Long signingUserId;
/**
* 签收方式
*/
@ApiModelProperty(value = "签收方式")
private Integer signforType;
}

21
blade-service-api/logpm-distribution-api/src/main/java/com/logpm/distribution/entity/DistributionParcelListEntity.java

@ -197,7 +197,7 @@ public class DistributionParcelListEntity extends TenantEntity {
* 运单ID
*/
@ApiModelProperty(value = "运单ID")
private String waybillId;
private Long waybillId;
/**
* 客户id
*/
@ -205,6 +205,13 @@ public class DistributionParcelListEntity extends TenantEntity {
@TableField(exist = false)
private Long marketId;
/**
* 商场id
*/
@ApiModelProperty(value = "商场id")
@TableField(exist = false)
private Long mallId;
/**
* 商场名称
*/
@ -223,12 +230,12 @@ public class DistributionParcelListEntity extends TenantEntity {
@ApiModelProperty(value = "零担标识")
@TableField(exist = false)
private String isZero;
/**
* 商场名称
*/
@ApiModelProperty(value = "商场iD")
@TableField(exist = false)
private Long mallId;
// /**
// * 商场名称
// */
// @ApiModelProperty(value = "商场iD")
// @TableField(exist = false)
// private Long mallId;
/**
* 托盘ID
*/

7
blade-service-api/logpm-distribution-api/src/main/java/com/logpm/distribution/entity/DistributionReservationEntity.java

@ -45,6 +45,7 @@ public class DistributionReservationEntity extends TenantEntity {
*/
@ApiModelProperty(value = "订单自编号;订单自编号,关联订单表")
private String stockArticleId;
// private String orderCodes;
/**
* 收货人
*/
@ -297,6 +298,10 @@ public class DistributionReservationEntity extends TenantEntity {
@ApiModelProperty(value = "备货结束时间")
private Date endTimeStocking;
/**
* 是否安装
*/
@ApiModelProperty(value = "是否安装, 0-否 1- 是")
private Integer isInstall;
}

7
blade-service-api/logpm-distribution-api/src/main/java/com/logpm/distribution/entity/DistributionReservationPackageEntity.java

@ -96,5 +96,12 @@ public class DistributionReservationPackageEntity extends TenantEntity {
private Integer cancelStatus;
/**
* 包件任务取消备注
*/
@ApiModelProperty(value = "包件任务取消备注")
private String cancelRemark;
}

12
blade-service-api/logpm-distribution-api/src/main/java/com/logpm/distribution/entity/DistributionStockArticleEntity.java

@ -404,7 +404,7 @@ public class DistributionStockArticleEntity extends TenantEntity {
private String orderStatus;
@ApiModelProperty(value = "预约状态")
private String reservationStatus;
private String reservationStatus;
@ApiModelProperty(value = "备货状态")
private String stockupStatus;
@ -475,6 +475,8 @@ public class DistributionStockArticleEntity extends TenantEntity {
String consigneePerson = distributionStockArticleEntity.getConsigneePerson();
String consigneeMobile = distributionStockArticleEntity.getConsigneeMobile();
String consigneeAddress = distributionStockArticleEntity.getConsigneeAddress();
String consigneeUnit = distributionStockArticleEntity.getConsigneeUnit();
String mallName = distributionStockArticleEntity.getMallName();
StringBuilder stringBuilder = new StringBuilder();
boolean nameFlag = ObjectUtil.equals(this.customerName, customerName);
@ -501,6 +503,14 @@ public class DistributionStockArticleEntity extends TenantEntity {
if(!consigneeAddressFlag){
stringBuilder.append("运单收货地址:["+this.consigneeAddress+"]修改为["+consigneeAddress+"];");
}
boolean consigneeUnitFlag = ObjectUtil.equals(this.consigneeUnit, consigneeUnit);
if(!consigneeUnitFlag){
stringBuilder.append("运单收货单位:["+this.consigneeUnit+"]修改为["+consigneeUnit+"];");
}
boolean mallNameFlag = ObjectUtil.equals(this.mallName, mallName);
if(!mallNameFlag){
stringBuilder.append("运单收货单位:["+this.mallName+"]修改为["+mallName+"];");
}
return stringBuilder.toString();
}

8
blade-service-api/logpm-distribution-api/src/main/java/com/logpm/distribution/entity/DistributionStockEntity.java

@ -117,6 +117,11 @@ public class DistributionStockEntity extends TenantEntity {
@ApiModelProperty(value = "包件id")
@TableField(exist = false)
private String parcelsId;
/**
* 扫描操作人
*/
@ApiModelProperty(value = "扫描操作人")
private String scanUser;
/**
* 单位
*/
@ -164,6 +169,9 @@ public class DistributionStockEntity extends TenantEntity {
@ApiModelProperty(value = "备货区")
private String stockupArea;
@ApiModelProperty(value = "备货区")
private Long stockupAreaId;
/**
* 货位Id
*/

18
blade-service-api/logpm-distribution-api/src/main/java/com/logpm/distribution/entity/DistrilbutionBillLadingEntity.java

@ -83,6 +83,12 @@ public class DistrilbutionBillLadingEntity extends TenantEntity {
@ApiModelProperty(value = "提货人")
private String consignee;
/**
* 收货单位
*/
@ApiModelProperty(value = "收货单位")
private String consigneeUnit;
@ApiModelProperty(value = "提货人电话")
private String consigneePhone;
/**
@ -161,6 +167,18 @@ public class DistrilbutionBillLadingEntity extends TenantEntity {
@ApiModelProperty(value = "备货库存品数量")
private Integer reserveQuantity;
/**
* 审核人ID
*/
@ApiModelProperty(value = "审核人ID")
private Long examineUserId;
/**
* 审核人名称
*/
@ApiModelProperty(value = "审核人名称")
private String examineUserName;

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

@ -128,6 +128,12 @@ public interface IDistributionDeliveryListClient {
@GetMapping(TOP+"/maintenanceDeliveryInfoByWarehouseId")
void maintenanceDeliveryInfoByWarehouseId(@RequestParam("warehouseId")String params);
@GetMapping(TOP+"/pushNotification")
void pushNotification(@RequestParam("warehouseIds")String warehouseIds,@RequestParam("reservationCode")String reservationCode);
@GetMapping(TOP+"/mallClientSignfor")
void mallClientSignfor(@RequestParam("tenantId") String tenantId,@RequestParam("trainNumber")String trainNumber,@RequestParam("warehouseId")Long warehouseId,@RequestParam("orderPackageCode")String orderPackageCode,@RequestParam("nowTenantId")String nowTenantId);
// /**
// * 根据配送任务ID查询配送司机信息

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

@ -16,6 +16,8 @@
*/
package com.logpm.distribution.feign;
import com.logpm.distribution.dto.FindParamterDTO;
import com.logpm.distribution.dto.OrderPackageDTO;
import com.logpm.distribution.entity.DistributionParcelListEntity;
import com.logpm.distribution.vo.DistributionParcelListVO;
import org.springblade.common.constant.ModuleNameConstant;
@ -29,6 +31,7 @@ import org.springframework.web.bind.annotation.RequestParam;
import java.util.List;
import java.util.Map;
import java.util.Set;
/**
* 在库订单包件清单 Feign接口类
@ -37,15 +40,15 @@ import java.util.Map;
* @since 2023-06-13
*/
@FeignClient(
value = ModuleNameConstant.APPLICATION_DISTRIBUTION_NAME
value = ModuleNameConstant.APPLICATION_DISTRIBUTION_NAME
)
public interface IDistributionParcelListClient {
String API_PREFIX = "/client";
String TOP = API_PREFIX + "/top1";
String TOPPARCELLIST = API_PREFIX + "/getParcelList";
String GETPARCELLISTID = API_PREFIX + "/getParcelListId";
String GETPARCELLISTINFO = API_PREFIX + "/getParcelListInfo";
String API_PREFIX = "/client";
String TOP = API_PREFIX + "/top1";
String TOPPARCELLIST = API_PREFIX + "/getParcelList";
String GETPARCELLISTID = API_PREFIX + "/getParcelListId";
String GETPARCELLISTINFO = API_PREFIX + "/getParcelListInfo";
@PostMapping(TOPPARCELLIST)
List<DistributionParcelListEntity> getParcelList(@RequestBody DistributionParcelListEntity parcelListEntity);
@ -54,99 +57,148 @@ public interface IDistributionParcelListClient {
@GetMapping(GETPARCELLISTID)
DistributionParcelListEntity getParcelListId(@RequestParam String id);
/**
* 获取在库订单包件清单列表
*
* @param current 页号
* @param size 页数
* @return BladePage
*/
@GetMapping(TOP)
BladePage<DistributionParcelListEntity> top(@RequestParam("current") Integer current, @RequestParam("size") Integer size);
/**
* 获取在库订单包件清单列表
*
* @param current 页号
* @param size 页数
* @return BladePage
*/
@GetMapping(TOP)
BladePage<DistributionParcelListEntity> top(@RequestParam("current") Integer current, @RequestParam("size") Integer size);
@GetMapping(API_PREFIX + "/findByPacketBarCode")
List<DistributionParcelListEntity> findByPacketBarCode(@RequestParam String unitNo);
@GetMapping(API_PREFIX+"/findByPacketBarCode")
DistributionParcelListEntity findByPacketBarCode(@RequestParam String unitNo);
@GetMapping(API_PREFIX + "/findByPacketBarCodeAndWarehouseId")
DistributionParcelListEntity findByPacketBarCodeAndWarehouseId(@RequestParam String unitNo, @RequestParam Long warehouseId);
@GetMapping(API_PREFIX+"/findByPacketBarCodeAndWarehouseId")
DistributionParcelListEntity findByPacketBarCodeAndWarehouseId(@RequestParam String unitNo,@RequestParam Long warehouseId);
@PostMapping(API_PREFIX + "/findByPacketBarCodesAndWarehouseId")
List<DistributionParcelListEntity> findByPacketBarCodesAndWarehouseId(@RequestBody OrderPackageDTO orderPackageDTO);
@PostMapping(API_PREFIX+"/addBatch")
@PostMapping(API_PREFIX + "/addBatch")
boolean addBatch(@RequestBody List<DistributionParcelListEntity> parcelListEntityList);
@PostMapping(API_PREFIX+"/add")
@PostMapping(API_PREFIX + "/add")
boolean add(@RequestBody DistributionParcelListEntity entity);
@GetMapping(API_PREFIX+"/submitNumByOrderIdAndName")
@GetMapping(API_PREFIX + "/submitNumByOrderIdAndName")
boolean submitNumByOrderIdAndName(@RequestParam Long articleId, @RequestParam String productName, @RequestParam Integer num);
@GetMapping(API_PREFIX+"/findEntityListByOrderCode")
List<DistributionParcelListEntity> findEntityListByOrderCode(@RequestParam String orderCode,@RequestParam Long warehouseId);
@GetMapping(API_PREFIX + "/findEntityListByOrderCode")
List<DistributionParcelListEntity> findEntityListByOrderCode(@RequestParam String orderCode, @RequestParam Long warehouseId);
@GetMapping(API_PREFIX+"/findALLNoUpShelfPackageByOrderCode")
List<DistributionParcelListEntity> findALLNoUpShelfPackageByOrderCode(@RequestParam String orderCode,@RequestParam Long warehouseId);
@GetMapping(API_PREFIX + "/findALLNoUpShelfPackageByOrderCode")
List<DistributionParcelListEntity> findALLNoUpShelfPackageByOrderCode(@RequestParam String orderCode, @RequestParam Long warehouseId);
@GetMapping(API_PREFIX+"/updatePackageGroundingStatus")
void updatePackageGroundingStatus(@RequestParam String orderPackageCode, @RequestParam String groundingStatus,@RequestParam Long warehouseId);
@GetMapping(API_PREFIX + "/updatePackageGroundingStatus")
void updatePackageGroundingStatus(@RequestParam String orderPackageCode, @RequestParam String groundingStatus, @RequestParam Long warehouseId);
@GetMapping(API_PREFIX+"/getListByOrderCodeAndgroundingStatus")
List<DistributionParcelListEntity> getListByOrderCodeAndgroundingStatus(@RequestParam String orderCode, @RequestParam String groundingStatus,@RequestParam Long warehouseId);
@PostMapping(API_PREFIX+"/update")
@GetMapping(API_PREFIX + "/getListByOrderCodeAndgroundingStatus")
List<DistributionParcelListEntity> getListByOrderCodeAndgroundingStatus(@RequestParam String orderCode, @RequestParam String groundingStatus, @RequestParam Long warehouseId);
@PostMapping(API_PREFIX + "/update")
void update(@RequestBody DistributionParcelListEntity distributionParcelListEntity);
@GetMapping(API_PREFIX+"/SumEntityZkByOrderId")
Integer SumEntityByOrderId(@RequestParam Long orderId,@RequestParam Long warehouseId);
@GetMapping(API_PREFIX + "/SumEntityZkByOrderId")
Integer SumEntityByOrderId(@RequestParam Long orderId, @RequestParam Long warehouseId);
/**
* 查询订单下所有包件信息
*
* @param id
* @return
*/
@GetMapping(API_PREFIX+"/getParcelListByStockArticleId")
@GetMapping(API_PREFIX + "/getParcelListByStockArticleId")
List<DistributionParcelListEntity> getParcelListByStockArticleId(@RequestParam Long id);
@PostMapping(API_PREFIX+"/addReturnId")
@PostMapping(API_PREFIX + "/addReturnId")
Long addReturnId(@RequestBody DistributionParcelListEntity entity);
@GetMapping(API_PREFIX+"/updateStockArticleIdByOrderCode")
@GetMapping(API_PREFIX + "/updateStockArticleIdByOrderCode")
void updateStockArticleIdByOrderCode(@RequestParam Long orderId, @RequestParam String orderCode);
@PostMapping(GETPARCELLISTINFO)
List<DistributionParcelListEntity> getParcelListInfo(@RequestBody DistributionParcelListVO parcelListVO);
@GetMapping(API_PREFIX+"/findByOrderPackageCodeAndStatus")
@GetMapping(API_PREFIX + "/findByOrderPackageCodeAndStatus")
DistributionParcelListEntity findByOrderPackageCodeAndStatus(@RequestParam String orderPackageCode);
@GetMapping(API_PREFIX+"/updateOrderPackageCodeById")
void updateOrderPackageCodeById(@RequestParam Long packageId, @RequestParam String orderPackageStatus);
@GetMapping(API_PREFIX + "/updateOrderPackageCodeById")
void updateOrderPackageCodeById(@RequestParam Long packageId, @RequestParam String orderPackageStatus);
/**
* 根据包条码和仓库ID查询订单相关信息
*
* @param orderPackCode 包条码
* @param warehouseId 仓库ID
* @param warehouseId 仓库ID
* @return
*/
@GetMapping(API_PREFIX+"/findByOrderInfoByOrderPackageCodeAndWarehouseId")
Map<String,Object> findByOrderInfoByOrderPackageCodeAndWarehouseId(@RequestParam String orderPackCode,@RequestParam Long warehouseId);
@GetMapping(API_PREFIX + "/findByOrderInfoByOrderPackageCodeAndWarehouseId")
Map<String, Object> findByOrderInfoByOrderPackageCodeAndWarehouseId(@RequestParam String orderPackCode, @RequestParam Long warehouseId);
@GetMapping(API_PREFIX + "/queryOrderByOrderPackageCode")
R<DistributionParcelListEntity> queryOrderByOrderPackageCode(@RequestParam String orderPackageCode);
@GetMapping(API_PREFIX+"/queryOrderByOrderPackageCode")
R<DistributionParcelListEntity> queryOrderByOrderPackageCode( @RequestParam String orderPackageCode);
@GetMapping(API_PREFIX+"/updateTransferStatus")
void updateTransferStatus(@RequestParam String orderCode, @RequestParam Long warehouseId, @RequestParam Integer isTransfer);
@GetMapping(API_PREFIX + "/updateTransferStatus")
void updateTransferStatus(@RequestParam String orderCode, @RequestParam Long warehouseId, @RequestParam Integer isTransfer);
@GetMapping(API_PREFIX+"/updateEntityByOpenOrder")
@GetMapping(API_PREFIX + "/updateEntityByOpenOrder")
void updateEntityByOpenOrder(@RequestParam Long advanceId, @RequestParam Long waybillId);
@GetMapping(API_PREFIX+"/findByWaybillNumber")
@GetMapping(API_PREFIX + "/findByWaybillNumber")
List<DistributionParcelListEntity> findByWaybillNumber(@RequestParam String waybillNumber);
@GetMapping(API_PREFIX+"/findEntityListByOrderCodeAndStatus")
List<DistributionParcelListEntity> findEntityListByOrderCodeAndStatus(@RequestParam String orderCode, @RequestParam Long warehouseId, @RequestParam String packageStatus);
@GetMapping(API_PREFIX + "/findEntityListByOrderCodeAndStatus")
List<DistributionParcelListEntity> findEntityListByOrderCodeAndStatus(@RequestParam String orderCode, @RequestParam Long warehouseId, @RequestParam String packageStatus, @RequestParam String waybillNo);
@GetMapping(API_PREFIX+"/getListByOrderPackageCode")
@GetMapping(API_PREFIX + "/getListByOrderPackageCode")
List<DistributionParcelListEntity> getListByOrderPackageCode(@RequestParam String orderPackageCode);
@GetMapping(API_PREFIX+"/findAllStockListByOrderPackageCode")
@GetMapping(API_PREFIX + "/findAllStockListByOrderPackageCode")
List<DistributionParcelListEntity> findAllStockListByOrderPackageCode(String orderPackageCode);
@PostMapping(API_PREFIX + "/updatePackageStatus")
void updatePackageStatus(@RequestParam List<String> orderPackageCodes, @RequestParam Long warehouseId, @RequestParam String packageStatus);
@PostMapping(API_PREFIX + "/updateList")
void updateList(@RequestBody List<DistributionParcelListEntity> updateParcelList);
@PostMapping(API_PREFIX + "/updateFreezeStatusByWaybillIds")
void updateFreezeStatusByWaybillIds(@RequestBody List<Long> waybillIds);
@PostMapping(API_PREFIX + "/updateUnFreezeStatusByWaybillIds")
void updateUnFreezeStatusByWaybillIds(@RequestBody List<Long> waybillIds);
@PostMapping(API_PREFIX + "/clearParceListWaybillByAdvanceIds")
void clearParceListWaybillByAdvanceIds(@RequestBody List<Long> advanceIds);
@GetMapping(API_PREFIX + "/findListByWaybillId")
List<DistributionParcelListEntity> findListByWaybillId(@RequestParam Long waybillId);
@PostMapping(API_PREFIX + "/findPackagesByAdvanceIdsAndNoStock")
List<DistributionParcelListEntity> findPackagesByAdvanceIdsAndNoStock(@RequestParam List<Long> advanceIds, @RequestParam Long warehouseId);
@PostMapping(API_PREFIX + "/findAllOrderCodesByAdvanceIds")
List<String> findAllOrderCodesAndDeleteByAdvanceIds(@RequestParam List<Long> advanceIds, @RequestParam Long warehouseId);
@GetMapping(API_PREFIX + "/findPackageCodeByCodes")
Map<String, Set<String>> findPackageCodeByCodes(@RequestBody Set<String> keySet);
@PostMapping(API_PREFIX + "/saveorUpdateBatchByOP")
void saveorUpdateBatchByOP(@RequestBody List<DistributionParcelListEntity> parcelListEntityList);
@PostMapping(API_PREFIX + "/findListByOrderCodesAndWarehouseId")
List<DistributionParcelListEntity> findListByOrderCodesAndWarehouseId(@RequestBody FindParamterDTO findParamterDTO);
@PostMapping(API_PREFIX + "/findListByOrderPackageCodeList")
List<DistributionParcelListEntity> findListByOrderPackageCodeList(@RequestBody FindParamterDTO findParamterDTO);
@PostMapping(API_PREFIX + "/findALLNoUpShelfPackageByOrderCodeList")
List<DistributionParcelListEntity> findALLNoUpShelfPackageByOrderCodeList(@RequestBody FindParamterDTO findParamterDTO);
@PostMapping(API_PREFIX + "/findAllParcelListByAdvanceIds")
List<DistributionParcelListEntity> findAllParcelListByAdvanceIds(@RequestBody List<Long> advanceIds);
}

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

@ -61,6 +61,8 @@ public interface IDistributionReservationClient {
*/
@GetMapping(TOP+"/getReservationList")
List<DistributionReservationEntity> getReservationList(@RequestParam("reservationIds") String reservationIds);
@GetMapping(TOP+"/getReservationByCodeAndWarehouseId")
DistributionReservationEntity getReservationByCodeAndWarehouseId(@RequestParam("reservationCode") String reservationCode,@RequestParam("warehouseId") String warehouseId);
/**

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

@ -19,6 +19,7 @@ package com.logpm.distribution.feign;
import com.logpm.distribution.entity.DistributionSignforEntity;
import org.springblade.common.constant.ModuleNameConstant;
import org.springblade.core.mp.support.BladePage;
import org.springblade.core.tool.api.R;
import org.springframework.cloud.openfeign.FeignClient;
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.RequestParam;
@ -36,6 +37,7 @@ public interface IDistributionSignforClient {
String API_PREFIX = "signfor/client";
String TOP = API_PREFIX + "/top";
String CLERKCHECKPUSHDATA = API_PREFIX + "/clerkCheckPushData";
/**
* 获取签收管理列表
@ -47,4 +49,17 @@ public interface IDistributionSignforClient {
@GetMapping(TOP)
BladePage<DistributionSignforEntity> top(@RequestParam("current") Integer current, @RequestParam("size") Integer size);
@GetMapping(TOP+"push0ldSystemSignInfo")
void push0ldSystemSignInfo(@RequestParam("current") Long signingId);
/**
* 推送老系统签收
* @param id
* @return
*/
@GetMapping(CLERKCHECKPUSHDATA)
Boolean clerkCheckPushData(@RequestParam("id") Long id);
}

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

@ -18,16 +18,20 @@ package com.logpm.distribution.feign;
import com.alibaba.fastjson.JSONObject;
import com.baomidou.mybatisplus.core.metadata.IPage;
import com.logpm.distribution.dto.FindParamterDTO;
import com.logpm.distribution.dto.OrderPackageDTO;
import com.logpm.distribution.entity.DistributionStockArticleEntity;
import com.logpm.distribution.vo.UpDownStockupAreaVO;
import org.springblade.common.constant.ModuleNameConstant;
import org.springblade.core.mp.support.BladePage;
import org.springframework.cloud.openfeign.FeignClient;
import org.springframework.http.MediaType;
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.PostMapping;
import org.springframework.web.bind.annotation.RequestBody;
import org.springframework.web.bind.annotation.RequestParam;
import java.util.ArrayList;
import java.util.List;
import java.util.Map;
@ -38,44 +42,44 @@ import java.util.Map;
* @since 2023-06-13
*/
@FeignClient(
value = ModuleNameConstant.APPLICATION_DISTRIBUTION_NAME
value = ModuleNameConstant.APPLICATION_DISTRIBUTION_NAME
)
public interface IDistributionStockArticleClient {
String API_PREFIX = "/client";
String TOP = API_PREFIX + "/top12";
String GETSTOCKARTICLEINFO = API_PREFIX + "/getStockArticleInfo";
String API_PREFIX = "/client";
String TOP = API_PREFIX + "/top12";
String GETSTOCKARTICLEINFO = API_PREFIX + "/getStockArticleInfo";
/**
* 获取配送在库订单列表
*
* @param current 页号
* @param size 页数
* @return BladePage
*/
@GetMapping(TOP)
BladePage<DistributionStockArticleEntity> top(@RequestParam("current") Integer current, @RequestParam("size") Integer size);
/**
* 获取配送在库订单列表
*
* @param current 页号
* @param size 页数
* @return BladePage
*/
@GetMapping(TOP)
BladePage<DistributionStockArticleEntity> top(@RequestParam("current") Integer current, @RequestParam("size") Integer size);
@PostMapping(API_PREFIX + "/addData")
Long addData(@RequestBody DistributionStockArticleEntity distributionStockArticleEntity);
Long addData(@RequestBody DistributionStockArticleEntity distributionStockArticleEntity);
@GetMapping(API_PREFIX + "/findByAdvanceId")
DistributionStockArticleEntity findByAdvanceId(@RequestParam Integer advanceId);
DistributionStockArticleEntity findByAdvanceId(@RequestParam Integer advanceId);
@PostMapping(API_PREFIX + "/saveOrUpdate")
void saveOrUpdate(@RequestBody DistributionStockArticleEntity distributionStockArticleEntity);
void saveOrUpdate(@RequestBody DistributionStockArticleEntity distributionStockArticleEntity);
@GetMapping(API_PREFIX + "/addHandQuantity")
void addHandQuantity(@RequestParam("id") Long id,@RequestParam("num") int num);
void addHandQuantity(@RequestParam("id") Long id, @RequestParam("num") int num);
@GetMapping(API_PREFIX + "/findByOrderSelfNum")
DistributionStockArticleEntity findByOrderSelfNum(@RequestParam String orderCode,@RequestParam Long warehouseId);
DistributionStockArticleEntity findByOrderSelfNum(@RequestParam String orderCode, @RequestParam Long warehouseId);
@GetMapping(API_PREFIX + "/deleteById")
void deleteById(@RequestParam Long orderId);
@GetMapping(API_PREFIX + "/submitHandQuantity")
void submitHandQuantity(@RequestParam Integer allNum,@RequestParam Long articleId);
void submitHandQuantity(@RequestParam Integer allNum, @RequestParam Long articleId);
@GetMapping(API_PREFIX + "/findListByOrderCodeLike")
List<DistributionStockArticleEntity> findListByOrderCodeLike(@RequestParam String orderCode);
@ -84,15 +88,20 @@ public interface IDistributionStockArticleClient {
DistributionStockArticleEntity findStockArticleByOrderCode(@RequestParam String orderCode);
@GetMapping(API_PREFIX + "/findEntityByStockArticleId")
DistributionStockArticleEntity findEntityByStockArticleId(@RequestParam Long stockArticleId);
DistributionStockArticleEntity findEntityByStockArticleId(@RequestParam Long stockArticleId);
@GetMapping(API_PREFIX + "/fingListByServiceNumber")
List<Map> fingListByServiceNumber(@RequestParam String serviceNumber,@RequestParam Long warehouseId);
List<Map> fingListByServiceNumber(@RequestParam String serviceNumber, @RequestParam Long warehouseId);
@GetMapping(API_PREFIX + "/findListByWaybillNumber")
List<DistributionStockArticleEntity> findListByWaybillNumber(@RequestParam String waybillNumber);
List<DistributionStockArticleEntity> findListByWaybillNumber(@RequestParam String waybillNumber);
@GetMapping(API_PREFIX + "/findStockArticleByOrderCodeAndWarehouseId")
DistributionStockArticleEntity findStockArticleByOrderCodeAndWarehouseId(@RequestParam String orderCode, @RequestParam Long warehouseId);
@GetMapping(API_PREFIX + "/findListByWaybillNumberAndWarehouseId")
List<DistributionStockArticleEntity> findListByWaybillNumberAndWarehouseId(@RequestParam String waybillNumber, @RequestParam Long warehouseId);
@GetMapping(API_PREFIX + "/updateGroundingStatus")
void updateGroundingStatus(@RequestParam String orderCode, @RequestParam String groundingStatus, @RequestParam Long warehouseId);
@ -104,35 +113,39 @@ public interface IDistributionStockArticleClient {
@GetMapping(API_PREFIX + "/findStockArticleByCodeAndMarketAndWarehouseId")
List<DistributionStockArticleEntity> findStockArticleByCodeAndMarketAndWarehouseId(@RequestParam String incomingBatch,@RequestParam String marketNames,@RequestParam Long warehouseId);
List<DistributionStockArticleEntity> findStockArticleByCodeAndMarketAndWarehouseId(@RequestParam String incomingBatch, @RequestParam String marketNames, @RequestParam Long warehouseId);
@GetMapping(API_PREFIX + "/findShelfNumByOrderCodeAndWarehouseId")
Map findShelfNumByOrderCodeAndWarehouseId(@RequestParam String orderCode, @RequestParam Long warehouseId);
@GetMapping(API_PREFIX + "/submitHandleNumByOrderId")
void submitHandleNumByOrderId(@RequestParam Integer subNum, @RequestParam Long articleId);
void submitHandleNumByOrderId(@RequestParam Integer subNum, @RequestParam Long articleId);
/**
* 查询订单信息数据
*
* @return
*/
@PostMapping(GETSTOCKARTICLEINFO)
List<DistributionStockArticleEntity> getStockArticleInfo(@RequestBody DistributionStockArticleEntity distributionStockArticleEntity);
List<DistributionStockArticleEntity> getStockArticleInfo(@RequestBody DistributionStockArticleEntity distributionStockArticleEntity);
@GetMapping(API_PREFIX + "/updateCustomerInfoByOrderCode")
void updateCustomerInfoByOrderCode(@RequestParam String customerName, @RequestParam String customerPhone, @RequestParam String customerAddress, @RequestParam String orderCode);
void updateCustomerInfoByOrderCode(@RequestParam String customerName, @RequestParam String customerPhone, @RequestParam String customerAddress, @RequestParam String orderCode);
@GetMapping(API_PREFIX + "/freezeByOrderCode")
void freezeByOrderCode(@RequestParam String orderCode,@RequestParam String freezeStatus);
void freezeByOrderCode(@RequestParam String orderCode, @RequestParam String freezeStatus);
@GetMapping(API_PREFIX + "/addCarsLoadNum")
void addCarsLoadNum(@RequestParam Integer planNum, @RequestParam String orderCode, @RequestParam Long warehouseId);
@GetMapping(API_PREFIX + "/addIncomingNum")
void addIncomingNum(@RequestParam Long orderId, @RequestParam Integer num);
void addIncomingNum(@RequestParam Long orderId, @RequestParam Integer num);
@GetMapping(API_PREFIX + "/updateOrderInfo")
void updateOrderInfo(@RequestParam String orderCode, @RequestParam Long warehouseId);
void updateOrderInfo(@RequestParam String orderCode, @RequestParam Long warehouseId);
@PostMapping(API_PREFIX + "/updateOrdersInfo")
void updateOrdersInfo(@RequestBody OrderPackageDTO orderPackageDTO);
@GetMapping(API_PREFIX + "/findZeroListByWarehouseId")
IPage<JSONObject> findZeroListByWarehouseId(@RequestParam Long warehouseId, @RequestParam Integer pageNum, @RequestParam Integer pageSize);
@ -144,11 +157,39 @@ public interface IDistributionStockArticleClient {
List<DistributionStockArticleEntity> findListByOrderCode(@RequestParam String orderCode);
@GetMapping(API_PREFIX + "/maintenanceOrderStatus")
Boolean maintenanceOrderStatus(String warehouseId);
Boolean maintenanceOrderStatus(String warehouseId);
@PostMapping(API_PREFIX + "/updateByBatchId")
void updateByBatchId(@RequestBody List<DistributionStockArticleEntity> stockArticleEntities);
@GetMapping(API_PREFIX + "/updateAllOrderTotalNum")
void updateAllOrderTotalNum(@RequestParam String orderCode, @RequestParam Integer total);
void updateAllOrderTotalNum(@RequestParam String orderCode, @RequestParam Integer total);
@GetMapping(API_PREFIX + "/maintenanceOrderMall")
Boolean maintenanceOrderMall(@RequestParam String orderIds);
/**
* 全仓更新未预约的在库定单的客户信息
*
* @param data 更新信息
* @return
*/
@PostMapping(value = API_PREFIX + "/updateCustomerAllByOrderCode",consumes = MediaType.APPLICATION_JSON_VALUE)
void updateCustomerAllByOrderCode(@RequestBody String data);
@PostMapping(value = API_PREFIX + "/findListByOrderCodesAndWarehouseId",consumes = MediaType.APPLICATION_JSON_VALUE)
List<DistributionStockArticleEntity> findListByOrderCodesAndWarehouseId(@RequestBody FindParamterDTO findParamterDTO);
@PostMapping(value = API_PREFIX + "/addReturnList",consumes = MediaType.APPLICATION_JSON_VALUE)
List<DistributionStockArticleEntity> addReturnList(@RequestBody List<DistributionStockArticleEntity> addStockArticleEntities);
@PostMapping(value = API_PREFIX + "/findOrderTotalNumByOrderCodes",consumes = MediaType.APPLICATION_JSON_VALUE)
Integer findOrderTotalNumByOrderCodes(@RequestBody JSONObject jsonObject);
@PostMapping(value = API_PREFIX + "/findOrderTotalNumByOrderPackageCodes",consumes = MediaType.APPLICATION_JSON_VALUE)
Integer findOrderTotalNumByOrderPackageCodes(@RequestBody JSONObject jsonObject);
@PostMapping(value = API_PREFIX + "/findAllStockArticleListByOrderCodes",consumes = MediaType.APPLICATION_JSON_VALUE)
List<DistributionStockArticleEntity> findAllStockArticleListByOrderCodes(@RequestBody List<String> orderCodes);
}

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

@ -47,4 +47,6 @@ public interface IDistributionStockClient {
@GetMapping(TOP)
BladePage<DistributionStockEntity> top(@RequestParam("current") Integer current, @RequestParam("size") Integer size);
@GetMapping(TOP+"/getCargoStockUpAllocationId")
String getCargoStockUpAllocationId(@RequestParam("code")String code,@RequestParam("warehouseId") Long warehouseId,@RequestParam("taskId") Long taskId);
}

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

@ -47,4 +47,19 @@ public interface IDistrilbutionBillLadingClient {
@GetMapping(TOP)
BladePage<DistrilbutionBillLadingEntity> top(@RequestParam("current") Integer current, @RequestParam("size") Integer size);
/**
* 推送老系统数据
* @param id
* @return
*/
@GetMapping(TOP+"/clerkBillCheckPushData")
Boolean clerkBillCheckPushData(@RequestParam("id")Long id);
/**
* 推送信息至工厂
* @param ids
* @return
*/
@GetMapping(TOP+"/sendFactorySignforInfo")
Boolean sendFactorySignforInfo(@RequestParam("ids")String ids);
}

Some files were not shown because too many files have changed in this diff Show More

Loading…
Cancel
Save