package util import ( log "github.com/donnie4w/go-logger/logger" ) const ( V_Bid_Purchasinginfo = "bid_purchasinginfo" V_Bid_Purchasing_Field_Record = "bid_purchasing_field_record" V_Bid_Fieldtags = "bid_fieldtags" V_Bid_Scopetags = "bid_scopetags" V_Code_Bidfield = "code_bidfield" //采用默认code V_Code_Bidscope = "code_bidscope" V_Code_Bidtopsubtype = "code_bidtopsubtype" V_Code_Productclass = "code_productclass" V_Product_Baseinfo = "product_baseinfo" S_Bidding_Coll = "bidding" ) var ( Mgo *MongodbSim TimeLayout = "2006-01-02 15:04:05" TimeTmeplate = "2006-01-02" MysqlMedicalTool, MysqlGlobalTool *Mysql //标讯相关 Bid_TopSubtype = map[string]map[string]string{} Bid_Industry = map[string]map[string]string{} //不同等级~不同名称~对应代码 Medical_Level_Class = map[int]map[string]string{} //标准产品名~对应编号 ProductDocText = map[string]string{} //编号~对应具体分类详细 CodeCatalog = map[string]map[string]string{} IsLocal bool ) func InitClass() { initMgo() initMysql() initVCode() } //初始化mgo func initMgo() { if IsLocal { Mgo = &MongodbSim{ MongodbAddr: "192.168.3.207:27001", DbName: "qfw_data", Size: 10, UserName: "root", Password: "root", } Mgo.InitPool() Mgo = &MongodbSim{ MongodbAddr: "127.0.0.1:27017", DbName: "zhengkun", Size: 10, UserName: "", Password: "", } Mgo.InitPool() } else { Mgo = &MongodbSim{ MongodbAddr: "172.17.145.163:27083,172.17.4.187:27082", DbName: "qfw", Size: 10, UserName: "zhengkun", Password: "zk@123123", } Mgo.InitPool() } } func initMysql() { username, password := "root", "=PDT49#80Z!RVv52_z" address := "192.168.3.217:4000" if !IsLocal { username = "zhengkun" password = "Zk#20220824" address = "172.17.4.242:4000" } MysqlMedicalTool = &Mysql{ Address: address, UserName: username, PassWord: password, DBName: "medical_field_data", } MysqlMedicalTool.Init() MysqlGlobalTool = &Mysql{ Address: address, UserName: username, PassWord: password, DBName: "global_common_data", } MysqlGlobalTool.Init() } //加载代码表~ func initVCode() { initBidInfoClass() //招标信息分类 initBidIndustryClass() //行业分类 GSE.LoadDict("./dictionary.txt") initMedicalLevelClass() //标准分类表 initMedicalProduct() //分类产品 } //插入数据 func InsertMedicalMysqlData(name string, data map[string]interface{}, mark string) int64 { inb := MysqlMedicalTool.Insert(name, data) if inb == -1 { log.Debug("插入数据异常...", name, "~", mark) } return inb } func InsertGlobalMysqlData(name string, data map[string]interface{}, mark string) int64 { inb := MysqlGlobalTool.Insert(name, data) if inb == -1 { log.Debug("插入数据异常...", name, "~", mark) } return inb }