package com.fgkj.actions;

import java.io.File;
import java.io.FileInputStream;
import java.io.FileOutputStream;
import java.io.IOException;
import java.util.Date;

import javax.servlet.http.HttpSession;

import org.apache.struts2.ServletActionContext;

import com.fgkj.dto.DLG_Progress;
import com.fgkj.dto.ServiceModel;
import com.fgkj.dto.User;
import com.fgkj.dto.User_inf;
import com.fgkj.services.FboDataUploadService;
import com.fgkj.services.ResDataUploadService;
import com.google.gson.Gson;

public class ResDataUploadAction extends ActionUtil{
	private String tableRowData;
	private int battgroupid;
	private File[] file;
	// 提交过来的file的名字
	private String[] fileFileName;
	private String result;
	
	public String uploadResfile(){
		User_inf user=(User_inf)ActionUtil.getUser();
		if(user!=null){
			HttpSession session = ActionUtil.getSession();
			Gson gson = new Gson();
			createFile();
			String[][] tableRowDatas = gson
					.fromJson(tableRowData, String[][].class);
			//System.out.println(file.length + "---" + tableRowDatas.length);
			//uinf.setUId(1001);
			
			ResDataUploadService rdus=new ResDataUploadService(user, battgroupid, tableRowDatas, file, session);
			rdus.start();
		}
		return SUCCESS;
	}
	
	// 停止上传
	public String stopResUpload() {
		HttpSession session = ActionUtil.getSession();
		DLG_Progress progress = (DLG_Progress) session.getAttribute("Resprogress");
		if (progress != null) {
			progress.setJudge(false);
			ServiceModel model=new ServiceModel();
			model.setCode(1);
			model.setData(model);
			result = ActionUtil.tojson(progress);
		}
		return SUCCESS;
	}

	// 查询进度
	public String selectResprogress() {
		HttpSession session = ActionUtil.getSession();
		DLG_Progress progress = (DLG_Progress) session.getAttribute("Resprogress");
//			for(int i=0;i<progress.getTableData().length;i++){
//				for(int j=0;j<progress.getTableData()[i].length;j++){
//					System.out.print(progress.getTableData()[i][j]+"\t");
//				}
//				System.out.println();
//			}
//		System.out.println(progress+"**********");
		if (progress != null) {
			ServiceModel model = new ServiceModel();
			model.setCode(1);
			model.setData(progress);
			result = ActionUtil.tojson(model);
		}
		return SUCCESS;
	}
	
	public void createFile(){		
		String root = ServletActionContext.getServletContext().getRealPath("");		// 上传路径
		//System.out.println(root);
		for(int i=0;i<file.length;i++){
			long times=new Date().getTime();
			String savepath=root+"/"+times+fileFileName[i];
			File f=new File(savepath);
			FileInputStream fis=null;
			FileOutputStream fos=null;
		    try {       
		    	if (!f.exists()) {       
		    		/** 创建此文件对象路径  */      
		    		f.createNewFile();       
		    	}       
		        /** 创建输入流 */      
		        fis = new FileInputStream(file[i]);       
		        /** 输出流 更据文件的路径+文件名称创建文件对象 */      
		        fos = new FileOutputStream(savepath);       
		        /** 读取字节   */      
		        byte b[] = new byte[1024];       
		        int n = 0;       
		        /** 读取操作   */      
		        while ((n = fis.read(b)) != -1) {       
		            /** 写操作   */      
		            fos.write(b, 0, n);       
		        }    
		        fos.flush();
		        file[i]=f;      
		    } catch (Exception e) {       
		        e.printStackTrace();       
		    } finally{
		    	 /** 关闭操作  */      
		        try {
					if (fis != null) {       
					    fis.close();       
					}       
					if (fos != null) {       
					    fos.close();       
					}
				} catch (IOException e) {
					e.printStackTrace();
				}
		    }
		}		
	}

	public String getTableRowData() {
		return tableRowData;
	}

	public void setTableRowData(String tableRowData) {
		this.tableRowData = tableRowData;
	}

	public int getBattgroupid() {
		return battgroupid;
	}

	public void setBattgroupid(int battgroupid) {
		this.battgroupid = battgroupid;
	}

	public File[] getFile() {
		return file;
	}

	public void setFile(File[] file) {
		this.file = file;
	}

	public String[] getFileFileName() {
		return fileFileName;
	}

	public void setFileFileName(String[] fileFileName) {
		this.fileFileName = fileFileName;
	}

	public String getResult() {
		return result;
	}

	public void setResult(String result) {
		this.result = result;
	}	
}