修改车间代码的查询方式，返回正确的车间代码

zhangzengfei

2023-07-13 89ce2bc6b71ea331c219c295074a289d09c808af

 config/config.go

@@ -15,10 +15,16 @@
   SqlUsername    string `json:"sql_username"`    // 数据库用户
   SqlPassword    string `json:"sql_password"`    // 数据库密码
   NsqServer      string `json:"nsq_server"`      // nsq TCP服务端地址
   NsqWebApi      string `json:"nsq_server"`      // nsq HTTP接口地址
   NsqWebApi      string `json:"nsq_webapi"`      // nsq HTTP接口地址
   OrderTopic     string `json:"order_topic"`     // 订单上报的topic
   InventoryTopic string `json:"inventory_topic"` // 库存上报的topic
   SqlQueryTopic  string `json:"query_topic"`     // 金蝶查询接口的topic
   SqlReplyTopic  string `json:"reply_topic"`     // 金蝶响应查询接口的topic
   CSTWebApi      string `json:"cst_webapi"`      // 生产任务单提交地址
   CSTQueryTopic  string `json:"cst_query_topic"` // 提交生产任务单主题
   CSTReplyTopic  string `json:"cst_reply_topic"` // 响应生产任务单主题
   SyncInterval   int    `json:"interval"`        // 同步的时间间隔, 单位/秒
   Debug          bool   `json:"debug"`           // 本地调试, 取本地数据
}

const configPath = "config.json"
@@ -33,9 +39,14 @@
   Options.SqlPassword = "123456"
   Options.NsqServer = "fai365.com:4150"
   Options.NsqWebApi = "http://121.31.232.83:9080/api/nsq/pub?topic=your_topic"
   Options.OrderTopic = "/province/city/factoryNo/kingdee_seOrder"
   Options.InventoryTopic = "/province/city/factoryNo/kingdee_inventory"
   Options.OrderTopic = "aps.factory.erp.seorder"
   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() {
@@ -49,8 +60,6 @@
      fd := json.NewDecoder(file)

      fd.Decode(&Options)

      fmt.Printf("%v\n", Options)
   }
}