|  |  |  | 
|---|
|  |  |  | 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); | 
|---|