package com.system.user.service.internal;

import com.app.base.data.ApiResponseResult;
import com.app.base.data.DataGrid;
import com.app.base.utils.MD5Util;
import com.auth0.jwt.JWT;
import com.system.role.dao.SysRoleDao;
import com.system.role.entity.SysRole;
import com.system.user.dao.SysUserDao;
import com.system.user.dao.UserRoleMapDao;
import com.system.user.entity.SysUser;
import com.system.user.entity.UserRoleMap;
import com.system.user.service.SysUserService;

import com.utils.BaseService;
import com.utils.SearchFilter;
import com.utils.UserUtil;
import com.utils.enumeration.BasicStateEnum;
import org.apache.commons.codec.digest.DigestUtils;
import org.apache.commons.lang3.StringUtils;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.dao.DataAccessException;
import org.springframework.data.domain.Example;
import org.springframework.data.domain.ExampleMatcher;
import org.springframework.data.domain.Page;
import org.springframework.data.domain.PageRequest;
import org.springframework.data.jpa.domain.Specification;
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 javax.persistence.EntityManager;
import javax.persistence.PersistenceContext;
import javax.persistence.Query;
import java.sql.CallableStatement;
import java.sql.Connection;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.util.*;
import java.util.regex.Pattern;

@Service(value = "sysUserService")
@Transactional(propagation = Propagation.REQUIRED)
public class SysUserImpl implements SysUserService {

    @Autowired
    private SysUserDao sysUserDao;
    @Autowired
    private SysRoleDao sysRoleDao;
    @Autowired
    private UserRoleMapDao userRoleMapDao;
    
    @Autowired
    private JdbcTemplate jdbcTemplate;

	@PersistenceContext
	private EntityManager entityManager;
    /**
     * 新增(编辑)用户
     * @param sysUser
     * @return
     * @throws Exception
     */
    @Override
    @Transactional
    public ApiResponseResult add(SysUser sysUser) throws Exception{
    	return ApiResponseResult.success();
/*        if(sysUser == null){
            return ApiResponseResult.failure("用户不能为空！");
        }
        if(StringUtils.isEmpty(sysUser.getBsCode())){
            return ApiResponseResult.failure("用户账号不能为空！");
        }

        //1.新增
        if(sysUser.getId() == null){
            //判断用户账号是否存在，存在则
            SysUser existUser = sysUserDao.findByIsDelAndBsCode(0, sysUser.getBsCode());
            if(existUser != null){
                return ApiResponseResult.failure("该账号已存在！");
            }
            sysUser.setCreatedTime(new Date());
            sysUser.setIsJob(0);
            sysUser.setBsPassword(DigestUtils.md5Hex("654321"));//设置密码
            sysUserDao.save(sysUser);

            // 给用户授角色
            if(StringUtils.isNotEmpty(sysUser.getRoleIds())){
                String[] arrays = sysUser.getRoleIds().split(",");
                for(String roleId : arrays){
                    UserRoleMap urItem = new UserRoleMap();
                    urItem.setCreatedTime(new Date());
                    urItem.setUserId(sysUser.getId());
                    urItem.setRoleId(Long.parseLong(roleId));
                    userRoleMapDao.save(urItem);
                }
            }
            return ApiResponseResult.success("新增成功！");
        }else{
            //1.编辑
            SysUser o = sysUserDao.findById((long) sysUser.getId());
            if(o == null){
                return ApiResponseResult.failure("用户不存在！");
            }
            String originalCode = o.getBsCode();
            if(o.getBsCode().equals(sysUser.getBsCode())){
            }else{
                int count = sysUserDao.countByIsDelAndBsCode(0, sysUser.getBsCode());
                if(count > 0){
                    return ApiResponseResult.failure("用户编号已存在，请填写其他用户编号！");
                }
                o.setBsCode(sysUser.getBsCode().trim());
            }
            o.setModifiedTime(new Date());
            o.setBsName(sysUser.getBsName());
            o.setMobile(sysUser.getMobile());
            o.setEmail(sysUser.getEmail());

            //删除原来的角色权限
            List<UserRoleMap> list = userRoleMapDao.findByIsDelAndUserId(0, o.getId());
            if(list.size() > 0){
                for(UserRoleMap urItem : list){
                    urItem.setModifiedTime(new Date());
                    urItem.setIsDel(1);
                }
                userRoleMapDao.saveAll(list);
            }

            // 给用户授角色权限
            if(StringUtils.isNotEmpty(sysUser.getRoleIds())){
                String[] arrays = sysUser.getRoleIds().split(",");
                for(String roleId : arrays){
                    UserRoleMap urItem = new UserRoleMap();
                    urItem.setCreatedTime(new Date());
                    urItem.setUserId(o.getId());
                    urItem.setRoleId(Long.parseLong(roleId));
                    userRoleMapDao.save(urItem);
                }
            }
            return ApiResponseResult.success("编辑成功！");
        }*/
    }

