package org.yzh.web.controller;

import io.swagger.v3.oas.annotations.Operation;
import lombok.RequiredArgsConstructor;
import org.springframework.web.bind.annotation.*;
import org.yzh.commons.model.R;
import org.yzh.commons.util.BytesUtils;
import org.yzh.protocol.t808.T0001;
import org.yzh.protocol.t808.T8900;
import org.yzh.protocol.t808.T8900Lock.*;
import org.yzh.web.endpoint.MessageManager;
import reactor.core.publisher.Mono;

import java.util.Calendar;
import java.util.Date;

@RestController
@RequestMapping("device")
@RequiredArgsConstructor
public class JT8900LockController {
    private final MessageManager messageManager;

    /**
     * 控制蝶阀锁状态 2025-05-26 zwy
     * @param clientId 终端ID
     * @param lockId 锁ID
     * @param status 锁状态(1:开, 2:关)
     * @return 操作结果
     */
    @Operation(summary = "控制蝶阀锁状态")
    @PostMapping("/control")
    public Mono<R<T0001>> controlValveLock(
            @RequestParam String clientId,
            @RequestParam String lockId,
            @RequestParam int status) {

        // 构建蝶阀锁控制消息
        ValveLockProtocol valveLockProtocol=new ValveLockProtocol();
        valveLockProtocol.setLockId(BytesUtils.hex2bytes(lockId));
        valveLockProtocol.setStatus((byte)status);
        valveLockProtocol.calculateChecksum();

        T8900 request = new T8900();
        request.setClientId(clientId);
        request.setValveLockProtocol(valveLockProtocol);

        // 发送消息并获取响应
        return messageManager.requestR(request.build(), T0001.class);
    }

    @Operation(summary = "读取电子锁当前状态")
    @PostMapping("query-status")
    public Mono<R<T0001>> queryLockStatus(
            @RequestParam String clientId, // 终端手机号String
            @RequestParam String lockId // 蝶阀锁ID（如0xaaaa）
    ) {
        T8900State t8900State = new T8900State(lockId);
        T8900 t8900 = new T8900();
        t8900.setClientId(clientId);
        t8900.setT8900State(t8900State);
        // 发送消息并指定响应类为T8900Response
        //T8900Response response = messageManager.request(clientId, t8900, T8900Response.class).block();

        //return response.parseStatus(); // 解析响应结果
        return messageManager.requestR(t8900.build(), T0001.class);

//        messageManager.request(clientId, request, T8900Response.class)
//                .map(T8900Response::get)
    }

    // 触发设备号读取
    @Operation(summary = "读取设备号")
    @GetMapping("/read-device-id")
    public Mono<R<T0001>> readDeviceId(@RequestParam String clientId) {
        T8900ReadDeviceID readDeviceID = new T8900ReadDeviceID();
        readDeviceID.setChecksum(readDeviceID.calculateChecksum());
        T8900 t8900 = new T8900();
        t8900.setClientId(clientId);
        t8900.setReadDeviceID(readDeviceID);

        return messageManager.requestR(t8900.build(), T0001.class);
    }

    @Operation(summary = "设置设备号")
    @PostMapping("/set-device-Id")
    public Mono<R<T0001>> setDeviceId(
            @RequestParam String clientId,
            @RequestParam String lockId,
            @RequestParam String newlockId
    ){
        T8900SetDeviceID setDeviceID = new T8900SetDeviceID();
        setDeviceID.setLockId(BytesUtils.hex2bytes(lockId));
        setDeviceID.setNewlockId(BytesUtils.hex2bytes(newlockId));
        T8900 t8900 = new T8900();
        t8900.setClientId(clientId);
        t8900.setSetDeviceID(setDeviceID);

        return messageManager.requestR(t8900.build(), T0001.class);
    }

    // 触发读所有信息
    @Operation(summary = "读所有信息")
    @PostMapping("/read-device-all")
    public Mono<R<T0001>> readAllInformation(
            @RequestParam String clientId,
            @RequestParam String lockId
    ) {
        T8900ReadAllInformation readAllInformation = new T8900ReadAllInformation();
        readAllInformation.setLockId(BytesUtils.hex2bytes(lockId));
        Date currentDate = new Date();
        Calendar calendar = Calendar.getInstance();
        calendar.setTime(currentDate);
        readAllInformation.setYear((byte) calendar.get(Calendar.YEAR));
        readAllInformation.setMonth((byte) calendar.get(Calendar.MONTH));
        readAllInformation.setDay((byte) calendar.get(Calendar.DAY_OF_MONTH));
        readAllInformation.setHour((byte) calendar.get(Calendar.HOUR_OF_DAY));
        readAllInformation.setMinute((byte) calendar.get(Calendar.MINUTE));
        readAllInformation.setSecond((byte) calendar.get(Calendar.SECOND));
        T8900 t8900 = new T8900();
        t8900.setClientId(clientId);
        t8900.setReadAllInformation(readAllInformation);

        return messageManager.requestR(t8900.build(), T0001.class);
    }

    @Operation(summary = "设置蝶阀锁离线开锁密码")
    @PostMapping("/setPassword")
    public Mono<R<T0001>> setPassword(
            @RequestParam String clientId,
            @RequestParam String lockId,
            @RequestParam String password
    ){
        T8900SetPassword setPassword = new T8900SetPassword();
        setPassword.setLockId(BytesUtils.hex2bytes(lockId));
        String[] pwd = password.split(",");
        if(pwd.length != 10){
            System.out.println("密码必须为10组，每组六位！");
            return null;
        }
        setPassword.setPassword1(BytesUtils.hex2bytes(pwd[0]));
        setPassword.setPassword2(BytesUtils.hex2bytes(pwd[1]));
        setPassword.setPassword3(BytesUtils.hex2bytes(pwd[2]));
        setPassword.setPassword4(BytesUtils.hex2bytes(pwd[3]));
        setPassword.setPassword5(BytesUtils.hex2bytes(pwd[4]));
        setPassword.setPassword6(BytesUtils.hex2bytes(pwd[5]));
        setPassword.setPassword7(BytesUtils.hex2bytes(pwd[6]));
        setPassword.setPassword8(BytesUtils.hex2bytes(pwd[7]));
        setPassword.setPassword9(BytesUtils.hex2bytes(pwd[8]));
        setPassword.setPassword10(BytesUtils.hex2bytes(pwd[9]));

        T8900 t8900 = new T8900();
        t8900.setClientId(clientId);
        t8900.setSetPassword(setPassword);
        return messageManager.requestR(t8900.build(), T0001.class);
    }
}