ruoyi-api/ruoyi-api-chargingPile/src/main/java/com/ruoyi/chargingPile/api/vo/SiteVO.java
@@ -17,6 +17,12 @@ private Integer superCount; @ApiModelProperty(value = "慢充数量") private Integer slowCount; @ApiModelProperty(value = "快充空闲数量") private Integer superFreeCount; @ApiModelProperty(value = "超充空闲数量") private Integer fastFreeCount; @ApiModelProperty(value = "慢充空闲数量") private Integer slowFreeCount; @ApiModelProperty(value = "普通电价") private BigDecimal electrovalence; @ApiModelProperty(value = "会员电价") ruoyi-service/ruoyi-chargingPile/src/main/java/com/ruoyi/chargingPile/service/impl/SiteServiceImpl.java
@@ -295,6 +295,11 @@ @Override public List<SiteVO> getMapSiteList(SiteQuery query) { if(StringUtils.isEmpty(query.getLon()) || StringUtils.isEmpty(query.getLat())){ return new ArrayList<>(); } // 获取当前登录用户id Long userId = tokenService.getLoginUserApplet().getUserId(); // 根据id查询用户信息 ruoyi-service/ruoyi-chargingPile/src/main/resources/mapper/chargingPile/SiteMapper.xml
@@ -212,7 +212,7 @@ ts.id, ts.partner_id, ts.code, ts.`name`, ts.site_type, ts.business_category, ts.status, ts.construction_site, ts.img_url, ts.lon, ts.lat, ts.address, ts.country_code, ts.phone,ts.guide, ts.service_description, ts.vehicle_description, ts.parking_space, ts.rate_description, ts.space_charge_explain, ts.accounting_strategy_id,ts.del_flag,tcg.fastCount, tcg.slowCount,tcg.superCount,tasd.electrovalence,tasd.vipElectrovalence, tcg.slowCount,tcg.superCount,tasd.electrovalence,tasd.vipElectrovalence,tcg.superFreeCount,tcg.fastFreeCount,tcg.slowFreeCount, ROUND( 6378.138 * 2 * ASIN( SQRT( @@ -239,7 +239,10 @@ select site_id, SUM(CASE WHEN charge_mode = 1 THEN 1 ELSE 0 END) AS superCount, SUM(CASE WHEN charge_mode = 2 THEN 1 ELSE 0 END) AS fastCount, SUM(CASE WHEN charge_mode = 3 THEN 1 ELSE 0 END) AS slowCount SUM(CASE WHEN charge_mode = 3 THEN 1 ELSE 0 END) AS slowCount, SUM(CASE WHEN charge_mode = 1 and `status` = 2 THEN 1 ELSE 0 END) AS superFreeCount, SUM(CASE WHEN charge_mode = 2 and `status` = 2 THEN 1 ELSE 0 END) AS fastFreeCount, SUM(CASE WHEN charge_mode = 3 and `status` = 2 THEN 1 ELSE 0 END) AS slowFreeCount from t_charging_gun where 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"; } 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); } /** * 统一封装消息 ruoyi-service/ruoyi-integration/src/main/java/com/ruoyi/integration/mongodb/service/ClearOfflineCardService.java
New file @@ -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> { } ruoyi-service/ruoyi-integration/src/main/java/com/ruoyi/integration/mongodb/service/ConfirmTransactionRecordService.java
New file @@ -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> { } ruoyi-service/ruoyi-integration/src/main/java/com/ruoyi/integration/mongodb/service/OpenOrCloseGroundLockService.java
New file @@ -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> { } ruoyi-service/ruoyi-integration/src/main/java/com/ruoyi/integration/mongodb/service/PlatformRemoteUpdateService.java
New file @@ -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> { } ruoyi-service/ruoyi-integration/src/main/java/com/ruoyi/integration/mongodb/service/PlatformRestartService.java
New file @@ -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> { } ruoyi-service/ruoyi-integration/src/main/java/com/ruoyi/integration/mongodb/service/PlatformStopChargingService.java
New file @@ -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> { } ruoyi-service/ruoyi-integration/src/main/java/com/ruoyi/integration/mongodb/service/QueryOfflineCardService.java
New file @@ -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> { } ruoyi-service/ruoyi-integration/src/main/java/com/ruoyi/integration/mongodb/service/SetupBillingModelService.java
New file @@ -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> { } ruoyi-service/ruoyi-integration/src/main/java/com/ruoyi/integration/mongodb/service/SynchronizeOfflineCardService.java
New file @@ -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> { } ruoyi-service/ruoyi-integration/src/main/java/com/ruoyi/integration/mongodb/service/TimingSettingService.java
New file @@ -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> { } ruoyi-service/ruoyi-integration/src/main/java/com/ruoyi/integration/mongodb/service/UpdateBalanceService.java
New file @@ -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> { } ruoyi-service/ruoyi-integration/src/main/java/com/ruoyi/integration/mongodb/service/WorkingParameterSettingService.java
New file @@ -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> { } ruoyi-service/ruoyi-integration/src/main/java/com/ruoyi/integration/mongodb/service/impl/ClearOfflineCardServiceImpl.java
New file @@ -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); } } ruoyi-service/ruoyi-integration/src/main/java/com/ruoyi/integration/mongodb/service/impl/ConfirmTransactionRecordServiceImpl.java
New file @@ -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); } } ruoyi-service/ruoyi-integration/src/main/java/com/ruoyi/integration/mongodb/service/impl/OpenOrCloseGroundLockServiceImpl.java
New file @@ -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); } } ruoyi-service/ruoyi-integration/src/main/java/com/ruoyi/integration/mongodb/service/impl/PlatformRemoteUpdateServiceImpl.java
New file @@ -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); } } ruoyi-service/ruoyi-integration/src/main/java/com/ruoyi/integration/mongodb/service/impl/PlatformRestartServiceImpl.java
New file @@ -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); } } ruoyi-service/ruoyi-integration/src/main/java/com/ruoyi/integration/mongodb/service/impl/PlatformStopChargingServiceImpl.java
New file @@ -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); } } ruoyi-service/ruoyi-integration/src/main/java/com/ruoyi/integration/mongodb/service/impl/QueryOfflineCardServiceImpl.java
New file @@ -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); } } ruoyi-service/ruoyi-integration/src/main/java/com/ruoyi/integration/mongodb/service/impl/SetupBillingModelServiceImpl.java
New file @@ -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); } } ruoyi-service/ruoyi-integration/src/main/java/com/ruoyi/integration/mongodb/service/impl/SynchronizeOfflineCardServiceImpl.java
New file @@ -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); } } ruoyi-service/ruoyi-integration/src/main/java/com/ruoyi/integration/mongodb/service/impl/TimingSettingServiceImpl.java
New file @@ -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); } } ruoyi-service/ruoyi-integration/src/main/java/com/ruoyi/integration/mongodb/service/impl/UpdateBalanceServiceImpl.java
New file @@ -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); } } ruoyi-service/ruoyi-integration/src/main/java/com/ruoyi/integration/mongodb/service/impl/WorkingParameterSettingServiceImpl.java
New file @@ -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); } }