嘉定公交调度系统计划调度功能优化3

1、完成前置时刻表信息验证 2、时刻表测试框架建立，完成前置时刻表信息验证测试用例

嘉定公交调度系统计划调度功能优化3
1、完成前置时刻表信息验证 2、时刻表测试框架建立，完成前置时刻表信息验证测试用例
徐烜
1 parent 7faaa175
Showing 29 changed files with 4792 additions and 2 deletions
pom.xml
src/main/java/com/bsth/service/schedule/plan/PlanConfig.java
src/main/java/com/bsth/service/schedule/plan/PlanConfigProperties.java
src/main/java/com/bsth/service/schedule/plan/process/_1_validate/_1_timetable/PlanProcessValidateTimetableService.java
src/main/java/com/bsth/service/schedule/plan/process/_1_validate/_1_timetable/PlanProcessValidateTimetableServiceDroolsImpl.java
src/main/java/com/bsth/service/schedule/plan/process/_1_validate/_1_timetable/drools/KBaseValidateTimeTable_Fact_CalcuParam.java
src/main/java/com/bsth/service/schedule/plan/process/_1_validate/_1_timetable/drools/KBaseValidateTimeTable_Fact_Line.java
src/main/java/com/bsth/service/schedule/plan/process/_1_validate/_1_timetable/drools/KBaseValidateTimeTable_Fact_TTInfo.java
src/main/java/com/bsth/service/schedule/plan/process/_1_validate/_1_timetable/drools/KBaseValidateTimeTable_Fact_TTInfoDetail.java
src/main/java/com/bsth/service/schedule/plan/process/_1_validate/_1_timetable/drools/KBaseValidateTimeTable_Function_AccumulateConflict.java
src/main/java/com/bsth/service/schedule/plan/process/_1_validate/_1_timetable/drools/KBaseValidateTimeTable_Function_ErrorBcCount.java
src/main/java/com/bsth/service/schedule/plan/process/_1_validate/_1_timetable/drools/KBaseValidateTimeTable_Result.java
src/main/resources/drools/KBase/validate/timetable/KBase_validate_timetable.drl
src/main/resources/drools/KBase/validate/timetable/KBase_validate_timetable_old.drl
src/main/resources/drools/config.properties
src/test/java/com/bsth/BaseTest_junit4.java
src/test/java/com/bsth/TestApplication.java
src/test/java/com/bsth/TestApplicationTypeFillter.java
src/test/java/com/bsth/entity/Business.java
src/test/java/com/bsth/entity/CarPark.java
@@ -34,7 +34,7 @@
 			<groupId>org.springframework.boot</groupId>
 			<artifactId>spring-boot-starter-security</artifactId>
 		</dependency>
-		<!-- <dependency> <groupId>org.springframework.security</groupId> <artifactId>spring-security-config</artifactId> 
+		<!-- <dependency> <groupId>org.springframework.security</groupId> <artifactId>spring-security-config</artifactId>
 			</dependency> -->
 		<dependency>
 			<groupId>org.springframework.boot</groupId>
@@ -302,7 +302,15 @@
             <artifactId>plan_module-common</artifactId>
             <version>1.0-SNAPSHOT</version>
         </dependency>
-	</dependencies>
+
+        <!-- lombok依赖 -->
+        <dependency>
+            <groupId>org.projectlombok</groupId>
+            <artifactId>lombok</artifactId>
+            <version>1.16.22</version>
+        </dependency>
+
+    </dependencies>
 	<dependencyManagement>
 		<dependencies>
