package com.slcf.controller;

import java.util.ArrayList;
import java.util.Arrays;
import java.util.Collections;
import java.util.HashMap;
import java.util.List;
import java.util.Map;
import java.util.Random;

import javax.annotation.Resource;
import javax.servlet.http.HttpServletRequest;

import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Controller;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RequestParam;
import org.springframework.web.bind.annotation.ResponseBody;

import com.slcf.pojo.UserBean;
import com.slcf.pojo.WorkMastBean;
import com.slcf.bean.LocDetailCondition;
import com.slcf.pojo.LocationBean;
import com.slcf.pojo.StationBean;
import com.slcf.pojo.SysLogBean;
import com.slcf.service.WaitPakInService;
import com.slcf.service.WorkFileService;
import com.slcf.service.WorkNoService;
import com.slcf.util.AuthorityCode;
import com.slcf.util.CommonMethod;
import com.slcf.util.DateTimeUtil;
import com.slcf.service.CrnService;
import com.slcf.service.LocDetailService;
import com.slcf.service.LocationService;
import com.slcf.service.MatCodeService;
import com.slcf.service.OperateService;
import com.slcf.service.RoleService;
import com.slcf.service.RowNoService;
import com.slcf.service.StaDescService;
import com.slcf.service.StationService;
import com.slcf.service.SysLogService;

/**
 * 空托盘控制器层
 * @author admin
 * @date 2018年12月4日
 */
@Controller
@RequestMapping("/work")
public class EmptyController {

	@Resource
	WaitPakInService waitPakInService;
	@Autowired
	SysLogService sysLogService;
	@Autowired
	MatCodeService matCodeService;
	@Autowired
	StaDescService staDescService;
	@Autowired
	StationService stationService;
	@Autowired
	WorkNoService workNoService;
	@Autowired
	WorkFileService workFileService;
	@Autowired
	RowNoService rowNoService;
	@Autowired
	LocationService locationService;
	@Autowired
	CrnService crnService;
	@Autowired
	OperateService operateService;
	@Autowired
	LocDetailService locDetailService;
	@Autowired
	RoleService roleService;
	
	@RequestMapping("/goEmptyIn.action")
	public String goEmptyInPage(HttpServletRequest request){
		try {
			String rid = request.getSession().getAttribute("ROLEID").toString();
			String authCode = roleService.getAuthListByRoleMenu(Integer.parseInt(rid), 
					AuthorityCode.EmptyInCode);
			request.getSession().setAttribute("AUTHCODE",authCode);
			// 插入日志
			UserBean user = (UserBean) request.getSession().getAttribute("USER");
			SysLogBean sysLog = new SysLogBean();
			sysLog.setLogin_no(user.getUser_account());
			sysLog.setMachine_ip(request.getRemoteAddr());
			sysLog.setForm_no("goEmptyIn.action");
			sysLog.setTts_keyname("访问空托盘入库");
			sysLog.setModi_user(user.getUser_account());
			sysLogService.insertSysLog(sysLog);
		}catch (Exception e) {
			System.out.println(e.getMessage());
		}
		return "emptyIn";
	}
	
	@RequestMapping("/goEmptyOut.action")
	public String goEmptyOutPage(HttpServletRequest request){
		try {
			String rid = request.getSession().getAttribute("ROLEID").toString();
			String authCode = roleService.getAuthListByRoleMenu(Integer.parseInt(rid), 
					AuthorityCode.EmptyOutCode);
			request.getSession().setAttribute("AUTHCODE",authCode);
			// 插入日志
			UserBean user = (UserBean) request.getSession().getAttribute("USER");
			SysLogBean sysLog = new SysLogBean();
			sysLog.setLogin_no(user.getUser_account());
			sysLog.setMachine_ip(request.getRemoteAddr());
			sysLog.setForm_no("goEmptyOut.action");
			sysLog.setTts_keyname("访问空托盘出库");
			sysLog.setModi_user(user.getUser_account());
			sysLogService.insertSysLog(sysLog);
		}catch (Exception e) {
			System.out.println(e.getMessage());
		}
		return "emptyOut";
	}
	
