员工管理

controllers/article/article_controller.go

@@ -24,6 +24,17 @@ func ArticleRouters() {
 	beego.Router("/api/acticle/delete",&ArticleManage{},"Delete:DeleteCategorys")
 	beego.Router("/api/acticle/addvido",&ArticleManage{},"Post:Addvido")
 	beego.Router("/api/acticle/savedraft",&ArticleManage{},"Post:SaveDraft")
+	beego.Router("/api/acticle/prviewArticle",&ArticleManage{},"Post:PrviewArticle")
+	beego.Router("/api/acticle/getarticlePreview",&ArticleManage{},"Get:GetArtilcePreview")
+	beego.Router("/api/acticle/save",&ArticleManage{},"Post:AddDraft")
+	beego.Router("/api/acticle/getEditArticle",&ArticleManage{},"Get:GetArticleInfo")
+	beego.Router("/api/article/Delete",&ArticleManage{},"Delete:DeleteArticle")
+	beego.Router("/api/acticle/getMenus",&ArticleManage{},"Get:GetMenus")
+	beego.Router("/api/acticle/updateArticlesInfo",&ArticleManage{},"Post:UpdataArticleInfo")
+	beego.Router("/api/acticle/previewEditArticle",&ArticleManage{},"Post:PreviewEditArticle")
+	beego.Router("/api/acticle/getPreviewInfo",&ArticleManage{},"Post:GetPreviewInfo")
+	beego.Router("/api/acticle/getAllComment",&ArticleManage{},"Get:GetAllComment")
+	beego.Router("/api/acticle/getArticleCommentDetail",&ArticleManage{},"Get:GetArticleCommentDetail")
 }
 
 type ArticleManage struct {
@@ -108,10 +119,13 @@ func (this *ArticleManage) GetArticleType(){
 
 func (this *ArticleManage) GetAllArticles()  {
 	page, _ := this.GetInt64("page", 1)
+	fmt.Println("页面",page)
 	limit, _ := this.GetInt64("limit", 10)
-	searchKey := this.GetString("search", "")
-	classId,_ := this.GetInt64("classid",0)
-    fmt.Println("页面",page,"限制",limit,"关键字",searchKey,"分类号",classId)
+	fmt.Println("限制",limit)
+	searchKey := this.GetString("keyword", "")
+	classId,_ := this.GetInt64("id",0)
+	status, _ := this.GetInt64("status")
+	fmt.Println("页面",page,"限制",limit,"关键字",searchKey,"分类号",classId,"状态值:",status)
 
 	if page <= 0 {
 		page = 1
@@ -119,10 +133,53 @@ func (this *ArticleManage) GetAllArticles()  {
 	if limit <= 0 {
 		limit = 10
 	}
+
+
 	adminUserInfo := this.GetAdminUserInfo()
 	userOrgID := adminUserInfo.CurrentOrgId
 
-	articles, total, err := article_service.FindAllArticle(userOrgID, page,limit, searchKey, classId)
+	if(status == 1){
+		articles, total, err := article_service.GetPublished(userOrgID, page, limit, searchKey)
+		category, err := article_service.FindCategoryList(userOrgID)
+		if err !=nil{
+			this.ServeFailJsonSend(enums.ErrorCodeDataException, "获取文章分类列表失败")
+			return
+		}
+		this.ServeSuccessJSON(map[string]interface{}{
+			"articles":articles,
+			"total":total,
+			"category":category,
+		})
+	}
+	if(status == 2){
+		articles, total, err := article_service.GetDraftbox(userOrgID, page, limit, searchKey)
+		category, err := article_service.FindCategoryList(userOrgID)
+		if err !=nil{
+			this.ServeFailJsonSend(enums.ErrorCodeDataException, "获取文章分类列表失败")
+			return
+		}
+		this.ServeSuccessJSON(map[string]interface{}{
+			"articles":articles,
+			"total":total,
+			"category":category,
+		})
+	}
+
+	if(status == 3){
+		articles, total, err := article_service.GetNoPass(userOrgID, page, limit, searchKey)
+		category, err := article_service.FindCategoryList(userOrgID)
+		if err !=nil{
+			this.ServeFailJsonSend(enums.ErrorCodeDataException, "获取文章分类列表失败")
+			return
+		}
+		this.ServeSuccessJSON(map[string]interface{}{
+			"articles":articles,
+			"total":total,
+			"category":category,
+		})
+	}
+
+	articles, total, err := article_service.FindAllArticle(userOrgID, page,limit, searchKey,classId)
 	fmt.Println("文章内容是是么",articles)
 	fmt.Println("total",total)
 	fmt.Println("err",err)
@@ -453,4 +510,367 @@ func (this *ArticleManage) SaveDraft()  {
 	this.ServeSuccessJSON(map[string]interface{}{
 		"savedraft":articles,
 	})
+}
+
+func (this *ArticleManage) PrviewArticle()  {
+	adminUserInfo := this.GetAdminUserInfo()
+	userOrgID := adminUserInfo.CurrentOrgId
+	dataBody := make(map[string]interface{}, 0)
+	err := json.Unmarshal(this.Ctx.Input.RequestBody, &dataBody)
+	fmt.Println("视频发布是什么呢",err)
+
+	if err != nil {
+		utils.ErrorLog(err.Error())
+		this.ServeFailJsonSend(enums.ErrorCodeParamWrong, "参数错误")
+		return
+	}
+
+	actname := dataBody["act_name"].(string)
+	if len(actname) == 0 {
+		this.ServeFailJsonSend(enums.ErrorCodeParamWrong, "文章标题不能为空")
+		return
+	}
+
+	actcontent := dataBody["act_content"].(string)
+	if len(actcontent) == 0 {
+		this.ServeFailJsonSend(enums.ErrorCodeParamWrong, "文章内容不能为空")
+		return
+	}
+
+	orglogo := dataBody["org_logo"].(string)
+	if len(orglogo) == 0 {
+		this.ServeFailJsonSend(enums.ErrorCodeParamWrong, "封面图片不能为空")
+		return
+	}
+
+	acttype := int64(dataBody["act_type"].(float64))
+	if  acttype <= 0 {
+		this.ServeFailJsonSend(enums.ErrorCodeParamWrong, "分类号不能为空")
+		return
+	}
+
+	timenow := time.Now().Unix()
+	fmt.Println("姓名:",actname,"文章内容",actcontent,"图片",orglogo,"文章类型",acttype,userOrgID)
+	articles := models.Articles{
+		Title: actname,
+		Content: actcontent,
+		Imgs: orglogo,
+		ClassId: acttype,
+		UserOrgId:userOrgID,
+		Ctime:timenow,
+		Status:1,
+		Type:1,
+		ArticleStatus:3,
+	}
+	 err = article_service.AddPrviewArticle(articles)
+	if err !=nil{
+		this.ServeFailJsonSend(enums.ErrorCodeDataException, "添加预览失败")
+		return
+	}
+	this.ServeSuccessJSON(map[string]interface{}{
+		"art":articles,
+	})
+	fmt.Println("art是谁",articles)
+}
+
+func (this *ArticleManage) GetArtilcePreview()  {
+	adminUserInfo := this.GetAdminUserInfo()
+	userOrgID := adminUserInfo.CurrentOrgId
+	articles, err := article_service.GetArtilcePreview(userOrgID)
+	if err !=nil{
+		this.ServeFailJsonSend(enums.ErrorCodeDataException, "获取预览失败")
+		return
+	}
+	fmt.Println("文章内容",articles)
+	this.ServeSuccessJSON(map[string]interface{}{
+		"articles":articles,
+	})
+
+}
+
+func (this *ArticleManage) AddDraft() {
+	adminUserInfo := this.GetAdminUserInfo()
+	userOrgID := adminUserInfo.CurrentOrgId
+	dataBody := make(map[string]interface{}, 0)
+	err := json.Unmarshal(this.Ctx.Input.RequestBody, &dataBody)
+	fmt.Println("视频发布是什么呢", err)
+
+	if err != nil {
+		utils.ErrorLog(err.Error())
+		this.ServeFailJsonSend(enums.ErrorCodeParamWrong, "参数错误")
+		return
+	}
+	actname := dataBody["act_name"].(string)
+	if len(actname) == 0 {
+		this.ServeFailJsonSend(enums.ErrorCodeParamWrong, "文章标题不能为空")
+		return
+	}
+
+	actcontent := dataBody["act_content"].(string)
+	if len(actcontent) == 0 {
+		this.ServeFailJsonSend(enums.ErrorCodeParamWrong, "文章内容不能为空")
+		return
+	}
+
+	orglogo := dataBody["org_logo"].(string)
+	if len(orglogo) == 0 {
+		this.ServeFailJsonSend(enums.ErrorCodeParamWrong, "封面图片不能为空")
+		return
+	}
+
+	acttype := int64(dataBody["act_type"].(float64))
+	if acttype <= 0 {
+		this.ServeFailJsonSend(enums.ErrorCodeParamWrong, "分类号不能为空")
+		return
+	}
+
+	timenow := time.Now().Unix()
+	fmt.Println("姓名:", actname, "文章内容", actcontent, "图片", orglogo, "文章类型", acttype, userOrgID)
+	articles := models.Articles{
+		Title:         actname,
+		Content:       actcontent,
+		Imgs:          orglogo,
+		ClassId:       acttype,
+		UserOrgId:     userOrgID,
+		Ctime:         timenow,
+		Status:        1,
+		Type:          1,
+		ArticleStatus: 2,
+	}
+	err = article_service.AddDraft(articles)
+	if err !=nil{
+		this.ServeFailJsonSend(enums.ErrorCodeDataException, "保存草稿失败")
+		return
+	}
+	fmt.Println("文章内容",articles)
+	this.ServeSuccessJSON(map[string]interface{}{
+		"articles":articles,
+	})
+}
+
+func (this *ArticleManage) GetArticleInfo()  {
+	id, _ := this.GetInt64("id")
+	fmt.Println("id是啥",id)
+	adminUserInfo := this.GetAdminUserInfo()
+	userOrgID := adminUserInfo.CurrentOrgId
+	articles, err := article_service.GetArticleInfo(userOrgID, id)
+	if err !=nil{
+		this.ServeFailJsonSend(enums.ErrorCodeDataException, "查询文章信息失败")
+		return
+	}
+	fmt.Println("内容是啥什么",articles)
+	this.ServeSuccessJSON(map[string]interface{}{
+		"articles":articles,
+	})
+}
+
+func (this *ArticleManage) DeleteArticle()  {
+	adminUserInfo := this.GetAdminUserInfo()
+	userOrgID := adminUserInfo.CurrentOrgId
+
+	dataBody := make(map[string]interface{}, 0)
+	err := json.Unmarshal(this.Ctx.Input.RequestBody, &dataBody)
+	if err != nil {
+		utils.ErrorLog(err.Error())
+		this.ServeFailJsonSend(enums.ErrorCodeParamWrong, "参数错误")
+		return
+	}
+
+	idsInters := dataBody["ids"].([]interface{})
+	if len(idsInters) == 0 {
+		if err != nil {
+			this.ServeFailJsonSend(enums.ErrorCodeDBDelete, "删除会员失败:（没有选择会员）")
+			return
+		}
+	}
+
+	ids := make([]int64, 0)
+	for _, idsInter := range idsInters {
+		id := int64(idsInter.(float64))
+		ids = append(ids, id)
+	}
+
+	err = article_service.DeleteArticle(ids, userOrgID)
+	if err !=nil{
+		this.ServeFailJsonSend(enums.ErrorCodeDataException, "删除失败")
+		return
+	}
+	returnData := make(map[string]interface{}, 0)
+	returnData["msg"] = "ok"
+	this.ServeSuccessJSON(returnData)
+	return
+}
+
+func (this *ArticleManage) GetMenus(){
+	adminUserInfo := this.GetAdminUserInfo()
+	userOrgID := adminUserInfo.CurrentOrgId
+	categorys, err := article_service.GetMenus(userOrgID)
+	if err !=nil{
+		this.ServeFailJsonSend(enums.ErrorCodeDataException, "查询失败")
+		return
+	}
+	this.ServeSuccessJSON(map[string]interface{}{
+		"categorys":categorys,
+	})
+}
+
+func (this * ArticleManage) UpdataArticleInfo(){
+	adminUserInfo := this.GetAdminUserInfo()
+	userOrgID := adminUserInfo.CurrentOrgId
+	id, _ := this.GetInt64("id")
+	fmt.Println("id是多少",id)
+	dataBody := make(map[string]interface{}, 0)
+	err := json.Unmarshal(this.Ctx.Input.RequestBody, &dataBody)
+	fmt.Println("视频发布是什么呢",err)
+
+	if err != nil {
+		utils.ErrorLog(err.Error())
+		this.ServeFailJsonSend(enums.ErrorCodeParamWrong, "参数错误")
+		return
+	}
+
+	title := dataBody["title"].(string)
+	if len(title) == 0 {
+		this.ServeFailJsonSend(enums.ErrorCodeParamWrong, "文章标题不能为空")
+		return
+	}
+	fmt.Println("title",title)
+	content := dataBody["content"].(string)
+	if len(content) == 0 {
+		this.ServeFailJsonSend(enums.ErrorCodeParamWrong, "内容不能为空")
+		return
+	}
+	fmt.Println("content",content)
+	images := dataBody["imgs"].(string)
+	fmt.Println("images",images)
+	classid :=int64( dataBody["class_id"].(float64))
+	if classid <=0 {
+		this.ServeFailJsonSend(enums.ErrorCodeParamWrong, "分类号不能为空")
+		return
+	}
+	//classid, _ := strconv.ParseInt(class_id, 10, 64)
+    fmt.Println("分类号",classid)
+	fmt.Println("标题",title,"内容",content,"图片",images,"分类号",classid,"机构ID",userOrgID)
+
+	articles := models.Articles{
+		Title:   title,
+		Content: content,
+		Imgs:    images,
+		ClassId: classid,
+		Status:  1,
+		Mtime:   time.Now().Unix(),
+	}
+	 fmt.Println("为什么",articles)
+	 article_service.UpdataArticleInfo(&articles,userOrgID, id)
+	this.ServeSuccessJSON(map[string]interface{}{
+		"articls":articles,
+	})
+}
+
+func (this * ArticleManage) PreviewEditArticle()  {
+	adminUserInfo := this.GetAdminUserInfo()
+	userOrgID := adminUserInfo.CurrentOrgId
+	id, _ := this.GetInt64("id")
+	fmt.Println("id是多少",id)
+	dataBody := make(map[string]interface{}, 0)
+	err := json.Unmarshal(this.Ctx.Input.RequestBody, &dataBody)
+	fmt.Println("视频发布是什么呢",err)
+
+	if err != nil {
+		utils.ErrorLog(err.Error())
+		this.ServeFailJsonSend(enums.ErrorCodeParamWrong, "参数错误")
+		return
+	}
+
+	title := dataBody["title"].(string)
+	if len(title) == 0 {
+		this.ServeFailJsonSend(enums.ErrorCodeParamWrong, "文章标题不能为空")
+		return
+	}
+	fmt.Println("title",title)
+	content := dataBody["content"].(string)
+	if len(content) == 0 {
+		this.ServeFailJsonSend(enums.ErrorCodeParamWrong, "内容不能为空")
+		return
+	}
+	fmt.Println("content",content)
+	images := dataBody["imgs"].(string)
+	fmt.Println("images",images)
+	classid :=int64( dataBody["class_id"].(float64))
+	if classid <=0 {
+		this.ServeFailJsonSend(enums.ErrorCodeParamWrong, "分类号不能为空")
+		return
+	}
+	//classid, _ := strconv.ParseInt(class_id, 10, 64)
+	fmt.Println("分类号",classid)
+	fmt.Println("标题",title,"内容",content,"图片",images,"分类号",classid,"机构ID",userOrgID)
+
+	articles := models.Articles{
+		Title:   title,
+		Content: content,
+		Imgs:    images,
+		ClassId: classid,
+		Status:  1,
+		Mtime:   time.Now().Unix(),
+		ArticleStatus:3,
+	}
+
+	article_service.PreviewEditArticle(articles,userOrgID,id)
+	this.ServeSuccessJSON(map[string]interface{}{
+		"articls":articles,
+	})
+}
+
+func (this * ArticleManage) GetPreviewInfo()  {
+	adminUserInfo := this.GetAdminUserInfo()
+	userOrgID := adminUserInfo.CurrentOrgId
+	articles, err := article_service.GetPreviewInfo(userOrgID)
+	if err !=nil{
+		this.ServeFailJsonSend(enums.ErrorCodeDataException, "获取预览失败")
+		return
+	}
+	fmt.Println("文章内容",articles)
+	this.ServeSuccessJSON(map[string]interface{}{
+		"articles":articles,
+	})
+}
+
+func  (this * ArticleManage) GetAllComment()  {
+	page, _ := this.GetInt64("page", 1)
+	fmt.Println("页面",page)
+	limit, _ := this.GetInt64("limit", 10)
+	fmt.Println("限制",limit)
+	if page <= 0 {
+		page = 1
+	}
+	if limit <= 0 {
+		limit = 10
+	}
+	adminUserInfo := this.GetAdminUserInfo()
+	userOrgID := adminUserInfo.CurrentOrgId
+	articles, total, err := article_service.GetAllComment(page, limit, userOrgID)
+	fmt.Println("文章内容",articles)
+	if err !=nil{
+		this.ServeFailJsonSend(enums.ErrorCodeDataException, "获取预览失败")
+		return
+	}
+	this.ServeSuccessJSON(map[string]interface{}{
+		"total":total,
+		"articles":articles,
+	})
+}
+
+func (this * ArticleManage) GetArticleCommentDetail(){
+	id, _ := this.GetInt64("id")
+	fmt.Println("id是多少",id)
+	adminUserInfo := this.GetAdminUserInfo()
+	userOrgID := adminUserInfo.CurrentOrgId
+	articles, err := article_service.GetArticleCommentDetail(id, userOrgID)
+	if err !=nil{
+		this.ServeFailJsonSend(enums.ErrorCodeDataException, "获取预览失败")
+		return
+	}
+	this.ServeSuccessJSON(map[string]interface{}{
+		"articles":articles,
+	})
 }

controllers/staff/router_collector.go

@@ -0,0 +1,5 @@
+package staff
+
+func RegisterRouters() {
+	staffRouters()
+}

controllers/staff/staff_controller.go

@@ -0,0 +1,150 @@
+package staff
+
+import (
+	"github.com/astaxie/beego"
+   "SCRM/controllers"
+	"encoding/json"
+	"fmt"
+	"SCRM/utils"
+	"SCRM/enums"
+	"SCRM/models"
+	"SCRM/service/staff_service"
+	"time"
+)
+func staffRouters() {
+	 
+	beego.Router("/api/staff/addStaffInfo",&StaffManage{},"Post:AddStaffInfo")
+	beego.Router("/api/staff/getAllStaffInfo",&StaffManage{},"Get:GetAllStaffInfo")
+}
+
+type StaffManage struct {
+
+	controllers.BaseAuthAPIController
+}
+
+func (this *StaffManage) AddStaffInfo()  {
+	adminUserInfo := this.GetAdminUserInfo()
+	userOrgID := int64(adminUserInfo.CurrentOrgId)
+	fmt.Println("机构ID",userOrgID)
+	dataBody := make(map[string]interface{}, 0)
+
+	err := json.Unmarshal(this.Ctx.Input.RequestBody, &dataBody)
+	fmt.Println("视频发布是什么呢",err)
+
+	if err != nil {
+		utils.ErrorLog(err.Error())
+		this.ServeFailJsonSend(enums.ErrorCodeParamWrong, "参数错误")
+		return
+	}
+     fmt.Println("hhhhh")
+	staffname := dataBody["name"].(string)
+	if len(staffname) == 0 {
+		this.ServeFailJsonSend(enums.ErrorCodeParamWrong, "姓名不能为空")
+		return
+	}
+
+	phone := dataBody["phone"].(string)
+	if len(phone) == 0 {
+		this.ServeFailJsonSend(enums.ErrorCodeParamWrong, "手机不能为空")
+		return
+	}
+
+	gender := int64(dataBody["gender"].(float64))
+	if gender <= 0{
+		this.ServeFailJsonSend(enums.ErrorCodeParamWrong, "性别不能为空")
+		return
+	}
+
+	birthday, _ := dataBody["birthday"].(string)
+	if len(birthday) == 0 {
+		this.ServeFailJsonSend(enums.ErrorCodeParamWrong, "生日格式不正确")
+		return
+	}
+
+	timeLayout := "2006-01-02 15:04:05"
+	theTime, err := utils.ParseTimeStringToTime(timeLayout, birthday+" 00:00:00")
+	if err != nil {
+		this.ServeFailJsonSend(enums.ErrorCodeParamWrong, "生日格式不正确")
+		return
+	}
+
+	var staffbirthday = theTime.Unix()
+	fmt.Println("生日",staffbirthday)
+
+	userType := int64(dataBody["user_type"].(float64))
+
+	if userType <= 0 {
+		this.ServeFailJsonSend(enums.ErrorCodeParamWrong, "职称类型不正确")
+		return
+	}
+	userTitle :=int64(dataBody["user_title"].(float64))
+	if userTitle <= 0 {
+		this.ServeFailJsonSend(enums.ErrorCodeParamWrong, "职称名称不正确")
+		return
+	}
+	dochead := dataBody["dochead"].(string)
+	if len(dochead) == 0 {
+		this.ServeFailJsonSend(enums.ErrorCodeParamWrong, "头像不正确")
+		return
+	}
+	content := dataBody["content"].(string)
+	if len(content) == 0 {
+		this.ServeFailJsonSend(enums.ErrorCodeParamWrong, "头像不正确")
+		return
+	}
+
+	fmt.Println("姓名",staffname,"性别" ,gender,"生日",staffbirthday,"职称类型",userType,"职称名称",userTitle,"头像",dochead,"内容",content)
+
+	StaffInfo := models.SgjUserStaffInfo{
+		Name:      staffname,
+		Phone:     phone,
+		Birthday:  staffbirthday,
+		Gender:gender,
+		Content:content,
+		UserType:  userType,
+		UserTitle: userType,
+		Dochead:   dochead,
+		Status: 1,
+		UserOrgId:userOrgID,
+		Ctime:time.Now().Unix(),
+	}
+
+	err = staff_service.AddStaffInfo(StaffInfo)
+	if err !=nil{
+		this.ServeFailJsonSend(enums.ErrorCodeDataException, "插入文章失败")
+		return
+	}
+	this.ServeSuccessJSON(map[string]interface{}{
+		"staffInfo":StaffInfo,
+	})
+	return
+}
+
+func (this *StaffManage) GetAllStaffInfo()  {
+	keyword := this.GetString("keyword")
+	page, _ := this.GetInt64("page", 1)
+	fmt.Println("页面",page)
+	limit, _ := this.GetInt64("limit", 10)
+
+	if page <= 0 {
+		page = 1
+	}
+	if limit <= 0 {
+		limit = 10
+	}
+	fmt.Println("限制",limit)
+	fmt.Println("关键字",keyword,"limit",limit,"page",page)
+
+	adminUserInfo := this.GetAdminUserInfo()
+	userOrgID := int64(adminUserInfo.CurrentOrgId)
+	userStaffInfo, total, err := staff_service.GetAllStaffInfo(userOrgID, page, limit, keyword)
+    fmt.Println("内容",userStaffInfo,"total",total,"err",err)
+	if err !=nil{
+		this.ServeFailJsonSend(enums.ErrorCodeDataException, "获取文章分类列表失败")
+		return
+	}
+	this.ServeSuccessJSON(map[string]interface{}{
+		"userStaffInfo":userStaffInfo,
+		"total":total,
+	})
+}

models/article_models.go

@@ -26,6 +26,7 @@ type Articles struct {
 	Content       string    `gorm:"column:content" json:"content"`
 	Type          int       `gorm:"column:type" json:"type"`
 	Num           int       `gorm:"column:num" json:"num"`
+	Realreadnum   int64       `gorm:"column:real_read_num" json:"real_read_num"`
 	Mtime         int64     `gorm:"column:mtime" json:"mtime"`
 	Ctime         int64     `gorm:"column:ctime" json:"ctime"`
 	ClassId       int64     `gorm:"column:class_id" json:"class_id"`

models/user_models.go

@@ -35,3 +35,23 @@ type User struct {
 func (User) TableName() string {
 	return "sgj_user_user"
 }
+
+type SgjUserStaffInfo struct {
+	ID int64 `gorm:"column:id" json:"id" form:"id"`
+	Name string `gorm:"column:name" json:"name" form:"name"`
+	Phone string `gorm:"column:phone" json:"phone" form:"phone"`
+	Birthday int64 `gorm:"column:birthday" json:"birthday" form:"birthday"`
+	Gender int64 `gorm:"column:gender" json:"gender" form:"gender"`
+	UserType int64 `gorm:"column:user_type" json:"user_type" form:"user_type"`
+	UserTitle int64 `gorm:"column:user_title" json:"user_title" form:"user_title"`
+	Dochead string `gorm:"column:dochead" json:"dochead" form:"dochead"`
+	Content string `gorm:"column:content" json:"content" form:"content"`
+	Ctime int64 `gorm:"column:ctime" json:"ctime" form:"ctime"`
+	Mtime int64 `gorm:"column:mtime" json:"mtime" form:"mtime"`
+	Status int64 `gorm:"column:status" json:"status" form:"status"`
+	UserOrgId int64 `gorm:"column:user_org_id" json:"user_org_id" form:"user_org_id"`
+}
+
+func (SgjUserStaffInfo) TableName() string{
+	return "sgj_user_staff_info"
+}

routers/router.go

@@ -12,6 +12,7 @@ import (
 
 	"github.com/astaxie/beego"
 	"github.com/astaxie/beego/plugins/cors"
+	"SCRM/controllers/staff"
 )
 
 func init() {
@@ -31,4 +32,5 @@ func init() {
 	marketing_tool.RegisterRouters()
 	article.RegisterRouters()
 	mpwechat.RegisterRouters()
+	staff.RegisterRouters()
 }

service/article_service/article_category_service.go

@@ -25,15 +25,15 @@ func AddAritcle(articles models.Articles) error {
 	return  err
 }
 
-func FindAllArticle(orgID int64, page int64,limit int64, searchKey string, classId int64) (articles []*models.Articles,total int64, err error) {
+func FindAllArticle(orgID int64, page int64,limit int64, searchKey string,classId int64) (articles []*models.Articles,total int64, err error) {
     fmt.Println("机构ID",orgID,"搜搜索",searchKey)
 	db := service.PatientReadDB().Table("sgj_patient_articles as a ").Where("a.status=1")
 	if(orgID>0){
 	  db = db.Where("a.user_org_id=?" ,orgID)
 	}
 
-	if(classId>0){
-	  db = db.Joins("JOIN sgj_patient_articles_menu as s ON s.id = a.class_id AND s.status=1 AND user_org_id=?",orgID)
+	if(classId > 0){
+		db = db.Where("class_id = ?",classId)
 	}
 
 	if len(searchKey) > 0 {
@@ -45,7 +45,7 @@ func FindAllArticle(orgID int64, page int64,limit int64, searchKey string, class
 		err = db.Count(&total).Order("a.ctime desc").Offset(offset).Limit(limit).
 		Preload("Comments", func(db *gorm.DB) *gorm.DB {
 			return  db.Where(" status = ?",1)
-		}).
+		}).Where("article_status <> ?",3).
 		Select("a.id, a.title, a.summary, a.content, a.type, a.num, a.mtime, a.real_read_num, a.ctime, a.class_id, a.author, a.status, a.reason,a.star_num, a.comment_num,a.user_org_id, a.article_status, a.imgs, a.video_url, a.source, a.category_id, a.ttid, a.ttype, a.toid").Find(&articles).Error
 		fmt.Println("err是啥呢?",err)
 		 	if err != nil {
@@ -100,4 +100,146 @@ func DeleteCategorys(orgID int64,ids[] int64)(err error){
 func AddVido(articles models.Articles) error  {
 	err := service.PatientWriteDB().Create(&articles).Error
 	return  err
-}
+}
+
+func AddPrviewArticle(articles models.Articles)(err error) {
+	err = service.PatientWriteDB().Create(&articles).Error
+	return err
+}
+
+func GetArtilcePreview(OrgID int64)(models.Articles,error) {
+	article := models.Articles{}
+	err := service.PatientReadDB().Where("user_org_id = ? AND article_status = ? AND type = ?", OrgID, 3, 1).Last(&article).Error
+	return article, err
+}
+
+func AddDraft(articles models.Articles) error {
+	err := service.PatientReadDB().Create(&articles).Error
+	return  err
+}
+
+func GetPublished(orgID int64,page int64,limit int64, searchKey string)(articles []*models.Articles,total int64, err error) {
+	db := service.PatientReadDB().Table("sgj_patient_articles as a ").Where("a.status=1")
+	if (orgID > 0) {
+		db = db.Where("a.user_org_id=? AND article_status = ?", orgID,1)
+	}
+	if len(searchKey) > 0 {
+		searchKey = "%" + searchKey + "%"
+		db = db.Where("a.title LIKE ?", searchKey)
+	}
+	offset := (page - 1) * limit
+	err = db.Count(&total).Order("a.ctime desc").Offset(offset).Limit(limit).
+		Preload("Comments", func(db *gorm.DB) *gorm.DB {
+		return  db.Where(" status = ?",1)
+	}).Where("status = ?",1).
+		Select("a.id, a.title, a.summary, a.content, a.type, a.num, a.mtime, a.real_read_num, a.ctime, a.class_id, a.author, a.status, a.reason,a.star_num, a.comment_num,a.user_org_id, a.article_status, a.imgs, a.video_url, a.source, a.category_id, a.ttid, a.ttype, a.toid").Find(&articles).Error
+	fmt.Println("err是啥呢?",err)
+	if err != nil {
+		return
+	}
+	return
+}
+
+func GetDraftbox(orgID int64,page int64,limit int64, searchKey string)(articles []*models.Articles,total int64, err error) {
+	db := service.PatientReadDB().Table("sgj_patient_articles as a ").Where("a.status=1")
+	if (orgID > 0) {
+		db = db.Where("a.user_org_id=? AND article_status = ?", orgID,2)
+	}
+	if len(searchKey) > 0 {
+		searchKey = "%" + searchKey + "%"
+		db = db.Where("a.title LIKE ?", searchKey)
+	}
+	offset := (page - 1) * limit
+	err = db.Count(&total).Order("a.ctime desc").Offset(offset).Limit(limit).
+		Preload("Comments", func(db *gorm.DB) *gorm.DB {
+		return  db.Where(" status = ?",1)
+	}).Where("article_status = ? AND status = ?",2,1).
+		Select("a.id, a.title, a.summary, a.content, a.type, a.num, a.mtime, a.real_read_num, a.ctime, a.class_id, a.author, a.status, a.reason,a.star_num, a.comment_num,a.user_org_id, a.article_status, a.imgs, a.video_url, a.source, a.category_id, a.ttid, a.ttype, a.toid").Find(&articles).Error
+	fmt.Println("err是啥呢?",err)
+	if err != nil {
+		return
+	}
+	return
+}
+
+func GetNoPass(orgID int64,page int64,limit int64, searchKey string)(articles []*models.Articles,total int64, err error)  {
+	db := service.PatientReadDB().Table("sgj_patient_articles as a ").Where("a.status=1")
+	if (orgID > 0) {
+		db = db.Where("a.user_org_id=? AND article_status = ?", orgID,4)
+	}
+	if len(searchKey) > 0 {
+		searchKey = "%" + searchKey + "%"
+		db = db.Where("a.title LIKE ?", searchKey)
+	}
+	offset := (page - 1) * limit
+	err = db.Count(&total).Order("a.ctime desc").Offset(offset).Limit(limit).
+		Preload("Comments", func(db *gorm.DB) *gorm.DB {
+		return  db.Where(" status = ?",1)
+	}).Where("article_status = ? AND status = ?",4,1).
+		Select("a.id, a.title, a.summary, a.content, a.type, a.num, a.mtime, a.real_read_num, a.ctime, a.class_id, a.author, a.status, a.reason,a.star_num, a.comment_num,a.user_org_id, a.article_status, a.imgs, a.video_url, a.source, a.category_id, a.ttid, a.ttype, a.toid").Find(&articles).Error
+	fmt.Println("err是啥呢?",err)
+	if err != nil {
+		return
+	}
+	return
+}
+
+func GetArticleInfo(orgID int64,id int64)(articles models.Articles,err error){
+	err = service.PatientReadDB().Where("user_org_id = ? AND id = ? AND status = ?", orgID, id, 1).Find(&articles).Error
+	return  articles,err
+}
+
+func DeleteArticle(ids[] int64,orgID int64)(err error)  {
+	if len(ids) ==1{
+		err =	service.PatientWriteDB().Model(&models.Articles{}).Where( "id=? and user_org_id = ?",ids[0],orgID).Update(map[string]interface{}{"status":0,"mtime":time.Now().Unix()}).Error
+	}else {
+		err =	service.PatientWriteDB().Model(&models.Articles{}).Where("id IN (?) and user_org_id = ?",ids,orgID).Update(map[string]interface{}{"status":0,"mtime":time.Now().Unix()}).Error
+	}
+	return
+}
+
+func GetMenus(OrgID int64)(categorys []*models.ArticleCategory,err error)  {
+	err = service.PatientReadDB().Where("user_org_id = ?", OrgID).Find(&categorys).Error
+	return  categorys ,err
+}
+
+func UpdataArticleInfo(art *models.Articles,orgID int64,id int64){
+	service.PatientWriteDB().Model(art).Where("user_org_id = ? AND id = ? AND status = ?",orgID,id,1).Update(map[string]interface{}{"title":art.Title,"content":art.Content,"imgs":art.Imgs,"class_id":art.ClassId,"mtime":art.Mtime})
+
+}
+
+func PreviewEditArticle(art models.Articles,orgID int64,id int64)  {
+	service.PatientWriteDB().Model(art).Where("user_org_id = ? AND id = ? AND status = ?",orgID,id,1).Update(map[string]interface{}{"title":art.Title,"content":art.Content,"imgs":art.Imgs,"class_id":art.ClassId,"mtime":art.Mtime,"article_status":art.ArticleStatus})
+}
+
+func GetPreviewInfo(orgID int64)(models.Articles,error)  {
+	article := models.Articles{}
+	err := service.PatientReadDB().Where("user_org_id = ? AND article_status = ? AND type = ?", orgID, 3, 1).Last(&article).Error
+	return article, err
+}
+
+func GetAllComment(page int64,limit int64,orgID int64)(articles []*models.Articles,total int64, err error) {
+	db := service.PatientReadDB().Table("sgj_patient_articles as a ").Where("a.status=1")
+	if (orgID > 0) {
+		db = db.Where("a.user_org_id=? AND article_status = ?", orgID,1)
+	}
+	offset := (page - 1) * limit
+	err = db.Count(&total).Order("a.ctime desc").Offset(offset).Limit(limit).
+		Preload("Comments", func(db *gorm.DB) *gorm.DB {
+		return  db.Where(" status = ?",1)
+	}).
+		Select("a.id, a.title, a.summary, a.content, a.type, a.num, a.mtime, a.real_read_num, a.ctime, a.class_id, a.author, a.status, a.reason,a.star_num, a.comment_num,a.user_org_id, a.article_status, a.imgs, a.video_url, a.source, a.category_id, a.ttid, a.ttype, a.toid").Find(&articles).Error
+	fmt.Println("err是啥呢?",err)
+	if err != nil {
+		return
+	}
+	return
+}
+
+func GetArticleCommentDetail(articleId int64,orgID int64)(*models.Articles, error){
+	article := &models.Articles{}
+	err :=service.PatientReadDB().Where("id = ? AND user_org_id = ? AND status = ?", articleId, orgID,1).Find(article).Error
+	tm := time.Unix(article.Ctime, 0)
+	article.PublicTime = tm.Format("2006-01-02 15:04:05")
+	return article, err
+}

service/marketing_tool_service/activity_service.go

@@ -164,3 +164,6 @@ func SaveActivityAndParagraph(activity *models.Activity, paragraph *models.Activ
 func SaveActivityWxShare(model *models.ActivityWxShare) error {
 	return service.PatientWriteDB().Save(model).Error
 }
+
+
+

service/staff_service/staff_manager_service.go

@@ -0,0 +1,34 @@
+package staff_service
+
+import (
+	"SCRM/models"
+	"SCRM/service"
+)
+
+func AddStaffInfo(info models.SgjUserStaffInfo) error  {
+	err := service.UserWriteDB().Create(&info).Error
+	return  err
+}
+
+func  GetAllStaffInfo(orgID int64,page int64,limit int64,keyword string)(userStaffInfo  []*models.SgjUserStaffInfo,total int64,err error){
+
+	db := service.UserReadDB().Table("sgj_user_staff_info as s").Where("s.status = 1")
+	if(orgID>0){
+		db = db.Where("s.user_org_id = ?", orgID)
+	}
+
+	if len(keyword) >0{
+		keyword = "%" + keyword + "%"
+		db.Where("s.name LIKE ? AND s.user_title LIEK ?",keyword,keyword)
+	}
+
+	offset := (page - 1) * limit
+	err = db.Count(&total).Order("s.ctime desc").Offset(offset).Limit(limit).
+		Select("s.id,s.name,s.phone,s.birthday,s.gender,s.user_type,s.user_title,s.dochead,s.content,s.ctime,s.mtime,s.status,s.user_org_id").Find(&userStaffInfo).Error
+
+	if err != nil {
+		return
+	}
+	return
+}
+