From a4dcca761cfe73acca8b9dc0a0d664451d5cc89a Mon Sep 17 00:00:00 2001
From: java110 <928255095@qq.com>
Date: 星期五, 11 六月 2021 14:15:31 +0800
Subject: [PATCH] 优化消息发布功能
---
service-job/src/main/java/com/java110/job/smo/HcFtpToFileSystemQuartz.java | 616 ++++++++++++++++++++++++++++----------------------------
1 files changed, 308 insertions(+), 308 deletions(-)
diff --git a/service-job/src/main/java/com/java110/job/smo/HcFtpToFileSystemQuartz.java b/service-job/src/main/java/com/java110/job/smo/HcFtpToFileSystemQuartz.java
old mode 100644
new mode 100755
index c5d42d5..c31ba74
--- a/service-job/src/main/java/com/java110/job/smo/HcFtpToFileSystemQuartz.java
+++ b/service-job/src/main/java/com/java110/job/smo/HcFtpToFileSystemQuartz.java
@@ -16,356 +16,356 @@
import java.util.*;
/**
- *
+ *
* @author
- *
+ *
*/
public abstract class HcFtpToFileSystemQuartz{
- protected static final Logger logger = LoggerFactory.getLogger(HcFtpToFileSystemQuartz.class);
- @Autowired
- private IHcFtpFileDAO iHcFtpFileDAO;
- @Autowired
- private IHcFtpFileSMO iHcFtpFileSMO;
+ protected static final Logger logger = LoggerFactory.getLogger(HcFtpToFileSystemQuartz.class);
+ @Autowired
+ private IHcFtpFileDAO iHcFtpFileDAO;
+ @Autowired
+ private IHcFtpFileSMO iHcFtpFileSMO;
- /*private IPrvncDumpSMO prvncDumpSMO;*/
- // 杩愯鐘舵�侊紝R锛氭鍦ㄦ墽琛� T锛氱瓑寰呰繍琛� TD1:鏂囦欢涓嬭浇澶辫触 TD2:鏂囦欢鍐呭淇濆瓨澶辫触 TU1:鏁版嵁鏂囦欢鐢熸垚澶辫触 TU2:鏁版嵁鏂囦欢涓婁紶澶辫触
- private static final String TASK_STATE_R = "R";// 姝ｅ湪杩愯
- private static final String TASK_STATE_T = "T";// 绛夊緟杩愯
- private static final String TASK_STATE_E1 = "E1";// 鎵ц浜嬪墠杩囩▼澶辫触
- private static final String TASK_STATE_E2 = "E2";// 澶勭悊鏁版嵁澶辫触
- private static final String TASK_STATE_E3 = "E3";// 鎵ц浜嬪悗杩囩▼澶辫触
+ /*private IPrvncDumpSMO prvncDumpSMO;*/
+ // 杩愯鐘舵�侊紝R锛氭鍦ㄦ墽琛� T锛氱瓑寰呰繍琛� TD1:鏂囦欢涓嬭浇澶辫触 TD2:鏂囦欢鍐呭淇濆瓨澶辫触 TU1:鏁版嵁鏂囦欢鐢熸垚澶辫触 TU2:鏁版嵁鏂囦欢涓婁紶澶辫触
+ private static final String TASK_STATE_R = "R";// 姝ｅ湪杩愯
+ private static final String TASK_STATE_T = "T";// 绛夊緟杩愯
+ private static final String TASK_STATE_E1 = "E1";// 鎵ц浜嬪墠杩囩▼澶辫触
+ private static final String TASK_STATE_E2 = "E2";// 澶勭悊鏁版嵁澶辫触
+ private static final String TASK_STATE_E3 = "E3";// 鎵ц浜嬪悗杩囩▼澶辫触
- public void initTask() {
+ public void initTask() {
- // 灏嗘墍鏈夌殑浠诲姟鐘舵�佹敼涓虹瓑寰呰繍琛岀姸鎬�
- Map paramIn = new HashMap();
- paramIn.put("oldRunState", "R");
- paramIn.put("runState", "T");
- int updateFtpItemRunStateFlag = iHcFtpFileDAO.updateFtpItemRunState(paramIn);
- if (updateFtpItemRunStateFlag < 1) {
- logger.error("--銆怭rvncFtpToFileSystemQuartz.initTask銆�,娌℃湁闇�瑕佹洿鏂扮殑鍐呭锛堟病鏈変笅杞戒竴鍗婂悗鍋滄搴旂敤鐨勬儏鍐碉級", paramIn);
- }
- }
+ // 灏嗘墍鏈夌殑浠诲姟鐘舵�佹敼涓虹瓑寰呰繍琛岀姸鎬�
+ Map paramIn = new HashMap();
+ paramIn.put("oldRunState", "R");
+ paramIn.put("runState", "T");
+ int updateFtpItemRunStateFlag = iHcFtpFileDAO.updateFtpItemRunState(paramIn);
+ if (updateFtpItemRunStateFlag < 1) {
+ logger.error("--銆怭rvncFtpToFileSystemQuartz.initTask銆�,娌℃湁闇�瑕佹洿鏂扮殑鍐呭锛堟病鏈変笅杞戒竴鍗婂悗鍋滄搴旂敤鐨勬儏鍐碉級", paramIn);
+ }
+ }
- /**
- * 鍚姩浠诲姟
- *
- * @param ftpItemConfigInfo
- */
- public void startFtpTask(Map ftpItemConfigInfo) throws Exception {
+ /**
+ * 鍚姩浠诲姟
+ *
+ * @param ftpItemConfigInfo
+ */
+ public void startFtpTask(Map ftpItemConfigInfo) throws Exception {
- // 杩欎箞鍋氭槸涓轰簡锛屽崟绾跨▼璋冪敤锛岄槻姝㈠绾跨▼瀵艰嚧鏁版嵁閲嶅澶勭悊
- if (!ftpItemConfigInfo.containsKey("RUN_STATE") || "R".equals(ftpItemConfigInfo.get("RUN_STATE"))) {
- return;
- }
+ // 杩欎箞鍋氭槸涓轰簡锛屽崟绾跨▼璋冪敤锛岄槻姝㈠绾跨▼瀵艰嚧鏁版嵁閲嶅澶勭悊
+ if (!ftpItemConfigInfo.containsKey("RUN_STATE") || "R".equals(ftpItemConfigInfo.get("RUN_STATE"))) {
+ return;
+ }
- long taskId = Long.parseLong(ftpItemConfigInfo.get("TASKID").toString());
+ long taskId = Long.parseLong(ftpItemConfigInfo.get("TASKID").toString());
- if (logger.isDebugEnabled()) {
- logger.debug("---銆怭rvncFtpToFileSystemQuartz.startFtpTask銆戯細浠诲姟銆�" + taskId + "銆戝紑濮嬭繍琛岋紒", taskId);
- }
+ if (logger.isDebugEnabled()) {
+ logger.debug("---銆怭rvncFtpToFileSystemQuartz.startFtpTask銆戯細浠诲姟銆�" + taskId + "銆戝紑濮嬭繍琛岋紒", taskId);
+ }
- // 淇濆瓨浠诲姟鎵ц涓昏鏃ュ織淇℃伅
- //鑾峰彇LOGID 榛樿鐢熸垚瑙勫垯涓簍adkid鍘绘帀骞存湀鏃ヤ箣鍓嶇殑鍊�+66
- String id = ftpItemConfigInfo.get("TASKID").toString();
- id = id.substring(10,id.length());
- long logid = Long.parseLong (id+"22");
- ftpItemConfigInfo.put("logid",logid);
- long taskLogID = insertTaskInfo(ftpItemConfigInfo);
+ // 淇濆瓨浠诲姟鎵ц涓昏鏃ュ織淇℃伅
+ //鑾峰彇LOGID 榛樿鐢熸垚瑙勫垯涓簍adkid鍘绘帀骞存湀鏃ヤ箣鍓嶇殑鍊�+66
+ String id = ftpItemConfigInfo.get("TASKID").toString();
+ id = id.substring(10,id.length());
+ long logid = Long.parseLong (id+"22");
+ ftpItemConfigInfo.put("logid",logid);
+ long taskLogID = insertTaskInfo(ftpItemConfigInfo);
- ftpItemConfigInfo.put("logid", taskLogID);
- ftpItemConfigInfo.put("taskid", taskId);
- ftpItemConfigInfo.put("threadrunstate", TASK_STATE_R);
- ftpItemConfigInfo.put("tnum", 1);
- // 淇敼浠诲姟鐘舵�佷负姝ｅ湪鎵ц鐘舵��
- updateTaskState(taskId, TASK_STATE_R);
- // 鏂规硶璋冪敤鏄惁鎴愬姛锛孲鎴愬姛锛堥粯璁わ級锛孍琛ㄧず澶辫触锛堝湪鏂规硶涓け璐ユ椂锛岄渶瑕佷慨鏀癸級
- ftpItemConfigInfo.put("PRE_METHOD_FLAG", "S");
- try {
- // 1.0绌烘柟娉曪紝璁╁瓙绫诲幓瀹炵幇
- prepare(ftpItemConfigInfo);
+ ftpItemConfigInfo.put("logid", taskLogID);
+ ftpItemConfigInfo.put("taskid", taskId);
+ ftpItemConfigInfo.put("threadrunstate", TASK_STATE_R);
+ ftpItemConfigInfo.put("tnum", 1);
+ // 淇敼浠诲姟鐘舵�佷负姝ｅ湪鎵ц鐘舵��
+ updateTaskState(taskId, TASK_STATE_R);
+ // 鏂规硶璋冪敤鏄惁鎴愬姛锛孲鎴愬姛锛堥粯璁わ級锛孍琛ㄧず澶辫触锛堝湪鏂规硶涓け璐ユ椂锛岄渶瑕佷慨鏀癸級
+ ftpItemConfigInfo.put("PRE_METHOD_FLAG", "S");
+ try {
+ // 1.0绌烘柟娉曪紝璁╁瓙绫诲幓瀹炵幇
+ prepare(ftpItemConfigInfo);
- // 2.0璋冪敤浜嬪墠杩囩▼
- if (ftpItemConfigInfo.containsKey("PREFLAG") && "0".equals(ftpItemConfigInfo.get("PREFLAG"))) {
- callPreFunction(ftpItemConfigInfo);
- }
+ // 2.0璋冪敤浜嬪墠杩囩▼
+ if (ftpItemConfigInfo.containsKey("PREFLAG") && "0".equals(ftpItemConfigInfo.get("PREFLAG"))) {
+ callPreFunction(ftpItemConfigInfo);
+ }
- if (ftpItemConfigInfo.containsKey("PRE_METHOD_FLAG") && "E".equals(ftpItemConfigInfo.get("PRE_METHOD_FLAG"))) {
- // 姝ゆ椂璋冪敤浜嬪墠杩囩▼澶辫触锛岀洿鎺ヨ繑鍥� 鏌ヨ鏍囪瘑涓篍锛屾洿鏂版棩蹇�
- udpateTaskLog(ftpItemConfigInfo);
- updateTaskState(taskId, TASK_STATE_E1);
- return;
- }
+ if (ftpItemConfigInfo.containsKey("PRE_METHOD_FLAG") && "E".equals(ftpItemConfigInfo.get("PRE_METHOD_FLAG"))) {
+ // 姝ゆ椂璋冪敤浜嬪墠杩囩▼澶辫触锛岀洿鎺ヨ繑鍥� 鏌ヨ鏍囪瘑涓篍锛屾洿鏂版棩蹇�
+ udpateTaskLog(ftpItemConfigInfo);
+ updateTaskState(taskId, TASK_STATE_E1);
+ return;
+ }
- // 3.0鏍稿績涓氬姟澶勭悊閫昏緫锛岄渶瑕佸瓙绫诲幓瀹炵幇
- process(ftpItemConfigInfo);
+ // 3.0鏍稿績涓氬姟澶勭悊閫昏緫锛岄渶瑕佸瓙绫诲幓瀹炵幇
+ process(ftpItemConfigInfo);
- if (ftpItemConfigInfo.containsKey("PRE_METHOD_FLAG") && "E".equals(ftpItemConfigInfo.get("PRE_METHOD_FLAG"))) {
- // 绋嬪簭澶勭悊澶辫触锛岀洿鎺ヨ繑鍥�
- ftpItemConfigInfo.put("threadrunstate", TASK_STATE_E2);
- updateTaskState(taskId, TASK_STATE_E2);
- udpateTaskLog(ftpItemConfigInfo);
- saveTaskLogDetail(ftpItemConfigInfo);// 淇濆瓨detail
- return;
- }
- // 璁板綍璇︾粏鏃ュ織
- ftpItemConfigInfo.put("threadrunstate", "T");
- saveTaskLogDetail(ftpItemConfigInfo);
+ if (ftpItemConfigInfo.containsKey("PRE_METHOD_FLAG") && "E".equals(ftpItemConfigInfo.get("PRE_METHOD_FLAG"))) {
+ // 绋嬪簭澶勭悊澶辫触锛岀洿鎺ヨ繑鍥�
+ ftpItemConfigInfo.put("threadrunstate", TASK_STATE_E2);
+ updateTaskState(taskId, TASK_STATE_E2);
+ udpateTaskLog(ftpItemConfigInfo);
+ saveTaskLogDetail(ftpItemConfigInfo);// 淇濆瓨detail
+ return;
+ }
+ // 璁板綍璇︾粏鏃ュ織
+ ftpItemConfigInfo.put("threadrunstate", "T");
+ saveTaskLogDetail(ftpItemConfigInfo);
- // 4.0璋冪敤浜嬪悗杩囩▼
- if (ftpItemConfigInfo.containsKey("AFTERFLAG") && "0".equals(ftpItemConfigInfo.get("AFTERFLAG"))) {
- callAfterFunction(ftpItemConfigInfo);
- }
- if (ftpItemConfigInfo.containsKey("PRE_METHOD_FLAG") && "E".equals(ftpItemConfigInfo.get("PRE_METHOD_FLAG"))) {
- // 姝ゆ椂璋冪敤浜嬪墠杩囩▼澶辫触锛岀洿鎺ヨ繑鍥� 鏌ヨ鏍囪瘑涓篍锛屾洿鏂版棩蹇�
- udpateTaskLog(ftpItemConfigInfo);
- updateTaskState(taskId, TASK_STATE_E3);
- return;
- }
- // 5.0绌烘柟娉曪紝璁╁瓙绫诲幓瀹炵幇
- post(ftpItemConfigInfo);
- } catch (Exception ex) {
- ftpItemConfigInfo.put("threadrunstate", TASK_STATE_E2);
- udpateTaskLog(ftpItemConfigInfo);
- ftpItemConfigInfo.put("threadrunstate", TASK_STATE_E2);
- ftpItemConfigInfo.put("remark", ex);
- saveTaskLogDetail(ftpItemConfigInfo);
- updateTaskState(taskId, TASK_STATE_E2);
- // 鎺ョ画鍚戝鎶涘嚭鍘�
- logger.error("澶勭悊鍑虹幇闂锛�", ex);
- return;
- }
+ // 4.0璋冪敤浜嬪悗杩囩▼
+ if (ftpItemConfigInfo.containsKey("AFTERFLAG") && "0".equals(ftpItemConfigInfo.get("AFTERFLAG"))) {
+ callAfterFunction(ftpItemConfigInfo);
+ }
+ if (ftpItemConfigInfo.containsKey("PRE_METHOD_FLAG") && "E".equals(ftpItemConfigInfo.get("PRE_METHOD_FLAG"))) {
+ // 姝ゆ椂璋冪敤浜嬪墠杩囩▼澶辫触锛岀洿鎺ヨ繑鍥� 鏌ヨ鏍囪瘑涓篍锛屾洿鏂版棩蹇�
+ udpateTaskLog(ftpItemConfigInfo);
+ updateTaskState(taskId, TASK_STATE_E3);
+ return;
+ }
+ // 5.0绌烘柟娉曪紝璁╁瓙绫诲幓瀹炵幇
+ post(ftpItemConfigInfo);
+ } catch (Exception ex) {
+ ftpItemConfigInfo.put("threadrunstate", TASK_STATE_E2);
+ udpateTaskLog(ftpItemConfigInfo);
+ ftpItemConfigInfo.put("threadrunstate", TASK_STATE_E2);
+ ftpItemConfigInfo.put("remark", ex);
+ saveTaskLogDetail(ftpItemConfigInfo);
+ updateTaskState(taskId, TASK_STATE_E2);
+ // 鎺ョ画鍚戝鎶涘嚭鍘�
+ logger.error("澶勭悊鍑虹幇闂锛�", ex);
+ return;
+ }
- // 淇敼浠诲姟鐘舵�佷负鎵ц瀹屾瘯鐘舵��
- updateTaskState(taskId, TASK_STATE_T);
- ftpItemConfigInfo.put("threadrunstate", TASK_STATE_T);
- udpateTaskLog(ftpItemConfigInfo);
+ // 淇敼浠诲姟鐘舵�佷负鎵ц瀹屾瘯鐘舵��
+ updateTaskState(taskId, TASK_STATE_T);
+ ftpItemConfigInfo.put("threadrunstate", TASK_STATE_T);
+ udpateTaskLog(ftpItemConfigInfo);
- // 鍙戦�佷换鍔¤繍琛岀粨鏋滈�氱煡鐭俊缁欑浉鍏充汉鍛� **鏆傛椂涓嶈皟鐢ㄧ煭淇�
- if (!TASK_STATE_T.equals(ftpItemConfigInfo.get("RUN_STATE").toString())) {
- /*sendErrLogPhoneMsg(ftpItemConfigInfo, taskLogID);*/
- }
+ // 鍙戦�佷换鍔¤繍琛岀粨鏋滈�氱煡鐭俊缁欑浉鍏充汉鍛� **鏆傛椂涓嶈皟鐢ㄧ煭淇�
+ if (!TASK_STATE_T.equals(ftpItemConfigInfo.get("RUN_STATE").toString())) {
+ /*sendErrLogPhoneMsg(ftpItemConfigInfo, taskLogID);*/
+ }
- }
+ }
- // 濡傛灉鏈変簨鍓嶅瓨杩囬渶瑕佽皟鐢紝鍒欏厛璋冪敤瀛樿繃
- public void callPreFunction(Map taskInfo) {
+ // 濡傛灉鏈変簨鍓嶅瓨杩囬渶瑕佽皟鐢紝鍒欏厛璋冪敤瀛樿繃
+ public void callPreFunction(Map taskInfo) {
- if (taskInfo.containsKey("PREFUNCTION") && taskInfo.get("PREFUNCTION") != null && !"".equals(taskInfo.get("PREFUNCTION"))) {
- try {
- iHcFtpFileSMO.saveDbFunction(taskInfo.get("PREFUNCTION").toString());
- taskInfo.put("threadrunstate", "T");
- taskInfo.put("remark", "璋冪敤浜嬪墠瀛樿繃缁撴潫");
- saveTaskLogDetail(taskInfo);
- } catch (Exception ex) {
- logger.error("璋冪敤浜嬪墠瀛樿繃澶辫触:", ex);
- taskInfo.put("threadrunstate", "E1");
- taskInfo.put("remark", "璋冪敤浜嬪墠瀛樿繃澶辫触" + ex);
- taskInfo.put("PRE_METHOD_FLAG", "E");
- saveTaskLogDetail(taskInfo);
- }
- }
- }
+ if (taskInfo.containsKey("PREFUNCTION") && taskInfo.get("PREFUNCTION") != null && !"".equals(taskInfo.get("PREFUNCTION"))) {
+ try {
+ iHcFtpFileSMO.saveDbFunction(taskInfo.get("PREFUNCTION").toString());
+ taskInfo.put("threadrunstate", "T");
+ taskInfo.put("remark", "璋冪敤浜嬪墠瀛樿繃缁撴潫");
+ saveTaskLogDetail(taskInfo);
+ } catch (Exception ex) {
+ logger.error("璋冪敤浜嬪墠瀛樿繃澶辫触:", ex);
+ taskInfo.put("threadrunstate", "E1");
+ taskInfo.put("remark", "璋冪敤浜嬪墠瀛樿繃澶辫触" + ex);
+ taskInfo.put("PRE_METHOD_FLAG", "E");
+ saveTaskLogDetail(taskInfo);
+ }
+ }
+ }
- /**
- * 涓昏涓氬姟澶勭悊锛堜笂浼犱笅杞斤級,璁╁瓙绫诲幓瀹炵幇
- *
- * @param ftpItemConfigInfo
- */
- protected abstract void process(Map ftpItemConfigInfo) throws Exception;
+ /**
+ * 涓昏涓氬姟澶勭悊锛堜笂浼犱笅杞斤級,璁╁瓙绫诲幓瀹炵幇
+ *
+ * @param ftpItemConfigInfo
+ */
+ protected abstract void process(Map ftpItemConfigInfo) throws Exception;
- // 濡傛灉鏈変簨鍚庡瓨杩囬渶瑕佽皟鐢紝鍒欒皟鐢ㄥ瓨杩�
- public void callAfterFunction(Map taskInfo) {
+ // 濡傛灉鏈変簨鍚庡瓨杩囬渶瑕佽皟鐢紝鍒欒皟鐢ㄥ瓨杩�
+ public void callAfterFunction(Map taskInfo) {
- if (taskInfo.containsKey("AFTERFUNCTION") && taskInfo.get("AFTERFUNCTION") != null && !"".equals(taskInfo.get("AFTERFUNCTION"))) {
- try {
- taskInfo.put("functionname", taskInfo.get("AFTERFUNCTION"));
- // taskInfo 鍙傛暟param闇�瑕佸湪process鏂规硶涓渶瑕佽嚜宸卞啓鍏�
- iHcFtpFileSMO.saveDbFunctionWithParam(taskInfo);
- taskInfo.put("threadrunstate", "T");
- taskInfo.put("remark", "璋冪敤浜嬪悗瀛樿繃缁撴潫");
- saveTaskLogDetail(taskInfo);
- } catch (Exception ex) {
- ex.printStackTrace();
- taskInfo.put("threadrunstate", "E3");
- taskInfo.put("remark", "璋冪敤浜嬪悗瀛樿繃澶辫触" + ex);
- taskInfo.put("PRE_METHOD_FLAG", "E");
- saveTaskLogDetail(taskInfo);
- }
- }
- }
+ if (taskInfo.containsKey("AFTERFUNCTION") && taskInfo.get("AFTERFUNCTION") != null && !"".equals(taskInfo.get("AFTERFUNCTION"))) {
+ try {
+ taskInfo.put("functionname", taskInfo.get("AFTERFUNCTION"));
+ // taskInfo 鍙傛暟param闇�瑕佸湪process鏂规硶涓渶瑕佽嚜宸卞啓鍏�
+ iHcFtpFileSMO.saveDbFunctionWithParam(taskInfo);
+ taskInfo.put("threadrunstate", "T");
+ taskInfo.put("remark", "璋冪敤浜嬪悗瀛樿繃缁撴潫");
+ saveTaskLogDetail(taskInfo);
+ } catch (Exception ex) {
+ ex.printStackTrace();
+ taskInfo.put("threadrunstate", "E3");
+ taskInfo.put("remark", "璋冪敤浜嬪悗瀛樿繃澶辫触" + ex);
+ taskInfo.put("PRE_METHOD_FLAG", "E");
+ saveTaskLogDetail(taskInfo);
+ }
+ }
+ }
- /**
- * 淇敼浠诲姟鐘舵��
- *
- * @return
- */
- private void updateTaskState(long taskId, String state) {
- Map info = new HashMap();
+ /**
+ * 淇敼浠诲姟鐘舵��
+ *
+ * @return
+ */
+ private void updateTaskState(long taskId, String state) {
+ Map info = new HashMap();
- info.put("taskId", taskId);
- info.put("runState", state);
- int updateFtpItemFlag = iHcFtpFileDAO.updateFtpItemByTaskId(info);
- // 杩欓噷鍙槸鍚庡彴鎻愮ず锛屼笉杩涜鏃ュ織淇濆瓨
- if (updateFtpItemFlag < 1) {
- logger.error("---銆怭rvncFtpToFileSystemQuartz.updateTaskState銆戜慨鏀逛换鍔°��" + taskId + "銆戠殑鐘舵�佸け璐�", info);
- }
- }
+ info.put("taskId", taskId);
+ info.put("runState", state);
+ int updateFtpItemFlag = iHcFtpFileDAO.updateFtpItemByTaskId(info);
+ // 杩欓噷鍙槸鍚庡彴鎻愮ず锛屼笉杩涜鏃ュ織淇濆瓨
+ if (updateFtpItemFlag < 1) {
+ logger.error("---銆怭rvncFtpToFileSystemQuartz.updateTaskState銆戜慨鏀逛换鍔°��" + taskId + "銆戠殑鐘舵�佸け璐�", info);
+ }
+ }
- /**
- * 淇敼浠诲姟鎵ц鏃ュ織鐨勭姸鎬�
- */
- private void udpateTaskLog(Map taskInfo) {
- FtpTaskLog loginfo = new FtpTaskLog();
- loginfo.setLogid(Long.valueOf(taskInfo.get("logid").toString()));
- loginfo.setState(taskInfo.get("threadrunstate").toString());
- iHcFtpFileSMO.updateTaskRunLog(loginfo);
- }
+ /**
+ * 淇敼浠诲姟鎵ц鏃ュ織鐨勭姸鎬�
+ */
+ private void udpateTaskLog(Map taskInfo) {
+ FtpTaskLog loginfo = new FtpTaskLog();
+ loginfo.setLogid(Long.valueOf(taskInfo.get("logid").toString()));
+ loginfo.setState(taskInfo.get("threadrunstate").toString());
+ iHcFtpFileSMO.updateTaskRunLog(loginfo);
+ }
- /**
- * 淇濆瓨浠诲姟鎵ц鐨勮缁嗘棩蹇�
- */
- protected void saveTaskLogDetail(Map taskInfo) {
- FtpTaskLogDetail logdetail = new FtpTaskLogDetail();
- logdetail.setId(Long.valueOf(taskInfo.get("logid").toString()+"66"));
- logdetail.setLogid(Long.valueOf(taskInfo.get("logid").toString()));
- logdetail.setTaskid(Long.valueOf(taskInfo.get("taskid").toString()));
- logdetail.setState((String) taskInfo.get("threadrunstate"));
- logdetail.setTnum(Integer.valueOf(taskInfo.get("tnum").toString()));
- if (taskInfo.get("begin") != null) {
- logdetail.setBegin(Long.valueOf(taskInfo.get("begin").toString()));
- }
- if (taskInfo.get("end") != null) {
- logdetail.setEnd(Long.valueOf(taskInfo.get("end").toString()));
- }
- if (taskInfo.get("havedown") != null) {
- logdetail.setHavedown(Long.valueOf(taskInfo.get("havedown").toString()));
- }
- logdetail.setRemark(taskInfo.get("remark") == null ? "" : (taskInfo.get("remark").toString().trim().length() > 2000 ? taskInfo.get("remark").toString().trim().substring(0,
- 1600) : taskInfo.get("remark").toString().trim()));
- logdetail.setData(taskInfo.get("data") == null ? "" : taskInfo.get("data").toString());
- logdetail.setServerfilename(taskInfo.get("serverfilename") == null ? "" : taskInfo.get("serverfilename").toString());
- logdetail.setLocalfilename(taskInfo.get("localfilename") == null ? "" : taskInfo.get("localfilename").toString());
- int logdetailid = iHcFtpFileSMO.saveTaskRunDetailLog(logdetail);
- taskInfo.put("logdetailid", logdetailid);
- }
+ /**
+ * 淇濆瓨浠诲姟鎵ц鐨勮缁嗘棩蹇�
+ */
+ protected void saveTaskLogDetail(Map taskInfo) {
+ FtpTaskLogDetail logdetail = new FtpTaskLogDetail();
+ logdetail.setId(Long.valueOf(taskInfo.get("logid").toString()+"66"));
+ logdetail.setLogid(Long.valueOf(taskInfo.get("logid").toString()));
+ logdetail.setTaskid(Long.valueOf(taskInfo.get("taskid").toString()));
+ logdetail.setState((String) taskInfo.get("threadrunstate"));
+ logdetail.setTnum(Integer.valueOf(taskInfo.get("tnum").toString()));
+ if (taskInfo.get("begin") != null) {
+ logdetail.setBegin(Long.valueOf(taskInfo.get("begin").toString()));
+ }
+ if (taskInfo.get("end") != null) {
+ logdetail.setEnd(Long.valueOf(taskInfo.get("end").toString()));
+ }
+ if (taskInfo.get("havedown") != null) {
+ logdetail.setHavedown(Long.valueOf(taskInfo.get("havedown").toString()));
+ }
+ logdetail.setRemark(taskInfo.get("remark") == null ? "" : (taskInfo.get("remark").toString().trim().length() > 2000 ? taskInfo.get("remark").toString().trim().substring(0,
+ 1600) : taskInfo.get("remark").toString().trim()));
+ logdetail.setData(taskInfo.get("data") == null ? "" : taskInfo.get("data").toString());
+ logdetail.setServerfilename(taskInfo.get("serverfilename") == null ? "" : taskInfo.get("serverfilename").toString());
+ logdetail.setLocalfilename(taskInfo.get("localfilename") == null ? "" : taskInfo.get("localfilename").toString());
+ int logdetailid = iHcFtpFileSMO.saveTaskRunDetailLog(logdetail);
+ taskInfo.put("logdetailid", logdetailid);
+ }
- // /**
- // * 淇敼浠诲姟鎵ц鐨勮缁嗘棩蹇楃殑鐘舵��
- // */
- // private void updateTaskLogDetail(Map taskInfo){
- // FtpTaskLogDetail logdetail=new FtpTaskLogDetail();//
- // logdetail.setId(Long.valueOf(taskInfo.get("logdetailid").toString()));
- // logdetail.setState(taskInfo.get("threadrunstate").toString());
- // logdetail.setRemark((String)taskInfo.get("remark"));
- // logdetail.setData((String)taskInfo.get("data"));
- // if(taskInfo.get("downedlength")!=null)
- // logdetail.setHavedown(Long.valueOf(taskInfo.get("downedlength").toString()));
- // prvncFtpFileSMO.updateTaskRunDetailLog(logdetail);
- // }
+ // /**
+ // * 淇敼浠诲姟鎵ц鐨勮缁嗘棩蹇楃殑鐘舵��
+ // */
+ // private void updateTaskLogDetail(Map taskInfo){
+ // FtpTaskLogDetail logdetail=new FtpTaskLogDetail();//
+ // logdetail.setId(Long.valueOf(taskInfo.get("logdetailid").toString()));
+ // logdetail.setState(taskInfo.get("threadrunstate").toString());
+ // logdetail.setRemark((String)taskInfo.get("remark"));
+ // logdetail.setData((String)taskInfo.get("data"));
+ // if(taskInfo.get("downedlength")!=null)
+ // logdetail.setHavedown(Long.valueOf(taskInfo.get("downedlength").toString()));
+ // prvncFtpFileSMO.updateTaskRunDetailLog(logdetail);
+ // }
- /**
- * 鐢熸垚浠诲姟鎵ц鏃ュ織
- */
- private long insertTaskInfo(Map taskInfo) {
- FtpTaskLog loginfo = new FtpTaskLog();
- loginfo.setTaskid(Long.valueOf(taskInfo.get("TASKID").toString()));
- loginfo.setState("R");
- loginfo.setServerfilename("");// taskInfo.get("serverfilename").toString()
- loginfo.setLocalfilename("");// taskInfo.get("localfilename").toString()
- loginfo.setUord(taskInfo.get("U_OR_D").toString());
- return iHcFtpFileSMO.saveTaskRunLog(loginfo);
- }
+ /**
+ * 鐢熸垚浠诲姟鎵ц鏃ュ織
+ */
+ private long insertTaskInfo(Map taskInfo) {
+ FtpTaskLog loginfo = new FtpTaskLog();
+ loginfo.setTaskid(Long.valueOf(taskInfo.get("TASKID").toString()));
+ loginfo.setState("R");
+ loginfo.setServerfilename("");// taskInfo.get("serverfilename").toString()
+ loginfo.setLocalfilename("");// taskInfo.get("localfilename").toString()
+ loginfo.setUord(taskInfo.get("U_OR_D").toString());
+ return iHcFtpFileSMO.saveTaskRunLog(loginfo);
+ }
- /**
- * 濡傛灉浠诲姟杩愯鏈夊紓甯革紝鍒欏彂閫佽鍛婄煭淇＄粰閰嶇疆鐨勬墜鏈哄彿鐮�
- */
- private void sendErrLogPhoneMsg(Map taskInfo, long taskLogID) {
- Map msginfo = new HashMap();
- String phone = (String) taskInfo.get("errphone");
- if (phone != null && !"".equals(phone)) {
- String[] phonelist = phone.split(",");
- for (int i = 0; i < phonelist.length; i++) {
- msginfo.put("taskid", taskInfo.get("taskid"));
- msginfo.put("phone", phonelist[i]);
- msginfo.put("msg", "閫氱敤FTP鏁版嵁鏂囦欢浼犳帴浠诲姟锛�" + (String) taskInfo.get("taskname") + "杩愯鎻愮ず");
+ /**
+ * 濡傛灉浠诲姟杩愯鏈夊紓甯革紝鍒欏彂閫佽鍛婄煭淇＄粰閰嶇疆鐨勬墜鏈哄彿鐮�
+ */
+ private void sendErrLogPhoneMsg(Map taskInfo, long taskLogID) {
+ Map msginfo = new HashMap();
+ String phone = (String) taskInfo.get("errphone");
+ if (phone != null && !"".equals(phone)) {
+ String[] phonelist = phone.split(",");
+ for (int i = 0; i < phonelist.length; i++) {
+ msginfo.put("taskid", taskInfo.get("taskid"));
+ msginfo.put("phone", phonelist[i]);
+ msginfo.put("msg", "閫氱敤FTP鏁版嵁鏂囦欢浼犳帴浠诲姟锛�" + (String) taskInfo.get("taskname") + "杩愯鎻愮ず");
- DateFormat df = new SimpleDateFormat("yyyy-mm-dd HH:mm:ss");
- String detail = "浠诲姟宸蹭簬" + df.format(new Date()) + "杩愯瀹屾瘯銆傝繍琛岃繃绋嬩腑鍑虹幇寮傚父锛岃鎯呰鐧诲綍绯荤粺鏌ョ湅锛�";
- msginfo.put("detail", detail);
- /*prvncDumpSMO.saveTaskErrInfoPhoneMsg(msginfo);*/
- }
- }
- }
+ DateFormat df = new SimpleDateFormat("yyyy-mm-dd HH:mm:ss");
+ String detail = "浠诲姟宸蹭簬" + df.format(new Date()) + "杩愯瀹屾瘯銆傝繍琛岃繃绋嬩腑鍑虹幇寮傚父锛岃鎯呰鐧诲綍绯荤粺鏌ョ湅锛�";
+ msginfo.put("detail", detail);
+ /*prvncDumpSMO.saveTaskErrInfoPhoneMsg(msginfo);*/
+ }
+ }
+ }
- /**
- * 澶勭悊鏂囦欢鍚嶏紝鏍￠獙鏂囦欢鍚嶆槸涓槸鍚﹀瓨鍦�****锛�4涓級锛岃〃绀洪�氶厤绗︼紝濡傛灉涓嶅瓨鍦ㄥ氨鏄‘瀹氬敮涓�鏂囦欢鍚�
- * 鏂囦欢鍚嶆敮鎸佹棩鏈熷瀷鐨勫CRM_########001.txt 绋嬪簭澶勭悊鍚庢槸 CRM_20170105001.txt 鏂囦欢鍚嶆敮鎸乻ql 璇彞鐢熸垚鐨�
- * 鏂囦欢鍚嶆敮鎸侀�氶厤绗︾殑濡�863_****.txt 绋嬪簭涓嬭浇鎵�鏈変互863_寮�澶寸殑鏂囦欢 863_****001.txt
- * 浠�863_寮�澶�,浠�001缁撳熬锛�****001.txt 浠�001缁撳熬鐨�
- *
- * @param fileName
- * @return
- */
- protected List<String> dealFileName(String fileName) {
- // TODO Auto-generated method stub
- List<String> results = new ArrayList<String>();
- String result = "";
- // 鏂囦欢涓娇鐢ㄧ殑鏃ユ湡
- if (StringUtils.contains(fileName, RuleDomain.REPLAY_TYPE_F)) {
- result = StringUtil.replace(fileName, RuleDomain.REPLAY_TYPE_F, DateUtil.getFormatTimeString(new Date(), "yyyyMMddHHmm"));
- } else if (StringUtils.contains(fileName, RuleDomain.REPLAY_TYPE_E)) {
- result = StringUtil.replace(fileName, RuleDomain.REPLAY_TYPE_E, DateUtil.getFormatTimeString(new Date(), "yyyyMMddHH"));
- } else if (StringUtils.contains(fileName, RuleDomain.REPLAY_TYPE_A)) {
- result = StringUtil.replace(fileName, RuleDomain.REPLAY_TYPE_A, DateUtil.getFormatTimeString(new Date(), "yyyyMMdd"));
- } else if (StringUtils.contains(fileName == null ? "" : fileName.toLowerCase(), RuleDomain.REPLAY_TYPE_SQL)) {
- // 鍚庢湡鏀归�狅紝鏂囦欢鍚嶅鏋滈厤缃殑鏄痵ql鐨勮瘽锛屼互sql鏌ヨ鏂囦欢鍚�
- List<String> fileNames = this.getPrvncFtpFileDAO().execConfigSql(fileName);
- // if (fileNames != null && fileNames.size() > 0) {
- // result = fileNames.get(0);
- // }
- return fileNames;
- } else {
- result = fileName;
- }
- results.add(result);
- return results;
- }
+ /**
+ * 澶勭悊鏂囦欢鍚嶏紝鏍￠獙鏂囦欢鍚嶆槸涓槸鍚﹀瓨鍦�****锛�4涓級锛岃〃绀洪�氶厤绗︼紝濡傛灉涓嶅瓨鍦ㄥ氨鏄‘瀹氬敮涓�鏂囦欢鍚�
+ * 鏂囦欢鍚嶆敮鎸佹棩鏈熷瀷鐨勫CRM_########001.txt 绋嬪簭澶勭悊鍚庢槸 CRM_20170105001.txt 鏂囦欢鍚嶆敮鎸乻ql 璇彞鐢熸垚鐨�
+ * 鏂囦欢鍚嶆敮鎸侀�氶厤绗︾殑濡�863_****.txt 绋嬪簭涓嬭浇鎵�鏈変互863_寮�澶寸殑鏂囦欢 863_****001.txt
+ * 浠�863_寮�澶�,浠�001缁撳熬锛�****001.txt 浠�001缁撳熬鐨�
+ *
+ * @param fileName
+ * @return
+ */
+ protected List<String> dealFileName(String fileName) {
+ // TODO Auto-generated method stub
+ List<String> results = new ArrayList<String>();
+ String result = "";
+ // 鏂囦欢涓娇鐢ㄧ殑鏃ユ湡
+ if (StringUtils.contains(fileName, RuleDomain.REPLAY_TYPE_F)) {
+ result = StringUtil.replace(fileName, RuleDomain.REPLAY_TYPE_F, DateUtil.getFormatTimeString(new Date(), "yyyyMMddHHmm"));
+ } else if (StringUtils.contains(fileName, RuleDomain.REPLAY_TYPE_E)) {
+ result = StringUtil.replace(fileName, RuleDomain.REPLAY_TYPE_E, DateUtil.getFormatTimeString(new Date(), "yyyyMMddHH"));
+ } else if (StringUtils.contains(fileName, RuleDomain.REPLAY_TYPE_A)) {
+ result = StringUtil.replace(fileName, RuleDomain.REPLAY_TYPE_A, DateUtil.getFormatTimeString(new Date(), "yyyyMMdd"));
+ } else if (StringUtils.contains(fileName == null ? "" : fileName.toLowerCase(), RuleDomain.REPLAY_TYPE_SQL)) {
+ // 鍚庢湡鏀归�狅紝鏂囦欢鍚嶅鏋滈厤缃殑鏄痵ql鐨勮瘽锛屼互sql鏌ヨ鏂囦欢鍚�
+ List<String> fileNames = this.getPrvncFtpFileDAO().execConfigSql(fileName);
+ // if (fileNames != null && fileNames.size() > 0) {
+ // result = fileNames.get(0);
+ // }
+ return fileNames;
+ } else {
+ result = fileName;
+ }
+ results.add(result);
+ return results;
+ }
- /**
- * 绌烘柟娉曪紝濡傛灉鍦ㄤ簨鍓嶈繃绋嬪鐞嗗墠锛岃繕闇�瑕佸仛涓�瀹氱殑澶勭悊锛岄渶瑕佸瓙绫婚噸鍐欒繖涓柟娉曪紝瀹炵幇涓氬姟閫昏緫
- *
- * @param ftpItemConfigInfo
- */
- protected void prepare(Map ftpItemConfigInfo) {
+ /**
+ * 绌烘柟娉曪紝濡傛灉鍦ㄤ簨鍓嶈繃绋嬪鐞嗗墠锛岃繕闇�瑕佸仛涓�瀹氱殑澶勭悊锛岄渶瑕佸瓙绫婚噸鍐欒繖涓柟娉曪紝瀹炵幇涓氬姟閫昏緫
+ *
+ * @param ftpItemConfigInfo
+ */
+ protected void prepare(Map ftpItemConfigInfo) {
- }
+ }
- /**
- * 绌烘柟娉曪紝濡傛灉鍦ㄤ簨鍚庤繃绋嬪鐞嗗畬鍚庯紝杩橀渶瑕佸仛涓�瀹氱殑澶勭悊锛岄渶瑕佸瓙绫婚噸鍐欒繖涓柟娉曪紝瀹炵幇涓氬姟閫昏緫
- *
- * @param ftpItemConfigInfo
- */
- protected void post(Map ftpItemConfigInfo) {
+ /**
+ * 绌烘柟娉曪紝濡傛灉鍦ㄤ簨鍚庤繃绋嬪鐞嗗畬鍚庯紝杩橀渶瑕佸仛涓�瀹氱殑澶勭悊锛岄渶瑕佸瓙绫婚噸鍐欒繖涓柟娉曪紝瀹炵幇涓氬姟閫昏緫
+ *
+ * @param ftpItemConfigInfo
+ */
+ protected void post(Map ftpItemConfigInfo) {
- }
+ }
- public IHcFtpFileDAO getPrvncFtpFileDAO() {
- return iHcFtpFileDAO;
- }
+ public IHcFtpFileDAO getPrvncFtpFileDAO() {
+ return iHcFtpFileDAO;
+ }
- public void setPrvncFtpFileDAO(IHcFtpFileDAO prvncFtpFileDAO) {
- this.iHcFtpFileDAO = prvncFtpFileDAO;
- }
+ public void setPrvncFtpFileDAO(IHcFtpFileDAO prvncFtpFileDAO) {
+ this.iHcFtpFileDAO = prvncFtpFileDAO;
+ }
- public IHcFtpFileSMO getPrvncFtpFileSMO() {
- return iHcFtpFileSMO;
- }
+ public IHcFtpFileSMO getPrvncFtpFileSMO() {
+ return iHcFtpFileSMO;
+ }
- public void setPrvncFtpFileSMO(IHcFtpFileSMO prvncFtpFileSMO) {
- this.iHcFtpFileSMO = prvncFtpFileSMO;
- }
+ public void setPrvncFtpFileSMO(IHcFtpFileSMO prvncFtpFileSMO) {
+ this.iHcFtpFileSMO = prvncFtpFileSMO;
+ }
/*public IPrvncDumpSMO getPrvncDumpSMO() {
return prvncDumpSMO;
@@ -375,4 +375,4 @@
this.prvncDumpSMO = prvncDumpSMO;
}
*/
-}
+}
\ No newline at end of file
--
Gitblit v1.8.0