Browse Source

消息推送

wanghui 8 years ago
parent
commit
7fa27c92ea

+ 8 - 0
src/main/java/com/goafanti/common/dao/MessageFromSystemMapper.java

@@ -112,6 +112,14 @@ public interface MessageFromSystemMapper {
 	 * @return
 	 */
 	List<MessageBo> selectSyncMessage(@Param("uid")String uid);
+	
+	
+	/**
+	 * 查询极光账号是否存在
+	 * @param uid
+	 * @return
+	 */
+	int checkJPushAcc(@Param("uid")String uid);
 
 	/**
 	 * 绑定第三方账�?

+ 4 - 0
src/main/java/com/goafanti/common/mapper/MessageFromSystemMapper.xml

@@ -487,6 +487,10 @@
 			and c.delete_sign = 0
    </select>
    
+   <select id="checkJPushAcc" parameterType="java.lang.String" resultType="java.lang.Integer">
+   		select count(0) from jpush_easemob_account where uid = #{uid,jdbcType=VARCHAR}
+   </select>
+   
    <update id="updateJpushEasemobAccount">
    		update jpush_easemob_account
    		<set>

+ 26 - 25
src/main/java/com/goafanti/message/service/impl/MessageServiceImpl.java

@@ -169,15 +169,14 @@ public class MessageServiceImpl  extends BaseMybatisDao<MessageFromSystemMapper>
 					mp.setMessageId(mfs.getId());
 					mp.setConsumerId(cid);
 					producerTarget.add(mp);
-					
-					bo = new MessageBo();
-					bo.setMessageId(mfs.getId());
-					bo.setMessageTitle(mfs.getTitle());
-					bo.setMessageBody(mfs.getBody());
-					bo.setResourceId(mfs.getResourceId());
-					bo.setResourceType(String.valueOf(mfs.getResourceType()));
-					bo.setRegistrationId(cid);
-					sendTarget.add(bo);
+					if(messageFromSystemMapper.checkJPushAcc(cid) >0){
+						bo = new MessageBo();
+						bo.setMessageId(mfs.getId());
+						bo.setMessageTitle(mfs.getTitle());
+						bo.setMessageBody(mfs.getBody());
+						bo.setRegistrationId(cid);
+						sendTarget.add(bo);
+					}
 				}
 			}
 			if(producerTarget.size()>0) insertBatchProducer(producerTarget);	
@@ -195,14 +194,14 @@ public class MessageServiceImpl  extends BaseMybatisDao<MessageFromSystemMapper>
 					mp.setConsumerId(cid);
 					producerTarget.add(mp);
 					
-					bo = new MessageBo();
-					bo.setMessageId(mfs.getId());
-					bo.setMessageTitle(mfs.getTitle());
-					bo.setMessageBody(mfs.getBody());
-					bo.setResourceId(mfs.getResourceId());
-					bo.setResourceType(String.valueOf(mfs.getResourceType()));
-					bo.setRegistrationId(cid);
-					sendTarget.add(bo);
+					if(messageFromSystemMapper.checkJPushAcc(cid) >0){
+						bo = new MessageBo();
+						bo.setMessageId(mfs.getId());
+						bo.setMessageTitle(mfs.getTitle());
+						bo.setMessageBody(mfs.getBody());
+						bo.setRegistrationId(cid);
+						sendTarget.add(bo);
+					}
 				}
 			}			
 			if(producerTarget.size()>0) insertBatchProducer(producerTarget);
@@ -260,14 +259,16 @@ public class MessageServiceImpl  extends BaseMybatisDao<MessageFromSystemMapper>
 							mp.setMessageId(messageId);
 							producerTarget.add(mp);
 							
-							bo = new MessageBo();
-							bo.setMessageId(messageId);
-							bo.setMessageTitle(message.getTitle());
-							bo.setMessageBody(message.getBody());
-							bo.setResourceId(message.getResourceId());
-							bo.setResourceType(String.valueOf(message.getResourceType()));
-							bo.setRegistrationId(cid);
-							sendTarget.add(bo);
+							if(messageFromSystemMapper.checkJPushAcc(cid) >0){
+								bo = new MessageBo();
+								bo.setMessageId(message.getId());
+								bo.setMessageTitle(message.getTitle());
+								bo.setMessageBody(message.getBody());
+								bo.setResourceId(message.getResourceId());
+								bo.setResourceType(String.valueOf(message.getResourceType()));
+								bo.setRegistrationId(cid);
+								sendTarget.add(bo);
+							}
 						}
 					}
 				}

+ 1 - 0
src/main/java/com/goafanti/order/service/impl/OrderServiceImpl.java

@@ -280,6 +280,7 @@ public class OrderServiceImpl extends BaseMybatisDao<TOrderMapper> implements Or
 		records.setTransactionMode(transactionMode.getCode());
 		records.setTransactionSubject(transactionSubject.getCode());
 		records.setTransactionChannel(payChannel.getCode());
+		records.setCreateTime(new Date());
 		tFundingRecordsMapper.insert(records);
 		return 1;
 	}