| | |
|---|
| | | NsqServer string `json:"nsq_server"` // nsq TCP服务端地址 |
|---|
| | | NsqWebApi string `json:"nsq_webapi"` // nsq HTTP接口地址 |
|---|
| | | OrderTopic string `json:"order_topic"` // 订单上报的topic |
|---|
| | | BomTopic string `json:"bom_topic"` // bom上报的topic |
|---|
| | | BomQueryTopic string `json:"bom_query_topic"` // bom上报的topic |
|---|
| | | BomChildTopic string `json:"bom_child_topic"` // bom子项上报的topic |
|---|
| | | InventoryTopic string `json:"inventory_topic"` // 库存上报的topic |
|---|
| | | SqlQueryTopic string `json:"query_topic"` // 金蝶查询接口的topic |
|---|
| | | SqlReplyTopic string `json:"reply_topic"` // 金蝶响应查询接口的topic |
|---|
| | |
|---|
| | | CSTQueryTopic string `json:"cst_query_topic"` // 提交生产任务单主题 |
|---|
| | | CSTReplyTopic string `json:"cst_reply_topic"` // 响应生产任务单主题 |
|---|
| | | SyncInterval int `json:"interval"` // 同步的时间间隔, 单位/秒 |
|---|
| | | Debug bool `json:"debug"` // 本地调试, 取本地数据 |
|---|
| | | } |
|---|
| | | |
|---|
| | | const configPath = "config.json" |
|---|
| | |
|---|
| | | Options.NsqServer = "fai365.com:4150" |
|---|
| | | Options.NsqWebApi = "http://121.31.232.83:9080/api/nsq/pub?topic=your_topic" |
|---|
| | | Options.OrderTopic = "aps.factory.erp.seorder" |
|---|
| | | Options.BomTopic = "aps.factory.erp.icBom" |
|---|
| | | Options.BomChildTopic = "aps.factory.erp.icBomChild" |
|---|
| | | Options.BomQueryTopic = "aps.factory.erp.icBomQuery" |
|---|
| | | Options.InventoryTopic = "aps.factory.erp.inventory" |
|---|
| | | Options.SqlQueryTopic = "aps.factory.erp.k3resource" |
|---|
| | | Options.SqlReplyTopic = "aps.factory.erp.k3reply" |
|---|
| | | Options.CSTQueryTopic = "aps.factory.erp.cstApply" |
|---|
| | | Options.CSTReplyTopic = "aps.factory.erp.cstReply" |
|---|
| | | Options.SyncInterval = 60 |
|---|
| | | Options.Debug = false |
|---|
| | | } |
|---|
| | | |
|---|
| | | func Load() { |
|---|
