Merge branch 'master' of https://bdgit.educoder.net/pn38qy6fk/watermonitor_GIt into xiazeyu_branch

README.md

@@ -1,2 +0,0 @@
-# watermonitor_Git
-

src/src_houduan/dao/UserDao.java

@@ -0,0 +1,47 @@
+package dao;
+
+
+
+import domain.User;
+
+import java.util.List;
+import java.util.Map;
+
+/**
+ * 用户操作的DAO
+ */
+public interface UserDao {
+
+
+    public List<User> findAll();
+
+    User findUserByUsernameAndPassword(String username, String password);
+
+    void add(User user);
+    void register(User user);
+    void updatePassword(User user);
+
+    void delete(int id);
+
+    User findById(int i);
+
+    void update(User user);
+
+    /**
+     * 查询总记录数
+     * @return
+     * @param condition
+     */
+    int findTotalCount(Map<String, String[]> condition);
+
+    /**
+     * 分页查询每页记录
+     * @param start
+     * @param rows
+     * @param condition
+     * @return
+     */
+    List<User> findByPage(int start, int rows, Map<String, String[]> condition);
+
+    boolean updateUserInfo(User user);
+}

src/src_houduan/dao/WaterQualityStationDao.java

@@ -0,0 +1,29 @@
+package dao;
+
+
+import domain.StationAndQuality;
+import domain.WaterQualityStation;
+
+import java.util.List;
+import java.util.Map;
+
+public interface WaterQualityStationDao
+{
+    public abstract List<WaterQualityStation> findAll();
+    public abstract WaterQualityStation findByName(String stationName);
+    public abstract WaterQualityStation findIntroByName(String name);
+    public abstract boolean addWaterQualityStation(WaterQualityStation station);
+    public abstract List<WaterQualityStation> findByPage(int start,int pageSize);
+    public abstract int findTotalCount();
+    public abstract WaterQualityStation findIntroById(int id);
+    public abstract List<WaterQualityStation> conditonalQueryByPage(int start, int pageSize, Map<String,String[]> condition);
+    public abstract int conditionalFindAllCount(Map<String, String[]> condition);
+    public abstract boolean update(WaterQualityStation station);
+    public abstract boolean delete(int id);
+    public abstract List<WaterQualityStation> findPollutedSite();
+    public  abstract WaterQualityStation findIntro(double longitude,double latitude);
+
+    public abstract StationAndQuality findStationAndQuality(double longitude,double latitude);
+
+    public abstract List<StationAndQuality> indexing();
+}

src/src_houduan/dao/impl/UserDaoImpl.java

@@ -0,0 +1,180 @@
+package dao.impl;
+
+
+import domain.User;
+import org.springframework.dao.DataAccessException;
+import util.JDBCUtils;
+import dao.UserDao;
+import org.springframework.jdbc.core.BeanPropertyRowMapper;
+import org.springframework.jdbc.core.JdbcTemplate;
+
+import java.util.ArrayList;
+import java.util.List;
+import java.util.Map;
+import java.util.Set;
+import domain.User;
+
+public class UserDaoImpl implements UserDao {
+
+    private JdbcTemplate template = new JdbcTemplate(JDBCUtils.getDataSource());
+
+    @Override
+    public List<User> findAll() {
+        //使用JDBC操作数据库...
+        //1.定义sql
+        String sql = "select * from user";
+        List<User> users = template.query(sql, new BeanPropertyRowMapper<User>(User.class));
+
+        return users;
+    }
+
+    @Override
+    public User findUserByUsernameAndPassword(String username, String password) {
+        try {
+            String sql = "select * from user where username = ? and password = ?";
+            User user = template.queryForObject(sql, new BeanPropertyRowMapper<User>(User.class), username, password);
+            return user;
+        } catch (Exception e) {
+            System.out.println(e);
+            return null;
+        }
+
+    }
+
+    @Override
+    public void add(User user) {
+        //1.定义sql
+        String sql = "insert into user values(null,?,?,?,?,?,?,null,null)";
+        //2.执行sql
+        template.update(sql, user.getName(), user.getGender(), user.getAge(), user.getAddress(), user.getQq(), user.getEmail());
+    }
+
+    @Override
+    public void register(User user)//用户注册
+    {
+        String sql="insert into user (id,age,username,password) values(null,?,?,?)";
+        template.update(sql,18,user.getUsername(),user.getPassword());
+
+    }
+
+    @Override
+    public void updatePassword(User user)//修改当前用户密码
+    {
+        String sql="update user set password=? where username=?";
+        template.update(sql,user.getPassword(),user.getUsername());
+    }
+
+    @Override
+    public void delete(int id) {
+        //1.定义sql
+        String sql = "delete from user where id = ?";
+        //2.执行sql
+        template.update(sql, id);
+    }
+
+    @Override
+    public User findById(int id) {
+        String sql = "select * from user where id = ?";
+        return template.queryForObject(sql, new BeanPropertyRowMapper<User>(User.class), id);
+    }
+
+    @Override
+    public void update(User user) {
+        String sql = "update user set name = ?,gender = ? ,age = ? , address = ? , qq = ?, email = ? where id = ?";
+        template.update(sql, user.getName(), user.getGender(), user.getAge(), user.getAddress(), user.getQq(), user.getEmail(), user.getId());
+    }
+
+    @Override
+    public int findTotalCount(Map<String, String[]> condition) {
+        //1.定义模板初始化sql
+        String sql = "select count(*) from user where 1 = 1 ";
+        StringBuilder sb = new StringBuilder(sql);
+        //2.遍历map
+        Set<String> keySet = condition.keySet();
+        //定义参数的集合
+        List<Object> params = new ArrayList<Object>();
+        for (String key : keySet) {
+
+            //排除分页条件参数
+            if("currentPage".equals(key) || "rows".equals(key)){
+                continue;
+            }
+
+            //获取value
+            String value = condition.get(key)[0];
+            //判断value是否有值
+            if(value != null && !"".equals(value)){
+                //有值
+                sb.append(" and "+key+" like ? ");
+                params.add("%"+value+"%");//？条件的值
+            }
+        }
+        System.out.println(sb.toString());
+        System.out.println(params);
+
+        return template.queryForObject(sb.toString(),Integer.class,params.toArray());
+    }
+
+    @Override
+    public List<User> findByPage(int start, int rows, Map<String, String[]> condition) {
+        String sql = "select * from user  where 1 = 1 ";
+
+        StringBuilder sb = new StringBuilder(sql);
+        //2.遍历map
+        Set<String> keySet = condition.keySet();
+        //定义参数的集合
+        List<Object> params = new ArrayList<Object>();
+        for (String key : keySet)
+        {
+
+            //排除分页条件参数
+            if("currentPage".equals(key) || "rows".equals(key))
+            {
+                continue;
+            }
+
+            //获取value
+            String value = condition.get(key)[0];
+            //判断value是否有值
+            if(value != null && !"".equals(value))
+            {
+                //有值
+                sb.append(" and "+key+" like ? ");
+                params.add("%"+value+"%");//？条件的值
+            }
+        }
+
+        //添加分页查询
+        sb.append(" limit ?,? ");
+        //添加分页查询参数值
+        params.add(start);
+        params.add(rows);
+        sql = sb.toString();
+        System.out.println(sql);
+        System.out.println(params);
+
+        return template.query(sql,new BeanPropertyRowMapper<User>(User.class),params.toArray());
+    }
+
+    @Override
+    public boolean updateUserInfo(User user)
+    {
+        int update=0;
+        try {
+            String sql="update user set name = ?,gender = ? ,age = ? , address = ? , qq = ?, email = ? where id = ?";
+            update = template.update(sql, user.getName(), user.getGender(), user.getAge(),
+                    user.getAddress(), user.getQq(), user.getEmail(), user.getId());
+        } catch (Exception e)
+        {
+            System.out.println(e);
+        }
+        if(update!=0)
+        {
+            return true;
+        }
+        else
+        {
+            return false;
+        }
+    }
+}

src/src_houduan/dao/impl/WaterQualityStationDaoImpl.java

