/** * Copyright 2019 DH * All right reserved. * 项目名称: 大恒泰山系统 * 创建日期:2022/8/22 */ package org.springblade.etl.controller; import cn.hutool.core.date.DateUtil; import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper; import com.baomidou.mybatisplus.core.toolkit.Wrappers; import com.github.xiaoymin.knife4j.annotations.ApiOperationSupport; import io.swagger.annotations.Api; import io.swagger.annotations.ApiOperation; import lombok.AllArgsConstructor; import lombok.extern.slf4j.Slf4j; import org.springblade.core.boot.ctrl.BladeController; import org.springblade.core.mp.support.Condition; import org.springblade.core.tool.api.R; import org.springblade.core.tool.jackson.JsonUtil; import org.springblade.core.tool.utils.Func; import org.springblade.enums.EquipmentStatusEnum; import org.springblade.etl.entity.EtlRainDataEntity; import org.springblade.etl.entity.EtlRsvrDataEntity; import org.springblade.etl.service.IEtlRainDataService; import org.springblade.modules.baseinfo.org.service.IBaseInfoOrgService; import org.springblade.modules.baseinfo.project.entity.ProjectInfoEntity; import org.springblade.modules.baseinfo.project.vo.ProjectInfoVO; import org.springblade.modules.baseinfo.project.wrapper.ProjectInfoWrapper; import org.springblade.modules.baseinfo.rtu.entity.RtuInfoEntity; import org.springblade.modules.baseinfo.rtu.service.IRtuBaseInfoService; import org.springblade.modules.business.data.entity.RtuDataGroundEntity; import org.springblade.modules.business.data.entity.RtuDataRainEntity; import org.springblade.modules.business.data.entity.RtuDataRiverEntity; import org.springblade.modules.business.data.entity.RtuDataRsvrEntity; import org.springblade.modules.business.rtumanage.entity.RtuStatusEntity; import org.springblade.modules.business.warning.entity.RtuWarningInfoEntity; import org.springblade.modules.system.entity.DictBiz; import org.springblade.modules.system.service.IDeptService; import org.springframework.web.bind.annotation.GetMapping; import org.springframework.web.bind.annotation.RequestMapping; import org.springframework.web.bind.annotation.RequestParam; import org.springframework.web.bind.annotation.RestController; import java.util.Calendar; import java.util.Date; import java.util.List; /*** * Date:2022/8/22 * Title:行政区划管理 * Description:对本文件的详细描述,原则上不能少于30字 * @author dylan * @version 1.0 * Remark:认为有必要的其他信息 */ @RestController @RequestMapping("galaxy-test/test") @AllArgsConstructor @Api(value = "业务字典", tags = "业务字典") @Slf4j public class TestController extends BladeController { private final IRtuBaseInfoService rtuBaseInfoService; private final IEtlRainDataService etlRainDataService; @GetMapping("/data/rain") @ApiOperationSupport(order = 1) public R addRain(@RequestParam(name = "rtuCode") String rtuCode) { Calendar calendar = Calendar.getInstance(); // calendar.set(Calendar.MINUTE, 0); // calendar.set(Calendar.SECOND, 0); LambdaQueryWrapper wrapper = Wrappers.query().lambda(); wrapper.eq(RtuInfoEntity::getRtuCode, rtuCode); wrapper.eq(RtuInfoEntity::getIsDeleted, 0); RtuInfoEntity rtuInfoEntity = rtuBaseInfoService.getOne(wrapper); if (rtuInfoEntity.getIsRain() == 1) { EtlRainDataEntity etlRainDataEntity = new EtlRainDataEntity(); etlRainDataEntity.setGuid(Func.randomUUID()); java.util.Random random = new java.util.Random(); Double drp = random.nextDouble(); etlRainDataEntity.setDrp(drp); etlRainDataEntity.setRtuCode(rtuInfoEntity.getRtuCode()); etlRainDataEntity.setTm(calendar.getTime()); etlRainDataEntity.setIntv(1.0); etlRainDataService.saveTestData(etlRainDataEntity); } String timeStartText = DateUtil.format(new Date(), "yyyy年MM月dd日 HH时mm分ss秒"); log.info("模似数据生成{}", timeStartText); return R.data("ok"); } }