package com.slcf.filter;

import java.io.BufferedReader;
import java.io.IOException;
import java.io.InputStreamReader;
import java.io.OutputStream;
import java.net.HttpURLConnection;
import java.net.URL;
import java.util.Date;
import java.util.HashMap;

import javax.annotation.Resource;

import com.alibaba.fastjson.JSON;
import com.slcf.pojo.SapRequestLogBean;
import com.slcf.service.SapRequestLogService;
import com.slcf.util.HttpHandler;
import net.sf.json.JSONString;
import org.activiti.engine.impl.transformer.IntegerToString;
import org.apache.log4j.Logger;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Controller;
import org.springframework.stereotype.Service;
import org.springframework.web.bind.annotation.RequestMapping;

import com.slcf.bean.AllBean;
import com.slcf.pojo.WaitPakInBean;
import com.slcf.pojo.WaitPakOutBean;
import com.slcf.service.WaitPakInService;
import com.slcf.service.WaitPakOutService;
import com.slcf.service.impl.WaitPakInServiceImpl;
import com.slcf.util.Constants;
import com.slcf.util.SpringBeanUtils;

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

/**
 * 回报，处理与sap交互数据
 * @author admin
 * @Date 2020-02-17
 */
//@Service
public class UpdateThread extends Thread {//implements Runnable{
//	@Resource
//	WaitPakInService waitPakInService;
//	@Resource
//	WaitPakOutService waitPakOutService;
//	@Resource
//	private static WaitPakInServiceImpl waitPakInService;
	@Autowired
	SapRequestLogService sapRequestLogService;

	Logger logger=Logger.getLogger(UpdateThread.class);

	public static int count=0;

	private WaitPakInService waitPakInService;
	public WaitPakInService getWaitPakInService() {
		return waitPakInService;
	}
	public void setWaitPakInService(WaitPakInService waitPakInService) {
		this.waitPakInService = waitPakInService;
	}

	private WaitPakOutService waitPakOutService;
	public WaitPakOutService getWaitPakOutService() {
		return waitPakOutService;
	}
	public void setWaitPakOutService(WaitPakOutService waitPakOutService) {
		this.waitPakOutService = waitPakOutService;
	}

	public void run() {
		waitPakInService = getWaitPakInService();
		waitPakOutService = getWaitPakOutService();
		while(true) {
			try {
				updateWaitPakInData(); // 入库
				sendPickPrintCmd(); // 打印
				updateWaitPakOutData(); // 出库
				// 清空2天前的日志
				sapRequestLogService.clearSapLog();
//				updateWaitCheckData();
				Thread.sleep(15000);
			} catch (InterruptedException e) {
				e.printStackTrace();
			}
		}
	}
    public JSONObject requestSAP(JSONObject body, String url) {
		logger.info(url);
        JSONObject resp;

            HashMap<String, Object> requestHeader = new HashMap<>();
            requestHeader.put("Accept", "application/json");
            requestHeader.put("Content-Type", "application/json");
            requestHeader.put("X-Requested-With", "X");
            requestHeader.put("Authorization","Basic TElRSTpzdGFydDEu");
            requestHeader.put("sap-client","100");
        String s = null;
        try {
            s = new HttpHandler.Builder()
                    .setUri(url)
                    .setJson(body.toString())
                    .setHeaders(requestHeader)
                    .build()
                    .doPost();
        } catch (IOException e) {
            throw new RuntimeException(e);
        }
        resp = JSONObject.fromObject(s);
		logger.info("返回体：" + resp);
        return resp;
    }

	/**
	 * 处理入库通知档数据
	 */
	private void updateWaitPakInData() {
		try {
//			logger.info("waitIn:" + count++);
			WaitPakInBean waitPakInBean = waitPakInService.queryWaitPakInFnh();
			if(waitPakInBean!=null) {
				String httpUrl = Constants.SAP_URL + "/sap/opu/odata/SAP/Z_WM_H5_DW_SRV/AsrsTrSet";
				int result = sendPakInStatus(httpUrl,waitPakInBean);
			}
		}catch(Exception e) {
			logger.error("SAP Error updateWaitPakInData---" + e.getMessage());
//			System.out.println(e.getMessage());
		}
	}

