package com.zy.asrs.controller;

import com.baomidou.mybatisplus.annotations.TableField;
import com.baomidou.mybatisplus.mapper.EntityWrapper;
import com.baomidou.mybatisplus.plugins.Page;
import com.core.common.Cools;
import com.core.common.R;
import com.core.annotations.ManagerAuth;
import com.zy.asrs.entity.MaterialReceive;
import com.zy.asrs.service.MaterialReceiveService;
import com.zy.common.web.BaseController;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.web.bind.annotation.*;
import com.core.common.DateUtils;
import java.lang.reflect.Field;
import java.math.BigDecimal;
import java.util.ArrayList;
import java.util.Date;
import java.util.HashMap;
import java.util.List;
import java.util.Map;

@RestController
public class MaterialReceiveController extends BaseController {

    @Autowired
    private MaterialReceiveService materialReceiveService;

    @RequestMapping(value = "/materialReceive/{id}/auth")
    @ManagerAuth
    public R get(@PathVariable("id") String id) {
        return R.ok(materialReceiveService.selectById(String.valueOf(id)));
    }

    @RequestMapping(value = "/materialReceive/list/auth")
    @ManagerAuth
    public R list(@RequestParam(defaultValue = "1") Integer curr,
                  @RequestParam(defaultValue = "1000") Integer limit,
                  @RequestParam(required = false) String orderByField,
                  @RequestParam(required = false) String orderByType,
                  @RequestParam(required = false) String condition,
                  @RequestParam(required = false) Boolean pdaQuery,
                  @RequestParam Map<String, Object> param) {
        EntityWrapper<MaterialReceive> wrapper = new EntityWrapper<>();
        excludeTrash(param);
        // 移除pdaQuery参数，因为它不是数据库字段，只是控制参数
        param.remove("pdaQuery");
        convert(param, wrapper);
        allLike(MaterialReceive.class, param.keySet(), wrapper, condition);
        
        // 参考其他出库模块，PDA出库查询时过滤掉已全部出库的物料（只显示还有剩余数量的）
        // 通过 pdaQuery 参数判断是否是PDA出库查询
        if (pdaQuery != null && pdaQuery) {
            // PDA出库查询：只显示剩余数量大于0的记录
            wrapper.gt("remain_qty", 0);
        }
        
        if (!Cools.isEmpty(orderByField)) {
            wrapper.orderBy(humpToLine(orderByField), "asc".equals(orderByType));
        }
        return R.ok(materialReceiveService.selectPage(new Page<>(curr, limit), wrapper));
    }

