抓拍单元

app/controller/captureUintController.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,25 +17,156 @@ var CaptureUint = new(captureUintCtl)
 type captureUintCtl struct{}
 
 func (c *captureUintCtl) Detail(ctx *gin.Context) {
+	id, e := strconv.Atoi(ctx.Query("id"))
+	if e != nil {
+		ctx.JSON(http.StatusOK, utils.ParamsInvalidResponse(e.Error(), nil))
+		return
+	}
+	deviceType := ctx.Query("type")
+	if deviceType == model.TypeCapture {
+		device, err := service.CaptureUintService.GetCapture(id)
+		if err != nil {
+			ctx.JSON(http.StatusOK, err)
+			return
+		}
+		ctx.JSON(http.StatusOK, utils.SuccessResponse(utils.Succeeded, device))
+	} else if deviceType == model.TypePoint {
+		device, err := service.CaptureUintService.GetPoint(id)
+		if err != nil {
+			ctx.JSON(http.StatusOK, err)
+			return
+		}
+		ctx.JSON(http.StatusOK, utils.SuccessResponse(utils.Succeeded, device))
+	} else {
+		ctx.JSON(http.StatusOK, utils.ParamsInvalidResponse(model.TypeInvalid, nil))
+	}
 }
 
 func (c *captureUintCtl) CaptureList(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.CaptureUintService.CaptureList(searchValue, current, size)
+	if err != nil {
+		ctx.JSON(http.StatusOK, err)
+		return
+	}
+	pages := math.Ceil(float64(len(devices)) / float64(size))
+	rsp := model.RspCaptureList{
+		Current: current,
+		Size:    size,
+		Total:   len(devices),
+		Pages:   int(pages),
+		Records: devices,
+	}
+
+	ctx.JSON(http.StatusOK, utils.SuccessResponse(utils.Succeeded, rsp))
 }
 
 func (c *captureUintCtl) CaptureSubmit(ctx *gin.Context) {
+	// 参数验证
+	var req *model.CaptureDetail
+	if err := ctx.ShouldBind(&req); err != nil {
+		ctx.JSON(http.StatusOK, utils.ParamsInvalidResponse(err.Error(), nil))
+		return
+	}
+	err := service.CaptureUintService.CaptureSubmit(req)
+	if err != nil {
+		ctx.JSON(http.StatusOK, err)
+		return
+	}
+	ctx.JSON(http.StatusOK, nil)
 }
 
 func (c *captureUintCtl) PointList(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
+	}
 
-func (c *captureUintCtl) PointSubmit(ctx *gin.Context) {
+	devices, err := service.CaptureUintService.PointList(searchValue, current, size)
+	if err != nil {
+		ctx.JSON(http.StatusOK, err)
+		return
+	}
+	pages := math.Ceil(float64(len(devices)) / float64(size))
+	rsp := model.RspPointList{
+		Current: current,
+		Size:    size,
+		Total:   len(devices),
+		Pages:   int(pages),
+		Records: devices,
+	}
+
+	ctx.JSON(http.StatusOK, utils.SuccessResponse(utils.Succeeded, rsp))
 }
 
