| | |
| | | package com.whyc.service; |
| | | |
| | | import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper; |
| | | import com.baomidou.mybatisplus.core.conditions.update.UpdateWrapper; |
| | | import com.baomidou.mybatisplus.core.toolkit.Wrappers; |
| | | import com.github.pagehelper.PageHelper; |
| | | import com.github.pagehelper.PageInfo; |
| | |
| | | import org.springframework.stereotype.Service; |
| | | |
| | | import javax.annotation.Resource; |
| | | import java.util.HashMap; |
| | | import java.util.LinkedList; |
| | | import java.util.List; |
| | | import java.util.Map; |
| | | |
| | | /** |
| | | * Oil通讯 |
| | |
| | | } |
| | | } |
| | | |
| | | public Response<Map<String, List>> getField() { |
| | | Map<String,List> fieldMap = new HashMap(); |
| | | List<String> fieldNames = new LinkedList(); |
| | | fieldNames.add("油站回油温度"); |
| | | fieldNames.add("润滑油出口流量"); |
| | | fieldNames.add("润滑油压力1"); |
| | | fieldNames.add("润滑油压力2"); |
| | | fieldNames.add("油站出口1压力"); |
| | | fieldNames.add("油站出口2压力"); |
| | | fieldNames.add("油站出口3压力"); |
| | | fieldNames.add("油站出口4压力"); |
| | | fieldNames.add("润滑油回油流量"); |
| | | fieldNames.add("油站冷却水压力"); |
| | | fieldNames.add("油站冷却水回水温度"); |
| | | fieldNames.add("油站出油温度"); |
| | | |
| | | List<String> fieldValues = new LinkedList(); |
| | | fieldValues.add("oil_returnTmp"); |
| | | fieldValues.add("oil_outFlow"); |
| | | fieldValues.add("oil_pre1"); |
| | | fieldValues.add("oil_pre2"); |
| | | fieldValues.add("oil_outpre1"); |
| | | fieldValues.add("oil_outpre2"); |
| | | fieldValues.add("oil_outpre3"); |
| | | fieldValues.add("oil_outpre4"); |
| | | fieldValues.add("oil_returnFlow"); |
| | | fieldValues.add("oil_coolpre"); |
| | | fieldValues.add("oil_coolTmp"); |
| | | fieldValues.add("oil_outTmp"); |
| | | |
| | | fieldMap.put("fieldNames",fieldNames); |
| | | fieldMap.put("fieldValues",fieldValues); |
| | | return new Response<Map<String,List>>().set(1,fieldMap); |
| | | } |
| | | |
| | | public Response<PageInfo<OilComm>> getHistory(int pageNum, int pageSize, int devId) { |
| | | List<String> tableNames = commonMapper.getTableName("db_3.5mw_motor_history", "tb_oil_comm_" + devId); |
| | | PageHelper.startPage(pageNum,pageSize); |
| | |
| | | PageInfo<OilComm> oilCommPageInfo = new PageInfo<>(oilComms); |
| | | return new Response<PageInfo<OilComm>>().set(1,oilCommPageInfo); |
| | | } |
| | | |
| | | public Response updateStatus(int devId, int oilState) { |
| | | UpdateWrapper<OilComm> wrapper = Wrappers.update(); |
| | | wrapper.set("oil_state",oilState).eq("dev_id",devId); |
| | | |
| | | mapper.update(null,wrapper); |
| | | return new Response().setMsg(1,"更新成功"); |
| | | } |
| | | } |