Browse Source

数据补全

dev
zxc 3 years ago
parent
commit
2dfb87e3ad
  1. 9
      epmet-module/gov-issue/gov-issue-server/src/main/java/com/epmet/service/impl/IssueApplicationServiceImpl.java
  2. 6
      epmet-module/gov-issue/gov-issue-server/src/main/resources/mapper/IssueApplicationDao.xml

9
epmet-module/gov-issue/gov-issue-server/src/main/java/com/epmet/service/impl/IssueApplicationServiceImpl.java

@ -46,6 +46,7 @@ import com.epmet.service.IssueApplicationService;
import com.epmet.utils.ModuleConstants; import com.epmet.utils.ModuleConstants;
import com.github.pagehelper.PageHelper; import com.github.pagehelper.PageHelper;
import com.github.pagehelper.PageInfo; import com.github.pagehelper.PageInfo;
import lombok.extern.slf4j.Slf4j;
import org.apache.commons.collections4.CollectionUtils; import org.apache.commons.collections4.CollectionUtils;
import org.apache.commons.lang3.StringUtils; import org.apache.commons.lang3.StringUtils;
import org.springframework.stereotype.Service; import org.springframework.stereotype.Service;
@ -62,6 +63,7 @@ import java.util.Map;
* @since v1.0.0 2020-11-17 * @since v1.0.0 2020-11-17
*/ */
@Service @Service
@Slf4j
public class IssueApplicationServiceImpl extends BaseServiceImpl<IssueApplicationDao, IssueApplicationEntity> implements IssueApplicationService { public class IssueApplicationServiceImpl extends BaseServiceImpl<IssueApplicationDao, IssueApplicationEntity> implements IssueApplicationService {
@Override @Override
@ -208,14 +210,15 @@ public class IssueApplicationServiceImpl extends BaseServiceImpl<IssueApplicatio
List<IssueApplicationDTO> list = pageInfo.getList(); List<IssueApplicationDTO> list = pageInfo.getList();
size = list.size(); size = list.size();
if (CollectionUtils.isNotEmpty(list)){ if (CollectionUtils.isNotEmpty(list)){
list.forEach(l -> { for (IssueApplicationDTO l : list) {
GridInfoCache gridInfo = CustomerOrgRedis.getGridInfo(l.getGridId()); GridInfoCache gridInfo = CustomerOrgRedis.getGridInfo(l.getGridId());
if (null == gridInfo){ if (null == gridInfo){
throw new EpmetException("查询网格信息失败:"+l.getGridId()); log.warn("查询网格信息失败:"+l.getGridId());
continue;
} }
l.setOrgId(gridInfo.getPid()); l.setOrgId(gridInfo.getPid());
l.setOrgIdPath(gridInfo.getPids()); l.setOrgIdPath(gridInfo.getPids());
}); }
updateIssueApplication(list); updateIssueApplication(list);
} }
no++; no++;

6
epmet-module/gov-issue/gov-issue-server/src/main/resources/mapper/IssueApplicationDao.xml

@ -7,19 +7,19 @@
<trim prefix="set" suffixOverrides=","> <trim prefix="set" suffixOverrides=",">
<trim prefix="ORG_ID = (case" suffix="end),"> <trim prefix="ORG_ID = (case" suffix="end),">
<foreach collection="list" item="i" index="index"> <foreach collection="list" item="i" index="index">
when ID = #{i.ID} then #{orgId} when ID = #{i.id} then #{i.orgId}
</foreach> </foreach>
</trim> </trim>
<trim prefix="ORG_ID_PATH = (case" suffix="end),"> <trim prefix="ORG_ID_PATH = (case" suffix="end),">
<foreach collection="list" item="i" index="index"> <foreach collection="list" item="i" index="index">
when ID = #{i.ID} then #{ORG_ID_PATH} when ID = #{i.id} then #{i.orgIdPath}
</foreach> </foreach>
</trim> </trim>
updated_time = now() updated_time = now()
where 1=1 where 1=1
<trim prefix="AND ( " suffix=" )"> <trim prefix="AND ( " suffix=" )">
<foreach collection="list" separator="or" item="i" index="index" > <foreach collection="list" separator="or" item="i" index="index" >
ID = #{i.ID} ID = #{i.id}
</foreach> </foreach>
</trim> </trim>
</trim> </trim>

Loading…
Cancel
Save