Browse Source

socket

feature/dangjian
zhangyuan 3 years ago
parent
commit
16b0e4f8c9
  1. 2
      esua-epdc/epdc-module/epdc-events/epdc-events-server/src/main/java/com/elink/esua/epdc/modules/events/service/impl/EpdcEventsServiceImpl.java
  2. 10
      esua-epdc/epdc-module/epdc-events/epdc-events-server/src/main/java/com/elink/esua/epdc/modules/item/service/ItemService.java
  3. 15
      esua-epdc/epdc-module/epdc-events/epdc-events-server/src/main/java/com/elink/esua/epdc/modules/item/service/impl/ItemServiceImpl.java
  4. 5
      esua-epdc/epdc-module/epdc-websocket/epdc-websocket-client/src/main/java/com.elink.esua.epdc/constants/MenuCodeConstant.java

2
esua-epdc/epdc-module/epdc-events/epdc-events-server/src/main/java/com/elink/esua/epdc/modules/events/service/impl/EpdcEventsServiceImpl.java

@ -465,6 +465,8 @@ public class EpdcEventsServiceImpl extends BaseServiceImpl<EpdcEventsDao, EpdcEv
itemService.sendItemHandleMenuNotice(deptId, userId);
// 项目-待处理项目-驳回-网格用户
itemService.sendItemHandleMenuNoticeReject(deptId, userId);
// 项目-待处理项目-结案-网格用户
itemService.sendItemHandleMenuNoticeExamine(deptId, userId);
} else if (OrganizationTypeConstant.ORG_TYPE_DISTRICT_PARTY.equals(dtoResult.getData().getTypeKey())
|| OrganizationTypeConstant.ORG_TYPE_DISTRICT_DEPT.equals(dtoResult.getData().getTypeKey())
|| OrganizationTypeConstant.ORG_TYPE_STREET_PARTY.equals(dtoResult.getData().getTypeKey())

10
esua-epdc/epdc-module/epdc-events/epdc-events-server/src/main/java/com/elink/esua/epdc/modules/item/service/ItemService.java

@ -325,6 +325,16 @@ public interface ItemService extends BaseService<ItemEntity> {
*/
void sendItemHandleMenuNoticeReject(Long deptId, Long userId);
/**
* 项目处理发送菜单消息-结案
*
* @return void
* @params [deptId]
* @author liuchuang
* @since 2019/10/30 9:12
*/
void sendItemHandleMenuNoticeExamine(Long deptId, Long userId);
/**
* 项目处理发送菜单消息-吹哨部门
*

15
esua-epdc/epdc-module/epdc-events/epdc-events-server/src/main/java/com/elink/esua/epdc/modules/item/service/impl/ItemServiceImpl.java

@ -1479,6 +1479,21 @@ public class ItemServiceImpl extends BaseServiceImpl<ItemDao, ItemEntity> implem
newsTask.eventMenuNotice(menuNoticeDTO, userId);
}
@Override
public void sendItemHandleMenuNoticeExamine(Long deptId, Long userId) {
// 获取部门待处理项目数量
// int num = baseDao.selectCountOfItemDeptNotice(deptId, EventIssueItemState.ITEM_HANDLING);
Map<String, Object> params = new HashMap<>();
params.put("itemState","0");
PageData<ItemExaminePageResultDTO> page = getExaminePage(params);
MenuNoticeDTO menuNoticeDTO = new MenuNoticeDTO();
menuNoticeDTO.setDeptId(deptId);
menuNoticeDTO.setNum(page.getTotal());
menuNoticeDTO.setMenuCode(MenuCodeConstant.PARTY_GROUP_DISCUSSION_ITEM_HANDLE_EXAMINE);
// 发送菜单消息通知
newsTask.eventMenuNotice(menuNoticeDTO, userId);
}
@Override
public void sendWhistlingDeptItemHandleMenuNotice(List<Long> deptIds, Long userId) {
MenuNoticeDTO menuNoticeDTO = new MenuNoticeDTO();

5
esua-epdc/epdc-module/epdc-websocket/epdc-websocket-client/src/main/java/com.elink.esua.epdc/constants/MenuCodeConstant.java

@ -29,4 +29,9 @@ public interface MenuCodeConstant {
*/
String PARTY_GROUP_DISCUSSION_ITEM_HANDLE_REJECT = "item-handle-reject";
/**
* 党群议事-项目管理-待处理项目-结案
*/
String PARTY_GROUP_DISCUSSION_ITEM_HANDLE_EXAMINE = "item-handle-examine";
}

Loading…
Cancel
Save