java/mx_charging_pile.git

			@@ -20,11 +20,13 @@
			import com.ruoyi.common.core.utils.StringUtils;
			import com.ruoyi.common.redis.service.RedisService;
			import com.ruoyi.integration.api.feignClient.ChargingMessageClient;
			import com.ruoyi.integration.api.feignClient.ChengDuJianGuanClient;
			import com.ruoyi.integration.api.feignClient.TCECClient;
			import com.ruoyi.integration.api.feignClient.UploadRealTimeMonitoringDataClient;
			import com.ruoyi.integration.api.model.TransactionRecord;
			import com.ruoyi.integration.api.model.UploadRealTimeMonitoringData;
			import com.ruoyi.integration.api.vo.ChargingOrderVo;
			import com.ruoyi.integration.api.vo.NotificationConnectorChargeStatusVo;
			import com.ruoyi.order.api.model.*;
			import com.ruoyi.order.api.vo.AccountingStrategyDetailOrderVo;
			import com.ruoyi.order.api.vo.TransactionRecordMessageVO;
			@@ -63,6 +65,9 @@
			import java.time.format.DateTimeFormatter;
			import java.time.temporal.ChronoUnit;
			import java.util.*;
			import java.util.concurrent.LinkedBlockingDeque;
			import java.util.concurrent.ThreadPoolExecutor;
			import java.util.concurrent.TimeUnit;
			import java.util.stream.Collectors;

			/**
			@@ -129,6 +134,9 @@

			@Resource
			private ITChargingOrderSummaryDataService chargingOrderSummaryDataService;

			@Resource
			private ChengDuJianGuanClient chengDuJianGuanClient;


			//十分钟循环执行的定时任务
			@@ -620,6 +628,17 @@
			if (2 == order.getOrderSource() && 1 == site.getIsOpenSynchronization()) {
			tcecClient.pushChargingGunStatus(chargingGun.getFullNumber(), 2);
			}
			ThreadPoolExecutor threadPoolExecutor = new ThreadPoolExecutor(1, 1, 0L, TimeUnit.SECONDS, new LinkedBlockingDeque<>());
			TChargingOrder finalOrder = order;
			threadPoolExecutor.execute(()->{
			//推送成都监管
			NotificationConnectorChargeStatusVo statusVo = new NotificationConnectorChargeStatusVo();
			statusVo.setOrderCode(finalOrder.getCode());
			statusVo.setChargingGunId(finalOrder.getChargingGunId());
			chengDuJianGuanClient.notificationConnectorChargeStatus(statusVo);
			chengDuJianGuanClient.notificationOrderInfo(statusVo);
			});


			//添加积分
			if (1 == order.getOrderSource()) {