添加PayPlatformAccount表

freemud-pay-module/freemud-pay-push-message/src/main/java/com/freemud/pay/job/dao/mapper/PayDMMapper.java

@@ -6,13 +6,17 @@ import com.freemud.pay.job.dao.dbModel.PayDM;
 public interface PayDMMapper extends IBaseDao<PayDM> {
     int deleteByPrimaryKey(Long id);
 
+    @Override
     int insert(PayDM record);
 
+    @Override
     int insertSelective(PayDM record);
 
     PayDM selectByPrimaryKey(Long id);
 
+    @Override
     int updateByPrimaryKeySelective(PayDM record);
 
+    @Override
     int updateByPrimaryKey(PayDM record);
 }
\ No newline at end of file

freemud-pay-module/freemud-pay-push-message/src/main/java/com/freemud/pay/job/dao/mapper/PayMessageActiveDMMapper.java

@@ -3,6 +3,7 @@ package com.freemud.pay.job.dao.mapper;
 import com.freemud.pay.job.dao.IBaseDao;
 import com.freemud.pay.job.dao.dbModel.PayMessageActiveDM;
 
+import java.util.List;
 import java.util.Map;
 
 public interface PayMessageActiveDMMapper extends IBaseDao<PayMessageActiveDM> {
@@ -20,4 +21,5 @@ public interface PayMessageActiveDMMapper extends IBaseDao<PayMessageActiveDM> {
     int updateByPrimaryKey(PayMessageActiveDM record);
 
     PayMessageActiveDM getPayMessageActiveDM(Map<String, Object> paramsMap);
+
 }
\ No newline at end of file

freemud-pay-module/freemud-pay-push-message/src/main/java/com/freemud/pay/job/dao/mapper/PayMessageDMMapper.java

@@ -23,5 +23,5 @@ public interface PayMessageDMMapper extends IBaseDao<PayMessageDM>{
 
     List<PayMessageDM> getPayMessages(Map<String, Object> paramsMap);
 
-    int updateMessageStatus(Long id);
+    int updateMessageStatus(Integer status,Long id);
 }
\ No newline at end of file

freemud-pay-module/freemud-pay-push-message/src/main/java/com/freemud/pay/job/dao/repository/IPayMessageRepository.java

@@ -18,5 +18,5 @@ import java.util.Map;
  */
 public interface IPayMessageRepository extends IBaseRepository{
      List<PayMessageDM> getPayMessages(Map<String, Object> paramsMap);
-     int updateMessageStatus(Long id);
+     int updateMessageStatus(Integer status,Long id);
 }

freemud-pay-module/freemud-pay-push-message/src/main/java/com/freemud/pay/job/dao/repository/Impl/PayMessageRepositoryImpl.java

@@ -40,7 +40,7 @@ public class PayMessageRepositoryImpl extends BaseRepositoryImpl implements IPay
     }
 
     @Override
-    public int updateMessageStatus(Long id) {
-        return payMessageMapper.updateMessageStatus(id);
+    public int updateMessageStatus(Integer status,Long id) {
+        return payMessageMapper.updateMessageStatus(status,id);
     }
 }
\ No newline at end of file

freemud-pay-module/freemud-pay-push-message/src/main/java/com/freemud/pay/job/dao/repository/Impl/PayPlatformAccountRepositoryImpl.java

+package com.freemud.pay.job.dao.repository.Impl;
+
+import com.freemud.pay.job.dao.IBaseDao;
+import com.freemud.pay.job.dao.dbModel.PayPlatformAccountDM;
+import com.freemud.pay.job.dao.mapper.PayPlatformAccountDMMapper;
+import com.freemud.pay.job.dao.repository.PayPlatformAccountRepository;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.context.annotation.Primary;
+import org.springframework.stereotype.Repository;
+
+/**
+ * All rights Reserved, Designed By www.freemud.cn
+ *
+ * @Title:
+ * @Package com.freemud.pay
+ * @Description:
+ * @author: lihui.wang
+ * @date:
+ * @Copyright: 2017 www.freemud.cn Inc. All rights reserved.
+ * 注意：本内容仅限于上海非码科技内部传阅，禁止外泄以及用于其他的商业目
+ */
+@Primary
+@Repository
+public class PayPlatformAccountRepositoryImpl extends BaseRepositoryImpl implements PayPlatformAccountRepository{
+
+    @Autowired
+    PayPlatformAccountDMMapper payPlatformAccountDMMapper;
+
+    @Override
+    protected IBaseDao getDao() {
+        return payPlatformAccountDMMapper;
+    }
+
+
+    @Override
+    public PayPlatformAccountDM selectByPartnerId(Integer partnerId) {
+        return payPlatformAccountDMMapper.selectByPartnerId(partnerId);
+    }
+}
\ No newline at end of file

