变压器的三个接口details，list，sumbit

app/controller/transformerController.go

@@ -2,6 +2,13 @@ package controller
 
 import (
 	"github.com/gin-gonic/gin"
+	"iot_manager_service/app/dao"
+	"iot_manager_service/app/model"
+	"iot_manager_service/app/service"
+	"iot_manager_service/app/utils"
+	"math"
+	"net/http"
+	"strconv"
 )
 
 // 变压器基本信息管理对象
@@ -10,12 +17,57 @@ var Transformer = new(transformerCtl)
 type transformerCtl struct{}
 
 func (c *transformerCtl) Detail(ctx *gin.Context) {
+	id, e := strconv.Atoi(ctx.Query("id"))
+	if e != nil {
+		ctx.JSON(http.StatusOK, utils.ParamsInvalidResponse(e.Error(), nil))
+		return
+	}
+
+	device, err := service.TransformerService.Get(id)
+	if err != nil {
+		ctx.JSON(http.StatusOK, err)
+		return
+	}
+	ctx.JSON(http.StatusOK, utils.SuccessResponse(utils.Succeeded, device))
 }
 
 func (c *transformerCtl) List(ctx *gin.Context) {
+	searchValue := ctx.Query("searchValue")
+	current, _ := strconv.Atoi(ctx.Query("current"))
+	size, _ := strconv.Atoi(ctx.Query("size"))
+	if current == 0 {
+		current = 1
+	}
+	if size <= 0 || size > 100 {
+		size = 10
+	}
+	devices, err := service.TransformerService.List(searchValue, current, size)
+	if err != nil {
+		ctx.JSON(http.StatusOK, err)
+		return
+	}
+	pages := math.Ceil(float64(len(devices)) / float64(size))
+	rsp := model.RsqTransformerList{
+		Current: current,
+		Size:    size,
+		Total:   len(devices),
+		Pages:   int(pages),
+	}
+	for _, device := range devices {
+
+		rsp.Records = append(rsp.Records, device)
+	}
+	ctx.JSON(http.StatusOK, utils.SuccessResponse(utils.Succeeded, rsp))
 }
 
 func (c *transformerCtl) CreateOrUpdate(ctx *gin.Context) {
+	var req dao.Transformer
+	if err := ctx.ShouldBindJSON(&req); err != nil {
+		ctx.JSON(http.StatusOK, utils.ParamsInvalidResponse(err.Error(), nil))
+		return
+	}
+	err := service.TransformerService.CreateOrUpdate(req)
+	ctx.JSON(http.StatusOK, err)
 }
 
 func (c *transformerCtl) Remove(ctx *gin.Context) {

app/dao/common.go

@@ -27,6 +27,6 @@ func InitDB() {
 		GDb.DB().SetMaxOpenConns(32)
 		GDb.DB().SetMaxIdleConns(5)
 		GDb.LogMode(false)
-		GDb.AutoMigrate(&CameraDevice{}, &LampPoleGroup{}, &LampPole{})
+		GDb.AutoMigrate(&CameraDevice{}, &LampPoleGroup{}, &LampPole{}, &Transformer{})
 	}
 }

app/dao/transformerDao.go

