Showing
2 changed files
with
19 additions
and
37 deletions
| ... | @@ -22,10 +22,12 @@ import com.infoloop.tianting.clientcustomerorderservice.GetClientCustomerOrderDe | ... | @@ -22,10 +22,12 @@ import com.infoloop.tianting.clientcustomerorderservice.GetClientCustomerOrderDe |
| 22 | import com.infoloop.tianting.clientcustomerorderservice.GetClientCustomerOrderDetailsByOrderIdsRpcRequest; | 22 | import com.infoloop.tianting.clientcustomerorderservice.GetClientCustomerOrderDetailsByOrderIdsRpcRequest; |
| 23 | import com.infoloop.tianting.clientcustomerorderservice.GetClientCustomerOrdersByCustomerIdRpcRequest; | 23 | import com.infoloop.tianting.clientcustomerorderservice.GetClientCustomerOrdersByCustomerIdRpcRequest; |
| 24 | import com.infoloop.tianting.clientcustomerorderservice.MealDetail; | 24 | import com.infoloop.tianting.clientcustomerorderservice.MealDetail; |
| 25 | +import com.infoloop.tianting.clientcustomerorderservice.OnlinePayEnum; | ||
| 25 | import com.infoloop.tianting.clientcustomerorderservice.OrderOperationRecordCreation; | 26 | import com.infoloop.tianting.clientcustomerorderservice.OrderOperationRecordCreation; |
| 26 | import com.infoloop.tianting.clientcustomerorderservice.OrderOperationType; | 27 | import com.infoloop.tianting.clientcustomerorderservice.OrderOperationType; |
| 27 | import com.infoloop.tianting.clientcustomerorderservice.OrderSourceEnum; | 28 | import com.infoloop.tianting.clientcustomerorderservice.OrderSourceEnum; |
| 28 | import com.infoloop.tianting.clientcustomerorderservice.OrderStatusEnum; | 29 | import com.infoloop.tianting.clientcustomerorderservice.OrderStatusEnum; |
| 30 | +import com.infoloop.tianting.clientcustomerorderservice.OrderTypeEnum; | ||
| 29 | import com.infoloop.tianting.clientcustomerorderservice.PayStatusEnum; | 31 | import com.infoloop.tianting.clientcustomerorderservice.PayStatusEnum; |
| 30 | import com.infoloop.tianting.clientcustomerorderservice.QueryClientCustomerOrdersByConditionRpcRequest; | 32 | import com.infoloop.tianting.clientcustomerorderservice.QueryClientCustomerOrdersByConditionRpcRequest; |
| 31 | import com.infoloop.tianting.clientcustomerorderservice.QueryClientCustomerOrdersByPaginationRpcRequest; | 33 | import com.infoloop.tianting.clientcustomerorderservice.QueryClientCustomerOrdersByPaginationRpcRequest; |
| ... | @@ -524,9 +526,7 @@ public class OrderServiceRpcClient { | ... | @@ -524,9 +526,7 @@ public class OrderServiceRpcClient { |
| 524 | .setShowName(orderDetailDto.getShowName()) | 526 | .setShowName(orderDetailDto.getShowName()) |
| 525 | .setPrice(orderDetailDto.getPrice()) | 527 | .setPrice(orderDetailDto.getPrice()) |
| 526 | .setMealDetailJson(mealDetail) | 528 | .setMealDetailJson(mealDetail) |
| 527 | -// .setAdjustSkuRemark(orderDetailDto.getAdjustSkuRemark()) | ||
| 528 | .setServeStatus(ServeStatusEnum.SERVE_NOT_START) | 529 | .setServeStatus(ServeStatusEnum.SERVE_NOT_START) |
| 529 | -// .setShouldCreateAdjustSkuRemark(true) | ||
| 530 | .setShouldCreatePrice(true) | 530 | .setShouldCreatePrice(true) |
| 531 | .setShouldCreateMealDetailJson(true) | 531 | .setShouldCreateMealDetailJson(true) |
| 532 | .setSkuId(orderDetailDto.getSkuId()) | 532 | .setSkuId(orderDetailDto.getSkuId()) |
| ... | @@ -537,43 +537,33 @@ public class OrderServiceRpcClient { | ... | @@ -537,43 +537,33 @@ public class OrderServiceRpcClient { |
| 537 | .addAllAvoids(createOrderDto.getCustomerNoticeJson().getAvoids()) | 537 | .addAllAvoids(createOrderDto.getCustomerNoticeJson().getAvoids()) |
| 538 | .addAllDoctors(createOrderDto.getCustomerNoticeJson().getDoctors()) | 538 | .addAllDoctors(createOrderDto.getCustomerNoticeJson().getDoctors()) |
| 539 | .build(); | 539 | .build(); |
| 540 | - | ||
| 541 | final var menuById = menuServiceRpcClient.getMenuById(createOrderDto.getEnterpriseId(), createOrderDto.getMenuId()); | 540 | final var menuById = menuServiceRpcClient.getMenuById(createOrderDto.getEnterpriseId(), createOrderDto.getMenuId()); |
| 542 | OrderStatusEnum orderStatus = OrderStatusEnum.TO_PREPARE; | 541 | OrderStatusEnum orderStatus = OrderStatusEnum.TO_PREPARE; |
| 543 | if (menuById.getResponse().getOrderRuleJson().getModeOfPayment() == ModeOfPaymentEnum.ONLINE && menuById.getResponse().getOrderRuleJson().getCloseTimeType() == CloseTimeTypeEnum.IMMEDIATELY) { | 542 | if (menuById.getResponse().getOrderRuleJson().getModeOfPayment() == ModeOfPaymentEnum.ONLINE && menuById.getResponse().getOrderRuleJson().getCloseTimeType() == CloseTimeTypeEnum.IMMEDIATELY) { |
| 544 | orderStatus = OrderStatusEnum.PREPARING; | 543 | orderStatus = OrderStatusEnum.PREPARING; |
| 545 | } | 544 | } |
| 546 | - | ||
| 547 | final var creation = ClientCustomerOrderCreation.newBuilder() | 545 | final var creation = ClientCustomerOrderCreation.newBuilder() |
| 548 | .setShouldCreateCustomerId(createOrderDto.getShouldCreateCustomerId()) | 546 | .setShouldCreateCustomerId(createOrderDto.getShouldCreateCustomerId()) |
| 549 | - .setCustomerId(createOrderDto.getCustomerId()) | 547 | + .setShouldCreateCustomerId(true).setCustomerId(createOrderDto.getCustomerId()) |
| 550 | .setStallId(createOrderDto.getStallId()) | 548 | .setStallId(createOrderDto.getStallId()) |
| 551 | .setStatus(orderStatus) | 549 | .setStatus(orderStatus) |
| 552 | .setAddress(createOrderDto.getAddress()) | 550 | .setAddress(createOrderDto.getAddress()) |
| 553 | .setClientId(createOrderDto.getClientId()) | 551 | .setClientId(createOrderDto.getClientId()) |
| 554 | - .setShouldCreateOpenId(!LoginContextHolder.getOpenId().isEmpty()) | 552 | + .setShouldCreateOpenId(!LoginContextHolder.getOpenId().isEmpty()).setOpenId(LoginContextHolder.getOpenId()) |
| 555 | - .setOpenId(LoginContextHolder.getOpenId()) | 553 | + .setShouldCreateRoomNo(!createOrderDto.getRoomNo().isEmpty()).setRoomNo(createOrderDto.getRoomNo()) |
| 556 | - .setShouldCreateRoomNo(!createOrderDto.getRoomNo().isEmpty()) | 554 | + .setShouldCreateTableCode(createOrderDto.getCloseTimeType().equals(CloseTimeType.IMMEDIATELY) || StringUtils.isNotEmpty(createOrderDto.getTableCode())).setTableCode(createOrderDto.getTableCode() == null ? "" : createOrderDto.getTableCode()) |
| 557 | - .setRoomNo(createOrderDto.getRoomNo()) | 555 | + .setShouldCreateOnlinePay(true).setOnlinePay(createOrderDto.getOnlinePay()) |
| 558 | - .setTableCode(createOrderDto.getTableCode() == null ? "" : createOrderDto.getTableCode()) | 556 | + .setShouldCreatePayStatus(true).setPayStatus(createOrderDto.getOnlinePay() == OnlinePayEnum.ONLINE || createOrderDto.getOnlinePay() == OnlinePayEnum.LEAVE_HOSPITAL ? PayStatusEnum.TO_PAY : PayStatusEnum.SUCCEED) |
| 559 | - .setShouldCreateOnlinePay(true) | ||
| 560 | - .setOnlinePay(createOrderDto.getOnlinePay()) | ||
| 561 | - .setShouldCreatePayStatus(true) | ||
| 562 | - .setPayStatus(PayStatusEnum.TO_PAY) | ||
| 563 | .setMenuId(createOrderDto.getMenuId()) | 557 | .setMenuId(createOrderDto.getMenuId()) |
| 564 | .setTotalNum(createOrderDto.getTotalNum()) | 558 | .setTotalNum(createOrderDto.getTotalNum()) |
| 565 | - .setPayPrice(createOrderDto.getPayPrice()) | 559 | + .setShouldCreatePayPrice(createOrderDto.getOnlinePay() == OnlinePayEnum.LEAVE_HOSPITAL).setPayPrice(createOrderDto.getPayPrice()) |
| 566 | .setMealTime(createOrderDto.getMealTime().toLocalDate().atStartOfDay().toInstant(ZoneOffset.UTC).toEpochMilli()) | 560 | .setMealTime(createOrderDto.getMealTime().toLocalDate().atStartOfDay().toInstant(ZoneOffset.UTC).toEpochMilli()) |
| 567 | - .setShouldCreateTableCode(createOrderDto.getCloseTimeType().equals(CloseTimeType.IMMEDIATELY) || StringUtils.isNotEmpty(createOrderDto.getTableCode())) | 561 | + .setShouldCreatePickupCode(createOrderDto.getCloseTimeType().equals(CloseTimeType.IMMEDIATELY)).setPickupCode(generatePickupCode()) |
| 568 | - .setShouldCreatePickupCode(createOrderDto.getCloseTimeType().equals(CloseTimeType.IMMEDIATELY)) | 562 | + .setShouldCreateOrderType(true).setOrderType(menuById.getResponse().getOrderRuleJson().getCloseTimeType() == CloseTimeTypeEnum.RESERVATION ? OrderTypeEnum.DELIVERY : OrderTypeEnum.DINE_IN) |
| 569 | - .setPickupCode(generatePickupCode()) | 563 | + .setShouldCreateRemark(true).setRemark(createOrderDto.getRemark()) |
| 570 | - .setShouldCreateRemark(true) | 564 | + .setShouldCreateCustomerNoticeJson(true).setCustomerNoticeJson(customerNotice) |
| 571 | - .setRemark(createOrderDto.getRemark()) | ||
| 572 | - .setShouldCreateCustomerNoticeJson(true) | ||
| 573 | - .setCustomerNoticeJson(customerNotice) | ||
| 574 | .setCloseTimeType(createOrderDto.getCloseTimeType()) | 565 | .setCloseTimeType(createOrderDto.getCloseTimeType()) |
| 575 | - .setShouldCreateOrderDetails(true) | 566 | + .setShouldCreateOrderDetails(true).addAllOrderDetails(orderDetails) |
| 576 | - .addAllOrderDetails(orderDetails) | ||
| 577 | .build(); | 567 | .build(); |
| 578 | 568 | ||
| 579 | if (menuById.getResponse().getOrderRuleJson().getCloseTimeType() == CloseTimeTypeEnum.IMMEDIATELY) { | 569 | if (menuById.getResponse().getOrderRuleJson().getCloseTimeType() == CloseTimeTypeEnum.IMMEDIATELY) { | ... | ... |
| ... | @@ -103,8 +103,7 @@ public class OrderServiceImpl implements OrderService { | ... | @@ -103,8 +103,7 @@ public class OrderServiceImpl implements OrderService { |
| 103 | createOrderDto.setAddress(record.getDepartmentName() + record.getRoomNo()); | 103 | createOrderDto.setAddress(record.getDepartmentName() + record.getRoomNo()); |
| 104 | createOrderDto.setOnlinePay(createOrderDto.getOnlinePay()); | 104 | createOrderDto.setOnlinePay(createOrderDto.getOnlinePay()); |
| 105 | createOrderDto.setPayPrice(0); | 105 | createOrderDto.setPayPrice(0); |
| 106 | - final var menu = menuServiceRpcClient.getMenuById(operator.getEnterpriseId(), | 106 | + final var menu = menuServiceRpcClient.getMenuById(operator.getEnterpriseId(), createOrderDto.getMenuId()).getResponse(); |
| 107 | - createOrderDto.getMenuId()).getResponse(); | ||
| 108 | final var placeOrderCount = menu.getOrderRuleJson().getPlaceOrderCount(); | 107 | final var placeOrderCount = menu.getOrderRuleJson().getPlaceOrderCount(); |
| 109 | if (placeOrderCount != 0 && menuOrderCount >= placeOrderCount) { | 108 | if (placeOrderCount != 0 && menuOrderCount >= placeOrderCount) { |
| 110 | throw ClientEndExceptions.OperationForbidden.build(ErrorCodeEnum.ORDER_COUNT_LIMIT.name()); | 109 | throw ClientEndExceptions.OperationForbidden.build(ErrorCodeEnum.ORDER_COUNT_LIMIT.name()); |
| ... | @@ -126,15 +125,13 @@ public class OrderServiceImpl implements OrderService { | ... | @@ -126,15 +125,13 @@ public class OrderServiceImpl implements OrderService { |
| 126 | final var labelRefs = clientCustomerServiceRpcClient.getCustomerLabelsByCustomerId(customer.getEnterpriseId(), customer.getId()).getResponsesList(); | 125 | final var labelRefs = clientCustomerServiceRpcClient.getCustomerLabelsByCustomerId(customer.getEnterpriseId(), customer.getId()).getResponsesList(); |
| 127 | final var labelIds = labelRefs.stream().map(SingleClientCustomerLabelRefRpcResponse::getLabelId).collect(Collectors.toList()); | 126 | final var labelIds = labelRefs.stream().map(SingleClientCustomerLabelRefRpcResponse::getLabelId).collect(Collectors.toList()); |
| 128 | final var labels = deliveryRuleServiceRpcClient.GetClientLabelsByIds(customer.getEnterpriseId(), labelIds).getResponsesList(); | 127 | final var labels = deliveryRuleServiceRpcClient.GetClientLabelsByIds(customer.getEnterpriseId(), labelIds).getResponsesList(); |
| 129 | - final var avoids = labels.stream().filter(l -> l.getType() == ClientLabelTypeEnum.CLIENT_LABEL_TYPE_AVOID).map( | 128 | + final var avoids = labels.stream().filter(l -> l.getType() == ClientLabelTypeEnum.CLIENT_LABEL_TYPE_AVOID).map(SingleClientLabelRpcResponse::getName).collect(Collectors.toList()); |
| 130 | - SingleClientLabelRpcResponse::getName).collect(Collectors.toList()); | ||
| 131 | List<HisAllergy> hisAllergies = new ArrayList<>(); | 129 | List<HisAllergy> hisAllergies = new ArrayList<>(); |
| 132 | List<HisMedicalAdviceDto> origionalHisDoctors = new ArrayList<>(); | 130 | List<HisMedicalAdviceDto> origionalHisDoctors = new ArrayList<>(); |
| 133 | if (!customer.getHISCustomerId().isEmpty()) { | 131 | if (!customer.getHISCustomerId().isEmpty()) { |
| 134 | hisAllergies = meiZhongYiHeService.getHisCustomerAllergiesByCustomerId(customer.getHISCustomerId()); | 132 | hisAllergies = meiZhongYiHeService.getHisCustomerAllergiesByCustomerId(customer.getHISCustomerId()); |
| 135 | origionalHisDoctors = meiZhongYiHeService.getHisCustomerMedicalAdvicesByContractNo(record.getContractNo()); | 133 | origionalHisDoctors = meiZhongYiHeService.getHisCustomerMedicalAdvicesByContractNo(record.getContractNo()); |
| 136 | } | 134 | } |
| 137 | - | ||
| 138 | final var allergyCodes = hisAllergies.stream().map(HisAllergy::getAllergyCode).collect(Collectors.toList()); | 135 | final var allergyCodes = hisAllergies.stream().map(HisAllergy::getAllergyCode).collect(Collectors.toList()); |
| 139 | final var allLabels = deliveryRuleServiceRpcClient.getLabelsByTypes(QueryLabelsDto.builder() | 136 | final var allLabels = deliveryRuleServiceRpcClient.getLabelsByTypes(QueryLabelsDto.builder() |
| 140 | .enterpriseId(operatorLoginInfo.getEnterpriseId()) | 137 | .enterpriseId(operatorLoginInfo.getEnterpriseId()) |
| ... | @@ -142,10 +139,8 @@ public class OrderServiceImpl implements OrderService { | ... | @@ -142,10 +139,8 @@ public class OrderServiceImpl implements OrderService { |
| 142 | .build()); | 139 | .build()); |
| 143 | final var mappingAllergies = allLabels.getResponsesList().stream().filter(l -> allergyCodes.contains(l.getCode())).map(SingleClientLabelRpcResponse::getName).collect(Collectors.toList()); | 140 | final var mappingAllergies = allLabels.getResponsesList().stream().filter(l -> allergyCodes.contains(l.getCode())).map(SingleClientLabelRpcResponse::getName).collect(Collectors.toList()); |
| 144 | 141 | ||
| 145 | - final var dietDoctors = origionalHisDoctors.stream().filter(d -> d.getMedicalAdviceType().equals( | 142 | + final var dietDoctors = origionalHisDoctors.stream().filter(d -> d.getMedicalAdviceType().equals(MedicalAdviceTypeEnum.DIET)).map(HisMedicalAdviceDto::getConnotation).collect(Collectors.toList()); |
| 146 | - MedicalAdviceTypeEnum.DIET)).map(HisMedicalAdviceDto::getConnotation).collect(Collectors.toList()); | 143 | + final var doctors = labels.stream().filter(l -> l.getType() == ClientLabelTypeEnum.CLIENT_LABEL_TYPE_DOCTOR).map(SingleClientLabelRpcResponse::getName).collect(Collectors.toList()); |
| 147 | - final var doctors = labels.stream().filter(l -> l.getType() == ClientLabelTypeEnum.CLIENT_LABEL_TYPE_DOCTOR).map( | ||
| 148 | - SingleClientLabelRpcResponse::getName).collect(Collectors.toList()); | ||
| 149 | final var customerNotice = CustomerNotice.builder() | 144 | final var customerNotice = CustomerNotice.builder() |
| 150 | .avoids(Stream.of(avoids, mappingAllergies).flatMap(List::stream).collect(Collectors.toList())) | 145 | .avoids(Stream.of(avoids, mappingAllergies).flatMap(List::stream).collect(Collectors.toList())) |
| 151 | .doctors(Stream.of(doctors, dietDoctors).flatMap(List::stream).collect(Collectors.toList())) | 146 | .doctors(Stream.of(doctors, dietDoctors).flatMap(List::stream).collect(Collectors.toList())) |
| ... | @@ -155,9 +150,7 @@ public class OrderServiceImpl implements OrderService { | ... | @@ -155,9 +150,7 @@ public class OrderServiceImpl implements OrderService { |
| 155 | createOrderDto.setUpdateSource(OrderSourceEnum.STALL.getNumber()); | 150 | createOrderDto.setUpdateSource(OrderSourceEnum.STALL.getNumber()); |
| 156 | List<CreateOrderDetailDto> orderDetailDtoList = new ArrayList<>(); | 151 | List<CreateOrderDetailDto> orderDetailDtoList = new ArrayList<>(); |
| 157 | final var menuDetails = menuServiceRpcClient.queryMenuDetailsByMenuId(menu.getEnterpriseId(), operatorCreateOrderDto.getMenuId()).getResponsesList(); | 152 | final var menuDetails = menuServiceRpcClient.queryMenuDetailsByMenuId(menu.getEnterpriseId(), operatorCreateOrderDto.getMenuId()).getResponsesList(); |
| 158 | - final var skuIds = menuDetails.stream() | 153 | + final var skuIds = menuDetails.stream().map(SingleMenuDetailRpcResponse::getSkuId).collect(Collectors.toList()); |
| 159 | - .map(SingleMenuDetailRpcResponse::getSkuId) | ||
| 160 | - .collect(Collectors.toList()); | ||
| 161 | final var rpcSkus = skuServiceRpcClient.getDishSkusByIds(skuIds).getResponseList(); | 154 | final var rpcSkus = skuServiceRpcClient.getDishSkusByIds(skuIds).getResponseList(); |
| 162 | Integer totalSkuCount = 0; | 155 | Integer totalSkuCount = 0; |
| 163 | for (OperatorCreateOrderDetailDto orderDetail : operatorCreateOrderDto.getOrderDetailDtos()) { | 156 | for (OperatorCreateOrderDetailDto orderDetail : operatorCreateOrderDto.getOrderDetailDtos()) { |
| ... | @@ -206,7 +199,6 @@ public class OrderServiceImpl implements OrderService { | ... | @@ -206,7 +199,6 @@ public class OrderServiceImpl implements OrderService { |
| 206 | } | 199 | } |
| 207 | createOrderDto.setOrderDetailDtos(orderDetailDtoList); | 200 | createOrderDto.setOrderDetailDtos(orderDetailDtoList); |
| 208 | createOrderDto.setTotalNum(totalSkuCount); | 201 | createOrderDto.setTotalNum(totalSkuCount); |
| 209 | - // createOrderDto.setPayPrice(); | ||
| 210 | return orderServiceRpcClient.createOrder(createOrderDto); | 202 | return orderServiceRpcClient.createOrder(createOrderDto); |
| 211 | } | 203 | } |
| 212 | 204 | ... | ... |
-
Please register or login to post a comment