no message

controllers/activity.go

@@ -2059,18 +2059,18 @@ func (this *ActivityCoAntroller) AskAdd() {
 		br.ErrMsg = "操作失败,Err:" + errInfo.Error()
 		return
 	}
-	resultTime := utils.StrTimeToTime(activityInfo.ActivityTime) //时间字符串格式转时间格式
-	if activityInfo.ActivityTypeId == 1 && activityInfo.ChartPermissionId != 31 {
-		if time.Now().After(resultTime.Add(-time.Minute * 15)) {
-			br.Msg = "活动开始前15分钟内无法提交问题"
-			return
-		}
-	} else {
-		if time.Now().After(resultTime.Add(-time.Minute * 60)) {
-			br.Msg = "活动开始前1小时内无法提交问题"
-			return
-		}
-	}
+	//resultTime := utils.StrTimeToTime(activityInfo.ActivityTime) //时间字符串格式转时间格式
+	//if activityInfo.ActivityTypeId == 1 && activityInfo.ChartPermissionId != 31 {
+	//	if time.Now().After(resultTime.Add(-time.Minute * 15)) {
+	//		br.Msg = "活动开始前15分钟内无法提交问题"
+	//		return
+	//	}
+	//} else {
+	//	if time.Now().After(resultTime.Add(-time.Minute * 60)) {
+	//		br.Msg = "活动开始前1小时内无法提交问题"
+	//		return
+	//	}
+	//}
 	companyDetail, err := models.GetCompanyDetailById(user.CompanyId)
 	if err != nil {
 		br.Msg = "提交失败！"
@@ -2097,6 +2097,35 @@ func (this *ActivityCoAntroller) AskAdd() {
 		br.ErrMsg = "提交带问失败,Err:" + err.Error()
 		return
 	}
+
+	openIpItem, _ := models.GetUserRecordByMobile(4, "15557270714")
+	fmt.Println(openIpItem)
+	if openIpItem != nil && openIpItem.OpenId != "" {
+		//获取销售信息
+		sellerItem, err := models.GetSellerByCompanyIdCheckFicc(user.CompanyId, 2)
+		if err != nil && err.Error() != utils.ErrNoRow() {
+			br.Msg = "申请失败"
+			br.ErrMsg = "获取销售信息失败,Err:" + err.Error()
+			return
+		}
+		//applyName, applyTime, activityName, openId string, activityId int
+		services.SendActivityAskApplyTemplateMsg(user.RealName+"——"+user.CompanyName+"(所属销售："+sellerItem.RoleName+"）", time.Now().Format(utils.FormatDateTime), req.Content+activityInfo.ActivityName, openIpItem.OpenId, activityInfo.ActivityId)
+	}
+	//resultTime := utils.StrTimeToTime(activityInfo.ActivityTime) //时间字符串格式转时间格式
+	//if activityInfo.ActivityTypeId == 1 && activityInfo.ChartPermissionId != 31 {
+	//	if time.Now().After(resultTime.Add(-time.Minute * 15)) {
+	//		openIpItem, _ := models.GetUserRecordByMobile(4, "15557270714")
+	//		if openIpItem != nil && openIpItem.OpenId != "" {
+	//			//applyName, applyTime, activityName, openId string, activityId int
+	//			services.SendActivityAskApplyTemplateMsg(user.RealName+"——"+user.CompanyName+"(所属销售："+"）", time.Now().Format(utils.FormatDateTime), openIpItem.OpenId,req.Content + activityInfo.ActivityName,  activityInfo.ActivityId)
+	//		}
+	//	}
+	//} else {
+	//	if time.Now().After(resultTime.Add(-time.Minute * 60)) {
+	//		br.Msg = "活动开始前1小时内无法提交问题"
+	//		return
+	//	}
+	//}
 	br.Ret = 200
 	br.Success = true
 	br.Msg = "提交成功"

models/user_record.go

@@ -113,6 +113,7 @@ func GetUserRecordByMobile(platform int, bindAccount string) (item *UserRecord,
 		platform = 1
 		sql = `SELECT open_id FROM	user_record  WHERE create_platform =? AND bind_account = ?`
 	}
+
 	err = orm.NewOrm().Raw(sql, platform, bindAccount).QueryRow(&item)
 	return
 }

services/activity.go

@@ -881,3 +881,66 @@ func AddCygxActivityRestrictSignupByAdmin(activityId int) (err error) {
 	}
 	return
 }
+
+//活动带问提醒
+func SendActivityAskApplyTemplateMsg(applyName, applyTime, activityName, openId string, activityId int) (err error) {
+	var msg string
+	defer func() {
+		if err != nil {
+			go utils.SendEmail("发送模版消息失败"+time.Now().Format("2006-01-02 15:04:05"), msg+";Err:"+err.Error(), utils.EmailSendToUsers)
+		}
+		if msg != "" {
+			utils.FileLog.Info("发送模版消息失败,msg:%s", msg)
+		}
+	}()
+
+	var accessToken string
+	if utils.RunMode == "release" {
+		accessToken, err = models.GetWxAccessTokenByXzs()
+		if err != nil {
+			msg = "GetWxAccessToken Err:" + err.Error()
+			return
+		}
+		if accessToken == "" {
+			msg = "accessToken is empty"
+			return
+		}
+	} else {
+		accessToken, err = models.GetWxAccessToken()
+		if err != nil {
+			msg = "GetWxAccessToken Err:" + err.Error()
+			return
+		}
+		if accessToken == "" {
+			msg = "accessToken is empty"
+			return
+		}
+	}
+
+	sendUrl := "https://api.weixin.qq.com/cgi-bin/message/template/send?access_token=" + accessToken
+
+	sendMap := make(map[string]interface{})
+	sendData := make(map[string]interface{})
+
+	first := "查研观向有一条新的权限申请，请及时处理。"
+	keyword1 := applyName
+	keyword2 := "-"
+	keyword3 := applyTime
+	keyword4 := activityName
+	fontColor := "#D9001B"
+	sendData["first"] = map[string]interface{}{"value": first, "color": fontColor}
+	sendData["keyword1"] = map[string]interface{}{"value": keyword1, "color": fontColor}
+	sendData["keyword2"] = map[string]interface{}{"value": keyword2, "color": fontColor}
+	sendData["keyword3"] = map[string]interface{}{"value": keyword3, "color": fontColor}
+	sendData["keyword4"] = map[string]interface{}{"value": keyword4, "color": fontColor}
+	if utils.RunMode == "release" {
+		sendMap["template_id"] = utils.WxMsgTemplateIdApplyXzs
+	} else {
+		sendMap["template_id"] = utils.WxMsgTemplateIdApply
+	}
+	sendMap["miniprogram"] = map[string]interface{}{"appid": utils.WxAppId, "pagepath": "activityPages/activityDetail/activityDetail?id=" + strconv.Itoa(activityId)}
+	sendMap["data"] = sendData
+	sendTemplateMsg(sendUrl, openId, sendMap)
+	fmt.Println("send end")
+	return
+}