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

import com.app.base.data.ApiResponseResult;
import com.web.pda.gltPda_wdPda.service.CreateService;
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 java.sql.CallableStatement;
import java.sql.Connection;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.util.*;

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

    @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<String> resultList = this.doPrc(device, "prc_eq_getproc");
        List<Object> a  = this.getListRf("10000", "1000",device,"App_Peiliao_Shebei_Select");
		
        if(true){
        	//001[M-FA-PE-515,ZJ002-1,TL0001{
            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);
            }
            //封装数据
            Map<String, Object> map = new HashMap<>();
            //map.put("list", a.get(1));
            //20200424-fyx
            String[] strs_1 = strs[1].split(",",-1);
            if(strs_1.length>=2){
            	map.put("station", strs_1[1]);
            }else{
            	map.put("station", "");
            }
            if(strs_1.length>=3){
            	String[] list_strs = strs_1[2].split("\\{");
            	map.put("order", list_strs);
            }else{
            	map.put("order", "");
            }
            
            return ApiResponseResult.success("获取数据成功！").data(map);
        }

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

    /**
     * 根据工位获取信息
     * @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");

        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[1015-15,{ZBK2014042103-2
            //String station = "";
            List<String> 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);
            }
            if(orderArray.length < 2){
                //station = orderArray[0];
            }else{
                //station = orderArray[0];
                String[] orderArray1 = replaceNull(orderArray[1].split("\\{"));
                if(orderArray1 != null && orderArray1.length > 0){
                    //数据转换
                    list = Arrays.asList(orderArray1);
                }
            }

            //封装数据
            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");
        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_Col_Tl01");

        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 planQty = "";
            if(StringUtils.isEmpty(strs[1])){
                return ApiResponseResult.failure("获取数据失败：" + resultList);
            }
            String[] tempArray = strs[1].split(",");
            if(tempArray.length > 0){
                planQty = tempArray[0];
            }

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

            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<Object> a  = this.getListRf("10000", "1000",param,"App_Peiliao_Jiaoban_Add");
		
        if(true){
            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);
            }
            //封装数据
            Map<String, Object> map = new HashMap<>();
            map.put("list", a.get(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_Jiaoban_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("删除数据失败！");
    }
    @Override
	public ApiResponseResult getList(String device, int page) throws Exception {
		// TODO Auto-generated method stub
		List<Object> a  = this.getAllListRf("10000", "1000",device,5,page,"app_peiliao_shebei_selecthis");
		/*if(!a.get(0).toString().equals("0")){
			return ApiResponseResult.failure(a.get(1).toString());
		}*/
		 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(cs.getString(2));
                return result;
            }
        });

        return resultList;
    }
    //去除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;
    }
    
  //执行存储获取数据
    public List<Object> getListRf(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("ID", rs.getString("ID"));
	    			m.put("TASK_NO", rs.getString("TASK_NO"));
	    			m.put("PLAN_QTY", rs.getString("PLAN_QTY"));
	    			m.put("FPUT_QTY", rs.getString("FPUT_QTY"));
	    			l.add(m);
	    			 }
	    		result.add(l);
	        }
	
			return result;
			}
		});
		return resultList;
		}
    
  //执行存储获取数据
    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("ID", rs.getString("ID"));
	    			m.put("TASK_NO", rs.getString("TASK_NO"));
	    			m.put("PLAN_QTY", rs.getString("PLAN_QTY"));
	    			m.put("FPUT_QTY", rs.getString("FPUT_QTY"));
	    			m.put("CREATE_DATE", rs.getString("CREATE_DATE"));
	    			m.put("CREATE_BY", rs.getString("CREATE_BY"));
	    			l.add(m);
	    			 }
	    		result.add(l);
	        }
	
			return result;
			}
		});
		return resultList;
		}

}