Browse Source

20200408晚20::25

master
牧羊人 4 years ago
parent
commit
f6300f1750
18 changed files with 311 additions and 179 deletions
  1. +22
    -9
      src/main/java/com/taauav/admin/controller/TauvInspectDriverController.java
  2. +11
    -9
      src/main/java/com/taauav/admin/dto/BaseInspectDriverDTO.java
  3. +9
    -7
      src/main/java/com/taauav/admin/dto/BaseReportDTO.java
  4. +27
    -19
      src/main/java/com/taauav/admin/dto/TauvInspectDriverDTO.java
  5. +47
    -4
      src/main/java/com/taauav/admin/entity/SysCity.java
  6. +12
    -21
      src/main/java/com/taauav/admin/entity/TauvDriver.java
  7. +20
    -25
      src/main/java/com/taauav/admin/entity/TauvInspect.java
  8. +2
    -6
      src/main/java/com/taauav/admin/entity/TauvInspectDriver.java
  9. +2
    -1
      src/main/java/com/taauav/admin/entity/TauvReport.java
  10. +9
    -12
      src/main/java/com/taauav/admin/mapper/TauvInspectDriverMapper.xml
  11. +2
    -2
      src/main/java/com/taauav/admin/query/TauvDriverQuery.java
  12. +13
    -2
      src/main/java/com/taauav/admin/service/ISysCityService.java
  13. +61
    -5
      src/main/java/com/taauav/admin/service/impl/SysCityServiceImpl.java
  14. +16
    -16
      src/main/java/com/taauav/admin/service/impl/TauvDriverServiceImpl.java
  15. +40
    -28
      src/main/java/com/taauav/admin/service/impl/TauvInspectDriverServiceImpl.java
  16. +0
    -1
      src/main/java/com/taauav/admin/service/impl/TauvInspectFileServiceImpl.java
  17. +16
    -11
      src/main/java/com/taauav/admin/service/impl/TauvInspectServiceImpl.java
  18. +2
    -1
      src/main/java/com/taauav/front/controller/FrontTestController.java

+ 22
- 9
src/main/java/com/taauav/admin/controller/TauvInspectDriverController.java View File

import org.springframework.web.bind.annotation.*; import org.springframework.web.bind.annotation.*;


import javax.validation.Valid; import javax.validation.Valid;
import java.math.BigInteger;
import java.util.HashMap; import java.util.HashMap;
import java.util.Map; import java.util.Map;




/** /**
* 任务列表--未分配 * 任务列表--未分配
*
* @param map * @param map
* @return * @return
*/ */


/** /**
* 任务列表--已分配 * 任务列表--已分配
*
* @param map * @param map
* @return * @return
*/ */
@PostMapping("/assignedList") @PostMapping("/assignedList")
@RequiresPermissions(controllerName + ":assignedList") @RequiresPermissions(controllerName + ":assignedList")
public Response assignedList(@RequestBody(required = false) Map<String, Object> map) { public Response assignedList(@RequestBody(required = false) Map<String, Object> map) {
Byte[] st = new Byte[]{2,3,4,5,6};
Byte[] st = new Byte[]{2, 3, 4, 5, 6};
if (map == null) { if (map == null) {
map = new HashMap<>(); map = new HashMap<>();
} }


/** /**
* 任务列表 * 任务列表
*
* @param map * @param map
* @return * @return
*/ */
@PostMapping("/list") @PostMapping("/list")
@RequiresPermissions(controllerName + ":list") @RequiresPermissions(controllerName + ":list")
public Response taskList(@RequestBody(required = false) Map<String,Object> map) {
public Response taskList(@RequestBody(required = false) Map<String, Object> map) {
if (map == null) { if (map == null) {
map = new HashMap<>(); map = new HashMap<>();
} }
if (map.containsKey(status) && !"".equals(map.get(status))) { if (map.containsKey(status) && !"".equals(map.get(status))) {
map.put("status", new Byte[]{Byte.valueOf(map.get(status).toString())}); map.put("status", new Byte[]{Byte.valueOf(map.get(status).toString())});
} else { } else {
map.put("status", new Byte[]{2,3,4,5,6});
map.put("status", new Byte[]{2, 3, 4, 5, 6});
} }
return iTauvInspectDriverService.getPageList(map, "list"); return iTauvInspectDriverService.getPageList(map, "list");
} }


/** /**
* 分配任务 * 分配任务
*
* @param map * @param map
* @return * @return
*/ */
@RequestMapping("/assignTask") @RequestMapping("/assignTask")
@RequiresPermissions(controllerName + ":assign") @RequiresPermissions(controllerName + ":assign")
public Response assignTask(@RequestBody Map<String,String> map) {
public Response assignTask(@RequestBody Map<String, String> map) {
return iTauvInspectDriverService.assignTask(map); return iTauvInspectDriverService.assignTask(map);
} }


@GetMapping("/detail") @GetMapping("/detail")
@RequiresPermissions(controllerName + ":" + PermissionConstants.VIEW_PERMISSION) @RequiresPermissions(controllerName + ":" + PermissionConstants.VIEW_PERMISSION)
public Response detail(@RequestBody @RequestParam("id") Integer id) { public Response detail(@RequestBody @RequestParam("id") Integer id) {
Map<String,Object> info = iTauvInspectDriverService.detail(id);
Map<String, Object> info = iTauvInspectDriverService.detail(id);
if (StringUtils.isEmpty(info.get("error"))) { if (StringUtils.isEmpty(info.get("error"))) {
return response.success(info); return response.success(info);
} else { } else {


/** /**
* 取消任务 * 取消任务
*
* @param map * @param map
* @return * @return
*/ */
@PostMapping("/cancel") @PostMapping("/cancel")
@RequiresPermissions(controllerName + ":cancel") @RequiresPermissions(controllerName + ":cancel")
public Response cancel(@RequestBody Map<String,String> map) {
public Response cancel(@RequestBody Map<String, String> map) {
return iTauvInspectDriverService.cancel(map); return iTauvInspectDriverService.cancel(map);
} }


/** /**
* 执行任务 * 执行任务
*
* @return * @return
*/ */
@PostMapping("/executeTask") @PostMapping("/executeTask")


/** /**
* 获取打印的数据信息 * 获取打印的数据信息
*
* @param id * @param id
* @return * @return
*/ */


/** /**
* 获取基础数据 * 获取基础数据
*
* @return * @return
*/ */
@GetMapping("/basicData") @GetMapping("/basicData")
//状态数组 //状态数组
result.put("statusList", tauvInspect.getStatusList()); result.put("statusList", tauvInspect.getStatusList());
//分类数组 //分类数组
result.put("typeList",tauvInspect.getTypeList());
result.put("typeList", tauvInspect.getTypeList());
//区域数组 //区域数组
result.put("areaList",cityService.getCityListByPidAndAdmin(320100));
//result.put("areaList",cityService.getCityListByPidAndAdmin(320100));
result.put("areaList", cityService.getCityList(BigInteger.valueOf(Long.valueOf("320117")), true));
//飞行小组 //飞行小组
result.put("adminList",adminService.getAdminListByGroupId(6));
result.put("adminList", adminService.getAdminListByGroupId(6));
return response.success("操作成功", result); return response.success("操作成功", result);
} }


/** /**
* 判断是否已生成报告 * 判断是否已生成报告
*
* @param map * @param map
* @return * @return
*/ */


/** /**
* 删除任务 * 删除任务
*
* @param map * @param map
* @return * @return
*/ */


/** /**
* 重处理任务 * 重处理任务
*
* @param map * @param map
* @return * @return
*/ */

+ 11
- 9
src/main/java/com/taauav/admin/dto/BaseInspectDriverDTO.java View File

import com.fasterxml.jackson.annotation.JsonIgnore; import com.fasterxml.jackson.annotation.JsonIgnore;
import lombok.Data; import lombok.Data;


import java.math.BigInteger;
import java.util.HashMap; import java.util.HashMap;
import java.util.Map; import java.util.Map;


/** /**
* 河流区域ID * 河流区域ID
*/ */
private Integer driverArea;
private BigInteger driverArea;


/** /**
* 报告id * 报告id


/** /**
* 状态类型 * 状态类型
*
* @return * @return
*/ */
@JsonIgnore @JsonIgnore
public Map<Integer,String> getStatusList() {
Map<Integer,String> map = new HashMap<>();
map.put(1,"待分配");
map.put(2,"待执行");
map.put(3,"执行中");
map.put(4,"已完成");
map.put(5,"复核中");
map.put(6,"复核完成");
public Map<Integer, String> getStatusList() {
Map<Integer, String> map = new HashMap<>();
map.put(1, "待分配");
map.put(2, "待执行");
map.put(3, "执行中");
map.put(4, "已完成");
map.put(5, "复核中");
map.put(6, "复核完成");
return map; return map;
} }
} }

+ 9
- 7
src/main/java/com/taauav/admin/dto/BaseReportDTO.java View File



import lombok.Data; import lombok.Data;


import java.math.BigInteger;
import java.util.HashMap; import java.util.HashMap;
import java.util.Map; import java.util.Map;


private String inspectNo; private String inspectNo;
private String driverName; private String driverName;


private Integer driverArea;
private BigInteger driverArea;


private String driverAreaText; private String driverAreaText;




/** /**
* 状态列表 * 状态列表
*
* @return * @return
*/ */
public Map<Integer,String> getStatusList() {
Map<Integer,String> map = new HashMap<>();
map.put(1,"待生成");
map.put(2,"审核中");
map.put(3,"审核通过");
map.put(4,"审核驳回");
public Map<Integer, String> getStatusList() {
Map<Integer, String> map = new HashMap<>();
map.put(1, "待生成");
map.put(2, "审核中");
map.put(3, "审核通过");
map.put(4, "审核驳回");
return map; return map;
} }
} }

