1234567891011121314151617181920212223242526272829303132333435363738394041424344454647484950515253545556575859606162636465 |
- /**
- * 微信AccessToken库。
- *
- * author:lyr
- * since: 2016/11/25.
- */
- "use strict";
- let log = require('../../util/log');
- let ImDb = require('../mysql/db/im.db');
- let configFile = require('../../include/commons').CONFIG_FILE;
- let config = require('../../resources/config/' + configFile);
- class WeChatTokenRepo {
- constructor() {
- }
- /**
- * 获取微信AccessToken
- *
- * @param handler 回调函数
- */
- static findOne(handler) {
- ImDb.execQuery({
- "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"
- , "handler": handler
- });
- };
- /**
- * 保存AccessToken
- *
- * @param accessToken 微信AccessToken
- * @param expireIn
- * @param createTime
- * @param handler 回调函数
- */
- static save(accessToken, expireIn, createTime, handler) {
- ImDb.execQuery({
- "sql": "insert into wlyy.wx_access_token (acc_id,access_token, expires_in, add_timestamp) values ('"+config.wechatConfig.accId+"',?,?,?)"
- , "args": [accessToken, expireIn, createTime.getTime()]
- , "handler": handler
- });
- }
- /**
- * 微信推送日志
- * @param openid
- * @param patient
- * @param name
- * @param request
- * @param response
- * @param status
- * @param createTime
- */
- static saveLog(openid,patient,name,request,response,status,createTime,handler){
- ImDb.execQuery({
- "sql": "insert into wlyy.wlyy_wx_push_log (type,openid, patient,name,request,response,status, create_time) values (3,?,?,?,?,?,?,?)"
- , "args": [openid,patient,name,request,response,status, createTime]
- , "handler": handler
- });
- }
- }
- module.exports = WeChatTokenRepo;
|