From e0d2fb416f362de49f1b5dc1a153e19a7551d61f Mon Sep 17 00:00:00 2001 From: dengbiao Date: Mon, 30 Dec 2024 23:44:37 +0800 Subject: [PATCH] 12 --- consume/user_register_for_my_my_recommender.go | 2 +- consume/user_register_for_official_consume.go | 2 +- k8s/zyos-go-mq-consume-prd.yaml | 18 +++++++++--------- 3 files changed, 11 insertions(+), 11 deletions(-) diff --git a/consume/user_register_for_my_my_recommender.go b/consume/user_register_for_my_my_recommender.go index e00bf24..e388f39 100644 --- a/consume/user_register_for_my_my_recommender.go +++ b/consume/user_register_for_my_my_recommender.go @@ -142,7 +142,7 @@ func handleUserRegisterConsumeForMyRecommender(msgData []byte) error { if err != nil { return err } - if len(*userGroups) < 1000 { + if len(*userGroups) <= 1000 { fansGroup = group } } diff --git a/consume/user_register_for_official_consume.go b/consume/user_register_for_official_consume.go index 67feba9..0e56e38 100644 --- a/consume/user_register_for_official_consume.go +++ b/consume/user_register_for_official_consume.go @@ -142,7 +142,7 @@ func handleUserRegisterConsumeForOfficial(msgData []byte) error { "key": "group_id", "value": group.GroupId, }) - if len(*userGroups) < 1000 { + if len(*userGroups) <= 1000 { officialGroup = group } } diff --git a/k8s/zyos-go-mq-consume-prd.yaml b/k8s/zyos-go-mq-consume-prd.yaml index d630b94..68aa3a6 100644 --- a/k8s/zyos-go-mq-consume-prd.yaml +++ b/k8s/zyos-go-mq-consume-prd.yaml @@ -2,10 +2,10 @@ kind: Deployment apiVersion: apps/v1 # 元数据 metadata: - name: egg-go-mq-consume + name: egg-gim-go-mq-consume namespace: egg labels: - app: egg-go-mq-consume + app: egg-gim-mq-consume annotations: kubesphere.io/creator: dengbiao # deployment主要部分 @@ -14,12 +14,12 @@ spec: selector: matchLabels: # 名称与上面的labels对应 - app: egg-go-mq-consume + app: egg-gim-mq-consume template: metadata: labels: # 名称与上面的matchLabels对应 - app: egg-go-mq-consume + app: egg-gim-mq-consume spec: # 声明挂载卷(将外部已存在的pvc、config等挂载进来) volumes: @@ -29,22 +29,22 @@ spec: path: /etc/localtime type: '' # 将前面创建的configMap也挂载进来 - - name: egg-go-mq-consume-cfg + - name: egg-gim-mq-consume-cfg configMap: # 这里的名字就是前面创建的configMap的名字 - name: egg-go-mq-consume-cfg + name: egg-gim-mq-consume-cfg defaultMode: 420 containers: # 主容器 - - name: egg-go-mq-consume + - name: egg-gim-mq-consume # 镜像地址(提前打包好并推送的镜像仓库) - image: 'registry.cn-shenzhen.aliyuncs.com/fnuoos-prd/egg-go-mq-consume:0.0.1' + image: 'registry.cn-shenzhen.aliyuncs.com/fnuoos-prd/egg-gim-mq-consume:0.0.1' # 将前面volume声明的需要用到的pvc、config挂载上来 volumeMounts: - name: host-time readOnly: true mountPath: /etc/localtime - - name: egg-go-mq-consume-cfg # 该名字对应前面volumes声明的名字 + - name: egg-gim-mq-consume-cfg # 该名字对应前面volumes声明的名字 readOnly: true # 挂载到容器的哪个路径 mountPath: /var/egg