@@ -0,0 +1,352 @@
+package dao.impl;
+
+import dao.WaterQualityStationDao;
+import domain.StationAndQuality;
+import domain.WaterQuality;
+import domain.WaterQualityStation;
+import org.springframework.dao.DataAccessException;
+import org.springframework.jdbc.core.BeanPropertyRowMapper;
+import org.springframework.jdbc.core.JdbcTemplate;
+import util.JDBCUtils;
+
+import java.util.ArrayList;
+import java.util.LinkedList;
+import java.util.List;
+import java.util.Map;
+
+public class WaterQualityStationDaoImpl implements WaterQualityStationDao
+{
+    private JdbcTemplate template=new JdbcTemplate(JDBCUtils.getDataSource());
+
+    @Override
+    public List<WaterQualityStation> findAll()
+    {
+        //定义sql
+        String sql="select * from water_quality_station";
+        //执行sql
+        List<WaterQualityStation> station = template.query(sql, new BeanPropertyRowMapper<WaterQualityStation>(WaterQualityStation.class));
+        return station;
+    }
+
+    @Override
+    public WaterQualityStation findByName(String stationName)
+    {
+        WaterQualityStation station = null;
+        try
+        {
+            String sql="select * from water_quality_station where stationName=?";
+            station = template.queryForObject(sql, new BeanPropertyRowMapper<WaterQualityStation>(WaterQualityStation.class), stationName);
+        } catch (DataAccessException e)
+        {
+            System.out.println(e);
+        }
+        return station;
+    }
+
+    @Override
+    public WaterQualityStation findIntroByName(String name) {
+        String sql="select * from water_quality_station where stationName=?";
+        WaterQualityStation waterQualityStation = template.queryForObject(sql, new BeanPropertyRowMapper<WaterQualityStation>(WaterQualityStation.class),name);
+        return waterQualityStation;
+    }
+
+    @Override
+    public boolean addWaterQualityStation(WaterQualityStation station)
+    {
+        int update = 0;
+        try {
+            String sql="insert into water_quality_station values(null,?,?,?,?,?)";
+            update = template.update(sql,station.getStationName(),station.getLongitude(),station.getLatitude(),station.getSection(),station.getIntroduction());
+        } catch (DataAccessException e) {
+            System.out.println(e);;
+        }
+        System.out.println(update);
+        if(update!=0)
+        {
+            return true;
+        }
+        else
+        {
+            return false;
+        }
+
+
+    }
+
+    @Override
+    public List<WaterQualityStation> findByPage(int start, int pageSize)
+    {
+        List<WaterQualityStation> list=null;
+        try {
+            String sql="select * from water_quality_station limit ?,?";
+          list = template.query(sql,
+                    new BeanPropertyRowMapper<WaterQualityStation>(WaterQualityStation.class), start, pageSize);
+        } catch (DataAccessException e) {
+            System.out.println(e);
+        }
+
+        return list;
+    }
+
+    @Override
+    public int findTotalCount()
+    {
+        String sql="select count(*) from water_quality_station";
+        Integer integer = template.queryForObject(sql, Integer.class);
+        return integer;
+    }
+
+    @Override
+    public WaterQualityStation findIntroById(int id)
+    {
+        WaterQualityStation station = null;
+        try {
+            String sql="select * from water_quality_station where id=?";
+            station = template.queryForObject(sql, new BeanPropertyRowMapper<WaterQualityStation>(WaterQualityStation.class), id);
+        } catch (DataAccessException e) {
+            System.out.println(e);
+        }
+        return station;
+    }
+
+    @Override
+    public List<WaterQualityStation> conditonalQueryByPage(int start, int pageSize, Map<String, String[]> condition)
+    {
+        StringBuilder builder=new StringBuilder();//代表整个sql语句
+        String starStr="select * from water_quality_station where 1=1 ";
+        builder.append(starStr);
+
+        List<Object> valueList=new ArrayList<>();
+
+        //遍历map集合
+        for(String key:condition.keySet())
+        {
+
+            //排除分页条件参数
+            if("currentPage".equals(key) || "pageSize".equals(key))
+            {
+                continue;
+            }
+
+
+            String value = condition.get(key)[0];
+            if(value!=null&&!"".equals(value))
+            {
+                builder.append(" and "+key+" like ? ");
+                valueList.add("%"+value+"%");
+
+            }
+        }
+
+
+        builder.append(" limit ?,? ");
+        valueList.add(start);
+        valueList.add(pageSize);
+        String sql = builder.toString();
+
+        System.out.println(sql);
+        System.out.println(valueList);
+
+        //执行sql
+        List<WaterQualityStation> objList = null;
+        try {
+            objList = template.query(sql, new BeanPropertyRowMapper<WaterQualityStation>(WaterQualityStation.class), valueList.toArray());
+        } catch (DataAccessException e) {
+            System.out.println(e);
+        }
+
+        return objList;
+    }
+
+    @Override
+    public int conditionalFindAllCount(Map<String, String[]> condition)
+    {
+        StringBuilder builder=new StringBuilder();//代表整个sql语句
+        String starStr="select count(*) from water_quality_station where 1=1 ";
+        builder.append(starStr);
+
+        List<Object> valueList=new ArrayList<>();
+
+        //遍历map集合
+        for(String key:condition.keySet())
+        {
+
+            //排除分页条件参数
+            if("currentPage".equals(key) || "pageSize".equals(key))
+            {
+                continue;
+            }
+
+
+            String value = condition.get(key)[0];
+            if(value!=null&&!"".equals(value))
+            {
+                builder.append(" and "+key+" like ? ");
+                valueList.add("%"+value+"%");
+
+            }
+        }
+        String sql = builder.toString();
+        System.out.println(sql);
+        System.out.println(valueList);
+
+        int integer = 0;
+        try {
+            integer = template.queryForObject(sql, Integer.class, valueList.toArray());
+        } catch (DataAccessException e)
+        {
+            System.out.println(e);
+        }
+
+
+        return integer;
+    }
+
+    @Override
+    public boolean update(WaterQualityStation station)
+    {
+        int update=0;
+        try {
+            String sql="update water_quality_station set stationName=?,longitude=?,latitude=?,section=?,introduction=? where id=?";
+            update = template.update(sql,
+                    station.getStationName(),
+                    station.getLongitude(),
+                    station.getLatitude(),
+                    station.getSection(),
+                    station.getIntroduction(),
+                    station.getId());
+        } catch (DataAccessException e) {
+            System.out.println(e);
+        }
+        if(update!=0)
+        {
+            return true;
+        }
+        else
+        {
+            return false;
+        }
+    }
+
+    @Override
+    public boolean delete(int id)
+    {
+        int update=0;
+        try {
+            String sql="delete from water_quality_station where id=?";
+            update = template.update(sql, id);
+        } catch (DataAccessException e)
+        {
+            System.out.println(e);
+        }
+        if(update!=0)
+        {
+            return true;
+        }
+        else
+        {
+            return false;
+        }
+
+    }
+
+    @Override
+    public List<WaterQualityStation> findPollutedSite()
+    {
+        List<WaterQualityStation> list=null;
+        try
+        {
+            String sql="SELECT * FROM water_quality_station WHERE stationName IN\n" +
+                    "(SELECT DISTINCT belongStation FROM water_quality WHERE (LEVEL='Ⅳ' OR LEVEL='Ⅴ' OR LEVEL='劣Ⅴ') \n" +
+                    "AND TO_DAYS(NOW())-TO_DAYS(DATETIME)<=1)";
+            list = template.query(sql, new BeanPropertyRowMapper<WaterQualityStation>(WaterQualityStation.class));
+        } catch (Exception e)
+        {
+            System.out.println(e);
+        }
+        return list;
+    }
+
+    @Override
+    public WaterQualityStation findIntro(double longitude, double latitude)
+    {
+        WaterQualityStation station= null;
+        try {
+            String sql="SELECT * FROM water_quality_station WHERE ABS(longitude-?)<0.1 AND ABS(latitude-?)<0.1;";
+            List<WaterQualityStation> list = template.query(sql, new BeanPropertyRowMapper<WaterQualityStation>(WaterQualityStation.class), longitude, latitude);
+            if(list!=null)
+            {station = list.get(0);}
+        } catch (Exception e) {
+            System.out.println(e);
+        }
+        return station;
+    }
+
+    @Override
+    public StationAndQuality findStationAndQuality(double longitude, double latitude)
+    {
+        StationAndQuality stationAndQuality= null;
+        try {
+            String sql1="SELECT * FROM water_quality_station WHERE ABS(longitude-?)<0.1 AND ABS(latitude-?)<0.1";
+            String sql2="SELECT * FROM water_quality WHERE belongStation IN\n" +
+                    " (SELECT stationName FROM water_quality_station WHERE ABS(longitude-?)<0.1 AND ABS(latitude-?)<0.1)\n" +
+                    "  ORDER BY DATETIME DESC LIMIT 1;";
+            List<WaterQualityStation> list = template.query(sql1, new BeanPropertyRowMapper<WaterQualityStation>(WaterQualityStation.class),longitude,latitude);
+
+            WaterQualityStation station=null;
+            if(list.size()!=0&&list!=null)
+            {
+               station=list.get(0);
+            }
+
+            List<WaterQuality> list2 = template.query(sql2, new BeanPropertyRowMapper<WaterQuality>(WaterQuality.class), longitude, latitude);
+
+            WaterQuality waterQuality=null;
+            if(list2!=null&&list2.size()!=0)
+            {
+                waterQuality=list2.get(0);
+            }
+
+            stationAndQuality = new StationAndQuality();
+            if(list!=null&&list2!=null)
+            {
+                stationAndQuality.setStation(station);
+                stationAndQuality.setQuality(waterQuality);
+            }
+
+        } catch (Exception e) {
+            System.out.println(e);
+        }
+        return stationAndQuality;
+    }
+
+    @Override
+    public List<StationAndQuality> indexing()
+    {
+        List<StationAndQuality> result=new LinkedList<>();
+        String sql="select * from water_quality_station";
+        List<WaterQualityStation> stationList = template.query(sql, new BeanPropertyRowMapper<WaterQualityStation>(WaterQualityStation.class));
+        for (WaterQualityStation station : stationList)
+        {
+            String stationName = station.getStationName();
+            String sql2="SELECT * FROM water_quality WHERE belongStation=? ORDER BY DATETIME DESC LIMIT 1";
+            List<WaterQuality> qualityList = null;
+            try {
+                qualityList = template.query(sql2, new BeanPropertyRowMapper<WaterQuality>(WaterQuality.class),stationName);
+            } catch (Exception e)
+            {
+                System.out.println(e);
+            }
+
+            WaterQuality waterQuality=null;
+            if(qualityList!=null&&qualityList.size()!=0)
+            {waterQuality = qualityList.get(0);}
+
+            StationAndQuality stationAndQuality=new StationAndQuality();
+            stationAndQuality.setStation(station);
+            stationAndQuality.setQuality(waterQuality);
+            result.add(stationAndQuality);
+        }
+        return result;
+    }
+}

src/src_houduan/domain/ResultInfo.java

@@ -0,0 +1,22 @@
+package domain;
+
+public class ResultInfo
+{
+
+    private String msg;
+
+    public String getMsg() {
+        return msg;
+    }
+
+    public void setMsg(String msg) {
+        this.msg = msg;
+    }
+
+    @Override
+    public String toString() {
+        return "ResultInfo{" +
+                "msg='" + msg + '\'' +
+                '}';
+    }
+}

src/src_houduan/domain/StationAndQuality.java

@@ -0,0 +1,35 @@
+package domain;
+
+/**
+ * @author laoyingyong
+ * @date: 2020-02-03 16:55
+ */
+public class StationAndQuality
+{
+    private WaterQualityStation station;
+    private WaterQuality quality;
+
+    public WaterQualityStation getStation() {
+        return station;
+    }
+
+    public void setStation(WaterQualityStation station) {
+        this.station = station;
+    }
+
+    public WaterQuality getQuality() {
+        return quality;
+    }
+
+    public void setQuality(WaterQuality quality) {
+        this.quality = quality;
+    }
+
+    @Override
+    public String toString() {
+        return "StationAndQuality{" +
+                "station=" + station +
+                ", quality=" + quality +
+                '}';
+    }
+}

src/src_houduan/domain/Statistics.java

@@ -0,0 +1,85 @@
+package domain;
+
+/**
+ * @author laoyingyong
+ * @date: 2020-01-30 12:47
+ */
+public class Statistics
+{
+    private int a;//I类水质的数量
+    private int b;//II类水质的数量
+    private int c;//III类水质的数量
+    private int d;//IV类水质的数量
+    private int e;//V类水质的数量
+    private int f;//劣V类水质的数量
+    private int g;//其他
+
+    public int getA() {
+        return a;
+    }
+
+    public void setA(int a) {
+        this.a = a;
+    }
+
+    public int getB() {
+        return b;
+    }
+
+    public void setB(int b) {
+        this.b = b;
+    }
+
+    public int getC() {
+        return c;
+    }
+
+    public void setC(int c) {
+        this.c = c;
+    }
+
+    public int getD() {
+        return d;
+    }
+
+    public void setD(int d) {
+        this.d = d;
+    }
+
+    public int getE() {
+        return e;
+    }
+
+    public void setE(int e) {
+        this.e = e;
+    }
+
+    public int getF() {
+        return f;
+    }
+
+    public void setF(int f) {
+        this.f = f;
+    }
+
+    public int getG() {
+        return g;
+    }
+
+    public void setG(int g) {
+        this.g = g;
+    }
+
+    @Override
+    public String toString() {
+        return "Statistics{" +
+                "a=" + a +
+                ", b=" + b +
+                ", c=" + c +
+                ", d=" + d +
+                ", e=" + e +
+                ", f=" + f +
+                ", g=" + g +
+                '}';
+    }
+}

src/src_houduan/domain/User.java

@@ -0,0 +1,102 @@
+package domain;
+
+public class User
+{
+    private int id;
+    private String name;
+    private String gender;
+    private int age;
+    private String address;
+    private String qq;
+    private String email;
+
+    private String username;
+    private String password;
+
+    public int getId() {
+        return id;
+    }
+
+    public void setId(int id) {
+        this.id = id;
+    }
+
+    public String getName() {
+        return name;
+    }
+
+    public void setName(String name) {
+        this.name = name;
+    }
+
+    public String getGender() {
+        return gender;
+    }
+
+    public void setGender(String gender) {
+        this.gender = gender;
+    }
+
+    public int getAge() {
+        return age;
+    }
+
+    public void setAge(int age) {
+        this.age = age;
+    }
+
+    public String getAddress() {
+        return address;
+    }
+
+    public void setAddress(String address) {
+        this.address = address;
+    }
+
+    public String getQq() {
+        return qq;
+    }
+
+    public void setQq(String qq) {
+        this.qq = qq;
+    }
+
+    public String getEmail() {
+        return email;
+    }
+
+    public void setEmail(String email) {
+        this.email = email;
+    }
+
+    public String getUsername() {
+        return username;
+    }
+
+    public void setUsername(String username) {
+        this.username = username;
+    }
+
+    public String getPassword() {
+        return password;
+    }
+
+    public void setPassword(String password) {
+        this.password = password;
+    }
+
+    @Override
+    public String toString() {
+        return "User{" +
+                "id=" + id +
+                ", name='" + name + '\'' +
+                ", gender='" + gender + '\'' +
+                ", age=" + age +
+                ", address='" + address + '\'' +
+                ", qq='" + qq + '\'' +
+                ", email='" + email + '\'' +
+                ", username='" + username + '\'' +
+                ", password='" + password + '\'' +
+                '}';
+    }
+}

src/src_houduan/domain/WaterLevel.java

@@ -0,0 +1,84 @@
+package domain;
+
+import java.sql.Timestamp;
+
+public class WaterLevel
+{
+   private Integer id;
+   private String riverName;
+   private String siteName;
+   private Timestamp collectionDate;
+   private Double waterLevel;
+   private Double flow;
+   private Double over;
+
+
+    public Integer getId() {
+        return id;
+    }
+
+    public void setId(Integer id) {
+        this.id = id;
+    }
+
+    public String getRiverName() {
+        return riverName;
+    }
+
+    public void setRiverName(String riverName) {
+        this.riverName = riverName;
+    }
+
+    public String getSiteName() {
+        return siteName;
+    }
+
+    public void setSiteName(String siteName) {
+        this.siteName = siteName;
+    }
+
+    public Timestamp getCollectionDate() {
+        return collectionDate;
+    }
+
+    public void setCollectionDate(Timestamp collectionDate) {
+        this.collectionDate = collectionDate;
+    }
+
+    public Double getWaterLevel() {
+        return waterLevel;
+    }
+
+    public void setWaterLevel(Double waterLevel) {
+        this.waterLevel = waterLevel;
+    }
+
+    public Double getFlow() {
+        return flow;
+    }
+
+    public void setFlow(Double flow) {
+        this.flow = flow;
+    }
+
+    public Double getOver() {
+        return over;
+    }
+
+    public void setOver(Double over) {
+        this.over = over;
+    }
+
+    @Override
+    public String toString() {
+        return "WaterLevel{" +
+                "id=" + id +
+                ", riverName='" + riverName + '\'' +
+                ", siteName='" + siteName + '\'' +
+                ", collectionDate=" + collectionDate +
+                ", waterLevel=" + waterLevel +
+                ", flow=" + flow +
+                ", over=" + over +
+                '}';
+    }
+}

src/src_houduan/domain/WaterQuality.java

