package com.stylefeng.guns.modular.system.controller.general;

import com.alibaba.fastjson.JSON;
import com.alibaba.fastjson.JSONArray;
import com.baomidou.mybatisplus.mapper.EntityWrapper;
import com.baomidou.mybatisplus.mapper.Wrapper;
import com.stylefeng.guns.core.shiro.ShiroKit;
import com.stylefeng.guns.core.util.SinataUtil;
import com.stylefeng.guns.core.util.ToolUtil;
import com.stylefeng.guns.modular.system.model.*;
import com.stylefeng.guns.modular.system.service.*;
import com.stylefeng.guns.modular.system.util.DateUtil;
import com.stylefeng.guns.modular.system.util.RedisUtil;
import com.stylefeng.guns.modular.system.util.ResultUtil;
import com.sun.org.apache.regexp.internal.RE;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Controller;
import org.springframework.ui.Model;
import org.springframework.web.bind.annotation.PostMapping;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RequestMethod;
import org.springframework.web.bind.annotation.ResponseBody;

import java.math.BigDecimal;
import java.util.*;

/**
 * 首页统计
 */
@Controller
@RequestMapping("/home")
public class HomeController {

    @Autowired
    private ITUserService tUserService;

    @Autowired
    private ITDriverService tDriverService;

    @Autowired
    private ITOrderTaxiService tOrderTaxiService;

    @Autowired
    private ITCarService tCarService;

    @Autowired
    private RedisUtil redisUtil;

    @Autowired
    private IUserService userService;

    @Autowired
    private ITCompanyService tCompanyService;

    @Autowired
    private ITCarBrandService carBrandService;

    @Autowired
    private ITCarModelService carModelService;

    private List<TCompany> companys = null;


    @Autowired
    private ITOrderPrivateCarService itOrderPrivateCarService;

    @Autowired
    private ITOrderCrossCityService itOrderCrossCityService;

    @Autowired
    private ITOrderLogisticsService itOrderLogisticsService;

    @Autowired
    private IDriverOnlineService driverOnlineService;


    @RequestMapping("/openNetCarInfo")
    public Object openNetCarInfo(Integer id, Model model){
        model.addAttribute("id", id);
        return "/netCarInfo.html";
    }

    @RequestMapping("/showDriverOnline")
    public String showDriverOnline(){
        return "/driverOnline.html";
    }




