by Robin at 20240725

api/consts/consts.go

@@ -57,6 +57,7 @@ const (
 	ZoneVIPConfigKey                          = "zone_vip_config"
 	StreamerScoreFormulaKey                   = "streamer_score_formula"
 	HvyogoSingleDistributeChargePercentageKey = "hvyogo_single_distribute_charge_percentage"
+	AutoResponseKey                           = "auto_response"
 )
 
 // del_flag

api/errcode/errcode.go

@@ -132,6 +132,7 @@ var ErrCodeMsgMap = map[ErrCode]string{
 
 	ErrCodeContactCustomerServiceSrvFail:  "联系客服服务错误",
 	ErrCodeContactCustomerServiceNotExist: "联系客服不存在",
+	ErrCodeAutoResponseSrvFail:            "自动回复服务错误",
 
 	ErrCodeImageAuditSrvFail:  "图像审核服务错误",
 	ErrCodeImageAuditNotExist: "图像审核不存在",
@@ -419,6 +420,7 @@ const (
 	ErrCodeContactCustomerServiceSrvOk    ErrCode = ErrCodeOk
 	ErrCodeContactCustomerServiceSrvFail  ErrCode = -19001 // 联系客服服务错误
 	ErrCodeContactCustomerServiceNotExist ErrCode = -19002 // 联系客服不存在
+	ErrCodeAutoResponseSrvFail            ErrCode = -19003 // 自动回复服务错误
 
 	// ImageAudit: 20xxx
 	ErrCodeImageAuditSrvOk    ErrCode = ErrCodeOk

apollostruct/auto_response.go

@@ -0,0 +1,7 @@
+package apollostruct
+
+type AutoResponseCfg struct {
+	StartTime string `json:"start_time"`
+	EndTime   string `json:"end_time"`
+	Message   string `json:"message"`
+}

app/mix/dao/mongo.go

@@ -163,8 +163,9 @@ const (
 	COLRealNameAuthentication    = "realname_authentication"
 	COLRealNameAuthenticationHis = "realname_authentication_his"
 
-	DBContactCustomerService  = "contact_customer_service"
-	COLContactCustomerService = "contact_customer_service"
+	DBContactCustomerService   = "contact_customer_service"
+	COLContactCustomerService  = "contact_customer_service"
+	COLAutoResponseCreateTimes = "auto_reponse_create_times"
 
 	DBImageAudit      = "image_audit"
 	COLImageAudit     = "image_audit"
@@ -460,6 +461,11 @@ func (m *Mongo) getColContactCustomerService() *qmgo.Collection {
 	return m.clientMix.Database(DBContactCustomerService).Collection(COLContactCustomerService)
 }
 
+// 联系客服自动回复创建频次表
+func (m *Mongo) getColAutoResponseCreateTimes() *qmgo.Collection {
+	return m.clientMix.Database(DBContactCustomerService).Collection(COLAutoResponseCreateTimes)
+}
+
 // 图像审核表
 func (m *Mongo) getColImageAudit() *qmgo.Collection {
 	return m.clientMix.Database(DBImageAudit).Collection(COLImageAudit)
@@ -3309,6 +3315,32 @@ func (m *Mongo) GetContactCustomerServiceListBySessionId(ctx *gin.Context, req *
 	return list, err
 }
 
+// 自动回复创建频次
+func (m *Mongo) GetAndUpdateAutoResponseCreateTimes(ctx *gin.Context, mid int64) (autoResponseCreateTimes *dbstruct.AutoResponseCreateTimes, err error) {
+	col := m.getColAutoResponseCreateTimes()
+
+	change := qmgo.Change{
+		Update:    qmgo.M{"$inc": qmgo.M{"create_times": 1}},
+		Upsert:    true,
+		ReturnNew: false,
+	}
+
+	autoResponseCreateTimesInstance := dbstruct.AutoResponseCreateTimes{}
+	if err = col.Find(ctx, qmgo.M{"_id": mid}).Apply(change, &autoResponseCreateTimesInstance); err != nil {
+		logger.Error("change error : %v", err)
+		return
+	}
+
+	return &autoResponseCreateTimesInstance, err
+}
+
+// 清空动态创建频次表
+func (m *Mongo) ClearAutoResponseCreateTimes(ctx *gin.Context) error {
+	col := m.getColAutoResponseCreateTimes()
+	_, err := col.RemoveAll(ctx, qmgo.M{})
+	return err
+}
+
 // 图像审核相关
 func (m *Mongo) CreateImageAudit(ctx *gin.Context, imageaudit *dbstruct.ImageAudit) error {
 	col := m.getColImageAudit()

app/mix/service/apiservice.go

@@ -1997,6 +1997,43 @@ func (s *Service) ApiCreateContactCustomerService(ctx *gin.Context, req *contact
 		ec = errcode.ErrCodeContactCustomerServiceSessionSrvFail
 		return
 	}
+
+	//获取自动信息
+	cfg := &apollostruct.AutoResponseCfg{}
+	err = apollo.GetJson(consts.AutoResponseKey, &cfg, apollo.ApolloOpts().SetNamespace("application"))
+	if err != nil {
+		logger.Error("Apollo read failed : %v", err)
+		return errcode.ErrCodeApolloReadFail
+	}
+
+	//如果在自动回复时间段，则创建一条自动回复信息
+	now := time.Now()
+	st := util.GetTimestampAtThisMomentForTime(now, cfg.StartTime)
+	et := util.GetTimestampAtThisMomentForTime(now, cfg.EndTime)
+	ct := util.DerefInt64(req.ContactCustomerService.Ct)
+	if ct > st && ct < et {
+		createTimes, err := _DefaultAutoResponseCreateTimes.OpGetAndUpdate(ctx, req.BaseRequest.Mid)
+		if err != nil {
+			logger.Error("_DefaultAutoResponseCreateTimes OpGetAndUpdate fail, req: %v, err: %v", util.ToJson(req), err)
+			ec = errcode.ErrCodeAutoResponseSrvFail
+			return
+		}
+		if createTimes.CreateTimes == 0 {
+			err := _DefaultContactCustomerService.OpCreate(ctx, &contact_customer_service_proto.OpCreateReq{
+				ContactCustomerService: &dbstruct.ContactCustomerService{
+					SessionId: req.ContactCustomerService.SessionId,
+					Predicate: goproto.Int64(consts.ContactCustomerService_FromSupportor),
+					Message:   goproto.String(cfg.Message),
+					IsRead:    goproto.Int64(consts.ContactCustomerService_NotRead),
+				},
+			})
+			if err != nil {
+				logger.Error("OpCreate fail, req: %v, err: %v", util.ToJson(req), err)
+				ec = errcode.ErrCodeContactCustomerServiceSrvFail
+				return
+			}
+		}
+	}
 	return
 }
 

app/mix/service/cronservice.go

@@ -85,6 +85,7 @@ func (s *CronService) Init(c any) (exec xxl.Executor, err error) {
 	exec.RegTask("video_moderation_batch_his", s.VideoModerationBatchHis)
 	exec.RegTask("clear_expired_btcb", s.ClearExpiredBtcb)
 	exec.RegTask("reload_blocked_from_being_searched_list", s.ReloadBlockedFromBeingSearchedList)
+	exec.RegTask("clear_auto_response_create_times", s.ClearAutoResponseCreateTimes)
 	exec.LogHandler(customLogHandle)
 	//注册任务handler
 

app/mix/service/logic/auto_response_create_times.go

@@ -0,0 +1,40 @@
+package logic
+
+import (
+	"service/app/mix/dao"
+	"service/dbstruct"
+	"service/library/logger"
+
+	"github.com/gin-gonic/gin"
+)
+
+type AutoResponseCreateTimes struct {
+	store *dao.Store
+}
+
+func NewAutoResponseCreateTimes(store *dao.Store) (a *AutoResponseCreateTimes) {
+	a = &AutoResponseCreateTimes{
+		store: store,
+	}
+	return
+}
+
+func (p *AutoResponseCreateTimes) OpGetAndUpdate(ctx *gin.Context, mid int64) (*dbstruct.AutoResponseCreateTimes, error) {
+
+	vericodeSendTimes, err := p.store.GetAndUpdateAutoResponseCreateTimes(ctx, mid)
+	if err != nil {
+		logger.Error("GetAndUpdateAutoResponseCreateTimes fail, err: %v", err)
+		return nil, err
+	}
+
+	return vericodeSendTimes, nil
+}
+
+func (p *AutoResponseCreateTimes) OpClear(ctx *gin.Context) error {
+	err := p.store.ClearAutoResponseCreateTimes(ctx)
+	if err != nil {
+		logger.Error("ClearAutoResponseCreateTimes fail, err: %v", err)
+		return err
+	}
+	return nil
+}

app/mix/service/service.go

@@ -149,6 +149,7 @@ var (
 	_DefaultStreamerScore                  *logic.StreamerScore
 	_DefaultWorkerId                       *logic.WorkerId
 	_DefaultSingleDistributeHis            *logic.SingleDistributeHis
+	_DefaultAutoResponseCreateTimes        *logic.AutoResponseCreateTimes
 )
 
 type Service struct {

app/mix/service/xxljob_tasks.go

@@ -592,3 +592,14 @@ func (s *CronService) ReloadBlockedFromBeingSearchedList(ctx context.Context, pa
 	logger.Info("Refresh blocked-from-being-searched list cached in redis accomplished...")
 	return "Refresh blocked-from-being-searched list cached in redis accomplished"
 }
+
+func (s *CronService) ClearAutoResponseCreateTimes(ctx context.Context, param *xxl.RunReq) (msg string) {
+	logger.Info("task %v param: %v log_id: %v", param.ExecutorHandler, param.ExecutorParams, xxl.Int64ToStr(param.LogID))
+	logger.Info("Clearing auto_response_create_times collection...")
+	if err := _DefaultAutoResponseCreateTimes.OpClear(&gin.Context{}); err != nil {
+		logger.Error("Clear auto_response_create_times collection fail: %v", err)
+		return fmt.Sprintf("Clear auto_response_create_times collection fail: %v", err)
+	}
+	logger.Info("auto_response_create_times collection has been cleared")
+	return "auto_response_create_times collection has been cleared"
+}

bizcommon/util/util.go

@@ -180,6 +180,20 @@ func GetDayStartTimeStamp(t time.Time) int64 {
 	return duetimecst.Unix()
 }
 
+// 获取当日该时间时间戳
+func GetTimestampAtThisMomentForTime(t time.Time, layout string) int64 {
+	loc, err := time.LoadLocation("Asia/Shanghai")
+	if err != nil {
+		loc = time.FixedZone("CST", 8*3600)
+	}
+	timeStr := fmt.Sprintf("%02d-%02d-%02d %s", t.Year(), t.Month(), t.Day(), layout)
+	duetimecst, err := time.ParseInLocation("2006-1-2 15:04:05", timeStr, loc)
+	if err != nil {
+		logger.Error("parse error : %v", err)
+	}
+	return duetimecst.Unix()
+}
+
 // 随机生成字符串
 func RandomString(l int) string {
 	str := "0123456789AaBbCcDdEeFfGgHhIiJjKkLlMmNnOoPpQqRrSsTtUuVvWwXxYyZz"

dbstruct/auto_response_create_times.go

@@ -0,0 +1,6 @@
+package dbstruct
+
+type AutoResponseCreateTimes struct {
+	Id          int64 `json:"id" bson:"_id"`                    //id,主播的mid
+	CreateTimes int64 `json:"create_times" bson:"create_times"` //发送次数
+}