package com.cloud.user.controller;

//import com.cloud.common.utils.AppUserUtil;
import com.cloud.model.common.Page;
import com.cloud.model.common.Result;
import com.cloud.model.log.LogAnnotation;
import com.cloud.model.log.constants.AbstractLogModule;
import com.cloud.model.sys.AppUser;
import com.cloud.model.sys.LoginAppUser;
import com.cloud.model.sys.SysRole;
import com.cloud.model.sys.constants.CredentialType;
//import com.cloud.user.feign.SmsClient;
import com.cloud.user.model.OrgNameAppUser;
import com.cloud.user.service.AppUserService;
import com.cloud.user.service.TokenService;
import io.swagger.annotations.Api;
import io.swagger.annotations.ApiImplicitParam;
import io.swagger.annotations.ApiImplicitParams;
import io.swagger.annotations.ApiOperation;
import lombok.extern.slf4j.Slf4j;
import org.apache.commons.lang3.StringUtils;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.http.MediaType;
import org.springframework.security.access.prepost.PreAuthorize;
//import org.springframework.security.oauth2.common.util.OAuth2Utils;
import org.springframework.web.bind.annotation.*;

import java.util.HashMap;
import java.util.Map;
import java.util.Set;

@Slf4j
@RestController
@RequestMapping("data/api-u")
@Api(value = "UserController", description = "用户控制层")
public class UserController {

	@Autowired
	private AppUserService appUserService;

	@Autowired
	private TokenService tokenService;


	/**
	 * 当前登录用户 LoginAppUser
	 */
	@GetMapping("/users/current")
	@ApiOperation(value = "获取当前登录用户", notes = "", httpMethod = "GET", produces = MediaType.APPLICATION_JSON_UTF8_VALUE)
	public LoginAppUser getLoginAppUser() {
		return tokenService.currentUser();
	}

	/**
	 * 根据用户名查找登录对象信息
	 */
	@GetMapping(value = "/users-anon/internal", params = "username")
	@ApiOperation(value = "查找用户", notes = "根据用户名字查找用户信息集合", httpMethod = "GET", produces = MediaType.APPLICATION_JSON_UTF8_VALUE)
	@ApiImplicitParams({
			@ApiImplicitParam(name = "username", value = "用户名", required = true, dataType = "String", paramType = "query")
	})
	public LoginAppUser findByUsername(String username) {
		return appUserService.findByUsername(username);
	}

	/**
	 * 用户查询
	 */
	@GetMapping("/users")
	@PreAuthorize("hasAuthority('sys:user:query')")
	@ApiOperation(value = "用户查询", notes = "有orgId分库查询，没有orgId全局查询", httpMethod = "GET", produces = MediaType.APPLICATION_JSON_UTF8_VALUE)
	@ApiImplicitParams({
			@ApiImplicitParam(name = "start", value = "起始页", required = true, dataType = "String", paramType = "query"),
			@ApiImplicitParam(name = "length", value = "条数", required = true, dataType = "String", paramType = "query"),
			@ApiImplicitParam(name = "orgId", value = "分库：orgId", required = true, dataType = "String", paramType = "query"),
			@ApiImplicitParam(name = "id", value = "组织id", required = true, dataType = "String", paramType = "query"),
			@ApiImplicitParam(name = "isAll", value = "是否查询全部", required = true, dataType = "String", paramType = "query")
	})
	public Page<OrgNameAppUser> findUsers(@RequestParam Map<String, Object> params){
		return appUserService.findUsers(params);
	}


	/**
	 * 根据id查询用户
	 */
	@GetMapping("/users/findUserById")
	@PreAuthorize("hasAuthority('sys:user:query')")
	@ApiOperation(value = "根据id查询用户", notes = "参数id,orgId", httpMethod = "GET", produces = MediaType.APPLICATION_FORM_URLENCODED_VALUE)
	@ApiImplicitParams({
			@ApiImplicitParam(name = "params",
					value = "{id：用户id ," +
							" orgId:组织机构Id" +
							"}",
					required = true, dataType = "string", paramType = "query"),
	})
	public AppUser findUserById(@RequestParam Map<String,Object> params) {
		return appUserService.findById(params);
	}

