diff --git a/epmet-commons/epmet-commons-tools/src/main/java/com/epmet/commons/tools/exception/EpmetErrorCode.java b/epmet-commons/epmet-commons-tools/src/main/java/com/epmet/commons/tools/exception/EpmetErrorCode.java
index 3ec318507f..aa74cd8e2a 100644
--- a/epmet-commons/epmet-commons-tools/src/main/java/com/epmet/commons/tools/exception/EpmetErrorCode.java
+++ b/epmet-commons/epmet-commons-tools/src/main/java/com/epmet/commons/tools/exception/EpmetErrorCode.java
@@ -107,6 +107,7 @@ public enum EpmetErrorCode {
REPLY_INFO_CONTENT_NOT_NULL(8610,"回复内容不能为空"),
PLEASE_CHOOSE_MEMBER(8611,"请选择成员"),
INFO_GROUP_NAME_EXISTS(8612,"名称已存在"),
+ INFO_REPLY_CONTENT_LENGTH_LIMIT(8613,"回复内容最多输入500字"),
// 爱心互助 居民端
NOT_IN_THE_SIGN_IN_RANGE(8510, "您还未进入指定的签到范围~"),
diff --git a/epmet-gateway/pom.xml b/epmet-gateway/pom.xml
index dc71150423..1e9334b0b0 100644
--- a/epmet-gateway/pom.xml
+++ b/epmet-gateway/pom.xml
@@ -299,7 +299,7 @@
lb://resi-mine-server
-
+
lb://resi-group-server
diff --git a/epmet-module/data-aggregator/data-aggregator-client/src/main/java/com/epmet/dataaggre/dto/message/result/InfoDetailResDTO.java b/epmet-module/data-aggregator/data-aggregator-client/src/main/java/com/epmet/dataaggre/dto/message/result/InfoDetailResDTO.java
index d3b9f34c96..1dc61d381d 100644
--- a/epmet-module/data-aggregator/data-aggregator-client/src/main/java/com/epmet/dataaggre/dto/message/result/InfoDetailResDTO.java
+++ b/epmet-module/data-aggregator/data-aggregator-client/src/main/java/com/epmet/dataaggre/dto/message/result/InfoDetailResDTO.java
@@ -35,7 +35,7 @@ public class InfoDetailResDTO implements Serializable {
/**
* 发布人2级组织名
*/
- private String publishOrgName;
+ private String publishStaffOrgName;
/**
* 发布人性别
diff --git a/epmet-module/data-aggregator/data-aggregator-client/src/main/java/com/epmet/dataaggre/dto/message/result/MyInfoGroupResultDTO.java b/epmet-module/data-aggregator/data-aggregator-client/src/main/java/com/epmet/dataaggre/dto/message/result/MyInfoGroupResultDTO.java
index 4e4c89b2d0..302ab42e37 100644
--- a/epmet-module/data-aggregator/data-aggregator-client/src/main/java/com/epmet/dataaggre/dto/message/result/MyInfoGroupResultDTO.java
+++ b/epmet-module/data-aggregator/data-aggregator-client/src/main/java/com/epmet/dataaggre/dto/message/result/MyInfoGroupResultDTO.java
@@ -16,7 +16,7 @@ public class MyInfoGroupResultDTO implements Serializable {
private static final long serialVersionUID = 3621868560778309056L;
private String receiverGroupId;
private String name;
- private Integer totalMem;
+ private Integer staffNum;
@JsonIgnore
private List staffIdList;
private List staffNameList;
diff --git a/epmet-module/data-aggregator/data-aggregator-client/src/main/java/com/epmet/dataaggre/dto/message/result/MySentResDTO.java b/epmet-module/data-aggregator/data-aggregator-client/src/main/java/com/epmet/dataaggre/dto/message/result/MySentResDTO.java
index dbb72ca045..7459b2ace5 100644
--- a/epmet-module/data-aggregator/data-aggregator-client/src/main/java/com/epmet/dataaggre/dto/message/result/MySentResDTO.java
+++ b/epmet-module/data-aggregator/data-aggregator-client/src/main/java/com/epmet/dataaggre/dto/message/result/MySentResDTO.java
@@ -23,6 +23,7 @@ public class MySentResDTO implements Serializable {
private Integer totalReceiver;
private Integer readTotal;
private String firstAttId;
+ private Integer unReadReplyNum;
/**
* 附件列表 列表默认返回一个
*/
diff --git a/epmet-module/data-aggregator/data-aggregator-server/src/main/java/com/epmet/dataaggre/service/epmetmessage/impl/EpmetMessageServiceImpl.java b/epmet-module/data-aggregator/data-aggregator-server/src/main/java/com/epmet/dataaggre/service/epmetmessage/impl/EpmetMessageServiceImpl.java
index 6f66a145a5..4f7c8b3117 100644
--- a/epmet-module/data-aggregator/data-aggregator-server/src/main/java/com/epmet/dataaggre/service/epmetmessage/impl/EpmetMessageServiceImpl.java
+++ b/epmet-module/data-aggregator/data-aggregator-server/src/main/java/com/epmet/dataaggre/service/epmetmessage/impl/EpmetMessageServiceImpl.java
@@ -79,10 +79,13 @@ public class EpmetMessageServiceImpl implements EpmetMessageService {
dto.setStaffId(item.getStaffId());
dto.setReadFlag(item.getReadFlag());
CustomerStaffInfoCacheResult staffInfoCache = CustomerStaffRedis.getStaffInfo(item.getCustomerId(), item.getStaffId());
- dto.setStaffName(staffInfoCache.getRealName());
- dto.setGender(staffInfoCache.getGender());
- dto.setHeadPhoto(staffInfoCache.getHeadPhoto());
- dto.setOrgName(staffInfoCache.getTwoOrgName());
+ if (null != staffInfoCache) {
+ dto.setStaffName(staffInfoCache.getRealName());
+ dto.setGender(staffInfoCache.getGender());
+ dto.setHeadPhoto(staffInfoCache.getHeadPhoto());
+ dto.setOrgName(staffInfoCache.getTwoOrgName());
+ }
+
return dto;
}).collect(Collectors.toList());
result.setDataList(dataList);
@@ -258,7 +261,7 @@ public class EpmetMessageServiceImpl implements EpmetMessageService {
if(StringUtils.isNotBlank(resDTO.getPublishStaffId())){
CustomerStaffInfoCacheResult publisher = CustomerStaffRedis.getStaffInfo(infoIdDTO.getCustomerId(), resDTO.getPublishStaffId());
resDTO.setHeadPhoto(StringUtils.isNotBlank(publisher.getHeadPhoto()) ? publisher.getHeadPhoto() : StrConstant.EPMETY_STR);
- resDTO.setPublishOrgName(publisher.getTwoOrgName());
+ resDTO.setPublishStaffOrgName(publisher.getTwoOrgName());
resDTO.setPublishStaffGender(publisher.getGender().toString());
resDTO.setPublishStaffName(publisher.getRealName());
}
diff --git a/epmet-module/data-aggregator/data-aggregator-server/src/main/java/com/epmet/dataaggre/service/epmetuser/impl/EpmetUserServiceImpl.java b/epmet-module/data-aggregator/data-aggregator-server/src/main/java/com/epmet/dataaggre/service/epmetuser/impl/EpmetUserServiceImpl.java
index 8806232b47..84cc6ea127 100644
--- a/epmet-module/data-aggregator/data-aggregator-server/src/main/java/com/epmet/dataaggre/service/epmetuser/impl/EpmetUserServiceImpl.java
+++ b/epmet-module/data-aggregator/data-aggregator-server/src/main/java/com/epmet/dataaggre/service/epmetuser/impl/EpmetUserServiceImpl.java
@@ -483,9 +483,12 @@ public class EpmetUserServiceImpl implements EpmetUserService {
}
return staffRoleList.stream().map(item -> {
RoleUsersResultDTO dto = new RoleUsersResultDTO();
- dto.setStaffId(item.getStaffId());
//从redis获取用户信息
CustomerStaffInfoCacheResult staffInfoCache = CustomerStaffRedis.getStaffInfo(item.getCustomerId(), item.getStaffId());
+ if (null == staffInfoCache) {
+ return null;
+ }
+ dto.setStaffId(item.getStaffId());
dto.setGender(staffInfoCache.getGender());
dto.setHeadPhoto(staffInfoCache.getHeadPhoto());
dto.setName(staffInfoCache.getRealName());
diff --git a/epmet-module/data-aggregator/data-aggregator-server/src/main/resources/mapper/epmetmessage/InfoProfileDao.xml b/epmet-module/data-aggregator/data-aggregator-server/src/main/resources/mapper/epmetmessage/InfoProfileDao.xml
index 3499ee3ff4..8c31bdcbb8 100644
--- a/epmet-module/data-aggregator/data-aggregator-server/src/main/resources/mapper/epmetmessage/InfoProfileDao.xml
+++ b/epmet-module/data-aggregator/data-aggregator-server/src/main/resources/mapper/epmetmessage/InfoProfileDao.xml
@@ -10,6 +10,7 @@
+
@@ -29,6 +30,7 @@
ip.total_receiver,
ip.read_total,
ip.first_att_id,
+ ip.UN_READ_REPLY_NUM,
ia.ATTACHMENT_NAME AS name,
ia.ATTACHMENT_FORMAT AS format,
ia.ATTACHMENT_TYPE AS type,
diff --git a/epmet-module/data-aggregator/data-aggregator-server/src/main/resources/mapper/epmetmessage/InfoReceiversDao.xml b/epmet-module/data-aggregator/data-aggregator-server/src/main/resources/mapper/epmetmessage/InfoReceiversDao.xml
index bea01703dc..083bcd133f 100644
--- a/epmet-module/data-aggregator/data-aggregator-server/src/main/resources/mapper/epmetmessage/InfoReceiversDao.xml
+++ b/epmet-module/data-aggregator/data-aggregator-server/src/main/resources/mapper/epmetmessage/InfoReceiversDao.xml
@@ -6,7 +6,7 @@
-
+
@@ -16,14 +16,14 @@
SELECT
irg.ID as receiverGroupId,
irg.`NAME` as name,
- ( SELECT count( igr.id ) FROM info_group_receivers igr WHERE igr.DEL_FLAG = '0' AND igr.info_receiver_group_id = irg.id ) AS totalMem,
+ ( SELECT count( igr.id ) FROM info_group_receivers igr WHERE igr.DEL_FLAG = '0' AND igr.info_receiver_group_id = irg.id ) AS staffNum,
igr.STAFF_ID as staffId
FROM
info_receiver_group irg
left join info_group_receivers igr
on(irg.id=igr.info_receiver_group_id and igr.DEL_FLAG='0')
WHERE
-
+ irg.del_flag='0'
AND irg.CREATE_STAFF_ID = #{staffId}
AND irg.CUSTOMER_ID = #{customerId}
diff --git a/epmet-module/data-aggregator/data-aggregator-server/src/main/resources/mapper/govorg/CustomerStaffAgencyDao.xml b/epmet-module/data-aggregator/data-aggregator-server/src/main/resources/mapper/govorg/CustomerStaffAgencyDao.xml
index 29da78941d..e41789ecf6 100644
--- a/epmet-module/data-aggregator/data-aggregator-server/src/main/resources/mapper/govorg/CustomerStaffAgencyDao.xml
+++ b/epmet-module/data-aggregator/data-aggregator-server/src/main/resources/mapper/govorg/CustomerStaffAgencyDao.xml
@@ -100,7 +100,7 @@
customer_agency ca
LEFT JOIN (
SELECT
- a.PIDS,
+ CONCAT( a.PIDS,':',a.ID) AS PIDS,
b.USER_ID
FROM
customer_agency a
diff --git a/epmet-module/data-report/data-report-client/src/main/java/com/epmet/user/result/GridManagerListYuShanResultDTO.java b/epmet-module/data-report/data-report-client/src/main/java/com/epmet/user/result/GridManagerListYuShanResultDTO.java
new file mode 100644
index 0000000000..51ab6b798a
--- /dev/null
+++ b/epmet-module/data-report/data-report-client/src/main/java/com/epmet/user/result/GridManagerListYuShanResultDTO.java
@@ -0,0 +1,94 @@
+package com.epmet.user.result;
+
+import com.epmet.commons.tools.constant.NumConstant;
+import com.fasterxml.jackson.annotation.JsonIgnore;
+import lombok.Data;
+
+import java.io.Serializable;
+
+/**
+ * @Author zxc
+ * @DateTime 2021/6/7 2:57 下午
+ * @DESC
+ */
+@Data
+public class GridManagerListYuShanResultDTO implements Serializable {
+
+ private static final long serialVersionUID = -2770911125810373090L;
+
+ /**
+ * 工作人员id
+ */
+ private String staffId;
+
+ /**
+ * 工作人员手机号
+ */
+ private String mobile;
+
+ /**
+ * 经度
+ */
+ private String longitude;
+
+ /**
+ * 纬度
+ */
+ private String latitude;
+
+ /**
+ * 网格ID
+ */
+ private String gridId;
+
+ /**
+ * 正在巡查:patrolling;否则返回空字符串
+ */
+ private String status;
+
+ /**
+ * 网格名称,最多显示上两级
+ */
+ private String gridName;
+
+ /**
+ * 姓名
+ */
+ private String staffName;
+
+ /**
+ * 巡查时长
+ */
+ private Integer patrolDuration;
+
+ /**
+ * 巡查次数
+ */
+ private Integer patrolCount;
+
+ /**
+ * 中心点位
+ */
+ @JsonIgnore
+ private String centerMark;
+
+ /**
+ * 经纬度赋值状态
+ */
+ @JsonIgnore
+ private Boolean llStatus;
+
+ public GridManagerListYuShanResultDTO() {
+ this.staffId = "";
+ this.longitude = "";
+ this.latitude = "";
+ this.gridId = "";
+ this.status = "";
+ this.gridName = "";
+ this.staffName = "";
+ this.centerMark = "";
+ this.llStatus = false;
+ this.patrolDuration = NumConstant.ZERO;
+ this.patrolCount = NumConstant.ZERO;
+ }
+}
diff --git a/epmet-module/data-report/data-report-server/src/main/java/com/epmet/datareport/controller/user/StaffPatrolDetailController.java b/epmet-module/data-report/data-report-server/src/main/java/com/epmet/datareport/controller/user/StaffPatrolDetailController.java
index e20e1e7d5c..5901ada344 100644
--- a/epmet-module/data-report/data-report-server/src/main/java/com/epmet/datareport/controller/user/StaffPatrolDetailController.java
+++ b/epmet-module/data-report/data-report-server/src/main/java/com/epmet/datareport/controller/user/StaffPatrolDetailController.java
@@ -11,6 +11,7 @@ import com.epmet.user.result.GridManagerListResultDTO;
import com.epmet.dto.result.PatrolTrackResultDTO;
import com.epmet.dto.result.RecordListResultDTO;
import com.epmet.dto.result.PatrolCountResultDTO;
+import com.epmet.user.result.GridManagerListYuShanResultDTO;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.web.bind.annotation.*;
@@ -77,4 +78,16 @@ public class StaffPatrolDetailController {
return new Result().ok(staffPatrolService.patrolCount(formDTO));
}
+ /**
+ * @Description 网格员分布-榆山
+ * @Param formDTO
+ * @author zxc
+ * @date 2021/8/25 3:00 下午
+ */
+ @PostMapping("gridmanagerlist-yushan")
+ public Result> gridManagerListYuShan(@RequestBody GridManagerListFormDTO formDTO){
+ ValidatorUtils.validateEntity(formDTO, GridManagerListFormDTO.GridManagerListForm.class);
+ return new Result>().ok(staffPatrolService.gridManagerListYuShan(formDTO));
+ }
+
}
diff --git a/epmet-module/data-report/data-report-server/src/main/java/com/epmet/datareport/service/user/StaffPatrolDetailService.java b/epmet-module/data-report/data-report-server/src/main/java/com/epmet/datareport/service/user/StaffPatrolDetailService.java
index 95fc1eb064..41c1e3278c 100644
--- a/epmet-module/data-report/data-report-server/src/main/java/com/epmet/datareport/service/user/StaffPatrolDetailService.java
+++ b/epmet-module/data-report/data-report-server/src/main/java/com/epmet/datareport/service/user/StaffPatrolDetailService.java
@@ -8,6 +8,7 @@ import com.epmet.user.result.GridManagerListResultDTO;
import com.epmet.dto.result.PatrolTrackResultDTO;
import com.epmet.dto.result.RecordListResultDTO;
import com.epmet.dto.result.PatrolCountResultDTO;
+import com.epmet.user.result.GridManagerListYuShanResultDTO;
import java.util.List;
@@ -27,6 +28,14 @@ public interface StaffPatrolDetailService{
*/
List gridManagerList(GridManagerListFormDTO formDTO);
+ /**
+ * @Description 网格员分布-榆山
+ * @Param formDTO
+ * @author zxc
+ * @date 2021/8/25 3:00 下午
+ */
+ List gridManagerListYuShan(GridManagerListFormDTO formDTO);
+
/**
* @Description 002、查看巡查记录
* @Param formDTO
diff --git a/epmet-module/data-report/data-report-server/src/main/java/com/epmet/datareport/service/user/impl/StaffPatrolDetailServiceImpl.java b/epmet-module/data-report/data-report-server/src/main/java/com/epmet/datareport/service/user/impl/StaffPatrolDetailServiceImpl.java
index 6f01a162ac..48a11334e2 100644
--- a/epmet-module/data-report/data-report-server/src/main/java/com/epmet/datareport/service/user/impl/StaffPatrolDetailServiceImpl.java
+++ b/epmet-module/data-report/data-report-server/src/main/java/com/epmet/datareport/service/user/impl/StaffPatrolDetailServiceImpl.java
@@ -19,6 +19,7 @@ import com.epmet.dto.form.RecordListFormDTO;
import com.epmet.dto.form.PatrolCountFormDTO;
import com.epmet.user.result.GridManagerListResultDTO;
import com.epmet.dto.result.PatrolCountResultDTO;
+import com.epmet.user.result.GridManagerListYuShanResultDTO;
import lombok.extern.slf4j.Slf4j;
import org.apache.commons.lang3.StringUtils;
import org.springframework.beans.factory.annotation.Autowired;
@@ -136,6 +137,34 @@ public class StaffPatrolDetailServiceImpl implements StaffPatrolDetailService {
return result;
}
+ /**
+ * @Description 网格员分布-榆山
+ * @Param formDTO
+ * @author zxc
+ * @date 2021/8/25 3:00 下午
+ */
+ @Override
+ public List gridManagerListYuShan(GridManagerListFormDTO formDTO) {
+ List resultTwo = this.gridManagerList(formDTO);
+ List result = ConvertUtils.sourceToTarget(resultTwo, GridManagerListYuShanResultDTO.class);
+ Result> listResult = epmetUserOpenFeignClient.patrolInfo(formDTO.getAgencyId());
+ if (!listResult.success()){
+ throw new RenException("查询巡查次数和时长失败");
+ }
+ List data = listResult.getData();
+ if (!CollectionUtils.isEmpty(data)){
+ result.forEach(r -> {
+ data.forEach(d -> {
+ if (r.getGridId().equals(d.getGridId()) && r.getStaffId().equals(d.getStaffId())){
+ r.setPatrolCount(d.getPatrolCount());
+ r.setPatrolDuration(d.getPatrolDuration());
+ }
+ });
+ });
+ }
+ return result;
+ }
+
/**
* @Description 根据中心点位截取经纬度
* @Param centMark
diff --git a/epmet-module/data-report/data-report-server/src/main/resources/mapper/screen/ScreenCustomerAgencyDao.xml b/epmet-module/data-report/data-report-server/src/main/resources/mapper/screen/ScreenCustomerAgencyDao.xml
index f0e65a8bd1..3e058e209a 100644
--- a/epmet-module/data-report/data-report-server/src/main/resources/mapper/screen/ScreenCustomerAgencyDao.xml
+++ b/epmet-module/data-report/data-report-server/src/main/resources/mapper/screen/ScreenCustomerAgencyDao.xml
@@ -341,7 +341,7 @@
AND cg.AREA_CODE LIKE CONCAT(#{areaCode},'%')
- AND cg.ALL_PARENT_IDS LIKE CONCAT(#{agencyId}, '%')
+ AND cg.ALL_PARENT_IDS LIKE CONCAT('%',#{agencyId}, '%')
diff --git a/epmet-module/data-statistical/data-statistical-server/src/main/java/com/epmet/aspect/RequestLogAspect.java b/epmet-module/data-statistical/data-statistical-server/src/main/java/com/epmet/aspect/RequestLogAspect.java
index 49581cf63c..be7ca7996f 100644
--- a/epmet-module/data-statistical/data-statistical-server/src/main/java/com/epmet/aspect/RequestLogAspect.java
+++ b/epmet-module/data-statistical/data-statistical-server/src/main/java/com/epmet/aspect/RequestLogAspect.java
@@ -21,7 +21,7 @@ import javax.servlet.http.HttpServletRequest;
public class RequestLogAspect extends BaseRequestLogAspect {
@Override
- @Around(value = "execution(* com.epmet.controller.*Controller*.*(..)) ")
+ @Around(value = "execution(* com.epmet.controller..*Controller*.*(..)) ")
public Object proceed(ProceedingJoinPoint point) throws Throwable {
return super.proceed(point, getRequest());
}
diff --git a/epmet-module/data-statistical/data-statistical-server/src/main/java/com/epmet/mq/ProjectChangedCustomListener.java b/epmet-module/data-statistical/data-statistical-server/src/main/java/com/epmet/mq/ProjectChangedCustomListener.java
index 852a5aec52..f62cfe09f8 100644
--- a/epmet-module/data-statistical/data-statistical-server/src/main/java/com/epmet/mq/ProjectChangedCustomListener.java
+++ b/epmet-module/data-statistical/data-statistical-server/src/main/java/com/epmet/mq/ProjectChangedCustomListener.java
@@ -2,7 +2,6 @@ package com.epmet.mq;
import com.alibaba.fastjson.JSON;
import com.epmet.commons.rocketmq.messages.ProjectChangedMQMsg;
-import com.epmet.commons.tools.constant.NumConstant;
import com.epmet.commons.tools.distributedlock.DistributedLock;
import com.epmet.commons.tools.exception.RenException;
import com.epmet.commons.tools.redis.RedisKeys;
@@ -12,8 +11,6 @@ import com.epmet.dto.extract.form.ExtractOriginFormDTO;
import com.epmet.service.evaluationindex.extract.todata.FactOriginExtractService;
import com.epmet.service.evaluationindex.extract.toscreen.ScreenExtractService;
import com.epmet.util.DimIdGenerator;
-import com.google.common.cache.Cache;
-import com.google.common.cache.CacheBuilder;
import lombok.extern.slf4j.Slf4j;
import org.apache.commons.lang3.StringUtils;
import org.apache.rocketmq.client.consumer.listener.ConsumeConcurrentlyContext;
@@ -23,7 +20,6 @@ import org.apache.rocketmq.common.message.MessageExt;
import org.redisson.api.RLock;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
-import org.springframework.data.redis.core.RedisTemplate;
import javax.annotation.PreDestroy;
import java.util.Date;
@@ -119,11 +115,12 @@ public class ProjectChangedCustomListener implements MessageListenerConcurrently
extractOriginFormDTO.setDateId(dateId);
Future> aBoolean = SpringContextUtils.getBean(FactOriginExtractService.class).submitProjectRelationData(extractOriginFormDTO,null);
try {
- aBoolean.get();
+ Object o = aBoolean.get();
+ log.info("submitProjectRelationData result:{}",o);
} catch (InterruptedException e) {
- e.printStackTrace();
+ log.error("submitProjectRelationData tread InterruptedException",e);
} catch (ExecutionException e) {
- e.printStackTrace();
+ log.error("submitProjectRelationData tread ExecutionException",e);
}
if (aBoolean.isDone()){
// 指标库,实时数据只更新:【screen_project_data】
diff --git a/epmet-module/data-statistical/data-statistical-server/src/main/resources/mapper/evaluationindex/extract/FactOriginProjectCategoryDailyDao.xml b/epmet-module/data-statistical/data-statistical-server/src/main/resources/mapper/evaluationindex/extract/FactOriginProjectCategoryDailyDao.xml
index 2a466396bd..a33bda9bed 100644
--- a/epmet-module/data-statistical/data-statistical-server/src/main/resources/mapper/evaluationindex/extract/FactOriginProjectCategoryDailyDao.xml
+++ b/epmet-module/data-statistical/data-statistical-server/src/main/resources/mapper/evaluationindex/extract/FactOriginProjectCategoryDailyDao.xml
@@ -91,6 +91,7 @@
UNION ALL
SELECT
c.CUSTOMER_ID,
+ c.CUSTOMER_ID AS categoryOriginCustomerId,
left(c.CATEGORY_CODE, 4) AS CATEGORY_CODE,
'1' AS `LEVEL`,
p.AGENCY_ID AS orgId,
diff --git a/epmet-module/data-statistical/data-statistical-server/src/main/resources/mapper/org/CustomerStaffGridDao.xml b/epmet-module/data-statistical/data-statistical-server/src/main/resources/mapper/org/CustomerStaffGridDao.xml
index 75b9aa5b40..0dada73cae 100644
--- a/epmet-module/data-statistical/data-statistical-server/src/main/resources/mapper/org/CustomerStaffGridDao.xml
+++ b/epmet-module/data-statistical/data-statistical-server/src/main/resources/mapper/org/CustomerStaffGridDao.xml
@@ -16,7 +16,7 @@
grid.PIDS gridPids
FROM
customer_staff_grid sg
- LEFT JOIN customer_grid grid ON grid.id = sg.grid_id
+ LEFT JOIN customer_grid grid ON grid.id = sg.grid_id AND grid.DEL_FLAG = '0'
WHERE
sg.del_flag = '0'
diff --git a/epmet-module/data-statistical/data-statistical-server/src/main/resources/mapper/partymember/PartyMemberDao.xml b/epmet-module/data-statistical/data-statistical-server/src/main/resources/mapper/partymember/PartyMemberDao.xml
index 1a6a74ddd4..59933198f7 100644
--- a/epmet-module/data-statistical/data-statistical-server/src/main/resources/mapper/partymember/PartyMemberDao.xml
+++ b/epmet-module/data-statistical/data-statistical-server/src/main/resources/mapper/partymember/PartyMemberDao.xml
@@ -10,14 +10,18 @@
GRID_ID,
USER_ID,
ID_CARD,
- STR_TO_DATE( SUBSTRING( ID_CARD, 7, 8 ),'%Y%m%d') AS birthday
+ (
+ case when LENGTH(ID_CARD)=15 then STR_TO_DATE( concat('19',SUBSTRING( ID_CARD, 7, 6 )),'%Y%m%d')
+ else STR_TO_DATE( SUBSTRING( ID_CARD, 7, 8 ),'%Y%m%d')
+ end
+ )as birthday
FROM
partymember_info
WHERE
DEL_FLAG = 0
- AND ( CONFIRM_RESULT = 'auto_confirm_success' OR CONFIRM_RESULT = 'approved' )
- AND CUSTOMER_ID = #{customerId}
- AND DATE_FORMAT( UPDATED_TIME, '%Y%m%d' ) = #{dateId}
+ AND ( CONFIRM_RESULT = 'auto_confirm_success' OR CONFIRM_RESULT = 'approved' )
+ AND CUSTOMER_ID = #{customerId}
+ AND DATE_FORMAT( UPDATED_TIME, '%Y%m%d' ) = #{dateId}
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
\ No newline at end of file