package com.sandu.ximon.admin.service;

import cn.hutool.core.collection.CollectionUtil;
import cn.hutool.core.util.HexUtil;
import cn.hutool.core.util.StrUtil;
import com.alibaba.fastjson.JSON;
import com.aliyuncs.iot.model.v20180120.BatchGetDeviceStateResponse;
import com.baomidou.mybatisplus.core.toolkit.Wrappers;
import com.github.pagehelper.PageHelper;
import com.sandu.common.domain.CommonPage;
import com.sandu.common.execption.BusinessException;
import com.sandu.common.redis.RedisService;
import com.sandu.common.service.impl.BaseServiceImpl;
import com.sandu.ximon.admin.manager.iot.frame.A7Frame;
import com.sandu.ximon.admin.manager.iot.frame.FrameBuilder;
import com.sandu.ximon.admin.manager.iot.frame.IRequestFrame;
import com.sandu.ximon.admin.manager.iot.frame.inner.report.A7PlcOperationReportInnerFrame;
import com.sandu.ximon.admin.manager.iot.frame.inner.request.*;
import com.sandu.ximon.admin.manager.iot.frame.inner.response.*;
import com.sandu.ximon.admin.manager.iot.rrpc.dto.CommonFrame;
import com.sandu.ximon.admin.manager.iot.rrpc.dto.WrapResponseCommonFrame;
import com.sandu.ximon.admin.manager.iot.rrpc.enums.A2OrderEnum;
import com.sandu.ximon.admin.manager.iot.rrpc.enums.A5OrderEnum;
import com.sandu.ximon.admin.manager.iot.rrpc.enums.A7OrderEnum;
import com.sandu.ximon.admin.manager.iot.rrpc.mainboard.MainBoardInvokeSyncService;
import com.sandu.ximon.admin.param.PlcControlParam;
import com.sandu.ximon.admin.param.PlcRemarkParam;
import com.sandu.ximon.admin.redis.LightKey;
import com.sandu.ximon.admin.security.SecurityUtils;
import com.sandu.ximon.admin.utils.RedisUtils;
import com.sandu.ximon.admin.utils.StoreOperationRecordsUtils;
import com.sandu.ximon.dao.bo.PlcBo;
import com.sandu.ximon.dao.domain.*;
import com.sandu.ximon.dao.enums.DeviceRespStatusEnums;
import com.sandu.ximon.dao.enums.OrderByEnums;
import com.sandu.ximon.dao.mapper.PlcMapper;
import lombok.AllArgsConstructor;
import lombok.extern.slf4j.Slf4j;
import org.springframework.stereotype.Service;

import java.util.*;
import java.util.stream.Collectors;

/**
 * plc路灯表(Plc)表服务接口
 *
 * @author van
 * @since 2022-12-15 14:45:27
 */
@Service
@Slf4j
@AllArgsConstructor
public class PlcService extends BaseServiceImpl<PlcMapper,Plc> {

    private final RedisService redisService;
    private final PlcReportDataService plcReportDataService;
    private final PoleBindingService bindingService;
    private final PoleService poleService;
    private final RedisUtils redisUtils;

