diff --git a/epmet-admin/epmet-admin-client/src/main/java/com/epmet/dto/form/LogOperationListFormDTO.java b/epmet-admin/epmet-admin-client/src/main/java/com/epmet/dto/form/LogOperationListFormDTO.java
index a4fc503431..e0fef69bbb 100644
--- a/epmet-admin/epmet-admin-client/src/main/java/com/epmet/dto/form/LogOperationListFormDTO.java
+++ b/epmet-admin/epmet-admin-client/src/main/java/com/epmet/dto/form/LogOperationListFormDTO.java
@@ -27,7 +27,12 @@ public class LogOperationListFormDTO {
*/
private String endTime;
/**
- * 默认传data_tm
+ * 产品原本前端默认传data_tm
+ * 03.01烟台需求,列表展示全部
+ * 项目流转:project_changed
+ * 登录:auth
+ * 积分:point
+ * 查看脱敏信息:data_tm
*/
private String category;
}
diff --git a/epmet-admin/epmet-admin-server/Dockerfile b/epmet-admin/epmet-admin-server/Dockerfile
index c2df4971cd..578a3503ec 100644
--- a/epmet-admin/epmet-admin-server/Dockerfile
+++ b/epmet-admin/epmet-admin-server/Dockerfile
@@ -1,4 +1,4 @@
-FROM java:8
+FROM openjdk:8-jre
RUN export LANG="zh_CN.UTF-8"
RUN ln -sf /usr/share/zoneinfo/Asia/Shanghai /etc/localtime
diff --git a/epmet-admin/epmet-admin-server/src/main/java/com/epmet/mq/listener/listener/CheckAndExportOperationLogListener.java b/epmet-admin/epmet-admin-server/src/main/java/com/epmet/mq/listener/listener/CheckAndExportOperationLogListener.java
index 977117ac84..1e07414afd 100644
--- a/epmet-admin/epmet-admin-server/src/main/java/com/epmet/mq/listener/listener/CheckAndExportOperationLogListener.java
+++ b/epmet-admin/epmet-admin-server/src/main/java/com/epmet/mq/listener/listener/CheckAndExportOperationLogListener.java
@@ -1,10 +1,8 @@
package com.epmet.mq.listener.listener;
import com.alibaba.fastjson.JSON;
-import com.epmet.auth.constants.AuthOperationEnum;
import com.epmet.commons.rocketmq.constants.MQUserPropertys;
import com.epmet.commons.rocketmq.messages.CheckMQMsg;
-import com.epmet.commons.rocketmq.messages.LoginMQMsg;
import com.epmet.commons.tools.distributedlock.DistributedLock;
import com.epmet.commons.tools.exception.ExceptionUtils;
import com.epmet.commons.tools.exception.RenException;
@@ -69,7 +67,7 @@ public class CheckAndExportOperationLogListener implements MessageListenerConcur
logEntity.setIp(msgObj.getIp());
logEntity.setFromApp(msgObj.getFromApp());
logEntity.setFromClient(msgObj.getFromClient());
- logEntity.setTargetId("");
+ logEntity.setTargetId(msgObj.getTargetId());
logEntity.setCustomerId(operatorInfo.getCustomerId());
logEntity.setOperatorId(msgObj.getUserId());
logEntity.setOperatorName(operatorInfo.getName());
diff --git a/epmet-admin/epmet-admin-server/src/main/resources/mapper/LogOperationDao.xml b/epmet-admin/epmet-admin-server/src/main/resources/mapper/LogOperationDao.xml
index 749e9b4288..032973b7fe 100644
--- a/epmet-admin/epmet-admin-server/src/main/resources/mapper/LogOperationDao.xml
+++ b/epmet-admin/epmet-admin-server/src/main/resources/mapper/LogOperationDao.xml
@@ -75,10 +75,10 @@
AND lo.OPERATOR_MOBILE LIKE concat('%',#{operatorMobile},'%')
- AND DATE_FORMAT( lo.OPERATING_TIME, '%Y%m%d' ) >= #{startTime}
+ AND DATE_FORMAT( lo.OPERATING_TIME, '%Y-%m-%d %H:%i' ) >= #{startTime}
- AND DATE_FORMAT( lo.OPERATING_TIME, '%Y%m%d' ) <= #{endTime}
+ AND DATE_FORMAT( lo.OPERATING_TIME, '%Y-%m-%d %H:%i' ) <= #{endTime}
ORDER BY lo.OPERATING_TIME DESC
diff --git a/epmet-auth/Dockerfile b/epmet-auth/Dockerfile
index 60c6be4331..a55d4837da 100644
--- a/epmet-auth/Dockerfile
+++ b/epmet-auth/Dockerfile
@@ -1,4 +1,4 @@
-FROM java:8
+FROM openjdk:8-jre
RUN export LANG="zh_CN.UTF-8"
RUN ln -sf /usr/share/zoneinfo/Asia/Shanghai /etc/localtime
diff --git a/epmet-commons/epmet-commons-rocketmq/src/main/java/com/epmet/commons/rocketmq/messages/CheckMQMsg.java b/epmet-commons/epmet-commons-rocketmq/src/main/java/com/epmet/commons/rocketmq/messages/CheckMQMsg.java
index 30b1595e20..b1bb6b7170 100644
--- a/epmet-commons/epmet-commons-rocketmq/src/main/java/com/epmet/commons/rocketmq/messages/CheckMQMsg.java
+++ b/epmet-commons/epmet-commons-rocketmq/src/main/java/com/epmet/commons/rocketmq/messages/CheckMQMsg.java
@@ -29,5 +29,5 @@ public class CheckMQMsg {
private String fromClient;
private String orgId;
private String orgIdPath;
-
+ private String targetId;
}
diff --git a/epmet-gateway/Dockerfile b/epmet-gateway/Dockerfile
index bb6890eefc..cf62665316 100644
--- a/epmet-gateway/Dockerfile
+++ b/epmet-gateway/Dockerfile
@@ -1,4 +1,4 @@
-FROM java:8
+FROM openjdk:8-jre
RUN export LANG="zh_CN.UTF-8"
RUN ln -sf /usr/share/zoneinfo/Asia/Shanghai /etc/localtime
diff --git a/epmet-module/data-aggregator/data-aggregator-server/Dockerfile b/epmet-module/data-aggregator/data-aggregator-server/Dockerfile
index 57bc7e63b0..adf2a92fcd 100644
--- a/epmet-module/data-aggregator/data-aggregator-server/Dockerfile
+++ b/epmet-module/data-aggregator/data-aggregator-server/Dockerfile
@@ -1,4 +1,4 @@
-FROM java:8
+FROM openjdk:8-jre
RUN export LANG="zh_CN.UTF-8"
RUN ln -sf /usr/share/zoneinfo/Asia/Shanghai /etc/localtime
diff --git a/epmet-module/data-aggregator/data-aggregator-server/src/main/java/com/epmet/dataaggre/service/epmetuser/impl/EpmetUserServiceImpl.java b/epmet-module/data-aggregator/data-aggregator-server/src/main/java/com/epmet/dataaggre/service/epmetuser/impl/EpmetUserServiceImpl.java
index 171f1a520d..75f863dd58 100644
--- a/epmet-module/data-aggregator/data-aggregator-server/src/main/java/com/epmet/dataaggre/service/epmetuser/impl/EpmetUserServiceImpl.java
+++ b/epmet-module/data-aggregator/data-aggregator-server/src/main/java/com/epmet/dataaggre/service/epmetuser/impl/EpmetUserServiceImpl.java
@@ -1023,6 +1023,7 @@ public class EpmetUserServiceImpl implements EpmetUserService {
result.setMobile(houseInfo.getOwnerPhone());
result.setIdCard(houseInfo.getOwnerIdCard());
msg.setContent("查看"+houseInfo.getAllName()+"房屋的敏感信息");
+ msg.setTargetId(formDTO.getId());
}else if (formDTO.getType().equals(NeighborhoodConstant.CHECK_IC_RESI_USER)){
IcResiUserInfoCache icResiUserInfo = CustomerResiUserRedis.getIcResiUserInfo(formDTO.getId());
if (null == icResiUserInfo){
@@ -1031,14 +1032,16 @@ public class EpmetUserServiceImpl implements EpmetUserService {
result.setIdCard(icResiUserInfo.getIdCard());
result.setMobile(icResiUserInfo.getMobile());
msg.setContent("查看"+icResiUserInfo.getName()+"的敏感信息");
+ msg.setTargetId(formDTO.getId());
}else if (formDTO.getType().equals(NeighborhoodConstant.JMFYXX)){
IcResiUserInfoCache icResiUserInfo = CustomerResiUserRedis.getIcResiUserInfo(formDTO.getId());
if (null == icResiUserInfo){
- throw new EpmetException("查询icResiUser失败:"+formDTO.getId());
+ throw new EpmetException("居民防疫信息查询icResiUser失败:"+formDTO.getId());
}
result.setIdCard(icResiUserInfo.getIdCard());
result.setMobile(icResiUserInfo.getMobile());
msg.setContent("查看"+icResiUserInfo.getName()+"的敏感信息(居民防疫信息)");
+ msg.setTargetId(formDTO.getId());
}else if (formDTO.getType().equals(NeighborhoodConstant.ROUTE_FOLLOW)){
Map info = icResiUserDao.getTripReportRecordInfo(formDTO.getId());
if (null == info){
@@ -1047,6 +1050,7 @@ public class EpmetUserServiceImpl implements EpmetUserService {
result.setIdCard(info.get(NeighborhoodConstant.ID_CARD));
result.setMobile(info.get(NeighborhoodConstant.MOBILE));
msg.setContent("查看"+info.get(NeighborhoodConstant.NAME)+"的敏感信息(行程随访)");
+ msg.setTargetId(formDTO.getId());
}else if (formDTO.getType().equals(NeighborhoodConstant.VACCINATION_RECORD)){
Map info = icResiUserDao.getVaccineRecordInfo(formDTO.getId());
if (null == info){
@@ -1055,6 +1059,7 @@ public class EpmetUserServiceImpl implements EpmetUserService {
result.setIdCard(info.get(NeighborhoodConstant.ID_CARD));
result.setMobile(info.get(NeighborhoodConstant.MOBILE));
msg.setContent("查看"+info.get(NeighborhoodConstant.NAME)+"的敏感信息(疫苗接种记录)");
+ msg.setTargetId(formDTO.getId());
}else if (formDTO.getType().equals(NeighborhoodConstant.VACCINE_SPECIAL_ATTENTION)
|| formDTO.getType().equals(NeighborhoodConstant.FOCUS_GROUP_SPECIAL_ATTENTION_QUARANTINE)
|| formDTO.getType().equals(NeighborhoodConstant.FOCUS_GROUP_SPECIAL_ATTENTION_HISTORY)){
@@ -1078,7 +1083,7 @@ public class EpmetUserServiceImpl implements EpmetUserService {
default:
}
msg.setContent("查看"+info.get(NeighborhoodConstant.NAME)+"的敏感信息("+cMsg+")");
-
+ msg.setTargetId(formDTO.getId());
}else if (formDTO.getType().equals(NeighborhoodConstant.NO_NAT_COMPARE)){
Map info = icResiUserDao.getNoNatCompareInfo(formDTO.getId());
if (null == info){
@@ -1087,6 +1092,7 @@ public class EpmetUserServiceImpl implements EpmetUserService {
result.setIdCard(info.get(NeighborhoodConstant.ID_CARD));
result.setMobile(info.get(NeighborhoodConstant.MOBILE));
msg.setContent("查看"+info.get(NeighborhoodConstant.NAME)+"的敏感信息(未做核酸比对)");
+ msg.setTargetId(formDTO.getId());
}else if (formDTO.getType().equals(NeighborhoodConstant.NAT_RECORD)){
Map info = icResiUserDao.getNatInfo(formDTO.getId());
if (null == info){
@@ -1095,6 +1101,7 @@ public class EpmetUserServiceImpl implements EpmetUserService {
result.setIdCard(info.get(NeighborhoodConstant.ID_CARD));
result.setMobile(info.get(NeighborhoodConstant.MOBILE));
msg.setContent("查看"+info.get(NeighborhoodConstant.NAME)+"的敏感信息(核酸检测信息)");
+ msg.setTargetId(formDTO.getId());
}else if (formDTO.getType().equals(NeighborhoodConstant.EMPLOYEE_EPIDEMIC_MANAGE_DETAIL)){
Map info = govOrgService.getEmployeeRegisterMobileAndIdCard(formDTO.getId());
if (null == info){
@@ -1103,6 +1110,7 @@ public class EpmetUserServiceImpl implements EpmetUserService {
result.setIdCard(info.get(NeighborhoodConstant.ID_CARD));
result.setMobile(info.get(NeighborhoodConstant.MOBILE));
msg.setContent("查看"+info.get(NeighborhoodConstant.NAME)+"的敏感信息(员工登记信息)");
+ msg.setTargetId(formDTO.getId());
}
// 发送mq消息
HttpServletRequest request = ((ServletRequestAttributes) RequestContextHolder.getRequestAttributes()).getRequest();
diff --git a/epmet-module/data-report/data-report-server/Dockerfile b/epmet-module/data-report/data-report-server/Dockerfile
index 98c31d5ed3..be9167fecf 100644
--- a/epmet-module/data-report/data-report-server/Dockerfile
+++ b/epmet-module/data-report/data-report-server/Dockerfile
@@ -1,4 +1,4 @@
-FROM java:8
+FROM openjdk:8-jre
RUN export LANG="zh_CN.UTF-8"
RUN ln -sf /usr/share/zoneinfo/Asia/Shanghai /etc/localtime
diff --git a/epmet-module/data-statistical/data-statistical-server/Dockerfile b/epmet-module/data-statistical/data-statistical-server/Dockerfile
index e029544f66..b2b22faaad 100644
--- a/epmet-module/data-statistical/data-statistical-server/Dockerfile
+++ b/epmet-module/data-statistical/data-statistical-server/Dockerfile
@@ -1,4 +1,4 @@
-FROM java:8
+FROM openjdk:8-jre
RUN export LANG="zh_CN.UTF-8"
RUN ln -sf /usr/share/zoneinfo/Asia/Shanghai /etc/localtime
diff --git a/epmet-module/epmet-activiti/epmet-activiti-server/Dockerfile b/epmet-module/epmet-activiti/epmet-activiti-server/Dockerfile
index a578c93035..8174c09bbc 100644
--- a/epmet-module/epmet-activiti/epmet-activiti-server/Dockerfile
+++ b/epmet-module/epmet-activiti/epmet-activiti-server/Dockerfile
@@ -1,4 +1,4 @@
-FROM java:8
+FROM openjdk:8-jre
RUN export LANG="zh_CN.UTF-8"
RUN ln -sf /usr/share/zoneinfo/Asia/Shanghai /etc/localtime
diff --git a/epmet-module/epmet-common-service/common-service-server/Dockerfile b/epmet-module/epmet-common-service/common-service-server/Dockerfile
index b0366f9c27..85575c46cf 100644
--- a/epmet-module/epmet-common-service/common-service-server/Dockerfile
+++ b/epmet-module/epmet-common-service/common-service-server/Dockerfile
@@ -1,4 +1,4 @@
-FROM java:8
+FROM openjdk:8-jre
RUN export LANG="zh_CN.UTF-8"
RUN ln -sf /usr/share/zoneinfo/Asia/Shanghai /etc/localtime
diff --git a/epmet-module/epmet-ext/epmet-ext-server/Dockerfile b/epmet-module/epmet-ext/epmet-ext-server/Dockerfile
index 72a70e41f9..d1c5cfcc05 100644
--- a/epmet-module/epmet-ext/epmet-ext-server/Dockerfile
+++ b/epmet-module/epmet-ext/epmet-ext-server/Dockerfile
@@ -1,4 +1,4 @@
-FROM java:8
+FROM openjdk:8-jre
RUN export LANG="zh_CN.UTF-8"
RUN ln -sf /usr/share/zoneinfo/Asia/Shanghai /etc/localtime
diff --git a/epmet-module/epmet-heart/epmet-heart-server/Dockerfile b/epmet-module/epmet-heart/epmet-heart-server/Dockerfile
index 2c90d35d42..e476811d7d 100644
--- a/epmet-module/epmet-heart/epmet-heart-server/Dockerfile
+++ b/epmet-module/epmet-heart/epmet-heart-server/Dockerfile
@@ -1,4 +1,4 @@
-FROM java:8
+FROM openjdk:8-jre
RUN export LANG="zh_CN.UTF-8"
RUN ln -sf /usr/share/zoneinfo/Asia/Shanghai /etc/localtime
diff --git a/epmet-module/epmet-job/epmet-job-server/Dockerfile b/epmet-module/epmet-job/epmet-job-server/Dockerfile
index 62d98c605d..8b2debbb4c 100644
--- a/epmet-module/epmet-job/epmet-job-server/Dockerfile
+++ b/epmet-module/epmet-job/epmet-job-server/Dockerfile
@@ -1,4 +1,4 @@
-FROM java:8
+FROM openjdk:8-jre
RUN export LANG="zh_CN.UTF-8"
RUN ln -sf /usr/share/zoneinfo/Asia/Shanghai /etc/localtime
diff --git a/epmet-module/epmet-message/epmet-message-server/Dockerfile b/epmet-module/epmet-message/epmet-message-server/Dockerfile
index ef183014e3..fded3e7d47 100644
--- a/epmet-module/epmet-message/epmet-message-server/Dockerfile
+++ b/epmet-module/epmet-message/epmet-message-server/Dockerfile
@@ -1,4 +1,4 @@
-FROM java:8
+FROM openjdk:8-jre
RUN export LANG="zh_CN.UTF-8"
RUN ln -sf /usr/share/zoneinfo/Asia/Shanghai /etc/localtime
diff --git a/epmet-module/epmet-oss/epmet-oss-server/Dockerfile b/epmet-module/epmet-oss/epmet-oss-server/Dockerfile
index 4c41cd08cb..b1343fa4ee 100644
--- a/epmet-module/epmet-oss/epmet-oss-server/Dockerfile
+++ b/epmet-module/epmet-oss/epmet-oss-server/Dockerfile
@@ -1,4 +1,4 @@
-FROM java:8
+FROM openjdk:8-jre
RUN export LANG="zh_CN.UTF-8"
RUN ln -sf /usr/share/zoneinfo/Asia/Shanghai /etc/localtime
diff --git a/epmet-module/epmet-point/epmet-point-server/Dockerfile b/epmet-module/epmet-point/epmet-point-server/Dockerfile
index 9268360dd7..c2bfd59a49 100644
--- a/epmet-module/epmet-point/epmet-point-server/Dockerfile
+++ b/epmet-module/epmet-point/epmet-point-server/Dockerfile
@@ -1,4 +1,4 @@
-FROM java:8
+FROM openjdk:8-jre
RUN export LANG="zh_CN.UTF-8"
RUN ln -sf /usr/share/zoneinfo/Asia/Shanghai /etc/localtime
diff --git a/epmet-module/epmet-third/epmet-third-server/Dockerfile b/epmet-module/epmet-third/epmet-third-server/Dockerfile
index 99663b0965..2c76db52c2 100644
--- a/epmet-module/epmet-third/epmet-third-server/Dockerfile
+++ b/epmet-module/epmet-third/epmet-third-server/Dockerfile
@@ -1,4 +1,4 @@
-FROM java:8
+FROM openjdk:8-jre
RUN export LANG="zh_CN.UTF-8"
RUN ln -sf /usr/share/zoneinfo/Asia/Shanghai /etc/localtime
diff --git a/epmet-module/gov-access/gov-access-server/Dockerfile b/epmet-module/gov-access/gov-access-server/Dockerfile
index b1fa39dad0..6cfc4eb81c 100644
--- a/epmet-module/gov-access/gov-access-server/Dockerfile
+++ b/epmet-module/gov-access/gov-access-server/Dockerfile
@@ -1,4 +1,4 @@
-FROM java:8
+FROM openjdk:8-jre
RUN export LANG="zh_CN.UTF-8"
RUN ln -sf /usr/share/zoneinfo/Asia/Shanghai /etc/localtime
diff --git a/epmet-module/gov-grid/gov-grid-server/Dockerfile b/epmet-module/gov-grid/gov-grid-server/Dockerfile
index 0a753e2a71..4eb6fdbff3 100644
--- a/epmet-module/gov-grid/gov-grid-server/Dockerfile
+++ b/epmet-module/gov-grid/gov-grid-server/Dockerfile
@@ -1,4 +1,4 @@
-FROM java:8
+FROM openjdk:8-jre
RUN export LANG="zh_CN.UTF-8"
RUN ln -sf /usr/share/zoneinfo/Asia/Shanghai /etc/localtime
diff --git a/epmet-module/gov-issue/gov-issue-server/Dockerfile b/epmet-module/gov-issue/gov-issue-server/Dockerfile
index 88d3240786..4f93029875 100644
--- a/epmet-module/gov-issue/gov-issue-server/Dockerfile
+++ b/epmet-module/gov-issue/gov-issue-server/Dockerfile
@@ -1,4 +1,4 @@
-FROM java:8
+FROM openjdk:8-jre
RUN export LANG="zh_CN.UTF-8"
RUN ln -sf /usr/share/zoneinfo/Asia/Shanghai /etc/localtime
diff --git a/epmet-module/gov-mine/gov-mine-server/Dockerfile b/epmet-module/gov-mine/gov-mine-server/Dockerfile
index cbc73e687e..7e31131cf9 100644
--- a/epmet-module/gov-mine/gov-mine-server/Dockerfile
+++ b/epmet-module/gov-mine/gov-mine-server/Dockerfile
@@ -1,4 +1,4 @@
-FROM java:8
+FROM openjdk:8-jre
RUN export LANG="zh_CN.UTF-8"
RUN ln -sf /usr/share/zoneinfo/Asia/Shanghai /etc/localtime
diff --git a/epmet-module/gov-org/gov-org-client/src/main/java/com/epmet/dto/form/GroupRentHouseFormDTO.java b/epmet-module/gov-org/gov-org-client/src/main/java/com/epmet/dto/form/GroupRentHouseFormDTO.java
new file mode 100644
index 0000000000..97c8832968
--- /dev/null
+++ b/epmet-module/gov-org/gov-org-client/src/main/java/com/epmet/dto/form/GroupRentHouseFormDTO.java
@@ -0,0 +1,48 @@
+package com.epmet.dto.form;
+
+import com.epmet.commons.tools.dto.form.PageFormDTO;
+import lombok.Data;
+
+import java.io.Serializable;
+
+/**
+ * @Description
+ * @Author yzm
+ * @Date 2023/3/2 17:35
+ */
+@Data
+public class GroupRentHouseFormDTO extends PageFormDTO implements Serializable {
+ private static final long serialVersionUID = -953729855530434972L;
+ /**
+ * 组织ID
+ */
+ private String orgId;
+ private String orgType;
+
+ /**
+ * 房主姓名
+ */
+ private String ownerName;
+ /**
+ * 房主电话
+ */
+ private String ownerPhone;
+
+ /**
+ * 房屋用途
+ */
+ private String purpose;
+
+ /**
+ * 备注
+ */
+ private String remark;
+
+
+ /**
+ * tokenDto获取
+ */
+ private String customerId;
+ private String staffId;
+}
+
diff --git a/epmet-module/gov-org/gov-org-client/src/main/java/com/epmet/dto/result/AgencyResultDTO.java b/epmet-module/gov-org/gov-org-client/src/main/java/com/epmet/dto/result/AgencyResultDTO.java
index a7aec4fa28..c40b7448d6 100644
--- a/epmet-module/gov-org/gov-org-client/src/main/java/com/epmet/dto/result/AgencyResultDTO.java
+++ b/epmet-module/gov-org/gov-org-client/src/main/java/com/epmet/dto/result/AgencyResultDTO.java
@@ -47,5 +47,8 @@ public class AgencyResultDTO implements Serializable {
private String longitude;
//维度【没值则取跟客户的值】
private String latitude;
-
+ /**
+ * agencyId的全路径,包含自身
+ */
+ private String orgIdPath;
}
diff --git a/epmet-module/gov-org/gov-org-client/src/main/java/com/epmet/dto/result/AgencySubResultDTO.java b/epmet-module/gov-org/gov-org-client/src/main/java/com/epmet/dto/result/AgencySubResultDTO.java
index 08bd0683b1..1461c66fa1 100644
--- a/epmet-module/gov-org/gov-org-client/src/main/java/com/epmet/dto/result/AgencySubResultDTO.java
+++ b/epmet-module/gov-org/gov-org-client/src/main/java/com/epmet/dto/result/AgencySubResultDTO.java
@@ -61,4 +61,8 @@ public class AgencySubResultDTO implements Serializable {
* 组织维度【没值取根组织的值】
*/
private String latitude = "";
+ /**
+ * agencyId的全路径,包含自身
+ */
+ private String orgIdPath;
}
\ No newline at end of file
diff --git a/epmet-module/gov-org/gov-org-client/src/main/java/com/epmet/dto/result/AgencyTreeResultDTO.java b/epmet-module/gov-org/gov-org-client/src/main/java/com/epmet/dto/result/AgencyTreeResultDTO.java
index 4d48b54960..ab12b7bac2 100644
--- a/epmet-module/gov-org/gov-org-client/src/main/java/com/epmet/dto/result/AgencyTreeResultDTO.java
+++ b/epmet-module/gov-org/gov-org-client/src/main/java/com/epmet/dto/result/AgencyTreeResultDTO.java
@@ -35,6 +35,10 @@ public class AgencyTreeResultDTO implements Serializable {
* orgId-orgLevel
*/
private String orgLevel;
+ /**
+ * agencyId的全路径,包含自身
+ */
+ private String orgIdPath;
/**
* 下级机关组织
*/
diff --git a/epmet-module/gov-org/gov-org-client/src/main/java/com/epmet/dto/result/GroupRentHouseResultDTO.java b/epmet-module/gov-org/gov-org-client/src/main/java/com/epmet/dto/result/GroupRentHouseResultDTO.java
new file mode 100644
index 0000000000..febcd6e4fc
--- /dev/null
+++ b/epmet-module/gov-org/gov-org-client/src/main/java/com/epmet/dto/result/GroupRentHouseResultDTO.java
@@ -0,0 +1,77 @@
+package com.epmet.dto.result;
+
+import lombok.Data;
+
+import java.io.Serializable;
+
+/**
+ * @Description 群租房列表
+ * @Author yzm
+ * @Date 2023/3/3 9:27
+ */
+@Data
+public class GroupRentHouseResultDTO implements Serializable {
+ private static final long serialVersionUID = 3671964765109154117L;
+ private String houseId;
+
+ /**
+ * 所属组织
+ */
+ private String agencyName;
+ private String agencyId;
+ /**
+ * 所属网格
+ */
+ private String gridName;
+ private String gridId;
+
+ /**
+ * 所属小区
+ */
+ private String neighborHoodName;
+ /**
+ * 所属楼栋
+ */
+ private String buildingName;
+
+ private String houseName;
+ /**
+ * 房屋类型
+ */
+ private String houseType;
+ private String houseTypeKey;
+ /**
+ * 房屋用途
+ */
+ private String purpose;
+ private String purposeKey;
+
+ /**
+ * 房屋状态:房屋状态:1:出租 0:自住 2:闲置 3:未售出
+ */
+ private String rentFlag;
+
+ /**
+ * 房主姓名
+ */
+ private String ownerName;
+ /**
+ * 房主电话
+ */
+ private String ownerPhone;
+ /**
+ * 房主身份证
+ */
+ private String ownerIdCard;
+
+ /**
+ * 备注
+ */
+ private String remark;
+
+ /**
+ * 排序
+ */
+ private Double sort;
+}
+
diff --git a/epmet-module/gov-org/gov-org-client/src/main/java/com/epmet/feign/GovOrgOpenFeignClient.java b/epmet-module/gov-org/gov-org-client/src/main/java/com/epmet/feign/GovOrgOpenFeignClient.java
index 9818f7f832..0ded926d87 100644
--- a/epmet-module/gov-org/gov-org-client/src/main/java/com/epmet/feign/GovOrgOpenFeignClient.java
+++ b/epmet-module/gov-org/gov-org-client/src/main/java/com/epmet/feign/GovOrgOpenFeignClient.java
@@ -21,7 +21,7 @@ import java.util.Set;
* @author yinzuomei@elink-cn.com
* @date 2020/6/4 13:37
*/
- //@FeignClient(name = ServiceConstant.GOV_ORG_SERVER, fallbackFactory = GovOrgOpenFeignClientFallbackFactory.class, url = "localhost:8092")
+ // @FeignClient(name = ServiceConstant.GOV_ORG_SERVER, fallbackFactory = GovOrgOpenFeignClientFallbackFactory.class, url = "localhost:8092")
@FeignClient(name = ServiceConstant.GOV_ORG_SERVER, fallbackFactory = GovOrgOpenFeignClientFallbackFactory.class)
public interface GovOrgOpenFeignClient {
@@ -757,4 +757,12 @@ public interface GovOrgOpenFeignClient {
@PostMapping("/gov/org/enterprise/sendEnterprisePatrolRemindMessage")
Result sendEnterprisePatrolRemindMessage();
+
+ /**
+ * 获取当前客户下所有的社区组织,只返回id,orgIdPath,agencyName
+ * @param customerId
+ * @return
+ */
+ @PostMapping("/gov/org/agency/getAllCommunity/{customerId}")
+ Result> getAllCommunity(@PathVariable(value = "customerId") String customerId);
}
diff --git a/epmet-module/gov-org/gov-org-client/src/main/java/com/epmet/feign/fallback/GovOrgOpenFeignClientFallback.java b/epmet-module/gov-org/gov-org-client/src/main/java/com/epmet/feign/fallback/GovOrgOpenFeignClientFallback.java
index befef36cf5..52cf691d6e 100644
--- a/epmet-module/gov-org/gov-org-client/src/main/java/com/epmet/feign/fallback/GovOrgOpenFeignClientFallback.java
+++ b/epmet-module/gov-org/gov-org-client/src/main/java/com/epmet/feign/fallback/GovOrgOpenFeignClientFallback.java
@@ -474,4 +474,14 @@ public class GovOrgOpenFeignClientFallback implements GovOrgOpenFeignClient {
return ModuleUtils.feignConError(ServiceConstant.GOV_ORG_SERVER, "gridStaffList", dto);
}
+ /**
+ * 获取当前客户下所有的社区组织,只返回id,orgIdPath,agencyName
+ *
+ * @param customerId
+ * @return
+ */
+ @Override
+ public Result> getAllCommunity(String customerId) {
+ return ModuleUtils.feignConError(ServiceConstant.GOV_ORG_SERVER, "getAllCommunity", customerId);
+ }
}
diff --git a/epmet-module/gov-org/gov-org-server/Dockerfile b/epmet-module/gov-org/gov-org-server/Dockerfile
index 84c2478da5..71100403c7 100644
--- a/epmet-module/gov-org/gov-org-server/Dockerfile
+++ b/epmet-module/gov-org/gov-org-server/Dockerfile
@@ -1,4 +1,4 @@
-FROM java:8
+FROM openjdk:8-jre
RUN export LANG="zh_CN.UTF-8"
RUN ln -sf /usr/share/zoneinfo/Asia/Shanghai /etc/localtime
diff --git a/epmet-module/gov-org/gov-org-server/src/main/java/com/epmet/controller/AgencyController.java b/epmet-module/gov-org/gov-org-server/src/main/java/com/epmet/controller/AgencyController.java
index c6576dde5e..5624c39127 100644
--- a/epmet-module/gov-org/gov-org-server/src/main/java/com/epmet/controller/AgencyController.java
+++ b/epmet-module/gov-org/gov-org-server/src/main/java/com/epmet/controller/AgencyController.java
@@ -624,4 +624,17 @@ public class AgencyController {
String orgType = input.getOrgType();
return new Result().ok(agencyService.usingCommunityStats(orgId, orgType));
}
+
+ /**
+ * @param customerId
+ * @return 获取当前客户下所有的社区组织,只返回id,orgIdPath,agencyName
+ */
+ @PostMapping("getAllCommunity/{customerId}")
+ public Result> getAllCommunity(@PathVariable(value = "customerId") String customerId) {
+ if (StringUtils.isBlank(customerId)) {
+ return new Result<>();
+ }
+ return new Result>().ok(agencyService.getAllCommunity(customerId));
+ }
+
}
diff --git a/epmet-module/gov-org/gov-org-server/src/main/java/com/epmet/controller/HouseController.java b/epmet-module/gov-org/gov-org-server/src/main/java/com/epmet/controller/HouseController.java
index 53738a3d4c..32062f26c5 100644
--- a/epmet-module/gov-org/gov-org-server/src/main/java/com/epmet/controller/HouseController.java
+++ b/epmet-module/gov-org/gov-org-server/src/main/java/com/epmet/controller/HouseController.java
@@ -691,4 +691,21 @@ public class HouseController implements ResultDataResolver {
return new Result>().ok(r);
}
+ /**
+ * 群租房列表来源于烟台需求
+ * @param tokenDto
+ * @param formDTO
+ * @return
+ */
+ @PostMapping("group-rent-house-list")
+ @MaskResponse(fieldNames = {"ownerIdCard", "ownerPhone"},
+ fieldsMaskType = {MaskResponse.MASK_TYPE_ID_CARD, MaskResponse.MASK_TYPE_MOBILE})
+ public Result> groupRentHouseList(@LoginUser TokenDto tokenDto, @RequestBody GroupRentHouseFormDTO formDTO) {
+ formDTO.setCustomerId(tokenDto.getCustomerId());
+ formDTO.setStaffId(tokenDto.getUserId());
+ return new Result>().ok(houseService.groupRentHouseList(formDTO));
+ }
+
+
+
}
diff --git a/epmet-module/gov-org/gov-org-server/src/main/java/com/epmet/dao/CustomerAgencyDao.java b/epmet-module/gov-org/gov-org-server/src/main/java/com/epmet/dao/CustomerAgencyDao.java
index 7e98f598f8..2ef0034462 100644
--- a/epmet-module/gov-org/gov-org-server/src/main/java/com/epmet/dao/CustomerAgencyDao.java
+++ b/epmet-module/gov-org/gov-org-server/src/main/java/com/epmet/dao/CustomerAgencyDao.java
@@ -422,5 +422,12 @@ public interface CustomerAgencyDao extends BaseDao {
* @return
*/
Integer selectTotalNext(String agencyId);
+
+ /**
+ * 获取当前客户下所有的社区组织,只返回id,orgIdPath,agencyName
+ * @param customerId
+ * @return
+ */
+ List getAllCommunity(String customerId);
}
diff --git a/epmet-module/gov-org/gov-org-server/src/main/java/com/epmet/dao/IcHouseDao.java b/epmet-module/gov-org/gov-org-server/src/main/java/com/epmet/dao/IcHouseDao.java
index 1f3ceacfe5..3e9d28b39f 100644
--- a/epmet-module/gov-org/gov-org-server/src/main/java/com/epmet/dao/IcHouseDao.java
+++ b/epmet-module/gov-org/gov-org-server/src/main/java/com/epmet/dao/IcHouseDao.java
@@ -2,10 +2,7 @@ package com.epmet.dao;
import com.epmet.commons.mybatis.dao.BaseDao;
import com.epmet.dto.ImportGeneralDTO;
-import com.epmet.dto.form.CheckHouseInfoFormDTO;
-import com.epmet.dto.form.GetHouseInfoToCollectFormDTO;
-import com.epmet.dto.form.HouseChartFormDTO;
-import com.epmet.dto.form.IcHouseListFormDTO;
+import com.epmet.dto.form.*;
import com.epmet.dto.result.*;
import com.epmet.entity.CustomerOrgParameterEntity;
import com.epmet.entity.IcHouseEntity;
@@ -213,4 +210,12 @@ public interface IcHouseDao extends BaseDao {
List houseStatisListDetail(HouseChartFormDTO formDTO);
List selectListForRenFangStats(@Param("buildingId") String buildingId);
+
+ /**
+ * 群租房列表
+ * 群租房:出租状态并超过5人(≥5)
+ * @param formDTO
+ * @return
+ */
+ List selectGroupRentHouseList(GroupRentHouseFormDTO formDTO);
}
diff --git a/epmet-module/gov-org/gov-org-server/src/main/java/com/epmet/service/AgencyService.java b/epmet-module/gov-org/gov-org-server/src/main/java/com/epmet/service/AgencyService.java
index d7bb4b2564..5d2a97ba5c 100644
--- a/epmet-module/gov-org/gov-org-server/src/main/java/com/epmet/service/AgencyService.java
+++ b/epmet-module/gov-org/gov-org-server/src/main/java/com/epmet/service/AgencyService.java
@@ -204,4 +204,11 @@ public interface AgencyService {
* @return
*/
UsingCommunityStatsResultDTO usingCommunityStats(String orgId, String orgType);
+
+ /**
+ * 获取当前客户下所有的社区组织,只返回id,orgIdPath,agencyName
+ * @param customerId
+ * @return
+ */
+ List getAllCommunity(String customerId);
}
diff --git a/epmet-module/gov-org/gov-org-server/src/main/java/com/epmet/service/HouseService.java b/epmet-module/gov-org/gov-org-server/src/main/java/com/epmet/service/HouseService.java
index 1161a1ee9f..8499b55722 100644
--- a/epmet-module/gov-org/gov-org-server/src/main/java/com/epmet/service/HouseService.java
+++ b/epmet-module/gov-org/gov-org-server/src/main/java/com/epmet/service/HouseService.java
@@ -204,4 +204,11 @@ public interface HouseService {
PageData houseStatisListDetail(HouseChartFormDTO formDTO);
PageData usingCommunityUserHouseStats(String orgId, String orgType, Integer pageNo, Integer pageSize);
+
+ /**
+ * 群租房列表来源于烟台需求
+ * @param formDTO
+ * @return
+ */
+ PageData groupRentHouseList(GroupRentHouseFormDTO formDTO);
}
diff --git a/epmet-module/gov-org/gov-org-server/src/main/java/com/epmet/service/impl/AgencyServiceImpl.java b/epmet-module/gov-org/gov-org-server/src/main/java/com/epmet/service/impl/AgencyServiceImpl.java
index 04d8dfb98b..31d49852b7 100644
--- a/epmet-module/gov-org/gov-org-server/src/main/java/com/epmet/service/impl/AgencyServiceImpl.java
+++ b/epmet-module/gov-org/gov-org-server/src/main/java/com/epmet/service/impl/AgencyServiceImpl.java
@@ -1168,4 +1168,15 @@ public class AgencyServiceImpl implements AgencyService {
return orgPids.concat(":").concat(orgId);
}
+
+ /**
+ * 获取当前客户下所有的社区组织,只返回id,orgIdPath,agencyName
+ *
+ * @param customerId
+ * @return
+ */
+ @Override
+ public List getAllCommunity(String customerId) {
+ return customerAgencyDao.getAllCommunity(customerId);
+ }
}
diff --git a/epmet-module/gov-org/gov-org-server/src/main/java/com/epmet/service/impl/HouseServiceImpl.java b/epmet-module/gov-org/gov-org-server/src/main/java/com/epmet/service/impl/HouseServiceImpl.java
index d7e3b1f8b2..d31ecc0c13 100644
--- a/epmet-module/gov-org/gov-org-server/src/main/java/com/epmet/service/impl/HouseServiceImpl.java
+++ b/epmet-module/gov-org/gov-org-server/src/main/java/com/epmet/service/impl/HouseServiceImpl.java
@@ -1484,4 +1484,30 @@ public class HouseServiceImpl implements HouseService, ResultDataResolver {
agencyNamePathList.add(agencyInfo.getOrganizationName());
return String.join("-", agencyNamePathList);
}
+
+
+ /**
+ * 群租房列表来源于烟台需求
+ *
+ * @param formDTO
+ * @return
+ */
+ @Override
+ public PageData groupRentHouseList(GroupRentHouseFormDTO formDTO) {
+ if(StringUtils.isBlank(formDTO.getOrgId())){
+ //默认查询当前组织及下级
+ formDTO.setOrgType("agency");
+ CustomerStaffInfoCacheResult staffInfoCacheResult=CustomerStaffRedis.getStaffInfo(formDTO.getCustomerId(),formDTO.getStaffId());
+ formDTO.setOrgId(staffInfoCacheResult.getAgencyId());
+ }
+ //群租房:出租状态并超过5人(≥5)
+ PageHelper.startPage(formDTO.getPageNo(),formDTO.getPageSize());
+ List list=icHouseDao.selectGroupRentHouseList(formDTO);
+ list.forEach(item -> {
+ item.setHouseType(HouseTypeEnums.getTypeValue(item.getHouseTypeKey()));
+ item.setPurpose(HousePurposeEnums.getTypeValue(item.getPurposeKey()));
+ });
+ PageInfo pageInfo = new PageInfo<>(list);
+ return new PageData<>(list, pageInfo.getTotal());
+ }
}
diff --git a/epmet-module/gov-org/gov-org-server/src/main/resources/mapper/CustomerAgencyDao.xml b/epmet-module/gov-org/gov-org-server/src/main/resources/mapper/CustomerAgencyDao.xml
index 37964a6e2c..882249b1ad 100644
--- a/epmet-module/gov-org/gov-org-server/src/main/resources/mapper/CustomerAgencyDao.xml
+++ b/epmet-module/gov-org/gov-org-server/src/main/resources/mapper/CustomerAgencyDao.xml
@@ -198,7 +198,11 @@
ca.pids AS "pids",
ca.level level,
IFNULL(ca.longitude, cc.longitude) longitude,
- IFNULL(ca.latitude, cc.latitude) latitude
+ IFNULL(ca.latitude, cc.latitude) latitude,
+ (
+ case when ca.pid is null or ca.pid='0' or ca.pid='' then ca.id
+ else concat(ca.pids,':',ca.id)
+ end)as orgIdPath
FROM customer_agency ca
INNER JOIN customer_agency cc ON cc.pid = '0' AND ca.customer_id = cc.customer_id
WHERE ca.del_flag = '0'
@@ -397,7 +401,11 @@
ca.pid pid,
ca.level level,
ca.longitude,
- ca.latitude
+ ca.latitude,
+ (
+ case when ca.pid is null or ca.pid='0' or ca.pid='' then ca.id
+ else concat(ca.pids,':',ca.id)
+ end)as orgIdPath
FROM
customer_agency ca
INNER JOIN customer_staff_agency csa ON ca.id = csa.agency_id
@@ -614,7 +622,12 @@
ID AS agencyId,
ORGANIZATION_NAME AS agencyName,
PID,
- LEVEL
+ LEVEL,
+ (
+ case when pid is null or pid='0' or pid='' then id
+ else concat(pids,':',id)
+ end
+ )as orgIdPath
from customer_agency
where
DEL_FLAG = 0
@@ -628,7 +641,12 @@
ID AS agencyId,
ORGANIZATION_NAME AS agencyName,
PID,
- LEVEL
+ LEVEL,
+ (
+ case when pid is null or pid='0' or pid='' then id
+ else concat(pids,':',id)
+ end
+ )as orgIdPath
from
customer_agency
where
@@ -1120,4 +1138,20 @@
AND g.DEL_FLAG = '0'
) t
+
+
+
diff --git a/epmet-module/gov-org/gov-org-server/src/main/resources/mapper/IcHouseDao.xml b/epmet-module/gov-org/gov-org-server/src/main/resources/mapper/IcHouseDao.xml
index 6eac8ed9fd..222062704a 100644
--- a/epmet-module/gov-org/gov-org-server/src/main/resources/mapper/IcHouseDao.xml
+++ b/epmet-module/gov-org/gov-org-server/src/main/resources/mapper/IcHouseDao.xml
@@ -701,4 +701,79 @@
CAST(a.DOOR_NAME AS SIGNED),
CONVERT(a.DOOR_NAME using gbk)
+
+
diff --git a/epmet-module/gov-project/gov-project-server/Dockerfile b/epmet-module/gov-project/gov-project-server/Dockerfile
index aed003692d..23cba9a446 100644
--- a/epmet-module/gov-project/gov-project-server/Dockerfile
+++ b/epmet-module/gov-project/gov-project-server/Dockerfile
@@ -1,4 +1,4 @@
-FROM java:8
+FROM openjdk:8-jre
RUN export LANG="zh_CN.UTF-8"
RUN ln -sf /usr/share/zoneinfo/Asia/Shanghai /etc/localtime
diff --git a/epmet-module/gov-voice/gov-voice-client/src/main/java/com/epmet/dto/TagCustomerDTO.java b/epmet-module/gov-voice/gov-voice-client/src/main/java/com/epmet/dto/TagCustomerDTO.java
index 0e7f1a5e20..15e4d22232 100644
--- a/epmet-module/gov-voice/gov-voice-client/src/main/java/com/epmet/dto/TagCustomerDTO.java
+++ b/epmet-module/gov-voice/gov-voice-client/src/main/java/com/epmet/dto/TagCustomerDTO.java
@@ -17,10 +17,15 @@
package com.epmet.dto;
+import com.epmet.commons.tools.validator.group.CustomerClientShowGroup;
+import com.fasterxml.jackson.annotation.JsonIgnore;
import lombok.Data;
+import javax.validation.constraints.NotBlank;
+import javax.validation.constraints.NotNull;
import java.io.Serializable;
import java.util.Date;
+import java.util.List;
/**
@@ -34,9 +39,12 @@ public class TagCustomerDTO implements Serializable {
private static final long serialVersionUID = 1L;
+ public interface ChangeShowFlagGroup extends CustomerClientShowGroup {
+ }
/**
* 主键ID
*/
+ @NotBlank(message = "id不能为空",groups = ChangeShowFlagGroup.class)
private String id;
/**
@@ -48,40 +56,60 @@ public class TagCustomerDTO implements Serializable {
* 标签名称
*/
private String tagName;
+ /**
+ * 标签颜色
+ */
+ private String tagColor;
/**
* 使用计数
*/
private Integer useCount;
+ /**
+ * 1:展示;0:隐藏;0302因烟台需求增加此列默认1
+ */
+ @NotNull(message = "showFlag不能为空",groups = ChangeShowFlagGroup.class)
+ private Integer showFlag;
+
/**
* 删除标识 0.未删除 1.已删除
*/
+ @JsonIgnore
private Integer delFlag;
/**
* 乐观锁
*/
+ @JsonIgnore
private Integer revision;
/**
* 创建人
*/
+ @JsonIgnore
private String createdBy;
/**
* 创建时间
*/
+ @JsonIgnore
private Date createdTime;
/**
* 更新人
*/
+ @JsonIgnore
private String updatedBy;
/**
* 更新时间
*/
+ @JsonIgnore
private Date updatedTime;
+ /**
+ * 应用范围
+ */
+ private List agencyList;
}
diff --git a/epmet-module/gov-voice/gov-voice-client/src/main/java/com/epmet/dto/TagScopeDTO.java b/epmet-module/gov-voice/gov-voice-client/src/main/java/com/epmet/dto/TagScopeDTO.java
new file mode 100644
index 0000000000..8eacc3441e
--- /dev/null
+++ b/epmet-module/gov-voice/gov-voice-client/src/main/java/com/epmet/dto/TagScopeDTO.java
@@ -0,0 +1,34 @@
+package com.epmet.dto;
+
+import com.epmet.commons.tools.validator.group.CustomerClientShowGroup;
+import lombok.Data;
+
+import javax.validation.constraints.NotBlank;
+import java.io.Serializable;
+
+/**
+ * @Description
+ * @Author yzm
+ * @Date 2023/3/2 13:52
+ */
+@Data
+public class TagScopeDTO implements Serializable {
+ public interface AddUserShowGroup extends CustomerClientShowGroup {
+ }
+ /**
+ * 标签ID
+ */
+ private String tagId;
+
+ /**
+ * 应用范围,这里只能是社区id
+ */
+ @NotBlank(message = "agencyId不能为空",groups = AddUserShowGroup.class)
+ private String agencyId;
+ /**
+ * agency_id全路径,包含自身
+ */
+ @NotBlank(message = "orgIdPath不能为空",groups = AddUserShowGroup.class)
+ private String orgIdPath;
+}
+
diff --git a/epmet-module/gov-voice/gov-voice-client/src/main/java/com/epmet/dto/form/CommonArticleListFormDTO.java b/epmet-module/gov-voice/gov-voice-client/src/main/java/com/epmet/dto/form/CommonArticleListFormDTO.java
index 6be60b5d1e..c7addb73e8 100644
--- a/epmet-module/gov-voice/gov-voice-client/src/main/java/com/epmet/dto/form/CommonArticleListFormDTO.java
+++ b/epmet-module/gov-voice/gov-voice-client/src/main/java/com/epmet/dto/form/CommonArticleListFormDTO.java
@@ -26,12 +26,12 @@ public class CommonArticleListFormDTO implements Serializable {
* 烟台需求:周边疫情 就业服务 警民互动 物业通知 党务公开 居务公开 财务公开 以上标签在实时动态里写死吧
*
*/
- public interface YanTaiShowGroup extends CustomerClientShowGroup {
+ public interface YanTaiDingShowGroup extends CustomerClientShowGroup {
}
/**
* 网格Id
* */
- @NotBlank(message = "网格Id不能为空" , groups = {ArticleBannerInternalGroup.class,YanTaiShowGroup.class})
+ @NotBlank(message = "网格Id不能为空" , groups = {ArticleBannerInternalGroup.class,YanTaiDingShowGroup.class})
private String gridId;
/**
@@ -42,7 +42,7 @@ public class CommonArticleListFormDTO implements Serializable {
/**
* 标签名称(高级配置里的参数)
* */
- @NotBlank(message = "标签名称不能为空",groups = YanTaiShowGroup.class)
+ @NotBlank(message = "标签名称不能为空",groups = YanTaiDingShowGroup.class)
private String tagName;
/**
* 排除的标签名称(高级配置里的参数)
@@ -53,8 +53,10 @@ public class CommonArticleListFormDTO implements Serializable {
*/
private Integer isTop;
- @NotNull(message = "pageNo不能为空", groups = YanTaiShowGroup.class)
+ @NotNull(message = "pageNo不能为空", groups = YanTaiDingShowGroup.class)
private Integer pageNo;
- @NotNull(message = "pageSize不能为空", groups = YanTaiShowGroup.class)
+ @NotNull(message = "pageSize不能为空", groups = YanTaiDingShowGroup.class)
private Integer pageSize;
+ @NotBlank(message = "tagId不能为空",groups = YanTaiDingShowGroup.class)
+ private String tagId;
}
diff --git a/epmet-module/gov-voice/gov-voice-client/src/main/java/com/epmet/dto/form/TagCustomerFormDTO.java b/epmet-module/gov-voice/gov-voice-client/src/main/java/com/epmet/dto/form/TagCustomerFormDTO.java
new file mode 100644
index 0000000000..d27d57e3f4
--- /dev/null
+++ b/epmet-module/gov-voice/gov-voice-client/src/main/java/com/epmet/dto/form/TagCustomerFormDTO.java
@@ -0,0 +1,56 @@
+package com.epmet.dto.form;
+
+import com.epmet.commons.tools.validator.group.CustomerClientShowGroup;
+import com.epmet.dto.TagScopeDTO;
+import lombok.Data;
+import org.hibernate.validator.constraints.Length;
+
+import javax.validation.constraints.NotBlank;
+import java.io.Serializable;
+import java.util.List;
+
+/**
+ * @Description
+ * @Author yzm
+ * @Date 2023/3/2 12:47
+ */
+@Data
+public class TagCustomerFormDTO implements Serializable {
+ private static final long serialVersionUID = -5631868409077026783L;
+
+ public interface AddUserInternalGroup {
+ }
+
+ public interface AddUserShowGroup extends CustomerClientShowGroup {
+ }
+
+ public interface UpdateUserInternalGroup {
+ }
+
+ public interface UpdateUserShowGroup extends CustomerClientShowGroup {
+ }
+
+
+ /**
+ * 主键ID
+ */
+ @NotBlank(message = "id不能为空", groups = {UpdateUserInternalGroup.class})
+ private String id;
+
+ /**
+ * 标签名称
+ */
+ @Length(max = 30, message = "标签名称最多输入30字", groups = {AddUserShowGroup.class, UpdateUserShowGroup.class})
+ @NotBlank(message = "标签名称不能为空", groups = {AddUserShowGroup.class, UpdateUserShowGroup.class})
+ private String tagName;
+
+ /**
+ * 应用范围,只能选社区
+ */
+ private List agencyList;
+ /**
+ * 客户ID
+ */
+ private String customerId;
+}
+
diff --git a/epmet-module/gov-voice/gov-voice-client/src/main/java/com/epmet/dto/form/TagCustomerPageFormDTO.java b/epmet-module/gov-voice/gov-voice-client/src/main/java/com/epmet/dto/form/TagCustomerPageFormDTO.java
new file mode 100644
index 0000000000..04ee2370eb
--- /dev/null
+++ b/epmet-module/gov-voice/gov-voice-client/src/main/java/com/epmet/dto/form/TagCustomerPageFormDTO.java
@@ -0,0 +1,44 @@
+package com.epmet.dto.form;
+
+import com.epmet.commons.tools.validator.group.CustomerClientShowGroup;
+import lombok.Data;
+
+import javax.validation.constraints.NotBlank;
+import javax.validation.constraints.NotNull;
+import java.io.Serializable;
+
+/**
+ * @Description pc标签管理-分页查询入参
+ * @Author yzm
+ * @Date 2023/3/2 11:34
+ */
+@Data
+public class TagCustomerPageFormDTO implements Serializable {
+ private static final long serialVersionUID = -2311491158902019019L;
+
+ public interface PageUserInternalGroup {
+ }
+
+ public interface PageUserShowGroup extends CustomerClientShowGroup {
+ }
+
+
+ /**
+ * 客户ID
+ */
+ @NotBlank(message = "customerId不能为空", groups = PageUserInternalGroup.class)
+ private String customerId;
+
+ /**
+ * 标签名称
+ */
+ private String tagName;
+
+
+ @NotNull(message = "页码不能为空", groups = PageUserInternalGroup.class)
+ private Integer pageNo;
+
+ @NotNull(message = "每页数量不能为空", groups = PageUserInternalGroup.class)
+ private Integer pageSize;
+}
+
diff --git a/epmet-module/gov-voice/gov-voice-server/Dockerfile b/epmet-module/gov-voice/gov-voice-server/Dockerfile
index 503cab5fd2..20f0a484b1 100644
--- a/epmet-module/gov-voice/gov-voice-server/Dockerfile
+++ b/epmet-module/gov-voice/gov-voice-server/Dockerfile
@@ -1,4 +1,4 @@
-FROM java:8
+FROM openjdk:8-jre
RUN export LANG="zh_CN.UTF-8"
RUN ln -sf /usr/share/zoneinfo/Asia/Shanghai /etc/localtime
diff --git a/epmet-module/gov-voice/gov-voice-server/src/main/java/com/epmet/controller/ArticleController.java b/epmet-module/gov-voice/gov-voice-server/src/main/java/com/epmet/controller/ArticleController.java
index a984a8a42a..77ef7f4361 100644
--- a/epmet-module/gov-voice/gov-voice-server/src/main/java/com/epmet/controller/ArticleController.java
+++ b/epmet-module/gov-voice/gov-voice-server/src/main/java/com/epmet/controller/ArticleController.java
@@ -338,11 +338,12 @@ public class ArticleController {
*/
@PostMapping("article-list-ytding")
public Result> pageArticleListByTagName(@RequestBody CommonArticleListFormDTO formDTO) {
- ValidatorUtils.validateEntity(formDTO, CommonArticleListFormDTO.YanTaiShowGroup.class);
+ ValidatorUtils.validateEntity(formDTO, CommonArticleListFormDTO.YanTaiDingShowGroup.class);
return new Result>().ok(articleService.pageArticleListByTagName(formDTO.getPageNo(),
formDTO.getPageSize(),
formDTO.getGridId(),
- formDTO.getTagName()));
+ formDTO.getTagName(),
+ formDTO.getTagId()));
}
diff --git a/epmet-module/gov-voice/gov-voice-server/src/main/java/com/epmet/controller/TagController.java b/epmet-module/gov-voice/gov-voice-server/src/main/java/com/epmet/controller/TagController.java
index bd2603685b..42b845210c 100644
--- a/epmet-module/gov-voice/gov-voice-server/src/main/java/com/epmet/controller/TagController.java
+++ b/epmet-module/gov-voice/gov-voice-server/src/main/java/com/epmet/controller/TagController.java
@@ -1,21 +1,21 @@
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.Result;
import com.epmet.commons.tools.validator.ValidatorUtils;
-import com.epmet.dto.form.CorrelationTagListFormDTO;
-import com.epmet.dto.form.InitTagFormDTO;
-import com.epmet.dto.form.ResiTagListFormDTO;
-import com.epmet.dto.form.TagCascadeListFormDTO;
+import com.epmet.dto.TagCustomerDTO;
+import com.epmet.dto.TagScopeDTO;
+import com.epmet.dto.form.*;
import com.epmet.dto.result.CorrelationTagListResultDTO;
import com.epmet.dto.result.TagInfoResultDTO;
+import com.epmet.service.TagCustomerService;
import com.epmet.service.TagService;
+import org.apache.commons.collections4.CollectionUtils;
+import org.apache.commons.lang3.StringUtils;
import org.springframework.beans.factory.annotation.Autowired;
-import org.springframework.web.bind.annotation.PostMapping;
-import org.springframework.web.bind.annotation.RequestBody;
-import org.springframework.web.bind.annotation.RequestMapping;
-import org.springframework.web.bind.annotation.RestController;
+import org.springframework.web.bind.annotation.*;
import java.util.List;
@@ -25,11 +25,14 @@ public class TagController {
@Autowired
private TagService tagService;
+ @Autowired
+ private TagCustomerService tagCustomerService;
/**
* @Description 已发布列表页的标签——政府端
* @param tokenDto
* @author zxc
+ * 补充:pc党建声音查询条件、新增弹框中的标签下拉框也调用的此接口
*/
@PostMapping("taglist")
// @RequirePermission(requirePermission = RequirePermissionEnum.WORK_PARTY_VOICE_PUBLISHED_LIST)
@@ -81,4 +84,96 @@ public class TagController {
return new Result().ok(tagService.initTag(formDto));
}
+ /**
+ * pc标签管理-分页查询
+ * @param formDTO
+ * @return
+ */
+ @PostMapping("page-list")
+ public Result> pageList(@LoginUser TokenDto tokenDto,@RequestBody TagCustomerPageFormDTO formDTO){
+ formDTO.setCustomerId(tokenDto.getCustomerId());
+ ValidatorUtils.validateEntity(formDTO,TagCustomerPageFormDTO.PageUserInternalGroup.class,TagCustomerPageFormDTO.PageUserShowGroup.class);
+ return new Result>().ok(tagCustomerService.page(formDTO));
+ }
+
+ /**
+ * 新增标签
+ * @param tokenDto
+ * @param formDTO
+ * @return
+ */
+ @PostMapping("save")
+ public Result save(@LoginUser TokenDto tokenDto,@RequestBody TagCustomerFormDTO formDTO){
+ formDTO.setCustomerId(tokenDto.getCustomerId());
+ if(CollectionUtils.isNotEmpty(formDTO.getAgencyList())){
+ ValidatorUtils.validateEntity(formDTO.getAgencyList(), TagScopeDTO.AddUserShowGroup.class);
+ }
+ ValidatorUtils.validateEntity(formDTO,TagCustomerFormDTO.AddUserShowGroup.class,TagCustomerFormDTO.AddUserInternalGroup.class);
+ tagCustomerService.save(formDTO);
+ return new Result();
+ }
+
+ /**
+ * 修改标签
+ * @param tokenDto
+ * @param formDTO
+ * @return
+ */
+ @PostMapping("update")
+ public Result update(@LoginUser TokenDto tokenDto,@RequestBody TagCustomerFormDTO formDTO){
+ formDTO.setCustomerId(tokenDto.getCustomerId());
+ if(CollectionUtils.isNotEmpty(formDTO.getAgencyList())){
+ ValidatorUtils.validateEntity(formDTO.getAgencyList(), TagScopeDTO.AddUserShowGroup.class);
+ }
+ ValidatorUtils.validateEntity(formDTO,TagCustomerFormDTO.UpdateUserShowGroup.class,TagCustomerFormDTO.UpdateUserInternalGroup.class);
+ tagCustomerService.update(formDTO);
+ return new Result();
+ }
+
+ /**
+ * 隐藏、显示
+ * @param tagCustomerDTO
+ * @return
+ */
+ @PostMapping("change-show-flag")
+ public Result changeShowFlag(@RequestBody TagCustomerDTO tagCustomerDTO){
+ tagCustomerService.changeShowFlag(tagCustomerDTO.getId(),tagCustomerDTO.getShowFlag());
+ return new Result();
+ }
+
+ /**
+ * 初始化标签应用范围,
+ * 每个标签,和当前客户下所有社区关联
+ * @param tokenDto
+ * @return
+ */
+ @PostMapping("initTagScope")
+ public Result initTagScope(@LoginUser TokenDto tokenDto){
+ tagCustomerService.initTagScope(tokenDto.getCustomerId());
+ return new Result();
+ }
+
+ /**
+ * 钉钉实时动态,获取网格所属社区下, 的标签列表 只返回tagId,tagName
+ * @param gridId
+ * @return
+ */
+ @PostMapping("getAgencyTag/{gridId}")
+ public Result> getAgencyTag(@PathVariable("gridId")String gridId){
+ if(StringUtils.isBlank(gridId)){
+ return new Result<>();
+ }
+ return new Result>().ok(tagCustomerService.getAgencyTag(gridId));
+ }
+
+ /**
+ * 工作端获取登录用户所属组织下的标签列表
+ *
+ * @param tokenDto
+ * @return
+ */
+ @PostMapping("queryAgencyTag")
+ public Result> queryAgencyTag(@LoginUser TokenDto tokenDto) {
+ return new Result>().ok(tagCustomerService.queryAgencyTag(tokenDto.getCustomerId(),tokenDto.getUserId()));
+ }
}
diff --git a/epmet-module/gov-voice/gov-voice-server/src/main/java/com/epmet/dao/ArticleDao.java b/epmet-module/gov-voice/gov-voice-server/src/main/java/com/epmet/dao/ArticleDao.java
index 53524c9bb7..c974947186 100644
--- a/epmet-module/gov-voice/gov-voice-server/src/main/java/com/epmet/dao/ArticleDao.java
+++ b/epmet-module/gov-voice/gov-voice-server/src/main/java/com/epmet/dao/ArticleDao.java
@@ -178,5 +178,6 @@ public interface ArticleDao extends BaseDao {
List pageArticleListByTagName(@Param("gridId")String gridId,
@Param("tagName")String tagName,
@Param("customerId")String customerId,
- @Param("agencyId")String agencyId);
+ @Param("agencyId")String agencyId,
+ @Param("tagId")String tagId);
}
diff --git a/epmet-module/gov-voice/gov-voice-server/src/main/java/com/epmet/dao/TagCustomerDao.java b/epmet-module/gov-voice/gov-voice-server/src/main/java/com/epmet/dao/TagCustomerDao.java
index 595f2a9a18..fcc0e268a7 100644
--- a/epmet-module/gov-voice/gov-voice-server/src/main/java/com/epmet/dao/TagCustomerDao.java
+++ b/epmet-module/gov-voice/gov-voice-server/src/main/java/com/epmet/dao/TagCustomerDao.java
@@ -18,6 +18,7 @@
package com.epmet.dao;
import com.epmet.commons.mybatis.dao.BaseDao;
+import com.epmet.dto.TagCustomerDTO;
import com.epmet.dto.form.InitTagsFormDTO;
import com.epmet.dto.form.UpdateTagFormDTO;
import com.epmet.entity.TagCustomerEntity;
@@ -55,4 +56,18 @@ public interface TagCustomerDao extends BaseDao {
* @return
*/
List selectInitData(@Param("customerIdList") List customerIdList);
+
+ /**
+ * pc标签管理-分页查询
+ * @param customerId
+ * @param tagName
+ * @return
+ */
+ List pageList(@Param("customerId") String customerId, @Param("tagName")String tagName);
+
+ /**
+ * 钉钉实时动态,获取网格所属社区下, 的标签列表
+ * 只返回tagId,tagName
+ */
+ List getAgencyTag(@Param("agencyId")String agencyId,@Param("customerId") String customerId);
}
diff --git a/epmet-module/gov-voice/gov-voice-server/src/main/java/com/epmet/dao/TagScopeDao.java b/epmet-module/gov-voice/gov-voice-server/src/main/java/com/epmet/dao/TagScopeDao.java
new file mode 100644
index 0000000000..411801f4b5
--- /dev/null
+++ b/epmet-module/gov-voice/gov-voice-server/src/main/java/com/epmet/dao/TagScopeDao.java
@@ -0,0 +1,23 @@
+package com.epmet.dao;
+
+import com.epmet.commons.mybatis.dao.BaseDao;
+import com.epmet.dto.TagScopeDTO;
+import com.epmet.entity.TagScopeEntity;
+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 2023-03-02
+ */
+@Mapper
+public interface TagScopeDao extends BaseDao {
+
+ int deleteByTagId(@Param("tagId") String tagId, @Param("customerId") String customerId);
+
+ List selectScope(String tagId);
+}
\ No newline at end of file
diff --git a/epmet-module/gov-voice/gov-voice-server/src/main/java/com/epmet/entity/TagCustomerEntity.java b/epmet-module/gov-voice/gov-voice-server/src/main/java/com/epmet/entity/TagCustomerEntity.java
index 7a2a54d7ae..e86fbb2231 100644
--- a/epmet-module/gov-voice/gov-voice-server/src/main/java/com/epmet/entity/TagCustomerEntity.java
+++ b/epmet-module/gov-voice/gov-voice-server/src/main/java/com/epmet/entity/TagCustomerEntity.java
@@ -55,4 +55,8 @@ public class TagCustomerEntity extends BaseEpmetEntity {
*/
private Integer useCount;
+ /**
+ * 1:展示;0:隐藏;0302因烟台需求增加此列默认1
+ */
+ private Integer showFlag;
}
diff --git a/epmet-module/gov-voice/gov-voice-server/src/main/java/com/epmet/entity/TagScopeEntity.java b/epmet-module/gov-voice/gov-voice-server/src/main/java/com/epmet/entity/TagScopeEntity.java
new file mode 100644
index 0000000000..7e00ef4919
--- /dev/null
+++ b/epmet-module/gov-voice/gov-voice-server/src/main/java/com/epmet/entity/TagScopeEntity.java
@@ -0,0 +1,41 @@
+package com.epmet.entity;
+
+import com.baomidou.mybatisplus.annotation.TableName;
+import com.epmet.commons.mybatis.entity.BaseEpmetEntity;
+import lombok.Data;
+import lombok.EqualsAndHashCode;
+
+/**
+ * 标签应用范围表
+ *
+ * @author generator generator@elink-cn.com
+ * @since v1.0.0 2023-03-02
+ */
+@Data
+@EqualsAndHashCode(callSuper=false)
+@TableName("tag_scope")
+public class TagScopeEntity extends BaseEpmetEntity {
+
+ private static final long serialVersionUID = 1L;
+
+ /**
+ * 客户ID(0302因烟台需求增加此表)
+ */
+ private String customerId;
+
+ /**
+ * 标签ID
+ */
+ private String tagId;
+
+ /**
+ * 应用范围,这里只能是社区id
+ */
+ private String agencyId;
+
+ /**
+ * agency_id全路径,包含自身
+ */
+ private String orgIdPath;
+
+}
diff --git a/epmet-module/gov-voice/gov-voice-server/src/main/java/com/epmet/service/ArticleService.java b/epmet-module/gov-voice/gov-voice-server/src/main/java/com/epmet/service/ArticleService.java
index d9374b1263..499ed51ab9 100644
--- a/epmet-module/gov-voice/gov-voice-server/src/main/java/com/epmet/service/ArticleService.java
+++ b/epmet-module/gov-voice/gov-voice-server/src/main/java/com/epmet/service/ArticleService.java
@@ -291,5 +291,6 @@ public interface ArticleService extends BaseService {
PageData pageArticleListByTagName(Integer pageNo,
Integer pageSize,
String gridId,
- String tagName);
+ String tagName,
+ String tagId);
}
\ No newline at end of file
diff --git a/epmet-module/gov-voice/gov-voice-server/src/main/java/com/epmet/service/TagCustomerService.java b/epmet-module/gov-voice/gov-voice-server/src/main/java/com/epmet/service/TagCustomerService.java
index 3ecb3c49c1..9bf4022967 100644
--- a/epmet-module/gov-voice/gov-voice-server/src/main/java/com/epmet/service/TagCustomerService.java
+++ b/epmet-module/gov-voice/gov-voice-server/src/main/java/com/epmet/service/TagCustomerService.java
@@ -20,11 +20,13 @@ package com.epmet.service;
import com.epmet.commons.mybatis.service.BaseService;
import com.epmet.commons.tools.page.PageData;
import com.epmet.dto.TagCustomerDTO;
+import com.epmet.dto.form.TagCustomerFormDTO;
+import com.epmet.dto.form.TagCustomerPageFormDTO;
+import com.epmet.dto.result.TagInfoResultDTO;
import com.epmet.dto.result.UpdateTagUseCountsResultDTO;
import com.epmet.entity.TagCustomerEntity;
import java.util.List;
-import java.util.Map;
/**
* 客户标签表
@@ -35,24 +37,14 @@ import java.util.Map;
public interface TagCustomerService extends BaseService {
/**
- * 默认分页
+ * pc标签管理-分页查询
*
- * @param params
+ * @param formDTO
* @return PageData
* @author generator
* @date 2020-06-02
*/
- PageData page(Map params);
-
- /**
- * 默认查询
- *
- * @param params
- * @return java.util.List
- * @author generator
- * @date 2020-06-02
- */
- List list(Map params);
+ PageData page(TagCustomerPageFormDTO formDTO);
/**
* 单条查询
@@ -65,24 +57,24 @@ public interface TagCustomerService extends BaseService {
TagCustomerDTO get(String id);
/**
- * 默认保存
+ * 新增标签
*
* @param dto
* @return void
* @author generator
* @date 2020-06-02
*/
- void save(TagCustomerDTO dto);
+ void save(TagCustomerFormDTO dto);
/**
- * 默认更新
+ * 修改标签
*
* @param dto
* @return void
* @author generator
* @date 2020-06-02
*/
- void update(TagCustomerDTO dto);
+ void update(TagCustomerFormDTO dto);
/**
* 批量删除
@@ -100,4 +92,34 @@ public interface TagCustomerService extends BaseService {
* @author zxc
*/
UpdateTagUseCountsResultDTO checkTagInfo(String tagName,String customerId,String userId);
+
+ /**
+ * 隐藏、显示
+ * @param id
+ * @param showFlag
+ */
+ void changeShowFlag(String id, Integer showFlag);
+
+ /**
+ * 初始化标签应用范围,
+ * 每个标签,和当前客户下所有社区关联
+ * @param tokenDto
+ * @return
+ */
+ void initTagScope(String customerId);
+
+ /**
+ * 钉钉实时动态,获取网格所属社区下, 的标签列表
+ * 只返回tagId,tagName
+ * @param gridId
+ * @return
+ */
+ List getAgencyTag(String gridId);
+
+ /**
+ * 工作端获取登录用户所属组织下的标签列表
+ * @param staffId
+ * @return
+ */
+ List queryAgencyTag(String customerId,String staffId);
}
\ No newline at end of file
diff --git a/epmet-module/gov-voice/gov-voice-server/src/main/java/com/epmet/service/impl/ArticleServiceImpl.java b/epmet-module/gov-voice/gov-voice-server/src/main/java/com/epmet/service/impl/ArticleServiceImpl.java
index a1777b5056..f51705afdd 100644
--- a/epmet-module/gov-voice/gov-voice-server/src/main/java/com/epmet/service/impl/ArticleServiceImpl.java
+++ b/epmet-module/gov-voice/gov-voice-server/src/main/java/com/epmet/service/impl/ArticleServiceImpl.java
@@ -2014,13 +2014,14 @@ public class ArticleServiceImpl extends BaseServiceImpl pageArticleListByTagName(Integer pageNo, Integer pageSize, String gridId, String tagName) {
+ public PageData pageArticleListByTagName(Integer pageNo, Integer pageSize, String gridId, String tagName,String tagId) {
PageHelper.startPage(pageNo, pageSize);
List list = baseDao.pageArticleListByTagName(
gridId,
tagName,
EpmetRequestHolder.getLoginUserCustomerId(),
- null);
+ null,
+ tagId);
PageInfo pageInfo = new PageInfo<>(list);
return new PageData<>(list, pageInfo.getTotal());
}
diff --git a/epmet-module/gov-voice/gov-voice-server/src/main/java/com/epmet/service/impl/TagCustomerServiceImpl.java b/epmet-module/gov-voice/gov-voice-server/src/main/java/com/epmet/service/impl/TagCustomerServiceImpl.java
index b5c69d76c1..dd37b13abf 100644
--- a/epmet-module/gov-voice/gov-voice-server/src/main/java/com/epmet/service/impl/TagCustomerServiceImpl.java
+++ b/epmet-module/gov-voice/gov-voice-server/src/main/java/com/epmet/service/impl/TagCustomerServiceImpl.java
@@ -17,26 +17,50 @@
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.conditions.query.LambdaQueryWrapper;
+import com.baomidou.mybatisplus.core.conditions.update.LambdaUpdateWrapper;
import com.epmet.commons.mybatis.service.impl.BaseServiceImpl;
-import com.epmet.commons.tools.constant.FieldConstant;
+import com.epmet.commons.tools.constant.NumConstant;
+import com.epmet.commons.tools.constant.StrConstant;
+import com.epmet.commons.tools.dto.result.CustomerStaffInfoCacheResult;
+import com.epmet.commons.tools.exception.EpmetErrorCode;
+import com.epmet.commons.tools.exception.EpmetException;
import com.epmet.commons.tools.page.PageData;
+import com.epmet.commons.tools.redis.common.CustomerOrgRedis;
+import com.epmet.commons.tools.redis.common.CustomerStaffRedis;
+import com.epmet.commons.tools.redis.common.bean.GridInfoCache;
import com.epmet.commons.tools.utils.ConvertUtils;
+import com.epmet.commons.tools.utils.EpmetRequestHolder;
+import com.epmet.commons.tools.utils.Result;
import com.epmet.dao.TagCustomerDao;
+import com.epmet.dao.TagScopeDao;
import com.epmet.dto.TagCustomerDTO;
+import com.epmet.dto.form.TagCustomerFormDTO;
+import com.epmet.dto.form.TagCustomerPageFormDTO;
import com.epmet.dto.form.UpdateTagFormDTO;
+import com.epmet.dto.result.AgencyResultDTO;
+import com.epmet.dto.result.TagInfoResultDTO;
import com.epmet.dto.result.UpdateTagUseCountsResultDTO;
import com.epmet.entity.TagCustomerEntity;
+import com.epmet.entity.TagScopeEntity;
+import com.epmet.feign.GovOrgOpenFeignClient;
+import com.epmet.redis.TagRedis;
import com.epmet.service.TagCustomerService;
import com.epmet.utils.TagColorUtils;
+import com.github.pagehelper.PageHelper;
+import com.github.pagehelper.PageInfo;
+import lombok.extern.slf4j.Slf4j;
+import org.apache.commons.collections4.CollectionUtils;
import org.apache.commons.lang3.StringUtils;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.scheduling.annotation.Async;
import org.springframework.stereotype.Service;
import org.springframework.transaction.annotation.Transactional;
+import java.util.ArrayList;
import java.util.Arrays;
+import java.util.Date;
import java.util.List;
-import java.util.Map;
/**
* 客户标签表
@@ -44,32 +68,27 @@ import java.util.Map;
* @author generator generator@elink-cn.com
* @since v1.0.0 2020-06-02
*/
+@Slf4j
@Service
public class TagCustomerServiceImpl extends BaseServiceImpl implements TagCustomerService {
+ @Autowired
+ private TagScopeDao tagScopeDao;
+ @Autowired
+ private GovOrgOpenFeignClient govOrgOpenFeignClient;
+ @Autowired
+ private TagRedis tagRedis;
+ /**
+ * pc标签管理-分页查询
+ * @param formDTO
+ * @return
+ */
@Override
- public PageData page(Map params) {
- IPage page = baseDao.selectPage(
- getPage(params, FieldConstant.CREATED_TIME, false),
- getWrapper(params)
- );
- return getPageData(page, TagCustomerDTO.class);
- }
-
- @Override
- public List list(Map params) {
- List entityList = baseDao.selectList(getWrapper(params));
-
- return ConvertUtils.sourceToTarget(entityList, TagCustomerDTO.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;
+ public PageData page(TagCustomerPageFormDTO formDTO) {
+ PageHelper.startPage(formDTO.getPageNo(),formDTO.getPageSize());
+ List list=baseDao.pageList(formDTO.getCustomerId(),formDTO.getTagName());
+ PageInfo pageInfo = new PageInfo<>(list);
+ return new PageData<>(list, pageInfo.getTotal());
}
@Override
@@ -78,18 +97,69 @@ public class TagCustomerServiceImpl extends BaseServiceImpl queryWrapper=new LambdaQueryWrapper<>();
+ queryWrapper.eq(TagCustomerEntity::getCustomerId,dto.getCustomerId())
+ .eq(TagCustomerEntity::getTagName,dto.getTagName());
+ if(baseDao.selectCount(queryWrapper)>0){
+ throw new EpmetException(EpmetErrorCode.EPMET_COMMON_OPERATION_FAIL.getCode(),"标签名称已存在","标签名称已存在");
+ }
TagCustomerEntity entity = ConvertUtils.sourceToTarget(dto, TagCustomerEntity.class);
+ entity.setTagColor(StrConstant.EPMETY_STR);
+ entity.setUseCount(NumConstant.ZERO);
+ entity.setShowFlag(NumConstant.ONE);
insert(entity);
+ if(CollectionUtils.isNotEmpty(dto.getAgencyList())){
+ dto.getAgencyList().forEach(tagScopeDTO->{
+ TagScopeEntity tagScopeEntity=new TagScopeEntity();
+ tagScopeEntity.setCustomerId(entity.getCustomerId());
+ tagScopeEntity.setTagId(entity.getId());
+ tagScopeEntity.setAgencyId(tagScopeDTO.getAgencyId());
+ tagScopeEntity.setOrgIdPath(tagScopeDTO.getOrgIdPath());
+ tagScopeDao.insert(tagScopeEntity);
+ });
+ }
+ //删除redis缓存
+ tagRedis.clearCustomerTag(dto.getCustomerId());
}
+ /**
+ * pc标签管理-修改
+ * @param dto
+ */
@Override
@Transactional(rollbackFor = Exception.class)
- public void update(TagCustomerDTO dto) {
+ public void update(TagCustomerFormDTO dto) {
+ // 标签名称是否存在
+ LambdaQueryWrapper queryWrapper=new LambdaQueryWrapper<>();
+ queryWrapper.eq(TagCustomerEntity::getCustomerId,dto.getCustomerId())
+ .eq(TagCustomerEntity::getTagName,dto.getTagName())
+ .ne(TagCustomerEntity::getId,dto.getId());
+ if(baseDao.selectCount(queryWrapper)>0){
+ throw new EpmetException(EpmetErrorCode.EPMET_COMMON_OPERATION_FAIL.getCode(),"标签名称已存在","标签名称已存在");
+ }
TagCustomerEntity entity = ConvertUtils.sourceToTarget(dto, TagCustomerEntity.class);
updateById(entity);
+ //删除应用范围
+ tagScopeDao.deleteByTagId(entity.getId(),entity.getCustomerId());
+ if(CollectionUtils.isNotEmpty(dto.getAgencyList())){
+ dto.getAgencyList().forEach(tagScopeDTO->{
+ TagScopeEntity tagScopeEntity=new TagScopeEntity();
+ tagScopeEntity.setCustomerId(entity.getCustomerId());
+ tagScopeEntity.setTagId(entity.getId());
+ tagScopeEntity.setAgencyId(tagScopeDTO.getAgencyId());
+ tagScopeEntity.setOrgIdPath(tagScopeDTO.getOrgIdPath());
+ tagScopeDao.insert(tagScopeEntity);
+ });
+ }
+ tagRedis.clearCustomerTag(dto.getCustomerId());
}
@Override
@@ -126,4 +196,99 @@ public class TagCustomerServiceImpl extends BaseServiceImpl tagCustomerUpdateWrapper = new LambdaUpdateWrapper<>();
+ tagCustomerUpdateWrapper.eq(TagCustomerEntity::getId, id)
+ .set(TagCustomerEntity::getUpdatedBy, EpmetRequestHolder.getLoginUserId())
+ .set(TagCustomerEntity::getUpdatedTime, new Date())
+ .set(TagCustomerEntity::getShowFlag,showFlag);
+ baseDao.update(null,tagCustomerUpdateWrapper);
+ tagRedis.clearCustomerTag(EpmetRequestHolder.getLoginUserCustomerId());
+ }
+
+ /**
+ * 初始化标签应用范围,
+ * 每个标签,和当前客户下所有社区关联
+ *
+ * @param customerId@return
+ */
+ @Async
+ @Override
+ public void initTagScope(String customerId) {
+ if (StringUtils.isBlank(customerId)) {
+ return;
+ }
+ LambdaQueryWrapper queryWrapper = new LambdaQueryWrapper();
+ queryWrapper.eq(TagCustomerEntity::getCustomerId, customerId);
+ List tagList = baseDao.selectList(queryWrapper);
+ if (CollectionUtils.isEmpty(tagList)) {
+ return;
+ }
+ int tagTotal = tagList.size();
+ // 获取当前客户下所有的社区组织
+ Result> communityRes = govOrgOpenFeignClient.getAllCommunity(customerId);
+ if (communityRes.success() && CollectionUtils.isNotEmpty(communityRes.getData())) {
+ int communityTotal = communityRes.getData().size();
+ int num = 0;
+ for (TagCustomerEntity tag : tagList) {
+ for (AgencyResultDTO agencyResultDTO : communityRes.getData()) {
+ TagScopeEntity tagScopeEntity = new TagScopeEntity();
+ tagScopeEntity.setCustomerId(tag.getCustomerId());
+ tagScopeEntity.setTagId(tag.getId());
+ tagScopeEntity.setAgencyId(agencyResultDTO.getAgencyId());
+ tagScopeEntity.setOrgIdPath(agencyResultDTO.getOrgIdPath());
+ tagScopeDao.insert(tagScopeEntity);
+ num++;
+ }
+ }
+ log.error(String.format("customerId:%s,已经将%s个标签应用给%s个社区,tag_scope产生%s条记录", customerId, tagTotal, communityTotal, num));
+ }
+
+ }
+
+
+ /**
+ * 钉钉实时动态,获取网格所属社区下, 的标签列表
+ * 只返回tagId,tagName
+ *
+ * @param gridId
+ * @return
+ */
+ @Override
+ public List getAgencyTag(String gridId) {
+ GridInfoCache gridInfoCache= CustomerOrgRedis.getGridInfo(gridId);
+ if(null==gridInfoCache){
+ throw new EpmetException(EpmetErrorCode.EPMET_COMMON_OPERATION_FAIL.getCode(),"查询网格信息异常gridId:"+gridId,"查询网格信息异常");
+ }
+ List list=baseDao.getAgencyTag(gridInfoCache.getPid(),gridInfoCache.getCustomerId());
+ return list;
+ }
+
+ /**
+ * 工作端获取登录用户所属组织下的标签列表
+ *
+ * @param staffId
+ * @return
+ */
+ @Override
+ public List queryAgencyTag(String customerId,String staffId) {
+ CustomerStaffInfoCacheResult staffInfoCacheResult= CustomerStaffRedis.getStaffInfo(customerId,staffId);
+ List list=baseDao.getAgencyTag(staffInfoCacheResult.getAgencyId(),customerId);
+ List resultDTOList=new ArrayList<>();
+ list.forEach(tagCustomerDTO->{
+ TagInfoResultDTO resultDTO=new TagInfoResultDTO();
+ resultDTO.setTagId(tagCustomerDTO.getId());
+ resultDTO.setTagColor(tagCustomerDTO.getTagColor());
+ resultDTO.setTagName(tagCustomerDTO.getTagName());
+ resultDTOList.add(resultDTO);
+ });
+ return resultDTOList;
+ }
}
diff --git a/epmet-module/gov-voice/gov-voice-server/src/main/java/com/epmet/service/impl/TagServiceImpl.java b/epmet-module/gov-voice/gov-voice-server/src/main/java/com/epmet/service/impl/TagServiceImpl.java
index cbfba74bb5..b85a637634 100644
--- a/epmet-module/gov-voice/gov-voice-server/src/main/java/com/epmet/service/impl/TagServiceImpl.java
+++ b/epmet-module/gov-voice/gov-voice-server/src/main/java/com/epmet/service/impl/TagServiceImpl.java
@@ -57,6 +57,7 @@ public class TagServiceImpl implements TagService {
* @Description 已发布列表页的标签——政府端
* @param tokenDto
* @author zxc
+ * 补充:pc党建声音查询条件、新增弹框中的标签下拉框也调用的此接口
*/
@Override
@Transactional(rollbackFor = Exception.class)
@@ -64,6 +65,7 @@ public class TagServiceImpl implements TagService {
String customerId = tokenDto.getCustomerId();
List resultDtos = tagRedis.zRevRange(customerId);
if (resultDtos.size() == NumConstant.ZERO){
+ //初始化标签
resultDtos = this.initTags(customerId);
}
return resultDtos;
diff --git a/epmet-module/gov-voice/gov-voice-server/src/main/resources/mapper/ArticleDao.xml b/epmet-module/gov-voice/gov-voice-server/src/main/resources/mapper/ArticleDao.xml
index 5e67b953a0..04b8d0d712 100644
--- a/epmet-module/gov-voice/gov-voice-server/src/main/resources/mapper/ArticleDao.xml
+++ b/epmet-module/gov-voice/gov-voice-server/src/main/resources/mapper/ArticleDao.xml
@@ -543,6 +543,9 @@
AND art.org_id_path like concat('%',#{agencyId},'%')
+
+ AND t.tag_id =#{tagId}
+
ORDER BY
art.PUBLISH_DATE DESC,
art.CREATED_TIME DESC
diff --git a/epmet-module/gov-voice/gov-voice-server/src/main/resources/mapper/TagCustomerDao.xml b/epmet-module/gov-voice/gov-voice-server/src/main/resources/mapper/TagCustomerDao.xml
index 83ed4289ad..8d10cda3fa 100644
--- a/epmet-module/gov-voice/gov-voice-server/src/main/resources/mapper/TagCustomerDao.xml
+++ b/epmet-module/gov-voice/gov-voice-server/src/main/resources/mapper/TagCustomerDao.xml
@@ -56,4 +56,40 @@
ORDER BY CUSTOMER_ID
+
+
+
+
+
+
+
+
+
+
+
+
+
+
diff --git a/epmet-module/gov-voice/gov-voice-server/src/main/resources/mapper/TagScopeDao.xml b/epmet-module/gov-voice/gov-voice-server/src/main/resources/mapper/TagScopeDao.xml
new file mode 100644
index 0000000000..3d132f74c5
--- /dev/null
+++ b/epmet-module/gov-voice/gov-voice-server/src/main/resources/mapper/TagScopeDao.xml
@@ -0,0 +1,34 @@
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+ delete from tag_scope
+ where TAG_ID=#{tagId}
+ and CUSTOMER_ID=#{customerId}
+
+
+
+
\ No newline at end of file
diff --git a/epmet-module/open-data-worker/open-data-worker-server/Dockerfile b/epmet-module/open-data-worker/open-data-worker-server/Dockerfile
index bdbf6243c4..003b91b84e 100644
--- a/epmet-module/open-data-worker/open-data-worker-server/Dockerfile
+++ b/epmet-module/open-data-worker/open-data-worker-server/Dockerfile
@@ -1,4 +1,4 @@
-FROM java:8
+FROM openjdk:8-jre
RUN export LANG="zh_CN.UTF-8"
RUN ln -sf /usr/share/zoneinfo/Asia/Shanghai /etc/localtime
diff --git a/epmet-module/oper-access/oper-access-server/Dockerfile b/epmet-module/oper-access/oper-access-server/Dockerfile
index c4f36b4688..aeec5d2302 100644
--- a/epmet-module/oper-access/oper-access-server/Dockerfile
+++ b/epmet-module/oper-access/oper-access-server/Dockerfile
@@ -1,4 +1,4 @@
-FROM java:8
+FROM openjdk:8-jre
RUN export LANG="zh_CN.UTF-8"
RUN ln -sf /usr/share/zoneinfo/Asia/Shanghai /etc/localtime
diff --git a/epmet-module/oper-crm/oper-crm-server/Dockerfile b/epmet-module/oper-crm/oper-crm-server/Dockerfile
index ad4c30e13b..ff20b9d047 100644
--- a/epmet-module/oper-crm/oper-crm-server/Dockerfile
+++ b/epmet-module/oper-crm/oper-crm-server/Dockerfile
@@ -1,4 +1,4 @@
-FROM java:8
+FROM openjdk:8-jre
RUN export LANG="zh_CN.UTF-8"
RUN ln -sf /usr/share/zoneinfo/Asia/Shanghai /etc/localtime
diff --git a/epmet-module/oper-customize/oper-customize-server/Dockerfile b/epmet-module/oper-customize/oper-customize-server/Dockerfile
index ff1a306110..3b38f95d7b 100644
--- a/epmet-module/oper-customize/oper-customize-server/Dockerfile
+++ b/epmet-module/oper-customize/oper-customize-server/Dockerfile
@@ -1,4 +1,4 @@
-FROM java:8
+FROM openjdk:8-jre
RUN export LANG="zh_CN.UTF-8"
RUN ln -sf /usr/share/zoneinfo/Asia/Shanghai /etc/localtime
diff --git a/epmet-module/resi-group/resi-group-server/Dockerfile b/epmet-module/resi-group/resi-group-server/Dockerfile
index 29d71963fc..89ea808426 100644
--- a/epmet-module/resi-group/resi-group-server/Dockerfile
+++ b/epmet-module/resi-group/resi-group-server/Dockerfile
@@ -1,4 +1,4 @@
-FROM java:8
+FROM openjdk:8-jre
RUN export LANG="zh_CN.UTF-8"
RUN ln -sf /usr/share/zoneinfo/Asia/Shanghai /etc/localtime
diff --git a/epmet-module/resi-guide/resi-guide-server/Dockerfile b/epmet-module/resi-guide/resi-guide-server/Dockerfile
index 106fedc419..7e3a67753c 100644
--- a/epmet-module/resi-guide/resi-guide-server/Dockerfile
+++ b/epmet-module/resi-guide/resi-guide-server/Dockerfile
@@ -1,4 +1,4 @@
-FROM java:8
+FROM openjdk:8-jre
RUN export LANG="zh_CN.UTF-8"
RUN ln -sf /usr/share/zoneinfo/Asia/Shanghai /etc/localtime
diff --git a/epmet-module/resi-hall/resi-hall-server/Dockerfile b/epmet-module/resi-hall/resi-hall-server/Dockerfile
index 8e4e6cb82e..bc06f2e756 100644
--- a/epmet-module/resi-hall/resi-hall-server/Dockerfile
+++ b/epmet-module/resi-hall/resi-hall-server/Dockerfile
@@ -1,4 +1,4 @@
-FROM java:8
+FROM openjdk:8-jre
RUN export LANG="zh_CN.UTF-8"
RUN ln -sf /usr/share/zoneinfo/Asia/Shanghai /etc/localtime
diff --git a/epmet-module/resi-home/resi-home-server/Dockerfile b/epmet-module/resi-home/resi-home-server/Dockerfile
index 2cf4822bf1..cf86ae2260 100644
--- a/epmet-module/resi-home/resi-home-server/Dockerfile
+++ b/epmet-module/resi-home/resi-home-server/Dockerfile
@@ -1,4 +1,4 @@
-FROM java:8
+FROM openjdk:8-jre
RUN export LANG="zh_CN.UTF-8"
RUN ln -sf /usr/share/zoneinfo/Asia/Shanghai /etc/localtime
diff --git a/epmet-module/resi-mine/resi-mine-server/Dockerfile b/epmet-module/resi-mine/resi-mine-server/Dockerfile
index 4251aeceb6..f0ad619c9a 100644
--- a/epmet-module/resi-mine/resi-mine-server/Dockerfile
+++ b/epmet-module/resi-mine/resi-mine-server/Dockerfile
@@ -1,4 +1,4 @@
-FROM java:8
+FROM openjdk:8-jre
RUN export LANG="zh_CN.UTF-8"
RUN ln -sf /usr/share/zoneinfo/Asia/Shanghai /etc/localtime
diff --git a/epmet-module/resi-partymember/resi-partymember-server/Dockerfile b/epmet-module/resi-partymember/resi-partymember-server/Dockerfile
index 6cd220670a..e7c1437952 100644
--- a/epmet-module/resi-partymember/resi-partymember-server/Dockerfile
+++ b/epmet-module/resi-partymember/resi-partymember-server/Dockerfile
@@ -1,4 +1,4 @@
-FROM java:8
+FROM openjdk:8-jre
RUN export LANG="zh_CN.UTF-8"
RUN ln -sf /usr/share/zoneinfo/Asia/Shanghai /etc/localtime
diff --git a/epmet-module/resi-voice/resi-voice-server/Dockerfile b/epmet-module/resi-voice/resi-voice-server/Dockerfile
index d00b5083c5..620e46950d 100644
--- a/epmet-module/resi-voice/resi-voice-server/Dockerfile
+++ b/epmet-module/resi-voice/resi-voice-server/Dockerfile
@@ -1,4 +1,4 @@
-FROM java:8
+FROM openjdk:8-jre
RUN export LANG="zh_CN.UTF-8"
RUN ln -sf /usr/share/zoneinfo/Asia/Shanghai /etc/localtime
diff --git a/epmet-openapi/epmet-openapi-scan/Dockerfile b/epmet-openapi/epmet-openapi-scan/Dockerfile
index 868fc70ac1..c5a3291ef8 100644
--- a/epmet-openapi/epmet-openapi-scan/Dockerfile
+++ b/epmet-openapi/epmet-openapi-scan/Dockerfile
@@ -1,4 +1,4 @@
-FROM java:8
+FROM openjdk:8-jre
RUN export LANG="zh_CN.UTF-8"
RUN ln -sf /usr/share/zoneinfo/Asia/Shanghai /etc/localtime
diff --git a/epmet-user/epmet-user-client/src/main/java/com/epmet/dto/UserBadgeCertificateRecordDTO.java b/epmet-user/epmet-user-client/src/main/java/com/epmet/dto/UserBadgeCertificateRecordDTO.java
index 820f0fa45c..7cef9e768f 100644
--- a/epmet-user/epmet-user-client/src/main/java/com/epmet/dto/UserBadgeCertificateRecordDTO.java
+++ b/epmet-user/epmet-user-client/src/main/java/com/epmet/dto/UserBadgeCertificateRecordDTO.java
@@ -16,6 +16,10 @@ public class UserBadgeCertificateRecordDTO implements Serializable {
private String id;
private String customerId;
private String gridId;
+ /**
+ * 组织id;0306烟台需求增加
+ */
+ private String agencyId;
private String userId;
private String badgeId;
private String surname;
diff --git a/epmet-user/epmet-user-client/src/main/java/com/epmet/dto/form/BadgeAuditPageFormDTO.java b/epmet-user/epmet-user-client/src/main/java/com/epmet/dto/form/BadgeAuditPageFormDTO.java
new file mode 100644
index 0000000000..804f22ee8b
--- /dev/null
+++ b/epmet-user/epmet-user-client/src/main/java/com/epmet/dto/form/BadgeAuditPageFormDTO.java
@@ -0,0 +1,58 @@
+package com.epmet.dto.form;
+
+import com.epmet.commons.tools.validator.group.CustomerClientShowGroup;
+import lombok.Data;
+
+import javax.validation.constraints.NotBlank;
+import javax.validation.constraints.NotNull;
+import java.io.Serializable;
+
+/**
+ * @Description
+ * @Author yzm
+ * @Date 2023/3/6 9:58
+ */
+@Data
+public class BadgeAuditPageFormDTO implements Serializable {
+ private static final long serialVersionUID = -6908967598027076330L;
+
+ public interface AddUserInternalGroup {
+ }
+
+ public interface AddUserShowGroup extends CustomerClientShowGroup {
+ }
+
+ @NotBlank(message = "customerId不能为空", groups = AddUserInternalGroup.class)
+ private String customerId;
+ /**
+ * 页码
+ */
+ @NotNull(message = "pageNo不能为空", groups = AddUserInternalGroup.class)
+ private Integer pageNo;
+ /**
+ * 每页显示数量
+ */
+ @NotNull(message = "pageSize不能为空", groups = AddUserInternalGroup.class)
+ private Integer pageSize;
+ /**
+ * 当前用户所属的组织id
+ */
+ @NotBlank(message = "agencyId不能为空", groups = AddUserInternalGroup.class)
+ private String agencyId;
+
+ /**
+ * 网格Id
+ */
+ private String gridId;
+ /**
+ * 徽章id
+ */
+ private String badgeId;
+ /**
+ * 审核状态 approved:审核通过,rejected:审核驳回;auditing:审核中
+ */
+ private String auditStatus;
+
+
+}
+
diff --git a/epmet-user/epmet-user-client/src/main/java/com/epmet/dto/result/BadgeAuditRecordResultDTO.java b/epmet-user/epmet-user-client/src/main/java/com/epmet/dto/result/BadgeAuditRecordResultDTO.java
index 7ae47fdbca..2ea48afe64 100644
--- a/epmet-user/epmet-user-client/src/main/java/com/epmet/dto/result/BadgeAuditRecordResultDTO.java
+++ b/epmet-user/epmet-user-client/src/main/java/com/epmet/dto/result/BadgeAuditRecordResultDTO.java
@@ -37,7 +37,7 @@ public class BadgeAuditRecordResultDTO implements Serializable {
*/
private Long createTime;
/**
- * 用户名
+ * 审核状态 approved:审核通过,rejected:审核驳回;auditing:审核中
*/
private String auditStatus;
@@ -50,4 +50,16 @@ public class BadgeAuditRecordResultDTO implements Serializable {
* 审核记录ID
*/
private String recordId;
+
+ /**
+ * pc端徽章审核-分页列表赋值
+ * 03.07:烟台需求pc端增加徽章审核
+ */
+ private String gridId;
+ /**
+ * pc端徽章审核-分页列表赋值
+ * 03.07:烟台需求pc端增加徽章审核
+ * 网格名称:社区-网格
+ */
+ private String gridName;
}
diff --git a/epmet-user/epmet-user-client/src/main/java/com/epmet/dto/result/BadgeListResultDTO.java b/epmet-user/epmet-user-client/src/main/java/com/epmet/dto/result/BadgeListResultDTO.java
index 8374a6497e..015f0d9422 100644
--- a/epmet-user/epmet-user-client/src/main/java/com/epmet/dto/result/BadgeListResultDTO.java
+++ b/epmet-user/epmet-user-client/src/main/java/com/epmet/dto/result/BadgeListResultDTO.java
@@ -32,4 +32,5 @@ public class BadgeListResultDTO {
* 固有徽章类型 党员徽章:party;无:none
*/
private String type;
+ private String customerId;
}
diff --git a/epmet-user/epmet-user-client/src/main/java/com/epmet/dto/result/CertificationDetailResultDTO.java b/epmet-user/epmet-user-client/src/main/java/com/epmet/dto/result/CertificationDetailResultDTO.java
index 63783adc2c..abb08847ba 100644
--- a/epmet-user/epmet-user-client/src/main/java/com/epmet/dto/result/CertificationDetailResultDTO.java
+++ b/epmet-user/epmet-user-client/src/main/java/com/epmet/dto/result/CertificationDetailResultDTO.java
@@ -63,6 +63,11 @@ public class CertificationDetailResultDTO implements Serializable {
*/
private String recordId;
+ private String gridId;
+ private String gridName;
+
+ private String badgeId;
+ private String badgeName;
public CertificationDetailResultDTO() {
this.surname = "";
this.name = "";
@@ -74,5 +79,9 @@ public class CertificationDetailResultDTO implements Serializable {
this.authResult = "";
this.authReason = "";
this.recordId = "";
+ this.gridId="";
+ this.gridName="";
+ this.badgeId="";
+ this.badgeName="";
}
}
diff --git a/epmet-user/epmet-user-server/Dockerfile b/epmet-user/epmet-user-server/Dockerfile
index 0d13a2021f..ed0a37601b 100644
--- a/epmet-user/epmet-user-server/Dockerfile
+++ b/epmet-user/epmet-user-server/Dockerfile
@@ -1,4 +1,4 @@
-FROM java:8
+FROM openjdk:8-jre
RUN export LANG="zh_CN.UTF-8"
RUN ln -sf /usr/share/zoneinfo/Asia/Shanghai /etc/localtime
diff --git a/epmet-user/epmet-user-server/src/main/java/com/epmet/controller/BadgeController.java b/epmet-user/epmet-user-server/src/main/java/com/epmet/controller/BadgeController.java
index 7f58178ffe..151302844d 100644
--- a/epmet-user/epmet-user-server/src/main/java/com/epmet/controller/BadgeController.java
+++ b/epmet-user/epmet-user-server/src/main/java/com/epmet/controller/BadgeController.java
@@ -4,6 +4,7 @@ import com.epmet.commons.tools.annotation.LoginUser;
import com.epmet.commons.tools.annotation.RequirePermission;
import com.epmet.commons.tools.aop.NoRepeatSubmit;
import com.epmet.commons.tools.enums.RequirePermissionEnum;
+import com.epmet.commons.tools.page.PageData;
import com.epmet.commons.tools.security.dto.TokenDto;
import com.epmet.commons.tools.utils.Result;
import com.epmet.commons.tools.validator.ValidatorUtils;
@@ -140,6 +141,20 @@ public class BadgeController {
return new Result>().ok(result);
}
+ /**
+ * pc端徽章审核-分页列表
+ *
+ * @param formDTO
+ * @return
+ */
+ @PostMapping("audit-page-list")
+ public Result> auditPageList(@LoginUser TokenDto tokenDto,@RequestBody BadgeAuditPageFormDTO formDTO) {
+ formDTO.setCustomerId(tokenDto.getCustomerId());
+ ValidatorUtils.validateEntity(formDTO, BadgeAuditPageFormDTO.AddUserInternalGroup.class, BadgeAuditPageFormDTO.AddUserShowGroup.class);
+ return new Result>().ok(badgeService.auditPageList(formDTO));
+ }
+
+
/**
* 审核
* @author zhaoqifeng
@@ -232,4 +247,12 @@ public class BadgeController {
return new Result().ok(badgeService.deleteBadgeCertificateAuditing(customerId,gridId));
}
+ /**
+ * 查询当前客户下,所有的徽章,用于pc徽章审核查询条件
+ * @return
+ */
+ @PostMapping("badge-options")
+ public Result> queryBadgeOptions(@LoginUser TokenDto tokenDto){
+ return new Result>().ok(badgeService.queryBadgeOptions(tokenDto.getCustomerId()));
+ }
}
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 324ee779fb..9fea75c217 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
@@ -1219,6 +1219,25 @@ public class IcResiUserController implements ResultDataResolver {
return new Result().ok(r);
}
+ /**
+ * 根据房屋主键查询户内家庭成员简信息
+ * 返回的手机号、身份证加密
+ *
+ * @param houseId 房屋主键
+ * @param loginUser 登录用户
+ * @return com.epmet.commons.tools.utils.Result>
+ * @author work@yujt.net.cn
+ * @date 2022/4/21/0021 15:00
+ */
+ @MaskResponse(fieldNames = {"mobile","idCard"}, fieldsMaskType = {MaskResponse.MASK_TYPE_MOBILE,MaskResponse.MASK_TYPE_ID_CARD})
+ @PostMapping("listhomeuserbrief-encrypt/{houseId}")
+ public Result> listHomeUserBriefEncrypt(@PathVariable("houseId") String houseId, @LoginUser TokenDto loginUser) {
+ String customerId = loginUser.getCustomerId();
+ List r = icResiUserService.listHomeUserBrief(houseId, customerId);
+ return new Result().ok(r);
+ }
+
+
/**
* 根据房屋id,查询居民信息表中-家庭信息-本人 的居民。如果有多个,返回最近一个
*
diff --git a/epmet-user/epmet-user-server/src/main/java/com/epmet/controller/UserBadgeController.java b/epmet-user/epmet-user-server/src/main/java/com/epmet/controller/UserBadgeController.java
index 637da83ce0..e421212c73 100644
--- a/epmet-user/epmet-user-server/src/main/java/com/epmet/controller/UserBadgeController.java
+++ b/epmet-user/epmet-user-server/src/main/java/com/epmet/controller/UserBadgeController.java
@@ -77,7 +77,7 @@ public class UserBadgeController {
certificationAddFormDTO.setUserId(tokenDto.getUserId());
certificationAddFormDTO.setSendMsgFlag(false);
// 是否自动通过
- certificationAddFormDTO.setAutoPassFlag(true);
+ certificationAddFormDTO.setAutoPassFlag(false);
ValidatorUtils.validateEntity(certificationAddFormDTO, CertificationAddFormDTO.CertificationAdd.class);
return userBadgeService.authBadgeRecord(certificationAddFormDTO);
}
diff --git a/epmet-user/epmet-user-server/src/main/java/com/epmet/dao/BadgeDao.java b/epmet-user/epmet-user-server/src/main/java/com/epmet/dao/BadgeDao.java
index 113ed28dee..528c00c45a 100644
--- a/epmet-user/epmet-user-server/src/main/java/com/epmet/dao/BadgeDao.java
+++ b/epmet-user/epmet-user-server/src/main/java/com/epmet/dao/BadgeDao.java
@@ -213,4 +213,19 @@ public interface BadgeDao extends BaseDao {
*/
Integer badgeAuditReset(@Param("gridId") String gridId);
+ /**
+ * pc端徽章审核-分页列表
+ *
+ * @param customerId
+ * @param agencyId
+ * @param gridId
+ * @param badgeId
+ * @param auditStatus
+ * @return
+ */
+ List auditPageList(@Param("customerId") String customerId,
+ @Param("agencyId") String agencyId,
+ @Param("gridId") String gridId,
+ @Param("badgeId") String badgeId,
+ @Param("auditStatus") String auditStatus);
}
\ No newline at end of file
diff --git a/epmet-user/epmet-user-server/src/main/java/com/epmet/entity/UserBadgeCertificateRecordEntity.java b/epmet-user/epmet-user-server/src/main/java/com/epmet/entity/UserBadgeCertificateRecordEntity.java
index a032c42fea..a036578581 100644
--- a/epmet-user/epmet-user-server/src/main/java/com/epmet/entity/UserBadgeCertificateRecordEntity.java
+++ b/epmet-user/epmet-user-server/src/main/java/com/epmet/entity/UserBadgeCertificateRecordEntity.java
@@ -47,6 +47,11 @@ public class UserBadgeCertificateRecordEntity extends BaseEpmetEntity {
*/
private String gridId;
+ /**
+ * 组织id;0306烟台需求增加
+ */
+ private String agencyId;
+
/**
* 用户ID
*/
diff --git a/epmet-user/epmet-user-server/src/main/java/com/epmet/redis/UserBaseInfoRedis.java b/epmet-user/epmet-user-server/src/main/java/com/epmet/redis/UserBaseInfoRedis.java
index 8b42599906..16fd4e04da 100644
--- a/epmet-user/epmet-user-server/src/main/java/com/epmet/redis/UserBaseInfoRedis.java
+++ b/epmet-user/epmet-user-server/src/main/java/com/epmet/redis/UserBaseInfoRedis.java
@@ -222,15 +222,17 @@ public class UserBaseInfoRedis {
String gridFullName = gridInfoCache.getGridNamePath();
baseInfo.setRegisteredGridName(gridFullName);
StringBuffer buffer = new StringBuffer(gridFullName.split(ModuleConstant.DASH)[NumConstant.ONE]).append(ModuleConstant.DASH).append(baseInfo.getSurname());
- switch (baseInfo.getGender()) {
- case NumConstant.ONE_STR:
- buffer.append(ModuleConstant.RESI_USER_NICKNAME_SUFFIX_MALE);
- break;
- case NumConstant.TWO_STR:
- buffer.append(ModuleConstant.RESI_USER_NICKNAME_SUFFIX_FEMALE);
- break;
- default:
- buffer.append(ModuleConstant.RESI_USER_NICKNAME_SUFFIX_GENDER_UNKNOWN);
+ if(null!=baseInfo.getGender()){
+ switch (baseInfo.getGender()) {
+ case NumConstant.ONE_STR:
+ buffer.append(ModuleConstant.RESI_USER_NICKNAME_SUFFIX_MALE);
+ break;
+ case NumConstant.TWO_STR:
+ buffer.append(ModuleConstant.RESI_USER_NICKNAME_SUFFIX_FEMALE);
+ break;
+ default:
+ buffer.append(ModuleConstant.RESI_USER_NICKNAME_SUFFIX_GENDER_UNKNOWN);
+ }
}
baseInfo.setShowName(buffer.toString());
}
diff --git a/epmet-user/epmet-user-server/src/main/java/com/epmet/service/BadgeService.java b/epmet-user/epmet-user-server/src/main/java/com/epmet/service/BadgeService.java
index 379d3c8fad..88cfbfee15 100644
--- a/epmet-user/epmet-user-server/src/main/java/com/epmet/service/BadgeService.java
+++ b/epmet-user/epmet-user-server/src/main/java/com/epmet/service/BadgeService.java
@@ -215,4 +215,18 @@ public interface BadgeService extends BaseService {
* @return
*/
Integer deleteBadgeCertificateAuditing(String customerId, String gridId);
+
+ /**
+ * pc端徽章审核-分页列表
+ * @param formDTO
+ * @return
+ */
+ PageData auditPageList(BadgeAuditPageFormDTO formDTO);
+
+ /**
+ * 查询当前客户下,所有的徽章,用于pc徽章审核查询条件
+ * @param customerId
+ * @return
+ */
+ List queryBadgeOptions(String customerId);
}
diff --git a/epmet-user/epmet-user-server/src/main/java/com/epmet/service/impl/BadgeServiceImpl.java b/epmet-user/epmet-user-server/src/main/java/com/epmet/service/impl/BadgeServiceImpl.java
index 39359b29ea..e6721412b8 100644
--- a/epmet-user/epmet-user-server/src/main/java/com/epmet/service/impl/BadgeServiceImpl.java
+++ b/epmet-user/epmet-user-server/src/main/java/com/epmet/service/impl/BadgeServiceImpl.java
@@ -30,6 +30,8 @@ import com.epmet.commons.tools.exception.ValidateException;
import com.epmet.commons.tools.page.PageData;
import com.epmet.commons.tools.redis.RedisKeys;
import com.epmet.commons.tools.redis.RedisUtils;
+import com.epmet.commons.tools.redis.common.CustomerOrgRedis;
+import com.epmet.commons.tools.redis.common.bean.GridInfoCache;
import com.epmet.commons.tools.security.dto.TokenDto;
import com.epmet.commons.tools.utils.ConvertUtils;
import com.epmet.commons.tools.utils.Result;
@@ -49,6 +51,8 @@ import com.epmet.feign.EpmetMessageOpenFeignClient;
import com.epmet.feign.MessageFeignClient;
import com.epmet.redis.UserBadgeRedis;
import com.epmet.service.*;
+import com.github.pagehelper.PageHelper;
+import com.github.pagehelper.PageInfo;
import lombok.extern.slf4j.Slf4j;
import org.apache.commons.collections4.CollectionUtils;
import org.apache.commons.lang3.StringUtils;
@@ -516,4 +520,40 @@ public class BadgeServiceImpl extends BaseServiceImpl imp
public Integer deleteBadgeCertificateAuditing(String customerId, String gridId) {
return userBadgeCertificateRecordService.deleteBadgeCertificateAuditing(customerId,gridId);
}
+
+ /**
+ * pc端徽章审核-分页列表
+ *
+ * @param formDTO
+ * @return
+ */
+ @Override
+ public PageData auditPageList(BadgeAuditPageFormDTO formDTO) {
+ PageHelper.startPage(formDTO.getPageNo(), formDTO.getPageSize());
+ List list = baseDao.auditPageList(formDTO.getCustomerId(),
+ formDTO.getAgencyId(),
+ formDTO.getGridId(),
+ formDTO.getBadgeId(),
+ formDTO.getAuditStatus());
+ list.forEach(dto -> {
+ GridInfoCache gridInfoCache = CustomerOrgRedis.getGridInfo(dto.getGridId());
+ if (null != gridInfoCache) {
+ dto.setGridName(gridInfoCache.getGridNamePath());
+ }
+ });
+ PageInfo pageInfo = new PageInfo<>(list);
+ return new PageData<>(list, pageInfo.getTotal());
+ }
+
+ /**
+ * 查询当前客户下,所有的徽章,用于pc徽章审核查询条件
+ *
+ * @param customerId
+ * @return
+ */
+ @Override
+ public List queryBadgeOptions(String customerId) {
+ List list=baseDao.selectList(customerId);
+ return list;
+ }
}
diff --git a/epmet-user/epmet-user-server/src/main/java/com/epmet/service/impl/UserBadgeServiceImpl.java b/epmet-user/epmet-user-server/src/main/java/com/epmet/service/impl/UserBadgeServiceImpl.java
index 009870cb44..8d691d4252 100644
--- a/epmet-user/epmet-user-server/src/main/java/com/epmet/service/impl/UserBadgeServiceImpl.java
+++ b/epmet-user/epmet-user-server/src/main/java/com/epmet/service/impl/UserBadgeServiceImpl.java
@@ -6,8 +6,11 @@ import com.epmet.commons.tools.constant.NumConstant;
import com.epmet.commons.tools.exception.EpmetErrorCode;
import com.epmet.commons.tools.exception.EpmetException;
import com.epmet.commons.tools.exception.RenException;
+import com.epmet.commons.tools.redis.common.CustomerOrgRedis;
+import com.epmet.commons.tools.redis.common.bean.GridInfoCache;
import com.epmet.commons.tools.security.dto.TokenDto;
import com.epmet.commons.tools.utils.ConvertUtils;
+import com.epmet.commons.tools.utils.EpmetRequestHolder;
import com.epmet.commons.tools.utils.Result;
import com.epmet.commons.tools.utils.SpringContextUtils;
import com.epmet.commons.tools.validator.PhoneValidatorUtils;
@@ -17,19 +20,18 @@ import com.epmet.constant.ReadFlagConstant;
import com.epmet.constant.SmsTemplateConstant;
import com.epmet.constant.UserMessageTypeConstant;
import com.epmet.dao.*;
+import com.epmet.dto.IcResiUserDTO;
import com.epmet.dto.ResiUserBadgeDTO;
import com.epmet.dto.UserBadgeCertificateRecordDTO;
import com.epmet.dto.form.*;
import com.epmet.dto.result.*;
+import com.epmet.entity.BadgeEntity;
import com.epmet.feign.EpmetMessageOpenFeignClient;
import com.epmet.feign.EpmetUserOpenFeignClient;
import com.epmet.feign.GovOrgFeignClient;
import com.epmet.redis.UserBadgeRedis;
import com.epmet.redis.UserBaseInfoRedis;
-import com.epmet.service.ResiUserBadgeService;
-import com.epmet.service.UserBadgeCertificateRecordService;
-import com.epmet.service.UserBadgeService;
-import com.epmet.service.UserBaseInfoService;
+import com.epmet.service.*;
import com.epmet.util.ModuleConstant;
import lombok.extern.slf4j.Slf4j;
import org.apache.commons.lang3.StringUtils;
@@ -278,6 +280,20 @@ public class UserBadgeServiceImpl implements UserBadgeService {
return new Result().error(EpmetErrorCode.MOBILE_CODE_ERROR.getCode());
}
}
+ // 0309:如果是党员徽章去判断居民信息-类别是否是党员
+ String auditRemark="";
+ BadgeEntity badgeEntity = badgeDao.selectBadgeInfo(EpmetRequestHolder.getLoginUserCustomerId(),certificationAddFormDTO.getBadgeId());
+ if (null == badgeEntity) {
+ throw new EpmetException(EpmetErrorCode.EPMET_COMMON_OPERATION_FAIL.getCode(), "徽章信息查询异常", "徽章信息查询异常");
+ }
+ if (BadgeConstant.PARTY.equals(badgeEntity.getFixationBadgeType())) {
+ // 如果是党员徽章,去查看居民信息-类别
+ IcResiUserDTO icResiUserDTO = SpringContextUtils.getBean(IcResiUserService.class).getByResiId(certificationAddFormDTO.getIdcard());
+ if (null != icResiUserDTO && NumConstant.ONE_STR.equals(icResiUserDTO.getIsParty())) {
+ auditRemark ="居民信息是党员,徽章申请自动通过";
+ certificationAddFormDTO.setAutoPassFlag(true);
+ }
+ }
UserBadgeCertificateRecordDTO form = ConvertUtils.sourceToTarget(certificationAddFormDTO, UserBadgeCertificateRecordDTO.class);
List userIds = new ArrayList<>();
userIds.add(certificationAddFormDTO.getUserId());
@@ -296,6 +312,11 @@ public class UserBadgeServiceImpl implements UserBadgeService {
log.info(JSON.toJSONString(form));
String recordId=IdWorker.getIdStr();
form.setId(recordId);
+ GridInfoCache gridInfoCache=CustomerOrgRedis.getGridInfo(form.getGridId());
+ if(null==gridInfoCache||StringUtils.isBlank(gridInfoCache.getPid())){
+ throw new EpmetException(EpmetErrorCode.EPMET_COMMON_OPERATION_FAIL.getCode(),"查询网格缓存异常","查询网格缓存异常");
+ }
+ form.setAgencyId(gridInfoCache.getPid());
userBadgeDao.insertUserBadgeCertificateRecord(form);
if(certificationAddFormDTO.getSendMsgFlag()){
//TODO 站内信发送
@@ -314,6 +335,7 @@ public class UserBadgeServiceImpl implements UserBadgeService {
//审核状态 approved:审核通过,rejected:审核驳回;auditing:审核中
badgeAuditFormDTO.setAuditStatus(BadgeConstant.APPROVED);
badgeAuditFormDTO.setCurrentUserId("APP_USER");
+ badgeAuditFormDTO.setAuditRemark(auditRemark);
autoPassBadge(badgeAuditFormDTO);
}
Map resultMap=new HashMap();
@@ -332,6 +354,7 @@ public class UserBadgeServiceImpl implements UserBadgeService {
dto.setStaffId(badgeAuditFormDTO.getCurrentUserId());
dto.setIsLast(BadgeConstant.YES);
dto.setAuditTime(new Date());
+ dto.setAuditRemark(badgeAuditFormDTO.getAuditRemark());
SpringContextUtils.getBean(UserBadgeCertificateRecordService.class).update(dto);
ResiUserBadgeDTO resiUserBadgeDTO = new ResiUserBadgeDTO();
@@ -402,7 +425,12 @@ public class UserBadgeServiceImpl implements UserBadgeService {
public CertificationDetailResultDTO certificationDetail(TokenDto tokenDto, CertificationDetailFormDTO certificationDetailFormDTO) {
//工作端
if (StringUtils.isNotBlank(certificationDetailFormDTO.getRecordId())){
- return userBadgeDao.selectBadgeAuthRecord(null, certificationDetailFormDTO.getBadgeId(),certificationDetailFormDTO.getRecordId());
+ CertificationDetailResultDTO res= userBadgeDao.selectBadgeAuthRecord(null, certificationDetailFormDTO.getBadgeId(),certificationDetailFormDTO.getRecordId());
+ GridInfoCache gridInfoCache= CustomerOrgRedis.getGridInfo(res.getGridId());
+ if(null!=gridInfoCache){
+ res.setGridName(gridInfoCache.getGridNamePath());
+ }
+ return res;
}
//居民端
CertificationDetailResultDTO resiResult = userBadgeDao.selectBadgeAuthRecord(tokenDto.getUserId(), certificationDetailFormDTO.getBadgeId(),certificationDetailFormDTO.getRecordId());
@@ -413,6 +441,10 @@ public class UserBadgeServiceImpl implements UserBadgeService {
resiResult.setIdcard(userInfo.getIdNum());
}
}
+ GridInfoCache gridInfoCache= CustomerOrgRedis.getGridInfo(resiResult.getGridId());
+ if(null!=gridInfoCache){
+ resiResult.setGridName(gridInfoCache.getGridNamePath());
+ }
return resiResult;
}
diff --git a/epmet-user/epmet-user-server/src/main/java/com/epmet/service/impl/UserBaseInfoServiceImpl.java b/epmet-user/epmet-user-server/src/main/java/com/epmet/service/impl/UserBaseInfoServiceImpl.java
index 3e6203d2c6..52930c1242 100644
--- a/epmet-user/epmet-user-server/src/main/java/com/epmet/service/impl/UserBaseInfoServiceImpl.java
+++ b/epmet-user/epmet-user-server/src/main/java/com/epmet/service/impl/UserBaseInfoServiceImpl.java
@@ -26,6 +26,7 @@ import com.epmet.commons.tools.constant.AppClientConstant;
import com.epmet.commons.tools.constant.FieldConstant;
import com.epmet.commons.tools.constant.NumConstant;
import com.epmet.commons.tools.constant.StrConstant;
+import com.epmet.commons.tools.distributedlock.DistributedLock;
import com.epmet.commons.tools.exception.EpmetErrorCode;
import com.epmet.commons.tools.exception.EpmetException;
import com.epmet.commons.tools.exception.RenException;
@@ -61,6 +62,7 @@ import com.github.pagehelper.PageInfo;
import org.apache.commons.lang3.StringUtils;
import org.apache.logging.log4j.LogManager;
import org.apache.logging.log4j.Logger;
+import org.redisson.api.RLock;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;
import org.springframework.transaction.annotation.Transactional;
@@ -68,6 +70,7 @@ import org.springframework.util.CollectionUtils;
import javax.annotation.Resource;
import java.util.*;
+import java.util.concurrent.TimeUnit;
/**
* 用户基础信息
@@ -102,6 +105,8 @@ public class UserBaseInfoServiceImpl extends BaseServiceImpl page(Map params) {
@@ -550,66 +555,72 @@ public class UserBaseInfoServiceImpl extends BaseServiceImpl registerWrapper = new LambdaQueryWrapper<>();
- registerWrapper.eq(RegisterRelationEntity::getCustomerId, formDTO.getCustomerId());
- registerWrapper.eq(RegisterRelationEntity::getUserId, baseInfo.getUserId());
- registerWrapper.eq(RegisterRelationEntity::getFirstRegister, NumConstant.ONE_STR);
- RegisterRelationEntity registerRelation = registerRelationDao.selectOne(registerWrapper);
- if (null != registerRelation) {
- result.setAgencyId(registerRelation.getAgencyId());
- result.setGridId(registerRelation.getGridId());
- GridInfoCache gridInfo = CustomerOrgRedis.getGridInfo(registerRelation.getGridId());
- if (null == gridInfo) {
- logger.error(String.format("获取用户注册网格信息为空,userId:%s,gridId:%s", baseInfo.getUserId(), registerRelation.getGridId()));
- throw new EpmetException(EpmetErrorCode.EPMET_COMMON_OPERATION_FAIL.getCode(), "获取网格信息为空", "获取小程序注册网格信息失败");
+ baseInfo.setGender(NumConstant.ZERO_STR);
+ baseDao.insert(baseInfo);
+
+ result.setEpmetUserId(userEntity.getId());
+ result.setRegFlag(false);
+ } else {
+ // 更新下user_Base_info信息
+ if (StringUtils.isNotBlank(formDTO.getNick()) && StringUtils.isBlank(baseInfo.getRealName())) {
+ baseInfo.setRealName(formDTO.getNick());
+ }
+ if (StringUtils.isNotBlank(formDTO.getNick()) && StringUtils.isBlank(baseInfo.getSurname())) {
+ baseInfo.setSurname(NameUtils.getSurNameComplex(formDTO.getNick()));
+ }
+ if (StringUtils.isNotBlank(formDTO.getNick()) && StringUtils.isBlank(baseInfo.getName())) {
+ baseInfo.setName(NameUtils.getNameComplex(formDTO.getNick()));
+ }
+ if (StringUtils.isNotBlank(formDTO.getNick()) && StringUtils.isBlank(baseInfo.getNickname())) {
+ baseInfo.setNickname(formDTO.getNick());
+ }
+ if (StringUtils.isNotBlank(formDTO.getAvatarUrl()) && StringUtils.isBlank(baseInfo.getHeadImgUrl())) {
+ baseInfo.setHeadImgUrl(formDTO.getAvatarUrl());
+ }
+ baseDao.updateById(baseInfo);
+
+ result.setEpmetUserId(baseInfo.getUserId());
+ LambdaQueryWrapper registerWrapper = new LambdaQueryWrapper<>();
+ registerWrapper.eq(RegisterRelationEntity::getCustomerId, formDTO.getCustomerId());
+ registerWrapper.eq(RegisterRelationEntity::getUserId, baseInfo.getUserId());
+ registerWrapper.eq(RegisterRelationEntity::getFirstRegister, NumConstant.ONE_STR);
+ RegisterRelationEntity registerRelation = registerRelationDao.selectOne(registerWrapper);
+ if (null != registerRelation) {
+ result.setAgencyId(registerRelation.getAgencyId());
+ result.setGridId(registerRelation.getGridId());
+ GridInfoCache gridInfo = CustomerOrgRedis.getGridInfo(registerRelation.getGridId());
+ if (null == gridInfo) {
+ logger.error(String.format("获取用户注册网格信息为空,userId:%s,gridId:%s", baseInfo.getUserId(), registerRelation.getGridId()));
+ throw new EpmetException(EpmetErrorCode.EPMET_COMMON_OPERATION_FAIL.getCode(), "获取网格信息为空", "获取小程序注册网格信息失败");
+ }
+ result.setGridName(gridInfo.getGridNamePath());
+ result.setRegFlag(true);
}
- result.setGridName(gridInfo.getGridNamePath());
- result.setRegFlag(true);
}
+ } finally {
+ distributedLock.unLock(lock);
}
return result;
}
diff --git a/epmet-user/epmet-user-server/src/main/java/com/epmet/service/impl/UserResiInfoServiceImpl.java b/epmet-user/epmet-user-server/src/main/java/com/epmet/service/impl/UserResiInfoServiceImpl.java
index 6101e9c2d5..99ffac21ba 100644
--- a/epmet-user/epmet-user-server/src/main/java/com/epmet/service/impl/UserResiInfoServiceImpl.java
+++ b/epmet-user/epmet-user-server/src/main/java/com/epmet/service/impl/UserResiInfoServiceImpl.java
@@ -619,14 +619,14 @@ public class UserResiInfoServiceImpl extends BaseServiceImpl registerWrapper = new LambdaQueryWrapper<>();
diff --git a/epmet-user/epmet-user-server/src/main/resources/mapper/BadgeDao.xml b/epmet-user/epmet-user-server/src/main/resources/mapper/BadgeDao.xml
index 275babd61f..2d9d49fd74 100644
--- a/epmet-user/epmet-user-server/src/main/resources/mapper/BadgeDao.xml
+++ b/epmet-user/epmet-user-server/src/main/resources/mapper/BadgeDao.xml
@@ -67,7 +67,8 @@
BADGE_NAME,
BADGE_ICON,
BADGE_STATUS,
- FIXATION_BADGE_TYPE AS "type"
+ FIXATION_BADGE_TYPE AS "type",
+ CUSTOMER_ID as customerId
FROM
(
SELECT * FROM badge
@@ -340,4 +341,59 @@
AND AUDIT_STATUS = 'auditing'
AND GRID_ID = #{gridId}
+
+
+
\ 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 47bb9cd511..568885f729 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
@@ -476,7 +476,8 @@
mobile,
agency_id,
grid_id,
- home_id
+ home_id,
+ IS_PARTY as isParty
FROM
ic_resi_user
WHERE
diff --git a/epmet-user/epmet-user-server/src/main/resources/mapper/UserBadgeDao.xml b/epmet-user/epmet-user-server/src/main/resources/mapper/UserBadgeDao.xml
index 95b77d51a7..f9f8390cd1 100644
--- a/epmet-user/epmet-user-server/src/main/resources/mapper/UserBadgeDao.xml
+++ b/epmet-user/epmet-user-server/src/main/resources/mapper/UserBadgeDao.xml
@@ -102,31 +102,35 @@
@@ -175,6 +179,7 @@
ID,
CUSTOMER_ID,
GRID_ID,
+ AGENCY_ID,
USER_ID,
BADGE_ID,
SURNAME,
@@ -200,6 +205,7 @@
#{id},
#{customerId},
#{gridId},
+ #{agencyId},
#{userId},
#{badgeId},
#{surname},