large-Back-Manager/project-zcustom/src/main/java/com/project/zcustom/tools/BuildingService.java

package com.project.zcustom.tools;

import com.alibaba.fastjson2.JSONObject;
import com.project.common.utils.StringUtils;
import com.project.common.utils.http.HttpUtils;
import com.project.zcustom.domain.addional.LargeBuilding;
import com.project.zcustom.domain.addional.LargeBuildingControl;
import com.project.zcustom.domain.addional.LargeCar;
import com.project.zcustom.domain.plat.PlatApiRecord;
import com.project.zcustom.mapper.unit.PlatBuildingMapper;
import com.project.zcustom.service.plat.IPlatApiRecordService;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;

import javax.annotation.Resource;

/**
 * @Description 楼宇运行监控接口
 * @Author bqyang
 * @Date 2025/2/10 16:58
 * @Version 1.0
 */
@Service
public class BuildingService {

    @Autowired
    private PlatBuildingMapper platBuildingMapper;
    @Resource
    IPlatApiRecordService iPlatApiRecordService;

    /**
     *  楼宇中控 接口数据同步
     */
    public void getLeftBuildingData(){
        String controlEquipment = repeat(ApiUrlConfig.getControlEquipment(), null);
        JSONObject jsonObject = JSONObject.parseObject(controlEquipment);
        Long normalNum = Long.valueOf(jsonObject.getJSONObject("sj").getString("zcdw"));
        Long abnormalNum = Long.valueOf(jsonObject.getJSONObject("sj").getString("ycdw"));
        LargeBuildingControl largeBuildingControl = new LargeBuildingControl(
                repeat(ApiUrlConfig.getControlElectricity(), null),
                repeat(ApiUrlConfig.getControlElectricityRoom(), null),
                repeat(ApiUrlConfig.getControlTodaySum(), null),
                repeat(ApiUrlConfig.getControlMonthSum(), "type=一号配电室"),
                repeat(ApiUrlConfig.getControlMonthSum(), "type=二号配电室"),
                repeat(ApiUrlConfig.getControlMonthSum(), "type=三号配电室"),
                repeat(ApiUrlConfig.getControlImportantSum(), "type=一号配电室"),
                repeat(ApiUrlConfig.getControlImportantSum(), "type=二号配电室"),
                repeat(ApiUrlConfig.getControlImportantSum(), "type=三号配电室"),
                repeat(ApiUrlConfig.getControlEquipment(), null),
                normalNum,
                abnormalNum,
                repeat(ApiUrlConfig.getControlAlarm(), null),
                repeat(ApiUrlConfig.getControlWater(), "position=23F"),
                repeat(ApiUrlConfig.getControlWater(), "position=负二")
                );
        if (platBuildingMapper.getExist() > 0){
            platBuildingMapper.updateBuildingControl(largeBuildingControl);
        }
        else platBuildingMapper.addBuildingControl(largeBuildingControl);
    }

    /**
     *  办公能耗 / 大楼安防 接口数据同步
     */
    public void getRightBuildingDataFirstHalf(){
        LargeBuilding largeBuilding = new LargeBuilding();
        largeBuilding.setJsonFrequency(repeat(ApiUrlConfig.getJsonFrequency(), null));
        largeBuilding.setJsonPatrol(repeat(ApiUrlConfig.getJsonPatrol(), null));
        largeBuilding.setJsonPatrolPoint(repeat(ApiUrlConfig.getJsonPatrolPoint(), null));
        largeBuilding.setJsonPowerWaterMonth((repeat(ApiUrlConfig.getJsonPowerWaterMonth(), null)));
        largeBuilding.setJsonTarget(repeat(ApiUrlConfig.getJsonTarget(), null));
        largeBuilding.setJsonUseElectricity(repeat(ApiUrlConfig.getJsonUseElectricity(), null));
        largeBuilding.setJsonGreenElectricity(repeat(ApiUrlConfig.getJsonGreenElectricity(), null));
        largeBuilding.setJsonCarbon(repeat(ApiUrlConfig.getJsonCarbon(), null));
        largeBuilding.setJsonEnergyYear(repeat(ApiUrlConfig.getJsonEnergyYear(), null));
        largeBuilding.setJsonPowerYear(repeat(ApiUrlConfig.getJsonPowerYear(), null));
        largeBuilding.setJsonWaterYear(repeat(ApiUrlConfig.getJsonWaterYear(), null));
        if (platBuildingMapper.getCount() > 0){
            platBuildingMapper.updateBuilding(largeBuilding);
        }
        else {
            platBuildingMapper.insertBuilding(largeBuilding);
        }
    }

    /**
     * 办公能耗 空气概况
     *  该接口请求频率 5分钟一次
     */
    public void getRightBuildingDataSecondHalf(){
        LargeBuilding largeBuilding = new LargeBuilding();
        largeBuilding.setJsonAir(repeat(ApiUrlConfig.getJsonAir(), null));
        if (platBuildingMapper.getCount() > 0){
            platBuildingMapper.updateBuilding(largeBuilding);
        }
        else {
            platBuildingMapper.insertBuilding(largeBuilding);
        }
    }

    public String repeat(String url, String params){
        String result = null;
        try {
            if (StringUtils.isNotBlank(params)){
                String res = HttpUtils.sendGet(url, params);
                if (StringUtils.isNotBlank(res)){
                    JSONObject jsonObject = JSONObject.parseObject(res);
                    result = jsonObject.getString("data");
                }
            } else {
                String res = HttpUtils.sendGet(url);
                if (StringUtils.isNotBlank(res)){
                    JSONObject jsonObject = JSONObject.parseObject(res);
                    result = jsonObject.getString("data");
                }
            }

        } catch (Exception e){
            result = e.getMessage();
        }
        // 添加接口请求记录
        PlatApiRecord platApiRecord = new PlatApiRecord();
        platApiRecord.setApiUrl(url);
        platApiRecord.setApiResult(result);
        iPlatApiRecordService.save(platApiRecord);
        return result;
    }
}