加入系统消息

yujian

2019-01-29 d1c067339554c90fb74653748ccf224104d8c8e4

加入系统消息

 fanli/src/main/java/com/yeshi/fanli/controller/admin/PushController.java

@@ -8,9 +8,12 @@
import org.springframework.web.bind.annotation.RequestMapping;

import org.springframework.web.bind.annotation.RequestMethod;



import com.yeshi.fanli.entity.bus.msg.UserSystemMsg;

import com.yeshi.fanli.entity.bus.msg.UserSystemMsgTypeEnum;

import com.yeshi.fanli.exception.PushException;

import com.yeshi.fanli.service.inter.config.ConfigService;

import com.yeshi.fanli.service.inter.config.SystemService;

import com.yeshi.fanli.service.inter.msg.UserSystemMsgService;

import com.yeshi.fanli.service.inter.push.PushRecordService;

import com.yeshi.fanli.service.inter.push.PushService;

import com.yeshi.fanli.service.inter.user.AccountMessageService;

@@ -51,6 +54,9 @@


    @Resource

    private PushService pushService;

	
    @Resource

    private UserSystemMsgService userSystemMsgService;



    /**

     * 商品推送

@@ -273,12 +279,17 @@
                    String str_uid = uidArray[i];

                    if (str_uid != null && str_uid.trim().length() > 0) {

                        pushService.pushZNX(Long.parseLong(str_uid), title, content);

						
                        userSystemMsgService.addUserSystemMsg(Long.parseLong(str_uid), 
                                UserSystemMsgTypeEnum.question, title, content, 
                                UserSystemMsg.TIME_TAG_EMERGENT, null);

                    }

                }

            }

			
            JsonUtil.printMode(out, callback, JsonUtil.loadTrueResult("推送成功"));

        } catch (PushException e) {

            JsonUtil.printMode(out, callback, JsonUtil.loadFalseResult("推送失败"));

        } catch (Exception e) {

            JsonUtil.printMode(out, callback, JsonUtil.loadFalseResult("推送失败"));

            e.printStackTrace();

        }

@@ -324,6 +335,8 @@
            

        } catch (PushException e) {

            JsonUtil.printMode(out, callback, JsonUtil.loadFalseResult("推送失败"));

        } catch (Exception e) {

            JsonUtil.printMode(out, callback, JsonUtil.loadFalseResult("推送失败"));

            e.printStackTrace();

        }

    }