package com.example.springboot.service;
|
|
import java.lang.reflect.Array;
|
import java.util.ArrayList;
|
import java.util.List;
|
|
import org.springframework.beans.factory.annotation.Autowired;
|
import org.springframework.stereotype.Service;
|
|
import com.example.springboot.common.Result;
|
import com.example.springboot.component.S7control;
|
import com.example.springboot.entity.Glass;
|
import com.example.springboot.entity.StorageCage;
|
import com.example.springboot.mapper.SpianMapper;
|
import com.google.common.primitives.Bytes;
|
|
@Service
|
public class SpianService {
|
@Autowired
|
private SpianMapper spianMapper;
|
|
// @GetMapping("/all2")
|
public Result selectout(String orderid) {
|
|
//spianMapper.UpdatetaskOut(); //完成上一次出片或者调度任务，改到plchold里，出片或调度任务完成立即改变结束任务；
|
// 定义PRC数据传送数组
|
List<String> adddresslist = new ArrayList<>();
|
adddresslist.add("DB105.6");// 出片车起始位置
|
adddresslist.add("DB105.8");// 出片车目标位置
|
adddresslist.add("DB105.10");// 出片笼玻璃数
|
adddresslist.add("DB105.14");// 出片车启动 1为启动
|
List<Short> datas = new ArrayList<>();
|
// 获取优先出片的位置
|
StorageCage cageout = spianMapper.selectOut(orderid);
|
if(cageout==null){
|
return Result.success("200");
|
}
|
|
|
|
|
int cage = cageout.getCage(); // 储存出片位置，笼子格子几号玻璃
|
int cell = cageout.getCell();// 出片格号
|
int tier = cageout.getTier();// 出片内外片
|
int prcid = cageout.getPrcId();// prcid
|
String glassid=cageout.getGlassId();
|
int prcid2;
|
int ids;
|
int cages;
|
int cells;
|
double glasswidth = cageout.getGlassWidth();
|
// 判断玻璃内外片
|
if (tier == 2) {
|
// 判断玻璃可直接出片时
|
// 修改数据库笼子表(出片)
|
datas.add((short) prcid);
|
datas.add((short) 1000);
|
datas.add((short) 1);
|
datas.add((short) 1);
|
|
spianMapper.UpdataOutCage1(glasswidth, cage, cell);//增加原格子宽度
|
spianMapper.UpdataGlassCage("", "", glasswidth, cage, cell, tier, 3);//清除格子玻璃信息
|
spianMapper.Inserttask(1, 0,cageout.getId(),1000,orderid);//新增任务
|
S7control.getinstance().WriteWord(adddresslist, datas);//派发出片车任务
|
outmesid(glassid);//派发出片ID
|
return Result.success(datas);//结束
|
} else {
|
// 获取格子的玻璃数量
|
int state = spianMapper.selectGlassState(cage, cell);
|
// 判断内片是否需要调拨
|
if (state == 0) {
|
//spianMapper.UpdataGlassCage("", "", glasswidth, cage, cell, tier, 0);
|
datas.add((short) prcid);
|
datas.add((short) 1000);
|
datas.add((short) 1);
|
datas.add((short) 1);
|
spianMapper.Inserttask(1, 0,cageout.getId(),1000,orderid);//新增任务
|
spianMapper.UpdataOutCage1(glasswidth, cage, cell);//增加原格子宽度
|
spianMapper.UpdataGlassCage("", "", glasswidth, cage, cell, tier, 3);//清除格子玻璃信息
|
S7control.getinstance().WriteWord(adddresslist, datas);//派发出片车任务
|
outmesid(glassid);//派发出片ID
|
//spianMapper.Updatetask(1, 1);//完成任务
|
return Result.success(datas);//结束
|
|
} else {
|
// 玻璃需要调拨时，判断属于哪个半区的笼子
|
if (cage < 6) {
|
StorageCage cagecell = spianMapper.selectGlassCage(cage, glasswidth, 0, 6);
|
if (cagecell == null) {
|
return Result.success(cagecell);
|
}
|
// 获取调拨位置进行调拨
|
prcid2 = cagecell.getPrcId();// 调拨目标位PRCID
|
ids = cagecell.getId();// 调拨目标位ID
|
cages=cagecell.getCage();//调拨目标位笼子
|
cells=cagecell.getCell();//调拨目标位格子
|
|
// 填入调拨数据
|
datas.add((short) prcid);// 调拨外片起始位置
|
datas.add((short) prcid2);
|
datas.add((short) 2);
|
datas.add((short) 1);
|
// 更换玻璃的笼子
|
String glassids=spianMapper.SelectGlassid(cage, cell); //获取被调拨的玻璃id
|
spianMapper.UpdateDBCage(ids, cage, cell);// 将原格子数据更新到新格子里
|
spianMapper.UpdataAddCage1(glasswidth, cages, cells);//减少新格子宽度
|
spianMapper.UpdataOutCage1(glasswidth, cage, cell);//增加原格子宽度
|
spianMapper.UpdataGlassCage("", "", glasswidth, cage, cell, 2, 3);// 清除被调拨格子数据
|
spianMapper.Inserttask(2, 0,cageout.getId(),ids,orderid);//新增调度任务
|
// 传输mes数据,坐标，数据
|
S7control.getinstance().WriteWord(adddresslist, datas);//派发出片车任务
|
System.out.println(datas);
|
outmesid(glassids);//派发调拨玻璃ID
|
return Result.success(cagecell); //结束
|
|
} else {// 笼子号大于5时
|
StorageCage cagecell = spianMapper.selectGlassCage(cage, glasswidth, 5, 11);
|
if (cagecell == null) {
|
return Result.success(cagecell);
|
}
|
// 获取调拨位置进行调拨
|
prcid2 = cagecell.getPrcId();// 调拨目标位prcID
|
ids = cagecell.getId();// 调拨目标位ID
|
cages=cagecell.getCage();//调拨目标位笼子
|
cells=cagecell.getCell();//调拨目标位格子
|
// 填入调拨数据
|
datas.add((short) prcid);
|
datas.add((short) prcid2);
|
datas.add((short) 2);
|
datas.add((short) 1);
|
String glassids=spianMapper.SelectGlassid(cage, cell); //获取被调拨的玻璃id
|
spianMapper.UpdateDBCage(ids, cage, cell);// 将原格子数据更新到新格子里
|
spianMapper.Inserttask(2, 0,cageout.getId(),ids,orderid);//新增调度任务
|
spianMapper.UpdataAddCage1(glasswidth, cages, cells);//减少新格子宽度
|
spianMapper.UpdataOutCage1(glasswidth, cage, cell);//增加原格子宽度
|
spianMapper.UpdataGlassCage("", "", glasswidth, cage, cell, 2, 3);// 清除被调拨格子数据
|
// 传输mes数据,坐标，数据
|
S7control.getinstance().WriteWord(adddresslist, datas);//派发出片车任务
|
|
outmesid(glassids);//派发调拨玻璃ID
|
return Result.success(cagecell); //结束
|
|
}
|
|
}
|
}
|
|
}
|
|
// @GetMapping("/all")
|
// 进片任务,传订单id
|
// 按订单优先进片
|
public Short selectAll(String glassid) {
|
|
int cage1;
|
int cells;
|
int ids;
|
int prcid;
|
int tiers;
|
int prctier;
|
double width;
|
double minwidth=0;
|
//spianMapper.Updatetask(1, 0);//完成任务,改到plchold里，出片或调度任务完成立即改变结束任务；
|
Glass glasslist = spianMapper.selectGlass(glassid);
|
if(glasslist==null){
|
return (300);
|
}
|
double widths = glasslist.getWidth();
|
Short orderids = glasslist.getOrderId();
|
|
List<String> adddresslist = new ArrayList<>();
|
adddresslist.add("DB105.0");// 进片车起始位置
|
adddresslist.add("DB105.2");// 进片车目标位置
|
adddresslist.add("DB105.4");// 进片笼玻璃数
|
adddresslist.add("DB105.12");// 进片车启动 1为启动
|
List<Short> datas = new ArrayList<>();
|
|
// String orderid="A001";
|
// 获取订单相关度最高的笼子排序
|
List<StorageCage> storageCage = spianMapper.selectAll(orderids);
|
if (storageCage == null) {
|
return (400);
|
}
|
for (StorageCage storageCage2 : storageCage) {
|
// 保存订单优先顺序笼子号
|
cage1 = storageCage2.getCage();
|
// 判断该笼子号相邻最大的空格数
|
int cages = spianMapper.selectCage(cage1);
|
StorageCage cages1 ;
|
//判断是否是第二片需要加间隔物
|
prctier = spianMapper.selectsum(cage1, storageCage2.getCell());// 传给prc的格子内玻璃数
|
if(prctier>0){
|
cages1 = spianMapper.selectCage1(cage1,storageCage2.getCell(),widths+400);
|
}else{
|
cages1 = spianMapper.selectCage1(cage1,storageCage2.getCell(),widths);
|
}
|
// 判断选中笼子是否有合适宽度空格
|
// 有合适空格时进片
|
if (cages1 != null&&cages>=1) {
|
ids = cages1.getId();// 数据库ID
|
tiers = cages1.getTier();// 内外片
|
cells = cages1.getCell();// 格子号
|
prcid = cages1.getPrcId();// 传给prc的目标地id
|
width=cages1.getWidth();//格子剩余宽度
|
widths=glasslist.getWidth();
|
|
// 执行进片
|
datas.add((short) 1000);
|
datas.add((short) prcid);
|
datas.add((short) prctier);
|
datas.add((short) 1);
|
// 数据库修改笼子表新增一条玻璃
|
spianMapper.UpdataAddCage(orderids, glassid, widths, cage1, cells, ids, 2);
|
spianMapper.UpdataAddCage1(widths, cage1, cells);//减少格子宽度
|
spianMapper.Inserttask(0, 0, 1000, ids,glassid.toString());//新增任务
|
S7control.getinstance().WriteWord(adddresslist, datas);
|
|
// S7control.getinstance().WriteByte("DB105.16",glassid);
|
return (200);
|
|
}
|
|
}
|
return (400);
|
|
}
|
|
// @GetMapping("/all2")
|
public Short selectout2(String glassid) {
|
//spianMapper.UpdatetaskOut(); //完成上一次出片或者调度任务,改到plchold里，出片或调度任务完成立即改变结束任务；
|
// 定义PRC数据传送数组
|
List<String> adddresslist = new ArrayList<>();
|
adddresslist.add("DB105.6");// 出片车起始位置
|
adddresslist.add("DB105.8");// 出片车目标位置
|
adddresslist.add("DB105.10");// 出片笼玻璃数
|
adddresslist.add("DB105.14");// 出片车启动 1为启动
|
List<Short> datas = new ArrayList<>();
|
// 获取优先出片的位置
|
StorageCage cageout = spianMapper.selectOut2(glassid);
|
if(cageout==null){
|
return (300);
|
}
|
|
|
|
|
int cage = cageout.getCage(); // 储存出片位置，笼子格子几号玻璃
|
int cell = cageout.getCell();// 出片格号
|
int tier = cageout.getTier();// 出片内外片
|
int prcid = cageout.getPrcId();// prcid
|
int prcid2;
|
int ids;
|
int cages;
|
int cells;
|
double glasswidth = cageout.getGlassWidth();
|
// 判断玻璃内外片
|
if (tier == 2) {
|
int state = spianMapper.selectGlassState(cage, cell);//获取格子数量
|
// 判断玻璃可直接出片时
|
// 修改数据库笼子表(出片)
|
datas.add((short) prcid);
|
datas.add((short) 1000);
|
datas.add((short) state);
|
datas.add((short) 1);
|
|
spianMapper.UpdataOutCage1(glasswidth, cage, cell);//增加原格子宽度
|
spianMapper.UpdataGlassCage("", "", glasswidth, cage, cell, tier, 3);//清除格子玻璃信息
|
spianMapper.Inserttask(1, 0,cageout.getId(),1000,glassid);//新增任务
|
//int state = spianMapper.selectGlassState(cage, cell);//获取格子数量
|
if(state==2){
|
spianMapper.UpdateDBCage1(cage, cell);// 将内片数据更新到外片里
|
spianMapper.UpdateDBCage2(cage, cell);// 清除内片数据
|
}
|
S7control.getinstance().WriteWord(adddresslist, datas);//派发出片车任务
|
outmesid(glassid);//派发出片ID
|
|
|
return (200);//结束
|
} else {
|
// 获取格子的玻璃数量
|
int state = spianMapper.selectGlassState(cage, cell);
|
// 判断内片是否需要调拨
|
if (state == 0) {
|
//spianMapper.UpdataGlassCage("", "", glasswidth, cage, cell, tier, 3);
|
datas.add((short) prcid);
|
datas.add((short) 1000);
|
datas.add((short) 1);
|
datas.add((short) 1);
|
spianMapper.Inserttask(1, 0,cageout.getId(),1000 ,glassid);//新增任务
|
spianMapper.UpdataOutCage1(glasswidth, cage, cell);//增加原格子宽度
|
spianMapper.UpdataGlassCage("", "", glasswidth, cage, cell, tier, 3);//清除格子玻璃信息
|
outmesid(glassid);//派发出片ID
|
S7control.getinstance().WriteWord(adddresslist, datas);//派发出片车任务
|
|
|
return (200);//结束
|
|
} else {
|
// 玻璃需要调拨时，判断属于哪个半区的笼子
|
if (cage < 6) {
|
StorageCage cagecell = spianMapper.selectGlassCage(cage, glasswidth, 0, 6);
|
if (cagecell == null) {
|
return (300);
|
}
|
// 获取调拨位置进行调拨
|
prcid2 = cagecell.getPrcId();// 调拨目标位PRCID
|
ids = cagecell.getId();// 调拨目标位ID
|
cages=cagecell.getCage();//调拨目标位笼子
|
cells=cagecell.getCell();//调拨目标位格子
|
|
|
// 填入调拨数据
|
datas.add((short) prcid);// 调拨外片起始位置
|
datas.add((short) prcid2);
|
datas.add((short) 2);
|
datas.add((short) 1);
|
// 更换玻璃的笼子
|
String glassids=spianMapper.SelectGlassid(cage, cell); //获取被调拨的玻璃id
|
spianMapper.UpdateDBCage(ids, cage, cell);// 将原格子数据更新到新格子里
|
spianMapper.UpdataAddCage1(glasswidth, cages, cells);//减少新格子宽度
|
spianMapper.UpdataOutCage1(glasswidth, cage, cell);//增加原格子宽度
|
spianMapper.UpdataGlassCage("", "", glasswidth, cage, cell, 2, 3);// 清除被调拨格子数据
|
spianMapper.Inserttask(2, 0,cageout.getId(),ids,glassid);//新增调度任务
|
spianMapper.Inserttask(1, 0,cageout.getId(),1000,glassid);//新增出片任务
|
// 传输mes数据,坐标，数据
|
S7control.getinstance().WriteWord(adddresslist, datas);//派发出片车任务
|
|
outmesid(glassids);//派发调拨玻璃ID
|
return (200); //结束
|
|
} else {// 笼子号大于5时
|
StorageCage cagecell = spianMapper.selectGlassCage(cage, glasswidth, 5, 11);
|
if (cagecell == null) {
|
return (300);
|
}
|
// 获取调拨位置进行调拨
|
prcid2 = cagecell.getPrcId();// 调拨目标位prcID
|
ids = cagecell.getId();// 调拨目标位ID
|
cages=cagecell.getCage();//调拨目标位笼子
|
cells=cagecell.getCell();//调拨目标位格子
|
// 填入调拨数据
|
datas.add((short) prcid);
|
datas.add((short) prcid2);
|
datas.add((short) 2);
|
datas.add((short) 1);
|
String glassids=spianMapper.SelectGlassid(cage, cell); //获取被调拨的玻璃id
|
spianMapper.Inserttask(2, 0,cageout.getId()+1,ids,glassid);//新增调度任务
|
spianMapper.Inserttask(1, 0,cageout.getId(),1000,glassid);//新增出片任务
|
spianMapper.UpdateDBCage(ids, cage, cell);// 将原格子数据更新到新格子里
|
spianMapper.UpdataAddCage1(glasswidth, cages, cells);//减少新格子宽度
|
spianMapper.UpdataOutCage1(glasswidth, cage, cell);//增加原格子宽度
|
spianMapper.UpdataGlassCage("", "", glasswidth, cage, cell, 2, 3);// 清除被调拨格子数据
|
// 传输mes数据,坐标，数据
|
S7control.getinstance().WriteWord(adddresslist, datas);//派发出片车任务
|
|
outmesid(glassids);//派发调拨玻璃ID
|
return (200);//结束
|
|
}
|
}
|
}
|
|
}
|
|
public void outmesid(String glassid) {
|
System.out.println("outmesid:"+glassid);
|
List<Byte> glassidlist=new ArrayList();
|
for (char iditem : glassid.toCharArray()) {
|
glassidlist.add(Byte.valueOf(String.valueOf(iditem)));
|
}
|
byte[] bytes= Bytes.toArray(glassidlist);
|
System.out.println("outmesidbytes:"+bytes.length);
|
S7control.getinstance().WriteByte("DB105.30", bytes);//派发出片id
|
}
|
|
/*** 修改用户* @throws SQLException */
|
// public static int updateUser(Glass user) throws SQLException {conn =
|
// getConn();
|
// String sql = "update t_user set name=?,gender=?,age=?,score=?"+ " where
|
// id=?";ps = conn.prepareStatement(sql);
|
// ps.setString(1, user.getName());ps.setString(2, user.getGender());
|
// ps.setInt(3, user.getAge());ps.setDouble(4, user.getScore());ps.setInt(5,
|
// user.getId());return ps.executeUpdate();}
|
// /*** 增加用户* @throws SQLException */
|
// public static int insertUser(User user) throws SQLException {
|
// conn = getConn();
|
// String sql = "insert into t_user(name,gender,age,score)"+ " values(?,?,?,?)";
|
// ps = conn.prepareStatement(sql);ps.setString(1,
|
// user.getName());ps.setString(2, user.getGender());
|
// ps.setInt(3, user.getAge());ps.setDouble(4, user.getScore());return
|
// ps.executeUpdate();
|
// }
|
|
}
|
