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 {


@@ -49,6 +42,9 @@




    @Resource


    private SystemConfigService systemConfigService;




    @Resource


    private RabbitmqManager rabbitmqManager;






    @Async("pushExecutor")


@@ -377,7 +373,7 @@


                    pushQueueRecordMapper.insert(pushQueueRecord);




                    // 加入队列


                    CMQManager.getInstance().addIOSPushMsg(pushQueueRecord);


                    rabbitmqManager.addIOSPushMsg(pushQueueRecord);




                    break;




@@ -394,7 +390,7 @@


                    // 存入数据库


                    pushQueueRecordMapper.insert(pushQueueRecord);


                    // 加入队列


                    CMQManager.getInstance().addIOSPushMsg(pushQueueRecord);


                    rabbitmqManager.addIOSPushMsg(pushQueueRecord);


                }




                i += totalCount;