    public List<PlcBo> listPlc(int pageNo, int pageSize, String keyword, Integer order, Integer seq) {
        Long clientId = SecurityUtils.getClientId();

        //排序字段
        String orderByResult = "plc_id";
        //正序、倒叙
        String orderBySeq = OrderByEnums.ASC.getCode();
        if (order != null) {
            switch (order) {
                case 1:
                    orderByResult = OrderByEnums.LIGHT_POLE_NAME.getCode();
                    break;
                case 2:
                    orderByResult = OrderByEnums.LIGHT_UPDATE_TIME.getCode();
                    break;
                case 3:
                    orderByResult = OrderByEnums.LIGHT_CREATE_TIME.getCode();
                    break;
                default:
            }
        }
        if (seq != null) {
            switch (seq) {
                case 1:
                    orderBySeq = OrderByEnums.ASC.getCode();
                    break;
                case 2:
                    orderBySeq = OrderByEnums.DESC.getCode();
                    break;
                default:
                    break;
            }
        }
        //排序方式
        String orderBy = orderByResult + " " + orderBySeq;

        PageHelper.startPage(pageNo, pageSize, orderBy);

        List<PlcBo> listPlc = baseMapper.listPlc(clientId, keyword);

        // 获取最近的上报时间
        List<String> deviceCodeList = listPlc.stream().map(Plc::getDeviceCode).collect(Collectors.toList());
        //拆分list
        List<List<String>> split = CollectionUtil.split(deviceCodeList, 100);

        List<BatchGetDeviceStateResponse.DeviceStatus> deviceStatuses = null;
        for (List<String> splist : split) {
            deviceStatuses = MainBoardInvokeSyncService.getInstance().batchGetDeviceState(splist);
            if (deviceStatuses != null) {
                for (PlcBo plcBo : listPlc ) {
                    for (BatchGetDeviceStateResponse.DeviceStatus deviceStatus : deviceStatuses) {

                        if (plcBo.getDeviceCode() != null && plcBo.getDeviceCode().equals(deviceStatus.getDeviceName())) {
                            if ("ONLINE".equals(deviceStatus.getStatus())) {
                                plcBo.setOnlineStatus(0);
                            } else if ("OFFLINE".equals(deviceStatus.getStatus())) {
                                plcBo.setOnlineStatus(1);
                            } else {
                                plcBo.setOnlineStatus(2);
                            }

                        }
                    }

                }
            }
        }

        if (CollectionUtil.isNotEmpty(deviceCodeList)) {
            List<PlcReportData> reportDataList = plcReportDataService.getNewestReportByDeviceCode(deviceCodeList);
            for (PlcBo plcBo : listPlc) {
                deviceCodeList.forEach(code -> {
                    PoleBinding bind = bindingService.getPoleIdByMac(code);
                    if (bind != null && plcBo.getDeviceCode().equals(bind.getDeviceCode())) {
                        Long poleId = bind.getPoleId();
                        Pole pole = poleService.getById(poleId);
                        plcBo.setPoleId(pole.getId());
                        plcBo.setPoleCode(pole.getDeviceCode());
                        plcBo.setPoleName(pole.getPoleName());
                    }
                });
                for (PlcReportData plcReportData : reportDataList) {
                    if (StrUtil.equals(plcBo.getDeviceCode(), plcReportData.getDeviceCode())) {
                        plcBo.setReportTime(plcReportData.getCreateTime1());
                        break;
                    }
                }
            }
        }
        return listPlc;
    }

    /**
     * 获取单个plc信息
     *
     * @param deviceCode 设备码
     * @return
     */
    public Plc getPlc(String deviceCode) {
        Plc one = getOne(Wrappers.<Plc>lambdaQuery().eq(Plc::getDeviceCode, deviceCode));
        if (one == null) {
            return null;
        } else {
            Object o = redisService.get(LightKey.REPORT_MAC.key(deviceCode));
            if (o != null) {
                one.setOnlineStatus(1);
            } else {
                one.setOnlineStatus(0);
            }
            return one;
        }
    }

    public boolean addRemark(PlcRemarkParam param) {
        Plc plc = getById(param.getPlcId());
        if (plc == null) {
            throw new BusinessException("找不到PLC");
        }
        Plc update = new Plc();
        update.setPlcId(param.getPlcId());
        update.setPlcRemark(param.getPlcRemark());
        return updateById(update);
    }

