display-server tfs的demo代码提交

display-server/sql/init/display_tfs_demo_sql_data.sql

@@ -0,0 +1,51 @@
/*
Navicat MySQL Data Transfer
Source Server         : 本地
Source Server Version : 50540
Source Host           : 127.0.0.1:3306
Source Database       : display
Target Server Type    : MYSQL
Target Server Version : 50540
File Encoding         : 65001
Date: 2017-12-21 15:49:51
*/
SET FOREIGN_KEY_CHECKS=0;
-- ----------------------------
-- Table structure for common_tfs_map
-- ----------------------------
DROP TABLE IF EXISTS `common_tfs_map`;
CREATE TABLE `common_tfs_map` (
  `md5` varchar(128) NOT NULL COMMENT '文件的md5唯一编码',
  `file_hash_code` varchar(128) NOT NULL COMMENT 'tfs对应的hash值',
  PRIMARY KEY (`md5`),
  UNIQUE KEY `uinque_index_file_hash_code` (`file_hash_code`) USING BTREE
) ENGINE=InnoDB DEFAULT CHARSET=utf8;
-- ----------------------------
-- Records of common_tfs_map
-- ----------------------------
INSERT INTO `common_tfs_map` VALUES ('47375cb03382346357214684e9010b41', 'T1ktJTByhT1RCvBVdK');
-- ----------------------------
-- Table structure for tab_file
-- ----------------------------
DROP TABLE IF EXISTS `tab_file`;
CREATE TABLE `tab_file` (
  `id` int(11) unsigned NOT NULL AUTO_INCREMENT,
  `file_name` varchar(255) DEFAULT NULL COMMENT '文件名',
  `file_hash_code` varchar(128) NOT NULL COMMENT 'tfs对应的hash值',
  `file_path` varchar(255) DEFAULT NULL COMMENT '所在服务器的相对路径',
  `create_time` datetime NOT NULL COMMENT '文件上传时间',
  `remark` varchar(128) DEFAULT NULL COMMENT '备用',
  PRIMARY KEY (`id`)
) ENGINE=InnoDB AUTO_INCREMENT=13 DEFAULT CHARSET=utf8;
-- ----------------------------
-- Records of tab_file
-- ----------------------------
INSERT INTO `tab_file` VALUES ('12', 'product2.jpg', 'T1ktJTByhT1RCvBVdK', null, '2017-05-04 16:01:37', null);

display-server/src/main/java/com/ai/server/bean/UploadDownloadWithTfsBean.java

