package cn.ksource.web.service.file;

import java.util.ArrayList;
import java.util.HashMap;
import java.util.List;
import java.util.Map;

import javax.servlet.http.HttpServletRequest;

import org.apache.commons.lang.StringUtils;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;

import cn.ksource.core.dao.BaseDao;
import cn.ksource.core.dao.SqlParameter;
import cn.ksource.core.util.ConvertUtil;
import cn.ksource.core.util.DateUtil;
import cn.ksource.core.util.StringUtil;
import cn.ksource.core.web.WebUtil;

@Service("fileService")
public class FileServiceImpl implements FileService {

	@Autowired
	private BaseDao baseDao;
	
	@Override
	public List<Map> getFileList(String business_id) {
		String sql = "select * from GG_FILES where DEL_FLAG =1 AND BUSINESS_ID=:BUSINESS_ID order by  ORDERNUM";
		List<Map> list = baseDao.queryForList(sql,new SqlParameter("BUSINESS_ID",business_id));
		return list;
	}
	
	
	public List<Map> getFileListByType(String business_id,String type) {
		String sql = "select * from CMS_ATTACHEMENTS where NEWS_ID=:BUSINESS_ID AND TYPE = :type";
		List<Map> list = baseDao.queryForList(sql,new SqlParameter("BUSINESS_ID",business_id).addValue("type", type));
		return list;
	}

	@Override
	public List<Map> getFileList(String business_id, int extend_level) {
		String sql = "select * from GG_FILES where DEL_FLAG =1 \n";
		if (extend_level == 1) {
			sql += " and EXTEND1=:BUSINESS_ID \n";
		}
		if (extend_level == 2) {
			sql += " and EXTEND2=:BUSINESS_ID \n";
		}
		if (extend_level == 3) {
			sql += " and EXTEND3=:BUSINESS_ID \n";
		}
		sql += " order by  ORDERNUM";
		List<Map> list = baseDao.queryForList(sql,new SqlParameter("BUSINESS_ID",business_id));
		for(Map map:list){
			String m=StringUtil.getFileSize(Double.parseDouble(map.get("FILE_SIZE")+""));
			map.put("FILE_SIZE_M", m);
		}
		
		return list;
	}

	@Override
	public List<Map> uploadFile(Map<String,String> params) {
		String business_id = params.get("business_id");
		String extend_1business_id = params.get("extend_1business_id");
		String extend_2business_id = params.get("extend_2business_id");
		String extend_3business_id = params.get("extend_3business_id");
		String userId = params.get("userId");
		String userName = params.get("userName");
		
		String file_id = params.get("fileId");
		String ext_name = params.get("fileExt");
		//String field_name = request.getParameterValues("FIELD_NAME");
		String file_path = params.get("filePath");
		String file_size = params.get("fileSize");
		String file_name = params.get("fileName");
		String file_type = params.get("fileType");
		
		
		//String file_note = request.getParameterValues("FILE_NOTE");
		
		List<Map> fileList = new ArrayList<Map>();
		baseDao.execute("delete from GG_FILES where BUSINESS_ID=:BUSINESS_ID ", new SqlParameter("BUSINESS_ID",business_id));
		List<SqlParameter> paramList = new ArrayList<SqlParameter>();
		String sql = "insert into GG_FILES(ID,FILE_NAME,FILE_PATH,FILE_SIZE,FILE_FORMAT,BUSINESS_ID,ORDERNUM,EXTEND1,EXTEND2,EXTEND3,CREATE_TIME,DEL_FLAG,USER_ID,USER_NAME,FILE_TYPE)" +
				"values(:ID,:FILE_NAME,:FILE_PATH,:FILE_SIZE,:FILE_FORMAT,:BUSINESS_ID,:ORDERNUM,:EXTEND1,:EXTEND2,:EXTEND3,:CREATE_TIME,1,:USER_ID,:USER_NAME,:FILE_TYPE)";
		if (ext_name != null  && file_path!=null 
				 && file_name != null ) {
			String[] file_ids = file_id.split(",");
			String[] ext_names = ext_name.split(",");
			//String[] field_names = request.getParameterValues("FIELD_NAME");
			String[] file_paths = file_path.split(",");
			String[] file_sizes = file_size.split(",");
			String[] file_names = file_name.split(",");
			String[] file_types = file_type.split(",");
			//String[] file_notes = request.getParameterValues("FILE_NOTE");
			Long create_time = DateUtil.getCurrentDate14();
			for (int i = 0; i < file_names.length; i++) {
				Map map = new HashMap();
				if(file_ids.length > i){
					map.put("ID", StringUtils.defaultIfEmpty(file_ids[i], StringUtil.getUUID()));
				}else{
					map.put("ID", StringUtil.getUUID());
				}
				map.put("FILE_NAME", file_names[i]);
				map.put("FILE_PATH", file_paths[i]);
				map.put("FILE_SIZE", file_sizes[i]);
				map.put("FILE_FORMAT", ext_names[i]);
				if(file_types[i].equals("blank")){
					map.put("FILE_TYPE", "");
				}else{
					map.put("FILE_TYPE", file_types[i]);
				}
				
				map.put("BUSINESS_ID", business_id);
				map.put("ORDERNUM", i);
				//map.put("FILE_NOTE", file_notes[i]);
				map.put("EXTEND1", extend_1business_id);
				map.put("EXTEND2", extend_2business_id);
				map.put("EXTEND3", extend_3business_id);
				map.put("CREATE_TIME", create_time);
				map.put("USER_ID", userId);
				map.put("USER_NAME", userName);
				paramList.add(new SqlParameter().setSource(map));
			}
			baseDao.executeBatch(sql, paramList);
		}
		return fileList;
	}