	@RequestMapping("/goLocMove.action")
	public String goLocMovePage(HttpServletRequest request){
		try {
			String rid = request.getSession().getAttribute("ROLEID").toString();
			String authCode = roleService.getAuthListByRoleMenu(Integer.parseInt(rid), 
					AuthorityCode.LocMoveCode);
			request.getSession().setAttribute("AUTHCODE",authCode);
			// 插入日志
			UserBean user = (UserBean) request.getSession().getAttribute("USER");
			SysLogBean sysLog = new SysLogBean();
			sysLog.setLogin_no(user.getUser_account());
			sysLog.setMachine_ip(request.getRemoteAddr());
			sysLog.setForm_no("goLocMove.action");
			sysLog.setTts_keyname("访问库位移转");
			sysLog.setModi_user(user.getUser_account());
			sysLogService.insertSysLog(sysLog);
		}catch (Exception e) {
			System.out.println(e.getMessage());
		}
		return "locMove";
	}
	
	@RequestMapping("/goLocCheck.action")
	public String goLocCheckPage(HttpServletRequest request){
		try {
			String rid = request.getSession().getAttribute("ROLEID").toString();
			String authCode = roleService.getAuthListByRoleMenu(Integer.parseInt(rid), 
					AuthorityCode.LocCheckCode);
			request.getSession().setAttribute("AUTHCODE",authCode);
			// 插入日志
			UserBean user = (UserBean) request.getSession().getAttribute("USER");
			SysLogBean sysLog = new SysLogBean();
			sysLog.setLogin_no(user.getUser_account());
			sysLog.setMachine_ip(request.getRemoteAddr());
			sysLog.setForm_no("goLocCheck.action");
			sysLog.setTts_keyname("访问库存盘点");
			sysLog.setModi_user(user.getUser_account());
			sysLogService.insertSysLog(sysLog);
		}catch (Exception e) {
			System.out.println(e.getMessage());
		}
		return "locCheck";
	}
	////////////////////////////////////////////////////////////////////////////
	/**
	 * 空托盘入库启动
	 * @return
	 */
	@ResponseBody
	@RequestMapping("/emptyStoreIn.action")
	public Map<String,Object> emptyStoreIn(
			@RequestParam("stn_no")int stn_no,HttpServletRequest request) throws Exception{
		Map<String,Object> map=new HashMap<String, Object>();
		try {
			CommonMethod commonMethod = new CommonMethod(workFileService,workNoService,crnService,
					stationService,locationService,rowNoService,staDescService);
			
			UserBean user=(UserBean)request.getSession().getAttribute("USER");
			WorkMastBean workMast = new WorkMastBean();
			
			//判断站点是否正常
			StationBean station = stationService.queryStationById(stn_no);
			Map<String,Object> mapStation = commonMethod.checkStationStatus(station);
			if((Integer)mapStation.get("code")==1) {
				map.put("code", 1);
				map.put("msg", mapStation.get("msg"));
				return map;
			}
			
			int wrk_no = commonMethod.getNewWorkNo(workNoService.queryWorkNoById(0));
			if(wrk_no<=0) {
				map.put("code", 1);
				map.put("msg", "生成工作号失败，请联系管理员");
				return map;
			}else {
				WorkMastBean workFile = workFileService.queryWorkMastById(wrk_no);
				if(workFile!=null) {
					map.put("code", 1);
					map.put("msg", "生成工作号" + wrk_no + "在工作档中已存在");
					return map;
				}
			}
			
			String loc_no = "";
			loc_no = commonMethod.getLocNo(10, rowNoService.queryRowNoById(1), stn_no, station.getCtn_type());
			if(loc_no.equals("")) {
				map.put("code", 1);
				map.put("msg", "查询可用库位失败，请检查堆垛机、设备状态");
				return map;
			}
			int crn_no = Integer.parseInt(loc_no.substring(0,2));
			crn_no = (crn_no+1) / 2;
			int e_staNo = commonMethod.getIoStaNo(10, crn_no, stn_no);
			if(e_staNo<=0) {
				map.put("code", 1);
				map.put("msg", "获取堆垛机站点失败");
				return map;
			}
			String io_time = DateTimeUtil.getStringDateTime(19);
			workMast.setWrk_no(wrk_no);
			workMast.setIo_time(io_time);
			workMast.setWrk_sts(1);
			workMast.setIo_type(10);
			workMast.setIo_pri(10);
			workMast.setCrn_no(crn_no);
			workMast.setSource_sta_no(stn_no);
			workMast.setSta_no(e_staNo);
			workMast.setLoc_no(loc_no);
			workMast.setFull_plt("N");
			workMast.setPicking("N");
			workMast.setExit_mk("N");
			workMast.setEmpty_mk("Y");
			workMast.setLink_mis("N");
			workMast.setModi_user(user.getUser_account());
			
			map = operateService.insertEmptyStoreIn(workMast, station, user);
			
			if((Integer)map.get("code")==0) {
				// 插入日志
//				UserBean user = (UserBean) request.getSession().getAttribute("USER");
				SysLogBean sysLog = new SysLogBean();
				sysLog.setLogin_no(user.getUser_account());
				sysLog.setMachine_ip(request.getRemoteAddr());
				sysLog.setForm_no("emptyStoreIn.action");
				sysLog.setTts_keyname("启动空板入库:" + workMast.getWrk_no() + "-" + workMast.getLoc_no());
				sysLog.setModi_user(user.getUser_account());
				sysLogService.insertSysLog(sysLog);
			}
		}catch(RuntimeException e) {
			System.out.println(e.getMessage());
		}
		return map;
	}
	
