Merge branch 'master' of http://git.shengws.com/zhangbj/scrm-go

conf/app.conf

@@ -43,6 +43,13 @@ httpdomain = http://api.jk.kuyicloud.com
 sso_domain = http://sso.kuyicloud.com
 front_end_domain = "http://jk.kuyicloud.com/#"
 
+openwechattoken = dwqofqon2e12en2o
+openwechatappid = wx9c877a6fc2acc742
+openwechatencodingaeskey = jiowefjw9pfjw9pfcw9pewjfow9huwgihg23hfwi8t4
+openwechatsecret = 5ac9ed5c6e3e8eee230befc7a7d04d37
+
+openwechatcomponentid = 1
+
 readmysqlhost = shengws1.mysql.rds.aliyuncs.com
 readmysqlport = 3306
 readmysqluser = syh
@@ -77,6 +84,13 @@ httpdomain = http://api.test1.sgjyun.com
 sso_domain = http://testsso.sgjyun.com
 front_end_domain = "http://test1.sgjyun.com/#"
 
+openwechattoken = dwqofqon2e12en2o
+openwechatappid = wx710ed9839d337b2a
+openwechatencodingaeskey = jiowefjw9pfjw9pfcw9pewjfow9huwgihg23hfwi8t4
+openwechatsecret = bbce950b9404ed80a6727f2f3c2ec729
+
+openwechatcomponentid = 1
+
 readmysqlhost = rm-wz9rg531npf61q03tro.mysql.rds.aliyuncs.com
 readmysqlport = 3306
 readmysqluser = root

controllers/base_controller.go

@@ -2,6 +2,7 @@ package controllers
 
 import (
 	service "SCRM/service/admin_service"
+	"SCRM/utils"
 
 	"github.com/astaxie/beego"
 )
