订单rpc
You can not select more than 25 topics Topics must start with a letter or number, can include dashes ('-') and can be up to 35 characters long.

75 lines
1.2 KiB

  1. package orderrpc
  2. import (
  3. "encoding/json"
  4. "strconv"
  5. "time"
  6. "git.tetele.net/tgo/crypter"
  7. "github.com/golang/protobuf/proto"
  8. )
  9. type OrderVerifyRes struct {
  10. Result bool
  11. }
  12. func VerifyByBooking(dbname, site_id string, data map[string]string, url ...string) (*OrderVerifyRes, error) {
  13. var order_rpc_url string = "127.0.0.1:7973"
  14. if len(url) > 0 && url[0] != "" {
  15. order_rpc_url = url[0]
  16. }
  17. conn, _, err := DialOrderService("tcp", order_rpc_url)
  18. if err != nil {
  19. return nil, err
  20. }
  21. defer conn.Close()
  22. data["dbname"] = dbname
  23. data["site_id"] = site_id
  24. data_json, err := json.Marshal(data)
  25. if err != nil {
  26. return nil, err
  27. }
  28. encryData := crypter.DesEn(string(data_json), DES_KEY)
  29. now_int64 := time.Now().Unix()
  30. now := strconv.FormatInt(now_int64, 10)
  31. sign := Sign(encryData, now)
  32. req := &Request{
  33. proto.String(encryData),
  34. proto.String(now),
  35. proto.String(sign),
  36. nil}
  37. res := &Response{}
  38. err = conn.VerifyByBooking(req, res)
  39. if err != nil {
  40. return nil, err
  41. }
  42. res_data_de, err := GetOrgData(res)
  43. if err != nil {
  44. return nil, err
  45. }
  46. var res_arr OrderVerifyRes
  47. err = json.Unmarshal([]byte(res_data_de), &res_arr)
  48. if err != nil {
  49. return nil, err
  50. }
  51. return &res_arr, nil
  52. }