qa-prevention-gwj/src/main/java/com/zcloud/service/fireresources/impl/FireResourcesServiceImpl.java

package com.zcloud.service.fireresources.impl;

import com.zcloud.entity.Page;
import com.zcloud.entity.PageData;
import com.zcloud.mapper.datasource.fireresources.FireResourcesMapper;
import com.zcloud.service.bus.ImgFilesService;
import com.zcloud.service.fireresources.FireResourcesService;
import com.zcloud.util.Tools;
import org.springframework.stereotype.Service;
import org.springframework.transaction.annotation.Transactional;
import org.springframework.web.multipart.MultipartFile;

import javax.annotation.Resource;
import java.util.LinkedList;
import java.util.List;

@Service
public class FireResourcesServiceImpl implements FireResourcesService {
    @Resource
    public FireResourcesMapper fireResourcesMapper;
    @Resource
    private ImgFilesService imgFilesService;

    @Override
    @Transactional(rollbackFor = Exception.class)
    public void save(PageData pd, MultipartFile[] files) throws Exception {
        if (files != null && files.length > 0) {
            imgFilesService.uploadPicture(files, "xfbf01".equals(pd.getString("FIRERESOURCES_TYPE")) ? "117" : "116", pd.getString("FIRERESOURCES_ID"));
        }
        String deleteIds = pd.getString("DELETE_IDS");
        if (Tools.notEmpty(deleteIds)) {
            String[] split = deleteIds.split(",");
            imgFilesService.deleteAll(split);
        }
        fireResourcesMapper.save(pd);
    }

    @Override
    @Transactional(rollbackFor = Exception.class)
    public void delete(PageData pd) {
        fireResourcesMapper.delete(pd);
    }

    @Override
    @Transactional(rollbackFor = Exception.class)
    public void edit(PageData pd, MultipartFile[] files) throws Exception {
        if (files != null && files.length > 0) {
            imgFilesService.uploadPicture(files, "xfbf01".equals(pd.getString("FIRERESOURCES_TYPE")) ? "117" : "116", pd.getString("FIRERESOURCES_ID"));
        }
        String deleteIds = pd.getString("DELETE_IDS");
        if (Tools.notEmpty(deleteIds)) {
            String[] split = deleteIds.split(",");
            imgFilesService.deleteAll(split);
        }
        fireResourcesMapper.edit(pd);
    }

    @Override
    public List<PageData> datalistPage(Page page) {
        return fireResourcesMapper.datalistPage(page);
    }

    @Override
    public List<PageData> listAll(PageData pd) {
        return fireResourcesMapper.listAll(pd);
    }

    @Override
    public PageData findById(PageData pd) {
        return fireResourcesMapper.findById(pd);
    }

    @Override
    public LinkedList<PageData> getControlRoomDataList(PageData pageData) {
        return fireResourcesMapper.getControlRoomDataList(pageData);
    }

    @Override
    public PageData getDataById(PageData pddata) {
        return fireResourcesMapper.getDataById(pddata);
    }

    @Override
    public List<PageData> getCheckRecordByPid(PageData pageData) {
        return fireResourcesMapper.getCheckRecordByPid(pageData);
    }

    @Override
    public PageData getPointInfoADeviceByPid(PageData pageData) {
        PageData resData = new PageData();
        PageData pointInfo = fireResourcesMapper.findPointById(pageData);
        // 只取最新的信息
        List<PageData> checkImages = fireResourcesMapper.getPointCheckPhotoById(pageData);
        if (checkImages != null && checkImages.size() > 0) {
            checkImages.forEach(item -> {
                String[] checkImagesItems = item.getString("FILEPATHLIST").split("@@");
                item.put("FILEPATH_LIST", checkImagesItems);
            });
        }
        List<PageData> deviceListByPointId = fireResourcesMapper.listAll4H5(pageData);
        if (deviceListByPointId.size() > 0) {
            deviceListByPointId.forEach(item -> {
                String[] fireCheckStandardItems = item.getString("FIRE_CHECK_STANDARD_ITEM").split("@@");
                item.put("FIRE_CHECK_STANDARD_ITEM", fireCheckStandardItems);
            });
        }
        resData.put("deviceList", deviceListByPointId);
        resData.put("checkImages", checkImages);
        resData.put("pointInfo", pointInfo);
        return resData;
    }

    @Override
    public List<PageData> getPointQualifiedPhotos(PageData pageData) {
        if (pageData.getString("ISLOG").equals("1")) {
            // 记录 EQUIPMENT_POINT_ID
            return fireResourcesMapper.getPointQualifiedPhotosByEpid(pageData);
        }
        return fireResourcesMapper.getPointQualifiedPhotos(pageData);
    }

    @Override
    public List<PageData> goRecordDeviceByPid(PageData pd) {
        List<PageData> list = fireResourcesMapper.goRecordDeviceByPid(pd);
        list.forEach(item -> {
            String[] fireCheckStandardItems = item.getString("FIRE_CHECK_STANDARD_ITEM").split("@@");
            item.put("fireDeviceTypeList", fireCheckStandardItems);
        });
        return list;
    }

    @Override
    public List<PageData> devicelistPage(Page page) {
        return fireResourcesMapper.devicelistPage(page);
    }
}