>().ok(opeKeys);*/
- return new Result();
}
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
new file mode 100644
index 0000000000..a02fdb01ee
--- /dev/null
+++ b/epmet-module/gov-org/gov-org-client/src/main/java/com/epmet/dto/result/AgencyResultDTO.java
@@ -0,0 +1,43 @@
+/**
+ * Copyright 2018 人人开源 https://www.renren.io
+ *
+ * This program is free software: you can redistribute it and/or modify
+ * it under the terms of the GNU General Public License as published by
+ * the Free Software Foundation, either version 3 of the License, or
+ * (at your option) any later version.
+ *
+ * This program is distributed in the hope that it will be useful,
+ * but WITHOUT ANY WARRANTY; without even the implied warranty of
+ * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
+ * GNU General Public License for more details.
+ *
+ * You should have received a copy of the GNU General Public License
+ * along with this program. If not, see .
+ */
+
+package com.epmet.dto.result;
+
+import lombok.Data;
+
+import java.io.Serializable;
+
+
+/**
+ * 组织信息
+ *
+ * @author sun
+ */
+@Data
+public class AgencyResultDTO implements Serializable {
+
+ private static final long serialVersionUID = 1L;
+
+ /**
+ * 机关组织Id
+ */
+ private String agencyId = "";
+ /**
+ * 机关组织名称
+ */
+ private String agencyName = "";
+}
\ No newline at end of file
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
new file mode 100644
index 0000000000..117976dee8
--- /dev/null
+++ b/epmet-module/gov-org/gov-org-client/src/main/java/com/epmet/dto/result/AgencySubResultDTO.java
@@ -0,0 +1,52 @@
+/**
+ * Copyright 2018 人人开源 https://www.renren.io
+ *
+ * This program is free software: you can redistribute it and/or modify
+ * it under the terms of the GNU General Public License as published by
+ * the Free Software Foundation, either version 3 of the License, or
+ * (at your option) any later version.
+ *
+ * This program is distributed in the hope that it will be useful,
+ * but WITHOUT ANY WARRANTY; without even the implied warranty of
+ * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
+ * GNU General Public License for more details.
+ *
+ * You should have received a copy of the GNU General Public License
+ * along with this program. If not, see .
+ */
+
+package com.epmet.dto.result;
+
+import lombok.Data;
+
+import java.io.Serializable;
+import java.util.List;
+
+
+/**
+ * 下级组织信息(迭代对象)
+ *
+ * @author sun
+ */
+@Data
+public class AgencySubResultDTO implements Serializable {
+
+ private static final long serialVersionUID = 1L;
+
+ /**
+ * 机关组织Id
+ */
+ private String agencyId = "";
+ /**
+ * 机关组织名称
+ */
+ private String agencyName = "";
+ /**
+ * 下级组织信息
+ */
+ private List subAgencyList;
+ /**
+ * 当前组织的所有上级组织Id
+ */
+ private String pids = "";
+}
\ No newline at end of file
diff --git a/epmet-module/gov-org/gov-org-client/src/main/java/com/epmet/dto/result/ProcessorListResultDTO.java b/epmet-module/gov-org/gov-org-client/src/main/java/com/epmet/dto/result/ProcessorListResultDTO.java
new file mode 100644
index 0000000000..cede6e5170
--- /dev/null
+++ b/epmet-module/gov-org/gov-org-client/src/main/java/com/epmet/dto/result/ProcessorListResultDTO.java
@@ -0,0 +1,48 @@
+/**
+ * Copyright 2018 人人开源 https://www.renren.io
+ *
+ * This program is free software: you can redistribute it and/or modify
+ * it under the terms of the GNU General Public License as published by
+ * the Free Software Foundation, either version 3 of the License, or
+ * (at your option) any later version.
+ *
+ * This program is distributed in the hope that it will be useful,
+ * but WITHOUT ANY WARRANTY; without even the implied warranty of
+ * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
+ * GNU General Public License for more details.
+ *
+ * You should have received a copy of the GNU General Public License
+ * along with this program. If not, see .
+ */
+
+package com.epmet.dto.result;
+
+import lombok.Data;
+
+import java.io.Serializable;
+import java.util.List;
+
+
+/**
+ * 项目人员选择(查询当前组织的上两级组织和所有下级组织)--接口返参
+ *
+ * @author sun
+ */
+@Data
+public class ProcessorListResultDTO implements Serializable {
+
+ private static final long serialVersionUID = 1L;
+
+ /**
+ * 当前组织的上两级组织信息
+ */
+ private List parentAgencyList;
+ /**
+ * 当前组织信息
+ */
+ private AgencyResultDTO agencyList;
+ /**
+ * 下级组织信息(迭代)
+ */
+ private List subAgencyList;
+}
\ No newline at end of file
diff --git a/epmet-module/gov-org/gov-org-server/Dockerfile b/epmet-module/gov-org/gov-org-server/Dockerfile
index 15c4d6ed03..b079f1ff77 100644
--- a/epmet-module/gov-org/gov-org-server/Dockerfile
+++ b/epmet-module/gov-org/gov-org-server/Dockerfile
@@ -8,4 +8,4 @@ COPY ./target/*.jar ./app.jar
EXPOSE 8092
-ENTRYPOINT ["java","-Xms32m","-Xmx250m","-jar","./app.jar"]
\ No newline at end of file
+ENTRYPOINT ["sh", "-c", "$RUN_INSTRUCT"]
\ No newline at end of file
diff --git a/epmet-module/gov-org/gov-org-server/docker-compose.yml b/epmet-module/gov-org/gov-org-server/deploy/docker-compose-dev.yml
similarity index 62%
rename from epmet-module/gov-org/gov-org-server/docker-compose.yml
rename to epmet-module/gov-org/gov-org-server/deploy/docker-compose-dev.yml
index 7414547eb5..ca5bdc1094 100644
--- a/epmet-module/gov-org/gov-org-server/docker-compose.yml
+++ b/epmet-module/gov-org/gov-org-server/deploy/docker-compose-dev.yml
@@ -2,12 +2,14 @@ version: "3.7"
services:
gov-org-server:
container_name: gov-org-server-dev
- image: registry-vpc.cn-qingdao.aliyuncs.com/epmet-cloud-dev/gov-org-server:0.3.31
+ image: 192.168.1.130:10080/epmet-cloud-dev/gov-org-server:0.3.34
ports:
- "8092:8092"
network_mode: host # 使用现有网络
volumes:
- "/opt/epmet-cloud-logs/dev:/logs"
+ environment:
+ RUN_INSTRUCT: "java -Xms32m -Xmx200m -jar ./app.jar"
deploy:
resources:
limits:
diff --git a/epmet-module/gov-org/gov-org-server/deploy/docker-compose-test.yml b/epmet-module/gov-org/gov-org-server/deploy/docker-compose-test.yml
new file mode 100644
index 0000000000..55a2ae514f
--- /dev/null
+++ b/epmet-module/gov-org/gov-org-server/deploy/docker-compose-test.yml
@@ -0,0 +1,17 @@
+version: "3.7"
+services:
+ gov-org-server:
+ container_name: gov-org-server-test
+ image: registry-vpc.cn-qingdao.aliyuncs.com/epmet-cloud-release/gov-org-server:0.3.33
+ ports:
+ - "8092:8092"
+ network_mode: host # 使用现有网络
+ volumes:
+ - "/opt/epmet-cloud-logs/test:/logs"
+ environment:
+ RUN_INSTRUCT: "java -Xms32m -Xmx200m -jar ./app.jar"
+ deploy:
+ resources:
+ limits:
+ cpus: '0.1'
+ memory: 300M
\ No newline at end of file
diff --git a/epmet-module/gov-org/gov-org-server/pom.xml b/epmet-module/gov-org/gov-org-server/pom.xml
index c731a93fb9..8bae1a2d21 100644
--- a/epmet-module/gov-org/gov-org-server/pom.xml
+++ b/epmet-module/gov-org/gov-org-server/pom.xml
@@ -2,7 +2,7 @@
4.0.0
- 0.3.31
+ 0.3.34
com.epmet
gov-org
@@ -40,20 +40,30 @@
org.springframework.boot
spring-boot-starter-actuator
+
+ com.epmet
+ epmet-commons-service-call
+ 0.3.1
+
+
+
+
+
+
-
+
@@ -103,7 +113,7 @@
- dev-local
+ dev
true
@@ -123,7 +133,7 @@
6379
123456
- false
+ true
122.152.200.70:8848
fcd6fc8f-ca3a-4b01-8026-2b05cdc5976b
@@ -133,13 +143,13 @@
- dev
+ test
8092
- dev
+ test
@@ -162,35 +172,5 @@
-
- test
-
-
- 8092
- test
-
-
-
-
-
- epmet
- elink@833066
-
- 0
- 10.10.10.248
- 6379
- 123456
-
- true
- 122.152.200.70:8848
- fcd6fc8f-ca3a-4b01-8026-2b05cdc5976b
-
-
- false
-
-
-
diff --git a/epmet-module/gov-org/gov-org-server/src/main/java/com/epmet/aspect/RequestLogAspect.java b/epmet-module/gov-org/gov-org-server/src/main/java/com/epmet/aspect/RequestLogAspect.java
new file mode 100644
index 0000000000..49581cf63c
--- /dev/null
+++ b/epmet-module/gov-org/gov-org-server/src/main/java/com/epmet/aspect/RequestLogAspect.java
@@ -0,0 +1,40 @@
+package com.epmet.aspect;
+
+import com.epmet.commons.tools.aspect.BaseRequestLogAspect;
+import org.aspectj.lang.ProceedingJoinPoint;
+import org.aspectj.lang.annotation.Around;
+import org.aspectj.lang.annotation.Aspect;
+import org.springframework.core.annotation.Order;
+import org.springframework.stereotype.Component;
+import org.springframework.web.context.request.RequestAttributes;
+import org.springframework.web.context.request.RequestContextHolder;
+import org.springframework.web.context.request.ServletRequestAttributes;
+
+import javax.servlet.http.HttpServletRequest;
+
+/**
+ * 日志/异常处理切面实现,调用父类方法完成日志记录和异常处理。
+ */
+@Aspect
+@Component
+@Order(0)
+public class RequestLogAspect extends BaseRequestLogAspect {
+
+ @Override
+ @Around(value = "execution(* com.epmet.controller.*Controller*.*(..)) ")
+ public Object proceed(ProceedingJoinPoint point) throws Throwable {
+ return super.proceed(point, getRequest());
+ }
+
+ /**
+ * 获取Request对象
+ *
+ * @return
+ */
+ private HttpServletRequest getRequest() {
+ RequestAttributes ra = RequestContextHolder.getRequestAttributes();
+ ServletRequestAttributes sra = (ServletRequestAttributes) ra;
+ return sra.getRequest();
+ }
+
+}
diff --git a/epmet-module/gov-org/gov-org-server/src/main/java/com/epmet/config/LoadBalanceConfig.java b/epmet-module/gov-org/gov-org-server/src/main/java/com/epmet/config/LoadBalanceConfig.java
new file mode 100644
index 0000000000..97bd3ae321
--- /dev/null
+++ b/epmet-module/gov-org/gov-org-server/src/main/java/com/epmet/config/LoadBalanceConfig.java
@@ -0,0 +1,23 @@
+package com.epmet.config;
+
+import com.epmet.loadbalancer.EpmetRequestLoadBalancerRule;
+import com.netflix.loadbalancer.IRule;
+import org.springframework.context.annotation.Bean;
+import org.springframework.context.annotation.Configuration;
+import org.springframework.core.env.Environment;
+
+@Configuration
+public class LoadBalanceConfig {
+
+ /**
+ * 自定义负载均衡算法bean
+ * @return
+ */
+ //@Bean
+ //public IRule getMyLoadBalancerRule(Environment env) {
+ // EpmetRequestLoadBalancerRule rule = new EpmetRequestLoadBalancerRule();
+ // rule.setEnv(env);
+ // return rule;
+ //}
+
+}
diff --git a/epmet-module/gov-org/gov-org-server/src/main/java/com/epmet/controller/CustomerAgencyController.java b/epmet-module/gov-org/gov-org-server/src/main/java/com/epmet/controller/CustomerAgencyController.java
index 6434a318b6..73728f19de 100644
--- a/epmet-module/gov-org/gov-org-server/src/main/java/com/epmet/controller/CustomerAgencyController.java
+++ b/epmet-module/gov-org/gov-org-server/src/main/java/com/epmet/controller/CustomerAgencyController.java
@@ -17,7 +17,9 @@
package com.epmet.controller;
+import com.epmet.commons.tools.annotation.LoginUser;
import com.epmet.commons.tools.page.PageData;
+import com.epmet.commons.tools.security.dto.TokenDto;
import com.epmet.commons.tools.utils.ExcelUtils;
import com.epmet.commons.tools.utils.Result;
import com.epmet.commons.tools.validator.AssertUtils;
@@ -28,10 +30,7 @@ import com.epmet.commons.tools.validator.group.UpdateGroup;
import com.epmet.dto.CustomerAgencyDTO;
import com.epmet.dto.form.AgencyDeptGridFormDTO;
import com.epmet.dto.form.StaffOrgFormDTO;
-import com.epmet.dto.result.AgencyDeptGridResultDTO;
-import com.epmet.dto.result.AgencyGridResultDTO;
-import com.epmet.dto.result.DepartmentStaffListResultDTO;
-import com.epmet.dto.result.StaffOrgsResultDTO;
+import com.epmet.dto.result.*;
import com.epmet.excel.CustomerAgencyExcel;
import com.epmet.service.CustomerAgencyService;
import org.springframework.beans.factory.annotation.Autowired;
@@ -142,4 +141,15 @@ public class CustomerAgencyController {
return new Result().ok(customerAgencyService.getAgencyDeptGridList(formDTO));
}
+ /**
+ * @param agencyId
+ * @return
+ * @Author sun
+ * @Description 根据当前组织ID查询上两级组织、本级组织和所有下级(迭代)组织
+ **/
+ @PostMapping("getprocessorlist/{agencyId}")
+ public Result getProcessorList(@PathVariable("agencyId") String agencyId) {
+ return new Result().ok(customerAgencyService.getProcessorList(agencyId));
+ }
+
}
\ No newline at end of file
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 a83d872672..a9846b3a76 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
@@ -19,10 +19,7 @@ package com.epmet.dao;
import com.epmet.commons.mybatis.dao.BaseDao;
import com.epmet.dto.CustomerAgencyDTO;
-import com.epmet.dto.result.AgencyListResultDTO;
-import com.epmet.dto.result.ParentListResultDTO;
-import com.epmet.dto.result.StaffOrgsResultDTO;
-import com.epmet.dto.result.SubListResultDTO;
+import com.epmet.dto.result.*;
import com.epmet.entity.CustomerAgencyEntity;
import org.apache.ibatis.annotations.Mapper;
import org.apache.ibatis.annotations.Param;
@@ -95,4 +92,12 @@ public interface CustomerAgencyDao extends BaseDao {
* @Description 批量查询组织信息
**/
List selectAgencyListByIds(@Param("agencyIdList") List agencyIdList);
+
+ /**
+ * @param subAgencyPids
+ * @return
+ * @Author sun
+ * @Description 查询当前组织的下一级组织列表
+ **/
+ List selectSubAgencyList(@Param("subAgencyPids") String subAgencyPids);
}
\ No newline at end of file
diff --git a/epmet-module/gov-org/gov-org-server/src/main/java/com/epmet/service/CustomerAgencyService.java b/epmet-module/gov-org/gov-org-server/src/main/java/com/epmet/service/CustomerAgencyService.java
index b79c1c6cfb..96132b35da 100644
--- a/epmet-module/gov-org/gov-org-server/src/main/java/com/epmet/service/CustomerAgencyService.java
+++ b/epmet-module/gov-org/gov-org-server/src/main/java/com/epmet/service/CustomerAgencyService.java
@@ -23,10 +23,7 @@ import com.epmet.commons.tools.utils.Result;
import com.epmet.dto.CustomerAgencyDTO;
import com.epmet.dto.form.AgencyDeptGridFormDTO;
import com.epmet.dto.form.StaffOrgFormDTO;
-import com.epmet.dto.result.AgencyDeptGridResultDTO;
-import com.epmet.dto.result.AgencyGridResultDTO;
-import com.epmet.dto.result.DepartmentStaffListResultDTO;
-import com.epmet.dto.result.StaffOrgsResultDTO;
+import com.epmet.dto.result.*;
import com.epmet.entity.CustomerAgencyEntity;
import java.util.List;
@@ -132,4 +129,12 @@ public interface CustomerAgencyService extends BaseService
* @Description 根据组织Id集合、部门Id集合、网格Id集合查询各自对应详细信息
**/
AgencyDeptGridResultDTO getAgencyDeptGridList(AgencyDeptGridFormDTO formDTO);
+
+ /**
+ * @param agencyId
+ * @return
+ * @Author sun
+ * @Description 根据当前组织ID查询上两级组织、本级组织和所有下级(迭代)组织
+ **/
+ ProcessorListResultDTO getProcessorList(String agencyId);
}
\ No newline at end of file
diff --git a/epmet-module/gov-org/gov-org-server/src/main/java/com/epmet/service/impl/CustomerAgencyServiceImpl.java b/epmet-module/gov-org/gov-org-server/src/main/java/com/epmet/service/impl/CustomerAgencyServiceImpl.java
index 2218c26341..2981b5919b 100644
--- a/epmet-module/gov-org/gov-org-server/src/main/java/com/epmet/service/impl/CustomerAgencyServiceImpl.java
+++ b/epmet-module/gov-org/gov-org-server/src/main/java/com/epmet/service/impl/CustomerAgencyServiceImpl.java
@@ -21,6 +21,7 @@ import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
import com.baomidou.mybatisplus.core.metadata.IPage;
import com.epmet.commons.mybatis.service.impl.BaseServiceImpl;
import com.epmet.commons.tools.constant.FieldConstant;
+import com.epmet.commons.tools.constant.NumConstant;
import com.epmet.commons.tools.exception.RenException;
import com.epmet.commons.tools.page.PageData;
import com.epmet.commons.tools.utils.ConvertUtils;
@@ -320,4 +321,65 @@ public class CustomerAgencyServiceImpl extends BaseServiceImpl parentAgencyList = new ArrayList<>();
+ //1:查询当前组织信息
+ CustomerAgencyEntity entity = baseDao.selectById(agencyId);
+ AgencyResultDTO agencyList = new AgencyResultDTO();
+ agencyList.setAgencyId(entity.getId());
+ agencyList.setAgencyName(entity.getOrganizationName());
+ processorList.setAgencyList(agencyList);
+ //2:查询当前组织的上两级组织,按层级排序
+ String pids = entity.getPids();
+ String[] args = pids.split(":");
+ List agencyIdList = new ArrayList<>();
+ if (args.length < NumConstant.ONE) {
+ processorList.setParentAgencyList(parentAgencyList);
+ } else {
+ if (args.length > NumConstant.ONE) {
+ agencyIdList.add(args[args.length - NumConstant.TWO]);
+ }
+ if (args.length > NumConstant.ZERO) {
+ agencyIdList.add(args[args.length - NumConstant.ONE]);
+ }
+ List parentList = baseDao.selectAgencyListByIds(agencyIdList);
+ parentList.forEach(parent->{
+ AgencyResultDTO agency = new AgencyResultDTO();
+ agency.setAgencyId(parent.getId());
+ agency.setAgencyName(parent.getOrganizationName());
+ parentAgencyList.add(agency);
+ });
+ processorList.setParentAgencyList(parentAgencyList);
+ }
+ //3:迭代查询当前组织的所有下级组织列表
+ List subAgencyList = getDepartmentList(entity.getPids() + ":" + entity.getId());
+ processorList.setSubAgencyList(subAgencyList);
+
+ return processorList;
+ }
+
+ /**
+ * @param subAgencyPids 当前组织的下一级组织的pids字段值(当前组织的pids+":"+当前组织Id)
+ * @return
+ * @Author 迭代查询当前组织的所有下级组织树结构数据
+ */
+ private List getDepartmentList(String subAgencyPids) {
+ List subAgencyList = baseDao.selectSubAgencyList(subAgencyPids);
+ if (subAgencyList.size() > NumConstant.ZERO) {
+ for (AgencySubResultDTO sub : subAgencyList) {
+ List subAgency = getDepartmentList(sub.getPids() + ":" + sub.getAgencyId());
+ sub.setSubAgencyList(subAgency);
+ }
+ }
+ return subAgencyList;
+ }
+
}
\ No newline at end of file
diff --git a/epmet-module/gov-org/gov-org-server/src/main/java/com/epmet/service/impl/CustomerStaffGridServiceImpl.java b/epmet-module/gov-org/gov-org-server/src/main/java/com/epmet/service/impl/CustomerStaffGridServiceImpl.java
index 44f14521b1..2eb0873cc8 100644
--- a/epmet-module/gov-org/gov-org-server/src/main/java/com/epmet/service/impl/CustomerStaffGridServiceImpl.java
+++ b/epmet-module/gov-org/gov-org-server/src/main/java/com/epmet/service/impl/CustomerStaffGridServiceImpl.java
@@ -119,6 +119,9 @@ public class CustomerStaffGridServiceImpl extends BaseServiceImpl getStaffGridOrderByGridName(LatestGridFormDTO latestGridFormDTO) {
CustomerGridDTO grid = baseDao.selectStaffGridOrderByGridName(latestGridFormDTO);
+ if(null==grid){
+ return new Result<>();
+ }
CustomerGridByUserIdResultDTO result = new CustomerGridByUserIdResultDTO();
result.setGridName(grid.getGridName());
result.setGridId(grid.getId());
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 41cce6fb8e..1b5fdf92a5 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
@@ -118,5 +118,22 @@
ca.id = #{agencyId}
+ ORDER BY field(
+ ca.id,
+
+ #{agencyId}
+
+
+
+
\ No newline at end of file
diff --git a/epmet-module/gov-project/gov-project-client/src/main/java/com/epmet/dto/ProjectDTO.java b/epmet-module/gov-project/gov-project-client/src/main/java/com/epmet/dto/ProjectDTO.java
index 356bff7769..ef8c8f0d11 100644
--- a/epmet-module/gov-project/gov-project-client/src/main/java/com/epmet/dto/ProjectDTO.java
+++ b/epmet-module/gov-project/gov-project-client/src/main/java/com/epmet/dto/ProjectDTO.java
@@ -38,6 +38,11 @@ public class ProjectDTO implements Serializable {
*/
private String id;
+ /**
+ * 客户ID
+ */
+ private String customerId;
+
/**
* 机关ID
*/
diff --git a/epmet-module/gov-project/gov-project-client/src/main/java/com/epmet/dto/form/ProcessorListFormDTO.java b/epmet-module/gov-project/gov-project-client/src/main/java/com/epmet/dto/form/ProcessorListFormDTO.java
new file mode 100644
index 0000000000..764412d461
--- /dev/null
+++ b/epmet-module/gov-project/gov-project-client/src/main/java/com/epmet/dto/form/ProcessorListFormDTO.java
@@ -0,0 +1,20 @@
+package com.epmet.dto.form;
+
+import lombok.Data;
+
+import javax.validation.constraints.NotBlank;
+import java.io.Serializable;
+
+/**
+ * @Description 项目人员选择(查询当前组织的上两级组织、当前组织和所有下级组织)--接口入参
+ * @Author sun
+ */
+@Data
+public class ProcessorListFormDTO implements Serializable {
+ private static final long serialVersionUID = 4859779755214502427L;
+
+ @NotBlank(message = "项目人员关联Id不能为空")
+ private String projectStaffId;
+
+}
+
diff --git a/epmet-module/gov-project/gov-project-client/src/main/java/com/epmet/dto/form/ShiftProjectsFromDTO.java b/epmet-module/gov-project/gov-project-client/src/main/java/com/epmet/dto/form/ShiftProjectsFromDTO.java
new file mode 100644
index 0000000000..97df9f343b
--- /dev/null
+++ b/epmet-module/gov-project/gov-project-client/src/main/java/com/epmet/dto/form/ShiftProjectsFromDTO.java
@@ -0,0 +1,20 @@
+package com.epmet.dto.form;
+
+import lombok.Data;
+
+import java.io.Serializable;
+import java.util.List;
+
+/**
+ * @author zhaoqifeng
+ * @dscription
+ * @date 2020/5/13 16:47
+ */
+@Data
+public class ShiftProjectsFromDTO implements Serializable {
+ private static final long serialVersionUID = 3832656052193286163L;
+ /**
+ * 议题ID
+ */
+ List issueIds;
+}
diff --git a/epmet-module/gov-project/gov-project-client/src/main/java/com/epmet/dto/result/ShiftProjectResultDTO.java b/epmet-module/gov-project/gov-project-client/src/main/java/com/epmet/dto/result/ShiftProjectResultDTO.java
new file mode 100644
index 0000000000..2f372a1b24
--- /dev/null
+++ b/epmet-module/gov-project/gov-project-client/src/main/java/com/epmet/dto/result/ShiftProjectResultDTO.java
@@ -0,0 +1,53 @@
+package com.epmet.dto.result;
+
+import lombok.Data;
+
+import java.io.Serializable;
+import java.util.Date;
+import java.util.List;
+
+/**
+ * @author zhaoqifeng
+ * @dscription
+ * @date 2020/5/14 13:45
+ */
+@Data
+public class ShiftProjectResultDTO implements Serializable {
+
+ private static final long serialVersionUID = 4807330131467747264L;
+ /**
+ * 唯一标识
+ */
+ private String id;
+
+ /**
+ * 来源ID
+ */
+ private String originId;
+
+ /**
+ * 项目标题
+ */
+ private String title;
+
+ /**
+ * 状态:待处理 pending,结案closed
+ */
+ private String status;
+
+ /**
+ * 结案说明
+ */
+ private String publicReply;
+
+ /**
+ * 创建时间
+ */
+ private Date createdTime;
+
+ /**
+ * 当前处理部门
+ */
+ private List departmentNameList;
+
+}
diff --git a/epmet-module/gov-project/gov-project-server/Dockerfile b/epmet-module/gov-project/gov-project-server/Dockerfile
index adb8530981..88b6575415 100644
--- a/epmet-module/gov-project/gov-project-server/Dockerfile
+++ b/epmet-module/gov-project/gov-project-server/Dockerfile
@@ -8,4 +8,4 @@ COPY ./target/*.jar ./app.jar
EXPOSE 8102
-ENTRYPOINT ["java","-Xms32m","-Xmx200m","-jar","./app.jar"]
\ No newline at end of file
+ENTRYPOINT ["sh", "-c", "$RUN_INSTRUCT"]
\ No newline at end of file
diff --git a/epmet-module/gov-project/gov-project-server/docker-compose.yml b/epmet-module/gov-project/gov-project-server/deploy/docker-compose-dev.yml
similarity index 62%
rename from epmet-module/gov-project/gov-project-server/docker-compose.yml
rename to epmet-module/gov-project/gov-project-server/deploy/docker-compose-dev.yml
index 71d21eb11b..f81da526df 100644
--- a/epmet-module/gov-project/gov-project-server/docker-compose.yml
+++ b/epmet-module/gov-project/gov-project-server/deploy/docker-compose-dev.yml
@@ -2,12 +2,14 @@ version: "3.7"
services:
gov-project-server:
container_name: gov-project-server-dev
- image: registry-vpc.cn-qingdao.aliyuncs.com/epmet-cloud-dev/gov-project-server:0.3.0
+ image: 192.168.1.130:10080/epmet-cloud-dev/gov-project-server:0.3.2
ports:
- "8102:8102"
network_mode: host # 使用现有网络
volumes:
- "/opt/epmet-cloud-logs/dev:/logs"
+ environment:
+ RUN_INSTRUCT: "java -Xms32m -Xmx200m -jar ./app.jar"
deploy:
resources:
limits:
diff --git a/epmet-module/gov-project/gov-project-server/deploy/docker-compose-test.yml b/epmet-module/gov-project/gov-project-server/deploy/docker-compose-test.yml
new file mode 100644
index 0000000000..5579a748f7
--- /dev/null
+++ b/epmet-module/gov-project/gov-project-server/deploy/docker-compose-test.yml
@@ -0,0 +1,17 @@
+version: "3.7"
+services:
+ gov-project-server:
+ container_name: gov-project-server-test
+ image: registry-vpc.cn-qingdao.aliyuncs.com/epmet-cloud-release/gov-project-server:0.3.1
+ ports:
+ - "8102:8102"
+ network_mode: host # 使用现有网络
+ volumes:
+ - "/opt/epmet-cloud-logs/test:/logs"
+ environment:
+ RUN_INSTRUCT: "java -Xms32m -Xmx200m -jar ./app.jar"
+ deploy:
+ resources:
+ limits:
+ cpus: '0.1'
+ memory: 250M
\ No newline at end of file
diff --git a/epmet-module/gov-project/gov-project-server/pom.xml b/epmet-module/gov-project/gov-project-server/pom.xml
index 1588d4238f..95f677175b 100644
--- a/epmet-module/gov-project/gov-project-server/pom.xml
+++ b/epmet-module/gov-project/gov-project-server/pom.xml
@@ -2,7 +2,7 @@
- 0.3.0
+ 0.3.2
gov-project
com.epmet
@@ -106,7 +106,7 @@
- dev-local
+ dev
true
@@ -126,7 +126,7 @@
6379
123456
- false
+ true
122.152.200.70:8848
fcd6fc8f-ca3a-4b01-8026-2b05cdc5976b
@@ -136,13 +136,13 @@
- dev
+ test
8102
- dev
+ test
@@ -165,36 +165,6 @@
-
- test
-
-
- 8102
- test
-
-
-
-
-
- epmet
- elink@833066
-
- 0
- 10.10.10.248
- 6379
- 123456
-
- true
- 122.152.200.70:8848
- fcd6fc8f-ca3a-4b01-8026-2b05cdc5976b
-
-
- false
-
-
-
\ No newline at end of file
diff --git a/epmet-module/gov-project/gov-project-server/src/main/java/com/epmet/aspect/RequestLogAspect.java b/epmet-module/gov-project/gov-project-server/src/main/java/com/epmet/aspect/RequestLogAspect.java
new file mode 100644
index 0000000000..49581cf63c
--- /dev/null
+++ b/epmet-module/gov-project/gov-project-server/src/main/java/com/epmet/aspect/RequestLogAspect.java
@@ -0,0 +1,40 @@
+package com.epmet.aspect;
+
+import com.epmet.commons.tools.aspect.BaseRequestLogAspect;
+import org.aspectj.lang.ProceedingJoinPoint;
+import org.aspectj.lang.annotation.Around;
+import org.aspectj.lang.annotation.Aspect;
+import org.springframework.core.annotation.Order;
+import org.springframework.stereotype.Component;
+import org.springframework.web.context.request.RequestAttributes;
+import org.springframework.web.context.request.RequestContextHolder;
+import org.springframework.web.context.request.ServletRequestAttributes;
+
+import javax.servlet.http.HttpServletRequest;
+
+/**
+ * 日志/异常处理切面实现,调用父类方法完成日志记录和异常处理。
+ */
+@Aspect
+@Component
+@Order(0)
+public class RequestLogAspect extends BaseRequestLogAspect {
+
+ @Override
+ @Around(value = "execution(* com.epmet.controller.*Controller*.*(..)) ")
+ public Object proceed(ProceedingJoinPoint point) throws Throwable {
+ return super.proceed(point, getRequest());
+ }
+
+ /**
+ * 获取Request对象
+ *
+ * @return
+ */
+ private HttpServletRequest getRequest() {
+ RequestAttributes ra = RequestContextHolder.getRequestAttributes();
+ ServletRequestAttributes sra = (ServletRequestAttributes) ra;
+ return sra.getRequest();
+ }
+
+}
diff --git a/epmet-module/gov-project/gov-project-server/src/main/java/com/epmet/constant/ProjectConstant.java b/epmet-module/gov-project/gov-project-server/src/main/java/com/epmet/constant/ProjectConstant.java
index 78d79402c1..d341afd494 100644
--- a/epmet-module/gov-project/gov-project-server/src/main/java/com/epmet/constant/ProjectConstant.java
+++ b/epmet-module/gov-project/gov-project-server/src/main/java/com/epmet/constant/ProjectConstant.java
@@ -84,5 +84,5 @@ public interface ProjectConstant {
/**
* 更新项目人员关联表数据失败
*/
- String DATe_EXCEPTION = "未勾选流转人员";
+ String DATE_EXCEPTION = "未勾选流转人员";
}
diff --git a/epmet-module/gov-project/gov-project-server/src/main/java/com/epmet/controller/ProjectController.java b/epmet-module/gov-project/gov-project-server/src/main/java/com/epmet/controller/ProjectController.java
index d0ff226582..804be2a6d3 100644
--- a/epmet-module/gov-project/gov-project-server/src/main/java/com/epmet/controller/ProjectController.java
+++ b/epmet-module/gov-project/gov-project-server/src/main/java/com/epmet/controller/ProjectController.java
@@ -26,6 +26,8 @@ import com.epmet.commons.tools.validator.group.AddGroup;
import com.epmet.commons.tools.validator.group.UpdateGroup;
import com.epmet.commons.tools.validator.group.DefaultGroup;
import com.epmet.dto.ProjectDTO;
+import com.epmet.dto.form.ShiftProjectsFromDTO;
+import com.epmet.dto.result.ShiftProjectResultDTO;
import com.epmet.excel.ProjectExcel;
import com.epmet.service.ProjectService;
import org.springframework.beans.factory.annotation.Autowired;
@@ -91,4 +93,17 @@ public class ProjectController {
ExcelUtils.exportExcelToTarget(response, null, list, ProjectExcel.class);
}
+ /**
+ * 根据议题查询项目
+ * @author zhaoqifeng
+ * @date 2020/5/13 16:55
+ * @param fromDTO
+ * @return com.epmet.commons.tools.utils.Result>
+ */
+ @PostMapping("shiftprojectlist")
+ public Result> getProjectByIssue(@RequestBody ShiftProjectsFromDTO fromDTO) {
+ List list = projectService.getProjectByIssue(fromDTO);
+ return new Result>().ok(list);
+ }
+
}
\ No newline at end of file
diff --git a/epmet-module/gov-project/gov-project-server/src/main/java/com/epmet/controller/ProjectTraceController.java b/epmet-module/gov-project/gov-project-server/src/main/java/com/epmet/controller/ProjectTraceController.java
index f252c27770..28c14a862e 100644
--- a/epmet-module/gov-project/gov-project-server/src/main/java/com/epmet/controller/ProjectTraceController.java
+++ b/epmet-module/gov-project/gov-project-server/src/main/java/com/epmet/controller/ProjectTraceController.java
@@ -12,6 +12,7 @@ import com.epmet.service.ProjectProcessService;
import com.epmet.service.ProjectSatisfactionDetailService;
import com.epmet.service.ProjectStaffService;
import com.epmet.service.ProjectTraceService;
+import oracle.jdbc.proxy.annotation.Post;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.web.bind.annotation.PostMapping;
import org.springframework.web.bind.annotation.RequestBody;
@@ -51,6 +52,7 @@ public class ProjectTraceController {
* @date 2020/5/11 16:14
*/
@PostMapping("pendprojectlist")
+ @RequirePermission(requirePermission = RequirePermissionEnum.WORK_PROJECT_TRACE_PENDING_LIST)
public Result> getPendProjectList(@LoginUser TokenDto tokenDto, @RequestBody ProjectListFromDTO fromDTO) {
List result = projectTraceService.getPendProjectList(tokenDto, fromDTO);
return new Result>().ok(result);
@@ -66,6 +68,7 @@ public class ProjectTraceController {
* @date 2020/5/11 16:19
*/
@PostMapping("createdlist")
+ @RequirePermission(requirePermission = RequirePermissionEnum.WORK_PROJECT_TRACE_CREATED_LIST)
public Result> getCreatedList(@LoginUser TokenDto tokenDto, @RequestBody ProjectListFromDTO fromDTO) {
List result = projectTraceService.getCreatedList(tokenDto, fromDTO);
return new Result>().ok(result);
@@ -81,6 +84,7 @@ public class ProjectTraceController {
* @date 2020/5/11 16:21
*/
@PostMapping("involvedlist")
+ @RequirePermission(requirePermission = RequirePermissionEnum.WORK_PROJECT_TRACE_INVOLVED_LIST)
public Result> getInvolvedList(@LoginUser TokenDto tokenDto, @RequestBody ProjectListFromDTO fromDTO) {
List result = projectTraceService.getInvolvedList(tokenDto, fromDTO);
return new Result>().ok(result);
@@ -96,6 +100,7 @@ public class ProjectTraceController {
* @date 2020/5/11 16:25
*/
@PostMapping("projectdetail")
+ @RequirePermission(requirePermission = RequirePermissionEnum.WORK_PROJECT_TRACE_DETAIL)
public Result getProjectDetail(@LoginUser TokenDto tokenDto, @RequestBody ProjectDetailFromDTO fromDTO) {
ProjectDetailResultDTO result = projectTraceService.getProjectDetail(tokenDto, fromDTO);
return new Result().ok(result);
@@ -111,6 +116,7 @@ public class ProjectTraceController {
* @date 2020/5/11 16:27
*/
@PostMapping("closeproject")
+ @RequirePermission(requirePermission = RequirePermissionEnum.WORK_PROJECT_TRACE_CLOSE)
public Result closed(@LoginUser TokenDto tokenDto, @RequestBody ProjectClosedFromDTO fromDTO) {
projectTraceService.closed(tokenDto, fromDTO);
return new Result();
@@ -125,6 +131,7 @@ public class ProjectTraceController {
* @date 2020/5/11 16:30
*/
@PostMapping("returnablelist")
+ @RequirePermission(requirePermission = RequirePermissionEnum.WORK_PROJECT_TRACE_RETURN)
public Result> getReturnableList(@RequestBody ReturnListFromDTO fromDTO) {
List result = projectTraceService.getReturnableList(fromDTO);
return new Result>().ok(result);
@@ -140,6 +147,7 @@ public class ProjectTraceController {
* @date 2020/5/11 16:32
*/
@PostMapping("return")
+ @RequirePermission(requirePermission = RequirePermissionEnum.WORK_PROJECT_TRACE_RETURN)
public Result projectReturn(@LoginUser TokenDto tokenDto, @RequestBody ReturnFromDTO fromDTO) {
projectTraceService.projectReturn(tokenDto, fromDTO);
return new Result();
@@ -197,5 +205,32 @@ public class ProjectTraceController {
projectProcessService.transfer(formDTO);
return new Result();
}
+
+ /**
+ * 我的处理部门
+ * @author zhaoqifeng
+ * @date 2020/5/14 14:22
+ * @param tokenDto
+ * @param fromDTO
+ * @return com.epmet.commons.tools.utils.Result>
+ */
+ @PostMapping("mydepartmentlist")
+ @RequirePermission(requirePermission = RequirePermissionEnum.WORK_PROJECT_TRACE_DETAIL)
+ public Result> myDepartmentList(@LoginUser TokenDto tokenDto, @RequestBody ProjectDetailFromDTO fromDTO) {
+ return new Result>().ok(projectTraceService.myDepartmentList(tokenDto, fromDTO));
+ }
+
+ /**
+ * @param formDTO
+ * @return
+ * @Author sun
+ * @Description 项目跟踪-项目人员选择
+ **/
+ @PostMapping("processorlist")
+ @RequirePermission(requirePermission = RequirePermissionEnum.WORK_PROJECT_TRACE_TRANSFER)
+ public Result processorList(@LoginUser TokenDto tokenDTO, @RequestBody ProcessorListFormDTO formDTO) {
+ ValidatorUtils.validateEntity(formDTO);
+ return new Result().ok(projectTraceService.processorList(formDTO));
+ }
}
diff --git a/epmet-module/gov-project/gov-project-server/src/main/java/com/epmet/dao/ProjectDao.java b/epmet-module/gov-project/gov-project-server/src/main/java/com/epmet/dao/ProjectDao.java
index c84c8d6f2d..95561d448e 100644
--- a/epmet-module/gov-project/gov-project-server/src/main/java/com/epmet/dao/ProjectDao.java
+++ b/epmet-module/gov-project/gov-project-server/src/main/java/com/epmet/dao/ProjectDao.java
@@ -20,7 +20,7 @@ package com.epmet.dao;
import com.epmet.commons.mybatis.dao.BaseDao;
import com.epmet.dto.ProjectDTO;
import com.epmet.dto.form.ProjectListFromDTO;
-import com.epmet.dto.result.DepartmentResultDTO;
+import com.epmet.dto.form.ShiftProjectsFromDTO;
import com.epmet.dto.result.ProjectDetailResultDTO;
import com.epmet.entity.ProjectEntity;
import org.apache.ibatis.annotations.Mapper;
@@ -85,4 +85,13 @@ public interface ProjectDao extends BaseDao {
*/
ProjectDetailResultDTO selectProjectDetail(@Param("id") String id);
+ /**
+ * 根据议题ID获取项目列表
+ * @author zhaoqifeng
+ * @date 2020/5/13 17:01
+ * @param fromDTO
+ * @return java.util.List
+ */
+ List selectShiftProjectList(ShiftProjectsFromDTO fromDTO);
+
}
\ No newline at end of file
diff --git a/epmet-module/gov-project/gov-project-server/src/main/java/com/epmet/entity/ProjectEntity.java b/epmet-module/gov-project/gov-project-server/src/main/java/com/epmet/entity/ProjectEntity.java
index a0c82726ea..38de1c8e93 100644
--- a/epmet-module/gov-project/gov-project-server/src/main/java/com/epmet/entity/ProjectEntity.java
+++ b/epmet-module/gov-project/gov-project-server/src/main/java/com/epmet/entity/ProjectEntity.java
@@ -38,6 +38,11 @@ public class ProjectEntity extends BaseEpmetEntity {
private static final long serialVersionUID = 1L;
+ /**
+ * 客户ID
+ */
+ private String customerId;
+
/**
* 机关ID
*/
diff --git a/epmet-module/gov-project/gov-project-server/src/main/java/com/epmet/excel/ProjectExcel.java b/epmet-module/gov-project/gov-project-server/src/main/java/com/epmet/excel/ProjectExcel.java
index 00424b5fc6..8bbdf111d7 100644
--- a/epmet-module/gov-project/gov-project-server/src/main/java/com/epmet/excel/ProjectExcel.java
+++ b/epmet-module/gov-project/gov-project-server/src/main/java/com/epmet/excel/ProjectExcel.java
@@ -34,6 +34,9 @@ public class ProjectExcel {
@Excel(name = "唯一标识")
private String id;
+ @Excel(name = " 客户ID")
+ private String customerId;
+
@Excel(name = " 机关ID")
private String agencyId;
diff --git a/epmet-module/gov-project/gov-project-server/src/main/java/com/epmet/feign/GovOrgFeignClient.java b/epmet-module/gov-project/gov-project-server/src/main/java/com/epmet/feign/GovOrgFeignClient.java
index 5038fa4206..a086079472 100644
--- a/epmet-module/gov-project/gov-project-server/src/main/java/com/epmet/feign/GovOrgFeignClient.java
+++ b/epmet-module/gov-project/gov-project-server/src/main/java/com/epmet/feign/GovOrgFeignClient.java
@@ -8,6 +8,7 @@ import com.epmet.commons.tools.utils.Result;
import com.epmet.dto.form.AgencyDeptGridFormDTO;
import com.epmet.dto.result.AgencyDeptGridResultDTO;
import com.epmet.dto.result.DepartmentStaffListResultDTO;
+import com.epmet.dto.result.ProcessorListResultDTO;
import com.epmet.feign.fallback.GovOrgFeignClientFallBack;
import org.springframework.cloud.openfeign.FeignClient;
import org.springframework.web.bind.annotation.PathVariable;
@@ -46,4 +47,13 @@ public interface GovOrgFeignClient {
@PostMapping(value = "/gov/org/customeragency/getagencydeptgridlist")
Result getAgencyDeptGridList(AgencyDeptGridFormDTO formDTO);
+ /**
+ * @param agencyId
+ * @return
+ * @Author sun
+ * @Description 根据当前组织ID查询上两级组织、当前组织和所有下级(迭代)组织
+ **/
+ @PostMapping(value = "/gov/org/customeragency/getprocessorlist/{agencyId}")
+ Result getProcessorList(@PathVariable("agencyId") String agencyId);
+
}
diff --git a/epmet-module/gov-project/gov-project-server/src/main/java/com/epmet/feign/fallback/GovOrgFeignClientFallBack.java b/epmet-module/gov-project/gov-project-server/src/main/java/com/epmet/feign/fallback/GovOrgFeignClientFallBack.java
index 3588d47287..1fad4e06c6 100644
--- a/epmet-module/gov-project/gov-project-server/src/main/java/com/epmet/feign/fallback/GovOrgFeignClientFallBack.java
+++ b/epmet-module/gov-project/gov-project-server/src/main/java/com/epmet/feign/fallback/GovOrgFeignClientFallBack.java
@@ -10,6 +10,7 @@ import com.epmet.commons.tools.utils.Result;
import com.epmet.dto.form.AgencyDeptGridFormDTO;
import com.epmet.dto.result.AgencyDeptGridResultDTO;
import com.epmet.dto.result.DepartmentStaffListResultDTO;
+import com.epmet.dto.result.ProcessorListResultDTO;
import com.epmet.feign.GovOrgFeignClient;
import org.springframework.stereotype.Component;
@@ -33,4 +34,9 @@ public class GovOrgFeignClientFallBack implements GovOrgFeignClient {
public Result getAgencyDeptGridList(AgencyDeptGridFormDTO formDTO) {
return ModuleUtils.feignConError(ServiceConstant.GOV_ORG_SERVER, "getAgencyDeptGridList", formDTO);
}
+
+ @Override
+ public Result getProcessorList(String agencyId) {
+ return ModuleUtils.feignConError(ServiceConstant.GOV_ORG_SERVER, "getProcessorList", agencyId);
+ }
}
diff --git a/epmet-module/gov-project/gov-project-server/src/main/java/com/epmet/service/ProjectProcessService.java b/epmet-module/gov-project/gov-project-server/src/main/java/com/epmet/service/ProjectProcessService.java
index aa523854d3..751e31ba03 100644
--- a/epmet-module/gov-project/gov-project-server/src/main/java/com/epmet/service/ProjectProcessService.java
+++ b/epmet-module/gov-project/gov-project-server/src/main/java/com/epmet/service/ProjectProcessService.java
@@ -19,10 +19,13 @@ package com.epmet.service;
import com.epmet.commons.mybatis.service.BaseService;
import com.epmet.commons.tools.page.PageData;
+import com.epmet.commons.tools.security.dto.TokenDto;
import com.epmet.dto.ProjectProcessDTO;
import com.epmet.dto.form.ProcessListFormDTO;
+import com.epmet.dto.form.ProjectDetailFromDTO;
import com.epmet.dto.form.ReturnListFromDTO;
import com.epmet.dto.form.TransferFormDTO;
+import com.epmet.dto.result.DepartmentResultDTO;
import com.epmet.dto.result.ProcesslistResultDTO;
import com.epmet.dto.result.ReturnListResultDTO;
import com.epmet.entity.ProjectProcessEntity;
@@ -122,4 +125,5 @@ public interface ProjectProcessService extends BaseService
* @Description 项目跟踪-转其他部门
**/
void transfer(TransferFormDTO formDTO);
+
}
\ No newline at end of file
diff --git a/epmet-module/gov-project/gov-project-server/src/main/java/com/epmet/service/ProjectService.java b/epmet-module/gov-project/gov-project-server/src/main/java/com/epmet/service/ProjectService.java
index cb39927bf0..f482b79abd 100644
--- a/epmet-module/gov-project/gov-project-server/src/main/java/com/epmet/service/ProjectService.java
+++ b/epmet-module/gov-project/gov-project-server/src/main/java/com/epmet/service/ProjectService.java
@@ -21,14 +21,8 @@ import com.epmet.commons.mybatis.service.BaseService;
import com.epmet.commons.tools.page.PageData;
import com.epmet.commons.tools.security.dto.TokenDto;
import com.epmet.dto.ProjectDTO;
-import com.epmet.dto.form.ProjectClosedFromDTO;
-import com.epmet.dto.form.ProjectDetailFromDTO;
-import com.epmet.dto.form.ProjectListFromDTO;
-import com.epmet.dto.form.ReturnFromDTO;
-import com.epmet.dto.result.CreatedListResultDTO;
-import com.epmet.dto.result.InvolvedListResultDTO;
-import com.epmet.dto.result.PendProjectListResultDTO;
-import com.epmet.dto.result.ProjectDetailResultDTO;
+import com.epmet.dto.form.*;
+import com.epmet.dto.result.*;
import com.epmet.entity.ProjectEntity;
import java.util.List;
@@ -159,4 +153,13 @@ public interface ProjectService extends BaseService {
* @return void
*/
void projectReturn(ReturnFromDTO fromDTO);
+
+ /**
+ * 根据议题查询项目
+ * @author zhaoqifeng
+ * @date 2020/5/13 16:55
+ * @param fromDTO
+ * @return java.util.List
+ */
+ List getProjectByIssue(ShiftProjectsFromDTO fromDTO);
}
\ No newline at end of file
diff --git a/epmet-module/gov-project/gov-project-server/src/main/java/com/epmet/service/ProjectTraceService.java b/epmet-module/gov-project/gov-project-server/src/main/java/com/epmet/service/ProjectTraceService.java
index f91afc3c3a..a3ebf9d74c 100644
--- a/epmet-module/gov-project/gov-project-server/src/main/java/com/epmet/service/ProjectTraceService.java
+++ b/epmet-module/gov-project/gov-project-server/src/main/java/com/epmet/service/ProjectTraceService.java
@@ -88,4 +88,23 @@ public interface ProjectTraceService {
* @date 2020/5/11 16:32
*/
void projectReturn(TokenDto tokenDto, ReturnFromDTO fromDTO);
+
+ /**
+ * 我的处理部门
+ *
+ * @param tokenDto token
+ * @param fromDTO 入参
+ * @return java.util.List
+ * @author zhaoqifeng
+ * @date 2020/5/14 14:24
+ */
+ List myDepartmentList(TokenDto tokenDto, ProjectDetailFromDTO fromDTO);
+
+ /**
+ * @param formDTO
+ * @return
+ * @Author sun
+ * @Description 项目跟踪-项目人员选择
+ **/
+ ProcessorListResultDTO processorList(ProcessorListFormDTO formDTO);
}
diff --git a/epmet-module/gov-project/gov-project-server/src/main/java/com/epmet/service/impl/ProjectProcessServiceImpl.java b/epmet-module/gov-project/gov-project-server/src/main/java/com/epmet/service/impl/ProjectProcessServiceImpl.java
index 38a3f8c9dc..0939efc749 100644
--- a/epmet-module/gov-project/gov-project-server/src/main/java/com/epmet/service/impl/ProjectProcessServiceImpl.java
+++ b/epmet-module/gov-project/gov-project-server/src/main/java/com/epmet/service/impl/ProjectProcessServiceImpl.java
@@ -196,7 +196,7 @@ public class ProjectProcessServiceImpl extends BaseServiceImpl staffList = formDTO.getStaffList();
if (null == staffList || staffList.size() < NumConstant.ONE) {
- throw new RenException(ProjectConstant.DATe_EXCEPTION);
+ throw new RenException(ProjectConstant.DATE_EXCEPTION);
}
//3.1:调用gov-org服务,获取所有勾选人员对应的组织信息、部门信息、网格信息用于对处理部门和ORG_ID_PATH字段的赋值
List agencyIdList = staffList.stream().map(TickStaffFormDTO::getAgencyId).collect(Collectors.toList());
diff --git a/epmet-module/gov-project/gov-project-server/src/main/java/com/epmet/service/impl/ProjectServiceImpl.java b/epmet-module/gov-project/gov-project-server/src/main/java/com/epmet/service/impl/ProjectServiceImpl.java
index a9aa55a296..19946355bd 100644
--- a/epmet-module/gov-project/gov-project-server/src/main/java/com/epmet/service/impl/ProjectServiceImpl.java
+++ b/epmet-module/gov-project/gov-project-server/src/main/java/com/epmet/service/impl/ProjectServiceImpl.java
@@ -296,6 +296,7 @@ public class ProjectServiceImpl extends BaseServiceImpl getProjectByIssue(ShiftProjectsFromDTO fromDTO) {
+ List resultList = new ArrayList<>();
+ List projectList = baseDao.selectShiftProjectList(fromDTO);
+ projectList.forEach(project -> {
+ ShiftProjectResultDTO shiftProject = ConvertUtils.sourceToTarget(project, ShiftProjectResultDTO.class);
+ List departmentNameList = baseDao.selectDepartmentNameList(project);
+ shiftProject.setDepartmentNameList(departmentNameList);
+ resultList.add(shiftProject);
+ });
+ return resultList;
+ }
+
/**
* 获取客户定制的可滞留天数
*
diff --git a/epmet-module/gov-project/gov-project-server/src/main/java/com/epmet/service/impl/ProjectTraceServiceImpl.java b/epmet-module/gov-project/gov-project-server/src/main/java/com/epmet/service/impl/ProjectTraceServiceImpl.java
index 69448b017a..3166c2497c 100644
--- a/epmet-module/gov-project/gov-project-server/src/main/java/com/epmet/service/impl/ProjectTraceServiceImpl.java
+++ b/epmet-module/gov-project/gov-project-server/src/main/java/com/epmet/service/impl/ProjectTraceServiceImpl.java
@@ -1,10 +1,17 @@
package com.epmet.service.impl;
+import com.epmet.commons.tools.exception.RenException;
import com.epmet.commons.tools.security.dto.TokenDto;
+import com.epmet.commons.tools.utils.Result;
+import com.epmet.constant.ProjectConstant;
+import com.epmet.dto.ProjectStaffDTO;
import com.epmet.dto.form.*;
import com.epmet.dto.result.*;
+import com.epmet.entity.ProjectStaffEntity;
+import com.epmet.feign.GovOrgFeignClient;
import com.epmet.service.ProjectProcessService;
import com.epmet.service.ProjectService;
+import com.epmet.service.ProjectStaffService;
import com.epmet.service.ProjectTraceService;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;
@@ -22,6 +29,10 @@ public class ProjectTraceServiceImpl implements ProjectTraceService {
private ProjectService projectService;
@Autowired
private ProjectProcessService projectProcessService;
+ @Autowired
+ private ProjectStaffService projectStaffService;
+ @Autowired
+ private GovOrgFeignClient govOrgFeignClient;
@Override
public List getPendProjectList(TokenDto tokenDto, ProjectListFromDTO fromDTO) {
@@ -63,4 +74,25 @@ public class ProjectTraceServiceImpl implements ProjectTraceService {
fromDTO.setUserId(tokenDto.getUserId());
projectService.projectReturn(fromDTO);
}
+
+ @Override
+ public List myDepartmentList(TokenDto tokenDto, ProjectDetailFromDTO fromDTO) {
+ fromDTO.setUserId(tokenDto.getUserId());
+ ProjectStaffDTO projectStaffDTO = new ProjectStaffDTO();
+ projectStaffDTO.setProjectId(fromDTO.getProjectId());
+ projectStaffDTO.setStaffId(fromDTO.getUserId());
+ return projectStaffService.getDepartmentNameList(projectStaffDTO);
+ }
+
+ @Override
+ public ProcessorListResultDTO processorList(ProcessorListFormDTO formDTO) {
+ //1:查询当前工作人员所属组织Id
+ ProjectStaffEntity staffEntity = projectStaffService.selectById(formDTO.getProjectStaffId());
+ if (null == staffEntity) {
+ throw new RenException(ProjectConstant.SELECT_PROJECTSTAFF_EXCEPTION);
+ }
+ //2:调用gov-org服务,查询组织树
+ Result resultDTOResult = govOrgFeignClient.getProcessorList(staffEntity.getOrgId());
+ return resultDTOResult.getData();
+ }
}
diff --git a/epmet-module/gov-project/gov-project-server/src/main/resources/db.migration/epmet_gov_project.sql b/epmet-module/gov-project/gov-project-server/src/main/resources/db.migration/epmet_gov_project.sql
index f87285eecd..9265cad8c9 100644
--- a/epmet-module/gov-project/gov-project-server/src/main/resources/db.migration/epmet_gov_project.sql
+++ b/epmet-module/gov-project/gov-project-server/src/main/resources/db.migration/epmet_gov_project.sql
@@ -41,7 +41,7 @@ CREATE TABLE `customer_project_parameter` (
DROP TABLE IF EXISTS `project`;
CREATE TABLE `project` (
`ID` varchar(64) CHARACTER SET utf8mb4 COLLATE utf8mb4_general_ci NOT NULL COMMENT '唯一标识',
- `AGENCY_ID` varchar(64) CHARACTER SET utf8mb4 COLLATE utf8mb4_general_ci NOT NULL COMMENT ' 机关ID',
+ `AGENCY_ID` varchar(64) CHARACTER SET utf8mb4 COLLATE utf8mb4_general_ci NOT NULL COMMENT '机关ID',
`ORIGIN` varchar(32) CHARACTER SET utf8mb4 COLLATE utf8mb4_general_ci DEFAULT NULL COMMENT '来源:议题issue',
`ORIGIN_ID` varchar(64) CHARACTER SET utf8mb4 COLLATE utf8mb4_general_ci NOT NULL COMMENT '来源ID',
`TITLE` varchar(32) CHARACTER SET utf8mb4 COLLATE utf8mb4_general_ci DEFAULT NULL COMMENT '项目标题',
@@ -129,7 +129,7 @@ CREATE TABLE `project_staff` (
`GRID_ID` varchar(32) CHARACTER SET utf8mb4 COLLATE utf8mb4_general_ci DEFAULT NULL COMMENT '网格ID',
`ORG_ID_PATH` varchar(32) CHARACTER SET utf8mb4 COLLATE utf8mb4_general_ci DEFAULT NULL COMMENT '所属机关(11:22:33)',
`STAFF_ID` varchar(64) CHARACTER SET utf8mb4 COLLATE utf8mb4_general_ci NOT NULL COMMENT '人员ID',
- `IS_HANDLE` varchar(32) CHARACTER SET utf8mb4 COLLATE utf8mb4_general_ci DEFAULT NULL COMMENT '是否处理:未处理unhandle,已处理handle',
+ `IS_HANDLE` varchar(32) CHARACTER SET utf8mb4 COLLATE utf8mb4_general_ci DEFAULT NULL COMMENT '是否处理:未处理unhandled,已处理handle',
`DEL_FLAG` char(1) CHARACTER SET utf8mb4 COLLATE utf8mb4_general_ci NOT NULL COMMENT '删除标识:0.未删除 1.已删除',
`REVISION` int(11) NOT NULL COMMENT '乐观锁',
`CREATED_BY` varchar(32) CHARACTER SET utf8mb4 COLLATE utf8mb4_general_ci NOT NULL COMMENT '创建人',
@@ -148,3 +148,5 @@ alter table project_process add column OPERATION_NAME varchar(200) NOT NULL COMM
alter table project_staff add column DEPARTMENT_NAME varchar(200) NOT NULL COMMENT '处理部门' after STAFF_ID;
alter table project_process add column DEPARTMENT_NAME varchar(200) NOT NULL COMMENT '处理部门' after PROJECT_ID;
+
+alter table project add column CUSTOMER_ID varchar(64) NOT NULL COMMENT '客户ID' after ID;
diff --git a/epmet-module/gov-project/gov-project-server/src/main/resources/mapper/ProjectDao.xml b/epmet-module/gov-project/gov-project-server/src/main/resources/mapper/ProjectDao.xml
index e7cc041e78..492465f853 100644
--- a/epmet-module/gov-project/gov-project-server/src/main/resources/mapper/ProjectDao.xml
+++ b/epmet-module/gov-project/gov-project-server/src/main/resources/mapper/ProjectDao.xml
@@ -134,6 +134,21 @@
WHERE p.DEL_FLAG = '0'
AND p.ID = #{id}
+
\ No newline at end of file
diff --git a/epmet-module/oper-access/oper-access-server/Dockerfile b/epmet-module/oper-access/oper-access-server/Dockerfile
index bde41338e6..48f2a3dea5 100644
--- a/epmet-module/oper-access/oper-access-server/Dockerfile
+++ b/epmet-module/oper-access/oper-access-server/Dockerfile
@@ -8,4 +8,4 @@ COPY ./target/*.jar ./app.jar
EXPOSE 8093
-ENTRYPOINT ["java","-Xms32m","-Xmx200m","-jar","./app.jar"]
\ No newline at end of file
+ENTRYPOINT ["sh", "-c", "$RUN_INSTRUCT"]
\ No newline at end of file
diff --git a/epmet-module/oper-access/oper-access-server/docker-compose.yml b/epmet-module/oper-access/oper-access-server/deploy/docker-compose-dev.yml
similarity index 62%
rename from epmet-module/oper-access/oper-access-server/docker-compose.yml
rename to epmet-module/oper-access/oper-access-server/deploy/docker-compose-dev.yml
index 5cfa3206cd..613e8ff293 100644
--- a/epmet-module/oper-access/oper-access-server/docker-compose.yml
+++ b/epmet-module/oper-access/oper-access-server/deploy/docker-compose-dev.yml
@@ -2,12 +2,14 @@ version: "3.7"
services:
oper-access-server:
container_name: oper-access-server-dev
- image: registry-vpc.cn-qingdao.aliyuncs.com/epmet-cloud-dev/oper-access-server:0.3.4
+ image: 192.168.1.130:10080/epmet-cloud-dev/oper-access-server:0.3.6
ports:
- "8093:8093"
network_mode: host # 使用现有网络
volumes:
- "/opt/epmet-cloud-logs/dev:/logs"
+ environment:
+ RUN_INSTRUCT: "java -Xms32m -Xmx200m -jar ./app.jar"
deploy:
resources:
limits:
diff --git a/epmet-module/oper-access/oper-access-server/deploy/docker-compose-test.yml b/epmet-module/oper-access/oper-access-server/deploy/docker-compose-test.yml
new file mode 100644
index 0000000000..fb5831137b
--- /dev/null
+++ b/epmet-module/oper-access/oper-access-server/deploy/docker-compose-test.yml
@@ -0,0 +1,17 @@
+version: "3.7"
+services:
+ oper-access-server:
+ container_name: oper-access-server-test
+ image: registry-vpc.cn-qingdao.aliyuncs.com/epmet-cloud-release/oper-access-server:0.3.6
+ ports:
+ - "8093:8093"
+ network_mode: host # 使用现有网络
+ volumes:
+ - "/opt/epmet-cloud-logs/test:/logs"
+ environment:
+ RUN_INSTRUCT: "java -Xms32m -Xmx200m -jar ./app.jar"
+ deploy:
+ resources:
+ limits:
+ cpus: '0.1'
+ memory: 250M
\ No newline at end of file
diff --git a/epmet-module/oper-access/oper-access-server/pom.xml b/epmet-module/oper-access/oper-access-server/pom.xml
index 55dbb0f047..ead4e79273 100644
--- a/epmet-module/oper-access/oper-access-server/pom.xml
+++ b/epmet-module/oper-access/oper-access-server/pom.xml
@@ -3,7 +3,7 @@
xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
- 0.3.4
+ 0.3.6
oper-access
com.epmet
@@ -93,59 +93,29 @@
- dev-local
+ dev
true
-
- 8093
- dev
-
-
-
-
-
- epmet_oper_access_user
- EpmEt-db-UsEr
-
- 0
- 192.168.1.130
- 6379
- 123456
-
- false
- 122.152.200.70:8848
- fcd6fc8f-ca3a-4b01-8026-2b05cdc5976b
-
-
- false
-
-
-
-
- dev
-
8093
dev
-
+
- epmet
- elink@833066
+ epmet_oper_access_user
+ EpmEt-db-UsEr
0
- r-m5eoz5b6tkx09y6bpz.redis.rds.aliyuncs.com
+ 192.168.1.130
6379
- EpmEtrEdIs!q@w
+ 123456
true
- 192.168.10.150:8848
- 67e3c350-533e-4d7c-9f8f-faf1b4aa82ae
+ 122.152.200.70:8848
+ fcd6fc8f-ca3a-4b01-8026-2b05cdc5976b
false
@@ -163,19 +133,19 @@
-
+
epmet
elink@833066
0
- 10.10.10.248
+ r-m5eoz5b6tkx09y6bpz.redis.rds.aliyuncs.com
6379
- 123456
+ EpmEtrEdIs!q@w
true
- 122.152.200.70:8848
- fcd6fc8f-ca3a-4b01-8026-2b05cdc5976b
+ 192.168.10.150:8848
+ 67e3c350-533e-4d7c-9f8f-faf1b4aa82ae
false
diff --git a/epmet-module/oper-access/oper-access-server/src/main/java/com/epmet/aspect/RequestLogAspect.java b/epmet-module/oper-access/oper-access-server/src/main/java/com/epmet/aspect/RequestLogAspect.java
new file mode 100644
index 0000000000..49581cf63c
--- /dev/null
+++ b/epmet-module/oper-access/oper-access-server/src/main/java/com/epmet/aspect/RequestLogAspect.java
@@ -0,0 +1,40 @@
+package com.epmet.aspect;
+
+import com.epmet.commons.tools.aspect.BaseRequestLogAspect;
+import org.aspectj.lang.ProceedingJoinPoint;
+import org.aspectj.lang.annotation.Around;
+import org.aspectj.lang.annotation.Aspect;
+import org.springframework.core.annotation.Order;
+import org.springframework.stereotype.Component;
+import org.springframework.web.context.request.RequestAttributes;
+import org.springframework.web.context.request.RequestContextHolder;
+import org.springframework.web.context.request.ServletRequestAttributes;
+
+import javax.servlet.http.HttpServletRequest;
+
+/**
+ * 日志/异常处理切面实现,调用父类方法完成日志记录和异常处理。
+ */
+@Aspect
+@Component
+@Order(0)
+public class RequestLogAspect extends BaseRequestLogAspect {
+
+ @Override
+ @Around(value = "execution(* com.epmet.controller.*Controller*.*(..)) ")
+ public Object proceed(ProceedingJoinPoint point) throws Throwable {
+ return super.proceed(point, getRequest());
+ }
+
+ /**
+ * 获取Request对象
+ *
+ * @return
+ */
+ private HttpServletRequest getRequest() {
+ RequestAttributes ra = RequestContextHolder.getRequestAttributes();
+ ServletRequestAttributes sra = (ServletRequestAttributes) ra;
+ return sra.getRequest();
+ }
+
+}
diff --git a/epmet-module/oper-crm/oper-crm-server/Dockerfile b/epmet-module/oper-crm/oper-crm-server/Dockerfile
index bb97bee10e..696964e45a 100644
--- a/epmet-module/oper-crm/oper-crm-server/Dockerfile
+++ b/epmet-module/oper-crm/oper-crm-server/Dockerfile
@@ -8,4 +8,4 @@ COPY ./target/*.jar ./app.jar
EXPOSE 8090
-ENTRYPOINT ["java","-Xms32m","-Xmx200m","-jar","./app.jar"]
\ No newline at end of file
+ENTRYPOINT ["sh", "-c", "$RUN_INSTRUCT"]
\ No newline at end of file
diff --git a/epmet-module/oper-crm/oper-crm-server/docker-compose.yml b/epmet-module/oper-crm/oper-crm-server/deploy/docker-compose-dev.yml
similarity index 62%
rename from epmet-module/oper-crm/oper-crm-server/docker-compose.yml
rename to epmet-module/oper-crm/oper-crm-server/deploy/docker-compose-dev.yml
index 01275c1887..2c4a57b403 100644
--- a/epmet-module/oper-crm/oper-crm-server/docker-compose.yml
+++ b/epmet-module/oper-crm/oper-crm-server/deploy/docker-compose-dev.yml
@@ -2,12 +2,14 @@ version: "3.7"
services:
oper-crm-server:
container_name: oper-crm-server-dev
- image: registry-vpc.cn-qingdao.aliyuncs.com/epmet-cloud-dev/oper-crm-server:0.3.5
+ image: 192.168.1.130:10080/epmet-cloud-dev/oper-crm-server:0.3.7
ports:
- "8090:8090"
network_mode: host # 使用现有网络
volumes:
- "/opt/epmet-cloud-logs/dev:/logs"
+ environment:
+ RUN_INSTRUCT: "java -Xms32m -Xmx200m -jar ./app.jar"
deploy:
resources:
limits:
diff --git a/epmet-module/oper-crm/oper-crm-server/deploy/docker-compose-test.yml b/epmet-module/oper-crm/oper-crm-server/deploy/docker-compose-test.yml
new file mode 100644
index 0000000000..e2111ec9b6
--- /dev/null
+++ b/epmet-module/oper-crm/oper-crm-server/deploy/docker-compose-test.yml
@@ -0,0 +1,17 @@
+version: "3.7"
+services:
+ oper-crm-server:
+ container_name: oper-crm-server-test
+ image: registry-vpc.cn-qingdao.aliyuncs.com/epmet-cloud-release/oper-crm-server:0.3.7
+ ports:
+ - "8090:8090"
+ network_mode: host # 使用现有网络
+ volumes:
+ - "/opt/epmet-cloud-logs/test:/logs"
+ environment:
+ RUN_INSTRUCT: "java -Xms32m -Xmx200m -jar ./app.jar"
+ deploy:
+ resources:
+ limits:
+ cpus: '0.1'
+ memory: 250M
\ No newline at end of file
diff --git a/epmet-module/oper-crm/oper-crm-server/pom.xml b/epmet-module/oper-crm/oper-crm-server/pom.xml
index 1a911314f8..d4272fbbc9 100644
--- a/epmet-module/oper-crm/oper-crm-server/pom.xml
+++ b/epmet-module/oper-crm/oper-crm-server/pom.xml
@@ -2,7 +2,7 @@
4.0.0
- 0.3.5
+ 0.3.7
com.epmet
oper-crm
@@ -91,7 +91,7 @@
- dev-local
+ dev
true
@@ -111,7 +111,7 @@
6379
123456
- false
+ true
122.152.200.70:8848
fcd6fc8f-ca3a-4b01-8026-2b05cdc5976b
@@ -121,13 +121,13 @@
- dev
+ test
8090
- dev
+ test
@@ -150,35 +150,5 @@
-
- test
-
-
- 8090
- test
-
-
-
-
-
- epmet
- elink@833066
-
- 0
- 10.10.10.248
- 6379
- 123456
-
- true
- 122.152.200.70:8848
- fcd6fc8f-ca3a-4b01-8026-2b05cdc5976b
-
-
- false
-
-
-
diff --git a/epmet-module/oper-crm/oper-crm-server/src/main/java/com/epmet/aspect/RequestLogAspect.java b/epmet-module/oper-crm/oper-crm-server/src/main/java/com/epmet/aspect/RequestLogAspect.java
new file mode 100644
index 0000000000..49581cf63c
--- /dev/null
+++ b/epmet-module/oper-crm/oper-crm-server/src/main/java/com/epmet/aspect/RequestLogAspect.java
@@ -0,0 +1,40 @@
+package com.epmet.aspect;
+
+import com.epmet.commons.tools.aspect.BaseRequestLogAspect;
+import org.aspectj.lang.ProceedingJoinPoint;
+import org.aspectj.lang.annotation.Around;
+import org.aspectj.lang.annotation.Aspect;
+import org.springframework.core.annotation.Order;
+import org.springframework.stereotype.Component;
+import org.springframework.web.context.request.RequestAttributes;
+import org.springframework.web.context.request.RequestContextHolder;
+import org.springframework.web.context.request.ServletRequestAttributes;
+
+import javax.servlet.http.HttpServletRequest;
+
+/**
+ * 日志/异常处理切面实现,调用父类方法完成日志记录和异常处理。
+ */
+@Aspect
+@Component
+@Order(0)
+public class RequestLogAspect extends BaseRequestLogAspect {
+
+ @Override
+ @Around(value = "execution(* com.epmet.controller.*Controller*.*(..)) ")
+ public Object proceed(ProceedingJoinPoint point) throws Throwable {
+ return super.proceed(point, getRequest());
+ }
+
+ /**
+ * 获取Request对象
+ *
+ * @return
+ */
+ private HttpServletRequest getRequest() {
+ RequestAttributes ra = RequestContextHolder.getRequestAttributes();
+ ServletRequestAttributes sra = (ServletRequestAttributes) ra;
+ return sra.getRequest();
+ }
+
+}
diff --git a/epmet-module/oper-customize/oper-customize-server/Dockerfile b/epmet-module/oper-customize/oper-customize-server/Dockerfile
index 0dc758020b..08eccce004 100644
--- a/epmet-module/oper-customize/oper-customize-server/Dockerfile
+++ b/epmet-module/oper-customize/oper-customize-server/Dockerfile
@@ -8,4 +8,4 @@ COPY ./target/*.jar ./app.jar
EXPOSE 8089
-ENTRYPOINT ["java","-Xms32m","-Xmx200m","-jar","./app.jar"]
\ No newline at end of file
+ENTRYPOINT ["sh", "-c", "$RUN_INSTRUCT"]
\ No newline at end of file
diff --git a/epmet-module/oper-customize/oper-customize-server/docker-compose.yml b/epmet-module/oper-customize/oper-customize-server/deploy/docker-compose-dev.yml
similarity index 62%
rename from epmet-module/oper-customize/oper-customize-server/docker-compose.yml
rename to epmet-module/oper-customize/oper-customize-server/deploy/docker-compose-dev.yml
index aa3c04f679..8e2903fed2 100644
--- a/epmet-module/oper-customize/oper-customize-server/docker-compose.yml
+++ b/epmet-module/oper-customize/oper-customize-server/deploy/docker-compose-dev.yml
@@ -2,12 +2,14 @@ version: "3.7"
services:
oper-customize-server:
container_name: oper-customize-server-dev
- image: registry-vpc.cn-qingdao.aliyuncs.com/epmet-cloud-dev/oper-customize-server:0.3.6
+ image: 192.168.1.130:10080/epmet-cloud-dev/oper-customize-server:0.3.8
ports:
- "8089:8089"
network_mode: host # 使用现有网络
volumes:
- "/opt/epmet-cloud-logs/dev:/logs"
+ environment:
+ RUN_INSTRUCT: "java -Xms32m -Xmx200m -jar ./app.jar"
deploy:
resources:
limits:
diff --git a/epmet-module/oper-customize/oper-customize-server/deploy/docker-compose-test.yml b/epmet-module/oper-customize/oper-customize-server/deploy/docker-compose-test.yml
new file mode 100644
index 0000000000..45827ee1bd
--- /dev/null
+++ b/epmet-module/oper-customize/oper-customize-server/deploy/docker-compose-test.yml
@@ -0,0 +1,17 @@
+version: "3.7"
+services:
+ oper-customize-server:
+ container_name: oper-customize-server-test
+ image: registry-vpc.cn-qingdao.aliyuncs.com/epmet-cloud-release/oper-customize-server:0.3.8
+ ports:
+ - "8089:8089"
+ network_mode: host # 使用现有网络
+ volumes:
+ - "/opt/epmet-cloud-logs/test:/logs"
+ environment:
+ RUN_INSTRUCT: "java -Xms32m -Xmx200m -jar ./app.jar"
+ deploy:
+ resources:
+ limits:
+ cpus: '0.1'
+ memory: 250M
\ No newline at end of file
diff --git a/epmet-module/oper-customize/oper-customize-server/pom.xml b/epmet-module/oper-customize/oper-customize-server/pom.xml
index 65825b904f..9b1397bf37 100644
--- a/epmet-module/oper-customize/oper-customize-server/pom.xml
+++ b/epmet-module/oper-customize/oper-customize-server/pom.xml
@@ -2,7 +2,7 @@
4.0.0
- 0.3.6
+ 0.3.8
com.epmet
oper-customize
@@ -85,7 +85,7 @@
- dev-local
+ dev
true
@@ -105,7 +105,7 @@
6379
123456
- false
+ true
122.152.200.70:8848
fcd6fc8f-ca3a-4b01-8026-2b05cdc5976b
@@ -115,13 +115,13 @@
- dev
+ test
8089
- dev
+ test
@@ -144,35 +144,5 @@
-
- test
-
-
- 8089
- test
-
-
-
-
-
- epmet
- elink@833066
-
- 0
- 10.10.10.248
- 6379
- 123456
-
- true
- 122.152.200.70:8848
- fcd6fc8f-ca3a-4b01-8026-2b05cdc5976b
-
-
- false
-
-
-
diff --git a/epmet-module/oper-customize/oper-customize-server/src/main/java/com/epmet/aspect/RequestLogAspect.java b/epmet-module/oper-customize/oper-customize-server/src/main/java/com/epmet/aspect/RequestLogAspect.java
new file mode 100644
index 0000000000..49581cf63c
--- /dev/null
+++ b/epmet-module/oper-customize/oper-customize-server/src/main/java/com/epmet/aspect/RequestLogAspect.java
@@ -0,0 +1,40 @@
+package com.epmet.aspect;
+
+import com.epmet.commons.tools.aspect.BaseRequestLogAspect;
+import org.aspectj.lang.ProceedingJoinPoint;
+import org.aspectj.lang.annotation.Around;
+import org.aspectj.lang.annotation.Aspect;
+import org.springframework.core.annotation.Order;
+import org.springframework.stereotype.Component;
+import org.springframework.web.context.request.RequestAttributes;
+import org.springframework.web.context.request.RequestContextHolder;
+import org.springframework.web.context.request.ServletRequestAttributes;
+
+import javax.servlet.http.HttpServletRequest;
+
+/**
+ * 日志/异常处理切面实现,调用父类方法完成日志记录和异常处理。
+ */
+@Aspect
+@Component
+@Order(0)
+public class RequestLogAspect extends BaseRequestLogAspect {
+
+ @Override
+ @Around(value = "execution(* com.epmet.controller.*Controller*.*(..)) ")
+ public Object proceed(ProceedingJoinPoint point) throws Throwable {
+ return super.proceed(point, getRequest());
+ }
+
+ /**
+ * 获取Request对象
+ *
+ * @return
+ */
+ private HttpServletRequest getRequest() {
+ RequestAttributes ra = RequestContextHolder.getRequestAttributes();
+ ServletRequestAttributes sra = (ServletRequestAttributes) ra;
+ return sra.getRequest();
+ }
+
+}
diff --git a/epmet-module/oper-customize/oper-customize-server/src/main/java/com/epmet/service/impl/HomeServiceImpl.java b/epmet-module/oper-customize/oper-customize-server/src/main/java/com/epmet/service/impl/HomeServiceImpl.java
index 1f697182b0..c2163d560c 100644
--- a/epmet-module/oper-customize/oper-customize-server/src/main/java/com/epmet/service/impl/HomeServiceImpl.java
+++ b/epmet-module/oper-customize/oper-customize-server/src/main/java/com/epmet/service/impl/HomeServiceImpl.java
@@ -53,7 +53,6 @@ public class HomeServiceImpl implements HomeService {
public Result getHomeDesignByCustomer(CustomerHomeFormDTO formDTO) {
HomeDesignByCustomerResultDTO resultDTO = new HomeDesignByCustomerResultDTO();
//根据客户id,所属端获取客户首页配置的设计稿
- formDTO.setStatus(OperCustomizeConstant.STATUS_DRAFT);
List list = customerHomeDetailDao.selectCustomerHomeDetail(formDTO);
List titleList = new ArrayList<>();
List topList = new ArrayList<>();
diff --git a/epmet-module/resi-group/resi-group-client/src/main/java/com/epmet/resi/group/dto/member/form/ApplyingMemberFormDTO.java b/epmet-module/resi-group/resi-group-client/src/main/java/com/epmet/resi/group/dto/member/form/ApplyingMemberFormDTO.java
index 4ab61b072f..f55ade60b2 100644
--- a/epmet-module/resi-group/resi-group-client/src/main/java/com/epmet/resi/group/dto/member/form/ApplyingMemberFormDTO.java
+++ b/epmet-module/resi-group/resi-group-client/src/main/java/com/epmet/resi/group/dto/member/form/ApplyingMemberFormDTO.java
@@ -25,4 +25,10 @@ public class ApplyingMemberFormDTO implements Serializable {
private Integer pageNo;
private Integer pageSize=20;
+
+ /**
+ * 从token中获取的用户ID
+ */
+ @NotBlank(message = "用户id不能为空")
+ private String userId;
}
diff --git a/epmet-module/resi-group/resi-group-client/src/main/java/com/epmet/resi/group/dto/member/form/GroupMemberListFormDTO.java b/epmet-module/resi-group/resi-group-client/src/main/java/com/epmet/resi/group/dto/member/form/GroupMemberListFormDTO.java
index e42fdb7c1f..010c24c30d 100644
--- a/epmet-module/resi-group/resi-group-client/src/main/java/com/epmet/resi/group/dto/member/form/GroupMemberListFormDTO.java
+++ b/epmet-module/resi-group/resi-group-client/src/main/java/com/epmet/resi/group/dto/member/form/GroupMemberListFormDTO.java
@@ -26,4 +26,9 @@ public class GroupMemberListFormDTO implements Serializable {
private Integer pageSize=20;
+ /**
+ * 从token中获取的用户ID
+ */
+ @NotBlank(message = "用户id不能为空")
+ private String userId;
}
diff --git a/epmet-module/resi-group/resi-group-server/Dockerfile b/epmet-module/resi-group/resi-group-server/Dockerfile
index f349a97319..b4a767cfc8 100644
--- a/epmet-module/resi-group/resi-group-server/Dockerfile
+++ b/epmet-module/resi-group/resi-group-server/Dockerfile
@@ -8,4 +8,4 @@ COPY ./target/*.jar ./app.jar
EXPOSE 8095
-ENTRYPOINT ["java","-Xms32m","-Xmx200m","-jar","./app.jar"]
\ No newline at end of file
+ENTRYPOINT ["sh", "-c", "$RUN_INSTRUCT"]
\ No newline at end of file
diff --git a/epmet-module/resi-group/resi-group-server/docker-compose.yml b/epmet-module/resi-group/resi-group-server/deploy/docker-compose-dev.yml
similarity index 62%
rename from epmet-module/resi-group/resi-group-server/docker-compose.yml
rename to epmet-module/resi-group/resi-group-server/deploy/docker-compose-dev.yml
index 479cc485a8..f45a475f69 100644
--- a/epmet-module/resi-group/resi-group-server/docker-compose.yml
+++ b/epmet-module/resi-group/resi-group-server/deploy/docker-compose-dev.yml
@@ -2,12 +2,14 @@ version: "3.7"
services:
resi-group-server:
container_name: resi-group-server-dev
- image: registry-vpc.cn-qingdao.aliyuncs.com/epmet-cloud-dev/resi-group-server:0.3.16
+ image: 192.168.1.130:10080/epmet-cloud-dev/resi-group-server:0.3.18
ports:
- "8095:8095"
network_mode: host # 使用现有网络
volumes:
- "/opt/epmet-cloud-logs/dev:/logs"
+ environment:
+ RUN_INSTRUCT: "java -Xms32m -Xmx200m -jar ./app.jar"
deploy:
resources:
limits:
diff --git a/epmet-module/resi-group/resi-group-server/deploy/docker-compose-test.yml b/epmet-module/resi-group/resi-group-server/deploy/docker-compose-test.yml
new file mode 100644
index 0000000000..c094af1ae4
--- /dev/null
+++ b/epmet-module/resi-group/resi-group-server/deploy/docker-compose-test.yml
@@ -0,0 +1,17 @@
+version: "3.7"
+services:
+ resi-group-server:
+ container_name: resi-group-server-test
+ image: registry-vpc.cn-qingdao.aliyuncs.com/epmet-cloud-release/resi-group-server:0.3.18
+ ports:
+ - "8095:8095"
+ network_mode: host # 使用现有网络
+ volumes:
+ - "/opt/epmet-cloud-logs/test:/logs"
+ environment:
+ RUN_INSTRUCT: "java -Xms32m -Xmx200m -jar ./app.jar"
+ deploy:
+ resources:
+ limits:
+ cpus: '0.1'
+ memory: 250M
\ No newline at end of file
diff --git a/epmet-module/resi-group/resi-group-server/pom.xml b/epmet-module/resi-group/resi-group-server/pom.xml
index b22be3af4e..8f24985c42 100644
--- a/epmet-module/resi-group/resi-group-server/pom.xml
+++ b/epmet-module/resi-group/resi-group-server/pom.xml
@@ -2,7 +2,7 @@
4.0.0
- 0.3.16
+ 0.3.18
com.epmet
resi-group
@@ -109,7 +109,7 @@
- dev-local
+ dev
true
@@ -124,12 +124,12 @@
epmet_resi_group_user
EpmEt-db-UsEr
- 1
+ 0
192.168.1.130
6379
123456
- false
+ true
122.152.200.70:8848
fcd6fc8f-ca3a-4b01-8026-2b05cdc5976b
@@ -139,13 +139,13 @@
- dev
-
8095
- dev
+ test
@@ -154,7 +154,7 @@
epmet
elink@833066
- 1
+ 0
r-m5eoz5b6tkx09y6bpz.redis.rds.aliyuncs.com
6379
EpmEtrEdIs!q@w
@@ -168,35 +168,5 @@
-
- test
-
-
- 8095
- test
-
-
-
-
-
- epmet
- elink@833066
-
- 1
- 10.10.10.248
- 6379
- 123456
-
- true
- 122.152.200.70:8848
- fcd6fc8f-ca3a-4b01-8026-2b05cdc5976b
-
-
- false
-
-
-
diff --git a/epmet-module/resi-group/resi-group-server/src/main/java/com/epmet/aspect/RequestLogAspect.java b/epmet-module/resi-group/resi-group-server/src/main/java/com/epmet/aspect/RequestLogAspect.java
new file mode 100644
index 0000000000..49581cf63c
--- /dev/null
+++ b/epmet-module/resi-group/resi-group-server/src/main/java/com/epmet/aspect/RequestLogAspect.java
@@ -0,0 +1,40 @@
+package com.epmet.aspect;
+
+import com.epmet.commons.tools.aspect.BaseRequestLogAspect;
+import org.aspectj.lang.ProceedingJoinPoint;
+import org.aspectj.lang.annotation.Around;
+import org.aspectj.lang.annotation.Aspect;
+import org.springframework.core.annotation.Order;
+import org.springframework.stereotype.Component;
+import org.springframework.web.context.request.RequestAttributes;
+import org.springframework.web.context.request.RequestContextHolder;
+import org.springframework.web.context.request.ServletRequestAttributes;
+
+import javax.servlet.http.HttpServletRequest;
+
+/**
+ * 日志/异常处理切面实现,调用父类方法完成日志记录和异常处理。
+ */
+@Aspect
+@Component
+@Order(0)
+public class RequestLogAspect extends BaseRequestLogAspect {
+
+ @Override
+ @Around(value = "execution(* com.epmet.controller.*Controller*.*(..)) ")
+ public Object proceed(ProceedingJoinPoint point) throws Throwable {
+ return super.proceed(point, getRequest());
+ }
+
+ /**
+ * 获取Request对象
+ *
+ * @return
+ */
+ private HttpServletRequest getRequest() {
+ RequestAttributes ra = RequestContextHolder.getRequestAttributes();
+ ServletRequestAttributes sra = (ServletRequestAttributes) ra;
+ return sra.getRequest();
+ }
+
+}
diff --git a/epmet-module/resi-group/resi-group-server/src/main/java/com/epmet/modules/invitation/controller/GroupInvitationController.java b/epmet-module/resi-group/resi-group-server/src/main/java/com/epmet/modules/invitation/controller/GroupInvitationController.java
index 1364dcbba8..cf50b0b4b3 100644
--- a/epmet-module/resi-group/resi-group-server/src/main/java/com/epmet/modules/invitation/controller/GroupInvitationController.java
+++ b/epmet-module/resi-group/resi-group-server/src/main/java/com/epmet/modules/invitation/controller/GroupInvitationController.java
@@ -60,7 +60,8 @@ public class GroupInvitationController {
@RequestBody CreateGroupInvitationFormDTO formDTO) {
formDTO.setUserId(tokenDto.getUserId());
ValidatorUtils.validateEntity(formDTO);
- return groupInvitationService.createGroupInvitation(formDTO);
+ CreateGroupInvitationResultDTO createGroupInvitationResultDTO=groupInvitationService.createGroupInvitation(formDTO);
+ return new Result().ok(createGroupInvitationResultDTO);
}
/**
@@ -75,7 +76,8 @@ public class GroupInvitationController {
@RequestBody LinkGroupInfoFormDTO formDTO) {
formDTO.setUserId(tokenDto.getUserId());
ValidatorUtils.validateEntity(formDTO);
- return groupInvitationService.getLinkGroupInfo(formDTO);
+ LinkGroupInfoResultDTO linkGroupInfoResultDTO=groupInvitationService.getLinkGroupInfo(formDTO);
+ return new Result().ok(linkGroupInfoResultDTO);
}
/**
@@ -92,6 +94,7 @@ public class GroupInvitationController {
formDTO.setUserId(tokenDto.getUserId());
formDTO.setApp(tokenDto.getApp());
ValidatorUtils.validateEntity(formDTO);
- return groupInvitationService.accetInvitation(formDTO);
+ groupInvitationService.accetInvitation(formDTO);
+ return new Result();
}
}
diff --git a/epmet-module/resi-group/resi-group-server/src/main/java/com/epmet/modules/invitation/service/GroupInvitationService.java b/epmet-module/resi-group/resi-group-server/src/main/java/com/epmet/modules/invitation/service/GroupInvitationService.java
index adc45ff5b2..053c4e036e 100644
--- a/epmet-module/resi-group/resi-group-server/src/main/java/com/epmet/modules/invitation/service/GroupInvitationService.java
+++ b/epmet-module/resi-group/resi-group-server/src/main/java/com/epmet/modules/invitation/service/GroupInvitationService.java
@@ -106,7 +106,7 @@ public interface GroupInvitationService extends BaseService createGroupInvitation(CreateGroupInvitationFormDTO formDTO);
+ CreateGroupInvitationResultDTO createGroupInvitation(CreateGroupInvitationFormDTO formDTO);
/**
* @return com.epmet.commons.tools.utils.Result
@@ -115,7 +115,7 @@ public interface GroupInvitationService extends BaseService getLinkGroupInfo(LinkGroupInfoFormDTO formDTO);
+ LinkGroupInfoResultDTO getLinkGroupInfo(LinkGroupInfoFormDTO formDTO);
/**
* @return com.epmet.commons.tools.utils.Result
@@ -124,5 +124,5 @@ public interface GroupInvitationService extends BaseService createGroupInvitation(CreateGroupInvitationFormDTO formDTO) {
+ public CreateGroupInvitationResultDTO createGroupInvitation(CreateGroupInvitationFormDTO formDTO) {
//1、只有群主可以邀请新成员(这块界面限制死了,只有群主才能看到邀请新成员按钮)
//2、审核通过(讨论中)的群才可以分享邀请连接
ResiGroupDTO resiGroupDTO = resiGroupService.get(formDTO.getGroupId());
@@ -181,7 +178,7 @@ public class GroupInvitationServiceImpl extends BaseServiceImpl().ok(resultDTO);
+ return resultDTO;
}
/**
@@ -192,13 +189,9 @@ public class GroupInvitationServiceImpl extends BaseServiceImpl getLinkGroupInfo(LinkGroupInfoFormDTO formDTO) {
+ public LinkGroupInfoResultDTO getLinkGroupInfo(LinkGroupInfoFormDTO formDTO) {
//0、校验是否存在该邀请连接(判断是会否被删除连接、是否失效、群状态)
- Result validResult = this.checkLinkValid(formDTO.getInvitationId());
- if (!validResult.success()) {
- return new Result().error(validResult.getCode(), validResult.getMsg());
- }
- GroupInvitationDTO groupInvitationDTO=validResult.getData();
+ GroupInvitationDTO groupInvitationDTO=this.checkLinkValid(formDTO.getInvitationId());
LinkGroupInfoResultDTO linkGroupInfoResultDTO = new LinkGroupInfoResultDTO();
//1、查询是否在群内
ResiGroupMemberDTO resiGroupMemberDTO = resiGroupMemberDao.selectGroupMemberInfo(groupInvitationDTO.getResiGroupId(), formDTO.getUserId());
@@ -214,12 +207,12 @@ public class GroupInvitationServiceImpl extends BaseServiceImpl().ok(linkGroupInfoResultDTO);
+ return linkGroupInfoResultDTO;
}
/**
@@ -240,9 +233,9 @@ public class GroupInvitationServiceImpl extends BaseServiceImpl checkLinkValid(String invitationId) {
+ private GroupInvitationDTO checkLinkValid(String invitationId) {
//校验是否存在该邀请连接
GroupInvitationDTO groupInvitationDTO = this.get(invitationId);
//Date1.after(Date2),当Date1大于Date2时,返回TRUE,当小于等于时,返回false;
if (null == groupInvitationDTO) {
- return new Result().error(EpmetErrorCode.LOSE_EFFICACY.getCode(), EpmetErrorCode.LOSE_EFFICACY.getMsg());
+ logger.error(String.format("根据链接【%s】查看群邀请信息异常,错误码:%s,错误提示:%s",invitationId,EpmetErrorCode.LOSE_EFFICACY.getCode(), EpmetErrorCode.LOSE_EFFICACY.getMsg()));
+ throw new RenException(EpmetErrorCode.LOSE_EFFICACY.getCode());
}
if (null != groupInvitationDTO && !groupInvitationDTO.getValidEndTime().after(new Date())) {
- return new Result().error(EpmetErrorCode.LOSE_EFFICACY.getCode(), EpmetErrorCode.LOSE_EFFICACY.getMsg());
+ logger.error(String.format("根据链接【%s】查看群邀请信息异常,错误码:%s,错误提示:%s",invitationId,EpmetErrorCode.LOSE_EFFICACY.getCode(), EpmetErrorCode.LOSE_EFFICACY.getMsg()));
+ throw new RenException(EpmetErrorCode.LOSE_EFFICACY.getCode());
}
- ResiGroupEntity resiGroupEntity = resiGroupDao.selectById(groupInvitationDTO.getResiGroupId());
+ /*ResiGroupEntity resiGroupEntity = resiGroupDao.selectById(groupInvitationDTO.getResiGroupId());
if (null == resiGroupEntity) {
logger.info("组不存在");
//TODO
@@ -290,8 +285,8 @@ public class GroupInvitationServiceImpl extends BaseServiceImpl().ok(groupInvitationDTO);
+ }*/
+ return groupInvitationDTO;
}
/**
@@ -302,13 +297,9 @@ public class GroupInvitationServiceImpl extends BaseServiceImpl validResult = this.checkLinkValid(formDTO.getInvitationId());
- if (!validResult.success()) {
- return new Result().error(validResult.getCode(), validResult.getMsg());
- }
- GroupInvitationDTO groupInvitationDTO=validResult.getData();
+ GroupInvitationDTO groupInvitationDTO=this.checkLinkValid(formDTO.getInvitationId());
//2、校验是否已经注册居民
ResiGroupDTO resiGroupDTO = resiGroupService.get(groupInvitationDTO.getResiGroupId());
UserRoleDTO userRoleDTO=new UserRoleDTO();
@@ -319,7 +310,8 @@ public class GroupInvitationServiceImpl extends BaseServiceImpl> getGroupMemberList(@LoginUser TokenDto tokenDto,
@RequestBody GroupMemberListFormDTO groupMemberListFormDTO) {
+ groupMemberListFormDTO.setUserId(tokenDto.getUserId());
ValidatorUtils.validateEntity(groupMemberListFormDTO);
- return resiGroupMemberService.getGroupMemberList(groupMemberListFormDTO);
+ List list=resiGroupMemberService.getGroupMemberList(groupMemberListFormDTO);
+ return new Result>().ok(list);
}
/**
@@ -88,9 +91,11 @@ public class ResiGroupMemberController {
**/
@PostMapping("getapplyingmember")
public Result> getApplyingMember(@LoginUser TokenDto tokenDto,
- @RequestBody ApplyingMemberFormDTO applyingMemberFormDTO) {
+ @RequestBody ApplyingMemberFormDTO applyingMemberFormDTO) {
+ applyingMemberFormDTO.setUserId(tokenDto.getUserId());
ValidatorUtils.validateEntity(applyingMemberFormDTO);
- return resiGroupMemberService.getApplyingMember(applyingMemberFormDTO);
+ List list = resiGroupMemberService.getApplyingMember(applyingMemberFormDTO);
+ return new Result>().ok(list);
}
/**
@@ -107,7 +112,8 @@ public class ResiGroupMemberController {
agreeApplyFormDTO.setUserId(tokenDto.getUserId());
agreeApplyFormDTO.setApp(tokenDto.getApp());
ValidatorUtils.validateEntity(agreeApplyFormDTO);
- return resiGroupMemberService.agreeApply(agreeApplyFormDTO);
+ resiGroupMemberService.agreeApply(agreeApplyFormDTO);
+ return new Result();
}
/**
@@ -123,7 +129,8 @@ public class ResiGroupMemberController {
@RequestBody DisagreeApplyFormDTO disagreeApplyFormDTO) {
disagreeApplyFormDTO.setUserId(tokenDto.getUserId());
ValidatorUtils.validateEntity(disagreeApplyFormDTO);
- return resiGroupMemberService.disAgreeApply(disagreeApplyFormDTO);
+ resiGroupMemberService.disAgreeApply(disagreeApplyFormDTO);
+ return new Result();
}
/**
diff --git a/epmet-module/resi-group/resi-group-server/src/main/java/com/epmet/modules/member/service/ResiGroupMemberService.java b/epmet-module/resi-group/resi-group-server/src/main/java/com/epmet/modules/member/service/ResiGroupMemberService.java
index e0f9e4420e..0fea515cc6 100644
--- a/epmet-module/resi-group/resi-group-server/src/main/java/com/epmet/modules/member/service/ResiGroupMemberService.java
+++ b/epmet-module/resi-group/resi-group-server/src/main/java/com/epmet/modules/member/service/ResiGroupMemberService.java
@@ -114,16 +114,16 @@ public interface ResiGroupMemberService extends BaseService> getGroupMemberList(GroupMemberListFormDTO groupMemberListFormDTO);
+ List getGroupMemberList(GroupMemberListFormDTO groupMemberListFormDTO);
/**
* @return com.epmet.commons.tools.utils.Result>
@@ -132,7 +132,7 @@ public interface ResiGroupMemberService extends BaseService> getApplyingMember(ApplyingMemberFormDTO applyingMemberFormDTO);
+ List getApplyingMember(ApplyingMemberFormDTO applyingMemberFormDTO);
/**
* @param agreeApplyFormDTO
@@ -141,7 +141,7 @@ public interface ResiGroupMemberService extends BaseService> getGroupMemberList(GroupMemberListFormDTO groupMemberListFormDTO) {
+ public List getGroupMemberList(GroupMemberListFormDTO groupMemberListFormDTO) {
int pageIndex = (groupMemberListFormDTO.getPageNo() - NumConstant.ONE) * groupMemberListFormDTO.getPageSize();
groupMemberListFormDTO.setPageNo(pageIndex);
List list = baseDao.selectListGroupMember(groupMemberListFormDTO);
@@ -258,9 +259,11 @@ public class ResiGroupMemberServiceImpl extends BaseServiceImpl>().ok(list);
+ return list;
}
/**
@@ -271,7 +274,7 @@ public class ResiGroupMemberServiceImpl extends BaseServiceImpl> getApplyingMember(ApplyingMemberFormDTO applyingMemberFormDTO) {
+ public List getApplyingMember(ApplyingMemberFormDTO applyingMemberFormDTO) {
int pageIndex = (applyingMemberFormDTO.getPageNo() - NumConstant.ONE) * applyingMemberFormDTO.getPageSize();
applyingMemberFormDTO.setPageNo(pageIndex);
List list = baseDao.selectListApplyingMember(applyingMemberFormDTO);
@@ -293,10 +296,12 @@ public class ResiGroupMemberServiceImpl extends BaseServiceImpl>().ok(list);
+ return list;
}
/**
@@ -307,17 +312,17 @@ public class ResiGroupMemberServiceImpl extends BaseServiceImpl
4.0.0
- 0.3.4
+ 0.3.6
com.epmet
resi-guide
@@ -108,7 +108,7 @@
- dev-local
+ dev
true
@@ -128,7 +128,7 @@
6379
123456
- false
+ true
122.152.200.70:8848
fcd6fc8f-ca3a-4b01-8026-2b05cdc5976b
@@ -138,13 +138,13 @@
- dev
-
8091
- dev
+ test
@@ -167,35 +167,5 @@
-
- test
-
-
- 8091
- test
-
-
-
-
-
- epmet
- elink@833066
-
- 0
- 10.10.10.248
- 6379
- 123456
-
- true
- 122.152.200.70:8848
- fcd6fc8f-ca3a-4b01-8026-2b05cdc5976b
-
-
- false
-
-
-
diff --git a/epmet-module/resi-guide/resi-guide-server/src/main/java/com/epmet/aspect/RequestLogAspect.java b/epmet-module/resi-guide/resi-guide-server/src/main/java/com/epmet/aspect/RequestLogAspect.java
new file mode 100644
index 0000000000..49581cf63c
--- /dev/null
+++ b/epmet-module/resi-guide/resi-guide-server/src/main/java/com/epmet/aspect/RequestLogAspect.java
@@ -0,0 +1,40 @@
+package com.epmet.aspect;
+
+import com.epmet.commons.tools.aspect.BaseRequestLogAspect;
+import org.aspectj.lang.ProceedingJoinPoint;
+import org.aspectj.lang.annotation.Around;
+import org.aspectj.lang.annotation.Aspect;
+import org.springframework.core.annotation.Order;
+import org.springframework.stereotype.Component;
+import org.springframework.web.context.request.RequestAttributes;
+import org.springframework.web.context.request.RequestContextHolder;
+import org.springframework.web.context.request.ServletRequestAttributes;
+
+import javax.servlet.http.HttpServletRequest;
+
+/**
+ * 日志/异常处理切面实现,调用父类方法完成日志记录和异常处理。
+ */
+@Aspect
+@Component
+@Order(0)
+public class RequestLogAspect extends BaseRequestLogAspect {
+
+ @Override
+ @Around(value = "execution(* com.epmet.controller.*Controller*.*(..)) ")
+ public Object proceed(ProceedingJoinPoint point) throws Throwable {
+ return super.proceed(point, getRequest());
+ }
+
+ /**
+ * 获取Request对象
+ *
+ * @return
+ */
+ private HttpServletRequest getRequest() {
+ RequestAttributes ra = RequestContextHolder.getRequestAttributes();
+ ServletRequestAttributes sra = (ServletRequestAttributes) ra;
+ return sra.getRequest();
+ }
+
+}
diff --git a/epmet-module/resi-hall/resi-hall-server/Dockerfile b/epmet-module/resi-hall/resi-hall-server/Dockerfile
index a799989bd3..59cacab9be 100644
--- a/epmet-module/resi-hall/resi-hall-server/Dockerfile
+++ b/epmet-module/resi-hall/resi-hall-server/Dockerfile
@@ -8,4 +8,4 @@ COPY ./target/*.jar ./app.jar
EXPOSE 8100
-ENTRYPOINT ["java","-Xms32m","-Xmx250m","-jar","./app.jar"]
\ No newline at end of file
+ENTRYPOINT ["sh", "-c", "$RUN_INSTRUCT"]
\ No newline at end of file
diff --git a/epmet-module/resi-hall/resi-hall-server/docker-compose.yml b/epmet-module/resi-hall/resi-hall-server/deploy/docker-compose-dev.yml
similarity index 62%
rename from epmet-module/resi-hall/resi-hall-server/docker-compose.yml
rename to epmet-module/resi-hall/resi-hall-server/deploy/docker-compose-dev.yml
index 27f5503f0b..befeeecbad 100644
--- a/epmet-module/resi-hall/resi-hall-server/docker-compose.yml
+++ b/epmet-module/resi-hall/resi-hall-server/deploy/docker-compose-dev.yml
@@ -2,12 +2,14 @@ version: "3.7"
services:
resi-hall-server:
container_name: resi-hall-server-dev
- image: registry-vpc.cn-qingdao.aliyuncs.com/epmet-cloud-dev/resi-hall-server:0.3.0
+ image: 192.168.1.130:10080/epmet-cloud-dev/resi-hall-server:0.3.2
ports:
- "8100:8100"
network_mode: host # 使用现有网络
volumes:
- "/opt/epmet-cloud-logs/dev:/logs"
+ environment:
+ RUN_INSTRUCT: "java -Xms32m -Xmx200m -jar ./app.jar"
deploy:
resources:
limits:
diff --git a/epmet-module/resi-hall/resi-hall-server/deploy/docker-compose-test.yml b/epmet-module/resi-hall/resi-hall-server/deploy/docker-compose-test.yml
new file mode 100644
index 0000000000..d202cbe37e
--- /dev/null
+++ b/epmet-module/resi-hall/resi-hall-server/deploy/docker-compose-test.yml
@@ -0,0 +1,17 @@
+version: "3.7"
+services:
+ resi-hall-server:
+ container_name: resi-hall-server-test
+ image: registry-vpc.cn-qingdao.aliyuncs.com/epmet-cloud-release/resi-hall-server:0.3.1
+ ports:
+ - "8100:8100"
+ network_mode: host # 使用现有网络
+ volumes:
+ - "/opt/epmet-cloud-logs/test:/logs"
+ environment:
+ RUN_INSTRUCT: "java -Xms32m -Xmx200m -jar ./app.jar"
+ deploy:
+ resources:
+ limits:
+ cpus: '0.1'
+ memory: 300M
\ No newline at end of file
diff --git a/epmet-module/resi-hall/resi-hall-server/pom.xml b/epmet-module/resi-hall/resi-hall-server/pom.xml
index 4c3d9cdefc..132ecfa98c 100644
--- a/epmet-module/resi-hall/resi-hall-server/pom.xml
+++ b/epmet-module/resi-hall/resi-hall-server/pom.xml
@@ -3,7 +3,7 @@
xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
4.0.0
- 0.3.0
+ 0.3.2
resi-hall
com.epmet
@@ -45,6 +45,12 @@
feign-httpclient
10.3.0
+
+ com.epmet
+ gov-issue-client
+ 2.0.0
+ compile
+
@@ -72,7 +78,7 @@
- dev-local
+ dev
true
@@ -86,7 +92,7 @@
6379
123456
- false
+ true
122.152.200.70:8848
fcd6fc8f-ca3a-4b01-8026-2b05cdc5976b
@@ -96,13 +102,13 @@
- dev
+ test
8100
- dev
+ test
0
@@ -119,29 +125,5 @@
-
- test
-
-
- 8100
- test
-
-
- 0
- 10.10.10.248
- 6379
- 123456
-
- true
- 122.152.200.70:8848
- fcd6fc8f-ca3a-4b01-8026-2b05cdc5976b
-
-
- false
-
-
-
\ No newline at end of file
diff --git a/epmet-module/resi-hall/resi-hall-server/src/main/java/com/epmet/aspect/RequestLogAspect.java b/epmet-module/resi-hall/resi-hall-server/src/main/java/com/epmet/aspect/RequestLogAspect.java
new file mode 100644
index 0000000000..49581cf63c
--- /dev/null
+++ b/epmet-module/resi-hall/resi-hall-server/src/main/java/com/epmet/aspect/RequestLogAspect.java
@@ -0,0 +1,40 @@
+package com.epmet.aspect;
+
+import com.epmet.commons.tools.aspect.BaseRequestLogAspect;
+import org.aspectj.lang.ProceedingJoinPoint;
+import org.aspectj.lang.annotation.Around;
+import org.aspectj.lang.annotation.Aspect;
+import org.springframework.core.annotation.Order;
+import org.springframework.stereotype.Component;
+import org.springframework.web.context.request.RequestAttributes;
+import org.springframework.web.context.request.RequestContextHolder;
+import org.springframework.web.context.request.ServletRequestAttributes;
+
+import javax.servlet.http.HttpServletRequest;
+
+/**
+ * 日志/异常处理切面实现,调用父类方法完成日志记录和异常处理。
+ */
+@Aspect
+@Component
+@Order(0)
+public class RequestLogAspect extends BaseRequestLogAspect {
+
+ @Override
+ @Around(value = "execution(* com.epmet.controller.*Controller*.*(..)) ")
+ public Object proceed(ProceedingJoinPoint point) throws Throwable {
+ return super.proceed(point, getRequest());
+ }
+
+ /**
+ * 获取Request对象
+ *
+ * @return
+ */
+ private HttpServletRequest getRequest() {
+ RequestAttributes ra = RequestContextHolder.getRequestAttributes();
+ ServletRequestAttributes sra = (ServletRequestAttributes) ra;
+ return sra.getRequest();
+ }
+
+}
diff --git a/epmet-module/resi-hall/resi-hall-server/src/main/java/com/epmet/controller/IssueController.java b/epmet-module/resi-hall/resi-hall-server/src/main/java/com/epmet/controller/IssueController.java
index 4ae0a0952e..cd5191d7ba 100644
--- a/epmet-module/resi-hall/resi-hall-server/src/main/java/com/epmet/controller/IssueController.java
+++ b/epmet-module/resi-hall/resi-hall-server/src/main/java/com/epmet/controller/IssueController.java
@@ -161,6 +161,17 @@ public class IssueController {
return new Result>().ok(issueService.projectEvaluationList(formDTO));
}
+ /**
+ * @Description 满意度评价列表——已转项目
+ * @param formDTO
+ * @author zxc
+ */
+ @PostMapping("shiftproject")
+ @RequirePermission(requirePermission = RequirePermissionEnum.WORK_GRASSROOTS_ISSUE_SHIFT_PROJECT)
+ public Result> getShiftProjectList(@RequestBody ShiftProjectListFromDTO formDTO){
+ return new Result>().ok(issueService.getShiftProjectList(formDTO));
+ }
+
/**
* @Description 获取表决中议题列表
* @param issueListFormDTO
diff --git a/epmet-module/resi-hall/resi-hall-server/src/main/java/com/epmet/feign/EpmetUserFeignClient.java b/epmet-module/resi-hall/resi-hall-server/src/main/java/com/epmet/feign/EpmetUserFeignClient.java
index e65812e3a4..2c7a8cb9b4 100644
--- a/epmet-module/resi-hall/resi-hall-server/src/main/java/com/epmet/feign/EpmetUserFeignClient.java
+++ b/epmet-module/resi-hall/resi-hall-server/src/main/java/com/epmet/feign/EpmetUserFeignClient.java
@@ -18,8 +18,8 @@ import java.util.List;
* @dscription
* @date 2020/5/11 10:32
*/
-@FeignClient(name = ServiceConstant.EPMET_USER_SERVER, fallback = EpmetUserFeignClientFallBack.class,url = "localhost:8087")
-//@FeignClient(name = ServiceConstant.EPMET_USER_SERVER, fallback = EpmetUserFeignClientFallBack.class)
+//@FeignClient(name = ServiceConstant.EPMET_USER_SERVER, fallback = EpmetUserFeignClientFallBack.class,url = "localhost:8087")
+@FeignClient(name = ServiceConstant.EPMET_USER_SERVER, fallback = EpmetUserFeignClientFallBack.class)
public interface EpmetUserFeignClient {
/**
diff --git a/epmet-module/resi-hall/resi-hall-server/src/main/java/com/epmet/feign/GovIssueFeignClient.java b/epmet-module/resi-hall/resi-hall-server/src/main/java/com/epmet/feign/GovIssueFeignClient.java
index 0ac6037189..b4903c1d10 100644
--- a/epmet-module/resi-hall/resi-hall-server/src/main/java/com/epmet/feign/GovIssueFeignClient.java
+++ b/epmet-module/resi-hall/resi-hall-server/src/main/java/com/epmet/feign/GovIssueFeignClient.java
@@ -1,8 +1,6 @@
package com.epmet.feign;
-import com.epmet.commons.tools.annotation.LoginUser;
import com.epmet.commons.tools.constant.ServiceConstant;
-import com.epmet.commons.tools.security.dto.TokenDto;
import com.epmet.commons.tools.utils.Result;
import com.epmet.dto.form.*;
import com.epmet.dto.result.*;
@@ -78,6 +76,16 @@ public interface GovIssueFeignClient {
@PostMapping("/gov/issue/issuesatisfactiondetail/evaluationlist")
Result> evaluationList(@RequestBody EvaluationListFormDTO formDTO);
+ /**
+ * 已转项目列表
+ * @author zhaoqifeng
+ * @date 2020/5/13 16:22
+ * @param fromDTO 参数
+ * @return java.util.List
+ */
+ @PostMapping("/gov/issue/issue/shiftprojectlist")
+ Result> getShiftProjectList(@RequestBody ShiftProjectListFromDTO fromDTO);
+
/**
* @Description 获取表决中议题列表
* @param issueListFormDTO
diff --git a/epmet-module/resi-hall/resi-hall-server/src/main/java/com/epmet/feign/fallback/GovIssueFeignClientFallBack.java b/epmet-module/resi-hall/resi-hall-server/src/main/java/com/epmet/feign/fallback/GovIssueFeignClientFallBack.java
index b7d6b4f6dc..84634ff843 100644
--- a/epmet-module/resi-hall/resi-hall-server/src/main/java/com/epmet/feign/fallback/GovIssueFeignClientFallBack.java
+++ b/epmet-module/resi-hall/resi-hall-server/src/main/java/com/epmet/feign/fallback/GovIssueFeignClientFallBack.java
@@ -1,7 +1,6 @@
package com.epmet.feign.fallback;
import com.epmet.commons.tools.constant.ServiceConstant;
-import com.epmet.commons.tools.security.dto.TokenDto;
import com.epmet.commons.tools.utils.ModuleUtils;
import com.epmet.commons.tools.utils.Result;
import com.epmet.dto.form.*;
@@ -53,6 +52,11 @@ public class GovIssueFeignClientFallBack implements GovIssueFeignClient {
return ModuleUtils.feignConError(ServiceConstant.GOV_ISSUE_SERVER, "evaluationList", formDTO);
}
+ @Override
+ public Result> getShiftProjectList(ShiftProjectListFromDTO fromDTO) {
+ return ModuleUtils.feignConError(ServiceConstant.GOV_ISSUE_SERVER, "getShiftProjectList", fromDTO);
+ }
+
@Override
public Result> votingList(CommonIssueListFormDTO issueListFormDTO) {
return ModuleUtils.feignConError(ServiceConstant.GOV_ISSUE_SERVER, "votingList", issueListFormDTO);
diff --git a/epmet-module/resi-hall/resi-hall-server/src/main/java/com/epmet/service/IssueService.java b/epmet-module/resi-hall/resi-hall-server/src/main/java/com/epmet/service/IssueService.java
index 7127ec9eee..156c51e375 100644
--- a/epmet-module/resi-hall/resi-hall-server/src/main/java/com/epmet/service/IssueService.java
+++ b/epmet-module/resi-hall/resi-hall-server/src/main/java/com/epmet/service/IssueService.java
@@ -95,4 +95,13 @@ public interface IssueService {
*/
List projectEvaluationList(ProjectEvaluationListFormDTO formDTO);
+ /**
+ * 已转项目列表
+ * @author zhaoqifeng
+ * @date 2020/5/14 14:11
+ * @param formDTO
+ * @return java.util.List
+ */
+ List getShiftProjectList(ShiftProjectListFromDTO formDTO);
+
}
diff --git a/epmet-module/resi-hall/resi-hall-server/src/main/java/com/epmet/service/impl/IssueServiceImpl.java b/epmet-module/resi-hall/resi-hall-server/src/main/java/com/epmet/service/impl/IssueServiceImpl.java
index e2baa08fd5..51fcfe5d68 100644
--- a/epmet-module/resi-hall/resi-hall-server/src/main/java/com/epmet/service/impl/IssueServiceImpl.java
+++ b/epmet-module/resi-hall/resi-hall-server/src/main/java/com/epmet/service/impl/IssueServiceImpl.java
@@ -39,8 +39,8 @@ public class IssueServiceImpl implements IssueService {
private GovProjectFeignClient govProjectFeignClient;
/**
- * @Description 议题详情
* @param issueDetail
+ * @Description 议题详情
* @author zxc
* @date 2020/5/11 10:04
*/
@@ -50,18 +50,18 @@ public class IssueServiceImpl implements IssueService {
//议题信息
Result issueResultDTOResult = govIssueFeignClient.detail(issueDetail);
IssueResultDTO issueResult = issueResultDTOResult.getData();
- if (issueResult==null){
+ if (issueResult == null) {
return issueDetailResult;
}
- BeanUtils.copyProperties(issueResult,issueDetailResult);
+ BeanUtils.copyProperties(issueResult, issueDetailResult);
//话题发起人
IssueInitiatorFormDTO initiatorFormDTO = new IssueInitiatorFormDTO();
initiatorFormDTO.setUserId(issueResult.getUserId());
if (!StringUtils.isBlank(issueResult.getUserId())) {
IssueInitiatorResultDTO initiatorResult = userFeignClient.selectIssueInitiator(initiatorFormDTO).getData();
- if (initiatorResult==null){
+ if (initiatorResult == null) {
issueDetailResult.setIssueInitiator("");
- }else {
+ } else {
issueDetailResult.setIssueInitiator(initiatorResult.getIssueInitiator());
}
}
@@ -70,9 +70,9 @@ public class IssueServiceImpl implements IssueService {
belongGridName.setGridId(issueResult.getGridId());
if (!StringUtils.isBlank(issueResult.getGridId())) {
BelongGridNameResultDTO belongGridNameResult = govOrgFeignClient.getGridNameByGridId(belongGridName).getData();
- if (belongGridNameResult==null){
+ if (belongGridNameResult == null) {
issueDetailResult.setBelongsGridName("");
- }else {
+ } else {
issueDetailResult.setBelongsGridName(belongGridNameResult.getBelongsGridName());
}
}
@@ -81,9 +81,9 @@ public class IssueServiceImpl implements IssueService {
topicInfoFormDTO.setTopicId(issueResult.getTopicId());
if (!StringUtils.isBlank(issueResult.getTopicId())) {
TopicInfoDTO topicInfoDTOResult = resiGroupFeignClient.selectDetail(topicInfoFormDTO).getData();
- if (topicInfoDTOResult==null){
+ if (topicInfoDTOResult == null) {
issueDetailResult.setTopicInfo(new TopicInfoDTO());
- }else {
+ } else {
issueDetailResult.setTopicInfo(topicInfoDTOResult);
}
}
@@ -91,8 +91,8 @@ public class IssueServiceImpl implements IssueService {
}
/**
- * @Description 议题表决折线图
* @param issueId
+ * @Description 议题表决折线图
* @author zxc
* @date 2020/5/12 8:49
*/
@@ -103,12 +103,12 @@ public class IssueServiceImpl implements IssueService {
}
/**
- * @Description 支持议题
* @param issueId
+ * @Description 支持议题
* @author zxc
*/
@Override
- public void support(TokenDto tokenDto,IssueIdFormDTO issueId) {
+ public void support(TokenDto tokenDto, IssueIdFormDTO issueId) {
VoteFormDTO voteFormDTO = new VoteFormDTO();
voteFormDTO.setAttitude("support");
voteFormDTO.setCreatedBy(tokenDto.getUserId());
@@ -117,12 +117,12 @@ public class IssueServiceImpl implements IssueService {
}
/**
- * @Description 反对议题
* @param issueId
+ * @Description 反对议题
* @author zxc
*/
@Override
- public void oppose(TokenDto tokenDto,IssueIdFormDTO issueId) {
+ public void oppose(TokenDto tokenDto, IssueIdFormDTO issueId) {
VoteFormDTO voteFormDTO = new VoteFormDTO();
voteFormDTO.setAttitude("opposition");
voteFormDTO.setCreatedBy(tokenDto.getUserId());
@@ -131,8 +131,8 @@ public class IssueServiceImpl implements IssueService {
}
/**
- * @Description 表决中议题详情——支持、反对数
* @param issueId
+ * @Description 表决中议题详情——支持、反对数
* @author zxc
*/
@Override
@@ -142,9 +142,9 @@ public class IssueServiceImpl implements IssueService {
}
/**
- * @Description 满意度评价初始化——已关闭
* @param tokenDto
* @param issueId
+ * @Description 满意度评价初始化——已关闭
* @author zxc
*/
@Override
@@ -157,9 +157,9 @@ public class IssueServiceImpl implements IssueService {
}
/**
- * @Description 满意度评价初始化——已转项目
* @param tokenDto
* @param projectId
+ * @Description 满意度评价初始化——已转项目
* @author zxc
*/
@Override
@@ -172,19 +172,19 @@ public class IssueServiceImpl implements IssueService {
}
/**
- * @Description 提交满意度评价——已关闭
* @param evaluateFormDTO
+ * @Description 提交满意度评价——已关闭
* @author zxc
*/
@Override
- public void evaluate(TokenDto tokenDto,EvaluateFormDTO evaluateFormDTO) {
+ public void evaluate(TokenDto tokenDto, EvaluateFormDTO evaluateFormDTO) {
evaluateFormDTO.setUserId(tokenDto.getUserId());
govIssueFeignClient.evaluate(evaluateFormDTO);
}
/**
- * @Description 提交满意度评价——已转项目
* @param projectEvaluateFormDTO
+ * @Description 提交满意度评价——已转项目
* @author zxc
*/
@Override
@@ -194,15 +194,15 @@ public class IssueServiceImpl implements IssueService {
}
/**
- * @Description 满意度评价列表——已关闭
* @param formDTO
+ * @Description 满意度评价列表——已关闭
* @author zxc
*/
@Override
public List evaluationList(EvaluationListFormDTO formDTO) {
Result> listResult = govIssueFeignClient.evaluationList(formDTO);
List data = listResult.getData();
- if (data.size()==NumConstant.ZERO||data==null){
+ if (data.size() == NumConstant.ZERO || data == null) {
return new ArrayList<>();
}
//获取头像和昵称 eg:山东路168号-周先生
@@ -224,14 +224,14 @@ public class IssueServiceImpl implements IssueService {
}
/**
- * @Description 满意度评价列表——已转项目
* @param formDTO
+ * @Description 满意度评价列表——已转项目
* @author zxc
*/
@Override
public List projectEvaluationList(ProjectEvaluationListFormDTO formDTO) {
List listResult = govProjectFeignClient.projectEvaluationList(formDTO).getData();
- if (listResult.size()==NumConstant.ZERO||listResult.equals(null)){
+ if (listResult.size() == NumConstant.ZERO || listResult.equals(null)) {
return new ArrayList<>();
}
//获取头像和昵称 eg:山东路168号-周先生
@@ -251,4 +251,13 @@ public class IssueServiceImpl implements IssueService {
})).collect(Collectors.toList());
return resultList;
}
+
+ @Override
+ public List getShiftProjectList(ShiftProjectListFromDTO formDTO) {
+ List resultList = govIssueFeignClient.getShiftProjectList(formDTO).getData();
+ if (null == resultList || resultList.size() == NumConstant.ZERO) {
+ return new ArrayList<>();
+ }
+ return resultList;
+ }
}
diff --git a/epmet-module/resi-mine/resi-mine-server/Dockerfile b/epmet-module/resi-mine/resi-mine-server/Dockerfile
index e1bde0a979..1278acc61a 100644
--- a/epmet-module/resi-mine/resi-mine-server/Dockerfile
+++ b/epmet-module/resi-mine/resi-mine-server/Dockerfile
@@ -8,4 +8,4 @@ COPY ./target/*.jar ./app.jar
EXPOSE 8094
-ENTRYPOINT ["java","-Xms32m","-Xmx250m","-jar","./app.jar"]
\ No newline at end of file
+ENTRYPOINT ["sh", "-c", "$RUN_INSTRUCT"]
\ No newline at end of file
diff --git a/epmet-module/resi-mine/resi-mine-server/docker-compose.yml b/epmet-module/resi-mine/resi-mine-server/deploy/docker-compose-dev.yml
similarity index 62%
rename from epmet-module/resi-mine/resi-mine-server/docker-compose.yml
rename to epmet-module/resi-mine/resi-mine-server/deploy/docker-compose-dev.yml
index aa8bb80ca1..9d9246e7d1 100644
--- a/epmet-module/resi-mine/resi-mine-server/docker-compose.yml
+++ b/epmet-module/resi-mine/resi-mine-server/deploy/docker-compose-dev.yml
@@ -2,12 +2,14 @@ version: "3.7"
services:
resi-mine-server:
container_name: resi-mine-server-dev
- image: registry-vpc.cn-qingdao.aliyuncs.com/epmet-cloud-dev/resi-mine-server:0.3.7
+ image: 192.168.1.130:10080/epmet-cloud-dev/resi-mine-server:0.3.10
ports:
- "8094:8094"
network_mode: host # 使用现有网络
volumes:
- "/opt/epmet-cloud-logs/dev:/logs"
+ environment:
+ RUN_INSTRUCT: "java -Xms32m -Xmx200m -jar ./app.jar"
deploy:
resources:
limits:
diff --git a/epmet-module/resi-mine/resi-mine-server/deploy/docker-compose-test.yml b/epmet-module/resi-mine/resi-mine-server/deploy/docker-compose-test.yml
new file mode 100644
index 0000000000..683470a329
--- /dev/null
+++ b/epmet-module/resi-mine/resi-mine-server/deploy/docker-compose-test.yml
@@ -0,0 +1,17 @@
+version: "3.7"
+services:
+ resi-mine-server:
+ container_name: resi-mine-server-test
+ image: registry-vpc.cn-qingdao.aliyuncs.com/epmet-cloud-release/resi-mine-server:0.3.9
+ ports:
+ - "8094:8094"
+ network_mode: host # 使用现有网络
+ volumes:
+ - "/opt/epmet-cloud-logs/test:/logs"
+ environment:
+ RUN_INSTRUCT: "java -Xms32m -Xmx200m -jar ./app.jar"
+ deploy:
+ resources:
+ limits:
+ cpus: '0.1'
+ memory: 300M
\ No newline at end of file
diff --git a/epmet-module/resi-mine/resi-mine-server/pom.xml b/epmet-module/resi-mine/resi-mine-server/pom.xml
index 838b8c2c4f..c366ff0dae 100644
--- a/epmet-module/resi-mine/resi-mine-server/pom.xml
+++ b/epmet-module/resi-mine/resi-mine-server/pom.xml
@@ -2,7 +2,7 @@
4.0.0
- 0.3.7
+ 0.3.10
com.epmet
resi-mine
@@ -110,7 +110,7 @@
- dev-local
+ dev
true
@@ -130,7 +130,7 @@
6379
123456
- false
+ true
122.152.200.70:8848
fcd6fc8f-ca3a-4b01-8026-2b05cdc5976b
@@ -140,13 +140,13 @@
- dev
+ test
8094
- dev
+ test
@@ -169,35 +169,5 @@
-
- test
-
-
- 8094
- test
-
-
-
-
-
- epmet
- elink@833066
-
- 0
- 10.10.10.248
- 6379
- 123456
-
- true
- 122.152.200.70:8848
- fcd6fc8f-ca3a-4b01-8026-2b05cdc5976b
-
-
- false
-
-
-
diff --git a/epmet-module/resi-mine/resi-mine-server/src/main/java/com/epmet/aspect/RequestLogAspect.java b/epmet-module/resi-mine/resi-mine-server/src/main/java/com/epmet/aspect/RequestLogAspect.java
new file mode 100644
index 0000000000..49581cf63c
--- /dev/null
+++ b/epmet-module/resi-mine/resi-mine-server/src/main/java/com/epmet/aspect/RequestLogAspect.java
@@ -0,0 +1,40 @@
+package com.epmet.aspect;
+
+import com.epmet.commons.tools.aspect.BaseRequestLogAspect;
+import org.aspectj.lang.ProceedingJoinPoint;
+import org.aspectj.lang.annotation.Around;
+import org.aspectj.lang.annotation.Aspect;
+import org.springframework.core.annotation.Order;
+import org.springframework.stereotype.Component;
+import org.springframework.web.context.request.RequestAttributes;
+import org.springframework.web.context.request.RequestContextHolder;
+import org.springframework.web.context.request.ServletRequestAttributes;
+
+import javax.servlet.http.HttpServletRequest;
+
+/**
+ * 日志/异常处理切面实现,调用父类方法完成日志记录和异常处理。
+ */
+@Aspect
+@Component
+@Order(0)
+public class RequestLogAspect extends BaseRequestLogAspect {
+
+ @Override
+ @Around(value = "execution(* com.epmet.controller.*Controller*.*(..)) ")
+ public Object proceed(ProceedingJoinPoint point) throws Throwable {
+ return super.proceed(point, getRequest());
+ }
+
+ /**
+ * 获取Request对象
+ *
+ * @return
+ */
+ private HttpServletRequest getRequest() {
+ RequestAttributes ra = RequestContextHolder.getRequestAttributes();
+ ServletRequestAttributes sra = (ServletRequestAttributes) ra;
+ return sra.getRequest();
+ }
+
+}
diff --git a/epmet-module/resi-mine/resi-mine-server/src/main/java/com/epmet/modules/grid/controller/ResiMineGridController.java b/epmet-module/resi-mine/resi-mine-server/src/main/java/com/epmet/modules/grid/controller/ResiMineGridController.java
index 9a1d262509..bb6bcc34ae 100644
--- a/epmet-module/resi-mine/resi-mine-server/src/main/java/com/epmet/modules/grid/controller/ResiMineGridController.java
+++ b/epmet-module/resi-mine/resi-mine-server/src/main/java/com/epmet/modules/grid/controller/ResiMineGridController.java
@@ -34,7 +34,8 @@ public class ResiMineGridController {
**/
@GetMapping("getlatestgridinfo")
public Result getLatestGridInfo(@LoginUser TokenDto tokenDto){
- return resiMineGridService.getLatestGridInfo(tokenDto);
+ LatestGridInfoResultDTO latestGridInfoResultDTO=resiMineGridService.getLatestGridInfo(tokenDto);
+ return new Result().ok(latestGridInfoResultDTO);
}
/**
diff --git a/epmet-module/resi-mine/resi-mine-server/src/main/java/com/epmet/modules/grid/service/ResiMineGridService.java b/epmet-module/resi-mine/resi-mine-server/src/main/java/com/epmet/modules/grid/service/ResiMineGridService.java
index 73a98ad7a4..f4f398306c 100644
--- a/epmet-module/resi-mine/resi-mine-server/src/main/java/com/epmet/modules/grid/service/ResiMineGridService.java
+++ b/epmet-module/resi-mine/resi-mine-server/src/main/java/com/epmet/modules/grid/service/ResiMineGridService.java
@@ -20,7 +20,7 @@ public interface ResiMineGridService {
* @param tokenDto
* @return com.epmet.commons.tools.utils.Result
*/
- Result getLatestGridInfo(TokenDto tokenDto);
+ LatestGridInfoResultDTO getLatestGridInfo(TokenDto tokenDto);
/**
* @return
diff --git a/epmet-module/resi-mine/resi-mine-server/src/main/java/com/epmet/modules/grid/service/impl/ResiMineGridServiceImpl.java b/epmet-module/resi-mine/resi-mine-server/src/main/java/com/epmet/modules/grid/service/impl/ResiMineGridServiceImpl.java
index 2207f5c491..61f9e675b3 100644
--- a/epmet-module/resi-mine/resi-mine-server/src/main/java/com/epmet/modules/grid/service/impl/ResiMineGridServiceImpl.java
+++ b/epmet-module/resi-mine/resi-mine-server/src/main/java/com/epmet/modules/grid/service/impl/ResiMineGridServiceImpl.java
@@ -2,6 +2,7 @@ package com.epmet.modules.grid.service.impl;
import com.epmet.commons.tools.constant.AppClientConstant;
import com.epmet.commons.tools.constant.NumConstant;
+import com.epmet.commons.tools.constant.ServiceConstant;
import com.epmet.commons.tools.exception.RenException;
import com.epmet.commons.tools.security.dto.TokenDto;
import com.epmet.commons.tools.utils.Result;
@@ -41,16 +42,21 @@ public class ResiMineGridServiceImpl implements ResiMineGridService {
* @Date 2020/3/24 11:11
**/
@Override
- public Result getLatestGridInfo(TokenDto tokenDto) {
+ public LatestGridInfoResultDTO getLatestGridInfo(TokenDto tokenDto) {
if (null == tokenDto || StringUtils.isBlank(tokenDto.getUserId())) {
- logger.error(ModuleConstant.USER_NOT_NULL);
+ logger.error(String.format("居民端【%s】获取用户最近访问的网格失败:错误提示:%s",tokenDto.getUserId(),ModuleConstant.USER_NOT_NULL));
throw new RenException(ModuleConstant.USER_NOT_NULL);
}
if(!AppClientConstant.APP_RESI.equals(tokenDto.getApp())){
- logger.error(ModuleConstant.FOR_RESI_CALL);
+ logger.error(String.format("居民端【%s】获取用户最近访问的网格失败,错误提示:%s",tokenDto.getUserId(),ModuleConstant.FOR_RESI_CALL));
throw new RenException(ModuleConstant.FOR_RESI_CALL);
}
- return epmetUserFeignClient.getLatestGridInfoByUserId(tokenDto.getUserId());
+ Result userResult=epmetUserFeignClient.getLatestGridInfoByUserId(tokenDto.getUserId());
+ if(userResult.success()&&null!=userResult.getData()){
+ return userResult.getData();
+ }
+ logger.error(String.format("居民端用户【%s】获取用户最近访问网格失败,调用%s服务入参userId:%s,错误码:%s,错误提示:%s", tokenDto.getUserId(),ServiceConstant.EPMET_USER_SERVER,tokenDto.getUserId(),userResult.getCode(),userResult.getMsg()));
+ return null;
}
/**
diff --git a/epmet-module/resi-partymember/resi-partymember-server/Dockerfile b/epmet-module/resi-partymember/resi-partymember-server/Dockerfile
index 321b1bffb1..98190f2cd2 100644
--- a/epmet-module/resi-partymember/resi-partymember-server/Dockerfile
+++ b/epmet-module/resi-partymember/resi-partymember-server/Dockerfile
@@ -8,4 +8,4 @@ COPY ./target/*.jar ./app.jar
EXPOSE 8096
-ENTRYPOINT ["java","-Xms32m","-Xmx200m","-jar","./app.jar"]
\ No newline at end of file
+ENTRYPOINT ["sh", "-c", "$RUN_INSTRUCT"]
\ No newline at end of file
diff --git a/epmet-module/resi-partymember/resi-partymember-server/docker-compose.yml b/epmet-module/resi-partymember/resi-partymember-server/deploy/docker-compose-dev.yml
similarity index 62%
rename from epmet-module/resi-partymember/resi-partymember-server/docker-compose.yml
rename to epmet-module/resi-partymember/resi-partymember-server/deploy/docker-compose-dev.yml
index 1761a56387..51f180e0d3 100644
--- a/epmet-module/resi-partymember/resi-partymember-server/docker-compose.yml
+++ b/epmet-module/resi-partymember/resi-partymember-server/deploy/docker-compose-dev.yml
@@ -2,12 +2,14 @@ version: "3.7"
services:
resi-partymember-server:
container_name: resi-partymember-server-dev
- image: registry-vpc.cn-qingdao.aliyuncs.com/epmet-cloud-dev/resi-partymember-server:0.3.17
+ image: 192.168.1.130:10080/epmet-cloud-dev/resi-partymember-server:0.3.19
ports:
- "8096:8096"
network_mode: host # 使用现有网络
volumes:
- "/opt/epmet-cloud-logs/dev:/logs"
+ environment:
+ RUN_INSTRUCT: "java -Xms32m -Xmx200m -jar ./app.jar"
deploy:
resources:
limits:
diff --git a/epmet-module/resi-partymember/resi-partymember-server/deploy/docker-compose-test.yml b/epmet-module/resi-partymember/resi-partymember-server/deploy/docker-compose-test.yml
new file mode 100644
index 0000000000..7cb52e45d7
--- /dev/null
+++ b/epmet-module/resi-partymember/resi-partymember-server/deploy/docker-compose-test.yml
@@ -0,0 +1,17 @@
+version: "3.7"
+services:
+ resi-partymember-server:
+ container_name: resi-partymember-server-test
+ image: registry-vpc.cn-qingdao.aliyuncs.com/epmet-cloud-release/resi-partymember-server:0.3.19
+ ports:
+ - "8096:8096"
+ network_mode: host # 使用现有网络
+ volumes:
+ - "/opt/epmet-cloud-logs/test:/logs"
+ environment:
+ RUN_INSTRUCT: "java -Xms32m -Xmx200m -jar ./app.jar"
+ deploy:
+ resources:
+ limits:
+ cpus: '0.1'
+ memory: 250M
\ No newline at end of file
diff --git a/epmet-module/resi-partymember/resi-partymember-server/pom.xml b/epmet-module/resi-partymember/resi-partymember-server/pom.xml
index 88d6a9cee4..0c076571b1 100644
--- a/epmet-module/resi-partymember/resi-partymember-server/pom.xml
+++ b/epmet-module/resi-partymember/resi-partymember-server/pom.xml
@@ -2,7 +2,7 @@
4.0.0
- 0.3.17
+ 0.3.19
com.epmet
resi-partymember
@@ -120,7 +120,7 @@
- dev-local
+ dev
true
@@ -140,7 +140,7 @@
6379
123456
- false
+ true
122.152.200.70:8848
fcd6fc8f-ca3a-4b01-8026-2b05cdc5976b
@@ -150,13 +150,13 @@
- dev
+ test
8096
- dev
+ test
@@ -179,35 +179,5 @@
-
- test
-
-
- 8096
- test
-
-
-
-
-
- epmet
- elink@833066
-
- 0
- 10.10.10.248
- 6379
- 123456
-
- true
- 122.152.200.70:8848
- fcd6fc8f-ca3a-4b01-8026-2b05cdc5976b
-
-
- false
-
-
-
diff --git a/epmet-module/resi-partymember/resi-partymember-server/src/main/java/com/epmet/aspect/RequestLogAspect.java b/epmet-module/resi-partymember/resi-partymember-server/src/main/java/com/epmet/aspect/RequestLogAspect.java
new file mode 100644
index 0000000000..49581cf63c
--- /dev/null
+++ b/epmet-module/resi-partymember/resi-partymember-server/src/main/java/com/epmet/aspect/RequestLogAspect.java
@@ -0,0 +1,40 @@
+package com.epmet.aspect;
+
+import com.epmet.commons.tools.aspect.BaseRequestLogAspect;
+import org.aspectj.lang.ProceedingJoinPoint;
+import org.aspectj.lang.annotation.Around;
+import org.aspectj.lang.annotation.Aspect;
+import org.springframework.core.annotation.Order;
+import org.springframework.stereotype.Component;
+import org.springframework.web.context.request.RequestAttributes;
+import org.springframework.web.context.request.RequestContextHolder;
+import org.springframework.web.context.request.ServletRequestAttributes;
+
+import javax.servlet.http.HttpServletRequest;
+
+/**
+ * 日志/异常处理切面实现,调用父类方法完成日志记录和异常处理。
+ */
+@Aspect
+@Component
+@Order(0)
+public class RequestLogAspect extends BaseRequestLogAspect {
+
+ @Override
+ @Around(value = "execution(* com.epmet.controller.*Controller*.*(..)) ")
+ public Object proceed(ProceedingJoinPoint point) throws Throwable {
+ return super.proceed(point, getRequest());
+ }
+
+ /**
+ * 获取Request对象
+ *
+ * @return
+ */
+ private HttpServletRequest getRequest() {
+ RequestAttributes ra = RequestContextHolder.getRequestAttributes();
+ ServletRequestAttributes sra = (ServletRequestAttributes) ra;
+ return sra.getRequest();
+ }
+
+}
diff --git a/epmet-user/epmet-user-server/Dockerfile b/epmet-user/epmet-user-server/Dockerfile
index e55cc4a531..2495f36a46 100644
--- a/epmet-user/epmet-user-server/Dockerfile
+++ b/epmet-user/epmet-user-server/Dockerfile
@@ -8,4 +8,4 @@ COPY ./target/*.jar ./app.jar
EXPOSE 8087
-ENTRYPOINT ["java","-Xms32m","-Xmx250m","-jar","./app.jar"]
\ No newline at end of file
+ENTRYPOINT ["sh", "-c", "$RUN_INSTRUCT"]
\ No newline at end of file
diff --git a/epmet-user/epmet-user-server/docker-compose.yml b/epmet-user/epmet-user-server/deploy/docker-compose-dev.yml
similarity index 63%
rename from epmet-user/epmet-user-server/docker-compose.yml
rename to epmet-user/epmet-user-server/deploy/docker-compose-dev.yml
index 0bb7fd6a21..6f9f48020d 100644
--- a/epmet-user/epmet-user-server/docker-compose.yml
+++ b/epmet-user/epmet-user-server/deploy/docker-compose-dev.yml
@@ -2,12 +2,14 @@ version: "3.7"
services:
epmet-user-server:
container_name: epmet-user-server-dev
- image: registry-vpc.cn-qingdao.aliyuncs.com/epmet-cloud-dev/epmet-user-server:0.3.25
+ image: 192.168.1.130:10080/epmet-cloud-dev/epmet-user-server:0.3.28
ports:
- "8087:8087"
network_mode: host # 不会创建新的网络
volumes:
- "/opt/epmet-cloud-logs/dev:/logs"
+ environment:
+ RUN_INSTRUCT: "java -Xms32m -Xmx200m -jar ./app.jar"
deploy:
resources:
limits:
diff --git a/epmet-user/epmet-user-server/deploy/docker-compose-test.yml b/epmet-user/epmet-user-server/deploy/docker-compose-test.yml
new file mode 100644
index 0000000000..68fc10a166
--- /dev/null
+++ b/epmet-user/epmet-user-server/deploy/docker-compose-test.yml
@@ -0,0 +1,17 @@
+version: "3.7"
+services:
+ epmet-user-server:
+ container_name: epmet-user-server-test
+ image: registry-vpc.cn-qingdao.aliyuncs.com/epmet-cloud-release/epmet-user-server:0.3.28
+ ports:
+ - "8087:8087"
+ network_mode: host # 不会创建新的网络
+ volumes:
+ - "/opt/epmet-cloud-logs/test:/logs"
+ environment:
+ RUN_INSTRUCT: "java -Xms32m -Xmx200m -jar ./app.jar"
+ deploy:
+ resources:
+ limits:
+ cpus: '0.1'
+ memory: 300M
\ No newline at end of file
diff --git a/epmet-user/epmet-user-server/pom.xml b/epmet-user/epmet-user-server/pom.xml
index b4cfaa0275..db9737f45c 100644
--- a/epmet-user/epmet-user-server/pom.xml
+++ b/epmet-user/epmet-user-server/pom.xml
@@ -2,7 +2,7 @@
4.0.0
- 0.3.25
+ 0.3.28
com.epmet
epmet-user
@@ -105,7 +105,7 @@
- dev-local
+ dev
true
@@ -125,7 +125,7 @@
6379
123456
- false
+ true
122.152.200.70:8848
fcd6fc8f-ca3a-4b01-8026-2b05cdc5976b
@@ -135,13 +135,13 @@
- dev
-
8087
- dev
+ test
@@ -164,35 +164,5 @@
-
- test
-
-
- 8087
- test
-
-
-
-
-
- epmet
- elink@833066
-
- 0
- 10.10.10.248
- 6379
- 123456
-
- true
- 122.152.200.70:8848
- fcd6fc8f-ca3a-4b01-8026-2b05cdc5976b
-
-
- false
-
-
-
diff --git a/epmet-user/epmet-user-server/src/main/java/com/epmet/aspect/RequestLogAspect.java b/epmet-user/epmet-user-server/src/main/java/com/epmet/aspect/RequestLogAspect.java
new file mode 100644
index 0000000000..49581cf63c
--- /dev/null
+++ b/epmet-user/epmet-user-server/src/main/java/com/epmet/aspect/RequestLogAspect.java
@@ -0,0 +1,40 @@
+package com.epmet.aspect;
+
+import com.epmet.commons.tools.aspect.BaseRequestLogAspect;
+import org.aspectj.lang.ProceedingJoinPoint;
+import org.aspectj.lang.annotation.Around;
+import org.aspectj.lang.annotation.Aspect;
+import org.springframework.core.annotation.Order;
+import org.springframework.stereotype.Component;
+import org.springframework.web.context.request.RequestAttributes;
+import org.springframework.web.context.request.RequestContextHolder;
+import org.springframework.web.context.request.ServletRequestAttributes;
+
+import javax.servlet.http.HttpServletRequest;
+
+/**
+ * 日志/异常处理切面实现,调用父类方法完成日志记录和异常处理。
+ */
+@Aspect
+@Component
+@Order(0)
+public class RequestLogAspect extends BaseRequestLogAspect {
+
+ @Override
+ @Around(value = "execution(* com.epmet.controller.*Controller*.*(..)) ")
+ public Object proceed(ProceedingJoinPoint point) throws Throwable {
+ return super.proceed(point, getRequest());
+ }
+
+ /**
+ * 获取Request对象
+ *
+ * @return
+ */
+ private HttpServletRequest getRequest() {
+ RequestAttributes ra = RequestContextHolder.getRequestAttributes();
+ ServletRequestAttributes sra = (ServletRequestAttributes) ra;
+ return sra.getRequest();
+ }
+
+}