no message

controllers/cygx/rai_serve.go

@@ -102,6 +102,10 @@ func (this *RaiServeCoAntroller) SearchTag() {
 	}
 	if len(list) == 0 {
 		list = make([]*cygx.RaiServeTagResp, 0)
+	} else {
+		for _, v := range list {
+			v.Md5Key = utils.MD5(fmt.Sprintf("K_", v.TagType, "V_", v.TagId))
+		}
 	}
 	resp.List = list
 	br.Ret = 200

controllers/cygx/user_feedback.go

@@ -0,0 +1,152 @@
+package cygx
+
+import (
+	"encoding/json"
+	"hongze/hz_crm_api/controllers"
+	"hongze/hz_crm_api/models"
+	"hongze/hz_crm_api/models/cygx"
+	"time"
+)
+
+// 联系人列表，交流反馈
+type UserFeedbackController struct {
+	controllers.BaseAuthController
+}
+
+// @Title 添加交流反馈接口
+// @Description 添加交流反馈接口
+// @Param	request	body cygx.AddCygxUserFeedbackReq true "type json string"
+// @Success 200 操作成功
+// @router /user_feedback/add [post]
+func (this *UserFeedbackController) UserFeedbackAdd() {
+	br := new(models.BaseResponse).Init()
+	defer func() {
+		this.Data["json"] = br
+		this.ServeJSON()
+	}()
+	sysUser := this.SysUser
+	if sysUser == nil {
+		br.Msg = "请登录"
+		br.ErrMsg = "请登录，SysUser Is Empty"
+		br.Ret = 408
+		return
+	}
+	var req cygx.AddCygxUserFeedbackReq
+	err := json.Unmarshal(this.Ctx.Input.RequestBody, &req)
+	if err != nil {
+		br.Msg = "参数解析异常！"
+		br.ErrMsg = "参数解析失败，Err:" + err.Error()
+		return
+	}
+	userId := req.UserId
+	content := req.Content
+	if content == "" {
+		br.Msg = "内容不能为空！"
+		return
+	}
+	wxUser, err := models.GetWxUserItemByUserId(userId)
+	if err != nil {
+		br.Msg = "获取失败"
+		br.ErrMsg = "获取失败, GetWxUserItemByUserId  Err:" + err.Error()
+		return
+	}
+	item := new(cygx.CygxUserFeedback)
+	item.Content = content
+	item.UserId = wxUser.UserId
+	item.Mobile = wxUser.Mobile
+	item.Email = wxUser.Email
+	item.CompanyId = wxUser.CompanyId
+	item.CompanyName = wxUser.CompanyName
+	item.RealName = wxUser.RealName
+	item.AdminId = sysUser.AdminId
+	item.CreateTime = time.Now()
+	_, err = cygx.AddCygxUserFeedback(item)
+	if err != nil {
+		br.Msg = "新增失败."
+		br.ErrMsg = "新增失败,Err:" + err.Error()
+		return
+	}
+	br.Ret = 200
+	br.Success = true
+	br.Msg = "操作成功"
+}
+
+// @Title 服务类型列表
+// @Description 服务类型列表接口
+// @Param   UserId   query   int	  false       "用户ID"
+// @Success 200 {object} cygx.CygxCygxUserFeedbackResp
+// @router /user_feedback/list [get]
+func (this *RaiServeCoAntroller) UserFeedbackList() {
+	br := new(models.BaseResponse).Init()
+	defer func() {
+		this.Data["json"] = br
+		this.ServeJSON()
+	}()
+	sysUser := this.SysUser
+	if sysUser == nil {
+		br.Msg = "请登录"
+		br.ErrMsg = "请登录，SysUser Is Empty"
+		br.Ret = 408
+		return
+	}
+	userId, _ := this.GetInt("UserId")
+	if userId < 1 {
+		br.Msg = "请输入用户ID"
+		return
+	}
+	resp := new(cygx.CygxCygxUserFeedbackResp)
+	list, err := cygx.GetCygxUserFeedbackListByUserId(userId)
+	if err != nil {
+		br.Msg = "获取失败"
+		br.ErrMsg = "获取数据失败，Err:" + err.Error()
+		return
+	}
+	resp.List = list
+	br.Ret = 200
+	br.Success = true
+	br.Msg = "获取成功"
+	br.Data = resp
+}
+
+// @Title 添加交流反馈接口
+// @Description 添加交流反馈接口
+// @Param	request	body cygx.CygxUserFeedbackIdReq true "type json string"
+// @Success 200 操作成功
+// @router /user_feedback/del [post]
+func (this *UserFeedbackController) UserFeedbackDel() {
+	br := new(models.BaseResponse).Init()
+	defer func() {
+		this.Data["json"] = br
+		this.ServeJSON()
+	}()
+	sysUser := this.SysUser
+	if sysUser == nil {
+		br.Msg = "请登录"
+		br.ErrMsg = "请登录，SysUser Is Empty"
+		br.Ret = 408
+		return
+	}
+	var req cygx.CygxUserFeedbackIdReq
+	err := json.Unmarshal(this.Ctx.Input.RequestBody, &req)
+	if err != nil {
+		br.Msg = "参数解析异常！"
+		br.ErrMsg = "参数解析失败，Err:" + err.Error()
+		return
+	}
+	userFeedbackId := req.UserFeedbackId
+
+	if userFeedbackId < 0 {
+		br.Msg = "参数错误！"
+		return
+	}
+
+	err = cygx.DeleteCygxUserFeedback(userFeedbackId)
+	if err != nil {
+		br.Msg = "删除失败"
+		br.ErrMsg = "删除失败,Err:" + err.Error()
+		return
+	}
+	br.Ret = 200
+	br.Success = true
+	br.Msg = "删除成功"
+}