@@ -0,0 +1,107 @@
+package domain;
+
+import java.sql.Timestamp;
+
+/**
+ * @author laoyingyong
+ * @date: 2020-01-19 15:24
+ */
+public class WaterQuality
+{
+    private Integer id;
+    private String belongStation;
+    private Timestamp dateTime;
+    private Double pH;
+    private Double dO;
+    private Double nH4;
+    private Double cODMn;
+    private Double tOC;
+    private String level;
+
+    public Integer getId() {
+        return id;
+    }
+
+    public void setId(Integer id) {
+        this.id = id;
+    }
+
+    public String getBelongStation() {
+        return belongStation;
+    }
+
+    public void setBelongStation(String belongStation) {
+        this.belongStation = belongStation;
+    }
+
+    public Timestamp getDateTime() {
+        return dateTime;
+    }
+
+    public void setDateTime(Timestamp dateTime) {
+        this.dateTime = dateTime;
+    }
+
+    public Double getpH() {
+        return pH;
+    }
+
+    public void setpH(Double pH) {
+        this.pH = pH;
+    }
+
+    public Double getdO() {
+        return dO;
+    }
+
+    public void setdO(Double dO) {
+        this.dO = dO;
+    }
+
+    public Double getnH4() {
+        return nH4;
+    }
+
+    public void setnH4(Double nH4) {
+        this.nH4 = nH4;
+    }
+
+    public Double getcODMn() {
+        return cODMn;
+    }
+
+    public void setcODMn(Double cODMn) {
+        this.cODMn = cODMn;
+    }
+
+    public Double gettOC() {
+        return tOC;
+    }
+
+    public void settOC(Double tOC) {
+        this.tOC = tOC;
+    }
+
+    public String getLevel() {
+        return level;
+    }
+
+    public void setLevel(String level) {
+        this.level = level;
+    }
+
+    @Override
+    public String toString() {
+        return "WaterQuality{" +
+                "id=" + id +
+                ", belongStation='" + belongStation + '\'' +
+                ", dateTime=" + dateTime +
+                ", pH=" + pH +
+                ", dO=" + dO +
+                ", nH4=" + nH4 +
+                ", cODMn=" + cODMn +
+                ", tOC=" + tOC +
+                ", level='" + level + '\'' +
+                '}';
+    }
+}

src/src_houduan/domain/WaterQualityStation.java

@@ -0,0 +1,72 @@
+package domain;
+
+public class WaterQualityStation
+{
+    private int id;
+    private String stationName;
+    private Double longitude;
+    private Double latitude;
+    private String section;
+    private String introduction;
+
+    public int getId() {
+        return id;
+    }
+
+    public void setId(int id) {
+        this.id = id;
+    }
+
+    public String getStationName() {
+        return stationName;
+    }
+
+    public void setStationName(String stationName) {
+        this.stationName = stationName;
+    }
+
+    public String getIntroduction() {
+        return introduction;
+    }
+
+    public void setIntroduction(String introduction) {
+        this.introduction = introduction;
+    }
+
+    public String getSection() {
+        return section;
+    }
+
+    public void setSection(String section) {
+        this.section = section;
+    }
+
+    public Double getLongitude() {
+        return longitude;
+    }
+
+    public void setLongitude(Double longitude) {
+        this.longitude = longitude;
+    }
+
+    public Double getLatitude() {
+        return latitude;
+    }
+
+    public void setLatitude(Double latitude) {
+        this.latitude = latitude;
+    }
+
+
+    @Override
+    public String toString() {
+        return "WaterQualityStation{" +
+                "id=" + id +
+                ", stationName='" + stationName + '\'' +
+                ", longitude=" + longitude +
+                ", latitude=" + latitude +
+                ", section='" + section + '\'' +
+                ", introduction='" + introduction + '\'' +
+                '}';
+    }
+}

src/src_houduan/druid.properties

@@ -0,0 +1,10 @@
+driverClassName=com.mysql.jdbc.Driver
+url=jdbc:mysql://127.0.0.1:3306/river?characterEncoding=utf8
+username=root
+password=root
+# 初始化连接数量
+initialSize=5
+# 最大连接数
+maxActive=10
+# 最大等待时间
+maxWait=3000

src/src_houduan/service/UserService.java

@@ -0,0 +1,76 @@
+package service;
+
+
+import domain.User;
+import domain.PageBean;
+
+import java.util.List;
+import java.util.Map;
+
+/**
+ * 用户管理的业务接口
+ */
+public interface UserService {
+
+    /**
+     * 查询所有用户信息
+     * @return
+     */
+    public List<User> findAll();
+
+    /**
+     * 登录方法
+     * @param user
+     * @return
+     */
+    User login(User user);
+
+    /**
+     * 保存User
+     * @param user
+     */
+    void addUser(User user);
+
+
+    void userRegister(User user);//用户注册
+
+    void updateUserPassword(User user);
+
+
+    /**
+     * 根据id删除User
+     * @param id
+     */
+    void deleteUser(String id);
+
+    /**
+     * 根据id查询
+     * @param id
+     * @return
+     */
+    User findUserById(String id);
+
+    /**
+     * 修改用户信息
+     * @param user
+     */
+    void updateUser(User user);
+
+    /**
+     * 批量删除用户
+     * @param ids
+     */
+    void delSelectedUser(String[] ids);
+
+    /**
+     * 分页条件查询
+     * @param currentPage
+     * @param rows
+     * @param condition
+     * @return
+     */
+    PageBean<User> findUserByPage(String currentPage, String rows, Map<String, String[]> condition);
+
+
+    boolean updateUserInfo(User user);
+}

src/src_houduan/service/WaterQualityStationService.java

@@ -0,0 +1,27 @@
+package service;
+
+import domain.PageBean;
+import domain.StationAndQuality;
+import domain.WaterQualityStation;
+
+import java.util.List;
+import java.util.Map;
+
+public interface WaterQualityStationService
+{
+    public abstract List<WaterQualityStation> findAll();
+    public abstract WaterQualityStation findByName(String stationName);
+    public abstract int findTotalCount();
+    public abstract WaterQualityStation findIntroByName(String name);
+    public abstract boolean addWaterQualityStation(WaterQualityStation station);
+    public abstract PageBean<WaterQualityStation> getPageBean(int currentPage,int pageSize);
+    public abstract WaterQualityStation findIntroById(int id);
+    public abstract PageBean<WaterQualityStation> conditonalQueryByPage(int currentPage, int pageSize, Map<String,String[]> condition);
+    public abstract int conditionalFindAllCount(Map<String, String[]> condition);
+    public abstract boolean update(WaterQualityStation station);
+    public abstract boolean delete(int id);
+    public abstract List<WaterQualityStation> findPollutedSite();
+    public  abstract WaterQualityStation findIntro(double longitude,double latitude);
+    public abstract StationAndQuality findStationAndQuality(double longitude, double latitude);
+    public abstract List<StationAndQuality> indexing();
+}

src/src_houduan/service/impl/UserServiceImpl.java

@@ -0,0 +1,110 @@
+package service.impl;
+
+
+
+import domain.User;
+import dao.UserDao;
+import dao.impl.UserDaoImpl;
+import domain.PageBean;
+import service.UserService;
+
+import java.util.List;
+import java.util.Map;
+
+public class UserServiceImpl implements UserService {
+    private UserDao dao = new UserDaoImpl();
+
+    @Override
+    public List<User> findAll() {
+        //调用Dao完成查询
+        return dao.findAll();
+    }
+
+    @Override
+    public User login(User user) {
+        return dao.findUserByUsernameAndPassword(user.getUsername(),user.getPassword());
+    }
+
+    @Override
+    public void addUser(User user) {
+        dao.add(user);
+    }
+
+    @Override
+    public void userRegister(User user) {
+        dao.register(user);
+    }
+
+    @Override
+    public void updateUserPassword(User user)//修改当前用户密码
+    {
+        dao.updatePassword(user);
+
+    }
+
+    @Override
+    public void deleteUser(String id) {
+        dao.delete(Integer.parseInt(id));
+    }
+
+    @Override
+    public User findUserById(String id) {
+        return dao.findById(Integer.parseInt(id));
+    }
+
+    @Override
+    public void updateUser(User user) {
+        dao.update(user);
+    }
+
+    @Override
+    public void delSelectedUser(String[] ids) {
+        if(ids != null && ids.length > 0){
+            //1.遍历数组
+            for (String id : ids) {
+                //2.调用dao删除
+                dao.delete(Integer.parseInt(id));
+            }
+        }
+
+    }
+
+    @Override
+    public PageBean<User> findUserByPage(String _currentPage, String _rows, Map<String, String[]> condition) {
+
+        int currentPage = Integer.parseInt(_currentPage);
+        int rows = Integer.parseInt(_rows);
+
+        if(currentPage <=0) {
+            currentPage = 1;
+        }
+        //1.创建空的PageBean对象
+        PageBean<User> pb = new PageBean<User>();
+        //2.设置参数
+        pb.setCurrentPage(currentPage);
+        pb.setRows(rows);
+
+        //3.调用dao查询总记录数
+        int totalCount = dao.findTotalCount(condition);
+        pb.setTotalCount(totalCount);
+        //4.调用dao查询List集合
+        //计算开始的记录索引
+        int start = (currentPage - 1) * rows;
+        List<User> list = dao.findByPage(start,rows,condition);
+        pb.setList(list);
+
+        //5.计算总页码
+        int totalPage = (totalCount % rows)  == 0 ? totalCount/rows : (totalCount/rows) + 1;
+        pb.setTotalPage(totalPage);
+
+
+        return pb;
+    }
+
+    @Override
+    public boolean updateUserInfo(User user)
+    {
+        boolean b = dao.updateUserInfo(user);
+        return b;
+    }
+}

src/src_houduan/service/impl/WaterQualityStationServiceImpl.java

@@ -0,0 +1,132 @@
+package service.impl;
+
+import dao.WaterQualityStationDao;
+import dao.impl.WaterQualityStationDaoImpl;
+import domain.PageBean;
+import domain.StationAndQuality;
+import domain.WaterQualityStation;
+import service.WaterQualityStationService;
+
+import java.util.List;
+import java.util.Map;
+
+public class WaterQualityStationServiceImpl implements WaterQualityStationService
+{
+    WaterQualityStationDao dao=new WaterQualityStationDaoImpl();
+
+    @Override
+    public List<WaterQualityStation> findAll()
+    {
+        return dao.findAll();
+    }
+
+    @Override
+    public WaterQualityStation findByName(String stationName)
+    {
+        return dao.findByName(stationName);
+    }
+
+    /**
+     * 查询所有水质监测站
+     * @return
+     */
+    @Override
+    public int findTotalCount()
+    {
+        int totalCount = dao.findTotalCount();
+        return totalCount;
+    }
+
+    @Override
+    public WaterQualityStation findIntroByName(String name) {
+        return dao.findIntroByName(name);
+    }
+
+    @Override
+    public boolean addWaterQualityStation(WaterQualityStation station)
+    {
+        return dao.addWaterQualityStation(station);
+
+    }
+
+    @Override
+    public PageBean<WaterQualityStation> getPageBean(int currentPage, int pageSize)
+    {
+        PageBean<WaterQualityStation> pageBean=new PageBean<>();
+        int totalCount=dao.findTotalCount();
+        pageBean.setTotalCount(totalCount);
+        int totalPage=totalCount%pageSize==0?totalCount/pageSize:(totalCount/pageSize+1);
+        pageBean.setTotalPage(totalPage);
+        pageBean.setCurrentPage(currentPage);
+        pageBean.setRows(pageSize);
+        int start=(currentPage-1)*pageSize;
+        List<WaterQualityStation> list = dao.findByPage(start, pageSize);
+        pageBean.setList(list);
+        return pageBean;
+    }
+
+    @Override
+    public WaterQualityStation findIntroById(int id)
+    {
+        WaterQualityStation introById = dao.findIntroById(id);
+        return introById;
+    }
+
+    @Override
+    public PageBean<WaterQualityStation> conditonalQueryByPage(int currentPage, int pageSize, Map<String, String[]> condition)
+    {
+        PageBean<WaterQualityStation> pageBean=new PageBean<>();
+        int totalCount= dao.conditionalFindAllCount(condition);
+        pageBean.setTotalCount(totalCount);
+        int totalPage=totalCount%pageSize==0?totalCount/pageSize:(totalCount/pageSize+1);
+        pageBean.setTotalPage(totalPage);
+        pageBean.setCurrentPage(currentPage);
+        pageBean.setRows(pageSize);
+        List<WaterQualityStation> list = dao.conditonalQueryByPage((currentPage - 1) * pageSize, pageSize, condition);
+        pageBean.setList(list);
+        return pageBean;
+    }
+
+    @Override
+    public int conditionalFindAllCount(Map<String, String[]> condition)
+    {
+        int i = dao.conditionalFindAllCount(condition);
+        return i;
+    }
+
+    @Override
+    public boolean update(WaterQualityStation station)
+    {
+        boolean b = dao.update(station);
+        return b;
+    }
+
+    @Override
+    public boolean delete(int id)
+    {
+        boolean b = dao.delete(id);
+        return b;
+    }
+
+    @Override
+    public List<WaterQualityStation> findPollutedSite()
+    {
+        return dao.findPollutedSite();
+    }
+
+    @Override
+    public WaterQualityStation findIntro(double longitude, double latitude) {
+        return dao.findIntro(longitude,latitude);
+    }
+
+    @Override
+    public StationAndQuality findStationAndQuality(double longitude, double latitude) {
+        return dao.findStationAndQuality(longitude,latitude);
+    }
+
+    @Override
+    public List<StationAndQuality> indexing()
+    {
+        return dao.indexing();
+    }
+}

