hotime/example/app/analyse.go

326 lines
8.8 KiB
Go
Raw Normal View History

2022-01-22 08:12:02 +00:00
package app
import (
. "../../../hotime"
2022-01-22 21:13:19 +00:00
. "../../common"
"time"
2022-01-22 08:12:02 +00:00
)
var analyseCtr = Ctr{
2022-01-22 21:13:19 +00:00
2022-01-22 08:12:02 +00:00
"home_data": func(this *Context) {
orgId := ObjToInt(this.Req.FormValue("org_id"))
if orgId == 0 {
this.Display(3, "参数错误")
return
}
2022-02-19 13:38:17 +00:00
res := this.Db.Get("org_analyse", "*", Map{"org_id": orgId})
2022-01-22 08:12:02 +00:00
if res == nil {
this.Display(4, "找不到该数据")
return
}
res["home_data"] = res.GetMap("home_data")
2022-02-19 13:38:17 +00:00
res["six_item_data"] = res.GetMap("six_item_data")
res["three_item_data"] = res.GetMap("three_item_data")
res["n_item_data"] = res.GetMap("n_item_data")
2022-02-16 20:10:53 +00:00
this.Display(0, res)
},
"home1_data": func(this *Context) {
orgId := ObjToInt(this.Req.FormValue("org_id"))
if orgId == 0 {
this.Display(3, "参数错误")
return
}
res := this.Db.Get("org_analyse", "*", Map{"org_id": orgId})
if res == nil {
this.Display(4, "找不到该数据")
return
}
res["home1_data"] = res.GetMap("home1_data")
2022-01-22 08:12:02 +00:00
res["six_item_data"] = res.GetMap("six_item_data")
res["three_item_data"] = res.GetMap("three_item_data")
res["n_item_data"] = res.GetMap("n_item_data")
this.Display(0, res)
},
2022-01-26 03:45:17 +00:00
2022-01-22 08:12:02 +00:00
"ctg": func(this *Context) {
orgId := ObjToInt(this.Req.FormValue("org_id"))
ctgID := ObjToInt(this.Req.FormValue("ctg_id"))
if orgId == 0 || ctgID == 0 {
this.Display(3, "参数错误")
return
}
res := this.Db.Get("category_analyse", "*", Map{"AND": Map{"org_id": orgId, "category_id": ctgID}})
if res == nil {
this.Display(4, "找不到该数据")
return
}
res["data"] = res.GetMap("data")
res1 := this.Db.Get("org_analyse", "home_data", Map{"org_id": orgId})
res["home"] = res1.GetMap("home_data")
this.Display(0, res)
},
2022-01-26 03:45:17 +00:00
"industrys": func(this *Context) {
orgId := ObjToInt(this.Req.FormValue("org_id"))
if orgId == 0 {
this.Display(3, "参数错误")
return
}
res := this.Db.Select("industry_analyse", "industry_id,name", Map{"org_id": orgId})
if res == nil {
this.Display(4, "找不到该数据")
return
}
this.Display(0, res)
},
"industry": func(this *Context) {
orgId := ObjToInt(this.Req.FormValue("org_id"))
industryId := ObjToInt(this.Req.FormValue("industry_id"))
if orgId == 0 || industryId == 0 {
this.Display(3, "参数错误")
return
}
res := this.Db.Get("industry_analyse", "*", Map{"AND": Map{"org_id": orgId, "industry_id": industryId}})
if res == nil {
this.Display(4, "找不到该数据")
return
}
res["data"] = res.GetMap("data")
res1 := this.Db.Get("org_analyse", "name,home_data", Map{"org_id": orgId})
res["home"] = res1.GetMap("home_data")
res["home_name"] = res1.GetString("name")
this.Display(0, res)
},
2022-01-22 08:12:02 +00:00
"map": func(this *Context) {
2022-01-26 03:45:17 +00:00
orgId := ObjToInt(this.Req.FormValue("org_id"))
industryId := ObjToInt(this.Req.FormValue("industry_id"))
//if orgId == 0 || industryId == 0 {
// this.Display(3, "参数错误")
// return
//}
2022-01-22 08:12:02 +00:00
page := ObjToInt(this.Req.FormValue("page"))
pageSize := ObjToInt(this.Req.FormValue("pageSize"))
search := this.Req.FormValue("search")
where := Map{}
levelStr := this.Req.FormValue("level")
if levelStr != "" {
where["level"] = ObjToInt(levelStr)
}
2022-01-26 03:45:17 +00:00
if orgId != 0 {
where["org_id"] = orgId
}
if industryId != 0 {
where["industry_id"] = industryId
}
2022-01-22 08:12:02 +00:00
if search != "" {
where["name[~]"] = search
}
if len(where) > 1 {
where = Map{"AND": where}
}
if page == 0 {
page = 1
}
if pageSize == 0 {
pageSize = 10
}
count := this.Db.Count("company", where)
2022-02-14 11:10:58 +00:00
companys := this.Db.Page(page, pageSize).PageSelect("company", Map{"[><]industry": "company.industry_id=industry.id"},
"company.id,company.collect_data,company.name,company.level,company.address,company.score,company.lat,company.lng,company.category_id,industry.name AS industry_name,company.industry_id",
2022-01-22 08:12:02 +00:00
where)
2022-02-14 11:10:58 +00:00
for _, res := range companys {
res["collect_data"] = res.GetMap("collect_data")
2022-02-19 13:38:17 +00:00
//if res.GetMap("collect_data") == nil {
// path := "company/" + Md5(res.GetString("name")) + time.Now().Format("/200601021504.json")
//
// data := getCompany(res.GetString("name"), this.Config.GetString("tpt")+"/"+path)
//
// if len(data) != 0 {
// data["path"] = path
// re := this.Db.Update("company", Map{"collect_data": data.ToJsonString(),
// "address": data.GetString("companyAddress"),
// "sn": data.GetString("creditNo"),
// "unit": data.GetString("authority"),
// }, Map{"id": res.GetCeilInt("id")})
// fmt.Println(re)
// res["collect_data"] = data
// res["address"] = data.GetString("companyAddress")
// res["sn"] = data.GetString("creditNo")
// res["unit"] = data.GetString("authority")
// }
//}
2022-02-14 11:10:58 +00:00
}
this.Display(0, Map{"count": count, "pageSize": pageSize, "data": companys})
2022-01-22 08:12:02 +00:00
},
"updateCompany": func(this *Context) {
lng := ObjToFloat64(this.Req.FormValue("lng"))
lat := ObjToFloat64(this.Req.FormValue("lat"))
id := ObjToInt(this.Req.FormValue("id"))
if lng == 0 || lat == 0 || id == 0 {
this.Display(3, "请求异常")
return
}
re := this.Db.Update("company", Map{"lng": lng, "lat": lat}, Map{"id": id})
if re == 0 {
this.Display(4, "更新失败")
return
}
this.Display(0, "更新成功")
},
2022-01-26 03:45:17 +00:00
2022-01-22 08:12:02 +00:00
"companys": func(this *Context) {
page := ObjToInt(this.Req.FormValue("page"))
pageSize := ObjToInt(this.Req.FormValue("pageSize"))
2022-02-23 22:26:36 +00:00
orgId := ObjToInt(this.Req.FormValue("org_id"))
2022-01-22 08:12:02 +00:00
search := this.Req.FormValue("search")
2022-02-23 22:26:36 +00:00
where := Map{"state": 0}
2022-01-22 08:12:02 +00:00
levelStr := this.Req.FormValue("level")
if levelStr != "" {
where["level"] = ObjToInt(levelStr)
}
2022-02-14 11:10:58 +00:00
industryId := ObjToInt(this.Req.FormValue("industry_id"))
if industryId != 0 {
where["industry_id"] = industryId
}
2022-02-23 22:26:36 +00:00
if orgId != 0 {
where["org_id"] = orgId
}
2022-01-22 08:12:02 +00:00
if search != "" {
where["name[~]"] = search
}
if len(where) > 1 {
where = Map{"AND": where}
}
where["ORDER"] = "score DESC"
if page == 0 {
page = 1
}
if pageSize == 0 {
pageSize = 10
}
count := this.Db.Count("company", where)
2022-02-14 11:10:58 +00:00
companys := this.Db.Page(page, pageSize).PageSelect("company",
"*",
2022-01-22 08:12:02 +00:00
where)
2022-02-14 11:10:58 +00:00
for _, res := range companys {
analyse := res.GetMap("analyse")
if analyse != nil {
for k, v := range analyse {
if ADataType[k] != nil {
analyse[ADataType.GetString(k)] = v
}
}
res["analyse"] = analyse
}
res["upload_data"] = res.GetMap("upload_data")
res["collect_data"] = res.GetMap("collect_data")
res["collect_data"] = res.GetMap("collect_data")
2022-02-23 22:26:36 +00:00
if res.GetMap("collect_data") == nil && page == 1 {
go func(res Map, this *Context) {
path := "company/" + Md5(res.GetString("name")) + time.Now().Format("/200601021504.json")
data := getCompany(res.GetString("name"), this.Config.GetString("tpt")+"/"+path)
if len(data) != 0 {
data["path"] = path
this.Db.Update("company", Map{"collect_data": data.ToJsonString(),
"address": data.GetString("companyAddress"),
"sn": data.GetString("creditNo"),
"unit": data.GetString("authority"),
}, Map{"id": res.GetCeilInt("id")})
res["collect_data"] = data
}
}(res, this)
}
2022-02-14 11:10:58 +00:00
}
this.Display(0, Map{"count": count, "pageSize": pageSize, "data": companys})
2022-01-22 08:12:02 +00:00
},
"company": func(this *Context) {
id := ObjToInt(this.Req.FormValue("id"))
if id == 0 {
this.Display(3, "参数错误")
return
}
res := this.Db.Get("company", "*", Map{"id": id})
if res == nil {
this.Display(4, "找不到该数据")
return
}
analyse := res.GetMap("analyse")
2022-02-16 20:10:53 +00:00
2022-01-22 08:12:02 +00:00
if analyse != nil {
for k, v := range analyse {
if ADataType[k] != nil {
analyse[ADataType.GetString(k)] = v
}
}
res["analyse"] = analyse
}
2022-02-16 20:10:53 +00:00
analyse1 := res.GetMap("analyse1")
if analyse1 != nil {
for k, v := range analyse1 {
if ADataType[k] != nil {
analyse1[ADataType.GetString(k)] = v
}
}
res["analyse1"] = analyse1
}
2022-01-22 08:12:02 +00:00
res["upload_data"] = res.GetMap("upload_data")
res["collect_data"] = res.GetMap("collect_data")
2022-01-22 21:13:19 +00:00
if res.GetMap("collect_data") == nil {
2022-01-26 03:45:17 +00:00
path := "company/" + Md5(res.GetString("name")) + time.Now().Format("/200601021504.json")
2022-01-22 21:13:19 +00:00
data := getCompany(res.GetString("name"), this.Config.GetString("tpt")+"/"+path)
2022-02-14 11:10:58 +00:00
2022-01-22 21:13:19 +00:00
if len(data) != 0 {
data["path"] = path
this.Db.Update("company", Map{"collect_data": data.ToJsonString()}, Map{"id": res.GetCeilInt("id")})
res["collect_data"] = data
}
}
2022-01-22 08:12:02 +00:00
this.Display(0, res)
},
2022-02-16 20:10:53 +00:00
"company_upload": func(this *Context) {
id := ObjToInt(this.Req.FormValue("id"))
if id == 0 {
this.Display(3, "参数错误")
return
}
2022-02-23 22:26:36 +00:00
res := this.Db.Get("company", "upload_data,org_id", Map{"id": id})
2022-02-16 20:10:53 +00:00
if res == nil {
this.Display(4, "找不到该数据")
return
}
uploadData := res.GetMap("upload_data")
2022-02-23 22:26:36 +00:00
tags := this.Db.Select("tag", "name,sn,`unit`,description", Map{"AND": Map{"type": 0, "org_id": res.GetCeilInt("org_id")}})
2022-02-16 20:10:53 +00:00
for _, v := range tags {
v["value"] = uploadData[v.GetString("sn")]
}
this.Display(0, tags)
},
2022-01-22 08:12:02 +00:00
}