feat(product&marketing): 新增面试服务商品及完成面试服务商品订单后向企业微信群发送通知 (#210)

Author: longyue0521

config/config.yaml

@@ -16,6 +16,11 @@ wechat:
     appSecretID: abc
     appSecretKey: abc
 
+# 企业微信
+qywechat:
+  # 机器人
+  chatRobot:
+    webhookURL: "your/webhookURL"
 
 mysql:
   dsn: "webook:webook@tcp(mysql8:3306)/webook?charset=utf8mb4&collation=utf8mb4_general_ci&parseTime=True&loc=Local&timeout=1s&readTimeout=3s&writeTimeout=3s"

internal/marketing/internal/event/consumer/order_event_consumer.go

@@ -70,7 +70,7 @@ func (c *OrderEventConsumer) Consume(ctx context.Context) error {
 	}
 
 	for _, spu := range evt.SPUs {
-		if !spu.IsMemberProduct() && !spu.IsProjectProduct() && !spu.IsCodeCategory() {
+		if !spu.IsMemberProduct() && !spu.IsProjectProduct() && !spu.IsServiceProduct() && !spu.IsCodeCategory() {
 			return nil
 		}
 	}

internal/marketing/internal/event/event.go

@@ -59,6 +59,10 @@ func (s SPU) IsProjectProduct() bool {
 	return s.IsProductCategory() && s.Category1 == "project"
 }
 
+func (s SPU) IsServiceProduct() bool {
+	return s.IsProductCategory() && s.Category1 == "service"
+}
+
 type CreditIncreaseEvent struct {
 	Key    string `json:"key"`
 	Uid    int64  `json:"uid"`    // 用户A       用户C
@@ -79,3 +83,7 @@ type UserRegistrationEvent struct {
 	Uid            int64  `json:"uid,omitempty"`
 	InvitationCode string `json:"invitationCode,omitempty"`
 }
+
+type QYWechatEvent struct {
+	Content string `json:"content"`
+}

internal/marketing/internal/event/producer/qywechat_event_producer.go

@@ -0,0 +1,52 @@
+package producer
+
+import (
+	"bytes"
+	"context"
+	"encoding/json"
+	"fmt"
+	"io"
+	"net/http"
+
+	"github.com/ecodeclub/webook/internal/marketing/internal/event"
+)
+
+type QYWeiChatEventProducer interface {
+	Produce(ctx context.Context, evt event.QYWechatEvent) error
+}
+
+type POSTFunc func(url, contentType string, body io.Reader) (resp *http.Response, err error)
+
+type qyWeChatEventProducer struct {
+	url      string
+	postFunc POSTFunc
+}
+
+func NewQYWeChatEventProducer(url string, postFunc POSTFunc) QYWeiChatEventProducer {
+	return &qyWeChatEventProducer{
+		url:      url,
+		postFunc: postFunc,
+	}
+}
+
+func (q *qyWeChatEventProducer) Produce(_ context.Context, evt event.QYWechatEvent) error {
+	type Message struct {
+		MsgType string              `json:"msgtype"`
+		Text    event.QYWechatEvent `json:"text"`
+	}
+	data, err := json.Marshal(&Message{MsgType: "text", Text: evt})
+	if err != nil {
+		return fmt.Errorf("序列化失败: %w", err)
+	}
+	resp, err := q.postFunc(q.url, "application/json", bytes.NewBuffer(data))
+	if err != nil {
+		return fmt.Errorf("发送请求失败: %w", err)
+	}
+	defer func() {
+		_ = resp.Body.Close()
+	}()
+	if resp.StatusCode != http.StatusOK {
+		return fmt.Errorf("处理请求失败: %d %s", resp.StatusCode, http.StatusText(resp.StatusCode))
+	}
+	return nil
+}