package com.ruoyi.procurementrecord.controller;

import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
import com.ruoyi.framework.aspectj.lang.annotation.Log;
import com.ruoyi.framework.aspectj.lang.enums.BusinessType;
import com.ruoyi.framework.web.domain.AjaxResult;
import com.ruoyi.procurementrecord.dto.ProcurementPageDto;
import com.ruoyi.procurementrecord.service.CustomStorageWarningRecordService;
import io.swagger.annotations.Api;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.PostMapping;
import org.springframework.web.bind.annotation.RequestBody;
import java.util.Map;
import java.math.BigDecimal;
import java.time.LocalDateTime;
import com.ruoyi.procurementrecord.pojo.CustomStorageWarningRecord;
import com.ruoyi.procurementrecord.pojo.CustomStorage;
import com.ruoyi.procurementrecord.mapper.CustomStorageWarningRecordMapper;
import com.ruoyi.procurementrecord.mapper.CustomStorageMapper;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RestController;

@RequestMapping("/customStorageWarning")
@RestController
@Api(value = "仓储物流-库存预警")
public class CustomStorageWarningRecordController {

    @Autowired
    private CustomStorageWarningRecordService customStorageWarningRecordService;

    @Autowired
    private CustomStorageWarningRecordMapper warningRecordMapper;

    @Autowired
    private CustomStorageMapper customStorageMapper;

    @GetMapping("/pageList")
    @Log(title = "仓储物流-库存预警-分页查询", businessType = BusinessType.OTHER)
    public AjaxResult pageList(Page page, ProcurementPageDto dto){
        return AjaxResult.success(customStorageWarningRecordService.listPage(page,dto));
    }

    /**
     * 生成采购建议 / 滞销处理提示（并记录到预警事件）
     */
    @PostMapping("/generateSuggestion")
    @Log(title = "仓储物流-库存预警-生成建议", businessType = BusinessType.UPDATE)
    public AjaxResult generateSuggestion(@RequestBody Map<String, Object> body) {
        Object idObj = body.get("id");
        if (idObj == null) return AjaxResult.error("参数不能为空");
        String type = body.get("type") == null ? "采购建议" : body.get("type").toString();
        Long targetId = Long.valueOf(idObj.toString());
        CustomStorageWarningRecord record = warningRecordMapper.selectById(targetId);
        if (record == null) {
            com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper<CustomStorageWarningRecord> w =
                    new com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper<>();
            w.eq(CustomStorageWarningRecord::getCustomStorageId, targetId.intValue()).last("limit 1");
            record = warningRecordMapper.selectOne(w);
        }
        if (record == null) {
            record = new CustomStorageWarningRecord();
            record.setCustomStorageId(targetId.intValue());
            record.setWarningStatus("已预警");
            record.setWarningTime(LocalDateTime.now());
            try {
                record.setTenantId(com.ruoyi.common.utils.SecurityUtils.getLoginUser().getTenantId());
            } catch (Exception ignored) {
            }
            warningRecordMapper.insert(record);
        }
        CustomStorage storage = record.getCustomStorageId() == null ? null : customStorageMapper.selectById(record.getCustomStorageId());
        String product = storage == null ? "未知商品"
                : (storage.getProductCategory() == null ? "" : storage.getProductCategory())
                  + (storage.getSpecificationModel() == null ? "" : " " + storage.getSpecificationModel());
        BigDecimal current = (storage == null || storage.getInboundNum() == null) ? BigDecimal.ZERO : storage.getInboundNum();
        BigDecimal warn = storage == null ? null : storage.getWarnNum();
        String content;
        if (type.contains("采购")) {
            BigDecimal suggest = (warn == null ? BigDecimal.ZERO : warn).subtract(current);
            if (suggest.compareTo(BigDecimal.ZERO) <= 0) suggest = BigDecimal.valueOf(10);
            content = String.format("【采购建议】%s 当前库存 %s，最低库存阈值 %s，建议采购 %s（建议结合近30天消耗量补货）",
                    product, current.toPlainString(), warn == null ? "-" : warn.toPlainString(), suggest.toPlainString());
        } else {
            content = String.format("【滞销处理提示】%s 当前库存 %s，周转缓慢/库存偏高，建议：①促销或内部领用 ②转作其他用途 ③与供应商协商退换货",
                    product, current.toPlainString());
        }
        record.setSuggestionType(type);
        record.setSuggestionContent(content);
        record.setSuggestionTime(LocalDateTime.now());
        warningRecordMapper.updateById(record);
        return AjaxResult.success(content);
    }}