    @RequestMapping(value = "/materialReceive/batchSave/auth", method = RequestMethod.POST)
    @ManagerAuth
    public R batchSave(@RequestBody List<Map<String, Object>> dataList) {
        if (Cools.isEmpty(dataList)) {
            return R.error("数据不能为空");
        }
        int successCount = 0;
        int updateCount = 0;
        for (Map<String, Object> data : dataList) {
            try {
                // 检查是否已存在（根据soCode和invCode和finterid唯一标识）
                String soCode = data.get("soCode") != null ? String.valueOf(data.get("soCode")) : null;
                String invCode = data.get("invCode") != null ? String.valueOf(data.get("invCode")) : null;
                Integer finterid = null;
                if (data.get("finterid") != null) {
                    try {
                        finterid = Integer.valueOf(String.valueOf(data.get("finterid")));
                    } catch (Exception e) {
                        // 忽略转换错误
                    }
                }

                MaterialReceive existRecord = null;
                if (soCode != null && invCode != null && finterid != null) {
                    existRecord = materialReceiveService.selectOne(new EntityWrapper<MaterialReceive>()
                            .eq("so_code", soCode)
                            .eq("inv_code", invCode)
                            .eq("finterid", finterid));
                }

                MaterialReceive materialReceive;
                if (existRecord != null) {
                    // 已存在，更新数据（不覆盖出库相关字段）
                    materialReceive = existRecord;
                    updateCount++;
                } else {
                    // 不存在，创建新记录
                    materialReceive = new MaterialReceive();
                    materialReceive.setCreateTime(new Date());
                    // 初始化出库相关字段
                    materialReceive.setOutQty(BigDecimal.ZERO);
                    materialReceive.setRemainQty(data.get("qty") != null ? 
                        new BigDecimal(String.valueOf(data.get("qty"))) : BigDecimal.ZERO);
                    materialReceive.setIsAllOut(0);
                    successCount++;
                }

                // 更新/设置字段
                materialReceive.setSoCode(soCode);
                materialReceive.setFbillno(data.get("fbillno") != null ? String.valueOf(data.get("fbillno")) : null);
                materialReceive.setInvCode(invCode);
                materialReceive.setInvName(data.get("invName") != null ? String.valueOf(data.get("invName")) : null);
                materialReceive.setInvStd(data.get("invStd") != null ? String.valueOf(data.get("invStd")) : null);
                
                // 数量字段处理（优先使用fqty，如果没有则使用qty）
                BigDecimal qty = null;
                if (data.get("fqty") != null) {
                    qty = new BigDecimal(String.valueOf(data.get("fqty")));
                    materialReceive.setFqty(qty);
                } else if (data.get("qty") != null) {
                    qty = new BigDecimal(String.valueOf(data.get("qty")));
                    materialReceive.setQty(qty);
                }
                
                if (data.get("fauxqty") != null) {
                    materialReceive.setFauxqty(new BigDecimal(String.valueOf(data.get("fauxqty"))));
                }
                
                // 如果已存在，更新剩余数量（基于原始数量）
                if (existRecord == null && qty != null) {
                    materialReceive.setRemainQty(qty);
                } else if (existRecord != null && qty != null) {
                    // 已存在时，如果数量有变化，重新计算剩余数量
                    BigDecimal originalQty = existRecord.getFqty() != null ? existRecord.getFqty() : 
                                           (existRecord.getQty() != null ? existRecord.getQty() : BigDecimal.ZERO);
                    BigDecimal outQty = existRecord.getOutQty() != null ? existRecord.getOutQty() : BigDecimal.ZERO;
                    // 如果新数量与原始数量不同，说明数量更新了，需要重新计算剩余数量
                    if (qty.compareTo(originalQty) != 0) {
                        // 数量变化，剩余数量 = 新数量 - 已出库数量
                        materialReceive.setRemainQty(qty.subtract(outQty));
                    } else {
                        // 数量没变化，保持原有剩余数量
                        materialReceive.setRemainQty(existRecord.getRemainQty());
                    }
                }
                
                materialReceive.setUnit(data.get("unit") != null ? String.valueOf(data.get("unit")) : null);
                materialReceive.setDepName(data.get("depName") != null ? String.valueOf(data.get("depName")) : null);
                materialReceive.setDepCode(data.get("depCode") != null ? String.valueOf(data.get("depCode")) : null);
                if (data.get("depId") != null) {
                    try {
                        materialReceive.setDepId(Integer.valueOf(String.valueOf(data.get("depId"))));
                    } catch (Exception e) {
                        // 忽略转换错误
                    }
                }
                if (data.get("fworkshop") != null) {
                    try {
                        materialReceive.setFworkshop(Integer.valueOf(String.valueOf(data.get("fworkshop"))));
                    } catch (Exception e) {
                        // 忽略转换错误
                    }
                }
                if (data.get("whId") != null) {
                    try {
                        materialReceive.setWhId(Integer.valueOf(String.valueOf(data.get("whId"))));
                    } catch (Exception e) {
                        // 忽略转换错误
                    }
                }
                materialReceive.setWhName(data.get("whName") != null ? String.valueOf(data.get("whName")) : null);
                if (data.get("fplancommitdate") != null && !Cools.isEmpty(String.valueOf(data.get("fplancommitdate")))) {
                    try {
                        String dateStr = String.valueOf(data.get("fplancommitdate"));
                        java.text.SimpleDateFormat sdf = new java.text.SimpleDateFormat("yyyy-MM-dd");
                        materialReceive.setFplancommitdate(sdf.parse(dateStr));
                    } catch (Exception ex) {
                        // 忽略日期解析错误
                    }
                }
                if (data.get("fplanfinishdate") != null && !Cools.isEmpty(String.valueOf(data.get("fplanfinishdate")))) {
                    try {
                        String dateStr = String.valueOf(data.get("fplanfinishdate"));
                        java.text.SimpleDateFormat sdf = new java.text.SimpleDateFormat("yyyy-MM-dd");
                        materialReceive.setFplanfinishdate(sdf.parse(dateStr));
                    } catch (Exception ex) {
                        // 忽略日期解析错误
                    }
                }
                if (finterid != null) {
                    materialReceive.setFinterid(finterid);
                }
                if (data.get("fitemid") != null) {
                    try {
                        materialReceive.setFitemid(Integer.valueOf(String.valueOf(data.get("fitemid"))));
                    } catch (Exception e) {
                        // 忽略转换错误
                    }
                }
                if (data.get("funitid") != null) {
                    try {
                        materialReceive.setFunitid(Integer.valueOf(String.valueOf(data.get("funitid"))));
                    } catch (Exception e) {
                        // 忽略转换错误
                    }
                }
                
                // 将其他字段存储到ext_data（JSON格式），用于校验生产领料出库数量
                Map<String, Object> extDataMap = new HashMap<>();
                // 已映射到数据库表字段的字段列表（这些字段不需要存储在ext_data中）
                java.util.Set<String> mappedFields = new java.util.HashSet<>();
                mappedFields.add("soCode");
                mappedFields.add("fbillno");
                mappedFields.add("invCode");
                mappedFields.add("invName");
                mappedFields.add("invStd");
                mappedFields.add("qty");
                mappedFields.add("fqty");
                mappedFields.add("fauxqty");
                mappedFields.add("unit");
                mappedFields.add("depName");
                mappedFields.add("depCode");
                mappedFields.add("depId");
                mappedFields.add("fworkshop");
                mappedFields.add("whId");
                mappedFields.add("whName");
                mappedFields.add("fplancommitdate");
                mappedFields.add("fplanfinishdate");
                mappedFields.add("finterid");
                mappedFields.add("fitemid");
                mappedFields.add("funitid");
                
                // 将所有未映射的字段存储到ext_data中（包含所有打印预览和打印相关的字段）
                for (Map.Entry<String, Object> entry : data.entrySet()) {
                    String key = entry.getKey();
                    if (!mappedFields.contains(key) && entry.getValue() != null) {
                        extDataMap.put(key, entry.getValue());
                    }
                }
                
                // 始终更新ext_data，即使为空也要存储（用于后续扩展）
                materialReceive.setExtData(com.alibaba.fastjson.JSON.toJSONString(extDataMap));
                
                materialReceive.setSyncTime(new Date());
                materialReceive.setUpdateTime(new Date());

                // 保存或更新
                if (existRecord != null) {
                    materialReceiveService.updateById(materialReceive);
                } else {
                    materialReceiveService.insert(materialReceive);
                }
            } catch (Exception e) {
                // 记录失败的记录，继续处理下一条
                e.printStackTrace();
            }
        }
        return R.ok("成功保存 " + successCount + " 条新数据，更新 " + updateCount + " 条已存在数据");
    }

