|
|
|
@ -47,15 +47,16 @@ public class CustomerLotteryCountServiceImpl implements ApplicationListener<Afte
|
|
|
|
|
String channel = order.getString("channel");
|
|
|
|
|
if ("Wechat".equals(channel)) {
|
|
|
|
|
JSONObject customerRelation = customerMapper.findCustomerByOpenId(order.getString("customer_id"));
|
|
|
|
|
if (customerRelation == null) {
|
|
|
|
|
customerRelation = customerMapper.findCustomerGlobalpayByOpenId(order.getString("customer_id"));
|
|
|
|
|
}
|
|
|
|
|
if (customerRelation.getString("kanga_openid") == null) {
|
|
|
|
|
return;
|
|
|
|
|
}
|
|
|
|
|
royalThreadPoolExecutor.execute(() -> afterPaymentAddLotteryCount(customerRelation.getString("kanga_openid"),
|
|
|
|
|
order.getString("order_id"), channel, clearAmount));
|
|
|
|
|
afterPaymentAddLotteryCount(customerRelation.getString("kanga_openid"), order.getString("order_id"), channel, clearAmount);
|
|
|
|
|
}
|
|
|
|
|
if ("Alipay".equals(channel)) {
|
|
|
|
|
royalThreadPoolExecutor.execute(() -> afterPaymentAddLotteryCount(order.getString("customer_id"),
|
|
|
|
|
order.getString("order_id"), channel, clearAmount));
|
|
|
|
|
afterPaymentAddLotteryCount(order.getString("customer_id"), order.getString("order_id"), channel, clearAmount);
|
|
|
|
|
}
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|