DIL-DAZHOU-WMS2/src/main/java/com/steerinfo/dil/service/impl/UtilServiceImpl.java

package com.steerinfo.dil.service.impl;


import com.steerinfo.dil.feign.IMFeign;
import com.steerinfo.dil.service.IUtilService;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;

import java.util.ArrayList;
import java.util.Date;
import java.util.HashMap;

@Service
public class UtilServiceImpl implements IUtilService {


    @Autowired
    IMFeign imFeign;

    /**
     * 推送消息给websocket
     * @param capacityNumber
     * @param pushMes
     */
    @Override
    public void pushMesToWebsocket(String capacityNumber, String pushMes) {

        //添加消息实体
        HashMap<Object, Object> mesMap = new HashMap<>();
        mesMap.put("messageType", 4); //用于进厂后 刷新消息
        mesMap.put("sendPerson", "system");
        mesMap.put("receivePerson", capacityNumber);
        mesMap.put("messageContent", pushMes + new Date());
        mesMap.put("createTime", new Date());
        ArrayList<Object> list = new ArrayList<>();
        list.add(mesMap);
        //调用websocket接口推送
        HashMap<Object, Object> sendMap = new HashMap<>();
        //将消息实体放入list中存到map中
        sendMap.put("messages", list);
        imFeign.sendToUser(sendMap);
    }



}