    /**
     * 编辑用户
     * @param sysUser
     * @return
     * @throws Exception
     */
    @Override
    @Transactional
    public ApiResponseResult edit(SysUser sysUser) throws Exception {
/*        if(sysUser == null || sysUser.getId() == null){
            return ApiResponseResult.failure("用户ID不能为空！");
        }
        SysUser currUser = UserUtil.getSessionUser();
        if(currUser == null || currUser.getId() == null){
            return ApiResponseResult.failure("当前用户不在线，请先登录！");
        }
        //获取当前用户信息
        SysUser o = sysUserDao.findById((long) sysUser.getId());
        if(o == null){
            return ApiResponseResult.failure("当前用户不存在！");
        }
        //提交信息与当前登录用户是否一致
        if(!StringUtils.equals(o.getBsCode(), currUser.getBsCode())){
            return ApiResponseResult.failure("提交信息与当前登录用户不一致，请重新登录！");
        }

        //修改用户信息
        o.setModifiedTime(new Date());
        o.setBsName(sysUser.getBsName());
        o.setMobile(sysUser.getMobile());
        o.setEmail(sysUser.getEmail());
        sysUserDao.save(o);*/

        return ApiResponseResult.success("编辑成功！");
    }

    /**
     * 删除用户
     * @param id
     * @return
     * @throws Exception
     */
    @Override
    @Transactional
    public ApiResponseResult delete(Long id) throws Exception{
        if(id == null){
            return ApiResponseResult.failure("用户ID不能为空！");
        }
/*
        //删除用户
        SysUser o = sysUserDao.findById((long) id);
        o.setModifiedTime(new Date());
        o.setIsDel(1);
        sysUserDao.save(o);

        //删除用户关联角信息
        List<UserRoleMap> list = userRoleMapDao.findByIsDelAndUserId(0, id);
        if(list.size() > 0){
            for(UserRoleMap urItem : list){
                urItem.setModifiedTime(new Date());
                urItem.setIsDel(1);
            }
            userRoleMapDao.saveAll(list);
        }*/

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

    /**
     * 修改密码
     * @param password
     * @param rePassword
     * @return
     * @throws Exception
     */
    @Override
    @Transactional
    public ApiResponseResult changePassword(String oldPassword, String password, String rePassword) throws Exception{
        SysUser sysUser = UserUtil.getSessionUser();
        if(sysUser == null || sysUser.getFid() == null){
            return ApiResponseResult.failure("没有足够的权限修改密码！");
        }
//        if(sysUser == null || sysUser.getId() == null){
//            return ApiResponseResult.failure("没有足够的权限修改密码！");
//        }
        if(StringUtils.isEmpty(oldPassword) || StringUtils.isEmpty(oldPassword.trim())){
            return ApiResponseResult.failure("原密码不能为空！");
        }
        if(StringUtils.isEmpty(password) || StringUtils.isEmpty(password.trim())){
            return ApiResponseResult.failure("新密码不能为空！");
        }
        if(StringUtils.isEmpty(rePassword) || StringUtils.isEmpty(rePassword.trim())){
            return ApiResponseResult.failure("确认新密码不能为空！");
        }
        //判断两次输入的新密码是否一致
        if(!StringUtils.equals(password.trim(), rePassword.trim())){
            return ApiResponseResult.failure("两次输入的新密码不一致！");
        }
        //密码长度校验
        ApiResponseResult result = validate(password.trim());
        if (!result.isResult()) {
            return result;
        }
/*
        //修改用户信息
        SysUser o = sysUserDao.findById((long) sysUser.getId());
        if(o == null){
            return ApiResponseResult.failure("用户不存在！");
        }
        //判断原始密码输入是否正确
        boolean isRight = decryptPassword(oldPassword, o.getBsPassword());
        if(!isRight){
            return ApiResponseResult.failure("原密码输入有误！");
        }
        //修改密码
        o.setModifiedTime(new Date());
        o.setBsPassword(DigestUtils.md5Hex(password.trim()));
        sysUserDao.save(o);*/

        return ApiResponseResult.success("密码修改成功！");
    }
    //判断原始密码输入是否正确
    private boolean decryptPassword(String passwordInput, String password){
        passwordInput = DigestUtils.md5Hex(passwordInput.trim());
        if(password.equals(passwordInput)){
            return true;
        }
        return false;
    }
    //密码长度校验
    private static ApiResponseResult validate(String password) {
        if (StringUtils.isEmpty(password) || StringUtils.isEmpty(password.trim())) {
            return ApiResponseResult.failure("密码不能为空");
        }
        if (password.length() < 6 || password.length() > 16) {
            return ApiResponseResult.failure("密码长度应在6~16位").data(-1);
        }

        return ApiResponseResult.success();
    }

    /**
     *
     * @return
     * @throws Exception
     */
    @Override
    @Transactional
    public ApiResponseResult getUserInfo() throws Exception{
        /*SysUser sysUser = UserUtil.getSessionUser();
        if(sysUser == null || sysUser.getId() == null){
            return ApiResponseResult.failure("当前用户不在线，请先登录！");
        }
        //获取当前用户信息
        SysUser o = sysUserDao.findById((long) sysUser.getId());
        if(o == null){
            return ApiResponseResult.failure("用户不存在！");
        }*/
        Map<String, Object> map = new HashMap<>();
       /* map.put("id", o.getId());
        map.put("bsCode", o.getBsCode());
        map.put("bsName", o.getBsName());
        map.put("mobile", o.getMobile());
        map.put("email", o.getEmail());
        map.put("isJob", o.getIsJob());*/

        return ApiResponseResult.success().data(map);
    }

	@Override
	public ApiResponseResult getUserInfo(String token) throws Exception {
        return ApiResponseResult.success("登录成功！");
	}

    /**
     * 获取用户列表
     * @param keyword
     * @param userName
     * @param mobile
     * @param createdTimeStart
     * @param createdTimeEnd
     * @param pageRequest
     * @return
     * @throws Exception
     */
	@Override
    @Transactional
	public ApiResponseResult getList(String keyword, String userName, String mobile, Date createdTimeStart, Date createdTimeEnd, PageRequest pageRequest) throws Exception {
        //查询条件1
	    List<SearchFilter> filters =new ArrayList<>();
        filters.add(new SearchFilter("isDel", SearchFilter.Operator.EQ, BasicStateEnum.FALSE.intValue()));
        if(StringUtils.isNotEmpty(userName)){
            filters.add(new SearchFilter("bsCode", SearchFilter.Operator.LIKE, userName));
        }
        if(StringUtils.isNotEmpty(mobile)){
            filters.add(new SearchFilter("mobile", SearchFilter.Operator.LIKE, mobile));
        }
        if(createdTimeStart != null){
            filters.add(new SearchFilter("createdTime", SearchFilter.Operator.GTE, createdTimeStart));
        }
        if(createdTimeEnd != null){
            filters.add(new SearchFilter("createdTime", SearchFilter.Operator.LTE, createdTimeEnd));
        }
        //查询2
        List<SearchFilter> filters1 =new ArrayList<>();
        if(StringUtils.isNotEmpty(keyword)){
            filters1.add(new SearchFilter("bsCode", SearchFilter.Operator.LIKE, keyword));
            filters1.add(new SearchFilter("mobile", SearchFilter.Operator.LIKE, keyword));
        }
        Specification<SysUser> spec = Specification.where(BaseService.and(filters, SysUser.class));
        Specification<SysUser> spec1 =  spec.and(BaseService.or(filters1, SysUser.class));
        Page<SysUser> page = sysUserDao.findAll(spec1, pageRequest);
        return ApiResponseResult.success().data(DataGrid.create(page.getContent(), (int) page.getTotalElements(), pageRequest.getPageNumber() + 1, pageRequest.getPageSize()));
	}

    /**
     * 根据ID获取用户信息
     * @param id
     * @return
     * @throws Exception
     */
    @Override
    @Transactional
    public ApiResponseResult getUserAndRoles(Long id) throws Exception{
    	return ApiResponseResult.success();
       /* if(id == null){
            return ApiResponseResult.failure("用户ID不能为空！");
        }
        SysUser sysUser = sysUserDao.findById((long) id);
        if(sysUser == null){
            return ApiResponseResult.failure("用户不存在！");
        }
        //获取当前用户关联角色信息
        List<UserRoleMap> list = userRoleMapDao.findByIsDelAndUserId(0, id);

        //获取所有角色信息
        List<ApiCode> list2 = sysRoleDao.findByIsDel(0);

        Map<String, Object> mapUser = new HashMap<>();
        mapUser.put("id",sysUser.getId());
        mapUser.put("version", sysUser.getVersion());
        mapUser.put("bsCode",sysUser.getBsCode());
        mapUser.put("bsName",sysUser.getBsName());
        mapUser.put("mobile",sysUser.getMobile());
        mapUser.put("email",sysUser.getEmail());
        mapUser.put("del",sysUser.getIsDel());
        mapUser.put("job",sysUser.getIsJob());
        mapUser.put("userRoles", list);

        //封装数据
        Map<String, Object> map = new HashMap<>();
        map.put("roles", list2);
        map.put("user", mapUser);

        return ApiResponseResult.success().data(map);*/
    }

    /**
     * 设置在职/离职
     * @param id
     * @param isJob
     * @return
     * @throws Exception
     */
    @Override
    @Transactional
    public ApiResponseResult doJob(Long id, Integer isJob) throws Exception{
    	return ApiResponseResult.failure();
        /*if(id == null){
            return ApiResponseResult.failure("用户ID不能为空！");
        }
        if(isJob == null){
            return ApiResponseResult.failure("请正确设置在职或离职！");
        }
        SysUser o = sysUserDao.findById((long) id);
        if(o == null){
            return ApiResponseResult.failure("用户不存在！");
        }

        o.setModifiedTime(new Date());
        o.setIsJob(isJob);
        sysUserDao.save(o);

        return ApiResponseResult.success("设置成功！").data(o);*/
    }
    
    

    /**
     * 修改密码
     * @param loginName
     * @param password
     * @param rePassword
     * @return
     * @throws Exception
     */
    @Override
    @Transactional
    public ApiResponseResult changePassword(String loginName, String oldPassword, String password, String rePassword) throws Exception{
        //验证，原密码和新密码都不能为空，并且原密码要求输入正确，新密码和确认密码一致
/*        if(StringUtils.isEmpty(loginName)){
            return ApiResponseResult.failure("登录名不能为空！");
        }
        if(StringUtils.isEmpty(oldPassword)){
            return ApiResponseResult.failure("原密码不能为空！");
        }
        if(StringUtils.isEmpty(password) || StringUtils.isEmpty(rePassword)){
            return ApiResponseResult.failure("密码不能为空！");
        }
        SysUser o = sysUserDao.findByIsDelAndUserCode(BasicStateEnum.FALSE.intValue(), loginName);
        if(o == null){
            return ApiResponseResult.failure("该用户不存在或已删除！");
        }
        if(!o.getUserPassword().equals(MD5Util.MD5(oldPassword))){
            return ApiResponseResult.failure("原密码输入错误！");
        }
        if(!password.equals(rePassword)){
            return ApiResponseResult.failure("密码不一致，请确认！");
        }

        //1.修改用户密码
        //admin和super为管理员用户，无法操作
        if("admin".equals(o.getUserCode().trim()) || "super".equals(o.getUserCode().trim())){
            return ApiResponseResult.failure("此用户名为管理员用户，无法修改密码！");
        }

        SysUser currUser = UserUtil.getCurrUser();  //获取当前用户
        o.setUserPassword(MD5Util.MD5(password));
        o.setModifiedTime(new Date());
        o.setPkModifiedBy((currUser!=null) ? (currUser.getId()) : null);
        sysUserDao.save(o);
*/

        return ApiResponseResult.success("密码修改成功！");
    }

    /**
     * 重置密码（管理员修改密码使用）
     * @param id
     * @param password
     * @param rePassword
     * @return
     * @throws Exception
     */
    @Override
    @Transactional
    public ApiResponseResult resetPassword(Long id, String password, String rePassword) throws Exception{
        //验证，新密码不能为空，并且要求新密码和确认密码一致
        if(id == null){
            return ApiResponseResult.failure("记录ID不能为空！");
        }
        if(StringUtils.isEmpty(password) || StringUtils.isEmpty(rePassword)){
            return ApiResponseResult.failure("密码不能为空！");
        }
        if(!password.equals(rePassword)){
            return ApiResponseResult.failure("密码不一致，请确认！");
        }
//        List<SysUser> sysUserList = sysUserDao.findById((long) id);
        List<SysUser> sysUserList = sysUserDao.findByFid(id.toString());
        if(sysUserList == null || sysUserList.size() == 0){
            return ApiResponseResult.failure("该用户不存在或已删除！");
        }
        SysUser o = sysUserList.get(0);
        if(o == null){
            return ApiResponseResult.failure("该用户不存在或已删除！");
        }

        //1.修改用户密码
        //admin和super为管理员用户，无法操作
//        if("admin".equals(o.getUserCode().trim()) || "super".equals(o.getUserCode().trim())){
//            return ApiResponseResult.failure("此用户名为管理员用户，无法修改密码！");
//        }
//
//        SysUser currUser = UserUtil.getCurrUser();  //获取当前用户
//        o.setUserPassword(MD5Util.MD5(password));
//        o.setModifiedTime(new Date());
//        o.setPkModifiedBy((currUser!=null) ? (currUser.getId()) : null);
//        sysUserDao.save(o);


        return ApiResponseResult.success("密码重置成功！");
    }


	@Override
	public List<Map<String, Object>> findByUserCode(String userCode) throws Exception {
		// TODO Auto-generated method stub
		String sql = "select s.fcode,s.fname,s.fpassword,s.fcompany,s.ffactory from sys_user s where  upper(s.fcode) ='"
				+ userCode.toUpperCase() +  "'";
        List<Map<String, Object>> countList = sysUserDao.findByUserCode(userCode.toUpperCase());//this.findBySql(sql, SQLParameter.newInstance(), null);
		return countList;
       //return sysUserDao.findByIsDelAndUserCode(0, userCode);
	}

    /**
     * 获取用户列表
     * @param usercode
     * @param username
     * @param pageRequest
     * @return
     * @throws Exception
     */
	@Override
    @Transactional
	public ApiResponseResult getlist(String usercode,String username,PageRequest pageRequest) throws Exception {
		// TODO Auto-generated method stub
		/*Sort sort = new Sort(Sort.Direction.DESC, "id");
        List<SysUser> list = sysUserDao.findAll(sort);*/
        return ApiResponseResult.success();
		/*SysUser demoBean = new SysUser();
		demoBean.setUserIsSuper(0);   //查询条件（0为普通用户，1为超级管理员，只显示普通用户）
		if(!StringUtils.isEmpty(usercode)){
			demoBean.setUserCode(usercode); //查询条件
		}
		if(!StringUtils.isEmpty(username)){
			demoBean.setUserName(username); //查询条件
		}

		//创建匹配器
        ExampleMatcher matcher = ExampleMatcher.matching()
                .withMatcher("userCode", ExampleMatcher.GenericPropertyMatchers.contains())
                .withMatcher("userName", ExampleMatcher.GenericPropertyMatchers.contains())
                .withIgnorePaths("userType", "userStatus");
        //创建查询参数
        Example<SysUser> example = Example.of(demoBean, matcher);
		//获取排序对象
		Sort sort = new Sort(Sort.Direction.DESC, "id");
		//创建分页对象
		PageRequest pageRequest = new PageRequest(0, 10, sort);
		//分页查询
		//List<SysUser> list  = sysUserDao.findAll(example, pageRequest).getContent();
		Page<SysUser> page = sysUserDao.findAll(example, pageRequest);
 
        return ApiResponseResult.success().data(DataGrid.create(page.getContent(), (int) page.getTotalElements(), pageRequest.getPageNumber() + 1, pageRequest.getPageSize()));
	*/
	}


	@Override
	public List<Map<String, Object>> queryVersion() throws Exception {
		// TODO Auto-generated method stub
		/*String sql = "select s.PARAM_VALUE from mes_sys_params s where s.PARAM_NAME='RF版本'";
        List<Map<String, Object>> countList = this.findBySql(sql, SQLParameter.newInstance(), null);
		return countList;*/
		return null;
	}
	@Override
	public List<Map<String, Object>> queryRunEnv() throws Exception {
		// TODO Auto-generated method stub
		/*String sql = "select s.PARAM_VALUE from mes_sys_params s where s.PARAM_NAME='运行环境'";
        List<Map<String, Object>> countList = this.findBySql(sql, SQLParameter.newInstance(), null);
		return countList;*/
		return null;
	}
	@Override
	public List queryPurview(String userno) throws Exception {
		// TODO Auto-generated method stub
		
//		 StoredProcedureQuery storedProcedureQuery = this.entityManager.createNamedStoredProcedureQuery("getContactsLikeName");
//	       storedProcedureQuery.setParameter("c_User_No", "ADMIN");
//	       storedProcedureQuery.setParameter("c_MachType", "WCE");
//	       storedProcedureQuery.execute();
//	       System.out.println(storedProcedureQuery.execute());
	       
//		Integer a = sysUserDao.createPolicy(1);
//		System.out.println(a);
		
//		Query query = entityManager.createNativeQuery("{call Prc_rf_j1_user_login(?,?,?)}");
//		query.setParameter(1, "ADMIN");
//		query.setParameter(2, "WCE");
//		query.setParameter(3, "");
//		String result = query.getSingleResult().toString();
		
		List<String> a = this.doPurview(userno);
		List arr = new ArrayList<>();
		if(a.size() > 0){
			String str = a.get(0);
			String[] strs = str.split("\\[");
			if(strs.length > 2){
				for(int i=2;i<strs.length;i++){
					String str2 = strs[i].trim();//20200423-fyx-去掉空格
					String[] s = str2.split("#");
					arr.add(s);
				}
			}
		}
		String[] tc = "退出#tuichu".split("#");
		arr.add(tc);
		return arr;
	}

	public List<String> doPurview(String userno) {
		List<String> resultList = (List<String>) jdbcTemplate.execute(new CallableStatementCreator() {
		@Override
		public CallableStatement createCallableStatement(Connection con) throws SQLException {
		String storedProc = "{call Prc_rf_j1_user_login(?,?,?)}";// 调用的sql
		CallableStatement cs = con.prepareCall(storedProc);
		cs.setString(1, userno.toUpperCase());
		cs.setString(2, "AN");
		cs.registerOutParameter(3,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(3));
		return result;
		}
		});


		return resultList;

		}


	@Override
	public ApiResponseResult getRfSetup(String functionName) throws Exception {
		// TODO Auto-generated method stub
		List<String> a = this.doRfSetup(functionName);
//		[001
//		 [FILED4#进货仓库#VARCHAR2#0#3#60#245#N##1##0##0#23
//		 [FILED2#加急#VARCHAR2#0#1#60#245#N##1##0##0#23
//		 [FILED3#卡板号#VARCHAR2#1#3#60#245#N##1#FILED5#0#999999#0#23
//		 [FILED5#物料条码#VARCHAR2#0#3#60#245#P#{FILED4,FILED3,FILED5,FILED1,FILED2}{FILED1,FILED6,FILED7,INFO}#0##0##0#23
//		 [FILED1#采购单号#VARCHAR2#1#3#60#245#P#{FILED1}{FILED4,FILED3}#1#FILED5#0##0#23
//		 [FILED6#物料编码#VARCHAR2#1#3#60#245#N##1##0##0#23
//		 [FILED7#进货数量#VARCHAR2#1#3#60#245#N##1##0###23
//		 [INFO#提示信息#MEMO#1#3#60#245#N##1##0###100]
		if(a.size()>0){
			String s = a.get(0).substring(0);
			String[] strs = s.split("\\[");
			if(strs.length<1){
				return ApiResponseResult.failure("返回值的格式不正确!"+a);
			}
			//判断取值是否成功
			String str = strs[0];
			if(str.equals("002")){
				return ApiResponseResult.failure("取值发生错误!"+a);
			}
			//拼接字符串
			
			List<String> list = Arrays.asList(strs);
			List arr = new ArrayList<>();
			for(int i=1;i<list.size();i++){
				String[] s1 = list.get(i).split("#");
				arr.add(s1);
			}
			return ApiResponseResult.success("功能界面成功！").data(arr);
		}else{
			return ApiResponseResult.failure("取值为空，请检测输入的参数是否正确!");
		}
		
		//return ApiResponseResult.success("功能界面成功！").data(arr);
	}
	public List<String> doRfSetup(String functionName) {
		List<String> resultList = (List<String>) jdbcTemplate.execute(new CallableStatementCreator() {
		@Override
		public CallableStatement createCallableStatement(Connection con) throws SQLException {
		String storedProc = "{call Prc_rf_setup(?,?,?)}";// 调用的sql
		CallableStatement cs = con.prepareCall(storedProc);
		cs.setString(1, functionName);
		cs.setString(2, "AN");
		cs.registerOutParameter(3,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(3));
		return result;
		}
		});


		return resultList;

		}


	@Override
	public ApiResponseResult queryAppVersion() throws Exception {
		// TODO Auto-generated method stub 
		Map m = new HashMap();
		 List<Map<String, Object>> l = sysUserDao.queryAppVersion();
		 if(l.size() > 0){
			 m.put("Version", l.get(0).get("PV"));
		 }else{
			 return ApiResponseResult.failure("未设置更新版本");
		 }
		 
		 l = sysUserDao.queryApkUrl();
		 if(l.size() > 0){
			 m.put("Url", l.get(0).get("PV"));
		 }else{
			 return ApiResponseResult.failure("未设置更新版本的下载地址");
		 }
		 
		 l = sysUserDao.queryAppSize();
		 if(l.size() > 0){
			 m.put("Size", l.get(0).get("PV"));
		 }else{
			 m.put("Size", 0);
		 }
		
		return ApiResponseResult.success().data(m);
	}


	@Override
	public ApiResponseResult changPsw(String userCode, String newp) throws Exception {
		// TODO Auto-generated method stub
		sysUserDao.updatePwsByUserCode(userCode, newp);
		return ApiResponseResult.success();
	}


	@Override
	public ApiResponseResult getExcProc(String functionName, String fileName, String pmachtype, String fileValue, String outFiles)
			throws Exception {
		// TODO Auto-generated method stub
		//[001[4500108372,80000123,100,物料80000123今日已收货 100]

//		List<String[]> a = new ArrayList<String[]>();
//		String str = "4500108372,80000123,100,物料80000123今日已收货 100]";
//		str = str.substring(0,str.length() - 1);
//		String[] files = outFiles.split(",");
//		String[] res = str.split(",");
//		for(int i=0;i<files.length;i++){
//			String[] temp = new String[2];
//			temp[0] = files[i];
//			temp[1] = res[i];
//			//m.put(files[i], res[i]);
//			a.add(temp);
//		}
//		return ApiResponseResult.success().data(a);
		List<String> a = this.doExcProc(functionName,fileName,pmachtype,fileValue);
		System.out.println(a);
		if(a.size()>0){
			String s = a.get(0).substring(0);
			String[] strs = s.split("\\[");
			if(strs.length<1){
				return ApiResponseResult.failure("返回值的格式不正确!"+a);
			}
			//判断取值是否成功
			String str = strs[0];
			if(str.equals("002")){
				return ApiResponseResult.failure(strs[1]);
			}else{
				if(StringUtils.isEmpty(outFiles)){
					if(strs.length < 2){
						return ApiResponseResult.success().data("");
					}
					return ApiResponseResult.success().data(strs[1]);
				}else{
					List<String[]> at = new ArrayList<String[]>();
					//[001[4500108372,80000123,100,物料80000123今日已收货 100]
					String[] files = outFiles.split(",");
					String[] res = strs[1].split(",", -1);
					for(int i=0;i<files.length;i++){
						String[] temp = new String[2];
						temp[0] = files[i];
						temp[1] = res[i];
						//m.put(files[i], res[i]);
						at.add(temp);
					}
					return ApiResponseResult.success().data(at);
				}
				
			}
			
		}
		return ApiResponseResult.success().data(a);
	}

	public List<String> doExcProc(String functionName, String fileName, String pmachtype, String fileValue) {
		List<String> resultList = (List<String>) jdbcTemplate.execute(new CallableStatementCreator() {
		@Override
		public CallableStatement createCallableStatement(Connection con) throws SQLException {
		String storedProc = "{call  Prc_rf_setup_ExcProc(?,?,?,?,?)}";// 调用的sql
		CallableStatement cs = con.prepareCall(storedProc);
		cs.setString(1, functionName);//功能名称
		cs.setString(2, fileName.trim());//字段名
		cs.setString(3,"AN");//设备类型 wince5,wmb5,wmb6
		cs.setString(4, fileValue);//参数值[第一位是用户]
		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(5));
		return result;
		}
		});


		return resultList;

		}

