package com.slcf.util;

import java.util.HashMap;
import java.util.Map;

import javax.sql.DataSource;

import org.apache.ibatis.datasource.pooled.PooledDataSource;
import org.apache.ibatis.mapping.Environment;
import org.apache.ibatis.session.Configuration;
import org.apache.ibatis.session.SqlSession;
import org.apache.ibatis.session.SqlSessionFactory;
import org.apache.ibatis.session.SqlSessionFactoryBuilder;
import org.apache.ibatis.transaction.TransactionFactory;
import org.apache.ibatis.transaction.jdbc.JdbcTransactionFactory;

import com.slcf.dao.UserDao;
import com.slcf.pojo.CrnBean;
import com.slcf.pojo.LocationBean;
import com.slcf.pojo.RowNoBean;
import com.slcf.pojo.StaDescBean;
import com.slcf.pojo.StationBean;
import com.slcf.pojo.WorkMastBean;
import com.slcf.pojo.WorkNoBean;
import com.slcf.service.CrnService;
import com.slcf.service.LocationService;
import com.slcf.service.RowNoService;
import com.slcf.service.StaDescService;
import com.slcf.service.StationService;
import com.slcf.service.WorkFileService;
import com.slcf.service.WorkNoService;

/**
 * 公共方法类
 * @author admin
 * @date 2018年11月6日
 */
public class CommonMethod {
	private WorkFileService workFileService;
	private WorkNoService workNoService;
	private CrnService crnService;
	private StationService stationService;
	private LocationService locationService;
	private RowNoService rowNoService;
	private StaDescService staDescService;
	
	public CommonMethod(WorkFileService workFileService,WorkNoService workNoService,
			CrnService crnService,StationService stationService,LocationService locationService,
			RowNoService rowNoService,StaDescService staDescService) {
		this.workFileService = workFileService;
		this.workNoService = workNoService;
		this.crnService = crnService;
		this.stationService = stationService;
		this.locationService = locationService;
		this.rowNoService = rowNoService;
		this.staDescService = staDescService;
	}
	
	public SqlSession getSession(){
		SqlSession session = null;
		try {
			String driver = "com.microsoft.sqlserver.jdbc.SQLServerDriver";
			String url = "jdbc:sqlserver://127.0.0.1:1433;databaseName=AccessData";
			String username="sa";
			String password="sa4761516";
			
			DataSource dataSource =new PooledDataSource(driver,url,username,password);
			
			//创建事务		
			TransactionFactory transactionFactory =  new JdbcTransactionFactory();
			
			Environment environment = new Environment("development", transactionFactory, dataSource);
			
			Configuration configuration = new Configuration(environment);
			
			configuration.addMapper(UserDao.class);
			SqlSessionFactory sqlSessionFactory = new  SqlSessionFactoryBuilder().build(configuration);
			System.out.println(sqlSessionFactory);
			
			session =  sqlSessionFactory.openSession();
		}catch(Exception e) {
			System.out.println(e);
		}
		return session;
	}
	
	/**
	 * 判断站点状态是否正常
	 * @param station
	 * @return
	 */
	public Map<String,Object> checkStationStatus(StationBean station) {
		Map<String,Object> mapStation=new HashMap<String, Object>();
		try {
			if(station!=null) {
				if(station.getAutoing()==null || !station.getAutoing().equals("Y")) {
					mapStation.put("code", 1);
					mapStation.put("msg", "入库站点不是自动状态");
					return mapStation;
				}
				if(station.getLoading()==null || !station.getLoading().equals("Y")) {
					mapStation.put("code", 1);
					mapStation.put("msg", "入库站点无物");
					return mapStation;
				}
				if(station.getWrk_no()>0) {
					mapStation.put("code", 1);
					mapStation.put("msg", "入库站点已有工作号");
					return mapStation;
				}
				
				int count = workFileService.getStoreWorkCount(station.getDev_no());
				if(count>0) {
					mapStation.put("code", 1);
					mapStation.put("msg", "同一站点不能同时生成两笔入库工作档");
					return mapStation;
				}
				
				mapStation.put("code", 0);
			}else {
				mapStation.put("code", 1);
				mapStation.put("msg", "入库站点不存在");
				return mapStation;
			}
		}catch(Exception e) {
			System.out.println(e.getMessage());
			mapStation.put("code", 1);
			mapStation.put("msg", "站点异常!" + e.getMessage());
		}
		return mapStation;
	}
	
