From 796b44ea813a1133beae4f3a67f1c0263510c0c7 Mon Sep 17 00:00:00 2001 From: 13693261870 <252740454@qq.com> Date: 星期日, 17 十一月 2024 09:45:07 +0800 Subject: [PATCH] 1 --- src/main/java/com/moon/server/service/data/ShuJianService.java | 437 +++++++++++++++++++++++++++++++++++++++++++++++------- 1 files changed, 381 insertions(+), 56 deletions(-) diff --git a/src/main/java/com/moon/server/service/data/ShuJianService.java b/src/main/java/com/moon/server/service/data/ShuJianService.java index df0510e..7e99ab0 100644 --- a/src/main/java/com/moon/server/service/data/ShuJianService.java +++ b/src/main/java/com/moon/server/service/data/ShuJianService.java @@ -7,16 +7,20 @@ import com.moon.server.entity.data.MetaPubEntity; import com.moon.server.entity.data.PublishEntity; import com.moon.server.entity.shujian.*; +import com.moon.server.entity.sys.LayerEntity; +import com.moon.server.entity.sys.ResEntity; import com.moon.server.helper.HttpHelper; -import com.moon.server.helper.PathHelper; import com.moon.server.helper.RestHelper; import com.moon.server.helper.StringHelper; +import com.moon.server.helper.WebHelper; +import com.moon.server.service.sys.LayerService; +import com.moon.server.service.sys.ResService; import org.apache.commons.logging.Log; import org.apache.commons.logging.LogFactory; import org.springframework.beans.factory.annotation.Value; -import org.springframework.http.HttpMethod; -import org.springframework.http.ResponseEntity; +import org.springframework.http.*; import org.springframework.stereotype.Service; +import org.springframework.web.bind.annotation.RequestBody; import org.springframework.web.client.RestTemplate; import javax.annotation.Resource; @@ -34,11 +38,23 @@ @Value("${shujian.ak}") String ak; - @Value("${shujian.url}") - String sjUrl; + @Value("${shujian.url1}") + String sjUrl1; + + @Value("${shujian.url5}") + String sjUrl5; + + @Value("${shujian.path}") + String sjPath; + + @Value("${shujian.domName}") + String domName; + + @Value("${shujian.demName}") + String demName; @Resource - PathHelper pathHelper; + ResService resService; @Resource MetaService metaService; @@ -46,21 +62,67 @@ @Resource PublishService publishService; + @Resource + LayerService layerService; + private final static Log log = LogFactory.getLog(ShuJianService.class); public final static List<String> TYPES = new ArrayList<>(Arrays.asList("DOM", "DEM")); + + private final static String DOM_FORMAT = "%s/sj_raster/v6/wmts/service/system/%d/%s"; + + private final static String DEM_FORMAT = "%s/sj_raster/v6/terrain_mesh/service/system/%d/%s"; + + private final static String API_LAYER = "%s/sj_raster/v6/api/layer?%s&sort=name%%20asc"; + + private final static String MISSION_STATUS = "%s/sj_raster/v6/api/mission/%d?op=get_status&%s"; + + private final static String COLOR_TABLE = "%s/sj_raster/v6/api/color_table?%s&page_count=%d&page_num=%d&key="; + + private final static String IMAGE_INFO = "%s/sj_raster/v6/api/image?%s&key=&page_num=1&page_count=1000&layer_id=%d"; /** * 鍒嗛〉鏌ヨ鏁扮畝鐨勯鑹茶〃 */ public void selectSjColorTables(Integer pageSize, Integer pageIndex, HttpServletRequest req, HttpServletResponse res) { try { - String url = String.format("%s/sj_raster/v6/api/color_table?%s&page_count=%d&page_num=%d&key=", sjUrl, ak, pageSize, pageIndex); + String url = String.format(COLOR_TABLE, sjUrl5, ak, pageSize, pageIndex); HttpHelper httpHelper = new HttpHelper(); httpHelper.service(req, res, null, url); } catch (Exception ex) { log.error(ex.getMessage(), ex); + WebHelper.writeJson2Page(res,ex.getMessage()); + } + } + + /** + * 鏌ヨ鏁扮畝鍥惧眰 + */ + public void selectSjLayers(Integer port, HttpServletRequest req, HttpServletResponse res) { + try { + String url = String.format(API_LAYER, null == port || 50001 == port ? sjUrl1 : sjUrl5, ak); + + HttpHelper httpHelper = new HttpHelper(); + httpHelper.service(req, res, null, url); + } catch (Exception ex) { + log.error(ex.getMessage(), ex); + WebHelper.writeJson2Page(res,ex.getMessage()); + } + } + + /** + * 鏌ヨ鏁扮畝浠诲姟鐘舵�� + */ + public void selectSjMissionStatus(Integer id, HttpServletRequest req, HttpServletResponse res) { + try { + String url = String.format(MISSION_STATUS, sjUrl5, id, ak); + + HttpHelper httpHelper = new HttpHelper(); + httpHelper.service(req, res, null, url); + } catch (Exception ex) { + log.error(ex.getMessage(), ex); + WebHelper.writeJson2Page(res,ex.getMessage()); } } @@ -69,24 +131,30 @@ */ public Integer insertSjService(PubEntity pub) { CreateLayerEntity layerEntity = createLayerEntity(pub); - Integer layerId = postLayerEntity(layerEntity); - if (null == layerId) { + LayerResultEntity.Result layerResult = postLayerEntity(layerEntity); + if (null == layerResult) { return 0; } - CreateServiceEntity serviceEntity = createServiceEntity(pub); + CreateServiceEntity serviceEntity = createServiceEntity(pub, layerResult.getLayer_id()); Integer serviceId = postServiceEntity(serviceEntity); if (null == serviceId) { return 0; } - PublishEntity publishEntity = createPublishEntity(pub, layerId, serviceId); - Integer id = publishService.insert(publishEntity); - if (null == id) { - return id; + PublishEntity publishEntity = createPublishEntity(pub, layerResult.getLayer_id(), serviceId); + int rows = publishService.insert(publishEntity); + if (0 == rows) { + return 0; } - return insertMetaPub(pub, id); + ResEntity resEntity = createResEntity(publishEntity); + resService.insert(resEntity); + + insertMetaPub(pub, publishEntity.getId()); + // layerService.insert(createLayerEntity(resEntity, StaticData.I3)) + + return layerResult.getMission_id(); } /** @@ -100,37 +168,53 @@ entity.setCreate_service(0); CreateLayerEntity.Layer layer = entity.getLayer(); - layer.setName(pub.getName()); + layer.setName(pub.getName() + "_" + pub.getTime()); layer.setProjection(getEpsg(pub)); - layer.setType(TYPES.indexOf(pub.getType())); + layer.setType(getPublishType(pub)); layer.setEnhance_type(pub.getEnhanceType()); + layer.setEnhance_factor(pub.getEnhanceFactor()); layer.setNodata(getNoData(pub, metas)); + layer.setConfig(getColorTableConfig(entity, pub)); - CreateLayerEntity.ImagePathList imagePathList = entity.getImage_path_list().get(0); - imagePathList.setPath(pathHelper.getConfig().getUploadPath()); - - List<CreateLayerEntity.ImageList> imageLists = entity.getImage_list(); for (MetaEntity meta : metas) { - CreateLayerEntity.ImageList imageList = entity.new ImageList(); - imageList.setPath(meta.getPath()); - imageLists.add(imageList); + String[] strs = meta.getPath().split(StaticData.BACKSLASH); + + CreateLayerEntity.ImagePathList imagePathList = entity.new ImagePathList(); + imagePathList.setPath(sjPath + strs[0]); + imagePathList.getFilter().add(strs[1]); + + entity.getImage_path_list().add(imagePathList); } return entity; } /** + * 鑾峰彇鍙戝竷绫诲瀷 + */ + private int getPublishType(PubEntity pub) { + if (null != pub.getColorTable() || null != pub.getGradientColorTable()) { + return StaticData.I2; + } + + return TYPES.indexOf(pub.getType()); + } + + /** * 鑾峰彇EPSG缂栫爜 */ public String getEpsg(PubEntity pub) { - if (StaticData.I104903 == pub.getEpsgCode()) { - return "ESRI:" + pub.getEpsgCode(); + if (StaticData.I104903 == pub.getEpsg()) { + return "ESRI:" + pub.getEpsg(); } - return "EPSG:" + pub.getEpsgCode(); + return "EPSG:" + pub.getEpsg(); } - private List<String> getNoData(PubEntity pub, List<MetaEntity> metas) { + /** + * 鑾峰彇 nodata + */ + private List<Integer> getNoData(PubEntity pub, List<MetaEntity> metas) { int bands = 1; for (MetaEntity meta : metas) { if (StringHelper.isEmpty(meta.getBands())) { @@ -146,46 +230,62 @@ } } - List<String> list = new ArrayList<>(); + List<Integer> list = new ArrayList<>(); for (int i = 0; i < bands; i++) { - list.add(String.valueOf(pub.getNodata())); + list.add(pub.getNodata()); } return list; } /** + * 鑾峰彇棰滆壊琛ㄧ殑閰嶇疆 + */ + private CreateLayerEntity.Config getColorTableConfig(CreateLayerEntity entity, PubEntity pub) { + if (null == pub.getColorTable() && null == pub.getGradientColorTable()) { + return null; + } + + Integer type = null != pub.getColorTable() ? 0 : 1; + List<?> levels = null != pub.getColorTable() ? pub.getColorTable() : pub.getGradientColorTable(); + + return entity.new Config(pub.getColorTableId(), type, levels); + } + + /** * 鍙戦�佸浘灞傚疄浣撶被 */ - public Integer postLayerEntity(CreateLayerEntity layerEntity) { + public LayerResultEntity.Result postLayerEntity(CreateLayerEntity layerEntity) { Map<String, Object> map = getMapData(layerEntity); - String url = String.format("%s/sj_raster/sj_raster/v6/api/layer?%s", sjUrl, ak); + String url = String.format("%s/sj_raster/v6/api/layer?op=create_ex&%s", sjUrl5, ak); LayerResultEntity rs = postForRest(url, map, LayerResultEntity.class); - boolean flag = null == rs || !StaticData.SUCCESS.equals(rs.getStatus()) || null == rs.getResult().getLayer_id(); + boolean flag = null == rs || !StaticData.SUCCESS.equals(rs.getStatus()); - return flag ? null : rs.getResult().getLayer_id(); + return flag ? null : rs.getResult(); } /** * 鍒涘缓鏈嶅姟瀹炰綋绫� */ - public CreateServiceEntity createServiceEntity(PubEntity pubEntity) { + public CreateServiceEntity createServiceEntity(PubEntity pub, Integer layerId) { CreateServiceEntity entity = new CreateServiceEntity(); List<Integer> layerList = entity.getLayer_list(); + layerList.add(layerId); CreateServiceEntity.Services services = entity.getService(); - services.setName(""); - services.setAccess_name(StringHelper.getGuid()); + services.setName(pub.getName() + "_" + pub.getTime()); + services.setAccess_name(pub.getUuid()); services.setPub_status(1); services.setRect_minx(-180.0); services.setRect_miny(-90.0); services.setRect_maxx(180.0); services.setRect_maxy(90.0); - services.setProjection("ESRI:" + StaticData.I104903); + services.setProjection(getEpsg(pub)); services.setSat_id(-1); services.setSensor_id(-1); services.setImage_type(-1); + services.setConfig(null); return entity; } @@ -195,7 +295,7 @@ */ public Integer postServiceEntity(CreateServiceEntity serviceEntity) { Map<String, Object> map = getMapData(serviceEntity); - String url = String.format("%s/sj_raster/v6/api/service?op=create_ex&%s", sjUrl, ak); + String url = String.format("%s/sj_raster/v6/api/service?op=create_ex&%s", sjUrl5, ak); ServiceResultEntity rs = postForRest(url, map, ServiceResultEntity.class); boolean flag = null == rs || !StaticData.SUCCESS.equals(rs.getStatus()) || null == rs.getResult(); @@ -208,20 +308,99 @@ */ public PublishEntity createPublishEntity(PubEntity pub, Integer layerId, Integer serviceId) { PublishEntity entity = new PublishEntity(); - entity.setType(pub.getType()); - entity.setName(pub.getName()); - entity.setMin(pub.getMin()); - entity.setMax(pub.getMax()); - entity.setEpsg(pub.getEpsgCode()); - entity.setCreateUser(pub.getUserId()); - entity.setDirid(pub.getDircode()); - entity.setDepid(pub.getDepcode()); - entity.setStatus(3); entity.setLayerid(layerId); entity.setServiceid(serviceId); - entity.setJson(getColorTableJson(pub)); + entity.setEventid(pub.getUuid()); + entity.setName(pub.getName()); + entity.setUrl(String.format(TYPES.get(0).equals(pub.getType()) ? DOM_FORMAT : DEM_FORMAT, sjUrl5, serviceId, StaticData.I0)); + entity.setPath(null); + entity.setType(pub.getType()); + entity.setStatus(3); + entity.setDirid(pub.getDircode()); + entity.setDepid(pub.getDepcode()); + entity.setEnhanceType(pub.getEnhanceType()); + entity.setMin(pub.getMin()); + entity.setMax(pub.getMax()); + entity.setEpsg(pub.getEpsg()); + entity.setCreateUser(pub.getUserId()); + entity.setCtType(getColorTableType(pub)); + entity.setCtJson(getColorTableJson(pub)); + entity.setCreateUser(pub.getUserId()); + entity.setGeom("null"); return entity; + } + + /** + * 鍒涘缓璧勬簮瀹炰綋绫� + */ + private ResEntity createResEntity(PublishEntity pub) { + ResEntity entity = new ResEntity(); + entity.setCnName(pub.getName()); + // 鐘舵�侊細0-绂佺敤锛�1-鍚敤鍘熷鍦板潃锛�2-鍚敤浠g悊鍦板潃 + entity.setStatus(2); + // 鏈嶅姟绫诲埆锛�0-鍏朵粬锛�1-GisServer锛�2-GeoServer锛�3-鏁扮畝 + entity.setCategory(3); + // 鏈嶅姟绫诲瀷锛�0-URL锛�1-TMS锛�2-WMTS锛�3-WMS锛�4-WFS锛�5-Tileset + entity.setType(StaticData.DOM.equals(pub.getType()) ? 2 : 0); + // 鏁版嵁绫诲瀷锛�0-URL锛�1-DOM锛�2-DEM + entity.setData(StaticData.DOM.equals(pub.getType()) ? 1 : 2); + entity.setUrl(pub.getUrl()); + entity.setArgs(ak); + entity.setDescr("绯荤粺鑷姩鍒涘缓"); + entity.setDepid(pub.getDepid()); + entity.setDirid(pub.getDirid()); + entity.setCreateUser(pub.getCreateUser()); + entity.setPubid(pub.getId()); + + return entity; + } + + /** + * 鍒涘缓鍥惧眰 + */ + private LayerEntity createLayerEntity(ResEntity resEntity, Integer category) { + Integer pid = layerService.selectIdByName(StaticData.I1 == resEntity.getData() ? domName : demName); + Integer orderNum = layerService.selectMaxOrderNumByPid(pid); + LayerEntity layer = layerService.selectById(pid); + + LayerEntity entity = new LayerEntity(); + entity.setPid(pid); + entity.setCnName(resEntity.getCnName()); + entity.setEnName(resEntity.getEnName()); + entity.setUrl(resEntity.getProxy()); + // 鏄惁涓哄浘灞傦細0-鍥惧眰缁�,1-鍥惧眰 + entity.setIsLayer(1); + entity.setLevel(null == layer ? 1 : layer.getLevel() + 1); + entity.setOrderNum(orderNum); + // 鐘舵�侊細0-鍋滄锛�1-鍚敤 + entity.setStatus(1); + entity.setCreateUser(resEntity.getCreateUser()); + entity.setResid(resEntity.getId()); + // 绫诲埆锛�0-URL锛�1-TMS锛�2-WMTS锛�3-WMS锛�4-WFS锛�5-Tileset + entity.setType(StaticData.I1 == resEntity.getData() ? 2 : 0); + // 鏁版嵁绫诲瀷锛�0-URL锛�1-DOM锛�2-DEM + entity.setData(resEntity.getData()); + // 鏈嶅姟绫诲埆锛�0-鍏朵粬锛�1-GisServer锛�2-GeoServer锛�3-鏁扮畝 + entity.setCategory(category); + // 鏄�/鍚﹂粯璁ゆ樉绀� + entity.setIsShow(0); + + return entity; + } + + /** + * 鑾峰彇棰滆壊琛ㄧ被鍨� + */ + private String getColorTableType(PubEntity pub) { + if (null == pub.getColorTable() && null == pub.getGradientColorTable()) { + return null; + } + if (null != pub.getGradientColorTable()) { + return "娓愬彉棰滆壊琛�"; + } + + return "鏅�氶鑹茶〃"; } /** @@ -257,9 +436,9 @@ } /** - * 鎻掑叆鏁扮畝鏈嶅姟 + * 鏇存柊鏁扮畝鏈嶅姟 */ - public Integer updateSjService(PubEntity pub, HttpServletRequest req, HttpServletResponse res) { + public Integer updateSjService(PubEntity pub) { PublishEntity entity = publishService.selectById(pub.getPubid()); if (null == entity) { return 0; @@ -270,8 +449,73 @@ if (null != entity.getServiceid()) { deleteService(entity.getServiceid()); } + setPubEntity(pub, entity); - return 1; + CreateLayerEntity layerEntity = createLayerEntity(pub); + LayerResultEntity.Result layerResult = postLayerEntity(layerEntity); + if (null == layerResult) { + return 0; + } + + CreateServiceEntity serviceEntity = createServiceEntity(pub, layerResult.getLayer_id()); + Integer serviceId = postServiceEntity(serviceEntity); + if (null == serviceId) { + return 0; + } + + entity.setLayerid(layerResult.getLayer_id()); + entity.setServiceid(serviceId); + entity.setEventid(pub.getUuid()); + entity.setUpdateUser(pub.getUserId()); + entity.setUrl(String.format(TYPES.get(0).equals(pub.getType()) ? DOM_FORMAT : DEM_FORMAT, sjUrl5, serviceId, StaticData.I0)); + if (StringHelper.isEmpty(entity.getGeom())) { + entity.setGeom(StaticData.NULL); + } + + int rows = publishService.update(entity); + if (0 == rows) { + return 0; + } + + ResEntity resEntity = resService.selectByPubid(entity.getId()); + if (null == resEntity) { + resEntity = createResEntity(entity); + resService.insert(resEntity); + } else { + resEntity.setUpdateUser(pub.getUserId()); + resEntity.setCnName(entity.getName()); + resEntity.setUrl(entity.getUrl()); + resService.update(resEntity); + } + + LayerEntity lyrEntity = layerService.selectByResId(resEntity.getId()); + if (null != lyrEntity) { + lyrEntity.setCnName(resEntity.getCnName()); + lyrEntity.setUpdateUser(pub.getUserId()); + layerService.update(lyrEntity); + } + + return layerResult.getMission_id(); + } + + /** + * 璁剧疆鍙戝竷瀹炰綋绫� + */ + private void setPubEntity(PubEntity pub, PublishEntity entity) { + List<MetaEntity> metas = publishService.selectMetasByPubid(pub.getPubid()); + + List<Integer> ids = new ArrayList<>(); + for (MetaEntity meta : metas) { + ids.add(meta.getId()); + } + pub.setIds(ids); + + if (StringHelper.isEmpty(pub.getName())) { + pub.setName(entity.getName()); + } + if (null == pub.getEpsg() || 0 == pub.getEpsg()) { + pub.setEpsg(entity.getEpsg()); + } } /** @@ -292,8 +536,9 @@ deleteService(entity.getServiceid()); } } + publishService.deletes(strs); - return publishService.deletes(strs); + return list.size(); } /** @@ -305,7 +550,7 @@ entity.getId_list().add(id); Map<String, Object> map = getMapData(entity); - String url = String.format("%s/sj_raster/sj_raster/v6/api/layer?%s", sjUrl, ak); + String url = String.format("%s/sj_raster/v6/api/layer?%s", sjUrl5, ak); DeleteResultEntity rs = deleteForRest(url, map); @@ -325,7 +570,7 @@ entity.getId_list().add(id); Map<String, Object> map = getMapData(entity); - String url = String.format("%s/sj_raster/sj_raster/v6/api/service?%s", sjUrl, ak); + String url = String.format("%s/sj_raster/v6/api/service?%s", sjUrl5, ak); DeleteResultEntity rs = deleteForRest(url, map); @@ -349,8 +594,13 @@ * delete璇锋眰锛圧est锛� */ public DeleteResultEntity deleteForRest(String url, Map<String, Object> map) { + HttpHeaders headers = new HttpHeaders(); + headers.setContentType(MediaType.APPLICATION_JSON); + + HttpEntity<?> entity = new HttpEntity<>(map, headers); + RestTemplate rest = RestHelper.getRestTemplate(); - ResponseEntity<DeleteResultEntity> rs = rest.exchange(url, HttpMethod.DELETE, null, DeleteResultEntity.class, map); + ResponseEntity<DeleteResultEntity> rs = rest.exchange(url, HttpMethod.DELETE, entity, DeleteResultEntity.class); return rs.getBody(); } @@ -379,4 +629,79 @@ return map; } + + /** + * 鑾峰彇浠诲姟鐘舵�� + */ + public List<TaskResultEntity.Result> getTaskStatus(List<Integer> list) { + String url = String.format("%s/sj_raster/v6/api/mission?op=bulk_get_mission_status&%s", sjUrl5, ak); + Map<String, Object> map = new HashMap<>(1); + map.put("cmd_list", list); + + TaskResultEntity rs = postForRest(url, map, TaskResultEntity.class); + boolean flag = null == rs || !StaticData.SUCCESS.equals(rs.getStatus()); + + return flag ? null : rs.getResult(); + } + + /** + * 鏇存柊鏁扮畝鍥惧眰鐨勬媺浼告柟寮� + */ + public Integer updateSjLayerStretch(PubEntity entity) { + PublishEntity pub = publishService.selectByLayerId(entity.getLayerId()); + if (null == pub || null == pub.getLayerid()) { + return 0; + } + + ImageResultEntity ir = selectImageInfo(pub.getLayerid()); + if (null == ir || null == ir.getResult() || null == ir.getResult().getItem_list()) { + return 0; + } + + List<ImageResultEntity.Image> itemList = ir.getResult().getItem_list(); + for (ImageResultEntity.Image image : itemList) { + Integer imgId = updateImageLayerStretch(image.getData_id(), entity); + } + + pub.setUpdateUser(entity.getUserId()); + if (null == pub.getGeom()) { + pub.setGeom("null"); + } + + return publishService.update(pub); + } + + /** + * 鏍规嵁鍥惧眰ID鏌ヨ褰卞儚淇℃伅 + */ + public ImageResultEntity selectImageInfo(Integer layerId) { + try { + String url = String.format(IMAGE_INFO, sjUrl5, ak, layerId); + + RestTemplate rest = RestHelper.getRestTemplate(); + ResponseEntity<ImageResultEntity> resp = rest.getForEntity(url, ImageResultEntity.class); + + return resp.getBody(); + } catch (Exception ex) { + log.error(ex.getMessage(), ex); + return null; + } + } + + /** + * 鏇存柊褰卞儚鍥惧眰鐨勬媺浼告柟寮� + */ + private Integer updateImageLayerStretch(Integer imageLayerId, PubEntity entity) { + String url = String.format("%s/sj_raster/v6/api/image/%d?op=update&%s", sjUrl5, imageLayerId, ak); + + Map<String, Object> map = new HashMap<>(3); + map.put("tile_rgb", entity.getTile_rgb()); + map.put("enhance_type", entity.getEnhanceType()); + map.put("enhance_factor", entity.getEnhanceFactor()); + + ServiceResultEntity rs = postForRest(url, map, ServiceResultEntity.class); + boolean flag = null == rs || !StaticData.SUCCESS.equals(rs.getStatus()); + + return flag ? null : rs.getResult(); + } } -- Gitblit v1.9.3