package com.jcdm.main.bs.batchInfo.service.impl;
|
|
import java.text.SimpleDateFormat;
|
import java.time.Instant;
|
import java.util.*;
|
import java.util.concurrent.CompletableFuture;
|
|
import cn.hutool.http.HttpRequest;
|
import cn.hutool.http.HttpResponse;
|
import cn.hutool.json.JSONUtil;
|
import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
|
import com.jcdm.common.utils.DateUtils;
|
import com.jcdm.main.bs.beatSetting.domain.BsBeatSetting;
|
import com.jcdm.main.bs.beatSetting.mapper.BsBeatSettingMapper;
|
import com.jcdm.main.bs.beatSetting.service.IBsBeatSettingService;
|
import com.jcdm.main.constant.Constants;
|
import com.jcdm.main.restful.qingYan.doman.ChildVO;
|
import com.jcdm.main.restful.qingYan.doman.ParentVO;
|
import org.springframework.beans.factory.annotation.Autowired;
|
import org.springframework.stereotype.Service;
|
import com.jcdm.main.bs.batchInfo.mapper.BsBatchInfoMapper;
|
import com.jcdm.main.bs.batchInfo.domain.BsBatchInfo;
|
import com.jcdm.main.bs.batchInfo.service.IBsBatchInfoService;
|
|
/**
|
* 批次信息录入Service业务层处理
|
*
|
* @author Yi
|
* @date 2024-10-15
|
*/
|
@Service
|
public class BsBatchInfoServiceImpl extends ServiceImpl<BsBatchInfoMapper, BsBatchInfo> implements IBsBatchInfoService
|
{
|
@Autowired
|
private BsBatchInfoMapper bsBatchInfoMapper;
|
|
/**
|
* 查询批次信息录入
|
*
|
* @param id 批次信息录入主键
|
* @return 批次信息录入
|
*/
|
@Override
|
public BsBatchInfo selectBsBatchInfoById(Long id)
|
{
|
return bsBatchInfoMapper.selectBsBatchInfoById(id);
|
}
|
|
/**
|
* 查询批次信息录入列表
|
*
|
* @param bsBatchInfo 批次信息录入
|
* @return 批次信息录入
|
*/
|
@Override
|
public List<BsBatchInfo> selectBsBatchInfoList(BsBatchInfo bsBatchInfo)
|
{
|
return bsBatchInfoMapper.selectBsBatchInfoList(bsBatchInfo);
|
}
|
|
/**
|
* 新增批次信息录入
|
*
|
* @param bsBatchInfo 批次信息录入
|
* @return 结果
|
*/
|
@Override
|
public int insertBsBatchInfo(BsBatchInfo bsBatchInfo)
|
{
|
bsBatchInfo.setChangeTime(DateUtils.getNowDate());
|
bsBatchInfo.setCreateTime(DateUtils.getNowDate());
|
return bsBatchInfoMapper.insertBsBatchInfo(bsBatchInfo);
|
}
|
|
/**
|
* 修改批次信息录入
|
*
|
* @param bsBatchInfo 批次信息录入
|
* @return 结果
|
*/
|
@Override
|
public int updateBsBatchInfo(BsBatchInfo bsBatchInfo)
|
{
|
bsBatchInfo.setUpdateTime(DateUtils.getNowDate());
|
return bsBatchInfoMapper.updateBsBatchInfo(bsBatchInfo);
|
}
|
|
/**
|
* 批量删除批次信息录入
|
*
|
* @param ids 需要删除的批次信息录入主键
|
* @return 结果
|
*/
|
@Override
|
public int deleteBsBatchInfoByIds(Long[] ids)
|
{
|
return bsBatchInfoMapper.deleteBsBatchInfoByIds(ids);
|
}
|
|
/**
|
* 删除批次信息录入信息
|
*
|
* @param id 批次信息录入主键
|
* @return 结果
|
*/
|
@Override
|
public int deleteBsBatchInfoById(Long id)
|
{
|
return bsBatchInfoMapper.deleteBsBatchInfoById(id);
|
}
|
|
@Override
|
public int bacthInput(Long[] ids) {
|
Integer sendData = 0;
|
SimpleDateFormat format = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
|
Set<Long> idSet = new HashSet<>(Arrays.asList(ids));
|
List<BsBatchInfo> bsBatchInfos = this.listByIds(idSet);
|
for (BsBatchInfo bsBatchInfo : bsBatchInfos) {
|
ParentVO parentVO = new ParentVO();
|
parentVO.setSiteCode("3983");
|
parentVO.setRecordId(String.valueOf(Instant.now().toEpochMilli()));
|
parentVO.setStationCode(bsBatchInfo.getStationCode());
|
parentVO.setProductNum(format.format(new Date()));
|
parentVO.setTotalResult("1");
|
List<ChildVO> listChildVo = new ArrayList<>();
|
ChildVO childVO = new ChildVO();
|
childVO.setItemCode(bsBatchInfo.getMaterialCode());
|
childVO.setItemType("3");
|
childVO.setItemText(bsBatchInfo.getMaterialName());
|
childVO.setItemValue(bsBatchInfo.getBatch());
|
childVO.setCheckResult("1");
|
childVO.setCheckTime(format.format(new Date()));
|
listChildVo.add(childVO);
|
parentVO.setCheckList(listChildVo);
|
try{
|
CompletableFuture<Void> cp1 = CompletableFuture.runAsync(() -> {
|
HttpResponse execute = HttpRequest.post(Constants.FACTORY_EMS_UAT_GET_RUL+"deviceResultFeedback").body(JSONUtil.toJsonStr(parentVO)).execute();
|
System.out.println(execute.body());
|
bsBatchInfo.setFlag("Y");
|
this.saveOrUpdate(bsBatchInfo);
|
});
|
}catch (Exception e){
|
System.out.println(e.getMessage());
|
}
|
sendData = sendData+1;
|
}
|
return sendData;
|
}
|
}
|
