| | |
| | | "basic.com/pubsub/protomsg.git" |
| | | ) |
| | | |
| | | |
| | | func Parsesources(sources []map[string]interface{}) (esinfos []*protomsg.Esinfo) { |
| | | var ok bool |
| | | for _, source := range sources { |
| | |
| | | } |
| | | return |
| | | } |
| | | |
| | | //解析底库人员结构 |
| | | func Dbpersonbyid(sources []map[string]interface{}) protomsg.Dbperson { |
| | | func Dbpersonbyid(sources []map[string]interface{}) (tmpinfos []protomsg.Dbperson) { |
| | | var ok bool |
| | | |
| | | var tmpinfo protomsg.Dbperson |
| | |
| | | //根据 tableid 获取 tablename |
| | | //name, _:= Dbtablename(tmpinfo.TableId) |
| | | //tmpinfo.TableName= name |
| | | tmpinfos = append(tmpinfos, tmpinfo) |
| | | } |
| | | |
| | | return tmpinfo |
| | | return tmpinfos |
| | | } |
| | | |
| | | //解析底库结构 |
| | | func Dbtablebyid(sources []map[string]interface{}) protomsg.Dbtable { |
| | | func Dbtablebyid(sources []map[string]interface{}) (tmpinfos []protomsg.Dbtable) { |
| | | var ok bool |
| | | |
| | | var tmpinfo protomsg.Dbtable |
| | |
| | | Isnil("isSync", ok) |
| | | tmpinfo.AnalyServerId, ok = source["analyServerId"].(string) |
| | | Isnil("analyServerId", ok) |
| | | |
| | | tmpinfos = append(tmpinfos, tmpinfo) |
| | | } |
| | | |
| | | return tmpinfo |
| | | return tmpinfos |
| | | } |
| | | |
| | | func Sourcelist(buf []byte) (sources []map[string]interface{}, err error) { |