package com.zy.asrs.controller;

import com.alibaba.fastjson.JSONObject;
import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
import com.core.annotations.ManagerAuth;
import com.core.common.BaseRes;
import com.core.common.Cools;
import com.core.common.R;
import com.zy.asrs.entity.BasCrnp;
import com.zy.asrs.entity.dto.BasCrnpMonitorDto;
import com.zy.asrs.entity.dto.WcsCrnDto;
import com.zy.asrs.entity.dto.WcsCrnSyncResult;
import com.zy.asrs.service.BasCrnpService;
import com.zy.asrs.service.WcsCrnSyncService;
import com.zy.asrs.utils.CrnUtils;
import com.zy.common.web.BaseController;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.web.bind.annotation.PathVariable;
import org.springframework.web.bind.annotation.RequestBody;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RequestMethod;
import org.springframework.web.bind.annotation.RequestParam;
import org.springframework.web.bind.annotation.RestController;

import java.util.ArrayList;
import java.util.Arrays;
import java.util.Date;
import java.util.HashMap;
import java.util.List;
import java.util.Map;

@RestController
public class BasCrnpController extends BaseController {

    @Autowired
    private BasCrnpService basCrnpService;

    @Autowired
    private WcsCrnSyncService wcsCrnSyncService;

    @Autowired
    private CrnUtils crnUtils;

    @RequestMapping(value = "/basCrnp/{id}/auth")
    @ManagerAuth
    public R get(@PathVariable("id") Integer id) {
        return R.ok(basCrnpService.getById(id));
    }

    @RequestMapping(value = "/basCrnp/list/auth")
    @ManagerAuth
    public R list(@RequestParam(defaultValue = "1") Integer curr,
                  @RequestParam(defaultValue = "10") Integer limit,
                  @RequestParam(required = false) Integer crnNo,
                  @RequestParam(required = false) String condition) {
        QueryWrapper<BasCrnp> wrapper = new QueryWrapper<>();
        if (crnNo != null) {
            wrapper.eq("crn_no", crnNo);
        }
        if (!Cools.isEmpty(condition)) {
            wrapper.and(inner -> inner.like("crn_no", condition).or().like("memo", condition));
        }
        wrapper.orderBy(true, true, "crn_no");

        Page<BasCrnp> page = basCrnpService.page(new Page<>(curr, limit), wrapper);
        List<BasCrnpMonitorDto> records = new ArrayList<>();
        for (BasCrnp basCrnp : page.getRecords()) {
            records.add(toMonitorDto(basCrnp));
        }

        Map<String, Object> data = new HashMap<>();
        data.put("total", page.getTotal());
        data.put("records", records);
        data.put("lastSyncTime", crnUtils.getLastSyncTime());
        data.put("syncError", crnUtils.getLastSyncError());
        return R.ok(data);
    }

    @RequestMapping(value = "/basCrnp/add/auth", method = RequestMethod.POST)
    @ManagerAuth
    public R add(BasCrnp basCrnp) {
        if (basCrnp == null || basCrnp.getCrnNo() == null) {
            return R.error("堆垛机编号不能为空");
        }
        if (basCrnpService.count(new QueryWrapper<BasCrnp>().eq("crn_no", basCrnp.getCrnNo())) > 0) {
            return R.parse(BaseRes.REPEAT).add("堆垛机编号");
        }
        Date now = new Date();
        basCrnp.setStatus(basCrnp.getStatus() == null ? 1 : basCrnp.getStatus());
        basCrnp.setCreateBy(getUserId());
        basCrnp.setCreateTime(now);
        basCrnp.setUpdateBy(getUserId());
        basCrnp.setUpdateTime(now);
        basCrnpService.save(basCrnp);
        return R.ok();
    }

    @RequestMapping(value = "/basCrnp/update/auth", method = RequestMethod.POST)
    @ManagerAuth
    public R update(BasCrnp basCrnp) {
        if (basCrnp == null || basCrnp.getCrnNo() == null) {
            return R.error("堆垛机编号不能为空");
        }
        BasCrnp old = basCrnpService.getById(basCrnp.getCrnNo());
        if (old == null) {
            return R.error("堆垛机配置不存在");
        }
        old.setStatus(basCrnp.getStatus() == null ? old.getStatus() : basCrnp.getStatus());
        old.setMemo(basCrnp.getMemo());
        old.setUpdateBy(getUserId());
        old.setUpdateTime(new Date());
        basCrnpService.updateById(old);
        return R.ok();
    }

    @RequestMapping(value = "/basCrnp/delete/auth", method = RequestMethod.POST)
    @ManagerAuth
    public R delete(@RequestParam(value = "ids[]") Integer[] ids) {
        if (ids == null || ids.length == 0) {
            return R.error("请选择要删除的数据");
        }
        basCrnpService.removeByIds(Arrays.asList(ids));
        for (Integer id : ids) {
            crnUtils.crnMap.remove(id);
        }
        return R.ok();
    }

    @RequestMapping(value = "/basCrnp/check/column/auth", method = RequestMethod.POST)
    @ManagerAuth
    public R checkColumn(@RequestBody JSONObject param) {
        String key = param == null ? null : param.getString("key");
        Object val = param == null ? null : param.get("val");
        if (!"crnNo".equals(key) || Cools.isEmpty(val)) {
            return R.ok();
        }
        BasCrnp basCrnp = basCrnpService.getOne(new QueryWrapper<BasCrnp>().eq("crn_no", val));
        if (basCrnp != null) {
            return R.parse(BaseRes.REPEAT).add(getComment(BasCrnp.class, key));
        }
        return R.ok();
    }

    @RequestMapping(value = "/basCrnp/refresh/auth", method = RequestMethod.POST)
    @ManagerAuth
    public R refresh() {
        WcsCrnSyncResult result = wcsCrnSyncService.sync();
        if (!result.isSuccess()) {
            return R.error(result.getMessage());
        }
        return R.ok(result);
    }

    private BasCrnpMonitorDto toMonitorDto(BasCrnp basCrnp) {
        BasCrnpMonitorDto dto = new BasCrnpMonitorDto();
        dto.setCrnNo(basCrnp.getCrnNo());
        dto.setLocalStatus(basCrnp.getStatus());
        dto.setLocalStatusDesc(basCrnp.getStatus$());
        dto.setMemo(basCrnp.getMemo());

        WcsCrnDto runtime = crnUtils.crnMap.get(basCrnp.getCrnNo());
        if (runtime == null) {
            dto.setOnline(0);
            dto.setOnlineDesc("离线");
            dto.setMode(null);
            dto.setModeDesc("离线");
            dto.setDeviceStatus(null);
            dto.setDeviceStatusDesc("离线");
            dto.setTaskNo(null);
            dto.setAlarm(null);
            dto.setLastSyncTime(crnUtils.getLastSyncTime());
            dto.setSyncError(crnUtils.getLastSyncError());
            return dto;
        }

        dto.setOnline(runtime.getOnline());
        dto.setOnlineDesc(runtime.getOnline() != null && runtime.getOnline() == 1 ? "在线" : "离线");
        dto.setMode(runtime.getMode());
        dto.setModeDesc(runtime.getModeDesc());
        dto.setDeviceStatus(runtime.getStatus());
        dto.setDeviceStatusDesc(runtime.getStatusDesc());
        dto.setTaskNo(runtime.getTaskNo());
        dto.setAlarm(runtime.getAlarm());
        dto.setLastSyncTime(runtime.getLastSyncTime());
        dto.setSyncError(runtime.getSyncError());
        return dto;
    }
}