admin
2020-07-14 eec7e789a87863c25d92c10ad5dfc22ad80c448d
fanli/src/main/java/com/yeshi/fanli/controller/admin/PushController.java
@@ -7,6 +7,7 @@
import javax.annotation.Resource;
import com.yeshi.fanli.entity.accept.AdminAcceptData;
import org.springframework.stereotype.Controller;
import org.springframework.web.bind.annotation.RequestMapping;
import org.yeshi.utils.HttpUtil;
@@ -16,7 +17,7 @@
import com.google.gson.reflect.TypeToken;
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.exception.push.PushException;
import com.yeshi.fanli.service.inter.msg.UserSystemMsgService;
import com.yeshi.fanli.service.inter.push.PushService;
import com.yeshi.fanli.util.StringUtil;
@@ -27,15 +28,6 @@
@Controller(value = "adminPushController")
@RequestMapping("admin/new/api/v1/push")
public class PushController {
   public final static int GOODS = 1; // 商品推送
   public final static int URL = 2; // 网页推送
   public final static int DETAIL = 3; // 详情推送
   public final static int ZNX = 4; // 站内推送
   public final static int WEEX = 5; // 站内推送
   public final static int BAICHUAN = 6; // 站内推送
   public final static int WELFARE_CENTER = 7; // 福利中心
   @Resource
   private PushService pushService;
@@ -52,7 +44,7 @@
    * @throws Exception
    */
   @RequestMapping(value = "convertLink")
   public void convertLink(String callback, String url, PrintWriter out) {
   public void convertLink(AdminAcceptData acceptData,String callback, String url, PrintWriter out) {
      if (StringUtil.isNullOrEmpty(url)) {
         JsonUtil.printMode(out, callback, JsonUtil.loadFalseResult("转链数据不能为空"));
@@ -84,8 +76,8 @@
    * @throws Exception
    */
   @RequestMapping(value = "newPushUrlAll")
   public void newPushUrlAll(String callback, String url, String title, String content, String uids,
         String arrayIOS, String arrayAndroid, PrintWriter out) {
   public void newPushUrlAll(AdminAcceptData acceptData, String callback, String url, String title, String content, String uids,
                       String arrayIOS, String arrayAndroid, PrintWriter out) {
      if (StringUtil.isNullOrEmpty(url) || StringUtil.isNullOrEmpty(title) || StringUtil.isNullOrEmpty(content)) {
         JsonUtil.printMode(out, callback, JsonUtil.loadFalseResult("请填写链接,标题与内容"));
@@ -120,12 +112,12 @@
         
         if (listuid == null) {
            // 全推
            pushService.pushUrl(null, title, content, url, listIOS, listAndroid);
            pushService.pushUrl(null, title, content, url, listIOS, listAndroid,acceptData.getSystem());
         } else {
            // 部分推送
            for (String str_uid: listuid) {
               if (str_uid != null && str_uid.trim().length() > 0) {
                  pushService.pushUrl(Long.parseLong(str_uid), url, title, content, listIOS, listAndroid);
                  pushService.pushUrl(Long.parseLong(str_uid), title, content, url, listIOS, listAndroid,acceptData.getSystem());
               }
            }
         }
@@ -143,13 +135,12 @@
    * 
    * 方法说明: 站内信推送 -(新后台)
    * 
    * @param uId
    * @param title
    * @param content
    * @throws Exception
    */
   @RequestMapping(value = "newPushFanZNX")
   public void newPushFanZNX(String callback, String uids, String title, String content, String arrayIOS,
   public void newPushFanZNX(AdminAcceptData acceptData,String callback, String uids, String title, String content, String arrayIOS,
         String arrayAndroid, PrintWriter out) {
      if (StringUtil.isNullOrEmpty(title) || StringUtil.isNullOrEmpty(content)) {
@@ -180,12 +171,12 @@
         
         if (listuid == null) {
            // 全推
            pushService.pushZNX(null, title, content, listIOS, listAndroid);
            pushService.pushZNX(null, title, content, listIOS, listAndroid,acceptData.getSystem());
         } else {
            // 部分推送
            for (String str_uid: listuid) {
               if (str_uid != null && str_uid.trim().length() > 0) {
                  pushService.pushZNX(Long.parseLong(str_uid), title, content, listIOS, listAndroid);
                  pushService.pushZNX(Long.parseLong(str_uid), title, content, listIOS, listAndroid,acceptData.getSystem());
                  userSystemMsgService.addUserSystemMsg(Long.parseLong(str_uid), UserSystemMsgTypeEnum.question,
                        title, content, UserSystemMsg.TIME_TAG_EMERGENT, null);
@@ -205,13 +196,12 @@
    * 
    * 方法说明: 百川推送 -(新后台)
    * 
    * @param uId
    * @param title
    * @param content
    * @throws Exception
    */
   @RequestMapping(value = "pushBaiChuan")
   public void pushBaiChuan(String callback, String uids, String title, String content, String url, String arrayIOS,
   public void pushBaiChuan(AdminAcceptData acceptData,String callback, String uids, String title, String content, String url, String arrayIOS,
         String arrayAndroid, PrintWriter out) {
      if (StringUtil.isNullOrEmpty(title) || StringUtil.isNullOrEmpty(content)) {
@@ -241,12 +231,12 @@
         
         if (listuid == null) {
            // 全推
            pushService.pushBaiChuanUrl(null, title, content, url, listIOS, listAndroid);
            pushService.pushBaiChuanUrl(null, title, content, url, listIOS, listAndroid,acceptData.getSystem());
         } else {
            // 部分推送
            for (String str_uid: listuid) {
               if (str_uid != null && str_uid.trim().length() > 0) {
                  pushService.pushBaiChuanUrl(Long.parseLong(str_uid), title, content, url, listIOS, listAndroid);
                  pushService.pushBaiChuanUrl(Long.parseLong(str_uid), title, content, url, listIOS, listAndroid,acceptData.getSystem());
               }
            }
         }