    @ResponseBody
    @PostMapping("/getSumData")
    public Object getSumData(Integer companyId, Date addDate, Date start, Date end){
        Integer id = ShiroKit.getUser().getId();
        User user = userService.selectById(id);
        if(companyId == null && user.getRoleType() != 1){
            companyId = user.getObjectId();
        }
        Map<String, Object> map = new HashMap<>();
        Date date = new Date();
        Calendar calendar1 = Calendar.getInstance();
        Calendar calendar2 = Calendar.getInstance();
        Calendar calendar3 = Calendar.getInstance();
        Calendar calendar4 = Calendar.getInstance();
        if(addDate == null){
            calendar1.setTime(date);
            calendar2.setTime(date);
        }else{
            calendar1.setTime(addDate);
            calendar2.setTime(addDate);
        }
        if(start == null || end == null){
            calendar3.setTime(date);
            calendar4.setTime(date);
        }else{
            calendar3.setTime(start);
            calendar4.setTime(end);
        }
        calendar1.set(Calendar.HOUR_OF_DAY, 00);
        calendar1.set(Calendar.MINUTE, 00);
        calendar1.set(Calendar.SECOND, 00);
        calendar2.set(Calendar.HOUR_OF_DAY, 23);
        calendar2.set(Calendar.MINUTE, 59);
        calendar2.set(Calendar.SECOND, 59);
        calendar3.set(Calendar.HOUR_OF_DAY, 00);
        calendar3.set(Calendar.MINUTE, 00);
        calendar3.set(Calendar.SECOND, 00);
        calendar4.set(Calendar.HOUR_OF_DAY, 23);
        calendar4.set(Calendar.MINUTE, 59);
        calendar4.set(Calendar.SECOND, 59);

        //【今日运行情况】
        Map<String, Object> map1 = new HashMap<>();
        Wrapper<TUser> ne = new EntityWrapper<TUser>().between("insertTime", calendar1.getTime(), calendar2.getTime()).ne("flag", 3);
        if(companyId != null){
            ne.eq("companyId", companyId);
        }
        int i = tUserService.selectCount(ne);
        map1.put("passengerInfo", i);  //新增用户

        Wrapper<TDriver> ne1 = new EntityWrapper<TDriver>().ne("state", 1).eq("authState", 2).ne("flag", 3);
        if(companyId != null){
            ne1.eq("companyId", companyId).or().eq("franchiseeId", companyId);
        }
        List<TDriver> tDrivers = tDriverService.selectList(ne1);
        String keys = "";
        for(TDriver driver : tDrivers){
            keys += "DRIVER" + driver.getId() + ",";
        }
        String value = redisUtil.getValue(keys.substring(0, keys.length() - 1));
        JSONArray jsonArray = JSON.parseArray(value);
        int size = driverOnlineService.queryOnlineDriverCount(null, null);
        map1.put("netcardriver", size);  //在线司机

        Wrapper<TOrderTaxi> travelTime1 = new EntityWrapper<TOrderTaxi>().between("travelTime", calendar1.getTime(), calendar2.getTime());
        if(companyId != null){
            travelTime1.eq("companyId", companyId);
        }
        int i1 = tOrderTaxiService.selectCount(travelTime1);
        map1.put("orderDetail2", i1);  //出租车订单

        Wrapper<TOrderPrivateCar> zcTodayTme = new EntityWrapper<TOrderPrivateCar>().between("travelTime", calendar1.getTime(), calendar2.getTime());
        if(companyId != null){
            zcTodayTme.eq("companyId", companyId);
        }
        int zcTodayNum = itOrderPrivateCarService.selectCount(zcTodayTme);
        map1.put("orderDetail1", zcTodayNum);  //专车订单

        Wrapper<TOrderCrossCity> kcTodayTme = new EntityWrapper<TOrderCrossCity>().between("travelTime", calendar1.getTime(), calendar2.getTime());
        if(companyId != null){
            kcTodayTme.eq("companyId", companyId);
        }
        int kcTodayNum = itOrderCrossCityService.selectCount(kcTodayTme);
        map1.put("orderDetail3", kcTodayNum);  //跨城订单

        Wrapper<TOrderLogistics> tcxTodayTme = new EntityWrapper<TOrderLogistics>().between("travelTime", calendar1.getTime(), calendar2.getTime());
        if(companyId != null){
            tcxTodayTme.eq("companyId", companyId);
        }
        tcxTodayTme.eq("type",4);
        int tcxTodayNum = itOrderLogisticsService.selectCount(tcxTodayTme);
        map1.put("orderDetail4", tcxTodayNum);  //同城物流订单

        Wrapper<TOrderLogistics> kcxTodayTme = new EntityWrapper<TOrderLogistics>().between("travelTime", calendar1.getTime(), calendar2.getTime());
        if(companyId != null){
            kcxTodayTme.eq("companyId", companyId);
        }
        tcxTodayTme.eq("type",5);
        int kcxTodayNum = itOrderLogisticsService.selectCount(kcxTodayTme);
        map1.put("orderDetail5", kcxTodayNum);  //跨城物流订单

        map.put("operationStatus", map1);

        //【全部运营总数据】
        map1 = new HashMap<>();
        Wrapper<TUser> flag1 = new EntityWrapper<TUser>().ne("flag", 3);
        if(companyId != null){
            flag1.eq("companyId", companyId);
        }
        int flag = tUserService.selectCount(flag1);
        map1.put("passengerInfoSum", flag);  //总用户

        Wrapper<TDriver> ne4 = new EntityWrapper<TDriver>().eq("authState", 2).ne("flag", 3);
        if(companyId != null){
            ne4.eq("companyId", companyId).or().eq("franchiseeId", companyId);
        }
        int i2 = tDriverService.selectCount(ne4);
        map1.put("netcarDriverSum", i2);  //总司机

        Wrapper<TCar> state3 = new EntityWrapper<TCar>().eq("state", 1);
        if(companyId != null){
            state3.eq("companyId", companyId).or().eq("franchiseeId", companyId);
        }
        int state1 = tCarService.selectCount(state3);
        map1.put("netCarSum", state1);  //总车辆

        Integer i3 = tOrderTaxiService.getAllOrderNum(companyId,null,null);
        map1.put("orderDetailSum", i3); //总订单

        Double allTradeMoney = tOrderTaxiService.getAllTradeMoney(companyId, null, null);
        Double allIncomeMoney = tOrderTaxiService.getAllIncomeMoney(companyId, null, null);
        map1.put("paiceSum", allTradeMoney);  //交易总金额
        map1.put("paySum", allIncomeMoney);  //总收益
        map.put("operationSum", map1);

        //【运营数据增长查询】
        map1 = new HashMap<>();
        Wrapper<TUser> ne2 = new EntityWrapper<TUser>().between("insertTime", calendar3.getTime(), calendar4.getTime()).ne("flag", 3);
        if(companyId != null){
            ne2.eq("companyId", companyId);
        }
        int i4 = tUserService.selectCount(ne2);
        map1.put("passengerInfoSum", i4);

        Wrapper<TDriver> ne3 = new EntityWrapper<TDriver>().between("insertTime", calendar3.getTime(), calendar4.getTime()).eq("authState", 2).ne("flag", 3);
        if(companyId != null){
            ne3.eq("companyId", companyId).or().eq("franchiseeId", companyId);
        }
        int i5 = tDriverService.selectCount(ne3);
        map1.put("netcarDriverSum", i5);

        Wrapper<TOrderPrivateCar> zcTodayTmeByConditions = new EntityWrapper<TOrderPrivateCar>().between("travelTime", calendar3.getTime(), calendar4.getTime());
        if(companyId != null){
            zcTodayTmeByConditions.eq("companyId", companyId);
        }
        int zcTodayNum1 = itOrderPrivateCarService.selectCount(zcTodayTmeByConditions);
        map1.put("orderDetail1", zcTodayNum1);  //专车订单

        Wrapper<TOrderTaxi> travelTime2 = new EntityWrapper<TOrderTaxi>().between("travelTime", calendar3.getTime(), calendar4.getTime());
        if(companyId != null){
            travelTime2.eq("companyId", companyId);
        }
        int travelTime = tOrderTaxiService.selectCount(travelTime2);
        map1.put("orderDetail2", travelTime);  //出租车订单

        Wrapper<TOrderCrossCity> kcTodayTmeByConditions = new EntityWrapper<TOrderCrossCity>().between("travelTime", calendar3.getTime(), calendar4.getTime());
        if(companyId != null){
            kcTodayTmeByConditions.eq("companyId", companyId);
        }
        int kcTodayNum1 = itOrderCrossCityService.selectCount(kcTodayTmeByConditions);
        map1.put("orderDetail3", kcTodayNum1);  //跨城订单

        Wrapper<TOrderLogistics> tcxTodayTmeByConditions = new EntityWrapper<TOrderLogistics>().between("travelTime", calendar3.getTime(), calendar4.getTime());
        if(companyId != null){
            tcxTodayTmeByConditions.eq("companyId", companyId);
        }
        tcxTodayTmeByConditions.eq("type",4);
        int tcxTodayNum1 = itOrderLogisticsService.selectCount(tcxTodayTmeByConditions);
        map1.put("orderDetail4", tcxTodayNum1);  //同城物流订单

        Wrapper<TOrderLogistics> kcxTodayTmeByConditions = new EntityWrapper<TOrderLogistics>().between("travelTime", calendar3.getTime(), calendar4.getTime());
        if(companyId != null){
            kcxTodayTmeByConditions.eq("companyId", companyId);
        }
        kcxTodayTmeByConditions.eq("type",5);
        int kcxTodayNum1 = itOrderLogisticsService.selectCount(kcxTodayTmeByConditions);
        map1.put("orderDetail5", kcxTodayNum1);  //跨城物流订单

        String startTime = null;
        if (SinataUtil.isNotEmpty(start)){
            startTime = DateUtil.format(start, "yyyy-MM-dd");
        }
        String endTime = null;
        if (SinataUtil.isNotEmpty(end)){
            endTime = DateUtil.format(end, "yyyy-MM-dd");
        }
        Double allTradeMoneyByTime = tOrderTaxiService.getAllTradeMoney(companyId, startTime, endTime);
        Double allIncomeMoneyByTime = tOrderTaxiService.getAllIncomeMoney(companyId, startTime, endTime);
        map1.put("paiceSum", allTradeMoneyByTime);  //交易总金额
        map1.put("paySum", allIncomeMoneyByTime);   //总收益
        map.put("operationGrow", map1);


        //【运营总趋势】
        Integer[] states = new Integer[]{8, 9};
        map1 = new HashMap<>();
        List<Integer> m1 = new ArrayList<>();
        List<Integer> m2 = new ArrayList<>();
        List<Integer> m3 = new ArrayList<>();
        List<Integer> m4 = new ArrayList<>();
        List<Integer> m5 = new ArrayList<>();
        List<Integer> m6 = new ArrayList<>();
        List<Integer> m7 = new ArrayList<>();
        for(int j = 30; j > 0; j--){
            Calendar s1 = Calendar.getInstance();
            s1.setTime(date);
            s1.set(s1.get(Calendar.YEAR), s1.get(Calendar.MONTH), s1.get(Calendar.DAY_OF_MONTH) - j, 0, 0, 1);
            Calendar e1 = Calendar.getInstance();
            e1.setTime(date);
            e1.set(e1.get(Calendar.YEAR), e1.get(Calendar.MONTH), e1.get(Calendar.DAY_OF_MONTH) - j, 23, 59, 59);

            //出租车订单趋势图
            Wrapper<TOrderTaxi> in = new EntityWrapper<TOrderTaxi>().between("travelTime", s1.getTime(), e1.getTime()).in("state", states);
            if(companyId != null){
                in.eq("companyId", companyId);
            }
            int i6 = tOrderTaxiService.selectCount(in);
            m1.add(i6);

            //用户注册趋势图
            Wrapper<TUser> ne5 = new EntityWrapper<TUser>().between("insertTime", s1.getTime(), e1.getTime()).ne("flag", 3);
            if(companyId != null){
                ne5.eq("companyId", companyId);
            }
            int i7 = tUserService.selectCount(ne5);
            m2.add(i7);

            //订单数趋势图
            String startTime1 = DateUtil.format(s1.getTime(), "yyyy-MM-dd");
            String endTime1 = DateUtil.format(e1.getTime(), "yyyy-MM-dd");
            Integer allOrderNum = tOrderTaxiService.getAllOrderNum(companyId, startTime1, endTime1);
            m3.add(allOrderNum);

            //专车订单趋势图
            Wrapper<TOrderPrivateCar> inZC = new EntityWrapper<TOrderPrivateCar>().between("travelTime", s1.getTime(), e1.getTime()).in("state", states);
            if(companyId != null){
                inZC.eq("companyId", companyId);
            }
            int zc = itOrderPrivateCarService.selectCount(inZC);
            m4.add(zc);

            //跨城订单趋势图
            Wrapper<TOrderCrossCity> inKC = new EntityWrapper<TOrderCrossCity>().between("travelTime", s1.getTime(), e1.getTime()).in("state", states);
            if(companyId != null){
                inKC.eq("companyId", companyId);
            }
            int kc = itOrderCrossCityService.selectCount(inKC);
            m5.add(kc);

            //同城物流订单趋势图
            Wrapper<TOrderLogistics> inTCX = new EntityWrapper<TOrderLogistics>().between("travelTime", s1.getTime(), e1.getTime()).in("state", states);
            if(companyId != null){
                inTCX.eq("companyId", companyId);
            }
            inTCX.eq("type",4);
            int tcx = itOrderLogisticsService.selectCount(inTCX);
            m6.add(tcx);

            //跨城物流订单趋势图
            Wrapper<TOrderLogistics> inKCX = new EntityWrapper<TOrderLogistics>().between("travelTime", s1.getTime(), e1.getTime()).in("state", states);
            if(companyId != null){
                inKCX.eq("companyId", companyId);
            }
            inKCX.eq("type",5);
            int kcx = itOrderLogisticsService.selectCount(inKCX);
            m7.add(kcx);

        }
        map1.put("orderDetail5", m7);  //跨城物流订单数趋势图
        map1.put("orderDetail4", m6);  //同城物流订单数趋势图
        map1.put("orderDetail3", m5);  //跨城订单数趋势图
        map1.put("orderDetail1", m4);  //专车订单数趋势图
        map1.put("orderDetailSum", m3);  //全部订单数趋势图
        map1.put("passengerInfoSum", m2);  //用户注册趋势图
        map1.put("orderDetail2", m1);  //出租车订单趋势图
        map.put("operationTrend", map1);

        return map;
    }



