package com.jcdm.main.om.productionOrde.service.impl;

import java.text.SimpleDateFormat;
import java.util.Date;
import java.util.List;
import java.util.stream.Collectors;

import cn.hutool.core.util.ObjectUtil;
import cn.hutool.json.JSONObject;
import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
import com.baomidou.mybatisplus.core.conditions.update.LambdaUpdateWrapper;
import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
import com.jcdm.common.core.domain.AjaxResult;
import com.jcdm.common.utils.DateUtils;
import com.jcdm.main.om.productionOrde.domain.OmProductionOrdeInfo;
import com.jcdm.main.om.productionOrde.mapper.OmProductionOrdeInfoMapper;
import com.jcdm.main.om.productionOrde.service.IOmProductionOrdeInfoService;
import com.jcdm.main.restful.factoryMes.service.RestfulService;
import lombok.extern.slf4j.Slf4j;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;

/**
 * 生产工单Service业务层处理
 * 
 * @author ruimin
 * @date 2023-12-11
 */
@Slf4j
@Service
public class OmProductionOrdeInfoServiceImpl extends ServiceImpl<OmProductionOrdeInfoMapper,OmProductionOrdeInfo> implements IOmProductionOrdeInfoService
{
    private static final Logger logger = LoggerFactory.getLogger("sys-user");
    public SimpleDateFormat format = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");

    @Autowired
    private OmProductionOrdeInfoMapper omProductionOrdeInfoMapper;

    @Autowired
    private IOmProductionOrdeInfoService omProductionOrdeInfoService;

    /**
     * 查询生产工单
     * 
     * @param id 生产工单主键
     * @return 生产工单
     */
    @Override
    public OmProductionOrdeInfo selectOmProductionOrdeInfoById(Long id)
    {
        return omProductionOrdeInfoMapper.selectOmProductionOrdeInfoById(id);
    }

    /**
     * 查询生产工单列表
     * 
     * @param omProductionOrdeInfo 生产工单
     * @return 生产工单
     */
    @Override
    public List<OmProductionOrdeInfo> selectOmProductionOrdeInfoList(OmProductionOrdeInfo omProductionOrdeInfo)
    {
        return omProductionOrdeInfoMapper.selectOmProductionOrdeInfoList(omProductionOrdeInfo);
    }

    /**
     * 新增生产工单
     * 
     * @param omProductionOrdeInfo 生产工单
     * @return 结果
     */
    @Override
    public int insertOmProductionOrdeInfo(OmProductionOrdeInfo omProductionOrdeInfo)
    {
        omProductionOrdeInfo.setCreateTime(DateUtils.getNowDate());
        Integer streamNumber = omProductionOrdeInfoMapper.getMaxStreamNumber();
        omProductionOrdeInfo.setStreamNumber(String.valueOf(streamNumber+1));
        return omProductionOrdeInfoMapper.insertOmProductionOrdeInfo(omProductionOrdeInfo);
    }

    /**
     * 修改生产工单
     * 
     * @param omProductionOrdeInfo 生产工单
     * @return 结果
     */
    @Override
    public int updateOmProductionOrdeInfo(OmProductionOrdeInfo omProductionOrdeInfo)
    {
        omProductionOrdeInfo.setUpdateTime(DateUtils.getNowDate());
        return omProductionOrdeInfoMapper.updateOmProductionOrdeInfo(omProductionOrdeInfo);
    }

    /**
     * 批量删除生产工单
     * 
     * @param ids 需要删除的生产工单主键
     * @return 结果
     */
    @Override
    public int deleteOmProductionOrdeInfoByIds(Long[] ids)
    {
        return omProductionOrdeInfoMapper.deleteOmProductionOrdeInfoByIds(ids);
    }

    /**
     * 删除生产工单信息
     * 
     * @param id 生产工单主键
     * @return 结果
     */
    @Override
    public int deleteOmProductionOrdeInfoById(Long id)
    {
        return omProductionOrdeInfoMapper.deleteOmProductionOrdeInfoById(id);
    }

    @Override
    public AjaxResult upDownMove(OmProductionOrdeInfo omProductionOrdeInfo) {
        long currentId = omProductionOrdeInfo.getFrontEndId();
        List<OmProductionOrdeInfo> omProductionOrdeInfos = omProductionOrdeInfoService.selectOmProductionOrdeInfoList(omProductionOrdeInfo);
        List<Long> idList = omProductionOrdeInfos.stream()
                .map(OmProductionOrdeInfo::getId) // 提取id属性
                .collect(Collectors.toList());
        int index = idList.indexOf(currentId);
        long moveId = 0L;
        try {
            if(omProductionOrdeInfo.getFlag().equals("up")){
                moveId = idList.get(index - 1);
            }else {
                moveId = idList.get(index + 1);
            }
        }catch (Exception e){
            return AjaxResult.error("当前工单为最后一个或第一个，无法移动");
        }
        OmProductionOrdeInfo  currentInfo = new OmProductionOrdeInfo();
        currentInfo.setId(currentId);
        List<OmProductionOrdeInfo> currentOrdeInfos = omProductionOrdeInfoService.selectOmProductionOrdeInfoList(currentInfo);
        String currentStreamNumber = currentOrdeInfos.get(0).getStreamNumber();
        OmProductionOrdeInfo  moveInfo = new OmProductionOrdeInfo();
        moveInfo.setId(moveId);
        List<OmProductionOrdeInfo> moveOrdeInfos = omProductionOrdeInfoService.selectOmProductionOrdeInfoList(moveInfo);
        String moveStreamNumber = moveOrdeInfos.get(0).getStreamNumber();
        moveOrdeInfos.get(0).setStreamNumber(currentStreamNumber);
        omProductionOrdeInfoService.updateOmProductionOrdeInfo(moveOrdeInfos.get(0));
        currentOrdeInfos.get(0).setStreamNumber(moveStreamNumber);
        omProductionOrdeInfoService.updateOmProductionOrdeInfo(currentOrdeInfos.get(0));
        return AjaxResult.success("移动成功");
    }

