增加有赚项目接口

@@ -105,4 +105,13 @@ public class SendScenes {
 	public static final String RETRUN_NOT_SEND_BACK = "RETRUN_NOT_SEND_BACK";
 	//换货商品未寄回
 	public static final String CHANGE_NOT_SEND_BACK = "CHANGE_NOT_SEND_BACK";
+
+	//有货有赚项目  佣金结算提醒
+	public static final String YOZHUAN_COMMISSION_SETTLEMENT = "YOZHUAN_COMMISSION_SETTLEMENT";
+
+	//有货有赚项目  提现打款提醒
+	public static final String YOZHUAN_CRASH_ACCOUNT = "YOZHUAN_CRASH_ACCOUNT";
+
+	//有货有赚项目  订单任务完成提醒
+	public static final String YOZHUAN_ORDER_COMPLETE = "YOZHUAN_ORDER_COMPLETE";
 }

 package com.yoho.message.sdk.service.product;
 
+import com.yoho.message.sdk.common.constants.SendScenes;
+import com.yoho.message.sdk.common.handler.MessageCenterMqHandler;
+import com.yoho.message.sdk.common.model.MessageCenterCommonEvent;
 import com.yoho.message.sdk.common.model.SendMessageRspBo;
+import com.yoho.message.sdk.service.AbstractSendMessage;
+import org.springframework.beans.factory.annotation.Autowired;
 
 /**
  * Created by min.ling on 2018/8/3.
  */
-public class SendProductMessageImpl implements ISendProductMessage {
+public class SendProductMessageImpl extends AbstractSendMessage implements ISendProductMessage {
+
+    @Autowired
+    private MessageCenterMqHandler messageCenterMqHandler;
+
+
     @Override
     public SendMessageRspBo commissionNotice(String uid, String orderNum, String orderAmount) {
-        return null;
+        MessageCenterCommonEvent messageCenterCommonEvent = genMessageCenterCommonEvent(SendScenes.YOZHUAN_COMMISSION_SETTLEMENT, uid, uid);
+        messageCenterCommonEvent.putInParams("orderNum", orderNum);
+        messageCenterCommonEvent.putInParams("orderAmount", orderAmount);
+        messageCenterMqHandler.sendMessageToMq(messageCenterCommonEvent);
+        return new SendMessageRspBo(200, "SUCCESS");
     }
 
     @Override
     public SendMessageRspBo cashAccountNotice(String uid, String accountCode, String accountAmount, String accountTime) {
-        return null;
+        MessageCenterCommonEvent messageCenterCommonEvent = genMessageCenterCommonEvent(SendScenes.YOZHUAN_CRASH_ACCOUNT, accountCode, uid);
+        messageCenterCommonEvent.putInParams("accountCode", accountCode);
+        messageCenterCommonEvent.putInParams("accountAmount", accountAmount);
+        messageCenterCommonEvent.putInParams("accountTime", accountTime);
+        messageCenterMqHandler.sendMessageToMq(messageCenterCommonEvent);
+        return new SendMessageRspBo(200, "SUCCESS");
     }
 
     @Override
     public SendMessageRspBo orderCompletedNotice(String uid, String ForecastIncome) {
-        return null;
+        MessageCenterCommonEvent messageCenterCommonEvent = genMessageCenterCommonEvent(SendScenes.YOZHUAN_ORDER_COMPLETE, uid, uid);
+        messageCenterCommonEvent.putInParams("ForecastIncome", ForecastIncome);
+        messageCenterMqHandler.sendMessageToMq(messageCenterCommonEvent);
+        return new SendMessageRspBo(200, "SUCCESS");
     }
 }