package com.changhong.epc.zuul.service.impl;

import com.changhong.epc.constter.base.BaseConst;
import com.changhong.epc.constter.exception.EPCServiceException;
import com.changhong.epc.constter.system.UserInfo;
import com.changhong.epc.constter.system.UserInfo.LogInInfo;
import com.changhong.epc.constter.system.prop.ChangHongProperties;
import com.changhong.epc.constter.system.prop.ChangHongProperties.PassPortName;
import com.changhong.epc.rely.api.service.CscApiService;
import com.changhong.epc.rely.api.tool.CscAesUtils;
import com.changhong.epc.zuul.service.LoginService;
import com.changhong.epc.zuul.util.HttpUtil;
import com.iemsoft.framework.cloud.core.password.Des;
import com.iemsoft.framework.cloud.core.thread.ThreadData;
import com.iemsoft.framework.cloud.core.tools.Assert;
import com.iemsoft.framework.cloud.core.tools.JSONTool;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.beans.factory.annotation.Value;
import org.springframework.stereotype.Service;
import org.springframework.ui.ModelMap;

import javax.annotation.Resource;
import java.util.HashMap;
import java.util.Map;
import java.util.Objects;
import java.util.concurrent.TimeoutException;

//import com.changhong.ubp.login.service.CscApiService;

@Service("loginService")
public class LoginServiceImpl implements LoginService, BaseConst {

	@Resource
	private CscApiService cscApiService;

	@Value("${aes.key:0123456789ABCDEF}")
	private String aesKey;
	
//	@Autowired
//	private RedisTemplate<String, Object> redisTemplate;
	
	private static final Map<String, UserInfo> USER_INFOS = new HashMap<>();
	
	private static String infoId=ThreadData.get(TENANT_ID)+"_"+ThreadData.get(COMPANY_ID)+"_"+ThreadData.get(SERVICE_ID)+"_"+"ubp";
	
	/**
	 * 获得用户信息类
	 */
	@Autowired
	private UserInfoServiceImpl userInfoService;
	

	@Override
	public UserInfo getUserInfo(LogInInfo loginInfo) {
		if(Objects.equals(loginInfo.getOpenId(),"test")){
			return JSONTool.toObj("{\"birthday\":\"2016-02-02\",\"bpsUserName\":\"76_13_17_1_ubp\",\"changeTimes\":\"1\",\"city\":\"石家庄市\",\"county\":\"市辖区\",\"emailVerified\":\"0\",\"interests\":\"\",\"ipAddress\":\"54.222.240.185\",\"isSuperManager\":true,\"loginInfo\":{\"openId\":\"893ccd52f0ec4eae\",\"token\":\"0e704547f54583ad430fe09f83e4b524\"},\"loginTime\":\"2017-11-23 13:23:26\",\"passwordStrength\":\"1\",\"phone\":\"15140615455\",\"pkgName\":\"http://chweb.changhong.com\",\"province\":\"河北省\",\"registerTime\":\"2017-05-16 14:28:14\",\"sex\":\"男\",\"uid\":\"\",\"updateTime\":\"2017-10-24 19:51:20\",\"userCode\":\"893ccd52f0ec4eae\",\"userName\":\"王煜鑫\",\"workFlowCode\":\"D1B67990431B7788CF09CECBC3B938B6\"}", UserInfo.class);
		}
		ThreadData.set(OPEN_ID, loginInfo.getOpenId());
//		String token=redisTemplate.opsForValue().get(loginInfo.getOpenId()).toString();
//		if(!Objects.equals(token, loginInfo.getToken())){
//			//Assert.empty(null, N0001);
//		  throw new EPCServiceException(N0001, N0001);
//		}
		
		return userInfoService.getUserInfo(loginInfo);
	}

	@Override
	public UserInfo getUserInfo(String token) {
		return getUserInfo(getLoginInfo(token));
	}

	@Override
	public UserInfo getUserInfo(LoginSecurity loginSecurity) {
		if(Objects.equals(loginSecurity.getOpenId(),"test")){
			return JSONTool.toObj("{\"birthday\":\"2016-02-02\",\"bpsUserName\":\"76_13_17_1_ubp\",\"changeTimes\":\"1\",\"city\":\"石家庄市\",\"county\":\"市辖区\",\"emailVerified\":\"0\",\"interests\":\"\",\"ipAddress\":\"54.222.240.185\",\"isSuperManager\":true,\"loginInfo\":{\"openId\":\"893ccd52f0ec4eae\",\"token\":\"0e704547f54583ad430fe09f83e4b524\"},\"loginTime\":\"2017-11-23 13:23:26\",\"passwordStrength\":\"1\",\"phone\":\"15140615455\",\"pkgName\":\"http://chweb.changhong.com\",\"province\":\"河北省\",\"registerTime\":\"2017-05-16 14:28:14\",\"sex\":\"男\",\"uid\":\"\",\"updateTime\":\"2017-10-24 19:51:20\",\"userCode\":\"893ccd52f0ec4eae\",\"userName\":\"王煜鑫\",\"workFlowCode\":\"D1B67990431B7788CF09CECBC3B938B6\"}", UserInfo.class);		
			}
		return getUserInfo(new LogInInfo(loginSecurity.getToken(), loginSecurity.getOpenId()));
	}
	
