Merge branch 'master' of http://10.1.235.20:3000/ipu/android-share

display-client/AndroidManifest.xml

@@ -112,6 +112,10 @@
        <activity
            android:name="com.wade.mobile.ui.activity.OpenUrlActivity">
        </activity>
        <!-- 打开自定义浏览器 -->
        <activity
            android:name="com.wade.mobile.common.browser.BrowserActivity">
        </activity>
        <!-- 侧滑菜单 -->
        <activity android:name="com.wade.mobile.ui.activity.SlidingMenuActivity"
            android:theme="@style/SlidingMenuTheme" >
@@ -136,17 +140,17 @@
        </activity> 
        -->
        <!-- 单个扫码 -->
        <activity
        <!-- <activity
            android:name="com.ai.ipu.scan.activity.CaptureSingleActivity"
            android:configChanges="orientation|keyboardHidden"   
            android:screenOrientation="portrait" >
        </activity>
        </activity> -->
        <!-- 多个扫码 -->
        <activity
      <!--   <activity
            android:name="com.ai.ipu.scan.activity.CaptureMultipleActivity"
            android:configChanges="orientation|keyboardHidden"   
            android:screenOrientation="portrait" >
        </activity>
        </activity> -->
        <!-- 音乐播放服务 -->
        <service android:name="com.wade.mobile.common.audio.play.AudioPlayerService" />
        <!-- 录制声音

display-client/assets/mobile-action.xml

@@ -22,6 +22,8 @@
	<action name="downloadWithServlet" class="com.wade.mobile.func.MobileNetWork" method="downloadWithServlet"></action>
	<action name="uploadWithServlet" class="com.wade.mobile.func.MobileNetWork" method="uploadWithServlet"></action>
	<action name="openBrowser" class="com.wade.mobile.func.MobileNetWork" method="openBrowser" ></action>
	<!-- 打开浏览器插件 -->
	<action name="openIpuBrowser" class="com.wade.mobile.func.MobileBrowser" method="openIpuBrowser" ></action>
	<!-- NFC -->
	<action name="initNfc" class="com.wade.mobile.func.MobileDevice" method="initNfc"></action>
	

display-client/project.properties

@@ -13,5 +13,5 @@
# Project target.
target=android-22
android.library=false
android.library.reference.1=../wade-mobile-common
android.library.reference.2=../wade-mobile-lib
android.library.reference.1=..\\wade-mobile-common
android.library.reference.2=..\\wade-mobile-lib

display-client/src/com/ai/ipu/display/MainActivity.java

