Commit afd2e197 by 周晓航

Merge remote-tracking branch 'origin/feature/20211021_加价购支持虚拟商品' into feature/20211021_加价购支持虚拟商品

parents 3ce75ce1 507ea3d6
...@@ -3126,6 +3126,10 @@ public class OrderSdkAdapter { ...@@ -3126,6 +3126,10 @@ public class OrderSdkAdapter {
extInfo.setNeedBonus(product.getNeedBonus()); extInfo.setNeedBonus(product.getNeedBonus());
} }
if (product.getExtInfo() != null) {
extInfo.setProductBindingCoupons(JSONArray.parseArray(product.getExtInfo(),ProductBindingCouponType.class));
}
orderItemCreateReq.setExtInfo(JSONObject.toJSONString(extInfo)); orderItemCreateReq.setExtInfo(JSONObject.toJSONString(extInfo));
// 拼单加购人信息 add by miaohui 2020.10.12 start // 拼单加购人信息 add by miaohui 2020.10.12 start
......
...@@ -271,4 +271,6 @@ public class CreateOrderProductRequest extends BaseConfig { ...@@ -271,4 +271,6 @@ public class CreateOrderProductRequest extends BaseConfig {
//积分商品活动使用总积分 //积分商品活动使用总积分
private Long score; private Long score;
private String extInfo;
} }
...@@ -2143,6 +2143,18 @@ public class OrderAdapter { ...@@ -2143,6 +2143,18 @@ public class OrderAdapter {
return this.checkAdvanceOrder(orderBean.getGmtExpect()); return this.checkAdvanceOrder(orderBean.getGmtExpect());
} }
// 加价购选择虚拟商品券包,订单完成前可申请退款,完成之后不能申请退款
if (OrderStatus.COMPLETE.equals(status) && CollectionUtils.isNotEmpty(orderBean.getProductList())) {
for (ProductBeanV1 productBeanV1 : orderBean.getProductList()){
if(StringUtils.isNotEmpty(productBeanV1.getExtInfo())){
OrderProductAddInfoDto extInfo = JSONObject.parseObject(productBeanV1.getExtInfo(), OrderProductAddInfoDto.class);
if(CollectionUtils.isNotEmpty(extInfo.getProductBindingCoupons())){
return false;
}
}
}
}
boolean canRefund = false; boolean canRefund = false;
String hkey = OrderType.TAKE_OUT.getCode().equals(orderBean.getOrderType()) ? KgdRedisKeyConstant.REFUND_CFG_TAKE_OUT : KgdRedisKeyConstant.REFUND_CFG_EAT_IN; String hkey = OrderType.TAKE_OUT.getCode().equals(orderBean.getOrderType()) ? KgdRedisKeyConstant.REFUND_CFG_TAKE_OUT : KgdRedisKeyConstant.REFUND_CFG_EAT_IN;
String configStr = redisCache.hashGet(MessageFormat.format(KgdRedisKeyConstant.ORDER_REFUND_CONFIG, orderBean.getCompanyId(), wxAppId), hkey); String configStr = redisCache.hashGet(MessageFormat.format(KgdRedisKeyConstant.ORDER_REFUND_CONFIG, orderBean.getCompanyId(), wxAppId), hkey);
...@@ -2837,6 +2849,7 @@ public class OrderAdapter { ...@@ -2837,6 +2849,7 @@ public class OrderAdapter {
createOrderProductDemoDto.setCartGoodsUid(cartGoodsDetailDto.getCartGoodsUid()); createOrderProductDemoDto.setCartGoodsUid(cartGoodsDetailDto.getCartGoodsUid());
createOrderProductDemoDto.setOriginalGoodsUid(cartGoodsDetailDto.getOriginalGoodsUid()); createOrderProductDemoDto.setOriginalGoodsUid(cartGoodsDetailDto.getOriginalGoodsUid());
createOrderProductDemoDto.setScore(cartGoodsDetailDto.getScore()); createOrderProductDemoDto.setScore(cartGoodsDetailDto.getScore());
createOrderProductDemoDto.setExtInfo(cartGoodsDetailDto.getExtInfo());
return createOrderProductDemoDto; return createOrderProductDemoDto;
} }
...@@ -4579,4 +4592,35 @@ public class OrderAdapter { ...@@ -4579,4 +4592,35 @@ public class OrderAdapter {
} }
return orderCompareAfterSaleOrder; return orderCompareAfterSaleOrder;
} }
/**
* 获取订单信息
*
* @param orderStatus
* @return
*/
public String getOrderStatusValue(Integer orderStatus) {
String name = "";
switch (orderStatus) {
case 1: {
name = "待审核";
break;
}
case 6: {
name = "审核通过";
break;
}
case 7: {
name = "审核未通过";
break;
}
case 8: {
name = "撤单";
break;
}
}
return name;
}
} }
...@@ -337,6 +337,8 @@ public class ShoppingCartGoodsDto { ...@@ -337,6 +337,8 @@ public class ShoppingCartGoodsDto {
*/ */
private String originalGoodsUid; private String originalGoodsUid;
private String extInfo;
@Data @Data
public final static class CartGoodsExtra { public final static class CartGoodsExtra {
/** /**
......
...@@ -229,7 +229,7 @@ public class OrderBusinessServiceImpl implements OrderBusinessService { ...@@ -229,7 +229,7 @@ public class OrderBusinessServiceImpl implements OrderBusinessService {
} }
//更新库存等信息 //更新库存等信息
BaseOrderResponse baseOrderResponse = updateStockAndScore(createOrderResponse.getData(), config.getBaseCreateOrderRequest().getProducts(), config.getBaseCreateOrderRequest().getActivityUpdateStockRequest(), BaseOrderResponse baseOrderResponse = updateStockAndScore(createOrderResponse.getData(), config.getBaseCreateOrderRequest().getProducts(), config.getBaseCreateOrderRequest().getActivityUpdateStockRequest(),
config.getBaseCreateOrderRequest().getAccounts(), config.getMqMessageRequest(),config.getBaseCreateOrderRequest().getMenuType(),config.getOpenId(),config.getBaseCreateOrderRequest().getTotalScore()); config.getBaseCreateOrderRequest().getAccounts(), config.getBaseCreateOrderRequest().getMenuType(),config.getOpenId(),config.getBaseCreateOrderRequest().getTotalScore());
if (!RESPONSE_SUCCESS.equals(baseOrderResponse.getErrcode())) { if (!RESPONSE_SUCCESS.equals(baseOrderResponse.getErrcode())) {
return getCreateOrderResponse(baseOrderResponse.getErrcode().toString(), baseOrderResponse.getErrmsg(), null); return getCreateOrderResponse(baseOrderResponse.getErrcode().toString(), baseOrderResponse.getErrmsg(), null);
} }
...@@ -264,7 +264,7 @@ public class OrderBusinessServiceImpl implements OrderBusinessService { ...@@ -264,7 +264,7 @@ public class OrderBusinessServiceImpl implements OrderBusinessService {
* @return * @return
*/ */
private BaseOrderResponse updateStockAndScore(OrderBeanV1 orderBean, List<CreateOrderProductRequest> products, ActivityUpdateStockRequest updateStockRequest, private BaseOrderResponse updateStockAndScore(OrderBeanV1 orderBean, List<CreateOrderProductRequest> products, ActivityUpdateStockRequest updateStockRequest,
List<CreateOrderAccountRequest> accounts, MqMessageRequest mqMessageRequest, String menuType, String openId,Long totalScore) { List<CreateOrderAccountRequest> accounts, String menuType, String openId,Long totalScore) {
//TODO 转换获取库存信息,扣减库存 //TODO 转换获取库存信息,扣减库存
UpdateStocksRequest updateStocksRequest = orderSdkAdapter.getUpdateProductStock(orderBean, products, StockChangeType.REDUCE,menuType); UpdateStocksRequest updateStocksRequest = orderSdkAdapter.getUpdateProductStock(orderBean, products, StockChangeType.REDUCE,menuType);
if (updateStocksRequest != null && CollectionUtils.isNotEmpty(updateStocksRequest.getProductStocks())) { if (updateStocksRequest != null && CollectionUtils.isNotEmpty(updateStocksRequest.getProductStocks())) {
......
...@@ -730,10 +730,6 @@ public class MCCafeOrderServiceImpl implements MCCafeOrderService { ...@@ -730,10 +730,6 @@ public class MCCafeOrderServiceImpl implements MCCafeOrderService {
CreateOrderRequest createOrderRequest = new CreateOrderRequest(); CreateOrderRequest createOrderRequest = new CreateOrderRequest();
baseCreateOrderRequest.setTrackingNo(LogThreadLocal.getTrackingNo()); baseCreateOrderRequest.setTrackingNo(LogThreadLocal.getTrackingNo());
createOrderRequest.setBaseCreateOrderRequest(baseCreateOrderRequest); createOrderRequest.setBaseCreateOrderRequest(baseCreateOrderRequest);
MqMessageRequest mqMessageRequest = new MqMessageRequest();
mqMessageRequest.setBackOrdersNotifyActivityExchange(backOrdersNotifyActivityExchange);
mqMessageRequest.setBackOrdersNotifyActivityQueue(backOrdersChangeOrderStatusConsumerQueue);
createOrderRequest.setMqMessageRequest(mqMessageRequest);
createOrderRequest.setTrackingNo(LogThreadLocal.getTrackingNo()); createOrderRequest.setTrackingNo(LogThreadLocal.getTrackingNo());
return mcCafeOrderCenterSdkService.createMCCafeOrderFlow(createOrderRequest); return mcCafeOrderCenterSdkService.createMCCafeOrderFlow(createOrderRequest);
} }
......
...@@ -285,10 +285,6 @@ public class MallOrderServiceImpl implements MallOrderService { ...@@ -285,10 +285,6 @@ public class MallOrderServiceImpl implements MallOrderService {
CreateOrderRequest createOrderRequest = new CreateOrderRequest(); CreateOrderRequest createOrderRequest = new CreateOrderRequest();
baseCreateOrderRequest.setTrackingNo(LogThreadLocal.getTrackingNo()); baseCreateOrderRequest.setTrackingNo(LogThreadLocal.getTrackingNo());
createOrderRequest.setBaseCreateOrderRequest(baseCreateOrderRequest); createOrderRequest.setBaseCreateOrderRequest(baseCreateOrderRequest);
MqMessageRequest mqMessageRequest = new MqMessageRequest();
// mqMessageRequest.setBackOrdersNotifyActivityExchange(backOrdersNotifyActivityExchange);
// mqMessageRequest.setBackOrdersNotifyActivityQueue(backOrdersChangeOrderStatusConsumerQueue);
createOrderRequest.setMqMessageRequest(mqMessageRequest);
createOrderRequest.getBaseCreateOrderRequest().setUserName(userLoginInfoDto.getNickName()); createOrderRequest.getBaseCreateOrderRequest().setUserName(userLoginInfoDto.getNickName());
createOrderRequest.setTrackingNo(LogThreadLocal.getTrackingNo()); createOrderRequest.setTrackingNo(LogThreadLocal.getTrackingNo());
return orderBusinessService.createOrderFlow(createOrderRequest); return orderBusinessService.createOrderFlow(createOrderRequest);
......
This source diff could not be displayed because it is too large. You can view the blob instead.
...@@ -139,6 +139,9 @@ public class PayServiceImpl { ...@@ -139,6 +139,9 @@ public class PayServiceImpl {
@Value("${collage.pre_order_pay.goods_tag}") @Value("${collage.pre_order_pay.goods_tag}")
private String collageGoodsTag; private String collageGoodsTag;
@Value("${query.pay.order:true}")
private Boolean queryPayOrder;
private static final Integer MULITI_RESPONSE = 200; private static final Integer MULITI_RESPONSE = 200;
private static final String SUCCESS = "SUCCESS"; private static final String SUCCESS = "SUCCESS";
...@@ -802,6 +805,9 @@ public class PayServiceImpl { ...@@ -802,6 +805,9 @@ public class PayServiceImpl {
public boolean closePrePay(OrderBeanV1 orderBean) { public boolean closePrePay(OrderBeanV1 orderBean) {
//是否支付成功 //是否支付成功
boolean paySuccess = false; boolean paySuccess = false;
if(!queryPayOrder){
return paySuccess;
}
OrderExtInfoDto extInfo = JSONObject.parseObject(orderBean.getExtInfo(), OrderExtInfoDto.class); OrderExtInfoDto extInfo = JSONObject.parseObject(orderBean.getExtInfo(), OrderExtInfoDto.class);
List<OrderPayItemResp> orderPayItemList = orderBean.getOrderPayItem(); List<OrderPayItemResp> orderPayItemList = orderBean.getOrderPayItem();
......
...@@ -98,11 +98,6 @@ public class MCCafeOrderCenterSdkServiceImpl implements MCCafeOrderCenterSdkServ ...@@ -98,11 +98,6 @@ public class MCCafeOrderCenterSdkServiceImpl implements MCCafeOrderCenterSdkServ
|| createOrderResponse.getData() == null) { || createOrderResponse.getData() == null) {
return getCreateOrderResponse(createOrderResponse.getErrcode().toString(), createOrderResponse.getErrmsg(), null); return getCreateOrderResponse(createOrderResponse.getErrcode().toString(), createOrderResponse.getErrmsg(), null);
} }
BaseOrderResponse baseOrderResponse = updateMCCafeStockAndScore(createOrderResponse.getData(), config.getBaseCreateOrderRequest().getProducts(), config.getBaseCreateOrderRequest().getActivityUpdateStockRequest(),
config.getBaseCreateOrderRequest().getAccounts(), config.getMqMessageRequest(),config.getBaseCreateOrderRequest().getMenuType());
if (!RESPONSE_SUCCESS.equals(baseOrderResponse.getErrcode())) {
return getCreateOrderResponse(baseOrderResponse.getErrcode().toString(), baseOrderResponse.getErrmsg(), null);
}
return createOrderResponse; return createOrderResponse;
} }
......
...@@ -2,9 +2,11 @@ package cn.freemud.service.thirdparty; ...@@ -2,9 +2,11 @@ package cn.freemud.service.thirdparty;
import cn.freemud.annotations.LogIgnoreFeign; import cn.freemud.annotations.LogIgnoreFeign;
import cn.freemud.base.entity.BaseResponse; import cn.freemud.base.entity.BaseResponse;
import cn.freemud.entities.dto.QueryInvoiceRepDto;
import cn.freemud.entities.dto.order.QueryInvoiceByCodesResponse; import cn.freemud.entities.dto.order.QueryInvoiceByCodesResponse;
import cn.freemud.entities.dto.pay.OrderInvoiceRequest; import cn.freemud.entities.dto.pay.OrderInvoiceRequest;
import cn.freemud.entities.dto.pay.QueryInvoiceByCodesRequest; import cn.freemud.entities.dto.pay.QueryInvoiceByCodesRequest;
import cn.freemud.entities.vo.QueryInvoiceReq;
import org.springframework.cloud.openfeign.FeignClient; import org.springframework.cloud.openfeign.FeignClient;
import org.springframework.http.MediaType; import org.springframework.http.MediaType;
import org.springframework.web.bind.annotation.PostMapping; import org.springframework.web.bind.annotation.PostMapping;
...@@ -24,7 +26,16 @@ public interface OrderServiceClient { ...@@ -24,7 +26,16 @@ public interface OrderServiceClient {
/** /**
* 查询用户订单号是否已开票 * 查询用户订单号是否已开票
*/ */
@LogIgnoreFeign(logMessage="queryByCodes") @LogIgnoreFeign(logMessage="queryInvoiceByCodes")
@PostMapping("/order/v2/invoice/queryByCodes") @PostMapping("/order/v2/invoice/queryByCodes")
BaseResponse<QueryInvoiceByCodesResponse> queryInvoiceByCodes(@RequestBody QueryInvoiceByCodesRequest request); BaseResponse<QueryInvoiceByCodesResponse> queryInvoiceByCodes(@RequestBody QueryInvoiceByCodesRequest request);
/**
* 2021年9月15日-开票历史列表接口+详情接口+发票所含订单接口-黄兆良
* 开票历史列表接口
*/
@LogIgnoreFeign(logMessage="queryInvoiceList")
@PostMapping(value = "/order/v2/invoice/list/forUser")
QueryInvoiceRepDto queryInvoiceList(@RequestBody QueryInvoiceReq queryInvoiceReq);
} }
...@@ -30,6 +30,6 @@ public class CustomerExtendClientTest { ...@@ -30,6 +30,6 @@ public class CustomerExtendClientTest {
requestDto.setStatusFlags(new ArrayList<>(0)); requestDto.setStatusFlags(new ArrayList<>(0));
requestDto.setIsProduct(1); requestDto.setIsProduct(1);
requestDto.setCouponType(0); requestDto.setCouponType(0);
GetMemberCouponListResponseDto responseDto=customerExtendClient.getMemberCouponListRequestDto(requestDto); // GetMemberCouponListResponseDto responseDto=customerExtendClient.getMemberCouponListRequestDto(requestDto);
} }
} }
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment