diff --git a/build.gradle b/build.gradle
index ea080fb..381e261 100644
--- a/build.gradle
+++ b/build.gradle
@@ -25,11 +25,14 @@
     providedRuntime 'org.springframework.boot:spring-boot-starter-tomcat'
     testImplementation 'org.springframework.boot:spring-boot-starter-test'
 
+    compile group: 'com.sun.jersey', name: 'jersey-client', version:'1.19'
     compile group: 'javax.servlet', name: 'jstl', version: '1.2'
     compile group: 'taglibs', name: 'standard', version: '1.1.2'
     compile group: 'javax.servlet.jsp', name: 'jsp-api', version: '2.1'
     compile group: 'log4j', name: 'log4j', version: '1.2.16'
     compile files ('libs/ojdbc6.jar')
+
+    compile group: 'com.google.code.gson', name: 'gson', version: '2.8.5'
 }
 
 compileKotlin {
diff --git a/src/main/java/com/supwisdom/dlpay/consume/bean/BaseResp.java b/src/main/java/com/supwisdom/dlpay/consume/bean/BaseResp.java
index 8c4c8a1..1df37a7 100644
--- a/src/main/java/com/supwisdom/dlpay/consume/bean/BaseResp.java
+++ b/src/main/java/com/supwisdom/dlpay/consume/bean/BaseResp.java
@@ -1,31 +1,38 @@
 package com.supwisdom.dlpay.consume.bean;
 
+import com.supwisdom.dlpay.util.Code;
+
 public class BaseResp {
-  private String retcode;
-  private String retmsg;
-  private Object data;
+    private String retcode;
+    private String retmsg;
+    private Object data;
 
-  public String getRetcode() {
-    return retcode;
-  }
+    public String getRetcode() {
+        return retcode;
+    }
 
-  public void setRetcode(String retcode) {
-    this.retcode = retcode;
-  }
+    public void setRetcode(String retcode) {
+        this.retcode = retcode;
+    }
 
-  public String getRetmsg() {
-    return retmsg;
-  }
+    public String getRetmsg() {
+        return retmsg;
+    }
 
-  public void setRetmsg(String retmsg) {
-    this.retmsg = retmsg;
-  }
+    public void setRetmsg(String retmsg) {
+        this.retmsg = retmsg;
+    }
 
-  public Object getData() {
-    return data;
-  }
+    public Object getData() {
+        return data;
+    }
 
-  public void setData(Object data) {
-    this.data = data;
-  }
+    public void setData(Object data) {
+        this.data = data;
+    }
+
+    public void setCode(Code code) {
+        this.retcode = code.getCode();
+        this.retmsg = code.getRetmsg();
+    }
 }
diff --git a/src/main/java/com/supwisdom/dlpay/consume/bean/ReqParam.java b/src/main/java/com/supwisdom/dlpay/consume/bean/ReqParam.java
new file mode 100644
index 0000000..31fac50
--- /dev/null
+++ b/src/main/java/com/supwisdom/dlpay/consume/bean/ReqParam.java
@@ -0,0 +1,147 @@
+package com.supwisdom.dlpay.consume.bean;
+
+/**
+ * Created by shuwei on 2019/4/9.
+ */
+public class ReqParam {
+    /**
+    * 交易流水号
+    * */
+    private String refno;
+    /**
+     * 交易金额(分)
+     * */
+    private Integer amount;
+    /**
+     * 支付渠道
+     * */
+    private String paytype;
+    /**
+     * 订单信息
+     * */
+    private String payinfo;
+    /**
+     * 订单详细
+     * */
+    private String transdesc;
+    /**
+     * 交易日期
+     * */
+    private String transdate;
+    /**
+     * 交易时间
+     * */
+    private String transtime;
+    /**
+     * 账号
+     * */
+    private String accno;
+    /**
+     * 商户号
+     * */
+    private String shopaccno;
+    /**
+     * 签名
+     * */
+    private String sign;
+
+
+    private String yktshopid;
+    private String devphyid;
+
+    public String getYktshopid() {
+        return yktshopid;
+    }
+
+    public void setYktshopid(String yktshopid) {
+        this.yktshopid = yktshopid;
+    }
+
+    public String getDevphyid() {
+        return devphyid;
+    }
+
+    public void setDevphyid(String devphyid) {
+        this.devphyid = devphyid;
+    }
+
+    public String getRefno() {
+        return refno;
+    }
+
+    public void setRefno(String refno) {
+        this.refno = refno;
+    }
+
+    public Integer getAmount() {
+        return amount;
+    }
+
+    public void setAmount(Integer amount) {
+        this.amount = amount;
+    }
+
+    public String getPaytype() {
+        return paytype;
+    }
+
+    public void setPaytype(String paytype) {
+        this.paytype = paytype;
+    }
+
+    public String getPayinfo() {
+        return payinfo;
+    }
+
+    public void setPayinfo(String payinfo) {
+        this.payinfo = payinfo;
+    }
+
+    public String getTransdesc() {
+        return transdesc;
+    }
+
+    public void setTransdesc(String transdesc) {
+        this.transdesc = transdesc;
+    }
+
+    public String getTransdate() {
+        return transdate;
+    }
+
+    public void setTransdate(String transdate) {
+        this.transdate = transdate;
+    }
+
+    public String getTranstime() {
+        return transtime;
+    }
+
+    public void setTranstime(String transtime) {
+        this.transtime = transtime;
+    }
+
+    public String getAccno() {
+        return accno;
+    }
+
+    public void setAccno(String accno) {
+        this.accno = accno;
+    }
+
+    public String getShopaccno() {
+        return shopaccno;
+    }
+
+    public void setShopaccno(String shopaccno) {
+        this.shopaccno = shopaccno;
+    }
+
+    public String getSign() {
+        return sign;
+    }
+
+    public void setSign(String sign) {
+        this.sign = sign;
+    }
+}
diff --git a/src/main/java/com/supwisdom/dlpay/consume/bean/SupStatusRevResp.java b/src/main/java/com/supwisdom/dlpay/consume/bean/SupStatusRevResp.java
new file mode 100644
index 0000000..355fd3d
--- /dev/null
+++ b/src/main/java/com/supwisdom/dlpay/consume/bean/SupStatusRevResp.java
@@ -0,0 +1,25 @@
+package com.supwisdom.dlpay.consume.bean;
+
+/**
+ * Created by shuwei on 2018/10/18.
+ */
+public class SupStatusRevResp {
+    private Integer status;
+    private Boolean revflag;
+
+    public Integer getStatus() {
+        return status;
+    }
+
+    public void setStatus(Integer status) {
+        this.status = status;
+    }
+
+    public Boolean getRevflag() {
+        return revflag;
+    }
+
+    public void setRevflag(Boolean revflag) {
+        this.revflag = revflag;
+    }
+}
diff --git a/src/main/java/com/supwisdom/dlpay/consume/bean/SupYktResp.java b/src/main/java/com/supwisdom/dlpay/consume/bean/SupYktResp.java
new file mode 100644
index 0000000..32caa3e
--- /dev/null
+++ b/src/main/java/com/supwisdom/dlpay/consume/bean/SupYktResp.java
@@ -0,0 +1,92 @@
+package com.supwisdom.dlpay.consume.bean;
+
+/**
+ * Created by shuwei on 2018/8/28.
+ */
+public class SupYktResp {
+    private String retcode;
+    private String retmsg;
+    private String tradeno;
+    private String refno;
+    private String sign;
+    private String timestamp;
+    private String sign_method;
+    private Integer balance;
+    private String other;
+
+    public String getOther() {
+        return other;
+    }
+
+    public void setOther(String other) {
+        this.other = other;
+    }
+
+    public String getRetcode() {
+        return retcode;
+    }
+
+    public void setRetcode(String retcode) {
+        this.retcode = retcode;
+    }
+
+    public String getRetmsg() {
+        return retmsg;
+    }
+
+    public void setRetmsg(String retmsg) {
+        this.retmsg = retmsg;
+    }
+
+    public String getTradeno() {
+        return tradeno;
+    }
+
+    public void setTradeno(String tradeno) {
+        this.tradeno = tradeno;
+    }
+
+    public String getRefno() {
+        return refno;
+    }
+
+    public void setRefno(String refno) {
+        this.refno = refno;
+    }
+
+    public String getSign() {
+        return sign;
+    }
+
+    public void setSign(String sign) {
+        this.sign = sign;
+    }
+
+    public String getTimestamp() {
+        return timestamp;
+    }
+
+    public void setTimestamp(String timestamp) {
+        this.timestamp = timestamp;
+    }
+
+    public String getSign_method() {
+        return sign_method;
+    }
+
+    public void setSign_method(String sign_method) {
+        this.sign_method = sign_method;
+    }
+
+    public Integer getBalance() {
+        return balance;
+    }
+
+    public void setBalance(Integer balance) {
+        this.balance = balance;
+    }
+
+    public boolean checkSign(String appid,String key){
+        return true;
+    }
+}
diff --git a/src/main/java/com/supwisdom/dlpay/consume/controller/PayapiAction.java b/src/main/java/com/supwisdom/dlpay/consume/controller/PayapiAction.java
new file mode 100644
index 0000000..ac7d7fe
--- /dev/null
+++ b/src/main/java/com/supwisdom/dlpay/consume/controller/PayapiAction.java
@@ -0,0 +1,98 @@
+package com.supwisdom.dlpay.consume.controller;
+
+import com.supwisdom.dlpay.consume.bean.BaseResp;
+import com.supwisdom.dlpay.consume.bean.ReqParam;
+import com.supwisdom.dlpay.consume.service.PayapiService;
+import com.supwisdom.dlpay.consume.service.PaytypeService;
+import com.supwisdom.dlpay.framework.data.SystemDateTime;
+import com.supwisdom.dlpay.util.Code;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.util.StringUtils;
+import org.springframework.web.bind.annotation.RequestBody;
+import org.springframework.web.bind.annotation.RequestMapping;
+import org.springframework.web.bind.annotation.RestController;
+
+/**
+ * 统一支付入口
+ * 1.支付
+ * 2.冲正
+ * 3.充值
+ *
+ * 校验
+ * -参数
+ * -签名
+ */
+@RestController
+@RequestMapping("/unified")
+public class PayapiAction {
+    @Autowired
+    private PayapiService payapiService;
+
+    /**
+     * 公共参数校验
+     * */
+
+    private boolean checkCommonParam(BaseResp resp,ReqParam param){
+        if(param.getAmount()==null){
+            resp.setRetcode("1");
+            resp.setRetmsg("参数错误[amount]");
+            return false;
+        }
+        if(StringUtils.isEmpty(param.getPayinfo())){
+            resp.setRetcode("1");
+            resp.setRetmsg("参数错误[payinfo]");
+            return false;
+        }
+        if(StringUtils.isEmpty(param.getPaytype())){
+            resp.setRetcode("1");
+            resp.setRetmsg("参数错误[paytype]");
+            return false;
+        }
+        if(StringUtils.isEmpty(param.getRefno())){
+            resp.setRetcode("1");
+            resp.setRetmsg("参数错误[refno]");
+            return false;
+        }
+        return true;
+    }
+    /**
+     *
+     * 统一消费接口
+     *
+     *
+     * */
+    @RequestMapping("/consume")
+    public BaseResp consume(@RequestBody ReqParam param) {
+        BaseResp resp = new BaseResp();
+        if(!checkCommonParam(resp,param)){
+            return resp;
+        }
+        payapiService.doConsume(param,resp);
+        return resp;
+    }
+
+    /**
+     *
+     * 统一冲正接口
+     *
+     *
+     * */
+    @RequestMapping("/reverse")
+    public BaseResp reverse() {
+        BaseResp resp = new BaseResp();
+        resp.setCode(Code.SUCCESS);
+        return resp;
+    }
+
+    /**
+     *
+     * 统一充值接口
+     *
+     * */
+    @RequestMapping("/recharge")
+    public BaseResp recharge() {
+        BaseResp resp = new BaseResp();
+        resp.setCode(Code.SUCCESS);
+        return resp;
+    }
+}
diff --git a/src/main/java/com/supwisdom/dlpay/consume/dao/PaytypeConfigDao.java b/src/main/java/com/supwisdom/dlpay/consume/dao/PaytypeConfigDao.java
new file mode 100644
index 0000000..62afecc
--- /dev/null
+++ b/src/main/java/com/supwisdom/dlpay/consume/dao/PaytypeConfigDao.java
@@ -0,0 +1,14 @@
+package com.supwisdom.dlpay.consume.dao;
+
+import com.supwisdom.dlpay.consume.domain.TPaytypeConfig;
+import com.supwisdom.dlpay.consume.domain.TPaytypeConfigPK;
+import org.springframework.data.jpa.repository.JpaRepository;
+
+import java.util.List;
+
+/**
+ * Created by shuwei on 2019/4/9.
+ */
+public interface PaytypeConfigDao extends JpaRepository<TPaytypeConfig, TPaytypeConfigPK> {
+    List<TPaytypeConfig> getByPaytype(String paytype);
+}
diff --git a/src/main/java/com/supwisdom/dlpay/consume/dao/PaytypeDao.java b/src/main/java/com/supwisdom/dlpay/consume/dao/PaytypeDao.java
new file mode 100644
index 0000000..79e97c1
--- /dev/null
+++ b/src/main/java/com/supwisdom/dlpay/consume/dao/PaytypeDao.java
@@ -0,0 +1,10 @@
+package com.supwisdom.dlpay.consume.dao;
+
+import com.supwisdom.dlpay.consume.domain.TPaytype;
+import org.springframework.data.jpa.repository.JpaRepository;
+
+/**
+ * Created by shuwei on 2019/4/9.
+ */
+public interface PaytypeDao extends JpaRepository<TPaytype, String> {
+}
diff --git a/src/main/java/com/supwisdom/dlpay/consume/dao/TransdtlDao.java b/src/main/java/com/supwisdom/dlpay/consume/dao/TransdtlDao.java
index a7c2c4f..ff74e33 100644
--- a/src/main/java/com/supwisdom/dlpay/consume/dao/TransdtlDao.java
+++ b/src/main/java/com/supwisdom/dlpay/consume/dao/TransdtlDao.java
@@ -22,4 +22,12 @@
       "where t.status='success' and t.feetype!='none' and t.accdate=:settledate " +
       "group by a.drsubjno,a.crsubjno,a.summary,t.shopaccno ", nativeQuery = true)
   List<VoucherTemp> getFeeVoucherData(@RequestParam("settledate") String settledate);
