读表 更新状态

freemud-pay-module/freemud-pay-push-message/src/main/java/com/freemud/pay/job/dao/dbModel/PartnerDM.java

+package com.freemud.pay.job.dao.dbModel;
+
+import java.io.Serializable;
+
+public class PartnerDM extends BaseModel implements Serializable {
+    private Integer id;
+
+    private String partnername;
+
+    private String ouraccountPartner;
+
+    private String logo;
+
+    private String description;
+
+    private String partnercode;
+
+    private String appsecret;
+
+    private String ebcode;
+
+    private Boolean enablesms;
+
+    private String partnertype;
+
+    private String unifyid;
+
+    private static final long serialVersionUID = 1L;
+
+    public Integer getId() {
+        return id;
+    }
+
+    public void setId(Integer id) {
+        this.id = id;
+    }
+
+    public String getPartnername() {
+        return partnername;
+    }
+
+    public void setPartnername(String partnername) {
+        this.partnername = partnername == null ? null : partnername.trim();
+    }
+
+    public String getOuraccountPartner() {
+        return ouraccountPartner;
+    }
+
+    public void setOuraccountPartner(String ouraccountPartner) {
+        this.ouraccountPartner = ouraccountPartner == null ? null : ouraccountPartner.trim();
+    }
+
+    public String getLogo() {
+        return logo;
+    }
+
+    public void setLogo(String logo) {
+        this.logo = logo == null ? null : logo.trim();
+    }
+
+    public String getDescription() {
+        return description;
+    }
+
+    public void setDescription(String description) {
+        this.description = description == null ? null : description.trim();
+    }
+
+    public String getPartnercode() {
+        return partnercode;
+    }
+
+    public void setPartnercode(String partnercode) {
+        this.partnercode = partnercode == null ? null : partnercode.trim();
+    }
+
+    public String getAppsecret() {
+        return appsecret;
+    }
+
+    public void setAppsecret(String appsecret) {
+        this.appsecret = appsecret == null ? null : appsecret.trim();
+    }
+
+    public String getEbcode() {
+        return ebcode;
+    }
+
+    public void setEbcode(String ebcode) {
+        this.ebcode = ebcode == null ? null : ebcode.trim();
+    }
+
+    public Boolean getEnablesms() {
+        return enablesms;
+    }
+
+    public void setEnablesms(Boolean enablesms) {
+        this.enablesms = enablesms;
+    }
+
+    public String getPartnertype() {
+        return partnertype;
+    }
+
+    public void setPartnertype(String partnertype) {
+        this.partnertype = partnertype == null ? null : partnertype.trim();
+    }
+
+    public String getUnifyid() {
+        return unifyid;
+    }
+
+    public void setUnifyid(String unifyid) {
+        this.unifyid = unifyid == null ? null : unifyid.trim();
+    }
+
+    @Override
+    public String toString() {
+        StringBuilder sb = new StringBuilder();
+        sb.append(getClass().getSimpleName());
+        sb.append(" [");
+        sb.append("Hash = ").append(hashCode());
+        sb.append(", id=").append(id);
+        sb.append(", partnername=").append(partnername);
+        sb.append(", ouraccountPartner=").append(ouraccountPartner);
+        sb.append(", logo=").append(logo);
+        sb.append(", description=").append(description);
+        sb.append(", partnercode=").append(partnercode);
+        sb.append(", appsecret=").append(appsecret);
+        sb.append(", ebcode=").append(ebcode);
+        sb.append(", enablesms=").append(enablesms);
+        sb.append(", partnertype=").append(partnertype);
+        sb.append(", unifyid=").append(unifyid);
+        sb.append("]");
+        return sb.toString();
+    }
+}
\ No newline at end of file

freemud-pay-module/freemud-pay-push-message/src/main/java/com/freemud/pay/job/dao/dbModel/PayMessageActiveDM.java