    @ResponseBody
    @PostMapping("/getDriverPosition")
    public Object getDriverPosition(Integer companyId){
        Integer id = ShiroKit.getUser().getId();
        User user = userService.selectById(id);
        if(companyId == null && user.getRoleType() != 1){
            companyId = user.getObjectId();
        }
        Wrapper<TDriver> ne = new EntityWrapper<TDriver>().eq("authState", 2).eq("state", 2).ne("flag", 3);
        if(companyId != null){
            ne.eq("companyId", companyId).or().eq("franchiseeId", companyId);
        }
        List<TDriver> tDrivers = tDriverService.selectList(ne);
        Map<String, Object> map = new HashMap<>();
        List<Object> list = new ArrayList<>();
        for(TDriver tDriver : tDrivers){
            Map<String, Object> d = new HashMap<>();
            String value = redisUtil.getValue("DRIVER" + tDriver.getId());
            if(ToolUtil.isEmpty(value)){
                continue;
            }
            d.put("driver", tDriver);
            d.put("lon", value.split(",")[0]);
            d.put("lat", value.split(",")[1]);
            list.add(d);
        }
        map.put("driver", list);

        Map<String, Object> map2 = new HashMap<>();
        Wrapper<TOrderTaxi> eq = new EntityWrapper<TOrderTaxi>().eq("state", 1).eq("isDelete", 1);
        if(companyId != null){
            eq.eq("companyId", companyId);
        }
        List<TOrderTaxi> tOrderTaxis = tOrderTaxiService.selectList(eq);
        list = new ArrayList<>();
        for(TOrderTaxi t : tOrderTaxis){
            Map<String, Object> map1 = new HashMap<>();
            map1.put("start", t.getStartAddress());
            map1.put("end", t.getEndAddress());
            map1.put("travelTime", t.getTravelTime());
            map1.put("carModel", "");
            map1.put("num", 1);
            list.add(map1);
        }
        map2.put("chuzu", list);
        map.put("order", map2);

        return map;
    }