@@ -13,15 +13,14 @@ import org.apache.commons.fileupload.disk.DiskFileItemFactory;
import org.apache.commons.fileupload.servlet.ServletFileUpload;
import org.apache.commons.lang3.StringUtils;
import com.ai.ipu.basic.file.FileUtil;
import com.ai.ipu.basic.log.ILogger;
import com.ai.ipu.basic.log.IpuLoggerFactory;
import com.ai.ipu.fs.IBaseFs;
import com.ai.ipu.fs.impl.UniqueCacheFs;
import com.ai.ipu.server.servlet.ServletManager;
import com.ai.ipu.server.util.MobileServerException;
import com.ai.server.core.bean.IpuAppBean;
import com.ai.server.dao.FileDao;
import com.ai.server.tfs.DbFs;
import com.ai.server.util.Constant;
import com.ailk.common.data.IData;
import com.ailk.common.data.IDataset;
@@ -31,7 +30,7 @@ public class UploadDownloadWithTfsBean extends IpuAppBean {
    transient protected static final ILogger log = IpuLoggerFactory.createLogger(UploadDownloadWithTfsBean.class);
    private static final String IPU_FILE = "ipu_file";
    /*private static final String IPU_FILE = "ipu_file";*/
    /**
     * 将流文件上传至tfs服务端，且记录数据库
@@ -65,7 +64,7 @@ public class UploadDownloadWithTfsBean extends IpuAppBean {
            // 2.将流文件存放tfs服务端，并返回存放信息
            String fileHashCode = null;
            IBaseFs fs = new DbFs();
            IBaseFs fs = new UniqueCacheFs();
            fis = (FileInputStream) is;
            fileHashCode = fs.saveFile(fis);
            log.debug("fileName=[" + fileName + "] 上传tfs成功,返回值fileHashCode=[" + fileHashCode + "]");
@@ -123,21 +122,22 @@ public class UploadDownloadWithTfsBean extends IpuAppBean {
        // 1.找到fileHashCode值
        FileDao dao = new FileDao(Constant.CONNNAME);
        IData fileObj = dao.queryFileListById(param);
        String fileName = fileObj.getString("file_name");
        /*String fileName = fileObj.getString("file_name");*/
        if (null == fileObj || null == fileObj.getString("file_hash_code") || "".equals(fileObj.getString("file_hash_code"))) {
            throw new MobileServerException("数据库未找到记录。");
        }
        String fileHashCode = fileObj.getString("file_hash_code");
        // 2.根据fileHashCode从tfs获取，并转化为本地文件
        IBaseFs fs = new DbFs();
        String path = FileUtil.connectFilePath(System.getProperty("catalina.base"), IPU_FILE, fileName);// 相对路径，转为输入流传到客户端app
        IBaseFs fs = new UniqueCacheFs();
        /*String path = FileUtil.connectFilePath(System.getProperty("catalina.base"), IPU_FILE, fileName);// 相对路径，转为输入流传到客户端app
        boolean result = fs.takeFile(fileHashCode, path);
        if (result) {
            return new FileInputStream(path);
        }
        return null;
        return null;*/
        return fs.takeFile(fileHashCode);
    }
    public IData deletePic(IData param) throws Exception {
@@ -153,7 +153,7 @@ public class UploadDownloadWithTfsBean extends IpuAppBean {
            throw new MobileServerException("数据库未找到记录。");
        }
        String fileHashCode = fileObj.getString("file_hash_code");
        IBaseFs fs = new DbFs();
        IBaseFs fs = new UniqueCacheFs();
        boolean deleteResult = fs.deleteFile(fileHashCode);
        if (!deleteResult) {
            throw new MobileServerException("tfs删除资源失败。");

display-server/src/main/java/com/ai/server/dao/TfsMapDao.java

@@ -10,18 +10,18 @@ public class TfsMapDao extends BaseDAO {
        super(connName);
    }
    public IData queryTfsMapListByFileHashCode(IData param) throws Exception {
    /*public IData queryTfsMapListByFileHashCode(IData param) throws Exception {
        String sql = "SELECT * FROM common_tfs_map WHERE file_hash_code=:file_hash_code";
        return this.queryList(sql, param).first();
    }
    }*/
    
    public IDataset queryTfsMapTfsListByMd5(IData param) throws Exception {
    public IData queryTfsMapTfsByMd5(IData param) throws Exception {
        String sql = "SELECT * FROM common_tfs_map WHERE md5=:md5";
        return this.queryList(sql, param);
        return this.queryList(sql, param).first();
    }
    public void insertTfsMap(IData param) throws Exception {
        String sql = "INSERT INTO common_tfs_map (file_hash_code, md5) VALUES(:file_hash_code, :md5)";
        String sql = "INSERT INTO common_tfs_map (md5, file_hash_code) VALUES(:md5, :file_hash_code)";
        this.executeUpdate(sql, param);
    }

display-server/src/main/java/com/ai/server/tfs/DbFsUnique.java

@@ -6,7 +6,6 @@ import com.ai.ipu.fs.unique.IFsUnique;
import com.ai.server.dao.TfsMapDao;
import com.ai.server.util.Constant;
import com.ailk.common.data.IData;
import com.ailk.common.data.IDataset;
import com.ailk.common.data.impl.DataMap;
/**
@@ -21,19 +20,8 @@ public class DbFsUnique implements IFsUnique {
     */
    @Override
	public boolean checkExists(String md5) {
		String fileHashCode = null;
		try {
			TfsMapDao dao = new TfsMapDao(Constant.CONNNAME);
			IData param = new DataMap();
			param.put("md5", md5);
			IDataset fileTfsList = dao.queryTfsMapTfsListByMd5(param);
			if (fileTfsList != null && !fileTfsList.isEmpty()) {
				fileHashCode = fileTfsList.getData(0).getString("file_hash_code");
			}
		} catch (Exception e) {
			e.printStackTrace();
		}
		return fileHashCode != null;
    	String fileKey = getFileKey(md5);
		return fileKey != null;
	}
    /*
@@ -44,14 +32,14 @@ public class DbFsUnique implements IFsUnique {
        try {
            TfsMapDao dao = new TfsMapDao(Constant.CONNNAME);
            IData param = new DataMap();
            param.put("file_hash_code", fileHashCode);
            param.put("md5", md5);
            IData tfsMapObj = dao.queryTfsMapListByFileHashCode(param);
            param.put("file_hash_code", fileHashCode);
            IData tfsMapObj = dao.queryTfsMapTfsByMd5(param);
            if (null == tfsMapObj) {
                log.debug("之前未发现记录，插入数据库。");
                dao.insertTfsMap(param);
            } else {
                if (md5.equals(tfsMapObj.getString("md5"))) {
                if (fileHashCode.equals(tfsMapObj.getString("file_hash_code"))) {
                    log.debug("发现对应记录且相同。");
                } else {
                    dao.updateTfsMap(param);
@@ -83,14 +71,14 @@ public class DbFsUnique implements IFsUnique {
    }
	@Override
	public String getFileKey(String uniqueId) {
	public String getFileKey(String md5) {
		// TODO Auto-generated method stub
		String fileHashCode = null;
        try {
            TfsMapDao dao = new TfsMapDao(Constant.CONNNAME);
            IData param = new DataMap();
            param.put("md5", uniqueId);
            IData tfsMapObj = dao.queryTfsMapListByFileHashCode(param);
            param.put("md5", md5);
            IData tfsMapObj = dao.queryTfsMapTfsByMd5(param);
            if (tfsMapObj != null) {
            	fileHashCode = tfsMapObj.getString("file_hash_code");
            }

display-server/src/main/resources/tfs.xml

@@ -15,7 +15,9 @@
	<!-- tfs本地文件存放的根目录 -->
	<config name="uploadFileHome" value="/home/ipuapp/web/webapps/display" />
	<!-- 是否开启本地文件缓存。缺省为true，开启。不想开启需要设置为false -->
	<config name="localFileCached" value="false" />
	<config name="localFileCache" value="false" />
	<!--  -->
	<config name="fsUniqueClass" value="com.ai.server.tfs.DbFsUnique"/>
	<!-- 不需要排重功能时，下面配置项可以不设置 -->
	<!-- tair排重数据库的serverlist -->

display-server/src/main/webapp/res/js/mobile/expand-mobile.js

@@ -130,11 +130,17 @@ define(["require"],function(require) {
			},getMemoryCache:function(callback,key,defValue,err){
				storageCallback("getMemoryCache",callback);
				execute("getMemoryCache",[key,defValue],err);
			},setOfflineCache:function(key,value,err){
				execute("setOfflineCache", [key,value],err);
			},getOfflineCache:function(callback,key,defValue,err){
			},setOfflineCache:function(key,value,isEncrypt,err){
				if(isEncrypt==undefined){
					isEncrypt = false;
				}
				execute("setOfflineCache", [key,value,isEncrypt],err);
			},getOfflineCache:function(callback,key,defValue,isEncrypt,err){
				if(isEncrypt==undefined){
					isEncrypt = false;
				}
				storageCallback("getOfflineCache",callback);
				return execute("getOfflineCache", [key,defValue],err);
				return execute("getOfflineCache", [key,defValue,isEncrypt],err);
			},removeOfflineCache:function(key,err){
				execute("removeOfflineCache", [key],err);
			},clearOfflineCache:function(err){