package com.fgkj.actions;
|
|
import java.io.File;
|
import java.io.FileInputStream;
|
import java.io.FileNotFoundException;
|
import java.io.FileOutputStream;
|
import java.io.IOException;
|
import java.util.ArrayList;
|
import java.util.List;
|
|
import javax.servlet.http.HttpServletResponse;
|
|
import com.fgkj.dto.BattInf;
|
import com.fgkj.dto.MyFile;
|
import com.fgkj.dto.ServiceModel;
|
import com.google.gson.Gson;
|
|
public class MyFileAction extends ActionUtil{
|
|
private String result;
|
private String json;
|
private String battname;
|
private File[] file;
|
// 提交过来的file的名字
|
private String[] fileFileName;
|
// 提交过来的file的MIME类型
|
private String[] fileContentType;
|
|
private String filestr; //文件内容
|
private String fname; //文件内容
|
|
//上传文件
|
public String UploadTestFile(){
|
HttpServletResponse res = ActionUtil.getResponse();
|
res.setHeader("Access-Control-Allow-Origin", "*"); //允许跨域访问
|
res.setHeader("Access-Control-Allow-Headers", "X-Requested-With,content-type,token");
|
res.setHeader("Access-Control-Allow-Methods", "GET, HEAD, POST, PUT, DELETE, TRACE, OPTIONS, PATCH");
|
|
|
boolean f = createFile();
|
ServiceModel model = new ServiceModel();
|
if(f){
|
model.setCode(1);
|
model.setMsg("上传成功");
|
}else{
|
model.setCode(0);
|
model.setMsg("上传失败");
|
}
|
result = ActionUtil.tojson(model);
|
return SUCCESS;
|
}
|
|
public boolean createFile(){
|
String loadpath = ActionUtil.getSession().getServletContext().getRealPath("/");
|
String str = new File(loadpath).getParentFile().getAbsolutePath();
|
boolean flag = false;
|
String root = str+"/uploadfiles/"; // 上传路径
|
//System.out.println(battname+"***");
|
for(int i=0;i<file.length;i++){
|
String savepath=root+battname+"/"+fileFileName[i];
|
//System.out.println(savepath);
|
FileInputStream fis=null;
|
FileOutputStream fos=null;
|
try {
|
File f = new File(savepath);
|
if(!f.exists()){
|
if(!f.getParentFile().exists()){
|
f.getParentFile().mkdirs();
|
}
|
f.createNewFile();
|
}
|
/** 创建输入流 */
|
fis = new FileInputStream(file[i]);
|
/** 输出流 根据文件的路径+文件名称创建文件对象 */
|
fos = new FileOutputStream(f);
|
/** 读取字节 */
|
byte b[] = new byte[1024];
|
int n = 0;
|
/** 读取操作 */
|
while ((n = fis.read(b)) != -1) {
|
/** 写操作 */
|
fos.write(b, 0, n);
|
}
|
fos.flush();
|
flag = true;
|
} catch (Exception e) {
|
e.printStackTrace();
|
} finally{
|
/** 关闭操作 */
|
try {
|
if (fis != null) {
|
fis.close();
|
}
|
if (fos != null) {
|
fos.close();
|
}
|
} catch (IOException e) {
|
e.printStackTrace();
|
}
|
}
|
}
|
return flag;
|
}
|
|
public String UploadIphoneFile(){
|
HttpServletResponse res = ActionUtil.getResponse();
|
res.setHeader("Access-Control-Allow-Origin", "*"); //允许跨域访问
|
res.setHeader("Access-Control-Allow-Headers", "X-Requested-With,content-type,token");
|
res.setHeader("Access-Control-Allow-Methods", "GET, HEAD, POST, PUT, DELETE, TRACE, OPTIONS, PATCH");
|
Gson gson = new Gson();
|
int[] arr = gson.fromJson(filestr, int[].class);
|
|
System.out.println("文件名"+fname);
|
System.out.println("文件内容:"+filestr);
|
System.out.println("电池组名称"+battname);
|
boolean f = createFileByarr(arr,fname,battname);
|
|
ServiceModel model = new ServiceModel();
|
if(f){
|
model.setCode(1);
|
model.setMsg("上传成功");
|
}else{
|
model.setCode(0);
|
model.setMsg("上传失败");
|
}
|
result = ActionUtil.tojson(model);
|
return SUCCESS;
|
}
|
|
/**
|
*
|
* @param arr 文件的字节数组
|
* @param fname 文件名
|
* @param bname 电池组名称
|
* @return 是否生成文件成功
|
*/
|
public boolean createFileByarr(int[] arr,String fname,String bname){
|
String loadpath = ActionUtil.getSession().getServletContext().getRealPath("/");
|
String str = new File(loadpath).getParentFile().getAbsolutePath();
|
boolean flag = false;
|
String root = str+"/uploadfiles/"; // 上传路径
|
//System.out.println(battname+"***");
|
String savepath=root+bname+"/"+fname;
|
//System.out.println(savepath);
|
FileOutputStream fos=null;
|
byte[] bytes = new byte[arr.length];
|
for(int i=0;i<arr.length;i++){
|
bytes[i] = (byte)(arr[i] & 0xFF);
|
}
|
|
try {
|
File f = new File(savepath);
|
if(!f.exists()){
|
if(!f.getParentFile().exists()){
|
f.getParentFile().mkdirs();
|
}
|
f.createNewFile();
|
}
|
fos = new FileOutputStream(savepath);
|
fos.write(bytes);
|
fos.flush();
|
flag = true;
|
} catch (Exception e) {
|
e.printStackTrace();
|
} finally{
|
/** 关闭操作 */
|
try {
|
if (fos != null) {
|
fos.close();
|
}
|
} catch (IOException e) {
|
e.printStackTrace();
|
}
|
}
|
return flag;
|
}
|
|
//上传机房视频接口
|
public String uploadStationFile(){
|
BattInf binf = getGson().fromJson(json, BattInf.class);
|
String fileRoot = "stationsrc";
|
ServiceModel model = new ServiceModel();
|
boolean isSuccess = false;
|
String loadpath = ActionUtil.getSession().getServletContext().getRealPath("/");
|
String str = new File(loadpath).getParentFile().getAbsolutePath(); //获取服务器所在的绝对路径
|
String root = str+"/"+fileRoot+"/"+binf.getStationId()+"/video/"; // 上传路径
|
for(int i=0;i<file.length && binf != null;i++){
|
String filePath = root+fileFileName[i];
|
createFilefolderIFNotExist(filePath);
|
copyFile(file[i], filePath);
|
isSuccess = true;
|
}
|
if(isSuccess){
|
model.setCode(1);
|
model.setMsg("上传成功");
|
}else{
|
model.setCode(0);
|
model.setMsg("上传失败");
|
}
|
result = tojson(model);
|
return SUCCESS;
|
}
|
|
/**
|
*
|
* 获取指定机房得资源
|
*/
|
public String searchStationSource(){
|
String fileRoot = "stationsrc"; //存放机房资源文件的文件夹
|
BattInf binf = getGson().fromJson(json, BattInf.class);
|
ServiceModel model = new ServiceModel();
|
String loadpath = ActionUtil.getSession().getServletContext().getRealPath("/");
|
String str = new File(loadpath).getParentFile().getAbsolutePath();
|
if(binf != null && binf.getStationId() != null && binf.getStationName() != null){
|
String filesource = str+File.separator+fileRoot+File.separator+binf.getStationId()+File.separator+binf.getStationName()+File.separator; //当前请求的机房所在的资源文件夹
|
System.out.println(filesource);
|
File source = new File(filesource);
|
File[] files = source.listFiles();
|
model.setMsg("暂无视频文件");
|
if(files.length>0){
|
List myfiles = new ArrayList<MyFile>();
|
for(int i=0;i<files.length;i++){
|
MyFile myfile = new MyFile();
|
if(files[i].isFile()){
|
myfile.setFile(files[i]);
|
myfiles.add(myfile);
|
}
|
}
|
if(myfiles.size() > 0){
|
model.setCode(1);
|
model.setData(myfiles);
|
model.setMsg("读取成功");
|
}
|
}
|
|
}
|
result = tojson(model);
|
return SUCCESS;
|
}
|
|
//将文件复制到指定的目录
|
public static void copyFile(File oldFile, String newPath){
|
File file = new File(newPath);
|
FileInputStream in = null;
|
FileOutputStream out = null;
|
try {
|
in = new FileInputStream(oldFile);
|
out = new FileOutputStream(file);;
|
|
byte[] buffer=new byte[2097152];
|
int readByte = 0;
|
while((readByte = in.read(buffer)) != -1){
|
out.write(buffer, 0, readByte);
|
}
|
} catch (FileNotFoundException e) {
|
e.printStackTrace();
|
} catch (IOException e) {
|
e.printStackTrace();
|
} finally {
|
if(in != null){
|
try {
|
in.close();
|
} catch (IOException e) {
|
e.printStackTrace();
|
}
|
}
|
if(out != null){
|
try {
|
out.close();
|
} catch (IOException e) {
|
e.printStackTrace();
|
}
|
}
|
}
|
}
|
|
|
|
public void setFilestr(String filestr) {
|
this.filestr = filestr;
|
}
|
|
public void setFname(String fname) {
|
this.fname = fname;
|
}
|
|
public void setFile(File[] file) {
|
this.file = file;
|
}
|
|
public void setFileFileName(String[] fileFileName) {
|
this.fileFileName = fileFileName;
|
}
|
|
|
public void setFileContentType(String[] fileContentType) {
|
this.fileContentType = fileContentType;
|
}
|
|
public String getResult() {
|
return result;
|
}
|
|
public void setBattname(String battname) {
|
this.battname = battname;
|
}
|
|
|
|
public void setJson(String json) {
|
this.json = json;
|
}
|
|
public static void main(String[] args) {
|
String filePath = "D:/test/a/a.txt";
|
//ActionUtil.createFileRootIFNotExist(filePath);
|
|
File file = new File(filePath);
|
System.out.println(ActionUtil.tojson(file));
|
|
}
|
}
|