+package com.freemud.pay.job.dao.dbModel;
+
+import java.io.Serializable;
+import java.math.BigDecimal;
+import java.util.Date;
+
+public class PayMessageActiveDM extends BaseModel implements Serializable {
+    private Long id;
+
+    private Integer partnerid;
+
+    private Integer couponactiveid;
+
+    private String name;
+
+    private String description;
+
+    private Integer platformaccountid;
+
+    private String templateid;
+
+    private Integer status;
+
+    private Date starttime;
+
+    private Date endtime;
+
+    private Integer scope;
+
+    private Integer area;
+
+    private BigDecimal amountlimit;
+
+    private String platform;
+
+    private String action;
+
+    private Integer priority;
+
+    private Date createdate;
+
+    private String createuser;
+
+    private Date lasteditdate;
+
+    private String lastedituser;
+
+    private Integer intervallimit;
+
+    private Integer dateintervallimit;
+
+    private BigDecimal maxamountlimit;
+
+    private BigDecimal delaytimelimit;
+
+    private Long secondactiveid;
+
+    private String wxmsgactiveid;
+
+    private static final long serialVersionUID = 1L;
+
+    public Long getId() {
+        return id;
+    }
+
+    public void setId(Long id) {
+        this.id = id;
+    }
+
+    public Integer getPartnerid() {
+        return partnerid;
+    }
+
+    public void setPartnerid(Integer partnerid) {
+        this.partnerid = partnerid;
+    }
+
+    public Integer getCouponactiveid() {
+        return couponactiveid;
+    }
+
+    public void setCouponactiveid(Integer couponactiveid) {
+        this.couponactiveid = couponactiveid;
+    }
+
+    public String getName() {
+        return name;
+    }
+
+    public void setName(String name) {
+        this.name = name == null ? null : name.trim();
+    }
+
+    public String getDescription() {
+        return description;
+    }
+
+    public void setDescription(String description) {
+        this.description = description == null ? null : description.trim();
+    }
+
+    public Integer getPlatformaccountid() {
+        return platformaccountid;
+    }
+
+    public void setPlatformaccountid(Integer platformaccountid) {
+        this.platformaccountid = platformaccountid;
+    }
+
+    public String getTemplateid() {
+        return templateid;
+    }
+
+    public void setTemplateid(String templateid) {
+        this.templateid = templateid == null ? null : templateid.trim();
+    }
+
+    public Integer getStatus() {
+        return status;
+    }
+
+    public void setStatus(Integer status) {
+        this.status = status;
+    }
+
+    public Date getStarttime() {
+        return starttime;
+    }
+
+    public void setStarttime(Date starttime) {
+        this.starttime = starttime;
+    }
+
+    public Date getEndtime() {
+        return endtime;
+    }
+
+    public void setEndtime(Date endtime) {
+        this.endtime = endtime;
+    }
+
+    public Integer getScope() {
+        return scope;
+    }
+
+    public void setScope(Integer scope) {
+        this.scope = scope;
+    }
+
+    public Integer getArea() {
+        return area;
+    }
+
+    public void setArea(Integer area) {
+        this.area = area;
+    }
+
+    public BigDecimal getAmountlimit() {
+        return amountlimit;
+    }
+
+    public void setAmountlimit(BigDecimal amountlimit) {
+        this.amountlimit = amountlimit;
+    }
+
+    public String getPlatform() {
+        return platform;
+    }
+
+    public void setPlatform(String platform) {
+        this.platform = platform == null ? null : platform.trim();
+    }
+
+    public String getAction() {
+        return action;
+    }
+
+    public void setAction(String action) {
+        this.action = action == null ? null : action.trim();
+    }
+
+    public Integer getPriority() {
+        return priority;
+    }
+
+    public void setPriority(Integer priority) {
+        this.priority = priority;
+    }
+
+    public Date getCreatedate() {
+        return createdate;
+    }
+
+    public void setCreatedate(Date createdate) {
+        this.createdate = createdate;
+    }
+
+    public String getCreateuser() {
+        return createuser;
+    }
+
+    public void setCreateuser(String createuser) {
+        this.createuser = createuser == null ? null : createuser.trim();
+    }
+
+    public Date getLasteditdate() {
+        return lasteditdate;
+    }
+
+    public void setLasteditdate(Date lasteditdate) {
+        this.lasteditdate = lasteditdate;
+    }
+
+    public String getLastedituser() {
+        return lastedituser;
+    }
+
+    public void setLastedituser(String lastedituser) {
+        this.lastedituser = lastedituser == null ? null : lastedituser.trim();
+    }
+
+    public Integer getIntervallimit() {
+        return intervallimit;
+    }
+
+    public void setIntervallimit(Integer intervallimit) {
+        this.intervallimit = intervallimit;
+    }
+
+    public Integer getDateintervallimit() {
+        return dateintervallimit;
+    }
+
+    public void setDateintervallimit(Integer dateintervallimit) {
+        this.dateintervallimit = dateintervallimit;
+    }
+
+    public BigDecimal getMaxamountlimit() {
+        return maxamountlimit;
+    }
+
+    public void setMaxamountlimit(BigDecimal maxamountlimit) {
+        this.maxamountlimit = maxamountlimit;
+    }
+
+    public BigDecimal getDelaytimelimit() {
+        return delaytimelimit;
+    }
+
+    public void setDelaytimelimit(BigDecimal delaytimelimit) {
+        this.delaytimelimit = delaytimelimit;
+    }
+
+    public Long getSecondactiveid() {
+        return secondactiveid;
+    }
+
+    public void setSecondactiveid(Long secondactiveid) {
+        this.secondactiveid = secondactiveid;
+    }
+
+    public String getWxmsgactiveid() {
+        return wxmsgactiveid;
+    }
+
+    public void setWxmsgactiveid(String wxmsgactiveid) {
+        this.wxmsgactiveid = wxmsgactiveid == null ? null : wxmsgactiveid.trim();
+    }
+
+    @Override
+    public String toString() {
+        StringBuilder sb = new StringBuilder();
+        sb.append(getClass().getSimpleName());
+        sb.append(" [");
+        sb.append("Hash = ").append(hashCode());
+        sb.append(", id=").append(id);
+        sb.append(", partnerid=").append(partnerid);
+        sb.append(", couponactiveid=").append(couponactiveid);
+        sb.append(", name=").append(name);
+        sb.append(", description=").append(description);
+        sb.append(", platformaccountid=").append(platformaccountid);
+        sb.append(", templateid=").append(templateid);
+        sb.append(", status=").append(status);
+        sb.append(", starttime=").append(starttime);
+        sb.append(", endtime=").append(endtime);
+        sb.append(", scope=").append(scope);
+        sb.append(", area=").append(area);
+        sb.append(", amountlimit=").append(amountlimit);
+        sb.append(", platform=").append(platform);
+        sb.append(", action=").append(action);
+        sb.append(", priority=").append(priority);
+        sb.append(", createdate=").append(createdate);
+        sb.append(", createuser=").append(createuser);
+        sb.append(", lasteditdate=").append(lasteditdate);
+        sb.append(", lastedituser=").append(lastedituser);
+        sb.append(", intervallimit=").append(intervallimit);
+        sb.append(", dateintervallimit=").append(dateintervallimit);
+        sb.append(", maxamountlimit=").append(maxamountlimit);
+        sb.append(", delaytimelimit=").append(delaytimelimit);
+        sb.append(", secondactiveid=").append(secondactiveid);
+        sb.append(", wxmsgactiveid=").append(wxmsgactiveid);
+        sb.append("]");
+        return sb.toString();
+    }
+}
\ No newline at end of file

