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

package com.project.zcustom.tools;

import com.alibaba.fastjson2.JSON;
import com.alibaba.fastjson2.JSONArray;
import com.alibaba.fastjson2.JSONObject;
import com.project.common.utils.StringUtils;
import com.project.common.utils.http.HttpUtils;
import com.project.zcustom.domain.addional.LargeAssetDirs;
import com.project.zcustom.domain.addional.LargeLogistics;
import com.project.zcustom.domain.basics.PlatAppOrg;
import com.project.zcustom.domain.plat.PlatApiRecord;
import com.project.zcustom.mapper.logistics.PlatAssetMapper;
import com.project.zcustom.service.basics.IPlatAppOrgService;
import com.project.zcustom.service.plat.IPlatApiRecordService;
import org.apache.commons.compress.utils.Lists;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;

import javax.annotation.Resource;
import java.util.ArrayList;
import java.util.List;
import java.util.Map;
import java.util.Objects;
import java.util.stream.Collectors;

/**
 * @Description 后勤资源监控服务
 * @Author bqyang
 * @Date 2025/2/10 17:23
 * @Version 1.0
 */
@Service
public class LogisticsService {

    @Autowired
    private PlatAssetMapper platAssetMapper;
    @Autowired
    private IPlatAppOrgService platAppOrgService;
    @Resource
    IPlatApiRecordService iPlatApiRecordService;


    public void getLogisticsData(){
        JSONObject jsonObject = this.repeat(ApiUrlConfig.getLogisticsUrl());
        if (Objects.isNull(jsonObject)) {
            return;
        }

        // 添加接口请求记录
        PlatApiRecord platApiRecord = new PlatApiRecord();
        platApiRecord.setApiUrl(ApiUrlConfig.getLogisticsUrl());
        platApiRecord.setApiResult(jsonObject.toString());
        iPlatApiRecordService.save(platApiRecord);

        JSONArray dataArray = jsonObject.getJSONArray("data");
        List<LargeLogistics> list = new ArrayList<>();
        List<LargeAssetDirs> officeAssetList = new ArrayList<>();
        List<LargeAssetDirs> buildingAssetList = new ArrayList<>();
        List<LargeAssetDirs> serviceAssetList = new ArrayList<>();

        // 查询所有组织信息
        List<PlatAppOrg> orgList = platAppOrgService.selectAppCodeList();
        Map<String, String> orgMap = orgList.stream().collect(Collectors.toMap(PlatAppOrg::getAppCode, PlatAppOrg::getAppName, (v1, v2) -> v1));

        for (int i = 0; i < dataArray.size(); i++) {
            JSONObject dataItem = dataArray.getJSONObject(i);
            LargeLogistics largeLogistics = JSON.parseObject(dataItem.toString(), LargeLogistics.class);
            // 业务方提供的数据包含一些不需要的部门数据进行过滤
            if ( !orgMap.containsKey(largeLogistics.getOrgId())){
                continue;
            }

            // 资产列表数据提取
            List<LargeAssetDirs> officeList = getAssetList(dataItem, largeLogistics.getOrgId(), "officeAssetDistrs");
            officeAssetList.addAll(officeList);

            List<LargeAssetDirs> buildingList = getAssetList(dataItem, largeLogistics.getOrgId(),"buildingAssetDistrs");
            buildingAssetList.addAll(buildingList);

            List<LargeAssetDirs> serviceList = getAssetList(dataItem, largeLogistics.getOrgId(), "serviceAssetDistrs");
            serviceAssetList.addAll(serviceList);

            list.add(largeLogistics);
        }
        platAssetMapper.deleteLogistics();
        platAssetMapper.insertLargePlatLogistics(list);
        platAssetMapper.deleteOfficeAssetDirs();
        platAssetMapper.insertOfficeAssetDirs(officeAssetList);
        platAssetMapper.deleteBuildingAssetDirs();
        platAssetMapper.insertBuildingAssetDirs(buildingAssetList);
        platAssetMapper.deleteServiceAssetDirs();
        platAssetMapper.insertServiceAssetDirs(serviceAssetList);
    }

    /**
     * officeAssetDistrs 办公资产分布列表
     * buildingAssetDistrs 楼宇设备分布列表
     * serviceAssetDistrs 服务设备分布列表
     * @param dataItem
     * @param appCode
     * @param jsonKey
     * @return
     */
    private List<LargeAssetDirs> getAssetList(JSONObject dataItem, String appCode, String jsonKey){
        List<LargeAssetDirs> list = Lists.newArrayList();
        JSONArray buildingAssetArray = dataItem.getJSONArray(jsonKey);
        for (int k = 0; k < buildingAssetArray.size(); k++) {
            LargeAssetDirs largeAssetDirs = new LargeAssetDirs();
            JSONObject assetItem = buildingAssetArray.getJSONObject(k);
            largeAssetDirs.setAppCode(appCode);
            largeAssetDirs.setCategoryName(assetItem.getString("categoryName"));
            largeAssetDirs.setAssetNum(assetItem.getLong("assetNum"));
            list.add(largeAssetDirs);
        }
        return list;
    }


    public JSONObject repeat(String url){
        try {
            String res = HttpUtils.sendPost(url,"");
            if (StringUtils.isNotBlank(res)){
                JSONObject jsonObject = JSONObject.parseObject(res);
                return jsonObject;
            }
        }catch (Exception e){
            e.printStackTrace();
        }
        return null;
    }
}