package org.jeecg.modules.lims.service.impl;

import cn.binarywang.wx.miniapp.api.WxMaMsgService;
import cn.binarywang.wx.miniapp.api.WxMaService;
import cn.binarywang.wx.miniapp.api.WxMaUserService;
import cn.binarywang.wx.miniapp.bean.WxMaJscode2SessionResult;
import cn.binarywang.wx.miniapp.bean.WxMaSubscribeMessage;
import me.chanjar.weixin.common.error.WxErrorException;
import org.apache.commons.lang3.StringUtils;
import org.jeecg.modules.lims.api.JeecgSystemClient;
import org.jeecg.modules.lims.entity.LimsAppointmentAudit;
import org.jeecg.modules.lims.entity.SysUser;
import org.jeecg.modules.lims.entity.WxAccessToken;
import org.jeecg.modules.lims.service.IWxService;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;

import java.util.ArrayList;
import java.util.List;
import java.util.Map;
import java.util.concurrent.atomic.AtomicBoolean;
import java.util.concurrent.atomic.AtomicReference;

@Service
public class WxServiceImpl implements IWxService {
    @Autowired
    private WxMaService wxMaService;
    @Autowired
    private JeecgSystemClient systemClient;

    @Autowired
    private LimsAppointmentAuditServiceImpl auditService;

    @Override
    public WxAccessToken getWxAccessToken() {
//        RestTemplate restTemplate = new RestTemplate();
//        String uri = "https://api.weixin.qq.com/cgi-bin/token?grant_type=client_credential&appid="+wxMaConfig.getAppid()+"&secret="+wxMaConfig.getSecret();
//        HttpHeaders headers = new HttpHeaders();
//        headers.setContentType(MediaType.parseMediaType("application/json;charset=UTF-8"));
//        HttpEntity<String> entity = new HttpEntity<String>(headers);
//        ResponseEntity<String> response = restTemplate.exchange(uri, HttpMethod.GET, entity, String.class);
//        System.err.println("1212121212");
//        System.err.println(uri);
//        System.out.println(response);
//        System.out.println(response.getBody());

        try {
            String accessToken = wxMaService.getAccessToken();

            WxMaMsgService msgService = wxMaService.getMsgService();
            WxMaSubscribeMessage msg = new WxMaSubscribeMessage();
            List<WxMaSubscribeMessage.MsgData> data = new ArrayList<>();
            WxMaSubscribeMessage.MsgData d1 = new WxMaSubscribeMessage.MsgData("thing1", "朱桂飞");
            WxMaSubscribeMessage.MsgData d2 = new WxMaSubscribeMessage.MsgData("thing2", "软件开发部");
            WxMaSubscribeMessage.MsgData d3 = new WxMaSubscribeMessage.MsgData("thing3", "高温测试仪");
            WxMaSubscribeMessage.MsgData d4 = new WxMaSubscribeMessage.MsgData("short_thing4", "4小时");
            data.add(d1);
            data.add(d2);
            data.add(d3);
            data.add(d4);
            msg.setMiniprogramState("developer");
            msg.setTemplateId("B_o0wim0Y0logboa6uuu3dYurdW9uHiVHOGAEAd1sOw");
            msg.setPage("pages/appo/appoAudit");
            msg.setToUser("ogmOE5B2uxDwMhuWkkOsq885p_hQ");
            msg.setData(data);
            msgService.sendSubscribeMsg(msg);
            System.err.println(accessToken);
        } catch (WxErrorException e) {
            e.printStackTrace();
        }

        return null;
    }

