zhimeng
/
ad_platform
2
0
Fork 0
Code Issues 0 Pull Requests 0 Releases 0 Wiki Activity
广告平台(站长使用)
You can not select more than 25 topics Topics must start with a letter or number, can include dashes ('-') and can be up to 35 characters long.
64 Commits
1 Branch
5.6 MiB
 
 
 
 
 
Tree: c27974eb0b
Branches Tags
${ item.name }
Create branch ${ searchTerm }
from 'c27974eb0b'
${ noResults }
ad_platform/app/hdl/hdl_set_center.go

670 lines
23 KiB
Raw Blame History 

  1. package hdl

  2. 

  3. import (

  4. 	"applet/app/cfg"

  5. 	implement2 "applet/app/db/implement"

  6. 	"applet/app/e"

  7. 	"applet/app/enum"

  8. 	"applet/app/lib/validate"

  9. 	"applet/app/lib/wechat"

  10. 	"applet/app/md"

  11. 	"applet/app/svc"

  12. 	"applet/app/utils"

  13. 	db "code.fnuoos.com/zhimeng/model.git/src"

  14. 	"code.fnuoos.com/zhimeng/model.git/src/super/implement"

  15. 	"code.fnuoos.com/zhimeng/model.git/src/super/model"

  16. 	"github.com/gin-gonic/gin"

  17. 	"time"

  18. )

  19. 

  20. // SetOss

  21. // @Summary    	 oss设置

  22. // @Tags         设置中心-基础设置

  23. // @Description  基础设置-oss设置

  24. // @param Authorization header string true "验证参数Bearer和token空格拼接"

  25. // @Accept       json

  26. // @Produce      json

  27. // @Param        args 	body      md.SetOssReq   true   "请求参数"

  28. // @Success      200   {string}		   "success"

  29. // @Failure      400   {object}   md.Response              "具体错误"

  30. // @Router       /api/setCenter/basic/setOss [POST]

  31. func SetOss(c *gin.Context) {

  32. 	var req md.SetOssReq

  33. 	err := c.ShouldBindJSON(&req)

  34. 	if err != nil {

  35. 		err = validate.HandleValidateErr(err)

  36. 		err1 := err.(e.E)

  37. 		e.OutErr(c, err1.Code, err1.Error())

  38. 		return

  39. 	}

  40. 	masterId := svc.GetMasterId(c)

  41. 	engine := db.DBs[masterId]

  42. 	sysCfgDb := implement2.NewSysCfgDb(engine, masterId)

  43. 	sysCfgDb.SysCfgUpdate(enum.FileAccessKey, req.FileAccessKey)

  44. 	sysCfgDb.SysCfgUpdate(enum.FileSecretKey, req.FileSecretKey)

  45. 	sysCfgDb.SysCfgUpdate(enum.FileBucketHost, req.FileBucketHost)

  46. 	sysCfgDb.SysCfgUpdate(enum.FileBucketRegion, req.FileBucketRegion)

  47. 	sysCfgDb.SysCfgUpdate(enum.FileBucket, req.FileBucket)

  48. 	svc.ClearRedis(c, masterId, enum.FileAccessKey)

  49. 	svc.ClearRedis(c, masterId, enum.FileSecretKey)

  50. 	svc.ClearRedis(c, masterId, enum.FileBucketHost)

  51. 	svc.ClearRedis(c, masterId, enum.FileBucketRegion)

  52. 	svc.ClearRedis(c, masterId, enum.FileBucket)

  53. 	svc.ClearAllRedis(c, masterId)

  54. 	e.OutSuc(c, "success", nil)

  55. 	return

  56. }

  57. 

  58. // GetOss

  59. // @Summary    	 oss获取

  60. // @Tags         设置中心-基础设置

  61. // @Description  基础设置-oss获取

  62. // @param Authorization header string true "验证参数Bearer和token空格拼接"

  63. // @Accept       json

  64. // @Produce      json

  65. // @Success      200   {object}		  md.SetOssResp

  66. // @Failure      400   {object}   md.Response              "具体错误"

  67. // @Router       /api/setCenter/basic/getOss [GET]

  68. func GetOss(c *gin.Context) {

  69. 	masterId := svc.GetMasterId(c)

  70. 	engine := db.DBs[masterId]

  71. 	sysCfgDb := implement2.NewSysCfgDb(engine, masterId)

  72. 	res := sysCfgDb.SysCfgFindWithDb(enum.FileAccessKey, enum.FileSecretKey, enum.FileBucketHost, enum.FileBucketRegion, enum.FileBucket)

  73. 

  74. 	e.OutSuc(c, md.SetOssResp{

  75. 		Data: md.SetOssReq{

  76. 			FileAccessKey:    res[enum.FileAccessKey],

  77. 			FileSecretKey:    res[enum.FileSecretKey],

  78. 			FileBucketHost:   res[enum.FileBucketHost],

  79. 			FileBucketRegion: res[enum.FileBucketRegion],

  80. 			FileBucket:       res[enum.FileBucket],

  81. 		},

  82. 		QiNiuBucketRegionList: md.QiNiuBucketRegionList,

  83. 	}, nil)

  84. 	return

  85. }

  86. 

  87. // WxOpenSet

  88. // @Summary    	 微信三方应用设置

  89. // @Tags         设置中心-基础设置

  90. // @Description  基础设置-微信三方应用设置

  91. // @param Authorization header string true "验证参数Bearer和token空格拼接"

  92. // @Accept       json

  93. // @Produce      json

  94. // @Param        args 	body      md.WxOpenSetReq   true   "请求参数"

  95. // @Success      200   {string}		   "success"

  96. // @Failure      400   {object}   md.Response              "具体错误"

  97. // @Router       /api/setCenter/basic/wxOpenSet [POST]

  98. func WxOpenSet(c *gin.Context) {

  99. 	var req md.WxOpenSetReq

  100. 	err := c.ShouldBindJSON(&req)

  101. 	if err != nil {

  102. 		err = validate.HandleValidateErr(err)

  103. 		err1 := err.(e.E)

  104. 		e.OutErr(c, err1.Code, err1.Error())

  105. 		return

  106. 	}

  107. 	masterId := svc.GetMasterId(c)

  108. 	//1、查找对应 wx_open_third_party_app_list 记录

  109. 	wxOpenThirdPartyAppListDb := implement.NewWxOpenThirdPartyAppListDb(db.Db)

  110. 	UserWxAppletList, err := wxOpenThirdPartyAppListDb.GetWxOpenThirdPartyAppList(utils.StrToInt(masterId))

  111. 	if err != nil {

  112. 		e.OutErr(c, e.ERR_DB_ORM, err.Error())

  113. 		return

  114. 	}

  115. 	if UserWxAppletList == nil {

  116. 		UserWxAppletList = &model.WxOpenThirdPartyAppList{

  117. 			Uuid:                  utils.StrToInt(masterId),

  118. 			Token:                 req.Token,

  119. 			AesKey:                req.AesKey,

  120. 			Appid:                 req.Appid,

  121. 			AppSecret:             req.AppSecret,

  122. 			ComponentVerifyTicket: "",

  123. 			ComponentAccessToken:  "",

  124. 			CreateAt:              time.Now().Format("2006-01-02 15:04:05"),

  125. 			UpdateAt:              time.Now().Format("2006-01-02 15:04:05"),

  126. 		}

  127. 		_, err = wxOpenThirdPartyAppListDb.WxOpenThirdPartyAppListInsert(UserWxAppletList)

  128. 		if err != nil {

  129. 			e.OutErr(c, e.ERR_DB_ORM, err.Error())

  130. 			return

  131. 		}

  132. 	} else {

  133. 		UserWxAppletList.Token = req.Token

  134. 		UserWxAppletList.AesKey = req.AesKey

  135. 		UserWxAppletList.Appid = req.Appid

  136. 		UserWxAppletList.AppSecret = req.AppSecret

  137. 		_, err = wxOpenThirdPartyAppListDb.UpdateWxOpenThirdPartyAppList(UserWxAppletList,

  138. 			"token", "aes_key", "appid", "app_secret")

  139. 		if err != nil {

  140. 			e.OutErr(c, e.ERR_DB_ORM, err.Error())

  141. 			return

  142. 		}

  143. 	}

  144. 	e.OutSuc(c, "success", nil)

  145. 	return

  146. }

  147. 

  148. // WxOpenGet

  149. // @Summary    	 微信三方应用获取

  150. // @Tags         设置中心-基础设置

  151. // @Description  基础设置-微信三方应用获取

  152. // @param Authorization header string true "验证参数Bearer和token空格拼接"

  153. // @Accept       json

  154. // @Produce      json

  155. // @Success      200   {object}		  md.WxOpenGetResp

  156. // @Failure      400   {object}   md.Response              "具体错误"

  157. // @Router       /api/setCenter/basic/wxOpenGet [GET]

  158. func WxOpenGet(c *gin.Context) {

  159. 	masterId := svc.GetMasterId(c)

  160. 	//1、查找对应 wx_open_third_party_app_list 记录

  161. 	wxOpenThirdPartyAppListDb := implement.NewWxOpenThirdPartyAppListDb(db.Db)

  162. 	UserWxAppletList, err := wxOpenThirdPartyAppListDb.GetWxOpenThirdPartyAppList(utils.StrToInt(masterId))

  163. 	if err != nil {

  164. 		e.OutErr(c, e.ERR_DB_ORM, err.Error())

  165. 		return

  166. 	}

  167. 	if UserWxAppletList == nil {

  168. 		UserWxAppletList = &model.WxOpenThirdPartyAppList{

  169. 			Uuid:                  utils.StrToInt(masterId),

  170. 			Token:                 "",

  171. 			AesKey:                "",

  172. 			Appid:                 "",

  173. 			AppSecret:             "",

  174. 			ComponentVerifyTicket: "",

  175. 			ComponentAccessToken:  "",

  176. 			CreateAt:              time.Now().Format("2006-01-02 15:04:05"),

  177. 			UpdateAt:              time.Now().Format("2006-01-02 15:04:05"),

  178. 		}

  179. 		_, err = wxOpenThirdPartyAppListDb.WxOpenThirdPartyAppListInsert(UserWxAppletList)

  180. 		if err != nil {

  181. 			e.OutErr(c, e.ERR_DB_ORM, err.Error())

  182. 			return

  183. 		}

  184. 	}

  185. 	sysCfgDb := implement2.NewSysCfgDb(db.Db, "")

  186. 	res := sysCfgDb.SysCfgFindWithDb(enum.WxOpenAppletServerDomain, enum.WxOpenAuthorizationEventReceivingConfiguration,

  187. 		enum.WxOpenDomainOfTheInitiatingPageForLoginAuthorization, enum.WxOpenMessageAndEventReceptionConfiguration, enum.WxOpenWhiteListIp)

  188. 	e.OutSuc(c, md.WxOpenGetResp{

  189. 		Token:                    UserWxAppletList.Token,

  190. 		AesKey:                   UserWxAppletList.AesKey,

  191. 		Appid:                    UserWxAppletList.Appid,

  192. 		AppSecret:                UserWxAppletList.AppSecret,

  193. 		WxOpenAppletServerDomain: res[enum.WxOpenAppletServerDomain],

  194. 		WxOpenAuthorizationEventReceivingConfiguration:       res[enum.WxOpenAuthorizationEventReceivingConfiguration],

  195. 		WxOpenDomainOfTheInitiatingPageForLoginAuthorization: res[enum.WxOpenDomainOfTheInitiatingPageForLoginAuthorization],

  196. 		WxOpenMessageAndEventReceptionConfiguration:          res[enum.WxOpenMessageAndEventReceptionConfiguration],

  197. 		WxOpenWhiteListIp: res[enum.WxOpenWhiteListIp],

  198. 	}, nil)

  199. 	return

  200. }

  201. 

  202. type WxOpenThirdPartyAppList struct {

  203. 	Id                    int    `json:"id" xorm:"not null pk autoincr unique(IDX_UUID_TYPE) INT(11)"`

  204. 	Uuid                  int    `json:"uuid" xorm:"not null comment('站长id') index unique(IDX_UUID_TYPE) INT(10)"`

  205. 	Token                 string `json:"token" xorm:"not null default '' comment('消息校验Token') VARCHAR(255)"`

  206. 	AesKey                string `json:"aes_key" xorm:"not null default '' comment('消息加解密Key') VARCHAR(255)"`

  207. 	Appid                 string `json:"appid" xorm:"not null default '' comment('appid') CHAR(50)"`

  208. 	AppSecret             string `json:"app_secret" xorm:"not null default '' comment('appSecret') VARCHAR(255)"`

  209. 	ComponentVerifyTicket string `json:"component_verify_ticket" xorm:"not null default '' comment('验证票据') VARCHAR(255)"`

  210. 	ComponentAccessToken  string `json:"component_access_token" xorm:"not null default '' comment('接口令牌') VARCHAR(255)"`

  211. 	CreateAt              string `json:"create_at" xorm:"not null default 'CURRENT_TIMESTAMP' DATETIME"`

  212. 	UpdateAt              string `json:"update_at" xorm:"not null default 'CURRENT_TIMESTAMP' DATETIME"`

  213. }

  214. 

  215. // AppletList

  216. // @Summary    	 列表

  217. // @Tags         设置中心-小程序设置

  218. // @Description  小程序设置-列表

  219. // @param Authorization header string true "验证参数Bearer和token空格拼接"

  220. // @Accept       json

  221. // @Produce      json

  222. // @Success      200   {object}   WxOpenThirdPartyAppList

  223. // @Failure      400   {object}   md.Response              "具体错误"

  224. // @Router       /api/setCenter/applet/list [GET]

  225. func AppletList(c *gin.Context) {

  226. 	masterId := svc.GetMasterId(c)

  227. 	//1、查找对应 user_wx_applet_list 记录

  228. 	userWxAppletListDb := implement.NewUserWxAppletListDb(db.Db)

  229. 	UserWxAppletList, err := userWxAppletListDb.GetUserWxAppletList(masterId)

  230. 	if err != nil {

  231. 		e.OutErr(c, e.ERR_DB_ORM, err.Error())

  232. 		return

  233. 	}

  234. 	e.OutSuc(c, UserWxAppletList, nil)

  235. 	return

  236. }

  237. 

  238. // AppletAdd

  239. // @Summary    	 新增

  240. // @Tags         设置中心-小程序设置

  241. // @Description  小程序设置-新增

  242. // @param Authorization header string true "验证参数Bearer和token空格拼接"

  243. // @Accept       json

  244. // @Produce      json

  245. // @Param        args 	body      md.AppletAddReq   true   "请求参数"

  246. // @Success      200   {string}		   "success"

  247. // @Failure      400   {object}   md.Response              "具体错误"

  248. // @Router       /api/setCenter/applet/add [POST]

  249. func AppletAdd(c *gin.Context) {

  250. 	var req md.AppletAddReq

  251. 	err := c.ShouldBindJSON(&req)

  252. 	if err != nil {

  253. 		err = validate.HandleValidateErr(err)

  254. 		err1 := err.(e.E)

  255. 		e.OutErr(c, err1.Code, err1.Error())

  256. 		return

  257. 	}

  258. 	masterId := svc.GetMasterId(c)

  259. 	//1、查找对应 user_wx_applet_list 记录

  260. 	userWxAppletListDb := implement.NewUserWxAppletListDb(db.Db)

  261. 	UserWxAppletList, err := userWxAppletListDb.GetUserWxAppletList(masterId)

  262. 	if err != nil {

  263. 		e.OutErr(c, e.ERR_DB_ORM, err.Error())

  264. 		return

  265. 	}

  266. 	if UserWxAppletList != nil {

  267. 		e.OutErr(c, e.ERR, "当前仅支持单个小程序")

  268. 		return

  269. 	}

  270. 	_, err = userWxAppletListDb.UserWxAppletListInsert(&model.UserWxAppletList{

  271. 		Name:                   req.Name,

  272. 		Logo:                   req.Logo,

  273. 		Appid:                  req.Appid,

  274. 		OriginalId:             req.OriginalId,

  275. 		AuthorizerRefreshToken: "",

  276. 		IsAuth:                 0,

  277. 		Uuid:                   masterId,

  278. 		CreateAt:               time.Now().Format("2006-01-02 15:04:05"),

  279. 		UpdateAt:               time.Now().Format("2006-01-02 15:04:05"),

  280. 	})

  281. 	if err != nil {

  282. 		e.OutErr(c, e.ERR_DB_ORM, err.Error())

  283. 		return

  284. 	}

  285. 

  286. 	e.OutSuc(c, "success", nil)

  287. 	return

  288. }

  289. 

  290. // AppletUpdate

  291. // @Summary    	 更新

  292. // @Tags         设置中心-小程序设置

  293. // @Description  小程序设置-更新

  294. // @param Authorization header string true "验证参数Bearer和token空格拼接"

  295. // @Accept       json

  296. // @Produce      json

  297. // @Param        args 	body      md.AppletUpdateReq   true   "请求参数"

  298. // @Success      200   {string}		   "success"

  299. // @Failure      400   {object}   md.Response              "具体错误"

  300. // @Router       /api/setCenter/applet/update [POST]

  301. func AppletUpdate(c *gin.Context) {

  302. 	var req md.AppletUpdateReq

  303. 	err := c.ShouldBindJSON(&req)

  304. 	if err != nil {

  305. 		err = validate.HandleValidateErr(err)

  306. 		err1 := err.(e.E)

  307. 		e.OutErr(c, err1.Code, err1.Error())

  308. 		return

  309. 	}

  310. 	masterId := svc.GetMasterId(c)

  311. 	//1、查找对应 user_wx_applet_list 记录

  312. 	userWxAppletListDb := implement.NewUserWxAppletListDb(db.Db)

  313. 	UserWxAppletList, err := userWxAppletListDb.GetUserWxAppletList(masterId)

  314. 	if err != nil {

  315. 		e.OutErr(c, e.ERR_DB_ORM, err.Error())

  316. 		return

  317. 	}

  318. 	if UserWxAppletList == nil {

  319. 		e.OutErr(c, e.ERR_NO_DATA, "未查询到对应记录")

  320. 		return

  321. 	}

  322. 	UserWxAppletList.Logo = req.Logo

  323. 	UserWxAppletList.Name = req.Name

  324. 	_, err = userWxAppletListDb.UpdateUserWxAppletList(UserWxAppletList, "logo", "name")

  325. 	if err != nil {

  326. 		e.OutErr(c, e.ERR_DB_ORM, err.Error())

  327. 		return

  328. 	}

  329. 

  330. 	e.OutSuc(c, "success", nil)

  331. 	return

  332. }

  333. 

  334. // AppletDelete

  335. // @Summary      删除

  336. // @Tags         设置中心-小程序设置

  337. // @Description  小程序设置-删除

  338. // @param Authorization header string true "验证参数Bearer和token空格拼接"

  339. // @Accept       json

  340. // @Produce      json

  341. // @Success      200   {string}   "success"

  342. // @Failure      400   {object}   md.Response                "具体错误"

  343. // @Router       /v1/banner/delete/{$id} [DELETE]

  344. func AppletDelete(c *gin.Context) {

  345. 	id := c.Param("id")

  346. 

  347. 	masterId := svc.GetMasterId(c)

  348. 	//1、查找对应 user_wx_applet_list 记录

  349. 	userWxAppletListDb := implement.NewUserWxAppletListDb(db.Db)

  350. 	UserWxAppletList, err := userWxAppletListDb.GetUserWxAppletList(masterId)

  351. 	if err != nil {

  352. 		e.OutErr(c, e.ERR_DB_ORM, err.Error())

  353. 		return

  354. 	}

  355. 	if UserWxAppletList == nil {

  356. 		e.OutErr(c, e.ERR_NO_DATA, "未查询到对应记录")

  357. 		return

  358. 	}

  359. 

  360. 	_, err = userWxAppletListDb.UserWxAppletListDelete(id)

  361. 	if err != nil {

  362. 		e.OutErr(c, e.ERR_DB_ORM, err.Error())

  363. 		return

  364. 	}

  365. 	e.OutSuc(c, "success", nil)

  366. 	return

  367. }

  368. 

  369. // AppletAuthorize

  370. // @Summary    	 设置中心-基础设置-微信三方应用获取

  371. // @Tags         设置中心

  372. // @Description  设置中心-基础设置

  373. // @param Authorization header string true "验证参数Bearer和token空格拼接"

  374. // @Accept       json

  375. // @Produce      json

  376. // @Success      200   {string}		  "微信授权界面url"

  377. // @Failure      400   {object}   md.Response              "具体错误"

  378. // @Router       /api/setCenter/applet/authorize [GET]

  379. func AppletAuthorize(c *gin.Context) {

  380. 	masterId := svc.GetMasterId(c)

  381. 	url := "http://super.advertisement.dengbiao.top/api/wxOpen/getPreAuthCode?master_id=" + masterId

  382. 	if cfg.Prd {

  383. 		url = "http://super.advertisement.dengbiao.top/api/wxOpen/getPreAuthCode?master_id=" + masterId

  384. 	}

  385. 	e.OutSuc(c, map[string]string{

  386. 		"url": url,

  387. 	}, nil)

  388. 	return

  389. }

  390. 

  391. // AppletUnauthorized

  392. // @Summary    	 设置中心-基础设置-微信三方应用获取

  393. // @Tags         设置中心

  394. // @Description  设置中心-基础设置

  395. // @param Authorization header string true "验证参数Bearer和token空格拼接"

  396. // @Accept       json

  397. // @Produce      json

  398. // @Success      200   {string}		  "success"

  399. // @Failure      400   {object}   md.Response              "具体错误"

  400. // @Router       /api/setCenter/applet/unauthorized [GET]

  401. func AppletUnauthorized(c *gin.Context) {

  402. 	appId := c.DefaultQuery("app_id", "")

  403. 	masterId := svc.GetMasterId(c)

  404. 	//1、查找对应 user_wx_applet_list 记录

  405. 	userWxAppletListDb := implement.NewUserWxAppletListDb(db.Db)

  406. 	UserWxAppletList, err := userWxAppletListDb.GetUserWxAppletList(masterId)

  407. 	if err != nil {

  408. 		e.OutErr(c, e.ERR_DB_ORM, err.Error())

  409. 		return

  410. 	}

  411. 	if UserWxAppletList == nil {

  412. 		e.OutErr(c, e.ERR_NO_DATA, "未查询到对应记录")

  413. 		return

  414. 	}

  415. 

  416. 	wxOpenThirdPartyAppListDb := implement.NewWxOpenThirdPartyAppListDb(db.Db)

  417. 	wxOpenThirdPartyAppList, err := wxOpenThirdPartyAppListDb.GetWxOpenThirdPartyAppList(utils.StrToInt(masterId))

  418. 	if err != nil {

  419. 		e.OutErr(c, e.ERR, err.Error())

  420. 		return

  421. 	}

  422. 	if wxOpenThirdPartyAppList == nil {

  423. 		e.OutErr(c, e.ERR_NOT_FAN, "未查询到对应三方应用记录")

  424. 		return

  425. 	}

  426. 	wxApiService, err := wechat.NewWxApiService(masterId, wxOpenThirdPartyAppList.Appid, wxOpenThirdPartyAppList.AppSecret)

  427. 	if err != nil {

  428. 		e.OutErr(c, e.ERR, err.Error())

  429. 		return

  430. 	}

  431. 	err = wxApiService.DelAuthorize(appId)

  432. 	if err != nil {

  433. 		e.OutErr(c, e.ERR, err.Error())

  434. 		return

  435. 	}

  436. 	e.OutSuc(c, "success", nil)

  437. 	return

  438. }

  439. 

  440. // ShareIndex

  441. // @Summary    	 邀请链接

  442. // @Tags         设置中心-邀请链接

  443. // @Description  邀请链接界面接口

  444. // @param Authorization header string true "验证参数Bearer和token空格拼接"

  445. // @Accept       json

  446. // @Produce      json

  447. // @Success      200   {object}		  md.ShareIndexResp

  448. // @Failure      400   {object}   md.Response              "具体错误"

  449. // @Router       /api/setCenter/share/index [GET]

  450. func ShareIndex(c *gin.Context) {

  451. 	masterId := svc.GetMasterId(c)

  452. 

  453. 	agent := new(model.UserAppDomain)

  454. 	_, err := db.Db.Where("type =?", "agent").And("uuid =?", masterId).And("is_ssl =1").Get(agent)

  455. 	if err != nil {

  456. 		e.OutErr(c, e.ERR_DB_ORM, err.Error())

  457. 		return

  458. 	}

  459. 

  460. 	medium := new(model.UserAppDomain)

  461. 	_, err = db.Db.Where("type =?", "medium").And("uuid =?", masterId).And("is_ssl =1").Get(medium)

  462. 	if err != nil {

  463. 		e.OutErr(c, e.ERR_DB_ORM, err.Error())

  464. 		return

  465. 	}

  466. 

  467. 	agentDomain := ""

  468. 	if agent != nil {

  469. 		agentDomain = agent.Domain

  470. 	}

  471. 	mediumDomain := ""

  472. 	if medium != nil {

  473. 		mediumDomain = medium.Domain

  474. 	}

  475. 	e.OutSuc(c, md.ShareIndexResp{

  476. 		MasterId:     masterId,

  477. 		AgentDomain:  agentDomain,

  478. 		MediumDomain: mediumDomain,

  479. 	}, nil)

  480. 	return

  481. }

  482. 

  483. // SetMob

  484. // @Summary    	 mob设置

  485. // @Tags         设置中心-基础设置

  486. // @Description  基础设置-mob设置

  487. // @param Authorization header string true "验证参数Bearer和token空格拼接"

  488. // @Accept       json

  489. // @Produce      json

  490. // @Param        args 	body      md.SetMobReq   true   "请求参数"

  491. // @Success      200   {string}		   "success"

  492. // @Failure      400   {object}   md.Response              "具体错误"

  493. // @Router       /api/setCenter/basic/setMob [POST]

  494. func SetMob(c *gin.Context) {

  495. 	var req md.SetMobReq

  496. 	err := c.ShouldBindJSON(&req)

  497. 	if err != nil {

  498. 		err = validate.HandleValidateErr(err)

  499. 		err1 := err.(e.E)

  500. 		e.OutErr(c, err1.Code, err1.Error())

  501. 		return

  502. 	}

  503. 	masterId := svc.GetMasterId(c)

  504. 	engine := db.DBs[masterId]

  505. 	sysCfgDb := implement2.NewSysCfgDb(engine, masterId)

  506. 	sysCfgDb.SysCfgUpdate("mob_app_key", req.MobAppKey)

  507. 	sysCfgDb.SysCfgUpdate("mob_app_secret", req.MobAppSecret)

  508. 	svc.ClearRedis(c, masterId, "mob_app_key")

  509. 	svc.ClearRedis(c, masterId, "mob_app_secret")

  510. 	svc.ClearAllRedis(c, masterId)

  511. 	e.OutSuc(c, "success", nil)

  512. 	return

  513. }

  514. 

  515. // GetMob

  516. // @Summary    	 mob获取

  517. // @Tags         设置中心-基础设置

  518. // @Description  基础设置-mob获取

  519. // @param Authorization header string true "验证参数Bearer和token空格拼接"

  520. // @Accept       json

  521. // @Produce      json

  522. // @Success      200   {object}		  md.SetOssResp

  523. // @Failure      400   {object}   md.Response              "具体错误"

  524. // @Router       /api/setCenter/basic/getMob [GET]

  525. func GetMob(c *gin.Context) {

  526. 	masterId := svc.GetMasterId(c)

  527. 	engine := db.DBs[masterId]

  528. 	sysCfgDb := implement2.NewSysCfgDb(engine, masterId)

  529. 	res := sysCfgDb.SysCfgFindWithDb("mob_app_key", "mob_app_secret")

  530. 

  531. 	e.OutSuc(c, md.SetMobResp{

  532. 		Data: md.SetMobReq{

  533. 			MobAppSecret: res["mob_app_secret"],

  534. 			MobAppKey:    res["mob_app_key"],

  535. 		},

  536. 	}, nil)

  537. 	return

  538. }

  539. 

  540. // SetLogo

  541. // @Summary    	 logo设置

  542. // @Tags         设置中心-基础设置

  543. // @Description  基础设置-logo设置

  544. // @param Authorization header string true "验证参数Bearer和token空格拼接"

  545. // @Accept       json

  546. // @Produce      json

  547. // @Param        args 	body      md.SetLogoReq   true   "请求参数"

  548. // @Success      200   {string}		   "success"

  549. // @Failure      400   {object}   md.Response              "具体错误"

  550. // @Router       /api/setCenter/basic/setLogo [POST]

  551. func SetLogo(c *gin.Context) {

  552. 	var req md.SetLogoReq

  553. 	err := c.ShouldBindJSON(&req)

  554. 	if err != nil {

  555. 		err = validate.HandleValidateErr(err)

  556. 		err1 := err.(e.E)

  557. 		e.OutErr(c, err1.Code, err1.Error())

  558. 		return

  559. 	}

  560. 	masterId := svc.GetMasterId(c)

  561. 	engine := db.DBs[masterId]

  562. 	sysCfgDb := implement2.NewSysCfgDb(engine, masterId)

  563. 	sysCfgDb.SysCfgUpdate("medium_logo", req.MediumLogo)

  564. 	sysCfgDb.SysCfgUpdate("agent_logo", req.AgentLogo)

  565. 	sysCfgDb.SysCfgUpdate("medium_login_logo", req.MediumLoginLogo)

  566. 	sysCfgDb.SysCfgUpdate("agent_login_logo", req.AgentLoginLogo)

  567. 	svc.ClearRedis(c, masterId, "medium_logo")

  568. 	svc.ClearRedis(c, masterId, "agent_logo")

  569. 	svc.ClearRedis(c, masterId, "medium_login_logo")

  570. 	svc.ClearRedis(c, masterId, "agent_login_logo")

  571. 	svc.ClearAllRedis(c, masterId)

  572. 	e.OutSuc(c, "success", nil)

  573. 	return

  574. }

  575. 

  576. // GetLogo

  577. // @Summary    	 logo获取

  578. // @Tags         设置中心-基础设置

  579. // @Description  基础设置-logo获取

  580. // @param Authorization header string true "验证参数Bearer和token空格拼接"

  581. // @Accept       json

  582. // @Produce      json

  583. // @Success      200   {object}		  md.SetLogoResp

  584. // @Failure      400   {object}   md.Response              "具体错误"

  585. // @Router       /api/setCenter/basic/getLogo [GET]

  586. func GetLogo(c *gin.Context) {

  587. 	masterId := svc.GetMasterId(c)

  588. 	engine := db.DBs[masterId]

  589. 	sysCfgDb := implement2.NewSysCfgDb(engine, masterId)

  590. 	res := sysCfgDb.SysCfgFindWithDb("medium_logo", "agent_logo", "medium_login_logo", "agent_login_logo")

  591. 

  592. 	e.OutSuc(c, md.SetLogoResp{

  593. 		Data: md.SetLogoReq{

  594. 			MediumLogo:      res["medium_logo"],

  595. 			AgentLogo:       res["agent_logo"],

  596. 			MediumLoginLogo: res["medium_login_logo"],

  597. 			AgentLoginLogo:  res["agent_login_logo"],

  598. 		},

  599. 	}, nil)

  600. 	return

  601. }

  602. 

  603. // SetSeo

  604. // @Summary    	 Seo设置

  605. // @Tags         设置中心-基础设置

  606. // @Description  基础设置-logo设置

  607. // @param Authorization header string true "验证参数Bearer和token空格拼接"

  608. // @Accept       json

  609. // @Produce      json

  610. // @Param        args 	body      md.SetSeoReq   true   "请求参数"

  611. // @Success      200   {string}		   "success"

  612. // @Failure      400   {object}   md.Response              "具体错误"

  613. // @Router       /api/setCenter/basic/setSeo [POST]

  614. func SetSeo(c *gin.Context) {

  615. 	var req md.SetSeoReq

  616. 	err := c.ShouldBindJSON(&req)

  617. 	if err != nil {

  618. 		err = validate.HandleValidateErr(err)

  619. 		err1 := err.(e.E)

  620. 		e.OutErr(c, err1.Code, err1.Error())

  621. 		return

  622. 	}

  623. 	masterId := svc.GetMasterId(c)

  624. 	engine := db.DBs[masterId]

  625. 	sysCfgDb := implement2.NewSysCfgDb(engine, masterId)

  626. 	sysCfgDb.SysCfgUpdate("seo_medium_title", req.SeoMediumTitle)

  627. 	sysCfgDb.SysCfgUpdate("seo_agent_title", req.SeoAgentTitle)

  628. 	sysCfgDb.SysCfgUpdate("seo_platform_title", req.SeoPlatformTitle)

  629. 	svc.ClearRedis(c, masterId, "seo_medium_title")

  630. 	svc.ClearRedis(c, masterId, "seo_agent_title")

  631. 	svc.ClearRedis(c, masterId, "seo_platform_title")

  632. 	sysCfgDb.SysCfgUpdate("seo_medium_logo", req.SeoMediumLogo)

  633. 	sysCfgDb.SysCfgUpdate("seo_agent_logo", req.SeoAgentLogo)

  634. 	sysCfgDb.SysCfgUpdate("seo_platform_logo", req.SeoPlatformLogo)

  635. 	svc.ClearRedis(c, masterId, "seo_medium_logo")

  636. 	svc.ClearRedis(c, masterId, "seo_agent_logo")

  637. 	svc.ClearRedis(c, masterId, "seo_platform_logo")

  638. 	svc.ClearAllRedis(c, masterId)

  639. 	e.OutSuc(c, "success", nil)

  640. 	return

  641. }

  642. 

  643. // GetSeo

  644. // @Summary    	 Seo获取

  645. // @Tags         设置中心-基础设置

  646. // @Description  基础设置-logo获取

  647. // @param Authorization header string true "验证参数Bearer和token空格拼接"

  648. // @Accept       json

  649. // @Produce      json

  650. // @Success      200   {object}		  md.SetSeoResp

  651. // @Failure      400   {object}   md.Response              "具体错误"

  652. // @Router       /api/setCenter/basic/getSeo [GET]

  653. func GetSeo(c *gin.Context) {

  654. 	masterId := svc.GetMasterId(c)

  655. 	engine := db.DBs[masterId]

  656. 	sysCfgDb := implement2.NewSysCfgDb(engine, masterId)

  657. 	res := sysCfgDb.SysCfgFindWithDb("seo_medium_logo", "seo_agent_logo", "seo_platform_logo", "seo_medium_title", "seo_agent_title", "seo_platform_title")

  658. 	e.OutSuc(c, md.SetSeoResp{

  659. 		Data: md.SetSeoReq{

  660. 			SeoMediumTitle:   res["seo_medium_title"],

  661. 			SeoAgentTitle:    res["seo_agent_title"],

  662. 			SeoPlatformTitle: res["seo_platform_title"],

  663. 			SeoMediumLogo:    res["seo_medium_logo"],

  664. 			SeoAgentLogo:     res["seo_agent_logo"],

  665. 			SeoPlatformLogo:  res["seo_platform_logo"],

  666. 		},

  667. 	}, nil)

  668. 	return

  669. }