src/src_houduan/util/JDBCUtils.java

@@ -0,0 +1,52 @@
+package util;
+
+import com.alibaba.druid.pool.DruidDataSourceFactory;
+
+import javax.sql.DataSource;
+import java.io.IOException;
+import java.io.InputStream;
+import java.sql.Connection;
+import java.sql.SQLException;
+import java.util.Properties;
+
+/**
+ * JDBC工具类 使用Durid连接池
+ */
+public class JDBCUtils {
+
+    private static DataSource ds ;
+
+    static {
+
+        try {
+            //1.加载配置文件
+            Properties pro = new Properties();
+            //使用ClassLoader加载配置文件，获取字节输入流
+            InputStream is = JDBCUtils.class.getClassLoader().getResourceAsStream("druid.properties");
+            pro.load(is);
+
+            //2.初始化连接池对象
+            ds = DruidDataSourceFactory.createDataSource(pro);
+
+        } catch (IOException e) {
+            e.printStackTrace();
+        } catch (Exception e) {
+            e.printStackTrace();
+        }
+    }
+
+    /**
+     * 获取连接池对象
+     */
+    public static DataSource getDataSource(){
+        return ds;
+    }
+
+
+    /**
+     * 获取连接Connection对象
+     */
+    public static Connection getConnection() throws SQLException {
+        return  ds.getConnection();
+    }
+}

src/src_houduan/web/servlet/others/CheckCodeServlet.java

@@ -0,0 +1,99 @@
+package web.servlet.others;
+
+import javax.imageio.ImageIO;
+import javax.servlet.ServletException;
+import javax.servlet.annotation.WebServlet;
+import javax.servlet.http.HttpServlet;
+import javax.servlet.http.HttpServletRequest;
+import javax.servlet.http.HttpServletResponse;
+import java.awt.*;
+import java.awt.image.BufferedImage;
+import java.io.IOException;
+import java.util.Random;
+
+/**
+ * 验证码
+ */
+@WebServlet("/checkCodeServlet")
+public class CheckCodeServlet extends HttpServlet {
+	public void doGet(HttpServletRequest request, HttpServletResponse response)throws ServletException, IOException {
+		
+		//服务器通知浏览器不要缓存
+		response.setHeader("pragma","no-cache");
+		response.setHeader("cache-control","no-cache");
+		response.setHeader("expires","0");
+		
+		//在内存中创建一个长80，宽30的图片，默认黑色背景
+		//参数一：长
+		//参数二：宽
+		//参数三：颜色
+		int width = 80;
+		int height = 30;
+		BufferedImage image = new BufferedImage(width,height,BufferedImage.TYPE_INT_RGB);
+		
+		//获取画笔
+		Graphics g = image.getGraphics();
+		//设置画笔颜色为灰色
+		g.setColor(Color.GRAY);
+		//填充图片
+		g.fillRect(0,0, width,height);
+		
+		//产生4个随机验证码，12Ey
+		String checkCode = getCheckCode();
+		//将验证码放入HttpSession中
+		request.getSession().setAttribute("CHECKCODE_SERVER",checkCode);
+		
+		//设置画笔颜色为黄色
+		g.setColor(Color.YELLOW);
+		//设置字体的小大
+		g.setFont(new Font("黑体",Font.BOLD,24));
+		//向图片上写入验证码
+		g.drawString(checkCode,15,25);
+
+		//2.4画干扰线
+		g.setColor(Color.GREEN);
+		//随机生成坐标点
+		Random ran=new Random();
+		for (int i = 0; i < 10; i++)
+		{
+			int x1 = ran.nextInt(width);
+			int x2 = ran.nextInt(width);
+
+			int y1 = ran.nextInt(height);
+			int y2 = ran.nextInt(height);
+			g.drawLine(x1,y1,x2,y2);
+		}
+		
+		//将内存中的图片输出到浏览器
+		//参数一：图片对象
+		//参数二：图片的格式，如PNG,JPG,GIF
+		//参数三：图片输出到哪里去
+		ImageIO.write(image,"PNG",response.getOutputStream());
+	}
+	/**
+	 * 产生4位随机字符串 
+	 */
+	private String getCheckCode()
+	{
+		String base = "0123456789ABCDEFGHIJKLMNOPQUVWXYZabcdefghijklmnopquvwxyz";
+		int size = base.length();
+		Random r = new Random();
+		StringBuffer sb = new StringBuffer();
+		for(int i=1;i<=4;i++)
+		{
+			//产生0到size-1的随机值
+			int index = r.nextInt(size);
+			//在base字符串中获取下标为index的字符
+			char c = base.charAt(index);
+			//将c放入到StringBuffer中去
+			sb.append(c);
+		}
+		return sb.toString();
+	}
+	public void doPost(HttpServletRequest request, HttpServletResponse response) throws ServletException, IOException {
+		this.doGet(request,response);
+	}
+}
+
+
+

src/src_houduan/web/servlet/others/DownloadFileServlet.java

@@ -0,0 +1,76 @@
+package web.servlet.others;
+
+import domain.WaterLevel;
+import service.WaterLevelService;
+import service.impl.WaterLevelServiceImpl;
+
+import javax.servlet.ServletContext;
+import javax.servlet.ServletException;
+import javax.servlet.ServletOutputStream;
+import javax.servlet.annotation.WebServlet;
+import javax.servlet.http.HttpServlet;
+import javax.servlet.http.HttpServletRequest;
+import javax.servlet.http.HttpServletResponse;
+import java.io.FileInputStream;
+import java.io.FileOutputStream;
+import java.io.IOException;
+import java.net.URLEncoder;
+import java.sql.Timestamp;
+import java.text.SimpleDateFormat;
+import java.util.List;
+
+/**
+ * @author laoyingyong
+ * @date: 2020-02-05 10:27
+ */
+@WebServlet("/DownloadFileServlet")
+public class DownloadFileServlet extends HttpServlet
+{
+    protected void doPost(HttpServletRequest request, HttpServletResponse response) throws ServletException, IOException
+    {
+        ServletOutputStream outputStream = response.getOutputStream();//网络字节输出流
+        WaterLevelService service=new WaterLevelServiceImpl();
+        List<WaterLevel> weekData = service.findWeekData();
+
+        outputStream.write(("河流"+"\t"+"测站名"+"\t"+"时间"+"\t"+"水位"+"\t"+"流量"+"\t"+"超警戒（汛限）水位"+"\n").getBytes());
+        outputStream.write("-----------------------------------------最近七天的水位数据-------------------------------------------\n".getBytes());
+        for (WaterLevel item : weekData)
+        {
+            String riverName = item.getRiverName();
+            String siteName = item.getSiteName();
+            Timestamp collectionDate = item.getCollectionDate();
+            SimpleDateFormat simpleDateFormat=new SimpleDateFormat("yyyy-MM-dd HH:mm");
+            String format = simpleDateFormat.format(collectionDate);
+            Double waterLevel = item.getWaterLevel();
+            Double flow = item.getFlow();
+            Double over = item.getOver();
+
+            outputStream.write((riverName+"\t"+siteName+"\t"+format+"\t"+waterLevel+"\t"+flow+"\t"+over+"\n").getBytes());
+
+
+        }
+
+
+        String filename = request.getParameter("filename");
+
+
+        ServletContext servletContext = request.getServletContext();
+
+        //设置响应的mime类型
+        String mimeType = servletContext.getMimeType(filename);
+        response.setContentType(mimeType);
+
+
+        String encodeFileName = URLEncoder.encode(filename, "utf-8");//编码，解决文件中文乱码问题
+        response.setHeader("content-disposition","attachment;filename="+encodeFileName);
+
+
+    }
+
+    protected void doGet(HttpServletRequest request, HttpServletResponse response) throws ServletException, IOException
+    {
+
+        this.doPost(request, response);
+
+    }
+}

src/src_houduan/web/servlet/others/DownloadFileServlet2.java

@@ -0,0 +1,80 @@
+package web.servlet.others;
+
+import domain.WaterLevel;
+import domain.WaterQuality;
+import service.WaterLevelService;
+import service.WaterQualityService;
+import service.impl.WaterLevelServiceImpl;
+import service.impl.WaterQualityServiceImpl;
+
+import javax.servlet.ServletContext;
+import javax.servlet.ServletException;
+import javax.servlet.ServletOutputStream;
+import javax.servlet.annotation.WebServlet;
+import javax.servlet.http.HttpServlet;
+import javax.servlet.http.HttpServletRequest;
+import javax.servlet.http.HttpServletResponse;
+import java.io.IOException;
+import java.net.URLEncoder;
+import java.sql.Timestamp;
+import java.text.SimpleDateFormat;
+import java.util.List;
+
+/**
+ * @author laoyingyong
+ * @date: 2020-02-05 10:27
+ */
+@WebServlet("/DownloadFileServlet2")
+public class DownloadFileServlet2 extends HttpServlet
+{
+    protected void doPost(HttpServletRequest request, HttpServletResponse response) throws ServletException, IOException
+    {
+        ServletOutputStream outputStream = response.getOutputStream();//网络字节输出流
+        WaterQualityService service=new WaterQualityServiceImpl();
+        List<WaterQuality> weekData = service.findWeekData();
+
+        outputStream.write(("测站名"+"\t"+"时间"+"\t"+"PH"+"\t"+"溶解氧"+"\t"+"氨氮"+"\t"+"高猛酸钾盐指数"+"\t"+"总有机碳"+"\t"+"水质类别"+"\n").getBytes());
+        outputStream.write("---------------------------------------------------------------最近七天的水质数据--\n".getBytes());
+        for (WaterQuality item : weekData)
+        {
+            String belongStation = item.getBelongStation();
+
+            Timestamp dateTime = item.getDateTime();
+            SimpleDateFormat simpleDateFormat=new SimpleDateFormat("yyyy-MM-dd HH:mm");
+            String format = simpleDateFormat.format(dateTime);
+            Double aDouble = item.getpH();
+            Double aDouble1 = item.getdO();
+            Double aDouble2 = item.getnH4();
+            Double aDouble3 = item.getcODMn();
+            Double aDouble4 = item.gettOC();
+            String level = item.getLevel();
+
+            outputStream.write((belongStation+"\t"+format+"\t"+aDouble+"\t"+aDouble1+"\t"+aDouble2+"\t"+aDouble3+"\t"+aDouble4+"\t"+level+"\n").getBytes());
+
+
+        }
+
+
+        String filename = request.getParameter("filename");
+
+
+        ServletContext servletContext = request.getServletContext();
+
+        //设置响应的mime类型
+        String mimeType = servletContext.getMimeType(filename);
+        response.setContentType(mimeType);
+
+
+        String encodeFileName = URLEncoder.encode(filename, "utf-8");//编码，解决文件中文乱码问题
+        response.setHeader("content-disposition","attachment;filename="+encodeFileName);
+
+
+    }
+
+    protected void doGet(HttpServletRequest request, HttpServletResponse response) throws ServletException, IOException
+    {
+
+        this.doPost(request, response);
+
+    }
+}

src/src_houduan/web/servlet/others/UploadServlet.java

