From 11b7ee0737314f83cc93873663a78a3c60008e52 Mon Sep 17 00:00:00 2001
From: puzhibing <393733352@qq.com>
Date: 星期四, 26 九月 2024 16:01:05 +0800
Subject: [PATCH] Merge remote-tracking branch 'origin/master'
---
ruoyi-service/ruoyi-other/src/main/java/com/ruoyi/other/controller/TVipController.java | 2 ++
ruoyi-service/ruoyi-chargingPile/src/main/java/com/ruoyi/chargingPile/service/impl/TChargingGunServiceImpl.java | 7 +++++++
ruoyi-service/ruoyi-integration/src/main/java/com/ruoyi/integration/iotda/utils/tools/MessageUtil.java | 44 ++++++++++++++++++++++----------------------
ruoyi-service/ruoyi-integration/src/main/java/com/ruoyi/integration/iotda/utils/produce/IotMessageProduce.java | 3 ++-
4 files changed, 33 insertions(+), 23 deletions(-)
diff --git a/ruoyi-service/ruoyi-chargingPile/src/main/java/com/ruoyi/chargingPile/service/impl/TChargingGunServiceImpl.java b/ruoyi-service/ruoyi-chargingPile/src/main/java/com/ruoyi/chargingPile/service/impl/TChargingGunServiceImpl.java
index 02184c2..496022c 100644
--- a/ruoyi-service/ruoyi-chargingPile/src/main/java/com/ruoyi/chargingPile/service/impl/TChargingGunServiceImpl.java
+++ b/ruoyi-service/ruoyi-chargingPile/src/main/java/com/ruoyi/chargingPile/service/impl/TChargingGunServiceImpl.java
@@ -210,6 +210,13 @@
}
List<Map<Integer, Integer>> modeStatistics = this.baseMapper.getModeStatistics(siteIds);
+ if(CollectionUtils.isEmpty(modeStatistics)){
+ Map<Integer, Integer> modeStatistics1 = new HashMap<>(3,0);
+ modeStatistics1.put(1, 0);
+ modeStatistics1.put(2, 0);
+ modeStatistics1.put(3, 0);
+ modeStatistics.add(modeStatistics1);
+ }
gunStatusStatisticsVO.setModeStatistics(modeStatistics);
List<Map<Integer, Integer>> statusStatistics = new ArrayList<>();
diff --git a/ruoyi-service/ruoyi-integration/src/main/java/com/ruoyi/integration/iotda/utils/produce/IotMessageProduce.java b/ruoyi-service/ruoyi-integration/src/main/java/com/ruoyi/integration/iotda/utils/produce/IotMessageProduce.java
index 0269d52..ace5a25 100644
--- a/ruoyi-service/ruoyi-integration/src/main/java/com/ruoyi/integration/iotda/utils/produce/IotMessageProduce.java
+++ b/ruoyi-service/ruoyi-integration/src/main/java/com/ruoyi/integration/iotda/utils/produce/IotMessageProduce.java
@@ -1,5 +1,6 @@
package com.ruoyi.integration.iotda.utils.produce;
+import com.alibaba.fastjson2.JSONObject;
import com.huaweicloud.sdk.core.exception.ConnectionException;
import com.huaweicloud.sdk.core.exception.RequestTimeoutException;
import com.huaweicloud.sdk.core.exception.ServiceResponseException;
@@ -34,7 +35,7 @@
* @return
*/
@PostMapping("/sendMessage")
- public String sendMessage(String deviceId,String name,String message){
+ public String sendMessage(String deviceId, String name, JSONObject message){
CreateMessageRequest request = new CreateMessageRequest();
request.withDeviceId(deviceId);
DeviceMessageRequest body = new DeviceMessageRequest();
diff --git a/ruoyi-service/ruoyi-integration/src/main/java/com/ruoyi/integration/iotda/utils/tools/MessageUtil.java b/ruoyi-service/ruoyi-integration/src/main/java/com/ruoyi/integration/iotda/utils/tools/MessageUtil.java
index 5fdcac0..89e9fc1 100644
--- a/ruoyi-service/ruoyi-integration/src/main/java/com/ruoyi/integration/iotda/utils/tools/MessageUtil.java
+++ b/ruoyi-service/ruoyi-integration/src/main/java/com/ruoyi/integration/iotda/utils/tools/MessageUtil.java
@@ -61,7 +61,7 @@
* @param onlineReply 实体对象
* @return
*/
- public String onlineReply(OnlineReply onlineReply){
+ public JSONObject onlineReply(OnlineReply onlineReply){
onlineReplyService.create(onlineReply);
return getMessageJsonString(onlineReply, ServiceIdMenu.ONLINE_REPLY.getValue());
}
@@ -71,7 +71,7 @@
* @param pong 实体对象
* @return
*/
- public String pong(Pong pong){
+ public JSONObject pong(Pong pong){
pongService.create(pong);
return getMessageJsonString(pong, ServiceIdMenu.PONG.getValue());
}
@@ -81,7 +81,7 @@
* @param billingModeVerifyReply 实体对象
* @return
*/
- public String billingModeVerifyReply(BillingModeVerifyReply billingModeVerifyReply){
+ public JSONObject billingModeVerifyReply(BillingModeVerifyReply billingModeVerifyReply){
billingModeVerifyReplyService.create(billingModeVerifyReply);
return getMessageJsonString(billingModeVerifyReply, ServiceIdMenu.BILLING_MODE_VERIFY_REPLY.getValue());
}
@@ -91,7 +91,7 @@
* @param acquisitionBillingModeReply 实体对象
* @return
*/
- public String acquisitionBillingModeReply(AcquisitionBillingModeReply acquisitionBillingModeReply){
+ public JSONObject acquisitionBillingModeReply(AcquisitionBillingModeReply acquisitionBillingModeReply){
acquisitionBillingModeReplyService.create(acquisitionBillingModeReply);
return getMessageJsonString(acquisitionBillingModeReply, ServiceIdMenu.ACQUISITION_BILLING_MODE_REPLY.getValue());
}
@@ -101,7 +101,7 @@
* @param readRealTimeMonitoringData 实体对象
* @return
*/
- public String readRealTimeMonitoringData(ReadRealTimeMonitoringData readRealTimeMonitoringData){
+ public JSONObject readRealTimeMonitoringData(ReadRealTimeMonitoringData readRealTimeMonitoringData){
readRealTimeMonitoringDataService.create(readRealTimeMonitoringData);
return getMessageJsonString(readRealTimeMonitoringData, ServiceIdMenu.READ_REAL_TIME_MONITORING_DATA.getValue());
}
@@ -121,7 +121,7 @@
* @param platformConfirmationCharging 实体对象
* @return
*/
- public String platformConfirmationCharging(PlatformConfirmationCharging platformConfirmationCharging){
+ public JSONObject platformConfirmationCharging(PlatformConfirmationCharging platformConfirmationCharging){
platformConfirmationChargingService.create(platformConfirmationCharging);
return getMessageJsonString(platformConfirmationCharging, ServiceIdMenu.PLATFORM_CONFIRMATION_CHARGING.getValue());
}
@@ -131,7 +131,7 @@
* @param platformStartCharging 实体对象
* @return
*/
- public String platformStartCharging(PlatformStartCharging platformStartCharging){
+ public JSONObject platformStartCharging(PlatformStartCharging platformStartCharging){
platformStartChargingService.create(platformStartCharging);
return getMessageJsonString(platformStartCharging, ServiceIdMenu.PLATFORM_START_CHARGING.getValue());
}
@@ -141,7 +141,7 @@
* @param platformStopCharging 实体对象
* @return
*/
- public String platformStopCharging(PlatformStopCharging platformStopCharging){
+ public JSONObject platformStopCharging(PlatformStopCharging platformStopCharging){
platformStopChargingService.create(platformStopCharging);
return getMessageJsonString(platformStopCharging, ServiceIdMenu.PLATFORM_STOP_CHARGING.getValue());
}
@@ -151,7 +151,7 @@
* @param confirmTransactionRecord 实体对象
* @return
*/
- public String confirmTransactionRecord(ConfirmTransactionRecord confirmTransactionRecord){
+ public JSONObject confirmTransactionRecord(ConfirmTransactionRecord confirmTransactionRecord){
confirmTransactionRecordService.create(confirmTransactionRecord);
return getMessageJsonString(confirmTransactionRecord, ServiceIdMenu.CONFIRM_TRANSACTION_RECORD.getValue());
}
@@ -161,7 +161,7 @@
* @param updateBalance 实体对象
* @return
*/
- public String updateBalance(UpdateBalance updateBalance){
+ public JSONObject updateBalance(UpdateBalance updateBalance){
updateBalanceService.create(updateBalance);
return getMessageJsonString(updateBalance, ServiceIdMenu.UPDATE_BALANCE.getValue());
}
@@ -171,7 +171,7 @@
* @param synchronizeOfflineCard 实体对象
* @return
*/
- public String synchronizeOfflineCard(SynchronizeOfflineCard synchronizeOfflineCard){
+ public JSONObject synchronizeOfflineCard(SynchronizeOfflineCard synchronizeOfflineCard){
synchronizeOfflineCardService.create(synchronizeOfflineCard);
return getMessageJsonString(synchronizeOfflineCard, ServiceIdMenu.SYNCHRONIZE_OFFLINE_CARD.getValue());
}
@@ -181,7 +181,7 @@
* @param clearOfflineCard 实体对象
* @return
*/
- public String clearOfflineCard(ClearOfflineCard clearOfflineCard){
+ public JSONObject clearOfflineCard(ClearOfflineCard clearOfflineCard){
clearOfflineCardService.create(clearOfflineCard);
return getMessageJsonString(clearOfflineCard, ServiceIdMenu.CLEAR_OFFLINE_CARD.getValue());
}
@@ -191,7 +191,7 @@
* @param queryOfflineCard 实体对象
* @return
*/
- public String queryOfflineCard(QueryOfflineCard queryOfflineCard){
+ public JSONObject queryOfflineCard(QueryOfflineCard queryOfflineCard){
queryOfflineCardService.create(queryOfflineCard);
return getMessageJsonString(queryOfflineCard, ServiceIdMenu.QUERY_OFFLINE_CARD.getValue());
}
@@ -201,7 +201,7 @@
* @param workingParameterSetting 实体对象
* @return
*/
- public String workingParameterSetting(WorkingParameterSetting workingParameterSetting){
+ public JSONObject workingParameterSetting(WorkingParameterSetting workingParameterSetting){
workingParameterSettingService.create(workingParameterSetting);
return getMessageJsonString(workingParameterSetting, ServiceIdMenu.WORKING_PARAMETER_SETTING.getValue());
}
@@ -211,7 +211,7 @@
* @param timingSetting 实体对象
* @return
*/
- public String timingSetting(TimingSetting timingSetting){
+ public JSONObject timingSetting(TimingSetting timingSetting){
timingSettingService.create(timingSetting);
return getMessageJsonString(timingSetting, ServiceIdMenu.TIMING_SETTING.getValue());
}
@@ -220,7 +220,7 @@
* @param timingSettingReply 实体对象
* @return
*/
- public String timingSettingReply(TimingSettingReply timingSettingReply){
+ public JSONObject timingSettingReply(TimingSettingReply timingSettingReply){
timingSettingReplyService.create(timingSettingReply);
return getMessageJsonString(timingSettingReply, ServiceIdMenu.TIMING_SETTING_REPLY.getValue());
}
@@ -230,7 +230,7 @@
* @param setupBillingModel 实体对象
* @return
*/
- public String setupBillingModel(SetupBillingModel setupBillingModel){
+ public JSONObject setupBillingModel(SetupBillingModel setupBillingModel){
setupBillingModelService.create(setupBillingModel);
return getMessageJsonString(setupBillingModel, ServiceIdMenu.SETUP_BILLING_MODEL.getValue());
}
@@ -240,7 +240,7 @@
* @param openOrCloseGroundLock 实体对象
* @return
*/
- public String openOrCloseGroundLock(OpenOrCloseGroundLock openOrCloseGroundLock){
+ public JSONObject openOrCloseGroundLock(OpenOrCloseGroundLock openOrCloseGroundLock){
openOrCloseGroundLockService.create(openOrCloseGroundLock);
return getMessageJsonString(openOrCloseGroundLock, ServiceIdMenu.OPEN_OR_CLOSE_GROUND_LOCK.getValue());
}
@@ -249,7 +249,7 @@
* @param platformRestart 实体对象
* @return
*/
- public String platformRestart(PlatformRestart platformRestart){
+ public JSONObject platformRestart(PlatformRestart platformRestart){
platformRestartService.create(platformRestart);
return getMessageJsonString(platformRestart, ServiceIdMenu.PLATFORM_RESTART.getValue());
}
@@ -258,7 +258,7 @@
* @param platformRemoteUpdate 实体对象
* @return
*/
- public String platformRemoteUpdate(PlatformRemoteUpdate platformRemoteUpdate){
+ public JSONObject platformRemoteUpdate(PlatformRemoteUpdate platformRemoteUpdate){
platformRemoteUpdateService.create(platformRemoteUpdate);
return getMessageJsonString(platformRemoteUpdate, ServiceIdMenu.PLATFORM_REMOTE_UPDATE.getValue());
}
@@ -269,9 +269,9 @@
* @param serviceId 服务ID
* @return
*/
- public String getMessageJsonString(Object object, String serviceId){
+ public JSONObject getMessageJsonString(Object object, String serviceId){
JSONObject jsonObject = JSONObject.parseObject(JSONObject.toJSONString(object));
jsonObject.put("service_id", serviceId);
- return jsonObject.toJSONString();
+ return jsonObject;
}
}
diff --git a/ruoyi-service/ruoyi-other/src/main/java/com/ruoyi/other/controller/TVipController.java b/ruoyi-service/ruoyi-other/src/main/java/com/ruoyi/other/controller/TVipController.java
index 5bb53f0..99d7270 100644
--- a/ruoyi-service/ruoyi-other/src/main/java/com/ruoyi/other/controller/TVipController.java
+++ b/ruoyi-service/ruoyi-other/src/main/java/com/ruoyi/other/controller/TVipController.java
@@ -136,6 +136,7 @@
return R.ok(vipService.getOne(Wrappers.lambdaQuery(TVip.class)
.eq(TVip::getReveal,1)
.orderByDesc(TVip::getMaximumDeduction)
+ .orderByDesc(TVip::getCreateTime)
.last("LIMIT 1")));
case 2:
return R.ok(vipService.getOne(Wrappers.lambdaQuery(TVip.class)
@@ -146,6 +147,7 @@
return R.ok(vipService.getOne(Wrappers.lambdaQuery(TVip.class)
.eq(TVip::getReveal,1)
.orderByDesc(TVip::getMonthlyCardDiscount)
+ .orderByDesc(TVip::getCreateTime)
.last("LIMIT 1")));
}
}
--
Gitblit v1.7.1