表定义枚举类型

xc

2020-12-07 16806eadf0dff9123ec09ea708078f223d155d7c

 src/main/java/com/hbbh/adapter/manager/impl/DataSourceImpl.java

@@ -24,8 +24,7 @@
import java.util.TreeMap;

@Service
public class DataSourceImpl implements DataSource
{
public class DataSourceImpl implements DataSource {
    private static final Logger log = LoggerFactory.getLogger(Class.class);


@@ -49,6 +48,7 @@

    /**
     * 获取表与标签数量关系
     *
     * @return
     * @throws Exception
     */
@@ -84,6 +84,7 @@
    /**
     * k - tableName
     * v - point
     *
     * @return
     * @throws Exception
     */
@@ -134,39 +135,42 @@


    public void insert(String flag,List<Point> point){
        System.out.println(flag);
        log.info("golden 中 表 ----> {}  正在构建数据...");
        TableEnum byType = TableEnum.getByType(flag);

        switch (flag) {
            case "SMS":
        switch (byType) {
            case SMS:
                point.forEach(p->{
                    SMS data=PointConvert.pointToSMS(p);
                    smsDao.saveAndFlush(data);
                });
                break;
            case "DLZ_PLC":
                point.forEach(p->{
                    DLZ_PLC data=PointConvert.pointToDLZPLC(p);
                    dlzPlcDao.saveAndFlush(data);
                });
                break;
            case "DJW_PLC":
                point.forEach(p->{
                    DJW_PLC data=PointConvert.pointToDJWPLC(p);
                    djwPlcDao.saveAndFlush(data);
                });
                break;
            case "BDS_PLC":
            case BDS_PLC:
                point.forEach(p->{
                    BDS_PLC data=PointConvert.pointToBDSPLC(p);
                    bdsPlcDao.saveAndFlush(data);
                });
                break;
            case "KTNZ2C_PLC":
            case DJW_PLC:
                point.forEach(p -> {
                    DJW_PLC data = PointConvert.pointToDJWPLC(p);
                    djwPlcDao.saveAndFlush(data);
                });
                break;
            case DLZ_PLC:
                point.forEach(p -> {
                    DLZ_PLC data = PointConvert.pointToDLZPLC(p);
                    dlzPlcDao.saveAndFlush(data);
                });
                break;
            case KTNZ2C_PLC:
                point.forEach(p->{
                    KTNZ2C_PLC data=PointConvert.pointToKTNZ2CPLC(p);
                    ktnz2CPlcDao.saveAndFlush(data);
                });
                break;
            default:
                //TODO:剩下表构建
        }

    }