package com.bofeng.controller;

import com.bofeng.dao.UptownHomeMapper;
import com.bofeng.dao.UserOpenMapper;
import com.bofeng.dao.UserRoleMapper;
import com.bofeng.entity.UptownHome;
import com.bofeng.entity.UserOpen;
import com.bofeng.entity.UserRole;
import com.bofeng.service.EpiAdminService;
import com.bofeng.service.EpiTemplateMessageService;
import com.bofeng.service.MsReportService;
import com.bofeng.service.TemplateMessageService;
import com.yvan.ModelOps;
import com.yvan.mvc.Pd;
import com.yvan.platform.StringUtils;
import io.swagger.annotations.ApiOperation;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.scheduling.annotation.Scheduled;
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.PostMapping;
import org.springframework.web.bind.annotation.RestController;

import java.util.List;

@RestController
public class EpiAdminController {

    @Autowired
    private EpiAdminService epiAdminService;
    @Autowired
    private UptownHomeMapper uptownHomeMapper;
    @Autowired
    private UserRoleMapper userRoleMapper;
    @Autowired
    private EpiTemplateMessageService epiTemplateMessageService;
    @Autowired
    private UserOpenMapper userOpenMapper;

    @Autowired
    private MsReportService msReportService;

    @ApiOperation("升级业委会角色")
    @PostMapping("/whepi/epi/admin/addRole")
    public ModelOps adminAddRole(@Pd(name = "we", desc = "手机号码") String we){
        if (!StringUtils.isNullOrEmpty(we)) {
            List<UptownHome> list = uptownHomeMapper.getUptownHomeByPhone(we);
            if (list.size() != 1) {
                return ModelOps.newFail("该电话号码不存在，或多人注册该号码");
            }
            Long userId = uptownHomeMapper.getUserIdByPhone(we);
            List<UserRole> list1 = userRoleMapper.getUserRoleByUserId(userId);
            if (list1.size() >= 2) {
                return ModelOps.newFail("该电话已经升级过业委会角色");
            }
            UserRole userRole = userRoleMapper.getUserRoleByPropertyId(list.get(0).getHouseId(), 1);
            return ModelOps.newSuccess(epiAdminService.addYwhRole(list.get(0), userRole.getUserId()));
        }
        return null;
    }

//    @Scheduled(cron = "0 44 12 * * ?") //每天19点执行一次
    @Scheduled(cron = "0 0 11 * * ?") //每天19点执行一次
    public void scheduledTaskByFixedDelay() {
        System.out.println("==============执行定时任务开始================");
        Long start = 0L, count = 100L;
        while (true) {
            List<UserOpen> userOpens = userOpenMapper.getOpenUser(start, count);
            int re = 0;
            for (UserOpen userOpen : userOpens) {
                re += epiTemplateMessageService.systemSendRemindMessage(userOpen.getUserId(), userOpen.getOpenId());
            }
            System.out.println("==============执行定时任务"+re+"================");
            start += count;
            if (userOpens == null || userOpens.size()<count) {
                break;
            }
        }

        System.out.println("==============执行定时任务完毕================");
    }

    @Scheduled(cron = "0 0 19 * * ?") //每天19点执行一次
    public void scheduledTaskByFixedDelay2() {
        System.out.println("==============执行定时任务开始================");
        Long start = 0L, count = 100L;
        while (true) {
            List<UserOpen> userOpens = userOpenMapper.getOpenUser(start, count);
            int re = 0;
            for (UserOpen userOpen : userOpens) {
                re += epiTemplateMessageService.systemSendRemindMessage(userOpen.getUserId(), userOpen.getOpenId());
            }
            System.out.println("==============执行定时任务"+re+"================");
            start += count;
            if (userOpens == null || userOpens.size()<count) {
                break;
            }
        }

        System.out.println("==============执行定时任务完毕================");
    }

//    @Scheduled(cron = "0 0 0 * * ?") //每天0点执行一次
    public void scheduledReportByFixedDelay() {
        System.out.println("==============执行定时任务开始================");
        msReportService.getNowByYesterdayDate();
//        Long start = 0L, count = 100L;
//        while (true) {
//            List<UserOpen> userOpens = userOpenMapper.getOpenUser(start, count);
//            int re = 0;
//            for (UserOpen userOpen : userOpens) {
//                re += epiTemplateMessageService.systemSendRemindMessage(userOpen.getUserId(), userOpen.getOpenId());
//            }
//            System.out.println("==============执行定时任务"+re+"================");
//            start += count;
//            if (userOpens == null || userOpens.size()<count) {
//                break;
//            }
//        }

        System.out.println("==============执行定时任务完毕================");
    }
}