+
+  TTransdtl getByOuttradenoAndStatus(String outtradeno,String status);
+
+  @Query(value = " select to_char(sysdate,'yyyyMMddhh24missSSS')||to_char(SEQ_REFNO.nextval,'FM0000000') as billno from dual ",nativeQuery = true)
+  String getReno();
+
+  @Query(value = " select to_char(CURRENT_TIMESTAMP,'yyyyMMddhh24missSS')||to_char(nextval('SEQ_REFNO'),'FM0000000') as billno ",nativeQuery = true)
+  String getRenoPG();
 }
diff --git a/src/main/java/com/supwisdom/dlpay/consume/domain/TPaytype.java b/src/main/java/com/supwisdom/dlpay/consume/domain/TPaytype.java
new file mode 100644
index 0000000..07d4679
--- /dev/null
+++ b/src/main/java/com/supwisdom/dlpay/consume/domain/TPaytype.java
@@ -0,0 +1,55 @@
+package com.supwisdom.dlpay.consume.domain;
+
+import javax.persistence.*;
+
+/**
+ * Created by shuwei on 2019/4/9.
+ */
+@Entity
+@Table(name = "TB_PAYTYPE")
+public class TPaytype {
+    @Id
+    @Column(name = "PAYTYPE", nullable = false, length = 20)
+    private String paytype;
+
+    @Column(name = "ENABLE", nullable = false, length = 20)
+    private String enable;
+
+    @Column(name = "DPS_ENABLE",  length = 20)
+    private String dpsEnable;
+
+    @Column(name = "REVERSE_ENABLE", length = 20)
+    private String reverseEnable;
+
+    public String getPaytype() {
+        return paytype;
+    }
+
+    public void setPaytype(String paytype) {
+        this.paytype = paytype;
+    }
+
+    public String getEnable() {
+        return enable;
+    }
+
+    public void setEnable(String enable) {
+        this.enable = enable;
+    }
+
+    public String getDpsEnable() {
+        return dpsEnable;
+    }
+
+    public void setDpsEnable(String dpsEnable) {
+        this.dpsEnable = dpsEnable;
+    }
+
+    public String getReverseEnable() {
+        return reverseEnable;
+    }
+
+    public void setReverseEnable(String reverseEnable) {
+        this.reverseEnable = reverseEnable;
+    }
+}
diff --git a/src/main/java/com/supwisdom/dlpay/consume/domain/TPaytypeConfig.java b/src/main/java/com/supwisdom/dlpay/consume/domain/TPaytypeConfig.java
new file mode 100644
index 0000000..65cf896
--- /dev/null
+++ b/src/main/java/com/supwisdom/dlpay/consume/domain/TPaytypeConfig.java
@@ -0,0 +1,56 @@
+package com.supwisdom.dlpay.consume.domain;
+
+import javax.persistence.*;
+
+/**
+ * Created by shuwei on 2019/4/9.
+ */
+@Entity
+@Table(name = "TB_PAYTYPE_CONFIG")
+@IdClass(TPaytypeConfigPK.class)
+public class TPaytypeConfig {
+    @Id
+    @Column(name = "PAYTYPE", nullable = false, length = 20)
+    private String paytype;
+    @Id
+    @Column(name = "CONFIGID", nullable = false, length = 40)
+    private String configid;
+
+    @Column(name = "CONFIG_VALUE", length = 2000)
+    private String configValue;
+
+    @Column(name = "CONFIG_NAME", length = 200)
+    private String configName;
+
+    public String getPaytype() {
+        return paytype;
+    }
+
+    public void setPaytype(String paytype) {
+        this.paytype = paytype;
+    }
+
+    public String getConfigid() {
+        return configid;
+    }
+
+    public void setConfigid(String configid) {
+        this.configid = configid;
+    }
+
+    public String getConfigValue() {
+        return configValue;
+    }
+
+    public void setConfigValue(String configValue) {
+        this.configValue = configValue;
+    }
+
+    public String getConfigName() {
+        return configName;
+    }
+
+    public void setConfigName(String configName) {
+        this.configName = configName;
+    }
+}
diff --git a/src/main/java/com/supwisdom/dlpay/consume/domain/TPaytypeConfigPK.java b/src/main/java/com/supwisdom/dlpay/consume/domain/TPaytypeConfigPK.java
new file mode 100644
index 0000000..5046c0b
--- /dev/null
+++ b/src/main/java/com/supwisdom/dlpay/consume/domain/TPaytypeConfigPK.java
@@ -0,0 +1,53 @@
+package com.supwisdom.dlpay.consume.domain;
+
+import javax.persistence.Column;
+import javax.persistence.Embeddable;
+import javax.persistence.Id;
+import java.io.Serializable;
+
+/**
+ * Created by shuwei on 2019/4/9.
+ */
+@Embeddable
+public class TPaytypeConfigPK implements Serializable {
+    @Id
+    @Column(name = "PAYTYPE", nullable = false, length = 20)
+    private String paytype;
+    @Id
+    @Column(name = "CONFIGID", nullable = false, length = 40)
+    private String configid;
+
+    public String getPaytype() {
+        return paytype;
+    }
+
+    public void setPaytype(String paytype) {
+        this.paytype = paytype;
+    }
+
+    public String getConfigid() {
+        return configid;
+    }
+
+    public void setConfigid(String configid) {
+        this.configid = configid;
+    }
+
+    @Override
+    public boolean equals(Object o) {
+        if (this == o) return true;
+        if (o == null || getClass() != o.getClass()) return false;
+
+        TPaytypeConfigPK that = (TPaytypeConfigPK) o;
+
+        if (!paytype.equals(that.paytype)) return false;
+        return configid.equals(that.configid);
+    }
+
+    @Override
+    public int hashCode() {
+        int result = paytype.hashCode();
+        result = 31 * result + configid.hashCode();
+        return result;
+    }
+}
diff --git a/src/main/java/com/supwisdom/dlpay/consume/domain/TTransdtlOrder.java b/src/main/java/com/supwisdom/dlpay/consume/domain/TTransdtlOrder.java
new file mode 100644
index 0000000..edc005e
--- /dev/null
+++ b/src/main/java/com/supwisdom/dlpay/consume/domain/TTransdtlOrder.java
@@ -0,0 +1,38 @@
+package com.supwisdom.dlpay.consume.domain;
+
+import javax.persistence.Column;
+import javax.persistence.Entity;
+import javax.persistence.Id;
+import javax.persistence.Table;
+
+/**
+*
+* 流水明细表
+* */
+
+@Entity
+@Table(name = "TB_TRANSDTL_ORDER")
+public class TTransdtlOrder {
+  @Id
+  @Column(name = "REFNO", nullable = false, length = 32)
+  private String refno;
+
+  @Column(name = "ERRMSG", length = 100)
+  private String errmsg;
+
+  public String getRefno() {
+    return refno;
+  }
+
+  public void setRefno(String refno) {
+    this.refno = refno;
+  }
+
+  public String getErrmsg() {
+    return errmsg;
+  }
+
+  public void setErrmsg(String errmsg) {
+    this.errmsg = errmsg;
+  }
+}
diff --git a/src/main/java/com/supwisdom/dlpay/consume/service/PayapiService.java b/src/main/java/com/supwisdom/dlpay/consume/service/PayapiService.java
new file mode 100644
index 0000000..0c8bec0
--- /dev/null
+++ b/src/main/java/com/supwisdom/dlpay/consume/service/PayapiService.java
@@ -0,0 +1,14 @@
+package com.supwisdom.dlpay.consume.service;
+
+import com.supwisdom.dlpay.consume.bean.BaseResp;
+import com.supwisdom.dlpay.consume.bean.ReqParam;
+import org.springframework.transaction.annotation.Propagation;
+import org.springframework.transaction.annotation.Transactional;
+
+/**
+ * Created by shuwei on 2019/4/9.
+ */
+public interface PayapiService {
+    @Transactional(propagation = Propagation.REQUIRED,rollbackFor = Exception.class)
+    boolean doConsume(ReqParam param, BaseResp resp);
+}
diff --git a/src/main/java/com/supwisdom/dlpay/consume/service/PaytypeService.java b/src/main/java/com/supwisdom/dlpay/consume/service/PaytypeService.java
new file mode 100644
index 0000000..7c6821d
--- /dev/null
+++ b/src/main/java/com/supwisdom/dlpay/consume/service/PaytypeService.java
@@ -0,0 +1,16 @@
+package com.supwisdom.dlpay.consume.service;
+
+import com.supwisdom.dlpay.consume.domain.TPaytype;
+
+import java.util.Map;
+
+/**
+ * Created by shuwei on 2019/4/9.
+ */
+public interface PaytypeService {
+
+    TPaytype getByPaytype(String paytype);
+
+    Map<String,String> getPaytypeConfigByPaytype(String pattype);
+
+}
diff --git a/src/main/java/com/supwisdom/dlpay/consume/service/impl/PayapiServiceImpl.java b/src/main/java/com/supwisdom/dlpay/consume/service/impl/PayapiServiceImpl.java
new file mode 100644
index 0000000..382d821
--- /dev/null
+++ b/src/main/java/com/supwisdom/dlpay/consume/service/impl/PayapiServiceImpl.java
@@ -0,0 +1,186 @@
+package com.supwisdom.dlpay.consume.service.impl;
+
+import com.google.gson.Gson;
+import com.sun.jersey.api.client.Client;
+import com.sun.jersey.api.client.ClientResponse;
+import com.sun.jersey.api.client.WebResource;
+import com.supwisdom.dlpay.consume.bean.BaseResp;
+import com.supwisdom.dlpay.consume.bean.ReqParam;
+import com.supwisdom.dlpay.consume.bean.SupStatusRevResp;
+import com.supwisdom.dlpay.consume.bean.SupYktResp;
+import com.supwisdom.dlpay.consume.dao.TransdtlDao;
+import com.supwisdom.dlpay.consume.domain.TPaytype;
+import com.supwisdom.dlpay.consume.domain.TTransdtl;
+import com.supwisdom.dlpay.consume.service.PayapiService;
+import com.supwisdom.dlpay.consume.service.PaytypeService;
+import com.supwisdom.dlpay.framework.data.SystemDateTime;
+import com.supwisdom.dlpay.framework.service.SystemUtilService;
+import com.supwisdom.dlpay.framework.util.DateUtil;
+import com.supwisdom.dlpay.framework.util.TradeCode;
+import com.supwisdom.dlpay.util.*;
+import org.apache.log4j.Logger;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.stereotype.Service;
+import org.springframework.util.StringUtils;
+
+import java.util.HashMap;
+import java.util.Map;
+
+/**
+ * Created by shuwei on 2019/4/9.
+ */
+@Service
+public class PayapiServiceImpl implements PayapiService {
+    @Autowired
+    private TransdtlDao transdtlDao;
+    @Autowired
+    private SystemUtilService systemUtilService;
+    @Autowired
+    private PaytypeService paytypeService;
+    private static final Logger logger = Logger.getLogger(PayapiServiceImpl.class);
+    private static final Gson gson = new Gson();
+
+    @Override
+    public boolean doConsume(ReqParam param, BaseResp resp) {
+        TTransdtl tTransdtl = transdtlDao.getByOuttradenoAndStatus(param.getRefno(), ConstUtil.STATUS_SUCCESS);
+        if (tTransdtl != null) {
+            resp.setRetcode("1");
+            resp.setRetmsg("流水号重复");
+            return false;
+        }
+        String refno = transdtlDao.getReno();
+        if (StringUtils.isEmpty(refno)) {
+            resp.setCode(Code.SYS_ERROR);
+            return false;
+        }
+        tTransdtl = new TTransdtl();
+        tTransdtl.setAccno(param.getAccno());
+        tTransdtl.setAmount(MoneyUtil.FenToYuan(param.getAmount()));
+        tTransdtl.setPaidamt(MoneyUtil.FenToYuan(param.getAmount()));
+        tTransdtl.setShopaccno(param.getShopaccno());
+        tTransdtl.setOuttradeno(param.getRefno());
+        tTransdtl.setPaytype(param.getPaytype());
+        tTransdtl.setTransdate(DateUtil.getNow("yyyyMMdd"));
+        tTransdtl.setTranstime(DateUtil.getNow("hhmmss"));
+        tTransdtl.setCreatetime(DateUtil.getNow());
+        tTransdtl.setPayinfo(param.getPayinfo());
+        tTransdtl.setStatus(ConstUtil.STATUS_INIT);
+        tTransdtl.setRefno(refno);
+        transdtlDao.save(tTransdtl);
+        switch (param.getPaytype()) {
+            case PaytypeUtil.YKTPAY:
+                return doYKTPay(param, tTransdtl, resp);
+        }
+        resp.setCode(Code.PAYTYPE_NOT_SUPPORT);
+        return false;
+    }
+
+    /**
+     * 一卡通支付
+     */
+
+    private boolean doYKTPay(ReqParam param, TTransdtl dtl, BaseResp resp) {
+        //TODO
+        TPaytype paytype = paytypeService.getByPaytype(PaytypeUtil.YKTPAY);
+        if (paytype == null || !ConstUtil.ENABLE_YES.equals(paytype.getEnable())) {
+            resp.setCode(Code.PAYTYPE_NOT_SUPPORT);
+            return false;
+        }
+        Map<String, String> config = paytypeService.getPaytypeConfigByPaytype(PaytypeUtil.YKTPAY);
+        String appid = config.get("appid");
+        String appkey = config.get("appkey");
+        String orderurl = config.get("orderurl");
+        if (config.size() == 0
+                || StringUtils.isEmpty(appid)
+                || StringUtils.isEmpty(appkey)
+                || StringUtils.isEmpty(orderurl)) {
+            resp.setCode(Code.PAYTYPE_CONFIG_ERROR);
+            logger.error("支付方式未配置,appid=" + appid + ",appkey=" + appkey + ",orderurl=" + orderurl);
+            return false;
+        }
+        SystemDateTime systemDateTime = systemUtilService.getSysdatetime();
+        dtl.setAccdate(systemDateTime.getHostdate());
+        Map<String, String> params = new HashMap<String, String>();
+        params.put("partner_id", appid);
+        params.put("stuempno", param.getAccno());
+        params.put("tradeno", dtl.getRefno());
+        params.put("tradename", param.getPayinfo());
+        params.put("amount", param.getAmount() + "");
+        params.put("shopid", param.getYktshopid());
+        params.put("devphyid", param.getDevphyid());
+        params.put("calcmanagefee", "T");//是否计算费率
+        params.put("timestamp", systemDateTime.getHostdatetime());
+
+        params.put("sign_method", "HMAC");
+        params.put("limitflag", "off"); //是否判断消费限额，on-判断；off-不判断。默认on（判断限额）。为空或不为off都是on；
+        String signstr = HmacUtil.createLinkString(HmacUtil.paraFilter(params));
+        String sign = HmacUtil.HMACSHA1(signstr, appkey);
+        signstr += "&sign=" + sign + "&sourcetype=food";
+        Client c = Client.create();
+        c.setConnectTimeout(20000);
+        dtl.setTranstype(TradeCode.TRANSTYPE_YKTPAY);
+        dtl.setTranscode(TradeCode.TRANSCODE_YKTPAY);
+
+        WebResource r = c.resource(orderurl);
+        ClientResponse respClient = r.post(ClientResponse.class, signstr);
+        if (200 == respClient.getStatus()) {
+            String ret = respClient.getEntity(String.class);
+            logger.error("***************yktpay.ret=" + ret + "*************************");
+            if (ret != null) {
+                try {
+                    SupYktResp result = gson.fromJson(ret, SupYktResp.class);
+                    if (result == null) {
+                        resp.setCode(Code.RESPNOSE_CONTENT_ERROR);
+                        logger.error("支付内容转换失败:null");
+                        return false;
+                    }
+                    if (!"0".equals(result.getRetcode())) {
+                        if ("30".equals(result.getRetcode())) {
+                            if (result.getOther() != null) {
+                                try {
+                                    SupStatusRevResp supStatusRevResp = gson.fromJson(result.getOther(), SupStatusRevResp.class);
+                                    if (supStatusRevResp != null) {
+                                        //同流水号，同一笔已经支付完成的，不重复支付。
+                                        if (3 == supStatusRevResp.getStatus() && supStatusRevResp.getRevflag() != null && !supStatusRevResp.getRevflag()) {
+                                            dtl.setStatus(ConstUtil.STATUS_SUCCESS);
+                                            dtl.setAccdate(systemDateTime.getHostdate());
+                                            transdtlDao.save(dtl);
+                                            resp.setCode(Code.SUCCESS);
+                                            return true;
+                                        }
+                                    }
+                                } catch (Exception e) {
+                                    e.printStackTrace();
+                                    logger.error("返回内容转换失败:" + e.getMessage());
+                                }
+                            }
+                        }
+                        resp.setRetcode("1");
+                        resp.setRetmsg("交易失败:" + result.getRetmsg());
+                        logger.error(result.getRetmsg());
+                        //dtl.setErrmsg(result.getRetmsg());
+                        //payApiDTLDao.save(dtl);
+                        return false;
+                    }
+                    dtl.setStatus(ConstUtil.STATUS_SUCCESS);
+                    dtl.setAccdate(systemDateTime.getHostdate());
+                    transdtlDao.save(dtl);
+                    resp.setCode(Code.SUCCESS);
+                    return true;
+                } catch (Exception e) {
+                    e.printStackTrace();
+                    resp.setCode(Code.RESPNOSE_CONTENT_ERROR);
+                    logger.error("支付内容转换失败:" + e.getMessage());
+                    return false;
+                }
+            } else {
+                resp.setCode(Code.REQUEST_ERROR);
+                return false;
+            }
+        } else {
+            resp.setCode(Code.REQUEST_ERROR);
+            logger.error("请求返回失败:" + respClient.getEntity(String.class) + ",code=" + respClient.getStatus());
+            return false;
+        }
+    }
+}
diff --git a/src/main/java/com/supwisdom/dlpay/consume/service/impl/PaytypeServiceImpl.java b/src/main/java/com/supwisdom/dlpay/consume/service/impl/PaytypeServiceImpl.java
new file mode 100644
index 0000000..5aad223
--- /dev/null
+++ b/src/main/java/com/supwisdom/dlpay/consume/service/impl/PaytypeServiceImpl.java
@@ -0,0 +1,39 @@
+package com.supwisdom.dlpay.consume.service.impl;
+
+import com.supwisdom.dlpay.consume.dao.PaytypeConfigDao;
+import com.supwisdom.dlpay.consume.dao.PaytypeDao;
+import com.supwisdom.dlpay.consume.domain.TPaytype;
+import com.supwisdom.dlpay.consume.domain.TPaytypeConfig;
+import com.supwisdom.dlpay.consume.service.PaytypeService;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.stereotype.Service;
+
+import java.util.HashMap;
+import java.util.List;
+import java.util.Map;
+
+/**
+ * Created by shuwei on 2019/4/9.
+ */
+@Service
+public class PaytypeServiceImpl implements PaytypeService {
+    @Autowired
+    private PaytypeDao paytypeDao;
+    @Autowired
+    private PaytypeConfigDao paytypeConfigDao;
+
+    @Override
+    public TPaytype getByPaytype(String paytype) {
+        return paytypeDao.getOne(paytype);
+    }
+
+    @Override
+    public Map<String, String> getPaytypeConfigByPaytype(String pattype) {
+        List<TPaytypeConfig> list = paytypeConfigDao.getByPaytype(pattype);
+        Map<String, String> map = new HashMap<>(list.size());
+        for (TPaytypeConfig paytypeConfig : list) {
+            map.put(paytypeConfig.getConfigid(), paytypeConfig.getConfigValue());
+        }
+        return map;
+    }
+}
diff --git a/src/main/java/com/supwisdom/dlpay/framework/util/TradeCode.java b/src/main/java/com/supwisdom/dlpay/framework/util/TradeCode.java
index b206704..2c9d7df 100644
--- a/src/main/java/com/supwisdom/dlpay/framework/util/TradeCode.java
+++ b/src/main/java/com/supwisdom/dlpay/framework/util/TradeCode.java
@@ -5,5 +5,9 @@
  * */
 public class TradeCode {
   public static final int TRANSCODE_PAY = 6630;
+  public static final int TRANSCODE_YKTPAY=1000;
+
+
   public static final int TRANSTYPE_PAY = 311;
+  public static final int TRANSTYPE_YKTPAY=1000;
 }
