package com.slcf.controller;

import java.io.*;
import java.net.HttpURLConnection;
import java.net.URL;
import java.util.List;
import java.util.Map;

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

import com.alibaba.excel.EasyExcel;
import com.slcf.controller.param.SyncStockParam;
import org.apache.commons.io.IOUtils;
import org.apache.log4j.Logger;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.orm.jpa.EntityManagerFactoryUtils;
import org.springframework.stereotype.Controller;
import org.springframework.transaction.annotation.Transactional;
import org.springframework.web.bind.annotation.*;

import com.slcf.pojo.UserBean;
import com.slcf.pojo.WaitPakInBean;
import com.slcf.bean.LocDetailCondition;
import com.slcf.bean.LocationCondition;
import com.slcf.pojo.LocDetailBean;
import com.slcf.pojo.LocationBean;
import com.slcf.pojo.SysLogBean;
import com.slcf.service.LocDetailService;
import com.slcf.service.LocationService;
import com.slcf.service.RoleService;
import com.slcf.service.SysLogService;
import com.slcf.util.AuthorityCode;
import com.slcf.util.Constants;

import net.sf.json.JSONArray;
import net.sf.json.JSONObject;
import org.springframework.web.multipart.MultipartFile;
import sun.misc.BASE64Encoder;

/**
 * 库位管理控制器层
 * @author admin
 * @date 2018年11月13日
 */
@Controller
@RequestMapping("/stock")
public class StockController {

	@Resource
	LocationService locationService;
	@Autowired
	LocDetailService locDetailService;
	@Autowired
	SysLogService sysLogService;
	@Autowired
	RoleService roleService;
	
	Logger logger=Logger.getLogger(StockController.class);
	
	@RequestMapping("/goStock.action")
	public String goLocationPage(HttpServletRequest request){
		try {
			String rid = request.getSession().getAttribute("ROLEID").toString();
			String authCode = roleService.getAuthListByRoleMenu(Integer.parseInt(rid), 
					AuthorityCode.StockCode);
			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("goStock.action");
			sysLog.setTts_keyname("访问:库存查询");
			sysLog.setModi_user(user.getUser_account());
			sysLogService.insertSysLog(sysLog);
		}catch (Exception e) {
			System.out.println(e.getMessage());
		}
		return "stock";
	}
	
	/**
	 * 分页查询所有
	 * @param pageNumber
	 * @param pageSize
	 * @return
	 */
	@ResponseBody
	@RequestMapping("/locationList.action")
	public Map<String,Object> queryLocationListByPages(LocationCondition locationCon){				
		Map<String,Object>map=locationService.queryLocationList(locationCon);
		return map;
	}
	
	/**
	 * 分页查询所有
	 * @param pageNumber
	 * @param pageSize
	 * @return
	 */
	@ResponseBody
	@RequestMapping("/stkDetailList.action")
	public Map<String,Object> queryLocDetailListByPages(LocDetailCondition locDetailCon){
		if(locDetailCon.getLoc_no()==null || locDetailCon.getLoc_no().equals("")) {
			return null;
//			locationCon.setLoc_no("1");
		}
		Map<String,Object>map=locDetailService.queryLocDetailList(locDetailCon);
		return map;
	}
	
	/**
	 * 根据id查询信息
	 * @param id
	 * @return
	 */
	@ResponseBody
	@RequestMapping("/queryLocationById.action")
	public LocationBean queryLocationById(@RequestParam("did")String id){
		try {
			return locationService.queryLocationById(id);
		}catch(Exception e) {
			System.out.println(e.getMessage());
			return null;
		}
	}
	
	/**
	 * 查询所有
	 * @return
	 */
	@ResponseBody
	@RequestMapping("/getLocation.action")
	public List<LocationBean> getLocation(){
		try {
			return locationService.getLocationList();
		}catch(Exception e) {
			System.out.println(e.getMessage());
			return null;
		}		
	}
	
