fix:mgo初始化&招标类信息发布后留资信息添加

entity/db.go

@@ -10,6 +10,14 @@ type MysqlMainStruct struct {
 	MaxIdleConns int    `json:"maxIdleConns"`
 }
 
+//mgo
+type Mgo struct {
+	DbName  string `json:"dbName"`
+	Address string `json:"address"`
+	Size    int    `json:"size"`
+	ReplSet string `json:"replSet"`
+}
+
 //nsq消息队列
 type NsqStruct struct {
 	Ip    string `json:"ip"`

rpc/common/etc/common.yaml

@@ -12,6 +12,11 @@ MysqlMain:
   passWord: Topnet123
   maxOpenConns: 5
   maxIdleConns: 5
+Mgo:
+  "address": "192.168.3.206:27080",
+  "size": 5,
+  "dbName": "qfw",
+  "replSet": ""
 Redis:
   Host: 192.168.3.206
   addr: 192.168.3.206:1712

rpc/common/init/init.go

@@ -36,6 +36,10 @@ func init() {
 	//初始化nsq
 	nsq := C.Nsq
 	model.InitNsqConfig(&nsq)
+
+	//初始mgo
+	mgo := C.Mgo
+	model.InitMgoConfig(&mgo)
 	//定时任务
 	//tk := C.Task
 	////日志清除

rpc/common/internal/config/config.go

@@ -22,4 +22,5 @@ type Config struct {
 	Es        entity.EsStruct
 	Sensitive entity.Sensitive
 	Nsq       entity.NsqStruct
+	Mgo       entity.Mgo
 }

rpc/common/internal/logic/statemethodlogic.go

@@ -62,6 +62,25 @@ func (l *StateMethodLogic) StateMethod(in *commoninfo.StateRequest) (*commoninfo
 		log.Println("nsq回调发布状态,更新信息状态失败", query, upData)
 		resp.ErrCode = -1
 		resp.ErrMsg = "nsq回调发布状态,更新信息状态失败"
+	} else {
+		//信息审核通过后 留资信息
+		go PublishSales(in.PublishId, *data)
 	}
 	return &resp, nil
 }
+
+//PublishSales 信息审核通过后 留资信息
+func PublishSales(id string, data map[string]interface{}) {
+	//选择了“我需要”，则信息审核通过后，生成1条留资信息
+	if mc.IntAll(data["recommended_service"]) == 1 {
+		_d := map[string]interface{}{
+			"userid":     data["user_id"],
+			"source":     "info_supplier_recom",
+			"company":    data["ent_name"],
+			"name":       data["contact_person"],
+			"phone":      data["contact_phone"],
+			"publish_id": id,
+		}
+		model.Mgo.Save("saleLeads", _d)
+	}
+}

rpc/model/db.go

@@ -4,6 +4,7 @@
 package model
 
 import (
+	"app.yhyue.com/moapp/jybase/mongodb"
 	"fmt"
 	"log"
 
@@ -19,6 +20,7 @@ var (
 	NsqConfig   *entity.NsqStruct
 	SupplyTotal int
 	Sensitive   *entity.Sensitive
+	Mgo         *mongodb.MongodbSim
 	PublishCity *map[string]string
 )
 
@@ -40,6 +42,21 @@ func InitNsqConfig(mm *entity.NsqStruct) {
 		}
 	}
 }
+
+func InitMgoConfig(mm *entity.Mgo) {
+	if mm.Address != "" {
+		log.Println("--初始化 nsq--")
+		log.Println("初始化 mongodb main")
+		Mgo = &mongodb.MongodbSim{
+			MongodbAddr: mm.Address,
+			Size:        mm.Size,
+			DbName:      mm.DbName,
+			ReplSet:     mm.ReplSet,
+		}
+		Mgo.InitPool()
+	}
+}
+
 func InitMysql(mm *entity.MysqlMainStruct) {
 	//初始化 mysql
 	if mm.Address != "" {