package com.ruoyi.web.controller.station;

import java.util.ArrayList;
import java.util.Collections;
import java.util.List;

import com.alibaba.fastjson.JSONArray;
import com.alibaba.fastjson.JSONObject;
import com.ruoyi.common.constant.UrlConstant;
import com.ruoyi.common.utils.DateUtils;
import com.ruoyi.common.utils.IdUtils;
import com.ruoyi.common.utils.StringUtils;
import com.ruoyi.station.domain.*;
import com.ruoyi.station.model.TmpDataModel;
import com.ruoyi.station.model.WorkUserModel;
import com.ruoyi.station.service.*;
import org.apache.shiro.authz.annotation.RequiresPermissions;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.http.HttpEntity;
import org.springframework.http.HttpHeaders;
import org.springframework.http.MediaType;
import org.springframework.http.ResponseEntity;
import org.springframework.stereotype.Controller;
import org.springframework.ui.ModelMap;
import org.springframework.util.LinkedMultiValueMap;
import org.springframework.util.MultiValueMap;
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.PathVariable;
import org.springframework.web.bind.annotation.PostMapping;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.ResponseBody;
import com.ruoyi.common.annotation.Log;
import com.ruoyi.common.enums.BusinessType;
import com.ruoyi.common.core.controller.BaseController;
import com.ruoyi.common.core.domain.AjaxResult;
import com.ruoyi.common.utils.poi.ExcelUtil;
import com.ruoyi.common.core.page.TableDataInfo;
import org.springframework.web.client.RestTemplate;

/**
 * 组区域关联Controller
 * 
 * @author ruoyi
 * @date 2020-08-27
 */
@Controller
@RequestMapping("/station/area")
public class MjTeamAreaController extends BaseController
{
    private String prefix = "station/area";

    @Autowired
    private IMjTeamAreaService mjTeamAreaService;
    @Autowired
    private IMjAreaManagementService iMjAreaManagementService;
    @Autowired
    private IMjTeamService iMjTeamService;
    @Autowired
    private IMjFingerprintReadHeadService iMjFingerprintReadHeadService;
    @Autowired
    private IMjHeadsUsersService iMjHeadsUsersService;
    @Autowired
    private IMjTeamMemberService iMjTeamMemberService;
    @Autowired
    private IMjWorkUserPushService mjWorkUserPushService;
    @Autowired
    private IMjWorkUserService workUserService;
    @Autowired
    private IMjFingerprintService fingerprintService;

    @RequiresPermissions("station:area:view")
    @GetMapping()
    public String area()
    {
        return prefix + "/area";
    }

    /**
     * 查询组区域关联列表
     */
    @RequiresPermissions("station:area:list")
    @PostMapping("/list")
    @ResponseBody
    public TableDataInfo list(MjTeamArea mjTeamArea)
    {
        startPage();
        List<MjTeamArea> list = mjTeamAreaService.selectMjTeamAreaList(mjTeamArea);
        return getDataTable(list);
    }

    /**
     * 导出组区域关联列表
     */
    @RequiresPermissions("station:area:export")
    @Log(title = "组区域关联", businessType = BusinessType.EXPORT)
    @PostMapping("/export")
    @ResponseBody
    public AjaxResult export(MjTeamArea mjTeamArea)
    {
        List<MjTeamArea> list = mjTeamAreaService.selectMjTeamAreaList(mjTeamArea);
        ExcelUtil<MjTeamArea> util = new ExcelUtil<MjTeamArea>(MjTeamArea.class);
        return util.exportExcel(list, "area");
    }

    /**
     * 新增组区域关联
     */
    @GetMapping("/add")
    public String add()
    {
        return prefix + "/add";
    }

