补充提交

yd-api/src/main/java/com/yd/api/agms/service/impl/AgmsFortuneServiceImpl.java

@@ -150,7 +150,7 @@ public class AgmsFortuneServiceImpl implements AgmsFortuneService {
                 customerWithdrawMap.put(customerWithdrawNoPay.getKey(),customerWithdrawNoPay.getValue());
                 customerWithdrawMap.put(customerWithdrawNoPay.getKey(),customerWithdrawNoPay.getValue());
                 continue;
                 continue;
             }
             }
-            if (payWithdrewId > customerWithdrawNoPay.getKey()){
+            if (BigDecimal.valueOf(payWithdrewId).compareTo(BigDecimal.valueOf(customerWithdrawNoPay.getValue())) > 0){
                 continue;
                 continue;
             }
             }
             customerWithdrawMap.put(customerWithdrawNoPay.getKey(),customerWithdrawNoPay.getValue());
             customerWithdrawMap.put(customerWithdrawNoPay.getKey(),customerWithdrawNoPay.getValue());
@@ -260,10 +260,10 @@ public class AgmsFortuneServiceImpl implements AgmsFortuneService {
         }
         }
         //批量更新withdraw记录
         //批量更新withdraw记录
         customerFortuneWithdrawDalService.updateAll(withdraws);
         customerFortuneWithdrawDalService.updateAll(withdraws);
-        withdraws.forEach(p-> System.out.println(p.toString()));
+//        withdraws.forEach(p-> System.out.println(p.toString()));
         //批量更新pay记录
         //批量更新pay记录
         customerFortunePayDalService.updateAll(pays);
         customerFortunePayDalService.updateAll(pays);
-        pays.forEach(p-> System.out.println(p.toString()));
+//        pays.forEach(p-> System.out.println(p.toString()));
         //再次更新fortune->payId
         //再次更新fortune->payId
         customerFortuneDalService.updateBatch(fortuneUpdates);
         customerFortuneDalService.updateBatch(fortuneUpdates);
     }
     }