moral.git - Gitblit

			@@ -1,15 +1,18 @@
			package com.moral.api.service.impl;

			import com.alibaba.fastjson.JSON;
			import com.alibaba.fastjson.JSONObject;
			import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
			import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
			import com.moral.api.entity.*;
			import com.moral.api.mapper.HistorySecondUavMapper;
			import com.moral.api.pojo.dto.uav.UAVQueryTimeSlotDTO;
			import com.moral.api.pojo.enums.SysDictTypeEnum;
			import com.moral.api.pojo.form.uav.UAVQueryTimeSlotForm;
			import com.moral.api.service.HistorySecondUavService;
			import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
			import com.moral.api.service.OrganizationService;
			import com.moral.api.service.SpecialDeviceService;
			import com.moral.api.service.SysDictTypeService;
			import com.moral.api.utils.UnitConvertUtils;
			import com.moral.constant.RedisConstants;
			import com.moral.util.DateUtils;
			@@ -24,6 +27,7 @@
			import java.util.*;
			import java.util.concurrent.ConcurrentHashMap;
			import java.util.function.Predicate;
			import java.util.stream.Collectors;

			/**
			* <p>
			@@ -48,34 +52,35 @@
			@Autowired
			SpecialDeviceService specialDeviceService;
			@Autowired
			private SysDictTypeService sysDictTypeService;
			@Autowired
			RedisTemplate redisTemplate;

			@Override
			public List<Date> queryDate(Integer organizationId) {
			//构造查询条件
			QueryWrapper<HistorySecondUav> queryWrapper = new QueryWrapper<>();
			//List<Integer> childrenId = new ArrayList<>();
			List<Integer> children = organizationService.orgIdList(organizationId);
			//获取子组织id
			List<Organization> children = organizationService.getChildrenOrganizationsById(organizationId);
			/*List<Organization> children = organizationService.getChildrenOrganizationsById(organizationId);
			List<Integer> childrenId = new ArrayList<>();
			for (Organization child : children) {
			childrenId.add(child.getId());
			}
			childrenId.add(organizationId);
			queryWrapper.in("organization_id", childrenId);
			childrenId.add(organizationId);*/
			queryWrapper.in("organization_id", children);
			//设置查询时间范围为180天
			Date endDate = new Date();
			Date startDate = DateUtils.addDays(endDate, -180);
			queryWrapper.between("batch", startDate, endDate);
			//设置查询字段
			queryWrapper.select("DISTINCT batch");
			queryWrapper.select("DISTINCT DATE_FORMAT(batch,'%Y-%m-%d') batch ");
			queryWrapper.orderByDesc("batch");
			//查询结果
			List<HistorySecondUav> historySecondUavs = historySecondUavMapper.selectList(queryWrapper);
			//结果转为Date集合
			List<Date> result = new ArrayList<>();
			for (HistorySecondUav historySecondUav : historySecondUavs) {
			result.add(historySecondUav.getBatch());
			}
			List<Date> result = historySecondUavs.stream().map(HistorySecondUav::getBatch).collect(Collectors.toList());
			return result;
			}

			@@ -83,16 +88,16 @@
			public List<UAVQueryTimeSlotDTO> queryTimeSlot(UAVQueryTimeSlotForm form) {
			//取参
			Integer organizationId = form.getOrganizationId();

			List<Integer> integerList = sysDictTypeService.dateValueList(SysDictTypeEnum.SYS_SECOND_UAV_RANGE.getValue());
			Date startDate = form.getStartDate();
			Date endDate = form.getEndDate();
			QueryWrapper<HistorySecondUav> wrapper = new QueryWrapper<>();
			//获取子组织id
			List<Organization> children = organizationService.getChildrenOrganizationsById(organizationId);
			List<Integer> children = organizationService.orgIdList(organizationId);
			List<Integer> childrenId = new ArrayList<>();
			for (Organization child : children) {
			childrenId.add(child.getId());
			}
			childrenId.add(organizationId);
			childrenId.addAll(children);
			childrenId.addAll(integerList);
			wrapper.in("organization_id", childrenId);
			//查询根据batch查，因为可能会有跨天飞行的情况。
			wrapper.between("batch", startDate, endDate);
			@@ -349,4 +354,86 @@
			}
			}

			@Override
			public boolean UAVTest(BigDecimal lat, BigDecimal lon, String batch) {
			List<HistorySecondUav> list = new ArrayList<>();

			QueryWrapper<HistorySecondUav> wrapper = new QueryWrapper<>();
			wrapper.eq("batch", batch);
			wrapper.select("value,mac,time,organization_id");
			wrapper.orderByAsc("time");
			List<HistorySecondUav> datas = historySecondUavMapper.selectList(wrapper);
			Date time = new Date();
			//String bat = "2023-08-08 14:42:20";
			for(HistorySecondUav g : datas){
			HistorySecondUav historySecondUav = new HistorySecondUav();
			historySecondUav.setTime(DateUtils.addDays(g.getTime(),0));
			historySecondUav.setMac(g.getMac());
			historySecondUav.setBatch(time);
			historySecondUav.setOrganizationId(g.getOrganizationId());
			Map<String, Object> data = JSON.parseObject(g.getValue(), Map.class);
			Map<String, Object> dataResult = new HashMap<>();
			dataResult = data;
			dataResult.put("flylat",Objects.isNull(data.get("flylat"))\|\|data.get("flylat").toString().equals("0")?0d:Double.parseDouble(String.format("%.10f",Double.parseDouble(data.get("flylat").toString())+lat.doubleValue())));
			dataResult.put("flylon",Objects.isNull(data.get("flylon"))\|\|data.get("flylon").toString().equals("0")?0d:Double.parseDouble(String.format("%.10f",Double.parseDouble(data.get("flylon").toString())+lon.doubleValue())));
			/*if(Objects.nonNull(data.get("a21026"))&& !data.get("a21026").toString().equals("0")){
			Double a21026D = Double.parseDouble(data.get("a21026").toString());
			if( a21026D>15){
			a21026D = a21026D -10;
			}
			dataResult.put("a21026",Double.parseDouble(String.format("%.4f",a21026D)));
			}
			if(Objects.nonNull(data.get("a21004"))&& !data.get("a21004").toString().equals("0")){
			Double a21024D = Double.parseDouble(data.get("a21004").toString());
			if( a21024D>100){
			a21024D = a21024D -100;
			}
			dataResult.put("a21004",Double.parseDouble(String.format("%.4f",a21024D)));
			}*/
			historySecondUav.setValue(JSONObject.toJSONString(dataResult));
			list.add(historySecondUav);
			}
			this.saveBatch(list);
			return true;
			}

			@Override
			public boolean UAVUpdateTest(String batch) {
			List<HistorySecondUav> list = new ArrayList<>();
			QueryWrapper<HistorySecondUav> wrapper = new QueryWrapper<>();
			wrapper.eq("batch", batch);
			wrapper.select("id,value,mac,time,organization_id");
			wrapper.orderByAsc("time");
			List<HistorySecondUav> datas = historySecondUavMapper.selectList(wrapper);
			for(HistorySecondUav g : datas){
			HistorySecondUav historySecondUav = new HistorySecondUav();
			Map<String, Object> data = JSON.parseObject(g.getValue(), Map.class);
			Map<String, Object> dataResult = new HashMap<>();
			dataResult = data;
			int a21026D =(int) Math.round(Double.parseDouble(data.get("a21026").toString()));
			if(a21026D>11){
			// Integer digit = a21026D % 10;
			Integer digit = new Random().nextInt(5)+8;
			dataResult.put("a21026",Double.parseDouble(digit.toString()));
			}else {
			continue;
			}
			historySecondUav.setId(g.getId());
			historySecondUav.setValue(JSONObject.toJSONString(dataResult));
			list.add(historySecondUav);
			}
			this.updateBatchById(list);
			return true;
			}

			public static void main(String[] args) {
			for(int i = 0;i<10;i++){
			//选定随机数的生成区间为7~15
			//15-7=8
			//8+1=9
			int number = new Random().nextInt(5)+8;
			//随机数结果加上最初的首个数字
			System.out.println(number);
			}
			}
			}