    /**
     * PLC亮度控制
     *
     * @return com.sandu.ximon.dao.enums.DeviceRespStatusEnums
     */
    public List<Map<String, Object>> controlBrightness(List<PlcControlParam> paramList) {
        if (CollectionUtil.isEmpty(paramList)) {
            throw new BusinessException("参数不能为空");
        }

        List<Map<String, Object>> resultList = new ArrayList<>();
        for (PlcControlParam param : paramList) {
            A7PlcBrightnessReqInnerFrame plcControlFrame = new A7PlcBrightnessReqInnerFrame(param.getBrightness(), param.getPlcAddress());
            A7Frame a7Frame = new A7Frame(A7OrderEnum.REQUEST_PLC_DATA.getCode(), plcControlFrame);
            Map<String, Object> map = new HashMap<>();
            try {
                map.put("deviceCode", param.getDeviceCode());
                WrapResponseCommonFrame<A7PlcBrightnessRespInnerFrame> frame
                        = MainBoardInvokeSyncService.getInstance().sendRRPC(param.getDeviceCode(), a7Frame, A7PlcBrightnessRespInnerFrame.class);
                //存储控制帧指令
                StoreOperationRecordsUtils.storeInnerFrameData(param.getDeviceCode(), "PLC帧-亮度开关控制", a7Frame, frame);

                if (frame == null) {
                    map.put("status", DeviceRespStatusEnums.OTHER_ERROR.getCode());
                    resultList.add(map);
                    continue;
                }
                String responseStatus = frame.getResponseInnerFrame().getResponseStatus();
                int status = HexUtil.hexToInt(responseStatus);
                map.put("status", status);
                resultList.add(map);
                // 更新亮度成功，修改到数据库
                if (DeviceRespStatusEnums.SUCCESS.getCode().equals(status)) {
                    Plc plc = new Plc();
                    if (param.getPlcAddress().equals("0001")){
                        plc.setPlcLight1(param.getBrightness());
                    }
                    else if (param.getPlcAddress().equals("0002")){
                        plc.setPlcLight2(param.getBrightness());
                    }
                    else if (param.getPlcAddress().equals("0003")){
                        plc.setPlcLight3(param.getBrightness());
                    }
                    else if (param.getPlcAddress().equals("FFFF")){
                        plc.setPlcLight1(param.getBrightness());
                        plc.setPlcLight2(param.getBrightness());
                        plc.setPlcLight3(param.getBrightness());

                    }
                    update(plc, Wrappers.lambdaUpdate(Plc.class).eq(Plc::getDeviceCode, param.getDeviceCode()));

                }
            } catch (BusinessException e) {
                map.put("status", DeviceRespStatusEnums.OTHER_ERROR.getCode());
                resultList.add(map);
            }
        }

        /**
         * 服务端批量控灯日志记录开始
         */
        String content = "{PLC控灯请求：" + paramList.toString()
                + "， PLC控灯结果：" + resultList.toString() + "}";
        List<String> codeList = new ArrayList<>();
        for (PlcControlParam bean : paramList) {
            codeList.add(bean.getDeviceCode());
        }
        StoreOperationRecordsUtils.storeOperationData(codeList, null, "服务端批量PLC控灯", content);
        /**
         * 服务端批量控灯日志记录结束
         */

        return resultList;

    }

    /**
     * PLC设置心跳时间
     *
     * @return com.sandu.ximon.dao.enums.DeviceRespStatusEnums
     */
    public List<Map<String, Object>> setHeartBeatTime(List<PlcControlParam> paramList) {
        if (CollectionUtil.isEmpty(paramList)) {
            throw new BusinessException("参数不能为空");
        }

        List<Map<String, Object>> resultList = new ArrayList<>();
        for (PlcControlParam param : paramList) {
            A7PlcSettingHeartBeatTimeReqInnerFrame plcControlFrame = new A7PlcSettingHeartBeatTimeReqInnerFrame(param.getHeartBeatTime());
            A7Frame a7Frame = new A7Frame(A7OrderEnum.REQUEST_PLC_DATA.getCode(), plcControlFrame);
            Map<String, Object> map = new HashMap<>();
            try {
                map.put("deviceCode", param.getDeviceCode());
                WrapResponseCommonFrame<A7PlcBrightnessRespInnerFrame> frame
                        = MainBoardInvokeSyncService.getInstance().sendRRPC(param.getDeviceCode(), a7Frame, A7PlcBrightnessRespInnerFrame.class);
                //存储控制帧指令
                StoreOperationRecordsUtils.storeInnerFrameData(param.getDeviceCode(), "PLC帧-设置PLC心跳包间隔时间", a7Frame, frame);

                if (frame == null) {
                    map.put("status", DeviceRespStatusEnums.OTHER_ERROR.getCode());
                    resultList.add(map);
                    continue;
                }
                String responseStatus = frame.getResponseInnerFrame().getResponseStatus();
                int status = HexUtil.hexToInt(responseStatus);
                map.put("status", status);
                resultList.add(map);
            } catch (BusinessException e) {
                map.put("status", DeviceRespStatusEnums.OTHER_ERROR.getCode());
                resultList.add(map);
            }
        }

        /**
         * 服务端批量控灯日志记录开始
         */
        String content = "{PLC设置心跳时间：" + paramList.toString()
                + "， PLC设置心跳时间结果：" + resultList.toString() + "}";
        List<String> codeList = new ArrayList<>();
        for (PlcControlParam bean : paramList) {
            codeList.add(bean.getDeviceCode());
        }
        StoreOperationRecordsUtils.storeOperationData(codeList, null, "PLC设置心跳时间", content);
        /**
         * 服务端批量控灯日志记录结束
         */

        return resultList;

    }

