快速开始
-
添加数据源
a. 新建数据源,输入获取天气预报的第三方API接口及参数配置
b. 点击列表中上一步所创建的数据源详情按钮,配置数据节点
c. 添加数据节点用户获取json字符串中某一个字段的值
这里的规则表达式可以自己写正则表达式对源json中某一个字段值进行匹配返回自定义内容
-
发布数据源
-
根据业务创建数据建模
a. 新建数据建模
这里的单元类型是在数据字典中配置,对应的业务模块,比如天气监测,对应的参数值会在下面业务实现中用到
b. 新建字段节点选择对应的数据源获取数据
c. 发布对应的数据建模
-
获取建模数据处理对应业务返回前端
a. 在api/v1目录下创建文件并定义API入参出参
type CityWeatherListReq struct {
g.Meta `path:"/weather/cityWeatherList" method:"get" summary:"获取城市的风力及日照时长" tags:"天气监测"`
Name string `json:"name" description:"名字"`
}
type CityWeatherListRes struct {
Info []*model.CityWeatherListRes
}b. 在logic下增加对应业务实现
func (a *sEnvWeather) CityWeatherList(ctx context.Context) (cityWeatherListOut []*model.CityWeatherListOut, err error) {
info, err := service.CityData().GetAll(ctx)
if err != nil {
return
}
if info != nil {
var cityIds []int
for _, city := range info {
cityIds = append(cityIds, city.Id)
}
if len(cityIds) > 0 {
//绑定的数据建模
dataInfo, _ := service.DataTemplateBusi().GetInfos(ctx, consts.Weather)
if dataInfo != nil {
//查询数据建模数据
var in = new(model.TemplateDataAllInput)
in.Id = uint64(dataInfo.DataTemplateId)
//查询条件
params := map[string]interface{}{
"CREATED_AT >= ? ": gtime.Now().Format("Y-m-d 00:00:00"),
"CREATED_AT < ? ": gtime.Now().Format("Y-m-d H:i:s"),
}
in.Param = params
out, _ := service.DataTemplate().GetAllData(ctx, in)
for _, city := range info {
var cityWeather = new(model.CityWeatherListOut)
cityWeather.Id = city.Id
cityWeather.Name = city.Name
cityWeather.Code = city.Code
//获取当前城市当天城市数据
var cityOut g.List
for _, v := range out.List {
if strings.EqualFold(city.Code, v["adcode"].(string)) {
cityOut = append(cityOut, v)
}
}
if len(cityOut) > 0 {
if err = gconv.Scan(cityOut[len(cityOut)-1], &cityWeather); err != nil {
return
}
}
//计算日照时长
if cityWeather.Sunrise != "" && cityWeather.Sunset != "" {
cityWeather.SunshineDuration = int(gtime.New(gtime.Now().Format("Y-m-d ") + cityWeather.Sunset + ":00").Sub(gtime.New(gtime.Now().Format("Y-m-d ") + cityWeather.Sunrise + ":00")).Hours())
}
cityWeatherListOut = append(cityWeatherListOut, cityWeather)
}
}
}
}
return
}c. 使用gf gen service命令生成对应的interface
type (
IEnvWeather interface {
CityWeatherList(ctx context.Context) (cityWeatherListOut []*model.CityWeatherListOut, err error)
)
var (
localEnvWeather IEnvWeather
)
func EnvWeather() IEnvWeather {
if localEnvWeather == nil {
panic("implement not found for interface IEnvWeather, forgot register?")
}
return localEnvWeather
}
func RegisterEnvWeather(i IEnvWeather) {
localEnvWeather = i
}d. controller定义方法体接口service层返回的业务数据并返回给前端
func (a *cWeather) CityWeatherList(ctx context.Context, req *envirotronics.CityWeatherListReq) (res *envirotronics.CityWeatherListRes, err error) {
out, err := service.EnvWeather().CityWeatherList(ctx)
if err != nil {
return
}
var cityWeatherListRes []*model.CityWeatherListRes
if out != nil {
if err = gconv.Scan(out, &cityWeatherListRes); err != nil {
return
}
}
res = &envirotronics.CityWeatherListRes{
Info: cityWeatherListRes,
}
return
}