+ 27
- 19
src/main/java/com/taauav/admin/dto/TauvInspectDriverDTO.java View File

package com.taauav.admin.dto; package com.taauav.admin.dto;


import com.fasterxml.jackson.annotation.JsonFormat;
import lombok.Data; import lombok.Data;
import org.springframework.format.annotation.DateTimeFormat;

import java.math.BigDecimal; import java.math.BigDecimal;
import java.util.Date;

/** /**
* 任务信息展示 * 任务信息展示
*
* @author dyg * @author dyg
* @date 2019/11/22 * @date 2019/11/22
*/ */
@Data @Data
public class TauvInspectDriverDTO extends BaseInspectDriverDTO{
public class TauvInspectDriverDTO extends BaseInspectDriverDTO {
/** /**
* 飞行小组 * 飞行小组
*/ */
/** /**
* 添加时间 * 添加时间
*/ */
private Integer createTime;
@DateTimeFormat(pattern = "yyyy-MM-dd HH:mm:ss")
@JsonFormat(pattern = "yyyy-MM-dd HH:mm:ss")
private Date createTime;
private String formatCreateTime; private String formatCreateTime;
/** /**
* 添加人 * 添加人
/** /**
* 状态 * 状态
*/ */
private Byte status;
private Integer status;
private String statusText; private String statusText;


/** /**
* 任务类型 * 任务类型
*/ */
private Byte type;
private Integer type;
private String typeText; private String typeText;


/** /**
* 期望巡检开始时间
* 期望巡检时间
*/ */
private Integer inspectStartTime;
private String formatInspectStartTime;

/**
* 期望巡检结束时间
*/
private Integer inspectEndTime;
private String formatInspectEndTime;
@DateTimeFormat(pattern = "yyyy-MM-dd")
@JsonFormat(pattern = "yyyy-MM-dd")
private Date inspectTime;
private String formatInspectTime;


/** /**
* 巡检长度 * 巡检长度
*/ */
private BigDecimal inspectLength; private BigDecimal inspectLength;


/**
* 执行周期(如:每月10号)
*/
private String executionCycle;
// /**
// * 执行周期(如:每月10号)
// */
// private String executionCycle;


/** /**
* 报告创建时间 * 报告创建时间
/** /**
* 执行开始时间 * 执行开始时间
*/ */
private Integer executionStartTime;
@DateTimeFormat(pattern = "yyyy-MM-dd HH:mm:ss")
@JsonFormat(pattern = "yyyy-MM-dd HH:mm:ss")
private Date executionStartTime;
private String formatExecutionStartTime; private String formatExecutionStartTime;


/** /**
* 执行结束时间 * 执行结束时间
*/ */
private Integer executionEndTime;
@DateTimeFormat(pattern = "yyyy-MM-dd HH:mm:ss")
@JsonFormat(pattern = "yyyy-MM-dd HH:mm:ss")
private Date executionEndTime;
private String formatExecutionEndTime; private String formatExecutionEndTime;


/** /**

+ 47
- 4
src/main/java/com/taauav/admin/entity/SysCity.java View File

package com.taauav.admin.entity; package com.taauav.admin.entity;


import java.io.Serializable; import java.io.Serializable;
import java.math.BigInteger;
import java.util.Date;


import com.baomidou.mybatisplus.annotation.IdType; import com.baomidou.mybatisplus.annotation.IdType;
import com.baomidou.mybatisplus.annotation.TableId; import com.baomidou.mybatisplus.annotation.TableId;
import com.baomidou.mybatisplus.annotation.TableName; import com.baomidou.mybatisplus.annotation.TableName;
import com.taauav.common.domain.Entity;
import com.fasterxml.jackson.annotation.JsonFormat;
import lombok.Data; import lombok.Data;
import lombok.EqualsAndHashCode; import lombok.EqualsAndHashCode;
import lombok.experimental.Accessors; import lombok.experimental.Accessors;
import org.springframework.format.annotation.DateTimeFormat;


/** /**
* <p> * <p>
@EqualsAndHashCode(callSuper = false) @EqualsAndHashCode(callSuper = false)
@Accessors(chain = true) @Accessors(chain = true)
@TableName("sys_city") @TableName("sys_city")
public class SysCity extends Entity {
public class SysCity implements Serializable {


private static final long serialVersionUID = 1L; private static final long serialVersionUID = 1L;


/**
* 编号
*/
@TableId(value = "id", type = IdType.AUTO)
private BigInteger id;

/** /**
* 父级ID * 父级ID
*/ */
private Integer pid;
private BigInteger pid;


/** /**
* 层级:1省 2市 3区 * 层级:1省 2市 3区
*/ */
private Boolean level;
private Integer level;


/** /**
* 省市区名称 * 省市区名称
*/ */
private Integer sort; private Integer sort;


/**
* 状态
*/
private Integer status;

/**
* 创建人
*/
private Integer createUser;

/**
* 创建时间
*/
@DateTimeFormat(pattern = "yyyy-MM-dd HH:mm:ss")
@JsonFormat(pattern = "yyyy-MM-dd HH:mm:ss")
private Date createTime;

/**
* 更新人
*/
private Integer updateUser;

/**
* 更新时间
*/
@DateTimeFormat(pattern = "yyyy-MM-dd HH:mm:ss")
@JsonFormat(pattern = "yyyy-MM-dd HH:mm:ss")
private Date updateTime;

/**
* 有效标识:1有效 0删除
*/
private Integer mark;

} }

