定时器生成数据

snowy-web-app/src/main/java/vip/xiaonuo/Timer/NumberUtils.java

@@ -0,0 +1,39 @@
+package vip.xiaonuo.Timer;
+
+
+import com.baomidou.mybatisplus.core.toolkit.StringUtils;
+
+import java.text.DecimalFormat;
+import java.util.Random;
+
+public class NumberUtils {
+
+    public static DecimalFormat df = new DecimalFormat("#,##0.00");
+    public static String format(String str) {
+        if (StringUtils.isBlank(str)){
+            return "0.00";
+        }
+        return df.format(Double.valueOf(str));
+    }
+    //num 是小数位数
+    public static String getNum(Integer min,Integer max, Integer num) {
+        Random rand = new Random();
+        int result = rand.nextInt(max - min ) +min;
+        if (num >0){
+            return result+"."+(rand.nextInt((int) Math.pow(10,num)));
+        }
+        return  result+"";
+    }
+    // 是小数位数
+    public static String getNumFloat(Double min, Double max) {
+        double v = Math.random() * (max - min) + min;
+        DecimalFormat df = new DecimalFormat("0.0");
+        return df.format(v);
+    }
+
+    public static String getNumFloat2(Double min, Double max) {
+        double v = Math.random() * (max - min) + min;
+        DecimalFormat df = new DecimalFormat("0.00");
+        return df.format(v);
+    }
+}

snowy-web-app/src/main/java/vip/xiaonuo/Timer/ProEnergyData.java

@@ -0,0 +1,62 @@
+package vip.xiaonuo.Timer;
+
+import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
+import lombok.extern.slf4j.Slf4j;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.stereotype.Component;
+import vip.xiaonuo.common.timer.CommonTimerTaskRunner;
+import vip.xiaonuo.modular.energy.energyDevice.entity.EnergyDevice;
+import vip.xiaonuo.modular.energy.energyDevice.mapper.EnergyDeviceMapper;
+import vip.xiaonuo.modular.energy.energyElectricity.entity.EnergyElectricity;
+import vip.xiaonuo.modular.energy.energyElectricity.mapper.EnergyElectricityMapper;
+import vip.xiaonuo.modular.energy.energyWater.entity.EnergyWater;
+import vip.xiaonuo.modular.energy.energyWater.mapper.EnergyWaterMapper;
+import vip.xiaonuo.modular.env.envdevice.entity.EnvDevice;
+
+import java.util.Date;
+import java.util.List;
+
+@Slf4j
+@Component
+public class ProEnergyData implements CommonTimerTaskRunner {
+
+    @Autowired
+    private EnergyDeviceMapper deviceMapper;
+    @Autowired
+    private EnergyElectricityMapper electricityMapper;
+    @Autowired
+    private EnergyWaterMapper waterMapper;
+
+    @Override
+    public void action() {
+        QueryWrapper<EnergyDevice> queryWrapper = new QueryWrapper<>();
+        queryWrapper.eq("org_id", "1543842934270394370").eq("delete_flag", "NOT_DELETE")
+                .eq("status", 1);
+        List<EnergyDevice> energyDevices = deviceMapper.selectList(queryWrapper);
+        for (EnergyDevice energyDevice : energyDevices) {
+            String waterValue = NumberUtils.getNumFloat(5.0, 20.0);
+            String electricityValue = NumberUtils.getNumFloat(10.0, 100.0);
+
+            EnergyWater water = new EnergyWater();
+            water.setOrgId(energyDevice.getOrgId());
+            water.setUnitId(energyDevice.getInstallPosition());
+            water.setDeviceCode(energyDevice.getDeviceCode());
+            water.setCreateDate(new Date());
+            water.setOriginalDate(new Date());
+            water.setWaterValue(waterValue);
+            water.setOriginalValue(waterValue);
+
+            EnergyElectricity electricity = new EnergyElectricity();
+            electricity.setOrgId(energyDevice.getOrgId());
+            electricity.setUnitId(energyDevice.getInstallPosition());
+            electricity.setDeviceCode(energyDevice.getDeviceCode());
+            electricity.setCreateDate(new Date());
+            electricity.setOriginalDate(new Date());
+            electricity.setElectricityValue(electricityValue);
+            electricity.setOriginalValue(electricityValue);
+
+            electricityMapper.insert(electricity);
+            waterMapper.insert(water);
+        }
+    }
+}

snowy-web-app/src/main/java/vip/xiaonuo/Timer/ProEnvData.java