@@ -0,0 +1,81 @@
+package dao
+
+import (
+	"github.com/jinzhu/gorm"
+	"time"
+)
+
+// Transformer 变压器
+type Transformer struct {
+	ID              int        `gorm:"primary_key" json:"id"`                             //编号
+	TransName       string     `gorm:"type:varchar(60)" json:"transName"`                 //变压器名称
+	TransSN         string     `gorm:"type:varchar(60)" json:"transSN"`                   //设备序列号
+	RatedPower      float32    `gorm:"type:double(8, 2) default 0.00 " json:"ratedPower"` //功率
+	ProvinceName    string     `gorm:" varchar(12)" json:"provinceName"`                  //省份
+	CityName        string     `gorm:"type:varchar(12)" json:"cityName"`                  //市
+	DistrictName    string     `gorm:"type:varchar(12)" json:"districtName"`              //区
+	TenantId        string     `gorm:"type:varchar(12)" json:"tenantId"`                  //租户id
+	InstallLocation string     `gorm:"type:varchar(100)" json:"installLocation"`          //详细位置
+	PoleLng         float64    `gorm:"type:double(17, 14) " json:"poleLng"`               //经度
+	PoleLat         float64    `gorm:"type:double(17, 14)  " json:"poleLat"`              //纬度
+	TransPhotoUrl   string     `gorm:"type:varchar(255)" json:"transPhotoUrl"`            //变压器照片地址
+	InstallTime     *time.Time `gorm:"type:date" json:"installTime"`                      //安装时间
+	CreateTime      time.Time  `gorm:"type:datetime" json:"createTime"`                   //新增时间
+	CreateUser      string     `gorm:"type:varchar(60)" json:"createUser"`                //新增记录操作用户ID
+	UpdateTime      time.Time  `gorm:"type:datetime" json:"updateTime"`                   //修改时间
+	UpdateUser      string     `gorm:"type:varchar(60)" json:"updateUser"`                //修改用户
+	IsDeleted       int        `gorm:"type:int;default 0" json:"isDeleted"`               //是否删除 0=未删除,1=删除
+	Status          int        `gorm:"type:int" json:"status"`                            //状态 0=正常,1=异常
+}
+
+func (Transformer) TableName() string {
+	return "t_dev_transformer"
+}
+
+func (c Transformer) Delete() error {
+	return GDb.Model(&c).Updates(map[string]interface{}{"state": 0}).Error
+}
+
+func (c Transformer) IsExistedByCode() bool {
+	var count = 0
+	_ = GDb.Model(&c).Where("  trans_sn = ? and is_deleted = ?",
+		c.TransSN, c.IsDeleted).Count(&count).Error
+	return count > 0
+}
+
+func (c Transformer) IsExistedByNameAndCode() bool {
+	var devices []Transformer
+	err := GDb.Model(&c).Where(" trans_sn = ? and is_deleted = ?",
+		c.TransSN, c.IsDeleted).Find(&devices).Error
+	//如果查询不到，返回相应的错误
+	if gorm.IsRecordNotFoundError(err) {
+		return false
+	}
+	for _, d := range devices {
+		if d.ID != c.ID {
+			return true
+		}
+	}
+	return false
+}
+
+func (c *Transformer) Create() error {
+	return GDb.Model(&c).Save(&c).Error
+}
+func (c *Transformer) Update() error {
+	return GDb.Model(&c).Where(" id = ? ", c.ID).Update(&c).Error
+}
+
+func (c Transformer) GetCameraDevice() error {
+	err := GDb.Model(&c).Where(" id = ? ", c.ID).Scan(&c).Error
+	return err
+}
+func (c *Transformer) GetDevice() error {
+	err := GDb.Model(&c).Where(" id = ? ", c.ID).Scan(&c).Error
+	return err
+}
+func (c Transformer) GetDevices(offset, limit int) ([]Transformer, error) {
+	var devices []Transformer
+	err := GDb.Model(&c).Where(" trans_name like ? ", "%"+c.TransName+"%").Offset(offset).Limit(limit).Find(&devices).Error
+	return devices, err
+}

app/model/transformer.go

@@ -0,0 +1,11 @@
+package model
+
+import "iot_manager_service/app/dao"
+
+type RsqTransformerList struct {
+	Records []dao.Transformer `json:"records"` //记录列表
+	Current int               `json:"current"` //当前分页
+	Size    int               `json:"size"`    //每页数量
+	Pages   int               `json:"pages"`   //总页数
+	Total   int               `json:"total"`   //总数
+}

app/service/transformerService.go

@@ -0,0 +1,72 @@
+package service
+
+import (
+	"fmt"
+	"iot_manager_service/app/dao"
+	"iot_manager_service/app/utils"
+	"time"
+)
+
+var TransformerService = new(transformerService)
+
+type transformerService struct{}
+
+func (s *transformerService) Get(id int) (*dao.Transformer, *utils.Errors) {
+	// 创建查询实例
+	device := &dao.Transformer{
+		ID: id,
+	}
+	err := device.GetDevice()
+	if err != nil {
+		return nil, utils.FailResponse(err.Error(), nil)
+	}
+	return device, nil
+
+}
+
+func (s *transformerService) CreateOrUpdate(req dao.Transformer) *utils.Errors {
+	// 创建查询实例
+	device := req
+
+	if req.ID == 0 {
+		device.CreateTime = time.Now()
+		device.CreateUser = "TODO" // todo: 使用登录态
+		if device.IsExistedByCode() {
+			fmt.Printf("Create GetDeviceID err \n")
+			return utils.ParamsInvalidResponse("编码不能重复，请重新填写！", nil)
+		}
+		if err := device.Create(); err != nil {
+			fmt.Printf("Create err = %s \n", err.Error())
+			return utils.FailResponse(err.Error(), nil)
+		}
+		return utils.SuccessResponse(utils.Succeeded, nil)
+	}
+	device.UpdateUser = "TODO" // todo: 使用登录态
+	device.UpdateTime = time.Now()
+	if device.IsExistedByNameAndCode() {
+		return utils.ParamsInvalidResponse("编码不能重复，请重新填写！", nil)
+	}
+
+	if err := device.Update(); err != nil {
+		fmt.Printf("Update err = %s \n", err.Error())
+		return utils.FailResponse(err.Error(), nil)
+	}
+
+	//todo operation record
+	return utils.SuccessResponse(utils.Succeeded, nil)
+}
+func (s *transformerService) List(searchValue string, current, size int) ([]dao.Transformer, *utils.Errors) {
+	device := dao.Transformer{}
+	if searchValue != "" {
+		device.TransSN = searchValue
+		device.TransName = searchValue
+	}
+
+	offset := (current - 1) * size
+	limit := size
+	devices, err := device.GetDevices(offset, limit)
+	if err != nil {
+		return nil, utils.FailResponse(err.Error(), nil)
+	}
+	return devices, nil
+}