灯杆相关接口

app/controller/lampPoleController.go

@@ -2,9 +2,11 @@ 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"
 )
@@ -30,7 +32,7 @@ func (c *lampPoleCtl) Detail(ctx *gin.Context) {
 }
 
 func (c *lampPoleCtl) CreateOrUpdate(ctx *gin.Context) {
-	var req *model.ReqLampPoleSubmit
+	var req *dao.LampPole
 	if err := ctx.ShouldBindJSON(&req); err != nil {
 		ctx.JSON(http.StatusOK, utils.ParamsInvalidResponse(err.Error(), nil))
 		return
@@ -41,9 +43,49 @@ func (c *lampPoleCtl) CreateOrUpdate(ctx *gin.Context) {
 }
 
 func (c *lampPoleCtl) List(ctx *gin.Context) {
+	searchValue := ctx.Query("searchValue")
+	groupId := ctx.Query("groupId")
+	boxId := ctx.Query("boxId")
+	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.LampPoleService.List(searchValue, groupId, boxId, current, size)
+	if err != nil {
+		ctx.JSON(http.StatusOK, err)
+		return
+	}
+	pages := math.Ceil(float64(len(devices)) / float64(size))
+	rsp := model.RspLampPoleList{
+		Current: current,
+		Size:    size,
+		Total:   len(devices),
+		Pages:   int(pages),
+	}
+	for _, device := range devices {
+		rsp.Records = append(rsp.Records, lampPoleDaoToModel(device))
+	}
+	ctx.JSON(http.StatusOK, utils.SuccessResponse(utils.Succeeded, rsp))
 }
 
 func (c *lampPoleCtl) GetRelevanceDetail(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.LampPoleService.GetRelevanceDetail(id)
+	if err != nil {
+		ctx.JSON(http.StatusOK, err)
+		return
+	}
+	ctx.JSON(http.StatusOK, utils.SuccessResponse(utils.Succeeded, device))
 }
 
 func (c *lampPoleCtl) Remove(ctx *gin.Context) {
@@ -60,3 +102,18 @@ func (c *lampPoleCtl) ExportTemplate(ctx *gin.Context) {
 
 func (c *lampPoleCtl) GetList(ctx *gin.Context) {
 }
+
+func lampPoleDaoToModel(device dao.LampPole) model.LampPoleDetail {
+	return model.LampPoleDetail{
+		LampPole:          device,
+		AlarmTerminalList: nil,
+		CameraList:        nil,
+		CaptureUnitList:   nil,
+		GatewayList:       nil,
+		InfoBoardList:     nil,
+		IpBroadcastList:   nil,
+		LightControlList:  nil,
+		SensorList:        nil,
+		ZigbeeList:        nil,
+	}
+}

app/controller/lampPoleGroupController.go

@@ -6,6 +6,7 @@ import (
 	"iot_manager_service/app/model"
 	"iot_manager_service/app/service"
 	"iot_manager_service/app/utils"
+	"math"
 	"net/http"
 	"strconv"
 )
@@ -28,12 +29,12 @@ func (c *lampPoleGroupCtl) Detail(ctx *gin.Context) {
 		ctx.JSON(http.StatusOK, err)
 		return
 	}
-	ctx.JSON(http.StatusOK, utils.SuccessResponse(utils.Succeeded, device))
+	ctx.JSON(http.StatusOK, utils.SuccessResponse(utils.Succeeded, lampPoleGroupDaoToModel(*device)))
 }
 
 // CreateOrUpdate 新增、更新
 func (c *lampPoleGroupCtl) CreateOrUpdate(ctx *gin.Context) {
-	var req *model.ReqLampPoleGroupSubmit
+	var req *dao.LampPoleGroup
 	if err := ctx.ShouldBindJSON(&req); err != nil {
 		ctx.JSON(http.StatusOK, utils.ParamsInvalidResponse(err.Error(), nil))
 		return
@@ -59,10 +60,12 @@ func (c *lampPoleGroupCtl) List(ctx *gin.Context) {
 		ctx.JSON(http.StatusOK, err)
 		return
 	}
+	pages := math.Ceil(float64(len(devices)) / float64(size))
 	rsp := model.RspLampPoleGroupList{
 		Current: current,
 		Size:    size,
 		Total:   len(devices),
+		Pages:   int(pages),
 	}
 	for _, device := range devices {
 		rsp.Records = append(rsp.Records, lampPoleGroupDaoToModel(device))
@@ -117,23 +120,13 @@ func (c *lampPoleGroupCtl) GetTree(ctx *gin.Context) {
 	ctx.JSON(http.StatusOK, utils.SuccessResponse(utils.Succeeded, devices))
 }
 
-func lampPoleGroupDaoToModel(device dao.LampPoleGroup) model.ReqLampPoleGroupSubmit {
-	return model.ReqLampPoleGroupSubmit{
-		ID:             device.ID,
-		PoleGroupName:  device.PoleGroupName,
-		CountLampPole:  device.CountLampPole,
-		Remark:         device.Remark,
-		TenantId:       device.TenantId,
-		CreateTime:     device.CreateTime,
-		CreateUser:     device.CreateUser,
-		UpdateTime:     device.UpdateTime,
-		UpdateUser:     device.UpdateUser,
-		IsDeleted:      device.IsDeleted,
-		Tag:            device.Tag,
+func lampPoleGroupDaoToModel(device dao.LampPoleGroup) model.LampPoleGroupDetail {
+	return model.LampPoleGroupDetail{
+		LampPoleGroup:  device,
 		PublicName:     "",
-		LampPoleVOList: nil,
-		CameraList:     nil,
-		SwitchBoxList:  nil,
-		InfoBoardList:  nil,
+		LampPoleVOList: []model.LampPoleVO{},
+		CameraList:     []model.Camera{},
+		SwitchBoxList:  []model.SwitchBox{},
+		InfoBoardList:  []model.InfoBoard{},
 	}
 }

app/dao/lampPoleDao.go

@@ -0,0 +1,108 @@
+package dao
+
+import (
+	"github.com/jinzhu/gorm"
+	"time"
+)
+
+//LampPole 灯杆设备
+type LampPole struct {
+	ID              int       `gorm:"primary_key" json:"id"`                    //编号
+	PoleName        string    `gorm:"type:varchar(64)"  json:"poleName"`        //灯杆名称
+	PoleSN          string    `gorm:"type:varchar(60)" json:"poleSn"`           //灯杆唯一识别码
+	PoleSize        float32   `gorm:"type:double(3,1)" json:"poleSize"`         //灯杆规格
+	GroupId         int       `gorm:"type:int" json:"groupId"`                  //所属灯杆分组
+	GatewayId       string    `gorm:"type:varchar(32)" json:"gatewayId"`        //所属网关id
+	BoxId           int       `gorm:"type:int" json:"boxId"`                    //所属配电箱
+	CoordType       int       `gorm:"type:int;default 1" json:"coordType"`      //经纬度类型0=百度,1=高德,2=腾讯,3=GPS
+	ProvinceName    string    `gorm:"type:varchar(60)" json:"provinceName"`     //省份
+	CityName        string    `gorm:"type:varchar(60)" json:"cityName"`         //城市
+	DistrictName    string    `gorm:"type:varchar(60)" json:"districtName"`     //区域
+	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"`        //纬度
+	RealLng         float64   `gorm:"type:double(17,14)" json:"realLng"`        //真实经度
+	RealLat         float64   `gorm:"type:double(17,14)" json:"realLat"`        //真实纬度
+	IsCross         int       `gorm:"type:int" json:"isCross"`                  //是否为路口-0-是1-不是
+	InstallTime     time.Time `gorm:"type:date" json:"installTime"`             //安装时间
+	LampPolePhoto   string    `gorm:"type:varchar(255)" json:"lampPolePhoto"`   //灯杆照片
+	TenantId        string    `gorm:"type:varchar(12)" json:"tenantId"`         //租户ID
+	CreateTime      time.Time `gorm:"type:datetime" json:"createTime"`          //新增时间
+	CreateUser      string    `gorm:"type:varchar(60)" json:"createUser"`       //新增记录操作用户ID
+	UpdateTime      time.Time `gorm:"type:datetime" json:"updateUime"`          //修改时间
+	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=异常
+	Tag             string    `gorm:"type:varchar(255)" json:"tag"`             //标签，(备用，逗号区分)
+	BridgeId        int       `gorm:"type:int" json:"bridgeId"`                 //桥梁ID
+}
+
+func (LampPole) TableName() string {
+	return "t_dev_lamp_pole"
+}
+
+func (c *LampPole) Delete() error {
+	return GDb.Model(&c).Where("id = ?", c.ID).Updates(map[string]interface{}{"update_time": c.UpdateTime,
+		"update_user": c.UpdateUser, "is_deleted": c.IsDeleted}).Error
+}
+
+func (c LampPole) IsExistedBySN() bool {
+	var count = 0
+	_ = GDb.Model(&c).Where(" pole_sn = ? and is_deleted = ?",
+		c.PoleSN, c.IsDeleted).Count(&count).Error
+	return count > 0
+}
+
+func (c LampPole) IsExistedByNameAndCode() bool {
+	var devices []LampPoleGroup
+	err := GDb.Model(&c).Where("pole_sn = ? and is_deleted = ?",
+		c.TenantId, 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 *LampPole) Create() error {
+	return GDb.Model(&c).Save(&c).Error
+}
+
+func (c *LampPole) Update() error {
+	return GDb.Model(&c).Where(" id = ? ", c.ID).Update(&c).Error
+}
+
+func (c *LampPole) GetDevice() error {
+	err := GDb.Model(&c).Where(" id = ? ", c.ID).First(&c).Error
+	return err
+}
+
+func (c LampPole) GetDevices(offset, limit int) ([]LampPole, error) {
+	var devices []LampPole
+
+	db := GDb.Model(&c)
+	if c.PoleName != "" {
+		db = db.Where("pole_name like ?", "%"+c.PoleName+"%")
+	}
+	if c.PoleSN != "" {
+		db = db.Where("pole_sn like ?", "%"+c.PoleSN+"%")
+	}
+	if c.GroupId != -1 {
+		db = db.Where("group_id = ?", c.GroupId)
+	}
+	if c.BoxId != -1 {
+		db = db.Where("box_id = ?", c.BoxId)
+	}
+	err := db.Offset(offset).Limit(limit).Find(&devices).Error
+	return devices, err
+}
+
+func (c LampPole) GetAllDevices() ([]LampPole, error) {
+	var devices []LampPole
+	err := GDb.Model(&c).Where(" tenant_id = ? and is_deleted = ? ", c.TenantId, c.IsDeleted).Scan(&devices).Error
+	return devices, err
+}

app/dao/lampPoleGroupDao.go

@@ -7,17 +7,17 @@ import (
 
 //LampPoleGroup 灯杆分组
 type LampPoleGroup struct {
-	ID            int       `gorm:"primary_key" `       //编号
-	PoleGroupName string    `gorm:"type:varchar(64)"`   //分组名称
-	TenantId      string    `gorm:"type:varchar(12)"`   //租户ID
-	CreateTime    time.Time `gorm:"type:datetime"`      //新增时间
-	CreateUser    string    `gorm:"type:varchar(60)"`   //新增记录操作用户ID
-	UpdateTime    time.Time `gorm:"type:datetime"`      //修改时间
-	UpdateUser    string    `gorm:"type:varchar(60)"`   //修改用户
-	IsDeleted     int       `gorm:"type:int;default 0"` //是否删除 0=未删除,1=删除
-	Tag           string    `gorm:"type:varchar(255)"`  //标签，(备用，逗号区分)
-	Remark        string    `gorm:"type:varchar(255)"`  //备注
-	CountLampPole int       `gorm:"type:int"`           //灯杆数
+	ID            int       `gorm:"primary_key" json:"id"`                 //编号
+	PoleGroupName string    `gorm:"type:varchar(64)" json:"poleGroupName"` //分组名称
+	TenantId      string    `gorm:"type:varchar(12)" json:"tenantId"`      //租户ID
+	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=删除
+	Tag           string    `gorm:"type:varchar(255)" json:"tag"`          //标签，(备用，逗号区分)
+	Remark        string    `gorm:"type:varchar(255)" json:"remark"`       //备注
+	CountLampPole int       `gorm:"type:int" json:"countLampPole"`         //灯杆数
 }
 
 func (LampPoleGroup) TableName() string {

app/middleware/checkAuth.go

@@ -1,14 +1,11 @@
 package middleware
 
 import (
-	"fmt"
 	"github.com/gin-gonic/gin"
 )
 
 func CheckAuth() gin.HandlerFunc {
 	return func(context *gin.Context) {
-		fmt.Println("鉴权中间件")
-
 		// TODO...
 
 		// 前置中间件

app/middleware/checkLogin.go

@@ -1,13 +1,11 @@
 package middleware
 
 import (
-	"fmt"
 	"github.com/gin-gonic/gin"
 )
 
 func CheckLogin() gin.HandlerFunc {
 	return func(ctx *gin.Context) {
-		fmt.Println("登录验证中间件")
 		// 前置中间件
 		ctx.Next()
 	}

app/model/common.go

@@ -0,0 +1,5 @@
+package model
+
+const (
+	RepeatedPrompts = "编码不能重复，请重新填写！"
+)

app/model/lampPole.go

@@ -0,0 +1,53 @@
+package model
+
+import (
+	"iot_manager_service/app/dao"
+)
+
+type LampPoleDetail struct {
+	dao.LampPole
+	IsCrossName       string          `json:"isCrossName"`           //是否路口名称
+	TagName           string          `json:"tagName"`               //标签(中文)
+	ProvincesName     string          `json:"provincesName"`         //省市区组合地址
+	GatewaySn         string          `json:"gatewaySn"`             //网关编码
+	BoxSn             string          `json:"boxSn"`                 //配电箱编码
+	RunState          string          `json:"runState"`              //运行状态
+	PoleGroupName     string          `json:"poleGroupName"`         //灯杆分组名称
+	BoxName           string          `json:"boxName"`               //配电箱名称
+	AlarmTerminalList []AlarmTerminal `json:"akeyAlarmTerminalList"` //一键告警集合
+	CameraList        []Camera        `json:"cameraList"`            //摄像头集合
+	CaptureUnitList   []CaptureUnit   `json:"captureUnitList"`       //抓拍单元集合
+	GatewayList       []Gateway       `json:"gatewayList"`           //网关集合
+	InfoBoardList     []InfoBoard     `json:"infoBoardList"`         //信息屏集合
+	IpBroadcastList   []IpBroadcast   `json:"ipBroadcastList"`       //IP音柱集合
+	LightControlList  []LightControl  `json:"lightControlList"`      //灯控集合
+	SensorList        []Sensor        `json:"sensorList"`            //环境监测集合
+	ZigbeeList        []Zigbee        `json:"zigbeeList"`            //ZigBee集合
+}
+
+type AlarmTerminal struct {
+}
+type CaptureUnit struct {
+}
+type Gateway struct {
+}
+type IpBroadcast struct {
+}
+type LightControl struct {
+}
+type Sensor struct {
+}
+type Zigbee struct {
+}
+
+type RspLampPoleList struct {
+	Records []LampPoleDetail `json:"records"` //记录列表
+	Current int              `json:"current"` //当前分页
+	Size    int              `json:"size"`    //每页数量
+	Total   int              `json:"total"`   //总数
+	Pages   int              `json:"pages"`   //总页数
+}
+
+type ReqLampPoleRemove struct {
+	IDs int `json:"ids"` //分组编码
+}

app/model/lampPoleGroup.go

@@ -1,43 +1,36 @@
 package model
 
-import "time"
-
-type ReqLampPoleGroupSubmit struct {
-	ID             int          `json:"id"`             //分组编码
-	PoleGroupName  string       `json:"poleGroupName"`  //分组名
-	CountLampPole  int          `json:"countLampPole"`  //灯杆数
-	Remark         string       `json:"remark"`         //备注
-	TenantId       string       `json:"tenantId"`       //租户ID
-	CreateTime     time.Time    `json:"createTime"`     //新增时间
-	CreateUser     string       `json:"createUser"`     //新增记录操作用户ID
-	UpdateTime     time.Time    `json:"updateTime"`     //修改时间
-	UpdateUser     string       `json:"updateUser"`     //修改用户
-	IsDeleted      int          `json:"isDeleted"`      //是否删除 0=未删除,1=删除
-	Tag            string       `json:"tag"`            //标签，(备用，逗号区分)
-	PublicName     string       `json:"publicName"`     //标节目发布时使用
-	LampPoleVOList []lampPoleVO `json:"lampPoleVOList"` //分组下的所有灯杆集合
-	CameraList     []camera     `json:"cameraList"`     //智能安防中调用摄像头直播列表
-	SwitchBoxList  []switchBox  `json:"switchBoxList"`  //智能安防中调用配电箱直播列表
-	InfoBoardList  []infoBoard  `json:"infoBoardList"`  //节目组下查询分组下的信息屏集合
+import (
+	"iot_manager_service/app/dao"
+)
+
+type LampPoleGroupDetail struct {
+	dao.LampPoleGroup
+	PublicName     string       `json:"publicName"`     // 用于虚拟字段组成的树
+	LampPoleVOList []LampPoleVO `json:"lampPoleVOList"` //分组下的所有灯杆集合
+	CameraList     []Camera     `json:"cameraList"`     //智能安防中调用摄像头直播列表
+	SwitchBoxList  []SwitchBox  `json:"switchBoxList"`  //智能安防中调用配电箱直播列表
+	InfoBoardList  []InfoBoard  `json:"infoBoardList"`  //节目组下查询分组下的信息屏集合
 }
 
-type lampPoleVO struct {
+type LampPoleVO struct {
 }
 
-type camera struct {
+type Camera struct {
 }
 
-type switchBox struct {
+type SwitchBox struct {
 }
 
-type infoBoard struct {
+type InfoBoard struct {
 }
 
 type RspLampPoleGroupList struct {
-	Records []ReqLampPoleGroupSubmit `json:"records"` //记录列表
-	Current int                      `json:"current"` //当前分页
-	Size    int                      `json:"size"`    //每页数量
-	Total   int                      `json:"total"`   //总数
+	Records []LampPoleGroupDetail `json:"records"` //记录列表
+	Current int                   `json:"current"` //当前分页
+	Size    int                   `json:"size"`    //每页数量
+	Pages   int                   `json:"pages"`   //总页数
+	Total   int                   `json:"total"`   //总数
 }
 
 type ReqLampPoleGroupRemove struct {

app/service/lampPoleGroupService.go

@@ -3,7 +3,6 @@ package service
 import (
 	"fmt"
 	"iot_manager_service/app/dao"
-	"iot_manager_service/app/model"
 	"iot_manager_service/app/utils"
 	"time"
 )
@@ -25,14 +24,10 @@ func (s *lampPoleGroupService) Get(id int) (*dao.LampPoleGroup, *utils.Errors) {
 	return device, nil
 }
 
-func (s *lampPoleGroupService) CreateOrUpdate(req *model.ReqLampPoleGroupSubmit) *utils.Errors {
-	// 创建查询实例
-	device := dao.LampPoleGroup{
-		PoleGroupName: req.PoleGroupName,
-		TenantId:      "000000", // todo: 使用登录态
-		IsDeleted:     0,
-		UpdateUser:    "TODO", // todo: 使用登录态
-		UpdateTime:    time.Now(),
+func (s *lampPoleGroupService) CreateOrUpdate(req *dao.LampPoleGroup) *utils.Errors {
+	device := req
+	if device.TenantId == "" {
+		device.TenantId = "000000" // todo: 使用登录态
 	}
 
 	if req.ID == 0 {
@@ -40,7 +35,7 @@ func (s *lampPoleGroupService) CreateOrUpdate(req *model.ReqLampPoleGroupSubmit)
 		device.CreateUser = "TODO" // todo: 使用登录态
 
 		if device.IsExistedByName() {
-			fmt.Printf("Create GetDeviceID err \n")
+			fmt.Printf("Create IsExistedByName \n")
 			return utils.ParamsInvalidResponse("列表中存在重名,请更改灯杆分组名称！", nil)
 		}
 		if err := device.Create(); err != nil {
@@ -50,8 +45,10 @@ func (s *lampPoleGroupService) CreateOrUpdate(req *model.ReqLampPoleGroupSubmit)
 		return utils.SuccessResponse(utils.Succeeded, nil)
 	}
 
-	device.ID = req.ID
+	device.UpdateUser = "TODO" // todo: 使用登录态
+	device.UpdateTime = time.Now()
 	if device.IsExistedByNameAndCode() {
+		fmt.Printf("Update IsExistedByNameAndCode \n")
 		return utils.ParamsInvalidResponse("列表中存在重名,请更改灯杆分组名称！", nil)
 	}
 

app/service/lampPoleService.go

@@ -0,0 +1,175 @@
+package service
+
+import (
+	"fmt"
+	"iot_manager_service/app/dao"
+	"iot_manager_service/app/model"
+	"iot_manager_service/app/utils"
+	"time"
+)
+
+// 中间件管理服务
+var LampPoleService = new(lampPoleService)
+
+type lampPoleService struct{}
+
+func (s *lampPoleService) Get(id int) (*dao.LampPole, *utils.Errors) {
+	// 创建查询实例
+	device := &dao.LampPole{
+		ID: id,
+	}
+	err := device.GetDevice()
+	if err != nil {
+		return nil, utils.FailResponse(err.Error(), nil)
+	}
+	//todo runstate 需要使用各个设备的状态来处理
+	return device, nil
+}
+
+func (s *lampPoleService) GetRelevanceDetail(id int) (*model.LampPoleDetail, *utils.Errors) {
+	// 创建查询实例
+	device := &dao.LampPole{
+		ID: id,
+	}
+	err := device.GetDevice()
+	if err != nil {
+		return nil, utils.FailResponse(err.Error(), nil)
+	}
+	//todo get gateway ipBroadcast lightcontroller... list
+	return &model.LampPoleDetail{
+		LampPole:          *device,
+		AlarmTerminalList: nil,
+		CameraList:        nil,
+		CaptureUnitList:   nil,
+		GatewayList:       nil,
+		InfoBoardList:     nil,
+		IpBroadcastList:   nil,
+		LightControlList:  nil,
+		SensorList:        nil,
+		ZigbeeList:        nil,
+	}, nil
+}
+
+func (s *lampPoleService) CreateOrUpdate(req *dao.LampPole) *utils.Errors {
+	device := req
+	if device.TenantId == "" {
+		device.TenantId = "000000" // todo: 使用登录态
+	}
+	device.CoordType = 1
+
+	if device.ID == 0 {
+		device.CreateTime = time.Now()
+		device.CreateUser = "TODO" // todo: 使用登录态
+
+		if device.IsExistedBySN() {
+			fmt.Printf("Create IsExistedBySN \n")
+			return utils.ParamsInvalidResponse(model.RepeatedPrompts, nil)
+		}
+		fmt.Printf("device = %+v \n", device)
+		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 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 *lampPoleService) List(searchValue, groupId, boxId string, current, size int) ([]dao.LampPole, *utils.Errors) {
+	device := dao.LampPole{}
+	if searchValue != "" {
+		device.PoleSN = searchValue
+		device.PoleName = searchValue
+	}
+
+	device.GroupId = utils.StringToInt(groupId)
+	device.BoxId = utils.StringToInt(boxId)
+
+	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
+}
+
+func (s *lampPoleService) Remove(id int) *utils.Errors {
+	// 创建查询实例
+	device := &dao.LampPole{
+		ID:         id,
+		IsDeleted:  1,
+		UpdateUser: "TODO", // todo 使用登录态
+		UpdateTime: time.Now(),
+	}
+
+	//todo
+	// service.lampPoleService.CountRelation()
+
+	//todo operation record
+	err := device.Delete()
+	if err != nil {
+		return utils.FailResponse(err.Error(), nil)
+	}
+	return nil
+}
+
+func (s *lampPoleService) GetList() ([]dao.LampPole, *utils.Errors) {
+	// todo use redis cache
+	device := &dao.LampPole{
+		TenantId:  "000000", // todo 使用登录态
+		IsDeleted: 0,
+	}
+	devices, err := device.GetAllDevices()
+	if err != nil {
+		return nil, utils.FailResponse(err.Error(), nil)
+	}
+
+	return devices, nil
+}
+
+func (s *lampPoleService) GetFiltration() ([]dao.LampPole, *utils.Errors) {
+	// todo use redis cache
+	device := &dao.LampPole{
+		TenantId:  "000000", // todo 使用登录态
+		IsDeleted: 0,
+	}
+
+	//todo
+	// get t_dev_light_control _id
+	// Ids := lightControl.GetIds()
+
+	devices, err := device.GetAllDevices()
+	if err != nil {
+		return nil, utils.FailResponse(err.Error(), nil)
+	}
+
+	return devices, nil
+}
+
+func (s *lampPoleService) GetTree() ([]dao.LampPole, *utils.Errors) {
+	// todo use redis cache
+	device := &dao.LampPole{
+		TenantId:  "000000", // todo 使用登录态
+		IsDeleted: 0,
+	}
+
+	//todo lampPole getALlDevice
+
+	devices, err := device.GetAllDevices()
+	if err != nil {
+		return nil, utils.FailResponse(err.Error(), nil)
+	}
+
+	return devices, nil
+}

app/utils/common.go

@@ -0,0 +1,13 @@
+package utils
+
+import "strconv"
+
+func StringToInt(id string) int {
+	if id != "" {
+		id, err := strconv.Atoi(id)
+		if err == nil {
+			return id
+		}
+	}
+	return -1
+}