浏览代码

add:添加日志

zqbao 8 月之前
父节点
当前提交
7ff9ec38b9
共有 2 个文件被更改,包括 15 次插入8 次删除
  1. 4 1
      controllers/wechat.go
  2. 11 7
      services/template_msg.go

+ 4 - 1
controllers/wechat.go

@@ -168,7 +168,10 @@ func (this *WeChatController) SendTemplateMsg() {
 	// 推送模板消息
 	go func(sendData map[string]interface{}, items []*services.OpenIdList, sendType, reportId int) {
 		fmt.Println("推送模板消息:", reportId)
-		_ = services.SendMultiTemplateMsg(sendData, openIds, 1, reportId)
+		err = services.SendMultiTemplateMsg(sendData, openIds, 1, reportId)
+		if err != nil {
+			utils.FileLog.Info("推送模板消息失败, Err:"+err.Error(), 1)
+		}
 	}(sendData, openIds, 1, reportId)
 
 	br.Ret = 200

+ 11 - 7
services/template_msg.go

@@ -138,7 +138,7 @@ func SendMultiTemplateMsg(sendData map[string]interface{}, items []*OpenIdList,
 	ws := GetWxChat()
 	accessToken, err := ws.GetAccessToken()
 	if err != nil {
-		utils.ApiLog.Info("获取微信token失败, Err:"+err.Error(), 1)
+		utils.FileLog.Info("获取微信token失败, Err:"+err.Error(), 1)
 		// alarm_msg.SendAlarmMsg("获取微信token失败, Err:"+err.Error(), 1)
 		return
 	}
@@ -154,7 +154,7 @@ func SendMultiTemplateMsg(sendData map[string]interface{}, items []*OpenIdList,
 		sendMap["data"] = sendData
 		data, e := json.Marshal(sendMap)
 		if e != nil {
-			err = e
+			utils.FileLog.Info("新增模板消息推送记录失败, Err:"+e.Error(), 1)
 			return
 		}
 		ts := &TemplateMsgSendClient{
@@ -162,6 +162,10 @@ func SendMultiTemplateMsg(sendData map[string]interface{}, items []*OpenIdList,
 			Data:        data,
 		}
 		result, e := ts.SendMsg()
+		if e != nil {
+			utils.FileLog.Info("新增模板消息推送记录失败, Err:"+e.Error(), 1)
+			return
+		}
 		if result == nil {
 			return
 		}
@@ -173,13 +177,13 @@ func SendMultiTemplateMsg(sendData map[string]interface{}, items []*OpenIdList,
 					sendStatus = 0
 				}
 				resultJson, _ := json.Marshal(result)
-				_ = AddUserTemplateRecord(v.UserId, sendStatus, sendType, v.OpenId, string(data), string(resultJson))
+				err = AddUserTemplateRecord(v.UserId, sendStatus, sendType, v.OpenId, string(data), string(resultJson))
+				if err != nil {
+					utils.FileLog.Info("新增模板消息推送记录失败, Err:"+err.Error(), 1)
+					return
+				}
 			}(item)
 		}
-		if e != nil {
-			err = e
-			return
-		}
 	}
 	return
 }