application/api/internal/service/network_test.go

package service

import (
	"log"
	"testing"

	"app.yhyue.com/moapp/jybase/es"
	"app.yhyue.com/moapp/jybase/mysql"
	. "bp.jydev.jianyu360.cn/CRM/application/api/common"
	"bp.jydev.jianyu360.cn/CRM/application/api/internal/config"
	"bp.jydev.jianyu360.cn/CRM/application/api/internal/types"
)

func initDb() {
	CrmMysql = &mysql.Mysql{
		Address:      "192.168.3.14:4000",
		UserName:     "root",
		PassWord:     "=PDT49#80Z!RVv52_z",
		DBName:       "crm",
		MaxOpenConns: 5,
		MaxIdleConns: 5,
	}
	CrmMysql.Init()
	ConnectClickhouse(&config.CHouseConfig{
		Addr:         "192.168.3.207:19000",
		UserName:     "jytop",
		Password:     "pwdTopJy123",
		DbName:       "jianyu",
		MaxIdleConns: 2,
		MaxOpenConns: 2,
	})
	es.NewEs("v7", "http://192.168.3.149:9200", 5, "", "")
}
func TestAddOrUpdate(t *testing.T) {
	initDb()
	//类型；firstparty：甲方 supplier：供应商 adiffb：同甲异业 middleman：中间人 agency：招标代理机构
	for _, v := range []string{"firstparty", "supplier", "adiffb", "middleman", "agency"} {
		text := ""
		switch v {
		case "firstparty":
			text = "甲方"
		case "supplier":
			text = "供应商"
		case "adiffb":
			text = "同甲异业"
		case "middleman":
			text = "中间人"
		case "agency":
			text = "招标代理机构"
		}
		text += "_2"
		res := Network.AddOrUpdate(&types.AddOrUpdateReq{
			PositionId:             943,
			Company_id:             "112233445566",
			Company_name:           "王传进的" + text,
			Contact_person:         "王传进",
			Contact_phone:          "15037870765",
			Introduce_owner_id:     "11,22,33",
			Introduce_owner_name:   "aa,bb,cc",
			Introduce_project_id:   "44,55,66",
			Introduce_project_name: "dd,ee,ff",
			Type:                   "middleman",
		})
		log.Println(res)
	}
}

func TestAssociate(t *testing.T) {
	initDb()
	//log.Println(NetworkCom.GetEntTagSeat(2))
	//类型；firstparty：甲方 supplier：供应商 adiffb：同甲异业 middleman：中间人 middleman_owner：中间人-业主 middleman_project：中间人-项目 agency：招标代理机构
	res := Network.Associate(&types.AssociateReq{
		Name: "郑州",
		Type: "firstparty",
	})
	log.Println(res.Data)
}

func TestNetWorkList(t *testing.T) {
	initDb()
	//类型；firstparty：甲方 supplier：供应商 adiffb：同甲异业 middleman：中间人 agency：招标代理机构
	res := Network.List(&types.NetWorkListReq{
		PositionId: 943,
		Name:       "王传进",
	})
	log.Println(res.Data.(map[string]interface{})["total_page"])
	for _, v := range res.Data.(map[string]interface{})["list"].([]map[string]interface{}) {
		log.Println(v)
	}
}