+ 12
- 21
src/main/java/com/taauav/admin/entity/TauvDriver.java View File

package com.taauav.admin.entity; package com.taauav.admin.entity;


import java.io.Serializable; import java.io.Serializable;
import java.math.BigInteger;
import java.util.HashMap; import java.util.HashMap;
import java.util.Map; import java.util.Map;


import com.baomidou.mybatisplus.annotation.IdType; import com.baomidou.mybatisplus.annotation.IdType;
import com.baomidou.mybatisplus.annotation.TableField;
import com.baomidou.mybatisplus.annotation.TableId; import com.baomidou.mybatisplus.annotation.TableId;
import com.baomidou.mybatisplus.annotation.TableName; import com.baomidou.mybatisplus.annotation.TableName;
import com.taauav.common.domain.Entity; import com.taauav.common.domain.Entity;
private Integer type; private Integer type;


/** /**
* 河道层级
* 河道层级:3县/区 4镇 5村
*/ */
private Integer level; private Integer level;


/**
* 河道等级:1省级 2市级 3区/县级 4镇级 5村级
*/
@NotNull(message = "请选择河道等级")
private Integer grade;

/** /**
* 河长 * 河长
*/ */
@Length(min = 2, max = 30, message = "河长长度为2-30个字") @Length(min = 2, max = 30, message = "河长长度为2-30个字")
private String driverManager; private String driverManager;


/**
* 区划ID
*/
@NotNull(message = "请选择区划")
private Integer agencyId;

/** /**
* 河道长度(单位:km) * 河道长度(单位:km)
*/ */
@Length(max = 20, message = "终点长度不能超过20个字") @Length(max = 20, message = "终点长度不能超过20个字")
private String endPoint; private String endPoint;


private String driverCode;
/**
* 河道编码
*/
private BigInteger driverArea;


/** /**
* 河流类型 * 河流类型
} }


/** /**
* 河湖
* 河湖
* *
* @return * @return
*/ */
public Map<Integer, String> getGradeList() {
public Map<Integer, String> getLevelList() {
Map<Integer, String> map = new HashMap<>(3); Map<Integer, String> map = new HashMap<>(3);
map.put(1, "省级");
map.put(2, "市级");
map.put(3, "区/县级");
map.put(4, "镇级");
map.put(5, "村级");
map.put(3, "县/区");
map.put(4, "镇");
map.put(5, "村");
return map; return map;
} }
} }

+ 20
- 25
src/main/java/com/taauav/admin/entity/TauvInspect.java View File



import com.baomidou.mybatisplus.annotation.TableField; import com.baomidou.mybatisplus.annotation.TableField;


import java.util.Date;
import java.util.HashMap; import java.util.HashMap;
import java.util.List; import java.util.List;
import java.util.Map; import java.util.Map;


import com.fasterxml.jackson.annotation.JsonFormat;
import com.taauav.common.domain.Entity; import com.taauav.common.domain.Entity;
import lombok.Data; import lombok.Data;
import lombok.EqualsAndHashCode; import lombok.EqualsAndHashCode;
import lombok.experimental.Accessors; import lombok.experimental.Accessors;
import org.springframework.format.annotation.DateTimeFormat;


import javax.validation.constraints.*; import javax.validation.constraints.*;


private String inspectNo; private String inspectNo;


/** /**
* 类型:1日常任务 2周期性任务
* 类型:1可见光巡检 2多光谱巡检
*/ */
@NotNull(message = "巡检类型不能为空") @NotNull(message = "巡检类型不能为空")
private Integer type; private Integer type;


