package com.landtool.lanbase.modules.res.service.impl;
|
|
import java.util.HashMap;
|
import java.util.List;
|
import java.util.Map;
|
|
import com.landtool.lanbase.common.utils.HttpUtils;
|
import com.landtool.lanbase.config.SysTemPropertyConfig;
|
import com.landtool.lanbase.modules.res.entity.Res_ExtBaseMap;
|
import com.qiniu.util.Json;
|
import org.springframework.beans.factory.annotation.Autowired;
|
import org.springframework.beans.factory.annotation.Value;
|
import org.springframework.stereotype.Service;
|
|
import com.landtool.lanbase.modules.res.dao.Res_ExtMapUrlMapper;
|
import com.landtool.lanbase.modules.res.entity.Res_ExtMapUrl;
|
import com.landtool.lanbase.modules.res.service.ResExtMapUrlService;
|
|
@Service("resExtMapUrlService")
|
public class ResExtMapUrlServiceImpl implements ResExtMapUrlService {
|
@Autowired
|
private Res_ExtMapUrlMapper resExtMapUrlMapper;
|
|
@Autowired
|
private SysTemPropertyConfig sysConfig;
|
@Override
|
public int deleteByPrimaryKey(int urlid) {
|
return resExtMapUrlMapper.deleteByPrimaryKey(urlid);
|
}
|
|
@Override
|
public int insert(Res_ExtMapUrl record) {
|
return resExtMapUrlMapper.insert(record);
|
}
|
|
@Override
|
public int insertSelective(Res_ExtMapUrl record) {
|
return resExtMapUrlMapper.insertSelective(record);
|
}
|
|
|
@Override
|
public Res_ExtMapUrl selectByPrimaryKey(int urlid) {
|
return resExtMapUrlMapper.selectByPrimaryKey(urlid);
|
}
|
|
@Override
|
public int updateByPrimaryKeySelective(Res_ExtMapUrl record) {
|
return resExtMapUrlMapper.updateByPrimaryKeySelective(record);
|
}
|
|
@Override
|
public int updateByPrimaryKey(Res_ExtMapUrl record) {
|
return resExtMapUrlMapper.updateByPrimaryKey(record);
|
}
|
|
@Override
|
public List<Res_ExtMapUrl> selectByCondition(Integer resourceid){return resExtMapUrlMapper.selectByCondition(resourceid);}
|
|
@Override
|
public int deleteByResourceId(Integer resourceId){return resExtMapUrlMapper.deleteByResourceId(resourceId);}
|
|
@Override
|
public Res_ExtMapUrl queryFirstOrderByResId(Integer resourceId) {
|
return resExtMapUrlMapper.queryFirstOrderByResId(resourceId);
|
}
|
|
/**获取第一条服务地址*/
|
@Override
|
public String getFirstServerUrl(Integer resourceid) {
|
String url ="";
|
List<Res_ExtMapUrl> urlList = resExtMapUrlMapper.selectByCondition(resourceid);
|
if(urlList != null && urlList.size() > 0){
|
url = urlList.get(0).getServerurl();
|
}
|
return url;
|
}
|
|
/**从空间服务Controller提取出来，插入资源支持协议与地址表**/
|
@Override
|
public void deleteAndInsertMapUrlArray(Integer resourceid,String extMapUrlStr){
|
System.out.println("extMapUrlStr = " + extMapUrlStr);
|
resExtMapUrlMapper.deleteByResourceId(resourceid);
|
if (!extMapUrlStr.equals("")) {
|
// String[] extMapUrlArray = extMapUrlStr.split("\\|");
|
//插入资源支持协议与地址表
|
// for (int i = 0; i < extMapUrlArray.length; i++) {
|
// String[] extMapUrlArray2 = extMapUrlArray[i].split(",");
|
String[] extMapUrlArray2 = extMapUrlStr.split(",");
|
String typeAndUrl = extMapUrlArray2[0];
|
String serverUrl = extMapUrlArray2[1];
|
Integer esbid = Integer.parseInt(extMapUrlArray2[2].toString());
|
Res_ExtMapUrl resExtMapUrl = new Res_ExtMapUrl();
|
resExtMapUrl.setResourceid(resourceid);
|
resExtMapUrl.setTypeandurl(typeAndUrl);
|
if(extMapUrlArray2.length>4){
|
String layertype=extMapUrlArray2[3];
|
String layername=extMapUrlArray2[4];
|
resExtMapUrl.setLayertype(layertype);
|
resExtMapUrl.setLayername(layername);
|
}
|
resExtMapUrl.setServerurl(serverUrl);
|
resExtMapUrl.setServername(extMapUrlStr.split("=").length>1?extMapUrlStr.split("=")[1]:"");
|
if(esbid != 0) resExtMapUrl.setEsbid(esbid);
|
resExtMapUrl.setIsPublic(esbid);
|
String proxyurl = getProxyurl(resExtMapUrl, resourceid);
|
resExtMapUrl.setServerurl(proxyurl);
|
resExtMapUrl.setOldserverurl(serverUrl);
|
System.out.println("resExtMapUrl = " + resExtMapUrl);
|
resExtMapUrlMapper.insertSelective(resExtMapUrl);
|
}
|
|
}
|
|
/**根据资源id获取REBids(英文逗号,分隔)**/
|
@Override
|
public String queryRsbidsByResourceid(Integer resourceid) {
|
String oldesbids = "";
|
List<Res_ExtMapUrl> oldMapUrlList = resExtMapUrlMapper.selectByCondition(resourceid);
|
if (oldMapUrlList != null && oldMapUrlList.size() > 0) {
|
for (int i = 0; i < oldMapUrlList.size(); i++) {
|
if (oldMapUrlList.get(i).getEsbid() != null && oldMapUrlList.get(i).getEsbid() != 0) {
|
if (oldesbids.length() != 0) {
|
oldesbids += "," + oldMapUrlList.get(i).getEsbid();
|
} else {
|
oldesbids += oldMapUrlList.get(i).getEsbid();
|
}
|
}
|
}
|
}
|
return oldesbids;
|
}
|
|
@Override
|
public int isExistContextPath(String contextPth){
|
return resExtMapUrlMapper.isExistContextPath(contextPth);
|
}
|
|
@Override
|
public List<Res_ExtMapUrl> selectAllUrl() {
|
return resExtMapUrlMapper.selectAllUrl();
|
}
|
|
@Override
|
public List<Map> selectBatchUrl(List<Integer> resourceids) {
|
|
return resExtMapUrlMapper.selectBatchUrl(resourceids);
|
}
|
|
private String getProxyurl(Res_ExtMapUrl record, Integer resourceid) {
|
String proxyUrl=sysConfig.getProxyUrl()+"/serverRegister/addArcGisServer";
|
String resourceIdStr="zyid="+resourceid;
|
String serverUrlStr="serverUrl="+record.getServerurl();
|
String isPublicStr= "isPublic="+record.getIsPublic();
|
String fromsys= "fromsys=HYJGPT";
|
String enable="enable=1";
|
String servername="servername="+record.getServername();
|
String s = null;
|
try {
|
s = HttpUtils.get(proxyUrl+"?"+
|
resourceIdStr+"&"+
|
serverUrlStr+"&"+
|
isPublicStr+"&"+
|
fromsys+"&"+
|
enable+"&"+
|
servername
|
);
|
} catch (Exception e) {
|
e.printStackTrace();
|
}
|
HashMap<String,Object> result= Json.decode(s,HashMap.class);
|
return (String)result.get("proxyurl");
|
}
|
|
@Override
|
public List<Res_ExtMapUrl> checkAllUrls() {
|
return resExtMapUrlMapper.checkAllUrls();
|
}
|
|
public static void main(String[] args) {
|
|
String str="DYNAMIC,http://192.168.20.106:8066/test/2,0,,ditu,|";
|
String[] split = str.split(",");
|
|
|
}
|
|
@Override
|
public Res_ExtMapUrl queryResourceId(Res_ExtMapUrl extMapUrl) {
|
return resExtMapUrlMapper.queryResourceId(extMapUrl);
|
}
|
|
@Override
|
public void updateSpcStatus(Map<String, Object> param) {
|
resExtMapUrlMapper.updateSpcStatus(param);
|
}
|
}
|
