明星电力充电桩
blame | 历史 | 补丁 | 提交 | 提交对比 | ignore whitespace
无关风月
2 天以前 fc555f5d9d49f9922a6f5688d4db7c2679f3252c 
 ruoyi-service/ruoyi-jianguan/src/main/java/com/ruoyi/jianguan/util/GovernmentCloudTask.java


@@ -300,7 +300,7 @@


                // 将id 设置为null


                log.info("策略"+appCoupons.size());


                appCoupons = appCoupons.stream()


                        .filter(accountingStrategy -> accountingStrategy.getCreateTime().isAfter(startOfDay))


                        .filter(accountingStrategy -> accountingStrategy.getCreateTime()!=null&&accountingStrategy.getCreateTime().isAfter(startOfDay))


                        .filter(accountingStrategy -> accountingStrategy.getCreateTime().isBefore(endOfDay))


                        .collect(Collectors.toList());


                // 分批插入数据 每次最多700条


@@ -312,7 +312,7 @@


            if (!appUsers.isEmpty()) {


                log.info("用户"+appUsers.size());


                appUsers = appUsers.stream()


                        .filter(accountingStrategy -> accountingStrategy.getCreateTime().isAfter(startOfDay))


                        .filter(accountingStrategy -> accountingStrategy.getCreateTime()!=null&&accountingStrategy.getCreateTime().isAfter(startOfDay))


                        .filter(accountingStrategy -> accountingStrategy.getCreateTime().isBefore(endOfDay))


                        .collect(Collectors.toList());


                // 分批插入数据 每次最多700条


@@ -325,7 +325,7 @@


            if (!appUserAddresses.isEmpty()) {


                log.info("用户地址"+appUserAddresses.size());


                appUserAddresses = appUserAddresses.stream()


                        .filter(accountingStrategy -> accountingStrategy.getCreateTime().isAfter(startOfDay))


                        .filter(accountingStrategy -> accountingStrategy.getCreateTime()!=null&&accountingStrategy.getCreateTime().isAfter(startOfDay))


                        .filter(accountingStrategy -> accountingStrategy.getCreateTime().isBefore(endOfDay))


                        .collect(Collectors.toList());


                // 分批插入数据 每次最多700条


@@ -337,7 +337,7 @@


            if (!appUserCars.isEmpty()) {


                log.info("用户车辆"+appUserCars.size());


                appUserCars = appUserCars.stream()


                        .filter(accountingStrategy -> accountingStrategy.getCreateTime().isAfter(startOfDay))


                        .filter(accountingStrategy -> accountingStrategy.getCreateTime()!=null&&accountingStrategy.getCreateTime().isAfter(startOfDay))


                        .filter(accountingStrategy -> accountingStrategy.getCreateTime().isBefore(endOfDay))


                        .collect(Collectors.toList());


                // 分批插入数据 每次最多700条


@@ -349,7 +349,7 @@


            if (!appUserIntegralChanges.isEmpty()) {


                log.info("用户积分变动"+appUserIntegralChanges.size());


                appUserIntegralChanges = appUserIntegralChanges.stream()


                        .filter(accountingStrategy -> accountingStrategy.getCreateTime().isAfter(startOfDay))


                        .filter(accountingStrategy -> accountingStrategy.getCreateTime()!=null&&accountingStrategy.getCreateTime().isAfter(startOfDay))


                        .filter(accountingStrategy -> accountingStrategy.getCreateTime().isBefore(endOfDay))


                        .collect(Collectors.toList());


                // 分批插入数据 每次最多700条


@@ -361,7 +361,7 @@


            if (!appUserSigns.isEmpty()) {


                log.info("用户签到"+appUserSigns.size());


                appUserSigns = appUserSigns.stream()


                        .filter(accountingStrategy -> accountingStrategy.getCreateTime().isAfter(startOfDay))


                        .filter(accountingStrategy -> accountingStrategy.getCreateTime()!=null&&accountingStrategy.getCreateTime().isAfter(startOfDay))


                        .filter(accountingStrategy -> accountingStrategy.getCreateTime().isBefore(endOfDay))


                        .collect(Collectors.toList());


                // 分批插入数据 每次最多700条


@@ -374,7 +374,7 @@


                log.info("用户标签"+appUserTags.size());




                appUserTags = appUserTags.stream()


                        .filter(accountingStrategy -> accountingStrategy.getCreateTime().isAfter(startOfDay))


                        .filter(accountingStrategy -> accountingStrategy.getCreateTime()!=null&&accountingStrategy.getCreateTime().isAfter(startOfDay))


                        .filter(accountingStrategy -> accountingStrategy.getCreateTime().isBefore(endOfDay))


                        .collect(Collectors.toList());


                // 分批插入数据 每次最多700条


@@ -387,7 +387,7 @@


                log.info("用户会员明细"+appUserVipDetails.size());




                appUserVipDetails = appUserVipDetails.stream()


                        .filter(accountingStrategy -> accountingStrategy.getCreateTime().isAfter(startOfDay))


                        .filter(accountingStrategy -> accountingStrategy.getCreateTime()!=null&&accountingStrategy.getCreateTime().isAfter(startOfDay))


                        .filter(accountingStrategy -> accountingStrategy.getCreateTime().isBefore(endOfDay))


                        .collect(Collectors.toList());


                // 分批插入数据 每次最多700条


@@ -399,7 +399,7 @@


            if (!inviteUsers.isEmpty()) {


                log.info("邀请用户"+inviteUsers.size());


                inviteUsers = inviteUsers.stream()


                        .filter(accountingStrategy -> accountingStrategy.getCreateTime().isAfter(startOfDay))


                        .filter(accountingStrategy -> accountingStrategy.getCreateTime()!=null&&accountingStrategy.getCreateTime().isAfter(startOfDay))


                        .filter(accountingStrategy -> accountingStrategy.getCreateTime().isBefore(endOfDay))


                        .collect(Collectors.toList());


                // 分批插入数据 每次最多700条


@@ -411,7 +411,7 @@


            if (!invoiceInformations.isEmpty()) {


                log.info("开票"+invoiceInformations.size());


                invoiceInformations = invoiceInformations.stream()


                        .filter(accountingStrategy -> accountingStrategy.getCreateTime().isAfter(startOfDay))


                        .filter(accountingStrategy -> accountingStrategy.getCreateTime()!=null&&accountingStrategy.getCreateTime().isAfter(startOfDay))


                        .filter(accountingStrategy -> accountingStrategy.getCreateTime().isBefore(endOfDay))


                        .collect(Collectors.toList());


                // 分批插入数据 每次最多700条


@@ -448,7 +448,7 @@


                log.info("策略"+accountingStrategies.size());


                // 筛选出昨天凌晨00:00:00到昨天晚上23:59:59的数据


                accountingStrategies = accountingStrategies.stream()


                        .filter(accountingStrategy -> accountingStrategy.getCreateTime().isAfter(startOfDay))


                        .filter(accountingStrategy -> accountingStrategy.getCreateTime()!=null&&accountingStrategy.getCreateTime().isAfter(startOfDay))


                        .filter(accountingStrategy -> accountingStrategy.getCreateTime().isBefore(endOfDay))


                        .collect(Collectors.toList());


                // 分批插入数据 每次最多700条


@@ -460,7 +460,7 @@


            if (!accountingStrategyDetails.isEmpty()) {


                log.info("策略明细"+accountingStrategyDetails.size());


                accountingStrategyDetails = accountingStrategyDetails.stream()


                        .filter(accountingStrategy -> accountingStrategy.getCreateTime().isAfter(startOfDay))


                        .filter(accountingStrategy -> accountingStrategy.getCreateTime()!=null&&accountingStrategy.getCreateTime().isAfter(startOfDay))


                        .filter(accountingStrategy -> accountingStrategy.getCreateTime().isBefore(endOfDay))


                        .collect(Collectors.toList());


                for (int i = 0; i < accountingStrategies.size(); i += 700) {


@@ -471,7 +471,7 @@


            if (!applyChargingPiles.isEmpty()) {


                log.info("申请充电桩"+applyChargingPiles.size());


                applyChargingPiles = applyChargingPiles.stream()


                        .filter(accountingStrategy -> accountingStrategy.getCreateTime().isAfter(startOfDay))


                        .filter(accountingStrategy -> accountingStrategy.getCreateTime()!=null&&accountingStrategy.getCreateTime().isAfter(startOfDay))


                        .filter(accountingStrategy -> accountingStrategy.getCreateTime().isBefore(endOfDay))


                        .collect(Collectors.toList());


                // 分批插入数据 每次最多700条


@@ -485,7 +485,7 @@


                log.info("车库"+carports.size());


                // 分批插入数据 每次最多700条


                carports = carports.stream()


                        .filter(accountingStrategy -> accountingStrategy.getCreateTime().isAfter(startOfDay))


                        .filter(accountingStrategy -> accountingStrategy.getCreateTime()!=null&&accountingStrategy.getCreateTime().isAfter(startOfDay))


                        .filter(accountingStrategy -> accountingStrategy.getCreateTime().isBefore(endOfDay))


                        .collect(Collectors.toList());


                for (int i = 0; i < carports.size(); i += 700) {


@@ -497,7 +497,7 @@


                log.info("充电枪"+chargingGuns.size());


                // 分批插入数据 每次最多700条


                chargingGuns = chargingGuns.stream()


                        .filter(accountingStrategy -> accountingStrategy.getCreateTime().isAfter(startOfDay))


                        .filter(accountingStrategy -> accountingStrategy.getCreateTime()!=null&&accountingStrategy.getCreateTime().isAfter(startOfDay))


                        .filter(accountingStrategy -> accountingStrategy.getCreateTime().isBefore(endOfDay))


                        .collect(Collectors.toList());


                for (int i = 0; i < chargingGuns.size(); i += 700) {


@@ -511,7 +511,7 @@


                log.info("充电桩"+chargingPiles.size());


                // 分批插入数据 每次最多700条


                chargingPiles = chargingPiles.stream()


                        .filter(accountingStrategy -> accountingStrategy.getCreateTime().isAfter(startOfDay))


                        .filter(accountingStrategy -> accountingStrategy.getCreateTime()!=null&&accountingStrategy.getCreateTime().isAfter(startOfDay))


                        .filter(accountingStrategy -> accountingStrategy.getCreateTime().isBefore(endOfDay))


                        .collect(Collectors.toList());


                for (int i = 0; i < chargingPiles.size(); i += 700) {


@@ -524,7 +524,7 @@


                log.info("充电桩通知"+chargingPileNotifications.size());


                // 分批插入数据 每次最多700条


                chargingPileNotifications = chargingPileNotifications.stream()


                        .filter(accountingStrategy -> accountingStrategy.getCreateTime().isAfter(startOfDay))


                        .filter(accountingStrategy -> accountingStrategy.getCreateTime()!=null&&accountingStrategy.getCreateTime().isAfter(startOfDay))


                        .filter(accountingStrategy -> accountingStrategy.getCreateTime().isBefore(endOfDay))


                        .collect(Collectors.toList());


                for (int i = 0; i < chargingPileNotifications.size(); i += 700) {


@@ -536,7 +536,7 @@


                log.info("故障"+faultMessages.size());


                // 分批插入数据 每次最多700条


                faultMessages = faultMessages.stream()


                        .filter(accountingStrategy -> accountingStrategy.getCreateTime().isAfter(startOfDay))


                        .filter(accountingStrategy -> accountingStrategy.getCreateTime()!=null&&accountingStrategy.getCreateTime().isAfter(startOfDay))


                        .filter(accountingStrategy -> accountingStrategy.getCreateTime().isBefore(endOfDay))


                        .collect(Collectors.toList());


                for (int i = 0; i < faultMessages.size(); i += 700) {


@@ -548,7 +548,7 @@


                log.info("监控设备"+monitoringEquipments.size());


                // 分批插入数据 每次最多700条


                monitoringEquipments = monitoringEquipments.stream()


                        .filter(accountingStrategy -> accountingStrategy.getCreateTime().isAfter(startOfDay))


                        .filter(accountingStrategy -> accountingStrategy.getCreateTime()!=null&&accountingStrategy.getCreateTime().isAfter(startOfDay))


                        .filter(accountingStrategy -> accountingStrategy.getCreateTime().isBefore(endOfDay))


                        .collect(Collectors.toList());


                for (int i = 0; i < monitoringEquipments.size(); i += 700) {


@@ -561,7 +561,7 @@


                log.info("停车场"+parkingLots.size());


                // 分批插入数据 每次最多700条


                parkingLots = parkingLots.stream()


                        .filter(accountingStrategy -> accountingStrategy.getCreateTime().isAfter(startOfDay))


                        .filter(accountingStrategy -> accountingStrategy.getCreateTime()!=null&&accountingStrategy.getCreateTime().isAfter(startOfDay))


                        .filter(accountingStrategy -> accountingStrategy.getCreateTime().isBefore(endOfDay))


                        .collect(Collectors.toList());


                for (int i = 0; i < parkingLots.size(); i += 700) {


@@ -573,7 +573,7 @@


                log.info("停车记录"+parkingRecords.size());


                // 分批插入数据 每次最多700条


                parkingRecords = parkingRecords.stream()


                        .filter(accountingStrategy -> accountingStrategy.getCreateTime().isAfter(startOfDay))


                        .filter(accountingStrategy -> accountingStrategy.getCreateTime()!=null&&accountingStrategy.getCreateTime().isAfter(startOfDay))


                        .filter(accountingStrategy -> accountingStrategy.getCreateTime().isBefore(endOfDay))


                        .collect(Collectors.toList());


                for (int i = 0; i < parkingRecords.size(); i += 700) {


@@ -594,7 +594,7 @@


                log.info("报修"+repairs.size());


                // 分批插入数据 每次最多700条


                repairs = repairs.stream()


                        .filter(accountingStrategy -> accountingStrategy.getCreateTime().isAfter(startOfDay))


                        .filter(accountingStrategy -> accountingStrategy.getCreateTime()!=null&&accountingStrategy.getCreateTime().isAfter(startOfDay))


                        .filter(accountingStrategy -> accountingStrategy.getCreateTime().isBefore(endOfDay))


                        .collect(Collectors.toList());


                for (int i = 0; i < repairs.size(); i += 700) {


@@ -606,7 +606,7 @@


                log.info("站点菜单"+repairs.size());


                // 分批插入数据 每次最多700条


                siteMenus = siteMenus.stream()


                        .filter(accountingStrategy -> accountingStrategy.getCreateTime().isAfter(startOfDay))


                        .filter(accountingStrategy -> accountingStrategy.getCreateTime()!=null&&accountingStrategy.getCreateTime().isAfter(startOfDay))


                        .filter(accountingStrategy -> accountingStrategy.getCreateTime().isBefore(endOfDay))


                        .collect(Collectors.toList());


                for (int i = 0; i < siteMenus.size(); i += 700) {


@@ -618,7 +618,7 @@


                log.info("车道"+vehicleRamps.size());


                // 分批插入数据 每次最多700条


                vehicleRamps = vehicleRamps.stream()


                        .filter(accountingStrategy -> accountingStrategy.getCreateTime().isAfter(startOfDay))


                        .filter(accountingStrategy -> accountingStrategy.getCreateTime()!=null&&accountingStrategy.getCreateTime().isAfter(startOfDay))


                        .filter(accountingStrategy -> accountingStrategy.getCreateTime().isBefore(endOfDay))


                        .collect(Collectors.toList());


                for (int i = 0; i < vehicleRamps.size(); i += 700) {


@@ -653,7 +653,7 @@


                log.info("订单明细策略" + accountingStrategyDetailOrders.size());


                // 分批插入数据 每次最多700条


                accountingStrategyDetailOrders = accountingStrategyDetailOrders.stream()


                        .filter(accountingStrategy -> accountingStrategy.getCreateTime().isAfter(startOfDay))


                        .filter(accountingStrategy -> accountingStrategy.getCreateTime()!=null&&accountingStrategy.getCreateTime().isAfter(startOfDay))


                        .filter(accountingStrategy -> accountingStrategy.getCreateTime().isBefore(endOfDay))


                        .collect(Collectors.toList());


                for (int i = 0; i < accountingStrategyDetailOrders.size(); i += 700) {


@@ -668,7 +668,7 @@


                // 分批插入数据 每次最多700条


                int size = 700;


                accountingStrategyOrders = accountingStrategyOrders.stream()


                        .filter(accountingStrategy -> accountingStrategy.getCreateTime().isAfter(startOfDay))


                        .filter(accountingStrategy -> accountingStrategy.getCreateTime()!=null&&accountingStrategy.getCreateTime().isAfter(startOfDay))


                        .filter(accountingStrategy -> accountingStrategy.getCreateTime().isBefore(endOfDay))


                        .collect(Collectors.toList());


                for (int i = 0; i < accountingStrategyOrders.size(); i += size) {


@@ -684,7 +684,7 @@


                // 分批插入数据 每次最多700条


                // 分批插入数据 每次最多700条


                chargingBills = chargingBills.stream()


                        .filter(accountingStrategy -> accountingStrategy.getCreateTime().isAfter(startOfDay))


                        .filter(accountingStrategy -> accountingStrategy.getCreateTime()!=null&&accountingStrategy.getCreateTime().isAfter(startOfDay))


                        .filter(accountingStrategy -> accountingStrategy.getCreateTime().isBefore(endOfDay))


                        .collect(Collectors.toList());


                for (int i = 0; i < chargingBills.size(); i += 700) {


@@ -699,7 +699,7 @@


                log.info("充电订单策略" + chargingOrderAccountingStrategies.size());


                // 分批插入数据 每次最多700条


                chargingOrderAccountingStrategies = chargingOrderAccountingStrategies.stream()


                        .filter(accountingStrategy -> accountingStrategy.getCreateTime().isAfter(startOfDay))


                        .filter(accountingStrategy -> accountingStrategy.getCreateTime()!=null&&accountingStrategy.getCreateTime().isAfter(startOfDay))


                        .filter(accountingStrategy -> accountingStrategy.getCreateTime().isBefore(endOfDay))


                        .collect(Collectors.toList());


                for (int i = 0; i < chargingOrderAccountingStrategies.size(); i += 700) {


@@ -714,7 +714,7 @@




                // 分批插入数据 每次最多700条


                chargingOrderRefunds = chargingOrderRefunds.stream()


                        .filter(accountingStrategy -> accountingStrategy.getCreateTime().isAfter(startOfDay))


                        .filter(accountingStrategy -> accountingStrategy.getCreateTime()!=null&&accountingStrategy.getCreateTime().isAfter(startOfDay))


                        .filter(accountingStrategy -> accountingStrategy.getCreateTime().isBefore(endOfDay))


                        .collect(Collectors.toList());


                for (int i = 0; i < chargingOrderRefunds.size(); i += 700) {


@@ -728,7 +728,7 @@


                log.info("充电订单" + chargingOrders.size());


                // 分批插入数据 每次最多700条


                chargingOrders = chargingOrders.stream()


                        .filter(accountingStrategy -> accountingStrategy.getCreateTime().isAfter(startOfDay))


                        .filter(accountingStrategy -> accountingStrategy.getCreateTime()!=null&&accountingStrategy.getCreateTime().isAfter(startOfDay))


                        .filter(accountingStrategy -> accountingStrategy.getCreateTime().isBefore(endOfDay))


                        .collect(Collectors.toList());


                for (int i = 0; i < chargingOrders.size(); i += 700) {


@@ -743,7 +743,7 @@


            if (!exchangeOrders.isEmpty()) {


                log.info("兑换订单" + exchangeOrders.size());


                exchangeOrders = exchangeOrders.stream()


                        .filter(accountingStrategy -> accountingStrategy.getCreateTime().isAfter(startOfDay))


                        .filter(accountingStrategy -> accountingStrategy.getCreateTime()!=null&&accountingStrategy.getCreateTime().isAfter(startOfDay))


                        .filter(accountingStrategy -> accountingStrategy.getCreateTime().isBefore(endOfDay))


                        .collect(Collectors.toList());


                // 分批插入数据 每次最多700条


@@ -759,7 +759,7 @@




                // 分批插入数据 每次最多700条


                grantVips = grantVips.stream()


                        .filter(accountingStrategy -> accountingStrategy.getCreateTime().isAfter(startOfDay))


                        .filter(accountingStrategy -> accountingStrategy.getCreateTime()!=null&&accountingStrategy.getCreateTime().isAfter(startOfDay))


                        .filter(accountingStrategy -> accountingStrategy.getCreateTime().isBefore(endOfDay))


                        .collect(Collectors.toList());


                for (int i = 0; i < grantVips.size(); i += 700) {


@@ -772,7 +772,7 @@


            if (!orderAppeals.isEmpty()) {


                log.info("订单申诉" + orderAppeals.size());


                orderAppeals = orderAppeals.stream()


                        .filter(accountingStrategy -> accountingStrategy.getCreateTime().isAfter(startOfDay))


                        .filter(accountingStrategy -> accountingStrategy.getCreateTime()!=null&&accountingStrategy.getCreateTime().isAfter(startOfDay))


                        .filter(accountingStrategy -> accountingStrategy.getCreateTime().isBefore(endOfDay))


                        .collect(Collectors.toList());


                // 分批插入数据 每次最多700条


@@ -786,7 +786,7 @@


            if (!orderEvaluates.isEmpty()) {


                log.info("订单评价"+orderEvaluates.size());


                orderEvaluates = orderEvaluates.stream()


                        .filter(accountingStrategy -> accountingStrategy.getCreateTime().isAfter(startOfDay))


                        .filter(accountingStrategy -> accountingStrategy.getCreateTime()!=null&&accountingStrategy.getCreateTime().isAfter(startOfDay))


                        .filter(accountingStrategy -> accountingStrategy.getCreateTime().isBefore(endOfDay))


                        .collect(Collectors.toList());


                // 分批插入数据 每次最多700条


@@ -801,7 +801,7 @@


                log.info("订单评价标签" + orderEvaluateTags.size());


                // 分批插入数据 每次最多700条


                orderEvaluateTags = orderEvaluateTags.stream()


                        .filter(accountingStrategy -> accountingStrategy.getCreateTime().isAfter(startOfDay))


                        .filter(accountingStrategy -> accountingStrategy.getCreateTime()!=null&&accountingStrategy.getCreateTime().isAfter(startOfDay))


                        .filter(accountingStrategy -> accountingStrategy.getCreateTime().isBefore(endOfDay))


                        .collect(Collectors.toList());


                for (int i = 0; i < orderEvaluateTags.size(); i += 700) {


@@ -815,7 +815,7 @@


                log.info("订单开票明细" + orderInvoiceDetails.size());


                // 分批插入数据 每次最多700条


                orderInvoiceDetails = orderInvoiceDetails.stream()


                        .filter(accountingStrategy -> accountingStrategy.getCreateTime().isAfter(startOfDay))


                        .filter(accountingStrategy -> accountingStrategy.getCreateTime()!=null&&accountingStrategy.getCreateTime().isAfter(startOfDay))


                        .filter(accountingStrategy -> accountingStrategy.getCreateTime().isBefore(endOfDay))


                        .collect(Collectors.toList());


                for (int i = 0; i < orderInvoiceDetails.size(); i += 700) {


@@ -828,7 +828,7 @@


            if (!orderInvoices.isEmpty()) {


                log.info("订单开票" + orderInvoices.size());


                orderInvoices = orderInvoices.stream()


                        .filter(accountingStrategy -> accountingStrategy.getCreateTime().isAfter(startOfDay))


                        .filter(accountingStrategy -> accountingStrategy.getCreateTime()!=null&&accountingStrategy.getCreateTime().isAfter(startOfDay))


                        .filter(accountingStrategy -> accountingStrategy.getCreateTime().isBefore(endOfDay))


                        .collect(Collectors.toList());


                // 分批插入数据 每次最多700条


@@ -843,7 +843,7 @@


            if (!settlementConfirms.isEmpty()) {


                log.info("账单结算" + settlementConfirms.size());


                settlementConfirms = settlementConfirms.stream()


                        .filter(accountingStrategy -> accountingStrategy.getCreateTime().isAfter(startOfDay))


                        .filter(accountingStrategy -> accountingStrategy.getCreateTime()!=null&&accountingStrategy.getCreateTime().isAfter(startOfDay))


                        .filter(accountingStrategy -> accountingStrategy.getCreateTime().isBefore(endOfDay))


                        .collect(Collectors.toList());


                // 分批插入数据 每次最多700条


@@ -858,7 +858,7 @@


                log.info("购物订单退款" + shoppingOrderRefunds.size());


                // 分批插入数据 每次最多700条


                shoppingOrderRefunds = shoppingOrderRefunds.stream()


                        .filter(accountingStrategy -> accountingStrategy.getCreateTime().isAfter(startOfDay))


                        .filter(accountingStrategy -> accountingStrategy.getCreateTime()!=null&&accountingStrategy.getCreateTime().isAfter(startOfDay))


                        .filter(accountingStrategy -> accountingStrategy.getCreateTime().isBefore(endOfDay))


                        .collect(Collectors.toList());


                for (int i = 0; i < shoppingOrderRefunds.size(); i += 700) {


@@ -871,7 +871,7 @@


            if (!vipOrderRefunds.isEmpty()) {


                log.info("会员订单退款" + vipOrderRefunds);


                vipOrderRefunds = vipOrderRefunds.stream()


                        .filter(accountingStrategy -> accountingStrategy.getCreateTime().isAfter(startOfDay))


                        .filter(accountingStrategy -> accountingStrategy.getCreateTime()!=null&&accountingStrategy.getCreateTime().isAfter(startOfDay))


                        .filter(accountingStrategy -> accountingStrategy.getCreateTime().isBefore(endOfDay))


                        .collect(Collectors.toList());


                // 分批插入数据 每次最多700条


@@ -885,7 +885,7 @@


            if (!vipOrders.isEmpty()) {


                log.info("会员订单" + vipOrders.size());


                vipOrders = vipOrders.stream()


                        .filter(accountingStrategy -> accountingStrategy.getCreateTime().isAfter(startOfDay))


                        .filter(accountingStrategy -> accountingStrategy.getCreateTime()!=null&&accountingStrategy.getCreateTime().isAfter(startOfDay))


                        .filter(accountingStrategy -> accountingStrategy.getCreateTime().isBefore(endOfDay))


                        .collect(Collectors.toList());


                // 分批插入数据 每次最多700条


@@ -899,7 +899,7 @@


            if (!shoppingOrders.isEmpty()) {


                log.info("购物订单" + shoppingOrders.size());


                shoppingOrders = shoppingOrders.stream()


                        .filter(accountingStrategy -> accountingStrategy.getCreateTime().isAfter(startOfDay))


                        .filter(accountingStrategy -> accountingStrategy.getCreateTime()!=null&&accountingStrategy.getCreateTime().isAfter(startOfDay))


                        .filter(accountingStrategy -> accountingStrategy.getCreateTime().isBefore(endOfDay))


                        .collect(Collectors.toList());


                // 分批插入数据 每次最多700条


@@ -1038,7 +1038,7 @@


            if (!loginLogs.isEmpty()) {


                log.info("登录日志"+loginLogs.size());


                loginLogs = loginLogs.stream()


                        .filter(accountingStrategy -> accountingStrategy.getCreateTime().isAfter(startOfDay))


                        .filter(accountingStrategy -> accountingStrategy.getCreateTime()!=null&&accountingStrategy.getCreateTime().isAfter(startOfDay))


                        .filter(accountingStrategy -> accountingStrategy.getCreateTime().isBefore(endOfDay))


                        .collect(Collectors.toList());


                // 分批插入数据 每次最多700条