@@ -21,20 +22,25 @@ func (this *BaseController) GetAdminUserInfo() *service.AdminUserInfo {
 
 func (this *BaseController) ErrorLog(format string, a ...interface{}) {
 	//beego.Error(fmt.Sprintf(format, a...))
+	utils.ErrorLog(format, a...)
 }
 
 func (this *BaseController) WarnLog(format string, a ...interface{}) {
 	//beego.Warn(fmt.Sprintf(format, a...))
+	utils.WarningLog(format, a...)
 }
 
 func (this *BaseController) InfoLog(format string, a ...interface{}) {
 	//beego.Info(fmt.Sprintf(format, a...))
+	utils.InfoLog(format, a...)
 }
 
 func (this *BaseController) DebugLog(format string, a ...interface{}) {
 	//beego.Debug(fmt.Sprintf(format, a...))
+	utils.InfoLog(format, a...)
 }
 
 func (this *BaseController) TraceLog(format string, a ...interface{}) {
 	//beego.Trace(fmt.Sprintf(format, a...))
+	utils.TraceLog(format, a...)
 }

controllers/global/open_wechat_controller.go

@@ -0,0 +1,395 @@
+package global
+
+import (
+	base_ctl "SCRM/controllers"
+	"SCRM/enums"
+	"SCRM/models"
+	"fmt"
+	"strings"
+	"time"
+
+	"github.com/astaxie/beego"
+
+	"SCRM/service"
+	"SCRM/utils"
+	"encoding/base64"
+	"encoding/json"
+	"encoding/xml"
+	"strconv"
+
+	"SCRM/service/org_service"
+	"SCRM/service/wechat_service"
+
+	"io/ioutil"
+
+	crypter "github.com/heroicyang/wechat-crypter"
+)
+
+//OpenWechatAPIController 微信开放平台相关
+type OpenWechatAPIController struct {
+	base_ctl.BaseAPIController
+}
+
+func (c *OpenWechatAPIController) Prepare() {
+	c.EnableXSRF = false
+}
+
+//OpenWechatCtlRegistRouters 微信开放平台注册路由
+func OpenWechatCtlRegistRouters() {
+	beego.Router("/openwechat/authorizationevents", &OpenWechatAPIController{}, "*:AuthorizationEvents")
+	beego.Router("/openwechat/mp/notice", &OpenWechatAPIController{}, "Post:MpWechatNotice")
+	beego.Router("/openwechat/mp/authorization", &OpenWechatAPIController{}, "Get:Authorization")
+	beego.Router("/openwechat/mp/authorizerinfo/:id/:vtime/:vcode", &OpenWechatAPIController{}, "*:AuthorizerInfo")
+}
+
+// AuthorizationEvents 接收微信服务器推送的 授权事件
+// 有四个处理功能，由解密后的infoType决定
+// 每隔10分钟定时推送           component_verify_ticket
+// 公众号授权给第三方平台        authorized
+// 公众号对第三方平台取消授权    unauthorized
+// 公众号对第三方平台更新授权    updateauthorized
+func (c *OpenWechatAPIController) AuthorizationEvents() {
+	//接收微信服务器主动调起授权事件接收URL时，由微信服务器额外拼接在URL的几个参数，
+	// nonce := c.GetString("nonce")
+	// encryptType := c.GetString("encrypt_type")
+	// msgSignature := c.GetString("msg_signature")
+	// signature := c.GetString("signature")
+	// timestamp := c.GetString("timestamp")
+
+	// MsgEncrypt 类型的me,MsgEncrypt是根据接下来要读取的xml数据格式定义的struct，
+	var me wechat_service.MsgEncrypt
+	err := xml.Unmarshal(c.Ctx.Input.RequestBody, &me)
+	if err != nil {
+		utils.ErrorLog("read body error: %s", err)
+		c.Ctx.WriteString("success")
+		return
+	}
+
+	msgCrypter, _ := crypter.NewMessageCrypter(beego.AppConfig.String("openwechattoken"), beego.AppConfig.String("openwechatencodingaeskey"), beego.AppConfig.String("openwechatappid")) //这是github.com/heroicyang/config.WECHAT-crypter上的组件
+	msgDecrypt, _, err := msgCrypter.Decrypt(me.Encrypt)
+	if err != nil {
+		utils.ErrorLog("msgDecrypt error: %s", err)
+		c.Ctx.WriteString("success")
+		return
+	}
+	fmt.Println("msgDecrypt:", string(msgDecrypt))
+	//将上面解密后的xml读到InfoType struct
+	var requestBody wechat_service.ComponentRequestBody
+	err = xml.Unmarshal(msgDecrypt, &requestBody)
+	if err != nil {
+		utils.ErrorLog("Unmarshal ComponentRequestBody error: %s", err)
+		c.Ctx.WriteString("success")
+		return
+	}
+
+	//判断推送类型
+	// 	推送           component_verify_ticket
+	//  公众号授权给第三方平台        authorized
+	//  公众号对第三方平台取消授权    unauthorized
+	//  公众号对第三方平台更新授权    updateauthorized
+	if requestBody.InfoType == "component_verify_ticket" {
+		utils.InfoLog("接收到component_verify_ticket：%s, ", requestBody.ComponentVerifyTicket)
+		redisClient := service.RedisClient()
+
+		defer redisClient.Close()
+
+		err = redisClient.Set("sgj_patient:ComponentVerifyTicket", requestBody.ComponentVerifyTicket, 0).Err()
+		if err != nil {
+			utils.ErrorLog("redis set failed: %s", err)
+		}
+
+		componentID, err := beego.AppConfig.Int64("openwechatcomponentid")
+		if err != nil {
+			utils.ErrorLog("get component id failed: %s", err)
+		}
+
+		err = wechat_service.SaveWechatComponentVerifyTicket(componentID, requestBody.ComponentVerifyTicket)
+		if err != nil {
+			utils.ErrorLog("SaveWechatComponentVerifyTicket failed: %s", err)
+		}
+
+	} else if requestBody.InfoType == "authorized" {
+		utils.InfoLog("authorized: %s", requestBody.AuthorizerAppid)
+
+	} else if requestBody.InfoType == "unauthorized" {
+		utils.InfoLog("unauthorized: %s", requestBody.AuthorizerAppid)
+
+		err = wechat_service.SaveAuthorizerStatusByAppID(requestBody.AuthorizerAppid, 2)
+		if err != nil {
+			utils.ErrorLog("SaveAuthorizerStatus failed: %s", err)
+		}
+
+	} else if requestBody.InfoType == "updateauthorized" || requestBody.InfoType == "authorized" {
+		utils.InfoLog("%s: %s", requestBody.AuthorizerAppid, requestBody.InfoType)
+	} else {
+		utils.ErrorLog("Unkown infotype")
+		c.Ctx.WriteString("success")
+		return
+	}
+
+	c.Ctx.WriteString("success")
+}
+
+//MpWechatNotice 授权后公众号消息与事件接收URL
+func (c *OpenWechatAPIController) MpWechatNotice() {
+	appid := c.GetString("appid")
+	if len(appid) == 0 {
+		utils.ErrorLog("appid not found")
+		c.Ctx.WriteString("success")
+		return
+	}
+
+	authorizer, err := wechat_service.GetAuthorizationByOnlyAppID(appid)
+	if err != nil {
+		utils.ErrorLog("Get MP Info error: %s", err)
+		c.Ctx.WriteString("success")
+		return
+	}
+	if authorizer == nil {
+		utils.ErrorLog("Get MP Info error: 信息不存在")
+		c.Ctx.WriteString("success")
+		return
+	}
+
+	orgID := authorizer.UserOrgId
+	timestamp := c.GetString("timestamp")
+	nonce := c.GetString("nonce")
+	// openid := c.GetString("openid")
+	// encryptType := c.GetString("encrypt_type")
+	msgSignature := c.GetString("msg_signature")
+	// signature := c.GetString("signature")
+
+	r := c.Ctx.Request
+
+	body, err := ioutil.ReadAll(r.Body)
+	if err != nil {
+		utils.ErrorLog("read body error: %s", err)
+		c.Ctx.WriteString("success")
+		return
+	}
+	encryptRequestBody := &wechat_service.EncryptRequestBody{}
+	err = xml.Unmarshal(body, encryptRequestBody)
+	if err != nil {
+		utils.ErrorLog("Unmarshal body error: %s", err)
+		c.Ctx.WriteString("success")
+		return
+	}
+
+	// Validate mstBody signature
+	if !wechat_service.ValidateMsg(timestamp, nonce, encryptRequestBody.Encrypt, msgSignature) {
+		fmt.Println("aa")
+		c.Ctx.WriteString("success")
+		return
+	}
+
+	// Decode base64
+	cipherData, err := base64.StdEncoding.DecodeString(encryptRequestBody.Encrypt)
+	if err != nil {
+		c.Ctx.WriteString("success")
+		return
+	}
+
+	// AES Decrypt
+	plainData, err := wechat_service.AesDecrypt(cipherData, wechat_service.AesKey)
+	if err != nil {
+		utils.ErrorLog("AesDecrypt error: %s", err)
+		c.Ctx.WriteString("success")
+		return
+	}
+
+	//封装struct
+	textRequestBody, err := wechat_service.ParseEncryptTextRequestBody(plainData)
+	if err != nil {
+		c.Ctx.WriteString("success")
+		return
+	}
+
+	fmt.Println(textRequestBody)
+	tp := textRequestBody.MsgType
+
+	FromUserName := textRequestBody.ToUserName
+	ToUserName := textRequestBody.FromUserName
+
+	if tp == "text" {
+		//当用户向微信公众号发送消息时，回复ta
+		wechat_service.SendMsgTypeTextMessage(appid, ToUserName, FromUserName, textRequestBody.Content, nonce, timestamp, c.Ctx, orgID)
+		return
+	}
+	if tp == "event" {
+		eventType := textRequestBody.Event
+		if eventType == "subscribe" {
+			//当用户关注微信公众号，回复ta
+			wechat_service.SendSubscribeTextMessage(appid, ToUserName, FromUserName, nonce, timestamp, c.Ctx, orgID)
+			return
+		}
+
+		if eventType == "CLICK" {
+			//当用户点击click类型的菜单，回复ta
+			wechat_service.SendClickButtonMessage(appid, ToUserName, FromUserName, textRequestBody.EventKey, nonce, timestamp, c.Ctx, orgID)
+			return
+		}
+
+		if eventType == "unsubscribe" {
+			org_service.SetFansUnsubscribe(orgID, ToUserName)
+		}
+
+		//某个类型的消息暂时后台不作处理，也需要向微信服务器做出响应
+		c.Ctx.WriteString("success")
+		return
+	}
+	c.Ctx.WriteString("success")
+}
+
+func (c *OpenWechatAPIController) Authorization() {
+
+	id, _ := c.GetInt64("id", 0)
+	if id <= 0 {
+		c.Ctx.WriteString("没有选择授权对象")
+		return
+	}
+	vtime, _ := c.GetInt64("vtime", 0)
+	if vtime <= 0 {
+		c.Ctx.WriteString("缺少vtime参数")
+		return
+	}
+	vcode := c.GetString("vcode")
+	if len(vcode) == 0 {
+		c.Ctx.WriteString("缺少vtime参数")
+		return
+	}
+	vtime, tcode := utils.GetOrgIdCode(id, vtime)
+	if tcode != vcode {
+		c.Ctx.WriteString("无效的vcode")
+		return
+	}
+
+	code, err := wechat_service.GetReqPreAuthCode()
+	if err != nil {
+		c.ServeFailJsonSend(enums.ErrorCodeDataException, "获取授权URL失败:（"+err.Error()+"）")
+		return
+	}
+
+	uri := fmt.Sprintf(beego.AppConfig.String("httpdomain")+"/openwechat/mp/authorizerinfo/%d/%d/%s", id, vtime, vcode)
+	url := "https://mp.weixin.qq.com/safe/bindcomponent?action=bindcomponent&auth_type=1&no_scan=1&component_appid=" + beego.AppConfig.String("openwechatappid") + "&pre_auth_code=" + code + "&redirect_uri=" + uri + "&auth_type=1#wechat_redirect"
+
+	c.Data["url"] = url
+	c.TplName = "openwechat/authorization.html"
+
+}
+
+//AuthorizerInfo 拉取公众号授权信息和基本信息
+func (c *OpenWechatAPIController) AuthorizerInfo() {
+	idS := c.Ctx.Input.Param(":id")
+	vtimeS := c.Ctx.Input.Param(":vtime")
+	vcode := c.Ctx.Input.Param(":vcode")
+	id, err := strconv.ParseInt(idS, 10, 64)
+	if err != nil {
+		c.Data["msg"] = err.Error()
+		c.TplName = "openwechat/errorauth.html"
+		return
+	}
+	vtime, err := strconv.ParseInt(vtimeS, 10, 64)
+	if err != nil {
+		c.Data["msg"] = err.Error()
+		c.TplName = "openwechat/errorauth.html"
+		return
+	}
+	vtime, tcode := utils.GetOrgIdCode(id, vtime)
+	if tcode != vcode {
+		c.Data["msg"] = "无效的vcode"
+		c.TplName = "openwechat/errorauth.html"
+		return
+	}
+
+	authorizationCode := c.GetString("auth_code")
+
+	redisClient := service.RedisClient()
+
+	componentAccessToken, err := redisClient.Get("sgj_patient:component_access_token").Result()
+	if err != nil {
+		c.Data["msg"] = "需要component_access_token才能验证信息"
+		c.TplName = "openwechat/errorauth.html"
+		return
+	}
+
+	body, err := wechat_service.ComponentAPIQueryAuth(authorizationCode, componentAccessToken)
+	if err != nil {
+		c.Data["msg"] = "获取公众号授权信息失败"
+		c.TplName = "openwechat/errorauth.html"
+		return
+	}
+
+	var ai wechat_service.AuthorizationInfo
+	err = json.Unmarshal([]byte(body), &ai)
+	if err != nil {
+		c.Data["msg"] = "解析公众号授权信息失败"
+		c.TplName = "openwechat/errorauth.html"
+		return
+	}
+
+	body, err = wechat_service.ComponentAPIGetAuthorizerInfo(ai.AuthorizationInfo.AuthorizerAppid, componentAccessToken)
+	if err != nil {
+		c.Data["msg"] = "获取公众号信息失败"
+		c.TplName = "openwechat/errorauth.html"
+		return
+	}
+
+	var aui wechat_service.AuthorizerInfo
+	err = json.Unmarshal([]byte(body), &aui)
+	if err != nil {
+		c.Data["msg"] = "解析公众号信息失败"
+		c.TplName = "openwechat/errorauth.html"
+		return
+	}
+
+	var funcInfoItem []string
+	for _, valjue := range ai.AuthorizationInfo.FuncInfo {
+		funcInfoItem = append(funcInfoItem, strconv.FormatInt(valjue.FuncscopeCategory.ID, 10))
+	}
+
+	BusinessInfo, err := json.MarshalIndent(aui.AuthorizerInfo.BusinessInfo, "", " ")
+	//用json，功能的开通状况（0代表未开通，1代表已开通）： open_store:是否开通微信门店功能 open_scan:是否开通微信扫商品功能 open_pay:是否开通微信支付功能 open_card:是否开通微信卡券功能 open_shake:是否开通微信摇一摇功能
+	if err != nil {
+		c.Data["msg"] = "解析公众号功能的开通状况失败"
+		c.TplName = "openwechat/errorauth.html"
+		return
+	}
+
+	authorizationsInfo, err := wechat_service.GetAuthorizationByOrgID(id)
+	if err != nil {
+		c.Data["msg"] = "读取公众号信息失败"
+		c.TplName = "openwechat/errorauth.html"
+		return
+	}
+	var authorizations models.PatientAuthorizations
+	if authorizationsInfo == nil {
+		authorizations.UserOrgId = id
+		authorizations.CreatedTime = time.Now().Unix()
+	} else {
+		authorizations = *authorizationsInfo
+	}
+	authorizations.UpdatedTime = time.Now().Unix()
+	authorizations.AuthorizerAccessToken = ai.AuthorizationInfo.AuthorizerAccessToken
+	authorizations.AuthorizerRefreshToken = ai.AuthorizationInfo.AuthorizerRefreshToken
+	authorizations.AuthorizerFuncscopeCategory = strings.Join(funcInfoItem, ",")
+	authorizations.AuthorizerAppid = ai.AuthorizationInfo.AuthorizerAppid
+	authorizations.AuthorizerNickName = aui.AuthorizerInfo.NickName
+	authorizations.AuthorizerHeadImg = aui.AuthorizerInfo.HeadImg
+	authorizations.AuthorizerServiceTypeInfo = aui.AuthorizerInfo.ServiceTypeInfo.ID
+	authorizations.AuthorizerVerifyTypeInfo = aui.AuthorizerInfo.VerifyTypeInfo.ID
+	authorizations.AuthorizerUserName = aui.AuthorizerInfo.UserName
+	authorizations.AuthorizerPrincipalName = aui.AuthorizerInfo.PrincipalName
+	authorizations.AuthorizerBusinessInfo = string(BusinessInfo)
+	authorizations.AuthorizerQrcodeUrl = aui.AuthorizerInfo.QrcodeURL
+	authorizations.AuthorizerStatus = 1
+
+	err = wechat_service.SaveAuthorizationInfo(&authorizations)
+	if err != nil {
+		c.Data["msg"] = "保存公众号信息失败"
+		c.TplName = "openwechat/errorauth.html"
+		return
+	}
+
+	c.TplName = "openwechat/successauth.html"
+	return
+}

controllers/global/router_collector.go

@@ -4,4 +4,5 @@ func RegisterRouters() {
 	ErrorCtlRegistRouters()
 	DistrictCtlRegistRouters()
 	QiniuCtlRegistRouters()
+	OpenWechatCtlRegistRouters()
 }

controllers/marketing_tool/activity_controller.go

@@ -5,6 +5,8 @@ import (
 	"SCRM/enums"
 	"SCRM/models"
 	"SCRM/service/marketing_tool_service"
+	"SCRM/utils"
+	"encoding/json"
 	"time"
 
 	"github.com/astaxie/beego"
@@ -12,6 +14,8 @@ import (
 
 func ActivityCtlRegistRouters() {
 	beego.Router("/api/activities", &ActivityAPIController{}, "get:Activities")
+	beego.Router("/api/activity", &ActivityAPIController{}, "get:GetActivity")
+	beego.Router("/api/activity/submit", &ActivityAPIController{}, "post:ActivitySubmit")
 }
 
 type ActivityAPIController struct {
@@ -114,3 +118,214 @@ func (this *ActivityAPIController) _convertToUnapprovedActivityViewJSON(activity
 	json["start_time"] = activity.StartTime
 	return json
 }
+
+// /api/activity [get]
+// @param id:int
+func (this *ActivityAPIController) GetActivity() {
+	activityID, _ := this.GetInt64("id")
+	if activityID <= 0 {
+		this.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeParamWrong)
+		return
+	}
+
+	adminUserInfo := this.GetAdminUserInfo()
+	activity, getActivityErr := marketing_tool_service.GetActivityWithID(adminUserInfo.CurrentOrgId, activityID)
+	if getActivityErr != nil {
+		this.ErrorLog("获取活动失败:%v", getActivityErr)
+		this.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeDataException)
+		return
+	} else if activity == nil {
+		this.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeActivityNotExist)
+		return
+	}
+
+	paragraph, getParagraphErr := marketing_tool_service.GetActivityParagraphByActivityID(activity.Id)
+	if getParagraphErr != nil {
+		this.ErrorLog("获取活动段落失败：%v", getParagraphErr)
+		this.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeDataException)
+		return
+	}
+
+	paragraphTitle := ""
+	paragraphContent := ""
+	if paragraph != nil {
+		paragraphTitle = paragraph.Title
+		paragraphContent = paragraph.Text
+	}
+
+	this.ServeSuccessJSON(map[string]interface{}{
+		"activity": activity,
+		"paragraph": map[string]interface{}{
+			"title":   paragraphTitle,
+			"content": paragraphContent,
+		},
+	})
+}
+
+// /api/activity/submit [post]
+// @param publish:bool 是否发布
+// @data 如下格式
+/*
+{
+	id?:int
+	title:string
+	subtitle:string
+	poster_photo:string
+	address:string
+	limit_num?:int
+	sign_up_deadline:string ("yyyy-MM-dd HH:mm")
+	start_time:string ("yyyy-MM-dd HH:mm")
+	phone_number?:string
+	sign_up_notice?:string
+
+	paragraph: {
+		title:string
+		content:string
+	}
+}
+*/
+func (this *ActivityAPIController) ActivitySubmit() {
+	publish, _ := this.GetBool("publish")
+
+	var activityForm ActivityForm
+	parseErr := json.Unmarshal(this.Ctx.Input.RequestBody, &activityForm)
+	if parseErr != nil {
+		this.ErrorLog("解析 activity form 失败：%v", parseErr)
+		this.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeParamFormatWrong)
+		return
+	}
+
+	adminUserInfo := this.GetAdminUserInfo()
+	var activity *models.Activity
+	if activityForm.ID > 0 {
+		var getActivityErr error
+		activity, getActivityErr = marketing_tool_service.GetActivityWithID(adminUserInfo.CurrentOrgId, activityForm.ID)
+		if getActivityErr != nil {
+			this.ErrorLog("获取活动失败：%v", getActivityErr)
+			this.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeDataException)
+			return
+		} else if activity == nil || activity.Status == 9 {
+			this.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeActivityNotExist)
+			return
+		}
+	}
+	if len(activityForm.Title) == 0 || len(activityForm.Subtitle) == 0 || len(activityForm.PosterPhoto) == 0 || len(activityForm.Address) == 0 || len(activityForm.SignUpDeadline) == 0 || len(activityForm.StartTime) == 0 {
+		this.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeParamWrong)
+		return
+	}
+	timeFmt := "2006-01-02 15:04"
+	signUpDeadlineTime, parseSUDErr := utils.ParseTimeStringToTime(timeFmt, activityForm.SignUpDeadline)
+	if parseSUDErr != nil {
+		this.ErrorLog("解析报名截止时间失败:%v", parseSUDErr)
+		this.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeParamFormatWrong)
+		return
+	}
+	activityTime, parseActivityTimeErr := utils.ParseTimeStringToTime(timeFmt, activityForm.StartTime)
+	if parseActivityTimeErr != nil {
+		this.ErrorLog("解析活动开始时间失败:%v", parseActivityTimeErr)
+		this.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeParamFormatWrong)
+		return
+	}
+
+	if len(activityForm.PhoneNumber) > 0 {
+		if utils.PhoneRegexp().MatchString(activityForm.PhoneNumber) == false {
+			this.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeParamFormatWrong)
+			return
+		}
+	}
+	if activityForm.LimitNum < 0 {
+		activityForm.LimitNum = 0
+	}
+
+	if activity == nil {
+		activity = &models.Activity{
+			UserOrgId:        adminUserInfo.CurrentOrgId,
+			UserAppId:        adminUserInfo.CurrentAppId,
+			Title:            activityForm.Title,
+			Subtitle:         activityForm.Subtitle,
+			Address:          activityForm.Address,
+			SignUpDeadline:   signUpDeadlineTime.Unix(),
+			SignUpNotice:     activityForm.SignUpNotice,
+			StartTime:        activityTime.Unix(),
+			PosterPhoto:      activityForm.PosterPhoto,
+			PosterPhotoThumb: activityForm.PosterPhoto,
+			LimitNum:         activityForm.LimitNum,
+			PhoneNumber:      activityForm.PhoneNumber,
+			CreateTime:       time.Now().Unix(),
+		}
+	} else {
+		activity.Title = activityForm.Title
+		activity.Subtitle = activityForm.Subtitle
+		activity.Address = activityForm.Address
+		activity.SignUpDeadline = signUpDeadlineTime.Unix()
+		activity.SignUpNotice = activityForm.SignUpNotice
+		activity.StartTime = activityTime.Unix()
+		activity.PosterPhoto = activityForm.PosterPhoto
+		activity.PosterPhotoThumb = activityForm.PosterPhoto
+		activity.LimitNum = activityForm.LimitNum
+		activity.PhoneNumber = activityForm.PhoneNumber
+	}
+	activity.ModifyTime = time.Now().Unix()
+	if publish {
+		activity.Status = 1
+	} else {
+		activity.Status = 4
+	}
+
+	var paragraph *models.ActivityParagraph
+	if activity.Id > 0 {
+		var getPErr error
+		paragraph, getPErr = marketing_tool_service.GetActivityParagraphByActivityID(activity.Id)
+		if getPErr != nil {
+			this.ErrorLog("获取活动段落失败：%v", getPErr)
+			this.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeDataException)
+			return
+		}
+	}
+	if len(activityForm.Paragraph.Title) > 0 {
+		if paragraph == nil {
+			paragraph = &models.ActivityParagraph{
+				Title:      activityForm.Paragraph.Title,
+				Text:       activityForm.Paragraph.Content,
+				Status:     1,
+				CreateTime: time.Now().Unix(),
+				ModifyTime: time.Now().Unix(),
+			}
+		} else {
+			paragraph.Title = activityForm.Paragraph.Title
+			paragraph.Text = activityForm.Paragraph.Content
+			paragraph.ModifyTime = time.Now().Unix()
+		}
+	} else {
+		if paragraph != nil {
+			paragraph.Status = 0
+			paragraph.ModifyTime = time.Now().Unix()
+		}
+	}
+
+	saveErr := marketing_tool_service.SaveActivityAndParagraph(activity, paragraph)
+	if saveErr != nil {
+		this.ErrorLog("保存活动失败:%v", saveErr)
+		this.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeDataException)
+		return
+	}
+
+	wxShareModel, getWxShareErr := marketing_tool_service.GetActivityWxShareByActivityID(activity.Id)
+	if getWxShareErr != nil {
+		this.ErrorLog("获取活动微信分享信息失败:%v", getWxShareErr)
+	} else if wxShareModel != nil {
+		wxShareModel.ModifyTime = time.Now().Unix()
+		wxShareModel.Status = 1
+		wxShareModel.Title = activity.Title
+		wxShareModel.Subtitle = activity.Subtitle
+		wxShareModel.Image = activity.PosterPhoto
+		saveWxShareErr := marketing_tool_service.SaveActivityWxShare(wxShareModel)
+		if saveWxShareErr != nil {
+			this.ErrorLog("更新活动微信分享信息失败:%v", saveWxShareErr)
+		}
+	}
+
+	this.ServeSuccessJSON(map[string]interface{}{
+		"activity_id": activity.Id,
+	})
+}

controllers/marketing_tool/activity_vms.go

@@ -0,0 +1,19 @@
+package marketing_tool
+
+type ActivityForm struct {
+	ID             int64  `json:"id"`
+	Title          string `json:"title"`
+	Subtitle       string `json:"subtitle"`
+	PosterPhoto    string `json:"poster_photo"`
+	Address        string `json:"address"`
+	LimitNum       int    `json:"limit_num"`
+	SignUpDeadline string `json:"sign_up_deadline"`
+	StartTime      string `json:"start_time"`
+	PhoneNumber    string `json:"phone_number"`
+	SignUpNotice   string `json:"sign_up_notice"`
+
+	Paragraph struct {
+		Title   string `json:"title"`
+		Content string `json:"content"`
+	} `json:"paragraph"`
+}

controllers/members/card_controller.go

@@ -20,6 +20,7 @@ func CardCtlRegistRouters() {
 	beego.Router("/api/membercards", &CardAPIController{}, "Get:GetCards")
 	beego.Router("/api/membercard/create", &CardAPIController{}, "Post:CreateCard")
 	beego.Router("/api/membercard/edit", &CardAPIController{}, "Put:EditCard")
+	beego.Router("/api/membercard/right/edit", &CardAPIController{}, "Put:EditRight")
 	beego.Router("/api/membercards/delete", &CardAPIController{}, "Delete:DeleteCard")
 }
 
