From 3e261beffdab4bfd58ebcf723496e7f78c618e44 Mon Sep 17 00:00:00 2001 From: xuhy <3313886187@qq.com> Date: 星期五, 23 八月 2024 09:55:38 +0800 Subject: [PATCH] 消息发送封装完成 --- ruoyi-service/ruoyi-integration/src/main/java/com/ruoyi/integration/mongodb/service/OpenOrCloseGroundLockService.java | 7 ruoyi-service/ruoyi-integration/src/main/java/com/ruoyi/integration/mongodb/service/impl/PlatformRestartServiceImpl.java | 31 ++ ruoyi-service/ruoyi-integration/src/main/java/com/ruoyi/integration/mongodb/service/impl/TimingSettingServiceImpl.java | 31 ++ ruoyi-service/ruoyi-integration/src/main/java/com/ruoyi/integration/mongodb/service/SetupBillingModelService.java | 7 ruoyi-service/ruoyi-integration/src/main/java/com/ruoyi/integration/mongodb/service/UpdateBalanceService.java | 7 ruoyi-service/ruoyi-integration/src/main/java/com/ruoyi/integration/mongodb/service/impl/SynchronizeOfflineCardServiceImpl.java | 33 +++ ruoyi-service/ruoyi-integration/src/main/java/com/ruoyi/integration/iotda/constant/ServiceIdConstant.java | 48 ++++ ruoyi-service/ruoyi-integration/src/main/java/com/ruoyi/integration/mongodb/service/TimingSettingService.java | 7 ruoyi-service/ruoyi-integration/src/main/java/com/ruoyi/integration/iotda/utils/tools/MessageUtil.java | 140 ++++++++++++ ruoyi-service/ruoyi-integration/src/main/java/com/ruoyi/integration/mongodb/service/QueryOfflineCardService.java | 7 ruoyi-service/ruoyi-integration/src/main/java/com/ruoyi/integration/mongodb/service/impl/SetupBillingModelServiceImpl.java | 31 ++ ruoyi-service/ruoyi-integration/src/main/java/com/ruoyi/integration/mongodb/service/impl/WorkingParameterSettingServiceImpl.java | 31 ++ ruoyi-service/ruoyi-integration/src/main/java/com/ruoyi/integration/mongodb/service/WorkingParameterSettingService.java | 7 ruoyi-service/ruoyi-integration/src/main/java/com/ruoyi/integration/mongodb/service/impl/ConfirmTransactionRecordServiceImpl.java | 33 +++ ruoyi-service/ruoyi-integration/src/main/java/com/ruoyi/integration/mongodb/service/SynchronizeOfflineCardService.java | 7 ruoyi-service/ruoyi-integration/src/main/java/com/ruoyi/integration/mongodb/service/PlatformRemoteUpdateService.java | 7 ruoyi-service/ruoyi-integration/src/main/java/com/ruoyi/integration/mongodb/service/impl/UpdateBalanceServiceImpl.java | 33 +++ ruoyi-service/ruoyi-integration/src/main/java/com/ruoyi/integration/mongodb/service/impl/PlatformStopChargingServiceImpl.java | 33 +++ ruoyi-service/ruoyi-integration/src/main/java/com/ruoyi/integration/mongodb/service/PlatformRestartService.java | 7 ruoyi-service/ruoyi-integration/src/main/java/com/ruoyi/integration/mongodb/service/impl/PlatformRemoteUpdateServiceImpl.java | 31 ++ ruoyi-service/ruoyi-integration/src/main/java/com/ruoyi/integration/mongodb/service/ClearOfflineCardService.java | 7 ruoyi-service/ruoyi-integration/src/main/java/com/ruoyi/integration/mongodb/service/impl/ClearOfflineCardServiceImpl.java | 31 ++ ruoyi-service/ruoyi-integration/src/main/java/com/ruoyi/integration/mongodb/service/impl/OpenOrCloseGroundLockServiceImpl.java | 31 ++ ruoyi-service/ruoyi-integration/src/main/java/com/ruoyi/integration/mongodb/service/PlatformStopChargingService.java | 7 ruoyi-service/ruoyi-integration/src/main/java/com/ruoyi/integration/mongodb/service/impl/QueryOfflineCardServiceImpl.java | 31 ++ ruoyi-service/ruoyi-integration/src/main/java/com/ruoyi/integration/mongodb/service/ConfirmTransactionRecordService.java | 7 26 files changed, 652 insertions(+), 0 deletions(-) diff --git a/ruoyi-service/ruoyi-integration/src/main/java/com/ruoyi/integration/iotda/constant/ServiceIdConstant.java b/ruoyi-service/ruoyi-integration/src/main/java/com/ruoyi/integration/iotda/constant/ServiceIdConstant.java index 8043449..a75de5a 100644 --- a/ruoyi-service/ruoyi-integration/src/main/java/com/ruoyi/integration/iotda/constant/ServiceIdConstant.java +++ b/ruoyi-service/ruoyi-integration/src/main/java/com/ruoyi/integration/iotda/constant/ServiceIdConstant.java @@ -33,5 +33,53 @@ * 运营平台远程控制启机 */ public static final String PLATFORM_START_CHARGING = "platform_start_charging"; + /** + * 运营平台远程停机 + */ + public static final String PLATFORM_STOP_CHARGING = "platform_stop_charging"; + /** + * 交易记录确认 + */ + public static final String CONFIRM_TRANSACTION_RECORD = "confirm_transaction_record"; + /** + * 远程账户余额更新 + */ + public static final String UPDATE_BALANCE = "update_balance"; + /** + * 离线卡数据同步 + */ + public static final String SYNCHRONIZE_OFFLINE_CARD = "synchronize_offline_card"; + /** + * 离线卡数据清除 + */ + public static final String CLEAR_OFFLINE_CARD = "clear_offline_card"; + /** + * 离线卡数据查询 + */ + public static final String QUERY_OFFLINE_CARD = "query_offline_card"; + /** + * 充电桩工作参数设置 + */ + public static final String WORKING_PARAMETER_SETTING = "working_parameter_setting"; + /** + * 对时设置 + */ + public static final String TIMING_SETTING = "timing_setting"; + /** + * 计费模型设置 + */ + public static final String SETUP_BILLING_MODEL = "setup_billing_model"; + /** + * 遥控地锁升锁与降锁命令 (下行) + */ + public static final String OPEN_OR_CLOSE_GROUND_LOCK = "open_or_close_ground_lock"; + /** + * 远程重启 + */ + public static final String PLATFORM_RESTART = "platform_restart"; + /** + * 远程更新 + */ + public static final String PLATFORM_REMOTE_UPDATE = "platform_remote_update"; } 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 7691758..09df514 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 @@ -26,6 +26,30 @@ private PlatformConfirmationChargingService platformConfirmationChargingService; @Autowired private PlatformStartChargingService platformStartChargingService; + @Autowired + private PlatformStopChargingService platformStopChargingService; + @Autowired + private ConfirmTransactionRecordService confirmTransactionRecordService; + @Autowired + private UpdateBalanceService updateBalanceService; + @Autowired + private SynchronizeOfflineCardService synchronizeOfflineCardService; + @Autowired + private ClearOfflineCardService clearOfflineCardService; + @Autowired + private QueryOfflineCardService queryOfflineCardService; + @Autowired + private WorkingParameterSettingService workingParameterSettingService; + @Autowired + private TimingSettingService timingSettingService; + @Autowired + private SetupBillingModelService setupBillingModelService; + @Autowired + private OpenOrCloseGroundLockService openOrCloseGroundLockService; + @Autowired + private PlatformRestartService platformRestartService; + @Autowired + private PlatformRemoteUpdateService platformRemoteUpdateService; /** * 登录认证应答 @@ -107,7 +131,123 @@ return getMessageJsonString(platformStartCharging, ServiceIdConstant.PLATFORM_START_CHARGING); } + /** + * 运营平台远程停机 + * @param platformStopCharging 实体对象 + * @return + */ + public String platformStopCharging(PlatformStopCharging platformStopCharging){ + platformStopChargingService.create(platformStopCharging); + return getMessageJsonString(platformStopCharging, ServiceIdConstant.PLATFORM_STOP_CHARGING); + } + /** + * 交易记录确认 + * @param confirmTransactionRecord 实体对象 + * @return + */ + public String confirmTransactionRecord(ConfirmTransactionRecord confirmTransactionRecord){ + confirmTransactionRecordService.create(confirmTransactionRecord); + return getMessageJsonString(confirmTransactionRecord, ServiceIdConstant.CONFIRM_TRANSACTION_RECORD); + } + + /** + * 远程账户余额更新 + * @param updateBalance 实体对象 + * @return + */ + public String updateBalance(UpdateBalance updateBalance){ + updateBalanceService.create(updateBalance); + return getMessageJsonString(updateBalance, ServiceIdConstant.UPDATE_BALANCE); + } + + /** + * 离线卡数据同步 + * @param synchronizeOfflineCard 实体对象 + * @return + */ + public String synchronizeOfflineCard(SynchronizeOfflineCard synchronizeOfflineCard){ + synchronizeOfflineCardService.create(synchronizeOfflineCard); + return getMessageJsonString(synchronizeOfflineCard, ServiceIdConstant.SYNCHRONIZE_OFFLINE_CARD); + } + + /** + * 离线卡数据清除 + * @param clearOfflineCard 实体对象 + * @return + */ + public String clearOfflineCard(ClearOfflineCard clearOfflineCard){ + clearOfflineCardService.create(clearOfflineCard); + return getMessageJsonString(clearOfflineCard, ServiceIdConstant.CLEAR_OFFLINE_CARD); + } + + /** + * 离线卡数据查询 + * @param queryOfflineCard 实体对象 + * @return + */ + public String queryOfflineCard(QueryOfflineCard queryOfflineCard){ + queryOfflineCardService.create(queryOfflineCard); + return getMessageJsonString(queryOfflineCard, ServiceIdConstant.QUERY_OFFLINE_CARD); + } + + /** + * 充电桩工作参数设置 + * @param workingParameterSetting 实体对象 + * @return + */ + public String workingParameterSetting(WorkingParameterSetting workingParameterSetting){ + workingParameterSettingService.create(workingParameterSetting); + return getMessageJsonString(workingParameterSetting, ServiceIdConstant.WORKING_PARAMETER_SETTING); + } + + /** + * 对时设置 + * @param timingSetting 实体对象 + * @return + */ + public String timingSetting(TimingSetting timingSetting){ + timingSettingService.create(timingSetting); + return getMessageJsonString(timingSetting, ServiceIdConstant.TIMING_SETTING); + } + + /** + * 计费模型设置 + * @param setupBillingModel 实体对象 + * @return + */ + public String setupBillingModel(SetupBillingModel setupBillingModel){ + setupBillingModelService.create(setupBillingModel); + return getMessageJsonString(setupBillingModel, ServiceIdConstant.SETUP_BILLING_MODEL); + } + + /** + * 遥控地锁升锁与降锁命令 (下行) + * @param openOrCloseGroundLock 实体对象 + * @return + */ + public String openOrCloseGroundLock(OpenOrCloseGroundLock openOrCloseGroundLock){ + openOrCloseGroundLockService.create(openOrCloseGroundLock); + return getMessageJsonString(openOrCloseGroundLock, ServiceIdConstant.OPEN_OR_CLOSE_GROUND_LOCK); + } + /** + * 远程重启 + * @param platformRestart 实体对象 + * @return + */ + public String platformRestart(PlatformRestart platformRestart){ + platformRestartService.create(platformRestart); + return getMessageJsonString(platformRestart, ServiceIdConstant.PLATFORM_RESTART); + } + /** + * 远程更新 + * @param platformRemoteUpdate 实体对象 + * @return + */ + public String platformRemoteUpdate(PlatformRemoteUpdate platformRemoteUpdate){ + platformRemoteUpdateService.create(platformRemoteUpdate); + return getMessageJsonString(platformRemoteUpdate, ServiceIdConstant.PLATFORM_REMOTE_UPDATE); + } /** * 统一封装消息 diff --git a/ruoyi-service/ruoyi-integration/src/main/java/com/ruoyi/integration/mongodb/service/ClearOfflineCardService.java b/ruoyi-service/ruoyi-integration/src/main/java/com/ruoyi/integration/mongodb/service/ClearOfflineCardService.java new file mode 100644 index 0000000..ca5cf48 --- /dev/null +++ b/ruoyi-service/ruoyi-integration/src/main/java/com/ruoyi/integration/mongodb/service/ClearOfflineCardService.java @@ -0,0 +1,7 @@ +package com.ruoyi.integration.mongodb.service; + +import com.ruoyi.integration.mongodb.base.BaseService; +import com.ruoyi.integration.mongodb.model.ClearOfflineCard; + +public interface ClearOfflineCardService extends BaseService<ClearOfflineCard> { +} diff --git a/ruoyi-service/ruoyi-integration/src/main/java/com/ruoyi/integration/mongodb/service/ConfirmTransactionRecordService.java b/ruoyi-service/ruoyi-integration/src/main/java/com/ruoyi/integration/mongodb/service/ConfirmTransactionRecordService.java new file mode 100644 index 0000000..dc44702 --- /dev/null +++ b/ruoyi-service/ruoyi-integration/src/main/java/com/ruoyi/integration/mongodb/service/ConfirmTransactionRecordService.java @@ -0,0 +1,7 @@ +package com.ruoyi.integration.mongodb.service; + +import com.ruoyi.integration.mongodb.base.BaseService; +import com.ruoyi.integration.mongodb.model.ConfirmTransactionRecord; + +public interface ConfirmTransactionRecordService extends BaseService<ConfirmTransactionRecord> { +} diff --git a/ruoyi-service/ruoyi-integration/src/main/java/com/ruoyi/integration/mongodb/service/OpenOrCloseGroundLockService.java b/ruoyi-service/ruoyi-integration/src/main/java/com/ruoyi/integration/mongodb/service/OpenOrCloseGroundLockService.java new file mode 100644 index 0000000..8d49063 --- /dev/null +++ b/ruoyi-service/ruoyi-integration/src/main/java/com/ruoyi/integration/mongodb/service/OpenOrCloseGroundLockService.java @@ -0,0 +1,7 @@ +package com.ruoyi.integration.mongodb.service; + +import com.ruoyi.integration.mongodb.base.BaseService; +import com.ruoyi.integration.mongodb.model.OpenOrCloseGroundLock; + +public interface OpenOrCloseGroundLockService extends BaseService<OpenOrCloseGroundLock> { +} diff --git a/ruoyi-service/ruoyi-integration/src/main/java/com/ruoyi/integration/mongodb/service/PlatformRemoteUpdateService.java b/ruoyi-service/ruoyi-integration/src/main/java/com/ruoyi/integration/mongodb/service/PlatformRemoteUpdateService.java new file mode 100644 index 0000000..fee304d --- /dev/null +++ b/ruoyi-service/ruoyi-integration/src/main/java/com/ruoyi/integration/mongodb/service/PlatformRemoteUpdateService.java @@ -0,0 +1,7 @@ +package com.ruoyi.integration.mongodb.service; + +import com.ruoyi.integration.mongodb.base.BaseService; +import com.ruoyi.integration.mongodb.model.PlatformRemoteUpdate; + +public interface PlatformRemoteUpdateService extends BaseService<PlatformRemoteUpdate> { +} diff --git a/ruoyi-service/ruoyi-integration/src/main/java/com/ruoyi/integration/mongodb/service/PlatformRestartService.java b/ruoyi-service/ruoyi-integration/src/main/java/com/ruoyi/integration/mongodb/service/PlatformRestartService.java new file mode 100644 index 0000000..96a3df4 --- /dev/null +++ b/ruoyi-service/ruoyi-integration/src/main/java/com/ruoyi/integration/mongodb/service/PlatformRestartService.java @@ -0,0 +1,7 @@ +package com.ruoyi.integration.mongodb.service; + +import com.ruoyi.integration.mongodb.base.BaseService; +import com.ruoyi.integration.mongodb.model.PlatformRestart; + +public interface PlatformRestartService extends BaseService<PlatformRestart> { +} diff --git a/ruoyi-service/ruoyi-integration/src/main/java/com/ruoyi/integration/mongodb/service/PlatformStopChargingService.java b/ruoyi-service/ruoyi-integration/src/main/java/com/ruoyi/integration/mongodb/service/PlatformStopChargingService.java new file mode 100644 index 0000000..a6ee95b --- /dev/null +++ b/ruoyi-service/ruoyi-integration/src/main/java/com/ruoyi/integration/mongodb/service/PlatformStopChargingService.java @@ -0,0 +1,7 @@ +package com.ruoyi.integration.mongodb.service; + +import com.ruoyi.integration.mongodb.base.BaseService; +import com.ruoyi.integration.mongodb.model.PlatformStopCharging; + +public interface PlatformStopChargingService extends BaseService<PlatformStopCharging> { +} diff --git a/ruoyi-service/ruoyi-integration/src/main/java/com/ruoyi/integration/mongodb/service/QueryOfflineCardService.java b/ruoyi-service/ruoyi-integration/src/main/java/com/ruoyi/integration/mongodb/service/QueryOfflineCardService.java new file mode 100644 index 0000000..e141bc6 --- /dev/null +++ b/ruoyi-service/ruoyi-integration/src/main/java/com/ruoyi/integration/mongodb/service/QueryOfflineCardService.java @@ -0,0 +1,7 @@ +package com.ruoyi.integration.mongodb.service; + +import com.ruoyi.integration.mongodb.base.BaseService; +import com.ruoyi.integration.mongodb.model.QueryOfflineCard; + +public interface QueryOfflineCardService extends BaseService<QueryOfflineCard> { +} diff --git a/ruoyi-service/ruoyi-integration/src/main/java/com/ruoyi/integration/mongodb/service/SetupBillingModelService.java b/ruoyi-service/ruoyi-integration/src/main/java/com/ruoyi/integration/mongodb/service/SetupBillingModelService.java new file mode 100644 index 0000000..0d45529 --- /dev/null +++ b/ruoyi-service/ruoyi-integration/src/main/java/com/ruoyi/integration/mongodb/service/SetupBillingModelService.java @@ -0,0 +1,7 @@ +package com.ruoyi.integration.mongodb.service; + +import com.ruoyi.integration.mongodb.base.BaseService; +import com.ruoyi.integration.mongodb.model.SetupBillingModel; + +public interface SetupBillingModelService extends BaseService<SetupBillingModel> { +} diff --git a/ruoyi-service/ruoyi-integration/src/main/java/com/ruoyi/integration/mongodb/service/SynchronizeOfflineCardService.java b/ruoyi-service/ruoyi-integration/src/main/java/com/ruoyi/integration/mongodb/service/SynchronizeOfflineCardService.java new file mode 100644 index 0000000..6281819 --- /dev/null +++ b/ruoyi-service/ruoyi-integration/src/main/java/com/ruoyi/integration/mongodb/service/SynchronizeOfflineCardService.java @@ -0,0 +1,7 @@ +package com.ruoyi.integration.mongodb.service; + +import com.ruoyi.integration.mongodb.base.BaseService; +import com.ruoyi.integration.mongodb.model.SynchronizeOfflineCard; + +public interface SynchronizeOfflineCardService extends BaseService<SynchronizeOfflineCard> { +} diff --git a/ruoyi-service/ruoyi-integration/src/main/java/com/ruoyi/integration/mongodb/service/TimingSettingService.java b/ruoyi-service/ruoyi-integration/src/main/java/com/ruoyi/integration/mongodb/service/TimingSettingService.java new file mode 100644 index 0000000..f4d2f5d --- /dev/null +++ b/ruoyi-service/ruoyi-integration/src/main/java/com/ruoyi/integration/mongodb/service/TimingSettingService.java @@ -0,0 +1,7 @@ +package com.ruoyi.integration.mongodb.service; + +import com.ruoyi.integration.mongodb.base.BaseService; +import com.ruoyi.integration.mongodb.model.TimingSetting; + +public interface TimingSettingService extends BaseService<TimingSetting> { +} diff --git a/ruoyi-service/ruoyi-integration/src/main/java/com/ruoyi/integration/mongodb/service/UpdateBalanceService.java b/ruoyi-service/ruoyi-integration/src/main/java/com/ruoyi/integration/mongodb/service/UpdateBalanceService.java new file mode 100644 index 0000000..488e81c --- /dev/null +++ b/ruoyi-service/ruoyi-integration/src/main/java/com/ruoyi/integration/mongodb/service/UpdateBalanceService.java @@ -0,0 +1,7 @@ +package com.ruoyi.integration.mongodb.service; + +import com.ruoyi.integration.mongodb.base.BaseService; +import com.ruoyi.integration.mongodb.model.UpdateBalance; + +public interface UpdateBalanceService extends BaseService<UpdateBalance> { +} diff --git a/ruoyi-service/ruoyi-integration/src/main/java/com/ruoyi/integration/mongodb/service/WorkingParameterSettingService.java b/ruoyi-service/ruoyi-integration/src/main/java/com/ruoyi/integration/mongodb/service/WorkingParameterSettingService.java new file mode 100644 index 0000000..ab588a2 --- /dev/null +++ b/ruoyi-service/ruoyi-integration/src/main/java/com/ruoyi/integration/mongodb/service/WorkingParameterSettingService.java @@ -0,0 +1,7 @@ +package com.ruoyi.integration.mongodb.service; + +import com.ruoyi.integration.mongodb.base.BaseService; +import com.ruoyi.integration.mongodb.model.WorkingParameterSetting; + +public interface WorkingParameterSettingService extends BaseService<WorkingParameterSetting> { +} diff --git a/ruoyi-service/ruoyi-integration/src/main/java/com/ruoyi/integration/mongodb/service/impl/ClearOfflineCardServiceImpl.java b/ruoyi-service/ruoyi-integration/src/main/java/com/ruoyi/integration/mongodb/service/impl/ClearOfflineCardServiceImpl.java new file mode 100644 index 0000000..308c0f6 --- /dev/null +++ b/ruoyi-service/ruoyi-integration/src/main/java/com/ruoyi/integration/mongodb/service/impl/ClearOfflineCardServiceImpl.java @@ -0,0 +1,31 @@ +package com.ruoyi.integration.mongodb.service.impl; + +import com.ruoyi.integration.iotda.constant.IotConstant; +import com.ruoyi.integration.mongodb.model.ClearOfflineCard; +import com.ruoyi.integration.mongodb.service.ClearOfflineCardService; +import org.springframework.beans.factory.annotation.Autowired; +import org.springframework.data.mongodb.core.MongoTemplate; +import org.springframework.stereotype.Service; + +import java.util.List; + +@Service +public class ClearOfflineCardServiceImpl implements ClearOfflineCardService { + @Autowired + private MongoTemplate mongoTemplate; + @Override + public int create(ClearOfflineCard clearOfflineCard) { + mongoTemplate.save(clearOfflineCard); + return IotConstant.SUCCESS; + } + + @Override + public ClearOfflineCard findById(String id) { + return mongoTemplate.findById(id, ClearOfflineCard.class); + } + + @Override + public List<ClearOfflineCard> findAll() { + return mongoTemplate.findAll(ClearOfflineCard.class); + } +} diff --git a/ruoyi-service/ruoyi-integration/src/main/java/com/ruoyi/integration/mongodb/service/impl/ConfirmTransactionRecordServiceImpl.java b/ruoyi-service/ruoyi-integration/src/main/java/com/ruoyi/integration/mongodb/service/impl/ConfirmTransactionRecordServiceImpl.java new file mode 100644 index 0000000..a918eb4 --- /dev/null +++ b/ruoyi-service/ruoyi-integration/src/main/java/com/ruoyi/integration/mongodb/service/impl/ConfirmTransactionRecordServiceImpl.java @@ -0,0 +1,33 @@ +package com.ruoyi.integration.mongodb.service.impl; + +import com.ruoyi.integration.iotda.constant.IotConstant; +import com.ruoyi.integration.mongodb.model.ConfirmTransactionRecord; +import com.ruoyi.integration.mongodb.service.ConfirmTransactionRecordService; +import org.springframework.beans.factory.annotation.Autowired; +import org.springframework.data.mongodb.core.MongoTemplate; +import org.springframework.stereotype.Service; + +import java.util.List; + +@Service +public class ConfirmTransactionRecordServiceImpl implements ConfirmTransactionRecordService { + + @Autowired + private MongoTemplate mongoTemplate; + + @Override + public int create(ConfirmTransactionRecord confirmTransactionRecord) { + mongoTemplate.save(confirmTransactionRecord); + return IotConstant.SUCCESS; + } + + @Override + public ConfirmTransactionRecord findById(String id) { + return mongoTemplate.findById(id, ConfirmTransactionRecord.class); + } + + @Override + public List<ConfirmTransactionRecord> findAll() { + return mongoTemplate.findAll(ConfirmTransactionRecord.class); + } +} diff --git a/ruoyi-service/ruoyi-integration/src/main/java/com/ruoyi/integration/mongodb/service/impl/OpenOrCloseGroundLockServiceImpl.java b/ruoyi-service/ruoyi-integration/src/main/java/com/ruoyi/integration/mongodb/service/impl/OpenOrCloseGroundLockServiceImpl.java new file mode 100644 index 0000000..467242e --- /dev/null +++ b/ruoyi-service/ruoyi-integration/src/main/java/com/ruoyi/integration/mongodb/service/impl/OpenOrCloseGroundLockServiceImpl.java @@ -0,0 +1,31 @@ +package com.ruoyi.integration.mongodb.service.impl; + +import com.ruoyi.integration.iotda.constant.IotConstant; +import com.ruoyi.integration.mongodb.model.OpenOrCloseGroundLock; +import com.ruoyi.integration.mongodb.service.OpenOrCloseGroundLockService; +import org.springframework.beans.factory.annotation.Autowired; +import org.springframework.data.mongodb.core.MongoTemplate; +import org.springframework.stereotype.Service; + +import java.util.List; + +@Service +public class OpenOrCloseGroundLockServiceImpl implements OpenOrCloseGroundLockService { + @Autowired + private MongoTemplate mongoTemplate; + @Override + public int create(OpenOrCloseGroundLock openOrCloseGroundLock) { + mongoTemplate.save(openOrCloseGroundLock); + return IotConstant.SUCCESS; + } + + @Override + public OpenOrCloseGroundLock findById(String id) { + return mongoTemplate.findById(id, OpenOrCloseGroundLock.class); + } + + @Override + public List<OpenOrCloseGroundLock> findAll() { + return mongoTemplate.findAll(OpenOrCloseGroundLock.class); + } +} diff --git a/ruoyi-service/ruoyi-integration/src/main/java/com/ruoyi/integration/mongodb/service/impl/PlatformRemoteUpdateServiceImpl.java b/ruoyi-service/ruoyi-integration/src/main/java/com/ruoyi/integration/mongodb/service/impl/PlatformRemoteUpdateServiceImpl.java new file mode 100644 index 0000000..ed1bd60 --- /dev/null +++ b/ruoyi-service/ruoyi-integration/src/main/java/com/ruoyi/integration/mongodb/service/impl/PlatformRemoteUpdateServiceImpl.java @@ -0,0 +1,31 @@ +package com.ruoyi.integration.mongodb.service.impl; + +import com.ruoyi.integration.iotda.constant.IotConstant; +import com.ruoyi.integration.mongodb.model.PlatformRemoteUpdate; +import com.ruoyi.integration.mongodb.service.PlatformRemoteUpdateService; +import org.springframework.beans.factory.annotation.Autowired; +import org.springframework.data.mongodb.core.MongoTemplate; +import org.springframework.stereotype.Service; + +import java.util.List; + +@Service +public class PlatformRemoteUpdateServiceImpl implements PlatformRemoteUpdateService { + @Autowired + private MongoTemplate mongoTemplate; + @Override + public int create(PlatformRemoteUpdate platformRemoteUpdate) { + mongoTemplate.save(platformRemoteUpdate); + return IotConstant.SUCCESS; + } + + @Override + public PlatformRemoteUpdate findById(String id) { + return mongoTemplate.findById(id, PlatformRemoteUpdate.class); + } + + @Override + public List<PlatformRemoteUpdate> findAll() { + return mongoTemplate.findAll(PlatformRemoteUpdate.class); + } +} diff --git a/ruoyi-service/ruoyi-integration/src/main/java/com/ruoyi/integration/mongodb/service/impl/PlatformRestartServiceImpl.java b/ruoyi-service/ruoyi-integration/src/main/java/com/ruoyi/integration/mongodb/service/impl/PlatformRestartServiceImpl.java new file mode 100644 index 0000000..c3ab610 --- /dev/null +++ b/ruoyi-service/ruoyi-integration/src/main/java/com/ruoyi/integration/mongodb/service/impl/PlatformRestartServiceImpl.java @@ -0,0 +1,31 @@ +package com.ruoyi.integration.mongodb.service.impl; + +import com.ruoyi.integration.iotda.constant.IotConstant; +import com.ruoyi.integration.mongodb.model.PlatformRestart; +import com.ruoyi.integration.mongodb.service.PlatformRestartService; +import org.springframework.beans.factory.annotation.Autowired; +import org.springframework.data.mongodb.core.MongoTemplate; +import org.springframework.stereotype.Service; + +import java.util.List; + +@Service +public class PlatformRestartServiceImpl implements PlatformRestartService { + @Autowired + private MongoTemplate mongoTemplate; + @Override + public int create(PlatformRestart platformRestart) { + mongoTemplate.save(platformRestart); + return IotConstant.SUCCESS; + } + + @Override + public PlatformRestart findById(String id) { + return mongoTemplate.findById(id, PlatformRestart.class); + } + + @Override + public List<PlatformRestart> findAll() { + return mongoTemplate.findAll(PlatformRestart.class); + } +} diff --git a/ruoyi-service/ruoyi-integration/src/main/java/com/ruoyi/integration/mongodb/service/impl/PlatformStopChargingServiceImpl.java b/ruoyi-service/ruoyi-integration/src/main/java/com/ruoyi/integration/mongodb/service/impl/PlatformStopChargingServiceImpl.java new file mode 100644 index 0000000..7516ffb --- /dev/null +++ b/ruoyi-service/ruoyi-integration/src/main/java/com/ruoyi/integration/mongodb/service/impl/PlatformStopChargingServiceImpl.java @@ -0,0 +1,33 @@ +package com.ruoyi.integration.mongodb.service.impl; + +import com.ruoyi.integration.iotda.constant.IotConstant; +import com.ruoyi.integration.mongodb.model.PlatformStopCharging; +import com.ruoyi.integration.mongodb.service.PlatformStopChargingService; +import org.springframework.beans.factory.annotation.Autowired; +import org.springframework.data.mongodb.core.MongoTemplate; +import org.springframework.stereotype.Service; + +import java.util.List; + +@Service +public class PlatformStopChargingServiceImpl implements PlatformStopChargingService { + + @Autowired + private MongoTemplate mongoTemplate; + + @Override + public int create(PlatformStopCharging platformStopCharging) { + mongoTemplate.save(platformStopCharging); + return IotConstant.SUCCESS; + } + + @Override + public PlatformStopCharging findById(String id) { + return mongoTemplate.findById(id, PlatformStopCharging.class); + } + + @Override + public List<PlatformStopCharging> findAll() { + return mongoTemplate.findAll(PlatformStopCharging.class); + } +} diff --git a/ruoyi-service/ruoyi-integration/src/main/java/com/ruoyi/integration/mongodb/service/impl/QueryOfflineCardServiceImpl.java b/ruoyi-service/ruoyi-integration/src/main/java/com/ruoyi/integration/mongodb/service/impl/QueryOfflineCardServiceImpl.java new file mode 100644 index 0000000..43e2a29 --- /dev/null +++ b/ruoyi-service/ruoyi-integration/src/main/java/com/ruoyi/integration/mongodb/service/impl/QueryOfflineCardServiceImpl.java @@ -0,0 +1,31 @@ +package com.ruoyi.integration.mongodb.service.impl; + +import com.ruoyi.integration.iotda.constant.IotConstant; +import com.ruoyi.integration.mongodb.model.QueryOfflineCard; +import com.ruoyi.integration.mongodb.service.QueryOfflineCardService; +import org.springframework.beans.factory.annotation.Autowired; +import org.springframework.data.mongodb.core.MongoTemplate; +import org.springframework.stereotype.Service; + +import java.util.List; + +@Service +public class QueryOfflineCardServiceImpl implements QueryOfflineCardService { + @Autowired + private MongoTemplate mongoTemplate; + @Override + public int create(QueryOfflineCard queryOfflineCard) { + mongoTemplate.save(queryOfflineCard); + return IotConstant.SUCCESS; + } + + @Override + public QueryOfflineCard findById(String id) { + return mongoTemplate.findById(id, QueryOfflineCard.class); + } + + @Override + public List<QueryOfflineCard> findAll() { + return mongoTemplate.findAll(QueryOfflineCard.class); + } +} diff --git a/ruoyi-service/ruoyi-integration/src/main/java/com/ruoyi/integration/mongodb/service/impl/SetupBillingModelServiceImpl.java b/ruoyi-service/ruoyi-integration/src/main/java/com/ruoyi/integration/mongodb/service/impl/SetupBillingModelServiceImpl.java new file mode 100644 index 0000000..79830bb --- /dev/null +++ b/ruoyi-service/ruoyi-integration/src/main/java/com/ruoyi/integration/mongodb/service/impl/SetupBillingModelServiceImpl.java @@ -0,0 +1,31 @@ +package com.ruoyi.integration.mongodb.service.impl; + +import com.ruoyi.integration.iotda.constant.IotConstant; +import com.ruoyi.integration.mongodb.model.SetupBillingModel; +import com.ruoyi.integration.mongodb.service.SetupBillingModelService; +import org.springframework.beans.factory.annotation.Autowired; +import org.springframework.data.mongodb.core.MongoTemplate; +import org.springframework.stereotype.Service; + +import java.util.List; + +@Service +public class SetupBillingModelServiceImpl implements SetupBillingModelService { + @Autowired + private MongoTemplate mongoTemplate; + @Override + public int create(SetupBillingModel setupBillingModel) { + mongoTemplate.save(setupBillingModel); + return IotConstant.SUCCESS; + } + + @Override + public SetupBillingModel findById(String id) { + return mongoTemplate.findById(id, SetupBillingModel.class); + } + + @Override + public List<SetupBillingModel> findAll() { + return mongoTemplate.findAll(SetupBillingModel.class); + } +} diff --git a/ruoyi-service/ruoyi-integration/src/main/java/com/ruoyi/integration/mongodb/service/impl/SynchronizeOfflineCardServiceImpl.java b/ruoyi-service/ruoyi-integration/src/main/java/com/ruoyi/integration/mongodb/service/impl/SynchronizeOfflineCardServiceImpl.java new file mode 100644 index 0000000..95bd093 --- /dev/null +++ b/ruoyi-service/ruoyi-integration/src/main/java/com/ruoyi/integration/mongodb/service/impl/SynchronizeOfflineCardServiceImpl.java @@ -0,0 +1,33 @@ +package com.ruoyi.integration.mongodb.service.impl; + +import com.ruoyi.integration.iotda.constant.IotConstant; +import com.ruoyi.integration.mongodb.model.SynchronizeOfflineCard; +import com.ruoyi.integration.mongodb.service.SynchronizeOfflineCardService; +import org.springframework.beans.factory.annotation.Autowired; +import org.springframework.data.mongodb.core.MongoTemplate; +import org.springframework.stereotype.Service; + +import java.util.List; + +@Service +public class SynchronizeOfflineCardServiceImpl implements SynchronizeOfflineCardService { + + @Autowired + private MongoTemplate mongoTemplate; + + @Override + public int create(SynchronizeOfflineCard synchronizeOfflineCard) { + mongoTemplate.save(synchronizeOfflineCard); + return IotConstant.SUCCESS; + } + + @Override + public SynchronizeOfflineCard findById(String id) { + return mongoTemplate.findById(id, SynchronizeOfflineCard.class); + } + + @Override + public List<SynchronizeOfflineCard> findAll() { + return mongoTemplate.findAll(SynchronizeOfflineCard.class); + } +} diff --git a/ruoyi-service/ruoyi-integration/src/main/java/com/ruoyi/integration/mongodb/service/impl/TimingSettingServiceImpl.java b/ruoyi-service/ruoyi-integration/src/main/java/com/ruoyi/integration/mongodb/service/impl/TimingSettingServiceImpl.java new file mode 100644 index 0000000..0f01b03 --- /dev/null +++ b/ruoyi-service/ruoyi-integration/src/main/java/com/ruoyi/integration/mongodb/service/impl/TimingSettingServiceImpl.java @@ -0,0 +1,31 @@ +package com.ruoyi.integration.mongodb.service.impl; + +import com.ruoyi.integration.iotda.constant.IotConstant; +import com.ruoyi.integration.mongodb.model.TimingSetting; +import com.ruoyi.integration.mongodb.service.TimingSettingService; +import org.springframework.beans.factory.annotation.Autowired; +import org.springframework.data.mongodb.core.MongoTemplate; +import org.springframework.stereotype.Service; + +import java.util.List; + +@Service +public class TimingSettingServiceImpl implements TimingSettingService { + @Autowired + private MongoTemplate mongoTemplate; + @Override + public int create(TimingSetting timingSetting) { + mongoTemplate.save(timingSetting); + return IotConstant.SUCCESS; + } + + @Override + public TimingSetting findById(String id) { + return mongoTemplate.findById(id, TimingSetting.class); + } + + @Override + public List<TimingSetting> findAll() { + return mongoTemplate.findAll(TimingSetting.class); + } +} diff --git a/ruoyi-service/ruoyi-integration/src/main/java/com/ruoyi/integration/mongodb/service/impl/UpdateBalanceServiceImpl.java b/ruoyi-service/ruoyi-integration/src/main/java/com/ruoyi/integration/mongodb/service/impl/UpdateBalanceServiceImpl.java new file mode 100644 index 0000000..b4e7398 --- /dev/null +++ b/ruoyi-service/ruoyi-integration/src/main/java/com/ruoyi/integration/mongodb/service/impl/UpdateBalanceServiceImpl.java @@ -0,0 +1,33 @@ +package com.ruoyi.integration.mongodb.service.impl; + +import com.ruoyi.integration.iotda.constant.IotConstant; +import com.ruoyi.integration.mongodb.model.UpdateBalance; +import com.ruoyi.integration.mongodb.service.UpdateBalanceService; +import org.springframework.beans.factory.annotation.Autowired; +import org.springframework.data.mongodb.core.MongoTemplate; +import org.springframework.stereotype.Service; + +import java.util.List; + +@Service +public class UpdateBalanceServiceImpl implements UpdateBalanceService { + + @Autowired + private MongoTemplate mongoTemplate; + + @Override + public int create(UpdateBalance updateBalance) { + mongoTemplate.save(updateBalance); + return IotConstant.SUCCESS; + } + + @Override + public UpdateBalance findById(String id) { + return mongoTemplate.findById(id, UpdateBalance.class); + } + + @Override + public List<UpdateBalance> findAll() { + return mongoTemplate.findAll(UpdateBalance.class); + } +} diff --git a/ruoyi-service/ruoyi-integration/src/main/java/com/ruoyi/integration/mongodb/service/impl/WorkingParameterSettingServiceImpl.java b/ruoyi-service/ruoyi-integration/src/main/java/com/ruoyi/integration/mongodb/service/impl/WorkingParameterSettingServiceImpl.java new file mode 100644 index 0000000..6c082ab --- /dev/null +++ b/ruoyi-service/ruoyi-integration/src/main/java/com/ruoyi/integration/mongodb/service/impl/WorkingParameterSettingServiceImpl.java @@ -0,0 +1,31 @@ +package com.ruoyi.integration.mongodb.service.impl; + +import com.ruoyi.integration.iotda.constant.IotConstant; +import com.ruoyi.integration.mongodb.model.WorkingParameterSetting; +import com.ruoyi.integration.mongodb.service.WorkingParameterSettingService; +import org.springframework.beans.factory.annotation.Autowired; +import org.springframework.data.mongodb.core.MongoTemplate; +import org.springframework.stereotype.Service; + +import java.util.List; + +@Service +public class WorkingParameterSettingServiceImpl implements WorkingParameterSettingService { + @Autowired + private MongoTemplate mongoTemplate; + @Override + public int create(WorkingParameterSetting workingParameterSetting) { + mongoTemplate.save(workingParameterSetting); + return IotConstant.SUCCESS; + } + + @Override + public WorkingParameterSetting findById(String id) { + return mongoTemplate.findById(id, WorkingParameterSetting.class); + } + + @Override + public List<WorkingParameterSetting> findAll() { + return mongoTemplate.findAll(WorkingParameterSetting.class); + } +} -- Gitblit v1.7.1