Merge remote-tracking branch 'origin/dev1.0' into dev1.0

epmet-auth/src/main/java/com/epmet/service/impl/LoginServiceImpl.java

@@ -124,29 +124,35 @@ public class LoginServiceImpl implements LoginService {
 	 * @since 2020/3/14 19:34
 	 */
 	private String getUserId(LoginByWxCodeFormDTO formDTO, WxMaJscode2SessionResult wxMaJscode2SessionResult) {
-		WxLoginUserInfoFormDTO wxLoginUserInfoFormDTO=new WxLoginUserInfoFormDTO();
+		WxLoginUserInfoFormDTO wxLoginUserInfoFormDTO = new WxLoginUserInfoFormDTO();
 		wxLoginUserInfoFormDTO.setApp(formDTO.getApp());
 		wxLoginUserInfoFormDTO.setOpenId(wxMaJscode2SessionResult.getOpenid());
-		Result<String> userResult=epmetUserFeignClient.selecWxLoginUserInfo(wxLoginUserInfoFormDTO);
+		Result<String> userResult = epmetUserFeignClient.selecWxLoginUserInfo(wxLoginUserInfoFormDTO);
-		String userId="";
+		String userId = "";
-		if(!userResult.success()){
+		if (!userResult.success()) {
-			throw new RenException("获取用户信息失败"+userResult.getMsg());
+			throw new RenException("获取用户信息失败" + userResult.getMsg());
 		}
-		userId= (String) userResult.getData();
+		userId = (String) userResult.getData();
-		if (StringUtils.isBlank(userId)&&LoginConstant.APP_GOV.equals(formDTO.getApp())) {
+		if (StringUtils.isBlank(userId) && LoginConstant.APP_GOV.equals(formDTO.getApp())) {
 			//查询customer_staff待完善
-		} else if (StringUtils.isBlank(userId)&&LoginConstant.APP_OPER.equals(formDTO.getApp())) {
+		} else if (StringUtils.isBlank(userId) && LoginConstant.APP_OPER.equals(formDTO.getApp())) {
 			//查询oper_user待完善
-		} else if (StringUtils.isBlank(userId)&&LoginConstant.APP_RESI.equals(formDTO.getApp())) {
+		} else if (StringUtils.isBlank(userId) && LoginConstant.APP_RESI.equals(formDTO.getApp())) {
 			//查询customer_user
+			CustomerUserDTO customerUserDTO = new CustomerUserDTO();
+			if (StringUtils.isNotBlank(formDTO.getIv()) && StringUtils.isNotBlank(formDTO.getEncryptedData())) {
 				WxMaUserInfo wxMaUserInfo = wxMaServiceUtils.resiWxMaService().getUserService()
 						.getUserInfo(wxMaJscode2SessionResult.getSessionKey(),
 								formDTO.getEncryptedData(),
 								formDTO.getIv());
-			CustomerUserDTO customerUserDTO=this.packageCustomerUserDTO(wxMaUserInfo);
+				customerUserDTO = this.packageCustomerUserDTO(wxMaUserInfo);
-			Result<String> saveCustomerUserResult=epmetUserFeignClient.saveCustomerUser(customerUserDTO);
+			} else {
-			if(!saveCustomerUserResult.success()){
+				customerUserDTO.setWxOpenId(wxMaJscode2SessionResult.getOpenid());
-				throw new RenException("创建用户失败"+userResult.getMsg());
+				customerUserDTO.setUnionId(wxMaJscode2SessionResult.getUnionid());
+			}
+			Result<String> saveCustomerUserResult = epmetUserFeignClient.saveCustomerUser(customerUserDTO);
+			if (!saveCustomerUserResult.success()) {
+				throw new RenException("创建用户失败" + userResult.getMsg());
 			}
 			userId = saveCustomerUserResult.getData();
 		}
@@ -222,22 +228,22 @@ public class LoginServiceImpl implements LoginService {
 	public Result<UserTokenResultDTO> loginByPassword(LoginByPassWordFormDTO formDTO) {
 		//1、验证码是否正确
 		boolean flag = captchaService.validate(formDTO.getUuid(), formDTO.getCaptcha());
-		if(!flag){
+		if (!flag) {
 			return new Result<UserTokenResultDTO>().error(ErrorCode.CAPTCHA_ERROR);
 		}
 		//2、账号是否存在
 		//获取用户信息
-		PasswordLoginUserInfoFormDTO passwordLoginUserInfoFormDTO=new PasswordLoginUserInfoFormDTO();
+		PasswordLoginUserInfoFormDTO passwordLoginUserInfoFormDTO = new PasswordLoginUserInfoFormDTO();
 		passwordLoginUserInfoFormDTO.setApp(formDTO.getApp());
 		passwordLoginUserInfoFormDTO.setPhone(formDTO.getPhone());
-		Result<PasswordLoginUserInfoResultDTO> userInfoResult=epmetUserFeignClient.selectLoginUserInfoByPassword(passwordLoginUserInfoFormDTO);
+		Result<PasswordLoginUserInfoResultDTO> userInfoResult = epmetUserFeignClient.selectLoginUserInfoByPassword(passwordLoginUserInfoFormDTO);
-		logger.info(userInfoResult.getCode()+userInfoResult.getMsg());
+		logger.info(userInfoResult.getCode() + userInfoResult.getMsg());
-		if(!userInfoResult.success()||null==userInfoResult.getData()){
+		if (!userInfoResult.success() || null == userInfoResult.getData()) {
 			return new Result<UserTokenResultDTO>().error("账号不存在");
 		}
 		//3、密码是否正确
 		//密码错误
-		if(!PasswordUtils.matches(formDTO.getPassword(),userInfoResult.getData().getPassWord())){
+		if (!PasswordUtils.matches(formDTO.getPassword(), userInfoResult.getData().getPassWord())) {
 			throw new RenException(ErrorCode.ACCOUNT_PASSWORD_ERROR);
 		}
 		//4、生成token返回，且将TokenDto存到redis

epmet-commons/epmet-common-clienttoken/src/main/java/com/epmet/common/token/dto/form/LoginByWxCodeFormDTO.java

@@ -23,12 +23,10 @@ public class LoginByWxCodeFormDTO extends LoginCommonFormDTO implements Serializ
 	/**
 	 * 用户信息
 	 */
-	@NotBlank(message = "用户信息不能为空")
 	private String encryptedData;
 
 	/**
 	 * 加密算法的初始向量
 	 */
-	@NotBlank(message = "初始向量不能为空")
 	private String iv;
 }

epmet-commons/epmet-commons-tools/src/main/java/com/epmet/commons/tools/redis/RedisKeys.java

@@ -65,7 +65,7 @@ public class RedisKeys {
 	 * 用户菜单导航Key
 	 */
 	public static String getUserMenuNavKey(String userId, String app, String client, String language) {
-		return rootPrefix.concat("oper:access:nav:").concat(userId).concat("_").concat(app).concat("_").concat(client).concat("_").concat(language);
+		return rootPrefix.concat("oper:access:nav:").concat(app).concat("-").concat(client).concat("-").concat(userId).concat("-").concat(language);
 	}
 
 	/**
@@ -86,7 +86,7 @@ public class RedisKeys {
 	 * 用户权限标识Key
 	 */
 	public static String getUserPermissionsKey(String userId, String app, String client) {
-		return rootPrefix.concat("oper:access:permissions:").concat(userId).concat("_").concat(app).concat("_").concat(client);
+		return rootPrefix.concat("oper:access:permissions:").concat(app).concat("_").concat(client).concat("_").concat(userId);
 	}
 
 	/**

epmet-gateway/src/main/resources/bootstrap.yml

@@ -180,7 +180,7 @@ renren:
     - /epmetuser/**
     - /gov/org/**
     - /oper/access/**
-    - /resi/guide/**
+    - /sys/**
 management:
   endpoints:
     web:

epmet-module/oper-access/oper-access-client/src/main/java/com/epmet/dto/OperMenuDTO.java

@@ -47,6 +47,11 @@ public class OperMenuDTO extends TreeStringNode<OperMenuDTO> implements Serializ
      */
 	private String pid;
 
+	/**
+	 * 菜单名称
+	 */
+	private String name;
+
     /**
      * 菜单URL
      */

epmet-module/oper-access/oper-access-server/src/main/java/com/epmet/controller/OperMenuController.java

@@ -1,6 +1,8 @@
 package com.epmet.controller;
 
+import com.epmet.commons.tools.annotation.LoginUser;
 import com.epmet.commons.tools.page.PageData;
+import com.epmet.commons.tools.security.dto.TokenDto;
 import com.epmet.commons.tools.utils.ExcelUtils;
 import com.epmet.commons.tools.utils.Result;
 import com.epmet.commons.tools.validator.AssertUtils;
@@ -79,23 +81,23 @@ public class OperMenuController {
 
 	/**
 	 * 导航
-	 * @param userInfo token
+	 * @param tokenDto token
 	 * @return List<OperMenuDTO>
 	 */
-	@PostMapping("nav")
+	@GetMapping("nav")
-	public Result<List<OperMenuDTO>> nav(@RequestBody UserInfoDto userInfo){
+	public Result<List<OperMenuDTO>> nav(@LoginUser TokenDto tokenDto){
-		List<OperMenuDTO> list = operMenuService.getUserMenuNavList(userInfo);
+		List<OperMenuDTO> list = operMenuService.getUserMenuNavList(tokenDto);
 		return new Result<List<OperMenuDTO>>().ok(list);
 	}
 
 	/**
 	 * 权限标识
-	 * @param userInfo token
+	 * @param tokenDto token
 	 * @return Set<String>
 	 */
-	@PostMapping("permissions")
+	@GetMapping("permissions")
-	public Result<Set<String>> permissions(@RequestBody UserInfoDto userInfo){
+	public Result<Set<String>> permissions(@LoginUser TokenDto tokenDto){
-		Set<String> set = operMenuService.getUserPermissions(userInfo);
+		Set<String> set = operMenuService.getUserPermissions(tokenDto);
 		return new Result<Set<String>>().ok(set);
 	}
 

epmet-module/oper-access/oper-access-server/src/main/java/com/epmet/controller/OperRoleController.java

@@ -28,10 +28,12 @@ import com.epmet.commons.tools.validator.group.DefaultGroup;
 import com.epmet.dto.OperRoleDTO;
 import com.epmet.excel.OperRoleExcel;
 import com.epmet.service.OperRoleService;
+import io.swagger.annotations.ApiOperation;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.web.bind.annotation.*;
 
 import javax.servlet.http.HttpServletResponse;
+import java.util.HashMap;
 import java.util.List;
 import java.util.Map;
 
@@ -91,4 +93,12 @@ public class OperRoleController {
         ExcelUtils.exportExcelToTarget(response, null, list, OperRoleExcel.class);
     }
 
+    @GetMapping("list")
+    @ApiOperation("列表")
+    public Result<List<OperRoleDTO>> list(){
+        List<OperRoleDTO> data = operRoleService.list(new HashMap<>(1));
+
+        return new Result<List<OperRoleDTO>>().ok(data);
+    }
+
 }

epmet-module/oper-access/oper-access-server/src/main/java/com/epmet/service/OperMenuService.java

@@ -19,6 +19,7 @@ package com.epmet.service;
 
 import com.epmet.commons.mybatis.service.BaseService;
 import com.epmet.commons.tools.page.PageData;
+import com.epmet.commons.tools.security.dto.TokenDto;
 import com.epmet.commons.tools.security.user.UserDetail;
 import com.epmet.dto.OperMenuDTO;
 import com.epmet.dto.form.UserInfoDto;
@@ -99,23 +100,23 @@ public interface OperMenuService extends BaseService<OperMenuEntity> {
     /**
      * 用户菜单列表
      *
-     * @param userInfo 用户信息
+     * @param tokenDto 用户信息
      * @param type 菜单类型
      * @return java.util.List<OperMenuDTO>
      */
-    List<OperMenuDTO> getUserMenuList(UserInfoDto userInfo, Integer type);
+    List<OperMenuDTO> getUserMenuList(TokenDto tokenDto, Integer type);
 
     /**
      * 用户菜单导航
-     * @param userInfo 用户信息
+     * @param tokenDto 用户信息
      * @return java.util.List<OperMenuDTO>
      */
-    List<OperMenuDTO> getUserMenuNavList(UserInfoDto userInfo);
+    List<OperMenuDTO> getUserMenuNavList(TokenDto tokenDto);
 
     /**
      * 获取用户权限标识
-     * @param userInfo 用户信息
+     * @param tokenDto 用户信息
      * @return java.util.Set<OperMenuDTO>
      */
-    Set<String> getUserPermissions(UserInfoDto userInfo);
+    Set<String> getUserPermissions(TokenDto tokenDto);
 }

epmet-module/oper-access/oper-access-server/src/main/java/com/epmet/service/impl/OperMenuServiceImpl.java

@@ -22,6 +22,7 @@ import com.baomidou.mybatisplus.core.metadata.IPage;
 import com.epmet.commons.mybatis.service.impl.BaseServiceImpl;
 import com.epmet.commons.tools.enums.SuperAdminEnum;
 import com.epmet.commons.tools.page.PageData;
+import com.epmet.commons.tools.security.dto.TokenDto;
 import com.epmet.commons.tools.utils.ConvertUtils;
 import com.epmet.commons.tools.constant.FieldConstant;
 import com.epmet.commons.tools.utils.HttpContextUtils;
@@ -110,16 +111,16 @@ public class OperMenuServiceImpl extends BaseServiceImpl<OperMenuDao, OperMenuEn
     }
 
     @Override
-    public List<OperMenuDTO> getUserMenuList(UserInfoDto userInfo, Integer type) {
+    public List<OperMenuDTO> getUserMenuList(TokenDto tokenDto, Integer type) {
         List<OperMenuEntity> menuList;
 
-        Result<OperUserDTO> operUserDTOResult = epmetUserFeignClient.info(userInfo.getUserId());
+        Result<OperUserDTO> operUserDTOResult = epmetUserFeignClient.info(tokenDto.getUserId());
 
         //系统管理员，拥有最高权限
         if(operUserDTOResult.getData().getSuperAdmin() == SuperAdminEnum.YES.value()){
             menuList = baseDao.getMenuList(type, HttpContextUtils.getLanguage());
         }else {
-            menuList = baseDao.getUserMenuList(userInfo.getUserId(), type, HttpContextUtils.getLanguage());
+            menuList = baseDao.getUserMenuList(tokenDto.getUserId(), type, HttpContextUtils.getLanguage());
         }
 
         List<OperMenuDTO> dtoList = ConvertUtils.sourceToTarget(menuList, OperMenuDTO.class);
@@ -128,33 +129,33 @@ public class OperMenuServiceImpl extends BaseServiceImpl<OperMenuDao, OperMenuEn
     }
 
     @Override
-    public List<OperMenuDTO> getUserMenuNavList(UserInfoDto userInfo) {
+    public List<OperMenuDTO> getUserMenuNavList(TokenDto tokenDto) {
-        List<OperMenuDTO> menuList = operMenuRedis.getUserMenuNavList(userInfo.getUserId(), userInfo.getApp(), userInfo.getClient());
+        List<OperMenuDTO> menuList = operMenuRedis.getUserMenuNavList(tokenDto.getUserId(), tokenDto.getApp(), tokenDto.getClient());
         if(menuList == null){
-            menuList = getUserMenuList(userInfo, MenuTypeEnum.MENU.value());
+            menuList = getUserMenuList(tokenDto, MenuTypeEnum.MENU.value());
 
-            operMenuRedis.setUserMenuNavList(userInfo.getUserId(), userInfo.getApp(), userInfo.getClient(), menuList);
+            operMenuRedis.setUserMenuNavList(tokenDto.getUserId(), tokenDto.getApp(), tokenDto.getClient(), menuList);
         }
 
         return menuList;
     }
 
     @Override
-    public Set<String> getUserPermissions(UserInfoDto userInfo) {
+    public Set<String> getUserPermissions(TokenDto tokenDto) {
         //用户权限列表
-        Set<String> permsSet = operMenuRedis.getUserPermissions(userInfo.getUserId(), userInfo.getApp(), userInfo.getClient());
+        Set<String> permsSet = operMenuRedis.getUserPermissions(tokenDto.getUserId(), tokenDto.getApp(), tokenDto.getClient());
         if(permsSet != null){
             return permsSet;
         }
 
-        Result<OperUserDTO> operUserDTOResult = epmetUserFeignClient.info(userInfo.getUserId());
+        Result<OperUserDTO> operUserDTOResult = epmetUserFeignClient.info(tokenDto.getUserId());
 
         //超级管理员，拥有最高权限
         List<OperMenuEntity> menuList;
         if(operUserDTOResult.getData().getSuperAdmin() == SuperAdminEnum.YES.value()){
             menuList = baseDao.getMenuList(MenuTypeEnum.BUTTON.value(), HttpContextUtils.getLanguage());
         }else{
-            menuList = baseDao.getUserMenuList(userInfo.getUserId(), MenuTypeEnum.BUTTON.value(), HttpContextUtils.getLanguage());
+            menuList = baseDao.getUserMenuList(tokenDto.getUserId(), MenuTypeEnum.BUTTON.value(), HttpContextUtils.getLanguage());
         }
 
         permsSet = new HashSet<>();
@@ -165,7 +166,7 @@ public class OperMenuServiceImpl extends BaseServiceImpl<OperMenuDao, OperMenuEn
         }
 
         //保存到缓存
-        operMenuRedis.setUserPermissions(userInfo.getUserId(), userInfo.getApp(), userInfo.getClient(), permsSet);
+        operMenuRedis.setUserPermissions(tokenDto.getUserId(), tokenDto.getApp(), tokenDto.getClient(), permsSet);
 
         return permsSet;
     }

epmet-user/epmet-user-client/src/main/java/com/epmet/dto/CustomerUserDTO.java

@@ -48,6 +48,11 @@ public class CustomerUserDTO implements Serializable {
      */
 	private String wxOpenId;
 
+	/**
+	 * 微信unionId
+	 */
+	private String unionId;
+
     /**
      * 手机号
      */

epmet-user/epmet-user-server/src/main/java/com/epmet/controller/OperUserController.java

@@ -17,8 +17,9 @@
 
 package com.epmet.controller;
 
+import com.epmet.commons.tools.annotation.LoginUser;
 import com.epmet.commons.tools.page.PageData;
-import com.epmet.commons.tools.security.user.UserDetail;
+import com.epmet.commons.tools.security.dto.TokenDto;
 import com.epmet.commons.tools.utils.ConvertUtils;
 import com.epmet.commons.tools.utils.ExcelUtils;
 import com.epmet.commons.tools.utils.Result;
@@ -53,19 +54,19 @@ public class OperUserController {
 	private OperUserService operUserService;
 
 	@GetMapping("page")
-    public Result<PageData<OperUserDTO>> page(@RequestParam Map<String, Object> params){
+	public Result<PageData<OperUserDTO>> page(@RequestParam Map<String, Object> params) {
 		PageData<OperUserDTO> page = operUserService.page(params);
 		return new Result<PageData<OperUserDTO>>().ok(page);
 	}
 
 	@GetMapping("{id}")
-    public Result<OperUserDTO> get(@PathVariable("id") String id){
+	public Result<OperUserDTO> get(@PathVariable("id") String id) {
 		OperUserDTO data = operUserService.get(id);
 		return new Result<OperUserDTO>().ok(data);
 	}
 
 	@PostMapping
-    public Result save(@RequestBody OperUserDTO dto){
+	public Result save(@RequestBody OperUserDTO dto) {
 		//效验数据
 		ValidatorUtils.validateEntity(dto, AddGroup.class, DefaultGroup.class);
 		operUserService.save(dto);
@@ -73,7 +74,7 @@ public class OperUserController {
 	}
 
 	@PutMapping
-    public Result update(@RequestBody OperUserDTO dto){
+	public Result update(@RequestBody OperUserDTO dto) {
 		//效验数据
 		ValidatorUtils.validateEntity(dto, UpdateGroup.class, DefaultGroup.class);
 		operUserService.update(dto);
@@ -81,7 +82,7 @@ public class OperUserController {
 	}
 
 	@DeleteMapping
-    public Result delete(@RequestBody String[] ids){
+	public Result delete(@RequestBody String[] ids) {
 		//效验数据
 		AssertUtils.isArrayEmpty(ids, "id");
 		operUserService.delete(ids);
@@ -96,12 +97,26 @@ public class OperUserController {
 
 	/**
 	 * 获取运营人员信息
+	 *
+	 * @param tokenDto token
+	 * @return OperUserDTO
+	 * @author zhaoqifeng
+	 */
+	@GetMapping("queryOperUserDto")
+	public Result<OperUserDTO> queryOperUserDto(@LoginUser TokenDto tokenDto) {
+		OperUserDTO data = operUserService.getOperUserInfoById(tokenDto.getUserId());
+		return new Result<OperUserDTO>().ok(data);
+	}
+
+	/**
+	 * 获取运营人员信息
+	 *
 	 * @param operUserId oper_user表主键
 	 * @return OperUserDTO
 	 * @author zhaoqifeng
 	 */
 	@GetMapping("queryOperUserDtoById/{operUserId}")
-    public Result<OperUserDTO> queryOperUserDtoById(@PathVariable("operUserId") String operUserId){
+	public Result<OperUserDTO> queryOperUserDtoById(@PathVariable("operUserId") String operUserId) {
 		OperUserDTO data = operUserService.getOperUserInfoById(operUserId);
 		return new Result<OperUserDTO>().ok(data);
 	}

epmet-user/epmet-user-server/src/main/java/com/epmet/entity/CustomerUserEntity.java

@@ -48,6 +48,11 @@ public class CustomerUserEntity extends BaseEpmetEntity {
      */
 	private String wxOpenId;
 
+	/**
+	 * 微信unionId
+	 */
+	private String unionId;
+
     /**
      * 手机号
      */

epmet-user/epmet-user-server/src/main/java/com/epmet/service/impl/OperUserServiceImpl.java

@@ -53,11 +53,13 @@ public class OperUserServiceImpl extends BaseServiceImpl<OperUserDao, OperUserEn
 
     @Override
     public PageData<OperUserDTO> page(Map<String, Object> params) {
+
         IPage<OperUserEntity> page = baseDao.selectPage(
                 getPage(params, FieldConstant.CREATED_TIME, false),
                 getWrapper(params)
         );
         return getPageData(page, OperUserDTO.class);
+
     }
 
     @Override
@@ -69,10 +71,9 @@ public class OperUserServiceImpl extends BaseServiceImpl<OperUserDao, OperUserEn
 
     private QueryWrapper<OperUserEntity> getWrapper(Map<String, Object> params){
         String id = (String)params.get(FieldConstant.ID_HUMP);
-
+        String realName = (String)params.get("realName");
         QueryWrapper<OperUserEntity> wrapper = new QueryWrapper<>();
-        wrapper.eq(StringUtils.isNotBlank(id), FieldConstant.ID, id);
+        wrapper.eq(StringUtils.isNotBlank(id), FieldConstant.ID, id).like(StringUtils.isNotBlank(realName), "real_name", realName);
-
         return wrapper;
     }
 

epmet-user/epmet-user-server/src/main/resources/mapper/CustomerUserDao.xml

@@ -3,26 +3,6 @@
 
 <mapper namespace="com.epmet.dao.CustomerUserDao">
 
-    <resultMap type="com.epmet.entity.CustomerUserEntity" id="customerUserMap">
-        <result property="id" column="ID"/>
-        <result property="customerId" column="CUSTOMER_ID"/>
-        <result property="wxOpenId" column="WX_OPEN_ID"/>
-        <result property="mobile" column="MOBILE"/>
-        <result property="nickname" column="NICKNAME"/>
-        <result property="sex" column="SEX"/>
-        <result property="headImgUrl" column="HEAD_IMG_URL"/>
-        <result property="country" column="COUNTRY"/>
-        <result property="province" column="PROVINCE"/>
-        <result property="city" column="CITY"/>
-        <result property="language" column="LANGUAGE"/>
-        <result property="delFlag" column="DEL_FLAG"/>
-        <result property="revision" column="REVISION"/>
-        <result property="createdBy" column="CREATED_BY"/>
-        <result property="createdTime" column="CREATED_TIME"/>
-        <result property="updatedBy" column="UPDATED_BY"/>
-        <result property="updatedTime" column="UPDATED_TIME"/>
-    </resultMap>
-
     <!--   根据openId查询居民用户信息 -->
     <select id="selectCustomerIdByOpenId" parameterType="java.lang.String" resultType="java.lang.String">
         SELECT