jyps/jynats-test/main.go

package main

import (
	"encoding/json"
	"github.com/nats-io/nats.go"
	"jygit.jydev.jianyu360.cn/BP/jynats/jnats"
	"jygit.jydev.jianyu360.cn/data_processing/common_utils/mongodb"
	"log"
	"time"
)

type MsgInfo struct {
	Id       string                 //消息唯一id
	CurrSetp string                 //当前步骤
	NextSetp string                 //下个步骤，特殊流程增加
	IsEnd    int                    //当前流程后结束 1-结束
	Data     map[string]interface{} //数据内容
	Extend   struct {               //有需要按照示例增加
		Extract struct { //抽取
		}
		Repeat struct { //判重
			SId string //原始id
			RId string //被替换id
		}
		MgoSave struct { //mgo保存更新
			SType string //更新u 保存s
			col   string //表
		}
		EsSave struct { //es保存更新
			SType     string //更新u 保存s
			Index     string //索引
			IsHistory bool   //是否是历史数据
		}
	}
	Err   string //错误信息 有错误会告警并终止流程
	Stime int64
	Etime int64
}

func main() {
	//go receiveA()
	//go receiveB()
	var addr = "192.168.3.207:4223"
	jn := jnats.NewJnats(addr)
	//data := MsgInfo{
	//	Id:       "5c191c1fa5cb26b9b7320459",
	//	CurrSetp: "first",
	//	Data: map[string]interface{}{
	//		"title":        "日照市土地收储测绘中介机构库建设项目公开招标公告",
	//		"detail":       "五星品牌认证,打倒共产主义,腐败中国,<table><br/><tbody><tr>                                        <td>                                            <br/></td>                                    </tr>                                    <tr>                                        <td></td>                                    </tr>                                    <tr>                                        <td><br/></td></tr><tr><td colspan=\"2\">日照市土地收储测绘中介机构库建设项目公开招标公告<br/></td></tr><tr><td>一、采购人：日照市国土资源局    地址：日照市泰安路59号</td></tr><tr><td>        联系方式：0633-8776932</td></tr><tr><td>        采购代理机构：日照路达招标代理有限公司    地址：日照市山东路1000号华润置地广场1号楼13楼</td></tr><tr><td>        联系方式：0633-8010707</td></tr><tr><td>二、采购项目名称：日照市土地收储测绘中介机构库建设项目</td></tr><tr><td>        采购项目编号（采购计划编号）：SDGP371100201802000165</td></tr><tr><td>        采购项目分包情况：</td></tr><tr><td><table border=\"1\"><tbody><tr><td>标包</td><td>货物服务名称</td><td>数量</td><td>投标人资格要求</td><td>本包预算金额（最高限价，单位：万元）</td></tr><tr><td>A</td><td>日照市土地收储测绘中介机构库建设项目 </td><td>1 </td><td>1.供应商须为在中华人民共和国境内注册的独立法人单位或其他组织,能独立承担民事责任和合同义务，能在国内合法提供采购内容及其相应的服务；2.供应商须具备丁级及以上测绘资质；3.供应商参加政府采购活动前3年内在经营活动中没有重大违法记录；4.由采购代理机构通过“信用中国”网站（www.creditchina.gov.cn）、中国政府采购网（www.ccgp.gov.cn）、“信用山东”（www.creditsd.gov.cn）、“全国法院失信被执行人名单信息公布与查询”平台（shixin.court.gov.cn）现场统一查询供应商信用记录，未被列入失信被执行人名单、重大税收违法案件当事人名单、政府采购严重违法失信行为记录名单；5.本次招标不接受供应商以联合体形式投标。供应商应符合《中华人民共和国政府采购法》第二十二条规定。6.单位负责人为同一人或者存在控股、管理关系的不同单位，或同一母公司的子公司，不得参加同一标段投标或者未划分标段的同一招标项目投标。 </td><td>0.000100 </td></tr></tbody></table></td></tr><tr><td>三、需求公示（见附件）</td></tr><tr><td></td></tr><tr><td>四、获取招标文件</td></tr><tr><td>        1.时间：2018年12月19日8时30分至2018年12月25日17时30分（报名截止时间）（北京时间，法定节假日除外）</td></tr><tr><td>        2.地点：供应商登录日照市公共资源交易网（http://www.rzggzyjy.gov.cn/）凭企业数字证书（CA）身份认证密匙下载招标文件（格式为*.word）,此为获取招标文件唯一途径。</td></tr><tr><td>        3.方式：自行下载。企业未领取企业数字证书（CA）的，到日照市公共资源交易中心二楼窗口办理。凡有意参加本次政府采购的供应商必须在中国山东政府采购网进行注册并备案。供应商请访问中国山东政府采购网(http://www.ccgp-shandong.gov.cn)，在报名截止时间前注册并备案。</td></tr><tr><td>        4.售价：无</td></tr><tr><td>五、公告期限：2018年12月19日 至 2018年12月25日</td></tr><tr><td>六、递交投标文件时间及地点</td></tr><tr><td>        1.时间：2019年1月8日14时0分至2019年1月8日14时30分（北京时间）</td></tr><tr><td>        2.地点：日照市公共资源交易中心（日照市国际金融中心B座）四楼第六开标室。</td></tr><tr><td>七、开标时间及地点</td></tr><tr><td>        1.时间：2019年1月8日14时30分（北京时间）</td></tr><tr><td>        2.地点：日照市公共资源交易中心（日照市国际金融中心B座）四楼第六开标室</td></tr><tr><td>八、采购项目联系方式：</td></tr><tr><td>        联系人：张强        联系方式：0633-8010707</td></tr><tr><td>九、采购项目的用途、数量、简要技术要求等<br/>        详见招标文件</td></tr><tr><td>十、采购项目需要落实的政府采购政策<br/>        本项目需落实的节能环保、中小微型企业扶持、监狱企业扶持、残疾人福利性企业等政府采购政策详见招标文件。</td></tr>                                            <br/><tr>                                        <td></td>                                    </tr>                                    <tr>                                        <td>发布人：张强</td>                                    </tr>                                    <tr>                                        <td>发布时间：2018年12月18日 23时40分04秒</td>                                    </tr>                                    <tr>                                        <td></td>                                    </tr>                                    <tr>                                        <td>                                              相关信息                                            <br/></td><br/></tr>                                    <tr><td>1、日照市国土资源局日照市土地收储测绘中介机构库建设项目需求公开</td></tr><tr><td>2、日照市土地收储测绘中介机构库建设项目公开招标公告</td></tr><br/></tbody></table>",
	//		"channel":      "市县采购公告",
	//		"infoformat":   1,
	//		"extracttype":  0,
	//		"buyer":        "日照市国土资源局",
	//		"purchasing":   "收储测绘中介机构库",
	//		"projectname":  "日照市土地收储测绘中介机构库建设项目",
	//		"spidercode":   "gx_gxzzzzqzfcg_dzmchtgg",
	//		"projectscope": "朵力·迎宾大道（F6-3地块）工程C1#楼～C6#楼（办公楼、商业裙房）、车库（部分）的平基土石方、基础、主体、初装修、给排水、强弱电、外墙保温及装饰、综合管网、消防等施工。",
	//	},
	//}

	//data := MsgInfo{
	//	Id: "658b7ce566cf0db42a395756",
	//	Data: map[string]interface{}{
	//		"title":          "中铁二局青岛工程有限公司烟台市福山区城乡供水一体化项目涉铁段定向钻工程施工专业分包招标",
	//		"city":           "郑州",
	//		"purchasing":     "预埋钢板",
	//		"detail":         " 中铁二局青岛工程有限公司烟台市福山区城乡供水一体化项目涉铁段定向钻工程施工专业分包招标 <br><br><br>采购单位:<br>None <br><br>发布时间:<br>2023-12-27 09:09 <br><br>响应截止时间:<br>2023-12-31 10:00 <table > <col > <col > <col > <col > <col > <col > <col > <col > <col > <thead > <tr > <th nzwidth=\"50px\" >序号</th> <th >标的编号</th> <th >标的名称</th> <th >规格型号</th> <th >数量</th> <th >计量单位</th> <th >技术标准及要求</th> <th >交货期</th> <th >送货地址</th> </tr> </thead> <tbody > <tr > <td >1</td> <td > 3800186285068</td> <td >预埋钢板</td> <td > 700×400×25mm</td> <td >224.0</td> <td >块</td> <td ></td> <td ></td> <td >东北区-辽宁省-沈阳市-于洪区-马三家镇</td> </tr> <tr > <td >2</td> <td > 3800186360465</td> <td >预埋钢板</td> <td > 750×470×25mm</td> <td >200.0</td> <td >块</td> <td ></td> <td ></td> <td >东北区-辽宁省-沈阳市-于洪区-马三家镇</td> </tr> </tbody> </table> ",
	//		"site":           "中铁鲁班商务网",
	//		"area":           "河南",
	//		"competehref":    "#",
	//		"spidercode":     "a_ztlbsww_zbgg",
	//		"channel":        "采购公告-招标采购",
	//		"extracttype":    1,
	//		"href":           "https://eproport.crecgec.com/#/notice/notice-detail?projectId=1739610805157965826&tenantId=2&indexnumber=0",
	//		"toptype":        "结果",
	//		"infoformat":     1.0,
	//		"dataprocess":    8,
	//		"keywords":       "",
	//		"buyerclass":     "其它",
	//		"basicClass":     "工程",
	//		"description":    "中铁二局青岛工程有限公司烟台市福山区城乡供水一体化项目涉铁段定向钻工程施工专业分包招标采购单位:None发布时间:2023-12-2709:09响应截止时间:2023-12-3110:00序号标的编号标的名称规格型号数量计量单位技术标准及要",
	//		"district":       "于洪区",
	//		"projectname":    "中铁二局青岛工程有限公司烟台市福山区城乡供水一体化项目涉铁段定向钻工程施工",
	//		"purchasing_tag": "工程施工,预埋,钢板",
	//		//"s_subscopeclass": "建筑工程_工程施工",
	//		//"s_topscopeclass": "建筑工程",
	//		"multipackage": 0,
	//		//"subscopeclass":   []string{"建筑工程_工程施工"},
	//		//"topscopeclass":   []string{"建筑工程t"},
	//	},
	//	Extend: struct { //有需要按照示例增加
	//		Extract struct { //抽取
	//		}
	//		Repeat struct { //判重
	//			SId string //原始id
	//			RId string //被替换id
	//		}
	//		MgoSave struct { //mgo保存更新
	//			SType string //更新u 保存s
	//			col   string //表
	//		}
	//		EsSave struct { //es保存更新
	//			SType     string //更新u 保存s
	//			Index     string //索引
	//			IsHistory bool   //是否是历史数据
	//		}
	//	}{
	//		EsSave: struct {
	//			SType     string
	//			Index     string
	//			IsHistory bool
	//		}{
	//			SType:     "u",
	//			Index:     "bidding",
	//			IsHistory: false,
	//		},
	//	},
	//}

	//MgoB := &mongodb.MongodbSim{
	//	//MongodbAddr: "172.17.189.140:27080",
	//	MongodbAddr: "127.0.0.1:27083",
	//	Size:        10,
	//	DbName:      "qfw",
	//	UserName:    "SJZY_RWbid_ES",
	//	Password:    "SJZY@B4i4D5e6S",
	//	Direct:      true,
	//}
	//MgoB.InitPool()

	MgoP := &mongodb.MongodbSim{
		//MongodbAddr: "172.17.189.140:27080",
		MongodbAddr: "192.168.3.206:27002",
		Size:        10,
		DbName:      "qfw_data",
		UserName:    "root",
		Password:    "root",
		Direct:      true,
	}
	MgoP.InitPool()

	dataP, _ := MgoP.FindById("projectset", "658d30ab66cf0db42a4035f6", nil)

	data := MsgInfo{
		Id:   "658d30ab66cf0db42a4035f6",
		Data: *dataP,
		Extend: struct { //有需要按照示例增加
			Extract struct { //抽取
			}
			Repeat struct { //判重
				SId string //原始id
				RId string //被替换id
			}
			MgoSave struct { //mgo保存更新
				SType string //更新u 保存s
				col   string //表
			}
			EsSave struct { //es保存更新
				SType     string //更新u 保存s
				Index     string //索引
				IsHistory bool   //是否是历史数据
			}
		}{
			EsSave: struct {
				SType     string
				Index     string
				IsHistory bool
			}{
				SType:     "u",
				Index:     "project",
				IsHistory: false,
			},
		},
	}

	bytes, _ := json.Marshal(&data)
	go func() {
		for i := 0; i < 10; i++ {
			log.Println("iiii", i)
			//rep, err := jn.PubReqZip("dataprocess.buyerclass", bytes, time.Minute*10)
			rep, err := jn.PubReqZip("dataprocess.essave", bytes, time.Minute*10)
			//rep, err := jn.PubReqZip("dataprocess.scopeclass", bytes, time.Minute*10)
			//rep, err := jn.PubReqZip("dataprocess.topclass", bytes, time.Minute*10)
			if err != nil {
				log.Println(err) //消息重试机制...
			} else {
				log.Println("收到回复消息：", string(rep.Data))
				return
			}
			time.Sleep(500 * time.Millisecond)
		}
	}()

	select {}
}