@@ -113,8 +114,14 @@ func (c *CardAPIController) GetCards() {
 	adminUserInfo := c.GetAdminUserInfo()
 	cards, _ := member_service.GetCardList(adminUserInfo.CurrentOrgId)
 
+	right, _ := member_service.GetMembershipRights(adminUserInfo.CurrentOrgId)
+	if right != nil && right.Status != 1 {
+		right = nil
+	}
+
 	returnData := make(map[string]interface{}, 0)
 	returnData["cards"] = cards
+	returnData["right"] = right
 	c.ServeSuccessJSON(returnData)
 	return
 }
@@ -440,3 +447,50 @@ func (c *CardAPIController) DeleteCard() {
 	c.ServeSuccessJSON(returnData)
 	return
 }
+
+func (c *CardAPIController) EditRight() {
+	adminUserInfo := c.GetAdminUserInfo()
+	timeNow := time.Now().Unix()
+
+	dataBody := make(map[string]interface{}, 0)
+	err := json.Unmarshal(c.Ctx.Input.RequestBody, &dataBody)
+	if err != nil {
+		utils.ErrorLog(err.Error())
+		c.ServeFailJsonSend(enums.ErrorCodeParamWrong, "参数错误")
+		return
+	}
+
+	var saveRight models.MembershipRights
+	right, err := member_service.GetMembershipRights(adminUserInfo.CurrentOrgId)
+	if err != nil {
+		c.ServeFailJsonSend(enums.ErrorCodeDBUpdate, "编辑会员权益失败:（"+err.Error()+"）")
+		return
+	}
+	if right != nil {
+		saveRight = *right
+	} else {
+		saveRight.UserOrgId = adminUserInfo.CurrentOrgId
+		saveRight.Status = 1
+		saveRight.CreatedTime = timeNow
+	}
+
+	if dataBody["rights"] == nil || reflect.TypeOf(dataBody["rights"]).String() != "string" {
+		c.ServeFailJsonSend(enums.ErrorCodeParamWrong, "缺少参数:rights")
+		return
+	}
+	rights, _ := dataBody["rights"].(string)
+	saveRight.Rights = rights
+	saveRight.UpdatedTime = timeNow
+
+	err = member_service.SaveMembershipRight(&saveRight)
+	if err != nil {
+		c.ServeFailJsonSend(enums.ErrorCodeDBUpdate, "编辑会员权益失败:（"+err.Error()+"）")
+		return
+	}
+
+	returnData := make(map[string]interface{}, 0)
+	returnData["right"] = saveRight
+	c.ServeSuccessJSON(returnData)
+	return
+
+}

controllers/mpwechat/menu_controller.go

@@ -0,0 +1,190 @@
+package mpwechat
+
+import (
+	base_ctl "SCRM/controllers"
+	"SCRM/enums"
+	"SCRM/models"
+	"SCRM/service/wechat_service"
+	"time"
+
+	"encoding/json"
+
+	"github.com/astaxie/beego"
+)
+
+func MpMenusCtlRegistRouters() {
+	beego.Router("/api/mpwechat/menus", &MpMenusAPIController{}, "Get:GetMenus")
+	beego.Router("/api/mpwechat/savemenus", &MpMenusAPIController{}, "Put:SaveMenus")
+}
+
+type MpMenusAPIController struct {
+	base_ctl.BaseAuthAPIController
+}
+
+func (c *MpMenusAPIController) GetMenus() {
+
+	adminUserInfo := c.GetAdminUserInfo()
+
+	buttons, err := wechat_service.GetOrgMenusWithMsgs(adminUserInfo.CurrentOrgId)
+	if err != nil {
+		c.ServeFailJsonSend(enums.ErrorCodeDataException, "读取菜单配置信息失败:（"+err.Error()+"）")
+		return
+	}
+	if buttons != nil && buttons.ButtonStatus != 1 {
+		buttons = nil
+	}
+
+	var menus wechat_service.SelfMenuInfo
+	if buttons != nil {
+		err = json.Unmarshal([]byte(buttons.ButtonFileds), &menus)
+		if err != nil {
+			c.ServeFailJsonSend(enums.ErrorCodeDataException, "解析菜单配置信息失败:（"+err.Error()+"）")
+			return
+		}
+
+		msgMap := make(map[string]string, 0)
+		for _, msg := range buttons.Messages {
+			msgMap[msg.MessageKeyName] = msg.MessageContent
+		}
+
+		for index, menu := range menus.Button {
+			if _, exist := msgMap[menu.Key]; exist {
+				menus.Button[index].Message = msgMap[menu.Key]
+			}
+			for sindex, sub := range menus.Button[index].SubButton {
+				if _, exist := msgMap[sub.Key]; exist {
+					menus.Button[index].SubButton[sindex].Message = msgMap[sub.Key]
+				}
+			}
+		}
+
+	}
+
+	returnData := make(map[string]interface{}, 0)
+	returnData["buttons"] = buttons
+	returnData["menus"] = menus
+	c.ServeSuccessJSON(returnData)
+	return
+}
+
+func (c *MpMenusAPIController) SaveMenus() {
+	adminUserInfo := c.GetAdminUserInfo()
+	authorization, err := wechat_service.GetAuthorizationByOrgID(adminUserInfo.CurrentOrgId)
+	if err != nil {
+		c.ServeFailJsonSend(enums.ErrorCodeDataException, "保存菜单失败:（"+err.Error()+"）")
+		return
+	}
+	if authorization == nil || authorization.AuthorizerStatus != 1 {
+		c.ServeFailJsonSend(enums.ErrorCodeDBUpdate, "保存菜单失败:（未授权）")
+		return
+	}
+
+	// 授权方公众号类型，0代表订阅号，1代表由历史老帐号升级后的订阅号，2代表服务号
+	// 授权方认证类型，-1代表未认证，0代表微信认证，1代表新浪微博认证，2代表腾讯微博认证，3代表已资质认证通过但还未通过名称认证，4代表已资质认证通过、还未通过名称认证，但通过了新浪微博认证，5代表已资质认证通过、还未通过名称认证，但通过了腾讯微博认证
+	if (authorization.AuthorizerServiceTypeInfo == 0 || authorization.AuthorizerServiceTypeInfo == 1) && authorization.AuthorizerVerifyTypeInfo == -1 {
+		c.ServeFailJsonSend(enums.ErrorCodeDBUpdate, "保存菜单失败:（未认证的订阅号没有自定义菜单的接口权限）")
+		return
+	}
+	var buttons wechat_service.SelfMenuInfo
+
+	err = json.Unmarshal(c.Ctx.Input.RequestBody, &buttons)
+	if err != nil {
+		c.ServeFailJsonSend(enums.ErrorCodeDBUpdate, "解析菜单失败:（"+err.Error()+"）")
+		return
+	}
+
+	clickMap := make(map[string]string, 0)
+	for pindex, button := range buttons.Button {
+		if button.Type == "click" && len(button.Key) > 0 && len(button.SubButton) == 0 {
+			clickMap[button.Key] = button.Message
+		}
+		if button.Type != "click" {
+			buttons.Button[pindex].Key = ""
+		}
+		if len(button.SubButton) > 0 {
+			for sindex, child := range button.SubButton {
+				if child.Type == "click" && len(child.Key) > 0 {
+					clickMap[child.Key] = child.Message
+				}
+				buttons.Button[pindex].SubButton[sindex].Message = ""
+
+				if child.Type != "click" {
+					buttons.Button[pindex].SubButton[sindex].Key = ""
+				}
+			}
+		}
+		buttons.Button[pindex].Message = ""
+	}
+	messages, err := wechat_service.GetOrgAllClickMessages(adminUserInfo.CurrentOrgId)
+	if err != nil {
+		c.ServeFailJsonSend(enums.ErrorCodeDataException, "保存菜单失败:（"+err.Error()+"）")
+		return
+	}
+	oldMsgs := make(map[string]models.AuthorizationMessageManagements)
+	for _, message := range messages {
+		if _, exist := clickMap[message.MessageKeyName]; exist {
+			msg := *message
+			oldMsgs[message.MessageKeyName] = msg
+		}
+	}
+
+	buttonFileds, err := json.Marshal(buttons)
+	if err != nil {
+		c.ServeFailJsonSend(enums.ErrorCodeDBUpdate, "解析菜单失败:（"+err.Error()+"）")
+		return
+	}
+
+	timeNow := time.Now().Unix()
+	var saveButton wechat_service.Buttons
+	saveButton.UserOrgID = adminUserInfo.CurrentOrgId
+	saveButton.UpdatedTime = timeNow
+	saveButton.ButtonStatus = 1
+	saveButton.SendStatus = 0
+	saveButton.ButtonFileds = string(buttonFileds)
+
+	button, err := wechat_service.GetMenusByOrgID(adminUserInfo.CurrentOrgId)
+	if err != nil {
+		c.ServeFailJsonSend(enums.ErrorCodeDataException, "保存菜单失败:（"+err.Error()+"）")
+		return
+	}
+	if button != nil {
+		saveButton.ID = button.ID
+		saveButton.CreatedTime = button.CreatedTime
+	}
+
+	saveButton.Messages = make([]*models.AuthorizationMessageManagements, 0)
+	for keyName, Content := range clickMap {
+		var msg models.AuthorizationMessageManagements
+		msg.MessageMsgType = "event"
+		msg.MessageMsgEvent = "click"
+		msg.MessageContent = Content
+		msg.UpdatedTime = timeNow
+		msg.MessageStatus = 1
+		msg.MessageKeyName = keyName
+		msg.UserOrgId = adminUserInfo.CurrentOrgId
+
+		if _, exist := oldMsgs[keyName]; exist {
+			msg.ID = oldMsgs[keyName].ID
+			msg.CreatedTime = oldMsgs[keyName].CreatedTime
+		} else {
+			msg.CreatedTime = timeNow
+		}
+		saveButton.Messages = append(saveButton.Messages, &msg)
+	}
+
+	err = wechat_service.SaveButtons(&saveButton)
+	if err != nil {
+		c.ServeFailJsonSend(enums.ErrorCodeDBUpdate, "保存菜单失败:（"+err.Error()+"）")
+		return
+	}
+	err = wechat_service.SendMpWechatMenus(authorization.AuthorizerAccessToken, buttonFileds)
+	if err != nil {
+		c.ServeFailJsonSend(enums.ErrorCodeDBUpdate, "保存菜单成功，但发布菜单到公众号失败:（"+err.Error()+"）")
+		return
+	}
+
+	returnData := make(map[string]interface{}, 0)
+	returnData["buttons"] = buttons
+	c.ServeSuccessJSON(returnData)
+	return
+}

controllers/mpwechat/mpwechat_controller.go

@@ -0,0 +1,51 @@
+package mpwechat
+
+import (
+	base_ctl "SCRM/controllers"
+	"SCRM/enums"
+	"SCRM/service/wechat_service"
+	"SCRM/utils"
+	"fmt"
+
+	"github.com/astaxie/beego"
+)
+
+func MpWechatCtlRegistRouters() {
+	beego.Router("/api/mpwechat/authorization", &MpWechatAPIController{}, "Get:GetAuthorizationInfo")
+	beego.Router("/api/mpwechat/authurl", &MpWechatAPIController{}, "Get:GetAuthUrl")
+}
+
+type MpWechatAPIController struct {
+	base_ctl.BaseAuthAPIController
+}
+
+func (c *MpWechatAPIController) GetAuthorizationInfo() {
+
+	adminUserInfo := c.GetAdminUserInfo()
+
+	authorization, err := wechat_service.GetAuthorizationByOrgID(adminUserInfo.CurrentOrgId)
+	if err != nil {
+		c.ServeFailJsonSend(enums.ErrorCodeDataException, "获取授权信息失败:（"+err.Error()+"）")
+		return
+	}
+
+	returnData := make(map[string]interface{}, 0)
+	returnData["authorization"] = authorization
+
+	c.ServeSuccessJSON(returnData)
+	return
+
+}
+
+func (c *MpWechatAPIController) GetAuthUrl() {
+
+	adminUserInfo := c.GetAdminUserInfo()
+
+	vcode, vtime := utils.GetOrgIdCode(adminUserInfo.CurrentOrgId, 0)
+	url := fmt.Sprintf("%s%s?id=%d&vcode=%s&vtime=%d", beego.AppConfig.String("httpdomain"), "/openwechat/mp/authorization", adminUserInfo.CurrentOrgId, vtime, vcode)
+
+	returnData := make(map[string]interface{}, 0)
+	returnData["url"] = url
+	c.ServeSuccessJSON(returnData)
+	return
+}

controllers/mpwechat/router_controller.go

@@ -0,0 +1,6 @@
+package mpwechat
+
+func RegisterRouters() {
+	MpWechatCtlRegistRouters()
+	MpMenusCtlRegistRouters()
+}

enums/error_code.go

