需求池-微信分享

controllers/english_report.go

@@ -9,11 +9,12 @@ import (
 	"time"
 )
 
-//报告分享
+// EnglishReportShareController 报告分享
 type EnglishReportShareController struct {
 	BaseCommonController
 }
 
+// EnglishReportDetail
 // @Title 英文研报-分享详情
 // @Description 英文研报-分享详情
 // @Param   ReportCode   query   string  true	"报告唯一编码"
@@ -103,3 +104,94 @@ func (this *EnglishReportShareController) EnglishReportDetail() {
 	br.Msg = "获取成功"
 	br.Data = resp
 }
+
+// TrialEnglishReportDetail
+// @Title 英文研报-分享详情-ETA试用平台
+// @Description 英文研报-分享详情
+// @Param   ReportCode   query   string  true	"报告唯一编码"
+// @Param   ShareEmail   query   int  false	"推送的邮箱ID"
+// @Success 200 {object} models.ReportShareDetailResp
+// @router /trial/share/detail [get]
+func (this *EnglishReportShareController) TrialEnglishReportDetail() {
+	br := new(models.BaseResponse).Init()
+	defer func() {
+		this.Data["json"] = br
+		this.ServeJSON()
+	}()
+
+	reportCode := this.GetString("ReportCode")
+	if reportCode == "" {
+		br.Msg = "参数错误"
+		br.ErrMsg = "参数错误，reportCode 为空"
+		return
+	}
+	report, err := models.GetTrialEnglishReportByCode(reportCode)
+	if err != nil {
+		br.Msg = "该报告已删除"
+		br.ErrMsg = "获取报告详情失败,Err:" + err.Error()
+		return
+	}
+	err = models.UpdateTrialEnglishReportCounts(reportCode)
+	if err != nil {
+		br.Msg = "更新失败"
+		br.ErrMsg = "更新失败,Err:" + err.Error()
+		return
+	}
+	report.ContentSub = html.UnescapeString(report.ContentSub)
+	report.Content = html.UnescapeString(report.Content)
+
+	// 记录邮箱
+	shareEmail, _ := this.GetInt("ShareEmail", 0)
+	if shareEmail != 0 {
+		go func() {
+			var errMsg error
+			defer func() {
+				if errMsg != nil {
+					alarm_msg.SendAlarmMsg(utils.APPNAME+"更新英文报告邮箱PV失败, Err: "+errMsg.Error(), 2)
+				}
+			}()
+
+			userEmail, e := models.GetTrialEnglishReportEmailById(shareEmail)
+			if e != nil && e.Error() != utils.ErrNoRow() {
+				errMsg = errors.New("获取客户邮箱信息失败, Err:" + e.Error())
+				return
+			}
+			if userEmail == nil {
+				return
+			}
+			// 更新报告邮箱pv(冗余)
+			if e = models.UpdateTrialEnglishReportEmailCounts(reportCode); e != nil {
+				errMsg = errors.New("更新报告邮箱PV失败, Err:" + e.Error())
+				return
+			}
+			// 记录邮箱PV
+			pv := &models.EnglishReportEmailPV{
+				ReportId:   report.Id,
+				EmailId:    userEmail.Id,
+				CreateTime: time.Now().Local(),
+			}
+			if e = models.InsertTrialEnglishReportEmailPV(pv); e != nil {
+				errMsg = errors.New("新增邮箱PV失败, Err: " + e.Error())
+				return
+			}
+			// 更新阅读量
+			if e = models.UpdateTrialEnglishReportEmailViewTotal(userEmail.Id); e != nil {
+				errMsg = errors.New("更新英文联系人阅读量失败, Err: " + e.Error())
+				return
+			}
+			if userEmail.CompanyId > 0 {
+				if e = models.UpdateTrialEnglishCompanyViewTotal(userEmail.CompanyId); e != nil {
+					errMsg = errors.New("更新英文客户阅读量, Err: " + e.Error())
+					return
+				}
+			}
+		}()
+	}
+
+	resp := new(models.EnglishReportShareDetailResp)
+	resp.Report = report
+	br.Ret = 200
+	br.Success = true
+	br.Msg = "获取成功"
+	br.Data = resp
+}

