Commit 2a1eb553 authored by huangjiamin's avatar huangjiamin

充值赠送

parent 50a9a698
...@@ -27,26 +27,26 @@ public class PayBackServiceImpl implements PayBackService { ...@@ -27,26 +27,26 @@ public class PayBackServiceImpl implements PayBackService {
@Override @Override
public List<PayBack> updatePayBack(PayBack payBack) { public List<PayBack> updatePayBack(PayBack payBack) {
List<PayBack> list = payBackRepository.findByPay(payBack.getPay()); //List<PayBack> list = payBackRepository.findByPay(payBack.getPay());
if(list.size() > 0 && payBack.getPay() > 0){ /*if(list.size() > 0 && payBack.getPay() > 0){
list.forEach(payBackRepository::delete); list.forEach(payBackRepository::delete);
payBackRepository.insert(payBack); payBackRepository.insert(payBack);
} }*/
return findAll(); return findAll();
} }
@Override @Override
public List<PayBack> createPayBack(PayBack payBack) { public List<PayBack> createPayBack(PayBack payBack) {
List<PayBack> list = payBackRepository.findByPay(payBack.getPay()); //List<PayBack> list = payBackRepository.findByPay(payBack.getPay());
if(list.size() == 0 && payBack.getPay() > 0){ /*if(list.size() == 0 && payBack.getPay() > 0){
payBackRepository.insert(payBack); payBackRepository.insert(payBack);
} }*/
return findAll(); return findAll();
} }
@Override @Override
public List<PayBack> deletePayBack(Integer pay) { public List<PayBack> deletePayBack(Integer pay) {
payBackRepository.findByPay(pay).forEach(payBackRepository::delete); //payBackRepository.findByPay(pay).forEach(payBackRepository::delete);
return findAll(); return findAll();
} }
} }
...@@ -590,7 +590,7 @@ public class PaymentServiceImpl implements PaymentService { ...@@ -590,7 +590,7 @@ public class PaymentServiceImpl implements PaymentService {
balance.setUsername(byTradeNo.getUsername()); balance.setUsername(byTradeNo.getUsername());
} }
// 充值返现 // 充值返现
PayBack payBack = payBackRepository.findByPay(byTradeNo.getAmount()).get(0); PayBack payBack = payBackRepository.findByPay(byTradeNo.getAmount());
if (payBack == null) { if (payBack == null) {
payBack = new PayBack(); payBack = new PayBack();
} }
...@@ -658,7 +658,7 @@ public class PaymentServiceImpl implements PaymentService { ...@@ -658,7 +658,7 @@ public class PaymentServiceImpl implements PaymentService {
balance.setUsername(byTradeNo.getUsername()); balance.setUsername(byTradeNo.getUsername());
} }
// 充值返现 // 充值返现
PayBack payBack = payBackRepository.findByPay(byTradeNo.getAmount()).get(0); PayBack payBack = payBackRepository.findByPay(byTradeNo.getAmount());
if (payBack == null) if (payBack == null)
payBack = new PayBack(); payBack = new PayBack();
balance.setBalanced(balance.getBalanced() + byTradeNo.getAmount() + payBack.getBack()); balance.setBalanced(balance.getBalanced() + byTradeNo.getAmount() + payBack.getBack());
...@@ -802,7 +802,7 @@ public class PaymentServiceImpl implements PaymentService { ...@@ -802,7 +802,7 @@ public class PaymentServiceImpl implements PaymentService {
if (b) { if (b) {
log.info("订单 " + byTradeNo.getTradeNo() + " 的支付状态更新为成功"); log.info("订单 " + byTradeNo.getTradeNo() + " 的支付状态更新为成功");
// 2.2 获取充值优惠赠送 // 2.2 获取充值优惠赠送
PayBack payBack = payBackRepository.findByPay(byTradeNo.getAmount()).get(0); PayBack payBack = payBackRepository.findByPay(byTradeNo.getAmount());
if (payBack == null) { if (payBack == null) {
payBack = new PayBack(); payBack = new PayBack();
} }
......
...@@ -7,5 +7,5 @@ import java.util.List; ...@@ -7,5 +7,5 @@ import java.util.List;
public interface PayBackRepository extends MongoRepository<PayBack, String> { public interface PayBackRepository extends MongoRepository<PayBack, String> {
List<PayBack> findByPay(int pay); PayBack findByPay(int pay);
} }
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