    /**
     * PLC 查询心跳时间
     *
     * @return com.sandu.ximon.dao.enums.DeviceRespStatusEnums
     */
    public List<Map<String, Object>> queryHeartBeatTime(List<PlcControlParam> paramList) {
        if (CollectionUtil.isEmpty(paramList)) {
            throw new BusinessException("参数不能为空");
        }

        List<Map<String, Object>> resultList = new ArrayList<>();
        for (PlcControlParam param : paramList) {
            A7PlcQueryHeartBeatTimeReqInnerFrame plcControlFrame = new A7PlcQueryHeartBeatTimeReqInnerFrame();
            A7Frame a7Frame = new A7Frame(A7OrderEnum.REQUEST_PLC_DATA.getCode(), plcControlFrame);
            Map<String, Object> map = new HashMap<>();
            try {
                map.put("deviceCode", param.getDeviceCode());
                WrapResponseCommonFrame<A7PlcQueryHeartBeatTimeRespInnerFrame> frame
                        = MainBoardInvokeSyncService.getInstance().sendRRPC(param.getDeviceCode(), a7Frame,  A7PlcQueryHeartBeatTimeRespInnerFrame.class);
                //存储控制帧指令
                StoreOperationRecordsUtils.storeInnerFrameData(param.getDeviceCode(), "PLC帧-设置PLC心跳包间隔时间", a7Frame, frame);

                if (frame == null) {
                    map.put("status", DeviceRespStatusEnums.OTHER_ERROR.getCode());
                    resultList.add(map);
                    continue;
                }
                String time = frame.getResponseInnerFrame().getTime();
                map.put("status", 0);
                map.put("time",time);
                resultList.add(map);
            } catch (BusinessException e) {
                map.put("status", DeviceRespStatusEnums.OTHER_ERROR.getCode());
                resultList.add(map);
            }
        }

        /**
         * 服务端批量控灯日志记录开始
         */
        String content = "{PLC查询心跳时间：" + paramList.toString()
                + "， PLC查询心跳时间结果：" + resultList.toString() + "}";
        List<String> codeList = new ArrayList<>();
        for (PlcControlParam bean : paramList) {
            codeList.add(bean.getDeviceCode());
        }
        StoreOperationRecordsUtils.storeOperationData(codeList, null, "PLC查询心跳时间", content);
        /**
         * 服务端批量控灯日志记录结束
         */

        return resultList;

    }

    /**
     * PLC 查询心跳包
     *
     * @return com.sandu.ximon.dao.enums.DeviceRespStatusEnums
     */
    public List<Map<String, Object>> queryHeartBeatData(List<PlcControlParam> paramList) {
        if (CollectionUtil.isEmpty(paramList)) {
            throw new BusinessException("参数不能为空");
        }

        List<Map<String, Object>> resultList = new ArrayList<>();
        for (PlcControlParam param : paramList) {
            A7PlcQueryHeartBeatDataReqInnerFrame plcControlFrame = new A7PlcQueryHeartBeatDataReqInnerFrame();
            A7Frame a7Frame = new A7Frame(A7OrderEnum.REQUEST_PLC_DATA.getCode(), plcControlFrame);
            Map<String, Object> map = new HashMap<>();
            try {
                map.put("deviceCode", param.getDeviceCode());
                WrapResponseCommonFrame<A7PlcQueryHeartBeatDataRespInnerFrame> frame
                        = MainBoardInvokeSyncService.getInstance().sendRRPC(param.getDeviceCode(), a7Frame,  A7PlcQueryHeartBeatDataRespInnerFrame.class);

                if (frame == null) {
                    map.put("status", DeviceRespStatusEnums.OTHER_ERROR.getCode());
                    resultList.add(map);
                    continue;
                }
                String data = JSON.toJSONString(frame.getResponseInnerFrame().getHeartbeatReportInnerFrame().getHeartBeatDataPackage());
                map.put("status", 0);
                map.put("heartBeatData",data);
                resultList.add(map);
            } catch (BusinessException e) {
                map.put("status", DeviceRespStatusEnums.OTHER_ERROR.getCode());
                resultList.add(map);
            }
        }



        return resultList;

    }