	@Override
	public LogInInfo getLoginInfo(String token) {
		LogInInfo loginInfo = JSONTool.toObj(
				new Des().strEnc(token, UserInfo.FIRST_KEY, UserInfo.SECOND_KEY, UserInfo.THIRD_KEY), LogInInfo.class);
		Assert.empty(loginInfo, U0002);
		return loginInfo;
	}

	@Service
	public class UserInfoServiceImpl{

		@Autowired
		private ChangHongProperties changHongProperties;
		
		/**
		 * 获得userInfo
		 * @param loginInfo
		 * @return
		 */
	//	@CacheSave(time=1 * 60 * 60 * 24)
		public UserInfo getUserInfo(LogInInfo loginInfo){
			// System.out.println(">>>>>"+loginInfo);
			UserInfo userInfo = null;
			try {
						userInfo = HttpUtil.get(
						changHongProperties.getPassUrl(PassPortName.USER_DETIAL
									, new ModelMap("token", loginInfo.getToken())
									.addAttribute("openId", loginInfo.getOpenId())
									.addAttribute("livemode", changHongProperties.getSsoLivemode()))
						, null, UserInfo.class);
			} catch (TimeoutException e) {
				throw new EPCServiceException(N0002).setchildIEMExc(changHongProperties.getPassUrl(PassPortName.USER_DETIAL, null));
			}
			Assert.empty(userInfo, N0001);
			userInfo.setLoginInfo(loginInfo);
			userInfo.setAesOpenId(CscAesUtils.encrypt(userInfo.getLoginInfo().getOpenId(), aesKey));
			//setEmpInfo(userInfo); 
			return userInfo;
		}
		/*
			18273479217:12345678
			15140615455:12345678
			15882806952:hr753753
			18681661636:12345678
			17615151309:12345678
		*/
//		private void setEmpInfo(UserInfo userInfo) {
//			String userId="";
//			if(ObjectUtil.notEmpty(userInfo.getPhone())&&ObjectUtil.notEmpty(ThreadData.get(TENANT_ID))){
//				userId=getUserId(userInfo.getPhone() );
//				userInfo.setUid(userId);
//			}
//			//ThreadData.get(TENANT_ID)+"_"+ThreadData.get(COMPANY_ID)+"_"+ThreadData.get(SERVICE_ID)+"_"+"ubp")
//			if(ObjectUtil.notEmpty(userId)){
//				userInfo.setBpsUserName((userId+"_"+ThreadData.get(TENANT_ID)+"_"+ThreadData.get(COMPANY_ID)+"_"+ThreadData.get(SERVICE_ID)+"_"+"ubp"));
//			userInfo.setWorkFlowCode(new Des().strEnc((userId+"_"+ThreadData.get(TENANT_ID)+"_"+ThreadData.get(COMPANY_ID)+"_"+ThreadData.get(SERVICE_ID)+"_"+"ubp").toString(), UserInfo.FIRST_KEY, UserInfo.SECOND_KEY, UserInfo.THIRD_KEY));
//			}else{
//				userInfo.setBpsUserName("sysadmin");
//				userInfo.setWorkFlowCode(new Des().strEnc(("sysadmin").toString(), UserInfo.FIRST_KEY, UserInfo.SECOND_KEY, UserInfo.THIRD_KEY));
//			}
//			userInfo.setUserCode(userInfo.getLoginInfo().getOpenId());
//			if(ThreadData.get(Keys.TENANT_ID) != null){
//				userInfo.setTenantId(ThreadData.get(TENANT_ID));
//			}
//		}
//	}
//	public  String getUserId(String phone){
//		String userId="";
//		if(!(ThreadData.get(Keys.APP_KEY).toString().contains(phoneAppKey))){
//		      // Object users=redisTemplate.opsForValue().get(ThreadData.get(TENANT_ID)+"_"+ThreadData.get(COMPANY_ID)+"_"+ThreadData.get(SERVICE_ID)+"_"+"ubp"+"allParticipantUser");
//		       List<WFParticipantEntity> allUser=new ArrayList<>();
////	       if(ObjectUtil.notEmpty(users)){
////	    	   		allUser=JSONTool.toList(users.toString(), WFParticipantEntity.class);
////		    }else{
//				com.changhong.epc.constter.system.Service se=new com.changhong.epc.constter.system.Service();
//				se.setAppId(ThreadData.get(COMPANY_ID));
//				se.setAccessId(ThreadData.get(ACCESS_ID));
//				se.setSecurityKey(ThreadData.get(SECURITY_KEY));
//		        List<WFParticipantEntity>   pList=cscApiService.findOrganizationByCompanyId(se);
//			    getAllUsers(pList,allUser);
//	   // }
//		//	 allUser=JSONTool.toList(redisTemplate.opsForValue().get(ThreadData.get(TENANT_ID)+"_"+ThreadData.get(COMPANY_ID)+"_"+ThreadData.get(SERVICE_ID)+"_"+"ubp"+"allParticipantUser").toString(),WFParticipantEntity.class);
//			for( WFParticipantEntity user:allUser){
//				if(Objects.equals(phone,user.getPhone())){
//					userId=user.getId();
//				}
//			}
//		}
//		return userId;
//	}
	
	
//	public static void getAllUsers(List<WFParticipantEntity> pList,List<WFParticipantEntity> orgData){
//		for(WFParticipantEntity org:pList){
//			if("emp".equals(org.getTypeCode())){
//				orgData.add(org);
//			}
//			if(ObjectUtil.notEmpty(org.getChildren()) ){
//				getAllUsers(org.getChildren(),orgData);
//			}
//	    }
	}
	
}