Update

徐烜
1 parent 7caf7607
Showing 18 changed files with 326 additions and 964 deletions
src/main/java/com/bsth/controller/BaseController.java
src/main/java/com/bsth/controller/BaseController2.java
src/main/java/com/bsth/controller/CarsController.java
src/main/java/com/bsth/controller/PersonnelController.java
src/main/java/com/bsth/entity/schedule/rule/ScheduleRule1Flat.java
src/main/java/com/bsth/entity/schedule/temp/SchedulePlanRuleResult.java
src/main/java/com/bsth/service/schedule/impl/SchedulePlanServiceImpl.java
src/main/java/com/bsth/service/schedule/rules/MyDroolsConfiguration.java
src/main/java/com/bsth/service/schedule/utils/DataImportExportService.java
src/main/java/com/bsth/service/schedule/utils/DataImportExportServiceImpl.java
src/main/java/com/bsth/service/schedule/utils/DataToolsServiceImpl.java
src/main/resources/static/pages/scheduleApp/module/core/busConfig/module.js
src/main/resources/static/pages/scheduleApp/module/core/employeeConfig/module.js
src/main/resources/static/pages/scheduleApp/module/core/guideboardManage/module.js
src/test/java/com/bsth/service/schedule/rules/SchedulePlan1Test.java
src/test/java/com/bsth/service/schedule/rules/SchedulePlan2Test.java
src/test/resources/testdata/test1.txt
src/test/resources/testdata/test2.txt
 package com.bsth.controller;
-import com.bsth.common.ResponseCode;
 import com.bsth.service.BaseService;
-import com.bsth.service.schedule.utils.DataImportExportService;
 import com.google.common.base.Splitter;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.data.domain.Page;
 import org.springframework.data.domain.PageRequest;
 import org.springframework.data.domain.Sort;
 import org.springframework.data.domain.Sort.Direction;
-import org.springframework.util.CollectionUtils;
 import org.springframework.web.bind.annotation.PathVariable;
 import org.springframework.web.bind.annotation.RequestMapping;
 import org.springframework.web.bind.annotation.RequestMethod;
 import org.springframework.web.bind.annotation.RequestParam;
-import org.springframework.web.multipart.MultipartFile;
-import javax.servlet.http.HttpServletResponse;
-import java.io.*;
+import java.io.Serializable;
 import java.util.ArrayList;
-import java.util.HashMap;
 import java.util.List;
 import java.util.Map;
@@ -35,8 +29,6 @@ public class BaseController&lt;T, ID extends Serializable&gt; {
     @Autowired
     protected BaseService<T, ID> baseService;
-    @Autowired
-    DataImportExportService dataImportExportService;
     /**
      * @param @param map 查询条件
@@ -126,115 +118,4 @@ public class BaseController&lt;T, ID extends Serializable&gt; {
         return baseService.delete(id);
     }
-    /**
-     * 上传数据文件，并使用ktr转换文件导入数据。
-     *
-     * @param file
-     * @return
-     * @throws Exception
-     */
-    @RequestMapping(value = "/dataImport", method = RequestMethod.POST)
-    public Map<String, Object> uploadDataAndImport(MultipartFile file) throws Exception {
-        Map<String, Object> resultMap = new HashMap<>();
-
-        try {
-            // 获取ktr转换文件绝对路径
-            File ktrfile = new File(this.getClass().getResource(getDataImportKtrClasspath()).toURI());
-            System.out.println(ktrfile.getAbsolutePath());
-            // 导入数据
-            dataImportExportService.fileDataImport(file, ktrfile);
-
-            resultMap.put("status", ResponseCode.SUCCESS);
-            resultMap.put("msg", "导入成功");
-        } catch (Exception exp) {
-            exp.printStackTrace();
-            resultMap.put("status", ResponseCode.ERROR);
-            resultMap.put("msg", exp.getLocalizedMessage());
-        }
-
-        return resultMap;
-    }
-
-    /**
-     * 使用ktr导出数据。
-     *
-     * @param response
-     * @throws Exception
-     */
-    @RequestMapping(value = "/dataExport", method = RequestMethod.GET)
-    public void dataExport(HttpServletResponse response) throws Exception {
-        dataExport(response, null);
-    }
-
-    @RequestMapping(value = "/dataExportExt", method = RequestMethod.GET)
-    public void dataExport(HttpServletResponse response, @RequestParam Map<String, Object> param) throws Exception {
-        // 1、使用ktr转换获取输出文件
-        File ktrfile = new File(this.getClass().getResource(getDataExportKtrClasspath()).toURI());
-        File outputfile = null;
-        if (!CollectionUtils.isEmpty(param)) {
-            outputfile = dataImportExportService.fileDataOutput(
-                    getDataExportFilename(),
-                    ktrfile,
-                    param);
-        } else {
-            outputfile = dataImportExportService.fileDataOutput(
-                    getDataExportFilename(),
-                    ktrfile);
-        }
-
-        System.out.println(outputfile.getName());
-        String filePath = outputfile.getAbsolutePath();
-        String fp[] = filePath.split(File.separator);
-        String fileName = fp[fp.length - 1];
-
-        // TODO：使用ktr获取导出数据
-
-        response.setHeader("conent-type", "application/octet-stream");
-        response.setContentType("application/octet-stream");
-        response.setHeader("Content-Disposition", "attachment; filename=" + "东东");
-
-        OutputStream os = response.getOutputStream();
-        BufferedOutputStream bos = new BufferedOutputStream(os);
-
-        InputStream is = null;
-
-        is = new FileInputStream(filePath);
-        BufferedInputStream bis = new BufferedInputStream(is);
-
-        int length = 0;
-        byte[] temp = new byte[1 * 1024 * 10];
-
-        while ((length = bis.read(temp)) != -1) {
-            bos.write(temp, 0, length);
-        }
-        bos.flush();
-        bis.close();
-        bos.close();
-        is.close();
-    }
-
-    /**
-     * @return 数据导出的ktr转换文件类路径。
-     */
-    protected String getDataExportKtrClasspath() {
-        // 默认返回异常，子类如果要使用导出功能，必须覆写此方法，指定ktr文件类路径
-        throw new RuntimeException("必须override，并指定ktr classpath");
-    }
-
-    /**
-     * @return 导出文件名。
-     */
-    protected String getDataExportFilename() {
-        // 默认返回异常，子类如果要使用导出功能，必须覆写此方法，指定导出的文件路径名
-        throw new RuntimeException("必须override，并指定导出文件名");
-    }
-
-    /**
-     * @return 数据导入的ktr转换文件类路径。
-     */
-    protected String getDataImportKtrClasspath() {
-        // 默认返回异常，子类如果要使用导入功能，必须覆写此方法，指定ktr文件类路径
-        throw new RuntimeException("必须override，并指定ktr classpath");
-    }
-
 }
