SHZHJCYJPTYWXT/src/main/java/org/springblade/etl/controller/TestController.java

/**
 * 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<String> addRain(@RequestParam(name = "rtuCode") String rtuCode) {
		Calendar calendar = Calendar.getInstance();
//		calendar.set(Calendar.MINUTE, 0);
//		calendar.set(Calendar.SECOND, 0);
		LambdaQueryWrapper<RtuInfoEntity> wrapper = Wrappers.<RtuInfoEntity>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");
	}
}