    @RequestMapping(value = "/materialReceive/update/auth")
    @ManagerAuth
    public R update(MaterialReceive materialReceive) {
        if (Cools.isEmpty(materialReceive) || null == materialReceive.getId()) {
            return R.error();
        }
        materialReceive.setUpdateTime(new Date());
        materialReceiveService.updateById(materialReceive);
        return R.ok();
    }

    @RequestMapping(value = "/materialReceive/updateOutQty/auth", method = RequestMethod.POST)
    @ManagerAuth
    public R updateOutQty(@RequestBody Map<String, Object> param) {
        Long id = Long.valueOf(String.valueOf(param.get("id")));
        BigDecimal addOutQty = new BigDecimal(String.valueOf(param.get("outQty"))); // 本次出库数量
        
        MaterialReceive materialReceive = materialReceiveService.selectById(id);
        if (materialReceive == null) {
            return R.error("记录不存在");
        }
        
        // 累加出库数量
        BigDecimal currentOutQty = materialReceive.getOutQty() != null ? materialReceive.getOutQty() : BigDecimal.ZERO;
        BigDecimal newOutQty = currentOutQty.add(addOutQty);
        materialReceive.setOutQty(newOutQty);
        
        // 计算剩余数量（优先使用fqty，如果没有则使用qty）
        BigDecimal qty = materialReceive.getFqty() != null ? materialReceive.getFqty() : 
                         (materialReceive.getQty() != null ? materialReceive.getQty() : BigDecimal.ZERO);
        BigDecimal remainQty = qty.subtract(newOutQty);
        materialReceive.setRemainQty(remainQty.compareTo(BigDecimal.ZERO) > 0 ? remainQty : BigDecimal.ZERO);
        
        // 判断是否全部出库完成
        materialReceive.setIsAllOut(remainQty.compareTo(BigDecimal.ZERO) <= 0 ? 1 : 0);
        materialReceive.setUpdateTime(new Date());
        
        materialReceiveService.updateById(materialReceive);
        return R.ok();
    }