	@Override
	public List<Map> getFileList(Map<String, String> params) {
		StringBuilder sql = new StringBuilder();
		sql.append(" SELECT * FROM GG_FILES WHERE 1=1 ");
		if(StringUtil.isNotBlank(params.get("businessId"))){
			sql.append(" AND BUSINESS_ID = :businessId ");
		}
		if(StringUtil.isNotBlank(params.get("fileType"))){
			sql.append(" AND FILE_TYPE = :fileType ");
		}
		sql.append(" ORDER BY ORDERNUM ");
		
		List<Map> list = baseDao.queryForList(sql.toString(),params);
		return list;
	}

	@Override
	public boolean deleteFile(String fileId) {
		String updateSql = "UPDATE GG_FILES SET DEL_FLAG = 2 WHERE ID = :id";
		baseDao.execute(updateSql, new SqlParameter("id",fileId));
		return true;
	}
	
	@Override
	public List<Map> uploadFile(HttpServletRequest request, String business_id,
			String extend_1business_id, String extend_2business_id,
			String extend_3business_id,String folder,String state,String note) {
		
		Map user = WebUtil.getLoginUser(request).getLoginUser();
		String userId = ConvertUtil.obj2StrBlank(user.get("ID"));
		String userName = ConvertUtil.obj2StrBlank(user.get("ZSXM"));
		
		String[] file_ids = request.getParameterValues("FILE_ID");
		String[] ext_names = request.getParameterValues("EXT_NAME");
		//String[] field_names = request.getParameterValues("FIELD_NAME");
		String[] file_paths = request.getParameterValues("FILE_PATH");
		String[] file_sizes = request.getParameterValues("FILE_SIZE");
		String[] file_names = request.getParameterValues("FILE_NAME");
		//String[] file_notes = request.getParameterValues("FILE_NOTE");
		/*if(!StringUtil.isEmpty(note)){
			file_notes[0]=note;
		}*/
		
		List<Map> fileList = new ArrayList<Map>();
		baseDao.execute("delete from GG_FILES where BUSINESS_ID=:BUSINESS_ID ", new SqlParameter("BUSINESS_ID",business_id));
		List<SqlParameter> paramList = new ArrayList<SqlParameter>();
		String sql = "insert into GG_FILES(ID,FILE_NAME,FILE_PATH,FILE_SIZE,FILE_FORMAT,BUSINESS_ID,ORDERNUM,EXTEND1,EXTEND2,EXTEND3,CREATE_TIME,DEL_FLAG,USER_ID,USER_NAME,FOLDER_ID,AUDIT_STATE,FILE_NOTE)" +
				"values(:ID,:FILE_NAME,:FILE_PATH,:FILE_SIZE,:FILE_FORMAT,:BUSINESS_ID,:ORDERNUM,:EXTEND1,:EXTEND2,:EXTEND3,:CREATE_TIME,1,:USER_ID,:USER_NAME,:FOLDER_ID,:AUDIT_STATE,:FILE_NOTE)";
		if (ext_names != null && file_paths!=null 
				&& file_sizes!=null && file_names != null) {
			Long create_time = DateUtil.getCurrentDate14();
			for (int i = 0; i < file_names.length; i++) {
				Map map = new HashMap();
				map.put("ID", StringUtils.defaultIfEmpty(file_ids[i], StringUtil.getUUID()));
				map.put("FILE_NAME", file_names[i]);
				map.put("FILE_PATH", file_paths[i]);
				map.put("FILE_SIZE", file_sizes[i]);
				map.put("FILE_FORMAT", ext_names[i]);
				
				map.put("BUSINESS_ID", business_id);
				map.put("ORDERNUM", i);

				map.put("FILE_NOTE", note);
				//map.put("FILE_NOTE", file_notes[i]);
				map.put("EXTEND1", extend_1business_id);
				map.put("EXTEND2", extend_2business_id);
				map.put("EXTEND3", extend_3business_id);
				map.put("CREATE_TIME", create_time);
				map.put("USER_ID", userId);
				map.put("USER_NAME", userName);
				map.put("FOLDER_ID", folder);
				map.put("AUDIT_STATE", state);
				paramList.add(new SqlParameter().setSource(map));
			}
			baseDao.executeBatch(sql, paramList);
		}
		return fileList;
	}
	
