package cn.stylefeng.guns.modular.opcua.cert;
|
|
|
import cn.hutool.extra.spring.SpringUtil;
|
import cn.stylefeng.guns.modular.cm.passingStationCollection.model.params.PassingStationCollectionParam;
|
import cn.stylefeng.guns.modular.cm.passingStationCollection.model.result.PassingStationCollectionResult;
|
import cn.stylefeng.guns.modular.cm.passingStationCollection.service.PassingStationCollectionService;
|
import cn.stylefeng.guns.modular.cm.passingStationCollection.service.impl.PassingStationCollectionServiceImpl;
|
import cn.stylefeng.guns.modular.om.productionOrdeInfo.entity.ProductionOrdeInfo;
|
import cn.stylefeng.guns.modular.om.productionOrdeInfo.model.params.ProductionOrdeInfoParam;
|
import cn.stylefeng.guns.modular.om.productionOrdeInfo.model.result.ProductionOrdeInfoResult;
|
import cn.stylefeng.guns.modular.om.productionOrdeInfo.service.ProductionOrdeInfoService;
|
import cn.stylefeng.guns.modular.opcua.client.ClientHandler;
|
import cn.stylefeng.guns.modular.opcua.config.BeanUtils;
|
import cn.stylefeng.guns.modular.opcua.entity.NodeEntity;
|
import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
|
import lombok.extern.slf4j.Slf4j;
|
import org.springframework.beans.factory.annotation.Autowired;
|
import org.springframework.security.core.parameters.P;
|
import org.springframework.stereotype.Component;
|
import oshi.util.StringUtil;
|
|
import java.text.SimpleDateFormat;
|
import java.util.Date;
|
import java.util.List;
|
import java.util.Random;
|
|
@Slf4j
|
public class MethodName {
|
private PassingStationCollectionService service = BeanUtils.getBean(PassingStationCollectionService.class);
|
|
private ProductionOrdeInfoService orderService = BeanUtils.getBean(ProductionOrdeInfoService.class);
|
|
private static SimpleDateFormat df = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
|
|
|
public void getSn(String Node, String value) {
|
ClientHandler clientHandler=new ClientHandler();
|
|
if(value.equals("1")){
|
try {
|
String snCode = "";
|
ProductionOrdeInfoResult bySpec = getOrder();
|
if(bySpec!=null){
|
if(bySpec.getActualQty()<bySpec.getPlanQty()) {
|
SimpleDateFormat format = new SimpleDateFormat("yyyyMMdd");
|
String condition = "SYS" + format.format(new Date());
|
List<PassingStationCollectionResult> results = service.snCodeSize(condition);
|
if (results.size() == 0) {
|
snCode = condition + String.format("%04d", 1);
|
} else {
|
snCode = condition + String.format("%04d", results.size() + 1);
|
}
|
|
NodeEntity node = NodeEntity.builder().index(2).identifier("nbu01.OP1010.SNCode")
|
.value(snCode).type("string").build();
|
|
Boolean out = clientHandler.write(node);
|
log.info("节点:{},响应结果:{}", node.getIdentifier(), out);
|
if (out) {
|
NodeEntity node1 = NodeEntity.builder().index(2).identifier("nbu01.OP1010.RecordSNDone")
|
.value("1").type("short").build();
|
Boolean out1 = clientHandler.write(node1);
|
log.info("节点:{},响应结果:{}", node1.getIdentifier(), out1);
|
}
|
}
|
}
|
} catch (Exception e) {
|
e.printStackTrace();
|
}
|
}else{
|
try {
|
NodeEntity node1= NodeEntity.builder().index(2).identifier("nbu01.OP1010.RecordSNDone")
|
.value("0").type("short").build();
|
Boolean out1=clientHandler.write(node1);
|
NodeEntity node = NodeEntity.builder().index(2).identifier("nbu01.OP1010.SNCode")
|
.value("").type("string").build();
|
Boolean out=clientHandler.write(node);
|
log.info("节点:{},响应结果:{}", node1.getIdentifier(),out1);
|
log.info("节点:{},响应结果:{}", node.getIdentifier(),out);
|
} catch (Exception e) {
|
e.printStackTrace();
|
}
|
}
|
}
|
|
public void Station(String Node, String value) throws Exception {
|
ClientHandler clientHandler=new ClientHandler();
|
String[] parts = Node.split("[.]");
|
switch (value) {
|
case "0": //初始
|
NodeEntity node1= NodeEntity.builder().index(2).identifier(parts[0]+"."+parts[1]+".RecordDataDone")
|
.value("0").type("short").build();
|
Boolean out=clientHandler.write(node1);
|
log.info("节点:{},响应结果:{}", node1.getIdentifier(),out);
|
break;
|
case "1": //请求下发进站状态
|
//进站状态反馈
|
NodeEntity node= NodeEntity.builder().index(2).identifier(parts[0]+"."+parts[1]+".RecordDataDone")
|
.value("11").type("short").build();
|
Boolean out1=clientHandler.write(node);
|
log.info("节点:{},响应结果:{}", node.getIdentifier(),out1);
|
break;
|
case "2": //请求记录工位数据
|
String SNCode = "";
|
String WorkID = "";
|
String PalletID = "";
|
try{
|
if(parts[1].equals("OP1010")){
|
NodeEntity sncode = NodeEntity.builder().index(2).identifier(parts[0]+"."+parts[1]+".StationSNCode").build();
|
SNCode=clientHandler.read(sncode);
|
|
}else {
|
NodeEntity sncode = NodeEntity.builder().index(2).identifier(parts[0]+"."+parts[1]+".SNCode").build();
|
SNCode=clientHandler.read(sncode);
|
}
|
}catch (Exception e){
|
SNCode = "";
|
}
|
NodeEntity grade = NodeEntity.builder().index(2).identifier(parts[0]+"."+parts[1]+".Grade").build();
|
NodeEntity workid = NodeEntity.builder().index(2).identifier(parts[0]+"."+parts[1]+".WorkID").build();
|
NodeEntity palletid = NodeEntity.builder().index(2).identifier(parts[0]+"."+parts[1]+".PalletID").build();
|
NodeEntity stationStatus = NodeEntity.builder().index(2).identifier(parts[0]+"."+parts[1]+".StationStatus").build();
|
NodeEntity inDataTime = NodeEntity.builder().index(2).identifier(parts[0]+"."+parts[1]+".Date_And_Time").build();
|
|
String Grade=clientHandler.read(grade);
|
try {
|
WorkID=clientHandler.read(workid);
|
}catch (Exception e){
|
WorkID = "";
|
}
|
try {
|
PalletID=clientHandler.read(palletid);
|
}catch (Exception e){
|
PalletID = "";
|
}
|
String StationStatus=clientHandler.read(stationStatus);
|
String inDate = clientHandler.read(inDataTime);
|
String ctsDate = DateConvert.getCtsDate(inDate);
|
String WorkOrderNo = "";
|
String MaterialCode = "";
|
ProductionOrdeInfoResult order = getOrder();
|
if(order == null){
|
List<ProductionOrdeInfo> list = orderService.list(new QueryWrapper<ProductionOrdeInfo>().orderByDesc("create_time"));
|
ProductionOrdeInfo info = list.get(0);
|
WorkOrderNo = info.getWorkOrderNo();
|
MaterialCode = info.getMaterialCode();
|
}else {
|
WorkOrderNo = order.getWorkOrderNo();
|
MaterialCode = order.getMaterialCode();
|
}
|
PassingStationCollectionParam param = new PassingStationCollectionParam();
|
param.setWorkOrderNo(WorkOrderNo);
|
param.setSfcCode(SNCode);
|
param.setProductCode(MaterialCode);
|
param.setLocationCode(parts[1]);
|
param.setProductionLine("SOCKET");
|
param.setInboundTime(df.parse(ctsDate));
|
param.setOutboundTime(new Date());
|
String distanceTime = PassingStationCollectionServiceImpl.getDistanceTime(df.format(new Date()), ctsDate);
|
param.setBeatTime(distanceTime);
|
param.setOutRsSign(StationStatus);
|
try {
|
if(parts[1].equals("OP1160")){
|
// if(!SNCode.equals("")){
|
List<ProductionOrdeInfo> list = orderService.list(new QueryWrapper<ProductionOrdeInfo>().eq("order_status","3"));
|
ProductionOrdeInfo productionOrdeInfo = list.get(0);
|
int i = productionOrdeInfo.getActualQty() + 1;
|
if(productionOrdeInfo.getPlanQty() == i){
|
productionOrdeInfo.setOrderStatus("5");
|
}
|
productionOrdeInfo.setActualQty(i);
|
orderService.saveOrUpdate(productionOrdeInfo);
|
// }
|
}
|
}catch (Exception e){
|
|
}
|
service.add(param);
|
|
log.info("SN号:{},员工权限:{},员工ID:{},托盘号:{},站状态:{}",SNCode,Grade,WorkID,PalletID,StationStatus);
|
|
NodeEntity node2= NodeEntity.builder().index(2).identifier(parts[0]+"."+parts[1]+".RecordDataDone")
|
.value("21").type("short").build();
|
Boolean out2=clientHandler.write(node2);
|
log.info("节点:{},响应结果:{}", node2.getIdentifier(),out2);
|
break;
|
default:
|
break;
|
}
|
}
|
|
public ProductionOrdeInfoResult getOrder(){
|
ProductionOrdeInfoParam param = new ProductionOrdeInfoParam();
|
param.setOrderStatus("3");
|
return orderService.findBySpec(param);
|
}
|
}
|