    @RequestMapping(value = "/materialReceive/checkSyncStatus/auth")
    @ManagerAuth
    public R checkSyncStatus(@RequestParam String soCode, @RequestParam(required = false) String invCode, @RequestParam(required = false) String fbillno) {
        EntityWrapper<MaterialReceive> wrapper = new EntityWrapper<>();
        wrapper.eq("so_code", soCode);
        wrapper.eq("fbillno", fbillno);
        if (!Cools.isEmpty(invCode)) {
            wrapper.eq("inv_code", invCode);
        }
        List<MaterialReceive> list = materialReceiveService.selectList(wrapper);
        
        Map<String, Object> result = new HashMap<>();
        if (Cools.isEmpty(list)) {
            result.put("synced", false);
            result.put("allOut", false);
            result.put("message", "该生产单号未同步到WMS");
            return R.ok(result);
        }
        
        // 检查是否全部出库完成
        boolean allOut = true;
        List<Map<String, Object>> notOutList = new ArrayList<>();
        for (MaterialReceive mr : list) {
            if (mr.getIsAllOut() == null || mr.getIsAllOut() != 1) {
                allOut = false;
                Map<String, Object> notOutItem = new HashMap<>();
                notOutItem.put("invCode", mr.getInvCode());
                notOutItem.put("invName", mr.getInvName());
                notOutItem.put("remainQty", mr.getRemainQty());
                notOutList.add(notOutItem);
            }
        }
        
        result.put("synced", true);
        result.put("allOut", allOut);
        result.put("records", list);
        if (!allOut && !notOutList.isEmpty()) {
            result.put("notOutList", notOutList);
            result.put("message", "部分物料未全部出库完成");
        } else if (allOut) {
            result.put("message", "全部物料已出库完成");
        }
        return R.ok(result);
    }
    
    private void convert(Map<String, Object> map, EntityWrapper<MaterialReceive> wrapper) {
        for (Map.Entry<String, Object> entry : map.entrySet()) {
            String fieldName = entry.getKey();
            String columnName = getColumnName(MaterialReceive.class, fieldName);
            String val = String.valueOf(entry.getValue());
            if (val.contains(RANGE_TIME_LINK)) {
                String[] dates = val.split(RANGE_TIME_LINK);
                wrapper.ge(columnName, DateUtils.convert(dates[0]));
                wrapper.le(columnName, DateUtils.convert(dates[1]));
            } else {
                wrapper.like(columnName, val);
            }
        }
    }
    
    /**
     * 根据实体类字段名获取数据库列名
     * @param cls 实体类
     * @param fieldName Java字段名（驼峰命名）
     * @return 数据库列名（下划线命名）
     */
    private String getColumnName(Class<?> cls, String fieldName) {
        for (Field field : Cools.getAllFields(cls)) {
            if (field.getName().equals(fieldName)) {
                if (field.isAnnotationPresent(TableField.class)) {
                    TableField annotation = field.getAnnotation(TableField.class);
                    if (!annotation.exist()) {
                        continue;
                    }
                    String column = annotation.value();
                    if (!Cools.isEmpty(column)) {
                        return column;
                    }
                }
                // 如果没有@TableField注解，使用humpToLine转换
                return humpToLine(fieldName);
            }
        }
        // 如果找不到字段，使用humpToLine转换
        return humpToLine(fieldName);
    }

    @RequestMapping(value = "/materialReceive/delete/auth")
    @ManagerAuth
    public R delete(@RequestParam String param) {
        com.alibaba.fastjson.JSONArray jsonArray = com.alibaba.fastjson.JSONArray.parseArray(param);
        List<MaterialReceive> list = jsonArray.toJavaList(MaterialReceive.class);
        if (Cools.isEmpty(list)) {
            return R.error("请选择要删除的数据");
        }
        for (MaterialReceive entity : list) {
            materialReceiveService.deleteById(entity.getId());
        }
        return R.ok();
    }
}