Skip to content

F
freemud-pay-job
Commit 17a4c9da by lihui.wang
Options

规范命名

parent c98fd65a
Showing with 127 additions and 686 deletions
freemud-pay-module/freemud-pay-push-message/src/main/java/com/freemud/pay/job/dao/dbModel/Partner.java deleted 100644 → 0
package com.freemud.pay.job.dao.dbModel;
import java.io.Serializable;
public class Partner 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/PayMessage.java deleted 100644 → 0
package com.freemud.pay.job.dao.dbModel;
import java.io.Serializable;
import java.util.Date;
public class PayMessage 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/dbModel/PayMessageActive.java deleted 100644 → 0
package com.freemud.pay.job.dao.dbModel;
import java.io.Serializable;
import java.math.BigDecimal;
import java.util.Date;
public class PayMessageActive 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/mapper/PartnerMapper.java
package com.freemud.pay.job.dao.mapper;
import com.freemud.pay.job.dao.IBaseDao;
import com.freemud.pay.job.dao.dbModel.Partner;
import com.freemud.pay.job.dao.dbModel.PartnerDM;
public interface PartnerMapper extends IBaseDao<Partner>{
public interface PartnerMapper extends IBaseDao<PartnerDM>{
int deleteByPrimaryKey(Integer id);
int insert(Partner record);
@Override
int insert(PartnerDM record);
int insertSelective(Partner record);
@Override
int insertSelective(PartnerDM record);
Partner selectByPrimaryKey(Integer id);
PartnerDM selectByPrimaryKey(Integer id);
int updateByPrimaryKeySelective(Partner record);
@Override
int updateByPrimaryKeySelective(PartnerDM record);
int updateByPrimaryKey(Partner record);
@Override
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/PayMapper.java
package com.freemud.pay.job.dao.mapper;
import com.freemud.pay.job.dao.IBaseDao;
import com.freemud.pay.job.dao.dbModel.Pay;
import com.freemud.pay.job.dao.dbModel.PayDM;
public interface PayMapper extends IBaseDao<Pay>{
public interface PayMapper extends IBaseDao<PayDM>{
int deleteByPrimaryKey(Long id);
int insert(Pay record);
int insert(PayDM record);
int insertSelective(Pay record);
int insertSelective(PayDM record);
Pay selectByPrimaryKey(Long id);
PayDM selectByPrimaryKey(Long id);
int updateByPrimaryKeySelective(Pay record);
int updateByPrimaryKeySelective(PayDM record);
int updateByPrimaryKey(Pay 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/PayMessageActiveMapper.java
package com.freemud.pay.job.dao.mapper;
import com.freemud.pay.job.dao.IBaseDao;
import com.freemud.pay.job.dao.dbModel.PayMessageActive;
import com.freemud.pay.job.dao.dbModel.PayMessageActiveDM;
public interface PayMessageActiveMapper extends IBaseDao<PayMessageActive> {
public interface PayMessageActiveMapper extends IBaseDao<PayMessageActiveDM> {
int deleteByPrimaryKey(Long id);
int insert(PayMessageActive record);
int insert(PayMessageActiveDM record);
int insertSelective(PayMessageActive record);
@Override
int insertSelective(PayMessageActiveDM record);
PayMessageActive selectByPrimaryKey(Long id);
PayMessageActiveDM selectByPrimaryKey(Long id);
int updateByPrimaryKeySelective(PayMessageActive record);
int updateByPrimaryKeySelective(PayMessageActiveDM record);
int updateByPrimaryKey(PayMessageActive record);
@Override
int updateByPrimaryKey(PayMessageActiveDM record);
}
\ No newline at end of file
freemud-pay-module/freemud-pay-push-message/src/main/java/com/freemud/pay/job/dao/mapper/PayMessageMapper.java
package com.freemud.pay.job.dao.mapper;
import com.freemud.pay.job.dao.IBaseDao;
import com.freemud.pay.job.dao.dbModel.PayMessage;
import com.freemud.pay.job.dao.dbModel.PayMessageDM;
import java.util.List;
public interface PayMessageMapper extends IBaseDao<PayMessage>{
public interface PayMessageMapper extends IBaseDao<PayMessageDM>{
int deleteByPrimaryKey(Long id);
@Override
int insert(PayMessage record);
int insert(PayMessageDM record);
@Override
int insertSelective(PayMessage record);
int insertSelective(PayMessageDM record);
PayMessage selectByPrimaryKey(Long id);
PayMessageDM selectByPrimaryKey(Long id);
@Override
int updateByPrimaryKeySelective(PayMessage record);
int updateByPrimaryKeySelective(PayMessageDM record);
@Override
int updateByPrimaryKey(PayMessage record);
int updateByPrimaryKey(PayMessageDM record);
List<com.freemud.pay.job.entity.PayMessage> getPayMessages(String dbPartition, String linkServer);
List<PayMessageDM> getPayMessages(String dbPartition, String linkServer);
}
\ No newline at end of file
freemud-pay-module/freemud-pay-push-message/src/main/java/com/freemud/pay/job/dao/repository/IPayMessageActiveRepository.java
package com.freemud.pay.job.dao.repository;
import com.freemud.pay.job.dao.dbModel.PayMessageActive;
import java.util.List;
import com.freemud.pay.job.dao.dbModel.PayMessageActiveDM;
/**
* All rights Reserved, Designed By www.freemud.cn
......@@ -16,5 +14,5 @@ import java.util.List;
* 注意：本内容仅限于上海非码科技内部传阅，禁止外泄以及用于其他的商业目
*/
public interface IPayMessageActiveRepository extends IBaseRepository{
PayMessageActive getPayMessageActive(long activeId, String dbPartition, String linkServer);
PayMessageActiveDM getPayMessageActiveDM(long activeId, String dbPartition, String linkServer);
}
freemud-pay-module/freemud-pay-push-message/src/main/java/com/freemud/pay/job/dao/repository/IPayMessageRepository.java
package com.freemud.pay.job.dao.repository;
import com.freemud.pay.job.dao.dbModel.PayMessageActiveDM;
import com.freemud.pay.job.dao.dbModel.PayMessageDM;
import com.freemud.pay.job.entity.PayMessage;
import java.util.List;
......@@ -16,5 +18,5 @@ import java.util.List;
* 注意：本内容仅限于上海非码科技内部传阅，禁止外泄以及用于其他的商业目
*/
public interface IPayMessageRepository extends IBaseRepository{
List<PayMessage> getPayMessages(String dbPartition, String linkServer);
List<PayMessageDM> getPayMessages(String dbPartition, String linkServer);
}
freemud-pay-module/freemud-pay-push-message/src/main/java/com/freemud/pay/job/dao/repository/Impl/PartnerRepositoryImpl.java
......@@ -7,8 +7,8 @@ import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.context.annotation.Primary;
import org.springframework.stereotype.Repository;
@Primary
@Repository
//@Primary
//@Repository
public class PartnerRepositoryImpl extends BaseRepositoryImpl implements IPartnerRepository {
@Override
protected IBaseDao getDao() {
......
freemud-pay-module/freemud-pay-push-message/src/main/java/com/freemud/pay/job/dao/repository/Impl/PayMessageActiveRepositoryImpl.java
package com.freemud.pay.job.dao.repository.Impl;
import com.freemud.pay.job.dao.IBaseDao;
import com.freemud.pay.job.dao.dbModel.PayMessageActive;
import com.freemud.pay.job.dao.dbModel.PayMessageActiveDM;
import com.freemud.pay.job.dao.mapper.PayMessageActiveMapper;
import com.freemud.pay.job.dao.repository.IPayMessageActiveRepository;
import com.freemud.pay.job.dao.repository.IPayMessageRepository;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.context.annotation.Primary;
import org.springframework.stereotype.Repository;
import java.util.List;
/**
* All rights Reserved, Designed By www.freemud.cn
*
......@@ -22,8 +19,8 @@ import java.util.List;
* @Copyright: 2017 www.freemud.cn Inc. All rights reserved.
* 注意：本内容仅限于上海非码科技内部传阅，禁止外泄以及用于其他的商业目
*/
@Primary
@Repository
//@Primary
//@Repository
public class PayMessageActiveRepositoryImpl extends BaseRepositoryImpl implements IPayMessageActiveRepository {
@Autowired
......@@ -35,7 +32,7 @@ public class PayMessageActiveRepositoryImpl extends BaseRepositoryImpl implement
}
@Override
public PayMessageActive getPayMessageActive(long activeId, String dbPartition, String linkServer) {
public PayMessageActiveDM getPayMessageActiveDM(long activeId, String dbPartition, String linkServer) {
return null;
}
......
freemud-pay-module/freemud-pay-push-message/src/main/java/com/freemud/pay/job/dao/repository/Impl/PayMessageRepositoryImpl.java
package com.freemud.pay.job.dao.repository.Impl;
import com.freemud.pay.job.dao.IBaseDao;
import com.freemud.pay.job.dao.dbModel.PayMessageDM;
import com.freemud.pay.job.dao.mapper.PayMessageMapper;
import com.freemud.pay.job.dao.repository.IPayMessageRepository;
import com.freemud.pay.job.entity.BaseParam;
import com.freemud.pay.job.entity.PayMessage;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.context.annotation.Primary;
import org.springframework.stereotype.Repository;
......@@ -22,8 +21,8 @@ import java.util.List;
* @Copyright: 2017 www.freemud.cn Inc. All rights reserved.
* 注意：本内容仅限于上海非码科技内部传阅，禁止外泄以及用于其他的商业目
*/
@Primary
@Repository
//@Primary
//@Repository
public class PayMessageRepositoryImpl extends BaseRepositoryImpl implements IPayMessageRepository {
@Autowired
......@@ -36,7 +35,8 @@ public class PayMessageRepositoryImpl extends BaseRepositoryImpl implements IPay
@Override
public List<PayMessage> getPayMessages(String dbPartition, String linkServer) {
public List<PayMessageDM> getPayMessages(String dbPartition, String linkServer) {
return payMessageMapper.getPayMessages(dbPartition,linkServer);
}
}
\ No newline at end of file
freemud-pay-module/freemud-pay-push-message/src/main/java/com/freemud/pay/job/dao/repository/Impl/PayRepositoryImpl.java
......@@ -22,8 +22,8 @@ import java.util.List;
* @Copyright: 2017 www.freemud.cn Inc. All rights reserved.
* 注意：本内容仅限于上海非码科技内部传阅，禁止外泄以及用于其他的商业目
*/
@Primary
@Repository
//@Primary
//@Repository
public class PayRepositoryImpl extends BaseRepositoryImpl implements IPayRepository {
@Override
protected IBaseDao getDao() {
......
freemud-pay-module/freemud-pay-push-message/src/main/java/com/freemud/pay/job/entity/PayMessage.java
package com.freemud.pay.job.entity;
import com.freemud.pay.job.dao.dbModel.PayMessageActiveDM;
import com.freemud.pay.job.dao.dbModel.PayMessageDM;
......@@ -17,8 +18,8 @@ import com.freemud.pay.job.dao.dbModel.PayMessageDM;
public class PayMessage {
private BaseParam baseParam;
private PayMessageDM payMessageDM;
private PayMessageActiveDM payMessageActiveDM;
private PayMessageDM payMessage;
private PayMessageActiveDM payMessageActive;
public BaseParam getBaseParam() {
return baseParam;
......@@ -28,19 +29,19 @@ public class PayMessage {
this.baseParam = baseParam;
}
public PayMessageDM getPayMessageDM() {
return payMessageDM;
public PayMessageDM getPayMessage() {
return payMessage;
}
public void setPayMessageDM(PayMessageDM payMessageDM) {
this.payMessageDM = payMessageDM;
public void setPayMessage(PayMessageDM payMessage) {
this.payMessage = payMessage;
}
public PayMessageActiveDM getPayMessageActiveDM() {
return payMessageActiveDM;
public PayMessageActiveDM getPayMessageActive() {
return payMessageActive;
}
public void setPayMessageActiveDM(PayMessageActiveDM payMessageActiveDM) {
this.payMessageActiveDM = payMessageActiveDM;
public void setPayMessageActive(PayMessageActiveDM payMessageActive) {
this.payMessageActive = payMessageActive;
}
}
\ No newline at end of file
freemud-pay-module/freemud-pay-push-message/src/main/java/com/freemud/pay/job/service/IMessageProcessor.java
package com.freemud.pay.job.service;
import com.freemud.pay.job.entity.PayMessage;
import org.springframework.stereotype.Service;
/**
* All rights Reserved, Designed By www.freemud.cn
......
freemud-pay-module/freemud-pay-push-message/src/main/java/com/freemud/pay/job/service/IPartnerService.java
package com.freemud.pay.job.service;
import com.freemud.pay.job.dao.dbModel.PartnerDM;
import org.springframework.stereotype.Service;
import java.util.List;
......
freemud-pay-module/freemud-pay-push-message/src/main/java/com/freemud/pay/job/service/IPayMessageService.java
package com.freemud.pay.job.service;
import com.freemud.pay.job.dao.dbModel.PayMessageDM;
import com.freemud.pay.job.entity.BaseParam;
import org.springframework.stereotype.Service;
import java.util.List;
......@@ -17,5 +17,5 @@ import java.util.List;
* 注意：本内容仅限于上海非码科技内部传阅，禁止外泄以及用于其他的商业目
*/
public interface IPayMessageService {
void pushMessage(BaseParam baseRequest );
void pushMessage(BaseParam baseRequest);
}
freemud-pay-module/freemud-pay-push-message/src/main/java/com/freemud/pay/job/service/IPayService.java
package com.freemud.pay.job.service;
import org.springframework.stereotype.Service;
/**
* All rights Reserved, Designed By www.freemud.cn
*
......
freemud-pay-module/freemud-pay-push-message/src/main/java/com/freemud/pay/job/service/MessageProcessorFactory.java
......@@ -2,7 +2,7 @@ package com.freemud.pay.job.service;
import com.freemud.pay.job.dao.dbModel.PayMessageActiveDM;
import com.freemud.pay.job.dao.dbModel.PayMessageDM;
import com.freemud.pay.job.service.IMessageProcessor;
import com.freemud.pay.job.entity.PayMessage;
import com.freemud.pay.job.service.impl.AliFuWuChuangSingleMessageSender;
import org.apache.commons.lang.StringUtils;
......
freemud-pay-module/freemud-pay-push-message/src/main/java/com/freemud/pay/job/service/impl/AliFuWuChuangSingleMessageSender.java
......@@ -16,6 +16,7 @@ import com.freemud.pay.job.service.IMessageProcessor;
*/
public class AliFuWuChuangSingleMessageSender implements IMessageProcessor {
@Override
public Boolean Process(PayMessage payMessage) {
......@@ -65,4 +66,6 @@ public class AliFuWuChuangSingleMessageSender implements IMessageProcessor {
return null;
}
}
\ No newline at end of file
freemud-pay-module/freemud-pay-push-message/src/main/java/com/freemud/pay/job/service/impl/PartnerServiceImpl.java
......@@ -4,6 +4,7 @@ import com.freemud.pay.job.dao.dbModel.PartnerDM;
import com.freemud.pay.job.dao.repository.IPartnerRepository;
import com.freemud.pay.job.service.IPartnerService;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;
import java.util.List;
......@@ -18,6 +19,7 @@ import java.util.List;
* @Copyright: 2017 www.freemud.cn Inc. All rights reserved.
* 注意：本内容仅限于上海非码科技内部传阅，禁止外泄以及用于其他的商业目
*/
@Service("partnerService")
public class PartnerServiceImpl implements IPartnerService {
@Autowired
......
freemud-pay-module/freemud-pay-push-message/src/main/java/com/freemud/pay/job/service/impl/PayMessageServiceImpl.java
......@@ -12,6 +12,7 @@ import com.freemud.pay.job.service.IPayMessageService;
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 java.util.ArrayList;
import java.util.List;
......@@ -27,6 +28,7 @@ import java.util.List;
* @Copyright: 2017 www.freemud.cn Inc. All rights reserved.
* 注意：本内容仅限于上海非码科技内部传阅，禁止外泄以及用于其他的商业目
*/
@Service("payMessageService")
public class PayMessageServiceImpl implements IPayMessageService {
@Autowired
......@@ -58,7 +60,7 @@ public class PayMessageServiceImpl implements IPayMessageService {
MarkMessageAsNoProcess(message,bussinessType,dbPartition);
return;
}
PayMessageActiveDM active = iPayMessageActiveRepository.getPayMessageActive(message.getPayMessageActiveId(), bussinessType, dbPartition);
PayMessageActiveDM active = iPayMessageActiveRepository.getPayMessageActiveDM(message.getPayMessageActiveId(), bussinessType, dbPartition);
if (active == null
|| StringUtils.isEmpty(active.getAction()))
{
......@@ -73,8 +75,8 @@ public class PayMessageServiceImpl implements IPayMessageService {
PayMessage payMessage=new PayMessage();
payMessage.setBaseParam(baseParam);
payMessage.setPayMessageDM(message);
payMessage.setPayMessageActiveDM(active);
payMessage.setPayMessage(message);
payMessage.setPayMessageActive(active);
result = (processor == null)
? false
: processor.Process(payMessage);
......@@ -112,7 +114,7 @@ public class PayMessageServiceImpl implements IPayMessageService {
}
private List<PayMessageDM> getPayMessages(String dbPartner,String linkServer){
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/java/com/freemud/pay/job/service/impl/PayServiceImpl.java
......@@ -2,6 +2,7 @@ package com.freemud.pay.job.service.impl;
import com.freemud.pay.job.service.IPayService;
import org.springframework.stereotype.Service;
/**
* All rights Reserved, Designed By www.freemud.cn
......@@ -14,5 +15,6 @@ import com.freemud.pay.job.service.IPayService;
* @Copyright: 2017 www.freemud.cn Inc. All rights reserved.
* 注意：本内容仅限于上海非码科技内部传阅，禁止外泄以及用于其他的商业目
*/
@Service("payService")
public class PayServiceImpl implements IPayService {
}
\ No newline at end of file
freemud-pay-module/freemud-pay-push-message/src/main/resources/generatorConfig.xml
......@@ -23,7 +23,7 @@
<!--JDBC URL: jdbc:mysql://<host>:<port>/<database_name>-->
<jdbcConnection
driverClass="com.microsoft.sqlserver.jdbc.SQLServerDriver"
connectionURL="jdbc:sqlserver://115.159.142.32:9528;databasename=zhuihu"
connectionURL="jdbc:sqlserver://115.159.142.32:9528;databasename=Freemud_ThirdParty"
userId="zhuihutest"
password="zhuihutest@freemud">
</jdbcConnection>
......@@ -55,25 +55,25 @@
</javaModelGenerator>
<!--Mapper映射文件生成所在的目录 为每一个数据库的表生成对应的SqlMap文件 -->
<sqlMapGenerator targetPackage="mapper"
targetProject="src/main/resources">
<property name="enableSubPackages" value="false"/>
</sqlMapGenerator>
<!--<sqlMapGenerator targetPackage="mapper"-->
<!--targetProject="src/main/resources">-->
<!--<property name="enableSubPackages" value="false"/>-->
<!--</sqlMapGenerator>-->
<!-- 客户端代码，生成易于使用的针对Model对象和XML配置文件 的代码
type="ANNOTATEDMAPPER",生成Java Model 和基于注解的Mapper对象
type="MIXEDMAPPER",生成基于注解的Java Model 和相应的Mapper对象
type="XMLMAPPER",生成SQLMap XML文件和独立的Mapper接口
-->
<javaClientGenerator targetPackage="com.freemud.pay.job.dao.mapper"
targetProject="src/main/java" type="XMLMAPPER">
<property name="enableSubPackages" value="true"/>
</javaClientGenerator>
<!--<table tableName="pay" enableCountByExample="false" enableUpdateByExample="false" enableDeleteByExample="false" enableSelectByExample="false" selectByExampleQueryId="false" ></table>-->
<!--<table tableName="Pay_Message" enableCountByExample="false" enableUpdateByExample="false" enableDeleteByExample="false" enableSelectByExample="false" selectByExampleQueryId="false" ></table>-->
<!--<table tableName="Pay_Message_Active" enableCountByExample="false" enableUpdateByExample="false" enableDeleteByExample="false" enableSelectByExample="false" selectByExampleQueryId="false" ></table>-->
<table tableName="Partner" enableCountByExample="false" enableUpdateByExample="false" enableDeleteByExample="false" enableSelectByExample="false" selectByExampleQueryId="false" ></table>
<!--<javaClientGenerator targetPackage="com.freemud.pay.job.dao.mapper"-->
<!--targetProject="src/main/java" type="XMLMAPPER">-->
<!--<property name="enableSubPackages" value="true"/>-->
<!--</javaClientGenerator>-->
<!--<table tableName="pay" domainObjectName="PayDM" enableCountByExample="false" enableUpdateByExample="false" enableDeleteByExample="false" enableSelectByExample="false" selectByExampleQueryId="false" ></table>-->
<table tableName="Pay_Message" domainObjectName="PayMessageDM" enableCountByExample="false" enableUpdateByExample="false" enableDeleteByExample="false" enableSelectByExample="false" selectByExampleQueryId="false" ></table>
<table tableName="Pay_Message_Active" domainObjectName="PayMessageActiveDM" enableCountByExample="false" enableUpdateByExample="false" enableDeleteByExample="false" enableSelectByExample="false" selectByExampleQueryId="false" ></table>
<!--<table tableName="Partner" domainObjectName="PartnerDM" enableCountByExample="false" enableUpdateByExample="false" enableDeleteByExample="false" enableSelectByExample="false" selectByExampleQueryId="false" ></table>-->
<!--<table tableName="partner" domainObjectName="Partner" ></table>
......
freemud-pay-module/freemud-pay-push-message/src/main/resources/mapper/PartnerMapper.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.PartnerMapper">
<resultMap id="BaseResultMap" type="com.freemud.pay.job.dao.dbModel.Partner">
<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" />
......@@ -38,7 +38,7 @@
#{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.Partner">
<insert id="insertSelective" parameterType="com.freemud.pay.job.dao.dbModel.PartnerDM">
insert into Partner
<trim prefix="(" suffix=")" suffixOverrides=",">
<if test="id != null">
......@@ -111,7 +111,7 @@
</if>
</trim>
</insert>
<update id="updateByPrimaryKeySelective" parameterType="com.freemud.pay.job.dao.dbModel.Partner">
<update id="updateByPrimaryKeySelective" parameterType="com.freemud.pay.job.dao.dbModel.PartnerDM">
update Partner
<set>
<if test="partnername != null">
......@@ -147,7 +147,7 @@
</set>
where ID = #{id,jdbcType=INTEGER}
</update>
<update id="updateByPrimaryKey" parameterType="com.freemud.pay.job.dao.dbModel.Partner">
<update id="updateByPrimaryKey" parameterType="com.freemud.pay.job.dao.dbModel.PartnerDM">
update Partner
set PartnerName = #{partnername,jdbcType=VARCHAR},
OurAccount_Partner = #{ouraccountPartner,jdbcType=VARCHAR},
......
freemud-pay-module/freemud-pay-push-message/src/main/resources/mapper/PayMapper.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.PayMapper">
<resultMap id="BaseResultMap" type="com.freemud.pay.job.dao.dbModel.Pay">
<resultMap id="BaseResultMap" type="com.freemud.pay.job.dao.dbModel.PayDM">
<id column="ID" jdbcType="BIGINT" property="id" />
<result column="Store_Id" jdbcType="VARCHAR" property="storeId" />
<result column="Station_Id" jdbcType="VARCHAR" property="stationId" />
......@@ -57,7 +57,7 @@
delete from Pay
where ID = #{id,jdbcType=BIGINT}
</delete>
<insert id="insert" parameterType="com.freemud.pay.job.dao.dbModel.Pay">
<insert id="insert" parameterType="com.freemud.pay.job.dao.dbModel.PayDM">
insert into Pay (ID, Store_Id, Station_Id,
Operator_Id, Partner, PartnerAccount,
PartnerOrderID, PlatformTradeAccount, PlatformTradeNumber,
......@@ -85,7 +85,7 @@
#{bankcommissionrate,jdbcType=DECIMAL}, #{payplatformrate,jdbcType=DECIMAL}, #{payplatformfee,jdbcType=DECIMAL},
#{netamount,jdbcType=DECIMAL})
</insert>
<insert id="insertSelective" parameterType="com.freemud.pay.job.dao.dbModel.Pay">
<insert id="insertSelective" parameterType="com.freemud.pay.job.dao.dbModel.PayDM">
insert into Pay
<trim prefix="(" suffix=")" suffixOverrides=",">
<if test="id != null">
......@@ -308,7 +308,7 @@
</if>
</trim>
</insert>
<update id="updateByPrimaryKeySelective" parameterType="com.freemud.pay.job.dao.dbModel.Pay">
<update id="updateByPrimaryKeySelective" parameterType="com.freemud.pay.job.dao.dbModel.PayDM">
update Pay
<set>
<if test="storeId != null">
......@@ -419,7 +419,7 @@
</set>
where ID = #{id,jdbcType=BIGINT}
</update>
<update id="updateByPrimaryKey" parameterType="com.freemud.pay.job.dao.dbModel.Pay">
<update id="updateByPrimaryKey" parameterType="com.freemud.pay.job.dao.dbModel.PayDM">
update Pay
set Store_Id = #{storeId,jdbcType=VARCHAR},
Station_Id = #{stationId,jdbcType=VARCHAR},
......
freemud-pay-module/freemud-pay-push-message/src/main/resources/mapper/PayMessageActiveMapper.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.PayMessageActiveMapper">
<resultMap id="BaseResultMap" type="com.freemud.pay.job.dao.dbModel.PayMessageActive">
<resultMap id="BaseResultMap" type="com.freemud.pay.job.dao.dbModel.PayMessageActiveDM">
<id column="ID" jdbcType="BIGINT" property="id" />
<result column="PartnerId" jdbcType="INTEGER" property="partnerid" />
<result column="CouponActiveId" jdbcType="INTEGER" property="couponactiveid" />
......@@ -45,7 +45,7 @@
delete from Pay_Message_Active
where ID = #{id,jdbcType=BIGINT}
</delete>
<insert id="insert" parameterType="com.freemud.pay.job.dao.dbModel.PayMessageActive">
<insert id="insert" parameterType="com.freemud.pay.job.dao.dbModel.PayMessageActiveDM">
insert into Pay_Message_Active (ID, PartnerId, CouponActiveId,
Name, Description, PlatformAccountId,
TemplateId, Status, StartTime,
......@@ -65,7 +65,7 @@
#{dateintervallimit,jdbcType=INTEGER}, #{maxamountlimit,jdbcType=DECIMAL}, #{delaytimelimit,jdbcType=DECIMAL},
#{secondactiveid,jdbcType=BIGINT}, #{wxmsgactiveid,jdbcType=NVARCHAR})
</insert>
<insert id="insertSelective" parameterType="com.freemud.pay.job.dao.dbModel.PayMessageActive">
<insert id="insertSelective" parameterType="com.freemud.pay.job.dao.dbModel.PayMessageActiveDM">
insert into Pay_Message_Active
<trim prefix="(" suffix=")" suffixOverrides=",">
<if test="id != null">
......@@ -228,7 +228,7 @@
</if>
</trim>
</insert>
<update id="updateByPrimaryKeySelective" parameterType="com.freemud.pay.job.dao.dbModel.PayMessageActive">
<update id="updateByPrimaryKeySelective" parameterType="com.freemud.pay.job.dao.dbModel.PayMessageActiveDM">
update Pay_Message_Active
<set>
<if test="partnerid != null">
......@@ -309,7 +309,7 @@
</set>
where ID = #{id,jdbcType=BIGINT}
</update>
<update id="updateByPrimaryKey" parameterType="com.freemud.pay.job.dao.dbModel.PayMessageActive">
<update id="updateByPrimaryKey" parameterType="com.freemud.pay.job.dao.dbModel.PayMessageActiveDM">
update Pay_Message_Active
set PartnerId = #{partnerid,jdbcType=INTEGER},
CouponActiveId = #{couponactiveid,jdbcType=INTEGER},
......
freemud-pay-module/freemud-pay-push-message/src/main/resources/mapper/PayMessageMapper.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.PayMessageMapper">
<resultMap id="BaseResultMap" type="com.freemud.pay.job.dao.dbModel.PayMessage">
<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" />
......@@ -28,7 +28,7 @@
delete from Pay_Message
where Id = #{id,jdbcType=BIGINT}
</delete>
<insert id="insert" parameterType="com.freemud.pay.job.dao.dbModel.PayMessage">
<insert id="insert" parameterType="com.freemud.pay.job.dao.dbModel.PayMessageDM">
insert into Pay_Message (Id, PartnerId, FMId,
TemplateId, UserId, Status,
TryTimes, CreateDate, LastEditDate,
......@@ -38,7 +38,7 @@
#{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.PayMessage">
<insert id="insertSelective" parameterType="com.freemud.pay.job.dao.dbModel.PayMessageDM">
insert into Pay_Message
<trim prefix="(" suffix=")" suffixOverrides=",">
<if test="id != null">
......@@ -111,7 +111,7 @@
</if>
</trim>
</insert>
<update id="updateByPrimaryKeySelective" parameterType="com.freemud.pay.job.dao.dbModel.PayMessage">
<update id="updateByPrimaryKeySelective" parameterType="com.freemud.pay.job.dao.dbModel.PayMessageDM">
update Pay_Message
<set>
<if test="partnerid != null">
......@@ -147,7 +147,7 @@
</set>
where Id = #{id,jdbcType=BIGINT}
</update>
<update id="updateByPrimaryKey" parameterType="com.freemud.pay.job.dao.dbModel.PayMessage">
<update id="updateByPrimaryKey" parameterType="com.freemud.pay.job.dao.dbModel.PayMessageDM">
update Pay_Message
set PartnerId = #{partnerid,jdbcType=INTEGER},
FMId = #{fmid,jdbcType=VARCHAR},
......
pom.xml
......@@ -14,7 +14,6 @@
<module>xxl-job-core</module>
<module>xxl-job-admin</module>
<module>xxl-job-executor-samples</module>
<module>freemud-pay-module/freemud-pay-push-message</module>
</modules>
<properties>
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment