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.
73 Commits
1 Branch
12 MiB
 
 
 
 
 
Tree: 0afc1329ed
Branches Tags
${ item.name }
Create branch ${ searchTerm }
from '0afc1329ed'
${ noResults }
ad_platform/app/hdl/hdl_set_center.go

994 lines
34 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. 	md2 "applet/app/lib/wechat/md"

  11. 	"applet/app/md"

  12. 	"applet/app/svc"

  13. 	"applet/app/utils"

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

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

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

  17. 	"encoding/json"

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

  19. 	"strings"

  20. 	"time"

  21. )

  22. 

  23. // SetOss

  24. // @Summary    	 oss设置

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

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

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

  28. // @Accept       json

  29. // @Produce      json

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

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

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

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

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

  35. 	var req md.SetOssReq

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

  37. 	if err != nil {

  38. 		err = validate.HandleValidateErr(err)

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

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

  41. 		return

  42. 	}

  43. 	masterId := svc.GetMasterId(c)

  44. 	engine := db.DBs[masterId]

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

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

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

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

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

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

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

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

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

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

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

  56. 	svc.ClearAllRedis(c, masterId)

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

  58. 	return

  59. }

  60. 

  61. // GetOss

  62. // @Summary    	 oss获取

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

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

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

  66. // @Accept       json

  67. // @Produce      json

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

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

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

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

  72. 	masterId := svc.GetMasterId(c)

  73. 	engine := db.DBs[masterId]

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

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

  76. 

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

  78. 		Data: md.SetOssReq{

  79. 			FileAccessKey:    res[enum.FileAccessKey],

  80. 			FileSecretKey:    res[enum.FileSecretKey],

  81. 			FileBucketHost:   res[enum.FileBucketHost],

  82. 			FileBucketRegion: res[enum.FileBucketRegion],

  83. 			FileBucket:       res[enum.FileBucket],

  84. 		},

  85. 		QiNiuBucketRegionList: md.QiNiuBucketRegionList,

  86. 	}, nil)

  87. 	return

  88. }

  89. 

  90. // WxOpenSet

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

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

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

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

  95. // @Accept       json

  96. // @Produce      json

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

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

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

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

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

  102. 	var req md.WxOpenSetReq

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

  104. 	if err != nil {

  105. 		err = validate.HandleValidateErr(err)

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

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

  108. 		return

  109. 	}

  110. 	masterId := svc.GetMasterId(c)

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

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

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

  114. 	if err != nil {

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

  116. 		return

  117. 	}

  118. 	if UserWxAppletList == nil {

  119. 		UserWxAppletList = &model.WxOpenThirdPartyAppList{

  120. 			Uuid:                  utils.StrToInt(masterId),

  121. 			Token:                 req.Token,

  122. 			AesKey:                req.AesKey,

  123. 			Appid:                 req.Appid,

  124. 			AppSecret:             req.AppSecret,

  125. 			ComponentVerifyTicket: "",

  126. 			ComponentAccessToken:  "",

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

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

  129. 		}

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

  131. 		if err != nil {

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

  133. 			return

  134. 		}

  135. 	} else {

  136. 		UserWxAppletList.Token = req.Token

  137. 		UserWxAppletList.AesKey = req.AesKey

  138. 		UserWxAppletList.Appid = req.Appid

  139. 		UserWxAppletList.AppSecret = req.AppSecret

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

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

  142. 		if err != nil {

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

  144. 			return

  145. 		}

  146. 	}

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

  148. 	return

  149. }

  150. 

  151. // WxOpenGet

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

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

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

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

  156. // @Accept       json

  157. // @Produce      json

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

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

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

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

  162. 	masterId := svc.GetMasterId(c)

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

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

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

  166. 	if err != nil {

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

  168. 		return

  169. 	}

  170. 	if UserWxAppletList == nil {

  171. 		UserWxAppletList = &model.WxOpenThirdPartyAppList{

  172. 			Uuid:                  utils.StrToInt(masterId),

  173. 			Token:                 "",

  174. 			AesKey:                "",

  175. 			Appid:                 "",

  176. 			AppSecret:             "",

  177. 			ComponentVerifyTicket: "",

  178. 			ComponentAccessToken:  "",

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

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

  181. 		}

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

  183. 		if err != nil {

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

  185. 			return

  186. 		}

  187. 	}

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

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

  190. 		enum.WxOpenDomainOfTheInitiatingPageForLoginAuthorization, enum.WxOpenMessageAndEventReceptionConfiguration, enum.WxOpenWhiteListIp)

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

  192. 		Token:                    UserWxAppletList.Token,

  193. 		AesKey:                   UserWxAppletList.AesKey,

  194. 		Appid:                    UserWxAppletList.Appid,

  195. 		AppSecret:                UserWxAppletList.AppSecret,

  196. 		WxOpenAppletServerDomain: res[enum.WxOpenAppletServerDomain],

  197. 		WxOpenAuthorizationEventReceivingConfiguration:       res[enum.WxOpenAuthorizationEventReceivingConfiguration],

  198. 		WxOpenDomainOfTheInitiatingPageForLoginAuthorization: res[enum.WxOpenDomainOfTheInitiatingPageForLoginAuthorization],

  199. 		WxOpenMessageAndEventReceptionConfiguration:          res[enum.WxOpenMessageAndEventReceptionConfiguration],

  200. 		WxOpenWhiteListIp: res[enum.WxOpenWhiteListIp],

  201. 	}, nil)

  202. 	return

  203. }

  204. 

  205. type WxOpenThirdPartyAppList struct {

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

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

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

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

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

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

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

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

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

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

  216. }

  217. 

  218. // AppletList

  219. // @Summary    	 列表

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

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

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

  223. // @Accept       json

  224. // @Produce      json

  225. // @Success      200   {object}   WxOpenThirdPartyAppList

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

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

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

  229. 	masterId := svc.GetMasterId(c)

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

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

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

  233. 	if err != nil {

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

  235. 		return

  236. 	}

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

  238. 	return

  239. }

  240. 

  241. // AppletAdd

  242. // @Summary    	 新增

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

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

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

  246. // @Accept       json

  247. // @Produce      json

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

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

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

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

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

  253. 	var req md.AppletAddReq

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

  255. 	if err != nil {

  256. 		err = validate.HandleValidateErr(err)

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

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

  259. 		return

  260. 	}

  261. 	masterId := svc.GetMasterId(c)

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

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

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

  265. 	if err != nil {

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

  267. 		return

  268. 	}

  269. 	if UserWxAppletList != nil {

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

  271. 		return

  272. 	}

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

  274. 		Name:                   req.Name,

  275. 		Logo:                   req.Logo,

  276. 		Appid:                  req.Appid,

  277. 		OriginalId:             req.OriginalId,

  278. 		AuthorizerRefreshToken: "",

  279. 		IsAuth:                 0,

  280. 		Uuid:                   masterId,

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

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

  283. 	})

  284. 	if err != nil {

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

  286. 		return

  287. 	}

  288. 

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

  290. 	return

  291. }

  292. 

  293. // AppletUpdate

  294. // @Summary    	 更新

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

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

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

  298. // @Accept       json

  299. // @Produce      json

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

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

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

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

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

  305. 	var req md.AppletUpdateReq

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

  307. 	if err != nil {

  308. 		err = validate.HandleValidateErr(err)

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

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

  311. 		return

  312. 	}

  313. 	masterId := svc.GetMasterId(c)

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

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

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

  317. 	if err != nil {

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

  319. 		return

  320. 	}

  321. 	if UserWxAppletList == nil {

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

  323. 		return

  324. 	}

  325. 	UserWxAppletList.Logo = req.Logo

  326. 	UserWxAppletList.Name = req.Name

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

  328. 	if err != nil {

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

  330. 		return

  331. 	}

  332. 

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

  334. 	return

  335. }

  336. 

  337. // AppletDelete

  338. // @Summary      删除

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

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

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

  342. // @Accept       json

  343. // @Produce      json

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

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

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

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

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

  349. 

  350. 	masterId := svc.GetMasterId(c)

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

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

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

  354. 	if err != nil {

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

  356. 		return

  357. 	}

  358. 	if UserWxAppletList == nil {

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

  360. 		return

  361. 	}

  362. 

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

  364. 	if err != nil {

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

  366. 		return

  367. 	}

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

  369. 	return

  370. }

  371. 

  372. // AppletAuthorize

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

  374. // @Tags         设置中心

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

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

  377. // @Accept       json

  378. // @Produce      json

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

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

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

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

  383. 	masterId := svc.GetMasterId(c)

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

  385. 	if cfg.Prd {

  386. 		url = "http://ad.zhios.cn/api/wxOpen/getPreAuthCode?master_id=" + masterId

  387. 	}

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

  389. 		"url": url,

  390. 	}, nil)

  391. 	return

  392. }

  393. 

  394. // AppletUnauthorized

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

  396. // @Tags         设置中心

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

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

  399. // @Accept       json

  400. // @Produce      json

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

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

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

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

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

  406. 	masterId := svc.GetMasterId(c)

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

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

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

  410. 	if err != nil {

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

  412. 		return

  413. 	}

  414. 	if UserWxAppletList == nil {

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

  416. 		return

  417. 	}

  418. 

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

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

  421. 	if err != nil {

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

  423. 		return

  424. 	}

  425. 	if wxOpenThirdPartyAppList == nil {

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

  427. 		return

  428. 	}

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

  430. 	if err != nil {

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

  432. 		return

  433. 	}

  434. 	err = wxApiService.DelAuthorize(appId)

  435. 	if err != nil {

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

  437. 		return

  438. 	}

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

  440. 	return

  441. }

  442. 

  443. // ShareIndex

  444. // @Summary    	 邀请链接

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

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

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

  448. // @Accept       json

  449. // @Produce      json

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

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

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

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

  454. 	masterId := svc.GetMasterId(c)

  455. 

  456. 	agent := new(model.UserAppDomain)

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

  458. 	if err != nil {

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

  460. 		return

  461. 	}

  462. 

  463. 	medium := new(model.UserAppDomain)

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

  465. 	if err != nil {

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

  467. 		return

  468. 	}

  469. 

  470. 	agentDomain := ""

  471. 	if agent != nil {

  472. 		agentDomain = agent.Domain

  473. 	}

  474. 	mediumDomain := ""

  475. 	if medium != nil {

  476. 		mediumDomain = medium.Domain

  477. 	}

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

  479. 		MasterId:     masterId,

  480. 		AgentDomain:  "https://" + agentDomain,

  481. 		MediumDomain: "https://" + mediumDomain,

  482. 	}, nil)

  483. 	return

  484. }

  485. 

  486. // SetMob

  487. // @Summary    	 mob设置

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

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

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

  491. // @Accept       json

  492. // @Produce      json

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

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

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

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

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

  498. 	var req md.SetMobReq

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

  500. 	if err != nil {

  501. 		err = validate.HandleValidateErr(err)

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

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

  504. 		return

  505. 	}

  506. 	masterId := svc.GetMasterId(c)

  507. 	engine := db.DBs[masterId]

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

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

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

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

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

  513. 	svc.ClearAllRedis(c, masterId)

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

  515. 	return

  516. }

  517. 

  518. // GetMob

  519. // @Summary    	 mob获取

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

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

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

  523. // @Accept       json

  524. // @Produce      json

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

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

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

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

  529. 	masterId := svc.GetMasterId(c)

  530. 	engine := db.DBs[masterId]

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

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

  533. 

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

  535. 		Data: md.SetMobReq{

  536. 			MobAppSecret: res["mob_app_secret"],

  537. 			MobAppKey:    res["mob_app_key"],

  538. 		},

  539. 	}, nil)

  540. 	return

  541. }

  542. 

  543. // SetLogo

  544. // @Summary    	 logo设置

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

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

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

  548. // @Accept       json

  549. // @Produce      json

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

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

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

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

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

  555. 	var req md.SetLogoReq

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

  557. 	if err != nil {

  558. 		err = validate.HandleValidateErr(err)

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

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

  561. 		return

  562. 	}

  563. 	masterId := svc.GetMasterId(c)

  564. 	engine := db.DBs[masterId]

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

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

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

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

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

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

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

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

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

  574. 	svc.ClearAllRedis(c, masterId)

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

  576. 	return

  577. }

  578. 

  579. // GetLogo

  580. // @Summary    	 logo获取

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

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

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

  584. // @Accept       json

  585. // @Produce      json

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

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

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

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

  590. 	masterId := svc.GetMasterId(c)

  591. 	engine := db.DBs[masterId]

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

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

  594. 

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

  596. 		Data: md.SetLogoReq{

  597. 			MediumLogo:      res["medium_logo"],

  598. 			AgentLogo:       res["agent_logo"],

  599. 			MediumLoginLogo: res["medium_login_logo"],

  600. 			AgentLoginLogo:  res["agent_login_logo"],

  601. 		},

  602. 	}, nil)

  603. 	return

  604. }

  605. 

  606. // SetSeo

  607. // @Summary    	 Seo设置

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

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

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

  611. // @Accept       json

  612. // @Produce      json

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

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

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

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

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

  618. 	var req md.SetSeoReq

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

  620. 	if err != nil {

  621. 		err = validate.HandleValidateErr(err)

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

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

  624. 		return

  625. 	}

  626. 	masterId := svc.GetMasterId(c)

  627. 	engine := db.DBs[masterId]

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

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

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

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

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

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

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

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

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

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

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

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

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

  641. 	svc.ClearAllRedis(c, masterId)

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

  643. 	return

  644. }

  645. 

  646. // GetSeo

  647. // @Summary    	 Seo获取

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

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

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

  651. // @Accept       json

  652. // @Produce      json

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

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

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

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

  657. 	masterId := svc.GetMasterId(c)

  658. 	engine := db.DBs[masterId]

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

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

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

  662. 		Data: md.SetSeoReq{

  663. 			SeoMediumTitle:   res["seo_medium_title"],

  664. 			SeoAgentTitle:    res["seo_agent_title"],

  665. 			SeoPlatformTitle: res["seo_platform_title"],

  666. 			SeoMediumLogo:    res["seo_medium_logo"],

  667. 			SeoAgentLogo:     res["seo_agent_logo"],

  668. 			SeoPlatformLogo:  res["seo_platform_logo"],

  669. 		},

  670. 	}, nil)

  671. 	return

  672. }

  673. 

  674. // AppletGetBlackList

  675. // @Summary    	 获取屏蔽的广告主

  676. // @Tags         设置中心-小程序设置-屏蔽规则

  677. // @Description  小程序设置-屏蔽规则-获取屏蔽的广告主

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

  679. // @Accept       json

  680. // @Produce      json

  681. // @Param        args 	body      md.AppletGetBlackListReq   true   "请求参数"

  682. // @Success      200   {object}	  md2.AgencyGetBlackListResp

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

  684. // @Router       /api/setCenter/basic/applet/shieldRules/getBlackList [POST]

  685. func AppletGetBlackList(c *gin.Context) {

  686. 	var req md.AppletGetBlackListReq

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

  688. 	if err != nil {

  689. 		err = validate.HandleValidateErr(err)

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

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

  692. 		return

  693. 	}

  694. 

  695. 	masterId := svc.GetMasterId(c)

  696. 

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

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

  699. 	if err != nil {

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

  701. 		return

  702. 	}

  703. 	if wxOpenThirdPartyAppList == nil {

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

  705. 		return

  706. 	}

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

  708. 	if err != nil {

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

  710. 		return

  711. 	}

  712. 	var resp md2.AgencyGetBlackListResp

  713. 	err, resp = wxApiService.GetBlackList(req.Appid)

  714. 	if err != nil {

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

  716. 		return

  717. 	}

  718. 	e.OutSuc(c, resp, nil)

  719. 	return

  720. }

  721. 

  722. // AppletAddBlackList

  723. // @Summary    	 添加屏蔽的广告主

  724. // @Tags         设置中心-小程序设置-屏蔽规则

  725. // @Description  小程序设置-屏蔽规则-添加屏蔽的广告主

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

  727. // @Accept       json

  728. // @Produce      json

  729. // @Param        args 	body      md.AppletAddBlackListReq   true   "请求参数"

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

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

  732. // @Router       /api/setCenter/basic/applet/shieldRules/addBlackList [POST]

  733. func AppletAddBlackList(c *gin.Context) {

  734. 	var req md.AppletAddBlackListReq

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

  736. 	if err != nil {

  737. 		err = validate.HandleValidateErr(err)

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

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

  740. 		return

  741. 	}

  742. 

  743. 	masterId := svc.GetMasterId(c)

  744. 

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

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

  747. 	if err != nil {

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

  749. 		return

  750. 	}

  751. 	if wxOpenThirdPartyAppList == nil {

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

  753. 		return

  754. 	}

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

  756. 	if err != nil {

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

  758. 		return

  759. 	}

  760. 	listStr, _ := json.Marshal([]interface{}{

  761. 		map[string]interface{}{

  762. 			"type": req.Kind,

  763. 			"id":   req.Id,

  764. 		},

  765. 	})

  766. 	err = wxApiService.SetBlackList(req.Appid, 1, string(listStr))

  767. 	if err != nil {

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

  769. 		return

  770. 	}

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

  772. 	return

  773. }

  774. 

  775. // AppletDelBlackList

  776. // @Summary    	 删除屏蔽的广告主

  777. // @Tags         设置中心-小程序设置-屏蔽规则

  778. // @Description  小程序设置-屏蔽规则-删除屏蔽的广告主

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

  780. // @Accept       json

  781. // @Produce      json

  782. // @Param        args 	body      md.AppletDelBlackListReq   true   "请求参数"

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

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

  785. // @Router       /api/setCenter/basic/applet/shieldRules/delBlackList [POST]

  786. func AppletDelBlackList(c *gin.Context) {

  787. 	var req md.AppletDelBlackListReq

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

  789. 	if err != nil {

  790. 		err = validate.HandleValidateErr(err)

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

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

  793. 		return

  794. 	}

  795. 

  796. 	masterId := svc.GetMasterId(c)

  797. 

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

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

  800. 	if err != nil {

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

  802. 		return

  803. 	}

  804. 	if wxOpenThirdPartyAppList == nil {

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

  806. 		return

  807. 	}

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

  809. 	if err != nil {

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

  811. 		return

  812. 	}

  813. 	listStr, _ := json.Marshal([]interface{}{

  814. 		map[string]interface{}{

  815. 			"type": req.Kind,

  816. 			"id":   req.Id,

  817. 		},

  818. 	})

  819. 	err = wxApiService.SetBlackList(req.Appid, 2, string(listStr))

  820. 	if err != nil {

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

  822. 		return

  823. 	}

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

  825. 	return

  826. }

  827. 

  828. // AppletGetAmsCategoryBlackList

  829. // @Summary    	 获取行业屏蔽信息

  830. // @Tags         设置中心-小程序设置-屏蔽规则

  831. // @Description  小程序设置-屏蔽规则-获取行业屏蔽信息

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

  833. // @Accept       json

  834. // @Produce      json

  835. // @Param        args 	body      md.AppletGetAmsCategoryBlackListReq   true   "请求参数"

  836. // @Success      200   {object}	  md.AppletGetAmsCategoryBlackListResp

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

  838. // @Router       /api/setCenter/basic/applet/shieldRules/getAmsCategoryBlackList [POST]

  839. func AppletGetAmsCategoryBlackList(c *gin.Context) {

  840. 	var req md.AppletGetAmsCategoryBlackListReq

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

  842. 	if err != nil {

  843. 		err = validate.HandleValidateErr(err)

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

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

  846. 		return

  847. 	}

  848. 

  849. 	masterId := svc.GetMasterId(c)

  850. 

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

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

  853. 	if err != nil {

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

  855. 		return

  856. 	}

  857. 	if wxOpenThirdPartyAppList == nil {

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

  859. 		return

  860. 	}

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

  862. 	if err != nil {

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

  864. 		return

  865. 	}

  866. 	var data md2.GetAmsCategoryBlackListResp

  867. 	err, data = wxApiService.GetAmsCategoryBlackList(req.Appid)

  868. 	if err != nil {

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

  870. 		return

  871. 	}

  872. 

  873. 	var resp md.AppletGetAmsCategoryBlackListResp

  874. 	amsCategoryArr := strings.Split(data.AmsCategory, "|")

  875. 	for _, v := range amsCategoryArr {

  876. 		resp.CheckedAmsCategory = append(resp.CheckedAmsCategory, struct {

  877. 			Value string `json:"value" example:"行业标识符"`

  878. 			Name  string `json:"name" example:"行业名称"`

  879. 		}{

  880. 			Value: v,

  881. 			Name:  enum.AmsCategory.String(enum.AmsCategory(v)),

  882. 		})

  883. 	}

  884. 	resp.AllAmsCategory = []struct {

  885. 		Value string `json:"value" example:"行业标识符"`

  886. 		Name  string `json:"name" example:"行业名称"`

  887. 	}{

  888. 		{

  889. 			Value: enum.AmsCategoryForChess,

  890. 			Name:  enum.AmsCategory.String(enum.AmsCategoryForChess),

  891. 		},

  892. 		{

  893. 			Value: enum.AmsCategoryForAdultSupplies,

  894. 			Name:  enum.AmsCategory.String(enum.AmsCategoryForAdultSupplies),

  895. 		},

  896. 		{

  897. 			Value: enum.AmsCategoryForMEDICALHEALTH,

  898. 			Name:  enum.AmsCategory.String(enum.AmsCategoryForMEDICALHEALTH),

  899. 		},

  900. 		{

  901. 			Value: enum.AmsCategoryForINSURANCE,

  902. 			Name:  enum.AmsCategory.String(enum.AmsCategoryForINSURANCE),

  903. 		},

  904. 		{

  905. 			Value: enum.AmsCategoryForSECURITES,

  906. 			Name:  enum.AmsCategory.String(enum.AmsCategoryForSECURITES),

  907. 		},

  908. 		{

  909. 			Value: enum.AmsCategoryForLOAN,

  910. 			Name:  enum.AmsCategory.String(enum.AmsCategoryForLOAN),

  911. 		},

  912. 		{

  913. 			Value: enum.AmsCategoryForLIVINGSERVICESBEAUTY,

  914. 			Name:  enum.AmsCategory.String(enum.AmsCategoryForLIVINGSERVICESBEAUTY),

  915. 		},

  916. 		{

  917. 			Value: enum.AmsCategoryForLIVINGSERVICESENTERTAINMENT,

  918. 			Name:  enum.AmsCategory.String(enum.AmsCategoryForLIVINGSERVICESENTERTAINMENT),

  919. 		},

  920. 		{

  921. 			Value: enum.AmsCategoryForLIVINGSERVICESOTHERS,

  922. 			Name:  enum.AmsCategory.String(enum.AmsCategoryForLIVINGSERVICESOTHERS),

  923. 		},

  924. 		{

  925. 			Value: enum.AmsCategoryForFOODINDUSTRY,

  926. 			Name:  enum.AmsCategory.String(enum.AmsCategoryForFOODINDUSTRY),

  927. 		},

  928. 		{

  929. 			Value: enum.AmsCategoryForRETAILANDGENERALMERCHANDISE,

  930. 			Name:  enum.AmsCategory.String(enum.AmsCategoryForRETAILANDGENERALMERCHANDISE),

  931. 		},

  932. 		{

  933. 			Value: enum.AmsCategoryForFOODANDDRINK,

  934. 			Name:  enum.AmsCategory.String(enum.AmsCategoryForFOODANDDRINK),

  935. 		},

  936. 		{

  937. 			Value: enum.AmsCategoryForTECHNICALSERVICE,

  938. 			Name:  enum.AmsCategory.String(enum.AmsCategoryForTECHNICALSERVICE),

  939. 		},

  940. 	}

  941. 

  942. 	e.OutSuc(c, resp, nil)

  943. 	return

  944. }

  945. 

  946. // AppletSetAmsCategoryBlackList

  947. // @Summary    	 设置行业屏蔽信息

  948. // @Tags         设置中心-小程序设置-屏蔽规则

  949. // @Description  小程序设置-屏蔽规则-设置行业屏蔽信息

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

  951. // @Accept       json

  952. // @Produce      json

  953. // @Param        args 	body      md.AppletSetAmsCategoryBlackListReq   true   "请求参数"

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

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

  956. // @Router       /api/setCenter/basic/applet/shieldRules/setAmsCategoryBlackList [POST]

  957. func AppletSetAmsCategoryBlackList(c *gin.Context) {

  958. 	var req md.AppletSetAmsCategoryBlackListReq

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

  960. 	if err != nil {

  961. 		err = validate.HandleValidateErr(err)

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

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

  964. 		return

  965. 	}

  966. 

  967. 	masterId := svc.GetMasterId(c)

  968. 

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

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

  971. 	if err != nil {

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

  973. 		return

  974. 	}

  975. 	if wxOpenThirdPartyAppList == nil {

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

  977. 		return

  978. 	}

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

  980. 	if err != nil {

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

  982. 		return

  983. 	}

  984. 

  985. 	amsCategory := strings.Join(req.CheckedAmsCategory, "|")

  986. 	err = wxApiService.SetAmsCategoryBlackList(req.Appid, amsCategory)

  987. 	if err != nil {

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

  989. 		return

  990. 	}

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

  992. 	return

  993. }