功能简介：
操作1：将本地的订单xml文件上传到FTP上，然后在本地其他文件夹进行备
份并删除源文件。
操作2：将FTP上面其他公司上传的订单回执Xml下载到temp文件夹（限制数
量为300，超过300则下个循环再下载。此举防止一个周期时间过长，产生中
断。） ——> 解析并存储到数据库中 ——> 将temp中的文件转移到备份文件
夹中并根据时间存储到相对应的文件夹中。
优化部分：
- 优化1
上次的项目流程是：为每个任务创建线程 ——> 线程里面创建定时器 ——>
完成任务。
我觉得我敢我上次的代码上传到github上也是胆子大，幸好github没有fans，不然被人笑掉大牙了。。。
我本来是想继续优化做成可视化，可人工控制的。结果按照我之前的那样压根控制不了，关闭线程，定时器还在继续任务。关闭定时器，线程又不会被关闭。哎，什么都不了解就乱写。。。
定时器本身开启之后就是创建一个线程的，在这个线程里面完成任务。所以再开启一个线程里面创建定时器完全是多此一举！在这里我换了个思路来写。
现在的项目流程：开启第一个任务在主线程中直接run ——> 开启一个分线程
来完成第二个任务
代码如下：
/**
* 开启任务
* @param task 任务对应标识
*/
private void startTimerTask(String task){
ThreadUtils orderThread = ThreadUtils.getThreadUtils(task);
/**
* 如果close为true则说明线程被暂停过，则修改值之后直接运行即可。
* 这里虽然启动第一个是在主线程运行，但是第二个就会自动在分线程运行的
*/
orderThread.setClose(false);
orderThread.run();
}
如下图：哈哈，我用oc写的一个简单的控制任务开关
控制任务开关器
这里就是直接开启线程执行任务，而在线程里的run方法里执行任务时根据一个标志boolean类型的属性close来控制任务的开始于停止，这里注意需要使用synchronized关键字将线程锁住，否则在线程睡眠的那段时间，再执行run就是重新创建一个新的线程了。（你们可以把关键字去掉，然后重复的开关开关）就知道我说的什么意思了。
代码如下
/**
* 线程方法
* 根据task来区分两个线程的方法，并且只要没有关闭，就一直执行任务，执行完sleep一段时间再次执行，通过
* 这种方式达到一个定时器的功能。
*/
@Override
public void run() {
/**
* 这里使用synchronized关键字来锁住线程，
* 这样当线程被再次启动的时候就不会一个任务启动多个线程了。
*/
if (task.equals("upload")){
synchronized (this) {
while (!close()) {
System.out.println("查找订单文件" + new Date().toString());
OrderInfoDeal.orderXmlUpload();
FtpUtils.closeFtpClient(FtpUtils.getFTPClient());
try {
Thread.sleep(60000);
} catch (InterruptedException e) {
e.printStackTrace();
}
}
}
}
else if (task.equals("download")){
synchronized (this) {
while (!close()) {
//回执xml下载
System.out.println("查找回执文件" + new Date().toString());
ReceiptDeal receiptDeal = new ReceiptDeal();
receiptDeal.receiptXmlDownload();
FtpUtils.closeFtpClient(FtpUtils.getFTPClient());
try {
Thread.sleep(60000);
} catch (InterruptedException e) {
e.printStackTrace();
}
}
}
}
}
- 优化2
之前的回执文件是直接下载至备份，然后解析存入数据库中再删除ftp上的文件，但是缺乏考虑到如果在下载过程，或者解析过程中途断掉之后的处理。如果断掉的话还是重头从ftp上下载，比较坑。
这次加入了一个temp文件，先将ftp上的文件下载到temp文件夹里面，然后进行解析插入数据库，最后将temp文件移到备份。现在每次开启任务的时候是先判断temp文件里面是否有未解析的文件，有的话先解析再下载。
这是项目流程考虑的不清楚！我的我的~
- 优化3
之前的存储到数据库是解析一个对象存储一个，这样真的太慢了！！！，插入50个就需要一分钟你敢信？
所以我将之前的单个单个存储用foreach改成了批量存储，经测试，插入五百条数据大约一秒钟不到。
用的mybatis代码如下：
<insert id="add" parameterType="java.util.ArrayList">
INSERT INTO add_receipt VALUES
<foreach item="item" index="key" collection="list"open="" separator="," close="">
(#{item.receiptId},#{item.guid},#{item.ebpCode},#{item.ebcCode},#{item.orderNo},#{item.returnStatus},#{item.returnTime}, #{item.returnInfo},#{item.uploadTime})
</foreach>;
</insert>
基本优化了以上三点。依旧新代码上传到github
现在准备转成b/s项目，接下来还需要展示回执错误信息的一个列表，还需要再写几个接口调用。
写着玩，有不对的地方还请指出来。谢谢。
联系方式
- github： 大猫传说中的gitHud地址
- 邮箱： 不经常用，回复慢的话请原谅1974469025@qq.com
网友评论