    /**
     * PLC 查询版本
     *
     * @return com.sandu.ximon.dao.enums.DeviceRespStatusEnums
     */
    public List<Map<String, Object>> queryVersion(List<PlcControlParam> paramList) {
        if (CollectionUtil.isEmpty(paramList)) {
            throw new BusinessException("参数不能为空");
        }

        List<Map<String, Object>> resultList = new ArrayList<>();
        for (PlcControlParam param : paramList) {
            A7PlcQueryVersionReqInnerFrame plcControlFrame = new A7PlcQueryVersionReqInnerFrame();
            A7Frame a7Frame = new A7Frame(A7OrderEnum.REQUEST_PLC_DATA.getCode(), plcControlFrame);
            Map<String, Object> map = new HashMap<>();
            try {
                map.put("deviceCode", param.getDeviceCode());
                WrapResponseCommonFrame<A7PlcQueryVersionRespInnerFrame> frame
                        = MainBoardInvokeSyncService.getInstance().sendRRPC(param.getDeviceCode(), a7Frame,  A7PlcQueryVersionRespInnerFrame.class);

                if (frame == null) {
                    map.put("status", DeviceRespStatusEnums.OTHER_ERROR.getCode());
                    resultList.add(map);
                    continue;
                }
                map.put("status", 0);
                map.put("hardwareVersion",frame.getResponseInnerFrame().getHardwareVersionDouble());
                map.put("softwareVersion",frame.getResponseInnerFrame().getSoftwareVersionDouble());

                resultList.add(map);
            } catch (BusinessException e) {
                map.put("status", DeviceRespStatusEnums.OTHER_ERROR.getCode());
                resultList.add(map);
            }
        }

        return resultList;

    }


    /**
     * PLC重启
     *
     * @return com.sandu.ximon.dao.enums.DeviceRespStatusEnums
     */
    public List<Map<String, Object>> reboot(List<PlcControlParam> paramList) {
        if (CollectionUtil.isEmpty(paramList)) {
            throw new BusinessException("参数不能为空");
        }

        List<Map<String, Object>> resultList = new ArrayList<>();
        for (PlcControlParam param : paramList) {
            A7PlcRebootReqInnerFrame plcControlFrame = new A7PlcRebootReqInnerFrame();
            A7Frame a7Frame = new A7Frame(A7OrderEnum.REQUEST_PLC_DATA.getCode(), plcControlFrame);
            Map<String, Object> map = new HashMap<>();
            try {
                map.put("deviceCode", param.getDeviceCode());
                WrapResponseCommonFrame<A7PlcBrightnessRespInnerFrame> frame
                        = MainBoardInvokeSyncService.getInstance().sendRRPC(param.getDeviceCode(), a7Frame, A7PlcBrightnessRespInnerFrame.class);
                //存储控制帧指令
                StoreOperationRecordsUtils.storeInnerFrameData(param.getDeviceCode(), "PLC帧-设置PLC重启", a7Frame, frame);

                if (frame == null) {
                    map.put("status", DeviceRespStatusEnums.OTHER_ERROR.getCode());
                    resultList.add(map);
                    continue;
                }
                String responseStatus = frame.getResponseInnerFrame().getResponseStatus();
                int status = HexUtil.hexToInt(responseStatus);
                map.put("status", status);
                resultList.add(map);
            } catch (BusinessException e) {
                map.put("status", DeviceRespStatusEnums.OTHER_ERROR.getCode());
                resultList.add(map);
            }
        }

        /**
         * 服务端批量控灯日志记录开始
         */
        String content = "{PLC重启：" + paramList.toString()
                + "， PLC重启：" + resultList.toString() + "}";
        List<String> codeList = new ArrayList<>();
        for (PlcControlParam bean : paramList) {
            codeList.add(bean.getDeviceCode());
        }
        StoreOperationRecordsUtils.storeOperationData(codeList, null, "PLC重启", content);
        /**
         * 服务端批量控灯日志记录结束
         */

        return resultList;

    }


