列名加饭引号,防止因关键字报错

master
chengqf 2 years ago
parent fd7d7d160c
commit 564b29d2b3

@ -100,14 +100,17 @@ public class IdcServiceImpl implements IdcService {
public BaseResponse download(HttpServletRequest request, Map<String, Object> params) { public BaseResponse download(HttpServletRequest request, Map<String, Object> params) {
return statusFile(params, "basic_export_status"); return statusFile(params, "basic_export_status");
} }
@Override @Override
public BaseResponse uploadStatus(HttpServletRequest request, Map<String, Object> params) { public BaseResponse uploadStatus(HttpServletRequest request, Map<String, Object> params) {
return statusFile(params, "basic_upload_status"); return statusFile(params, "basic_upload_status");
} }
@Override @Override
public BaseResponse downloadStatus(HttpServletRequest request, Map<String, Object> params) { public BaseResponse downloadStatus(HttpServletRequest request, Map<String, Object> params) {
return statusFile(params, "basic_download_status"); return statusFile(params, "basic_download_status");
} }
private BaseResponse statusFile(Map<String, Object> params, String tableName) { private BaseResponse statusFile(Map<String, Object> params, String tableName) {
String id = ""; String id = "";
if (params.containsKey("taskId") && params.get("taskId") != null) { if (params.containsKey("taskId") && params.get("taskId") != null) {
@ -119,9 +122,9 @@ public class IdcServiceImpl implements IdcService {
Map<String, Object> map = map = dbDao.get("select * from " + tableName + " where id='" + id + "'"); Map<String, Object> map = map = dbDao.get("select * from " + tableName + " where id='" + id + "'");
if (map == null) if (map == null)
return ResultVOUtils.error(9000, "下载任务不存在"); return ResultVOUtils.error(9000, "下载任务不存在" + tableName);
if (!(map.get("cacheFilePath") != null && FileUtils.isFileExist(map.get("cacheFilePath").toString()))) if (!(map.get("cacheFilePath") != null && FileUtils.isFileExist(map.get("cacheFilePath").toString())))
return ResultVOUtils.error(9000, "下载文件不存在"); return ResultVOUtils.error(9000, "下载文件不存在-" + tableName);
String json = FileUtils.readFileAll(map.get("cacheFilePath").toString()); String json = FileUtils.readFileAll(map.get("cacheFilePath").toString());
JSONObject object = JSON.parseObject(json); JSONObject object = JSON.parseObject(json);
@ -211,8 +214,7 @@ public class IdcServiceImpl implements IdcService {
String[] syncTables = TableUtils.syncTables(); String[] syncTables = TableUtils.syncTables();
for (int i = 0; i < syncTables.length; i++) { for (int i = 0; i < syncTables.length; i++) {
String[] tnames = syncTables[i].split("/"); String[] tnames = syncTables[i].split("/");
boolean sync = ((tnames[0]==null||StringUtils.isEmpty(tnames[0])||(tnames[0]!=null&&tnames[0].equals("null")))&& boolean sync = StringUtils.isEmpty(tnames[0]) ||
(tnames[1]==null||StringUtils.isEmpty(tnames[1])||(tnames[1]!=null&&tnames[1].equals("null"))))||
(!StringUtils.isEmpty(tnames[0]) && map != null && map.get(tnames[0]) != null && map.get(tnames[0]).toString().equals("1")); (!StringUtils.isEmpty(tnames[0]) && map != null && map.get(tnames[0]) != null && map.get(tnames[0]).toString().equals("1"));
saveIdcLog("---", "", map.get(tnames[0]) + syncTables[i], 0, 0); saveIdcLog("---", "", map.get(tnames[0]) + syncTables[i], 0, 0);
if (sync) { if (sync) {
@ -309,6 +311,7 @@ public class IdcServiceImpl implements IdcService {
return result; return result;
} }
private String fetchData(String host, Map<String, Object> params) { private String fetchData(String host, Map<String, Object> params) {
OkHttpClient client = new OkHttpClient().newBuilder() OkHttpClient client = new OkHttpClient().newBuilder()
.build(); .build();
@ -359,7 +362,6 @@ public class IdcServiceImpl implements IdcService {
} }
public BaseResponse downlaodSuccess(HttpServletRequest request, Map<String, Object> params) { public BaseResponse downlaodSuccess(HttpServletRequest request, Map<String, Object> params) {
String sql = "update basic_export_status set receiveStatus='1',endTime=now() where id='" + params.get("taskId") + "'"; String sql = "update basic_export_status set receiveStatus='1',endTime=now() where id='" + params.get("taskId") + "'";
dbDao.update(sql); dbDao.update(sql);
@ -372,11 +374,13 @@ public class IdcServiceImpl implements IdcService {
return ResultVOUtils.success(); return ResultVOUtils.success();
} }
@Override @Override
public BaseResponse uploadFile(HttpServletRequest request, public BaseResponse uploadFile(HttpServletRequest request,
String content, MultipartFile[] files) { String content, MultipartFile[] files) {
return ResultVOUtils.success(); return ResultVOUtils.success();
} }
/****/ /****/
@Override @Override
public BaseResponse receive(HttpServletRequest request, public BaseResponse receive(HttpServletRequest request,
@ -681,7 +685,8 @@ public class IdcServiceImpl implements IdcService {
} }
/*增加同步任务状态*/ /*增加同步任务状态*/
private void syncAddTaskStatus(Map<String, Object> json, int scheduleType, boolean success, Date startTime, boolean isEnd) { private void syncAddTaskStatus(Map<String, Object> json, int scheduleType, boolean success, Date startTime,
boolean isEnd) {
try { try {
String content = JSON.toJSONString(json); String content = JSON.toJSONString(json);
String datePath = DateUtil.formatDate(new Date(), "yyyy-MM-dd"); String datePath = DateUtil.formatDate(new Date(), "yyyy-MM-dd");
@ -724,7 +729,8 @@ public class IdcServiceImpl implements IdcService {
} }
private boolean analyMiddle(String host, JSONObject jsonObject, MultipartFile[] files, boolean isUpload, boolean isToDB) { private boolean analyMiddle(String host, JSONObject jsonObject, MultipartFile[] files, boolean isUpload,
boolean isToDB) {
if (jsonObject.get("data") != null) { if (jsonObject.get("data") != null) {
String tableName = ""; String tableName = "";
String uniqueColumn = ""; String uniqueColumn = "";
@ -787,7 +793,9 @@ public class IdcServiceImpl implements IdcService {
/*解析到数据库*/ /*解析到数据库*/
/*按表名解析数据到数据库,子表暂未处理*/ /*按表名解析数据到数据库,子表暂未处理*/
private boolean analyToDB(String host, String tableName, String uniqueColumn, String filePathColumn, List<Map<String, Object>> list, boolean isUpload) { private boolean analyToDB(String host, String tableName, String uniqueColumn, String
filePathColumn, List<Map<String, Object>> list, boolean isUpload) {
String tName = DBAUtils.tableRealName(tableName); String tName = DBAUtils.tableRealName(tableName);
String sql = "replace " + tName + "("; String sql = "replace " + tName + "(";
@ -803,7 +811,7 @@ public class IdcServiceImpl implements IdcService {
if (col > 0) if (col > 0)
sql += ","; sql += ",";
columnList.get(i).put("attrName", columnList.get(i).get("columnName")); columnList.get(i).put("attrName", columnList.get(i).get("columnName"));
sql += columnList.get(i).get("columnName").toString(); sql += "`"+columnList.get(i).get("columnName").toString()+"`";
col++; col++;
if (uniqueColumn != null && columnList.get(i).get("columnKey") != null && ("," + uniqueColumn + ",").contains("," + columnList.get(i).get("columnName") + ",")) { if (uniqueColumn != null && columnList.get(i).get("columnKey") != null && ("," + uniqueColumn + ",").contains("," + columnList.get(i).get("columnName") + ",")) {
keyColumn[key] = columnList.get(i).get("columnName").toString(); keyColumn[key] = columnList.get(i).get("columnName").toString();
@ -1074,7 +1082,8 @@ public class IdcServiceImpl implements IdcService {
} }
/*由表名获取数据*/ /*由表名获取数据*/
private Map<String, Object> getData(String messageType, String tableName, Map<String, Object> params, Map<String, Object> whereParams) { private Map<String, Object> getData(String messageType, String
tableName, Map<String, Object> params, Map<String, Object> whereParams) {
List<Map<String, Object>> list = getList(tableName, whereParams); List<Map<String, Object>> list = getList(tableName, whereParams);
Map<String, Object> map = new HashMap<String, Object>(); Map<String, Object> map = new HashMap<String, Object>();
map.put("messageId", CustomUtil.getId()); map.put("messageId", CustomUtil.getId());
@ -1091,7 +1100,8 @@ public class IdcServiceImpl implements IdcService {
} }
private SystemParamConfigEntity getSystemParamConfig(String paramKey, String paramName, String defaultValue, String paramExplain) { private SystemParamConfigEntity getSystemParamConfig(String paramKey, String paramName, String
defaultValue, String paramExplain) {
SystemParamConfigEntity systemParamConfigEntity = systemParamConfigService.selectByParamKey(paramKey); SystemParamConfigEntity systemParamConfigEntity = systemParamConfigService.selectByParamKey(paramKey);
if (systemParamConfigEntity == null || (systemParamConfigEntity != null && StringUtils.isEmpty(systemParamConfigEntity.getParamKey()))) { if (systemParamConfigEntity == null || (systemParamConfigEntity != null && StringUtils.isEmpty(systemParamConfigEntity.getParamKey()))) {
systemParamConfigEntity = new SystemParamConfigEntity(); systemParamConfigEntity = new SystemParamConfigEntity();

Loading…
Cancel
Save