-package com.bsth.controller;
-
-
-import com.bsth.common.ResponseCode;
-import com.bsth.service.BaseService;
-import com.bsth.service.schedule.utils.DataImportExportService;
-import com.google.common.base.Splitter;
-import jxl.Sheet;
-import jxl.Workbook;
-import org.springframework.beans.factory.annotation.Autowired;
-import org.springframework.data.domain.Page;
-import org.springframework.data.domain.PageRequest;
-import org.springframework.data.domain.Sort;
-import org.springframework.util.CollectionUtils;
-import org.springframework.web.bind.annotation.*;
-import org.springframework.web.multipart.MultipartFile;
-
-import javax.servlet.http.HttpServletResponse;
-import java.io.*;
-import java.util.ArrayList;
-import java.util.HashMap;
-import java.util.List;
-import java.util.Map;
-
-/**
- * Created by xu on 16/11/3.
- */
-public class BaseController2<T, ID extends Serializable> {
-
-    @Autowired
-    protected BaseService<T, ID> baseService;
-    @Autowired
-    DataImportExportService dataImportExportService;
-
-    /**
-     *
-     * @Title: list
-     * @Description: TODO(多条件分页查询)
-     * @param @param map 查询条件
-     * @param @param page 页码
-     * @param @param size 每页显示数量
-     * @throws
-     */
-    @RequestMapping(method = RequestMethod.GET)
-    public Page<T> list(@RequestParam Map<String, Object> map,
-                        @RequestParam(defaultValue = "0") int page,
-                        @RequestParam(defaultValue = "10") int size,
-                        @RequestParam(defaultValue = "id") String order,
-                        @RequestParam(defaultValue = "DESC") String direction){
-
-        // 允许多个字段排序，order可以写单个字段，也可以写多个字段
-        // 多个字段格式：{col1},{col2},{col3},....,{coln}
-        List<String> order_columns = Splitter.on(",").trimResults().splitToList(order);
-        // 多字段排序：DESC,ASC...
-        List<String> order_dirs = Splitter.on(",").trimResults().splitToList(direction);
-
-        if (order_dirs.size() == 1) { // 所有字段采用一种排序
-            if (null != order_dirs.get(0) && order_dirs.get(0).equals("ASC")) {
-                return baseService.list(map, new PageRequest(page, size, new Sort(Sort.Direction.ASC, order_columns)));
-            } else {
-                return baseService.list(map, new PageRequest(page, size, new Sort(Sort.Direction.DESC, order_columns)));
-            }
-        } else if (order_columns.size() == order_dirs.size()) {
-            List<Sort.Order> orderList = new ArrayList<>();
-            for (int i = 0; i < order_columns.size(); i++) {
-                if (null != order_dirs.get(i) && order_dirs.get(i).equals("ASC")) {
-                    orderList.add(new Sort.Order(Sort.Direction.ASC, order_columns.get(i)));
-                } else {
-                    orderList.add(new Sort.Order(Sort.Direction.DESC, order_columns.get(i)));
-                }
-            }
-            return baseService.list(map, new PageRequest(page, size, new Sort(orderList)));
-        } else {
-            throw new RuntimeException("多字段排序参数格式问题，排序顺序和字段数不一致");
-        }
-    }
-
-    /**
-     *
-     * @Title: list
-     * @Description: TODO(多条件查询)
-     * @param @param map
-     * @throws
-     */
-    @RequestMapping(value = "/all", method = RequestMethod.GET)
-    public Iterable<T> list(@RequestParam Map<String, Object> map){
-        return baseService.list(map);
-    }
-
-    /**
-     * 这里保存直接返回保存后的对象，不自己定义Map返回了，和前端angularjs配合。
-     * form也可以提交，但是页面参数可能不全，
-     * json的化比较灵活，但是貌似有多余属性也会报错，或者碰到lazy属性值，也有问题
-     * 不论form，还是json提交都能解决问题，就看哪个方便哪个来
-     *
-     * @param t 参数需要使用@RequestBody转换json成对象
-     * @return
-     */
-    @RequestMapping(method = RequestMethod.POST)
-    public T save(@RequestBody T t) {
-        baseService.save(t);
-        return t;
-    }
-
-    @RequestMapping(value="/{id}", method = RequestMethod.POST)
-    public T update(@RequestBody T t) {
-        baseService.save(t);
-        return t;
-    }
-
-    /**
-     *
-     * @Title: findById
-     * @Description: TODO(根据主键获取单个对象)
-     * @param @param id
-     * @throws
-     */
-    @RequestMapping(value="/{id}",method = RequestMethod.GET)
-    public T findById(@PathVariable("id") ID id){
-        return baseService.findById(id);
-    }
-
-    /**
-     *
-     * @Title: delete
-     * @Description: TODO(根据主键删除对象)
-     * @param @param id
-     * @throws
-     */
-    @RequestMapping(value="/{id}",method = RequestMethod.DELETE)
-    public Map<String, Object> delete(@PathVariable("id") ID id){
-        return baseService.delete(id);
-    }
-
-    /**
-     * 上传数据文件，并使用ktr转换文件导入数据。
-     * @param file
-     * @return
-     * @throws Exception
-     */
-    @RequestMapping(value = "/dataImport", method = RequestMethod.POST)
-    public Map<String, Object> uploadDataAndImport(MultipartFile file) throws Exception {
-        Map<String, Object> resultMap = new HashMap<>();
-
-        try {
-            // 获取ktr转换文件绝对路径
-            File ktrfile = new File(this.getClass().getResource(getDataImportKtrClasspath()).toURI());
-            System.out.println(ktrfile.getAbsolutePath());
-            // 导入数据
-            dataImportExportService.fileDataImport(file, ktrfile);
-
-            resultMap.put("status", ResponseCode.SUCCESS);
-            resultMap.put("msg", "导入成功");
-        } catch (Exception exp) {
-            exp.printStackTrace();
-            resultMap.put("status", ResponseCode.ERROR);
-            resultMap.put("msg", exp.getLocalizedMessage());
-        }
-
-        return resultMap;
-    }
-
-    /**
-     * 使用ktr导出数据。
-     * @param response
-     * @throws Exception
-     */
-    @RequestMapping(value = "/dataExport", method = RequestMethod.GET)
-    public void dataExport(HttpServletResponse response) throws Exception {
-        dataExport(response, null);
-    }
-
-    @RequestMapping(value = "/dataExportExt", method = RequestMethod.GET)
-    public void dataExport(HttpServletResponse response, @RequestParam Map<String, Object> param) throws Exception {
-        // 1、使用ktr转换获取输出文件
-        File ktrfile = new File(this.getClass().getResource(getDataExportKtrClasspath()).toURI());
-        File outputfile = null;
-        if (!CollectionUtils.isEmpty(param)) {
-            outputfile = dataImportExportService.fileDataOutput(
-                    getDataExportFilename(),
-                    ktrfile,
-                    param);
-        } else {
-            outputfile = dataImportExportService.fileDataOutput(
-                    getDataExportFilename(),
-                    ktrfile);
-        }
-
-        System.out.println(outputfile.getName());
-        System.out.println(outputfile.getAbsolutePath());
-
-        String filePath = outputfile.getAbsolutePath();
-//        String fp[] = filePath.split(File.separator);
-//        String fileName = fp[fp.length - 1];
-
-        // TODO：使用ktr获取导出数据
-
-        response.setHeader("conent-type", "application/octet-stream");
-        response.setContentType("application/octet-stream");
-        response.setHeader("Content-Disposition", "attachment; filename=" + "东东");
-
-        OutputStream os = response.getOutputStream();
-        BufferedOutputStream bos = new BufferedOutputStream(os);
-
-        InputStream is = null;
-
-        is = new FileInputStream(filePath);
-        BufferedInputStream bis = new BufferedInputStream(is);
-
-        int length = 0;
-        byte[] temp = new byte[1 * 1024 * 10];
-
-        while ((length = bis.read(temp)) != -1) {
-            bos.write(temp, 0, length);
-        }
-        bos.flush();
-        bis.close();
-        bos.close();
-        is.close();
-    }
-
-    /**
-     * @return 数据导出的ktr转换文件类路径。
-     */
-    protected String getDataExportKtrClasspath() {
-        // 默认返回异常，子类如果要使用导出功能，必须覆写此方法，指定ktr文件类路径
-        throw new RuntimeException("必须override，并指定ktr classpath");
-    }
-
-    /**
-     * @return 导出文件名。
-     */
-    protected String getDataExportFilename() {
-        // 默认返回异常，子类如果要使用导出功能，必须覆写此方法，指定导出的文件路径名
-        throw new RuntimeException("必须override，并指定导出文件名");
-    }
-
-    /**
-     * @return 数据导入的ktr转换文件类路径。
-     */
-    protected String getDataImportKtrClasspath() {
-        // 默认返回异常，子类如果要使用导入功能，必须覆写此方法，指定ktr文件类路径
-        throw new RuntimeException("必须override，并指定ktr classpath");
-    }
-
-
-    public static class ExcelFileOutput {
-        private String fileName;
-        private List<Map<String, Object>> sheetnames = new ArrayList<>();
-
-        public String getFileName() {
-            return fileName;
-        }
-
-        public void setFileName(String fileName) {
-            this.fileName = fileName;
-        }
-
-        public List<Map<String, Object>> getSheetnames() {
-            return sheetnames;
-        }
-
-        public void setSheetnames(List<Map<String, Object>> sheetnames) {
-            this.sheetnames = sheetnames;
-        }
-    }
-
-    /**
-     * 上传Excel文件，返回文件全路径名，工作区名称列表。
-     * @param file
-     * @return
-     * @throws Exception
-     */
-    @RequestMapping(value = "/uploadFile", method = RequestMethod.POST)
-    public ExcelFileOutput fileUpload(MultipartFile file) throws Exception {
-        // 返回对象
-        ExcelFileOutput rs = new ExcelFileOutput();
-
-        // 上传文件
-        File file1 = dataImportExportService.uploadFile(file);
-        // 获取文件的sheet
-        Workbook book = Workbook.getWorkbook(file1);
-        for (Sheet sheet : book.getSheets()) {
-            String sheetname = sheet.getName();
-            Map<String, Object> s = new HashMap<>();
-            s.put("name", sheetname);
-            rs.getSheetnames().add(s);
-        }
-
-        rs.setFileName(file1.getAbsolutePath());
-        return rs;
-    }
-
-}
 package com.bsth.controller;
