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.LittleInputService;
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 = "littleInputService")
@Transactional(propagation = Propagation.REQUIRED)
public class LittleInputImpl  implements LittleInputService {

	@Autowired
    private JdbcTemplate jdbcTemplate;
	
    /**
     * 根据设备号获取信息
     * @param deviceNo
     * @return
     * @throws Exception
     */
    @Override
    @Transactional
    public ApiResponseResult afterDevice(String deviceNo) throws Exception {
        if(StringUtils.isEmpty(deviceNo)){
            return ApiResponseResult.failure("设备号不能为空!");
        }
        List<String> resultList = this.doPrc(deviceNo,"Prc_Jiaoban_eq");
        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+"");
            }
            //获取列表
            if(strs.length <1 ){
            	return ApiResponseResult.failure("长度解析发生错误:"+resultList);
            }
            List arr = new ArrayList<>();
            String[] list_strs = strs[1].split("‖");
            for(int i=0;i<list_strs.length-1;i++){
            	String[] map_strs = list_strs[i].split("＠");
            	if(map_strs.length > 1){
            		Map map = new HashMap();
                	map.put("order", map_strs[0]);
                	map.put("qty", map_strs[1]);
                	map.put("pqty", map_strs[2]);
                	arr.add(map);
            	}
            }

            //封装数据
            Map<String, Object> map = new HashMap<>();
            map.put("list", arr);
            if(list_strs.length >0){
            	String[] last = list_strs[list_strs.length-1].split("＠",-1);
            	map.put("station", last[0]);
            	map.put("code", last[1]);
            	map.put("classes", last[2]);
            	map.put("remark", last[3]);
            }

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

        return ApiResponseResult.failure("没有数据！");
    }

    /**
     * 根据设备号获取信息
     * @param barcode
     * @return
     * @throws Exception
     */
    @Override
    @Transactional
    public ApiResponseResult afterBarcoe(String barcode) throws Exception{
    	if(StringUtils.isEmpty(barcode)){
            return ApiResponseResult.failure("物料号不能为空!");
        }
        List<String> resultList = this.doPrc(barcode,"Prc_Zhijiao_Mara");
        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+"");
            }
            return ApiResponseResult.success().data(strs[1]);
        	
        }
        return ApiResponseResult.failure("没有数据！");
    }


    /**
     * 根据工单获取信息
     * @param param
     * @return
     * @throws Exception
     */
    @Override
    @Transactional
    public ApiResponseResult afterQty(String param) throws Exception{
    	//模块名称[字段名[登录帐号[工位[工号[班次[工单号[批量[设备[物料[用量
    	//工单号[批量为空
    	if(StringUtils.isEmpty(param)){
            return ApiResponseResult.failure("数量不能为空!");
        }
        List<String> resultList = this.doPrc(param,"Prc_Zhijiang_Put");
        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+"");
            }
            return ApiResponseResult.success().data(strs[1]);
        }
        
        return ApiResponseResult.failure("没有数据！");
    	
    }

    
	 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;
	    }

	@Override
	public ApiResponseResult getList(String device, int page) throws Exception {
		// TODO Auto-generated method stub
		List<Object> a  = this.getListRf("10000", "1000",device,5,page);
		if(!a.get(0).toString().equals("0")){
			return ApiResponseResult.failure(a.get(1).toString());
		}
		
		return ApiResponseResult.success().data(a.get(2));
	}
	
	public List<Object> getListRf(String factory,String company,String in_str,int page,int size) {
		List<Object> resultList = (List<Object>) jdbcTemplate.execute(new CallableStatementCreator() {
		@Override
		public CallableStatement createCallableStatement(Connection con) throws SQLException {
		String storedProc = "{call app_prc_zhijiang_put(?,?,?,?,?,?,?,?)}";// 调用的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(6));
		result.add(cs.getString(7));
		if(cs.getString(6).toString().endsWith("0")){
			//游标处理
			ResultSet rs = (ResultSet)cs.getObject(8);
			List l = new ArrayList();

			while(rs.next()){
				Map m = new HashMap();	
				m.put("ITEM_BARCODE", rs.getString("ITEM_BARCODE"));
				m.put("ITEM_NO", rs.getString("ITEM_NO"));
				m.put("ITEM_NAME", rs.getString("ITEM_NAME"));
				m.put("ITEM_MODEL", rs.getString("ITEM_MODEL"));
				m.put("QUANTITY", rs.getString("QUANTITY"));
				m.put("ITEM_UNIT", rs.getString("ITEM_UNIT"));
				m.put("CREATE_DATE", rs.getString("CREATE_DATE"));
				m.put("ID", rs.getString("ID"));
				l.add(m);
				 }
			result.add(l);
		}
		

		return result;
		}
		});
		return resultList;

		}

	@Override
	public ApiResponseResult delete(String pid) throws Exception {
		// TODO Auto-generated method stub
		if(StringUtils.isEmpty(pid)){
            return ApiResponseResult.failure("ID不能为空!");
        }
		List<String> a = this.doDeletePrc("10000", "1000", Integer.parseInt(pid));
		if(a.get(0).equals("1")){
			return ApiResponseResult.failure(a.get(1));
		}
		
		return ApiResponseResult.success(a.get(1));
	}
	 public List<String> doDeletePrc(String factory,String company,int pid){
	        List<String> resultList = (List<String>) jdbcTemplate.execute(new CallableStatementCreator() {
	            @Override
	            public CallableStatement createCallableStatement(Connection con) throws SQLException {
	                String storedProc = "{call Prc_Batch_Del_Barcode_peiliao(?,?,?,?,?)}";// 调用的sql
	                CallableStatement cs = con.prepareCall(storedProc);
	                cs.setString(1, factory);
	                cs.setString(2, company);
	                cs.setInt(3, pid);
	                cs.registerOutParameter(4,java.sql.Types.INTEGER);// 注册输出参数 返回类型
	                cs.registerOutParameter(5,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(4));
	                result.add(cs.getString(5));
	                return result;
	            }
	        });

	        return resultList;
	    }


}