innov
/
aggregation-platform
1
0
Fork 0
Code Issues Pull Requests Releases Wiki Activity

最新修改+cfg文件产生+地区下所有系统的xml产生

Browse Source
web_backend_develope
chenlw 10 years ago
parent 8a8e52357d
commit a1363a3484
17 changed files with 968 additions and 96 deletions
Show Stats Download Patch File Download Diff File

8
src/com/dao/mapper/standard_data_details-mapper.xml
Unescape View File

@ -12,10 +12,8 @@ PUBLIC "-//ibatis.apache.org//DTD Mapper 3.0//EN"
jdbcType="VARCHAR" />
<result property="districtName" column="district_name"
javaType="string" jdbcType="VARCHAR" />
<!--
<result property="systemCode" column="system_code" javaType="int"
<result property="sysCode" column="sys_code" javaType="int"
jdbcType="INTEGER" />
-->
<result property="sysName" column="system_name" javaType="string"
jdbcType="VARCHAR" />
<result property="areaLevel" column="area_level"
@ -84,7 +82,7 @@ PUBLIC "-//ibatis.apache.org//DTD Mapper 3.0//EN"
<!-- sql txt Base_Column_List -->
<sql id="Base_Column_List">
id,area_code,city_name,district_name,system_name,area_level,data_version,begin_in_use,function_details,
id,area_code,city_name,district_name,system_name,sys_code,area_level,data_version,begin_in_use,function_details,
department_manager,manager_contacts,sys_developer_full_name,data_base_type,data_base_version,
is_budget_exec,is_budget_quota,is_collection,is_department_budget,total_budget_account,
final_account_manage,report_form_manage,non_tax_revenue_manage,wage_system,
@ -173,7 +171,7 @@ PUBLIC "-//ibatis.apache.org//DTD Mapper 3.0//EN"
</select>
<!-- 更新字段 -->
<update id="update" parameterType="com.platform.entities.PreDataInfoFull">
<update id="update" parameterType="com.platform.entities.PreDataInfo">
UPDATE
default_data_description
<set>

23
src/com/platform/controller/ExcelController.java
Unescape View File

@ -47,6 +47,7 @@ import com.platform.entities.PreDataInfo;
import com.platform.entities.ResumableInfo;
import com.platform.entities.ResumableInfoStorage;
import com.platform.service.IPreDataInfoService;
import com.platform.service.IScriptMakeService;
import com.platform.utils.Configs;
import com.platform.utils.HttpUtils;
import com.platform.utils.UtilsHelper;
@ -60,6 +61,9 @@ public class ExcelController extends BaseController{
@Resource(name = "preDataInfoService")
private IPreDataInfoService preDataInfoService;
@Resource(name = "scriptMakeService")
private IScriptMakeService scriptMakeService;
// 文件上传处理函数
@RequestMapping(value = "/file/upload", method = RequestMethod.POST)
public void upload(HttpServletRequest request, HttpServletResponse response)
@ -235,13 +239,13 @@ public class ExcelController extends BaseController{
}
log.info(jsonlist.size());
List<String> listPath = new ArrayList<String>();
// 末尾 含有 /
// 末尾 含有 /(linux)
Pattern pattern2 = Pattern.compile("\\/$");
Matcher matcher2 = pattern2.matcher(Configs.FILE_UPLOAD_PATH);
// 加上 最后 的 /
String dirPath = Configs.FILE_UPLOAD_PATH;
if (!matcher2.find()) {
dirPath = dirPath+"/";
dirPath = dirPath + File.separator;
}
for (String p : jsonlist) {
listPath.add(dirPath + p);
@ -264,12 +268,8 @@ public class ExcelController extends BaseController{
//读取完后删除源文件（不管是否成功导入）
File tmpf = new File(filePath + ".temp");
File f = new File(filePath);
if (tmpf.exists()) {
tmpf.delete();
}
if (f.exists()) {
f.delete();
}
tmpf.delete();
f.delete();
}
}
return modelMap;
@ -313,4 +313,11 @@ public class ExcelController extends BaseController{
}
}
}
@RequestMapping(value = "/exportFile")
public void exportFile(HttpServletRequest request, HttpServletResponse response) throws Exception {
scriptMakeService.makeCfg();
scriptMakeService.makeXml();
response.setStatus(200);
}
}

