From a0070809b2344266608de9f8c9ac5c8ce1c31a8c Mon Sep 17 00:00:00 2001
From: xuhy <3313886187@qq.com>
Date: 星期三, 16 七月 2025 20:59:55 +0800
Subject: [PATCH] Merge branch 'dev' of http://120.76.84.145:10101/gitblit/r/java/mx_charging_pile into dev
---
ruoyi-service/ruoyi-jianguan/src/main/java/com/ruoyi/jianguan/util/GovernmentCloudTask.java | 520 ++++++++++++++++++++++++++++++++++++++-------------------
1 files changed, 347 insertions(+), 173 deletions(-)
diff --git a/ruoyi-service/ruoyi-jianguan/src/main/java/com/ruoyi/jianguan/util/GovernmentCloudTask.java b/ruoyi-service/ruoyi-jianguan/src/main/java/com/ruoyi/jianguan/util/GovernmentCloudTask.java
index 923ce2e..7548617 100644
--- a/ruoyi-service/ruoyi-jianguan/src/main/java/com/ruoyi/jianguan/util/GovernmentCloudTask.java
+++ b/ruoyi-service/ruoyi-jianguan/src/main/java/com/ruoyi/jianguan/util/GovernmentCloudTask.java
@@ -1,20 +1,11 @@
package com.ruoyi.jianguan.util;
-
-import com.ruoyi.other.api.domain.TEnterpriseUserApplication;
-import com.ruoyi.other.api.domain.THtml;
-import com.ruoyi.other.api.domain.TCoupon;
-import com.ruoyi.other.api.domain.TSystemConfiguration;
-import com.ruoyi.other.api.domain.TVip;
-import com.ruoyi.other.api.domain.Operator;
-import com.ruoyi.other.api.domain.TGoods;
-import com.ruoyi.other.api.domain.TInvoiceType;
-import com.ruoyi.other.api.domain.TIntegralRule;
-import com.ruoyi.other.api.domain.TActivity;
-import com.ruoyi.other.api.domain.TAdvertising;
-import com.ruoyi.other.api.domain.TCompany;
-import com.ruoyi.other.api.domain.TEvaluationTag;
-import com.ruoyi.other.api.domain.TNotice;
-import com.ruoyi.other.api.domain.TUserTag;
+import com.ruoyi.account.api.factory.JianGuanAccountFallbackFactory;
+import com.ruoyi.account.api.feignClient.JianGuanAccountClient;
+import com.ruoyi.other.api.domain.*;
+import com.ruoyi.system.api.domain.SysRole;
+import com.ruoyi.system.api.domain.SysLoginLog;
+import com.ruoyi.system.api.domain.SysOperLog;
+import com.ruoyi.system.api.domain.SysUser;
import com.ruoyi.order.api.model.AccountingStrategyDetailOrder;
import com.ruoyi.order.api.model.TOrderInvoice;
@@ -65,7 +56,6 @@
import com.ruoyi.account.api.model.TAppUserIntegralChange;
import com.ruoyi.account.api.model.TAppUserTag;
-import com.ruoyi.account.api.feignClient.JianGuanAccountClient;
import com.ruoyi.account.api.vo.GovernmentCloudAccountVO;
import com.ruoyi.chargingPile.api.feignClient.JianGuanChargingPileClient;
import com.ruoyi.chargingPile.api.model.TChargingPile;
@@ -75,6 +65,9 @@
import com.ruoyi.order.api.vo.GovernmentCloudOrderVO;
import com.ruoyi.other.api.feignClient.JianGuanOtherClient;
import com.ruoyi.other.api.vo.GovernmentCloudOtherVO;
+import com.ruoyi.system.api.feignClient.JianGuanSystemClient;
+import com.ruoyi.system.api.vo.GovernmentCloudSystemVO;
+import lombok.extern.slf4j.Slf4j;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.scheduling.annotation.Scheduled;
import org.springframework.stereotype.Component;
@@ -88,6 +81,7 @@
* @date 2023/7/11 8:39
*/
@Component
+@Slf4j
public class GovernmentCloudTask {
@@ -265,354 +259,534 @@
private JianGuanOrderClient jianGuanOrderClient;
@Resource
private JianGuanOtherClient jianGuanOtherClient;
+ @Resource
+ private JianGuanSystemClient jianGuanSystemClient;
- // 每天早上9点执行的定时任务
- @Scheduled(cron = "0 0 9 * * ?")
+ // 每天下午3点执行的定时任务
+ @Scheduled(fixedRate = 86400000)
public void taskMonth() {
+ log.info("市政云传数据");
// account服务
GovernmentCloudAccountVO data = jianGuanAccountClient.listAll().getData();
if (data != null) {
+ log.info("Account");
+
List<TAppCoupon> appCoupons = data.getAppCoupons();
if (!appCoupons.isEmpty()) {
- appCouponService.saveBatch(appCoupons);
+ log.info("用户优惠券"+appCoupons.size());
+ // 将id 设置为null
+ appCouponService.saveOrUpdateBatch(appCoupons);
}
List<TAppUser> appUsers = data.getAppUsers();
if (!appUsers.isEmpty()) {
- appUserService.saveBatch(appUsers);
+ log.info("用户"+appUsers.size());
+
+ appUserService.saveOrUpdateBatch(appUsers);
}
List<TAppUserAddress> appUserAddresses = data.getAppUserAddresses();
if (!appUserAddresses.isEmpty()) {
- appUserAddressService.saveBatch(appUserAddresses);
+ log.info("用户地址"+appUserAddresses.size());
+
+ appUserAddressService.saveOrUpdateBatch(appUserAddresses);
}
List<TAppUserCar> appUserCars = data.getAppUserCars();
if (!appUserCars.isEmpty()) {
- appUserCarService.saveBatch(appUserCars);
+ log.info("用户车辆"+appUserCars.size());
+ appUserCarService.saveOrUpdateBatch(appUserCars);
}
List<TAppUserIntegralChange> appUserIntegralChanges = data.getAppUserIntegralChanges();
if (!appUserIntegralChanges.isEmpty()) {
- appUserIntegralChangeService.saveBatch(appUserIntegralChanges);
+ log.info("用户积分变动"+appUserIntegralChanges.size());
+
+ appUserIntegralChangeService.saveOrUpdateBatch(appUserIntegralChanges);
}
List<TAppUserSign> appUserSigns = data.getAppUserSigns();
if (!appUserSigns.isEmpty()) {
- appUserSignService.saveBatch(appUserSigns);
+ log.info("用户签到"+appUserSigns.size());
+
+ appUserSignService.saveOrUpdateBatch(appUserSigns);
}
List<TAppUserTag> appUserTags = data.getAppUserTags();
if (!appUserTags.isEmpty()) {
- appUserTagService.saveBatch(appUserTags);
+ log.info("用户标签"+appUserTags.size());
+
+ appUserTagService.saveOrUpdateBatch(appUserTags);
}
List<TAppUserVipDetail> appUserVipDetails = data.getAppUserVipDetails();
if (!appUserVipDetails.isEmpty()) {
- appUserVipDetailService.saveBatch(appUserVipDetails);
+ log.info("用户会员明细"+appUserVipDetails.size());
+
+ appUserVipDetailService.saveOrUpdateBatch(appUserVipDetails);
}
List<TInviteUser> inviteUsers = data.getInviteUsers();
if (!inviteUsers.isEmpty()) {
- inviteUserService.saveBatch(inviteUsers);
+ log.info("邀请用户"+inviteUsers.size());
+
+ inviteUserService.saveOrUpdateBatch(inviteUsers);
}
List<TInvoiceInformation> invoiceInformations = data.getInvoiceInformations();
if (!invoiceInformations.isEmpty()) {
- tInvoiceInformationService.saveBatch(invoiceInformations);
+ log.info("开票"+invoiceInformations.size());
+
+ tInvoiceInformationService.saveOrUpdateBatch(invoiceInformations);
}
}
// chargingPile服务
GovernmentCloudChargingPileVO data1 = jianGuanChargingPileClient.listAll().getData();
if (data1 != null) {
+ log.info("chargingPile服务");
+
List<Partner> partners = data1.getPartners();
if (!partners.isEmpty()) {
- partnerService.saveBatch(partners);
+ log.info("合作商"+partners.size());
+
+ partnerService.saveOrUpdateBatch(partners);
}
List<Site> sites = data1.getSites();
if (!sites.isEmpty()) {
- siteService.saveBatch(sites);
+ log.info("站点"+sites.size());
+
+ siteService.saveOrUpdateBatch(sites);
}
List<TAccountingStrategy> accountingStrategies = data1.getAccountingStrategies();
if (!accountingStrategies.isEmpty()) {
- accountingStrategyService.saveBatch(accountingStrategies);
+ log.info("策略"+accountingStrategies.size());
+ // 分批插入数据 每次最多700条
+ for (int i = 0; i < accountingStrategies.size(); i += 700) {
+ accountingStrategyService.saveOrUpdateBatch(accountingStrategies.subList(i, Math.min(i + 700, accountingStrategies.size())));
+ }
}
List<TAccountingStrategyDetail> accountingStrategyDetails = data1.getAccountingStrategyDetails();
if (!accountingStrategyDetails.isEmpty()) {
- accountingStrategyDetailService.saveBatch(accountingStrategyDetails);
+ log.info("策略明细"+accountingStrategyDetails.size());
+ for (int i = 0; i < accountingStrategies.size(); i += 700) {
+ accountingStrategyDetailService.saveOrUpdateBatch(accountingStrategyDetails.subList(i, Math.min(i + 700, accountingStrategyDetails.size())));
+ }
}
List<TApplyChargingPile> applyChargingPiles = data1.getApplyChargingPiles();
if (!applyChargingPiles.isEmpty()) {
- applyChargingPileService.saveBatch(applyChargingPiles);
+ log.info("申请充电桩"+applyChargingPiles.size());
+ // 分批插入数据 每次最多700条
+ for (int i = 0; i < applyChargingPiles.size(); i += 700) {
+ applyChargingPileService.saveOrUpdateBatch(applyChargingPiles.subList(i, Math.min(i + 700, applyChargingPiles.size())));
+ }
}
List<TCarport> carports = data1.getCarports();
if (!carports.isEmpty()) {
- carportService.saveBatch(carports);
+ log.info("停车场"+carports.size());
+ // 分批插入数据 每次最多700条
+ for (int i = 0; i < carports.size(); i += 700) {
+ carportService.saveOrUpdateBatch(carports.subList(i, Math.min(i + 700, carports.size())));
+ }
}
List<TChargingGun> chargingGuns = data1.getChargingGuns();
if (!chargingGuns.isEmpty()) {
- chargingGunService.saveBatch(chargingGuns);
+ log.info("充电枪"+chargingGuns.size());
+ // 分批插入数据 每次最多700条
+ for (int i = 0; i < chargingGuns.size(); i += 700) {
+ chargingGunService.saveOrUpdateBatch(chargingGuns.subList(i, Math.min(i + 700, chargingGuns.size())));
+ }
+
+ chargingGunService.saveOrUpdateBatch(chargingGuns);
}
List<TChargingPile> chargingPiles = data1.getChargingPiles();
if (!chargingPiles.isEmpty()) {
- chargingPileService.saveBatch(chargingPiles);
+ log.info("充电桩"+chargingPiles.size());
+ // 分批插入数据 每次最多700条
+ for (int i = 0; i < chargingPiles.size(); i += 700) {
+ chargingPileService.saveOrUpdateBatch(chargingPiles.subList(i, Math.min(i + 700, chargingPiles.size())));
+ }
+
}
List<TChargingPileNotification> chargingPileNotifications = data1.getChargingPileNotifications();
if (!chargingPileNotifications.isEmpty()) {
- chargingPileNotificationService.saveBatch(chargingPileNotifications);
+ log.info("充电桩通知"+chargingPileNotifications.size());
+ // 分批插入数据 每次最多700条
+ for (int i = 0; i < chargingPileNotifications.size(); i += 700) {
+ chargingPileNotificationService.saveOrUpdateBatch(chargingPileNotifications.subList(i, Math.min(i + 700, chargingPileNotifications.size())));
+ }
}
List<TFaultMessage> faultMessages = data1.getFaultMessages();
if (!faultMessages.isEmpty()) {
- faultMessageService.saveBatch(faultMessages);
+ log.info("故障"+faultMessages.size());
+ // 分批插入数据 每次最多700条
+ for (int i = 0; i < faultMessages.size(); i += 700) {
+ faultMessageService.saveOrUpdateBatch(faultMessages.subList(i, Math.min(i + 700, faultMessages.size())));
+ }
}
List<TMonitoringEquipment> monitoringEquipments = data1.getMonitoringEquipments();
if (!monitoringEquipments.isEmpty()) {
- monitoringEquipmentService.saveBatch(monitoringEquipments);
+ log.info("监控设备"+monitoringEquipments.size());
+ // 分批插入数据 每次最多700条
+ for (int i = 0; i < monitoringEquipments.size(); i += 700) {
+ monitoringEquipmentService.saveOrUpdateBatch(monitoringEquipments.subList(i, Math.min(i + 700, monitoringEquipments.size())));
+
+ }
}
List<TParkingLot> parkingLots = data1.getParkingLots();
if (!parkingLots.isEmpty()) {
- parkingLotService.saveBatch(parkingLots);
+ log.info("停车场"+parkingLots.size());
+ // 分批插入数据 每次最多700条
+ for (int i = 0; i < parkingLots.size(); i += 700) {
+ parkingLotService.saveOrUpdateBatch(parkingLots.subList(i, Math.min(i + 700, parkingLots.size())));
+ }
}
List<TParkingRecord> parkingRecords = data1.getParkingRecords();
if (!parkingRecords.isEmpty()) {
- parkingRecordService.saveBatch(parkingRecords);
+ log.info("停车记录"+parkingRecords.size());
+ // 分批插入数据 每次最多700条
+ for (int i = 0; i < parkingRecords.size(); i += 700) {
+ parkingRecordService.saveOrUpdateBatch(parkingRecords.subList(i, Math.min(i + 700, parkingRecords.size())));
+ }
}
-// List<TPartnerSite> partnerSites = data1.getPartnerSites();
-// if (!partnerSites.isEmpty()) {
-// partnerSiteService.saveBatch(partnerSites);
-// }
+ List<TPartnerSite> partnerSites = data1.getPartnerSites();
+ if (partnerSites!=null&&!partnerSites.isEmpty()) {
+ log.info("合作商站点"+parkingRecords.size());
+ // 分批插入数据 每次最多700条
+ for (int i = 0; i < partnerSites.size(); i += 700) {
+ partnerSiteService.saveOrUpdateBatch(partnerSites.subList(i, Math.min(i + 700, partnerSites.size())));
+ }
+ }
List<TRepair> repairs = data1.getRepairs();
if (!repairs.isEmpty()) {
- repairService.saveBatch(repairs);
+ log.info("报修"+repairs.size());
+ // 分批插入数据 每次最多700条
+ for (int i = 0; i < repairs.size(); i += 700) {
+ repairService.saveOrUpdateBatch(repairs.subList(i, Math.min(i + 700, repairs.size())));
+ }
}
-// List<TSiteMenu> siteMenus = data1.getSiteMenus();
-// if (!siteMenus.isEmpty()) {
-// siteMenuService.saveBatch(siteMenus);
-// }
+ List<TSiteMenu> siteMenus = data1.getSiteMenus();
+ if (siteMenus!=null&&!siteMenus.isEmpty()) {
+ log.info("站点菜单"+repairs.size());
+ // 分批插入数据 每次最多700条
+ for (int i = 0; i < siteMenus.size(); i += 700) {
+ siteMenuService.saveOrUpdateBatch(siteMenus.subList(i, Math.min(i + 700, siteMenus.size())));
+ }
+ }
List<TVehicleRamp> vehicleRamps = data1.getVehicleRamps();
if (!vehicleRamps.isEmpty()) {
- vehicleRampService.saveBatch(vehicleRamps);
+ log.info("车道"+vehicleRamps.size());
+ // 分批插入数据 每次最多700条
+ for (int i = 0; i < vehicleRamps.size(); i += 700) {
+ vehicleRampService.saveOrUpdateBatch(vehicleRamps.subList(i, Math.min(i + 700, vehicleRamps.size())));
+ }
}
}
//order服务
GovernmentCloudOrderVO data2 = jianGuanOrderClient.listAll().getData();
-
-
if (data2 != null) {
+ log.info("Order服务");
List<AccountingStrategyDetailOrder> accountingStrategyDetailOrders = data2.getAccountingStrategyDetailOrders();
if (!accountingStrategyDetailOrders.isEmpty()) {
- accountingStrategyDetailOrderService.saveBatch(accountingStrategyDetailOrders);
+ log.info("订单明细策略"+accountingStrategyDetailOrders.size());
+ // 分批插入数据 每次最多700条
+ for (int i = 0; i < accountingStrategyDetailOrders.size(); i += 700) {
+ accountingStrategyDetailOrderService.saveOrUpdateBatch(accountingStrategyDetailOrders.subList(i, Math.min(i + 700, accountingStrategyDetailOrders.size())));
+ }
}
List<AccountingStrategyOrder> accountingStrategyOrders = data2.getAccountingStrategyOrders();
if (!accountingStrategyOrders.isEmpty()) {
- accountingStrategyOrderService.saveBatch(accountingStrategyOrders);
+ log.info("订单策略"+accountingStrategyOrders.size());
+ // 分批插入数据 每次最多700条
+ int size = 700;
+ for (int i = 0; i < accountingStrategyOrders.size(); i += size) {
+ List<AccountingStrategyOrder> subList = accountingStrategyOrders.subList(i, Math.min(i + size, accountingStrategyOrders.size()));
+ accountingStrategyOrderService.saveOrUpdateBatch(subList);
+ }
}
List<TChargingBill> chargingBills = data2.getChargingBills();
if (!chargingBills.isEmpty()) {
- chargingBillService.saveBatch(chargingBills);
+ log.info("账单"+chargingBills.size());
+ // 分批插入数据 每次最多700条
+ // 分批插入数据 每次最多700条
+ for (int i = 0; i < chargingBills.size(); i += 700) {
+ chargingBillService.saveOrUpdateBatch(chargingBills.subList(i, Math.min(i + 700, chargingBills.size())));
+ }
+
}
List<TChargingOrder> chargingOrders = data2.getChargingOrders();
if (!chargingOrders.isEmpty()) {
- chargingOrderService.saveBatch(chargingOrders);
+ log.info("充电订单"+chargingOrders.size());
+ // 分批插入数据 每次最多700条
+ for (int i = 0; i < chargingOrders.size(); i += 700) {
+ chargingOrderService.saveOrUpdateBatch(chargingOrders.subList(i, Math.min(i + 700, chargingOrders.size())));
+ }
}
List<TChargingOrderAccountingStrategy> chargingOrderAccountingStrategies = data2.getChargingOrderAccountingStrategies();
if (!chargingOrderAccountingStrategies.isEmpty()) {
- chargingOrderAccountingStrategyService.saveBatch(chargingOrderAccountingStrategies);
+ log.info("充电订单策略"+chargingOrderAccountingStrategies.size());
+ // 分批插入数据 每次最多700条
+ for (int i = 0; i < chargingOrderAccountingStrategies.size(); i += 700) {
+ chargingOrderAccountingStrategyService.saveOrUpdateBatch(chargingOrderAccountingStrategies.subList(i, Math.min(i + 700, chargingOrderAccountingStrategies.size())));
+ }
}
List<TChargingOrderRefund> chargingOrderRefunds = data2.getChargingOrderRefunds();
if (!chargingOrderRefunds.isEmpty()) {
- chargingOrderRefundService.saveBatch(chargingOrderRefunds);
+ log.info("充电订单退款"+chargingOrderRefunds.size());
+
+ // 分批插入数据 每次最多700条
+ for (int i = 0; i < chargingOrderRefunds.size(); i += 700) {
+ chargingOrderRefundService.saveOrUpdateBatch(chargingOrderRefunds.subList(i, Math.min(i + 700, chargingOrderRefunds.size())));
+ }
}
List<TExchangeOrder> exchangeOrders = data2.getExchangeOrders();
if (!exchangeOrders.isEmpty()) {
- exchangeOrderService.saveBatch(exchangeOrders);
+ log.info("兑换订单"+exchangeOrders.size());
+
+ // 分批插入数据 每次最多700条
+ for (int i = 0; i < exchangeOrders.size(); i += 700) {
+ exchangeOrderService.saveOrUpdateBatch(exchangeOrders.subList(i, Math.min(i + 700, exchangeOrders.size())));
+ }
}
List<TGrantVip> grantVips = data2.getGrantVips();
if (!grantVips.isEmpty()) {
- grantVipService.saveBatch(grantVips);
+ log.info("赠送vip"+grantVips.size());
+
+ // 分批插入数据 每次最多700条
+ for (int i = 0; i < grantVips.size(); i += 700) {
+ grantVipService.saveOrUpdateBatch(grantVips.subList(i, Math.min(i + 700, grantVips.size())));
+ }
}
List<TOrderAppeal> orderAppeals = data2.getOrderAppeals();
if (!orderAppeals.isEmpty()) {
- orderAppealService.saveBatch(orderAppeals);
+ log.info("订单申诉"+orderAppeals.size());
+
+ // 分批插入数据 每次最多700条
+ for (int i = 0; i < orderAppeals.size(); i += 700) {
+ orderAppealService.saveOrUpdateBatch(orderAppeals.subList(i, Math.min(i + 700, orderAppeals.size())));
+ }
}
List<TOrderEvaluate> orderEvaluates = data2.getOrderEvaluates();
if (!orderEvaluates.isEmpty()) {
- orderEvaluateService.saveBatch(orderEvaluates);
+ log.info("订单评价"+orderEvaluates.size());
+
+ // 分批插入数据 每次最多700条
+ for (int i = 0; i < orderEvaluates.size(); i += 700) {
+ orderEvaluateService.saveOrUpdateBatch(orderEvaluates.subList(i, Math.min(i + 700, orderEvaluates.size())));
+ }
}
List<TOrderEvaluateTag> orderEvaluateTags = data2.getOrderEvaluateTags();
if (!orderEvaluateTags.isEmpty()) {
- orderEvaluateTagService.saveBatch(orderEvaluateTags);
+ log.info("订单评价标签"+orderEvaluateTags.size());
+ // 分批插入数据 每次最多700条
+ for (int i = 0; i < orderEvaluateTags.size(); i += 700) {
+ orderEvaluateTagService.saveOrUpdateBatch(orderEvaluateTags.subList(i, Math.min(i + 700, orderEvaluateTags.size())));
+ }
}
List<TOrderInvoice> orderInvoices = data2.getOrderInvoices();
if (!orderInvoices.isEmpty()) {
- orderInvoiceService.saveBatch(orderInvoices);
+ log.info("订单开票"+orderInvoices.size());
+
+ // 分批插入数据 每次最多700条
+ for (int i = 0; i < orderInvoices.size(); i += 700) {
+ orderInvoiceService.saveOrUpdateBatch(orderInvoices.subList(i, Math.min(i + 700, orderInvoices.size())));
+ }
}
List<TOrderInvoiceDetail> orderInvoiceDetails = data2.getOrderInvoiceDetails();
if (!orderInvoiceDetails.isEmpty()) {
- orderInvoiceDetailService.saveBatch(orderInvoiceDetails);
+ log.info("订单开票明细"+orderInvoiceDetails.size());
+ // 分批插入数据 每次最多700条
+ for (int i = 0; i < orderInvoiceDetails.size(); i += 700) {
+ orderInvoiceDetailService.saveOrUpdateBatch(orderInvoiceDetails.subList(i, Math.min(i + 700, orderInvoiceDetails.size())));
+ }
}
List<TSettlementConfirm> settlementConfirms = data2.getSettlementConfirms();
if (!settlementConfirms.isEmpty()) {
- settlementConfirmService.saveBatch(settlementConfirms);
+ log.info("账单结算"+settlementConfirms.size());
+
+ // 分批插入数据 每次最多700条
+ for (int i = 0; i < settlementConfirms.size(); i += 700) {
+ settlementConfirmService.saveOrUpdateBatch(settlementConfirms.subList(i, Math.min(i + 700, settlementConfirms.size())));
+ }
}
List<TShoppingOrder> shoppingOrders = data2.getShoppingOrders();
if (!shoppingOrders.isEmpty()) {
- shoppingOrderService.saveBatch(shoppingOrders);
+ log.info("购物订单"+shoppingOrders.size());
+
+ // 分批插入数据 每次最多700条
+ for (int i = 0; i < shoppingOrders.size(); i += 700) {
+ shoppingOrderService.saveOrUpdateBatch(shoppingOrders.subList(i, Math.min(i + 700, shoppingOrders.size())));
+ }
}
List<TShoppingOrderRefund> shoppingOrderRefunds = data2.getShoppingOrderRefunds();
if (!shoppingOrderRefunds.isEmpty()) {
- shoppingOrderRefundService.saveBatch(shoppingOrderRefunds);
+ log.info("购物订单退款"+shoppingOrderRefunds.size());
+ // 分批插入数据 每次最多700条
+ for (int i = 0; i < shoppingOrderRefunds.size(); i += 700) {
+ shoppingOrderRefundService.saveOrUpdateBatch(shoppingOrderRefunds.subList(i, Math.min(i + 700, shoppingOrderRefunds.size())));
+ }
}
List<TVipOrder> vipOrders = data2.getVipOrders();
if (!vipOrders.isEmpty()) {
- vipOrderService.saveBatch(vipOrders);
+ log.info("会员订单"+vipOrders.size());
+
+ // 分批插入数据 每次最多700条
+ for (int i = 0; i < vipOrders.size(); i += 700) {
+ vipOrderService.saveOrUpdateBatch(vipOrders.subList(i, Math.min(i + 700, vipOrders.size())));
+ }
}
List<TVipOrderRefund> vipOrderRefunds = data2.getVipOrderRefunds();
if (!vipOrderRefunds.isEmpty()) {
- vipOrderRefundService.saveBatch(vipOrderRefunds);
+ log.info("会员订单退款"+vipOrderRefunds);
+
+ // 分批插入数据 每次最多700条
+ for (int i = 0; i < vipOrderRefunds.size(); i += 700) {
+ vipOrderRefundService.saveOrUpdateBatch(vipOrderRefunds.subList(i, Math.min(i + 700, vipOrderRefunds.size())));
+ }
}
}
// other服务
GovernmentCloudOtherVO data3 = jianGuanOtherClient.listAll().getData();
-
-
if (data3 != null) {
+ log.info("other服务");
+
List<Operator> operators = data3.getOperators();
if (!operators.isEmpty()) {
- try {
- operatorService.saveBatch(operators);
- }catch (Exception e){
- }
+ log.info("运营商"+operators.size());
+
+ operatorService.saveOrUpdateBatch(operators);
}
List<TActivity> activities = data3.getActivities();
if (!activities.isEmpty()) {
- activityService.saveBatch(activities);
+ log.info("活动"+activities.size());
+
+ activityService.saveOrUpdateBatch(activities);
}
List<TAdvertising> advertisings = data3.getAdvertisings();
if (!advertisings.isEmpty()) {
- advertisingService.saveBatch(advertisings);
+ log.info("广告"+advertisings.size());
+
+ advertisingService.saveOrUpdateBatch(advertisings);
}
List<TCompany> companies = data3.getCompanies();
if (!companies.isEmpty()) {
- companyService.saveBatch(companies);
+ log.info("公司"+companies.size());
+
+ companyService.saveOrUpdateBatch(companies);
}
List<TCoupon> coupons = data3.getCoupons();
if (!coupons.isEmpty()) {
- couponService.saveBatch(coupons);
+ log.info("优惠券"+coupons.size());
+
+ couponService.saveOrUpdateBatch(coupons);
}
List<TEnterpriseUserApplication> enterpriseUserApplications = data3.getEnterpriseUserApplications();
if (!enterpriseUserApplications.isEmpty()) {
- enterpriseUserApplicationService.saveBatch(enterpriseUserApplications);
+ log.info("公司申请"+enterpriseUserApplications.size());
+
+ enterpriseUserApplicationService.saveOrUpdateBatch(enterpriseUserApplications);
}
List<TEvaluationTag> evaluationTags = data3.getEvaluationTags();
if (!evaluationTags.isEmpty()) {
- evaluationTagService.saveBatch(evaluationTags);
+ log.info("评价标签"+evaluationTags.size());
+
+ evaluationTagService.saveOrUpdateBatch(evaluationTags);
}
List<TGoods> goods = data3.getGoods();
if (!goods.isEmpty()) {
- goodsService.saveBatch(goods);
+ log.info("商品"+goods.size());
+
+ goodsService.saveOrUpdateBatch(goods);
}
List<THtml> htmls = data3.getHtmls();
if (!htmls.isEmpty()) {
- htmlService.saveBatch(htmls);
+ log.info("html"+htmls.size());
+
+ htmlService.saveOrUpdateBatch(htmls);
}
List<TIntegralRule> integralRules = data3.getIntegralRules();
if (!integralRules.isEmpty()) {
- integralRuleService.saveBatch(integralRules);
+ log.info("积分规则"+integralRules.size());
+
+ integralRuleService.saveOrUpdateBatch(integralRules);
}
List<TInvoiceType> invoiceTypes = data3.getInvoiceTypes();
if (!invoiceTypes.isEmpty()) {
- invoiceTypeService.saveBatch(invoiceTypes);
+ log.info("开票类型"+invoiceTypes.size());
+
+ invoiceTypeService.saveOrUpdateBatch(invoiceTypes);
}
List<TNotice> notices = data3.getNotices();
if (!notices.isEmpty()) {
- noticeService.saveBatch(notices);
+ log.info("通知"+notices.size());
+ // 分批插入数据 每次最多700条
+ for (int i = 0; i < notices.size(); i += 700) {
+ noticeService.saveOrUpdateBatch(notices.subList(i, Math.min(i + 700, notices.size())));
+ }
}
List<TSystemConfiguration> systemConfigurations = data3.getSystemConfigurations();
if (!systemConfigurations.isEmpty()) {
- systemConfigurationService.saveBatch(systemConfigurations);
+ log.info("系统设置"+systemConfigurations.size());
+
+ systemConfigurationService.saveOrUpdateBatch(systemConfigurations);
}
List<TUserTag> userTags = data3.getUserTags();
if (!userTags.isEmpty()) {
- userTagService.saveBatch(userTags);
+ log.info("用户标签"+userTags.size());
+
+ // 分批插入数据 每次最多700条
+ for (int i = 0; i < userTags.size(); i += 700) {
+ userTagService.saveOrUpdateBatch(userTags.subList(i, Math.min(i + 700, userTags.size())));
+ }
}
List<TVip> vips = data3.getVips();
if (!vips.isEmpty()) {
- vipService.saveBatch(vips);
+ log.info("会员"+vips.size());
+
+ vipService.saveOrUpdateBatch(vips);
+ }
+ List<TUserSite> userSites = data3.getUserSites();
+ if (userSites!=null&&!userSites.isEmpty()) {
+ log.info("用户站点"+userSites.size());
+
+ // 分批插入数据 每次最多700条
+ for (int i = 0; i < userTags.size(); i += 700) {
+ userSiteService.saveOrUpdateBatch(userSites.subList(i, Math.min(i + 700, userSites.size())));
+ }
+ }
+ List<TRoleSite> roleSites = data3.getRoleSites();
+ if (roleSites!=null&&!userSites.isEmpty()) {
+ log.info("角色站点"+userSites.size());
+ // 分批插入数据 每次最多700条
+ for (int i = 0; i < roleSites.size(); i += 700) {
+ roleSiteService.saveOrUpdateBatch(roleSites.subList(i, Math.min(i + 700, roleSites.size())));
+ }
}
}
-// accountingStrategyDetailOrderService
-// accountingStrategyOrderService
-// genTableColumnService
-// genTableService
-// partnerService
-// regionService
-// siteService
-// sysConfigService
-// deptService
-// sysDictDataService
-// sysDictTypeService
-// sysLoginLogService
-// sysMenuService
-// sysNoticeService
-// sysOperLogService
-// sysPermissionService
-// sysPostService
-// sysRoleService
-// sysUserOnlineService
-// sysUserRoleService
-// sysUserService
-// operatorService
-// accountingStrategyDetailService
-// accountingStrategyService
-// activityService
-// advertisingService
-// appCouponService
-// applyChargingPileService
-// appUserAddressService
-// appUserCarService
-// appUserIntegralChangeService
-// appUserService
-// appUserSignService
-// appUserTagService
-// appUserVipDetailService
-// carportService
-// chargingBillService
-// chargingGunService
-// chargingOrderAccountingStrategyService
-// chargingOrderRefundService
-// chargingOrderService
-// chargingPileNotificationService
-// chargingPileService
-// companyService
-// couponService
-// enterpriseUserApplicationService
-// evaluationTagService
-// exchangeOrderService
-// faultMessageService
-// goodsService
-// grantVipService
-// htmlService
-// integralRuleService
-// inviteUserService
-// tInvoiceInformationService
-// invoiceTypeService
-// monitoringEquipmentService
-// noticeService
-// orderAppealService
-// orderEvaluateService
-// orderEvaluateTagService
-// orderInvoiceDetailService
-// orderInvoiceService
-// parkingLotService
-// parkingRecordService
-// partnerSiteService
-// repairService
-// roleSiteService
-// settlementConfirmService
-// shoppingOrderRefundService
-// shoppingOrderService
-// siteMenuService
-// systemConfigurationService
-// userSiteService
-// userTagService
-// vehicleRampService
-// vipOrderRefundService
-// vipOrderService
-// vipService
+ GovernmentCloudSystemVO data4 = jianGuanSystemClient.listAll().getData();
+ if (data4 != null) {
+ log.info("System服务");
+ List<SysLoginLog> loginLogs = data4.getLoginLogs();
+ if (!loginLogs.isEmpty()) {
+ log.info("登录日志"+loginLogs.size());
+
+ // 分批插入数据 每次最多700条
+ for (int i = 0; i < loginLogs.size(); i += 700) {
+ sysLoginLogService.saveOrUpdateBatch(loginLogs.subList(i, Math.min(i + 700, loginLogs.size())));
+ }
+ }
+ List<SysOperLog> sysOperLogs = data4.getSysOperLogs();
+ if (!sysOperLogs.isEmpty()) {
+ log.info("操作日志"+sysOperLogs.size());
+
+ // 分批插入数据 每次最多700条
+ for (int i = 0; i < sysOperLogs.size(); i += 700) {
+ sysOperLogService.saveOrUpdateBatch(sysOperLogs.subList(i, Math.min(i + 700, sysOperLogs.size())));
+ }
+ }
+ List<SysRole> sysRoles = data4.getSysRoles();
+ if (!sysRoles.isEmpty()) {
+ log.info("角色"+sysRoles.size());
+
+ sysRoleService.saveOrUpdateBatch(sysRoles);
+ }
+ List<SysUser> sysUsers = data4.getSysUsers();
+ if (!sysUsers.isEmpty()) {
+ log.info("系统用户"+sysUsers.size());
+
+ sysUserService.saveOrUpdateBatch(sysUsers);
+ }
+ }
}
-
-
}
--
Gitblit v1.7.1