package hdl import ( "applet/app/db" "applet/app/db/model" "applet/app/e" "applet/app/md" "applet/app/svc" "applet/app/utils" "encoding/json" "github.com/gin-gonic/gin" "github.com/tidwall/gjson" "time" ) // UserStoreList 门店列表 // @Summary 门店-列表 // @Tags 门店 // @Description 门店-列表 // @Accept json // @Produce json // @Param req body md.Store true "请求参数" // @Success 200 {string} "" // @Failure 400 {object} md.Response "具体错误" // @Router /api/v1/communityTeam/ownStore/store/list [POST] func UserStoreList(c *gin.Context) { var arg md.Store if err := c.ShouldBindJSON(&arg); err != nil { e.OutErr(c, e.ERR_INVALID_ARGS, err) return } user := svc.GetUser(c) list, count := db.GetUserList(svc.MasterDb(c), arg, user.Info.Uid) data := make([]map[string]interface{}, 0) if list != nil { currentMonth := utils.GetTimeRange("current_month") for _, v := range *list { store := v.CommunityTeamStore tmp := map[string]interface{}{ "uid": utils.IntToStr(v.User.Uid), "create_at": store.CreateAt.Format("2006-01-02 15:04:05"), "name": "", "address": "", "logo": "", "order_count": "0", "order_amount": "0", "agent_commission": "0", "platform_commission": "0", "base_commission": "0", "work_state": "", } count1, _ := svc.MasterDb(c).Where("store_uid=? and parent_uid=?", v.User.Uid, user.Info.Uid).In("state", []string{"1", "2"}).Count(&model.CommunityTeamOrder{}) sum, _ := svc.MasterDb(c).Where("store_uid=? and parent_uid=? and create_at>=?", v.User.Uid, user.Info.Uid, time.Unix(currentMonth["start"], 0).Format("2006-01-02 15:04:05")).In("state", []string{"1", "2"}).Sum(&model.CommunityTeamOrder{}, "amount") tmp["order_count"] = utils.Int64ToStr(count1) tmp["order_amount"] = svc.GetCommissionPrec(c, utils.Float64ToStr(sum), "2", "") tmp["name"] = store.Name tmp["address"] = store.Address tmp["logo"] = store.Logo tmp["work_state"] = "营业中" if store.WorkState == 1 { tmp["work_state"] = "休息中" } tmp["agent_commission"] = store.AgentCommission data = append(data, tmp) } } res := map[string]interface{}{ "total": count, "list": data, } e.OutSuc(c, res, nil) } // UserStoreSave 门店编辑 // @Summary 门店-门店编辑 // @Tags 门店 // @Description 门店-门店编辑 // @Accept json // @Produce json // @Param req body md.StoreSave true "请求参数" // @Success 200 {string} "" // @Failure 400 {object} md.Response "具体错误" // @Router /api/v1/communityTeam/ownStore/store/save [POST] func UserStoreSave(c *gin.Context) { var arg md.StoreSave if err := c.ShouldBindJSON(&arg); err != nil { e.OutErr(c, e.ERR_INVALID_ARGS, err) return } store := db.GetUserStore(svc.MasterDb(c), utils.StrToInt(arg.Uid)) if store == nil { e.OutErr(c, 400, e.NewErr(400, "门店不存在")) return } store.AgentCommission = arg.AgentCommission svc.MasterDb(c).Where("id=?", store.Id).Cols("agent_commission").Update(store) e.OutSuc(c, "success", nil) return } // UserStoreOrder 门店订单-订单管理共用一个 // @Summary 门店-门店订单 // @Tags 门店 // @Description 门店-门店订单 // @Accept json // @Produce json // @Param req body md.StoreOrder true "请求参数" // @Success 200 {string} "" // @Failure 400 {object} md.Response "具体错误" // @Router /api/v1/communityTeam/ownStore/store/order [POST] func UserStoreOrder(c *gin.Context) { var arg md.StoreOrder if err := c.ShouldBindJSON(&arg); err != nil { e.OutErr(c, e.ERR_INVALID_ARGS, err) return } user := svc.GetUser(c) arg.StoreUid = utils.IntToStr(user.Info.Uid) data, total, _ := db.GetStoreOrderList(svc.MasterDb(c), arg, 0) list := make([]map[string]string, 0) if data != nil { stateList := []string{"待付款", "已支付", "已提货", "已取消"} for _, v := range *data { tmp := map[string]string{ "oid": utils.Int64ToStr(v.Oid), "uid": utils.IntToStr(v.Uid), "phone": "", "nickname": "", "store_name": "", "state_str": stateList[v.State], "amount": v.Amount, "agent_commission": v.AgentCommission, "state": utils.IntToStr(v.State), "create_at": v.CreateAt.Format("2006-01-02 15:04:05"), "confirm_at": utils.Int64ToStr(v.Oid), } if v.ConfirmAt.IsZero() == false { tmp["confirm_at"] = v.ConfirmAt.Format("2006-01-02 15:04:05") } user1, _ := db.UserFindByID(svc.MasterDb(c), v.Uid) if user1 != nil { tmp["phone"] = user1.Phone tmp["nickname"] = user1.Nickname } store := db.GetUserStore(svc.MasterDb(c), v.StoreUid) if store != nil { tmp["store_name"] = store.Name } list = append(list, tmp) } } res := map[string]interface{}{ "total": total, "state": []map[string]string{ {"name": "待付款", "value": "0"}, {"name": "已支付", "value": "1"}, {"name": "已提货", "value": "2"}, {"name": "已取消", "value": "3"}, }, "list": list, } e.OutSuc(c, res, nil) } // UserStoreOrderDetail 门店订单详情-订单管理共用一个 // @Summary 门店-门店订单详情 // @Tags 门店 // @Description 门店-门店订单详情 // @Accept json // @Produce json // @Param req body md.StoreOrderDetail true "请求参数" // @Success 200 {string} "" // @Failure 400 {object} md.Response "具体错误" // @Router /api/v1/communityTeam/ownStore/store/order/detail [POST] func UserStoreOrderDetail(c *gin.Context) { var arg md.StoreOrderDetail if err := c.ShouldBindJSON(&arg); err != nil { e.OutErr(c, e.ERR_INVALID_ARGS, err) return } order := db.GetOrderByOid(svc.MasterDb(c), arg.Oid) if order == nil { e.OutErr(c, 400, e.NewErr(400, "订单不存在")) return } stateList := []string{"待付款", "已支付", "已提货", "已取消"} payMethodStr := []string{"余额支付", "支付宝支付", "微信支付"} orderInfoMap := make([]map[string]string, 0) res := map[string]interface{}{ "oid": utils.Int64ToStr(order.Oid), "uid": utils.IntToStr(order.Uid), "phone": order.Phone, "nickname": "", "store_name": "", "memo": order.Memo, "coupon": order.Coupon, "code": order.Code, "amount": order.Amount, "all_amount": utils.Float64ToStr(utils.StrToFloat64(order.Amount) + utils.StrToFloat64(order.Coupon)), "pay_method_str": payMethodStr[order.PayMethod], "state_str": stateList[order.State], "state": utils.IntToStr(order.State), "create_at": order.CreateAt.Format("2006-01-02 15:04:05"), "confirm_at": "", "pay_at": "", "order_info": orderInfoMap, } if order.ConfirmAt.IsZero() == false { res["confirm_at"] = order.ConfirmAt.Format("2006-01-02 15:04:05") } else { res["confirm_at"] = order.Timer if order.IsNow == 1 { res["confirm_at"] = "立即提货" } } if order.PayAt.IsZero() == false { res["pay_at"] = order.PayAt.Format("2006-01-02 15:04:05") } user, _ := db.UserFindByID(svc.MasterDb(c), order.Uid) if user != nil { res["nickname"] = user.Nickname if order.Phone == "" { res["phone"] = user.Phone } } store := db.GetUserStore(svc.MasterDb(c), order.StoreUid) if store != nil { res["store_name"] = store.Name } orderInfo := db.GetOrderInfoAllEg(svc.MasterDb(c), arg.Oid) if orderInfo != nil { for _, v := range *orderInfo { skuData := make([]md.Sku, 0) json.Unmarshal([]byte(v.SkuInfo), &skuData) skuStr := "" for _, v1 := range skuData { if skuStr != "" { skuStr += ";" } skuStr += v1.Value } tmp := map[string]string{ "sku_str": skuStr, "goods_title": v.Title, "goods_img": v.Img, "num": utils.IntToStr(v.Num), "amount": utils.Float64ToStr(float64(v.Num) * utils.StrToFloat64(v.Price)), } orderInfoMap = append(orderInfoMap, tmp) } res["order_info"] = orderInfoMap } e.OutSuc(c, res, nil) return } func UserStoreInfo(c *gin.Context) { var arg map[string]string if err := c.ShouldBindJSON(&arg); err != nil { e.OutErr(c, e.ERR_INVALID_ARGS, err) return } user := svc.GetUser(c) data, _ := db.SysModFindBySkipIdentifierWithUid(c, svc.MasterDb(c), "pub.flutter.user_store", user.Info.Uid) if data == nil { data = &model.SysModule{ ModName: "user_store", Position: "user_store", SkipIdentifier: "pub.flutter.user_store", Title: "店铺模板", Uid: utils.StrToInt(arg["uid"]), State: 1, Data: "{\"icon\":\"\",\"icon_url\":\"\",\"name\":\"\",\"store_detail_url\":\"\",\"address\":\"\",\"phone\":\"\",\"time_str\":\"\",\"notice_str\":\"\",\"banner_title\":\"\",\"activity_title\":\"\"}", Platform: 1, CreateAt: time.Now(), UpdateAt: time.Now(), } svc.MasterDb(c).Insert(data) } var tmp = make(map[string]interface{}) json.Unmarshal([]byte(data.Data), &tmp) h5Domain := svc.GetWebSiteDomainInfo(c, "wap") store := db.GetStoreIdEg(svc.MasterDb(c), utils.IntToStr(user.Info.Uid)) if store != nil { tmp["lat"] = store.Lat tmp["lng"] = store.Lng tmp["province"] = store.Province tmp["city"] = store.City tmp["district"] = store.District tmp["province_id"] = store.ProvinceId tmp["city_id"] = store.CityId tmp["district_id"] = store.DistrictId tmp["work_state"] = utils.IntToStr(store.WorkState) } tmp["share_url"] = h5Domain + "/#/zy-user-store/pages/store-page/index?uid=" + arg["uid"] e.OutSuc(c, tmp, nil) return } func UserStoreInfoSet(c *gin.Context) { var arg map[string]interface{} if err := c.ShouldBindJSON(&arg); err != nil { e.OutErr(c, e.ERR_INVALID_ARGS, err) return } user := svc.GetUser(c) data, _ := db.SysModFindBySkipIdentifierWithUid(c, svc.MasterDb(c), "pub.flutter.user_store", user.Info.Uid) data.Data = utils.SerializeStr(arg) svc.MasterDb(c).Where("mod_id=?", data.ModId).Cols("data").Update(data) store := db.GetStoreIdEg(svc.MasterDb(c), utils.IntToStr(user.Info.Uid)) if store == nil { store = &model.CommunityTeamStore{ Uid: int(utils.AnyToInt64(arg["uid"])), CreateAt: time.Now(), UpdateAt: time.Now(), State: 1, } svc.MasterDb(c).Insert(store) } if gjson.Get(data.Data, "address").String() != "" { store.Address = gjson.Get(data.Data, "address").String() } if gjson.Get(data.Data, "lat").String() != "" { store.Lat = gjson.Get(data.Data, "lat").String() } if gjson.Get(data.Data, "lng").String() != "" { store.Lng = gjson.Get(data.Data, "lng").String() } if gjson.Get(data.Data, "province").String() != "" { store.Province = gjson.Get(data.Data, "province").String() } if gjson.Get(data.Data, "city").String() != "" { store.City = gjson.Get(data.Data, "city").String() } if gjson.Get(data.Data, "district").String() != "" { store.District = gjson.Get(data.Data, "district").String() } if gjson.Get(data.Data, "province_id").String() != "" { store.ProvinceId = utils.StrToInt(gjson.Get(data.Data, "province_id").String()) } if gjson.Get(data.Data, "city_id").String() != "" { store.CityId = utils.StrToInt(gjson.Get(data.Data, "city_id").String()) } if gjson.Get(data.Data, "district_id").String() != "" { store.DistrictId = utils.StrToInt(gjson.Get(data.Data, "district_id").String()) } if gjson.Get(data.Data, "name").String() != "" { store.Name = gjson.Get(data.Data, "name").String() } if gjson.Get(data.Data, "work_state").String() != "" { store.WorkState = utils.StrToInt(gjson.Get(data.Data, "work_state").String()) } if gjson.Get(data.Data, "time_str").String() != "" { store.Timer = gjson.Get(data.Data, "time_str").String() } if gjson.Get(data.Data, "phone").String() != "" { store.Phone = gjson.Get(data.Data, "phone").String() } if gjson.Get(data.Data, "icon_url").String() != "" { store.Logo = gjson.Get(data.Data, "icon_url").String() } svc.MasterDb(c).Where("id=?", store.Id).Cols("province_id,city_id,district_id,timer,phone,logo,work_state,name,province,city,district,address,lat,lng").Update(store) e.OutSuc(c, "success", nil) return } func UserStoreBanner(c *gin.Context) { var arg map[string]string if err := c.ShouldBindJSON(&arg); err != nil { e.OutErr(c, e.ERR_INVALID_ARGS, err) return } uid := utils.StrToInt(arg["uid"]) activity := db.GetUserStoreActivity(svc.MasterDb(c), arg["type"], uid) data := make([]map[string]string, 0) if activity != nil { scheme := svc.SysCfgGet(c, "file_bucket_scheme") domain := svc.SysCfgGet(c, "file_bucket_host") linkTypeStr := []string{"内链分享", "外链分享"} for _, v := range *activity { tmp := map[string]string{ "id": utils.IntToStr(v.Id), "title": v.Title, "link_type_str": linkTypeStr[v.LinkType], "img": v.Img, "img_url": svc.ImageFormatWithBucket(scheme, domain, v.Img), "label": v.Label, "uid": utils.IntToStr(v.Uid), } data = append(data, tmp) } } e.OutSuc(c, data, nil) return } func UserStoreBannerDetail(c *gin.Context) { var arg map[string]string if err := c.ShouldBindJSON(&arg); err != nil { e.OutErr(c, e.ERR_INVALID_ARGS, err) return } data := db.GetUserStoreActivityById(svc.MasterDb(c), arg["id"]) if data == nil { e.OutErr(c, 400, e.NewErr(400, "记录不存在")) return } scheme := svc.SysCfgGet(c, "file_bucket_scheme") domain := svc.SysCfgGet(c, "file_bucket_host") res := map[string]string{ "id": utils.IntToStr(data.Id), "uid": utils.IntToStr(data.Uid), "title": data.Title, "img": data.Img, "img_url": svc.ImageFormatWithBucket(scheme, domain, data.Img), "label": data.Label, "content": data.Content, "type": data.Type, "url": data.Url, "link_type": utils.IntToStr(data.LinkType), "sort": utils.IntToStr(data.Sort), } e.OutSuc(c, res, nil) return } func UserStoreBannerSave(c *gin.Context) { var arg map[string]string if err := c.ShouldBindJSON(&arg); err != nil { e.OutErr(c, e.ERR_INVALID_ARGS, err) return } data := model.UserStoreActivity{} if arg["id"] == "" { data = model.UserStoreActivity{ Uid: utils.StrToInt(arg["uid"]), Type: arg["type"], Time: time.Now(), } svc.MasterDb(c).Insert(&data) } else { svc.MasterDb(c).Where("id=?", arg["id"]).Get(&data) } data.Label = arg["label"] data.Img = arg["img"] data.Title = arg["title"] data.Content = arg["content"] data.LinkType = utils.StrToInt(arg["link_type"]) data.Url = arg["url"] data.Sort = utils.StrToInt(arg["sort"]) svc.MasterDb(c).Where("id=?", data.Id).Update(&data) e.OutSuc(c, "success", nil) return } func UserStoreBannerDel(c *gin.Context) { var arg map[string]string if err := c.ShouldBindJSON(&arg); err != nil { e.OutErr(c, e.ERR_INVALID_ARGS, err) return } svc.MasterDb(c).Where("id=?", arg["id"]).Delete(&model.UserStoreActivity{}) e.OutSuc(c, "success", nil) return }