| | |
| | | return 0; |
| | | } |
| | | |
| | | if (msg.getCount() > 0) { |
| | | serverRegister(msg.getResult(), req); |
| | | } |
| | | |
| | | return msg.getCount(); |
| | | } |
| | | |
| | |
| | | } |
| | | |
| | | /** |
| | | * 服务注册 |
| | | */ |
| | | private void serverRegister(String ids, HttpServletRequest req) { |
| | | List<PublishEntity> list = selectByIds(ids); |
| | | if (null == list || list.isEmpty()) { |
| | | return; |
| | | } |
| | | |
| | | for (PublishEntity entity : list) { |
| | | // 避免重复注册 |
| | | if (null != entity.getUpdateTime()) { |
| | | continue; |
| | | } |
| | | |
| | | String url = entity.getUrl().replace("{host}", iisHost); |
| | | String type = getServerType(entity); |
| | | |
| | | RegisterEntity reg = fmeService.serverRegister(entity.getName(), url, type, req); |
| | | if (null == reg || StringHelper.isEmpty(reg.getSerialnum())) { |
| | | continue; |
| | | } |
| | | |
| | | fmeService.serverApply(reg.getSerialnum(), entity.getId(), req); |
| | | |
| | | entity.setRegid(reg.getHashid()); |
| | | update(entity); |
| | | } |
| | | } |
| | | |
| | | /** |
| | | * 获取服务类型 |
| | | */ |
| | | private String getServerType(PublishEntity entity) { |
| | |
| | | public Integer deletes(List<Integer> idList, HttpServletRequest req) { |
| | | String ids = StringHelper.join(idList, ","); |
| | | |
| | | deleteRes(ids, req); |
| | | |
| | | return deletes(ids); |
| | | } |
| | | |
| | | /** |
| | | * 删除资源 |
| | | */ |
| | | private void deleteRes(String ids, HttpServletRequest req) { |
| | | List<PublishEntity> list = selectByIds(ids); |
| | | if (null == list || list.isEmpty()) { |
| | | return; |
| | | } |
| | | |
| | | for (PublishEntity entity : list) { |
| | | if (StringHelper.isEmpty(entity.getRegid())) { |
| | | continue; |
| | | } |
| | | |
| | | try { |
| | | fmeService.deleteRes(entity.getRegid(), req); |
| | | } catch (Exception ex) { |
| | | log.error(ex.getMessage(), ex); |
| | | } |
| | | } |
| | | } |
| | | |
| | | /** |