@@ -0,0 +1,130 @@
+package web.servlet.others;
+
+import domain.WaterQuality;
+import org.apache.commons.fileupload.FileItem;
+import org.apache.commons.fileupload.FileUploadException;
+import org.apache.commons.fileupload.disk.DiskFileItemFactory;
+import org.apache.commons.fileupload.servlet.ServletFileUpload;
+import service.WaterQualityService;
+import service.impl.WaterQualityServiceImpl;
+
+import javax.servlet.ServletException;
+import javax.servlet.annotation.WebServlet;
+import javax.servlet.http.HttpServlet;
+import javax.servlet.http.HttpServletRequest;
+import javax.servlet.http.HttpServletResponse;
+import java.io.*;
+import java.sql.Timestamp;
+import java.text.SimpleDateFormat;
+import java.util.Arrays;
+import java.util.Date;
+import java.util.List;
+
+/**
+ * @author laoyingyong
+ * @date: 2020-02-11 12:12
+ */
+@WebServlet("/UploadServlet")
+public class UploadServlet extends HttpServlet
+{
+
+
+    protected void doPost(HttpServletRequest request, HttpServletResponse response) throws ServletException, IOException
+    {
+
+        int count=0;
+        WaterQualityService service=new WaterQualityServiceImpl();
+
+
+        request.setCharacterEncoding("UTF-8");
+        //String type=request.getParameter("type");
+
+        try {
+            // 配置上传参数
+            DiskFileItemFactory factory = new DiskFileItemFactory();
+            ServletFileUpload upload = new ServletFileUpload(factory);
+            // 解析请求的内容提取文件数据
+            @SuppressWarnings("unchecked")
+            List<FileItem> formItems = upload.parseRequest(request);
+
+
+            // 迭代表单数据
+            for (FileItem item : formItems)
+            {
+                // 处理不在表单中的字段
+                if (!item.isFormField())
+                {
+                    String fileName = item.getName(); //获取上传的文件名
+                    String fileType=fileName.substring(fileName.lastIndexOf(".")+1);
+                    //定义上传文件的存放路径
+                    String path = request.getServletContext().getRealPath("/upload");
+                    //定义上传文件的完整路径
+                    fileName= new SimpleDateFormat("yyyyMMddhhmmss").format(new Date()).toString();
+                    fileName+="."+fileType;  //将文件名字改为时间，避免重名文件
+                    String filePath = String.format("%s\\%s",path,fileName);
+                    File storeFile = new File(filePath);
+                    // 在控制台输出文件的上传路径
+                    System.out.println(path);
+                    System.out.println(filePath);
+
+                    // 保存文件到硬盘
+                    item.write(storeFile);
+
+                    BufferedReader bufferedReader=new BufferedReader(new InputStreamReader(new FileInputStream(filePath),"utf-8"));//缓冲字符输入流、转换流
+                    String line=null;
+
+                    while((line=bufferedReader.readLine())!=null)
+                    {
+                        //System.out.println(line);
+                        String[] split = line.split("\t");
+                        System.out.println(Arrays.toString(split));
+                        WaterQuality waterQuality=new WaterQuality();
+                        try
+                        {
+                            waterQuality.setBelongStation(split[0]);
+                            waterQuality.setDateTime(Timestamp.valueOf(split[1]+":00"));
+                            if(!split[2].equals("null"))
+                            {waterQuality.setpH(Double.parseDouble(split[2]));}
+                            if(!split[3].equals("null"))
+                            {waterQuality.setdO(Double.parseDouble(split[3]));}
+                            if(!split[4].equals("null"))
+                            {waterQuality.setnH4(Double.parseDouble(split[4]));}
+                            if(!split[5].equals("null"))
+                            {waterQuality.setcODMn(Double.parseDouble(split[5]));}
+                            if(!split[6].equals("null"))
+                            {waterQuality.settOC(Double.parseDouble(split[6]));}
+                            if(!split[7].equals("null"))
+                            {waterQuality.setLevel(split[7]);}
+                        } catch (Exception e)
+                        {
+                            System.out.println(e);
+                        }
+                        boolean b = service.addOne(waterQuality);
+                        if(b)
+                        {
+                            count++;
+                        }
+                    }
+                }
+            }
+        } catch (FileUploadException e) {
+            e.printStackTrace();
+        } catch (Exception e) {
+            e.printStackTrace();
+        }
+
+
+        request.setAttribute("message",count);
+        // 跳转到 message.jsp
+        getServletContext().getRequestDispatcher("/message.jsp").forward(
+                request, response);
+
+    }
+
+    protected void doGet(HttpServletRequest request, HttpServletResponse response) throws ServletException, IOException
+    {
+
+        this.doPost(request, response);
+
+    }
+}

src/src_houduan/web/servlet/others/UploadServlet2.java

@@ -0,0 +1,128 @@
+package web.servlet.others;
+
+import domain.WaterLevel;
+import domain.WaterQuality;
+import org.apache.commons.fileupload.FileItem;
+import org.apache.commons.fileupload.FileUploadException;
+import org.apache.commons.fileupload.disk.DiskFileItemFactory;
+import org.apache.commons.fileupload.servlet.ServletFileUpload;
+import service.WaterLevelService;
+import service.WaterQualityService;
+import service.impl.WaterLevelServiceImpl;
+import service.impl.WaterQualityServiceImpl;
+
+import javax.servlet.ServletException;
+import javax.servlet.annotation.WebServlet;
+import javax.servlet.http.HttpServlet;
+import javax.servlet.http.HttpServletRequest;
+import javax.servlet.http.HttpServletResponse;
+import java.io.*;
+import java.sql.Timestamp;
+import java.text.SimpleDateFormat;
+import java.util.Arrays;
+import java.util.Date;
+import java.util.List;
+
+/**
+ * @author laoyingyong
+ * @date: 2020-02-11 12:12
+ */
+@WebServlet("/UploadServlet2")
+public class UploadServlet2 extends HttpServlet
+{
+
+
+    protected void doPost(HttpServletRequest request, HttpServletResponse response) throws ServletException, IOException
+    {
+
+        int count=0;
+        WaterLevelService service=new WaterLevelServiceImpl();
+
+
+        request.setCharacterEncoding("UTF-8");
+        //String type=request.getParameter("type");
+
+        try {
+            // 配置上传参数
+            DiskFileItemFactory factory = new DiskFileItemFactory();
+            ServletFileUpload upload = new ServletFileUpload(factory);
+            // 解析请求的内容提取文件数据
+            @SuppressWarnings("unchecked")
+            List<FileItem> formItems = upload.parseRequest(request);
+
+
+            // 迭代表单数据
+            for (FileItem item : formItems)
+            {
+                // 处理不在表单中的字段
+                if (!item.isFormField())
+                {
+                    String fileName = item.getName(); //获取上传的文件名
+                    String fileType=fileName.substring(fileName.lastIndexOf(".")+1);
+                    //定义上传文件的存放路径
+                    String path = request.getServletContext().getRealPath("/upload");
+                    //定义上传文件的完整路径
+                    fileName= new SimpleDateFormat("yyyyMMddhhmmss").format(new Date()).toString();
+                    fileName+="."+fileType;  //将文件名字改为时间，避免重名文件
+                    String filePath = String.format("%s\\%s",path,fileName);
+                    File storeFile = new File(filePath);
+                    // 在控制台输出文件的上传路径
+                    System.out.println(path);
+                    System.out.println(filePath);
+
+                    // 保存文件到硬盘
+                    item.write(storeFile);
+
+                    BufferedReader bufferedReader=new BufferedReader(new InputStreamReader(new FileInputStream(filePath),"utf-8"));//缓冲字符输入流、转换流
+                    String line=null;
+
+                    while((line=bufferedReader.readLine())!=null)
+                    {
+                        //System.out.println(line);
+                        String[] split = line.split("\t");
+                        System.out.println(Arrays.toString(split));
+                        WaterLevel waterLevel=new WaterLevel();
+                        try
+                        {
+                            waterLevel.setRiverName(split[0]);
+                            waterLevel.setSiteName(split[1]);
+                            waterLevel.setCollectionDate(Timestamp.valueOf(split[2]+":00"));
+                            if(!split[3].equals("null"))
+                            {waterLevel.setWaterLevel(Double.parseDouble(split[3]));}
+                            if(!split[4].equals("null"))
+                            {waterLevel.setFlow(Double.parseDouble(split[4]));}
+                            if(!split[5].equals("null"))
+                            {waterLevel.setOver(Double.parseDouble(split[5]));}
+                        } catch (Exception e)
+                        {
+                            System.out.println(e);
+                        }
+                        boolean b = service.addWaterLevelInfo(waterLevel);
+                        if(b)
+                        {
+                            count++;
+                        }
+                    }
+                }
+            }
+        } catch (FileUploadException e) {
+            e.printStackTrace();
+        } catch (Exception e) {
+            e.printStackTrace();
+        }
+
+
+        request.setAttribute("message",count);
+        // 跳转到 message.jsp
+        getServletContext().getRequestDispatcher("/otherPage/message2.jsp").forward(
+                request, response);
+
+    }
+
+    protected void doGet(HttpServletRequest request, HttpServletResponse response) throws ServletException, IOException
+    {
+
+        this.doPost(request, response);
+
+    }
+}

src/src_houduan/web/servlet/user/AddUserServlet.java

@@ -0,0 +1,46 @@
+package web.servlet.user;
+
+
+import domain.User;
+import org.apache.commons.beanutils.BeanUtils;
+import service.UserService;
+import service.impl.UserServiceImpl;
+
+import javax.servlet.ServletException;
+import javax.servlet.annotation.WebServlet;
+import javax.servlet.http.HttpServlet;
+import javax.servlet.http.HttpServletRequest;
+import javax.servlet.http.HttpServletResponse;
+import java.io.IOException;
+import java.lang.reflect.InvocationTargetException;
+import java.util.Map;
+
+@WebServlet("/addUserServlet")
+public class AddUserServlet extends HttpServlet {
+    protected void doPost(HttpServletRequest request, HttpServletResponse response) throws ServletException, IOException {
+        //1.设置编码
+        request.setCharacterEncoding("utf-8");
+        //2.获取参数
+        Map<String, String[]> map = request.getParameterMap();
+        //3.封装对象
+        User user = new User();
+        try {
+            BeanUtils.populate(user,map);
+        } catch (IllegalAccessException e) {
+            e.printStackTrace();
+        } catch (InvocationTargetException e) {
+            e.printStackTrace();
+        }
+
+        //4.调用Service保存
+        UserService service = new UserServiceImpl();
+        service.addUser(user);
+
+        //5.跳转到userListServlet
+        response.sendRedirect(request.getContextPath()+"/userListServlet");
+    }
+
+    protected void doGet(HttpServletRequest request, HttpServletResponse response) throws ServletException, IOException {
+        this.doPost(request, response);
+    }
+}

src/src_houduan/web/servlet/user/DelSelectedServlet.java

@@ -0,0 +1,31 @@
+package web.servlet.user;
+
+
+
+import service.UserService;
+import service.impl.UserServiceImpl;
+
+import javax.servlet.ServletException;
+import javax.servlet.annotation.WebServlet;
+import javax.servlet.http.HttpServlet;
+import javax.servlet.http.HttpServletRequest;
+import javax.servlet.http.HttpServletResponse;
+import java.io.IOException;
+
+@WebServlet("/delSelectedServlet")
+public class DelSelectedServlet extends HttpServlet {
+    protected void doPost(HttpServletRequest request, HttpServletResponse response) throws ServletException, IOException {
+        //1.获取所有id
+        String[] ids = request.getParameterValues("uid");
+        //2.调用service删除
+        UserService service = new UserServiceImpl();
+        service.delSelectedUser(ids);
+
+        //3.跳转查询所有Servlet
+        response.sendRedirect(request.getContextPath()+"/userListServlet");
+    }
+
+    protected void doGet(HttpServletRequest request, HttpServletResponse response) throws ServletException, IOException {
+        this.doPost(request, response);
+    }
+}

src/src_houduan/web/servlet/user/DelUserServlet.java

@@ -0,0 +1,31 @@
+package web.servlet.user;
+
+
+
+import service.UserService;
+import service.impl.UserServiceImpl;
+
+import javax.servlet.ServletException;
+import javax.servlet.annotation.WebServlet;
+import javax.servlet.http.HttpServlet;
+import javax.servlet.http.HttpServletRequest;
+import javax.servlet.http.HttpServletResponse;
+import java.io.IOException;
+
+@WebServlet("/delUserServlet")
+public class DelUserServlet extends HttpServlet {
+    protected void doPost(HttpServletRequest request, HttpServletResponse response) throws ServletException, IOException {
+        //1.获取id
+        String id = request.getParameter("id");
+        //2.调用service删除
+        UserService service = new UserServiceImpl();
+        service.deleteUser(id);
+
+        //3.跳转到查询所有Servlet
+        response.sendRedirect(request.getContextPath()+"/userListServlet");
+    }
+
+    protected void doGet(HttpServletRequest request, HttpServletResponse response) throws ServletException, IOException {
+        this.doPost(request, response);
+    }
+}

src/src_houduan/web/servlet/user/FindUserByPageServlet.java