freemud-pay-module/freemud-pay-push-message/src/main/java/com/freemud/pay/job/dao/repository/PayPlatformAccountRepository.java

+package com.freemud.pay.job.dao.repository;
+
+import com.freemud.pay.job.dao.dbModel.PayPlatformAccountDM;
+
+/**
+ * All rights Reserved, Designed By www.freemud.cn
+ *
+ * @Title:
+ * @Package com.freemud.pay
+ * @Description:
+ * @author: lihui.wang
+ * @date:
+ * @Copyright: 2017 www.freemud.cn Inc. All rights reserved.
+ * 注意：本内容仅限于上海非码科技内部传阅，禁止外泄以及用于其他的商业目
+ */
+
+public interface PayPlatformAccountRepository extends IBaseRepository{
+    PayPlatformAccountDM selectByPartnerId(Integer partnerId);
+}

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

@@ -18,4 +18,5 @@ import java.util.List;
  */
 public interface IPayMessageService {
     void pushMessage(BaseParam baseRequest);
+    int updateMessageStatus(Integer status,Long id);
 }

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

+package com.freemud.pay.job.service;
+
+import com.freemud.pay.job.dao.dbModel.PayMessageActiveDM;
+import com.freemud.pay.job.entity.BaseParam;
+
+/**
+ * All rights Reserved, Designed By www.freemud.cn
+ *
+ * @Title:
+ * @Package com.freemud.pay
+ * @Description:
+ * @author: lihui.wang
+ * @date:
+ * @Copyright: 2017 www.freemud.cn Inc. All rights reserved.
+ * 注意：本内容仅限于上海非码科技内部传阅，禁止外泄以及用于其他的商业目
+ */
+public interface PayMessageActiveService {
+    PayMessageActiveDM getPayMessageActiveDM(long activeId, BaseParam baseParam);
+}

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

+package com.freemud.pay.job.service;
+
+import com.freemud.pay.job.dao.dbModel.PayPlatformAccountDM;
+
+/**
+ * All rights Reserved, Designed By www.freemud.cn
+ *
+ * @Title:
+ * @Package com.freemud.pay
+ * @Description:
+ * @author: lihui.wang
+ * @date:
+ * @Copyright: 2017 www.freemud.cn Inc. All rights reserved.
+ * 注意：本内容仅限于上海非码科技内部传阅，禁止外泄以及用于其他的商业目
+ */
+public interface PayPlatformAccountService {
+    PayPlatformAccountDM getPayPlatformAccount(Integer partnerId);
+}

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

+package com.freemud.pay.job.service.impl;
+
+import com.freemud.pay.job.dao.dbModel.PayMessageActiveDM;
+import com.freemud.pay.job.dao.repository.IPayMessageActiveRepository;
+import com.freemud.pay.job.entity.BaseParam;
+import com.freemud.pay.job.service.PayMessageActiveService;
+import com.freemud.pay.job.service.PayPlatformAccountService;
+import org.springframework.beans.factory.annotation.Autowired;
+
+import java.util.HashMap;
+import java.util.Map;
+
+/**
+ * All rights Reserved, Designed By www.freemud.cn
+ *
+ * @Title:
+ * @Package com.freemud.pay
+ * @Description:
+ * @author: lihui.wang
+ * @date:
+ * @Copyright: 2017 www.freemud.cn Inc. All rights reserved.
+ * 注意：本内容仅限于上海非码科技内部传阅，禁止外泄以及用于其他的商业目
+ */
+public class PayMessageActiveServiceImpl implements PayMessageActiveService{
+
+    @Autowired
+    IPayMessageActiveRepository iPayMessageActiveRepository;
+
+    @Override
+    public PayMessageActiveDM getPayMessageActiveDM(long activeId, BaseParam baseParam){
+        Map<String, Object> paramsMap = new HashMap<String, Object>();
+        paramsMap.put("activeId",activeId);
+        paramsMap.put("dbPartition",baseParam.getDbPartition());
+        paramsMap.put("linkServer",baseParam.getLinkServer());
+        return iPayMessageActiveRepository.getPayMessageActiveDM(paramsMap);
+    }
+}
\ No newline at end of file

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

@@ -3,19 +3,17 @@ package com.freemud.pay.job.service.impl;
 
 import com.freemud.pay.job.dao.dbModel.PayMessageActiveDM;
 import com.freemud.pay.job.dao.dbModel.PayMessageDM;
