Merge branch 'feature/image_content' into debug

services/day_new.go

@@ -82,7 +82,7 @@ func DayNewWeworkMsgRefresh() (err error) {
 			continue
 		}
 		if limitRoomId != "" {
-			if v.RoomID == "wrPhSiBwAAQcw_fTWXizaK3mIBMG9LAA" {
+			if v.RoomID != limitRoomId {
 				continue
 			}
 		}

services/wework/wework_audit_linux.go

@@ -59,7 +59,7 @@ func (w *WeWorkMsgAuditClient) GetMsgAuditContent(seq, limit uint64, timeout int
 				indexBuf = mediaData.OutIndexBuf
 			}
 			filePath, _ := os.Getwd()
-			filePath = path.Join(filePath, image.Image.Md5Sum)
+			filePath = path.Join(filePath, image.Image.Md5Sum+".jpg")
 			err := ioutil.WriteFile(filePath, buffer.Bytes(), 0666)
 			if err != nil {
 				utils.FileLog.Info(fmt.Sprintf("文件存储失败：%v \n", err))
@@ -87,6 +87,32 @@ func (w *WeWorkMsgAuditClient) GetMsgAuditContent(seq, limit uint64, timeout int
 			}
 			utils.FileLog.Info(fmt.Sprintf("明文：%s \n", msg))
 			list = append(list, msg)
+		}else if chatInfo.Type == "file" {
+			file, err := chatInfo.GetFileMessage()
+			if err != nil {
+				utils.FileLog.Info(fmt.Sprintf("查询文件消息类型失败：%v \n", err))
+				errMsg = errors.New("企业微信 查询文件消息类型失败："+err.Error())
+				return
+			}
+			// 保存文件到本地
+			filePath, _ := os.Getwd()
+			filePath = path.Join(filePath, file.File.FileName+"."+file.File.FileExt)
+			err := ioutil.WriteFile(filePath, file.File.Data, 0666)
+			if err != nil {
+				utils.FileLog.Info(fmt.Sprintf("文件存储失败：%v \n", err))
+				errMsg = errors.New("企业微信 文件存储失败："+err.Error())
+				return
+			}
+			utils.FileLog.Info(fmt.Sprintf("文件存储成功：%s \n", filePath))
+			var textMsg msgaudit.TextMessage
+			textMsg.MsgID = file.BaseMessage.MsgID
+			textMsg.Action = file.BaseMessage.Action
+			textMsg.From = file.BaseMessage.From
+			textMsg.ToList = file.BaseMessage.ToList
+			textMsg.RoomID = file.BaseMessage.RoomID
+			textMsg.MsgTime = file.BaseMessage.MsgTime
+			textMsg.Text.Content = filePath
+			list = append(list, textMsg)
 		}
 	}