增加网站文章相关功能，后期拆分为独立的module

platform-dao/src/main/java/com/platform/dao/vo/query/qykh/HotspotVO.java

@@ -0,0 +1,75 @@
+package com.platform.dao.vo.query.qykh;
+
+import com.platform.common.bean.BaseVO;
+import lombok.Data;
+import lombok.EqualsAndHashCode;
+import lombok.experimental.Accessors;
+
+import java.io.Serializable;
+
+/**
+ * @Description 自定义报表VO结果类
+ * @Author xc
+ * @Date 2022-05-30 19:50:16
+ * @Version Copyright (c) 2020,北京乾元坤和科技有限公司 All rights reserved.
+ */
+@Data
+@Accessors(chain = true)
+@EqualsAndHashCode(callSuper = true)
+public class HotspotVO extends BaseVO implements Serializable {
+
+    /**
+     * 主键id
+     */
+    private Integer id;
+    /**
+     * 方案类别名称
+     */
+    private String hname;
+    /**
+     * 类别说明
+     */
+    private String desrc;
+    /**
+     *
+     */
+    private String shortdesc;
+    /**
+     *
+     */
+    private Integer hid;
+    /**
+     *
+     */
+    private Integer pid;
+    /**
+     *
+     */
+    private Integer level;
+    /**
+     *
+     */
+    private String hurl;
+    /**
+     *
+     */
+    private String oname;
+
+    /**
+     *
+     */
+    private Integer ord;
+    /**
+     *
+     */
+    private Integer seoid;
+    /**
+     *
+     */
+    private Integer iszt;
+    /**
+     *
+     */
+    private String zturl;
+
+}

platform-dao/src/main/java/com/platform/dao/vo/query/qykh/InformationHelpVO.java

@@ -0,0 +1,59 @@
+package com.platform.dao.vo.query.qykh;
+
+import com.platform.common.bean.BaseVO;
+import lombok.Data;
+import lombok.EqualsAndHashCode;
+import lombok.experimental.Accessors;
+
+import java.io.Serializable;
+
+/**
+ * @Description 自定义报表VO结果类
+ * @Author xc
+ * @Date 2022-05-30 19:50:40
+ * @Version Copyright (c) 2020,北京乾元坤和科技有限公司 All rights reserved.
+ */
+@Data
+@Accessors(chain = true)
+@EqualsAndHashCode(callSuper = true)
+public class InformationHelpVO extends BaseVO implements Serializable {
+
+    /**
+     *
+     */
+    private Integer id;
+    /**
+     * 详情标题
+     */
+    private String title;
+    /**
+     *
+     */
+    private String descr;
+    /**
+     *
+     */
+    private String shortdesc;
+    /**
+     * 对应的类别id
+     */
+    private Integer pid;
+    /**
+     *
+     */
+    private String keywords;
+    /**
+     *
+     */
+    private Integer ord;
+    /**
+     *
+     */
+    private String digest;
+    /**
+     *
+     */
+    private String time;
+
+
+}

platform-dao/src/main/java/com/platform/dao/vo/query/qykh/InformationVO.java

@@ -0,0 +1,62 @@
+package com.platform.dao.vo.query.qykh;
+
+import com.platform.common.bean.BaseVO;
+import lombok.Data;
+import lombok.EqualsAndHashCode;
+import lombok.experimental.Accessors;
+
+import java.io.Serializable;
+
+/**
+ * @Description 自定义报表VO结果类
+ * @Author xc
+ * @Date 2022-05-30 19:50:16
+ * @Version Copyright (c) 2020,北京乾元坤和科技有限公司 All rights reserved.
+ */
+@Data
+@Accessors(chain = true)
+@EqualsAndHashCode(callSuper = true)
+public class InformationVO extends BaseVO implements Serializable {
+
+    /**
+     * 主键id
+     */
+    private Integer id;
+    /**
+     * 方案类别名称
+     */
+    private String inforname;
+    /**
+     * 类别说明
+     */
+    private String infordes;
+    /**
+     *
+     */
+    private Integer pid;
+    /**
+     *
+     */
+    private Integer level;
+    /**
+     *
+     */
+    private String purl;
+    /**
+     *
+     */
+    private Integer seoid;
+    /**
+     *
+     */
+    private Integer ord;
+    /**
+     *
+     */
+    private String addtime;
+
+    /**
+     *
+     */
+    private String updatetime;
+}

platform-iec/src/main/java/com/ydl/iec/iec104/server/master/handler/Iec104ClientHandler.java

@@ -69,7 +69,7 @@ public class Iec104ClientHandler extends SimpleChannelInboundHandler<MessageDeta
 		Iec104ThreadLocal.getScheduledTaskPool().stopSendTestFrame();
 		//使用过程中断线重连
 		final EventLoop eventLoop = ctx.channel().eventLoop();