    @Override
    public void overrideSaveBatch(List<OmProductionOrdeInfo> omProductionOrdeInfoList) {
        try {
            this.saveBatch(omProductionOrdeInfoList);
        }catch (Exception e){
            return;
        }
    }

    @Override
    public AjaxResult receivingWorkOrders() {
        return null;
    }

    @Override
    public AjaxResult trolleyYardBinDing(OmProductionOrdeInfo omProductionOrdeInfo) {
        OmProductionOrdeInfo clearTrolleyYard = omProductionOrdeInfoService.getOne(new LambdaQueryWrapper<OmProductionOrdeInfo>().eq(OmProductionOrdeInfo::getTrolleyYard, omProductionOrdeInfo.getTrolleyYard()));
        if(clearTrolleyYard!=null){
            clearTrolleyYard.setTrolleyYard("");
            omProductionOrdeInfoService.saveOrUpdate(clearTrolleyYard);
        }
        OmProductionOrdeInfo one = omProductionOrdeInfoService.getOne(new LambdaQueryWrapper<OmProductionOrdeInfo>().eq(OmProductionOrdeInfo::getProductNum, omProductionOrdeInfo.getProductNum()));
        one.setTrolleyYard(omProductionOrdeInfo.getTrolleyYard());
        omProductionOrdeInfoService.saveOrUpdate(one);
        logger.info("绑定pack码{}到小车：{}",omProductionOrdeInfo.getProductNum(),omProductionOrdeInfo.getTrolleyYard());

        return AjaxResult.success();
    }

    @Override
    public AjaxResult getCarCodeSize(OmProductionOrdeInfo omProductionOrdeInfo) {
//        omProductionOrdeInfo.
        return null;
    }

    @Override
    public AjaxResult findBytrolleyYardGetOne(OmProductionOrdeInfo omProductionOrdeInfo) {
        String str = "";
        OmProductionOrdeInfo one = omProductionOrdeInfoService.getOne(new LambdaQueryWrapper<OmProductionOrdeInfo>().eq(OmProductionOrdeInfo::getTrolleyYard, omProductionOrdeInfo.getTrolleyYard()));
        if(one == null){
            str = "2";
        }else {
            str = one.getProductNum();
        }
        return AjaxResult.success(str);
    }

    @Override
    public List<OmProductionOrdeInfo> checkCarCode(OmProductionOrdeInfo omProductionOrdeInfo) {
        List<OmProductionOrdeInfo> list = omProductionOrdeInfoService.list(new LambdaQueryWrapper<OmProductionOrdeInfo>().eq(OmProductionOrdeInfo::getProductNum, omProductionOrdeInfo.getProductNum()).isNotNull(OmProductionOrdeInfo::getTrolleyYard));
        return list;
    }

    @Override
    public AjaxResult workReportingByStation(OmProductionOrdeInfo info) {
        OmProductionOrdeInfo omProductionOrdeInfo = omProductionOrdeInfoService.getById(info.getId());
        logger.info("OP230报工开始-工厂MES异步方法");
        String reportResult = RestfulService.getWorkReportResultFeedback(omProductionOrdeInfo.getProductNum(), info.getStationCode(), format.format(new Date()));
        JSONObject jsonObject = new JSONObject(reportResult);
        String code = jsonObject.getStr("code");
        String status = jsonObject.getJSONObject("data").getStr("resultCode");
        if("success".equals(code)&&"S".equals(status)){
            //如果成功，执行报工成功方法，修改是否报工为1，添加报工时间
            this.updateOrderByProductNum("1",omProductionOrdeInfo.getProductNum(),info.getStationCode());
        }else{
            //解析工厂mes返回结果，如果失败，执行报工失败方法，修改是否报工为2，添加报工时间
            this.updateOrderByProductNum("2",omProductionOrdeInfo.getProductNum(),info.getStationCode());
        }
        return null;
    }

    @Override
    public void updateOrderByProductNum(String onlineCompletionMark, String productNum, String stationCode) {
        LambdaUpdateWrapper<OmProductionOrdeInfo> updateWrapper = new LambdaUpdateWrapper<>();
        if(stationCode.equals("POP230")){
            updateWrapper.set(OmProductionOrdeInfo::getOnlineCompletionMark,onlineCompletionMark);
            updateWrapper.set(OmProductionOrdeInfo::getActualStartTime,new Date());
        }
        if(stationCode.equals("POP430")){
            updateWrapper.set(OmProductionOrdeInfo::getSfResult,onlineCompletionMark);
        }
        updateWrapper.eq(OmProductionOrdeInfo::getProductNum,productNum);
        OmProductionOrdeInfo omProductionOrdeInfo = new OmProductionOrdeInfo();
        omProductionOrdeInfoService.update(omProductionOrdeInfo,updateWrapper);
    }
}