批量机审 时间修改

src/main/java/com/sqx/modules/pay/service/impl/CashOutServiceImpl.java

@@ -43,6 +43,7 @@ import com.sqx.modules.sys.service.SysUserService;
 import com.sqx.modules.utils.AliPayOrderUtil;
 import com.sqx.modules.utils.AmountCalUtils;
 import com.sqx.modules.utils.excel.ExcelData;
+import lombok.extern.slf4j.Slf4j;
 import org.apache.commons.lang.StringUtils;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.stereotype.Service;
@@ -65,6 +66,7 @@ import java.util.stream.Collectors;
  * 提现申请记录
  */
 @Service
+@Slf4j
 public class CashOutServiceImpl extends ServiceImpl<CashOutDao, CashOut> implements CashOutService {
 
     /**
@@ -749,14 +751,17 @@ public class CashOutServiceImpl extends ServiceImpl<CashOutDao, CashOut> impleme
 
                 try {
                     // 查询用户待审核的列表
+                    BigDecimal cashTotal = BigDecimal.ZERO;
                     List<CashOut> cashOutList = baseMapper.selectList(Wrappers.<CashOut>lambdaQuery().eq(CashOut::getUserId, userId).eq(CashOut::getState, 3));
                     for (CashOut cashOut : cashOutList) {
                         cashOut.setIsAgree(1);
                         cashOut.setRefund("");
                         queueAudit(cashOut);
+                        cashTotal = cashTotal.add(new BigDecimal(cashOut.getMoney()));
                     }
 
-                    TimeUnit.SECONDS.sleep(1);
+                    log.info("用户 {} 提现成功！ {}笔, 金额{}元", userId, cashOutList.size(), cashTotal);
+                    TimeUnit.MILLISECONDS.sleep(500);
                 } catch (Exception e) {
                     e.printStackTrace();
                 }