controllers/report_share.go

@@ -5,11 +5,12 @@ import (
 	"html"
 )
 
-//报告分享
+// ReportShareController 报告分享
 type ReportShareController struct {
 	BaseCommonController
 }
 
+// Detail
 // @Title 日评详情
 // @Description 日评详情接口
 // @Param   ReportCode   query   string  true       "报告唯一编码"
@@ -44,3 +45,40 @@ func (this *ReportShareController) Detail() {
 	br.Msg = "获取成功"
 	br.Data = resp
 }
+
+// TrialDetail
+// @Title 日评详情-ETA试用平台
+// @Description 日评详情接口
+// @Param   ReportCode   query   string  true       "报告唯一编码"
+// @Success 200 {object} models.ReportShareDetailResp
+// @router /trial/share/detail [get]
+func (this *ReportShareController) TrialDetail() {
+	br := new(models.BaseResponse).Init()
+	defer func() {
+		this.Data["json"] = br
+		this.ServeJSON()
+	}()
+
+	reportCode := this.GetString("ReportCode")
+	if reportCode == "" {
+		br.Msg = "参数错误"
+		br.ErrMsg = "参数错误，reportCode 为空"
+		return
+	}
+	report, err := models.GetTrialReportByCode(reportCode)
+	if err != nil {
+		br.Msg = "该报告已删除"
+		br.ErrMsg = "获取报告详情失败,Err:" + err.Error()
+		return
+	}
+	report.ContentSub = html.UnescapeString(report.ContentSub)
+	report.Content = html.UnescapeString(report.Content)
+
+	resp := new(models.ReportShareDetailResp)
+	resp.Report = report
+
+	br.Ret = 200
+	br.Success = true
+	br.Msg = "获取成功"
+	br.Data = resp
+}

controllers/wechat.go