-import com.bsth.common.ResponseCode;
 import com.bsth.entity.Cars;
-import com.bsth.service.schedule.utils.DataImportExportService;
-import com.bsth.service.schedule.utils.DataToolsProperties;
-import org.springframework.beans.factory.annotation.Autowired;
-import org.springframework.boot.context.properties.EnableConfigurationProperties;
 import org.springframework.web.bind.annotation.RequestMapping;
-import org.springframework.web.bind.annotation.RequestMethod;
-import org.springframework.web.bind.annotation.RequestParam;
 import org.springframework.web.bind.annotation.RestController;
-import java.io.File;
-import java.util.HashMap;
-import java.util.Map;
-
 /**
  * Created by xu on 16/5/31.
  */
 @RestController
 @RequestMapping("cars")
-@EnableConfigurationProperties(DataToolsProperties.class)
-public class CarsController extends BaseController2<Cars, Integer> {
-
-    @Autowired
-    private DataToolsProperties dataToolsProperties;
-    @Autowired
-    private DataImportExportService dataImportExportService;
-
-    /**
-     * 验证。
-     * @param map
-     * @return
-     */
-    @RequestMapping(value = "/validate/equale", method = RequestMethod.GET)
-    public Map<String, Object> validateData(@RequestParam Map<String, Object> map) {
-        // 一般比较自编号是否重复
-        return baseService.validateEquale(map);
-    }
-
-    // uploadFile post
-
-    // 验证excel sheet
-    @RequestMapping(value = "/validate/sheet", method = RequestMethod.GET)
-    public Map<String, Object> validateSheet() throws Exception {
-        Map<String, Object> rtn = new HashMap<>();
-
-        // TODO：
-
-        rtn.put("status", ResponseCode.SUCCESS);
-        return rtn;
-    }
-
-    @RequestMapping(value = "/importfile", method = RequestMethod.POST)
-    public Map<String, Object> importData(
-            @RequestParam Map<String, Object> form)
-            throws Exception {
-        Map<String, Object> rtn = new HashMap<>();
-
-        // TODO：
-        String filename = (String) form.get("filename");
-
-
-        try {
-            // 获取ktr转换文件绝对路径
-            File ktrfile = new File(this.getClass().getResource(getDataImportKtrClasspath()).toURI());
-            System.out.println(ktrfile.getAbsolutePath());
-            // 导入数据
-            dataImportExportService.fileDataImport(new File(filename), ktrfile);
-
-            rtn.put("status", ResponseCode.SUCCESS);
-            rtn.put("msg", "导入成功");
-        } catch (Exception exp) {
-            exp.printStackTrace();
-            rtn.put("status", ResponseCode.ERROR);
-            rtn.put("msg", exp.getLocalizedMessage());
-        }
-
-        return rtn;
-    }
-
-
-    @Override
-    protected String getDataImportKtrClasspath() {
-        return dataToolsProperties.getCarsDatainputktr();
-    }
-
-    @Override
-    protected String getDataExportKtrClasspath() {
-        return dataToolsProperties.getCarsDataoutputktr();
-    }
+public class CarsController extends BaseController<Cars, Integer> {
-    @Override
-    protected String getDataExportFilename() {
-        return "车辆基础数据";
-    }
 }
@@ -2,10 +2,11 @@ package com.bsth.controller;
 import com.bsth.entity.Personnel;
 import com.bsth.service.PersonnelService;
-import com.bsth.service.schedule.utils.DataToolsProperties;
 import org.springframework.beans.factory.annotation.Autowired;
-import org.springframework.boot.context.properties.EnableConfigurationProperties;
-import org.springframework.web.bind.annotation.*;
+import org.springframework.web.bind.annotation.RequestMapping;
+import org.springframework.web.bind.annotation.RequestMethod;
+import org.springframework.web.bind.annotation.RequestParam;
+import org.springframework.web.bind.annotation.RestController;
 import java.util.List;
 import java.util.Map;
@@ -15,54 +16,11 @@ import java.util.Map;
  */
 @RestController
 @RequestMapping("personnel")
-@EnableConfigurationProperties(DataToolsProperties.class)
 public class PersonnelController extends BaseController<Personnel, Integer> {
     @Autowired
-    private DataToolsProperties dataToolsProperties;
-
-    @Autowired
     private PersonnelService service;
-    /**
-     * 覆写方法，因为form提交的方式参数不全，改用 json形式提交 @RequestBody
-     * @Title: save
-     * @Description: TODO(持久化对象)
-     * @param @param t
-     * @param @return    设定文件
-     * @return Map<String,Object>  {status: 1（成功），-1（失败）}
-     * @throws
-     */
-    @RequestMapping(method = RequestMethod.POST)
-    public Map<String, Object> save(@RequestBody Personnel t){
-        return baseService.save(t);
-    }
-
-    /**
-     * 验证。
-     * @param map
-     * @return
-     */
-    @RequestMapping(value = "/validate/equale", method = RequestMethod.GET)
-    public Map<String, Object> validateData(@RequestParam Map<String, Object> map) {
-        // 一般比较相同公司下工号是否相同
-        return baseService.validateEquale(map);
-    }
-
-    @Override
-    protected String getDataImportKtrClasspath() {
-        return dataToolsProperties.getEmployeesDatainputktr();
-    }
-
-    @Override
-    protected String getDataExportKtrClasspath() {
-        return dataToolsProperties.getEmployeesDataoutputktr();
-    }
-    @Override
-    protected String getDataExportFilename() {
-        return "人员基础信息";
-    }
-    
     @RequestMapping(value = "/sreachPersonnel", method = RequestMethod.GET)
 	public List<Map<String, String>> sreachPersonnel(@RequestParam String jobCode) {
 		return service.sreachPersonnel(jobCode);
@@ -67,6 +67,7 @@ public class ScheduleRule1Flat extends BEntity {
     private String ryDbbms;
     /** 对应的人员配置ids（用逗号隔开，如果分班，就先-隔开再逗号隔开） */
     @NotNull
+    @Column(length = 1000)
     private String ryConfigIds;
     /** 起始人员（从0开始） */
     @NotNull
@@ -2,10 +2,7 @@ package com.bsth.entity.schedule.temp;
 import com.bsth.entity.schedule.SchedulePlan;
-import javax.persistence.Entity;
-import javax.persistence.GeneratedValue;
-import javax.persistence.Id;
-import javax.persistence.Table;
+import javax.persistence.*;
 import java.util.Date;
 /**
@@ -32,12 +29,14 @@ public class SchedulePlanRuleResult {
     private String ccZbh;
     /** 路牌id列表字符串 */
+    @Column(length = 1000)
     private String gids;
     /** 路牌名字列表字符串 */
     private String gnames;
     /** 翻到哪个路牌索引 */
     private String gidindex;
     /** 人员配置id列表字符串 */
+    @Column(length = 1000)
     private String ecids;
     /** 人员配置搭班编码列表字符串 */
     private String ecdbbms;
@@ -65,7 +65,7 @@ public class SchedulePlanServiceImpl extends BServiceImpl&lt;SchedulePlan, Long&gt; im
      * @param schedulePlan 排班计划对象
      * @param lpInfoResults_output 时刻表每日路牌的情况
      */
-    private ScheduleResults_output loopRuleOutput(
+    public ScheduleResults_output loopRuleOutput(
             SchedulePlan schedulePlan,
             LpInfoResults_output lpInfoResults_output) {
         // 1-1、构造drools规则输入数据，输出数据
@@ -116,7 +116,7 @@ public class SchedulePlanServiceImpl extends BServiceImpl&lt;SchedulePlan, Long&gt; im
      * @param schedulePlan 排班计划对象
      * @return TTInfoResults_output, LpInfoResults_output
      */
-    private Object[] ttInfoOutput(SchedulePlan schedulePlan) {
+    public Object[] ttInfoOutput(SchedulePlan schedulePlan) {
         // 获取线路的所有未作废的时刻表
         List<TTInfo> ttInfos = ttInfoRepository.findInCanceledByXl(schedulePlan.getXl());
@@ -174,7 +174,7 @@ public class SchedulePlanServiceImpl extends BServiceImpl&lt;SchedulePlan, Long&gt; im
      * @param ttInfoResults_output ttInfoOutput方法规则输出
      * @return PlanResult
      */
-    private PlanResult planResultOutput(
+    public PlanResult planResultOutput(
             SchedulePlan schedulePlan,
             ScheduleResults_output scheduleResults_output,
             TTInfoResults_output ttInfoResults_output) {
@@ -4,7 +4,6 @@ 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.Message;
 import org.kie.api.builder.model.KieBaseModel;
 import org.kie.api.builder.model.KieModuleModel;
 import org.kie.api.builder.model.KieSessionModel;
@@ -12,6 +11,8 @@ 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.slf4j.Logger;
+import org.slf4j.LoggerFactory;
 import org.springframework.context.annotation.Bean;
 import org.springframework.context.annotation.Configuration;
@@ -20,6 +21,9 @@ import org.springframework.context.annotation.Configuration;
  */
 @Configuration
 public class MyDroolsConfiguration {
+    /** 日志记录器 */
+    private static final Logger logger = LoggerFactory.getLogger(MyDroolsConfiguration.class);
+
     /**
      * 返回一个kiebase知识库，直接冲文件系统读入drl规则文件，
      * TODO：以后需要从数据库读入规则文件，并重新创建kbase知识库。
@@ -72,8 +76,12 @@ public class MyDroolsConfiguration {
         // 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());
+//        if (results.hasMessages(Message.Level.ERROR))
+//            throw new IllegalStateException("构建drools6错误：" + results.getMessages());
+        if (results.hasMessages(Message.Level.ERROR)) {
+            logger.info("构建drools6错误：" + results.getMessages());
+            return null;
+        }
         // 5、获取KieContainer
         // TODO：ReleaseId用处很大，以后再议
-package com.bsth.service.schedule.utils;
-
-import org.springframework.web.multipart.MultipartFile;
-
-import java.io.File;
-import java.util.Map;
-
-/**
- * 数据导入导出服务。
- */
-public interface DataImportExportService {
-    /**
-     * 上传文件。
-     * @param file mutipartFile
-     * @return 上传后的文件路径
-     * @throws Exception
-     */
-    File uploadFile(MultipartFile file) throws Exception;
-
-    /**
-     * 上传文件，并导入文件数据。
-     * @param datafile 上传的文件
-     * @param ktrFile 导入的逻辑ktr文件
-     * @throws Exception
-     */
-    void fileDataImport(MultipartFile datafile, File ktrFile) throws Exception;
-    void fileDataImport(File datafile, File ktrFile) throws Exception;
-
-    /**
-     * 数据导出。
-     * @param fileName 文件名
-     * @param ktrFile 导出的逻辑ktr文件
-     * @return 导出的文件
-     * @throws Exception
-     */
-    File fileDataOutput(String fileName, File ktrFile) throws Exception;
-
-
-    File fileDataOutput(String fileName, File ktrFile, Map<String, Object> param) throws Exception;
-}
-package com.bsth.service.schedule.utils;
-
-import com.google.common.io.Files;
-import org.joda.time.DateTime;
-import org.pentaho.di.core.KettleEnvironment;
-import org.pentaho.di.core.util.EnvUtil;
-import org.pentaho.di.trans.Trans;
-import org.pentaho.di.trans.TransMeta;
-import org.springframework.beans.factory.InitializingBean;
-import org.springframework.beans.factory.annotation.Autowired;
-import org.springframework.boot.context.properties.EnableConfigurationProperties;
-import org.springframework.stereotype.Service;
-import org.springframework.util.CollectionUtils;
-import org.springframework.web.multipart.MultipartFile;
-
-import java.io.File;
-import java.util.HashMap;
-import java.util.Map;
-import java.util.Properties;
-
-/**
- * Created by xu on 16/6/23.
- */
-@Service
-@EnableConfigurationProperties(DataToolsProperties.class)
-public class DataImportExportServiceImpl implements DataImportExportService, InitializingBean {
-
-    @Autowired
-    private DataToolsProperties dataToolsProperties;
-
-    /**
-     * 自定义kettle环境初始化定义。
-     */
-    private void ktrEnvironmentInit() throws Exception {
-        // 由于kettle.properties可能没有（没有安装过kettle），
-        // 导致 EnvUtil.environmentInit() 报找不到kettle.properties文件
-        // 所以这里重写 EnvUtil.environmentInit() 方法
-
-        if(Thread.currentThread().getContextClassLoader() == null) {
-            Thread.currentThread().setContextClassLoader(ClassLoader.getSystemClassLoader());
-        }
-
-        // 获取配置文件
-        File file = new File(getClass().getResource(dataToolsProperties.getKettleProperties()).toURI());
-        Properties kettleProperties = EnvUtil.readProperties(file.getAbsolutePath());
-        EnvUtil.applyKettleProperties(kettleProperties);
-        System.getProperties().put("Internal.Cluster.Size", "1");
-        System.getProperties().put("Internal.Slave.Transformation.Number", "0");
-        System.getProperties().put("Internal.Slave.Server.Name", "slave-trans-name");
-        System.getProperties().put("Internal.Step.CopyNr", "0");
-        System.getProperties().put("Internal.Step.Name", "step-name");
-        System.getProperties().put("Internal.Step.Partition.ID", "partition-id");
-        System.getProperties().put("Internal.Step.Partition.Number", "0");
-        System.getProperties().put("Internal.Step.Unique.Count", "1");
-        System.getProperties().put("Internal.Step.Unique.Number", "0");
-        if(!kettleProperties.containsKey("vfs.sftp.org.apache.commons.vfs2.provider.sftp.SftpFileSystemConfigBuilder.USER_DIR_IS_ROOT")) {
-            System.getProperties().put("vfs.sftp.org.apache.commons.vfs2.provider.sftp.SftpFileSystemConfigBuilder.USER_DIR_IS_ROOT", "false");
-        }
-
-    }
-
-    @Override
-    public void afterPropertiesSet() throws Exception {
-        // 初始化kettle环境（自定义）
-        ktrEnvironmentInit();
-
-        // 添加全局ktr变量，并覆盖原来的设置
-        Map<String, String> kvars = new HashMap<>();
-        kvars.put("v_db_ip", dataToolsProperties.getKvarsDbip());
-        kvars.put("v_db_uname", dataToolsProperties.getKvarsDbuname());
-        kvars.put("v_db_pwd", dataToolsProperties.getKvarsDbpwd());
-        kvars.put("v_db_dname", dataToolsProperties.getKvarsDbdname());
-        EnvUtil.applyKettleProperties(kvars, true);
-        KettleEnvironment.init();
-    }
-
-    @Override
-    public File uploadFile(MultipartFile file) throws Exception {
-        // TODO：以后的文件名要加时间戳
-        File newFile = new File(
-                dataToolsProperties.getFileuploadDir() + File.separator +
-                        file.getOriginalFilename());
-        Files.write(file.getBytes(), newFile);
-
-        return newFile;
-    }
-
-    @Override
-    public void fileDataImport(MultipartFile datafile, File ktrFile) throws Exception {
-        // 1、上传数据文件
-        File uploadFile = uploadFile(datafile);
-
-        // 2、使用kettle运行封装数据导入逻辑的ktr转换文件
-        // 2.1、初始化kettle（组件初始化已经做了）
-        // 2.2、创建转换元数据，转换
-        TransMeta transMeta = new TransMeta(ktrFile.getAbsolutePath());
-        Trans trans = new Trans(transMeta);
-        // 2.3、设定命名参数，用于指定数据文件，注意每个ktr必须都有以下指定的命名参数
-        trans.setParameterValue("filepath", uploadFile.getAbsolutePath()); // 指定导入数据文件的位置
-        trans.setParameterValue("erroroutputdir", dataToolsProperties.getTransErrordir()); // ktr转换错误输出目录
-        // TODO：可以考虑设定日志输出
-        // 2.4、执行转换
-        trans.execute(null);
-        // 2.5、等待转换结束
-        trans.waitUntilFinished();
-
-        // 3、判定ktr错误数，注意这种错误代表部分数据错误，不会终止转换执行，一般设计ktr的时候，会有错误输出文件，TODO：以后考虑使用日志实时输出
-        if (trans.getErrors() > 0) {
-            throw new Exception("转换数据部分错误，请查看相关错误输出文件！");
-        }
-    }
-
-    @Override
-    public void fileDataImport(File datafile, File ktrFile) throws Exception {
-//        // 1、上传数据文件
-//        File uploadFile = datafile;
-
-        // 2、使用kettle运行封装数据导入逻辑的ktr转换文件
-        // 2.1、初始化kettle（组件初始化已经做了）
-        // 2.2、创建转换元数据，转换
-        TransMeta transMeta = new TransMeta(ktrFile.getAbsolutePath());
-        Trans trans = new Trans(transMeta);
-        // 2.3、设定命名参数，用于指定数据文件，注意每个ktr必须都有以下指定的命名参数
-        trans.setParameterValue("filepath", datafile.getAbsolutePath()); // 指定导入数据文件的位置
-        trans.setParameterValue("erroroutputdir", dataToolsProperties.getTransErrordir()); // ktr转换错误输出目录
-        // TODO：可以考虑设定日志输出
-        // 2.4、执行转换
-        trans.execute(null);
-        // 2.5、等待转换结束
-        trans.waitUntilFinished();
-
-        // 3、判定ktr错误数，注意这种错误代表部分数据错误，不会终止转换执行，一般设计ktr的时候，会有错误输出文件，TODO：以后考虑使用日志实时输出
-        if (trans.getErrors() > 0) {
-            throw new Exception("转换数据部分错误，请查看相关错误输出文件！");
-        }
-    }
-
-    @Override
-    public File fileDataOutput(String fileName, File ktrFile) throws Exception {
-        return fileDataOutput(fileName, ktrFile, null);
-    }
-
-    @Override
-    public File fileDataOutput(String fileName, File ktrFile, Map<String, Object> param) throws Exception {
-        // 初始化转换，元数据，转换对象
-        TransMeta transMeta = new TransMeta(ktrFile.getAbsolutePath());
-        Trans trans = new Trans(transMeta);
-        // 设定命名参数
-        String filepath = dataToolsProperties.getFileoutputDir() +
-                File.separator +
-                fileName +
-                new DateTime().toString("yyyyMMddHHmmss") + ".xls";
-        trans.setParameterValue("filepath", filepath);
-
-        // 添加其他参数
-        if (!CollectionUtils.isEmpty(param)) {
-            for (String key : param.keySet()) {
-                trans.setParameterValue(key, String.valueOf(param.get(key)));
-            }
-        }
-
-        // 执行转换
-        trans.execute(null);
-        // 等待转换结束
-        trans.waitUntilFinished();
-
-        if (trans.getErrors() > 0) {
-            throw new Exception("转换数据部分错误，请查看相关错误输出文件！");
-        }
-
-        return new File(filepath);
-    }
-
-
-    // TODO：以后改成下面的样子
-//    import java.io.FileInputStream;
-//    import java.io.FileOutputStream;
-//    import java.io.IOException;
-//    import java.io.InputStream;
-//    import java.util.Iterator;
-//
-//    import org.apache.poi.hssf.usermodel.HSSFCell;
-//    import org.apache.poi.hssf.usermodel.HSSFRow;
-//    import org.apache.poi.hssf.usermodel.HSSFSheet;
-//    import org.apache.poi.hssf.usermodel.HSSFWorkbook;
-//
-//    import org.apache.poi.xssf.usermodel.XSSFCell;
-//    import org.apache.poi.xssf.usermodel.XSSFRow;
-//    import org.apache.poi.xssf.usermodel.XSSFSheet;
-//    import org.apache.poi.xssf.usermodel.XSSFWorkbook;
-//
-//    public class ReadWriteExcelFile {
-//
-//        public static void readXLSFile() throws IOException
-//        {
-//            InputStream ExcelFileToRead = new FileInputStream("C:/Test.xls");
-//            HSSFWorkbook wb = new HSSFWorkbook(ExcelFileToRead);
-//
-//            HSSFSheet sheet=wb.getSheetAt(0);
-//            HSSFRow row;
-//            HSSFCell cell;
-//
-//            Iterator rows = sheet.rowIterator();
-//
-//            while (rows.hasNext())
-//            {
-//                row=(HSSFRow) rows.next();
-//                Iterator cells = row.cellIterator();
-//
-//                while (cells.hasNext())
-//                {
-//                    cell=(HSSFCell) cells.next();
-//
-//                    if (cell.getCellType() == HSSFCell.CELL_TYPE_STRING)
-//                    {
-//                        System.out.print(cell.getStringCellValue()+" ");
-//                    }
-//                    else if(cell.getCellType() == HSSFCell.CELL_TYPE_NUMERIC)
-//                    {
-//                        System.out.print(cell.getNumericCellValue()+" ");
-//                    }
-//                    else
-//                    {
-//                        //U Can Handel Boolean, Formula, Errors
-//                    }
-//                }
-//                System.out.println();
-//            }
-//
-//        }
-//
-//        public static void writeXLSFile() throws IOException {
-//
-//            String excelFileName = "C:/Test.xls";//name of excel file
-//
-//            String sheetName = "Sheet1";//name of sheet
-//
-//            HSSFWorkbook wb = new HSSFWorkbook();
-//            HSSFSheet sheet = wb.createSheet(sheetName) ;
-//
-//            //iterating r number of rows
-//            for (int r=0;r < 5; r++ )
-//            {
-//                HSSFRow row = sheet.createRow(r);
-//
-//                //iterating c number of columns
-//                for (int c=0;c < 5; c++ )
-//                {
-//                    HSSFCell cell = row.createCell(c);
-//
-//                    cell.setCellValue("Cell "+r+" "+c);
-//                }
-//            }
-//
-//            FileOutputStream fileOut = new FileOutputStream(excelFileName);
-//
-//            //write this workbook to an Outputstream.
-//            wb.write(fileOut);
-//            fileOut.flush();
-//            fileOut.close();
-//        }
-//
-//        public static void readXLSXFile() throws IOException
-//        {
-//            InputStream ExcelFileToRead = new FileInputStream("C:/Test.xlsx");
-//            XSSFWorkbook  wb = new XSSFWorkbook(ExcelFileToRead);
-//
-//            XSSFWorkbook test = new XSSFWorkbook();
-//
-//            XSSFSheet sheet = wb.getSheetAt(0);
-//            XSSFRow row;
-//            XSSFCell cell;
-//
-//            Iterator rows = sheet.rowIterator();
-//
-//            while (rows.hasNext())
-//            {
-//                row=(XSSFRow) rows.next();
-//                Iterator cells = row.cellIterator();
-//                while (cells.hasNext())
-//                {
-//                    cell=(XSSFCell) cells.next();
-//
-//                    if (cell.getCellType() == XSSFCell.CELL_TYPE_STRING)
-//                    {
-//                        System.out.print(cell.getStringCellValue()+" ");
-//                    }
-//                    else if(cell.getCellType() == XSSFCell.CELL_TYPE_NUMERIC)
-//                    {
-//                        System.out.print(cell.getNumericCellValue()+" ");
-//                    }
-//                    else
-//                    {
-//                        //U Can Handel Boolean, Formula, Errors
-//                    }
-//                }
-//                System.out.println();
-//            }
-//
-//        }
-//
-//        public static void writeXLSXFile() throws IOException {
-//
-//            String excelFileName = "C:/Test.xlsx";//name of excel file
-//
-//            String sheetName = "Sheet1";//name of sheet
-//
-//            XSSFWorkbook wb = new XSSFWorkbook();
-//            XSSFSheet sheet = wb.createSheet(sheetName) ;
-//
-//            //iterating r number of rows
-//            for (int r=0;r < 5; r++ )
-//            {
-//                XSSFRow row = sheet.createRow(r);
-//
-//                //iterating c number of columns
-//                for (int c=0;c < 5; c++ )
-//                {
-//                    XSSFCell cell = row.createCell(c);
-//
-//                    cell.setCellValue("Cell "+r+" "+c);
-//                }
-//            }
-//
-//            FileOutputStream fileOut = new FileOutputStream(excelFileName);
-//
-//            //write this workbook to an Outputstream.
-//            wb.write(fileOut);
-//            fileOut.flush();
-//            fileOut.close();
-//        }
-//
-//        public static void main(String[] args) throws IOException {
-//
-//            writeXLSFile();
-//            readXLSFile();
-//
-//            writeXLSXFile();
-//            readXLSXFile();
-//
-//        }
-//
-//    }
-}
@@ -13,10 +13,9 @@ import org.pentaho.di.trans.Trans;
 import org.pentaho.di.trans.TransMeta;
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
-import org.springframework.beans.factory.InitializingBean;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.boot.context.properties.EnableConfigurationProperties;
-import org.springframework.stereotype.Service;
+import org.springframework.stereotype.Component;
 import java.io.File;
 import java.io.PrintWriter;
@@ -24,19 +23,41 @@ import java.io.StringWriter;
 import java.util.HashMap;
 import java.util.Map;
 import java.util.Properties;
+import java.util.concurrent.atomic.AtomicBoolean;
 /**
  * Created by xu on 17/1/3.
  */
-@Service
+@Component
 @EnableConfigurationProperties(DataToolsProperties.class)
-public class DataToolsServiceImpl implements DataToolsService, InitializingBean {
+public class DataToolsServiceImpl implements DataToolsService {
     /** 日志记录器 */
     private static final Logger LOGGER = LoggerFactory.getLogger(DataToolsServiceImpl.class);
     @Autowired
     private DataToolsProperties dataToolsProperties;
+    /** 原子操作类 */
+    private AtomicBoolean flag = new AtomicBoolean(false);
+
+    private void initKettle() throws Exception {
+        if (flag.compareAndSet(false, true)) {
+            LOGGER.info("kettle开始初始化......");
+
+            // 初始化kettle环境（自定义）
+            ktrEnvironmentInit();
+
+            // 添加全局ktr变量，并覆盖原来的设置
+            Map<String, String> kvars = new HashMap<>();
+            kvars.put("v_db_ip", dataToolsProperties.getKvarsDbip());
+            kvars.put("v_db_uname", dataToolsProperties.getKvarsDbuname());
+            kvars.put("v_db_pwd", dataToolsProperties.getKvarsDbpwd());
+            kvars.put("v_db_dname", dataToolsProperties.getKvarsDbdname());
+            EnvUtil.applyKettleProperties(kvars, true);
+            KettleEnvironment.init();
+        }
+    }
+
     /**
      * 自定义kettle环境初始化定义。
      */
@@ -70,24 +91,11 @@ public class DataToolsServiceImpl implements DataToolsService, InitializingBean 
     }
     @Override
-    public void afterPropertiesSet() throws Exception {
-        // 初始化kettle环境（自定义）
-        ktrEnvironmentInit();
-
-        // 添加全局ktr变量，并覆盖原来的设置
-        Map<String, String> kvars = new HashMap<>();
-        kvars.put("v_db_ip", dataToolsProperties.getKvarsDbip());
-        kvars.put("v_db_uname", dataToolsProperties.getKvarsDbuname());
-        kvars.put("v_db_pwd", dataToolsProperties.getKvarsDbpwd());
-        kvars.put("v_db_dname", dataToolsProperties.getKvarsDbdname());
-        EnvUtil.applyKettleProperties(kvars, true);
-        KettleEnvironment.init();
-    }
-
-    @Override
     public File uploadFile(String filename, byte[] filedata) throws ScheduleException {
         // 上传文件
         try {
+            initKettle();
+
             LOGGER.info("start uploadFile...originalFilename={}", filename);
             File newFile = new File(dataToolsProperties.getFileuploadDir() + File.separator +
                     filename + "-upload-" + new DateTime().toString("yyyyMMddHHmmss") + ".xls");
@@ -127,6 +135,8 @@ public class DataToolsServiceImpl implements DataToolsService, InitializingBean 
         String transLogId = "";
         String transMetaLogId = "";
         try {
+            initKettle();
+
             LOGGER.info("start importData...originalFilename={}", file.getAbsolutePath());
             // 检查参数
             String transpath = String.valueOf(params.get("transpath"));
@@ -189,6 +199,8 @@ public class DataToolsServiceImpl implements DataToolsService, InitializingBean 
         String transLogId = "";
         String transMetaLogId = "";
         try {
+            initKettle();
+
             LOGGER.info("start exportData...");
             // 检查参数
             String filename = String.valueOf(params.get("filename"));
@@ -126,8 +126,9 @@ angular.module(&#39;ScheduleApp&#39;).controller(
             // 导出excel
             self.exportData = function() {
-                if (busConfigService.dataExport()) {
-                    busConfigService.dataExport().then(
+                var p = busConfigService.dataExport();
+                if (p) {
+                    p.then(
                         function(result) {
                             fileDownload.downloadFile(result.data, "application/octet-stream", "车辆配置信息.xls");
                         },
@@ -127,8 +127,9 @@ angular.module(&#39;ScheduleApp&#39;).controller(
             // 导出excel
             self.exportData = function() {
-                if (service.dataExport()) {
-                    service.dataExport().then(
+                var p = service.dataExport();
+                if (p) {
+                    p.then(
                         function(result) {
                             fileDownload.downloadFile(result.data, "application/octet-stream", "人员配置信息.xls");
                         },
@@ -131,8 +131,9 @@ angular.module(&#39;ScheduleApp&#39;).controller(
             // 导出excel
             self.exportData = function() {
-                if (service.dataExport()) {
-                    service.dataExport().then(
+                var p = service.dataExport();
+                if (p) {
+                    p.then(
                         function(result) {
                             fileDownload.downloadFile(result.data, "application/octet-stream", "路牌信息.xls");
                         },
+package com.bsth.service.schedule.rules;
+
+import com.bsth.service.schedule.BaseTest;
+import org.dbunit.database.DatabaseConnection;
+import org.dbunit.database.IDatabaseConnection;
+import org.dbunit.dataset.IDataSet;
+import org.dbunit.dataset.xml.FlatXmlDataSetBuilder;
+import org.dbunit.operation.DatabaseOperation;
+import org.junit.After;
+import org.junit.Before;
+import org.junit.Test;
+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;
+
+/**
+ * 排班计划测试（手工排班测试）。
+ */
+public class SchedulePlan1Test extends BaseTest {
+    /** 日志记录器 */
+    private static final Logger logger = LoggerFactory.getLogger(SchedulePlan1Test.class);
+
+    @Autowired
+    private DataSource dataSource;
+
+    /**
+     * 初始化数据。
+     */
+    @Before
+    public void initData() throws Exception {
+        logger.info("载入数据......");
+
+        // 获取数据库连接
+        IDatabaseConnection iDatabaseConnection = new DatabaseConnection(dataSource.getConnection());
+        // 获取Dbunit数据源
+        Resource res = new ClassPathResource("testdata/d2.xml");
+        FlatXmlDataSetBuilder flatXmlDataSetBuilder = new FlatXmlDataSetBuilder();
+        flatXmlDataSetBuilder.setColumnSensing(false);
+        flatXmlDataSetBuilder.setCaseSensitiveTableNames(false);
+        IDataSet iDataSet = flatXmlDataSetBuilder.build(res.getInputStream());
+
+        // 载入数据
+        DatabaseOperation.CLEAN_INSERT.execute(iDatabaseConnection, iDataSet);
+    }
+
+    /**
+     * 清除数据。
+     */
+    @After
+    public void destoryData() throws Exception {
+        logger.info("清除数据......");
+        // 获取数据库连接
+        IDatabaseConnection iDatabaseConnection = new DatabaseConnection(dataSource.getConnection());
+        // 获取Dbunit数据源
+        Resource res = new ClassPathResource("testdata/d2.xml");
+        FlatXmlDataSetBuilder flatXmlDataSetBuilder = new FlatXmlDataSetBuilder();
+        flatXmlDataSetBuilder.setColumnSensing(false);
+        flatXmlDataSetBuilder.setCaseSensitiveTableNames(false);
+        IDataSet iDataSet = flatXmlDataSetBuilder.build(res.getInputStream());
+
+        // 清除数据
+        DatabaseOperation.DELETE_ALL.execute(iDatabaseConnection, iDataSet);
+    }
+
+
+    @Test
+    public void t1() {
+
+    }
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+}
+package com.bsth.service.schedule.rules;
+
+/**
+ * 时刻表测试（自动排班测试）。
+ */
+public class SchedulePlan2Test {
+    // TODO：
+}
+select * from jwgl_f_t_clxh_workflow_detail a where a.ID_LYSYLB = 36;
+
+select sum(amount - tl_amount) from jwgl_f_t_clxh_workflow_detail
+where
+to_date(statdateid, 'YYYYMMDD') >= to_date('20170301', 'YYYYMMDD')
+and to_date(statdateid, 'YYYYMMDD') <= to_date('20170331', 'YYYYMMDD')
+
+select * from JWGL_D_T_LYSYLB
+
+-- all xh
+
+select
+statdateid statdate
+, ssjc gs
+, xl xl
+, zbh cl
+, b.SYLB1 || '-' || b.SYLB2 as lylb
+, (sum(amount) - sum(tl_amount)) ch
+from JWGL_F_T_CLXH_WORKFLOW_DETAIL a, JWGL_D_T_LYSYLB b
+where
+to_date(statdateid, 'YYYYMMDD') >= to_date('20170301', 'YYYYMMDD')
+and to_date(statdateid, 'YYYYMMDD') <= to_date('20170331', 'YYYYMMDD')
+and a.ID_LYSYLB = b.ID(+)
+group by
+statdateid
+, ssjc
+, xl
+, zbh
+, b.SYLB1 || '-' || b.SYLB2
+
+-- part1
+
+select sum(ch) from
+(
+select
+statdateid statdate
+, ssjc gs
+, xl xl
+, zbh cl
+, b.SYLB1 || '-' || b.SYLB2 as lylb
+, (sum(amount) - sum(tl_amount)) ch
+from JWGL_F_T_CLXH_WORKFLOW_DETAIL a, JWGL_D_T_LYSYLB b
+where
+to_date(statdateid, 'YYYYMMDD') >= to_date('20170301', 'YYYYMMDD')
+and to_date(statdateid, 'YYYYMMDD') <= to_date('20170331', 'YYYYMMDD')
+and a.ID_LYSYLB = b.ID(+)
+group by
+statdateid
+, ssjc
+, xl
+, zbh
+, b.SYLB1 || '-' || b.SYLB2
+)
+where lylb in (
+'路救-路救',
+'小修-小修机工',
+'专项-安检',
+'专项-节检',
+'专项-水箱',
+'专项-电瓶',
+'小修-小修电工',
+'专项-电并',
+'小修-小修车身',
+'专项-镗固',
+'保养-一级保养',
+'小修-发动机',
+'专项-轮胎',
+'分摊-轮胎',
+'专项-润滑油',
+'总成-差变速',
+'总成-大泵',
+'总成-小总成',
+'总成-发动机',
+'保养-二级保养',
+'保养-三级保养',
+'整修-整修',
+'空调-保外',
+'空调-保内',
+'事故-事故'
+)
+
+-- part2
+
+select sum(ch) from
+(
+select
+statdateid statdate
+, ssjc gs
+, xl xl
+, zbh cl
+, b.SYLB1 || '-' || b.SYLB2 as lylb
+, (sum(amount) - sum(tl_amount)) ch
+from JWGL_F_T_CLXH_WORKFLOW_DETAIL a, JWGL_D_T_LYSYLB b
+where
+to_date(statdateid, 'YYYYMMDD') >= to_date('20170301', 'YYYYMMDD')
+and to_date(statdateid, 'YYYYMMDD') <= to_date('20170331', 'YYYYMMDD')
+and a.ID_LYSYLB = b.ID(+)
+group by
+statdateid
+, ssjc
+, xl
+, zbh
+, b.SYLB1 || '-' || b.SYLB2
+)
+where lylb in(
+'分摊-镗固',
+'专项-机油',
+'分摊-机油',
+'总成-其它',
+'分摊-工具',
+'分摊-辅助料',
+'分摊-设备',
+'车间经费-车间经费'
+)
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+select * from JWGL_FR_T_CH_REPORT_DATA1;
+
+select * from JWGL_FR_T_CH_REPORT_DATA2;
+
+-- sum part1
+
+select
+(
+sum(lj_lj) + sum(xx_xxjg) + sum(xx_xxdg) + sum(zx_db) + sum(xx_xxcs) + sum(zx_tg) + sum(by_b1) +
+sum(nvl(future_bx, 0)) + sum(xx_fdj) + sum(zx_lt) + sum(zx_rhy) + sum(zc_cbx) + sum(zc_db) + sum(zc_xzc) +
+sum(zc_fdj) + sum(by_b2) + sum(by_b3) + sum(nvl(future_wx_db, 0)) + sum(nvl(future_wxfy, 0)) + sum(nvl(future_ktwx, 0)) + sum(nvl(future_sx, 0)) +
+sum(nvl(future_dp, 0)) + sum(zx_zx) + sum(kt_bw) + sum(sg_sg)
+) as part1
+from JWGL_FR_T_CH_REPORT_DATA1
+where
+statdate >= to_date('20170301', 'YYYYMMDD')
+and statdate <= to_date('20170331', 'YYYYMMDD')
+
+-- sum part2
+
+select
+(
+sum(zx_tg) + sum(jy) + sum(qt) + sum(zcfl) + sum(gj) + sum(sb) + sum(cjjf)
+) as part2
+from JWGL_FR_T_CH_REPORT_DATA2
+where statdate = to_date('20170331', 'YYYYMMDD')
 \ No newline at end of file