/** /**
* 巡检目的
* 巡检时间
*/ */
@NotNull(message = "巡检目的不能为空")
@Size(min = 1, max = 200, message = "巡检目的字数长度为1-200")
private String inspectPurpose;

/**
* 巡检开始时间
*/
private Integer inspectStartTime;

/**
* 巡检结束时间
*/
private Integer inspectEndTime;
@DateTimeFormat(pattern = "yyyy-MM-dd")
@JsonFormat(pattern = "yyyy-MM-dd")
private Date inspectTime;


/** /**
* 实际执行时间 * 实际执行时间
*/ */
private Integer executionTime;

/**
* 执行周期(如:每月10号)
*/
private String executionCycle;
@DateTimeFormat(pattern = "yyyy-MM-dd HH:mm:ss")
@JsonFormat(pattern = "yyyy-MM-dd HH:mm:ss")
private Date executionTime;


/** /**
* 巡检总长(单位:KM) * 巡检总长(单位:KM)
private BigDecimal inspectLength; private BigDecimal inspectLength;


/** /**
* 巡检期望结果
* 备注
*/
private String note;

/**
* 附件地址
*/ */
private String inspectResult;
private String attachment;


/** /**
* 河道任务 * 河道任务
*/ */
public Map<Integer, String> getTypeList() { public Map<Integer, String> getTypeList() {
Map<Integer, String> map = new HashMap<>(2); Map<Integer, String> map = new HashMap<>(2);
map.put(1, "日常任务");
map.put(2, "周期任务");
map.put(1, "可见光巡检");
map.put(2, "多光谱巡检");
return map; return map;
} }



+ 2
- 6
src/main/java/com/taauav/admin/entity/TauvInspectDriver.java View File





import java.io.Serializable; import java.io.Serializable;
import java.math.BigInteger;


import com.taauav.common.domain.Entity; import com.taauav.common.domain.Entity;
import lombok.Data; import lombok.Data;
* 河流区域ID * 河流区域ID
*/ */
@NotEmpty(message = "河流区域不能为空") @NotEmpty(message = "河流区域不能为空")
private Integer driverArea;
private BigInteger driverArea;


/** /**
* 河流长度(单位:KM) * 河流长度(单位:KM)
*/ */
private String driverNote; private String driverNote;


/**
* 是否省/国考河道:1是 2否
*/
private Integer driverExam;

/** /**
* 飞行小组 * 飞行小组
*/ */

+ 2
- 1
src/main/java/com/taauav/admin/entity/TauvReport.java View File

import com.baomidou.mybatisplus.annotation.TableField; import com.baomidou.mybatisplus.annotation.TableField;


import java.io.Serializable; import java.io.Serializable;
import java.math.BigInteger;
import java.util.HashMap; import java.util.HashMap;
import java.util.Map; import java.util.Map;


/** /**
* 河流区域ID * 河流区域ID
*/ */
private Integer driverArea;
private BigInteger driverArea;
@TableField(exist = false) @TableField(exist = false)
private String driverAreaText; private String driverAreaText;
/** /**

+ 9
- 12
src/main/java/com/taauav/admin/mapper/TauvInspectDriverMapper.xml View File

<mapper namespace="com.taauav.admin.mapper.TauvInspectDriverMapper"> <mapper namespace="com.taauav.admin.mapper.TauvInspectDriverMapper">


<select id="getPageList" parameterType="java.util.Map" resultType="com.taauav.admin.dto.TauvInspectDriverDTO"> <select id="getPageList" parameterType="java.util.Map" resultType="com.taauav.admin.dto.TauvInspectDriverDTO">
select driver.* ,inspect.type,inspect.inspect_start_time,inspect.inspect_end_time,inspect.execution_cycle,inspect.inspect_length
select driver.* ,inspect.type,inspect.inspect_time,inspect.inspect_length
from tauv_inspect_driver driver left join tauv_inspect inspect on driver.inspect_id=inspect.id from tauv_inspect_driver driver left join tauv_inspect inspect on driver.inspect_id=inspect.id
where driver.mark=1 where driver.mark=1
<if test="param.type != null and param.type >0"> <if test="param.type != null and param.type >0">
#{driver} #{driver}
</foreach> </foreach>
</if> </if>
<if test="param.executionTime != null and param.executionTime != ''">
and driver.execution_start_time >= #{param.executionTime}
</if>
<if test="param.inspectStartTime != null and param.inspectStartTime != ''">
and inspect.inspect_start_time >= #{param.inspectStartTime}
</if>
<if test="param.flightGroup != null and param.flightGroup != ''">
and driver.flight_group = #{param.flightGroup}
<if test="param.inspectTime != null and param.inspectTime != ''">
and inspect.inspect_time >= #{param.inspectTime}
</if> </if>
<!-- <if test="param.flightGroup != null and param.flightGroup != ''">-->
<!-- and driver.flight_group = #{param.flightGroup}-->
<!-- </if>-->
<if test="param.status != null and param.status != '' "> <if test="param.status != null and param.status != '' ">
and driver.status in and driver.status in
<foreach collection="param.status" item="item" separator="," open="(" close=")"> <foreach collection="param.status" item="item" separator="," open="(" close=")">
<if test="param.allocation != null and param.allocation>0"> <if test="param.allocation != null and param.allocation>0">
and driver.flight_group > 0 and driver.flight_group > 0
</if> </if>
<if test="param.driverExam != null and param.driverExam > 0">
and driver.driver_exam = #{param.driverExam}
</if>
<!-- <if test="param.driverExam != null and param.driverExam > 0">-->
<!-- and driver.driver_exam = #{param.driverExam}-->
<!-- </if>-->
order by driver.status asc, driver.inspect_id desc, driver.num asc order by driver.status asc, driver.inspect_id desc, driver.num asc
</select> </select>



+ 2
- 2
src/main/java/com/taauav/admin/query/TauvDriverQuery.java View File

private Integer type; private Integer type;


/** /**
* 河道等级
* 河道层级:3县区 4镇 5村
*/ */
private Integer grade;
private Integer level;


} }

+ 13
- 2
src/main/java/com/taauav/admin/service/ISysCityService.java View File

