blame | 历史 | 补丁 | 提交 | 提交对比 | ignore whitespace
admin
2025-02-25 30d8e227e8d823b6c38c3b9c90ac2df03b63befe 
 fanli/src/main/java/com/yeshi/fanli/service/impl/push/IOSPushServiceImpl.java


@@ -1,24 +1,11 @@


package com.yeshi.fanli.service.impl.push;




import java.util.ArrayList;


import java.util.Arrays;


import java.util.Calendar;


import java.util.Date;


import java.util.List;




import javax.annotation.Resource;




import com.yeshi.fanli.entity.SystemEnum;


import com.yeshi.fanli.entity.config.SystemConfigKeyEnum;


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


import org.springframework.scheduling.annotation.Async;


import org.springframework.stereotype.Service;


import org.springframework.transaction.annotation.Transactional;




import com.yeshi.fanli.dao.mybatis.push.DeviceTokenIOSMapper;


import com.yeshi.fanli.dao.mybatis.push.PushQueueRecordMapper;


import com.yeshi.fanli.dto.push.PushTypeEnum;


import com.yeshi.fanli.entity.SystemEnum;


import com.yeshi.fanli.entity.bus.user.AccountMessage;


import com.yeshi.fanli.entity.config.SystemConfigKeyEnum;


import com.yeshi.fanli.entity.push.DeviceTokenIOS;


import com.yeshi.fanli.entity.push.PushQueueRecord;


import com.yeshi.fanli.entity.system.SystemZnx;


@@ -26,14 +13,20 @@


import com.yeshi.fanli.entity.xinge.PushRecord;


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


import com.yeshi.fanli.log.PushLogHelper;


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


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


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


import com.yeshi.fanli.util.CMQManager;


import com.yeshi.fanli.util.Constant;


import com.yeshi.fanli.util.StringUtil;


import com.yeshi.fanli.util.mq.rabbit.RabbitmqManager;


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




import net.sf.json.JSONObject;


import org.springframework.scheduling.annotation.Async;


import org.springframework.stereotype.Service;


import org.springframework.transaction.annotation.Transactional;




import javax.annotation.Resource;


import java.util.*;




@Service


public class IOSPushServiceImpl implements IOSPushService {


@@ -50,10 +43,13 @@


    @Resource


    private SystemConfigService systemConfigService;




    @Resource


    private RabbitmqManager rabbitmqManager;






    @Async("pushExecutor")


    @Override


    public void pushGoods(Long uid, Long auctionId, String title, String content, String versionCodes, SystemEnum system)


    public void pushGoods(Long uid, String auctionId, String title, String content, String versionCodes, SystemEnum system)


            throws PushException {




        String url = "https://item.taobao.com/item.htm?id=" + auctionId;


@@ -330,8 +326,6 @@




    /**


     * 保存推送内容只队列中


     *


     * @param json


     */


    @Transactional(rollbackFor = Exception.class)


    public void addPushIOSQueue(MessageInfo info, String url, int type, String versionCodes,SystemEnum system) throws PushException {


@@ -379,7 +373,7 @@


                    pushQueueRecordMapper.insert(pushQueueRecord);




                    // 加入队列


                    CMQManager.getInstance().addIOSPushMsg(pushQueueRecord);


                    rabbitmqManager.addIOSPushMsg(pushQueueRecord);




                    break;




@@ -396,7 +390,7 @@


                    // 存入数据库


                    pushQueueRecordMapper.insert(pushQueueRecord);


                    // 加入队列


                    CMQManager.getInstance().addIOSPushMsg(pushQueueRecord);


                    rabbitmqManager.addIOSPushMsg(pushQueueRecord);


                }




                i += totalCount;