package com.web.pda.gltPda_wdPda.service.internal;

import java.sql.CallableStatement;
import java.sql.Connection;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.util.ArrayList;
import java.util.HashMap;
import java.util.List;
import java.util.Map;

import com.web.pda.gltPda_wdPda.service.GlueService;
import org.apache.commons.lang3.StringUtils;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.dao.DataAccessException;
import org.springframework.jdbc.core.CallableStatementCallback;
import org.springframework.jdbc.core.CallableStatementCreator;
import org.springframework.jdbc.core.JdbcTemplate;
import org.springframework.stereotype.Service;
import org.springframework.transaction.annotation.Propagation;
import org.springframework.transaction.annotation.Transactional;

import com.app.base.data.ApiResponseResult;

@Service(value = "GlueService")
@Transactional(propagation = Propagation.REQUIRED)
public class GlueImpl implements GlueService {

    @Autowired
    private JdbcTemplate jdbcTemplate;

    /**
     * 根据设备号获取信息
     * @param device
     * @return
     * @throws Exception
     */
    @Override
    @Transactional
    public ApiResponseResult afterDevice(String device) throws Exception {
    	if(StringUtils.isEmpty(device)){
            return ApiResponseResult.failure("设备号不能为空!");
        }

        //获取数据
        List<Object> delList = getDelListRf("10000", "1000", device, "App_Zhijiao_Shebei_Enter");
        String s2 = delList.get(0).toString();//resultList.get(0).substring(0);
        String[] delStrs = s2.split("\\[");
        if(delStrs.length < 1){
            return ApiResponseResult.failure("返回值的格式不正确：" + s2);
        }
        //判断取值是否成功
        String delStr = delStrs[0];
        if(delStr.equals("002")){
            return ApiResponseResult.failure("系统错误：" + s2);
        }
        //封装数据
        Map<String, Object> map = new HashMap<>();
        map.put("list", delList.get(1));

        return ApiResponseResult.success("获取数据成功！").data(map);
    }

    /**
     * 根据工位获取信息
     * @param station
     * @return
     * @throws Exception
     */
    @Override
    @Transactional
    public ApiResponseResult afterStation(String station) throws Exception{
        if(StringUtils.isEmpty(station)){
            return ApiResponseResult.failure("设备号不能为空!");
        }

        List<String> resultList = this.doPrc(station, "Prc_Check_ProcLine");
        System.out.println(resultList);

        if(resultList.size() > 0){
            String s = resultList.get(0).substring(0);
            String[] strs = s.split("\\[");
            if(strs.length < 1){
                return ApiResponseResult.failure("返回值的格式不正确：" + resultList);
            }
            //判断取值是否成功
            String str = strs[0];
            if(str.equals("002")){
                return ApiResponseResult.failure("系统错误：" + resultList);
            }
            //获取列表
            //例如：001[FJ001-1,{A05<A05>[A06<A06>
            //String station = "";
            List<Map> list = new ArrayList<>();
            if(StringUtils.isEmpty(strs[1])){
                return ApiResponseResult.failure("获取数据失败：" + resultList);
            }
            String[] orderArray = strs[1].split(",");
            if(orderArray.length < 1){
                return ApiResponseResult.failure("获取数据失败：" + resultList);
            }
            String[] orderArray1 = replaceNull(orderArray[1].split("\\{"));
            if(orderArray1 != null && orderArray1.length > 0){
                //数据转换
            	for(String st:orderArray1){
            		String[] strs1 = st.split("\\[");
            		for(String st1:strs1){
            			String[] strs2 = st1.split("<");
            			Map m = new HashMap();
            			m.put("key", strs2[0]);
            			m.put("name", strs2[1].substring(0, strs2[1].length() - 1));
            			list.add(m);
            		}
            	}
            }
            //封装数据
            Map<String, Object> map = new HashMap<>();
            //map.put("station", station);
            map.put("list", list);

            return ApiResponseResult.success("获取数据成功！").data(map);
        }


        return null;
    }

