package com.customization.quanshimeting; import aiyh.utils.Util; import aiyh.utils.zwl.common.ToolUtil; import com.engine.core.cfg.annotation.ServiceDynamicProxy; import com.engine.core.cfg.annotation.ServiceMethodDynamicProxy; import com.engine.core.impl.aop.AbstractServiceProxy; import com.engine.meeting.service.MeetingBaseService; import com.engine.meeting.service.impl.MeetingBaseServiceImpl; import com.fasterxml.jackson.core.JsonProcessingException; import com.fasterxml.jackson.databind.ObjectMapper; import weaver.aiyh_quanshi.RequestApi; import weaver.aiyh_quanshi.entity.QsConfParty; import weaver.aiyh_quanshi.entity.QsResponse; import weaver.conn.RecordSet; import java.text.ParseException; import java.text.SimpleDateFormat; import java.util.*; /** * @author EBU7-dev1-ayh * @create 2021/9/17 0017 16:18 * 代理类 */ @ServiceDynamicProxy(target = MeetingBaseServiceImpl.class, desc = "对全时会议进行同步") public class NewMeetingServiceProxy extends AbstractServiceProxy implements MeetingBaseService { private final ToolUtil toolUtil = new ToolUtil(); private final RequestApi requestApi = new RequestApi(); private final SimpleDateFormat simpleFormat = new SimpleDateFormat("yyyy-MM-dd hh:mm"); @Override @ServiceMethodDynamicProxy(desc = "创建会议，向全时会议中添加预约会议") public Map newMeeting(Map map) { toolUtil.writeErrorLog(map.toString()); try { int quanShiType = Integer.parseInt(Util.null2String("".equals(toolUtil.getSystemParamValue("QUAN_SHI_TYPE")) ? null : toolUtil.getSystemParamValue("QUAN_SHI_TYPE"), "-1")); int meetingType = Integer.parseInt(Util.null2String("".equals(String.valueOf(map.get("meetingtype"))) ? null : String.valueOf(map.get("meetingtype")), "0")); if (quanShiType != meetingType) { return (Map) executeMethod(map); } } catch (Exception e) { toolUtil.writeErrorLog("转换失败，失败原因：" + e); return (Map) executeMethod(map); } Map result = (Map) executeMethod(map); // 获取会议标题 String title = String.valueOf(map.get("name")); // 会议内容 String desc_n = String.valueOf(map.get("desc_n")); // 获取会议创建人 String creator = String.valueOf(map.get("contacter")); RecordSet rs = new RecordSet(); // 获取会议创建人邮件 String query = "select * from hrmresource where id = ?"; rs.executeQuery(query, creator); rs.next(); String creatorEmail = rs.getString("email"); // 获取会议开始日期 String startDate = String.valueOf(map.get("begindate")); // 获取会议开始时间 String startTime = String.valueOf(map.get("begintime")); Date start; try { start = simpleFormat.parse(startDate + " " + startTime); } catch (ParseException e) { /* e.printStackTrace(); Map resultErr = new HashMap<>(); // 请求失败 resultErr.put("status", false); resultErr.put("retstatus", true); resultErr.put("error", "日期转换失败！"); resultErr.put("msg", "日期转换失败！"); resultErr.put("api_errormsg", "日期转换失败！"); return resultErr;*/ return result; } // 获取会议结束日期 String endDate = String.valueOf(map.get("enddate")); // 获取会议结束时间 String endTime = String.valueOf(map.get("endtime")); Date end; try { end = simpleFormat.parse(endDate + " " + endTime); } catch (ParseException e) { /* e.printStackTrace(); Map resultErr = new HashMap<>(); // 请求失败 resultErr.put("status", false); resultErr.put("retstatus", true); resultErr.put("error", "日期转换失败!"); resultErr.put("msg", "日期转换失败！"); resultErr.put("api_errormsg", "日期转换失败！"); return resultErr;*/ return result; } // 计算会议时长 int length = new Long((end.getTime() - start.getTime()) / (1000 * 60)).intValue(); // 获取会议参与人 String hrmStr = String.valueOf(map.get("hrmmembers")); // 处理会议参与人 List list = new ArrayList<>(); List emailList = new ArrayList<>(); query = "select * from hrmresource where id in ( " + hrmStr + ")"; rs.executeQuery(query); while (rs.next()) { QsConfParty qsConfParty = new QsConfParty(); qsConfParty.setEmail(rs.getString("email")); emailList.add(rs.getString("email")); list.add(qsConfParty); if (emailList.size() == 199) { QsResponse userIdsByEmails = requestApi.getInfoByEmail(emailList); Map resultMap = new HashMap<>(); ObjectMapper mapper = new ObjectMapper(); try { resultMap = mapper.readValue(userIdsByEmails.getResult(), Map.class); } catch (JsonProcessingException e) { toolUtil.writeErrorLog(userIdsByEmails.toString()); toolUtil.writeErrorLog("请求结果转换失败，失败信息：" + e); } for (QsConfParty confParty : list) { confParty.setUserId(Long.valueOf(String.valueOf(((Map) resultMap.get(confParty.getEmail())).get("userId")))); } emailList.clear(); } } QsResponse userIdsByEmails = requestApi.getInfoByEmail(emailList); Map resultsMap = new HashMap<>(); ObjectMapper mapper = new ObjectMapper(); try { resultsMap = mapper.readValue(userIdsByEmails.getResult(), Map.class); } catch (JsonProcessingException e) { toolUtil.writeErrorLog(userIdsByEmails.toString()); toolUtil.writeErrorLog("请求结果转换失败，失败信息：" + e); } for (QsConfParty confParty : list) { confParty.setUserId(Long.valueOf(String.valueOf(((Map) resultsMap.get(confParty.getEmail())).get("userId")))); } /* toolUtil.writeErrorLog(list.toString()); toolUtil.writeErrorLog(creatorEmail); toolUtil.writeErrorLog(title); toolUtil.writeErrorLog(String.valueOf(length)); toolUtil.writeErrorLog(startDate + " " + startTime + ":00 ");*/ QsResponse meeting = requestApi.createMeting(creatorEmail, title, length, startDate + " " + startTime + ":00", list); if (meeting != null) { if (!"0".equals(meeting.getStatus())) { String update = "update meeting set quanshimeeting = ? where id = ?"; rs.executeUpdate(update, "全时会议添加失败！", String.valueOf(map.get("meetingid"))); toolUtil.writeErrorLog(meeting.toString()); /* Map result = new HashMap<>(); // 请求失败 result.put("status", false); result.put("retstatus", false); result.put("error", "全时会议添加失败"); result.put("msg", "全时会议添加失败！"); result.put("api_errormsg", "全时会议添加失败！"); return result;*/ return result; } else { // 请求成功 Map resultMap = new HashMap<>(); try { resultMap = mapper.readValue(meeting.getResult(), Map.class); } catch (JsonProcessingException e) { toolUtil.writeErrorLog("请求结果转换失败，失败信息：" + e); } if (Boolean.parseBoolean(String.valueOf(result.get("status")))) { // 添加成功 String update = "update meeting set quan_shi_id = ?, quanshimeeting = ? where id = ?"; String quanShjInfo = "会议密码：" + String.valueOf(resultMap.get("pcode2")) + "

会议连接：" + String.valueOf(resultMap.get("attendeeJoinUrl")); rs.executeUpdate(update, String.valueOf(resultMap.get("conferenceId")), quanShjInfo, String.valueOf(map.get("meetingid"))); return result; } else { QsResponse qsResponse = requestApi.cancelConference(String.valueOf(resultMap.get("conferenceId")), creatorEmail); toolUtil.writeErrorLog(qsResponse.toString()); /* Map resultErr = new HashMap<>(); // 请求失败 resultErr.put("status", false); resultErr.put("retstatus", false); resultErr.put("error", "OA会议添加失败！"); resultErr.put("msg", "OA会议添加失败！"); resultErr.put("api_errormsg", "OA会议添加失败！"); return resultErr;*/ return result; } } } else { /* Map resultErr = new HashMap<>(); // 请求失败 resultErr.put("status", false); resultErr.put("retstatus", false); resultErr.put("error", "全时会议添加失败"); resultErr.put("msg", "全时会议添加失败！"); resultErr.put("api_errormsg", "全时会议添加失败！"); return resultErr;*/ return result; } } /* Map result = (Map) executeMethod(map); if (Boolean.parseBoolean(String.valueOf(result.get("status")))) { // 会议添加成功，需要王全时会议中添加会议 String meetingId = String.valueOf(result.get("meetingid")); // 通过会议id获取到会议相关的信息 String query = "select * from meeting where id = ?"; RecordSet rs = new RecordSet(); rs.executeQuery(query, meetingId); MeetingInfoDTO meetingInfoDTO = Util.recordeSet2Entity(rs, MeetingInfoDTO.class, true); // 判断是否需要对会议进行全时会议添加 int quanShiType = Integer.parseInt(Util.null2String(toolUtil.getSystemParamValue("QUAN_SHI_TYPE"), "-1")); if (meetingInfoDTO.getMeetingtype() != quanShiType) { return result; } // 通过信息查询全时会议所需要的数据 // 获取创建人邮箱 query = "select email from hrmresource where id = ?"; rs.executeQuery(query, meetingInfoDTO.getCreater()); rs.next(); String creatorEmail = rs.getString("email"); // 获取参与人邮箱 List list = new ArrayList<>(); query = "select email from hrmresource where id in ( " + meetingInfoDTO.getHrmmembers() + ")"; rs.executeQuery(query); while (rs.next()) { QsConfParty qsConfParty = new QsConfParty(); qsConfParty.setEmail(rs.getString("email")); list.add(qsConfParty); } // 获取开始i时间和结束时间以及计算会议时长 int length = 0; String startDate = ""; String startTime = ""; try { // 获取会议开始日期 startDate = String.valueOf(meetingInfoDTO.getBegindate()); // 获取会议开始时间 startTime = String.valueOf(meetingInfoDTO.getBegintime()); Date start = simpleFormat.parse(startDate + " " + startTime); // 获取会议结束日期 String endDate = String.valueOf(meetingInfoDTO.getEnddate()); // 获取会议结束时间 String endTime = String.valueOf(meetingInfoDTO.getEndtime()); Date end = simpleFormat.parse(endDate + " " + endTime); // 计算会议时长 length = new Long((end.getTime() - start.getTime()) / (1000 * 60)).intValue(); } catch (Exception e) { toolUtil.writeErrorLog("日期传换失败，失败信息：" + e); } // 调取接口 QsResponse meting = requestApi.createMeting(creatorEmail, meetingInfoDTO.getName(), length, startDate + " " + startTime + ":00 ", list); if (!"0".equals(meting.getStatus())) { toolUtil.writeErrorLog("全时会议添加失败！失败结果" + meting); // 需要删除OA会议 // 添加全时会议失败 result.put("status", false); result.put("retstatus", false); result.put("error", "全时会议添加失败"); result.put("msg", "全时会议添加失败！"); result.put("api_errormsg", "abab全时会议添加失败！"); result.remove("apiCost"); result.remove("meetingid"); } else { // 添加全时会议成功 String update = "update meeting set quan_shi_id = ? where id = ?"; Map resultMap = new HashMap<>(); ObjectMapper mapper = new ObjectMapper(); try { resultMap = mapper.readValue(meting.getResult(), Map.class); } catch (JsonProcessingException e) { toolUtil.writeErrorLog("请求结果转换失败，失败信息：" + e); } rs.executeUpdate(update, String.valueOf(resultMap.get("conferenceId")), String.valueOf(map.get("meetingid"))); } } // throw new RuntimeException("全时会议添加失败!"); return result;*/ @Override @ServiceMethodDynamicProxy(desc = "删除会议时， 需要判断是否需要对全时会议的会议进行取消预约") public Map deleteMeeting(Map map) { Map result = (Map) executeMethod(map); // 获取请求参数中的会议id String meetingIds = String.valueOf(map.get("meetingids")); // 查询要删除的会议中是否存再全时会议预约的，如果有需要对全时会议进行取消 String query = "select * from meeting where id in (" + meetingIds + ") and cancel != 1 and quan_shi_id is not null and quan_shi_cancel is null"; RecordSet rs = new RecordSet(); rs.executeQuery(query); RecordSet rs_1 = new RecordSet(); while (rs.next()) { // 取消会议 String quanShiId = rs.getString("quan_shi_id"); String hrmId = rs.getString("contacter"); query = "select * from hrmresource where id = ?"; rs_1.executeQuery(query, hrmId); rs_1.next(); String creatorEmail = rs_1.getString("email"); QsResponse qsResponse = requestApi.cancelConference(quanShiId, creatorEmail); if (!"0".equals(qsResponse.getStatus())) { // 取消失败 toolUtil.writeErrorLog("全时会议取消失败！失败结果" + qsResponse); /*Map resultErr = new HashMap<>(); resultErr.put("status", false); resultErr.put("retstatus", false); resultErr.put("ret", false); resultErr.put("error", "全时会议取消失败！"); resultErr.put("msg", "全时会议取消失败！"); resultErr.put("api_errormsg", "全时会议取消失败！"); return resultErr;*/ return result; } else { String update = "update meeting set quan_shi_cancel = ? where id = ?"; rs_1.executeUpdate(update, "1", rs.getString("id")); } } // 取消成功，需要删除OA中会议 // Map result = (Map) executeMethod(map); return result; } @Override public Map editMeeting(Map map) { return null; } @Override public Map overMeeting(Map map) { return null; } @Override @ServiceMethodDynamicProxy(desc = "取消会议时，需要对全时会议的会议也进行同步取消") public Map cancelMeeting(Map map) { String meetingId = String.valueOf(map.get("meetingid")); // 通过会议id获取到会议相关的信息 String query = "select * from meeting where id = ?"; RecordSet rs = new RecordSet(); rs.executeQuery(query, meetingId); rs.next(); String quanShiId = rs.getString("quan_shi_id"); Map result = (Map) executeMethod(map); int quanShiType = Integer.parseInt(Util.null2String(toolUtil.getSystemParamValue("QUAN_SHI_TYPE"), "-1")); if (rs.getInt("meetingtype") != quanShiType) { return result; } RecordSet rs_1 = new RecordSet(); // 取消会议 String hrmId = rs.getString("contacter"); query = "select * from hrmresource where id = ?"; rs_1.executeQuery(query, hrmId); rs_1.next(); String creatorEmail = rs_1.getString("email"); QsResponse qsResponse = requestApi.cancelConference(quanShiId, creatorEmail); if (!"0".equals(qsResponse.getStatus())) { // 取消失败 toolUtil.writeErrorLog("全时会议取消失败！失败结果" + qsResponse); /*Map resultErr = new HashMap<>(); resultErr.put("status", false); resultErr.put("retstatus", false); resultErr.put("ret", false); resultErr.put("error", "全时会议取消失败！"); resultErr.put("msg", "全时会议取消失败！"); resultErr.put("api_errormsg", "全时会议取消失败！"); return resultErr;*/ return result; } else { String update = "update meeting set quan_shi_cancel = ? where id = ?"; rs_1.executeUpdate(update, "1", rs.getString("id")); } return result; } @Override public Map chkMember(Map map) { return null; } @Override public Map chkRoom(Map map) { return null; } @Override public Map chkservice(Map map) { return null; } @Override public Map chkRoomAttribute(Map map) { return null; } @Override public Map chkWPMember(Map map) { return null; } @Override public Map updateCkIsck(Map map) { return null; } @Override public Map chkMeeting(Map map) { return null; } @Override public Map customMeetingChk(Map map) { return null; } @Override public Map changeMeeting(Map map) { return null; } @Override public Map submitMeeting(Map map) { return null; } @Override public Map afterMeetingNormal(Map map) { return null; } @Override public Map afterMeetingChange(Map map) { return null; } @Override public Map getUnReadCount(Map map) { return null; } @Override public Map doSubmit(Map map) { return null; } @Override public Map selRejectNode(Map map) { return null; } @Override public Map doReject(Map map) { return null; } @Override public Map getUserDefInfo(Map map) { return null; } @Override public Map getNowMeeting(Map map) { return null; } @Override public Map getMoreMeeting(Map map) { return null; } @Override public Map getMeetingCornerMark(Map map) { return null; } @Override public Map getRequestParams(Map map) { return null; } @Override public Map exportExcel(Map map) { return null; } @Override public Map chkRight(Map map) { return null; } @Override public Map customChangeHrm(Map map) { return null; } @Override public Map getMeetingTabElement(Map map) { return null; } @Override public Map chkRepeatMeeting(Map map) { return null; } @Override public Map afterMeetingDelete(Map map) { return null; } @Override public Map meetingToGovern(Map map) { return null; } @Override public Map meetingDecisionToGovern(Map map) { return null; } @Override public Map getMeetingInfluenceInfo(String s) { return null; } @Override public Map getMeetingSysWorkRecordList(Map map) { return null; } @Override public Map getDefalutByLevel(Map map) { return null; } @Override public Map getMeetingBaseInfo(Map map) { return null; } }