	/**
	 * 入库完成，调用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="";

//        HttpURLConnection connection1 = null;
//		try {
//			encodedPassword = base.encode(input.getBytes("UTF-8"));
//			URL url1 = new URL(httpUrl);
//	        connection1 = (HttpURLConnection) url1.openConnection();
//	        connection1.setDoOutput(true);
//	        connection1.setDoInput(true);
//	        connection1.setConnectTimeout(30000);
//	        connection1.setReadTimeout(30000);
//	        connection1.setRequestMethod("GET");
//	        connection1.setRequestProperty("Authorization", "Basic " + encodedPassword);
//	        connection1.setRequestProperty("x-csrf-token","Fetch");
//
//
//	        String sessionCookie = connection1.getHeaderField("Set-Cookie");
//	        if(sessionCookie==null || sessionCookie.length()<1)
//	        {
//	        	logger.error("SAP ERROR-----调用上架完成接口，get请求获取cookie失败");
//				// SAP INFO-----调用上架完成接口，日志记录
//				SapRequestLogBean logInfo = new SapRequestLogBean();
//				logInfo.setMatnr(waitPakIn.getMatnr());
//				logInfo.setRequest("获取cookie失败,cookie值:" + sessionCookie);
//				logInfo.setResponse("SAP ERROR-----调用上架完成接口，get请求获取cookie失败");
//				logInfo.setCreate_time(new Date());
//				logInfo.setType(2);
////				sapRequestLogService.addSapLog(logInfo);
//	        	return result;
//	        }
//	        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) {
//			logger.error("SAP ERROR-----调用上架完成接口1，get请求获取cookie失败。" + e1.getMessage());
//			// SAP INFO-----调用上架完成接口，日志记录
//			SapRequestLogBean logInfo = new SapRequestLogBean();
//			logInfo.setMatnr(waitPakIn.getMatnr());
//			logInfo.setRequest("获取cookie失败");
//			logInfo.setResponse("SAP ERROR-----调用上架完成接口1，get请求获取cookie失败。" + e1.getMessage());
//			logInfo.setCreate_time(new Date());
//			logInfo.setType(2);
////			sapRequestLogService.addSapLog(logInfo);
////			e1.printStackTrace();
//		}finally {
//			if(connection1!=null){
//				connection1.disconnect();
//			}
//		}

		JSONObject jsObj = new JSONObject();
		try {
			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;
            JSONObject json = requestSAP(jsObj, httpUrl);

            //创建连接
//			HttpURLConnection connection = null;
//	        try {
////	        	String input = "ZHANGX:654321";
////	            BASE64Encoder base = new BASE64Encoder();
////	            String encodedPassword = base.encode(input.getBytes("UTF-8"));
//
//	        	URL url = new URL(httpUrl);
//		        connection = (HttpURLConnection) url.openConnection();
//		        connection.setDoOutput(true);
//		        connection.setDoInput(true);
//		        connection.setRequestMethod("POST");
//		        connection.setConnectTimeout(30000);
//		        connection.setReadTimeout(30000);
////        		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);
//		        }
//		        logger.error("SAP INFO-----调用上架完成接口，返回JSON数据：" + sb.toString());
//		        System.out.println(sb.toString());
//		        JSONObject json = JSONObject.fromObject(sb.toString());
				String d = json.get("d").toString();
				JSONObject jsonD = JSONObject.fromObject(d);
				String Item = jsonD.get("item").toString();
				JSONObject jsonItem = JSONObject.fromObject(Item);
				String results = jsonItem.get("results").toString();
				JSONArray array = JSONArray.fromObject(results);

				if(array.size()>0) {
					for(int i=0;i<array.size();i++){
						JSONObject job = array.getJSONObject(i);
						String zstatus = job.get("zstatus").toString();
//						String message = job.get("message").toString();
						String message="";
						try {
							message = java.net.URLDecoder.decode(job.get("message").toString(), "utf-8");
//							logger.error("SAP TEST-----数据：" + message);
						}catch(Exception em) {
						}
						if(zstatus.equals("s") || message.contains("已经完全提供")) {//上报SAP成功,转历史档
							// SAP INFO-----调用上架完成接口，日志记录
							SapRequestLogBean logInfo = new SapRequestLogBean();
							logInfo.setMatnr(waitPakIn.getMatnr());
							logInfo.setRequest(jsObj.toString());
							logInfo.setResponse(json.toString());
							logInfo.setCreate_time(new Date());
							logInfo.setRemark("上架完成接口:" + message);
							logInfo.setType(1);
//							sapRequestLogService.addSapLog(logInfo);
//						if(zstatus.equals("s")) {
							waitPakIn.setIo_status("Y");
							waitPakInService.upWaitPakIn(waitPakIn);
							waitPakInService.moveToLog(waitPakIn);
						}else if(zstatus.equals("e")) {//上报SAP失败,更新io_status=X
							// SAP INFO-----调用上架完成接口，日志记录
							SapRequestLogBean logInfo = new SapRequestLogBean();
							logInfo.setMatnr(waitPakIn.getMatnr());
							logInfo.setRequest(jsObj.toString());
							logInfo.setResponse(json.toString());
							logInfo.setCreate_time(new Date());
							logInfo.setRemark("上架完成接口:" + message);
							logInfo.setType(2);
//							sapRequestLogService.addSapLog(logInfo);
							waitPakIn.setIo_status("X");
							waitPakIn.setMemo(message);
							waitPakInService.upWaitPakIn(waitPakIn);
						}
//						System.out.println("zstatus信息.." + zstatus);
//						System.out.println("message信息.." + message);
					}
				}
		        result = 1;
	        }catch (Exception e) {
	        	waitPakIn.setIo_status("X");
				waitPakIn.setMemo(e.getMessage());
				waitPakInService.upWaitPakIn(waitPakIn);
	        	logger.error("SAP Error sendPakInStatus--"+waitPakIn.getMatnr()+"---" + e.getMessage());
				logger.error("1入库完成回报异常时ASRS请求JSON：" + jsObj.toString());
//				System.out.println(e.getMessage());
			}
//		}catch (Exception e) {
//			waitPakIn.setIo_status("X");
//			waitPakIn.setMemo(e.getMessage());
//			waitPakInService.upWaitPakIn(waitPakIn);
//			logger.error("SAP Error sendPakInStatus--"+waitPakIn.getMatnr()+"---" + e.getMessage());
//			logger.error("2入库完成回报异常时ASRS请求JSON：" + jsObj.toString());
////			System.out.println(e.getMessage());
//		}
		return result;
	}

	/**
	 * 处理出库通知档数据
	 */
	private void updateWaitPakOutData() {
		try {
//			logger.info("waitOut:" + count++);
			WaitPakOutBean waitPakOutBean = waitPakOutService.queryWaitPakOutFnh();
			if(waitPakOutBean!=null) {
				String httpUrl = Constants.SAP_URL + "/sap/opu/odata/SAP/Z_WM_H5_DW_SRV/ToConHeadSet";
				int result = sendPakOutStatus(httpUrl,waitPakOutBean);
			}
		}catch(Exception e) {
			logger.error("SAP Error updateWaitPakOutData---" + e.getMessage());
		}
	}