    /**
     * 根据工号获取信息
     * @param userCode
     * @return
     * @throws Exception
     */
    @Override
    @Transactional
    public ApiResponseResult afterJob(String userCode) throws Exception{
        if(StringUtils.isEmpty(userCode)){
            return ApiResponseResult.failure("工号不能为空!");
        }

        List<String> resultList = this.doPrc(userCode, "Prc_Check_Gonghao");
        System.out.println(resultList);
        
        if(resultList.size() > 0){
            String s = resultList.get(0).substring(0);
            String[] strs = s.split("\\[");
            if(strs.length < 1){
                return ApiResponseResult.failure("返回值的格式不正确：" + resultList);
            }
            //判断取值是否成功
            String str = strs[0];
            if(str.equals("002")){
                return ApiResponseResult.failure("系统错误：" + resultList);
            }
            //获取信息
            String classes = "";
            if(StringUtils.isEmpty(strs[1])){
                return ApiResponseResult.failure("获取数据失败：" + resultList);
            }
            classes = strs[1];

            //封装数据
            Map<String, Object> map = new HashMap<>();
            map.put("classes", classes);//班次

            return ApiResponseResult.success("获取数据成功！").data(map);
        }

        return ApiResponseResult.failure("获取数据失败！");
    }

    /**
     * 根据工单获取信息
     * @param order
     * @return
     * @throws Exception
     */
    @Override
    @Transactional
    public ApiResponseResult afterOrder(String order) throws Exception{
        if(StringUtils.isEmpty(order)){
            return ApiResponseResult.failure("工单不能为空!");
        }

        List<String> resultList = this.doPrc(order, "Prc_Zhijiao_Peifang");
        System.out.println(resultList);

        if(resultList.size() > 0){
            String s = resultList.get(0).substring(0);
            String[] strs = s.split("\\[");
            if(strs.length < 1){
                return ApiResponseResult.failure("返回值的格式不正确：" + resultList);
            }
            //判断取值是否成功
            String str = strs[0];
            if(str.equals("002")){
                return ApiResponseResult.failure("系统错误：" + resultList);
            }
            //获取信息
            String orderNo = "";
            if(StringUtils.isEmpty(strs[1])){
                return ApiResponseResult.failure("获取数据失败：" + resultList);
            }
            String[] tempArray = strs[1].split(",");
            if(tempArray.length > 0){
                orderNo = tempArray[0];
            }

            //封装数据
            Map<String, Object> map = new HashMap<>();
            map.put("orderNo", orderNo);//计划数量(用“，”隔开)

            return ApiResponseResult.success("获取数据成功！").data(map);
        }

        return ApiResponseResult.failure("获取数据失败！");
    }

    /**
     * 根据批量获取信息
     * @param param
     * @return
     * @throws Exception
     */
    @Override
    @Transactional
    public ApiResponseResult afterBatch(String param) throws Exception{
        if(StringUtils.isEmpty(param)){
            return ApiResponseResult.failure("批量不能为空!");
        }

        List<String> resultList = this.doPrc(param, "Prc_Zhijiao_Put");
        System.out.println(resultList);
		
        if(resultList.size() > 0){
            String s = resultList.get(0).toString();//resultList.get(0).substring(0);
            String[] strs = s.split("\\[");
            if(strs.length < 1){
                return ApiResponseResult.failure("返回值的格式不正确：" + resultList);
            }
            //判断取值是否成功
            String str = strs[0];
            if(str.equals("002")){
                return ApiResponseResult.failure("系统错误：" + resultList);
            }
            //封装数据
            Map<String, Object> map = new HashMap<>();
            map.put("remark", strs[1]);

            return ApiResponseResult.success("获取数据成功！").data(map);
        }

        return ApiResponseResult.failure("获取数据失败！");
    }