-func (c *captureUintCtl) Remove(ctx *gin.Context) {
+func (c *captureUintCtl) PointSubmit(ctx *gin.Context) {
+	// 参数验证
+	var req *dao.CheckPoint
+	if err := ctx.ShouldBind(&req); err != nil {
+		ctx.JSON(http.StatusOK, utils.ParamsInvalidResponse(err.Error(), nil))
+		return
+	}
+	err := service.CaptureUintService.PointSubmit(req)
+	if err != nil {
+		ctx.JSON(http.StatusOK, err)
+		return
+	}
+	ctx.JSON(http.StatusOK, nil)
 }
 
 func (c *captureUintCtl) CaptureGetList(ctx *gin.Context) {
+	devices, err := service.CaptureUintService.CaptureGetList()
+	if err != nil {
+		ctx.JSON(http.StatusOK, err)
+		return
+	}
+	ctx.JSON(http.StatusOK, utils.SuccessResponse(utils.Succeeded, devices))
 }
 
 func (c *captureUintCtl) PointGetList(ctx *gin.Context) {
+	devices, err := service.CaptureUintService.PointGetList()
+	if err != nil {
+		ctx.JSON(http.StatusOK, err)
+		return
+	}
+	ctx.JSON(http.StatusOK, utils.SuccessResponse(utils.Succeeded, devices))
+}
+
+func (c *captureUintCtl) Remove(ctx *gin.Context) {
+	var req *model.ReqCaptureRemove
+	if err := ctx.ShouldBindJSON(&req); err != nil {
+		ctx.JSON(http.StatusOK, utils.ParamsInvalidResponse(err.Error(), nil))
+		return
+	}
+	if req.Type == model.TypeCapture {
+		err := service.CaptureUintService.RemoveCapture(req.IDs)
+		if err != nil {
+			ctx.JSON(http.StatusOK, err)
+			return
+		}
+		ctx.JSON(http.StatusOK, utils.SuccessResponse(utils.Succeeded, nil))
+	} else if req.Type == model.TypePoint {
+		err := service.CaptureUintService.RemovePoint(req.IDs)
+		if err != nil {
+			ctx.JSON(http.StatusOK, err)
+			return
+		}
+		ctx.JSON(http.StatusOK, utils.SuccessResponse(utils.Succeeded, nil))
+	} else {
+		ctx.JSON(http.StatusOK, utils.ParamsInvalidResponse(model.TypeInvalid, nil))
+	}
 }

app/dao/captureUintDao.go

@@ -0,0 +1,82 @@
+package dao
+
+import "time"
+
+//CaptureUint 抓拍单元
+type CaptureUint struct {
+	ID                     int       `gorm:"primary_key" json:"id"`                                //编号
+	CaptureName            string    `gorm:"type:varchar(64)" json:"captureName"`                  //设备名称
+	CaptureSN              string    `gorm:"type:varchar(60)" json:"captureSn"`                    //设备序列号
+	PointId                int       `gorm:"type:int" json:"pointId"`                              //卡口ID
+	LampPoleId             int       `gorm:"type:int" json:"lampPoleId"`                           //灯杆ID
+	WayName                string    `gorm:"type:varchar(64)" json:"wayName"`                      //道路名称
+	CaptureDirection       int       `gorm:"type:int" json:"captureDirection"`                     //灯杆sn
+	InstallTime            time.Time `gorm:"type:date" json:"installTime"`                         //安装时间
+	TerrainClearance       float32   `gorm:"type:float(10,1);default 0.0" json:"terrainClearance"` //离地高度(米)
+	CaptureLane            string    `gorm:"type:varchar(120)" json:"captureLane"`                 //抓拍车道
+	VidiconPixel           int       `gorm:"type:int" json:"vidiconPixel"`                         //相机像素
+	VidiconSpecification   string    `gorm:"type:varchar(255)" json:"vidiconSpecification"`        //相机规格
+	RadarCount             int       `gorm:"type:int" json:"radarCount"`                           //雷达数量
+	RadarSpecification     string    `gorm:"type:varchar(255)" json:"radar_specification"`         //雷达规格
+	SuggestSpeed           int       `gorm:"type:int" json:"suggestSpeed"`                         //雷达数量
+	FillLightCount         int       `gorm:"type:int" json:"fillLightCount"`                       //补光灯数量
+	FillLightSpecification string    `gorm:"type:varchar(255)" json:"fillLightSpecification"`      //补光灯规格
+	PowerSpecification     string    `gorm:"type:varchar(255)" json:"powerSpecification"`          //电源规格
+	CaptureIp              string    `gorm:"type:varchar(60)" json:"captureIp"`                    //ip
+	CapturePort            int       `gorm:"type:int" json:"capturePort"`                          //端口
+	GatewayId              int       `gorm:"type:int" json:"gatewayId"`                            //网关ID
+	GatewayName            string    `gorm:"type:varchar(80)" json:"gatewayName"`                  //网关名称
+	GatewaySN              string    `gorm:"type:varchar(30)" json:"gatewaySn"`                    //网关编码
+	TenantId               string    `gorm:"type:varchar(12)" json:"tenantId"`                     //租户ID
+	CreateTime             time.Time `gorm:"type:datetime" json:"createTime"`                      //新增时间
+	CreateUser             string    `gorm:"type:varchar(30)" json:"createUser"`                   //新增记录操作用户ID
+	UpdateTime             time.Time `gorm:"type:datetime" json:"updateTime"`                      //修改时间
+	UpdateUser             string    `gorm:"type:varchar(30)" json:"updateUser"`                   //修改用户
+	IsDeleted              int       `gorm:"type:int;default 0" json:"isDeleted"`                  //是否删除 0=未删除,1=删除
+}
+
+func (CaptureUint) TableName() string {
+	return "t_dev_capture_uint"
+}
+
+func (c CaptureUint) IsExistedBySN() bool {
+	var count = 0
+	_ = GDb.Model(&c).Where("capture_sn = ? and is_deleted = ?",
+		c.CaptureSN, c.IsDeleted).Count(&count).Error
+	return count > 0
+}
+
+func (c *CaptureUint) Create() error {
+	return GDb.Model(&c).Save(&c).Error
+}
+
+func (c *CaptureUint) Update() error {
+	return GDb.Model(&c).Where(" id = ? ", c.ID).Update(&c).Error
+}
+
+func (c *CaptureUint) GetDevice() error {
+	err := GDb.Model(&c).Where(" id = ? ", c.ID).First(&c).Error
+	return err
+}
+
+func (c CaptureUint) GetDevices(offset, limit int) ([]CaptureUint, error) {
+	var Captures []CaptureUint
+	db := GDb.Model(&c)
+	if c.CaptureSN != "" {
+		db = db.Where("capture_name like ? or capture_sn like ?", "%"+c.CaptureSN+"%", "%"+c.CaptureSN+"%")
+	}
+
+	err := db.Where("is_deleted = 0").Offset(offset).Limit(limit).Find(&Captures).Error
+	return Captures, err
+}
+
+func (c *CaptureUint) 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 CaptureUint) GetAllDevices() ([]*CaptureUint, error) {
+	var Captures []*CaptureUint
+	err := GDb.Model(&c).Where(" tenant_id = ? and is_deleted = ? ", c.TenantId, c.IsDeleted).Scan(&Captures).Error
+	return Captures, err
+}

