居民端-居民注册添加角色信息

epmet-module/resi-mine/resi-mine-server/src/main/java/com/epmet/modules/resiregister/service/impl/ResiRegisterServiceImpl.java

@@ -59,6 +59,7 @@ public class ResiRegisterServiceImpl implements ResiRegisterService {
             return new Result<ResiRegisterResultDTO>().error(ModuleConstant.PARAMETER_EXCEPTION);
         }
         formDTO.setUserId(tokenDTO.getUserId());
+        formDTO.setApp(tokenDTO.getApp());
         return epmetUserFeignClient.submit(formDTO);
     }
 

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

@@ -33,6 +33,11 @@ public class UserResiInfoDTO implements Serializable {
 
     private static final long serialVersionUID = 1L;
 
+	/**
+	 * 政府端:gov、居民端:resi、运营端:oper
+	 */
+	private String app;
+
 	/**
 	 * 唯一标识
 	 */

epmet-user/epmet-user-server/src/main/java/com/epmet/dao/RoleDao.java

@@ -18,6 +18,7 @@
 package com.epmet.dao;
 
 import com.epmet.commons.mybatis.dao.BaseDao;
+import com.epmet.dto.RoleDTO;
 import com.epmet.entity.RoleEntity;
 import org.apache.ibatis.annotations.Mapper;
 
@@ -30,4 +31,5 @@ import org.apache.ibatis.annotations.Mapper;
 @Mapper
 public interface RoleDao extends BaseDao<RoleEntity> {
 
+    RoleDTO selectRoleByKey(RoleDTO roleDTO);
 }

epmet-user/epmet-user-server/src/main/java/com/epmet/dao/UserResiInfoDao.java

@@ -47,7 +47,7 @@ public interface UserResiInfoDao extends BaseDao<UserResiInfoEntity> {
 	 * @Author sun
 	 * @Description 用户居民端注册信息表新增数据
 	 **/
-	void saveUserResiInfo(UserResiInfoDTO userResiInfoDTO);
+	boolean saveUserResiInfo(UserResiInfoDTO userResiInfoDTO);
 
 	/**
 	 * @Author sun

epmet-user/epmet-user-server/src/main/java/com/epmet/dao/UserRoleDao.java

@@ -18,6 +18,7 @@
 package com.epmet.dao;
 
 import com.epmet.commons.mybatis.dao.BaseDao;
+import com.epmet.dto.UserRoleDTO;
 import com.epmet.dto.form.UserRoleFormDTO;
 import com.epmet.dto.result.UserRoleResultDTO;
 import com.epmet.entity.UserRoleEntity;
@@ -42,4 +43,6 @@ public interface UserRoleDao extends BaseDao<UserRoleEntity> {
      **/
     List<UserRoleResultDTO> getUserRoleInfo(UserRoleFormDTO userRoleFormDTO);
 
+    boolean saveResiRole(UserRoleDTO userRoleDTO);
+
 }

epmet-user/epmet-user-server/src/main/java/com/epmet/redis/UserResiInfoRedis.java

@@ -17,6 +17,7 @@
 
 package com.epmet.redis;
 
+import com.epmet.commons.tools.redis.RedisKeys;
 import com.epmet.commons.tools.redis.RedisUtils;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.stereotype.Component;
@@ -44,4 +45,14 @@ public class UserResiInfoRedis {
         return null;
     }
 
+    public void setUserResiMobileCode(String userId, String mobile, String verificationCode){
+        String key = RedisKeys.getUserMobileCodeKey(userId, mobile, verificationCode);
+        redisUtils.set(key, verificationCode);
+    }
+
+    public String getUserResiMobileCode(String userId, String mobile, String verificationCode){
+        String key = RedisKeys.getUserMobileCodeKey(userId, mobile, verificationCode);
+        return (String) redisUtils.get(key);
+    }
+
 }