6
src/com/platform/dao/ISystemCodeDao.java
Unescape View File

@ -2,14 +2,8 @@ package com.platform.dao;
import java.util.List;
import org.apache.ibatis.annotations.Param;
import org.springframework.stereotype.Repository;
import com.platform.entities.DataInfoEntity;
import com.platform.entities.DataInfoEntityMoveTmp;
import com.platform.entities.PagerOptions;
import com.platform.entities.PreDataInfoFull;
import com.platform.entities.RegionalismEntity;
import com.platform.entities.SystemEntity;
/**

5
src/com/platform/dao/PreDataInfoDao.java
Unescape View File

@ -10,7 +10,6 @@ import com.platform.entities.DataInfoEntity;
import com.platform.entities.DataInfoEntityMoveTmp;
import com.platform.entities.PagerOptions;
import com.platform.entities.PreDataInfo;
import com.platform.entities.PreDataInfoFull;
@Repository(value = "preDataInfoDao")
public interface PreDataInfoDao {
@ -25,9 +24,9 @@ public interface PreDataInfoDao {
List<PreDataInfo> findAll()throws Exception;
void insertBatch(List<PreDataInfoFull> list) throws Exception;
void insertBatch(List<PreDataInfo> list) throws Exception;
int update(PreDataInfoFull data) throws Exception;
int update(PreDataInfo data) throws Exception;
/** 查找 存在的 系统（根据 地区编码 和 系统编码）
* @param list

478
src/com/platform/entities/DefaultDataDescription.java
View File

File diff suppressed because it is too large Load Diff

53
src/com/platform/entities/MyFileEntity.java
Unescape View File

@ -0,0 +1,53 @@
package com.platform.entities;
public class MyFileEntity {
private String fileName;
private String lastTime;
private String filePath;
/**
* @return the fileName
*/
public String getFileName() {
return fileName;
}
/**
* @param fileName the fileName to set
*/
public void setFileName(String fileName) {
this.fileName = fileName;
}
/**
* @return the lastTime
*/
public String getLastTime() {
return lastTime;
}
/**
* @param lastTime the lastTime to set
*/
public void setLastTime(String lastTime) {
this.lastTime = lastTime;
}
/**
* @return the filePath
*/
public String getFilePath() {
return filePath;
}
/**
* @param filePath the filePath to set
*/
public void setFilePath(String filePath) {
this.filePath = filePath;
}
}

30
src/com/platform/entities/PreDataInfo.java
Unescape View File

