/*
  * Copyright (C), 2018-2021
  * Project: starter
  * FileName: UserServiceKit
  * Author:   Louis
  * Date:     2021/5/14 8:28
  */
 package com.fr.plugin.hdmu.kit;

 import com.fanruan.api.log.LogKit;
 import com.fanruan.api.util.StringKit;
 import com.fr.decision.authority.AuthorityContext;
 import com.fr.decision.authority.base.constant.type.operation.ManualOperationType;
 import com.fr.decision.authority.data.User;
 import com.fr.decision.authority.data.extra.user.type.PasswordChangeTimeKey;
 import com.fr.decision.base.util.UUIDUtil;
 import com.fr.decision.privilege.TransmissionTool;
 import com.fr.decision.privilege.encrpt.PasswordValidator;
 import com.fr.decision.webservice.bean.user.DepartmentPostBean;
 import com.fr.decision.webservice.bean.user.UserBean;
 import com.fr.decision.webservice.exception.login.UserPwdErrorException;
 import com.fr.decision.webservice.utils.UserSourceFactory;
 import com.fr.decision.webservice.v10.login.kickout.KickOutConfig;
 import com.fr.decision.webservice.v10.login.kickout.KickOutUserEvent;
 import com.fr.decision.webservice.v10.login.lock.LoginLockService;
 import com.fr.decision.webservice.v10.password.strategy.PasswordStrategyService;
 import com.fr.decision.webservice.v10.user.PositionService;
 import com.fr.decision.webservice.v10.user.UserService;
 import com.fr.event.EventDispatcher;
 import com.fr.general.ComparatorUtils;
 import com.fr.json.JSONObject;
 import com.fr.stable.StringUtils;

 import java.util.ArrayList;
 import java.util.Date;
 import java.util.List;

 import static com.fr.plugin.hdmu.user.SsoUserManager.JOB_CODE;
 import static com.fr.plugin.hdmu.user.SsoUserManager.ORG_CODE;

 /**
  * <Function Description><br>
  * <UserServiceKit>
  *
  * @author fr.open
  * @since 1.0.0
  */
 public class UserServiceKit extends UserService {
     public static final String USER_NAME = "prWorkNo";
     public static final String REAL_NAME = "userName";
     public static final String ENABLE = "status";
     public static final String EMAIL = "email";
     public static final String PASSWORD = "appPwd";
     public static final String REQUEST_FLAG = "requestFlag";
     private static volatile UserServiceKit userServiceKit = null;

     public UserServiceKit() {
     }

     public static UserServiceKit getInstance() {
         if (userServiceKit == null) {
             userServiceKit = new UserServiceKit();
         }
         return userServiceKit;
     }

     @Override
     public void resetPassword(UserBean var1) throws Exception {
         User var2 = (User) AuthorityContext.getInstance().getUserController().getById(var1.getId());
         String var3 = var2.getUserName();
         String var4 = var2.getId();
         String var5 = TransmissionTool.decrypt(var1.getPassword());
         String var6 = var2.getPassword();
         String var7 = "";
         PasswordValidator var8 = UserSourceFactory.getInstance().getUserSource(var2).getPasswordValidator();
         if (StringUtils.isNotEmpty(var5)) {
//             AuthenticController var9 = ControllerFactory.getInstance().getAuthenticController(var2.getId());
//             if (!var9.passwordChangeable(var2)) {
//                 throw new UserPasswordCanNotChangeException();
//             }
             var7 = var8.encode(var2.getUserName(), var5, var2.getSalt());
             var2.setPassword(var7);
             PasswordStrategyService.getInstance().checkPasswordHistoryList(var2, var7);
         }
         AuthorityContext.getInstance().getUserController().update(var2.lastOperationType(ManualOperationType.KEY));
         if (StringUtils.isNotEmpty(var7) && !ComparatorUtils.equals(var6, var7)) {
             var2.salt(UUIDUtil.generate());
             var2.password(var8.encode(var2.getUserName(), var5, var2.getSalt()));
             AuthorityContext.getInstance().getUserController().update(var2);
             PasswordStrategyService.getInstance().updateUserPasswordHistoryList(var2, var6);
             AuthorityContext.getInstance().getUserController().addPasswordChangeTime(var4, PasswordChangeTimeKey.KEY, (Date) null);
             LoginLockService.getInstance().unlockByUserId(var4);
             PasswordStrategyService.getInstance().unblockPasswordChangeByUser(var2);
             EventDispatcher.fire(KickOutUserEvent.KickOutUser, new KickOutConfig(new UserPwdErrorException(), new String[]{var3}));
         }
     }

     public UserBean createUserBean(JSONObject account) throws Exception {
         UserBean userBean = new UserBean();
         userBean.setUsername(account.getString(USER_NAME));
         userBean.setRealName(account.getString(REAL_NAME));
         userBean.setEnable(StringKit.equals(account.getJSONArray("userJobAttr").getJSONObject(0).getString(ENABLE), "1"));
         userBean.setEmail(account.getString(EMAIL));
         userBean.setPassword(TransmissionTool.defaultEncrypt(account.getString(PASSWORD)));
         userBean.setPasswordChangeable(true);
         String departmentId;
         String position;
         try {
             departmentId = account.getString(ORG_CODE);
             position = account.getString(JOB_CODE);
         } catch (Exception e) {
             departmentId = StringKit.EMPTY;
             position = StringKit.EMPTY;
         }
         if (StringKit.isNotBlank(departmentId)) {
             List<String> departmentPostIds = createDepartmentPostIds(departmentId, position);
             userBean.setDepartmentPostIds(departmentPostIds);
         }
         return userBean;
     }

     /**
      * 转为部门职务组合
      *
      * @param departmentPostId
      * @param positionId
      * @return
      * @throws Exception
      */
     private List<String> createDepartmentPostIds(String departmentPostId, String positionId) throws Exception {
         List<String> departmentPostIds = new ArrayList<>();
         if (StringKit.isBlank(departmentPostId) || StringKit.equals(departmentPostId, "null")) {
             return departmentPostIds;
         }
         if (StringKit.isNotBlank(positionId)) {
             String positionName = PositionServiceKit.getInstance().getPostNameById(positionId);
             List<DepartmentPostBean> departmentPostBeanList = PositionService.getInstance().getPositionsUnderParentDepartment(getAdminUserId(), departmentPostId, positionName);
             if (departmentPostBeanList == null || departmentPostBeanList.isEmpty()) {
                 try {
                     AuthorityContext.getInstance().getPostController().addPostToDepartment(positionId, departmentPostId);
                 } catch (Exception e) {
                     LogKit.info("sso-UserServiceKit-createDepartmentPostIds-addPostToDepartmentFailed-position:{}, departmentId:{}", positionId + positionName, departmentPostId);
                     LogKit.error(e.getMessage(), e);
                 }
             }
             departmentPostId = departmentPostId + "@@@" + positionId;
         }
         departmentPostIds.add(departmentPostId);
         return departmentPostIds;
     }

     /**
      * 获取管理员id
      *
      * @return
      * @throws Exception
      */
     public String getAdminUserId() throws Exception {
         List<String> adminUserIdList = UserService.getInstance().getAdminUserIdList();
         if (adminUserIdList.isEmpty()) {
             return "admin";
         }
         return StringKit.isNotBlank(adminUserIdList.get(0)) ? adminUserIdList.get(0) : "admin";
     }

     public void editUser(UserBean userBean) throws Exception {
         super.editUser(userBean, this.getAdminUserId());
     }

     public UserBean updateUserBean(JSONObject account) throws Exception {
         User user = UserService.getInstance().getUserByUserName(account.getString(USER_NAME));
         if (user == null) {
             return null;
         }
         UserBean userBean = new UserBean();
         userBean.setId(user.getId());
         userBean.setUsername(user.getUserName());
         userBean.setRealName(account.getString(REAL_NAME));
         userBean.setEnable(user.isEnable());
         userBean.setEmail(account.getString(EMAIL));
         userBean.setPassword(TransmissionTool.defaultEncrypt(account.getString(PASSWORD)));
         String departmentId;
         String position;
         try {
             departmentId = account.getString(ORG_CODE);
             position = account.getString(JOB_CODE);
         } catch (Exception e) {
             departmentId = StringKit.EMPTY;
             position = StringKit.EMPTY;
         }
         if (StringKit.isNotBlank(departmentId)) {
             List<String> departmentPostIds = createDepartmentPostIds(departmentId, position);
             userBean.setDepartmentPostIds(departmentPostIds);
         }
         return userBean;
     }
 }