/*
|
* Copyright (c) 2018-2025, ztt All rights reserved.
|
*
|
* Redistribution and use in source and binary forms, with or without
|
* modification, are permitted provided that the following conditions are met:
|
*
|
* Redistributions of source code must retain the above copyright notice,
|
* this list of conditions and the following disclaimer.
|
* Redistributions in binary form must reproduce the above copyright
|
* notice, this list of conditions and the following disclaimer in the
|
* documentation and/or other materials provided with the distribution.
|
* Neither the name of the pig4cloud.com developer nor the names of its
|
* contributors may be used to endorse or promote products derived from
|
* this software without specific prior written permission.
|
* Author: ztt
|
*/
|
package com.chinaztt.mes.warehouse.service.impl;
|
|
import cn.hutool.core.collection.CollectionUtil;
|
import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
|
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.chinaztt.mes.common.handler.StateMachineHandler;
|
import com.chinaztt.mes.common.numgen.NumberGenerator;
|
import com.chinaztt.mes.common.util.StateResult;
|
import com.chinaztt.mes.warehouse.dto.PrepareDetailDTO;
|
import com.chinaztt.mes.warehouse.dto.ReserveMainDTO;
|
import com.chinaztt.mes.warehouse.entity.PrepareDetail;
|
import com.chinaztt.mes.warehouse.entity.ReserveDetail;
|
import com.chinaztt.mes.warehouse.entity.ReserveMain;
|
import com.chinaztt.mes.warehouse.entity.Stock;
|
import com.chinaztt.mes.warehouse.mapper.PrepareDetailMapper;
|
import com.chinaztt.mes.warehouse.mapper.ReserveDetailMapper;
|
import com.chinaztt.mes.warehouse.mapper.ReserveMainMapper;
|
import com.chinaztt.mes.warehouse.mapper.StockMapper;
|
import com.chinaztt.mes.warehouse.service.ReserveMainService;
|
import com.chinaztt.mes.warehouse.state.ReserveStateMachineConfig;
|
import com.chinaztt.mes.warehouse.state.constant.ReserveEvents;
|
import com.chinaztt.mes.warehouse.state.constant.ReserveStates;
|
import com.chinaztt.mes.warehouse.util.StockUtils;
|
import lombok.AllArgsConstructor;
|
import org.springframework.messaging.Message;
|
import org.springframework.messaging.support.MessageBuilder;
|
import org.springframework.statemachine.config.StateMachineFactory;
|
import org.springframework.statemachine.persist.StateMachinePersister;
|
import org.springframework.stereotype.Service;
|
import org.springframework.transaction.annotation.Transactional;
|
|
import java.math.BigDecimal;
|
import java.time.LocalDateTime;
|
import java.util.List;
|
|
/**
|
* 领料主表
|
*
|
* @author sunxl
|
* @date 2020-10-13 13:30:50
|
*
|
*/
|
@Service
|
@Transactional(rollbackFor = Exception.class)
|
@AllArgsConstructor
|
public class ReserveMainServiceImpl extends ServiceImpl<ReserveMainMapper, ReserveMain> implements ReserveMainService {
|
private NumberGenerator<ReserveMain> numberGenerator;
|
private ReserveDetailMapper reserveDetailMapper;
|
private StockMapper stockMapper;
|
private StockUtils stockUtils;
|
private PrepareDetailMapper prepareDetailMapper;
|
private StateMachineFactory<ReserveStates, ReserveEvents> reserveStateMachineFactory;
|
private StateMachinePersister<ReserveStates, ReserveEvents, ReserveMain> persister;
|
@Override
|
|
public boolean fullSave(ReserveMain reserveMain) {
|
reserveMain.setResNo(numberGenerator.generateNumberWithPrefix(ReserveMain.DIGIT, ReserveMain.PREFIX, ReserveMain::getResNo));
|
reserveMain.setResDate(LocalDateTime.now());
|
baseMapper.insert(reserveMain);
|
return false;
|
}
|
|
@Override
|
public boolean fullDelete(Long id) {
|
baseMapper.deleteById(id);
|
reserveDetailMapper.delete(Wrappers.<ReserveDetail>query().lambda().eq(ReserveDetail::getWarehouseMainId,id));
|
return true;
|
}
|
@Override
|
public boolean updateReserve(List<Long> ids,String event) {
|
List<ReserveDetail> reserveDetails = baseMapper.issueReserve(ids);
|
for (int i = 0; i <reserveDetails.size(); i++) {
|
if (reserveDetails.get(i) == null) {
|
throw new RuntimeException("请重新选择申请单号，有申请单号没有配置零件");
|
}
|
}
|
for(ReserveDetail reserveDetail : reserveDetails){
|
reserveDetail.setStatus("已下发");
|
reserveDetailMapper.updateById(reserveDetail);
|
}
|
changeResStatus(ids, event);
|
return true;
|
}
|
@Override
|
public IPage<List<ReserveMain>> getReserveMain(Page page, QueryWrapper<ReserveMain> gen, String type) {
|
return baseMapper.getReserveMain(page, gen, type);
|
}
|
|
@Override
|
public IPage<List<ReserveMain>> getReserveMainPage( Page page,QueryWrapper<ReserveMain> gen) {
|
return baseMapper.getReserveMainPage(page,gen);
|
}
|
|
@Override
|
public IPage<List<ReserveMain>> getReserveMainByPage(Page page, QueryWrapper<ReserveMain> gen) {
|
return baseMapper.getReserveMainByPage(page,gen);
|
}
|
|
public void changeResStatus(List<Long> ids, String event) {
|
for (Long id : ids) {
|
ReserveMain reserveMain = baseMapper.selectById(id);
|
Message<ReserveEvents> message = MessageBuilder.withPayload(ReserveEvents.valueOf(event)).setHeader("reserveMain", reserveMain).build();
|
StateMachineHandler handler = new StateMachineHandler(reserveStateMachineFactory, persister, ReserveStateMachineConfig.MACHINE_ID, reserveMain);
|
StateResult res = handler.sendEvent(message, reserveMain.getId());
|
if (!res.isSuccess()) {
|
throw new RuntimeException(res.getMsg());
|
}
|
}
|
}
|
}
|
