From bd5b7076aa4572f50953ec9ff0b97af7d46994aa Mon Sep 17 00:00:00 2001
From: chenweijian <820961417@qq.com>
Date: Fri, 10 Mar 2023 17:36:19 +0800
Subject: [PATCH] =?UTF-8?q?=E5=AE=B6=E6=97=8F=E6=88=90=E5=91=98?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../model/groupPower_m/group_power_invite.go  | 50 +++++++++++++++++++
 1 file changed, 50 insertions(+)
 create mode 100644 domain/model/groupPower_m/group_power_invite.go

diff --git a/domain/model/groupPower_m/group_power_invite.go b/domain/model/groupPower_m/group_power_invite.go
new file mode 100644
index 0000000..4c4c040
--- /dev/null
+++ b/domain/model/groupPower_m/group_power_invite.go
@@ -0,0 +1,50 @@
+package groupPower_m
+
+import (
+	"git.hilo.cn/hilo-common/resource/mysql"
+	"gorm.io/gorm"
+	"hilo-group/myerr"
+	"time"
+)
+
+type GroupPowerInviteJoin struct {
+	Id           uint64    `json:"id"`
+	UserId       uint64    `json:"user_id"`
+	GroupPowerId uint64    `json:"group_power_id"`
+	CreatedTime  time.Time `json:"created_time"`
+	UpdatedTime  time.Time `json:"updated_time"`
+	InviteUserId uint64    `json:"invite_user_id"`
+	IsAccept     int8      `json:"is_accept"`
+}
+
+func InsertGroupPowerInviteJoin(userId, inviteUserId, familyId uint64) error {
+	nowTime := time.Now()
+	sql := "insert into group_power_invite_join(user_id,invite_user_id,group_power_id,is_accept,created_time,updated_time) " +
+		"value(?,?,?,?,?,?) on duplicate key update is_accept=?,created_time=?,updated_time=?"
+	err := mysql.Db.Exec(sql, userId, inviteUserId, familyId, 0, nowTime, nowTime, 0, nowTime, nowTime).Error
+	if err != nil {
+		return myerr.WrapErr(err)
+	}
+	return nil
+}
+
+func GetGroupPowerInviteJoin(userId, familyId uint64) (*GroupPowerInviteJoin, error) {
+	res := new(GroupPowerInviteJoin)
+	err := mysql.Db.Where(GroupPowerInviteJoin{UserId: userId, GroupPowerId: familyId}).Where("is_accept=0").First(&res).Error
+	if err != nil {
+		if err == gorm.ErrRecordNotFound {
+			return nil, nil
+		} else {
+			return nil, myerr.WrapErr(err)
+		}
+	}
+	return res, nil
+}
+
+func AcceptGroupPowerInviteJoin(userId, familyId uint64) error {
+	err := mysql.Db.Exec("update group_power_invite_join set is_accept = 1 where user_id=? and group_power_id=?", userId, familyId).Error
+	if err != nil {
+		return myerr.WrapErr(err)
+	}
+	return nil
+}
-- 
2.22.0