    /**
     * 删除
     * @param order
     * @return
     * @throws Exception
     */
    @Override
    @Transactional
    public ApiResponseResult delete(String order) throws Exception{
        if(StringUtils.isEmpty(order)){
            return ApiResponseResult.failure("工单不能为空！");
        }

        List<String> resultList = this.doPrc(order, "Prc_Zhijiao_Del");

        if(resultList.size() > 0){
            String s = resultList.get(0).substring(0);
            String[] strs = s.split("\\[");
            if(strs.length < 1){
                return ApiResponseResult.failure("返回值的格式不正确：" + resultList);
            }
            //判断取值是否成功
            String str = strs[0];
            if(str.equals("002")){
                return ApiResponseResult.failure("删除数据失败：" + resultList);
            }

            return ApiResponseResult.success("删除数据成功！");
        }

        return ApiResponseResult.failure("删除数据失败！");
    }

    /**
     * 获取删除列表数据
     * @param device
     * @return
     * @throws Exception
     */
    @Override
    @Transactional
    public ApiResponseResult getDelList(String device) throws Exception{
        if(StringUtils.isEmpty(device)){
            return ApiResponseResult.failure("设备号不能为空!");
        }

        //获取数据
        List<Object> delList = getDelListRf("10000", "1000", device, "App_Zhijiao_Shebei_Select");
        String s2 = delList.get(0).toString();//resultList.get(0).substring(0);
        String[] delStrs = s2.split("\\[");
        if(delStrs.length < 1){
            return ApiResponseResult.failure("返回值的格式不正确：" + s2);
        }
        //判断取值是否成功
        String delStr = delStrs[0];
        if(delStr.equals("002")){
            return ApiResponseResult.failure("系统错误：" + s2);
        }
        //封装数据
        Map<String, Object> map = new HashMap<>();
        map.put("list", delList.get(1));

        return ApiResponseResult.success("获取数据成功！").data(map);
    }

    /**
     * 获取列表
     * @param device
     * @param page
     * @return
     * @throws Exception
     */
    @Override
    public ApiResponseResult getList(String device, int page) throws Exception {
        List<Object> a  = this.getAllListRf("10000", "1000",device,5,page,"App_ZhiJiao_Shebei_Selecthis");
        String s = a.get(0).toString();//resultList.get(0).substring(0);
        String[] strs = s.split("\\[");
        if(strs.length < 1){
            return ApiResponseResult.failure("返回值的格式不正确：" + s);
        }
        //判断取值是否成功
        String str = strs[0];
        if(str.equals("002")){
            return ApiResponseResult.failure("系统错误：" + s);
        }

        return ApiResponseResult.success().data(a.get(1));
    }

    //执行存
    public List<String> doPrc(String param,String prc_name){
        List<String> resultList = (List<String>) jdbcTemplate.execute(new CallableStatementCreator() {
            @Override
            public CallableStatement createCallableStatement(Connection con) throws SQLException {
                String storedProc = "{call "+prc_name+"(?,?)}";// 调用的sql
                CallableStatement cs = con.prepareCall(storedProc);
                cs.setString(1, param);
                cs.registerOutParameter(2,java.sql.Types.VARCHAR);// 注册输出参数 返回类型
                return cs;
            }
        }, new CallableStatementCallback() {
            public Object doInCallableStatement(CallableStatement cs) throws SQLException, DataAccessException {
                List<String> result = new ArrayList<String>();
                cs.execute();
                result.add(getEmpty(cs.getString(2)));
                return result;
            }
        });

        return resultList;
    }
    //值为"null"或者null转换成""
    private String getEmpty(String str){
        if(str == null){
            return "";
        }
        if(StringUtils.equals("null", str)){
            return "";
        }
        return str;
    }
    //去除List数组中为空的元素
    private String[] replaceNull(String[] str){
        //用StringBuffer来存放数组中的非空元素，用“;”分隔
        StringBuffer sb = new StringBuffer();
        for(int i=0; i<str.length; i++) {
            if("".equals(str[i])) {
                continue;
            }
            sb.append(str[i]);
            if(i != str.length - 1) {
                sb.append(";");
            }
        }
        //用String的split方法分割，得到数组
        if(StringUtils.isEmpty(sb)){
            return null;
        }
        str = sb.toString().split(";");
        return str;
    }