    /**
     * 新增保存组区域关联
     */
    @RequiresPermissions("station:area:add")
    @Log(title = "组区域关联", businessType = BusinessType.INSERT)
    @PostMapping("/add")
    @ResponseBody
    public synchronized AjaxResult addSave(MjTeamArea mjTeamArea)
    {
        List<MjTeamArea> mjTeamAreas = mjTeamAreaService.selectMjTeamAreaList(mjTeamArea);
        if(mjTeamAreas.size()>0){
//            if(mjTeamAreas.get(0).getStatus()==2){
//                MjTeamArea m2 = mjTeamAreas.get(0);
//                m2.setStatus(0);
//                return toAjax(mjTeamAreaService.updateMjTeamArea(m2));
//            }
            return error("不可重复添加");
        }
        mjTeamArea.setUpdateTime(DateUtils.getNowDate());
        mjTeamArea.setId(IdUtils.fastSimpleUUID());
        MjAreaManagement mjAreaManagement = iMjAreaManagementService.selectMjAreaManagementById(mjTeamArea.getAreaId());
        mjTeamArea.setAreaName(mjAreaManagement.getAreaName());

        updateNum(mjTeamArea.getTeamId());

        MjTeam team = iMjTeamService.selectMjTeamById(mjTeamArea.getTeamId());
        MjTeamMember teamMember = new MjTeamMember();
        teamMember.setTeamId(team.getId());
        teamMember.setStatus(0);
        teamMember.setDelFlag(0);
        List<MjTeamMember> mjTeamMembers = iMjTeamMemberService.selectMjTeamMemberList(teamMember);
        for(MjTeamMember mtm:mjTeamMembers) {
            MjFingerprintReadHead fingerprintReadHead = new MjFingerprintReadHead();
            fingerprintReadHead.setAreaId(mjTeamArea.getAreaId());
            List<MjFingerprintReadHead> hs = iMjFingerprintReadHeadService.selectMjFingerprintReadHeadList(fingerprintReadHead);
            for (MjFingerprintReadHead rh : hs) {
                MjHeadsUsers mjHeadsUsers = new MjHeadsUsers();
                mjHeadsUsers.setUserId(Long.valueOf(mtm.getUserId()));
                mjHeadsUsers.setAuthorizeName(team.getTeamName());
                mjHeadsUsers.setAuthorizeResult(0);//未授权
                mjHeadsUsers.setAuthorizeType(0);//组授权
                mjHeadsUsers.setAuthorizeStatus(0);//增加授权
                mjHeadsUsers.setHeadId(rh.getId());//读头id
                mjHeadsUsers.setHeadType(rh.getNewOldStatus());
                mjHeadsUsers.setMainUser(1);
                mjHeadsUsers.setOrderId(team.getId());
                iMjHeadsUsersService.insertMjHeadsUsers(mjHeadsUsers);
                if(rh.getNewOldStatus()==1){
                    addPush(mjHeadsUsers);
                }
            }
        }
        return toAjax(mjTeamAreaService.insertMjTeamArea(mjTeamArea));
    }

    //更新组人数
    public void updateNum(String teamId){
//        MjTeamArea mjTeamMember2 = new MjTeamArea();
//        mjTeamMember2.setTeamId(teamId);
//        List<MjTeamArea> mjTeamMembers2 = mjTeamAreaService.selectMjTeamAreaList(mjTeamMember2);
        MjTeam mjTeam = iMjTeamService.selectMjTeamById(teamId);
        mjTeam.setAreaNumber(mjTeam.getAreaNumber()+1);
        mjTeam.setEquipmentUpdateStatus(1);
        iMjTeamService.updateMjTeam(mjTeam);
    }

    /**
     * 修改组区域关联
     */
    @GetMapping("/edit/{id}")
    public String edit(@PathVariable("id") String id, ModelMap mmap)
    {
        MjTeamArea mjTeamArea = mjTeamAreaService.selectMjTeamAreaById(id);
        mmap.put("mjTeamArea", mjTeamArea);
        return prefix + "/edit";
    }

    /**
     * 修改保存组区域关联
     */
    @RequiresPermissions("station:area:edit")
    @Log(title = "组区域关联", businessType = BusinessType.UPDATE)
    @PostMapping("/edit")
    @ResponseBody
    public AjaxResult editSave(MjTeamArea mjTeamArea)
    {
        MjAreaManagement mjAreaManagement = iMjAreaManagementService.selectMjAreaManagementById(mjTeamArea.getAreaId());
        mjTeamArea.setAreaName(mjAreaManagement.getAreaName());
        return toAjax(mjTeamAreaService.updateMjTeamArea(mjTeamArea));
    }

    /**
     * 删除组区域关联
     */
    @RequiresPermissions("station:area:remove")
    @Log(title = "组区域关联", businessType = BusinessType.DELETE)
    @PostMapping( "/remove")
    @ResponseBody
    public AjaxResult remove(String ids)
    {

        String[] split = ids.split(",");
        MjTeamArea mjTeamArea = mjTeamAreaService.selectMjTeamAreaById(split[0]);
        MjTeam mjTeam = iMjTeamService.selectMjTeamById(mjTeamArea.getTeamId());
        mjTeam.setAreaNumber(mjTeam.getAreaNumber()-split.length);
        iMjTeamService.updateMjTeam(mjTeam);
        //updateNum(mjTeamMember.getTeamId());
        int i = mjTeamAreaService.deleteMjTeamAreaByIds(ids);
        return toAjax(i);
    }