	/**
	 * 空托盘出库启动
	 * @return
	 */
	@ResponseBody
	@RequestMapping("/emptyRetrieve.action")
	public Map<String,Object> emptyRetrieve(@RequestParam("ids")String[] ids,
			@RequestParam("stn_no")int stn_no,HttpServletRequest request) throws Exception{
		Map<String,Object> map=new HashMap<String, Object>();
		try {
			CommonMethod commonMethod = new CommonMethod(workFileService,workNoService,crnService,
					stationService,locationService,rowNoService,staDescService);
			
			UserBean user=(UserBean)request.getSession().getAttribute("USER");
			WorkMastBean workMast = new WorkMastBean();
			
//			workMast.setWrk_no(wrk_no);
//			workMast.setIo_time(io_time);
			workMast.setWrk_sts(11);
			workMast.setIo_type(110);
			workMast.setIo_pri(13);
			workMast.setSta_no(stn_no);
//			workMast.setCrn_no(crn_no);
//			workMast.setSource_sta_no(stn_no);
//			workMast.setSta_no(e_staNo);
//			workMast.setLoc_no(loc_no);
			workMast.setFull_plt("N");
			workMast.setPicking("N");
			workMast.setExit_mk("N");
			workMast.setEmpty_mk("Y");
			workMast.setLink_mis("N");
			workMast.setModi_user(user.getUser_account());
			
			map = operateService.insertemptyRetrieve(workMast, ids, stn_no, user, commonMethod);
			
			if((Integer)map.get("code")==0) {
				// 插入日志
//				UserBean user = (UserBean) request.getSession().getAttribute("USER");
				SysLogBean sysLog = new SysLogBean();
				sysLog.setLogin_no(user.getUser_account());
				sysLog.setMachine_ip(request.getRemoteAddr());
				sysLog.setForm_no("emptyRetrieve.action");
				sysLog.setTts_keyname("启动空托盘出库:" + workMast.getWrk_no() + "-" + workMast.getLoc_no());
				sysLog.setModi_user(user.getUser_account());
				sysLogService.insertSysLog(sysLog);
			}
		}catch(RuntimeException e) {
			System.out.println(e.getMessage());
		}
		return map;
	}
	
	//////////////////////库位移转///////////////////////////////////////////
	@ResponseBody
	@RequestMapping("/locDetlList.action")
	public Map<String,Object> querylocDetlListByPages(LocDetailCondition locDetailCon){
		Map<String,Object> map = new HashMap<String, Object>();
		if(locDetailCon.getLoc_no()==null || locDetailCon.getLoc_no().equals("")) {
			return map;
		}
		map=locDetailService.queryLocDetailList(locDetailCon);
		return map;
	}
	
	/**
	 * 检查旧库位状态
	 * @param loc_no
	 * @return
	 */
	@ResponseBody
	@RequestMapping("/checkOldLoc.action")
	public Map<String,Object> checkOldLoc(@RequestParam("loc_no")String loc_no){		
		Map<String,Object> map=new HashMap<String, Object>();
		try {
			LocationBean location = locationService.queryLocationById(loc_no);
			if(location!=null){
				if(location.getLoc_sts().equals("F") || location.getLoc_sts().equals("D")) {
					map.put("msg", "库位可用");
				}else {
					map.put("msg", "库位不是在库状态");
				}
			}else{
				map.put("msg", "库位不存在");
			}
		}catch(Exception e) {
			System.out.println(e.getMessage());
		}
		return map;
	}
	
