From 018d0357568292b1c6a4aa2005321c7a995f97bd Mon Sep 17 00:00:00 2001
From: chenweijian <820961417@qq.com>
Date: Thu, 15 Jun 2023 10:09:17 +0800
Subject: [PATCH] cp

---
 _const/enum/cp_e/cp_relation.go |  2 ++
 route/cp_r/cp_relation.go       | 22 +++++++++++++---------
 2 files changed, 15 insertions(+), 9 deletions(-)

diff --git a/_const/enum/cp_e/cp_relation.go b/_const/enum/cp_e/cp_relation.go
index ed22585..9aa7dcb 100644
--- a/_const/enum/cp_e/cp_relation.go
+++ b/_const/enum/cp_e/cp_relation.go
@@ -22,4 +22,6 @@ const (
 	CpCancelAcceptAuto CpCancelStatus = 4
 
 	CpConfessionGiftId = 3379 // cp礼物id cwj----
+	CpMaleHeadwearId   = 2551 // cp绑定成功后赠送的头饰-男
+	CpFemaleHeadwearId = 2561 // cp绑定成功后赠送的头饰-女
 )
diff --git a/route/cp_r/cp_relation.go b/route/cp_r/cp_relation.go
index 6672bcb..235394f 100644
--- a/route/cp_r/cp_relation.go
+++ b/route/cp_r/cp_relation.go
@@ -13,6 +13,7 @@ import (
 	"git.hilo.cn/hilo-common/sdk/tencentyun"
 	"git.hilo.cn/hilo-common/txop/bag_tx"
 	"git.hilo.cn/hilo-common/txop/diamond_tx"
+	"git.hilo.cn/hilo-common/txop/headwear_tx"
 	"git.hilo.cn/hilo-common/txop/msg"
 	"git.hilo.cn/hilo-common/utils"
 	"github.com/gin-gonic/gin"
@@ -217,15 +218,18 @@ func ReplyCpInvite(c *gin.Context) (*mycontext.MyContext, error) {
 				model.Log.Errorf("ReplyCpInvite userSender:%d, user:%d, status:%d, err:%v", userSender.ID, user.ID, updateStatus, err)
 				return err
 			}
-			// 发放头饰 cwj----
-			//if err = headwear_tx.SendHeadwear(model, userSender.ID, 1, 3); err != nil {
-			//	model.Log.Errorf("ReplyCpInvite userSender:%d, user:%d, status:%d, err:%v", userSender.ID, user.ID, updateStatus, err)
-			//	return err
-			//}
-			//if err = headwear_tx.SendHeadwear(model, user.ID, 1, 3); err != nil {
-			//	model.Log.Errorf("ReplyCpInvite userSender:%d, user:%d, status:%d, err:%v", userSender.ID, user.ID, updateStatus, err)
-			//	return err
-			//}
+			// 发放头饰
+			for _, u := range []*user_m.User{userSender, user} {
+				headwearId := cp_e.CpMaleHeadwearId
+				if u.Sex == mysql.WOMAN {
+					headwearId = cp_e.CpFemaleHeadwearId
+				}
+				if err = headwear_tx.SendHeadwear(model, u.ID, mysql.ID(headwearId), 9999); err != nil {
+					model.Log.Errorf("ReplyCpInvite user:%d, headwearId:%d, err:%v", u.ID, headwearId, err)
+					return err
+				}
+			}
+
 			// 私信-接受
 			content, err := msg.GetResMultiTextBy(model, common.MSG_ID_BIND_CP_SUCCEED, lang)
 			if err != nil {
-- 
2.22.0