一键求助记录 完成

app/record/controller/aKeyAlarmRecordController.go

@@ -0,0 +1,90 @@
+package controller
+
+import (
+	"github.com/gin-gonic/gin"
+	"iot_manager_service/app/record/dao"
+	"iot_manager_service/app/record/service"
+	"iot_manager_service/util/common"
+	"math"
+	"net/http"
+	"strconv"
+)
+
+var AKeyAlarmRecord = new(aKeyAlarmRecordCtl)
+
+type aKeyAlarmRecordCtl struct{}
+
+type AKeyAlarmRecordRespose struct {
+	Records []dao.AkeyAlarmRecord `json:"records"` //记录列表
+	Current int                   `json:"current"` //当前分页
+	Size    int                   `json:"size"`    //每页数量
+	Total   int                   `json:"total"`   //总数
+	Pages   int                   `json:"pages"`   //总页数
+}
+
+func (c *aKeyAlarmRecordCtl) List(ctx *gin.Context) {
+	searchValue := ctx.Query("searchValue")
+	start := ctx.Query("queryStartTime")
+	end := ctx.Query("queryEndTime")
+	serveId := ctx.Query("serveId")
+	current, _ := strconv.Atoi(ctx.Query("current"))
+	size, _ := strconv.Atoi(ctx.Query("size"))
+	if current == 0 {
+		current = 1
+	}
+	if size <= 0 || size > 100 {
+		size = 10
+	}
+	id := -1
+	if serveId != "" {
+		id, _ = strconv.Atoi(serveId)
+	}
+
+	records, err := service.AKeyAlarmRecordService.List(searchValue, start, end, id, current, size)
+	if err != nil {
+		ctx.JSON(http.StatusOK, err)
+		return
+	}
+	pages := math.Ceil(float64(len(records)) / float64(size))
+	rsp := AKeyAlarmRecordRespose{
+		Current: current,
+		Size:    size,
+		Total:   len(records),
+		Pages:   int(pages),
+		Records: records,
+	}
+	ctx.JSON(http.StatusOK, common.SuccessResponse(common.Succeeded, rsp))
+}
+
+// refresh 同步sos记录
+func (c *aKeyAlarmRecordCtl) Refresh(ctx *gin.Context) {
+	recordService := service.AKeyAlarmRecordService
+	go func() {
+		recordService.Refresh()
+	}()
+	ctx.JSON(http.StatusOK, common.SuccessResponse(common.Succeeded, nil))
+}
+
+// Detail 查看详情
+func (c *aKeyAlarmRecordCtl) Detail(ctx *gin.Context) {
+	id, _ := strconv.Atoi(ctx.Query("id"))
+	record, err := service.AKeyAlarmRecordService.Detail(id)
+	if err != nil {
+		ctx.JSON(http.StatusOK, err)
+		return
+	}
+	ctx.JSON(http.StatusOK, common.SuccessResponse(common.Succeeded, record))
+}
+
+// Dispose 添加备注
+func (c *aKeyAlarmRecordCtl) Dispose(ctx *gin.Context) {
+	id, _ := strconv.Atoi(ctx.Query("id"))
+	remark := ctx.Query("remark")
+	err := service.AKeyAlarmRecordService.UpdateRemark(id, remark)
+	if err != nil {
+		ctx.JSON(http.StatusOK, err)
+		return
+	}
+
+	ctx.JSON(http.StatusOK, common.SuccessResponse(common.Succeeded, nil))
+}

app/record/edge_service/recordAlarmSos.go

@@ -0,0 +1,62 @@
+package edge_service
+
+import (
+	"encoding/json"
+	"fmt"
+	"io/ioutil"
+	"iot_manager_service/config"
+	"net/http"
+	url2 "net/url"
+)
+
+type RecordAlarmSos struct{}
+
+type RecordAlarmSosReq struct {
+	Code int                  `json:"code"`
+	Msg  string               `json:"msg"`
+	Data []RecordAlarmSosData `json:"data"`
+}
+
+type RecordAlarmSosData struct {
+	ID        int     `json:"id"`
+	Code      string  `json:"code"`
+	Tstart    string  `json:"tstart"`
+	Tend      string  `json:"tend"`
+	Duration  float64 `json:"duration"`
+	Updatedat string  `json:"updatedat"`
+}
+
+// SyncRecord 同步sos一键求助数据
+func (r *RecordAlarmSos) SyncRecord(maxId int64, maxUpDateTime string) ([]RecordAlarmSosData, error) {
+	cfg := config.Instance()
+	api := cfg.Foreign.IotEdgeUrl + "/data/v1/sos/sync"
+	url := fmt.Sprintf("%v?id=%d&&updatedat=%v", api, maxId, url2.QueryEscape(maxUpDateTime))
+	//fmt.Printf("url = %v", url)
+	method := "GET"
+	client := &http.Client{}
+	req, err := http.NewRequest(method, url, nil)
+
+	if err != nil {
+		return nil, err
+	}
+	res, err := client.Do(req)
+	if err != nil {
+		return nil, err
+	}
+	defer res.Body.Close()
+	body, err := ioutil.ReadAll(res.Body)
+	if err != nil {
+		return nil, err
+	}
+	//fmt.Printf("body = %v", string(body))
+	result := RecordAlarmSosReq{}
+	err = json.Unmarshal(body, &result)
+	if err != nil {
+		return nil, err
+	}
+	if result.Code != 0 {
+		panic(result.Msg)
+	}
+	//fmt.Printf("result.Data = %v", result.Data)
+	return result.Data, nil
+}