	/**
	 * 添加用户,根据用户名注册
	 */
	@PostMapping("/users-anon/register")
	@ApiOperation(value = "添加用户", notes = "添加用户,根据用户名注册", httpMethod = "POST", produces = MediaType.APPLICATION_JSON_UTF8_VALUE)
	@ApiImplicitParams({
			@ApiImplicitParam(name = "orgId", value = "分库orgId", required = true, dataType = "String", paramType = "query"),
			@ApiImplicitParam(name = "officeId", value = "部门id", required = true, dataType = "String", paramType = "query"),
			@ApiImplicitParam(name = "username", value = "分库orgId", required = true, dataType = "String", paramType = "query"),
			@ApiImplicitParam(name = "password", value = "用户名", required = true, dataType = "String", paramType = "query"),
			@ApiImplicitParam(name = "nickname", value = "昵称", required = true, dataType = "String", paramType = "query"),
			@ApiImplicitParam(name = "phone", value = "手机号", required = true, dataType = "String", paramType = "query"),
			@ApiImplicitParam(name = "sex", value = "性别", required = true, dataType = "String", paramType = "query"),
			@ApiImplicitParam(name = "type", value = "类型", required = true, dataType = "String", paramType = "query"),
			@ApiImplicitParam(name = "no", value = "编号", required = true, dataType = "String", paramType = "query"),
			@ApiImplicitParam(name = "eMail", value = "电子邮件", required = true, dataType = "String", paramType = "query"),
			@ApiImplicitParam(name = "telPhone", value = "电话", required = true, dataType = "String", paramType = "query"),
			@ApiImplicitParam(name = "headImgUrl", value = "头像", required = false, dataType = "String", paramType = "query"),
			@ApiImplicitParam(name = "qrCode", value = "二维码路径", required = false, dataType = "String", paramType = "query"),
			@ApiImplicitParam(name = "idCard", value = "身份证号", required = false, dataType = "String", paramType = "query"),
			@ApiImplicitParam(name = "userType", value = "用户类型", required = false, dataType = "String", paramType = "query")
	})
	public AppUser register(@RequestBody AppUser appUser) {

		appUserService.addAppUser(appUser);
		return appUser;
	}

	/**
	 * 逻辑删除系统用户
	 * @param params
	 * @return
	 */
	@ApiOperation(value = "逻辑删除系统用户", notes = "逻辑删除系统用户", httpMethod = "GET", produces = MediaType.APPLICATION_JSON_UTF8_VALUE)
	@ApiImplicitParams({
			@ApiImplicitParam(name = "id", value = "用户id", required = true, dataType = "String", paramType = "query"),
	})
	@GetMapping("/users-anon/delete")
	public Map<String,Object> deleteAppUser(@RequestParam Map<String,Object> params){

		return appUserService.deleteAppUser(params);
	}

	/**
	 * 修改自己的个人信息
	 */
	@ApiOperation(value = "修改用户", notes = "修改用户保存模块", httpMethod = "PUT", produces = MediaType.APPLICATION_JSON_UTF8_VALUE)
	@LogAnnotation(module = AbstractLogModule.UPDATE_ME)
	@PutMapping("/users/me")
	public AppUser updateMe(@RequestBody AppUser appUser) {
		AppUser user = tokenService.currentUser();
		appUser.setId(user.getId());
		appUser.setEnabled(user.isEnabled());

		appUserService.updateAppUser(appUser);

		return appUser;
	}

	/**
	 * 修改密码
	 */
	@PutMapping(value = "/users/password", params = { "oldPassword", "newPassword" })
	@LogAnnotation(module = AbstractLogModule.UPDATE_PASSWORD)
	@ApiOperation(value = "修改密码", notes = "用户修改自己密码模块", httpMethod = "PUT", produces = MediaType.APPLICATION_JSON_UTF8_VALUE)
	@ApiImplicitParams({
			@ApiImplicitParam(name = "id", value = "用户id", required = true, dataType = "String", paramType = "query"),
			@ApiImplicitParam(name = "oldPassword", value = "旧密码", required = true, dataType = "String", paramType = "query"),
			@ApiImplicitParam(name = "newPassword", value = "新密码", required = true, dataType = "String", paramType = "query"),
			@ApiImplicitParam(name = "orgId", value = "组织ID", required = true, dataType = "String", paramType = "query")
	})
	public Result updatePassword(@RequestParam  Map<String,Object> params) {
		String oldPassword = params.get("oldPassword").toString();
		String newPassword = params.get("newPassword").toString();
		if (StringUtils.isBlank(oldPassword)) {
			throw new IllegalArgumentException("旧密码不能为空");
		}
		if (StringUtils.isBlank(newPassword)) {
			throw new IllegalArgumentException("新密码不能为空");
		}
		//AppUser user = AppUserUtil.getLoginAppUser();
		appUserService.updatePassword(params);
		return Result.ok();
	}