models/cygx/rai_serve_bill.go

@@ -27,6 +27,7 @@ type RaiServeTagResp struct {
 	TagType int    `description:"标签类型"`
 	TagId   int    `description:"标签ID"`
 	TagName string `description:"标签名称"`
+	Md5Key  string `description:"加密key,前端找参数当唯一索引值使用"`
 }
 
 type RaiServeTagListResp struct {

models/cygx/user_feedback.go

@@ -0,0 +1,59 @@
+package cygx
+
+import (
+	"github.com/beego/beego/v2/client/orm"
+	"time"
+)
+
+//用户交流反馈表
+
+// 权益服务明细表
+type CygxUserFeedback struct {
+	UserFeedbackId int       `comment:"UserFeedbackId 主键ID"`
+	Content        string    `comment:"服务内容说明"`
+	UserId         int       `comment:"用户ID"`
+	Mobile         string    `comment:"手机号"`
+	Email          string    `comment:"邮箱"`
+	CompanyId      int       `comment:"公司ID"`
+	CompanyName    string    `comment:"公司名称"`
+	RealName       string    `comment:"用户实际名称"`
+	AdminId        int       `comment:"操作人ID"`
+	CreateTime     time.Time `comment:"创建时间"`
+}
+
+type AddCygxUserFeedbackReq struct {
+	Content string `comment:"服务内容说明"`
+	UserId  int    `comment:"用户ID"`
+}
+
+type CygxUserFeedbackIdReq struct {
+	UserFeedbackId int `comment:"UserFeedbackId 主键ID"`
+}
+
+// 添加
+func AddCygxUserFeedback(item *CygxUserFeedback) (newId int64, err error) {
+	o := orm.NewOrmUsingDB("hz_cygx")
+	newId, err = o.Insert(item)
+	return
+}
+
+// 删除数据
+func DeleteCygxUserFeedback(userFeedbackId int) (err error) {
+	o := orm.NewOrmUsingDB("hz_cygx")
+	sql := ` DELETE FROM cygx_user_feedback WHERE user_feedback_id = ?  `
+	_, err = o.Raw(sql, userFeedbackId).Exec()
+	return
+}
+
+// 列表
+func GetCygxUserFeedbackListByUserId(userId int) (items []*CygxUserFeedback, err error) {
+	o := orm.NewOrmUsingDB("hz_cygx")
+	sql := `SELECT * FROM cygx_user_feedback WHERE  user_id = ? `
+	sql += `  ORDER BY user_feedback_id DESC  LIMIT  100 `
+	_, err = o.Raw(sql, userId).QueryRows(&items)
+	return
+}
+
+type CygxCygxUserFeedbackResp struct {
+	List []*CygxUserFeedback
+}

models/db.go

@@ -480,6 +480,7 @@ func initCygx() {
 		new(cygx.CygxOrderRefund),
 		new(cygx.CygxOrder),
 		new(cygx.CygxOrderAction),
+		new(cygx.CygxUserFeedback),
 	)
 }
 

routers/commentsRouter.go

@@ -2338,6 +2338,15 @@ func init() {
             Filters: nil,
             Params: nil})
 
+    beego.GlobalControllerRouter["hongze/hz_crm_api/controllers/cygx:RaiServeCoAntroller"] = append(beego.GlobalControllerRouter["hongze/hz_crm_api/controllers/cygx:RaiServeCoAntroller"],
+        beego.ControllerComments{
+            Method: "UserFeedbackList",
+            Router: `/user_feedback/list`,
+            AllowHTTPMethods: []string{"get"},
+            MethodParams: param.Make(),
+            Filters: nil,
+            Params: nil})
+
     beego.GlobalControllerRouter["hongze/hz_crm_api/controllers/cygx:ReportArticleController"] = append(beego.GlobalControllerRouter["hongze/hz_crm_api/controllers/cygx:ReportArticleController"],
         beego.ControllerComments{
             Method: "ExportList",
@@ -3184,6 +3193,24 @@ func init() {
             Filters: nil,
             Params: nil})
 
+    beego.GlobalControllerRouter["hongze/hz_crm_api/controllers/cygx:UserFeedbackController"] = append(beego.GlobalControllerRouter["hongze/hz_crm_api/controllers/cygx:UserFeedbackController"],
+        beego.ControllerComments{
+            Method: "UserFeedbackAdd",
+            Router: `/user_feedback/add`,
+            AllowHTTPMethods: []string{"post"},
+            MethodParams: param.Make(),
+            Filters: nil,
+            Params: nil})
+
+    beego.GlobalControllerRouter["hongze/hz_crm_api/controllers/cygx:UserFeedbackController"] = append(beego.GlobalControllerRouter["hongze/hz_crm_api/controllers/cygx:UserFeedbackController"],
+        beego.ControllerComments{
+            Method: "UserFeedbackDel",
+            Router: `/user_feedback/del`,
+            AllowHTTPMethods: []string{"post"},
+            MethodParams: param.Make(),
+            Filters: nil,
+            Params: nil})
+
     beego.GlobalControllerRouter["hongze/hz_crm_api/controllers/cygx:YanxuanSpecialController"] = append(beego.GlobalControllerRouter["hongze/hz_crm_api/controllers/cygx:YanxuanSpecialController"],
         beego.ControllerComments{
             Method: "ApprovalLogList",

routers/router.go

@@ -163,6 +163,7 @@ func init() {
 				&cygx.EnterScoreController{},
 				&cygx.OrderController{},
 				&cygx.RaiServeCoAntroller{},
+				&cygx.UserFeedbackController{},
 			),
 		),
 		web.NSNamespace("/advisory",