@@ -0,0 +1,56 @@
+package web.servlet.user;
+
+
+
+import domain.User;
+import domain.PageBean;
+import service.UserService;
+import service.impl.UserServiceImpl;
+
+import javax.servlet.ServletException;
+import javax.servlet.annotation.WebServlet;
+import javax.servlet.http.HttpServlet;
+import javax.servlet.http.HttpServletRequest;
+import javax.servlet.http.HttpServletResponse;
+import java.io.IOException;
+import java.util.Map;
+
+@WebServlet("/findUserByPageServlet")
+public class FindUserByPageServlet extends HttpServlet {
+    protected void doPost(HttpServletRequest request, HttpServletResponse response) throws ServletException, IOException {
+        request.setCharacterEncoding("utf-8");
+
+        //1.获取参数
+        String currentPage = request.getParameter("currentPage");//当前页码
+        String rows = request.getParameter("rows");//每页显示条数
+
+        if(currentPage == null || "".equals(currentPage)){
+
+            currentPage = "1";
+        }
+
+        if(rows == null || "".equals(rows)){
+            rows = "5";
+        }
+        
+        //获取条件查询参数
+        Map<String, String[]> condition = request.getParameterMap();
+
+
+        //2.调用service查询
+        UserService service = new UserServiceImpl();
+        PageBean<User> pb = service.findUserByPage(currentPage,rows,condition);
+
+        System.out.println(pb);
+
+        //3.将PageBean存入request
+        request.setAttribute("pb",pb);
+        request.setAttribute("condition",condition);//将查询条件存入request
+        //4.转发到list.jsp
+        request.getRequestDispatcher("/list.jsp").forward(request,response);
+    }
+
+    protected void doGet(HttpServletRequest request, HttpServletResponse response) throws ServletException, IOException {
+        this.doPost(request, response);
+    }
+}

src/src_houduan/web/servlet/user/FindUserServlet.java

@@ -0,0 +1,34 @@
+package web.servlet.user;
+
+
+
+import domain.User;
+import service.UserService;
+import service.impl.UserServiceImpl;
+
+import javax.servlet.ServletException;
+import javax.servlet.annotation.WebServlet;
+import javax.servlet.http.HttpServlet;
+import javax.servlet.http.HttpServletRequest;
+import javax.servlet.http.HttpServletResponse;
+import java.io.IOException;
+
+@WebServlet("/findUserServlet")
+public class FindUserServlet extends HttpServlet {
+    protected void doPost(HttpServletRequest request, HttpServletResponse response) throws ServletException, IOException {
+        //1.获取id
+        String id = request.getParameter("id");
+        //2.调用Service查询
+        UserService service = new UserServiceImpl();
+        User user = service.findUserById(id);
+
+        //3.将user存入request
+        request.setAttribute("user",user);
+        //4.转发到update.jsp
+        request.getRequestDispatcher("/update.jsp").forward(request,response);
+    }
+
+    protected void doGet(HttpServletRequest request, HttpServletResponse response) throws ServletException, IOException {
+        this.doPost(request, response);
+    }
+}

src/src_houduan/web/servlet/user/LoginServlet.java

@@ -0,0 +1,82 @@
+package web.servlet.user;
+
+
+import domain.User;
+import org.apache.commons.beanutils.BeanUtils;
+import service.UserService;
+import service.impl.UserServiceImpl;
+
+import javax.servlet.ServletException;
+import javax.servlet.annotation.WebServlet;
+import javax.servlet.http.HttpServlet;
+import javax.servlet.http.HttpServletRequest;
+import javax.servlet.http.HttpServletResponse;
+import javax.servlet.http.HttpSession;
+import java.io.IOException;
+import java.lang.reflect.InvocationTargetException;
+import java.util.Map;
+
+@WebServlet("/loginServlet")
+public class LoginServlet extends HttpServlet {
+    protected void doPost(HttpServletRequest request, HttpServletResponse response) throws ServletException, IOException {
+        //1.设置编码
+        request.setCharacterEncoding("utf-8");
+
+        //2.获取数据
+        //2.1获取用户填写验证码
+        String verifycode = request.getParameter("verifycode");
+
+        //3.验证码校验
+        HttpSession session = request.getSession();
+        String checkcode_server = (String) session.getAttribute("CHECKCODE_SERVER");
+        session.removeAttribute("CHECKCODE_SERVER");//确保验证码一次性
+        if(!checkcode_server.equalsIgnoreCase(verifycode)){
+            //验证码不正确
+            //提示信息
+            request.setAttribute("login_msg","验证码错误！");
+            //跳转登录页面
+            request.getRequestDispatcher("/login.jsp").forward(request,response);
+
+            return;
+        }
+
+        Map<String, String[]> map = request.getParameterMap();
+        //4.封装User对象
+        User user = new User();
+        try {
+            BeanUtils.populate(user,map);
+        } catch (IllegalAccessException e) {
+            e.printStackTrace();
+        } catch (InvocationTargetException e) {
+            e.printStackTrace();
+        }
+
+
+        //5.调用Service查询
+        UserService service = new UserServiceImpl();
+        User loginUser = service.login(user);
+        //6.判断是否登录成功
+        if(loginUser != null){
+            //登录成功
+            //将用户存入session
+            session.setAttribute("user",loginUser);
+            //跳转页面
+            response.sendRedirect(request.getContextPath()+"/index.jsp");
+        }else{
+            //登录失败
+            //提示信息
+            request.setAttribute("login_msg","用户名或密码错误！");
+            //跳转登录页面
+            request.getRequestDispatcher("/login.jsp").forward(request,response);
+
+        }
+
+
+
+
+    }
+
+    protected void doGet(HttpServletRequest request, HttpServletResponse response) throws ServletException, IOException {
+        this.doPost(request, response);
+    }
+}

src/src_houduan/web/servlet/user/LogoutServlet.java

@@ -0,0 +1,27 @@
+package web.servlet.user;
+
+import javax.servlet.ServletException;
+import javax.servlet.annotation.WebServlet;
+import javax.servlet.http.HttpServlet;
+import javax.servlet.http.HttpServletRequest;
+import javax.servlet.http.HttpServletResponse;
+import javax.servlet.http.HttpSession;
+import java.io.IOException;
+
+@WebServlet("/LogoutServlet")
+public class LogoutServlet extends HttpServlet
+{
+    protected void doPost(HttpServletRequest request, HttpServletResponse response) throws ServletException, IOException
+    {
+        HttpSession session = request.getSession();
+        session.removeAttribute("user");
+        response.sendRedirect(request.getContextPath()+"/login.jsp");
+    }
+
+    protected void doGet(HttpServletRequest request, HttpServletResponse response) throws ServletException, IOException
+    {
+
+        this.doPost(request, response);
+
+    }
+}

src/src_houduan/web/servlet/user/RegisterServlet.java

@@ -0,0 +1,39 @@
+package web.servlet.user;
+
+import domain.User;
+import service.impl.UserServiceImpl;
+
+import javax.servlet.ServletException;
+import javax.servlet.annotation.WebServlet;
+import javax.servlet.http.HttpServlet;
+import javax.servlet.http.HttpServletRequest;
+import javax.servlet.http.HttpServletResponse;
+import java.io.IOException;
+
+@WebServlet("/RegisterServlet")
+public class RegisterServlet extends HttpServlet
+{
+    protected void doPost(HttpServletRequest request, HttpServletResponse response) throws ServletException, IOException
+    {
+        request.setCharacterEncoding("utf-8");
+        String username = request.getParameter("username");
+        String password = request.getParameter("password");
+        User registerUser=new User();
+        registerUser.setUsername(username);
+        registerUser.setPassword(password);
+
+
+        UserServiceImpl service=new UserServiceImpl();
+        service.userRegister(registerUser);
+
+        request.setAttribute("register_msg","注册成功！");
+        request.getRequestDispatcher("/register.jsp").forward(request,response);
+    }
+
+    protected void doGet(HttpServletRequest request, HttpServletResponse response) throws ServletException, IOException
+    {
+
+        this.doPost(request, response);
+
+    }
+}

src/src_houduan/web/servlet/user/UpdatePasswordServlet.java

@@ -0,0 +1,50 @@
+package web.servlet.user;
+
+import com.fasterxml.jackson.databind.ObjectMapper;
+import domain.ResultInfo;
+import domain.User;
+import service.impl.UserServiceImpl;
+
+import javax.servlet.ServletException;
+import javax.servlet.annotation.WebServlet;
+import javax.servlet.http.HttpServlet;
+import javax.servlet.http.HttpServletRequest;
+import javax.servlet.http.HttpServletResponse;
+import javax.servlet.http.HttpSession;
+import java.io.IOException;
+
+@WebServlet("/UpdatePasswordServlet")
+public class UpdatePasswordServlet extends HttpServlet
+{
+    protected void doPost(HttpServletRequest request, HttpServletResponse response) throws ServletException, IOException
+    {
+        String username = request.getParameter("username");
+        String newPassword = request.getParameter("newPassword");
+
+        User user=new User();
+        user.setUsername(username);
+        user.setPassword(newPassword);
+
+        UserServiceImpl service=new UserServiceImpl();
+        service.updateUserPassword(user);
+
+        HttpSession session = request.getSession();
+        session.removeAttribute("user");
+
+        ResultInfo info=new ResultInfo();
+        info.setMsg("密码修改成功！");
+
+        ObjectMapper mapper=new ObjectMapper();
+        response.setContentType("application/json;charset=utf-8");
+        mapper.writeValue(response.getOutputStream(),info);
+
+
+    }
+
+    protected void doGet(HttpServletRequest request, HttpServletResponse response) throws ServletException, IOException
+    {
+
+        this.doPost(request, response);
+
+    }
+}

src/src_houduan/web/servlet/user/UpdateUserInfoServlet.java

@@ -0,0 +1,74 @@
+package web.servlet.user;
+
+import com.fasterxml.jackson.databind.ObjectMapper;
+import domain.ResultInfo;
+import domain.User;
+import service.UserService;
+import service.impl.UserServiceImpl;
+
+import javax.servlet.ServletException;
+import javax.servlet.annotation.WebServlet;
+import javax.servlet.http.HttpServlet;
+import javax.servlet.http.HttpServletRequest;
+import javax.servlet.http.HttpServletResponse;
+import java.io.IOException;
+
+/**
+ * @author laoyingyong
+ * @date: 2020-01-22 19:01
+ */
+@WebServlet("/UpdateUserInfoServlet")
+public class UpdateUserInfoServlet extends HttpServlet
+{
+    protected void doPost(HttpServletRequest request, HttpServletResponse response) throws ServletException, IOException
+    {
+        String id = request.getParameter("id");
+        String name = request.getParameter("name");
+        String gender = request.getParameter("gender");
+        String age = request.getParameter("age");
+        String address = request.getParameter("address");
+        String qq = request.getParameter("qq");
+        String email = request.getParameter("email");
+
+
+        User user=new User();
+        try
+        {
+            user.setId(Integer.parseInt(id));
+            user.setName(name);
+            user.setGender(gender);
+            user.setAge(Integer.parseInt(age));
+            user.setAddress(address);
+            user.setQq(qq);
+            user.setEmail(email);
+        } catch (Exception e)
+        {
+            System.out.println(e);
+        }
+
+
+        UserService service=new UserServiceImpl();
+        boolean b = service.updateUserInfo(user);
+        ResultInfo info=new ResultInfo();
+        if(b)
+        {
+            info.setMsg("修改成功，下次登录后即可查看更新！");
+        }
+        else
+        {
+            info.setMsg("修改失败！");
+        }
+
+        ObjectMapper mapper=new ObjectMapper();
+        response.setContentType("application/json;charset=utf8");
+        mapper.writeValue(response.getOutputStream(),info);
+
+    }
+
+    protected void doGet(HttpServletRequest request, HttpServletResponse response) throws ServletException, IOException
+    {
+
+        this.doPost(request, response);
+
+    }
+}

src/src_houduan/web/servlet/user/UpdateUserServlet.java

@@ -0,0 +1,47 @@
+package web.servlet.user;
+
+import domain.User;
+import org.apache.commons.beanutils.BeanUtils;
+import service.UserService;
+import service.impl.UserServiceImpl;
+
+import javax.servlet.ServletException;
+import javax.servlet.annotation.WebServlet;
+import javax.servlet.http.HttpServlet;
+import javax.servlet.http.HttpServletRequest;
+import javax.servlet.http.HttpServletResponse;
+import java.io.IOException;
+import java.lang.reflect.InvocationTargetException;
+import java.util.Map;
+
+@WebServlet("/updateUserServlet")
+public class UpdateUserServlet extends HttpServlet {
+    protected void doPost(HttpServletRequest request, HttpServletResponse response) throws ServletException, IOException {
+        //1.设置编码
+        request.setCharacterEncoding("utf-8");
+        //2.获取map
+        Map<String, String[]> map = request.getParameterMap();
+        //3.封装对象
+        User user = new User();
+        try {
+            BeanUtils.populate(user,map);
+        } catch (IllegalAccessException e) {
+            e.printStackTrace();
+        } catch (InvocationTargetException e) {
+            e.printStackTrace();
+        }
+
+        //4.调用Service修改
+        UserService service = new UserServiceImpl();
+        service.updateUser(user);
+
+        //5.跳转到查询所有Servlet
+        response.sendRedirect(request.getContextPath()+"/userListServlet");
+    }
+
+    protected void doGet(HttpServletRequest request, HttpServletResponse response) throws ServletException, IOException
+    {
+        
+        this.doPost(request, response);
+    }
+}

src/src_houduan/web/servlet/user/UserListServlet.java

