| | |
|---|
| | | 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); |
|---|
| | |
|---|
| | | }) |
|---|
| | | @GetMapping(path = "bingRecords/{monitoringId}") |
|---|
| | | @SsoAop() |
|---|
| | | public BaseResponse<List<Map<String, Object>>> getBingRecordsByMonitoringId(@PathVariable("monitoringId") Long monitoringId) { |
|---|
| | | public BaseResponse<List<Map<String, Object>>> getBingRecordsByMonitoringId(@PathVariable("monitoringId") String monitoringId) { |
|---|
| | | try { |
|---|
| | | List<Map<String, Object>> list = Optional.ofNullable(moniFlowSv.getBingRecordsByMonitoringId(monitoringId)).orElse(new ArrayList<>()); |
|---|
| | | if (list.size() <= 0) { |
|---|
