no message

master
zcy 2021-12-09 00:52:31 +08:00
parent e177f9d138
commit 0d00588976
2 changed files with 68 additions and 69 deletions

26
main.go
View File

@ -93,21 +93,20 @@ func InitLogs() {
logs.Init(config.GetLogConfig().Dir, config.GetLogConfig().File, config.GetLogConfig().Level, config.GetLogConfig().SaveFile) logs.Init(config.GetLogConfig().Dir, config.GetLogConfig().File, config.GetLogConfig().Level, config.GetLogConfig().SaveFile)
} }
type WsHandle struct{ type WsHandle struct {
} }
func (this WsHandle) OnDisConected(*network.ConnectionContext) { func (this WsHandle) OnDisConected(*network.ConnectionContext) {
} }
func (this WsHandle) OnConected(c *network.ConnectionContext) { func (this WsHandle) OnConected(c *network.ConnectionContext) {
log.Print(c.IpAdress,c.Cnntime) log.Print(c.IpAdress, c.Cnntime)
} }
func (this WsHandle) OnDataRecv(p *network.ConnectionContext, dat []byte) { func (this WsHandle) OnDataRecv(p *network.ConnectionContext, dat []byte) {
log.Print(p.IpAdress) log.Print(p.IpAdress)
logger.LogRealeaseInfo(string(dat)) logger.LogRealeaseInfo(string(dat))
} }
func main() { func main() {
InitConfig() InitConfig()
InitLogs() InitLogs()
@ -119,8 +118,8 @@ func main() {
r.Use(sessions.Middleware("sess_store", store)) r.Use(sessions.Middleware("sess_store", store))
r.Use(CORSMiddleware) // Cross domain r.Use(CORSMiddleware) // Cross domain
go func () { go func() {
server := network.ServerFactory("0.0.0.0",config.ApiConfig().WsServerConf) server := network.ServerFactory("0.0.0.0", config.ApiConfig().WsServerConf)
server.SetHandle(WsHandle{}) server.SetHandle(WsHandle{})
e := server.Run() e := server.Run()
if nil != e { if nil != e {
@ -162,8 +161,8 @@ func main() {
api.GET("/article_type", controller.ArticlesType) //获取所有文章分类 api.GET("/article_type", controller.ArticlesType) //获取所有文章分类
api.PUT("/article_type", controller.AddArticleType) // 添加文章分类 api.PUT("/article_type", controller.AddArticleType) // 添加文章分类
api.DELETE("/article_type", controller.DeleteArticleType) // 删除文章分类 api.DELETE("/article_type", controller.DeleteArticleType) // 删除文章分类
api.POST("/doc_search_term",controller.SearchArticleES) // 文章内容搜索,基于es的倒排 api.POST("/doc_search_term", controller.SearchArticleES) // 文章内容搜索,基于es的倒排
api.POST("/doc_match_search_hightlight",controller.SearchArticleESHightLight) // 文章内容搜索,基于es的倒排 api.POST("/doc_match_search_hightlight", controller.SearchArticleESHightLight) // 文章内容搜索,基于es的倒排
api.POST("/article_update", controller.UpdateArtilce) //更新文章 api.POST("/article_update", controller.UpdateArtilce) //更新文章
api.GET("/articleCount", controller.GetArticleCount) //获取所有文章个数 api.GET("/articleCount", controller.GetArticleCount) //获取所有文章个数
@ -189,7 +188,6 @@ func main() {
api.GET("/memo", controller.GetMemo) // 单独读取备忘录 api.GET("/memo", controller.GetMemo) // 单独读取备忘录
api.GET("/memocnt", controller.GetMemoCnt) // 单独读取备忘录 api.GET("/memocnt", controller.GetMemoCnt) // 单独读取备忘录
api.GET("doc_groups", controller.GetDocGroup) // 获取所有的文章分组 api.GET("doc_groups", controller.GetDocGroup) // 获取所有的文章分组
api.POST("type_group", controller.GetDocTypeGroup) // 获取类所在的组 api.POST("type_group", controller.GetDocTypeGroup) // 获取类所在的组
api.POST("group_type", controller.GetDoGroupcType) // 获取类所在的组 api.POST("group_type", controller.GetDoGroupcType) // 获取类所在的组
@ -218,11 +216,11 @@ func main() {
api.DELETE("/undo/:id", planController.DeleteUndo) // 删除待办事项 api.DELETE("/undo/:id", planController.DeleteUndo) // 删除待办事项
api.PUT("/doc_template",controller.CreateDocTemplate) // 创建文章模板 api.PUT("/doc_template", controller.CreateDocTemplate) // 创建文章模板
api.POST("/doc_template",controller.UpdateDocTemplate) // 更新文章模板 api.POST("/doc_template", controller.UpdateDocTemplate) // 更新文章模板
api.POST("/get_doc_template",controller.GetDocTemplate) // 获得文章模板 api.POST("/get_doc_template", controller.GetDocTemplate) // 获得文章模板
api.DELETE("/doc_template/:id",controller.DeleteDocTemplate) // 删除文章模板 api.DELETE("/doc_template/:id", controller.DeleteDocTemplate) // 删除文章模板
api.GET("/doc_template/:id",controller.GetDocTemplateId) //获得单个文章模板信息 api.GET("/doc_template/:id", controller.GetDocTemplateId) //获得单个文章模板信息
} }
openapi := r.Group("openapi") openapi := r.Group("openapi")
{ {

View File

@ -90,7 +90,7 @@ UpdateDoc 更新文档
func UpdateDoc(doc Doc) error { func UpdateDoc(doc Doc) error {
sql := fmt.Sprintf(`update doc set doc.author = '%s' ,doc.title = '%s',doc.type = '%d',doc.content = '%s' ,doc.update_time = '%s' ,doc.version = '%d' where doc.id = '%d'; `, sql := fmt.Sprintf(`update doc set doc.author = '%s' ,doc.title = '%s',doc.type = '%d',doc.content = '%s' ,doc.update_time = '%s' ,doc.version = '%d' where doc.id = '%d'; `,
doc.Author, doc.Title, doc.Type, doc.Author, doc.Title, doc.Type,
strings.Replace(doc.Content, "'", "\\'", -1), time.Now().Format("2006-01-02 15:04:05"),doc.Version, doc.ID) strings.Replace(doc.Content, "'", "\\'", -1), time.Now().Format("2006-01-02 15:04:05"), doc.Version, doc.ID)
_, e := db.GetMysqlClient().Query(sql) _, e := db.GetMysqlClient().Query(sql)
if nil != e { if nil != e {
logs.Error(e.Error()) logs.Error(e.Error())
@ -153,6 +153,7 @@ func DeleteArticleType(id int32) error {
return nil return nil
} }
func GetAllDocs() ([]Doc, error) { func GetAllDocs() ([]Doc, error) {
ret := []Doc{} ret := []Doc{}
sql := fmt.Sprintf("select * from doc") sql := fmt.Sprintf("select * from doc")