完成bom上报

zhangzengfei

2023-08-17 d9bc2c9e991b2fe925565dfd7d0ec667b64bb52f

完成bom上报

 config/config.go

@@ -19,7 +19,6 @@
    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
@@ -43,7 +42,6 @@
    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"

 report/send.go

@@ -211,48 +211,4 @@

        logger.Debug("已上报%d条BOM数据", successCnt)
    }
    //
    //// 上报bom子项
    //
    //// 如果请求全量数据, 直接查询所有的数据并发送. 增量上报, 先判断bom是否有更新,然后按bom编码查询子项
    //if fData {
    //    bomChildList = kingdee.BomChild(nil)
    //} else {
    //    if len(bomList) <= 0 {
    //        return
    //    }
    //
    //    var bomIds []string
    //    for _, v := range bomList {
    //        bomIds = append(bomIds, v.FBOMNumber)
    //    }
    //
    //    bomChildList = kingdee.BomChild(bomIds)
    //}
    //
    //logger.Debug("查询到%d条BOM子项数据", len(bomList))
    //
    //if len(bomChildList) == 0 {
    //    logger.Debug("没有要更新的BOM子项数据.")
    //    return
    //}
    //
    //// 每次发 1000 条
    //successCnt := 0
    //for i := 0; i < len(bomChildList); i += 1000 {
    //    end := i + 1000
    //    if end > len(bomChildList) {
    //        end = len(bomChildList)
    //    }
    //
    //    b, _ := json.Marshal(bomChildList[i:end])
    //
    //    ok := nsqclient.Produce(config.Options.BomChildTopic, b)
    //    if !ok {
    //        logger.Warn("BOM数据上报失败")
    //    } else {
    //        successCnt = end
    //    }
    //}
    //logger.Debug("已上报%d条BOM子项数据", successCnt)
}