在线客服系统源码开发实战总结：Golang实现CMS内容管理增删查改功能 - ToB企服应用市场:ToB评测及商务社交产业平台

DROP TABLE IF EXISTS `cms_cate`;
CREATE TABLE `cms_cate` (
`id` int(11) NOT NULL AUTO_INCREMENT,
`cat_name` varchar(50) NOT NULL DEFAULT '' COMMENT '分类名称',
`created_at` timestamp NOT NULL DEFAULT CURRENT_TIMESTAMP COMMENT '创建时间',
PRIMARY KEY (`id`) COMMENT '自增主键索引'
) ENGINE=InnoDB DEFAULT CHARSET=utf8mb4 COMMENT 'CMS分类表';
DROP TABLE IF EXISTS `cms_news`;
CREATE TABLE `cms_news` (
`id` int(11) NOT NULL AUTO_INCREMENT,
`title` varchar(500) COLLATE utf8mb4_general_ci NOT NULL DEFAULT '' COMMENT '标题',
`content` text COLLATE utf8mb4_general_ci COMMENT '内容',
`cat_id` int(11) NOT NULL DEFAULT '0' COMMENT '分类ID',
`created_at` timestamp NOT NULL DEFAULT CURRENT_TIMESTAMP COMMENT '创建时间',
PRIMARY KEY (`id`) COMMENT '自增主键索引'
) ENGINE=InnoDB DEFAULT CHARSET=utf8mb4 COMMENT 'CMS内容表';

复制代码

type CmsCate struct {
Id uint `json:"id"`
CatName string `json:"cat_name"`
CreatedAt types.Time `json:"created_at"`
}
type CmsNews struct {
Id uint `json:"id"`
Title string `json:"title"`
Content string `json:"content"`
CreatedAt types.Time `json:"created_at"`
}

复制代码

package types
import (
"database/sql/driver"
"fmt"
"time"
)
type Time struct {
time.Time
}
func (t Time) MarshalJSON() ([]byte, error) {
localTime := t.Format("2006-01-02 15:04:05")
return []byte(fmt.Sprintf(`"%s"`, localTime)), nil
}
func (t Time) Value() (driver.Value, error) {
var zeroTime time.Time
if t.Time.UnixNano() == zeroTime.UnixNano() {
return nil, nil
}
return t.Time, nil
}
func (t *Time) Scan(v interface{}) error {
value, ok := v.(time.Time)
if ok {
*t = Time{Time: value}
return nil
}
return fmt.Errorf("can not convert %v to timestamp", v)
}

复制代码

/*内容表*/
//根据条件查询条数
func CountCmsNews(query interface{}, args ...interface{}) uint {
var v uint
DB.Table("cms_news").Where(query, args...).Count(&v)
return v
}
//根据条件更新
func (this *CmsNews) SaveCmsNews(query interface{}, args ...interface{}) error {
db := DB.Table("cms_news").Where(query, args...).Update(this)
return db.Error
}
//增加数据
func (this *CmsNews) AddCmsNews() error {
return DB.Create(this).Error
}
//根据条件查询分页列表
func FindCmsNews(page, pagesize int, query interface{}, args ...interface{}) []CmsNews {
offset := (page - 1) * pagesize
var res []CmsNews
DB.Table("cms_news").Where(query, args...).Order("id desc").Offset(offset).Limit(pagesize).Find(&res)
return res
}
//根据条件删除
func DelCmsNews(query interface{}, args ...interface{}) error {
return DB.Where(query, args...).Delete(&CmsNews{}).Error
}
/*分类表*/
//根据条件分类
func (this *CmsCate) SaveCmsCate(query interface{}, args ...interface{}) error {
db := DB.Table("cms_cate").Where(query, args...).Update(this)
return db.Error
}
//增加分类
func (this *CmsCate) AddCmsCate() error {
return DB.Create(this).Error
}
//根据条件查询分类列表
func FindCmsCate(page, pagesize int, query interface{}, args ...interface{}) []CmsCate {
offset := (page - 1) * pagesize
var res []CmsCate
DB.Table("cms_cate").Where(query, args...).Order("id desc").Offset(offset).Limit(pagesize).Find(&res)
return res
}
//根据条件删除分类
func DelCmsCate(query interface{}, args ...interface{}) error {
return DB.Where(query, args...).Delete(&CmsCate{}).Error
}

复制代码

//系统相关
systemGroup := engine.Group("/system")
systemGroup.Use()
{
//分类列表
systemGroup.GET("/cmsCate", controller.GetCmsCate)
//删除分类
systemGroup.GET("/delCmsCate", controller.DelCmsCate)
//增加或编辑分类
systemGroup.POST("/cmsCate", controller.PostCmsCate)
//CMS内容列表
systemGroup.GET("/cmsNews", controller.GetCmsNews)
//增加或编辑内容
systemGroup.POST("/cmsNews", controller.PostCmsNews)
//删除内容
systemGroup.GET("/delCmsNews", controller.DelCmsNews)
}

复制代码