areainfologic.go 1.4 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263
  1. package logic
  2. import (
  3. "app.yhyue.com/moapp/jyInfo/rpc/model/province"
  4. "context"
  5. "fmt"
  6. "log"
  7. "strings"
  8. "app.yhyue.com/moapp/jyInfo/rpc/common/commonclient"
  9. "app.yhyue.com/moapp/jyInfo/rpc/common/internal/svc"
  10. "github.com/zeromicro/go-zero/core/logx"
  11. )
  12. type AreaInfoLogic struct {
  13. ctx context.Context
  14. svcCtx *svc.ServiceContext
  15. logx.Logger
  16. }
  17. func NewAreaInfoLogic(ctx context.Context, svcCtx *svc.ServiceContext) *AreaInfoLogic {
  18. return &AreaInfoLogic{
  19. ctx: ctx,
  20. svcCtx: svcCtx,
  21. Logger: logx.WithContext(ctx),
  22. }
  23. }
  24. // 获取省份信息
  25. func (l *AreaInfoLogic) AreaInfo(in *commonclient.ProjectReq) (*commonclient.AreaResp, error) {
  26. //获取地区信息
  27. data, err := l.svcCtx.AreaModel.Find()
  28. log.Println("data:", data, "--err:", err)
  29. return &commonclient.AreaResp{
  30. Data: AreaFormat(data),
  31. }, nil
  32. }
  33. //省份信息结构化
  34. func AreaFormat(data []model.AreaResp) (ps []*commonclient.Province) {
  35. var provinces = map[string][]*commonclient.City{}
  36. for _, v := range data {
  37. pk := fmt.Sprintf("%s-%s", v.Province, fmt.Sprint(v.Pid))
  38. provinces[pk] = append(provinces[pk], &commonclient.City{
  39. Name: v.City,
  40. Code: fmt.Sprint(v.Cid),
  41. })
  42. }
  43. if provinces != nil {
  44. for pk, pv := range provinces {
  45. if strings.Contains(pk, "-") {
  46. pkarr := strings.Split(pk, "-")
  47. ps = append(ps, &commonclient.Province{
  48. Name: pkarr[0],
  49. Code: pkarr[1],
  50. Citys: pv,
  51. })
  52. }
  53. }
  54. }
  55. return
  56. }