	/**
	 * 入出库作业生成新的工作号
	 * @return
	 */
	public int getNewWorkNo(WorkNoBean workNoBean) {
		int wrk_no=0;
		try {
			if(workNoBean!=null) {
				wrk_no = workNoBean.getWrk_no();
				int s_no = workNoBean.getS_no();
				int e_no = workNoBean.getE_no();
				
				if(wrk_no>=e_no) {
					wrk_no = s_no;
				}else {
					wrk_no++;
				}
				
				while(true) {
					WorkMastBean workFile = workFileService.queryWorkMastById(wrk_no);
					if(workFile!=null) {
						wrk_no++;
						if(wrk_no>=e_no) {
							wrk_no = s_no;
						}else {
							wrk_no++;
						}
					}else {
						break;
					}
				}
				
				if(wrk_no>0) {
					workNoBean.setWrk_no(wrk_no);
					workNoService.upWorkNo(workNoBean);
				}
			}
		}catch(Exception e) {
			System.out.println(e.getMessage());
		}
		return wrk_no;
	}
	
	/**
	 * 入库作业寻找空库位号
	 * @return
	 */
	public String getLocNo(int type, RowNoBean rowNoBean, int stn_no, int loc_type) {
		String loc_no = "";
		try {
			if(rowNoBean!=null) {
				int cur_row = rowNoBean.getCurrent_row();
				int min_row = rowNoBean.getS_row();
				int max_row = rowNoBean.getE_row();
				int crn_qty = rowNoBean.getCrn_qty();
				
				int iii=1;
				int max_row_1 = max_row - 1;
				
				while(loc_no=="") {
					if(cur_row==max_row) {
						cur_row = min_row;
					}else if(cur_row==max_row_1) {
						cur_row = min_row + 1;
					}else {
						cur_row = cur_row + 2;
					}
					
					int crn_no = (cur_row+1)/2;
					if("Y".equals(getCrnEnable(crn_no,"I"))) {
						int e_staNo = getIoStaNo(type,crn_no,stn_no);
						if(e_staNo==0) {
							continue;
						}
						StationBean station = stationService.queryStationById(e_staNo);
						if(station!=null) {
							if("Y".equals(station.getIn_enable())
								&& "Y".equals(station.getAutoing())
								&& station.getIn_qty()<2) {
								//查找库位
								LocationBean location = locationService.getLocNoByRow(cur_row,loc_type);
								if(location!=null) {
									loc_no = location.getLoc_no();
									break;
								}
							}
						}
					}
					iii=iii+1;
					if(iii>(crn_qty*2+1)) {
						return loc_no;
					}
				}
				
				if(loc_no!=null && !loc_no.equals("")) {
					rowNoBean.setCurrent_row(cur_row);
					rowNoService.upRowNo(rowNoBean);
				}
			}
		}catch(Exception e) {
			System.out.println(e.getMessage());
		}
		return loc_no;
	}
	
	/**
	 * 判断堆垛机入出库是否禁用
	 * @param crn_no
	 * @param type
	 * @return
	 */
	public String getCrnEnable(int crn_no,String type) {
		String result="";
		try {
			CrnBean crn = crnService.queryCrnById(crn_no);
			if(crn!=null) {
				if(type.equals("I")) {
					result = crn.getIn_enable();
				}else {
					result = crn.getOut_enable();
				}
			}
		}catch(Exception e) {
			System.out.println(e.getMessage());
		}
		return result;
	}
	
	/**
	 * 根据堆垛机编号，入库站得到堆垛机入库站
	 * @param type
	 * @param crn_no
	 * @param sta_no
	 * @return
	 */
	public int getIoStaNo(int type, int crn_no, int sta_no) {
		int result=0;
		try {
			StationBean station = stationService.queryStationById(sta_no);
			if(station!=null) {
				StaDescBean staDesc = new StaDescBean();
				staDesc.setType_no(type);
				staDesc.setStn_no(sta_no);
				staDesc.setCrn_no(crn_no);
				result = staDescService.queryStnByTypeStnCrn(staDesc);
			}
		}catch(Exception e) {
			System.out.println(e.getMessage());
		}
		return result;
	}
	
}