    /**
     * PLC恢复出厂设置
     *
     * @return com.sandu.ximon.dao.enums.DeviceRespStatusEnums
     */
    public List<Map<String, Object>> reset(List<PlcControlParam> paramList) {
        if (CollectionUtil.isEmpty(paramList)) {
            throw new BusinessException("参数不能为空");
        }

        List<Map<String, Object>> resultList = new ArrayList<>();
        for (PlcControlParam param : paramList) {
            A7PlcResetReqInnerFrame plcControlFrame = new A7PlcResetReqInnerFrame();
            A7Frame a7Frame = new A7Frame(A7OrderEnum.REQUEST_PLC_DATA.getCode(), plcControlFrame);
            Map<String, Object> map = new HashMap<>();
            try {
                map.put("deviceCode", param.getDeviceCode());
                WrapResponseCommonFrame<A7PlcResetRespInnerFrame> frame
                        = MainBoardInvokeSyncService.getInstance().sendRRPC(param.getDeviceCode(), a7Frame, A7PlcResetRespInnerFrame.class);
                //存储控制帧指令
                StoreOperationRecordsUtils.storeInnerFrameData(param.getDeviceCode(), "PLC帧-设置PLC恢复出厂设置", a7Frame, frame);

                if (frame == null) {
                    map.put("status", DeviceRespStatusEnums.OTHER_ERROR.getCode());
                    resultList.add(map);
                    continue;
                }

                String responseStatus = frame.getResponseInnerFrame().getResponseStatus();
                int status = HexUtil.hexToInt(responseStatus);

                IRequestFrame iRequestFrame = FrameBuilder.builderA2().innerFrame(new EmptyRequestInnerFrame()).orderType(A2OrderEnum.REQUEST_MAIN_BOARD_RESET.getCode()).build();
                CommonFrame rebootFrame = MainBoardInvokeSyncService.getInstance().sendRRPC(param.getDeviceCode(), iRequestFrame);

                boolean b = false;

                if (!"00".equals(rebootFrame.getPayload())) {
                    map.put("status", DeviceRespStatusEnums.OTHER_ERROR.getCode());
                    resultList.add(map);
                    continue;
                }

                map.put("status", status);
                resultList.add(map);
            } catch (BusinessException e) {
                map.put("status", DeviceRespStatusEnums.OTHER_ERROR.getCode());
                resultList.add(map);
            }
        }

        /**
         * 服务端批量控灯日志记录开始
         */
        String content = "{PLC恢复出厂设置：" + paramList.toString()
                + "， PLC恢复出厂设置：" + resultList.toString() + "}";
        List<String> codeList = new ArrayList<>();
        for (PlcControlParam bean : paramList) {
            codeList.add(bean.getDeviceCode());
        }
        StoreOperationRecordsUtils.storeOperationData(codeList, null, "PLC恢复出厂设置", content);
        /**
         * 服务端批量控灯日志记录结束
         */

        return resultList;

    }


    /**
     * 获取用户所有的设备码
     */
    public CommonPage<String> listDeviceCode(int pageNo, int pageSize, String keyword, String deviceCode, String orderBy) {
        List<String> list;
        if (SecurityUtils.getClientId() != null) {
            PageHelper.startPage(pageNo, pageSize);
            list = baseMapper.listCode(SecurityUtils.getUserId(), keyword, deviceCode);
        } else {

            PageHelper.startPage(pageNo, pageSize, orderBy);
            list = baseMapper.listCode(null, keyword, deviceCode);
        }

        return CommonPage.restPage(list);
    }

    public void timeSynchronizationInitiative(String deviceCode, String destinationAddress) {
        Plc plc = getPlc(deviceCode);
        if (plc == null) {
            log.error("PLC主动同步时间请求异常，PLC信息不存在！");
            return;
        }
        SetCalendar(plc.getPlcId(), destinationAddress);

    }
    /**
     * 设置日历（同心跳包中的6字节日期时间）
     *
     * @return
     */
    public String SetCalendar(Long plcId, String address) {
        Calendar cal = Calendar.getInstance();
        //获取当前时间
        int year = cal.get(Calendar.YEAR);
        int month = cal.get(Calendar.MONTH);
        int day = cal.get(Calendar.DATE);
        int hour = cal.get(Calendar.HOUR_OF_DAY);
        int min = cal.get(Calendar.MINUTE);
        int sec = cal.get(Calendar.SECOND);


        Plc one = getById(plcId);
        if (one == null) {
            System.out.println("plc不存在！");
        }

        A7PlcSetCalendarReqInnerFrame setCalendarReqInnerFrame =
                new A7PlcSetCalendarReqInnerFrame(address, year % 100, month + 1, day, hour, min, sec);

        A7Frame a7Frame = new A7Frame(A5OrderEnum.REQUEST_LIGHT_DATA.getCode(), setCalendarReqInnerFrame);
        System.out.println(a7Frame + "            -----A7Frame");

        CommonFrame commonFrame;

        commonFrame = MainBoardInvokeSyncService.getInstance().sendRRPC(one.getDeviceCode(), a7Frame);
        StoreOperationRecordsUtils.storeInnerFrameData(one.getDeviceCode(), "PLC帧-设置日历", a7Frame, commonFrame);

        System.out.println(commonFrame + "            -----commonFrame");

        A7PlcOperationReportInnerFrame operationReportInnerFrame = new A7PlcOperationReportInnerFrame().transformFrame(commonFrame.getPayload());
        if (operationReportInnerFrame.isValidate()) {
            return operationReportInnerFrame.getState();
        } else {
            throw new BusinessException("数据校验错误，请重新请求");
        }
    }
}