opms_backend/opms_parent/app/service/base/base_sales_region.go

package base

import (
	"context"
	"strconv"

	"github.com/gogf/gf/errors/gerror"
	"github.com/gogf/gf/frame/g"
	"github.com/gogf/gf/os/gtime"
	"github.com/gogf/gf/util/gconv"

	"dashoo.cn/micro/app/dao/base"
	model "dashoo.cn/micro/app/model/base"
	"dashoo.cn/micro/app/service"
)

type salesRegionService struct {
	*service.ContextService
	Dao    *base.BaseSalesRegionDao
	Detail *base.BaseSalesRegionDetailDao
}

func NewSalesRegionService(ctx context.Context) (svc *salesRegionService, err error) {
	svc = new(salesRegionService)
	if svc.ContextService, err = svc.Init(ctx); err != nil {
		return nil, err
	}
	svc.Dao = base.NewBaseSalesRegionDao(svc.Tenant)
	svc.Detail = base.NewBaseSalesRegionDetailDao(svc.Tenant)

	return svc, nil
}

//获取区域
func (p *salesRegionService) GetListRegion() (RegionList []*model.RegionRep) {
	regionModel := p.Dao.M
	err := regionModel.Order("id asc").Scan(&RegionList)
	if err != nil {
		g.Log().Error(err)
		err = gerror.New("获取数据失败")
		return
	}
	return
}

//创建区域
func (p *salesRegionService) Create(req *model.AddRegionReq) (err error) {

	Model := p.Dao.M
	regionData := new(model.BaseSalesRegion)
	if err = gconv.Struct(req, regionData); err != nil {
		return
	}
	service.SetCreatedInfo(regionData, p.GetCxtUserId(), p.GetCxtUserName())
	regionData.RegionCode = strconv.Itoa(int(gtime.Timestamp()))
	service.SetCreatedInfo(regionData, p.GetCxtUserId(), p.GetCxtUserName())
	_, err = Model.Insert(regionData)
	if err != nil {
		return err
	}
	return nil
}