	/**
	 * 出库完成，调用sap接口上传完成信息
	 */
	private int sendPakOutStatus(String httpUrl,WaitPakOutBean waitPakOut) {
		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="";

//        HttpURLConnection connection1 = null;
//		try {
//			encodedPassword = base.encode(input.getBytes("UTF-8"));
//			URL url1 = new URL(httpUrl);
//	        connection1 = (HttpURLConnection) url1.openConnection();
//	        connection1.setDoOutput(true);
//	        connection1.setDoInput(true);
//	        connection1.setConnectTimeout(30000);
//	        connection1.setReadTimeout(30000);
//	        connection1.setRequestMethod("GET");
//	        connection1.setRequestProperty("Authorization", "Basic " + encodedPassword);
//	        connection1.setRequestProperty("x-csrf-token","Fetch");
//	        String sessionCookie = connection1.getHeaderField("Set-Cookie");
//	        if(sessionCookie==null || sessionCookie.length()<1)
//	        {
//	        	logger.error("调用下架完成接口，get请求获取cookie失败");
//				// SAP INFO-----调用上架完成接口，日志记录
//				SapRequestLogBean logInfo = new SapRequestLogBean();
//				logInfo.setMatnr(waitPakOut.getMatnr());
//				logInfo.setRequest("获取cookie值失败,cookie：" + sessionCookie);
//				logInfo.setResponse("调用出库完成接口，get请求获取cookie失败");
//				logInfo.setCreate_time(new Date());
//				logInfo.setType(2);
////				sapRequestLogService.addSapLog(logInfo);
//	        	return result;
//	        }
//	        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) {
//			logger.error("调用下架完成接口，get请求获取cookie失败" + e1.getMessage());
//			// SAP INFO-----调用上架完成接口，日志记录
//			SapRequestLogBean logInfo = new SapRequestLogBean();
//			logInfo.setMatnr(waitPakOut.getMatnr());
//			logInfo.setRequest("获取cookie失败");
//			logInfo.setResponse("调用出库完成接口，get请求获取cookie失败");
//			logInfo.setCreate_time(new Date());
//			logInfo.setType(2);
////			sapRequestLogService.addSapLog(logInfo);
////			e1.printStackTrace();
//		}finally{
//			if(connection1!=null){
//				connection1.disconnect();
//			}
//		}

		logger.info("TEST===>>4");

		JSONObject jsObj = new JSONObject();
		try {
			JSONArray arr = new JSONArray();
			for(int i=0;i<1;i++) {
				JSONObject json = new JSONObject();
				json.put("lgnum",waitPakOut.getLgnum());
				json.put("tanum",Long.toString(waitPakOut.getTanum()));
				json.put("tapos",Integer.toString(waitPakOut.getTapos()));

				double nista =  waitPakOut.getNista();
//				if(nista>0)
				if(nista>=-1 && (int)nista!=0)
				{
					double vsolm = waitPakOut.getVsolm();
					if( (int)nista == -1 ) {
						nista=0;
					}
					double ndifa = vsolm - nista;
					json.put("nista",Double.toString(nista));  //实际数量
					json.put("ndifa",Double.toString(ndifa));  //差异数量
				}
				json.put("altme",waitPakOut.getMeins());
				json.put("nltyp","A01");
//				json.put("nlpla",waitPakOut.getNlpla());
				json.put("arbpl","A01-01");
				arr.add(json);
			}
			int action = 1;
			if (waitPakOut.getAction() == 3){
				action = waitPakOut.getAction();
			}
			jsObj.put("trart", Integer.toString(action));
			jsObj.put("item", arr);
			byte[] buff = jsObj.toString().getBytes();
			int buffLen = buff.length;
			//创建连接
//			HttpURLConnection connection = null;
//	        try {
////	        	String input = "ZHANGX:654321";
////	            BASE64Encoder base = new BASE64Encoder();
////	            String encodedPassword = base.encode(input.getBytes("UTF-8"));
//
//	        	URL url = new URL(httpUrl);
//		        connection = (HttpURLConnection) url.openConnection();
//		        connection.setDoOutput(true);
//		        connection.setDoInput(true);
//		        connection.setConnectTimeout(30000);
//		        connection.setReadTimeout(30000);
//		        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());
                JSONObject json = requestSAP(jsObj, httpUrl);
//		        JSONObject json = JSONObject.fromObject(sb.toString());
				String d = json.get("d").toString();
				JSONObject jsonD = JSONObject.fromObject(d);
				String Item = jsonD.get("item").toString();
				JSONObject jsonItem = JSONObject.fromObject(Item);
				String results = jsonItem.get("results").toString();
				JSONArray array = JSONArray.fromObject(results);

				logger.info("出库通知档SAP返回数据集大小 ===>> " + array.size());
				if(array.size()>0) {
					for(int i=0;i<array.size();i++){
						JSONObject job = array.getJSONObject(i);
						String zstatus = job.get("zstatus").toString();
//						String message = job.get("message").toString();
						String message="";
						try {
							message = java.net.URLDecoder.decode(job.get("message").toString(), "utf-8");
						}catch(Exception em) {
						}
						if(zstatus.equals("s") || message.contains("已经完全提供") || message.contains("已确认")) {
							// SAP INFO-----调用下架完成接口，日志记录
							SapRequestLogBean logInfo = new SapRequestLogBean();
							logInfo.setMatnr(waitPakOut.getMatnr());
							logInfo.setRequest(jsObj.toString());
							logInfo.setResponse(json.toString());
							logInfo.setCreate_time(new Date());
							logInfo.setType(1);
							logInfo.setRemark("出库完成接口:" + message);
//							sapRequestLogService.addSapLog(logInfo);
//						if(zstatus.equals("s")) {//上报SAP成功,转历史档
							waitPakOut.setIo_status("Y");
							waitPakOutService.upWaitPakOut(waitPakOut,0);
							waitPakOutService.moveToLog(waitPakOut);
						}else if(zstatus.equals("e")) {//上报SAP失败,更新io_status=X
							// SAP INFO-----调用下架完成接口，日志记录
							SapRequestLogBean logInfo = new SapRequestLogBean();
							logInfo.setMatnr(waitPakOut.getMatnr());
							logInfo.setRequest(jsObj.toString());
							logInfo.setResponse(json.toString());
							logInfo.setCreate_time(new Date());
							logInfo.setType(2);
							logInfo.setRemark("出库完成接口:" + message);
//							sapRequestLogService.addSapLog(logInfo);
							waitPakOut.setIo_status("X");
							waitPakOut.setMemo(message);
							waitPakOutService.upWaitPakOut(waitPakOut,0);
							logger.error("SAP返回异常时，ASRS提交的json--" + jsObj.toString());
						}
//						System.out.println("zstatus信息.." + zstatus);
//						System.out.println("message信息.." + message);
					}
				}
		        result = 1;
	        }catch (Exception e) {
	        	waitPakOut.setIo_status("X");
				waitPakOut.setMemo(e.getMessage());
				waitPakOutService.upWaitPakOut(waitPakOut,0);
	        	logger.error("出库通知档回报异常1--"+waitPakOut.getMatnr() + "---" + e.getMessage());
	        	logger.error("1出库完成回报异常时ASRS请求JSON：" + jsObj.toString());
//				System.out.println(e.getMessage());
			}
//		}catch (Exception e) {
//			waitPakOut.setIo_status("X");
//			waitPakOut.setMemo(e.getMessage());
//			waitPakOutService.upWaitPakOut(waitPakOut,0);
//			logger.error("出库通知档回报异常2--"+waitPakOut.getMatnr() + "---" + e.getMessage());
//			logger.error("2出库完成回报异常时ASRS请求JSON：" + jsObj.toString());
////			System.out.println(e.getMessage());
//		}
		return result;
	}