	@Override
	public List<Map> uploadFile(HttpServletRequest request, String business_id,String folder,String state) {
		return uploadFile(request, business_id, null, null, null,folder,state,null);
	}
	@Override
	public List<Map> uploadFile(HttpServletRequest request, String business_id,String folder,String state,String note) {
		return uploadFile(request, business_id, null, null, null,folder,state,note);
	}
	@Override
	public void newuploadFileAll(HttpServletRequest request, String business_id,String extend_1,
			String extend_1business_id, String extend_2business_id,
			String extend_3business_id,String customer_id,String project_id,String project_name,String customer_name) {
		Map user = WebUtil.getLoginUser(request).getLoginUser();
		String userId = ConvertUtil.obj2StrBlank(user.get("ID"));
		String userName = ConvertUtil.obj2StrBlank(user.get("ZSXM"));
		
		String[] file_ids = request.getParameterValues("FILE_ID");
		String[] ext_names = request.getParameterValues("EXT_NAME");
		String[] field_names = request.getParameterValues("FIELD_NAME");
		String[] file_paths = request.getParameterValues("FILE_PATH");
		String[] file_sizes = request.getParameterValues("FILE_SIZE");
		String[] file_names = request.getParameterValues("FILE_NAME");
		String[] file_notes = request.getParameterValues("FILE_NOTE");
		
		List<Map> fileList = new ArrayList<Map>();
//		baseDao.execute("delete from GG_FILES where BUSINESS_ID=:BUSINESS_ID ", new SqlParameter("BUSINESS_ID",business_id));
		List<SqlParameter> paramList = new ArrayList<SqlParameter>();
		String sql = "insert into GG_FILES(ID,FILE_NAME,FILE_PATH,FILE_SIZE,FILE_FORMAT,BUSINESS_ID,ORDERNUM,FOLDER_ID,AUDIT_STATE,EXTEND3,CREATE_TIME,DEL_FLAG,USER_ID,USER_NAME,PROJECT_ID,CUSTOMER_ID,EXTEND1,PROJECT_NAME,CUSTOMER_NAME)" +
				"values(:ID,:FILE_NAME,:FILE_PATH,:FILE_SIZE,:FILE_FORMAT,:BUSINESS_ID,:ORDERNUM,:EXTEND1,:EXTEND2,:EXTEND3,:CREATE_TIME,1,:USER_ID,:USER_NAME,:project_id,:customer_id,:extend_1,:project_name,:customer_name)";
		if (ext_names != null && field_names!=null && file_paths!=null 
				&& file_sizes!=null && file_names != null ) {
			Long create_time = DateUtil.getCurrentDate14();
			for (int i = 0; i < field_names.length; i++) {
				Map map = new HashMap();
				map.put("ID", StringUtils.defaultIfEmpty(file_ids[i], StringUtil.getUUID()));
				map.put("FILE_NAME", file_names[i]);
				map.put("FILE_PATH", file_paths[i]);
				map.put("FILE_SIZE", file_sizes[i]);
				map.put("FILE_FORMAT", ext_names[i]);
				
				map.put("BUSINESS_ID", business_id);
				map.put("ORDERNUM", i);
//				map.put("FILE_NOTE", file_notes[i]);
				map.put("EXTEND1", extend_1business_id);
				map.put("EXTEND2", extend_2business_id);
				map.put("EXTEND3", extend_3business_id);
				map.put("CREATE_TIME", create_time);
				map.put("USER_ID", userId);
				map.put("USER_NAME", userName);
				map.put("project_id", project_id);
				map.put("customer_id", customer_id);
				map.put("extend_1", extend_1);
				map.put("project_name", project_name);
				map.put("customer_name", customer_name);
				paramList.add(new SqlParameter().setSource(map));
			}
			baseDao.executeBatch(sql, paramList);
		}
		
	}
}