opt:优化出入烘箱时重复更新代码(根据code根据可能导致表锁)
This commit is contained in:
@@ -131,7 +131,6 @@ public class HotPointIvtServiceImpl implements HotPointIvtService {
|
|||||||
}
|
}
|
||||||
|
|
||||||
@Override
|
@Override
|
||||||
@Transactional(rollbackFor = Exception.class)
|
|
||||||
public void update(HotPointIvtDto dto) {
|
public void update(HotPointIvtDto dto) {
|
||||||
HotPointIvtDto entity = this.findById(dto.getIvt_id());
|
HotPointIvtDto entity = this.findById(dto.getIvt_id());
|
||||||
if (entity == null) {
|
if (entity == null) {
|
||||||
|
|||||||
@@ -208,10 +208,6 @@ public class InHotTask extends AbstractAcsTask {
|
|||||||
log.info("入烘箱wql执行update语句!");
|
log.info("入烘箱wql执行update语句!");
|
||||||
hotIvtTab.update(jsonHotIvt);
|
hotIvtTab.update(jsonHotIvt);
|
||||||
|
|
||||||
log.info("入烘箱mybatis执行update语句!");
|
|
||||||
HotMapper hotMapper = SpringContextHolder.getBean(HotMapper.class);
|
|
||||||
hotMapper.updateHotByObject(jsonHotIvt);
|
|
||||||
|
|
||||||
hot_point_code = jsonHotIvt.getString("ext_code");
|
hot_point_code = jsonHotIvt.getString("ext_code");
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|||||||
@@ -188,18 +188,6 @@ public class OutHotTask extends AbstractAcsTask {
|
|||||||
|
|
||||||
log.info("出烘箱wql执行update语句!");
|
log.info("出烘箱wql执行update语句!");
|
||||||
hotIvtTab.update(jsonHotIvt);
|
hotIvtTab.update(jsonHotIvt);
|
||||||
JSONObject update_ivt = hotIvtTab.query("point_code = '" + jsonTask.getString("point_code1") + "'").uniqueResult(0);
|
|
||||||
log.info("更新完后烘箱库存为:-----------------" + update_ivt.toString());
|
|
||||||
|
|
||||||
log.info("出烘箱mybatis执行update语句!");
|
|
||||||
HotMapper hotMapper = SpringContextHolder.getBean(HotMapper.class);
|
|
||||||
hotMapper.updateHotByObject(jsonHotIvt);
|
|
||||||
JSONObject update_ivt2 = hotIvtTab.query("point_code = '" + jsonTask.getString("point_code1") + "'").uniqueResult(0);
|
|
||||||
log.info("更新完后烘箱库存为:-----------------" + update_ivt2.toString());
|
|
||||||
|
|
||||||
if (!update_ivt2.getString("container_name").equals(update_ivt.getString("container_name"))) {
|
|
||||||
log.info("出烘箱WQL更新不成功!");
|
|
||||||
}
|
|
||||||
|
|
||||||
// 将出烘箱信息发送给mes
|
// 将出烘箱信息发送给mes
|
||||||
JSONObject param = new JSONObject();
|
JSONObject param = new JSONObject();
|
||||||
|
|||||||
Reference in New Issue
Block a user