package com.netsdk.demo.customize;

import com.netsdk.demo.util.CaseMenu;
import com.netsdk.lib.NetSDKLib;
import com.netsdk.lib.ToolKits;
import com.netsdk.lib.structure.*;
import com.netsdk.lib.utils.Initialization;
import com.sun.jna.Memory;
import com.sun.jna.Pointer;

import java.io.UnsupportedEncodingException;

/**
 * @author 291189
 * @version 1.0
 * @description  流量统计
 * @date 2022/5/7 9:54
 */
public class FluxStatDemo extends Initialization {

    public  static  NetSDKLib.LLong lFindHandle=new NetSDKLib.LLong(0);
        public void  StartFindFluxStat(){
            NET_IN_TRAFFICSTARTFINDSTAT input=new NET_IN_TRAFFICSTARTFINDSTAT();

                NET_TIME stStartTime=new NET_TIME(2022,5,7,0,30,0);

               NET_TIME stEndTime=new NET_TIME(2022,5,7,11,12,0);

                    input.stStartTime=stStartTime;
                    input.stEndTime=stEndTime;
                    input.nWaittime=3000;
            NET_OUT_TRAFFICSTARTFINDSTAT  output=new NET_OUT_TRAFFICSTARTFINDSTAT();

            Pointer pointerInput = new Memory(input.size());
            pointerInput.clear(input.size());
            ToolKits.SetStructDataToPointer(input, pointerInput, 0);

            Pointer pointerOutput = new Memory(output.size());
            pointerOutput.clear(output.size());
            ToolKits.SetStructDataToPointer(output, pointerOutput, 0);


            lFindHandle  = netSdk.CLIENT_StartFindFluxStat(loginHandle, pointerInput, pointerOutput);
            if(lFindHandle.longValue()==0){
                System.out.printf("CLIENT_StartFindFluxStat Failed!LastError = %s\n",
                        ToolKits.getErrorCode());
            }else {
                System.out.println("CLIENT_StartFindFluxStat SUCCESS");
                ToolKits.GetPointerData(pointerOutput,output);
                int dwTotalCount
                        = output.dwTotalCount;
                System.out.println("dwTotalCount: "+dwTotalCount);
            }
        }
    //继续查询流量统计
        public void  DoFindFluxStat(){
            NET_IN_TRAFFICDOFINDSTAT inputTra=new NET_IN_TRAFFICDOFINDSTAT();
          //每次查询的流量统计条数
            inputTra.nCount=3;
            inputTra.nWaittime=3000;

            Pointer pointerInput = new Memory(inputTra.size());
            pointerInput.clear(inputTra.size());
            ToolKits.SetStructDataToPointer(inputTra, pointerInput, 0);


            NET_OUT_TRAFFICDOFINDSTAT outPutTra=new NET_OUT_TRAFFICDOFINDSTAT();

            Pointer pointerOutput = new Memory(outPutTra.size());
            pointerOutput.clear(outPutTra.size());
            ToolKits.SetStructDataToPointer(outPutTra, pointerOutput, 0);

            int isOk
                    = netSdk.CLIENT_DoFindFluxStat(lFindHandle, pointerInput, pointerOutput);
            if(isOk!=1){
                System.out.printf("CLIENT_DoFindFluxStat Failed!LastError = %s\n",
                        ToolKits.getErrorCode());
            }else {
                System.out.println("CLIENT_DoFindFluxStat SUCCESS");
                ToolKits.GetPointerData(pointerOutput,outPutTra);

                DH_TRAFFICFLOWSTAT_OUT stStatInfo
                        = outPutTra.stStatInfo;

                int nStatInfo
                        = stStatInfo.nStatInfo;

                Pointer pStatInfo
                        = stStatInfo.pStatInfo;

                System.out.println("nStatInfo:"+nStatInfo);
                          for(int i=0;i<nStatInfo;i++){
                              DH_TRAFFICFLOWSTAT  dhTrafficflowstats=new DH_TRAFFICFLOWSTAT();
                              ToolKits.GetPointerDataToStruct(pStatInfo,i*dhTrafficflowstats.size(),dhTrafficflowstats);
                              byte[] szMachineName
                                      = dhTrafficflowstats.szMachineName;
                              byte[] szMachineAddress
                                      = dhTrafficflowstats.szMachineAddress;
                              byte[] szDrivingDirection
                                      = dhTrafficflowstats.szDrivingDirection;
                              try {
                                  System.out.println("szMachineName utf-8:"+new String(szMachineName,"utf-8"));
                                  System.out.println("szMachineName gbk:"+new String(szMachineName,"gbk"));

                                  System.out.println("szMachineAddress utf-8:"+new String(szMachineAddress,"utf-8"));
                                  System.out.println("szMachineAddress gbk:"+new String(szMachineAddress,"gbk"));

                                  System.out.println("szDrivingDirection utf-8:"+new String(szDrivingDirection,"utf-8"));
                                  System.out.println("szDrivingDirection gbk:"+new String(szDrivingDirection,"gbk"));

                              } catch (UnsupportedEncodingException e) {
                                  e.printStackTrace();
                              }

                              System.out.println("UTC:"+dhTrafficflowstats.UTC);


                          }
            }

        }
                    public void StopFindFluxStat(){
                        boolean b
                                = netSdk.CLIENT_StopFindFluxStat(lFindHandle);
                        if(b){
                            System.out.println("CLIENT_StopFindFluxStat SUCCESS");
                        }else {
                            System.out.printf("CLIENT_StopFindFluxStat Failed!LastError = %s\n",
                                    ToolKits.getErrorCode());
                        }
                    }

    public void RunTest()
    {
        System.out.println("Run Test");
        CaseMenu menu = new CaseMenu();;
        menu.addItem((new CaseMenu.Item(this , "StartFindFluxStat" , "StartFindFluxStat")));
        menu.addItem((new CaseMenu.Item(this , "DoFindFluxStat" , "DoFindFluxStat")));
        menu.addItem((new CaseMenu.Item(this , "StopFindFluxStat" , "StopFindFluxStat")));

        menu.run();
    }

    public static void main(String[] args) {
        FluxStatDemo fluxStatDemo=new FluxStatDemo();
        InitTest("172.24.2.171",37777,"admin","admin123");
        fluxStatDemo.RunTest();
        LoginOut();

    }

}