app/dao/checkPointDao.go

@@ -0,0 +1,63 @@
+package dao
+
+import "time"
+
+//CheckPoint 卡口
+type CheckPoint struct {
+	ID            int       `gorm:"primary_key" json:"id"`                  //编号
+	PointName     string    `gorm:"type:varchar(64)" json:"pointName"`      //卡口名称
+	PointSN       string    `gorm:"type:varchar(60)" json:"pointSn"`        //卡口编码
+	PointLocation string    `gorm:"type:varchar(150)" json:"pointLocation"` //卡口位置
+	TenantId      string    `gorm:"type:varchar(12)" json:"tenantId"`       //租户ID
+	CreateTime    time.Time `gorm:"type:datetime" json:"createTime"`        //新增时间
+	CreateUser    string    `gorm:"type:varchar(30)" json:"createUser"`     //新增记录操作用户ID
+	UpdateTime    time.Time `gorm:"type:datetime" json:"updateTime"`        //修改时间
+	UpdateUser    string    `gorm:"type:varchar(30)" json:"updateUser"`     //修改用户
+	IsDeleted     int       `gorm:"type:int;default 0" json:"isDeleted"`    //是否删除 0=未删除,1=删除
+}
+
+func (CheckPoint) TableName() string {
+	return "t_dev_check_point"
+}
+
+func (c CheckPoint) IsExistedBySN() bool {
+	var count = 0
+	_ = GDb.Model(&c).Where("point_sn = ? and is_deleted = ?",
+		c.PointSN, c.IsDeleted).Count(&count).Error
+	return count > 0
+}
+
+func (c *CheckPoint) Create() error {
+	return GDb.Model(&c).Save(&c).Error
+}
+
+func (c *CheckPoint) Update() error {
+	return GDb.Model(&c).Where(" id = ? ", c.ID).Update(&c).Error
+}
+
+func (c *CheckPoint) GetDevice() error {
+	err := GDb.Model(&c).Where(" id = ? ", c.ID).First(&c).Error
+	return err
+}
+
+func (c CheckPoint) GetDevices(offset, limit int) ([]CheckPoint, error) {
+	var Points []CheckPoint
+	db := GDb.Model(&c)
+	if c.PointSN != "" {
+		db = db.Where("point_name like ? or point_sn like ?", "%"+c.PointSN+"%", "%"+c.PointSN+"%")
+	}
+
+	err := db.Where("is_deleted = 0").Offset(offset).Limit(limit).Find(&Points).Error
+	return Points, err
+}
+
+func (c *CheckPoint) 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 CheckPoint) GetAllDevices() ([]*CheckPoint, error) {
+	var Points []*CheckPoint
+	err := GDb.Model(&c).Where(" tenant_id = ? and is_deleted = ? ", c.TenantId, c.IsDeleted).Scan(&Points).Error
+	return Points, err
+}

app/dao/common.go

