管道基础大数据平台系统开发-【后端】-Server
1
13693261870
2023-03-20 1991cda18d5675f754e3960b6de95a0089bf7440
src/main/java/com/lf/server/service/show/ApplyService.java
@@ -5,7 +5,6 @@
import com.lf.server.entity.show.FlowEntity;
import com.lf.server.entity.sys.UserEntity;
import com.lf.server.helper.AesHelper;
import com.lf.server.helper.Md5Helper;
import com.lf.server.helper.StringHelper;
import com.lf.server.mapper.show.ApplyMapper;
import org.apache.commons.logging.Log;
@@ -37,14 +36,14 @@
    @Override
    public Integer selectCount(String uname, Integer status, Timestamp start, Timestamp end) {
        uname = StringHelper.getLikeStr(uname);
        uname = StringHelper.getLikeUpperStr(uname);
        return applyMapper.selectCount(uname, status, start, end);
    }
    @Override
    public List<ApplyEntity> selectByPage(Integer userid, String uname, Integer status, Timestamp start, Timestamp end, Integer limit, Integer offset) {
        uname = StringHelper.getLikeStr(uname);
        uname = StringHelper.getLikeUpperStr(uname);
        return applyMapper.selectByPage(userid, uname, status, start, end, limit, offset);
    }
@@ -60,8 +59,8 @@
    }
    @Override
    public UserEntity selectUserByDepid(Integer depid) {
        return applyMapper.selectUserByDepid(depid);
    public UserEntity selectUserByDepcode(String depcode) {
        return applyMapper.selectUserByDepcode(depcode);
    }
    @Override
@@ -105,23 +104,23 @@
    }
    @Override
    public Integer updateForDiscard(Integer id) {
        return applyMapper.updateForDiscard(id);
    public Integer updateForDiscard(Integer userid, Integer id) {
        return applyMapper.updateForDiscard(userid, id);
    }
    @Override
    public Integer updateForResubmit(Integer id) {
        return applyMapper.updateForResubmit(id);
    public Integer updateForResubmit(Integer userid, Integer id) {
        return applyMapper.updateForResubmit(userid, id);
    }
    @Override
    public Integer updateForSubmit(Integer applyid, Integer flowId) {
        return applyMapper.updateForSubmit(applyid, flowId);
    public Integer updateForSubmit(Integer userid, Integer applyid, Integer flowId) {
        return applyMapper.updateForSubmit(userid, applyid, flowId);
    }
    @Override
    public Integer updateForReject(Integer applyid, Integer flowId) {
        return applyMapper.updateForReject(applyid, flowId);
    public Integer updateForReject(Integer userid, Integer applyid, Integer flowId) {
        return applyMapper.updateForReject(userid, applyid, flowId);
    }
    /**
@@ -149,13 +148,13 @@
        ApplyEntity apply = new ApplyEntity();
        apply.setUserid(ue.getId());
        apply.setDepids(StringHelper.join(dr.getIds(), ","));
        apply.setDepids(StringHelper.join(dr.getDepcodes(), ","));
        apply.setTabs(StringHelper.join(dr.getTabs(), ","));
        apply.setEntities(StringHelper.join(dr.getEntities(), ","));
        apply.setWkt(dr.getWkt());
        apply.setPwd(aesPwd);
        apply.setStatus(0);
        apply.setCount(dr.getIds().size());
        apply.setCount(dr.getDepcodes().size());
        apply.setDescr(dr.getDescr());
        apply.setCreateUser(ue.getId());
@@ -167,15 +166,15 @@
     */
    private List<FlowEntity> getFlowEntities(Integer applyId, UserEntity ue, DownloadReqEntity dr) {
        List<FlowEntity> list = new ArrayList<>();
        for (Integer depid : dr.getIds()) {
            UserEntity user = selectUserByDepid(depid);
        for (String depcode : dr.getDepcodes()) {
            UserEntity user = selectUserByDepcode(depcode);
            if (null == user) {
                continue;
            }
            FlowEntity flow = new FlowEntity();
            flow.setApplyid(applyId);
            flow.setDepid(depid);
            flow.setDepcode(user.getDepcode());
            flow.setUserid(user.getId());
            flow.setStatus(0);
            flow.setDescr(null);
@@ -195,7 +194,7 @@
            List<String> entities = Arrays.asList(entity.getEntities().split(","));
            String pwd = AesHelper.decrypt(entity.getPwd());
            dataLibService.createZipFile(ue, entities, entity.getWkt(), pwd);
            dataLibService.createZipFile(ue, entities, null, null, entity.getWkt(), pwd);
        } catch (Exception ex) {
            log.error(ex.getMessage(), ex);
        }