epmet-user/epmet-user-server/src/main/java/com/epmet/service/RoleService.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.utils.Result;
 import com.epmet.dto.RoleDTO;
 import com.epmet.entity.RoleEntity;
 
@@ -92,4 +93,6 @@ public interface RoleService extends BaseService<RoleEntity> {
      * @date 2020-03-30
      */
     void delete(String[] ids);
+
+    Result<RoleDTO> getRoleByKey(RoleDTO roleDTO);
 }

epmet-user/epmet-user-server/src/main/java/com/epmet/service/UserRoleService.java

@@ -20,6 +20,7 @@ package com.epmet.service;
 import com.epmet.commons.mybatis.service.BaseService;
 import com.epmet.commons.tools.page.PageData;
 import com.epmet.commons.tools.utils.Result;
+import com.epmet.dto.UserResiInfoDTO;
 import com.epmet.dto.UserRoleDTO;
 import com.epmet.dto.form.UserRoleFormDTO;
 import com.epmet.dto.result.UserRoleResultDTO;
@@ -97,12 +98,18 @@ public interface UserRoleService extends BaseService<UserRoleEntity> {
     void delete(String[] ids);
 
     /**
+     * @return UserRoleResultDTO
      * @Description 根据用户Id、来源app、客户Id查询用户角色
      * @Param userRoleFormDTO
-     * @return UserRoleResultDTO
      * @Author wangc
      * @Date 2020.03.30 15:35
      **/
     Result<List<UserRoleResultDTO>> getUserRoleInfo(UserRoleFormDTO userRoleFormDTO);
 
+    /**
+     * @Description 居民注册成功添加居民角色
+     * @Author sun
+     **/
+    Result saveResiRole(UserResiInfoDTO userResiInfoDTO);
+
 }

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

@@ -23,6 +23,7 @@ import com.epmet.commons.mybatis.service.impl.BaseServiceImpl;
 import com.epmet.commons.tools.page.PageData;
 import com.epmet.commons.tools.utils.ConvertUtils;
 import com.epmet.commons.tools.constant.FieldConstant;
+import com.epmet.commons.tools.utils.Result;
 import com.epmet.dao.RoleDao;
 import com.epmet.dto.RoleDTO;
 import com.epmet.entity.RoleEntity;
@@ -48,6 +49,8 @@ public class RoleServiceImpl extends BaseServiceImpl<RoleDao, RoleEntity> implem
 
     @Autowired
     private RoleRedis roleRedis;
+    @Autowired
+    private RoleDao roleDao;
 
     @Override
     public PageData<RoleDTO> page(Map<String, Object> params) {
@@ -101,4 +104,9 @@ public class RoleServiceImpl extends BaseServiceImpl<RoleDao, RoleEntity> implem
         baseDao.deleteBatchIds(Arrays.asList(ids));
     }
 
+    @Override
+    public Result<RoleDTO> getRoleByKey(RoleDTO roleDTO) {
+        return new Result<RoleDTO>().ok(roleDao.selectRoleByKey(roleDTO));
+    }
+
 }

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

@@ -37,6 +37,7 @@ import com.epmet.redis.UserResiInfoRedis;
 import com.epmet.service.RegisterRelationService;
 import com.epmet.service.UserResiInfoService;
 import com.epmet.service.UserResiRegisterVisitService;