    @Override
    public void sendMessage(Map<String, String> params, LimsAppointmentAudit audit) {
        System.err.println(params.toString());
        //1.发送消息服务
        WxMaMsgService msgService = wxMaService.getMsgService();
        //2.组装消息
        WxMaSubscribeMessage msg = new WxMaSubscribeMessage();
        List<WxMaSubscribeMessage.MsgData> data = new ArrayList<>();
        WxMaSubscribeMessage.MsgData d1 = new WxMaSubscribeMessage.MsgData("thing1", params.get("realname"));
        WxMaSubscribeMessage.MsgData d2 = new WxMaSubscribeMessage.MsgData("thing2", params.get("depart"));
        WxMaSubscribeMessage.MsgData d3 = new WxMaSubscribeMessage.MsgData("thing3", params.get("equ"));
        WxMaSubscribeMessage.MsgData d4 = new WxMaSubscribeMessage.MsgData("short_thing4", params.get("time"));
        data.add(d1);
        data.add(d2);
        data.add(d3);
        data.add(d4);
        msg.setMiniprogramState("formal");
        msg.setTemplateId("B_o0wim0Y0logboa6uuu3dYurdW9uHiVHOGAEAd1sOw");
        msg.setPage("pages/appo/appoAudit");
        msg.setData(data);
        //3.查询需要推送的用户
        List<SysUser> result = systemClient.minilist().getResult();
        AtomicReference<String> errMessage = new AtomicReference<>();
        errMessage.set("");
        AtomicBoolean success = new AtomicBoolean(false);
        if (result.size()>0) {
            result.forEach(item -> {
                //4.发送消息
                try {
                    if (!StringUtils.isEmpty(item.getOpenid())) {
                        msg.setToUser(item.getOpenid());
                        msgService.sendSubscribeMsg(msg);
                        success.set(true);
                        errMessage.set("");
                    } else {
                        System.err.println("微信推送消息：审批管理员openid为空！");
                        if (!success.get()) {
                            errMessage.set("微信推送消息：审批管理员openid为空！");
                        }
                    }
                } catch (WxErrorException e) {
                    e.printStackTrace();
                    if (!success.get()) {
                        errMessage.set("微信推送消息：消息推送异常！");
                    }
                }
            });
        } else {
            errMessage.set("微信推送消息：没有审批用户，推送消息失败!");
        }


        audit.setRemark(StringUtils.isEmpty(errMessage.get()) ? "推送成功" : errMessage.get());
        audit.setPush(StringUtils.isEmpty(errMessage.get()) ? 1 : 0);
        auditService.updateById(audit);
    }

    @Override
    public void sendMessageToUser(Map<String, String> params, LimsAppointmentAudit audit) {
        //1.发送消息服务
        WxMaMsgService msgService = wxMaService.getMsgService();
        //2.组装消息
        WxMaSubscribeMessage msg = new WxMaSubscribeMessage();
        List<WxMaSubscribeMessage.MsgData> data = new ArrayList<>();
        WxMaSubscribeMessage.MsgData d1 = new WxMaSubscribeMessage.MsgData("thing7", params.get("equ"));
        WxMaSubscribeMessage.MsgData d2 = new WxMaSubscribeMessage.MsgData("thing2", params.get("realname"));
        WxMaSubscribeMessage.MsgData d3 = new WxMaSubscribeMessage.MsgData("time3", params.get("date"));
        WxMaSubscribeMessage.MsgData d4 = new WxMaSubscribeMessage.MsgData("thing10", params.get("result"));
        WxMaSubscribeMessage.MsgData d5 = new WxMaSubscribeMessage.MsgData("thing6", params.get("remark"));
        data.add(d1);
        data.add(d2);
        data.add(d3);
        data.add(d4);
        data.add(d5);
        msg.setMiniprogramState("formal");
        msg.setTemplateId("ZDDaS7ujKRQJuFbNbVCRCbEYlOGF9_lf_xV1GQzeOvg");
        msg.setPage("pages/appo/appoAudit");
        msg.setData(data);
        //3.查询需要推送的用户
        SysUser user = systemClient.queryByUserName(params.get("username")).getResult();
        AtomicReference<String> errMessage = new AtomicReference<>();
        errMessage.set("");
        AtomicBoolean success = new AtomicBoolean(false);
        if (user!=null) {
                //4.发送消息
                try {
                    if (!StringUtils.isEmpty(user.getOpenid())) {
                        msg.setToUser(user.getOpenid());
                        msgService.sendSubscribeMsg(msg);
                        success.set(true);
                        errMessage.set("");
                    } else {
                        System.err.println("微信推送消息：被通知用户openid为空！");
                        if (!success.get()) {
                            errMessage.set("微信推送消息：被通知用户openid为空！");
                        }
                    }
                } catch (WxErrorException e) {
                    e.printStackTrace();
                    if (!success.get()) {
                        errMessage.set("微信推送消息：消息推送异常！");
                    }
                }

        }
    }

    @Override
    public String getOpenId(String js_code) {
        WxMaUserService userService = wxMaService.getUserService();
        String openid = null;
        try {
            WxMaJscode2SessionResult sessionInfo = userService.getSessionInfo(js_code);
            openid = sessionInfo.getOpenid();
            System.err.println(openid);
        } catch (WxErrorException e) {
            e.printStackTrace();
        }

        return openid;
    }


}