|
|
@ -17,6 +17,7 @@ import com.epmet.commons.tools.utils.ConvertUtils; |
|
|
|
import com.epmet.commons.tools.utils.Result; |
|
|
|
import com.epmet.commons.tools.utils.ScanContentUtils; |
|
|
|
import com.epmet.constant.IssueConstant; |
|
|
|
import com.epmet.constant.OrgInfoConstant; |
|
|
|
import com.epmet.constant.ReadFlagConstant; |
|
|
|
import com.epmet.constant.UserMessageConstant; |
|
|
|
import com.epmet.dao.IssueDao; |
|
|
@ -34,21 +35,27 @@ import com.epmet.entity.IssueProjectRelationEntity; |
|
|
|
import com.epmet.feign.*; |
|
|
|
import com.epmet.redis.GovIssueRedis; |
|
|
|
import com.epmet.redis.IssueVoteDetailRedis; |
|
|
|
import com.epmet.resi.group.dto.group.form.GroupInfoFormDTO; |
|
|
|
import com.epmet.resi.group.dto.group.result.GroupInfoResultDTO; |
|
|
|
import com.epmet.resi.group.dto.topic.ResiTopicDTO; |
|
|
|
import com.epmet.resi.group.dto.topic.form.GovTopicIssueInfoFormDTO; |
|
|
|
import com.epmet.resi.group.dto.topic.form.TopicInfoFormDTO; |
|
|
|
import com.epmet.resi.group.dto.topic.result.GovTopicIssueInfoResultDTO; |
|
|
|
import com.epmet.resi.group.feign.ResiGroupOpenFeignClient; |
|
|
|
import com.epmet.service.IssueProcessService; |
|
|
|
import com.epmet.service.IssueProjectRelationService; |
|
|
|
import com.epmet.service.IssueService; |
|
|
|
import com.epmet.service.IssueVoteStatisticalService; |
|
|
|
import com.epmet.utils.ModuleConstants; |
|
|
|
import com.github.pagehelper.PageHelper; |
|
|
|
import com.github.pagehelper.PageInfo; |
|
|
|
import org.slf4j.Logger; |
|
|
|
import org.slf4j.LoggerFactory; |
|
|
|
import org.springframework.beans.factory.annotation.Autowired; |
|
|
|
import org.springframework.beans.factory.annotation.Value; |
|
|
|
import org.springframework.stereotype.Service; |
|
|
|
import org.springframework.transaction.annotation.Transactional; |
|
|
|
import org.springframework.util.CollectionUtils; |
|
|
|
|
|
|
|
import java.util.*; |
|
|
|
import java.util.stream.Collectors; |
|
|
@ -78,6 +85,10 @@ public class IssueServiceImpl extends BaseServiceImpl<IssueDao, IssueEntity> imp |
|
|
|
private IssueProjectRelationDao issueProjectRelationDao; |
|
|
|
@Autowired |
|
|
|
private IssueVoteDetailRedis issueVoteDetailRedis; |
|
|
|
@Autowired |
|
|
|
private GovOrgOpenFeignClient govOrgOpenFeignClient; |
|
|
|
@Autowired |
|
|
|
private ResiGroupOpenFeignClient resiGroupOpenFeignClient; |
|
|
|
|
|
|
|
protected static final Logger logger = LoggerFactory.getLogger(IssueServiceImpl.class); |
|
|
|
|
|
|
@ -841,4 +852,30 @@ public class IssueServiceImpl extends BaseServiceImpl<IssueDao, IssueEntity> imp |
|
|
|
return baseDao.checkTopicShiftIssue(formDTO); |
|
|
|
} |
|
|
|
|
|
|
|
/** |
|
|
|
* @Description 个人中心-我发起的议题列表-表决中 |
|
|
|
* @Param myPubIssuesAuditingFormDTO |
|
|
|
* @author zxc |
|
|
|
* @date 2020/11/11 9:24 上午 |
|
|
|
*/ |
|
|
|
@Override |
|
|
|
public List<MyPubIssuesAuditingResultDTO> myPubIssuesAuditing(MyPubIssuesAuditingFormDTO form) { |
|
|
|
List<MyPubIssuesAuditingResultDTO> list = new ArrayList<>(); |
|
|
|
PageInfo<MyPubIssuesAuditingResultDTO> result = PageHelper.startPage(form.getPageNo(),form.getPageSize()).doSelectPageInfo(() -> baseDao.myPubIssuesAuditing(form.getUserId())); |
|
|
|
if (!CollectionUtils.isEmpty(result.getList())){ |
|
|
|
list = result.getList(); |
|
|
|
Result<List<OrgInfoResultDTO>> gridNameList = govOrgOpenFeignClient.selectOrgInfo(new OrgInfoFormDTO(OrgInfoConstant.GRID, list.stream().map(m -> m.getGridId()).collect(Collectors.toList()))); |
|
|
|
if (!gridNameList.success()){ |
|
|
|
throw new RenException("查询议题来源网格名称失败......"); |
|
|
|
} |
|
|
|
list.forEach(l -> gridNameList.getData().stream().filter(o -> l.getGridId().equals(o.getOrgId())).forEach(o -> l.setTopicReleaseGridName(o.getOrgName()))); |
|
|
|
Result<List<GroupInfoResultDTO>> groupNameList = resiGroupOpenFeignClient.selectGroupInfo(new GroupInfoFormDTO(list.stream().map(m -> m.getTopicId()).collect(Collectors.toList()))); |
|
|
|
if (!groupNameList.success()){ |
|
|
|
throw new RenException("查询议题来源小组名称失败......"); |
|
|
|
} |
|
|
|
list.forEach(l -> groupNameList.getData().stream().filter(g -> l.getTopicId().equals(g.getTopicId())).forEach(g -> l.setTopicReleaseGroupName(g.getTopicGroupName()))); |
|
|
|
} |
|
|
|
return list; |
|
|
|
} |
|
|
|
|
|
|
|
} |
|
|
|