管道基础大数据平台系统开发-【后端】-Server
1
13693261870
2023-03-25 fe8b2f6b674c259d948c872dd564f83810218bff
src/main/java/com/lf/server/service/sys/AttachService.java
@@ -1,7 +1,9 @@
package com.lf.server.service.sys;
import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
import com.lf.server.entity.all.BaseEntity;
import com.lf.server.entity.data.FmeLogEntity;
import com.lf.server.entity.data.MetaEntity;
import com.lf.server.entity.sys.AttachEntity;
import com.lf.server.helper.ClassHelper;
import com.lf.server.helper.StringHelper;
@@ -11,6 +13,7 @@
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;
import java.lang.reflect.Field;
import java.util.List;
/**
@@ -124,19 +127,39 @@
        return attachMapper.updateFmeLog(id);
    }
    @Override
    public Integer insertAttachByMeta(String metaName, String tab, String tabGuid) {
        return attachMapper.insertAttachByMeta(metaName, tab, tabGuid);
    }
    /**
     * 同步附件
     */
    public void syncAttaches(FmeLogEntity entity) {
        String tab = entity.getPgNs() + "." + entity.getTcdm();
        String field = UploadAttachService.ATTACH_TABS.get(tab);
        String fieldName = UploadAttachService.ATTACH_TABS.get(tab);
        List<?> list = selectRowsByParentid(entity.getTcdm().replace("_", ""), entity.getParentid(), field);
        List<?> list = selectRowsByParentid(entity.getTcdm().replace("_", ""), entity.getParentid(), fieldName);
        if (null == list || list.isEmpty()) {
            return;
        }
        //
        Field field = UploadAttachService.getAnnexField(list.get(0), tab);
        if (null == field) {
            return;
        }
        for (Object obj : list) {
            String[] names = UploadAttachService.getNames(UploadAttachService.getAnnexName(obj, field));
            if (null == names || names.length == 0) {
                continue;
            }
            BaseEntity be = (BaseEntity) obj;
            for (String name : names) {
                insertAttachByMeta(name, tab, be.getEventid());
            }
        }
    }
    /**