|
@@ -1,26 +1,32 @@
|
|
|
package followent
|
|
|
|
|
|
import (
|
|
|
+ "config"
|
|
|
"fmt"
|
|
|
"log"
|
|
|
"qfw/util"
|
|
|
+ "qfw/util/elastic"
|
|
|
"qfw/util/redis"
|
|
|
+ "strconv"
|
|
|
+ "time"
|
|
|
"tools"
|
|
|
+
|
|
|
"github.com/go-xweb/xweb"
|
|
|
- "qfw/util/elastic"
|
|
|
- "config"
|
|
|
- "strconv"
|
|
|
)
|
|
|
|
|
|
var mongodb = tools.MQFW
|
|
|
|
|
|
type FollowEnt struct {
|
|
|
*xweb.Action
|
|
|
- entList xweb.Mapper `xweb:"/jylab/followent/entList"` //获取关注企业列表
|
|
|
- addEnt xweb.Mapper `xweb:"/jylab/followent/addEnt"` //添加关注企业页面
|
|
|
- newInfo xweb.Mapper `xweb:"/jylab/followent/newInfo/(.*)/(.*)"` //企业最新信息
|
|
|
- recList xweb.Mapper `xweb:"/jylab/followent/recList"` //获取推荐企业列表
|
|
|
- saveEnt xweb.Mapper `xweb:"/jylab/followent/saveEnt"` //保存关注企业
|
|
|
+
|
|
|
+ entList xweb.Mapper `xweb:"/jylab/followent/entList"` //获取关注企业列表
|
|
|
+ addEnt xweb.Mapper `xweb:"/jylab/followent/addEnt"` //添加关注企业页面
|
|
|
+ newInfo xweb.Mapper `xweb:"/jylab/followent/newInfo/(.*)/(.*)"` //企业最新信息
|
|
|
+ recList xweb.Mapper `xweb:"/jylab/followent/recList"` //获取推荐企业列表
|
|
|
+ saveEnt xweb.Mapper `xweb:"/jylab/followent/saveEnt"` //保存关注企业
|
|
|
+ followYorN xweb.Mapper `xweb:"/jylab/followent/followYorN"` //查询用户是否关注企业
|
|
|
+ qgFollow xweb.Mapper `xweb:"/jylab/followent/qgFollow"` //取消关注
|
|
|
+
|
|
|
}
|
|
|
|
|
|
func init() {
|
|
@@ -41,9 +47,9 @@ func (f *FollowEnt) EntList() error {
|
|
|
datas, ok := mongodb.Find("jylab_followent", `{"s_userid":"`+f.GetSession("userId").(string)+`"}`, `{"l_createtime":-1}`, `{"_id":1,"winner":1,"s_userid":1,"s_openid":1,"l_createtime":1,"s_id":1}`, false, 0, 10)
|
|
|
f.T["flag"] = false
|
|
|
if ok && datas != nil && len(*datas) > 0 {
|
|
|
- for k, v := range *datas {
|
|
|
+ for _, v := range *datas {
|
|
|
v["_id"] = util.EncodeArticleId2ByCheck(util.BsonIdToSId(v["_id"]))
|
|
|
- log.Println(k, ":", v["l_createtime"])
|
|
|
+ v["s_id"] = util.EncodeArticleId2ByCheck(util.BsonIdToSId(v["s_id"]))
|
|
|
}
|
|
|
f.T["datas"] = datas
|
|
|
}
|
|
@@ -57,12 +63,12 @@ func (f *FollowEnt) AddEnt() error {
|
|
|
func (f *FollowEnt) RecList() {
|
|
|
fmt.Println("entName", f.GetString("entName"))
|
|
|
var entName = f.GetString("entName")
|
|
|
- if entName!=""{
|
|
|
- limit,_ := strconv.Atoi(config.Sysconfig["recommendEntLimit"].(string))
|
|
|
+ if entName != "" {
|
|
|
+ limit, _ := strconv.Atoi(config.Sysconfig["recommendEntLimit"].(string))
|
|
|
r := elastic.GetPage("winner", "winner", `{"winner":"`+entName+`"}`, ``, `"_id","winner"`, 0, limit)
|
|
|
- if r!=nil && len(*r) != 0{
|
|
|
- fmt.Println("RecList",r)
|
|
|
- for _,v := range *r{
|
|
|
+ if r != nil && len(*r) != 0 {
|
|
|
+ fmt.Println("RecList", r)
|
|
|
+ for _, v := range *r {
|
|
|
v["_id"] = util.EncodeArticleId2ByCheck(v["_id"].(string))
|
|
|
}
|
|
|
f.ServeJson(map[string]interface{}{
|
|
@@ -81,22 +87,70 @@ func (f *FollowEnt) SaveEnt() {
|
|
|
}
|
|
|
|
|
|
//企业最新信息
|
|
|
-func (f *FollowEnt) NewInfo(winner,id string) error {
|
|
|
+func (f *FollowEnt) NewInfo(winner, id string) error {
|
|
|
defer util.Catch()
|
|
|
- ////var winner = "天津超林时代科技发展有限公司"
|
|
|
- fields := `{"projectname":1,"projectcode":1,"bidamount":1,"title":1,"publishtime":1,"subtype":1}`
|
|
|
+ id = util.EncodeArticleId2ByCheck(id)
|
|
|
+ fmt.Println(id)
|
|
|
+ fields := `{"projectname":1,"projectcode":1,"bidamount":1,"title":1,"publishtime":1,"subtype":1,"href":1}`
|
|
|
data, ok := mongodb.Find("bidding", `{"winner":"`+winner+`"}`, nil, fields, false, -1, -1)
|
|
|
- if !ok || data == nil || len(*data) == 0 {
|
|
|
- return f.Render("_error.html")
|
|
|
- }
|
|
|
+ //if !ok || data == nil || len(*data) == 0 {
|
|
|
+ // return f.Render("_error.html")
|
|
|
+ //}
|
|
|
if ok && data != nil && *data != nil && len(*data) != 0 {
|
|
|
f.T["data"] = data
|
|
|
- fmt.Println(f.T["data"])
|
|
|
}
|
|
|
f.T["winner"] = winner
|
|
|
+ f.T["id"] = id
|
|
|
return f.Render("/weixin/set.html", &f.T)
|
|
|
}
|
|
|
|
|
|
+//用户是否已关注企业判断
|
|
|
+func (f *FollowEnt) FollowYorN() error {
|
|
|
+ defer util.Catch()
|
|
|
+ s_id := ""
|
|
|
+ userId := f.GetSession("userId").(string)
|
|
|
+ id := f.GetString("id")
|
|
|
+ winner := f.GetString("winner")
|
|
|
+ fmt.Println("===========", userId, id, winner)
|
|
|
+ if id == "" {
|
|
|
+ s_id = createId(winner)
|
|
|
+ fmt.Println("空")
|
|
|
+ } else {
|
|
|
+ fmt.Println("不为空")
|
|
|
+ s_id = util.DecodeArticleId2ByCheck(f.GetString("id"))[0]
|
|
|
+ fmt.Println("1111111111", s_id)
|
|
|
+ }
|
|
|
+ var follow = "n"
|
|
|
+ if mongodb.Count("jylab_followent", `{"s_userid":"`+userId+`","s_id":"`+s_id+`"}`) > 0 {
|
|
|
+ follow = "y" //已经关注此企业
|
|
|
+ fmt.Println("已关注")
|
|
|
+ }
|
|
|
+ f.ServeJson(map[string]interface{}{
|
|
|
+ "follow": follow,
|
|
|
+ "s_id": util.EncodeArticleId2ByCheck(s_id),
|
|
|
+ })
|
|
|
+ return nil
|
|
|
+}
|
|
|
+
|
|
|
+//取消企业关注
|
|
|
+func (f *FollowEnt) QgFollow() error {
|
|
|
+ defer util.Catch()
|
|
|
+ status := "n"
|
|
|
+ userId := f.GetSession("userId").(string)
|
|
|
+ id := f.GetString("id")
|
|
|
+ fmt.Println("取关时id=======", id)
|
|
|
+ s_id := util.DecodeArticleId2ByCheck(id)[0]
|
|
|
+ fmt.Println("解密后的id=======", s_id)
|
|
|
+ ok := mongodb.Del("jylab_followent", `{"s_userid":"`+userId+`","s_id":"`+s_id+`"}`)
|
|
|
+ if ok {
|
|
|
+ status = "y"
|
|
|
+ }
|
|
|
+ f.ServeJson(map[string]interface{}{
|
|
|
+ "status": status,
|
|
|
+ })
|
|
|
+ return nil
|
|
|
+}
|
|
|
+
|
|
|
//
|
|
|
func (f *FollowEnt) Followent() error {
|
|
|
//data := mongodb.FindById("user", "597ec30861fd00271cff7154", nil)
|
|
@@ -105,3 +159,23 @@ func (f *FollowEnt) Followent() error {
|
|
|
log.Println("data:", redis.Get("sso", "followent"))
|
|
|
return f.Render("/weixin/index.html")
|
|
|
}
|
|
|
+
|
|
|
+//没有企业id创建企业id
|
|
|
+func createId(winner string) string {
|
|
|
+ defer util.Catch()
|
|
|
+ tem, ok := mongodb.FindOneByField("winner", `{"winner":"`+winner+`"}`, `{"_id":1}`)
|
|
|
+ winnerid := ""
|
|
|
+ if ok && len(*tem) == 0 {
|
|
|
+ data := map[string]interface{}{}
|
|
|
+ data["winner"] = winner
|
|
|
+ data["winnersign"] = 1
|
|
|
+ data["l_createtime"] = time.Now().Unix()
|
|
|
+ winnerid = mongodb.Save("winner", data)
|
|
|
+ data["_id"] = winnerid
|
|
|
+ flag := elastic.Save("winner", "winner", data)
|
|
|
+ if !flag {
|
|
|
+ log.Println("企业保存elastic出错!")
|
|
|
+ }
|
|
|
+ }
|
|
|
+ return winnerid
|
|
|
+}
|