view.jsp 15.2 KB

原文件审查历史永久链接

<%@ page language="java" contentType="text/html; charset=UTF-8"
	pageEncoding="UTF-8"%>
<%@ page import="java.util.*"%>
<%@ page import="java.sql.*"%>
<%@ page import="com.espeed.reading.util.*"%>
<%@ page import="java.util.concurrent.ExecutorService"%>
<%@ page import="java.util.concurrent.Executors"%>
<!DOCTYPE html PUBLIC "-//W3C//DTD HTML 4.01 Transitional//EN" "http://www.w3.org/TR/html4/loose.dtd">
<html>
<head>
<meta http-equiv="Content-Type" content="text/html; charset=UTF-8">
<title>文件预览</title>
<link rel="alternate icon" type="image/png"
	href="https://webmail120117.yiwaixiao.com/esmail/static/img/es.png">
<style>
#reader {
	margin: auto;
}

#ywx-download {
	background: url(images/download.png) no-repeat;
	background-size: 23px;
	width: 24px;
	font-size: 0;
	line-height: 0;
	overflow: hidden;
	display: inline-block;
	height: 30px;
	margin-bottom: 2px;
	cursor: pointer;
	margin-right: 10px;
	margin-top: 12px;
}
</style>

</head>
<body onunload="recordTrack();">
	<%
		String to = null;
		String token = null;
		String trackId = null;//云盘附件是分享id、追踪附件是追踪文件id
		String userId = null;
		String companyId = null;
		String status = null;
		String docId = null;
		Long fileId = null;
		String mailUid = null;
		String title = null;
		String uid = null;

		String type = request.getParameter("type");

		String poporimap = request.getParameter("poporimap");//null/0是pop，1是imap
		poporimap = poporimap == null ? "0" : poporimap.replace("3D", "")
				.trim();

		if (type != null) {
			type = type.trim();
			type = type.startsWith("3D")
					? type.replaceFirst("3D", "")
					: type;
		}

		if (type != null && !type.trim().isEmpty()
				&& Arrays.asList("1", "2").contains(type)) {

			token = request.getParameter("token");
			trackId = request.getParameter("trackId");
			to = request.getParameter("to");
			uid = request.getParameter("uid");

			ExecutorService fixedThreadPool = Executors
					.newFixedThreadPool(3);

			//异步添加附件消息提醒
			String sql = "";

			final String recordType = type;
			final String recordId = trackId == null ? null : (trackId
					.trim().startsWith("3D") ? trackId.trim().replaceFirst(
					"3D", "") : trackId.trim());
			final String recordEmail = to == null ? null : (to.trim()
					.startsWith("3D")
					? to.trim().replaceFirst("3D", "")
					: to.trim());
			final String recordMailUid = uid == null ? null : (uid.trim()
					.startsWith("3D")
					? uid.trim().replaceFirst("3D", "")
					: uid.trim());
			if (recordId != null && recordEmail != null
					&& !recordMailUid.equals("ywxreceiveemail")
					&& recordMailUid != null
					&& !recordMailUid.equals("null")) {
				// 点击附件时异步添加消息提醒
				fixedThreadPool.execute(new Runnable() {

					public void run() {
						System.out.println("开始添加附件点击消息提醒...");
						String title = null;

						Connection conn = null;
						PreparedStatement ps = null;
						ResultSet rs = null;

						try {
							String recordUserId = null;
							//一个封邮件里的一个超链接一天提醒一次
							// 《xx》邮箱点开了您邮件《xx》里的xx附件《xx》
							conn = WebmailDBUtil.getConnection();

							String subject = "未知";//邮件名称
							String name = "未知";//文件名称

							String sql = "select subject,user_id from eml_send_mail_master_base where mail_uid = ? limit 1";
							ps = conn.prepareStatement(sql);
							ps.setString(1, recordMailUid);

							rs = ps.executeQuery();

							if (rs.first()) {
								subject = rs.getString("subject");
								recordUserId = rs.getString("user_id");
							}

							if (recordType.equals("1")) {//邮件云盘附件
								sql = "SELECT f.`name` FROM cloud_file AS f,cloud_share AS s WHERE s.share_ids = f.id AND s.id = ? limit 1";
								ps = conn.prepareStatement(sql);
								ps.setObject(1, recordId);
								rs = ps.executeQuery();

								if (rs.first()) {
									name = rs.getString("name");
								}
							} else {//邮件追踪附件
								Connection conn2 = null;
								PreparedStatement ps2 = null;
								// 结果集对象
								ResultSet rs2 = null;

								try {
									conn2 = DBUtil.getConnection();
									sql = "select title from ts_file_track where id = ? limit 1";
									ps2 = conn2.prepareStatement(sql);
									ps2.setObject(1, recordId);

									rs2 = ps2.executeQuery();

									if (rs2.first()) {
										name = rs2.getString("title");
									}
								} catch (Exception e) {
									e.printStackTrace();
								} finally {
									//DBUtil.close(rs, ps, conn);
								}

							}

							if (recordType.equals("1")) {//邮件云盘附件

								sql = "select id from sys_user_remind where to_days(remind_time) = to_days(now()) and remind_content like '《"
										+ recordEmail.trim()
										+ "》%《"
										+ subject.trim()
										+ "》%云盘附件《"
										+ name.trim()
										+ "》%' and remind_userid = "
										+ recordUserId;

							} else {//邮件追踪附件

								sql = "select id from sys_user_remind where to_days(remind_time) = to_days(now()) and remind_content like '《"
										+ recordEmail.trim()
										+ "》%《"
										+ subject.trim()
										+ "》%追踪附件《"
										+ name.trim()
										+ "》%' and remind_userid = "
										+ recordUserId;
							}

							ps = conn.prepareStatement(sql);
							rs = ps.executeQuery();

							int id = 0;
							if (rs.first()) {
								id = rs.getInt("id");
							}

							if (id == 0) {
								String content = "";
								int remindType = 20;//20云盘附件阅读、22追踪附件阅读

								if (recordType.equals("1")) {//邮件云盘附件
									content = "《" + recordEmail.trim()
											+ "》邮箱点开了您邮件《" + subject.trim()
											+ "》里的云盘附件《" + name.trim()
											+ "》，请前往云盘管理-我的分享查看！";
								} else {//邮件追踪附件
									content = "《" + recordEmail.trim()
											+ "》邮箱点开了您邮件《" + subject.trim()
											+ "》里的追踪附件《" + name.trim()
											+ "》，请前往企业邮件查看！";
									remindType = 22;
								}

								sql = "insert into sys_user_remind(remind_userid,remind_type,remind_status,remind_time,remind_content,target_id,is_read) values(?,?,?,?,?,?,?)";
								ps = conn.prepareStatement(sql);
								ps.setObject(1, recordUserId);
								ps.setObject(2, remindType);
								ps.setObject(3, 0);
								ps.setObject(4, DateFormat.getNowDate());
								ps.setObject(5, content);
								ps.setObject(6, recordId);
								ps.setObject(7, 0);
								ps.executeUpdate();
							}

						} catch (Exception e) {
							e.printStackTrace();
						} finally {
							WebmailDBUtil.close(rs, ps, conn);
						}

					}
				});
			}

			if (type.equals("1")) {//邮件云盘附件

				trackId = request.getParameter("trackId");

				if (trackId != null && !trackId.trim().isEmpty()) {
					trackId = trackId.trim();
					trackId = trackId.startsWith("3D") ? trackId
							.replaceFirst("3D", "") : trackId;
				} else {
					out.write("参数缺失，没有指定分享文件ID");
					return;
				}

				uid = request.getParameter("uid");

				if (uid != null && !uid.trim().isEmpty()) {
					uid = uid.trim();
					uid = uid.startsWith("3D")
							? uid.replaceFirst("3D", "")
							: uid;
				}
				//else {
				//	out.write("参数缺失，没有指定邮件UID");
				//	return;
				//}

				if (uid != null && !uid.trim().isEmpty() && !uid.toLowerCase().trim().equals("null")) {

					//更新mailuid
					WebmailDBUtil.updateMailUid(1, Long.valueOf(trackId),
							uid, poporimap);
				}

				if (token != null && !token.trim().isEmpty()) {
					token = token.trim();
					token = token.startsWith("3D") ? token.replaceFirst(
							"3D", "") : token;

					response.sendRedirect(ConfigPath.getCloudShareUrl()
							+ "/share/diskSharePage.html?token=" + token);
					return;
				} else {
					response.sendRedirect(ConfigPath.getCloudShareUrl()
							+ "/share/diskSharePage.html?token=null");
					return;
				}

			} else if (type.equals("2")) {//邮件追踪附件

				if (token != null && !token.trim().isEmpty()) {
					token = token.trim();
					token = token.startsWith("3D") ? token.replaceFirst(
							"3D", "") : token;
				} else {
					out.write("参数缺失，没有指定文件token");
					return;
				}

				trackId = request.getParameter("trackId");

				if (trackId != null && !trackId.trim().isEmpty()) {
					trackId = trackId.trim();
					trackId = trackId.startsWith("3D") ? trackId
							.replaceFirst("3D", "") : trackId;
				} else {
					out.write("参数缺失，没有指定文件追踪ID");
					return;
				}

				uid = request.getParameter("uid");

				if (uid != null && !uid.trim().isEmpty()) {
					uid = uid.trim();
					uid = uid.startsWith("3D")
							? uid.replaceFirst("3D", "")
							: uid;
				}
				//else {
				//	out.write("参数缺失，没有指定邮件UID");
				//	return;
				//}

				to = request.getParameter("to");

				if (to != null && !to.trim().isEmpty()) {
					to = to.trim();
					to = to.startsWith("3D")
							? to.replaceFirst("3D", "")
							: to;
				}
				//else {
				//	out.write("参数缺失，没有指定邮件收件人邮箱");
				//	return;
				//}

			} else {
				response.sendRedirect(ConfigPath.getDefaultToUrl());

				return;
			}

			Connection conn = null;
			PreparedStatement ps = null;
			// 结果集对象
			ResultSet rs = null;

			try {
				conn = DBUtil.getConnection();
				sql = "select * from ts_file_track where id = ? limit 1";
				ps = conn.prepareStatement(sql);
				ps.setObject(1, Long.valueOf(trackId));

				rs = ps.executeQuery();

				if (!rs.first()) {
					out.write("不存在的追踪ID");
					return;
				}

				status = rs.getString("status");
				docId = rs.getString("doc_id");
				fileId = rs.getLong("file_id");
				mailUid = rs.getString("mail_uid");
				title = rs.getString("title");
				userId = rs.getString("user_id");
				companyId = rs.getString("company_id");

				if (uid != null && !uid.trim().isEmpty() && !uid.toLowerCase().trim().equals("null")) {
					if (mailUid == null || mailUid.trim().isEmpty()
							|| mailUid.toLowerCase().startsWith("uid_")) {
						sql = "update ts_file_track set mail_uid = ?, is_imap = ? where id = ?";
						ps = conn.prepareStatement(sql);
						ps.setObject(1, uid);
						ps.setObject(2, poporimap);
						ps.setObject(3, Long.valueOf(trackId));

						ps.executeUpdate();

						//更新mailuid
						WebmailDBUtil.updateMailUid(0, fileId, uid,
								poporimap);

						mailUid = uid;
					}
				}

				if (to != null && !to.trim().isEmpty()
						&& !uid.toLowerCase().trim().equals("null")) {

					sql = "update ts_file_track set is_open = 1, open_count = open_count + 1 where id = ?";
					ps = conn.prepareStatement(sql);
					ps.setObject(1, Long.valueOf(trackId));

					ps.executeUpdate();

				}
				conn.commit();
			} catch (Exception e) {
				System.out.println("预览追踪附件异常:" + e.getClass().getName()
						+ "-->" + e.getMessage());
			} finally {
				DBUtil.close(rs, ps, conn);
			}

		} else {
			out.write("参数缺失，未指定预览类型");

			return;
		}
	%>

	<div id="reader"></div>

	<input type="hidden" value="<%=to%>" id="to">
	<input type="hidden" value="<%=token%>" id="token">
	<input type="hidden" value="<%=trackId%>" id="trackId">
	<input type="hidden" value="<%=userId%>" id="userId">
	<input type="hidden" value="<%=companyId%>" id="companyId">
	<input type="hidden" value="<%=status%>" id="status">
	<input type="hidden" value="<%=docId%>" id="docId">
	<input type="hidden" value="<%=fileId%>" id="fileId">
	<input type="hidden" value="<%=mailUid%>" id="mailUid">
	<input type="hidden" value="<%=title%>" id="title">
	<input type="hidden" value="<%=ConfigPath.getCloudServiceUrl()%>"
		id="cloudServiceUrl">

