消息发送

xuhy

2024-08-22 6732f66d7724b1ee5e5ffd53ca4b7146e046331d

消息发送

 ruoyi-service/ruoyi-integration/src/main/java/com/ruoyi/integration/iotda/constant/IotConstant.java

@@ -1,6 +1,8 @@
package com.ruoyi.integration.iotda.constant;

public class IotConstant {
    public static final int SUCCESS = 1;
    public static final int FAIL = 0;
    /**
     * 华为云iot  token
     */

 ruoyi-service/ruoyi-integration/src/main/java/com/ruoyi/integration/iotda/constant/ServiceIdConstant.java

@@ -5,5 +5,33 @@
     * 登录认证应答
     */
    public static final String ONLINE_REPLY = "online_reply";
    /**
     * 登录认证应答
     */
    public static final String PONG = "pong";
    /**
     * 计费模型验证请求应答
     */
    public static final String BILLING_MODE_VERIFY_REPLY = "billing_mode_verify_reply";
    /**
     * 计费模型请求应答
     */
    public static final String ACQUISITION_BILLING_MODE_REPLY = "acquisition_billing_mode_reply";
    /**
     * 读取实时监测数据
     */
    public static final String READ_REAL_TIME_MONITORING_DATA = "read_real_time_monitoring_data";
    /**
     * 充电结束
     */
    public static final String END_CHARGE = "end_charge";
    /**
     * 运营平台确认启动充电
     */
    public static final String PLATFORM_CONFIRMATION_CHARGING = "platform_confirmation_charging";
    /**
     * 运营平台远程控制启机
     */
    public static final String PLATFORM_START_CHARGING = "platform_start_charging";

}

 ruoyi-service/ruoyi-integration/src/main/java/com/ruoyi/integration/iotda/utils/tools/MessageUtil.java

@@ -3,40 +3,122 @@

import com.alibaba.fastjson2.JSONObject;
import com.ruoyi.integration.iotda.constant.ServiceIdConstant;

import java.util.HashMap;
import java.util.Map;
import com.ruoyi.integration.mongodb.model.*;
import com.ruoyi.integration.mongodb.service.*;
import org.apache.poi.ss.formula.functions.T;
import org.springframework.beans.factory.annotation.Autowired;

public class MessageUtil {

    @Autowired
    private OnlineReplyService onlineReplyService;
    @Autowired
    private PongService pongService;
    @Autowired
    private BillingModeVerifyReplyService billingModeVerifyReplyService;
    @Autowired
    private AcquisitionBillingModeReplyService acquisitionBillingModeReplyService;
    @Autowired
    private ReadRealTimeMonitoringDataService readRealTimeMonitoringDataService;
    @Autowired
    private EndChargeService endChargeService;
    @Autowired
    private PlatformConfirmationChargingService platformConfirmationChargingService;
    @Autowired
    private PlatformStartChargingService platformStartChargingService;