	/**
	 * 调用SAP库存同步接口，同步SAP库存到ASRS
	 * @param loc_no
	 * @return
	 */
	@ResponseBody
	@RequestMapping("/syncStockFromSap.action")
	public Integer syncStockFromSap(@RequestParam("loc_no")String loc_no,
			@RequestParam("barcode")String barcode,HttpServletRequest request){
		int result = 0;
		try {
//			String sb = "{\"d\":{\"results\":[{\"__metadata\":{\"id\":\"httpTO_CDS(lgnum='385',lqnum='0000126742')\",\"uri\":\"http://d01aas25.sap.kraussmaffeigroup.net:8025/sap/opu/odata/SAP/Z_WM_H5_SRV/ZLQUA_AUTO_CDS(lgnum='385',lqnum='0000126742')\",\"type\":\"Z_WM_H5_SRV.ZLQUA_AUTO_CDSType\"},\"lgnum\":\"385\",\"lqnum\":\"0000126742\",\"lgtyp\":\"A01\",\"lgpla\":\"0400201\",\"matnr\":\"0028009\",\"maktx\":\"RECHTECK\",\"werks\":\"3885\",\"gesme\":\"5.000\",\"altme\":\"KGM\"}]}}";
			UserBean user=(UserBean)request.getSession().getAttribute("USER");
//			String httpUrl = Constants.SAP_URL + "/sap/opu/odata/SAP/Z_WM_H5_SRV/autoStorageSet";
			String httpUrl = Constants.SAP_URL + "/sap/opu/odata/SAP/Z_WM_H5_SRV/ZLQUA_AUTO_CDS";
			result = sendSyncStockCmd(httpUrl,loc_no,barcode);
//			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("同步SAP库存到ASRS:" + loc_no);
				sysLog.setModi_user(user.getUser_account());
				sysLogService.insertSysLog(sysLog);
			}
		}catch(Exception e) {
			System.out.println(e.getMessage());
		}
		return result;
	}

	/**
	 * 调用SAP库存同步接口，同步SAP库存到ASRS
	 * @param loc_no
	 * @return
	 */
	@ResponseBody
	@RequestMapping(value = "/syncStocksFromSap.action", method = RequestMethod.POST)
	public String syncStocksFromSap(@RequestBody List<SyncStockParam> params, HttpServletRequest request){
		StringBuilder res = new StringBuilder();
		int result = 0;
		int success = 0;
		int total = 0;
		try {
			if (params != null && params.size()>0) {
				for (SyncStockParam param : params) {
					total ++;
					String sb = "{\"d\":{\"results\":[{\"__metadata\":{\"id\":\"httpTO_CDS(lgnum='385',lqnum='0000126742')\",\"uri\":\"http://d01aas25.sap.kraussmaffeigroup.net:8025/sap/opu/odata/SAP/Z_WM_H5_SRV/ZLQUA_AUTO_CDS(lgnum='385',lqnum='0000126742')\",\"type\":\"Z_WM_H5_SRV.ZLQUA_AUTO_CDSType\"},\"lgnum\":\"385\",\"lqnum\":\"0000126742\",\"lgtyp\":\"A01\",\"lgpla\":\"0400201\",\"matnr\":\"0028009\",\"maktx\":\"RECHTECK\",\"werks\":\"3885\",\"gesme\":\"5.000\",\"altme\":\"KGM\"}]}}";
					UserBean user=(UserBean)request.getSession().getAttribute("USER");
					String httpUrl = Constants.SAP_URL + "/sap/opu/odata/SAP/Z_WM_H5_SRV/ZLQUA_AUTO_CDS";
					result = sendSyncStockCmd(httpUrl,param.getLocNo(),param.getBarcode());
//					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("同步SAP库存到ASRS:" + param.getBarcode());
						sysLog.setModi_user(user.getUser_account());
						sysLogService.insertSysLog(sysLog);
						success ++ ;
					} else {
						res.append(param.getLocNo()).append(",");
					}
				}
			}
//
		}catch(Exception e) {
			System.out.println(e.getMessage());
		}
		res.insert(0, "Number Of FAIL: " + (total - success) + "\n\n");
		res.insert(0, "Number Of SUCCESS: " + (success) + "\n\n");
		res.insert(0, "Processing is complete!\n\n");
		if (res.length() > 0) {
			res.append("location synchronization failure!");
		} else {
			res.append("synchronization success");
		}
		return res.toString();
	}