package com.taauav.admin.service; package com.taauav.admin.service;


import com.baomidou.mybatisplus.extension.service.IService;
import com.taauav.common.bean.Response; import com.taauav.common.bean.Response;
import com.taauav.admin.entity.SysCity; import com.taauav.admin.entity.SysCity;
import com.taauav.common.service.IBaseService; import com.taauav.common.service.IBaseService;


import java.math.BigInteger;
import java.util.List; import java.util.List;
import java.util.Map; import java.util.Map;


* @author dyg * @author dyg
* @since 2019-11-13 * @since 2019-11-13
*/ */
public interface ISysCityService extends IBaseService<SysCity> {
public interface ISysCityService extends IService<SysCity> {
/** /**
* 根据父级编号获取数据 * 根据父级编号获取数据
* *
*/ */
List<Map<String, Object>> getCityListByPid(Integer pid); List<Map<String, Object>> getCityListByPid(Integer pid);


/**
* 获取城市列表
*
* @param pid
* @param isTree 是否树结构
* @return
*/
List<SysCity> getCityList(BigInteger pid, boolean isTree);

/** /**
* 根据父级编号和用户信息获取城市列表 * 根据父级编号和用户信息获取城市列表
* *
* @param id * @param id
* @return * @return
*/ */
SysCity getInfoById(Integer id);
SysCity getInfoById(BigInteger id);


/** /**
* 获取城市各辖区河道信息 * 获取城市各辖区河道信息

+ 61
- 5
src/main/java/com/taauav/admin/service/impl/SysCityServiceImpl.java View File

package com.taauav.admin.service.impl; package com.taauav.admin.service.impl;


import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper; import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
import com.taauav.admin.vo.TauvAgencyListVo;
import com.taauav.common.bean.Response; import com.taauav.common.bean.Response;
import com.taauav.admin.entity.SysAdmin; import com.taauav.admin.entity.SysAdmin;
import com.taauav.admin.entity.SysCity; import com.taauav.admin.entity.SysCity;
import com.taauav.common.service.impl.BaseServiceImpl; import com.taauav.common.service.impl.BaseServiceImpl;
import com.taauav.common.util.ShiroUtils; import com.taauav.common.util.ShiroUtils;
import com.taauav.common.util.StringUtils; import com.taauav.common.util.StringUtils;
import io.netty.util.internal.StringUtil;
import org.springframework.beans.factory.annotation.Autowired; import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service; import org.springframework.stereotype.Service;


import javax.annotation.Resource; import javax.annotation.Resource;
import java.math.BigInteger;
import java.util.ArrayList;
import java.util.HashMap;
import java.util.List; import java.util.List;
import java.util.Map; import java.util.Map;


* @since 2019-11-13 * @since 2019-11-13
*/ */
@Service @Service
public class SysCityServiceImpl extends BaseServiceImpl<SysCityMapper, SysCity> implements ISysCityService {
public class SysCityServiceImpl extends ServiceImpl<SysCityMapper, SysCity> implements ISysCityService {
@Autowired @Autowired
private SysCityMapper sysCityMapper; private SysCityMapper sysCityMapper;
@Autowired @Autowired


/** /**
* 根据上级编号获取数据 * 根据上级编号获取数据
*
* @param pid * @param pid
* @return * @return
*/ */
public List<Map<String, Object>> getCityListByPid(Integer pid) { public List<Map<String, Object>> getCityListByPid(Integer pid) {
QueryWrapper<SysCity> queryWrapper = new QueryWrapper<>(); QueryWrapper<SysCity> queryWrapper = new QueryWrapper<>();
queryWrapper.eq("pid", pid); queryWrapper.eq("pid", pid);
queryWrapper.eq("mark",1);
queryWrapper.eq("mark", 1);
queryWrapper.select("id,pid,name,longitude,latitude"); queryWrapper.select("id,pid,name,longitude,latitude");
List<Map<String,Object>> list = sysCityMapper.selectMaps(queryWrapper);
List<Map<String, Object>> list = sysCityMapper.selectMaps(queryWrapper);
return list; return list;
} }


/**
* 获取城市列表
*
* @param pid 上级ID
* @param isTree 是否树结构
* @return
*/
@Override
public List<SysCity> getCityList(BigInteger pid, boolean isTree) {
List<SysCity> cityList = new ArrayList<>();
if (pid.toString().equals("320117")) {
QueryWrapper<SysCity> queryWrapper2 = new QueryWrapper<>();
queryWrapper2.eq("id", pid);
queryWrapper2.eq("mark", 1);
queryWrapper2.select("id,pid,name,longitude,latitude");
SysCity city = sysCityMapper.selectOne(queryWrapper2);
cityList.add(city);
}
QueryWrapper<SysCity> queryWrapper = new QueryWrapper<>();
queryWrapper.eq("pid", pid);
queryWrapper.eq("mark", 1);
queryWrapper.select("id,pid,name,longitude,latitude");
List<SysCity> list = sysCityMapper.selectList(queryWrapper);
if (!list.isEmpty()) {
// 获取子级
list.forEach(item -> {
// 城市名称加层级修饰符
if (isTree) {
item.setName("|--" + item.getName());
}
cityList.add(item);
List<SysCity> children = this.getCityList(BigInteger.valueOf(Long.valueOf(item.getId().toString())), isTree);
if (!children.isEmpty()) {
for (SysCity child : children) {
// 城市名称加层级修饰符
if (isTree) {
child.setName("|--" + child.getName());
}
cityList.add(child);
}
}
});
}
return cityList;
}

/** /**
* 根据父级id和用户城市权限获取城市列表 * 根据父级id和用户城市权限获取城市列表
* 备注:待完善
*
* @param pid * @param pid
* @return * @return
*/ */
wrapper.eq("pid", pid); wrapper.eq("pid", pid);
wrapper.eq("mark", 1); wrapper.eq("mark", 1);
wrapper.select("id,pid,name,longitude,latitude"); wrapper.select("id,pid,name,longitude,latitude");
List<Map<String,Object>> list = sysCityMapper.selectMaps(wrapper);
List<Map<String, Object>> list = sysCityMapper.selectMaps(wrapper);
return list; return list;
} else { } else {
return null; return null;
} }


@Override @Override
public SysCity getInfoById(Integer id) {
public SysCity getInfoById(BigInteger id) {
return sysCityMapper.selectById(id); return sysCityMapper.selectById(id);
} }


/** /**
* 获取城市各辖区河道信息 * 获取城市各辖区河道信息
*
* @param cityId * @param cityId
* @return * @return
*/ */

+ 16
- 16
src/main/java/com/taauav/admin/service/impl/TauvDriverServiceImpl.java View File

import com.baomidou.mybatisplus.core.metadata.IPage; import com.baomidou.mybatisplus.core.metadata.IPage;
import com.baomidou.mybatisplus.extension.plugins.pagination.Page; import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
import com.taauav.admin.query.TauvDriverQuery; import com.taauav.admin.query.TauvDriverQuery;
import com.taauav.admin.service.ITauvAgencyService;
import com.taauav.admin.service.ISysCityService;
import com.taauav.common.bean.Response; import com.taauav.common.bean.Response;
import com.taauav.admin.entity.SysAdmin; import com.taauav.admin.entity.SysAdmin;
import com.taauav.admin.entity.TauvDriver; import com.taauav.admin.entity.TauvDriver;
import org.springframework.stereotype.Service; import org.springframework.stereotype.Service;
import org.springframework.util.StringUtils; import org.springframework.util.StringUtils;


import javax.validation.Valid;
import java.math.BigInteger;
import java.util.HashMap; import java.util.HashMap;
import java.util.List; import java.util.List;
import java.util.Map; import java.util.Map;
@Autowired @Autowired
private ISysAdminService iSysAdminService; private ISysAdminService iSysAdminService;
@Autowired @Autowired
private ITauvAgencyService agencyService;
@Autowired
private TauvDriverMapper driverMapper; private TauvDriverMapper driverMapper;
@Autowired
private ISysCityService cityService;


/** /**
* 获取河道列表 * 获取河道列表
if (!StringUtils.isEmpty(query.getName())) { if (!StringUtils.isEmpty(query.getName())) {
queryWrapper.like("name", query.getName()); queryWrapper.like("name", query.getName());
} }
// 河道类型
// 河道类型
if (query.getType() != null && query.getType() > 0) { if (query.getType() != null && query.getType() > 0) {
queryWrapper.eq("type", query.getType()); queryWrapper.eq("type", query.getType());
} }
// 河道
if (query.getGrade() != null && query.getGrade() > 0) {
queryWrapper.eq("grade", query.getGrade());
// 河道
if (query.getLevel() != null && query.getLevel() > 0) {
queryWrapper.eq("level", query.getLevel());
} }
queryWrapper.eq("mark", 1); queryWrapper.eq("mark", 1);
queryWrapper.orderByDesc("id"); queryWrapper.orderByDesc("id");
* @return * @return
*/ */
@Override @Override
public Response edit(@Valid TauvDriver driver) {
public Response edit(TauvDriver driver) {
if (driver == null) { if (driver == null) {
return response.failure("数据不存在"); return response.failure("数据不存在");
} }
if (StringUtils.isEmpty(info)) { if (StringUtils.isEmpty(info)) {
return response.failure("数据不存在"); return response.failure("数据不存在");
} }
boolean result = this.editData(driver);
boolean result = editData(driver);
if (!result) { if (!result) {
return response.failure("编辑失败"); return response.failure("编辑失败");
} }
* @return * @return
*/ */
@Override @Override
public Response add(@Valid TauvDriver driver) {
public Response add(TauvDriver driver) {
if (driver == null || driver.getId() == 0) { if (driver == null || driver.getId() == 0) {
return response.failure("实体对象不存在"); return response.failure("实体对象不存在");
} }
map.put("driver_sn", info.getDriverSn()); map.put("driver_sn", info.getDriverSn());
map.put("name", info.getName()); map.put("name", info.getName());
map.put("type", info.getType()); map.put("type", info.getType());
map.put("geade", info.getGrade());
map.put("level", info.getLevel());
map.put("driver_manager", info.getDriverManager()); map.put("driver_manager", info.getDriverManager());
map.put("agency_id", info.getAgencyId());
map.put("agency_list", agencyService.getAgencyList(0));
map.put("driver_area", info.getDriverArea());
map.put("area_list", cityService.getCityListByPid(0));
map.put("length", info.getLength()); map.put("length", info.getLength());
map.put("start_point", info.getStartPoint()); map.put("start_point", info.getStartPoint());
map.put("end_point", info.getEndPoint()); map.put("end_point", info.getEndPoint());
TauvDriver driver = new TauvDriver(); TauvDriver driver = new TauvDriver();
Map<String, Object> map = new HashMap<>(3); Map<String, Object> map = new HashMap<>(3);
map.put("type_list", driver.getTypeList()); map.put("type_list", driver.getTypeList());
map.put("agency_list", agencyService.getAgencyList(0));
map.put("grade_list", driver.getGradeList());
map.put("area_list", cityService.getCityList(BigInteger.valueOf(Long.valueOf("320117")), false));
map.put("level_list", driver.getLevelList());
return map; return map;
} }



+ 40
- 28
src/main/java/com/taauav/admin/service/impl/TauvInspectDriverServiceImpl.java View File



import java.io.File; import java.io.File;
import java.math.BigDecimal; import java.math.BigDecimal;
import java.math.BigInteger;
import java.text.SimpleDateFormat; import java.text.SimpleDateFormat;
import java.util.*; import java.util.*;


TauvDriver driverInfo = iTauvDriverService.getInfoById(driverId); TauvDriver driverInfo = iTauvDriverService.getInfoById(driverId);
if (driverInfo != null) { if (driverInfo != null) {
driver.setDriverName(driverInfo.getName()); driver.setDriverName(driverInfo.getName());
// driver.setDriverArea(driverInfo.getDriverArea());
driver.setDriverArea(driverInfo.getDriverArea());
BigDecimal bigDecimal = new BigDecimal(driverInfo.getLength()); BigDecimal bigDecimal = new BigDecimal(driverInfo.getLength());
driver.setDriverLength(bigDecimal); driver.setDriverLength(bigDecimal);
driver.setDriverStart(driverInfo.getStartPoint()); driver.setDriverStart(driverInfo.getStartPoint());
pageSize = Integer.valueOf(map.get("pageSize").toString()); pageSize = Integer.valueOf(map.get("pageSize").toString());
} }
//分配列表:期望巡检时间 任务列表:执行时间 //分配列表:期望巡检时间 任务列表:执行时间
String inspectStartTime = "inspectStartTime";
if (!StringUtils.isEmpty(map.get(inspectStartTime)) && Integer.valueOf(map.get(inspectStartTime).toString()) > 0) {
String startTime = FunctionUtils.formatTime(Integer.valueOf(map.get(inspectStartTime).toString()), "yyyy-MM-dd") + " 00:00:00";
String inspectTime = "inspectTime";
if (!StringUtils.isEmpty(map.get(inspectTime))) {
String startTime = FunctionUtils.formatTime(Integer.valueOf(map.get(inspectTime).toString()), "yyyy-MM-dd") + " 00:00:00";
Integer startStamp = FunctionUtils.dateToStamp(startTime); Integer startStamp = FunctionUtils.dateToStamp(startTime);
if ("list".equals(act)) { if ("list".equals(act)) {
map.put("executionTime", startStamp); map.put("executionTime", startStamp);
map.remove("inspectStartTime");
map.remove("inspectTime");
} else { } else {
map.put("inspectStartTime", startStamp);
map.put("inspectTime", startStamp);
map.remove("executionTime"); map.remove("executionTime");
} }
} }
//河道类型
String driverExam = "driverExam";
if (!StringUtils.isEmpty(map.get(driverExam)) && Integer.valueOf(map.get(driverExam).toString()) > 0) {
map.put("driverExam", Integer.valueOf(map.get(driverExam).toString()));
} else {
map.remove(driverExam);
}
// //河道类型
// String driverExam = "driverExam";
// if (!StringUtils.isEmpty(map.get(driverExam)) && Integer.valueOf(map.get(driverExam).toString()) > 0) {
// map.put("driverExam", Integer.valueOf(map.get(driverExam).toString()));
// } else {
// map.remove(driverExam);
// }
//区属 //区属
map = FunctionUtils.dealArea(map); map = FunctionUtils.dealArea(map);
} else { } else {
} }
TauvInspect inspectInfo = inspectMapper.selectById(inspectId); TauvInspect inspectInfo = inspectMapper.selectById(inspectId);


Integer driverArea = info.getDriverArea();
BigInteger driverArea = info.getDriverArea();
detail.put("id", info.getId()); detail.put("id", info.getId());
detail.put("inspectNo", info.getInspectNo()); detail.put("inspectNo", info.getInspectNo());
detail.put("num", info.getNum()); detail.put("num", info.getNum());
detail.put("flightHeight", info.getFlightHeight()); detail.put("flightHeight", info.getFlightHeight());
detail.put("flightSpeed", info.getFlightSpeed()); detail.put("flightSpeed", info.getFlightSpeed());
detail.put("flightGroup", info.getFlightGroup()); detail.put("flightGroup", info.getFlightGroup());
detail.put("inspectStartTime", inspectInfo.getInspectStartTime());
// detail.put("inspectTime", inspectInfo.getinspectTime());
detail.put("inspectTime", inspectInfo.getInspectTime());
//图片位置信息 //图片位置信息
if (!"".equals(info.getDriverImage())) { if (!"".equals(info.getDriverImage())) {
info.setDriverImage(uploadUrl + info.getDriverImage()); info.setDriverImage(uploadUrl + info.getDriverImage());
} }
detail.put("driverImage", info.getDriverImage()); detail.put("driverImage", info.getDriverImage());
//巡检目的
detail.put("inspectPurpose", inspectInfo.getInspectPurpose());
//巡检结果
detail.put("inspectResult", inspectInfo.getInspectResult());
// //巡检目的
// detail.put("inspectPurpose", inspectInfo.getInspectPurpose());
// //巡检结果
// detail.put("inspectResult", inspectInfo.getInspectResult());
// 备注
detail.put("note", inspectInfo.getNote());
//执行时间 //执行时间
detail.put("executionStartTime", info.getExecutionStartTime()); detail.put("executionStartTime", info.getExecutionStartTime());
return detail; return detail;
} }
Integer groupId = (Integer) info.get("flightGroup"); Integer groupId = (Integer) info.get("flightGroup");
Long startTime = new Long(info.get("executionStartTime").toString()); Long startTime = new Long(info.get("executionStartTime").toString());
Long inspectStartTime = new Long(info.get("inspectStartTime").toString());
Long inspectTime = new Long(info.get("inspectTime").toString());
if (startTime > 0) { if (startTime > 0) {
info.put("executionTime", FunctionUtils.formatTime(startTime.intValue(), "yyyy-MM-dd HH:mm:ss")); info.put("executionTime", FunctionUtils.formatTime(startTime.intValue(), "yyyy-MM-dd HH:mm:ss"));
} else { } else {
info.put("executionTime", ""); info.put("executionTime", "");
} }
if (inspectStartTime > 0) {
info.put("formatInspectStartTime", FunctionUtils.formatTime(inspectStartTime.intValue(), "yyyy-MM-dd HH:mm:ss"));
if (inspectTime > 0) {
info.put("formatinspectTime", FunctionUtils.formatTime(inspectTime.intValue(), "yyyy-MM-dd HH:mm:ss"));
} else { } else {
info.put("formatInspectStartTime", "");
info.put("formatinspectTime", "");
} }
SysAdmin adminInfo = iSysAdminService.getAdminInfo(groupId); SysAdmin adminInfo = iSysAdminService.getAdminInfo(groupId);
info.put("flightGroupText", StringUtils.isEmpty(adminInfo) ? "" : adminInfo.getRealname()); info.put("flightGroupText", StringUtils.isEmpty(adminInfo) ? "" : adminInfo.getRealname());