	@Override
	public SysUser findByUserCode2(String userCode) throws Exception {
		// TODO Auto-generated method stub
		return null;
	}


	@Override
	public ApiResponseResult getPrintInfo(List<String> list) throws Exception {
		return ApiResponseResult.success().data(sysUserDao.findPrintInfo(list));
	}

	//执行pda前端注入的sql语句
	public ApiResponseResult getExcuteSql(String str)throws Exception {
		try {
			String regex=".*INSERT.*DELETE.*UPDATE.*DROP.*TRUNCATE.*";
			if(!str.matches(regex)){//SQL不允许含上述五个关键字
				Query nativeQuery=entityManager.createNativeQuery(str);
				List resultList =nativeQuery.getResultList();
				return ApiResponseResult.success().data(resultList);
			}
			return ApiResponseResult.failure("错误:"+str+"含除SELECT外的关键字");

		} catch (Exception e) {
			System.out.println(e.toString());
			return ApiResponseResult.failure(e.toString());
		}
	}

	@Override
	public ApiResponseResult getCursor(String functionName, String fileName, String pmachtype, String fileValue, String outFiles) throws SQLException {
		List<String> resultList = this.handleProc(functionName,fileName,pmachtype,fileValue);
		if(resultList != null && resultList.size() > 0){
			return ApiResponseResult.success().data(resultList);
		}
		return ApiResponseResult.failure("获取列表失败！");
	}