    //执行存储获取数据1
    public List<Object> getDelListRf(String factory,String company,String in_str,String prc_name) {
        List<Object> resultList = (List<Object>) jdbcTemplate.execute(new CallableStatementCreator() {
            @Override
            public CallableStatement createCallableStatement(Connection con) throws SQLException {
                String storedProc = "{call "+prc_name+"(?,?,?,?,?,?)}";// 调用的sql
                CallableStatement cs = con.prepareCall(storedProc);
                cs.setString(1, factory);
                cs.setString(2, company);
                cs.setString(3, in_str);
                cs.registerOutParameter(4,java.sql.Types.INTEGER);// 注册输出参数 返回类型
                cs.registerOutParameter(5,java.sql.Types.VARCHAR);// 注册输出参数 返回类型
                cs.registerOutParameter(6,-10);// 注册输出参数 返回类型
                return cs;
            }
        }, new CallableStatementCallback() {
            public Object doInCallableStatement(CallableStatement cs) throws SQLException, DataAccessException {
                List<Object> result = new ArrayList<Object>();
                cs.execute();
                result.add(cs.getString(5));

                String[] strs = cs.getString(5).split("\\[");
                //判断取值是否成功
                String str = strs[0];
                if(str.equals("001")){
                    //游标处理
                    ResultSet rs = (ResultSet)cs.getObject(6);
                    List l = new ArrayList();

                    while(rs.next()){
                        Map m = new HashMap();
                        m.put("MID", rs.getString("MID"));
                        m.put("FPEIFANG", rs.getString("FPEIFANG"));
                        m.put("FPUT_QTY", rs.getString("FPUT_QTY"));
                        m.put("LOT_NO", rs.getString("LOT_NO"));
                        l.add(m);
                    }
                    result.add(l);
                }

                return result;
            }
        });
        return resultList;
    }

    //执行存储获取数据2
    public List<Object> getAllListRf(String factory,String company,String in_str,int page,int size,String prc_name) {
		List<Object> resultList = (List<Object>) jdbcTemplate.execute(new CallableStatementCreator() {
		@Override
		public CallableStatement createCallableStatement(Connection con) throws SQLException {
		String storedProc = "{call "+prc_name+"(?,?,?,?,?,?,?,?)}";// 调用的sql
		CallableStatement cs = con.prepareCall(storedProc);
		cs.setString(1, factory);
		cs.setString(2, company);
        cs.setString(3, in_str);
        cs.setInt(4, page);
        cs.setInt(5, size);
		cs.registerOutParameter(6,java.sql.Types.INTEGER);// 注册输出参数 返回类型
		cs.registerOutParameter(7,java.sql.Types.VARCHAR);// 注册输出参数 返回类型
		cs.registerOutParameter(8,-10);// 注册输出参数 返回类型
		return cs;
		}
		}, new CallableStatementCallback() {
		public Object doInCallableStatement(CallableStatement cs) throws SQLException, DataAccessException {
			List<Object> result = new ArrayList<Object>();
			cs.execute();
			result.add(cs.getString(7));
			
			String[] strs = cs.getString(7).split("\\[");
	        //判断取值是否成功
	        String str = strs[0];
	        if(str.equals("001")){
	        	//游标处理
	    		ResultSet rs = (ResultSet)cs.getObject(8);
	    		List l = new ArrayList();
	
	    		while(rs.next()){
	    			Map m = new HashMap();
                    m.put("MID", rs.getString("MID"));
                    m.put("FPEIFANG", rs.getString("FPEIFANG"));
                    m.put("FPUT_QTY", rs.getString("FPUT_QTY"));
                    m.put("LOT_NO", rs.getString("LOT_NO"));
                    m.put("CREATE_DATE", rs.getString("CREATE_DATE"));
	    			l.add(m);
	    			 }
	    		result.add(l);
	        }
	
			return result;
			}
		});
		return resultList;
		}

}