//	@RequestMapping(value = "/sync/excel/file/import.action", method = RequestMethod.POST)
//	@ResponseBody
//	public String matCodeImport(MultipartFile file) throws IOException, InterruptedException {
//		MatCodeExcelListener listener = new MatCodeExcelListener(getUserId());
//		EasyExcel.read(file.getInputStream(), MatCodeExcel.class, listener).sheet().doRead();
//		System.out.println(file.getOriginalFilename());
//		return "ok";
//	}


	/**
	 * 调用sap接口完成ASRS库存更新
	 */
	private int sendSyncStockCmd(String httpUrl,String loc_no,String barcode) {
		int result = 0;
		String input = Constants.SAP_USER + ":" + Constants.SAP_PASSWORD;//"ZHANGX:654321";
        BASE64Encoder base = new BASE64Encoder();
        String encodedPassword;
		try {
			encodedPassword = base.encode(input.getBytes("UTF-8"));
//			httpUrl += "?$filter=lgnum eq '385' and lgtyp eq 'A01' and lgpla eq '" + loc_no + "'";
			//"?$filter=lgnum%20eq%20%27385%27"
//			String filter = java.net.URLEncoder.encode("?$filter=lgnum eq '385'", "utf-8");
//			httpUrl += "?$filter=lgnum%20eq%20%27385%27%20";
			//空格20%,单引号27%
//			String filter1 = "?$filter=lgnum%20eq%20%27385%27%20and20%lgtyp%20eq%20%27A01%27";//20%and20%lgpla20%eq%20%27" + loc_no + "27%";
			String filter  = "?$filter=lgnum%20eq%20%27385%27%20and%20lgtyp%20eq%20%27A01%27%20and%20lgpla%20eq%20%27" + loc_no + "%27%20";
			httpUrl += filter;
			URL url1 = new URL(httpUrl);
	        HttpURLConnection connection = (HttpURLConnection) url1.openConnection();
	        connection.setDoOutput(true);
	        connection.setDoInput(true);
	        connection.setRequestMethod("GET");
	        connection.setRequestProperty("Authorization", "Basic " + encodedPassword);
	        connection.setRequestProperty("Content-Type","application/json");
	        connection.setRequestProperty("Accept","application/json");
	        connection.setRequestProperty("Accept-Language","zh-CN,zh;q=0.9");
//	        connection.setRequestProperty("Accept-Encoding","gzip, deflate");
	        connection.setRequestProperty("x-csrf-token","Fetch");

	        //读取响应
	        InputStream instream = connection.getInputStream();
	        String sb = IOUtils.toString(instream,"utf-8");
//	        BufferedReader reader = new BufferedReader(new InputStreamReader(
//	        		connection.getInputStream(),"utf-8"));
//	        String lines;
//	        StringBuffer sb = new StringBuffer("");
//	        while ((lines = reader.readLine()) != null) {
//	            lines = new String(lines.getBytes(), "utf-8");
//	            sb.append(lines);
//	        }
			logger.error("syncStocksFromSap---同步库存返回数据" + sb.toString());
	        //解析json，更新库存
	        JSONObject json = JSONObject.fromObject(sb.toString());
			String d = json.get("d").toString();
			JSONObject jsonItem = JSONObject.fromObject(d);
			String results = jsonItem.get("results").toString();
			JSONArray array = JSONArray.fromObject(results);

			result = locDetailService.delLocDetailByLocNo(loc_no);
			if(array.size()>0) {
				for(int i=0;i<array.size();i++){
					JSONObject job = array.getJSONObject(i);
					String matnr = job.get("matnr").toString();
					String maktx = job.get("maktx").toString();
					String werks = job.get("werks").toString();
					double gesme = job.get("gesme").toString().equals("")?0:Double.parseDouble(job.get("gesme").toString());
					String altme = job.get("altme").toString();
					
					LocDetailBean locDetl = new LocDetailBean();
//					logger.error("syncStocksFromSap---插入数据" + matnr+"-"+maktx+"-"+werks+"-"+gesme+"-"+altme);
					locDetl.setLoc_no(loc_no);
					locDetl.setMatnr(matnr);
					locDetl.setLgnum("385");
					locDetl.setTbnum(1);
					locDetl.setTbpos(1);
					locDetl.setZmatid("1");
					locDetl.setMaktx(maktx);
					locDetl.setWerks(werks);
					locDetl.setAnfme(gesme);
					locDetl.setAltme(altme);
					locDetl.setZpallet(barcode);
					locDetl.setBname("");
					result = locDetailService.insertLocDetail(locDetl);
//					logger.error("syncStocksFromSap---插入结果" + result);

					if(result<=0) {
						break;
					}
				}
			}
		} catch (Exception e) {
			logger.error("sendSyncStockCmd Error----" + e.getMessage());
			System.out.println(e.getMessage());
		}
		return result;
	}
	
}