+ * This program is free software: you can redistribute it and/or modify
+ * it under the terms of the GNU General Public License as published by
+ * the Free Software Foundation, either version 3 of the License, or
+ * (at your option) any later version.
+ *
+ * This program is distributed in the hope that it will be useful,
+ * but WITHOUT ANY WARRANTY; without even the implied warranty of
+ * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
+ * GNU General Public License for more details.
+ *
+ * This program is free software: you can redistribute it and/or modify
+ * it under the terms of the GNU General Public License as published by
+ * the Free Software Foundation, either version 3 of the License, or
+ * (at your option) any later version.
+ *
+ * This program is distributed in the hope that it will be useful,
+ * but WITHOUT ANY WARRANTY; without even the implied warranty of
+ * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
+ * GNU General Public License for more details.
+ *
+ * This program is free software: you can redistribute it and/or modify
+ * it under the terms of the GNU General Public License as published by
+ * the Free Software Foundation, either version 3 of the License, or
+ * (at your option) any later version.
+ *
+ * This program is distributed in the hope that it will be useful,
+ * but WITHOUT ANY WARRANTY; without even the implied warranty of
+ * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
+ * GNU General Public License for more details.
+ *
+ * You should have received a copy of the GNU General Public License
+ * along with this program. If not, see .
+ */
+
+package com.epmet.controller;
+
+import com.epmet.commons.tools.page.PageData;
+import com.epmet.commons.tools.utils.ExcelUtils;
+import com.epmet.commons.tools.utils.Result;
+import com.epmet.commons.tools.validator.AssertUtils;
+import com.epmet.commons.tools.validator.ValidatorUtils;
+import com.epmet.commons.tools.validator.group.AddGroup;
+import com.epmet.commons.tools.validator.group.DefaultGroup;
+import com.epmet.commons.tools.validator.group.UpdateGroup;
+import com.epmet.dto.IcResiUserAttachmentDTO;
+import com.epmet.excel.ProjectProcessAttachmentExcel;
+import com.epmet.service.IcResiUserAttachmentService;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.web.bind.annotation.*;
+
+import javax.servlet.http.HttpServletResponse;
+import java.util.List;
+import java.util.Map;
+
+
+/**
+ * 项目节点附件表
+ *
+ * @author generator generator@elink-cn.com
+ * @since v1.0.0 2020-12-21
+ */
+@RestController
+@RequestMapping("icresiuserattachment")
+public class IcResiUserAttachmentController {
+
+ @Autowired
+ private IcResiUserAttachmentService icResiUserAttachmentService;
+
+ @GetMapping("page")
+ public Result> page(@RequestParam Map params){
+ PageData page = icResiUserAttachmentService.page(params);
+ return new Result>().ok(page);
+ }
+
+ @GetMapping("{id}")
+ public Result get(@PathVariable("id") String id){
+ IcResiUserAttachmentDTO data = icResiUserAttachmentService.get(id);
+ return new Result().ok(data);
+ }
+
+ @PostMapping
+ public Result save(@RequestBody IcResiUserAttachmentDTO dto){
+ //效验数据
+ ValidatorUtils.validateEntity(dto, AddGroup.class, DefaultGroup.class);
+ icResiUserAttachmentService.save(dto);
+ return new Result();
+ }
+
+ @PutMapping
+ public Result update(@RequestBody IcResiUserAttachmentDTO dto){
+ //效验数据
+ ValidatorUtils.validateEntity(dto, UpdateGroup.class, DefaultGroup.class);
+ icResiUserAttachmentService.update(dto);
+ return new Result();
+ }
+
+ @DeleteMapping
+ public Result delete(@RequestBody String[] ids){
+ //效验数据
+ AssertUtils.isArrayEmpty(ids, "id");
+ icResiUserAttachmentService.delete(ids);
+ return new Result();
+ }
+
+ @GetMapping("export")
+ public void export(@RequestParam Map params, HttpServletResponse response) throws Exception {
+ List list = icResiUserAttachmentService.list(params);
+ ExcelUtils.exportExcelToTarget(response, null, list, ProjectProcessAttachmentExcel.class);
+ }
+
+}
\ No newline at end of file
diff --git a/epmet-user/epmet-user-server/src/main/java/com/epmet/controller/IcResiUserController.java b/epmet-user/epmet-user-server/src/main/java/com/epmet/controller/IcResiUserController.java
index 5a44547fc8..4576a0d599 100644
--- a/epmet-user/epmet-user-server/src/main/java/com/epmet/controller/IcResiUserController.java
+++ b/epmet-user/epmet-user-server/src/main/java/com/epmet/controller/IcResiUserController.java
@@ -229,16 +229,51 @@ public class IcResiUserController implements ResultDataResolver {
@PostMapping("edit")
public Result edit(@LoginUser TokenDto tokenDto, @RequestBody List formDTO) {
String resiUserId = icResiUserService.edit(tokenDto, formDTO);
+ //推送MQ事件
+ editResiMq(tokenDto.getCustomerId(), resiUserId);
+ return new Result();
+ }
+
+ /**
+ * 租客房东根据身份证更新头像
+ *
+ * @param formDTO
+ * @return com.epmet.commons.tools.utils.Result
+ * @author zhy
+ * @date 2022/4/26 10:48
+ */
+ @PostMapping("rent/rentUpdate")
+ public Result rentUpdate(@RequestBody RentTenantFormDTO formDTO) {
+ String resiUserId = icResiUserService.rentUpdate(formDTO);
+ //推送MQ事件
+ editResiMq(formDTO.getCustomerId(), resiUserId);
+ return new Result();
+ }
+
+ private void editResiMq(String customerId, String userId) {
//推送MQ事件
IcResiUserAddMQMsg mqMsg = new IcResiUserAddMQMsg();
- mqMsg.setCustomerId(tokenDto.getCustomerId());
- log.info("customer id is {}",tokenDto.getCustomerId());
- mqMsg.setIcResiUser(resiUserId);
+ mqMsg.setCustomerId(customerId);
+ log.info("customer id is {}", customerId);
+ mqMsg.setIcResiUser(userId);
SystemMsgFormDTO form = new SystemMsgFormDTO();
form.setMessageType(SystemMessageType.IC_RESI_USER_EDIT);
form.setContent(mqMsg);
epmetMessageOpenFeignClient.sendSystemMsgByMQ(form);
- return new Result();
+ }
+
+ /**
+ * 租客房东黑名单查询个人数据
+ *
+ * @param formDTO
+ * @return com.epmet.commons.tools.utils.Result
+ * @author zhy
+ * @date 2022/4/26 15:51
+ */
+ @PostMapping("rent/tenantData")
+ public Result tenantData(@RequestBody RentTenantDataFormDTO formDTO) {
+ ValidatorUtils.validateEntity(formDTO, RentTenantDataFormDTO.class);
+ return new Result().ok(icResiUserService.tenantData(formDTO));
}
/**
@@ -255,12 +290,13 @@ public class IcResiUserController implements ResultDataResolver {
/**
* 根据ic_resi_user找家属
+ *
* @param icResiUserId
* @return
*/
@GetMapping("findfamilymem/{icResiUserId}")
- public Result findFamilyMem(@PathVariable("icResiUserId") String icResiUserId){
- if(StringUtils.isNotBlank(icResiUserId)){
+ public Result findFamilyMem(@PathVariable("icResiUserId") String icResiUserId) {
+ if (StringUtils.isNotBlank(icResiUserId)) {
return new Result().ok(icResiUserService.findFamilyMem(icResiUserId));
}
return new Result<>();
@@ -272,7 +308,7 @@ public class IcResiUserController implements ResultDataResolver {
pageFormDTO.setCustomerId(tokenDto.getCustomerId());
pageFormDTO.setStaffId(tokenDto.getUserId());
ValidatorUtils.validateEntity(pageFormDTO, IcResiUserPageFormDTO.AddUserInternalGroup.class);
- if(null==pageFormDTO.getConditions()){
+ if (null == pageFormDTO.getConditions()) {
pageFormDTO.setConditions(new ArrayList<>());
}
return new Result>>().ok(icResiUserService.pageResiMap(pageFormDTO));
@@ -304,12 +340,12 @@ public class IcResiUserController implements ResultDataResolver {
* @return void
* @author LiuJanJun
* @date 2021/11/19 4:24 下午
- * @remark:分页批量导出 oss目录在 各个环境对应的前缀文件夹/file-template/resi-template/客户ID.xlsx,
+ * @remark:分页批量导出 oss目录在 各个环境对应的前缀文件夹/file-template/resi-template/客户ID.xlsx,
* 如果某个客户需要更新模版 则替换掉上面的模版文件；然后 更新缓存里的值或者删除也行 再导出就会下载新的模版了
*/
@NoRepeatSubmit
@RequestMapping(value = "/exportExcel")
- public void exportExcelByEasyExcel(@RequestHeader String customerId,@LoginUser TokenDto tokenDto, @RequestBody IcResiUserPageFormDTO pageFormDTO, HttpServletResponse response) throws Exception {
+ public void exportExcelByEasyExcel(@RequestHeader String customerId, @LoginUser TokenDto tokenDto, @RequestBody IcResiUserPageFormDTO pageFormDTO, HttpServletResponse response) throws Exception {
//tokenDto.setUserId("9e37adcce6472152e6508a19d3683e02");
long startM = System.currentTimeMillis();
CustomerStaffInfoCacheResult staffInfoCacheResult = CustomerStaffRedis.getStaffInfo(customerId, tokenDto.getUserId());
@@ -335,23 +371,23 @@ public class IcResiUserController implements ResultDataResolver {
List resiFormAllItems = icResiUserService.listFormItems(customerId, IcFormCodeEnum.RESI_BASE_INFO.getCode());
Map allItemMap = resiFormAllItems.stream().collect(Collectors.toMap(FormItemResult::getItemId, o -> o));
Map map = new HashMap<>();
- allItemMap.values().forEach(item->{
+ allItemMap.values().forEach(item -> {
String tableName = item.getTableName();
ExportResiUserItemDTO exportItem = map.getOrDefault(tableName, new ExportResiUserItemDTO());
- map.putIfAbsent(tableName,exportItem);
+ map.putIfAbsent(tableName, exportItem);
String columnName = item.getColumnName().concat(item.getColumnNum() == NumConstant.ZERO ? StrConstant.EPMETY_STR : item.getColumnNum().toString());
- exportItem.getItemMap().put(columnName,item);
- if (Constant.OPITON_SOURCE_REMOTE.equals(item.getOptionSourceType())&&item.getOptionSourceValue().contains(StrConstant.QUESTION_MARK)){
+ exportItem.getItemMap().put(columnName, item);
+ if (Constant.OPITON_SOURCE_REMOTE.equals(item.getOptionSourceType()) && item.getOptionSourceValue().contains(StrConstant.QUESTION_MARK)) {
//多个参数
String[] paramArr = item.getOptionSourceValue().split(StrConstant.QUESTION_MARK_TRANSFER)[NumConstant.ONE].split(StrConstant.AND_MARK);
- Arrays.stream(paramArr).forEach(o->{
+ Arrays.stream(paramArr).forEach(o -> {
FormItemResult value = allItemMap.get(o);
- if (value == null){
+ if (value == null) {
return;
}
- Set conditionSet = exportItem.getRemoteItemConditionMap().getOrDefault(item.getItemId(),new HashSet<>());
+ Set conditionSet = exportItem.getRemoteItemConditionMap().getOrDefault(item.getItemId(), new HashSet<>());
conditionSet.add(value);
- exportItem.getRemoteItemConditionMap().putIfAbsent(item.getItemId(),conditionSet);
+ exportItem.getRemoteItemConditionMap().putIfAbsent(item.getItemId(), conditionSet);
});
}
});
@@ -378,7 +414,7 @@ public class IcResiUserController implements ResultDataResolver {
stopSearchSet.add(tableName);
}
//如果没有 构建新的writeSheet
- WriteSheet writeSheet = childTableWriteSheetMap.getOrDefault(tableName,EasyExcel.writerSheet(tableEnum.getSheetNo()).build());
+ WriteSheet writeSheet = childTableWriteSheetMap.getOrDefault(tableName, EasyExcel.writerSheet(tableEnum.getSheetNo()).build());
childTableWriteSheetMap.putIfAbsent(tableName, writeSheet);
//写入数据
excelWriter.fill(new FillWrapper("t" + (tableEnum.getSheetNo() + NumConstant.ONE), resiResultList), writeSheet);
@@ -391,10 +427,10 @@ public class IcResiUserController implements ResultDataResolver {
}
} finally {
- if (excelWriter != null){
+ if (excelWriter != null) {
excelWriter.finish();
}
- log.info("exportExcelByEasyExcel resi info cost time:{}s",(System.currentTimeMillis()-startM)/NumConstant.ONE_THOUSAND);
+ log.info("exportExcelByEasyExcel resi info cost time:{}s", (System.currentTimeMillis() - startM) / NumConstant.ONE_THOUSAND);
}
}
@@ -404,7 +440,7 @@ public class IcResiUserController implements ResultDataResolver {
* @param customerId
* @return
*/
- private File getIcResiTemplateFile(String customerId, IcUserTemplateEnums template) throws Exception{
+ private File getIcResiTemplateFile(String customerId, IcUserTemplateEnums template) throws Exception {
String fileType = ".xlsx";
String fileName = customerId + fileType;
File file = new File(IC_RESI_DOWNLOAD_DIR.resolve(fileName).toString());
@@ -422,11 +458,11 @@ public class IcResiUserController implements ResultDataResolver {
if (result == null || !result.success()) {
log.warn("获取居民模版失败,path:{},走默认模版", ossFilePath);
InputStream resourceAsStream = this.getClass().getClassLoader().getResourceAsStream(template.getPathInApp());
- FileUtils.copyInputStreamToFile(resourceAsStream,file);
- log.warn("getIcResiTemplateFile copy default file to template,customerId:{}",customerId);
+ FileUtils.copyInputStreamToFile(resourceAsStream, file);
+ log.warn("getIcResiTemplateFile copy default file to template,customerId:{}", customerId);
} else {
- log.warn("getIcResiTemplateFile reload file form oss default file to template,customerId:{}",customerId);
- FileUtils.writeByteArrayToFile(file,result.getData());
+ log.warn("getIcResiTemplateFile reload file form oss default file to template,customerId:{}", customerId);
+ FileUtils.writeByteArrayToFile(file, result.getData());
}
redisUtils.hSet(RedisKeys.getResiTempChangedKey(customerId), serverIp, NumConstant.ZERO_STR);
return file;
@@ -441,7 +477,7 @@ public class IcResiUserController implements ResultDataResolver {
*/
@NoRepeatSubmit
@PostMapping("importExcel")
- public Result importExcelByEasyExcel(@RequestHeader("customerId") String customerId,@RequestPart("file") MultipartFile file, HttpServletRequest multipartRequest, HttpServletResponse response) {
+ public Result importExcelByEasyExcel(@RequestHeader("customerId") String customerId, @RequestPart("file") MultipartFile file, HttpServletRequest multipartRequest, HttpServletResponse response) {
if (file.isEmpty()) {
throw new RenException("请上传文件");
}
@@ -472,7 +508,7 @@ public class IcResiUserController implements ResultDataResolver {
executorService.execute(() -> {
boolean isAllSuccess = false;
try {
- List formItemList = icResiUserService.listFormItems(customerId,IcFormCodeEnum.RESI_BASE_INFO.getCode());
+ List formItemList = icResiUserService.listFormItems(customerId, IcFormCodeEnum.RESI_BASE_INFO.getCode());
isAllSuccess = icResiUserImportService.importIcResiInfoFromExcel(importTaskId, formItemList, importTempFileSavePath.toString(), response, IC_RESI_UPLOAD_DIR);
} catch (Throwable e) {
String errorMsg = ExceptionUtils.getThrowableErrorStackTrace(e);
@@ -490,7 +526,7 @@ public class IcResiUserController implements ResultDataResolver {
} finally {
try {
// 都导入成功了没问题，才删除
- if (importTempFileSavePath != null){
+ if (importTempFileSavePath != null) {
if (isAllSuccess) {
Files.delete(importTempFileSavePath);
} else {
@@ -522,9 +558,9 @@ public class IcResiUserController implements ResultDataResolver {
* @date 2021/11/3 9:21 上午
*/
@PostMapping("persondata")
- public Result personData(@LoginUser TokenDto tokenDto,@RequestBody PersonDataFormDTO formDTO) {
+ public Result personData(@LoginUser TokenDto tokenDto, @RequestBody PersonDataFormDTO formDTO) {
formDTO.setCustomerId(tokenDto.getCustomerId());
- ValidatorUtils.validateEntity(formDTO,PersonDataFormDTO.PersonDataForm.class);
+ ValidatorUtils.validateEntity(formDTO, PersonDataFormDTO.PersonDataForm.class);
return new Result().ok(icResiUserService.personData(formDTO));
}
@@ -545,6 +581,7 @@ public class IcResiUserController implements ResultDataResolver {
/**
* 需求： http://zentao.elinkservice.cn/task-view-4193.html 第11条
+ *
* @param formDTO
* @param tokenDto
* @return 根据分类搜索
@@ -594,10 +631,10 @@ public class IcResiUserController implements ResultDataResolver {
}
/**
- * @LoginUser TokenDto tokenDto,
- * 新增需求，需求人列表：展示当前工作人员所属组织+页面已选择所属网格 下的居民列表
* @param formDTO
* @return
+ * @LoginUser TokenDto tokenDto,
+ * 新增需求，需求人列表：展示当前工作人员所属组织+页面已选择所属网格 下的居民列表
*/
@PostMapping("demandusers")
public Result> queryDemandUsers(@RequestBody DemandUserFormDTO formDTO) {
@@ -607,6 +644,7 @@ public class IcResiUserController implements ResultDataResolver {
/**
* 下载ic居民信息导入excel模板
+ *
* @return
*/
@PostMapping("import/download-template")
@@ -637,6 +675,7 @@ public class IcResiUserController implements ResultDataResolver {
/**
* 党员年龄范围统计
+ *
* @Param formDTO
* @Return {@link Result< List< OptionDataResultDTO >>}
* @Author zhaoqifeng
@@ -650,6 +689,7 @@ public class IcResiUserController implements ResultDataResolver {
/**
* 党员年龄列表
+ *
* @Param formDTO
* @Return {@link Result< PageData< PartyMemberEducationResultDTO>>}
* @Author zhaoqifeng
@@ -713,6 +753,7 @@ public class IcResiUserController implements ResultDataResolver {
/**
* 党员学历统计
+ *
* @Param formDTO
* @Return {@link Result< List< OptionDataResultDTO>>}
* @Author zhaoqifeng
@@ -726,6 +767,7 @@ public class IcResiUserController implements ResultDataResolver {
/**
* 党员学历列表
+ *
* @Param formDTO
* @Return {@link Result< PageData< PartyMemberEducationResultDTO>>}
* @Author zhaoqifeng
@@ -795,6 +837,7 @@ public class IcResiUserController implements ResultDataResolver {
/**
* 根据居民id查询居民信息简介
+ *
* @param resiUserId
* @return
*/
@@ -807,12 +850,13 @@ public class IcResiUserController implements ResultDataResolver {
/**
* 获取ic_resi_user
+ *
* @param icResiUserId
* @return
*/
@PostMapping("geticresiuser/{icResiUserId}")
- public Result getIcResiUserDTO(@PathVariable("icResiUserId") String icResiUserId){
- if(StringUtils.isNotBlank(icResiUserId)){
+ public Result getIcResiUserDTO(@PathVariable("icResiUserId") String icResiUserId) {
+ if (StringUtils.isNotBlank(icResiUserId)) {
return new Result().ok(icResiUserService.get(icResiUserId));
}
return new Result<>();
@@ -820,6 +864,7 @@ public class IcResiUserController implements ResultDataResolver {
/**
* 【社区查询】搜索居民们
+ *
* @param input
* @return
*/
@@ -848,33 +893,34 @@ public class IcResiUserController implements ResultDataResolver {
}
/**
- * @Description 【社区查询】人员预警右侧列表
* @param formDTO
* @param tokenDto
+ * @Description 【社区查询】人员预警右侧列表
* @author zxc
* @date 2022/1/17 4:25 下午
*/
@PostMapping("personwarn/rightlist")
- public Result personWarnRightList(@RequestBody PersonWarnRightListFormDTO formDTO,@LoginUser TokenDto tokenDto){
+ public Result personWarnRightList(@RequestBody PersonWarnRightListFormDTO formDTO, @LoginUser TokenDto tokenDto) {
ValidatorUtils.validateEntity(formDTO, PersonWarnRightListFormDTO.PersonWarnRightListForm.class);
- return new Result().ok(icResiUserService.personWarnRightList(formDTO,tokenDto));
+ return new Result().ok(icResiUserService.personWarnRightList(formDTO, tokenDto));
}
/**
* Desc: 根据房屋IDs查询房屋下是否有存在居民的
+ *
* @param ids
* @author zxc
* @date 2022/3/2 10:32 上午
*/
@PostMapping("getexistuserbyhouseids")
- public Result> getExistUserByHouseIds(@RequestBody List ids){
+ public Result> getExistUserByHouseIds(@RequestBody List ids) {
return new Result>().ok(icResiUserService.getExistUserByHouseIds(ids));
}
// public static ThreadLocal tl = new ThreadLocal();
@PostMapping("test-async")
- public Result testAsync(HttpServletRequest request){
+ public Result testAsync(HttpServletRequest request) {
// tl.set("wxz");
executorService.submit(() -> {
try {
diff --git a/epmet-user/epmet-user-server/src/main/java/com/epmet/dao/IcResiUserAttachmentDao.java b/epmet-user/epmet-user-server/src/main/java/com/epmet/dao/IcResiUserAttachmentDao.java
new file mode 100644
index 0000000000..233a0e756c
--- /dev/null
+++ b/epmet-user/epmet-user-server/src/main/java/com/epmet/dao/IcResiUserAttachmentDao.java
@@ -0,0 +1,45 @@
+/**
+ * Copyright 2018 人人开源 https://www.renren.io
+ *
+ * This program is free software: you can redistribute it and/or modify
+ * it under the terms of the GNU General Public License as published by
+ * the Free Software Foundation, either version 3 of the License, or
+ * (at your option) any later version.
+ *
+ * This program is distributed in the hope that it will be useful,
+ * but WITHOUT ANY WARRANTY; without even the implied warranty of
+ * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
+ * GNU General Public License for more details.
+ *
+ * You should have received a copy of the GNU General Public License
+ * along with this program. If not, see .
+ */
+
+package com.epmet.dao;
+
+import com.epmet.commons.mybatis.dao.BaseDao;
+import com.epmet.dto.result.PublicAndInternalFileResultDTO;
+import com.epmet.entity.IcResiUserAttachmentEntity;
+import org.apache.ibatis.annotations.Mapper;
+import org.apache.ibatis.annotations.Param;
+
+import java.util.List;
+
+/**
+ * 项目节点附件表
+ *
+ * @author generator generator@elink-cn.com
+ * @since v1.0.0 2020-12-21
+ */
+@Mapper
+public interface IcResiUserAttachmentDao extends BaseDao {
+
+ /**
+ * @Description 根据项目ID查询附件
+ * @Param projectId
+ * @author zxc
+ * @date 2020/12/21 下午4:33
+ */
+ List selectAttachByProjectId(@Param("projectId")String projectId);
+
+}
\ No newline at end of file
diff --git a/epmet-user/epmet-user-server/src/main/java/com/epmet/dao/IcResiUserDao.java b/epmet-user/epmet-user-server/src/main/java/com/epmet/dao/IcResiUserDao.java
index d3fe22ee44..93c49beb7f 100644
--- a/epmet-user/epmet-user-server/src/main/java/com/epmet/dao/IcResiUserDao.java
+++ b/epmet-user/epmet-user-server/src/main/java/com/epmet/dao/IcResiUserDao.java
@@ -156,6 +156,8 @@ public interface IcResiUserDao extends BaseDao {
**/
IcResiUserDTO getResiUser(IcResiUserDTO dto);
+ IcResiUserDTO getResiUserByIdCard(@Param("idCard") String idCard,@Param("customerId") String customerId);
+
/**
* @param agencyId
* @param gridId
diff --git a/epmet-user/epmet-user-server/src/main/java/com/epmet/entity/IcResiUserAttachmentEntity.java b/epmet-user/epmet-user-server/src/main/java/com/epmet/entity/IcResiUserAttachmentEntity.java
new file mode 100644
index 0000000000..a8bc7dd061
--- /dev/null
+++ b/epmet-user/epmet-user-server/src/main/java/com/epmet/entity/IcResiUserAttachmentEntity.java
@@ -0,0 +1,119 @@
+/**
+ * Copyright 2018 人人开源 https://www.renren.io
+ *
+ * This program is free software: you can redistribute it and/or modify
+ * it under the terms of the GNU General Public License as published by
+ * the Free Software Foundation, either version 3 of the License, or
+ * (at your option) any later version.
+ *
+ * This program is distributed in the hope that it will be useful,
+ * but WITHOUT ANY WARRANTY; without even the implied warranty of
+ * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
+ * GNU General Public License for more details.
+ *
+ * This program is free software: you can redistribute it and/or modify
+ * it under the terms of the GNU General Public License as published by
+ * the Free Software Foundation, either version 3 of the License, or
+ * (at your option) any later version.
+ *
+ * This program is distributed in the hope that it will be useful,
+ * but WITHOUT ANY WARRANTY; without even the implied warranty of
+ * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
+ * GNU General Public License for more details.
+ *
+ * This program is free software: you can redistribute it and/or modify
+ * it under the terms of the GNU General Public License as published by
+ * the Free Software Foundation, either version 3 of the License, or
+ * (at your option) any later version.
+ *
+ * This program is distributed in the hope that it will be useful,
+ * but WITHOUT ANY WARRANTY; without even the implied warranty of
+ * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
+ * GNU General Public License for more details.
+ *
+ * This program is free software: you can redistribute it and/or modify
+ * it under the terms of the GNU General Public License as published by
+ * the Free Software Foundation, either version 3 of the License, or
+ * (at your option) any later version.
+ *
+ * This program is distributed in the hope that it will be useful,
+ * but WITHOUT ANY WARRANTY; without even the implied warranty of
+ * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
+ * GNU General Public License for more details.
+ *
+ * You should have received a copy of the GNU General Public License
+ * along with this program. If not, see .
+ */
+
+package com.epmet.service.impl;
+
+import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
+import com.baomidou.mybatisplus.core.metadata.IPage;
+import com.epmet.commons.mybatis.service.impl.BaseServiceImpl;
+import com.epmet.commons.tools.constant.FieldConstant;
+import com.epmet.commons.tools.page.PageData;
+import com.epmet.commons.tools.utils.ConvertUtils;
+import com.epmet.dao.IcResiUserAttachmentDao;
+import com.epmet.dto.IcResiUserAttachmentDTO;
+import com.epmet.entity.IcResiUserAttachmentEntity;
+import com.epmet.service.IcResiUserAttachmentService;
+import org.apache.commons.lang3.StringUtils;
+import org.springframework.stereotype.Service;
+import org.springframework.transaction.annotation.Transactional;
+
+import java.util.Arrays;
+import java.util.List;
+import java.util.Map;
+
+/**
+ * 项目节点附件表
+ *
+ * @author generator generator@elink-cn.com
+ * @since v1.0.0 2020-12-21
+ */
+@Service
+public class IcResiUserAttachmentServiceImpl extends BaseServiceImpl implements IcResiUserAttachmentService {
+
+ @Override
+ public PageData page(Map params) {
+ IPage page = baseDao.selectPage(
+ getPage(params, FieldConstant.CREATED_TIME, false),
+ getWrapper(params)
+ );
+ return getPageData(page, IcResiUserAttachmentDTO.class);
+ }
+
+ @Override
+ public List list(Map params) {
+ List entityList = baseDao.selectList(getWrapper(params));
+
+ return ConvertUtils.sourceToTarget(entityList, IcResiUserAttachmentDTO.class);
+ }
+
+ private QueryWrapper getWrapper(Map params){
+ String id = (String)params.get(FieldConstant.ID_HUMP);
+
+ QueryWrapper wrapper = new QueryWrapper<>();
+ wrapper.eq(StringUtils.isNotBlank(id), FieldConstant.ID, id);
+
+ return wrapper;
+ }
+
+ @Override
+ public IcResiUserAttachmentDTO get(String id) {
+ IcResiUserAttachmentEntity entity = baseDao.selectById(id);
+ return ConvertUtils.sourceToTarget(entity, IcResiUserAttachmentDTO.class);
+ }
+
+ @Override
+ @Transactional(rollbackFor = Exception.class)
+ public void save(IcResiUserAttachmentDTO dto) {
+ IcResiUserAttachmentEntity entity = ConvertUtils.sourceToTarget(dto, IcResiUserAttachmentEntity.class);
+ insert(entity);
+ }
+
+ @Override
+ @Transactional(rollbackFor = Exception.class)
+ public void update(IcResiUserAttachmentDTO dto) {
+ IcResiUserAttachmentEntity entity = ConvertUtils.sourceToTarget(dto, IcResiUserAttachmentEntity.class);
+ updateById(entity);
+ }
+
+ @Override
+ @Transactional(rollbackFor = Exception.class)
+ public void delete(String[] ids) {
+ // 逻辑删除（@TableLogic 注解）
+ baseDao.deleteBatchIds(Arrays.asList(ids));
+ }
+
+}
\ No newline at end of file
diff --git a/epmet-user/epmet-user-server/src/main/java/com/epmet/service/impl/IcResiUserServiceImpl.java b/epmet-user/epmet-user-server/src/main/java/com/epmet/service/impl/IcResiUserServiceImpl.java
index 4b3dab701f..5744c10f62 100644
--- a/epmet-user/epmet-user-server/src/main/java/com/epmet/service/impl/IcResiUserServiceImpl.java
+++ b/epmet-user/epmet-user-server/src/main/java/com/epmet/service/impl/IcResiUserServiceImpl.java
@@ -101,7 +101,8 @@ public class IcResiUserServiceImpl extends BaseServiceImpl getWrapper(Map params){
- String id = (String)params.get(FieldConstant.ID_HUMP);
+ private QueryWrapper getWrapper(Map params) {
+ String id = (String) params.get(FieldConstant.ID_HUMP);
QueryWrapper wrapper = new QueryWrapper<>();
wrapper.eq(StringUtils.isNotBlank(id), FieldConstant.ID, id);
@@ -172,7 +175,7 @@ public class IcResiUserServiceImpl extends BaseServiceImpl NumConstant.ZERO ) {
+ if (str.length() > NumConstant.ZERO) {
String errorMsg = String.format("新增居民信息,必要字段值为空,%s值为空", str);
throw new EpmetException(EpmetErrorCode.EPMET_COMMON_OPERATION_FAIL.getCode(), errorMsg, errorMsg);
}
@@ -193,7 +196,7 @@ public class IcResiUserServiceImpl extends BaseServiceImpl> categoryListResult = operCustomizeOpenFeignClient.getCategoryList(sfdto);
- if (!categoryListResult.success()){
+ if (!categoryListResult.success()) {
throw new RenException("居民信息修改，获取客户居民类别预警配置表数据失败");
}
//修改前数据库居民十八类信息值
@@ -495,7 +521,7 @@ public class IcResiUserServiceImpl extends BaseServiceImpl getPeopleByRoom(String homeId) {
- if(StringUtils.isBlank(homeId)) {
+ if (StringUtils.isBlank(homeId)) {
return Collections.emptyList();
}
LambdaQueryWrapper wrapper = new LambdaQueryWrapper<>();
@@ -515,72 +541,70 @@ public class IcResiUserServiceImpl extends BaseServiceImpl> pageResiMap(IcResiUserPageFormDTO formDTO) {
- CustomerStaffInfoCacheResult staffInfoCacheResult=CustomerStaffRedis.getStaffInfo(formDTO.getCustomerId(),formDTO.getStaffId());
+ CustomerStaffInfoCacheResult staffInfoCacheResult = CustomerStaffRedis.getStaffInfo(formDTO.getCustomerId(), formDTO.getStaffId());
String staffOrgPath;
- if(StringUtils.isNotBlank(staffInfoCacheResult.getAgencyPIds())&& !NumConstant.ZERO_STR.equals(staffInfoCacheResult.getAgencyPIds())){
- staffOrgPath=staffInfoCacheResult.getAgencyPIds().concat(":").concat(staffInfoCacheResult.getAgencyId());
- }else{
- staffOrgPath=staffInfoCacheResult.getAgencyId();
+ if (StringUtils.isNotBlank(staffInfoCacheResult.getAgencyPIds()) && !NumConstant.ZERO_STR.equals(staffInfoCacheResult.getAgencyPIds())) {
+ staffOrgPath = staffInfoCacheResult.getAgencyPIds().concat(":").concat(staffInfoCacheResult.getAgencyId());
+ } else {
+ staffOrgPath = staffInfoCacheResult.getAgencyId();
}
// 查询列表展示项，如果没有，直接返回
- CustomerFormQueryDTO queryDTO1=new CustomerFormQueryDTO();
+ CustomerFormQueryDTO queryDTO1 = new CustomerFormQueryDTO();
queryDTO1.setCustomerId(formDTO.getCustomerId());
queryDTO1.setFormCode(formDTO.getFormCode());
- Result> resultColumnRes=operCustomizeOpenFeignClient.queryConditions(queryDTO1);
+ Result> resultColumnRes = operCustomizeOpenFeignClient.queryConditions(queryDTO1);
if (!resultColumnRes.success() || CollectionUtils.isEmpty(resultColumnRes.getData())) {
log.warn("没有配置列表展示列");
return new PageData(new ArrayList(), NumConstant.ZERO);
}
List resultColumns = resultColumnRes.getData();
// 查询结果列对应的表:
- Set resultColumnTables=resultColumns.stream().map(IcFormResColumnDTO::getTableName).collect(Collectors.toSet());
+ Set resultColumnTables = resultColumns.stream().map(IcFormResColumnDTO::getTableName).collect(Collectors.toSet());
// 查询列表展示项需要用到哪些子表
- Result> subTablesRes=operCustomizeOpenFeignClient.querySubTables(queryDTO1);
- List subTables =subTablesRes.getData();
+ Result> subTablesRes = operCustomizeOpenFeignClient.querySubTables(queryDTO1);
+ List subTables = subTablesRes.getData();
// log.info("1、所有的子表subTables:"+JSON.toJSONString(subTables,true));
//关联哪些子表：查询条件用到的表名+查询的列对应的表 并集去重
- Set whereConditionTables=formDTO.getConditions().stream().map(ResiUserQueryValueDTO::getTableName).collect(Collectors.toSet());
- Set tables=new HashSet<>();
+ Set whereConditionTables = formDTO.getConditions().stream().map(ResiUserQueryValueDTO::getTableName).collect(Collectors.toSet());
+ Set tables = new HashSet<>();
tables.addAll(whereConditionTables);
tables.addAll(resultColumnTables);
// log.info("2、查询条件+查询列对应的tables并集去重:"+ JSON.toJSONString(tables,true));
//最终关联的子表对应的sql：
- List finalSubTables =new ArrayList<>();
- subTables.forEach(subTable->{
- if(tables.contains(subTable.getTableName())){
+ List finalSubTables = new ArrayList<>();
+ subTables.forEach(subTable -> {
+ if (tables.contains(subTable.getTableName())) {
finalSubTables.add(subTable.getJoinTableSql());
}
});
- PageInfo> pageInfo=new PageInfo<>();
- if (null == formDTO.getPageFlag()||formDTO.getPageFlag()) {
+ PageInfo> pageInfo = new PageInfo<>();
+ if (null == formDTO.getPageFlag() || formDTO.getPageFlag()) {
//分页
String finalStaffOrgPath = staffOrgPath;
- pageInfo= PageHelper.startPage(formDTO.getPageNo(),
+ pageInfo = PageHelper.startPage(formDTO.getPageNo(),
formDTO.getPageSize()).doSelectPageInfo(() -> baseDao.selectListResiMap(formDTO.getCustomerId(),
formDTO.getFormCode(),
formDTO.getConditions(),
resultColumns,
finalSubTables,
- staffInfoCacheResult.getAgencyId(), finalStaffOrgPath,null, formDTO.getKeyword()));
- }else{
- List> list=baseDao.selectListResiMap(formDTO.getCustomerId(),
+ staffInfoCacheResult.getAgencyId(), finalStaffOrgPath, null, formDTO.getKeyword()));
+ } else {
+ List> list = baseDao.selectListResiMap(formDTO.getCustomerId(),
formDTO.getFormCode(),
formDTO.getConditions(),
resultColumns,
finalSubTables,
staffInfoCacheResult.getAgencyId(),
- staffOrgPath,null,
+ staffOrgPath, null,
formDTO.getKeyword());
- pageInfo.setTotal(CollectionUtils.isEmpty(list)?NumConstant.ZERO:list.size());
+ pageInfo.setTotal(CollectionUtils.isEmpty(list) ? NumConstant.ZERO : list.size());
pageInfo.setList(list);
}
@@ -596,23 +620,23 @@ public class IcResiUserServiceImpl extends BaseServiceImpl> gridInfoRes=govOrgOpenFeignClient.getGridListByGridIds(gridIds);
+ Result> gridInfoRes = govOrgOpenFeignClient.getGridListByGridIds(gridIds);
List gridInfoList = gridInfoRes.success() && !CollectionUtils.isEmpty(gridInfoRes.getData()) ? gridInfoRes.getData() : new ArrayList<>();
Map gridInfoMap = gridInfoList.stream().collect(Collectors.toMap(AllGridsByUserIdResultDTO::getGridId, Function.identity()));
//查询房子名称
- Result> houseInfoRes=govOrgOpenFeignClient.queryListHouseInfo(houseIds,formDTO.getCustomerId());
+ Result> houseInfoRes = govOrgOpenFeignClient.queryListHouseInfo(houseIds, formDTO.getCustomerId());
List houseInfoDTOList = houseInfoRes.success() && !CollectionUtils.isEmpty(houseInfoRes.getData()) ? houseInfoRes.getData() : new ArrayList<>();
Map houseInfoMap = houseInfoDTOList.stream().collect(Collectors.toMap(HouseInfoDTO::getHomeId, Function.identity()));
//查询需求分类字典
- UserDemandNameQueryFormDTO userDemandNameQueryFormDTO=new UserDemandNameQueryFormDTO();
+ UserDemandNameQueryFormDTO userDemandNameQueryFormDTO = new UserDemandNameQueryFormDTO();
userDemandNameQueryFormDTO.setCustomerId(formDTO.getCustomerId());
- Result> demandNameRes=heartOpenFeignClient.queryDemandNames(userDemandNameQueryFormDTO);
- if(!demandNameRes.success()||CollectionUtils.isEmpty(demandNameRes.getData())){
- throw new EpmetException(EpmetErrorCode.SERVER_ERROR.getCode(),"获取需求分类字典表数据异常",EpmetErrorCode.SERVER_ERROR.getMsg());
+ Result> demandNameRes = heartOpenFeignClient.queryDemandNames(userDemandNameQueryFormDTO);
+ if (!demandNameRes.success() || CollectionUtils.isEmpty(demandNameRes.getData())) {
+ throw new EpmetException(EpmetErrorCode.SERVER_ERROR.getCode(), "获取需求分类字典表数据异常", EpmetErrorCode.SERVER_ERROR.getMsg());
}
- Map demandDictMap=demandNameRes.getData().stream().collect(Collectors.toMap(IcResiDemandDictDTO::getCategoryCode,Function.identity()));
+ Map demandDictMap = demandNameRes.getData().stream().collect(Collectors.toMap(IcResiDemandDictDTO::getCategoryCode, Function.identity()));
for (Map resultMap : list) {
String gridIdValue = null != resultMap.get(UserConstant.GRID_ID) ? resultMap.get(UserConstant.GRID_ID).toString() : StrConstant.EPMETY_STR;
@@ -650,7 +674,7 @@ public class IcResiUserServiceImpl extends BaseServiceImpl(pageInfo.getList(), pageInfo.getTotal());
}
- private String queryUserDemandName(String icResiUserId,Map demandDictMap) {
+ private String queryUserDemandName(String icResiUserId, Map demandDictMap) {
// epmet_user.ic_resi_demand.category_code存储的值为 分类编码的全路径，eg:
// 1003,10030002
// 1012,10120003
// 1016,10160003
- Set demandCodePath=baseDao.selectUserDemandCode(icResiUserId);
- if(CollectionUtils.isEmpty(demandCodePath)){
+ Set demandCodePath = baseDao.selectUserDemandCode(icResiUserId);
+ if (CollectionUtils.isEmpty(demandCodePath)) {
return StrConstant.EPMETY_STR;
}
- List nameList=new ArrayList<>();
- for(String codePath:demandCodePath){
+ List nameList = new ArrayList<>();
+ for (String codePath : demandCodePath) {
if (StringUtils.isNotBlank(codePath) && codePath.contains(StrConstant.COMMA)) {
- String[] codeAtt=codePath.split(StrConstant.COMMA);
- String code=codeAtt[codeAtt.length-1];
- if(StringUtils.isNotBlank(code)&&demandDictMap.containsKey(code)){
+ String[] codeAtt = codePath.split(StrConstant.COMMA);
+ String code = codeAtt[codeAtt.length - 1];
+ if (StringUtils.isNotBlank(code) && demandDictMap.containsKey(code)) {
nameList.add(demandDictMap.get(code).getParentName());
}
- }else{
- if(StringUtils.isNotBlank(codePath)&&demandDictMap.containsKey(codePath)){
+ } else {
+ if (StringUtils.isNotBlank(codePath) && demandDictMap.containsKey(codePath)) {
nameList.add(demandDictMap.get(codePath).getParentName());
}
}
}
- String demandName=String.join(StrConstant.COMMA_ZH,nameList);
- return demandName;
+ String demandName = String.join(StrConstant.COMMA_ZH, nameList);
+ return demandName;
}
@@ -708,17 +732,17 @@ public class IcResiUserServiceImpl extends BaseServiceImpl> icResiUserMapList = baseDao.selectListMapById(pageFormDTO.getCustomerId(),pageFormDTO.getIcResiUserId());
+ List> icResiUserMapList = baseDao.selectListMapById(pageFormDTO.getCustomerId(), pageFormDTO.getIcResiUserId());
if (CollectionUtils.isEmpty(icResiUserMapList)) {
return new HashMap();
}
resultMap.put("ic_resi_user", icResiUserMapList);
- CustomerFormQueryDTO queryDTO=ConvertUtils.sourceToTarget(pageFormDTO,CustomerFormQueryDTO.class);
+ CustomerFormQueryDTO queryDTO = ConvertUtils.sourceToTarget(pageFormDTO, CustomerFormQueryDTO.class);
//循环查询每个子表的记录
- Result> subTableRes=operCustomizeOpenFeignClient.queryIcResiSubTables(queryDTO);
- if(subTableRes.success()&&!CollectionUtils.isEmpty(subTableRes.getData())){
+ Result> subTableRes = operCustomizeOpenFeignClient.queryIcResiSubTables(queryDTO);
+ if (subTableRes.success() && !CollectionUtils.isEmpty(subTableRes.getData())) {
for (String subTalbeName : subTableRes.getData()) {
- List> list = baseDao.selectSubTableRecords(pageFormDTO.getCustomerId(),pageFormDTO.getIcResiUserId(), subTalbeName);
+ List> list = baseDao.selectSubTableRecords(pageFormDTO.getCustomerId(), pageFormDTO.getIcResiUserId(), subTalbeName);
if (!CollectionUtils.isEmpty(list)) {
resultMap.put(subTalbeName, list);
}
@@ -732,6 +756,7 @@ public class IcResiUserServiceImpl extends BaseServiceImpl> dynamicQuery(String customerId,
- String formCode,
- String resultTableName,
- List conditions,
- String currentStaffAgencyId,
- String staffOrgPath){
- CustomerFormQueryDTO queryDTO=new CustomerFormQueryDTO();
+ public List> dynamicQuery(String customerId,
+ String formCode,
+ String resultTableName,
+ List conditions,
+ String currentStaffAgencyId,
+ String staffOrgPath) {
+ CustomerFormQueryDTO queryDTO = new CustomerFormQueryDTO();
queryDTO.setCustomerId(customerId);
queryDTO.setFormCode(formCode);
//所有的子表
- Result> subTablesRes=operCustomizeOpenFeignClient.querySubTables(queryDTO);
+ Result> subTablesRes = operCustomizeOpenFeignClient.querySubTables(queryDTO);
/*List subTablesBak=new ArrayList<>();
if(subTablesRes.success()&&CollectionUtils.isNotEmpty(subTablesRes.getData())){
subTablesBak =subTablesRes.getData().stream().map(SubTableJoinDTO::getJoinTableSql).collect(Collectors.toList());
}*/
- List subTables =subTablesRes.getData();
+ List subTables = subTablesRes.getData();
// log.info("1、所有的子表subTables:"+JSON.toJSONString(subTables,true));
//关联哪些子表：查询条件用到的表名+查询的列对应的表 并集去重
- Set whereConditionTables=conditions.stream().map(ResiUserQueryValueDTO::getTableName).collect(Collectors.toSet());
- Set tables=new HashSet<>();
+ Set whereConditionTables = conditions.stream().map(ResiUserQueryValueDTO::getTableName).collect(Collectors.toSet());
+ Set tables = new HashSet<>();
tables.addAll(whereConditionTables);
tables.add(resultTableName);
// log.info("2、查询条件+查询列对应的tables并集去重:"+ JSON.toJSONString(tables,true));
//最终关联的子表对应的sql：
- List finalSubTables =new ArrayList<>();
- subTables.forEach(subTable->{
- if(tables.contains(subTable.getTableName())){
+ List finalSubTables = new ArrayList<>();
+ subTables.forEach(subTable -> {
+ if (tables.contains(subTable.getTableName())) {
finalSubTables.add(subTable.getJoinTableSql());
}
});
- return baseDao.dynamicQuery(customerId,resultTableName,conditions,finalSubTables,currentStaffAgencyId,staffOrgPath);
+ return baseDao.dynamicQuery(customerId, resultTableName, conditions, finalSubTables, currentStaffAgencyId, staffOrgPath);
}
/**
- * @Description 查询个人数据
* @param formDTO
+ * @Description 查询个人数据
* @author zxc
* @date 2021/11/3 9:21 上午
*/
@Override
public PersonDataResultDTO personData(PersonDataFormDTO formDTO) {
PersonDataResultDTO personData = baseDao.personData(formDTO.getUserId());
- if (null == personData){
+ if (null == personData) {
return new PersonDataResultDTO();
}
//新增以下2个返参
@@ -796,16 +821,16 @@ public class IcResiUserServiceImpl extends BaseServiceImpl> listResult = govOrgOpenFeignClient.selectHouseInfoByIdCard(personData.getIdCard(),formDTO.getCustomerId());
- if (!listResult.success()){
+ Result> listResult = govOrgOpenFeignClient.selectHouseInfoByIdCard(personData.getIdCard(), formDTO.getCustomerId());
+ if (!listResult.success()) {
throw new RenException("查询房屋信息失败");
}
personData.setHouseInfo(listResult.getData());
// 志愿者处理
- if (personData.getIsVolunteer().equals(NumConstant.ONE_STR)){
+ if (personData.getIsVolunteer().equals(NumConstant.ONE_STR)) {
List volunteerList = baseDao.selectVolunteerByUserId(formDTO.getUserId());
- if (!CollectionUtils.isEmpty(volunteerList)){
+ if (!CollectionUtils.isEmpty(volunteerList)) {
List volunteers = new ArrayList<>();
List finalVolunteers = volunteers;
volunteerList.forEach(v -> {
@@ -815,7 +840,7 @@ public class IcResiUserServiceImpl extends BaseServiceImpl> volunteerResult = operCustomizeOpenFeignClient.volunteerLabelByValues(volunteers, personData.getCustomerId());
- if (!volunteerResult.success()){
+ if (!volunteerResult.success()) {
throw new RenException("查询志愿者类别失败...");
}
personData.setVolunteerCategory(volunteerResult.getData());
@@ -823,7 +848,7 @@ public class IcResiUserServiceImpl extends BaseServiceImpl> categoryListResult = operCustomizeOpenFeignClient.getCategoryList(dto);
- if (!categoryListResult.success()){
+ if (!categoryListResult.success()) {
throw new RenException("查询客户下的人员类别失败...");
}
List categoryData = categoryListResult.getData();
- if (!CollectionUtils.isEmpty(categoryData)){
+ if (!CollectionUtils.isEmpty(categoryData)) {
Map> groupByStatus = categoryData.stream().collect(Collectors.groupingBy(IcResiCategoryStatsConfigDTO::getStatus));
List showList = groupByStatus.get(IcPlatformConstant.PERSON_CATEGORY_SHOW);
List personCategoryList = new ArrayList<>();
- if (!CollectionUtils.isEmpty(showList)){
+ if (!CollectionUtils.isEmpty(showList)) {
Map> groupByTableName = showList.stream().collect(Collectors.groupingBy(IcResiCategoryStatsConfigDTO::getTableName));
- groupByTableName.forEach((tableName,list) -> {
+ groupByTableName.forEach((tableName, list) -> {
List columns = list.stream().map(IcResiCategoryStatsConfigDTO::getColumnName).collect(Collectors.toList());
- Map result = baseDao.selectPersonType(columns, personData.getCustomerId(), tableName,formDTO.getUserId());
+ Map result = baseDao.selectPersonType(columns, personData.getCustomerId(), tableName, formDTO.getUserId());
list.forEach(l -> {
- result.forEach((k,v) -> {
- if (l.getColumnName().equals(k) && v.equals(NumConstant.ONE_STR)){
+ result.forEach((k, v) -> {
+ if (l.getColumnName().equals(k) && v.equals(NumConstant.ONE_STR)) {
personCategoryList.add(l.getLabel());
}
});
@@ -861,9 +886,15 @@ public class IcResiUserServiceImpl extends BaseServiceImpl searchByName(SearchByNameFormDTO formDTO) {
// 查询工作人员所属组织
CustomerStaffInfoCacheResult staffInfo = CustomerStaffRedis.getStaffInfo(formDTO.getCustomerId(), formDTO.getUserId());
- if (null == staffInfo){
+ if (null == staffInfo) {
throw new RenException("未查询到当前工作人员所属组织");
}
Integer no = (formDTO.getPageNo() - NumConstant.ONE) * formDTO.getPageSize();
- PageInfo pageInfo = PageHelper.startPage(formDTO.getPageNo(), formDTO.getPageSize()).doSelectPageInfo(() -> baseDao.searchByName(formDTO.getName(), formDTO.getColumnName(),staffInfo.getAgencyId(), no));
+ PageInfo pageInfo = PageHelper.startPage(formDTO.getPageNo(), formDTO.getPageSize()).doSelectPageInfo(() -> baseDao.searchByName(formDTO.getName(), formDTO.getColumnName(), staffInfo.getAgencyId(), no));
List result = pageInfo.getList();
- if (CollectionUtils.isEmpty(result)){
+ if (CollectionUtils.isEmpty(result)) {
return new PageData<>(new ArrayList<>(), pageInfo.getTotal());
}
// 查询小区，楼号，网格
Result> gridResult = govOrgOpenFeignClient.getGridListByGridIds(result.stream().map(SearchByNameResultDTO::getGridId).collect(Collectors.toList()));
if (!gridResult.success()) {
- throw new RenException(gridResult.getCode(),gridResult.getMsg());
+ throw new RenException(gridResult.getCode(), gridResult.getMsg());
}
Map gridMap = gridResult.getData().stream().collect(Collectors.toMap(AllGridsByUserIdResultDTO::getGridId, AllGridsByUserIdResultDTO::getGridName));
Result> neighborHoodResult = govOrgOpenFeignClient.getListByIds(result.stream().map(SearchByNameResultDTO::getNeighborHoodId).collect(Collectors.toList()));
if (!neighborHoodResult.success()) {
- throw new RenException(neighborHoodResult.getCode(),neighborHoodResult.getMsg());
+ throw new RenException(neighborHoodResult.getCode(), neighborHoodResult.getMsg());
}
Map neighborHoodMap = neighborHoodResult.getData().stream().collect(Collectors.toMap(IcNeighborHoodDTO::getId, IcNeighborHoodDTO::getNeighborHoodName));
Result> buildResult = govOrgOpenFeignClient.buildingListByIds(result.stream().map(SearchByNameResultDTO::getBuildId).collect(Collectors.toList()));
if (!buildResult.success()) {
- throw new RenException(buildResult.getCode(),buildResult.getMsg());
+ throw new RenException(buildResult.getCode(), buildResult.getMsg());
}
Map buildMap = buildResult.getData().stream().collect(Collectors.toMap(BuildingResultDTO::getBuildingId, BuildingResultDTO::getBuildingName));
AtomicInteger i = new AtomicInteger(NumConstant.ONE);
@@ -910,8 +941,7 @@ public class IcResiUserServiceImpl extends BaseServiceImpl {
- if (o instanceof java.sql.Date){
- o = DateUtils.format(((Date) o),DateUtils.DATE_PATTERN);
- }else if (o instanceof java.sql.Timestamp){
- o = DateUtils.format(new Date(((Timestamp) o).getTime()),DateUtils.DATE_TIME_PATTERN);
+ resiUser.forEach((k, o) -> {
+ if (o instanceof java.sql.Date) {
+ o = DateUtils.format(((Date) o), DateUtils.DATE_PATTERN);
+ } else if (o instanceof java.sql.Timestamp) {
+ o = DateUtils.format(new Date(((Timestamp) o).getTime()), DateUtils.DATE_TIME_PATTERN);
}
- resiUser.put(k,o);
+ resiUser.put(k, o);
});
//当前条数据原始的id值 resiUser
- Map originalConditionMap = new ConcurrentHashMap<>();
- formItemMap.getItemMap().values().parallelStream().forEach(e->{
+ Map originalConditionMap = new ConcurrentHashMap<>();
+ formItemMap.getItemMap().values().parallelStream().forEach(e -> {
String columnName = getColumnName(e);
Object temp = resiUser.get(columnName);
String vauleStr = temp == null ? StrConstant.EPMETY_STR : temp.toString();
- originalConditionMap.putIfAbsent(columnName,vauleStr);
+ originalConditionMap.putIfAbsent(columnName, vauleStr);
if (Constant.OPITON_SOURCE_REMOTE.equals(e.getOptionSourceType()) && StringUtils.isNotBlank(vauleStr)) {
- putRemoteValue(formItemMap.getRemoteItemConditionMap().get(e.getItemId()), currentStaffAgencyId, resiUser,originalConditionMap, e, columnName, vauleStr);
+ putRemoteValue(formItemMap.getRemoteItemConditionMap().get(e.getItemId()), currentStaffAgencyId, resiUser, originalConditionMap, e, columnName, vauleStr);
} else {
putOptionValue(resiUser, e, columnName, vauleStr);
}
@@ -962,14 +992,14 @@ public class IcResiUserServiceImpl extends BaseServiceImpl> remoteOptionCacheMap = new HashMap<>();
+ private static Map> remoteOptionCacheMap = new HashMap<>();
+
private void putRemoteValue(Set conditionItemSet, String currentStaffAgencyId, Map map, Map originalConditionMap, FormItemResult e, String columnName, String vauleStr) {
try {
Map columnWrappers = new HashMap<>();
- if (e.getOptionSourceValue().contains(StrConstant.QUESTION_MARK)){
+ if (e.getOptionSourceValue().contains(StrConstant.QUESTION_MARK)) {
for (FormItemResult o : conditionItemSet) {
String column = getColumnName(o);
Object conditionValue = originalConditionMap.getOrDefault(column, map.get(column));
- originalConditionMap.putIfAbsent(column,conditionValue.toString());
+ originalConditionMap.putIfAbsent(column, conditionValue.toString());
IcResiUserImportServiceImpl.ColumnWrapper value = new IcResiUserImportServiceImpl.ColumnWrapper();
value.setColValue(conditionValue.toString());
columnWrappers.put(o.getItemId(), value);
@@ -1003,10 +1034,10 @@ public class IcResiUserServiceImpl extends BaseServiceImpl cache = remoteOptionCacheMap.getOrDefault(e.getItemId(), CacheBuilder.newBuilder().maximumSize(NumConstant.FIVE_HUNDRED).build());
- remoteOptionCacheMap.putIfAbsent(e.getItemId(),cache);
+ remoteOptionCacheMap.putIfAbsent(e.getItemId(), cache);
String cacheValue = cache.getIfPresent(vauleStr);
- if (StringUtils.isNotBlank(cacheValue)){
- map.put(columnName,cacheValue);
+ if (StringUtils.isNotBlank(cacheValue)) {
+ map.put(columnName, cacheValue);
} else {
String[] parts = icResiUserImportService.splitOptionSourceUrl(e.getOptionSourceValue());
@@ -1018,7 +1049,7 @@ public class IcResiUserServiceImpl extends BaseServiceImpl queryDemandUsers(DemandUserFormDTO formDTO) {
- return baseDao.selectDemandUsers(formDTO.getAgencyId(),formDTO.getGridId(),formDTO.getName());
+ return baseDao.selectDemandUsers(formDTO.getAgencyId(), formDTO.getGridId(), formDTO.getName());
}
/**
@@ -1130,11 +1161,11 @@ public class IcResiUserServiceImpl extends BaseServiceImpl> configListResult = operCustomizeOpenFeignClient.getCustomerCategoryShowAndWarnList(tokenDto.getCustomerId());
- if (!configListResult.success()){
+ if (!configListResult.success()) {
throw new EpmetException("查询居民分类配置失败...");
}
PersonWarnRightListResultDTO result = new PersonWarnRightListResultDTO();
- if (CollectionUtils.isEmpty(configListResult.getData())){
+ if (CollectionUtils.isEmpty(configListResult.getData())) {
return result;
}
List configListOrigin = configListResult.getData();
List configList = new ArrayList<>();
- if (StringUtils.isNotBlank(formDTO.getCategoryCode())){
+ if (StringUtils.isNotBlank(formDTO.getCategoryCode())) {
for (CustomerCategoryShowAndWarnListResultDTO c : configListOrigin) {
- if (c.getColumnName().equals(formDTO.getCategoryCode())){
+ if (c.getColumnName().equals(formDTO.getCategoryCode())) {
configList.add(c);
}
}
- }else {
+ } else {
configList = configListOrigin;
}
List finalConfigList = configList;
@@ -1237,8 +1268,8 @@ public class IcResiUserServiceImpl extends BaseServiceImpl userList = disposeCategory(list, configList);
- Result> houseInfosResult = govOrgOpenFeignClient.queryListHouseInfo(userList.stream().distinct().map(m -> m.getHomeId()).collect(Collectors.toSet()),tokenDto.getCustomerId());
- if (!houseInfosResult.success()){
+ Result> houseInfosResult = govOrgOpenFeignClient.queryListHouseInfo(userList.stream().distinct().map(m -> m.getHomeId()).collect(Collectors.toSet()), tokenDto.getCustomerId());
+ if (!houseInfosResult.success()) {
throw new EpmetException("查询房屋信息失败...");
}
List houseInfos = houseInfosResult.getData();
@@ -1256,6 +1287,7 @@ public class IcResiUserServiceImpl extends BaseServiceImpl houseIds = new HashSet<>();
List houseIdList = list.stream().map(EpidemicPreventionResultDTO::getHomeId).collect(Collectors.toList()).stream().distinct().collect(Collectors.toList());
houseIds.addAll(houseIdList);
- Result> houseInfoRes=govOrgOpenFeignClient.queryListHouseInfo(houseIds,formDTO.getCustomerId());
+ Result> houseInfoRes = govOrgOpenFeignClient.queryListHouseInfo(houseIds, formDTO.getCustomerId());
List houseInfoDTOList = houseInfoRes.success() && !CollectionUtils.isEmpty(houseInfoRes.getData()) ? houseInfoRes.getData() : new ArrayList<>();
Map houseInfoMap = houseInfoDTOList.stream().collect(Collectors.toMap(HouseInfoDTO::getHomeId, Function.identity()));
list.forEach(item -> {
@@ -1318,19 +1350,19 @@ public class IcResiUserServiceImpl extends BaseServiceImpl list = new ArrayList<>();
- if (formDTO.getAttentionType().equals(NumConstant.TWO)){
+ if (formDTO.getAttentionType().equals(NumConstant.TWO)) {
list = baseDao.natList(formDTO);
- }else if (formDTO.getAttentionType().equals(NumConstant.ONE)){
+ } else if (formDTO.getAttentionType().equals(NumConstant.ONE)) {
list = baseDao.vaccineList(formDTO);
}
Set homeIds = list.stream().filter(m -> StringUtils.isNotBlank(m.getIdCard())).map(m -> m.getHomeId()).distinct().collect(Collectors.toSet());
- if (CollectionUtils.isNotEmpty(homeIds)){
+ if (CollectionUtils.isNotEmpty(homeIds)) {
Result> houseInfoRes = govOrgOpenFeignClient.queryListHouseInfo(homeIds, formDTO.getCustomerId());
- if (!houseInfoRes.success()){
+ if (!houseInfoRes.success()) {
throw new EpmetException("查询居民所属房屋失败...");
}
- if (CollectionUtils.isNotEmpty(houseInfoRes.getData())){
- list.forEach(l -> houseInfoRes.getData().stream().filter( h -> h.getHomeId().equals(l.getHomeId())).forEach(h -> l.setHouseName(h.getAllName())));
+ if (CollectionUtils.isNotEmpty(houseInfoRes.getData())) {
+ list.forEach(l -> houseInfoRes.getData().stream().filter(h -> h.getHomeId().equals(l.getHomeId())).forEach(h -> l.setHouseName(h.getAllName())));
}
}
PageInfo pageInfo = new PageInfo<>(list);
@@ -1402,31 +1434,31 @@ public class IcResiUserServiceImpl extends BaseServiceImpl disposeCategory(List> list,List configList){
+ public List disposeCategory(List> list, List configList) {
List userList = new ArrayList<>();
list.forEach(l -> {
PersonWarnRightListResultDTO.PersonWarnRightList dto = ConvertUtils.mapToEntity(l, PersonWarnRightListResultDTO.PersonWarnRightList.class);
// 分类名字
List types = new ArrayList<>();
configList.forEach(c -> {
- l.forEach((k,v) -> {
- if (c.getColumnName().equals(k) && null != v && v.equals(NumConstant.ONE_STR)){
+ l.forEach((k, v) -> {
+ if (c.getColumnName().equals(k) && null != v && v.equals(NumConstant.ONE_STR)) {
types.add(c.getLabel());
}
});
});
// 只显示有类别的居民
- if (CollectionUtils.isNotEmpty(types)){
+ if (CollectionUtils.isNotEmpty(types)) {
dto.setType(types);
GridInfoCache gridInfo = CustomerOrgRedis.getGridInfo(dto.getGridId());
- if (null == gridInfo){
- throw new EpmetException(String.format("查询网格信息失败%s",dto.getGridId()));
+ if (null == gridInfo) {
+ throw new EpmetException(String.format("查询网格信息失败%s", dto.getGridId()));
}
dto.setGridName(gridInfo.getGridNamePath());
userList.add(dto);
@@ -1437,6 +1469,7 @@ public class IcResiUserServiceImpl extends BaseServiceImpl(list, pageInfo.getTotal());
}
List list = baseDao.getPartyMemberAgeList(formDTO.getOrgType(), formDTO.getOrgId(), formDTO.getCode());
- return new PageData<>(list, null == list?NumConstant.ZERO:list.size());
+ return new PageData<>(list, null == list ? NumConstant.ZERO : list.size());
}
/**
@@ -1548,7 +1581,7 @@ public class IcResiUserServiceImpl extends BaseServiceImpl(list, null == list?NumConstant.ZERO:list.size());
+ return new PageData<>(list, null == list ? NumConstant.ZERO : list.size());
}
}
diff --git a/epmet-user/epmet-user-server/src/main/resources/mapper/IcResiUserAttachmentDao.xml b/epmet-user/epmet-user-server/src/main/resources/mapper/IcResiUserAttachmentDao.xml
new file mode 100644
index 0000000000..a6618a4f06
--- /dev/null
+++ b/epmet-user/epmet-user-server/src/main/resources/mapper/IcResiUserAttachmentDao.xml
@@ -0,0 +1,23 @@
+
+
+
+
+
+
+
+
\ No newline at end of file
diff --git a/epmet-user/epmet-user-server/src/main/resources/mapper/IcResiUserDao.xml b/epmet-user/epmet-user-server/src/main/resources/mapper/IcResiUserDao.xml
index df62d9b6dc..054839bf02 100644
--- a/epmet-user/epmet-user-server/src/main/resources/mapper/IcResiUserDao.xml
+++ b/epmet-user/epmet-user-server/src/main/resources/mapper/IcResiUserDao.xml
@@ -307,7 +307,19 @@
AND customer_id = #{customerId}
AND id_card = #{idCard}
-
+