    @ResponseBody
    @PostMapping("/getAllOrder")
    public Object getAllOrder(){
        List<TOrderTaxi> tOrderTaxis = tOrderTaxiService.selectList(new EntityWrapper<TOrderTaxi>().eq("isDelete", 1));
        List list = new ArrayList<>();
        for(TOrderTaxi t : tOrderTaxis){
            Map<String, Object> map = new HashMap<>();
            map.put("lon", t.getStartLon());
            map.put("lat", t.getStartLat());
            list.add(map);
        }
        return list;
    }


    @ResponseBody
    @PostMapping("/getCompanyInfoByUserId")
    public Object getCompanyInfoByUserId(){
        Integer id = ShiroKit.getUser().getId();
        User user = userService.selectById(id);
        companys = new ArrayList<>();
        List<TCompany> ids = new ArrayList<>();
        TCompany tCompany = null;
        if(user.getRoleType() == 1 && user.getObjectId() == null){
            tCompany = tCompanyService.selectById(1);
        }else{
            tCompany = tCompanyService.selectById(user.getObjectId());
        }
        ids.add(tCompany);
        companys.addAll(ids);
        this.getCompanyIds(ids);
        return companys;
    }


    @ResponseBody
    @RequestMapping(value = "/getDriverInfo", method = RequestMethod.POST)
    public Object getDriverInfo(Integer driverId){
        Map<String, Object> map = new HashMap<>();
        TDriver tDriver = tDriverService.selectById(driverId);
//        TCar tCar = tCarService.selectById(tDriver.getCarId());
        TCarBrand tCarBrand = null;
        TCarModel tCarModel = null;
//        if(null != tCar){
//            tCarBrand = carBrandService.selectById(tCar.getCarBrandId());
//            tCarModel = carModelService.selectById(tCar.getCarModelId());
//        }
        Integer[] states = new Integer[]{2, 3, 4, 5, 6, 11};
        Wrapper<TOrderTaxi> state4 = new EntityWrapper<TOrderTaxi>().in("state", states).eq("driverId", driverId).eq("isDelete", 1);
        List<TOrderTaxi> tOrderTaxis = tOrderTaxiService.selectList(state4);
        map.put("netcarDriver", tDriver);
//        map.put("netcar", tCar);
        map.put("carBrand", null != tCarBrand ? tCarBrand.getName() : "");
        map.put("carModel", null != tCarModel ? tCarModel.getName() : "");
        map.put("order", tOrderTaxis);
        return map;
    }



    public void getCompanyIds(List<TCompany> ids){
        List<TCompany> ids_ = new ArrayList<>();
        for(TCompany id : ids){
            if(id.getId() == 1){
                List<TCompany> tCompanies = tCompanyService.selectList(new EntityWrapper<TCompany>().eq("superiorId", id.getId()).or().isNull("superiorId").eq("state", 0).ne("flag", 3).ne("type", 1));
                ids_.addAll(tCompanies);
                companys.addAll(tCompanies);
            }else{
                List<TCompany> tCompanies = tCompanyService.selectList(new EntityWrapper<TCompany>().eq("superiorId", id.getId()).eq("state", 0).ne("flag", 3));
                ids_.addAll(tCompanies);
                companys.addAll(tCompanies);
            }
        }
        if(ids_.size() == 0){
            return;
        }
        this.getCompanyIds(ids_);
    }



    @ResponseBody
    @RequestMapping(value = "/queryOnlineDriver", method = RequestMethod.POST)
    public Object queryOnlineDriver(String name, String phone, Integer offset, Integer limit){
        try {
            return driverOnlineService.queryOnlineDriver(name, phone, offset, limit);
        }catch (Exception e){
            e.printStackTrace();
            return ResultUtil.runErr();
        }
    }
}