package com.slcf.controller;

import java.io.BufferedReader;
import java.io.InputStreamReader;
import java.io.OutputStream;
import java.net.HttpURLConnection;
import java.net.URL;
import java.util.HashMap;
import java.util.List;
import java.util.Map;

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.bean.WaitPakInCondition;
import com.slcf.pojo.WaitPakInBean;
import com.slcf.pojo.MatCodeBean;
import com.slcf.pojo.SysLogBean;
import com.slcf.service.WaitPakInService;
import com.slcf.util.AuthorityCode;
import com.slcf.util.Constants;
import com.slcf.util.DateTimeUtil;

import net.sf.json.JSONArray;
import net.sf.json.JSONObject;
import sun.misc.BASE64Encoder;

import com.slcf.service.MatCodeService;
import com.slcf.service.RoleService;
import com.slcf.service.SysLogService;

/**
 * 入库通知档控制器层
 * @author admin
 * @date 2018年11月17日
 */
@Controller
@RequestMapping("/work")
public class WaitPakInController {

	@Resource
	WaitPakInService waitPakInService;
	@Autowired
	SysLogService sysLogService;
	@Autowired
	MatCodeService matCodeService;
	@Autowired
	RoleService roleService;
	
	@RequestMapping("/goWaitPakIn.action")
	public String goWaitPakInPage(HttpServletRequest request){
		try {
			String rid = request.getSession().getAttribute("ROLEID").toString();
			String authCode = roleService.getAuthListByRoleMenu(Integer.parseInt(rid), 
					AuthorityCode.WaitPakInCode);
			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("goWaitPakIn.action");
			sysLog.setTts_keyname("访问:入库通知档");
			sysLog.setModi_user(user.getUser_account());
			sysLogService.insertSysLog(sysLog);
		}catch (Exception e) {
			System.out.println(e.getMessage());
		}
		return "waitPakIn";
	}
	
	/**
	 * 添加
	 * @param waitPakIn
	 * @param request
	 * @return
	 */
	@ResponseBody
	@RequestMapping("/addWaitPakIn.action")
	public Integer insertWaitPakIn(WaitPakInBean waitPakIn,HttpServletRequest request){
		int result=0;
		try {
			UserBean user=(UserBean)request.getSession().getAttribute("USER");
			if(waitPakIn.getSheet_no()==null || waitPakIn.getSheet_no().equals("")) {
				int random = (int)(Math.random()*900 + 100);
				String seq = Integer.toString(random);
				String sheet_no = DateTimeUtil.getStringDateTime(14);				
				waitPakIn.setSheet_no(sheet_no+seq);
			}
			waitPakIn.setModi_user(user.getUser_account());
			result = waitPakInService.insertWaitPakIn(waitPakIn);								

			if(result>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("addWaitPakIn.action");
				sysLog.setTts_keyname("插入通知档:" + waitPakIn.getSheet_no() + "-" + waitPakIn.getMat_no());
				sysLog.setModi_user(user.getUser_account());
				sysLogService.insertSysLog(sysLog);
			}
		}catch(Exception e) {
			System.out.println(e.getMessage());
			result=0;
		}
		return result;
	}
	
	/**
	 * 分页查询所有
	 * @param pageNumber
	 * @param pageSize
	 * @return
	 */
	@ResponseBody
	@RequestMapping("/waitPakInList.action")
	public Map<String,Object> queryWaitPakInListByPages(WaitPakInCondition waitPakInCon){
		Map<String,Object>map=waitPakInService.queryWaitPakInList(waitPakInCon);
		return map;
	}

	/**
	 * 验证物料编号是否存在
	 * @param did
	 * @return
	 */
	@ResponseBody
	@RequestMapping("/checkCode.action")
	public Map<String,Object> checkMatCode(@RequestParam("did")String id){		
		Map<String,Object> map=new HashMap<String, Object>();
//		boolean flag=userService.validUserAccount(account, uid);
		try {
			MatCodeBean matCode = matCodeService.queryMatCodeById(id);
			if(matCode!=null){
				map.put("msg", "代号可用");
				map.put("mat_name_add",matCode.getMat_name());
			}else{
				map.put("msg", "物料号不存在");
			}
		}catch(Exception e) {
			System.out.println(e.getMessage());
		}
		return map;
	}
	
