Function DocumentProcess

models/Utils.go:20–209

文档处理

(uid int, form FormUpload)

// 文档处理
func DocumentProcess(uid int, form FormUpload) (err error) {
	// 1. 计算文档 md5
	// 2. 判断文档是否合法
	// 3. 存入 document_store
	// 4. 存入 document
	// 5. 存入 document_info
	// 6. 文档分类数量增加 category 表
	// 7. 总文档数增加
	// 8. 用户积分和文档数量增加
	// 9. 积分记录

	sys, _ := NewSys().Get()
	score := 0 // 文档已被上传的话，获得的积分为0

	var doc = &Document{
		Title:       form.Title,
		Filename:    form.Filename,
		Keywords:    form.Tags,
		Description: form.Intro,
	}

	o := orm.NewOrm()
	o.Begin()
	defer func() {
		if err != nil {
			o.Rollback()
			os.Remove(form.TmpFile)
		} else {
			o.Commit()
			if helper.Debug {
				beego.Debug("============")
				beego.Debug("form: %+v", form)
				beego.Debug("doc: %+v", doc)
				beego.Debug("============")
			}
			if score > 0 {
				go DocumentConvert(form.TmpFile, form.Md5, sys.PreviewPage)
			}
			go func() {
				if errIndex := NewElasticSearchClient().BuildIndexById(doc.Id); err != nil {
					helper.Logger.Error("重建索引失败：%v", errIndex.Error())
				}
			}()
		}
	}()

	var (
		errForbidden   = errors.New("您上传的文档已被管理员禁止上传")
		errRetry       = errors.New("文档上传失败，请重新上传")
		errRepeatedDoc = errors.New("您要分享的文档已存在，请勿再次分享")
	)

	var file *os.File
	file, err = os.Open(form.TmpFile)
	if err == nil {
		defer file.Close()
		form.Md5 = helper.ComputeFileMD5(file)
	}