管道基础大数据平台系统开发-【后端】-Server
1
13693261870
2023-08-01 b492001eab2a9e8751a4073432789efb7e945c4a
1
已修改2个文件
24 ■■■■■ 文件已修改
src/main/java/com/lf/server/controller/data/TaskController.java 7 ●●●● 补丁 | 查看 | 原始文档 | blame | 历史
src/main/java/com/lf/server/service/data/PublishService.java 17 ●●●●● 补丁 | 查看 | 原始文档 | blame | 历史
src/main/java/com/lf/server/controller/data/TaskController.java
@@ -182,7 +182,12 @@
            PubEntity entity = new PubEntity();
            entity.setIds(ids);
            entity.setDircode("00");
            entity.setToken(WebHelper.getToken(req));
            UserEntity ue = tokenService.getCurrentUser(req);
            if (ue != null) {
                entity.setUserId(ue.getId());
                entity.setToken(WebHelper.getToken(req));
            }
            long rows = publishService.postForPub(entity, "/Convert/DeleteTask");
src/main/java/com/lf/server/service/data/PublishService.java
@@ -7,11 +7,13 @@
import com.lf.server.entity.ctrl.RegisterEntity;
import com.lf.server.entity.data.MetaEntity;
import com.lf.server.entity.data.PublishEntity;
import com.lf.server.entity.sys.UserEntity;
import com.lf.server.helper.PathHelper;
import com.lf.server.helper.RestHelper;
import com.lf.server.helper.StringHelper;
import com.lf.server.helper.WebHelper;
import com.lf.server.mapper.data.PublishMapper;
import com.lf.server.service.sys.TokenService;
import org.apache.commons.logging.Log;
import org.apache.commons.logging.LogFactory;
import org.springframework.beans.factory.annotation.Value;
@@ -43,6 +45,9 @@
    @Resource
    PathHelper pathHelper;
    @Resource
    TokenService tokenService;
    private final static Log log = LogFactory.getLog(PublishService.class);
@@ -214,6 +219,11 @@
        }
        for (PublishEntity entity : list) {
            // 避免重复注册
            if (null != entity.getUpdateTime()) {
                continue;
            }
            String url = entity.getUrl().replace("{host}", iisHost);
            String type = getServerType(entity);
@@ -310,7 +320,12 @@
        PubEntity entity = new PubEntity();
        entity.setIds(ids);
        entity.setDircode("00");
        entity.setToken(WebHelper.getToken(req));
        UserEntity ue = tokenService.getCurrentUser(req);
        if (ue != null) {
            entity.setUserId(ue.getId());
            entity.setToken(WebHelper.getToken(req));
        }
        long rows = postForPub(entity, "/Convert/DeleteFiles");
    }