@@ -36,6 +36,8 @@ func InitDB() {
 			&CameraDevice{},
 			&InfoBoard{},
 			&Alarm{},
+			&CaptureUint{},
+			&CheckPoint{},
 		).Error
 		if err != nil {
 			panic(fmt.Sprintf("AutoMigrate err : %v", err))

app/model/captureUint.go

@@ -0,0 +1,39 @@
+package model
+
+import "iot_manager_service/app/dao"
+
+type CaptureDetail struct {
+	dao.CaptureUint
+	PoleName        string  `json:"poleName"`        //灯杆名称
+	PoleSn          string  `json:"poleSn"`          //灯杆编码
+	PoleLat         float32 `json:"poleLat"`         //灯杆纬度
+	PoleLng         float32 `json:"poleLng"`         //灯杆经度
+	InstallLocation string  `json:"installLocation"` //灯杆地址
+	PointName       string  `json:"pointName"`       //卡口名称
+	PointSn         string  `json:"pointSn"`         //卡口编码
+	PointLocation   string  `json:"pointLocation"`   //卡口位置
+	NetworkState    string  `json:"networkState"`    //通讯状态 1在线2离线
+	EndLineTime     string  `json:"endLineTime"`     //最后在线时间
+}
+
+type RspCaptureList struct {
+	Records []CaptureDetail `json:"records"` //记录列表
+	Current int             `json:"current"` //当前分页
+	Size    int             `json:"size"`    //每页数量
+	Total   int             `json:"total"`   //总数
+	Pages   int             `json:"pages"`   //总页数
+}
+
+type RspPointList struct {
+	Records []dao.CheckPoint `json:"records"` //记录列表
+	Current int              `json:"current"` //当前分页
+	Size    int              `json:"size"`    //每页数量
+	Total   int              `json:"total"`   //总数
+	Pages   int              `json:"pages"`   //总页数
+}
+
+type ReqCaptureRemove struct {
+	IDs  int    `json:"ids"`  //分组编码
+	SN   int    `json:"sn"`   //sn
+	Type string `json:"type"` //类型
+}

app/model/common.go

@@ -10,6 +10,7 @@ const (
 
 	EnableInvalid = "启用禁用参数错误"
 	ParamsInvalid = "非法参数！"
+	TypeInvalid   = "非法类型！"
 )
 
 const (
@@ -26,10 +27,15 @@ const (
 )
 
 const (
-	CameraType_Ball      = 1 //球机
-	CameraType_Gun       = 2 //枪机
-	CameraType_Ball_Name = "球机"
-	CameraType_Gun_Name  = "枪机"
+	CameraTypeBall     = 1 //球机
+	CameraTypeGun      = 2 //枪机
+	CameraTypeBallName = "球机"
+	CameraTypeGunName  = "枪机"
+)
+
+const (
+	TypeCapture = "capture"
+	TypePoint   = "point"
 )
 
 type AlarmTerminal struct {

app/service/GatewayService.go

@@ -168,3 +168,15 @@ func (s *gatewayService) GetRelevanceDetail(id int) (*model.GatewayDetail, *util
 		ZigbeeList:        nil,
 	}, nil
 }
+
+func (s *gatewayService) GetOne(id int) (*dao.Gateway, *utils.Errors) {
+	// 创建查询实例
+	device := &dao.Gateway{
+		ID: id,
+	}
+	err := device.GetDevice()
+	if err != nil {
+		return nil, utils.FailResponse(err.Error(), nil)
+	}
+	return device, nil
+}

app/service/cameraService.go

@@ -71,10 +71,10 @@ func (s *cameraService) Get(id int) (*model.CameraDetail, *utils.Errors) {
 	}
 
 	detail := &model.CameraDetail{CameraDevice: *device}
-	if device.CameraType == model.CameraType_Ball {
-		detail.CameraTypeName = model.CameraType_Ball_Name
-	} else if device.CameraType == model.CameraType_Gun {
-		detail.CameraTypeName = model.CameraType_Gun_Name
+	if device.CameraType == model.CameraTypeBall {
+		detail.CameraTypeName = model.CameraTypeBallName
+	} else if device.CameraType == model.CameraTypeGun {
+		detail.CameraTypeName = model.CameraTypeGunName
 	}
 
 	//todo 获取运行状态

app/service/captureUintService.go

@@ -0,0 +1,224 @@
+package service
+
+import (
+	"fmt"
+	"iot_manager_service/app/dao"
+	"iot_manager_service/app/model"
+	"iot_manager_service/app/utils"
+	"time"
+)
+
+// 中间件管理服务
+var CaptureUintService = new(captureUintService)
+
+type captureUintService struct{}
+
+func (s *captureUintService) CaptureSubmit(req *model.CaptureDetail) *utils.Errors {
+	device := req.CaptureUint
+	if device.TenantId == "" {
+		device.TenantId = "000000" // todo: 使用登录态
+	}
+	device.UpdateUser = "TODO" // todo: 使用登录态
+	device.UpdateTime = time.Now()
+	if gateway, err := GatewayService.GetOne(device.GatewayId); err == nil {
+		device.GatewayName = gateway.GatewayName
+		device.GatewaySN = gateway.GatewaySN
+	}
+
+	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)
+	}
+
+	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 *captureUintService) GetCapture(id int) (*model.CaptureDetail, *utils.Errors) {
+	// 创建查询实例
+	device := &dao.CaptureUint{
+		ID: id,
+	}
+	err := device.GetDevice()
+	if err != nil {
+		return nil, utils.FailResponse(err.Error(), nil)
+	}
+	detail := &model.CaptureDetail{CaptureUint: *device}
+	//todo 获取实时在线最新数据
+	// detail.EndLineTime = *
+	// detail.NetworkState = *
+
+	return detail, nil
+}
+
+func (s *captureUintService) CaptureList(searchValue string, current, size int) ([]model.CaptureDetail, *utils.Errors) {
+	var details []model.CaptureDetail
+	device := dao.CaptureUint{}
+
+	if searchValue != "" {
+		device.CaptureSN = searchValue
+	}
+
+	offset := (current - 1) * size
+	limit := size
+	devices, err := device.GetDevices(offset, limit)
+
+	if err != nil {
+		return nil, utils.FailResponse(err.Error(), nil)
+	}
+
+	for _, d := range devices {
+		details = append(details, model.CaptureDetail{
+			CaptureUint: d,
+			//todo 获取实时在线最新数据
+			// detail.EndLineTime = *
+			// detail.NetworkState = *
+
+		})
+	}
+
+	return details, nil
+}
+
+func (s *captureUintService) CaptureGetList() ([]*dao.CaptureUint, *utils.Errors) {
+	// todo use redis cache
+	device := &dao.CaptureUint{
+		TenantId:  "000000", // todo 使用登录态
+		IsDeleted: 0,
+	}
+	devices, err := device.GetAllDevices()
+	if err != nil {
+		return nil, utils.FailResponse(err.Error(), nil)
+	}
+	for _, d := range devices {
+		d.CaptureName = d.CaptureName + "(" + d.CaptureSN + ")"
+	}
+	return devices, nil
+}
+
+func (s *captureUintService) GetPoint(id int) (*dao.CheckPoint, *utils.Errors) {
+	// 创建查询实例
+	device := &dao.CheckPoint{
+		ID: id,
+	}
+	err := device.GetDevice()
+	if err != nil {
+		return nil, utils.FailResponse(err.Error(), nil)
+	}
+
+	return device, nil
+}
+
+func (s *captureUintService) PointSubmit(req *dao.CheckPoint) *utils.Errors {
+	device := req
+	if device.TenantId == "" {
+		device.TenantId = "000000" // todo: 使用登录态
+	}
+	device.UpdateUser = "TODO" // todo: 使用登录态
+	device.UpdateTime = time.Now()
+
+	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)
+	}
+
+	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 *captureUintService) PointList(searchValue string, current, size int) ([]dao.CheckPoint, *utils.Errors) {
+	device := dao.CheckPoint{}
+	if searchValue != "" {
+		device.PointSN = 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
+}
+
+func (s *captureUintService) PointGetList() ([]*dao.CheckPoint, *utils.Errors) {
+	// todo use redis cache
+	device := &dao.CheckPoint{
+		TenantId:  "000000", // todo 使用登录态
+		IsDeleted: 0,
+	}
+	devices, err := device.GetAllDevices()
+	if err != nil {
+		return nil, utils.FailResponse(err.Error(), nil)
+	}
+	for _, d := range devices {
+		d.PointName = d.PointName + "(" + d.PointSN + ")"
+	}
+	return devices, nil
+}
+
+func (s *captureUintService) RemoveCapture(id int) *utils.Errors {
+	// 创建查询实例
+	device := &dao.CaptureUint{
+		ID:         id,
+		IsDeleted:  1,
+		UpdateUser: "TODO", // todo 使用登录态
+		UpdateTime: time.Now(),
+	}
+
+	//todo operation record
+	err := device.Delete()
+	if err != nil {
+		return utils.FailResponse(err.Error(), nil)
+	}
+	return nil
+}
+
+func (s *captureUintService) RemovePoint(id int) *utils.Errors {
+	// 创建查询实例
+	device := &dao.CheckPoint{
+		ID:         id,
+		IsDeleted:  1,
+		UpdateUser: "TODO", // todo 使用登录态
+		UpdateTime: time.Now(),
+	}
+
+	//todo operation record
+	err := device.Delete()
+	if err != nil {
+		return utils.FailResponse(err.Error(), nil)
+	}
+	return nil
+}