|
|
@@ -541,7 +541,7 @@ public class BillsServiceImpl extends ServiceImpl<BillsMapper, Bills> implements
|
|
|
BigDecimal measurement = bills.getMeasurement();
|
|
|
//主单应加上分单费用
|
|
|
if ("MM".equals(bills.getBillType()) && ObjectUtils.isNotNull(bills.getId())) {
|
|
|
- if (ObjectUtils.isNotNull(bills.getMblno()) && ObjectUtils.isNotNull(bills.getTemporaryId())){
|
|
|
+ if (ObjectUtils.isNotNull(bills.getMblno()) && ObjectUtils.isNotNull(bills.getTemporaryId())) {
|
|
|
Bills bills1 = new Bills();
|
|
|
bills1.setMblno(bills.getMblno());
|
|
|
bills1.setVesselId(bills.getVesselId());
|
|
|
@@ -4123,14 +4123,17 @@ public class BillsServiceImpl extends ServiceImpl<BillsMapper, Bills> implements
|
|
|
TransactionAspectSupport.currentTransactionStatus().setRollbackOnly();
|
|
|
throw new RuntimeException("生成订单编号失败");
|
|
|
}
|
|
|
+ copyBills.setBusinessType("SE");
|
|
|
+ copyBills.setBusinessTypes("HYCK");
|
|
|
+ copyBills.setSeaType("E");
|
|
|
copyBills.setBillNo((String) clientBillNo.getData());
|
|
|
- copyBills.setOperatorId(AuthUtil.getUserId());
|
|
|
- copyBills.setOperatorName(AuthUtil.getUserName());
|
|
|
- copyBills.setBillNo("");
|
|
|
+ copyBills.setCarrierId(detail.getActualShippingCompanyId());
|
|
|
+ copyBills.setCarrierCnName(detail.getActualShippingCompanyCname());
|
|
|
+ copyBills.setCarrierEnName(detail.getActualShippingCompanyEname());
|
|
|
+ copyBills.setCarrierShortName(detail.getActualShippingCompanyAbbreviation());
|
|
|
copyBills.setMblno("");
|
|
|
copyBills.setHblno("");
|
|
|
copyBills.setRefno("");
|
|
|
- copyBills.setBookingNo("");
|
|
|
copyBills.setMasterBillNo(null);
|
|
|
copyBills.setMasterId(null);
|
|
|
copyBills.setStatus(0);
|
|
|
@@ -4203,6 +4206,30 @@ public class BillsServiceImpl extends ServiceImpl<BillsMapper, Bills> implements
|
|
|
}
|
|
|
preContainersService.saveBatch(preContainers);
|
|
|
}
|
|
|
+ R<User> res = userClient.userInfoById(copyBills.getOperatorId());
|
|
|
+ if (res.isSuccess() && ObjectUtils.isNotNull(res.getData())) {
|
|
|
+ LocalDateTime now = LocalDateTime.now();
|
|
|
+ DateTimeFormatter formatter = DateTimeFormatter.ofPattern("yyyy-MM-dd HH:mm:ss");
|
|
|
+ String formatted = now.format(formatter);
|
|
|
+ Message sendMessage = new Message();
|
|
|
+ sendMessage.setParameter(bills.getId() + "");
|
|
|
+ sendMessage.setUserName(AuthUtil.getUserName());
|
|
|
+ sendMessage.setUserId(null);
|
|
|
+ sendMessage.setToUserId(res.getData().getId());
|
|
|
+ sendMessage.setToUserName(res.getData().getName());
|
|
|
+ sendMessage.setMessageType(1);
|
|
|
+ sendMessage.setTenantId(AuthUtil.getTenantId());
|
|
|
+ sendMessage.setCreateUser(null);
|
|
|
+ sendMessage.setCreateTime(new Date());
|
|
|
+ sendMessage.setUrl("/iosBasicData/SeafreightExportF/bills/index");
|
|
|
+ sendMessage.setPageLabel("海运出口");
|
|
|
+ sendMessage.setPageStatus("this.$store.getters.domSaleStatus");
|
|
|
+ sendMessage.setMessageBody("您有新的预定舱,请及时待处理!单号:" + bills.getBillNo() + "时间:" + formatted);
|
|
|
+ R save = messageClient.save(sendMessage);
|
|
|
+ if (!save.isSuccess()) {
|
|
|
+ throw new SecurityException("发送消息失败");
|
|
|
+ }
|
|
|
+ }
|
|
|
return R.data(copyBills);
|
|
|
}
|
|
|
|
|
|
@@ -4443,35 +4470,33 @@ public class BillsServiceImpl extends ServiceImpl<BillsMapper, Bills> implements
|
|
|
|
|
|
@Override
|
|
|
public R sendMessageBooking(Bills bills) {
|
|
|
- //发送消息
|
|
|
- R<String> res = sysClient.getRoleIds(bills.getBranchId(), "业务员");
|
|
|
- if (res.isSuccess() && ObjectUtils.isNotNull(res.getData())){
|
|
|
- R<List<User>> userListR = userClient.listUserByRoleId(res.getData(),AuthUtil.getTenantId(),bills.getBranchId());
|
|
|
- if (userListR.isSuccess() && ObjectUtils.isNotNull(userListR.getData())) {
|
|
|
+ if (ObjectUtils.isNotNull(bills.getCustomerServiceId())) {
|
|
|
+ R<User> res = userClient.userInfoById(bills.getCustomerServiceId());
|
|
|
+ if (res.isSuccess() && ObjectUtils.isNotNull(res.getData())) {
|
|
|
LocalDateTime now = LocalDateTime.now();
|
|
|
DateTimeFormatter formatter = DateTimeFormatter.ofPattern("yyyy-MM-dd HH:mm:ss");
|
|
|
String formatted = now.format(formatter);
|
|
|
- for (User datum : userListR.getData()){
|
|
|
- Message sendMessage = new Message();
|
|
|
- sendMessage.setParameter(bills.getId() + "");
|
|
|
- sendMessage.setUserName(AuthUtil.getUserName());
|
|
|
- sendMessage.setUserId(null);
|
|
|
- sendMessage.setToUserId(datum.getId());
|
|
|
- sendMessage.setToUserName(datum.getName());
|
|
|
- sendMessage.setMessageType(1);
|
|
|
- sendMessage.setTenantId(AuthUtil.getTenantId());
|
|
|
- sendMessage.setCreateUser(null);
|
|
|
- sendMessage.setCreateTime(new Date());
|
|
|
- sendMessage.setUrl("/iosBasicData/OceanFreightImport/bills/index");
|
|
|
- sendMessage.setPageLabel("海运进口");
|
|
|
- sendMessage.setPageStatus("this.$store.getters.domSaleStatus");
|
|
|
- sendMessage.setMessageBody("您有新的预定舱,请及时待处理!单号:" + bills.getBillNo() + "时间:" + formatted);
|
|
|
- R save = messageClient.save(sendMessage);
|
|
|
- if (!save.isSuccess()) {
|
|
|
- throw new SecurityException("发送消息失败");
|
|
|
- }
|
|
|
+ Message sendMessage = new Message();
|
|
|
+ sendMessage.setParameter(bills.getId() + "");
|
|
|
+ sendMessage.setUserName(AuthUtil.getUserName());
|
|
|
+ sendMessage.setUserId(null);
|
|
|
+ sendMessage.setToUserId(res.getData().getId());
|
|
|
+ sendMessage.setToUserName(res.getData().getName());
|
|
|
+ sendMessage.setMessageType(1);
|
|
|
+ sendMessage.setTenantId(AuthUtil.getTenantId());
|
|
|
+ sendMessage.setCreateUser(null);
|
|
|
+ sendMessage.setCreateTime(new Date());
|
|
|
+ sendMessage.setUrl("/iosBasicData/SeafreightExportF/bills/index");
|
|
|
+ sendMessage.setPageLabel("海运出口");
|
|
|
+ sendMessage.setPageStatus("this.$store.getters.domSaleStatus");
|
|
|
+ sendMessage.setMessageBody("您有新的预定舱,请及时待处理!单号:" + bills.getBillNo() + "时间:" + formatted);
|
|
|
+ R save = messageClient.save(sendMessage);
|
|
|
+ if (!save.isSuccess()) {
|
|
|
+ throw new SecurityException("发送消息失败");
|
|
|
}
|
|
|
}
|
|
|
+ } else {
|
|
|
+ throw new RuntimeException("请选择负责人");
|
|
|
}
|
|
|
return R.data("操作成功");
|
|
|
}
|