| | |
|---|
| | | |
|---|
| | | 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) |
|---|
| | | } |
|---|
