publicService/rpc/service/datasmt.go

package service

import (
	"fmt"
	"strings"

	"app.yhyue.com/moapp/jybase/common"
	"app.yhyue.com/moapp/jybase/encrypt"
	"jygit.jydev.jianyu360.cn/ApplicationCenter/publicService/rpc/db"
	"jygit.jydev.jianyu360.cn/ApplicationCenter/publicService/rpc/internal/config"
	"jygit.jydev.jianyu360.cn/ApplicationCenter/publicService/rpc/pb"
)

const (
	DATA_SUPERMARKET = "data_supermarket"
)

type DataSmt struct {
}

// 列表数据
func (d *DataSmt) List(searchValue, dataType string, pageNum, pageSize int64) *pb.DatasmtRespList {
	result := pb.DatasmtRespList{}
	//包含字段说明
	fieldIllustrate := []*pb.Field{}
	fieldIllustrateMap := map[string]string{}
	for _, v := range config.C.DataSmt.DataType {
		fieldIllustrate = append(fieldIllustrate, &pb.Field{
			Code:     v.Code,
			Name:     v.Name,
			Describe: v.Describe,
		})
		fieldIllustrateMap[v.Code] = v.Name
	}
	result.FieldIllustrate = fieldIllustrate
	if pageSize == 0 {
		pageSize = 40
	}
	//数据查询
	data := &[]map[string]interface{}{}
	querySql := "select id,name,data_type,format,clear_status from %s where %s ORDER BY serial_number, update_time desc,CONVERT(name USING gbk) asc,id desc limit %v ,%v "
	queryStrArr := []string{
		" status=1 ",
	}
	args := []interface{}{}
	if searchValue != "" {
		queryStrArr = append(queryStrArr, " name LIKE ? ")
		args = append(args, "%"+searchValue+"%")
	}
	if dataType != "" {
		queryStrArr = append(queryStrArr, " data_type=? ")
		args = append(args, dataType)
	}
	querySql = fmt.Sprintf(querySql, DATA_SUPERMARKET, strings.Join(queryStrArr, " and "), (pageNum-1)*pageSize, pageSize)
	data = db.Mysql_BaseService.SelectBySql(querySql, args...)
	if data != nil && len(*data) > 0 {
		//数据处理
		dataList := []*pb.DatasmtList{}
		for _, v := range *data {
			dataList = append(dataList, &pb.DatasmtList{
				Id:          encrypt.SE.Encode2Hex(common.InterfaceToStr(v["id"])),
				Name:        common.InterfaceToStr(v["name"]),
				DataType:    fieldIllustrateMap[common.InterfaceToStr(v["data_type"])],
				Format:      common.InterfaceToStr(v["format"]),
				ClearStatus: common.InterfaceToStr(v["clear_status"]),
			})
		}
		result.List = dataList
	}
	//总数查询
	countQuerySql := "select count(id) from %s where %s "
	countQuerySql = fmt.Sprintf(countQuerySql, DATA_SUPERMARKET, strings.Join(queryStrArr, " and "))
	count := db.Mysql_BaseService.CountBySql(countQuerySql, args...)
	result.PageCount = count
	//热搜词处理
	hotKeySql := fmt.Sprintf(" select a.keyword as keyword from (SELECT keyword,min(serial_number) as serial_number,max(update_time) as update_time FROM %s where keyword<>'' and keyword is not null and  status=1 GROUP BY keyword ) a ORDER BY a.serial_number, a.update_time desc,CONVERT(a.keyword USING gbk) asc limit 8", DATA_SUPERMARKET)
	hotData := db.Mysql_BaseService.SelectBySql(hotKeySql)
	hotKeyArr := []string{}
	for _, m := range *hotData {
		hotKeyArr = append(hotKeyArr, common.InterfaceToStr(m["keyword"]))
	}
	result.HotKeys = hotKeyArr
	result.DataTypeStr = fieldIllustrateMap[dataType]
	return &result
}

// 详情
func (d *DataSmt) Detail(id string) *pb.DatasmtRespDetail {
	result := &pb.DatasmtRespDetail{}
	querySql := fmt.Sprintf("select id,name,data_type,format,clear_status,data_example,introduce,keyword from %s where id=?", DATA_SUPERMARKET)
	data := db.Mysql_BaseService.SelectBySql(querySql, id)
	if data != nil && len(*data) > 0 {
		//数据处理
		v := (*data)[0]
		dataType := common.InterfaceToStr(v["data_type"])
		result = &pb.DatasmtRespDetail{
			Name:        common.InterfaceToStr(v["name"]),
			DataType:    common.InterfaceToStr(v["data_type"]),
			Format:      common.InterfaceToStr(v["format"]),
			ClearStatus: common.InterfaceToStr(v["clear_status"]),
			DataExample: config.C.DataSmt.ResUrl + common.InterfaceToStr(v["data_example"]),
			Introduce:   common.InterfaceToStr(v["introduce"]),
			Keyword:     common.InterfaceToStr(v["keyword"]),
		}
		for _, v := range config.C.DataSmt.DataType {
			if dataType == v.Code {
				result.FieldIllustrate = &pb.Field{
					Code:     v.Code,
					Name:     v.Name,
					Describe: v.Describe,
				}
				if v.Application != "" {
					result.FieldIllustrate.Application = config.C.DataSmt.ResUrl + v.Application
				}
				if v.ApplicationApp != "" {
					result.FieldIllustrate.ApplicationApp = config.C.DataSmt.ResUrl + v.ApplicationApp
				}
			}
		}
		result.DataType = result.FieldIllustrate.Name
	}
	return result
}