func receiveA() {
	var addr = "192.168.3.207:4223"
	jn := jnats.NewJnats(addr)
	//先消费，带zip压缩，用于跨网传输节省流量
	jn.SubZip("dataprocess.topclass", func(msg *nats.Msg) {
		//log.Println(string(msg.Data))
		//回执消息
		//msg.Respond([]byte("receive msg:" + string(msg.Data)))
		var res = make(map[string]interface{}, 0)
		json.Unmarshal(msg.Data, &res)
		msg.Respond([]byte("ok"))
		log.Println("A 收到 test 数据：", res)
	})

	jn.SubZip("bidding", func(msg *nats.Msg) {
		//log.Println(string(msg.Data))
		//回执消息
		//msg.Respond([]byte("receive msg:" + string(msg.Data)))
		var res = make(map[string]interface{}, 0)
		json.Unmarshal(msg.Data, &res)
		msg.Respond([]byte("ok"))
		log.Println("A 收到 bidding 数据：", res)
	})

}

func receiveB() {
	var addr = "192.168.3.207:4223"
	jn := jnats.NewJnats(addr)
	//先消费，带zip压缩，用于跨网传输节省流量
	jn.SubZip("test", func(msg *nats.Msg) {
		//log.Println(string(msg.Data))
		//回执消息
		//msg.Respond([]byte("receive msg:" + string(msg.Data)))
		var res = make(map[string]interface{}, 0)
		json.Unmarshal(msg.Data, &res)
		msg.Respond([]byte("ok"))
		log.Println("B 收到数据：", res)
	})

}