微信修改小程序头像

controllers/article.go

@@ -944,7 +944,6 @@ func (this *ArticleController) Pdfwatermark() {
 		writer := bufio.NewWriter(file)
 		written, _ := io.Copy(writer, reader)
 		fmt.Printf("Total length: %d", written)
-
 	}
 	newFile = uploadDir + "new_" + pdfName
 	onTop := true

controllers/resource.go

@@ -33,7 +33,7 @@ func (this *ResourceController) Upload() {
 	}
 	ext := path.Ext(h.Filename)
 	dateDir := time.Now().Format("20060102")
-	uploadDir := "./temp/" + dateDir
+	uploadDir := "static/temp/" + dateDir
 	err = os.MkdirAll(uploadDir, 777)
 	if err != nil {
 		br.Msg = "存储目录创建失败"
@@ -50,18 +50,29 @@ func (this *ResourceController) Upload() {
 		br.ErrMsg = "文件上传失败，Err:" + err.Error()
 		return
 	}
+	//
+	////上传到阿里云
+	//resourceUrl, err := services.UploadAliyun(fileName, fpath)
+	//if err != nil {
+	//	br.Msg = "文件上传失败"
+	//	br.ErrMsg = "文件上传失败，Err:" + err.Error()
+	//	return
+	//}
+
+	savePath := uploadDir + time.Now().Format("200601/20060102/")
+	savePath += fileName
 	//上传到阿里云
-	resourceUrl, err := services.UploadAliyun(fileName, fpath)
+	err = services.UploadFileToAliyun("", fpath, savePath)
 	if err != nil {
 		br.Msg = "文件上传失败"
 		br.ErrMsg = "文件上传失败，Err:" + err.Error()
 		return
 	}
-
+	fileHost := "https://hzstatic.hzinsights.com/"
+	resourceUrl := fileHost + savePath
 	defer func() {
 		os.Remove(fpath)
 	}()
-
 	item := new(models.Resource)
 	item.ResourceUrl = resourceUrl
 	item.ResourceType = 1
@@ -81,4 +92,4 @@ func (this *ResourceController) Upload() {
 	br.Success = true
 	br.Data = resp
 	return
-}
+}

controllers/user.go

@@ -214,7 +214,9 @@ func (this *UserController) Detail() {
 		userRecord, _ := models.GetUserRecordByUserId(uid, utils.WxPlatform)
 		if userRecord != nil {
 			detail.NickName = userRecord.NickName
-			detail.Headimgurl = userRecord.Headimgurl
+			if detail.Headimgurl == "" {
+				detail.Headimgurl = userRecord.Headimgurl
+			}
 			if detail.Headimgurl == "" {
 				userRecord, _ = models.GetUserRecordByUserId(uid, 1)
 				if userRecord != nil {
@@ -291,7 +293,7 @@ func (this *UserController) Detail() {
 		detail.HasPermission = hasPermission
 	}
 	if detail.Headimgurl == "" {
-		detail.Headimgurl = "https://hongze.oss-cn-shanghai.aliyuncs.com/static/images/202204/20220425/uYF0So2tSwAudlscqQhEzREGTwak.png"
+		detail.Headimgurl = utils.DefaultHeadimgurl
 	}
 	br.Ret = 200
 	br.Success = true
@@ -1200,3 +1202,45 @@ func (this *UserController) ShareIsShow() {
 	br.Success = true
 	br.Data = resp
 }
+
+// @Title 更改用户微信头像
+// @Description 更改用户微信头像
+// @Param	request	body models.Headimgurl true "type json string"
+// @Success 200 {object} models.ArticleDetailFileLink
+// @router /headimgurl/update [post]
+func (this *UserController) HeadimgurlUpdate() {
+	br := new(models.BaseResponse).Init()
+	defer func() {
+		this.Data["json"] = br
+		this.ServeJSON()
+	}()
+	user := this.User
+	if user == nil {
+		br.Msg = "请登录"
+		br.ErrMsg = "请登录，用户信息为空"
+		br.Ret = 408
+		return
+	}
+	var req models.Headimgurl
+	err := json.Unmarshal(this.Ctx.Input.RequestBody, &req)
+	if err != nil {
+		br.Msg = "参数解析异常！"
+		br.ErrMsg = "参数解析失败，Err:" + err.Error()
+		return
+	}
+	uid := user.UserId
+	headimgurl := req.Headimgurl
+	if headimgurl == "" {
+		br.Msg = "操作失败"
+		br.ErrMsg = "头像信息不能为空"
+		return
+	}
+	err = models.UpdateUserHeadimgurl(headimgurl, uid)
+	if err != nil {
+		br.Msg = "操作失败"
+		br.ErrMsg = "头像信息不能为空"
+	}
+	br.Ret = 200
+	br.Success = true
+	br.Msg = "操作成功"
+}

models/user.go

@@ -435,3 +435,15 @@ func GetSendEmailAllUserWithCompany() (items []*GetSendEmailAllUserWithCompanyRe
 	_, err = orm.NewOrm().Raw(sql).QueryRows(&items)
 	return
 }
+
+type Headimgurl struct {
+	Headimgurl string `description:"用户头像"`
+}
+
+//更改用户手机号
+func UpdateUserHeadimgurl(headimgurl string, userId int) (err error) {
+	o := orm.NewOrm()
+	sql := `UPDATE wx_user SET headimgurl = ? WHERE user_id=? `
+	_, err = o.Raw(sql, headimgurl, userId).Exec()
+	return
+}

routers/commentsRouter_controllers.go

@@ -745,6 +745,15 @@ func init() {
             Filters: nil,
             Params: nil})
 
+    beego.GlobalControllerRouter["hongze/hongze_cygx/controllers:UserController"] = append(beego.GlobalControllerRouter["hongze/hongze_cygx/controllers:UserController"],
+        beego.ControllerComments{
+            Method: "HeadimgurlUpdate",
+            Router: "/headimgurl/update",
+            AllowHTTPMethods: []string{"post"},
+            MethodParams: param.Make(),
+            Filters: nil,
+            Params: nil})
+
     beego.GlobalControllerRouter["hongze/hongze_cygx/controllers:UserController"] = append(beego.GlobalControllerRouter["hongze/hongze_cygx/controllers:UserController"],
         beego.ControllerComments{
             Method: "InterviewApplyList",

utils/constants.go

@@ -23,6 +23,7 @@ const (
 	APPNAME           = "弘则-查研观向"
 	EmailSendToUsers  = "glji@hzinsights.com;pyan@hzinsights.com;cxzhang@hzinsights.com"
 	EmailSendToExpert = "cxzhang@hzinsights.com"
+	DefaultHeadimgurl = "https://hzstatic.hzinsights.com/static/temp/20220426202204/20220426/P5qLR2zzfBdKItp3eX2Du1tvq9Ba.jpg"
 )
 
 //手机号，电子邮箱正则