|
|
@@ -10,9 +10,11 @@ import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
|
|
|
import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
|
|
|
import com.tuoren.web.layer.d0.PumpRemoveRequestDTO;
|
|
|
import com.tuoren.web.layer.d0.PumpVo;
|
|
|
+import com.tuoren.web.layer.entity.BusPatientEntity;
|
|
|
import com.tuoren.web.layer.entity.BusPumpEntity;
|
|
|
import com.tuoren.web.layer.entity.BusReceiveRecordCopyEntity;
|
|
|
import com.tuoren.web.layer.entity.BusReceiveRecordEntity;
|
|
|
+import com.tuoren.web.layer.mapper.BusPatientMapper;
|
|
|
import com.tuoren.web.layer.mapper.BusPumpMapper;
|
|
|
import com.tuoren.web.layer.mapper.BusReceiveRecordCopyMapper;
|
|
|
import com.tuoren.web.layer.mapper.BusReceiveRecordMapper;
|
|
|
@@ -48,6 +50,8 @@ public class BusPumpServiceImpl extends ServiceImpl<BusPumpMapper, BusPumpEntity
|
|
|
|
|
|
@Autowired
|
|
|
BusReceiveRecordCopyMapper busReceiveRecordCopyMapper;
|
|
|
+ @Autowired
|
|
|
+ private BusPatientMapper busPatientMapper;
|
|
|
|
|
|
@Autowired
|
|
|
@Lazy
|
|
|
@@ -227,6 +231,14 @@ public class BusPumpServiceImpl extends ServiceImpl<BusPumpMapper, BusPumpEntity
|
|
|
.collect(Collectors.groupingBy(BusPumpEntity::getHospitalCode));
|
|
|
|
|
|
this.updateBatchById(pumps);
|
|
|
+ //更新患者信息
|
|
|
+ pumpMap.forEach((k,v)->{
|
|
|
+ v.forEach(p->{
|
|
|
+ busPatientMapper.updateUndoPeronBuPumpCode(requestDTO.getRemoveUser(),p.getPumpCode());
|
|
|
+ });
|
|
|
+
|
|
|
+ });
|
|
|
+
|
|
|
try {
|
|
|
//下发
|
|
|
rabbitHandle.sendRemovePump(pumpMap);
|