	/**
	 * 管理后台，给用户重置密码
	 */
	@PostMapping(value = "/users/resetPassword")
	//@PreAuthorize("hasAuthority('back:user:password')")
	@ApiOperation(value = "重置密码", notes = "管理后台，给用户重置密码", httpMethod = "PUT", produces = MediaType.APPLICATION_JSON_UTF8_VALUE)
	@ApiImplicitParams({
			@ApiImplicitParam(name = "id", value = "用户id", required = true, dataType = "Long", paramType = "query"),
			@ApiImplicitParam(name = "orgId", value = "组织orgId", required = true, dataType = "Long", paramType = "query"),
			@ApiImplicitParam(name = "newPassword", value = "新密码", required = true, dataType = "String", paramType = "query")
	})
	@LogAnnotation(module = AbstractLogModule.RESET_PASSWORD)
	public Result resetPassword(@RequestParam Map<String,Object> params) {

		appUserService.updatePassword(params);
		return Result.ok();
	}

	/**
	 * 用户重置密码123456
	 */
	@GetMapping(value = "/users/setPassWord")
	@ApiOperation(value = "用户重置密码", notes = "系统管理用户重置密码", httpMethod = "GET", produces = MediaType.APPLICATION_FORM_URLENCODED_VALUE)
	@ApiImplicitParams({
			@ApiImplicitParam(name = "id", value = "用户id", required = true, dataType = "Long", paramType = "query"),
			@ApiImplicitParam(name = "orgId", value = "组织orgId", required = true, dataType = "Long", paramType = "query")
	})
	@LogAnnotation(module = AbstractLogModule.RESET_PASSWORD)
	public Result setPassWord(@RequestParam Map<String,Object> params) {
		AppUser appUser = new AppUser();
		appUser.setId(Long.parseLong(params.get("id").toString()));
		appUser.setOrgId(Long.parseLong(params.get("orgId").toString()));
		appUserService.setPassWord(appUser);
		return Result.ok();
	}

	/**
	 * 管理后台修改用户
	 */
	@ApiOperation(value = "管理后台修改用户", notes = "管理后台修改用户", httpMethod = "POST", produces = MediaType.APPLICATION_JSON_UTF8_VALUE)
	@ApiImplicitParams({
			@ApiImplicitParam(name = "orgId", value = "分库orgId", required = true, dataType = "String", paramType = "query"),
			@ApiImplicitParam(name = "officeId", value = "部门id", required = true, dataType = "String", paramType = "query"),
			@ApiImplicitParam(name = "username", value = "分库orgId", required = true, dataType = "String", paramType = "query"),
			@ApiImplicitParam(name = "password", value = "用户名", required = true, dataType = "String", paramType = "query"),
			@ApiImplicitParam(name = "nickname", value = "昵称", required = true, dataType = "String", paramType = "query"),
			@ApiImplicitParam(name = "phone", value = "手机号", required = true, dataType = "String", paramType = "query"),
			@ApiImplicitParam(name = "sex", value = "性别", required = true, dataType = "String", paramType = "query"),
			@ApiImplicitParam(name = "type", value = "类型", required = true, dataType = "String", paramType = "query"),
			@ApiImplicitParam(name = "no", value = "编号", required = true, dataType = "String", paramType = "query"),
			@ApiImplicitParam(name = "eMail", value = "电子邮件", required = true, dataType = "String", paramType = "query"),
			@ApiImplicitParam(name = "telPhone", value = "电话", required = true, dataType = "String", paramType = "query"),
			@ApiImplicitParam(name = "headImgUrl", value = "头像", required = false, dataType = "String", paramType = "query"),
			@ApiImplicitParam(name = "qrCode", value = "二维码路径", required = false, dataType = "String", paramType = "query"),
			@ApiImplicitParam(name = "idCard", value = "身份证号", required = false, dataType = "String", paramType = "query"),
			@ApiImplicitParam(name = "userType", value = "用户类型", required = false, dataType = "String", paramType = "query")
	})
	@LogAnnotation(module = AbstractLogModule.UPDATE_USER)
	//@PreAuthorize("hasAuthority('back:user:update')")
	@PostMapping("/users-anon/update")
	public Result updateAppUser(@RequestBody AppUser appUser) {
		appUserService.updateAppUser(appUser);
		return Result.ok();
	}

	/**
	 * 管理后台给用户分配角色
	 * id,orgId,set<Long> roleIds
	 */
	@PostMapping("/users/setRoleToUser")
	@LogAnnotation(module = AbstractLogModule.SET_ROLE)
	@ApiOperation(value = "管理后台给用户分配角色", notes = "管理后台给用户分配角色", httpMethod = "POST", produces = MediaType.APPLICATION_JSON_UTF8_VALUE)
	@ApiImplicitParams({
			@ApiImplicitParam(name = "orgId", value = "orgId", required = true, dataType = "String", paramType = "query"),
			@ApiImplicitParam(name = "id", value = "用户id", required = true, dataType = "String", paramType = "query"),
			@ApiImplicitParam(name = "roleIds", value = "角色ids,字符串','分割", required = true, dataType = "query", paramType = "query")
	})
	//@PreAuthorize("hasAuthority('back:user:role:set')")
	public Map<String,Object> setRoleToUser(@RequestBody Map<String,Object> params) {
		Map<String,Object> map = new HashMap<>();
		int status = appUserService.setRoleToUser(params);
		if(status > 0){
			map.put("code",0);
			map.put("message","更新成功！");
		}else {
			map.put("code",1);
			map.put("message","更新失败！");
		}
		return map;
	}