@@ -0,0 +1,31 @@
+package web.servlet.user;
+
+
+import domain.User;
+import service.UserService;
+import service.impl.UserServiceImpl;
+
+import javax.servlet.ServletException;
+import javax.servlet.annotation.WebServlet;
+import javax.servlet.http.HttpServlet;
+import javax.servlet.http.HttpServletRequest;
+import javax.servlet.http.HttpServletResponse;
+import java.io.IOException;
+import java.util.List;
+
+@WebServlet("/userListServlet")
+public class UserListServlet extends HttpServlet {
+    protected void doPost(HttpServletRequest request, HttpServletResponse response) throws ServletException, IOException {
+        //1.调用UserService完成查询
+        UserService service = new UserServiceImpl();
+        List<User> users = service.findAll();
+        //2.将list存入request域
+        request.setAttribute("users",users);
+        //3.转发到list.jsp
+        request.getRequestDispatcher("/list.jsp").forward(request,response);
+    }
+
+    protected void doGet(HttpServletRequest request, HttpServletResponse response) throws ServletException, IOException {
+        this.doPost(request, response);
+    }
+}

src/src_houduan/web/servlet/waterQualityStation/AddWaterQualityDataServlet.java

@@ -0,0 +1,67 @@
+package web.servlet.waterQualityStation;
+
+import com.fasterxml.jackson.databind.ObjectMapper;
+import domain.ResultInfo;
+import domain.WaterQualityStation;
+import service.WaterQualityStationService;
+import service.impl.WaterQualityStationServiceImpl;
+
+import javax.servlet.ServletException;
+import javax.servlet.annotation.WebServlet;
+import javax.servlet.http.HttpServlet;
+import javax.servlet.http.HttpServletRequest;
+import javax.servlet.http.HttpServletResponse;
+import java.io.IOException;
+
+@WebServlet("/AddWaterQualityDataServlet")
+public class AddWaterQualityDataServlet extends HttpServlet
+{
+    protected void doPost(HttpServletRequest request, HttpServletResponse response) throws ServletException, IOException
+    {
+        request.setCharacterEncoding("utf-8");
+        String stationName = request.getParameter("stationName");
+        String longitude = request.getParameter("longitude");
+        String latitude = request.getParameter("latitude");
+        String section = request.getParameter("section");
+        String introduction = request.getParameter("introduction");
+        WaterQualityStation station=new WaterQualityStation();
+        //封装对象
+        try
+        {
+            station.setStationName(stationName);
+            station.setLongitude(Double.parseDouble(longitude));
+            station.setLatitude(Double.parseDouble(latitude));
+            station.setSection(section);
+            station.setIntroduction(introduction);
+        } catch (NumberFormatException e)
+        {
+            System.out.println(e);
+        }
+
+        WaterQualityStationService service=new WaterQualityStationServiceImpl();
+        boolean flag = service.addWaterQualityStation(station);
+
+        ResultInfo info=new ResultInfo();
+        if(flag)
+        {
+            info.setMsg("添加成功！");
+        }
+        else
+        {
+            info.setMsg("添加失败，监测站点名已存在！");
+        }
+
+        ObjectMapper mapper=new ObjectMapper();
+        response.setContentType("application/json;charset=utf-8");
+        System.out.println(info);
+        String string = mapper.writeValueAsString(info);
+        response.getWriter().write(string);
+    }
+
+    protected void doGet(HttpServletRequest request, HttpServletResponse response) throws ServletException, IOException
+    {
+
+        this.doPost(request, response);
+
+    }
+}

src/src_houduan/web/servlet/waterQualityStation/ConditionalQueryStationByPageServlet.java

@@ -0,0 +1,63 @@
+package web.servlet.waterQualityStation;
+
+import com.fasterxml.jackson.databind.ObjectMapper;
+import domain.PageBean;
+import domain.WaterQualityStation;
+import service.WaterQualityStationService;
+import service.impl.WaterQualityStationServiceImpl;
+
+
+import javax.servlet.ServletException;
+import javax.servlet.annotation.WebServlet;
+import javax.servlet.http.HttpServlet;
+import javax.servlet.http.HttpServletRequest;
+import javax.servlet.http.HttpServletResponse;
+import java.io.IOException;
+import java.util.Map;
+
+@WebServlet("/ConditionalQueryStationByPageServlet")
+public class ConditionalQueryStationByPageServlet extends HttpServlet
+{
+    protected void doPost(HttpServletRequest request, HttpServletResponse response) throws ServletException, IOException
+    {
+        request.setCharacterEncoding("utf-8");
+        WaterQualityStationService service=new WaterQualityStationServiceImpl();
+        Map<String, String[]> parameterMap = request.getParameterMap();
+        int totalCount = service.conditionalFindAllCount(parameterMap); //总的记录数
+
+        String currentPage = request.getParameter("currentPage");
+        String pageSize = request.getParameter("pageSize");
+        int intCurrentPage = 1;
+        int intPageSize = 5;
+        try {
+            intCurrentPage = Integer.parseInt(currentPage);
+            intPageSize = Integer.parseInt(pageSize);
+        } catch (NumberFormatException e) {
+            System.out.println(e);
+        }
+        int totalPage=totalCount%intPageSize==0?totalCount/intPageSize:(totalCount/intPageSize+1);
+        if(intCurrentPage<=0)
+        {
+            intCurrentPage=1;
+        }
+        if(intCurrentPage>totalPage)
+        {
+            intCurrentPage=totalPage;
+
+        }
+
+        PageBean<WaterQualityStation> bean = service.conditonalQueryByPage(intCurrentPage, intPageSize, parameterMap);
+        ObjectMapper mapper=new ObjectMapper();
+        response.setContentType("application/json;chartset=utf-8");
+        System.out.println(bean);
+        mapper.writeValue(response.getOutputStream(),bean);
+
+    }
+
+    protected void doGet(HttpServletRequest request, HttpServletResponse response) throws ServletException, IOException
+    {
+
+        this.doPost(request, response);
+
+    }
+}

src/src_houduan/web/servlet/waterQualityStation/DeleteStationServlet.java

@@ -0,0 +1,55 @@
+package web.servlet.waterQualityStation;
+
+import com.fasterxml.jackson.databind.ObjectMapper;
+import domain.ResultInfo;
+import domain.WaterQualityStation;
+import service.WaterQualityStationService;
+import service.impl.WaterQualityStationServiceImpl;
+
+import javax.servlet.ServletException;
+import javax.servlet.annotation.WebServlet;
+import javax.servlet.http.HttpServlet;
+import javax.servlet.http.HttpServletRequest;
+import javax.servlet.http.HttpServletResponse;
+import java.io.IOException;
+
+@WebServlet("/DeleteStationServlet")
+public class DeleteStationServlet extends HttpServlet
+{
+    protected void doPost(HttpServletRequest request, HttpServletResponse response) throws ServletException, IOException
+    {
+        String id = request.getParameter("id");
+
+        int i=0;
+        try
+        {
+            i = Integer.parseInt(id);
+        } catch (NumberFormatException e)
+        {
+            System.out.println(e);
+        }
+
+        WaterQualityStationService service=new WaterQualityStationServiceImpl();
+        boolean flag = service.delete(i);
+        ResultInfo info=new ResultInfo();
+        if(flag)
+        {
+            info.setMsg("删除成功！");
+        }
+        else
+        {
+            info.setMsg("删除失败！");
+        }
+        ObjectMapper mapper=new ObjectMapper();
+        response.setContentType("application/json;charset=utf-8");
+        mapper.writeValue(response.getOutputStream(),info);
+
+    }
+
+    protected void doGet(HttpServletRequest request, HttpServletResponse response) throws ServletException, IOException
+    {
+
+        this.doPost(request, response);
+
+    }
+}

src/src_houduan/web/servlet/waterQualityStation/FindAlllStationServlet.java

@@ -0,0 +1,35 @@
+package web.servlet.waterQualityStation;
+
+import com.fasterxml.jackson.databind.ObjectMapper;
+import domain.WaterQualityStation;
+import service.WaterQualityStationService;
+import service.impl.WaterQualityStationServiceImpl;
+
+import javax.servlet.ServletException;
+import javax.servlet.annotation.WebServlet;
+import javax.servlet.http.HttpServlet;
+import javax.servlet.http.HttpServletRequest;
+import javax.servlet.http.HttpServletResponse;
+import java.io.IOException;
+import java.util.List;
+
+@WebServlet("/FindAlllStationServlet")
+public class FindAlllStationServlet extends HttpServlet
+{
+    protected void doPost(HttpServletRequest request, HttpServletResponse response) throws ServletException, IOException
+    {
+        WaterQualityStationService service=new WaterQualityStationServiceImpl();
+        List<WaterQualityStation> list = service.findAll();
+        ObjectMapper mapper=new ObjectMapper();
+        response.setContentType("application/json;charset=utf-8");
+        mapper.writeValue(response.getOutputStream(),list);
+
+    }
+
+    protected void doGet(HttpServletRequest request, HttpServletResponse response) throws ServletException, IOException
+    {
+
+        this.doPost(request, response);
+
+    }
+}

src/src_houduan/web/servlet/waterQualityStation/FindByNameAndTimeServlet.java

@@ -0,0 +1,60 @@
+package web.servlet.waterQualityStation;
+
+import com.fasterxml.jackson.databind.ObjectMapper;
+import domain.WaterQuality;
+import service.WaterQualityService;
+import service.impl.WaterQualityServiceImpl;
+
+import javax.servlet.ServletException;
+import javax.servlet.annotation.WebServlet;
+import javax.servlet.http.HttpServlet;
+import javax.servlet.http.HttpServletRequest;
+import javax.servlet.http.HttpServletResponse;
+import java.io.IOException;
+import java.util.List;
+
+/**
+ * @author laoyingyong
+ * @date: 2020-02-03 23:11
+ */
+@WebServlet("/FindByNameAndTimeServlet")
+public class FindByNameAndTimeServlet extends HttpServlet
+{
+    protected void doPost(HttpServletRequest request, HttpServletResponse response) throws ServletException, IOException
+    {
+        String name = request.getParameter("cezhanName");
+        System.out.println(name);
+        String star = request.getParameter("startTime");
+        String startTime=null;
+        if(star!=null)
+        {
+           startTime=star.replace("T"," ")+":00";
+            System.out.println("开始时间"+startTime);
+        }
+        String end = request.getParameter("endTime");
+        String endTime=null;
+        if(end!=null)
+        {
+            endTime=end.replace("T"," ")+":00";
+            System.out.println("结束时间"+endTime);
+        }
+        String water_level = request.getParameter("water_level");
+        System.out.println("level:"+water_level);
+
+
+        WaterQualityService service=new WaterQualityServiceImpl();
+        List<WaterQuality> byNameAndTime = service.findByNameAndTime(name, startTime, endTime,water_level);
+        System.out.println(byNameAndTime);
+        ObjectMapper mapper=new ObjectMapper();
+        response.setContentType("application/json;chartset=utf-8");
+        mapper.writeValue(response.getOutputStream(),byNameAndTime);
+
+    }
+
+    protected void doGet(HttpServletRequest request, HttpServletResponse response) throws ServletException, IOException
+    {
+
+        this.doPost(request, response);
+
+    }
+}

src/src_houduan/web/servlet/waterQualityStation/FindByPageServlet.java

@@ -0,0 +1,65 @@
+package web.servlet.waterQualityStation;
+
+import com.fasterxml.jackson.databind.ObjectMapper;
+import domain.PageBean;
+import domain.WaterQualityStation;
+import org.springframework.dao.DataAccessException;
+import org.springframework.jdbc.core.BeanPropertyRowMapper;
+import org.springframework.jdbc.core.JdbcTemplate;
+import service.WaterQualityStationService;
+import service.impl.WaterQualityStationServiceImpl;
+import util.JDBCUtils;
+
+import javax.servlet.ServletException;
+import javax.servlet.annotation.WebServlet;
+import javax.servlet.http.HttpServlet;
+import javax.servlet.http.HttpServletRequest;
+import javax.servlet.http.HttpServletResponse;
+import javax.servlet.http.HttpSession;
+import java.io.IOException;
+import java.util.List;
+
+@WebServlet("/FindByPageServlet")
+public class FindByPageServlet extends HttpServlet
+{
+    protected void doPost(HttpServletRequest request, HttpServletResponse response) throws ServletException, IOException
+    {
+        WaterQualityStationService service=new WaterQualityStationServiceImpl();
+        int totalCount = service.findTotalCount();//总记录数
+
+        String currentPage = request.getParameter("currentPage");
+        String pageSize = request.getParameter("pageSize");
+        int intCurrentPage=1;
+        int intPageSize=10;
+        try {
+            intCurrentPage = Integer.parseInt(currentPage);
+            intPageSize = Integer.parseInt(pageSize);
+        } catch (NumberFormatException e) {
+            System.out.println(e);
+        }
+        if(intCurrentPage==0)
+        {
+            intCurrentPage=1;
+        }
+        int totalPage=totalCount%intPageSize==0?totalCount/intPageSize:(totalCount/intPageSize+1);
+        if (intCurrentPage>totalPage)
+        {
+            intCurrentPage=totalPage;
+        }
+        PageBean<WaterQualityStation> pageBean = service.getPageBean(intCurrentPage, intPageSize);
+        System.out.println(pageBean);
+
+        ObjectMapper mapper=new ObjectMapper();
+        response.setContentType("application/json;charset=utf-8");
+        mapper.writeValue(response.getOutputStream(),pageBean);
+
+
+    }
+
+    protected void doGet(HttpServletRequest request, HttpServletResponse response) throws ServletException, IOException
+    {
+
+        this.doPost(request, response);
+
+    }
+}

