分享
  1. 首页
  2. 文章

Golang解析xml文件

____追梦人 · · 9824 次点击 · · 开始浏览
这是一个创建于 的文章,其中的信息可能已经有所发展或是发生改变。

一段xml数据:

<?xml version="1.0" encoding="utf-8"?>
<string xmlns="http://tempuri.org/">
<?xml version="1.0" encoding="utf-8"?>
<data>
<head>
<service name="query_syj_cyfwxk" />
</head>
<body type="out">
<result count="38">
<row XuKeZhengHao="" XinDanWeiMingC="" XinJingYingDiZ="" XinXingMing="" ShenQingXiangMu="" ShenQingXiangMuBz="" XinLianXiDianH="" XinJingJiXingZ="" SuoShuXiaQu="" XinCongYeRenYS="" JiaGongJingYingCSMJZJ="" ZhengZhaoYouXiaoQSRQ="" ZhengZhaoYouXiaoJZRQ="" LeiXing="新发" SuoShuXiaQu="" />
<row XuKeZhengHao="" XinDanWeiMingC="" XinJingYingDiZ="" XinXingMing="" ShenQingXiangMu="" ShenQingXiangMuBz="" XinLianXiDianH="" XinJingJiXingZ="" SuoShuXiaQu="" XinCongYeRenYS="" JiaGongJingYingCSMJZJ="" ZhengZhaoYouXiaoQSRQ="" ZhengZhaoYouXiaoJZRQ="" LeiXing="新发" SuoShuXiaQu="" />
<row XuKeZhengHao="" XinDanWeiMingC="延期测试2" XinJingYingDiZ="延期测试2" XinXingMing="延期测试2" ShenQingXiangMu="" ShenQingXiangMuBz="" XinLianXiDianH="" XinJingJiXingZ="延期测试2" SuoShuXiaQu="" XinCongYeRenYS="2" JiaGongJingYingCSMJZJ="" ZhengZhaoYouXiaoQSRQ="" ZhengZhaoYouXiaoJZRQ="" LeiXing="新发" SuoShuXiaQu="" />
</result>
</body>
</data>
</string>

Go代码:

packagewebService


import (
  "bufio"
  "encoding/xml"
  "fmt"
  "io/ioutil"
  "net/http"
  "os"
  "strings"
  "time"


)

type GetWebServiceDataController struct {
  BaseController
}

var (
  //获取数据地址
  url = ""
  //保存获取数据的服务器地址
  XmlPath = "/static/xml"
)

//xml中的string标签的结构体
type String struct {
  String string `xml:"xmlns,attr"`
  Xml  []Xml `xml:"?xml"`
  Data  []Data `xml:"data"`
}

//xml中的Xml标签的结构体
type Xml struct {
  Version string `xml:"version,attr"`
  Encoding string `xml:"encoding,attr"`
}

//xml中的data标签的结构体
type Data struct {
  Head []Head `xml:"head"`
  Body []Body `xml:"body"`
}

//xml中的head标签的结构体
type Head struct {
  Service []Service `xml:",attr"`
}

//xml中的service标签的结构体
type Service struct {
  Name string `xml:"name,attr"`
}

//xml中的body标签的结构体
type Body struct {
  Type  string  `xml:"type,attr"`
  Results []Results `xml:"result"`
}

//xml中的result标签的结构体
type Results struct {
  Count string `xml:"count,attr"`
  Row  []Row `xml:"row"`
}

//xml中的result标签的结构体
type Result struct {
  Count string `xml:"count,attr"`
}

//xml中的row标签的结构体
type Row struct {
  XuKeZhengHao     string `xml:"XuKeZhengHao,attr"`
  XinDanWeiMingC    string `xml:"XinDanWeiMingC,attr"`
  XinJingYingDiZ    string `xml:"XinJingYingDiZ,attr"`
  XinXingMing      string `xml:"XinXingMing,attr"`
  ShenQingXiangMu    string `xml:"ShenQingXiangMu,attr"`
  ShenQingXiangMuBz   string `xml:"ShenQingXiangMuBz,attr"`
  XinLianXiDianH    string `xml:"XinLianXiDianH,attr"`
  XinJingJiXingZ    string `xml:"XinJingJiXingZ,attr"`
  SuoShuXiaQu      string `xml:"SuoShuXiaQu,attr"`
  XinCongYeRenYS    string `xml:"XinCongYeRenYS,attr"`
  JiaGongJingYingCSMJZJ string `xml:"JiaGongJingYingCSMJZJ,attr"`
  ZhengZhaoYouXiaoQSRQ string `xml:"ZhengZhaoYouXiaoQSRQ,attr"`
  ZhengZhaoYouXiaoJZRQ string `xml:"ZhengZhaoYouXiaoJZRQ,attr"`
  LeiXing        string `xml:"LeiXing,attr"`
}

