明星电力充电桩
blame | 历史 | 补丁 | 提交 | 提交对比 | ignore whitespace
xuhy
2024-09-10 09d010da12e5dd22766cf0979f8f34c968ab6ffd 
 ruoyi-service/ruoyi-integration/src/main/java/com/ruoyi/integration/rocket/produce/EnhanceProduce.java


@@ -7,11 +7,12 @@


import com.ruoyi.integration.rocket.util.RocketMQEnhanceTemplate;


import lombok.Setter;


import lombok.extern.slf4j.Slf4j;


import org.apache.rocketmq.client.producer.DefaultMQProducer;


import org.apache.rocketmq.client.producer.SendResult;


import org.apache.rocketmq.common.message.Message;


import org.apache.rocketmq.remoting.common.RemotingHelper;


import org.springframework.beans.factory.annotation.Autowired;


import org.springframework.stereotype.Component;


import org.springframework.web.bind.annotation.RequestMapping;


import org.springframework.web.bind.annotation.RestController;




import java.util.UUID;




@@ -23,7 +24,7 @@


    @Setter(onMethod_ = @Autowired)


    private RocketMQEnhanceTemplate rocketMQEnhanceTemplate;




    private static final String TOPIC = "rocket_enhance";


    private static final String TOPIC = "charge_";




    /**


     * 充电桩登录认证


@@ -34,7 +35,7 @@


        message.setKey(UUID.randomUUID().toString());


        // 设置消息来源，便于查询


        message.setSource(SendTagConstant.ONLINE);


        return rocketMQEnhanceTemplate.send(TOPIC, SendTagConstant.ONLINE, message);


        return rocketMQEnhanceTemplate.send(TOPIC+SendTagConstant.ONLINE, SendTagConstant.ONLINE, message);


    }




    /**


@@ -46,7 +47,7 @@


        message.setKey(UUID.randomUUID().toString());


        // 设置消息来源，便于查询


        message.setSource(SendTagConstant.PING);


        return rocketMQEnhanceTemplate.send(TOPIC, SendTagConstant.PING, message);


        return rocketMQEnhanceTemplate.send(TOPIC+SendTagConstant.PING, SendTagConstant.PING, message);


    }


    /**


     * 充电结束


@@ -57,7 +58,7 @@


        message.setKey(UUID.randomUUID().toString());


        // 设置消息来源，便于查询


        message.setSource(SendTagConstant.END_CHARGE);


        return rocketMQEnhanceTemplate.send(TOPIC, SendTagConstant.END_CHARGE, message);


        return rocketMQEnhanceTemplate.send(TOPIC+SendTagConstant.END_CHARGE, SendTagConstant.END_CHARGE, message);


    }




    /**


@@ -69,7 +70,7 @@


        message.setKey(UUID.randomUUID().toString());


        // 设置消息来源，便于查询


        message.setSource(SendTagConstant.BILLING_MODE_VERIFY);


        return rocketMQEnhanceTemplate.send(TOPIC, SendTagConstant.BILLING_MODE_VERIFY, message);


        return rocketMQEnhanceTemplate.send(TOPIC+SendTagConstant.BILLING_MODE_VERIFY, SendTagConstant.BILLING_MODE_VERIFY, message);


    }




    /**


@@ -81,7 +82,7 @@


        message.setKey(UUID.randomUUID().toString());


        // 设置消息来源，便于查询


        message.setSource(SendTagConstant.ACQUISITION_BILLING_MODE);


        return rocketMQEnhanceTemplate.send(TOPIC, SendTagConstant.ACQUISITION_BILLING_MODE, message);


        return rocketMQEnhanceTemplate.send(TOPIC+SendTagConstant.ACQUISITION_BILLING_MODE, SendTagConstant.ACQUISITION_BILLING_MODE, message);


    }




    /**


@@ -93,7 +94,7 @@


        message.setKey(UUID.randomUUID().toString());


        // 设置消息来源，便于查询


        message.setSource(SendTagConstant.UPLOAD_REAL_TIME_MONITORING_DATA);


        return rocketMQEnhanceTemplate.send(TOPIC, SendTagConstant.UPLOAD_REAL_TIME_MONITORING_DATA, message);


        return rocketMQEnhanceTemplate.send(TOPIC+SendTagConstant.UPLOAD_REAL_TIME_MONITORING_DATA, SendTagConstant.UPLOAD_REAL_TIME_MONITORING_DATA, message);


    }




    /**


@@ -105,7 +106,7 @@


        message.setKey(UUID.randomUUID().toString());


        // 设置消息来源，便于查询


        message.setSource(SendTagConstant.CHARGING_HANDSHAKE);


        return rocketMQEnhanceTemplate.send(TOPIC, SendTagConstant.CHARGING_HANDSHAKE, message);


        return rocketMQEnhanceTemplate.send(TOPIC+SendTagConstant.CHARGING_HANDSHAKE, SendTagConstant.CHARGING_HANDSHAKE, message);


    }




    /**


@@ -117,7 +118,7 @@


        message.setKey(UUID.randomUUID().toString());


        // 设置消息来源，便于查询


        message.setSource(SendTagConstant.BMS_ABORT);


        return rocketMQEnhanceTemplate.send(TOPIC, SendTagConstant.BMS_ABORT, message);


        return rocketMQEnhanceTemplate.send(TOPIC+SendTagConstant.BMS_ABORT, SendTagConstant.BMS_ABORT, message);


    }




    /**


@@ -129,7 +130,7 @@


        message.setKey(UUID.randomUUID().toString());


        // 设置消息来源，便于查询


        message.setSource(SendTagConstant.MOTOR_ABORT);


        return rocketMQEnhanceTemplate.send(TOPIC, SendTagConstant.MOTOR_ABORT, message);


        return rocketMQEnhanceTemplate.send(TOPIC+SendTagConstant.MOTOR_ABORT, SendTagConstant.MOTOR_ABORT, message);


    }




    /**


@@ -141,7 +142,7 @@


        message.setKey(UUID.randomUUID().toString());


        // 设置消息来源，便于查询


        message.setSource(SendTagConstant.BMS_DEMAND_AND_CHARGER_EXPORTATION);


        return rocketMQEnhanceTemplate.send(TOPIC, SendTagConstant.BMS_DEMAND_AND_CHARGER_EXPORTATION, message);


        return rocketMQEnhanceTemplate.send(TOPIC+SendTagConstant.BMS_DEMAND_AND_CHARGER_EXPORTATION, SendTagConstant.BMS_DEMAND_AND_CHARGER_EXPORTATION, message);


    }




    /**


@@ -153,7 +154,7 @@


        message.setKey(UUID.randomUUID().toString());


        // 设置消息来源，便于查询


        message.setSource(SendTagConstant.BMS_INFORMATION);


        return rocketMQEnhanceTemplate.send(TOPIC, SendTagConstant.BMS_INFORMATION, message);


        return rocketMQEnhanceTemplate.send(TOPIC+SendTagConstant.BMS_INFORMATION, SendTagConstant.BMS_INFORMATION, message);


    }




    /**


@@ -165,7 +166,7 @@


        message.setKey(UUID.randomUUID().toString());


        // 设置消息来源，便于查询


        message.setSource(SendTagConstant.CHARGING_PILE_STARTS_CHARGING);


        return rocketMQEnhanceTemplate.send(TOPIC, SendTagConstant.CHARGING_PILE_STARTS_CHARGING, message);


        return rocketMQEnhanceTemplate.send(TOPIC+SendTagConstant.CHARGING_PILE_STARTS_CHARGING, SendTagConstant.CHARGING_PILE_STARTS_CHARGING, message);


    }




    /**


@@ -177,7 +178,7 @@


        message.setKey(UUID.randomUUID().toString());


        // 设置消息来源，便于查询


        message.setSource(SendTagConstant.PLATFORM_START_CHARGING_REPLY);


        return rocketMQEnhanceTemplate.send(TOPIC, SendTagConstant.PLATFORM_START_CHARGING_REPLY, message);


        return rocketMQEnhanceTemplate.send(TOPIC+SendTagConstant.PLATFORM_START_CHARGING_REPLY, SendTagConstant.PLATFORM_START_CHARGING_REPLY, message);


    }




    /**


@@ -189,7 +190,7 @@


        message.setKey(UUID.randomUUID().toString());


        // 设置消息来源，便于查询


        message.setSource(SendTagConstant.PLATFORM_STOP_CHARGING_REPLY);


        return rocketMQEnhanceTemplate.send(TOPIC, SendTagConstant.PLATFORM_STOP_CHARGING_REPLY, message);


        return rocketMQEnhanceTemplate.send(TOPIC+SendTagConstant.PLATFORM_STOP_CHARGING_REPLY, SendTagConstant.PLATFORM_STOP_CHARGING_REPLY, message);


    }




    /**


@@ -201,7 +202,7 @@


        message.setKey(UUID.randomUUID().toString());


        // 设置消息来源，便于查询


        message.setSource(SendTagConstant.TRANSACTION_RECORD);


        return rocketMQEnhanceTemplate.send(TOPIC, SendTagConstant.TRANSACTION_RECORD, message);


        return rocketMQEnhanceTemplate.send(TOPIC+SendTagConstant.TRANSACTION_RECORD, SendTagConstant.TRANSACTION_RECORD, message);


    }




    /**


@@ -213,7 +214,7 @@


        message.setKey(UUID.randomUUID().toString());


        // 设置消息来源，便于查询


        message.setSource(SendTagConstant.UPDATE_BALANCE_REPLY);


        return rocketMQEnhanceTemplate.send(TOPIC, SendTagConstant.UPDATE_BALANCE_REPLY, message);


        return rocketMQEnhanceTemplate.send(TOPIC+SendTagConstant.UPDATE_BALANCE_REPLY, SendTagConstant.UPDATE_BALANCE_REPLY, message);


    }




    /**


@@ -225,7 +226,7 @@


        message.setKey(UUID.randomUUID().toString());


        // 设置消息来源，便于查询


        message.setSource(SendTagConstant.SYNCHRONIZE_OFFLINE_CARD_REPLY);


        return rocketMQEnhanceTemplate.send(TOPIC, SendTagConstant.SYNCHRONIZE_OFFLINE_CARD_REPLY, message);


        return rocketMQEnhanceTemplate.send(TOPIC+SendTagConstant.SYNCHRONIZE_OFFLINE_CARD_REPLY, SendTagConstant.SYNCHRONIZE_OFFLINE_CARD_REPLY, message);


    }




    /**


@@ -237,7 +238,7 @@


        message.setKey(UUID.randomUUID().toString());


        // 设置消息来源，便于查询


        message.setSource(SendTagConstant.CLEAR_OFFLINE_CARD_REPLY);


        return rocketMQEnhanceTemplate.send(TOPIC, SendTagConstant.CLEAR_OFFLINE_CARD_REPLY, message);


        return rocketMQEnhanceTemplate.send(TOPIC+SendTagConstant.CLEAR_OFFLINE_CARD_REPLY, SendTagConstant.CLEAR_OFFLINE_CARD_REPLY, message);


    }




    /**


@@ -249,7 +250,7 @@


        message.setKey(UUID.randomUUID().toString());


        // 设置消息来源，便于查询


        message.setSource(SendTagConstant.WORKING_PARAMETER_SETTING_REPLY);


        return rocketMQEnhanceTemplate.send(TOPIC, SendTagConstant.WORKING_PARAMETER_SETTING_REPLY, message);


        return rocketMQEnhanceTemplate.send(TOPIC+SendTagConstant.WORKING_PARAMETER_SETTING_REPLY, SendTagConstant.WORKING_PARAMETER_SETTING_REPLY, message);


    }




    /**


@@ -261,7 +262,7 @@


        message.setKey(UUID.randomUUID().toString());


        // 设置消息来源，便于查询


        message.setSource(SendTagConstant.TIMING_SETTING);


        return rocketMQEnhanceTemplate.send(TOPIC, SendTagConstant.TIMING_SETTING, message);


        return rocketMQEnhanceTemplate.send(TOPIC+SendTagConstant.TIMING_SETTING, SendTagConstant.TIMING_SETTING, message);


    }




    /**


@@ -273,7 +274,7 @@


        message.setKey(UUID.randomUUID().toString());


        // 设置消息来源，便于查询


        message.setSource(SendTagConstant.SETUP_BILLING_MODEL_REPLY);


        return rocketMQEnhanceTemplate.send(TOPIC, SendTagConstant.SETUP_BILLING_MODEL_REPLY, message);


        return rocketMQEnhanceTemplate.send(TOPIC+SendTagConstant.SETUP_BILLING_MODEL_REPLY, SendTagConstant.SETUP_BILLING_MODEL_REPLY, message);


    }




    /**


@@ -285,7 +286,7 @@


        message.setKey(UUID.randomUUID().toString());


        // 设置消息来源，便于查询


        message.setSource(SendTagConstant.GROUND_LOCK_REAL_TIME_DATA);


        return rocketMQEnhanceTemplate.send(TOPIC, SendTagConstant.GROUND_LOCK_REAL_TIME_DATA, message);


        return rocketMQEnhanceTemplate.send(TOPIC+SendTagConstant.GROUND_LOCK_REAL_TIME_DATA, SendTagConstant.GROUND_LOCK_REAL_TIME_DATA, message);


    }




    /**


@@ -297,7 +298,7 @@


        message.setKey(UUID.randomUUID().toString());


        // 设置消息来源，便于查询


        message.setSource(SendTagConstant.CHARGING_PILE_RETURNS_GROUND_LOCK_DATA);


        return rocketMQEnhanceTemplate.send(TOPIC, SendTagConstant.CHARGING_PILE_RETURNS_GROUND_LOCK_DATA, message);


        return rocketMQEnhanceTemplate.send(TOPIC+SendTagConstant.CHARGING_PILE_RETURNS_GROUND_LOCK_DATA, SendTagConstant.CHARGING_PILE_RETURNS_GROUND_LOCK_DATA, message);


    }




    /**


@@ -309,7 +310,7 @@


        message.setKey(UUID.randomUUID().toString());


        // 设置消息来源，便于查询


        message.setSource(SendTagConstant.PLATFORM_RESTART_REPLY);


        return rocketMQEnhanceTemplate.send(TOPIC, SendTagConstant.PLATFORM_RESTART_REPLY, message);


        return rocketMQEnhanceTemplate.send(TOPIC+SendTagConstant.PLATFORM_RESTART_REPLY, SendTagConstant.PLATFORM_RESTART_REPLY, message);


    }




    /**


@@ -321,6 +322,6 @@


        message.setKey(UUID.randomUUID().toString());


        // 设置消息来源，便于查询


        message.setSource(SendTagConstant.PLATFORM_REMOTE_UPDATE_REPLY);


        return rocketMQEnhanceTemplate.send(TOPIC, SendTagConstant.PLATFORM_REMOTE_UPDATE_REPLY, message);


        return rocketMQEnhanceTemplate.send(TOPIC+SendTagConstant.PLATFORM_REMOTE_UPDATE_REPLY, SendTagConstant.PLATFORM_REMOTE_UPDATE_REPLY, message);


    }


}