|
@ -0,0 +1,31 @@
|
|
|
"use strict";
|
|
|
|
|
|
let express = require('express');
|
|
|
let router = express.Router();
|
|
|
let request = require('request');
|
|
|
let http = require('http');
|
|
|
let configFile = require('../../include/commons').CONFIG_FILE;
|
|
|
let config = require('../../resources/config/' + configFile);
|
|
|
let ImDb = require('../../repository/mysql/db/im.db');
|
|
|
let WlyySDK = require("../../util/wlyy.sdk");
|
|
|
let log = require('../../util/log.js');
|
|
|
let clientCache = require('../../models/socket.io/client.cache').clientCache();
|
|
|
const SOCKET_TYPES = require('../../include/commons').SOCKET_TYPES;
|
|
|
const APIv2 = require('../../include/endpoints').APIv2;
|
|
|
|
|
|
/**
|
|
|
* socket 推送demo
|
|
|
*/
|
|
|
router.post("/", function (req, response) {
|
|
|
let payload = req.body;
|
|
|
let client = clientCache.findByIdAndType(payload.userId,payload.clientType);
|
|
|
log.info("推送的用户ID:"+payload.userId+"客户端类型:"+payload.clientType);
|
|
|
if(client){
|
|
|
client.socket.emit('message',{ data:payload.data});
|
|
|
response.status(200).send({"msg": "推送成功!"});
|
|
|
}else{
|
|
|
response.status(200).send({"msg": "用户不在线!"});
|
|
|
}
|
|
|
});
|
|
|
|
|
|
module.exports = router;
|