| | |
| | | import com.dy.common.webUtil.BaseResponseUtils; |
| | | import com.dy.common.webUtil.ResultCodeMsg; |
| | | import com.dy.pipIrrGlobal.pojoPr.PrFlowMonitoring; |
| | | import com.dy.pipIrrGlobal.pojoPr.PrFlowmeter; |
| | | import com.dy.pipIrrGlobal.pojoPr.PrMonitoringFlowmeter; |
| | | import com.dy.pipIrrProject.result.ProjectResultCode; |
| | | import io.swagger.v3.oas.annotations.Operation; |
| | |
| | | prMonitoringFlowmeter.setOperatedt(operateTime); |
| | | prMonitoringFlowmeter.setOperatetype((byte) 1); |
| | | |
| | | PrFlowmeter flowmeter = new PrFlowmeter(); |
| | | flowmeter.setMonitoringId(po.getMonitoringId().toString()); |
| | | flowmeter.setId(po.getFlowmeterId()); |
| | | flowmeter.setOperator(po.getOperator()); |
| | | flowmeter.setOperateDt(operateTime); |
| | | Integer shu = flowmeterSv.flowmeterAddMonId(flowmeter); |
| | | |
| | | Integer rec = Optional.ofNullable(moniFlowSv.addRecord(prMonitoringFlowmeter)).orElse(0); |
| | | if (rec == 0) { |
| | | if (rec == 0 || shu == 0) { |
| | | return BaseResponseUtils.buildFail(ProjectResultCode.MONITORING_FLOWMETER_BIND_FAIL.getMessage()); |
| | | } |
| | | return BaseResponseUtils.buildSuccess(true); |
| | |
| | | PrMonitoringFlowmeter prMonitoringFlowmeter = DtoToMoniFlowPojo.INSTANCT.po2vo(po); |
| | | Date operateTime = new Date(); |
| | | prMonitoringFlowmeter.setOperatedt(operateTime); |
| | | prMonitoringFlowmeter.setOperatetype((byte) 1); |
| | | prMonitoringFlowmeter.setOperatetype((byte) 2); |
| | | |
| | | PrFlowmeter flowmeter = new PrFlowmeter(); |
| | | flowmeter.setMonitoringId(null); |
| | | flowmeter.setId(po.getFlowmeterId()); |
| | | flowmeter.setOperator(po.getOperator()); |
| | | flowmeter.setOperateDt(operateTime); |
| | | Integer shu = flowmeterSv.flowmeterAddMonId(flowmeter); |
| | | |
| | | Integer rec = Optional.ofNullable(moniFlowSv.addRecord(prMonitoringFlowmeter)).orElse(0); |
| | | if (rec == 0) { |
| | | if (rec == 0 || shu == 0) { |
| | | return BaseResponseUtils.buildFail(ProjectResultCode.MONITORING_FLOWMETER_BIND_FAIL.getMessage()); |
| | | } |
| | | return BaseResponseUtils.buildSuccess(true); |