@@ -427,11 +427,11 @@ func (this *WechatCommonController) Notify() {
 			var flag bool
 			for _, v := range classifyArr {
 				if strings.Contains(v, item.Content) || strings.Contains(item.Content, v) {
-					flag=true
+					flag = true
 				}
 			}
 			if flag {
-				contactMsg=`请点击研究报告-FICC研报，查看报告`
+				contactMsg = `请点击研究报告-FICC研报，查看报告`
 				textXmlTpl = fmt.Sprintf(textXmlTpl, item.FromUserName, utils.WxId, createTime, contactMsg)
 				this.Ctx.WriteString(textXmlTpl)
 				return
@@ -439,11 +439,11 @@ func (this *WechatCommonController) Notify() {
 			reportNameArr := utils.ReportNameArr
 			for _, v := range reportNameArr {
 				if strings.Contains(v, item.Content) || strings.Contains(item.Content, v) {
-					flag=true
+					flag = true
 				}
 			}
 			if flag {
-				contactMsg=`请点击研究报告-FICC研报-研报（左上），查看报告`
+				contactMsg = `请点击研究报告-FICC研报-研报（左上），查看报告`
 				textXmlTpl = fmt.Sprintf(textXmlTpl, item.FromUserName, utils.WxId, createTime, contactMsg)
 				this.Ctx.WriteString(textXmlTpl)
 				return
@@ -451,11 +451,11 @@ func (this *WechatCommonController) Notify() {
 
 			if strings.Contains("解绑", item.Content) || strings.Contains(item.Content, "解绑") ||
 				strings.Contains("手机号", item.Content) || strings.Contains(item.Content, "手机号") {
-				flag=true
+				flag = true
 			}
 
 			if flag {
-				contactMsg=`请通过电话联系我们或者联系销售人员处理`
+				contactMsg = `请通过电话联系我们或者联系销售人员处理`
 				textXmlTpl = fmt.Sprintf(textXmlTpl, item.FromUserName, utils.WxId, createTime, contactMsg)
 				this.Ctx.WriteString(textXmlTpl)
 				return
@@ -580,3 +580,49 @@ func subscribe(openId string) {
 		return
 	}
 }
+
+// @Title 微信获取签名接口-无token校验
+// @Description 微信获取签名接口
+// @Param   Url   query   string  true       "url地址"
+// @Success 200 {object} models.WechatSign
+// @router /open/getWxSign [get]
+func (this *WechatCommonController) GetWxSign() {
+	br := new(models.BaseResponse).Init()
+	defer func() {
+		this.Data["json"] = br
+		this.ServeJSON()
+	}()
+	getUrl := this.GetString("Url")
+	fmt.Println("getUrl:", getUrl)
+	accessToken, err := services.WxGetAccessToken()
+	if err != nil {
+		br.Msg = "获取用户信息失败"
+		br.ErrMsg = "获取access_token失败，err:" + err.Error()
+		return
+	}
+
+	ticket, err := services.GetWxTicket(accessToken)
+	if err != nil {
+		br.Msg = "获取Ticket失败,请联系客服"
+		br.ErrMsg = "获取Ticket失败,Err" + err.Error()
+		return
+	}
+	if ticket == "" {
+		br.Msg = "获取Ticket失败,请联系客服"
+		br.ErrMsg = "ticket为空" + ticket
+		return
+	}
+	nonceStr := utils.GetRandStringNoSpecialChar(16)
+	signature, nonceString, timestamp := services.GetWxSignature(ticket, getUrl, nonceStr)
+
+	resp := new(models.WechatSign)
+	resp.AppId = utils.WxAppId
+	resp.NonceStr = nonceString
+	resp.Timestamp = timestamp
+	resp.Url = getUrl
+	resp.Signature = signature
+	br.Ret = 200
+	br.Success = true
+	br.Msg = "获取签名成功"
+	br.Data = resp
+}

models/db.go

@@ -24,12 +24,19 @@ func init() {
 	report_db, _ := orm.GetDB("rddp")
 	report_db.SetConnMaxLifetime(10 * time.Minute)
 
-	_ = orm.RegisterDataBase("edb", "mysql", utils.MYSQL_URL_EDB)
-	orm.SetMaxIdleConns("edb", 50)
-	orm.SetMaxOpenConns("edb", 100)
+	//_ = orm.RegisterDataBase("edb", "mysql", utils.MYSQL_URL_EDB)
+	//orm.SetMaxIdleConns("edb", 50)
+	//orm.SetMaxOpenConns("edb", 100)
 
-	edb_db, _ := orm.GetDB("edb")
-	edb_db.SetConnMaxLifetime(10 * time.Minute)
+	//edb_db, _ := orm.GetDB("edb")
+	//edb_db.SetConnMaxLifetime(10 * time.Minute)
+
+	_ = orm.RegisterDataBase("rddp_trial", "mysql", utils.MYSQL_URL_RDDP_TRIAL)
+	orm.SetMaxIdleConns("rddp_trial", 50)
+	orm.SetMaxOpenConns("rddp_trial", 100)
+
+	rddpTrial, _ := orm.GetDB("rddp_trial")
+	rddpTrial.SetConnMaxLifetime(10 * time.Minute)
 
 	orm.Debug = true
 	orm.DebugLog = orm.NewLog(utils.Binlog)

models/english_company.go

@@ -71,3 +71,11 @@ func UpdateEnglishCompanyViewTotal(companyId int) (err error) {
 	_, err = o.Raw(sql, companyId).Exec()
 	return
 }
+
+// UpdateTrialEnglishCompanyViewTotal 更新英文客户阅读量-ETA试用平台
+func UpdateTrialEnglishCompanyViewTotal(companyId int) (err error) {
+	o := orm.NewOrmUsingDB("rddp_trial")
+	sql := `UPDATE english_company SET view_total = view_total+1 WHERE company_id = ? `
+	_, err = o.Raw(sql, companyId).Exec()
+	return
+}

models/english_report.go

@@ -54,3 +54,24 @@ func UpdateEnglishReportEmailCounts(reportCode string) (err error) {
 	_, err = o.Raw(sql, reportCode).Exec()
 	return
 }
+
+func GetTrialEnglishReportByCode(reportCode string) (item *EnglishReportDetail, err error) {
+	o := orm.NewOrmUsingDB("rddp_trial")
+	sql := `SELECT * FROM english_report WHERE report_code=?`
+	err = o.Raw(sql, reportCode).QueryRow(&item)
+	return
+}
+
+func UpdateTrialEnglishReportCounts(reportCode string) (err error) {
+	o := orm.NewOrmUsingDB("rddp_trial")
+	sql := `UPDATE english_report SET pv = pv+1 WHERE report_code = ?  `
+	_, err = o.Raw(sql, reportCode).Exec()
+	return
+}
+
+func UpdateTrialEnglishReportEmailCounts(reportCode string) (err error) {
+	o := orm.NewOrmUsingDB("rddp_trial")
+	sql := `UPDATE english_report SET pv_email = pv_email+1 WHERE report_code = ?  `
+	_, err = o.Raw(sql, reportCode).Exec()
+	return
+}

models/english_report_email.go

@@ -62,3 +62,19 @@ func UpdateEnglishReportEmailViewTotal(emailId int) (err error) {
 	_, err = o.Raw(sql, emailId).Exec()
 	return
 }
+
+// GetTrialEnglishReportEmailById 主键获取邮箱-ETA试用平台
+func GetTrialEnglishReportEmailById(id int) (item *EnglishReportEmail, err error) {
+	o := orm.NewOrmUsingDB("rddp_trial")
+	sql := `SELECT * FROM english_report_email WHERE is_deleted = 0 AND id = ? LIMIT 1`
+	err = o.Raw(sql, id).QueryRow(&item)
+	return
+}
+
+// UpdateTrialEnglishReportEmailViewTotal 更新英文联系人阅读量-ETA试用平台
+func UpdateTrialEnglishReportEmailViewTotal(emailId int) (err error) {
+	o := orm.NewOrmUsingDB("rddp_trial")
+	sql := `UPDATE english_report_email SET view_total = view_total+1, last_view_time = NOW() WHERE id = ? `
+	_, err = o.Raw(sql, emailId).Exec()
+	return
+}

models/english_report_email_pv.go

@@ -26,3 +26,11 @@ func (item *EnglishReportEmailPV) Create() (err error) {
 	item.Id = int(id)
 	return
 }
+
+// InsertTrialEnglishReportEmailPV ETA试用平台-新增英文邮箱PV
+func InsertTrialEnglishReportEmailPV(item *EnglishReportEmailPV) (err error) {
+	o := orm.NewOrmUsingDB("rddp_trial")
+	sql := `INSERT INTO english_report_email_pv VALUE(?, ?, ?)`
+	_, err = o.Raw(sql, item.ReportId, item.EmailId, item.CreateTime).Exec()
+	return
+}

models/report.go

@@ -269,3 +269,11 @@ func GetReportAuthor(reportAuthor string) (item *ReportAuthor, err error) {
 	err = o.Raw(sql, reportAuthor).QueryRow(&item)
 	return
 }
+
+// GetTrialReportByCode ETA试用-根据编码获取报告
+func GetTrialReportByCode(reportCode string) (item *Report, err error) {
+	o := orm.NewOrmUsingDB("rddp_trial")
+	sql := `SELECT * FROM report WHERE report_code=?`
+	err = o.Raw(sql, reportCode).QueryRow(&item)
+	return
+}

routers/commentsRouter.go

@@ -52,6 +52,15 @@ func init() {
             Filters: nil,
             Params: nil})
 
+    beego.GlobalControllerRouter["hongze/hongze_api/controllers:EnglishReportShareController"] = append(beego.GlobalControllerRouter["hongze/hongze_api/controllers:EnglishReportShareController"],
+        beego.ControllerComments{
+            Method: "TrialEnglishReportDetail",
+            Router: `/trial/share/detail`,
+            AllowHTTPMethods: []string{"get"},
+            MethodParams: param.Make(),
+            Filters: nil,
+            Params: nil})
+
     beego.GlobalControllerRouter["hongze/hongze_api/controllers:HomeCommonController"] = append(beego.GlobalControllerRouter["hongze/hongze_api/controllers:HomeCommonController"],
         beego.ControllerComments{
             Method: "PcListBanner",
@@ -178,6 +187,15 @@ func init() {
             Filters: nil,
             Params: nil})
 
+    beego.GlobalControllerRouter["hongze/hongze_api/controllers:ReportShareController"] = append(beego.GlobalControllerRouter["hongze/hongze_api/controllers:ReportShareController"],
+        beego.ControllerComments{
+            Method: "TrialDetail",
+            Router: `/trial/share/detail`,
+            AllowHTTPMethods: []string{"get"},
+            MethodParams: param.Make(),
+            Filters: nil,
+            Params: nil})
+
     beego.GlobalControllerRouter["hongze/hongze_api/controllers:RunLogController"] = append(beego.GlobalControllerRouter["hongze/hongze_api/controllers:RunLogController"],
         beego.ControllerComments{
             Method: "Edit",
@@ -349,6 +367,15 @@ func init() {
             Filters: nil,
             Params: nil})
 
+    beego.GlobalControllerRouter["hongze/hongze_api/controllers:WechatCommonController"] = append(beego.GlobalControllerRouter["hongze/hongze_api/controllers:WechatCommonController"],
+        beego.ControllerComments{
+            Method: "GetWxSign",
+            Router: `/open/getWxSign`,
+            AllowHTTPMethods: []string{"get"},
+            MethodParams: param.Make(),
+            Filters: nil,
+            Params: nil})
+
     beego.GlobalControllerRouter["hongze/hongze_api/controllers:WechatCommonController"] = append(beego.GlobalControllerRouter["hongze/hongze_api/controllers:WechatCommonController"],
         beego.ControllerComments{
             Method: "PcWechatLogin",

utils/config.go

@@ -15,7 +15,8 @@ var (
 	RunMode        string //运行模式
 	MYSQL_URL      string //数据库连接
 	MYSQL_URL_RDDP string //数据库连接
-	MYSQL_URL_EDB  string
+	//MYSQL_URL_EDB        string
+	MYSQL_URL_RDDP_TRIAL string // ETA试用rddp库
 
 	REDIS_CACHE string        //缓存地址
 	Redis       *redis.Client //redis链接
@@ -25,7 +26,7 @@ var (
 	STATIC_DIR string
 )
 
-//微信配置信息
+// 微信配置信息
 var (
 	WxId                string //微信原始ID
 	WxAppId             string
@@ -35,7 +36,7 @@ var (
 	WxPlatform          int    //用户来源，需要入库，用来保存该用户来自哪个平台，默认是：1
 )
 
-//pc端微信配置信息
+// pc端微信配置信息
 var (
 	PcWxId                string //微信原始ID
 	PcWxAppId             string
@@ -46,8 +47,8 @@ var (
 )
 
 var (
-	ClassifyArr []string
-	ReportNameArr  []string
+	ClassifyArr   []string
+	ReportNameArr []string
 )
 
 func init() {
@@ -87,7 +88,8 @@ func init() {
 	logs.Info(RunMode + " 模式")
 	MYSQL_URL = config["mysql_url"]
 	MYSQL_URL_RDDP = config["mysql_url_rddp"]
-	MYSQL_URL_EDB = config["mysql_url_edb"]
+	//MYSQL_URL_EDB = config["mysql_url_edb"]
+	MYSQL_URL_RDDP_TRIAL = config["mysql_url_rddp_trial"]
 
 	if RunMode == "release" {
 		WxAppId = "wx4a844c734d8c8e56"
@@ -156,7 +158,7 @@ func initRedis(config map[string]string) {
 	Redis = client
 }
 
-//自动回复
+// 自动回复
 func initAutoReply() {
 	keyWord := `宏观经济、利率债、原油、PTA、MEG、织造终端、甲醇、聚烯烃、沥青、苯乙烯、聚酯、钢材、铁矿、玻璃纯碱、PVC、双焦、铜/铝、镍/不锈钢、锌、钴锂、策略`
 	ClassifyArr = strings.Split(keyWord, "、")