@ -7,6 +7,10 @@ public class PreDataInfo {
private int id;
private int sysCode;
private String updateTime;
/** 是否更新 */
private String isupdate = "-";
@ -98,7 +102,33 @@ public class PreDataInfo {
public void setId(int id) {
this.id = id;
}
/**
* @return the sysCode
*/
public int getSysCode() {
return sysCode;
}
/**
* @param sysCode the sysCode to set
*/
public void setSysCode(int sysCode) {
this.sysCode = sysCode;
}
/**
* @return the updateTime
*/
public String getUpdateTime() {
return updateTime;
}
/**
* @param updateTime the updateTime to set
*/
public void setUpdateTime(String updateTime) {
this.updateTime = updateTime;
}
/**
* @return the isupdate
*/

37
src/com/platform/entities/PreDataInfoFull.java
Unescape View File

@ -1,37 +0,0 @@
package com.platform.entities;
public class PreDataInfoFull extends PreDataInfo {
private String sysCode;
private String updateTime;
/**
* @return the sysCode
*/
public String getSysCode() {
return sysCode;
}
/**
* @param sysCode the sysCode to set
*/
public void setSysCode(String sysCode) {
this.sysCode = sysCode;
}
/**
* @return the updateTime
*/
public String getUpdateTime() {
return updateTime;
}
/**
* @param updateTime the updateTime to set
*/
public void setUpdateTime(String updateTime) {
this.updateTime = updateTime;
}
}

17
src/com/platform/service/IScriptMakeService.java
Unescape View File

@ -0,0 +1,17 @@
package com.platform.service;
import java.util.List;
import com.platform.entities.MyFileEntity;
public interface IScriptMakeService {
public int makeCfg() throws Exception;
public int makeXml() throws Exception;
public int moveFiles(MyFileEntity file) throws Exception;
public List<MyFileEntity> FindFiles() throws Exception;
}

43
src/com/platform/service/impl/PreDataInfoServiceImpl.java
Unescape View File

@ -29,7 +29,6 @@ import com.platform.dao.PreDataInfoDao;
import com.platform.dao.VolumeDao;
import com.platform.entities.PagerOptions;
import com.platform.entities.PreDataInfo;
import com.platform.entities.PreDataInfoFull;
import com.platform.entities.RegionalismEntity;
import com.platform.entities.SystemEntity;
import com.platform.service.IPreDataInfoService;
@ -64,9 +63,9 @@ public class PreDataInfoServiceImpl implements IPreDataInfoService {
List<String> errArea = new ArrayList<String>();
List<String> errFile = new ArrayList<String>();
// 待增加的
List<PreDataInfoFull> all2Insert = new ArrayList<PreDataInfoFull>();
List<PreDataInfo> all2Insert = new ArrayList<PreDataInfo>();
// 待修改的
List<PreDataInfoFull> all2Update = new ArrayList<PreDataInfoFull>();
List<PreDataInfo> all2Update = new ArrayList<PreDataInfo>();
//excel读出的 所有
List<PreDataInfo> all = new ArrayList<PreDataInfo>();
//excel读出的 所有修改操作的数据
@ -99,7 +98,7 @@ public class PreDataInfoServiceImpl implements IPreDataInfoService {
//Excel导入
try {
//excel数据 --> java bean
List<PreDataInfo> subPreData = ExcelOperation.readExcel4Update(workbook, Constant.EXCEL_TEMPLATE_INIT_ROW, 0, PreDataInfo.class, "id", "workRange");
List<PreDataInfo> subPreData = ExcelOperation.readExcel4Update(workbook, Constant.EXCEL_TEMPLATE_INIT_ROW, 0, PreDataInfo.class, "id", "workRange","sysCode","updateTime");
if (null != subPreData && subPreData.size() > 0) {
//是否是 同一个县区的 系统--是则 加入
boolean isSameArea = true;
@ -160,14 +159,14 @@ public class PreDataInfoServiceImpl implements IPreDataInfoService {
if (sysNames.size() > 0) {
listSystem = systemCodeDao.findByName(sysNames);
}
Map<String, String> syscodeMap = new HashMap<String, String>();
Map<String, Object> syscodeMap = new HashMap<String, Object>();
for (SystemEntity systemEntity : listSystem) {
syscodeMap.put(systemEntity.getSystemName(), String.valueOf(systemEntity.getCode()));
}
for ( PreDataInfo systemEntity : list4AddSystem) {
PreDataInfoFull systemFull = new PreDataInfoFull();
PreDataInfo systemFull = new PreDataInfo();
BeanCopy.copyBean(systemEntity, systemFull);
systemFull.setSysCode(syscodeMap.get(systemFull.getSysName()));
systemFull.setSysCode((int) syscodeMap.get(systemFull.getSysName()));
systemFull.setUpdateTime(DateForm.date2StringBysecond(new Date()));
all2Insert.add(systemFull);
}
@ -182,7 +181,7 @@ public class PreDataInfoServiceImpl implements IPreDataInfoService {
this.addArea(list4AddArea);
}
//在 pre_data_info表中 新增 操作为（新增行政区划）的系统
List<PreDataInfoFull> allAreaInsert = new ArrayList<PreDataInfoFull>();
List<PreDataInfo> allAreaInsert = new ArrayList<PreDataInfo>();
List<String> sysNamesArea = new ArrayList<String>();
for (PreDataInfo preDataInfo : list4AddArea) {
sysNamesArea.add(preDataInfo.getSysName());
@ -192,14 +191,14 @@ public class PreDataInfoServiceImpl implements IPreDataInfoService {
if (sysNamesArea.size() > 0) {
listSystem = systemCodeDao.findByName(sysNamesArea);
}
Map<String, String> syscodeMap = new HashMap<String, String>();
Map<String, Object> syscodeMap = new HashMap<String, Object>();
for (SystemEntity systemEntity : listSystem) {
syscodeMap.put(systemEntity.getSystemName(), String.valueOf(systemEntity.getCode()));
}
for (PreDataInfo preDataInfo : list4AddArea) {
PreDataInfoFull areaFull = new PreDataInfoFull();
PreDataInfo areaFull = new PreDataInfo();
BeanCopy.copyBean(preDataInfo, areaFull);
areaFull.setSysCode(syscodeMap.get(areaFull.getSysName()));
areaFull.setSysCode((int) syscodeMap.get(areaFull.getSysName()));
areaFull.setUpdateTime(DateForm.date2StringBysecond(new Date()));
allAreaInsert.add(areaFull);
}
@ -211,7 +210,7 @@ public class PreDataInfoServiceImpl implements IPreDataInfoService {
//在 pre_data_info表中 更新 操作为 (修改) 的系统
if (list4Update.size() > 0) {
List<PreDataInfoFull> allUpdate = new ArrayList<PreDataInfoFull>();
List<PreDataInfo> allUpdate = new ArrayList<PreDataInfo>();
// 查询系统 code
for (PreDataInfo preDataInfo : list4Update) {
sysNamesArea.add(preDataInfo.getSysName());
@ -225,13 +224,13 @@ public class PreDataInfoServiceImpl implements IPreDataInfoService {
syscodeMap.put(systemEntity.getSystemName(), String.valueOf(systemEntity.getCode()));
}
for (PreDataInfo preUpdate : list4Update) {
PreDataInfoFull UpdateFull = new PreDataInfoFull();
PreDataInfo UpdateFull = new PreDataInfo();
BeanCopy.copyBean(preUpdate, UpdateFull);
UpdateFull.setSysCode(syscodeMap.get(UpdateFull.getSysName()));
UpdateFull.setSysCode((int) syscodeMap.get(UpdateFull.getSysName()));
UpdateFull.setUpdateTime(DateForm.date2StringBysecond(new Date()));
allUpdate.add(UpdateFull);
}
for (PreDataInfoFull preEntity : allUpdate) {
for (PreDataInfo preEntity : allUpdate) {
preDataInfoDao.update(preEntity);
}
}
@ -324,7 +323,7 @@ public class PreDataInfoServiceImpl implements IPreDataInfoService {
XSSFWorkbook result = null;
try {
workbook = new XSSFWorkbook(res.getInputStream());
result = ExcelOperation.writeExcelTemplate(workbook, Constant.EXCEL_TEMPLATE_INIT_ROW, 0, 25, list, "id", "workRange");
result = ExcelOperation.writeExcelTemplate(workbook, Constant.EXCEL_TEMPLATE_INIT_ROW, 0, 25, list, "id", "workRange","sysCode","updateTime");
} catch (IllegalArgumentException
| IllegalAccessException | IOException e) {
errList.add(e.getMessage());
@ -332,14 +331,10 @@ public class PreDataInfoServiceImpl implements IPreDataInfoService {
try {
File f = new File(path);
FileOutputStream fileOut = null;
if (f.exists()) {
fileOut = new FileOutputStream(f);
result.write(fileOut);
fileOut.close();
}
else {
errList.add("without this file "+path);
}
f.createNewFile();
fileOut = new FileOutputStream(f);
result.write(fileOut);
fileOut.close();
} catch (IOException e) {
errList.add(e.getMessage());
}

116
src/com/platform/service/impl/ScriptMakeService.java
Unescape View File

@ -0,0 +1,116 @@
package com.platform.service.impl;
import java.io.File;
import java.util.ArrayList;
import java.util.HashMap;
import java.util.List;
import java.util.Map;
import javax.annotation.Resource;
import org.apache.log4j.Logger;
import org.springframework.stereotype.Service;
import com.platform.dao.PreDataInfoDao;
import com.platform.entities.DefaultDataDescription;
import com.platform.entities.MyFileEntity;
import com.platform.entities.PreDataInfo;
import com.platform.service.IScriptMakeService;
import com.platform.utils.Configs;
import com.platform.utils.Constant;
import com.platform.utils.FileOperateHelper;
import com.platform.utils.XmlOperationByDom4j;
@Service(value = "scriptMakeService")
public class ScriptMakeService implements IScriptMakeService {
public static Logger log = Configs.DAILY_ROLLING_LOGGER.getLogger(PreDataInfoServiceImpl.class);
@Resource(name = "preDataInfoDao")
private PreDataInfoDao preDataInfoDao;
@Override
public int makeCfg() throws Exception {
log.info("makeCfg");
List<PreDataInfo> systemInfoList = preDataInfoDao.findAll();
String path = FileOperateHelper.addLastSeparator(Configs.sql_script_path_standard);
StringBuffer sb = new StringBuffer();
sb.append("市\t县（市、区）\t行政区划代码\r\n");
Map<String, Object> startData = new HashMap<String, Object>();
for (PreDataInfo preDataInfo : systemInfoList) {
startData.put(preDataInfo.getAreaCode(), preDataInfo);
}
//以地区为准--一个地区一个xml
for ( String key : startData.keySet()) {
PreDataInfo preDataInfo = (PreDataInfo) startData.get(key);
sb.append(preDataInfo.getCityName());
sb.append("\t");
sb.append(preDataInfo.getDistrictName());
sb.append("\t");
sb.append(preDataInfo.getAreaCode());
sb.append("\r\n");
}
FileOperateHelper.fileWrite(path+Constant.cfgFileName, sb.toString());
log.info("makeCfg--end");
return 1;
}
@Override
public int makeXml() throws Exception {
log.info("makeXml");
List<PreDataInfo> systemInfoList = preDataInfoDao.findAll();
String dirpath = FileOperateHelper.addLastSeparator(Configs.sql_script_path_standard);
Map<String, List<Object>> map = new HashMap<String, List<Object>>();
for (PreDataInfo preDataInfo : systemInfoList) {
putSystemByAreaCode(map, preDataInfo.getAreaCode(), preDataInfo);
}
//一个地区一个xml
for ( String key : map.keySet()) {
String areaPath = dirpath + key;
File f = new File(areaPath);
f.mkdir();
List<Object> defList = new ArrayList<Object>();
List<Object> list = map.get(key);
for (Object object : list) {
DefaultDataDescription defaul = new DefaultDataDescription();
defaul.setvalue((PreDataInfo) object);
defList.add(defaul);
}
XmlOperationByDom4j.createXml(FileOperateHelper.addLastSeparator(areaPath)+key+".xml", defList, "Data_info", "workRange");
}
log.info("makeXml--end");
return 1;
}
@Override
public int moveFiles(MyFileEntity file) throws Exception {
// TODO Auto-generated method stub
return 0;
}
@Override
public List<MyFileEntity> FindFiles() throws Exception {
// TODO Auto-generated method stub
return null;
}
/**
* @param map
* @param code
* @param data
* @return
*/
private Map<String, List<Object>> putSystemByAreaCode(Map<String, List<Object>> map,String code, PreDataInfo data) {
List<Object> list = map.get(code);
if (null == list) {
list = new ArrayList<Object>();
}
list.add(data);
map.put(code, list);
return map;
}
}

14
src/com/platform/utils/BeanCopy.java
Unescape View File

@ -40,12 +40,14 @@ public class BeanCopy {
if (sourceFieldName.contains(name)) {
field.setAccessible(true);
Object value;
// Method m = source.getClass().getMethod("get"+upperHeadChar(name));
// value = m.invoke(source);
value = source.getClass().getDeclaredField(name).get(source);
if (null != value) {
field.set(dst, value);
}
Method m = source.getClass().getMethod("get"+upperHeadChar(name));
value = m.invoke(source);
// Field fie = source.getClass().getDeclaredField(name);
// fie.setAccessible(true);
// value = fie.get(source);
if (null != value) {
field.set(dst, value);
}
}
}

4
src/com/platform/utils/Configs.java
Unescape View File

@ -53,4 +53,8 @@ public class Configs {
public static String FILE_UPLOAD_PATH="";
public static String FILE_DOWNLOAD_PATH="";
public static String sql_script_path_last="";
public static String sql_script_path_standard="";
}

4
src/com/platform/utils/ConfigsLoader.java
Unescape View File

@ -70,6 +70,10 @@ public class ConfigsLoader implements ServletContextListener {
Configs.FILE_DOWNLOAD_PATH = properties.getProperty("file_download_path");
Configs.sql_script_path_last = properties.getProperty("sql_script_path_last");
Configs.sql_script_path_standard = properties.getProperty("sql_script_path_standard");
HttpClientConstant.URL_IP_PORT = properties.getProperty("HttpClientConstant_URL_IP_PORT").trim();
Constant.hostIp=properties.getProperty("gfs_control_ip").trim();

3
src/com/platform/utils/Constant.java
Unescape View File

@ -70,5 +70,8 @@ public class Constant {
/** excel导入-新增信息系统-preDataInfo信息 */
public final static String preDataInfo_add_system = "新增信息系统";
/** cfg文件的名称 */
public final static String cfgFileName = "systen_name_sys_code.cfg";
}

33
src/com/platform/utils/FileOperateHelper.java
Unescape View File

@ -6,8 +6,8 @@ import java.io.FileInputStream;
import java.io.FileOutputStream;
import java.io.IOException;
import java.io.InputStreamReader;
import org.junit.Test;
import java.util.regex.Matcher;
import java.util.regex.Pattern;
/**
* 文件读写操作帮助类
@ -29,10 +29,9 @@ public class FileOperateHelper {
return;
}
try {
path = path+".log";
File file = new File(path);
if (file.exists())
file.createNewFile();
file.delete();
file.createNewFile();
FileOutputStream out = new FileOutputStream(file, true); // 如果追加方式用true
StringBuffer sb = new StringBuffer();
sb.append(message);
@ -93,7 +92,27 @@ public class FileOperateHelper {
}
return sb.toString();
}
public static String addLastSeparator(String path){
// 末尾 含有 /
Pattern pattern2 = Pattern.compile(File.separator+"$");
Matcher matcher2 = pattern2.matcher(path);
if (!matcher2.find()) {
path = path + File.separator;
}
return path;
}
public static String removeLastSeparator(String path){
// 末尾 含有 /
if (path.length() < 1) {
return path;
}
Pattern pattern2 = Pattern.compile(File.separator+"$");
Matcher matcher2 = pattern2.matcher(path);
if (matcher2.find()) {
path = path.substring(0, path.length()-1);
}
return path;
}
}

190
src/com/platform/utils/XmlOperationByDom4j.java
Unescape View File

@ -0,0 +1,190 @@
package com.platform.utils;
import java.io.File;
import java.io.FileOutputStream;
import java.io.IOException;
import java.io.OutputStreamWriter;
import java.lang.reflect.Field;
import java.util.ArrayList;
import java.util.Arrays;
import java.util.List;
import org.dom4j.Document;
import org.dom4j.DocumentException;
import org.dom4j.DocumentHelper;
import org.dom4j.Element;
import org.dom4j.io.OutputFormat;
import org.dom4j.io.SAXReader;
import org.dom4j.io.XMLWriter;
/**
* @<EFBFBD><EFBFBD><EFBFBD><EFBFBD>
* @author chen
* @date 2016<EFBFBD><EFBFBD>8<EFBFBD><EFBFBD>5<EFBFBD><EFBFBD>
* @package com.base
*/
public class XmlOperationByDom4j {
/**
* @<EFBFBD><EFBFBD><EFBFBD><EFBFBD> <EFBFBD><EFBFBD><EFBFBD><EFBFBD>xml<EFBFBD>ļ<EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD>ӽڵ㣩
* @param fileName
* <EFBFBD>ļ<EFBFBD>·<EFBFBD><EFBFBD>+<EFBFBD><EFBFBD>
* @param params
* <EFBFBD><EFBFBD>Ҫ<EFBFBD>Ľڵ<EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD>
* @return true<EFBFBD><EFBFBD><EFBFBD>ɹ<EFBFBD>
*/
public static boolean createXml(String fileName, List<Object> nodes, String rootnode, String... filters) {
if (null == nodes || nodes.size() == 0) {
return false;
}
boolean issuccess = false;
Document document = null;
try {
OutputFormat xmlFormat = OutputFormat.createPrettyPrint();
xmlFormat.setEncoding("UTF-8");
XMLWriter xmlWriter;
// <20>ļ<EFBFBD><C4BC>Ƿ<EFBFBD><C7B7><EFBFBD>ڣ<EFBFBD>
document = DocumentHelper.createDocument(); // <20><><EFBFBD><EFBFBD><EFBFBD>ĵ<EFBFBD>
Element root = document.addElement(rootnode);
// <20><><EFBFBD> node<64><65><EFBFBD><EFBFBD><EFBFBD>ԣ<EFBFBD><D4A3><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD>ڵ<EFBFBD><DAB5><EFBFBD>
for (Object node : nodes) {
addOneNode(root, node, filters);
}
xmlWriter = new XMLWriter(new OutputStreamWriter(new FileOutputStream(new File(fileName)), "UTF-8"),
xmlFormat);
// <20><><EFBFBD><EFBFBD>д<EFBFBD>ļ<EFBFBD><C4BC><EFBFBD><EFBFBD><EFBFBD>
xmlWriter.write(document); // д<><D0B4><EFBFBD>ļ<EFBFBD><C4BC><EFBFBD>
xmlWriter.close();
issuccess = true;
} catch (Exception e) {
issuccess = false;
}
return issuccess;
}
public static boolean addNode2Xml(String fileName, String rootnode, List<Object> nodes) {
if (null == nodes || 0 ==nodes.size()) {
return false;
}
boolean issuccess = false;
Document document = null;
try {
OutputFormat xmlFormat = OutputFormat.createPrettyPrint();
xmlFormat.setEncoding("UTF-8");
XMLWriter xmlWriter;
File file = new File(fileName);
// <20>ļ<EFBFBD><C4BC>Ƿ<EFBFBD><C7B7><EFBFBD>ڣ<EFBFBD>
if (file.exists()) {
SAXReader saxReader = new SAXReader();
document = saxReader.read(file);
Element root = document.getRootElement(); // <20><>ȡ<EFBFBD>ĵ<EFBFBD><C4B5><EFBFBD><EFBFBD>ڵ<EFBFBD> Data_info
// <20><><EFBFBD> node<64><65><EFBFBD><EFBFBD><EFBFBD>ԣ<EFBFBD><D4A3><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD>ڵ<EFBFBD><DAB5><EFBFBD>
for (Object node : nodes) {
addOneNode(root, node);
}
xmlWriter = new XMLWriter(new OutputStreamWriter(new FileOutputStream(file), "UTF-8"), xmlFormat);
}else {
return false;
}
xmlWriter.write(document); // д<><D0B4><EFBFBD>ļ<EFBFBD><C4BC><EFBFBD>
xmlWriter.close();
issuccess = true;
} catch (Exception e) {
issuccess = false;
}
return issuccess;
}
/**
* @<EFBFBD><EFBFBD><EFBFBD><EFBFBD> ɾ<EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD>нڵ<EFBFBD>
* @param fileName
* xml<EFBFBD>ļ<EFBFBD><EFBFBD><EFBFBD>·<EFBFBD><EFBFBD>
* @return
*/
public static boolean delAllNodes(String fileName) {
boolean issuccess = false;
OutputFormat xmlFormat = OutputFormat.createPrettyPrint();
xmlFormat.setEncoding("UTF-8");
XMLWriter xmlWriter;
File file = new File(fileName);
try {
if (file.exists()) {
SAXReader saxReader = new SAXReader();
Document document;
document = saxReader.read(file);
Element root = document.getRootElement(); // <20><>ȡ<EFBFBD>ĵ<EFBFBD><C4B5><EFBFBD><EFBFBD>ڵ<EFBFBD> Data_info
// <20><><EFBFBD> node<64><65><EFBFBD><EFBFBD><EFBFBD>ԣ<EFBFBD><D4A3><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD>ڵ<EFBFBD><DAB5><EFBFBD>
@SuppressWarnings("unchecked")
List<Element> eles = root.elements();
for (Element obj : eles) {
root.remove(obj);
}
xmlWriter = new XMLWriter(new OutputStreamWriter(new FileOutputStream(file), "UTF-8"), xmlFormat);
xmlWriter.write(document); // д<><D0B4><EFBFBD>ļ<EFBFBD><C4BC><EFBFBD>
xmlWriter.close();
issuccess = true;
}
} catch (DocumentException | IOException e) {
issuccess = false;
}
return issuccess;
}
/**
* @<EFBFBD><EFBFBD><EFBFBD><EFBFBD> <EFBFBD>ڸ<EFBFBD><EFBFBD>ڵ<EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD>һ<EFBFBD><EFBFBD><EFBFBD>ڵ<EFBFBD>
* @param root
* <EFBFBD><EFBFBD><EFBFBD>ڵ<EFBFBD>
* @param node
* ij<EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD>ڵ<EFBFBD><EFBFBD><EFBFBD><EFBFBD>ݵ<EFBFBD>ʵ<EFBFBD><EFBFBD>
* @throws IllegalArgumentException
* @throws IllegalAccessException
*/
private static void addOneNode(Element root, Object node, String... filters) throws IllegalArgumentException, IllegalAccessException {
List<String> filter = new ArrayList<String>();
filter.addAll(Arrays.asList(filters));
// <20><><EFBFBD>ڵ<EFBFBD>
Field[] params = node.getClass().getDeclaredFields();
Field rootField = null;
for (Field field : params) {
field.setAccessible(true);
if ("localNodeName".equals(field.getName())) {
rootField = field;
break;
}
}
Element dataInfo = root.addElement((String) rootField.get(node));
// <20>ӽڵ<D3BD>
List<Field> noString = new ArrayList<Field>();
for (Field field : params) {
field.setAccessible(true);
String fName = field.getName();
if ("localNodeName".equals(fName)) {
continue;
}
if (filter.contains(fName)) {
continue;
}
//String <20><> Integer <20><><EFBFBD>͵<EFBFBD><CDB5><EFBFBD>ӽ<EFBFBD>ȥ
if (field.getType() != String.class) {
if (field.getType() != Integer.class) {
Element element = dataInfo.addElement(fName);
if (null != field.get(node)) {
element.setText(String.valueOf(field.get(node)));
}
}
else {
noString.add(field);
dataInfo.addElement(fName);
}
} else {
Element element = dataInfo.addElement(fName);
if (null != field.get(node)) {
element.setText((String) field.get(node));
}
}
}
}
}
Write Preview
Loading…
Cancel
Save