	/**
	 * 检查旧库位状态
	 * @param loc_no
	 * @return
	 */
	@ResponseBody
	@RequestMapping("/checkNewLoc.action")
	public Map<String,Object> checkNewLoc(@RequestParam("loc_no")String loc_no){		
		Map<String,Object> map=new HashMap<String, Object>();
		try {
			LocationBean location = locationService.queryLocationById(loc_no);
			if(location!=null){
				if(location.getLoc_sts().equals("O")) {
					map.put("msg", "库位可用");
				}else {
					map.put("msg", "库位不是空库位状态");
				}
			}else{
				map.put("msg", "库位不存在");
			}
		}catch(Exception e) {
			System.out.println(e.getMessage());
		}
		return map;
	}
	
	/**
	 * 库位移转
	 * @return
	 */
	@ResponseBody
	@RequestMapping("/locMove.action")
	public Map<String,Object> locMove(@RequestParam("old_loc_no")String old_loc_no,
			@RequestParam("new_loc_no")String new_loc_no,HttpServletRequest request) throws Exception{
		Map<String,Object> map=new HashMap<String, Object>();
		try {
			CommonMethod commonMethod = new CommonMethod(workFileService,workNoService,crnService,
					stationService,locationService,rowNoService,staDescService);
			
			UserBean user=(UserBean)request.getSession().getAttribute("USER");
			WorkMastBean workMast = new WorkMastBean();
			
			String emptyMk = "N";
			LocationBean location = locationService.queryLocationById(old_loc_no);
			if(location!=null) {
				String loc_sts = location.getLoc_sts();
				if(loc_sts.equals("D")) {
					emptyMk="Y";
				}
			}
			
			int wrk_no = commonMethod.getNewWorkNo(workNoService.queryWorkNoById(0));
			if(wrk_no<=0) {
				map.put("code", 1);
				map.put("msg", "生成工作号失败，请联系管理员");
				return map;
			}else {
				WorkMastBean workFile = workFileService.queryWorkMastById(wrk_no);
				if(workFile!=null) {
					map.put("code", 1);
					map.put("msg", "生成工作号" + wrk_no + "在工作档中已存在");
					return map;
				}
			}
			
			int crn_no = Integer.parseInt(old_loc_no.substring(0,2));
			crn_no = (crn_no+1)/2;
//			int e_staNo = commonMethod.getIoStaNo(crn_no,"I",stn_no);
			String io_time = DateTimeUtil.getStringDateTime(19);
			workMast.setWrk_no(wrk_no);
			workMast.setIo_time(io_time);
			workMast.setWrk_sts(11);
			workMast.setIo_type(11);
			workMast.setIo_pri(10);
			workMast.setCrn_no(crn_no);
//			workMast.setSource_sta_no(stn_no);
//			workMast.setSta_no(e_staNo);
			workMast.setSource_loc_no(old_loc_no);
			workMast.setLoc_no(new_loc_no);
			workMast.setFull_plt("N");
			workMast.setPicking("N");
			workMast.setExit_mk("N");
			workMast.setEmpty_mk(emptyMk);
			workMast.setLink_mis("N");
			workMast.setModi_user(user.getUser_account());
			
			map = operateService.insertLocMove(workMast, old_loc_no, new_loc_no, user);
			
			if((Integer)map.get("code")==0) {
				// 插入日志
//				UserBean user = (UserBean) request.getSession().getAttribute("USER");
				SysLogBean sysLog = new SysLogBean();
				sysLog.setLogin_no(user.getUser_account());
				sysLog.setMachine_ip(request.getRemoteAddr());
				sysLog.setForm_no("locMove.action");
				sysLog.setTts_keyname("启动库位移转:" + workMast.getWrk_no() + "-" + workMast.getLoc_no());
				sysLog.setModi_user(user.getUser_account());
				sysLogService.insertSysLog(sysLog);
			}
		}catch(RuntimeException e) {
			System.out.println(e.getMessage());
		}
		return map;
	}
	