</body>
<script src="https://static.bcedocument.com/reader/v2/doc_reader_v2.js"></script>
<script type="text/javascript">
	var to = document.getElementById("to").value;
	var token = document.getElementById("token").value;
	var trackId = document.getElementById("trackId").value;
	var userId = document.getElementById("userId").value;
	var companyId = document.getElementById("companyId").value;
	var status = document.getElementById("status").value;
	var docId = document.getElementById("docId").value;
	var fileId = document.getElementById("fileId").value;
	var mailUid = document.getElementById("mailUid").value;
	var title = document.getElementById("title").value;
	var cloudServiceUrl = document.getElementById("cloudServiceUrl").value;

	var start = new Date();
	var pageNumber = 1;

	var isFirst = true;

	if (to != null && to != "null" && status == "PUBLISHED") {
		document.getElementsByTagName("title")[0].innerHTML = title;

		var option = {
			docId : docId,
			token : "TOKEN",
			host : "BCEDOC",
			serverHost : "https://doc.bj.baidubce.com",
			width : 1000, // 文档容器宽度
			pn : 1, // 定位到第几页，可选
			ready : function(handler) { // 设置字体大小和颜色, 背景颜色（可设置白天黑夜模式）
				handler.setFontSize(1);
				handler.setBackgroundColor("#000");
				handler.setFontColor("#fff");
			},
			flip : function(data) { // 翻页时回调函数, 可供客户进行统计等
				if (isFirst) {
					isFirst = false;

					initHtml();
				} else {
					recordTrack();

					pageNumber = data.pn;
				}
			},
			fontSize : "big",
			toolbarConf : {
				page : true, // 上下翻页箭头图标
				pagenum : true, // 几分之几页
				full : true, // 是否显示全屏图标,点击后全屏
				copy : true, // 是否可以复制文档内容
				position : "center" // 设置 toolbar中翻页和放大图标的位置(值有left/center)
			}
		//文档顶部工具条配置对象,必选
		};

		new Document("reader", option);
	} else {

		var url = "";

		var format = null;

		if (title != null) {
			format = title.trim().toLowerCase().substring(
					title.lastIndexOf(".") + 1);
		}

		if (format == "pdf") {
			url = "https://dcsapi.com/?k=340401151&url=";
		} else {
			url = "https://view.officeapps.live.com/op/embed.aspx?wdStartOn=1&src=";
		}

		//url += "https://view.officeapps.live.com/op/embed.aspx?wdStartOn=1&src="
		url += cloudServiceUrl
				+ "/file/stream/"
				+ userId
				+ "/0/"
				+ token
				+ "/" + title;

		location.href = url;
	}

	function recordTrack() {
		console.log("开始记录页数：" + pageNumber);
		if (to == null || to == "null")
			return;
		var arr = new Array();
		arr.push("userId=" + userId);
		arr.push("companyId=" + companyId);
		arr.push("pageNumber=" + pageNumber);
		arr.push("accessTime=" + (new Date().getTime() - start.getTime()));
		start = new Date();
		arr.push("to=" + to);
		arr.push("trackId=" + trackId);

		(new Image()).src = "track_recordTrackFile.action?" + arr.join("&");
	}

	function initHtml() {

		if (document.getElementById("ywx-download") == null) {
			var ele = document.createElement("a");
			ele.id = "ywx-download";
			ele.innerHTML = "下载";

			document.getElementsByClassName("wenku-toolsbar-zoom")[0]
					.appendChild(ele);

			document.getElementById("ywx-download").addEventListener(
					"click",
					function() {

						var url = "track_downloadTrackFile.action?trackId="
								+ trackId + "&token=" + token;
						window.open(url, "_blank");
					}, false);
		}
	}
</script>
</html>