Skip to content

F
freemud-pay-job
Commit b3530fb1 by lihui.wang
Options

自动生成model、mapper、dao

parent 78731fed
Showing with 1418 additions and 975 deletions
freemud-pay-module/freemud-pay-push-message/pom.xml
......@@ -120,33 +120,77 @@
<artifactId>fastjson</artifactId>
<version>1.2.7</version>
</dependency>
<dependency>
<groupId>commons-lang</groupId>
<artifactId>commons-lang</artifactId>
<version>2.6</version>
</dependency>
<dependency>
<groupId>org.mybatis.generator</groupId>
<artifactId>mybatis-generator-core</artifactId>
<version>1.3.5</version>
</dependency>
<dependency>
<groupId>org.mybatis</groupId>
<artifactId>mybatis</artifactId>
<version>3.4.2</version>
</dependency>
</dependencies>
<!--<build>-->
<!--<plugins>-->
<!--&lt;!&ndash; spring-boot-maven-plugin (提供了直接运行项目的插件：如果是通过parent方式继承spring-boot-starter-parent则不用此插件) &ndash;&gt;-->
<!--<plugin>-->
<!--<groupId>org.springframework.boot</groupId>-->
<!--<artifactId>spring-boot-maven-plugin</artifactId>-->
<!--<version>1.3.6.RELEASE</version>-->
<!--<executions>-->
<!--<execution>-->
<!--<goals>-->
<!--<goal>repackage</goal>-->
<!--</goals>-->
<!--</execution>-->
<!--</executions>-->
<!--</plugin>-->
<!--<plugin>-->
<!--<groupId>org.apache.maven.plugins</groupId>-->
<!--<artifactId>maven-compiler-plugin</artifactId>-->
<!--<configuration>-->
<!--<source>1.6</source>-->
<!--<target>1.6</target>-->
<!--</configuration>-->
<!--</plugin>-->
<!--</plugins>-->
<!--</build>-->
<!--&lt;!&ndash;测试&ndash;&gt;-->
<build>
<plugins>
<!-- spring-boot-maven-plugin (提供了直接运行项目的插件：如果是通过parent方式继承spring-boot-starter-parent则不用此插件) -->
<plugin>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-maven-plugin</artifactId>
<version>${spring-boot.version}</version>
<groupId>org.mybatis.generator</groupId>
<artifactId>mybatis-generator-maven-plugin</artifactId>
<version>1.3.5</version>
<executions>
<execution>
<id>Generate MyBatis Artifacts</id>
<goals>
<goal>repackage</goal>
<goal>generate</goal>
</goals>
</execution>
</executions>
</plugin>
<plugin>
<groupId>org.apache.maven.plugins</groupId>
<artifactId>maven-compiler-plugin</artifactId>
<configuration>
<source>1.6</source>
<target>1.6</target>
</configuration>
</plugin>
</plugins>
<plugin>
<groupId>org.apache.maven.plugins</groupId>
<artifactId>maven-compiler-plugin</artifactId>
<configuration>
<source>1.6</source>
<target>1.6</target>
</configuration>
</plugin>
</plugins>
</build>
</project>
freemud-pay-module/freemud-pay-push-message/src/main/java/com/freemud/pay/job/dao/dbModel/Partner.java 0 → 100644
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/PartnerDM.java deleted 100644 → 0
package com.freemud.pay.job.dao.dbModel;
import javax.persistence.*;
@Table(name="partner")
public class PartnerDM extends BaseModel {
private static final long serialVersionUID = 5918340306801584347L;
@Id
@Column(name="ID")
@GeneratedValue(strategy = GenerationType.IDENTITY)
private Integer id;
@Column(name = "PartnerName")
private String partnerName;
@Column(name = "OurAccount_Partner")
private String ourAccountPartner;
@Column(name = "Logo")
private String logo;
@Column(name = "Description")
private String description;
@Column(name = "PartnerCode")
private String partnerCode;
@Column(name = "AppSecret")
private String appSecret;
@Column(name = "EBCode")
private String ebcode;
@Column(name = "EnableSMS")
private Boolean enableSms;
@Column(name = "PartnerType")
private String partnerType;
@Column(name = "UnifyId")
private String unifyId;
public Integer getId() {
return id;
}
public String getPartnerName() {
return partnerName;
}
public String getOurAccountPartner() {
return ourAccountPartner;
}
public String getLogo() {
return logo;
}
public String getDescription() {
return description;
}
public String getPartnerCode() {
return partnerCode;
}
public String getAppSecret() {
return appSecret;
}
public String getEbcode() {
return ebcode;
}
public Boolean getEnableSms() {
return enableSms;
}
public String getPartnerType() {
return partnerType;
}
public String getUnifyId() {
return unifyId;
}
public void setId(Integer id) {
this.id = id;
}
public void setPartnerName(String partnerName) {
this.partnerName = partnerName;
}
public void setOurAccountPartner(String ourAccountPartner) {
this.ourAccountPartner = ourAccountPartner;
}
public void setLogo(String logo) {
this.logo = logo;
}
public void setDescription(String description) {
this.description = description;
}
public void setPartnerCode(String partnerCode) {
this.partnerCode = partnerCode;
}
public void setAppSecret(String appSecret) {
this.appSecret = appSecret;
}
public void setEbcode(String ebcode) {
this.ebcode = ebcode;
}
public void setEnableSms(Boolean enableSms) {
this.enableSms = enableSms;
}
public void setPartnerType(String partnerType) {
this.partnerType = partnerType;
}
public void setUnifyId(String unifyId) {
this.unifyId = unifyId;
}
}
\ No newline at end of file
freemud-pay-module/freemud-pay-push-message/src/main/java/com/freemud/pay/job/dao/dbModel/PayDM.java deleted 100644 → 0
package com.freemud.pay.job.dao.dbModel;
import javax.persistence.Column;
import javax.persistence.GeneratedValue;
import javax.persistence.GenerationType;
import javax.persistence.Id;
import java.util.Date;
/**
* 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 PayDM extends BaseModel{
private static final long serialVersionUID = 5918340306801584347L;
@Id
@Column(name="ID")
@GeneratedValue(strategy = GenerationType.IDENTITY)
private Integer id;
@Column(name = "Store_Id")
private String storeId;
@Column(name = "Station_Id")
private String stationId;
@Column(name = "Operator_Id")
private String operatorId;
@Column(name = "Partner")
private String partner;
@Column(name = "PartnerAccount")
private String partnerAccount;
@Column(name = "PattnerOrderId")
private String pattnerOrderId;
@Column(name = "Code")
private String code;
@Column(name = "Amount")
private Double amount;
@Column(name = "State")
private Integer state;
@Column(name = "Subject")
private String subject;
@Column(name = "Remark")
private String remark;
@Column(name = "CreateUser")
private String createUser;
@Column(name = "CreateDate")
private Date createDate;
@Column(name = "CancelUser")
private String cancelUser;
@Column(name = "CancelDate")
private Date cancelDate;
@Column(name = "Tans_Id")
private String tansId;
@Column(name = "ZhuihuOrderID")
private String zhuihuOrderID;
@Column(name = "AlipayState")
private Integer alipayState;
@Column(name = "PlatformPartnerId")
private String platformPartnerId;
@Column(name = "PartnerId")
private Integer partnerId;
@Column(name = "PlatformBuyerUserId")
private String platformBuyerUserId;
@Column(name = "Platform")
private String platform;
@Column(name = "Mcoupon")
private Double mcoupon;
@Column(name = "BusinessDate")
private String businessDate;
@Column(name = "OrginalPayId")
private Integer orginalPayId;
@Column(name = "Pcoupon")
private Double pcoupon;
@Column(name = "LiquidatorCommissionRate")
private Double liquidatorCommissionRate;
@Column(name = "LiquidatorCommossonFee")
private Double liquidatorCommossonFee;
@Column(name = "BankCommissionFee")
private Double bankCommissionFee;
@Column(name = "BankCommissionRate")
private Double bankCommissionRate;
@Column(name = "PayPlatformRete")
private Double payPlatformRete;
@Column(name = "PayPlatformFee")
private Double payPlatformFee;
@Column(name = "NetAmount")
private Double netAmount;
public Integer getId() {
return id;
}
public void setId(Integer id) {
this.id = id;
}
public String getStoreId() {
return storeId;
}
public void setStoreId(String storeId) {
this.storeId = storeId;
}
public String getStationId() {
return stationId;
}
public void setStationId(String stationId) {
this.stationId = stationId;
}
public String getOperatorId() {
return operatorId;
}
public void setOperatorId(String operatorId) {
this.operatorId = operatorId;
}
public String getPartner() {
return partner;
}
public void setPartner(String partner) {
this.partner = partner;
}
public String getPartnerAccount() {
return partnerAccount;
}
public void setPartnerAccount(String partnerAccount) {
this.partnerAccount = partnerAccount;
}
public String getPattnerOrderId() {
return pattnerOrderId;
}
public void setPattnerOrderId(String pattnerOrderId) {
this.pattnerOrderId = pattnerOrderId;
}
public String getCode() {
return code;
}
public void setCode(String code) {
this.code = code;
}
public Double getAmount() {
return amount;
}
public void setAmount(Double amount) {
this.amount = amount;
}
public Integer getState() {
return state;
}
public void setState(Integer state) {
this.state = state;
}
public String getSubject() {
return subject;
}
public void setSubject(String subject) {
this.subject = subject;
}
public String getRemark() {
return remark;
}
public void setRemark(String remark) {
this.remark = remark;
}
public String getCreateUser() {
return createUser;
}
public void setCreateUser(String createUser) {
this.createUser = createUser;
}
public Date getCreateDate() {
return createDate;
}
public void setCreateDate(Date createDate) {
this.createDate = createDate;
}
public String getCancelUser() {
return cancelUser;
}
public void setCancelUser(String cancelUser) {
this.cancelUser = cancelUser;
}
public Date getCancelDate() {
return cancelDate;
}
public void setCancelDate(Date cancelDate) {
this.cancelDate = cancelDate;
}
public String getTansId() {
return tansId;
}
public void setTansId(String tansId) {
this.tansId = tansId;
}
public String getZhuihuOrderID() {
return zhuihuOrderID;
}
public void setZhuihuOrderID(String zhuihuOrderID) {
this.zhuihuOrderID = zhuihuOrderID;
}
public Integer getAlipayState() {
return alipayState;
}
public void setAlipayState(Integer alipayState) {
this.alipayState = alipayState;
}
public String getPlatformPartnerId() {
return platformPartnerId;
}
public void setPlatformPartnerId(String platformPartnerId) {
this.platformPartnerId = platformPartnerId;
}
public Integer getPartnerId() {
return partnerId;
}
public void setPartnerId(Integer partnerId) {
this.partnerId = partnerId;
}
public String getPlatformBuyerUserId() {
return platformBuyerUserId;
}
public void setPlatformBuyerUserId(String platformBuyerUserId) {
this.platformBuyerUserId = platformBuyerUserId;
}
public String getPlatform() {
return platform;
}
public void setPlatform(String platform) {
this.platform = platform;
}
public Double getMcoupon() {
return mcoupon;
}
public void setMcoupon(Double mcoupon) {
this.mcoupon = mcoupon;
}
public String getBusinessDate() {
return businessDate;
}
public void setBusinessDate(String businessDate) {
this.businessDate = businessDate;
}
public Integer getOrginalPayId() {
return orginalPayId;
}
public void setOrginalPayId(Integer orginalPayId) {
this.orginalPayId = orginalPayId;
}
public Double getPcoupon() {
return pcoupon;
}
public void setPcoupon(Double pcoupon) {
this.pcoupon = pcoupon;
}
public Double getLiquidatorCommissionRate() {
return liquidatorCommissionRate;
}
public void setLiquidatorCommissionRate(Double liquidatorCommissionRate) {
this.liquidatorCommissionRate = liquidatorCommissionRate;
}
public Double getLiquidatorCommossonFee() {
return liquidatorCommossonFee;
}
public void setLiquidatorCommossonFee(Double liquidatorCommossonFee) {
this.liquidatorCommossonFee = liquidatorCommossonFee;
}
public Double getBankCommissionFee() {
return bankCommissionFee;
}
public void setBankCommissionFee(Double bankCommissionFee) {
this.bankCommissionFee = bankCommissionFee;
}
public Double getBankCommissionRate() {
return bankCommissionRate;
}
public void setBankCommissionRate(Double bankCommissionRate) {
this.bankCommissionRate = bankCommissionRate;
}
public Double getPayPlatformRete() {
return payPlatformRete;
}
public void setPayPlatformRete(Double payPlatformRete) {
this.payPlatformRete = payPlatformRete;
}
public Double getPayPlatformFee() {
return payPlatformFee;
}
public void setPayPlatformFee(Double payPlatformFee) {
this.payPlatformFee = payPlatformFee;
}
public Double getNetAmount() {
return netAmount;
}
public void setNetAmount(Double netAmount) {
this.netAmount = netAmount;
}
}
\ No newline at end of file
freemud-pay-module/freemud-pay-push-message/src/main/java/com/freemud/pay/job/dao/dbModel/PayMessage.java 0 → 100644
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 0 → 100644
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/dbModel/PayMessageDM.java deleted 100644 → 0
package com.freemud.pay.job.dao.dbModel;
import javax.persistence.Column;
import javax.persistence.GeneratedValue;
import javax.persistence.GenerationType;
import javax.persistence.Id;
import java.util.Date;
/**
* 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 PayMessageDM extends BaseModel{
private static final long serialVersionUID = 5918340306801584347L;
@Id
@Column(name="ID")
@GeneratedValue(strategy = GenerationType.IDENTITY)
private Integer id;
@Column(name = "PartnerId")
private Integer partnerId;
@Column(name = "FmId")
private String fmId;
@Column(name = "TemplateId")
private String templateId;
@Column(name = "UserId")
private String userId;
@Column(name = "Status")
private Integer status;
@Column(name = "TTryTimes")
private Integer tryTimes;
@Column(name = "CreateDate")
private Date createDate;
@Column(name = "LastEditDate")
private Date lastEditDate;
@Column(name = "Code")
private String code;
@Column(name = "PayMessageActiveId")
private Integer payMessageActiveId;
public Integer getId() {
return id;
}
public void setId(Integer 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;
}
public String getTemplateId() {
return templateId;
}
public void setTemplateId(String templateId) {
this.templateId = templateId;
}
public String getUserId() {
return userId;
}
public void setUserId(String userId) {
this.userId = userId;
}
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;
}
public Integer getPayMessageActiveId() {
return payMessageActiveId;
}
public void setPayMessageActiveId(Integer payMessageActiveId) {
this.payMessageActiveId = payMessageActiveId;
}
}
\ No newline at end of file
freemud-pay-module/freemud-pay-push-message/src/main/java/com/freemud/pay/job/dao/mapper/PartnerDMMapper.java deleted 100644 → 0
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> {
}
\ No newline at end of file
freemud-pay-module/freemud-pay-push-message/src/main/java/com/freemud/pay/job/dao/mapper/PartnerMapper.java 0 → 100644
package com.freemud.pay.job.dao.mapper;
import com.freemud.pay.job.dao.dbModel.Partner;
public interface PartnerMapper {
int deleteByPrimaryKey(Integer id);
int insert(Partner record);
int insertSelective(Partner record);
Partner selectByPrimaryKey(Integer id);
int updateByPrimaryKeySelective(Partner record);
int updateByPrimaryKey(Partner 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 0 → 100644
package com.freemud.pay.job.dao.mapper;
import com.freemud.pay.job.dao.dbModel.Pay;
public interface PayMapper {
int deleteByPrimaryKey(Long id);
int insert(Pay record);
int insertSelective(Pay record);
Pay selectByPrimaryKey(Long id);
int updateByPrimaryKeySelective(Pay record);
int updateByPrimaryKey(Pay 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 0 → 100644
package com.freemud.pay.job.dao.mapper;
import com.freemud.pay.job.dao.dbModel.PayMessageActive;
public interface PayMessageActiveMapper {
int deleteByPrimaryKey(Long id);
int insert(PayMessageActive record);
int insertSelective(PayMessageActive record);
PayMessageActive selectByPrimaryKey(Long id);
int updateByPrimaryKeySelective(PayMessageActive record);
int updateByPrimaryKey(PayMessageActive 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 0 → 100644
package com.freemud.pay.job.dao.mapper;
import com.freemud.pay.job.dao.dbModel.PayMessage;
public interface PayMessageMapper {
int deleteByPrimaryKey(Long id);
int insert(PayMessage record);
int insertSelective(PayMessage record);
PayMessage selectByPrimaryKey(Long id);
int updateByPrimaryKeySelective(PayMessage record);
int updateByPrimaryKey(PayMessage record);
}
\ No newline at end of file
freemud-pay-module/freemud-pay-push-message/src/main/java/com/freemud/pay/job/dao/mapper/PayMessageDMMapper.java → freemud-pay-module/freemud-pay-push-message/src/main/java/com/freemud/pay/job/dao/repository/IPayMessageActiveRepository.java
package com.freemud.pay.job.dao.mapper;
package com.freemud.pay.job.dao.repository;
import com.freemud.pay.job.dao.IBaseDao;
import com.freemud.pay.job.dao.dbModel.PayMessageDM;
import com.freemud.pay.job.dao.dbModel.PayMessageActive;
import java.util.List;
/**
* All rights Reserved, Designed By www.freemud.cn
......@@ -14,5 +15,6 @@ import com.freemud.pay.job.dao.dbModel.PayMessageDM;
* @Copyright: 2017 www.freemud.cn Inc. All rights reserved.
* 注意：本内容仅限于上海非码科技内部传阅，禁止外泄以及用于其他的商业目
*/
public interface PayMessageDMMapper extends IBaseDao<PayMessageDM> {
public interface IPayMessageActiveRepository extends IBaseRepository{
PayMessageActive getPayMessageActive(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.entity.PayMessage;
import java.util.List;
/**
* All rights Reserved, Designed By www.freemud.cn
*
......@@ -12,4 +16,5 @@ package com.freemud.pay.job.dao.repository;
* 注意：本内容仅限于上海非码科技内部传阅，禁止外泄以及用于其他的商业目
*/
public interface IPayMessageRepository extends IBaseRepository{
List<PayMessage> getPayMessages(String dbPartition, String linkServer);
}
freemud-pay-module/freemud-pay-push-message/src/main/java/com/freemud/pay/job/dao/repository/Impl/PartnerRepositoryImpl.java
......@@ -2,21 +2,24 @@ package com.freemud.pay.job.dao.repository.Impl;
import com.freemud.pay.job.dao.IBaseDao;
import com.freemud.pay.job.dao.mapper.PartnerDMMapper;
import com.freemud.pay.job.dao.repository.IPartnerRepository;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.context.annotation.Primary;
import org.springframework.stereotype.Repository;
//
//@Primary
//@Repository
public class PartnerRepositoryImpl extends BaseRepositoryImpl implements IPartnerRepository {
@Autowired
private PartnerDMMapper partnerDMMapper;
@Primary
@Repository
public class PartnerRepositoryImpl extends BaseRepositoryImpl implements IPartnerRepository {
@Override
protected IBaseDao getDao() {
return partnerDMMapper;
return null;
}
// @Autowired
// PartnerDMMapper partnerDMMapper;
//
// @Override
// protected IBaseDao getDao() {
// return partnerDMMapper;
// }
}
freemud-pay-module/freemud-pay-push-message/src/main/java/com/freemud/pay/job/dao/repository/Impl/PayMessageActiveRepositoryImpl.java 0 → 100644
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.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
*
* @Title:
* @Package com.freemud.pay
* @Description:
* @author: lihui.wang
* @date:
* @Copyright: 2017 www.freemud.cn Inc. All rights reserved.
* 注意：本内容仅限于上海非码科技内部传阅，禁止外泄以及用于其他的商业目
*/
@Primary
@Repository
public class PayMessageActiveRepositoryImpl extends BaseRepositoryImpl implements IPayMessageActiveRepository {
@Autowired
PayMessageActiveMapper payMessageActiveMapper;
@Override
protected IBaseDao getDao() {
return null;
}
@Override
public PayMessageActive getPayMessageActive(long activeId, String dbPartition, String linkServer) {
return null;
}
// @Override
// public PayMessageActive getPayMessageActive(long activeId, String dbPartition, String linkServer) {
// return payMessageActiveMapper.getPayMessageActive(activeId,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/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.PayMessageDMMapper;
import com.freemud.pay.job.dao.repository.IPayMessageRepository;
import com.freemud.pay.job.entity.BaseParam;
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
*
......@@ -18,15 +22,21 @@ import org.springframework.stereotype.Repository;
* @Copyright: 2017 www.freemud.cn Inc. All rights reserved.
* 注意：本内容仅限于上海非码科技内部传阅，禁止外泄以及用于其他的商业目
*/
//@Primary
//@Repository
@Primary
@Repository
public class PayMessageRepositoryImpl extends BaseRepositoryImpl implements IPayMessageRepository {
@Autowired
private PayMessageDMMapper payMessageDMMapper;
PayMessageDMMapper payMessageDMMapper;
@Override
protected IBaseDao getDao() {
return payMessageDMMapper;
}
@Override
public List<PayMessageDM> getPayMessages(String dbPartition, String linkServer) {
return payMessageDMMapper.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
......@@ -2,12 +2,17 @@ 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.PayDMMapper;
import com.freemud.pay.job.dao.repository.IPayMessageRepository;
import com.freemud.pay.job.dao.repository.IPayRepository;
import com.freemud.pay.job.entity.BaseParam;
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
*
......@@ -19,15 +24,21 @@ import org.springframework.stereotype.Repository;
* @Copyright: 2017 www.freemud.cn Inc. All rights reserved.
* 注意：本内容仅限于上海非码科技内部传阅，禁止外泄以及用于其他的商业目
*/
//@Primary
//@Repository
public class PayRepositoryImpl extends BaseRepositoryImpl implements IPayMessageRepository {
@Autowired
private PayDMMapper payDMMapper;
@Primary
@Repository
public class PayRepositoryImpl extends BaseRepositoryImpl implements IPayRepository {
@Override
protected IBaseDao getDao() {
return payDMMapper;
return null;
}
// @Autowired
// PayDMMapper payDMMapper;
//
// @Override
// protected IBaseDao getDao() {
// return payDMMapper;
// }
}
\ No newline at end of file
freemud-pay-module/freemud-pay-push-message/src/main/java/com/freemud/pay/job/entity/PayMessage.java 0 → 100644
package com.freemud.pay.job.entity;
import com.freemud.pay.job.dao.dbModel.PayMessageActiveDM;
import com.freemud.pay.job.dao.dbModel.PayMessageDM;
/**
* 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 PayMessage {
private BaseParam baseParam;
private PayMessageDM payMessageDM;
private PayMessageActiveDM payMessageActiveDM;
public BaseParam getBaseParam() {
return baseParam;
}
public void setBaseParam(BaseParam baseParam) {
this.baseParam = baseParam;
}
public PayMessageDM getPayMessageDM() {
return payMessageDM;
}
public void setPayMessageDM(PayMessageDM payMessageDM) {
this.payMessageDM = payMessageDM;
}
public PayMessageActiveDM getPayMessageActiveDM() {
return payMessageActiveDM;
}
public void setPayMessageActiveDM(PayMessageActiveDM payMessageActiveDM) {
this.payMessageActiveDM = payMessageActiveDM;
}
}
\ No newline at end of file
freemud-pay-module/freemud-pay-push-message/src/main/java/com/freemud/pay/job/jobhandler/PayMessageJobHandler.java
......@@ -2,10 +2,12 @@ package com.freemud.pay.job.jobhandler;
import com.alibaba.fastjson.JSON;
import com.freemud.pay.job.entity.BaseParam;
import com.freemud.pay.job.service.IPayMessageService;
import com.xxl.job.core.biz.model.ReturnT;
import com.xxl.job.core.handler.IJobHandler;
import com.xxl.job.core.handler.annotation.JobHandler;
import com.xxl.job.core.log.XxlJobLogger;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Component;
/**
......@@ -23,8 +25,8 @@ import org.springframework.stereotype.Component;
@Component
public class PayMessageJobHandler extends IJobHandler {
// @Autowired
// private IPayMessageService payMessageService;
@Autowired
private IPayMessageService payMessageService;
@Override
public ReturnT<String> execute(String param) throws Exception {
......@@ -32,7 +34,7 @@ public class PayMessageJobHandler extends IJobHandler {
BaseParam baseRequest = JSON.parseObject(param,BaseParam.class);
System.out.println(baseRequest.getBussinessType()+" "+baseRequest.getDbPartition()+" "+baseRequest.getLinkServer());
XxlJobLogger.log("PAYMESSAGE-JOB, START");
// payMessageService.pushMessage();
payMessageService.pushMessage(baseRequest);
XxlJobLogger.log("PAYMESSAGE-JOB, END");
return SUCCESS;
}
......
freemud-pay-module/freemud-pay-push-message/src/main/java/com/freemud/pay/job/dao/mapper/PayDMMapper.java → freemud-pay-module/freemud-pay-push-message/src/main/java/com/freemud/pay/job/service/IMessageProcessor.java
package com.freemud.pay.job.dao.mapper;
package com.freemud.pay.job.service;
import com.freemud.pay.job.dao.IBaseDao;
import com.freemud.pay.job.dao.dbModel.PayDM;
import com.freemud.pay.job.entity.PayMessage;
/**
* All rights Reserved, Designed By www.freemud.cn
......@@ -14,5 +13,6 @@ import com.freemud.pay.job.dao.dbModel.PayDM;
* @Copyright: 2017 www.freemud.cn Inc. All rights reserved.
* 注意：本内容仅限于上海非码科技内部传阅，禁止外泄以及用于其他的商业目
*/
public interface PayDMMapper extends IBaseDao<PayDM> {
public interface IMessageProcessor {
Boolean Process(PayMessage payMessage);
}
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 java.util.List;
/**
* All rights Reserved, Designed By www.freemud.cn
*
......@@ -12,5 +17,5 @@ package com.freemud.pay.job.service;
* 注意：本内容仅限于上海非码科技内部传阅，禁止外泄以及用于其他的商业目
*/
public interface IPayMessageService {
public void pushMessage();
void pushMessage(BaseParam baseRequest );
}
freemud-pay-module/freemud-pay-push-message/src/main/java/com/freemud/pay/job/service/MessageProcessorFactory.java 0 → 100644
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.service.impl.AliFuWuChuangSingleMessageSender;
import org.apache.commons.lang.StringUtils;
/**
* 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 MessageProcessorFactory {
public static IMessageProcessor GetMessageProcessor(PayMessageDM messasge, PayMessageActiveDM active)
{
if (active == null
|| StringUtils.isEmpty(active.getAction()))
{
return null;
}
String s = active.getAction().toLowerCase();
if ("ali.single.send".equals(s)) {
return new AliFuWuChuangSingleMessageSender();
} else {
return null;
}
}
}
\ No newline at end of file
freemud-pay-module/freemud-pay-push-message/src/main/java/com/freemud/pay/job/service/impl/AliFuWuChuangSingleMessageSender.java 0 → 100644
package com.freemud.pay.job.service.impl;
import com.freemud.pay.job.entity.PayMessage;
import com.freemud.pay.job.service.IMessageProcessor;
/**
* 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 AliFuWuChuangSingleMessageSender implements IMessageProcessor {
@Override
public Boolean Process(PayMessage payMessage) {
// var account = new PayPlatformAccountRepository().GetPayPlatformAccount(context.Message.PartnerId,
// PayPlatformAccountRepository.PLATFORM_ALI_FWC, context.BussinessType, context.DBPartition);
// if (account == null)
// {
// context.NoRetry = true;
// return false;
// }
// try
// {
//
// Logger.Info("process:" + context.Message.Id);
// var url = ConfigurationManager.AppSettings["alipay_gateway"];
// var req = new AlipayMobilePublicMessageSingleSendRequest();
// req.BizContent = TemplateHelper.Interprent(context);
// // Logger.Info("account.PlatformAppId:" + account.PlatformAppId + ",account.PlatformAppId:" + account.CerFile);
// var client = new DefaultAopClient(url, account.PlatformAppId, account.CerFile);
// Stopwatch stopwatch = new Stopwatch();
// stopwatch.Start();
// var rsp = client.Execute(req, null, account.AuthCode);
// stopwatch.Stop();
// string timeCost = "timecost:" + stopwatch.ElapsedMilliseconds;
// if (rsp.Code == "200")
// {
// Logger.Info(timeCost+" \tsend:" + req.BizContent + "\tget response:" + rsp.Body);
// return true;
// }
// else if (rsp.Code == "12007")//未关注
// {
// Logger.Warn(timeCost + " \tsend:" + JsonUtility.ToJson(req) + "\tget response:" + rsp.Body);
// new Repository().UpdateMessageStatus(context.Message.Id, context.BussinessType, context.DBPartition);
// return false;
// }
// else
// {
// Logger.Warn(timeCost + " \tsend:" + JsonUtility.ToJson(req) + "\tget response:" + rsp.Body);
// return false;
// }
// }
// catch (Exception ex)
// {
// Logger.Warn(string.Format("failed process #{0},exception:{1}", context.Message.Id, ex));
// return false;
// }
return null;
}
}
\ No newline at end of file
freemud-pay-module/freemud-pay-push-message/src/main/java/com/freemud/pay/job/service/impl/PayMessageServiceImpl.java
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 org.apache.commons.lang.StringUtils;
import org.springframework.beans.factory.annotation.Autowired;
import java.util.ArrayList;
import java.util.List;
/**
* All rights Reserved, Designed By www.freemud.cn
......@@ -16,7 +29,90 @@ import com.freemud.pay.job.service.IPayMessageService;
*/
public class PayMessageServiceImpl implements IPayMessageService {
public void pushMessage() {
@Autowired
IPayMessageRepository iPayMessageRepository;
@Autowired
IPayMessageActiveRepository iPayMessageActiveRepository;
@Override
public void pushMessage(BaseParam baseParam) {
String bussinessType = baseParam.getBussinessType();
if (!bussinessType.isEmpty()){
String linkServer = baseParam.getLinkServer();
if (linkServer.isEmpty()){
linkServer = "";
}
if (linkServer.substring(linkServer.length()-1).equals(".")){
linkServer = linkServer + ".";
}
String dbPartition= baseParam.getDbPartition();
//第一步：获取数据
List<PayMessageDM> payMessages=getPayMessages(baseParam.getDbPartition(),linkServer);
for (PayMessageDM message :payMessages){
if (message.getPayMessageActiveId()<0)
{
MarkMessageAsNoProcess(message,bussinessType,dbPartition);
return;
}
PayMessageActiveDM active = iPayMessageActiveRepository.getPayMessageActive(message.getPayMessageActiveId(), bussinessType, dbPartition);
if (active == null
|| StringUtils.isEmpty(active.getAction()))
{
MarkMessageAsNoProcess(message, bussinessType, dbPartition);
return;
}
boolean result = false;
try
{
IMessageProcessor processor = MessageProcessorFactory.GetMessageProcessor(message, active);
PayMessage payMessage=new PayMessage();
payMessage.setBaseParam(baseParam);
payMessage.setPayMessageDM(message);
payMessage.setPayMessageActiveDM(active);
result = (processor == null)
? false
: processor.Process(payMessage);
}
catch (Exception ex)
{
//Logger.Warn(string.Format("failed process #{0},exception:{1}", message.Id, ex));
}
if (result)
{
MarkMessageAsSuccess(message, bussinessType, dbPartition);
}
else
{
MarkMessageAsFailed(message, bussinessType, dbPartition);
}
}
}
}
private void MarkMessageAsSuccess(PayMessageDM message, String bussinessType, String dbPartition) {
}
private void MarkMessageAsFailed(PayMessageDM message, String bussinessType, String dbPartition) {
}
private void MarkMessageAsNoProcess(PayMessageDM message, String bussinessType, String dbPartition) {
}
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/util/DBName.java deleted 100644 → 0
package com.freemud.pay.job.service.util;
import java.text.ParseException;
import java.text.SimpleDateFormat;
import java.util.Date;
/**
* 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 DBName {
public static void main(String[] args) {
String string = "2015-02-10 22:00:00";
SimpleDateFormat format = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
Date d1;
try {
d1 = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss").parse(string);
System.out.println("DateTime d1>>>>>>: " + d1);
String d2 = format.format(d1);
System.out.println("DateTime d2>>>>>>: " + d2);
Date d3;
d3 = format.parse(d2);
System.out.println("DateTime d3>>>>>>: " + format.format(d3));
} catch (ParseException e1) {
// TODO Auto-generated catch block
e1.printStackTrace();
}
}
}
\ No newline at end of file
freemud-pay-module/freemud-pay-push-message/src/main/resources/mapper/PartnerDMMapper.xml deleted 100644 → 0
<?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 property="id" column="ID" />
<result property="partnerName" column="PartnerName" />
<result property="ourAccountPartner" column="OurAccount_Partner" />
<result property="logo" column="Logo" />
<result property="description" column="Description" />
<result property="partnerCode" column="PartnerCode" />
<result property="appSecret" column="AppSecret" />
<result property="ebcode" column="EBCode" />
<result property="enableSms" column="EnableSMS" />
<result property="partnerType" column="PartnerType" />
<result property="unifyId" column="UnifyId" />
</resultMap>
<sql id="Base_Column_List" >
ID, PartnerName, OurAccount_Partner, Logo, Description, PartnerCode, AppSecret, EBCode,
EnableSMS, PartnerType, UnifyId
</sql>
<select id="getPartnerByPartnerId" resultMap="BaseResultMap" parameterType="java.lang.Integer" >
select
<include refid="Base_Column_List" />
from partner
where ID = #{partnerId,jdbcType=INTEGER}
</select>
<select id="getPartnerByPartnerCode" resultMap="BaseResultMap" parameterType="java.lang.String" >
select
<include refid="Base_Column_List" />
from partner
where partnerCode = #{partnerCode,jdbcType=VARCHAR}
</select>
</mapper>
\ No newline at end of file
freemud-pay-module/freemud-pay-push-message/src/main/resources/mapper/PartnerMapper.xml 0 → 100644
<?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">
<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.Partner">
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.Partner">
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.Partner">
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.Partner">
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/PayDMMapper.xml deleted 100644 → 0
<?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.PayDMMapper" >
<resultMap id="BaseResultMap" type="com.freemud.pay.job.dao.dbModel.PayDM" >
<id property="id" column="ID" />
<result property="storeId" column="Store_Id" />
<result property="stationId" column="Station_Id" />
<result property="operatorId" column="Operator_Id" />
<result property="partner" column="Partner" />
<result property="partnerAmount" column="PartnerAmount" />
<result property="partnerOrderId" column="PartnerOrderId" />
<result property="platformTradeAccount" column="PlatformTradeAccount" />
<result property="platformTradeNumber" column="PlatformTradeNumber" />
<result property="code" column="Code" />
<result property="amount" column="Amount" />
<result property="state" column="State" />
<result property="subject" column="Subject" />
<result property="remark" column="Remark" />
<result property="createUser" column="CreateUser" />
<result property="createDate" column="CreateDate" />
<result property="cancelUser" column="CancelUser" />
<result property="cancelDate" column="CancelDate" />
<result property="transId" column="Trans_Id" />
<result property="zhuiHuOrderId" column="ZhuiHuOrderId" />
<result property="alipayState" column="AlipayState" />
<result property="platformPartnerId" column="PlatformPartnerId" />
<result property="partnerId" column="PartnerId" />
<result property="platformBuyerUserId" column="PlatformBuyerUserId" />
<result property="platform" column="Platform" />
<result property="mcoupon" column="mcoupon" />
<result property="businessDate" column="BusinessDate" />
<result property="orginalPayId" column="OrginalPayId" />
<result property="pcoupon" column="pcoupon" />
<result property="liquidatorCommissonRate" column="LiquidatorCommissonRate" />
<result property="liquidatorCommissonFee" column="LiquidatorCommissonFee" />
<result property="bankCommissionRate" column="BankCommissionRate" />
<result property="bankCommissionFee" column="BankCommissionFee" />
<result property="payPlatformRate" column="PayPlatformRate" />
<result property="payPlatformFee" column="PayPlatformFee" />
<result property="netAmount" column="NetAmount" />
</resultMap>
<sql id="Base_Column_List" >
ID, Store_Id, Station_Id, Operator_Id, Partner, PartnerAmount, PartnerOrderId, PlatformTradeAccount,PlatformTradeNumber,Code,Amount,State,Subject,
Remark,CreateUser,CreateDate,CancelUser,Trans_Id,ZhuiHuOrderId,AlipayState,PlatformPartnerId,PartnerId,PlatformBuyerUserId,Platform,mcoupon,BusinessDate,
OrginalPayId,pcoupon,LiquidatorCommissonRate,LiquidatorCommissonFee,BankCommissionRate,BankCommissionFee,PayPlatformRate,PayPlatformFee,NetAmount
</sql>
<select id="getPayByPayId" resultMap="BaseResultMap" parameterType="java.lang.Integer" >
select
<include refid="Base_Column_List" />
from pay
where ID = #{partnerId,jdbcType=INTEGER}
</select>
<select id="getPayByPayCode" resultMap="BaseResultMap" parameterType="java.lang.String" >
select
<include refid="Base_Column_List" />
from pay
where code = #{Code,jdbcType=VARCHAR}
</select>
</mapper>
\ No newline at end of file
freemud-pay-module/freemud-pay-push-message/src/main/resources/mapper/PayMessageDMMapper.xml deleted 100644 → 0
<?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 property="id" column="ID" />
<result property="partnerId" column="PartnerId" />
<result property="fmId" column="FmId" />
<result property="templateId" column="TemplateId" />
<result property="userId" column="UserId" />
<result property="status" column="Status" />
<result property="tryTimes" column="TryTimes" />
<result property="createDate" column="CreateDate" />
<result property="lastEditDate" column="LastEditDate" />
<result property="code" column="Code" />
<result property="payMessageActiveID" column="Pay_Message_Active_ID" />
</resultMap>
<sql id="Base_Column_List" >
ID,PartnerId,FmId,TemplateId,UserId,Status,TryTimes,CreateDate,LastEditDate,Code,Pay_Message_Active_ID
</sql>
<select id="getPayMessaeByfmId" parameterType="Map" resultMap="BaseResultMap">
SELECT
<include refid="Base_Column_List"/>
from ${dbName}.dbo.pay_message with(nolock)
WHERE fmId = #{fmId}
AND
createdate
BETWEEN
dateadd(minute,-2,CONVERT(varchar(16),#{createDate},120))
AND
dateadd(minute,2,CONVERT(varchar(16),#{createDate},120))
<!--UNION ALL-->
<!--SELECT-->
<!--<include refid="Base_Column_List"/>-->
<!--from SH_PAY_DB_Log2.${dbName}.dbo.Pay_Alipay_API_Log with(nolock)-->
<!--WHERE ZhuiHuOrderId = #{zhuiHuOrderId}-->
<!--AND-->
<!--createdate-->
<!--BETWEEN-->
<!--dateadd(minute,-1,CONVERT(varchar(16),#{createDate},120))-->
<!--AND-->
<!--dateadd(minute,1,CONVERT(varchar(16),#{createDate},120))-->
</select>
<select id="getPayMessageQuartzJobsMcd" 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 {0}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 &gt; GETDATE()
AND a.PartnerId = 1587
</select>
<select id="getPayMessageQuartzJobsMcdOther" 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
FROM [Freemud_ThirdParty].[dbo].[Pay_Message] a WITH ( NOLOCK )
INNER JOIN {0}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 &gt; DATEADD(MINUTE,-30, GETDATE())
AND a.LastEditDate &lt; GETDATE()
and a.PartnerID &lt;&gt; 1205
</select>
<select id="getPayMessage" 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 {0}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())
</select>
</mapper>
\ No newline at end of file
freemud-pay-module/freemud-pay-push-message/src/main/resources/mapper/PayMessageMapper.xml 0 → 100644
<?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">
<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.PayMessage">
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.PayMessage">
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.PayMessage">
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.PayMessage">
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>
</mapper>
\ No newline at end of file
xxl-job-executor-samples/pom.xml
......@@ -15,7 +15,7 @@
<module>xxl-job-executor-sample-springboot</module>
<module>xxl-job-executor-sample-jfinal</module>
<module>xxl-job-executor-sample-nutz</module>
<module>freemud-executor-sample-message</module>
<module>../freemud-pay-module/freemud-pay-push-message</module>
</modules>
</project>
\ No newline at end of file
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