1

13693261870

2023-03-25 e8b508b0c3abe33eed40486a3ae3c73f84ead256

1

 src/main/java/com/lf/server/mapper/sys/AttachMapper.java

@@ -1,6 +1,7 @@
package com.lf.server.mapper.sys;

import com.lf.server.entity.data.FmeLogEntity;
import com.lf.server.entity.data.MetaEntity;
import com.lf.server.entity.sys.AttachEntity;
import org.apache.ibatis.annotations.Mapper;
import org.springframework.stereotype.Repository;
@@ -154,4 +155,12 @@
     * @return
     */
    public Integer updateFmeLog(Integer id);

    /**
     * 根据名称查询元数据
     *
     * @param name
     * @return
     */
    public MetaEntity selectMetaByName(String name);
}

 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,32 @@
        return attachMapper.updateFmeLog(id);
    }

    @Override
    public MetaEntity selectMetaByName(String name) {
        return attachMapper.selectMetaByName(name);
    }

    /**
     * 同步附件
     */
    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 = getAnnexField(list.get(0), fieldName);
        if (null == field) {
            return;
        }

        for (Object obj : list) {
            BaseEntity be = (BaseEntity) obj;
            //
        }
    }

    /**
@@ -154,4 +170,18 @@

        return baseMapper.selectList(wrapper);
    }

    /**
     * 获取附件字段
     */
    private Field getAnnexField(Object obj, String name) {
        try {
            Field field = obj.getClass().getDeclaredField(name);
            field.setAccessible(true);

            return field;
        } catch (Exception ex) {
            return null;
        }
    }
}

 src/main/resources/mapper/sys/AttachMapper.xml

@@ -112,4 +112,11 @@
    <update id="updateFmeLog">
        update lf.sys_fme_log set update_time = now() where id = #{id};
    </update>

    <select id="selectMetaByName" resultType="com.lf.server.entity.data.MetaEntity">
        select * from lf.sys_meta
        where name = #{name} and create_time > now()::timestamp + '-10 min'
        order by id desc
        limit 1;
    </select>
</mapper>