	private List<String> handleProc(String functionName, String fileName, String pmachtype, String fileValue) throws SQLException{
		List<String> resultList = (List<String>) jdbcTemplate.execute(new CallableStatementCreator() {
			@Override
			public CallableStatement createCallableStatement(Connection con) throws SQLException {
				String storedProc = "{call  Prc_Rf_Setup_Handleproc(?,?,?,?,?,?,?)}";// 调用的sql
				CallableStatement cs = con.prepareCall(storedProc);
				cs.setString(1, functionName);//功能名称
				cs.setString(2, fileName.trim());//字段名
				cs.setString(3,"AN");//设备类型 wince5,wmb5,wmb6
				cs.setString(4, fileValue);//参数值[第一位是用户]
				cs.registerOutParameter(5, java.sql.Types.INTEGER);// 输出参数 返回标识-标识
				cs.registerOutParameter(6, java.sql.Types.VARCHAR);// 输出参数 返回标识
				cs.registerOutParameter(7,-10);// 注册输出参数 返回类型
				return cs;
			}
		}, new CallableStatementCallback() {
			public Object doInCallableStatement(CallableStatement cs) throws SQLException, DataAccessException {
				List<Object> result = new ArrayList<>();
				List<Map<String, Object>> l = new ArrayList();
				List<String> cols = new ArrayList();
				List<Map<String, Object>> l2 = new ArrayList();
				List<Object> cols2 = new ArrayList();
				cs.execute();
				result.add(cs.getInt(5));
				result.add(cs.getString(6));
				if (cs.getString(5).toString().equals("0")) {
					// 游标处理
					ResultSet rs = (ResultSet) cs.getObject(7);
					System.out.println(rs);
//					ResultSet resultSet = (ResultSet) cs.getObject(4);
//					System.out.println(resultSet);
					try {
						l = fitMap(rs);
						cols=fitMapCols(rs);

//						l2 = fitMap(resultSet);
//						cols2=fitMapCols(resultSet);
					} catch (Exception e) {
						e.printStackTrace();
					}
					result.add(l);
					result.add(cols);
//					result.add(l2);
//					result.add(cols2);
				}
				System.out.println(l);
//				System.out.println(l2);
				return result;
			}
		});
		return resultList;
	}

	private List<Map<String, Object>> fitMap(ResultSet rs) throws Exception {
		List<Map<String, Object>> list = new ArrayList<>();
		if (null != rs) {
			Map<String, Object> map;
			int colNum = rs.getMetaData().getColumnCount();
			List<String> columnNames =fitMapCols(rs);

			while (rs.next()) {
				map = new LinkedHashMap<>();
				for (String columnName : columnNames) {
					map.put(columnName, rs.getString(columnName));
				}
				list.add(map);
			}
		}
		return list;
	}

	/**
	 * lst 只返回列名
	 **/
	private List<String> fitMapCols(ResultSet rs) throws Exception {
		List<String> list = new ArrayList<>();
		if (null != rs) {
			int colNum = rs.getMetaData().getColumnCount();
			List<String> columnNames = new ArrayList<String>();
			for (int i = 1; i <= colNum; i++) {
				columnNames.add(rs.getMetaData().getColumnName(i));
			}
			list = columnNames;
		}
		return list;
	}
}