From d9bc2c9e991b2fe925565dfd7d0ec667b64bb52f Mon Sep 17 00:00:00 2001
From: zhangzengfei <zhangzengfei@smartai.com>
Date: 星期四, 17 八月 2023 16:01:02 +0800
Subject: [PATCH] 完成bom上报
---
config/config.go | 2 --
report/send.go | 44 --------------------------------------------
2 files changed, 0 insertions(+), 46 deletions(-)
diff --git a/config/config.go b/config/config.go
index 152b20a..ed0f042 100644
--- a/config/config.go
+++ b/config/config.go
@@ -19,7 +19,6 @@
OrderTopic string `json:"order_topic"` // 璁㈠崟涓婃姤鐨則opic
BomTopic string `json:"bom_topic"` // bom涓婃姤鐨則opic
BomQueryTopic string `json:"bom_query_topic"` // bom涓婃姤鐨則opic
- BomChildTopic string `json:"bom_child_topic"` // bom瀛愰」涓婃姤鐨則opic
InventoryTopic string `json:"inventory_topic"` // 搴撳瓨涓婃姤鐨則opic
SqlQueryTopic string `json:"query_topic"` // 閲戣澏鏌ヨ鎺ュ彛鐨則opic
SqlReplyTopic string `json:"reply_topic"` // 閲戣澏鍝嶅簲鏌ヨ鎺ュ彛鐨則opic
@@ -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"
diff --git a/report/send.go b/report/send.go
index 9068701..aadd06b 100644
--- a/report/send.go
+++ b/report/send.go
@@ -211,48 +211,4 @@
logger.Debug("宸蹭笂鎶�%d鏉OM鏁版嵁", successCnt)
}
- //
- //// 涓婃姤bom瀛愰」
- //
- //// 濡傛灉璇锋眰鍏ㄩ噺鏁版嵁, 鐩存帴鏌ヨ鎵�鏈夌殑鏁版嵁骞跺彂閫�. 澧為噺涓婃姤, 鍏堝垽鏂璪om鏄惁鏈夋洿鏂�,鐒跺悗鎸塨om缂栫爜鏌ヨ瀛愰」
- //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鏉OM瀛愰」鏁版嵁", 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鏉OM瀛愰」鏁版嵁", successCnt)
}
--
Gitblit v1.8.0