freemud-pay-module/freemud-pay-push-message/src/main/java/com/freemud/pay/job/dao/dbModel/PayMessageDM.java

+package com.freemud.pay.job.dao.dbModel;
+
+import java.io.Serializable;
+import java.util.Date;
+
+public class PayMessageDM extends BaseModel implements Serializable {
+    private Long id;
+
+    private Integer partnerid;
+
+    private String fmid;
+
+    private String templateid;
+
+    private String userid;
+
+    private Integer status;
+
+    private Integer trytimes;
+
+    private Date createdate;
+
+    private Date lasteditdate;
+
+    private String code;
+
+    private Long payMessageActiveId;
+
+    private static final long serialVersionUID = 1L;
+
+    public Long getId() {
+        return id;
+    }
+
+    public void setId(Long id) {
+        this.id = id;
+    }
+
+    public Integer getPartnerid() {
+        return partnerid;
+    }
+
+    public void setPartnerid(Integer partnerid) {
+        this.partnerid = partnerid;
+    }
+
+    public String getFmid() {
+        return fmid;
+    }
+
+    public void setFmid(String fmid) {
+        this.fmid = fmid == null ? null : fmid.trim();
+    }
+
+    public String getTemplateid() {
+        return templateid;
+    }
+
+    public void setTemplateid(String templateid) {
+        this.templateid = templateid == null ? null : templateid.trim();
+    }
+
+    public String getUserid() {
+        return userid;
+    }
+
+    public void setUserid(String userid) {
+        this.userid = userid == null ? null : userid.trim();
+    }
+
+    public Integer getStatus() {
+        return status;
+    }
+
+    public void setStatus(Integer status) {
+        this.status = status;
+    }
+
+    public Integer getTrytimes() {
+        return trytimes;
+    }
+
+    public void setTrytimes(Integer trytimes) {
+        this.trytimes = trytimes;
+    }
+
+    public Date getCreatedate() {
+        return createdate;
+    }
+
+    public void setCreatedate(Date createdate) {
+        this.createdate = createdate;
+    }
+
+    public Date getLasteditdate() {
+        return lasteditdate;
+    }
+
+    public void setLasteditdate(Date lasteditdate) {
+        this.lasteditdate = lasteditdate;
+    }
+
+    public String getCode() {
+        return code;
+    }
+
+    public void setCode(String code) {
+        this.code = code == null ? null : code.trim();
+    }
+
+    public Long getPayMessageActiveId() {
+        return payMessageActiveId;
+    }
+
+    public void setPayMessageActiveId(Long payMessageActiveId) {
+        this.payMessageActiveId = payMessageActiveId;
+    }
+
+    @Override
+    public String toString() {
+        StringBuilder sb = new StringBuilder();
+        sb.append(getClass().getSimpleName());
+        sb.append(" [");
+        sb.append("Hash = ").append(hashCode());
+        sb.append(", id=").append(id);
+        sb.append(", partnerid=").append(partnerid);
+        sb.append(", fmid=").append(fmid);
+        sb.append(", templateid=").append(templateid);
+        sb.append(", userid=").append(userid);
+        sb.append(", status=").append(status);
+        sb.append(", trytimes=").append(trytimes);
+        sb.append(", createdate=").append(createdate);
+        sb.append(", lasteditdate=").append(lasteditdate);
+        sb.append(", code=").append(code);
+        sb.append(", payMessageActiveId=").append(payMessageActiveId);
+        sb.append("]");
+        return sb.toString();
+    }
+}
\ No newline at end of file

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