	/**
	 * 根据id查询信息
	 * @param id
	 * @return
	 */
	@ResponseBody
	@RequestMapping("/queryWaitPakInById.action")
//	public WaitPakInBean queryWaitPakInById(@RequestParam("sheet_no")String sheet_no,
//			@RequestParam("mat_no")String mat_no,HttpServletRequest request){
	public WaitPakInBean queryWaitPakInById(WaitPakInBean waitPakIn,HttpServletRequest request){
		try {
			return waitPakInService.queryWaitPakInById(waitPakIn);
		}catch(Exception e) {
			System.out.println(e.getMessage());
			return null;
		}
	}
	
//	/**
//	 * 验证工作代号是否唯一
//	 * @param did
//	 * @return
//	 */
//	@ResponseBody
//	@RequestMapping("/checkWaitPakIn.action")
//	public Map<String,Object> checkWaitPakIn(@RequestParam("did")int id){		
//		Map<String,Object> map=new HashMap<String, Object>();
////		boolean flag=userService.validUserAccount(account, uid);
//		try {
//			WaitPakInBean WaitPakIn = WaitPakInService.queryWaitPakInById(id);
//			if(WaitPakIn==null){
//				map.put("msg", "代号可用");
//			}else{
//				map.put("msg", "代号不可用");
//			}
//		}catch(Exception e) {
//			System.out.println(e.getMessage());
//		}
//		return map;
//	}
	
	/**
	 * 手工完结入库通知档，反馈ERP
	 * @param WaitPakInEntity
	 * @return
	 */
	@ResponseBody
	@RequestMapping("/overWaitPakIn.action")
	public Integer overWaitPakIn(WaitPakInBean waitPakIn,HttpServletRequest request){
		int result = 0;
		try {
			UserBean user=(UserBean)request.getSession().getAttribute("USER");
			waitPakIn.setModi_user(user.getUser_account());
			
			WaitPakInBean waitPakInBean = waitPakInService.queryWaitPakInById(waitPakIn);
			String httpUrl = Constants.SAP_URL + "/sap/opu/odata/SAP/Z_WM_H5_SRV/AsrsTrSet";
			result = sendPakInStatus(httpUrl,waitPakInBean);
//			result=waitPakInService.upWaitPakIn(waitPakIn);
			if(result>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("upWaitPakIn.action");
				sysLog.setTts_keyname("修改入库通知档:" + waitPakIn.getSheet_no());
				sysLog.setModi_user(user.getUser_account());
				sysLogService.insertSysLog(sysLog);
			}
		}catch(Exception e) {
			System.out.println(e.getMessage());
		}
		return result;
	}
	
	/**
	 * 入库完成，调用sap接口上传完成信息
	 */
	private int sendPakInStatus(String httpUrl,WaitPakInBean waitPakIn) {
		int result = 0;
//		String token = getXCsrfToken(httpUrl);
		String input = Constants.SAP_USER + ":" + Constants.SAP_PASSWORD;//"ZHANGX:654321";
        BASE64Encoder base = new BASE64Encoder();
        String encodedPassword;
        String token="";
        String session_value="";
		try {
			encodedPassword = base.encode(input.getBytes("UTF-8"));
			URL url1 = new URL(httpUrl);
	        HttpURLConnection connection1 = (HttpURLConnection) url1.openConnection();
	        connection1.setDoOutput(true);
	        connection1.setDoInput(true);
	        connection1.setRequestMethod("GET");
	        connection1.setRequestProperty("Authorization", "Basic " + encodedPassword);
	        connection1.setRequestProperty("x-csrf-token","Fetch");
	        String sessionCookie = connection1.getHeaderField("Set-Cookie");
	        String[] sessionId = sessionCookie.split(";");
	        session_value = sessionId[0];
	        token = connection1.getHeaderField("x-csrf-token");
//	        Map<String, List<String>> map = connection1.getHeaderFields();
//	        token = map.get("x-csrf-token").toString();
		} catch (Exception e1) {
			e1.printStackTrace();
		}
        
		try {
			JSONObject jsObj = new JSONObject();
			JSONArray arr = new JSONArray();
			for(int i=0;i<1;i++) {
				JSONObject json = new JSONObject();
				json.put("lgnum",waitPakIn.getLgnum());
				json.put("tbnum",Long.toString(waitPakIn.getTbnum()));
				json.put("tbpos",Integer.toString(waitPakIn.getTbpos()));
				json.put("zmatid",waitPakIn.getZmatid());
				
				json.put("anfme",Double.toString(waitPakIn.getAnfme()));
				json.put("altme",waitPakIn.getAltme());
				json.put("nltyp","A01");
				json.put("nlber","001");
				json.put("nlpla",waitPakIn.getLoc_no());
				arr.add(json);
			}
			jsObj.put("item", arr);
			byte[] buff = jsObj.toString().getBytes();
			int buffLen = buff.length;
			//创建连接
	        try {
//	        	String input = "ZHANGX:654321";
//	            BASE64Encoder base = new BASE64Encoder();
//	            String encodedPassword = base.encode(input.getBytes("UTF-8"));
	            
	        	URL url = new URL(httpUrl);
		        HttpURLConnection connection = (HttpURLConnection) url.openConnection();
		        connection.setDoOutput(true);
		        connection.setDoInput(true);
		        connection.setRequestMethod("POST");
//        		connection.setUseCaches(false);            
//        		connection.setInstanceFollowRedirects(true);
//		        connection.setRequestProperty("Content-Type","text/json;charset=gb2312");
		        connection.setRequestProperty("Cookie", session_value);
		        connection.setRequestProperty("Content-Type","application/json");
		        connection.setRequestProperty("Accept","application/json");
		        connection.setRequestProperty("Accept-Language","zh-CN,zh;q=0.9,en;q=0.8");
		        connection.setRequestProperty("Content-Length","" + buffLen);
//		        connection.setRequestProperty("Authorization", "Basic " + encodedPassword);
		        connection.setRequestProperty("x-csrf-token",token);
		        
		        //POST请求
		        OutputStream out = connection.getOutputStream();
		        out.write(buff);
				out.close();
				
		        //读取响应
		        BufferedReader reader = new BufferedReader(new InputStreamReader(
		                connection.getInputStream()));
		        String lines;
		        StringBuffer sb = new StringBuffer("");
		        while ((lines = reader.readLine()) != null) {
		            lines = new String(lines.getBytes(), "utf-8");
		            sb.append(lines);
		        }
		        System.out.println(sb.toString());
		        result = 1;
	        }catch (Exception e) {
				System.out.println(e.getMessage());
			}
		}catch (Exception e) {
			System.out.println(e.getMessage());
		}
		return result;
	}
	