src/src_houduan/web/servlet/waterQualityStation/FindIntroServlet.java

@@ -0,0 +1,38 @@
+package web.servlet.waterQualityStation;
+
+import com.fasterxml.jackson.databind.ObjectMapper;
+import domain.WaterQualityStation;
+import service.WaterQualityStationService;
+import service.impl.WaterQualityStationServiceImpl;
+
+import javax.servlet.ServletException;
+import javax.servlet.annotation.WebServlet;
+import javax.servlet.http.HttpServlet;
+import javax.servlet.http.HttpServletRequest;
+import javax.servlet.http.HttpServletResponse;
+import java.io.IOException;
+
+@WebServlet("/FindIntroServlet")
+public class FindIntroServlet extends HttpServlet
+{
+    protected void doPost(HttpServletRequest request, HttpServletResponse response) throws ServletException, IOException
+    {
+        String id = request.getParameter("id");
+        int intId = Integer.parseInt(id);
+        System.out.println(intId);
+
+        WaterQualityStationService service=new WaterQualityStationServiceImpl();
+        WaterQualityStation station = service.findIntroById(intId);
+        ObjectMapper mapper=new ObjectMapper();
+        response.setContentType("application/json;charset=utf-8");
+        mapper.writeValue(response.getOutputStream(),station);
+
+    }
+
+    protected void doGet(HttpServletRequest request, HttpServletResponse response) throws ServletException, IOException
+    {
+
+        this.doPost(request, response);
+
+    }
+}

src/src_houduan/web/servlet/waterQualityStation/FindLocationByNameServlet.java

@@ -0,0 +1,36 @@
+package web.servlet.waterQualityStation;
+
+import com.fasterxml.jackson.databind.ObjectMapper;
+import domain.WaterQualityStation;
+import service.WaterQualityStationService;
+import service.impl.WaterQualityStationServiceImpl;
+
+import javax.servlet.ServletException;
+import javax.servlet.annotation.WebServlet;
+import javax.servlet.http.HttpServlet;
+import javax.servlet.http.HttpServletRequest;
+import javax.servlet.http.HttpServletResponse;
+import java.io.IOException;
+
+@WebServlet("/FindLocationByNameServlet")
+public class FindLocationByNameServlet extends HttpServlet
+{
+    protected void doPost(HttpServletRequest request, HttpServletResponse response) throws ServletException, IOException
+    {
+        request.setCharacterEncoding("utf-8");
+        String stationName = request.getParameter("stationName");
+        WaterQualityStationService service=new WaterQualityStationServiceImpl();
+        WaterQualityStation station = service.findByName(stationName);
+        ObjectMapper mapper=new ObjectMapper();
+        response.setContentType("application/json;charset=utf-8");
+        mapper.writeValue(response.getOutputStream(),station);
+
+    }
+
+    protected void doGet(HttpServletRequest request, HttpServletResponse response) throws ServletException, IOException
+    {
+
+        this.doPost(request, response);
+
+    }
+}

src/src_houduan/web/servlet/waterQualityStation/FindPollutedSiteServlet.java

@@ -0,0 +1,39 @@
+package web.servlet.waterQualityStation;
+
+import com.fasterxml.jackson.databind.ObjectMapper;
+import domain.WaterQualityStation;
+import service.WaterQualityStationService;
+import service.impl.WaterQualityStationServiceImpl;
+
+import javax.servlet.ServletException;
+import javax.servlet.annotation.WebServlet;
+import javax.servlet.http.HttpServlet;
+import javax.servlet.http.HttpServletRequest;
+import javax.servlet.http.HttpServletResponse;
+import java.io.IOException;
+import java.util.List;
+
+/**
+ * @author laoyingyong
+ * @date: 2020-02-01 22:29
+ */
+@WebServlet("/FindPollutedSiteServlet")
+public class FindPollutedSiteServlet extends HttpServlet
+{
+    protected void doPost(HttpServletRequest request, HttpServletResponse response) throws ServletException, IOException
+    {
+        WaterQualityStationService service=new WaterQualityStationServiceImpl();
+        List<WaterQualityStation> pollutedSite = service.findPollutedSite();
+        ObjectMapper mapper=new ObjectMapper();
+        response.setContentType("application/json;chartset=utf-8");
+        mapper.writeValue(response.getOutputStream(),pollutedSite);
+
+    }
+
+    protected void doGet(HttpServletRequest request, HttpServletResponse response) throws ServletException, IOException
+    {
+
+        this.doPost(request, response);
+
+    }
+}

src/src_houduan/web/servlet/waterQualityStation/FindSimIntroServlet.java

@@ -0,0 +1,55 @@
+package web.servlet.waterQualityStation;
+
+import com.fasterxml.jackson.databind.ObjectMapper;
+import domain.WaterQualityStation;
+import service.WaterQualityStationService;
+import service.impl.WaterQualityStationServiceImpl;
+
+import javax.servlet.ServletException;
+import javax.servlet.annotation.WebServlet;
+import javax.servlet.http.HttpServlet;
+import javax.servlet.http.HttpServletRequest;
+import javax.servlet.http.HttpServletResponse;
+import java.io.IOException;
+
+/**
+ * @author laoyingyong
+ * @date: 2020-02-03 14:21
+ */
+@WebServlet("/FindSimIntroServlet")
+public class FindSimIntroServlet extends HttpServlet
+{
+    protected void doPost(HttpServletRequest request, HttpServletResponse response) throws ServletException, IOException
+    {
+        String zuobiao = request.getParameter("zuobiao");
+        System.out.println("坐标是："+zuobiao);
+        String[] split = zuobiao.split(",");
+        String lo=split[0];
+        String la=split[1];
+        double longitude=0;
+        double latitude=0;
+        try
+        {
+            longitude=Double.parseDouble(lo);
+            latitude=Double.parseDouble(la);
+        } catch (NumberFormatException e)
+        {
+            System.out.println(e);
+        }
+
+        WaterQualityStationService service=new WaterQualityStationServiceImpl();
+        WaterQualityStation station = service.findIntro(longitude, latitude);
+        ObjectMapper mapper=new ObjectMapper();
+        response.setContentType("application/json/chartset=utf-8");
+        mapper.writeValue(response.getOutputStream(),station);
+
+
+    }
+
+    protected void doGet(HttpServletRequest request, HttpServletResponse response) throws ServletException, IOException
+    {
+
+        this.doPost(request, response);
+
+    }
+}

src/src_houduan/web/servlet/waterQualityStation/FindStationAndQualityServlet.java

@@ -0,0 +1,52 @@
+package web.servlet.waterQualityStation;
+
+import com.fasterxml.jackson.databind.ObjectMapper;
+import domain.StationAndQuality;
+import service.WaterQualityStationService;
+import service.impl.WaterQualityStationServiceImpl;
+
+import javax.servlet.ServletException;
+import javax.servlet.annotation.WebServlet;
+import javax.servlet.http.HttpServlet;
+import javax.servlet.http.HttpServletRequest;
+import javax.servlet.http.HttpServletResponse;
+import java.io.IOException;
+
+/**
+ * @author laoyingyong
+ * @date: 2020-02-03 17:07
+ */
+@WebServlet("/FindStationAndQualityServlet")
+public class FindStationAndQualityServlet extends HttpServlet
+{
+    protected void doPost(HttpServletRequest request, HttpServletResponse response) throws ServletException, IOException
+    {
+        String lo = request.getParameter("jingdu");
+        System.out.println("经度是："+lo);
+
+        String la = request.getParameter("weidu");
+        System.out.println("纬度是："+la);
+        double longitude=0;
+        double latitude=0;
+        try {
+            longitude=Double.parseDouble(lo);
+            latitude=Double.parseDouble(la);
+        } catch (NumberFormatException e) {
+            System.out.println(e);
+        }
+
+        WaterQualityStationService service=new WaterQualityStationServiceImpl();
+        StationAndQuality stationAndQuality = service.findStationAndQuality(longitude, latitude);
+        ObjectMapper mapper=new ObjectMapper();
+        response.setContentType("application/json;chartset=utf-8");
+        mapper.writeValue(response.getOutputStream(),stationAndQuality);
+
+    }
+
+    protected void doGet(HttpServletRequest request, HttpServletResponse response) throws ServletException, IOException
+    {
+
+        this.doPost(request, response);
+
+    }
+}

src/src_houduan/web/servlet/waterQualityStation/IndexingServlet.java

@@ -0,0 +1,39 @@
+package web.servlet.waterQualityStation;
+
+import com.fasterxml.jackson.databind.ObjectMapper;
+import domain.StationAndQuality;
+import service.WaterQualityStationService;
+import service.impl.WaterQualityStationServiceImpl;
+
+import javax.servlet.ServletException;
+import javax.servlet.annotation.WebServlet;
+import javax.servlet.http.HttpServlet;
+import javax.servlet.http.HttpServletRequest;
+import javax.servlet.http.HttpServletResponse;
+import java.io.IOException;
+import java.util.List;
+
+/**
+ * @author laoyingyong
+ * @date: 2020-02-08 11:32
+ */
+@WebServlet("/IndexingServlet")
+public class IndexingServlet extends HttpServlet
+{
+    protected void doPost(HttpServletRequest request, HttpServletResponse response) throws ServletException, IOException
+    {
+        WaterQualityStationService service=new WaterQualityStationServiceImpl();
+        List<StationAndQuality> list = service.indexing();
+        ObjectMapper mapper=new ObjectMapper();
+        response.setContentType("application/json;chartset-utf-8");
+        mapper.writeValue(response.getOutputStream(),list);
+
+    }
+
+    protected void doGet(HttpServletRequest request, HttpServletResponse response) throws ServletException, IOException
+    {
+
+        this.doPost(request, response);
+
+    }
+}

src/src_houduan/web/servlet/waterQualityStation/UpdateStationInfoServlet.java

@@ -0,0 +1,70 @@
+package web.servlet.waterQualityStation;
+
+import com.fasterxml.jackson.databind.ObjectMapper;
+import domain.ResultInfo;
+import domain.WaterQualityStation;
+import service.WaterQualityStationService;
+import service.impl.WaterQualityStationServiceImpl;
+
+import javax.servlet.ServletException;
+import javax.servlet.annotation.WebServlet;
+import javax.servlet.http.HttpServlet;
+import javax.servlet.http.HttpServletRequest;
+import javax.servlet.http.HttpServletResponse;
+import java.io.IOException;
+
+@WebServlet("/UpdateStationInfoServlet")
+public class UpdateStationInfoServlet extends HttpServlet
+{
+    protected void doPost(HttpServletRequest request, HttpServletResponse response) throws ServletException, IOException
+    {
+        request.setCharacterEncoding("utf-8");
+        String id = request.getParameter("id");
+        String stationName = request.getParameter("stationName");
+        String longitude = request.getParameter("longitude");
+        System.out.println(longitude);
+        String latitude = request.getParameter("latitude");
+        System.out.println(latitude);
+        String section = request.getParameter("section");
+        String introduction = request.getParameter("introduction");
+
+        WaterQualityStation station=new WaterQualityStation();
+        try
+        {
+            station.setId(Integer.parseInt(id));
+            station.setStationName(stationName);
+            station.setLongitude(Double.parseDouble(longitude));
+            station.setLatitude(Double.parseDouble(latitude));
+            station.setSection(section);
+            station.setIntroduction(introduction);
+        } catch (Exception e)
+        {
+            System.out.println(e);
+        }
+
+
+        WaterQualityStationService service=new WaterQualityStationServiceImpl();
+        boolean flag = service.update(station);
+        ResultInfo info=new ResultInfo();
+        if(flag)
+        {
+            info.setMsg("更新成功！");
+        }
+        else
+        {
+            info.setMsg("更新失败！");
+        }
+
+        ObjectMapper mapper=new ObjectMapper();
+        response.setContentType("appilication/json;charset=utf-8");
+        mapper.writeValue(response.getOutputStream(),info);
+
+    }
+
+    protected void doGet(HttpServletRequest request, HttpServletResponse response) throws ServletException, IOException
+    {
+
+        this.doPost(request, response);
+
+    }
+}