+package com.freemud.pay.job.dao.mapper;
+
+import com.freemud.pay.job.dao.IBaseDao;
+import com.freemud.pay.job.dao.dbModel.PartnerDM;
+
+public interface PartnerDMMapper extends IBaseDao<PartnerDM>{
+    int deleteByPrimaryKey(Integer id);
+
+    int insert(PartnerDM record);
+
+    int insertSelective(PartnerDM record);
+
+    PartnerDM selectByPrimaryKey(Integer id);
+
+    int updateByPrimaryKeySelective(PartnerDM record);
+
+    int updateByPrimaryKey(PartnerDM record);
+}
\ No newline at end of file

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

+package com.freemud.pay.job.dao.mapper;
+
+import com.freemud.pay.job.dao.IBaseDao;
+import com.freemud.pay.job.dao.dbModel.PayDM;
+
+public interface PayDMMapper extends IBaseDao<PayDM> {
+    int deleteByPrimaryKey(Long id);
+
+    int insert(PayDM record);
+
+    int insertSelective(PayDM record);
+
+    PayDM selectByPrimaryKey(Long id);
+
+    int updateByPrimaryKeySelective(PayDM record);
+
+    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

+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.Map;
+
+public interface PayMessageActiveDMMapper extends IBaseDao<PayMessageActiveDM> {
+    int deleteByPrimaryKey(Long id);
+    @Override
+    int insert(PayMessageActiveDM record);
+    @Override
+    int insertSelective(PayMessageActiveDM record);
+
+    PayMessageActiveDM selectByPrimaryKey(Long id);
+    @Override
+    int updateByPrimaryKeySelective(PayMessageActiveDM record);
+
+    @Override
+    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

+package com.freemud.pay.job.dao.mapper;
+
+import com.freemud.pay.job.dao.IBaseDao;
+import com.freemud.pay.job.dao.dbModel.PayMessageDM;
+
+import java.util.List;
+import java.util.Map;
+
+public interface PayMessageDMMapper extends IBaseDao<PayMessageDM>{
+    int deleteByPrimaryKey(Long id);
+
+    @Override
+    int insert(PayMessageDM record);
+
+    @Override
+    int insertSelective(PayMessageDM record);
+
+    PayMessageDM selectByPrimaryKey(Long id);
+    @Override
+    int updateByPrimaryKeySelective(PayMessageDM record);
+    @Override
+    int updateByPrimaryKey(PayMessageDM record);
+
+    List<PayMessageDM> getPayMessages(Map<String, Object> paramsMap);
+
+    int updateMessageStatus(Long id);
+}
\ No newline at end of file

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

@@ -2,6 +2,8 @@ package com.freemud.pay.job.dao.repository;
 
 import com.freemud.pay.job.dao.dbModel.PayMessageActiveDM;
 
+import java.util.Map;
+
 /**
  * All rights Reserved, Designed By www.freemud.cn
  *
@@ -14,5 +16,5 @@ import com.freemud.pay.job.dao.dbModel.PayMessageActiveDM;
  * 注意：本内容仅限于上海非码科技内部传阅，禁止外泄以及用于其他的商业目
  */
 public interface IPayMessageActiveRepository extends IBaseRepository{
-     PayMessageActiveDM getPayMessageActiveDM(long activeId, String dbPartition, String linkServer);
+     PayMessageActiveDM getPayMessageActiveDM(Map<String, Object> paramsMap);
 }

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

@@ -3,6 +3,7 @@ package com.freemud.pay.job.dao.repository;
 import com.freemud.pay.job.dao.dbModel.PayMessageDM;
 
 import java.util.List;
+import java.util.Map;
 
 /**
  * All rights Reserved, Designed By www.freemud.cn
@@ -16,5 +17,6 @@ import java.util.List;
  * 注意：本内容仅限于上海非码科技内部传阅，禁止外泄以及用于其他的商业目
  */
 public interface IPayMessageRepository extends IBaseRepository{
-     List<PayMessageDM> getPayMessages(String dbPartition, String linkServer);
+     List<PayMessageDM> getPayMessages(Map<String, Object> paramsMap);
+     int updateMessageStatus(Long id);
 }

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

@@ -8,6 +8,9 @@ import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.context.annotation.Primary;
 import org.springframework.stereotype.Repository;
 
+import java.util.HashMap;
+import java.util.Map;
+
 /**
  * All rights Reserved, Designed By www.freemud.cn
  *
@@ -26,14 +29,15 @@ public class PayMessageActiveRepositoryImpl extends BaseRepositoryImpl implement
     @Autowired
     PayMessageActiveDMMapper payMessageActiveMapper;
 
+
     @Override
     protected IBaseDao getDao() {
         return null;
     }
 
     @Override
-    public PayMessageActiveDM getPayMessageActiveDM(long activeId, String dbPartition, String linkServer) {
-        return null;
+    public PayMessageActiveDM getPayMessageActiveDM(Map<String, Object> paramsMap) {
+        return payMessageActiveMapper.getPayMessageActiveDM(paramsMap);
     }
 
 

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

@@ -9,6 +9,7 @@ import org.springframework.context.annotation.Primary;
 import org.springframework.stereotype.Repository;
 
 import java.util.List;
+import java.util.Map;
 
 /**
  * All rights Reserved, Designed By www.freemud.cn
@@ -33,10 +34,13 @@ public class PayMessageRepositoryImpl extends BaseRepositoryImpl implements IPay
         return payMessageMapper;
     }
 
-
     @Override
-    public List<PayMessageDM> getPayMessages(String dbPartition, String linkServer) {
-        return payMessageMapper.getPayMessages(dbPartition,linkServer);
+    public List<PayMessageDM> getPayMessages(Map<String, Object> paramsMap) {
+        return payMessageMapper.getPayMessages(paramsMap);
     }
 
+    @Override
+    public int updateMessageStatus(Long id) {
+        return payMessageMapper.updateMessageStatus(id);
+    }
 }
\ No newline at end of file

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

@@ -13,9 +13,12 @@ import com.freemud.pay.job.service.MessageProcessorFactory;
 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;
 
 /**
  * All rights Reserved, Designed By www.freemud.cn
@@ -48,23 +51,24 @@ public class PayMessageServiceImpl implements IPayMessageService {
             if (linkServer.substring(linkServer.length()-1).equals(".")){
                 linkServer = linkServer + ".";
             }
+            baseParam.setLinkServer(linkServer);
              String dbPartition= baseParam.getDbPartition();
 
             //第一步：获取数据
-            List<PayMessageDM> payMessages=getPayMessages(baseParam.getDbPartition(),linkServer);
+            List<PayMessageDM> payMessages=getPayMessages(baseParam);
 
             for (PayMessageDM message :payMessages){
 
                 if (message.getPayMessageActiveId()<0)
                 {
-                    MarkMessageAsNoProcess(message,bussinessType,dbPartition);
+                    markMessageAsNoProcess(message);
                     return;
                 }
-                PayMessageActiveDM active = iPayMessageActiveRepository.getPayMessageActiveDM(message.getPayMessageActiveId(), bussinessType, dbPartition);
+                PayMessageActiveDM active = getPayMessageActiveDM(message.getPayMessageActiveId(),baseParam);
                 if (active == null
                         || StringUtils.isEmpty(active.getAction()))
                 {
-                    MarkMessageAsNoProcess(message, bussinessType, dbPartition);
+                    markMessageAsNoProcess(message);
                     return;
                 }
                 boolean result = false;
@@ -88,11 +92,11 @@ public class PayMessageServiceImpl implements IPayMessageService {
 
                 if (result)
                 {
-                    MarkMessageAsSuccess(message, bussinessType, dbPartition);
+                    markMessageAsSuccess(message, bussinessType, dbPartition);
                 }
                 else
                 {
-                    MarkMessageAsFailed(message, bussinessType, dbPartition);
+                    markMessageAsFailed(message, bussinessType, dbPartition);
                 }
 
 
@@ -101,20 +105,31 @@ public class PayMessageServiceImpl implements IPayMessageService {
         }
     }
 
-    private void MarkMessageAsSuccess(PayMessageDM message, String bussinessType, String dbPartition) {
+    private void markMessageAsSuccess(PayMessageDM message, String linkServer, String dbPartition) {
     }
 
-    private void MarkMessageAsFailed(PayMessageDM message, String bussinessType, String dbPartition) {
+    private void markMessageAsFailed(PayMessageDM message, String linkServer, String dbPartition) {
 
     }
 
-    private void MarkMessageAsNoProcess(PayMessageDM message, String bussinessType, String dbPartition) {
+    private void markMessageAsNoProcess(PayMessageDM message) {
+        iPayMessageRepository.updateMessageStatus(message.getId());
+    }
 
 
+    private List<PayMessageDM> getPayMessages(BaseParam baseParam){
+        //db linkserver
+        Map<String, Object> paramsMap = new HashMap<String, Object>();
+        paramsMap.put("linkServer",baseParam.getLinkServer());
+        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);
 
-    private List<PayMessageDM> getPayMessages(String dbPartner, String linkServer){
-        return new ArrayList<PayMessageDM>();
     }
 }
\ No newline at end of file

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

+<?xml version="1.0" encoding="UTF-8"?>
+<!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" "http://mybatis.org/dtd/mybatis-3-mapper.dtd">
+<mapper namespace="com.freemud.pay.job.dao.mapper.PartnerDMMapper">
+  <resultMap id="BaseResultMap" type="com.freemud.pay.job.dao.dbModel.PartnerDM">
+    <id column="ID" jdbcType="INTEGER" property="id" />
+    <result column="PartnerName" jdbcType="VARCHAR" property="partnername" />
+    <result column="OurAccount_Partner" jdbcType="VARCHAR" property="ouraccountPartner" />
+    <result column="Logo" jdbcType="VARCHAR" property="logo" />
+    <result column="Description" jdbcType="VARCHAR" property="description" />
+    <result column="PartnerCode" jdbcType="VARCHAR" property="partnercode" />
+    <result column="AppSecret" jdbcType="VARCHAR" property="appsecret" />
+    <result column="EBCode" jdbcType="VARCHAR" property="ebcode" />
+    <result column="EnableSMS" jdbcType="BIT" property="enablesms" />
+    <result column="PartnerType" jdbcType="VARCHAR" property="partnertype" />
+    <result column="UnifyId" jdbcType="VARCHAR" property="unifyid" />
+  </resultMap>
+  <sql id="Base_Column_List">
+    ID, PartnerName, OurAccount_Partner, Logo, Description, PartnerCode, AppSecret, EBCode, 
+    EnableSMS, PartnerType, UnifyId
+  </sql>
+  <select id="selectByPrimaryKey" parameterType="java.lang.Integer" resultMap="BaseResultMap">
+    select 
+    <include refid="Base_Column_List" />
+    from Partner
+    where ID = #{id,jdbcType=INTEGER}
+  </select>
+  <delete id="deleteByPrimaryKey" parameterType="java.lang.Integer">
+    delete from Partner
+    where ID = #{id,jdbcType=INTEGER}
+  </delete>
+  <insert id="insert" parameterType="com.freemud.pay.job.dao.dbModel.PartnerDM">
+    insert into Partner (ID, PartnerName, OurAccount_Partner, 
+      Logo, Description, PartnerCode, 
+      AppSecret, EBCode, EnableSMS, 
+      PartnerType, UnifyId)
+    values (#{id,jdbcType=INTEGER}, #{partnername,jdbcType=VARCHAR}, #{ouraccountPartner,jdbcType=VARCHAR}, 
+      #{logo,jdbcType=VARCHAR}, #{description,jdbcType=VARCHAR}, #{partnercode,jdbcType=VARCHAR}, 
+      #{appsecret,jdbcType=VARCHAR}, #{ebcode,jdbcType=VARCHAR}, #{enablesms,jdbcType=BIT}, 
+      #{partnertype,jdbcType=VARCHAR}, #{unifyid,jdbcType=VARCHAR})
+  </insert>
+  <insert id="insertSelective" parameterType="com.freemud.pay.job.dao.dbModel.PartnerDM">
+    insert into Partner
+    <trim prefix="(" suffix=")" suffixOverrides=",">
+      <if test="id != null">
+        ID,
+      </if>
+      <if test="partnername != null">
+        PartnerName,
+      </if>
+      <if test="ouraccountPartner != null">
+        OurAccount_Partner,
+      </if>
+      <if test="logo != null">
+        Logo,
+      </if>
+      <if test="description != null">
+        Description,
+      </if>
+      <if test="partnercode != null">
+        PartnerCode,
+      </if>
+      <if test="appsecret != null">
+        AppSecret,
+      </if>
+      <if test="ebcode != null">
+        EBCode,
+      </if>
+      <if test="enablesms != null">
+        EnableSMS,
+      </if>
+      <if test="partnertype != null">
+        PartnerType,
+      </if>
+      <if test="unifyid != null">
+        UnifyId,
+      </if>
+    </trim>
+    <trim prefix="values (" suffix=")" suffixOverrides=",">
+      <if test="id != null">
+        #{id,jdbcType=INTEGER},
+      </if>
+      <if test="partnername != null">
+        #{partnername,jdbcType=VARCHAR},
+      </if>
+      <if test="ouraccountPartner != null">
+        #{ouraccountPartner,jdbcType=VARCHAR},
+      </if>
+      <if test="logo != null">
+        #{logo,jdbcType=VARCHAR},
+      </if>
+      <if test="description != null">
+        #{description,jdbcType=VARCHAR},
+      </if>
+      <if test="partnercode != null">
+        #{partnercode,jdbcType=VARCHAR},
+      </if>
+      <if test="appsecret != null">
+        #{appsecret,jdbcType=VARCHAR},
+      </if>
+      <if test="ebcode != null">
+        #{ebcode,jdbcType=VARCHAR},
+      </if>
+      <if test="enablesms != null">
+        #{enablesms,jdbcType=BIT},
+      </if>
+      <if test="partnertype != null">
+        #{partnertype,jdbcType=VARCHAR},
+      </if>
+      <if test="unifyid != null">
+        #{unifyid,jdbcType=VARCHAR},
+      </if>
+    </trim>
+  </insert>
+  <update id="updateByPrimaryKeySelective" parameterType="com.freemud.pay.job.dao.dbModel.PartnerDM">
+    update Partner
+    <set>
+      <if test="partnername != null">
+        PartnerName = #{partnername,jdbcType=VARCHAR},
+      </if>
+      <if test="ouraccountPartner != null">
+        OurAccount_Partner = #{ouraccountPartner,jdbcType=VARCHAR},
+      </if>
+      <if test="logo != null">
+        Logo = #{logo,jdbcType=VARCHAR},
+      </if>
+      <if test="description != null">
+        Description = #{description,jdbcType=VARCHAR},
+      </if>
+      <if test="partnercode != null">
+        PartnerCode = #{partnercode,jdbcType=VARCHAR},
+      </if>
+      <if test="appsecret != null">
+        AppSecret = #{appsecret,jdbcType=VARCHAR},
+      </if>
+      <if test="ebcode != null">
+        EBCode = #{ebcode,jdbcType=VARCHAR},
+      </if>
+      <if test="enablesms != null">
+        EnableSMS = #{enablesms,jdbcType=BIT},
+      </if>
+      <if test="partnertype != null">
+        PartnerType = #{partnertype,jdbcType=VARCHAR},
+      </if>
+      <if test="unifyid != null">
+        UnifyId = #{unifyid,jdbcType=VARCHAR},
+      </if>
+    </set>
+    where ID = #{id,jdbcType=INTEGER}
+  </update>
+  <update id="updateByPrimaryKey" parameterType="com.freemud.pay.job.dao.dbModel.PartnerDM">
+    update Partner
+    set PartnerName = #{partnername,jdbcType=VARCHAR},
+      OurAccount_Partner = #{ouraccountPartner,jdbcType=VARCHAR},
+      Logo = #{logo,jdbcType=VARCHAR},
+      Description = #{description,jdbcType=VARCHAR},
+      PartnerCode = #{partnercode,jdbcType=VARCHAR},
+      AppSecret = #{appsecret,jdbcType=VARCHAR},
+      EBCode = #{ebcode,jdbcType=VARCHAR},
+      EnableSMS = #{enablesms,jdbcType=BIT},
+      PartnerType = #{partnertype,jdbcType=VARCHAR},
+      UnifyId = #{unifyid,jdbcType=VARCHAR}
+    where ID = #{id,jdbcType=INTEGER}
+  </update>
+</mapper>
\ No newline at end of file

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

+<?xml version="1.0" encoding="UTF-8"?>
+<!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" "http://mybatis.org/dtd/mybatis-3-mapper.dtd">
+<mapper namespace="com.freemud.pay.job.dao.mapper.PayMessageDMMapper">
+  <resultMap id="BaseResultMap" type="com.freemud.pay.job.dao.dbModel.PayMessageDM">
+    <id column="Id" jdbcType="BIGINT" property="id" />
+    <result column="PartnerId" jdbcType="INTEGER" property="partnerid" />
+    <result column="FMId" jdbcType="VARCHAR" property="fmid" />
+    <result column="TemplateId" jdbcType="VARCHAR" property="templateid" />
+    <result column="UserId" jdbcType="VARCHAR" property="userid" />
+    <result column="Status" jdbcType="INTEGER" property="status" />
+    <result column="TryTimes" jdbcType="INTEGER" property="trytimes" />
+    <result column="CreateDate" jdbcType="TIMESTAMP" property="createdate" />
+    <result column="LastEditDate" jdbcType="TIMESTAMP" property="lasteditdate" />
+    <result column="Code" jdbcType="CHAR" property="code" />
+    <result column="Pay_Message_Active_ID" jdbcType="BIGINT" property="payMessageActiveId" />
+  </resultMap>
+  <sql id="Base_Column_List">
+    Id, PartnerId, FMId, TemplateId, UserId, Status, TryTimes, CreateDate, LastEditDate, 
+    Code, Pay_Message_Active_ID
+  </sql>
+  <select id="selectByPrimaryKey" parameterType="java.lang.Long" resultMap="BaseResultMap">
+    select 
+    <include refid="Base_Column_List" />
+    from Pay_Message
+    where Id = #{id,jdbcType=BIGINT}
+  </select>
+  <delete id="deleteByPrimaryKey" parameterType="java.lang.Long">
+    delete from Pay_Message
+    where Id = #{id,jdbcType=BIGINT}
+  </delete>
+  <insert id="insert" parameterType="com.freemud.pay.job.dao.dbModel.PayMessageDM">
+    insert into Pay_Message (Id, PartnerId, FMId, 
+      TemplateId, UserId, Status, 
+      TryTimes, CreateDate, LastEditDate, 
+      Code, Pay_Message_Active_ID)
+    values (#{id,jdbcType=BIGINT}, #{partnerid,jdbcType=INTEGER}, #{fmid,jdbcType=VARCHAR}, 
+      #{templateid,jdbcType=VARCHAR}, #{userid,jdbcType=VARCHAR}, #{status,jdbcType=INTEGER}, 
+      #{trytimes,jdbcType=INTEGER}, #{createdate,jdbcType=TIMESTAMP}, #{lasteditdate,jdbcType=TIMESTAMP}, 
+      #{code,jdbcType=CHAR}, #{payMessageActiveId,jdbcType=BIGINT})
+  </insert>
+  <insert id="insertSelective" parameterType="com.freemud.pay.job.dao.dbModel.PayMessageDM">
+    insert into Pay_Message
+    <trim prefix="(" suffix=")" suffixOverrides=",">
+      <if test="id != null">
+        Id,
+      </if>
+      <if test="partnerid != null">
+        PartnerId,
+      </if>
+      <if test="fmid != null">
+        FMId,
+      </if>
+      <if test="templateid != null">
+        TemplateId,
+      </if>
+      <if test="userid != null">
+        UserId,
+      </if>
+      <if test="status != null">
+        Status,
+      </if>
+      <if test="trytimes != null">
+        TryTimes,
+      </if>
+      <if test="createdate != null">
+        CreateDate,
+      </if>
+      <if test="lasteditdate != null">
+        LastEditDate,
+      </if>
+      <if test="code != null">
+        Code,
+      </if>
+      <if test="payMessageActiveId != null">
+        Pay_Message_Active_ID,
+      </if>
+    </trim>
+    <trim prefix="values (" suffix=")" suffixOverrides=",">
+      <if test="id != null">
+        #{id,jdbcType=BIGINT},
+      </if>
+      <if test="partnerid != null">
+        #{partnerid,jdbcType=INTEGER},
+      </if>
+      <if test="fmid != null">
+        #{fmid,jdbcType=VARCHAR},
+      </if>
+      <if test="templateid != null">
+        #{templateid,jdbcType=VARCHAR},
+      </if>
+      <if test="userid != null">
+        #{userid,jdbcType=VARCHAR},
+      </if>
+      <if test="status != null">
+        #{status,jdbcType=INTEGER},
+      </if>
+      <if test="trytimes != null">
+        #{trytimes,jdbcType=INTEGER},
+      </if>
+      <if test="createdate != null">
+        #{createdate,jdbcType=TIMESTAMP},
+      </if>
+      <if test="lasteditdate != null">
+        #{lasteditdate,jdbcType=TIMESTAMP},
+      </if>
+      <if test="code != null">
+        #{code,jdbcType=CHAR},
+      </if>
+      <if test="payMessageActiveId != null">
+        #{payMessageActiveId,jdbcType=BIGINT},
+      </if>
+    </trim>
+  </insert>
+  <update id="updateByPrimaryKeySelective" parameterType="com.freemud.pay.job.dao.dbModel.PayMessageDM">
+    update Pay_Message
+    <set>
+      <if test="partnerid != null">
+        PartnerId = #{partnerid,jdbcType=INTEGER},
+      </if>
+      <if test="fmid != null">
+        FMId = #{fmid,jdbcType=VARCHAR},
+      </if>
+      <if test="templateid != null">
+        TemplateId = #{templateid,jdbcType=VARCHAR},
+      </if>
+      <if test="userid != null">
+        UserId = #{userid,jdbcType=VARCHAR},
+      </if>
+      <if test="status != null">
+        Status = #{status,jdbcType=INTEGER},
+      </if>
+      <if test="trytimes != null">
+        TryTimes = #{trytimes,jdbcType=INTEGER},
+      </if>
+      <if test="createdate != null">
+        CreateDate = #{createdate,jdbcType=TIMESTAMP},
+      </if>
+      <if test="lasteditdate != null">
+        LastEditDate = #{lasteditdate,jdbcType=TIMESTAMP},
+      </if>
+      <if test="code != null">
+        Code = #{code,jdbcType=CHAR},
+      </if>
+      <if test="payMessageActiveId != null">
+        Pay_Message_Active_ID = #{payMessageActiveId,jdbcType=BIGINT},
+      </if>
+    </set>
+    where Id = #{id,jdbcType=BIGINT}
+  </update>
+  <update id="updateByPrimaryKey" parameterType="com.freemud.pay.job.dao.dbModel.PayMessageDM">
+    update Pay_Message
+    set PartnerId = #{partnerid,jdbcType=INTEGER},
+      FMId = #{fmid,jdbcType=VARCHAR},
+      TemplateId = #{templateid,jdbcType=VARCHAR},
+      UserId = #{userid,jdbcType=VARCHAR},
+      Status = #{status,jdbcType=INTEGER},
+      TryTimes = #{trytimes,jdbcType=INTEGER},
+      CreateDate = #{createdate,jdbcType=TIMESTAMP},
+      LastEditDate = #{lasteditdate,jdbcType=TIMESTAMP},
+      Code = #{code,jdbcType=CHAR},
+      Pay_Message_Active_ID = #{payMessageActiveId,jdbcType=BIGINT}
+    where Id = #{id,jdbcType=BIGINT}
+  </update>
+
+  <select id="getPayMessages" parameterType="Map" resultMap="BaseResultMap">
+    SELECT TOP 1000
+    a.[Id] ,
+    a.[PartnerId] ,
+    a.[FMId] ,
+    a.[UserId] ,
+    a.[Code] ,
+    a.[Pay_Message_Active_ID] ,
+    p.Amount ,
+    p.Store_Id ,
+    p.Station_Id ,
+    p.mcoupon ,
+    p.pcoupon ,
+    p.CreateDate ,
+    p.PlatformTradeNumber ,
+    p.Platform ,
+    p.PlatformTradeAccount AS SubUserId ,
+    part.UnifyId ,
+    p.Operator_Id,
+    p.Trans_Id,
+    p.Remark,
+    p.Code AS PayCode
+    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
+
+    WHERE   a.Status IN ( -1, 0 )
+    AND a.TryTimes &lt; 3
+    AND  a.LastEditDate> DATEADD(MINUTE,-30, GETDATE())
+    AND a.LastEditDate &lt; GETDATE()
+  </select>
+  <update id="updateMessageStatus">
+    update top(1) [Freemud_ThirdParty].[dbo].[Pay_Message] set status=-1 ,TryTimes=TryTimes+1 where id=#{id}
+  </update>
+</mapper>
\ No newline at end of file