package cn.huge.module.grid.service;

import cn.huge.base.common.bo.R;
import cn.huge.base.common.utils.HttpClientUtils;
import cn.huge.base.common.utils.SpringContextUtil;
import cn.huge.module.grid.dao.mapper.CitizenEventMapper;
import cn.huge.module.grid.domain.po.CitizenEventPo;
import cn.huge.module.grid.domain.vo.GenerateQrCodeRequestVo;
import cn.huge.module.grid.domain.vo.YaymQrCodeInfoVo;
import com.alibaba.fastjson.JSON;
import com.alibaba.fastjson.JSONObject;
import lombok.extern.slf4j.Slf4j;
import org.apache.commons.codec.digest.DigestUtils;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.beans.factory.annotation.Value;
import org.springframework.stereotype.Service;

import java.time.LocalDateTime;
import java.time.format.DateTimeFormatter;
import java.util.HashMap;
import java.util.Map;

/**
 * 市民工单服务类
 */
@Slf4j
@Service
public class CitizenEventService {
    
    @Autowired
    private CitizenEventMapper citizenEventMapper;
    
    @Value("${grid.url:http://219.137.166.84:8061}")
    private String gridUrl;
    
    @Value("${grid.username:mtxt0011}")
    private String userName;
    
    @Value("${grid.password}")
    private String passWord;
    
    @Value("${grid.secret:BZb2hLCx05}")
    private String secret;
    
    @Value("${grid.passid:b08c0ec0-772d-caf8-5c9b-1f7d86295a95}")
    private String passid;
    
    /**
     * 初始化请求头信息
     */
    public HashMap<String,String> initHeadVo() {
        long timestamp = System.currentTimeMillis()/1000;
        HashMap<String,String> headVo = new HashMap<>();
        headVo.put("x-rio-paasid",passid);
        headVo.put("x-rio-timestamp",timestamp+"");
        headVo.put("x-rio-nonce","mt");
        headVo.put("x-rio-signature", DigestUtils.sha256Hex(timestamp+secret+"mt"+timestamp));
        return headVo;
    }
    
    /**
     * 生成二维码并保存工单信息
     */
    public R<YaymQrCodeInfoVo> generateQrCodeAndSave(GenerateQrCodeRequestVo requestVo) {
        log.info("生成二维码请求参数:{}", JSON.toJSONString(requestVo));
        
        // 参数验证
        if (requestVo == null) {
            return R.fail("请求参数不能为空");
        }
        if (requestVo.getId() == null || requestVo.getId().trim().isEmpty()) {
            return R.fail("工单id不能为空");
        }
        if (requestVo.getBusinessSource() == null || requestVo.getBusinessSource().trim().isEmpty()) {
            return R.fail("事件业务来源编码不能为空");
        }
        if (requestVo.getGenerateUnifiedCode() == null) {
            return R.fail("是否生成统一工单编码不能为空");
        }
        
        // 当generateUnifiedCode为true时，校验必填字段
        if (Boolean.TRUE.equals(requestVo.getGenerateUnifiedCode())) {
            if (requestVo.getInfoSource() == null || requestVo.getInfoSource().trim().isEmpty()) {
                return R.fail("当生成统一工单编码时，事件来源渠道不能为空");
            }
            if (requestVo.getGridCode() == null || requestVo.getGridCode().trim().isEmpty()) {
                return R.fail("当生成统一工单编码时，网格编码不能为空");
            }
        }
        
        // 初始化请求头
        HashMap<String,String> headVo = initHeadVo();
        log.info("请求头信息:{}", JSON.toJSONString(headVo));
        
        String responseStr;
        try {
            // 开发环境
            if (SpringContextUtil.checkDev()) {
                String testUrl = "http://183.2.142.46:9007/api/thrid/citizen/event/generateQrCode";
                log.info("开发环境请求URL:{}", testUrl);
                Map<String, String> headers = new HashMap<>();
                headers.put("Content-Type", "application/json");
                responseStr = HttpClientUtils.httpPostRaw(testUrl, JSON.toJSONString(requestVo), headers, "utf-8");
            } else {
                // 生产环境 - 使用HTTP Header认证方式
                String httpPostUrl = gridUrl + "/standard/eventform/generateYaymQrCode";
                log.info("生产环境请求URL:{}", httpPostUrl);
                log.info("请求参数:{}", JSON.toJSONString(requestVo));
                responseStr = HttpClientUtils.httpPostRaw(httpPostUrl, JSON.toJSONString(requestVo), headVo, "utf-8");
            }
        } catch (Exception e) {
            log.error("调用接口异常:", e);
            throw new RuntimeException("调用接口失败", e);
        }
        
        log.info("接口响应:{}", responseStr);
        
        // 解析响应结果
        JSONObject response = JSONObject.parseObject(responseStr);
        Integer code = response.getInteger("code");
        String message = response.getString("message");
        if (message == null) {
            message = response.getString("desc");
        }
        
        if (code == null || code != 0) {
            log.error("接口调用失败, code:{}, message:{}", code, message);
            return R.fail(message != null ? message : "接口调用失败");
        }
        
        // 获取响应数据
        YaymQrCodeInfoVo yaymQrCodeInfo = response.getObject("data", YaymQrCodeInfoVo.class);
        
        if (yaymQrCodeInfo != null) {
            // 保存到数据库
            saveToDatabase(requestVo.getId(), yaymQrCodeInfo);
        }
        
        return R.ok(yaymQrCodeInfo, message);
    }
    
