Hentua
2023-04-12 3dd0ef369d83281002ecd39d3d7753877c278ab1
init meiye mall
7 files modified
66 ■■■■ changed files
src/main/java/cc/mrbird/febs/rabbit/constants/ExchangeConstants.java 2 ●●● patch | view | raw | blame | history
src/main/java/cc/mrbird/febs/rabbit/constants/QueueConstants.java 12 ●●●● patch | view | raw | blame | history
src/main/java/cc/mrbird/febs/rabbit/constants/RouteKeyConstants.java 2 ●●● patch | view | raw | blame | history
src/main/java/cc/mrbird/febs/rabbit/consumer/AgentConsumer.java 2 ●●● patch | view | raw | blame | history
src/main/java/cc/mrbird/febs/rabbit/enumerates/RabbitQueueEnum.java 42 ●●●● patch | view | raw | blame | history
src/main/resources/application-dev.yml 4 ●●●● patch | view | raw | blame | history
src/main/resources/application-test.yml 2 ●●● patch | view | raw | blame | history
src/main/java/cc/mrbird/febs/rabbit/constants/ExchangeConstants.java
@@ -6,5 +6,5 @@
 **/
public class ExchangeConstants {
    public static final String EXCHANGE_DEFAULT = "hlm_exchange_default";
    public static final String EXCHANGE_DEFAULT = "meye_exchange_default";
}
src/main/java/cc/mrbird/febs/rabbit/constants/QueueConstants.java
@@ -6,15 +6,15 @@
 **/
public class QueueConstants {
    public static final String QUEUE_DEFAULT = "hlm_queue_default";
    public static final String AGENT_AUTO_LEVEL_UP = "hlm_queue_agent_auto_level_up";
    public static final String AGENT_RETURN_MONEY = "hlm_queue_agent_return_money";
    public static final String ORDER_RETURN_MONEY = "hlm_queue_order_return_money";
    public static final String QUEUE_DEFAULT = "meye_queue_default";
    public static final String AGENT_AUTO_LEVEL_UP = "meye_queue_agent_auto_level_up";
    public static final String AGENT_RETURN_MONEY = "meye_queue_agent_return_money";
    public static final String ORDER_RETURN_MONEY = "meye_queue_order_return_money";
    /**
     * 补贴金额 ,
     *      分享补贴,星级补贴
     */
    public static final String PERK_MONEY = "hlm_queue_perk_money";
    public static final String PERK_MONEY = "meye_queue_perk_money";
    public static final String FORCE_VOUCHER_SALE = "hlm_queue_force_voucher_sale";
    public static final String FORCE_VOUCHER_SALE = "meye_queue_force_voucher_sale";
}
src/main/java/cc/mrbird/febs/rabbit/constants/RouteKeyConstants.java
@@ -6,5 +6,5 @@
 **/
public class RouteKeyConstants {
    public static final String ROUTE_KEY_DEFAULT = "hlm_route_key_default";
    public static final String ROUTE_KEY_DEFAULT = "meye_route_key_default";
}
src/main/java/cc/mrbird/febs/rabbit/consumer/AgentConsumer.java
@@ -34,7 +34,7 @@
        log.info("消费者:{}", new String(message.getBody()));
    }
    @RabbitListener(queues = "hlm_queue_order_delay")
    @RabbitListener(queues = "meye_queue_order_delay")
    public void orderCancelDelay(String id) {
        try {
            orderInfoService.autoCancelOrder(Long.parseLong(id));
src/main/java/cc/mrbird/febs/rabbit/enumerates/RabbitQueueEnum.java
@@ -5,32 +5,32 @@
@Getter
public enum RabbitQueueEnum {
    DEFAULT("hlm_exchange_default",
            "hlm_route_key_default",
            "hlm_queue_default"),
    DEFAULT("meye_exchange_default",
            "meye_route_key_default",
            "meye_queue_default"),
    ORDER_CANCEL_DELAY_TTL("hlm_exchange_order_delay_ttl",
            "hlm_route_key_order_delay_ttl",
            "hlm_queue_order_delay_ttl"),
    ORDER_CANCEL_DELAY("hlm_exchange_order_delay",
            "hlm_route_key_order_delay",
            "hlm_queue_order_delay"),
    ORDER_CANCEL_DELAY_TTL("meye_exchange_order_delay_ttl",
            "meye_route_key_order_delay_ttl",
            "meye_queue_order_delay_ttl"),
    ORDER_CANCEL_DELAY("meye_exchange_order_delay",
            "meye_route_key_order_delay",
            "meye_queue_order_delay"),
    AGENT_REUTRN_MONEY("hlm_exchange_agent_return_money",
            "hlm_route_key_agent_return_money",
            "hlm_queue_agent_return_money"),
    AGENT_REUTRN_MONEY("meye_exchange_agent_return_money",
            "meye_route_key_agent_return_money",
            "meye_queue_agent_return_money"),
    ORDER_RETURN_MONEY("hlm_exchange_order_return_money",
            "hlm_route_key_order_return_money",
            "hlm_queue_order_return_money"),
    ORDER_RETURN_MONEY("meye_exchange_order_return_money",
            "meye_route_key_order_return_money",
            "meye_queue_order_return_money"),
    PERK_MONEY("hlm_exchange_perk_money",
            "hlm_route_key_perk_money",
            "hlm_queue_perk_money"),
    PERK_MONEY("meye_exchange_perk_money",
            "meye_route_key_perk_money",
            "meye_queue_perk_money"),
    FORCE_VOUCHER_SALE("hlm_exchange_force_voucher_sale",
            "hlm_route_key_force_voucher_sale",
            "hlm_queue_force_voucher_sale");
    FORCE_VOUCHER_SALE("meye_exchange_force_voucher_sale",
            "meye_route_key_force_voucher_sale",
            "meye_queue_force_voucher_sale");
    private String exchange;
src/main/resources/application-dev.yml
@@ -18,11 +18,11 @@
          username: ct_test
          password: 123456
          driver-class-name: com.mysql.cj.jdbc.Driver
          url: jdbc:mysql://120.27.238.55:3406/db_hongloumeng?useUnicode=true&characterEncoding=UTF-8&useJDBCCompliantTimezoneShift=true&allowMultiQueries=true&useLegacyDatetimeCode=false&serverTimezone=GMT%2b8
          url: jdbc:mysql://120.27.238.55:3406/db_meiye_mall?useUnicode=true&characterEncoding=UTF-8&useJDBCCompliantTimezoneShift=true&allowMultiQueries=true&useLegacyDatetimeCode=false&serverTimezone=GMT%2b8
  redis:
    # Redis数据库索引(默认为 0)
    database: 3
    database: 4
    # Redis服务器地址
    host: 120.27.238.55
    # Redis服务器连接端口
src/main/resources/application-test.yml
@@ -18,7 +18,7 @@
          username: ct_test
          password: 123456
          driver-class-name: com.mysql.cj.jdbc.Driver
          url: jdbc:mysql://120.27.238.55:3406/db_hongloumeng?useUnicode=true&characterEncoding=UTF-8&useJDBCCompliantTimezoneShift=true&allowMultiQueries=true&useLegacyDatetimeCode=false&serverTimezone=GMT%2b8
          url: jdbc:mysql://120.27.238.55:3406/db_meiye_mall?useUnicode=true&characterEncoding=UTF-8&useJDBCCompliantTimezoneShift=true&allowMultiQueries=true&useLegacyDatetimeCode=false&serverTimezone=GMT%2b8
  redis:
    # Redis数据库索引(默认为 0)