消息推送

model/typeManage/responsiblePerson.go

@@ -1,6 +1,7 @@
 package typeManage
 
 import (
+	"errors"
 	"log-server/global"
 )
 
@@ -59,3 +60,14 @@ func (m *ResponsiblePerson) GetUserInfoData() (mps map[string]ResponsiblePerson,
 	}
 	return mp, err
 }
+
+func (m *ResponsiblePerson) GetUserInfoByName(name string) (person ResponsiblePerson, err error) {
+	err = global.GVA_DB.Table("responsible_person").Where("name = ?", name).Where("state = ?", 1).Find(&person).Error
+	if err != nil {
+		return
+	}
+	if person.Id == 0 {
+		return person, errors.New("数据错误")
+	}
+	return
+}

service/task/sync_data.go

@@ -198,6 +198,7 @@ func (s *SyncData) SyncTaskData() {
 					_ = s.cache.SetCacheStr(context.Background(), lastPayAddNumKey, gameTarget.PayTarget-completeTaskData[gameTask.TaskId].PayTarget)
 					payErrAddNumKey := fmt.Sprintf(PayErrAddNumKey, date, gameTask.TaskId)
 					s.common.SaveGameAddFee(gameTarget.PayTarget-completeTaskData[gameTask.TaskId].PayTarget, gameTarget.PayTarget, gameTask.TaskName)
+					go s.FreeSendMsg(gameTarget.PayTarget-completeTaskData[gameTask.TaskId].PayTarget, gameTarget.PayTarget, gameTask.TaskName, gameTask.User)
 					// 如果当前付费目标完成，加入一下逻辑
 					if completeTaskData[gameTask.TaskId].PayTarget <= completeTaskData[gameTask.TaskId].PayComplete {
 						lastPayCompletedUpdateTimeKey := fmt.Sprintf(LastPayCompletedUpdateTimeKey, date, gameTask.TaskId)
@@ -232,6 +233,7 @@ func (s *SyncData) SyncTaskData() {
 					_ = s.cache.SetCacheStr(context.Background(), lastPayAddNumKey, gameTarget.PayTarget-completeTaskData[gameTask.TaskId].PayTarget)
 					payErrAddNumKey := fmt.Sprintf(PayErrAddNumKey, date, gameTask.TaskId)
 					s.common.SaveGameAddFee(gameTarget.PayTarget-completeTaskData[gameTask.TaskId].PayTarget, gameTarget.PayTarget, gameTask.TaskName)
+					go s.FreeSendMsg(gameTarget.PayTarget-completeTaskData[gameTask.TaskId].PayTarget, gameTarget.PayTarget, gameTask.TaskName, gameTask.User)
 					// 如果当前付费目标完成，加入一下逻辑
 					if completeTaskData[gameTask.TaskId].PayTarget <= completeTaskData[gameTask.TaskId].PayComplete {
 						lastPayCompletedUpdateTimeKey := fmt.Sprintf(LastPayCompletedUpdateTimeKey, date, gameTask.TaskId)
@@ -1331,3 +1333,28 @@ func (s *SyncData) TaskMsgSendFreeDataUpdate(ctx context.Context, completesInfo
 	}
 	return
 }
+
+// 加付费通知
+func (s *SyncData) FreeSendMsg(num, target int, taskName, director string) {
+	hour := time.Now().Hour()
+	if hour < 8 {
+		return
+	}
+	person, err := s.Person.GetUserInfoByName(director)
+	if err != nil {
+		global.GVA_LOG.Error("FreeSendMsg获取用户数据失败"+director, zap.Error(err))
+	}
+	if person.PushStatus != 1 {
+		return
+	}
+	personMsg := "# 加付费"
+	personMsg += fmt.Sprintf("<font color=\"warning\">%s</font>", time.Now().Format("2006-01-02 15:04:05"))
+	personMsg += "\n"
+	personMsg += taskName
+	personMsg += fmt.Sprintf("<font color=\"warning\"> 加付费 %d, 当前付费目标 %d</font>", num, target)
+	url := person.Url
+	var sendData SendMsg
+	sendData.MsgType = "markdown"
+	sendData.Markdown.Content = personMsg
+	s.SendMsgData(url, sendData)
+}