	/**
	 * 修改信息
	 * @param WaitPakInEntity
	 * @return
	 */
	@ResponseBody
	@RequestMapping("/upWaitPakIn.action")
	public Integer upWaitPakIn(WaitPakInBean waitPakIn,HttpServletRequest request){
		int result = 0;
		try {
			UserBean user=(UserBean)request.getSession().getAttribute("USER");
			waitPakIn.setModi_user(user.getUser_account());
			
			result=waitPakInService.upWaitPakIn(waitPakIn);
			if(result>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("upWaitPakIn.action");
				sysLog.setTts_keyname("修改入库通知档:" + waitPakIn.getSheet_no());
				sysLog.setModi_user(user.getUser_account());
				sysLogService.insertSysLog(sysLog);
			}
		}catch(Exception e) {
			System.out.println(e.getMessage());
		}
		return result;
	}
	
	/**
	 * 删除信息
	 * @param id
	 * @return
	 */
	@ResponseBody
	@RequestMapping("/delWaitPakIn.action")
	public int delWaitPakIn(@RequestParam("lgnum")String lgnum,@RequestParam("tbnum")int tbnum,
			@RequestParam("tbpos")int tbpos,@RequestParam("zmatid")String zmatid,HttpServletRequest request){
		int result = 0;
		try {
			WaitPakInBean waitPakIn = new WaitPakInBean();
			waitPakIn.setLgnum(lgnum);
			waitPakIn.setTbnum(tbnum);
			waitPakIn.setTbpos(tbpos);
			waitPakIn.setZmatid(zmatid);
			result=waitPakInService.delWaitPakIn(waitPakIn);
			
			if(result>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("delWaitPakIn.action");
				sysLog.setTts_keyname("删除通知档资料:" + lgnum + "-" + tbnum);
				sysLog.setModi_user(user.getUser_account());
				sysLogService.insertSysLog(sysLog);
			}
		}catch(Exception e) {
			System.out.println(e.getMessage());
		}
		return result;
	}
	
	/**
	 * 查询所有
	 * @return
	 */
	@ResponseBody
	@RequestMapping("/getWaitPakIn.action")
	public List<WaitPakInBean> getWaitPakIn(){
		try {
			return waitPakInService.getWaitPakInList();
		}catch(Exception e) {
			System.out.println(e.getMessage());
			return null;
		}		
	}
	
	/**
	 * 通知档资料转历史档
	 * @return
	 */
	@ResponseBody
	@RequestMapping("/movePakInToLog.action")
	public int movePakInToLog(@RequestParam("ids")String[] sheetNos,
			@RequestParam("matStr")String[] matNos,HttpServletRequest request){
		int result = 0;
		try {
			String sheet_no="", mat_no="";
			for(int i=0;i<sheetNos.length;i++) {
				WaitPakInBean waitPakIn = new WaitPakInBean();
				waitPakIn.setSheet_no(sheetNos[i]);
				waitPakIn.setMat_no(matNos[i]);
				result=waitPakInService.moveToLog(waitPakIn);
			}			
			if(result>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("movePakInToLog.action");
				sysLog.setTts_keyname("通知档资料转历史档:" + sheet_no + "-" + mat_no);
				sysLog.setModi_user(user.getUser_account());
				sysLogService.insertSysLog(sysLog);
			}
		}catch(Exception e) {
			System.out.println(e.getMessage());
		}
		return result;
	}
	
}