@@ -0,0 +1,50 @@
+package vip.xiaonuo.Timer;
+
+import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
+import lombok.extern.slf4j.Slf4j;
+import org.checkerframework.checker.units.qual.A;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.stereotype.Component;
+import vip.xiaonuo.common.timer.CommonTimerTaskRunner;
+import vip.xiaonuo.modular.env.envdata.entity.EnvData;
+import vip.xiaonuo.modular.env.envdata.mapper.EnvDataMapper;
+import vip.xiaonuo.modular.env.envdevice.entity.EnvDevice;
+import vip.xiaonuo.modular.env.envdevice.mapper.EnvDeviceMapper;
+
+import java.math.BigDecimal;
+import java.util.Date;
+import java.util.List;
+
+@Slf4j
+@Component
+public class ProEnvData implements CommonTimerTaskRunner {
+
+    @Autowired
+    private EnvDeviceMapper deviceMapper;
+    @Autowired
+    private EnvDataMapper dataMapper;
+    @Override
+    public void action() {
+        QueryWrapper<EnvDevice> queryWrapper = new QueryWrapper<>();
+        queryWrapper.eq("org_id", "1543842934270394370").eq("delete_flag", "NOT_DELETE")
+                .eq("status", 1);
+        List<EnvDevice> devices = deviceMapper.selectList(queryWrapper);
+        for (EnvDevice device : devices) {
+            EnvData data = new EnvData();
+            data.setAskTime(new Date());
+            data.setUpdateTime(new Date());
+            data.setChipCode(device.getId());
+            data.setDeviceCode(device.getDeviceCode());
+            data.setPigpenId(device.getInstallPosition());
+            data.setOrgId(device.getOrgId());
+            data.setIsShow(0);
+            String tem = NumberUtils.getNumFloat(19.0, 21.0);
+            String hum = NumberUtils.getNumFloat(39.0, 41.0);
+            data.setTemHandleValue(new BigDecimal(tem));
+            data.setTemOriginalValue(new BigDecimal(tem));
+            data.setHumiHandleValue(new BigDecimal(hum));
+            data.setHumiOriginalValue(new BigDecimal(hum));
+            dataMapper.insert(data);
+        }
+    }
+}

snowy-web-app/src/main/java/vip/xiaonuo/Timer/ProFeedingData.java

@@ -0,0 +1,77 @@
+package vip.xiaonuo.Timer;
+
+import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
+import lombok.extern.slf4j.Slf4j;
+import org.checkerframework.checker.units.qual.A;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.stereotype.Component;
+import vip.xiaonuo.common.timer.CommonTimerTaskRunner;
+import vip.xiaonuo.modular.feed.feedingenv.entity.FeedingEnv;
+import vip.xiaonuo.modular.feed.feedingenv.mapper.FeedingEnvMapper;
+import vip.xiaonuo.modular.feed.feedingfat.entity.FeedingFat;
+import vip.xiaonuo.modular.feed.feedingfat.mapper.FeedingFatMapper;
+import vip.xiaonuo.modular.feed.feedinglist.entity.FeedingList;
+import vip.xiaonuo.modular.feed.feedinglist.mapper.FeedingListMapper;
+
+import java.util.Date;
+import java.util.List;
+
+
+@Slf4j
+@Component
+public class ProFeedingData implements CommonTimerTaskRunner {
+
+    @Autowired
+    private FeedingListMapper listMapper;
+    @Autowired
+    private FeedingFatMapper fatMapper;
+    @Autowired
+    private FeedingEnvMapper envMapper;
+
+    @Override
+    public void action() {
+        QueryWrapper<FeedingEnv> queryWrapper = new QueryWrapper<>();
+        queryWrapper.eq("org_id", "1543842934270394370").eq("device_status", 1);
+        List<FeedingEnv> feedingEnvs = envMapper.selectList(queryWrapper);
+        for (FeedingEnv feedingEnv : feedingEnvs) {
+            String water = NumberUtils.getNumFloat(5.0, 20.0);
+            String feeding = NumberUtils.getNumFloat(5.0, 15.0);
+            String weight = NumberUtils.getNumFloat(60.0, 65.0);
+            String tem = NumberUtils.getNumFloat(36.0, 38.0);
+            String act = NumberUtils.getNum(8, 10, 0);
+
+
+            FeedingFat fat = new FeedingFat();
+            fat.setUnitId(feedingEnv.getUnitId());
+            fat.setUnitName(feedingEnv.getUnitName());
+            fat.setEartagNum(feedingEnv.getEartagNum());
+            fat.setCreateTime(new Date());
+            fat.setUploadTime(new Date());
+            fat.setDeviceCode(feedingEnv.getDeviceCode());
+            fat.setOrgId(feedingEnv.getOrgId());
+            fat.setDeviceType(feedingEnv.getType());
+            fat.setWaterValue(water);
+            fat.setWeigthValue(weight);
+            fat.setFeedAct(act);
+            fat.setFeedValue(feeding);
+            fat.setTemp(tem);
+            fat.setDayNum("100");
+            if ("1".equals(feedingEnv.getType())) {
+                fat.setRank(NumberUtils.getNumFloat(0.1, 1.0));
+            }
+            fatMapper.insert(fat);
+            FeedingList list = new FeedingList();
+            list.setUnitId(feedingEnv.getUnitId());
+            list.setUnitName(feedingEnv.getUnitName());
+            list.setCreateTime(new Date());
+            list.setUploadTime(new Date());
+            list.setOrgId(feedingEnv.getOrgId());
+            list.setType(feedingEnv.getType());
+            list.setPigNum(feedingEnv.getPigNum());
+            String feedValue = NumberUtils.getNumFloat(30.0, 40.0);
+            list.setFeedValue(feeding);
+            list.setMarginValue(feedValue);
+            listMapper.insert(list);
+        }
+    }
+}

snowy-web-app/src/main/java/vip/xiaonuo/modular/env/envdata/entity/EnvData.java

@@ -36,7 +36,7 @@ import java.util.Date;
 public class EnvData implements TransPojo {
 
     /** ID */
-    @TableId
+    @TableId(value = "id", type = IdType.AUTO)
     @ApiModelProperty(value = "ID", position = 1)
     private String id;