0817pm

controllers/cases/caseuser.go

@@ -0,0 +1,59 @@
+package cases
+
+import "spaceofcheng/services/models/model"
+
+// GetCaseUserByCase 根据案场获取用户信息
+func (c *CaseController) GetCaseUserByCase() {
+	caseid := c.GetString("caseid")
+
+	list, err := c.dao.GetCaseUserByCase(caseid)
+
+	if err != nil {
+		c.ResponseError(err)
+	}
+	c.ResponseJSON(list)
+}
+
+// GetCaseUserByType 根据类型获取用户信息
+func (c *CaseController) GetCaseUserByType() {
+	usertype := c.GetString("usertype")
+	caseid := c.GetString("caseid")
+	caseuser, err := c.dao.GetCaseUserByType(caseid, usertype)
+	if err != nil {
+		c.ResponseError(err)
+	}
+	c.ResponseJSON(caseuser)
+}
+
+// GetCaseUserByID 根据ID获取用户
+func (c *CaseController) GetCaseUserByID() {
+	userid := c.GetString(":userid")
+	info, err := c.dao.GetCaseUserByID(userid)
+	if err != nil {
+		c.ResponseError(err)
+	}
+	c.ResponseJSON(info)
+}
+
+// SaveCaseUser 保存标签
+func (c *CaseController) SaveCaseUser() {
+	user := model.SysCaseUser{}
+	if err := c.ParseForm(&user); err != nil {
+		c.ResponseError(err)
+	}
+	newUser, err := c.dao.SaveCaseUser(user)
+	if err != nil {
+		c.ResponseError(err)
+	}
+	c.ResponseJSON(newUser)
+}
+
+// DelCaseUser 删除标签
+func (c *CaseController) DelCaseUser() {
+	tagid := c.GetString(":userid")
+	err := c.dao.DelCaseUser(tagid)
+	if err != nil {
+		c.ResponseError(err)
+	}
+	c.ResponseJSON("删除成功！")
+}

controllers/cases/tag.go

@@ -23,5 +23,29 @@ func (c *CaseController) GetTagByID() {
 	if err != nil {
 		c.ResponseError(err)
 	}
-	c.ResponseJSON(list)
+	c.ResponseJSON(info)
+}
+
+// SaveCaseTag 保存标签
+func (c *CaseController) SaveCaseTag() {
+	tag := model.SysTag{}
+	if err := c.ParseForm(&tag); err != nil {
+		c.ResponseError(err)
+	}
+	caseids := c.GetString("caseids")
+	newTag, err := c.dao.SaveTag(tag, caseids)
+	if err != nil {
+		c.ResponseError(err)
+	}
+	c.ResponseJSON(newTag)
+}
+
+// DelCaseTag 删除标签
+func (c *CaseController) DelCaseTag() {
+	tagid := c.GetString(":tagid")
+	err := c.dao.DelTag(tagid)
+	if err != nil {
+		c.ResponseError(err)
+	}
+	c.ResponseJSON("删除成功！")
 }

models/cases/caseuser.go

