oppo推送绑定

admin

2019-09-24 f54093a69938aca18ca6ba005e17afe5ee5bbfe6

oppo推送绑定

 fanli/src/main/java/com/yeshi/fanli/controller/TestController.java

@@ -48,6 +48,7 @@
import com.yeshi.fanli.entity.taobao.TaoBaoGoodsBrief;

import com.yeshi.fanli.entity.taobao.TaoBaoGoodsBriefExtra;

import com.yeshi.fanli.exception.ActivityException;

import com.yeshi.fanli.exception.push.PushException;

import com.yeshi.fanli.exception.share.UserShareGoodsRecordException;

import com.yeshi.fanli.exception.taobao.TaobaoGoodsDownException;

import com.yeshi.fanli.log.LogHelper;

@@ -65,6 +66,7 @@
import com.yeshi.fanli.util.db.MongoDBManager;

import com.yeshi.fanli.util.factory.goods.GoodsDetailVOFactory;

import com.yeshi.fanli.util.jd.JDApiUtil;

import com.yeshi.fanli.util.push.OPPOPushUtil;

import com.yeshi.fanli.vo.goods.GoodsDetailVO;



import net.sf.json.JSONArray;

@@ -538,4 +540,39 @@
        }

        out.println(array.toString());

    }



    @RequestMapping(value = "pushOppo")

    public void pushOppo(String registerId, PrintWriter out) {

        List<String> registerIds = new ArrayList<>();

        registerIds.add(registerId);

        try {

            OPPOPushUtil.pushUrl(registerIds, "测试网页推送", "测试网页推送内容", "http://www.baidu.com");

        } catch (PushException e) {

            e.printStackTrace();

        }



        try {

            OPPOPushUtil.pushGoods(registerIds, "测试商品网页推送", "测试商品推送内容", 1, 577628549116L);

        } catch (PushException e) {

            e.printStackTrace();

        }



        try {

            OPPOPushUtil.pushUserSignInNotification(registerIds, "测试签到推送", "测试签到推送");

        } catch (PushException e) {

            e.printStackTrace();

        }

        try {

            OPPOPushUtil.pushWelfareCenter(registerIds, "测试福利中心推送", "测试福利中心推送");

        } catch (PushException e) {

            e.printStackTrace();

        }

        try {

            OPPOPushUtil.pushZNX(registerIds, "测试站内信推送", "测试站内信推送");

        } catch (PushException e) {

            e.printStackTrace();

        }



        out.print("success");

    }

}


 fanli/src/main/java/com/yeshi/fanli/controller/client/v1/UserAccountController.java

@@ -262,6 +262,11 @@
                            platformType = 2;

                        }

                        userSystemCouponService.copyLotteryPrize(uuser.getId(), platformType, acceptData.getDevice());

                        // 绑定oppo推送

                        DeviceActive active = deviceActiveService.getFirstActiveInfo(acceptData.getDevice());

                        if (active != null) {

                            deviceTokenOPPOService.bindUid(uuser.getId(), active.getId());

                        }

                    } catch (Exception e) {

                        e.printStackTrace();

                    }

@@ -1224,6 +1229,12 @@
                                e.printStackTrace();

                            }

                        }

						
                        // 绑定oppo推送

                        DeviceActive active = deviceActiveService.getFirstActiveInfo(acceptData.getDevice());

                        if (active != null) {

                            deviceTokenOPPOService.bindUid(uuser.getId(), active.getId());

                        }

                    }

                });

            }


 fanli/src/main/java/com/yeshi/fanli/mapping/push/DeviceTokenOPPOMapper.xml

@@ -73,12 +73,8 @@
                da_version_code=#{ver}
            </foreach>
        </if>
		
    </select>
    
     List<Integer> verisonList
	

    <delete id="deleteByPrimaryKey" parameterType="java.lang.Long">delete from
        yeshi_ec_uid_devicetoken_oppo where do_id = #{id,jdbcType=BIGINT}
    </delete>

 fanli/src/main/java/com/yeshi/fanli/service/impl/order/tb/TaoBaoOrderServiceImpl.java

@@ -1,8 +1,5 @@
package com.yeshi.fanli.service.impl.order.tb;



import java.util.ArrayList;

import java.util.Collections;

import java.util.Comparator;

import java.util.Date;

import java.util.HashSet;

import java.util.Iterator;


 fanli/src/main/java/com/yeshi/fanli/service/impl/push/DeviceTokenOPPOServiceImpl.java

@@ -48,6 +48,18 @@
    }



    @Override

    public void bindUid(Long uid, Long deviceActiveId) {

        DeviceTokenOPPO oldOppo = deviceTokenOPPOMapper.selectByDeviceActiveId(deviceActiveId);

        if (oldOppo != null) {

            DeviceTokenOPPO update = new DeviceTokenOPPO();

            update.setId(oldOppo.getId());

            update.setUid(uid);

            update.setUpdateTime(new Date());

            deviceTokenOPPOMapper.updateByPrimaryKeySelective(update);

        }

    }



    @Override

    public long countDeviceToken(List<Integer> versionList) {

        return deviceTokenOPPOMapper.countDeviceToken(versionList);

    }


 fanli/src/main/java/com/yeshi/fanli/service/inter/push/DeviceTokenOPPOService.java

@@ -28,6 +28,14 @@
    public void unBindUid(Long uid, Long deviceActiveId);



    /**

     * 绑定设备

     * 
     * @param uid

     * @param deviceActiveId

     */

    public void bindUid(Long uid, Long deviceActiveId);



    /**

     * 计算所有的设备

     * 

     * @return