管道基础大数据平台系统开发-【后端】-Server
12
13693261870
2023-07-31 c8e5656bd1d02f66b9e6e159da56804f7c7da112
src/main/java/com/lf/server/service/data/PublishService.java
@@ -47,17 +47,19 @@
    private final static Log log = LogFactory.getLog(PublishService.class);
    @Override
    public Integer selectCount(String name) {
    public Integer selectCount(String name, String dircode, String type) {
        name = StringHelper.getLikeUpperStr(name);
        dircode = StringHelper.getRightLike(dircode);
        return publishMapper.selectCount(name);
        return publishMapper.selectCount(name, dircode, type);
    }
    @Override
    public List<PublishEntity> selectByPage(String name, Integer limit, Integer offset) {
    public List<PublishEntity> selectByPage(String name, String dircode, String type, Integer limit, Integer offset) {
        name = StringHelper.getLikeUpperStr(name);
        dircode = StringHelper.getRightLike(dircode);
        return publishMapper.selectByPage(name, limit, offset);
        return publishMapper.selectByPage(name, dircode, type, limit, offset);
    }
    @Override
@@ -300,4 +302,35 @@
            WebHelper.exec(cmd);
        }
    }
    /**
     * 删除发布文件
     */
    public void deleteFiles(List<Integer> ids, HttpServletRequest req) {
        PubEntity entity = new PubEntity();
        entity.setIds(ids);
        entity.setDircode("00");
        entity.setToken(WebHelper.getToken(req));
        long rows = postForPub(entity, "/Convert/DeleteFiles");
    }
    /**
     * 发送发布请求
     */
    public long postForPub(PubEntity entity, String method) {
        Map<String, Object> map = getMapData(entity);
        String str = RestHelper.postForRest(exportServer + method, map);
        if (StringHelper.isEmpty(str)) {
            return 0;
        }
        ResponseMsg<String> msg = JSON.parseObject(str, ResponseMsg.class);
        if (msg == null || msg.getCode() != StaticData.TWO_HUNDRED) {
            return 0;
        }
        return msg.getCount();
    }
}