消息发送封装完成

xuhy

2024-08-23 3e261beffdab4bfd58ebcf723496e7f78c618e44

消息发送封装完成

 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);
    }
}