pipIrr-SV.git - Gitblit

			@@ -2,10 +2,13 @@

			import com.dy.common.aop.SsoVo;
			import com.dy.common.multiDataSource.DataSourceContext;
			import com.dy.common.util.MD5;
			import com.dy.common.webUtil.BaseResponse;
			import com.dy.common.webUtil.BaseResponseUtils;
			import com.dy.common.webUtil.ResultCodeMsg;
			import com.dy.pipIrrGlobal.pojoBa.BaUser;
			import com.dy.pipIrrGlobal.util.Org;
			import com.mysql.cj.util.StringUtils;
			import io.swagger.v3.oas.annotations.Hidden;
			import io.swagger.v3.oas.annotations.Operation;
			import io.swagger.v3.oas.annotations.Parameter;
			@@ -18,11 +21,11 @@
			import jakarta.validation.Valid;
			import lombok.extern.slf4j.Slf4j;
			import org.springframework.beans.factory.annotation.Autowired;
			//import org.springframework.cache.CacheManager;
			import org.springframework.http.MediaType;
			import org.springframework.validation.BindingResult;
			import org.springframework.web.bind.annotation.*;

			import java.util.List;
			import java.util.Objects;
			import java.util.UUID;

			@@ -52,6 +55,25 @@


			/**
			* 客户端请求得到所有组织机构
			* @return 所有组织机构数据
			*/
			@Operation(summary = "所有组织机构", description = "返回所有所有组织机构数据")
			@ApiResponses(value = {
			@ApiResponse(
			responseCode = ResultCodeMsg.RsCode.SUCCESS_CODE,
			description = "返回所有组织机构数据（BaseResponse.content:[ { \"tag\":\"ym\", \"name\":\"元谋\" }, { \"tag\":\"片角\", \"name\":\"片角镇\" }]）",
			content = {@Content(mediaType = MediaType.APPLICATION_JSON_VALUE,
			schema = @Schema(implementation = Org.class))}
			)
			})
			@GetMapping(path = "allOrg")
			public BaseResponse<List<Org.OrgVo>> allOrg(){
			//List<Org> list = Arrays.asList(Org.Ym, Org.Pj) ;
			return BaseResponseUtils.buildSuccess(Org.OrgList);
			}

			/**
			* 客户端请求用户登录，客户端提交Json数据
			* @param vo 用户登录值对象
			* @param bindingResult 输入验证
			@@ -76,9 +98,28 @@
			)
			})
			@PostMapping(path = "loginJson", consumes = MediaType.APPLICATION_JSON_VALUE)
			public BaseResponse<UserVo> loginJson(@Valid @RequestBody LoginVo vo, @Parameter(hidden = true) BindingResult bindingResult) {
			public BaseResponse<UserVo> loginJson(@RequestBody @Parameter(description = "登录json数据", required = true) @Valid LoginVo vo, @Parameter(hidden = true) BindingResult bindingResult) {
			if(bindingResult != null && bindingResult.hasErrors()){
			return BaseResponseUtils.buildFail(Objects.requireNonNull(bindingResult.getFieldError()).getDefaultMessage());
			}
			if(vo.phone == null \|\| vo.phone.trim().length() == 0){
			return BaseResponseUtils.buildFail("手机号不能为空");
			}
			if(!vo.phone.equals("admin")){
			if(vo.phone.length() != 11){
			return BaseResponseUtils.buildFail("手机号（长度不是11位）不正确");
			}
			}
			if(vo.orgTag == null \|\| vo.orgTag.trim().length() == 0){
			return BaseResponseUtils.buildFail("未选择组织单位");
			}
			//把组织单位标签作为数据源名称
			DataSourceContext.set(vo.orgTag);

			//得到所有用户账号
			List<String> phones = sv.getPhones();
			if(!phones.contains(vo.phone)){
			return BaseResponseUtils.buildFail("账号不存在");
			}

			String uuid ;
			@@ -86,6 +127,13 @@
			try {
			//Boolean flag = cacheManager.getCacheNames().isEmpty() ;
			uuid = UUID.randomUUID().toString();
			if(!StringUtils.isNullOrEmpty(vo.password)){
			/*
			如果前端进行了base64加密
			po.password = new String(Base64.getDecoder().decode(po.password)) ;
			*/
			vo.password = MD5.encrypt(vo.password) ;
			}
			userPo = this.sv.loginWithMapperXml(uuid, vo.phone, vo.password);
			} catch (Exception e) {
			log.error("用户登录异常", e);
			@@ -97,7 +145,7 @@
			uVo.token = uuid ;
			return BaseResponseUtils.buildSuccess(uVo);
			}else{
			return BaseResponseUtils.buildFail("登录失败");
			return BaseResponseUtils.buildFail("密码错误");
			}
			}

			@@ -131,6 +179,13 @@
			try {
			//Boolean flag = cacheManager.getCacheNames().isEmpty() ;
			uuid = UUID.randomUUID().toString();
			if(!StringUtils.isNullOrEmpty(vo.password)){
			/*
			如果前端进行了base64加密
			po.password = new String(Base64.getDecoder().decode(po.password)) ;
			*/
			vo.password = MD5.encrypt(vo.password) ;
			}
			userPo = this.sv.loginWithMapperXml(uuid, vo.phone, vo.password);
			} catch (Exception e) {
			log.error("用户登录异常", e);
			@@ -183,7 +238,27 @@
			BaUser userPo = this.sv.getByUuid(token) ;
			return userPo == null ? null : userPo.id ;
			}

			/**
			* 此方法供子模块系统调用，所以不公开在API接口中
			* 方法功能：验证是否已经登录
			* @param token 登录用户token
			* @return SsoVo
			*/
			@Hidden
			@GetMapping(path = "ssoCheck")
			public SsoVo ssoCheck(String token){
			BaUser userPo = this.sv.getByUuid(token) ;
			SsoVo vo = new SsoVo();
			if(userPo != null){
			vo.dataSourceName = userPo.orgTag ;
			vo.logined = true ;
			vo.hasPower = true ;//默认有权限。2023-12-21 经商议，由前端鉴权
			}else{
			vo.logined = false ;
			vo.hasPower = true ;//默认有权限。2023-12-21 经商议，由前端鉴权
			}
			return vo ;
			}
			/**
			* 此方法供子模块系统调用，所以不公开在API接口中
			* 方法功能：验证是否已经登录，如果登录了，再验证权限
			@@ -194,8 +269,8 @@
			* @return SsoVo
			*/
			@Hidden
			@GetMapping(path = "ssoCheck")
			public SsoVo ssoCheck(String token, String privilege, String[] allPrivilege, String[] anyPrivilege){
			@GetMapping(path = "ssoPowerCheck")
			public SsoVo ssoPowerCheck(String token, String privilege, String[] allPrivilege, String[] anyPrivilege){
			BaUser userPo = this.sv.getByUuid(token) ;
			SsoVo vo = new SsoVo();
			if(userPo != null){
			@@ -227,6 +302,22 @@
			return vo ;
			}

			/**
			* 获得当前登录用户
			* @param token 登录用户token
			* @return SsoVo
			*/
			@Hidden
			@GetMapping(path = "ssoCurUser")
			public CurUserVo ssoCurUser(String token){
			BaUser userPo = this.sv.getByUuid(token) ;
			CurUserVo vo = new CurUserVo();
			if(userPo != null){
			vo.id = userPo.id ;
			vo.name = userPo.userName;
			}
			return vo ;
			}
			/////////////////////////////////////////////////////////////////
			//
			// 以下私有方法