0809PM

controllers/goods/goods.go

@@ -0,0 +1,118 @@
+package goods
+
+import (
+	"spaceofcheng/services/controllers"
+	"spaceofcheng/services/models/model"
+	"spaceofcheng/services/service/goods"
+)
+
+// GoodsController 商品
+type GoodsController struct {
+	dao *goods.GoodsServ
+	controllers.BaseController
+}
+
+// Constructor 初始化 Controller
+// @Title Constructor
+// @Description 初始化 Controller, 系统自动调用
+func (c *GoodsController) Constructor() {
+	c.dao = goods.NewGoodsServ(c.Context)
+}
+
+// GetGoodsType 获取商品分类列表
+func (c *GoodsController) GetGoodsType() {
+	caseids := c.GetString("caseid")
+	if caseids == "" {
+		cases := c.Context.Get("cases").([]model.SysUserCase)
+		caseids = c.GetCaseIDs(cases)
+	}
+	page, _ := c.GetInt("page")
+	pageSize, _ := c.GetInt("pagesize")
+	goodstype, err := c.dao.GetGoodsType(caseids, page, pageSize)
+	if err != nil {
+		c.ResponseError(err)
+	}
+	c.ResponseJSON(goodstype)
+}
+
+// GetGoodsTypeByID 根据ID获取商品分类
+func (c *GoodsController) GetGoodsTypeByID() {
+	typeid := c.GetString(":typeid")
+	goodsType, err := c.dao.GetGoodsTypeByID(typeid)
+	if err != nil {
+		c.ResponseError(err)
+	}
+	c.ResponseJSON(goodsType)
+}
+
+// SaveGoodsType 保存商品分类
+func (c *GoodsController) SaveGoodsType() {
+	goodsType := model.TdGoodsType{}
+	if err := c.ParseForm(&goodsType); err != nil {
+		c.ResponseError(err)
+	}
+	newtype, err := c.dao.SaveGoodsType(goodsType)
+	if err != nil {
+		c.ResponseError(err)
+	}
+	c.ResponseJSON(newtype)
+}
+
+// DelGoodsType 删除商品分类
+func (c *GoodsController) DelGoodsType() {
+	typeid := c.GetString(":typeid")
+	err := c.dao.DelGoodsType(typeid)
+	if err != nil {
+		c.ResponseError(err)
+	}
+	c.ResponseJSON("删除成功！")
+}
+
+// GetGoodsSpec 获取商品规格列表
+func (c *GoodsController) GetGoodsSpec() {
+	caseids := c.GetString("caseid")
+	if caseids == "" {
+		cases := c.Context.Get("cases").([]model.SysUserCase)
+		caseids = c.GetCaseIDs(cases)
+	}
+	page, _ := c.GetInt("page")
+	pageSize, _ := c.GetInt("pagesize")
+	goodsSpec, err := c.dao.GetGoodsSpec(caseids, page, pageSize)
+	if err != nil {
+		c.ResponseError(err)
+	}
+	c.ResponseJSON(goodsSpec)
+}
+
+// GetGoodsSpecByID 根据ID获取商品分类
+func (c *GoodsController) GetGoodsSpecByID() {
+	specid := c.GetString(":specid")
+	goodsSpec, err := c.dao.GetGoodsSpecByID(specid)
+	if err != nil {
+		c.ResponseError(err)
+	}
+	c.ResponseJSON(goodsSpec)
+}
+
+// SaveGoodsSpec 保存商品分类
+func (c *GoodsController) SaveGoodsSpec() {
+	goodsSpec := model.TdSpec{}
+	if err := c.ParseForm(&goodsSpec); err != nil {
+		c.ResponseError(err)
+	}
+	newSpec, err := c.dao.SaveGoodsSpec(goodsSpec)
+	if err != nil {
+		c.ResponseError(err)
+	}
+	c.ResponseJSON(newSpec)
+}
+
+// DelGoodsSpec 删除商品分类
+func (c *GoodsController) DelGoodsSpec() {
+	specid := c.GetString(":specid")
+	err := c.dao.DelGoodsSpec(specid)
+	if err != nil {
+		c.ResponseError(err)
+	}
+	c.ResponseJSON("删除成功！")
+}

models/goods/goods.go

@@ -0,0 +1,21 @@
+package goods
+
+import (
+	"spaceofcheng/services/utils"
+
+	"github.com/go-xorm/xorm"
+)
+
+// GoodsDAO 当前数据库操作对象
+type GoodsDAO struct {
+	ctx *utils.Context
+	db  *xorm.Session
+}
+
+// NewGoodsDAO New Inst
+func NewGoodsDAO(ctx *utils.Context) *GoodsDAO {
+	return &GoodsDAO{
+		ctx: ctx,
+		db:  ctx.DB,
+	}
+}

models/goods/spec.go