+import com.epmet.service.UserRoleService;
 import org.apache.commons.lang3.StringUtils;
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
@@ -58,153 +59,161 @@ import java.util.Map;
 @Service
 public class UserResiInfoServiceImpl extends BaseServiceImpl<UserResiInfoDao, UserResiInfoEntity> implements UserResiInfoService {
 
-	private static final Logger log = LoggerFactory.getLogger(UserResiInfoServiceImpl.class);
+    private static final Logger log = LoggerFactory.getLogger(UserResiInfoServiceImpl.class);
-	@Autowired
+    @Autowired
-	private UserResiInfoRedis userResiInfoRedis;
+    private UserResiInfoRedis userResiInfoRedis;
-	@Autowired
+    @Autowired
-	private UserResiRegisterVisitService userResiRegisterVisitService;
+    private UserResiRegisterVisitService userResiRegisterVisitService;
-	@Autowired
+    @Autowired
-	private UserResiInfoDao userResiInfoDao;
+    private UserResiInfoDao userResiInfoDao;
-	@Autowired
+    @Autowired
-	private RegisterRelationService registerRelationService;
+    private RegisterRelationService registerRelationService;
-
+    @Autowired
-	@Override
+    private UserRoleService userRoleService;
-	public PageData<UserResiInfoDTO> page(Map<String, Object> params) {
+
-		IPage<UserResiInfoEntity> page = baseDao.selectPage(
+    @Override
-				getPage(params, FieldConstant.CREATED_TIME, false),
+    public PageData<UserResiInfoDTO> page(Map<String, Object> params) {
-				getWrapper(params)
+        IPage<UserResiInfoEntity> page = baseDao.selectPage(
-		);
+                getPage(params, FieldConstant.CREATED_TIME, false),
-		return getPageData(page, UserResiInfoDTO.class);
+                getWrapper(params)
-	}
+        );
-
+        return getPageData(page, UserResiInfoDTO.class);
-	@Override
+    }
-	public List<UserResiInfoDTO> list(Map<String, Object> params) {
+
-		List<UserResiInfoEntity> entityList = baseDao.selectList(getWrapper(params));
+    @Override
-
+    public List<UserResiInfoDTO> list(Map<String, Object> params) {
-		return ConvertUtils.sourceToTarget(entityList, UserResiInfoDTO.class);
+        List<UserResiInfoEntity> entityList = baseDao.selectList(getWrapper(params));
-	}
+
-
+        return ConvertUtils.sourceToTarget(entityList, UserResiInfoDTO.class);
-	private QueryWrapper<UserResiInfoEntity> getWrapper(Map<String, Object> params) {
+    }
-		String id = (String) params.get(FieldConstant.ID_HUMP);
+
-
+    private QueryWrapper<UserResiInfoEntity> getWrapper(Map<String, Object> params) {
-		QueryWrapper<UserResiInfoEntity> wrapper = new QueryWrapper<>();
+        String id = (String) params.get(FieldConstant.ID_HUMP);
-		wrapper.eq(StringUtils.isNotBlank(id), FieldConstant.ID, id);
+
-
+        QueryWrapper<UserResiInfoEntity> wrapper = new QueryWrapper<>();
-		return wrapper;
+        wrapper.eq(StringUtils.isNotBlank(id), FieldConstant.ID, id);
-	}
+
-
+        return wrapper;
-	@Override
+    }
-	public UserResiInfoDTO get(String id) {
+
-		UserResiInfoEntity entity = baseDao.selectById(id);
+    @Override
-		return ConvertUtils.sourceToTarget(entity, UserResiInfoDTO.class);
+    public UserResiInfoDTO get(String id) {
-	}
+        UserResiInfoEntity entity = baseDao.selectById(id);
-
+        return ConvertUtils.sourceToTarget(entity, UserResiInfoDTO.class);
-	@Override
+    }
-	@Transactional(rollbackFor = Exception.class)
+
-	public void save(UserResiInfoDTO dto) {
+    @Override
-		UserResiInfoEntity entity = ConvertUtils.sourceToTarget(dto, UserResiInfoEntity.class);
+    @Transactional(rollbackFor = Exception.class)
-		insert(entity);
+    public void save(UserResiInfoDTO dto) {
-	}
+        UserResiInfoEntity entity = ConvertUtils.sourceToTarget(dto, UserResiInfoEntity.class);
-
+        insert(entity);
-	@Override
+    }
-	@Transactional(rollbackFor = Exception.class)
+
-	public void update(UserResiInfoDTO dto) {
+    @Override
-		UserResiInfoEntity entity = ConvertUtils.sourceToTarget(dto, UserResiInfoEntity.class);
+    @Transactional(rollbackFor = Exception.class)
-		updateById(entity);
+    public void update(UserResiInfoDTO dto) {
-	}
+        UserResiInfoEntity entity = ConvertUtils.sourceToTarget(dto, UserResiInfoEntity.class);
-
+        updateById(entity);
-	@Override
+    }
-	@Transactional(rollbackFor = Exception.class)
+
-	public void delete(String[] ids) {
+    @Override
-		// 逻辑删除（@TableLogic 注解）
+    @Transactional(rollbackFor = Exception.class)
-		baseDao.deleteBatchIds(Arrays.asList(ids));
+    public void delete(String[] ids) {
-	}
+        // 逻辑删除（@TableLogic 注解）
-
+        baseDao.deleteBatchIds(Arrays.asList(ids));
-	/**
+    }
-	 * @param userResiInfoFormDTO
+
-	 * @return com.epmet.commons.tools.utils.Result<com.epmet.dto.UserResiInfoDTO>
+    /**
-	 * @Author yinzuomei
+     * @param userResiInfoFormDTO
-	 * @Description 查询用户注册信息
+     * @return com.epmet.commons.tools.utils.Result<com.epmet.dto.UserResiInfoDTO>
-	 * @Date 2020/3/30 11:07
+     * @Author yinzuomei
-	 **/
+     * @Description 查询用户注册信息
-	@Override
+     * @Date 2020/3/30 11:07
-	public Result<UserResiInfoDTO> getUserResiInfoDTO(UserResiInfoFormDTO userResiInfoFormDTO) {
+     **/
-		UserResiInfoDTO userResiInfoDTO = baseDao.selectUserResiInfoDTO(userResiInfoFormDTO);
+    @Override
-		if (null != userResiInfoDTO) {
+    public Result<UserResiInfoDTO> getUserResiInfoDTO(UserResiInfoFormDTO userResiInfoFormDTO) {
-			String showName = userResiInfoDTO.getStreet() + "-" + userResiInfoDTO.getSurname() + userResiInfoDTO.getName();
+        UserResiInfoDTO userResiInfoDTO = baseDao.selectUserResiInfoDTO(userResiInfoFormDTO);
-			userResiInfoDTO.setShowName(showName);
+        if (null != userResiInfoDTO) {
-		}
+            String showName = userResiInfoDTO.getStreet() + "-" + userResiInfoDTO.getSurname() + userResiInfoDTO.getName();
-		return new Result<UserResiInfoDTO>().ok(userResiInfoDTO);
+            userResiInfoDTO.setShowName(showName);
-	}
+        }
-
+        return new Result<UserResiInfoDTO>().ok(userResiInfoDTO);
-	@Override
+    }
-	public Result submit(UserResiInfoDTO userResiInfoDTO) {
+
-		Result result = new Result();
+    @Override
-		//1:手机验证码数据校验//TODO
+    public Result submit(UserResiInfoDTO userResiInfoDTO) {
-
+        Result result = new Result();
-		//2:验证码校验失败则更新行为记录表数据 返回前台结果
+        //1:手机验证码数据校验//TODO
-		if (false) {
+
-			userResiRegisterVisitService.updateResiRegisterVisit(false, userResiInfoDTO);
+        //2:验证码校验失败则更新行为记录表数据 返回前台结果
-			result.error(UserResiRegisterConstant.PARAMETER_ERROR);
+        if (false) {
-			result.setMsg(UserResiRegisterConstant.MOBILECODE_EXCEPTION);
+            userResiRegisterVisitService.updateResiRegisterVisit(false, userResiInfoDTO);
-			return result;
+            result.error(UserResiRegisterConstant.PARAMETER_ERROR);
-		}
+            result.setMsg(UserResiRegisterConstant.MOBILECODE_EXCEPTION);
-		//3:校验成功 数据存入居民注册表 更新行为记录表数据
+            return result;
-		saveUserResiInfo(userResiInfoDTO);
+        }
-		userResiRegisterVisitService.updateResiRegisterVisit(true, userResiInfoDTO);
+        //3:校验成功 数据存入居民注册表 新增角色 更新行为记录表数据
-		//4:居民注册关系表新增数据 首次注册数加一 注册数加一 参与数加一
+        saveUserResiInfo(userResiInfoDTO);
-		registerRelationService.saveRegisterRelation(userResiInfoDTO);
+        userResiRegisterVisitService.updateResiRegisterVisit(true, userResiInfoDTO);
-		return result;
+        //4:居民注册关系表新增数据 首次注册数加一 注册数加一 参与数加一
-	}
+        registerRelationService.saveRegisterRelation(userResiInfoDTO);
-
+        return result;
-	/**
+    }
-	 * 居民注册信息表新增数据
+
-	 *
+    /**
-	 * @param userResiInfoDTO
+     * 居民注册信息表新增数据,角色表新增角色
-	 * @Author sun
+     *
-	 */
+     * @param userResiInfoDTO
-	@Transactional(rollbackFor = Exception.class)
+     * @Author sun
-	public void saveUserResiInfo(UserResiInfoDTO userResiInfoDTO) {
+     */
-		Date date = new Date();
+    @Transactional(rollbackFor = Exception.class)
-		userResiInfoDTO.setId(IdWorker.get32UUID());
+    public Result saveUserResiInfo(UserResiInfoDTO userResiInfoDTO) {
-		userResiInfoDTO.setDelFlag(NumConstant.ZERO);
+        //1:注册信息表新增数据
-		userResiInfoDTO.setRevision(NumConstant.ZERO);
+        Date date = new Date();
-		userResiInfoDTO.setCreatedBy(userResiInfoDTO.getUserId());
+        userResiInfoDTO.setId(IdWorker.get32UUID());
-		userResiInfoDTO.setCreatedTime(date);
+        userResiInfoDTO.setDelFlag(NumConstant.ZERO);
-		userResiInfoDTO.setUpdatedBy(userResiInfoDTO.getUserId());
+        userResiInfoDTO.setRevision(NumConstant.ZERO);
-		userResiInfoDTO.setUpdatedTime(date);
+        userResiInfoDTO.setCreatedBy(userResiInfoDTO.getUserId());
-		userResiInfoDao.saveUserResiInfo(userResiInfoDTO);
+        userResiInfoDTO.setCreatedTime(date);
-	}
+        userResiInfoDTO.setUpdatedBy(userResiInfoDTO.getUserId());
-
+        userResiInfoDTO.setUpdatedTime(date);
-	/**
+        userResiInfoDao.saveUserResiInfo(userResiInfoDTO);
-	 * @param verificationCodeFormDTO
+        //2:角色表新增角色数据
-	 * @Author sun
+        userRoleService.saveResiRole(userResiInfoDTO);
-	 * @Description 居民端-居民注册根据手机号获取验证码
+        return new Result();
-	 **/
+    }
-	@Override
+
-	public Result getVerificationCode(VerificationCodeFormDTO verificationCodeFormDTO) {
+    /**
-		Result result = new Result();
+     * @param verificationCodeFormDTO
-		//1:更新居民注册访问记录表数据
+     * @Author sun
-		userResiRegisterVisitService.updateResiVisitOperate(verificationCodeFormDTO);
+     * @Description 居民端-居民注册根据手机号获取验证码
-		//2:判断手机号是否可用
+     **/
-		if (!getResiInfoByMobile(verificationCodeFormDTO.getMobile())) {
+    @Override
-			result.error(UserResiRegisterConstant.PARAMETER_ERROR);
+    public Result getVerificationCode(VerificationCodeFormDTO verificationCodeFormDTO) {
-			result.setMsg(UserResiRegisterConstant.MOBILE_EXIST);
+        Result result = new Result();
-			return result;
+        //1:更新居民注册访问记录表数据
-		}
+        userResiRegisterVisitService.updateResiVisitOperate(verificationCodeFormDTO);
-		//3:调用短信服务 生成验证码发送短信 TODO
+        //2:判断手机号是否可用
-
+        if (!getResiInfoByMobile(verificationCodeFormDTO.getMobile())) {
-		//4:将验证码存入redis TODO
+            result.error(UserResiRegisterConstant.PARAMETER_ERROR);
-
+            result.setMsg(UserResiRegisterConstant.MOBILE_EXIST);
-		return result;
+            return result;
-	}
+        }
-
+        //3:调用短信服务 生成验证码发送短信 TODO
-	@Override
+        String verificationCode = "TODO";
-	public Result saveResiInfo(UserResiInfoDTO userResiInfoDTO) {
+
-		Result result = new Result();
+        //4:将验证码存入redis TODO
-
+        userResiInfoRedis.setUserResiMobileCode(verificationCodeFormDTO.getUserId(), verificationCodeFormDTO.getMobile(), verificationCode);
-		//判断手机号是否可用
+
-		if (getResiInfoByMobile(userResiInfoDTO.getRegMobile())) {
+        return result;
+    }
+
+    @Override
+    public Result saveResiInfo(UserResiInfoDTO userResiInfoDTO) {
+        Result result = new Result();
+
+        //判断手机号是否可用
+        if (getResiInfoByMobile(userResiInfoDTO.getRegMobile())) {
             UserResiRegisterVisitEntity visitEntity = new UserResiRegisterVisitEntity();
             visitEntity.setCustomerId(userResiInfoDTO.getCustomerId());
             visitEntity.setGridId(userResiInfoDTO.getGridId());
@@ -215,30 +224,30 @@ public class UserResiInfoServiceImpl extends BaseServiceImpl<UserResiInfoDao, Us
             visitEntity.setVisitTime(new Date());
             userResiRegisterVisitService.insert(visitEntity);
             //数据存入居民注册表
-			userResiInfoDTO.setResiVisitId(visitEntity.getId());
+            userResiInfoDTO.setResiVisitId(visitEntity.getId());
-			saveUserResiInfo(userResiInfoDTO);
+            saveUserResiInfo(userResiInfoDTO);
             //4:居民注册关系表新增数据 首次注册数加一 注册数加一 参与数加一
             registerRelationService.saveRegisterRelation(userResiInfoDTO);
-		}
+        }
-
+
-		return result;
+        return result;
-	}
+    }
-
+
-	/**
+    /**
-	 * 判断手机号是否可用-根据手机号查询居民注册信息(user_resi_info)表数据
+     * 判断手机号是否可用-根据手机号查询居民注册信息(user_resi_info)表数据
-	 *
+     *
-	 * @param mobile
+     * @param mobile
-	 * @return
+     * @return
-	 * @Author sun
+     * @Author sun
-	 */
+     */
-	private Boolean getResiInfoByMobile(String mobile) {
+    private Boolean getResiInfoByMobile(String mobile) {
-		Boolean bl = true;
+        Boolean bl = true;
-
+
-		List<UserResiInfoDTO> list = userResiInfoDao.selectResiInfoByMobile(mobile);
+        List<UserResiInfoDTO> list = userResiInfoDao.selectResiInfoByMobile(mobile);
-		if (list.size() > 0) {
+        if (list.size() > 0) {
-			bl = false;
+            bl = false;
-		}
+        }
-		return bl;
+        return bl;
-	}
+    }
 
 }

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

@@ -19,24 +19,33 @@ package com.epmet.service.impl;
 
 import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
 import com.baomidou.mybatisplus.core.metadata.IPage;
+import com.baomidou.mybatisplus.core.toolkit.IdWorker;
 import com.epmet.commons.mybatis.service.impl.BaseServiceImpl;
+import com.epmet.commons.tools.constant.EpmetRoleKeyConstant;
+import com.epmet.commons.tools.constant.NumConstant;
 import com.epmet.commons.tools.page.PageData;
 import com.epmet.commons.tools.utils.ConvertUtils;
 import com.epmet.commons.tools.constant.FieldConstant;
 import com.epmet.commons.tools.utils.Result;
 import com.epmet.dao.UserRoleDao;
+import com.epmet.dto.RoleDTO;
+import com.epmet.dto.UserResiInfoDTO;
 import com.epmet.dto.UserRoleDTO;
 import com.epmet.dto.form.UserRoleFormDTO;
 import com.epmet.dto.result.UserRoleResultDTO;
 import com.epmet.entity.UserRoleEntity;
 import com.epmet.redis.UserRoleRedis;
+import com.epmet.service.RoleService;
 import com.epmet.service.UserRoleService;
 import org.apache.commons.lang3.StringUtils;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.stereotype.Service;
 import org.springframework.transaction.annotation.Transactional;
 
 import java.util.Arrays;
+import java.util.Date;
 import java.util.List;
 import java.util.Map;
 
@@ -49,8 +58,13 @@ import java.util.Map;
 @Service
 public class UserRoleServiceImpl extends BaseServiceImpl<UserRoleDao, UserRoleEntity> implements UserRoleService {
 
+    private static final Logger log = LoggerFactory.getLogger(UserRoleServiceImpl.class);
     @Autowired
     private UserRoleRedis userRoleRedis;
+    @Autowired
+    private RoleService roleService;
+    @Autowired
+    private UserRoleDao userRoleDao;
 
     @Override
     public PageData<UserRoleDTO> page(Map<String, Object> params) {
@@ -68,8 +82,8 @@ public class UserRoleServiceImpl extends BaseServiceImpl<UserRoleDao, UserRoleEn
         return ConvertUtils.sourceToTarget(entityList, UserRoleDTO.class);
     }
 
-    private QueryWrapper<UserRoleEntity> getWrapper(Map<String, Object> params){
+    private QueryWrapper<UserRoleEntity> getWrapper(Map<String, Object> params) {
-        String id = (String)params.get(FieldConstant.ID_HUMP);
+        String id = (String) params.get(FieldConstant.ID_HUMP);
 
         QueryWrapper<UserRoleEntity> wrapper = new QueryWrapper<>();
         wrapper.eq(StringUtils.isNotBlank(id), FieldConstant.ID, id);
@@ -105,9 +119,9 @@ public class UserRoleServiceImpl extends BaseServiceImpl<UserRoleDao, UserRoleEn
     }
 
     /**
+     * @return UserRoleResultDTO
      * @Description 根据用户Id、来源app、客户Id查询用户角色
      * @Param userRoleFormDTO
-     * @return UserRoleResultDTO
      * @Author wangc
      * @Date 2020.03.30 15:35
      **/
@@ -116,4 +130,33 @@ public class UserRoleServiceImpl extends BaseServiceImpl<UserRoleDao, UserRoleEn
         return new Result<List<UserRoleResultDTO>>().ok(baseDao.getUserRoleInfo(userRoleFormDTO));
     }
 
+    /**
+     * @Description 居民注册成功添加居民角色
+     * @Author sun
+     **/
+    @Override
+    public Result saveResiRole(UserResiInfoDTO userResiInfoDTO) {
+        //1:查询角色Id
+        RoleDTO roleDTO = new RoleDTO();
+        roleDTO.setApp(userResiInfoDTO.getApp());
+        roleDTO.setRoleKey(EpmetRoleKeyConstant.REGISTERED_RESI);
+        Result<RoleDTO> result = roleService.getRoleByKey(roleDTO);
+        RoleDTO role = result.getData();
+        //2:新增角色数据
+        UserRoleDTO userRoleDTO = new UserRoleDTO();
+        userRoleDTO.setCustomerId(userResiInfoDTO.getCustomerId());
+        userRoleDTO.setUserId(userResiInfoDTO.getUserId());
+        userRoleDTO.setRoleId(role.getId());
+        Date date = new Date();
+        userRoleDTO.setId(IdWorker.get32UUID());
+        userRoleDTO.setDelFlag(NumConstant.ZERO);
+        userRoleDTO.setRevision(NumConstant.ZERO);
+        userRoleDTO.setCreatedBy(userResiInfoDTO.getUserId());
+        userRoleDTO.setCreatedTime(date);
+        userRoleDTO.setUpdatedBy(userResiInfoDTO.getUserId());
+        userRoleDTO.setUpdatedTime(date);
+        userRoleDao.saveResiRole(userRoleDTO);
+        return new Result();
+    }
+
 }

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

@@ -16,5 +16,26 @@
         <result property="updatedTime" column="UPDATED_TIME"/>
     </resultMap>
 
+    <sql id="sql">
+        er.id AS "id",
+        er.app AS "app",
+        er.role_name AS "roleName",
+        er.role_key AS "roleKey",
+        er.del_flag AS "delflag",
+        er.revision AS "revision",
+        er.created_by AS "createdby",
+        er.created_time AS "createdtime",
+        er.updated_by AS "updatedby",
+        er.updated_time AS "updatedtime"
+    </sql>
+
+    <select id="selectRoleByKey" parameterType="com.epmet.dto.RoleDTO" resultType="com.epmet.dto.RoleDTO">
+        SELECT
+        <include refid="sql"></include>
+        FROM epmet_role er
+        WHERE er.del_flag = '0'
+        AND er.app = #{app}
+        AND er.role_key = #{roleKey}
+    </select>
 
 </mapper>

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

@@ -16,32 +16,58 @@
         <result property="updatedTime" column="UPDATED_TIME"/>
     </resultMap>
 
+    <insert id="saveResiRole" parameterType="com.epmet.dto.UserRoleDTO">
+        INSERT INTO user_role (
+            id,
+            customer_id,
+            user_id,
+            role_id,
+            del_flag,
+            revision,
+            created_by,
+            created_time,
+            updated_by,
+            updated_time
+        )VALUES(
+            #{id},
+            #{customerId},
+            #{userId},
+            #{roleId},
+            #{delFlag},
+            #{revision},
+            #{createdBy},
+            #{createdTime},
+            #{updatedBy},
+            #{updatedTime}
+        )
+    </insert>
 
 
-    <select id="getUserRoleInfo" parameterType="com.epmet.dto.form.UserRoleFormDTO" resultType="com.epmet.dto.result.UserRoleResultDTO" >
+    <select id="getUserRoleInfo" parameterType="com.epmet.dto.form.UserRoleFormDTO"
+            resultType="com.epmet.dto.result.UserRoleResultDTO">
 
-    SELECT
+        SELECT
         DISTINCT
         er.ROLE_NAME,
         er.ROLE_KEY
-    FROM
+        FROM
         USER_ROLE ur
         JOIN EPMET_ROLE er ON ur.ROLE_ID = er.ID
-    <where>
+        <where>
             er.DEL_FLAG = 0
             AND
             ur.DEL_FLAG = 0
             AND
             ur.USER_ID = #{userId}
-        <if test='null != app and "" != app'>
+            <if test='null != app and "" != app'>
-            AND
+                AND
-            er.APP = #{app}
+                er.APP = #{app}
-        </if>
+            </if>
-        <if test='null != customerId and "" != customerId'>
+            <if test='null != customerId and "" != customerId'>
-            AND
+                AND
-            ur.CUSTOMER_ID = #{customerId}
+                ur.CUSTOMER_ID = #{customerId}
-        </if>
+            </if>
-    </where>
+        </where>
 
     </select>