diff --git a/epmet-module/open-data-worker/open-data-worker-server/src/main/java/com/epmet/opendata/controller/CaPingfangController.java b/epmet-module/open-data-worker/open-data-worker-server/src/main/java/com/epmet/opendata/controller/CaPingfangController.java
index 5c5f592d43..99adb55e93 100644
--- a/epmet-module/open-data-worker/open-data-worker-server/src/main/java/com/epmet/opendata/controller/CaPingfangController.java
+++ b/epmet-module/open-data-worker/open-data-worker-server/src/main/java/com/epmet/opendata/controller/CaPingfangController.java
@@ -13,6 +13,7 @@ import com.epmet.commons.tools.validator.group.DefaultGroup;
 import com.epmet.commons.tools.validator.group.UpdateGroup;
 import com.epmet.opendata.dto.CaPingfangDTO;
 import com.epmet.opendata.dto.form.CaPingfangFormDTO;
+import com.epmet.opendata.dto.form.PreserVationFormDTO;
 import com.epmet.opendata.excel.CaPingfangExcel;
 import com.epmet.opendata.service.CaPingfangService;
 import org.springframework.beans.factory.annotation.Autowired;
@@ -93,5 +94,19 @@ public class CaPingfangController {
         return new Result<PageData>().ok(data);
     }
 
+    /**
+     * 平房调用ruoyi接口存储数据
+     *
+     * @param dto
+     * @return com.epmet.commons.tools.utils.Result
+     * @author LZN
+     * @date 2022/6/2 10:20
+     */
+    @PostMapping("/preserPingFangVation")
+    public Result getPreserPingFangVation(@RequestBody PreserVationFormDTO dto) {
+        caPingfangService.preserPingFangVation(dto);
+        return new Result();
+    }
+
 
 }
diff --git a/epmet-module/open-data-worker/open-data-worker-server/src/main/java/com/epmet/opendata/dao/CaPingfangDao.java b/epmet-module/open-data-worker/open-data-worker-server/src/main/java/com/epmet/opendata/dao/CaPingfangDao.java
index a07282a7b9..14ec80b58a 100644
--- a/epmet-module/open-data-worker/open-data-worker-server/src/main/java/com/epmet/opendata/dao/CaPingfangDao.java
+++ b/epmet-module/open-data-worker/open-data-worker-server/src/main/java/com/epmet/opendata/dao/CaPingfangDao.java
@@ -22,4 +22,6 @@ public interface CaPingfangDao extends BaseDao<CaPingfangEntity> {
      * @return
      */
     List<CaPingfangResultDTO> getPage(@Param("buildingName") String buildingName);
+
+    void deleteAll();
 }
\ No newline at end of file
diff --git a/epmet-module/open-data-worker/open-data-worker-server/src/main/java/com/epmet/opendata/service/CaPingfangService.java b/epmet-module/open-data-worker/open-data-worker-server/src/main/java/com/epmet/opendata/service/CaPingfangService.java
index 7bd16e9185..2fbc007254 100644
--- a/epmet-module/open-data-worker/open-data-worker-server/src/main/java/com/epmet/opendata/service/CaPingfangService.java
+++ b/epmet-module/open-data-worker/open-data-worker-server/src/main/java/com/epmet/opendata/service/CaPingfangService.java
@@ -5,6 +5,7 @@ import com.epmet.commons.mybatis.service.BaseService;
 import com.epmet.commons.tools.page.PageData;
 import com.epmet.opendata.dto.CaPingfangDTO;
 import com.epmet.opendata.dto.form.CaPingfangFormDTO;
+import com.epmet.opendata.dto.form.PreserVationFormDTO;
 import com.epmet.opendata.entity.CaPingfangEntity;
 
 
@@ -84,4 +85,11 @@ public interface CaPingfangService extends BaseService<CaPingfangEntity> {
      * @return
      */
     PageData getPage(CaPingfangFormDTO dto);
+
+    /**
+     * 平房调用ruoyi接口存储数据
+     *
+     * @param dto
+     */
+    void preserPingFangVation(PreserVationFormDTO dto);
 }
\ No newline at end of file
diff --git a/epmet-module/open-data-worker/open-data-worker-server/src/main/java/com/epmet/opendata/service/impl/CaPingfangServiceImpl.java b/epmet-module/open-data-worker/open-data-worker-server/src/main/java/com/epmet/opendata/service/impl/CaPingfangServiceImpl.java
index 0b8f85c23f..9b986ca2a1 100644
--- a/epmet-module/open-data-worker/open-data-worker-server/src/main/java/com/epmet/opendata/service/impl/CaPingfangServiceImpl.java
+++ b/epmet-module/open-data-worker/open-data-worker-server/src/main/java/com/epmet/opendata/service/impl/CaPingfangServiceImpl.java
@@ -1,16 +1,23 @@
 package com.epmet.opendata.service.impl;
 
