gas-cylinder-api/app/admin/service/gas_cylinder.go

package service

import (
	"encoding/json"
	"errors"
	"gas-cylinder-api/app/admin/model"
	"gas-cylinder-api/app/admin/service/dto"
	"gas-cylinder-api/common/actions"
	cDto "gas-cylinder-api/common/dto"
	"gas-cylinder-api/common/global"
	model2 "gas-cylinder-api/common/model"
	"github.com/go-resty/resty/v2"
	"gogs.baozhida.cn/zoie/OAuth-core/service"
	"gorm.io/gorm"
)

type GasCylinder struct {
	service.Service
}

// GetPage 获取GasCylinder列表
func (e *GasCylinder) GetPage(c *dto.GasCylinderGetPageReq, list *[]model.GasCylinder, count *int64, p *actions.DataPermission) error {
	var err error
	var data model.GasCylinder

	err = e.Orm.Model(&data).
		Scopes(
			cDto.MakeCondition(c.GetNeedSearch()),
			cDto.Paginate(c.GetPageSize(), c.GetPageIndex()),
			actions.Permission(data.TableName(), p),
		).
		Find(list).Limit(-1).Offset(-1).
		Count(count).Error
	if err != nil {
		e.Log.Errorf("db error: %s", err)
		return global.GetFailedErr
	}
	return nil
}

// Get 获取GasCylinder对象
func (e *GasCylinder) Get(d *dto.GasCylinderGetReq, data *model.ProvGasCylinder, p *actions.DataPermission) error {
	// TODO 通过省平台获取气瓶详情

	client := resty.New()

	resp, err := client.R().Get("https://mock.apifox.com/m2/4037076-0-default/151344663")
	if err != nil {
		e.Log.Errorf("db error: %s", err)
		return global.GetFailedErr
	}
	err = json.Unmarshal(resp.Body(), data)
	if err != nil {
		e.Log.Errorf("json Unmarshal err: %s", err)
		return global.GetFailedErr
	}
	obj := model.GasCylinder{
		ProVariety:   data.ProVariety,
		ProName:      data.ProName,
		ProNo:        data.ProNo,
		FillMedia:    data.FillMedia,
		MakeUnit:     data.MakeUnit,
		MakeTime:     data.MakeTime,
		WorkPressure: data.WorkPressure,
		//InnerCode:     data.InnerCode,
		Volume:        data.Volume,
		CheckTime:     data.CheckTime,
		NextCheckTime: data.NextCheckTime,
		ProUuid:       data.ProUuid,
		Uid:           data.Uid,
		ProductId:     data.ProductId,
		DeadlineTime:  data.DeadlineTime,
		CheckInTime:   data.CheckInTime,
		DeptBy: model2.DeptBy{
			DeptId: p.DeptId,
		},
	}
	//e.Orm.Create(&obj)

	err = e.Orm.Where("inner_code = ?", d.GetInnerCode()).Updates(&obj).Error
	if err != nil {
		e.Log.Errorf("db error: %s", err)
		if errors.Is(err, gorm.ErrRecordNotFound) {
			return global.GetNotFoundOrNoPermissionErr
		}
		return global.GetFailedErr
	}

	data.InnerCode = d.InnerCode

	return nil
}