对接同步项目数据

src/main/java/com/sky/ioc/controller/security/PersonController.java

@@ -10,6 +10,7 @@ import com.sky.ioc.service.security.SecurityDoorService;
 import com.sky.ioc.service.security.SecurityPersonService;
 import com.sky.ioc.service.security.SecurityService;
 import com.sky.ioc.service.space.BuildingFloorService;
+import com.sky.ioc.service.space.CompanyService;
 import com.sky.ioc.tool.ReturnMsg;
 import io.swagger.annotations.Api;
 import io.swagger.annotations.ApiOperation;
@@ -69,14 +70,6 @@ public class PersonController {
         return securityPersonService.getPersonList(personParam);
     }
 
-    @Autowired
-    SecurityDoorRecordService securityDoorRecordService;
-
-    @ApiOperation("门禁数据")
-    @PostMapping("/getDoor")
-    public ReturnMsg getDoor(){
-        return securityDoorRecordService.getSecurityDoorRecordData();
-    }
 
 
 }

src/main/java/com/sky/ioc/entity/domain/operation/EnergyUsed.java

@@ -0,0 +1,36 @@
+package com.sky.ioc.entity.domain.operation;
+
+import lombok.Data;
+
+/**
+ * 能源使用
+ * */
+@Data
+public class EnergyUsed {
+
+    private Integer id;
+
+    /**
+     * 能源类型
+     * */
+    private Integer type;
+
+    /**
+     * 用量
+     * */
+    private String dosage;
+    /**
+     * 成本
+     * */
+    private String cost;
+    /**
+     * 区域
+     * */
+    private String scope;
+    /**
+     * 时间
+     * */
+    private String time;
+
+
+}

src/main/java/com/sky/ioc/entity/domain/space/Company.java

@@ -0,0 +1,55 @@
+package com.sky.ioc.entity.domain.space;
+
+import lombok.Data;
+
+@Data
+public class Company {
+
+    private Integer id;
+    /**
+     * 单位名称
+     * */
+    private String companyName;
+    /**
+     * 单位logo
+     * */
+    private String logo;
+    /**
+     * */
+    private String abbreviation;
+    /**
+     * 编码
+     * */
+    private String code;
+    /**
+     * 注册地址
+     * */
+    private String registeredAddress;
+    /***/
+    private String business_address;
+    /**
+     * 法人
+     * */
+    private String legal_person_name;
+    /**
+     * */
+    private String company_code;
+    /**
+     * 人员规模
+     * */
+    private Integer staff_size;
+
+    /**
+     * 参保人数
+     * */
+    private Integer on_guard_size;
+
+    /**
+     * 部门id
+     * */
+    private Integer officeId;
+    /**
+     * 区域id
+     * */
+    private Integer areaId;
+}

src/main/java/com/sky/ioc/mapper/space/CompanyMapper.java

@@ -0,0 +1,9 @@
+package com.sky.ioc.mapper.space;
+
+import com.baomidou.mybatisplus.core.mapper.BaseMapper;
+import com.sky.ioc.entity.domain.space.Company;
+import org.apache.ibatis.annotations.Mapper;
+
+@Mapper
+public interface CompanyMapper extends BaseMapper<Company> {
+}

src/main/java/com/sky/ioc/service/space/CompanyService.java

@@ -0,0 +1,8 @@
+package com.sky.ioc.service.space;
+
+import com.sky.ioc.tool.ReturnMsg;
+
+public interface CompanyService {
+
+    ReturnMsg getCompanyData();
+}

src/main/java/com/sky/ioc/service/space/impl/CompanyServiceImpl.java

@@ -0,0 +1,68 @@
+package com.sky.ioc.service.space.impl;
+
+import com.sky.ioc.config.RestTemplateConfig;
+import com.sky.ioc.entity.domain.space.Company;
+import com.sky.ioc.entity.domain.space.Department;
+import com.sky.ioc.mapper.space.CompanyMapper;
+import com.sky.ioc.mapper.space.DepartmentMapper;
+import com.sky.ioc.service.space.CompanyService;
+import com.sky.ioc.tool.ReturnMsg;
+import lombok.extern.slf4j.Slf4j;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.http.ResponseEntity;
+import org.springframework.stereotype.Service;
+import org.springframework.web.client.RestTemplate;
+
+import java.util.ArrayList;
+import java.util.LinkedHashMap;
+import java.util.Map;
+import java.util.concurrent.ThreadLocalRandom;
+
+@Service
+@Slf4j
+public class CompanyServiceImpl implements CompanyService {
+
+    @Autowired
+    RestTemplateConfig restTemplateConfig;
+
+    @Autowired
+    CompanyMapper companyMapper;
+
+    final static  String COMPANY_URL="/api/space/SPACE/siteArea/list";
+    @Override
+    public ReturnMsg getCompanyData() {
+        String url = restTemplateConfig.addBaseUrl(COMPANY_URL)+"?pageNum=1&pageSize=1000";
+        // 创建RestTemplate
+        RestTemplate restTemplate = restTemplateConfig.build();
+        // 发送GET请求
+        ResponseEntity<Map> responseEntity = restTemplate.getForEntity(url, Map.class);
+        // 获取响应对象里的 body 对象
+        Map<String, Object> body = responseEntity.getBody();
+        // 获取状态码
+        Integer code = (Integer)body.get("code");
+        // 获取响应信息
+        String message = (String)body.get("msg");
+        if(code==200){
+            ThreadLocalRandom random = ThreadLocalRandom.current();
+            ArrayList list = (ArrayList) body.get("rows");
+            if(list!=null&&list.size()>0){
+                companyMapper.delete(null);
+                for (int i=0;i<list.size();i++){
+                    LinkedHashMap json = (LinkedHashMap) list.get(i);
+                    Company company = new Company();
+                    company.setId((Integer) json.get("id"));
+                    company.setCompanyName(String.valueOf(json.get("name")));
+                    company.setRegisteredAddress(String.valueOf(json.get("address")));
+                    company.setAreaId(Integer.parseInt(String.valueOf(json.get("areaId"))));
+                    company.setOfficeId(Integer.parseInt(String.valueOf(json.get("officeId"))));
+                    companyMapper.insert(company);
+                }
+            }
+            return ReturnMsg.ok();
+
+        }else{
+            log.info("获取项目数据："+message);
+            return  ReturnMsg.fail(message);
+        }
+    }
+}