diff --git a/.idea/workspace.xml b/.idea/workspace.xml new file mode 100644 index 0000000..e15ca50 --- /dev/null +++ b/.idea/workspace.xml @@ -0,0 +1,849 @@ + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + 未能连接到 + yy-mm-d + + + + + + + + + + + true + DEFINITION_ORDER + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + 1567762862031 + + + 1568000184886 + + + 1568100549456 + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + pgdsc + + + + + + + + Web (pgdsc)|Web + + + + + + + + + + + + + + + 1.8 + + + + + + + + pgdsc + + + + + + + + json + + + + + + + + \ No newline at end of file diff --git a/src/com/szpg/db/dao/PgConRemoveDao.java b/src/com/szpg/db/dao/PgConRemoveDao.java new file mode 100644 index 0000000..49903fc --- /dev/null +++ b/src/com/szpg/db/dao/PgConRemoveDao.java @@ -0,0 +1,14 @@ +package com.szpg.db.dao; + +import com.szpg.db.data.PgConRemoveMsg; +import com.szpg.db.data.PgConWorkOrder; + +import java.util.List; + +public interface PgConRemoveDao { + + public void addConRemove(List pgConRemoveMsgList); + + public String findLastRecordTime(); + +} diff --git a/.idea/workspace.xml b/.idea/workspace.xml new file mode 100644 index 0000000..e15ca50 --- /dev/null +++ b/.idea/workspace.xml @@ -0,0 +1,849 @@ + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + 未能连接到 + yy-mm-d + + + + + + + + + + + true + DEFINITION_ORDER + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + 1567762862031 + + + 1568000184886 + + + 1568100549456 + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + pgdsc + + + + + + + + Web (pgdsc)|Web + + + + + + + + + + + + + + + 1.8 + + + + + + + + pgdsc + + + + + + + + json + + + + + + + + \ No newline at end of file diff --git a/src/com/szpg/db/dao/PgConRemoveDao.java b/src/com/szpg/db/dao/PgConRemoveDao.java new file mode 100644 index 0000000..49903fc --- /dev/null +++ b/src/com/szpg/db/dao/PgConRemoveDao.java @@ -0,0 +1,14 @@ +package com.szpg.db.dao; + +import com.szpg.db.data.PgConRemoveMsg; +import com.szpg.db.data.PgConWorkOrder; + +import java.util.List; + +public interface PgConRemoveDao { + + public void addConRemove(List pgConRemoveMsgList); + + public String findLastRecordTime(); + +} diff --git a/src/com/szpg/db/dao/PgConRequestMsgDao.java b/src/com/szpg/db/dao/PgConRequestMsgDao.java new file mode 100644 index 0000000..274f5a6 --- /dev/null +++ b/src/com/szpg/db/dao/PgConRequestMsgDao.java @@ -0,0 +1,13 @@ +package com.szpg.db.dao; + +import com.szpg.db.data.PgConRequestMsg; +import com.szpg.db.data.PgConWorkOrder; + +import java.util.List; + +public interface PgConRequestMsgDao { + + public void addConRequestMsg(List pgConRequestMsgList); + + public String findLastRecordTime(); +} diff --git a/src/com/szpg/db/dao/PgConWorkOrderDao.java b/src/com/szpg/db/dao/PgConWorkOrderDao.java new file mode 100644 index 0000000..ad2c4ae --- /dev/null +++ b/src/com/szpg/db/dao/PgConWorkOrderDao.java @@ -0,0 +1,12 @@ +package com.szpg.db.dao; + + import com.szpg.db.data.PgConWorkOrder; + + import java.util.List; + +public interface PgConWorkOrderDao { + + public void addConWorkerOrder(List pgConWorkOrderList); + + public String findLastRecordTime(); +} diff --git a/.idea/workspace.xml b/.idea/workspace.xml new file mode 100644 index 0000000..e15ca50 --- /dev/null +++ b/.idea/workspace.xml @@ -0,0 +1,849 @@ + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + 未能连接到 + yy-mm-d + + + + + + + + + + + true + DEFINITION_ORDER + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + 1567762862031 + + + 1568000184886 + + + 1568100549456 + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + pgdsc + + + + + + + + Web (pgdsc)|Web + + + + + + + + + + + + + + + 1.8 + + + + + + + + pgdsc + + + + + + + + json + + + + + + + + \ No newline at end of file diff --git a/src/com/szpg/db/dao/PgConRemoveDao.java b/src/com/szpg/db/dao/PgConRemoveDao.java new file mode 100644 index 0000000..49903fc --- /dev/null +++ b/src/com/szpg/db/dao/PgConRemoveDao.java @@ -0,0 +1,14 @@ +package com.szpg.db.dao; + +import com.szpg.db.data.PgConRemoveMsg; +import com.szpg.db.data.PgConWorkOrder; + +import java.util.List; + +public interface PgConRemoveDao { + + public void addConRemove(List pgConRemoveMsgList); + + public String findLastRecordTime(); + +} diff --git a/src/com/szpg/db/dao/PgConRequestMsgDao.java b/src/com/szpg/db/dao/PgConRequestMsgDao.java new file mode 100644 index 0000000..274f5a6 --- /dev/null +++ b/src/com/szpg/db/dao/PgConRequestMsgDao.java @@ -0,0 +1,13 @@ +package com.szpg.db.dao; + +import com.szpg.db.data.PgConRequestMsg; +import com.szpg.db.data.PgConWorkOrder; + +import java.util.List; + +public interface PgConRequestMsgDao { + + public void addConRequestMsg(List pgConRequestMsgList); + + public String findLastRecordTime(); +} diff --git a/src/com/szpg/db/dao/PgConWorkOrderDao.java b/src/com/szpg/db/dao/PgConWorkOrderDao.java new file mode 100644 index 0000000..ad2c4ae --- /dev/null +++ b/src/com/szpg/db/dao/PgConWorkOrderDao.java @@ -0,0 +1,12 @@ +package com.szpg.db.dao; + + import com.szpg.db.data.PgConWorkOrder; + + import java.util.List; + +public interface PgConWorkOrderDao { + + public void addConWorkerOrder(List pgConWorkOrderList); + + public String findLastRecordTime(); +} diff --git a/src/com/szpg/db/dao/impl/PgAssetInSpectionImpl.java b/src/com/szpg/db/dao/impl/PgAssetInSpectionImpl.java index 2383707..de88d3b 100644 --- a/src/com/szpg/db/dao/impl/PgAssetInSpectionImpl.java +++ b/src/com/szpg/db/dao/impl/PgAssetInSpectionImpl.java @@ -28,47 +28,48 @@ "END_TIME,START_PILE_NO,END_PILE_NO,BUILD_CABIN,MILEAGE,FREQUENCY_TIME,FREQUENCYTIME_END,KETTLE_TS,UPDATEDATE) " + "VALUES (?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?)"; - List paramObjectList=new ArrayList(); + List paramObjectList=new ArrayList<>(); for(PgAssetInSpectionPlan pgAssetInSpectionPlan:pgAssetInSpectionPlanList){ + + if(!pgAssetInSpectionPlan.getPLAN_NAME().contains("吴中太湖新城")) continue; Object[] params = new Object[34]; params[0] = pgAssetInSpectionPlan.getKEY_ID(); params[1] = pgAssetInSpectionPlan.getPLAN_NAME(); params[2] = pgAssetInSpectionPlan.getINSPECTION_PERSON(); params[3] = pgAssetInSpectionPlan.getSTART_DATE(); - params[4]=pgAssetInSpectionPlan.getEND_DATE(); - params[5]=pgAssetInSpectionPlan.getFREQUENCY(); - params[6]=pgAssetInSpectionPlan.getSTATE(); - params[7]=pgAssetInSpectionPlan.getRESPONSIBLE_DEPT(); - params[8]=pgAssetInSpectionPlan.getPLAN_NO(); - params[9]=pgAssetInSpectionPlan.getINSPECTION_TYPE(); - params[10]=pgAssetInSpectionPlan.getINSPECTION_MODE(); - params[11]=pgAssetInSpectionPlan.getINSPECTION_ROUTE(); - params[12]=pgAssetInSpectionPlan.getINSPECTION_START_TIME(); - params[13]=pgAssetInSpectionPlan.getINSPECTION_END_TIME(); - params[14]=pgAssetInSpectionPlan.getINSPECTION_PRACE(); - params[15]=pgAssetInSpectionPlan.getINSPECTION_GROUP(); - params[16]=pgAssetInSpectionPlan.getINSERT_TIME(); - params[17]=pgAssetInSpectionPlan.getFREQUENCYDATE(); - params[18]=pgAssetInSpectionPlan.getFREQUENCYTIME(); - params[19]=pgAssetInSpectionPlan.getCREATEDATE(); - params[20]=pgAssetInSpectionPlan.getCREATOR(); - params[21]=pgAssetInSpectionPlan.getPROJECT(); - params[22]=pgAssetInSpectionPlan.getCOMLILE(); - params[23]=pgAssetInSpectionPlan.getSTART_TIME(); - params[24]=pgAssetInSpectionPlan.getDEVELOP_DEPT(); - params[25]=pgAssetInSpectionPlan.getEND_TIME(); - params[26]=pgAssetInSpectionPlan.getSTART_PILE_NO(); - params[27]=pgAssetInSpectionPlan.getEND_PILE_NO(); - params[28]=pgAssetInSpectionPlan.getBUILD_CABIN(); - params[29]=pgAssetInSpectionPlan.getMILEAGE(); - params[30]=pgAssetInSpectionPlan.getFREQUENCY_TIME(); - params[31]=pgAssetInSpectionPlan.getFREQUENCYTIME_END(); - params[32]=pgAssetInSpectionPlan.getKETTLE_TS(); - params[33]=pgAssetInSpectionPlan.getUPDATEDATE(); + params[4] = pgAssetInSpectionPlan.getEND_DATE(); + params[5] = pgAssetInSpectionPlan.getFREQUENCY(); + params[6] = pgAssetInSpectionPlan.getSTATE(); + params[7] = pgAssetInSpectionPlan.getRESPONSIBLE_DEPT(); + params[8] = pgAssetInSpectionPlan.getPLAN_NO(); + params[9] = pgAssetInSpectionPlan.getINSPECTION_TYPE(); + params[10] = pgAssetInSpectionPlan.getINSPECTION_MODE(); + params[11] = pgAssetInSpectionPlan.getINSPECTION_ROUTE(); + params[12] = pgAssetInSpectionPlan.getINSPECTION_START_TIME(); + params[13] = pgAssetInSpectionPlan.getINSPECTION_END_TIME(); + params[14] = pgAssetInSpectionPlan.getINSPECTION_PRACE(); + params[15] = pgAssetInSpectionPlan.getINSPECTION_GROUP(); + params[16] = pgAssetInSpectionPlan.getINSERT_TIME(); + params[17] = pgAssetInSpectionPlan.getFREQUENCYDATE(); + params[18] = pgAssetInSpectionPlan.getFREQUENCYTIME(); + params[19] = pgAssetInSpectionPlan.getCREATEDATE(); + params[20] = pgAssetInSpectionPlan.getCREATOR(); + params[21] = pgAssetInSpectionPlan.getPROJECT(); + params[22] = pgAssetInSpectionPlan.getCOMLILE(); + params[23] = pgAssetInSpectionPlan.getSTART_TIME(); + params[24] = pgAssetInSpectionPlan.getDEVELOP_DEPT(); + params[25] = pgAssetInSpectionPlan.getEND_TIME(); + params[26] = pgAssetInSpectionPlan.getSTART_PILE_NO(); + params[27] = pgAssetInSpectionPlan.getEND_PILE_NO(); + params[28] = pgAssetInSpectionPlan.getBUILD_CABIN(); + params[29] = pgAssetInSpectionPlan.getMILEAGE(); + params[30] = pgAssetInSpectionPlan.getFREQUENCY_TIME(); + params[31] = pgAssetInSpectionPlan.getFREQUENCYTIME_END(); + params[32] = pgAssetInSpectionPlan.getKETTLE_TS(); + params[33] = pgAssetInSpectionPlan.getUPDATEDATE(); paramObjectList.add(params); } - try { conn = ConnectionManager.getConnectionFromC3P0(); conn.setAutoCommit(false); diff --git a/src/com/szpg/db/dao/impl/PgConRemoveDaoImp.java b/src/com/szpg/db/dao/impl/PgConRemoveDaoImp.java new file mode 100644 index 0000000..510020e --- /dev/null +++ b/src/com/szpg/db/dao/impl/PgConRemoveDaoImp.java @@ -0,0 +1,98 @@ +package com.szpg.db.dao.impl; + +import com.szpg.db.dao.PgConRemoveDao; +import com.szpg.db.data.PgConRemoveMsg; +import com.szpg.db.util.ConnectionManager; +import org.apache.commons.dbutils.DbUtils; +import org.apache.commons.dbutils.QueryRunner; +import org.apache.commons.dbutils.handlers.BeanListHandler; +import org.apache.log4j.Logger; + +import java.sql.Connection; +import java.sql.SQLException; +import java.util.ArrayList; +import java.util.List; + +public class PgConRemoveDaoImp implements PgConRemoveDao { + + private org.apache.log4j.Logger logger = Logger.getLogger(this.getClass().getName()); + + @Override + public void addConRemove(List pgConRemoveMsgList){ + Connection conn = null; + + String insertStr = "INSERT INTO PG_CON_REMOVE_MSG " + + "(XD_DATE, XD_END_TIME, XD_SUPERVISOR,XD_FIELD_SITUATION,XD_REMARKS,XD_APPROVER,XD_APPROVER_TIME,LOG_DATE)" + + "VALUES (?,?,?,?,?,?,?,?)"; + + List paramObjectList=new ArrayList<>(); + for(PgConRemoveMsg pgConRemoveMsg:pgConRemoveMsgList){ + + Object[] params = new Object[34]; + params[0] = pgConRemoveMsg.getXD_DATE(); + params[1] = pgConRemoveMsg.getXD_END_TIME(); + params[2] = pgConRemoveMsg.getXD_SUPERVISOR(); + params[3] = pgConRemoveMsg.getXD_FIELD_SITUATION(); + params[4] = pgConRemoveMsg.getXD_REMARKS(); + params[5] = pgConRemoveMsg.getXD_APPROVER(); + params[6] = pgConRemoveMsg.getXD_APPROVER_TIME(); + params[7] = pgConRemoveMsg.getLOG_DATE(); + + paramObjectList.add(params); + } + try { + conn = ConnectionManager.getConnectionFromC3P0(); + conn.setAutoCommit(false); + + QueryRunner runner = new QueryRunner(); + for (Object[] params:paramObjectList) { + int count = runner.update(conn, insertStr, params); + if (count > 0) + logger.info("施工消点数据同步成功" + pgConRemoveMsgList.toString()); + else + logger.info("施工消点数据同步失败！"); + } + + } catch (Exception ex) { + logger.info("施工作业数据同步异常", ex); + } finally { + try { + DbUtils.commitAndClose(conn); + } catch (SQLException e) { + e.printStackTrace(); + } + } + } + + @Override + public String findLastRecordTime(){ + Connection conn = null; + + String queryStr = "SELECT * FROM PG_CON_REMOVE_MSG ORDER BY LOG_DATE DESC"; + try { + conn = ConnectionManager.getConnectionFromC3P0(); + conn.setAutoCommit(false); + + QueryRunner runner = new QueryRunner(); + List pgConRemoveMsgList = (List) runner.query(conn, + queryStr, new BeanListHandler(PgConRemoveMsg.class)); + + if (null != pgConRemoveMsgList && pgConRemoveMsgList.isEmpty() == false) { + logger.debug("获取最新施工消点记录成功[" + pgConRemoveMsgList + "]"); + return pgConRemoveMsgList.get(0).getLOG_DATE(); + } + else + return null; + } catch (Exception ex) { + logger.error("获取最新施工消点记录异常", ex); + } finally { + try { + DbUtils.commitAndClose(conn); + } catch (SQLException e) { + e.printStackTrace(); + } + } + return null; + } + +} diff --git a/.idea/workspace.xml b/.idea/workspace.xml new file mode 100644 index 0000000..e15ca50 --- /dev/null +++ b/.idea/workspace.xml @@ -0,0 +1,849 @@ + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + 未能连接到 + yy-mm-d + + + + + + + + + + + true + DEFINITION_ORDER + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + 1567762862031 + + + 1568000184886 + + + 1568100549456 + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + pgdsc + + + + + + + + Web (pgdsc)|Web + + + + + + + + + + + + + + + 1.8 + + + + + + + + pgdsc + + + + + + + + json + + + + + + + + \ No newline at end of file diff --git a/src/com/szpg/db/dao/PgConRemoveDao.java b/src/com/szpg/db/dao/PgConRemoveDao.java new file mode 100644 index 0000000..49903fc --- /dev/null +++ b/src/com/szpg/db/dao/PgConRemoveDao.java @@ -0,0 +1,14 @@ +package com.szpg.db.dao; + +import com.szpg.db.data.PgConRemoveMsg; +import com.szpg.db.data.PgConWorkOrder; + +import java.util.List; + +public interface PgConRemoveDao { + + public void addConRemove(List pgConRemoveMsgList); + + public String findLastRecordTime(); + +} diff --git a/src/com/szpg/db/dao/PgConRequestMsgDao.java b/src/com/szpg/db/dao/PgConRequestMsgDao.java new file mode 100644 index 0000000..274f5a6 --- /dev/null +++ b/src/com/szpg/db/dao/PgConRequestMsgDao.java @@ -0,0 +1,13 @@ +package com.szpg.db.dao; + +import com.szpg.db.data.PgConRequestMsg; +import com.szpg.db.data.PgConWorkOrder; + +import java.util.List; + +public interface PgConRequestMsgDao { + + public void addConRequestMsg(List pgConRequestMsgList); + + public String findLastRecordTime(); +} diff --git a/src/com/szpg/db/dao/PgConWorkOrderDao.java b/src/com/szpg/db/dao/PgConWorkOrderDao.java new file mode 100644 index 0000000..ad2c4ae --- /dev/null +++ b/src/com/szpg/db/dao/PgConWorkOrderDao.java @@ -0,0 +1,12 @@ +package com.szpg.db.dao; + + import com.szpg.db.data.PgConWorkOrder; + + import java.util.List; + +public interface PgConWorkOrderDao { + + public void addConWorkerOrder(List pgConWorkOrderList); + + public String findLastRecordTime(); +} diff --git a/src/com/szpg/db/dao/impl/PgAssetInSpectionImpl.java b/src/com/szpg/db/dao/impl/PgAssetInSpectionImpl.java index 2383707..de88d3b 100644 --- a/src/com/szpg/db/dao/impl/PgAssetInSpectionImpl.java +++ b/src/com/szpg/db/dao/impl/PgAssetInSpectionImpl.java @@ -28,47 +28,48 @@ "END_TIME,START_PILE_NO,END_PILE_NO,BUILD_CABIN,MILEAGE,FREQUENCY_TIME,FREQUENCYTIME_END,KETTLE_TS,UPDATEDATE) " + "VALUES (?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?)"; - List paramObjectList=new ArrayList(); + List paramObjectList=new ArrayList<>(); for(PgAssetInSpectionPlan pgAssetInSpectionPlan:pgAssetInSpectionPlanList){ + + if(!pgAssetInSpectionPlan.getPLAN_NAME().contains("吴中太湖新城")) continue; Object[] params = new Object[34]; params[0] = pgAssetInSpectionPlan.getKEY_ID(); params[1] = pgAssetInSpectionPlan.getPLAN_NAME(); params[2] = pgAssetInSpectionPlan.getINSPECTION_PERSON(); params[3] = pgAssetInSpectionPlan.getSTART_DATE(); - params[4]=pgAssetInSpectionPlan.getEND_DATE(); - params[5]=pgAssetInSpectionPlan.getFREQUENCY(); - params[6]=pgAssetInSpectionPlan.getSTATE(); - params[7]=pgAssetInSpectionPlan.getRESPONSIBLE_DEPT(); - params[8]=pgAssetInSpectionPlan.getPLAN_NO(); - params[9]=pgAssetInSpectionPlan.getINSPECTION_TYPE(); - params[10]=pgAssetInSpectionPlan.getINSPECTION_MODE(); - params[11]=pgAssetInSpectionPlan.getINSPECTION_ROUTE(); - params[12]=pgAssetInSpectionPlan.getINSPECTION_START_TIME(); - params[13]=pgAssetInSpectionPlan.getINSPECTION_END_TIME(); - params[14]=pgAssetInSpectionPlan.getINSPECTION_PRACE(); - params[15]=pgAssetInSpectionPlan.getINSPECTION_GROUP(); - params[16]=pgAssetInSpectionPlan.getINSERT_TIME(); - params[17]=pgAssetInSpectionPlan.getFREQUENCYDATE(); - params[18]=pgAssetInSpectionPlan.getFREQUENCYTIME(); - params[19]=pgAssetInSpectionPlan.getCREATEDATE(); - params[20]=pgAssetInSpectionPlan.getCREATOR(); - params[21]=pgAssetInSpectionPlan.getPROJECT(); - params[22]=pgAssetInSpectionPlan.getCOMLILE(); - params[23]=pgAssetInSpectionPlan.getSTART_TIME(); - params[24]=pgAssetInSpectionPlan.getDEVELOP_DEPT(); - params[25]=pgAssetInSpectionPlan.getEND_TIME(); - params[26]=pgAssetInSpectionPlan.getSTART_PILE_NO(); - params[27]=pgAssetInSpectionPlan.getEND_PILE_NO(); - params[28]=pgAssetInSpectionPlan.getBUILD_CABIN(); - params[29]=pgAssetInSpectionPlan.getMILEAGE(); - params[30]=pgAssetInSpectionPlan.getFREQUENCY_TIME(); - params[31]=pgAssetInSpectionPlan.getFREQUENCYTIME_END(); - params[32]=pgAssetInSpectionPlan.getKETTLE_TS(); - params[33]=pgAssetInSpectionPlan.getUPDATEDATE(); + params[4] = pgAssetInSpectionPlan.getEND_DATE(); + params[5] = pgAssetInSpectionPlan.getFREQUENCY(); + params[6] = pgAssetInSpectionPlan.getSTATE(); + params[7] = pgAssetInSpectionPlan.getRESPONSIBLE_DEPT(); + params[8] = pgAssetInSpectionPlan.getPLAN_NO(); + params[9] = pgAssetInSpectionPlan.getINSPECTION_TYPE(); + params[10] = pgAssetInSpectionPlan.getINSPECTION_MODE(); + params[11] = pgAssetInSpectionPlan.getINSPECTION_ROUTE(); + params[12] = pgAssetInSpectionPlan.getINSPECTION_START_TIME(); + params[13] = pgAssetInSpectionPlan.getINSPECTION_END_TIME(); + params[14] = pgAssetInSpectionPlan.getINSPECTION_PRACE(); + params[15] = pgAssetInSpectionPlan.getINSPECTION_GROUP(); + params[16] = pgAssetInSpectionPlan.getINSERT_TIME(); + params[17] = pgAssetInSpectionPlan.getFREQUENCYDATE(); + params[18] = pgAssetInSpectionPlan.getFREQUENCYTIME(); + params[19] = pgAssetInSpectionPlan.getCREATEDATE(); + params[20] = pgAssetInSpectionPlan.getCREATOR(); + params[21] = pgAssetInSpectionPlan.getPROJECT(); + params[22] = pgAssetInSpectionPlan.getCOMLILE(); + params[23] = pgAssetInSpectionPlan.getSTART_TIME(); + params[24] = pgAssetInSpectionPlan.getDEVELOP_DEPT(); + params[25] = pgAssetInSpectionPlan.getEND_TIME(); + params[26] = pgAssetInSpectionPlan.getSTART_PILE_NO(); + params[27] = pgAssetInSpectionPlan.getEND_PILE_NO(); + params[28] = pgAssetInSpectionPlan.getBUILD_CABIN(); + params[29] = pgAssetInSpectionPlan.getMILEAGE(); + params[30] = pgAssetInSpectionPlan.getFREQUENCY_TIME(); + params[31] = pgAssetInSpectionPlan.getFREQUENCYTIME_END(); + params[32] = pgAssetInSpectionPlan.getKETTLE_TS(); + params[33] = pgAssetInSpectionPlan.getUPDATEDATE(); paramObjectList.add(params); } - try { conn = ConnectionManager.getConnectionFromC3P0(); conn.setAutoCommit(false); diff --git a/src/com/szpg/db/dao/impl/PgConRemoveDaoImp.java b/src/com/szpg/db/dao/impl/PgConRemoveDaoImp.java new file mode 100644 index 0000000..510020e --- /dev/null +++ b/src/com/szpg/db/dao/impl/PgConRemoveDaoImp.java @@ -0,0 +1,98 @@ +package com.szpg.db.dao.impl; + +import com.szpg.db.dao.PgConRemoveDao; +import com.szpg.db.data.PgConRemoveMsg; +import com.szpg.db.util.ConnectionManager; +import org.apache.commons.dbutils.DbUtils; +import org.apache.commons.dbutils.QueryRunner; +import org.apache.commons.dbutils.handlers.BeanListHandler; +import org.apache.log4j.Logger; + +import java.sql.Connection; +import java.sql.SQLException; +import java.util.ArrayList; +import java.util.List; + +public class PgConRemoveDaoImp implements PgConRemoveDao { + + private org.apache.log4j.Logger logger = Logger.getLogger(this.getClass().getName()); + + @Override + public void addConRemove(List pgConRemoveMsgList){ + Connection conn = null; + + String insertStr = "INSERT INTO PG_CON_REMOVE_MSG " + + "(XD_DATE, XD_END_TIME, XD_SUPERVISOR,XD_FIELD_SITUATION,XD_REMARKS,XD_APPROVER,XD_APPROVER_TIME,LOG_DATE)" + + "VALUES (?,?,?,?,?,?,?,?)"; + + List paramObjectList=new ArrayList<>(); + for(PgConRemoveMsg pgConRemoveMsg:pgConRemoveMsgList){ + + Object[] params = new Object[34]; + params[0] = pgConRemoveMsg.getXD_DATE(); + params[1] = pgConRemoveMsg.getXD_END_TIME(); + params[2] = pgConRemoveMsg.getXD_SUPERVISOR(); + params[3] = pgConRemoveMsg.getXD_FIELD_SITUATION(); + params[4] = pgConRemoveMsg.getXD_REMARKS(); + params[5] = pgConRemoveMsg.getXD_APPROVER(); + params[6] = pgConRemoveMsg.getXD_APPROVER_TIME(); + params[7] = pgConRemoveMsg.getLOG_DATE(); + + paramObjectList.add(params); + } + try { + conn = ConnectionManager.getConnectionFromC3P0(); + conn.setAutoCommit(false); + + QueryRunner runner = new QueryRunner(); + for (Object[] params:paramObjectList) { + int count = runner.update(conn, insertStr, params); + if (count > 0) + logger.info("施工消点数据同步成功" + pgConRemoveMsgList.toString()); + else + logger.info("施工消点数据同步失败！"); + } + + } catch (Exception ex) { + logger.info("施工作业数据同步异常", ex); + } finally { + try { + DbUtils.commitAndClose(conn); + } catch (SQLException e) { + e.printStackTrace(); + } + } + } + + @Override + public String findLastRecordTime(){ + Connection conn = null; + + String queryStr = "SELECT * FROM PG_CON_REMOVE_MSG ORDER BY LOG_DATE DESC"; + try { + conn = ConnectionManager.getConnectionFromC3P0(); + conn.setAutoCommit(false); + + QueryRunner runner = new QueryRunner(); + List pgConRemoveMsgList = (List) runner.query(conn, + queryStr, new BeanListHandler(PgConRemoveMsg.class)); + + if (null != pgConRemoveMsgList && pgConRemoveMsgList.isEmpty() == false) { + logger.debug("获取最新施工消点记录成功[" + pgConRemoveMsgList + "]"); + return pgConRemoveMsgList.get(0).getLOG_DATE(); + } + else + return null; + } catch (Exception ex) { + logger.error("获取最新施工消点记录异常", ex); + } finally { + try { + DbUtils.commitAndClose(conn); + } catch (SQLException e) { + e.printStackTrace(); + } + } + return null; + } + +} diff --git a/src/com/szpg/db/dao/impl/PgConRequestMsgDaoImp.java b/src/com/szpg/db/dao/impl/PgConRequestMsgDaoImp.java new file mode 100644 index 0000000..d763e19 --- /dev/null +++ b/src/com/szpg/db/dao/impl/PgConRequestMsgDaoImp.java @@ -0,0 +1,108 @@ +package com.szpg.db.dao.impl; + +import com.szpg.db.dao.PgConRequestMsgDao; +import com.szpg.db.data.PgConRequestMsg; +import com.szpg.db.data.PgConWorkOrder; +import com.szpg.db.util.ConnectionManager; +import org.apache.commons.dbutils.DbUtils; +import org.apache.commons.dbutils.QueryRunner; +import org.apache.commons.dbutils.handlers.BeanListHandler; +import org.apache.log4j.Logger; + +import java.sql.Connection; +import java.sql.SQLException; +import java.util.ArrayList; +import java.util.Date; +import java.util.List; + +public class PgConRequestMsgDaoImp implements PgConRequestMsgDao { + + private org.apache.log4j.Logger logger = Logger.getLogger(this.getClass().getName()); + + @Override + public void addConRequestMsg(List pgConRequestMsgList){ + Connection conn = null; + + String insertStr = "INSERT INTO PG_CON_REQUEST_MSG " + + "(BUILD_TASK_ID, DATE, TASK_ID,BUILD_COMPANY,SUPERVISOR_TEL,TEL,BUILD_PLACE,BUILD_TIME,START_PLACE," + + "END_PLACE,PROJECT,BUILD_CONTENT,APPROVER,APPROVER_TIME,LOG_DATE)" + + "VALUES (?,?,?,?,?,?,?,?,?,?,?,?,?,?,?)"; + + List paramObjectList=new ArrayList<>(); + for(PgConRequestMsg pgConRequestMsg:pgConRequestMsgList){ + + Object[] params = new Object[34]; + params[0] = pgConRequestMsg.getBUILD_TASK_ID(); + params[1] = pgConRequestMsg.getDATE(); + params[2] = pgConRequestMsg.getTASK_ID(); + params[3] = pgConRequestMsg.getBUILD_COMPANY(); + params[4] = pgConRequestMsg.getSUPERVISOR_TEL(); + params[5] = pgConRequestMsg.getTEL(); + params[6] = pgConRequestMsg.getBUILD_PLACE(); + params[7] = pgConRequestMsg.getBUILD_TIME(); + params[8] = pgConRequestMsg.getSTART_PLACE(); + params[9] = pgConRequestMsg.getEND_PLACE(); + params[10] = pgConRequestMsg.getPROJECT(); + params[11] = pgConRequestMsg.getBUILD_CONTENT(); + params[12] = pgConRequestMsg.getAPPROVER(); + params[13] = pgConRequestMsg.getAPPROVER_TIME(); + params[14] = pgConRequestMsg.getLOG_DATE(); + + paramObjectList.add(params); + } + try { + conn = ConnectionManager.getConnectionFromC3P0(); + conn.setAutoCommit(false); + + QueryRunner runner = new QueryRunner(); + for (Object[] params:paramObjectList) { + int count = runner.update(conn, insertStr, params); + if (count > 0) + logger.info("施工请点数据同步成功" + pgConRequestMsgList.toString()); + else + logger.info("施工请点数据同步失败！"); + } + + } catch (Exception ex) { + logger.info("施工请点数据同步异常", ex); + } finally { + try { + DbUtils.commitAndClose(conn); + } catch (SQLException e) { + e.printStackTrace(); + } + } + } + + @Override + public String findLastRecordTime(){ + Connection conn = null; + + String queryStr = "SELECT * FROM PG_CON_REQUEST_MSG ORDER BY LOG_DATE DESC"; + try { + conn = ConnectionManager.getConnectionFromC3P0(); + conn.setAutoCommit(false); + + QueryRunner runner = new QueryRunner(); + List pgConRequestMsgList = (List) runner.query(conn, + queryStr, new BeanListHandler(PgConRequestMsg.class)); + + if (null != pgConRequestMsgList && pgConRequestMsgList.isEmpty() == false) { + logger.debug("获取最新施工请点记录成功[" + pgConRequestMsgList + "]"); + return pgConRequestMsgList.get(0).getLOG_DATE(); + } + else + return null; + } catch (Exception ex) { + logger.error("获取最新施工请点记录异常", ex); + } finally { + try { + DbUtils.commitAndClose(conn); + } catch (SQLException e) { + e.printStackTrace(); + } + } + return null; + } + +} diff --git a/src/com/szpg/db/dao/impl/PgConWorkOrderDaoImp.java b/src/com/szpg/db/dao/impl/PgConWorkOrderDaoImp.java new file mode 100644 index 0000000..98e2a66 --- /dev/null +++ b/src/com/szpg/db/dao/impl/PgConWorkOrderDaoImp.java @@ -0,0 +1,116 @@ +package com.szpg.db.dao.impl; + +import com.szpg.db.dao.PgConWorkOrderDao; +import com.szpg.db.data.PgAssetInSpectionPlan; +import com.szpg.db.data.PgConWorkOrder; +import com.szpg.db.util.ConnectionManager; +import freemarker.template.utility.DateUtil; +import org.apache.commons.dbutils.DbUtils; +import org.apache.commons.dbutils.QueryRunner; +import org.apache.commons.dbutils.handlers.BeanListHandler; +import org.apache.log4j.Logger; + +import java.sql.Connection; +import java.sql.SQLException; +import java.util.ArrayList; +import java.util.Date; +import java.util.List; + +public class PgConWorkOrderDaoImp implements PgConWorkOrderDao { + + private org.apache.log4j.Logger logger = Logger.getLogger(this.getClass().getName()); + + @Override + public void addConWorkerOrder(List pgConWorkOrderList){ + Connection conn = null; + + String insertStr = "INSERT INTO PG_CON_WORK_ORDER " + + "(KEY_ID, PLAN_NO, TASK_COMPANY,TASK_ID,SUPERVISOR,SUPERVISOR_PHONE,APPLCIANT,APPLCIANT_PHONE,TASK_NAME," + + "TASK_PLACE,TASK_DATE,TASK_DATE_END,PROJECT,TASK_CONTENT,TASK_SAFETY_MEASURES," + + "TASK_PEOPLE_NUM,TASK_INFLUENCE,COMPLETION_OF_THE_SITUATION,REMARKS,BUILD_STATE,LOG_DATE)" + + "VALUES (?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?)"; + + List paramObjectList=new ArrayList<>(); + for(PgConWorkOrder pgConWorkOrder:pgConWorkOrderList){ + + Object[] params = new Object[34]; + params[0] = pgConWorkOrder.getKEY_ID(); + params[1] = pgConWorkOrder.getPLAN_NO(); + params[2] = pgConWorkOrder.getTASK_COMPANY(); + params[3] = pgConWorkOrder.getTASK_ID(); + params[4] = pgConWorkOrder.getSUPERVISOR(); + params[5] = pgConWorkOrder.getSUPERVISOR_PHONE(); + params[6] = pgConWorkOrder.getAPPLCIANT(); + params[7] = pgConWorkOrder.getAPPLCIANT_PHONE(); + params[8] = pgConWorkOrder.getTASK_NAME(); + params[9] = pgConWorkOrder.getTASK_PLACE(); + params[10] = pgConWorkOrder.getTASK_DATE(); + params[11] = pgConWorkOrder.getTASK_DATE_END(); + params[12] = pgConWorkOrder.getPROJECT(); + params[13] = pgConWorkOrder.getTASK_CONTENT(); + params[14] = pgConWorkOrder.getTASK_SAFETY_MEASURES(); + params[15] = pgConWorkOrder.getTASK_PEOPLE_NUM(); + params[16] = pgConWorkOrder.getTASK_INFLUENCE(); + params[17] = pgConWorkOrder.getCOMPLETION_OF_THE_SITUATION(); + params[18] = pgConWorkOrder.getREMARKS(); + params[19] = pgConWorkOrder.getBUILD_STATE(); + params[19] = new Date(); + + paramObjectList.add(params); + } + try { + conn = ConnectionManager.getConnectionFromC3P0(); + conn.setAutoCommit(false); + + QueryRunner runner = new QueryRunner(); + for (Object[] params:paramObjectList) { + int count = runner.update(conn, insertStr, params); + if (count > 0) + logger.info("施工作业数据同步成功" + pgConWorkOrderList.toString()); + else + logger.info("施工作业数据同步失败！"); + } + + } catch (Exception ex) { + logger.info("施工作业数据同步异常", ex); + } finally { + try { + DbUtils.commitAndClose(conn); + } catch (SQLException e) { + e.printStackTrace(); + } + } + } + + @Override + public String findLastRecordTime(){ + Connection conn = null; + + String queryStr = "SELECT * FROM PG_CON_WORK_ORDER ORDER BY LOG_DATE DESC"; + try { + conn = ConnectionManager.getConnectionFromC3P0(); + conn.setAutoCommit(false); + + QueryRunner runner = new QueryRunner(); + List pgConWorkOrderList = (List) runner.query(conn, + queryStr, new BeanListHandler(PgConWorkOrder.class)); + + if (null != pgConWorkOrderList && pgConWorkOrderList.isEmpty() == false) { + logger.debug("获取最新施工记录成功[" + pgConWorkOrderList + "]"); + return pgConWorkOrderList.get(0).getLOG_DATE(); + } + else + return null; + } catch (Exception ex) { + logger.error("获取最新施工记录异常", ex); + } finally { + try { + DbUtils.commitAndClose(conn); + } catch (SQLException e) { + e.printStackTrace(); + } + } + return null; + } + +} diff --git a/.idea/workspace.xml b/.idea/workspace.xml new file mode 100644 index 0000000..e15ca50 --- /dev/null +++ b/.idea/workspace.xml @@ -0,0 +1,849 @@ + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + 未能连接到 + yy-mm-d + + + + + + + + + + + true + DEFINITION_ORDER + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + 1567762862031 + + + 1568000184886 + + + 1568100549456 + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + pgdsc + + + + + + + + Web (pgdsc)|Web + + + + + + + + + + + + + + + 1.8 + + + + + + + + pgdsc + + + + + + + + json + + + + + + + + \ No newline at end of file diff --git a/src/com/szpg/db/dao/PgConRemoveDao.java b/src/com/szpg/db/dao/PgConRemoveDao.java new file mode 100644 index 0000000..49903fc --- /dev/null +++ b/src/com/szpg/db/dao/PgConRemoveDao.java @@ -0,0 +1,14 @@ +package com.szpg.db.dao; + +import com.szpg.db.data.PgConRemoveMsg; +import com.szpg.db.data.PgConWorkOrder; + +import java.util.List; + +public interface PgConRemoveDao { + + public void addConRemove(List pgConRemoveMsgList); + + public String findLastRecordTime(); + +} diff --git a/src/com/szpg/db/dao/PgConRequestMsgDao.java b/src/com/szpg/db/dao/PgConRequestMsgDao.java new file mode 100644 index 0000000..274f5a6 --- /dev/null +++ b/src/com/szpg/db/dao/PgConRequestMsgDao.java @@ -0,0 +1,13 @@ +package com.szpg.db.dao; + +import com.szpg.db.data.PgConRequestMsg; +import com.szpg.db.data.PgConWorkOrder; + +import java.util.List; + +public interface PgConRequestMsgDao { + + public void addConRequestMsg(List pgConRequestMsgList); + + public String findLastRecordTime(); +} diff --git a/src/com/szpg/db/dao/PgConWorkOrderDao.java b/src/com/szpg/db/dao/PgConWorkOrderDao.java new file mode 100644 index 0000000..ad2c4ae --- /dev/null +++ b/src/com/szpg/db/dao/PgConWorkOrderDao.java @@ -0,0 +1,12 @@ +package com.szpg.db.dao; + + import com.szpg.db.data.PgConWorkOrder; + + import java.util.List; + +public interface PgConWorkOrderDao { + + public void addConWorkerOrder(List pgConWorkOrderList); + + public String findLastRecordTime(); +} diff --git a/src/com/szpg/db/dao/impl/PgAssetInSpectionImpl.java b/src/com/szpg/db/dao/impl/PgAssetInSpectionImpl.java index 2383707..de88d3b 100644 --- a/src/com/szpg/db/dao/impl/PgAssetInSpectionImpl.java +++ b/src/com/szpg/db/dao/impl/PgAssetInSpectionImpl.java @@ -28,47 +28,48 @@ "END_TIME,START_PILE_NO,END_PILE_NO,BUILD_CABIN,MILEAGE,FREQUENCY_TIME,FREQUENCYTIME_END,KETTLE_TS,UPDATEDATE) " + "VALUES (?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?)"; - List paramObjectList=new ArrayList(); + List paramObjectList=new ArrayList<>(); for(PgAssetInSpectionPlan pgAssetInSpectionPlan:pgAssetInSpectionPlanList){ + + if(!pgAssetInSpectionPlan.getPLAN_NAME().contains("吴中太湖新城")) continue; Object[] params = new Object[34]; params[0] = pgAssetInSpectionPlan.getKEY_ID(); params[1] = pgAssetInSpectionPlan.getPLAN_NAME(); params[2] = pgAssetInSpectionPlan.getINSPECTION_PERSON(); params[3] = pgAssetInSpectionPlan.getSTART_DATE(); - params[4]=pgAssetInSpectionPlan.getEND_DATE(); - params[5]=pgAssetInSpectionPlan.getFREQUENCY(); - params[6]=pgAssetInSpectionPlan.getSTATE(); - params[7]=pgAssetInSpectionPlan.getRESPONSIBLE_DEPT(); - params[8]=pgAssetInSpectionPlan.getPLAN_NO(); - params[9]=pgAssetInSpectionPlan.getINSPECTION_TYPE(); - params[10]=pgAssetInSpectionPlan.getINSPECTION_MODE(); - params[11]=pgAssetInSpectionPlan.getINSPECTION_ROUTE(); - params[12]=pgAssetInSpectionPlan.getINSPECTION_START_TIME(); - params[13]=pgAssetInSpectionPlan.getINSPECTION_END_TIME(); - params[14]=pgAssetInSpectionPlan.getINSPECTION_PRACE(); - params[15]=pgAssetInSpectionPlan.getINSPECTION_GROUP(); - params[16]=pgAssetInSpectionPlan.getINSERT_TIME(); - params[17]=pgAssetInSpectionPlan.getFREQUENCYDATE(); - params[18]=pgAssetInSpectionPlan.getFREQUENCYTIME(); - params[19]=pgAssetInSpectionPlan.getCREATEDATE(); - params[20]=pgAssetInSpectionPlan.getCREATOR(); - params[21]=pgAssetInSpectionPlan.getPROJECT(); - params[22]=pgAssetInSpectionPlan.getCOMLILE(); - params[23]=pgAssetInSpectionPlan.getSTART_TIME(); - params[24]=pgAssetInSpectionPlan.getDEVELOP_DEPT(); - params[25]=pgAssetInSpectionPlan.getEND_TIME(); - params[26]=pgAssetInSpectionPlan.getSTART_PILE_NO(); - params[27]=pgAssetInSpectionPlan.getEND_PILE_NO(); - params[28]=pgAssetInSpectionPlan.getBUILD_CABIN(); - params[29]=pgAssetInSpectionPlan.getMILEAGE(); - params[30]=pgAssetInSpectionPlan.getFREQUENCY_TIME(); - params[31]=pgAssetInSpectionPlan.getFREQUENCYTIME_END(); - params[32]=pgAssetInSpectionPlan.getKETTLE_TS(); - params[33]=pgAssetInSpectionPlan.getUPDATEDATE(); + params[4] = pgAssetInSpectionPlan.getEND_DATE(); + params[5] = pgAssetInSpectionPlan.getFREQUENCY(); + params[6] = pgAssetInSpectionPlan.getSTATE(); + params[7] = pgAssetInSpectionPlan.getRESPONSIBLE_DEPT(); + params[8] = pgAssetInSpectionPlan.getPLAN_NO(); + params[9] = pgAssetInSpectionPlan.getINSPECTION_TYPE(); + params[10] = pgAssetInSpectionPlan.getINSPECTION_MODE(); + params[11] = pgAssetInSpectionPlan.getINSPECTION_ROUTE(); + params[12] = pgAssetInSpectionPlan.getINSPECTION_START_TIME(); + params[13] = pgAssetInSpectionPlan.getINSPECTION_END_TIME(); + params[14] = pgAssetInSpectionPlan.getINSPECTION_PRACE(); + params[15] = pgAssetInSpectionPlan.getINSPECTION_GROUP(); + params[16] = pgAssetInSpectionPlan.getINSERT_TIME(); + params[17] = pgAssetInSpectionPlan.getFREQUENCYDATE(); + params[18] = pgAssetInSpectionPlan.getFREQUENCYTIME(); + params[19] = pgAssetInSpectionPlan.getCREATEDATE(); + params[20] = pgAssetInSpectionPlan.getCREATOR(); + params[21] = pgAssetInSpectionPlan.getPROJECT(); + params[22] = pgAssetInSpectionPlan.getCOMLILE(); + params[23] = pgAssetInSpectionPlan.getSTART_TIME(); + params[24] = pgAssetInSpectionPlan.getDEVELOP_DEPT(); + params[25] = pgAssetInSpectionPlan.getEND_TIME(); + params[26] = pgAssetInSpectionPlan.getSTART_PILE_NO(); + params[27] = pgAssetInSpectionPlan.getEND_PILE_NO(); + params[28] = pgAssetInSpectionPlan.getBUILD_CABIN(); + params[29] = pgAssetInSpectionPlan.getMILEAGE(); + params[30] = pgAssetInSpectionPlan.getFREQUENCY_TIME(); + params[31] = pgAssetInSpectionPlan.getFREQUENCYTIME_END(); + params[32] = pgAssetInSpectionPlan.getKETTLE_TS(); + params[33] = pgAssetInSpectionPlan.getUPDATEDATE(); paramObjectList.add(params); } - try { conn = ConnectionManager.getConnectionFromC3P0(); conn.setAutoCommit(false); diff --git a/src/com/szpg/db/dao/impl/PgConRemoveDaoImp.java b/src/com/szpg/db/dao/impl/PgConRemoveDaoImp.java new file mode 100644 index 0000000..510020e --- /dev/null +++ b/src/com/szpg/db/dao/impl/PgConRemoveDaoImp.java @@ -0,0 +1,98 @@ +package com.szpg.db.dao.impl; + +import com.szpg.db.dao.PgConRemoveDao; +import com.szpg.db.data.PgConRemoveMsg; +import com.szpg.db.util.ConnectionManager; +import org.apache.commons.dbutils.DbUtils; +import org.apache.commons.dbutils.QueryRunner; +import org.apache.commons.dbutils.handlers.BeanListHandler; +import org.apache.log4j.Logger; + +import java.sql.Connection; +import java.sql.SQLException; +import java.util.ArrayList; +import java.util.List; + +public class PgConRemoveDaoImp implements PgConRemoveDao { + + private org.apache.log4j.Logger logger = Logger.getLogger(this.getClass().getName()); + + @Override + public void addConRemove(List pgConRemoveMsgList){ + Connection conn = null; + + String insertStr = "INSERT INTO PG_CON_REMOVE_MSG " + + "(XD_DATE, XD_END_TIME, XD_SUPERVISOR,XD_FIELD_SITUATION,XD_REMARKS,XD_APPROVER,XD_APPROVER_TIME,LOG_DATE)" + + "VALUES (?,?,?,?,?,?,?,?)"; + + List paramObjectList=new ArrayList<>(); + for(PgConRemoveMsg pgConRemoveMsg:pgConRemoveMsgList){ + + Object[] params = new Object[34]; + params[0] = pgConRemoveMsg.getXD_DATE(); + params[1] = pgConRemoveMsg.getXD_END_TIME(); + params[2] = pgConRemoveMsg.getXD_SUPERVISOR(); + params[3] = pgConRemoveMsg.getXD_FIELD_SITUATION(); + params[4] = pgConRemoveMsg.getXD_REMARKS(); + params[5] = pgConRemoveMsg.getXD_APPROVER(); + params[6] = pgConRemoveMsg.getXD_APPROVER_TIME(); + params[7] = pgConRemoveMsg.getLOG_DATE(); + + paramObjectList.add(params); + } + try { + conn = ConnectionManager.getConnectionFromC3P0(); + conn.setAutoCommit(false); + + QueryRunner runner = new QueryRunner(); + for (Object[] params:paramObjectList) { + int count = runner.update(conn, insertStr, params); + if (count > 0) + logger.info("施工消点数据同步成功" + pgConRemoveMsgList.toString()); + else + logger.info("施工消点数据同步失败！"); + } + + } catch (Exception ex) { + logger.info("施工作业数据同步异常", ex); + } finally { + try { + DbUtils.commitAndClose(conn); + } catch (SQLException e) { + e.printStackTrace(); + } + } + } + + @Override + public String findLastRecordTime(){ + Connection conn = null; + + String queryStr = "SELECT * FROM PG_CON_REMOVE_MSG ORDER BY LOG_DATE DESC"; + try { + conn = ConnectionManager.getConnectionFromC3P0(); + conn.setAutoCommit(false); + + QueryRunner runner = new QueryRunner(); + List pgConRemoveMsgList = (List) runner.query(conn, + queryStr, new BeanListHandler(PgConRemoveMsg.class)); + + if (null != pgConRemoveMsgList && pgConRemoveMsgList.isEmpty() == false) { + logger.debug("获取最新施工消点记录成功[" + pgConRemoveMsgList + "]"); + return pgConRemoveMsgList.get(0).getLOG_DATE(); + } + else + return null; + } catch (Exception ex) { + logger.error("获取最新施工消点记录异常", ex); + } finally { + try { + DbUtils.commitAndClose(conn); + } catch (SQLException e) { + e.printStackTrace(); + } + } + return null; + } + +} diff --git a/src/com/szpg/db/dao/impl/PgConRequestMsgDaoImp.java b/src/com/szpg/db/dao/impl/PgConRequestMsgDaoImp.java new file mode 100644 index 0000000..d763e19 --- /dev/null +++ b/src/com/szpg/db/dao/impl/PgConRequestMsgDaoImp.java @@ -0,0 +1,108 @@ +package com.szpg.db.dao.impl; + +import com.szpg.db.dao.PgConRequestMsgDao; +import com.szpg.db.data.PgConRequestMsg; +import com.szpg.db.data.PgConWorkOrder; +import com.szpg.db.util.ConnectionManager; +import org.apache.commons.dbutils.DbUtils; +import org.apache.commons.dbutils.QueryRunner; +import org.apache.commons.dbutils.handlers.BeanListHandler; +import org.apache.log4j.Logger; + +import java.sql.Connection; +import java.sql.SQLException; +import java.util.ArrayList; +import java.util.Date; +import java.util.List; + +public class PgConRequestMsgDaoImp implements PgConRequestMsgDao { + + private org.apache.log4j.Logger logger = Logger.getLogger(this.getClass().getName()); + + @Override + public void addConRequestMsg(List pgConRequestMsgList){ + Connection conn = null; + + String insertStr = "INSERT INTO PG_CON_REQUEST_MSG " + + "(BUILD_TASK_ID, DATE, TASK_ID,BUILD_COMPANY,SUPERVISOR_TEL,TEL,BUILD_PLACE,BUILD_TIME,START_PLACE," + + "END_PLACE,PROJECT,BUILD_CONTENT,APPROVER,APPROVER_TIME,LOG_DATE)" + + "VALUES (?,?,?,?,?,?,?,?,?,?,?,?,?,?,?)"; + + List paramObjectList=new ArrayList<>(); + for(PgConRequestMsg pgConRequestMsg:pgConRequestMsgList){ + + Object[] params = new Object[34]; + params[0] = pgConRequestMsg.getBUILD_TASK_ID(); + params[1] = pgConRequestMsg.getDATE(); + params[2] = pgConRequestMsg.getTASK_ID(); + params[3] = pgConRequestMsg.getBUILD_COMPANY(); + params[4] = pgConRequestMsg.getSUPERVISOR_TEL(); + params[5] = pgConRequestMsg.getTEL(); + params[6] = pgConRequestMsg.getBUILD_PLACE(); + params[7] = pgConRequestMsg.getBUILD_TIME(); + params[8] = pgConRequestMsg.getSTART_PLACE(); + params[9] = pgConRequestMsg.getEND_PLACE(); + params[10] = pgConRequestMsg.getPROJECT(); + params[11] = pgConRequestMsg.getBUILD_CONTENT(); + params[12] = pgConRequestMsg.getAPPROVER(); + params[13] = pgConRequestMsg.getAPPROVER_TIME(); + params[14] = pgConRequestMsg.getLOG_DATE(); + + paramObjectList.add(params); + } + try { + conn = ConnectionManager.getConnectionFromC3P0(); + conn.setAutoCommit(false); + + QueryRunner runner = new QueryRunner(); + for (Object[] params:paramObjectList) { + int count = runner.update(conn, insertStr, params); + if (count > 0) + logger.info("施工请点数据同步成功" + pgConRequestMsgList.toString()); + else + logger.info("施工请点数据同步失败！"); + } + + } catch (Exception ex) { + logger.info("施工请点数据同步异常", ex); + } finally { + try { + DbUtils.commitAndClose(conn); + } catch (SQLException e) { + e.printStackTrace(); + } + } + } + + @Override + public String findLastRecordTime(){ + Connection conn = null; + + String queryStr = "SELECT * FROM PG_CON_REQUEST_MSG ORDER BY LOG_DATE DESC"; + try { + conn = ConnectionManager.getConnectionFromC3P0(); + conn.setAutoCommit(false); + + QueryRunner runner = new QueryRunner(); + List pgConRequestMsgList = (List) runner.query(conn, + queryStr, new BeanListHandler(PgConRequestMsg.class)); + + if (null != pgConRequestMsgList && pgConRequestMsgList.isEmpty() == false) { + logger.debug("获取最新施工请点记录成功[" + pgConRequestMsgList + "]"); + return pgConRequestMsgList.get(0).getLOG_DATE(); + } + else + return null; + } catch (Exception ex) { + logger.error("获取最新施工请点记录异常", ex); + } finally { + try { + DbUtils.commitAndClose(conn); + } catch (SQLException e) { + e.printStackTrace(); + } + } + return null; + } + +} diff --git a/src/com/szpg/db/dao/impl/PgConWorkOrderDaoImp.java b/src/com/szpg/db/dao/impl/PgConWorkOrderDaoImp.java new file mode 100644 index 0000000..98e2a66 --- /dev/null +++ b/src/com/szpg/db/dao/impl/PgConWorkOrderDaoImp.java @@ -0,0 +1,116 @@ +package com.szpg.db.dao.impl; + +import com.szpg.db.dao.PgConWorkOrderDao; +import com.szpg.db.data.PgAssetInSpectionPlan; +import com.szpg.db.data.PgConWorkOrder; +import com.szpg.db.util.ConnectionManager; +import freemarker.template.utility.DateUtil; +import org.apache.commons.dbutils.DbUtils; +import org.apache.commons.dbutils.QueryRunner; +import org.apache.commons.dbutils.handlers.BeanListHandler; +import org.apache.log4j.Logger; + +import java.sql.Connection; +import java.sql.SQLException; +import java.util.ArrayList; +import java.util.Date; +import java.util.List; + +public class PgConWorkOrderDaoImp implements PgConWorkOrderDao { + + private org.apache.log4j.Logger logger = Logger.getLogger(this.getClass().getName()); + + @Override + public void addConWorkerOrder(List pgConWorkOrderList){ + Connection conn = null; + + String insertStr = "INSERT INTO PG_CON_WORK_ORDER " + + "(KEY_ID, PLAN_NO, TASK_COMPANY,TASK_ID,SUPERVISOR,SUPERVISOR_PHONE,APPLCIANT,APPLCIANT_PHONE,TASK_NAME," + + "TASK_PLACE,TASK_DATE,TASK_DATE_END,PROJECT,TASK_CONTENT,TASK_SAFETY_MEASURES," + + "TASK_PEOPLE_NUM,TASK_INFLUENCE,COMPLETION_OF_THE_SITUATION,REMARKS,BUILD_STATE,LOG_DATE)" + + "VALUES (?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?)"; + + List paramObjectList=new ArrayList<>(); + for(PgConWorkOrder pgConWorkOrder:pgConWorkOrderList){ + + Object[] params = new Object[34]; + params[0] = pgConWorkOrder.getKEY_ID(); + params[1] = pgConWorkOrder.getPLAN_NO(); + params[2] = pgConWorkOrder.getTASK_COMPANY(); + params[3] = pgConWorkOrder.getTASK_ID(); + params[4] = pgConWorkOrder.getSUPERVISOR(); + params[5] = pgConWorkOrder.getSUPERVISOR_PHONE(); + params[6] = pgConWorkOrder.getAPPLCIANT(); + params[7] = pgConWorkOrder.getAPPLCIANT_PHONE(); + params[8] = pgConWorkOrder.getTASK_NAME(); + params[9] = pgConWorkOrder.getTASK_PLACE(); + params[10] = pgConWorkOrder.getTASK_DATE(); + params[11] = pgConWorkOrder.getTASK_DATE_END(); + params[12] = pgConWorkOrder.getPROJECT(); + params[13] = pgConWorkOrder.getTASK_CONTENT(); + params[14] = pgConWorkOrder.getTASK_SAFETY_MEASURES(); + params[15] = pgConWorkOrder.getTASK_PEOPLE_NUM(); + params[16] = pgConWorkOrder.getTASK_INFLUENCE(); + params[17] = pgConWorkOrder.getCOMPLETION_OF_THE_SITUATION(); + params[18] = pgConWorkOrder.getREMARKS(); + params[19] = pgConWorkOrder.getBUILD_STATE(); + params[19] = new Date(); + + paramObjectList.add(params); + } + try { + conn = ConnectionManager.getConnectionFromC3P0(); + conn.setAutoCommit(false); + + QueryRunner runner = new QueryRunner(); + for (Object[] params:paramObjectList) { + int count = runner.update(conn, insertStr, params); + if (count > 0) + logger.info("施工作业数据同步成功" + pgConWorkOrderList.toString()); + else + logger.info("施工作业数据同步失败！"); + } + + } catch (Exception ex) { + logger.info("施工作业数据同步异常", ex); + } finally { + try { + DbUtils.commitAndClose(conn); + } catch (SQLException e) { + e.printStackTrace(); + } + } + } + + @Override + public String findLastRecordTime(){ + Connection conn = null; + + String queryStr = "SELECT * FROM PG_CON_WORK_ORDER ORDER BY LOG_DATE DESC"; + try { + conn = ConnectionManager.getConnectionFromC3P0(); + conn.setAutoCommit(false); + + QueryRunner runner = new QueryRunner(); + List pgConWorkOrderList = (List) runner.query(conn, + queryStr, new BeanListHandler(PgConWorkOrder.class)); + + if (null != pgConWorkOrderList && pgConWorkOrderList.isEmpty() == false) { + logger.debug("获取最新施工记录成功[" + pgConWorkOrderList + "]"); + return pgConWorkOrderList.get(0).getLOG_DATE(); + } + else + return null; + } catch (Exception ex) { + logger.error("获取最新施工记录异常", ex); + } finally { + try { + DbUtils.commitAndClose(conn); + } catch (SQLException e) { + e.printStackTrace(); + } + } + return null; + } + +} diff --git a/src/com/szpg/db/data/PgAssetInSpectionPlan.java b/src/com/szpg/db/data/PgAssetInSpectionPlan.java index fd10c61..c86ec88 100644 --- a/src/com/szpg/db/data/PgAssetInSpectionPlan.java +++ b/src/com/szpg/db/data/PgAssetInSpectionPlan.java @@ -103,7 +103,6 @@ this.RESPONSIBLE_DEPT = RESPONSIBLE_DEPT; } - public String getPLAN_NO() { return PLAN_NO; } @@ -312,5 +311,4 @@ this.UPDATEDATE = UPDATEDATE; } - -} +} \ No newline at end of file diff --git a/src/com/szpg/db/data/PgConRemoveMsg.java b/src/com/szpg/db/data/PgConRemoveMsg.java new file mode 100644 index 0000000..6dcbaa0 --- /dev/null +++ b/src/com/szpg/db/data/PgConRemoveMsg.java @@ -0,0 +1,79 @@ +package com.szpg.db.data; + +import java.io.Serializable; + +public class PgConRemoveMsg implements Serializable { + + private String XD_DATE; + private String XD_END_TIME; + private String XD_SUPERVISOR; + private String XD_FIELD_SITUATION; + private String XD_REMARKS; + private String XD_APPROVER; + private String XD_APPROVER_TIME; + private String LOG_DATE; + + public String getXD_DATE() { + return XD_DATE; + } + + public void setXD_DATE(String XD_DATE) { + this.XD_DATE = XD_DATE; + } + + public String getXD_END_TIME() { + return XD_END_TIME; + } + + public void setXD_END_TIME(String XD_END_TIME) { + this.XD_END_TIME = XD_END_TIME; + } + + public String getXD_SUPERVISOR() { + return XD_SUPERVISOR; + } + + public void setXD_SUPERVISOR(String XD_SUPERVISOR) { + this.XD_SUPERVISOR = XD_SUPERVISOR; + } + + public String getXD_FIELD_SITUATION() { + return XD_FIELD_SITUATION; + } + + public void setXD_FIELD_SITUATION(String XD_FIELD_SITUATION) { + this.XD_FIELD_SITUATION = XD_FIELD_SITUATION; + } + + public String getXD_REMARKS() { + return XD_REMARKS; + } + + public void setXD_REMARKS(String XD_REMARKS) { + this.XD_REMARKS = XD_REMARKS; + } + + public String getXD_APPROVER() { + return XD_APPROVER; + } + + public void setXD_APPROVER(String XD_APPROVER) { + this.XD_APPROVER = XD_APPROVER; + } + + public String getXD_APPROVER_TIME() { + return XD_APPROVER_TIME; + } + + public void setXD_APPROVER_TIME(String XD_APPROVER_TIME) { + this.XD_APPROVER_TIME = XD_APPROVER_TIME; + } + + public String getLOG_DATE() { + return LOG_DATE; + } + + public void setLOG_DATE(String LOG_DATE) { + this.LOG_DATE = LOG_DATE; + } +} diff --git a/.idea/workspace.xml b/.idea/workspace.xml new file mode 100644 index 0000000..e15ca50 --- /dev/null +++ b/.idea/workspace.xml @@ -0,0 +1,849 @@ + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + 未能连接到 + yy-mm-d + + + + + + + + + + + true + DEFINITION_ORDER + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + 1567762862031 + + + 1568000184886 + + + 1568100549456 + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + pgdsc + + + + + + + + Web (pgdsc)|Web + + + + + + + + + + + + + + + 1.8 + + + + + + + + pgdsc + + + + + + + + json + + + + + + + + \ No newline at end of file diff --git a/src/com/szpg/db/dao/PgConRemoveDao.java b/src/com/szpg/db/dao/PgConRemoveDao.java new file mode 100644 index 0000000..49903fc --- /dev/null +++ b/src/com/szpg/db/dao/PgConRemoveDao.java @@ -0,0 +1,14 @@ +package com.szpg.db.dao; + +import com.szpg.db.data.PgConRemoveMsg; +import com.szpg.db.data.PgConWorkOrder; + +import java.util.List; + +public interface PgConRemoveDao { + + public void addConRemove(List pgConRemoveMsgList); + + public String findLastRecordTime(); + +} diff --git a/src/com/szpg/db/dao/PgConRequestMsgDao.java b/src/com/szpg/db/dao/PgConRequestMsgDao.java new file mode 100644 index 0000000..274f5a6 --- /dev/null +++ b/src/com/szpg/db/dao/PgConRequestMsgDao.java @@ -0,0 +1,13 @@ +package com.szpg.db.dao; + +import com.szpg.db.data.PgConRequestMsg; +import com.szpg.db.data.PgConWorkOrder; + +import java.util.List; + +public interface PgConRequestMsgDao { + + public void addConRequestMsg(List pgConRequestMsgList); + + public String findLastRecordTime(); +} diff --git a/src/com/szpg/db/dao/PgConWorkOrderDao.java b/src/com/szpg/db/dao/PgConWorkOrderDao.java new file mode 100644 index 0000000..ad2c4ae --- /dev/null +++ b/src/com/szpg/db/dao/PgConWorkOrderDao.java @@ -0,0 +1,12 @@ +package com.szpg.db.dao; + + import com.szpg.db.data.PgConWorkOrder; + + import java.util.List; + +public interface PgConWorkOrderDao { + + public void addConWorkerOrder(List pgConWorkOrderList); + + public String findLastRecordTime(); +} diff --git a/src/com/szpg/db/dao/impl/PgAssetInSpectionImpl.java b/src/com/szpg/db/dao/impl/PgAssetInSpectionImpl.java index 2383707..de88d3b 100644 --- a/src/com/szpg/db/dao/impl/PgAssetInSpectionImpl.java +++ b/src/com/szpg/db/dao/impl/PgAssetInSpectionImpl.java @@ -28,47 +28,48 @@ "END_TIME,START_PILE_NO,END_PILE_NO,BUILD_CABIN,MILEAGE,FREQUENCY_TIME,FREQUENCYTIME_END,KETTLE_TS,UPDATEDATE) " + "VALUES (?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?)"; - List paramObjectList=new ArrayList(); + List paramObjectList=new ArrayList<>(); for(PgAssetInSpectionPlan pgAssetInSpectionPlan:pgAssetInSpectionPlanList){ + + if(!pgAssetInSpectionPlan.getPLAN_NAME().contains("吴中太湖新城")) continue; Object[] params = new Object[34]; params[0] = pgAssetInSpectionPlan.getKEY_ID(); params[1] = pgAssetInSpectionPlan.getPLAN_NAME(); params[2] = pgAssetInSpectionPlan.getINSPECTION_PERSON(); params[3] = pgAssetInSpectionPlan.getSTART_DATE(); - params[4]=pgAssetInSpectionPlan.getEND_DATE(); - params[5]=pgAssetInSpectionPlan.getFREQUENCY(); - params[6]=pgAssetInSpectionPlan.getSTATE(); - params[7]=pgAssetInSpectionPlan.getRESPONSIBLE_DEPT(); - params[8]=pgAssetInSpectionPlan.getPLAN_NO(); - params[9]=pgAssetInSpectionPlan.getINSPECTION_TYPE(); - params[10]=pgAssetInSpectionPlan.getINSPECTION_MODE(); - params[11]=pgAssetInSpectionPlan.getINSPECTION_ROUTE(); - params[12]=pgAssetInSpectionPlan.getINSPECTION_START_TIME(); - params[13]=pgAssetInSpectionPlan.getINSPECTION_END_TIME(); - params[14]=pgAssetInSpectionPlan.getINSPECTION_PRACE(); - params[15]=pgAssetInSpectionPlan.getINSPECTION_GROUP(); - params[16]=pgAssetInSpectionPlan.getINSERT_TIME(); - params[17]=pgAssetInSpectionPlan.getFREQUENCYDATE(); - params[18]=pgAssetInSpectionPlan.getFREQUENCYTIME(); - params[19]=pgAssetInSpectionPlan.getCREATEDATE(); - params[20]=pgAssetInSpectionPlan.getCREATOR(); - params[21]=pgAssetInSpectionPlan.getPROJECT(); - params[22]=pgAssetInSpectionPlan.getCOMLILE(); - params[23]=pgAssetInSpectionPlan.getSTART_TIME(); - params[24]=pgAssetInSpectionPlan.getDEVELOP_DEPT(); - params[25]=pgAssetInSpectionPlan.getEND_TIME(); - params[26]=pgAssetInSpectionPlan.getSTART_PILE_NO(); - params[27]=pgAssetInSpectionPlan.getEND_PILE_NO(); - params[28]=pgAssetInSpectionPlan.getBUILD_CABIN(); - params[29]=pgAssetInSpectionPlan.getMILEAGE(); - params[30]=pgAssetInSpectionPlan.getFREQUENCY_TIME(); - params[31]=pgAssetInSpectionPlan.getFREQUENCYTIME_END(); - params[32]=pgAssetInSpectionPlan.getKETTLE_TS(); - params[33]=pgAssetInSpectionPlan.getUPDATEDATE(); + params[4] = pgAssetInSpectionPlan.getEND_DATE(); + params[5] = pgAssetInSpectionPlan.getFREQUENCY(); + params[6] = pgAssetInSpectionPlan.getSTATE(); + params[7] = pgAssetInSpectionPlan.getRESPONSIBLE_DEPT(); + params[8] = pgAssetInSpectionPlan.getPLAN_NO(); + params[9] = pgAssetInSpectionPlan.getINSPECTION_TYPE(); + params[10] = pgAssetInSpectionPlan.getINSPECTION_MODE(); + params[11] = pgAssetInSpectionPlan.getINSPECTION_ROUTE(); + params[12] = pgAssetInSpectionPlan.getINSPECTION_START_TIME(); + params[13] = pgAssetInSpectionPlan.getINSPECTION_END_TIME(); + params[14] = pgAssetInSpectionPlan.getINSPECTION_PRACE(); + params[15] = pgAssetInSpectionPlan.getINSPECTION_GROUP(); + params[16] = pgAssetInSpectionPlan.getINSERT_TIME(); + params[17] = pgAssetInSpectionPlan.getFREQUENCYDATE(); + params[18] = pgAssetInSpectionPlan.getFREQUENCYTIME(); + params[19] = pgAssetInSpectionPlan.getCREATEDATE(); + params[20] = pgAssetInSpectionPlan.getCREATOR(); + params[21] = pgAssetInSpectionPlan.getPROJECT(); + params[22] = pgAssetInSpectionPlan.getCOMLILE(); + params[23] = pgAssetInSpectionPlan.getSTART_TIME(); + params[24] = pgAssetInSpectionPlan.getDEVELOP_DEPT(); + params[25] = pgAssetInSpectionPlan.getEND_TIME(); + params[26] = pgAssetInSpectionPlan.getSTART_PILE_NO(); + params[27] = pgAssetInSpectionPlan.getEND_PILE_NO(); + params[28] = pgAssetInSpectionPlan.getBUILD_CABIN(); + params[29] = pgAssetInSpectionPlan.getMILEAGE(); + params[30] = pgAssetInSpectionPlan.getFREQUENCY_TIME(); + params[31] = pgAssetInSpectionPlan.getFREQUENCYTIME_END(); + params[32] = pgAssetInSpectionPlan.getKETTLE_TS(); + params[33] = pgAssetInSpectionPlan.getUPDATEDATE(); paramObjectList.add(params); } - try { conn = ConnectionManager.getConnectionFromC3P0(); conn.setAutoCommit(false); diff --git a/src/com/szpg/db/dao/impl/PgConRemoveDaoImp.java b/src/com/szpg/db/dao/impl/PgConRemoveDaoImp.java new file mode 100644 index 0000000..510020e --- /dev/null +++ b/src/com/szpg/db/dao/impl/PgConRemoveDaoImp.java @@ -0,0 +1,98 @@ +package com.szpg.db.dao.impl; + +import com.szpg.db.dao.PgConRemoveDao; +import com.szpg.db.data.PgConRemoveMsg; +import com.szpg.db.util.ConnectionManager; +import org.apache.commons.dbutils.DbUtils; +import org.apache.commons.dbutils.QueryRunner; +import org.apache.commons.dbutils.handlers.BeanListHandler; +import org.apache.log4j.Logger; + +import java.sql.Connection; +import java.sql.SQLException; +import java.util.ArrayList; +import java.util.List; + +public class PgConRemoveDaoImp implements PgConRemoveDao { + + private org.apache.log4j.Logger logger = Logger.getLogger(this.getClass().getName()); + + @Override + public void addConRemove(List pgConRemoveMsgList){ + Connection conn = null; + + String insertStr = "INSERT INTO PG_CON_REMOVE_MSG " + + "(XD_DATE, XD_END_TIME, XD_SUPERVISOR,XD_FIELD_SITUATION,XD_REMARKS,XD_APPROVER,XD_APPROVER_TIME,LOG_DATE)" + + "VALUES (?,?,?,?,?,?,?,?)"; + + List paramObjectList=new ArrayList<>(); + for(PgConRemoveMsg pgConRemoveMsg:pgConRemoveMsgList){ + + Object[] params = new Object[34]; + params[0] = pgConRemoveMsg.getXD_DATE(); + params[1] = pgConRemoveMsg.getXD_END_TIME(); + params[2] = pgConRemoveMsg.getXD_SUPERVISOR(); + params[3] = pgConRemoveMsg.getXD_FIELD_SITUATION(); + params[4] = pgConRemoveMsg.getXD_REMARKS(); + params[5] = pgConRemoveMsg.getXD_APPROVER(); + params[6] = pgConRemoveMsg.getXD_APPROVER_TIME(); + params[7] = pgConRemoveMsg.getLOG_DATE(); + + paramObjectList.add(params); + } + try { + conn = ConnectionManager.getConnectionFromC3P0(); + conn.setAutoCommit(false); + + QueryRunner runner = new QueryRunner(); + for (Object[] params:paramObjectList) { + int count = runner.update(conn, insertStr, params); + if (count > 0) + logger.info("施工消点数据同步成功" + pgConRemoveMsgList.toString()); + else + logger.info("施工消点数据同步失败！"); + } + + } catch (Exception ex) { + logger.info("施工作业数据同步异常", ex); + } finally { + try { + DbUtils.commitAndClose(conn); + } catch (SQLException e) { + e.printStackTrace(); + } + } + } + + @Override + public String findLastRecordTime(){ + Connection conn = null; + + String queryStr = "SELECT * FROM PG_CON_REMOVE_MSG ORDER BY LOG_DATE DESC"; + try { + conn = ConnectionManager.getConnectionFromC3P0(); + conn.setAutoCommit(false); + + QueryRunner runner = new QueryRunner(); + List pgConRemoveMsgList = (List) runner.query(conn, + queryStr, new BeanListHandler(PgConRemoveMsg.class)); + + if (null != pgConRemoveMsgList && pgConRemoveMsgList.isEmpty() == false) { + logger.debug("获取最新施工消点记录成功[" + pgConRemoveMsgList + "]"); + return pgConRemoveMsgList.get(0).getLOG_DATE(); + } + else + return null; + } catch (Exception ex) { + logger.error("获取最新施工消点记录异常", ex); + } finally { + try { + DbUtils.commitAndClose(conn); + } catch (SQLException e) { + e.printStackTrace(); + } + } + return null; + } + +} diff --git a/src/com/szpg/db/dao/impl/PgConRequestMsgDaoImp.java b/src/com/szpg/db/dao/impl/PgConRequestMsgDaoImp.java new file mode 100644 index 0000000..d763e19 --- /dev/null +++ b/src/com/szpg/db/dao/impl/PgConRequestMsgDaoImp.java @@ -0,0 +1,108 @@ +package com.szpg.db.dao.impl; + +import com.szpg.db.dao.PgConRequestMsgDao; +import com.szpg.db.data.PgConRequestMsg; +import com.szpg.db.data.PgConWorkOrder; +import com.szpg.db.util.ConnectionManager; +import org.apache.commons.dbutils.DbUtils; +import org.apache.commons.dbutils.QueryRunner; +import org.apache.commons.dbutils.handlers.BeanListHandler; +import org.apache.log4j.Logger; + +import java.sql.Connection; +import java.sql.SQLException; +import java.util.ArrayList; +import java.util.Date; +import java.util.List; + +public class PgConRequestMsgDaoImp implements PgConRequestMsgDao { + + private org.apache.log4j.Logger logger = Logger.getLogger(this.getClass().getName()); + + @Override + public void addConRequestMsg(List pgConRequestMsgList){ + Connection conn = null; + + String insertStr = "INSERT INTO PG_CON_REQUEST_MSG " + + "(BUILD_TASK_ID, DATE, TASK_ID,BUILD_COMPANY,SUPERVISOR_TEL,TEL,BUILD_PLACE,BUILD_TIME,START_PLACE," + + "END_PLACE,PROJECT,BUILD_CONTENT,APPROVER,APPROVER_TIME,LOG_DATE)" + + "VALUES (?,?,?,?,?,?,?,?,?,?,?,?,?,?,?)"; + + List paramObjectList=new ArrayList<>(); + for(PgConRequestMsg pgConRequestMsg:pgConRequestMsgList){ + + Object[] params = new Object[34]; + params[0] = pgConRequestMsg.getBUILD_TASK_ID(); + params[1] = pgConRequestMsg.getDATE(); + params[2] = pgConRequestMsg.getTASK_ID(); + params[3] = pgConRequestMsg.getBUILD_COMPANY(); + params[4] = pgConRequestMsg.getSUPERVISOR_TEL(); + params[5] = pgConRequestMsg.getTEL(); + params[6] = pgConRequestMsg.getBUILD_PLACE(); + params[7] = pgConRequestMsg.getBUILD_TIME(); + params[8] = pgConRequestMsg.getSTART_PLACE(); + params[9] = pgConRequestMsg.getEND_PLACE(); + params[10] = pgConRequestMsg.getPROJECT(); + params[11] = pgConRequestMsg.getBUILD_CONTENT(); + params[12] = pgConRequestMsg.getAPPROVER(); + params[13] = pgConRequestMsg.getAPPROVER_TIME(); + params[14] = pgConRequestMsg.getLOG_DATE(); + + paramObjectList.add(params); + } + try { + conn = ConnectionManager.getConnectionFromC3P0(); + conn.setAutoCommit(false); + + QueryRunner runner = new QueryRunner(); + for (Object[] params:paramObjectList) { + int count = runner.update(conn, insertStr, params); + if (count > 0) + logger.info("施工请点数据同步成功" + pgConRequestMsgList.toString()); + else + logger.info("施工请点数据同步失败！"); + } + + } catch (Exception ex) { + logger.info("施工请点数据同步异常", ex); + } finally { + try { + DbUtils.commitAndClose(conn); + } catch (SQLException e) { + e.printStackTrace(); + } + } + } + + @Override + public String findLastRecordTime(){ + Connection conn = null; + + String queryStr = "SELECT * FROM PG_CON_REQUEST_MSG ORDER BY LOG_DATE DESC"; + try { + conn = ConnectionManager.getConnectionFromC3P0(); + conn.setAutoCommit(false); + + QueryRunner runner = new QueryRunner(); + List pgConRequestMsgList = (List) runner.query(conn, + queryStr, new BeanListHandler(PgConRequestMsg.class)); + + if (null != pgConRequestMsgList && pgConRequestMsgList.isEmpty() == false) { + logger.debug("获取最新施工请点记录成功[" + pgConRequestMsgList + "]"); + return pgConRequestMsgList.get(0).getLOG_DATE(); + } + else + return null; + } catch (Exception ex) { + logger.error("获取最新施工请点记录异常", ex); + } finally { + try { + DbUtils.commitAndClose(conn); + } catch (SQLException e) { + e.printStackTrace(); + } + } + return null; + } + +} diff --git a/src/com/szpg/db/dao/impl/PgConWorkOrderDaoImp.java b/src/com/szpg/db/dao/impl/PgConWorkOrderDaoImp.java new file mode 100644 index 0000000..98e2a66 --- /dev/null +++ b/src/com/szpg/db/dao/impl/PgConWorkOrderDaoImp.java @@ -0,0 +1,116 @@ +package com.szpg.db.dao.impl; + +import com.szpg.db.dao.PgConWorkOrderDao; +import com.szpg.db.data.PgAssetInSpectionPlan; +import com.szpg.db.data.PgConWorkOrder; +import com.szpg.db.util.ConnectionManager; +import freemarker.template.utility.DateUtil; +import org.apache.commons.dbutils.DbUtils; +import org.apache.commons.dbutils.QueryRunner; +import org.apache.commons.dbutils.handlers.BeanListHandler; +import org.apache.log4j.Logger; + +import java.sql.Connection; +import java.sql.SQLException; +import java.util.ArrayList; +import java.util.Date; +import java.util.List; + +public class PgConWorkOrderDaoImp implements PgConWorkOrderDao { + + private org.apache.log4j.Logger logger = Logger.getLogger(this.getClass().getName()); + + @Override + public void addConWorkerOrder(List pgConWorkOrderList){ + Connection conn = null; + + String insertStr = "INSERT INTO PG_CON_WORK_ORDER " + + "(KEY_ID, PLAN_NO, TASK_COMPANY,TASK_ID,SUPERVISOR,SUPERVISOR_PHONE,APPLCIANT,APPLCIANT_PHONE,TASK_NAME," + + "TASK_PLACE,TASK_DATE,TASK_DATE_END,PROJECT,TASK_CONTENT,TASK_SAFETY_MEASURES," + + "TASK_PEOPLE_NUM,TASK_INFLUENCE,COMPLETION_OF_THE_SITUATION,REMARKS,BUILD_STATE,LOG_DATE)" + + "VALUES (?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?)"; + + List paramObjectList=new ArrayList<>(); + for(PgConWorkOrder pgConWorkOrder:pgConWorkOrderList){ + + Object[] params = new Object[34]; + params[0] = pgConWorkOrder.getKEY_ID(); + params[1] = pgConWorkOrder.getPLAN_NO(); + params[2] = pgConWorkOrder.getTASK_COMPANY(); + params[3] = pgConWorkOrder.getTASK_ID(); + params[4] = pgConWorkOrder.getSUPERVISOR(); + params[5] = pgConWorkOrder.getSUPERVISOR_PHONE(); + params[6] = pgConWorkOrder.getAPPLCIANT(); + params[7] = pgConWorkOrder.getAPPLCIANT_PHONE(); + params[8] = pgConWorkOrder.getTASK_NAME(); + params[9] = pgConWorkOrder.getTASK_PLACE(); + params[10] = pgConWorkOrder.getTASK_DATE(); + params[11] = pgConWorkOrder.getTASK_DATE_END(); + params[12] = pgConWorkOrder.getPROJECT(); + params[13] = pgConWorkOrder.getTASK_CONTENT(); + params[14] = pgConWorkOrder.getTASK_SAFETY_MEASURES(); + params[15] = pgConWorkOrder.getTASK_PEOPLE_NUM(); + params[16] = pgConWorkOrder.getTASK_INFLUENCE(); + params[17] = pgConWorkOrder.getCOMPLETION_OF_THE_SITUATION(); + params[18] = pgConWorkOrder.getREMARKS(); + params[19] = pgConWorkOrder.getBUILD_STATE(); + params[19] = new Date(); + + paramObjectList.add(params); + } + try { + conn = ConnectionManager.getConnectionFromC3P0(); + conn.setAutoCommit(false); + + QueryRunner runner = new QueryRunner(); + for (Object[] params:paramObjectList) { + int count = runner.update(conn, insertStr, params); + if (count > 0) + logger.info("施工作业数据同步成功" + pgConWorkOrderList.toString()); + else + logger.info("施工作业数据同步失败！"); + } + + } catch (Exception ex) { + logger.info("施工作业数据同步异常", ex); + } finally { + try { + DbUtils.commitAndClose(conn); + } catch (SQLException e) { + e.printStackTrace(); + } + } + } + + @Override + public String findLastRecordTime(){ + Connection conn = null; + + String queryStr = "SELECT * FROM PG_CON_WORK_ORDER ORDER BY LOG_DATE DESC"; + try { + conn = ConnectionManager.getConnectionFromC3P0(); + conn.setAutoCommit(false); + + QueryRunner runner = new QueryRunner(); + List pgConWorkOrderList = (List) runner.query(conn, + queryStr, new BeanListHandler(PgConWorkOrder.class)); + + if (null != pgConWorkOrderList && pgConWorkOrderList.isEmpty() == false) { + logger.debug("获取最新施工记录成功[" + pgConWorkOrderList + "]"); + return pgConWorkOrderList.get(0).getLOG_DATE(); + } + else + return null; + } catch (Exception ex) { + logger.error("获取最新施工记录异常", ex); + } finally { + try { + DbUtils.commitAndClose(conn); + } catch (SQLException e) { + e.printStackTrace(); + } + } + return null; + } + +} diff --git a/src/com/szpg/db/data/PgAssetInSpectionPlan.java b/src/com/szpg/db/data/PgAssetInSpectionPlan.java index fd10c61..c86ec88 100644 --- a/src/com/szpg/db/data/PgAssetInSpectionPlan.java +++ b/src/com/szpg/db/data/PgAssetInSpectionPlan.java @@ -103,7 +103,6 @@ this.RESPONSIBLE_DEPT = RESPONSIBLE_DEPT; } - public String getPLAN_NO() { return PLAN_NO; } @@ -312,5 +311,4 @@ this.UPDATEDATE = UPDATEDATE; } - -} +} \ No newline at end of file diff --git a/src/com/szpg/db/data/PgConRemoveMsg.java b/src/com/szpg/db/data/PgConRemoveMsg.java new file mode 100644 index 0000000..6dcbaa0 --- /dev/null +++ b/src/com/szpg/db/data/PgConRemoveMsg.java @@ -0,0 +1,79 @@ +package com.szpg.db.data; + +import java.io.Serializable; + +public class PgConRemoveMsg implements Serializable { + + private String XD_DATE; + private String XD_END_TIME; + private String XD_SUPERVISOR; + private String XD_FIELD_SITUATION; + private String XD_REMARKS; + private String XD_APPROVER; + private String XD_APPROVER_TIME; + private String LOG_DATE; + + public String getXD_DATE() { + return XD_DATE; + } + + public void setXD_DATE(String XD_DATE) { + this.XD_DATE = XD_DATE; + } + + public String getXD_END_TIME() { + return XD_END_TIME; + } + + public void setXD_END_TIME(String XD_END_TIME) { + this.XD_END_TIME = XD_END_TIME; + } + + public String getXD_SUPERVISOR() { + return XD_SUPERVISOR; + } + + public void setXD_SUPERVISOR(String XD_SUPERVISOR) { + this.XD_SUPERVISOR = XD_SUPERVISOR; + } + + public String getXD_FIELD_SITUATION() { + return XD_FIELD_SITUATION; + } + + public void setXD_FIELD_SITUATION(String XD_FIELD_SITUATION) { + this.XD_FIELD_SITUATION = XD_FIELD_SITUATION; + } + + public String getXD_REMARKS() { + return XD_REMARKS; + } + + public void setXD_REMARKS(String XD_REMARKS) { + this.XD_REMARKS = XD_REMARKS; + } + + public String getXD_APPROVER() { + return XD_APPROVER; + } + + public void setXD_APPROVER(String XD_APPROVER) { + this.XD_APPROVER = XD_APPROVER; + } + + public String getXD_APPROVER_TIME() { + return XD_APPROVER_TIME; + } + + public void setXD_APPROVER_TIME(String XD_APPROVER_TIME) { + this.XD_APPROVER_TIME = XD_APPROVER_TIME; + } + + public String getLOG_DATE() { + return LOG_DATE; + } + + public void setLOG_DATE(String LOG_DATE) { + this.LOG_DATE = LOG_DATE; + } +} diff --git a/src/com/szpg/db/data/PgConRemoveMsgJson.java b/src/com/szpg/db/data/PgConRemoveMsgJson.java new file mode 100644 index 0000000..d3253c5 --- /dev/null +++ b/src/com/szpg/db/data/PgConRemoveMsgJson.java @@ -0,0 +1,53 @@ +package com.szpg.db.data; + +import java.util.List; + +public class PgConRemoveMsgJson { + + private String total; + private String totalRecords; + private String page; + private String records; + private List rows; + + public String getTotal() { + return total; + } + + public void setTotal(String total) { + this.total = total; + } + + public String getTotalRecords() { + return totalRecords; + } + + public void setTotalRecords(String totalRecords) { + this.totalRecords = totalRecords; + } + + public String getPage() { + return page; + } + + public void setPage(String page) { + this.page = page; + } + + public String getRecords() { + return records; + } + + public void setRecords(String records) { + this.records = records; + } + + public List getRows() { + return rows; + } + + public void setRows(List rows) { + this.rows = rows; + } + +} \ No newline at end of file diff --git a/src/com/szpg/db/data/PgConRequestMsg.java b/src/com/szpg/db/data/PgConRequestMsg.java new file mode 100644 index 0000000..fddd30a --- /dev/null +++ b/src/com/szpg/db/data/PgConRequestMsg.java @@ -0,0 +1,142 @@ +package com.szpg.db.data; + +import java.io.Serializable; + +public class PgConRequestMsg implements Serializable { + + private String BUILD_TASK_ID;//作业令编号 + private String DATE;//请点日期 + private String TASK_ID;//作业代码 + private String BUILD_COMPANY;//施工单位 + private String SUPERVISOR_TEL;//请点负责人 + private String TEL;//负责人电话 + private String BUILD_PLACE;//请点地点 + private String BUILD_TIME;//请点时间 + private String START_PLACE;//起始位置 + private String END_PLACE;//结束位置 + private String PROJECT;//所属项目 CBL：城北路，CYL：城阳路，THXC:太湖新城 + private String BUILD_CONTENT;//施工内容 + private String APPROVER;//批准人 + private String APPROVER_TIME;//批准时间 + private String LOG_DATE; + + public String getBUILD_TASK_ID() { + return BUILD_TASK_ID; + } + + public void setBUILD_TASK_ID(String BUILD_TASK_ID) { + this.BUILD_TASK_ID = BUILD_TASK_ID; + } + + public String getDATE() { + return DATE; + } + + public void setDATE(String DATE) { + this.DATE = DATE; + } + + public String getTASK_ID() { + return TASK_ID; + } + + public void setTASK_ID(String TASK_ID) { + this.TASK_ID = TASK_ID; + } + + public String getBUILD_COMPANY() { + return BUILD_COMPANY; + } + + public void setBUILD_COMPANY(String BUILD_COMPANY) { + this.BUILD_COMPANY = BUILD_COMPANY; + } + + public String getSUPERVISOR_TEL() { + return SUPERVISOR_TEL; + } + + public void setSUPERVISOR_TEL(String SUPERVISOR_TEL) { + this.SUPERVISOR_TEL = SUPERVISOR_TEL; + } + + public String getTEL() { + return TEL; + } + + public void setTEL(String TEL) { + this.TEL = TEL; + } + + public String getBUILD_PLACE() { + return BUILD_PLACE; + } + + public void setBUILD_PLACE(String BUILD_PLACE) { + this.BUILD_PLACE = BUILD_PLACE; + } + + public String getBUILD_TIME() { + return BUILD_TIME; + } + + public void setBUILD_TIME(String BUILD_TIME) { + this.BUILD_TIME = BUILD_TIME; + } + + public String getSTART_PLACE() { + return START_PLACE; + } + + public void setSTART_PLACE(String START_PLACE) { + this.START_PLACE = START_PLACE; + } + + public String getEND_PLACE() { + return END_PLACE; + } + + public void setEND_PLACE(String END_PLACE) { + this.END_PLACE = END_PLACE; + } + + public String getPROJECT() { + return PROJECT; + } + + public void setPROJECT(String PROJECT) { + this.PROJECT = PROJECT; + } + + public String getBUILD_CONTENT() { + return BUILD_CONTENT; + } + + public void setBUILD_CONTENT(String BUILD_CONTENT) { + this.BUILD_CONTENT = BUILD_CONTENT; + } + + public String getAPPROVER() { + return APPROVER; + } + + public void setAPPROVER(String APPROVER) { + this.APPROVER = APPROVER; + } + + public String getAPPROVER_TIME() { + return APPROVER_TIME; + } + + public void setAPPROVER_TIME(String APPROVER_TIME) { + this.APPROVER_TIME = APPROVER_TIME; + } + + public String getLOG_DATE() { + return LOG_DATE; + } + + public void setLOG_DATE(String LOG_DATE) { + this.LOG_DATE = LOG_DATE; + } +} diff --git a/.idea/workspace.xml b/.idea/workspace.xml new file mode 100644 index 0000000..e15ca50 --- /dev/null +++ b/.idea/workspace.xml @@ -0,0 +1,849 @@ + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + 未能连接到 + yy-mm-d + + + + + + + + + + + true + DEFINITION_ORDER + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + 1567762862031 + + + 1568000184886 + + + 1568100549456 + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + pgdsc + + + + + + + + Web (pgdsc)|Web + + + + + + + + + + + + + + + 1.8 + + + + + + + + pgdsc + + + + + + + + json + + + + + + + + \ No newline at end of file diff --git a/src/com/szpg/db/dao/PgConRemoveDao.java b/src/com/szpg/db/dao/PgConRemoveDao.java new file mode 100644 index 0000000..49903fc --- /dev/null +++ b/src/com/szpg/db/dao/PgConRemoveDao.java @@ -0,0 +1,14 @@ +package com.szpg.db.dao; + +import com.szpg.db.data.PgConRemoveMsg; +import com.szpg.db.data.PgConWorkOrder; + +import java.util.List; + +public interface PgConRemoveDao { + + public void addConRemove(List pgConRemoveMsgList); + + public String findLastRecordTime(); + +} diff --git a/src/com/szpg/db/dao/PgConRequestMsgDao.java b/src/com/szpg/db/dao/PgConRequestMsgDao.java new file mode 100644 index 0000000..274f5a6 --- /dev/null +++ b/src/com/szpg/db/dao/PgConRequestMsgDao.java @@ -0,0 +1,13 @@ +package com.szpg.db.dao; + +import com.szpg.db.data.PgConRequestMsg; +import com.szpg.db.data.PgConWorkOrder; + +import java.util.List; + +public interface PgConRequestMsgDao { + + public void addConRequestMsg(List pgConRequestMsgList); + + public String findLastRecordTime(); +} diff --git a/src/com/szpg/db/dao/PgConWorkOrderDao.java b/src/com/szpg/db/dao/PgConWorkOrderDao.java new file mode 100644 index 0000000..ad2c4ae --- /dev/null +++ b/src/com/szpg/db/dao/PgConWorkOrderDao.java @@ -0,0 +1,12 @@ +package com.szpg.db.dao; + + import com.szpg.db.data.PgConWorkOrder; + + import java.util.List; + +public interface PgConWorkOrderDao { + + public void addConWorkerOrder(List pgConWorkOrderList); + + public String findLastRecordTime(); +} diff --git a/src/com/szpg/db/dao/impl/PgAssetInSpectionImpl.java b/src/com/szpg/db/dao/impl/PgAssetInSpectionImpl.java index 2383707..de88d3b 100644 --- a/src/com/szpg/db/dao/impl/PgAssetInSpectionImpl.java +++ b/src/com/szpg/db/dao/impl/PgAssetInSpectionImpl.java @@ -28,47 +28,48 @@ "END_TIME,START_PILE_NO,END_PILE_NO,BUILD_CABIN,MILEAGE,FREQUENCY_TIME,FREQUENCYTIME_END,KETTLE_TS,UPDATEDATE) " + "VALUES (?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?)"; - List paramObjectList=new ArrayList(); + List paramObjectList=new ArrayList<>(); for(PgAssetInSpectionPlan pgAssetInSpectionPlan:pgAssetInSpectionPlanList){ + + if(!pgAssetInSpectionPlan.getPLAN_NAME().contains("吴中太湖新城")) continue; Object[] params = new Object[34]; params[0] = pgAssetInSpectionPlan.getKEY_ID(); params[1] = pgAssetInSpectionPlan.getPLAN_NAME(); params[2] = pgAssetInSpectionPlan.getINSPECTION_PERSON(); params[3] = pgAssetInSpectionPlan.getSTART_DATE(); - params[4]=pgAssetInSpectionPlan.getEND_DATE(); - params[5]=pgAssetInSpectionPlan.getFREQUENCY(); - params[6]=pgAssetInSpectionPlan.getSTATE(); - params[7]=pgAssetInSpectionPlan.getRESPONSIBLE_DEPT(); - params[8]=pgAssetInSpectionPlan.getPLAN_NO(); - params[9]=pgAssetInSpectionPlan.getINSPECTION_TYPE(); - params[10]=pgAssetInSpectionPlan.getINSPECTION_MODE(); - params[11]=pgAssetInSpectionPlan.getINSPECTION_ROUTE(); - params[12]=pgAssetInSpectionPlan.getINSPECTION_START_TIME(); - params[13]=pgAssetInSpectionPlan.getINSPECTION_END_TIME(); - params[14]=pgAssetInSpectionPlan.getINSPECTION_PRACE(); - params[15]=pgAssetInSpectionPlan.getINSPECTION_GROUP(); - params[16]=pgAssetInSpectionPlan.getINSERT_TIME(); - params[17]=pgAssetInSpectionPlan.getFREQUENCYDATE(); - params[18]=pgAssetInSpectionPlan.getFREQUENCYTIME(); - params[19]=pgAssetInSpectionPlan.getCREATEDATE(); - params[20]=pgAssetInSpectionPlan.getCREATOR(); - params[21]=pgAssetInSpectionPlan.getPROJECT(); - params[22]=pgAssetInSpectionPlan.getCOMLILE(); - params[23]=pgAssetInSpectionPlan.getSTART_TIME(); - params[24]=pgAssetInSpectionPlan.getDEVELOP_DEPT(); - params[25]=pgAssetInSpectionPlan.getEND_TIME(); - params[26]=pgAssetInSpectionPlan.getSTART_PILE_NO(); - params[27]=pgAssetInSpectionPlan.getEND_PILE_NO(); - params[28]=pgAssetInSpectionPlan.getBUILD_CABIN(); - params[29]=pgAssetInSpectionPlan.getMILEAGE(); - params[30]=pgAssetInSpectionPlan.getFREQUENCY_TIME(); - params[31]=pgAssetInSpectionPlan.getFREQUENCYTIME_END(); - params[32]=pgAssetInSpectionPlan.getKETTLE_TS(); - params[33]=pgAssetInSpectionPlan.getUPDATEDATE(); + params[4] = pgAssetInSpectionPlan.getEND_DATE(); + params[5] = pgAssetInSpectionPlan.getFREQUENCY(); + params[6] = pgAssetInSpectionPlan.getSTATE(); + params[7] = pgAssetInSpectionPlan.getRESPONSIBLE_DEPT(); + params[8] = pgAssetInSpectionPlan.getPLAN_NO(); + params[9] = pgAssetInSpectionPlan.getINSPECTION_TYPE(); + params[10] = pgAssetInSpectionPlan.getINSPECTION_MODE(); + params[11] = pgAssetInSpectionPlan.getINSPECTION_ROUTE(); + params[12] = pgAssetInSpectionPlan.getINSPECTION_START_TIME(); + params[13] = pgAssetInSpectionPlan.getINSPECTION_END_TIME(); + params[14] = pgAssetInSpectionPlan.getINSPECTION_PRACE(); + params[15] = pgAssetInSpectionPlan.getINSPECTION_GROUP(); + params[16] = pgAssetInSpectionPlan.getINSERT_TIME(); + params[17] = pgAssetInSpectionPlan.getFREQUENCYDATE(); + params[18] = pgAssetInSpectionPlan.getFREQUENCYTIME(); + params[19] = pgAssetInSpectionPlan.getCREATEDATE(); + params[20] = pgAssetInSpectionPlan.getCREATOR(); + params[21] = pgAssetInSpectionPlan.getPROJECT(); + params[22] = pgAssetInSpectionPlan.getCOMLILE(); + params[23] = pgAssetInSpectionPlan.getSTART_TIME(); + params[24] = pgAssetInSpectionPlan.getDEVELOP_DEPT(); + params[25] = pgAssetInSpectionPlan.getEND_TIME(); + params[26] = pgAssetInSpectionPlan.getSTART_PILE_NO(); + params[27] = pgAssetInSpectionPlan.getEND_PILE_NO(); + params[28] = pgAssetInSpectionPlan.getBUILD_CABIN(); + params[29] = pgAssetInSpectionPlan.getMILEAGE(); + params[30] = pgAssetInSpectionPlan.getFREQUENCY_TIME(); + params[31] = pgAssetInSpectionPlan.getFREQUENCYTIME_END(); + params[32] = pgAssetInSpectionPlan.getKETTLE_TS(); + params[33] = pgAssetInSpectionPlan.getUPDATEDATE(); paramObjectList.add(params); } - try { conn = ConnectionManager.getConnectionFromC3P0(); conn.setAutoCommit(false); diff --git a/src/com/szpg/db/dao/impl/PgConRemoveDaoImp.java b/src/com/szpg/db/dao/impl/PgConRemoveDaoImp.java new file mode 100644 index 0000000..510020e --- /dev/null +++ b/src/com/szpg/db/dao/impl/PgConRemoveDaoImp.java @@ -0,0 +1,98 @@ +package com.szpg.db.dao.impl; + +import com.szpg.db.dao.PgConRemoveDao; +import com.szpg.db.data.PgConRemoveMsg; +import com.szpg.db.util.ConnectionManager; +import org.apache.commons.dbutils.DbUtils; +import org.apache.commons.dbutils.QueryRunner; +import org.apache.commons.dbutils.handlers.BeanListHandler; +import org.apache.log4j.Logger; + +import java.sql.Connection; +import java.sql.SQLException; +import java.util.ArrayList; +import java.util.List; + +public class PgConRemoveDaoImp implements PgConRemoveDao { + + private org.apache.log4j.Logger logger = Logger.getLogger(this.getClass().getName()); + + @Override + public void addConRemove(List pgConRemoveMsgList){ + Connection conn = null; + + String insertStr = "INSERT INTO PG_CON_REMOVE_MSG " + + "(XD_DATE, XD_END_TIME, XD_SUPERVISOR,XD_FIELD_SITUATION,XD_REMARKS,XD_APPROVER,XD_APPROVER_TIME,LOG_DATE)" + + "VALUES (?,?,?,?,?,?,?,?)"; + + List paramObjectList=new ArrayList<>(); + for(PgConRemoveMsg pgConRemoveMsg:pgConRemoveMsgList){ + + Object[] params = new Object[34]; + params[0] = pgConRemoveMsg.getXD_DATE(); + params[1] = pgConRemoveMsg.getXD_END_TIME(); + params[2] = pgConRemoveMsg.getXD_SUPERVISOR(); + params[3] = pgConRemoveMsg.getXD_FIELD_SITUATION(); + params[4] = pgConRemoveMsg.getXD_REMARKS(); + params[5] = pgConRemoveMsg.getXD_APPROVER(); + params[6] = pgConRemoveMsg.getXD_APPROVER_TIME(); + params[7] = pgConRemoveMsg.getLOG_DATE(); + + paramObjectList.add(params); + } + try { + conn = ConnectionManager.getConnectionFromC3P0(); + conn.setAutoCommit(false); + + QueryRunner runner = new QueryRunner(); + for (Object[] params:paramObjectList) { + int count = runner.update(conn, insertStr, params); + if (count > 0) + logger.info("施工消点数据同步成功" + pgConRemoveMsgList.toString()); + else + logger.info("施工消点数据同步失败！"); + } + + } catch (Exception ex) { + logger.info("施工作业数据同步异常", ex); + } finally { + try { + DbUtils.commitAndClose(conn); + } catch (SQLException e) { + e.printStackTrace(); + } + } + } + + @Override + public String findLastRecordTime(){ + Connection conn = null; + + String queryStr = "SELECT * FROM PG_CON_REMOVE_MSG ORDER BY LOG_DATE DESC"; + try { + conn = ConnectionManager.getConnectionFromC3P0(); + conn.setAutoCommit(false); + + QueryRunner runner = new QueryRunner(); + List pgConRemoveMsgList = (List) runner.query(conn, + queryStr, new BeanListHandler(PgConRemoveMsg.class)); + + if (null != pgConRemoveMsgList && pgConRemoveMsgList.isEmpty() == false) { + logger.debug("获取最新施工消点记录成功[" + pgConRemoveMsgList + "]"); + return pgConRemoveMsgList.get(0).getLOG_DATE(); + } + else + return null; + } catch (Exception ex) { + logger.error("获取最新施工消点记录异常", ex); + } finally { + try { + DbUtils.commitAndClose(conn); + } catch (SQLException e) { + e.printStackTrace(); + } + } + return null; + } + +} diff --git a/src/com/szpg/db/dao/impl/PgConRequestMsgDaoImp.java b/src/com/szpg/db/dao/impl/PgConRequestMsgDaoImp.java new file mode 100644 index 0000000..d763e19 --- /dev/null +++ b/src/com/szpg/db/dao/impl/PgConRequestMsgDaoImp.java @@ -0,0 +1,108 @@ +package com.szpg.db.dao.impl; + +import com.szpg.db.dao.PgConRequestMsgDao; +import com.szpg.db.data.PgConRequestMsg; +import com.szpg.db.data.PgConWorkOrder; +import com.szpg.db.util.ConnectionManager; +import org.apache.commons.dbutils.DbUtils; +import org.apache.commons.dbutils.QueryRunner; +import org.apache.commons.dbutils.handlers.BeanListHandler; +import org.apache.log4j.Logger; + +import java.sql.Connection; +import java.sql.SQLException; +import java.util.ArrayList; +import java.util.Date; +import java.util.List; + +public class PgConRequestMsgDaoImp implements PgConRequestMsgDao { + + private org.apache.log4j.Logger logger = Logger.getLogger(this.getClass().getName()); + + @Override + public void addConRequestMsg(List pgConRequestMsgList){ + Connection conn = null; + + String insertStr = "INSERT INTO PG_CON_REQUEST_MSG " + + "(BUILD_TASK_ID, DATE, TASK_ID,BUILD_COMPANY,SUPERVISOR_TEL,TEL,BUILD_PLACE,BUILD_TIME,START_PLACE," + + "END_PLACE,PROJECT,BUILD_CONTENT,APPROVER,APPROVER_TIME,LOG_DATE)" + + "VALUES (?,?,?,?,?,?,?,?,?,?,?,?,?,?,?)"; + + List paramObjectList=new ArrayList<>(); + for(PgConRequestMsg pgConRequestMsg:pgConRequestMsgList){ + + Object[] params = new Object[34]; + params[0] = pgConRequestMsg.getBUILD_TASK_ID(); + params[1] = pgConRequestMsg.getDATE(); + params[2] = pgConRequestMsg.getTASK_ID(); + params[3] = pgConRequestMsg.getBUILD_COMPANY(); + params[4] = pgConRequestMsg.getSUPERVISOR_TEL(); + params[5] = pgConRequestMsg.getTEL(); + params[6] = pgConRequestMsg.getBUILD_PLACE(); + params[7] = pgConRequestMsg.getBUILD_TIME(); + params[8] = pgConRequestMsg.getSTART_PLACE(); + params[9] = pgConRequestMsg.getEND_PLACE(); + params[10] = pgConRequestMsg.getPROJECT(); + params[11] = pgConRequestMsg.getBUILD_CONTENT(); + params[12] = pgConRequestMsg.getAPPROVER(); + params[13] = pgConRequestMsg.getAPPROVER_TIME(); + params[14] = pgConRequestMsg.getLOG_DATE(); + + paramObjectList.add(params); + } + try { + conn = ConnectionManager.getConnectionFromC3P0(); + conn.setAutoCommit(false); + + QueryRunner runner = new QueryRunner(); + for (Object[] params:paramObjectList) { + int count = runner.update(conn, insertStr, params); + if (count > 0) + logger.info("施工请点数据同步成功" + pgConRequestMsgList.toString()); + else + logger.info("施工请点数据同步失败！"); + } + + } catch (Exception ex) { + logger.info("施工请点数据同步异常", ex); + } finally { + try { + DbUtils.commitAndClose(conn); + } catch (SQLException e) { + e.printStackTrace(); + } + } + } + + @Override + public String findLastRecordTime(){ + Connection conn = null; + + String queryStr = "SELECT * FROM PG_CON_REQUEST_MSG ORDER BY LOG_DATE DESC"; + try { + conn = ConnectionManager.getConnectionFromC3P0(); + conn.setAutoCommit(false); + + QueryRunner runner = new QueryRunner(); + List pgConRequestMsgList = (List) runner.query(conn, + queryStr, new BeanListHandler(PgConRequestMsg.class)); + + if (null != pgConRequestMsgList && pgConRequestMsgList.isEmpty() == false) { + logger.debug("获取最新施工请点记录成功[" + pgConRequestMsgList + "]"); + return pgConRequestMsgList.get(0).getLOG_DATE(); + } + else + return null; + } catch (Exception ex) { + logger.error("获取最新施工请点记录异常", ex); + } finally { + try { + DbUtils.commitAndClose(conn); + } catch (SQLException e) { + e.printStackTrace(); + } + } + return null; + } + +} diff --git a/src/com/szpg/db/dao/impl/PgConWorkOrderDaoImp.java b/src/com/szpg/db/dao/impl/PgConWorkOrderDaoImp.java new file mode 100644 index 0000000..98e2a66 --- /dev/null +++ b/src/com/szpg/db/dao/impl/PgConWorkOrderDaoImp.java @@ -0,0 +1,116 @@ +package com.szpg.db.dao.impl; + +import com.szpg.db.dao.PgConWorkOrderDao; +import com.szpg.db.data.PgAssetInSpectionPlan; +import com.szpg.db.data.PgConWorkOrder; +import com.szpg.db.util.ConnectionManager; +import freemarker.template.utility.DateUtil; +import org.apache.commons.dbutils.DbUtils; +import org.apache.commons.dbutils.QueryRunner; +import org.apache.commons.dbutils.handlers.BeanListHandler; +import org.apache.log4j.Logger; + +import java.sql.Connection; +import java.sql.SQLException; +import java.util.ArrayList; +import java.util.Date; +import java.util.List; + +public class PgConWorkOrderDaoImp implements PgConWorkOrderDao { + + private org.apache.log4j.Logger logger = Logger.getLogger(this.getClass().getName()); + + @Override + public void addConWorkerOrder(List pgConWorkOrderList){ + Connection conn = null; + + String insertStr = "INSERT INTO PG_CON_WORK_ORDER " + + "(KEY_ID, PLAN_NO, TASK_COMPANY,TASK_ID,SUPERVISOR,SUPERVISOR_PHONE,APPLCIANT,APPLCIANT_PHONE,TASK_NAME," + + "TASK_PLACE,TASK_DATE,TASK_DATE_END,PROJECT,TASK_CONTENT,TASK_SAFETY_MEASURES," + + "TASK_PEOPLE_NUM,TASK_INFLUENCE,COMPLETION_OF_THE_SITUATION,REMARKS,BUILD_STATE,LOG_DATE)" + + "VALUES (?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?)"; + + List paramObjectList=new ArrayList<>(); + for(PgConWorkOrder pgConWorkOrder:pgConWorkOrderList){ + + Object[] params = new Object[34]; + params[0] = pgConWorkOrder.getKEY_ID(); + params[1] = pgConWorkOrder.getPLAN_NO(); + params[2] = pgConWorkOrder.getTASK_COMPANY(); + params[3] = pgConWorkOrder.getTASK_ID(); + params[4] = pgConWorkOrder.getSUPERVISOR(); + params[5] = pgConWorkOrder.getSUPERVISOR_PHONE(); + params[6] = pgConWorkOrder.getAPPLCIANT(); + params[7] = pgConWorkOrder.getAPPLCIANT_PHONE(); + params[8] = pgConWorkOrder.getTASK_NAME(); + params[9] = pgConWorkOrder.getTASK_PLACE(); + params[10] = pgConWorkOrder.getTASK_DATE(); + params[11] = pgConWorkOrder.getTASK_DATE_END(); + params[12] = pgConWorkOrder.getPROJECT(); + params[13] = pgConWorkOrder.getTASK_CONTENT(); + params[14] = pgConWorkOrder.getTASK_SAFETY_MEASURES(); + params[15] = pgConWorkOrder.getTASK_PEOPLE_NUM(); + params[16] = pgConWorkOrder.getTASK_INFLUENCE(); + params[17] = pgConWorkOrder.getCOMPLETION_OF_THE_SITUATION(); + params[18] = pgConWorkOrder.getREMARKS(); + params[19] = pgConWorkOrder.getBUILD_STATE(); + params[19] = new Date(); + + paramObjectList.add(params); + } + try { + conn = ConnectionManager.getConnectionFromC3P0(); + conn.setAutoCommit(false); + + QueryRunner runner = new QueryRunner(); + for (Object[] params:paramObjectList) { + int count = runner.update(conn, insertStr, params); + if (count > 0) + logger.info("施工作业数据同步成功" + pgConWorkOrderList.toString()); + else + logger.info("施工作业数据同步失败！"); + } + + } catch (Exception ex) { + logger.info("施工作业数据同步异常", ex); + } finally { + try { + DbUtils.commitAndClose(conn); + } catch (SQLException e) { + e.printStackTrace(); + } + } + } + + @Override + public String findLastRecordTime(){ + Connection conn = null; + + String queryStr = "SELECT * FROM PG_CON_WORK_ORDER ORDER BY LOG_DATE DESC"; + try { + conn = ConnectionManager.getConnectionFromC3P0(); + conn.setAutoCommit(false); + + QueryRunner runner = new QueryRunner(); + List pgConWorkOrderList = (List) runner.query(conn, + queryStr, new BeanListHandler(PgConWorkOrder.class)); + + if (null != pgConWorkOrderList && pgConWorkOrderList.isEmpty() == false) { + logger.debug("获取最新施工记录成功[" + pgConWorkOrderList + "]"); + return pgConWorkOrderList.get(0).getLOG_DATE(); + } + else + return null; + } catch (Exception ex) { + logger.error("获取最新施工记录异常", ex); + } finally { + try { + DbUtils.commitAndClose(conn); + } catch (SQLException e) { + e.printStackTrace(); + } + } + return null; + } + +} diff --git a/src/com/szpg/db/data/PgAssetInSpectionPlan.java b/src/com/szpg/db/data/PgAssetInSpectionPlan.java index fd10c61..c86ec88 100644 --- a/src/com/szpg/db/data/PgAssetInSpectionPlan.java +++ b/src/com/szpg/db/data/PgAssetInSpectionPlan.java @@ -103,7 +103,6 @@ this.RESPONSIBLE_DEPT = RESPONSIBLE_DEPT; } - public String getPLAN_NO() { return PLAN_NO; } @@ -312,5 +311,4 @@ this.UPDATEDATE = UPDATEDATE; } - -} +} \ No newline at end of file diff --git a/src/com/szpg/db/data/PgConRemoveMsg.java b/src/com/szpg/db/data/PgConRemoveMsg.java new file mode 100644 index 0000000..6dcbaa0 --- /dev/null +++ b/src/com/szpg/db/data/PgConRemoveMsg.java @@ -0,0 +1,79 @@ +package com.szpg.db.data; + +import java.io.Serializable; + +public class PgConRemoveMsg implements Serializable { + + private String XD_DATE; + private String XD_END_TIME; + private String XD_SUPERVISOR; + private String XD_FIELD_SITUATION; + private String XD_REMARKS; + private String XD_APPROVER; + private String XD_APPROVER_TIME; + private String LOG_DATE; + + public String getXD_DATE() { + return XD_DATE; + } + + public void setXD_DATE(String XD_DATE) { + this.XD_DATE = XD_DATE; + } + + public String getXD_END_TIME() { + return XD_END_TIME; + } + + public void setXD_END_TIME(String XD_END_TIME) { + this.XD_END_TIME = XD_END_TIME; + } + + public String getXD_SUPERVISOR() { + return XD_SUPERVISOR; + } + + public void setXD_SUPERVISOR(String XD_SUPERVISOR) { + this.XD_SUPERVISOR = XD_SUPERVISOR; + } + + public String getXD_FIELD_SITUATION() { + return XD_FIELD_SITUATION; + } + + public void setXD_FIELD_SITUATION(String XD_FIELD_SITUATION) { + this.XD_FIELD_SITUATION = XD_FIELD_SITUATION; + } + + public String getXD_REMARKS() { + return XD_REMARKS; + } + + public void setXD_REMARKS(String XD_REMARKS) { + this.XD_REMARKS = XD_REMARKS; + } + + public String getXD_APPROVER() { + return XD_APPROVER; + } + + public void setXD_APPROVER(String XD_APPROVER) { + this.XD_APPROVER = XD_APPROVER; + } + + public String getXD_APPROVER_TIME() { + return XD_APPROVER_TIME; + } + + public void setXD_APPROVER_TIME(String XD_APPROVER_TIME) { + this.XD_APPROVER_TIME = XD_APPROVER_TIME; + } + + public String getLOG_DATE() { + return LOG_DATE; + } + + public void setLOG_DATE(String LOG_DATE) { + this.LOG_DATE = LOG_DATE; + } +} diff --git a/src/com/szpg/db/data/PgConRemoveMsgJson.java b/src/com/szpg/db/data/PgConRemoveMsgJson.java new file mode 100644 index 0000000..d3253c5 --- /dev/null +++ b/src/com/szpg/db/data/PgConRemoveMsgJson.java @@ -0,0 +1,53 @@ +package com.szpg.db.data; + +import java.util.List; + +public class PgConRemoveMsgJson { + + private String total; + private String totalRecords; + private String page; + private String records; + private List rows; + + public String getTotal() { + return total; + } + + public void setTotal(String total) { + this.total = total; + } + + public String getTotalRecords() { + return totalRecords; + } + + public void setTotalRecords(String totalRecords) { + this.totalRecords = totalRecords; + } + + public String getPage() { + return page; + } + + public void setPage(String page) { + this.page = page; + } + + public String getRecords() { + return records; + } + + public void setRecords(String records) { + this.records = records; + } + + public List getRows() { + return rows; + } + + public void setRows(List rows) { + this.rows = rows; + } + +} \ No newline at end of file diff --git a/src/com/szpg/db/data/PgConRequestMsg.java b/src/com/szpg/db/data/PgConRequestMsg.java new file mode 100644 index 0000000..fddd30a --- /dev/null +++ b/src/com/szpg/db/data/PgConRequestMsg.java @@ -0,0 +1,142 @@ +package com.szpg.db.data; + +import java.io.Serializable; + +public class PgConRequestMsg implements Serializable { + + private String BUILD_TASK_ID;//作业令编号 + private String DATE;//请点日期 + private String TASK_ID;//作业代码 + private String BUILD_COMPANY;//施工单位 + private String SUPERVISOR_TEL;//请点负责人 + private String TEL;//负责人电话 + private String BUILD_PLACE;//请点地点 + private String BUILD_TIME;//请点时间 + private String START_PLACE;//起始位置 + private String END_PLACE;//结束位置 + private String PROJECT;//所属项目 CBL：城北路，CYL：城阳路，THXC:太湖新城 + private String BUILD_CONTENT;//施工内容 + private String APPROVER;//批准人 + private String APPROVER_TIME;//批准时间 + private String LOG_DATE; + + public String getBUILD_TASK_ID() { + return BUILD_TASK_ID; + } + + public void setBUILD_TASK_ID(String BUILD_TASK_ID) { + this.BUILD_TASK_ID = BUILD_TASK_ID; + } + + public String getDATE() { + return DATE; + } + + public void setDATE(String DATE) { + this.DATE = DATE; + } + + public String getTASK_ID() { + return TASK_ID; + } + + public void setTASK_ID(String TASK_ID) { + this.TASK_ID = TASK_ID; + } + + public String getBUILD_COMPANY() { + return BUILD_COMPANY; + } + + public void setBUILD_COMPANY(String BUILD_COMPANY) { + this.BUILD_COMPANY = BUILD_COMPANY; + } + + public String getSUPERVISOR_TEL() { + return SUPERVISOR_TEL; + } + + public void setSUPERVISOR_TEL(String SUPERVISOR_TEL) { + this.SUPERVISOR_TEL = SUPERVISOR_TEL; + } + + public String getTEL() { + return TEL; + } + + public void setTEL(String TEL) { + this.TEL = TEL; + } + + public String getBUILD_PLACE() { + return BUILD_PLACE; + } + + public void setBUILD_PLACE(String BUILD_PLACE) { + this.BUILD_PLACE = BUILD_PLACE; + } + + public String getBUILD_TIME() { + return BUILD_TIME; + } + + public void setBUILD_TIME(String BUILD_TIME) { + this.BUILD_TIME = BUILD_TIME; + } + + public String getSTART_PLACE() { + return START_PLACE; + } + + public void setSTART_PLACE(String START_PLACE) { + this.START_PLACE = START_PLACE; + } + + public String getEND_PLACE() { + return END_PLACE; + } + + public void setEND_PLACE(String END_PLACE) { + this.END_PLACE = END_PLACE; + } + + public String getPROJECT() { + return PROJECT; + } + + public void setPROJECT(String PROJECT) { + this.PROJECT = PROJECT; + } + + public String getBUILD_CONTENT() { + return BUILD_CONTENT; + } + + public void setBUILD_CONTENT(String BUILD_CONTENT) { + this.BUILD_CONTENT = BUILD_CONTENT; + } + + public String getAPPROVER() { + return APPROVER; + } + + public void setAPPROVER(String APPROVER) { + this.APPROVER = APPROVER; + } + + public String getAPPROVER_TIME() { + return APPROVER_TIME; + } + + public void setAPPROVER_TIME(String APPROVER_TIME) { + this.APPROVER_TIME = APPROVER_TIME; + } + + public String getLOG_DATE() { + return LOG_DATE; + } + + public void setLOG_DATE(String LOG_DATE) { + this.LOG_DATE = LOG_DATE; + } +} diff --git a/src/com/szpg/db/data/PgConRequestMsgJson.java b/src/com/szpg/db/data/PgConRequestMsgJson.java new file mode 100644 index 0000000..29ab61f --- /dev/null +++ b/src/com/szpg/db/data/PgConRequestMsgJson.java @@ -0,0 +1,52 @@ +package com.szpg.db.data; + +import java.util.List; + +public class PgConRequestMsgJson { + + private String total; + private String totalRecords; + private String page; + private String records; + private List rows; + + public String getTotal() { + return total; + } + + public void setTotal(String total) { + this.total = total; + } + + public String getTotalRecords() { + return totalRecords; + } + + public void setTotalRecords(String totalRecords) { + this.totalRecords = totalRecords; + } + + public String getPage() { + return page; + } + + public void setPage(String page) { + this.page = page; + } + + public String getRecords() { + return records; + } + + public void setRecords(String records) { + this.records = records; + } + + public List getRows() { + return rows; + } + + public void setRows(List rows) { + this.rows = rows; + } +} diff --git a/src/com/szpg/db/data/PgConWorkOrder.java b/src/com/szpg/db/data/PgConWorkOrder.java new file mode 100644 index 0000000..7e39c59 --- /dev/null +++ b/src/com/szpg/db/data/PgConWorkOrder.java @@ -0,0 +1,196 @@ +package com.szpg.db.data; + +import java.io.Serializable; + +public class PgConWorkOrder implements Serializable { + + private String KEY_ID;//GUID字段 + private String PLAN_NO;//计划申请单号 + private String TASK_COMPANY;//作业单位 + private String TASK_ID;//作业编号 + private String SUPERVISOR;//负责人 + private String SUPERVISOR_PHONE;//负责人联系方式 + private String APPLCIANT;//申报人 + private String APPLCIANT_PHONE;//申报人联系方式 + private String TASK_NAME;//作业名称 + private String TASK_PLACE;//作业区域 + private String TASK_DATE;//作业开始日期 + private String TASK_DATE_END;//作业结束日期 + private String PROJECT;//所属项目 CBL：城北路，CYL：城阳路，THXC:太湖新城 + private String TASK_CONTENT;//作业内容 + private String TASK_SAFETY_MEASURES;//作业安全措施 + private String TASK_PEOPLE_NUM;//人数及施工人员 + private String TASK_INFLUENCE;//施工影响 1：A类，2：B类，3：C类 + private String COMPLETION_OF_THE_SITUATION;//完成情况 + private String REMARKS;//备注 + private String BUILD_STATE;//施工状态 申请=1，进入=2，延期=3，验收=4 + private String LOG_DATE; + + public String getKEY_ID() { + return KEY_ID; + } + + public void setKEY_ID(String KEY_ID) { + this.KEY_ID = KEY_ID; + } + + public String getPLAN_NO() { + return PLAN_NO; + } + + public void setPLAN_NO(String PLAN_NO) { + this.PLAN_NO = PLAN_NO; + } + + public String getTASK_COMPANY() { + return TASK_COMPANY; + } + + public void setTASK_COMPANY(String TASK_COMPANY) { + this.TASK_COMPANY = TASK_COMPANY; + } + + public String getTASK_ID() { + return TASK_ID; + } + + public void setTASK_ID(String TASK_ID) { + this.TASK_ID = TASK_ID; + } + + public String getSUPERVISOR() { + return SUPERVISOR; + } + + public void setSUPERVISOR(String SUPERVISOR) { + this.SUPERVISOR = SUPERVISOR; + } + + public String getSUPERVISOR_PHONE() { + return SUPERVISOR_PHONE; + } + + public void setSUPERVISOR_PHONE(String SUPERVISOR_PHONE) { + this.SUPERVISOR_PHONE = SUPERVISOR_PHONE; + } + + public String getAPPLCIANT() { + return APPLCIANT; + } + + public void setAPPLCIANT(String APPLCIANT) { + this.APPLCIANT = APPLCIANT; + } + + public String getAPPLCIANT_PHONE() { + return APPLCIANT_PHONE; + } + + public void setAPPLCIANT_PHONE(String APPLCIANT_PHONE) { + this.APPLCIANT_PHONE = APPLCIANT_PHONE; + } + + public String getTASK_NAME() { + return TASK_NAME; + } + + public void setTASK_NAME(String TASK_NAME) { + this.TASK_NAME = TASK_NAME; + } + + public String getTASK_PLACE() { + return TASK_PLACE; + } + + public void setTASK_PLACE(String TASK_PLACE) { + this.TASK_PLACE = TASK_PLACE; + } + + public String getTASK_DATE() { + return TASK_DATE; + } + + public void setTASK_DATE(String TASK_DATE) { + this.TASK_DATE = TASK_DATE; + } + + public String getTASK_DATE_END() { + return TASK_DATE_END; + } + + public void setTASK_DATE_END(String TASK_DATE_END) { + this.TASK_DATE_END = TASK_DATE_END; + } + + public String getPROJECT() { + return PROJECT; + } + + public void setPROJECT(String PROJECT) { + this.PROJECT = PROJECT; + } + + public String getTASK_CONTENT() { + return TASK_CONTENT; + } + + public void setTASK_CONTENT(String TASK_CONTENT) { + this.TASK_CONTENT = TASK_CONTENT; + } + + public String getTASK_SAFETY_MEASURES() { + return TASK_SAFETY_MEASURES; + } + + public void setTASK_SAFETY_MEASURES(String TASK_SAFETY_MEASURES) { + this.TASK_SAFETY_MEASURES = TASK_SAFETY_MEASURES; + } + + public String getTASK_PEOPLE_NUM() { + return TASK_PEOPLE_NUM; + } + + public void setTASK_PEOPLE_NUM(String TASK_PEOPLE_NUM) { + this.TASK_PEOPLE_NUM = TASK_PEOPLE_NUM; + } + + public String getTASK_INFLUENCE() { + return TASK_INFLUENCE; + } + + public void setTASK_INFLUENCE(String TASK_INFLUENCE) { + this.TASK_INFLUENCE = TASK_INFLUENCE; + } + + public String getCOMPLETION_OF_THE_SITUATION() { + return COMPLETION_OF_THE_SITUATION; + } + + public void setCOMPLETION_OF_THE_SITUATION(String COMPLETION_OF_THE_SITUATION) { + this.COMPLETION_OF_THE_SITUATION = COMPLETION_OF_THE_SITUATION; + } + + public String getREMARKS() { + return REMARKS; + } + + public void setREMARKS(String REMARKS) { + this.REMARKS = REMARKS; + } + + public String getBUILD_STATE() { + return BUILD_STATE; + } + + public void setBUILD_STATE(String BUILD_STATE) { + this.BUILD_STATE = BUILD_STATE; + } + + public String getLOG_DATE() { + return LOG_DATE; + } + + public void setLOG_DATE(String LOG_DATE) { + this.LOG_DATE = LOG_DATE; + } +} \ No newline at end of file diff --git a/.idea/workspace.xml b/.idea/workspace.xml new file mode 100644 index 0000000..e15ca50 --- /dev/null +++ b/.idea/workspace.xml @@ -0,0 +1,849 @@ + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + 未能连接到 + yy-mm-d + + + + + + + + + + + true + DEFINITION_ORDER + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + 1567762862031 + + + 1568000184886 + + + 1568100549456 + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + pgdsc + + + + + + + + Web (pgdsc)|Web + + + + + + + + + + + + + + + 1.8 + + + + + + + + pgdsc + + + + + + + + json + + + + + + + + \ No newline at end of file diff --git a/src/com/szpg/db/dao/PgConRemoveDao.java b/src/com/szpg/db/dao/PgConRemoveDao.java new file mode 100644 index 0000000..49903fc --- /dev/null +++ b/src/com/szpg/db/dao/PgConRemoveDao.java @@ -0,0 +1,14 @@ +package com.szpg.db.dao; + +import com.szpg.db.data.PgConRemoveMsg; +import com.szpg.db.data.PgConWorkOrder; + +import java.util.List; + +public interface PgConRemoveDao { + + public void addConRemove(List pgConRemoveMsgList); + + public String findLastRecordTime(); + +} diff --git a/src/com/szpg/db/dao/PgConRequestMsgDao.java b/src/com/szpg/db/dao/PgConRequestMsgDao.java new file mode 100644 index 0000000..274f5a6 --- /dev/null +++ b/src/com/szpg/db/dao/PgConRequestMsgDao.java @@ -0,0 +1,13 @@ +package com.szpg.db.dao; + +import com.szpg.db.data.PgConRequestMsg; +import com.szpg.db.data.PgConWorkOrder; + +import java.util.List; + +public interface PgConRequestMsgDao { + + public void addConRequestMsg(List pgConRequestMsgList); + + public String findLastRecordTime(); +} diff --git a/src/com/szpg/db/dao/PgConWorkOrderDao.java b/src/com/szpg/db/dao/PgConWorkOrderDao.java new file mode 100644 index 0000000..ad2c4ae --- /dev/null +++ b/src/com/szpg/db/dao/PgConWorkOrderDao.java @@ -0,0 +1,12 @@ +package com.szpg.db.dao; + + import com.szpg.db.data.PgConWorkOrder; + + import java.util.List; + +public interface PgConWorkOrderDao { + + public void addConWorkerOrder(List pgConWorkOrderList); + + public String findLastRecordTime(); +} diff --git a/src/com/szpg/db/dao/impl/PgAssetInSpectionImpl.java b/src/com/szpg/db/dao/impl/PgAssetInSpectionImpl.java index 2383707..de88d3b 100644 --- a/src/com/szpg/db/dao/impl/PgAssetInSpectionImpl.java +++ b/src/com/szpg/db/dao/impl/PgAssetInSpectionImpl.java @@ -28,47 +28,48 @@ "END_TIME,START_PILE_NO,END_PILE_NO,BUILD_CABIN,MILEAGE,FREQUENCY_TIME,FREQUENCYTIME_END,KETTLE_TS,UPDATEDATE) " + "VALUES (?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?)"; - List paramObjectList=new ArrayList(); + List paramObjectList=new ArrayList<>(); for(PgAssetInSpectionPlan pgAssetInSpectionPlan:pgAssetInSpectionPlanList){ + + if(!pgAssetInSpectionPlan.getPLAN_NAME().contains("吴中太湖新城")) continue; Object[] params = new Object[34]; params[0] = pgAssetInSpectionPlan.getKEY_ID(); params[1] = pgAssetInSpectionPlan.getPLAN_NAME(); params[2] = pgAssetInSpectionPlan.getINSPECTION_PERSON(); params[3] = pgAssetInSpectionPlan.getSTART_DATE(); - params[4]=pgAssetInSpectionPlan.getEND_DATE(); - params[5]=pgAssetInSpectionPlan.getFREQUENCY(); - params[6]=pgAssetInSpectionPlan.getSTATE(); - params[7]=pgAssetInSpectionPlan.getRESPONSIBLE_DEPT(); - params[8]=pgAssetInSpectionPlan.getPLAN_NO(); - params[9]=pgAssetInSpectionPlan.getINSPECTION_TYPE(); - params[10]=pgAssetInSpectionPlan.getINSPECTION_MODE(); - params[11]=pgAssetInSpectionPlan.getINSPECTION_ROUTE(); - params[12]=pgAssetInSpectionPlan.getINSPECTION_START_TIME(); - params[13]=pgAssetInSpectionPlan.getINSPECTION_END_TIME(); - params[14]=pgAssetInSpectionPlan.getINSPECTION_PRACE(); - params[15]=pgAssetInSpectionPlan.getINSPECTION_GROUP(); - params[16]=pgAssetInSpectionPlan.getINSERT_TIME(); - params[17]=pgAssetInSpectionPlan.getFREQUENCYDATE(); - params[18]=pgAssetInSpectionPlan.getFREQUENCYTIME(); - params[19]=pgAssetInSpectionPlan.getCREATEDATE(); - params[20]=pgAssetInSpectionPlan.getCREATOR(); - params[21]=pgAssetInSpectionPlan.getPROJECT(); - params[22]=pgAssetInSpectionPlan.getCOMLILE(); - params[23]=pgAssetInSpectionPlan.getSTART_TIME(); - params[24]=pgAssetInSpectionPlan.getDEVELOP_DEPT(); - params[25]=pgAssetInSpectionPlan.getEND_TIME(); - params[26]=pgAssetInSpectionPlan.getSTART_PILE_NO(); - params[27]=pgAssetInSpectionPlan.getEND_PILE_NO(); - params[28]=pgAssetInSpectionPlan.getBUILD_CABIN(); - params[29]=pgAssetInSpectionPlan.getMILEAGE(); - params[30]=pgAssetInSpectionPlan.getFREQUENCY_TIME(); - params[31]=pgAssetInSpectionPlan.getFREQUENCYTIME_END(); - params[32]=pgAssetInSpectionPlan.getKETTLE_TS(); - params[33]=pgAssetInSpectionPlan.getUPDATEDATE(); + params[4] = pgAssetInSpectionPlan.getEND_DATE(); + params[5] = pgAssetInSpectionPlan.getFREQUENCY(); + params[6] = pgAssetInSpectionPlan.getSTATE(); + params[7] = pgAssetInSpectionPlan.getRESPONSIBLE_DEPT(); + params[8] = pgAssetInSpectionPlan.getPLAN_NO(); + params[9] = pgAssetInSpectionPlan.getINSPECTION_TYPE(); + params[10] = pgAssetInSpectionPlan.getINSPECTION_MODE(); + params[11] = pgAssetInSpectionPlan.getINSPECTION_ROUTE(); + params[12] = pgAssetInSpectionPlan.getINSPECTION_START_TIME(); + params[13] = pgAssetInSpectionPlan.getINSPECTION_END_TIME(); + params[14] = pgAssetInSpectionPlan.getINSPECTION_PRACE(); + params[15] = pgAssetInSpectionPlan.getINSPECTION_GROUP(); + params[16] = pgAssetInSpectionPlan.getINSERT_TIME(); + params[17] = pgAssetInSpectionPlan.getFREQUENCYDATE(); + params[18] = pgAssetInSpectionPlan.getFREQUENCYTIME(); + params[19] = pgAssetInSpectionPlan.getCREATEDATE(); + params[20] = pgAssetInSpectionPlan.getCREATOR(); + params[21] = pgAssetInSpectionPlan.getPROJECT(); + params[22] = pgAssetInSpectionPlan.getCOMLILE(); + params[23] = pgAssetInSpectionPlan.getSTART_TIME(); + params[24] = pgAssetInSpectionPlan.getDEVELOP_DEPT(); + params[25] = pgAssetInSpectionPlan.getEND_TIME(); + params[26] = pgAssetInSpectionPlan.getSTART_PILE_NO(); + params[27] = pgAssetInSpectionPlan.getEND_PILE_NO(); + params[28] = pgAssetInSpectionPlan.getBUILD_CABIN(); + params[29] = pgAssetInSpectionPlan.getMILEAGE(); + params[30] = pgAssetInSpectionPlan.getFREQUENCY_TIME(); + params[31] = pgAssetInSpectionPlan.getFREQUENCYTIME_END(); + params[32] = pgAssetInSpectionPlan.getKETTLE_TS(); + params[33] = pgAssetInSpectionPlan.getUPDATEDATE(); paramObjectList.add(params); } - try { conn = ConnectionManager.getConnectionFromC3P0(); conn.setAutoCommit(false); diff --git a/src/com/szpg/db/dao/impl/PgConRemoveDaoImp.java b/src/com/szpg/db/dao/impl/PgConRemoveDaoImp.java new file mode 100644 index 0000000..510020e --- /dev/null +++ b/src/com/szpg/db/dao/impl/PgConRemoveDaoImp.java @@ -0,0 +1,98 @@ +package com.szpg.db.dao.impl; + +import com.szpg.db.dao.PgConRemoveDao; +import com.szpg.db.data.PgConRemoveMsg; +import com.szpg.db.util.ConnectionManager; +import org.apache.commons.dbutils.DbUtils; +import org.apache.commons.dbutils.QueryRunner; +import org.apache.commons.dbutils.handlers.BeanListHandler; +import org.apache.log4j.Logger; + +import java.sql.Connection; +import java.sql.SQLException; +import java.util.ArrayList; +import java.util.List; + +public class PgConRemoveDaoImp implements PgConRemoveDao { + + private org.apache.log4j.Logger logger = Logger.getLogger(this.getClass().getName()); + + @Override + public void addConRemove(List pgConRemoveMsgList){ + Connection conn = null; + + String insertStr = "INSERT INTO PG_CON_REMOVE_MSG " + + "(XD_DATE, XD_END_TIME, XD_SUPERVISOR,XD_FIELD_SITUATION,XD_REMARKS,XD_APPROVER,XD_APPROVER_TIME,LOG_DATE)" + + "VALUES (?,?,?,?,?,?,?,?)"; + + List paramObjectList=new ArrayList<>(); + for(PgConRemoveMsg pgConRemoveMsg:pgConRemoveMsgList){ + + Object[] params = new Object[34]; + params[0] = pgConRemoveMsg.getXD_DATE(); + params[1] = pgConRemoveMsg.getXD_END_TIME(); + params[2] = pgConRemoveMsg.getXD_SUPERVISOR(); + params[3] = pgConRemoveMsg.getXD_FIELD_SITUATION(); + params[4] = pgConRemoveMsg.getXD_REMARKS(); + params[5] = pgConRemoveMsg.getXD_APPROVER(); + params[6] = pgConRemoveMsg.getXD_APPROVER_TIME(); + params[7] = pgConRemoveMsg.getLOG_DATE(); + + paramObjectList.add(params); + } + try { + conn = ConnectionManager.getConnectionFromC3P0(); + conn.setAutoCommit(false); + + QueryRunner runner = new QueryRunner(); + for (Object[] params:paramObjectList) { + int count = runner.update(conn, insertStr, params); + if (count > 0) + logger.info("施工消点数据同步成功" + pgConRemoveMsgList.toString()); + else + logger.info("施工消点数据同步失败！"); + } + + } catch (Exception ex) { + logger.info("施工作业数据同步异常", ex); + } finally { + try { + DbUtils.commitAndClose(conn); + } catch (SQLException e) { + e.printStackTrace(); + } + } + } + + @Override + public String findLastRecordTime(){ + Connection conn = null; + + String queryStr = "SELECT * FROM PG_CON_REMOVE_MSG ORDER BY LOG_DATE DESC"; + try { + conn = ConnectionManager.getConnectionFromC3P0(); + conn.setAutoCommit(false); + + QueryRunner runner = new QueryRunner(); + List pgConRemoveMsgList = (List) runner.query(conn, + queryStr, new BeanListHandler(PgConRemoveMsg.class)); + + if (null != pgConRemoveMsgList && pgConRemoveMsgList.isEmpty() == false) { + logger.debug("获取最新施工消点记录成功[" + pgConRemoveMsgList + "]"); + return pgConRemoveMsgList.get(0).getLOG_DATE(); + } + else + return null; + } catch (Exception ex) { + logger.error("获取最新施工消点记录异常", ex); + } finally { + try { + DbUtils.commitAndClose(conn); + } catch (SQLException e) { + e.printStackTrace(); + } + } + return null; + } + +} diff --git a/src/com/szpg/db/dao/impl/PgConRequestMsgDaoImp.java b/src/com/szpg/db/dao/impl/PgConRequestMsgDaoImp.java new file mode 100644 index 0000000..d763e19 --- /dev/null +++ b/src/com/szpg/db/dao/impl/PgConRequestMsgDaoImp.java @@ -0,0 +1,108 @@ +package com.szpg.db.dao.impl; + +import com.szpg.db.dao.PgConRequestMsgDao; +import com.szpg.db.data.PgConRequestMsg; +import com.szpg.db.data.PgConWorkOrder; +import com.szpg.db.util.ConnectionManager; +import org.apache.commons.dbutils.DbUtils; +import org.apache.commons.dbutils.QueryRunner; +import org.apache.commons.dbutils.handlers.BeanListHandler; +import org.apache.log4j.Logger; + +import java.sql.Connection; +import java.sql.SQLException; +import java.util.ArrayList; +import java.util.Date; +import java.util.List; + +public class PgConRequestMsgDaoImp implements PgConRequestMsgDao { + + private org.apache.log4j.Logger logger = Logger.getLogger(this.getClass().getName()); + + @Override + public void addConRequestMsg(List pgConRequestMsgList){ + Connection conn = null; + + String insertStr = "INSERT INTO PG_CON_REQUEST_MSG " + + "(BUILD_TASK_ID, DATE, TASK_ID,BUILD_COMPANY,SUPERVISOR_TEL,TEL,BUILD_PLACE,BUILD_TIME,START_PLACE," + + "END_PLACE,PROJECT,BUILD_CONTENT,APPROVER,APPROVER_TIME,LOG_DATE)" + + "VALUES (?,?,?,?,?,?,?,?,?,?,?,?,?,?,?)"; + + List paramObjectList=new ArrayList<>(); + for(PgConRequestMsg pgConRequestMsg:pgConRequestMsgList){ + + Object[] params = new Object[34]; + params[0] = pgConRequestMsg.getBUILD_TASK_ID(); + params[1] = pgConRequestMsg.getDATE(); + params[2] = pgConRequestMsg.getTASK_ID(); + params[3] = pgConRequestMsg.getBUILD_COMPANY(); + params[4] = pgConRequestMsg.getSUPERVISOR_TEL(); + params[5] = pgConRequestMsg.getTEL(); + params[6] = pgConRequestMsg.getBUILD_PLACE(); + params[7] = pgConRequestMsg.getBUILD_TIME(); + params[8] = pgConRequestMsg.getSTART_PLACE(); + params[9] = pgConRequestMsg.getEND_PLACE(); + params[10] = pgConRequestMsg.getPROJECT(); + params[11] = pgConRequestMsg.getBUILD_CONTENT(); + params[12] = pgConRequestMsg.getAPPROVER(); + params[13] = pgConRequestMsg.getAPPROVER_TIME(); + params[14] = pgConRequestMsg.getLOG_DATE(); + + paramObjectList.add(params); + } + try { + conn = ConnectionManager.getConnectionFromC3P0(); + conn.setAutoCommit(false); + + QueryRunner runner = new QueryRunner(); + for (Object[] params:paramObjectList) { + int count = runner.update(conn, insertStr, params); + if (count > 0) + logger.info("施工请点数据同步成功" + pgConRequestMsgList.toString()); + else + logger.info("施工请点数据同步失败！"); + } + + } catch (Exception ex) { + logger.info("施工请点数据同步异常", ex); + } finally { + try { + DbUtils.commitAndClose(conn); + } catch (SQLException e) { + e.printStackTrace(); + } + } + } + + @Override + public String findLastRecordTime(){ + Connection conn = null; + + String queryStr = "SELECT * FROM PG_CON_REQUEST_MSG ORDER BY LOG_DATE DESC"; + try { + conn = ConnectionManager.getConnectionFromC3P0(); + conn.setAutoCommit(false); + + QueryRunner runner = new QueryRunner(); + List pgConRequestMsgList = (List) runner.query(conn, + queryStr, new BeanListHandler(PgConRequestMsg.class)); + + if (null != pgConRequestMsgList && pgConRequestMsgList.isEmpty() == false) { + logger.debug("获取最新施工请点记录成功[" + pgConRequestMsgList + "]"); + return pgConRequestMsgList.get(0).getLOG_DATE(); + } + else + return null; + } catch (Exception ex) { + logger.error("获取最新施工请点记录异常", ex); + } finally { + try { + DbUtils.commitAndClose(conn); + } catch (SQLException e) { + e.printStackTrace(); + } + } + return null; + } + +} diff --git a/src/com/szpg/db/dao/impl/PgConWorkOrderDaoImp.java b/src/com/szpg/db/dao/impl/PgConWorkOrderDaoImp.java new file mode 100644 index 0000000..98e2a66 --- /dev/null +++ b/src/com/szpg/db/dao/impl/PgConWorkOrderDaoImp.java @@ -0,0 +1,116 @@ +package com.szpg.db.dao.impl; + +import com.szpg.db.dao.PgConWorkOrderDao; +import com.szpg.db.data.PgAssetInSpectionPlan; +import com.szpg.db.data.PgConWorkOrder; +import com.szpg.db.util.ConnectionManager; +import freemarker.template.utility.DateUtil; +import org.apache.commons.dbutils.DbUtils; +import org.apache.commons.dbutils.QueryRunner; +import org.apache.commons.dbutils.handlers.BeanListHandler; +import org.apache.log4j.Logger; + +import java.sql.Connection; +import java.sql.SQLException; +import java.util.ArrayList; +import java.util.Date; +import java.util.List; + +public class PgConWorkOrderDaoImp implements PgConWorkOrderDao { + + private org.apache.log4j.Logger logger = Logger.getLogger(this.getClass().getName()); + + @Override + public void addConWorkerOrder(List pgConWorkOrderList){ + Connection conn = null; + + String insertStr = "INSERT INTO PG_CON_WORK_ORDER " + + "(KEY_ID, PLAN_NO, TASK_COMPANY,TASK_ID,SUPERVISOR,SUPERVISOR_PHONE,APPLCIANT,APPLCIANT_PHONE,TASK_NAME," + + "TASK_PLACE,TASK_DATE,TASK_DATE_END,PROJECT,TASK_CONTENT,TASK_SAFETY_MEASURES," + + "TASK_PEOPLE_NUM,TASK_INFLUENCE,COMPLETION_OF_THE_SITUATION,REMARKS,BUILD_STATE,LOG_DATE)" + + "VALUES (?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?)"; + + List paramObjectList=new ArrayList<>(); + for(PgConWorkOrder pgConWorkOrder:pgConWorkOrderList){ + + Object[] params = new Object[34]; + params[0] = pgConWorkOrder.getKEY_ID(); + params[1] = pgConWorkOrder.getPLAN_NO(); + params[2] = pgConWorkOrder.getTASK_COMPANY(); + params[3] = pgConWorkOrder.getTASK_ID(); + params[4] = pgConWorkOrder.getSUPERVISOR(); + params[5] = pgConWorkOrder.getSUPERVISOR_PHONE(); + params[6] = pgConWorkOrder.getAPPLCIANT(); + params[7] = pgConWorkOrder.getAPPLCIANT_PHONE(); + params[8] = pgConWorkOrder.getTASK_NAME(); + params[9] = pgConWorkOrder.getTASK_PLACE(); + params[10] = pgConWorkOrder.getTASK_DATE(); + params[11] = pgConWorkOrder.getTASK_DATE_END(); + params[12] = pgConWorkOrder.getPROJECT(); + params[13] = pgConWorkOrder.getTASK_CONTENT(); + params[14] = pgConWorkOrder.getTASK_SAFETY_MEASURES(); + params[15] = pgConWorkOrder.getTASK_PEOPLE_NUM(); + params[16] = pgConWorkOrder.getTASK_INFLUENCE(); + params[17] = pgConWorkOrder.getCOMPLETION_OF_THE_SITUATION(); + params[18] = pgConWorkOrder.getREMARKS(); + params[19] = pgConWorkOrder.getBUILD_STATE(); + params[19] = new Date(); + + paramObjectList.add(params); + } + try { + conn = ConnectionManager.getConnectionFromC3P0(); + conn.setAutoCommit(false); + + QueryRunner runner = new QueryRunner(); + for (Object[] params:paramObjectList) { + int count = runner.update(conn, insertStr, params); + if (count > 0) + logger.info("施工作业数据同步成功" + pgConWorkOrderList.toString()); + else + logger.info("施工作业数据同步失败！"); + } + + } catch (Exception ex) { + logger.info("施工作业数据同步异常", ex); + } finally { + try { + DbUtils.commitAndClose(conn); + } catch (SQLException e) { + e.printStackTrace(); + } + } + } + + @Override + public String findLastRecordTime(){ + Connection conn = null; + + String queryStr = "SELECT * FROM PG_CON_WORK_ORDER ORDER BY LOG_DATE DESC"; + try { + conn = ConnectionManager.getConnectionFromC3P0(); + conn.setAutoCommit(false); + + QueryRunner runner = new QueryRunner(); + List pgConWorkOrderList = (List) runner.query(conn, + queryStr, new BeanListHandler(PgConWorkOrder.class)); + + if (null != pgConWorkOrderList && pgConWorkOrderList.isEmpty() == false) { + logger.debug("获取最新施工记录成功[" + pgConWorkOrderList + "]"); + return pgConWorkOrderList.get(0).getLOG_DATE(); + } + else + return null; + } catch (Exception ex) { + logger.error("获取最新施工记录异常", ex); + } finally { + try { + DbUtils.commitAndClose(conn); + } catch (SQLException e) { + e.printStackTrace(); + } + } + return null; + } + +} diff --git a/src/com/szpg/db/data/PgAssetInSpectionPlan.java b/src/com/szpg/db/data/PgAssetInSpectionPlan.java index fd10c61..c86ec88 100644 --- a/src/com/szpg/db/data/PgAssetInSpectionPlan.java +++ b/src/com/szpg/db/data/PgAssetInSpectionPlan.java @@ -103,7 +103,6 @@ this.RESPONSIBLE_DEPT = RESPONSIBLE_DEPT; } - public String getPLAN_NO() { return PLAN_NO; } @@ -312,5 +311,4 @@ this.UPDATEDATE = UPDATEDATE; } - -} +} \ No newline at end of file diff --git a/src/com/szpg/db/data/PgConRemoveMsg.java b/src/com/szpg/db/data/PgConRemoveMsg.java new file mode 100644 index 0000000..6dcbaa0 --- /dev/null +++ b/src/com/szpg/db/data/PgConRemoveMsg.java @@ -0,0 +1,79 @@ +package com.szpg.db.data; + +import java.io.Serializable; + +public class PgConRemoveMsg implements Serializable { + + private String XD_DATE; + private String XD_END_TIME; + private String XD_SUPERVISOR; + private String XD_FIELD_SITUATION; + private String XD_REMARKS; + private String XD_APPROVER; + private String XD_APPROVER_TIME; + private String LOG_DATE; + + public String getXD_DATE() { + return XD_DATE; + } + + public void setXD_DATE(String XD_DATE) { + this.XD_DATE = XD_DATE; + } + + public String getXD_END_TIME() { + return XD_END_TIME; + } + + public void setXD_END_TIME(String XD_END_TIME) { + this.XD_END_TIME = XD_END_TIME; + } + + public String getXD_SUPERVISOR() { + return XD_SUPERVISOR; + } + + public void setXD_SUPERVISOR(String XD_SUPERVISOR) { + this.XD_SUPERVISOR = XD_SUPERVISOR; + } + + public String getXD_FIELD_SITUATION() { + return XD_FIELD_SITUATION; + } + + public void setXD_FIELD_SITUATION(String XD_FIELD_SITUATION) { + this.XD_FIELD_SITUATION = XD_FIELD_SITUATION; + } + + public String getXD_REMARKS() { + return XD_REMARKS; + } + + public void setXD_REMARKS(String XD_REMARKS) { + this.XD_REMARKS = XD_REMARKS; + } + + public String getXD_APPROVER() { + return XD_APPROVER; + } + + public void setXD_APPROVER(String XD_APPROVER) { + this.XD_APPROVER = XD_APPROVER; + } + + public String getXD_APPROVER_TIME() { + return XD_APPROVER_TIME; + } + + public void setXD_APPROVER_TIME(String XD_APPROVER_TIME) { + this.XD_APPROVER_TIME = XD_APPROVER_TIME; + } + + public String getLOG_DATE() { + return LOG_DATE; + } + + public void setLOG_DATE(String LOG_DATE) { + this.LOG_DATE = LOG_DATE; + } +} diff --git a/src/com/szpg/db/data/PgConRemoveMsgJson.java b/src/com/szpg/db/data/PgConRemoveMsgJson.java new file mode 100644 index 0000000..d3253c5 --- /dev/null +++ b/src/com/szpg/db/data/PgConRemoveMsgJson.java @@ -0,0 +1,53 @@ +package com.szpg.db.data; + +import java.util.List; + +public class PgConRemoveMsgJson { + + private String total; + private String totalRecords; + private String page; + private String records; + private List rows; + + public String getTotal() { + return total; + } + + public void setTotal(String total) { + this.total = total; + } + + public String getTotalRecords() { + return totalRecords; + } + + public void setTotalRecords(String totalRecords) { + this.totalRecords = totalRecords; + } + + public String getPage() { + return page; + } + + public void setPage(String page) { + this.page = page; + } + + public String getRecords() { + return records; + } + + public void setRecords(String records) { + this.records = records; + } + + public List getRows() { + return rows; + } + + public void setRows(List rows) { + this.rows = rows; + } + +} \ No newline at end of file diff --git a/src/com/szpg/db/data/PgConRequestMsg.java b/src/com/szpg/db/data/PgConRequestMsg.java new file mode 100644 index 0000000..fddd30a --- /dev/null +++ b/src/com/szpg/db/data/PgConRequestMsg.java @@ -0,0 +1,142 @@ +package com.szpg.db.data; + +import java.io.Serializable; + +public class PgConRequestMsg implements Serializable { + + private String BUILD_TASK_ID;//作业令编号 + private String DATE;//请点日期 + private String TASK_ID;//作业代码 + private String BUILD_COMPANY;//施工单位 + private String SUPERVISOR_TEL;//请点负责人 + private String TEL;//负责人电话 + private String BUILD_PLACE;//请点地点 + private String BUILD_TIME;//请点时间 + private String START_PLACE;//起始位置 + private String END_PLACE;//结束位置 + private String PROJECT;//所属项目 CBL：城北路，CYL：城阳路，THXC:太湖新城 + private String BUILD_CONTENT;//施工内容 + private String APPROVER;//批准人 + private String APPROVER_TIME;//批准时间 + private String LOG_DATE; + + public String getBUILD_TASK_ID() { + return BUILD_TASK_ID; + } + + public void setBUILD_TASK_ID(String BUILD_TASK_ID) { + this.BUILD_TASK_ID = BUILD_TASK_ID; + } + + public String getDATE() { + return DATE; + } + + public void setDATE(String DATE) { + this.DATE = DATE; + } + + public String getTASK_ID() { + return TASK_ID; + } + + public void setTASK_ID(String TASK_ID) { + this.TASK_ID = TASK_ID; + } + + public String getBUILD_COMPANY() { + return BUILD_COMPANY; + } + + public void setBUILD_COMPANY(String BUILD_COMPANY) { + this.BUILD_COMPANY = BUILD_COMPANY; + } + + public String getSUPERVISOR_TEL() { + return SUPERVISOR_TEL; + } + + public void setSUPERVISOR_TEL(String SUPERVISOR_TEL) { + this.SUPERVISOR_TEL = SUPERVISOR_TEL; + } + + public String getTEL() { + return TEL; + } + + public void setTEL(String TEL) { + this.TEL = TEL; + } + + public String getBUILD_PLACE() { + return BUILD_PLACE; + } + + public void setBUILD_PLACE(String BUILD_PLACE) { + this.BUILD_PLACE = BUILD_PLACE; + } + + public String getBUILD_TIME() { + return BUILD_TIME; + } + + public void setBUILD_TIME(String BUILD_TIME) { + this.BUILD_TIME = BUILD_TIME; + } + + public String getSTART_PLACE() { + return START_PLACE; + } + + public void setSTART_PLACE(String START_PLACE) { + this.START_PLACE = START_PLACE; + } + + public String getEND_PLACE() { + return END_PLACE; + } + + public void setEND_PLACE(String END_PLACE) { + this.END_PLACE = END_PLACE; + } + + public String getPROJECT() { + return PROJECT; + } + + public void setPROJECT(String PROJECT) { + this.PROJECT = PROJECT; + } + + public String getBUILD_CONTENT() { + return BUILD_CONTENT; + } + + public void setBUILD_CONTENT(String BUILD_CONTENT) { + this.BUILD_CONTENT = BUILD_CONTENT; + } + + public String getAPPROVER() { + return APPROVER; + } + + public void setAPPROVER(String APPROVER) { + this.APPROVER = APPROVER; + } + + public String getAPPROVER_TIME() { + return APPROVER_TIME; + } + + public void setAPPROVER_TIME(String APPROVER_TIME) { + this.APPROVER_TIME = APPROVER_TIME; + } + + public String getLOG_DATE() { + return LOG_DATE; + } + + public void setLOG_DATE(String LOG_DATE) { + this.LOG_DATE = LOG_DATE; + } +} diff --git a/src/com/szpg/db/data/PgConRequestMsgJson.java b/src/com/szpg/db/data/PgConRequestMsgJson.java new file mode 100644 index 0000000..29ab61f --- /dev/null +++ b/src/com/szpg/db/data/PgConRequestMsgJson.java @@ -0,0 +1,52 @@ +package com.szpg.db.data; + +import java.util.List; + +public class PgConRequestMsgJson { + + private String total; + private String totalRecords; + private String page; + private String records; + private List rows; + + public String getTotal() { + return total; + } + + public void setTotal(String total) { + this.total = total; + } + + public String getTotalRecords() { + return totalRecords; + } + + public void setTotalRecords(String totalRecords) { + this.totalRecords = totalRecords; + } + + public String getPage() { + return page; + } + + public void setPage(String page) { + this.page = page; + } + + public String getRecords() { + return records; + } + + public void setRecords(String records) { + this.records = records; + } + + public List getRows() { + return rows; + } + + public void setRows(List rows) { + this.rows = rows; + } +} diff --git a/src/com/szpg/db/data/PgConWorkOrder.java b/src/com/szpg/db/data/PgConWorkOrder.java new file mode 100644 index 0000000..7e39c59 --- /dev/null +++ b/src/com/szpg/db/data/PgConWorkOrder.java @@ -0,0 +1,196 @@ +package com.szpg.db.data; + +import java.io.Serializable; + +public class PgConWorkOrder implements Serializable { + + private String KEY_ID;//GUID字段 + private String PLAN_NO;//计划申请单号 + private String TASK_COMPANY;//作业单位 + private String TASK_ID;//作业编号 + private String SUPERVISOR;//负责人 + private String SUPERVISOR_PHONE;//负责人联系方式 + private String APPLCIANT;//申报人 + private String APPLCIANT_PHONE;//申报人联系方式 + private String TASK_NAME;//作业名称 + private String TASK_PLACE;//作业区域 + private String TASK_DATE;//作业开始日期 + private String TASK_DATE_END;//作业结束日期 + private String PROJECT;//所属项目 CBL：城北路，CYL：城阳路，THXC:太湖新城 + private String TASK_CONTENT;//作业内容 + private String TASK_SAFETY_MEASURES;//作业安全措施 + private String TASK_PEOPLE_NUM;//人数及施工人员 + private String TASK_INFLUENCE;//施工影响 1：A类，2：B类，3：C类 + private String COMPLETION_OF_THE_SITUATION;//完成情况 + private String REMARKS;//备注 + private String BUILD_STATE;//施工状态 申请=1，进入=2，延期=3，验收=4 + private String LOG_DATE; + + public String getKEY_ID() { + return KEY_ID; + } + + public void setKEY_ID(String KEY_ID) { + this.KEY_ID = KEY_ID; + } + + public String getPLAN_NO() { + return PLAN_NO; + } + + public void setPLAN_NO(String PLAN_NO) { + this.PLAN_NO = PLAN_NO; + } + + public String getTASK_COMPANY() { + return TASK_COMPANY; + } + + public void setTASK_COMPANY(String TASK_COMPANY) { + this.TASK_COMPANY = TASK_COMPANY; + } + + public String getTASK_ID() { + return TASK_ID; + } + + public void setTASK_ID(String TASK_ID) { + this.TASK_ID = TASK_ID; + } + + public String getSUPERVISOR() { + return SUPERVISOR; + } + + public void setSUPERVISOR(String SUPERVISOR) { + this.SUPERVISOR = SUPERVISOR; + } + + public String getSUPERVISOR_PHONE() { + return SUPERVISOR_PHONE; + } + + public void setSUPERVISOR_PHONE(String SUPERVISOR_PHONE) { + this.SUPERVISOR_PHONE = SUPERVISOR_PHONE; + } + + public String getAPPLCIANT() { + return APPLCIANT; + } + + public void setAPPLCIANT(String APPLCIANT) { + this.APPLCIANT = APPLCIANT; + } + + public String getAPPLCIANT_PHONE() { + return APPLCIANT_PHONE; + } + + public void setAPPLCIANT_PHONE(String APPLCIANT_PHONE) { + this.APPLCIANT_PHONE = APPLCIANT_PHONE; + } + + public String getTASK_NAME() { + return TASK_NAME; + } + + public void setTASK_NAME(String TASK_NAME) { + this.TASK_NAME = TASK_NAME; + } + + public String getTASK_PLACE() { + return TASK_PLACE; + } + + public void setTASK_PLACE(String TASK_PLACE) { + this.TASK_PLACE = TASK_PLACE; + } + + public String getTASK_DATE() { + return TASK_DATE; + } + + public void setTASK_DATE(String TASK_DATE) { + this.TASK_DATE = TASK_DATE; + } + + public String getTASK_DATE_END() { + return TASK_DATE_END; + } + + public void setTASK_DATE_END(String TASK_DATE_END) { + this.TASK_DATE_END = TASK_DATE_END; + } + + public String getPROJECT() { + return PROJECT; + } + + public void setPROJECT(String PROJECT) { + this.PROJECT = PROJECT; + } + + public String getTASK_CONTENT() { + return TASK_CONTENT; + } + + public void setTASK_CONTENT(String TASK_CONTENT) { + this.TASK_CONTENT = TASK_CONTENT; + } + + public String getTASK_SAFETY_MEASURES() { + return TASK_SAFETY_MEASURES; + } + + public void setTASK_SAFETY_MEASURES(String TASK_SAFETY_MEASURES) { + this.TASK_SAFETY_MEASURES = TASK_SAFETY_MEASURES; + } + + public String getTASK_PEOPLE_NUM() { + return TASK_PEOPLE_NUM; + } + + public void setTASK_PEOPLE_NUM(String TASK_PEOPLE_NUM) { + this.TASK_PEOPLE_NUM = TASK_PEOPLE_NUM; + } + + public String getTASK_INFLUENCE() { + return TASK_INFLUENCE; + } + + public void setTASK_INFLUENCE(String TASK_INFLUENCE) { + this.TASK_INFLUENCE = TASK_INFLUENCE; + } + + public String getCOMPLETION_OF_THE_SITUATION() { + return COMPLETION_OF_THE_SITUATION; + } + + public void setCOMPLETION_OF_THE_SITUATION(String COMPLETION_OF_THE_SITUATION) { + this.COMPLETION_OF_THE_SITUATION = COMPLETION_OF_THE_SITUATION; + } + + public String getREMARKS() { + return REMARKS; + } + + public void setREMARKS(String REMARKS) { + this.REMARKS = REMARKS; + } + + public String getBUILD_STATE() { + return BUILD_STATE; + } + + public void setBUILD_STATE(String BUILD_STATE) { + this.BUILD_STATE = BUILD_STATE; + } + + public String getLOG_DATE() { + return LOG_DATE; + } + + public void setLOG_DATE(String LOG_DATE) { + this.LOG_DATE = LOG_DATE; + } +} \ No newline at end of file diff --git a/src/com/szpg/db/data/PgConWorkOrderJson.java b/src/com/szpg/db/data/PgConWorkOrderJson.java new file mode 100644 index 0000000..37160c7 --- /dev/null +++ b/src/com/szpg/db/data/PgConWorkOrderJson.java @@ -0,0 +1,53 @@ +package com.szpg.db.data; + +import java.util.List; + +public class PgConWorkOrderJson { + + private String total; + private String totalRecords; + private String page; + private String records; + private List rows; + + public String getTotal() { + return total; + } + + public void setTotal(String total) { + this.total = total; + } + + public String getTotalRecords() { + return totalRecords; + } + + public void setTotalRecords(String totalRecords) { + this.totalRecords = totalRecords; + } + + public String getPage() { + return page; + } + + public void setPage(String page) { + this.page = page; + } + + public String getRecords() { + return records; + } + + public void setRecords(String records) { + this.records = records; + } + + public List getRows() { + return rows; + } + + public void setRows(List rows) { + this.rows = rows; + } + +} \ No newline at end of file diff --git a/src/com/szpg/task/ReadConRemoveTask.java b/src/com/szpg/task/ReadConRemoveTask.java new file mode 100644 index 0000000..6a52501 --- /dev/null +++ b/src/com/szpg/task/ReadConRemoveTask.java @@ -0,0 +1,98 @@ +package com.szpg.task; + +import com.alibaba.fastjson.JSON; +import com.alibaba.fastjson.JSONObject; +import com.alibaba.fastjson.TypeReference; +import com.szpg.db.dao.PgConRemoveDao; +import com.szpg.db.dao.impl.PgConRemoveDaoImp; +import com.szpg.db.data.PgConRemoveMsg; +import com.szpg.db.data.PgConRemoveMsgJson; +import com.szpg.util.HttpRequest; +import org.apache.log4j.Logger; + +import java.text.SimpleDateFormat; +import java.util.Calendar; +import java.util.Date; +import java.util.List; + +public class ReadConRemoveTask implements Runnable { + + private org.apache.log4j.Logger logger = Logger.getLogger(this.getClass().getName()); + final String tableName="ASSET_INSPECTION_PLAN1";// + final String url="http://10.10.2.31:9056/GLYW/api/Common/LoadIndexData"; + SimpleDateFormat dateFormat = new SimpleDateFormat("yyyy-MM-dd"); + + @Override + public void run(){ + PgConRemoveDao pgConRemoveDao=new PgConRemoveDaoImp(); + + try { + String endTime = dateFormat.format(new Date());//当前时间 + + String startTime = pgConRemoveDao.findLastRecordTime();//上次同步数据最后记录时间 + if (startTime == null) { + Date dt = new Date();; + startTime = getStartDateStr(dt, -1);; + } + else + { + Date dtStart = dateFormat.parse(startTime); + startTime=getStartDateStr(dtStart,1);; + } + + StringBuilder sb = new StringBuilder(); + sb.append("tableName=").append(tableName); + sb.append("&page=-1"); + sb.append("&strWhere= LOG_DATE");; + sb.append(" between '").append(startTime); + sb.append("' and '").append(endTime); + sb.append("'"); + + logger.info("开始请求施工消点数据"); + String jsonStr = HttpRequest.sendPostByHttp(url, sb.toString()); + if (jsonStr.equals("")) + logger.error("施工消点数据请求失败"); + else { + insertDB(pgConRemoveDao, jsonStr); + logger.error("施工消点数据存储成功"); + } + } + catch(Exception ex) + { + ex.printStackTrace(); + } + } + + public void insertDB(PgConRemoveDao pgConRemoveDao,String jsonStr) + { + List pgConRemoveMsgList= getAssetByJsonString(jsonStr); + logger.info("同步施工消点数据条数："+ String.valueOf(pgConRemoveMsgList.size())); + pgConRemoveDao.addConRemove(pgConRemoveMsgList); + } + + private List getAssetByJsonString(String jsonStr){ + try { + String jsonString=String.valueOf(JSON.parse(jsonStr)); + PgConRemoveMsgJson pgConRemoveMsgJson = JSONObject.parseObject(jsonString, new TypeReference() {}); + List pgConRemoveMsgList = pgConRemoveMsgJson.getRows(); + return pgConRemoveMsgList; + } + catch(Exception ex){ + logger.error(ex.getMessage()); + return null; + } + + } + + public String getStartDateStr(Date dt,int d) { + + String yesToday = ""; + Date dtt = (Date) dt.clone(); + Calendar calendar = Calendar.getInstance(); + calendar.setTime(dtt); + calendar.add(Calendar.DAY_OF_MONTH, d);; + yesToday = dateFormat.format(calendar.getTime()); + + return yesToday; + } +} diff --git a/.idea/workspace.xml b/.idea/workspace.xml new file mode 100644 index 0000000..e15ca50 --- /dev/null +++ b/.idea/workspace.xml @@ -0,0 +1,849 @@ + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + 未能连接到 + yy-mm-d + + + + + + + + + + + true + DEFINITION_ORDER + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + 1567762862031 + + + 1568000184886 + + + 1568100549456 + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + pgdsc + + + + + + + + Web (pgdsc)|Web + + + + + + + + + + + + + + + 1.8 + + + + + + + + pgdsc + + + + + + + + json + + + + + + + + \ No newline at end of file diff --git a/src/com/szpg/db/dao/PgConRemoveDao.java b/src/com/szpg/db/dao/PgConRemoveDao.java new file mode 100644 index 0000000..49903fc --- /dev/null +++ b/src/com/szpg/db/dao/PgConRemoveDao.java @@ -0,0 +1,14 @@ +package com.szpg.db.dao; + +import com.szpg.db.data.PgConRemoveMsg; +import com.szpg.db.data.PgConWorkOrder; + +import java.util.List; + +public interface PgConRemoveDao { + + public void addConRemove(List pgConRemoveMsgList); + + public String findLastRecordTime(); + +} diff --git a/src/com/szpg/db/dao/PgConRequestMsgDao.java b/src/com/szpg/db/dao/PgConRequestMsgDao.java new file mode 100644 index 0000000..274f5a6 --- /dev/null +++ b/src/com/szpg/db/dao/PgConRequestMsgDao.java @@ -0,0 +1,13 @@ +package com.szpg.db.dao; + +import com.szpg.db.data.PgConRequestMsg; +import com.szpg.db.data.PgConWorkOrder; + +import java.util.List; + +public interface PgConRequestMsgDao { + + public void addConRequestMsg(List pgConRequestMsgList); + + public String findLastRecordTime(); +} diff --git a/src/com/szpg/db/dao/PgConWorkOrderDao.java b/src/com/szpg/db/dao/PgConWorkOrderDao.java new file mode 100644 index 0000000..ad2c4ae --- /dev/null +++ b/src/com/szpg/db/dao/PgConWorkOrderDao.java @@ -0,0 +1,12 @@ +package com.szpg.db.dao; + + import com.szpg.db.data.PgConWorkOrder; + + import java.util.List; + +public interface PgConWorkOrderDao { + + public void addConWorkerOrder(List pgConWorkOrderList); + + public String findLastRecordTime(); +} diff --git a/src/com/szpg/db/dao/impl/PgAssetInSpectionImpl.java b/src/com/szpg/db/dao/impl/PgAssetInSpectionImpl.java index 2383707..de88d3b 100644 --- a/src/com/szpg/db/dao/impl/PgAssetInSpectionImpl.java +++ b/src/com/szpg/db/dao/impl/PgAssetInSpectionImpl.java @@ -28,47 +28,48 @@ "END_TIME,START_PILE_NO,END_PILE_NO,BUILD_CABIN,MILEAGE,FREQUENCY_TIME,FREQUENCYTIME_END,KETTLE_TS,UPDATEDATE) " + "VALUES (?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?)"; - List paramObjectList=new ArrayList(); + List paramObjectList=new ArrayList<>(); for(PgAssetInSpectionPlan pgAssetInSpectionPlan:pgAssetInSpectionPlanList){ + + if(!pgAssetInSpectionPlan.getPLAN_NAME().contains("吴中太湖新城")) continue; Object[] params = new Object[34]; params[0] = pgAssetInSpectionPlan.getKEY_ID(); params[1] = pgAssetInSpectionPlan.getPLAN_NAME(); params[2] = pgAssetInSpectionPlan.getINSPECTION_PERSON(); params[3] = pgAssetInSpectionPlan.getSTART_DATE(); - params[4]=pgAssetInSpectionPlan.getEND_DATE(); - params[5]=pgAssetInSpectionPlan.getFREQUENCY(); - params[6]=pgAssetInSpectionPlan.getSTATE(); - params[7]=pgAssetInSpectionPlan.getRESPONSIBLE_DEPT(); - params[8]=pgAssetInSpectionPlan.getPLAN_NO(); - params[9]=pgAssetInSpectionPlan.getINSPECTION_TYPE(); - params[10]=pgAssetInSpectionPlan.getINSPECTION_MODE(); - params[11]=pgAssetInSpectionPlan.getINSPECTION_ROUTE(); - params[12]=pgAssetInSpectionPlan.getINSPECTION_START_TIME(); - params[13]=pgAssetInSpectionPlan.getINSPECTION_END_TIME(); - params[14]=pgAssetInSpectionPlan.getINSPECTION_PRACE(); - params[15]=pgAssetInSpectionPlan.getINSPECTION_GROUP(); - params[16]=pgAssetInSpectionPlan.getINSERT_TIME(); - params[17]=pgAssetInSpectionPlan.getFREQUENCYDATE(); - params[18]=pgAssetInSpectionPlan.getFREQUENCYTIME(); - params[19]=pgAssetInSpectionPlan.getCREATEDATE(); - params[20]=pgAssetInSpectionPlan.getCREATOR(); - params[21]=pgAssetInSpectionPlan.getPROJECT(); - params[22]=pgAssetInSpectionPlan.getCOMLILE(); - params[23]=pgAssetInSpectionPlan.getSTART_TIME(); - params[24]=pgAssetInSpectionPlan.getDEVELOP_DEPT(); - params[25]=pgAssetInSpectionPlan.getEND_TIME(); - params[26]=pgAssetInSpectionPlan.getSTART_PILE_NO(); - params[27]=pgAssetInSpectionPlan.getEND_PILE_NO(); - params[28]=pgAssetInSpectionPlan.getBUILD_CABIN(); - params[29]=pgAssetInSpectionPlan.getMILEAGE(); - params[30]=pgAssetInSpectionPlan.getFREQUENCY_TIME(); - params[31]=pgAssetInSpectionPlan.getFREQUENCYTIME_END(); - params[32]=pgAssetInSpectionPlan.getKETTLE_TS(); - params[33]=pgAssetInSpectionPlan.getUPDATEDATE(); + params[4] = pgAssetInSpectionPlan.getEND_DATE(); + params[5] = pgAssetInSpectionPlan.getFREQUENCY(); + params[6] = pgAssetInSpectionPlan.getSTATE(); + params[7] = pgAssetInSpectionPlan.getRESPONSIBLE_DEPT(); + params[8] = pgAssetInSpectionPlan.getPLAN_NO(); + params[9] = pgAssetInSpectionPlan.getINSPECTION_TYPE(); + params[10] = pgAssetInSpectionPlan.getINSPECTION_MODE(); + params[11] = pgAssetInSpectionPlan.getINSPECTION_ROUTE(); + params[12] = pgAssetInSpectionPlan.getINSPECTION_START_TIME(); + params[13] = pgAssetInSpectionPlan.getINSPECTION_END_TIME(); + params[14] = pgAssetInSpectionPlan.getINSPECTION_PRACE(); + params[15] = pgAssetInSpectionPlan.getINSPECTION_GROUP(); + params[16] = pgAssetInSpectionPlan.getINSERT_TIME(); + params[17] = pgAssetInSpectionPlan.getFREQUENCYDATE(); + params[18] = pgAssetInSpectionPlan.getFREQUENCYTIME(); + params[19] = pgAssetInSpectionPlan.getCREATEDATE(); + params[20] = pgAssetInSpectionPlan.getCREATOR(); + params[21] = pgAssetInSpectionPlan.getPROJECT(); + params[22] = pgAssetInSpectionPlan.getCOMLILE(); + params[23] = pgAssetInSpectionPlan.getSTART_TIME(); + params[24] = pgAssetInSpectionPlan.getDEVELOP_DEPT(); + params[25] = pgAssetInSpectionPlan.getEND_TIME(); + params[26] = pgAssetInSpectionPlan.getSTART_PILE_NO(); + params[27] = pgAssetInSpectionPlan.getEND_PILE_NO(); + params[28] = pgAssetInSpectionPlan.getBUILD_CABIN(); + params[29] = pgAssetInSpectionPlan.getMILEAGE(); + params[30] = pgAssetInSpectionPlan.getFREQUENCY_TIME(); + params[31] = pgAssetInSpectionPlan.getFREQUENCYTIME_END(); + params[32] = pgAssetInSpectionPlan.getKETTLE_TS(); + params[33] = pgAssetInSpectionPlan.getUPDATEDATE(); paramObjectList.add(params); } - try { conn = ConnectionManager.getConnectionFromC3P0(); conn.setAutoCommit(false); diff --git a/src/com/szpg/db/dao/impl/PgConRemoveDaoImp.java b/src/com/szpg/db/dao/impl/PgConRemoveDaoImp.java new file mode 100644 index 0000000..510020e --- /dev/null +++ b/src/com/szpg/db/dao/impl/PgConRemoveDaoImp.java @@ -0,0 +1,98 @@ +package com.szpg.db.dao.impl; + +import com.szpg.db.dao.PgConRemoveDao; +import com.szpg.db.data.PgConRemoveMsg; +import com.szpg.db.util.ConnectionManager; +import org.apache.commons.dbutils.DbUtils; +import org.apache.commons.dbutils.QueryRunner; +import org.apache.commons.dbutils.handlers.BeanListHandler; +import org.apache.log4j.Logger; + +import java.sql.Connection; +import java.sql.SQLException; +import java.util.ArrayList; +import java.util.List; + +public class PgConRemoveDaoImp implements PgConRemoveDao { + + private org.apache.log4j.Logger logger = Logger.getLogger(this.getClass().getName()); + + @Override + public void addConRemove(List pgConRemoveMsgList){ + Connection conn = null; + + String insertStr = "INSERT INTO PG_CON_REMOVE_MSG " + + "(XD_DATE, XD_END_TIME, XD_SUPERVISOR,XD_FIELD_SITUATION,XD_REMARKS,XD_APPROVER,XD_APPROVER_TIME,LOG_DATE)" + + "VALUES (?,?,?,?,?,?,?,?)"; + + List paramObjectList=new ArrayList<>(); + for(PgConRemoveMsg pgConRemoveMsg:pgConRemoveMsgList){ + + Object[] params = new Object[34]; + params[0] = pgConRemoveMsg.getXD_DATE(); + params[1] = pgConRemoveMsg.getXD_END_TIME(); + params[2] = pgConRemoveMsg.getXD_SUPERVISOR(); + params[3] = pgConRemoveMsg.getXD_FIELD_SITUATION(); + params[4] = pgConRemoveMsg.getXD_REMARKS(); + params[5] = pgConRemoveMsg.getXD_APPROVER(); + params[6] = pgConRemoveMsg.getXD_APPROVER_TIME(); + params[7] = pgConRemoveMsg.getLOG_DATE(); + + paramObjectList.add(params); + } + try { + conn = ConnectionManager.getConnectionFromC3P0(); + conn.setAutoCommit(false); + + QueryRunner runner = new QueryRunner(); + for (Object[] params:paramObjectList) { + int count = runner.update(conn, insertStr, params); + if (count > 0) + logger.info("施工消点数据同步成功" + pgConRemoveMsgList.toString()); + else + logger.info("施工消点数据同步失败！"); + } + + } catch (Exception ex) { + logger.info("施工作业数据同步异常", ex); + } finally { + try { + DbUtils.commitAndClose(conn); + } catch (SQLException e) { + e.printStackTrace(); + } + } + } + + @Override + public String findLastRecordTime(){ + Connection conn = null; + + String queryStr = "SELECT * FROM PG_CON_REMOVE_MSG ORDER BY LOG_DATE DESC"; + try { + conn = ConnectionManager.getConnectionFromC3P0(); + conn.setAutoCommit(false); + + QueryRunner runner = new QueryRunner(); + List pgConRemoveMsgList = (List) runner.query(conn, + queryStr, new BeanListHandler(PgConRemoveMsg.class)); + + if (null != pgConRemoveMsgList && pgConRemoveMsgList.isEmpty() == false) { + logger.debug("获取最新施工消点记录成功[" + pgConRemoveMsgList + "]"); + return pgConRemoveMsgList.get(0).getLOG_DATE(); + } + else + return null; + } catch (Exception ex) { + logger.error("获取最新施工消点记录异常", ex); + } finally { + try { + DbUtils.commitAndClose(conn); + } catch (SQLException e) { + e.printStackTrace(); + } + } + return null; + } + +} diff --git a/src/com/szpg/db/dao/impl/PgConRequestMsgDaoImp.java b/src/com/szpg/db/dao/impl/PgConRequestMsgDaoImp.java new file mode 100644 index 0000000..d763e19 --- /dev/null +++ b/src/com/szpg/db/dao/impl/PgConRequestMsgDaoImp.java @@ -0,0 +1,108 @@ +package com.szpg.db.dao.impl; + +import com.szpg.db.dao.PgConRequestMsgDao; +import com.szpg.db.data.PgConRequestMsg; +import com.szpg.db.data.PgConWorkOrder; +import com.szpg.db.util.ConnectionManager; +import org.apache.commons.dbutils.DbUtils; +import org.apache.commons.dbutils.QueryRunner; +import org.apache.commons.dbutils.handlers.BeanListHandler; +import org.apache.log4j.Logger; + +import java.sql.Connection; +import java.sql.SQLException; +import java.util.ArrayList; +import java.util.Date; +import java.util.List; + +public class PgConRequestMsgDaoImp implements PgConRequestMsgDao { + + private org.apache.log4j.Logger logger = Logger.getLogger(this.getClass().getName()); + + @Override + public void addConRequestMsg(List pgConRequestMsgList){ + Connection conn = null; + + String insertStr = "INSERT INTO PG_CON_REQUEST_MSG " + + "(BUILD_TASK_ID, DATE, TASK_ID,BUILD_COMPANY,SUPERVISOR_TEL,TEL,BUILD_PLACE,BUILD_TIME,START_PLACE," + + "END_PLACE,PROJECT,BUILD_CONTENT,APPROVER,APPROVER_TIME,LOG_DATE)" + + "VALUES (?,?,?,?,?,?,?,?,?,?,?,?,?,?,?)"; + + List paramObjectList=new ArrayList<>(); + for(PgConRequestMsg pgConRequestMsg:pgConRequestMsgList){ + + Object[] params = new Object[34]; + params[0] = pgConRequestMsg.getBUILD_TASK_ID(); + params[1] = pgConRequestMsg.getDATE(); + params[2] = pgConRequestMsg.getTASK_ID(); + params[3] = pgConRequestMsg.getBUILD_COMPANY(); + params[4] = pgConRequestMsg.getSUPERVISOR_TEL(); + params[5] = pgConRequestMsg.getTEL(); + params[6] = pgConRequestMsg.getBUILD_PLACE(); + params[7] = pgConRequestMsg.getBUILD_TIME(); + params[8] = pgConRequestMsg.getSTART_PLACE(); + params[9] = pgConRequestMsg.getEND_PLACE(); + params[10] = pgConRequestMsg.getPROJECT(); + params[11] = pgConRequestMsg.getBUILD_CONTENT(); + params[12] = pgConRequestMsg.getAPPROVER(); + params[13] = pgConRequestMsg.getAPPROVER_TIME(); + params[14] = pgConRequestMsg.getLOG_DATE(); + + paramObjectList.add(params); + } + try { + conn = ConnectionManager.getConnectionFromC3P0(); + conn.setAutoCommit(false); + + QueryRunner runner = new QueryRunner(); + for (Object[] params:paramObjectList) { + int count = runner.update(conn, insertStr, params); + if (count > 0) + logger.info("施工请点数据同步成功" + pgConRequestMsgList.toString()); + else + logger.info("施工请点数据同步失败！"); + } + + } catch (Exception ex) { + logger.info("施工请点数据同步异常", ex); + } finally { + try { + DbUtils.commitAndClose(conn); + } catch (SQLException e) { + e.printStackTrace(); + } + } + } + + @Override + public String findLastRecordTime(){ + Connection conn = null; + + String queryStr = "SELECT * FROM PG_CON_REQUEST_MSG ORDER BY LOG_DATE DESC"; + try { + conn = ConnectionManager.getConnectionFromC3P0(); + conn.setAutoCommit(false); + + QueryRunner runner = new QueryRunner(); + List pgConRequestMsgList = (List) runner.query(conn, + queryStr, new BeanListHandler(PgConRequestMsg.class)); + + if (null != pgConRequestMsgList && pgConRequestMsgList.isEmpty() == false) { + logger.debug("获取最新施工请点记录成功[" + pgConRequestMsgList + "]"); + return pgConRequestMsgList.get(0).getLOG_DATE(); + } + else + return null; + } catch (Exception ex) { + logger.error("获取最新施工请点记录异常", ex); + } finally { + try { + DbUtils.commitAndClose(conn); + } catch (SQLException e) { + e.printStackTrace(); + } + } + return null; + } + +} diff --git a/src/com/szpg/db/dao/impl/PgConWorkOrderDaoImp.java b/src/com/szpg/db/dao/impl/PgConWorkOrderDaoImp.java new file mode 100644 index 0000000..98e2a66 --- /dev/null +++ b/src/com/szpg/db/dao/impl/PgConWorkOrderDaoImp.java @@ -0,0 +1,116 @@ +package com.szpg.db.dao.impl; + +import com.szpg.db.dao.PgConWorkOrderDao; +import com.szpg.db.data.PgAssetInSpectionPlan; +import com.szpg.db.data.PgConWorkOrder; +import com.szpg.db.util.ConnectionManager; +import freemarker.template.utility.DateUtil; +import org.apache.commons.dbutils.DbUtils; +import org.apache.commons.dbutils.QueryRunner; +import org.apache.commons.dbutils.handlers.BeanListHandler; +import org.apache.log4j.Logger; + +import java.sql.Connection; +import java.sql.SQLException; +import java.util.ArrayList; +import java.util.Date; +import java.util.List; + +public class PgConWorkOrderDaoImp implements PgConWorkOrderDao { + + private org.apache.log4j.Logger logger = Logger.getLogger(this.getClass().getName()); + + @Override + public void addConWorkerOrder(List pgConWorkOrderList){ + Connection conn = null; + + String insertStr = "INSERT INTO PG_CON_WORK_ORDER " + + "(KEY_ID, PLAN_NO, TASK_COMPANY,TASK_ID,SUPERVISOR,SUPERVISOR_PHONE,APPLCIANT,APPLCIANT_PHONE,TASK_NAME," + + "TASK_PLACE,TASK_DATE,TASK_DATE_END,PROJECT,TASK_CONTENT,TASK_SAFETY_MEASURES," + + "TASK_PEOPLE_NUM,TASK_INFLUENCE,COMPLETION_OF_THE_SITUATION,REMARKS,BUILD_STATE,LOG_DATE)" + + "VALUES (?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?)"; + + List paramObjectList=new ArrayList<>(); + for(PgConWorkOrder pgConWorkOrder:pgConWorkOrderList){ + + Object[] params = new Object[34]; + params[0] = pgConWorkOrder.getKEY_ID(); + params[1] = pgConWorkOrder.getPLAN_NO(); + params[2] = pgConWorkOrder.getTASK_COMPANY(); + params[3] = pgConWorkOrder.getTASK_ID(); + params[4] = pgConWorkOrder.getSUPERVISOR(); + params[5] = pgConWorkOrder.getSUPERVISOR_PHONE(); + params[6] = pgConWorkOrder.getAPPLCIANT(); + params[7] = pgConWorkOrder.getAPPLCIANT_PHONE(); + params[8] = pgConWorkOrder.getTASK_NAME(); + params[9] = pgConWorkOrder.getTASK_PLACE(); + params[10] = pgConWorkOrder.getTASK_DATE(); + params[11] = pgConWorkOrder.getTASK_DATE_END(); + params[12] = pgConWorkOrder.getPROJECT(); + params[13] = pgConWorkOrder.getTASK_CONTENT(); + params[14] = pgConWorkOrder.getTASK_SAFETY_MEASURES(); + params[15] = pgConWorkOrder.getTASK_PEOPLE_NUM(); + params[16] = pgConWorkOrder.getTASK_INFLUENCE(); + params[17] = pgConWorkOrder.getCOMPLETION_OF_THE_SITUATION(); + params[18] = pgConWorkOrder.getREMARKS(); + params[19] = pgConWorkOrder.getBUILD_STATE(); + params[19] = new Date(); + + paramObjectList.add(params); + } + try { + conn = ConnectionManager.getConnectionFromC3P0(); + conn.setAutoCommit(false); + + QueryRunner runner = new QueryRunner(); + for (Object[] params:paramObjectList) { + int count = runner.update(conn, insertStr, params); + if (count > 0) + logger.info("施工作业数据同步成功" + pgConWorkOrderList.toString()); + else + logger.info("施工作业数据同步失败！"); + } + + } catch (Exception ex) { + logger.info("施工作业数据同步异常", ex); + } finally { + try { + DbUtils.commitAndClose(conn); + } catch (SQLException e) { + e.printStackTrace(); + } + } + } + + @Override + public String findLastRecordTime(){ + Connection conn = null; + + String queryStr = "SELECT * FROM PG_CON_WORK_ORDER ORDER BY LOG_DATE DESC"; + try { + conn = ConnectionManager.getConnectionFromC3P0(); + conn.setAutoCommit(false); + + QueryRunner runner = new QueryRunner(); + List pgConWorkOrderList = (List) runner.query(conn, + queryStr, new BeanListHandler(PgConWorkOrder.class)); + + if (null != pgConWorkOrderList && pgConWorkOrderList.isEmpty() == false) { + logger.debug("获取最新施工记录成功[" + pgConWorkOrderList + "]"); + return pgConWorkOrderList.get(0).getLOG_DATE(); + } + else + return null; + } catch (Exception ex) { + logger.error("获取最新施工记录异常", ex); + } finally { + try { + DbUtils.commitAndClose(conn); + } catch (SQLException e) { + e.printStackTrace(); + } + } + return null; + } + +} diff --git a/src/com/szpg/db/data/PgAssetInSpectionPlan.java b/src/com/szpg/db/data/PgAssetInSpectionPlan.java index fd10c61..c86ec88 100644 --- a/src/com/szpg/db/data/PgAssetInSpectionPlan.java +++ b/src/com/szpg/db/data/PgAssetInSpectionPlan.java @@ -103,7 +103,6 @@ this.RESPONSIBLE_DEPT = RESPONSIBLE_DEPT; } - public String getPLAN_NO() { return PLAN_NO; } @@ -312,5 +311,4 @@ this.UPDATEDATE = UPDATEDATE; } - -} +} \ No newline at end of file diff --git a/src/com/szpg/db/data/PgConRemoveMsg.java b/src/com/szpg/db/data/PgConRemoveMsg.java new file mode 100644 index 0000000..6dcbaa0 --- /dev/null +++ b/src/com/szpg/db/data/PgConRemoveMsg.java @@ -0,0 +1,79 @@ +package com.szpg.db.data; + +import java.io.Serializable; + +public class PgConRemoveMsg implements Serializable { + + private String XD_DATE; + private String XD_END_TIME; + private String XD_SUPERVISOR; + private String XD_FIELD_SITUATION; + private String XD_REMARKS; + private String XD_APPROVER; + private String XD_APPROVER_TIME; + private String LOG_DATE; + + public String getXD_DATE() { + return XD_DATE; + } + + public void setXD_DATE(String XD_DATE) { + this.XD_DATE = XD_DATE; + } + + public String getXD_END_TIME() { + return XD_END_TIME; + } + + public void setXD_END_TIME(String XD_END_TIME) { + this.XD_END_TIME = XD_END_TIME; + } + + public String getXD_SUPERVISOR() { + return XD_SUPERVISOR; + } + + public void setXD_SUPERVISOR(String XD_SUPERVISOR) { + this.XD_SUPERVISOR = XD_SUPERVISOR; + } + + public String getXD_FIELD_SITUATION() { + return XD_FIELD_SITUATION; + } + + public void setXD_FIELD_SITUATION(String XD_FIELD_SITUATION) { + this.XD_FIELD_SITUATION = XD_FIELD_SITUATION; + } + + public String getXD_REMARKS() { + return XD_REMARKS; + } + + public void setXD_REMARKS(String XD_REMARKS) { + this.XD_REMARKS = XD_REMARKS; + } + + public String getXD_APPROVER() { + return XD_APPROVER; + } + + public void setXD_APPROVER(String XD_APPROVER) { + this.XD_APPROVER = XD_APPROVER; + } + + public String getXD_APPROVER_TIME() { + return XD_APPROVER_TIME; + } + + public void setXD_APPROVER_TIME(String XD_APPROVER_TIME) { + this.XD_APPROVER_TIME = XD_APPROVER_TIME; + } + + public String getLOG_DATE() { + return LOG_DATE; + } + + public void setLOG_DATE(String LOG_DATE) { + this.LOG_DATE = LOG_DATE; + } +} diff --git a/src/com/szpg/db/data/PgConRemoveMsgJson.java b/src/com/szpg/db/data/PgConRemoveMsgJson.java new file mode 100644 index 0000000..d3253c5 --- /dev/null +++ b/src/com/szpg/db/data/PgConRemoveMsgJson.java @@ -0,0 +1,53 @@ +package com.szpg.db.data; + +import java.util.List; + +public class PgConRemoveMsgJson { + + private String total; + private String totalRecords; + private String page; + private String records; + private List rows; + + public String getTotal() { + return total; + } + + public void setTotal(String total) { + this.total = total; + } + + public String getTotalRecords() { + return totalRecords; + } + + public void setTotalRecords(String totalRecords) { + this.totalRecords = totalRecords; + } + + public String getPage() { + return page; + } + + public void setPage(String page) { + this.page = page; + } + + public String getRecords() { + return records; + } + + public void setRecords(String records) { + this.records = records; + } + + public List getRows() { + return rows; + } + + public void setRows(List rows) { + this.rows = rows; + } + +} \ No newline at end of file diff --git a/src/com/szpg/db/data/PgConRequestMsg.java b/src/com/szpg/db/data/PgConRequestMsg.java new file mode 100644 index 0000000..fddd30a --- /dev/null +++ b/src/com/szpg/db/data/PgConRequestMsg.java @@ -0,0 +1,142 @@ +package com.szpg.db.data; + +import java.io.Serializable; + +public class PgConRequestMsg implements Serializable { + + private String BUILD_TASK_ID;//作业令编号 + private String DATE;//请点日期 + private String TASK_ID;//作业代码 + private String BUILD_COMPANY;//施工单位 + private String SUPERVISOR_TEL;//请点负责人 + private String TEL;//负责人电话 + private String BUILD_PLACE;//请点地点 + private String BUILD_TIME;//请点时间 + private String START_PLACE;//起始位置 + private String END_PLACE;//结束位置 + private String PROJECT;//所属项目 CBL：城北路，CYL：城阳路，THXC:太湖新城 + private String BUILD_CONTENT;//施工内容 + private String APPROVER;//批准人 + private String APPROVER_TIME;//批准时间 + private String LOG_DATE; + + public String getBUILD_TASK_ID() { + return BUILD_TASK_ID; + } + + public void setBUILD_TASK_ID(String BUILD_TASK_ID) { + this.BUILD_TASK_ID = BUILD_TASK_ID; + } + + public String getDATE() { + return DATE; + } + + public void setDATE(String DATE) { + this.DATE = DATE; + } + + public String getTASK_ID() { + return TASK_ID; + } + + public void setTASK_ID(String TASK_ID) { + this.TASK_ID = TASK_ID; + } + + public String getBUILD_COMPANY() { + return BUILD_COMPANY; + } + + public void setBUILD_COMPANY(String BUILD_COMPANY) { + this.BUILD_COMPANY = BUILD_COMPANY; + } + + public String getSUPERVISOR_TEL() { + return SUPERVISOR_TEL; + } + + public void setSUPERVISOR_TEL(String SUPERVISOR_TEL) { + this.SUPERVISOR_TEL = SUPERVISOR_TEL; + } + + public String getTEL() { + return TEL; + } + + public void setTEL(String TEL) { + this.TEL = TEL; + } + + public String getBUILD_PLACE() { + return BUILD_PLACE; + } + + public void setBUILD_PLACE(String BUILD_PLACE) { + this.BUILD_PLACE = BUILD_PLACE; + } + + public String getBUILD_TIME() { + return BUILD_TIME; + } + + public void setBUILD_TIME(String BUILD_TIME) { + this.BUILD_TIME = BUILD_TIME; + } + + public String getSTART_PLACE() { + return START_PLACE; + } + + public void setSTART_PLACE(String START_PLACE) { + this.START_PLACE = START_PLACE; + } + + public String getEND_PLACE() { + return END_PLACE; + } + + public void setEND_PLACE(String END_PLACE) { + this.END_PLACE = END_PLACE; + } + + public String getPROJECT() { + return PROJECT; + } + + public void setPROJECT(String PROJECT) { + this.PROJECT = PROJECT; + } + + public String getBUILD_CONTENT() { + return BUILD_CONTENT; + } + + public void setBUILD_CONTENT(String BUILD_CONTENT) { + this.BUILD_CONTENT = BUILD_CONTENT; + } + + public String getAPPROVER() { + return APPROVER; + } + + public void setAPPROVER(String APPROVER) { + this.APPROVER = APPROVER; + } + + public String getAPPROVER_TIME() { + return APPROVER_TIME; + } + + public void setAPPROVER_TIME(String APPROVER_TIME) { + this.APPROVER_TIME = APPROVER_TIME; + } + + public String getLOG_DATE() { + return LOG_DATE; + } + + public void setLOG_DATE(String LOG_DATE) { + this.LOG_DATE = LOG_DATE; + } +} diff --git a/src/com/szpg/db/data/PgConRequestMsgJson.java b/src/com/szpg/db/data/PgConRequestMsgJson.java new file mode 100644 index 0000000..29ab61f --- /dev/null +++ b/src/com/szpg/db/data/PgConRequestMsgJson.java @@ -0,0 +1,52 @@ +package com.szpg.db.data; + +import java.util.List; + +public class PgConRequestMsgJson { + + private String total; + private String totalRecords; + private String page; + private String records; + private List rows; + + public String getTotal() { + return total; + } + + public void setTotal(String total) { + this.total = total; + } + + public String getTotalRecords() { + return totalRecords; + } + + public void setTotalRecords(String totalRecords) { + this.totalRecords = totalRecords; + } + + public String getPage() { + return page; + } + + public void setPage(String page) { + this.page = page; + } + + public String getRecords() { + return records; + } + + public void setRecords(String records) { + this.records = records; + } + + public List getRows() { + return rows; + } + + public void setRows(List rows) { + this.rows = rows; + } +} diff --git a/src/com/szpg/db/data/PgConWorkOrder.java b/src/com/szpg/db/data/PgConWorkOrder.java new file mode 100644 index 0000000..7e39c59 --- /dev/null +++ b/src/com/szpg/db/data/PgConWorkOrder.java @@ -0,0 +1,196 @@ +package com.szpg.db.data; + +import java.io.Serializable; + +public class PgConWorkOrder implements Serializable { + + private String KEY_ID;//GUID字段 + private String PLAN_NO;//计划申请单号 + private String TASK_COMPANY;//作业单位 + private String TASK_ID;//作业编号 + private String SUPERVISOR;//负责人 + private String SUPERVISOR_PHONE;//负责人联系方式 + private String APPLCIANT;//申报人 + private String APPLCIANT_PHONE;//申报人联系方式 + private String TASK_NAME;//作业名称 + private String TASK_PLACE;//作业区域 + private String TASK_DATE;//作业开始日期 + private String TASK_DATE_END;//作业结束日期 + private String PROJECT;//所属项目 CBL：城北路，CYL：城阳路，THXC:太湖新城 + private String TASK_CONTENT;//作业内容 + private String TASK_SAFETY_MEASURES;//作业安全措施 + private String TASK_PEOPLE_NUM;//人数及施工人员 + private String TASK_INFLUENCE;//施工影响 1：A类，2：B类，3：C类 + private String COMPLETION_OF_THE_SITUATION;//完成情况 + private String REMARKS;//备注 + private String BUILD_STATE;//施工状态 申请=1，进入=2，延期=3，验收=4 + private String LOG_DATE; + + public String getKEY_ID() { + return KEY_ID; + } + + public void setKEY_ID(String KEY_ID) { + this.KEY_ID = KEY_ID; + } + + public String getPLAN_NO() { + return PLAN_NO; + } + + public void setPLAN_NO(String PLAN_NO) { + this.PLAN_NO = PLAN_NO; + } + + public String getTASK_COMPANY() { + return TASK_COMPANY; + } + + public void setTASK_COMPANY(String TASK_COMPANY) { + this.TASK_COMPANY = TASK_COMPANY; + } + + public String getTASK_ID() { + return TASK_ID; + } + + public void setTASK_ID(String TASK_ID) { + this.TASK_ID = TASK_ID; + } + + public String getSUPERVISOR() { + return SUPERVISOR; + } + + public void setSUPERVISOR(String SUPERVISOR) { + this.SUPERVISOR = SUPERVISOR; + } + + public String getSUPERVISOR_PHONE() { + return SUPERVISOR_PHONE; + } + + public void setSUPERVISOR_PHONE(String SUPERVISOR_PHONE) { + this.SUPERVISOR_PHONE = SUPERVISOR_PHONE; + } + + public String getAPPLCIANT() { + return APPLCIANT; + } + + public void setAPPLCIANT(String APPLCIANT) { + this.APPLCIANT = APPLCIANT; + } + + public String getAPPLCIANT_PHONE() { + return APPLCIANT_PHONE; + } + + public void setAPPLCIANT_PHONE(String APPLCIANT_PHONE) { + this.APPLCIANT_PHONE = APPLCIANT_PHONE; + } + + public String getTASK_NAME() { + return TASK_NAME; + } + + public void setTASK_NAME(String TASK_NAME) { + this.TASK_NAME = TASK_NAME; + } + + public String getTASK_PLACE() { + return TASK_PLACE; + } + + public void setTASK_PLACE(String TASK_PLACE) { + this.TASK_PLACE = TASK_PLACE; + } + + public String getTASK_DATE() { + return TASK_DATE; + } + + public void setTASK_DATE(String TASK_DATE) { + this.TASK_DATE = TASK_DATE; + } + + public String getTASK_DATE_END() { + return TASK_DATE_END; + } + + public void setTASK_DATE_END(String TASK_DATE_END) { + this.TASK_DATE_END = TASK_DATE_END; + } + + public String getPROJECT() { + return PROJECT; + } + + public void setPROJECT(String PROJECT) { + this.PROJECT = PROJECT; + } + + public String getTASK_CONTENT() { + return TASK_CONTENT; + } + + public void setTASK_CONTENT(String TASK_CONTENT) { + this.TASK_CONTENT = TASK_CONTENT; + } + + public String getTASK_SAFETY_MEASURES() { + return TASK_SAFETY_MEASURES; + } + + public void setTASK_SAFETY_MEASURES(String TASK_SAFETY_MEASURES) { + this.TASK_SAFETY_MEASURES = TASK_SAFETY_MEASURES; + } + + public String getTASK_PEOPLE_NUM() { + return TASK_PEOPLE_NUM; + } + + public void setTASK_PEOPLE_NUM(String TASK_PEOPLE_NUM) { + this.TASK_PEOPLE_NUM = TASK_PEOPLE_NUM; + } + + public String getTASK_INFLUENCE() { + return TASK_INFLUENCE; + } + + public void setTASK_INFLUENCE(String TASK_INFLUENCE) { + this.TASK_INFLUENCE = TASK_INFLUENCE; + } + + public String getCOMPLETION_OF_THE_SITUATION() { + return COMPLETION_OF_THE_SITUATION; + } + + public void setCOMPLETION_OF_THE_SITUATION(String COMPLETION_OF_THE_SITUATION) { + this.COMPLETION_OF_THE_SITUATION = COMPLETION_OF_THE_SITUATION; + } + + public String getREMARKS() { + return REMARKS; + } + + public void setREMARKS(String REMARKS) { + this.REMARKS = REMARKS; + } + + public String getBUILD_STATE() { + return BUILD_STATE; + } + + public void setBUILD_STATE(String BUILD_STATE) { + this.BUILD_STATE = BUILD_STATE; + } + + public String getLOG_DATE() { + return LOG_DATE; + } + + public void setLOG_DATE(String LOG_DATE) { + this.LOG_DATE = LOG_DATE; + } +} \ No newline at end of file diff --git a/src/com/szpg/db/data/PgConWorkOrderJson.java b/src/com/szpg/db/data/PgConWorkOrderJson.java new file mode 100644 index 0000000..37160c7 --- /dev/null +++ b/src/com/szpg/db/data/PgConWorkOrderJson.java @@ -0,0 +1,53 @@ +package com.szpg.db.data; + +import java.util.List; + +public class PgConWorkOrderJson { + + private String total; + private String totalRecords; + private String page; + private String records; + private List rows; + + public String getTotal() { + return total; + } + + public void setTotal(String total) { + this.total = total; + } + + public String getTotalRecords() { + return totalRecords; + } + + public void setTotalRecords(String totalRecords) { + this.totalRecords = totalRecords; + } + + public String getPage() { + return page; + } + + public void setPage(String page) { + this.page = page; + } + + public String getRecords() { + return records; + } + + public void setRecords(String records) { + this.records = records; + } + + public List getRows() { + return rows; + } + + public void setRows(List rows) { + this.rows = rows; + } + +} \ No newline at end of file diff --git a/src/com/szpg/task/ReadConRemoveTask.java b/src/com/szpg/task/ReadConRemoveTask.java new file mode 100644 index 0000000..6a52501 --- /dev/null +++ b/src/com/szpg/task/ReadConRemoveTask.java @@ -0,0 +1,98 @@ +package com.szpg.task; + +import com.alibaba.fastjson.JSON; +import com.alibaba.fastjson.JSONObject; +import com.alibaba.fastjson.TypeReference; +import com.szpg.db.dao.PgConRemoveDao; +import com.szpg.db.dao.impl.PgConRemoveDaoImp; +import com.szpg.db.data.PgConRemoveMsg; +import com.szpg.db.data.PgConRemoveMsgJson; +import com.szpg.util.HttpRequest; +import org.apache.log4j.Logger; + +import java.text.SimpleDateFormat; +import java.util.Calendar; +import java.util.Date; +import java.util.List; + +public class ReadConRemoveTask implements Runnable { + + private org.apache.log4j.Logger logger = Logger.getLogger(this.getClass().getName()); + final String tableName="ASSET_INSPECTION_PLAN1";// + final String url="http://10.10.2.31:9056/GLYW/api/Common/LoadIndexData"; + SimpleDateFormat dateFormat = new SimpleDateFormat("yyyy-MM-dd"); + + @Override + public void run(){ + PgConRemoveDao pgConRemoveDao=new PgConRemoveDaoImp(); + + try { + String endTime = dateFormat.format(new Date());//当前时间 + + String startTime = pgConRemoveDao.findLastRecordTime();//上次同步数据最后记录时间 + if (startTime == null) { + Date dt = new Date();; + startTime = getStartDateStr(dt, -1);; + } + else + { + Date dtStart = dateFormat.parse(startTime); + startTime=getStartDateStr(dtStart,1);; + } + + StringBuilder sb = new StringBuilder(); + sb.append("tableName=").append(tableName); + sb.append("&page=-1"); + sb.append("&strWhere= LOG_DATE");; + sb.append(" between '").append(startTime); + sb.append("' and '").append(endTime); + sb.append("'"); + + logger.info("开始请求施工消点数据"); + String jsonStr = HttpRequest.sendPostByHttp(url, sb.toString()); + if (jsonStr.equals("")) + logger.error("施工消点数据请求失败"); + else { + insertDB(pgConRemoveDao, jsonStr); + logger.error("施工消点数据存储成功"); + } + } + catch(Exception ex) + { + ex.printStackTrace(); + } + } + + public void insertDB(PgConRemoveDao pgConRemoveDao,String jsonStr) + { + List pgConRemoveMsgList= getAssetByJsonString(jsonStr); + logger.info("同步施工消点数据条数："+ String.valueOf(pgConRemoveMsgList.size())); + pgConRemoveDao.addConRemove(pgConRemoveMsgList); + } + + private List getAssetByJsonString(String jsonStr){ + try { + String jsonString=String.valueOf(JSON.parse(jsonStr)); + PgConRemoveMsgJson pgConRemoveMsgJson = JSONObject.parseObject(jsonString, new TypeReference() {}); + List pgConRemoveMsgList = pgConRemoveMsgJson.getRows(); + return pgConRemoveMsgList; + } + catch(Exception ex){ + logger.error(ex.getMessage()); + return null; + } + + } + + public String getStartDateStr(Date dt,int d) { + + String yesToday = ""; + Date dtt = (Date) dt.clone(); + Calendar calendar = Calendar.getInstance(); + calendar.setTime(dtt); + calendar.add(Calendar.DAY_OF_MONTH, d);; + yesToday = dateFormat.format(calendar.getTime()); + + return yesToday; + } +} diff --git a/src/com/szpg/task/ReadConRequestTask.java b/src/com/szpg/task/ReadConRequestTask.java new file mode 100644 index 0000000..7c9fe7b --- /dev/null +++ b/src/com/szpg/task/ReadConRequestTask.java @@ -0,0 +1,99 @@ +package com.szpg.task; + +import com.alibaba.fastjson.JSON; +import com.alibaba.fastjson.JSONObject; +import com.alibaba.fastjson.TypeReference; +import com.szpg.db.dao.PgConRequestMsgDao; +import com.szpg.db.dao.impl.PgConRequestMsgDaoImp; +import com.szpg.db.data.PgConRequestMsg; +import com.szpg.db.data.PgConRequestMsgJson; +import com.szpg.util.HttpRequest; +import org.apache.log4j.Logger; + +import java.text.SimpleDateFormat; +import java.util.Calendar; +import java.util.Date; +import java.util.List; + +public class ReadConRequestTask implements Runnable{ + + private org.apache.log4j.Logger logger = Logger.getLogger(this.getClass().getName()); + final String tableName="ASSET_INSPECTION_PLAN";// + final String url="http://10.10.2.31:9056/GLYW/api/Common/LoadIndexData"; + SimpleDateFormat dateFormat = new SimpleDateFormat("yyyy-MM-dd"); + + @Override + public void run(){ + PgConRequestMsgDao pgConRequestMsgDao=new PgConRequestMsgDaoImp(); + + try { + String endTime = dateFormat.format(new Date());//当前时间 + + String startTime = pgConRequestMsgDao.findLastRecordTime();//上次同步数据最后记录时间 + if (startTime == null) { + Date dt = new Date();; + startTime = getStartDateStr(dt, -1);; + } + else + { + Date dtStart = dateFormat.parse(startTime); + startTime=getStartDateStr(dtStart,1); + } + + StringBuilder sb = new StringBuilder(); + sb.append("tableName=").append(tableName); + sb.append("&page=-1"); + sb.append("&strWhere= LOG_DATE");; + sb.append(" between '").append(startTime); + sb.append("' and '").append(endTime); + sb.append("'"); + + logger.info("开始请求施工请点数据"); + String jsonStr = HttpRequest.sendPostByHttp(url, sb.toString()); + if (jsonStr.equals("")) + logger.error("施工请点数据请求失败"); + else { + insertDB(pgConRequestMsgDao, jsonStr); + logger.error("施工请点数据存储成功"); + } + } + catch(Exception ex) + { + ex.printStackTrace(); + } + } + + public void insertDB(PgConRequestMsgDao pgConRequestMsgDao,String jsonStr) + { + List pgConRequestMsgList= getAssetByJsonString(jsonStr); + logger.info("同步施工请点数据条数："+ String.valueOf(pgConRequestMsgList.size())); + pgConRequestMsgDao.addConRequestMsg(pgConRequestMsgList); + } + + private List getAssetByJsonString(String jsonStr){ + try { + String jsonString=String.valueOf(JSON.parse(jsonStr)); + PgConRequestMsgJson pgConRequestMsgJson = JSONObject.parseObject(jsonString, new TypeReference() {}); + List pgConRequestMsgList = pgConRequestMsgJson.getRows(); + return pgConRequestMsgList; + } + catch(Exception ex){ + logger.error(ex.getMessage()); + return null; + } + + } + + public String getStartDateStr(Date dt,int d) { + + String yesToday = ""; + Date dtt = (Date) dt.clone(); + Calendar calendar = Calendar.getInstance(); + calendar.setTime(dtt); + calendar.add(Calendar.DAY_OF_MONTH, d); + yesToday = dateFormat.format(calendar.getTime());; + + return yesToday; + } + +} diff --git a/src/com/szpg/task/ReadConWorkOrderTask.java b/src/com/szpg/task/ReadConWorkOrderTask.java new file mode 100644 index 0000000..8bd75c7 --- /dev/null +++ b/src/com/szpg/task/ReadConWorkOrderTask.java @@ -0,0 +1,98 @@ +package com.szpg.task; + +import com.alibaba.fastjson.JSON; +import com.alibaba.fastjson.JSONObject; +import com.alibaba.fastjson.TypeReference; +import com.szpg.db.dao.PgConWorkOrderDao; +import com.szpg.db.dao.impl.PgConWorkOrderDaoImp; +import com.szpg.db.data.PgConWorkOrder; +import com.szpg.db.data.PgConWorkOrderJson; +import com.szpg.util.HttpRequest; +import org.apache.log4j.Logger; + +import java.text.SimpleDateFormat; +import java.util.Calendar; +import java.util.Date; +import java.util.List; + +public class ReadConWorkOrderTask implements Runnable { + + private org.apache.log4j.Logger logger = Logger.getLogger(this.getClass().getName()); + final String tableName="ASSET_INSPECTION_PLAN";// + final String url="http://10.10.2.31:9056/GLYW/api/Common/LoadIndexData"; + SimpleDateFormat dateFormat = new SimpleDateFormat("yyyy-MM-dd"); + + @Override + public void run(){ + PgConWorkOrderDao pgConWorkOrderDao=new PgConWorkOrderDaoImp(); + + try { + String endTime = dateFormat.format(new Date());//当前时间 + + String startTime = pgConWorkOrderDao.findLastRecordTime();//上次同步数据最后记录时间 + if (startTime == null) { + Date dt = new Date();; + startTime = getStartDateStr(dt, -1); + } + else + { + Date dtStart = dateFormat.parse(startTime); + startTime=getStartDateStr(dtStart,1); + } + + StringBuilder sb = new StringBuilder(); + sb.append("tableName=").append(tableName); + sb.append("&page=-1"); + sb.append("&strWhere= LOG_DATE"); + sb.append(" between '").append(startTime); + sb.append("' and '").append(endTime); + sb.append("'"); + + logger.info("开始请求施工作业数据"); + String jsonStr = HttpRequest.sendPostByHttp(url, sb.toString()); + if (jsonStr.equals("")) + logger.error("施工作业数据请求失败"); + else { + insertDB(pgConWorkOrderDao, jsonStr); + logger.error("施工作业数据存储成功"); + } + } + catch(Exception ex) + { + ex.printStackTrace(); + } + } + + public void insertDB(PgConWorkOrderDao pgConWorkOrderDao,String jsonStr) + { + List pgConWorkOrderList= getAssetByJsonString(jsonStr); + logger.info("同步施工作业数据条数："+ String.valueOf(pgConWorkOrderList.size())); + pgConWorkOrderDao.addConWorkerOrder(pgConWorkOrderList); + } + + private List getAssetByJsonString(String jsonStr){ + try { + String jsonString=String.valueOf(JSON.parse(jsonStr)); + PgConWorkOrderJson pgConWorkOrderJson = JSONObject.parseObject(jsonString, new TypeReference() {}); + List pgConWorkOrderList = pgConWorkOrderJson.getRows(); + return pgConWorkOrderList; + } + catch(Exception ex){ + logger.error(ex.getMessage()); + return null; + } + + } + + public String getStartDateStr(Date dt,int d) { + + String yesToday = ""; + Date dtt = (Date) dt.clone(); + Calendar calendar = Calendar.getInstance(); + calendar.setTime(dtt);; + calendar.add(Calendar.DAY_OF_MONTH, d); + yesToday = dateFormat.format(calendar.getTime()); + + return yesToday; + } +}