@@ -0,0 +1,68 @@
+package cases
+
+import (
+	"spaceofcheng/services/models"
+	"spaceofcheng/services/models/model"
+	"spaceofcheng/services/utils"
+	"time"
+)
+
+// GetCaseUserByCase 根据案场id获取案场相关人员
+func (m *CaseDAO) GetCaseUserByCase(caseid string) ([]model.SysCaseUser, error) {
+	var caseusers []model.SysCaseUser
+	err := m.db.Where("case_id=?", caseid).And("status=?", models.STATUS_NORMAL).Find(&caseusers)
+	return caseusers, err
+}
+
+// GetCaseUserByID 根据id获取相关人员
+func (m *CaseDAO) GetCaseUserByID(userid string) (*model.SysCaseUser, error) {
+	var caseusers []model.SysCaseUser
+	err := m.db.Where("case_user_id=?", userid).And("status=?", models.STATUS_NORMAL).Find(&caseusers)
+	if err != nil {
+		return nil, err
+	}
+	if len(caseusers) > 0 {
+		return &caseusers[0], nil
+	}
+	return nil, nil
+}
+
+// GetCaseUserByUserType 根据用户类型获取相关人员
+func (m *CaseDAO) GetCaseUserByUserType(caseid, usertype string) ([]model.SysCaseUser, error) {
+	var caseusers []model.SysCaseUser
+	err := m.db.Where("case_id=?", caseid).And("user_type=?", usertype).And("status=?", models.STATUS_NORMAL).Find(&caseusers)
+	return caseusers, err
+}
+
+// AddCaseUser 新增案场相关人员
+func (m *CaseDAO) AddCaseUser(caseuser model.SysCaseUser) (*model.SysCaseUser, error) {
+	caseuser.CreateDate = time.Now()
+	caseuser.Status = models.STATUS_NORMAL
+	caseuser.CaseUserId = utils.GetGUID()
+	_, err := m.db.Insert(&caseuser)
+	return &caseuser, err
+}
+
+// UpdateCaseUser 修改案场相关人员
+func (m *CaseDAO) UpdateCaseUser(caseuser model.SysCaseUser) error {
+	var cols = []string{
+		"user_name",
+		"tel",
+		"user_type",
+	}
+	_, err := m.db.Cols(cols...).Where("case_user_id=?", caseuser.CaseUserId).Update(caseuser)
+	return err
+}
+
+// DelCaseUser 删除案场相关人员
+func (m *CaseDAO) DelCaseUser(caseuserid string) error {
+	var caseuser = model.SysCaseUser{
+		CaseUserId: caseuserid,
+		Status:     models.STATUS_DEL,
+	}
+	var cols = []string{
+		"status",
+	}
+	_, err := m.db.Cols(cols...).Where("case_user_id=?", caseuserid).Update(caseuser)
+	return err
+}

models/cases/tag.go

@@ -3,8 +3,10 @@ package cases
 import (
 	"jcjy/demo/models"
 	"spaceofcheng/services/models/model"
+	"spaceofcheng/services/utils"
 	"strconv"
 	"strings"
+	"time"
 )
 
 // GetTagCount 获取标签总数
@@ -58,3 +60,48 @@ func (m *CaseDAO) GetTagCaseByTagID(tagid string) ([]model.SysTagCase, error) {
 	err := m.db.Where("tag_id=?", tagid).Find(&tagcase)
 	return tagcase, err
 }
+
+// AddTag 新增标签
+func (m *CaseDAO) AddTag(tag model.SysTag) (*model.SysTag, error) {
+	tag.TagId = utils.GetGUID()
+	tag.Status = models.STATUS_NORMAL
+	tag.CreateDate = time.Now()
+	_, err := m.db.Insert(&tag)
+	return &tag, err
+}
+
+// UpdateTag 修改标签
+func (m *CaseDAO) UpdateTag(tag model.SysTag) error {
+	var cols = []string{
+		"tag_name",
+	}
+	_, err := m.db.Cols(cols...).Where("tag_id=?", tag.TagId).Update(tag)
+	return err
+}
+
+// DeleteTag 刪除标签
+func (m *CaseDAO) DeleteTag(tagid string) error {
+	var tag = model.SysTag{
+		TagId:  tagid,
+		Status: models.STATUS_DEL,
+	}
+	var cols = []string{
+		"status",
+	}
+	_, err := m.db.Cols(cols...).Where("tag_id=?", tag.TagId).Update(tag)
+	return err
+}
+
+// DelTagCase 删除标签对应的案场
+func (m *CaseDAO) DelTagCase(tagid string) error {
+	sql := "delete from sys_tag_case where tag_id='" + tagid + "'"
+	_, err := m.db.Exec(sql)
+	return err
+}
+
+// SaveTagCase 保存标签对应的案场
+func (m *CaseDAO) SaveTagCase(tagid, caseids string) error {
+	sql := `insert into sys_tag_case(tag_id,case_id) select '` + tagid + `', case_id from sys_case where case_id in ('` + strings.Replace(caseids, ",", "','", -1) + `') and status = ` + strconv.Itoa(models.STATUS_NORMAL)
+	_, err := m.db.Exec(sql)
+	return err
+}

routers/common.go