    /**
     * 登录认证应答
     * @param charging_pile_code  桩编码
     * @param online_result 登录结果（0：成功，1：失败）
     * @param onlineReply  实体对象
     * @return
     */
    public static String onlineReply(String charging_pile_code,Integer online_result){
        Map<String,Object> map = new HashMap<>(3);
        map.put("service_id", ServiceIdConstant.ONLINE_REPLY);
        map.put("charging_pile_code",charging_pile_code);
        map.put("online_result",online_result);
        return JSONObject.toJSONString(map);
    public String onlineReply(OnlineReply onlineReply){
        onlineReplyService.create(onlineReply);
        return getMessageJsonString(onlineReply, ServiceIdConstant.ONLINE_REPLY);
    }

    /**
     * 心跳包应答
     * @param charging_pile_code 桩编码
     * @param charging_gun_code 枪号
     * @param charging_gun_status 心跳应答（0）
     * @param pong 实体对象
     * @return
     */
    public static String pong(String charging_pile_code,String charging_gun_code,Integer charging_gun_status){
        Map<String,Object> map = new HashMap<>(3);
        map.put("service_id", ServiceIdConstant.ONLINE_REPLY);
        map.put("charging_pile_code",charging_pile_code);
        map.put("charging_gun_code",charging_gun_code);
        map.put("charging_gun_status",charging_gun_status);
        return JSONObject.toJSONString(map);
    public String pong(Pong pong){
        pongService.create(pong);
        return getMessageJsonString(pong, ServiceIdConstant.PONG);
    }

    /**
     * 计费模型验证请求应答
     * @param billingModeVerifyReply 实体对象
     * @return
     */
    public String billingModeVerifyReply(BillingModeVerifyReply billingModeVerifyReply){
        billingModeVerifyReplyService.create(billingModeVerifyReply);
        return getMessageJsonString(billingModeVerifyReply, ServiceIdConstant.BILLING_MODE_VERIFY_REPLY);
    }

    /**
     * 计费模型验证请求应答
     * @param acquisitionBillingModeReply 实体对象
     * @return
     */
    public String acquisitionBillingModeReply(AcquisitionBillingModeReply acquisitionBillingModeReply){
        acquisitionBillingModeReplyService.create(acquisitionBillingModeReply);
        return getMessageJsonString(acquisitionBillingModeReply, ServiceIdConstant.ACQUISITION_BILLING_MODE_REPLY);
    }

    /**
     * 读取实时监测数据
     * @param readRealTimeMonitoringData 实体对象
     * @return
     */
    public String readRealTimeMonitoringData(ReadRealTimeMonitoringData readRealTimeMonitoringData){
        readRealTimeMonitoringDataService.create(readRealTimeMonitoringData);
        return getMessageJsonString(readRealTimeMonitoringData, ServiceIdConstant.READ_REAL_TIME_MONITORING_DATA);
    }

    /**
     * 充电结束
     * @param endCharge 实体对象
     * @return
     */
    public String endCharge(EndCharge endCharge){
        endChargeService.create(endCharge);
        return getMessageJsonString(endCharge, ServiceIdConstant.END_CHARGE);
    }

    /**
     * 运营平台确认启动充电
     * @param platformConfirmationCharging 实体对象
     * @return
     */
    public String platformConfirmationCharging(PlatformConfirmationCharging platformConfirmationCharging){
        platformConfirmationChargingService.create(platformConfirmationCharging);
        return getMessageJsonString(platformConfirmationCharging, ServiceIdConstant.PLATFORM_CONFIRMATION_CHARGING);
    }

    /**
     * 运营平台远程控制启机
     * @param platformStartCharging 实体对象
     * @return
     */
    public String platformConfirmationCharging(PlatformStartCharging platformStartCharging){
        platformStartChargingService.create(platformStartCharging);
        return getMessageJsonString(platformStartCharging, ServiceIdConstant.PLATFORM_START_CHARGING);
    }



    /**
     * 统一封装消息
     * @param object 实体对象
     * @param serviceId 服务ID
     * @return
     */
    private String getMessageJsonString(Object object, String serviceId){
        JSONObject jsonObject = JSONObject.parseObject(JSONObject.toJSONString(object));
        jsonObject.put("service_id", serviceId);
        return jsonObject.toJSONString();
    }

}

 ruoyi-service/ruoyi-integration/src/main/java/com/ruoyi/integration/mongodb/base/BaseService.java

New file
@@ -0,0 +1,28 @@
package com.ruoyi.integration.mongodb.base;


import java.util.List;

public interface BaseService<T> {

    /**
     * 添加
     * @param t 实体类
     * @return 添加结果 1=成功 0=失败
     */
    int create(T t);

    /**
     * 根据id查询
     * @param id 实体id
     * @return 实体对象
     */
    T findById(String id);

    /**
     * 查询列表
     * @return 实体列表
     */
    List<T> findAll();

}

 ruoyi-service/ruoyi-integration/src/main/java/com/ruoyi/integration/mongodb/model/UpdateBalance.java

@@ -15,9 +15,10 @@
@Accessors(chain = true)
public class UpdateBalance {

    private String charging_pile_code; //桩编码
    private String physical_card_number; //物理卡号
    private BigDecimal account_balance; //修改结果（:0：修改成功，1：设备编号错误，2：卡号错误）
    private String charging_pile_code;// 桩编码
    private String charging_gun_code;// 抢号
    private String physical_card_number;// 物理卡号
    private BigDecimal account_balance;// 修改后账户金额

}


 ruoyi-service/ruoyi-integration/src/main/java/com/ruoyi/integration/mongodb/model/UpdateBalanceReply.java

@@ -15,11 +15,9 @@
@Accessors(chain = true)
public class UpdateBalanceReply {

    private String charging_pile_code;// 桩编码
    private String charging_gun_code;// 抢号
    private String physical_card_number;// 物理卡号
    private BigDecimal account_balance;// 修改后账户金额

    private String charging_pile_code; //桩编码
    private String physical_card_number; //物理卡号
    private BigDecimal account_balance; //修改结果（:0：修改成功，1：设备编号错误，2：卡号错误）

}


 ruoyi-service/ruoyi-integration/src/main/java/com/ruoyi/integration/mongodb/service/AcquisitionBillingModeReplyService.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.AcquisitionBillingModeReply;

public interface AcquisitionBillingModeReplyService extends BaseService<AcquisitionBillingModeReply> {
}

 ruoyi-service/ruoyi-integration/src/main/java/com/ruoyi/integration/mongodb/service/BillingModeVerifyReplyService.java

New file
@@ -0,0 +1,8 @@
package com.ruoyi.integration.mongodb.service;

import com.ruoyi.integration.mongodb.base.BaseService;
import com.ruoyi.integration.mongodb.model.BillingModeVerifyReply;
import org.springframework.stereotype.Service;

public interface BillingModeVerifyReplyService extends BaseService<BillingModeVerifyReply> {
}

 ruoyi-service/ruoyi-integration/src/main/java/com/ruoyi/integration/mongodb/service/EndChargeService.java

New file
@@ -0,0 +1,8 @@
package com.ruoyi.integration.mongodb.service;

import com.ruoyi.integration.mongodb.base.BaseService;
import com.ruoyi.integration.mongodb.model.EndCharge;

public interface EndChargeService extends BaseService<EndCharge> {

}

 ruoyi-service/ruoyi-integration/src/main/java/com/ruoyi/integration/mongodb/service/OnlineReplyService.java

@@ -1,8 +1,12 @@
package com.ruoyi.integration.mongodb.service;

import com.ruoyi.integration.mongodb.base.BaseService;
import com.ruoyi.integration.mongodb.model.OnlineReply;
import org.springframework.stereotype.Service;

/**
 * 登录认证应答接口
 */
public interface OnlineReplyService {
public interface OnlineReplyService extends BaseService<OnlineReply> {

}

 ruoyi-service/ruoyi-integration/src/main/java/com/ruoyi/integration/mongodb/service/OnlineService.java

@@ -1,8 +1,12 @@
package com.ruoyi.integration.mongodb.service;

import com.ruoyi.integration.mongodb.base.BaseService;
import com.ruoyi.integration.mongodb.model.Online;
import org.springframework.stereotype.Service;

/**
 * 充电桩登录认证接口
 */
public interface OnlineService {
public interface OnlineService extends BaseService<Online> {

}

 ruoyi-service/ruoyi-integration/src/main/java/com/ruoyi/integration/mongodb/service/PlatformConfirmationChargingService.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.PlatformConfirmationCharging;

public interface PlatformConfirmationChargingService extends BaseService<PlatformConfirmationCharging> {
}

 ruoyi-service/ruoyi-integration/src/main/java/com/ruoyi/integration/mongodb/service/PlatformStartChargingService.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.PlatformStartCharging;

public interface PlatformStartChargingService extends BaseService<PlatformStartCharging> {
}

 ruoyi-service/ruoyi-integration/src/main/java/com/ruoyi/integration/mongodb/service/PongService.java

New file
@@ -0,0 +1,13 @@
package com.ruoyi.integration.mongodb.service;

import com.ruoyi.integration.mongodb.base.BaseService;
import com.ruoyi.integration.mongodb.model.Online;
import com.ruoyi.integration.mongodb.model.Pong;
import org.springframework.stereotype.Service;

/**
 * 心跳包应答接口
 */
public interface PongService extends BaseService<Pong> {

}

 ruoyi-service/ruoyi-integration/src/main/java/com/ruoyi/integration/mongodb/service/ReadRealTimeMonitoringDataService.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.ReadRealTimeMonitoringData;

public interface ReadRealTimeMonitoringDataService extends BaseService<ReadRealTimeMonitoringData> {
}

 ruoyi-service/ruoyi-integration/src/main/java/com/ruoyi/integration/mongodb/service/impl/AcquisitionBillingModeReplyServiceImpl.java

New file
@@ -0,0 +1,32 @@
package com.ruoyi.integration.mongodb.service.impl;

import com.ruoyi.integration.iotda.constant.IotConstant;
import com.ruoyi.integration.mongodb.model.AcquisitionBillingModeReply;
import com.ruoyi.integration.mongodb.service.AcquisitionBillingModeReplyService;
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 AcquisitionBillingModeReplyServiceImpl implements AcquisitionBillingModeReplyService {

    @Autowired
    private MongoTemplate mongoTemplate;

    @Override
    public int create(AcquisitionBillingModeReply acquisitionBillingModeReply) {
        mongoTemplate.save(acquisitionBillingModeReply);
        return IotConstant.SUCCESS;
    }

    @Override
    public AcquisitionBillingModeReply findById(String id) {
        return mongoTemplate.findById(id, AcquisitionBillingModeReply.class);
    }

    @Override
    public List<AcquisitionBillingModeReply> findAll() {
        return mongoTemplate.findAll(AcquisitionBillingModeReply.class);
    }
}

 ruoyi-service/ruoyi-integration/src/main/java/com/ruoyi/integration/mongodb/service/impl/BillingModeVerifyReplyServiceImpl.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.BillingModeVerifyReply;
import com.ruoyi.integration.mongodb.service.BillingModeVerifyReplyService;
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 BillingModeVerifyReplyServiceImpl implements BillingModeVerifyReplyService {
    @Autowired
    private MongoTemplate mongoTemplate;

    @Override
    public int create(BillingModeVerifyReply billingModeVerifyReply) {
        mongoTemplate.save(billingModeVerifyReply);
        return IotConstant.SUCCESS;
    }

    @Override
    public BillingModeVerifyReply findById(String id) {
        return mongoTemplate.findById(id, BillingModeVerifyReply.class);
    }

    @Override
    public List<BillingModeVerifyReply> findAll() {
        return mongoTemplate.findAll(BillingModeVerifyReply.class);
    }
}

 ruoyi-service/ruoyi-integration/src/main/java/com/ruoyi/integration/mongodb/service/impl/EndChargeServiceImpl.java

New file
@@ -0,0 +1,34 @@
package com.ruoyi.integration.mongodb.service.impl;

import com.ruoyi.integration.iotda.constant.IotConstant;
import com.ruoyi.integration.mongodb.model.EndCharge;
import com.ruoyi.integration.mongodb.model.Pong;
import com.ruoyi.integration.mongodb.service.EndChargeService;
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 EndChargeServiceImpl implements EndChargeService {
    @Autowired
    private MongoTemplate mongoTemplate;

    @Override
    public int create(EndCharge endCharge) {
        mongoTemplate.save(endCharge);
        return IotConstant.SUCCESS;
    }

    @Override
    public EndCharge findById(String id) {
        return mongoTemplate.findById(id, EndCharge.class);
    }

    @Override
    public List<EndCharge> findAll() {
        return mongoTemplate.findAll(EndCharge.class);
    }
}

 ruoyi-service/ruoyi-integration/src/main/java/com/ruoyi/integration/mongodb/service/impl/OnlineReplyServiceImpl.java

@@ -1,7 +1,13 @@
package com.ruoyi.integration.mongodb.service.impl;

import com.ruoyi.integration.iotda.constant.IotConstant;
import com.ruoyi.integration.mongodb.model.OnlineReply;
import com.ruoyi.integration.mongodb.service.OnlineReplyService;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.data.mongodb.core.MongoTemplate;
import org.springframework.stereotype.Service;

import java.util.List;


/**
@@ -10,5 +16,21 @@
@Service
public class OnlineReplyServiceImpl implements OnlineReplyService {

    @Autowired
    private MongoTemplate mongoTemplate;
    @Override
    public int create(OnlineReply onlineReply) {
        mongoTemplate.save(onlineReply);
        return IotConstant.SUCCESS;
    }

    @Override
    public OnlineReply findById(String id) {
        return null;
    }

    @Override
    public List<OnlineReply> findAll() {
        return null;
    }
}

 ruoyi-service/ruoyi-integration/src/main/java/com/ruoyi/integration/mongodb/service/impl/OnlineServiceImpl.java

@@ -1,7 +1,13 @@
package com.ruoyi.integration.mongodb.service.impl;

import com.ruoyi.integration.iotda.constant.IotConstant;
import com.ruoyi.integration.mongodb.model.Online;
import com.ruoyi.integration.mongodb.service.OnlineService;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.data.mongodb.core.MongoTemplate;
import org.springframework.stereotype.Service;

import java.util.List;


/**
@@ -9,6 +15,22 @@
 **/
@Service
public class OnlineServiceImpl implements OnlineService {
    @Autowired
    private MongoTemplate mongoTemplate;

    @Override
    public int create(Online online) {
        mongoTemplate.save(online);
        return IotConstant.SUCCESS;
    }

    @Override
    public Online findById(String id) {
        return mongoTemplate.findById(id, Online.class);
    }

    @Override
    public List<Online> findAll() {
        return mongoTemplate.findAll(Online.class);
    }
}

 ruoyi-service/ruoyi-integration/src/main/java/com/ruoyi/integration/mongodb/service/impl/PlatformConfirmationChargingServiceImpl.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.PlatformConfirmationCharging;
import com.ruoyi.integration.mongodb.service.PlatformConfirmationChargingService;
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 PlatformConfirmationChargingServiceImpl implements PlatformConfirmationChargingService {
    @Autowired
    private MongoTemplate mongoTemplate;
    @Override
    public int create(PlatformConfirmationCharging platformConfirmationCharging) {
        mongoTemplate.save(platformConfirmationCharging);
        return IotConstant.SUCCESS;
    }

    @Override
    public PlatformConfirmationCharging findById(String id) {
        return mongoTemplate.findById(id, PlatformConfirmationCharging.class);
    }

    @Override
    public List<PlatformConfirmationCharging> findAll() {
        return mongoTemplate.findAll(PlatformConfirmationCharging.class);
    }
}

 ruoyi-service/ruoyi-integration/src/main/java/com/ruoyi/integration/mongodb/service/impl/PlatformStartChargingServiceImpl.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.PlatformStartCharging;
import com.ruoyi.integration.mongodb.service.PlatformStartChargingService;
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 PlatformStartChargingServiceImpl implements PlatformStartChargingService {
    @Autowired
    private MongoTemplate mongoTemplate;
    @Override
    public int create(PlatformStartCharging platformStartCharging) {
        mongoTemplate.save(platformStartCharging);
        return IotConstant.SUCCESS;
    }

    @Override
    public PlatformStartCharging findById(String id) {
        return mongoTemplate.findById(id, PlatformStartCharging.class);
    }

    @Override
    public List<PlatformStartCharging> findAll() {
        return mongoTemplate.findAll(PlatformStartCharging.class);
    }
}

 ruoyi-service/ruoyi-integration/src/main/java/com/ruoyi/integration/mongodb/service/impl/PongServiceImpl.java

New file
@@ -0,0 +1,38 @@
package com.ruoyi.integration.mongodb.service.impl;

import com.ruoyi.integration.iotda.constant.IotConstant;
import com.ruoyi.integration.mongodb.model.Online;
import com.ruoyi.integration.mongodb.model.Pong;
import com.ruoyi.integration.mongodb.service.OnlineService;
import com.ruoyi.integration.mongodb.service.PongService;
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 PongServiceImpl implements PongService {
    @Autowired
    private MongoTemplate mongoTemplate;

    @Override
    public int create(Pong pong) {
        mongoTemplate.save(pong);
        return IotConstant.SUCCESS;
    }

    @Override
    public Pong findById(String id) {
        return mongoTemplate.findById(id, Pong.class);
    }

    @Override
    public List<Pong> findAll() {
        return mongoTemplate.findAll(Pong.class);
    }
}

 ruoyi-service/ruoyi-integration/src/main/java/com/ruoyi/integration/mongodb/service/impl/ReadRealTimeMonitoringDataServiceImpl.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.ReadRealTimeMonitoringData;
import com.ruoyi.integration.mongodb.service.ReadRealTimeMonitoringDataService;
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 ReadRealTimeMonitoringDataServiceImpl implements ReadRealTimeMonitoringDataService {
    @Autowired
    private MongoTemplate mongoTemplate;
    @Override
    public int create(ReadRealTimeMonitoringData readRealTimeMonitoringData) {
        mongoTemplate.save(readRealTimeMonitoringData);
        return IotConstant.SUCCESS;
    }

    @Override
    public ReadRealTimeMonitoringData findById(String id) {
        return mongoTemplate.findById(id, ReadRealTimeMonitoringData.class);
    }

    @Override
    public List<ReadRealTimeMonitoringData> findAll() {
        return mongoTemplate.findAll(ReadRealTimeMonitoringData.class);
    }
}