diff --git a/src/main/java/com/supwisdom/dlpay/util/Code.java b/src/main/java/com/supwisdom/dlpay/util/Code.java
new file mode 100644
index 0000000..8f05ecd
--- /dev/null
+++ b/src/main/java/com/supwisdom/dlpay/util/Code.java
@@ -0,0 +1,39 @@
+package com.supwisdom.dlpay.util;
+
+/**
+ * Created by shuwei on 2019/4/9.
+ */
+public enum Code {
+    SUCCESS("0","OK"),
+    PARAM_ERROR("1","参数错误"),
+    SYS_ERROR("2","系统异常"),
+    PAYTYPE_NOT_SUPPORT("10","支付方式不支持"),
+    PAYTYPE_CONFIG_ERROR("11","支付方式未配置或配置错误"),
+    REQUEST_ERROR("20","响应内容错误"),
+    RESPNOSE_CONTENT_ERROR("21","响应内容错误")
+    ;
+
+    private String code;
+    private String retmsg;
+
+    private Code(String code,String retmsg){
+        this.code = code;
+        this.retmsg = retmsg;
+    }
+
+    public String getCode() {
+        return code;
+    }
+
+    public void setCode(String code) {
+        this.code = code;
+    }
+
+    public String getRetmsg() {
+        return retmsg;
+    }
+
+    public void setRetmsg(String retmsg) {
+        this.retmsg = retmsg;
+    }
+}
diff --git a/src/main/java/com/supwisdom/dlpay/util/ConstUtil.java b/src/main/java/com/supwisdom/dlpay/util/ConstUtil.java
new file mode 100644
index 0000000..4a54efa
--- /dev/null
+++ b/src/main/java/com/supwisdom/dlpay/util/ConstUtil.java
@@ -0,0 +1,15 @@
+package com.supwisdom.dlpay.util;
+
+/**
+ * Created by shuwei on 2019/4/9.
+ */
+public class ConstUtil {
+    public static final String STATUS_INIT = "init";
+    public static final String STATUS_SUCCESS = "success";
+    public static final String STATUS_FAIL = "fail";
+
+    public static final String ENABLE_YES = "yes";
+
+    public static final String ENABLE_NO = "no";
+
+}
diff --git a/src/main/java/com/supwisdom/dlpay/util/HmacUtil.java b/src/main/java/com/supwisdom/dlpay/util/HmacUtil.java
new file mode 100644
index 0000000..832c699
--- /dev/null
+++ b/src/main/java/com/supwisdom/dlpay/util/HmacUtil.java
@@ -0,0 +1,130 @@
+package com.supwisdom.dlpay.util;
+
+import com.supwisdom.dlpay.framework.util.DateUtil;
+
+import javax.crypto.Mac;
+import javax.crypto.spec.SecretKeySpec;
+import java.io.UnsupportedEncodingException;
+import java.security.InvalidKeyException;
+import java.security.NoSuchAlgorithmException;
+import java.util.*;
+
+public class HmacUtil {
+    /**
+     * 除去数组中的空值和签名参数
+     *
+     * @param sArray 签名参数组
+     * @return 去掉空值与签名参数后的新签名参数组
+     */
+    public static Map<String, String> paraFilter(Map<String, String> sArray) {
+
+        Map<String, String> result = new HashMap<String, String>();
+
+        if (sArray == null || sArray.size() <= 0) {
+            return result;
+        }
+
+        for (String key : sArray.keySet()) {
+            String value = sArray.get(key);
+            if (value == null || value.equals("") || "null".equals(value) || key.equalsIgnoreCase("sign")) {
+                continue;
+            }
+            result.put(key, value);
+        }
+
+        return result;
+    }
+
+    /**
+     * 把数组所有元素排序，并按照“参数=参数值”的模式用“&”字符拼接成字符串
+     *
+     * @param params 需要排序并参与字符拼接的参数组
+     * @return 拼接后字符串
+     */
+    public static String createLinkString(Map<String, String> params) {
+
+        List<String> keys = new ArrayList<String>(params.keySet());
+        Collections.sort(keys);
+
+        String prestr = "";
+
+        for (int i = 0; i < keys.size(); i++) {
+            String key = keys.get(i);
+            String value = params.get(key);
+
+            if (i == keys.size() - 1) {//拼接时，不包括最后一个&字符
+                prestr = prestr + key + "=" + value;
+            } else {
+                prestr = prestr + key + "=" + value + "&";
+            }
+        }
+
+        return prestr;
+    }
+
+    public static String HMACSHA1(String data, String key) {
+        byte[] byteHMAC = null;
+        try {
+            Mac mac = Mac.getInstance("HmacSHA1");
+            SecretKeySpec spec = new SecretKeySpec(key.getBytes(), "HmacSHA1");
+            mac.init(spec);
+            byteHMAC = mac.doFinal(data.getBytes("UTF-8"));
+        } catch (InvalidKeyException e) {
+            e.printStackTrace();
+        } catch (NoSuchAlgorithmException ignore) {
+            ignore.printStackTrace();
+        } catch (UnsupportedEncodingException e) {
+            e.printStackTrace();
+        }
+
+        if (byteHMAC != null) {
+            try {
+                String hexMac = getHexString(byteHMAC);
+                return hexMac;
+            } catch (Exception e) {
+                // TODO Auto-generated catch block
+                e.printStackTrace();
+            }
+            return null;
+        }
+        return null;
+
+    }
+
+    public static String getHexString(byte[] b) throws Exception {
+        String result = "";
+        for (int i = 0; i < b.length; i++) {
+            result += Integer.toString((b[i] & 0xff) + 0x100, 16).substring(1);
+        }
+        return result;
+    }
+
+    public static boolean checkHmacSign(String data, String key, String sign) {
+        String asign = HMACSHA1(data, key);
+        if (asign == null) {
+            return false;
+        }
+        if (asign.equalsIgnoreCase(sign)) {
+            return true;
+        }
+
+        return false;
+    }
+
+    public static void main(String[] args) {
+        String refno = DateUtil.getNow();
+        Map<String, String> mapValue = new HashMap<String, String>();
+        mapValue.put("tradeaccount", "10000097");
+        mapValue.put("tradename", "在线点餐");
+        mapValue.put("tradeamount", "1");
+        mapValue.put("paidamount", "1");
+        mapValue.put("outtradeno", refno);
+        mapValue.put("yktshopid", "2");
+        mapValue.put("shopid", "68512084");
+        String signstr = createLinkString(HmacUtil.paraFilter(mapValue));
+        String sign = HmacUtil.HMACSHA1(signstr, "adc4ac6822fd462780f878b86cb94688");
+        System.out.println("{\"tradeaccount\":\"10000097\",\"tradename\":\"在线点餐\",\"tradeamount\":\"1\"," +
+                "\"paidamount\": \"1\",\"outtradeno\":\""+refno+"\",\"yktshopid\": \"2\",\"shopid\":\"68512084\",\"sign\": \""+sign+"\"}");
+    }
+
+}
diff --git a/src/main/java/com/supwisdom/dlpay/util/MoneyUtil.java b/src/main/java/com/supwisdom/dlpay/util/MoneyUtil.java
new file mode 100644
index 0000000..2fb8b73
--- /dev/null
+++ b/src/main/java/com/supwisdom/dlpay/util/MoneyUtil.java
@@ -0,0 +1,28 @@
+package com.supwisdom.dlpay.util;
+
+
+import java.text.DecimalFormat;
+
+public class MoneyUtil {
+
+	public static int YuanToFen(double yuan) {
+		return (int) (Math.round(yuan * 100));
+	}
+
+	public static boolean moneyCompare(double x1, double x2) {
+		return YuanToFen(x1) == YuanToFen(x2);
+	}
+	public static double formatYuan(double yuan) {
+		DecimalFormat df = new DecimalFormat("##0.00");
+		double money = ((double) YuanToFen(yuan)) / 100;
+		return Double.valueOf(df.format(money));
+	}
+
+	public static double FenToYuan(int fen) {
+		return formatYuan(fen / 100.0);
+	}
+	public static String format(double num,String format) {
+		DecimalFormat df = new DecimalFormat(format);
+		return df.format(num);
+	}
+}
diff --git a/src/main/java/com/supwisdom/dlpay/util/PaytypeUtil.java b/src/main/java/com/supwisdom/dlpay/util/PaytypeUtil.java
new file mode 100644
index 0000000..8222e90
--- /dev/null
+++ b/src/main/java/com/supwisdom/dlpay/util/PaytypeUtil.java
@@ -0,0 +1,10 @@
+package com.supwisdom.dlpay.util;
+
+/**
+ * Created by shuwei on 2019/4/9.
+ */
+public class PaytypeUtil {
+    public static final String YKTPAY = "yktpay";
+
+    public static final String WECHAT = "wechat";
+}