|
@@ -12,6 +12,7 @@ import (
|
|
|
"log"
|
|
|
cf "qfw/coreconfig"
|
|
|
"qfw/mobile"
|
|
|
+ tag "qfw/tag"
|
|
|
"qfw/util"
|
|
|
"qfw/util/credit"
|
|
|
elastic "qfw/util/elastic"
|
|
@@ -212,23 +213,13 @@ func CommonEntInfo(yp *xweb.Action, id string, editFlag int, ismobile bool) erro
|
|
|
//关系网数据
|
|
|
yp.T["relflag"] = relflag
|
|
|
//著作权
|
|
|
- yp.T["copyright"] = FindOne("enterprise_copyright", `{"EntId":"`+id+`"}`)
|
|
|
+ yp.T["copyright"] = FindOne("enterprise_copyright", `{"EntName":"`+entName+`"}`)
|
|
|
//编辑企业名片标识
|
|
|
yp.T["editFlag"] = editFlag
|
|
|
yp.T["lastService"] = getLastService(id)
|
|
|
//过滤企业名
|
|
|
if relflag && nodes != nil && len(*nodes) > 0 {
|
|
|
- go func() {
|
|
|
- util.Try(func() {
|
|
|
- if filterEntName(nodes) > 0 {
|
|
|
- relation["nodes"] = nodes
|
|
|
- redis.Put("enterprise", "relation-"+regNo, relation, 7*ONEDAY)
|
|
|
- redis.Del("enterprise", "enterpriseInfo_"+id)
|
|
|
- }
|
|
|
- }, func(e interface{}) {
|
|
|
- log.Println("过滤企业名出错:", e)
|
|
|
- })
|
|
|
- }()
|
|
|
+ processRelation(nodes, relation, regNo, id)
|
|
|
}
|
|
|
if editFlag > 0 {
|
|
|
return yp.Render("/enterprise/detail.html", &yp.T)
|
|
@@ -569,6 +560,20 @@ func checkAuth(obj map[string]interface{}) (b bool, err string) {
|
|
|
}
|
|
|
return true, ""
|
|
|
}
|
|
|
+func processRelation(nodes *[]map[string]interface{}, relation map[string]interface{}, regNo, id string) {
|
|
|
+ go func() {
|
|
|
+ util.Try(func() {
|
|
|
+ if filterEntName(nodes) > 0 {
|
|
|
+ relation["nodes"] = nodes
|
|
|
+ redis.Put("enterprise", "relation-"+regNo, relation, 7*ONEDAY)
|
|
|
+ redis.Del("enterprise", "enterpriseInfo_"+id)
|
|
|
+ }
|
|
|
+ }, func(e interface{}) {
|
|
|
+ log.Println("过滤企业名出错:", e)
|
|
|
+ })
|
|
|
+ }()
|
|
|
+}
|
|
|
+
|
|
|
func filterEntName(nodes *[]map[string]interface{}) int {
|
|
|
if len(provinces) == 0 {
|
|
|
util.ReadConfig("./province.json", &provinces)
|
|
@@ -691,3 +696,45 @@ func filterRegion(text string) string {
|
|
|
}
|
|
|
return text
|
|
|
}
|
|
|
+
|
|
|
+//根据注册证号展示关系网
|
|
|
+func (yp *Yellowpage) ShowRelationByRegNo(regNo string) error {
|
|
|
+ defer util.Catch()
|
|
|
+ data := tag.Ad("relation-limit", 1)
|
|
|
+ if strings.TrimSpace(regNo) == "" || data == nil || len(data) == 0 || len(data[0]) == 0 || data[0]["o_extend"] == nil {
|
|
|
+ log.Println("关系网接口没有开放!")
|
|
|
+ return yp.Render("/_error.html")
|
|
|
+ }
|
|
|
+ extend := data[0]["o_extend"].(map[string]interface{})
|
|
|
+ if util.ObjToString(extend["flag"]) != "true" {
|
|
|
+ log.Println("关系网接口没有开放!")
|
|
|
+ return yp.Render("/_error.html")
|
|
|
+ }
|
|
|
+ res := mongodbutil.FindOneByField("enterprise", cf.SysConfig.EntMongodbAlias, cf.SysConfig.EntMongodbName, `{"RegNo":"`+regNo+`"}`, `{"EntName":1,"LegCerNO":1,"RegCapCurName":1}`)
|
|
|
+ var flag = -1
|
|
|
+ if res != nil && len(*res) > 0 {
|
|
|
+ id := util.BsonIdToSId((*res)["_id"])
|
|
|
+ entName, _ := (*res)["EntName"].(string)
|
|
|
+ datas, ok := getRelation(regNo, entName)
|
|
|
+ var nodes *[]map[string]interface{}
|
|
|
+ if ok {
|
|
|
+ d, err := json.Marshal(datas["nodes"])
|
|
|
+ if err != nil || json.Unmarshal(d, &nodes) != nil {
|
|
|
+ flag = -2
|
|
|
+ }
|
|
|
+ if ok {
|
|
|
+ flag = 1
|
|
|
+ processRelation(nodes, datas, regNo, id)
|
|
|
+ }
|
|
|
+ }
|
|
|
+ yp.T["RegNo"] = regNo
|
|
|
+ yp.T["EntName"] = entName
|
|
|
+ yp.T["LegCerNO"] = (*res)["LegCerNO"]
|
|
|
+ yp.T["RegCapCurName"] = (*res)["RegCapCurName"]
|
|
|
+ yp.T["relation"] = datas
|
|
|
+ } else {
|
|
|
+ flag = -3
|
|
|
+ }
|
|
|
+ yp.T["relFlag"] = flag
|
|
|
+ return yp.Render("/enterprise/relation.html")
|
|
|
+}
|