@@ -61,6 +61,13 @@ func getCommonRoutes() beego.LinkNamespace {
 		beego.NSRouter("/cmscase", &message.MessageController{}, "put:SaveCmsCase"),
 		beego.NSRouter("/cmscase/:cmscaseid", &message.MessageController{}, "delete:DelCmsCase"),
 
+		beego.NSRouter("/caseuser", &message.MessageController{}, "get:GetCaseUserByCase"),
+		beego.NSRouter("/caseuserbytype", &message.MessageController{}, "get:GetCaseUserByType"),
+		beego.NSRouter("/caseuser/:userid", &message.MessageController{}, "get:GetCaseUserByID"),
+		beego.NSRouter("/caseuser", &message.MessageController{}, "post:SaveCaseUser"),
+		beego.NSRouter("/caseuser", &message.MessageController{}, "put:SaveCaseUser"),
+		beego.NSRouter("/caseuser/:userid", &message.MessageController{}, "delete:DelCaseUser"),
+
 		beego.NSRouter("/file", &controllers.BaseController{}, "post:FileUpload"),
 	)
 }

service/cases/caseuser.go

@@ -0,0 +1,40 @@
+package cases
+
+import "spaceofcheng/services/models/model"
+
+// GetCaseUserByCase 根据案场id获取案场相关人员信息
+func (s *CaseServ) GetCaseUserByCase(caseid string) ([]model.SysCaseUser, error) {
+	caseusers, err := s.dao.GetCaseUserByCase(caseid)
+	return caseusers, err
+}
+
+// GetCaseUserByType 根据类型获取人员
+func (s *CaseServ) GetCaseUserByType(caseid, usertype string) ([]model.SysCaseUser, error) {
+	caseusers, err := s.dao.GetCaseUserByUserType(caseid, usertype)
+	return caseusers, err
+}
+
+// GetCaseUserByID 根据ID获取人员
+func (s *CaseServ) GetCaseUserByID(userid string) (*model.SysCaseUser, error) {
+	caseuser, err := s.dao.GetCaseUserByID(userid)
+	return caseuser, err
+}
+
+// SaveCaseUser 保存人员信息
+func (s *CaseServ) SaveCaseUser(caseuser model.SysCaseUser) (*model.SysCaseUser, error) {
+	var newInfo *model.SysCaseUser
+	var err error
+	if caseuser.CaseUserId == "" {
+		newInfo, err = s.dao.AddCaseUser(caseuser)
+	} else {
+		err = s.dao.UpdateCaseUser(caseuser)
+		newInfo = &caseuser
+	}
+	return newInfo, err
+}
+
+// DelCaseUser 删除人员信息
+func (s *CaseServ) DelCaseUser(userid string) error {
+	err := s.dao.DelCaseUser(userid)
+	return err
+}

service/cases/equipment.go

@@ -0,0 +1 @@
+package cases

service/cases/tag.go

@@ -2,6 +2,7 @@ package cases
 
 import (
 	"spaceofcheng/services/models/cases"
+	"spaceofcheng/services/models/model"
 	"spaceofcheng/services/service"
 )
 
@@ -42,3 +43,33 @@ func (s *CaseServ) GetTagByID(tagid string) (*cases.Tag, error) {
 	}
 	return tag, err
 }
+
+// SaveTag 保存标签
+func (s *CaseServ) SaveTag(tag model.SysTag, caseids string) (*model.SysTag, error) {
+	var newInfo *model.SysTag
+	var err error
+	if tag.TagId == "" {
+		newInfo, err = s.dao.AddTag(tag)
+	} else {
+		err = s.dao.UpdateTag(tag)
+		newInfo = &tag
+	}
+	if err != nil {
+		return nil, err
+	}
+	err = s.dao.DelTagCase(newInfo.TagId)
+	if err != nil {
+		return nil, err
+	}
+	err = s.dao.SaveTagCase(newInfo.TagId, caseids)
+	if err != nil {
+		return nil, err
+	}
+	return newInfo, err
+}
+
+// DelTag 删除标签
+func (s *CaseServ) DelTag(tagid string) error {
+	err := s.dao.DeleteTag(tagid)
+	return err
+}