|
@@ -51,6 +51,8 @@ import vip.xiaonuo.biz.modular.bizorder.param.BizOrderExportResult;
|
|
import vip.xiaonuo.biz.modular.bizorder.service.BizOrderService;
|
|
import vip.xiaonuo.biz.modular.bizorder.service.BizOrderService;
|
|
import vip.xiaonuo.biz.modular.bizorderconfig.entity.BizOrderConfig;
|
|
import vip.xiaonuo.biz.modular.bizorderconfig.entity.BizOrderConfig;
|
|
import vip.xiaonuo.biz.modular.bizorderconfig.service.BizOrderConfigService;
|
|
import vip.xiaonuo.biz.modular.bizorderconfig.service.BizOrderConfigService;
|
|
|
|
+import vip.xiaonuo.biz.modular.bizordersupplier.entity.BizOrderSupplier;
|
|
|
|
+import vip.xiaonuo.biz.modular.bizordersupplier.service.BizOrderSupplierService;
|
|
import vip.xiaonuo.biz.modular.bizsupplier.entity.BizSupplierTransport;
|
|
import vip.xiaonuo.biz.modular.bizsupplier.entity.BizSupplierTransport;
|
|
import vip.xiaonuo.biz.modular.bizsupplier.service.BizSupplierTransportService;
|
|
import vip.xiaonuo.biz.modular.bizsupplier.service.BizSupplierTransportService;
|
|
import vip.xiaonuo.biz.modular.customer.entity.BizCustomer;
|
|
import vip.xiaonuo.biz.modular.customer.entity.BizCustomer;
|
|
@@ -133,6 +135,9 @@ public class BizAppointmentRecordServiceImpl extends ServiceImpl<BizAppointmentR
|
|
@Resource
|
|
@Resource
|
|
private BizLoadTimeService bizLoadTimeService;
|
|
private BizLoadTimeService bizLoadTimeService;
|
|
|
|
|
|
|
|
+ @Resource
|
|
|
|
+ private BizOrderSupplierService bizOrderSupplierService;
|
|
|
|
+
|
|
@Override
|
|
@Override
|
|
public Page<BizAppointmentRecord> page(BizAppointmentRecordPageParam bizAppointmentRecordPageParam) {
|
|
public Page<BizAppointmentRecord> page(BizAppointmentRecordPageParam bizAppointmentRecordPageParam) {
|
|
QueryWrapper<BizAppointmentRecord> queryWrapper = getQueryWrapper(bizAppointmentRecordPageParam);
|
|
QueryWrapper<BizAppointmentRecord> queryWrapper = getQueryWrapper(bizAppointmentRecordPageParam);
|
|
@@ -332,6 +337,18 @@ public class BizAppointmentRecordServiceImpl extends ServiceImpl<BizAppointmentR
|
|
if(count>0){
|
|
if(count>0){
|
|
throw new CommonException("车牌号:{}已经添加过预约!",bizAppointmentRecordAddParam.getLicenseNumber());
|
|
throw new CommonException("车牌号:{}已经添加过预约!",bizAppointmentRecordAddParam.getLicenseNumber());
|
|
}
|
|
}
|
|
|
|
+
|
|
|
|
+ //查询是否存在没有回签的记录
|
|
|
|
+ QueryWrapper<BizAppointmentRecord> queryWrapper = new QueryWrapper<>();
|
|
|
|
+ queryWrapper.eq("bar.delete_flag","NOT_DELETE");
|
|
|
|
+ queryWrapper.isNull("br.unload_weight");
|
|
|
|
+ queryWrapper.eq("bo.order_type","1");
|
|
|
|
+ queryWrapper.eq("bar.`status`","10");
|
|
|
|
+ queryWrapper.eq("bar.license_number",bizAppointmentRecordAddParam.getLicenseNumber());
|
|
|
|
+ List<BizAppointmentRecord> recordList = this.getBaseMapper().getRecordList(queryWrapper);
|
|
|
|
+ if(ObjectUtil.isNotEmpty(recordList)){
|
|
|
|
+ throw new CommonException("请先填写回签信息,再进行预约!");
|
|
|
|
+ }
|
|
}
|
|
}
|
|
//校验手机号
|
|
//校验手机号
|
|
if(ObjectUtil.isNotEmpty(bizAppointmentRecordAddParam.getDriverMobile())){
|
|
if(ObjectUtil.isNotEmpty(bizAppointmentRecordAddParam.getDriverMobile())){
|
|
@@ -353,9 +370,14 @@ public class BizAppointmentRecordServiceImpl extends ServiceImpl<BizAppointmentR
|
|
}
|
|
}
|
|
}
|
|
}
|
|
|
|
|
|
|
|
+ //查询订单下的供应商
|
|
|
|
+ List<BizOrderSupplier> supplierList = bizOrderSupplierService.list(new QueryWrapper<BizOrderSupplier>().lambda().
|
|
|
|
+ eq(BizOrderSupplier::getOrderId, bizAppointmentRecordAddParam.getOrderId()));
|
|
|
|
+ List<String> supplierIdList = Lists.newArrayList();
|
|
|
|
+ supplierList.forEach(supplier->supplierIdList.add(supplier.getSupplierId()));
|
|
//查询车辆是否在供应商名下
|
|
//查询车辆是否在供应商名下
|
|
BizSupplierTransport transport = bizSupplierTransportService.getOne(new QueryWrapper<BizSupplierTransport>().lambda().
|
|
BizSupplierTransport transport = bizSupplierTransportService.getOne(new QueryWrapper<BizSupplierTransport>().lambda().
|
|
- eq(BizSupplierTransport::getSupplierId, bizOrder.getSupplierId()).
|
|
|
|
|
|
+ in(BizSupplierTransport::getSupplierId, supplierIdList).
|
|
eq(BizSupplierTransport::getTransportNo, bizAppointmentRecordAddParam.getLicenseNumber()).
|
|
eq(BizSupplierTransport::getTransportNo, bizAppointmentRecordAddParam.getLicenseNumber()).
|
|
eq(BizSupplierTransport::getAuditStatus,"2").
|
|
eq(BizSupplierTransport::getAuditStatus,"2").
|
|
last("limit 1"));
|
|
last("limit 1"));
|
|
@@ -368,31 +390,25 @@ public class BizAppointmentRecordServiceImpl extends ServiceImpl<BizAppointmentR
|
|
bizAppointmentRecordAddParam.setTimeId(bizOrderService.queryEntity(bizAppointmentRecordAddParam.getOrderId()).getDeliveryTimeId());
|
|
bizAppointmentRecordAddParam.setTimeId(bizOrderService.queryEntity(bizAppointmentRecordAddParam.getOrderId()).getDeliveryTimeId());
|
|
//查询预约时间段内可预约次数
|
|
//查询预约时间段内可预约次数
|
|
//BizAppointmentTime bizAppointmentTime = bizAppointmentTimeService.getById(bizAppointmentRecordAddParam.getTimeId());
|
|
//BizAppointmentTime bizAppointmentTime = bizAppointmentTimeService.getById(bizAppointmentRecordAddParam.getTimeId());
|
|
|
|
+ getTimeCount(bizAppointmentRecordAddParam);
|
|
|
|
+ }
|
|
|
|
+
|
|
|
|
+
|
|
|
|
+
|
|
|
|
+ }
|
|
|
|
+
|
|
|
|
+ public void getTimeCount(BizAppointmentRecordAddParam bizAppointmentRecordAddParam){
|
|
|
|
+ lock.lock();
|
|
|
|
+ try{
|
|
BizOrderConfig bizOrderConfig = bizOrderConfigService.getOne(new QueryWrapper<BizOrderConfig>().lambda().
|
|
BizOrderConfig bizOrderConfig = bizOrderConfigService.getOne(new QueryWrapper<BizOrderConfig>().lambda().
|
|
eq(BizOrderConfig::getOrderId, bizAppointmentRecordAddParam.getOrderId()).
|
|
eq(BizOrderConfig::getOrderId, bizAppointmentRecordAddParam.getOrderId()).
|
|
last("limit 1"));
|
|
last("limit 1"));
|
|
if(ObjectUtil.isNotNull(bizOrderConfig)){
|
|
if(ObjectUtil.isNotNull(bizOrderConfig)){
|
|
//校验预约时间段是否预约满
|
|
//校验预约时间段是否预约满
|
|
- //查询预约时间段内的预约记录,10:已出场 11:已签收 12:自动审核 13:销售已审核 14:已取消这些状态都占用预约名额
|
|
|
|
- /*long count = this.count(new QueryWrapper<BizAppointmentRecord>().lambda().
|
|
|
|
- eq(BizAppointmentRecord::getTimeId, bizAppointmentRecordAddParam.getTimeId()).
|
|
|
|
- notIn(BizAppointmentRecord::getStatus, "10", "11", "12", "13", "14","15"));
|
|
|
|
- if(count>=bizOrderConfig.getApplyNumber()){
|
|
|
|
- throw new CommonException("该订单已经预约满!");
|
|
|
|
- }*/
|
|
|
|
if(bizOrderConfig.getApplyNumber()-bizOrderConfig.getApplyNumberAlready() <=0){
|
|
if(bizOrderConfig.getApplyNumber()-bizOrderConfig.getApplyNumberAlready() <=0){
|
|
throw new CommonException("该订单已经预约满!");
|
|
throw new CommonException("该订单已经预约满!");
|
|
}
|
|
}
|
|
}
|
|
}
|
|
- }
|
|
|
|
-
|
|
|
|
- getTimeCount(bizAppointmentRecordAddParam);
|
|
|
|
-
|
|
|
|
- }
|
|
|
|
-
|
|
|
|
- public void getTimeCount(BizAppointmentRecordAddParam bizAppointmentRecordAddParam){
|
|
|
|
- lock.lock();
|
|
|
|
- try{
|
|
|
|
//判断装卸预约次数是否满足
|
|
//判断装卸预约次数是否满足
|
|
if(ObjectUtil.isNotEmpty(bizAppointmentRecordAddParam.getLoadTimeId())){
|
|
if(ObjectUtil.isNotEmpty(bizAppointmentRecordAddParam.getLoadTimeId())){
|
|
BizLoadTime bizLoadTime = bizLoadTimeService.queryEntity(bizAppointmentRecordAddParam.getLoadTimeId());
|
|
BizLoadTime bizLoadTime = bizLoadTimeService.queryEntity(bizAppointmentRecordAddParam.getLoadTimeId());
|
|
@@ -444,6 +460,18 @@ public class BizAppointmentRecordServiceImpl extends ServiceImpl<BizAppointmentR
|
|
if(count>0){
|
|
if(count>0){
|
|
throw new CommonException("车牌号:{}已经添加过预约!",bizAppointmentRecordEditParam.getLicenseNumber());
|
|
throw new CommonException("车牌号:{}已经添加过预约!",bizAppointmentRecordEditParam.getLicenseNumber());
|
|
}
|
|
}
|
|
|
|
+
|
|
|
|
+ //查询是否存在没有回签的记录
|
|
|
|
+ QueryWrapper<BizAppointmentRecord> queryWrapper = new QueryWrapper<>();
|
|
|
|
+ queryWrapper.eq("bar.delete_flag","NOT_DELETE");
|
|
|
|
+ queryWrapper.isNull("br.unload_weight");
|
|
|
|
+ queryWrapper.eq("bo.order_type","1");
|
|
|
|
+ queryWrapper.eq("bar.`status`","10");
|
|
|
|
+ queryWrapper.eq("bar.license_number",bizAppointmentRecordEditParam.getLicenseNumber());
|
|
|
|
+ List<BizAppointmentRecord> recordList = this.getBaseMapper().getRecordList(queryWrapper);
|
|
|
|
+ if(ObjectUtil.isNotEmpty(recordList)){
|
|
|
|
+ throw new CommonException("请先填写回签信息,再进行预约!");
|
|
|
|
+ }
|
|
}
|
|
}
|
|
}
|
|
}
|
|
//校验手机号
|
|
//校验手机号
|
|
@@ -466,9 +494,14 @@ public class BizAppointmentRecordServiceImpl extends ServiceImpl<BizAppointmentR
|
|
}
|
|
}
|
|
}
|
|
}
|
|
|
|
|
|
|
|
+ //查询订单下的供应商
|
|
|
|
+ List<BizOrderSupplier> supplierList = bizOrderSupplierService.list(new QueryWrapper<BizOrderSupplier>().lambda().
|
|
|
|
+ eq(BizOrderSupplier::getOrderId, bizAppointmentRecordEditParam.getOrderId()));
|
|
|
|
+ List<String> supplierIdList = Lists.newArrayList();
|
|
|
|
+ supplierList.forEach(supplier->supplierIdList.add(supplier.getSupplierId()));
|
|
//查询车辆是否在供应商名下
|
|
//查询车辆是否在供应商名下
|
|
BizSupplierTransport transport = bizSupplierTransportService.getOne(new QueryWrapper<BizSupplierTransport>().lambda().
|
|
BizSupplierTransport transport = bizSupplierTransportService.getOne(new QueryWrapper<BizSupplierTransport>().lambda().
|
|
- eq(BizSupplierTransport::getSupplierId, bizOrder.getSupplierId()).
|
|
|
|
|
|
+ in(BizSupplierTransport::getSupplierId, supplierIdList).
|
|
eq(BizSupplierTransport::getTransportNo, bizAppointmentRecordEditParam.getLicenseNumber()).
|
|
eq(BizSupplierTransport::getTransportNo, bizAppointmentRecordEditParam.getLicenseNumber()).
|
|
eq(BizSupplierTransport::getAuditStatus,"2").
|
|
eq(BizSupplierTransport::getAuditStatus,"2").
|
|
last("limit 1"));
|
|
last("limit 1"));
|
|
@@ -487,12 +520,6 @@ public class BizAppointmentRecordServiceImpl extends ServiceImpl<BizAppointmentR
|
|
if(ObjectUtil.isNotNull(bizOrderConfig)){
|
|
if(ObjectUtil.isNotNull(bizOrderConfig)){
|
|
//校验预约时间段是否预约满
|
|
//校验预约时间段是否预约满
|
|
//查询预约时间段内的预约记录,10:已出场 11:已签收 12:自动审核 13:销售已审核 14:已取消这些状态都占用预约名额
|
|
//查询预约时间段内的预约记录,10:已出场 11:已签收 12:自动审核 13:销售已审核 14:已取消这些状态都占用预约名额
|
|
- /*long count = this.count(new QueryWrapper<BizAppointmentRecord>().lambda().
|
|
|
|
- eq(BizAppointmentRecord::getTimeId, bizAppointmentRecordEditParam.getTimeId()).
|
|
|
|
- notIn(BizAppointmentRecord::getStatus, "10", "11", "12", "13", "14","15"));
|
|
|
|
- if(count>=bizOrderConfig.getApplyNumber()+1){
|
|
|
|
- throw new CommonException("该订单已经预约满!");
|
|
|
|
- }*/
|
|
|
|
if(bizOrderConfig.getApplyNumber()-bizOrderConfig.getApplyNumberAlready() <=0){
|
|
if(bizOrderConfig.getApplyNumber()-bizOrderConfig.getApplyNumberAlready() <=0){
|
|
throw new CommonException("该订单已经预约满!");
|
|
throw new CommonException("该订单已经预约满!");
|
|
}
|
|
}
|