//解析保存到本地的xml数据,并存到数据库中
func (this *GetWebServiceDataController) GetWebServiceData() {

  fileName := this.WriteDataToXml()

  f, err := os.Open(fileName)
  if err != nil {
    panic(err)
  }
  data, err := ioutil.ReadAll(f)
  if err != nil {
    panic(err)
  }
  //fmt.Println("xml中的数据:=\n", string(data))
  var v String

  err = xml.Unmarshal(data, &v)

  if err != nil {
    panic(err)
  }
  //fmt.Println("aaaa=", v.Data)
  for _, data := range v.Data {

    for _, body := range data.Body {

      for _, result := range body.Results {

        for k, row := range result.Row {
          svc := webService.GetWebService(utils.DBE)
          var entity afscateringlicense.AFS_CateringLicense
          b := svc.GetIsExistByLicense(row.XuKeZhengHao, &entity)
          if b == false {
            //fmt.Println(k, row.XuKeZhengHao, row.XinDanWeiMingC)

            this.ParseForm(&entity)
            entity.License = row.XuKeZhengHao
            entity.UnitName = row.XinDanWeiMingC
            entity.Address = row.XinJingYingDiZ
            entity.LegalPerson = row.XinXingMing
            entity.Type = row.ShenQingXiangMu
            entity.Memo = row.ShenQingXiangMuBz
            entity.Tel = row.XinLianXiDianH
            entity.Nature = row.XinJingJiXingZ
            entity.Regional = row.SuoShuXiaQu
            entity.PractitionersNumber = row.XinCongYeRenYS
            entity.Area = row.JiaGongJingYingCSMJZJ
            entity.PeriodValidityBegin, _ = time.Parse(row.ZhengZhaoYouXiaoQSRQ, "2006年01月02日")
            entity.PeriodValidityEnd, _ = time.Parse(row.ZhengZhaoYouXiaoJZRQ, "2006年01月02日")
            entity.NewCardType = row.LeiXing
            _, err := svc.InsertWebServiceData(entity)
            if err == nil {
              this.Ctx.WriteString("添加成功")
            } else {
              this.Ctx.WriteString("添加失败")
            }
          } else {
            _, err := svc.UpdateEntityByLicense(row.XuKeZhengHao, &entity)
            if err == nil {
              this.Ctx.WriteString("修改成功")
            } else {
              this.Ctx.WriteString("修改失败")
            }
          }
        }
      }
    }
  }

}

//把获取到的数据保存到服务器/static/xml文件夹下
func (this *GetWebServiceDataController) WriteDataToXml() string {
  var s string
  body := this.Apiget(url)
  s = string(body)
  s = strings.Replace(s, "&lt;", "<", -1)
  s = strings.Replace(s, "&gt;", ">", -1)

  var spit string
  if os.IsPathSeparator('\\') { //前边的判断是否是系统的分隔符
    spit = "\\"
  } else {
    spit = "/"
  }
  var urlpath = XmlPath
  dir, _ := os.Getwd() //当前目录
  path := dir + spit + strings.Replace(XmlPath, "/", spit, -1) + spit + utils.ToStr(time.Now().Year()) + spit + fmt.Sprintf("%s", time.Now().Format("1")) + spit + "Cateringlicense" + spit

  os.MkdirAll(path, os.ModePerm)
  var fileName = "Cateringlicense-" + time.Now().Format("2006年01月02日-15-04") + ".xml"
  f, _ := os.Create(path + fileName)
  defer f.Close()
  writer := bufio.NewWriter(f)
  writer.WriteString(s)
  writer.WriteString("\n")
  writer.Flush()
  return dir + "/" + urlpath + "/" + utils.ToStr(time.Now().Year()) + "/" + fmt.Sprintf("%s", time.Now().Format("1")) + "/" + "Cateringlicense" + "/" + fileName

}

//通过Get方式获取接口餐饮服务的数据
func (this *GetWebServiceDataController) Apiget(str string) (body []byte) {
  response, _ := http.Get(str)
  if response != nil {
    defer response.Body.Close()
    body, _ = ioutil.ReadAll(response.Body)
  }
  return
}

操作数据库代码:

packagewebService


import (
  "github.com/go-xorm/xorm"



)

type WebService struct {
  ServiceBase
}

func GetWebService(xormEngine *xorm.Engine) *WebService {
  s := new(WebService)
  s.DBE = xormEngine
  return s
}

//把xml中的数据插入到数据库中
func (s WebService) InsertWebServiceData(entity interface{}) (affected int64, err error) {
  affected, err = s.DBE.Insert(entity)
  LogError(err)
  return
}

//根据证号查询是否有重复
func (s *WebService) GetIsExistByLicense(License string, entity interface{}) bool {
  b, _ := utils.DBE.Where("License = '" + License + "'").Get(entity)
  return b
}

//如果有重复的数据,根据证号进行修改
func (s *WebService) UpdateEntityByLicense(License string, entity interface{}) (affected int64, err error) {
  affected, err = s.DBE.Where("License = '" + License + "'").Update(entity)
  LogError(err)
  return
}


有疑问加站长微信联系(非本文作者)

本文来自:开源中国博客

感谢作者:____追梦人

查看原文:Golang解析xml文件

入群交流(和以上内容无关):加入Go大咖交流群,或添加微信:liuxiaoyan-s 备注:入群;或加QQ群:692541889

关注微信
9824 次点击
1 回复 | 直到 2017年08月16日 15:48:11
暂无回复
添加一条新回复 (您需要 后才能回复 没有账号 ?)
  • 请尽量让自己的回复能够对别人有帮助
  • 支持 Markdown 格式, **粗体**、~~删除线~~、`单行代码`
  • 支持 @ 本站用户;支持表情(输入 : 提示),见 Emoji cheat sheet
  • 图片支持拖拽、截图粘贴等方式上传

用户登录

没有账号?注册
或
(追記) (追記ここまで)

今日阅读排行

    加载中
(追記) (追記ここまで)

一周阅读排行

    加载中

关注我

  • 扫码关注领全套学习资料 关注微信公众号
  • 加入 QQ 群:
    • 192706294(已满)
    • 731990104(已满)
    • 798786647(已满)
    • 729884609(已满)
    • 977810755(已满)
    • 815126783(已满)
    • 812540095(已满)
    • 1006366459(已满)
    • 692541889

  • 关注微信公众号
  • 加入微信群:liuxiaoyan-s,备注入群
  • 也欢迎加入知识星球 Go粉丝们(免费)

给该专栏投稿 写篇新文章

每篇文章有总共有 5 次投稿机会

收入到我管理的专栏 新建专栏