test.go 812 B

1234567891011121314151617181920212223242526272829303132
  1. package extract
  2. import (
  3. "data_ai/ul"
  4. "fmt"
  5. log "github.com/donnie4w/go-logger/logger"
  6. qu "jygit.jydev.jianyu360.cn/data_processing/common_utils"
  7. )
  8. func TestSingleFieldInfo(name string, tmpid string) {
  9. tmp := ul.SourceMgo.FindById(name, tmpid)
  10. data := ResolveInfo(tmp)
  11. //最终结果...
  12. for k, v := range data {
  13. log.Debug(k, "~", v)
  14. }
  15. }
  16. // 更新链接
  17. func TestUpdateJyhref(name string) {
  18. dataArr, _ := ul.SourceMgo.Find(name, map[string]interface{}{}, nil, map[string]interface{}{"_id": 1})
  19. for _, v := range dataArr {
  20. tmpid := ul.BsonTOStringId(v["_id"])
  21. jyhref := fmt.Sprintf(ul.Url, qu.CommonEncodeArticle("content", tmpid))
  22. ul.SourceMgo.UpdateById(name, tmpid, map[string]interface{}{
  23. "$set": map[string]interface{}{
  24. "jyhref": jyhref,
  25. },
  26. })
  27. }
  28. log.Debug("is over ...")
  29. }