bigdata_houtai/bigData/src/com/happy/service/Impl/UserImplService.java

package com.happy.service.Impl;

import com.happy.Model.*;
import com.happy.dao.UserDao;
import com.happy.service.TouristAnalysisService;
import com.happy.service.UserService;
import org.springframework.stereotype.Service;

import javax.annotation.Resource;
import java.util.List;
import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;

@Service("UserService")
public class UserImplService implements UserService {

    @Resource
    public UserDao userDao;

    @Resource
    public TouristAnalysisService touristAnalysisService;

    ExecutorService threadPool = Executors.newFixedThreadPool(10);

    public int insertUser(User user){
        return userDao.insertUser(user);
    }

    // 信息处理
    public int insertMessage(Message_handler message_handler){
        return userDao.insertMessage(message_handler);
    }

    // 疫情响应处理---处理总数
    public int queryTotalHandler(){
        return userDao.queryTotalHandler();
    };

    // 疫情响应处理---当年处理
    public int queryYearHandler(){
        return userDao.queryYearHandler();
    };

    // 疫情响应处理---当月处理
    public int queryMonthHandler(){
        return userDao.queryMonthHandler();
    };

    // 疫情响应处理---当日处理
    public int queryDayHandler(){
        return userDao.queryDayHandler();
    };

    // 响应处理数据
    public List<User> queryHandler(String sm_color,int page, int rows,String sqlx){
        return userDao.queryHandler(sm_color,page,rows,sqlx);
    };

    public int queryHandlerTotal(String sm_color,String sqlx){
        return userDao.queryHandlerTotal(sm_color,sqlx);
    }

    // 响应处理数据--所有的
    public List<User> queryHandlerAll(){
        return userDao.queryHandlerAll();
    }

    // 红码人员-短信
    public List<User> queryRedMes(){
        return userDao.queryRedMes();
    };

    // 黄码人员-短信
    public List<User> queryYellowMes(){
        return userDao.queryYellowMes();
    };

    // 重点、发热-短信
    public List<User> queryOtherMes(){
        return userDao.queryOtherMes();
    };

    // 脱管人员-短信
    public List<User> queryOtherTuo(){
        return userDao.queryOtherTuo();
    }

    // 处理红黄码人员
    public int updateHandlerStateM(int id,String message_time){
        return userDao.updateHandlerStateM(id,message_time);
    };

    public List<User> queryMById(int id){
        return userDao.queryMById(id);
    }

    public List<User> queryGui(String uuid, String sm_time){
        return userDao.queryGui(uuid, sm_time);
    }

    // 插入信息后-查询人员轨迹
    public List<User> queryGui2(String uuid, String sm_time){
        return userDao.queryGui2(uuid, sm_time);
    }

    // 插入信息后-查询人员轨迹分页
    public List<User> queryGui3(String uuid, String sm_time,int page, int rows){
        return userDao.queryGui3(uuid, sm_time, page, rows);
    };

    // 查询轨迹总数-分页
    public int queryGuijiTotal(String uuid, String sm_time){
        return userDao.queryGuijiTotal(uuid, sm_time);
    };

    public int updateGui(String trace_before, String trace_after, int id){
        return userDao.updateGui(trace_before, trace_after, id);
    }

    public List<User> queryGjById(int id){
        return userDao.queryGjById(id);
    }

    // 根据id查询需处置的人员
    public List<User> queryHanlerById(int id){
        return userDao.queryHanlerById(id);
    }

    // 根据uuid查询需处置的人员
    public List<User> queryHanlerByUUId(int id){
        return userDao.queryHanlerByUUId(id);
    }

    public List<Message_handler> queryMessage(String uuid, String sm_month){
        return userDao.queryMessage(uuid,sm_month);
    }

    // 查询红黄码、重点、发热人员
    public List<User> queryDanger(){
        return userDao.queryDanger();
    };

    // 导入到处置表
    public int insertUserX(User user){
        return userDao.insertUserX(user);
    };

    // 查询重复
    public List<User> queryChong(User user){
        return userDao.queryChong(user);
    };

    public int updateTb(int id){
        return userDao.updateTb(id);
    }

    // 更新处理状态
    public int updateHands(String uuid,String handler_message,String message_commit){
        return userDao.updateHands(uuid, handler_message, message_commit);
    }

    // 更新处理状态
    public int updateHand(String uuid,String handler_message,String sm_time,String message_commit,String handler_unit,int id){
        return userDao.updateHand(uuid,handler_message,sm_time,message_commit,handler_unit,id);
    }

    // 查看待处置人员
    public List<User> queryCz(String startTime,String endTime, String handler_state2,String sqlx,int page, int rows){
        return userDao.queryCz(startTime, endTime, handler_state2, sqlx, page, rows);
    }

    // 第一道防线黄码人员总数-分页
    public int queryCzTotal(String startTime,String endTime, String handler_state2,String sqlx){
        return userDao.queryCzTotal(startTime, endTime, handler_state2, sqlx);
    }

    public int updateGui(){
        return userDao.updateGui();
    };

    public int updateJw(){
        return userDao.updateJw();
    };

    // 更新定位为空
    public int updateJwp(){
        return userDao.updateJwp();
    }

    public List<User> OutUser(String sqlx){
        List<User> users = userDao.OutUser(sqlx);
        if (users!=null){
            for (int i=0;i<users.size();i++){
                if (users.get(i).getTown()!=null) {
                    System.out.println(111111);
                    users.get(i).setHandler_unit("县指挥部防疫组"+"-"+users.get(i).getTown());
                } else {
                    users.get(i).setHandler_unit("县指挥部防疫组");
                }
            }
        }
        return users;
    }

    // 查询绿码人员
    public List<User> queryGreen(int page, int rows,String sqlx){
        return userDao.queryGreen(page, rows, sqlx);
    };

    // 查询用户表绿码中的总记录数
    public int findGreenTotal(String sqlx){
        return userDao.findGreenTotal(sqlx);
    };

    // 根据id查询需处理的人员
    public List<User> queryXById(int id){
        return userDao.queryXById(id);
    }

    public List<Town> queryTownByName(String town){
        return userDao.queryTownByName(town);
    }

    public List<Country> queryManager(){
        return userDao.queryManager();
    }

    // 添加操作记录
    public int insertRecords(Records records){
        return userDao.insertRecords(records);
    }

    // 查询操作记录
    public List<Records> queryRecordsByUUID(String uuid){
        return userDao.queryRecordsByUUID(uuid);
    }

    // 发送短信时间查询
    public List<User> queryMesTime(String uuid){
        return userDao.queryMesTime(uuid);
    }
}