springCloud_dataservice_bus.zip

package com.csii.publish.service.impl; import com.csii.publish.dao.*; import com.csii.publish.service.PublishedServicesService; import entities.*; import net.sf.json.JSONArray; import net.sf.json.JSONObject; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.stereotype.Service; import org.springframework.transaction.annotation.Transactional; import java.sql.Connection; import java.sql.DriverManager; import java.sql.ResultSet; import java.sql.Statement; import java.text.SimpleDateFormat; import java.util.*; /** * @author wanggc * @date 2020/7/29 18:26 * @email wanggaochong@csii.com.cn */ @Service public class PublishedServicesServiceImpl implements PublishedServicesService { @Autowired(required = false) PublishedServicesMapper publishedServicesMapper; @Autowired(required = false) DatabaseAssestsMapper databaseAssestsMapper; @Autowired(required = false) TableAssetsMapper tableAssetsMapper; @Autowired(required = false) FieldAssestsMapper fieldAssestsMapper; @Autowired(required = false) PublishedServicesMetaMapper publishedServicesMetaMapper; @Autowired(required = false) PublishedDatabaseAssestsMapper publishedDatabaseAssestsMapper; @Autowired(required = false) PublishedTableAssetsMapper publishedTableAssetsMapper; @Autowired(required = false) PublishedFieldAssestsMapper publishedFieldAssestsMapper; PublishedServices publishedServices =new PublishedServices(); PublishedServicesMeta publishedServicesMeta; PublishedDatabaseAssests publishedDatabaseAssests=new PublishedDatabaseAssests(); PublishedTableAssets publishedTableAssets; PublishedFieldAssests publishedFieldAssests; SimpleDateFormat df = new SimpleDateFormat("YYYYMMddHHmmss"); Date date; @Override public List<Map<String, Object>> getMetaFromMysql(Map<String, Object> map) { List<Map<String,Object>> datas= null; String ds_type = map.get("dsType").toString(); String db_name = map.get("dbName").toString(); String table_name = map.get("tableName").toString(); if(!ds_type.equals("") && db_name.equals("") && table_name.equals("")){ datas= databaseAssestsMapper.selectdatabaseNamesByDsTpye(map); } else if(!ds_type.equals("") && !db_name.equals("") && table_name.equals("")){ datas= tableAssetsMapper.selectTableNamesByDatabase(map); } else if(!ds_type.equals("") && !db_name.equals("") && !table_name.equals("")){ datas= fieldAssestsMapper.selectFieldNamesByTable(map); } else{ System.out.print("非法"); } return datas; } /** * 获取API,将API数据项导入到数据库 * @param map * @return */ @Override @Transactional public int addServiceApi(LinkedHashMap<String, Object> map,CommonResult commonResult) { JSONObject jsonObject = JSONObject.fromObject(map); List<PublishedServicesMeta> fieldList = new ArrayList<>(); date =new Date(); List<PublishedServices> publishService; String publishedId = df.format(date); String serviceName = jsonObject.getString("serviceName").trim(); if(!serviceName.equals("") && serviceName != null){ publishService = publishedServicesMapper.selectBypublishedServiceName(serviceName); if(publishService.size() > 0){ commonResult.setCode(200); commonResult.setMessage("服务API【"+serviceName+"】已经添加，重新设置服务名称"); return -1; }else { //设置API url 的前缀 String url = "http://localhost:8090/csii"; String serviceUrl = url+jsonObject.getString("serviceUrl"); publishedServices.setServiceName(serviceName); publishedServices.setServiceUrl(serviceUrl); publishedServices.setRequestType(jsonObject.getString("requestType")); publishedServices.setPublishedId(publishedId); publishedServices.setServiceVersion(jsonObject.getString("serviceVersion")); publishedServices.setDataType(jsonObject.getString("dataType")); publishedServices.setDataContent(jsonObject.getString("dataContent")); publishedServices.setServiceStatus(jsonObject.getString("serviceStatus")); publishedServices.setDbType(jsonObject.getString("dbType")); publishedServices.setFilter(jsonObject.getString("filter")); publishedServices.setDecimals(jsonObject.getString("decimals")); publishedServices.setOrderType(jsonObject.getString("orderType")); publishedServices.setServiceDesc(jsonObject.getString("serviceDesc")); publishedServices.setApprovalStatus(jsonObject.getString("approvalStatus")); publishedServices.setApprovalSuggest(jsonObject.getString("approvalSuggest")); publishedServices.setApprover(jsonObject.getString("approver")); publishedServices.setApproveTime(jsonObject.getString("approveTime")); publishedServices.setCreateBy(jsonObject.getString("createBy")); publishedServices.setCreateTime(date); publishedServices.setUpdateBy(jsonObject.getString("updateBy")); publishedServices.setUpdateTime(date); publishedServicesMapper.insertSelective(publishedServices); JSONArray tableAndFields = jsonObject.getJSONArray("tableAndFields"); Iterator<JSONObject> tableIterator = tableAndFields.iterator(); while (tableIterator.hasNext()) { publishedServicesMeta = new PublishedServicesMeta(); JSONObject jsonName = tableIterator.next(); publishedServicesMeta.setDatabaseId(jsonName.getInt("databaseId")); publishedServicesMeta.setTableId(jsonName.getInt("tableId")); publishedServicesMeta.setPublishedId(publishedId); publishedServicesMeta.setApproveStatus(jsonObject.getString("approveStatus")); publishedServicesMeta.setApplyDesc(jsonObject.getString("applyDesc")); publishedServicesMeta.setRefuseReason(jsonObject.getString("refuseReason")); publishedServicesMeta.setFlag(jsonObject.getString("flag")); publishedServicesMeta.setCreateBy(jsonObject.getString("createBy")); publishedServicesMeta.setCreateTime(date); publishedServicesMeta.setUpdateBy(jsonObject.getString("updateBy")); publishedServicesMeta.setUpdateTime(date); JSONArray fields = jsonName.getJSONArray("fields"); Iterator iterator = fields.iterator(); String fieldNames = ""; while (iterator.hasNext()) { String fieldName = (String) iterator.next(); fieldNames += fieldName + ","; } fieldNames = fieldNames.substring(0, fieldNames.length() - 1); publishedServicesMeta.setFieldNameList(fieldNames); fieldList.add(publishedServicesMeta); } Integer flag = publishedServicesMetaMapper.insertSelectList(fieldList); if(flag == fieldList.size()){ commonResult.setMessage("服务API【"+serviceName+"】添加成功"); commonResult.setCode(200); return 1; }else{ commonResult.s