base.go 42 KB

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