package com.adc.da.mq;

import com.adc.da.slrs.sarBussionessStand.entity.SarBussionessStand;
import com.adc.da.slrs.sarLawsInfo.entity.SarLawsInfo;
import com.adc.da.slrs.sarLawsStandInfo.entity.SarLawsStandInfo;
import net.sf.json.JSONObject;
import org.springframework.amqp.core.AmqpTemplate;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Component;

import java.util.HashMap;
import java.util.Map;

@Component
public class CreateStandMQService {
    @Autowired
    private AmqpTemplate rabbitTemplate;

    /**
     *
     * @param sarStandardsInfoEO 标准实体
     * @param addOrUpdate
     * @throws Exception
     */
    public void sendStandMQ(Object sarStandardsInfoEO, String addOrUpdate) throws Exception{
        JSONObject json = JSONObject.fromObject(sarStandardsInfoEO);
        String sarStandardsInfoStr = json.toString();
        Map<String,Object> standMap = new HashMap<String,Object>();
        standMap.put("sarStandards", sarStandardsInfoStr);
        standMap.put("addOrUpdate", addOrUpdate);

        //发送消息队列
        this.rabbitTemplate.convertAndSend("stand-exchange_SQ_GSAR_RELEASE", "stand-key_SQ_GSAR_RELEASE", standMap);
    }

    public void sendLawsMQ(SarLawsStandInfo sarLawsStandInfo, String addOrUpdate) throws Exception{
//        JSONObject json = JSONObject.fromObject(sarLawsStandInfo);
        com.alibaba.fastjson.JSONObject object = (com.alibaba.fastjson.JSONObject) com.alibaba.fastjson.JSONObject.toJSON(sarLawsStandInfo);

        String sarLawsInfoStr = object.toString();
        Map<String,Object> lawsMap = new HashMap<String,Object>();
        lawsMap.put("sarLaws", sarLawsInfoStr);
        lawsMap.put("addOrUpdate", addOrUpdate);

        //发送消息队列
        this.rabbitTemplate.convertAndSend("laws-exchange_SQ_GSAR_RELEASE", "laws-key_SQ_GSAR_RELEASE", lawsMap);
    }

    public void sendBussStandMQ(Object sarBussionessStandEO, String addOrUpdate) throws Exception{
        JSONObject json = JSONObject.fromObject(sarBussionessStandEO);
        String sarBussInfoStr = json.toString();
        Map<String,Object> bussMap = new HashMap<String,Object>();
        bussMap.put("sarBuss", sarBussInfoStr);
        bussMap.put("addOrUpdate", addOrUpdate);

        //发送消息队列
        this.rabbitTemplate.convertAndSend("buss-exchange_SQ_GSAR_RELEASE", "buss-key_SQ_GSAR_RELEASE", bussMap);
    }

}