package com.ruoyi.web.controller.system;

import com.ruoyi.common.core.controller.BaseController;
import com.ruoyi.common.core.domain.AjaxResult;
import com.ruoyi.common.core.redis.RedisCache;
import com.ruoyi.common.utils.netty.ChannelHandlerContextCache;
import com.ruoyi.common.utils.netty.ConcurrentHashMapBean;
import com.ruoyi.common.utils.netty.NettyTool;
import com.ruoyi.common.utils.netty.connectToClient;
import com.ruoyi.system.domain.dto.NettyCommandDTO;
import io.swagger.annotations.Api;
import io.swagger.annotations.ApiImplicitParam;
import io.swagger.annotations.ApiImplicitParams;
import lombok.extern.slf4j.Slf4j;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.security.access.prepost.PreAuthorize;
import org.springframework.web.bind.annotation.*;
import org.springframework.web.multipart.MultipartFile;

import java.util.ArrayList;
import java.util.List;
import java.util.Map;

/**
 * 命令 执行
 *
 * @author ruoyi
 * @date 2022-10-11
 */
@Slf4j
@Api("远程升级")
@RestController
@RequestMapping("/system/command")
public class NettyCommandController extends BaseController
{

    @Autowired
    private RedisCache redisCache;

    /**
     * 查询升级内容详情列表
     */
    @PreAuthorize("@ss.hasPermi('system:content:list')")
    @PostMapping("perform")
    public AjaxResult list(@RequestBody  NettyCommandDTO nettyCommandDTO)
    {
        //解析文件
        Integer type=nettyCommandDTO.getType();
        switch (type){
            case 15:
                if (nettyCommandDTO.getUpgrade()==1){
                    for (String stcd:nettyCommandDTO.getStcdList()){
                        stcd=NettyTool.stcdHex2bcd(stcd);
                        String updatefileStrCRC = ChannelHandlerContextCache.UpgradeFileString;
                        //高位在前
                        updatefileStrCRC=updatefileStrCRC.substring(0,updatefileStrCRC.length()-1);
                        String RS232number2f = NettyTool.getCRChigh(updatefileStrCRC);
                        log.info("---------------CRC16校验----------"+RS232number2f+"--------------");
                        //块数量 两个字节向前补位
                        String Numberofblocks = NettyTool.addZeroForNum(NettyTool.Numberofblocks(ChannelHandlerContextCache.cache).toString(), 4);
                        String crc = NettyTool.getCRChigh("AA000E0000000001" + Numberofblocks + RS232number2f);
                        log.info("数据包：【" + "AA000E0000000001" + Numberofblocks + RS232number2f + crc + "】" + " 块数量：【" + Numberofblocks + "】" + " 文件校验码：【" + RS232number2f + "】" + " CRC16校验：【" + crc + "】");
                        String data  = "AA000E0000000001" + Numberofblocks + RS232number2f + crc;
                        connectToClient.write2Client(data, ConcurrentHashMapBean.channelMap.get(stcd),"下载文件信息01");
                    }
                    //发送升级文件信息
                    return AjaxResult.success("执行成功");
                }
                break;
            default:
                throw new IllegalStateException("Unexpected value: " + type);
        }

        return AjaxResult.success("执行成功");
    }


