//package com.ruoyi.production.service.impl;
//
//import com.alibaba.fastjson2.JSONArray;
//import com.alibaba.fastjson2.JSONObject;
//import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
//import com.baomidou.mybatisplus.core.metadata.IPage;
//import com.baomidou.mybatisplus.core.toolkit.Wrappers;
//import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
//import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
//import com.ruoyi.common.exception.ServiceException;
//import com.ruoyi.common.exception.base.BaseException;
//import com.ruoyi.common.utils.StringUtils;
//import com.ruoyi.common.utils.bean.BeanUtils;
//import com.ruoyi.common.utils.poi.ExcelUtil;
//import com.ruoyi.production.bean.dto.ProductionPlanDto;
//import com.ruoyi.production.bean.dto.ProductionPlanImportDto;
//import com.ruoyi.production.bean.vo.ProductionPlanVo;
//import com.ruoyi.production.mapper.ProductionPlanMapper;
//import com.ruoyi.production.pojo.ProductionPlan;
//import com.ruoyi.production.service.ProductionPlanService;
//import lombok.RequiredArgsConstructor;
//import org.springframework.stereotype.Service;
//import org.springframework.transaction.annotation.Transactional;
//import org.springframework.web.multipart.MultipartFile;
//
//import javax.servlet.http.HttpServletResponse;
//import java.math.BigDecimal;
//import java.time.Instant;
//import java.time.LocalDateTime;
//import java.time.ZoneId;
//import java.util.*;
//import java.util.concurrent.locks.ReentrantLock;
//import java.util.stream.Collectors;
//
///**
// *
// * 生产计划表 服务实现类
// *
// *
// * @author 芯导软件(江苏)有限公司
// * @since 2026-04-21 02:11:10
// */
//@Service
//@RequiredArgsConstructor
//public class ProductionPlanServiceImpl extends ServiceImpl implements ProductionPlanService {
//
// private ProductionPlanMapper productionPlanMapper;
//
//
// /**
// * 同步锁,确保手动和定时任务不同时执行
// */
// private final ReentrantLock syncLock = new ReentrantLock();
//
// @Override
// public IPage listPage(Page page, ProductionPlanDto productionPlanDto) {
//
// return productionPlanMapper.selectPage(page, null);
// }
//
// /**
// * 页面手动同步
// */
// @Override
// public void loadProdData() {
// syncProdData(1);
// }
//
// /**
// * 定时任务同步
// */
// @Override
// public void syncProdDataJob() {
// syncProdData(2);
// }
//
// /**
// * 合并生产计划
// */
// @Override
// @Transactional(rollbackFor = Exception.class)
// public boolean combine(ProductionPlanDto productionPlanDto) {
// if (productionPlanDto.getIds() == null || productionPlanDto.getIds().isEmpty()) {
// return false;
// }
//
// // 查询主生产计划
// List plans = productionPlanMapper.selectWithMaterialByIds(productionPlanDto.getIds());
//
// if (plans == null || plans.isEmpty()) {
// throw new ServiceException("下发失败,生产计划不存在");
// }
//
// // 校验是否存在不同的产品名称
// String firstProductName = plans.get(0).getProductName();
// if (plans.stream().anyMatch(p -> p.getProductName() == null || !p.getProductName().equals(firstProductName))) {
// throw new BaseException("合并失败,存在不同的产品名称");
// }
//
// // 校验是否存在不同的产品规格
// String firstProductSpec = plans.get(0).getModel();
// if (plans.stream().anyMatch(p -> p.getModel() == null || !p.getModel().equals(firstProductSpec))) {
// throw new BaseException("合并失败,存在不同的产品规格");
// }
//
// // 叠加剩余方数
// BigDecimal totalRemainingVolume = plans.stream()
// .map(ProductionPlan::getRemainingVolume)
// .filter(Objects::nonNull)
// .reduce(BigDecimal.ZERO, BigDecimal::add);
// // 判断下发数量是否大于等于剩余方数
// if (productionPlanDto.getTotalAssignedQuantity().compareTo(totalRemainingVolume) > 0) {
// throw new BaseException("操作失败,下发数量不能大于剩余方数");
// }
//
// // 创建生产订单
// ProductOrder productOrder = new ProductOrder();
// productOrder.setQuantity(productionPlanDto.getTotalAssignedQuantity());
// productOrder.setPlanCompleteTime(productionPlanDto.getPlanCompleteTime());
// productOrder.setStatus(ProductOrderStatusEnum.WAIT.getCode());
// productOrder.setStrength(productionPlanDto.getStrength());
// productOrder.setProductMaterialSkuId(plans.get(0).getProductMaterialSkuId());
//
// Long orderId = productOrderService.insertProductOrder(productOrder);
//
// // 当下发的产品为砌块或板材,就拉取BOM子集与工艺路线子集数据存入到附表中
// if ("砌块".equals(productionPlanDto.getProductName())) {
// productOrder.setRouteId(productionOrderAppendixService.populateBlocks(orderId, productionPlanDto));
// }
// if ("板材".equals(productionPlanDto.getProductName())) {
// productOrder.setRouteId(productionOrderAppendixService.populatePlates(orderId, productionPlanDto));
// }
// // 更新绑定的工艺路线
// productOrderService.updateById(productOrder);
//
// // 根据下发数量,从第一个生产计划开始分配方数
// BigDecimal assignedVolume = BigDecimal.ZERO;
// for (ProductionPlan plan : plans) {
// BigDecimal volume = plan.getVolume();
// if (volume == null) {
// continue;
// }
// // 计算剩余方数
// BigDecimal remainingVolume = plan.getRemainingVolume();
// if (remainingVolume.compareTo(BigDecimal.ZERO) <= 0) {
// continue;
// }
//
// ProductOrderPlan productOrderPlan = new ProductOrderPlan();
// productOrderPlan.setProductOrderId(productOrder.getId());
// productOrderPlan.setProductionPlanId(plan.getId());
//
// if (assignedVolume.add(remainingVolume).compareTo(productionPlanDto.getTotalAssignedQuantity()) >= 0) {
// // 最后一个计划,分配剩余方数
// BigDecimal lastRemainingVolume = productionPlanDto.getTotalAssignedQuantity().subtract(assignedVolume);
// BigDecimal assignedQuantity = Optional.ofNullable(plan.getAssignedQuantity()).orElse(BigDecimal.ZERO).add(lastRemainingVolume);
// plan.setAssignedQuantity(assignedQuantity);
// plan.setStatus(assignedQuantity.compareTo(plan.getVolume()) >= 0 ? 2 : 1);
// productOrderPlan.setAssignedQuantity(lastRemainingVolume);
// productionPlanMapper.updateById(plan);
// productOrderPlanMapper.insert(productOrderPlan);
// break;
// }
//
// // 分配当前计划方数
// BigDecimal assignedQuantity = Optional.ofNullable(plan.getAssignedQuantity()).orElse(BigDecimal.ZERO).add(remainingVolume);
// plan.setAssignedQuantity(assignedQuantity);
// plan.setStatus(assignedQuantity.compareTo(plan.getVolume()) >= 0 ? 2 : 1);
// productOrderPlan.setAssignedQuantity(remainingVolume);
// // 更新生产计划
// productionPlanMapper.updateById(plan);
// // 创建关联关系
// productOrderPlanMapper.insert(productOrderPlan);
// assignedVolume = assignedVolume.add(remainingVolume);
// }
//
// for (ProductionPlan plan : plans) {
// BigDecimal assignedQuantity = Optional.ofNullable(plan.getAssignedQuantity()).orElse(BigDecimal.ZERO);
// BigDecimal volume = Optional.ofNullable(plan.getVolume()).orElse(BigDecimal.ZERO);
// if (assignedQuantity.compareTo(BigDecimal.ZERO) <= 0) {
// plan.setStatus(0);
// } else if (assignedQuantity.compareTo(volume) >= 0) {
// plan.setStatus(2);
// } else {
// plan.setStatus(1);
// }
// productionPlanMapper.updateById(plan);
// }
// return true;
// }
//
// @Override
// @Transactional(rollbackFor = Exception.class)
// public boolean add(ProductionPlanDto productionPlanDto) {
// if (StringUtils.isEmpty(productionPlanDto.getApplyNo())) {
// throw new ServiceException("新增失败,申请单编号不能为空");
// }
// Long count = productionPlanMapper.selectCount(Wrappers.lambdaQuery()
// .eq(ProductionPlan::getApplyNo, productionPlanDto.getApplyNo()));
// if (count > 0) {
// throw new ServiceException("新增失败,申请单编号 " + productionPlanDto.getApplyNo() + " 已存在");
// }
// productionPlanDto.setDataSourceType(DataSourceTypeEnum.MANUAL.getCode());
// productionPlanDto.setStatus(0);
// productionPlanMapper.insert(productionPlanDto);
// return true;
// }
//
// @Override
// @Transactional(rollbackFor = Exception.class)
// public boolean update(ProductionPlanDto productionPlanDto) {
// if (productionPlanDto == null || productionPlanDto.getId() == null) {
// throw new ServiceException("编辑失败,数据不能为空");
// }
// ProductionPlan productionPlan = getById(productionPlanDto.getId());
// if (productionPlan == null) {
// throw new ServiceException("编辑失败,主生产计划不存在");
// }
//
// if (StringUtils.isNotEmpty(productionPlanDto.getApplyNo())
// && !productionPlanDto.getApplyNo().equals(productionPlan.getApplyNo())) {
//
// Long count = productionPlanMapper.selectCount(Wrappers.lambdaQuery()
// .eq(ProductionPlan::getApplyNo, productionPlanDto.getApplyNo())
// .ne(ProductionPlan::getId, productionPlanDto.getId())); // 排除自身
//
// if (count > 0) {
// throw new ServiceException("编辑失败,申请单编号 " + productionPlanDto.getApplyNo() + " 已被占用");
// }
// }
// // 已下发状态,不能编辑
// if (productionPlan.getStatus() != 0) {
// throw new BaseException("编辑失败,该生产计划已下发或部分下发状态,禁止编辑");
// }
//
// // 查询是否有关联订单
// boolean hasProductOrderPlan = productOrderPlanMapper.selectList(Wrappers.lambdaQuery()
// .eq(ProductOrderPlan::getProductionPlanId, productionPlanDto.getId()))
// .stream().anyMatch(p -> p.getProductOrderId() != null);
//
// if (hasProductOrderPlan) {
// if (productionPlanDto.getVolume().compareTo(productionPlan.getVolume()) < 0) {
// throw new BaseException("方数不能递减");
// }
// }
//
// return productionPlanMapper.updateById(productionPlanDto) > 0;
// }
//
// @Override
// @Transactional(rollbackFor = Exception.class)
// public boolean delete(List ids) {
// // 如果存在已下发的计划,则不能删除
// if (productionPlanMapper.selectList(Wrappers.lambdaQuery().in(ProductionPlan::getId, ids)).stream().anyMatch(p -> p.getStatus() == 1 || p.getStatus() == 2)) {
// throw new BaseException("删除失败,存在已下发或部分下发的计划");
// }
// // 如果有关联订单,则不能删除
// if (productOrderPlanMapper.selectList(Wrappers.lambdaQuery().in(ProductOrderPlan::getProductionPlanId, ids)).stream().anyMatch(p -> p.getProductOrderId() != null)) {
// throw new BaseException("删除失败,存在关联订单");
// }
//
// return productionPlanMapper.deleteBatchIds(ids) > 0;
// }
//
// /**
// * 同步数据
// */
// @Transactional(rollbackFor = Exception.class)
// public void syncProdData(Integer dataSyncType) {
// if (!syncLock.tryLock()) {
// log.warn("同步正在进行中,本次 {} 同步请求被跳过", dataSyncType == 1 ? "手动同步" : "定时任务同步");
// return;
// }
//
// try {
// JSONArray searchConditions = new JSONArray();
// JSONObject condition = new JSONObject();
// condition.put("key", "processApprovedResult");
// JSONArray valueArray = new JSONArray();
// valueArray.add("agree");
//
// condition.put("value", valueArray);
// condition.put("type", "ARRAY");
// condition.put("operator", "in");
// condition.put("componentName", "SelectField");
// searchConditions.add(condition);
//
// String searchFieldJson = searchConditions.toJSONString();
//
// JSONArray dataArr = AliDingUtils.getFormDataList(aliDingConfig, aliDingConfig.getProducePlanFormUuid(), searchFieldJson, this, ProductionPlan::getFormModifiedTime);
//
// if (dataArr.isEmpty()) {
// log.info("没有更多新数据需要同步");
// return;
// }
//
// // 解析并保存数据
// List list = parseProductionPlans(dataArr, dataSyncType, dataArr.size());
// if (!list.isEmpty()) {
// // 处理更新或新增
// int affected = processSaveOrUpdate(list);
// log.info("数据同步完成,共同步 {} 条数据", affected);
// }
//
// } catch (Exception e) {
// log.error("同步生产计划异常", e);
// } finally {
// // 释放锁
// syncLock.unlock();
// }
// }
//
// private List parseProductionPlans(JSONArray dataArr, Integer dataSyncType, Integer totalCount) {
// List list = new ArrayList<>();
// LocalDateTime now = LocalDateTime.now();
//
// for (int i = 0; i < dataArr.size(); i++) {
// JSONObject item = dataArr.getJSONObject(i);
// String formInstanceId = item.getString("formInstanceId");
// String serialNo = item.getString("serialNo");
//
// JSONObject originator = item.getJSONObject("originator");
// String originatorName = originator != null && originator.containsKey("userName")
// ? originator.getJSONObject("userName").getString("nameInChinese") : "未知";
//
// JSONObject formData = item.getJSONObject("formData");
// JSONArray tableArr = formData.getJSONArray("tableField_l7fytfcn");
// if (tableArr == null || tableArr.isEmpty()) {
// continue;
// }
//
// for (int j = 0; j < tableArr.size(); j++) {
// JSONObject row = tableArr.getJSONObject(j);
// ProductionPlan plan = new ProductionPlan();
//
// plan.setFormInstanceId(formInstanceId);
// plan.setSerialNo(serialNo);
// plan.setApplyNo(formData.getString("textField_l7fytfco"));
// plan.setCustomerName(formData.getString("textField_lbkozohg"));
//
// String materialCode = row.getString("textField_l9xo62q5");
// // 根据物料编码查询物料信息表,关联物料ID
// if (StringUtils.isNotEmpty(materialCode)) {
// LambdaQueryWrapper skuQueryWrapper = new LambdaQueryWrapper<>();
// skuQueryWrapper.eq(ProductMaterialSku::getMaterialCode, materialCode);
// ProductMaterialSku sku = productMaterialSkuService.getOne(skuQueryWrapper);
// if (sku != null) {
// plan.setProductMaterialSkuId(sku.getId());
// }
// }
//
// plan.setLength(row.getInteger("numberField_lb7lgatg_value"));
// plan.setWidth(row.getInteger("numberField_lb7lgath_value"));
// plan.setHeight(row.getInteger("numberField_lb7lgati_value"));
// plan.setQuantity(row.getInteger("numberField_lb7lgatj_value"));
// plan.setVolume(row.getBigDecimal("numberField_l7fytfd3_value"));
// plan.setStrength(row.getString("radioField_m9urarr2_id"));
//
// JSONArray dateArr = row.getJSONArray("cascadeDateField_lfxqqluw");
// if (dateArr != null && dateArr.size() == 2) {
// try {
// long start = Long.parseLong(dateArr.getString(0));
// long end = Long.parseLong(dateArr.getString(1));
//
// Date startDate = Date.from(Instant.ofEpochMilli(start)
// .atZone(ZoneId.systemDefault())
// .toLocalDate()
// .atStartOfDay(ZoneId.systemDefault())
// .toInstant());
// Date endDate = Date.from(Instant.ofEpochMilli(end)
// .atZone(ZoneId.systemDefault())
// .toLocalDate()
// .atStartOfDay(ZoneId.systemDefault())
// .toInstant());
//
// plan.setStartDate(startDate);
// plan.setEndDate(endDate);
// } catch (Exception e) {
// log.warn("解析日期失败: {}", dateArr);
// }
// }
//
// plan.setSubmitter(originatorName);
// plan.setSubmitOrg("宁夏中创绿能实业集团有限公司");
// plan.setRemarkOne(formData.getString("textareaField_l7fytfcy"));
// plan.setRemarkTwo(formData.getString("textField_l7fytfcx"));
// plan.setCreatorName(originatorName);
//
// JSONObject modifyUser = item.getJSONObject("modifyUser");
// if (modifyUser != null && modifyUser.containsKey("userName")) {
// plan.setModifierName(modifyUser.getJSONObject("userName").getString("nameInChinese"));
// }
//
// plan.setFormCreatedTime(AliDingUtils.parseUtcTime(item.getString("createdTimeGMT")));
// plan.setFormModifiedTime(AliDingUtils.parseUtcTime(item.getString("modifiedTimeGMT")));
// plan.setDataSourceType(DataSourceTypeEnum.DING_TALK.getCode());
// plan.setCreateTime(now);
// plan.setUpdateTime(now);
// plan.setTotalCount(totalCount);
//
// list.add(plan);
// }
// }
// return list;
// }
//
// private int processSaveOrUpdate(List list) {
// if (list == null || list.isEmpty()) {
// return 0;
// }
// int affected = 0;
//
// // 去重 formInstanceId
// Set formIds = list.stream()
// .map(ProductionPlan::getFormInstanceId)
// .collect(Collectors.toSet());
//
// // 查询数据库已有数据
// List existList = this.list(new LambdaQueryWrapper().in(ProductionPlan::getFormInstanceId, formIds));
//
// // Map (formInstanceId + materialCode)
// Map existMap = new HashMap<>();
// for (ProductionPlan p : existList) {
// String key = p.getFormInstanceId() + "_" + p.getProductMaterialSkuId();
// existMap.put(key, p);
// }
//
// // 遍历同步数据
// for (ProductionPlan plan : list) {
// String key = plan.getFormInstanceId() + "_" + plan.getProductMaterialSkuId();
// ProductionPlan exist = existMap.get(key);
// if (exist == null) {
// // 新增
// this.save(plan);
// affected++;
// log.info("新增数据 formInstanceId={}, materialCode={}", plan.getFormInstanceId(), plan.getProductMaterialSkuId());
// } else {
// // 判断是否需要更新
// if (exist.getFormModifiedTime() == null || !exist.getFormModifiedTime().equals(plan.getFormModifiedTime())) {
// plan.setId(exist.getId());
// plan.setCreateTime(exist.getCreateTime());
// this.updateById(plan);
// affected++;
// log.info("更新数据 formInstanceId={}, materialCode={}", plan.getFormInstanceId(), plan.getProductMaterialSkuId());
// }
// }
// }
// return affected;
// }
//
// @Override
// public List summaryByProductType(ProductionPlanSummaryDto query) {
// return baseMapper.selectSummaryByProductType(query);
// }
//
// @Override
// @Transactional(rollbackFor = Exception.class)
// public void importProdData(MultipartFile file) {
// if (file == null || file.isEmpty()) {
// throw new ServiceException("导入数据不能为空");
// }
// ExcelUtil excelUtil = new ExcelUtil<>(ProductionPlanImportDto.class);
// List list;
// try {
// list = excelUtil.importExcel(file.getInputStream());
// } catch (Exception e) {
// log.error("生产需求Excel导入失败", e);
// throw new ServiceException("Excel解析失败");
// }
//
// if (list == null || list.isEmpty()) {
// throw new ServiceException("Excel没有数据");
// }
//
// Set applyNos = new HashSet<>();
// Set materialCodes = new HashSet<>();
// for (int i = 0; i < list.size(); i++) {
// ProductionPlanImportDto dto = list.get(i);
// String applyNo = dto.getApplyNo();
// String materialCode = dto.getMaterialCode();
//
// if (StringUtils.isEmpty(applyNo)) {
// throw new ServiceException("导入失败:第 " + (i + 2) + " 行申请单编号不能为空");
// }
// if (!applyNos.add(applyNo)) {
// throw new ServiceException("导入失败:Excel 中存在重复的申请单编号: " + applyNo);
// }
// if (StringUtils.isEmpty(materialCode)) {
// throw new ServiceException("导入失败:第 " + (i + 2) + " 行物料编码不能为空");
// }
//
// String strength = dto.getStrength();
// if (StringUtils.isNotEmpty(strength)) {
// if (!"A3.5".equals(strength) && !"A5.0".equals(strength)) {
// throw new ServiceException("导入失败:第 " + (i + 2) + " 行强度只能是 A3.5 或 A5.0");
// }
// }
//
// materialCodes.add(materialCode);
// }
//
// // 申请单编号是否已存在
// Long existApplyNoCount = baseMapper.selectCount(Wrappers.lambdaQuery()
// .in(ProductionPlan::getApplyNo, applyNos));
// if (existApplyNoCount > 0) {
// List existApplyNos = baseMapper.selectList(Wrappers.lambdaQuery()
// .in(ProductionPlan::getApplyNo, applyNos))
// .stream().map(ProductionPlan::getApplyNo).collect(Collectors.toList());
// throw new ServiceException("导入失败,申请单编号已存在: " + String.join(", ", existApplyNos));
// }
//
// Map skuMap = productMaterialSkuService.list(Wrappers.lambdaQuery()
// .in(ProductMaterialSku::getMaterialCode, materialCodes))
// .stream().collect(Collectors.toMap(ProductMaterialSku::getMaterialCode, ProductMaterialSku::getId, (k1, k2) -> k1));
//
// List missingCodes = materialCodes.stream()
// .filter(code -> !skuMap.containsKey(code))
// .collect(Collectors.toList());
// if (!missingCodes.isEmpty()) {
// throw new ServiceException("导入失败,以下物料编码不存在: " + String.join(", ", missingCodes));
// }
//
// LocalDateTime now = LocalDateTime.now();
// List entityList = list.stream().map(dto -> {
// ProductionPlan entity = new ProductionPlan();
// BeanUtils.copyProperties(dto, entity);
// entity.setProductMaterialSkuId(skuMap.get(dto.getMaterialCode()));
// entity.setAssignedQuantity(BigDecimal.ZERO);
// entity.setDataSourceType(DataSourceTypeEnum.MANUAL.getCode());
// entity.setStatus(0);
// entity.setCreateTime(now);
// entity.setUpdateTime(now);
// return entity;
// }).collect(Collectors.toList());
//
// this.saveBatch(entityList);
// }
//
// @Override
// public void exportProdData(HttpServletResponse response, List ids) {
// List list;
// if (ids != null && !ids.isEmpty()) {
// list = baseMapper.selectBatchIds(ids);
// } else {
// list = baseMapper.selectList(null);
// }
//
// List exportList = new ArrayList<>();
// for (ProductionPlan entity : list) {
// ProductionPlanImportDto dto = new ProductionPlanImportDto();
// BeanUtils.copyProperties(entity, dto);
// exportList.add(dto);
// }
// ExcelUtil util = new ExcelUtil<>(ProductionPlanImportDto.class);
// util.exportExcel(response, exportList, "销售生产需求数据");
// }
//
//}