wechat.token.repo.js 1.8 KB

1234567891011121314151617181920212223242526272829303132333435363738394041424344454647484950515253545556575859606162636465
  1. /**
  2. * 微信AccessToken库。
  3. *
  4. * author:lyr
  5. * since: 2016/11/25.
  6. */
  7. "use strict";
  8. let log = require('../../util/log');
  9. let ImDb = require('../mysql/db/im.db');
  10. let configFile = require('../../include/commons').CONFIG_FILE;
  11. let config = require('../../resources/config/' + configFile);
  12. class WeChatTokenRepo {
  13. constructor() {
  14. }
  15. /**
  16. * 获取微信AccessToken
  17. *
  18. * @param handler 回调函数
  19. */
  20. static findOne(handler) {
  21. ImDb.execQuery({
  22. "sql": "select access_token, expires_in, add_timestamp from wlyy.wx_access_token where acc_id = '"+config.wechatConfig.accId+"' order by add_timestamp desc limit 0, 1"
  23. , "handler": handler
  24. });
  25. };
  26. /**
  27. * 保存AccessToken
  28. *
  29. * @param accessToken 微信AccessToken
  30. * @param expireIn
  31. * @param createTime
  32. * @param handler 回调函数
  33. */
  34. static save(accessToken, expireIn, createTime, handler) {
  35. ImDb.execQuery({
  36. "sql": "insert into wlyy.wx_access_token (acc_id,access_token, expires_in, add_timestamp) values ('"+config.wechatConfig.accId+"',?,?,?)"
  37. , "args": [accessToken, expireIn, createTime.getTime()]
  38. , "handler": handler
  39. });
  40. }
  41. /**
  42. * 微信推送日志
  43. * @param openid
  44. * @param patient
  45. * @param name
  46. * @param request
  47. * @param response
  48. * @param status
  49. * @param createTime
  50. */
  51. static saveLog(openid,patient,name,request,response,status,createTime,handler){
  52. ImDb.execQuery({
  53. "sql": "insert into wlyy.wlyy_wx_push_log (type,openid, patient,name,request,response,status, create_time) values (3,?,?,?,?,?,?,?)"
  54. , "args": [openid,patient,name,request,response,status, createTime]
  55. , "handler": handler
  56. });
  57. }
  58. }
  59. module.exports = WeChatTokenRepo;