package com.zy.asrs.controller;

import com.alibaba.fastjson.JSON;
import com.baomidou.mybatisplus.mapper.EntityWrapper;
import com.core.common.Cools;
import com.core.common.R;
import com.zy.asrs.entity.BasStationTv;
import com.zy.asrs.entity.TvDevice;

import com.zy.asrs.entity.dto.TvDataDto;
import com.zy.asrs.entity.dto.TvLocDataDto;
import com.zy.asrs.entity.dto.WcsStationDto;
import com.zy.asrs.enums.RedisKeyType;
import com.zy.asrs.service.BasStationTvService;
import com.zy.asrs.service.TvDeviceService;
import com.zy.asrs.utils.StationUtils;
import com.zy.asrs.utils.Utils;
import com.zy.common.utils.RedisUtil;
import lombok.extern.slf4j.Slf4j;
import org.apache.poi.ss.usermodel.charts.LineChartData;
import org.springframework.beans.factory.annotation.Value;
import org.springframework.web.bind.annotation.*;
import org.springframework.beans.factory.annotation.Autowired;

import javax.servlet.http.HttpServletRequest;

import java.util.*;

@Slf4j
@RestController
@RequestMapping("/openapi")
public class OpenController {

    private static final String[] WEEK = {"星期日","星期一","星期二","星期三","星期四","星期五","星期六"};

    @Autowired
    private TvDeviceService tvDeviceService;
    @Autowired
    private BasStationTvService basStationTvService;
    @Autowired
    private StationUtils stationUtils;
    @Autowired
    private RedisUtil redisUtil;

    @Value("${app.version:1.0.0}")
    private String appVersion;
    @Value("${app.version-type:stable}")
    private String appVersionType;

    @GetMapping("/systemStatus")
    public R systemStatus() {
        return R.ok();
    }

    @GetMapping("/getSystemVersion")
    public R getSystemVersion() {
        HashMap<String, Object> map = new HashMap<>();
        map.put("version", appVersion);
        map.put("versionType", appVersionType);
        return R.ok().add(map);
    }

    @GetMapping("/getLedInfos")
    public R getLedInfos(HttpServletRequest request) {
        String remoteAddr = request.getRemoteAddr();
        TvDevice tvDevice = tvDeviceService.selectOne(
                new EntityWrapper<TvDevice>().eq("ip", remoteAddr));
        if (tvDevice == null) {
            return R.error("未找到IP对应的电视机设备: " + remoteAddr);
        }

        List<BasStationTv> relations = basStationTvService
                .selectList(new EntityWrapper<BasStationTv>().eq("tv_id", tvDevice.getId()));
        if (relations == null || relations.isEmpty()) {
            R r = R.ok();
            r.put("data", new ArrayList<>());
            return r;
        }


        List<TvDataDto> list = new ArrayList<>();
        for (BasStationTv relation : relations) {
            WcsStationDto wcsStationDto = stationUtils.stationMap.get(relation.getStationId());

            if (wcsStationDto == null) {
                continue;
            }

            if (wcsStationDto.getLoading() != 1) {
                continue;
            }

            String errorMsg = "";
            if (!Cools.isEmpty(wcsStationDto.getErrorMsg())) {
                errorMsg +=  wcsStationDto.getErrorMsg();
            }

            if (!Cools.isEmpty(wcsStationDto.getSystemWarning())) {
                errorMsg +=  wcsStationDto.getSystemWarning();
            }

            TvDataDto tvDataDto = new TvDataDto();
            tvDataDto.setStationId(wcsStationDto.getStationId());
            tvDataDto.setTaskNo(wcsStationDto.getTaskNo());
            tvDataDto.setBarcode(wcsStationDto.getBarcode());
            tvDataDto.setErrorMsg(errorMsg);
            tvDataDto.setIoType(wcsStationDto.getIoType());
            tvDataDto.setWrkDetls(wcsStationDto.getWrkDetls());

            if (Cools.isEmpty(errorMsg)) {
                tvDataDto.setErrorCode(0);
            }else {
                tvDataDto.setErrorCode(1);
            }

            list.add(tvDataDto);
        }

        return R.ok().add(list);
    }

    /**
     * 获取当前时间
     */
    @GetMapping("/monitor/date")
    public R monitorDate() {
        Date now = new Date();
        Calendar calendar = Calendar.getInstance();
        calendar.setTime(now);
        return R.ok(
                Cools.add("year", calendar.get(Calendar.YEAR))
                        .add("month", Utils.zerofill(String.valueOf(calendar.get(Calendar.MONTH)+1), 2))
                        .add("day", Utils.zerofill(String.valueOf(calendar.get(Calendar.DATE)), 2))
                        .add("hour", Utils.zerofill(String.valueOf(calendar.get(Calendar.HOUR_OF_DAY)), 2))
                        .add("minute", Utils.zerofill(String.valueOf(calendar.get(Calendar.MINUTE)), 2))
                        .add("second", Utils.zerofill(String.valueOf(calendar.get(Calendar.SECOND)) , 2))
                        .add("week", WEEK[calendar.get(Calendar.DAY_OF_WEEK)-1])
        );
    }

    /**
     * 获取库位数据
     */
    @GetMapping("/queryLoc")
    public R queryLoc() {
        TvLocDataDto tvLocDataDto = new TvLocDataDto();
        Object o = redisUtil.get(RedisKeyType.TV_LOC_DATA_DTO.key);
        if(o == null){
            return R.ok().add(tvLocDataDto);
        }

        tvLocDataDto = JSON.parseObject(o.toString(), TvLocDataDto.class);
        return R.ok().add(tvLocDataDto);
    }

    /**
     * WMS入出库折线图
     */
    @GetMapping("/inOutLineCharts")
    public R inOutLineCharts() {
        Object o = redisUtil.get(RedisKeyType.TV_LINE_CHARTS.key);
        if(o == null){
            return R.error();
        }

        return R.ok().add(JSON.parseObject(o.toString()));
    }

    /**
     * WMS库存数据统计
     */
    @GetMapping("/locDetlStatistics")
    public R locDetlStatistics() {
        Object o = redisUtil.get(RedisKeyType.TV_LOC_DETL_STATISTICS.key);
        if(o == null){
            return R.error();
        }

        return R.ok().add(JSON.parseArray(o.toString()));
    }

}