diff --git a/.idea/.gitignore b/.idea/.gitignore new file mode 100644 index 0000000..359bb53 --- /dev/null +++ b/.idea/.gitignore @@ -0,0 +1,3 @@ +# 默认忽略的文件 +/shelf/ +/workspace.xml diff --git a/.idea/compiler.xml b/.idea/compiler.xml new file mode 100644 index 0000000..357b45b --- /dev/null +++ b/.idea/compiler.xml @@ -0,0 +1,19 @@ + + + + + + + + + + + + + + + + + \ No newline at end of file diff --git a/.idea/encodings.xml b/.idea/encodings.xml new file mode 100644 index 0000000..63574ec --- /dev/null +++ b/.idea/encodings.xml @@ -0,0 +1,8 @@ + + + + + + + + \ No newline at end of file diff --git a/.idea/inspectionProfiles/Project_Default.xml b/.idea/inspectionProfiles/Project_Default.xml new file mode 100644 index 0000000..4b4cb0e --- /dev/null +++ b/.idea/inspectionProfiles/Project_Default.xml @@ -0,0 +1,6 @@ + + + + \ No newline at end of file diff --git a/.idea/jarRepositories.xml b/.idea/jarRepositories.xml new file mode 100644 index 0000000..712ab9d --- /dev/null +++ b/.idea/jarRepositories.xml @@ -0,0 +1,20 @@ + + + + + + + + + + + \ No newline at end of file diff --git a/.idea/misc.xml b/.idea/misc.xml new file mode 100644 index 0000000..6f5230a --- /dev/null +++ b/.idea/misc.xml @@ -0,0 +1,13 @@ + + + + + + + + + \ No newline at end of file diff --git a/.idea/uiDesigner.xml b/.idea/uiDesigner.xml new file mode 100644 index 0000000..2b63946 --- /dev/null +++ b/.idea/uiDesigner.xml @@ -0,0 +1,124 @@ + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + \ No newline at end of file diff --git a/.idea/vcs.xml b/.idea/vcs.xml new file mode 100644 index 0000000..94a25f7 --- /dev/null +++ b/.idea/vcs.xml @@ -0,0 +1,6 @@ + + + + + + \ No newline at end of file diff --git a/pom.xml b/pom.xml index 905408c..a386647 100644 --- a/pom.xml +++ b/pom.xml @@ -24,6 +24,12 @@ + + com.auth0 + java-jwt + 3.4.0 + + org.springframework.boot spring-boot-starter-web @@ -108,6 +114,6 @@ spring-boot-maven-plugin - + \ No newline at end of file diff --git a/src/main/java/com/xydl/service/impl/EiaServiceImpl.java b/src/main/java/com/xydl/service/impl/EiaServiceImpl.java index 4acda12..6ae87fa 100644 --- a/src/main/java/com/xydl/service/impl/EiaServiceImpl.java +++ b/src/main/java/com/xydl/service/impl/EiaServiceImpl.java @@ -146,7 +146,7 @@ public class EiaServiceImpl implements EiaService { List tableNames = new ArrayList<>(); try { conn = DataSourceUtils.getConnection(); - String sql = "select DISTINCT table_name from sync_tables_info"; + String sql = "select table_name from sync_tables_info"; pstmt = conn.prepareStatement(sql); rs = pstmt.executeQuery(); @@ -189,45 +189,69 @@ public class EiaServiceImpl implements EiaService { return fieldsMap; } - public String getLastRecordTimeSended(String tableName,String deviceId) { - Connection conn = null; - PreparedStatement pstmt = null; - ResultSet rs = null; - Timestamp timeStamp = null; - try { - conn = DataSourceUtils.getConnection(); - String sql = "select field_val2 from sync_records where table_name =? and devid_val=?"; - pstmt = conn.prepareStatement(sql); - pstmt.setString(1, tableName); - pstmt.setString(2, deviceId); - rs = pstmt.executeQuery(); - if(rs.next()){ - timeStamp = rs.getTimestamp("field_val2"); - - } - } catch (SQLException e) { - logger.error("execute sql exception:", e); - } finally { - DataSourceUtils.closeResource(rs, pstmt, conn); - } - - return new SimpleDateFormat("yyyy-MM-dd HH:mm:ss").format(timeStamp); - } +// public String getLastRecordTimeSended(String tableName,String deviceId) { +// Connection conn = null; +// PreparedStatement pstmt = null; +// ResultSet rs = null; +// Timestamp timeStamp = null; +// try { +// conn = DataSourceUtils.getConnection(); +// String sql = "select field_val2 from sync_records where table_name =? and devid_val=?"; +// pstmt = conn.prepareStatement(sql); +// pstmt.setString(1, tableName); +// pstmt.setString(2, deviceId); +// rs = pstmt.executeQuery(); +// if(rs.next()){ +// timeStamp = rs.getTimestamp("field_val2"); +// +// } +// } catch (SQLException e) { +// logger.error("execute sql exception:", e); +// } finally { +// DataSourceUtils.closeResource(rs, pstmt, conn); +// } +// +// return new SimpleDateFormat("yyyy-MM-dd HH:mm:ss").format(timeStamp); +// } + +// public List getDeviceID(String tableName) { +// Connection conn = null; +// PreparedStatement pstmt = null; +// ResultSet rs = null; +// String sqlExecuting = null ; +// List deviceIDs = new ArrayList<>(); +// try { +// conn = DataSourceUtils.getConnection(); +// String sql = "select distinct devid_val from sync_records where table_name =?"; +// pstmt = conn.prepareStatement(sql); +// pstmt.setString(1, tableName); +// rs = pstmt.executeQuery(); +// while(rs.next()){ +// deviceIDs.add(rs.getString("devid_val")); +// } +// } catch (SQLException e) { +// logger.error("execute sql exception:", e); +// } finally { +// DataSourceUtils.closeResource(rs, pstmt, conn); +// } +// +// return deviceIDs; +// } - public List getDeviceID(String tableName) { + public Map getDeviceID1(String tableName) { Connection conn = null; PreparedStatement pstmt = null; ResultSet rs = null; String sqlExecuting = null ; - List deviceIDs = new ArrayList<>(); + Map devIDTimeMap = new HashMap<>(); try { conn = DataSourceUtils.getConnection(); - String sql = "select distinct devid_val from sync_records where table_name =?"; + String sql = "select devid_val,field_val2 from sync_records where table_name =?"; pstmt = conn.prepareStatement(sql); pstmt.setString(1, tableName); rs = pstmt.executeQuery(); while(rs.next()){ - deviceIDs.add(rs.getString("devid_val")); + devIDTimeMap.put(rs.getString("devid_val"),rs.getString("field_val2")); } } catch (SQLException e) { logger.error("execute sql exception:", e); @@ -235,7 +259,7 @@ public class EiaServiceImpl implements EiaService { DataSourceUtils.closeResource(rs, pstmt, conn); } - return deviceIDs; + return devIDTimeMap; } public String getSQL(String tableName) { @@ -293,111 +317,177 @@ public class EiaServiceImpl implements EiaService { } +// @Scheduled(initialDelay=1000, fixedRate = 1000 * 3600) //通过@Scheduled声明该方法是计划任务，使用fixedRate属性每隔固定时间执行 +// public void reportRecord(){ +// List allTableNames = getAllTableName(); +// Map> tableFieldMap = new HashMap<>(); +// Map>>>> allTableData = new HashMap<>(); +// for(String tablenName : allTableNames){ +// //if用来测试 +// if(!"data_eaif_h".equals(tablenName)){ +// Map fieldMap = getFieldMap(tablenName); +// tableFieldMap.put(tablenName,fieldMap); +// +// String sqlExecuting = getSQL(tablenName); +// List deviceIDs = getDeviceID(tablenName); +// List>>> dataOfoneTable = new ArrayList<>(); +// for(String deviceID : deviceIDs){ +// Map>> deviceIDMap = new HashMap<>(); +// String timeStamp = getLastRecordTimeSended(tablenName,deviceID); +// List> dataOfoneDeviceID = getData(sqlExecuting,deviceID,timeStamp); +// +// deviceIDMap.put(deviceID,dataOfoneDeviceID); +// dataOfoneTable.add(deviceIDMap); +// } +// allTableData.put(tablenName,dataOfoneTable); +// } +// +// } +// System.out.println("旧数据： "+allTableData); +// System.out.println("==============================="); +// +// +// Map>>>> newAllData = new HashMap<>(); +// for(Map.Entry>>>> dataEntry : allTableData.entrySet()){ +// List>>> newRecords = transformFields(dataEntry.getKey(),tableFieldMap,dataEntry.getValue()); +// newAllData.put(dataEntry.getKey(),newRecords); +// } +// +// for(String tableName : newAllData.keySet()){ +// List>>> records = newAllData.get(tableName); +// String jsonStringData = FormatUtil.list2Json(records); +// if(MqttUtil.publish2MQTT(jsonStringData)){ +// updateLastRecordTimeSended(tableName,records); +// }else{ +// System.out.println("消息推送失败"); +// } +// } +// +// } + @Scheduled(initialDelay=1000, fixedRate = 1000 * 3600) //通过@Scheduled声明该方法是计划任务，使用fixedRate属性每隔固定时间执行 - public void reportRecord(){ + public void reportRecord1(){ List allTableNames = getAllTableName(); Map> tableFieldMap = new HashMap<>(); Map>>>> allTableData = new HashMap<>(); - for(String tablenName : allTableNames){ + for(String tableName : allTableNames){ //if用来测试 - if(!"data_eaif_h".equals(tablenName)){ - Map fieldMap = getFieldMap(tablenName); - tableFieldMap.put(tablenName,fieldMap); - - String sqlExecuting = getSQL(tablenName); - List deviceIDs = getDeviceID(tablenName); - List>>> dataOfoneTable = new ArrayList<>(); - for(String deviceID : deviceIDs){ - Map>> deviceIDMap = new HashMap<>(); - String timeStamp = getLastRecordTimeSended(tablenName,deviceID); - List> dataOfoneDeviceID = getData(sqlExecuting,deviceID,timeStamp); - deviceIDMap.put(deviceID,dataOfoneDeviceID); - dataOfoneTable.add(deviceIDMap); + if(!"data_eaif_h".equals(tableName)){ + Map fieldMap = getFieldMap(tableName); + String sqlExecuting = getSQL(tableName); + Map devIDLastTimeMap = getDeviceID1(tableName); + for(String deviceID : devIDLastTimeMap.keySet()){ + List> dataOfoneDeviceID = getData(sqlExecuting,deviceID, (String) devIDLastTimeMap.get(deviceID)); + + List> newDataOfoneDeviceID = transformList(fieldMap,dataOfoneDeviceID); + + String jsonStringData = FormatUtil.list2Json(newDataOfoneDeviceID); + if(MqttUtil.publish2MQTT(jsonStringData)){ + updateSyncRecordsTable(tableName,deviceID, (String) devIDLastTimeMap.get(deviceID)); + }else{ + System.out.println("消息推送失败"); + } } - allTableData.put(tablenName,dataOfoneTable); } - } - System.out.println("旧数据： "+allTableData); - System.out.println("==============================="); +// System.out.println("旧数据： "+allTableData); +// System.out.println("==============================="); - Map>>>> newAllData = new HashMap<>(); - for(Map.Entry>>>> dataEntry : allTableData.entrySet()){ - List>>> newRecords = transformFields(dataEntry.getKey(),tableFieldMap,dataEntry.getValue()); - newAllData.put(dataEntry.getKey(),newRecords); - } +// Map>>>> newAllData = new HashMap<>(); +// for(Map.Entry>>>> dataEntry : allTableData.entrySet()){ +// List>>> newRecords = transformFields(dataEntry.getKey(),tableFieldMap,dataEntry.getValue()); +// newAllData.put(dataEntry.getKey(),newRecords); +// } - for(String tableName : newAllData.keySet()){ - List>>> records = newAllData.get(tableName); - String jsonStringData = FormatUtil.list2Json(records); - if(MqttUtil.publish2MQTT(jsonStringData)){ - updateLastRecordTimeSended(tableName,records); - }else{ - System.out.println("消息推送失败"); - } - } +// for(String tableName : newAllData.keySet()){ +// List>>> records = newAllData.get(tableName); +// String jsonStringData = FormatUtil.list2Json(records); +// if(MqttUtil.publish2MQTT(jsonStringData)){ +// updateLastRecordTimeSended(tableName,records); +// }else{ +// System.out.println("消息推送失败"); +// } +// } } - //返回替换字段名的records - private List>>> transformFields(String recordTableName, Map> tableFieldMap, List>>> records) { - List>>> newRecords = new ArrayList<>(); - if(tableFieldMap.containsKey(recordTableName)){ - for(Map>> record : records ){ - newRecords.add(transformMore(tableFieldMap.get(recordTableName),record)); - } - } - return newRecords; - } - - private Map>> transformMore(Map fieldMap, Map>> deviceIDDataMap) { - Map>> newDeviceIDData = new HashMap<>(); - for(Map.Entry>> entry : deviceIDDataMap.entrySet()){ - newDeviceIDData.put(entry.getKey(),transformMoreAgain(fieldMap, entry.getValue())); - } - return newDeviceIDData; - } +// //返回替换字段名的records +// private List>>> transformFields(String recordTableName, Map> tableFieldMap, List>>> records) { +// List>>> newRecords = new ArrayList<>(); +// if(tableFieldMap.containsKey(recordTableName)){ +// for(Map>> record : records ){ +// newRecords.add(transformMore(tableFieldMap.get(recordTableName),record)); +// } +// } +// return newRecords; +// } +// +// private Map>> transformMore(Map fieldMap, Map>> deviceIDDataMap) { +// Map>> newDeviceIDData = new HashMap<>(); +// for(Map.Entry>> entry : deviceIDDataMap.entrySet()){ +// newDeviceIDData.put(entry.getKey(),transformMoreAgain(fieldMap, entry.getValue())); +// } +// return newDeviceIDData; +// } +// +// private List> transformMoreAgain(Map fieldMap, List> deviceIDData) { +// List> newDeviceIDData = new ArrayList<>(); +// for(Map fieldValueMap : deviceIDData){ +// newDeviceIDData.add(transformMoreAgain2(fieldMap,fieldValueMap)); +// } +// return newDeviceIDData; +// } +// +// private Map transformMoreAgain2(Map fieldMap, Map fieldValueMap) { +// Map newFieldValueMap = new HashMap<>(); +// for(String field : fieldMap.keySet()){ +// for(String columnName : fieldValueMap.keySet() ){ +// if(Objects.equals(field,columnName)){ +// newFieldValueMap.put(fieldMap.get(field),fieldValueMap.get(columnName) ); +// } +// } +// } +// return newFieldValueMap; +// } - private List> transformMoreAgain(Map fieldMap, List> deviceIDData) { + private List> transformList(Map fieldMap, List> deviceIDData) { List> newDeviceIDData = new ArrayList<>(); for(Map fieldValueMap : deviceIDData){ - newDeviceIDData.add(transformMoreAgain2(fieldMap,fieldValueMap)); + newDeviceIDData.add(transformOneRecord(fieldMap,fieldValueMap)); } return newDeviceIDData; } - private Map transformMoreAgain2(Map fieldMap, Map fieldValueMap) { + private Map transformOneRecord(Map fieldMap, Map fieldValueMap) { Map newFieldValueMap = new HashMap<>(); for(String field : fieldMap.keySet()){ - for(String columnName : fieldValueMap.keySet() ){ - if(Objects.equals(field,columnName)){ - newFieldValueMap.put(fieldMap.get(field),fieldValueMap.get(columnName) ); - } + if(fieldValueMap.containsKey(field)){ + newFieldValueMap.put(fieldMap.get(field),fieldValueMap.get(field) ); } } return newFieldValueMap; } - - public void updateLastRecordTimeSended(String tableName, List>>> records) { - List deviceIDs = getDeviceID(tableName); - for(String deviceID : deviceIDs){ - String lastRecordTimesJustSended = null; - for(Map>> recordMap : records){ - if(recordMap.get(deviceID) != null){ - List> deviceIDData = recordMap.get(deviceID); - lastRecordTimesJustSended = (String) deviceIDData.get(deviceIDData.size()-1).get("AcquisitionTime"); - System.out.println(tableName+"表"+deviceID+"最后一条记录时间: "+lastRecordTimesJustSended); - } - - } -// updateSyncRecordsTable(tableName, deviceID, lastRecordTimesJustSended); - - } - - } +// +// public void updateLastRecordTimeSended(String tableName, List>>> records) { +// List deviceIDs = getDeviceID(tableName); +// for(String deviceID : deviceIDs){ +// String lastRecordTimesJustSended = null; +// for(Map>> recordMap : records){ +// if(recordMap.get(deviceID) != null){ +// List> deviceIDData = recordMap.get(deviceID); +// lastRecordTimesJustSended = (String) deviceIDData.get(deviceIDData.size()-1).get("AcquisitionTime"); +// System.out.println(tableName+"表"+deviceID+"最后一条记录时间: "+lastRecordTimesJustSended); +// } +// +// } +//// updateSyncRecordsTable(tableName, deviceID, lastRecordTimesJustSended); +// +// } +// +// } public boolean updateSyncRecordsTable(String tableName, String deviceID, String time) { diff --git a/src/main/java/com/xydl/util/FormatUtil.java b/src/main/java/com/xydl/util/FormatUtil.java index bc0fdad..efb79b7 100644 --- a/src/main/java/com/xydl/util/FormatUtil.java +++ b/src/main/java/com/xydl/util/FormatUtil.java @@ -3,10 +3,7 @@ package com.xydl.util; import com.fasterxml.jackson.core.JsonProcessingException; import com.fasterxml.jackson.databind.ObjectMapper; -import java.util.ArrayList; -import java.util.HashMap; -import java.util.List; -import java.util.Map; +import java.util.*; public class FormatUtil { @@ -16,7 +13,7 @@ public class FormatUtil { assetList.add(new HashMap(){{ put("AssetCode","ironCore"); put("AttributeList",list); - put("Timestamp", 1606800979591089792L); + put("Timestamp", new Date().getTime()); }}); Map resultMap = new HashMap(){{ put("AssetList",assetList); @@ -30,5 +27,9 @@ public class FormatUtil { return jsonString; } + public static void main(String[] args) { + System.out.println(new Date().getTime()); + } + } diff --git a/target/classes/application.yml b/target/classes/application.yml new file mode 100644 index 0000000..f57d40d --- /dev/null +++ b/target/classes/application.yml @@ -0,0 +1,27 @@ +#端口号 +server: + port: 8088 + + #数据源配置 +spring: + datasource: + driver-class-name: com.mysql.cj.jdbc.Driver + url: jdbc:mysql://localhost:3306/cac?characterEncoding=utf-8&serverTimezone=UTC + username: root + password: root + #sql: + #init: + #指定脚本文件位置 + #schema-locations: classpath:user.sql + #初始化方式 + #mode: always + #设置数据源类型C + type: com.alibaba.druid.pool.DruidDataSource +mybatis: + configuration: + map-underscore-to-camel-case: true + #mybatis: + #指定mybatis配置文件的位置 + #config-location: classpath:mybatis/mybatis-config.xml + #指定映射文件的位置 + mapper-locations: classpath:mybatis/mapper/*.xml \ No newline at end of file diff --git a/target/classes/com/xydl/mapper/EaifMapper.xml b/target/classes/com/xydl/mapper/EaifMapper.xml new file mode 100644 index 0000000..6d2fe78 --- /dev/null +++ b/target/classes/com/xydl/mapper/EaifMapper.xml @@ -0,0 +1,62 @@ + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + insert into employee values (#{id},#{lastName},#{email},#{gender},#{department.id}) + + + + update employee + + + last_name=#{employee.lastName}, + + + email=#{employee.email}, + + + gender=#{employee.gender}, + + + d_id=#{employee.department.id} + + + where id = #{id} + + + + delete from employee where id=#{id} + + \ No newline at end of file diff --git a/target/classes/com/xydl/mapper/EiaMapper.xml b/target/classes/com/xydl/mapper/EiaMapper.xml new file mode 100644 index 0000000..5372a41 --- /dev/null +++ b/target/classes/com/xydl/mapper/EiaMapper.xml @@ -0,0 +1,69 @@ + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + insert into employee values (#{id},#{lastName},#{email},#{gender},#{department.id}) + + + + update employee + + + last_name=#{employee.lastName}, + + + email=#{employee.email}, + + + gender=#{employee.gender}, + + + d_id=#{employee.department.id} + + + where id = #{id} + + + + delete from employee where id=#{id} + + \ No newline at end of file diff --git a/target/classes/com/xydl/mapper/EpaMapper.xml b/target/classes/com/xydl/mapper/EpaMapper.xml new file mode 100644 index 0000000..c5d0e4f --- /dev/null +++ b/target/classes/com/xydl/mapper/EpaMapper.xml @@ -0,0 +1,86 @@ + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + insert into employee values (#{id},#{lastName},#{email},#{gender},#{department.id}) + + + + update employee + + + last_name=#{employee.lastName}, + + + email=#{employee.email}, + + + gender=#{employee.gender}, + + + d_id=#{employee.department.id} + + + where id = #{id} + + + + delete from employee where id=#{id} + + \ No newline at end of file diff --git a/target/classes/com/xydl/mapper/EtpMapper.xml b/target/classes/com/xydl/mapper/EtpMapper.xml new file mode 100644 index 0000000..c80f768 --- /dev/null +++ b/target/classes/com/xydl/mapper/EtpMapper.xml @@ -0,0 +1,69 @@ + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + insert into employee values (#{id},#{lastName},#{email},#{gender},#{department.id}) + + + + update employee + + + last_name=#{employee.lastName}, + + + email=#{employee.email}, + + + gender=#{employee.gender}, + + + d_id=#{employee.department.id} + + + where id = #{id} + + + + delete from employee where id=#{id} + + \ No newline at end of file diff --git a/target/classes/com/xydl/mapper/MicMapper.xml b/target/classes/com/xydl/mapper/MicMapper.xml new file mode 100644 index 0000000..6ad6a16 --- /dev/null +++ b/target/classes/com/xydl/mapper/MicMapper.xml @@ -0,0 +1,70 @@ + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + insert into employee values (#{id},#{lastName},#{email},#{gender},#{department.id}) + + + + update employee + + + last_name=#{employee.lastName}, + + + email=#{employee.email}, + + + gender=#{employee.gender}, + + + d_id=#{employee.department.id} + + + where id = #{id} + + + + delete from employee where id=#{id} + + \ No newline at end of file diff --git a/target/classes/com/xydl/mapper/MoaMapper.xml b/target/classes/com/xydl/mapper/MoaMapper.xml new file mode 100644 index 0000000..e7d9436 --- /dev/null +++ b/target/classes/com/xydl/mapper/MoaMapper.xml @@ -0,0 +1,68 @@ + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + insert into employee values (#{id},#{lastName},#{email},#{gender},#{department.id}) + + + + update employee + + + last_name=#{employee.lastName}, + + + email=#{employee.email}, + + + gender=#{employee.gender}, + + + d_id=#{employee.department.id} + + + where id = #{id} + + + + delete from employee where id=#{id} + + \ No newline at end of file diff --git a/target/classes/com/xydl/mapper/PdMapper.xml b/target/classes/com/xydl/mapper/PdMapper.xml new file mode 100644 index 0000000..e20de19 --- /dev/null +++ b/target/classes/com/xydl/mapper/PdMapper.xml @@ -0,0 +1,69 @@ + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + insert into employee values (#{id},#{lastName},#{email},#{gender},#{department.id}) + + + + update employee + + + last_name=#{employee.lastName}, + + + email=#{employee.email}, + + + gender=#{employee.gender}, + + + d_id=#{employee.department.id} + + + where id = #{id} + + + + delete from employee where id=#{id} + + \ No newline at end of file diff --git a/target/classes/com/xydl/mapper/RptTemperMapper.xml b/target/classes/com/xydl/mapper/RptTemperMapper.xml new file mode 100644 index 0000000..35b33cb --- /dev/null +++ b/target/classes/com/xydl/mapper/RptTemperMapper.xml @@ -0,0 +1,68 @@ + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + insert into employee values (#{id},#{lastName},#{email},#{gender},#{department.id}) + + + + update employee + + + last_name=#{employee.lastName}, + + + email=#{employee.email}, + + + gender=#{employee.gender}, + + + d_id=#{employee.department.id} + + + where id = #{id} + + + + delete from employee where id=#{id} + + \ No newline at end of file diff --git a/target/classes/com/xydl/mapper/ScurMapper.xml b/target/classes/com/xydl/mapper/ScurMapper.xml new file mode 100644 index 0000000..4ec60a1 --- /dev/null +++ b/target/classes/com/xydl/mapper/ScurMapper.xml @@ -0,0 +1,68 @@ + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + insert into employee values (#{id},#{lastName},#{email},#{gender},#{department.id}) + + + + update employee + + + last_name=#{employee.lastName}, + + + email=#{employee.email}, + + + gender=#{employee.gender}, + + + d_id=#{employee.department.id} + + + where id = #{id} + + + + delete from employee where id=#{id} + + \ No newline at end of file diff --git a/target/classes/com/xydl/mapper/Sf6Mapper.xml b/target/classes/com/xydl/mapper/Sf6Mapper.xml new file mode 100644 index 0000000..c334cd5 --- /dev/null +++ b/target/classes/com/xydl/mapper/Sf6Mapper.xml @@ -0,0 +1,67 @@ + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + insert into employee values (#{id},#{lastName},#{email},#{gender},#{department.id}) + + + + update employee + + + last_name=#{employee.lastName}, + + + email=#{employee.email}, + + + gender=#{employee.gender}, + + + d_id=#{employee.department.id} + + + where id = #{id} + + + + delete from employee where id=#{id} + + \ No newline at end of file diff --git a/target/classes/com/xydl/mapper/Sf6envMapper.xml b/target/classes/com/xydl/mapper/Sf6envMapper.xml new file mode 100644 index 0000000..35d414f --- /dev/null +++ b/target/classes/com/xydl/mapper/Sf6envMapper.xml @@ -0,0 +1,68 @@ + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + insert into employee values (#{id},#{lastName},#{email},#{gender},#{department.id}) + + + + update employee + + + last_name=#{employee.lastName}, + + + email=#{employee.email}, + + + gender=#{employee.gender}, + + + d_id=#{employee.department.id} + + + where id = #{id} + + + + delete from employee where id=#{id} + + \ No newline at end of file diff --git a/target/classes/templates/a.html b/target/classes/templates/a.html new file mode 100644 index 0000000..ebd090b --- /dev/null +++ b/target/classes/templates/a.html @@ -0,0 +1,12 @@ + + + + + Title + + +

${list}

+

${name}

+ + + \ No newline at end of file diff --git a/target/maven-archiver/pom.properties b/target/maven-archiver/pom.properties new file mode 100644 index 0000000..a94a1ca --- /dev/null +++ b/target/maven-archiver/pom.properties @@ -0,0 +1,3 @@ +artifactId=mqtt +groupId=com.xydl +version=1.0-SNAPSHOT diff --git a/target/mqtt-1.0-SNAPSHOT.jar.original b/target/mqtt-1.0-SNAPSHOT.jar.original new file mode 100644 index 0000000..d188471 Binary files /dev/null and b/target/mqtt-1.0-SNAPSHOT.jar.original differ