package petsLy import ( "context" "duoduo/conf" "duoduo/models/mysqlLy" "duoduo/tools/app" "encoding/json" "fmt" "github.com/gin-gonic/gin" "github.com/qiniu/go-sdk/v7/auth/qbox" "github.com/qiniu/go-sdk/v7/storage" "github.com/shopspring/decimal" "os" "strconv" "time" ) func CreateUpload(c *gin.Context) { confIni, err := conf.ConnIni() if err != nil { app.Error(c, 400, err, err.Error()) return } form, err := c.MultipartForm() if err != nil { app.Error(c, 400, err, err.Error()) return } files := form.File["files"] openId := c.PostForm("open_id") name := c.PostForm("name") pet := c.PostForm("pet") age := c.PostForm("age") sex := c.PostForm("sex") petDes := c.PostForm("pet_des") if openId == "" || name == "" || pet == "" || age == "" || sex == "" || petDes == "" { app.Error(c, 400, err, "必填字段为空值") return } petStatus := c.PostForm("pet_status") petStatusN, _ := strconv.Atoi(petStatus) isSterilization := c.PostForm("is_sterilization") isSterilizationN, _ := strconv.Atoi(isSterilization) isExpellingParasite := c.PostForm("is_expelling_parasite") isExpellingParasiteN, _ := strconv.Atoi(isExpellingParasite) isImmune := c.PostForm("is_immune") isImmuneN, _ := strconv.Atoi(isImmune) isFee := c.PostForm("is_fee") isFeeN, _ := strconv.Atoi(isFee) if petStatusN == 0 || isSterilizationN == 0 || isExpellingParasiteN == 0 || isImmuneN == 0 || isFeeN == 0 { app.Error(c, 400, err, "必填状态为空值") return } deposit := c.PostForm("deposit") depositDate := c.PostForm("deposit_date") amount := c.PostForm("amount") if isFeeN == 2 && (deposit == "" || depositDate == "") { app.Error(c, 400, err, "押金信息未填写") return } if isFeeN == 3 && amount == "" { app.Error(c, 400, err, "金额信息未填写") return } province := c.PostForm("province") city := c.PostForm("city") area := c.PostForm("area") petInfo := c.PostForm("pet_info") adoptInfo := c.PostForm("adopt_info") if province == "" || city == "" || area == "" || petInfo == "" || adoptInfo == "" { app.Error(c, 400, err, "必填状态为空值!") return } user := mysqlLy.User{} user.OpenID = openId userInfo, err := user.Get() if err != nil { app.Error(c, 500, err, "用户信息错误") return } var pictures []string for _, file := range files { timeUnixNano := time.Now().UnixNano() //单位纳秒 fileName := fmt.Sprintf("%d-%s.jpg", timeUnixNano, openId) err := c.SaveUploadedFile(file, "./"+fileName) if err != nil { app.Error(c, 500, err, "保存图片失败") return } //七牛云上传图片 //localFile = "/Users/jemy/Documents/github.png" bucket := "imgxx" key := "lingyang/" + openId + "/" + fileName putPolicy := storage.PutPolicy{ Scope: bucket, } mac := qbox.NewMac(confIni.MustValue("ly-qn", "access_key"), confIni.MustValue("ly-qn", "secret_key")) upToken := putPolicy.UploadToken(mac) cfg := storage.Config{} // 空间对应的机房 cfg.Zone = &storage.ZoneHuanan // 是否使用https域名 cfg.UseHTTPS = false // 上传是否使用CDN上传加速 cfg.UseCdnDomains = false // 构建表单上传的对象 formUploader := storage.NewFormUploader(&cfg) ret := storage.PutRet{} // 可选配置 //putExtra := storage.PutExtra{ // Params: map[string]string{ // "x:name": "github logo", // }, //} err = formUploader.PutFile(context.Background(), &ret, upToken, key, "./"+fileName, nil) if err != nil { app.Error(c, 500, err, "上传图片失败") return } fmt.Println(ret.Key, ret.Hash) err = os.Remove("./" + fileName) if err != nil { app.Error(c, 500, err, "删除图片失败") return } pictures = append(pictures, "http://lingyang.shisanmiao.com/"+key) } sqlData := mysqlLy.Pets{} sqlData.Province = province picture, err := json.Marshal(pictures) if err != nil { app.Error(c, 500, err, err.Error()) return } sqlData.Pictures = string(picture) sqlData.PetStatus = petStatusN sqlData.PetInfo = petInfo sqlData.PetDes = petDes sqlData.IsSterilization = isSterilizationN sqlData.IsImmune = isImmuneN sqlData.IsFee = isFeeN sqlData.IsExpellingParasite = isExpellingParasiteN sqlData.DepositDate, _ = time.Parse("2006-01-02", depositDate) sqlData.Deposit, _ = decimal.NewFromString(deposit) sqlData.City = city sqlData.Area = area sqlData.Age = age sqlData.AdoptInfo = adoptInfo sqlData.Amount, _ = decimal.NewFromString(amount) sqlData.UserID = userInfo.ID sqlData.Status = 1 //待领养 sqlData.Sex = sex sqlData.Name = name sqlData.CreateTime = time.Now().Local() sqlData.UpdateTime = time.Now().Local() _, err = sqlData.Create() if err != nil { app.Error(c, 500, err, "插入数据失败") return } app.OK(c, nil, "成功") //OpenId string `json:"open_id" binding:"required"` //Name string `json:"name" binding:"required"` // 昵称 //Pet string `json:"pet" binding:"required"` // 品种 //Age string `json:"age" binding:"required"` // 年龄 '0-3个月','3-6个月','6-9个月','小于1岁','小于2岁','小于3岁','大于3岁' //Sex string `json:"sex" binding:"required"` // 性别 MM GG //PetStatus int `json:"pet_status" binding:"required"` // 1-流浪 2-家养 3-收养所 //PetDes string `json:"pet_des" binding:"required"` // 宠物详细种类 //IsSterilization int `json:"is_sterilization" binding:"required"` // 绝育状态:1-是 2-否 3-不确认 //IsExpellingParasite int `json:"is_expelling_parasite" binding:"required"` // 驱虫状态：1-是 2-否 3-不确认 //IsImmune int `json:"is_immune" binding:"required"` // 免疫状态：1-是 2-否 3-不确认 //IsFee int `json:"is_fee" binding:"required"` // 1-免费 2-押金 3-有偿 //Deposit decimal.Decimal `json:"deposit"` // 押金 //DepositDate time.Time `json:"deposit_date"` // 押金到期时间 //Amount decimal.Decimal `json:"amount" ` // 金额 //Province string `json:"province" binding:"required"` // 省 //City string `json:"city" binding:"required"` // 市 //Area string `json:"area" binding:"required"` // 区 //PetInfo string `json:"pet_info" binding:"required"` // 宠物信息 //AdoptInfo string `json:"adopt_info" binding:"required"` // 领养要求 //Pictures string `json:"pictures"` // 图片url }