	////////////////////////////////库存盘点//////////////////////////
	/**
	 * 检查旧库位状态
	 * @param loc_no
	 * @return
	 */
	@ResponseBody
	@RequestMapping("/checkChkLoc.action")
	public Map<String,Object> checkChkLoc(@RequestParam("loc_no")String loc_no){		
		Map<String,Object> map=new HashMap<String, Object>();
		try {
			LocationBean location = locationService.queryLocationById(loc_no);
			if(location!=null){
				if(location.getLoc_sts().equals("F")) {
					map.put("msg", "库位可用");
				}else {
					map.put("msg", "库位不是在库状态");
				}
			}else{
				map.put("msg", "库位不存在");
			}
		}catch(Exception e) {
			System.out.println(e.getMessage());
		}
		return map;
	}
	
	/**
	 * 盘点出库启动
	 * @return
	 */
	@ResponseBody
	@RequestMapping("/locCheck.action")
	public Map<String,Object> locCheck(@RequestParam("old_loc_no")String value,@RequestParam("chk_type")int chk_type,
			@RequestParam("stn_no")int stn_no,HttpServletRequest request) throws Exception{
		Map<String,Object> map=new HashMap<String, Object>();
		try {
			CommonMethod commonMethod = new CommonMethod(workFileService,workNoService,crnService,
					stationService,locationService,rowNoService,staDescService);
			
			UserBean user=(UserBean)request.getSession().getAttribute("USER");
			String locs = "";
			switch(chk_type) {
				case 0:  //指定库位
					map = operateService.insertLocCheck(value, stn_no, user, commonMethod);
					break;
				case 1:  //全盘
					locs = locationService.getLocationListBySts("F");
					List<String> listLoc = Arrays.asList(locs.split(","));
					
					if(listLoc!=null && listLoc.size()>0) {
						for(String loc_no : listLoc) {
							map = operateService.insertLocCheck(loc_no, stn_no, user, commonMethod);
						}
					}else {
						map.put("code", 1);
						map.put("msg", "无在库资料");
						return map;
					}
					break;
				case 2:  //百分比盘点
					locs = locationService.getLocationListBySts("F");
					String[] array = locs.split(",");
					List<String> list = new ArrayList<String>(array.length); 
					Collections.addAll(list, array);
//					list = Arrays.asList(locs.split(","));  //静态list不能做增删操作
					
					int count = (list.size()*Integer.parseInt(value))/100;
					List<String> arrayList = getListByQty(list,count);
					if(arrayList!=null && arrayList.size()>0) {
						for (String loc_no : arrayList) {
							map = operateService.insertLocCheck(loc_no, stn_no, user, commonMethod);
						}
					}else {
						map.put("code", 1);
						map.put("msg", "无在库资料");
						return map;
					}
					break;
			}
			
			if((Integer)map.get("code")==0) {
				// 插入日志
//				UserBean user = (UserBean) request.getSession().getAttribute("USER");
				SysLogBean sysLog = new SysLogBean();
				sysLog.setLogin_no(user.getUser_account());
				sysLog.setMachine_ip(request.getRemoteAddr());
				sysLog.setForm_no("locCheck.action");
				sysLog.setTts_keyname("启动盘点出库");
				sysLog.setModi_user(user.getUser_account());
				sysLogService.insertSysLog(sysLog);
			}
		}catch(RuntimeException e) {
			System.out.println(e.getMessage());
		}
		return map;
	}
	
	/**
	 * 从原list中随机获取指定数量元素的list
	 * @param list
	 * @param count
	 * @return
	 */
	private List<String> getListByQty(List<String> list, int count){
		List<String> result = new ArrayList<String>();
		try {
			Random r = new Random();
			int index = 0;
			for (int i = 0; i < count; i++) {
				index = r.nextInt(list.size() - i);
				result.add(list.get(index));
				list.remove(index);
			}
		}catch(Exception e) {
			System.out.println(e.getMessage());
		}
		return result;
	}
	
	//测试代码
	public static void main(String[] args) {
		List<String> ids = new ArrayList<String>();
		ids.add("aa");
		ids.add("bb");
		ids.add("cc");
		ids.add("dd");
		ids.add("ee");
		ids.add("ff");
		Random r = new Random();
		List<String> ret = new ArrayList<String>();
		int index = 0;
		for (int i = 0; i < 2; i++) {
			index = r.nextInt(ids.size() - i);
			ret.add(ids.get(index));
			ids.remove(index);
		}
		for (String str : ret) {
			System.out.print(str + " ");
		}
	}
	
	
}