SysAdmin adminInfo = iSysAdminService.getAdminInfo(driver.getCreateUser()); SysAdmin adminInfo = iSysAdminService.getAdminInfo(driver.getCreateUser());
driver.setFormatCreateUser(StringUtils.isEmpty(adminInfo) ? "" : adminInfo.getRealname()); driver.setFormatCreateUser(StringUtils.isEmpty(adminInfo) ? "" : adminInfo.getRealname());
driver.setFormatCreateTime(FunctionUtils.formatTime(driver.getCreateTime(), "yyyy-MM-dd HH:mm:ss"));
driver.setFormatInspectStartTime(FunctionUtils.formatTime(driver.getInspectStartTime(), "yyyy-MM-dd HH:mm:ss"));
driver.setFormatInspectEndTime(FunctionUtils.formatTime(driver.getInspectEndTime(), "yyyy-MM-dd HH:mm:ss"));
driver.setFormatExecutionStartTime(FunctionUtils.formatTime(driver.getExecutionStartTime(), "yyyy-MM-dd HH:mm:ss"));
driver.setFormatExecutionEndTime(FunctionUtils.formatTime(driver.getExecutionEndTime(), "yyyy-MM-dd HH:mm:ss"));
// driver.setFormatCreateTime(FunctionUtils.formatTime(driver.getCreateTime(), "yyyy-MM-dd HH:mm:ss"));
// driver.setFormatinspectTime(FunctionUtils.formatTime(driver.getinspectTime(), "yyyy-MM-dd HH:mm:ss"));
// driver.setFormatInspectEndTime(FunctionUtils.formatTime(driver.getInspectEndTime(), "yyyy-MM-dd HH:mm:ss"));
// driver.setFormatExecutionStartTime(FunctionUtils.formatTime(driver.getExecutionStartTime(), "yyyy-MM-dd HH:mm:ss"));
// driver.setFormatExecutionEndTime(FunctionUtils.formatTime(driver.getExecutionEndTime(), "yyyy-MM-dd HH:mm:ss"));
driver.setFormatCreateTime(DateUtil.format(driver.getCreateTime(), "yyyy-MM-dd HH:mm:ss"));
driver.setFormatInspectTime(DateUtil.format(driver.getInspectTime(), "yyyy-MM-dd HH:mm:ss"));
if (!StringUtils.isEmpty(driver.getExecutionStartTime())) {
driver.setFormatExecutionStartTime(DateUtil.format(driver.getExecutionStartTime(), "yyyy-MM-dd HH:mm:ss"));
}
if (!StringUtils.isEmpty(driver.getExecutionEndTime())) {
driver.setFormatExecutionEndTime(DateUtil.format(driver.getExecutionEndTime(), "yyyy-MM-dd HH:mm:ss"));
}
if (!StringUtils.isEmpty(driver.getDriverArea())) { if (!StringUtils.isEmpty(driver.getDriverArea())) {
SysCity cityInfo = iSysCityService.getInfoById(driver.getDriverArea()); SysCity cityInfo = iSysCityService.getInfoById(driver.getDriverArea());
driver.setDriverAreaText(StringUtils.isEmpty(cityInfo) ? "" : cityInfo.getName()); driver.setDriverAreaText(StringUtils.isEmpty(cityInfo) ? "" : cityInfo.getName());

+ 0
- 1
src/main/java/com/taauav/admin/service/impl/TauvInspectFileServiceImpl.java View File

report.setInspectStartTime(inspectDriver.getExecutionStartTime()); report.setInspectStartTime(inspectDriver.getExecutionStartTime());
report.setInspectEndTime(inspectDriver.getExecutionEndTime()); report.setInspectEndTime(inspectDriver.getExecutionEndTime());
report.setFlightGroup(inspectDriver.getFlightGroup()); report.setFlightGroup(inspectDriver.getFlightGroup());
report.setDriverExam(inspectDriver.getDriverExam());
report.setCreateTime(DateUtil.now()); report.setCreateTime(DateUtil.now());
report.setCreateUser(ShiroUtils.getAdminId()); report.setCreateUser(ShiroUtils.getAdminId());
reportMapper.insert(report); reportMapper.insert(report);

+ 16
- 11
src/main/java/com/taauav/admin/service/impl/TauvInspectServiceImpl.java View File

*/ */
@Override @Override
public Response addTask(TauvInspect inspect) { public Response addTask(TauvInspect inspect) {
Integer type = inspect.getType().intValue();
if (type.equals(2) && StringUtils.isEmpty(inspect.getExecutionCycle())) {
return response.failure("巡检周期不能为空");
// 巡检类型校验
if (inspect.getType() == null || inspect.getType() <= 0) {
return response.failure("请选择巡检类型");
} }
inspect.setCreateTime(DateUtil.now());
inspect.setCreateUser(ShiroUtils.getAdminId());
inspectMapper.insert(inspect);
//生成巡检任务单号
// 创建巡检任务
boolean result = this.addData(inspect);
if (!result) {
return response.failure("巡检任务创建失败");
}

// 生成巡检任务单号
String code = ""; String code = "";
if (type == 2) {
code = "ZQ" + FunctionUtils.formatTime(FunctionUtils.getCurrentTime(), "yyyyMM");
} else {
code = "RC" + FunctionUtils.formatTime(FunctionUtils.getCurrentTime(), "yyyyMM");
if (inspect.getType() == 1) {
// 可见光巡检
code = "KJG" + FunctionUtils.formatTime(FunctionUtils.getCurrentTime(), "yyyyMM");
} else if (inspect.getType() == 2) {
// 多光谱巡检
code = "DGP" + FunctionUtils.formatTime(FunctionUtils.getCurrentTime(), "yyyyMM");
} }
Integer id = inspect.getId(); Integer id = inspect.getId();
String idStr = String.format("%04d", id); String idStr = String.format("%04d", id);

+ 2
- 1
src/main/java/com/taauav/front/controller/FrontTestController.java View File

import org.springframework.web.bind.annotation.RestController; import org.springframework.web.bind.annotation.RestController;
import java.io.*; import java.io.*;
import java.math.BigInteger;
import java.util.ArrayList; import java.util.ArrayList;
import java.util.HashMap; import java.util.HashMap;
import java.util.List; import java.util.List;
String start = jsonObject.getString("start"); String start = jsonObject.getString("start");
String end = jsonObject.getString("end"); String end = jsonObject.getString("end");
driver.setName(riverName); driver.setName(riverName);
driver.setDriverCode(areaCode);
// driver.setDriverCode(areaCode);
if (riverType.equals("河流")) { if (riverType.equals("河流")) {
driver.setType(1); driver.setType(1);
} else if (riverType.equals("水库")) { } else if (riverType.equals("水库")) {

Loading…
Cancel
Save