package com.hdfs.file.serviceImpl;
import java.io.BufferedInputStream;
import java.io.BufferedOutputStream;
import java.io.File;
import java.io.FileInputStream;
import java.io.FileNotFoundException;
import java.io.FileOutputStream;
import java.io.IOException;
import java.io.InputStream;
import java.io.OutputStream;
import java.security.KeyPair;
import java.security.interfaces.RSAPrivateKey;
import java.security.interfaces.RSAPublicKey;
import java.text.ParseException;
import java.text.SimpleDateFormat;
import java.util.ArrayList;
import java.util.Date;
import java.util.List;
import javax.crypto.KeyGenerator;
import javax.crypto.SecretKey;
import javax.crypto.spec.SecretKeySpec;
import net.sf.json.JSONObject;
import net.sf.json.util.JSONUtils;
import com.encryption.DesEncrypter;
import com.encryption.RSAEncrypter;
import com.hdfs.comm.util.fileUtil;
import com.hdfs.comm.util.pathToId;
import com.hdfs.file.bean.HdfsFile;
import com.hdfs.file.bean.HdfsMemory;
import com.hdfs.file.bean.checkFile;
import com.hdfs.file.bean.dillResult;
import com.hdfs.file.dao.fileDao;
import com.hdfs.file.service.fileService;
import com.hdfs.user.bean.Users;
import com.hdfs.user.dao.userDao;
import com.hdfsTools.action.createAction;
import com.hdfsTools.action.deleteAction;
import com.hdfsTools.action.downLoadAction;
import com.hdfsTools.action.renameAction;
import com.hdfsTools.action.upLoadAction;
public class fileServiceImpl implements fileService {
public fileDao filedao;
public userDao userdao;
public userDao getUserdao() {
return userdao;
}
public void setUserdao(userDao userdao) {
this.userdao = userdao;
}
@Override
public String listFile(long currentId, long userId) {
List<HdfsFile> fileList = filedao.listFile(currentId, userId);// 获得文件列表
// 转化为json格式
ArrayList<checkFile> list = new ArrayList();
for (HdfsFile hdfsfile : fileList) {
checkFile file = new checkFile();
if (null == hdfsfile.getCreateTime()) {
file.setCreateTime("");
} else {
file.setCreateTime(hdfsfile.getCreateTime().toString());
}
if (null == hdfsfile.getDeadline()) {
file.setTime("");
} else {
file.setTime(hdfsfile.getDeadline().toString());
}
file.setId(hdfsfile.getFileId());
if (null == hdfsfile.getModifiedTime()) {
file.setModifiedTime("");
} else {
file.setModifiedTime(hdfsfile.getModifiedTime().toString());
}
file.setName(hdfsfile.getFileName());
file.setParentId(hdfsfile.getParentid());
if (null == hdfsfile.getSafeLevel()) {
file.setSaveLevel(0);
} else {
file.setSaveLevel(hdfsfile.getSafeLevel());
}
if (null == hdfsfile.getSize()) {
file.setSize(-1);
} else {
file.setSize(hdfsfile.getSize());
}
file.setType(hdfsfile.getType());
file.setUrl(hdfsfile.getFileUrl());
list.add(file);
file = null;
}
JSONObject jsonresult = new JSONObject();
jsonresult.accumulate("list", list);
String jsonList = JSONUtils.valueToString(jsonresult);
System.out.println(jsonList);
return jsonList;
}
@Override
public String searchfile(String name, long userId) {
List<HdfsFile> fileList = filedao.SearchFile(name, userId);// 获得文件列表
// 转化为json格式
ArrayList<checkFile> list = new ArrayList();
System.out.println(fileList.toString());
for (HdfsFile hdfsfile : fileList) {
checkFile file = new checkFile();
if (null == hdfsfile.getCreateTime()) {
file.setCreateTime("");
} else {
file.setCreateTime(hdfsfile.getCreateTime().toString());
}
if (null == hdfsfile.getDeadline()) {
file.setTime("");
} else {
file.setTime(hdfsfile.getDeadline().toString());
}
file.setId(hdfsfile.getFileId());
if (null == hdfsfile.getModifiedTime()) {
file.setModifiedTime("");
} else {
file.setModifiedTime(hdfsfile.getModifiedTime().toString());
}
file.setName(hdfsfile.getFileName());
file.setParentId(hdfsfile.getParentid());
if (null == hdfsfile.getSafeLevel()) {
file.setSaveLevel(0);
} else {
file.setSaveLevel(hdfsfile.getSafeLevel());
}
if (null == hdfsfile.getSize()) {
file.setSize(-1);
} else {
file.setSize(hdfsfile.getSize());
}
file.setType(hdfsfile.getType());
file.setUrl(hdfsfile.getFileUrl());
list.add(file);
file = null;
}
JSONObject jsonresult = new JSONObject();
jsonresult.accumulate("list", list);
String jsonList = JSONUtils.valueToString(jsonresult);
System.out.println(jsonList);
return jsonList;
}
@Override
public List<HdfsFile> listAllFile() {
List<HdfsFile> fileList = filedao.listAllFile();
return fileList;
}
public fileDao getFiledao() {
return filedao;
}
public void setFiledao(fileDao filedao) {
this.filedao = filedao;
}
@Override
public Boolean mkdir(long parentId, String name, long userId)
throws IOException {
String parentPath = filedao.getFileUrl(parentId);// 获取父目录的id
// System.out.println("the filepath is:"+parentPath);
// String filePath=parentPath.substring(1, parentPath.length());
System.out.println("the filepath is:" + parentPath);
String newfile = null;
System.out.println(parentPath.length());
System.out.println(parentPath.lastIndexOf("/"));
if ((parentPath.length() - 1) == parentPath.lastIndexOf("/")) {
newfile = parentPath + name;
}// 新建文件的详细路径
else {
newfile = parentPath + "/" + name;
}
long fileId = pathToId.ParsepathToId(newfile);// hash得出fileid
HdfsFile hdfsfile = new HdfsFile(fileId, name, parentId, newfile, 0);
hdfsfile.setUserId(userId);
hdfsfile.setCreateTime(new Date());
hdfsfile.setModifiedTime(new Date());
boolean result = filedao.insertFile(hdfsfile);// 保存文件
createAction caction = new createAction();
caction.createDir(newfile);// 操作文件系统
return result;
}
@Override
public Boolean rootmkdir(long parentId, String name, long userId,
long rootid) throws IOException {
String parentPath = filedao.getFileUrl(parentId);// 获取父目录的id
// System.out.println("the filepath is:"+parentPath);
// String filePath=parentPath.substring(1, parentPath.length());
System.out.println("the filepath is:" + parentPath);
// newfile指向文件的完整路径
String newfile = null;
System.out.println(parentPath.length());
System.out.println(parentPath.lastIndexOf("/"));
if ((parentPath.length() - 1) == parentPath.lastIndexOf("/")) {
newfile = parentPath + name;
}// 新建文件的详细路径
else {
newfile = parentPath + "/" + name;
}
long fileId = rootid;// hash得出fileid
HdfsFile hdfsfile = new HdfsFile(fileId, name, parentId, newfile, 0);
hdfsfile.setUserId(userId);
hdfsfile.setCreateTime(new Date());
hdfsfile.setModifiedTime(new Date());
System.out.println(newfile);
boolean result = filedao.insertFile(hdfsfile);// 保存文件，即在数据库中保存该文件的信息
// 在hdfs文件系统创建相应的文件夹
createAction caction = new createAction();
caction.createDir(newfile);// 操作hdfs文件系统
return result;
}
@Override
public String deleteFile(long fileId, HdfsMemory memory) {
// TODO Auto-generated method stub
boolean deletedb = false;
String result = "";
HdfsFile file = filedao.findFile(fileId);
if (filedao.findFile(fileId) == null)
System.out.println("kongduixiang");// 获得文件的url
System.out.println("url is :" + file.getFileUrl());
deleteAction delete = new deleteAction();
boolean deletehdfs = delete.deleteDirector(file.getFileUrl());
if (deletehdfs) {
int delmem = filedao.deleteFilesmem(file.getFileUrl());
deletedb = filedao.deleteFiles(file.getFileUrl());// 删除数据库中该文件和子文件的记
基于hadoop，利用ssh框架实现hdfs网盘.zip （629个子文件） 
all-wcprops 532B all-wcprops 532B fileServiceImpl.class 17KB fileAction.class 14KB userAction.class 10KB fileImpl.class 9KB userImpl.class 6KB JsonUtil.class 6KB Monitor.class 5KB HdfsFile.class 4KB HdfsFileDelete.class 4KB checkImpl.class 4KB RSAEncrypter.class 3KB dillResult.class 3KB CheckAction.class 3KB Users.class 3KB DaoTest.class 3KB upLoadImpl.class 3KB ListUserAction.class 3KB Users.class 3KB HibernateSessionFactory.class 3KB upLoadAction.class 2KB checkFile.class 2KB NodesPrint.class 2KB DesEncrypter.class 2KB Test.class 2KB upLoadFileImpl.class 2KB BaseException.class 2KB userServiceImpl.class 2KB memoryAction.class 2KB deleteAction.class 2KB downLoadAction.class 2KB fileUtilTest.class 2KB fileService.class 2KB DFSOperatorTest.class 2KB Nodes.class 1KB test.class 1KB Nodes.class 1KB deleteImpl.class 1KB HdfsMemory.class 1KB fileDao.class 1KB BaseAction.class 1KB renameAction.class 1KB downLoadImpl.class 1KB fileUtil.class 1KB HdfsFilesystem.class 1KB createAction.class 1KB renameImpl.class 1KB mkdirImpl.class 977B upLoadFileImpl$1.class 843B pathToId.class 778B BaseAction.class 765B EmptyInterceptor.class 750B userDao.class 653B checkDao.class 566B userService.class 457B upLoadDao.class 420B BaseDao.class 330B deleteDao.class 283B downLoadDao.class 271B renameDao.class 262B mkdirDao.class 245B upLoadFile.class 184B .classpath 520B org.eclipse.wst.common.component 441B org.eclipse.wst.jsdt.ui.superType.container 49B jQuery_UI_uniq.css 20KB jQuery_UI_uniq.css 20KB style.css 19KB style.css 19KB webDisk.css 5KB webDisk.css 5KB aero.css 4KB aero.css 4KB chrome.css 3KB chrome.css 3KB facebook.css 3KB facebook.css 3KB mini.css 3KB mini.css 3KB visualize.css 2KB visualize.css 2KB iPhoneCheckboxes.css 2KB iPhoneCheckboxes.css 2KB jquery.cleditor.css 2KB jquery.cleditor.css 2KB login.css 1KB login.css 1KB dtree.css 795B dtree.css 795B IEfix.css 275B IEfix.css 275B entries 2KB entries 591B entries 591B entries 331B entries 331B
WDlogo.gif 43KB WDlogo.gif 43KB newicon.gif 4KB共 629 条
- 1
- 2
- 3
- 4
- 5
- 6
- 7
资源评论
博士僧小星
- 粉丝: 2386
- 资源: 5995
最新资源
- 燃气表摇杆上料压装机sw18全套技术开发资料100%好用.zip
- 美容品、电脑、书检测17-YOLO（v5至v11）、COCO、CreateML、Paligemma、TFRecord、VOC数据集合集.rar
- Runtime Editor v4.4.6
- 考虑需求响应的微网优化调度matlab 程序采用粒子群算法，风力发电机、光伏发电机、储能装置、燃气轮机、柴油机组等主体，考虑负荷需求响应、soc约束等，程序模块化编程，注释清楚，有对应资料
- STM32F103C8T6实现用2.4G模块NRF2401传输室内温湿度并显示OLED 源程序
- GENEX-Probe-3.5软件及GENEX-Assistant-3.5软件使用及报告输出指导书
- ， 免费，局域网，IP电话， SIP, VOIP, 视频通话，可与手机互通，手机上也安装 yealink
- 西门子S7-200PLC和MCGS组态的燃油锅炉控制系统
- Peer-to-peer LAN chat and file transfer， 局域网点对点消息传输和文件 传输，类似飞秋
- FreeModbus从机基于STM32平台移植源码
- 基于高频方波电压注入的永磁同步电机无感FOC 1.采用方波电压注入，减少了提取dq轴基频电流时LPF的使用，提高了系统的动态性能； 2.可实现带载起动和突加负载运行； 提供算法对应的参考文献和仿真模型
- 免费，局域网，IP电话， SIP, VOIP, 视频通话，可与手机互通，需要安装 手机版本
- 旅游景点数据集.zip
- 基于龙贝格观测器的永磁同步电机无感FOC 1.采用龙伯格观测器提取电机反电势，使用PLL从反电势中获得转子位置和速度信息 2.提供算法对应的参考文献和仿真模型，支持技术解答 仿真模型纯手工搭建
- 中国汽车基础软件发展白皮书4.0
- 背包、炸弹、瓶子、椅子、时钟、键盘、老鼠、人检测1-YOLO（v5至v11）、COCO、CreateML、Paligemma、TFRecord、VOC数据集合集.rar
资源上传下载、课程学习等过程中有任何疑问或建议，欢迎提出宝贵意见哦~我们会及时处理！
点击此处反馈
