Skip to content

O
order-group
Commit 90cea014 by 张洪旺
Options

fix 循环依赖

parent e7eb1f71
Showing with 348 additions and 348 deletions
order-application-service/src/main/java/cn/freemud/fuyou/service/processor/AliPayEventProcessor.java
......@@ -83,60 +83,60 @@ public class AliPayEventProcessor extends AbstractProcessor {
//10216 扫呗公众号支付
//10217 商盟支付
//10300 扫呗支付宝
//private final PaymentNewService paymentNewService;
//
// protected AliPayEventProcessor(OrderSdkService orderSdkService, PaymentService paymentService, PaymentNewService paymentNewService) {
// super(orderSdkService, paymentService);
// this.paymentNewService = paymentNewService;
// }
//
// @Override
// BaseResponse doProcess(DiscountRequest request) {
// BaseResponse baseResponse =new BaseResponse();
// baseResponse.setCode(ResponseResultEnum.SUCCESS.getCode());
// OrderInfoReqs orderInfoReqs = request.getOrderInfoReqs();
//
// CodePayRequest codePayRequest =new CodePayRequest();
// codePayRequest.setCode(request.getCode());
// codePayRequest.setBody(orderInfoReqs.getStoreName());
// codePayRequest.setBusinessDate(DateUtil.convert2String(new Date(), DateUtil.FORMAT_YYYY_MM_DD_HHMMSS));
// codePayRequest.setStationId("1");
// codePayRequest.setOperatorId("1");
// //codePayRequest.setClientCode(10095);
// //codePayRequest.setCode("10102");
// codePayRequest.setAmount(request.getPayAmount());
// codePayRequest.setPartnerId(orderInfoReqs.getPartnerId());
// codePayRequest.setStoreId(orderInfoReqs.getStoreId());
// codePayRequest.setFrontTransId(orderInfoReqs.getOrderCode());
// codePayRequest.setVer("2");
// // codePayRequest.setClientCode(10095L);
// codePayRequest.setTransId(orderInfoReqs.getOrderCode());
// codePayRequest.setProducts(convertPayProduct(request.getOrderItemList()));
// com.freemud.application.sdk.api.base.BaseResponse<CodePayResponse> codePayResponseBaseResponse = paymentNewService.codePay(codePayRequest, LogThreadLocal.getTrackingNo());
// log.info("aliPay.paymentFeignClient.codePay,request:{},response:{}", JSON.toJSONString(codePayRequest),JSON.toJSONString(codePayResponseBaseResponse));
// if(ObjectUtils.notEqual(ResponseResultEnum.SUCCESS.getCode(),codePayResponseBaseResponse.getCode()) ||
// ObjectUtils.notEqual(ResponseResultEnum.SUCCESS.getCode(),codePayResponseBaseResponse.getData().getCode()) ||
// ObjectUtils.notEqual(ResponseResultEnum.SUCCESS.getCode(),codePayResponseBaseResponse.getData().getData().getResultCode())
// ){
// baseResponse.setCode(codePayResponseBaseResponse.getCode());
// baseResponse.setMessage(codePayResponseBaseResponse.getMessage());
// return baseResponse;
// }
// request.setFmId(codePayResponseBaseResponse.getData().getData().getFmId());
// return baseResponse;
// }
//
//
//
// @Override
// OrderSettlementReq getOrderSettlement(DiscountRequest request) {
// OrderInfoReqs orderInfoReqs = request.getOrderInfoReqs();
// return buildOrderSettlement("支付宝支付", OrderSettlementType.ALIPAY, true, orderInfoReqs, request);
//
// }
//
// @Override
// public Integer getEvent() {
// return PayChannelEnum.ALIPAY.getCode();
// }
private final PaymentNewService paymentNewService;
protected AliPayEventProcessor(OrderSdkService orderSdkService, PaymentService paymentService, PaymentNewService paymentNewService) {
super(orderSdkService, paymentService);
this.paymentNewService = paymentNewService;
}
@Override
BaseResponse doProcess(DiscountRequest request) {
BaseResponse baseResponse =new BaseResponse();
baseResponse.setCode(ResponseResultEnum.SUCCESS.getCode());
OrderInfoReqs orderInfoReqs = request.getOrderInfoReqs();
CodePayRequest codePayRequest =new CodePayRequest();
codePayRequest.setCode(request.getCode());
codePayRequest.setBody(orderInfoReqs.getStoreName());
codePayRequest.setBusinessDate(DateUtil.convert2String(new Date(), DateUtil.FORMAT_YYYY_MM_DD_HHMMSS));
codePayRequest.setStationId("1");
codePayRequest.setOperatorId("1");
//codePayRequest.setClientCode(10095);
//codePayRequest.setCode("10102");
codePayRequest.setAmount(request.getPayAmount());
codePayRequest.setPartnerId(orderInfoReqs.getPartnerId());
codePayRequest.setStoreId(orderInfoReqs.getStoreId());
codePayRequest.setFrontTransId(orderInfoReqs.getOrderCode());
codePayRequest.setVer("2");
// codePayRequest.setClientCode(10095L);
codePayRequest.setTransId(orderInfoReqs.getOrderCode());
codePayRequest.setProducts(convertPayProduct(request.getOrderItemList()));
com.freemud.application.sdk.api.base.BaseResponse<CodePayResponse> codePayResponseBaseResponse = paymentNewService.codePay(codePayRequest, LogThreadLocal.getTrackingNo());
log.info("aliPay.paymentFeignClient.codePay,request:{},response:{}", JSON.toJSONString(codePayRequest),JSON.toJSONString(codePayResponseBaseResponse));
if(ObjectUtils.notEqual(ResponseResultEnum.SUCCESS.getCode(),codePayResponseBaseResponse.getCode()) ||
ObjectUtils.notEqual(ResponseResultEnum.SUCCESS.getCode(),codePayResponseBaseResponse.getData().getCode()) ||
ObjectUtils.notEqual(ResponseResultEnum.SUCCESS.getCode(),codePayResponseBaseResponse.getData().getData().getResultCode())
){
baseResponse.setCode(codePayResponseBaseResponse.getCode());
baseResponse.setMessage(codePayResponseBaseResponse.getMessage());
return baseResponse;
}
request.setFmId(codePayResponseBaseResponse.getData().getData().getFmId());
return baseResponse;
}
@Override
OrderSettlementReq getOrderSettlement(DiscountRequest request) {
OrderInfoReqs orderInfoReqs = request.getOrderInfoReqs();
return buildOrderSettlement("支付宝支付", OrderSettlementType.ALIPAY, true, orderInfoReqs, request);
}
@Override
public Integer getEvent() {
return PayChannelEnum.ALIPAY.getCode();
}
}
order-application-service/src/main/java/cn/freemud/fuyou/service/processor/CashEventProcessor.java
......@@ -22,30 +22,30 @@ import static cn.freemud.management.util.ResponseCodeEnum.SUCCESS;
public class CashEventProcessor extends AbstractProcessor {
// protected CashEventProcessor(OrderSdkService orderSdkService, PaymentService paymentService) {
// //super(orderSdkService, paymentService);
// }
//
// @Override
// BaseResponse doProcess(DiscountRequest request) {
// BaseResponse baseResponse =new BaseResponse();
// baseResponse.setCode(SUCCESS.code);
// return baseResponse;
// }
//
// public OrderInfoReqs getOrderByThirdOrderCode(String thirdOrderCode, String orderClient) {
// return super.getOrderByThirdOrderCode(thirdOrderCode, orderClient);
// }
//
// @Override
// OrderSettlementReq getOrderSettlement(DiscountRequest request) {
// OrderInfoReqs orderInfoReqs = request.getOrderInfoReqs();
// return buildOrderSettlement("富有现金支付", OrderSettlementType.CASH, false, orderInfoReqs, request);
// }
//
// @Override
// public Integer getEvent() {
// return PayChannelEnum.CASH.getCode();
// }
protected CashEventProcessor(OrderSdkService orderSdkService, PaymentService paymentService) {
super(orderSdkService, paymentService);
}
@Override
BaseResponse doProcess(DiscountRequest request) {
BaseResponse baseResponse =new BaseResponse();
baseResponse.setCode(SUCCESS.code);
return baseResponse;
}
public OrderInfoReqs getOrderByThirdOrderCode(String thirdOrderCode, String orderClient) {
return super.getOrderByThirdOrderCode(thirdOrderCode, orderClient);
}
@Override
OrderSettlementReq getOrderSettlement(DiscountRequest request) {
OrderInfoReqs orderInfoReqs = request.getOrderInfoReqs();
return buildOrderSettlement("富有现金支付", OrderSettlementType.CASH, false, orderInfoReqs, request);
}
@Override
public Integer getEvent() {
return PayChannelEnum.CASH.getCode();
}
}
order-application-service/src/main/java/cn/freemud/fuyou/service/processor/CouponEventProcessor.java
......@@ -35,76 +35,76 @@ import static cn.freemud.management.util.ResponseCodeEnum.SUCCESS;
public class CouponEventProcessor extends AbstractProcessor {
// private final OfflineCouponSdkService offlineCouponSdkService;
//
// protected CouponEventProcessor(OrderSdkService orderSdkService, PaymentService paymentService, OfflineCouponSdkService offlineCouponSdkService) {
// //super(orderSdkService, paymentService);
// this.offlineCouponSdkService = offlineCouponSdkService;
// }
//
//
// @Override
// com.freemud.application.sdk.api.ordercenter.response.BaseResponse doProcess(DiscountRequest request) {
// com.freemud.application.sdk.api.ordercenter.response.BaseResponse baseResponse = new com.freemud.application.sdk.api.ordercenter.response.BaseResponse();
// baseResponse.setCode(SUCCESS.code);
// OrderInfoReqs orderInfoReqs = request.getOrderInfoReqs();
// //1.核销券
// CouponRequest couponCodeVerificationDto = new CouponRequest();
// couponCodeVerificationDto.setVer(Integer.valueOf(Version.VERSION_1));
// couponCodeVerificationDto.setReqtype(71);
// couponCodeVerificationDto.setPartnerId(Integer.parseInt(orderInfoReqs.getPartnerId()));
// //自取：pickup，外送：delivery，麦咖啡微信小程序：mocoffee_wx，麦咖啡支付宝小程序：mocoffee_zfb
// couponCodeVerificationDto.setChannel("pickup");
// couponCodeVerificationDto.setStation_id(request.getPosId());
// couponCodeVerificationDto.setOperator_id("-1");
// couponCodeVerificationDto.setStore_id(orderInfoReqs.getStoreId());
// //核销不需要核销通知
// //couponCodeVerificationDto.setAppFlag("kgd.N");
// // 订单号 替换成唯一序号
// couponCodeVerificationDto.setTrans_id(orderInfoReqs.getOrderCode());
// couponCodeVerificationDto.setBusiness_date(cn.freemud.base.util.DateUtil.convert2Str(new Date(), cn.freemud.base.util.DateUtil.FORMAT_yyyyMMdd));
// List<TransactionVO> transactions = new ArrayList<>();
// TransactionVO couponCodeVerificationTransDto = new TransactionVO();
// couponCodeVerificationTransDto.setCode(request.getCoupon());
// couponCodeVerificationTransDto.setTotalAmount(request.getPayAmount());
// List<ProductRedeemVO> productRedeemVOS = convertOrderItemCreateReq(request.getOrderItemList());
// couponCodeVerificationTransDto.setProducts(productRedeemVOS);
// transactions.add(couponCodeVerificationTransDto);
// couponCodeVerificationDto.setTransactions(transactions);
// final BaseResponse<CouponRedeemResponse> couponRedeemResponseBaseResponse = offlineCouponSdkService.couponRedeem(couponCodeVerificationDto, LogThreadLocal.getTrackingNo());
// if (ObjectUtils.notEqual(FMStatusCode.SUCCESS.getCode(), couponRedeemResponseBaseResponse.getCode())) {
// baseResponse.setCode(couponRedeemResponseBaseResponse.getCode());
// baseResponse.setMessage(couponRedeemResponseBaseResponse.getMessage());
// }
// return baseResponse;
// }
//
// private List<ProductRedeemVO> convertOrderItemCreateReq(List<OrderItemCreateReq> orderItemList) {
// List<ProductRedeemVO> products = new ArrayList<>();
// if (CollectionUtils.isEmpty(orderItemList)) {
// return products;
// }
// for (int i = 0; i < orderItemList.size(); i++) {
// //商品券核销核销参数
// ProductRedeemVO couponCodeVerificationProductDto = new ProductRedeemVO();
// couponCodeVerificationProductDto.setPid(UUID.randomUUID().toString());
// couponCodeVerificationProductDto.setConsume_num(orderItemList.get(i).getProductQuantity());
// couponCodeVerificationProductDto.setSeq(i);
// // couponCodeVerificationProductDto.setMerchantProductId(orderItemList.get(i).getProductId());
// products.add(couponCodeVerificationProductDto);
// }
// return products;
// }
//
//
// @Override
// OrderSettlementReq getOrderSettlement(DiscountRequest request) {
// OrderInfoReqs orderInfoReqs = request.getOrderInfoReqs();
// return buildOrderSettlement("富有优惠券", OrderSettlementType.COUPON, false, orderInfoReqs, request);
// }
//
// @Override
// public Integer getEvent() {
// return PayChannelEnum.COUPON.getCode();
// }
private final OfflineCouponSdkService offlineCouponSdkService;
protected CouponEventProcessor(OrderSdkService orderSdkService, PaymentService paymentService, OfflineCouponSdkService offlineCouponSdkService) {
super(orderSdkService, paymentService);
this.offlineCouponSdkService = offlineCouponSdkService;
}
@Override
com.freemud.application.sdk.api.ordercenter.response.BaseResponse doProcess(DiscountRequest request) {
com.freemud.application.sdk.api.ordercenter.response.BaseResponse baseResponse = new com.freemud.application.sdk.api.ordercenter.response.BaseResponse();
baseResponse.setCode(SUCCESS.code);
OrderInfoReqs orderInfoReqs = request.getOrderInfoReqs();
//1.核销券
CouponRequest couponCodeVerificationDto = new CouponRequest();
couponCodeVerificationDto.setVer(Integer.valueOf(Version.VERSION_1));
couponCodeVerificationDto.setReqtype(71);
couponCodeVerificationDto.setPartnerId(Integer.parseInt(orderInfoReqs.getPartnerId()));
//自取：pickup，外送：delivery，麦咖啡微信小程序：mocoffee_wx，麦咖啡支付宝小程序：mocoffee_zfb
couponCodeVerificationDto.setChannel("pickup");
couponCodeVerificationDto.setStation_id(request.getPosId());
couponCodeVerificationDto.setOperator_id("-1");
couponCodeVerificationDto.setStore_id(orderInfoReqs.getStoreId());
//核销不需要核销通知
//couponCodeVerificationDto.setAppFlag("kgd.N");
// 订单号 替换成唯一序号
couponCodeVerificationDto.setTrans_id(orderInfoReqs.getOrderCode());
couponCodeVerificationDto.setBusiness_date(cn.freemud.base.util.DateUtil.convert2Str(new Date(), cn.freemud.base.util.DateUtil.FORMAT_yyyyMMdd));
List<TransactionVO> transactions = new ArrayList<>();
TransactionVO couponCodeVerificationTransDto = new TransactionVO();
couponCodeVerificationTransDto.setCode(request.getCoupon());
couponCodeVerificationTransDto.setTotalAmount(request.getPayAmount());
List<ProductRedeemVO> productRedeemVOS = convertOrderItemCreateReq(request.getOrderItemList());
couponCodeVerificationTransDto.setProducts(productRedeemVOS);
transactions.add(couponCodeVerificationTransDto);
couponCodeVerificationDto.setTransactions(transactions);
final BaseResponse<CouponRedeemResponse> couponRedeemResponseBaseResponse = offlineCouponSdkService.couponRedeem(couponCodeVerificationDto, LogThreadLocal.getTrackingNo());
if (ObjectUtils.notEqual(FMStatusCode.SUCCESS.getCode(), couponRedeemResponseBaseResponse.getCode())) {
baseResponse.setCode(couponRedeemResponseBaseResponse.getCode());
baseResponse.setMessage(couponRedeemResponseBaseResponse.getMessage());
}
return baseResponse;
}
private List<ProductRedeemVO> convertOrderItemCreateReq(List<OrderItemCreateReq> orderItemList) {
List<ProductRedeemVO> products = new ArrayList<>();
if (CollectionUtils.isEmpty(orderItemList)) {
return products;
}
for (int i = 0; i < orderItemList.size(); i++) {
//商品券核销核销参数
ProductRedeemVO couponCodeVerificationProductDto = new ProductRedeemVO();
couponCodeVerificationProductDto.setPid(UUID.randomUUID().toString());
couponCodeVerificationProductDto.setConsume_num(orderItemList.get(i).getProductQuantity());
couponCodeVerificationProductDto.setSeq(i);
// couponCodeVerificationProductDto.setMerchantProductId(orderItemList.get(i).getProductId());
products.add(couponCodeVerificationProductDto);
}
return products;
}
@Override
OrderSettlementReq getOrderSettlement(DiscountRequest request) {
OrderInfoReqs orderInfoReqs = request.getOrderInfoReqs();
return buildOrderSettlement("富有优惠券", OrderSettlementType.COUPON, false, orderInfoReqs, request);
}
@Override
public Integer getEvent() {
return PayChannelEnum.COUPON.getCode();
}
}
order-application-service/src/main/java/cn/freemud/fuyou/service/processor/EventProcessor.java
......@@ -9,21 +9,21 @@ import ma.glasnost.orika.impl.DefaultMapperFactory;
public interface EventProcessor {
// MapperFacade mapper = new DefaultMapperFactory.Builder().build().getMapperFacade();
//
// /**
// * 处理
// *
// * @param request
// */
// BaseResponse process(DiscountRequest request);
//
//
// /**
// * 消息类型
// * {@link PayChannelEnum}
// *
// * @return
// */
// Integer getEvent();
MapperFacade mapper = new DefaultMapperFactory.Builder().build().getMapperFacade();
/**
* 处理
*
* @param request
*/
BaseResponse process(DiscountRequest request);
/**
* 消息类型
* {@link PayChannelEnum}
*
* @return
*/
Integer getEvent();
}
order-application-service/src/main/java/cn/freemud/fuyou/service/processor/EventProcessorRegister.java
......@@ -16,27 +16,27 @@ import java.util.Map;
public class EventProcessorRegister extends ApplicationObjectSupport {
//Collections.emptyMap()
// private static Map<Integer, EventProcessor> processorMap = Maps.newHashMap();
//
// @PostConstruct
// private void init() {
// Map<String, EventProcessor> beans = getApplicationContext().getBeansOfType(EventProcessor.class);
// log.info("EventProcessorRegister:bean:{}",beans);
// if (!CollectionUtils.isEmpty(beans)) {
// beans.values().stream().forEach((EventProcessor obj) -> {
// processorMap.put(obj.getEvent(), obj);
// }
//
//
// );
// }
// }
//
// public EventProcessor getEventProcessor(Integer event) {
// //todo dev环境init初始化 beans =null
// if(processorMap.get(event) ==null){
// init();
// }
// return processorMap.get(event);
// }
private static Map<Integer, EventProcessor> processorMap = Maps.newHashMap();
@PostConstruct
private void init() {
Map<String, EventProcessor> beans = getApplicationContext().getBeansOfType(EventProcessor.class);
log.info("EventProcessorRegister:bean:{}",beans);
if (!CollectionUtils.isEmpty(beans)) {
beans.values().stream().forEach((EventProcessor obj) -> {
processorMap.put(obj.getEvent(), obj);
}
);
}
}
public EventProcessor getEventProcessor(Integer event) {
//todo dev环境init初始化 beans =null
if(processorMap.get(event) ==null){
init();
}
return processorMap.get(event);
}
}
order-application-service/src/main/java/cn/freemud/fuyou/service/processor/IntegralEventProcessor.java
......@@ -25,53 +25,53 @@ import static cn.freemud.management.util.ResponseCodeEnum.SUCCESS;
@Slf4j
public class IntegralEventProcessor extends AbstractProcessor {
// private final ScoreFeignClient scoreFeignClient;
//
// protected IntegralEventProcessor(OrderSdkService orderSdkService, PaymentService paymentService, ScoreFeignClient scoreFeignClient) {
// //super(orderSdkService, paymentService);
// this.scoreFeignClient = scoreFeignClient;
// }
//
//
// @Override
// BaseResponse doProcess(DiscountRequest request) {
// BaseResponse baseResponse = new BaseResponse();
// baseResponse.setCode(SUCCESS.code);
// final OrderInfoReqs order = request.getOrderInfoReqs();
//
// ScorePayRequest scorePayRequest = new ScorePayRequest();
// scorePayRequest.setPartnerId(order.getPartnerId());
// scorePayRequest.setChangeScore(request.getScore().intValue());
// scorePayRequest.setMemberId(order.getUserId());
// scorePayRequest.setOrderId(order.getOrderCode());
// scorePayRequest.setOperationType(14);
// scorePayRequest.setIdempotencyBussinessType("5");
// scorePayRequest.setChangeScore(request.getScore().intValue());
// scorePayRequest.setIdempotencyBussinessId(order.getOrderCode());
// cn.freemud.base.entity.BaseResponse<UpdateScoreResponse> responseBaseResponse = scoreFeignClient.pay(scorePayRequest);
// log.info("scoreFeignClient.pay,order:{},response:{}", order.getOrderCode(), JSON.toJSONString(responseBaseResponse));
// if (ObjectUtils.notEqual(SUCCESS.code, responseBaseResponse.getCode())) {
// baseResponse.setCode(responseBaseResponse.getCode());
// baseResponse.setMessage(responseBaseResponse.getMessage());
// }
// return baseResponse;
// }
//
//
// @Override
// OrderSettlementReq getOrderSettlement(DiscountRequest request) {
// OrderInfoReqs orderInfoReqs = request.getOrderInfoReqs();
// return buildOrderSettlement("富有积分兑换", OrderSettlementType.POINTS, true, orderInfoReqs, request);
// }
//
//
// @Override
// protected boolean postProcessors(DiscountRequest request) {
// return false;
// }
//
// @Override
// public Integer getEvent() {
// return PayChannelEnum.INTEGRAL.getCode();
// }
private final ScoreFeignClient scoreFeignClient;
protected IntegralEventProcessor(OrderSdkService orderSdkService, PaymentService paymentService, ScoreFeignClient scoreFeignClient) {
super(orderSdkService, paymentService);
this.scoreFeignClient = scoreFeignClient;
}
@Override
BaseResponse doProcess(DiscountRequest request) {
BaseResponse baseResponse = new BaseResponse();
baseResponse.setCode(SUCCESS.code);
final OrderInfoReqs order = request.getOrderInfoReqs();
ScorePayRequest scorePayRequest = new ScorePayRequest();
scorePayRequest.setPartnerId(order.getPartnerId());
scorePayRequest.setChangeScore(request.getScore().intValue());
scorePayRequest.setMemberId(order.getUserId());
scorePayRequest.setOrderId(order.getOrderCode());
scorePayRequest.setOperationType(14);
scorePayRequest.setIdempotencyBussinessType("5");
scorePayRequest.setChangeScore(request.getScore().intValue());
scorePayRequest.setIdempotencyBussinessId(order.getOrderCode());
cn.freemud.base.entity.BaseResponse<UpdateScoreResponse> responseBaseResponse = scoreFeignClient.pay(scorePayRequest);
log.info("scoreFeignClient.pay,order:{},response:{}", order.getOrderCode(), JSON.toJSONString(responseBaseResponse));
if (ObjectUtils.notEqual(SUCCESS.code, responseBaseResponse.getCode())) {
baseResponse.setCode(responseBaseResponse.getCode());
baseResponse.setMessage(responseBaseResponse.getMessage());
}
return baseResponse;
}
@Override
OrderSettlementReq getOrderSettlement(DiscountRequest request) {
OrderInfoReqs orderInfoReqs = request.getOrderInfoReqs();
return buildOrderSettlement("富有积分兑换", OrderSettlementType.POINTS, true, orderInfoReqs, request);
}
@Override
protected boolean postProcessors(DiscountRequest request) {
return false;
}
@Override
public Integer getEvent() {
return PayChannelEnum.INTEGRAL.getCode();
}
}
order-application-service/src/main/java/cn/freemud/fuyou/service/processor/SvcEventProcessor.java
......@@ -27,59 +27,59 @@ import java.util.Date;
@Component
@Slf4j
public class SvcEventProcessor extends AbstractProcessor {
// private final PaymentNewService paymentNewService;
//
// protected SvcEventProcessor(OrderSdkService orderSdkService, PaymentService paymentService,
// PaymentNewService paymentNewService) {
// //super(orderSdkService, paymentService);
// this.paymentNewService = paymentNewService;
// }
//
//
// @Override
// BaseResponse doProcess(DiscountRequest request)
// {
// BaseResponse baseResponse =new BaseResponse();
// baseResponse.setCode(ResponseResultEnum.SUCCESS.getCode());
// OrderInfoReqs orderInfoReqs = request.getOrderInfoReqs();
//
// CodePayRequest codePayRequest =new CodePayRequest();
// codePayRequest.setCode(request.getCode());
// codePayRequest.setAmount(request.getPayAmount());
// codePayRequest.setStoreId(orderInfoReqs.getStoreId());
// codePayRequest.setFrontTransId(orderInfoReqs.getOrderCode());
// codePayRequest.setProducts(convertPayProduct(request.getOrderItemList()));
// codePayRequest.setBody(orderInfoReqs.getStoreName());
// codePayRequest.setBusinessDate(DateUtil.convert2String(new Date(), DateUtil.FORMAT_YYYY_MM_DD_HHMMSS));
// codePayRequest.setStationId("1");
// codePayRequest.setOperatorId("1");
// codePayRequest.setVer("2");
// //codePayRequest.setCode("10102");
// codePayRequest.setPartnerId(orderInfoReqs.getPartnerId());
// codePayRequest.setTransId(orderInfoReqs.getOrderCode());
//
// final com.freemud.application.sdk.api.base.BaseResponse<CodePayResponse> codePayResponseBaseResponse = paymentNewService.codePay(codePayRequest, LogThreadLocal.getTrackingNo());
// log.info("SVC.paymentFeignClient.codePay,request:{},response:{}", JSON.toJSONString(codePayRequest),JSON.toJSONString(codePayResponseBaseResponse));
// if(ObjectUtils.notEqual(ResponseResultEnum.SUCCESS.getCode(),codePayResponseBaseResponse.getCode()) ||
// ObjectUtils.notEqual(ResponseResultEnum.SUCCESS.getCode(),codePayResponseBaseResponse.getData().getCode()) ||
// ObjectUtils.notEqual(ResponseResultEnum.SUCCESS.getCode(),codePayResponseBaseResponse.getData().getData().getResultCode())
// ){
// baseResponse.setCode(codePayResponseBaseResponse.getCode());
// baseResponse.setMessage(codePayResponseBaseResponse.getMessage());
// return baseResponse;
// }
// request.setFmId(codePayResponseBaseResponse.getData().getData().getFmId());
// return baseResponse;
// }
//
// @Override
// OrderSettlementReq getOrderSettlement(DiscountRequest request) {
// OrderInfoReqs orderInfoReqs = request.getOrderInfoReqs();
// return buildOrderSettlement("SVV支付", OrderSettlementType.SVC, true, orderInfoReqs, request);
// }
//
// @Override
// public Integer getEvent() {
// return PayChannelEnum.SVC.getCode();
// }
private final PaymentNewService paymentNewService;
protected SvcEventProcessor(OrderSdkService orderSdkService, PaymentService paymentService,
PaymentNewService paymentNewService) {
super(orderSdkService, paymentService);
this.paymentNewService = paymentNewService;
}
@Override
BaseResponse doProcess(DiscountRequest request)
{
BaseResponse baseResponse =new BaseResponse();
baseResponse.setCode(ResponseResultEnum.SUCCESS.getCode());
OrderInfoReqs orderInfoReqs = request.getOrderInfoReqs();
CodePayRequest codePayRequest =new CodePayRequest();
codePayRequest.setCode(request.getCode());
codePayRequest.setAmount(request.getPayAmount());
codePayRequest.setStoreId(orderInfoReqs.getStoreId());
codePayRequest.setFrontTransId(orderInfoReqs.getOrderCode());
codePayRequest.setProducts(convertPayProduct(request.getOrderItemList()));
codePayRequest.setBody(orderInfoReqs.getStoreName());
codePayRequest.setBusinessDate(DateUtil.convert2String(new Date(), DateUtil.FORMAT_YYYY_MM_DD_HHMMSS));
codePayRequest.setStationId("1");
codePayRequest.setOperatorId("1");
codePayRequest.setVer("2");
//codePayRequest.setCode("10102");
codePayRequest.setPartnerId(orderInfoReqs.getPartnerId());
codePayRequest.setTransId(orderInfoReqs.getOrderCode());
final com.freemud.application.sdk.api.base.BaseResponse<CodePayResponse> codePayResponseBaseResponse = paymentNewService.codePay(codePayRequest, LogThreadLocal.getTrackingNo());
log.info("SVC.paymentFeignClient.codePay,request:{},response:{}", JSON.toJSONString(codePayRequest),JSON.toJSONString(codePayResponseBaseResponse));
if(ObjectUtils.notEqual(ResponseResultEnum.SUCCESS.getCode(),codePayResponseBaseResponse.getCode()) ||
ObjectUtils.notEqual(ResponseResultEnum.SUCCESS.getCode(),codePayResponseBaseResponse.getData().getCode()) ||
ObjectUtils.notEqual(ResponseResultEnum.SUCCESS.getCode(),codePayResponseBaseResponse.getData().getData().getResultCode())
){
baseResponse.setCode(codePayResponseBaseResponse.getCode());
baseResponse.setMessage(codePayResponseBaseResponse.getMessage());
return baseResponse;
}
request.setFmId(codePayResponseBaseResponse.getData().getData().getFmId());
return baseResponse;
}
@Override
OrderSettlementReq getOrderSettlement(DiscountRequest request) {
OrderInfoReqs orderInfoReqs = request.getOrderInfoReqs();
return buildOrderSettlement("SVV支付", OrderSettlementType.SVC, true, orderInfoReqs, request);
}
@Override
public Integer getEvent() {
return PayChannelEnum.SVC.getCode();
}
}
order-application-service/src/main/java/cn/freemud/fuyou/service/processor/WeChatEventProcessor.java
......@@ -25,55 +25,55 @@ import java.util.Date;
@Slf4j
public class WeChatEventProcessor extends AbstractProcessor{
// private final PaymentNewService paymentNewService;
// protected WeChatEventProcessor(OrderSdkService orderSdkService, PaymentService paymentService,
// PaymentNewService paymentNewService) {
// //super(orderSdkService, paymentService);
// this.paymentNewService = paymentNewService;
// }
//
// @Override
// BaseResponse doProcess(DiscountRequest request) {
// BaseResponse baseResponse =new BaseResponse();
// baseResponse.setCode(ResponseResultEnum.SUCCESS.getCode());
// OrderInfoReqs orderInfoReqs = request.getOrderInfoReqs();
// com.freemud.application.sdk.api.paymentcenter.client.request.CodePayRequest codePayRequest =new CodePayRequest();
// codePayRequest.setCode(request.getCode());
// codePayRequest.setAmount(request.getPayAmount());
// codePayRequest.setStoreId(orderInfoReqs.getStoreId());
// codePayRequest.setFrontTransId(orderInfoReqs.getOrderCode());
// codePayRequest.setProducts(convertPayProduct(request.getOrderItemList()));
// codePayRequest.setBody(orderInfoReqs.getStoreName());
// codePayRequest.setBusinessDate(DateUtil.convert2String(new Date(), DateUtil.FORMAT_YYYY_MM_DD_HHMMSS));
// codePayRequest.setStationId("1");
// codePayRequest.setOperatorId("1");
// codePayRequest.setVer("2");
// //codePayRequest.setClientCode(100037L);
// codePayRequest.setPartnerId(orderInfoReqs.getPartnerId());
// codePayRequest.setTransId(orderInfoReqs.getOrderCode());
//
// final com.freemud.application.sdk.api.base.BaseResponse<CodePayResponse> codePayResponseBaseResponse = paymentNewService.codePay(codePayRequest, LogThreadLocal.getTrackingNo());
// log.info("wechat.paymentFeignClient.codePay,request:{},response:{}", JSON.toJSONString(codePayRequest),JSON.toJSONString(codePayResponseBaseResponse));
// if(ObjectUtils.notEqual(ResponseResultEnum.SUCCESS.getCode(),codePayResponseBaseResponse.getCode()) ||
// ObjectUtils.notEqual(ResponseResultEnum.SUCCESS.getCode(),codePayResponseBaseResponse.getData().getCode()) ||
// ObjectUtils.notEqual(ResponseResultEnum.SUCCESS.getCode(),codePayResponseBaseResponse.getData().getData().getResultCode())
// ){
// baseResponse.setCode(codePayResponseBaseResponse.getCode());
// baseResponse.setMessage(codePayResponseBaseResponse.getMessage());
// return baseResponse;
// }
// request.setFmId(codePayResponseBaseResponse.getData().getData().getFmId());
// return baseResponse;
// }
//
// @Override
// OrderSettlementReq getOrderSettlement(DiscountRequest request) {
// OrderInfoReqs orderInfoReqs = request.getOrderInfoReqs();
// return buildOrderSettlement("微信支付", OrderSettlementType.WEIXIN, true, orderInfoReqs, request);
//
// }
// @Override
// public Integer getEvent() {
// return PayChannelEnum.WECHAT.getCode();
// }
private final PaymentNewService paymentNewService;
protected WeChatEventProcessor(OrderSdkService orderSdkService, PaymentService paymentService,
PaymentNewService paymentNewService) {
super(orderSdkService, paymentService);
this.paymentNewService = paymentNewService;
}
@Override
BaseResponse doProcess(DiscountRequest request) {
BaseResponse baseResponse =new BaseResponse();
baseResponse.setCode(ResponseResultEnum.SUCCESS.getCode());
OrderInfoReqs orderInfoReqs = request.getOrderInfoReqs();
com.freemud.application.sdk.api.paymentcenter.client.request.CodePayRequest codePayRequest =new CodePayRequest();
codePayRequest.setCode(request.getCode());
codePayRequest.setAmount(request.getPayAmount());
codePayRequest.setStoreId(orderInfoReqs.getStoreId());
codePayRequest.setFrontTransId(orderInfoReqs.getOrderCode());
codePayRequest.setProducts(convertPayProduct(request.getOrderItemList()));
codePayRequest.setBody(orderInfoReqs.getStoreName());
codePayRequest.setBusinessDate(DateUtil.convert2String(new Date(), DateUtil.FORMAT_YYYY_MM_DD_HHMMSS));
codePayRequest.setStationId("1");
codePayRequest.setOperatorId("1");
codePayRequest.setVer("2");
//codePayRequest.setClientCode(100037L);
codePayRequest.setPartnerId(orderInfoReqs.getPartnerId());
codePayRequest.setTransId(orderInfoReqs.getOrderCode());
final com.freemud.application.sdk.api.base.BaseResponse<CodePayResponse> codePayResponseBaseResponse = paymentNewService.codePay(codePayRequest, LogThreadLocal.getTrackingNo());
log.info("wechat.paymentFeignClient.codePay,request:{},response:{}", JSON.toJSONString(codePayRequest),JSON.toJSONString(codePayResponseBaseResponse));
if(ObjectUtils.notEqual(ResponseResultEnum.SUCCESS.getCode(),codePayResponseBaseResponse.getCode()) ||
ObjectUtils.notEqual(ResponseResultEnum.SUCCESS.getCode(),codePayResponseBaseResponse.getData().getCode()) ||
ObjectUtils.notEqual(ResponseResultEnum.SUCCESS.getCode(),codePayResponseBaseResponse.getData().getData().getResultCode())
){
baseResponse.setCode(codePayResponseBaseResponse.getCode());
baseResponse.setMessage(codePayResponseBaseResponse.getMessage());
return baseResponse;
}
request.setFmId(codePayResponseBaseResponse.getData().getData().getFmId());
return baseResponse;
}
@Override
OrderSettlementReq getOrderSettlement(DiscountRequest request) {
OrderInfoReqs orderInfoReqs = request.getOrderInfoReqs();
return buildOrderSettlement("微信支付", OrderSettlementType.WEIXIN, true, orderInfoReqs, request);
}
@Override
public Integer getEvent() {
return PayChannelEnum.WECHAT.getCode();
}
}
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