| | |
| | | package cache |
| | | |
| | | import ( |
| | | "kingdee-dbapi/models" |
| | | "sync" |
| | | |
| | | "kingdee-dbapi/models" |
| | | ) |
| | | |
| | | var orderKeyCache sync.Map |
| | |
| | | package gui |
| | | |
| | | import ( |
| | | "kingdee-dbapi/logger" |
| | | "kingdee-dbapi/nsqclient" |
| | | "strings" |
| | | |
| | | "kingdee-dbapi/config" |
| | | "kingdee-dbapi/kingdee" |
| | | "kingdee-dbapi/logger" |
| | | "kingdee-dbapi/nsqclient" |
| | | "kingdee-dbapi/report" |
| | | "kingdee-dbapi/static" |
| | | "kingdee-dbapi/webserver" |
| | |
| | | |
| | | import ( |
| | | "context" |
| | | "kingdee-dbapi/logger" |
| | | |
| | | "kingdee-dbapi/config" |
| | | "kingdee-dbapi/logger" |
| | | ) |
| | | |
| | | var producerCli Producer |
| | |
| | | |
| | | import ( |
| | | "context" |
| | | "time" |
| | | |
| | | "kingdee-dbapi/config" |
| | | "kingdee-dbapi/logger" |
| | | "time" |
| | | ) |
| | | |
| | | var ctx context.Context |
| | |
| | | import ( |
| | | "encoding/json" |
| | | "io/ioutil" |
| | | "kingdee-dbapi/logger" |
| | | "time" |
| | | |
| | | "kingdee-dbapi/cache" |
| | | "kingdee-dbapi/config" |
| | | "kingdee-dbapi/kingdee" |
| | | "kingdee-dbapi/logger" |
| | | "kingdee-dbapi/models" |
| | | "kingdee-dbapi/nsqclient" |
| | | ) |
| | |
| | | //ok := nsqclient.HttpPost(config.Options.OrderTopic, b) |
| | | |
| | | if len(list) == 0 { |
| | | logger.Debug("没有新的订单需要上报") |
| | | logger.Debug("没有新的订单数据") |
| | | return |
| | | } |
| | | |