管道基础大数据平台系统开发-【后端】-Server
1
13693261870
2023-04-11 4c882f00d9ee90d43a1c330683a612063ce64f04
src/main/java/com/lf/server/service/show/ApplyService.java
@@ -8,6 +8,8 @@
import com.lf.server.helper.AesHelper;
import com.lf.server.helper.StringHelper;
import com.lf.server.mapper.show.ApplyMapper;
import com.lf.server.service.data.DownloadService;
import com.lf.server.service.sys.UserService;
import org.apache.commons.logging.Log;
import org.apache.commons.logging.LogFactory;
import org.springframework.beans.factory.annotation.Autowired;
@@ -31,7 +33,13 @@
    FlowService flowService;
    @Autowired
    UserService userService;
    @Autowired
    DataLibService dataLibService;
    @Autowired
    DownloadService downloadService;
    private final static Log log = LogFactory.getLog(ApplyService.class);
@@ -149,6 +157,7 @@
    private ApplyEntity getApplyEntity(UserEntity ue, DownloadReqEntity dr) throws Exception {
        // String dbPwd = Md5Helper.reverse(Md5Helper.generate(dr.getPwd()))
        String aesPwd = AesHelper.encrypt(dr.getPwd());
        String gids = null == dr.getIds() || dr.getIds().isEmpty() ? null : StringHelper.join(dr.getIds(), ",");
        ApplyEntity apply = new ApplyEntity();
        apply.setUserid(ue.getId());
@@ -163,7 +172,7 @@
        apply.setCreateUser(ue.getId());
        apply.setDepcode(dr.getDepcode());
        apply.setDircodes(dr.getDirs());
        apply.setGids(StringHelper.join(dr.getIds(), ","));
        apply.setGids(gids);
        apply.setFilters(dr.getFilter());
        return apply;
@@ -177,12 +186,12 @@
        for (String depcode : dr.getDepcodes()) {
            UserEntity user = selectUserByDepcode(depcode);
            if (null == user) {
                continue;
                user = userService.selectByUid(StaticData.ADMIN);
            }
            FlowEntity flow = new FlowEntity();
            flow.setApplyid(applyId);
            flow.setDepcode(user.getDepcode());
            flow.setDepcode(depcode);
            flow.setUserid(user.getId());
            flow.setStatus(0);
            flow.setDescr(null);
@@ -211,7 +220,11 @@
            dr.setIds(getIds(entity));
            dr.setFilter(entity.getFilters());
            dataLibService.downloadDbReq(ue, dr);
            String guid = "sysmeta".equals(entity.getEntities()) ? "" : dataLibService.downloadDbReq(ue, dr);
            if (!StringHelper.isEmpty(guid)) {
                entity.setGuid(guid);
                update(entity);
            }
        } catch (Exception ex) {
            log.error(ex.getMessage(), ex);
        }
@@ -221,6 +234,10 @@
     * 获取ID集合
     */
    private List<Integer> getIds(ApplyEntity entity) {
        if (StringHelper.isEmpty(entity.getGids())) {
            return null;
        }
        List<Integer> list = new ArrayList<>();
        for (String str : entity.getGids().split(StaticData.COMMA)) {
            list.add(Integer.parseInt(str));