package agent import ( "encoding/json" //"fmt" //"git.loafle.net/overflow/overflow_proxy_service/proxy" "git.loafle.net/overflow/overflow_proxy_service/proxy/member" "time" "git.loafle.net/overflow/overflow_proxy_service/proxy/utils" ) type AgentService struct { } type Agent struct { Id json.Number `json:"id,Number,omitempty"` AuthorizedDate int64 `json:"authorizedDate,Number,omitempty"` Description string `json:"description,omitempty"` Member member.Member `json:"member,omitempty"` LastPollingDate int64 `json:"lastPollingDate,omitempty"` Status string `json:"status,omitempty"` } func NewAgentService() *AgentService { return &AgentService{} } func NewAgent(desc string, member member.Member) *Agent { na := &Agent{ AuthorizedDate: time.Now().Unix(), Description: desc, Member: member, } return na } func (as *AgentService) SaveAgent(agent *Agent) (string, error) { //bytes, err := json.Marshal(agent) //if err != nil { // return "", err //} //fmt.Println(agent.Member.Id) //fmt.Println(string(bytes)) //paramMap := make(map[string]string) //paramMap["com.loafle.overflow.agent.model.Agent"] = string(bytes) // //out, err := proxy.InvokeDB("agent", "create", paramMap) out, err := utils.InvokeDB("agent", "create", agent) if err != nil { return "", err } return out, nil } func (as *AgentService) getAgentList(memberId string) (string, error) { //paramMap := make(map[string]string) // mem := member.NewMember() mem.Id = json.Number(memberId) // //bytes, err := json.Marshal(mem) //if err != nil { // return "", err //} // //paramMap["com.loafle.overflow.member.model.Member"] = string(bytes) // //out, err := proxy.InvokeDB("agent", "findAgentListByMemberId", paramMap) out, err := utils.InvokeDBByModel("agent", "findAgentListByMemberId", mem, "com.loafle.overflow.member.model.Member") if err != nil { return "", err } return out, nil } func (as *AgentService) GetModel() (interface{}) { return &Agent{} }