+import com.alibaba.fastjson.JSON;
+import com.alibaba.fastjson.JSONObject;
 import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
 import com.baomidou.mybatisplus.core.metadata.IPage;
 import com.epmet.commons.mybatis.service.impl.BaseServiceImpl;
 import com.epmet.commons.tools.constant.FieldConstant;
+import com.epmet.commons.tools.constant.NumConstant;
 import com.epmet.commons.tools.page.PageData;
 import com.epmet.commons.tools.utils.ConvertUtils;
+import com.epmet.commons.tools.utils.HttpClientManager;
+import com.epmet.commons.tools.utils.Result;
 import com.epmet.opendata.dao.CaPingfangDao;
 import com.epmet.opendata.dto.CaPingfangDTO;
 import com.epmet.opendata.dto.form.CaPingfangFormDTO;
+import com.epmet.opendata.dto.form.PreserVationFormDTO;
 import com.epmet.opendata.dto.result.CaLoudongResultDTO;
 import com.epmet.opendata.dto.result.CaPingfangResultDTO;
+import com.epmet.opendata.entity.CaLoudongEntity;
 import com.epmet.opendata.entity.CaPingfangEntity;
 import com.epmet.opendata.redis.CaPingfangRedis;
 import com.epmet.opendata.service.CaPingfangService;
@@ -95,4 +102,85 @@ public class CaPingfangServiceImpl extends BaseServiceImpl<CaPingfangDao, CaPing
         return new PageData<>(result, info.getTotal());
     }
 
+    /**
+     * 平房调用ruoyi接口存储数据
+     *
+     * @param dto
+     * @return void
+     * @author LZN
+     * @date 2022/6/2 10:21
+     */
+    @Override
+    public void preserPingFangVation(PreserVationFormDTO dto) {
+        baseDao.deleteAll();
+
+        dto.setPageNo(NumConstant.ONE);
+        dto.setPageSize(NumConstant.FIFTY);
+        dto.setTableSchema(pingFangEnum.PF.name);
+        dto.setTableName(pingFangEnum.PF.code);
+
+        dto.setWhereCase("delete_flag = 'normal'");
+        dto.setOrderBy("grid_id,update_date desc");
+
+        int pageNo = 1;
+
+        int total = 0;
+
+        do {
+            total = listPingFang(dto);
+            pageNo++;
+            dto.setPageNo(pageNo);
+        } while (total > (pageNo * NumConstant.FIFTY));
+    }
+
+    enum pingFangEnum {
+
+        PF("unicom", "ca_pingfang"),
+        ;
+
+        pingFangEnum(String name, String code) {
+            this.name = name;
+            this.code = code;
+        }
+
+        private String name;
+        private String code;
+    }
+
+    private int listPingFang(PreserVationFormDTO dto) {
+        String data = HttpClientManager.getInstance().sendPostByJSON("http://120.221.72.83:9090/bridge/unicom/page", JSON.toJSONString(dto)).getData();
+        JSONObject toResult = JSON.parseObject(data);
+        Result result = ConvertUtils.mapToEntity(toResult, Result.class);
+        if (!result.success()) {
+            return dto.getPageNo() + 1;
+        }
+
+        ReturnDate returnDate = JSONObject.parseObject(JSONObject.toJSONString(result.getData()), ReturnDate.class);
+        this.insertBatch(returnDate.getList());
+        return returnDate.getTotal();
+    }
+
+    class ReturnDate {
+
+        private int total;
+        private List<CaPingfangEntity> list;
+
+
+        public int getTotal() {
+            return total;
+        }
+
+        public void setTotal(int total) {
+            this.total = total;
+        }
+
+        public List<CaPingfangEntity> getList() {
+            return list;
+        }
+
+        public void setList(List<CaPingfangEntity> list) {
+            this.list = list;
+        }
+    }
+
 }
\ No newline at end of file
diff --git a/epmet-module/open-data-worker/open-data-worker-server/src/main/resources/mapper/CaPingfangDao.xml b/epmet-module/open-data-worker/open-data-worker-server/src/main/resources/mapper/CaPingfangDao.xml
index 6da205998e..27711e5ff6 100644
--- a/epmet-module/open-data-worker/open-data-worker-server/src/main/resources/mapper/CaPingfangDao.xml
+++ b/epmet-module/open-data-worker/open-data-worker-server/src/main/resources/mapper/CaPingfangDao.xml
@@ -48,6 +48,9 @@
         <result property="attribute10" column="attribute10"/>
         <result property="communityId" column="community_id"/>
     </resultMap>
+    <delete id="deleteAll">
+        delete from ca_pingfang
+    </delete>
     <select id="getPage" resultType="com.epmet.opendata.dto.result.CaPingfangResultDTO">
         SELECT
             building_id,