package com.sun.sqlloader.controller;

import java.io.IOException;

import javax.servlet.ServletException;

import org.apache.log4j.Logger;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.beans.factory.annotation.Value;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RequestParam;
import org.springframework.web.bind.annotation.RestController;
import org.springframework.web.multipart.MultipartFile;
import org.springframework.web.servlet.ModelAndView;

import com.sun.sqlloader.api.ISqlLoader;

/**
 * SqlLoader前端控制器
 * @ClassName: SqlLoaderController  
 * @author sunt  
 * @date 2017年11月15日 
 * @version V1.0
 */
@RestController
@RequestMapping(value = "/sqlLoader")
public class SqlLoaderController {
	
	private Logger logger = Logger.getLogger(SqlLoaderController.class);
	
	@Autowired
	private ISqlLoader sqlLoader;
	
	@Value("${user}")
	private String user;
	
	@Value("${pwd}")
	private String pwd;
	
	@Value("${database}")
	private String database;
	
	@Value("${logfileName}")
	private String logfileName;
	
	@Value("${ctlfileName}")
	private String ctlfileName;
	
	@Value("${fileRoute}")
	private String fileRoute;
	
	/**
	 * 跳转到导入页面
	 * @Title: toImpot 
	 * @author sunt  
	 * @date 2017年11月15日
	 * @return ModelAndView
	 */
	@RequestMapping(value = "/toImpot")
	public ModelAndView toImpot() {
		ModelAndView modelAndView = new ModelAndView();
		modelAndView.setViewName("import");
		return modelAndView;
	}
	
	@RequestMapping(value = "/importData")
	public String importData(@RequestParam(value="file")MultipartFile file,@RequestParam(value = "tableName")String tableName,
			@RequestParam(value = "fieldName")String fieldName) throws IOException, ServletException {
		String fileName = file.getOriginalFilename();//文件名
		
        try {
        	logger.info("执行生成控制文件...");
        	sqlLoader.ctlFileWriter(fileRoute, fileName, tableName, fieldName, ctlfileName);
        	
        	logger.info("执行dos命令...");
        	sqlLoader.Executive(user, pwd, database, fileRoute, ctlfileName, logfileName);
        	
        	return "导入成功!";
		} catch (Exception e) {
			return "导入失败!";
		}
	}

}