Browse Source

BUG修复

dist.1.3.0
汤建军 7 months ago
parent
commit
f373696ed7
  1. 2
      blade-service/logpm-distribution/src/main/java/com/logpm/distribution/feign/DistrilbutionBillLadingClient.java
  2. 3
      blade-service/logpm-distribution/src/main/java/com/logpm/distribution/service/IDistrilbutionBillLadingService.java
  3. 15
      blade-service/logpm-distribution/src/main/java/com/logpm/distribution/service/impl/DistrilbutionBillLadingServiceImpl.java

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

@ -61,7 +61,7 @@ public class DistrilbutionBillLadingClient implements IDistrilbutionBillLadingCl
@Override @Override
public Boolean sendFactorySignforInfo(String ids) { public Boolean sendFactorySignforInfo(String ids) {
for (String string : ids.split(",")) { for (String string : ids.split(",")) {
distributionAsyncService.sendFactorySignforInfo(string); distrilbutionBillLadingService.sendFactory(string);
} }
return null; return null;
} }

3
blade-service/logpm-distribution/src/main/java/com/logpm/distribution/service/IDistrilbutionBillLadingService.java

@ -276,4 +276,7 @@ public interface IDistrilbutionBillLadingService extends BaseService<Distrilbuti
* @return * @return
*/ */
R getBillLadingPackageIds(Long id,Long orderId); R getBillLadingPackageIds(Long id,Long orderId);
void sendFactory(String string);
} }

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

@ -1174,6 +1174,21 @@ public class DistrilbutionBillLadingServiceImpl extends BaseServiceImpl<Distrilb
return R.data(list.stream().map(DistrilbutionBillPackageEntity::getParceListId).collect(Collectors.toList())); return R.data(list.stream().map(DistrilbutionBillPackageEntity::getParceListId).collect(Collectors.toList()));
} }
@Override
public void sendFactory(String string) {
List<Long> list = Func.toLongList(string);
BasicdataWarehouseEntity myCurrentWarehouse = basicdataWarehouseClient.getMyCurrentWarehouse();
if (Func.isEmpty(myCurrentWarehouse)){
log.error("自提推送工厂为进行仓库选择?>>>>>>>>>>>>>>>>>>>>warehouse:{}",myCurrentWarehouse);
}
if (!list.isEmpty()) {
for (Long l : list) {
distributionAsyncService.sendFactorySignforInfo(l,myCurrentWarehouse,AuthUtil.getUser());
}
}
}
/** /**
* 转换老系统的ID * 转换老系统的ID
* *

Loading…
Cancel
Save