feat:邮箱提醒

internal/dao/internal/offline.go

@@ -31,8 +31,12 @@ func (o *OfflineInfo) OfflineData() ([]*AnalyzeTask, error) {
 	var analyze = &AnalyzeTask{}
 	for _, row := range *res {
 		ui := NewUserInfo()
-		ui.MgoUserId = common.ObjToString(row["s_userId"])   //MgoUserId
+		ui.MgoUserId = common.ObjToString(row["s_mgoUserId"]) //MgoUserId
+		if ui.MgoUserId == "" {
+			ui.MgoUserId = common.ObjToString(row["s_userId"]) //MgoUserId
+		}
 		ui.PositionId = common.Int64All(row["i_positionId"]) //职位id
+		ui.Phone = common.ObjToString(row["s_phone"])        //手机号
 		ui.RId = mongodb.BsonIdToSId(row["_id"])
 		ui.AnalysisParam = entity.AnalyzeParameters{
 			KeysItemsStr: common.ObjToString(row["s_keysItems"]),

internal/dao/internal/userTask.go

@@ -21,8 +21,9 @@ import (
 
 // user 信息
 type UserTask struct {
-	MgoUserId            string //用户id
-	PositionId           int64
+	MgoUserId            string                       //用户id
+	PositionId           int64                        //职位id
+	Phone                string                       //手机号
 	StartTime            int64                        //开始时间
 	EndTime              int64                        //结束时间
 	IsEnd                bool                         //是否结束
@@ -1208,7 +1209,7 @@ func (ut *UserTask) ResultSave() {
 func (ut *UserTask) SendMsg() {
 	//分析报告离线分析异常
 	if ut.IsFalse {
-		content := fmt.Sprintf(g.Cfg("task.yaml").MustGet(model.Ctx, "falseMsg").String(), ut.RId, ut.MgoUserId, ut.PositionId, ut.AnalysisParam.KeysItemsStr, ut.AnalysisParam.Area, ut.AnalysisParam.Industry, ut.AnalysisParam.BuyerClass, ut.MatchingMode)
+		content := fmt.Sprintf(g.Cfg("task.yaml").MustGet(model.Ctx, "falseMsg").String(), ut.RId, ut.MgoUserId, ut.PositionId, ut.Phone, ut.AnalysisParam.KeysItemsStr, ut.AnalysisParam.Area, ut.AnalysisParam.Industry, ut.AnalysisParam.BuyerClass, ut.MatchingMode)
 		SendAlarmMail(model.Ctx, content)
 	} else {
 		SendReportMsg(model.Ctx, ut.MgoUserId, ut.PositionId, ut.RId)

internal/model/entity/result.go

@@ -283,7 +283,3 @@ type MemberScore struct {
 	Id     string
 	Score  float64
 }
-
-//err
-type ErrorInfo struct {
-}