| | |
| | | } |
| | | |
| | | permsService.clearPermsCache(); |
| | | Integer rows = shuJianService.insertSjService(entity, req, res); |
| | | Integer rows = shuJianService.insertSjService(entity); |
| | | |
| | | return success(rows); |
| | | } catch (Exception ex) { |
| | |
| | | public class PublishEntity implements Serializable { |
| | | private static final long serialVersionUID = -386130556178340032L; |
| | | |
| | | private int id; |
| | | private Integer id; |
| | | |
| | | private Integer layerid; |
| | | |
| | | private Integer serviceid; |
| | | |
| | | private String name; |
| | | |
| | |
| | | |
| | | private String type; |
| | | |
| | | private int status; |
| | | private Integer status; |
| | | |
| | | private String dirid; |
| | | |
| | | private String depid; |
| | | |
| | | private int min; |
| | | private Integer enhanceType; |
| | | |
| | | private int max; |
| | | private Integer min; |
| | | |
| | | private Integer max; |
| | | |
| | | private Integer epsg; |
| | | |
| | | private String ctType; |
| | | |
| | | private String ctJson; |
| | | |
| | | private String json; |
| | | |
| | | private int createUser; |
| | | private Integer createUser; |
| | | |
| | | private Timestamp createTime; |
| | | |
| | | private int updateUser; |
| | | private Integer updateUser; |
| | | |
| | | private Timestamp updateTime; |
| | | |
| | |
| | | |
| | | private String updateName; |
| | | |
| | | private Integer layerid; |
| | | |
| | | private Integer serviceid; |
| | | |
| | | public PublishEntity() { |
| | | } |
| | | |
| | | public int getId() { |
| | | public Integer getId() { |
| | | return id; |
| | | } |
| | | |
| | | public void setId(int id) { |
| | | public void setId(Integer id) { |
| | | this.id = id; |
| | | } |
| | | |
| | | public Integer getLayerid() { |
| | | return layerid; |
| | | } |
| | | |
| | | public void setLayerid(Integer layerid) { |
| | | this.layerid = layerid; |
| | | } |
| | | |
| | | public Integer getServiceid() { |
| | | return serviceid; |
| | | } |
| | | |
| | | public void setServiceid(Integer serviceid) { |
| | | this.serviceid = serviceid; |
| | | } |
| | | |
| | | public String getName() { |
| | |
| | | this.type = type; |
| | | } |
| | | |
| | | public int getStatus() { |
| | | public Integer getStatus() { |
| | | return status; |
| | | } |
| | | |
| | | public void setStatus(int status) { |
| | | public void setStatus(Integer status) { |
| | | this.status = status; |
| | | } |
| | | |
| | |
| | | this.depid = depid; |
| | | } |
| | | |
| | | public int getMin() { |
| | | public Integer getEnhanceType() { |
| | | return enhanceType; |
| | | } |
| | | |
| | | public void setEnhanceType(Integer enhanceType) { |
| | | this.enhanceType = enhanceType; |
| | | } |
| | | |
| | | public Integer getMin() { |
| | | return min; |
| | | } |
| | | |
| | | public void setMin(int min) { |
| | | public void setMin(Integer min) { |
| | | this.min = min; |
| | | } |
| | | |
| | | public int getMax() { |
| | | public Integer getMax() { |
| | | return max; |
| | | } |
| | | |
| | | public void setMax(int max) { |
| | | public void setMax(Integer max) { |
| | | this.max = max; |
| | | } |
| | | |
| | | public Integer getEpsg() { |
| | | return epsg; |
| | | } |
| | | |
| | | public void setEpsg(Integer epsg) { |
| | | this.epsg = epsg; |
| | | } |
| | | |
| | | public String getCtType() { |
| | | return ctType; |
| | | } |
| | | |
| | | public void setCtType(String ctType) { |
| | | this.ctType = ctType; |
| | | } |
| | | |
| | | public String getCtJson() { |
| | | return ctJson; |
| | | } |
| | | |
| | | public void setCtJson(String ctJson) { |
| | | this.ctJson = ctJson; |
| | | } |
| | | |
| | | public String getJson() { |
| | |
| | | this.json = json; |
| | | } |
| | | |
| | | public int getCreateUser() { |
| | | public Integer getCreateUser() { |
| | | return createUser; |
| | | } |
| | | |
| | | public void setCreateUser(int createUser) { |
| | | public void setCreateUser(Integer createUser) { |
| | | this.createUser = createUser; |
| | | } |
| | | |
| | |
| | | this.createTime = createTime; |
| | | } |
| | | |
| | | public int getUpdateUser() { |
| | | public Integer getUpdateUser() { |
| | | return updateUser; |
| | | } |
| | | |
| | | public void setUpdateUser(int updateUser) { |
| | | public void setUpdateUser(Integer updateUser) { |
| | | this.updateUser = updateUser; |
| | | } |
| | | |
| | |
| | | |
| | | public void setUpdateName(String updateName) { |
| | | this.updateName = updateName; |
| | | } |
| | | |
| | | public Integer getLayerid() { |
| | | return layerid; |
| | | } |
| | | |
| | | public void setLayerid(Integer layerid) { |
| | | this.layerid = layerid; |
| | | } |
| | | |
| | | public Integer getServiceid() { |
| | | return serviceid; |
| | | } |
| | | |
| | | public void setServiceid(Integer serviceid) { |
| | | this.serviceid = serviceid; |
| | | } |
| | | } |
| | |
| | | import com.alibaba.fastjson.JSON; |
| | | import com.moon.server.entity.all.StaticData; |
| | | import com.moon.server.entity.ctrl.PubEntity; |
| | | import com.moon.server.entity.data.MetaPubEntity; |
| | | import com.moon.server.entity.data.PublishEntity; |
| | | import com.moon.server.entity.shujian.*; |
| | | import com.moon.server.helper.HttpHelper; |
| | |
| | | */ |
| | | @Service |
| | | public class ShuJianService { |
| | | private final static Log log = LogFactory.getLog(ShuJianService.class); |
| | | |
| | | @Value("${shujian.ak}") |
| | | private String ak; |
| | | |
| | |
| | | |
| | | @Resource |
| | | PublishService publishService; |
| | | |
| | | private final static Log log = LogFactory.getLog(ShuJianService.class); |
| | | |
| | | /** |
| | | * 分页查询数简的颜色表 |
| | |
| | | /** |
| | | * 插入数简服务 |
| | | */ |
| | | public Integer insertSjService(PubEntity pubEntity, HttpServletRequest req, HttpServletResponse res) { |
| | | CreateLayerEntity layerEntity = createLayerEntity(pubEntity); |
| | | public Integer insertSjService(PubEntity pub) { |
| | | CreateLayerEntity layerEntity = createLayerEntity(pub); |
| | | Integer layerId = postLayerEntity(layerEntity); |
| | | if (null == layerId) { |
| | | return 0; |
| | | } |
| | | |
| | | CreateServiceEntity serviceEntity = createServiceEntity(pubEntity); |
| | | CreateServiceEntity serviceEntity = createServiceEntity(pub); |
| | | Integer serviceId = postServiceEntity(serviceEntity); |
| | | if (null == serviceId) { |
| | | return 0; |
| | | } |
| | | |
| | | PublishEntity publishEntity = createPublishEntity(pubEntity, layerId, serviceId); |
| | | PublishEntity publishEntity = createPublishEntity(pub, layerId, serviceId); |
| | | Integer id = publishService.insert(publishEntity); |
| | | if (null == id) { |
| | | return id; |
| | | } |
| | | |
| | | return publishService.insert(publishEntity); |
| | | return insertMetaPub(pub, id); |
| | | } |
| | | |
| | | /** |
| | |
| | | * 创建发布实体类 |
| | | */ |
| | | public PublishEntity createPublishEntity(PubEntity pub, Integer layerId, Integer serviceId) { |
| | | String epsg = (StaticData.I104903 == pub.getEpsgCode() ? "ESRI:" : "EPSG:") + pub.getEpsgCode(); |
| | | |
| | | PublishEntity entity = new PublishEntity(); |
| | | entity.setType(pub.getType()); |
| | | entity.setName(pub.getName()); |
| | | entity.setMin(pub.getMin()); |
| | | entity.setMax(pub.getMax()); |
| | | entity.setBak(epsg); |
| | | entity.setBak(getEpsg(pub)); |
| | | 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)); |
| | | |
| | | return entity; |
| | | } |
| | | |
| | | /** |
| | | * 获取EPSG编码 |
| | | */ |
| | | public String getEpsg(PubEntity pub) { |
| | | if (StaticData.I104903 == pub.getEpsgCode()) { |
| | | return "ESRI:" + pub.getEpsgCode(); |
| | | } |
| | | |
| | | return "EPSG:" + pub.getEpsgCode(); |
| | | } |
| | | |
| | | /** |
| | | * 获取颜色表的JSON字符串 |
| | | */ |
| | | public String getColorTableJson(PubEntity pub) { |
| | | if (null == pub.getColorTable() && null == pub.getGradientColorTable()) { |
| | | return null; |
| | | } |
| | | |
| | | if (null != pub.getGradientColorTable()) { |
| | | return JSON.toJSONString(pub.getGradientColorTable()); |
| | | } |
| | | |
| | | return JSON.toJSONString(pub.getColorTable()); |
| | | } |
| | | |
| | | /** |
| | | * 插入元数据发布类 |
| | | */ |
| | | private int insertMetaPub(PubEntity pub, Integer pubid) { |
| | | int count = 0; |
| | | for (Integer metaid : pub.getIds()) { |
| | | MetaPubEntity mp = new MetaPubEntity(); |
| | | mp.setMetaid(metaid); |
| | | mp.setPubid(pubid); |
| | | mp.setCreateUser(pub.getUserId()); |
| | | |
| | | count += publishService.insertMetaPub(mp); |
| | | } |
| | | |
| | | return count; |
| | | } |
| | | |
| | | /** |
| | |
| | | */ |
| | | public Integer deletesSjServices(List<Integer> ids) { |
| | | String strs = StringHelper.join(ids, ","); |
| | | |
| | | List<PublishEntity> list = publishService.selectByIds(strs); |
| | | if (null == list || list.isEmpty()) { |
| | | return 0; |
| | |
| | | </selectKey> |
| | | |
| | | insert into lf.sys_publish |
| | | (layerid,serviceid,name,url,path,type,status,dirid,depid,min,max,json,create_user,create_time,geom,bak) |
| | | (layerid,serviceid,name,url,path,type,status,dirid,depid,enhance_type,min,max,epsg,ct_type,ct_json,json,create_user,create_time,geom,bak) |
| | | values |
| | | (#{layerid},#{serviceid},#{name},#{url},#{path},#{type},#{status},#{dirid},#{depid},#{min},#{max},#{json},#{createUser},now(),${geom},#{bak}) |
| | | (#{layerid},#{serviceid},#{name},#{url},#{path},#{type},#{status},#{dirid},#{depid},#{enhanceType},#{min},#{max},#{epsg},#{ctType},#{ctJson},#{json},#{createUser},now(),${geom},#{bak}) |
| | | </insert> |
| | | |
| | | <insert id="insertPubDown"> |
| | |
| | | |
| | | <insert id="inserts"> |
| | | insert into lf.sys_publish |
| | | (layerid,serviceid,,name,url,path,type,status,dirid,depid,min,max,json,create_user,create_time,geom,bak) |
| | | (layerid,serviceid,name,url,path,type,status,dirid,depid,enhance_type,min,max,epsg,ct_type,ct_json,json,create_user,create_time,geom,bak) |
| | | values |
| | | <foreach collection="list" item="item" index="index" separator=","> |
| | | (#{item.layerid},#{item.serviceid},#{item.name},#{item.url},#{item.path},#{item.type},#{item.status},#{item.dirid},#{item.depid},#{item.min},#{item.max},#{item.json},#{item.createUser},now(),${item.geom},#{item.bak}) |
| | | (#{item.layerid},#{item.serviceid},#{item.name},#{item.url},#{item.path},#{item.type},#{item.status},#{item.dirid},#{item.depid},#{item.enhanceType},#{item.min},#{item.max},#{item.epsg},#{item.ctType},#{item.ctJson},#{item.json},#{item.createUser},now(),${item.geom},#{item.bak}) |
| | | </foreach> |
| | | </insert> |
| | | |
| | |
| | | |
| | | <update id="update"> |
| | | update lf.sys_publish |
| | | set layerid=#{layerid},serviceid=#{serviceid},name=#{name},url=#{url},path=#{path},type=#{type},status=#{status},dirid=#{dirid},depid=#{depid},min=#{min},max=#{max},json=#{json},update_user=#{updateUser},update_time=now(),geom=${geom},bak=#{bak} |
| | | set layerid=#{layerid},serviceid=#{serviceid},name=#{name},url=#{url},path=#{path},type=#{type},status=#{status},dirid=#{dirid},depid=#{depid},enhance_type=#{enhanceType},min=#{min},max=#{max},epsg=#{epsg},ct_type=#{ctType},ct_json=#{ctJson},json=#{json},update_user=#{updateUser},update_time=now(),geom=${geom},bak=#{bak} |
| | | where id=#{id} |
| | | </update> |
| | | |
| | | <update id="updates"> |
| | | <foreach collection="list" item="item" index="index" separator=";"> |
| | | update lf.sys_publish |
| | | <set> |
| | | layerid=#{item.layerid},serviceid=#{item.serviceid},name=#{item.name},url=#{item.url},path=#{item.path},type=#{item.type},status=#{item.status},dirid=#{item.dirid},depid=#{item.depid},min=#{item.min},max=#{item.max},json=#{item.json},update_user=#{item.updateUser},update_time=now(),geom=#{item.geom},bak=#{item.bak} |
| | | </set> |
| | | set layerid=#{item.layerid},serviceid=#{item.serviceid},name=#{item.name},url=#{item.url},path=#{item.path},type=#{item.type},status=#{item.status},dirid=#{item.dirid},depid=#{item.depid},enhance_type=#{item.enhanceType},min=#{item.min},max=#{item.max},epsg=#{item.epsg},ct_type=#{item.ctType},ct_json=#{item.ctJson},json=#{item.json},update_user=#{item.updateUser},update_time=now(),geom=${item.geom},bak=#{item.bak} |
| | | where id = #{item.id} |
| | | </foreach> |
| | | </update> |