@@ -0,0 +1,57 @@
+package goods
+
+import (
+	"spaceofcheng/services/models"
+	"spaceofcheng/services/models/model"
+	"spaceofcheng/services/utils"
+	"strings"
+)
+
+// GetGoodsSpecCount 获取商品规格总数
+func (m *GoodsDAO) GetGoodsSpecCount(caseids string) (int64, error) {
+	total, err := m.db.Where("status>?", models.STATUS_DEL).Count()
+	return total, err
+}
+
+// GetGoodsSpec 根据案场获取商品规格
+func (m *GoodsDAO) GetGoodsSpec(caseids string, page int, pageSize int) ([]model.TdSpec, error) {
+	var goodsSpec []model.TdSpec
+	err := m.db.Where("status>?", models.STATUS_DEL).And("case_id in ('"+strings.Replace(caseids, ",", "','", -1)+"')").Limit(pageSize, page*pageSize).Find(&goodsSpec)
+	return goodsSpec, err
+}
+
+// GetGoodsSpecByID 根据ID获取商品规格
+func (m *GoodsDAO) GetGoodsSpecByID(specid string) (*model.TdSpec, error) {
+	var goodsSpec = model.TdSpec{}
+	_, err := m.db.Where("status>?", models.STATUS_DEL).And("spec_id=?", specid).Get(&goodsSpec)
+	return &goodsSpec, err
+}
+
+// AddGoodsSpec 新增商品规格
+func (m *GoodsDAO) AddGoodsSpec(goodsSpec *model.TdSpec) (*model.TdSpec, error) {
+	goodsSpec.SpecId = utils.GetGUID()
+	_, err := m.db.Insert(goodsSpec)
+	return goodsSpec, err
+}
+
+// UpdateGoodsSpec 修改商品规格
+func (m *GoodsDAO) UpdateGoodsSpec(goodsSpec model.TdSpec) error {
+	var cols = []string{
+		"spec_name",
+	}
+	_, err := m.db.Update(goodsSpec, cols, "spec_id=?", goodsSpec.SpecId)
+	return err
+}
+
+// DelGoodsSpec 刪除商品规格
+func (m *GoodsDAO) DelGoodsSpec(specid string) error {
+	var goodsSpec = model.TdSpec{
+		SpecId: specid,
+		Status: models.STATUS_DEL,
+	}
+	var cols = []string{
+		"status",
+	}
+	_, err := m.db.Update(goodsSpec, cols, "spec_id=?", goodsSpec.SpecId)
+	return err
+}

models/goods/type.go

@@ -0,0 +1,59 @@
+package goods
+
+import (
+	"spaceofcheng/services/models"
+	"spaceofcheng/services/models/model"
+	"spaceofcheng/services/utils"
+	"strings"
+	"time"
+)
+
+// GetGoodsTypeCount 获取商品类型总数
+func (m *GoodsDAO) GetGoodsTypeCount(caseids string) (int64, error) {
+	total, err := m.db.Where("status>?", models.STATUS_DEL).Count()
+	return total, err
+}
+
+// GetGoodsType 根据案场获取商品类型
+func (m *GoodsDAO) GetGoodsType(caseids string, page int, pageSize int) ([]model.TdGoodsType, error) {
+	var goodstype []model.TdGoodsType
+	err := m.db.Where("status>?", models.STATUS_DEL).And("case_id in ('"+strings.Replace(caseids, ",", "','", -1)+"')").Limit(pageSize, page*pageSize).Desc("create_date").Find(&goodstype)
+	return goodstype, err
+}
+
+// GetGoodsTypeByID 根据ID获取商品类型
+func (m *GoodsDAO) GetGoodsTypeByID(typeid string) (*model.TdGoodsType, error) {
+	var goodstype = model.TdGoodsType{}
+	_, err := m.db.Where("status>?", models.STATUS_DEL).And("type_id=?", typeid).Get(&goodstype)
+	return &goodstype, err
+}
+
+// AddGoodsType 新增商品类型
+func (m *GoodsDAO) AddGoodsType(goodsType *model.TdGoodsType) (*model.TdGoodsType, error) {
+	goodsType.TypeId = utils.GetGUID()
+	goodsType.CreateDate = time.Now()
+	_, err := m.db.Insert(goodsType)
+	return goodsType, err
+}
+
+// UpdateGoodsType 修改商品类型
+func (m *GoodsDAO) UpdateGoodsType(goodsType model.TdGoodsType) error {
+	var cols = []string{
+		"type_name",
+	}
+	_, err := m.db.Update(goodsType, cols, "type_id=?", goodsType.TypeId)
+	return err
+}
+
+// DelGoodsType 刪除商品类型
+func (m *GoodsDAO) DelGoodsType(typeid string) error {
+	var goodsType = model.TdGoodsType{
+		TypeId: typeid,
+		Status: models.STATUS_DEL,
+	}
+	var cols = []string{
+		"status",
+	}
+	_, err := m.db.Update(goodsType, cols, "type_id=?", goodsType.TypeId)
+	return err
+}

models/system/user.go

