|
@@ -81,6 +81,7 @@ public class TaskSqlServiceImpl implements TaskSqlService {
|
|
|
* @param taskSqlBeans
|
|
|
*/
|
|
|
public int runTask(TaskBean t, String condition) {
|
|
|
+ log.info("SqlTask[{}] running......", t.getCode());
|
|
|
if (!TaskBean.TYPE_SQL.equals(t.getType())) {
|
|
|
return -1;
|
|
|
}
|
|
@@ -379,9 +380,11 @@ public class TaskSqlServiceImpl implements TaskSqlService {
|
|
|
if (count == 0) {
|
|
|
nameJdbcTemplate.update(insertSql, param);
|
|
|
}
|
|
|
+ System.err.println(i + 1);
|
|
|
}
|
|
|
log.info("SqlTask[{}] update {} records", taskSqlBean.getId(), data.size());
|
|
|
} catch (Exception e) {
|
|
|
+ e.printStackTrace();
|
|
|
return -1;
|
|
|
}
|
|
|
log.info("SqlTask[{}] doCommit cost:{}", taskSqlBean.getId(), System.currentTimeMillis() - start);
|
|
@@ -433,8 +436,6 @@ public class TaskSqlServiceImpl implements TaskSqlService {
|
|
|
cacheBean.setCacheData(result);
|
|
|
cacheBean.setFileName(fileName);
|
|
|
cacheBeanService.writeCache(cacheBean);
|
|
|
- cacheBeanService.writeCache(cacheBean);
|
|
|
- cacheBeanService.writeCache(cacheBean);
|
|
|
t.setCacheUse(TaskBean.CACHE_USE);
|
|
|
taskService.updateByPrimaryKey(t);
|
|
|
log.info("SqlTask[] saveCache cost:{}", t.getCode(), System.currentTimeMillis() - start);
|