base.go 43 KB

1234567891011121314151617181920212223242526272829303132333435363738394041424344454647484950515253545556575859606162636465666768697071727374757677787980818283848586878889909192939495969798991001011021031041051061071081091101111121131141151161171181191201211221231241251261271281291301311321331341351361371381391401411421431441451461471481491501511521531541551561571581591601611621631641651661671681691701711721731741751761771781791801811821831841851861871881891901911921931941951961971981992002012022032042052062072082092102112122132142152162172182192202212222232242252262272282292302312322332342352362372382392402412422432442452462472482492502512522532542552562572582592602612622632642652662672682692702712722732742752762772782792802812822832842852862872882892902912922932942952962972982993003013023033043053063073083093103113123133143153163173183193203213223233243253263273283293303313323333343353363373383393403413423433443453463473483493503513523533543553563573583593603613623633643653663673683693703713723733743753763773783793803813823833843853863873883893903913923933943953963973983994004014024034044054064074084094104114124134144154164174184194204214224234244254264274284294304314324334344354364374384394404414424434444454464474484494504514524534544554564574584594604614624634644654664674684694704714724734744754764774784794804814824834844854864874884894904914924934944954964974984995005015025035045055065075085095105115125135145155165175185195205215225235245255265275285295305315325335345355365375385395405415425435445455465475485495505515525535545555565575585595605615625635645655665675685695705715725735745755765775785795805815825835845855865875885895905915925935945955965975985996006016026036046056066076086096106116126136146156166176186196206216226236246256266276286296306316326336346356366376386396406416426436446456466476486496506516526536546556566576586596606616626636646656666676686696706716726736746756766776786796806816826836846856866876886896906916926936946956966976986997007017027037047057067077087097107117127137147157167177187197207217227237247257267277287297307317327337347357367377387397407417427437447457467477487497507517527537547557567577587597607617627637647657667677687697707717727737747757767777787797807817827837847857867877887897907917927937947957967977987998008018028038048058068078088098108118128138148158168178188198208218228238248258268278288298308318328338348358368378388398408418428438448458468478488498508518528538548558568578588598608618628638648658668678688698708718728738748758768778788798808818828838848858868878888898908918928938948958968978988999009019029039049059069079089099109119129139149159169179189199209219229239249259269279289299309319329339349359369379389399409419429439449459469479489499509519529539549559569579589599609619629639649659669679689699709719729739749759769779789799809819829839849859869879889899909919929939949959969979989991000100110021003100410051006100710081009101010111012101310141015101610171018101910201021102210231024102510261027102810291030103110321033103410351036103710381039104010411042104310441045104610471048104910501051105210531054105510561057105810591060106110621063106410651066106710681069107010711072107310741075107610771078107910801081108210831084108510861087108810891090109110921093109410951096109710981099110011011102110311041105110611071108110911101111111211131114111511161117111811191120112111221123112411251126112711281129113011311132113311341135113611371138113911401141114211431144114511461147114811491150115111521153115411551156115711581159116011611162116311641165116611671168116911701171117211731174117511761177117811791180118111821183118411851186118711881189119011911192119311941195119611971198119912001201120212031204120512061207120812091210121112121213121412151216121712181219122012211222122312241225122612271228122912301231123212331234123512361237123812391240124112421243124412451246124712481249125012511252125312541255125612571258125912601261126212631264126512661267126812691270127112721273127412751276127712781279128012811282128312841285128612871288128912901291129212931294129512961297129812991300130113021303130413051306130713081309131013111312131313141315131613171318131913201321132213231324132513261327132813291330133113321333133413351336
  1. package grpc
  2. import (
  3. "context"
  4. "encoding/json"
  5. pb "sportfitness/base/api/grpc/base"
  6. "sportfitness/base/assembly/base/service"
  7. "sportfitness/base/errors"
  8. "sportfitness/base/global"
  9. "strings"
  10. "time"
  11. "google.golang.org/grpc/metadata"
  12. )
  13. type Api struct {
  14. pb.UnimplementedApiServer
  15. }
  16. func (Api) getRemoteIp(ctx context.Context) string {
  17. if md, ok := metadata.FromIncomingContext(ctx); ok {
  18. ip := md.Get("x-forwarded-for")
  19. if len(ip) > 0 {
  20. return ip[0]
  21. }
  22. }
  23. return ""
  24. }
  25. func (Api) getUserAgent(ctx context.Context) string {
  26. if md, ok := metadata.FromIncomingContext(ctx); ok {
  27. agents := md.Get("user-agent")
  28. return strings.Join(agents, "\n")
  29. }
  30. return ""
  31. }
  32. func (Api) getToken(ctx context.Context) (token string) {
  33. if md, ok := metadata.FromIncomingContext(ctx); ok {
  34. sl := md.Get("Token")
  35. if len(sl) >= 1 {
  36. token = sl[0]
  37. }
  38. }
  39. return
  40. }
  41. func (Api) checkRs(rs string) bool {
  42. b := false
  43. rsMap := make(map[string]interface{})
  44. err := json.Unmarshal([]byte(rs), &rsMap)
  45. if err != nil {
  46. panic(errors.J2MError)
  47. }
  48. code := int(rsMap["code"].(float64))
  49. if code == 0 {
  50. b = true
  51. } else {
  52. b = false
  53. }
  54. return b
  55. }
  56. // webToGoVerify 前端入Go验证签名函数,只允许StandardRequest进行验证
  57. func (a Api) webToGoVerify(ctx context.Context, q *pb.StandardRequest) (string, *pb.StandardRequest, string) {
  58. token := a.getToken(ctx)
  59. //wtgStr = q.JsonStr
  60. wtgSign := q.Sign // 生成新签名
  61. return token, q, wtgSign
  62. }
  63. // courseToGoVerify 前端入Go验证签名函数,只允许StandardRequest进行验证
  64. func (a Api) courseToGoVerify(ctx context.Context, q *pb.CourseStandardRequest) (string, *pb.CourseStandardRequest, string) {
  65. token := a.getToken(ctx)
  66. //wtgStr = q.JsonStr
  67. wtgSign := q.Sign // 生成新签名
  68. return token, q, wtgSign
  69. }
  70. func (Api) goToWebSigner(content string) (gtwStr, gtwSign string) {
  71. gtwStr = content
  72. gtwSign = ""
  73. return
  74. }
  75. func (a Api) toWebFunc(content string) *pb.StandardReply {
  76. gtwStr, gtwSign := a.goToWebSigner(content) // 空函数,go透传给前台数据时生成签名
  77. return &pb.StandardReply{
  78. JsonRst: gtwStr,
  79. Sign: gtwSign,
  80. }
  81. }
  82. func (a Api) SignIn(ctx context.Context, q *pb.SignInRequest) (*pb.SignInReply, error) {
  83. token := service.User{}.SignInUserCodePassword(
  84. q.Name, q.Password, a.getRemoteIp(ctx), a.getUserAgent(ctx), q.CodeId, q.VerifyCode)
  85. return &pb.SignInReply{Token: token}, nil
  86. }
  87. func (a Api) GenVerifyImage(ctx context.Context, q *pb.GenVerifyImageRequest) (*pb.GenVerifyImageReply, error) {
  88. codeId, imageBase64 := service.User{}.GenVerifyImage(q.Height, q.Width)
  89. return &pb.GenVerifyImageReply{ImageBase64: imageBase64, CodeId: codeId}, nil
  90. }
  91. func (a Api) SignOut(ctx context.Context, q *pb.DefaultRequest) (*pb.DefaultReply, error) {
  92. token := a.getToken(ctx)
  93. service.User{}.SignOut(token)
  94. return &pb.DefaultReply{}, nil
  95. }
  96. //func (a Api) SignUpInWithPhone() {
  97. //
  98. //}
  99. // ----------------------- 商家信息管理 ---------------------------------------------
  100. // AcrossUserSimpleQuery 可跨店会员简单查询
  101. func (a Api) AcrossUserSimpleQuery(ctx context.Context, r *pb.StandardRequest) (*pb.StandardReply, error) {
  102. // 获取token,并验证签名函数
  103. token, q, sign := a.webToGoVerify(ctx, r)
  104. rs := service.User{}.AcrossUserSimpleQuery(token, q.ShopID, q.JsonStr, sign)
  105. rst := a.toWebFunc(rs)
  106. return rst, nil
  107. }
  108. // VipUserSimpleQuery 会员简单查询
  109. func (a Api) VipUserSimpleQuery(ctx context.Context, r *pb.StandardRequest) (*pb.StandardReply, error) {
  110. // 获取token,并验证签名函数
  111. token, q, sign := a.webToGoVerify(ctx, r)
  112. rs := service.User{}.VipUserSimpleQuery(token, q.ShopID, q.JsonStr, sign)
  113. rst := a.toWebFunc(rs)
  114. return rst, nil
  115. }
  116. // TempVipUserSimpleQuery 临时会员简单查询
  117. func (a Api) TempVipUserSimpleQuery(ctx context.Context, r *pb.StandardRequest) (*pb.StandardReply, error) {
  118. // 获取token,并验证签名函数
  119. token, q, sign := a.webToGoVerify(ctx, r)
  120. rs := service.User{}.TempVipUserSimpleQuery(token, q.ShopID, q.JsonStr, sign)
  121. rst := a.toWebFunc(rs)
  122. return rst, nil
  123. }
  124. // ClassSimpleQuery 课目简单查询
  125. func (a Api) ClassSimpleQuery(ctx context.Context, r *pb.StandardRequest) (*pb.StandardReply, error) {
  126. // 获取token,并验证签名函数
  127. token, q, sign := a.webToGoVerify(ctx, r)
  128. rs := service.Class{}.ClassSimpleQuery(token, q.ShopID, q.JsonStr, sign)
  129. rst := a.toWebFunc(rs)
  130. return rst, nil
  131. }
  132. // SelectHrSensors 心率带简单查询
  133. func (a Api) SelectHrSensors(ctx context.Context, r *pb.StandardRequest) (*pb.StandardReply, error) {
  134. // 获取token,并验证签名函数
  135. token, q, sign := a.webToGoVerify(ctx, r)
  136. rs := service.Hr{}.SelectHrSensors(token, q.ShopID, q.JsonStr, sign)
  137. rst := a.toWebFunc(rs)
  138. return rst, nil
  139. }
  140. // GroupSimpleQueryByShopID 商家分组简单查询-通过商家自己ID查询
  141. func (a Api) GroupSimpleQueryByShopID(ctx context.Context, r *pb.StandardRequest) (*pb.StandardReply, error) {
  142. // 获取token,并验证签名函数
  143. token, q, sign := a.webToGoVerify(ctx, r)
  144. rs := service.Shop{}.GroupSimpleQueryByShopID(token, q.ShopID, q.JsonStr, sign)
  145. rst := a.toWebFunc(rs)
  146. return rst, nil
  147. }
  148. // EqSimpleQuery 商家分组简单查询-通过商家自己ID查询
  149. func (a Api) EqSimpleQuery(ctx context.Context, r *pb.StandardRequest) (*pb.StandardReply, error) {
  150. // 获取token,并验证签名函数
  151. token, q, sign := a.webToGoVerify(ctx, r)
  152. rs := service.Shop{}.EqSimpleQuery(token, q.ShopID, q.JsonStr, sign)
  153. rst := a.toWebFunc(rs)
  154. return rst, nil
  155. }
  156. // ----------------------- 商家信息管理 ---------------------------------------------
  157. func (a Api) ManageableShopList(ctx context.Context, r *pb.ShopListRequest) (*pb.ShopListReply, error) {
  158. token := a.getToken(ctx)
  159. rs := service.Shop{}.ManageableShopList(token, r)
  160. return rs, nil
  161. }
  162. func (a Api) ManageableGetShopInfo(ctx context.Context, r *pb.ShopDetailRequest) (*pb.ShopInfo, error) {
  163. token := a.getToken(ctx)
  164. rs := service.Shop{}.ManageableGetShopInfo(token, r)
  165. return rs, nil
  166. }
  167. func (a Api) ShopLicenseList(ctx context.Context, r *pb.ShopDetailRequest) (*pb.LicenseList, error) {
  168. token := a.getToken(ctx)
  169. rs := service.Shop{}.ShopLicenseList(token, r)
  170. return rs, nil
  171. }
  172. //func (a Api) ShopLicenseTypeMap(ctx context.Context, r *pb.IdList) (*pb.LicenseTypeMapReply, error) {
  173. // token := a.getToken(ctx)
  174. //
  175. // _ = service.Shop{}.LicenseTypeMap(token, r)
  176. //
  177. // return nil, nil
  178. //}
  179. // ShopGroupQuery 商家跨店分组查询
  180. func (a Api) ShopGroupQuery(ctx context.Context, r *pb.StandardRequest) (*pb.StandardReply, error) {
  181. // 获取token,并验证签名函数
  182. token, q, sign := a.webToGoVerify(ctx, r)
  183. rs := service.Shop{}.ShopGroupQuery(token, q.ShopID, q.JsonStr, sign)
  184. rst := a.toWebFunc(rs)
  185. return rst, nil
  186. }
  187. // GetShopNavi 查询商家栏目:分级查询,查询一级菜单parentId传入0
  188. func (a Api) GetShopNavi(ctx context.Context, r *pb.GetShopNaviRequest) (*pb.GetShopNaviReply, error) {
  189. token := a.getToken(ctx)
  190. rs := service.Shop{}.GetShopNavi(token, r)
  191. return rs, nil
  192. }
  193. // GetShopNaviAll 查询商家全部栏目
  194. func (a Api) GetShopNaviAll(ctx context.Context, r *pb.GetShopNaviAllRequest) (*pb.GetShopNaviAllReply, error) {
  195. token := a.getToken(ctx)
  196. rs := service.Shop{}.GetShopNaviAll(token, r)
  197. return rs, nil
  198. }
  199. // ShopGroupAdd 商家跨店分组添加
  200. func (a Api) ShopGroupAdd(ctx context.Context, r *pb.StandardRequest) (*pb.StandardReply, error) {
  201. // 获取token,并验证签名函数
  202. token, q, sign := a.webToGoVerify(ctx, r)
  203. rs := service.Shop{}.ShopGroupAdd(token, q.ShopID, q.JsonStr, sign)
  204. rst := a.toWebFunc(rs)
  205. return rst, nil
  206. }
  207. // ShopGroupEdit 商家跨店分组编辑
  208. func (a Api) ShopGroupEdit(ctx context.Context, r *pb.StandardRequest) (*pb.StandardReply, error) {
  209. // 获取token,并验证签名函数
  210. token, q, sign := a.webToGoVerify(ctx, r)
  211. rs := service.Shop{}.ShopGroupEdit(token, q.ShopID, q.JsonStr, sign)
  212. rst := a.toWebFunc(rs)
  213. return rst, nil
  214. }
  215. // ShopGroupStatusEdit 商家跨店分组状态修改
  216. func (a Api) ShopGroupStatusEdit(ctx context.Context, r *pb.StandardRequest) (*pb.StandardReply, error) {
  217. // 获取token,并验证签名函数
  218. token, q, sign := a.webToGoVerify(ctx, r)
  219. rs := service.Shop{}.ShopGroupStatusEdit(token, q.ShopID, q.JsonStr, sign)
  220. rst := a.toWebFunc(rs)
  221. return rst, nil
  222. }
  223. // ShopGroupDetailsQuery 跨店分组详情查询
  224. func (a Api) ShopGroupDetailsQuery(ctx context.Context, r *pb.StandardRequest) (*pb.StandardReply, error) {
  225. // 获取token,并验证签名函数
  226. token, q, sign := a.webToGoVerify(ctx, r)
  227. rs := service.Shop{}.ShopGroupDetailsQuery(token, q.ShopID, q.JsonStr, sign)
  228. rst := a.toWebFunc(rs)
  229. return rst, nil
  230. }
  231. // ShopVenueQuery 商家区域查询
  232. func (a Api) ShopVenueQuery(ctx context.Context, r *pb.StandardRequest) (*pb.StandardReply, error) {
  233. // 获取token,并验证签名函数
  234. token, q, sign := a.webToGoVerify(ctx, r)
  235. rs := service.Shop{}.ShopVenueQuery(token, q.ShopID, q.JsonStr, sign)
  236. rst := a.toWebFunc(rs)
  237. return rst, nil
  238. }
  239. // ShopVenueAdd 商家区域添加
  240. func (a Api) ShopVenueAdd(ctx context.Context, r *pb.StandardRequest) (*pb.StandardReply, error) {
  241. // 获取token,并验证签名函数
  242. token, q, sign := a.webToGoVerify(ctx, r)
  243. rs := service.Shop{}.ShopVenueAdd(token, q.ShopID, q.JsonStr, sign)
  244. rst := a.toWebFunc(rs)
  245. return rst, nil
  246. }
  247. // ShopVenueEdit 商家区域编辑
  248. func (a Api) ShopVenueEdit(ctx context.Context, r *pb.StandardRequest) (*pb.StandardReply, error) {
  249. // 获取token,并验证签名函数
  250. token, q, sign := a.webToGoVerify(ctx, r)
  251. rs := service.Shop{}.ShopVenueEdit(token, q.ShopID, q.JsonStr, sign)
  252. rst := a.toWebFunc(rs)
  253. return rst, nil
  254. }
  255. // ShopVenueStatusEdit 商家区域状态修改
  256. func (a Api) ShopVenueStatusEdit(ctx context.Context, r *pb.StandardRequest) (*pb.StandardReply, error) {
  257. // 获取token,并验证签名函数
  258. token, q, sign := a.webToGoVerify(ctx, r)
  259. rs := service.Shop{}.ShopVenueStatusEdit(token, q.ShopID, q.JsonStr, sign)
  260. rst := a.toWebFunc(rs)
  261. return rst, nil
  262. }
  263. // ShopVenueEquipQuery 商家设备查询
  264. func (a Api) ShopVenueEquipQuery(ctx context.Context, r *pb.StandardRequest) (*pb.StandardReply, error) {
  265. // 获取token,并验证签名函数
  266. token, q, sign := a.webToGoVerify(ctx, r)
  267. rs := service.Shop{}.ShopVenueEquipQuery(token, q.ShopID, q.JsonStr, sign)
  268. rst := a.toWebFunc(rs)
  269. return rst, nil
  270. }
  271. // ShopVenueEquipEdit 商家设备编辑
  272. func (a Api) ShopVenueEquipEdit(ctx context.Context, r *pb.StandardRequest) (*pb.StandardReply, error) {
  273. // 获取token,并验证签名函数
  274. token, q, sign := a.webToGoVerify(ctx, r)
  275. rs := service.Shop{}.ShopVenueEquipEdit(token, q.ShopID, q.JsonStr, sign)
  276. rst := a.toWebFunc(rs)
  277. return rst, nil
  278. }
  279. // ShopVenueEquipStatusEdit 商家设备状态修改
  280. func (a Api) ShopVenueEquipStatusEdit(ctx context.Context, r *pb.StandardRequest) (*pb.StandardReply, error) {
  281. // 获取token,并验证签名函数
  282. token, q, sign := a.webToGoVerify(ctx, r)
  283. rs := service.Shop{}.ShopVenueEquipStatusEdit(token, q.ShopID, q.JsonStr, sign)
  284. rst := a.toWebFunc(rs)
  285. return rst, nil
  286. }
  287. // ShopVenueEquipStatusDel 商家设备删除
  288. func (a Api) ShopVenueEquipStatusDel(ctx context.Context, r *pb.StandardRequest) (*pb.StandardReply, error) {
  289. // 获取token,并验证签名函数
  290. token, q, sign := a.webToGoVerify(ctx, r)
  291. rs := service.Shop{}.ShopVenueEquipStatusEdit(token, q.ShopID, q.JsonStr, sign)
  292. rst := a.toWebFunc(rs)
  293. return rst, nil
  294. }
  295. // ShopConfigQuery 商家配置查询
  296. func (a Api) ShopConfigQuery(ctx context.Context, r *pb.StandardRequest) (*pb.StandardReply, error) {
  297. // 获取token,并验证签名函数
  298. token, q, sign := a.webToGoVerify(ctx, r)
  299. rs := service.Shop{}.ShopConfigQuery(token, q.ShopID, q.JsonStr, sign)
  300. rst := a.toWebFunc(rs)
  301. return rst, nil
  302. }
  303. // ShopConfigEdit 商家配置编辑
  304. func (a Api) ShopConfigEdit(ctx context.Context, r *pb.StandardRequest) (*pb.StandardReply, error) {
  305. // 获取token,并验证签名函数
  306. token, q, sign := a.webToGoVerify(ctx, r)
  307. rs := service.Shop{}.ShopConfigEdit(token, q.ShopID, q.JsonStr, sign)
  308. rst := a.toWebFunc(rs)
  309. return rst, nil
  310. }
  311. // --------------------------商家会员管理----------------------------------------------------
  312. // ShopVipUserQuery 商家会员查询
  313. func (a Api) ShopVipUserQuery(ctx context.Context, r *pb.StandardRequest) (*pb.StandardReply, error) {
  314. // 获取token,并验证签名函数
  315. token, q, sign := a.webToGoVerify(ctx, r)
  316. rs := service.User{}.ShopVipUserQuery(token, q.ShopID, q.JsonStr, sign)
  317. rst := a.toWebFunc(rs)
  318. return rst, nil
  319. }
  320. // ShopVipUserAdd 商家会员添加
  321. func (a Api) ShopVipUserAdd(ctx context.Context, r *pb.StandardRequest) (*pb.StandardReply, error) {
  322. // 获取token,并验证签名函数
  323. token, q, sign := a.webToGoVerify(ctx, r)
  324. rs := service.User{}.ShopVipUserAdd(token, q.ShopID, q.JsonStr, sign)
  325. rst := a.toWebFunc(rs)
  326. return rst, nil
  327. }
  328. // ShopVipUserEdit 商家会员编辑
  329. func (a Api) ShopVipUserEdit(ctx context.Context, r *pb.StandardRequest) (*pb.StandardReply, error) {
  330. // 获取token,并验证签名函数
  331. token, q, sign := a.webToGoVerify(ctx, r)
  332. rs := service.User{}.ShopVipUserEdit(token, q.ShopID, q.JsonStr, sign)
  333. rst := a.toWebFunc(rs)
  334. return rst, nil
  335. }
  336. // ShopVipUserStatusEdit 商家会员状态编辑
  337. func (a Api) ShopVipUserStatusEdit(ctx context.Context, r *pb.StandardRequest) (*pb.StandardReply, error) {
  338. // 获取token,并验证签名函数
  339. token, q, sign := a.webToGoVerify(ctx, r)
  340. rs := service.User{}.ShopVipUserStatusEdit(token, q.ShopID, q.JsonStr, sign)
  341. rst := a.toWebFunc(rs)
  342. return rst, nil
  343. }
  344. // AcrossVipUserQuery 跨店会员查询
  345. func (a Api) AcrossVipUserQuery(ctx context.Context, r *pb.StandardRequest) (*pb.StandardReply, error) {
  346. // 获取token,并验证签名函数
  347. token, q, sign := a.webToGoVerify(ctx, r)
  348. rs := service.User{}.AcrossVipUserQuery(token, q.ShopID, q.JsonStr, sign)
  349. rst := a.toWebFunc(rs)
  350. return rst, nil
  351. }
  352. // AcrossVipUserAdd 跨店会员添加
  353. func (a Api) AcrossVipUserAdd(ctx context.Context, r *pb.StandardRequest) (*pb.StandardReply, error) {
  354. // 获取token,并验证签名函数
  355. token, q, sign := a.webToGoVerify(ctx, r)
  356. rs := service.User{}.AcrossVipUserQuery(token, q.ShopID, q.JsonStr, sign)
  357. rst := a.toWebFunc(rs)
  358. return rst, nil
  359. }
  360. // AcrossVipUserDel 跨店会员删除
  361. func (a Api) AcrossVipUserDel(ctx context.Context, r *pb.StandardRequest) (*pb.StandardReply, error) {
  362. // 获取token,并验证签名函数
  363. token, q, sign := a.webToGoVerify(ctx, r)
  364. rs := service.User{}.AcrossVipUserDel(token, q.ShopID, q.JsonStr, sign)
  365. rst := a.toWebFunc(rs)
  366. return rst, nil
  367. }
  368. // VipPhoneQuery 商家会员手机号查询
  369. func (a Api) VipPhoneQuery(ctx context.Context, r *pb.StandardRequest) (*pb.StandardReply, error) {
  370. // 获取token,并验证签名函数
  371. token, q, sign := a.webToGoVerify(ctx, r)
  372. rs := service.User{}.VipPhoneQuery(token, q.ShopID, q.JsonStr, sign)
  373. rst := a.toWebFunc(rs)
  374. return rst, nil
  375. }
  376. // VipMainPhoneCheck 商家会员主手机号校验
  377. func (a Api) VipMainPhoneCheck(ctx context.Context, r *pb.StandardRequest) (*pb.StandardReply, error) {
  378. // 获取token,并验证签名函数
  379. token, q, sign := a.webToGoVerify(ctx, r)
  380. rs := service.User{}.VipMainPhoneCheck(token, q.ShopID, q.JsonStr, sign)
  381. rst := a.toWebFunc(rs)
  382. return rst, nil
  383. }
  384. // VipOtherPhoneAdd 商家会员其他手机号添加
  385. func (a Api) VipOtherPhoneAdd(ctx context.Context, r *pb.StandardRequest) (*pb.StandardReply, error) {
  386. // 获取token,并验证签名函数
  387. token, q, sign := a.webToGoVerify(ctx, r)
  388. rs := service.User{}.VipOtherPhoneAdd(token, q.ShopID, q.JsonStr, sign)
  389. rst := a.toWebFunc(rs)
  390. return rst, nil
  391. }
  392. // VipOtherPhoneEdit 商家会员其他手机号编辑
  393. func (a Api) VipOtherPhoneEdit(ctx context.Context, r *pb.StandardRequest) (*pb.StandardReply, error) {
  394. // 获取token,并验证签名函数
  395. token, q, sign := a.webToGoVerify(ctx, r)
  396. rs := service.User{}.VipOtherPhoneEdit(token, q.ShopID, q.JsonStr, sign)
  397. rst := a.toWebFunc(rs)
  398. return rst, nil
  399. }
  400. // VipOtherPhoneStatusEdit 商家会员其他手机号状态修改
  401. func (a Api) VipOtherPhoneStatusEdit(ctx context.Context, r *pb.StandardRequest) (*pb.StandardReply, error) {
  402. // 获取token,并验证签名函数
  403. token, q, sign := a.webToGoVerify(ctx, r)
  404. rs := service.User{}.VipOtherPhoneStatusEdit(token, q.ShopID, q.JsonStr, sign)
  405. rst := a.toWebFunc(rs)
  406. return rst, nil
  407. }
  408. // TempVipUserQuery 商家临时会员查询
  409. func (a Api) TempVipUserQuery(ctx context.Context, r *pb.StandardRequest) (*pb.StandardReply, error) {
  410. // 获取token,并验证签名函数
  411. token, q, sign := a.webToGoVerify(ctx, r)
  412. rs := service.User{}.TempVipUserQuery(token, q.ShopID, q.JsonStr, sign)
  413. rst := a.toWebFunc(rs)
  414. return rst, nil
  415. }
  416. // TempVipUserAdd 商家临时会员添加
  417. func (a Api) TempVipUserAdd(ctx context.Context, r *pb.StandardRequest) (*pb.StandardReply, error) {
  418. // 获取token,并验证签名函数
  419. token, q, sign := a.webToGoVerify(ctx, r)
  420. rs := service.User{}.TempVipUserAdd(token, q.ShopID, q.JsonStr, sign)
  421. rst := a.toWebFunc(rs)
  422. return rst, nil
  423. }
  424. // TempVipUserEdit 商家临时会员编辑
  425. func (a Api) TempVipUserEdit(ctx context.Context, r *pb.StandardRequest) (*pb.StandardReply, error) {
  426. // 获取token,并验证签名函数
  427. token, q, sign := a.webToGoVerify(ctx, r)
  428. rs := service.User{}.TempVipUserEdit(token, q.ShopID, q.JsonStr, sign)
  429. rst := a.toWebFunc(rs)
  430. return rst, nil
  431. }
  432. // TempVipUserStatusEdit 商家临时会员状态修改
  433. func (a Api) TempVipUserStatusEdit(ctx context.Context, r *pb.StandardRequest) (*pb.StandardReply, error) {
  434. // 获取token,并验证签名函数
  435. token, q, sign := a.webToGoVerify(ctx, r)
  436. rs := service.User{}.TempVipUserStatusEdit(token, q.ShopID, q.JsonStr, sign)
  437. rst := a.toWebFunc(rs)
  438. return rst, nil
  439. }
  440. // VipHourEdit 商家会员课时编辑
  441. func (a Api) VipHourEdit(ctx context.Context, r *pb.StandardRequest) (*pb.StandardReply, error) {
  442. // 获取token,并验证签名函数
  443. token, q, sign := a.webToGoVerify(ctx, r)
  444. rs := service.User{}.VipHourEdit(token, q.ShopID, q.JsonStr, sign)
  445. rst := a.toWebFunc(rs)
  446. return rst, nil
  447. }
  448. // VipConsumeListQuery 商家会员消费课时查询
  449. func (a Api) VipConsumeListQuery(ctx context.Context, r *pb.StandardRequest) (*pb.StandardReply, error) {
  450. // 获取token,并验证签名函数
  451. token, q, sign := a.webToGoVerify(ctx, r)
  452. rs := service.User{}.VipConsumeListQuery(token, q.ShopID, q.JsonStr, sign)
  453. rst := a.toWebFunc(rs)
  454. return rst, nil
  455. }
  456. // VipConsumeDetailQuery 商家会员消费课时详情查询
  457. func (a Api) VipConsumeDetailQuery(ctx context.Context, r *pb.StandardRequest) (*pb.StandardReply, error) {
  458. // 获取token,并验证签名函数
  459. token, q, sign := a.webToGoVerify(ctx, r)
  460. rs := service.User{}.VipConsumeDetailQuery(token, q.ShopID, q.JsonStr, sign)
  461. rst := a.toWebFunc(rs)
  462. return rst, nil
  463. }
  464. // VipClassRelationEdit 商家会员对应课程增删
  465. func (a Api) VipClassRelationEdit(ctx context.Context, r *pb.StandardRequest) (*pb.StandardReply, error) {
  466. // 获取token,并验证签名函数
  467. token, q, sign := a.webToGoVerify(ctx, r)
  468. rs := service.User{}.VipClassRelationEdit(token, q.ShopID, q.JsonStr, sign)
  469. rst := a.toWebFunc(rs)
  470. return rst, nil
  471. }
  472. // VipHourChgQuery 商家会员消费课时详情查询
  473. func (a Api) VipHourChgQuery(ctx context.Context, r *pb.StandardRequest) (*pb.StandardReply, error) {
  474. // 获取token,并验证签名函数
  475. token, q, sign := a.webToGoVerify(ctx, r)
  476. rs := service.User{}.VipHourChgQuery(token, q.ShopID, q.JsonStr, sign)
  477. rst := a.toWebFunc(rs)
  478. return rst, nil
  479. }
  480. // VipUserClassQuery 商家会员课程查询
  481. func (a Api) VipUserClassQuery(ctx context.Context, r *pb.StandardRequest) (*pb.StandardReply, error) {
  482. // 获取token,并验证签名函数
  483. token, q, sign := a.webToGoVerify(ctx, r)
  484. rs := service.User{}.VipUserClassQuery(token, q.ShopID, q.JsonStr, sign)
  485. rst := a.toWebFunc(rs)
  486. return rst, nil
  487. }
  488. // GetSimpleQiNiuToken 获取七牛简单Token
  489. func (a Api) GetSimpleQiNiuToken(ctx context.Context, r *pb.DefaultRequest) (*pb.QiNiuTokenReply, error) {
  490. token := a.getToken(ctx)
  491. rs := service.User{}.GetSimpleQiNiuToken(token)
  492. return rs, nil
  493. }
  494. // GetOverlayImgQiNiuToken 获取七牛可覆盖文件Token
  495. func (a Api) GetOverlayImgQiNiuToken(ctx context.Context, r *pb.GetOverlayImgRequest) (*pb.QiNiuTokenReply, error) {
  496. token := a.getToken(ctx)
  497. rs := service.User{}.GetOverlayImgQiNiuToken(token, r.FileName)
  498. return rs, nil
  499. }
  500. // ClassQuery 商家基础课程查询
  501. func (a Api) ClassQuery(ctx context.Context, r *pb.StandardRequest) (*pb.StandardReply, error) {
  502. // 获取token,并验证签名函数
  503. token, q, sign := a.webToGoVerify(ctx, r)
  504. rs := service.Class{}.ClassQuery(token, q.ShopID, q.JsonStr, sign)
  505. rst := a.toWebFunc(rs)
  506. return rst, nil
  507. }
  508. // ClassAdd 商家基础课程添加
  509. func (a Api) ClassAdd(ctx context.Context, r *pb.StandardRequest) (*pb.StandardReply, error) {
  510. // 获取token,并验证签名函数
  511. token, q, sign := a.webToGoVerify(ctx, r)
  512. rs := service.Class{}.ClassAdd(token, q.ShopID, q.JsonStr, sign)
  513. rst := a.toWebFunc(rs)
  514. return rst, nil
  515. }
  516. // ClassEdit 商家基础课程编辑
  517. func (a Api) ClassEdit(ctx context.Context, r *pb.StandardRequest) (*pb.StandardReply, error) {
  518. // 获取token,并验证签名函数
  519. token, q, sign := a.webToGoVerify(ctx, r)
  520. rs := service.Class{}.ClassEdit(token, q.ShopID, q.JsonStr, sign)
  521. rst := a.toWebFunc(rs)
  522. return rst, nil
  523. }
  524. // ClassStatusEdit 商家基础课程状态编辑
  525. func (a Api) ClassStatusEdit(ctx context.Context, r *pb.StandardRequest) (*pb.StandardReply, error) {
  526. // 获取token,并验证签名函数
  527. token, q, sign := a.webToGoVerify(ctx, r)
  528. rs := service.Class{}.ClassStatusEdit(token, q.ShopID, q.JsonStr, sign)
  529. rst := a.toWebFunc(rs)
  530. return rst, nil
  531. }
  532. // ClassColorEdit 商家基础课程颜色修改
  533. func (a Api) ClassColorEdit(ctx context.Context, r *pb.StandardRequest) (*pb.StandardReply, error) {
  534. // 获取token,并验证签名函数
  535. token, q, sign := a.webToGoVerify(ctx, r)
  536. rs := service.Class{}.ClassColorEdit(token, q.ShopID, q.JsonStr, sign)
  537. rst := a.toWebFunc(rs)
  538. return rst, nil
  539. }
  540. // ClassWxVisibleEdit 商家基础课程微信显示状态修改
  541. func (a Api) ClassWxVisibleEdit(ctx context.Context, r *pb.StandardRequest) (*pb.StandardReply, error) {
  542. // 获取token,并验证签名函数
  543. token, q, sign := a.webToGoVerify(ctx, r)
  544. rs := service.Class{}.ClassWxVisibleEdit(token, q.ShopID, q.JsonStr, sign)
  545. rst := a.toWebFunc(rs)
  546. return rst, nil
  547. }
  548. // ClassVipEdit 商家课程会员增删
  549. func (a Api) ClassVipEdit(ctx context.Context, r *pb.StandardRequest) (*pb.StandardReply, error) {
  550. // 获取token,并验证签名函数
  551. token, q, sign := a.webToGoVerify(ctx, r)
  552. rs := service.Class{}.ClassVipEdit(token, q.ShopID, q.JsonStr, sign)
  553. rst := a.toWebFunc(rs)
  554. return rst, nil
  555. }
  556. // SttPlanBasicQuery 商家课程表模板总览查询
  557. func (a Api) SttPlanBasicQuery(ctx context.Context, r *pb.StandardRequest) (*pb.StandardReply, error) {
  558. // 获取token,并验证签名函数
  559. token, q, sign := a.webToGoVerify(ctx, r)
  560. rs := service.Class{}.SttPlanBasicQuery(token, q.ShopID, q.JsonStr, sign)
  561. rst := a.toWebFunc(rs)
  562. return rst, nil
  563. }
  564. // SttPlanBasicAdd 商家课程表模板总览添加
  565. func (a Api) SttPlanBasicAdd(ctx context.Context, r *pb.StandardRequest) (*pb.StandardReply, error) {
  566. // 获取token,并验证签名函数
  567. token, q, sign := a.webToGoVerify(ctx, r)
  568. rs := service.Class{}.SttPlanBasicAdd(token, q.ShopID, q.JsonStr, sign)
  569. rst := a.toWebFunc(rs)
  570. return rst, nil
  571. }
  572. // SttPlanBasicEdit 商家课程表模板总览编辑
  573. func (a Api) SttPlanBasicEdit(ctx context.Context, r *pb.StandardRequest) (*pb.StandardReply, error) {
  574. // 获取token,并验证签名函数
  575. token, q, sign := a.webToGoVerify(ctx, r)
  576. rs := service.Class{}.SttPlanBasicEdit(token, q.ShopID, q.JsonStr, sign)
  577. rst := a.toWebFunc(rs)
  578. return rst, nil
  579. }
  580. // SttPlanBasicShopEdit 商家课程表模板总览所属商家修改
  581. func (a Api) SttPlanBasicShopEdit(ctx context.Context, r *pb.StandardRequest) (*pb.StandardReply, error) {
  582. // 获取token,并验证签名函数
  583. token, q, sign := a.webToGoVerify(ctx, r)
  584. rs := service.Class{}.SttPlanBasicShopEdit(token, q.ShopID, q.JsonStr, sign)
  585. rst := a.toWebFunc(rs)
  586. return rst, nil
  587. }
  588. // SttPlanBasicStatusEdit 商家课程表模板状态
  589. func (a Api) SttPlanBasicStatusEdit(ctx context.Context, r *pb.StandardRequest) (*pb.StandardReply, error) {
  590. // 获取token,并验证签名函数
  591. token, q, sign := a.webToGoVerify(ctx, r)
  592. rs := service.Class{}.SttPlanBasicStatusEdit(token, q.ShopID, q.JsonStr, sign)
  593. rst := a.toWebFunc(rs)
  594. return rst, nil
  595. }
  596. // SttPlanBasicPublish 商家课程表模板发布
  597. func (a Api) SttPlanBasicPublish(ctx context.Context, r *pb.StandardRequest) (*pb.StandardReply, error) {
  598. // 获取token,并验证签名函数
  599. token, q, sign := a.webToGoVerify(ctx, r)
  600. rs := service.Class{}.SttPlanBasicPublish(token, q.ShopID, q.JsonStr, sign)
  601. rst := a.toWebFunc(rs)
  602. return rst, nil
  603. }
  604. // SttPlanPreview 商家课程表模板详情预览
  605. func (a Api) SttPlanPreview(ctx context.Context, r *pb.StandardRequest) (*pb.StandardReply, error) {
  606. // 获取token,并验证签名函数
  607. token, q, sign := a.webToGoVerify(ctx, r)
  608. rs := service.Class{}.SttPlanPreview(token, q.ShopID, q.JsonStr, sign)
  609. rst := a.toWebFunc(rs)
  610. return rst, nil
  611. }
  612. // SttPlanCopy 商家课程表模板复制
  613. func (a Api) SttPlanCopy(ctx context.Context, r *pb.StandardRequest) (*pb.StandardReply, error) {
  614. // 获取token,并验证签名函数
  615. token, q, sign := a.webToGoVerify(ctx, r)
  616. rs := service.Class{}.SttPlanCopy(token, q.ShopID, q.JsonStr, sign)
  617. rst := a.toWebFunc(rs)
  618. return rst, nil
  619. }
  620. // SttPlanDetailQuery 商家课程表模板详情查询
  621. func (a Api) SttPlanDetailQuery(ctx context.Context, r *pb.StandardRequest) (*pb.StandardReply, error) {
  622. // 获取token,并验证签名函数
  623. token, q, sign := a.webToGoVerify(ctx, r)
  624. rs := service.Class{}.SttPlanDetailQuery(token, q.ShopID, q.JsonStr, sign)
  625. rst := a.toWebFunc(rs)
  626. return rst, nil
  627. }
  628. // SttPlanDetailBatchSave 商家课程表模板详情批量保存
  629. func (a Api) SttPlanDetailBatchSave(ctx context.Context, r *pb.StandardRequest) (*pb.StandardReply, error) {
  630. // 获取token,并验证签名函数
  631. token, q, sign := a.webToGoVerify(ctx, r)
  632. rs := service.Class{}.SttPlanDetailBatchSave(token, q.ShopID, q.JsonStr, sign)
  633. rst := a.toWebFunc(rs)
  634. return rst, nil
  635. }
  636. // STTBasicQuery 商家课程表总览查询
  637. func (a Api) STTBasicQuery(ctx context.Context, r *pb.StandardRequest) (*pb.StandardReply, error) {
  638. // 获取token,并验证签名函数
  639. token, q, sign := a.webToGoVerify(ctx, r)
  640. rs := service.Class{}.STTBasicQuery(token, q.ShopID, q.JsonStr, sign)
  641. rst := a.toWebFunc(rs)
  642. return rst, nil
  643. }
  644. // STTBasicAdd 商家课程表总览添加
  645. func (a Api) STTBasicAdd(ctx context.Context, r *pb.StandardRequest) (*pb.StandardReply, error) {
  646. // 获取token,并验证签名函数
  647. token, q, sign := a.webToGoVerify(ctx, r)
  648. rs := service.Class{}.STTBasicAdd(token, q.ShopID, q.JsonStr, sign)
  649. rst := a.toWebFunc(rs)
  650. return rst, nil
  651. }
  652. // STTBasicEdit 商家课程表总览编辑
  653. func (a Api) STTBasicEdit(ctx context.Context, r *pb.StandardRequest) (*pb.StandardReply, error) {
  654. // 获取token,并验证签名函数
  655. token, q, sign := a.webToGoVerify(ctx, r)
  656. rs := service.Class{}.STTBasicEdit(token, q.ShopID, q.JsonStr, sign)
  657. if !a.checkRs(rs) {
  658. rst := a.toWebFunc(rs)
  659. return rst, nil
  660. }
  661. rst := a.toWebFunc(rs)
  662. return rst, nil
  663. }
  664. // STTBasicStatusEdit 商家课程表总览状态修改
  665. func (a Api) STTBasicStatusEdit(ctx context.Context, r *pb.StandardRequest) (*pb.StandardReply, error) {
  666. // 获取token,并验证签名函数
  667. token, q, sign := a.webToGoVerify(ctx, r)
  668. rs := service.Class{}.STTBasicStatusEdit(token, q.ShopID, q.JsonStr, sign)
  669. rst := a.toWebFunc(rs)
  670. return rst, nil
  671. }
  672. // STTBasicPreview 商家课程表详情预览
  673. func (a Api) STTBasicPreview(ctx context.Context, r *pb.StandardRequest) (*pb.StandardReply, error) {
  674. // 获取token,并验证签名函数
  675. token, q, sign := a.webToGoVerify(ctx, r)
  676. rs := service.Class{}.STTBasicPreview(token, q.ShopID, q.JsonStr, sign)
  677. rst := a.toWebFunc(rs)
  678. return rst, nil
  679. }
  680. // STTBasicCopy 商家课程表模板复制
  681. func (a Api) STTBasicCopy(ctx context.Context, r *pb.StandardRequest) (*pb.StandardReply, error) {
  682. // 获取token,并验证签名函数
  683. token, q, sign := a.webToGoVerify(ctx, r)
  684. rs := service.Class{}.STTBasicCopy(token, q.ShopID, q.JsonStr, sign)
  685. rst := a.toWebFunc(rs)
  686. return rst, nil
  687. }
  688. // STTBasicOfflineEdit 商家课程表上下线状态修改
  689. func (a Api) STTBasicOfflineEdit(ctx context.Context, r *pb.StandardRequest) (*pb.StandardReply, error) {
  690. // 获取token,并验证签名函数
  691. token, q, sign := a.webToGoVerify(ctx, r)
  692. rs := service.Class{}.STTBasicOfflineEdit(token, q.ShopID, q.JsonStr, sign)
  693. rst := a.toWebFunc(rs)
  694. return rst, nil
  695. }
  696. // STTDetailListQuery 商家课程表详情列表查询
  697. func (a Api) STTDetailListQuery(ctx context.Context, r *pb.StandardRequest) (*pb.StandardReply, error) {
  698. // 获取token,并验证签名函数
  699. token, q, sign := a.webToGoVerify(ctx, r)
  700. rs := service.Class{}.STTDetailListQuery(token, q.ShopID, q.JsonStr, sign)
  701. rst := a.toWebFunc(rs)
  702. return rst, nil
  703. }
  704. // STTBasicDetailBatchSave 商家课程表详情批量保存
  705. func (a Api) STTBasicDetailBatchSave(ctx context.Context, r *pb.StandardRequest) (*pb.StandardReply, error) {
  706. // 获取token,并验证签名函数
  707. token, q, sign := a.webToGoVerify(ctx, r)
  708. rs := service.Class{}.STTBasicDetailBatchSave(token, q.ShopID, q.JsonStr, sign)
  709. rst := a.toWebFunc(rs)
  710. return rst, nil
  711. }
  712. // STTDetailAllowDelCheck 商家课程表详情判断是否可删除
  713. func (a Api) STTDetailAllowDelCheck(ctx context.Context, r *pb.StandardRequest) (*pb.StandardReply, error) {
  714. // 获取token,并验证签名函数
  715. token, q, sign := a.webToGoVerify(ctx, r)
  716. rs := service.Class{}.STTDetailAllowDelCheck(token, q.ShopID, q.JsonStr, sign)
  717. rst := a.toWebFunc(rs)
  718. return rst, nil
  719. }
  720. // ----------------------- 商家上下课管理 ---------------------------------------------
  721. // CourseDetailQuery 课程管理查询
  722. func (a Api) CourseDetailQuery(ctx context.Context, r *pb.StandardRequest) (*pb.StandardReply, error) {
  723. // 获取token,并验证签名函数
  724. token, q, sign := a.webToGoVerify(ctx, r)
  725. rs := service.Course{}.CourseDetailQuery(token, q.ShopID, q.JsonStr, sign)
  726. rst := a.toWebFunc(rs)
  727. return rst, nil
  728. }
  729. // ClassListByOrderDate 某日课程表查询
  730. func (a Api) ClassListByOrderDate(ctx context.Context, r *pb.StandardRequest) (*pb.StandardReply, error) {
  731. // 获取token,并验证签名函数
  732. token, q, sign := a.webToGoVerify(ctx, r)
  733. rs := service.Course{}.ClassListByOrderDate(token, q.ShopID, q.JsonStr, sign)
  734. rst := a.toWebFunc(rs)
  735. return rst, nil
  736. }
  737. // ClassStartPrepare 上课准备
  738. func (a Api) ClassStartPrepare(ctx context.Context, r *pb.CourseStandardRequest) (*pb.StandardReply, error) {
  739. // 获取token,并验证签名函数
  740. token, q, sign := a.courseToGoVerify(ctx, r)
  741. rs := service.Course{}.ClassStartPrepare(token, q.ShopID, q.JsonStr, sign)
  742. if !a.checkRs(rs) {
  743. rst := a.toWebFunc(rs)
  744. return rst, nil
  745. }
  746. if q.IsHr == 1 {
  747. //todo 调用心率系统接口
  748. if !a.checkRs(rs) {
  749. rst := a.toWebFunc(rs)
  750. return rst, nil
  751. }
  752. }
  753. if q.IsScore == 1 {
  754. // todo 调用评分系统接口
  755. if !a.checkRs(rs) {
  756. rst := a.toWebFunc(rs)
  757. return rst, nil
  758. }
  759. }
  760. rst := a.toWebFunc(rs)
  761. return rst, nil
  762. }
  763. // VipClassDetailQuery 会员上课详情查询
  764. func (a Api) VipClassDetailQuery(ctx context.Context, r *pb.StandardRequest) (*pb.StandardReply, error) {
  765. // 获取token,并验证签名函数
  766. token, q, sign := a.webToGoVerify(ctx, r)
  767. rs := service.Course{}.VipClassDetailQuery(token, q.ShopID, q.JsonStr, sign)
  768. rst := a.toWebFunc(rs)
  769. return rst, nil
  770. }
  771. // VipClassDetailAdd 会员上课详情添加-上课未预约
  772. func (a Api) VipClassDetailAdd(ctx context.Context, r *pb.CourseStandardRequest) (*pb.StandardReply, error) {
  773. // 获取token,并验证签名函数
  774. token, q, sign := a.courseToGoVerify(ctx, r)
  775. rs := service.Course{}.VipClassDetailAdd(token, q.ShopID, q.JsonStr, sign)
  776. if !a.checkRs(rs) {
  777. rst := a.toWebFunc(rs)
  778. return rst, nil
  779. }
  780. if q.IsHr == 1 {
  781. //todo 调用心率系统接口
  782. }
  783. if q.IsScore == 1 {
  784. // todo 调用评分系统接口
  785. }
  786. rst := a.toWebFunc(rs)
  787. return rst, nil
  788. }
  789. // VipClassDetailDel 会员上课详情删除
  790. func (a Api) VipClassDetailDel(ctx context.Context, r *pb.CourseStandardRequest) (*pb.StandardReply, error) {
  791. // 获取token,并验证签名函数
  792. token, q, sign := a.courseToGoVerify(ctx, r)
  793. rs := service.Course{}.VipClassDetailDel(token, q.ShopID, q.JsonStr, sign)
  794. if !a.checkRs(rs) {
  795. rst := a.toWebFunc(rs)
  796. return rst, nil
  797. }
  798. if q.IsHr == 1 {
  799. //todo 调用心率系统接口
  800. }
  801. if q.IsScore == 1 {
  802. // todo 调用评分系统接口
  803. }
  804. rst := a.toWebFunc(rs)
  805. return rst, nil
  806. }
  807. // TmpClassDetailAdd 临时会员上课详情添加
  808. func (a Api) TmpClassDetailAdd(ctx context.Context, r *pb.CourseStandardRequest) (*pb.StandardReply, error) {
  809. // 获取token,并验证签名函数
  810. token, q, sign := a.courseToGoVerify(ctx, r)
  811. rs := service.Course{}.TmpClassDetailAdd(token, q.ShopID, q.JsonStr, sign)
  812. if !a.checkRs(rs) {
  813. rst := a.toWebFunc(rs)
  814. return rst, nil
  815. }
  816. if q.IsHr == 1 {
  817. //todo 调用心率系统接口
  818. }
  819. if q.IsScore == 1 {
  820. // todo 调用评分系统接口
  821. }
  822. rst := a.toWebFunc(rs)
  823. return rst, nil
  824. }
  825. // TmpClassDetailDel 临时会员上课详情删除
  826. func (a Api) TmpClassDetailDel(ctx context.Context, r *pb.CourseStandardRequest) (*pb.StandardReply, error) {
  827. // 获取token,并验证签名函数
  828. token, q, sign := a.courseToGoVerify(ctx, r)
  829. rs := service.Course{}.TmpClassDetailDel(token, q.ShopID, q.JsonStr, sign)
  830. if !a.checkRs(rs) {
  831. rst := a.toWebFunc(rs)
  832. return rst, nil
  833. }
  834. if q.IsHr == 1 {
  835. //todo 调用心率系统接口
  836. }
  837. if q.IsScore == 1 {
  838. // todo 调用评分系统接口
  839. }
  840. rst := a.toWebFunc(rs)
  841. return rst, nil
  842. }
  843. // VipClassDetailStatueEdit 会员上课详情状态修改
  844. func (a Api) VipClassDetailStatueEdit(ctx context.Context, r *pb.CourseStandardRequest) (*pb.StandardReply, error) {
  845. // 获取token,并验证签名函数
  846. token, q, sign := a.courseToGoVerify(ctx, r)
  847. rs := service.Course{}.VipClassDetailStatueEdit(token, q.ShopID, q.JsonStr, sign)
  848. if !a.checkRs(rs) {
  849. rst := a.toWebFunc(rs)
  850. return rst, nil
  851. }
  852. if q.IsHr == 1 {
  853. //todo 调用心率系统接口
  854. }
  855. if q.IsScore == 1 {
  856. // todo 调用评分系统接口
  857. }
  858. rst := a.toWebFunc(rs)
  859. return rst, nil
  860. }
  861. // ClassStartConfirm 确认上课
  862. func (a Api) ClassStartConfirm(ctx context.Context, r *pb.CourseStandardRequest) (*pb.StandardReply, error) {
  863. // 获取token,并验证签名函数
  864. token, q, sign := a.courseToGoVerify(ctx, r)
  865. rs := service.Course{}.ClassStartConfirm(token, q.ShopID, q.JsonStr, sign)
  866. if !a.checkRs(rs) {
  867. rst := a.toWebFunc(rs)
  868. return rst, nil
  869. }
  870. if q.IsHr == 1 {
  871. //todo 调用心率系统接口
  872. }
  873. if q.IsScore == 1 {
  874. // todo 调用评分系统接口
  875. }
  876. rst := a.toWebFunc(rs)
  877. return rst, nil
  878. }
  879. // ClassOverConfirm 确认下课
  880. func (a Api) ClassOverConfirm(ctx context.Context, r *pb.StandardRequest) (*pb.StandardReply, error) {
  881. // 获取token,并验证签名函数
  882. token, q, sign := a.webToGoVerify(ctx, r)
  883. rs := service.Course{}.ClassOverConfirm(token, q.ShopID, q.JsonStr, sign)
  884. rst := a.toWebFunc(rs)
  885. return rst, nil
  886. }
  887. // ClassGiveUpConfirm 关闭课程
  888. func (a Api) ClassGiveUpConfirm(ctx context.Context, r *pb.CourseStandardRequest) (*pb.StandardReply, error) {
  889. // 获取token,并验证签名函数
  890. token, q, sign := a.courseToGoVerify(ctx, r)
  891. rs := service.Course{}.ClassGiveUpConfirm(token, q.ShopID, q.JsonStr, sign)
  892. if !a.checkRs(rs) {
  893. rst := a.toWebFunc(rs)
  894. return rst, nil
  895. }
  896. if q.IsHr == 1 {
  897. //todo 调用心率系统接口
  898. }
  899. if q.IsScore == 1 {
  900. // todo 调用评分系统接口
  901. }
  902. rst := a.toWebFunc(rs)
  903. return rst, nil
  904. }
  905. // AfterClassAddClassDetail 关闭课程
  906. func (a Api) AfterClassAddClassDetail(ctx context.Context, r *pb.CourseStandardRequest) (*pb.StandardReply, error) {
  907. // 获取token,并验证签名函数
  908. token, q, sign := a.courseToGoVerify(ctx, r)
  909. var rs string
  910. // 因为是上课后追加的人,已经在基础库中添加,所以只需要在心率与评分中加入
  911. //rs := service.Course{}.ClassGiveUpConfirm(token, q.ShopID, q.JsonStr, sign)
  912. if q.IsHr == 1 {
  913. rs = service.Hr{}.AfterClassAddClassDetail(token, q.ShopID, q.JsonStr, sign)
  914. if !a.checkRs(rs) {
  915. rst := a.toWebFunc(rs)
  916. return rst, nil
  917. }
  918. }
  919. if q.IsScore == 1 {
  920. // todo 调用评分系统接口
  921. }
  922. rst := a.toWebFunc(rs)
  923. return rst, nil
  924. }
  925. // ----------------------- 商家预约管理 ---------------------------------------------
  926. // OrderListQuery 预约记录查询
  927. func (a Api) OrderListQuery(ctx context.Context, r *pb.StandardRequest) (*pb.StandardReply, error) {
  928. // 获取token,并验证签名函数
  929. token, q, sign := a.webToGoVerify(ctx, r)
  930. rs := service.Order{}.OrderListQuery(token, q.ShopID, q.JsonStr, sign)
  931. rst := a.toWebFunc(rs)
  932. return rst, nil
  933. }
  934. // OrderAddByManager 管理员预约添加
  935. func (a Api) OrderAddByManager(ctx context.Context, r *pb.StandardRequest) (*pb.StandardReply, error) {
  936. // 获取token,并验证签名函数
  937. token, q, sign := a.webToGoVerify(ctx, r)
  938. rs := service.Order{}.OrderAddByManager(token, q.ShopID, q.JsonStr, sign)
  939. rst := a.toWebFunc(rs)
  940. return rst, nil
  941. }
  942. // OrderCancelByManager 管理员预约取消
  943. func (a Api) OrderCancelByManager(ctx context.Context, r *pb.StandardRequest) (*pb.StandardReply, error) {
  944. // 获取token,并验证签名函数
  945. token, q, sign := a.webToGoVerify(ctx, r)
  946. rs := service.Order{}.OrderCancelByManager(token, q.ShopID, q.JsonStr, sign)
  947. rst := a.toWebFunc(rs)
  948. return rst, nil
  949. }
  950. // OrderStatistics 商家预约统计
  951. func (a Api) OrderStatistics(ctx context.Context, r *pb.StandardRequest) (*pb.StandardReply, error) {
  952. // 获取token,并验证签名函数
  953. token, q, sign := a.webToGoVerify(ctx, r)
  954. rs := service.Order{}.OrderStatistics(token, q.ShopID, q.JsonStr, sign)
  955. rst := a.toWebFunc(rs)
  956. return rst, nil
  957. }
  958. // ClassOrderQuery 可预约课程预约列表查询
  959. func (a Api) ClassOrderQuery(ctx context.Context, r *pb.StandardRequest) (*pb.StandardReply, error) {
  960. // 获取token,并验证签名函数
  961. token, q, sign := a.webToGoVerify(ctx, r)
  962. rs := service.Order{}.ClassOrderQuery(token, q.ShopID, q.JsonStr, sign)
  963. rst := a.toWebFunc(rs)
  964. return rst, nil
  965. }
  966. // VipUserOrderQuery 会员预约列表查询
  967. func (a Api) VipUserOrderQuery(ctx context.Context, r *pb.StandardRequest) (*pb.StandardReply, error) {
  968. // 获取token,并验证签名函数
  969. token, q, sign := a.webToGoVerify(ctx, r)
  970. rs := service.Order{}.VipUserOrderQuery(token, q.ShopID, q.JsonStr, sign)
  971. rst := a.toWebFunc(rs)
  972. return rst, nil
  973. }
  974. // UserOrderQueryByStd 查询课程预约用户列表
  975. func (a Api) UserOrderQueryByStd(ctx context.Context, r *pb.StandardRequest) (*pb.StandardReply, error) {
  976. // 获取token,并验证签名函数
  977. token, q, sign := a.webToGoVerify(ctx, r)
  978. rs := service.Order{}.UserOrderQueryByStd(token, q.ShopID, q.JsonStr, sign)
  979. rst := a.toWebFunc(rs)
  980. return rst, nil
  981. }
  982. // ----------------------- 商家心率管理 ---------------------------------------------
  983. // HrSensorsPublicQuery 公共心率带查询
  984. func (a Api) HrSensorsPublicQuery(ctx context.Context, r *pb.StandardRequest) (*pb.StandardReply, error) {
  985. // 获取token,并验证签名函数
  986. token, q, sign := a.webToGoVerify(ctx, r)
  987. rs := service.Hr{}.HrSensorsPublicQuery(token, q.ShopID, q.JsonStr, sign)
  988. rst := a.toWebFunc(rs)
  989. return rst, nil
  990. }
  991. // HrSensorsPvtQuery 私有心率带查询
  992. func (a Api) HrSensorsPvtQuery(ctx context.Context, r *pb.StandardRequest) (*pb.StandardReply, error) {
  993. // 获取token,并验证签名函数
  994. token, q, sign := a.webToGoVerify(ctx, r)
  995. rs := service.Hr{}.HrSensorsPvtQuery(token, q.ShopID, q.JsonStr, sign)
  996. rst := a.toWebFunc(rs)
  997. return rst, nil
  998. }
  999. // AddHrSensors 公共心率带添加
  1000. func (a Api) AddHrSensors(ctx context.Context, r *pb.StandardRequest) (*pb.StandardReply, error) {
  1001. // 获取token,并验证签名函数
  1002. token, q, sign := a.webToGoVerify(ctx, r)
  1003. rs := service.Hr{}.AddHrSensors(token, q.ShopID, q.JsonStr, sign)
  1004. rst := a.toWebFunc(rs)
  1005. return rst, nil
  1006. }
  1007. // AddPvtHrSensors 私有心率带添加
  1008. func (a Api) AddPvtHrSensors(ctx context.Context, r *pb.StandardRequest) (*pb.StandardReply, error) {
  1009. // 获取token,并验证签名函数
  1010. token, q, sign := a.webToGoVerify(ctx, r)
  1011. rs := service.Hr{}.AddPvtHrSensors(token, q.ShopID, q.JsonStr, sign)
  1012. rst := a.toWebFunc(rs)
  1013. return rst, nil
  1014. }
  1015. // EditHrSensors 心率带编辑
  1016. func (a Api) EditHrSensors(ctx context.Context, r *pb.StandardRequest) (*pb.StandardReply, error) {
  1017. // 获取token,并验证签名函数
  1018. token, q, sign := a.webToGoVerify(ctx, r)
  1019. rs := service.Hr{}.EditHrSensors(token, q.ShopID, q.JsonStr, sign)
  1020. rst := a.toWebFunc(rs)
  1021. return rst, nil
  1022. }
  1023. // HrSensorsDel 心率带删除
  1024. func (a Api) HrSensorsDel(ctx context.Context, r *pb.StandardRequest) (*pb.StandardReply, error) {
  1025. // 获取token,并验证签名函数
  1026. token, q, sign := a.webToGoVerify(ctx, r)
  1027. rs := service.Hr{}.HrSensorsDel(token, q.ShopID, q.JsonStr, sign)
  1028. rst := a.toWebFunc(rs)
  1029. return rst, nil
  1030. }
  1031. // PKGroupChg 修改PK分队
  1032. func (a Api) PKGroupChg(ctx context.Context, r *pb.StandardRequest) (*pb.StandardReply, error) {
  1033. // 获取token,并验证签名函数
  1034. token, q, sign := a.webToGoVerify(ctx, r)
  1035. rs := service.Hr{}.PKGroupChg(token, q.ShopID, q.JsonStr, sign)
  1036. rst := a.toWebFunc(rs)
  1037. return rst, nil
  1038. }
  1039. // BindHrSensor 绑定心率带
  1040. func (a Api) BindHrSensor(ctx context.Context, r *pb.StandardRequest) (*pb.StandardReply, error) {
  1041. // 获取token,并验证签名函数
  1042. token, q, sign := a.webToGoVerify(ctx, r)
  1043. rs := service.Hr{}.BindHrSensor(token, q.ShopID, q.JsonStr, sign)
  1044. rst := a.toWebFunc(rs)
  1045. return rst, nil
  1046. }
  1047. // UnBindHrSensor 解绑心率带
  1048. func (a Api) UnBindHrSensor(ctx context.Context, r *pb.StandardRequest) (*pb.StandardReply, error) {
  1049. // 获取token,并验证签名函数
  1050. token, q, sign := a.webToGoVerify(ctx, r)
  1051. rs := service.Hr{}.UnBindHrSensor(token, q.ShopID, q.JsonStr, sign)
  1052. rst := a.toWebFunc(rs)
  1053. return rst, nil
  1054. }
  1055. // ----------------------- 评分管理 ---------------------------------------------
  1056. // ----------------------- 微信管理 ---------------------------------------------
  1057. // GenVerifyImageByWinXin 微信登陆获取图片验证码
  1058. func (Api) GenVerifyImageByWinXin(ctx context.Context, r *pb.GenVerifyImageRequest) (*pb.GenVerifyImageReply, error) {
  1059. //height := int(r.Height)
  1060. //width := int(r.Width)
  1061. id, pic := service.VerifyCode{}.GenImage(int(r.Height), int(r.Width))
  1062. return &pb.GenVerifyImageReply{
  1063. CodeId: id,
  1064. ImageBase64: pic,
  1065. }, nil
  1066. }
  1067. // GenPhoneVerifyCodeByWeiXin 微信登陆获取短信验证码
  1068. func (a Api) GenPhoneVerifyCodeByWeiXin(ctx context.Context, r *pb.GenPhoneVerifyCodeRequestWX) (*pb.StandardReply, error) {
  1069. ip := a.getRemoteIp(ctx)
  1070. rs := service.VerifyCode{}.GetPhoneVFCode(
  1071. r.SId,
  1072. r.Account, ip, global.TemplateCode, r.CodeId, r.ImgCode, r.VerifyType, time.Duration(global.SmsExpireNano))
  1073. rst := a.toWebFunc(rs)
  1074. return rst, nil
  1075. }
  1076. //// WeiXinSignIn 微信登陆
  1077. //func (a Api) WeiXinSignIn(ctx context.Context, r *pb.WeiXinSignInRequest) (*pb.SignInReply, error) {
  1078. //
  1079. //
  1080. // rs := service.Wx{}.WeiXinSignIn(token, q.ShopID, q.JsonStr, sign)
  1081. //
  1082. // return &pb.SignInReply{Token: rs}, nil
  1083. //}