@@ -31,7 +31,7 @@ func NewUserDAO(ctx *utils.Context) *UserDAO {
 func (m *UserDAO) GetUserList(username, typeid, caseids string) ([]model.SysUser, error) {
 	var users []model.SysUser
 	userDAO := m.db.Where(`(status>? and user_name like '%?%' and user_id in 
-		(select user_id from sys_user_tag a inner join sys_tag_case b on a.tag_id=b.tag_id where b.case_id in ('?')))`, models.STATUS_DEL, username, caseids)
+		(select user_id from sys_user_tag a inner join sys_tag_case b on a.tag_id=b.tag_id where b.case_id in ('?')))`, models.STATUS_DEL, username, strings.Replace(caseids, ",", "','", -1))
 
 	if typeid != "" {
 		userDAO.In("user_id", builder.Select("user_id").From("sys_user_type").Where(builder.Eq{"type_id": typeid}))

service/goods/goods.go

@@ -0,0 +1,20 @@
+package goods
+
+import (
+	"spaceofcheng/services/models/goods"
+	"spaceofcheng/services/utils"
+)
+
+// GoodsServ 系统处理
+type GoodsServ struct {
+	ctx *utils.Context
+	dao *goods.GoodsDAO
+}
+
+// NewGoodsServ 初始化
+func NewGoodsServ(ctx *utils.Context) *GoodsServ {
+	return &GoodsServ{
+		ctx: ctx,
+		dao: goods.NewGoodsDAO(ctx),
+	}
+}

service/goods/spec.go

@@ -0,0 +1,51 @@
+package goods
+
+import (
+	"spaceofcheng/services/models/model"
+	"spaceofcheng/services/service"
+)
+
+// GetGoodsSpec 获取商品规格
+func (s *GoodsServ) GetGoodsSpec(caseids string, page int, pageSize int) (map[string]interface{}, error) {
+	if pageSize == 0 {
+		pageSize = service.PAGENUM
+	}
+	specs, err := s.dao.GetGoodsSpec(caseids, page, pageSize)
+	if err != nil {
+		return nil, err
+	}
+	total, err := s.dao.GetGoodsSpecCount(caseids)
+	if err != nil {
+		return nil, err
+	}
+
+	return map[string]interface{}{
+		"list":     specs,
+		"pagesize": pageSize,
+		"pagenum":  total,
+		"page":     page + 1,
+	}, err
+}
+
+// GetGoodsSpecByID 根据商品类型ID获取商品类型
+func (s *GoodsServ) GetGoodsSpecByID(specid string) (*model.TdSpec, error) {
+	goodsSpec, err := s.dao.GetGoodsSpecByID(specid)
+	return goodsSpec, err
+}
+
+// SaveGoodsSpec 保存商品类型
+func (s *GoodsServ) SaveGoodsSpec(goodsSpec model.TdSpec) (*model.TdSpec, error) {
+	var err error
+	if goodsSpec.SpecId == "" {
+		_, err = s.dao.AddGoodsSpec(&goodsSpec)
+	} else {
+		err = s.dao.UpdateGoodsSpec(goodsSpec)
+	}
+	return &goodsSpec, err
+}
+
+// DelGoodsSpec 删除商品类型
+func (s *GoodsServ) DelGoodsSpec(specid string) error {
+	err := s.DelGoodsSpec(specid)
+	return err
+}

service/goods/type.go

@@ -0,0 +1,51 @@
+package goods
+
+import (
+	"spaceofcheng/services/models/model"
+	"spaceofcheng/services/service"
+)
+
+// GetGoodsType 获取商品类型
+func (s *GoodsServ) GetGoodsType(caseids string, page int, pageSize int) (map[string]interface{}, error) {
+	if pageSize == 0 {
+		pageSize = service.PAGENUM
+	}
+	types, err := s.dao.GetGoodsType(caseids, page, pageSize)
+	if err != nil {
+		return nil, err
+	}
+	total, err := s.dao.GetGoodsTypeCount(caseids)
+	if err != nil {
+		return nil, err
+	}
+
+	return map[string]interface{}{
+		"list":     types,
+		"pagesize": pageSize,
+		"pagenum":  total,
+		"page":     page + 1,
+	}, err
+}
+
+// GetGoodsTypeByID 根据商品类型ID获取商品类型
+func (s *GoodsServ) GetGoodsTypeByID(typeid string) (*model.TdGoodsType, error) {
+	goodsType, err := s.dao.GetGoodsTypeByID(typeid)
+	return goodsType, err
+}
+
+// SaveGoodsType 保存商品类型
+func (s *GoodsServ) SaveGoodsType(goodsType model.TdGoodsType) (*model.TdGoodsType, error) {
+	var err error
+	if goodsType.TypeId == "" {
+		_, err = s.dao.AddGoodsType(&goodsType)
+	} else {
+		err = s.dao.UpdateGoodsType(goodsType)
+	}
+	return &goodsType, err
+}
+
+// DelGoodsType 删除商品类型
+func (s *GoodsServ) DelGoodsType(typeid string) error {
+	err := s.DelGoodsType(typeid)
+	return err
+}

service/sys.go

@@ -5,6 +5,10 @@ import (
 	"spaceofcheng/services/utils"
 )
 
+const (
+	PAGENUM = 10
+)
+
 // SysServ 系统处理
 type SysServ struct {
 	ctx *utils.Context