base.go 42 KB

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