var meetingModel = require('../model/meetingModel');
var oldMeetingModel = require('../model/oldMeetingModel');
var oldMeetingRecording = require('../model/oldMeetingRecording');
var v_meetingModel = require('../model/v_meetingModel');
var status = require('../util/resTemplate');
var saitMd5 = require('../util/saltMD5');
var sequelize = require('../config');
var tokenUtil = require('../util/tokenUtil');
var saitMd5 = require('../util/saltMD5')
var co = require('co');
const xml2js = require('xml2js');
const requestUtil = require('../util/requestUtil')
const builder = new xml2js.Builder(); // JSON->xml
const parser = new xml2js.Parser(); //xml -> json
function meetingService(){
}
meetingService.prototype.createMeeting = async(meetingInfo) =>{
try {
let backMeeting = await meetingModel.create(meetingInfo);
return backMeeting
} catch (error) {
throw error
}
}
meetingService.prototype.getMeeting = async(queryData,page = 1,pageno =12) =>{
try {
let sql =`SELECT
id,
meeting_number AS meetingNumber,
meeting_name AS meetingName,
meeting_content AS meetingContent,
create_user,
create_time AS createTime,
begin_time AS beginTime,
end_time AS endTime,
invite_user AS inviteUser,
meeting_type AS meetingType,
meeting_status AS meetingStatus,
user_ip AS userIp,
meeting_key AS meetingKey,
host_password AS hostPassword,
presenter_password AS presenterPassword,
assistant_password AS assistantPassword,
attendee_password AS attendeePassword,
capacity,
top_node_id AS topNodeId,
top_node_addr AS topNodeAddr,
user_data AS userData,
site_id AS siteId,
classroom_number AS classroomNumber,
ui_language AS uiLanguage,
is_public AS isPublic,
control_mode AS controlMode,
mic_auto AS micAuto,
has_interaction AS hasInteraction,
auto_record AS autoRecord,
max_videoChannels AS maxVideoChannels,
max_audioChannels AS maxAudioChannels,
video_quality AS videoQuality,
pagenavi_Userprivilege AS pagenaviUserprivilege,
marker_Userprivilege AS markerUserprivilege,
chatToNormal_Userprivilege AS chatToNormalUserprivilege,
chatToHost_Userprivilege AS chatToHostUserprivilege,
doc_module AS docModule,
screen_module AS screenModule,
media_module AS mediaModule,
whiteboard_module AS whiteboardModule,
record_module AS recordModule,
video_module AS videoModule,
userList_module AS userListModule,
chat_module AS chatModule,
cycle,
repeatmode,
endmode,
finalenddate,
endcount,
repeatday,
repeatweek,
repeatmonthday,
repeatmonthweekweek,
repeatmonthweekday,
frequency,
month_type AS monthType,
inviter_radio AS inviterRadio,
ahead_time AS aheadTime,
chat_interval AS chatInterval,
h5_Module AS h5Module,
(SELECT
3m_attachment.path
FROM
3m_user
LEFT JOIN 3m_attachment ON 3m_attachment.business_id = 3m_user.id
WHERE
3m_user.login_name = 3m_meeting.create_user) teacherPhoto,
(
SELECT
path
FROM
3m_attachment
WHERE
3m_attachment.business_id = 3m_meeting.id and 3m_attachment.category = 1
) meetingPhoto,
(
SELECT
COUNT(*)
FROM
3m_student_meeting
WHERE
3m_student_meeting.meeting_id = 3m_meeting.id
) reservationNumber
FROM
3m_meeting AS 3m_meeting
WHERE 3m_meeting.site_id = '` +queryData.siteId+"'";
if(queryData.create_user){
sql += " and 3m_meeting.create_user = '" + queryData.create_user+"'";
}
if(queryData.id){
sql += " and 3m_meeting.id = '" + queryData.id+"'";
}
if(queryData.meetingStatus){
sql += " and 3m_meeting.meeting_status = '" + queryData.meetingStatus+"'";
}
if(queryData.meetingType){
sql += " and 3m_meeting.meeting_type = '" + queryData.meetingType+"'";
}
sql += ' ORDER BY 3m_meeting.create_time DESC LIMIT '+(page-1)*pageno+' , ' +pageno
let backMeeting = await sequelize.query(sql);
//let backMeeting = await meetingModel.findAll({where:queryData,order:[['createTime', 'DESC']], offset: (page-1)*pageno, limit: pageno});
let count = await meetingModel.count({where:queryData})
return {meetingInfo:backMeeting[0],count:count,page:page,pageno:pageno};
} catch (error) {
console.error(error)
throw error;
}
}
meetingService.prototype.delMeeting = async(meetingId) =>{
try {
let Meeting = await meetingModel.findOne({where:{id:meetingId}});
if(!Meeting){
return {code:11,msg:'课堂不存在'}
}
let backMeeting = await meetingModel.destroy({where:{id:meetingId}});
return backMeeting
} catch (error) {
throw error;
}
}
meetingService.prototype.updateMeeting = async(params,meetingId) =>{
try {
let Meeting = await meetingModel.findOne({where:{id:meetingId}});
if(!Meeting){
return {code:11,msg:'课堂不存在'}
}
let backMeeting = await meetingModel.update({where:{id:meetingId}});
return backMeeting
} catch (error) {
console.error(error);
throw error
}
}
meetingService.prototype.getAllMeetingBySiteID = async(params,page = 1,pageno =10)=>{
try {
let oldMeeting = await oldMeetingModel.findAll({where:{siteId:params.meetingId}});
let oldMeetingCont = await oldMeetingModel.count({where:{siteId:params.meetingId}});
let Meeting = await meetingModel.findAll({where:{site_id:params.meetingId}});
let MeetingCount = await meetingModel.count({where:{site_id:params.meetingId}});
if(!Meeting){
return {code:11,msg:'课堂不存在'}
}
let meetingAll = await v_meetingModel.findAll({where:params,offset: (page-1)*pageno, limit: pageno,order:[['beginTime', 'DESC']]});
let meetingdata = Meeting.concat(oldMeeting);
await meetingdata.sort(function(m1,m2){
return new Date(m2.beginTime).getTime() - new Date(m1.beginTime).getTime();
});
console.log((page-1)*pageno,(page-1)*pageno+10)
// return {meeting:meetingdata.slice((page-1)*pageno,100)}
return {meeting:meetingAll}
} catch (error) {
throw error
}
}
meetingService.prototype.recording = async(params)=>{
try {
let newURL = 'http://'+params.siteId+'.xuedianyun.com/3m/doPlayRecord.do?meetingNumber=';
let Meeting = await meetingModel.findOne({where:{classroomNumber:params.mtgKey}});
if(Meeting){
return {url:newURL+Meeting.meetingNumber}
}else{
let oldMeeting = await oldMeetingModel.findOne({where:{classroomNumber:params.mtgKey}});
if(!oldMeeting){
return {code:400,msg:'课堂不存在'}
}else{
let oldURL = 'http://saas.3mang.com:80/3m/attend.do?meetingNumber='+oldMeeting.meetingNumber+'&streamNameOfRecord=';
let oldMRecording = await oldMeetingRecording.findOne({where:{meetingId:oldMeeting.meetingNumber}});
if(!oldMRecording){
throw new Error('课堂没有录制')
}
var d = oldMRecording.configFile.split('.')[0]
let a = oldURL+d+"&userRole=record&userName="+params.username+"&password="+oldMeeting.attendeePassword;
return {url:a}
// var xml = builder.buildObject(recordInfo);
// let info = await requestUtil.post('http://markettest.xuedianyun.com/3m/meeting/join_mtg.do',xml);
// var jsonXml = await requestUtil.json2xml(info);
}
}
return {meeting:Meeting.concat(oldMeeting)}
} catch (error) {
console.error(error);
throw error
}
}
module.exports = new meetingService();