|
@@ -175,6 +175,7 @@ func save(mid interface{}, qmap, fileinfo map[string]interface{}) {
|
|
|
<-ChanB
|
|
|
}()
|
|
|
type FileData struct {
|
|
|
+ OrgUrl string //源下载地址
|
|
|
Fid string
|
|
|
Name string
|
|
|
Type string //文件类型png、jpg、tif、swf(ocr识别);pdf,doc,docx,xls
|
|
@@ -200,6 +201,7 @@ func save(mid interface{}, qmap, fileinfo map[string]interface{}) {
|
|
|
fffpath = fffpath[1:]
|
|
|
}
|
|
|
fileData := &FileData{
|
|
|
+ OrgUrl: qu.ObjToString(fileinfo["org_url"]),
|
|
|
Name: qu.ObjToString(fileinfo["filename"]),
|
|
|
Fid: qu.ObjToString(fileinfo["fid"]), //附件id
|
|
|
Type: fffpath,
|
|
@@ -272,24 +274,5 @@ func save(mid interface{}, qmap, fileinfo map[string]interface{}) {
|
|
|
},})
|
|
|
log.Println(mid, "调用rpc服务解析异常:", rdata["err"])
|
|
|
}
|
|
|
- //if qu.ObjToString(fileinfo["ftype"]) == "zip" || qu.ObjToString(fileinfo["ftype"]) == "rar" {
|
|
|
- // fileDatas := make([]map[string]interface{}, 0)
|
|
|
- // if err := json.Unmarshal(reply, &fileDatas); err != nil {
|
|
|
- // log.Println("json转换错误", mid, err)
|
|
|
- // return
|
|
|
- // }
|
|
|
- // fileinfo["content"] = fileDatas
|
|
|
- //} else {
|
|
|
- // fileinfo["content"] = string(reply)
|
|
|
- //}
|
|
|
- //if !mongodbutil.Mgo.UpdateById(MgoC, mid, bson.M{
|
|
|
- // "$set": bson.M{
|
|
|
- // MgoFileFiled: qmap[MgoFileFiled],
|
|
|
- // },
|
|
|
- //}) {
|
|
|
- // log.Println(mid, "更新数据失败")
|
|
|
- //} else {
|
|
|
- // log.Println(mid, "更新数据成功")
|
|
|
- //}
|
|
|
|
|
|
}
|