|
@@ -56,6 +56,7 @@ public class BilletBasicInfoServiceImpl extends ServiceImpl<BilletBasicInfoMappe
|
|
|
log.info("{}{}", "start钢坯基础信息接收到mqtt消息,开始处理逻辑:", DateUtils.date2Str(new Date(), DateUtils.datetimeFormat.get()));
|
|
|
String classShiftGroup = String.format("class:shift:group:%s", billetBasicInfo.getCcmNo()); // 班组
|
|
|
String classShift = String.format("class:shift:%s", billetBasicInfo.getCcmNo()); // 班别
|
|
|
+ String brandNum = String.format("billet:basic:info:brand:num:%s", billetBasicInfo.getCcmNo()); // 牌号
|
|
|
String classShiftStr = !oConvertUtils.getString(redisTemplate.opsForValue().get(classShift)).isEmpty() ? oConvertUtils.getString(redisTemplate.opsForValue().get(classShift)) : "";
|
|
|
String classShiftGroupStr = !oConvertUtils.getString(redisTemplate.opsForValue().get(classShiftGroup)).isEmpty() ? oConvertUtils.getString(redisTemplate.opsForValue().get(classShiftGroup)) : "";
|
|
|
log.info("{}{}", "钢坯实绩接收时缓存中的班组班别:", classShiftGroupStr + " " + classShiftStr);
|
|
@@ -88,6 +89,7 @@ public class BilletBasicInfoServiceImpl extends ServiceImpl<BilletBasicInfoMappe
|
|
|
// 新增数据
|
|
|
billetBasicInfo.setBilletWeight(weight);
|
|
|
billetBasicInfo.setShift(classShiftStr);
|
|
|
+ billetBasicInfo.setBrandNum(brandNum);
|
|
|
billetBasicInfo.setShiftGroup(classShiftGroupStr);
|
|
|
|
|
|
log.info("{}{}", "新增钢坯实绩时班组班别:", billetBasicInfo.getShiftGroup() + " " + billetBasicInfo.getShift());
|