	/**
	 * 处理打印标签需求
	 */
	private void sendPickPrintCmd() {
		try {
			WaitPakOutBean waitPakOutBean = waitPakOutService.getWaitPakOutPrint();
			if(waitPakOutBean!=null) {
				String httpUrl = Constants.SAP_URL + "/sap/opu/odata/SAP/Z_WM_H5_DW_SRV/ToConHeadSet";
				int result = sendPrinCommand(httpUrl,waitPakOutBean);
			}
		}catch(Exception e) {
			logger.error("SAP Error updateWaitPakOutData---" + e.getMessage());
		}
	}

	/**
	 * 拣料站，调用SAP打印标签接口,action=2
	 */
	private int sendPrinCommand(String httpUrl,WaitPakOutBean waitPakOut) {
		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="";
//
//        HttpURLConnection connection1 = null;
//		try {
////			logger.error("sendPrinCommand-----调用打印接口" + waitPakOut.getMaktx());
//			encodedPassword = base.encode(input.getBytes("UTF-8"));
//			URL url1 = new URL(httpUrl);
//	        connection1 = (HttpURLConnection) url1.openConnection();
//	        connection1.setDoOutput(true);
//	        connection1.setDoInput(true);
//	        connection1.setConnectTimeout(30000);
//	        connection1.setReadTimeout(30000);
//	        connection1.setRequestMethod("GET");
//	        connection1.setRequestProperty("Authorization", "Basic " + encodedPassword);
//	        connection1.setRequestProperty("x-csrf-token","Fetch");
//	        String sessionCookie = connection1.getHeaderField("Set-Cookie");
//	        if(sessionCookie==null || sessionCookie.length()<1)
//	        {
//	        	logger.error("调用打印接口，get请求获取cookie失败");
//	        	// 调用sap打印接口,记录日志
//				SapRequestLogBean logInfo = new SapRequestLogBean();
//				logInfo.setMatnr(waitPakOut.getMatnr());
//				logInfo.setRequest("调用打印接口，get请求获取cookie失败");
//				logInfo.setResponse(sessionCookie);
//				logInfo.setCreate_time(new Date());
//				logInfo.setType(2);
//				sapRequestLogService.addSapLog(logInfo);
//	        	return result;
//	        }
//	        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) {
//			logger.error("sendPrinCommand1-----调用打印接口请求cookie失败" + waitPakOut.getMaktx() + e1.getMessage());
//			// 调用sap打印接口,记录日志
//			SapRequestLogBean logInfo = new SapRequestLogBean();
//			logInfo.setMatnr(waitPakOut.getMatnr());
//			logInfo.setRequest("sendPrinCommand1-----调用打印接口请求cookie失败"  + waitPakOut.getMaktx());
//			logInfo.setResponse(e1.getMessage());
//			logInfo.setCreate_time(new Date());
//			logInfo.setType(2);
//			sapRequestLogService.addSapLog(logInfo);
//			e1.printStackTrace();
//		}finally{
//			if(connection1!=null){
//				connection1.disconnect();
//			}
//		}

		try {
//			logger.error("sendPrinCommand2-----开始调用打印接口" + waitPakOut.getMaktx());
			JSONObject jsObj = new JSONObject();
			JSONArray arr = new JSONArray();
			for(int i=0;i<1;i++) {
				JSONObject json = new JSONObject();
				json.put("lgnum",waitPakOut.getLgnum());
				json.put("tanum",Long.toString(waitPakOut.getTanum()));
				json.put("tapos",Integer.toString(waitPakOut.getTapos()));

				double nista =  waitPakOut.getNista();
				if(nista>0)
				{
					double vsolm = waitPakOut.getVsolm();
					double ndifa = vsolm - nista;
					json.put("nista",Double.toString(nista));  //实际数量
					json.put("ndifa",Double.toString(ndifa));  //差异数量
				}
				json.put("altme",waitPakOut.getMeins());
				json.put("nltyp","A01");
//				json.put("nlpla",waitPakOut.getNlpla());
				json.put("arbpl","A01-01");
				arr.add(json);
			}
			jsObj.put("trart", "2");
			jsObj.put("item", arr);
			byte[] buff = jsObj.toString().getBytes();
			int buffLen = buff.length;
			//创建连接
//			HttpURLConnection connection = null;
//	        try {
////	        	String input = "ZHANGX:654321";
////	            BASE64Encoder base = new BASE64Encoder();
////	            String encodedPassword = base.encode(input.getBytes("UTF-8"));
//
//	        	URL url = new URL(httpUrl);
//		        connection = (HttpURLConnection) url.openConnection();
//		        connection.setDoOutput(true);
//		        connection.setDoInput(true);
//		        connection.setConnectTimeout(30000);
//		        connection.setReadTimeout(30000);
//		        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();
////				logger.error("sendPrinCommand3-----调用打印接口" + waitPakOut.getMaktx());
//		        //读取响应
//		        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());
//		        JSONObject json = JSONObject.fromObject(sb.toString());
                JSONObject json = requestSAP(jsObj, httpUrl);
				String d = json.get("d").toString();
				JSONObject jsonD = JSONObject.fromObject(d);
				String Item = jsonD.get("item").toString();
				JSONObject jsonItem = JSONObject.fromObject(Item);
				String results = jsonItem.get("results").toString();
				JSONArray array = JSONArray.fromObject(results);
				logger.error("sendPrinCommand4-----调用打印接口" + waitPakOut.getMaktx());
				if(array.size()>0) {
					for(int i=0;i<array.size();i++){
						JSONObject job = array.getJSONObject(i);
						String zstatus = job.get("zstatus").toString();
//						String message = job.get("message").toString();
						String message="";
						try {
							message = java.net.URLDecoder.decode(job.get("message").toString(), "utf-8");
						}catch(Exception em) {
						}
						if(zstatus.equals("s") || message.contains("已经完全提供")) {
//						if(zstatus.equals("s")) {//上报SAP成功,转历史档
							waitPakOut.setAction(1);     //模式变为1单独确认
							waitPakOut.setPrnstatus(2);  //打印完成
							waitPakOutService.upWaitPakOut(waitPakOut,0);
							logger.error("sendPrinCommand5---调用打印接口成功，请求json数据--" + jsObj.toString());
							logger.info("sendPrinCommand5---调用打印接口成功，返回json数据--" + json.toString());
							// 调用sap打印接口,记录日志
							SapRequestLogBean logInfo = new SapRequestLogBean();
							logInfo.setMatnr(waitPakOut.getMatnr());
							logInfo.setRequest(jsObj.toString());
							logInfo.setResponse(json.toString());
							logInfo.setCreate_time(new Date());
							logInfo.setRemark(message);
							logInfo.setType(1);
							sapRequestLogService.addSapLog(logInfo);
						}else if(zstatus.equals("e")) {//上报SAP失败,更新io_status=X
							waitPakOut.setPrnstatus(3); 	//打印失败
							waitPakOut.setMemo(message);
							waitPakOutService.upWaitPakOut(waitPakOut,0);
							logger.error("sendPrinCommand6---调用打印接口失败，请求json数据--" + message);
							// 调用sap打印接口,记录日志
							SapRequestLogBean logInfo = new SapRequestLogBean();
							logInfo.setMatnr(waitPakOut.getMatnr());
							logInfo.setRequest(jsObj.toString());
							logInfo.setResponse(json.toString());
							logInfo.setCreate_time(new Date());
							logInfo.setRemark(message);
							logInfo.setType(2);
							sapRequestLogService.addSapLog(logInfo);
						}
					}
				}
		        result = 1;
	        }catch (Exception e) {
	        	waitPakOut.setPrnstatus(3); 	//打印失败
				waitPakOut.setMemo(e.getMessage());
				waitPakOutService.upWaitPakOut(waitPakOut,0);
	        	logger.error("sendPrinCommand7---调用打印接口回报异常--"+waitPakOut.getMatnr() + "---" + e.getMessage());
				// 调用sap打印接口,记录日志
				SapRequestLogBean logInfo = new SapRequestLogBean();
				logInfo.setMatnr(waitPakOut.getMatnr());
//				logInfo.setRequest(jsObj.toString());
				logInfo.setResponse("sendPrinCommand7---调用打印接口回报异常--"+waitPakOut.getMatnr() + "---");
				logInfo.setCreate_time(new Date());
				logInfo.setRemark(e.getMessage());
				logInfo.setType(2);
				sapRequestLogService.addSapLog(logInfo);
//				System.out.println(e.getMessage());
			}
//		}catch (Exception e) {
//			waitPakOut.setPrnstatus(3); 	//打印失败
//			waitPakOut.setMemo(e.getMessage());
//			waitPakOutService.upWaitPakOut(waitPakOut,0);
//			logger.error("sendPrinCommand8---调用打印接口回报异常--"+waitPakOut.getMatnr() + "---" + e.getMessage());
//			// 调用sap打印接口,记录日志
//			SapRequestLogBean logInfo = new SapRequestLogBean();
//			logInfo.setMatnr(waitPakOut.getMatnr());
//			logInfo.setRequest("打印请求失败");
//			logInfo.setResponse("sendPrinCommand8---调用打印接口回报异常--"+waitPakOut.getMatnr() + "---");
//			logInfo.setCreate_time(new Date());
//			logInfo.setRemark(e.getMessage());
//			logInfo.setType(2);
//			sapRequestLogService.addSapLog(logInfo);
////			System.out.println(e.getMessage());
//		}
		return result;
	}

	/**
	 * 处理盘点通知档数据
	 */
	private void updateWaitCheckData() {
		try {
//			logger.info("waitCheck:" + count++);
		}catch(Exception e) {

		}
	}

	public static void main(String[] args) {
		UpdateThread Thread1=new UpdateThread();
		Thread mThread1=new Thread(Thread1,"线程1");
//		Thread mThread2=new Thread(Thread1,"线程2");
//		Thread mThread3=new Thread(Thread1,"线程3");
		mThread1.start();
//		mThread2.start();
//		mThread3.start();
	}
}