    /**
     * 保存工单信息到数据库
     */
    private void saveToDatabase(String caseId, YaymQrCodeInfoVo yaymQrCodeInfo) {
        try {
            CitizenEventPo citizenEvent = new CitizenEventPo();
            citizenEvent.setCaseId(caseId);
            citizenEvent.setCitizenEventCode(yaymQrCodeInfo.getCitizenEventCode());
            citizenEvent.setQrcodeImg(yaymQrCodeInfo.getQrcodeImg());
            citizenEvent.setTitle(yaymQrCodeInfo.getTitle());
            
            // 处理时间字符串转换
            if (yaymQrCodeInfo.getReportTime() != null && !yaymQrCodeInfo.getReportTime().isEmpty()) {
                try {
                    DateTimeFormatter formatter = DateTimeFormatter.ofPattern("yyyy-MM-dd HH:mm:ss");
                    citizenEvent.setReportTime(LocalDateTime.parse(yaymQrCodeInfo.getReportTime(), formatter));
                } catch (Exception e) {
                    log.warn("时间格式转换失败:{}", yaymQrCodeInfo.getReportTime(), e);
                }
            }
            
            citizenEvent.setReportUser(yaymQrCodeInfo.getReportUser());
            citizenEvent.setEntryItemName(yaymQrCodeInfo.getEntryItemName());
            citizenEvent.setUnifiedCode(yaymQrCodeInfo.getUnifiedCode());
            citizenEvent.setCreateTime(LocalDateTime.now());
            citizenEvent.setUpdateTime(LocalDateTime.now());
            citizenEvent.setDeleteStatus(0);
            
            // 先尝试更新，如果不存在则插入
            int updateCount = citizenEventMapper.updateById(citizenEvent);
            if (updateCount == 0) {
                citizenEventMapper.insert(citizenEvent);
                log.info("新增工单信息成功, caseId:{}", caseId);
            } else {
                log.info("更新工单信息成功, caseId:{}", caseId);
            }
            
        } catch (Exception e) {
            log.error("保存工单信息到数据库失败, caseId:{}", caseId, e);
            throw new RuntimeException("保存工单信息失败", e);
        }
    }
    
    /**
     * 根据工单ID查询工单信息
     */
    public R<CitizenEventPo> getCitizenEventById(String caseId) {
        try {
            CitizenEventPo citizenEvent = citizenEventMapper.selectById(caseId);
            if (citizenEvent == null) {
                return R.fail("工单信息不存在");
            }
            return R.ok(citizenEvent);
        } catch (Exception e) {
            log.error("查询工单信息失败, caseId:{}", caseId, e);
            return R.fail("查询工单信息失败: " + e.getMessage());
        }
    }
}