From 47b6906cf168d8bbb3bc61ba1769fdbb2b6bd84b Mon Sep 17 00:00:00 2001 From: huangjiajun <582604932@qq.com> Date: Wed, 21 Aug 2024 13:54:06 +0800 Subject: [PATCH] =?UTF-8?q?=E5=BF=AB=E7=AB=99?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- db/offical/db_kuaizhan_short_url.go | 15 + db/offical/db_kuaizhan_url.go | 15 + db/offical/model/kuaizhan_short_url_money.go | 11 + .../model/kuaizhan_short_url_num_list.go | 7 + db/offical/model/kuaizhan_short_url_record.go | 27 ++ db/offical/model/kuaizhan_url.go | 9 + e/code.go | 244 +++++++++++++++ e/error.go | 72 +++++ e/set_cache.go | 8 + go.mod | 1 + go.sum | 6 + kuaizhan/kuaizhan_test.go | 9 + kuaizhan/short_url.go | 84 ++++++ kuaizhan/url.go | 21 ++ md/cfg_key.go | 279 ++++++++++++++++++ md/file.go | 62 ++++ qiniuyun/api.go | 67 +++++ qiniuyun/bucket_create.go | 16 + qiniuyun/bucket_delete.go | 18 ++ qiniuyun/bucket_get_domain.go | 18 ++ qiniuyun/init.go | 20 ++ qiniuyun/req_img_upload.go | 42 +++ 22 files changed, 1051 insertions(+) create mode 100644 db/offical/db_kuaizhan_short_url.go create mode 100644 db/offical/db_kuaizhan_url.go create mode 100644 db/offical/model/kuaizhan_short_url_money.go create mode 100644 db/offical/model/kuaizhan_short_url_num_list.go create mode 100644 db/offical/model/kuaizhan_short_url_record.go create mode 100644 db/offical/model/kuaizhan_url.go create mode 100644 e/code.go create mode 100644 e/error.go create mode 100644 e/set_cache.go create mode 100644 kuaizhan/kuaizhan_test.go create mode 100644 kuaizhan/short_url.go create mode 100644 kuaizhan/url.go create mode 100644 md/cfg_key.go create mode 100644 md/file.go create mode 100644 qiniuyun/api.go create mode 100644 qiniuyun/bucket_create.go create mode 100644 qiniuyun/bucket_delete.go create mode 100644 qiniuyun/bucket_get_domain.go create mode 100644 qiniuyun/init.go create mode 100644 qiniuyun/req_img_upload.go diff --git a/db/offical/db_kuaizhan_short_url.go b/db/offical/db_kuaizhan_short_url.go new file mode 100644 index 0000000..a42c2d6 --- /dev/null +++ b/db/offical/db_kuaizhan_short_url.go @@ -0,0 +1,15 @@ +package offical + +import ( + "code.fnuoos.com/go_rely_warehouse/zyos_go_third_party_api.git/db/offical/model" + "xorm.io/xorm" +) + +func GetKuaizhanShortUrl(engine *xorm.Engine, uid interface{}) *model.KuaizhanShortUrlNumList { + var data model.KuaizhanShortUrlNumList + get, err := engine.Where("uid=?", uid).Get(&data) + if get == false || err != nil { + return nil + } + return &data +} diff --git a/db/offical/db_kuaizhan_url.go b/db/offical/db_kuaizhan_url.go new file mode 100644 index 0000000..5847132 --- /dev/null +++ b/db/offical/db_kuaizhan_url.go @@ -0,0 +1,15 @@ +package offical + +import ( + "code.fnuoos.com/go_rely_warehouse/zyos_go_third_party_api.git/db/offical/model" + "xorm.io/xorm" +) + +func GetKuaizhanUrl(engine *xorm.Engine, uid interface{}) *model.KuaizhanUrl { + var data model.KuaizhanUrl + get, err := engine.Where("uid=?", uid).Get(&data) + if get == false || err != nil { + return nil + } + return &data +} diff --git a/db/offical/model/kuaizhan_short_url_money.go b/db/offical/model/kuaizhan_short_url_money.go new file mode 100644 index 0000000..e86d7dd --- /dev/null +++ b/db/offical/model/kuaizhan_short_url_money.go @@ -0,0 +1,11 @@ +package model + +type KuaizhanShortUrlMoney struct { + Id int `json:"id" xorm:"not null pk autoincr INT(11)"` + Money float64 `json:"money" xorm:"default 0.00 comment('金额') DOUBLE(11,2)"` + Num int `json:"num" xorm:"default 0 comment('短信条数') INT(11)"` + Hide int `json:"hide" xorm:"default 0 comment('0否 1是') INT(1)"` + Sort int `json:"sort" xorm:"default 0 comment('排序') INT(11)"` + UpdateTime int `json:"update_time" xorm:"default 0 comment('修改时间') INT(11)"` + Time int `json:"time" xorm:"default 0 comment('创建时间') INT(11)"` +} diff --git a/db/offical/model/kuaizhan_short_url_num_list.go b/db/offical/model/kuaizhan_short_url_num_list.go new file mode 100644 index 0000000..e25e17a --- /dev/null +++ b/db/offical/model/kuaizhan_short_url_num_list.go @@ -0,0 +1,7 @@ +package model + +type KuaizhanShortUrlNumList struct { + Id int `json:"id" xorm:"not null pk autoincr INT(11)"` + Uid int `json:"uid" xorm:"default 0 comment('用户') INT(11)"` + Num int `json:"num" xorm:"default 0 comment('短信条数') INT(11)"` +} diff --git a/db/offical/model/kuaizhan_short_url_record.go b/db/offical/model/kuaizhan_short_url_record.go new file mode 100644 index 0000000..2a9c551 --- /dev/null +++ b/db/offical/model/kuaizhan_short_url_record.go @@ -0,0 +1,27 @@ +package model + +import ( + "time" +) + +type KuaizhanShortUrlRecord struct { + Id int `json:"id" xorm:"not null pk autoincr INT(11)"` + OrdId string `json:"ord_id" xorm:"not null default '' comment('订单id') VARCHAR(100)"` + Uid int `json:"uid" xorm:"not null default 0 comment('主用户id') INT(11)"` + Phone string `json:"phone" xorm:"not null default 0 comment('主账号-手机号码') VARCHAR(255)"` + Nickname string `json:"nickname" xorm:"not null default '' comment('主账号-昵称') VARCHAR(255)"` + Amount string `json:"amount" xorm:"not null default '0' comment('充值金额') VARCHAR(255)"` + CostPrice string `json:"cost_price" xorm:"not null default '0' comment('付费价格') VARCHAR(255)"` + Balance string `json:"balance" xorm:"not null default '0' comment('当前余额(充值完当前余额)') VARCHAR(255)"` + PayWay int `json:"pay_way" xorm:"not null default 1 comment('支付方式(1:支付宝 2:微信 3:余额)') TINYINT(1)"` + State int `json:"state" xorm:"not null default 0 comment('状态(0:待付款 1:已付款 2:付款失败)') TINYINT(2)"` + Memo string `json:"memo" xorm:"not null default '' comment('备注') VARCHAR(255)"` + CreateAt time.Time `json:"create_at" xorm:"not null default CURRENT_TIMESTAMP comment('创建时间') DATETIME"` + UpdateAt time.Time `json:"update_at" xorm:"default CURRENT_TIMESTAMP comment('更新时间') DATETIME"` + TradeNo string `json:"trade_no" xorm:"not null default '' comment('支付平台(支付宝/微信)订单号') VARCHAR(100)"` + Type int `json:"type" xorm:"default 0 comment('0收入 1支出') INT(1)"` + OrdType string `json:"ord_type" xorm:"comment('订单类型') VARCHAR(255)"` + SubUid int `json:"sub_uid" xorm:"default 0 INT(11)"` + Fee string `json:"fee" xorm:"VARCHAR(255)"` + Ext string `json:"ext" xorm:"TEXT"` +} diff --git a/db/offical/model/kuaizhan_url.go b/db/offical/model/kuaizhan_url.go new file mode 100644 index 0000000..a32b633 --- /dev/null +++ b/db/offical/model/kuaizhan_url.go @@ -0,0 +1,9 @@ +package model + +import "time" + +type KuaizhanUrl struct { + Id int `json:"id" xorm:"not null pk autoincr INT(11)"` + Uid int `json:"uid" xorm:"default 0 comment('用户') INT(11)"` + EndTime time.Time `json:"end_time" xorm:"not null default '' comment('') DATETIME"` +} diff --git a/e/code.go b/e/code.go new file mode 100644 index 0000000..6bebf2b --- /dev/null +++ b/e/code.go @@ -0,0 +1,244 @@ +package e + +const ( + // 200 因为部分第三方接口不能返回错误头,因此在此定义部分错误 + ERR_FILE_SAVE = 200001 + // 400 系列 + ERR_BAD_REQUEST = 400000 + ERR_INVALID_ARGS = 400001 + ERR_API_RESPONSE = 400002 + ERR_NO_DATA = 400003 + ERR_MOBILE_NIL = 400004 + ERR_MOBILE_MATH = 400005 + ERR_FILE_EXT = 400006 + ERR_FILE_MAX_SIZE = 400007 + ERR_SIGN = 400008 + ERR_PASSWORD_MATH = 400009 + ERR_PROVIDER_RESPONSE = 400010 + ERR_AES_ENCODE = 400011 + ERR_ADMIN_API = 400012 + ERR_QINIUAPI_RESPONSE = 400013 + ERR_URL_TURNCHAIN = 400014 + + // 401 未授权 + ERR_UNAUTHORIZED = 401000 + ERR_NOT_AUTH = 401001 + ERR_SMS_AUTH = 401002 + ERR_TOKEN_AUTH = 401003 + ERR_TOKEN_FORMAT = 401004 + ERR_TOKEN_GEN = 401005 + // 403 禁止 + ERR_FORBIDEN = 403000 + ERR_PLATFORM = 403001 + ERR_MOBILE_EXIST = 403002 + ERR_USER_NO_EXIST = 403003 + ERR_MOBILE_NO_EXIST = 403004 + ERR_FORBIDEN_VALID = 403005 + ERR_RELATE_ERR = 403006 + ERR_REPEAT_RELATE = 403007 + ERR_MOB_FORBIDEN = 403008 + ERR_MOB_SMS_NO_AVA = 403009 + ERR_USER_IS_REG = 403010 + ERR_MASTER_ID = 403011 + ERR_CASH_OUT_TIME = 403012 + ERR_CASH_OUT_FEE = 403013 + ERR_CASH_OUT_USER_NOT_FOUND = 403014 + ERR_CASH_OUT_FAIL = 403015 + ERR_CASH_OUT_TIMES = 403016 + ERR_CASH_OUT_MINI = 403017 + ERR_CASH_OUT_MUT = 403018 + ERR_CASH_OUT_NOT_DECIMAL = 403019 + ERR_CASH_OUT_NOT_DAY_AVA = 403020 + ERR_USER_LEVEL_PAY_CHECK_TASK_NO_DONE = 403021 + ERR_USER_LEVEL_PAY_CHECK_NO_CROSS = 403022 + ERR_USER_LEVEL_ORD_EXP = 403023 + ERR_IS_BIND_THIRDPARTY = 403024 + ERR_USER_LEVEL_UPDATE_CHECK_TASK_NO_DONE = 403025 + ERR_USER_LEVEL_UPDATE_CHECK_NOT_FOUND_ORDER = 403026 + ERR_USER_LEVEL_UPDATE_REPEAT = 403027 + ERR_USER_NO_ACTIVE = 403028 + ERR_USER_IS_BAN = 403029 + ERR_ALIPAY_SETTING = 403030 + ERR_ALIPAY_ORDERTYPE = 403031 + ERR_CLIPBOARD_UNSUP = 403032 + ERR_SYSUNION_CONFIG = 403033 + ERR_WECAHT_MINI = 403034 + ERR_WECAHT_MINI_CACHE = 403035 + ERR_WECAHT_MINI_DECODE = 403036 + ERR_WECHAT_MINI_ACCESSTOKEN = 403037 + ERR_CURRENT_VIP_LEVEL_AUDITING = 403038 + ERR_LEVEL_RENEW_SHOULD_KEEP_CURRENT = 403039 + ERR_LEVEL_UPGRADE_APPLY_AUDITTING = 403040 + ERR_LEVEL_TASK_PAY_TYPE = 403041 + ERR_BALANCE_NOT_ENOUGH = 403042 + ERR_ADMIN_PUSH = 403043 + ERR_PLAN = 403044 + ERR_MOB_CONFIG = 403045 + ERR_BAlANCE_PAY_ORDERTYPE = 403046 + ERR_PHONE_EXISTED = 403047 + ERR_NOT_RESULT = 403048 + ERR_REVIEW = 403049 + ERR_USER_LEVEL_HAS_PAID = 403050 + ERR_USER_BIND_OWN = 403051 + ERR_PARENTUID_ERR = 403052 + ERR_USER_DEL = 403053 + ERR_SEARCH_ERR = 403054 + ERR_LEVEL_REACH_TOP = 403055 + ERR_USER_CHECK_ERR = 403056 + ERR_PASSWORD_ERR = 403057 + ERR_IS_BIND_PDD_ERR = 403058 + ERR_MOB_SMS_NO_SAME = 403059 + ERR_MOB_SMS_NO_EXISTS = 403060 + // 404 + ERR_USER_NOTFOUND = 404001 + ERR_SUP_NOTFOUND = 404002 + ERR_LEVEL_MAP = 404003 + ERR_MOD_NOTFOUND = 404004 + ERR_CLIPBOARD_PARSE = 404005 + ERR_NOT_FAN = 404006 + ERR_USER_LEVEL = 404007 + ERR_LACK_PAY_CFG = 404008 + ERR_NOT_LEVEL_TASK = 404009 + ERR_ITEM_NOT_FOUND = 404012 + ERR_WX_CHECKFILE_NOTFOUND = 404011 + + // 429 请求频繁 + ERR_TOO_MANY_REQUESTS = 429000 + // 500 系列 + ERR = 500000 + ERR_UNMARSHAL = 500001 + ERR_UNKNOWN = 500002 + ERR_SMS = 500003 + ERR_ARKID_REGISTER = 500004 + ERR_ARKID_WHITELIST = 500005 + ERR_ARKID_LOGIN = 500006 + ERR_CFG = 500007 + ERR_DB_ORM = 500008 + ERR_CFG_CACHE = 500009 + ERR_ZHIMENG_CONVERT_ERR = 500010 + ERR_ALIPAY_ERR = 500011 + ERR_ALIPAY_ORDER_ERR = 500012 + ERR_PAY_ERR = 500013 + ERR_IS_BIND_THIRDOTHER = 500014 + ERR_IS_BIND_THIRDOTHERWECHAT = 500015 + ERR_INIT_RABBITMQ = 500016 +) + +var MsgFlags = map[int]string{ + // 200 + ERR_FILE_SAVE: "文件保存失败", + // 400 + ERR_BAD_REQUEST: "请求失败..", + ERR_INVALID_ARGS: "请求参数错误", + ERR_API_RESPONSE: "API错误", + ERR_QINIUAPI_RESPONSE: "七牛请求API错误", + ERR_URL_TURNCHAIN: "转链失败", + ERR_NO_DATA: "暂无数据", + ERR_MOBILE_NIL: "电话号码不能为空", + ERR_MOBILE_MATH: "电话号码输入有误", + ERR_FILE_MAX_SIZE: "文件上传大小超限", + ERR_FILE_EXT: "文件类型不支持", + ERR_SIGN: "签名校验失败", + ERR_PROVIDER_RESPONSE: "提供商接口错误", + ERR_AES_ENCODE: "加解密错误", + ERR_ADMIN_API: "后台接口请求失败", + // 401 + ERR_NOT_AUTH: "请登录后操作", + ERR_SMS_AUTH: "验证码过期或无效", + ERR_UNAUTHORIZED: "验证用户失败", + ERR_TOKEN_FORMAT: "Token格式不对", + ERR_TOKEN_GEN: "生成Token失败", + // 403 + ERR_FORBIDEN: "禁止访问", + ERR_PLATFORM: "平台不支持", + ERR_MOBILE_EXIST: "该号码已注册过", + ERR_USER_NO_EXIST: "用户没有注册或账号密码不正确", + ERR_PASSWORD_ERR: "输入两次密码不一致", + ERR_RELATE_ERR: "推荐人不能是自己的粉丝", + ERR_PARENTUID_ERR: "推荐人不存在", + ERR_TOKEN_AUTH: "登录信息失效,请重新登录", + ERR_MOB_SMS_NO_AVA: "短信余额不足", + ERR_MOB_SMS_NO_SAME: "验证码不一致", + ERR_MOB_SMS_NO_EXISTS: "验证码已失效", + ERR_USER_IS_REG: "用户已注册", + ERR_MASTER_ID: "找不到对应站长的数据库", + ERR_CASH_OUT_TIME: "非可提现时间段", + ERR_CASH_OUT_USER_NOT_FOUND: "收款账号不存在", + ERR_CASH_OUT_FAIL: "提现失败", + ERR_CASH_OUT_FEE: "提现金额必须大于手续费", + ERR_CASH_OUT_TIMES: "当日提现次数已达上线", + ERR_CASH_OUT_MINI: "申请提现金额未达到最低金额要求", + ERR_CASH_OUT_MUT: "申请提现金额未达到整数倍要求", + ERR_CASH_OUT_NOT_DECIMAL: "提现申请金额只能是整数", + ERR_CASH_OUT_NOT_DAY_AVA: "不在可提现日期范围内", + ERR_USER_LEVEL_PAY_CHECK_TASK_NO_DONE: "请先完成其他任务", + ERR_USER_LEVEL_PAY_CHECK_NO_CROSS: "无法跨越升级", + ERR_USER_LEVEL_ORD_EXP: "付费订单已失效", + ERR_IS_BIND_THIRDPARTY: "该用户已经绑定了", + ERR_IS_BIND_THIRDOTHER: "该账号已经被绑定了", + ERR_IS_BIND_THIRDOTHERWECHAT: "该账号已经绑定了其他微信账号", + ERR_USER_LEVEL_UPDATE_CHECK_TASK_NO_DONE: "请完成指定任务", + ERR_USER_LEVEL_UPDATE_CHECK_NOT_FOUND_ORDER: "没有找到对应的订单", + ERR_USER_LEVEL_UPDATE_REPEAT: "不允许重复升级", + ERR_USER_NO_ACTIVE: "账户没激活", + ERR_USER_IS_BAN: "账户已被冻结", + ERR_SYSUNION_CONFIG: "联盟设置错误,请检查配置", + ERR_WECAHT_MINI: "小程序响应错误,请检查小程序配置", + ERR_WECAHT_MINI_CACHE: "获取小程序缓存失败", + ERR_WECAHT_MINI_DECODE: "小程序解密失败", + ERR_WECHAT_MINI_ACCESSTOKEN: "无法获取accesstoekn", + ERR_CURRENT_VIP_LEVEL_AUDITING: "当前等级正在审核中", + ERR_LEVEL_RENEW_SHOULD_KEEP_CURRENT: "续费只能在当前等级续费", + ERR_LEVEL_UPGRADE_APPLY_AUDITTING: "已有申请正在审核中，暂时不能申请", + ERR_LEVEL_TASK_PAY_TYPE: "任务付费类型错误", + ERR_BALANCE_NOT_ENOUGH: "余额不足", + ERR_ADMIN_PUSH: "后台MOB推送错误", + ERR_PLAN: "分拥方案出错", + ERR_MOB_CONFIG: "Mob 配置错误", + ERR_BAlANCE_PAY_ORDERTYPE: "无效余额支付订单类型", + ERR_PHONE_EXISTED: "手机号码已存在", + ERR_NOT_RESULT: "已加载完毕", + ERR_REVIEW: "审核模板错误", + ERR_USER_LEVEL_HAS_PAID: "该等级已经付过款", + ERR_IS_BIND_PDD_ERR: "获取PDD绑定信息失败", + // 404 + ERR_USER_NOTFOUND: "用户不存在", + ERR_USER_DEL: "账号被删除,如有疑问请联系客服", + ERR_SUP_NOTFOUND: "上级用户不存在", + ERR_LEVEL_MAP: "无等级映射关系", + ERR_MOD_NOTFOUND: "没有找到对应模块", + ERR_CLIPBOARD_PARSE: "无法解析剪切板内容", + ERR_NOT_FAN: "没有粉丝", + ERR_CLIPBOARD_UNSUP: "不支持该平台", + ERR_USER_LEVEL: "该等级已不存在", + ERR_LACK_PAY_CFG: "支付配置不完整", + ERR_NOT_LEVEL_TASK: "等级任务查找错误", + ERR_ITEM_NOT_FOUND: "找不到对应商品", + ERR_WX_CHECKFILE_NOTFOUND: "找不到微信校验文件", + ERR_USER_BIND_OWN: "不能填写自己的邀请码", + // 429 + ERR_TOO_MANY_REQUESTS: "请求频繁,请稍后重试", + // 500 内部错误 + ERR: "接口错误", + ERR_SMS: "短信发送出错", + ERR_CFG: "服务器配置错误", + ERR_UNMARSHAL: "JSON解码错误", + ERR_UNKNOWN: "未知错误", + ERR_ARKID_LOGIN: "登录失败", + ERR_MOBILE_NO_EXIST: "该用户未设定手机号", + ERR_FORBIDEN_VALID: "验证码错误", + ERR_CFG_CACHE: "获取配置缓存失败", + ERR_DB_ORM: "数据操作失败", + ERR_REPEAT_RELATE: "重复关联", + ERR_ZHIMENG_CONVERT_ERR: "智盟转链失败", + ERR_MOB_FORBIDEN: "Mob调用失败", + ERR_ALIPAY_ERR: "支付宝参数错误", + ERR_ALIPAY_SETTING: "请在后台正确配置支付宝", + ERR_ALIPAY_ORDERTYPE: "无效支付宝订单类型", + ERR_ALIPAY_ORDER_ERR: "订单创建错误", + ERR_PAY_ERR: "未找到支付方式", + ERR_SEARCH_ERR: "暂无该分类商品", + ERR_LEVEL_REACH_TOP: "已经是最高等级", + ERR_USER_CHECK_ERR: "校验失败", + ERR_INIT_RABBITMQ: "连接mq失败", +} diff --git a/e/error.go b/e/error.go new file mode 100644 index 0000000..2564174 --- /dev/null +++ b/e/error.go @@ -0,0 +1,72 @@ +package e + +import ( + "fmt" + "path" + "runtime" +) + +type E struct { + Code int // 错误码 + msg string // 报错代码 + st string // 堆栈信息 +} + +func NewErrCode(code int) error { + if msg, ok := MsgFlags[code]; ok { + return E{code, msg, stack(3)} + } + return E{ERR_UNKNOWN, "unknown", stack(3)} +} + +func NewErr(code int, msg string) error { + return E{code, msg, stack(3)} +} + +func NewErrf(code int, msg string, args ...interface{}) error { + return E{code, fmt.Sprintf(msg, args), stack(3)} +} + +func (e E) Error() string { + return e.msg +} + +func stack(skip int) string { + stk := make([]uintptr, 32) + str := "" + l := runtime.Callers(skip, stk[:]) + for i := 0; i < l; i++ { + f := runtime.FuncForPC(stk[i]) + name := f.Name() + file, line := f.FileLine(stk[i]) + str += fmt.Sprintf("\n%-30s[%s:%d]", name, path.Base(file), line) + } + return str +} + +// ErrorIsAccountBan is 检查这个账号是否被禁用的错误 +func ErrorIsAccountBan(e error) bool { + err, ok := e.(E) + if ok && err.Code == 403029 { + return true + } + return false +} + +// ErrorIsAccountNoActive is 检查这个账号是否被禁用的错误 +func ErrorIsAccountNoActive(e error) bool { + err, ok := e.(E) + if ok && err.Code == 403028 { + return true + } + return false +} + +// ErrorIsUserDel is 检查这个账号是否被删除 +func ErrorIsUserDel(e error) bool { + err, ok := e.(E) + if ok && err.Code == 403053 { + return true + } + return false +} diff --git a/e/set_cache.go b/e/set_cache.go new file mode 100644 index 0000000..45337a1 --- /dev/null +++ b/e/set_cache.go @@ -0,0 +1,8 @@ +package e + +func SetCache(cacheTime int64) map[string]interface{} { + if cacheTime == 0 { + return map[string]interface{}{"cache_time": cacheTime} + } + return map[string]interface{}{"cache_time": cacheTime} +} diff --git a/go.mod b/go.mod index 124158c..dd9b620 100644 --- a/go.mod +++ b/go.mod @@ -15,6 +15,7 @@ require ( github.com/nilorg/sdk v0.0.0-20221104025912-4b6ccb7004d8 github.com/onsi/ginkgo v1.16.5 // indirect github.com/onsi/gomega v1.19.0 // indirect + github.com/qiniu/api.v7/v7 v7.8.2 github.com/shopspring/decimal v1.2.0 github.com/syyongx/php2go v0.9.7 github.com/tidwall/gjson v1.14.1 diff --git a/go.sum b/go.sum index 4dc11e6..817791e 100644 --- a/go.sum +++ b/go.sum @@ -134,6 +134,8 @@ github.com/google/renameio v0.1.0/go.mod h1:KWCgfxg9yswjAJkECMjeO8J8rahYeXnNhOm4 github.com/google/uuid v1.0.0/go.mod h1:TIyPZe4MgqvfeYDBFedMoGGpEw/LqOeaOT+nhxU+yHo= github.com/google/uuid v1.3.0 h1:t6JiXgmwXMjEs8VusXIJk2BXHsn+wx8BZdTaoZ5fu7I= github.com/google/uuid v1.3.0/go.mod h1:TIyPZe4MgqvfeYDBFedMoGGpEw/LqOeaOT+nhxU+yHo= +github.com/gookit/color v1.3.6 h1:Rgbazd4JO5AgSTVGS3o0nvaSdwdrS8bzvIXwtK6OiMk= +github.com/gookit/color v1.3.6/go.mod h1:R3ogXq2B9rTbXoSHJ1HyUVAZ3poOJHpd9nQmyGZsfvQ= github.com/gopherjs/gopherjs v0.0.0-20181017120253-0766667cb4d1/go.mod h1:wJfORRmW1u3UXTncJ5qlYoELFm8eSnnEO6hX4iZ3EWY= github.com/gorilla/context v1.1.1/go.mod h1:kBGZzfjB9CEq2AlWe17Uuf7NDRt0dE0s8S51q0aT7Yg= github.com/gorilla/mux v1.6.2/go.mod h1:1lud6UwP+6orDFRuTfBEV8e9/aOM/c4fVVCaMa2zaAs= @@ -349,6 +351,8 @@ github.com/prometheus/procfs v0.0.0-20181005140218-185b4288413d/go.mod h1:c3At6R github.com/prometheus/procfs v0.0.0-20190117184657-bf6a532e95b1/go.mod h1:c3At6R/oaqEKCNdg8wHV1ftS6bRYblBhIjjI8uT2IGk= github.com/prometheus/procfs v0.0.2/go.mod h1:TjEm7ze935MbeOT/UhFTIMYKhuLP4wbCsTZCD3I8kEA= github.com/prometheus/procfs v0.0.8/go.mod h1:7Qr8sr6344vo1JqZ6HhLceV9o3AJ1Ff+GxbHq6oeK9A= +github.com/qiniu/api.v7/v7 v7.8.2 h1:f08kI0MmsJNzK4sUS8bG3HDH67ktwd/ji23Gkiy2ra4= +github.com/qiniu/api.v7/v7 v7.8.2/go.mod h1:FPsIqxh1Ym3X01sANE5ZwXfLZSWoCUp5+jNI8cLo3l0= github.com/rcrowley/go-metrics v0.0.0-20181016184325-3113b8401b8a/go.mod h1:bCqnVzQkZxMG4s8nGwiZ5l3QUCyqpo9Y+/ZMZ9VjZe4= github.com/remyoudompheng/bigfft v0.0.0-20200410134404-eec4a21b6bb0 h1:OdAsTTz6OkFY5QxjkYwrChwuRruF69c169dPK26NUlk= github.com/remyoudompheng/bigfft v0.0.0-20200410134404-eec4a21b6bb0/go.mod h1:qqbHyh8v60DhA7CoWK5oRCqLrMHRGoxYCSS9EjAz6Eo= @@ -481,6 +485,8 @@ golang.org/x/sync v0.0.0-20190227155943-e225da77a7e6/go.mod h1:RxMgew5VJxzue5/jJ golang.org/x/sync v0.0.0-20190423024810-112230192c58/go.mod h1:RxMgew5VJxzue5/jJTE5uejpjVlOe/izrB70Jof72aM= golang.org/x/sync v0.0.0-20190911185100-cd5d95a43a6e/go.mod h1:RxMgew5VJxzue5/jJTE5uejpjVlOe/izrB70Jof72aM= golang.org/x/sync v0.0.0-20201020160332-67f06af15bc9/go.mod h1:RxMgew5VJxzue5/jJTE5uejpjVlOe/izrB70Jof72aM= +golang.org/x/sync v0.0.0-20201207232520-09787c993a3a h1:DcqTD9SDLc+1P/r1EmRBwnVsrOwW+kk2vWf9n+1sGhs= +golang.org/x/sync v0.0.0-20201207232520-09787c993a3a/go.mod h1:RxMgew5VJxzue5/jJTE5uejpjVlOe/izrB70Jof72aM= golang.org/x/sys v0.0.0-20180823144017-11551d06cbcc/go.mod h1:STP8DvDyc/dI5b8T5hshtkjS+E42TnysNCUPdjciGhY= golang.org/x/sys v0.0.0-20180830151530-49385e6e1522/go.mod h1:STP8DvDyc/dI5b8T5hshtkjS+E42TnysNCUPdjciGhY= golang.org/x/sys v0.0.0-20180905080454-ebe1bf3edb33/go.mod h1:STP8DvDyc/dI5b8T5hshtkjS+E42TnysNCUPdjciGhY= diff --git a/kuaizhan/kuaizhan_test.go b/kuaizhan/kuaizhan_test.go new file mode 100644 index 0000000..3adc936 --- /dev/null +++ b/kuaizhan/kuaizhan_test.go @@ -0,0 +1,9 @@ +package kuaizhan + +import ( + "testing" +) + +func TestKuaishou(t *testing.T) { + GetKuaizhanUrl("https://www.1234la.com/url/4444.html") +} diff --git a/kuaizhan/short_url.go b/kuaizhan/short_url.go new file mode 100644 index 0000000..34ee82f --- /dev/null +++ b/kuaizhan/short_url.go @@ -0,0 +1,84 @@ +package kuaizhan + +import ( + "code.fnuoos.com/go_rely_warehouse/zyos_go_third_party_api.git/db" + "code.fnuoos.com/go_rely_warehouse/zyos_go_third_party_api.git/db/offical" + "code.fnuoos.com/go_rely_warehouse/zyos_go_third_party_api.git/db/offical/model" + zhios_third_party_utils "code.fnuoos.com/go_rely_warehouse/zyos_go_third_party_api.git/utils" + "fmt" + "strings" + "time" + "xorm.io/xorm" +) + +func ShortUrlSend(engine *xorm.Engine, uid string, url string) string { + num := KuaizhanShortUrlNumGetSmsNum(engine, uid) + if num <= 0 { + return url + } + if strings.Contains(url, "kuaizhan") { + + } + return url +} +func GetKuaizhanUrl(url string) { + method := "https://cloud.kuaizhan.com/api/v1/tbk/genKzShortUrl" + appKey := "7w2N8ohpFJxW" + appSecret := "11f7fa9a66c75229aca909b6c171cf84fa747ec4" + arg := map[string]string{ + "appKey": appKey, + "url": url, + } + str := "appKey" + appKey + "url" + url + arg["sign"] = zhios_third_party_utils.Md5(appSecret + str + appSecret) + post, err := zhios_third_party_utils.CurlPost(method, arg, nil) + fmt.Println(string(post)) + fmt.Println(err) +} + +// 数量 +func KuaizhanShortUrlNumGetSmsNum(engine *xorm.Engine, uid interface{}) int { + numData := offical.GetKuaizhanShortUrl(engine, uid) + num := 0 + if numData != nil { + num = numData.Num + } + if num < 0 { + num = 0 + } + return num +} + +// 发送 +func KuaizhanShortUrlSend(engine *xorm.Engine, args map[string]interface{}) error { + num := KuaizhanShortUrlNumGetSmsNum(engine, args["uid"]) + //存入记录 + ext := map[string]interface{}{ + "post": args, + } + var record = model.KuaizhanShortUrlRecord{ + OrdId: "", + Uid: int(zhios_third_party_utils.AnyToInt64(args["uid"])), + Amount: "1", + CostPrice: "", + Balance: zhios_third_party_utils.IntToStr(num - 1), + PayWay: 0, + State: 1, + Memo: "短链", + CreateAt: time.Now(), + UpdateAt: time.Now(), + TradeNo: "", + Type: 1, + OrdType: "buy", + Fee: "", + Ext: zhios_third_party_utils.SerializeStr(ext), + } + engine.InsertOne(&record) + sql := `UPDATE kuaizhan_short_url_num_list set num=num-%d WHERE uid=%s ;` + sql = fmt.Sprintf(sql, 1, args["uid"]) + fmt.Println(sql) + nativeString, err := db.QueryNativeString(engine, sql) + fmt.Println(nativeString) + fmt.Println(err) + return nil +} diff --git a/kuaizhan/url.go b/kuaizhan/url.go new file mode 100644 index 0000000..9329a0e --- /dev/null +++ b/kuaizhan/url.go @@ -0,0 +1,21 @@ +package kuaizhan + +import ( + "code.fnuoos.com/go_rely_warehouse/zyos_go_third_party_api.git/db/offical" + "github.com/syyongx/php2go" + "time" + "xorm.io/xorm" +) + +func KuaizhanUrl(engine *xorm.Engine, args map[string]string) string { + kuaizhan_host := offical.SysCfgByKeyStr(engine, "kuaizhan_host") + if kuaizhan_host == "" { + return "" + } + numData := offical.GetKuaizhanUrl(engine, args["mid"]) + if numData.EndTime.Unix() <= time.Now().Unix() { + return "" + } + kuaizhan_host += "?code=" + php2go.URLEncode(php2go.Base64Encode(args["url"])) + return kuaizhan_host +} diff --git a/md/cfg_key.go b/md/cfg_key.go new file mode 100644 index 0000000..f234df5 --- /dev/null +++ b/md/cfg_key.go @@ -0,0 +1,279 @@ +package md + +// 获取用户的缓存key +const ( + KEY_SYS_CFG_CACHE = "sys_cfg_cache" + FunctionPermissionCfgCacheKey = "%s:function_permission_cfg" + // 文件缓存的key + KEY_CFG_FILE_PVD = "file_provider" // 文件供应商 + KEY_CFG_FILE_BUCKET = "file_bucket" + KEY_CFG_FILE_REGION = "file_bucket_region" + KEY_CFG_FILE_HOST = "file_bucket_host" + KEY_CFG_FILE_SCHEME = "file_bucket_scheme" + KEY_CFG_FILE_AK = "file_access_key" + KEY_CFG_FILE_SK = "file_secret_key" + KEY_CFG_FILE_MAX_SIZE = "file_user_upload_max_size" + KEY_CFG_FILE_EXT = "file_ext" + KEY_CFG_FILE_AVATAR_THUMBNAIL = "file_avatar_thumbnail" // 默认头像缩略图参数,宽高120px,格式webp. + // 智盟 + KEY_CFG_ZM_JD_SITE_ID = "third_zm_jd_site_id" // 智盟京东联盟id + KEY_CFG_ZM_SMS_AK = "third_zm_sms_ak" + KEY_CFG_ZM_SMS_SK = "third_zm_sms_sk" + KEY_CFG_APP_NAME = "app_name" + + KEY_CFG_WHITELIST = "api_cfg_whitelist" // API允许的访问的设置白名单 + + // 淘宝 + KEY_CFG_TB_AUTH_AK = "third_taobao_auth_ak" + KEY_CFG_TB_AUTH_SK = "third_taobao_auth_sk" + KEY_CFG_TB_INVITER_CODE = "third_taobao_auth_inviter_code" + KEY_CFG_TB_AK = "third_taobao_ak" + KEY_CFG_TB_SK = "third_taobao_sk" + KEY_CFG_TB_PID = "third_taobao_pid" // 淘宝推广ID,如:mm_123_456_789,123是联盟ID,456是site_id,789是adzone_id + KEY_CFG_TB_SID = "third_taobao_sid" // 淘宝session id ,又称access_token + + // 苏宁 + KEY_CFG_SN_AK = "third_suning_ak" + KEY_CFG_SN_SK = "third_suning_sk" + + KEY_CFG_JD_AK = "" + KEY_CFG_JD_SK = "" + + KEY_CFG_KL_AK = "third_kaola_ak" + KEY_CFG_KL_SK = "third_kaola_sk" + + KEY_CFG_VIP_AK = "" + KEY_CFG_VIP_SK = "" + + // 自动任务配置 + KEY_CFG_CRON_TB = "cron_order_taobao" + KEY_CFG_CRON_TBSETTLEORDER = "cron_order_taobao_settle_order" + KEY_CFG_CRON_JD = "cron_order_jd" + KEY_CFG_CRON_PDD = "cron_order_pdd" + KEY_CFG_CRON_PDD_SUCC = "cron_order_pdd_succ" + KEY_CFG_CRON_PDDBYCREATETIME = "cron_order_pdd_by_create_time" + KEY_CFG_CRON_PDDBYLOOPTIME = "cron_order_pdd_by_loop_time" + KEY_CFG_CRON_PDDBYLOOPMONTHTIME = "cron_order_pdd_by_loop_month_ago_time" + KEY_CFG_CRON_JDBYCREATETIME = "cron_order_jd_by_create_time" + KEY_CFG_CRON_JDBYSUCCESS = "cron_order_jd_by_success" + KEY_CFG_CRON_JDFAILBYCREATETIME = "cron_order_jd_fail_by_create_time" + KEY_CFG_CRON_PDDBYAGOTIME = "cron_order_pdd_by_ago_time" + KEY_CFG_CRON_PDDBYSTATUS = "cron_order_pdd_by_status" + KEY_CFG_CRON_PDDBYSTATUSSUCCESS = "cron_order_pdd_by_status_success" + KEY_CFG_CRON_PDDBYSTATUSFAIL = "cron_order_pdd_by_status_fail" + KEY_CFG_CRON_JDBYSTATUS = "cron_order_jd_by_status" + KEY_CFG_CRON_TBBYAGOTIME = "cron_order_tb_by_ago_time" + KEY_CFG_CRON_TBBYPAY = "cron_order_tb_by_pay" + KEY_CFG_CRON_TB12 = "cron_order_tb12" + KEY_CFG_CRON_TB13 = "cron_order_tb13" + KEY_CFG_CRON_TB3 = "cron_order_tb3" + KEY_CFG_CRON_TB14 = "cron_order_tb14" + + KEY_CFG_CRON_PDDREFUND = "cron_order_pdd_refund" + KEY_CFG_CRON_TBREFUND = "cron_order_tb_refund" + KEY_CFG_CRON_WPHREFUND = "cron_order_wph_refund" + KEY_CFG_CRON_JDREFUND = "cron_order_jd_refund" + KEY_CFG_CRON_SN = "cron_order_suning" + KEY_CFG_CRON_VIP = "cron_order_vip" + KEY_CFG_CRON_KL = "cron_order_kaola" + KEY_CFG_CRON_DUOMAI = "cron_order_duomai" + KEY_CFG_CRON_HIS = "cron_order_his" // 迁移到历史订单 + KEY_CFG_CRON_SETTLE = "cron_order_settle" //结算 + KEY_CFG_CRON_FREE_SETTLE = "cron_order_free_settle" //结算 + KEY_CFG_CRON_SECOND_FREE_SETTLE = "cron_order_second_free_settle" + KEY_CFG_CRON_THIRD_FREE_SETTLE = "cron_order_third_free_settle" + KEY_CFG_CRON_ACQUISTION_SETTLE = "cron_acquistion_settle" // 拉新结算 + KEY_CFG_CRON_NEW_ACQUISTION_SETTLE = "cron_new_acquistion_settle" // 拉新结算 + KEY_CFG_CRON_PUBLISHER = "cron_taobao_publisher" // 跟踪淘宝备案信息绑定会员运营id 针对小程序 + KEY_CFG_CRON_AUTO_UN_FREEZE = "cron_auto_un_freeze" + KEY_CFG_CRON_MEITUAN = "cron_order_meituan_fxlm" //美团 + KEY_CFG_CRON_MEITUANLM = "cron_order_meituan_lm" //美团联盟 + KEY_CFG_CRON_MEITUANLM_START = "cron_order_meituan_lm_start" //美团联盟 + KEY_CFG_CRON_ORDER_SUCCESS_CHECK = "cron_order_success_check" + KEY_CFG_CRON_MEITUAN_START = "cron_order_meituan_start" //美团联盟 + KEY_CFG_CRON_STARBUCKS = "cron_order_starbucks" //海威星巴克 + KEY_CFG_CRON_HWMOVIE = "cron_order_hw_movie" //海威电影票 + KEY_CFG_CRON_MCDONALD = "cron_order_mcdonald" //海威麦当劳 + KEY_CFG_CRON_NAYUKI = "cron_order_nayuki" //海威奈雪 + KEY_CFG_CRON_BURGERKING = "cron_order_burger_king" //海威汉堡王 + KEY_CFG_CRON_HEYTEA = "cron_order_heytea" //海威喜茶 + KEY_CFG_CRON_TIKTOKLIFE = "cron_order_tik_tok_life" // + KEY_CFG_CRON_FAST_REFUND = "cron_order_fast_refund" + KEY_CFG_CRON_CHECK_GUIDE_STORE_ORDER = "cron_check_guide_store_order" + KEY_CFG_CRON_CHECK_BUCKLE_ORDER = "cron_check_buckle_order" + KEY_CFG_CRON_BUCKLE = "cron_order_buckle" + KEY_CFG_CRON_FAST_SUCCESS = "cron_order_fast_success" + KEY_CFG_CRON_PIZZA = "cron_order_pizza" //海威 + KEY_CFG_CRON_WALLACE = "cron_order_wallace" //海威 + KEY_CFG_CRON_TOURISM = "cron_order_tourism" //海威 + KEY_CFG_CRON_NEAR = "cron_order_near" //海威 + KEY_CFG_CRON_FLOWERCAKE = "cron_order_flowerCake" //海威 + KEY_CFG_CRON_DELIVERY = "cron_order_delivery" //海威 + KEY_CFG_CRON_TO_KFC = "cron_order_to_kfc" // + KEY_CFG_CRON_PAGODA = "cron_order_pagoda" // + KEY_CFG_CRON_LUCKIN = "cron_order_luckin" // + KEY_CFG_CRON_STATIONMEITUANLM = "cron_order_station_meituan_lm" //站长美团联盟 + KEY_CFG_CRON_MEITUANOFFICIAL = "cron_order_meituan_official" //美团联盟智莺 + KEY_CFG_CRON_OILSTATION = "cron_order_oilstation" //加油 + KEY_CFG_CRON_BRIGHTOILSTATION = "cron_order_bright_oilstation" //加油 + KEY_CFG_CRON_KFC = "cron_order_kfc" //肯德基 + KEY_CFG_CRON_CINEMA = "cron_order_cinema" //电影票 + KEY_CFG_CRON_OilRequest = "cron_order_oilrequest" //加入主动请求抓单 + KEY_CFG_CRON_AGOTB = "cron_order_agotaobao" //n天前的淘宝订单 + KEY_CFG_CRON_CREDIT_CARD = "cron_order_credit_card" + KEY_CFG_CRON_ORDER_STAT = "cron_order_stat" // 订单统计任务 + KEY_CFG_CRON_CARD_UPDATE = "cron_card_update" // 权益卡更新 + KEY_CFG_CRON_USER_LV_UP_SETTLE = "cron_user_lv_up_settle" //会员费订单结算 + KEY_CFG_CRON_DUOYOUORD_SETTLE = "cron_duoyou_settle" //会员费订单结算 + KEY_CFG_CRON_LIANLIAN_SETTLE = "cron_lianlian_settle" //会员费订单结算 + KEY_CFG_CRON_SWIPE_SETTLE = "cron_swipe_settle" + KEY_CFG_CRON_AGGREGATION_RECHARGE_SETTLE = "cron_aggregation_recharge_settle" + KEY_CFG_CRON_ACQUISITION_CONDITION = "cron_acquisition_condition" + KEY_CFG_CRON_ACQUISITION_CONDITION_BY_LV = "cron_acquisition_condition_by_lv" + KEY_CFG_CRON_ACQUISITION_REWARD = "cron_acquisition_reward" + KEY_CFG_CRON_PLAYLET_SETTLE = "cron_playlet_settle" + KEY_CFG_CRON_TIKTOK_AUTH = "cron_tik_tok_auth" + KEY_CFG_CRON_TASKBOX_SETTLE = "cron_task_box_settle" //会员费订单结算 + KEY_CFG_CRON_PRIVILEGE_CARD_SETTLE = "cron_privilege_card_settle" //权益卡订单结算 + KEY_CFG_CRON_CARD_RETURN = "cron_card_return" //权益卡退款 + KEY_CFG_CRON_PUBLISHER_RELATION = "cron_taobao_publisher_relation" //获取淘宝渠道 + KEY_CFG_CRON_PUBLISHER_RELATION_NEW = "cron_taobao_publisher_relation_new" //获取淘宝渠道 + + KEY_CFG_CRON_DTKBRAND = "cron_dtk_brand" //大淘客品牌信息 + KEY_CFG_CRON_PUBLISHER_RELATION_BIND = "cron_taobao_publisher_relation_bind" //获取淘宝渠道绑定 + KEY_CFG_CRON_GOODS_SHELF = "cron_goods_shelf" //商品上下架定时任务 + KEY_CFG_CRON_DIDI_ENERGY = "cron_order_didi_energy" // + KEY_CFG_CRON_T3_CAR = "cron_order_t3_car" // + KEY_CFG_CRON_DIDI_ONLINE_CAR = "cron_order_didi_online_car" // + KEY_CFG_CRON_KING_FLOWER = "cron_order_king_flower" // + KEY_CFG_CRON_DIDI_CHAUFFEUR = "cron_order_didi_chauffeur" // + KEY_CFG_CRON_PLAYLET_ORDER = "cron_order_playlet_order" // + KEY_CFG_CRON_PLAYLET_GOODS = "cron_order_playlet_goods" // + KEY_CFG_CRON_CARD_CHECK_RETURN = "cron_card_check_return" // + KEY_CFG_CRON_CARD_CHECK_UPDATE = "cron_card_check_update" // + KEY_CFG_CRON_DIDI_FREIGHT = "cron_order_didi_freight" // + KEY_CFG_CRON_TB_PUNISH_REFUND = "cron_order_tb_punish_refund" + KEY_CFG_CRON_TIKTOK = "cron_order_tikTok" + KEY_CFG_CRON_ELM = "cron_order_elm" + KEY_CFG_CRON_AUTO_ADD_TIKTOK_GOODS = "cron_order_auto_add_tiktok_goods" + KEY_CFG_CRON_TIKTOKOwn = "cron_order_tikTokOwn" + KEY_CFG_CRON_TIKTOKCsjp = "cron_order_tikTokCsjp" + KEY_CFG_CRON_TIKTOKCsjpLive = "cron_order_tikTokCsjpLive" + KEY_CFG_CRON_TIKTOKOwnCsjp = "cron_order_tikTokOwnCsjp" + KEY_CFG_CRON_TIKTOKOwnCsjpLive = "cron_order_tikTokOwnCsjpLive" + KEY_CFG_CRON_TIKTOKOwnCsjpActivity = "cron_order_tikTokOwnCsjpActivity" + KEY_CFG_CRON_PlayLet_Total = "cron_playlet_total" + KEY_CFG_CRON_TIKTOKOwnCreate = "cron_order_tikTokOwnCreate" + KEY_CFG_CRON_KuaishouOwn = "cron_order_kuaishouOwn" + KEY_CFG_CRON_KuaishouOwnCreate = "cron_order_kuaishouOwnCreate" + KEY_CFG_CRON_TIKTOKOwnACtivity = "cron_order_tikTokOwnActivity" + KEY_CFG_CRON_DUOYOUORD = "cron_order_DouYouOrd" + KEY_CFG_CRON_TASKBOX = "cron_order_TaskBox" + KEY_CFG_CRON_TASKBOXSECOND = "cron_order_TaskBoxSecond" + KEY_CFG_CRON_TIKTOKOwnMixH5 = "cron_order_tikTokOwnMixH5" + + KEY_CFG_CRON_TIKTOKLIVE_UPDATE = "cron_order_tikTokLive_update" + KEY_CFG_CRON_KUAISHOU = "cron_order_kuaishou" + KEY_CFG_CRON_KUAISHOUOFFICIAL = "cron_order_kuaishou_official" + KEY_CFG_CRON_KUAISHOUOFFICIALLive = "cron_order_kuaishou_official_live" + KEY_CFG_CRON_MEITUANFFICIAL = "cron_order_meituan_official" + KEY_CFG_CRON_TIKTOKLIVE = "cron_order_tikTok_live" + KEY_CFG_CRON_TIKTOKLIVEOWN = "cron_order_tikTok_live_own" + KEY_CFG_CRON_TIKTOKACTIVITY = "cron_order_tikTok_activity" + KEY_CFG_CRON_KUAISHOULIVE = "cron_order_kuaishou_live" + + ZhimengCronPlayletVideoOrder = "cron_playlet_video_order" //短剧订单 + ZhimengCronPlayletAdvOrder = "cron_playlet_adv_order" //短剧广告订单 + ZhimengCronPlayletVideoOrderYesterDay = "cron_playlet_video_order_yesterday" + ZhimengCronPlayletVideoOrderMonth = "cron_playlet_video_order_month" + ZhimengCronPlayletAdvOrderYesterDay = "cron_playlet_adv_order_yesterday" + ZhimengCronPlayletAdvOrderMonth = "cron_playlet_adv_order_month" + ZhimengCronPlayletAdvOrderYesterDayToMoney = "cron_playlet_adv_order_yesterday_to_money" + KEY_CFG_TIK_TOK_TEAM_ORDER_PAY = "cron_tik_tok_team_order_pay" + KEY_CFG_KUAISHOU_TEAM_ORDER_PAY = "cron_kuaishou_team_order_pay" + KEY_CFG_KUAISHOU_TEAM_ORDER_UPDATE = "cron_kuaishou_team_order_update" + KEY_CFG_KUAISHOU_AUTH = "cron_kuaishou_auth" + KEY_CFG_VERIFY = "cron_verify" + KEY_CFG_TIK_TOK_TEAM_ORDER_UPDATE = "cron_tik_tok_team_order_update" + KEY_CFG_TIK_TOK_TEAM_USER_BIND_BUYINID = "cron_tik_tok_team_user_bind_buyinid" + // 自动任务运行时设置 + KEY_CFG_CRON_TIME_PIZZA = "crontab_order_time_pizza" + KEY_CFG_CRON_TIME_WALLACE = "crontab_order_time_wallace" + KEY_CFG_CRON_TIME_TOURISM = "crontab_order_time_tourism" + KEY_CFG_CRON_TIME_NEAR = "crontab_order_time_pizza" + KEY_CFG_CRON_TIME_FLOWERCAKE = "crontab_order_time_flowerCake" + KEY_CFG_CRON_TIME_DELIVERY = "crontab_order_time_delivery" + KEY_CFG_CRON_TIME_TIKTOK = "crontab_order_time_tikTok" + KEY_CFG_CRON_TIME_ELM = "crontab_order_time_elm" + KEY_CFG_CRON_TIME_TIKTOKOwn = "crontab_order_time_tikTokOwn" + KEY_CFG_CRON_TIME_TIKTOKOwnCreate = "crontab_order_time_tikTokOwnCreate" + KEY_CFG_CRON_TIME_KuaishouOwn = "crontab_order_time_kuaishouOwn" + KEY_CFG_CRON_TIME_KuaishouOwnCreate = "crontab_order_time_kuaishouOwnCreate" + KEY_CFG_CRON_TIME_TIKTOKOwnActivity = "KEY_CFG_CRON_TIME_TIKTOKOwnActivity" + KEY_CFG_CRON_TIME_TIKTOKOwnMix = "KEY_CFG_CRON_TIME_TIKTOKOwnMix" + KEY_CFG_CRON_TIME_TIKTOKOwnLive = "crontab_order_time_tikTokOwnLive" + KEY_CFG_CRON_TIME_KUAISHOU = "crontab_order_time_kuaishou" + KEY_CFG_CRON_TIME_TIKTOKLIVE = "crontab_order_time_tikTok_live" + KEY_CFG_CRON_TIME_KUAISHOULIVE = "crontab_order_time_kuaishou_live" + KEY_CFG_CRON_TIME_TB = "crontab_order_time_taobao" + KEY_CFG_CRON_TIME_CSJP = "crontab_order_time_csjp" + KEY_CFG_CRON_TIME_KUAISHOU_OFFICIAL = "crontab_order_time_kuaishou_official" + KEY_CFG_CRON_TIME_KUAISHOU_OFFICIAL_LIVE = "crontab_order_time_kuaishou_official_live" + KEY_CFG_CRON_TIME_MEITUAN_OFFICIAL = "crontab_order_time_meituan_official" + KEY_CFG_CRON_TIME_CSJP_Live = "crontab_order_time_csjp_live" + KEY_CFG_CRON_TIME_OWN_CSJP = "crontab_order_time_own_csjp" + KEY_CFG_CRON_TIME_TIKTOK_TEAM_ORDER = "crontab_order_time_tiktok_team_order" + KEY_CFG_CRON_TIME_OWN_CSJP_Live = "crontab_order_time_own_csjp_live" + KEY_CFG_CRON_TIME_OWN_CSJP_ACTIVITY = "crontab_order_time_own_csjp_activity" + KEY_CFG_CRON_TIME_TBREFUND = "crontab_order_time_taobao_refund" + KEY_CFG_CRON_TIME_TBPUNISHREFUND = "crontab_order_time_taobao_punish_refund_new" + KEY_CFG_CRON_TIME_JD = "crontab_order_time_jd" + KEY_CFG_CRON_TIME_PDD = "crontab_order_time_pdd" + KEY_CFG_CRON_TIME_TBBYCREATETIME = "crontab_order_time_tb_by_create_time" + KEY_CFG_CRON_TIME_TBBYPAY = "crontab_order_time_tb_by_pay" + KEY_CFG_CRON_TIME_TB12 = "crontab_order_time_tb12" + KEY_CFG_CRON_TIME_TB13 = "crontab_order_time_tb13" + KEY_CFG_CRON_TIME_TB14 = "crontab_order_time_tb14" + KEY_CFG_CRON_TIME_TB3 = "crontab_order_time_tb3" + KEY_CFG_CRON_TIME_TBBYSETTLE = "crontab_order_time_tb_by_settle" + KEY_CFG_CRON_TIME_PDDBYCREATETIME = "crontab_order_time_pdd_by_create_time" + KEY_CFG_CRON_TIME_JDBYCREATETIME = "crontab_order_time_jd_by_create_time" + KEY_CFG_CRON_TIME_JDBYSUCCESS = "crontab_order_time_jd_by_success" + KEY_CFG_CRON_TIME_JDFAILBYCREATETIME = "crontab_order_time_jd_fail_by_create_time" + KEY_CFG_CRON_TIME_PDDBYAGOTIME = "crontab_order_time_pdd_by_ago_time" + KEY_CFG_CRON_TIME_PDDBYSTATUSSUCCESS = "crontab_order_time_pdd_by_status_success" + KEY_CFG_CRON_TIME_PDDBYSTATUSFAIL = "crontab_order_time_pdd_by_status_fail" + KEY_CFG_CRON_TIME_PDDBYSTATUS = "crontab_order_time_pdd_by_status" + KEY_CFG_CRON_TIME_JDBYSTATUS = "crontab_order_time_jd_by_status" + KEY_CFG_CRON_TIME_SN = "crontab_order_time_suning" + KEY_CFG_CRON_TIME_VIP = "crontab_order_time_vip" + KEY_CFG_CRON_TIME_KL = "crontab_order_time_kaola" + KEY_CFG_CRON_TIME_DUOMAI = "crontab_order_time_duomai" + KEY_CFG_CRON_TIME_PUBLISHER = "crontab_taobao_time_publisher" // 跟踪淘宝备案信息绑定会员运营id 针对小程序 + KEY_CFG_CRON_TIME_MEITUAN = "crontab_order_time_meituan" //美团 + KEY_CFG_CRON_TIME_MEITUANLM = "crontab_order_time_meituan_lm" //美团联盟 + KEY_CFG_CRON_TIME_MEITUANLMSTART = "crontab_order_time_meituan_lm_start" //美团联盟 + KEY_CFG_CRON_TIME_MEITUANSTART = "crontab_order_time_meituan_start" //美团联盟 + KEY_CFG_CRON_TIME_STATIONMEITUANLM = "crontab_order_time_station_meituan_lm" //美团联盟 + KEY_CFG_CRON_TIME_OILSTATION = "crontab_order_time_oilstation" //加油 + KEY_CFG_CRON_TIME_BRIGHT_OILSTATION = "crontab_order_time_bright_oilstation" //加油 + KEY_CFG_CRON_TIME_KFC = "crontab_order_time_kfc" //肯德基 + KEY_CFG_CRON_TIME_CINEMA = "crontab_order_time_cinema" //电影票 + KEY_CFG_CRON_TIME_STARBUCKS = "crontab_order_time_starbucks" //海威星巴克 + KEY_CFG_CRON_TIME_MCDONALD = "crontab_order_time_mcdonald" //海威麦当劳 + KEY_CFG_CRON_TIME_NAYUKI = "crontab_order_time_nayuki" //海威奈雪 + KEY_CFG_CRON_TIME_BURGERKING = "crontab_order_time_burger_king" //海威汉堡王 + KEY_CFG_CRON_TIME_HEYTEA = "crontab_order_time_heytea" //海威喜茶 + KEY_CFG_CRON_TIME_HWMOVIE = "crontab_order_time_hw_movie" //海威电影票 + KEY_CFG_CRON_TIME_TIKTOKLIFE = "crontab_order_time_tik_tok_life" //海威电影票 + KEY_CFG_CRON_TIME_PAGODA = "crontab_order_time_pagoda" // + KEY_CFG_CRON_TIME_TO_KFC = "crontab_order_time_to_kfc" // + KEY_CFG_CRON_TIME_LUCKIN = "crontab_order_time_luckin" // + KEY_CFG_CRON_TIME_DIDI_ENERGY = "crontab_order_time_didi_energy" // + KEY_CFG_CRON_TIME_T3_CAR = "crontab_order_time_t3_car" // + KEY_CFG_CRON_TIME_DIDI_ONLINE_CAR = "crontab_order_time_didi_online_car" // + KEY_CFG_CRON_TIME_KING_FLOWER = "crontab_order_time_king_flower" // + KEY_CFG_CRON_TIME_DIDI_FREIGHT = "crontab_order_time_didi_freight" // + KEY_CFG_CRON_TIME_DIDI_CHAUFFEUR = "crontab_order_time_didi_chauffeur" // + KEY_CFG_CRON_USER_RELATE = "cron_user_relate" +) diff --git a/md/file.go b/md/file.go new file mode 100644 index 0000000..0418fa5 --- /dev/null +++ b/md/file.go @@ -0,0 +1,62 @@ +package md + +// 用户拥有上传权限的目录, 目录ID + +const ( + FILE_DIR_FEEDBACK = "feedback" + FILE_DIR_AVATAR = "avatar" + FILE_DIR_QRCODE = "qrcode" + FILE_DIR_STYLE = "style" + FILE_DIR_O2O = "O2OStore" + FILE_DIR_MALL_AFTER_SALE = "Proprietary_After_Service" + FILE_DIR_IMGREWARD = "img_reward" + FILE_DOCTOR = "doctor" +) + +var ( + FileUserDir = map[string]string{ + FILE_DIR_FEEDBACK: "4", // 用户反馈 + FILE_DIR_AVATAR: "5", // 用户头像 + FILE_DIR_QRCODE: "6", // 用户微信二维码 + FILE_DIR_STYLE: "7", // 用户样式 + FILE_DIR_O2O: "8", //O2O商家上传 + FILE_DIR_MALL_AFTER_SALE: "9", // 售后图片上传 + FILE_DIR_IMGREWARD: "10", //拍立返 + FILE_DOCTOR: "11", //数字医生 + } +) + +// 文件回调信息 +type FileCallback struct { + Uid string `json:"uid"` + DirId string `json:"dir_id"` + Provider string `json:"provider"` // 供应商 + FileName string `json:"fname"` // 原文件名 + FileSize string `json:"fsize"` + Hash string `json:"hash"` + Bucket string `json:"bucket"` + Mime string `json:"mime"` + Width string `json:"w,omitempty"` + Height string `json:"h,omitempty"` + Time string `json:"time"` // 默认一个小时内要上传完毕,否则超时 + Sign string `json:"sign"` // 签名 +} + +type FileList struct { + Path string `json:"path"` + DirId int `json:"dir_id"` + FileName string `json:"f_name"` // 显示名称 + StgName string `json:"stg_name"` // 存储名字 + Ext string `json:"ext"` // 后缀名, png,jpg等 + FileSize string `json:"f_size"` + Provider string `json:"provider"` // 存储供应商 + Hash string `json:"hash"` + Bucket string `json:"bucket"` + Width int `json:"w"` + Height int `json:"h"` + Mime string `json:"mime"` + IsAdm bool `json:"is_adm"` //是否管理后台上传 + IsDir bool `json:"is_dir"` //是否文件夹 + CreateAt int `json:"create_at"` + Url string `json:"url"` +} diff --git a/qiniuyun/api.go b/qiniuyun/api.go new file mode 100644 index 0000000..397ccf3 --- /dev/null +++ b/qiniuyun/api.go @@ -0,0 +1,67 @@ +package qiniu + +import ( + "code.fnuoos.com/go_rely_warehouse/zyos_go_third_party_api.git/e" + "code.fnuoos.com/go_rely_warehouse/zyos_go_third_party_api.git/md" + zhios_third_party_utils "code.fnuoos.com/go_rely_warehouse/zyos_go_third_party_api.git/utils" + "fmt" + "strings" +) + +func ImgReqUpload(arg map[string]string, uid, dirName, fname, callbackUrl string, fsize int64) (interface{}, error) { + ext := zhios_third_party_utils.FileExt(fname) + if err := initStg(arg, fsize, ext); err != nil { + return nil, err + } + newName := dirName + "_" + fmt.Sprintf("%010s", uid) + // 默认都加时间戳 + newName += "_" + zhios_third_party_utils.FormatNanoUnix() + zhios_third_party_utils.RandString(4, "0123456789") + newName += "." + ext + f := &md.FileCallback{ + Uid: uid, + DirId: md.FileUserDir[dirName], + FileName: newName, + } + return ReqImgUpload(f, callbackUrl), nil +} + +func initStg(stgInfo map[string]string, fsize int64, ext string) error { + // todo 目前仅支持七牛 + if v, ok := stgInfo[md.KEY_CFG_FILE_REGION]; !ok || v == "" { + return e.NewErrCode(e.ERR_CFG) + } + if v, ok := stgInfo[md.KEY_CFG_FILE_AK]; !ok || v == "" { + return e.NewErrCode(e.ERR_CFG) + } + if v, ok := stgInfo[md.KEY_CFG_FILE_SK]; !ok || v == "" { + return e.NewErrCode(e.ERR_CFG) + } + if v, ok := stgInfo[md.KEY_CFG_FILE_BUCKET]; !ok || v == "" { + return e.NewErrCode(e.ERR_CFG) + } + if v, ok := stgInfo[md.KEY_CFG_FILE_SCHEME]; !ok || v == "" { + stgInfo[md.KEY_CFG_FILE_SCHEME] = "http" + } + Init(stgInfo[md.KEY_CFG_FILE_AK], stgInfo[md.KEY_CFG_FILE_SK], stgInfo[md.KEY_CFG_FILE_BUCKET], stgInfo[md.KEY_CFG_FILE_REGION], stgInfo[md.KEY_CFG_FILE_SCHEME]) + if v, ok := stgInfo[md.KEY_CFG_FILE_HOST]; !ok || v == "" { + var err error + stgInfo[md.KEY_CFG_FILE_HOST], err = BucketGetDomain(stgInfo[md.KEY_CFG_FILE_BUCKET]) + if err != nil { + return e.NewErrCode(e.ERR_CFG) + } + } + // 头像缩略图参数 + if v, ok := stgInfo[md.KEY_CFG_FILE_AVATAR_THUMBNAIL]; !ok || v == "" { + stgInfo[md.KEY_CFG_FILE_AVATAR_THUMBNAIL] = "?imageView2/1/w/200/h/200/format/png" + } + + // 检查文件大小限制 + if v, ok := stgInfo[md.KEY_CFG_FILE_MAX_SIZE]; ok && v != "" && zhios_third_party_utils.StrToInt64(v) < fsize { + return e.NewErrCode(e.ERR_FILE_MAX_SIZE) + } + // 检查文件后缀 + if v, ok := stgInfo[md.KEY_CFG_FILE_EXT]; ok && v != "" && !strings.Contains(v, ext) { + return e.NewErrCode(e.ERR_FILE_EXT) + } + return nil +} diff --git a/qiniuyun/bucket_create.go b/qiniuyun/bucket_create.go new file mode 100644 index 0000000..28d8106 --- /dev/null +++ b/qiniuyun/bucket_create.go @@ -0,0 +1,16 @@ +package qiniu + +import ( + "github.com/qiniu/api.v7/v7/auth" + "github.com/qiniu/api.v7/v7/storage" +) + +func BucketCreate() error { + mac := auth.New(AK, SK) + cfg := storage.Config{ + // 是否使用https域名进行资源管理 + UseHTTPS: false, + } + bucketManager := storage.NewBucketManager(mac, &cfg) + return bucketManager.CreateBucket("", storage.RIDHuanan) +} diff --git a/qiniuyun/bucket_delete.go b/qiniuyun/bucket_delete.go new file mode 100644 index 0000000..6d41521 --- /dev/null +++ b/qiniuyun/bucket_delete.go @@ -0,0 +1,18 @@ +package qiniu + +import ( + "github.com/qiniu/api.v7/v7/auth" + "github.com/qiniu/api.v7/v7/storage" +) + +func BucketDelete(bucketName string) error { + mac := auth.New(AK, SK) + + cfg := storage.Config{ + // 是否使用https域名进行资源管理 + UseHTTPS: false, + } + + bucketManager := storage.NewBucketManager(mac, &cfg) + return bucketManager.DropBucket(bucketName) +} diff --git a/qiniuyun/bucket_get_domain.go b/qiniuyun/bucket_get_domain.go new file mode 100644 index 0000000..f4cee3a --- /dev/null +++ b/qiniuyun/bucket_get_domain.go @@ -0,0 +1,18 @@ +package qiniu + +import ( + "github.com/qiniu/api.v7/v7/auth" + "github.com/qiniu/api.v7/v7/storage" +) + +func BucketGetDomain(bucketName string) (string, error) { + mac := auth.New(AK, SK) + + cfg := storage.Config{UseHTTPS: false} + bucketManager := storage.NewBucketManager(mac, &cfg) + b, err := bucketManager.ListBucketDomains(bucketName) + if err != nil { + return "", err + } + return b[0].Domain, nil +} diff --git a/qiniuyun/init.go b/qiniuyun/init.go new file mode 100644 index 0000000..ed61dd3 --- /dev/null +++ b/qiniuyun/init.go @@ -0,0 +1,20 @@ +package qiniu + +import zhios_third_party_utils "code.fnuoos.com/go_rely_warehouse/zyos_go_third_party_api.git/utils" + +var ( + AK = "MmxNdai23egjNUHjdzEVaTPdPCIbWzENz9BQuak3" + SK = "mElaFlM9O16rXp-ihoQdJ9KOH56naKm3MoyQBA59" + BUCKET = "dev-fnuoos" // 桶子名称 + BUCKET_SCHEME = "http" + BUCKET_REGION = "up-z2.qiniup.com" + Expires uint64 = 3600 +) + +func Init(ak, sk, bucket, region, scheme string) { + AK, SK, BUCKET, BUCKET_REGION, BUCKET_SCHEME = ak, sk, bucket, region, scheme +} + +func Sign(t string) string { + return zhios_third_party_utils.Md5(AK + SK + t) +} diff --git a/qiniuyun/req_img_upload.go b/qiniuyun/req_img_upload.go new file mode 100644 index 0000000..82fbf0c --- /dev/null +++ b/qiniuyun/req_img_upload.go @@ -0,0 +1,42 @@ +package qiniu + +import ( + "code.fnuoos.com/go_rely_warehouse/zyos_go_third_party_api.git/md" + zhios_third_party_utils "code.fnuoos.com/go_rely_warehouse/zyos_go_third_party_api.git/utils" + "time" + + "github.com/qiniu/api.v7/v7/auth/qbox" + _ "github.com/qiniu/api.v7/v7/conf" + "github.com/qiniu/api.v7/v7/storage" +) + +// 请求图片上传地址信息 +func ReqImgUpload(f *md.FileCallback, callbackUrl string) interface{} { + if ext := zhios_third_party_utils.FileExt(f.FileName); ext == "png" || ext == "jpg" || ext == "jpeg" || ext == "gif" || ext == "bmp" || ext == "webp" { + f.Width = "$(imageInfo.width)" + f.Height = "$(imageInfo.height)" + } + f.Provider = "qiniu" + f.FileSize = "$(fsize)" + f.Hash = "$(etag)" + f.Bucket = "$(bucket)" + f.Mime = "$(mimeType)" + f.Time = zhios_third_party_utils.Int64ToStr(time.Now().Unix()) + f.Sign = Sign(f.Time) + putPolicy := storage.PutPolicy{ + Scope: BUCKET + ":" + f.FileName, // 使用覆盖方式时候必须请求里面有key,否则报错 + Expires: Expires, + ForceSaveKey: true, + SaveKey: f.FileName, + //MimeLimit: "image/*", // 只允许上传图片 + CallbackURL: callbackUrl, + CallbackBody: zhios_third_party_utils.SerializeStr(f), + CallbackBodyType: "application/json", + } + return &struct { + Method string `json:"method"` + Key string `json:"key"` + Host string `json:"host"` + Token string `json:"token"` + }{Key: f.FileName, Method: "POST", Host: BUCKET_SCHEME + "://" + BUCKET_REGION, Token: putPolicy.UploadToken(qbox.NewMac(AK, SK))} +}