package report
|
|
import (
|
"encoding/json"
|
"time"
|
|
"kingdee-dbapi/cache"
|
"kingdee-dbapi/config"
|
"kingdee-dbapi/kingdee"
|
"kingdee-dbapi/logger"
|
"kingdee-dbapi/models"
|
"kingdee-dbapi/nsqclient"
|
)
|
|
// 上报销售订单, 增量, 本地会存储已经上报过的. 订单不存在修改
|
func SendOrder() {
|
list := kingdee.SeOrderList()
|
logger.Debug("查询到%d条订单信息", len(list))
|
|
var completedOrderNo = make(map[string]struct{})
|
|
for i := 0; i < len(list); {
|
if cache.Exists(list[i].FBillNo) {
|
list = append(list[:i], list[i+1:]...)
|
} else {
|
completedOrderNo[list[i].FBillNo] = struct{}{}
|
i++
|
}
|
}
|
|
b, _ := json.Marshal(list)
|
|
// http协议上报, 已修改为TCP
|
//ok := nsqclient.HttpPost(config.Options.OrderTopic, b)
|
|
if len(list) == 0 {
|
logger.Debug("没有新的订单数据")
|
return
|
}
|
|
// TCP协议上报
|
ok := nsqclient.Produce(config.Options.OrderTopic, b)
|
if ok {
|
// 写入数据库, 标记已经上报过了,避免重复上报
|
for orderNo, _ := range completedOrderNo {
|
cursor := models.Order{
|
OrderNo: orderNo,
|
}
|
|
cursor.Insert()
|
cache.WriteCache(orderNo)
|
}
|
|
logger.Debug("已上报%d个订单信息", len(list))
|
} else {
|
logger.Warn("订单数据上报失败")
|
}
|
}
|
|
var invReportedCache = make(map[string]float64, 0)
|
var bomReportedCache = make(map[string]struct{}, 0)
|
var fullInvData bool
|
|
// 上报库存
|
func SendInventory() {
|
// 设置每天凌晨1点上报一次全量数据
|
hour := time.Now().Hour()
|
if hour == 1 {
|
if fullInvData == false {
|
invReportedCache = make(map[string]float64, 0)
|
// 顺便清理下bom的当天缓存
|
bomReportedCache = make(map[string]struct{})
|
fullInvData = true
|
}
|
} else {
|
fullInvData = false
|
}
|
|
list := kingdee.ICInventory()
|
|
logger.Debug("查询到%d条库存数据", len(list))
|
|
// 先过滤一遍数据, 格瑞米发现有同一个产品同批号同仓库, 有多条库存记录的情况
|
// 将类似的数据库存数累计到一起
|
var filterMap = make(map[string]float64, 0)
|
for i := 0; i < len(list); {
|
cacheKey := list[i].FNumber + list[i].FBatchNo + list[i].FStockNo
|
if qty, ok := filterMap[cacheKey]; ok {
|
filterMap[cacheKey] = list[i].FUnitQty + qty
|
list = append(list[:i], list[i+1:]...)
|
} else {
|
filterMap[cacheKey] = list[i].FUnitQty
|
i++
|
}
|
}
|
|
// 过滤数据, 判断是否已经上报过
|
for i := 0; i < len(list); {
|
cacheKey := list[i].FNumber + list[i].FBatchNo + list[i].FStockNo
|
if qty, ok := invReportedCache[cacheKey]; ok && qty == list[i].FUnitQty {
|
list = append(list[:i], list[i+1:]...)
|
} else {
|
invReportedCache[cacheKey] = list[i].FUnitQty
|
i++
|
}
|
}
|
|
if len(list) == 0 {
|
logger.Debug("没有要更新的库存数据.")
|
return
|
}
|
|
// 每次发 1000 条
|
successCnt := 0
|
for i := 0; i < len(list); i += 1000 {
|
end := i + 1000
|
if end > len(list) {
|
end = len(list)
|
}
|
|
b, _ := json.Marshal(list[i:end])
|
|
// HTTP协议上报,已修改为TCP
|
//nsqclient.HttpPost(config.Options.InventoryTopic, b)
|
|
// TCP协议上报
|
ok := nsqclient.Produce(config.Options.InventoryTopic, b)
|
if !ok {
|
logger.Warn("库存数据上报失败")
|
|
//上报失败, 缓存清空
|
for _, v := range list[i:end] {
|
key := v.FNumber + v.FBatchNo + v.FStockNo
|
delete(invReportedCache, key)
|
}
|
} else {
|
successCnt = end
|
}
|
}
|
|
logger.Debug("已上报%d条库存数据", successCnt)
|
}
|
|
// bom数据分bom和bomChild两个表
|
func SendBom(fData bool) {
|
var bomList []kingdee.ICBom
|
var bomChildList []kingdee.ICBomChild
|
|
// 上报bom
|
bomList = kingdee.BomList(fData)
|
logger.Debug("查询到%d条BOM数据", len(bomList))
|
|
// 过滤数据, 判断是否已经上报过, 请求全量数据不过滤, 直接上报
|
if !fData {
|
var bomNumbers []string
|
for i := 0; i < len(bomList); {
|
cacheKey := bomList[i].FBOMNumber + bomList[i].FAudDate
|
if _, ok := bomReportedCache[cacheKey]; ok {
|
bomList = append(bomList[:i], bomList[i+1:]...)
|
} else {
|
bomReportedCache[cacheKey] = struct{}{}
|
bomNumbers = append(bomNumbers, bomList[i].FBOMNumber)
|
i++
|
}
|
}
|
if len(bomNumbers) > 0 {
|
bomChildList = kingdee.BomChild(bomNumbers)
|
}
|
} else {
|
bomChildList = kingdee.BomChild(nil)
|
}
|
|
// 分组上传bom数据
|
if len(bomList) == 0 {
|
logger.Debug("没有要更新的BOM数据.")
|
} else {
|
// 将bom组件按bomId整理
|
var bomChildMap = make(map[int][]kingdee.ICBomChild, 0)
|
for idx, bomChild := range bomChildList {
|
bomChildMap[bomChild.FInterID] = append(bomChildMap[bomChild.FInterID], bomChildList[idx])
|
}
|
|
// 给bom添加组件
|
for idx, bom := range bomList {
|
bomList[idx].Component = bomChildMap[bom.FInterID]
|
}
|
|
// 每次发 200 条
|
successCnt := 0
|
for i := 0; i < len(bomList); i += 200 {
|
end := i + 200
|
if end > len(bomList) {
|
end = len(bomList)
|
}
|
|
b, _ := json.Marshal(bomList[i:end])
|
|
ok := nsqclient.Produce(config.Options.BomTopic, b)
|
if !ok {
|
logger.Warn("BOM数据上报失败")
|
|
//上报失败, 缓存清空
|
for _, v := range bomList[i:end] {
|
key := v.FBOMNumber + v.FAudDate
|
delete(bomReportedCache, key)
|
}
|
} else {
|
successCnt = end
|
}
|
}
|
|
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)
|
}
|