    /**
     * 根据teamId获取组区域
     * @param teamId
     * @return
     */
    @PostMapping( "/findByTeamId")
    @ResponseBody
    public Object findByTeamId(String teamId)
    {
        MjTeamArea mjTeamArea = new MjTeamArea();
        mjTeamArea.setTeamId(teamId);
        List<MjTeamArea> mjTeamMembers = mjTeamAreaService.selectMjTeamAreaList(mjTeamArea);
        return mjTeamMembers;
    }

    /**
     * 批量添加区域
     * @param teamId
     * @param arrMember  逗号分割
     * @return
     */
    @PostMapping( "/addList")
    @ResponseBody
    public Object addList(String teamId,String arrMember)
    {
        String[] split = arrMember.split(",");
        for(String str : split){
            MjTeamArea mjTeamArea = new MjTeamArea();
            mjTeamArea.setTeamId(teamId);
            mjTeamArea.setAreaId(str);
            mjTeamArea.setStatus(0);
            mjTeamAreaService.insertMjTeamArea(mjTeamArea);
        }
        return toAjax(true);
    }

    /**
     * 区域删除，把状态更新为待删除
     * @param id
     * @return
     */
    @PostMapping( "/updateStatus")
    @ResponseBody
    public Object updateStatus(String id)
    {
        MjTeamArea mjTeamArea = mjTeamAreaService.selectMjTeamAreaById(id);
        if(mjTeamArea==null){
            return toAjax(false);
        }
//        mjTeamArea.setStatus(2);
//        mjTeamArea.setDelFlag(1);
//        mjTeamAreaService.updateMjTeamArea(mjTeamArea);

        MjTeam mjTeam = iMjTeamService.selectMjTeamById(mjTeamArea.getTeamId());
        mjTeam.setAreaNumber(mjTeam.getAreaNumber()-1);
        mjTeam.setEquipmentUpdateStatus(1);
        iMjTeamService.updateMjTeam(mjTeam);

        mjTeamAreaService.deleteMjTeamAreaById(id);

        MjFingerprintReadHead fingerprintReadHead = new MjFingerprintReadHead();
        fingerprintReadHead.setAreaId(mjTeamArea.getAreaId());
        List<MjFingerprintReadHead> hs = iMjFingerprintReadHeadService.selectMjFingerprintReadHeadList(fingerprintReadHead);
        for(MjFingerprintReadHead rh:hs) {
            MjHeadsUsers hu = new MjHeadsUsers();
            hu.setAuthorizeType(0);//组授权
            hu.setHeadId(rh.getId());//读头id
            List<MjHeadsUsers> mjHeadsUsers1 = iMjHeadsUsersService.selectMjHeadsUsersList(hu);
            for(MjHeadsUsers mhu : mjHeadsUsers1){
                iMjHeadsUsersService.deleteMjHeadsUsersById(mhu.getId());
                quXiao(mhu);
            }
        }
        return toAjax(true);
    }