-		eventLoop.schedule((Runnable) () -> {
+		eventLoop.schedule(() -> {
 			Iec104MasterFactory.createTcpClientMaster(Iec104Util.host, Iec104Util.port).run();
 		}, 5L, TimeUnit.SECONDS);
 

platform-rest/src/main/java/com/platform/rest/controller/qykh/QykhHotspotController.java

@@ -0,0 +1,69 @@
+package com.platform.rest.controller.qykh;
+
+import com.platform.common.util.R;
+import com.platform.common.validation.group.AddGroup;
+import com.platform.common.validation.group.UpdateGroup;
+import com.platform.dao.vo.query.qykh.HotspotVO;
+import com.platform.rest.log.annotation.SysLog;
+import com.platform.service.qykh.QykhHotspotService;
+import lombok.AllArgsConstructor;
+import org.springframework.security.access.prepost.PreAuthorize;
+import org.springframework.validation.annotation.Validated;
+import org.springframework.web.bind.annotation.*;
+
+@RestController
+@AllArgsConstructor
+@RequestMapping("/qykh/hotspots")
+public class QykhHotspotController {
+    private final QykhHotspotService qykhPlanDetailsService;
+    /**
+     * 通过id查询单条记录
+     *
+     * @param id 主键
+     * @return R
+     */
+    @GetMapping("/{id}")
+    public R getById(@PathVariable("id") Integer id) {
+        return new R(qykhPlanDetailsService.selectSingle(id));
+    }
+
+    /**
+     * 新增记录
+     *
+     * @param sbTypeDTO 设备类别DTO
+     * @return R
+     */
+    @SysLog("新增")
+    @PostMapping
+    @PreAuthorize("@pms.hasPermission('qykh-add')")
+    public R save(@Validated({AddGroup.class}) @RequestBody HotspotVO sbTypeDTO) {
+        return new R<>(qykhPlanDetailsService.insertSingle(sbTypeDTO));
+    }
+    
+    /**
+     * 获取分页
+     *
+     * @param pageNum 当前页码
+     * @param pageSize 每页条数
+     * @return R
+     */
+    @GetMapping("/page")
+    public R query(HotspotVO dto, @RequestParam(defaultValue = "1") int pageNum, @RequestParam(defaultValue = "20") int pageSize) {
+        return new R(qykhPlanDetailsService.selectPage(pageNum,pageSize,dto));
+    }
+
+    /**
+     * 修改某条记录
+     * @param infoAdapterVO 电子保函表DTO
+     * @return R
+     */
+    @SysLog("修改")
+    @PutMapping("/{id}")
+    @PreAuthorize("@pms.hasPermission('qykh-edit')")
+    public R update(@PathVariable("id") String id, @Validated({UpdateGroup.class}) @RequestBody HotspotVO infoAdapterVO) {
+        qykhPlanDetailsService.modModel(infoAdapterVO);
+        return new R();
+    }
+
+
+}

platform-rest/src/main/java/com/platform/rest/controller/qykh/QykhHotspotHelpController.java

@@ -35,7 +35,7 @@ public class QykhHotspotHelpController {
      */
     @SysLog("新增")
     @PostMapping
-    @PreAuthorize("@pms.hasPermission('hotspot-helps-add')")
+    @PreAuthorize("@pms.hasPermission('qykh-add')")
     public R save(@Validated({AddGroup.class}) @RequestBody HotspotHelpVO sbTypeDTO) {
         return new R<>(qykhPlanDetailsService.insertSingle(sbTypeDTO));
     }
@@ -59,7 +59,7 @@ public class QykhHotspotHelpController {
      */
     @SysLog("修改")
     @PutMapping("/{id}")
-    @PreAuthorize("@pms.hasPermission('hotspot-helps-edit')")
+    @PreAuthorize("@pms.hasPermission('qykh-edit')")
     public R update(@PathVariable("id") String id, @Validated({UpdateGroup.class}) @RequestBody HotspotHelpVO infoAdapterVO) {
         qykhPlanDetailsService.modModel(infoAdapterVO);
         return new R();

platform-rest/src/main/java/com/platform/rest/controller/qykh/QykhInformationController.java

@@ -0,0 +1,69 @@
+package com.platform.rest.controller.qykh;
+
+import com.platform.common.util.R;
+import com.platform.common.validation.group.AddGroup;
+import com.platform.common.validation.group.UpdateGroup;
+import com.platform.dao.vo.query.qykh.InformationVO;
+import com.platform.rest.log.annotation.SysLog;
+import com.platform.service.qykh.QykhInformationService;
+import lombok.AllArgsConstructor;
+import org.springframework.security.access.prepost.PreAuthorize;
+import org.springframework.validation.annotation.Validated;
+import org.springframework.web.bind.annotation.*;
+
+@RestController
+@AllArgsConstructor
+@RequestMapping("/qykh/informations")
+public class QykhInformationController {
+    private final QykhInformationService qykhPlanDetailsService;
+    /**
+     * 通过id查询单条记录
+     *
+     * @param id 主键
+     * @return R
+     */
+    @GetMapping("/{id}")
+    public R getById(@PathVariable("id") Integer id) {
+        return new R(qykhPlanDetailsService.selectSingle(id));
+    }
+
+    /**
+     * 新增记录
+     *
+     * @param sbTypeDTO 设备类别DTO
+     * @return R
+     */
+    @SysLog("新增")
+    @PostMapping
+    @PreAuthorize("@pms.hasPermission('qykh-add')")
+    public R save(@Validated({AddGroup.class}) @RequestBody InformationVO sbTypeDTO) {
+        return new R<>(qykhPlanDetailsService.insertSingle(sbTypeDTO));
+    }
+    
+    /**
+     * 获取分页
+     *
+     * @param pageNum 当前页码
+     * @param pageSize 每页条数
+     * @return R
+     */
+    @GetMapping("/page")
+    public R query(InformationVO dto, @RequestParam(defaultValue = "1") int pageNum, @RequestParam(defaultValue = "20") int pageSize) {
+        return new R(qykhPlanDetailsService.selectPage(pageNum,pageSize,dto));
+    }
+
+    /**
+     * 修改某条记录
+     * @param infoAdapterVO 电子保函表DTO
+     * @return R
+     */
+    @SysLog("修改")
+    @PutMapping("/{id}")
+    @PreAuthorize("@pms.hasPermission('qykh-edit')")
+    public R update(@PathVariable("id") String id, @Validated({UpdateGroup.class}) @RequestBody InformationVO infoAdapterVO) {
+        qykhPlanDetailsService.modModel(infoAdapterVO);
+        return new R();
+    }
+
+
+}

platform-rest/src/main/java/com/platform/rest/controller/qykh/QykhInformationHelpController.java

@@ -0,0 +1,69 @@
+package com.platform.rest.controller.qykh;
+
+import com.platform.common.util.R;
+import com.platform.common.validation.group.AddGroup;
+import com.platform.common.validation.group.UpdateGroup;
+import com.platform.dao.vo.query.qykh.InformationHelpVO;
+import com.platform.rest.log.annotation.SysLog;
+import com.platform.service.qykh.QykhInformationHelpService;
+import lombok.AllArgsConstructor;
+import org.springframework.security.access.prepost.PreAuthorize;
+import org.springframework.validation.annotation.Validated;
+import org.springframework.web.bind.annotation.*;
+
+@RestController
+@AllArgsConstructor
+@RequestMapping("/qykh/information/helps")
+public class QykhInformationHelpController {
+    private final QykhInformationHelpService qykhPlanDetailsService;
+    /**
+     * 通过id查询单条记录
+     *
+     * @param id 主键
+     * @return R
+     */
+    @GetMapping("/{id}")
+    public R getById(@PathVariable("id") Integer id) {
+        return new R(qykhPlanDetailsService.selectSingle(id));
+    }
+
+    /**
+     * 新增记录
+     *
+     * @param sbTypeDTO 设备类别DTO
+     * @return R
+     */
+    @SysLog("新增")
+    @PostMapping
+    @PreAuthorize("@pms.hasPermission('qykh-add')")
+    public R save(@Validated({AddGroup.class}) @RequestBody InformationHelpVO sbTypeDTO) {
+        return new R<>(qykhPlanDetailsService.insertSingle(sbTypeDTO));
+    }
+    
+    /**
+     * 获取分页
+     *
+     * @param pageNum 当前页码
+     * @param pageSize 每页条数
+     * @return R
+     */
+    @GetMapping("/page")
+    public R query(InformationHelpVO dto, @RequestParam(defaultValue = "1") int pageNum, @RequestParam(defaultValue = "20") int pageSize) {
+        return new R(qykhPlanDetailsService.selectPage(pageNum,pageSize,dto));
+    }
+
+    /**
+     * 修改某条记录
+     * @param infoAdapterVO 电子保函表DTO
+     * @return R
+     */
+    @SysLog("修改")
+    @PutMapping("/{id}")
+    @PreAuthorize("@pms.hasPermission('qykh-edit')")
+    public R update(@PathVariable("id") String id, @Validated({UpdateGroup.class}) @RequestBody InformationHelpVO infoAdapterVO) {
+        qykhPlanDetailsService.modModel(infoAdapterVO);
+        return new R();
+    }
+
+
+}

platform-rest/src/main/java/com/platform/rest/controller/qykh/QykhPlanController.java

@@ -36,7 +36,7 @@ public class QykhPlanController {
      */
     @SysLog("新增")
     @PostMapping
-    @PreAuthorize("@pms.hasPermission('plans-add')")
+    @PreAuthorize("@pms.hasPermission('qykh-add')")
     public R save(@Validated({AddGroup.class}) @RequestBody PlanVO sbTypeDTO) {
         return new R<>(qykhPlanDetailsService.insertSingle(sbTypeDTO));
     }
@@ -60,7 +60,7 @@ public class QykhPlanController {
      */
     @SysLog("修改")
     @PutMapping("/{id}")
-    @PreAuthorize("@pms.hasPermission('plans-edit')")
+    @PreAuthorize("@pms.hasPermission('qykh-edit')")
     public R update(@PathVariable("id") String id, @Validated({UpdateGroup.class}) @RequestBody PlanVO infoAdapterVO) {
         qykhPlanDetailsService.modModel(infoAdapterVO);
         return new R();

platform-rest/src/main/java/com/platform/rest/controller/qykh/QykhPlanDetailsController.java

@@ -35,7 +35,7 @@ public class QykhPlanDetailsController {
      */
     @SysLog("新增")
     @PostMapping
-    @PreAuthorize("@pms.hasPermission('plan-details-add')")
+    @PreAuthorize("@pms.hasPermission('qykh-add')")
     public R save(@Validated({AddGroup.class}) @RequestBody PlandetailsVO sbTypeDTO) {
         return new R<>(qykhPlanDetailsService.insertSingle(sbTypeDTO));
     }
@@ -59,7 +59,7 @@ public class QykhPlanDetailsController {
      */
     @SysLog("修改")
     @PutMapping("/{id}")
-    @PreAuthorize("@pms.hasPermission('plan-details-edit')")
+    @PreAuthorize("@pms.hasPermission('qykh-edit')")
     public R update(@PathVariable("id") String id, @Validated({UpdateGroup.class}) @RequestBody PlandetailsVO infoAdapterVO) {
         qykhPlanDetailsService.modModel(infoAdapterVO);
         return new R();

platform-rest/src/main/java/com/platform/rest/controller/qykh/QykhProductController.java

@@ -14,7 +14,7 @@ import org.springframework.web.bind.annotation.*;
 
 @RestController
 @AllArgsConstructor
-@RequestMapping("/qykh/products")
+@RequestMapping("/qykh/qykh-")
 public class QykhProductController {
     private final QykhProductService qykhPlanDetailsService;
     /**
@@ -36,7 +36,7 @@ public class QykhProductController {
      */
     @SysLog("新增")
     @PostMapping
-    @PreAuthorize("@pms.hasPermission('products-add')")
+    @PreAuthorize("@pms.hasPermission('qykh-add')")
     public R save(@Validated({AddGroup.class}) @RequestBody ProductVO sbTypeDTO) {
         return new R<>(qykhPlanDetailsService.insertSingle(sbTypeDTO));
     }
@@ -60,7 +60,7 @@ public class QykhProductController {
      */
     @SysLog("修改")
     @PutMapping("/{id}")
-    @PreAuthorize("@pms.hasPermission('products-edit')")
+    @PreAuthorize("@pms.hasPermission('qykh-edit')")
     public R update(@PathVariable("id") String id, @Validated({UpdateGroup.class}) @RequestBody ProductVO infoAdapterVO) {
         qykhPlanDetailsService.modModel(infoAdapterVO);
         return new R();

platform-rest/src/main/java/com/platform/rest/controller/qykh/QykhProductHelpController.java

@@ -37,7 +37,7 @@ public class QykhProductHelpController {
      */
     @SysLog("新增")
     @PostMapping
-    @PreAuthorize("@pms.hasPermission('product-helps-add')")
+    @PreAuthorize("@pms.hasPermission('qykh-add')")
     public R save(@Validated({AddGroup.class}) @RequestBody ProductHelpVO sbTypeDTO) {
         return new R<>(qykhProductHelpService.insertSingle(sbTypeDTO));
     }
@@ -61,7 +61,7 @@ public class QykhProductHelpController {
      */
     @SysLog("修改")
     @PutMapping("/{id}")
-    @PreAuthorize("@pms.hasPermission('product-helps-edit')")
+    @PreAuthorize("@pms.hasPermission('qykh-edit')")
     public R update(@PathVariable("id") String id, @Validated({UpdateGroup.class}) @RequestBody ProductHelpVO infoAdapterVO) {
         qykhProductHelpService.modModel(infoAdapterVO);
         return new R();

platform-service/src/main/java/com/platform/service/qykh/QykhHotspotService.java

@@ -0,0 +1,41 @@
+package com.platform.service.qykh;
+
+import com.platform.dao.bean.MyVOPage;
+import com.platform.dao.vo.query.qykh.HotspotVO;
+
+public interface QykhHotspotService {
+
+    /**
+     * 单个数据插入
+     * @param vo
+     */
+    String insertSingle(HotspotVO vo);
+
+    /**
+     * 单个数据查询
+     *
+     * @param id
+     */
+    HotspotVO selectSingle(Integer id);
+
+    /**
+     * 更新
+     *
+     * @param vo
+     */
+    void modModel(HotspotVO vo);
+
+    /**
+     * 分页查询
+     * @param pageNum
+     * @param pageSize
+     * @param HotspotVO 查询对象
+     */
+    MyVOPage<HotspotVO> selectPage(int pageNum, int pageSize, HotspotVO HotspotVO );
+
+    /**
+     * 统一手动插入
+     * @param sql
+     */
+    void centerInsertBatch(String sql);
+}

platform-service/src/main/java/com/platform/service/qykh/QykhInformationHelpService.java

@@ -0,0 +1,41 @@
+package com.platform.service.qykh;
+
+import com.platform.dao.bean.MyVOPage;
+import com.platform.dao.vo.query.qykh.InformationHelpVO;
+
+public interface QykhInformationHelpService {
+
+    /**
+     * 单个数据插入
+     * @param vo
+     */
+    String insertSingle(InformationHelpVO vo);
+
+    /**
+     * 单个数据查询
+     *
+     * @param id
+     */
+    InformationHelpVO selectSingle(Integer id);
+
+    /**
+     * 更新
+     *
+     * @param vo
+     */
+    void modModel(InformationHelpVO vo);
+
+    /**
+     * 分页查询
+     * @param pageNum
+     * @param pageSize
+     * @param HotspotVO 查询对象
+     */
+    MyVOPage<InformationHelpVO> selectPage(int pageNum, int pageSize, InformationHelpVO HotspotVO );
+
+    /**
+     * 统一手动插入
+     * @param sql
+     */
+    void centerInsertBatch(String sql);
+}

platform-service/src/main/java/com/platform/service/qykh/QykhInformationService.java

@@ -0,0 +1,41 @@
+package com.platform.service.qykh;
+
+import com.platform.dao.bean.MyVOPage;
+import com.platform.dao.vo.query.qykh.InformationVO;
+
+public interface QykhInformationService {
+
+    /**
+     * 单个数据插入
+     * @param vo
+     */
+    String insertSingle(InformationVO vo);
+
+    /**
+     * 单个数据查询
+     *
+     * @param id
+     */
+    InformationVO selectSingle(Integer id);
+
+    /**
+     * 更新
+     *
+     * @param vo
+     */
+    void modModel(InformationVO vo);
+
+    /**
+     * 分页查询
+     * @param pageNum
+     * @param pageSize
+     * @param InformationVO 查询对象
+     */
+    MyVOPage<InformationVO> selectPage(int pageNum, int pageSize, InformationVO InformationVO );
+
+    /**
+     * 统一手动插入
+     * @param sql
+     */
+    void centerInsertBatch(String sql);
+}

platform-service/src/main/java/com/platform/service/qykh/impl/QykhHotspotServiceImpl.java

@@ -0,0 +1,311 @@
+package com.platform.service.qykh.impl;
+
+import com.github.pagehelper.Page;
+import com.platform.common.exception.BusinessException;
+import com.platform.common.exception.DeniedException;
+import com.platform.common.util.StringUtils;
+import com.platform.dao.bean.MyVOPage;
+import com.platform.dao.vo.query.qykh.HotspotVO;
+import com.platform.service.qykh.QykhHotspotService;
+import com.platform.service.qykh.QykhProductService;
+import lombok.extern.slf4j.Slf4j;
+import org.springframework.beans.factory.annotation.Value;
+import org.springframework.stereotype.Service;
+import org.springframework.transaction.annotation.Transactional;
+
+import javax.annotation.Resource;
+import javax.sql.DataSource;
+import java.sql.Connection;
+import java.sql.ResultSet;
+import java.sql.SQLException;
+import java.sql.Statement;
+import java.util.ArrayList;
+import java.util.List;
+
+@Service("qykhHotspotService")
+@Slf4j
+public class QykhHotspotServiceImpl implements QykhHotspotService {
+    @Resource
+    private DataSource qykhDataSource;
+
+    @Value("${qykh.hotspot}")
+    private String info_table_name;
+
+    @Override
+    public MyVOPage<HotspotVO> selectPage(int pageNum, int pageSize, HotspotVO guaranteeInfoDTO) {
+        MyVOPage<HotspotVO> myVOPage = new MyVOPage<>();
+        myVOPage.setPageNum(pageNum);
+        myVOPage.setPageSize(pageSize);
+        Connection conn = null;
+        Statement stmt = null;
+        ResultSet rs = null;
+        StringBuffer querySql = new StringBuffer("select " +
+                "id," +
+                "level," +
+                "hid," +
+                "pid," +
+                "hname," +
+                "desrc," +
+                "shortdesc," +
+                "hurl," +
+                "ord, " +
+                "oname," +
+                "seoid," +
+                "iszt," +
+                "zturl");
+        StringBuffer countSql = new StringBuffer("select count(*) ");
+        StringBuffer sql = new StringBuffer(" from " + info_table_name + " where 1 = 1 ");
+        if (StringUtils.isNotBlank(guaranteeInfoDTO.getHname())) {
+            sql.append("and hname like '%" + guaranteeInfoDTO.getHname() + "%' ");
+        }
+        sql.append(" order by ord ");
+        try {
+            conn = qykhDataSource.getConnection();
+            stmt = conn.createStatement();
+            // 获取总条数
+            rs = stmt.executeQuery(countSql.append(sql).toString());
+            rs.next();
+            long total = rs.getLong(1);
+            Page page = new Page(pageNum, pageSize);
+            page.setTotal(total);
+            myVOPage.setPages(page.getPages());
+            myVOPage.setTotal(total);
+            if (total < 1) {
+                myVOPage.setRows(new ArrayList<HotspotVO>());
+                return myVOPage;
+            }
+            int startNum = (pageNum - 1) * pageSize;
+            sql.append("limit " + startNum + "," + pageSize);
+            rs = stmt.executeQuery(querySql.append(sql).toString());
+            // 封装数据
+            myVOPage.setRows(packageInfo(rs));
+            rs.close();
+            stmt.close();
+            conn.close();
+            return myVOPage;
+        } catch (SQLException e1) {
+            e1.printStackTrace();
+            throw new DeniedException("获取乾元数据库连接失败" + e1.getCause().getMessage());
+        } finally {
+            try {
+                if (rs != null) {
+                    rs.close();
+                }
+                if (stmt != null) {
+                    stmt.close();
+                }
+                if (conn != null) {
+                    conn.close();
+                }
+            } catch (Exception e) {
+
+            }
+        }
+    }
+
+    @Override
+    public void modModel(HotspotVO vo) {
+        Connection conn = null;
+        Statement stmt = null;
+        if(StringUtils.isBlank(vo.getHname()) || StringUtils.isBlank(vo.getDesrc())){
+            return;
+        }
+        StringBuffer updateSql = new StringBuffer("update " + info_table_name + " set " +
+                "pname='" + vo.getHname() +
+                "',desrc='" + vo.getDesrc() +
+         /*       "',shortdesc='" + vo.getShortdesc() +
+                "',planid='" + vo.getPlanid() +
+                "',orderid='" + vo.getOrderid() +
+                "',digest='" + vo.getDigest() +
+                "',keywords='" + vo.getKeywords() +
+                "',seoid='" + vo.getSeoid() +
+                "',time='" + vo.getTime() +*/
+                "' where id=" + vo.getId() + "");
+        log.info("更新数据：" + updateSql);
+        try {
+            conn = qykhDataSource.getConnection();
+            stmt = conn.createStatement();
+            // 获取总条数
+            int result = stmt.executeUpdate(updateSql.toString());
+            if (result != 1) {
+                throw new BusinessException("");
+            }
+            stmt.close();
+            conn.close();
+        } catch (SQLException e1) {
+            e1.printStackTrace();
+            throw new DeniedException("获取乾元数据库连接失败" + e1.getCause().getMessage());
+        } finally {
+            try {
+                if (stmt != null) {
+                    stmt.close();
+                }
+                if (conn != null) {
+                    conn.close();
+                }
+            } catch (Exception e) {
+
+            }
+        }
+    }
+
+    private List<HotspotVO> packageInfo(ResultSet rs) throws SQLException {
+        List<HotspotVO> list = new ArrayList<>();
+        while (rs.next()) {
+            HotspotVO vo = new HotspotVO();
+            vo.setId(rs.getInt(1));
+            vo.setLevel(rs.getInt(2));
+            vo.setHid(rs.getInt(3));
+            vo.setPid(rs.getInt(4));
+            vo.setHname(rs.getString(5));
+            vo.setDesrc(rs.getString(6));
+            vo.setShortdesc(rs.getString(7));
+            vo.setHurl(rs.getString(8));
+            vo.setOrd(rs.getInt(9));
+            vo.setOname(rs.getString(10));
+            vo.setSeoid(rs.getInt(11));
+            vo.setIszt(rs.getInt(12));
+            vo.setZturl(rs.getString(13));
+            list.add(vo);
+        }
+        return list;
+    }
+
+    @Override
+    @Transactional(rollbackFor = Exception.class)
+    public String insertSingle(HotspotVO vo) {
+        try {
+            if (vo != null) {
+                StringBuffer sql = new StringBuffer();
+                sql.append("insert into " + info_table_name +
+                        " (level,hid,pid,hname,desrc,shortdesc,hurl,ord,oname,seoid,iszt,zturl) values ");
+                sql.append("('");
+                sql.append("'" + vo.getLevel() + "',");
+                sql.append("'" + vo.getHid() + "',");
+                sql.append("'" + vo.getPid() + "',");
+                sql.append("'" + vo.getHname() + "',");
+                sql.append("'" + vo.getDesrc() + "',");
+                sql.append("'" + vo.getShortdesc() + "',");
+                sql.append("'" + vo.getHurl() + "',");
+                sql.append("'" + vo.getOrd() + "',");
+                sql.append("'" + vo.getOname() + "',");
+                sql.append("'" + vo.getSeoid() + "',");
+                sql.append("'" + vo.getIszt() + "',");
+                sql.append("'" + vo.getZturl() + "'");
+                sql.append(")");
+                log.info("----------" + sql.toString());
+                centerInsertBatch(sql.toString());
+            }
+        } catch (Exception e) {
+            e.printStackTrace();
+            //throw new DeniedException("单个宿州交易中心失败，请联系技术处理");
+        }
+        return "推送成功";
+    }
+
+    @Override
+    @Transactional(rollbackFor = Exception.class)
+    public void centerInsertBatch(String sql) {
+        Connection conn = null;
+        Statement stmt = null;
+        try {
+            conn = qykhDataSource.getConnection();
+            stmt = conn.createStatement();
+            stmt.executeUpdate(sql);
+        } catch (Exception e) {
+            e.printStackTrace();
+        } finally {
+            try {
+                stmt.close();
+                conn.close();
+            } catch (Exception e1) {
+                e1.printStackTrace();
+            }
+        }
+    }
+
+    @Override
+    public HotspotVO selectSingle(Integer id) {
+        try {
+            HotspotVO vo = new HotspotVO();
+            StringBuffer sql = new StringBuffer();
+            sql.append("select " +
+                    "id," +
+                    "level," +
+                    "hid," +
+                    "pid," +
+                    "hname," +
+                    "desrc," +
+                    "shortdesc," +
+                    "hurl," +
+                    "ord, " +
+                    "oname," +
+                    "seoid," +
+                    "iszt," +
+                    "zturl" +
+                    "from "
+                    + info_table_name + " where id = " + id + "");
+            ResultSet rs = null;
+            Connection conn = null;
+            Statement stmt = null;
+            try {
+                conn = qykhDataSource.getConnection();
+                stmt = conn.createStatement();
+                rs = stmt.executeQuery(sql.toString());
+                rs.next();
+                vo.setId(rs.getInt(1));
+                vo.setLevel(rs.getInt(2));
+                vo.setHid(rs.getInt(3));
+                vo.setPid(rs.getInt(4));
+                vo.setHname(rs.getString(5));
+                vo.setDesrc(rs.getString(6));
+                vo.setShortdesc(rs.getString(7));
+                vo.setHurl(rs.getString(8));
+                vo.setOrd(rs.getInt(9));
+                vo.setOname(rs.getString(10));
+                vo.setSeoid(rs.getInt(11));
+                vo.setIszt(rs.getInt(12));
+                vo.setZturl(rs.getString(13));
+                return vo;
+            } catch (Exception e) {
+                log.info(e.getCause().getMessage());
+                e.printStackTrace();
+                //throw new DeniedException("交易中心插入报错"+e.getCause().getMessage());
+            } finally {
+                try {
+                    rs.close();
+                    stmt.close();
+                    conn.close();
+                } catch (Exception e1) {
+                    e1.printStackTrace();
+                }
+            }
+        } catch (Exception e) {
+            e.printStackTrace();
+        }
+        return null;
+    }
+
+    @Transactional(rollbackFor = Exception.class)
+    public ResultSet queryQykh(String sql) {
+        Connection conn = null;
+        Statement stmt = null;
+        try {
+            conn = qykhDataSource.getConnection();
+            stmt = conn.createStatement();
+            return stmt.executeQuery(sql);
+        } catch (Exception e) {
+            log.info(e.getCause().getMessage());
+            e.printStackTrace();
+            //throw new DeniedException("交易中心插入报错"+e.getCause().getMessage());
+        } finally {
+            try {
+                stmt.close();
+                conn.close();
+            } catch (Exception e1) {
+                e1.printStackTrace();
+            }
+        }
+        return null;
+    }
+}

platform-service/src/main/java/com/platform/service/qykh/impl/QykhInformationHelpServiceImpl.java

@@ -0,0 +1,298 @@
+package com.platform.service.qykh.impl;
+
+import com.github.pagehelper.Page;
+import com.platform.common.exception.BusinessException;
+import com.platform.common.exception.DeniedException;
+import com.platform.common.util.DateUtils;
+import com.platform.common.util.StringUtils;
+import com.platform.dao.bean.MyVOPage;
+import com.platform.dao.vo.query.qykh.InformationHelpVO;
+import com.platform.dao.vo.query.qykh.InformationHelpVO;
+import com.platform.service.qykh.QykhHotspotHelpService;
+import com.platform.service.qykh.QykhInformationHelpService;
+import lombok.extern.slf4j.Slf4j;
+import org.springframework.beans.factory.annotation.Value;
+import org.springframework.stereotype.Service;
+import org.springframework.transaction.annotation.Transactional;
+
+import javax.annotation.Resource;
+import javax.sql.DataSource;
+import java.sql.Connection;
+import java.sql.ResultSet;
+import java.sql.SQLException;
+import java.sql.Statement;
+import java.time.LocalDateTime;
+import java.util.ArrayList;
+import java.util.List;
+
+@Service("qykhInformationHelpService")
+@Slf4j
+public class QykhInformationHelpServiceImpl implements QykhInformationHelpService {
+    @Resource
+    private DataSource qykhDataSource;
+
+    @Value("${qykh.information_help}")
+    private String info_table_name;
+
+    @Override
+    public MyVOPage<InformationHelpVO> selectPage(int pageNum, int pageSize, InformationHelpVO guaranteeInfoDTO) {
+        MyVOPage<InformationHelpVO> myVOPage = new MyVOPage<>();
+        myVOPage.setPageNum(pageNum);
+        myVOPage.setPageSize(pageSize);
+        Connection conn = null;
+        Statement stmt = null;
+        ResultSet rs = null;
+        StringBuffer querySql = new StringBuffer("select " +
+                "id," +
+                "title," +
+                "descr," +
+                "shortdesc," +
+                "pid," +
+                "keywords," +
+                "ord," +
+                "digest," +
+                "time ");
+        StringBuffer countSql = new StringBuffer("select count(*) ");
+        StringBuffer sql = new StringBuffer(" from " + info_table_name + " where 1 = 1 ");
+        if (StringUtils.isNotBlank(guaranteeInfoDTO.getTitle())) {
+            sql.append("and title like '%" + guaranteeInfoDTO.getTitle() + "%' ");
+        }
+        sql.append(" order by time desc ");
+        try {
+            conn = qykhDataSource.getConnection();
+            stmt = conn.createStatement();
+            // 获取总条数
+            rs = stmt.executeQuery(countSql.append(sql).toString());
+            rs.next();
+            long total = rs.getLong(1);
+            Page page = new Page(pageNum, pageSize);
+            page.setTotal(total);
+            myVOPage.setPages(page.getPages());
+            myVOPage.setTotal(total);
+            if (total < 1) {
+                myVOPage.setRows(new ArrayList<InformationHelpVO>());
+                return myVOPage;
+            }
+            int startNum = (pageNum - 1) * pageSize;
+            sql.append("limit " + startNum + "," + pageSize);
+            rs = stmt.executeQuery(querySql.append(sql).toString());
+            // 封装数据
+            myVOPage.setRows(packageInfo(rs));
+            rs.close();
+            stmt.close();
+            conn.close();
+            return myVOPage;
+        } catch (SQLException e1) {
+            e1.printStackTrace();
+            throw new DeniedException("获取乾元数据库连接失败" + e1.getCause().getMessage());
+        } finally {
+            try {
+                if (rs != null) {
+                    rs.close();
+                }
+                if (stmt != null) {
+                    stmt.close();
+                }
+                if (conn != null) {
+                    conn.close();
+                }
+            } catch (Exception e) {
+
+            }
+        }
+    }
+
+    @Override
+    public void modModel(InformationHelpVO vo) {
+        Connection conn = null;
+        Statement stmt = null;
+        if(StringUtils.isBlank(vo.getTitle()) || StringUtils.isBlank(vo.getDescr())){
+            return;
+        }
+        StringBuffer updateSql = new StringBuffer("update " + info_table_name + " set " +
+                "title='" + vo.getTitle() +
+                "',descr='" + vo.getDescr() +
+         /*       "',shortdesc='" + vo.getShortdesc() +
+                "',planid='" + vo.getPlanid() +
+                "',orderid='" + vo.getOrderid() +
+                "',digest='" + vo.getDigest() +
+                "',keywords='" + vo.getKeywords() +
+                "',seoid='" + vo.getSeoid() +
+                "',time='" + vo.getTime() +*/
+                "' where id=" + vo.getId() + "");
+        log.info("更新数据：" + updateSql);
+        try {
+            conn = qykhDataSource.getConnection();
+            stmt = conn.createStatement();
+            // 获取总条数
+            int result = stmt.executeUpdate(updateSql.toString());
+            if (result != 1) {
+                throw new BusinessException("");
+            }
+            stmt.close();
+            conn.close();
+        } catch (SQLException e1) {
+            e1.printStackTrace();
+            throw new DeniedException("获取乾元数据库连接失败" + e1.getCause().getMessage());
+        } finally {
+            try {
+                if (stmt != null) {
+                    stmt.close();
+                }
+                if (conn != null) {
+                    conn.close();
+                }
+            } catch (Exception e) {
+
+            }
+        }
+    }
+
+    private List<InformationHelpVO> packageInfo(ResultSet rs) throws SQLException {
+        List<InformationHelpVO> list = new ArrayList<>();
+        while (rs.next()) {
+            InformationHelpVO vo = new InformationHelpVO();
+            vo.setId(rs.getInt(1));
+            vo.setTitle(rs.getString(2));
+            vo.setDescr(rs.getString(3));
+            vo.setShortdesc(rs.getString(4));
+            vo.setPid(rs.getInt(5));
+            vo.setKeywords(rs.getString(6));
+            vo.setOrd(rs.getInt(7));
+            vo.setDigest(rs.getString(8));
+            vo.setTime(rs.getString(9));
+            list.add(vo);
+        }
+        return list;
+    }
+
+    @Override
+    @Transactional(rollbackFor = Exception.class)
+    public String insertSingle(InformationHelpVO vo) {
+        try {
+            if (vo != null) {
+                if (vo.getTime() == null) {
+                    vo.setTime(DateUtils.dateToString(LocalDateTime.now(), DateUtils.PATTERN_YMD_HMS));
+                }
+                StringBuffer sql = new StringBuffer();
+                sql.append("insert into " + info_table_name +
+                        " (title,descr,shortdesc,pid,keywords,ord,digest,time) values ");
+                sql.append("('");
+                sql.append("'" + vo.getTitle() + "',");
+                sql.append("'" + vo.getDescr() + "',");
+                sql.append("'" + vo.getShortdesc() + "',");
+                sql.append("'" + vo.getShortdesc() + "',");
+                sql.append("'" + vo.getPid() + "',");
+                sql.append("'" + vo.getKeywords() + "',");
+                sql.append("'" + vo.getOrd() + "',");
+                sql.append("'" + vo.getDigest() + "',");
+                sql.append("'" + vo.getTime() + "',");
+                sql.append(")");
+                log.info("----------" + sql.toString());
+                centerInsertBatch(sql.toString());
+            }
+        } catch (Exception e) {
+            e.printStackTrace();
+            //throw new DeniedException("单个宿州交易中心失败，请联系技术处理");
+        }
+        return "推送成功";
+    }
+
+    @Override
+    @Transactional(rollbackFor = Exception.class)
+    public void centerInsertBatch(String sql) {
+        Connection conn = null;
+        Statement stmt = null;
+        try {
+            conn = qykhDataSource.getConnection();
+            stmt = conn.createStatement();
+            stmt.executeUpdate(sql);
+        } catch (Exception e) {
+            e.printStackTrace();
+        } finally {
+            try {
+                stmt.close();
+                conn.close();
+            } catch (Exception e1) {
+                e1.printStackTrace();
+            }
+        }
+    }
+
+    @Override
+    public InformationHelpVO selectSingle(Integer id) {
+        try {
+            InformationHelpVO vo = new InformationHelpVO();
+            StringBuffer sql = new StringBuffer();
+            sql.append("select " +
+                    "id," +
+                    "title," +
+                    "descr," +
+                    "shortdesc," +
+                    "hid," +
+                    "keywords," +
+                    "ord," +
+                    "digest," +
+                    "time " +
+                    "from "
+                    + info_table_name + " where id = " + id + "");
+            ResultSet rs = null;
+            Connection conn = null;
+            Statement stmt = null;
+            try {
+                conn = qykhDataSource.getConnection();
+                stmt = conn.createStatement();
+                rs = stmt.executeQuery(sql.toString());
+                rs.next();
+                vo.setId(rs.getInt(1));
+                vo.setTitle(rs.getString(2));
+                vo.setDescr(rs.getString(3));
+                vo.setShortdesc(rs.getString(4));
+                vo.setPid(rs.getInt(5));
+                vo.setKeywords(rs.getString(6));
+                vo.setOrd(rs.getInt(7));
+                vo.setDigest(rs.getString(8));
+                vo.setTime(rs.getString(9));
+                return vo;
+            } catch (Exception e) {
+                log.info(e.getCause().getMessage());
+                e.printStackTrace();
+                //throw new DeniedException("交易中心插入报错"+e.getCause().getMessage());
+            } finally {
+                try {
+                    rs.close();
+                    stmt.close();
+                    conn.close();
+                } catch (Exception e1) {
+                    e1.printStackTrace();
+                }
+            }
+        } catch (Exception e) {
+            e.printStackTrace();
+        }
+        return null;
+    }
+
+    @Transactional(rollbackFor = Exception.class)
+    public ResultSet queryQykh(String sql) {
+        Connection conn = null;
+        Statement stmt = null;
+        try {
+            conn = qykhDataSource.getConnection();
+            stmt = conn.createStatement();
+            return stmt.executeQuery(sql);
+        } catch (Exception e) {
+            log.info(e.getCause().getMessage());
+            e.printStackTrace();
+            //throw new DeniedException("交易中心插入报错"+e.getCause().getMessage());
+        } finally {
+            try {
+                stmt.close();
+                conn.close();
+            } catch (Exception e1) {
+                e1.printStackTrace();
+            }
+        }
+        return null;
+    }
+}

platform-service/src/main/java/com/platform/service/qykh/impl/QykhInformationServiceImpl.java

@@ -0,0 +1,296 @@
+package com.platform.service.qykh.impl;
+
+import com.github.pagehelper.Page;
+import com.platform.common.exception.BusinessException;
+import com.platform.common.exception.DeniedException;
+import com.platform.common.util.StringUtils;
+import com.platform.dao.bean.MyVOPage;
+import com.platform.dao.vo.query.qykh.InformationVO;
+import com.platform.service.qykh.QykhInformationService;
+import com.platform.service.qykh.QykhPlanService;
+import lombok.extern.slf4j.Slf4j;
+import org.springframework.beans.factory.annotation.Value;
+import org.springframework.stereotype.Service;
+import org.springframework.transaction.annotation.Transactional;
+
+import javax.annotation.Resource;
+import javax.sql.DataSource;
+import java.sql.Connection;
+import java.sql.ResultSet;
+import java.sql.SQLException;
+import java.sql.Statement;
+import java.util.ArrayList;
+import java.util.List;
+
+@Service("qykhInformationService")
+@Slf4j
+public class QykhInformationServiceImpl implements QykhInformationService {
+    @Resource
+    private DataSource qykhDataSource;
+
+    @Value("${qykh.information}")
+    private String info_table_name;
+
+    @Override
+    public MyVOPage<InformationVO> selectPage(int pageNum, int pageSize, InformationVO guaranteeInfoDTO) {
+        MyVOPage<InformationVO> myVOPage = new MyVOPage<>();
+        myVOPage.setPageNum(pageNum);
+        myVOPage.setPageSize(pageSize);
+        Connection conn = null;
+        Statement stmt = null;
+        ResultSet rs = null;
+        StringBuffer querySql = new StringBuffer("select " +
+                "id," +
+                "inforname," +
+                "infordes," +
+                "pid," +
+                "level," +
+                "purl," +
+                "seoid, " +
+                "ord,  " +
+                "addtime," +
+                "updatetime");
+        StringBuffer countSql = new StringBuffer("select count(*) ");
+        StringBuffer sql = new StringBuffer(" from " + info_table_name + " where 1 = 1 ");
+        if (StringUtils.isNotBlank(guaranteeInfoDTO.getInforname())) {
+            sql.append("and inforname like '%" + guaranteeInfoDTO.getInforname() + "%' ");
+        }
+        sql.append(" order by ord ");
+        try {
+            conn = qykhDataSource.getConnection();
+            stmt = conn.createStatement();
+            // 获取总条数
+            rs = stmt.executeQuery(countSql.append(sql).toString());
+            rs.next();
+            long total = rs.getLong(1);
+            Page page = new Page(pageNum, pageSize);
+            page.setTotal(total);
+            myVOPage.setPages(page.getPages());
+            myVOPage.setTotal(total);
+            if (total < 1) {
+                myVOPage.setRows(new ArrayList<InformationVO>());
+                return myVOPage;
+            }
+            int startNum = (pageNum - 1) * pageSize;
+            sql.append("limit " + startNum + "," + pageSize);
+            rs = stmt.executeQuery(querySql.append(sql).toString());
+            // 封装数据
+            myVOPage.setRows(packageInfo(rs));
+            rs.close();
+            stmt.close();
+            conn.close();
+            return myVOPage;
+        } catch (SQLException e1) {
+            e1.printStackTrace();
+            throw new DeniedException("获取乾元数据库连接失败" + e1.getCause().getMessage());
+        } finally {
+            try {
+                if (rs != null) {
+                    rs.close();
+                }
+                if (stmt != null) {
+                    stmt.close();
+                }
+                if (conn != null) {
+                    conn.close();
+                }
+            } catch (Exception e) {
+
+            }
+        }
+    }
+
+    @Override
+    public void modModel(InformationVO vo) {
+        Connection conn = null;
+        Statement stmt = null;
+        if (StringUtils.isBlank(vo.getInforname()) || StringUtils.isBlank(vo.getInfordes())) {
+            return;
+        }
+        StringBuffer updateSql = new StringBuffer("update " + info_table_name + " set " +
+                "inforname='" + vo.getInfordes() +
+                "',infordes='" + vo.getInfordes() +
+         /*       "',shortdesc='" + vo.getShortdesc() +
+                "',planid='" + vo.getPlanid() +
+                "',orderid='" + vo.getOrderid() +
+                "',digest='" + vo.getDigest() +
+                "',keywords='" + vo.getKeywords() +
+                "',seoid='" + vo.getSeoid() +
+                "',time='" + vo.getTime() +*/
+                "' where id=" + vo.getId() + "");
+        log.info("更新数据：" + updateSql);
+        try {
+            conn = qykhDataSource.getConnection();
+            stmt = conn.createStatement();
+            // 获取总条数
+            int result = stmt.executeUpdate(updateSql.toString());
+            if (result != 1) {
+                throw new BusinessException("");
+            }
+            stmt.close();
+            conn.close();
+        } catch (SQLException e1) {
+            e1.printStackTrace();
+            throw new DeniedException("获取乾元数据库连接失败" + e1.getCause().getMessage());
+        } finally {
+            try {
+                if (stmt != null) {
+                    stmt.close();
+                }
+                if (conn != null) {
+                    conn.close();
+                }
+            } catch (Exception e) {
+
+            }
+        }
+    }
+
+    private List<InformationVO> packageInfo(ResultSet rs) throws SQLException {
+        List<InformationVO> list = new ArrayList<>();
+        while (rs.next()) {
+            InformationVO vo = new InformationVO();
+            vo.setId(rs.getInt(1));
+            vo.setInforname(rs.getString(2));
+            vo.setInfordes(rs.getString(3));
+            vo.setPid(rs.getInt(4));
+            vo.setLevel(rs.getInt(5));
+            vo.setPurl(rs.getString(6));
+            vo.setSeoid(rs.getInt(7));
+            vo.setOrd(rs.getInt(8));
+            vo.setAddtime(rs.getString(9));
+            vo.setUpdatetime(rs.getString(10));
+            list.add(vo);
+        }
+        return list;
+    }
+
+    @Override
+    @Transactional(rollbackFor = Exception.class)
+    public String insertSingle(InformationVO vo) {
+        try {
+            if (vo != null) {
+                StringBuffer sql = new StringBuffer();
+                sql.append("insert into " + info_table_name +
+                        " (inforname,infordes,pid,level,purl,seoid,ord,addtime,updatetime) values ");
+                sql.append("('");
+                sql.append("'" + vo.getInforname() + "',");
+                sql.append("'" + vo.getInfordes() + "',");
+                sql.append("'" + vo.getPid() + "',");
+                sql.append("'" + vo.getLevel() + "',");
+                sql.append("'" + vo.getPurl() + "',");
+                sql.append("'" + vo.getSeoid() + "',");
+                sql.append("'" + vo.getOrd() + "',");
+                sql.append("'" + vo.getAddtime() + "',");
+                sql.append("'" + vo.getUpdatetime() + "'");
+                sql.append(")");
+                log.info("----------" + sql.toString());
+                centerInsertBatch(sql.toString());
+            }
+        } catch (Exception e) {
+            e.printStackTrace();
+            //throw new DeniedException("单个宿州交易中心失败，请联系技术处理");
+        }
+        return "推送成功";
+    }
+
+    @Override
+    @Transactional(rollbackFor = Exception.class)
+    public void centerInsertBatch(String sql) {
+        Connection conn = null;
+        Statement stmt = null;
+        try {
+            conn = qykhDataSource.getConnection();
+            stmt = conn.createStatement();
+            stmt.executeUpdate(sql);
+        } catch (Exception e) {
+            e.printStackTrace();
+        } finally {
+            try {
+                stmt.close();
+                conn.close();
+            } catch (Exception e1) {
+                e1.printStackTrace();
+            }
+        }
+    }
+
+    @Override
+    public InformationVO selectSingle(Integer id) {
+        try {
+            InformationVO vo = new InformationVO();
+            StringBuffer sql = new StringBuffer();
+            sql.append("select " +
+                            "id," +
+                            "inforname," +
+                            "infordes," +
+                            "pid," +
+                            "level," +
+                            "purl," +
+                            "seoid," +
+                            "ord, " +
+                            "addtime," +
+                            "updatetime " +
+                    "from "
+                    + info_table_name + " where id = " + id + "");
+            ResultSet rs = null;
+            Connection conn = null;
+            Statement stmt = null;
+            try {
+                conn = qykhDataSource.getConnection();
+                stmt = conn.createStatement();
+                rs = stmt.executeQuery(sql.toString());
+                rs.next();
+                vo.setId(rs.getInt(1));
+                vo.setInforname(rs.getString(2));
+                vo.setInfordes(rs.getString(3));
+                vo.setPid(rs.getInt(4));
+                vo.setLevel(rs.getInt(5));
+                vo.setPurl(rs.getString(6));
+                vo.setSeoid(rs.getInt(7));
+                vo.setOrd(rs.getInt(8));
+                vo.setAddtime(rs.getString(9));
+                vo.setUpdatetime(rs.getString(10));
+                return vo;
+            } catch (Exception e) {
+                log.info(e.getCause().getMessage());
+                e.printStackTrace();
+                //throw new DeniedException("交易中心插入报错"+e.getCause().getMessage());
+            } finally {
+                try {
+                    rs.close();
+                    stmt.close();
+                    conn.close();
+                } catch (Exception e1) {
+                    e1.printStackTrace();
+                }
+            }
+        } catch (Exception e) {
+            e.printStackTrace();
+        }
+        return null;
+    }
+
+    @Transactional(rollbackFor = Exception.class)
+    public ResultSet queryQykh(String sql) {
+        Connection conn = null;
+        Statement stmt = null;
+        try {
+            conn = qykhDataSource.getConnection();
+            stmt = conn.createStatement();
+            return stmt.executeQuery(sql);
+        } catch (Exception e) {
+            log.info(e.getCause().getMessage());
+            e.printStackTrace();
+            //throw new DeniedException("交易中心插入报错"+e.getCause().getMessage());
+        } finally {
+            try {
+                stmt.close();
+                conn.close();
+            } catch (Exception e1) {
+                e1.printStackTrace();
+            }
+        }
+        return null;
+    }
+}