Selaa lähdekoodia

修改获取交易流水定时任务

zhouzeyu@c-top.com.cn 3 vuotta sitten
vanhempi
commit
966d5f2975

+ 8 - 6
module-toutiao/src/main/java/cn/com/ctop/toutiao/modules/agent/service/impl/AgentManagementServiceImpl.java

@@ -262,11 +262,12 @@ public class AgentManagementServiceImpl implements AgentManagementService {
         Calendar ca = Calendar.getInstance();
         ca.setTime(new Date());
         ca.add(Calendar.DATE, -1);
-        List<TransactionDay> transactionDetailsList = new ArrayList<>();
+
         try {
             List<String> accountIdList = ctopAgentAccountMapper.getAllAccountId();
             if (!accountIdList.isEmpty()) {
                 accountIdList.stream().forEach(str -> {
+                    List<TransactionDay> transactionDetailsList = new ArrayList<>();
                     if (!str.isEmpty()) {
                         //查询账号下充值的交易流水
                         JSONObject jsonObject = queryAccountTransactionDay(str, 1, 1000, startDate, endDate);
@@ -318,13 +319,14 @@ public class AgentManagementServiceImpl implements AgentManagementService {
                             }
                         }
                     }
+                    //保存数据
+                    if (!transactionDetailsList.isEmpty()) {
+                        ctopAccountTransactionDayMapper.saveAccountTransactionDay(transactionDetailsList, df.format(new Date()));
+                        log.info("新增日流水记录:{}条", transactionDetailsList.size());
+                    }
                 });
             }
-            //保存数据
-            if (!transactionDetailsList.isEmpty()) {
-                ctopAccountTransactionDayMapper.saveAccountTransactionDay(transactionDetailsList, df.format(new Date()));
-                log.info("新增日流水记录:{}条", transactionDetailsList.size());
-            }
+
             result.setSuccess(true);
             result.setMessage("success");
         } catch (Exception e) {