    @PostMapping("/add2")
    @ResponseBody
    public AjaxResult addSave2(MjTeamArea mjTeamArea)
    {

        MjAreaManagement areaManagement = new MjAreaManagement();
        areaManagement.setAreaParentId(mjTeamArea.getAreaId());
        List<MjAreaManagement> mjAreaManagements = iMjAreaManagementService.selectMjAreaManagementList(areaManagement);
        for(MjAreaManagement m:mjAreaManagements){
            mjTeamArea.setAreaId(m.getId());
            addSave(mjTeamArea);
        }
        addSave(mjTeamArea);
        return toAjax(true);
    }

//    @PostMapping("/add2")
//    @ResponseBody
//    public AjaxResult addSave2(MjTeamArea mjTeamArea)
//    {
//
//        MjAreaManagement areaManagement = new MjAreaManagement();
//        areaManagement.setAreaParentId(mjTeamArea.getAreaId());
//        List<MjAreaManagement> mjAreaManagements = iMjAreaManagementService.selectMjAreaManagementList(areaManagement);
//        for(MjAreaManagement m:mjAreaManagements){
//            MjTeamArea mjTeamArea2 = new MjTeamArea();
//            mjTeamArea2.setAreaId(m.getId());
//            mjTeamArea2.setTeamId(mjTeamArea.getTeamId());
//            mjTeamArea2.setAreaName(m.getAreaName());
//            List<MjTeamArea> mjTeamAreas2 = mjTeamAreaService.selectMjTeamAreaList(mjTeamArea2);
//            if(mjTeamAreas2.size()>0){
//                if(mjTeamAreas2.get(0).getStatus()==2){
//                    MjTeamArea m2 = mjTeamAreas2.get(0);
//                    m2.setStatus(0);
//                    return toAjax(mjTeamAreaService.updateMjTeamArea(m2));
//                }
//                //return error("不可重复添加");
//                continue;
//            }
//            mjTeamArea2.setUpdateTime(DateUtils.getNowDate());
//            mjTeamArea2.setId(IdUtils.fastSimpleUUID());
//
//
//            updateNum(mjTeamArea2.getTeamId());
//            mjTeamAreaService.insertMjTeamArea(mjTeamArea2);
//
//            MjTeam team = iMjTeamService.selectMjTeamById(mjTeamArea.getTeamId());
//            MjTeamMember teamMember = new MjTeamMember();
//            teamMember.setTeamId(team.getId());
//            teamMember.setStatus(0);
//            teamMember.setDelFlag(0);
//            List<MjTeamMember> mjTeamMembers = iMjTeamMemberService.selectMjTeamMemberList(teamMember);
//            for(MjTeamMember mtm:mjTeamMembers) {
//                MjFingerprintReadHead fingerprintReadHead = new MjFingerprintReadHead();
//                fingerprintReadHead.setAreaId(mjTeamArea.getAreaId());
//                List<MjFingerprintReadHead> hs = iMjFingerprintReadHeadService.selectMjFingerprintReadHeadList(fingerprintReadHead);
//                for (MjFingerprintReadHead rh : hs) {
//                    MjHeadsUsers mjHeadsUsers = new MjHeadsUsers();
//                    mjHeadsUsers.setUserId(Long.valueOf(mtm.getUserId()));
//                    mjHeadsUsers.setAuthorizeName(team.getTeamName());
//                    mjHeadsUsers.setAuthorizeResult(0);//未授权
//                    mjHeadsUsers.setAuthorizeType(0);//组授权
//                    mjHeadsUsers.setAuthorizeStatus(0);//增加授权
//                    mjHeadsUsers.setHeadId(rh.getId());//读头id
//                    mjHeadsUsers.setHeadType(rh.getNewOldStatus());
//                    mjHeadsUsers.setMainUser(1);
//                    mjHeadsUsers.setOrderId(team.getId());
//                    iMjHeadsUsersService.insertMjHeadsUsers(mjHeadsUsers);
//                    addPush(mjHeadsUsers);
//                }
//            }
//        }
//
//        List<MjTeamArea> mjTeamAreas = mjTeamAreaService.selectMjTeamAreaList(mjTeamArea);
//        if(mjTeamAreas.size()>0){
//            if(mjTeamAreas.get(0).getStatus()==2){
//                mjTeamArea.setStatus(0);
//                return toAjax(mjTeamAreaService.updateMjTeamArea(mjTeamArea));
//            }
//            return error("不可重复添加");
//        }
//        mjTeamArea.setUpdateTime(DateUtils.getNowDate());
//        mjTeamArea.setId(IdUtils.fastSimpleUUID());
//        MjAreaManagement mjAreaManagement = iMjAreaManagementService.selectMjAreaManagementById(mjTeamArea.getAreaId());
//        mjTeamArea.setAreaName(mjAreaManagement.getAreaName());
//
//        updateNum(mjTeamArea.getTeamId());
//        mjTeamAreaService.insertMjTeamArea(mjTeamArea);
//
//        MjTeam team = iMjTeamService.selectMjTeamById(mjTeamArea.getTeamId());
//        MjTeamMember teamMember = new MjTeamMember();
//        teamMember.setTeamId(team.getId());
//        teamMember.setStatus(0);
//        teamMember.setDelFlag(0);
//        List<MjTeamMember> mjTeamMembers = iMjTeamMemberService.selectMjTeamMemberList(teamMember);
//        for(MjTeamMember mtm:mjTeamMembers) {
//            MjFingerprintReadHead fingerprintReadHead = new MjFingerprintReadHead();
//            fingerprintReadHead.setAreaId(mjTeamArea.getAreaId());
//            List<MjFingerprintReadHead> hs = iMjFingerprintReadHeadService.selectMjFingerprintReadHeadList(fingerprintReadHead);
//            for (MjFingerprintReadHead rh : hs) {
//                MjHeadsUsers mjHeadsUsers = new MjHeadsUsers();
//                mjHeadsUsers.setUserId(Long.valueOf(mtm.getUserId()));
//                mjHeadsUsers.setAuthorizeName(team.getTeamName());
//                mjHeadsUsers.setAuthorizeResult(0);//未授权
//                mjHeadsUsers.setAuthorizeType(0);//组授权
//                mjHeadsUsers.setAuthorizeStatus(0);//增加授权
//                mjHeadsUsers.setHeadId(rh.getId());//读头id
//                mjHeadsUsers.setHeadType(rh.getNewOldStatus());
//                mjHeadsUsers.setMainUser(1);
//                mjHeadsUsers.setOrderId(team.getId());
//                iMjHeadsUsersService.insertMjHeadsUsers(mjHeadsUsers);
//                if(rh.getNewOldStatus()==1){
//                    addPush(mjHeadsUsers);
//                }
//            }
//        }
//        return toAjax(true);
//    }

