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("OP230")){
|
updateWrapper.set(OmProductionOrdeInfo::getOnlineCompletionMark,onlineCompletionMark);
|
updateWrapper.set(OmProductionOrdeInfo::getActualStartTime,new Date());
|
}
|
if(stationCode.equals("OP500")){
|
updateWrapper.set(OmProductionOrdeInfo::getSfResult,onlineCompletionMark);
|
}
|
updateWrapper.eq(OmProductionOrdeInfo::getProductNum,productNum);
|
OmProductionOrdeInfo omProductionOrdeInfo = new OmProductionOrdeInfo();
|
omProductionOrdeInfoService.update(omProductionOrdeInfo,updateWrapper);
|
}
|
}
|