-import com.freemud.pay.job.dao.repository.IPayMessageActiveRepository;
 import com.freemud.pay.job.dao.repository.IPayMessageRepository;
 import com.freemud.pay.job.entity.BaseParam;
 import com.freemud.pay.job.entity.PayMessage;
 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.PayMessageActiveService;
 import org.apache.commons.lang.StringUtils;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.stereotype.Service;
-import sun.security.krb5.internal.PAData;
 
-import java.util.ArrayList;
 import java.util.HashMap;
 import java.util.List;
 import java.util.Map;
@@ -38,7 +36,7 @@ public class PayMessageServiceImpl implements IPayMessageService {
     IPayMessageRepository iPayMessageRepository;
 
     @Autowired
-    IPayMessageActiveRepository iPayMessageActiveRepository;
+    PayMessageActiveService payMessageActiveService;
 
     @Override
     public void pushMessage(BaseParam baseParam) {
@@ -64,7 +62,7 @@ public class PayMessageServiceImpl implements IPayMessageService {
                     markMessageAsNoProcess(message);
                     return;
                 }
-                PayMessageActiveDM active = getPayMessageActiveDM(message.getPayMessageActiveId(),baseParam);
+                PayMessageActiveDM active = payMessageActiveService.getPayMessageActiveDM(message.getPayMessageActiveId(),baseParam);
                 if (active == null
                         || StringUtils.isEmpty(active.getAction()))
                 {
@@ -92,28 +90,34 @@ public class PayMessageServiceImpl implements IPayMessageService {
 
                 if (result)
                 {
-                    markMessageAsSuccess(message, bussinessType, dbPartition);
+                    markMessageAsSuccess(message);
                 }
                 else
                 {
-                    markMessageAsFailed(message, bussinessType, dbPartition);
+                    markMessageAsFailed(message);
                 }
 
-
             }
 
         }
     }
 
-    private void markMessageAsSuccess(PayMessageDM message, String linkServer, String dbPartition) {
+    @Override
+    public int updateMessageStatus(Integer status, Long id) {
+        return iPayMessageRepository.updateMessageStatus(status,id);
     }
 
-    private void markMessageAsFailed(PayMessageDM message, String linkServer, String dbPartition) {
+    private void markMessageAsSuccess(PayMessageDM message) {
+        updateMessageStatus(1,message.getId());
+    }
 
+    private void markMessageAsFailed(PayMessageDM message) {
+        updateMessageStatus(-1,message.getId());
     }
 
+
     private void markMessageAsNoProcess(PayMessageDM message) {
-        iPayMessageRepository.updateMessageStatus(message.getId());
+        updateMessageStatus(-1,message.getId());
     }
 
 
@@ -124,12 +128,5 @@ public class PayMessageServiceImpl implements IPayMessageService {
         return iPayMessageRepository.getPayMessages(paramsMap);
     }
 
-    private PayMessageActiveDM getPayMessageActiveDM(long activeId,BaseParam baseParam){
-        Map<String, Object> paramsMap = new HashMap<String, Object>();
-        paramsMap.put("activeId",activeId);
-        paramsMap.put("dbPartition",baseParam.getDbPartition());
-        paramsMap.put("linkServer",baseParam.getLinkServer());
-        return iPayMessageActiveRepository.getPayMessageActiveDM(paramsMap);
 
-    }
 }
\ No newline at end of file

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

+package com.freemud.pay.job.service.impl;
+
+import com.freemud.pay.job.dao.dbModel.PayMessageActiveDM;
+import com.freemud.pay.job.dao.dbModel.PayPlatformAccountDM;
+import com.freemud.pay.job.dao.repository.PayPlatformAccountRepository;
+import com.freemud.pay.job.entity.BaseParam;
+import com.freemud.pay.job.service.PayPlatformAccountService;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.stereotype.Service;
+
+import java.util.HashMap;
+import java.util.Map;
+
+/**
+ * All rights Reserved, Designed By www.freemud.cn
+ *
+ * @Title:
+ * @Package com.freemud.pay
+ * @Description:
+ * @author: lihui.wang
+ * @date:
+ * @Copyright: 2017 www.freemud.cn Inc. All rights reserved.
+ * 注意：本内容仅限于上海非码科技内部传阅，禁止外泄以及用于其他的商业目
+ */
+@Service
+public class PayPlatformAccountServiceImpl implements PayPlatformAccountService {
+
+    @Autowired
+    PayPlatformAccountRepository payPlatformAccountRepository;
+
+
+    @Override
+    public PayPlatformAccountDM getPayPlatformAccount(Integer partnerId) {
+        return payPlatformAccountRepository.selectByPartnerId(partnerId);
+    }
+}
\ No newline at end of file