    public void quXiao(MjHeadsUsers headsUsers){
        Thread t = new Thread(new Runnable(){
            public void run(){
                MjFingerprintReadHead head = iMjFingerprintReadHeadService.selectMjFingerprintReadHeadById(headsUsers.getHeadId());
                if(StringUtils.isNotEmpty(head.getIpOrOther()) && StringUtils.isNotEmpty(head.getPort())) {
                    mjWorkUserPushService.removeFingerTmp(headsUsers.getUserId().toString(), head.getIpOrOther(), head.getPort());
                }
            }
        });
    }

    public void addPush(MjHeadsUsers headsUsers){
        Thread t = new Thread(new Runnable(){
            public void run(){
                MjFingerprintReadHead head = iMjFingerprintReadHeadService.selectMjFingerprintReadHeadById(headsUsers.getHeadId());
                List<TmpDataModel> tmpDataModels = fingerprintService.selectMjFingerprintListByUserId(headsUsers.getUserId());
                String users = domainToModel(headsUsers, tmpDataModels);

                int code = addTeamUsers(users,head);
                if(code==0){
                    System.out.println("推送成功");
                }else{
                    System.out.println("推送失败");
                }
            }
        });
        t.start();
    }

    //增加组用户
    private Integer addTeamUsers(String value, MjFingerprintReadHead head) {
        RestTemplate restTemplate = new RestTemplate();
        HttpHeaders headers = new HttpHeaders();
        headers.setContentType(MediaType.APPLICATION_FORM_URLENCODED);
        JSONObject jsonObject = null;

        MultiValueMap<String, Object> map= new LinkedMultiValueMap<>();

        map.add("ip", head.getIpOrOther());
        map.add("port", head.getPort());
        map.add("userDatas", value);

        HttpEntity<MultiValueMap<String, Object>> request = new HttpEntity<>(map, headers);
        try {
            ResponseEntity<String> response = restTemplate.postForEntity( UrlConstant.ZK_URL+"api/SDZ/ZktAddUserTmpByList", request , String.class );
            jsonObject = JSONObject.parseObject(response.getBody());
            System.out.println(response.getBody());
        }catch (Exception e) {
            e.printStackTrace();
            return 1;
        }
        if(jsonObject != null) {
            return (int)jsonObject.get("code");
        }
        return 1;
    }

    //转换为访问所需model
    private String domainToModel(MjHeadsUsers headsUsers, List<TmpDataModel> mjFingerprintList) {
        List<WorkUserModel> wums = new ArrayList<WorkUserModel>();

        WorkUserModel workUserModel = new WorkUserModel();
        workUserModel.setId(headsUsers.getUserId().toString().trim());
        MjWorkUser workUser = workUserService.selectMjWorkUserById(headsUsers.getUserId());
        workUserModel.setName(workUser.getUserName().trim());
        workUserModel.setPass("");
        workUserModel.setiPrivilege(0);
        workUserModel.setFlag("a");
        workUserModel.setTmpDatas(mjFingerprintList);
        wums.add(workUserModel);

        JSONArray jsonArray=new JSONArray(Collections.singletonList(wums));
        String userDatas = jsonArray.toString().substring(1, jsonArray.toString().length()-1);
        return userDatas;
    }
}