From 851cb98ae2f9d1713a5443274ca14424b118018f Mon Sep 17 00:00:00 2001
From: zhangzengfei <zhangzengfei@smartai.com>
Date: 星期二, 15 八月 2023 12:09:51 +0800
Subject: [PATCH] 修改bom读取数据为空的bug
---
config.json | 12 ++++++------
config/config.go | 1 +
report/send.go | 5 +++++
kingdee/bom.go | 36 ++++++++++++++++++------------------
4 files changed, 30 insertions(+), 24 deletions(-)
diff --git a/config.json b/config.json
index 4f0ce9b..3219501 100644
--- a/config.json
+++ b/config.json
@@ -7,14 +7,14 @@
"nsq_server": "121.31.232.83:4150",
"nsq_webapi": "http://121.31.232.83:9080/api/nsq/pub?topic=your_topic",
"order_topic": "aps.wangpengfei.erp.seorder",
- "bom_topic": "aps.wangpengfei.erp.icbom",
- "bom_query_topic": "aps.wangpengfei.erp.querybom",
- "bom_child_topic": "aps.wangpengfei.erp.bomchild",
+ "bom_topic": "aps.wangpengfei.erp.icBom",
+ "bom_query_topic": "aps.wangpengfei.erp.icBomQuery",
+ "bom_child_topic": "aps.wangpengfei.erp.icBomChild",
"inventory_topic": "aps.wangpengfei.erp.inventory",
"query_topic": "aps.wangpengfei.erp.k3resource",
"reply_topic": "aps.wangpengfei.erp.k3reply",
- "cst_webapi": "",
- "cst_query_topic": "",
- "cst_reply_topic": "",
+ "cst_webapi": "http://localhost/cst/local_post.ashx",
+ "cst_query_topic": "aps.wangpengfei.erp.cstApply",
+ "cst_reply_topic": "aps.wangpengfei.erp.cstReply",
"interval": 60
}
\ No newline at end of file
diff --git a/config/config.go b/config/config.go
index 3994d37..152b20a 100644
--- a/config/config.go
+++ b/config/config.go
@@ -48,6 +48,7 @@
Options.InventoryTopic = "aps.factory.erp.inventory"
Options.SqlQueryTopic = "aps.factory.erp.k3resource"
Options.SqlReplyTopic = "aps.factory.erp.k3reply"
+ Options.CSTWebApi = "http://localhost/cst/local_post.ashx"
Options.CSTQueryTopic = "aps.factory.erp.cstApply"
Options.CSTReplyTopic = "aps.factory.erp.cstReply"
Options.SyncInterval = 60
diff --git a/kingdee/bom.go b/kingdee/bom.go
index 9b276bf..2177773 100644
--- a/kingdee/bom.go
+++ b/kingdee/bom.go
@@ -1,24 +1,24 @@
package kingdee
type ICBom struct {
- FInterID int // 鍐呯爜
- FBOMNumber string // BOM鍗曠紪鍙�
- FUseStatus int // 浣跨敤鐘舵�佺爜
- FUseStatusName string // 浣跨敤鐘舵��
- FItemIDNumber string // 鐗╂枡浠ｇ爜
- FItemIDName string // 鐗╂枡鍚嶇О
- FModel string // 瑙勬牸鍨嬪彿
- FErpClsID string // 鐗╂枡灞炴��
- FQty float64 // 鏁伴噺
- FUnitName string // 鍗曚綅
- FYield float64 // 鎴愬搧鐜�
- FRoutingIDNumber string // 宸ヨ壓璺嚎浠ｇ爜
- FRoutingIDName string // 宸ヨ壓璺嚎鍚嶇О
- FNote string // 澶囨敞
- FBomType int // BOM绫诲瀷
- FAudDate string // 鏇存柊鏃堕棿
- FPDMImportDate string // 瀵煎叆鏃堕棿
- FStatus int // 鐘舵��
+ FInterID int `gorm:"column:FInterID" json:"FInterID"` // 鍐呯爜
+ FBOMNumber string `gorm:"column:FBOMNumber" json:"FBOMNumber"` // BOM鍗曠紪鍙�
+ FUseStatus int `gorm:"column:FUseStatus" json:"FUseStatus"` // 浣跨敤鐘舵�佺爜
+ FUseStatusName string `gorm:"column:FUseStatusName" json:"FUseStatusName"` // 浣跨敤鐘舵��
+ FItemIDNumber string `gorm:"column:FItemIDNumber" json:"FItemIDNumber"` // 鐗╂枡浠ｇ爜
+ FItemIDName string `gorm:"column:FItemIDName" json:"FItemIDName"` // 鐗╂枡鍚嶇О
+ FModel string `gorm:"column:FModel" json:"FModel"` // 瑙勬牸鍨嬪彿
+ FErpClsID string `gorm:"column:FErpClsID" json:"FErpClsID"` // 鐗╂枡灞炴��
+ FQty float64 `gorm:"column:FQty" json:"FQty"` // 鏁伴噺
+ FUnitName string `gorm:"column:FUnitName" json:"FUnitName"` // 鍗曚綅
+ FYield float64 `gorm:"column:FYield" json:"FYield"` // 鎴愬搧鐜�
+ FRoutingIDNumber string `gorm:"column:FRoutingIDNumber" json:"FRoutingIDNumber"` // 宸ヨ壓璺嚎浠ｇ爜
+ FRoutingIDName string `gorm:"column:FRoutingIDName" json:"FRoutingIDName"` // 宸ヨ壓璺嚎鍚嶇О
+ FNote string `gorm:"column:FNote" json:"FNote"` // 澶囨敞
+ FBomType int `gorm:"column:FBomType" json:"FBomType"` // BOM绫诲瀷
+ FAudDate string `gorm:"column:FAudDate" json:"FAudDate"` // 鏇存柊鏃堕棿
+ FPDMImportDate string `gorm:"column:FPDMImportDate" json:"FPDMImportDate"` // 瀵煎叆鏃堕棿
+ FStatus int `gorm:"column:FStatus" json:"FStatus"` // 鐘舵��
}
func BomList(fData bool) []ICBom {
diff --git a/report/send.go b/report/send.go
index 10818a0..6df988f 100644
--- a/report/send.go
+++ b/report/send.go
@@ -2,6 +2,7 @@
import (
"encoding/json"
+ "io/ioutil"
"time"
"kingdee-dbapi/cache"
@@ -143,6 +144,10 @@
bomList := kingdee.BomList(fData)
logger.Debug("鏌ヨ鍒�%d鏉om鏁版嵁", len(bomList))
+ b, _ := json.Marshal(bomList)
+
+ ioutil.WriteFile("bomList.tmp", b, 0644)
+
// 杩囨护鏁版嵁, 鍒ゆ柇鏄惁宸茬粡涓婃姤杩�, 璇锋眰鍏ㄩ噺鏁版嵁涓嶈繃婊�, 鐩存帴涓婃姤
if fData {
for i := 0; i < len(bomList); {
--
Gitblit v1.8.0