	/**
	 * 获取用户的角色列表
	 * orgId,userId
	 */
	@GetMapping("/users/findRolesByUserId")
	//@PreAuthorize("hasAnyAuthority('back:user:role:set','user:role:byuid')")
	@ApiOperation(value = "获取用户的角色列表", notes = "获取用户的角色列表", httpMethod = "GET", produces = MediaType.APPLICATION_JSON_UTF8_VALUE)
	@ApiImplicitParams({
			@ApiImplicitParam(name = "orgId", value = "orgId", required = true, dataType = "String", paramType = "query"),
			@ApiImplicitParam(name = "id", value = "用户ID", required = true, dataType = "String", paramType = "query")
	})
	public Set<SysRole> findRolesByUserId(@RequestParam Map<String,Object> params) {
		//TODO lllppp 先临时查出orgId,以后由前台传入
		AppUser user = appUserService.findById(params);
		if(user != null){
			return appUserService.findRolesByUserId(user.getId(),user.getOrgId());
		}
		return null;
	}

	/**
	 * 获取用户的角色回显列表
	 * id,orgId
	 */
	@GetMapping("/users/findRolesIdsByUserId")
	@ApiOperation(value = "获取用户的角色回显的角色Id", notes = "获取用户的角色回显的角色Id", httpMethod = "GET", produces = MediaType.APPLICATION_JSON_UTF8_VALUE)
	@ApiImplicitParams({
			@ApiImplicitParam(name = "orgId", value = "orgId", required = true, dataType = "String", paramType = "query"),
			@ApiImplicitParam(name = "id", value = "用户ID", required = true, dataType = "String", paramType = "query")
	})
	public Map<String,Object> findRolesIdsByUserId(@RequestParam Map<String,Object> params){

		return appUserService.findRolesIdsByUserId(params);
	}

//	@Autowired
//	private SmsClient smsClient;

	@PostMapping(value = "/users/binding-phone")
	public void bindingPhone(String phone, String key, String code) {
		if (StringUtils.isBlank(phone)) {
			throw new IllegalArgumentException("手机号不能为空");
		}

		if (StringUtils.isBlank(key)) {
			throw new IllegalArgumentException("key不能为空");
		}

		if (StringUtils.isBlank(code)) {
			throw new IllegalArgumentException("code不能为空");
		}

		LoginAppUser loginAppUser =tokenService.currentUser();
		log.info("绑定手机号，key:{},code:{},username:{}", key, code, loginAppUser.getUsername());

		String value = "";//smsClient.matcheCodeAndGetPhone(key, code, false, 30);
		if (value == null) {
			throw new IllegalArgumentException("验证码错误");
		}

		if (phone.equals(value)) {
			appUserService.bindingPhone(loginAppUser.getId(), phone,loginAppUser.getOrgId());
		} else {
			throw new IllegalArgumentException("手机号不一致");
		}
	}

	/**
	 * 用户组织机构变更
	 * @param params
	 * @return
	 */
	@ApiOperation(value = "用户组织机构变更", notes = "用户组织机构变更", httpMethod = "GET", produces = MediaType.APPLICATION_FORM_URLENCODED_VALUE)
	@ApiImplicitParams({
			@ApiImplicitParam(name = "orgId", value = "分库orgId", required = true, dataType = "String", paramType = "query"),
			@ApiImplicitParam(name = "userIds", value = "人员ids", required = true, dataType = "String", paramType = "query"),
			@ApiImplicitParam(name = "officeId", value = "部门id", required = true, dataType = "String", paramType = "query"),
			@ApiImplicitParam(name = "updateOfficeId", value = "修改后的部门id", required = true, dataType = "String", paramType = "query"),
			@ApiImplicitParam(name = "updateOrgId", value = "修改后的组织机构id", required = true, dataType = "String", paramType = "query"),
	})
	@RequestMapping("/users/updateOfficeId")
	public Result updateOfficeId(@RequestParam Map<String, Object> params){
		try{
			return Result.ok("操作成功", appUserService.updateOfficeId(params));
		}catch (Exception e){
			e.printStackTrace();
			return Result.error(e);
		}
	}

}