@@ -44,63 +44,9 @@ const ( // ErrorCode
 	ErrorCodeCannotRemoveRole       = 9006
 	ErrorCodeRoleMobileIsSuperAdmin = 9007
 
-	ErrorCodeGetQiniuUpToken                = 1001
-	ErrorCodeCreatePatient                  = 1002
-	ErrorCodeDialysisNoExist                = 1003
-	ErrorCodeIdCardNoExist                  = 1004
-	ErrorCodePatientNoExist                 = 1005
-	ErrorCodeUpdatePatient                  = 1006
-	ErrorCodeDialysisSolutionExist          = 1007
-	ErrorCodeDialysisSolutionCreate         = 1008
-	ErrorCodeDialysisSolutionUpdate         = 1009
-	ErrorCodeDialysisSolutionNotExist       = 1010
-	ErrorCodeParentDialysisSolutionNotExist = 1011
-	ErrorCodeAlReadyHadChildSolution        = 1012
-	ErrorCodeCanntCreateChildChildSolution  = 1013
-	ErrorCodeDialysisSolutionUsed           = 1014
-	ErrorCodeCreateDryWeightFail            = 1015
-	ErrorCodeCreateDoctorAdviceFail         = 1016
-	ErrorCodeDoctorAdviceNotExist           = 1017
-	ErrorCodeUpdateDoctorAdviceFail         = 1018
-	ErrorCodeLongTimeAdviceNotCanntEdit     = 1019
-	ErrorCodeAdviceStoped                   = 1020
-	ErrorCodeParentAdviceNotExist           = 1021
-	ErrorCodeStopAdviceFail                 = 1022
-	ErrorCodeDeleteAdviceFail               = 1023
-	ErrorCodeDialysisSolutionDelete         = 1024
-	ErrorCodeDeviceNumberNotTheZone         = 1025
-	ErrorCodeCreateScheduleFail             = 1026
-	ErrorCodeCantSetScheduleAgainOneDay     = 1027
-	ErrorCodeCantSetScheduleBeforeNow       = 1028
-	ErrorCodeScheduleNotExist               = 1029
-	ErrorCodeDeleteScheduleFail             = 1030
-	ErrorCodeChangeScheduleFail             = 1031
-	ErrorCodePatientPhoneUsed               = 1032
-	ErrorCodeAdviceExced                    = 1033
-	ErrorCodeAdviceChecked                  = 1034
-	ErrorCodePointScheduleExist             = 1035
-	ErrorCodeExceAndCheckNotOneUser         = 1036
-	ErrorCodeCanotEditOtherAdvice           = 1037
-	ErrorCodeEditLapsetoFail                = 1038
-	ErrorCodeAdviceCheckBeforeExce          = 1039
-	ErrorCodeAdviceExceBeforeStart          = 1040
-	ErrorCodeDelScheduleFailByDialysis      = 1041
-	ErrorCodeNotSelectLapsetoType           = 1042
-	ErrorCodeNotSelectLapsetoTime           = 1043
+	ErrorCodeActivityNotExist = 9100
 
-	ErrorCodeInspectionDateExit    = 1201
-	ErrorCodeInspectionAddFail     = 1202
-	ErrorCodeInspectionEditFail    = 1204
-	ErrorCodeInspectionDateNotExit = 1203
-	ErrorCodeInspectionDeleteFail  = 1205
-
-	ErrorCodeMonitorCreate                  = 1128
-	ErrorCodeMonitorNotExist                = 1129
-	ErrorCodeMonitorUpdate                  = 1130
-	ErrorDialysisOrderNoStart               = 1132
-	ErrorDialysisOrderNoEND                 = 1133
-	ErrorDialysisOrderRepeatStart           = 1134
-	ErrorCodeDialysisPermissionDeniedModify = 1135
+	ErrorCodeGetQiniuUpToken = 1001
 
 	ErrorCodeNotSubscibe       = 4003
 	ErrorCodeServeNotExist     = 4004
@@ -109,50 +55,6 @@ const ( // ErrorCode
 	ErrorCodeHetongHad         = 4007
 	ErrorCodeCreateHetongFail  = 4008
 	ErrorCodePatientReachLimit = 4009
-
-	ErrorCodeDeviceZoneNotExist                      = 9021
-	ErrorCodeDeviceZoneNameRepeat                    = 9022
-	ErrorCodeDeviceGroupNotExist                     = 9023
-	ErrorCodeDeviceGroupNameRepeat                   = 9024
-	ErrorCodeDeviceNumberNotExist                    = 9025
-	ErrorCodeDeviceNumberRepeat                      = 9026
-	ErrorCodeDeviceNotExist                          = 9027
-	ErrorCodeDeviceZoneCannotDisable                 = 9028
-	ErrorCodeDeviceNumberCannotDisableCuzDevice      = 9029
-	ErrorCodeDeviceNumberCannotDisableCuzSchedule    = 9030
-	ErrorCodeDeviceNumberCannotDisableCuzSchTemplate = 9031
-
-	ErrorCommitFail = 90000
-
-	ErrorCodeCreateStockInFail = 20001
-
-	ErrorCodeScheduleTemplateNotExist = 10001
-
-	ErrorCodeSystemError  = 6666
-	ErrorCodeProductError = 6667
-	ErrorCodeFieldExist   = 100001
-	ErrorCodeCreateConfig = 100002
-	ErrorCodeUpdateConfig = 100003
-
-	ErrorCodeDoubleCheckWrong     = 200003
-	ErrorCodeDoubleCheckUserWrong = 200004
-	ErrorCodeGoodNoStockInError   = 200005
-	ErrorCodeCancelStockFail      = 200006
-	ErrorCodeDeleteGoodTypeFail   = 200007
-	ErrorCodeDeleteGoodInfoFail   = 200008
-	ErrorCodeDeleteFail           = 200009
-
-	ErrorCodeKeyFail                 = 200010
-	ErrorCodeDeleteStockInRecordFail = 200011
-	ErrorCodeNameWrong               = 200012
-
-	ErrorCodeParamEmptyWrong       = 200013
-	ErrorCodeParamAdviceEmptyWrong = 200014
-
-	ErrorCodeParamTemplateNOEXISTWrong = 200015
-
-	ErrorCodeDeleteDealerWrong       = 200016
-	ErrorCodeDeleteManufacturerWrong = 200017
 )
 
 var ErrCodeMsgs = map[int]string{
@@ -197,68 +99,9 @@ var ErrCodeMsgs = map[int]string{
 	ErrorCodeCannotRemoveRole:       "存在该角色的管理员，不能删除该角色",
 	ErrorCodeRoleMobileIsSuperAdmin: "该手机号已注册为超级管理员",
 
-	ErrorCodeGetQiniuUpToken: "获取七牛uptoken失败",
-	ErrorCodeCreatePatient:   "创建患者失败",
-	ErrorCodeDialysisNoExist: "患者透析号重复！",
-	ErrorCodeIdCardNoExist:   "身份证号重复！",
-	ErrorCodePatientNoExist:  "患者信息不存在！",
-	ErrorCodeUpdatePatient:   "修改患者信息失败",
-
-	ErrorCodeDialysisSolutionExist:          "该处方已经存在",
-	ErrorCodeDialysisSolutionCreate:         "创建处方失败",
-	ErrorCodeDialysisSolutionUpdate:         "修改处方失败",
-	ErrorCodeDialysisSolutionNotExist:       "该处方不存在",
-	ErrorCodeParentDialysisSolutionNotExist: "上级处方不存在",
-	ErrorCodeAlReadyHadChildSolution:        "所选处方已经存在子方案",
-	ErrorCodeCanntCreateChildChildSolution:  "子方案不能添加子方案",
-	ErrorCodeDialysisSolutionUsed:           "处方已被使用，不能删除",
-	ErrorCodeCreateDryWeightFail:            "添加干体重失败",
-	ErrorCodeCreateDoctorAdviceFail:         "添加医嘱失败",
-	ErrorCodeUpdateDoctorAdviceFail:         "修改医嘱信息失败",
-	ErrorCodeDoctorAdviceNotExist:           "医嘱不存在",
-	ErrorCodeLongTimeAdviceNotCanntEdit:     "长期医嘱不能修改！",
-	ErrorCodeAdviceStoped:                   "所选医嘱已停止",
-	ErrorCodeParentAdviceNotExist:           "上级医嘱不存在",
-	ErrorCodeDeleteAdviceFail:               "删除医嘱失败",
-	ErrorCodeStopAdviceFail:                 "停止医嘱失败",
-	ErrorCodeDialysisSolutionDelete:         "删除方案失败",
-	ErrorCodeDeviceNumberNotTheZone:         "所选机号不在选择分区中",
-	ErrorCodeCreateScheduleFail:             "添加排班失败",
-	ErrorCodeCantSetScheduleAgainOneDay:     "同一天不可有两次排班",
-	ErrorCodeCantSetScheduleBeforeNow:       "不能给今天之前的日期排班",
-	ErrorCodeScheduleNotExist:               "排班不存在",
-	ErrorCodePointScheduleExist:             "所先位置排班已经存在",
-	ErrorCodeDeleteScheduleFail:             "取消排班失败",
-	ErrorCodeChangeScheduleFail:             "修改排班失败",
-	ErrorCodePatientPhoneUsed:               "手机号已经存在",
-	ErrorCodeAdviceExced:                    "医嘱已经执行",
-	ErrorCodeAdviceCheckBeforeExce:          "核对医嘱不能在执行医嘱之前",
-	ErrorCodeAdviceExceBeforeStart:          "执行医嘱不能在开始之前",
-	ErrorCodeAdviceChecked:                  "医嘱已经核对",
-	ErrorCodeExceAndCheckNotOneUser:         "核对与执行不能是同一人",
-	ErrorCodeCanotEditOtherAdvice:           "不能修改非本人添加的医嘱",
-	ErrorCodeEditLapsetoFail:                "转归失败",
-	ErrorCodeDelScheduleFailByDialysis:      "已经上机透析，不能取消排班",
-	ErrorCodeNotSelectLapsetoType:           "请选择转归状态",
-	ErrorCodeNotSelectLapsetoTime:           "请选择转归时间",
-
-	ErrorCodeInspectionDateExit:    "当天已经存在检验检查记录",
-	ErrorCodeInspectionAddFail:     "添加记录失败",
-	ErrorCodeInspectionDateNotExit: "当天不存在检验检查记录",
-	ErrorCodeInspectionEditFail:    "修改记录失败",
-	ErrorCodeInspectionDeleteFail:  "删除记录失败",
+	ErrorCodeActivityNotExist: "活动不存在",
 
-	ErrorCodeDeviceZoneNotExist:                      "设备分区不存在",
-	ErrorCodeDeviceZoneNameRepeat:                    "该分区名已存在",
-	ErrorCodeDeviceGroupNotExist:                     "设备分组不存在",
-	ErrorCodeDeviceGroupNameRepeat:                   "该分组名已存在",
-	ErrorCodeDeviceNumberNotExist:                    "机号不存在",
-	ErrorCodeDeviceNumberRepeat:                      "该机号已存在",
-	ErrorCodeDeviceNotExist:                          "该设备不存在",
-	ErrorCodeDeviceZoneCannotDisable:                 "该分区存在床位号，不能删除",
-	ErrorCodeDeviceNumberCannotDisableCuzDevice:      "该床位存在设备，不能删除",
-	ErrorCodeDeviceNumberCannotDisableCuzSchedule:    "该床位尚有排班安排，不能删除",
-	ErrorCodeDeviceNumberCannotDisableCuzSchTemplate: "排班模板在该床位尚有排班安排，不能删除",
+	ErrorCodeGetQiniuUpToken: "获取七牛uptoken失败",
 
 	ErrorCodeNotSubscibe:       "没有订阅服务或服务已过期，请先购买服务！",
 	ErrorCodeServeNotExist:     "服务订单不存在！",
@@ -267,47 +110,6 @@ var ErrCodeMsgs = map[int]string{
 	ErrorCodeHetongHad:         "合同已经存在！",
 	ErrorCodeCreateHetongFail:  "合同创建失败",
 	ErrorCodePatientReachLimit: "患者数已达到当前服务版本病人数，需要升级到更高的版本",
-
-	ErrorCodeMonitorCreate:                  "创建监测失败",
-	ErrorCodeMonitorNotExist:                "监测记录不存在",
-	ErrorCodeMonitorUpdate:                  "修改监测失败",
-	ErrorCodeDialysisPermissionDeniedModify: "您没有权限修改其他医护的数据！",
-
-	ErrorDialysisOrderNoStart:     "尚未上机，无法执行下机操作",
-	ErrorDialysisOrderNoEND:       "已处于下机状态",
-	ErrorDialysisOrderRepeatStart: "已上机",
-	//ErrorCodeScheduleTemplateNotExist: "排班模板不存在",
-
-	ErrorCodeSystemError:              "系统异常",
-	ErrorCodeProductError:             "该服务商品已丢失",
-	ErrorCodeScheduleTemplateNotExist: "排班模板不存在",
-
-	ErrorCodeCreateStockInFail: "入库失败",
-	//ErrorCodeSystemError:  "系统异常",
-	//ErrorCodeProductError: "该服务商品已丢失",
-	ErrorCodeFieldExist:   "配置字段已存在",
-	ErrorCodeCreateConfig: "创建配置失败",
-	ErrorCodeUpdateConfig: "修改配置失败",
-
-	ErrorCommitFail:               "提交失败",
-	ErrorCodeDoubleCheckWrong:     "核对已完成, 无法再次提交",
-	ErrorCodeDoubleCheckUserWrong: "你已完成核对，不能重复核对",
-	ErrorCodeGoodNoStockInError:   "该商品尚未入库",
-
-	ErrorCodeCancelStockFail:    "出库退库失败",
-	ErrorCodeDeleteGoodTypeFail: "该类型存在商品信息,无法删除",
-	ErrorCodeDeleteGoodInfoFail: "该商品已经入库无法删除",
-
-	ErrorCodeDeleteFail: "删除失败",
-
-	ErrorCodeKeyFail:                 "关键字不能为空",
-	ErrorCodeDeleteStockInRecordFail: "该记录已经有出库或退货操作,无法删除",
-	ErrorCodeNameWrong:               "该模版名字已存在",
-	ErrorCodeParamEmptyWrong:         "模版名称不能为空",
-	ErrorCodeParamAdviceEmptyWrong:   "医嘱名称不能为空",
-
-	ErrorCodeDeleteDealerWrong:       "该经销商所属商品已入库无法删除",
-	ErrorCodeDeleteManufacturerWrong: "该厂商所属商品已入库无法删除",
 }
 
 type SGJError struct {

jobcron/open_wechat_job.go

@@ -0,0 +1,200 @@
+package jobcron
+
+import (
+	"encoding/json"
+	"fmt"
+	"time"
+
+	"github.com/silenceper/wechat/util"
+
+	"SCRM/service"
+	"SCRM/service/wechat_service"
+	"SCRM/utils"
+
+	"github.com/astaxie/beego"
+	"github.com/robfig/cron"
+)
+
+var openWechatCron *cron.Cron
+
+func init() {
+	openWechatCron = cron.New()
+	openWechatCron.AddFunc("@every 1h30m", func() {
+		go func() {
+			RequestComponentAccessToken()
+		}()
+	})
+
+	openWechatCron.AddFunc("@every 1h30m", func() {
+		go func() {
+			RequestMpWechatAccessToken()
+		}()
+	})
+
+}
+
+func StartOpenWechatCron() {
+	openWechatCron.Start()
+}
+
+var (
+	token          = beego.AppConfig.String("openwechattoken")
+	appID          = beego.AppConfig.String("openwechatappid")
+	encodingAESKey = beego.AppConfig.String("openwechatencodingaeskey")
+	appSecret      = beego.AppConfig.String("openwechatsecret")
+)
+
+type ReqComponentAccessStruct struct {
+	ComponentAppid        string `json:"component_appid"`
+	ComponentAppSecret    string `json:"component_appsecret"`
+	ComponentVerifyTicket string `json:"component_verify_ticket"`
+}
+
+//请求第三方平台的accessToken
+func RequestComponentAccessToken() {
+	utils.InfoLog("Request ComponentAccessToken Start...")
+	redisClient := service.RedisClient()
+	defer redisClient.Close()
+
+	componentVerifyTicket, err := redisClient.Get("sgj_patient:ComponentVerifyTicket").Result()
+	if err != nil {
+		utils.ErrorLog("读取ComponentVerifyTicket失败：%s", err)
+		return
+	}
+
+	//假设 拿到了  component_verify_ticket ，开始通过接口 拿 component_access_token
+	//获取第三方平台component_access_token,POST数据
+	var ReqComponentAccess ReqComponentAccessStruct
+	ReqComponentAccess.ComponentAppid = appID
+	ReqComponentAccess.ComponentAppSecret = appSecret
+	ReqComponentAccess.ComponentVerifyTicket = componentVerifyTicket
+	fmt.Println(ReqComponentAccess)
+	//创建请求
+	uri := fmt.Sprintf("%s", "https://api.weixin.qq.com/cgi-bin/component/api_component_token")
+	var responseBytes []byte
+	responseBytes, err = util.PostJSON(uri, ReqComponentAccess)
+	if err != nil {
+		utils.ErrorLog("创建请求失败：%s", err)
+		return
+	}
+
+	var res wechat_service.MPResult
+	err = json.Unmarshal(responseBytes, &res)
+	if err != nil {
+		utils.ErrorLog("MPResult error：%s", err)
+		return
+	}
+
+	if res.ErrCode > 0 {
+		fmt.Println(res.ErrMsg)
+		return
+	}
+
+	//body 是上面请求返回的json数据
+	//{"component_access_token":"61W3mEpU66027wgNZ_MhGHNQDHnFATkDa9-2llqrMBjUwxRSNPbVsMmyD-yq8wZETSoE5NQgecigDrSHkPtIYA", "expires_in":7200}
+	var access_token wechat_service.ComponentAccessToken
+	// 将body的json解析成 access_token ComponentAccessToken
+	err = json.Unmarshal(responseBytes, &access_token)
+	if err != nil {
+		utils.ErrorLog("Unmarshal json error：%s", err)
+		return
+	}
+
+	err = redisClient.Set("sgj_patient:component_access_token", access_token.ComponentAccessToken, time.Second*7000).Err()
+	if err != nil {
+		utils.ErrorLog("redis set failed：%s", err)
+		return
+	}
+
+	componentID, err := beego.AppConfig.Int64("openwechatcomponentid")
+	if err != nil {
+		utils.ErrorLog("get component id failed: %s", err)
+		return
+	}
+
+	info := make(map[string]interface{}, 0)
+	info["ComponentAccessToken"] = access_token.ComponentAccessToken
+	info["UpdatedTime"] = time.Now().Unix()
+	info["ComponentStatus"] = 1
+
+	err = wechat_service.SaveWechatComponentInfoByMap(componentID, info)
+
+	utils.InfoLog("Request ComponentAccessToken Finish.")
+}
+
+type ReqRefreshTokenStruct struct {
+	ComponentAppid         string `json:"component_appid"`
+	AuthorizerAppid        string `json:"authorizer_appid"`
+	AuthorizerRefreshToken string `json:"authorizer_refresh_token"`
+}
+
+func RequestMpWechatAccessToken() {
+	utils.InfoLog("Request MpWechatAccessToken start...")
+	mps, err := wechat_service.GetAuthorizations()
+	if err != nil {
+		utils.ErrorLog("get mps error: %s", err)
+		return
+	}
+
+	redisClient := service.RedisClient()
+	defer redisClient.Close()
+
+	componentAccessToken, err := redisClient.Get("sgj_patient:component_access_token").Result()
+	if err != nil {
+		utils.ErrorLog("get component_access_token error: %s", err)
+		return
+	}
+
+	for _, item := range mps {
+		var ReqRefreshToken ReqRefreshTokenStruct
+		ReqRefreshToken.ComponentAppid = appID
+		ReqRefreshToken.AuthorizerAppid = item.AuthorizerAppid
+		ReqRefreshToken.AuthorizerRefreshToken = item.AuthorizerRefreshToken
+
+		uri := fmt.Sprintf("%s?component_access_token=%s", "https://api.weixin.qq.com/cgi-bin/component/api_authorizer_token", componentAccessToken)
+		var responseBytes []byte
+		responseBytes, err = util.PostJSON(uri, ReqRefreshToken)
+		if err != nil {
+			utils.ErrorLog(" error: %s", err)
+			return
+		}
+
+		var res wechat_service.MPResult
+		err = json.Unmarshal(responseBytes, &res)
+		if err != nil {
+			utils.ErrorLog(" error: %s", err)
+			return
+		}
+
+		if res.ErrCode > 0 {
+			utils.ErrorLog(" error: %s", res.ErrMsg)
+			return
+		}
+
+		var accessToken wechat_service.RefreshToken
+		err = json.Unmarshal(responseBytes, &accessToken)
+		if err != nil {
+			utils.ErrorLog("Unmarshal error: %s", err)
+			continue
+		}
+
+		info := *item
+		info.AuthorizerAccessToken = accessToken.AuthorizerAccessToken
+		info.AuthorizerRefreshToken = accessToken.AuthorizerRefreshToken
+		info.UpdatedTime = time.Now().Unix()
+		err = wechat_service.SaveAuthorizationInfo(&info)
+		if err != nil {
+			utils.ErrorLog("Save error: %s", err)
+			continue
+		}
+
+		atKey := fmt.Sprintf("Patient:AccessToken[%s]", item.AuthorizerAppid)
+		_, err = redisClient.Set(atKey, accessToken.AuthorizerAccessToken, 0).Result()
+		if err != nil {
+			utils.ErrorLog("Save redis error: %s", err)
+			continue
+		}
+	}
+	utils.InfoLog("Request MpWechatAccessToken END")
+
+}

main.go

@@ -1,9 +1,12 @@
 package main
 
 import (
+	"SCRM/jobcron"
 	_ "SCRM/routers"
 	"SCRM/service"
 
+	// "SCRM/jobcron"
+
 	"github.com/astaxie/beego"
 )
 
@@ -12,5 +15,14 @@ func init() {
 }
 
 func main() {
+
+	//微信开放平台
+	go func() {
+		// jobcron.RequestComponentAccessToken()
+		// jobcron.RequestMpWechatAccessToken()
+		// jobcron.ReqJsapiTicket()
+	}()
+	jobcron.StartOpenWechatCron()
+
 	beego.Run()
 }

models/activity_models.go

@@ -2,7 +2,7 @@ package models
 
 // 表
 type Activity struct {
-	Id               int    `gorm:"column:id" json:"id"`                                 // 活动 ID
+	Id               int64  `gorm:"column:id" json:"id"`                                 // 活动 ID
 	Title            string `json:"title"`                                               // 活动标题
 	Subtitle         string `json:"subtitle"`                                            // 活动副标题
 	CityId           int    `gorm:"column:city_id" json:"city_id"`                       // 活动地点 ID
@@ -24,8 +24,8 @@ type Activity struct {
 	IsRecommend      int8   `gorm:"column:is_recommend;" json:"is_recommend"`            // 0:未推荐;1:已推荐
 	CreateTime       int64  `gorm:"column:ctime" json:"-"`                               // 创建时间
 	ModifyTime       int64  `gorm:"column:mtime" json:"-"`                               // 修改时间
-	UserOrgId        int    `gorm:"column:user_org_id" json:"-"`                         // 所属发布机构 ID
-	UserAppId        int    `gorm:"column:user_app_id" json:"-"`                         // 所属发布应用 ID
+	UserOrgId        int64  `gorm:"column:user_org_id" json:"-"`                         // 所属发布机构 ID
+	UserAppId        int64  `gorm:"column:user_app_id" json:"-"`                         // 所属发布应用 ID
 	CommentNum       int    `gorm:"column:comment_num;" json:"comment_num"`              // 评论数
 	StarNum          int    `gorm:"column:star_num" json:"star_num"`                     // 点赞书
 	ReadNum          int    `gorm:"column:read_num;" json:"read_num"`                    // 阅读数
@@ -36,14 +36,14 @@ func (Activity) TableName() string {
 }
 
 type ActivityParagraph struct {
-	Id         int `gorm:"PRIMARY_KEY;AUTO_INCREMENT"` // 记录 ID
-	ActivityId int `gorm:"column:activity_id"`         // 活动 ID
-	Title      string
-	Text       string
-	Image      string
-	Status     int8  // 状态 0.无效 1.有效
-	CreateTime int64 `gorm:"column:ctime"` // 创建时间
-	ModifyTime int64 `gorm:"column:mtime"` // 修改时间
+	Id         int64  `gorm:"PRIMARY_KEY;AUTO_INCREMENT" json:"id"`  // 记录 ID
+	ActivityId int64  `gorm:"column:activity_id" json:"activity_id"` // 活动 ID
+	Title      string `json:"title"`
+	Text       string `json:"text"`
+	// Image      string `json:"image"` // 该字段实际上已经没用了
+	Status     int8  `json:"-"`                     // 状态 0.无效 1.有效
+	CreateTime int64 `gorm:"column:ctime" json:"-"` // 创建时间
+	ModifyTime int64 `gorm:"column:mtime" json:"-"` // 修改时间
 }
 
 func (ActivityParagraph) TableName() string {

models/org_fans_models.go

@@ -0,0 +1,29 @@
+package models
+
+type OrgFans struct {
+	ID          int64  `gorm:"column:id" json:"id" form:"id"`
+	UserOrgId   int64  `gorm:"column:user_org_id" json:"user_org_id" form:"user_org_id"`
+	UserId      int64  `gorm:"column:user_id" json:"user_id" form:"user_id"`
+	Mobile      string `gorm:"column:mobile" json:"mobile" form:"mobile"`
+	Name        string `gorm:"column:name" json:"name" form:"name"`
+	Gender      int64  `gorm:"column:gender" json:"gender" form:"gender"`
+	ProvinceId  int64  `gorm:"column:province_id" json:"province_id" form:"province_id"`
+	CityId      int64  `gorm:"column:city_id" json:"city_id" form:"city_id"`
+	Address     string `gorm:"column:address" json:"address" form:"address"`
+	Birthday    int64  `gorm:"column:birthday" json:"birthday" form:"birthday"`
+	Openid      string `gorm:"column:openid" json:"openid" form:"openid"`
+	Sources     int64  `gorm:"column:sources" json:"sources" form:"sources"`
+	Avatar      string `gorm:"column:avatar" json:"avatar" form:"avatar"`
+	Unionid     string `gorm:"column:unionid" json:"unionid" form:"unionid"`
+	Status      int64  `gorm:"column:status" json:"status" form:"status"`
+	CreatedTime int64  `gorm:"column:created_time" json:"created_time" form:"created_time"`
+	UpdatedTime int64  `gorm:"column:updated_time" json:"updated_time" form:"updated_time"`
+	Ttid        int64  `gorm:"column:ttid" json:"ttid" form:"ttid"`
+	Tuid        int64  `gorm:"column:tuid" json:"tuid" form:"tuid"`
+	Taid        int64  `gorm:"column:taid" json:"taid" form:"taid"`
+	Ttype       int64  `gorm:"column:ttype" json:"ttype" form:"ttype"`
+}
+
+func (Org) OrgFans() string {
+	return "sgj_user_org_fans"
+}

models/user_membership_card_models.go

@@ -36,3 +36,16 @@ type UserCard struct {
 func (UserCard) TableName() string {
 	return "sgj_user_user_card"
 }
+
+type MembershipRights struct {
+	ID          int64  `gorm:"column:id" json:"id" form:"id"`
+	UserOrgId   int64  `gorm:"column:user_org_id" json:"user_org_id" form:"user_org_id"`
+	Rights      string `gorm:"column:rights" json:"rights" form:"rights"`
+	Status      int64  `gorm:"column:status" json:"status" form:"status"`
+	CreatedTime int64  `gorm:"column:created_time" json:"created_time" form:"created_time"`
+	UpdatedTime int64  `gorm:"column:updated_time" json:"updated_time" form:"updated_time"`
+}
+
+func (MembershipRights) TableName() string {
+	return "sgj_user_membership_rights"
+}

models/wechat_models.go

@@ -0,0 +1,74 @@
+package models
+
+type WechatComponents struct {
+	ID                    int64  `gorm:"column:id" json:"id" form:"id"`
+	ComponentAppid        string `gorm:"column:component_appid" json:"component_appid" form:"component_appid"`
+	ComponentAppsecret    string `gorm:"column:component_appsecret" json:"component_appsecret" form:"component_appsecret"`
+	ComponentVerifyTicket string `gorm:"column:component_verify_ticket" json:"component_verify_ticket" form:"component_verify_ticket"`
+	ComponentAccessToken  string `gorm:"column:component_access_token" json:"component_access_token" form:"component_access_token"`
+	PreAuthCode           string `gorm:"column:pre_auth_code" json:"pre_auth_code" form:"pre_auth_code"`
+	CreatedTime           int64  `gorm:"column:created_time" json:"created_time" form:"created_time"`
+	UpdatedTime           int64  `gorm:"column:updated_time" json:"updated_time" form:"updated_time"`
+	ComponentStatus       int64  `gorm:"column:component_status" json:"component_status" form:"component_status"`
+}
+
+func (WechatComponents) TableName() string {
+	return "sgj_patient_wechat_components"
+}
+
+type PatientAuthorizations struct {
+	ID                          int64  `gorm:"column:id" json:"id" form:"id"`
+	UserOrgId                   int64  `gorm:"column:user_org_id" json:"user_org_id" form:"user_org_id"`
+	AuthorizerAppid             string `gorm:"column:authorizer_appid" json:"authorizer_appid" form:"authorizer_appid"`
+	AuthorizerAccessToken       string `gorm:"column:authorizer_access_token" json:"authorizer_access_token" form:"authorizer_access_token"`
+	AuthorizerRefreshToken      string `gorm:"column:authorizer_refresh_token" json:"authorizer_refresh_token" form:"authorizer_refresh_token"`
+	AuthorizerJsapiTicket       string `gorm:"column:authorizer_jsapi_ticket" json:"authorizer_jsapi_ticket" form:"authorizer_jsapi_ticket"`
+	AuthorizerFuncscopeCategory string `gorm:"column:authorizer_funcscope_category" json:"authorizer_funcscope_category" form:"authorizer_funcscope_category"`
+	AuthorizerNickName          string `gorm:"column:authorizer_nick_name" json:"authorizer_nick_name" form:"authorizer_nick_name"`
+	AuthorizerHeadImg           string `gorm:"column:authorizer_head_img" json:"authorizer_head_img" form:"authorizer_head_img"`
+	AuthorizerServiceTypeInfo   int64  `gorm:"column:authorizer_service_type_info" json:"authorizer_service_type_info" form:"authorizer_service_type_info"`
+	AuthorizerVerifyTypeInfo    int64  `gorm:"column:authorizer_verify_type_info" json:"authorizer_verify_type_info" form:"authorizer_verify_type_info"`
+	AuthorizerUserName          string `gorm:"column:authorizer_user_name" json:"authorizer_user_name" form:"authorizer_user_name"`
+	AuthorizerPrincipalName     string `gorm:"column:authorizer_principal_name" json:"authorizer_principal_name" form:"authorizer_principal_name"`
+	AuthorizerBusinessInfo      string `gorm:"column:authorizer_business_info" json:"authorizer_business_info" form:"authorizer_business_info"`
+	AuthorizerQrcodeUrl         string `gorm:"column:authorizer_qrcode_url" json:"authorizer_qrcode_url" form:"authorizer_qrcode_url"`
+	CreatedTime                 int64  `gorm:"column:created_time" json:"created_time" form:"created_time"`
+	UpdatedTime                 int64  `gorm:"column:updated_time" json:"updated_time" form:"updated_time"`
+	AuthorizerStatus            int64  `gorm:"column:authorizer_status" json:"authorizer_status" form:"authorizer_status"`
+}
+
+func (PatientAuthorizations) TableName() string {
+	return "sgj_patient_authorizations"
+}
+
+type AuthorizationMessageManagements struct {
+	ID                 int64  `gorm:"column:id" json:"id" form:"id"`
+	UserOrgId          int64  `gorm:"column:user_org_id" json:"user_org_id" form:"user_org_id"`
+	MessageMsgEvent    string `gorm:"column:message_msg_event" json:"message_msg_event" form:"message_msg_event"`
+	MessageMsgType     string `gorm:"column:message_msg_type" json:"message_msg_type" form:"message_msg_type"`
+	MessageKeyType     int64  `gorm:"column:message_key_type" json:"message_key_type" form:"message_key_type"`
+	MessageRegularName string `gorm:"column:message_regular_name" json:"message_regular_name" form:"message_regular_name"`
+	MessageKeyName     string `gorm:"column:message_key_name" json:"message_key_name" form:"message_key_name"`
+	MessageContent     string `gorm:"column:message_content" json:"message_content" form:"message_content"`
+	CreatedTime        int64  `gorm:"column:created_time" json:"created_time" form:"created_time"`
+	UpdatedTime        int64  `gorm:"column:updated_time" json:"updated_time" form:"updated_time"`
+	MessageStatus      int64  `gorm:"column:message_status" json:"message_status" form:"message_status"`
+}
+
+func (AuthorizationMessageManagements) TableName() string {
+	return "sgj_patient_authorization_message_managements"
+}
+
+type AuthorizationButtons struct {
+	ID           int64  `gorm:"column:id" json:"id"`
+	UserOrgID    int64  `gorm:"column:user_org_id" json:"user_org_id"`
+	ButtonFileds string `gorm:"column:button_fileds" json:"button_fileds"`
+	CreatedTime  int64  `gorm:"column:created_time" json:"created_time"`
+	UpdatedTime  int64  `gorm:"column:updated_time" json:"updated_time"`
+	ButtonStatus int64  `gorm:"column:button_status" json:"button_status"`
+	SendStatus   int64  `gorm:"column:send_status" json:"send_status"`
+}
+
+func (AuthorizationButtons) TableName() string {
+	return "sgj_patient_authorization_buttons"
+}

routers/router.go

@@ -7,6 +7,7 @@ import (
 	"SCRM/controllers/login"
 	"SCRM/controllers/marketing_tool"
 	"SCRM/controllers/members"
+	"SCRM/controllers/mpwechat"
 	"SCRM/controllers/role"
 
 	"github.com/astaxie/beego"
@@ -29,4 +30,5 @@ func init() {
 	members.RegisterRouters()
 	marketing_tool.RegisterRouters()
 	article.RegisterRouters()
+	mpwechat.RegisterRouters()
 }

service/marketing_tool_service/activity_service.go

@@ -4,6 +4,8 @@ import (
 	"SCRM/models"
 	"SCRM/service"
 	"time"
+
+	"github.com/jinzhu/gorm"
 )
 
 func GetValidActivities(orgID int64, appID int64, keyWord string, page int, count int) ([]*models.Activity, int64, error) {
@@ -88,3 +90,77 @@ func GetDidEndedActivities(orgID int64, appID int64, keyWord string, page int, c
 		return nil, 0, err
 	}
 }
+
+func GetActivityWithID(orgID int64, activityID int64) (*models.Activity, error) {
+	var activity models.Activity
+	err := service.PatientReadDB().Model(&models.Activity{}).Where("user_org_id = ? and id = ?", orgID, activityID).First(&activity).Error
+	if err != nil {
+		if err == gorm.ErrRecordNotFound {
+			return nil, nil
+		} else {
+			return nil, err
+		}
+	}
+	return &activity, nil
+}
+
+func GetActivityParagraphByActivityID(activityID int64) (*models.ActivityParagraph, error) {
+	var paragraph models.ActivityParagraph
+	err :=
+		service.PatientReadDB().Model(&models.ActivityParagraph{}).
+			Where("activity_id = ? and status = 1", activityID).
+			First(&paragraph).
+			Error
+	if err != nil {
+		if err == gorm.ErrRecordNotFound {
+			return nil, nil
+		} else {
+			return nil, err
+		}
+	}
+	return &paragraph, nil
+}
+
+func GetActivityWxShareByActivityID(activityID int64) (*models.ActivityWxShare, error) {
+	var model models.ActivityWxShare
+	err :=
+		service.PatientReadDB().Model(&models.ActivityWxShare{}).
+			Where("activity_id = ?", activityID).
+			First(&model).
+			Error
+	if err != nil {
+		if err == gorm.ErrRecordNotFound {
+			return nil, nil
+		} else {
+			return nil, err
+		}
+	}
+	return &model, nil
+}
+
+func SaveActivityAndParagraph(activity *models.Activity, paragraph *models.ActivityParagraph) error {
+	tx := service.PatientWriteDB().Begin()
+	saveActivityErr := tx.Save(activity).Error
+	if saveActivityErr != nil {
+		tx.Rollback()
+		return saveActivityErr
+	}
+	if paragraph != nil {
+		if paragraph.Id == 0 {
+			paragraph.ActivityId = activity.Id
+		}
+
+		saveParagraphErr := tx.Save(paragraph).Error
+		if saveParagraphErr != nil {
+			tx.Rollback()
+			return saveParagraphErr
+		}
+	}
+
+	tx.Commit()
+	return nil
+}
+
+func SaveActivityWxShare(model *models.ActivityWxShare) error {
+	return service.PatientWriteDB().Save(model).Error
+}

service/member_service/cards_service.go

@@ -122,3 +122,20 @@ func DeleteMemberShipCards(orgID int64, ids []int64) (err error) {
 	}
 	return
 }
+
+func GetMembershipRights(orgID int64) (*models.MembershipRights, error) {
+	var right models.MembershipRights
+	err := service.UserReadDB().Model(&models.MembershipRights{}).Where("user_org_id=?", orgID).First(&right).Error
+	if err == gorm.ErrRecordNotFound {
+		return nil, nil
+	}
+	if err != nil {
+		return nil, err
+	}
+	return &right, nil
+}
+
+func SaveMembershipRight(right *models.MembershipRights) (err error) {
+	err = service.UserWriteDB().Save(right).Error
+	return
+}

service/member_service/member_service.go

@@ -134,3 +134,15 @@ func DeleteMembers(orgID int64, ids []int64) (err error) {
 	}
 	return
 }
+
+func FindCustomerInfoByOpenid(orgID int64, openid string) (*models.UserCustomer, error) {
+	var cusotmer models.UserCustomer
+	err := service.UserReadDB().Where("user_org_id = ? and wechat_openid =? and status=1", orgID, openid).First(&cusotmer).Error
+	if err == gorm.ErrRecordNotFound {
+		return nil, nil
+	}
+	if err != nil {
+		return nil, err
+	}
+	return &cusotmer, nil
+}

service/org_service/org_fans_service.go

@@ -0,0 +1,14 @@
+package org_service
+
+import (
+	"SCRM/models"
+	"SCRM/service"
+	"time"
+)
+
+func SetFansUnsubscribe(orgID int64, openid string) (err error) {
+
+	err = service.UserWriteDB().Model(&models.OrgFans{}).Where("user_org_id=? and openid=?", orgID, openid).Update(map[string]interface{}{"UpdatedTime": time.Now().Unix(), "Status": 2}).Error
+	return
+
+}

service/wechat_service/authorization_service.go

@@ -0,0 +1,75 @@
+package wechat_service
+
+import (
+	"SCRM/models"
+	"SCRM/service"
+
+	"github.com/jinzhu/gorm"
+)
+
+//GetAuthorizationByOnlyAppID 通过appid取信息
+func GetAuthorizationByOnlyAppID(appid string) (*models.PatientAuthorizations, error) {
+	var authorizationinfo models.PatientAuthorizations
+	var err error
+	err = service.PatientReadDB().Model(&models.PatientAuthorizations{}).Where("authorizer_appid=? and authorizer_status=1", appid).First(&authorizationinfo).Error
+	if err == gorm.ErrRecordNotFound {
+		return nil, nil
+	}
+	if err != nil {
+		return nil, err
+	}
+	return &authorizationinfo, nil
+}
+
+//GetAuthorizationByAppID 通过appid取信息
+func GetAuthorizationByAppID(orgID int64, appid string) (*models.PatientAuthorizations, error) {
+	var authorizationinfo models.PatientAuthorizations
+	var err error
+	err = service.PatientReadDB().Model(&models.PatientAuthorizations{}).Where(" user_org_id=? and authorizer_appid=? and authorizer_status=1", orgID, appid).First(&authorizationinfo).Error
+	if err == gorm.ErrRecordNotFound {
+		return nil, nil
+	}
+	if err != nil {
+		return nil, err
+	}
+	return &authorizationinfo, nil
+}
+
+//GetAuthorizationByOrgID 通过orgid取信息
+func GetAuthorizationByOrgID(orgID int64) (*models.PatientAuthorizations, error) {
+	var authorizationinfo models.PatientAuthorizations
+	var err error
+	err = service.PatientReadDB().Model(&models.PatientAuthorizations{}).Where("user_org_id=?", orgID).First(&authorizationinfo).Error
+	if err == gorm.ErrRecordNotFound {
+		return nil, nil
+	}
+	if err != nil {
+		return nil, err
+	}
+	return &authorizationinfo, nil
+}
+
+func SaveWechatComponentVerifyTicket(id int64, componentVerifyTicket string) (err error) {
+	err = service.PatientWriteDB().Model(&models.WechatComponents{}).Where("id=?", id).Update(map[string]interface{}{"ComponentVerifyTicket": componentVerifyTicket}).Error
+	return
+}
+
+func SaveWechatComponentInfoByMap(id int64, info map[string]interface{}) (err error) {
+	err = service.PatientWriteDB().Model(&models.WechatComponents{}).Where("id=?", id).Update(info).Error
+	return
+}
+
+func SaveAuthorizerStatusByAppID(appID string, status int64) (err error) {
+	err = service.PatientWriteDB().Model(&models.PatientAuthorizations{}).Where("authorizer_appid=?", appID).Update(map[string]interface{}{"AuthorizerStatus": status}).Error
+	return
+}
+
+func SaveAuthorizationInfo(authorization *models.PatientAuthorizations) (err error) {
+	err = service.PatientWriteDB().Model(&models.PatientAuthorizations{}).Save(&authorization).Error
+	return
+}
+
+func GetAuthorizations() (mps []*models.PatientAuthorizations, err error) {
+	err = service.PatientReadDB().Where("authorizer_status = 1").Find(&mps).Error
+	return
+}

service/wechat_service/menu_service.go

@@ -0,0 +1,63 @@
+package wechat_service
+
+import (
+	"SCRM/models"
+	"SCRM/service"
+	"time"
+
+	"github.com/jinzhu/gorm"
+)
+
+//GetMenusByOrgID 通过user_org_id（机构ID）取信息
+func GetMenusByOrgID(orgID int64) (*models.AuthorizationButtons, error) {
+	var button models.AuthorizationButtons
+	err := service.PatientReadDB().Where("user_org_id=?", orgID).Order("id desc").First(&button).Error
+	if err == gorm.ErrRecordNotFound {
+		return nil, nil
+	}
+	if err != nil {
+		return nil, err
+	}
+	return &button, nil
+}
+
+func GetOrgMenusWithMsgs(orgID int64) (*Buttons, error) {
+	var button Buttons
+	err := service.PatientReadDB().Where("user_org_id=?", orgID).Order("id desc").Preload("Messages", "user_org_id=? AND message_msg_type='event' AND message_msg_event='click' AND message_status=1", orgID).First(&button).Error
+	if err == gorm.ErrRecordNotFound {
+		return nil, nil
+	}
+	if err != nil {
+		return nil, err
+	}
+	return &button, nil
+}
+
+type Buttons struct {
+	ID           int64  `gorm:"column:id" json:"id"`
+	UserOrgID    int64  `gorm:"column:user_org_id" json:"user_org_id"`
+	ButtonFileds string `gorm:"column:button_fileds" json:"button_fileds"`
+	CreatedTime  int64  `gorm:"column:created_time" json:"created_time"`
+	UpdatedTime  int64  `gorm:"column:updated_time" json:"updated_time"`
+	ButtonStatus int64  `gorm:"column:button_status" json:"button_status"`
+	SendStatus   int64  `gorm:"column:send_status" json:"send_status"`
+
+	Messages []*models.AuthorizationMessageManagements `gorm:"ForeignKey:user_org_id;association_foreignkey:user_org_id" json:"messages"`
+}
+
+func (Buttons) TableName() string {
+	return "sgj_patient_authorization_buttons"
+}
+
+func SaveButtons(menu *Buttons) (err error) {
+	tx := service.PatientWriteDB().Begin()
+
+	err = tx.Model(&models.AuthorizationMessageManagements{}).Where("user_org_id=? AND message_msg_type='event' AND message_msg_event='click'", menu.UserOrgID).Update(map[string]interface{}{"MessageStatus": 2, "UpdatedTime": time.Now().Unix()}).Error
+	if err != nil {
+		tx.Rollback()
+		return
+	}
+	err = tx.Save(menu).Error
+	tx.Commit()
+	return
+}

service/wechat_service/messages_service.go

@@ -0,0 +1,53 @@
+package wechat_service
+
+import (
+	"SCRM/models"
+	"SCRM/service"
+
+	"github.com/jinzhu/gorm"
+)
+
+//GetTextReplyMessagesByKey 通过关键词搜索 user_org_id（机构ID）取信息
+func GetTextReplyMessagesByKey(userOrgID int64, keywrods string) (messages []*models.AuthorizationMessageManagements, err error) {
+	if len(keywrods) == 0 {
+		return
+	}
+
+	likekey := "%" + keywrods + "%"
+	err = service.PatientReadDB().Where("user_org_id=? AND message_msg_type='text' AND message_status=1 AND ((message_key_name LIKE ? AND message_key_type=1) OR (message_key_name = ? AND message_key_type=2))", userOrgID, likekey, keywrods).Order("id desc").Find(&messages).Error
+	return
+}
+
+//GetSubscribeReplyMessagesByOrgID 通过user_org_id（机构ID）取信息
+func GetSubscribeReplyMessagesByOrgID(orgID int64) (*models.AuthorizationMessageManagements, error) {
+
+	var message models.AuthorizationMessageManagements
+
+	err := service.PatientReadDB().Where("user_org_id=? AND message_msg_type='event' AND message_msg_event='subscribe' AND message_status=1", orgID).First(&message).Error
+	if err == gorm.ErrRecordNotFound {
+		return nil, nil
+	}
+	if err != nil {
+		return nil, err
+	}
+	return &message, nil
+
+}
+
+//GetClickButtonReplyMessagesByOrgID 通过user_org_id（机构ID）取信息
+func GetClickButtonReplyMessagesByOrgID(orgID int64, key string) (*models.AuthorizationMessageManagements, error) {
+	var message models.AuthorizationMessageManagements
+	err := service.PatientReadDB().Where("user_org_id=? AND message_msg_type='event' AND message_msg_event='click' AND message_key_name=? AND message_status=1", orgID, key).First(&message).Error
+	if err == gorm.ErrRecordNotFound {
+		return nil, nil
+	}
+	if err != nil {
+		return nil, err
+	}
+	return &message, nil
+}
+
+func GetOrgAllClickMessages(orgID int64) (messages []*models.AuthorizationMessageManagements, err error) {
+	err = service.PatientReadDB().Where("user_org_id=? AND message_msg_type='event' AND message_msg_event='click'", orgID).Find(&messages).Error
+	return
+}

service/wechat_service/open_wechat_model.go

@@ -0,0 +1,169 @@
+package wechat_service
+
+import (
+	"encoding/xml"
+	"time"
+
+	"github.com/silenceper/wechat/menu"
+)
+
+//MsgEncrypt 微信平台向第三方平台授权事件接收URL推送的xml数据结构
+type MsgEncrypt struct {
+	AppID   string `xml:"AppId"`
+	Encrypt string `xml:"Encrypt"`
+}
+
+//ComponentRequestBody 第三方平台授权事件接收URL接收数据后解密后的基本结构，
+//有各种不同的结构：Ticket，AuthorizedStruct，UnauthorizedStruct，UpdateauthorizedStruct，由InfoType.InfoType判断
+type ComponentRequestBody struct {
+	AppID      string `xml:"AppId"`
+	CreateTime string `xml:"CreateTime"`
+	InfoType   string `xml:"InfoType"`
+
+	// 接收微信平台向第三方平台授权事件接收URL推送，InfoType为component_verify_ticket时，返回
+	ComponentVerifyTicket string `xml:"ComponentVerifyTicket,omitempty"`
+
+	// 微信平台向第三方平台授权事件接收URL推送的数据，InfoType为authorized，unauthorized，updateauthorized时间有返回
+	AuthorizerAppid string `xml:"AuthorizerAppid,omitempty"`
+
+	// 微信平台向第三方平台授权事件接收URL推送的数据，InfoType为authorized，updateauthorized时间有返回
+	AuthorizationCode            string `xml:"AuthorizationCode,omitempty"`
+	AuthorizationCodeExpiredTime string `xml:"AuthorizationCodeExpiredTime,omitempty"`
+	PreAuthCode                  string `xml:"PreAuthCode,omitempty"`
+}
+
+type EncryptRequestBody struct {
+	XMLName    xml.Name `xml:"xml"`
+	ToUserName string
+	Encrypt    string
+}
+
+type TextRequestBody struct {
+	XMLName      xml.Name `xml:"xml"`
+	ToUserName   string
+	FromUserName string
+	CreateTime   time.Duration
+	MsgType      string
+	Event        string
+	EventKey     string
+	Url          string
+	PicUrl       string
+	MediaId      string
+	ThumbMediaId string
+	Content      string
+	MsgId        int
+	Location_X   string
+	Location_Y   string
+	Label        string
+}
+type CDATAText struct {
+	Text string `xml:",innerxml"`
+}
+
+type EncryptResponseBody struct {
+	XMLName      xml.Name `xml:"xml"`
+	Encrypt      CDATAText
+	MsgSignature CDATAText
+	TimeStamp    string
+	Nonce        CDATAText
+}
+
+type TextResponseBody struct {
+	XMLName      xml.Name `xml:"xml"`
+	ToUserName   CDATAText
+	FromUserName CDATAText
+	CreateTime   string
+	MsgType      CDATAText
+	Content      CDATAText
+}
+
+type MPResult struct {
+	ErrCode int64  `json:"errcode"`
+	ErrMsg  string `json:"errmsg"`
+}
+
+//ComponentAccessToken 第三方平台主动向微信服务器请求第三方平台自己的component_access_token返回的数据结构
+type ComponentAccessToken struct {
+	ComponentAccessToken string `json:"component_access_token"`
+	ExpiresIn            int    `json:"expires_in"`
+}
+
+//PreAuthCode 第三方平台主动向微信服务器请求第三方平台预授权码pre_auth_code返回的数据结构
+type PreAuthCode struct {
+	PreAuthCode string `json:"pre_auth_code"`
+	ExpiresIn   int    `json:"expires_in"`
+}
+
+//AuthorizationInfo 公众号向第三方平台授权成功后，在redirect_uri利用auth_code（公众号确定授权后，微信拼接在redirect_uri上，用来交换AuthorizationInfo）主动请求授权信息
+type AuthorizationInfo struct {
+	AuthorizationInfo struct {
+		AuthorizerAppid        string          `json:"authorizer_appid"`
+		AuthorizerAccessToken  string          `json:"authorizer_access_token"`
+		ExpiresIn              int64           `json:"expires_in"`
+		AuthorizerRefreshToken string          `json:"authorizer_refresh_token"`
+		FuncInfo               []FuncInfoItems `json:"func_info"`
+	} `json:"authorization_info"`
+}
+
+type FuncInfoItems struct {
+	FuncscopeCategory struct {
+		ID int64 `json:"id"`
+	} `json:"funcscope_category"`
+}
+
+//AuthorizerInfo 第三方平利用authorizer_appid（公众号的appid，授权确定后获得，AuthorizationInfo.authorizer_appid）和component_appid(第三方平台appid，在微信开发平台新建一个第三方应用时生成)
+type AuthorizerInfo struct {
+	AuthorizerInfo struct {
+		NickName        string                 `json:"nick_name"`
+		HeadImg         string                 `json:"head_img"`
+		ServiceTypeInfo AuthorizerInfoTypeInfo `json:"service_type_info"`
+		VerifyTypeInfo  AuthorizerInfoTypeInfo `json:"verify_type_info"`
+		UserName        string                 `json:"user_name"`
+		QrcodeURL       string                 `json:"qrcode_url"`
+		PrincipalName   string                 `json:"principal_name"`
+		BusinessInfo    BusinessInfo           `json:"business_info"`
+		FuncInfo        []FuncInfoItems        `json:"func_info"`
+	} `json:"authorizer_info"`
+}
+
+type AuthorizerInfoTypeInfo struct {
+	ID int64 `json:"id"`
+}
+
+type BusinessInfo struct {
+	OpenPay   int64 `json:"open_pay"`
+	OpenShake int64 `json:"open_shake"`
+	OpenScan  int64 `json:"open_scan"`
+	OpenCard  int64 `json:"open_card"`
+	OpenStore int64 `json:"open_store"`
+}
+
+//微信菜单形式
+type SelfMenuInfo struct {
+	Button []SelfMenuButton `json:"button"`
+}
+
+//reqMenu 设置菜单请求数据
+type RRreqMenu struct {
+	Button    []*menu.Button  `json:"button,omitempty"`
+	MatchRule *menu.MatchRule `json:"matchrule,omitempty"`
+}
+
+//SelfMenuButton 自定义菜单配置详情
+type SelfMenuButton struct {
+	Name      string           `json:"name"`
+	Type      string           `json:"type,omitempty"`
+	Key       string           `json:"key,omitempty"`
+	AppID     string           `json:"appid,omitempty"`
+	PagePath  string           `json:"pagepath,omitempty"`
+	Message   string           `json:"message,omitempty"`
+	URL       string           `json:"url,omitempty"`
+	MediaId   string           `json:"media_id,omitempty"`
+	SubButton []SelfMenuButton `json:"sub_button,omitempty"`
+}
+
+type RefreshToken struct {
+	AuthorizerAccessToken  string `json:"authorizer_access_token"`
+	ExpiresIn              int64  `json:"expires_in"`
+	AuthorizerRefreshToken string `json:"authorizer_refresh_token"`
+}

service/wechat_service/open_wechat_service.go

@@ -0,0 +1,495 @@
+package wechat_service
+
+import (
+	"bytes"
+	"crypto/aes"
+	"crypto/cipher"
+	"crypto/rand"
+	"crypto/sha1"
+	"encoding/base64"
+	"encoding/binary"
+	"encoding/json"
+	"encoding/xml"
+	"errors"
+	"fmt"
+	"io"
+	"io/ioutil"
+	math_rand "math/rand"
+	"net/http"
+	"sort"
+	"strings"
+	"time"
+
+	"SCRM/service"
+	"SCRM/utils"
+
+	"github.com/astaxie/beego"
+	"github.com/astaxie/beego/context"
+	"github.com/astaxie/beego/httplib"
+	"github.com/silenceper/wechat/util"
+)
+
+func init() {
+	AesKey = EncodingAESKey2AESKey(encodingAESKey)
+}
+
+var (
+	//以下均为公众号管理后台设置项
+	token          = beego.AppConfig.String("openwechattoken")
+	appID          = beego.AppConfig.String("openwechatappid")
+	encodingAESKey = beego.AppConfig.String("openwechatencodingaeskey")
+)
+
+func MakeMsgSignature(timestamp, nonce, msg_encrypt string) string {
+	sl := []string{token, timestamp, nonce, msg_encrypt}
+	sort.Strings(sl)
+	s := sha1.New()
+	io.WriteString(s, strings.Join(sl, ""))
+	return fmt.Sprintf("%x", s.Sum(nil))
+}
+
+func ValidateMsg(timestamp, nonce, msgEncrypt, msgSignatureIn string) bool {
+	msgSignatureGen := MakeMsgSignature(timestamp, nonce, msgEncrypt)
+	if msgSignatureGen != msgSignatureIn {
+		return false
+	}
+	return true
+}
+
+func AesDecrypt(cipherData []byte, aesKey []byte) ([]byte, error) {
+	k := len(aesKey) //PKCS#7
+	if len(cipherData)%k != 0 {
+		return nil, errors.New("crypto/cipher: ciphertext size is not multiple of aes key length")
+	}
+
+	block, err := aes.NewCipher(aesKey)
+	if err != nil {
+		return nil, err
+	}
+
+	iv := make([]byte, aes.BlockSize)
+	if _, err := io.ReadFull(rand.Reader, iv); err != nil {
+		return nil, err
+	}
+	blockMode := cipher.NewCBCDecrypter(block, iv)
+	plainData := make([]byte, len(cipherData))
+	blockMode.CryptBlocks(plainData, cipherData)
+	return plainData, nil
+}
+
+var AesKey []byte
+
+func EncodingAESKey2AESKey(encodingKey string) []byte {
+	data, _ := base64.StdEncoding.DecodeString(encodingKey + "=")
+	return data
+}
+func ValidateAppId(id []byte) bool {
+	if string(id) == appID {
+		return true
+	}
+	return false
+}
+
+func ParseEncryptTextRequestBody(plainText []byte) (*TextRequestBody, error) {
+
+	// Read length
+	buf := bytes.NewBuffer(plainText[16:20])
+	var length int32
+	binary.Read(buf, binary.BigEndian, &length)
+
+	// appID validation
+	appIDstart := 20 + length
+	id := plainText[appIDstart : int(appIDstart)+len(appID)]
+	if !ValidateAppId(id) {
+		return nil, errors.New("Appid is invalid")
+	}
+
+	textRequestBody := &TextRequestBody{}
+	xml.Unmarshal(plainText[20:20+length], textRequestBody)
+	return textRequestBody, nil
+}
+
+func Value2CDATA(v string) CDATAText {
+	//return CDATAText{[]byte("<![CDATA[" + v + "]]>")}
+	return CDATAText{"<![CDATA[" + v + "]]>"}
+}
+func MakeEncryptXmlData(fromUserName, toUserName, timestamp, content string) (string, error) {
+	textResponseBody := &TextResponseBody{}
+	textResponseBody.FromUserName = Value2CDATA(fromUserName)
+	textResponseBody.ToUserName = Value2CDATA(toUserName)
+	textResponseBody.MsgType = Value2CDATA("text")
+	textResponseBody.Content = Value2CDATA(content)
+	textResponseBody.CreateTime = timestamp
+	body, err := xml.MarshalIndent(textResponseBody, " ", "  ")
+	if err != nil {
+		return "", errors.New("xml marshal error")
+	}
+
+	buf := new(bytes.Buffer)
+	err = binary.Write(buf, binary.BigEndian, int32(len(body)))
+	if err != nil {
+		return "", errors.New("Binary write err:" + err.Error())
+	}
+	bodyLength := buf.Bytes()
+
+	randomBytes := []byte("abcdefghijklmnop")
+
+	plainData := bytes.Join([][]byte{randomBytes, bodyLength, body, []byte(appID)}, nil)
+	cipherData, err := AesEncrypt(plainData, AesKey)
+	if err != nil {
+		return "", errors.New("AesEncrypt error")
+	}
+	return base64.StdEncoding.EncodeToString(cipherData), nil
+}
+
+// PadLength calculates padding length, from github.com/vgorin/cryptogo
+func PadLength(slice_length, blocksize int) (padlen int) {
+	padlen = blocksize - slice_length%blocksize
+	if padlen == 0 {
+		padlen = blocksize
+	}
+	return padlen
+}
+
+//from github.com/vgorin/cryptogo
+func PKCS7Pad(message []byte, blocksize int) (padded []byte) {
+	// block size must be bigger or equal 2
+	if blocksize < 1<<1 {
+		panic("block size is too small (minimum is 2 bytes)")
+	}
+	// block size up to 255 requires 1 byte padding
+	if blocksize < 1<<8 {
+		// calculate padding length
+		padlen := PadLength(len(message), blocksize)
+
+		// define PKCS7 padding block
+		padding := bytes.Repeat([]byte{byte(padlen)}, padlen)
+
+		// apply padding
+		padded = append(message, padding...)
+		return padded
+	}
+	// block size bigger or equal 256 is not currently supported
+	panic("unsupported block size")
+}
+func AesEncrypt(plainData []byte, aesKey []byte) ([]byte, error) {
+	k := len(aesKey)
+	if len(plainData)%k != 0 {
+		plainData = PKCS7Pad(plainData, k)
+	}
+
+	block, err := aes.NewCipher(aesKey)
+	if err != nil {
+		return nil, err
+	}
+
+	iv := make([]byte, aes.BlockSize)
+	if _, err := io.ReadFull(rand.Reader, iv); err != nil {
+		return nil, err
+	}
+
+	cipherData := make([]byte, len(plainData))
+	blockMode := cipher.NewCBCEncrypter(block, iv)
+	blockMode.CryptBlocks(cipherData, plainData)
+
+	return cipherData, nil
+}
+func MakeEncryptResponseBody(fromUserName, toUserName, content, nonce, timestamp string) ([]byte, error) {
+	encryptBody := &EncryptResponseBody{}
+
+	encryptXmlData, _ := MakeEncryptXmlData(fromUserName, toUserName, timestamp, content)
+	encryptBody.Encrypt = Value2CDATA(encryptXmlData)
+	encryptBody.MsgSignature = Value2CDATA(MakeMsgSignature(timestamp, nonce, encryptXmlData))
+	encryptBody.TimeStamp = timestamp
+	encryptBody.Nonce = Value2CDATA(nonce)
+
+	return xml.MarshalIndent(encryptBody, " ", "  ")
+}
+
+func SendMsgTypeTextMessage(appid string, ToUserName string, FromUserName string, text string, nonce string, timestamp string, Ctx *context.Context, orgID int64) {
+
+	arthorizer, err := GetAuthorizationByAppID(orgID, appid)
+	if err != nil {
+		utils.ErrorLog("SendMsgTypeTextMessage error:%s", err)
+		Ctx.WriteString("success")
+		return
+	}
+
+	messages, err := GetTextReplyMessagesByKey(arthorizer.UserOrgId, text)
+	if err != nil {
+		utils.ErrorLog("SendMsgTypeTextMessage error:%s", err)
+		Ctx.WriteString("success")
+		return
+	}
+	if len(messages) == 0 {
+		utils.ErrorLog("SendMsgTypeTextMessage error: messages is nil")
+		Ctx.WriteString("success")
+		return
+	}
+
+	r := math_rand.New(math_rand.NewSource(time.Now().UnixNano()))
+	n := r.Intn(len(messages))
+
+	for key, item := range messages {
+		if key == n {
+			//安全模式下向用户回复消息也需要加密
+			respBody, e := MakeEncryptResponseBody(FromUserName, ToUserName, item.MessageContent, nonce, timestamp)
+			if e != nil {
+				Ctx.WriteString("success")
+				return
+			}
+
+			Ctx.WriteString(string(respBody))
+			fmt.Println(string(respBody))
+			return
+		}
+
+	}
+
+	Ctx.WriteString("success")
+	return
+
+}
+
+//SendSubscribeTextMessage  当用户关注微信公众号，回复ta
+func SendSubscribeTextMessage(appid string, ToUserName string, FromUserName string, nonce string, timestamp string, Ctx *context.Context, orgID int64) {
+	arthorizer, err := GetAuthorizationByAppID(orgID, appid)
+	if err != nil {
+		utils.ErrorLog("SendSubscribeTextMessage error:%s", err)
+		Ctx.WriteString("success")
+		return
+	}
+
+	message, err := GetSubscribeReplyMessagesByOrgID(arthorizer.UserOrgId)
+	if err != nil {
+		utils.ErrorLog("SendSubscribeTextMessage error:%s", err)
+		Ctx.WriteString("success")
+		return
+	}
+	if message == nil {
+		utils.ErrorLog("SendSubscribeTextMessage error: message is nil")
+		Ctx.WriteString("success")
+		return
+	}
+
+	respBody, e := MakeEncryptResponseBody(FromUserName, ToUserName, message.MessageContent, nonce, timestamp)
+	if e != nil {
+		Ctx.WriteString("success")
+		return
+	}
+
+	Ctx.WriteString(string(respBody))
+	return
+
+}
+
+func SendClickButtonMessage(appid string, ToUserName string, FromUserName string, keyName string, nonce string, timestamp string, Ctx *context.Context, orgID int64) {
+	arthorizer, err := GetAuthorizationByAppID(orgID, appid)
+	if err != nil {
+		utils.ErrorLog("SendClickButtonMessage error:%s", err)
+		Ctx.WriteString("success")
+		return
+	}
+	message, err := GetClickButtonReplyMessagesByOrgID(arthorizer.UserOrgId, keyName)
+	if err != nil {
+		utils.ErrorLog("SendClickButtonMessage error:%s", err)
+		Ctx.WriteString("success")
+		return
+	}
+	if message == nil {
+		utils.ErrorLog("SendClickButtonMessage error: message is nil")
+		Ctx.WriteString("success")
+		return
+	}
+
+	respBody, e := MakeEncryptResponseBody(FromUserName, ToUserName, message.MessageContent, nonce, timestamp)
+	if e != nil {
+		Ctx.WriteString("success")
+		return
+	}
+
+	Ctx.WriteString(string(respBody))
+	return
+}
+
+func GetReqPreAuthCode() (code string, err error) {
+	redisClient := service.RedisClient()
+	defer redisClient.Close()
+
+	componentAccessToken, err := redisClient.Get("sgj_patient:component_access_token").Result()
+	if err != nil {
+		utils.ErrorLog("component_access_token不存在")
+		return
+	}
+
+	appID := beego.AppConfig.String("openwechatappid")
+
+	type reqPreAuthCodeStruct struct {
+		ComponentAppid string `json:"component_appid"`
+	}
+
+	// 通过 ComponentAccessToken 取 pre_auth_code
+	// 3、获取预授权码pre_auth_code
+	var ReqPreAuthCode reqPreAuthCodeStruct
+	ReqPreAuthCode.ComponentAppid = appID
+	//创建请求
+
+	uri := fmt.Sprintf("%s?component_access_token=%s", "https://api.weixin.qq.com/cgi-bin/component/api_create_preauthcode", componentAccessToken)
+	var responseBytes []byte
+	responseBytes, err = util.PostJSON(uri, ReqPreAuthCode)
+	if err != nil {
+		utils.ErrorLog("%s", err)
+		return
+	}
+
+	var res MPResult
+	err = json.Unmarshal(responseBytes, &res)
+	if err != nil {
+		utils.ErrorLog("%s", err)
+		return
+	}
+
+	if res.ErrCode > 0 {
+		utils.ErrorLog("%s", res.ErrMsg)
+		return
+	}
+
+	var pre_auth_code_struct PreAuthCode
+	err = json.Unmarshal(responseBytes, &pre_auth_code_struct)
+	if err != nil {
+		utils.ErrorLog("pre_auth_code_struct Unmarshal json error:%s", err)
+		return
+	}
+	code = pre_auth_code_struct.PreAuthCode
+	return
+}
+
+//ComponentAPIQueryAuth 使用授权码换取公众号的接口调用凭据和授权信息
+func ComponentAPIQueryAuth(AuthorizationCode string, ComponentAccessToken string) ([]byte, error) {
+
+	//post的body内容,当前为json格式
+	reqbody := "{\"component_appid\":\"" + beego.AppConfig.String("openwechatappid") + "\",\"authorization_code\": \"" + AuthorizationCode + "\"}"
+	//创建请求
+	postReq, err := http.NewRequest("POST",
+		"https://api.weixin.qq.com/cgi-bin/component/api_query_auth?component_access_token="+ComponentAccessToken,
+		strings.NewReader(reqbody)) //post内容
+
+	if err != nil {
+		utils.ErrorLog("POST请求:omponent/api_query_auth请求创建失败:%s", err)
+		return nil, err
+	}
+
+	//增加header
+	postReq.Header.Set("Content-Type", "application/json; encoding=utf-8")
+
+	//执行请求
+	client := &http.Client{}
+	resp, err := client.Do(postReq)
+	if err != nil {
+		utils.ErrorLog("POST请求:创建请求失败:%s", err)
+		return nil, err
+	}
+	//读取响应
+	body, err := ioutil.ReadAll(resp.Body) //此处可增加输入过滤
+	if err != nil {
+		utils.ErrorLog("POST请求:读取body失败:%s", err)
+		return nil, err
+	}
+
+	resp.Body.Close()
+	return body, nil
+
+}
+
+//ComponentAPIGetAuthorizerInfo 利用AuthorizerAppid（公众号授权后，获取的appid）拉取公众号信息
+func ComponentAPIGetAuthorizerInfo(AuthorizerAppid string, ComponentAccessToken string) ([]byte, error) {
+	//post的body内容,当前为json格式
+	reqbody := "{\"component_appid\":\"" + beego.AppConfig.String("openwechatappid") + "\",\"authorizer_appid\": \"" + AuthorizerAppid + "\"}"
+	//创建请求
+	postReq, err := http.NewRequest("POST",
+		"https://api.weixin.qq.com/cgi-bin/component/api_get_authorizer_info?component_access_token="+ComponentAccessToken, //post链接
+		strings.NewReader(reqbody)) //post内容
+
+	if err != nil {
+		fmt.Println("POST请求:omponent/api_get_authorizer_info请求创建失败")
+		return nil, err
+	}
+
+	//增加header
+	postReq.Header.Set("Content-Type", "application/json; encoding=utf-8")
+
+	//执行请求
+	client := &http.Client{}
+	resp, err := client.Do(postReq)
+	if err != nil {
+		fmt.Println("POST请求:创建请求失败")
+		return nil, err
+	}
+	//读取响应
+	body, err := ioutil.ReadAll(resp.Body) //此处可增加输入过滤
+	if err != nil {
+		fmt.Println("POST请求:读取body失败")
+		return nil, err
+	}
+
+	resp.Body.Close()
+	return body, nil
+}
+
+func PostJSON(uri string, jsonData []byte) ([]byte, error) {
+	// jsonData, err := json.Marshal(obj)
+	// if err != nil {
+	// 	return nil, err
+	// }
+
+	jsonData = bytes.Replace(jsonData, []byte("\\u003c"), []byte("<"), -1)
+	jsonData = bytes.Replace(jsonData, []byte("\\u003e"), []byte(">"), -1)
+	jsonData = bytes.Replace(jsonData, []byte("\\u0026"), []byte("&"), -1)
+
+	body := bytes.NewBuffer(jsonData)
+	response, err := http.Post(uri, "application/json;charset=utf-8", body)
+	if err != nil {
+		return nil, err
+	}
+	defer response.Body.Close()
+
+	if response.StatusCode != http.StatusOK {
+		return nil, fmt.Errorf("http get error : uri=%v , statusCode=%v", uri, response.StatusCode)
+	}
+	return ioutil.ReadAll(response.Body)
+}
+
+func SendMpWechatMenus(AuthorizerAccessToken string, jsonData []byte) (err error) {
+	//读取响应
+	body, err := PostJSON("https://api.weixin.qq.com/cgi-bin/menu/create?access_token="+AuthorizerAccessToken, jsonData)
+	if err != nil {
+		return
+	}
+	var result MPResult
+	err = json.Unmarshal([]byte(body), &result)
+	if err != nil {
+		return
+	}
+	if result.ErrCode > 0 {
+		utils.ErrorLog("MPResult ERROR:%v", result)
+		err = errors.New(result.ErrMsg)
+		return
+	}
+	return
+
+}
+
+func DeleteMpWechatMenus(AuthorizerAccessToken string) (bool, error) {
+	uri := fmt.Sprintf("https://api.weixin.qq.com/cgi-bin/menu/delete?access_token=%s", AuthorizerAccessToken)
+
+	b := httplib.Get(uri)
+	var result MPResult
+	err := b.ToJSON(&result)
+	if err != nil {
+		return false, err
+	}
+	if result.ErrCode > 0 {
+		return false, errors.New(result.ErrMsg)
+	}
+	return true, nil
+}

utils/tools.go

@@ -13,6 +13,9 @@ import (
 	"strings"
 	"time"
 
+	"crypto/md5"
+	"encoding/hex"
+
 	"github.com/astaxie/beego"
 )
 
@@ -238,3 +241,18 @@ func GetMondayAndSundayOfWeekDate(date *time.Time) (time.Time, time.Time) {
 	sunday, _ := time.ParseInLocation("2006-01-02 15:04:05", date.AddDate(0, 0, 7-weekday).Format("2006-01-02")+" 23:59:59", loc)
 	return monday, sunday
 }
+
+func GetOrgIdCode(orgID int64, timestamps int64) (int64, string) {
+	if timestamps == 0 {
+		timestamps = time.Now().Unix()
+	}
+
+	key := "47&hsq5wjfHXy%m&"
+	stringA := fmt.Sprintf("org_id=%d&time=%d&key=%s", orgID, timestamps, key)
+
+	md5 := md5.New()
+	md5.Write([]byte(stringA))
+	md5Data := md5.Sum([]byte(nil))
+	md5A := hex.EncodeToString(md5Data)
+	return timestamps, md5A
+}

views/openwechat/authorization.html

@@ -0,0 +1,14 @@
+<!DOCTYPE html>
+<html lang="en">
+<head>
+    <meta charset="UTF-8">
+    <meta name="viewport" content="width=device-width, initial-scale=1.0">
+    <meta http-equiv="X-UA-Compatible" content="ie=edge">
+    <title>酷医云--授权</title>
+    <link href="https://cdn.bootcss.com/weui/2.0.0/style/weui.min.css" rel="stylesheet">
+</head>
+<body>
+    <div style="width:70%;margin:50px auto"><img src="/static/images/logo.png" alt="" srcset="" style="width: 100%"></div>
+    <div style="width: 70%;margin:0 auto"><a href="{{.url}}" class="weui-btn weui-btn_block weui-btn_primary">去授权</a></div>
+</body>
+</html>

views/openwechat/errorauth.html

@@ -0,0 +1,22 @@
+<!DOCTYPE html>
+<html lang="en">
+<head>
+    <meta charset="UTF-8">
+    <meta name="viewport" content="width=device-width, initial-scale=1.0">
+    <meta http-equiv="X-UA-Compatible" content="ie=edge">
+    <title>酷医云--授权错误</title>
+    <link href="https://cdn.bootcss.com/weui/2.0.0/style/weui.min.css" rel="stylesheet">
+</head>
+<body>
+    <div class="page">
+        <div class="weui-msg">
+            <div class="weui-msg__icon-area"><i class="weui-icon-warn weui-icon_msg"></i></div>
+            <div class="weui-msg__text-area">
+                <h2 class="weui-msg__title">授权失败</h2>
+                <p class="weui-msg__desc">{{.msg}}</p>
+            </div>
+           
+        </div>
+    </div>
+</body>
+</html>

views/openwechat/successauth.html

@@ -0,0 +1,22 @@
+<!DOCTYPE html>
+<html lang="en">
+<head>
+    <meta charset="UTF-8">
+    <meta name="viewport" content="width=device-width, initial-scale=1.0">
+    <meta http-equiv="X-UA-Compatible" content="ie=edge">
+    <title>酷医云--授权成功</title>
+    <link href="https://cdn.bootcss.com/weui/2.0.0/style/weui.min.css" rel="stylesheet">
+</head>
+<body>
+    <div class="page">
+        <div class="weui-msg">
+            <div class="weui-msg__icon-area"><i class="weui-icon-success weui-icon_msg"></i></div>
+            <div class="weui-msg__text-area">
+                <h2 class="weui-msg__title">授权成功</h2>
+                <p class="weui-msg__desc">请点击PC端页面的刷新按钮，查看是否成功。</p>
+            </div>
+           
+        </div>
+    </div>
+</body>
+</html>