    @PreAuthorize("@ss.hasPermi('system:content:list')")
    @PostMapping("/importData")
    @ApiImplicitParams({
            @ApiImplicitParam(name = "file", value = "文件", dataType = "MultipartFile", dataTypeClass = MultipartFile.class)
    })
    public AjaxResult importData(MultipartFile file) throws Exception
    {
        String fileName= file.getOriginalFilename();
        //判定是否重复数据
//        if (redisCache.getCacheList("fileName").contains(fileName)){
//            return AjaxResult.success("升级文件重复请重新升级");
//        }
        //解析数据
         String data1 =NettyTool.readCityFile(file);
         List<String> kuai1List=new ArrayList<>();
         //
        List<Integer> indexs=NettyTool.getIndexs(data1,"@");
        for (Integer index:indexs){
            String  kuai = data1.substring(index,data1.length());
            String[] strings = kuai.split(" ");
            kuai1List.add(strings[0].substring(0,strings[0].length()-2));
        }

        String UpgradeFileString = NettyTool.readCityFile(file).replace(" ", "");
        //读取文件信息 储存到 redis中
        log.info("---------------------读取文件成功，字符串解析成功-------------------------------");
        //开始分包数 将@后的存到map 里面 将其分包
//        ChannelHandlerContextCache.fileStr = NettyTool.xiabiao(UpgradeFileString);
        Map<String, String>  fileStr_new = NettyTool.xiabiao_new(UpgradeFileString, kuai1List);
        ChannelHandlerContextCache.fileStr = fileStr_new;
//        ChannelHandlerContextCache.cache=NettyTool.cachepage(ChannelHandlerContextCache.fileStr);
        Map<String, List<String>> cache_new = NettyTool.cachepage(fileStr_new);
        ChannelHandlerContextCache.cache = cache_new;
        //将字数不够的补齐
        for (List<String> value :  ChannelHandlerContextCache.cache.values()) {
            String a = NettyTool.addstrfFForNum(value.get(value.size() - 1), 1024);
            value.set(value.size() - 1, a);
        }

        ChannelHandlerContextCache.keys=ChannelHandlerContextCache.cache.keySet().toArray();
        //计算包数 开始逐步发送
        int pagenumber=NettyTool.Calculatepagenumber(ChannelHandlerContextCache.cache);
        /*log.info("-----------------包数一共为 "+pagenumber+"--------------------------------");*/
        /*   开始原始文件 进行校验  替换 @为 40000*/
//        String updatefileStr = UpgradeFileString.replaceAll("@", "4000");
        String updatefileStr_new=NettyTool.replace(UpgradeFileString,kuai1List);
        ChannelHandlerContextCache.UpgradeFileString=updatefileStr_new;
        String updatefileStrCRC = updatefileStr_new.replaceAll("q","");
        //高位在前
        String RS232number2f = NettyTool.getCRChigh(updatefileStrCRC);
        log.info("---------------CRC16校验----------"+RS232number2f+"--------------");
        //块数量 两个字节向前补位
        String Numberofblocks = NettyTool.addZeroForNum(NettyTool.Numberofblocks(ChannelHandlerContextCache.cache).toString(), 4);
        String crc = NettyTool.getCRChigh("AA000E0000000001" + Numberofblocks + RS232number2f);
        log.info("数据包：【" + "AA000E0000000001" + Numberofblocks + RS232number2f + crc + "】" + " 块数量：【" + Numberofblocks + "】" + " 文件校验码：【" + RS232number2f + "】" + " CRC16校验：【" + crc + "】");
        String data  = "AA000E0000000001" + Numberofblocks + RS232number2f + crc;
//        connectToClient.write2Client(data, ConcurrentHashMapBean.channelMap.get("166400"),"下载文件信息01");
         //发送升级文件信息
        List<String> fileNameList=redisCache.getCacheList(fileName);
        fileNameList.add(fileName);
        redisCache.setCacheList("fileName",fileNameList);
        //ChannelHandlerContextCache.fileStr
        redisCache.setCacheMap(fileName+"fileStr",ChannelHandlerContextCache.fileStr);
        //ChannelHandlerContextCache.cache
        redisCache.setCacheMap(fileName+"cache",ChannelHandlerContextCache.cache);
        //ChannelHandlerContextCache.keys
        redisCache.setCacheObject(fileName+"keys",ChannelHandlerContextCache.keys);
        //ChannelHandlerContextCache.UpgradeFileString
        redisCache.setCacheObject(fileName+"UpgradeFileString",ChannelHandlerContextCache.UpgradeFileString);
        return AjaxResult.success("执行成功");
    }





}