Skip to content

A
amos-boot-biz
Commit e8c2b830 authored by caotao's avatar caotao
Browse files
Options

1.智能分析后端代码提交

parent 70d1fc45
Show whitespace changes
Inline Side-by-side
Showing with 926 additions and 203 deletions
amos-boot-system-jxiop/amos-boot-module-jxiop-analyse-biz/src/main/java/com/yeejoin/amos/boot/module/jxiop/biz/controller/DemoController.java deleted 100644 → 0
View file @ 70d1fc45
//package com.yeejoin.amos.boot.module.jxiop.biz.controller;
//
//
//import com.alibaba.fastjson.JSON;
//import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
//import com.yeejoin.amos.boot.biz.common.controller.BaseController;
//import com.yeejoin.amos.boot.biz.common.utils.RedisUtils;
//import com.yeejoin.amos.boot.module.jxiop.api.entity.MonitorFanIndicator;
//import com.yeejoin.amos.boot.module.jxiop.api.entity.StationBasic;
//import com.yeejoin.amos.boot.module.jxiop.api.mapper.MonitorFanIndicatorMapper;
//import com.yeejoin.amos.boot.module.jxiop.api.mapper.StationBasicMapper;
//import com.yeejoin.amos.boot.module.jxiop.biz.dto.IndicatorsDto;
//import com.yeejoin.amos.boot.module.jxiop.biz.entity.Test;
//import com.yeejoin.amos.boot.module.jxiop.biz.service.impl.StationBasicServiceImpl;
//import com.yeejoin.amos.boot.module.jxiop.biz.service.impl.TestServiceImpl;
//import com.yeejoin.amos.boot.module.jxiop.biz.utils.InfluxDButils;
//import com.yeejoin.amos.component.influxdb.InfluxDbConnection;
//import io.swagger.annotations.Api;
//import io.swagger.annotations.ApiOperation;
//
//import org.slf4j.Logger;
//import org.slf4j.LoggerFactory;
//import org.springframework.beans.factory.annotation.Autowired;
//import org.springframework.web.bind.annotation.*;
//import org.typroject.tyboot.component.emq.EmqKeeper;
//import org.typroject.tyboot.core.foundation.enumeration.UserType;
//import org.typroject.tyboot.core.restful.doc.TycloudOperation;
//import org.typroject.tyboot.core.restful.utils.ResponseHelper;
//import org.typroject.tyboot.core.restful.utils.ResponseModel;
//
//import java.util.*;
//import java.util.concurrent.TimeUnit;
//
//
//@RestController
//@Api(tags = "Demo-test")
//@RequestMapping(value = "/demo")
//public class DemoController extends BaseController {
// Logger logger = LoggerFactory.getLogger(DemoController.class);
//
// @Autowired
// StationBasicServiceImpl stationBasicServiceimpl;
// @Autowired
// TestServiceImpl testServiceimpl;
//
// @Autowired
// InfluxDbConnection influxDbConnection;
//
// @Autowired
// InfluxDButils influxDButils;
//
// @Autowired
// EmqKeeper emqKeeper;
//
// @Autowired
// private MonitorFanIndicatorMapper monitorFanIndicatorregionMapper;
//
// @TycloudOperation(needAuth = false, ApiLevel = UserType.AGENCY)
// @ApiOperation(value = "demo测试prodcutcion 库")
// @GetMapping("/test")
// public StationBasic demoTest() {
// return stationBasicServiceimpl.getById(1660231556607774721L);
// }
//
// @TycloudOperation(needAuth = false, ApiLevel = UserType.AGENCY)
// @ApiOperation(value = "demo测试中间库")
// @GetMapping("/test1")
// public List<Test> demoTest1() {
// return testServiceimpl.getList();
// }
//
// @TycloudOperation(needAuth = false, ApiLevel = UserType.AGENCY)
// @ApiOperation(value = "demo测试influxdb")
// @GetMapping("/test3")
// public void demoTest2() {
// String sql = "SELECT * FROM indicators_1668801435891929089";
// String sql1 = "SELECT * FROM indicators_1668801570352926721";
// List<IndicatorsDto> list = influxDButils.getListData(sql, IndicatorsDto.class);
// List<IndicatorsDto> list2 = influxDButils.getListData(sql1, IndicatorsDto.class);
// System.out.println(list.size());
// System.out.println(list2.size());
// }
//
// @TycloudOperation(needAuth = false, ApiLevel = UserType.AGENCY)
// @ApiOperation(value = "初始化influxdb-风电、光伏、升压站")
// @GetMapping("/test4")
// public void demoTest3() {
// //数据说明 夏造风电、泰和光伏、夏造升压站、泰和升压站
// String [] strings = {"1668801435891929089","1669524885619085313"};
//// String [] strings = {"1669524885619085313"};
//// Object o=this.monitorFanIndicatorImpl.getIndicatoralueAvage("1668801435891929089","60秒平均风速");
//// System.out.println(o.toString());
// for (int i = 0; i < strings.length; i++) {
// QueryWrapper<MonitorFanIndicator> QueryWrapper = new QueryWrapper<>();
//// 夏造风电
//// QueryWrapper.eq("gateway", "1668801435891929089");
//// 泰和光伏
// QueryWrapper.eq("gateway", strings[i]);
// long DATE = new Date().getTime();
// System.out.println(DATE);
// List<MonitorFanIndicator> list = monitorFanIndicatorregionMapper.selectList(QueryWrapper);
//
// for (MonitorFanIndicator monitorFanIndicator : list) {
// Map<String, String> tag = new HashMap<>();
// Map<String, Object> maps2 = new HashMap<>();
//
// maps2.put("address", monitorFanIndicator.getIndexAddress());
// maps2.put("dataType", monitorFanIndicator.getDataType());
// maps2.put("equipmentSpecificName", monitorFanIndicator.getFanCode());
// tag.put("equipmentsIdx", monitorFanIndicator.getAddressGateway());
// maps2.put("gatewayId", monitorFanIndicator.getGateway());
// maps2.put("isAlarm", monitorFanIndicator.getIsAlarm());
// maps2.put("createdTime", "2023-07-05 18:30:26");
// maps2.put("unit", monitorFanIndicator.getUnit());
// maps2.put("value", "");
// maps2.put("valueLabel","" );
// maps2.put("traceId", "");
// maps2.put("equipmentIndexName", monitorFanIndicator.getIndicator());
// maps2.put("equipmentNumber", monitorFanIndicator.getEquipmentNumber());
// maps2.put("frontModule", monitorFanIndicator.getFrontModule());
// maps2.put("systemType", monitorFanIndicator.getSystemType());
// maps2.put("pictureName", monitorFanIndicator.getPictureName());
// //升压站的字段显示名称
// maps2.put("displayName", "");
// influxDbConnection.insert("indicators_" + monitorFanIndicator.getGateway(), tag, maps2, 1688558007051L, TimeUnit.MILLISECONDS);
// }
// }
//
// }
//
// @TycloudOperation(needAuth = false, ApiLevel = UserType.AGENCY)
// @ApiOperation(value = "测试消息发送")
// @GetMapping("/test5")
// public void demoTest4() {
// HashMap<String, String> hashMap = new HashMap<>();
// hashMap.put("test", String.valueOf(Math.random() * 1000));
// hashMap.put("test1", String.valueOf(Math.random() * 100));
// try {
// emqKeeper.getMqttClient().publish("test_topic", JSON.toJSON(hashMap).toString().getBytes("UTF-8"), 1, true);
// emqKeeper.getMqttClient().publish("test_topic1", JSON.toJSON(hashMap).toString().getBytes("UTF-8"), 1, true);
// logger.info("++++++++++++++++++++++++++++++++++发送消息成功++++++++++++++++++++++++++++++++++++++");
// } catch (Exception exception) {
// logger.error("============================================================发送消息报错");
// }
// }
//
// @TycloudOperation(needAuth = false, ApiLevel = UserType.AGENCY)
// @ApiOperation(value = "初始化升压站")
// @GetMapping("/test6")
// public void demoTest5() {
// //数据说明 夏造风电、泰和光伏、夏造升压站、泰和升压站
// String [] strings = {"1668801570352926721","1669525017559306241"};
//// String [] strings = {"1669525017559306241"};
//// Object o=this.monitorFanIndicatorImpl.getIndicatoralueAvage("1668801435891929089","60秒平均风速");
//// System.out.println(o.toString());
// for (int i = 0; i < strings.length; i++) {
// QueryWrapper<MonitorFanIndicator> QueryWrapper = new QueryWrapper<>();
//// 夏造风电
//// QueryWrapper.eq("gateway", "1668801435891929089");
//// 泰和光伏
// QueryWrapper.eq("gateway", strings[i]);
// long DATE = new Date().getTime();
// System.out.println(DATE);
// List<MonitorFanIndicator> list = monitorFanIndicatorregionMapper.selectList(QueryWrapper);
//
// for (MonitorFanIndicator monitorFanIndicator : list) {
// Map<String, String> tag = new HashMap<>();
// Map<String, Object> maps2 = new HashMap<>();
//
// maps2.put("address", monitorFanIndicator.getIndexAddress());
// maps2.put("dataType", monitorFanIndicator.getDataType());
// maps2.put("equipmentSpecificName", monitorFanIndicator.getFanCode());
// tag.put("equipmentsIdx", monitorFanIndicator.getAddressGateway());
// maps2.put("gatewayId", monitorFanIndicator.getGateway());
// maps2.put("isAlarm", monitorFanIndicator.getIsAlarm());
// maps2.put("createdTime", "2023-07-05 18:30:26");
// maps2.put("unit", monitorFanIndicator.getUnit());
// maps2.put("value", "");
// maps2.put("valueLabel","" );
// maps2.put("traceId", "");
// maps2.put("equipmentIndexName", monitorFanIndicator.getIndicator());
// maps2.put("equipmentNumber", monitorFanIndicator.getEquipmentNumber());
// maps2.put("frontModule", monitorFanIndicator.getFrontModule());
// maps2.put("systemType", monitorFanIndicator.getSystemType());
// maps2.put("pictureName", monitorFanIndicator.getPictureName());
// //升压站的字段显示名称
// maps2.put("displayName", monitorFanIndicator.getEquipmentNumber());
// influxDbConnection.insert("indicators_" + monitorFanIndicator.getGateway(), tag, maps2, 1688558007051L, TimeUnit.MILLISECONDS);
// }
// }
// }
//
// @TycloudOperation(needAuth = false, ApiLevel = UserType.AGENCY)
// @ApiOperation(value = "测试动态图片")
// @GetMapping("/test7")
// public ResponseModel<HashMap<String, String>> demoTest6() {
// HashMap<String, String> hashMap = new HashMap<>();
// hashMap.put("url", "upload/jxiop/amos_studio/758F6F4BC695B777899485DB0C7E5D3.gif");
// return ResponseHelper.buildResponse(hashMap);
// }
//
//}
amos-boot-system-jxiop/amos-boot-module-jxiop-analyse-biz/src/main/java/com/yeejoin/amos/boot/module/jxiop/biz/controller/IdxBizC80cController.java 0 → 100644
View file @ e8c2b830
package com.yeejoin.amos.boot.module.jxiop.biz.controller;
import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
import com.yeejoin.amos.boot.biz.common.controller.BaseController;
import com.yeejoin.amos.boot.module.jxiop.biz.dto.dto.IdxBizC80cDto;
import com.yeejoin.amos.boot.module.jxiop.biz.service.impl.IdxBizC80cServiceImpl;
import io.swagger.annotations.Api;
import io.swagger.annotations.ApiOperation;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.web.bind.annotation.*;
import org.typroject.tyboot.core.foundation.enumeration.UserType;
import org.typroject.tyboot.core.restful.doc.TycloudOperation;
import org.typroject.tyboot.core.restful.utils.ResponseHelper;
import org.typroject.tyboot.core.restful.utils.ResponseModel;
import javax.servlet.http.HttpServletRequest;
import java.util.List;
/**
*
*
* @author system_generator
* @date 2023-08-11
*/
@RestController
@Api(tags = "风电监测变量")
@RequestMapping(value = "/idx-biz-c80-c")
public class IdxBizC80cController extends BaseController {
@Autowired
IdxBizC80cServiceImpl idxBizC80cServiceImpl;
/**
* 新增
*
* @return
*/
@TycloudOperation(ApiLevel = UserType.AGENCY)
@PostMapping(value = "/save")
@ApiOperation(httpMethod = "POST", value = "新增", notes = "新增")
public ResponseModel<IdxBizC80cDto> save(@RequestBody IdxBizC80cDto model) {
model = idxBizC80cServiceImpl.createWithModel(model);
return ResponseHelper.buildResponse(model);
}
/**
* 根据sequenceNbr更新
*
* @param sequenceNbr 主键
* @return
*/
@TycloudOperation(ApiLevel = UserType.AGENCY)
@PutMapping(value = "/{sequenceNbr}")
@ApiOperation(httpMethod = "PUT", value = "根据sequenceNbr更新", notes = "根据sequenceNbr更新")
public ResponseModel<IdxBizC80cDto> updateBySequenceNbrIdxBizC80c(@RequestBody IdxBizC80cDto model,@PathVariable(value = "sequenceNbr") String sequenceNbr) {
model.setSequenceNbr(sequenceNbr);
return ResponseHelper.buildResponse(idxBizC80cServiceImpl.updateWithModel(model));
}
/**
* 根据sequenceNbr删除
*
* @param sequenceNbr 主键
* @return
*/
@TycloudOperation(ApiLevel = UserType.AGENCY)
@DeleteMapping(value = "/{sequenceNbr}")
@ApiOperation(httpMethod = "DELETE", value = "根据sequenceNbr删除", notes = "根据sequenceNbr删除")
public ResponseModel<Boolean> deleteBySequenceNbr(HttpServletRequest request, @PathVariable(value = "sequenceNbr") Long sequenceNbr){
return ResponseHelper.buildResponse(idxBizC80cServiceImpl.removeById(sequenceNbr));
}
/**
* 根据sequenceNbr查询
*
* @param sequenceNbr 主键
* @return
*/
@TycloudOperation(ApiLevel = UserType.AGENCY)
@GetMapping(value = "/{sequenceNbr}")
@ApiOperation(httpMethod = "GET",value = "根据sequenceNbr查询单个", notes = "根据sequenceNbr查询单个")
public ResponseModel<IdxBizC80cDto> selectOne(@PathVariable Long sequenceNbr) {
return ResponseHelper.buildResponse(idxBizC80cServiceImpl.queryBySeq(sequenceNbr));
}
/**
* 列表分页查询
*
* @param current 当前页
* @param current 每页大小
* @return
*/
@TycloudOperation(ApiLevel = UserType.AGENCY)
@GetMapping(value = "/page")
@ApiOperation(httpMethod = "GET",value = "分页查询", notes = "分页查询")
public ResponseModel<Page<IdxBizC80cDto>> queryForPage(@RequestParam(value = "current") int current,@RequestParam
(value = "size") int size) {
Page<IdxBizC80cDto> page = new Page<IdxBizC80cDto>();
page.setCurrent(current);
page.setSize(size);
return ResponseHelper.buildResponse(idxBizC80cServiceImpl.queryForIdxBizC80cPage(page));
}
/**
* 列表全部数据查询
*
* @return
*/
@TycloudOperation(ApiLevel = UserType.AGENCY,needAuth = false)
@ApiOperation(httpMethod = "GET",value = "列表全部数据查询", notes = "列表全部数据查询")
@GetMapping(value = "/list")
public ResponseModel<List<IdxBizC80cDto>> selectForList() {
return ResponseHelper.buildResponse(idxBizC80cServiceImpl.queryForIdxBizC80cList());
}
}
amos-boot-system-jxiop/amos-boot-module-jxiop-analyse-biz/src/main/java/com/yeejoin/amos/boot/module/jxiop/biz/controller/IdxBizHjevController.java 0 → 100644
View file @ e8c2b830
package com.yeejoin.amos.boot.module.jxiop.biz.controller;
import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
import com.yeejoin.amos.boot.biz.common.controller.BaseController;
import com.yeejoin.amos.boot.module.jxiop.biz.dto.dto.IdxBizHjevDto;
import com.yeejoin.amos.boot.module.jxiop.biz.service.impl.IdxBizHjevServiceImpl;
import io.swagger.annotations.Api;
import io.swagger.annotations.ApiOperation;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.web.bind.annotation.*;
import org.typroject.tyboot.core.foundation.enumeration.UserType;
import org.typroject.tyboot.core.restful.doc.TycloudOperation;
import org.typroject.tyboot.core.restful.utils.ResponseHelper;
import org.typroject.tyboot.core.restful.utils.ResponseModel;
import javax.servlet.http.HttpServletRequest;
import java.util.List;
/**
*
*
* @author system_generator
* @date 2023-08-11
*/
@RestController
@Api(tags = "光伏监测变量")
@RequestMapping(value = "/idx-biz-hjev")
public class IdxBizHjevController extends BaseController {
@Autowired
IdxBizHjevServiceImpl idxBizHjevServiceImpl;
/**
* 新增
*
* @return
*/
@TycloudOperation(ApiLevel = UserType.AGENCY)
@PostMapping(value = "/save")
@ApiOperation(httpMethod = "POST", value = "新增", notes = "新增")
public ResponseModel<IdxBizHjevDto> save(@RequestBody IdxBizHjevDto model) {
model = idxBizHjevServiceImpl.createWithModel(model);
return ResponseHelper.buildResponse(model);
}
/**
* 根据sequenceNbr更新
*
* @param sequenceNbr 主键
* @return
*/
@TycloudOperation(ApiLevel = UserType.AGENCY)
@PutMapping(value = "/{sequenceNbr}")
@ApiOperation(httpMethod = "PUT", value = "根据sequenceNbr更新", notes = "根据sequenceNbr更新")
public ResponseModel<IdxBizHjevDto> updateBySequenceNbrIdxBizHjev(@RequestBody IdxBizHjevDto model,@PathVariable(value = "sequenceNbr") String sequenceNbr) {
model.setSequenceNbr(sequenceNbr);
return ResponseHelper.buildResponse(idxBizHjevServiceImpl.updateWithModel(model));
}
/**
* 根据sequenceNbr删除
*
* @param sequenceNbr 主键
* @return
*/
@TycloudOperation(ApiLevel = UserType.AGENCY)
@DeleteMapping(value = "/{sequenceNbr}")
@ApiOperation(httpMethod = "DELETE", value = "根据sequenceNbr删除", notes = "根据sequenceNbr删除")
public ResponseModel<Boolean> deleteBySequenceNbr(HttpServletRequest request, @PathVariable(value = "sequenceNbr") Long sequenceNbr){
return ResponseHelper.buildResponse(idxBizHjevServiceImpl.removeById(sequenceNbr));
}
/**
* 根据sequenceNbr查询
*
* @param sequenceNbr 主键
* @return
*/
@TycloudOperation(ApiLevel = UserType.AGENCY)
@GetMapping(value = "/{sequenceNbr}")
@ApiOperation(httpMethod = "GET",value = "根据sequenceNbr查询单个", notes = "根据sequenceNbr查询单个")
public ResponseModel<IdxBizHjevDto> selectOne(@PathVariable Long sequenceNbr) {
return ResponseHelper.buildResponse(idxBizHjevServiceImpl.queryBySeq(sequenceNbr));
}
/**
* 列表分页查询
*
* @param current 当前页
* @param current 每页大小
* @return
*/
@TycloudOperation(ApiLevel = UserType.AGENCY)
@GetMapping(value = "/page")
@ApiOperation(httpMethod = "GET",value = "分页查询", notes = "分页查询")
public ResponseModel<Page<IdxBizHjevDto>> queryForPage(@RequestParam(value = "current") int current,@RequestParam
(value = "size") int size) {
Page<IdxBizHjevDto> page = new Page<IdxBizHjevDto>();
page.setCurrent(current);
page.setSize(size);
return ResponseHelper.buildResponse(idxBizHjevServiceImpl.queryForIdxBizHjevPage(page));
}
/**
* 列表全部数据查询
*
* @return
*/
@TycloudOperation(ApiLevel = UserType.AGENCY,needAuth = false)
@ApiOperation(httpMethod = "GET",value = "列表全部数据查询", notes = "列表全部数据查询")
@GetMapping(value = "/list")
public ResponseModel<List<IdxBizHjevDto>> selectForList() {
return ResponseHelper.buildResponse(idxBizHjevServiceImpl.queryForIdxBizHjevList());
}
}
amos-boot-system-jxiop/amos-boot-module-jxiop-analyse-biz/src/main/java/com/yeejoin/amos/boot/module/jxiop/biz/controller/TestController.java 0 → 100644
View file @ e8c2b830
package com.yeejoin.amos.boot.module.jxiop.biz.controller;
import com.yeejoin.amos.boot.biz.common.controller.BaseController;
import com.yeejoin.amos.boot.module.jxiop.biz.entity.IdxBizC80c;
import com.yeejoin.amos.boot.module.jxiop.biz.entity.IdxBizHjev;
import com.yeejoin.amos.boot.module.jxiop.biz.service.impl.CommonServiceImpl;
import io.swagger.annotations.Api;
import io.swagger.annotations.ApiOperation;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.web.bind.annotation.*;
import org.typroject.tyboot.core.foundation.enumeration.UserType;
import org.typroject.tyboot.core.restful.doc.TycloudOperation;
import org.typroject.tyboot.core.restful.utils.ResponseHelper;
import org.typroject.tyboot.core.restful.utils.ResponseModel;
import java.util.List;
/**
*
*
* @author system_generator
* @date 2023-08-11
*/
@RestController
@Api(tags = "工况测点测试")
@RequestMapping(value = "/test")
public class TestController extends BaseController {
@Autowired
CommonServiceImpl commonServiceImpl;
/**
* 列表全部数据查询
*
* @return
*/
@TycloudOperation(ApiLevel = UserType.AGENCY,needAuth = false)
@ApiOperation(httpMethod = "GET",value = "列表全部数据查询-风电", notes = "列表全部数据查询")
@GetMapping(value = "/listfan")
public ResponseModel<List<IdxBizC80c>> selectForListFan() {
return ResponseHelper.buildResponse(commonServiceImpl.getAllFanstationTestPoint().subList(0,20));
}
@TycloudOperation(ApiLevel = UserType.AGENCY,needAuth = false)
@ApiOperation(httpMethod = "GET",value = "列表全部数据查询-光伏", notes = "列表全部数据查询")
@GetMapping(value = "/listpv")
public ResponseModel<List<IdxBizHjev>> selectForListPV() {
return ResponseHelper.buildResponse(commonServiceImpl.getAllPVstationTestPoint().subList(0,20));
}
}
amos-boot-system-jxiop/amos-boot-module-jxiop-analyse-biz/src/main/java/com/yeejoin/amos/boot/module/jxiop/biz/dto/IdxBizC80cDto.java 0 → 100644
View file @ e8c2b830
package com.yeejoin.amos.boot.module.jxiop.biz.dto.dto;
import com.baomidou.mybatisplus.annotation.TableField;
import com.baomidou.mybatisplus.annotation.TableId;
import io.swagger.annotations.ApiModel;
import io.swagger.annotations.ApiModelProperty;
import com.yeejoin.amos.boot.biz.common.dto.BaseDto;
import lombok.Data;
import lombok.EqualsAndHashCode;
import java.time.LocalDateTime;
/**
*
*
* @author system_generator
* @date 2023-08-11
*/
@Data
@ApiModel(value="IdxBizC80cDto", description="")
public class IdxBizC80cDto {
private static final long serialVersionUID = 1L;
@TableId("SEQUENCE_NBR")
private String sequenceNbr;
@TableField("RECORD")
private String record;
@TableField("REC_DATE")
private LocalDateTime recDate;
@TableField("REC_USER_ID")
private String recUserId;
@TableField("INSTANCE_ID")
private String instanceId;
@TableField("STATUS")
private String status;
@TableField("CORRELATION_COEFFICIENT")
private Double correlationCoefficient;
@TableField("ANALYSIS_POINT_ID")
private Integer analysisPointId;
@TableField("PROCESS_POINT_ID")
private Integer processPointId;
@ApiModelProperty(value = "片区")
@TableField("ARAE")
private String arae;
@ApiModelProperty(value = "场站")
@TableField("STATION")
private String station;
@ApiModelProperty(value = "子系统")
@TableField("SUB_SYSTEM")
private String subSystem;
@ApiModelProperty(value = "型号")
@TableField("NUMBER")
private String number;
@ApiModelProperty(value = "设备类型")
@TableField("DEVICE_TYPE")
private String deviceType;
@TableField("ANALYSIS_GATEWAY_ID")
private String analysisGatewayId;
@TableField("ANALYSIS_INDEX_ADDRESS")
private String analysisIndexAddress;
@ApiModelProperty(value = "网关ID")
@TableField("PROCESS_GATEWAY_ID")
private String processGatewayId;
@TableField("PROCESS_INDEX_ADDRESS")
private String processIndexAddress;
@ApiModelProperty(value = "设备名称")
@TableField("EQUIPMENT_NAME")
private String equipmentName;
private String fxPointName;
private String gkPointName;
private String functionNum;
}
amos-boot-system-jxiop/amos-boot-module-jxiop-analyse-biz/src/main/java/com/yeejoin/amos/boot/module/jxiop/biz/dto/IdxBizHjevDto.java 0 → 100644
View file @ e8c2b830
package com.yeejoin.amos.boot.module.jxiop.biz.dto.dto;
import com.baomidou.mybatisplus.annotation.TableField;
import com.baomidou.mybatisplus.annotation.TableId;
import io.swagger.annotations.ApiModel;
import io.swagger.annotations.ApiModelProperty;
import com.yeejoin.amos.boot.biz.common.dto.BaseDto;
import lombok.Data;
import lombok.EqualsAndHashCode;
import java.time.LocalDateTime;
/**
*
*
* @author system_generator
* @date 2023-08-11
*/
@Data
@ApiModel(value="IdxBizHjevDto", description="")
public class IdxBizHjevDto {
private static final long serialVersionUID = 1L;
@TableId("SEQUENCE_NBR")
private String sequenceNbr;
@TableField("RECORD")
private String record;
@TableField("REC_DATE")
private LocalDateTime recDate;
@TableField("REC_USER_ID")
private String recUserId;
@TableField("INSTANCE_ID")
private String instanceId;
@TableField("STATUS")
private String status;
@TableField("CORRELATION_COEFFICIENT")
private Double correlationCoefficient;
@TableField("ANALYSIS_POINT_ID")
private Integer analysisPointId;
@TableField("PROCESS_POINT_ID")
private Integer processPointId;
@ApiModelProperty(value = "片区")
@TableField("ARAE")
private String arae;
@ApiModelProperty(value = "场站")
@TableField("STATION")
private String station;
@ApiModelProperty(value = "设备名称")
@TableField("RQUIPMENT_NAME")
private String rquipmentName;
@ApiModelProperty(value = "子阵")
@TableField("SUBARRAY")
private String subarray;
@ApiModelProperty(value = "厂商")
@TableField("MANUFACTURER")
private String manufacturer;
@ApiModelProperty(value = "设备类型")
@TableField("DEVICE_TYPE")
private String deviceType;
@ApiModelProperty(value = "网关ID")
@TableField("ANALYSIS_GATEWAY_ID")
private String analysisGatewayId;
@ApiModelProperty(value = "点表地址")
@TableField("ANALYSIS_INDEX_ADDRESS")
private Integer analysisIndexAddress;
@ApiModelProperty(value = "网关ID")
@TableField("PROCESS_GATEWAY_ID")
private String processGatewayId;
@ApiModelProperty(value = "点表地址")
@TableField("PROCESS_INDEX_ADDRESS")
private Integer processIndexAddress;
}
amos-boot-system-jxiop/amos-boot-module-jxiop-analyse-biz/src/main/java/com/yeejoin/amos/boot/module/jxiop/biz/entity/IdxBizC80c.java 0 → 100644
View file @ e8c2b830
package com.yeejoin.amos.boot.module.jxiop.biz.entity;
import com.baomidou.mybatisplus.annotation.TableField;
import com.baomidou.mybatisplus.annotation.TableName;
import lombok.Data;
import lombok.experimental.Accessors;
import org.joda.time.LocalDateTime;
/**
*
*
* @author system_generator
* @date 2023-08-11
*/
@Data
@Accessors(chain = true)
@TableName("idx_biz_c80c")
public class IdxBizC80c {
private static final long serialVersionUID = 1L;
/**
*
*/
@TableField("SEQUENCE_NBR")
private String sequenceNbr;
/**
*
*/
@TableField("RECORD")
private String record;
/**
*
*/
@TableField("REC_DATE")
private LocalDateTime recDate;
/**
*
*/
@TableField("REC_USER_ID")
private String recUserId;
/**
*
*/
@TableField("INSTANCE_ID")
private String instanceId;
/**
*
*/
@TableField("STATUS")
private String status;
/**
*
*/
@TableField("CORRELATION_COEFFICIENT")
private Double correlationCoefficient;
/**
*
*/
@TableField("ANALYSIS_POINT_ID")
private Integer analysisPointId;
/**
*
*/
@TableField("PROCESS_POINT_ID")
private Integer processPointId;
/**
* 片区
*/
@TableField("ARAE")
private String arae;
/**
* 场站
*/
@TableField("STATION")
private String station;
/**
* 子系统
*/
@TableField("SUB_SYSTEM")
private String subSystem;
/**
* 型号
*/
@TableField("NUMBER")
private String number;
/**
* 设备类型
*/
@TableField("DEVICE_TYPE")
private String deviceType;
/**
*
*/
@TableField("ANALYSIS_GATEWAY_ID")
private String analysisGatewayId;
/**
*
*/
@TableField("ANALYSIS_INDEX_ADDRESS")
private String analysisIndexAddress;
/**
* 网关ID
*/
@TableField("PROCESS_GATEWAY_ID")
private String processGatewayId;
/**
*
*/
@TableField("PROCESS_INDEX_ADDRESS")
private String processIndexAddress;
/**
* 设备名称
*/
@TableField("EQUIPMENT_NAME")
private String equipmentName;
/**
*
*/
@TableField("fx_point_name")
private String fxPointName;
/**
*
*/
@TableField("gk_point_name")
private String gkPointName;
/**
*
*/
@TableField("function_num")
private String functionNum;
}
amos-boot-system-jxiop/amos-boot-module-jxiop-analyse-biz/src/main/java/com/yeejoin/amos/boot/module/jxiop/biz/entity/IdxBizHjev.java 0 → 100644
View file @ e8c2b830
package com.yeejoin.amos.boot.module.jxiop.biz.entity;
import com.baomidou.mybatisplus.annotation.TableField;
import com.baomidou.mybatisplus.annotation.TableName;
import lombok.Data;
import lombok.experimental.Accessors;
import org.joda.time.LocalDateTime;
/**
*
*
* @author system_generator
* @date 2023-08-11
*/
@Data
@Accessors(chain = true)
@TableName("idx_biz_hjev")
public class IdxBizHjev {
private static final long serialVersionUID = 1L;
/**
*
*/
@TableField("SEQUENCE_NBR")
private String sequenceNbr;
/**
*
*/
@TableField("RECORD")
private String record;
/**
*
*/
@TableField("REC_DATE")
private LocalDateTime recDate;
/**
*
*/
@TableField("REC_USER_ID")
private String recUserId;
/**
*
*/
@TableField("INSTANCE_ID")
private String instanceId;
/**
*
*/
@TableField("STATUS")
private String status;
/**
*
*/
@TableField("CORRELATION_COEFFICIENT")
private Double correlationCoefficient;
/**
*
*/
@TableField("ANALYSIS_POINT_ID")
private Integer analysisPointId;
/**
*
*/
@TableField("PROCESS_POINT_ID")
private Integer processPointId;
/**
* 片区
*/
@TableField("ARAE")
private String arae;
/**
* 场站
*/
@TableField("STATION")
private String station;
/**
* 设备名称
*/
@TableField("RQUIPMENT_NAME")
private String rquipmentName;
/**
* 子阵
*/
@TableField("SUBARRAY")
private String subarray;
/**
* 厂商
*/
@TableField("MANUFACTURER")
private String manufacturer;
/**
* 设备类型
*/
@TableField("DEVICE_TYPE")
private String deviceType;
/**
* 网关ID
*/
@TableField("ANALYSIS_GATEWAY_ID")
private String analysisGatewayId;
/**
* 点表地址
*/
@TableField("ANALYSIS_INDEX_ADDRESS")
private Integer analysisIndexAddress;
/**
* 网关ID
*/
@TableField("PROCESS_GATEWAY_ID")
private String processGatewayId;
/**
* 点表地址
*/
@TableField("PROCESS_INDEX_ADDRESS")
private Integer processIndexAddress;
}
amos-boot-system-jxiop/amos-boot-module-jxiop-analyse-biz/src/main/java/com/yeejoin/amos/boot/module/jxiop/biz/mapper2/IdxBizC80cMapper.java 0 → 100644
View file @ e8c2b830
package com.yeejoin.amos.boot.module.jxiop.biz.mapper2;
import com.baomidou.mybatisplus.core.mapper.BaseMapper;
import com.yeejoin.amos.boot.module.jxiop.biz.entity.IdxBizC80c;
/**
* Mapper 接口
*
* @author system_generator
* @date 2023-08-11
*/
public interface IdxBizC80cMapper extends BaseMapper<IdxBizC80c> {
}
amos-boot-system-jxiop/amos-boot-module-jxiop-analyse-biz/src/main/java/com/yeejoin/amos/boot/module/jxiop/biz/mapper2/IdxBizHjevMapper.java 0 → 100644
View file @ e8c2b830
package com.yeejoin.amos.boot.module.jxiop.biz.mapper2;
import com.baomidou.mybatisplus.core.mapper.BaseMapper;
import com.yeejoin.amos.boot.module.jxiop.biz.entity.IdxBizHjev;
/**
* Mapper 接口
*
* @author system_generator
* @date 2023-08-11
*/
public interface IdxBizHjevMapper extends BaseMapper<IdxBizHjev> {
}
amos-boot-system-jxiop/amos-boot-module-jxiop-analyse-biz/src/main/java/com/yeejoin/amos/boot/module/jxiop/biz/service/IIdxBizC80cService.java 0 → 100644
View file @ e8c2b830
package com.yeejoin.amos.boot.module.jxiop.biz.service;
/**
* 接口类
*
* @author system_generator
* @date 2023-08-11
*/
public interface IIdxBizC80cService {
}
amos-boot-system-jxiop/amos-boot-module-jxiop-analyse-biz/src/main/java/com/yeejoin/amos/boot/module/jxiop/biz/service/IIdxBizHjevService.java 0 → 100644
View file @ e8c2b830
package com.yeejoin.amos.boot.module.jxiop.biz.service;
/**
* 接口类
*
* @author system_generator
* @date 2023-08-11
*/
public interface IIdxBizHjevService {
}
amos-boot-system-jxiop/amos-boot-module-jxiop-analyse-biz/src/main/java/com/yeejoin/amos/boot/module/jxiop/biz/service/impl/CommonServiceImpl.java 0 → 100644
View file @ e8c2b830
package com.yeejoin.amos.boot.module.jxiop.biz.service.impl;
import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
import com.yeejoin.amos.boot.module.jxiop.biz.entity.IdxBizC80c;
import com.yeejoin.amos.boot.module.jxiop.biz.entity.IdxBizHjev;
import com.yeejoin.amos.boot.module.jxiop.biz.mapper2.IdxBizC80cMapper;
import com.yeejoin.amos.boot.module.jxiop.biz.mapper2.IdxBizHjevMapper;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;
import java.util.ArrayList;
import java.util.List;
@Service
public class CommonServiceImpl {
@Autowired
private IdxBizC80cMapper idxBizC80cMapper;
@Autowired
private IdxBizHjevMapper idxBizHjevMapper;
public List<IdxBizC80c> getAllFanstationTestPoint(){
List<IdxBizC80c> idxBizC80cList = new ArrayList<>();
idxBizC80cList = idxBizC80cMapper.selectList(new QueryWrapper<IdxBizC80c>().isNotNull("SEQUENCE_NBR"));
return idxBizC80cList;
}
public List<IdxBizHjev> getAllPVstationTestPoint(){
List<IdxBizHjev> idxBizC80cList = new ArrayList<>();
idxBizC80cList = idxBizHjevMapper.selectList(new QueryWrapper<IdxBizHjev>().isNotNull("SEQUENCE_NBR"));
return idxBizC80cList;
}
}
amos-boot-system-jxiop/amos-boot-module-jxiop-analyse-biz/src/main/java/com/yeejoin/amos/boot/module/jxiop/biz/service/impl/IdxBizC80cServiceImpl.java 0 → 100644
View file @ e8c2b830
package com.yeejoin.amos.boot.module.jxiop.biz.service.impl;
import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
import com.yeejoin.amos.boot.module.jxiop.biz.dto.dto.IdxBizC80cDto;
import com.yeejoin.amos.boot.module.jxiop.biz.entity.IdxBizC80c;
import com.yeejoin.amos.boot.module.jxiop.biz.mapper2.IdxBizC80cMapper;
import com.yeejoin.amos.boot.module.jxiop.biz.service.IIdxBizC80cService;
import org.springframework.stereotype.Service;
import org.typroject.tyboot.core.rdbms.service.BaseService;
import java.util.List;
/**
* 服务实现类
*
* @author system_generator
* @date 2023-08-11
*/
@Service
public class IdxBizC80cServiceImpl extends BaseService<IdxBizC80cDto, IdxBizC80c, IdxBizC80cMapper> implements IIdxBizC80cService {
/**
* 分页查询
*/
public Page<IdxBizC80cDto> queryForIdxBizC80cPage(Page<IdxBizC80cDto> page) {
return this.queryForPage(page, null, false);
}
/**
* 列表查询 示例
*/
public List<IdxBizC80cDto> queryForIdxBizC80cList() {
return this.queryForList("" , false);
}
}
\ No newline at end of file
amos-boot-system-jxiop/amos-boot-module-jxiop-analyse-biz/src/main/java/com/yeejoin/amos/boot/module/jxiop/biz/service/impl/IdxBizHjevServiceImpl.java 0 → 100644
View file @ e8c2b830
package com.yeejoin.amos.boot.module.jxiop.biz.service.impl;
import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
import com.yeejoin.amos.boot.module.jxiop.biz.dto.dto.IdxBizHjevDto;
import com.yeejoin.amos.boot.module.jxiop.biz.entity.IdxBizHjev;
import com.yeejoin.amos.boot.module.jxiop.biz.mapper2.IdxBizHjevMapper;
import com.yeejoin.amos.boot.module.jxiop.biz.service.IIdxBizHjevService;
import org.springframework.stereotype.Service;
import org.typroject.tyboot.core.rdbms.service.BaseService;
import java.util.List;
/**
* 服务实现类
*
* @author system_generator
* @date 2023-08-11
*/
@Service
public class IdxBizHjevServiceImpl extends BaseService<IdxBizHjevDto, IdxBizHjev, IdxBizHjevMapper> implements IIdxBizHjevService {
/**
* 分页查询
*/
public Page<IdxBizHjevDto> queryForIdxBizHjevPage(Page<IdxBizHjevDto> page) {
return this.queryForPage(page, null, false);
}
/**
* 列表查询 示例
*/
public List<IdxBizHjevDto> queryForIdxBizHjevList() {
return this.queryForList("" , false);
}
}
\ No newline at end of file
amos-boot-system-jxiop/amos-boot-module-jxiop-analyse-biz/src/main/resources/application-dev.properties
View file @ e8c2b830
......@@ -7,7 +7,7 @@ spring.db1.datasource.password=Yeejoin@2020
spring.db1.datasource.driver-class-name: com.mysql.cj.jdbc.Driver
## db2-sync_data
spring.db2.datasource.type: com.alibaba.druid.pool.DruidDataSource
spring.db2.datasource.url=jdbc:mysql://39.98.223.23:3306/jxiop_sync_data?allowMultiQueries=true&serverTimezone=GMT%2B8&characterEncoding=utf8
spring.db2.datasource.url=jdbc:mysql://172.16.10.220:3306/yeeamos_amos_idx_biz?allowMultiQueries=true&serverTimezone=GMT%2B8&characterEncoding=utf8
spring.db2.datasource.username=root
spring.db2.datasource.password=Yeejoin@2020
spring.db2.datasource.driver-class-name: com.mysql.cj.jdbc.Driver
......
amos-boot-system-jxiop/amos-boot-module-jxiop-analyse-biz/src/main/resources/mapper/cluster/IdxBizC80cMapper.xml 0 → 100644
View file @ e8c2b830
<?xml version="1.0" encoding="UTF-8"?>
<!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" "http://mybatis.org/dtd/mybatis-3-mapper.dtd">
<mapper namespace="com.yeejoin.amos.boot.module.jxiop.biz.entity.IdxBizC80c">
</mapper>
amos-boot-system-jxiop/amos-boot-module-jxiop-analyse-biz/src/main/resources/mapper/cluster/IdxBizHjevMapper.xml 0 → 100644
View file @ e8c2b830
<?xml version="1.0" encoding="UTF-8"?>
<!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" "http://mybatis.org/dtd/mybatis-3-mapper.dtd">
<mapper namespace="com.yeejoin.amos.boot.module.jxiop.biz.entity.IdxBizHjev">
</mapper>
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment