添加了部分日志

freemud-pay-module/freemud-pay-push-message/src/main/java/com/freemud/pay/job/service/impl/AliFuWuChuangSingleMessageSender.java

@@ -5,17 +5,13 @@ import com.alipay.api.DefaultAlipayClient;
 import com.alipay.api.request.AlipayMobilePublicMessageSingleSendRequest;
 import com.alipay.api.response.AlipayMobilePublicMessageSingleSendResponse;
 import com.freemud.pay.job.config.AliPayConfig;
-import com.freemud.pay.job.dao.dbModel.ActiveDM;
 import com.freemud.pay.job.dao.dbModel.PayPlatformAccountDM;
-import com.freemud.pay.job.dao.dbModel.StoreDM;
 import com.freemud.pay.job.entity.PayMessage;
 import com.freemud.pay.job.service.*;
 import com.freemud.pay.job.service.util.InterrprentUtil;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
 import org.springframework.beans.factory.annotation.Autowired;
-import org.springframework.stereotype.Service;
-
-import java.io.*;
-import java.text.SimpleDateFormat;
 
 /**
  * All rights Reserved, Designed By www.freemud.cn
@@ -30,6 +26,8 @@ import java.text.SimpleDateFormat;
  */
 public class AliFuWuChuangSingleMessageSender implements IMessageProcessor {
 
+    protected final Logger logger = LoggerFactory.getLogger(getClass());
+
     @Autowired
     IPayPlatformAccountService IPayPlatformAccountService;
 
@@ -54,6 +52,7 @@ public class AliFuWuChuangSingleMessageSender implements IMessageProcessor {
         PayPlatformAccountDM payPlatformAccountDM = IPayPlatformAccountService.getPayPlatformAccount(payMessage.getPayMessage().getPartnerid());
         if (payPlatformAccountDM == null){
             payMessage.setNoRetry(true);
+            logger.info("平台信息为空");
             return false;
         }
         try {
@@ -71,7 +70,7 @@ public class AliFuWuChuangSingleMessageSender implements IMessageProcessor {
             }
             else if (response.getCode() == "12007") //未关注
             {
-                iPayMessageService.updateMessageStatus(3,payMessage.getPayMessage().getId());
+                iPayMessageService.updateMessageTryTimes(3,payMessage.getPayMessage().getId());
             }
             else
             {

freemud-pay-module/freemud-pay-push-message/src/main/java/com/freemud/pay/job/service/impl/PayMessageServiceImpl.java

@@ -10,13 +10,13 @@ import com.freemud.pay.job.service.IMessageProcessor;
 import com.freemud.pay.job.service.IPayMessageService;
 import com.freemud.pay.job.service.MessageProcessorFactory;
 import com.freemud.pay.job.service.IPayMessageActiveService;
-import groovy.util.logging.Slf4j;
 import org.apache.commons.lang.StringUtils;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.context.annotation.Primary;
 import org.springframework.stereotype.Service;
 
-import java.util.ArrayList;
 import java.util.HashMap;
 import java.util.List;
 import java.util.Map;
@@ -36,6 +36,8 @@ import java.util.Map;
 @Service("payMessageServiceImpl")
 public class PayMessageServiceImpl implements IPayMessageService {
 
+    protected final Logger logger = LoggerFactory.getLogger(getClass());
+
     @Autowired
     IPayMessageRepository iPayMessageRepository;
 
@@ -63,6 +65,7 @@ public class PayMessageServiceImpl implements IPayMessageService {
             if (message.getPayMessageActiveId()<0)
             {
                 markMessageAsNoProcess(message);
+                logger.info("活动ID不存在");
                 return;
             }
             PayMessageActiveDM active = iPayMessageActiveService.getPayMessageActiveDM(message.getPayMessageActiveId(),baseParam);
@@ -70,6 +73,7 @@ public class PayMessageServiceImpl implements IPayMessageService {
                     || StringUtils.isEmpty(active.getAction()))
             {
                 markMessageAsNoProcess(message);
+                logger.info("活动action不存在");
                 return;
             }
             boolean result = false;
@@ -85,19 +89,23 @@ public class PayMessageServiceImpl implements IPayMessageService {
                 result = (processor == null)
                         ? false
                         : processor.Process(payMessage);
+                logger.info("消息推送成功");
             }
             catch (Exception ex)
             {
                 //Logger.Warn(string.Format("failed process #{0},exception:{1}", message.Id, ex));
+                logger.error("消息推送失败");
             }
 
             if (result)
             {
                 markMessageAsSuccess(message);
+                logger.info("消息状态更新成功，状态为1");
             }
             else
             {
                 markMessageAsFailed(message);
+                logger.error("消息状态更新失败，状态码为-1");
             }
 
         }

freemud-pay-module/freemud-pay-push-message/src/main/java/com/freemud/pay/job/service/util/InterrprentUtil.java

@@ -5,6 +5,8 @@ import com.freemud.pay.job.dao.dbModel.StoreDM;
 import com.freemud.pay.job.entity.PayMessage;
 import com.freemud.pay.job.service.IActiveService;
 import com.freemud.pay.job.service.IStoreService;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
 import org.springframework.beans.factory.annotation.Autowired;
 
 import java.io.*;
@@ -23,6 +25,8 @@ import java.text.SimpleDateFormat;
  */
 public class InterrprentUtil {
 
+    protected final Logger logger = LoggerFactory.getLogger(getClass());
+
     @Autowired
     IStoreService iStoreService;
 
@@ -40,6 +44,7 @@ public class InterrprentUtil {
 
         String templateContent=readToFile("templates"+"\\"+context.getPayMessageActive().getTemplateid()+".txt");
 
+
         templateContent= templateContent.replace("#id#", context.getPayMessage().getId().toString())
                 .replace("#toUserId#", context.getPayMessage().getUserid())
                 .replace("#fmId#", context.getPayMessage().getFmid())
@@ -59,7 +64,7 @@ public class InterrprentUtil {
         if (context.getPayMessageActive().getCouponactiveid() > 0)
         {
             /**
-             * todo code 解密沒有
+             * 解密
              */
             EncryptionHelper encryptionHelper = new EncryptionHelper();
             String code = context.getPayMessage().getCode().isEmpty()?null:encryptionHelper.Decode(context.getPayMessage().getCode().trim());
@@ -72,6 +77,8 @@ public class InterrprentUtil {
             templateContent = templateContent.replace("#code#", code)
                     .replace("#validFrom#", dateformat2.format(couponInfo.getStartdate()))
                     .replace("#validEnd#", dateformat2.format(couponInfo.getEnddate()));
+        }else {
+            logger.info("活动券码号为空");
         }
 
         return templateContent;
@@ -88,8 +95,10 @@ public class InterrprentUtil {
             in.close();
         } catch (FileNotFoundException e) {
             e.printStackTrace();
+            logger.error("读取文件失败");
         } catch (IOException e) {
             e.printStackTrace();
+            logger.error("读取文件流失败");
         }
         try {
             return new String(filecontent, encoding);

freemud-pay-module/freemud-pay-push-message/src/main/resources/mapper/PayMessageDMMapper.xml

@@ -44,7 +44,6 @@
     FROM [Freemud_ThirdParty].[dbo].[Pay_Message] a WITH ( NOLOCK )
     INNER JOIN ${linkServer}zhuihu.dbo.Pay p WITH ( NOLOCK ) ON a.FMId = p.ZhuiHuOrderId
     INNER JOIN zhuihu.dbo.[Partner] part WITH(NOLOCK) ON part.ID=a.PartnerId
-
     ]]>
   </select>