Skip to content

T
task2.0
Commit 949bf94e by java-李谡
Options

Merge branch 'feature-ls' into 'develop' 

使用阿里代码规范插件扫描后修改

See merge request java-jdair-foc/foc-task-2.0!1
parents fe67d18c ebcdb997
Showing with 313 additions and 511 deletions
src/com/foc/task/AnkeDateMiIdMain.java
......@@ -37,7 +37,6 @@ public class AnkeDateMiIdMain {
String password = GConstants.getValue("anke.database.password", "123@abc");
String tableName = "dbo.cdr";
// args = new String[]{"2011-1212-"};
Connection conn = null;
ResultSet rs = null;
PreparedStatement pstmt = null;
......
src/com/foc/task/FlightAssignmentTaskMain.java
......@@ -3,13 +3,6 @@
*/
package com.foc.task;
import java.text.SimpleDateFormat;
import java.util.Date;
import java.util.Map;
import java.util.TreeMap;
import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;
import com.alibaba.fastjson.JSONObject;
import com.foc.TaskSupporter;
import com.foc.TaskTemplate;
......@@ -22,34 +15,38 @@ import com.foc.util.DateUtil;
import com.foc.util.IdWorker;
import com.foc.version.VersionService;
import java.text.SimpleDateFormat;
import java.util.Date;
import java.util.Map;
import java.util.TreeMap;
import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;
/**
* # 同步飞行计划书数据
* *#3 4-23 * * * root bash /mnt/foc/project/task/runassigment.sh
* 导出文件名称：jd-task-assigment-2.0.jar
* @team IT Team
*
* @author renmb
* @version 1.0
* @team IT Team
* @time 2016年11月28日
*/
public class FlightAssignmentTaskMain {
public static void main(String[] args) {
// String[] ids = "PN6345/PN6346".split("/");
// for (String flightNo:ids) {
// System.out.println("flightNo:"+flightNo);
// }
// System.exit(0);
// Logger logger = Logger.getLogger(BefBasicArchiveMain.class);
final String key = "assignment.task.is.running";
final String allTaskKey = "all.task.is.running";
final String dailyTaskKey = "daily.task.is.running";
if (HistoryConfig.getInt(key, 0) == 1) {
System.out.println("[FlightSssignmentTaskMain]上次程序正在运行！跳过本次运行。。。");
System.out.println("[FlightAssignmentTaskMain]上次程序正在运行！跳过本次运行。。。");
return;
}
if (HistoryConfig.getInt("all.task.is.running", 0) == 1) {
System.out.println("[FlightSssignmentTaskMain][ALL]上次程序正在运行！跳过本次运行。。。");
if (HistoryConfig.getInt(allTaskKey, 0) == 1) {
System.out.println("[FlightAssignmentTaskMain][ALL]上次程序正在运行！跳过本次运行。。。");
return;
}
if (HistoryConfig.getInt("daily.task.is.running", 0) == 1) {
System.out.println("[FlightSssignmentTaskMain][DAILY]上次程序正在运行！跳过本次运行。。。");
if (HistoryConfig.getInt(dailyTaskKey, 0) == 1) {
System.out.println("[FlightAssignmentTaskMain][DAILY]上次程序正在运行！跳过本次运行。。。");
return;
}
HistoryConfig.put("assignment.task.last.time", DateUtil.getDateTime());
......@@ -57,16 +54,17 @@ public class FlightAssignmentTaskMain {
HistoryConfig.saveHistory();
long startTime = System.nanoTime();
// args = new String[]{"0", "0"};
//args = new String[]{"0", "0"};
// 一个参数： 参数为向后加几天
// 两个参数： 第一个参数为向前减减几天，第二个参数向后加几天
if (args == null || args.length != 2) {
args = new String[] { "0", "0" };
int argsLengthValue = 2;
if (args == null || args.length != argsLengthValue) {
args = new String[]{"0", "0"};
}
final int start = Integer.valueOf(args[0]);// 开始日期位移天数
final int days = Integer.valueOf(args[1]);// 结束日期位移天数
// final int days = Integer.valueOf(args[1]);// 结束日期位移天数
// 开始日期位移天数
final int start = Integer.valueOf(args[0]);
// 结束日期位移天数
final int days = Integer.valueOf(args[1]);
// TODO Auto-generated method stub
final ExecutorService threadPool = Executors.newCachedThreadPool();
......@@ -74,9 +72,9 @@ public class FlightAssignmentTaskMain {
SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
final String modified = sdf.format(new Date());
System.out.println("[ODSTaskMain][修改时间]"+modified);
threadPool.execute(new Runnable() {// 5.3 航班动态接口
System.out.println("[OdsTaskMain][修改时间]" + modified);
// 5.3 航班动态接口
threadPool.execute(new Runnable() {
@Override
public void run() {
......@@ -86,8 +84,9 @@ public class FlightAssignmentTaskMain {
String dateFrom = DateUtil.dateToStr(DateUtil.offsetDate(new Date(), i), DateUtil.DATE_FORMAT);
System.out.println("[FlightSssignmentTaskMain]航班日期[" + dateFrom + "]");
final String currentVersion = IdWorker.getNextId("V");
final String lastVersion = versionService.getCurrentVersion("ASSIGNMENT", dateFrom);//HistoryConfig.getValue("assignment.current.use.version", "");// 当前使用版本
System.out.println("[FlightSssignmentTaskMain]FROM VERSION[" + lastVersion + "]TO["+currentVersion+"]");
// 当前使用版本
final String lastVersion = versionService.getCurrentVersion("ASSIGNMENT", dateFrom);
System.out.println("[FlightSssignmentTaskMain]FROM VERSION[" + lastVersion + "]TO[" + currentVersion + "]");
startFlightAssignmentTask(threadPool, lastVersion, currentVersion, i, modified);
}
......@@ -103,7 +102,7 @@ public class FlightAssignmentTaskMain {
long endTime = System.nanoTime();
long duration = endTime - startTime;
System.out
.println("[FlightSssignmentTaskMain]结束[" + DateUtil.dateToStr(new Date(), DateUtil.TIMEF_FORMAT) + "]");
.println("[FlightAssignmentTaskMain]结束[" + DateUtil.dateToStr(new Date(), DateUtil.TIMEF_FORMAT) + "]");
System.out.println("执行总共用时：" + duration + "纳秒");
System.out.println("执行总共用时格式化：" + DateUtil.getDurationTime(duration));
HistoryConfig.put(key, "0");
......@@ -130,6 +129,7 @@ public class FlightAssignmentTaskMain {
final FlightAssignmentService service = new FlightAssignmentService();
final String flightDate = DateUtil.dateToStr(DateUtil.offsetDate(new Date(), offset), DateUtil.DATE_FORMAT);
private boolean hasNewData = false;
@Override
public String setBaseUrl(TaskTemplate taskTemplate) {
......@@ -140,23 +140,14 @@ public class FlightAssignmentTaskMain {
@Override
public Map<String, String> setParams() {
Map<String, String> params = new TreeMap<String, String>();
//departStation=CTU&arrivalStation=SYX&flightNos=JD5178
params.put("flightDate", flightDate);
// params.put("departStation", "CTU");
// params.put("flightDate", "2016-09-22");
// params.put("arrivalStation", "SYX");
// params.put("flightNos", "JD5178");
return params;
}
@Override
public void successHandle(JSONObject result) {
// String flightDate = flightDate;
boolean ret = service.handle(currentVersion, flightDate, result, modified);
if(!hasNewData && ret){
if (!hasNewData && ret) {
hasNewData = true;
}
}
......@@ -186,7 +177,7 @@ public class FlightAssignmentTaskMain {
public boolean finish() {
// TODO Auto-generated method stub
if(hasNewData){
if (hasNewData) {
System.out.println("【finish】本次有新数据，需要删除老数据!");
service.finish(flightDate, lastVersion, currentVersion);
......
src/com/foc/task/HRMTaskMain.java → src/com/foc/task/HrmTaskMain.java
......@@ -6,6 +6,7 @@ import java.util.Map;
import java.util.TreeMap;
import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;
import java.util.concurrent.ThreadPoolExecutor;
import com.alibaba.fastjson.JSONObject;
import com.foc.TaskSupporter;
......@@ -17,13 +18,16 @@ import com.foc.hrm.HRMTask;
import com.foc.hrm.service.HRMService;
import com.foc.util.DateUtil;
public class HRMTaskMain {
/**
* @author lisu
*/
public class HrmTaskMain {
public static void main(String[] args) {
final String key = "hrm.task.is.running";
if (HistoryConfig.getInt(key, 0) == 1) {
System.out.println("[HRMTaskMain]上次程序正在运行！跳过本次运行。。。");
System.out.println("[HrmTaskMain]上次程序正在运行！跳过本次运行。。。");
return;
}
HistoryConfig.put("hrm.task.last.time", DateUtil.getDateTime());
......@@ -31,20 +35,21 @@ public class HRMTaskMain {
HistoryConfig.saveHistory();
long startTime = System.nanoTime();
System.out.println("[HRMTaskMain]统计时间段["+DateUtil.getDateTime()+"]");
System.out.println("[HrmTaskMain]统计时间段[" + DateUtil.getDateTime() + "]");
SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
final String modified = sdf.format(new Date());
System.out.println("[ODSTaskMain][修改时间]"+modified);
System.out.println("[OdsTaskMain][修改时间]" + modified);
// TODO Auto-generated method stub
final ExecutorService threadPool = Executors.newCachedThreadPool();
threadPool.execute(new Runnable() {// 5.4 HRM人资接口
// 5.4 HRM人资接口
threadPool.execute(new Runnable() {
@Override
public void run() {
startHRMTask(threadPool, modified);// HRM 插入或更新user和role的数据
// HRM 插入或更新user和role的数据
startHRMTask(threadPool, modified);
}
});
threadPool.shutdown();
......@@ -70,6 +75,7 @@ public class HRMTaskMain {
}
}
}
private static void startHRMTask(ExecutorService threadPool, final String modified) {
/**
......@@ -83,26 +89,32 @@ public class HRMTaskMain {
// return
// GConstants.FOC_FLIGHT_DYNAMIC_URL+"&pageParam.pageIndex="+taskTemplate.getPageIndex()+"&pageParam.pageSize="+GConstants.PAGE_SIZE;
}
@Override
public Map<String, String> setParams() {
Map<String, String> params = new TreeMap<String, String>();
params.put("companyNodeId", "4477");
params.put("includePost", "1");// 默认null，即false如果true，则返回的HrEmp才会包含empPosts属性值
//默认null，即false如果true，则返回的HrEmp才会包含empPosts属性值
params.put("includePost", "1");
return params;
}
@Override
public void successHandle(JSONObject result) {
HRMService hRMService = new HRMService();
hRMService.insertHRM(result, modified);
}
@Override
public String setPageIndexProperty() {
return "foc.hrm.page.index";
}
@Override
public boolean isGet() {
return true;
}
@Override
public boolean isPost() {
return false;
......@@ -113,6 +125,7 @@ public class HRMTaskMain {
return "hrm";
}
@Override
public boolean finish() {
// TODO Auto-generated method stub
......
src/com/foc/task/HRMUpdateTaskMain.java → src/com/foc/task/HrmUpdateTaskMain.java
......@@ -3,14 +3,14 @@
*/
package com.foc.task;
import java.text.SimpleDateFormat;
import java.util.Date;
import com.foc.conf.HistoryConfig;
import com.foc.fetcher.HCFetcher;
import com.foc.hrm.service.HRMUpdatePreMobileService;
import com.foc.util.DateUtil;
import java.text.SimpleDateFormat;
import java.util.Date;
/**
* # 格式化手机号和座机号
* 1 2 * * * root bash /mnt/foc/project/task/runupdatehrmtask.sh
......@@ -21,7 +21,7 @@ import com.foc.util.DateUtil;
* @version 1.0
* @time 2016年10月30日
*/
public class HRMUpdateTaskMain {
public class HrmUpdateTaskMain {
/**
*
......@@ -33,7 +33,7 @@ public class HRMUpdateTaskMain {
// TODO Auto-generated method stub
final String key = "hrm.premobile.task.is.running";
if (HistoryConfig.getInt(key, 0) == 1) {
System.out.println("[HRMUpdateTaskMain]上次程序正在运行！跳过本次运行。。。");
System.out.println("[HrmUpdateTaskMain]上次程序正在运行！跳过本次运行。。。");
return;
}
HistoryConfig.put("hrm.premobile.task.last.time", DateUtil.getDateTime());
......@@ -41,13 +41,8 @@ public class HRMUpdateTaskMain {
HistoryConfig.saveHistory();
long startTime = System.nanoTime();
System.out.println("[HRMUpdateTaskMain]统计时间段["+DateUtil.getDateTime()+"]");
System.out.println("[HrmUpdateTaskMain]统计时间段[" + DateUtil.getDateTime() + "]");
// String mobile = "18910892562北京";
// mobile = "+61 0468386992";
// mobile = "+61（0）467613626";
// mobile = "＋61426286619";
// System.out.println(mobile.replaceAll("[^0-9|+]+", ""));
// 如果有一个参数则修改手机号
args = new String[]{"1"};
boolean isUpdateMobile = false;
......@@ -57,7 +52,7 @@ public class HRMUpdateTaskMain {
}
SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
final String modified = sdf.format(new Date());
System.out.println("[ODSTaskMain][修改时间]"+modified);
System.out.println("[OdsTaskMain][修改时间]" + modified);
HRMUpdatePreMobileService service = new HRMUpdatePreMobileService();
service.start(isUpdateMobile);
......
src/com/foc/task/ODSChangeTaskMain.java → src/com/foc/task/OdsChangeTaskMain.java
package com.foc.task;
import java.text.SimpleDateFormat;
import java.util.Calendar;
import java.util.Date;
import java.util.Map;
import java.util.TreeMap;
import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;
import com.alibaba.fastjson.JSONObject;
import com.foc.TaskSupporter;
import com.foc.TaskTemplate;
......@@ -18,34 +10,40 @@ import com.foc.ods.ODSTask;
import com.foc.ods.service.ODSService;
import com.foc.util.DateUtil;
import java.text.SimpleDateFormat;
import java.util.Date;
import java.util.Map;
import java.util.TreeMap;
import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;
/**
* 每天定时同步昨天和今天的数据
* 只同步ODS数据
* *#1 * * * * root bash /mnt/foc/project/task/runodschangetask.sh
* 导出文件名称： jd-task-odschange-2.0.jar
*
* @team IT Team
* @author renmb
* @version 1.0
* @team IT Team
* @time 2016年10月3日
*/
public class ODSChangeTaskMain {
public class OdsChangeTaskMain {
public static void main(String[] args) {
// System.out.println(DateUtil.getDateTime().replaceAll("[-|:|\\s]", "")+".json");
// System.exit(0);
// Logger logger = Logger.getLogger(BefBasicArchiveMain.class);
final String key = "ods.change.task.is.running";
final String allTaskKey = "all.task.is.running";
final String dailyTaskKey = "daily.task.is.running";
if (HistoryConfig.getInt(key, 0) == 1) {
System.out.println("[ODSChangeTaskMain]上次程序正在运行！跳过本次运行。。。");
System.out.println("[OdsChangeTaskMain]上次程序正在运行！跳过本次运行。。。");
return;
}
if (HistoryConfig.getInt("all.task.is.running", 0) == 1) {
System.out.println("[ODSChangeTaskMain][ALL]上次程序正在运行！跳过本次运行。。。");
if (HistoryConfig.getInt(allTaskKey, 0) == 1) {
System.out.println("[OdsChangeTaskMain][ALL]上次程序正在运行！跳过本次运行。。。");
return;
}
if (HistoryConfig.getInt("daily.task.is.running", 0) == 1) {
System.out.println("[ODSChangeTaskMain][DAILY]上次程序正在运行！跳过本次运行。。。");
if (HistoryConfig.getInt(dailyTaskKey, 0) == 1) {
System.out.println("[OdsChangeTaskMain][DAILY]上次程序正在运行！跳过本次运行。。。");
return;
}
HistoryConfig.put("ods.change.task.last.time", DateUtil.getDateTime());
......@@ -54,39 +52,32 @@ public class ODSChangeTaskMain {
long startTime = System.nanoTime();
// 一个参数： 参数为向后加几天
// 两个参数： 第一个参数为向前减减几天，第二个参数向后加几天
if(args == null || args.length ==0 || args.length > 2){
int argsLengthValue1 = 1;
int argsLengthValue2 = 2;
if (args == null || args.length == 0 || args.length > argsLengthValue2) {
args = new String[]{"-1", "0"};
} else if(args.length == 1){
} else if (args.length == argsLengthValue1) {
args = new String[]{"-1", args[0]};
} else if(args.length == 2){
} else if (args.length == argsLengthValue2) {
args = new String[]{args[0], args[1]};
}
// Calendar calendar = Calendar.getInstance();
// int hour = calendar.get(Calendar.HOUR_OF_DAY);
// int timeOffset = GConstants.getIntValue("start.time.offset.hour", 8);
// if(hour>timeOffset){
// if("-1".equals(args[0])){
// args[0] = "0";
// }
// }
final int start = Integer.valueOf(args[0]);// 开始日期位移天数
final int days = Integer.valueOf(args[1]);// 结束日期位移天数
// 开始日期位移天数
final int start = Integer.valueOf(args[0]);
// 结束日期位移天数
final int days = Integer.valueOf(args[1]);
String dateFrom = DateUtil.dateToStr(DateUtil.offsetDate(new Date(), start), DateUtil.DATE_FORMAT);
String dateTo = DateUtil.dateToStr(DateUtil.offsetDate(new Date(), days), DateUtil.DATE_FORMAT);
System.out.println("[ODSChangeTaskMain]统计时间段["+dateFrom+"]TO["+dateTo+"]");
System.out.println("[OdsChangeTaskMain]统计时间段[" + dateFrom + "]TO[" + dateTo + "]");
SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
final String modified = sdf.format(new Date());
System.out.println("[ODSChangeTaskMain][修改时间]"+modified);
System.out.println("[OdsChangeTaskMain][修改时间]" + modified);
// TODO Auto-generated method stub
final ExecutorService threadPool = Executors.newCachedThreadPool();
threadPool.execute(new Runnable() {// 5.2 ODS飞行计划调整单接口
// 5.2 ODS飞行计划调整单接口
threadPool.execute(new Runnable() {
@Override
public void run() {
......@@ -118,6 +109,7 @@ public class ODSChangeTaskMain {
}
}
}
private static void startODSChangeTask(ExecutorService threadPoolSecond, final String modified, final int startDateIndex, final int offsetDateIndex) {
/**
* ODS飞行计划调整单
......@@ -137,8 +129,8 @@ public class ODSChangeTaskMain {
String fltChangeDateFrom = DateUtil.dateToStr(DateUtil.offsetDate(new Date(), startDateIndex), DateUtil.DATE_FORMAT);
String fltChangeDateTo = DateUtil.dateToStr(DateUtil.offsetDate(new Date(), offsetDateIndex), DateUtil.DATE_FORMAT);
params.put("fltChangeDateFrom", fltChangeDateFrom+" 00:00:00");
params.put("fltChangeDateTo", fltChangeDateTo+" 23:59:59");
params.put("fltChangeDateFrom", fltChangeDateFrom + " 00:00:00");
params.put("fltChangeDateTo", fltChangeDateTo + " 23:59:59");
return params;
}
......
src/com/foc/task/ODSTaskMain.java → src/com/foc/task/OdsTaskMain.java
package com.foc.task;
import java.text.SimpleDateFormat;
import java.util.Calendar;
import java.util.Date;
import java.util.Map;
import java.util.TreeMap;
import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;
import com.alibaba.fastjson.JSONObject;
import com.foc.TaskSupporter;
import com.foc.TaskTemplate;
......@@ -18,6 +10,14 @@ import com.foc.ods.ODSTask;
import com.foc.ods.service.ODSService;
import com.foc.util.DateUtil;
import java.text.SimpleDateFormat;
import java.util.Calendar;
import java.util.Date;
import java.util.Map;
import java.util.TreeMap;
import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;
/**
* 每天定时同步昨天和今天的数据
* 只同步ODS数据
......@@ -27,28 +27,27 @@ import com.foc.util.DateUtil;
* *#1 * * * * root bash /mnt/foc/project/task/runodschangetask.sh
* 导出文件名称：jd-task-ods-2.0.jar
*
* @team IT Team
* @author renmb
* @version 1.0
* @team IT Team
* @time 2016年10月3日
*/
public class ODSTaskMain {
public class OdsTaskMain {
public static void main(String[] args) {
// System.out.println(DateUtil.getDateTime().replaceAll("[-|:|\\s]", "")+".json");
// System.exit(0);
// Logger logger = Logger.getLogger(BefBasicArchiveMain.class);
final String key = "ods.task.is.running";
final String allTaskKey = "all.task.is.running";
final String dailyTaskKey = "daily.task.is.running";
if (HistoryConfig.getInt(key, 0) == 1) {
System.out.println("[ODSTaskMain]上次程序正在运行！跳过本次运行。。。");
System.out.println("[OdsTaskMain]上次程序正在运行！跳过本次运行。。。");
return;
}
if (HistoryConfig.getInt("all.task.is.running", 0) == 1) {
System.out.println("[ODSTaskMain][ALL]上次程序正在运行！跳过本次运行。。。");
if (HistoryConfig.getInt(allTaskKey, 0) == 1) {
System.out.println("[OdsTaskMain][ALL]上次程序正在运行！跳过本次运行。。。");
return;
}
if (HistoryConfig.getInt("daily.task.is.running", 0) == 1) {
System.out.println("[ODSTaskMain][DAILY]上次程序正在运行！跳过本次运行。。。");
if (HistoryConfig.getInt(dailyTaskKey, 0) == 1) {
System.out.println("[OdsTaskMain][DAILY]上次程序正在运行！跳过本次运行。。。");
return;
}
HistoryConfig.put("ods.task.last.time", DateUtil.getDateTime());
......@@ -57,51 +56,52 @@ public class ODSTaskMain {
long startTime = System.nanoTime();
// 一个参数： 参数为向后加几天
// 两个参数： 第一个参数为向前减减几天，第二个参数向后加几天
if(args == null || args.length ==0 || args.length > 2){
int argsLength = 2;
if (args == null || args.length == 0 || args.length > argsLength) {
args = new String[]{"-1", "0"};
} else if(args.length == 1){
} else if (args.length == 1) {
args = new String[]{"-1", args[0]};
} else if(args.length == 2){
} else if (args.length == argsLength) {
args = new String[]{args[0], args[1]};
}
Calendar calendar = Calendar.getInstance();
int hour = calendar.get(Calendar.HOUR_OF_DAY);
int timeOffset = GConstants.getIntValue("start.time.offset.hour", 8);
if(hour>timeOffset){
if("-1".equals(args[0])){
if (hour > timeOffset) {
String argsValue = "-1";
if (argsValue.equals(args[0])) {
args[0] = "0";
}
}
final int start = Integer.valueOf(args[0]);// 开始日期位移天数
final int days = Integer.valueOf(args[1]);// 结束日期位移天数
// 开始日期位移天数
final int start = Integer.valueOf(args[0]);
// 结束日期位移天数
final int days = Integer.valueOf(args[1]);
String dateFrom = DateUtil.dateToStr(DateUtil.offsetDate(new Date(), start), DateUtil.DATE_FORMAT);
String dateTo = DateUtil.dateToStr(DateUtil.offsetDate(new Date(), days), DateUtil.DATE_FORMAT);
System.out.println("[ODSTaskMain]统计时间段["+dateFrom+"]TO["+dateTo+"]");
System.out.println("[OdsTaskMain]统计时间段[" + dateFrom + "]TO[" + dateTo + "]");
SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
final String modified = sdf.format(new Date());
System.out.println("[ODSTaskMain][修改时间]"+modified);
System.out.println("[OdsTaskMain][修改时间]" + modified);
// TODO Auto-generated method stub
final ExecutorService threadPool = Executors.newCachedThreadPool();
threadPool.execute(new Runnable() {// 5.1 ODS飞行计划接口（亦即机组排班接口）
// 5.1 ODS飞行计划接口（亦即机组排班接口）
threadPool.execute(new Runnable() {
@Override
public void run() {
if(0>=start && 0<= days){// 优先同步今天的数据
// 优先同步今天的数据
if (0 >= start && 0 <= days) {
startODSTask(threadPool, 0, modified);
}
for (int i = start; i <= days; i++) {
if(i != 0){
startODSTask(threadPool, i, modified);// 插入或更新ods数据
if (i != 0) {
// 插入或更新ods数据
startODSTask(threadPool, i, modified);
}
}
}
......@@ -139,6 +139,7 @@ public class ODSTaskMain {
final ODSService oDSService = new ODSService();
final String flightDate = DateUtil.dateToStr(DateUtil.offsetDate(new Date(), offsetDateIndex), DateUtil.DATE_FORMAT);
@Override
public String setBaseUrl(TaskTemplate taskTemplate) {
......@@ -151,7 +152,6 @@ public class ODSTaskMain {
Map<String, String> params = new TreeMap<String, String>();
params.put("flightDate", flightDate);
// params.put("flightNos", flightNos);
return params;
}
......@@ -192,7 +192,6 @@ public class ODSTaskMain {
});
oDSTask.run();
// threadPoolSecond.execute(oDSTask);
}
}
src/com/foc/task/PlanPushTaskMain.java
......@@ -3,34 +3,32 @@
*/
package com.foc.task;
import com.foc.conf.HistoryConfig;
import com.foc.plan.push.service.PlanPushService;
import com.foc.util.DateUtil;
import java.text.SimpleDateFormat;
import java.util.Date;
import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;
import com.foc.conf.HistoryConfig;
import com.foc.plan.push.service.PlanPushService;
import com.foc.util.DateUtil;
/**
* # 签到推送
* *#1 5-23 * * * root bash /mnt/foc/project/task/runpushtask.sh
* 导出文件名称： jd-task-push-2.6.jar
*
* @team BBDTEK IT Team
* @author renmb
* @version 1.0
* @team BBDTEK IT Team
* @time 2016年12月17日
*/
public class PlanPushTaskMain {
public static void main(String[] args) {
// System.out.println(String.format("%02d", 2));System.exit(0);
// System.out.println(DateUtil.getDateTime().replaceAll("[-|:|\\s]",
// "")+".json");
// System.exit(0);
// Logger logger = Logger.getLogger(BefBasicArchiveMain.class);
boolean isForce = false;
if((args != null && args.length >= 1 && "F".equals((args[args.length-1])))){
final String stringValue = "F";
final String allTaskKey = "all.task.is.running";
final String dailyTaskKey = "daily.task.is.running";
if ((args != null && args.length >= 1 && stringValue.equals((args[args.length - 1])))) {
System.out.println("[PlanPushTaskMain]强制模式");
isForce = true;
}
......@@ -39,11 +37,11 @@ public class PlanPushTaskMain {
System.out.println("[PlanPushTaskMain]上次程序正在运行！跳过本次运行。。。");
return;
}
if (!isForce && HistoryConfig.getInt("all.task.is.running", 0) == 1) {
if (!isForce && HistoryConfig.getInt(allTaskKey, 0) == 1) {
System.out.println("[PlanPushTaskMain][ALL]上次程序正在运行！跳过本次运行。。。");
return;
}
if (!isForce && HistoryConfig.getInt("daily.task.is.running", 0) == 1) {
if (!isForce && HistoryConfig.getInt(dailyTaskKey, 0) == 1) {
System.out.println("[PlanPushTaskMain][DAILY]上次程序正在运行！跳过本次运行。。。");
return;
}
......@@ -60,8 +58,8 @@ public class PlanPushTaskMain {
System.out.println("[PlanPushTaskMain][修改时间]" + modified);
// TODO Auto-generated method stub
final ExecutorService threadPool = Executors.newCachedThreadPool();
threadPool.execute(new Runnable() {// 5.1 ODS飞行计划接口（亦即机组排班接口）
// 5.1 ODS飞行计划接口（亦即机组排班接口）
threadPool.execute(new Runnable() {
@Override
public void run() {
......
src/com/foc/task/SoundCopyTaskMain.java
......@@ -32,26 +32,21 @@ public class SoundCopyTaskMain {
* @param args
*/
public static void main(String[] args) {
// TODO Auto-generated method stub
List<Map<String, Object>> sounds = new ArrayList<>();//.fetch("sound", "select * from dbo.cdr where id BETWEEN " + 10000 + " AND "+30000+" order by id ASC");
List<Map<String, Object>> sounds = new ArrayList<>();
String driver = "com.microsoft.jdbc.sqlserver.SQLServerDriver";
String url = "jdbc:microsoft:sqlserver://10.72.23.187:1433;DatabaseName=edison200";
Connection conn = null;
ResultSet rs = null;
PreparedStatement pstmt = null;
int count = 0;
try {
// System.out.println("[SoundTaskMain]统计ID段[" + minId + " ]TO[" + maxId + " ]");
Class.forName(driver);
conn = DriverManager.getConnection(url, "foctest", "123@abc");
pstmt = conn
.prepareStatement("select * from dbo.cdr where id BETWEEN " + 10000 + " AND "+30000+" order by id ASC");
rs = pstmt.executeQuery();
List<SoundRecordingEntity> recordingEntities = new ArrayList<SoundRecordingEntity>();
Long newMaxId = 0L;
System.out.printf("%s\t%s\t%s\t%s\t%s\t%s\t%s\t%s\t%s\n","id","caller","callee","stm","edm","elapsed","recfile","filesize","callresult");
while (rs.next()) {
SoundRecordingEntity recordingEntity = new SoundRecordingEntity();
......@@ -66,7 +61,7 @@ public class SoundCopyTaskMain {
recordingEntity.setResult(rs.getString("callresult"));
recordingEntities.add(recordingEntity);
System.out.printf("%s\t%s\t%s\t%s\t%s\t%s\t%s\t%s\t%s\n",rs.getObject("id"),rs.getObject("caller"), rs.getObject("callee"), rs.getObject("stm"), rs.getObject("edm"), rs.getObject("elapsed"), rs.getObject("recfile"), rs.getObject("filesize"), rs.getObject("callresult"));
Map<String, Object> row = new HashMap<>();
Map<String, Object> row = new HashMap<>(10);
row.put("id", rs.getObject("id"));
row.put("caller", rs.getObject("caller"));
row.put("callee", rs.getObject("callee"));
......@@ -80,8 +75,6 @@ public class SoundCopyTaskMain {
sounds.add(row);
}
// service.updateSoundmaxId(newMaxId);
// return count;
} catch (ClassNotFoundException e) {
e.printStackTrace();
} catch (SQLException e) {
......
src/com/foc/task/TestMain.java
......@@ -3,6 +3,9 @@
*/
package com.foc.task;
import java.util.HashMap;
import java.util.Map;
/**
*
* @team BBDTEK IT Team
......@@ -20,30 +23,37 @@ public class TestMain {
*/
public static void main(String[] args) {
// TODO Auto-generated method stub
int count = 6;
int pageNo=2;
int pageSize=4;
System.out.println(count/pageSize+1);
int startSize=(pageNo-1)*pageSize;
int endSize=pageNo*pageSize;
String sql = "SELECT ROWNUM AS rowno,tmp.* FROM (SELECT T.PK_JKBX,T.DJZT FROM ER_BXZB T ORDER BY T.TS DESC) tmp WHERE ROWNUM<="+endSize;
System.out.println("SELECT * FROM ("+sql+") tm WHERE tm.rowno >"+startSize);
int index1 = sql.indexOf("SELECT")+6;
String prefixSql1 = sql.substring(0, index1);
String endSql1 = sql.substring(index1);
String qsql1 = prefixSql1+" ROWNUM AS rowno,"+endSql1;
int index = qsql1.lastIndexOf("WHERE")+5;
String prefixSql = qsql1.substring(0, index);
String endSql = qsql1.substring(index);
String qsql = prefixSql+" ROWNUM<="+endSize+" AND "+endSql;
System.out.println("SELECT * FROM ("+qsql+") tmp WHERE tmp.rowno >"+startSize);
//
// int count = 6;
// int pageNo=2;
// int pageSize=4;
// System.out.println(count/pageSize+1);
// int startSize=(pageNo-1)*pageSize;
// int endSize=pageNo*pageSize;
//
// String sql = "SELECT ROWNUM AS rowno,tmp.* FROM (SELECT T.PK_JKBX,T.DJZT FROM ER_BXZB T ORDER BY T.TS DESC) tmp WHERE ROWNUM<="+endSize;
// System.out.println("SELECT * FROM ("+sql+") tm WHERE tm.rowno >"+startSize);
//
//
// int index1 = sql.indexOf("SELECT")+6;
// String prefixSql1 = sql.substring(0, index1);
// String endSql1 = sql.substring(index1);
// String qsql1 = prefixSql1+" ROWNUM AS rowno,"+endSql1;
//
// int index = qsql1.lastIndexOf("WHERE")+5;
// String prefixSql = qsql1.substring(0, index);
// String endSql = qsql1.substring(index);
//
// String qsql = prefixSql+" ROWNUM<="+endSize+" AND "+endSql;
//
// System.out.println("SELECT * FROM ("+qsql+") tmp WHERE tmp.rowno >"+startSize);
// Map<String,String> map = new HashMap<>(3);
// map.put("1","2");
// map.put("2","2");
// map.put("3","2");
// map.put("4","2");
// map.put("5","2");
// System.out.println(map.size());
}
}
src/com/foc/task/TestSoundCopyTaskMain.java deleted 100644 → 0
/**
*
*/
package com.foc.task;
import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.PreparedStatement;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.util.ArrayList;
import java.util.HashMap;
import java.util.List;
import java.util.Map;
import com.foc.sound.entity.SoundRecordingEntity;
import com.foc.util.DBHelper;
/**
*
* @team BBDTEK IT Team
* @author renmb
* @version 1.0
* @time 2017年9月3日
*/
public class TestSoundCopyTaskMain {
/**
* 测试类
*
* @author renmb
* @time 2017年9月3日
* @param args
*/
public static void main(String[] args) {
// TODO Auto-generated method stub
List<Map<String, Object>> sounds = new ArrayList<>();//.fetch("sound", "select * from dbo.cdr where id BETWEEN " + 10000 + " AND "+30000+" order by id ASC");
String driver = "com.microsoft.jdbc.sqlserver.SQLServerDriver";
String url = "jdbc:microsoft:sqlserver://10.72.23.187:1433;DatabaseName=edison200";
Connection conn = null;
ResultSet rs = null;
PreparedStatement pstmt = null;
int count = 0;
try {
// System.out.println("[SoundTaskMain]统计ID段[" + minId + " ]TO[" + maxId + " ]");
Class.forName(driver);
conn = DriverManager.getConnection(url, "foctest", "123@abc");
pstmt = conn
.prepareStatement("select * from dbo.cdr where id BETWEEN " + 10000 + " AND "+30000+" order by id ASC");
rs = pstmt.executeQuery();
List<SoundRecordingEntity> recordingEntities = new ArrayList<SoundRecordingEntity>();
Long newMaxId = 0L;
System.out.printf("%s\t%s\t%s\t%s\t%s\t%s\t%s\t%s\t%s\n","id","caller","callee","stm","edm","elapsed","recfile","filesize","callresult");
while (rs.next()) {
SoundRecordingEntity recordingEntity = new SoundRecordingEntity();
recordingEntity.setId(String.valueOf(rs.getInt("id")));
recordingEntity.setCallNo(rs.getString("caller"));
recordingEntity.setAcceptNo(rs.getString("callee"));
recordingEntity.setBeginTime(rs.getDate("stm"));
recordingEntity.setEndTime(rs.getDate("edm"));
recordingEntity.setDuration(rs.getInt("elapsed"));
recordingEntity.setDownloadUrl(rs.getString("recfile"));
recordingEntity.setDownloadSize(rs.getLong("filesize"));
recordingEntity.setResult(rs.getString("callresult"));
recordingEntities.add(recordingEntity);
System.out.printf("%s\t%s\t%s\t%s\t%s\t%s\t%s\t%s\t%s\n",rs.getObject("id"),rs.getObject("caller"), rs.getObject("callee"), rs.getObject("stm"), rs.getObject("edm"), rs.getObject("elapsed"), rs.getObject("recfile"), rs.getObject("filesize"), rs.getObject("callresult"));
Map<String, Object> row = new HashMap<>();
row.put("id", rs.getObject("id"));
row.put("caller", rs.getObject("caller"));
row.put("callee", rs.getObject("callee"));
row.put("stm", rs.getObject("stm"));
row.put("edm", rs.getObject("edm"));
row.put("elapsed", rs.getObject("elapsed"));
row.put("recfile", rs.getObject("recfile"));
row.put("filesize", rs.getObject("filesize"));
row.put("direct", rs.getObject("direct"));
row.put("callresult", rs.getObject("callresult"));
sounds.add(row);
}
// service.updateSoundmaxId(newMaxId);
// return count;
} catch (ClassNotFoundException e) {
e.printStackTrace();
} catch (SQLException e) {
e.printStackTrace();
} finally {
try {
rs.close();
} catch (Exception e2) {}
try {
pstmt.close();
} catch (Exception e2) {}
try {
conn.close();
} catch (Exception e2) {}
}
DBHelper.insert("foc", "dbo.cdr", sounds);
}
}
src/com/foc/task/UCImGroupTaskMain.java → src/com/foc/task/UcImGroupTaskMain.java
......@@ -3,70 +3,72 @@
*/
package com.foc.task;
import java.util.List;
import com.foc.fetcher.HCFetcher;
import com.foc.util.DateUtil;
import com.uc.entity.UCImGroupEntity;
import com.uc.entity.UserProfileEntity;
import com.uc.service.FOCImGroupService;
import com.uc.service.UCImGroupService;
import com.uc.service.UCUserService;
import java.util.List;
/**
* # 每小时同步一次华为的群信息
* 0 *#1 * * * root bash /mnt/foc/project/task/runucgroup.sh
* 导出文件名称： jd-task-group-2.6.jar
*
* @team BBDTEK IT Team
* @author renmb
* @version 1.0
* @team BBDTEK IT Team
* @time 2017年3月2日
*/
public class UCImGroupTaskMain {
public class UcImGroupTaskMain {
/**
*
* @param args
* @author renmb
* @time 2017年3月2日
* @param args
*/
public static void main(String[] args) {
// TODO Auto-generated method stub
// TODO Auto-generated method stub
System.out.println("[UCImGroupTaskMain]开始时间[" + DateUtil.getDateTime() + "]");
System.out.println("[UcImGroupTaskMain]开始时间[" + DateUtil.getDateTime() + "]");
long startTime = System.nanoTime();
try {
FOCImGroupService focService = new FOCImGroupService();
UCImGroupService ucService = new UCImGroupService(focService);
if(args.length>0){
if("SQL".equals(args[0])){// 通过SQL同步
if (args.length > 0) {
// 通过SQL同步
String str1 = "SQL";
String str2 = "SELECT";
String str3 = "ALL";
if (str1.equals(args[0])) {
if(args[1].startsWith("SELECT")){
if (args[1].startsWith(str2)) {
List<UCImGroupEntity> users = ucService.findGroupListBySql(args[1]);
System.out.println("本次同步总人数："+users.size());
System.out.println("本次同步总人数：" + users.size());
ucService.handleGroup(users, "SQL");
}
} else if("ALL".equals(args[0])){// 同步所有没有绑定华为账号的用户
// 同步所有没有绑定华为账号的用户
} else if (str3.equals(args[0])) {
List<UCImGroupEntity> users = ucService.findGroupList(null);
System.out.println("本次同步总人数："+users.size());
System.out.println("本次同步总人数：" + users.size());
ucService.handleGroup(users, "ALL");
} else {
List<UCImGroupEntity> users = ucService.findGroupList(args);// 同步指定用户ID的用户
System.out.println("本次同步总人数："+users.size());
// 同步指定用户ID的用户
List<UCImGroupEntity> users = ucService.findGroupList(args);
System.out.println("本次同步总人数：" + users.size());
ucService.handleGroup(users, "ID");
}
}
} catch (Exception e) {
// TODO: handle exception
e.printStackTrace();
}
long endTime = System.nanoTime();
long duration = endTime - startTime;
System.out.println("[UCImGroupTaskMain]结束时间[" + DateUtil.getDateTime() + "]");
System.out.println("[UCImGroupTaskMain]总共用时：" + duration + "纳秒");
System.out.println("[UCImGroupTaskMain]总共用时格式化：" + DateUtil.getDurationTime(duration));
System.out.println("[UcImGroupTaskMain]结束时间[" + DateUtil.getDateTime() + "]");
System.out.println("[UcImGroupTaskMain]总共用时：" + duration + "纳秒");
System.out.println("[UcImGroupTaskMain]总共用时格式化：" + DateUtil.getDurationTime(duration));
HCFetcher.getInstance().shutdown();
System.exit(0);
}
......
src/com/foc/task/UCUserTaskMain.java → src/com/foc/task/UcUserTaskMain.java
......@@ -3,79 +3,82 @@
*/
package com.foc.task;
import java.util.List;
import com.foc.fetcher.HCFetcher;
import com.foc.util.DateUtil;
import com.uc.demo.UCDepartmentDemo;
import com.uc.entity.SeatEntity;
import com.uc.entity.UserProfileEntity;
import com.uc.service.UCUserService;
import java.util.List;
/**
* # 每天凌晨1点同步用户数据
* 1 * * * root bash /mnt/foc/project/task/runhrmtask.sh
* 导出文件名称： jd-task-hrm-2.6.jar
*
* @team IT Team
* @author renmb
* @version 1.0
* @team IT Team
* @time 2017年1月17日
*/
public class UCUserTaskMain {
public class UcUserTaskMain {
/**
*
* @param args
* @author renmb
* @time 2017年1月17日
* @param args
*/
public static void main(String[] args) {
// TODO Auto-generated method stub
System.out.println("[UCUserTaskMain]开始时间[" + DateUtil.getDateTime() + "]");
System.out.println("[UcUserTaskMain]开始时间[" + DateUtil.getDateTime() + "]");
long startTime = System.nanoTime();
try {
UCUserService service = new UCUserService();
if(args.length>0){
if("SQL".equals(args[0])){// 通过SQL同步
String str1 = "SQL";
String str2 = "SELECT";
String str3 = "ALL";
if (args.length > 0) {
// 通过SQL同步
if (str1.equals(args[0])) {
if(args[1].startsWith("SELECT")){
if (args[1].startsWith(str2)) {
List<UserProfileEntity> users = service.findUserListBySql(args[1]);
System.out.println("本次同步总人数："+users.size());
System.out.println("本次同步总人数：" + users.size());
service.addAccountToUc(users);
List<SeatEntity> seatList = service.findSeatListBySql(args[1]);// 同步指定用户ID的用户
System.out.println("本次同步总席位数："+seatList.size());
// 同步指定用户ID的用户
List<SeatEntity> seatList = service.findSeatListBySql(args[1]);
System.out.println("本次同步总席位数：" + seatList.size());
service.addSeatAccountToUc(seatList);
}
} else if("ALL".equals(args[0])){// 同步所有没有绑定华为账号的用户
// 同步所有没有绑定华为账号的用户
} else if (str3.equals(args[0])) {
List<UserProfileEntity> users = service.findUserList(null);
System.out.println("本次同步总人数："+users.size());
System.out.println("本次同步总人数：" + users.size());
service.addAccountToUc(users);
List<SeatEntity> seatList = service.findSeatList(null);// 同步指定用户ID的用户
System.out.println("本次同步总席位数："+seatList.size());
// 同步指定用户ID的用户
List<SeatEntity> seatList = service.findSeatList(null);
System.out.println("本次同步总席位数：" + seatList.size());
service.addSeatAccountToUc(seatList);
} else {
List<UserProfileEntity> users = service.findUserList(args);// 同步指定用户ID的用户
System.out.println("本次同步总人数："+users.size());
// 同步指定用户ID的用户
List<UserProfileEntity> users = service.findUserList(args);
System.out.println("本次同步总人数：" + users.size());
service.addAccountToUc(users);
List<SeatEntity> seatList = service.findSeatList(args);// 同步指定用户ID的用户
System.out.println("本次同步总席位数："+seatList.size());
// 同步指定用户ID的用户
List<SeatEntity> seatList = service.findSeatList(args);
System.out.println("本次同步总席位数：" + seatList.size());
service.addSeatAccountToUc(seatList);
}
}
} catch (Exception e) {
// TODO: handle exception
e.printStackTrace();
}
long endTime = System.nanoTime();
long duration = endTime - startTime;
System.out.println("[UCUserTaskMain]结束时间[" + DateUtil.getDateTime() + "]");
System.out.println("[UCUserTaskMain]总共用时：" + duration + "纳秒");
System.out.println("[UCUserTaskMain]总共用时格式化：" + DateUtil.getDurationTime(duration));
System.out.println("[UcUserTaskMain]结束时间[" + DateUtil.getDateTime() + "]");
System.out.println("[UcUserTaskMain]总共用时：" + duration + "纳秒");
System.out.println("[UcUserTaskMain]总共用时格式化：" + DateUtil.getDurationTime(duration));
HCFetcher.getInstance().shutdown();
System.exit(0);
}
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment