package com.doumee.service.business.impl.hksync;

import com.doumee.core.constants.ResponseStatus;
import com.doumee.core.exception.BusinessException;
import com.doumee.core.haikang.model.HKConstants;
import com.doumee.core.haikang.model.param.BaseResponse;
import com.doumee.core.haikang.model.param.request.AcsDeviceListRequest;
import com.doumee.core.haikang.model.param.request.ParkListRequest;
import com.doumee.core.haikang.model.param.respose.AcsDeviceInfoResponse;
import com.doumee.core.haikang.model.param.respose.AcsDeviceListResponse;
import com.doumee.core.haikang.model.param.respose.ParkListResponse;
import com.doumee.core.haikang.service.HKService;
import com.doumee.core.utils.Constants;
import com.doumee.core.utils.DateUtil;
import com.doumee.dao.business.DeviceMapper;
import com.doumee.dao.business.ParksMapper;
import com.doumee.dao.business.model.Device;
import com.doumee.dao.business.model.Parks;
import org.apache.commons.lang3.StringUtils;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;

import java.util.ArrayList;
import java.util.Date;
import java.util.List;

/**
 * 海康停车库同步Service实现
 * @author 江蹄蹄
 * @date 2023/11/30 15:33
 */
@Service
public class HkSyncParkServiceImpl extends HkSyncBaseServiceImpl {

    @Autowired
    private ParksMapper parksMapper;

    /**
     * 同步海康停车库数据
     * @param param
     * @return
     */
    @Override
//    @Async
    public   String syncHkParks(ParkListRequest param){
        List<Parks> deleteList = new ArrayList<>();
        List<Parks> addList = new ArrayList<>();
        List<Parks> editList = new ArrayList<>();
        Date date = new Date();
        //查询全部当前数据
        List<Parks> allList = parksMapper.selectList(null);
            //分页遍历循环查询所有门禁设备数据
        param = new ParkListRequest();
        BaseResponse<List<ParkListResponse>> response = HKService.parkList(param);
        if(response == null || !StringUtils.equals(response.getCode(), HKConstants.RESPONSE_SUCCEE)){
            throw  new BusinessException(ResponseStatus.SERVER_ERROR.getCode(), "对不起，海康同步数据失败~");
        }
        List<ParkListResponse> allHkList = response.getData();
         // 获取增删改数据集合
        getDataChangeList(allList,allHkList,addList,editList,deleteList,date);
        if(deleteList.size()>0){
            //逻辑删除
            for(Parks d : deleteList){
                parksMapper.updateById(d);
            }
        }
        if(addList.size()>0){
            parksMapper.insertBatchSomeColumn(addList);
        }
        if(editList.size()>0){
            for(Parks d : editList){
                parksMapper.updateById(d);
            }
        }
        return "同步数据：新增【"+addList.size()+"】条，更新【"+editList.size()+"】条，删除【"+deleteList.size()+"】条";
    }
    private void getDataChangeList(List<Parks> allList, List<ParkListResponse> allHkList, List<Parks> addList, List<Parks> editList,List<Parks> deleteList, Date date) {
        if(allHkList!=null && allHkList.size()>0){
            for(ParkListResponse device : allHkList){
                Parks model = getExistedData(device,allList);
                if(model !=null){
                    //如果已存在，则更新数据
                    model =  initModelByHkData(model,device,date);
                    editList.add(model);
                }else{
                    //如果不存在，则新增数据
                    model = new Parks();
                    model =  initModelByHkData(model,device,date);
                    addList.add(model);
                }
            }
        }
        //判断获取删除的门禁设备，逻辑删除
        getDeleteList(allList,allHkList,deleteList,date);
    }

    /**
     * 初始化海康入库数据
     * @param model
     * @param device
     * @param date
     * @return
     */
    private Parks initModelByHkData(Parks model, ParkListResponse device,Date date) {
        model.setIsdeleted(Constants.ZERO);
        model.setName(device.getParkName());
        model.setHkDate(date);
        model.setCreateDate(DateUtil.getISO8601DateByStr(device.getCreateTime()));
        model.setEditDate(DateUtil.getISO8601DateByStr(device.getUpdateTime()));
        model.setHkId(device.getParkIndexCode());
        model.setHkStatus(Constants.ONE);
        return  model;
    }

    private Parks getExistedData(ParkListResponse data, List<Parks> allList) {
        if(allList.size()>0){
            for(Parks r : allList){
                if(StringUtils.equals(r.getHkId(), data.getParkIndexCode())){
                    //表示未删除
                    return  r;
                }
            }
        }
        return  null;
    }

    private void getDeleteList(List<Parks> allList, List<ParkListResponse> allHkList,List<Parks> deleteList ,Date date) {
        if(allList!=null && allList.size()>0){
            for(Parks data : allList){
                if(isDeletedDevice(data,allHkList)){
                    data.setIsdeleted(Constants.ONE);
                    data.setEditDate(date);
                    deleteList.add(data);
                }
            }
        }
    }

    private boolean isDeletedDevice(Parks device, List<ParkListResponse> allHkList) {
        if(allHkList.size()>0){
            for(ParkListResponse r : allHkList){
                if(StringUtils.equals(device.getHkId(), r.getParkIndexCode())){
                    //表示未删除
                    return  false;
                }
            }
        }
        return  true;

    }
    
}