+package com.bsth.service.schedule.plan;
+
+import org.kie.api.KieBase;
+import org.kie.api.KieBaseConfiguration;
+import org.kie.api.KieServices;
+import org.kie.api.builder.*;
+import org.kie.api.builder.model.KieBaseModel;
+import org.kie.api.builder.model.KieModuleModel;
+import org.kie.api.builder.model.KieSessionModel;
+import org.kie.api.conf.EqualityBehaviorOption;
+import org.kie.api.conf.EventProcessingOption;
+import org.kie.api.runtime.KieContainer;
+import org.kie.api.runtime.conf.ClockTypeOption;
+import org.kie.internal.io.ResourceFactory;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.boot.context.properties.EnableConfigurationProperties;
+import org.springframework.context.annotation.Bean;
+import org.springframework.context.annotation.Configuration;
+
+/**
+ * 计划配置类。
+ */
+@Configuration
+@EnableConfigurationProperties(PlanConfigProperties.class)
+public class PlanConfig {
+    /** 日志记录器 */
+    private static final Logger LOGGER = LoggerFactory.getLogger(PlanConfig.class);
+
+    /** 计划配置文件 */
+    @Autowired
+    private PlanConfigProperties planConfigProperties;
+
+    /**
+     * 验证时刻表kieBase。
+     * @return
+     */
+    @Bean(name = "kBaseValidateTimetable")
+    public KieBase kBaseValidateTimetable() {
+        KieBase kieBase = this.generateKieBase(
+                "kBaseValidateTimetable",
+                new String[] {this.planConfigProperties.getValidateTimetable()}
+        );
+        LOGGER.info("初始化 KieBase[{}]成功", "前置验证相关时刻表信息");
+        return kieBase;
+    }
+
+    /**
+     * 生成KieBase。
+     * @param kBaseName kBase名字
+     * @param drlClasspaths 规则类路径
+     */
+    private KieBase generateKieBase(String kBaseName, String[] drlClasspaths) {
+        // Drools 6开始引入kie统一接口（jboss的jbpm工作流也使用kie接口了），整个定义方式和5差别很大
+        // 这里使用全api方式配置知识库对象，不使用xml的方式，提供最大的灵活性
+
+        // 1、创建kieservices
+        KieServices kieServices = KieServices.Factory.get();
+
+        // 2、创建KieModuleModel，默认是由kmodule.xml的方式创建，这里使用api方式闯将
+        KieModuleModel kieModuleModel = kieServices.newKieModuleModel();
+        // 2.1、创建KieBaseModel，类似kmodule.xml中的kbase标签
+        KieBaseModel kieBaseModel1 = kieModuleModel.newKieBaseModel(kBaseName)
+                .setDefault(true)
+                .setEqualsBehavior(EqualityBehaviorOption.EQUALITY)
+                .setEventProcessingMode(EventProcessingOption.STREAM);
+        // 2.2、创建与kbase关联的KieSessionModel，类似kmodule.xml中的kbase内的ksession标签
+        kieBaseModel1.newKieSessionModel("KSession1")
+                .setDefault(true)
+                .setType(KieSessionModel.KieSessionType.STATEFUL)
+                .setClockType(ClockTypeOption.get("realtime"));
+
+        // 3、创建KieFileSystem，将模型xml，drl等写入，TODO：以后考虑从数据库中获取
+        KieFileSystem kfs = kieServices.newKieFileSystem();
+        // 3.1、写入KieBaseModel（内部包含了KieSessionModel的内容了，注意之前的KieSessionModel的创建方式）
+        kfs.writeKModuleXML(kieModuleModel.toXML());
+        // 3.2、写入drl
+        // 这里使用文件的形式写入，TODO：以后考虑从数据库中读drl写入
+        // 注意kfs写的时候如果指定path，强制为src/main/resources/加上文件名，还有就是文件名不要重复否则会覆盖的
+//        kfs.write(ResourceFactory.newFileResource(new File(rules_root_path + kbase_validate_timetable_drl)));
+        for (String drlClasspath : drlClasspaths) {
+            kfs.write(ResourceFactory.newClassPathResource(drlClasspath));
+        }
+
+        // 4、创建KieBuilder，使用KieFileSystem构建
+        KieBuilder kieBuilder = kieServices.newKieBuilder(kfs).buildAll();
+        Results results = kieBuilder.getResults();
+        if (results.hasMessages(Message.Level.ERROR))
+            throw new IllegalStateException("构建drools6错误：" + results.getMessages());
+
+        // 5、获取KieContainer
+        // TODO：ReleaseId用处很大，以后再议
+        ReleaseId releaseId = kieServices.getRepository().getDefaultReleaseId();
+        KieContainer kieContainer = kieServices.newKieContainer(releaseId);
+
+        // 6、创建kbase
+        KieBaseConfiguration kieBaseConfiguration = kieServices.newKieBaseConfiguration();
+        KieBase kieBase = kieContainer.newKieBase(kBaseName, kieBaseConfiguration);
+
+        return kieBase;
+    }
+}
+package com.bsth.service.schedule.plan;
+
+import org.springframework.boot.context.properties.ConfigurationProperties;
+
+import javax.validation.constraints.NotNull;
+
+/**
+ * 排班计划相关配置文件。
+ */
+@ConfigurationProperties(
+        locations = "classpath:drools/config.properties",
+        ignoreInvalidFields = true,
+        prefix = "drools.KBase"
+)
+public class PlanConfigProperties {
+
+    /** 排班前置验证规则（时刻表）*/
+    @NotNull
+    private String validateTimetable;
+
+    public String getValidateTimetable() {
+        return validateTimetable;
+    }
+
+    public void setValidateTimetable(String validateTimetable) {
+        this.validateTimetable = validateTimetable;
+    }
+}
+package com.bsth.service.schedule.plan.process._1_validate._1_timetable;
+
+import com.bsth.service.schedule.plan.process._1_validate._1_timetable.drools.KBaseValidateTimeTable_Result;
+
+import java.util.Date;
+
+/**
+ * 验证时刻表服务。
+ */
+public interface PlanProcessValidateTimetableService {
+    /**
+     * 验证关联的时刻表信息。
+     * @param xlid 线路Id
+     * @param from 排班计划开始时间
+     * @param to 排班计划结束时间
+     * @return 验证输出
+     */
+    KBaseValidateTimeTable_Result validateTTInfovalidateTTInfo(Integer xlid, Date from, Date to);
+}
+package com.bsth.service.schedule.plan.process._1_validate._1_timetable;
+
+import com.bsth.service.schedule.plan.process._1_validate._1_timetable.drools.*;
+import org.joda.time.DateTime;
+import org.kie.api.KieBase;
+import org.kie.api.runtime.KieSession;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+import org.springframework.jdbc.core.JdbcTemplate;
+import org.springframework.jdbc.core.RowMapper;
+import org.springframework.jdbc.core.namedparam.NamedParameterJdbcTemplate;
+
+import java.sql.ResultSet;
+import java.sql.SQLException;
+import java.util.*;
+
+/**
+ * 验证时刻表服务drools实现。
+ */
+public class PlanProcessValidateTimetableServiceDroolsImpl implements PlanProcessValidateTimetableService {
+    /** 日志记录器 */
+    private static final Logger LOGGER = LoggerFactory.getLogger(PlanProcessValidateTimetableServiceDroolsImpl.class);
+
+    /** 验证时刻表drools kbase */
+    private KieBase validateTimetableKBase;
+
+    /** 使用的jdbc服务 */
+    private JdbcTemplate jdbcTemplate;
+
+    /** 线路查询SQL */
+    private static final String LINE_QUERY_SQL =
+            "select id, name from bsth_c_line line where line.id = ? and destroy = 0";
+    /** 时刻表查询SQL */
+    private static final String TTINFO_QUERY_SQL =
+            "select id, name, rule_days, special_days, line_version " +
+                    "from bsth_c_s_ttinfo ttinfo " +
+                    "where ttinfo.is_cancel = 0 and ttinfo.is_enable_dis_template = 1 and ttinfo.xl = ?";
+    /** 时刻表明细查询SQL（使用 NamedParameterJdbcTemplate） */
+    private static final String TTINFO_DETAIL_QUERY_SQL =
+            "select id, qdz_code, qdz_name, zdz_code, zdz_name, ttinfo, line_version, bc_type, bcsj " +
+                    "from bsth_c_s_ttinfo_detail td " +
+                    "where td.ttinfo in (:ttInfoIds)";
+
+    @Override
+    public KBaseValidateTimeTable_Result validateTTInfovalidateTTInfo(final Integer xlid, Date from, Date to) {
+        LOGGER.info("KieBase[{}]，线路id={}，开始日期={}，结束日期={} 开始验证",
+                "前置验证相关时刻表信息", xlid, from, to);
+
+        // 构造drools session->载入数据->启动规则->计算->销毁session
+        // 创建session，内部配置的是stateful
+        KieSession session = validateTimetableKBase.newKieSession();
+        // 设置gloable对象，在drl中通过别名使用
+        session.setGlobal("LOGGER", LOGGER);
+
+        KBaseValidateTimeTable_Result rs = new KBaseValidateTimeTable_Result(); // 输出gloable对象
+        session.setGlobal("rs", rs);
+
+        // 载入数据，参数数据，线路数据，时刻表数据，时刻表明细数据
+        KBaseValidateTimeTable_Fact_CalcuParam calcuParam = new KBaseValidateTimeTable_Fact_CalcuParam(
+                new DateTime(from), new DateTime(to), xlid);
+        session.insert(calcuParam);
+
+        // 载入线路dto
+        List<KBaseValidateTimeTable_Fact_Line> fact_lines = jdbcTemplate.query(
+                LINE_QUERY_SQL,
+                new Object[] {xlid},
+                new RowMapper<KBaseValidateTimeTable_Fact_Line>() {
+                    @Override
+                    public KBaseValidateTimeTable_Fact_Line mapRow(ResultSet rs, int rowNum) throws SQLException {
+                        return KBaseValidateTimeTable_Fact_Line.builder()
+                                .id(rs.getInt("id"))
+                                .name(rs.getString("name"))
+                                .build();
+                    }
+                });
+        if (fact_lines.size() > 0) {
+            session.insert(fact_lines.get(0));
+        }
+
+        // 载入时刻表dto
+        List<KBaseValidateTimeTable_Fact_TTInfo> fact_ttInfos = jdbcTemplate.query(
+                TTINFO_QUERY_SQL,
+                new Object[] {xlid},
+                new RowMapper<KBaseValidateTimeTable_Fact_TTInfo>() {
+                    @Override
+                    public KBaseValidateTimeTable_Fact_TTInfo mapRow(ResultSet rs, int rowNum) throws SQLException {
+                        return KBaseValidateTimeTable_Fact_TTInfo.getBuilder()
+                                .setId(rs.getLong("id"))
+                                .setName(rs.getString("name"))
+                                .setRule_days(rs.getString("rule_days"))
+                                .setWeekdayList(rs.getString("rule_days"))
+                                .setSpecial_days(rs.getString("special_days"))
+                                .setSpecialDayList(rs.getString("special_days"))
+                                .setLineVersion(rs.getInt("line_version"))
+                                .setXl(KBaseValidateTimeTable_Fact_Line.builder().id(xlid).build())
+                                .build();
+                    }
+                });
+        for (KBaseValidateTimeTable_Fact_TTInfo fact_ttInfo : fact_ttInfos) {
+            session.insert(fact_ttInfo);
+        }
+
+        // 载入时刻表明细dto
+        Map<String, Object> param = new HashMap<>();
+        List<Long> ttInfoIds = new ArrayList<>();
+        param.put("ttInfoIds", ttInfoIds);
+        for (KBaseValidateTimeTable_Fact_TTInfo fact_ttInfo : fact_ttInfos) {
+            ttInfoIds.add(fact_ttInfo.getId());
+        }
+        if (ttInfoIds.size() > 0) {
+            NamedParameterJdbcTemplate namedParameterJdbcTemplate = new NamedParameterJdbcTemplate(jdbcTemplate);
+            List<KBaseValidateTimeTable_Fact_TTInfoDetail> fact_ttInfoDetails = namedParameterJdbcTemplate.query(
+                    TTINFO_DETAIL_QUERY_SQL,
+                    param,
+                    new RowMapper<KBaseValidateTimeTable_Fact_TTInfoDetail>() {
+                        @Override
+                        public KBaseValidateTimeTable_Fact_TTInfoDetail mapRow(ResultSet rs, int rowNum) throws SQLException {
+                            return KBaseValidateTimeTable_Fact_TTInfoDetail.builder()
+                                    .id(rs.getLong("id"))
+                                    .qdzCode(rs.getString("qdz_code"))
+                                    .qdzName(rs.getString("qdz_name"))
+                                    .zdzCode(rs.getString("zdz_code"))
+                                    .zdzName(rs.getString("zdz_name"))
+                                    .ttinfo(KBaseValidateTimeTable_Fact_TTInfo.getBuilder().setId(rs.getLong("ttinfo")).build())
+                                    .lineVersion(rs.getInt("line_version"))
+                                    .bcType(rs.getString("bc_type"))
+                                    .bcsj(rs.getInt("bcsj"))
+                                    .build();
+                        }
+                    });
+            for (KBaseValidateTimeTable_Fact_TTInfoDetail fact_ttInfoDetail : fact_ttInfoDetails) {
+                session.insert(fact_ttInfoDetail);
+            }
+        }
+
+        // 执行rule
+        session.fireAllRules();
+
+        // 执行完毕销毁，有日志的也要关闭
+        session.dispose();
+
+        LOGGER.info("KieBase[{}]，线路id={}，开始日期={}，结束日期={} 完成验证",
+                "前置验证相关时刻表信息", xlid, from, to);
+
+        return rs;
+    }
+
+    private PlanProcessValidateTimetableServiceDroolsImpl() {}
+    private PlanProcessValidateTimetableServiceDroolsImpl(Builder builder) {
+        this.validateTimetableKBase = builder.validateTimetableKBase;
+        this.jdbcTemplate = builder.jdbcTemplate;
+
+    }
+
+    public static Builder getBuilder() {
+        return new Builder();
+    }
+
+    public static class Builder {
+        /** 验证时刻表drools kbase */
+        private KieBase validateTimetableKBase;
+
+        /** 使用的jdbc服务 */
+        private JdbcTemplate jdbcTemplate;
+
+        public Builder setValidateTimetableKBase(KieBase validateTimetableKBase) {
+            this.validateTimetableKBase = validateTimetableKBase;
+            return this;
+        }
+
+        public Builder setJdbcTemplate(JdbcTemplate jdbcTemplate) {
+            this.jdbcTemplate = jdbcTemplate;
+            return this;
+        }
+
+        public PlanProcessValidateTimetableServiceDroolsImpl build() {
+            return new PlanProcessValidateTimetableServiceDroolsImpl(this);
+        }
+    }
+}
+package com.bsth.service.schedule.plan.process._1_validate._1_timetable.drools;
+
+import lombok.AllArgsConstructor;
+import lombok.Builder;
+import lombok.Data;
+import org.joda.time.DateTime;
+
+/**
+ * drools规则验证时刻表使用的参数fact对象。
+ */
+@Data
+@Builder
+@AllArgsConstructor
+public class KBaseValidateTimeTable_Fact_CalcuParam {
+    /** 开始计算时间 */
+    private DateTime fromDate;
+    /** 结束计算时间 */
+    private DateTime toDate;
+    /** 线路id */
+    private Integer xlId;
+
+}
+package com.bsth.service.schedule.plan.process._1_validate._1_timetable.drools;
+
+import lombok.AllArgsConstructor;
+import lombok.Builder;
+import lombok.Data;
+
+/**
+ * drools规则验证时刻表使用的线路fact对象。
+ */
+@Data
+@Builder
+@AllArgsConstructor
+public class KBaseValidateTimeTable_Fact_Line {
+    /** 主键id */
+    private Integer id;
+    /** 线路名称 */
+    private String name;
+}
+package com.bsth.service.schedule.plan.process._1_validate._1_timetable.drools;
+
+import org.apache.commons.lang3.StringUtils;
+import org.apache.commons.lang3.time.DateFormatUtils;
+import org.joda.time.DateTime;
+
+import java.text.ParseException;
+import java.util.ArrayList;
+import java.util.List;
+
+/**
+ * drools规则验证时刻表使用的时刻表fact对象。
+ */
+public class KBaseValidateTimeTable_Fact_TTInfo {
+    /** 主键Id */
+    private Long id;
+
+    /** 线路关联 */
+    private KBaseValidateTimeTable_Fact_Line xl;
+
+    /** 时刻表名称 */
+    private String name;
+
+    // TODO：原系统里的分别在，圈后圈进场，意思不知道，再议
+
+    /** 常规有效日（1-7表示星期一到星期日，多个用逗号隔开） */
+    private String rule_days;
+    /** 特殊有效日期（格式：2001-01-01，多个用逗号隔开） */
+    private String special_days;
+
+    /** 常规有效日（参照rule_days，1=true表示启用，0=false表示未启用，一个星期7天，保存7个元素） */
+    private List<Boolean> weekdayList = new ArrayList<>();
+    /** 特殊有效日期（参照special_days，1个日期保存1个元素） */
+    private List<DateTime> specialDayList = new ArrayList<>();
+
+    /** 线路版本（bsth_c_line_versions表对应字段） */
+    private int lineVersion;
+
+    public Long getId() {
+        return id;
+    }
+
+    public void setId(Long id) {
+        this.id = id;
+    }
+
+    public KBaseValidateTimeTable_Fact_Line getXl() {
+        return xl;
+    }
+
+    public void setXl(KBaseValidateTimeTable_Fact_Line xl) {
+        this.xl = xl;
+    }
+
+    public String getName() {
+        return name;
+    }
+
+    public void setName(String name) {
+        this.name = name;
+    }
+
+    public String getRule_days() {
+        return rule_days;
+    }
+
+    public void setRule_days(String rule_days) {
+        this.rule_days = rule_days;
+    }
+
+    public String getSpecial_days() {
+        return special_days;
+    }
+
+    public void setSpecial_days(String special_days) {
+        this.special_days = special_days;
+    }
+
+    public List<Boolean> getWeekdayList() {
+        return weekdayList;
+    }
+
+    public void setWeekdayList(List<Boolean> weekdayList) {
+        this.weekdayList = weekdayList;
+    }
+
+    public List<DateTime> getSpecialDayList() {
+        return specialDayList;
+    }
+
+    public void setSpecialDayList(List<DateTime> specialDayList) {
+        this.specialDayList = specialDayList;
+    }
+
+    public int getLineVersion() {
+        return lineVersion;
+    }
+
+    public void setLineVersion(int lineVersion) {
+        this.lineVersion = lineVersion;
+    }
+
+    public KBaseValidateTimeTable_Fact_TTInfo(Builder builder) {
+        this.id = builder.id;
+
+        this.xl = builder.xl;
+
+        this.name = builder.name;
+
+        this.rule_days = builder.rule_days;
+        this.special_days = builder.special_days;
+        this.weekdayList = builder.weekdayList;
+        this.specialDayList = builder.specialDayList;
+
+        this.lineVersion = builder.lineVersion;
+
+    }
+
+    //------------------- builder模式 -----------------//
+    public static Builder getBuilder() {
+        return new Builder();
+    }
+    public static class Builder {
+        /** 主键Id */
+        private Long id;
+
+        /** 线路关联 */
+        private KBaseValidateTimeTable_Fact_Line xl;
+
+        /** 时刻表名称 */
+        private String name;
+
+        // TODO：原系统里的分别在，圈后圈进场，意思不知道，再议
+
+        /** 常规有效日（1-7表示星期一到星期日，多个用逗号隔开） */
+        private String rule_days;
+        /** 特殊有效日期（格式：2001-01-01，多个用逗号隔开） */
+        private String special_days;
+
+        /** 常规有效日（参照rule_days，1=true表示启用，0=false表示未启用，一个星期7天，保存7个元素） */
+        private List<Boolean> weekdayList = new ArrayList<>();
+        /** 特殊有效日期（参照special_days，1个日期保存1个元素） */
+        private List<DateTime> specialDayList = new ArrayList<>();
+
+        /** 线路版本（bsth_c_line_versions表对应字段） */
+        private int lineVersion;
+
+        public Builder() {
+            // 初始化 weekdayList，7个元素为FALSE
+            for (int i = 0; i < 7; i++) {
+                this.weekdayList.add(Boolean.FALSE);
+            }
+        }
+
+        public Builder setId(Long id) {
+            this.id = id;
+            return this;
+        }
+
+        public Builder setXl(KBaseValidateTimeTable_Fact_Line xl) {
+            this.xl = xl;
+            return this;
+        }
+
+        public Builder setName(String name) {
+            this.name = name;
+            return this;
+        }
+
+        public Builder setRule_days(String rule_days) {
+            this.rule_days = rule_days;
+            return this;
+        }
+
+        public Builder setSpecial_days(String special_days) {
+            this.special_days = special_days;
+            return this;
+        }
+
+        public Builder setWeekdayList(String rule_days) {
+            // 初始化weekday，全false
+            this.weekdayList = new ArrayList<>(7);
+            for (int i = 0; i < 7; i++) {
+                this.weekdayList.add(Boolean.FALSE);
+            }
+            // 1表示工作，其他表示不工作
+            if (StringUtils.isNotEmpty(rule_days)) {
+                String[] days = rule_days.split(",");
+                for (int i = 0; i < 7 && i < days.length; i++) {
+                    if ("1".equals(days[i])) {
+                        this.weekdayList.set(i, Boolean.TRUE);
+                    } else {
+                        this.weekdayList.set(i, Boolean.FALSE);
+                    }
+                }
+            }
+            return this;
+        }
+
+        public Builder setSpecialDayList(String special_days) {
+            this.specialDayList = new ArrayList<>();
+            if (StringUtils.isNotEmpty(special_days)) {
+                String[] days = special_days.split(",");
+                for (String day : days) {
+                    try {
+                        this.specialDayList.add(new DateTime(DateFormatUtils.ISO_DATE_FORMAT.parse(day)));
+                    } catch (ParseException exp) {
+                        throw new RuntimeException(exp);
+                    }
+                }
+            }
+            return this;
+        }
+
+        public Builder setLineVersion(int lineVersion) {
+            this.lineVersion = lineVersion;
+            return this;
+        }
+
+        public KBaseValidateTimeTable_Fact_TTInfo build() {
+            return new KBaseValidateTimeTable_Fact_TTInfo(this);
+        }
+    }
+
+}
+package com.bsth.service.schedule.plan.process._1_validate._1_timetable.drools;
+
+import lombok.AllArgsConstructor;
+import lombok.Builder;
+import lombok.Data;
+
+/**
+ * drools规则验证时刻表使用的时刻表明细fact对象。
+ */
+@Data
+@Builder
+@AllArgsConstructor
+public class KBaseValidateTimeTable_Fact_TTInfoDetail {
+    /** 主健Id */
+    private Long id;
+    /** 时刻表主对象关联 */
+    private KBaseValidateTimeTable_Fact_TTInfo ttinfo;
+
+    // 站点包括普通站点和停车场（站点编码不同，使用站点编码区分）
+    // 以后不需要再区分是站点还是停车场了
+    /** 起站点代码（bsth_c_station，bsth_c_car_park 里的编码） */
+    private String qdzCode;
+    /** 起站点名字（bsth_c_stationroute，bsth_c_car_park里的名字） */
+    private String qdzName;
+    /** 终点站代码（bsth_c_station，bsth_c_car_park 里的编码） */
+    private String zdzCode;
+    /** 终点站名字（bsth_c_stationroute，bsth_c_car_park里的名字） */
+    private String zdzName;
+
+    /** 线路版本（bsth_c_line_versions表对应字段） */
+    private int lineVersion;
+
+    /** 班次类型 字典type=ScheduleType */
+    private String bcType;
+
+    /** 班次历时 */
+    private Integer bcsj;
+
+}
+package com.bsth.service.schedule.plan.process._1_validate._1_timetable.drools;
+
+import com.bsth.service.schedule.plan.process._1_validate._1_timetable.drools.KBaseValidateTimeTable_Result.StatInfo;
+import org.apache.commons.lang3.StringUtils;
+import org.kie.api.runtime.rule.AccumulateFunction;
+import org.springframework.util.CollectionUtils;
+
+import java.io.*;
+import java.util.ArrayList;
+import java.util.HashMap;
+import java.util.List;
+import java.util.Map;
+
+/**
+ * 聚合时刻表冲突函数（去除重复的时刻表，优先提取冲突的时刻表）。
+ */
+public class KBaseValidateTimeTable_Function_AccumulateConflict implements AccumulateFunction {
+    @Override
+    public void readExternal(ObjectInput in) throws IOException, ClassNotFoundException {
+    }
+    @Override
+    public void writeExternal(ObjectOutput out) throws IOException {
+    }
+
+    protected static class AccumulateConflictData implements Serializable {
+        /** 聚合后的时刻表统计信息（key为时刻表Id） */
+        private Map<Long, StatInfo> statInfoGroupMap;
+        /** 聚合后的冲突描述信息（key为时刻表Id） */
+        private Map<Long, List<String>> conflictDescGroupMap;
+
+        public AccumulateConflictData() {
+            statInfoGroupMap = new HashMap<>();
+            conflictDescGroupMap = new HashMap<>();
+        }
+
+        public void remove(Long ttInfoId) {
+            statInfoGroupMap.remove(ttInfoId);
+            conflictDescGroupMap.remove(ttInfoId);
+        }
+
+        public List<StatInfo> result() {
+            // 输出时，需要讲聚合后的冲突信息合并到时刻表统计信息中
+            List<StatInfo> rs = new ArrayList<>();
+            for (Long ttInfoId : statInfoGroupMap.keySet()) {
+                StatInfo statInfo = statInfoGroupMap.get(ttInfoId);
+                List<String> conflictDescList = conflictDescGroupMap.get(ttInfoId);
+                if (!CollectionUtils.isEmpty(conflictDescGroupMap)) {
+                    // 使用逗号分隔
+                    String conflictDesc = StringUtils.join(conflictDescList, ",");
+                    statInfo.setConflictDesc(conflictDesc);
+                }
+                rs.add(statInfo);
+            }
+            return rs;
+        }
+        public void add(StatInfo statInfo) {
+            /**
+             * 聚合时刻表统计信息，
+             * 1、第一次直接添加时刻表统计信息
+             * 2、如果下一个时刻表统计信息中有冲突标识，则覆盖添加
+             */
+            Long ttInfoId = statInfo.getTtid();
+            boolean conflict = statInfo.getConflict();
+            if (statInfoGroupMap.get(ttInfoId) == null) {
+                statInfoGroupMap.put(ttInfoId, statInfo);
+            } else {
+                if (conflict) {
+                    statInfoGroupMap.put(ttInfoId, statInfo);
+                }
+            }
+            /**
+             * 聚合时刻表冲突信息。
+             */
+            if (conflict) {
+                if (conflictDescGroupMap.get(ttInfoId) == null) {
+                    conflictDescGroupMap.put(ttInfoId, new ArrayList<String>());
+                }
+                conflictDescGroupMap.get(ttInfoId).add(statInfo.getConflictDesc());
+            }
+
+        }
+    }
+
+    @Override
+    public Serializable createContext() {
+        return new AccumulateConflictData();
+    }
+
+    @Override
+    public void init(Serializable context) throws Exception {
+    }
+
+    @Override
+    public void accumulate(Serializable context, Object value) {
+        AccumulateConflictData accumulateConflictData = (AccumulateConflictData) context;
+        StatInfo statInfo = (StatInfo) value;
+        accumulateConflictData.add(statInfo);
+    }
+
+    @Override
+    public void reverse(Serializable context, Object value) throws Exception {
+        AccumulateConflictData accumulateConflictData = (AccumulateConflictData) context;
+        StatInfo statInfo = (StatInfo) value;
+        accumulateConflictData.remove(statInfo.getTtid());
+    }
+
+    @Override
+    public boolean supportsReverse() {
+        return true;
+    }
+
+    @Override
+    public Class<?> getResultType() {
+        return List.class;
+    }
+
+    @Override
+    public Object getResult(Serializable context) throws Exception {
+        AccumulateConflictData accumulateConflictData = (AccumulateConflictData) context;
+        return accumulateConflictData.result();
+    }
+}
+package com.bsth.service.schedule.plan.process._1_validate._1_timetable.drools;
+
+import org.apache.commons.lang3.StringUtils;
+import org.kie.api.runtime.rule.AccumulateFunction;
+
+import java.io.*;
+
+/**
+ * drools规则验证时刻表用的函数（计算错误班次数量）
+ */
+public class KBaseValidateTimeTable_Function_ErrorBcCount implements AccumulateFunction {
+    @Override
+    public void readExternal(ObjectInput in) throws IOException, ClassNotFoundException {
+    }
+
+    @Override
+    public void writeExternal(ObjectOutput out) throws IOException {
+    }
+
+    protected static class ErrorCountData implements Externalizable {
+        public long errorcount = 0;
+        public KBaseValidateTimeTable_Fact_TTInfoDetail ttInfoDetail;
+
+        public ErrorCountData() {
+        }
+
+        @Override
+        public void readExternal(ObjectInput in) throws IOException, ClassNotFoundException {
+            errorcount = in.readLong();
+            ttInfoDetail = (KBaseValidateTimeTable_Fact_TTInfoDetail) in.readObject();
+        }
+
+        @Override
+        public void writeExternal(ObjectOutput out) throws IOException {
+            out.writeLong(errorcount);
+            out.writeObject(ttInfoDetail);
+        }
+    }
+
+    @Override
+    public Serializable createContext() {
+        return new ErrorCountData();
+    }
+
+    @Override
+    public void init(Serializable context) throws Exception {
+        ErrorCountData errorCountData = (ErrorCountData) context;
+        errorCountData.errorcount = 0;
+    }
+
+    @Override
+    public void accumulate(Serializable context, Object value) {
+        ErrorCountData errorCountData = (ErrorCountData) context;
+        KBaseValidateTimeTable_Fact_TTInfoDetail ttInfoDetail = (KBaseValidateTimeTable_Fact_TTInfoDetail) value;
+
+        if (ttInfoDetail.getTtinfo() == null) {
+            errorCountData.errorcount ++;
+            return;
+        }
+
+        // 判定条件（数据库中的对应字段没有非空约束），与界面saTimeTable.js的validInfo方法对应
+        // 1、起点站编码，名字为空
+        // 2、终点站编码，名字为空
+        // 3、班次时间
+        // TODO：其他再议
+        if (StringUtils.isEmpty(ttInfoDetail.getQdzCode()) ||
+                StringUtils.isEmpty(ttInfoDetail.getQdzName()) ||
+                StringUtils.isEmpty(ttInfoDetail.getZdzCode()) ||
+                StringUtils.isEmpty(ttInfoDetail.getZdzName()) ||
+                (ttInfoDetail.getBcsj() == null) ) {
+
+            errorCountData.errorcount ++;
+        }
+    }
+
+    @Override
+    public void reverse(Serializable context, Object value) throws Exception {
+        ErrorCountData errorCountData = (ErrorCountData) context;
+        KBaseValidateTimeTable_Fact_TTInfoDetail ttInfoDetail = (KBaseValidateTimeTable_Fact_TTInfoDetail) value;
+
+        if (ttInfoDetail.getTtinfo() == null) {
+            errorCountData.errorcount --;
+            return;
+        }
+
+        if (StringUtils.isEmpty(ttInfoDetail.getQdzCode()) ||
+                StringUtils.isEmpty(ttInfoDetail.getQdzName()) ||
+                StringUtils.isEmpty(ttInfoDetail.getZdzCode()) ||
+                StringUtils.isEmpty(ttInfoDetail.getZdzName()) ) {
+
+            errorCountData.errorcount --;
+        }
+
+    }
+
+    @Override
+    public Object getResult(Serializable context) throws Exception {
+        ErrorCountData errorCountData = (ErrorCountData) context;
+        return errorCountData.errorcount;
+    }
+
+    @Override
+    public boolean supportsReverse() {
+        return true;
+    }
+
+    @Override
+    public Class<?> getResultType() {
+        return Number.class;
+    }
+}
+package com.bsth.service.schedule.plan.process._1_validate._1_timetable.drools;
+
+import java.util.ArrayList;
+import java.util.List;
+
+/**
+ * drools规则验证时刻表输出结果。
+ */
+public class KBaseValidateTimeTable_Result {
+    private List<StatInfo> infos = new ArrayList<>();
+
+    public List<StatInfo> getInfos() {
+        return infos;
+    }
+
+    public void setInfos(List<StatInfo> infos) {
+        this.infos = infos;
+    }
+
+    public static class StatInfo {
+        /** 时刻表id */
+        private Long ttid;
+        /** 时刻表名字 */
+        private String ttname;
+        /** 线路版本 */
+        private Integer lineVersion;
+
+        /** 所有班次数 */
+        private Long allbc;
+        /** 进场班次数 */
+        private Long inbc;
+        /** 出场班次数 */
+        private Long outbc;
+        /** 营运班次数 */
+        private Long yybc;
+
+        /** 错误班次数 */
+        private Long errorbc;
+
+        /** 是否冲突（同一天多张时刻表） */
+        private Boolean conflict;
+        /** 冲突描述（在drools规则中写入） */
+        private String conflictDesc;
+        /** 是否进行了冲突聚合计算（针对drools规则的聚合函数） */
+        private Boolean conflictAccumulate;
+
+        public Long getTtid() {
+            return ttid;
+        }
+
+        public void setTtid(Long ttid) {
+            this.ttid = ttid;
+        }
+
+        public String getTtname() {
+            return ttname;
+        }
+
+        public void setTtname(String ttname) {
+            this.ttname = ttname;
+        }
+
+        public Long getAllbc() {
+            return allbc;
+        }
+
+        public void setAllbc(Long allbc) {
+            this.allbc = allbc;
+        }
+
+        public Long getInbc() {
+            return inbc;
+        }
+
+        public void setInbc(Long inbc) {
+            this.inbc = inbc;
+        }
+
+        public Long getOutbc() {
+            return outbc;
+        }
+
+        public void setOutbc(Long outbc) {
+            this.outbc = outbc;
+        }
+
+        public Long getYybc() {
+            return yybc;
+        }
+
+        public void setYybc(Long yybc) {
+            this.yybc = yybc;
+        }
+
+        public Long getErrorbc() {
+            return errorbc;
+        }
+
+        public void setErrorbc(Long errorbc) {
+            this.errorbc = errorbc;
+        }
+
+        public Integer getLineVersion() {
+            return lineVersion;
+        }
+
+        public void setLineVersion(Integer lineVersion) {
+            this.lineVersion = lineVersion;
+        }
+
+        public Boolean getConflict() {
+            return conflict;
+        }
+
+        public void setConflict(Boolean conflict) {
+            this.conflict = conflict;
+        }
+
+        public String getConflictDesc() {
+            return conflictDesc;
+        }
+
+        public void setConflictDesc(String conflictDesc) {
+            this.conflictDesc = conflictDesc;
+        }
+
+        public Boolean getConflictAccumulate() {
+            return conflictAccumulate;
+        }
+
+        public void setConflictAccumulate(Boolean conflictAccumulate) {
+            this.conflictAccumulate = conflictAccumulate;
+        }
+    }
+}
+package com.bsth.service.schedule.plan.process._1_validate._1_timetable.drools;
+
+import org.joda.time.*;
+import org.joda.time.format.DateTimeFormat;
+import java.util.*;
+import org.apache.commons.lang3.StringUtils;
+
+import com.bsth.service.schedule.plan.process._1_validate._1_timetable.drools.KBaseValidateTimeTable_Fact_CalcuParam;
+import com.bsth.service.schedule.plan.process._1_validate._1_timetable.drools.KBaseValidateTimeTable_Result;
+import com.bsth.service.schedule.plan.process._1_validate._1_timetable.drools.KBaseValidateTimeTable_Result.StatInfo;
+
+import com.bsth.service.schedule.plan.process._1_validate._1_timetable.drools.KBaseValidateTimeTable_Fact_Line;
+import com.bsth.service.schedule.plan.process._1_validate._1_timetable.drools.KBaseValidateTimeTable_Fact_TTInfo;
+import com.bsth.service.schedule.plan.process._1_validate._1_timetable.drools.KBaseValidateTimeTable_Fact_TTInfoDetail;
+
+import org.slf4j.Logger;
+
+// 全局日志类（使用PlanPreValidateServiceImpl里定义的LOGGER）
+global Logger LOGGER;
+
+// 输出
+global KBaseValidateTimeTable_Result rs;
+
+/*
+    规则说明：
+    1、找出指定线路，指定时间范围的时刻表
+    2、统计这些时刻表班次数据的情况
+    3、统计时会计算同一天多张时刻表的情况
+*/
+
+//-------------- 第一阶段、计算规则迭代数据（天数） ------------//
+declare Calcu_iter_days_result
+    xlId: Integer // 线路Id
+    xlName: String // 线路名字
+
+    // 迭代数据
+    calcu_day: Integer // 准备计算第几天
+    calcu_weekday: Integer // 准备计算星期几（1到7）
+    calcu_date: DateTime // 准备计算的具体日期
+
+    // 范围数据
+    calcu_days: Integer // 总共需要计算的天数
+    calcu_start_date: DateTime // 开始计算日期
+    calcu_end_date: DateTime // 结束计算日期
+
+    // 时刻表映射数据
+    ttinfomap: Map // 指定时间段内，用的时刻表id映射 Map<Long, Long>
+end
+
+rule "calcu_iter_days"
+    salience 1900
+    when
+        KBaseValidateTimeTable_Fact_CalcuParam(
+            $xlId: xlId,
+            $fromDate: fromDate,
+            $toDate: toDate,
+            $fromDate.isBefore($toDate) || $fromDate.isEqual($toDate)
+        )
+        $line: KBaseValidateTimeTable_Fact_Line(id == $xlId)
+    then
+        // 构造Calcu_iter_days_result对象，进行下一步计算
+        Calcu_iter_days_result cidr = new Calcu_iter_days_result();
+        Period p = new Period($fromDate, $toDate, PeriodType.days());
+
+        cidr.setXlId($xlId);
+        cidr.setXlName($line.getName());
+
+        cidr.setCalcu_day(new Integer(1));
+        cidr.setCalcu_weekday(Integer.valueOf($fromDate.getDayOfWeek()));
+        cidr.setCalcu_date($fromDate);
+
+        cidr.setCalcu_days(Integer.valueOf(p.getDays() + 1));
+        cidr.setCalcu_start_date($fromDate);
+        cidr.setCalcu_end_date($toDate);
+
+        cidr.setTtinfomap(new HashMap());
+
+        LOGGER.info(
+            "线路={}-id={},开始时间={},结束时间={},总共计算的天数={},将从开始时间迭代",
+            cidr.getXlName(),
+            cidr.getXlId(),
+            cidr.getCalcu_start_date(),
+            cidr.getCalcu_end_date(),
+            cidr.getCalcu_days()
+        );
+
+        insert(cidr);
+end
+
+//-------------- 第二阶段、时刻表的日期匹配 ------------//
+declare TTInfoList_wrap // 时刻表封装对象
+    calcu_date: DateTime // 具体的日期
+    ttInfoNormalList: List // 时刻表列表-平日匹配 List<KBaseValidateTimeTable_Fact_TTInfo>
+    ttInfoSpecialList: List // 时刻表类标-特殊日期匹配 List<KBaseValidateTimeTable_Fact_TTInfo>
+end
+
+rule "Calcu_iter_days_special_day" // 日期匹配
+    salience 800
+    when
+        $cid : Calcu_iter_days_result(
+            $calcu_date: calcu_date,
+            $calcu_weekday: calcu_weekday,
+            $calcu_day: calcu_day,
+            calcu_day <= calcu_days
+        )
+        $ttInfoSpecialList : ArrayList() from collect (
+            KBaseValidateTimeTable_Fact_TTInfo(
+                specialDayList contains $calcu_date
+            )
+        )
+        $ttInfoNormalList : ArrayList() from collect (
+            KBaseValidateTimeTable_Fact_TTInfo(
+                specialDayList not contains $calcu_date,
+                weekdayList[$calcu_weekday - 1] == Boolean.TRUE
+            )
+        )
+    then
+        LOGGER.debug("日期={}, 一般日期匹配时刻表数量={}, 特殊日期时刻表匹配数量={}",
+            $calcu_date, $ttInfoNormalList.size(), $ttInfoSpecialList.size());
+
+        // 插入时刻表封装对象
+        TTInfoList_wrap fact = new TTInfoList_wrap();
+        fact.setCalcu_date(new DateTime($calcu_date));
+        // 注意：如果要赋值List，必须重新建ArrayList，直接用drools的变量有问题
+        List ttInfoNormalList = new ArrayList();
+        ttInfoNormalList.addAll($ttInfoNormalList);
+        fact.setTtInfoNormalList(ttInfoNormalList);
+        // 注意：如果要赋值List，必须重新建ArrayList，直接用drools的变量有问题
+        List ttInfoSpecialList = new ArrayList();
+        ttInfoSpecialList.addAll($ttInfoSpecialList);
+        fact.setTtInfoSpecialList(ttInfoSpecialList);
+
+        insert(fact);
+
+        // 更新迭代对象
+        Integer new_calcu_day = Integer.valueOf($calcu_day + 1);
+        $cid.setCalcu_day(new_calcu_day);
+        DateTime new_calcu_date = $calcu_date.plusDays(1);
+        $cid.setCalcu_date(new_calcu_date);
+        $cid.setCalcu_weekday(Integer.valueOf(new_calcu_date.getDayOfWeek()));
+
+        update($cid);
+end
+
+//----------------- 第三阶段、组装待处理时刻表统计信息 ----------------//
+rule "Calcu_StatInfo_wrap_special_not_conflict" // 当天有特殊日期匹配的时刻表，只有一张
+    salience 750
+    when
+        TTInfoList_wrap(
+            ttInfoSpecialList.size == 1,
+            $calcu_date: calcu_date,
+            $ttInfoSpecialList: ttInfoSpecialList
+        )
+        $ttInfo: KBaseValidateTimeTable_Fact_TTInfo($tid: id, $tname: name, $lineVersion: lineVersion) from $ttInfoSpecialList
+    then
+        LOGGER.debug("特殊日期匹配，同一天单一时刻表：" +
+            "时刻表id={} 日期={}",
+            $tid, $calcu_date);
+
+        StatInfo statInfo = new StatInfo();
+        statInfo.setTtid($tid);
+        statInfo.setTtname($tname);
+        statInfo.setLineVersion($lineVersion);
+        statInfo.setConflict(false);
+        statInfo.setConflictAccumulate(false);
+        insert(statInfo);
+end
+
+rule "Calcu_StatInfo_wrap_special_conflict" // 当天有特殊日期匹配的时刻表, 多张时刻表
+    salience 740
+    when
+        TTInfoList_wrap(
+            ttInfoSpecialList.size > 1,
+            $calcu_date: calcu_date,
+            $ttInfoSpecialList: ttInfoSpecialList
+        )
+        $ttInfo: KBaseValidateTimeTable_Fact_TTInfo($tid: id, $tname: name, $lineVersion: lineVersion) from $ttInfoSpecialList
+    then
+        LOGGER.debug("特殊日期匹配，同一天多张时刻表：" +
+            "时刻表id={} 日期={}",
+            $tid, $calcu_date);
+
+        StatInfo statInfo = new StatInfo();
+        statInfo.setTtid($tid);
+        statInfo.setTtname($tname);
+        statInfo.setLineVersion($lineVersion);
+        statInfo.setConflict(true);
+        statInfo.setConflictDesc("特殊日期冲突_" + $calcu_date.toString("yyyy-MM-dd"));
+        statInfo.setConflictAccumulate(false);
+        insert(statInfo);
+end
+
+rule "Calcu_StatInfo_wrap_normal_not_conflict" // 当天一般日期匹配的时刻表，只有一张
+    salience 730
+    when
+        TTInfoList_wrap(
+            ttInfoSpecialList.size < 1,
+            ttInfoNormalList.size == 1,
+            $calcu_date: calcu_date,
+            $ttInfoNormalList: ttInfoNormalList
+        )
+        $ttInfo: KBaseValidateTimeTable_Fact_TTInfo($tid: id, $tname: name, $lineVersion: lineVersion) from $ttInfoNormalList
+    then
+        LOGGER.debug("一般日期匹配，同一天单一时刻表：" +
+            "时刻表id={} 日期={}",
+            $tid, $calcu_date);
+
+        StatInfo statInfo = new StatInfo();
+        statInfo.setTtid($tid);
+        statInfo.setTtname($tname);
+        statInfo.setLineVersion($lineVersion);
+        statInfo.setConflict(false);
+        statInfo.setConflictAccumulate(false);
+        insert(statInfo);
+end
+
+rule "Calcu_StatInfo_wrap_normal_conflict" // 当天一般日期匹配的时刻表，多张时刻表
+    salience 730
+    when
+        TTInfoList_wrap(
+            ttInfoSpecialList.size < 1,
+            ttInfoNormalList.size > 1,
+            $calcu_date: calcu_date,
+            $ttInfoNormalList: ttInfoNormalList
+        )
+        $ttInfo: KBaseValidateTimeTable_Fact_TTInfo($tid: id, $tname: name, $lineVersion: lineVersion) from $ttInfoNormalList
+    then
+        LOGGER.debug("一般日期匹配，同一天多张时刻表：" +
+            "时刻表id={} 日期={}",
+            $tid, $calcu_date);
+
+        StatInfo statInfo = new StatInfo();
+        statInfo.setTtid($tid);
+        statInfo.setTtname($tname);
+        statInfo.setLineVersion($lineVersion);
+        statInfo.setConflict(true);
+        statInfo.setConflictDesc("一般日期冲突_" + $calcu_date.toString("yyyy-MM-dd"));
+        statInfo.setConflictAccumulate(false);
+        insert(statInfo);
+end
+
+//-------------- 第四阶段、时刻表聚合统计 ------------//
+rule "statinfo_accumulate_conflict" // 聚合统计
+    salience 300
+    no-loop
+    when
+        $accList: List() from accumulate (
+            $statInfo: StatInfo(conflictAccumulate == false),
+            ac($statInfo)
+        )
+        StatInfo(
+            $tid: ttid,
+            $tname: ttname,
+            $lineVersion: lineVersion,
+            $conflict: conflict,
+            $conflictDesc: ConflictDesc) from $accList
+    then
+        LOGGER.info("ttid={}, conflictDesc={}", $tid, $conflictDesc);
+
+        StatInfo statInfo = new StatInfo();
+        statInfo.setTtid($tid);
+        statInfo.setTtname($tname);
+        statInfo.setLineVersion($lineVersion);
+        statInfo.setConflict($conflict);
+        statInfo.setConflictDesc($conflictDesc);
+        statInfo.setConflictAccumulate(true);
+        insert(statInfo);
+end
+
+rule "statinfo_result" // 统计计算结果
+    salience 300
+    no-loop
+    when
+        $statInfo: StatInfo(conflictAccumulate == true, $tid: ttid, $lineVersion: lineVersion, $conflict: conflict, $conflictDesc: conflictDesc)
+        $bcInfoList : ArrayList() from collect (KBaseValidateTimeTable_Fact_TTInfoDetail(ttinfo.id == $tid))
+        $allbc: Long() from accumulate (KBaseValidateTimeTable_Fact_TTInfoDetail() from $bcInfoList, count())
+        $inbc: Long() from accumulate (KBaseValidateTimeTable_Fact_TTInfoDetail(bcType == "in") from $bcInfoList, count())
+        $outbc: Long() from accumulate (KBaseValidateTimeTable_Fact_TTInfoDetail(bcType == "out") from $bcInfoList, count())
+        $yybc: Long() from accumulate (KBaseValidateTimeTable_Fact_TTInfoDetail(bcType != "out", bcType != "in") from $bcInfoList, count())
+        $errorbc: Long() from accumulate ($ttd: KBaseValidateTimeTable_Fact_TTInfoDetail() from $bcInfoList, ecount($ttd))
+    then
+        LOGGER.info("时刻表={},id={},线路版本={},班次数={},进场={},出场={},营运={},错误={},是否冲突={},冲突描述={}",
+            $statInfo.getTtname(), $statInfo.getTtid(), $lineVersion, $allbc, $inbc, $outbc, $yybc, $errorbc, $conflict, $conflictDesc);
+
+        $statInfo.setAllbc($allbc);
+        $statInfo.setInbc($inbc);
+        $statInfo.setOutbc($outbc);
+        $statInfo.setYybc($yybc);
+        $statInfo.setErrorbc($errorbc);
+
+        rs.getInfos().add($statInfo);
+end
+
+
+/*
+rule "test"
+    when
+        $test: TTInfoList_wrap(
+            $calcu_date: calcu_date,
+            $ttInfoNormalList: ttInfoNormalList,
+            $ttInfoSpecialList: ttInfoSpecialList
+        )
+    then
+        LOGGER.debug("日期={}, nsize={}, ssize={}", $calcu_date, $ttInfoNormalList.size(), $ttInfoSpecialList.size());
+
+end
+*/
+package com.bsth.service.schedule.plan.process._1_validate._1_timetable.drools;
+
+import org.joda.time.*;
+import org.joda.time.format.DateTimeFormat;
+import java.util.*;
+import org.apache.commons.lang3.StringUtils;
+
+import com.bsth.service.schedule.plan.process._1_validate._1_timetable.drools.KBaseValidateTimeTable_Fact_CalcuParam;
+import com.bsth.service.schedule.plan.process._1_validate._1_timetable.drools.KBaseValidateTimeTable_Result;
+import com.bsth.service.schedule.plan.process._1_validate._1_timetable.drools.KBaseValidateTimeTable_Result.StatInfo;
+
+import com.bsth.service.schedule.plan.process._1_validate._1_timetable.drools.KBaseValidateTimeTable_Fact_Line;
+import com.bsth.service.schedule.plan.process._1_validate._1_timetable.drools.KBaseValidateTimeTable_Fact_TTInfo;
+import com.bsth.service.schedule.plan.process._1_validate._1_timetable.drools.KBaseValidateTimeTable_Fact_TTInfoDetail;
+
+import org.slf4j.Logger;
+
+// 全局日志类（使用PlanPreValidateServiceImpl里定义的LOGGER）
+global Logger LOGGER;
+
+// 输出
+global KBaseValidateTimeTable_Result rs;
+
+/*
+    规则说明：
+    1、找出指定线路，指定时间范围的时刻表
+    2、统计这些时刻表班次数据的情况
+*/
+
+//-------------- 第一阶段、计算规则迭代数据（天数） ------------//
+declare Calcu_iter_days_result
+    xlId: Integer // 线路Id
+    xlName: String // 线路名字
+
+    // 迭代数据
+    calcu_day: Integer // 准备计算第几天
+    calcu_weekday: Integer // 准备计算星期几（1到7）
+    calcu_date: DateTime // 准备计算的具体日期
+
+    // 范围数据
+    calcu_days: Integer // 总共需要计算的天数
+    calcu_start_date: DateTime // 开始计算日期
+    calcu_end_date: DateTime // 结束计算日期
+
+    // 时刻表映射数据
+    ttinfomap: Map // 指定时间段内，用的时刻表id映射 Map<Long, Long>
+end
+
+rule "calcu_iter_days"
+    salience 1900
+    when
+        KBaseValidateTimeTable_Fact_CalcuParam(
+            $xlId: xlId,
+            $fromDate: fromDate,
+            $toDate: toDate,
+            $fromDate.isBefore($toDate) || $fromDate.isEqual($toDate)
+        )
+        $line: KBaseValidateTimeTable_Fact_Line(id == $xlId)
+    then
+        // 构造Calcu_iter_days_result对象，进行下一步计算
+        Calcu_iter_days_result cidr = new Calcu_iter_days_result();
+        Period p = new Period($fromDate, $toDate, PeriodType.days());
+
+        cidr.setXlId($xlId);
+        cidr.setXlName($line.getName());
+
+        cidr.setCalcu_day(new Integer(1));
+        cidr.setCalcu_weekday(Integer.valueOf($fromDate.getDayOfWeek()));
+        cidr.setCalcu_date($fromDate);
+
+        cidr.setCalcu_days(Integer.valueOf(p.getDays() + 1));
+        cidr.setCalcu_start_date($fromDate);
+        cidr.setCalcu_end_date($toDate);
+
+        cidr.setTtinfomap(new HashMap());
+
+        LOGGER.info(
+            "线路={}-id={},开始时间={},结束时间={},总共计算的天数={},将从开始时间迭代",
+            cidr.getXlName(),
+            cidr.getXlId(),
+            cidr.getCalcu_start_date(),
+            cidr.getCalcu_end_date(),
+            cidr.getCalcu_days()
+        );
+
+        insert(cidr);
+end
+
+//-------------- 第二阶段、时刻表的日期匹配 ------------//
+declare TTInfoDetails_wrap
+    ttInfoId: Long // 时刻表id
+    lineVersion: Integer // 线路版本
+    bcInfoList: List // 班次信息列表 List<KBaseValidateTimeTable_Fact_TTInfoDetail>
+end
+
+rule "Calcu_iter_days_special_day" // 特殊日期匹配（并且不在StatInfo中）
+    salience 800
+    when
+        $cid : Calcu_iter_days_result(
+            $calcu_date: calcu_date,
+            $calcu_day: calcu_day,
+            calcu_day <= calcu_days
+        )
+        KBaseValidateTimeTable_Fact_TTInfo(
+            $tid: id,
+            $tname: name,
+            $lineVersion: lineVersion,
+            specialDayList contains $calcu_date
+        )
+        not StatInfo(ttid == $tid)
+        $bcInfoList : ArrayList() from collect (KBaseValidateTimeTable_Fact_TTInfoDetail(ttinfo.id == $tid))
+    then
+        // 更新迭代对象
+        Integer new_calcu_day = Integer.valueOf($calcu_day + 1);
+        $cid.setCalcu_day(new_calcu_day);
+        DateTime new_calcu_date = $calcu_date.plusDays(1);
+        $cid.setCalcu_date(new_calcu_date);
+        $cid.setCalcu_weekday(Integer.valueOf(new_calcu_date.getDayOfWeek()));
+
+        LOGGER.debug("启用特殊日期时刻表（设置StatInfo）：" +
+            "时刻表id={} 特殊日期={}",
+            $tid, $calcu_date);
+
+        StatInfo statInfo = new StatInfo();
+        statInfo.setTtid($tid);
+        statInfo.setTtname($tname);
+        insert(statInfo);
+
+        TTInfoDetails_wrap ttInfoDetails_wrap = new TTInfoDetails_wrap();
+        ttInfoDetails_wrap.setTtInfoId($tid);
+        ttInfoDetails_wrap.setBcInfoList($bcInfoList);
+        ttInfoDetails_wrap.setLineVersion($lineVersion);
+        insert(ttInfoDetails_wrap);
+
+        update($cid);
+
+end
+
+rule "Calcu_iter_days_special_day_exist" // 特殊日期匹配（已经在StatInfo中）
+    salience 800
+    when
+        $cid : Calcu_iter_days_result(
+            $calcu_date: calcu_date,
+            $calcu_day: calcu_day,
+            calcu_day <= calcu_days
+        )
+        KBaseValidateTimeTable_Fact_TTInfo(
+            $tid: id,
+            $tname: name,
+            $lineVersion: lineVersion,
+            specialDayList contains $calcu_date
+        )
+        StatInfo(ttid == $tid)
+    then
+        // 更新迭代对象
+        Integer new_calcu_day = Integer.valueOf($calcu_day + 1);
+        $cid.setCalcu_day(new_calcu_day);
+        DateTime new_calcu_date = $calcu_date.plusDays(1);
+        $cid.setCalcu_date(new_calcu_date);
+        $cid.setCalcu_weekday(Integer.valueOf(new_calcu_date.getDayOfWeek()));
+
+        LOGGER.debug("启用特殊日期时刻表（已经设置过StatInfo）：" +
+                    "时刻表id={} 特殊日期={}",
+                    $tid, $calcu_date);
+
+        update($cid);
+
+end
+
+rule "Calcu_iter_days_normal_day" // 平日匹配（并且不在StatInfo中）
+    salience 700
+    when
+        $cid : Calcu_iter_days_result(
+            $calcu_date: calcu_date,
+            $calcu_weekday: calcu_weekday,
+            $calcu_day: calcu_day,
+            calcu_day <= calcu_days
+        )
+        KBaseValidateTimeTable_Fact_TTInfo(
+            $tid: id,
+            $tname: name,
+            $lineVersion: lineVersion,
+            specialDayList not contains $calcu_date,
+            weekdayList[$calcu_weekday - 1] == Boolean.TRUE
+        )
+        not StatInfo(ttid == $tid)
+        $bcInfoList : ArrayList() from collect (KBaseValidateTimeTable_Fact_TTInfoDetail(ttinfo.id == $tid))
+    then
+        // 更新迭代对象
+        Integer new_calcu_day = Integer.valueOf($calcu_day + 1);
+        $cid.setCalcu_day(new_calcu_day);
+        DateTime new_calcu_date = $calcu_date.plusDays(1);
+        $cid.setCalcu_date(new_calcu_date);
+        $cid.setCalcu_weekday(Integer.valueOf(new_calcu_date.getDayOfWeek()));
+
+
+        LOGGER.debug("启用常规日期时刻表（设置StatInfo）：" +
+            "时刻表id={} 常规日期={} 星期几={}",
+            $tid, $calcu_date, $calcu_weekday);
+
+        StatInfo statInfo = new StatInfo();
+        statInfo.setTtid($tid);
+        statInfo.setTtname($tname);
+        insert(statInfo);
+
+        TTInfoDetails_wrap ttInfoDetails_wrap = new TTInfoDetails_wrap();
+        ttInfoDetails_wrap.setTtInfoId($tid);
+        ttInfoDetails_wrap.setBcInfoList($bcInfoList);
+        ttInfoDetails_wrap.setLineVersion($lineVersion);
+        insert(ttInfoDetails_wrap);
+
+        update($cid);
+
+end
+
+rule "Calcu_iter_days_normal_day_exist" // 平日匹配（已经在StatInfo中）
+    salience 700
+    when
+        $cid : Calcu_iter_days_result(
+            $calcu_date: calcu_date,
+            $calcu_weekday: calcu_weekday,
+            $calcu_day: calcu_day,
+            calcu_day <= calcu_days
+        )
+        KBaseValidateTimeTable_Fact_TTInfo(
+            $tid: id,
+            $tname: name,
+            $lineVersion: lineVersion,
+            specialDayList not contains $calcu_date,
+            weekdayList[$calcu_weekday - 1] == Boolean.TRUE
+        )
+        StatInfo(ttid == $tid)
+    then
+        // 更新迭代对象
+        Integer new_calcu_day = Integer.valueOf($calcu_day + 1);
+        $cid.setCalcu_day(new_calcu_day);
+        DateTime new_calcu_date = $calcu_date.plusDays(1);
+        $cid.setCalcu_date(new_calcu_date);
+        $cid.setCalcu_weekday(Integer.valueOf(new_calcu_date.getDayOfWeek()));
+
+        LOGGER.debug("启用常规日期时刻表（已经设置过StatInfo）：" +
+                    "时刻表id={} 常规日期={} 星期几={}",
+                    $tid, $calcu_date, $calcu_weekday);
+
+        update($cid);
+
+end
+
+rule "Calcu_iter_days_other_day" // 都没有的情况下，匹配
+    salience 500
+    when
+        $cid : Calcu_iter_days_result(
+            $calcu_date: calcu_date,
+            $calcu_weekday: calcu_weekday,
+            $calcu_day: calcu_day,
+            calcu_day <= calcu_days
+        )
+        not KBaseValidateTimeTable_Fact_TTInfo(
+            (specialDayList contains $calcu_date) ||
+            (weekdayList[$calcu_weekday - 1] == Boolean.TRUE)
+        )
+    then
+        // 更新迭代对象
+        Integer new_calcu_day = Integer.valueOf($calcu_day + 1);
+        $cid.setCalcu_day(new_calcu_day);
+        DateTime new_calcu_date = $calcu_date.plusDays(1);
+        $cid.setCalcu_date(new_calcu_date);
+        $cid.setCalcu_weekday(Integer.valueOf(new_calcu_date.getDayOfWeek()));
+
+        LOGGER.debug("当前日期没有匹配的时刻表：日期={} 星期几={}", $calcu_date, $calcu_weekday);
+
+        update($cid);
+
+end
+
+//-------------- 第三阶段、时刻表明细统计值 ------------//
+
+rule "statinfo_result" // 统计计算结果
+    salience 300
+    no-loop
+    when
+        $statInfo: StatInfo($tid: ttid)
+        $ttInfoDetails_wrap: TTInfoDetails_wrap(ttInfoId == $tid)
+        $allbc: Long() from accumulate (KBaseValidateTimeTable_Fact_TTInfoDetail() from $ttInfoDetails_wrap.getBcInfoList(), count())
+        $inbc: Long() from accumulate (KBaseValidateTimeTable_Fact_TTInfoDetail(bcType == "in") from $ttInfoDetails_wrap.getBcInfoList(), count())
+        $outbc: Long() from accumulate (KBaseValidateTimeTable_Fact_TTInfoDetail(bcType == "out") from $ttInfoDetails_wrap.getBcInfoList(), count())
+        $yybc: Long() from accumulate (KBaseValidateTimeTable_Fact_TTInfoDetail(bcType != "out", bcType != "in") from $ttInfoDetails_wrap.getBcInfoList(), count())
+        $errorbc: Long() from accumulate ($ttd: KBaseValidateTimeTable_Fact_TTInfoDetail() from $ttInfoDetails_wrap.getBcInfoList(), ecount($ttd))
+    then
+        LOGGER.info("时刻表={},id={},班次数={},进场={},出场={},营运={},错误={}", $statInfo.getTtname(), $statInfo.getTtid(), $allbc, $inbc, $outbc, $yybc, $errorbc);
+
+        $statInfo.setAllbc($allbc);
+        $statInfo.setInbc($inbc);
+        $statInfo.setOutbc($outbc);
+        $statInfo.setYybc($yybc);
+        $statInfo.setErrorbc($errorbc);
+
+        int lineVersion = $ttInfoDetails_wrap.getLineVersion();
+        $statInfo.setLineVersion(lineVersion);
+
+        rs.getInfos().add($statInfo);
+
+end
+
+
+
+
+# drools各个kBase的drl路径配置
+#kbase.root.path=/Users/xu/resource/project_code/bsth_project/bsth_control_parent/bsth-control_v2-plan_module-service-schedule_generate/src/main/resources/drools/
+#kbase.root.classpath=drools/
+
+# 排班前置验证规则
+#kbase.validate.timetable.drl=kBase/validate/timetable/kBase_validate_timetable.drl
+#kbase.validate.rule.drl=kBase/validate/rule/kBase_validate_rule.drl
+
+# 排班生成 - 1、计算时刻表相关信息
+#kbase.generate.calcu.timetable.drl=kBase/generate/calcu/timetable/kBase_generate_calcu_timetable.drl
+# 排班生成 - 2、计算排班规则翻班信息
+#kbase.generate.calcu.shiftloop.drl=kBase/generate/calcu/shiftloop/kBase_generate_calcu_shiftloop.drl
+# 排班生成 - 3、组合排班数据
+#kbase.generate.plan.drl=kBase/generate/plan/kBase_generate_plan.drl
+# 排班生成 - 4、套跑规则修正排班数据
+#kbase.generate.rerun.drl=kBase/generate/rerun/kBase_generate_rerun.drl
+# 排班生成 - 5、验证排班数据
+#kbase.validate.plan.drl=kBase/validate/plan/kBase_validate_plan.drl
+
+# 排班前置验证规则
+# 时刻表验证
+drools.KBase.validate_timetable=drools/KBase/validate/timetable/KBase_validate_timetable.drl
+
+
+package com.bsth;
+
+import ch.qos.logback.classic.LoggerContext;
+import ch.qos.logback.classic.joran.JoranConfigurator;
+import ch.qos.logback.core.util.StatusPrinter;
+import org.apache.commons.lang3.StringUtils;
+import org.dbunit.database.DatabaseConfig;
+import org.dbunit.database.DatabaseConnection;
+import org.dbunit.database.DatabaseSequenceFilter;
+import org.dbunit.database.IDatabaseConnection;
+import org.dbunit.dataset.FilteredDataSet;
+import org.dbunit.dataset.IDataSet;
+import org.dbunit.dataset.xml.FlatXmlDataSetBuilder;
+import org.dbunit.ext.h2.H2DataTypeFactory;
+import org.dbunit.operation.DatabaseOperation;
+import org.junit.After;
+import org.junit.Before;
+import org.junit.BeforeClass;
+import org.junit.Rule;
+import org.junit.rules.TestName;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.core.io.ClassPathResource;
+import org.springframework.core.io.Resource;
+
+import javax.sql.DataSource;
+import java.io.File;
+import java.util.Map;
+
+/**
+ * junit4基础测试类。
+ */
+public abstract class BaseTest_junit4 {
+    /** 日志记录器 */
+    public static final Logger LOG = LoggerFactory.getLogger(BaseTest_junit4.class);
+
+    @Rule
+    public TestName name = new TestName();
+
+    @BeforeClass
+    public static void initLogConfig() throws Exception {
+        File logFile = new File(BaseTest_junit4.class.getResource("/logback.xml").toURI());
+        LoggerContext lc = (LoggerContext) LoggerFactory.getILoggerFactory();
+        JoranConfigurator configurator = new JoranConfigurator();
+        configurator.setContext(lc);
+        lc.reset();
+        configurator.doConfigure(logFile);
+        StatusPrinter.printInCaseOfErrorsOrWarnings(lc);
+    }
+
+    /**
+     * 获取DBUnit数据源。
+     * @return
+     */
+    private IDataSet getDataSet() throws Exception {
+        Map<String, String> dbFileMap = getDbunitTestDbFileClassPathMap();
+        String methodName = name.getMethodName();
+        String dbunitClassPath = dbFileMap.get(methodName);
+        if (StringUtils.isEmpty(dbunitClassPath)) {
+            LOG.info("dbunit测试xml为空，key={}", methodName);
+        }
+        Resource res = new ClassPathResource(dbunitClassPath);
+        FlatXmlDataSetBuilder builder = new FlatXmlDataSetBuilder();
+        builder.setColumnSensing(true);
+        return builder.build(res.getInputStream());
+    }
+
+    /**
+     * 获取数据库连接。
+     * @return
+     */
+    private IDatabaseConnection getConnection() throws Exception {
+        DatabaseConnection conn = new DatabaseConnection(getDataSource().getConnection());
+        DatabaseConfig config = conn.getConfig();
+        config.setProperty(DatabaseConfig.PROPERTY_DATATYPE_FACTORY, new H2DataTypeFactory());
+        return conn;
+    }
+
+    /**
+     * 初始化数据。
+     * @throws Exception
+     */
+    @Before
+    public void initDbunitDataSet() throws Exception {
+        LOG.info("junit setup：dbunit-载入测试数据！===>");
+        IDatabaseConnection connection = getConnection();
+        DatabaseOperation.CLEAN_INSERT.execute(connection, getDataSet());
+        connection.close();
+    }
+
+    /**
+     * 销毁测试数据。
+     * @throws Exception
+     */
+    @After
+    public void afterDbunitDataSet() throws Exception {
+        LOG.info("===>junit teardown：dbunit-销毁测试数据！");
+        IDatabaseConnection connection = getConnection();
+        // 使用FilteredDataSet重新定义数据库，否则删除的时候会发生外健依赖错误
+        // 因为默认删除是按照表名字母顺序删除的，如果外健关联的表先删除，则发生外健约束错误
+        IDataSet fullDataSet = new FilteredDataSet(new DatabaseSequenceFilter(connection), connection.createDataSet());
+        DatabaseOperation.DELETE_ALL.execute(connection, fullDataSet);
+        connection.close();
+    }
+
+    @Autowired
+    private DataSource dataSource;
+    /**
+     * 获取数据源。
+     * @return
+     */
+    public DataSource getDataSource() {
+        return dataSource;
+    }
+
+    /**
+     * 获取Dbunit测试数据文件xml映射，key=测试方法名，value=dbunit测试文件classpath
+     * key：子类testCase方法名
+     * value：dbunit数据文件classpath（如：db/testdata/dbunit_testdata1.xml）
+     * @return
+     */
+    public abstract Map<String, String> getDbunitTestDbFileClassPathMap();
+}
+package com.bsth;
+
+import org.springframework.boot.CommandLineRunner;
+import org.springframework.boot.SpringApplication;
+import org.springframework.boot.autoconfigure.SpringBootApplication;
+import org.springframework.context.annotation.ComponentScan;
+import org.springframework.context.annotation.FilterType;
+import org.springframework.transaction.annotation.EnableTransactionManagement;
+
+/**
+ * 测试用的SpringBoot启动类。
+ */
+@EnableTransactionManagement
+@SpringBootApplication
+@ComponentScan(excludeFilters = {
+        @ComponentScan.Filter(
+                type = FilterType.ASSIGNABLE_TYPE,
+                value = { Application.class, StartCommand.class, WebAppConfiguration.class, XDApplication.class }
+        ),
+        @ComponentScan.Filter(
+                type = FilterType.CUSTOM,
+                classes = { TestApplicationTypeFillter.class }
+        )
+})
+public class TestApplication implements CommandLineRunner {
+    @Override
+    public void run(String... args) throws Exception {
+        // TODO：其他初始化代码
+    }
+
+    public static void main(String[] args) throws Exception {
+        SpringApplication.run(TestApplication.class, args);
+    }
+}
+package com.bsth;
+
+import org.springframework.core.io.Resource;
+import org.springframework.core.type.AnnotationMetadata;
+import org.springframework.core.type.ClassMetadata;
+import org.springframework.core.type.classreading.MetadataReader;
+import org.springframework.core.type.classreading.MetadataReaderFactory;
+import org.springframework.core.type.filter.TypeFilter;
+
+import java.io.IOException;
+
+public class TestApplicationTypeFillter implements TypeFilter {
+    private ClassMetadata classMetadata;
+
+    /**
+     * MetadataReader 读取到当前正在扫描类的信息
+     * MetadataReaderFactory 可以获取到其他任何类信息
+     */
+    @Override
+    public boolean match(MetadataReader metadataReader, MetadataReaderFactory metadataReaderFactory) throws IOException {
+        //获取当前类注解的信息
+        AnnotationMetadata annotationMetadata = metadataReader.getAnnotationMetadata();
+        //获取当前正在扫描的类信息
+        classMetadata = metadataReader.getClassMetadata();
+        //获取当前类资源(类的路径)
+        Resource resource = metadataReader.getResource();
+
+        String className = classMetadata.getClassName();
+        System.out.println("----->" + className);
+        //当类包含Buy字符, 则匹配成功,返回true
+        //excludeFilters返回true---->会被过滤掉
+        //includeFilters返回true---->会通过
+//        if (className.contains("Buy")) {
+//            return false;
+//        }
+        if (className.contains("com.bsth.repository")) {
+            return false;
+        }
+        if (className.contains("com.bsth.service.schedule.plan")) {
+            return false;
+        }
+        return true;
+
+    }
+}
+package com.bsth.entity;
+
+import javax.persistence.*;
+import java.util.Date;
+
+/**
+ *
+ * @ClassName : Business(公司实体类)
+ *
+ * @Author : bsth@lq
+ *
+ * @Description : TODO(公司信息)
+ *
+ * @Data : 2016-04-27
+ *
+ * @Version 公交调度系统BS版 0.1
+ *
+ */
+
+@Entity
+@Table(name = "bsth_c_business")
+public class Business {
+
+    // ID
+    @Id
+    @GeneratedValue(strategy = GenerationType.IDENTITY)
+    private Integer id;
+
+    // 企业<公司>名称
+    private String businessName;
+
+    // 企业<公司>代码
+    private String businessCode;
+
+    // 所属企业<公司>代码
+    private String upCode;
+
+    // 描述
+    private String descriptions;
+
+    // 创建日期
+//    @Column(updatable = false, name = "create_date", columnDefinition = "TIMESTAMP DEFAULT CURRENT_TIMESTAMP")
+    @Column(updatable = false, name = "create_date")
+    private Date createDate;
+
+    // 修改日期
+//    @Column(name = "update_date", columnDefinition = "timestamp  DEFAULT CURRENT_TIMESTAMP ON UPDATE CURRENT_TIMESTAMP")
+    @Column(name = "update_date")
+    private Date updateDate;
+    public Date getCreateDate() {
+        return createDate;
+    }
+
+    public void setCreateDate(Date createDate) {
+        this.createDate = createDate;
+    }
+
+    public Date getUpdateDate() {
+        return updateDate;
+    }
+
+    public void setUpdateDate(Date updateDate) {
+        this.updateDate = updateDate;
+    }
+
+    public Integer getId() {
+        return id;
+    }
+
+    public void setId(Integer id) {
+        this.id = id;
+    }
+
+    public String getBusinessName() {
+        return businessName;
+    }
+
+    public void setBusinessName(String businessName) {
+        this.businessName = businessName;
+    }
+
+    public String getBusinessCode() {
+        return businessCode;
+    }
+
+    public void setBusinessCode(String businessCode) {
+        this.businessCode = businessCode;
+    }
+
+    public String getUpCode() {
+        return upCode;
+    }
+
+    public void setUpCode(String upCode) {
+        this.upCode = upCode;
+    }
+
+    public String getDescriptions() {
+        return descriptions;
+    }
+
+    public void setDescriptions(String descriptions) {
+        this.descriptions = descriptions;
+    }
+}
+package com.bsth.entity;
+
+import com.fasterxml.jackson.annotation.JsonIgnoreProperties;
+import org.hibernate.annotations.Formula;
+
+import javax.persistence.*;
+import java.util.Date;
+
+
+/**
+ *
+ * @ClassName: CarPark(停车场类)
+ *
+ * @Description: TODO(停车场)
+ *
+ * @Author bsth@lq
+ *
+ * @Date 2016-06-01 16:06:17
+ *
+ * @Version 公交调度系统BS版 0.1
+ *
+ */
+
+@Entity
+@Table(name = "bsth_c_car_park")
+@JsonIgnoreProperties(value={"hibernateLazyInitializer","handler","fieldHandler"})
+public class CarPark {
+
+    @Id
+    @GeneratedValue
+    private Integer id;
+
+    // 停车场编号
+    private String parkCode;
+
+    // 停车场名称
+    private String parkName;
+
+    // 地理位置(百度坐标)
+    private String bParkPoint;
+
+    // 地理位置中心点(百度坐标)
+    private String bCenterPoint;
+
+    // 地理位置(WGS坐标)
+    private String gParkPoint;
+
+    // 地理位置中心点(WGS坐标)
+    private String gCenterPoint;
+
+    /**
+     * 经纬坐标类型
+     *
+     * --------- b：百度坐标系
+     *
+     * --------- d：高德坐标系
+     */
+    private String dbType;
+
+    /**
+     * 图形类型
+     *
+     * ------ r：圆形
+     *
+     * ------ p：多边形
+     */
+    private String shapesType;
+
+    // 圆形半径
+    private Integer radius;
+
+    // 面积
+    private double area;
+
+    // 所属公司
+    private String company;
+
+    // 分公司
+    private String brancheCompany;
+
+    /** 组合公司分公司编码 */
+    @Formula(" concat(company, '_', branche_company) ")
+    private String cgsbm;
+
+    // 是否撤销
+    private Integer destroy;
+
+    // 版本号
+    private Integer versions;
+
+    // 描述
+    private String descriptions;
+
+    // 创建人
+    private Integer createBy;
+
+    // 修改人
+    private Integer updateBy;
+
+    // 创建日期
+//    @Column(updatable = false, name = "create_date", columnDefinition = "TIMESTAMP DEFAULT CURRENT_TIMESTAMP")
+    @Column(updatable = false, name = "create_date")
+    private Date createDate;
+
+    // 修改日期
+//    @Column(name = "update_date", columnDefinition = "TIMESTAMP  DEFAULT CURRENT_TIMESTAMP ON UPDATE CURRENT_TIMESTAMP")
+    @Column(name = "update_date")
+    private Date updateDate;
+
+    public String getCgsbm() {
+        return cgsbm;
+    }
+
+    public void setCgsbm(String cgsbm) {
+        this.cgsbm = cgsbm;
+    }
+
+    public Integer getId() {
+        return id;
+    }
+
+    public void setId(Integer id) {
+        this.id = id;
+    }
+
+    public String getParkCode() {
+        return parkCode;
+    }
+
+    public void setParkCode(String parkCode) {
+        this.parkCode = parkCode;
+    }
+
+    public String getParkName() {
+        return parkName;
+    }
+
+    public void setParkName(String parkName) {
+        this.parkName = parkName;
+    }
+
+    public String getbParkPoint() {
+        return bParkPoint;
+    }
+
+    public void setbParkPoint(String bParkPoint) {
+        this.bParkPoint = bParkPoint;
+    }
+
+    public String getbCenterPoint() {
+        return bCenterPoint;
+    }
+
+    public void setbCenterPoint(String bCenterPoint) {
+        this.bCenterPoint = bCenterPoint;
+    }
+
+    public String getgParkPoint() {
+        return gParkPoint;
+    }
+
+    public void setgParkPoint(String gParkPoint) {
+        this.gParkPoint = gParkPoint;
+    }
+
+    public String getDbType() {
+        return dbType;
+    }
+
+    public void setDbType(String dbType) {
+        this.dbType = dbType;
+    }
+
+    public String getShapesType() {
+        return shapesType;
+    }
+
+    public void setShapesType(String shapesType) {
+        this.shapesType = shapesType;
+    }
+
+    public Integer getRadius() {
+        return radius;
+    }
+
+    public void setRadius(Integer radius) {
+        this.radius = radius;
+    }
+
+    public String getgCenterPoint() {
+        return gCenterPoint;
+    }
+
+    public void setgCenterPoint(String gCenterPoint) {
+        this.gCenterPoint = gCenterPoint;
+    }
+
+    public double getArea() {
+        return area;
+    }
+
+    public void setArea(double area) {
+        this.area = area;
+    }
+
+    public String getBrancheCompany() {
+        return brancheCompany;
+    }
+
+    public void setBrancheCompany(String brancheCompany) {
+        this.brancheCompany = brancheCompany;
+    }
+
+    public String getCompany() {
+        return company;
+    }
+
+    public void setCompany(String company) {
+        this.company = company;
+    }
+
+    public Integer getDestroy() {
+        return destroy;
+    }
+
+    public void setDestroy(Integer destroy) {
+        this.destroy = destroy;
+    }
+
+    public Integer getVersions() {
+        return versions;
+    }
+
+    public void setVersions(Integer versions) {
+        this.versions = versions;
+    }
+
+    public String getDescriptions() {
+        return descriptions;
+    }
+
+    public void setDescriptions(String descriptions) {
+        this.descriptions = descriptions;
+    }
+
+    public Integer getCreateBy() {
+        return createBy;
+    }
+
+    public void setCreateBy(Integer createBy) {
+        this.createBy = createBy;
+    }
+
+    public Integer getUpdateBy() {
+        return updateBy;
+    }
+
+    public void setUpdateBy(Integer updateBy) {
+        this.updateBy = updateBy;
+    }
+
+    public Date getCreateDate() {
+        return createDate;
+    }
+
+    public void setCreateDate(Date createDate) {
+        this.createDate = createDate;
+    }
+
+    public Date getUpdateDate() {
+        return updateDate;
+    }
+
+    public void setUpdateDate(Date updateDate) {
+        this.updateDate = updateDate;
+    }
+
+}
+package com.bsth.entity;
+
+import com.fasterxml.jackson.annotation.JsonIgnoreProperties;
+import org.hibernate.annotations.Formula;
+import org.springframework.format.annotation.DateTimeFormat;
+
+import javax.persistence.*;
+import java.io.Serializable;
+import java.util.Date;
+
+
+/**
+ *
+ * @ClassName: Line(线路实体类)
+ *
+ * @Description: TODO(线路)
+ *
+ * @Author bsth@lq
+ *
+ * @Date 2016-4-11 16:06:17
+ *
+ * @Version 公交调度系统BS版 0.1
+ *
+ */
+
+@Entity
+@Table(name = "bsth_c_line")
+@JsonIgnoreProperties(value={"hibernateLazyInitializer","handler","fieldHandler"})
+public class Line implements Serializable {
+
+    @Id
+    /** 线路ID 主键(唯一标识符) int length(11) */
+    private Integer id;
+
+    /** 线路名称  varchar length(50) 不能为空 */
+    private String name;
+
+    /** 线路编码 varchar length(50) 不能为空 */
+    private String lineCode;
+
+    /** 英文名  varchar length(50)  */
+    private String es;
+
+    /** 简称 varchar length(50) */
+    private String shortName;
+
+    /** 起始站名称 varchar length(50) 不能为空
+     *  该字段值会在规划线路站点操作时会去验证是否有值。如果为空，则用线路规划站点的起点站。默认使用该字段填写值 */
+    private String  startStationName;
+
+    /** 终点站名称 varchar length(50) 不能为空
+     *  该字段值会在规划线路站点操作时会去验证是否有值。如果为空，则用线路规划站点的起点站。默认使用该字段填写值 */
+    private String endStationName;
+
+    /** 起始站首班车时间 00:00 上海公交APP中某个接口所需要的字段值 varchar length(50) 不能为空 */
+    private String startStationFirstTime;
+
+    /** 起始站末班车时间 00:00 上海公交APP中某个接口所需要的字段值 varchar length(50) 不能为空 */
+    private String startStationEndTime;
+
+    /** 终点站首班时间 00:00 上海公交APP中某个接口所需要的字段值 varchar length(50) 不能为空*/
+    private String endStationFirstTime;
+
+    /** 终点站末班时间 00:00 上海公交APP中某个接口所需要的字段值 */
+    private String endStationEndTime;
+
+    /** 所属公司 varchar length(50) */
+    private String company;
+
+    /** 分公司  varchar length(50)*/
+    private String brancheCompany;
+
+    /** 组合公司分公司编码 */
+    @Formula(" concat(company, '_', branche_company) ")
+    private String cgsbm;
+
+    /** 性质(线路类型) varchar length(50) */
+    private String nature;
+
+    /** 线路等级 varchar length(50) */
+    private String level;
+
+    /** 线路长度 */
+    private double length;
+
+    /** 线路负责人 varchar length(50) */
+    private String chargeName;
+
+    /** 负责人电话 varchar length(50) */
+    private String telephone;
+
+    /** 是否撤销 <1:是;0:否> bit length(50) */
+    private Integer destroy;
+
+    /** 是否夜宵线   <1:是;0:否> bit length(50)*/
+    private Integer supperLine;
+
+    /** 是否营运   <1:是;0:否> bit length(50)*/
+    private Integer sfyy;
+
+    /** 线路区域 <0：区内，1：区外> bit length(1)*/
+    private Integer region;
+
+    /** 起始调度电话 varchar length(50) */
+    private String startPhone;
+
+    /** 终点调度电话  varchar length(50) */
+    private String endPhone;
+
+    /** 开辟日期 date*/
+    @DateTimeFormat(pattern ="yyyy-MM-dd")
+    private Date openDate;
+
+    /** 大间隔等级 */
+    private Integer spacGrade;
+
+    /** 线路沿革 varchar length(50) */
+    private String history;
+
+    /** 上海市线路编码 varchar length(50) */
+    private String shanghaiLinecode;
+
+    /** 设备线路编码 varchar length(50) */
+    private String eqLinecode;
+
+    /** 配置车辆总数   老版本系统字段， 新版本系统业务需求暂时没用到该字段 ，这里暂时留着 int length(11)*/
+    private Integer carSumNumber;
+
+    /** 空调车辆数量   老版本系统字段， 新版本系统业务需求暂时没用到该字段 ，这里暂时留着 int length(11) */
+    private Integer hvacCarNumber;
+
+    /** 普通车辆数量   老版本系统字段， 新版本系统业务需求暂时没用到该字段 ，这里暂时留着 int length(11) */
+    private Integer ordCarNumber;
+
+    /** 权证车辆数量  报表需要的字段值 */
+    private Integer warrantCar;
+
+    /** 权证配车启用日期  报表需要的字段值 */
+    private Integer warrantDate;
+
+    /** 停车场编码   老版本系统字段， 新版本系统业务需求暂时没用到该字段 ，这里暂时留着 int length(11) */
+    private String carParkCode;
+
+    /** 线路规划类型 <0:双向;1:环线> int length(11) 运管处接口需要的字段 不能为空 */
+    private Integer linePlayType;
+
+    /** 描述 varchar length(255) */
+    private String descriptions;
+
+    /** 创建人 int length(11) */
+    private Integer createBy;
+
+    /** 修改人 int length(11) */
+    private Integer updateBy;
+
+    /** 创建日期 timestamp  */
+//    @Column(updatable = false, name = "create_date", columnDefinition = "TIMESTAMP DEFAULT CURRENT_TIMESTAMP")
+    @Column(updatable = false, name = "create_date")
+    private Date createDate;
+
+    /** 修改日期 timestamp */
+//    @Column(name = "update_date", columnDefinition = "TIMESTAMP  DEFAULT CURRENT_TIMESTAMP ON UPDATE CURRENT_TIMESTAMP")
+    @Column(name = "update_date")
+    private Date updateDate;
+
+    /** 是否在使用 <1:是;0:否> bit length(50) */
+    private Integer inUse;
+
+    /**
+     * 逻辑删除标记 为 1：标识已删除
+     */
+    private Integer remove = 0;
+
+    public Integer getSpacGrade() {
+        return spacGrade;
+    }
+
+    public void setSpacGrade(Integer spacGrade) {
+        this.spacGrade = spacGrade;
+    }
+
+    public Integer getWarrantCar() {
+        return warrantCar;
+    }
+
+    public void setWarrantCar(Integer warrantCar) {
+        this.warrantCar = warrantCar;
+    }
+
+    public Integer getWarrantDate() {
+        return warrantDate;
+    }
+
+    public void setWarrantDate(Integer warrantDate) {
+        this.warrantDate = warrantDate;
+    }
+
+    public Integer getLinePlayType() {
+        return linePlayType;
+    }
+
+    public void setLinePlayType(Integer linePlayType) {
+        this.linePlayType = linePlayType;
+    }
+
+    public Integer getId() {
+        return id;
+    }
+
+    public void setId(Integer id) {
+        this.id = id;
+    }
+
+    public String getLineCode() {
+        return lineCode;
+    }
+
+    public void setLineCode(String lineCode) {
+        this.lineCode = lineCode;
+    }
+
+    public String getName() {
+        return name;
+    }
+
+    public void setName(String name) {
+        this.name = name;
+    }
+
+    public String getEs() {
+        return es;
+    }
+
+    public void setEs(String es) {
+        this.es = es;
+    }
+
+    public String getShortName() {
+        return shortName;
+    }
+
+    public void setShortName(String shortName) {
+        this.shortName = shortName;
+    }
+
+    public Integer getCarSumNumber() {
+        return carSumNumber;
+    }
+
+    public void setCarSumNumber(Integer carSumNumber) {
+        this.carSumNumber = carSumNumber;
+    }
+
+    public Integer getHvacCarNumber() {
+        return hvacCarNumber;
+    }
+
+    public void setHvacCarNumber(Integer hvacCarNumber) {
+        this.hvacCarNumber = hvacCarNumber;
+    }
+
+    public Integer getOrdCarNumber() {
+        return ordCarNumber;
+    }
+
+    public void setOrdCarNumber(Integer ordCarNumber) {
+        this.ordCarNumber = ordCarNumber;
+    }
+
+    public String getCarParkCode() {
+        return carParkCode;
+    }
+
+    public void setCarParkCode(String carParkCode) {
+        this.carParkCode = carParkCode;
+    }
+
+    public String getStartStationName() {
+        return startStationName;
+    }
+
+    public void setStartStationName(String startStationName) {
+        this.startStationName = startStationName;
+    }
+
+    public String getStartStationFirstTime() {
+        return startStationFirstTime;
+    }
+
+    public void setStartStationFirstTime(String startStationFirstTime) {
+        this.startStationFirstTime = startStationFirstTime;
+    }
+
+    public String getStartStationEndTime() {
+        return startStationEndTime;
+    }
+
+    public void setStartStationEndTime(String startStationEndTime) {
+        this.startStationEndTime = startStationEndTime;
+    }
+
+    public String getEndStationName() {
+        return endStationName;
+    }
+
+    public void setEndStationName(String endStationName) {
+        this.endStationName = endStationName;
+    }
+
+    public String getEndStationFirstTime() {
+        return endStationFirstTime;
+    }
+
+    public void setEndStationFirstTime(String endStationFirstTime) {
+        this.endStationFirstTime = endStationFirstTime;
+    }
+
+    public String getEndStationEndTime() {
+        return endStationEndTime;
+    }
+
+    public void setEndStationEndTime(String endStationEndTime) {
+        this.endStationEndTime = endStationEndTime;
+    }
+
+    public String getCompany() {
+        return company;
+    }
+
+    public void setCompany(String company) {
+        this.company = company;
+    }
+
+    public String getBrancheCompany() {
+        return brancheCompany;
+    }
+
+    public void setBrancheCompany(String brancheCompany) {
+        this.brancheCompany = brancheCompany;
+    }
+
+    public String getNature() {
+        return nature;
+    }
+
+    public void setNature(String nature) {
+        this.nature = nature;
+    }
+
+    public String getLevel() {
+        return level;
+    }
+
+    public void setLevel(String level) {
+        this.level = level;
+    }
+
+    public double getLength() {
+        return length;
+    }
+
+    public void setLength(double length) {
+        this.length = length;
+    }
+
+    public String getChargeName() {
+        return chargeName;
+    }
+
+    public void setChargeName(String chargeName) {
+        this.chargeName = chargeName;
+    }
+
+    public String getTelephone() {
+        return telephone;
+    }
+
+    public void setTelephone(String telephone) {
+        this.telephone = telephone;
+    }
+
+    public Integer getDestroy() {
+        return destroy;
+    }
+
+    public void setDestroy(Integer destroy) {
+        this.destroy = destroy;
+    }
+
+    public Integer getSupperLine() {
+        return supperLine;
+    }
+
+    public void setSupperLine(Integer supperLine) {
+        this.supperLine = supperLine;
+    }
+
+    public String getStartPhone() {
+        return startPhone;
+    }
+
+    public void setStartPhone(String startPhone) {
+        this.startPhone = startPhone;
+    }
+
+    public String getEndPhone() {
+        return endPhone;
+    }
+
+    public void setEndPhone(String endPhone) {
+        this.endPhone = endPhone;
+    }
+
+    public Date getOpenDate() {
+        return openDate;
+    }
+
+    public void setOpenDate(Date openDate) {
+        this.openDate = openDate;
+    }
+
+    public String getHistory() {
+        return history;
+    }
+
+    public void setHistory(String history) {
+        this.history = history;
+    }
+
+    public String getShanghaiLinecode() {
+        return shanghaiLinecode;
+    }
+
+    public void setShanghaiLinecode(String shanghaiLinecode) {
+        this.shanghaiLinecode = shanghaiLinecode;
+    }
+
+    public String getEqLinecode() {
+        return eqLinecode;
+    }
+
+    public void setEqLinecode(String eqLinecode) {
+        this.eqLinecode = eqLinecode;
+    }
+
+    public String getDescriptions() {
+        return descriptions;
+    }
+
+    public void setDescriptions(String descriptions) {
+        this.descriptions = descriptions;
+    }
+
+    public Integer getCreateBy() {
+        return createBy;
+    }
+
+    public void setCreateBy(Integer createBy) {
+        this.createBy = createBy;
+    }
+
+    public Integer getUpdateBy() {
+        return updateBy;
+    }
+
+    public void setUpdateBy(Integer updateBy) {
+        this.updateBy = updateBy;
+    }
+
+    public Date getCreateDate() {
+        return createDate;
+    }
+
+    public void setCreateDate(Date createDate) {
+        this.createDate = createDate;
+    }
+
+    public Date getUpdateDate() {
+        return updateDate;
+    }
+
+    public void setUpdateDate(Date updateDate) {
+        this.updateDate = updateDate;
+    }
+
+    public Integer getInUse() { return inUse; }
+
+    public void setInUse(Integer inUse) { this.inUse = inUse; }
+
+    public String getCgsbm() {
+        return cgsbm;
+    }
+
+    public void setCgsbm(String cgsbm) {
+        this.cgsbm = cgsbm;
+    }
+
+    public Integer getSfyy() {
+        return sfyy;
+    }
+
+    public void setSfyy(Integer sfyy) {
+        this.sfyy = sfyy;
+    }
+
+    public Integer getRegion() {
+        return region;
+    }
+
+    public void setRegion(Integer region) {
+        this.region = region;
+    }
+
+    public Integer getRemove() {
+        return remove;
+    }
+
+    public void setRemove(Integer remove) {
+        this.remove = remove;
+    }
+}
+package com.bsth.entity;
+
+import javax.persistence.*;
+import java.util.Date;
+
+/**
+ *
+ * @ClassName: LineInformation(线路标准信息实体类)
+ *
+ * @Description: TODO(线路标准信息)
+ *
+ * @Author bsth@lq
+ *
+ * @Date 2016-4-12 9:34:39
+ *
+ * @Version 公交调度系统BS版 0.1
+ *
+ */
+@Entity
+@Table(name = "bsth_c_line_information")
+public class LineInformation {
+
+    @Id
+    @GeneratedValue(strategy = GenerationType.IDENTITY)
+    private Integer id;
+
+    // 线路标准信息类型
+    private String type;
+
+    // 标准总里程
+    private Double totalMileage;
+
+    // 空放里程
+    private Double emptyMileage;
+
+    // 上行里程
+    private Double upMileage;
+
+    // 下行里程
+    private Double downMileage;
+
+    // 上行行驶时间
+    private Double upTravelTime;
+
+    // 下行行驶时间
+    private Double downTravelTime;
+
+    // 早高峰开始时间 00:00
+    private String earlyStartTime;
+
+    // 早高峰结束时间 00:00
+    private String earlyEndTime;
+
+    // 晚高峰开始时间 00:00
+    private String lateStartTime;
+
+    // 晚高峰结束时间 00:00
+    private String lateEndTime;
+
+    // 小夜高峰开始时间 00:00
+    private String xygfkssj;
+
+    // 小夜高峰结束时间 00:00
+    private String xygfjssj;
+
+    // 早高峰上行行驶时间
+    private Double earlyUpTime;
+
+    // 早高峰下行行驶时间
+    private Double earlyDownTime;
+
+    // 晚高峰上行行驶时间
+    private Double lateUpTime;
+
+    // 晚高峰下行行驶时间
+    private Double lateDownTime;
+
+    // 小夜高峰上行行驶时间
+    private Double nightStartTime;
+
+    // 小夜高峰下行行驶时间
+    private Double nightEndTime;
+
+    // 低谷上行行驶时间
+    private Double troughUpTime;
+
+    // 低谷下行行驶时间
+    private Double troughDownTime;
+
+    // 停车场
+    private String carPark;
+
+    // 上行进场时间
+    private Double upInTimer;
+
+    // 上行出场时间
+    private Double upOutTimer;
+
+    // 下行进场时间
+    private Double downInTimer;
+
+    // 下行出场时间
+    private Double downOutTimer;
+
+    // 上行进场里程
+    private Double upInMileage;
+
+    // 上行出场里程
+    private Double upOutMileage;
+
+    // 下行进场里程
+    private Double downInMileage;
+
+    // 下行出场里程
+    private Double downOutMileage;
+
+    // 早高峰大间隔（分钟）老调度系统字段,暂时保留
+    private Double earlyIntervalLg;
+
+    // 晚高峰大间隔（分钟）老调度系统字段,暂时保留
+    private Double lateIntervalLg;
+
+    // 平时大间隔（分钟）老调度系统字段,暂时保留
+    private Double intervalLg;
+
+    // 限速（平时）老调度系统字段,暂时保留
+    private Double speedLimit;
+
+    // 限速（雨天）老调度系统字段,暂时保留
+    private Double rainLimit;
+
+    // 限速（大雾）老调度系统字段,暂时保留
+    private Double fogLimit;
+
+    // 限速（冰雪）老调度系统字段,暂时保留
+    private Double snowLimit;
+
+    // 限速（节庆）老调度系统字段,暂时保留
+    private Double festivalSpeedLimit;
+
+    // 滞站
+    private Integer lagStation;
+
+    // 越站
+    private Integer skip;
+
+    // 超速
+    private Integer speeding;
+
+    // 串线
+    private Integer  crossedLine;
+
+    // 越界
+    private Integer overflights;
+
+    // 描述
+    private String descriptions;
+
+    // 创建人
+    private Integer createBy;
+
+    // 修改人
+    private Integer updateBy;
+
+    // 创建日期
+//    @Column(updatable = false, name = "create_date", columnDefinition = "TIMESTAMP DEFAULT CURRENT_TIMESTAMP")
+    @Column(updatable = false, name = "create_date")
+    private Date createDate;
+
+    // 修改日期
+//    @Column(name = "update_date", columnDefinition = "timestamp  DEFAULT CURRENT_TIMESTAMP ON UPDATE CURRENT_TIMESTAMP")
+    @Column(name = "update_date")
+    private Date updateDate;
+
+    @ManyToOne
+    private Line line;
+
+    public String getXygfkssj() {
+        return xygfkssj;
+    }
+
+    public void setXygfkssj(String xygfkssj) {
+        this.xygfkssj = xygfkssj;
+    }
+
+    public String getXygfjssj() {
+        return xygfjssj;
+    }
+
+    public void setXygfjssj(String xygfjssj) {
+        this.xygfjssj = xygfjssj;
+    }
+
+    public Double getUpInTimer() {
+        return upInTimer;
+    }
+
+    public void setUpInTimer(Double upInTimer) {
+        this.upInTimer = upInTimer;
+    }
+
+    public Double getUpOutTimer() {
+        return upOutTimer;
+    }
+
+    public void setUpOutTimer(Double upOutTimer) {
+        this.upOutTimer = upOutTimer;
+    }
+
+    public Double getDownInTimer() {
+        return downInTimer;
+    }
+
+    public void setDownInTimer(Double downInTimer) {
+        this.downInTimer = downInTimer;
+    }
+
+    public Double getDownOutTimer() {
+        return downOutTimer;
+    }
+
+    public void setDownOutTimer(Double downOutTimer) {
+        this.downOutTimer = downOutTimer;
+    }
+
+    public Double getUpInMileage() {
+        return upInMileage;
+    }
+
+    public void setUpInMileage(Double upInMileage) {
+        this.upInMileage = upInMileage;
+    }
+
+    public Double getUpOutMileage() {
+        return upOutMileage;
+    }
+
+    public void setUpOutMileage(Double upOutMileage) {
+        this.upOutMileage = upOutMileage;
+    }
+
+    public Double getDownInMileage() {
+        return downInMileage;
+    }
+
+    public void setDownInMileage(Double downInMileage) {
+        this.downInMileage = downInMileage;
+    }
+
+    public Double getDownOutMileage() {
+        return downOutMileage;
+    }
+
+    public void setDownOutMileage(Double downOutMileage) {
+        this.downOutMileage = downOutMileage;
+    }
+
+    public Integer getId() {
+        return id;
+    }
+
+    public void setId(Integer id) {
+        this.id = id;
+    }
+
+    public String getType() {
+        return type;
+    }
+
+    public void setType(String type) {
+        this.type = type;
+    }
+
+    public Double getTotalMileage() {
+        return totalMileage;
+    }
+
+    public void setTotalMileage(Double totalMileage) {
+        this.totalMileage = totalMileage;
+    }
+
+    public Double getEmptyMileage() {
+        return emptyMileage;
+    }
+
+    public void setEmptyMileage(Double emptyMileage) {
+        this.emptyMileage = emptyMileage;
+    }
+
+    public Double getUpMileage() {
+        return upMileage;
+    }
+
+    public void setUpMileage(Double upMileage) {
+        this.upMileage = upMileage;
+    }
+
+    public Double getDownMileage() {
+        return downMileage;
+    }
+
+    public void setDownMileage(Double downMileage) {
+        this.downMileage = downMileage;
+    }
+
+    public Double getUpTravelTime() {
+        return upTravelTime;
+    }
+
+    public void setUpTravelTime(Double upTravelTime) {
+        this.upTravelTime = upTravelTime;
+    }
+
+    public Double getDownTravelTime() {
+        return downTravelTime;
+    }
+
+    public void setDownTravelTime(Double downTravelTime) {
+        this.downTravelTime = downTravelTime;
+    }
+
+    public String getEarlyStartTime() {
+        return earlyStartTime;
+    }
+
+    public void setEarlyStartTime(String earlyStartTime) {
+        this.earlyStartTime = earlyStartTime;
+    }
+
+    public String getEarlyEndTime() {
+        return earlyEndTime;
+    }
+
+    public void setEarlyEndTime(String earlyEndTime) {
+        this.earlyEndTime = earlyEndTime;
+    }
+
+    public String getLateStartTime() {
+        return lateStartTime;
+    }
+
+    public void setLateStartTime(String lateStartTime) {
+        this.lateStartTime = lateStartTime;
+    }
+
+    public String getLateEndTime() {
+        return lateEndTime;
+    }
+
+    public void setLateEndTime(String lateEndTime) {
+        this.lateEndTime = lateEndTime;
+    }
+
+    public Double getEarlyUpTime() {
+        return earlyUpTime;
+    }
+
+    public void setEarlyUpTime(Double earlyUpTime) {
+        this.earlyUpTime = earlyUpTime;
+    }
+
+    public Double getEarlyDownTime() {
+        return earlyDownTime;
+    }
+
+    public void setEarlyDownTime(Double earlyDownTime) {
+        this.earlyDownTime = earlyDownTime;
+    }
+
+    public Double getLateUpTime() {
+        return lateUpTime;
+    }
+
+    public void setLateUpTime(Double lateUpTime) {
+        this.lateUpTime = lateUpTime;
+    }
+
+    public Double getLateDownTime() {
+        return lateDownTime;
+    }
+
+    public void setLateDownTime(Double lateDownTime) {
+        this.lateDownTime = lateDownTime;
+    }
+
+    public Double getNightStartTime() {
+        return nightStartTime;
+    }
+
+    public void setNightStartTime(Double nightStartTime) {
+        this.nightStartTime = nightStartTime;
+    }
+
+    public Double getNightEndTime() {
+        return nightEndTime;
+    }
+
+    public void setNightEndTime(Double nightEndTime) {
+        this.nightEndTime = nightEndTime;
+    }
+
+    public Double getTroughUpTime() {
+        return troughUpTime;
+    }
+
+    public void setTroughUpTime(Double troughUpTime) {
+        this.troughUpTime = troughUpTime;
+    }
+
+    public Double getTroughDownTime() {
+        return troughDownTime;
+    }
+
+    public void setTroughDownTime(Double troughDownTime) {
+        this.troughDownTime = troughDownTime;
+    }
+    public String getCarPark() {
+        return carPark;
+    }
+
+    public void setCarPark(String carPark) {
+        this.carPark = carPark;
+    }
+    public Double getEarlyIntervalLg() {
+        return earlyIntervalLg;
+    }
+
+    public void setEarlyIntervalLg(Double earlyIntervalLg) {
+        this.earlyIntervalLg = earlyIntervalLg;
+    }
+
+    public Double getLateIntervalLg() {
+        return lateIntervalLg;
+    }
+
+    public void setLateIntervalLg(Double lateIntervalLg) {
+        this.lateIntervalLg = lateIntervalLg;
+    }
+
+    public Double getIntervalLg() {
+        return intervalLg;
+    }
+
+    public void setIntervalLg(Double intervalLg) {
+        this.intervalLg = intervalLg;
+    }
+
+    public Double getSpeedLimit() {
+        return speedLimit;
+    }
+
+    public void setSpeedLimit(Double speedLimit) {
+        this.speedLimit = speedLimit;
+    }
+
+    public Double getRainLimit() {
+        return rainLimit;
+    }
+
+    public void setRainLimit(Double rainLimit) {
+        this.rainLimit = rainLimit;
+    }
+
+    public Double getFogLimit() {
+        return fogLimit;
+    }
+
+    public void setFogLimit(Double fogLimit) {
+        this.fogLimit = fogLimit;
+    }
+
+    public Double getSnowLimit() {
+        return snowLimit;
+    }
+
+    public void setSnowLimit(Double snowLimit) {
+        this.snowLimit = snowLimit;
+    }
+
+    public Double getFestivalSpeedLimit() {
+        return festivalSpeedLimit;
+    }
+
+    public void setFestivalSpeedLimit(Double festivalSpeedLimit) {
+        this.festivalSpeedLimit = festivalSpeedLimit;
+    }
+
+    public Integer getLagStation() {
+        return lagStation;
+    }
+
+    public void setLagStation(Integer lagStation) {
+        this.lagStation = lagStation;
+    }
+
+    public Integer getSkip() {
+        return skip;
+    }
+
+    public void setSkip(Integer skip) {
+        this.skip = skip;
+    }
+
+    public Integer getSpeeding() {
+        return speeding;
+    }
+
+    public void setSpeeding(Integer speeding) {
+        this.speeding = speeding;
+    }
+
+    public Integer getCrossedLine() {
+        return crossedLine;
+    }
+
+    public void setCrossedLine(Integer crossedLine) {
+        this.crossedLine = crossedLine;
+    }
+
+    public Integer getOverflights() {
+        return overflights;
+    }
+
+    public void setOverflights(Integer overflights) {
+        this.overflights = overflights;
+    }
+
+    public String getDescriptions() {
+        return descriptions;
+    }
+
+    public void setDescriptions(String descriptions) {
+        this.descriptions = descriptions;
+    }
+
+    public Integer getCreateBy() {
+        return createBy;
+    }
+
+    public void setCreateBy(Integer createBy) {
+        this.createBy = createBy;
+    }
+
+    public Integer getUpdateBy() {
+        return updateBy;
+    }
+
+    public void setUpdateBy(Integer updateBy) {
+        this.updateBy = updateBy;
+    }
+
+    public Date getCreateDate() {
+        return createDate;
+    }
+
+    public void setCreateDate(Date createDate) {
+        this.createDate = createDate;
+    }
+
+    public Date getUpdateDate() {
+        return updateDate;
+    }
+
+    public void setUpdateDate(Date updateDate) {
+        this.updateDate = updateDate;
+    }
+
+    public Line getLine() {
+        return line;
+    }
+
+    public void setLine(Line line) {
+        this.line = line;
+    }
+}
+package com.bsth.entity;
+
+import javax.persistence.*;
+import java.util.Date;
+
+
+/**
+ *
+ * @ClassName: LineVersions(线路版本实体类)
+ *
+ * @Description: TODO(线路版本)
+ *
+ * @Author bsth@lq
+ *
+ * @Version 公交调度系统BS版 0.1
+ *
+ */
+
+@Entity
+@Table(name = "bsth_c_line_versions")
+public class LineVersions{
+
+    @Id
+    @GeneratedValue(strategy = GenerationType.IDENTITY)
+    /** ID 主键(唯一标识符) int length(11) */
+    private Integer id;
+
+    /** 线路版本名字 varchar length(50)
+     * 	给排版人员选版本使用
+     *  */
+    private String name;
+
+    /** 线路ID  int length(11) */
+    @ManyToOne
+    private Line line;
+
+    /** 线路编码 varchar length(50) */
+    private String lineCode;
+
+    /** 版本号  int length(11)  */
+    private int versions;
+
+    /** 启用日期 timestamp  */
+    private Date startDate;
+
+    /** 终止日期 timestamp  */
+    private Date endDate;
+
+    /** 创建日期 timestamp  */
+//    @Column(updatable = false, name = "create_date", columnDefinition = "TIMESTAMP DEFAULT CURRENT_TIMESTAMP")
+    @Column(updatable = false, name = "create_date")
+    private Date createDate;
+
+    /** 修改日期 timestamp */
+//    @Column(name = "update_date", columnDefinition = "TIMESTAMP  DEFAULT CURRENT_TIMESTAMP ON UPDATE CURRENT_TIMESTAMP")
+    @Column(name = "update_date")
+    private Date updateDate;
+
+    /** 备注 varchar length(50) */
+    private String remark;
+
+    /** 版本状态 int length(11)
+     *  0（历史版本），1（当前版本），2（待更新版本）
+     */
+    private int status;
+
+    /**
+     * 是否发布 int length(1)
+     * 0（没有），1（发布）
+     */
+    private int isupdate = 0;
+
+    public Integer getId() {
+        return id;
+    }
+
+    public void setId(Integer id) {
+        this.id = id;
+    }
+
+    public String getName() {
+        return name;
+    }
+
+    public void setName(String name) {
+        this.name = name;
+    }
+
+    public Line getLine() {
+        return line;
+    }
+
+    public void setLine(Line line) {
+        this.line = line;
+    }
+
+    public String getLineCode() {
+        return lineCode;
+    }
+
+    public void setLineCode(String lineCode) {
+        this.lineCode = lineCode;
+    }
+
+    public int getVersions() {
+        return versions;
+    }
+
+    public void setVersions(int versions) {
+        this.versions = versions;
+    }
+
+    public Date getStartDate() {
+        return startDate;
+    }
+
+    public void setStartDate(Date startDate) {
+        this.startDate = startDate;
+    }
+
+    public Date getEndDate() {
+        return endDate;
+    }
+
+    public void setEndDate(Date endDate) {
+        this.endDate = endDate;
+    }
+
+    public Date getCreateDate() {
+        return createDate;
+    }
+
+    public void setCreateDate(Date createDate) {
+        this.createDate = createDate;
+    }
+
+    public Date getUpdateDate() {
+        return updateDate;
+    }
+
+    public void setUpdateDate(Date updateDate) {
+        this.updateDate = updateDate;
+    }
+
+    public String getRemark() {
+        return remark;
+    }
+
+    public void setRemark(String remark) {
+        this.remark = remark;
+    }
+
+    public int getStatus() {
+        return status;
+    }
+
+    public void setStatus(int status) {
+        this.status = status;
+    }
+
+    public int getIsupdate() {
+        return isupdate;
+    }
+
+    public void setIsupdate(int isupdate) {
+        this.isupdate = isupdate;
+    }
+
+}
+package com.bsth.entity;
+
+import javax.persistence.*;
+import java.util.Date;
+
+
+/**
+ *
+ * @ClassName : SectionRoute(历史路段路由实体类)
+ *
+ * @Author : bsth@lq
+ *
+ * @Description : TODO(历史路段路由)
+ *
+ * @Version 公交调度系统BS版 0.1
+ *
+ */
+
+@Entity
+@Table(name = "bsth_c_ls_sectionroute")
+public class LsSectionRoute {
+
+    @Id
+    @GeneratedValue(strategy = GenerationType.IDENTITY)
+    private Integer id;
+
+    // 路段路由序号
+    private Integer sectionrouteCode;
+
+    // 线路编号
+    private String lineCode;
+
+    // 路段编号
+    private String sectionCode;
+
+    // 路段路由方向
+    private Integer directions;
+
+    // 版本号
+    private Integer versions;
+
+    // 是否撤销
+    private Integer destroy;
+
+    /** 是否有路段限速数据  <0：分段；1：未分段>*/
+    private Integer isRoadeSpeed;
+
+    // 描述
+    private String descriptions;
+
+    // 创建人
+    private Integer createBy;
+
+    // 修改人
+    private Integer updateBy;
+
+    // 创建日期
+//    @Column(updatable = false, name = "create_date", columnDefinition = "TIMESTAMP DEFAULT CURRENT_TIMESTAMP")
+    @Column(updatable = false, name = "create_date")
+    private Date createDate;
+
+    // 修改日期
+//    @Column(name = "update_date", columnDefinition = "timestamp  DEFAULT CURRENT_TIMESTAMP ON UPDATE CURRENT_TIMESTAMP")
+    @Column(name = "update_date")
+    private Date updateDate;
+
+    // 路段信息
+    @OneToOne
+    private Section section;
+
+    // 线路信息
+    @ManyToOne
+    private Line line;
+
+    public Integer getIsRoadeSpeed() {
+        return isRoadeSpeed;
+    }
+
+    public void setIsRoadeSpeed(Integer isRoadeSpeed) {
+        this.isRoadeSpeed = isRoadeSpeed;
+    }
+
+    public Integer getId() {
+        return id;
+    }
+
+    public void setId(Integer id) {
+        this.id = id;
+    }
+
+    public Integer getSectionrouteCode() {
+        return sectionrouteCode;
+    }
+
+    public void setSectionrouteCode(Integer sectionrouteCode) {
+        this.sectionrouteCode = sectionrouteCode;
+    }
+
+    public String getLineCode() {
+        return lineCode;
+    }
+
+    public void setLineCode(String lineCode) {
+        this.lineCode = lineCode;
+    }
+
+    public String getSectionCode() {
+        return sectionCode;
+    }
+
+    public void setSectionCode(String sectionCode) {
+        this.sectionCode = sectionCode;
+    }
+
+    public Integer getDirections() {
+        return directions;
+    }
+
+    public void setDirections(Integer directions) {
+        this.directions = directions;
+    }
+
+    public Integer getVersions() {
+        return versions;
+    }
+
+    public void setVersions(Integer versions) {
+        this.versions = versions;
+    }
+
+    public Integer getDestroy() {
+        return destroy;
+    }
+
+    public void setDestroy(Integer destroy) {
+        this.destroy = destroy;
+    }
+
+    public String getDescriptions() {
+        return descriptions;
+    }
+
+    public void setDescriptions(String descriptions) {
+        this.descriptions = descriptions;
+    }
+
+    public Integer getCreateBy() {
+        return createBy;
+    }
+
+    public void setCreateBy(Integer createBy) {
+        this.createBy = createBy;
+    }
+
+    public Integer getUpdateBy() {
+        return updateBy;
+    }
+
+    public void setUpdateBy(Integer updateBy) {
+        this.updateBy = updateBy;
+    }
+
+    public Date getCreateDate() {
+        return createDate;
+    }
+
+    public void setCreateDate(Date createDate) {
+        this.createDate = createDate;
+    }
+
+    public Date getUpdateDate() {
+        return updateDate;
+    }
+
+    public void setUpdateDate(Date updateDate) {
+        this.updateDate = updateDate;
+    }
+
+    public Section getSection() {
+        return section;
+    }
+
+    public void setSection(Section section) {
+        this.section = section;
+    }
+
+    public Line getLine() {
+        return line;
+    }
+
+    public void setLine(Line line) {
+        this.line = line;
+    }
+}
+package com.bsth.entity;
+
+import javax.persistence.*;
+import java.util.Date;
+
+/**
+ *
+ * @ClassName : StationRoute(历史站点路由实体类)
+ *
+ * @Author : bsth@lq
+ *
+ * @Description : TODO(历史站点路由)
+ *
+ * @Version 公交调度系统BS版 0.1
+ *
+ */
+
+@Entity
+@Table(name = "bsth_c_ls_stationroute")
+@NamedEntityGraphs({
+        @NamedEntityGraph(name = "ls_stationRoute_station", attributeNodes = {
+                @NamedAttributeNode("station"),
+                @NamedAttributeNode("line")
+        })
+})
+public class LsStationRoute {
+
+    //站点路由ID
+    @Id
+    @GeneratedValue(strategy = GenerationType.IDENTITY)
+    private Integer id;
+
+    // 站点路由序号
+    private Integer stationRouteCode;
+
+    // 站点编码
+    private String stationCode;
+
+    // 站点名称
+    private String stationName;
+
+    // 线路编码
+    private String lineCode;
+
+    // 行业编码
+    private String industryCode;
+    /**
+     * 站点类型
+     *
+     * ------ B：起点站
+     *
+     * ------ Z：中途站
+     *
+     * ------ E：终点站
+     *
+     * ------ T：停车场
+     *
+     */
+    private String stationMark;
+
+    // 站点路由出站序号
+    private Integer outStationNmber;
+
+    // 站点路由到站距离
+    private Double distances;
+
+    // 站点路由到站时间
+    private Double toTime;
+
+    // 首班时间
+    private String firstTime;
+
+    // 末班时间
+    private String endTime;
+
+    // 站点路由方向
+    private Integer directions;
+
+    // 版本号
+    private Integer versions;
+
+    // 是否撤销
+    private Integer destroy;
+
+    // 描述
+    private String descriptions;
+
+    // 创建人
+    private Integer createBy;
+
+    // 修改人
+    private Integer updateBy;
+
+    // 创建日期
+//    @Column(updatable = false, name = "create_date", columnDefinition = "TIMESTAMP DEFAULT CURRENT_TIMESTAMP")
+    @Column(updatable = false, name = "create_date")
+    private Date createDate;
+
+    // 修改日期
+//    @Column(name = "update_date", columnDefinition = "timestamp  DEFAULT CURRENT_TIMESTAMP ON UPDATE CURRENT_TIMESTAMP")
+    @Column(name = "update_date")
+    private Date updateDate;
+
+    // 站点信息
+    @ManyToOne(fetch = FetchType.LAZY)
+    private Station station;
+
+    // 线路信息
+    @ManyToOne
+    private Line line;
+
+    public Integer getId() {
+        return id;
+    }
+
+    public void setId(Integer id) {
+        this.id = id;
+    }
+
+    public Integer getStationRouteCode() {
+        return stationRouteCode;
+    }
+
+    public void setStationRouteCode(Integer stationRouteCode) {
+        this.stationRouteCode = stationRouteCode;
+    }
+
+    public String getStationCode() {
+        return stationCode;
+    }
+
+    public void setStationCode(String stationCode) {
+        this.stationCode = stationCode;
+    }
+
+    public String getStationName() {
+        return stationName;
+    }
+
+    public void setStationName(String stationName) {
+        this.stationName = stationName;
+    }
+
+    public String getLineCode() {
+        return lineCode;
+    }
+
+    public void setLineCode(String lineCode) {
+        this.lineCode = lineCode;
+    }
+
+    public String getIndustryCode() {
+        return industryCode;
+    }
+
+    public void setIndustryCode(String industryCode) {
+        this.industryCode = industryCode;
+    }
+
+    public String getStationMark() {
+        return stationMark;
+    }
+
+    public void setStationMark(String stationMark) {
+        this.stationMark = stationMark;
+    }
+
+    public Integer getOutStationNmber() {
+        return outStationNmber;
+    }
+
+    public void setOutStationNmber(Integer outStationNmber) {
+        this.outStationNmber = outStationNmber;
+    }
+
+    public Double getDistances() {
+        return distances;
+    }
+
+    public void setDistances(Double distances) {
+        this.distances = distances;
+    }
+
+    public Double getToTime() {
+        return toTime;
+    }
+
+    public void setToTime(Double toTime) {
+        this.toTime = toTime;
+    }
+
+    public String getFirstTime() {
+        return firstTime;
+    }
+
+    public void setFirstTime(String firstTime) {
+        this.firstTime = firstTime;
+    }
+
+    public String getEndTime() {
+        return endTime;
+    }
+
+    public void setEndTime(String endTime) {
+        this.endTime = endTime;
+    }
+
+    public Integer getDirections() {
+        return directions;
+    }
+
+    public void setDirections(Integer directions) {
+        this.directions = directions;
+    }
+
+    public Integer getVersions() {
+        return versions;
+    }
+
+    public void setVersions(Integer versions) {
+        this.versions = versions;
+    }
+
+    public Integer getDestroy() {
+        return destroy;
+    }
+
+    public void setDestroy(Integer destroy) {
+        this.destroy = destroy;
+    }
+
+    public String getDescriptions() {
+        return descriptions;
+    }
+
+    public void setDescriptions(String descriptions) {
+        this.descriptions = descriptions;
+    }
+
+    public Integer getCreateBy() {
+        return createBy;
+    }
+
+    public void setCreateBy(Integer createBy) {
+        this.createBy = createBy;
+    }
+
+    public Integer getUpdateBy() {
+        return updateBy;
+    }
+
+    public void setUpdateBy(Integer updateBy) {
+        this.updateBy = updateBy;
+    }
+
+    public Date getCreateDate() {
+        return createDate;
+    }
+
+    public void setCreateDate(Date createDate) {
+        this.createDate = createDate;
+    }
+
+    public Date getUpdateDate() {
+        return updateDate;
+    }
+
+    public void setUpdateDate(Date updateDate) {
+        this.updateDate = updateDate;
+    }
+
+    public Station getStation() {
+        return station;
+    }
+
+    public void setStation(Station station) {
+        this.station = station;
+    }
+
+    public Line getLine() {
+        return line;
+    }
+
+    public void setLine(Line line) {
+        this.line = line;
+    }
+}
+package com.bsth.entity;
+
+import javax.persistence.*;
+import java.util.Date;
+
+@Entity
+@Table(name = "bsth_c_road_speed")
+public class RoadSpeed {
+
+    @Id
+    @GeneratedValue(strategy = GenerationType.IDENTITY)
+    private Integer id;
+
+    // 路段名称
+    private String name;
+
+    // 路段矢量(空间坐标点集合)--GPS坐标点
+    private String bRoadVector;
+
+    // 路段矢量(空间坐标点集合)--百度坐标点
+    private String gRoadVector;
+
+    // 限速 （km/h）
+    private Double speed;
+
+    // 限速开始时间
+    private String speedStartDate;
+
+    // 限速结束时间
+    private String speedEndDate;
+
+    // 是否启用限速（0：启用、1：未启用）
+    private int isStart;
+
+    // 预留字段(限速的线路)
+    private String line;
+
+    // 创建日期 timestamp
+//    @Column(updatable = false, name = "create_date", columnDefinition = "TIMESTAMP DEFAULT CURRENT_TIMESTAMP")
+    @Column(updatable = false, name = "create_date")
+    private Date createDate;
+
+    // 修改日期 timestamp
+//    @Column(name = "update_date", columnDefinition = "TIMESTAMP  DEFAULT CURRENT_TIMESTAMP ON UPDATE CURRENT_TIMESTAMP")
+    @Column(name = "update_date")
+    private Date updateDate;
+
+    public Integer getId() {
+        return id;
+    }
+
+    public String getName() {
+        return name;
+    }
+
+    public String getbRoadVector() {
+        return bRoadVector;
+    }
+
+    public String getgRoadVector() {
+        return gRoadVector;
+    }
+
+    public Double getSpeed() {
+        return speed;
+    }
+
+    public String getSpeedStartDate() {
+        return speedStartDate;
+    }
+
+    public String getSpeedEndDate() {
+        return speedEndDate;
+    }
+
+    public int getIsStart() {
+        return isStart;
+    }
+
+    public String getLine() {
+        return line;
+    }
+
+    public Date getCreateDate() {
+        return createDate;
+    }
+
+    public Date getUpdateDate() {
+        return updateDate;
+    }
+
+    public void setId(Integer id) {
+        this.id = id;
+    }
+
+    public void setName(String name) {
+        this.name = name;
+    }
+
+    public void setbRoadVector(String bRoadVector) {
+        this.bRoadVector = bRoadVector;
+    }
+
+    public void setgRoadVector(String gRoadVector) {
+        this.gRoadVector = gRoadVector;
+    }
+
+    public void setSpeed(Double speed) {
+        this.speed = speed;
+    }
+
+    public void setSpeedStartDate(String speedStartDate) {
+        this.speedStartDate = speedStartDate;
+    }
+
+    public void setSpeedEndDate(String speedEndDate) {
+        this.speedEndDate = speedEndDate;
+    }
+
+    public void setIsStart(int isStart) {
+        this.isStart = isStart;
+    }
+
+    public void setLine(String line) {
+        this.line = line;
+    }
+
+    public void setCreateDate(Date createDate) {
+        this.createDate = createDate;
+    }
+
+    public void setUpdateDate(Date updateDate) {
+        this.updateDate = updateDate;
+    }
+
+    @Override
+    public String toString() {
+        return "RoadSpeed [id=" + id + ", name=" + name + ", bRoadVector=" + bRoadVector + ", gRoadVector="
+                + gRoadVector + ", speed=" + speed + ", speedStartDate=" + speedStartDate + ", speedEndDate="
+                + speedEndDate + ", isStart=" + isStart + ", line=" + line + ", createDate=" + createDate
+                + ", updateDate=" + updateDate + "]";
+    }
+
+
+}
+package com.bsth.entity;
+
+import javax.persistence.Column;
+import javax.persistence.Entity;
+import javax.persistence.Id;
+import javax.persistence.Table;
+import java.util.Date;
+
+/**
+ *
+ * @ClassName : Section(路段实体类)
+ *
+ * @Author : bsth@lq
+ *
+ * @Description : TODO(路段)
+ *
+ * @Data :2016-04-21
+ *
+ * @Version 公交调度系统BS版 0.1
+ *
+ */
+
+@Entity
+@Table(name = "bsth_c_section")
+public class Section {
+
+    @Id
+    /*@GeneratedValue(strategy = GenerationType.IDENTITY)*/
+    private Integer id;
+
+    // 路段编码
+    private String sectionCode;
+
+    // 道路编码
+    private String roadCoding;
+
+    // 路段名称
+    private String sectionName;
+
+    // 路段距离
+    private Double sectionDistance;
+
+    // 路段时间
+    private Double sectionTime;
+
+    // 经纬坐标类型
+    private String dbType;
+
+    // 路段类型
+    private String sectionType;
+
+    // 路段矢量(空间坐标点集合)--GPS坐标点
+    private String gsectionVector;
+
+    // 路段矢量(空间坐标点集合)--百度原始坐标坐标点
+    private String bsectionVector;
+
+    // 路段矢量(空间坐标点集合)--城建坐标点
+    private String csectionVector;
+
+    // 交叉路
+    private String crosesRoad;
+
+    // 起始节点
+    private String startNode;
+
+    // 中间节点
+    private String middleNode;
+
+    // 终止节点
+    private String endNode;
+
+    // 限速
+    private Double speedLimit;
+
+    // 版本号
+    private Integer versions;
+
+    // 描述
+    private String descriptions;
+
+    // 创建人
+    private Integer createBy;
+
+    // 修改人
+    private Integer updateBy;
+
+    // 创建日期
+//    @Column(updatable = false, name = "create_date", columnDefinition = "TIMESTAMP DEFAULT CURRENT_TIMESTAMP")
+    @Column(updatable = false, name = "create_date")
+    private Date createDate;
+
+    // 修改日期
+//    @Column(name = "update_date", columnDefinition = "timestamp  DEFAULT CURRENT_TIMESTAMP ON UPDATE CURRENT_TIMESTAMP")
+    @Column(name = "update_date")
+    private Date updateDate;
+
+    public Integer getId() {
+        return id;
+    }
+
+    public void setId(Integer id) {
+        this.id = id;
+    }
+
+    public String getSectionCode() {
+        return sectionCode;
+    }
+
+    public void setSectionCode(String sectionCode) {
+        this.sectionCode = sectionCode;
+    }
+
+    public String getRoadCoding() {
+        return roadCoding;
+    }
+
+    public void setRoadCoding(String roadCoding) {
+        this.roadCoding = roadCoding;
+    }
+
+    public String getSectionName() {
+        return sectionName;
+    }
+
+    public void setSectionName(String sectionName) {
+        this.sectionName = sectionName;
+    }
+
+    public Double getSectionDistance() {
+        return sectionDistance;
+    }
+
+    public void setSectionDistance(Double sectionDistance) {
+        this.sectionDistance = sectionDistance;
+    }
+
+    public Double getSectionTime() {
+        return sectionTime;
+    }
+
+    public void setSectionTime(Double sectionTime) {
+        this.sectionTime = sectionTime;
+    }
+
+    public String getDbType() {
+        return dbType;
+    }
+
+    public void setDbType(String dbType) {
+        this.dbType = dbType;
+    }
+
+    public String getSectionType() {
+        return sectionType;
+    }
+
+    public void setSectionType(String sectionType) {
+        this.sectionType = sectionType;
+    }
+
+    public String getGsectionVector() {
+        return gsectionVector;
+    }
+
+    public void setGsectionVector(String gsectionVector) {
+        this.gsectionVector = gsectionVector;
+    }
+
+    public String getBsectionVector() {
+        return bsectionVector;
+    }
+
+    public void setBsectionVector(String bsectionVector) {
+        this.bsectionVector = bsectionVector;
+    }
+
+    public String getCsectionVector() {
+        return csectionVector;
+    }
+
+    public void setCsectionVector(String csectionVector) {
+        this.csectionVector = csectionVector;
+    }
+
+    public String getCrosesRoad() {
+        return crosesRoad;
+    }
+
+    public void setCrosesRoad(String crosesRoad) {
+        this.crosesRoad = crosesRoad;
+    }
+
+    public String getStartNode() {
+        return startNode;
+    }
+
+    public void setStartNode(String startNode) {
+        this.startNode = startNode;
+    }
+
+    public String getMiddleNode() {
+        return middleNode;
+    }
+
+    public void setMiddleNode(String middleNode) {
+        this.middleNode = middleNode;
+    }
+
+    public String getEndNode() {
+        return endNode;
+    }
+
+    public void setEndNode(String endNode) {
+        this.endNode = endNode;
+    }
+
+    public Double getSpeedLimit() {
+        return speedLimit;
+    }
+
+    public void setSpeedLimit(Double speedLimit) {
+        this.speedLimit = speedLimit;
+    }
+
+    public Integer getVersions() {
+        return versions;
+    }
+
+    public void setVersions(Integer versions) {
+        this.versions = versions;
+    }
+
+    public String getDescriptions() {
+        return descriptions;
+    }
+
+    public void setDescriptions(String descriptions) {
+        this.descriptions = descriptions;
+    }
+
+    public Integer getCreateBy() {
+        return createBy;
+    }
+
+    public void setCreateBy(Integer createBy) {
+        this.createBy = createBy;
+    }
+
+    public Integer getUpdateBy() {
+        return updateBy;
+    }
+
+    public void setUpdateBy(Integer updateBy) {
+        this.updateBy = updateBy;
+    }
+
+    public Date getCreateDate() {
+        return createDate;
+    }
+
+    public void setCreateDate(Date createDate) {
+        this.createDate = createDate;
+    }
+
+    public Date getUpdateDate() {
+        return updateDate;
+    }
+
+    public void setUpdateDate(Date updateDate) {
+        this.updateDate = updateDate;
+    }
+}
+package com.bsth.entity;
+
+import javax.persistence.*;
+import java.util.Date;
+
+
+/**
+ *
+ * @ClassName : SectionRoute(路段路由实体类)
+ *
+ * @Author : bsth@lq
+ *
+ * @Description : TODO(路段路由)
+ *
+ * @Data :2016-04-21
+ *
+ * @Version 公交调度系统BS版 0.1
+ *
+ */
+
+@Entity
+@Table(name = "bsth_c_sectionroute")
+public class SectionRoute {
+
+    @Id
+    @GeneratedValue(strategy = GenerationType.IDENTITY)
+    private Integer id;
+
+    // 路段路由序号
+    private Integer sectionrouteCode;
+
+    // 线路编号
+    private String lineCode;
+
+    // 路段编号
+    private String sectionCode;
+
+    // 路段路由方向
+    private Integer directions;
+
+    // 版本号
+    private Integer versions;
+
+    // 是否撤销
+    private Integer destroy;
+
+    /** 是否有路段限速数据  <0：分段；1：未分段>*/
+    private Integer isRoadeSpeed;
+
+    // 描述
+    private String descriptions;
+
+    // 创建人
+    private Integer createBy;
+
+    // 修改人
+    private Integer updateBy;
+
+    // 创建日期
+//    @Column(updatable = false, name = "create_date", columnDefinition = "TIMESTAMP DEFAULT CURRENT_TIMESTAMP")
+    @Column(updatable = false, name = "create_date")
+    private Date createDate;
+
+    // 修改日期
+//    @Column(name = "update_date", columnDefinition = "timestamp  DEFAULT CURRENT_TIMESTAMP ON UPDATE CURRENT_TIMESTAMP")
+    @Column(name = "update_date")
+    private Date updateDate;
+
+    // 路段信息
+    @OneToOne
+    private Section section;
+
+    // 线路信息
+    @ManyToOne
+    private Line line;
+
+    public Integer getIsRoadeSpeed() {
+        return isRoadeSpeed;
+    }
+
+    public void setIsRoadeSpeed(Integer isRoadeSpeed) {
+        this.isRoadeSpeed = isRoadeSpeed;
+    }
+
+    public Integer getId() {
+        return id;
+    }
+
+    public void setId(Integer id) {
+        this.id = id;
+    }
+
+    public Integer getSectionrouteCode() {
+        return sectionrouteCode;
+    }
+
+    public void setSectionrouteCode(Integer sectionrouteCode) {
+        this.sectionrouteCode = sectionrouteCode;
+    }
+
+    public String getLineCode() {
+        return lineCode;
+    }
+
+    public void setLineCode(String lineCode) {
+        this.lineCode = lineCode;
+    }
+
+    public String getSectionCode() {
+        return sectionCode;
+    }
+
+    public void setSectionCode(String sectionCode) {
+        this.sectionCode = sectionCode;
+    }
+
+    public Integer getDirections() {
+        return directions;
+    }
+
+    public void setDirections(Integer directions) {
+        this.directions = directions;
+    }
+
+    public Integer getVersions() {
+        return versions;
+    }
+
+    public void setVersions(Integer versions) {
+        this.versions = versions;
+    }
+
+    public Integer getDestroy() {
+        return destroy;
+    }
+
+    public void setDestroy(Integer destroy) {
+        this.destroy = destroy;
+    }
+
+    public String getDescriptions() {
+        return descriptions;
+    }
+
+    public void setDescriptions(String descriptions) {
+        this.descriptions = descriptions;
+    }
+
+    public Integer getCreateBy() {
+        return createBy;
+    }
+
+    public void setCreateBy(Integer createBy) {
+        this.createBy = createBy;
+    }
+
+    public Integer getUpdateBy() {
+        return updateBy;
+    }
+
+    public void setUpdateBy(Integer updateBy) {
+        this.updateBy = updateBy;
+    }
+
+    public Date getCreateDate() {
+        return createDate;
+    }
+
+    public void setCreateDate(Date createDate) {
+        this.createDate = createDate;
+    }
+
+    public Date getUpdateDate() {
+        return updateDate;
+    }
+
+    public void setUpdateDate(Date updateDate) {
+        this.updateDate = updateDate;
+    }
+
+    public Section getSection() {
+        return section;
+    }
+
+    public void setSection(Section section) {
+        this.section = section;
+    }
+
+    public Line getLine() {
+        return line;
+    }
+
+    public void setLine(Line line) {
+        this.line = line;
+    }
+}
+package com.bsth.entity;
+
+import javax.persistence.*;
+import java.util.Date;
+
+
+/**
+ *
+ * @ClassName : SectionRoute(路段路由缓存实体类)
+ *
+ * @Author : bsth@lq
+ *
+ * @Description : TODO(路段路由)
+ *
+ * @Data :2016-04-21
+ *
+ * @Version 公交调度系统BS版 0.1
+ *
+ */
+
+@Entity
+@Table(name = "bsth_c_sectionroute_cache")
+public class SectionRouteCache {
+
+    @Id
+    @GeneratedValue(strategy = GenerationType.IDENTITY)
+    private Integer id;
+
+    // 路段路由序号
+    private Integer sectionrouteCode;
+
+    // 线路编号
+    private String lineCode;
+
+    // 路段编号
+    private String sectionCode;
+
+    // 路段路由方向
+    private Integer directions;
+
+    // 版本号
+    private Integer versions;
+
+    // 是否撤销
+    private Integer destroy;
+
+    /** 是否有路段限速数据  <0：分段；1：未分段>*/
+    private Integer isRoadeSpeed;
+
+    // 描述
+    private String descriptions;
+
+    // 创建人
+    private Integer createBy;
+
+    // 修改人
+    private Integer updateBy;
+
+    // 创建日期
+//    @Column(updatable = false, name = "create_date", columnDefinition = "TIMESTAMP DEFAULT CURRENT_TIMESTAMP")
+    @Column(updatable = false, name = "create_date")
+    private Date createDate;
+
+    // 修改日期
+//    @Column(name = "update_date", columnDefinition = "timestamp  DEFAULT CURRENT_TIMESTAMP ON UPDATE CURRENT_TIMESTAMP")
+    @Column(name = "update_date")
+    private Date updateDate;
+
+    // 路段信息
+    @OneToOne
+    private Section section;
+
+    // 线路信息
+    @ManyToOne
+    private Line line;
+
+    public Integer getIsRoadeSpeed() {
+        return isRoadeSpeed;
+    }
+
+    public void setIsRoadeSpeed(Integer isRoadeSpeed) {
+        this.isRoadeSpeed = isRoadeSpeed;
+    }
+
+    public Integer getId() {
+        return id;
+    }
+
+    public void setId(Integer id) {
+        this.id = id;
+    }
+
+    public Integer getSectionrouteCode() {
+        return sectionrouteCode;
+    }
+
+    public void setSectionrouteCode(Integer sectionrouteCode) {
+        this.sectionrouteCode = sectionrouteCode;
+    }
+
+    public String getLineCode() {
+        return lineCode;
+    }
+
+    public void setLineCode(String lineCode) {
+        this.lineCode = lineCode;
+    }
+
+    public String getSectionCode() {
+        return sectionCode;
+    }
+
+    public void setSectionCode(String sectionCode) {
+        this.sectionCode = sectionCode;
+    }
+
+    public Integer getDirections() {
+        return directions;
+    }
+
+    public void setDirections(Integer directions) {
+        this.directions = directions;
+    }
+
+    public Integer getVersions() {
+        return versions;
+    }
+
+    public void setVersions(Integer versions) {
+        this.versions = versions;
+    }
+
+    public Integer getDestroy() {
+        return destroy;
+    }
+
+    public void setDestroy(Integer destroy) {
+        this.destroy = destroy;
+    }
+
+    public String getDescriptions() {
+        return descriptions;
+    }
+
+    public void setDescriptions(String descriptions) {
+        this.descriptions = descriptions;
+    }
+
+    public Integer getCreateBy() {
+        return createBy;
+    }
+
+    public void setCreateBy(Integer createBy) {
+        this.createBy = createBy;
+    }
+
+    public Integer getUpdateBy() {
+        return updateBy;
+    }
+
+    public void setUpdateBy(Integer updateBy) {
+        this.updateBy = updateBy;
+    }
+
+    public Date getCreateDate() {
+        return createDate;
+    }
+
+    public void setCreateDate(Date createDate) {
+        this.createDate = createDate;
+    }
+
+    public Date getUpdateDate() {
+        return updateDate;
+    }
+
+    public void setUpdateDate(Date updateDate) {
+        this.updateDate = updateDate;
+    }
+
+    public Section getSection() {
+        return section;
+    }
+
+    public void setSection(Section section) {
+        this.section = section;
+    }
+
+    public Line getLine() {
+        return line;
+    }
+
+    public void setLine(Line line) {
+        this.line = line;
+    }
+}