@@ -8,23 +8,23 @@ import android.os.Bundle;
import android.util.DisplayMetrics;
import android.view.View;
import com.ai.ipu.ipupathmenu.PathMenu;
import com.ai.ipu.ipupathmenu.PathMenu.OnButtonClickListener;
import com.ai.ipu.mobile.app.AppInfoUtil;
import com.ai.ipu.mobile.app.ApplicationManager;
import com.ai.ipu.mobile.app.MobileCheck;
import com.ai.ipu.mobile.app.MobileOperation;
import com.ai.ipu.mobile.res.assets.AssetsUtil;
import com.ai.ipu.mobile.util.IpuMobileLog;
//import com.baidu.mapapi.SDKInitializer;
import com.umeng.analytics.MobclickAgent;
import com.wade.mobile.app.AppRecord;
import com.wade.mobile.frame.activity.TemplateMainActivity;
import com.wade.mobile.frame.config.ServerConfig;
import com.wade.mobile.func.MobileUI;
import com.wade.mobile.ui.comp.dialog.ConfirmBlockDialog;
import com.wade.mobile.ui.comp.menu.PathMenu;
import com.wade.mobile.ui.comp.menu.PathMenu.OnButtonClickListener;
import com.wade.mobile.ui.view.FlipperLayout;
import com.wade.mobile.util.Constant;
import com.wade.mobile.util.Constant.LoadingDialogStyle;
import com.wade.mobile.util.Messages;
public class MainActivity extends TemplateMainActivity {

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

@@ -1,173 +1,176 @@
package com.ai.server.bean;
import java.io.FileInputStream;
import java.io.IOException;
import java.io.InputStream;
import java.util.Date;
import java.util.Iterator;
import java.util.List;
import java.util.Map;
import java.util.Set;
import javax.servlet.http.HttpServletRequest;
import org.apache.commons.fileupload.FileItem;
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.file.PropertiesHelper;
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.fs.util.FsFactory;
import com.ai.ipu.server.servlet.ServletManager;
import com.ai.ipu.server.util.MobileUtility;
import com.ai.ipu.server.util.MobileServerException;
import com.ai.server.core.bean.IpuAppBean;
import com.ai.server.dao.FileDao;
import com.ai.server.util.Constant;
import com.ai.tfs.DbFs;
import com.ailk.common.data.IData;
import com.ailk.common.data.IDataset;
import com.ailk.common.data.impl.DataMap;
import com.ailk.common.data.impl.DatasetList;
public class UploadDownloadWithTfsBean extends IpuAppBean {
    private final String path = this.getClass().getClassLoader().getResource("tfsdb.properties").getPath();
    transient protected static final ILogger log = IpuLoggerFactory.createLogger(UploadDownloadWithTfsBean.class);
    private static final String IPU_FILE = "ipu_file";
    /**
     * 将流文件上传至tfs服务端，且修改tfsdb.properties文件
     * 将流文件上传至tfs服务端，且记录数据库
     * 
     * @param param
     * @return
     * @throws Exception
     */
    public IData uploadPic(IData param) throws Exception {
        String fileName = param.getString("fileName");
        // 1.从客户端接受流文件
        DiskFileItemFactory factory = new DiskFileItemFactory(); // 获得磁盘文件条目工厂
        ServletFileUpload upload = new ServletFileUpload(factory);
        HttpServletRequest request = ServletManager.getRequest();
        if (!ServletFileUpload.isMultipartContent(request)) {
            MobileUtility.error("没有检测到文件,请重新提交!");
        }
        List<FileItem> fileList = upload.parseRequest(request);
        Iterator<FileItem> it = fileList.iterator();
        IData result = new DataMap();
        InputStream is = null;
        while (it.hasNext()) {
            FileItem item = it.next();
            if (!item.isFormField()) {
                is = item.getInputStream();
                break;
            }
        }
        // 2.将流文件存放tfs服务端，并返回存放信息
        String fileHashCode = null;
        FileInputStream fis = null;
        try {
            UniqueCacheFs ucfs = new UniqueCacheFs();
            String fileName = param.getString("fileName");
            // 1.从客户端接受流文件
            DiskFileItemFactory factory = new DiskFileItemFactory(); // 获得磁盘文件条目工厂
            ServletFileUpload upload = new ServletFileUpload(factory);
            HttpServletRequest request = ServletManager.getRequest();
            if (!ServletFileUpload.isMultipartContent(request)) {
                throw new MobileServerException("没有检测到文件,请重新提交!");
            }
            List<FileItem> fileList = upload.parseRequest(request);
            Iterator<FileItem> it = fileList.iterator();
            while (it.hasNext()) {
                FileItem item = it.next();
                if (!item.isFormField()) {
                    is = item.getInputStream();
                    break;
                }
            }
            // 2.将流文件存放tfs服务端，并返回存放信息
            String fileHashCode = null;
            IBaseFs fs = new DbFs();
            fis = (FileInputStream) is;
            fileHashCode = ucfs.saveFile(fis);
            fileHashCode = fs.saveFile(fis);
            log.debug("fileName=[" + fileName + "] 上传tfs成功,返回值fileHashCode=[" + fileHashCode + "]");
            // 3.业务数据保存。无就插入；有不必插入
            if (fileHashCode != null) {
                FileDao dao = new FileDao(Constant.CONNNAME);
                IData fileParam = new DataMap();
                fileParam.put("file_name", fileName);
                fileParam.put("file_hash_code", fileHashCode);
                // fileParam.put("file_path", null);
                fileParam.put("create_time", new Date());
                IDataset list = dao.queryFileListByFileHashCode(fileParam);
                if (list == null || list.isEmpty()) {
                    dao.insertFile(fileParam);
                    log.debug("fileHashCode=[" + fileHashCode + "] 未经存在,插入业务数据库表tab_file。");
                } else {
                    log.debug("fileHashCode=[" + fileHashCode + "] 已经存在,跳过插入业务数据库表tab_file步骤。");
                }
            }
            result.put("flag", "success");
        }
        catch (Exception e) {
            // TODO Auto-generated catch block
            e.printStackTrace();
            log.error(e.getMessage());
            result.put("flag", "fail");
        }
        finally {
            if (fis != null) {
                fis.close();
                try {
                    fis.close();
                }
                catch (Exception e) {
                    log.error(e.getMessage());
                }
            }
            if (is != null) {
                is.close();
                try {
                    is.close();
                }
                catch (Exception e) {
                    log.error(e.getMessage());
                }
            }
        }
        // 3.将信息记录数据库，或tfsdb.properties文件
        PropertiesHelper pro = new PropertiesHelper(path);
        String value = fileName + "," + fileHashCode + "," + "123";
        Set<Object> keySet = pro.keySet();
        String key = getNextKey(keySet);
        pro.put(key, value);
        IData result = new DataMap();
        result.put("flag", "success");
        return result;
    }
    private String getNextKey(Set<Object> keySet) {
        int maxNum = 0;
        for (Object key : keySet) {
            maxNum = Integer.valueOf((String) key) > maxNum ? Integer.valueOf((String) key) : maxNum;
        }
        return (maxNum + 1) + "";
    }
    public InputStream downloadPic(IData param) throws Exception {
        String id = param.getString("id");
        // 1.遍历tfsdb.properties文件，找到fileHashCode值
        PropertiesHelper pro = new PropertiesHelper(path);
        String value = pro.getProperty(id);
        String[] arr = value.split(",");
        if (arr.length != 3) {
            MobileUtility.error("读取tfsdb.properties格式有误。");
        if (StringUtils.isEmpty(id)) {
            throw new MobileServerException("参数id缺失。");
        }
        // 1.找到fileHashCode值
        FileDao dao = new FileDao(Constant.CONNNAME);
        IData fileObj = dao.queryFileListById(param);
        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 fileName = arr[0];
        String fileHashCode = arr[1];
        String md5 = arr[2];
        String fileHashCode = fileObj.getString("file_hash_code");
        // 2.根据fileHashCode从tfs获取，并转化为本地文件
        IBaseFs fs = FsFactory.getUniqueCacheFs();
        String localFileName = "temp/"+fileName;
        boolean result = fs.takeFile(fileHashCode, localFileName);
        
        if(result){
            return new FileInputStream(FileUtil.connectFilePath("c:/", localFileName));
        IBaseFs fs = new DbFs();
        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;
    }
    public IData deletePic(IData param) throws Exception {
        String id = param.getString("id");
        if (StringUtils.isEmpty(id)) {
            throw new MobileServerException("参数id缺失。");
        }
        // 1.删除tfs服务端资源
        PropertiesHelper pro = new PropertiesHelper(path);
        String value = pro.getProperty(id);
        String[] arr = value.split(",");
        if (arr.length != 3) {
            MobileUtility.error("读取tfsdb.properties格式有误。");
        FileDao dao = new FileDao(Constant.CONNNAME);
        IData fileObj = dao.queryFileListById(param);
        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");
        IBaseFs fs = new DbFs();
        boolean deleteResult = fs.deleteFile(fileHashCode);
        if (!deleteResult) {
            throw new MobileServerException("tfs删除资源失败。");
        }
        String fileName = arr[0];
        String fileHashCode = arr[1];
        String md5 = arr[2];
        UniqueCacheFs ucfs = new UniqueCacheFs();
        ucfs.deleteFile(fileHashCode);
        // 2.删除tfsdb.properties一条记录
        pro.remove(id);
        // 2.删除数据库记录
        dao.deleteFileById(param);
        IData result = new DataMap();
        result.put("flag", "success");
        return result;
    }
    public IData getPictureList(IData param) throws IOException {
    public IData getPictureList(IData param) throws Exception {
        IData result = new DataMap();
        IDataset list = new DatasetList();
        IData obj = new DataMap();
        PropertiesHelper pro = new PropertiesHelper(path);
        Map<String, ?> map = pro.getProMap();
        Set<String> keySet = map.keySet();
        String value;
        for (String key : keySet) {
            obj = new DataMap();
            obj.put("id", key);
            value = (String) map.get(key);
            String[] arr = value.split(",");
            if (arr.length != 3) {
                MobileUtility.error("tfsdb.properties配置有误。");
            }
            obj.put("fileName", arr[0]);
            obj.put("fileHashCode", arr[1]);
            obj.put("fileMD5", arr[2]);
            list.add(obj);
        }
        FileDao dao = new FileDao(Constant.CONNNAME);
        IDataset list = dao.queryFileList(null);
        result.put("infoList", list);
        return result;
    }

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

@@ -0,0 +1,42 @@
package com.ai.server.dao;
import com.ai.ipu.server.db.dao.impl.BaseDAO;
import com.ailk.common.data.IData;
import com.ailk.common.data.IDataset;
public class FileDao extends BaseDAO {
    public FileDao(String connName) throws Exception {
        super(connName);
    }
    public IDataset queryFileList(IData param) throws Exception {
        String sql = "SELECT * FROM tab_file ORDER BY create_time DESC";
        return this.queryList(sql, param);
    }
    public IDataset queryFileListByFileHashCode(IData param) throws Exception {
        String sql = "SELECT * FROM tab_file WHERE file_hash_code=:file_hash_code";
        return this.queryList(sql, param);
    }
    
    public IData queryFileListById(IData param) throws Exception {
        String sql = "SELECT * FROM tab_file WHERE id=:id";
        return this.queryList(sql, param).first();
    }
    public void insertFile(IData param) throws Exception {
        String sql = "INSERT INTO tab_file (file_name, file_hash_code, file_path, create_time, remark) VALUES(:file_name, :file_hash_code, :file_path, :create_time, :remark)";
        this.executeUpdate(sql, param);
    }
    public void deleteFileByFileHashCode(IData param) throws Exception {
        String sql = "DELETE FROM tab_file WHERE file_hash_code=:file_hash_code";
        this.executeUpdate(sql, param);
    }
    
    public void deleteFileById(IData param) throws Exception {
        String sql = "DELETE FROM tab_file WHERE id=:id";
        this.executeUpdate(sql, param);
    }
}

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

@@ -0,0 +1,37 @@
package com.ai.server.dao;
import com.ai.ipu.server.db.dao.impl.BaseDAO;
import com.ailk.common.data.IData;
import com.ailk.common.data.IDataset;
public class TfsMapDao extends BaseDAO {
    public TfsMapDao(String connName) throws Exception {
        super(connName);
    }
    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 {
        String sql = "SELECT * FROM common_tfs_map WHERE md5=:md5";
        return this.queryList(sql, param);
    }
    public void insertTfsMap(IData param) throws Exception {
        String sql = "INSERT INTO common_tfs_map (file_hash_code, md5) VALUES(:file_hash_code, :md5)";
        this.executeUpdate(sql, param);
    }
    public void deleteTfsMapByFileHashCode(IData param) throws Exception {
        String sql = "DELETE FROM common_tfs_map WHERE file_hash_code=:file_hash_code";
        this.executeUpdate(sql, param);
    }
    
    public void updateTfsMap(IData param) throws Exception {
        String sql = "UPDATE common_tfs_map SET md5=:md5 WHERE file_hash_code=:file_hash_code";
        this.executeUpdate(sql, param);
    }
}

display-server/src/main/java/com/ai/server/util/Constant.java

@@ -1,6 +1,8 @@
package com.ai.server.util;
public class Constant {
    public static final String CONNNAME = "display";
    
    public static final String SUCCESS = "success";
    
	public static class Cache{

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

@@ -0,0 +1,181 @@
package com.ai.tfs;
import java.io.File;
import java.io.FileInputStream;
import java.io.OutputStream;
import com.ai.ipu.basic.cipher.MD5;
import com.ai.ipu.basic.file.FileUtil;
import com.ai.ipu.fs.cache.IFsUnique;
import com.ai.ipu.fs.impl.BaseFs;
import com.ai.ipu.fs.util.FsConstant;
import com.ai.ipu.fs.util.FsFactory;
/**
 * @author chengwb3 以MD5值为key的一系列操作，数据库存放记录
 */
public class DbFs extends BaseFs {
    private String fsUniqueClassPath = "com.ai.tfs.DbFsUnique";
    private IFsUnique fsUnique;
    public DbFs() throws Exception {
        fsUnique = FsFactory.getFsUnique(fsUniqueClassPath);
    }
    public String saveFile(String fileName) throws Exception {
        String md5 = MD5.hexDigestByFilePath(getLocalFileName(fileName)); // 计算md5值是为了排重
        String tfsFileHashCode = fsUnique.checkExists(md5);
        if (tfsFileHashCode != null) {
            return tfsFileHashCode;
        } else {
            tfsFileHashCode = super.saveFile(fileName);
            fsUnique.recordUnique(md5, tfsFileHashCode);// 上传排重时使用
        }
        return tfsFileHashCode;
    }
    @Override
    public String saveFile(FileInputStream fis) throws Exception {
        String md5 = MD5.hexDigest(fis); // 计算md5值是为了排重
        String tfsFileHashCode = fsUnique.checkExists(md5);
        if (tfsFileHashCode != null) {
            return tfsFileHashCode;
        } else {
            tfsFileHashCode = super.saveFile(fis);
            fsUnique.recordUnique(md5, tfsFileHashCode);// 上传排重时使用
        }
        return tfsFileHashCode;
    }
    /*
     * 通过fileHashCode获取文件，并转化为指定localFileName的文件
     * localFileName是绝对路径。例如：/home/ipuapp/web/deploy/8081 + / + ipu_file
     */
    @Override
    public boolean takeFile(String tfsFileHashCode, String localFileName) throws Exception {
        String cacheFilePath = FileUtil.connectFilePath(FsConstant.CACHE_DIRECTORY, tfsFileHashCode);
        File cacheFile = new File(FileUtil.connectFilePath(tfsUploadFileHome, cacheFilePath));
        String md5 = DbFsUnique.getMd5ByFileHashCode(tfsFileHashCode);
        // 使用缓存文件需要先判断md5值是否相同
        if (needLocalFileCache && cacheFile.exists() && MD5.hexDigestByFile(cacheFile).equals(md5)) {
            FileUtil.initDirectory(localFileName);
            FileUtil.writeFile(new FileInputStream(cacheFile), localFileName);
            return true;
        } else {
            /* 没有目录先建目录 */
            FileUtil.initDirectory(FileUtil.connectFilePath(tfsUploadFileHome, cacheFilePath));
            FileUtil.initDirectory(localFileName);
            boolean bo = super.takeFile(tfsFileHashCode, cacheFilePath);// 先下载到缓存目录下
            if (bo) {
                FileUtil.copyFile(FileUtil.connectFilePath(tfsUploadFileHome, cacheFilePath), localFileName);
                fsUnique.recordUnique(md5, tfsFileHashCode);
            }
            return bo;
        }
    }
    // public boolean takeFile(String tfsFileHashCode, String localFileName)
    // throws Exception {
    // String cacheFilePath =
    // FileUtil.connectFilePath(FsConstant.CACHE_DIRECTORY, tfsFileHashCode);
    // File cacheFile = new File(FileUtil.connectFilePath(tfsUploadFileHome,
    // cacheFilePath));
    //
    // String md5 = DbFsUnique.getMd5ByFileHashCode(tfsFileHashCode);
    // // 使用缓存文件需要先判断md5值是否相同
    //
    // if (needLocalFileCache && cacheFile.exists() &&
    // MD5.hexDigestByFile(cacheFile).equals(md5)) {
    //
    // FileUtil.writeFile(new FileInputStream(cacheFile),
    // getLocalFileName(localFileName));
    // return true;
    // } else {
    // /* 没有目录先建目录 */
    // FileUtil.initDirectory(FileUtil.connectFilePath(tfsUploadFileHome,
    // cacheFilePath));
    // FileUtil.initDirectory(FileUtil.connectFilePath(tfsUploadFileHome,
    // localFileName));
    //
    // boolean bo = super.takeFile(tfsFileHashCode, cacheFilePath);// 先下载到缓存目录下
    // if (bo) {
    // FileUtil.copyFile(FileUtil.connectFilePath(tfsUploadFileHome,
    // cacheFilePath),
    // FileUtil.connectFilePath(tfsUploadFileHome, localFileName));
    // fsUnique.recordUnique(md5, tfsFileHashCode);
    // }
    // return bo;
    // }
    // }
    @Override
    public boolean takeFile(String tfsFileHashCode, OutputStream out) throws Exception {
        String cacheFilePath = FileUtil.connectFilePath(FsConstant.CACHE_DIRECTORY, tfsFileHashCode);
        File cacheFile = new File(FileUtil.connectFilePath(tfsUploadFileHome, cacheFilePath));
        String md5 = DbFsUnique.getMd5ByFileHashCode(tfsFileHashCode);
        // 使用缓存文件需要先判断md5值是否相同
        if (needLocalFileCache && cacheFile.exists() && MD5.hexDigestByFile(cacheFile).equals(md5)) {
            FileUtil.writeFile(new FileInputStream(cacheFile), out);// 是否需要内部关闭out输出流
            return true;
        } else {
            /* 没有目录先建目录 */
            FileUtil.initDirectory(FileUtil.connectFilePath(tfsUploadFileHome, cacheFilePath));
            boolean bo = super.takeFile(tfsFileHashCode, cacheFilePath);// 先下载到缓存目录下
            if (bo) {
                FileInputStream fis = new FileInputStream(FileUtil.connectFilePath(tfsUploadFileHome, cacheFilePath));
                FileUtil.writeFile(fis, out);
                fsUnique.recordUnique(md5, tfsFileHashCode);
            }
            return bo;
        }
    }
    // public boolean takeFile(String tfsFileHashCode, OutputStream out) throws
    // Exception {
    //
    // String cacheFilePath =
    // FileUtil.connectFilePath(FsConstant.CACHE_DIRECTORY, tfsFileHashCode);
    // File cacheFile = new File(FileUtil.connectFilePath(tfsUploadFileHome,
    // cacheFilePath));
    //
    // String md5 = DbFsUnique.getMd5ByFileHashCode(tfsFileHashCode);
    // // 使用缓存文件需要先判断md5值是否相同
    // if (needLocalFileCache && cacheFile.exists() &&
    // MD5.hexDigestByFile(cacheFile).equals(md5)) {
    // FileUtil.writeFile(new FileInputStream(cacheFile), out);// 是否需要内部关闭out输出流
    // return true;
    // } else {
    // /* 没有目录先建目录 */
    // FileUtil.initDirectory(FileUtil.connectFilePath(tfsUploadFileHome,
    // cacheFilePath));
    //
    // boolean bo = super.takeFile(tfsFileHashCode, cacheFilePath);// 先下载到缓存目录下
    // if (bo) {
    // FileInputStream fis = new
    // FileInputStream(FileUtil.connectFilePath(tfsUploadFileHome,
    // cacheFilePath));
    // FileUtil.writeFile(fis, out);
    // fsUnique.recordUnique(md5, tfsFileHashCode);
    // }
    //
    // return bo;
    // }
    // }
    public boolean deleteFile(String tfsFileHashCode) throws Exception {
        boolean bo = super.deleteFile(tfsFileHashCode);
        if (bo) {
            fsUnique.cleanUnique(tfsFileHashCode);
        }
        return bo;
    }
}

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

@@ -0,0 +1,105 @@
package com.ai.tfs;
import com.ai.ipu.basic.log.ILogger;
import com.ai.ipu.basic.log.IpuLoggerFactory;
import com.ai.ipu.fs.cache.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;
/**
 * @author chengwb3 通过数据库判断唯一性的工具类
 */
public class DbFsUnique implements IFsUnique {
    transient protected static final ILogger log = IpuLoggerFactory.createLogger(DbFsUnique.class);
    /*
     * 根据文件的md5，检测tfs是否包含此文件
     */
    @Override
    public String 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;
        }
        return fileHashCode;
    }
    /*
     * 记录数据唯一性
     */
    @Override
    public void recordUnique(String md5, String fileHashCode) {
        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);
            if (null == tfsMapObj) {
                log.debug("之前未发现记录，插入数据库。");
                dao.insertTfsMap(param);
            } else {
                if (md5.equals(tfsMapObj.getString("md5"))) {
                    log.debug("发现对应记录且相同。");
                } else {
                    dao.updateTfsMap(param);
                    log.debug("发现对应记录且不相同，更改记录。");
                }
            }
        }
        catch (Exception e) {
            e.printStackTrace();
        }
    }
    /*
     * 清楚文件记录信息
     */
    @Override
    public boolean cleanUnique(String fileHashCode) {
        try {
            TfsMapDao dao = new TfsMapDao(Constant.CONNNAME);
            IData param = new DataMap();
            param.put("file_hash_code", fileHashCode);
            dao.deleteTfsMapByFileHashCode(param);
        }
        catch (Exception e) {
            e.printStackTrace();
            return false;
        }
        return true;
    }
    public static String getMd5ByFileHashCode(String fileHashCode) {
        String md5 = null;
        try {
            TfsMapDao dao = new TfsMapDao(Constant.CONNNAME);
            IData param = new DataMap();
            param.put("file_hash_code", fileHashCode);
            IData tfsMapObj = dao.queryTfsMapListByFileHashCode(param);
            if (tfsMapObj != null) {
                md5 = tfsMapObj.getString("md5");
            }
        }
        catch (Exception e) {
            e.printStackTrace();
            return md5;
        }
        return md5;
    }
}

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

@@ -16,4 +16,15 @@
		maxIdle="5"
		maxWait="1000"
		/>
	<display
		type="dbcp"
		driver="com.mysql.jdbc.Driver"
		url="jdbc:mysql://123.57.35.51:3307/display?useUnicode=true"
        user="ipu"
        passwd="ipumysql"
		initialSize="5"
		maxActive="20"
		maxIdle="5"
		maxWait="1000"
		/>
</database>

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

@@ -3,26 +3,25 @@
<memcache>
    <default-datacenter>center1</default-datacenter>
    <datacenter name="center1" >
        <!-- codecode查询缓存 -->
        <cluster name="codecode_cache">
        <!-- 单点登录缓存 -->
        <cluster name="SSN_CACHE">
            <heartbeat-second>2</heartbeat-second>
            <pool-size>16</pool-size>
            <address master="10.1.31.40:10001"/>
            <address master="123.57.35.51:10001"/>
        </cluster>
        
        <!-- 单点登录缓存 -->
        <cluster name="SSN_CACHE">
        <!-- codecode查询缓存 -->
        <cluster name="codecode_cache">
            <heartbeat-second>2</heartbeat-second>
            <pool-size>16</pool-size>
            <address master="10.1.31.40:10002"/>
            <address master="123.57.35.51:10002"/>
        </cluster>
        
        <!-- tfs缓存 -->
        <cluster name="tfs_cache">
            <heartbeat-second>2</heartbeat-second>
            <pool-size>16</pool-size>
            <address master="114.215.100.48:11001"/>
            <address master="114.215.100.48:11002"/>
            <address master="123.57.35.51:10003"/>
        </cluster>
    </datacenter>
</memcache>

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

@@ -1,7 +1,7 @@
<?xml version="1.0" encoding="UTF-8"?>
<configs>
      <!-- 整个进程中系统最多等待多少个请求,取决于你有多少个线程并发的请求TFS -->
       <config name="maxWaitThread" value="100"/>
       <config name="maxWaitThread" value="1000"/>
      <!-- 单个请求最大的等待时间(ms) 超过这个时间放弃这次请求-->
      <config name="timeout" value="20000"/>
      <!-- Tfs master nameserver ip address -->
@@ -9,11 +9,11 @@
      <!-- TFS在读取文件的时候会缓存block所在的数据服务器ip,这个参数配置了最多缓存的记录个数!-->
      <config name="maxCacheItemCount" value="10000"/>
      <!-- 上一项缓存最大有效的时间(ms)!-->
      <config name="maxCacheTime" value="5000"/>
      <config name="maxCacheTime" value="50000"/>
      <!-- tfs保存失败后最大重试次数-->
      <config name="maxTryNum" value="3"/>
      <!-- tfs本地文件存放的根目录 -->
      <config name="uploadFileHome" value="c:/"/>
      <config name="uploadFileHome" value="/home/ipuapp/web/webapps/display"/>
      <!-- 是否开启本地文件缓存。缺省为true，开启。不想开启需要设置为false -->
      <config name="localFileCached" value="false"/>
      

display-server/src/main/webapp/biz/js/more/scene/TfsDemo.js

@@ -1,7 +1,7 @@
require(["mobile","common","hammer","handlebars","wadeMobile","util"],function(Mobile,Common,Hammer,Handlebars,WadeMobile){	
	
	var maxNum = "3";//允许上传的最大数量
	var localPicRelativePath = "picture/my2.png";//被查看的图片的本地路径
	var localPicRelativePath = "picture/tfsFile.png";//被查看的图片的本地路径
	
	initData();
	

display-server/src/main/webapp/biz/js/plugin/pageHandler/pageHandler.js

@@ -12,15 +12,22 @@ require(["domReady!","wadeMobile","mobile","util"], function(doc,WadeMobile,Mobi
	$("#loadTemplate").tap(function(){
		Mobile.loadTemplate("PageA");
	});
	// 被打开的url，不管停留在哪一层页面，按返回会提示退出
	$("#openUrl").tap(function(){
		Mobile.openUrl("https://www.baidu.com");
	});
	// 被打开的url，不管停留在哪一层页面，直接退出至ipu主页面
	$("#loadUrl").tap(function(){
		Mobile.loadUrl("https://www.baidu.com");
	});
	// 打开原生的浏览器窗口
	$("#openBrowser").tap(function(){
		WadeMobile.openBrowser("https://www.baidu.com");
	});
	// 在IPU应用中集成浏览器功能，打开自定义浏览器
	$("#openIpuBroswer").tap(function() {
		WadeMobile.openIpuBrowser("https://www.baidu.com","true");
	});
	$("#back").tap(function(){
		Mobile.openPage("KeyDownListen");
	});

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

@@ -162,6 +162,8 @@ define(["require"],function(require) {
				execute("shareByBluetooth", [],err);
			},openBrowser:function(url,err){
				execute("openBrowser",[url],err);
			},openIpuBrowser:function(url,hasTitle,err){
				execute("openIpuBrowser",[url,hasTitle],err);
			},setSmsListener:function(callback,telString,err){
				storageCallback("setSmsListener", callback);
				execute("setSmsListener", [telString],err);

display-server/src/main/webapp/template/webapp/more/scene/TfsDemo.html

@@ -38,7 +38,7 @@
{{#each infoList}}
<li>
	<div class="content">
		<div class="main">{{fileName}}</div>
		<div class="main">{{file_name}}</div>
		<div class="side">
			<div class="link" id="download" data-id="{{id}}">查看</div>
		</div>

display-server/src/main/webapp/template/webapp/plugin/PageHandler/PageHandler.html

@@ -69,6 +69,13 @@
						<div class="fn fn-2">测试</div>
					</div>
				</li>
				
				<li id="openIpuBroswer">
					<div class="content">
						<div class="main">openIpuBroswer</div>
						<div class="fn fn-2">测试</div>
					</div>
				</li>
			</ul>
		</div>
		

ipu-pathmenu/project.properties

@@ -1,17 +0,0 @@
# This file is automatically generated by Android Tools.
# Do not modify this file -- YOUR CHANGES WILL BE ERASED!
#
# This file must be checked in Version Control Systems.
#
# To customize properties used by the Ant build system edit
# "ant.properties", and override values to adapt the script to your
# project structure.
#
# To enable ProGuard to shrink and obfuscate your code, uncomment this (available properties: sdk.dir, user.home):
#proguard.config=${sdk.dir}/tools/proguard/proguard-android.txt:proguard-project.txt
# Project target.
target=android-15
android.library=true
android.library.reference.1=..\\wade-mobile-lib
android.library.reference.2=../wade-mobile-common

ipupathmenu-lib/.classpath

@@ -1,8 +0,0 @@
<?xml version="1.0" encoding="UTF-8"?>
<classpath>
	<classpathentry kind="src" path="gen"/>
	<classpathentry kind="con" path="com.android.ide.eclipse.adt.ANDROID_FRAMEWORK"/>
	<classpathentry exported="true" kind="con" path="com.android.ide.eclipse.adt.LIBRARIES"/>
	<classpathentry exported="true" kind="con" path="com.android.ide.eclipse.adt.DEPENDENCIES"/>
	<classpathentry kind="output" path="bin/classes"/>
</classpath>

ipupathmenu-lib/AndroidManifest.xml

@@ -1,26 +0,0 @@
<?xml version="1.0" encoding="utf-8"?>
<manifest xmlns:android="http://schemas.android.com/apk/res/android"
    package="com.ai.ipu.ipupathmenu"
    android:versionCode="1"
    android:versionName="1.0" >
    <uses-sdk
        android:minSdkVersion="15"
        android:targetSdkVersion="21" />
    <application
        android:allowBackup="true"
        android:label="@string/app_name"
        android:theme="@style/AppTheme" >
        <activity
            android:name=".MainActivity"
            android:label="@string/app_name" >
            <intent-filter>
                <action android:name="android.intent.action.MAIN" />
                <category android:name="android.intent.category.LAUNCHER" />
            </intent-filter>
        </activity>
    </application>
</manifest>

ipupathmenu-lib/proguard-project.txt

@@ -1,20 +0,0 @@
# To enable ProGuard in your project, edit project.properties
# to define the proguard.config property as described in that file.
#
# Add project specific ProGuard rules here.
# By default, the flags in this file are appended to flags specified
# in ${sdk.dir}/tools/proguard/proguard-android.txt
# You can edit the include path and order by changing the ProGuard
# include property in project.properties.
#
# For more details, see
#   http://developer.android.com/guide/developing/tools/proguard.html
# Add any project specific keep options here:
# If your project uses WebView with JS, uncomment the following
# and specify the fully qualified class name to the JavaScript interface
# class:
#-keepclassmembers class fqcn.of.javascript.interface.for.webview {
#   public *;
#}

ipupathmenu-lib/project.properties

@@ -1,15 +0,0 @@
# This file is automatically generated by Android Tools.
# Do not modify this file -- YOUR CHANGES WILL BE ERASED!
#
# This file must be checked in Version Control Systems.
#
# To customize properties used by the Ant build system edit
# "ant.properties", and override values to adapt the script to your
# project structure.
#
# To enable ProGuard to shrink and obfuscate your code, uncomment this (available properties: sdk.dir, user.home):
#proguard.config=${sdk.dir}/tools/proguard/proguard-android.txt:proguard-project.txt
# Project target.
target=android-22
android.library=true

ipupathmenu-lib/res/values-v11/styles.xml

@@ -1,11 +0,0 @@
<resources>
    <!--
        Base application theme for API 11+. This theme completely replaces
        AppBaseTheme from res/values/styles.xml on API 11+ devices.
    -->
    <style name="AppBaseTheme" parent="android:Theme.Holo.Light">
        <!-- API 11 theme customizations can go here. -->
    </style>
</resources>

ipupathmenu-lib/res/values-v14/styles.xml

@@ -1,12 +0,0 @@
<resources>
    <!--
        Base application theme for API 14+. This theme completely replaces
        AppBaseTheme from BOTH res/values/styles.xml and
        res/values-v11/styles.xml on API 14+ devices.
    -->
    <style name="AppBaseTheme" parent="android:Theme.Holo.Light.DarkActionBar">
        <!-- API 14 theme customizations can go here. -->
    </style>
</resources>

ipupathmenu-lib/res/values/dimens.xml

@@ -1,7 +0,0 @@
<resources>
    <!-- Default screen margins, per the Android Design guidelines. -->
    <dimen name="activity_horizontal_margin">16dp</dimen>
    <dimen name="activity_vertical_margin">16dp</dimen>
</resources>

ipupathmenu-lib/res/values/strings.xml

@@ -1,6 +0,0 @@
<?xml version="1.0" encoding="utf-8"?>
<resources>
    <string name="app_name">ipu快捷菜单</string>
</resources>

ipupathmenu-lib/res/values/styles.xml

@@ -1,20 +0,0 @@
<resources>
    <!--
        Base application theme, dependent on API level. This theme is replaced
        by AppBaseTheme from res/values-vXX/styles.xml on newer devices.
    -->
    <style name="AppBaseTheme" parent="android:Theme.Light">
        <!--
            Theme customizations available in newer API levels can go in
            res/values-vXX/styles.xml, while customizations related to
            backward-compatibility can go here.
        -->
    </style>
    <!-- Application theme. -->
    <style name="AppTheme" parent="AppBaseTheme">
        <!-- All customizations that are NOT specific to a particular API-level can go here. -->
    </style>
</resources>

wade-mobile-common/.classpath

@@ -1,8 +1,8 @@
<?xml version="1.0" encoding="UTF-8"?>
<classpath>
	<classpathentry kind="src" path="gen"/>
	<classpathentry kind="con" path="com.android.ide.eclipse.adt.ANDROID_FRAMEWORK"/>
	<classpathentry exported="true" kind="con" path="com.android.ide.eclipse.adt.DEPENDENCIES"/>
	<classpathentry exported="true" kind="con" path="com.android.ide.eclipse.adt.LIBRARIES"/>
	<classpathentry kind="con" path="com.android.ide.eclipse.adt.ANDROID_FRAMEWORK"/>
	<classpathentry kind="output" path="bin/classes"/>
</classpath>

wade-mobile-common/res/layout/browser.xml

@@ -0,0 +1,77 @@
<LinearLayout xmlns:android="http://schemas.android.com/apk/res/android"
    xmlns:tools="http://schemas.android.com/tools"
    android:layout_width="fill_parent"
    android:layout_height="fill_parent"
    android:background="#ffffff"
    android:orientation="vertical" >
    <LinearLayout
        android:layout_width="fill_parent"
        android:layout_height="wrap_content"
        android:orientation="vertical" >
        <LinearLayout
            android:id="@+id/layout"
            android:layout_width="fill_parent"
            android:layout_height="wrap_content"
            android:orientation="horizontal"
            android:visibility="gone" >
            <EditText
                android:id="@+id/et_url"
                android:layout_width="0dp"
                android:layout_height="wrap_content"
                android:layout_weight="1"
                android:inputType="textUri"
                android:singleLine="true" />
            <Button
                android:id="@+id/btn_visit"
                android:layout_width="wrap_content"
                android:layout_height="wrap_content"
                android:text="@string/visit" />
        </LinearLayout>
        <LinearLayout
            android:id="@+id/ll_btn"
            android:layout_width="fill_parent"
            android:layout_height="wrap_content"
            android:gravity="center_horizontal"
            android:orientation="horizontal" >
            <Button
                android:id="@+id/btn_home"
                android:layout_width="wrap_content"
                android:layout_height="wrap_content"
                android:layout_weight="1"
                android:text="@string/home" />
            <Button
                android:id="@+id/btn_left"
                android:layout_width="wrap_content"
                android:layout_height="wrap_content"
                android:layout_weight="1"
                android:text="@string/left" />
            <Button
                android:id="@+id/btn_right"
                android:layout_width="wrap_content"
                android:layout_height="wrap_content"
                android:layout_weight="1"
                android:text="@string/right" />
            <Button
                android:id="@+id/btn_exit"
                android:layout_width="wrap_content"
                android:layout_height="wrap_content"
                android:layout_weight="1"
                android:text="@string/exit" />
        </LinearLayout>
        <WebView
            android:id="@+id/web"
            android:layout_width="fill_parent"
            android:layout_height="fill_parent" />
    </LinearLayout>
</LinearLayout>

wade-mobile-common/res/values/strings_browser.xml

@@ -0,0 +1,8 @@
<?xml version="1.0" encoding="utf-8"?>
<resources>
    <string name="home">主页</string>
    <string name="left">后退</string>
    <string name="right">前进</string>
    <string name="exit">退出</string>
    <string name="visit">访问</string>
</resources>

wade-mobile-func/src/com/wade/mobile/func/MobileBrowser.java

@@ -0,0 +1,35 @@
package com.wade.mobile.func;
import org.json.JSONArray;
import android.content.Intent;
import android.os.Bundle;
import com.wade.mobile.common.browser.BrowserActivity;
import com.wade.mobile.frame.IWadeMobile;
import com.wade.mobile.frame.plugin.Plugin;
/**
 * 打开浏览器插件
 * @author wangyujuan
 *
 */
public class MobileBrowser extends Plugin {
	
	private int BROWSER = 90004;
	public MobileBrowser(IWadeMobile wademobile) {
		super(wademobile);
	}
	public void openIpuBrowser(JSONArray param) throws Exception {
		String url = param.getString(0);
		String hasTitle = param.getString(1);
		Intent intent = new Intent(context, BrowserActivity.class);
	    Bundle bundle=new Bundle();
	    bundle.putString("url", url);
	    bundle.putString("hasTitle", hasTitle);
	    intent.putExtras(bundle);
	    startActivityForResult(intent, BROWSER);
	}
}