|
@@ -80,7 +80,7 @@ public class BilletSendRecordServiceImpl extends ServiceImpl<BilletSendRecordMap
|
|
|
log.info("开始处理未完成推送的炉次,共计 {} 条", heatsActuals.size());
|
|
|
|
|
|
for (HeatsActuals heatsActual : heatsActuals) {
|
|
|
- log.info("处理炉次:{}", heatsActual.getHeatsCode());
|
|
|
+// log.info("处理炉次:{}", heatsActual.getHeatsCode());
|
|
|
sendFromHeatsActuals(heatsActual);
|
|
|
}
|
|
|
}
|
|
@@ -125,15 +125,15 @@ public class BilletSendRecordServiceImpl extends ServiceImpl<BilletSendRecordMap
|
|
|
List<String> billetsToPush = filterAlreadyPushedBillets(heatNo, request.getRollNo(), length, transportTypeStr, billets);
|
|
|
|
|
|
if (billetsToPush.isEmpty()) {
|
|
|
- log.info("炉次:{},分组:{} 长度:{} 送坯方式:{},无新增钢坯可推送", heatNo, belongTable, length, transportTypeStr);
|
|
|
+// log.info("炉次:{},分组:{} 长度:{} 送坯方式:{},无新增钢坯可推送", heatNo, belongTable, length, transportTypeStr);
|
|
|
continue;
|
|
|
}
|
|
|
|
|
|
BilletSendRequest.SizeData sizeData = buildSizeData(length, transportTypeStr, billets, billetsToPush);
|
|
|
sizeDataList.add(sizeData);
|
|
|
|
|
|
- log.info("准备推送炉次:{},分组:{},长度:{},送坯方式:{},数量:{}",
|
|
|
- heatNo, belongTable, length, transportTypeStr, billetsToPush.size());
|
|
|
+// log.info("准备推送炉次:{},分组:{},长度:{},送坯方式:{},数量:{}",
|
|
|
+// heatNo, belongTable, length, transportTypeStr, billetsToPush.size());
|
|
|
|
|
|
|
|
|
newPushedCount += billetsToPush.size();
|
|
@@ -163,7 +163,7 @@ public class BilletSendRecordServiceImpl extends ServiceImpl<BilletSendRecordMap
|
|
|
heatsActualsMapper.update(null, updateWrapper);
|
|
|
log.info("炉次 {} 所有钢坯已完成推送,更新 complete_status 为 0", heatNo);
|
|
|
} else {
|
|
|
- log.info("炉次 {} 当前推送进度:历史 {} + 本次 {} / 总数 {}", heatNo, historyPushedCount, newPushedCount, totalBilletCount);
|
|
|
+// log.info("炉次 {} 当前推送进度:历史 {} + 本次 {} / 总数 {}", heatNo, historyPushedCount, newPushedCount, totalBilletCount);
|
|
|
}
|
|
|
|
|
|
return allResponses;
|
|
@@ -298,7 +298,7 @@ public class BilletSendRecordServiceImpl extends ServiceImpl<BilletSendRecordMap
|
|
|
|
|
|
BilletSendResponse body = response.getBody();
|
|
|
saveSendRecord(body, request);
|
|
|
- log.info("推送成功,响应信息: {}", body);
|
|
|
+// log.info("推送成功,响应信息: {}", body);
|
|
|
|
|
|
return body;
|
|
|
} catch (Exception e) {
|