Index: src/main/java/com/novaone/dao/CompanyBankAccMapper.java =================================================================== --- src/main/java/com/novaone/dao/CompanyBankAccMapper.java (不存在的) +++ src/main/java/com/novaone/dao/CompanyBankAccMapper.java (版本 31414) @@ -0,0 +1,67 @@ +package com.novaone.dao; + +import com.novaone.entity.CompanyBankAcc; +import java.util.List; +import org.apache.ibatis.annotations.Param; + +public interface CompanyBankAccMapper { + /** + * delete by primary key + * @param id primaryKey + * @return deleteCount + */ + int deleteByPrimaryKey(Long id); + + /** + * insert record to table + * @param record the record + * @return insert count + */ + int insert(CompanyBankAcc record); + + int insertOrUpdate(CompanyBankAcc record); + + int insertOrUpdateSelective(CompanyBankAcc record); + + /** + * insert record to table selective + * @param record the record + * @return insert count + */ + int insertSelective(CompanyBankAcc record); + + /** + * select by primary key + * @param id primary key + * @return object by primary key + */ + CompanyBankAcc selectByPrimaryKey(Long id); + + + /** + * 根据公司名称查找未禁用的付款账号 + * @param company 公司名称 + * @return 对用公司并且未禁用的银行账号 + */ + CompanyBankAcc selectByCompany(String company); + + /** + * update record selective + * @param record the updated record + * @return update count + */ + int updateByPrimaryKeySelective(CompanyBankAcc record); + + /** + * update record + * @param record the updated record + * @return update count + */ + int updateByPrimaryKey(CompanyBankAcc record); + + int updateBatch(List list); + + int updateBatchSelective(List list); + + int batchInsert(@Param("list") List list); +} \ No newline at end of file Index: src/main/java/com/novaone/dao/Mapper/CompanyBankAccMapper.xml =================================================================== --- src/main/java/com/novaone/dao/Mapper/CompanyBankAccMapper.xml (不存在的) +++ src/main/java/com/novaone/dao/Mapper/CompanyBankAccMapper.xml (版本 31414) @@ -0,0 +1,378 @@ + + + + + + + + + + + + + + + + + + id, company, bank_name, bank_account, currency, disabled, create_time, update_time + + + + + + + + delete from company_bank_acc + where id = #{id} + + + + insert into company_bank_acc (company, bank_name, bank_account, currency, disabled, create_time, + update_time) + values (#{company}, #{bankName}, #{bankAccount}, #{currency}, #{disabled}, #{createTime}, + #{updateTime}) + + + + insert into company_bank_acc + + + company, + + + bank_name, + + + bank_account, + + + currency, + + + disabled, + + + create_time, + + + update_time, + + + + + #{company}, + + + #{bankName}, + + + #{bankAccount}, + + + #{currency}, + + + #{disabled}, + + + #{createTime}, + + + #{updateTime}, + + + + + + update company_bank_acc + + + company = #{company}, + + + bank_name = #{bankName}, + + + bank_account = #{bankAccount}, + + + currency = #{currency}, + + + disabled = #{disabled}, + + + create_time = #{createTime}, + + + update_time = #{updateTime}, + + + where id = #{id} + + + + update company_bank_acc + set company = #{company}, + bank_name = #{bankName}, + bank_account = #{bankAccount}, + currency = #{currency}, + disabled = #{disabled}, + create_time = #{createTime}, + update_time = #{updateTime} + where id = #{id} + + + + update company_bank_acc + + + + when id = #{item.id} then #{item.company} + + + + + when id = #{item.id} then #{item.bankName} + + + + + when id = #{item.id} then #{item.bankAccount} + + + + + when id = #{item.id} then #{item.currency} + + + + + when id = #{item.id} then #{item.disabled} + + + + + when id = #{item.id} then #{item.createTime} + + + + + when id = #{item.id} then #{item.updateTime} + + + + where id in + + #{item.id} + + + + + update company_bank_acc + + + + + when id = #{item.id} then #{item.company} + + + + + + + when id = #{item.id} then #{item.bankName} + + + + + + + when id = #{item.id} then #{item.bankAccount} + + + + + + + when id = #{item.id} then #{item.currency} + + + + + + + when id = #{item.id} then #{item.disabled} + + + + + + + when id = #{item.id} then #{item.createTime} + + + + + + + when id = #{item.id} then #{item.updateTime} + + + + + where id in + + #{item.id} + + + + + insert into company_bank_acc + (company, bank_name, bank_account, currency, disabled, create_time, update_time) + values + + (#{item.company}, #{item.bankName}, #{item.bankAccount}, #{item.currency}, #{item.disabled}, + #{item.createTime}, #{item.updateTime}) + + + + + insert into company_bank_acc + + + id, + + company, + bank_name, + bank_account, + currency, + disabled, + create_time, + update_time, + + values + + + #{id}, + + #{company}, + #{bankName}, + #{bankAccount}, + #{currency}, + #{disabled}, + #{createTime}, + #{updateTime}, + + on duplicate key update + + + id = #{id}, + + company = #{company}, + bank_name = #{bankName}, + bank_account = #{bankAccount}, + currency = #{currency}, + disabled = #{disabled}, + create_time = #{createTime}, + update_time = #{updateTime}, + + + + + insert into company_bank_acc + + + id, + + + company, + + + bank_name, + + + bank_account, + + + currency, + + + disabled, + + + create_time, + + + update_time, + + + values + + + #{id}, + + + #{company}, + + + #{bankName}, + + + #{bankAccount}, + + + #{currency}, + + + #{disabled}, + + + #{createTime}, + + + #{updateTime}, + + + on duplicate key update + + + id = #{id}, + + + company = #{company}, + + + bank_name = #{bankName}, + + + bank_account = #{bankAccount}, + + + currency = #{currency}, + + + disabled = #{disabled}, + + + create_time = #{createTime}, + + + update_time = #{updateTime}, + + + + \ No newline at end of file Index: src/main/java/com/novaone/dao/Mapper/TradingBillRecordMapper.xml =================================================================== --- src/main/java/com/novaone/dao/Mapper/TradingBillRecordMapper.xml (不存在的) +++ src/main/java/com/novaone/dao/Mapper/TradingBillRecordMapper.xml (版本 31414) @@ -0,0 +1,402 @@ + + + + + + + + + + + + + + + + + + id, pay_no, `state`, `name`, `path`, message, creat_time, update_time + + + + + delete from trading_bill_record + where id = #{id} + + + + insert into trading_bill_record (pay_no, `state`, `name`, `path`, message, creat_time, update_time) select #{payNo}, #{state}, #{name}, #{path}, #{message}, #{creatTime}, #{updateTime} from dual where not exists(select 1 from trading_bill_record where pay_no = #{payNo}) + + + + + + + + insert into trading_bill_record + + + pay_no, + + + `state`, + + + `name`, + + + `path`, + + + message, + + + creat_time, + + + update_time, + + + + + #{payNo}, + + + #{state}, + + + #{name}, + + + #{path}, + + + #{message}, + + + #{creatTime}, + + + #{updateTime}, + + + + + + update trading_bill_record + + + pay_no = #{payNo}, + + + `state` = #{state}, + + + `name` = #{name}, + + + `path` = #{path}, + + + message = #{message}, + + + creat_time = #{creatTime}, + + + update_time = #{updateTime}, + + + where id = #{id} + + + + update trading_bill_record + + + `state` = #{state}, + + + `name` = #{name}, + + + `path` = #{path}, + + + message = #{message}, + + + creat_time = #{creatTime}, + + + update_time = #{updateTime}, + + + where pay_no = #{payNo} + + + + + + update trading_bill_record + set pay_no = #{payNo}, + `state` = #{state}, + `name` = #{name}, + `path` = #{path}, + message = #{message}, + creat_time = #{creatTime}, + update_time = #{updateTime} + where id = #{id} + + + + update trading_bill_record + + + + when id = #{item.id} then #{item.payNo} + + + + + when id = #{item.id} then #{item.state} + + + + + when id = #{item.id} then #{item.name} + + + + + when id = #{item.id} then #{item.path} + + + + + when id = #{item.id} then #{item.message} + + + + + when id = #{item.id} then #{item.creatTime} + + + + + when id = #{item.id} then #{item.updateTime} + + + + where id in + + #{item.id} + + + + + update trading_bill_record + + + + + when id = #{item.id} then #{item.payNo} + + + + + + + when id = #{item.id} then #{item.state} + + + + + + + when id = #{item.id} then #{item.name} + + + + + + + when id = #{item.id} then #{item.path} + + + + + + + when id = #{item.id} then #{item.message} + + + + + + + when id = #{item.id} then #{item.creatTime} + + + + + + + when id = #{item.id} then #{item.updateTime} + + + + + where id in + + #{item.id} + + + + + insert into trading_bill_record + (pay_no, `state`, `name`, `path`, message, creat_time, update_time) + values + + (#{item.payNo}, #{item.state}, #{item.name}, #{item.path}, #{item.message}, #{item.creatTime}, + #{item.updateTime}) + + + + + insert into trading_bill_record + + + id, + + pay_no, + `state`, + `name`, + `path`, + message, + creat_time, + update_time, + + values + + + #{id}, + + #{payNo}, + #{state}, + #{name}, + #{path}, + #{message}, + #{creatTime}, + #{updateTime}, + + on duplicate key update + + + id = #{id}, + + pay_no = #{payNo}, + `state` = #{state}, + `name` = #{name}, + `path` = #{path}, + message = #{message}, + creat_time = #{creatTime}, + update_time = #{updateTime}, + + + + + insert into trading_bill_record + + + id, + + + pay_no, + + + `state`, + + + `name`, + + + `path`, + + + message, + + + creat_time, + + + update_time, + + + values + + + #{id}, + + + #{payNo}, + + + #{state}, + + + #{name}, + + + #{path}, + + + #{message}, + + + #{creatTime}, + + + #{updateTime}, + + + on duplicate key update + + + id = #{id}, + + + pay_no = #{payNo}, + + + `state` = #{state}, + + + `name` = #{name}, + + + `path` = #{path}, + + + message = #{message}, + + + creat_time = #{creatTime}, + + + update_time = #{updateTime}, + + + + \ No newline at end of file Index: src/main/java/com/novaone/dao/Mapper/TradingHistoryMapper.xml =================================================================== --- src/main/java/com/novaone/dao/Mapper/TradingHistoryMapper.xml (不存在的) +++ src/main/java/com/novaone/dao/Mapper/TradingHistoryMapper.xml (版本 31414) @@ -0,0 +1,477 @@ + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + id, fractn_ibknum, fractn_actacn, fractn_acntname, fractn_ibkname, fractn_outref, + toactn_toibkn, toactn_actacn, toactn_toname, toactn_tobank, toactn_tobref, mactibkn, + mactacn, mactname, mactbank, vchnum, transid, insid, txndate, txntime, txnamt, acctbal, + avlbal, frzamt, overdramt, avloverdramt, useinfo, furinfo, transtype, bustype, trncur, + direction, feeact, feeamt, feecur, valdat, vouchtp, vouchnum, fxrate, interinfo, + channelflg, commnum + + + + + delete from trading_history + where id = #{id} + + + + insert into trading_history (fractn_ibknum, fractn_actacn, fractn_acntname, fractn_ibkname, fractn_outref, + toactn_toibkn, toactn_actacn, toactn_toname, toactn_tobank, toactn_tobref, + mactibkn, mactacn, mactname, mactbank, vchnum, transid, insid, + txndate, txntime, txnamt, acctbal, avlbal, frzamt, overdramt, + avloverdramt, useinfo, furinfo, transtype, bustype, trncur, direction, + feeact, feeamt, feecur, valdat, vouchtp, vouchnum, fxrate, + interinfo, channelflg, commnum) + values (#{fractn.ibknum}, #{fractn.actacn}, #{fractn.acntname}, #{fractn.ibkname}, #{fractn.outref}, + #{toactn.toibkn}, #{toactn.actacn}, #{toactn.toname}, #{toactn.tobank}, #{toactn.tobref}, + #{mactibkn}, #{mactacn}, #{mactname}, #{mactbank}, #{vchnum}, #{transid}, #{insid}, + #{txndate}, #{txntime}, #{txnamt}, #{acctbal}, #{avlbal}, #{frzamt}, #{overdramt}, + #{avloverdramt}, #{useinfo}, #{furinfo}, #{transtype}, #{bustype}, #{trncur}, #{direction}, + #{feeact}, #{feeamt}, #{feecur}, #{valdat}, #{vouchtp}, #{vouchnum}, #{fxrate}, + #{interinfo}, #{channelflg}, #{commnum}) + + + + + insert into trading_history + + + fractn_ibknum, + + + fractn_actacn, + + + fractn_acntname, + + + fractn_ibkname, + + + fractn_outref, + + + toactn_toibkn, + + + toactn_actacn, + + + toactn_toname, + + + toactn_tobank, + + + toactn_tobref, + + + mactibkn, + + + mactacn, + + + mactname, + + + mactbank, + + + vchnum, + + + transid, + + + insid, + + + txndate, + + + txntime, + + + txnamt, + + + acctbal, + + + avlbal, + + + frzamt, + + + overdramt, + + + avloverdramt, + + + useinfo, + + + furinfo, + + + transtype, + + + bustype, + + + trncur, + + + direction, + + + feeact, + + + feeamt, + + + feecur, + + + valdat, + + + vouchtp, + + + vouchnum, + + + fxrate, + + + interinfo, + + + channelflg, + + + commnum, + + + + + #{fractn.ibknum}, + + + #{fractn.actacn}, + + + #{fractn.acntname}, + + + #{fractn.ibkname}, + + + #{fractn.outref}, + + + #{toactn.toibkn}, + + + #{toactn.actacn}, + + + #{toactn.toname}, + + + #{toactn.tobank}, + + + #{toactn.tobref}, + + + #{mactibkn}, + + + #{mactacn}, + + + #{mactname}, + + + #{mactbank}, + + + #{vchnum}, + + + #{transid}, + + + #{insid}, + + + #{txndate}, + + + #{txntime}, + + + #{txnamt}, + + + #{acctbal}, + + + #{avlbal}, + + + #{frzamt}, + + + #{overdramt}, + + + #{avloverdramt}, + + + #{useinfo}, + + + #{furinfo}, + + + #{transtype}, + + + #{bustype}, + + + #{trncur}, + + + #{direction}, + + + #{feeact}, + + + #{feeamt}, + + + #{feecur}, + + + #{valdat}, + + + #{vouchtp}, + + + #{vouchnum}, + + + #{fxrate}, + + + #{interinfo}, + + + #{channelflg}, + + + #{commnum} + + + FROM DUAL WHERE NOT EXISTS(SELECT 1 FROM trading_history WHERE transid = #{transid} LIMIT 1) + + + + + + + update trading_history + + + fractn_ibknum = #{fractn.ibknum}, + + + fractn_actacn = #{fractn.actacn}, + + + fractn_acntname = #{fractn.acntname}, + + + fractn_ibkname = #{fractn.ibkname}, + + + fractn_outref = #{fractn.outref}, + + + toactn_toibkn = #{toactn.toibkn}, + + + toactn_actacn = #{toactn.actacn}, + + + toactn_toname = #{toactn.toname}, + + + toactn_tobank = #{toactn.tobank}, + + + toactn_tobref = #{toactn.tobref}, + + + mactibkn = #{mactibkn}, + + + mactacn = #{mactacn}, + + + mactname = #{mactname}, + + + mactbank = #{mactbank}, + + + vchnum = #{vchnum}, + + + transid = #{transid}, + + + insid = #{insid}, + + + txndate = #{txndate}, + + + txntime = #{txntime}, + + + txnamt = #{txnamt}, + + + acctbal = #{acctbal}, + + + avlbal = #{avlbal}, + + + frzamt = #{frzamt}, + + + overdramt = #{overdramt}, + + + avloverdramt = #{avloverdramt}, + + + useinfo = #{useinfo}, + + + furinfo = #{furinfo}, + + + transtype = #{transtype}, + + + bustype = #{bustype}, + + + trncur = #{trncur}, + + + direction = #{direction}, + + + feeact = #{feeact}, + + + feeamt = #{feeamt}, + + + feecur = #{feecur}, + + + valdat = #{valdat}, + + + vouchtp = #{vouchtp}, + + + vouchnum = #{vouchnum}, + + + fxrate = #{fxrate}, + + + interinfo = #{interinfo}, + + + channelflg = #{channelflg}, + + + commnum = #{commnum}, + + + where id = #{id} + + \ No newline at end of file Index: src/main/java/com/novaone/dao/Mapper/TradingLogMapper.xml =================================================================== --- src/main/java/com/novaone/dao/Mapper/TradingLogMapper.xml (不存在的) +++ src/main/java/com/novaone/dao/Mapper/TradingLogMapper.xml (版本 31414) @@ -0,0 +1,369 @@ + + + + + + + + + + + + + + + + + + id, pay_no, api_no, resp_code, resp_msg, mesage, `state`, creat_time + + + + + delete from trading_log + where id = #{id} + + + + insert into trading_log (pay_no, api_no, resp_code, resp_msg, mesage, `state`, creat_time + ) + values (#{payNo}, #{apiNo}, #{respCode}, #{respMsg}, #{mesage}, #{state}, #{creatTime} + ) + + + + insert into trading_log + + + pay_no, + + + api_no, + + + resp_code, + + + resp_msg, + + + mesage, + + + `state`, + + + creat_time, + + + + + #{payNo}, + + + #{apiNo}, + + + #{respCode}, + + + #{respMsg}, + + + #{mesage}, + + + #{state}, + + + #{creatTime}, + + + + + + update trading_log + + + pay_no = #{payNo}, + + + api_no = #{apiNo}, + + + resp_code = #{respCode}, + + + resp_msg = #{respMsg}, + + + mesage = #{mesage}, + + + `state` = #{state}, + + + creat_time = #{creatTime}, + + + where id = #{id} + + + + update trading_log + set pay_no = #{payNo}, + api_no = #{apiNo}, + resp_code = #{respCode}, + resp_msg = #{respMsg}, + mesage = #{mesage}, + `state` = #{state}, + creat_time = #{creatTime} + where id = #{id} + + + + update trading_log + + + + when id = #{item.id} then #{item.payNo} + + + + + when id = #{item.id} then #{item.apiNo} + + + + + when id = #{item.id} then #{item.respCode} + + + + + when id = #{item.id} then #{item.respMsg} + + + + + when id = #{item.id} then #{item.mesage} + + + + + when id = #{item.id} then #{item.state} + + + + + when id = #{item.id} then #{item.creatTime} + + + + where id in + + #{item.id} + + + + + update trading_log + + + + + when id = #{item.id} then #{item.payNo} + + + + + + + when id = #{item.id} then #{item.apiNo} + + + + + + + when id = #{item.id} then #{item.respCode} + + + + + + + when id = #{item.id} then #{item.respMsg} + + + + + + + when id = #{item.id} then #{item.mesage} + + + + + + + when id = #{item.id} then #{item.state} + + + + + + + when id = #{item.id} then #{item.creatTime} + + + + + where id in + + #{item.id} + + + + + insert into trading_log + (pay_no, api_no, resp_code, resp_msg, mesage, `state`, creat_time) + values + + (#{item.payNo}, #{item.apiNo}, #{item.respCode}, #{item.respMsg}, #{item.mesage}, + #{item.state}, #{item.creatTime}) + + + + + insert into trading_log + + + id, + + pay_no, + api_no, + resp_code, + resp_msg, + mesage, + `state`, + creat_time, + + values + + + #{id}, + + #{payNo}, + #{apiNo}, + #{respCode}, + #{respMsg}, + #{mesage}, + #{state}, + #{creatTime}, + + on duplicate key update + + + id = #{id}, + + pay_no = #{payNo}, + api_no = #{apiNo}, + resp_code = #{respCode}, + resp_msg = #{respMsg}, + mesage = #{mesage}, + `state` = #{state}, + creat_time = #{creatTime}, + + + + + insert into trading_log + + + id, + + + pay_no, + + + api_no, + + + resp_code, + + + resp_msg, + + + mesage, + + + `state`, + + + creat_time, + + + values + + + #{id}, + + + #{payNo}, + + + #{apiNo}, + + + #{respCode}, + + + #{respMsg}, + + + #{mesage}, + + + #{state}, + + + #{creatTime}, + + + on duplicate key update + + + id = #{id}, + + + pay_no = #{payNo}, + + + api_no = #{apiNo}, + + + resp_code = #{respCode}, + + + resp_msg = #{respMsg}, + + + mesage = #{mesage}, + + + `state` = #{state}, + + + creat_time = #{creatTime}, + + + + \ No newline at end of file Index: src/main/java/com/novaone/dao/Mapper/TradingRecordMapper.xml =================================================================== --- src/main/java/com/novaone/dao/Mapper/TradingRecordMapper.xml (不存在的) +++ src/main/java/com/novaone/dao/Mapper/TradingRecordMapper.xml (版本 31414) @@ -0,0 +1,899 @@ + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + id, pay_no, pay_bill_no, `type`, company, pay_acc, pay_name, pay_amount, payee_bank_name, + payee_bank_no, payee_acc, payee_name, payee_acc_type, urgent, description, bank_state, + business_state, message, schedule_date, creat_time, update_time + + + + + + + + + delete from trading_record + where id = #{id,jdbcType=BIGINT} + + + + + + insert into trading_record (pay_no, pay_bill_no, `type`, + company, pay_acc, pay_name, + pay_amount, payee_bank_name, payee_bank_no, + payee_acc, payee_name, payee_acc_type, + urgent, description, bank_state, + business_state, message, schedule_date, + creat_time, update_time) + values (#{payNo,jdbcType=VARCHAR}, #{payBillNo,jdbcType=VARCHAR}, #{type,jdbcType=BOOLEAN}, + #{company,jdbcType=VARCHAR}, #{payAcc,jdbcType=VARCHAR}, #{payName,jdbcType=VARCHAR}, + #{payAmount,jdbcType=DECIMAL}, #{payeeBankName,jdbcType=VARCHAR}, #{payeeBankNo,jdbcType=VARCHAR}, + #{payeeAcc,jdbcType=VARCHAR}, #{payeeName,jdbcType=VARCHAR}, #{payeeAccType,jdbcType=TINYINT}, + #{urgent,jdbcType=BOOLEAN}, #{description,jdbcType=VARCHAR}, #{bankState,jdbcType=VARCHAR}, + #{businessState,jdbcType=TINYINT}, #{message,jdbcType=VARCHAR}, #{scheduleDate,jdbcType=VARCHAR}, + #{creatTime,jdbcType=TIMESTAMP}, #{updateTime,jdbcType=TIMESTAMP}) + + + + + + insert into trading_record + + + pay_no, + + + pay_bill_no, + + + `type`, + + + company, + + + pay_acc, + + + pay_name, + + + pay_amount, + + + payee_bank_name, + + + payee_bank_no, + + + payee_acc, + + + payee_name, + + + payee_acc_type, + + + urgent, + + + description, + + + bank_state, + + + business_state, + + + message, + + + schedule_date, + + + creat_time, + + + update_time, + + + + + #{payNo,jdbcType=VARCHAR}, + + + #{payBillNo,jdbcType=VARCHAR}, + + + #{type,jdbcType=BOOLEAN}, + + + #{company,jdbcType=VARCHAR}, + + + #{payAcc,jdbcType=VARCHAR}, + + + #{payName,jdbcType=VARCHAR}, + + + #{payAmount,jdbcType=DECIMAL}, + + + #{payeeBankName,jdbcType=VARCHAR}, + + + #{payeeBankNo,jdbcType=VARCHAR}, + + + #{payeeAcc,jdbcType=VARCHAR}, + + + #{payeeName,jdbcType=VARCHAR}, + + + #{businessState,jdbcType=TINYINT}, + + + #{urgent,jdbcType=BOOLEAN}, + + + #{description,jdbcType=VARCHAR}, + + + #{bankState,jdbcType=VARCHAR}, + + + #{businessState,jdbcType=TINYINT}, + + + #{message,jdbcType=VARCHAR}, + + + #{scheduleDate,jdbcType=VARCHAR}, + + + #{creatTime,jdbcType=TIMESTAMP}, + + + #{updateTime,jdbcType=TIMESTAMP}, + + + + + + + + update trading_record + + + pay_no = #{payNo,jdbcType=VARCHAR}, + + + pay_bill_no = #{payBillNo,jdbcType=VARCHAR}, + + + `type` = #{type,jdbcType=BOOLEAN}, + + + company = #{company,jdbcType=VARCHAR}, + + + pay_acc = #{payAcc,jdbcType=VARCHAR}, + + + pay_name = #{payName,jdbcType=VARCHAR}, + + + pay_amount = #{payAmount,jdbcType=DECIMAL}, + + + payee_bank_name = #{payeeBankName,jdbcType=VARCHAR}, + + + payee_bank_no = #{payeeBankNo,jdbcType=VARCHAR}, + + + payee_acc = #{payeeAcc,jdbcType=VARCHAR}, + + + payee_name = #{payeeName,jdbcType=VARCHAR}, + + + payee_acc_type = #{payeeAccType,jdbcType=TINYINT}, + + + urgent = #{urgent,jdbcType=BOOLEAN}, + + + description = #{description,jdbcType=VARCHAR}, + + + bank_state = #{bankState,jdbcType=VARCHAR}, + + + business_state = #{businessState,jdbcType=TINYINT}, + + + message = #{message,jdbcType=VARCHAR}, + + + schedule_date = #{scheduleDate,jdbcType=VARCHAR}, + + + creat_time = #{creatTime,jdbcType=TIMESTAMP}, + + + update_time = #{updateTime,jdbcType=TIMESTAMP}, + + + where id = #{id,jdbcType=BIGINT} + + + + + + update trading_record + set pay_no = #{payNo,jdbcType=VARCHAR}, + pay_bill_no = #{payBillNo,jdbcType=VARCHAR}, + `type` = #{type,jdbcType=BOOLEAN}, + company = #{company,jdbcType=VARCHAR}, + pay_acc = #{payAcc,jdbcType=VARCHAR}, + pay_name = #{payName,jdbcType=VARCHAR}, + pay_amount = #{payAmount,jdbcType=DECIMAL}, + payee_bank_name = #{payeeBankName,jdbcType=VARCHAR}, + payee_bank_no = #{payeeBankNo,jdbcType=VARCHAR}, + payee_acc = #{payeeAcc,jdbcType=VARCHAR}, + payee_name = #{payeeName,jdbcType=VARCHAR}, + payee_acc_type = #{payeeAccType,jdbcType=TINYINT}, + urgent = #{urgent,jdbcType=BOOLEAN}, + description = #{description,jdbcType=VARCHAR}, + bank_state = #{bankState,jdbcType=VARCHAR}, + business_state = #{businessState,jdbcType=TINYINT}, + message = #{message,jdbcType=VARCHAR}, + schedule_date = #{scheduleDate,jdbcType=VARCHAR}, + creat_time = #{creatTime,jdbcType=TIMESTAMP}, + update_time = #{updateTime,jdbcType=TIMESTAMP} + where id = #{id,jdbcType=BIGINT} + + + + + + update trading_record + + + + when id = #{item.id,jdbcType=BIGINT} then #{item.payNo,jdbcType=VARCHAR} + + + + + when id = #{item.id,jdbcType=BIGINT} then #{item.payBillNo,jdbcType=VARCHAR} + + + + + when id = #{item.id,jdbcType=BIGINT} then #{item.type,jdbcType=BOOLEAN} + + + + + when id = #{item.id,jdbcType=BIGINT} then #{item.company,jdbcType=VARCHAR} + + + + + when id = #{item.id,jdbcType=BIGINT} then #{item.payAcc,jdbcType=VARCHAR} + + + + + when id = #{item.id,jdbcType=BIGINT} then #{item.payName,jdbcType=VARCHAR} + + + + + when id = #{item.id,jdbcType=BIGINT} then #{item.payAmount,jdbcType=DECIMAL} + + + + + when id = #{item.id,jdbcType=BIGINT} then #{item.payeeBankName,jdbcType=VARCHAR} + + + + + when id = #{item.id,jdbcType=BIGINT} then #{item.payeeBankNo,jdbcType=VARCHAR} + + + + + when id = #{item.id,jdbcType=BIGINT} then #{item.payeeAcc,jdbcType=VARCHAR} + + + + + when id = #{item.id,jdbcType=BIGINT} then #{item.payeeName,jdbcType=VARCHAR} + + + + + when id = #{item.id,jdbcType=BIGINT} then #{item.payeeAccType,jdbcType=TINYINT} + + + + + when id = #{item.id,jdbcType=BIGINT} then #{item.urgent,jdbcType=BOOLEAN} + + + + + when id = #{item.id,jdbcType=BIGINT} then #{item.description,jdbcType=VARCHAR} + + + + + when id = #{item.id,jdbcType=BIGINT} then #{item.bankState,jdbcType=VARCHAR} + + + + + when id = #{item.id,jdbcType=BIGINT} then #{item.businessState,jdbcType=TINYINT} + + + + + when id = #{item.id,jdbcType=BIGINT} then #{item.message,jdbcType=VARCHAR} + + + + + when id = #{item.id,jdbcType=BIGINT} then #{item.scheduleDate,jdbcType=VARCHAR} + + + + + when id = #{item.id,jdbcType=BIGINT} then #{item.creatTime,jdbcType=TIMESTAMP} + + + + + when id = #{item.id,jdbcType=BIGINT} then #{item.updateTime,jdbcType=TIMESTAMP} + + + + where id in + + #{item.id,jdbcType=BIGINT} + + + + + update trading_record + + + + + when id = #{item.id,jdbcType=BIGINT} then #{item.payNo,jdbcType=VARCHAR} + + + + + + + when id = #{item.id,jdbcType=BIGINT} then #{item.payBillNo,jdbcType=VARCHAR} + + + + + + + when id = #{item.id,jdbcType=BIGINT} then #{item.type,jdbcType=BOOLEAN} + + + + + + + when id = #{item.id,jdbcType=BIGINT} then #{item.company,jdbcType=VARCHAR} + + + + + + + when id = #{item.id,jdbcType=BIGINT} then #{item.payAcc,jdbcType=VARCHAR} + + + + + + + when id = #{item.id,jdbcType=BIGINT} then #{item.payName,jdbcType=VARCHAR} + + + + + + + when id = #{item.id,jdbcType=BIGINT} then #{item.payAmount,jdbcType=DECIMAL} + + + + + + + when id = #{item.id,jdbcType=BIGINT} then #{item.payeeBankName,jdbcType=VARCHAR} + + + + + + + when id = #{item.id,jdbcType=BIGINT} then #{item.payeeBankNo,jdbcType=VARCHAR} + + + + + + + when id = #{item.id,jdbcType=BIGINT} then #{item.payeeAcc,jdbcType=VARCHAR} + + + + + + + when id = #{item.id,jdbcType=BIGINT} then #{item.payeeName,jdbcType=VARCHAR} + + + + + + + when id = #{item.id,jdbcType=BIGINT} then #{item.payeeAccType,jdbcType=TINYINT} + + + + + + + when id = #{item.id,jdbcType=BIGINT} then #{item.urgent,jdbcType=BOOLEAN} + + + + + + + when id = #{item.id,jdbcType=BIGINT} then #{item.description,jdbcType=VARCHAR} + + + + + + + when id = #{item.id,jdbcType=BIGINT} then #{item.bankState,jdbcType=VARCHAR} + + + + + + + when id = #{item.id,jdbcType=BIGINT} then #{item.businessState,jdbcType=TINYINT} + + + + + + + when id = #{item.id,jdbcType=BIGINT} then #{item.message,jdbcType=VARCHAR} + + + + + + + when id = #{item.id,jdbcType=BIGINT} then #{item.scheduleDate,jdbcType=VARCHAR} + + + + + + + when id = #{item.id,jdbcType=BIGINT} then #{item.creatTime,jdbcType=TIMESTAMP} + + + + + + + when id = #{item.id,jdbcType=BIGINT} then #{item.updateTime,jdbcType=TIMESTAMP} + + + + + where id in + + #{item.id,jdbcType=BIGINT} + + + + + + + insert into trading_record + (pay_no, pay_bill_no, `type`, company, pay_acc, pay_name, pay_amount, payee_bank_name, + payee_bank_no, payee_acc, payee_name, payee_acc_type, urgent, description, bank_state, + business_state, message, schedule_date, pay_bank,creat_time, update_time) + values + + (#{item.payNo,jdbcType=VARCHAR}, #{item.payBillNo,jdbcType=VARCHAR}, #{item.type,jdbcType=TINYINT}, + #{item.company,jdbcType=VARCHAR}, #{item.payAcc,jdbcType=VARCHAR}, #{item.payName,jdbcType=VARCHAR}, + #{item.payAmount,jdbcType=DECIMAL}, #{item.payeeBankName,jdbcType=VARCHAR}, #{item.payeeBankNo,jdbcType=VARCHAR}, + #{item.payeeAcc,jdbcType=VARCHAR}, #{item.payeeName,jdbcType=VARCHAR}, #{item.payeeAccType,jdbcType=TINYINT}, + #{item.urgent,jdbcType=TINYINT}, #{item.description,jdbcType=VARCHAR}, #{item.bankState,jdbcType=VARCHAR}, + #{item.businessState,jdbcType=TINYINT}, #{item.message,jdbcType=VARCHAR}, #{item.scheduleDate,jdbcType=VARCHAR}, + #{item.payBank,jdbcType=VARCHAR},#{item.creatTime,jdbcType=TIMESTAMP}, #{item.updateTime,jdbcType=TIMESTAMP}) + + + + + + + + + + + insert into trading_record + + + id, + + pay_no, + pay_bill_no, + `type`, + company, + pay_acc, + pay_name, + pay_amount, + payee_bank_name, + payee_bank_no, + payee_acc, + payee_name, + payee_acc_type, + urgent, + description, + bank_state, + business_state, + message, + schedule_date, + creat_time, + update_time, + + values + + + #{id,jdbcType=BIGINT}, + + #{payNo,jdbcType=VARCHAR}, + #{payBillNo,jdbcType=VARCHAR}, + #{type,jdbcType=BOOLEAN}, + #{company,jdbcType=VARCHAR}, + #{payAcc,jdbcType=VARCHAR}, + #{payName,jdbcType=VARCHAR}, + #{payAmount,jdbcType=DECIMAL}, + #{payeeBankName,jdbcType=VARCHAR}, + #{payeeBankNo,jdbcType=VARCHAR}, + #{payeeAcc,jdbcType=VARCHAR}, + #{payeeName,jdbcType=VARCHAR}, + #{payeeAccType,jdbcType=TINYINT}, + #{urgent,jdbcType=BOOLEAN}, + #{description,jdbcType=VARCHAR}, + #{bankState,jdbcType=VARCHAR}, + #{businessState,jdbcType=TINYINT}, + #{message,jdbcType=VARCHAR}, + #{scheduleDate,jdbcType=VARCHAR}, + #{creatTime,jdbcType=TIMESTAMP}, + #{updateTime,jdbcType=TIMESTAMP}, + + on duplicate key update + + + id = #{id,jdbcType=BIGINT}, + + pay_no = #{payNo,jdbcType=VARCHAR}, + pay_bill_no = #{payBillNo,jdbcType=VARCHAR}, + `type` = #{type,jdbcType=BOOLEAN}, + company = #{company,jdbcType=VARCHAR}, + pay_acc = #{payAcc,jdbcType=VARCHAR}, + pay_name = #{payName,jdbcType=VARCHAR}, + pay_amount = #{payAmount,jdbcType=DECIMAL}, + payee_bank_name = #{payeeBankName,jdbcType=VARCHAR}, + payee_bank_no = #{payeeBankNo,jdbcType=VARCHAR}, + payee_acc = #{payeeAcc,jdbcType=VARCHAR}, + payee_name = #{payeeName,jdbcType=VARCHAR}, + payee_acc_type = #{payeeAccType,jdbcType=TINYINT}, + urgent = #{urgent,jdbcType=BOOLEAN}, + description = #{description,jdbcType=VARCHAR}, + bank_state = #{bankState,jdbcType=VARCHAR}, + business_state = #{businessState,jdbcType=TINYINT}, + message = #{message,jdbcType=VARCHAR}, + schedule_date = #{scheduleDate,jdbcType=VARCHAR}, + creat_time = #{creatTime,jdbcType=TIMESTAMP}, + update_time = #{updateTime,jdbcType=TIMESTAMP}, + + + + + + + insert into trading_record + + + id, + + + pay_no, + + + pay_bill_no, + + + `type`, + + + company, + + + pay_acc, + + + pay_name, + + + pay_amount, + + + payee_bank_name, + + + payee_bank_no, + + + payee_acc, + + + payee_name, + + + payee_acc_type, + + + urgent, + + + description, + + + bank_state, + + + business_state, + + + message, + + + schedule_date, + + + creat_time, + + + update_time, + + + values + + + #{id,jdbcType=BIGINT}, + + + #{payNo,jdbcType=VARCHAR}, + + + #{payBillNo,jdbcType=VARCHAR}, + + + #{type,jdbcType=BOOLEAN}, + + + #{company,jdbcType=VARCHAR}, + + + #{payAcc,jdbcType=VARCHAR}, + + + #{payName,jdbcType=VARCHAR}, + + + #{payAmount,jdbcType=DECIMAL}, + + + #{payeeBankName,jdbcType=VARCHAR}, + + + #{payeeBankNo,jdbcType=VARCHAR}, + + + #{payeeAcc,jdbcType=VARCHAR}, + + + #{payeeName,jdbcType=VARCHAR}, + + + #{payeeAccType,jdbcType=TINYINT}, + + + #{urgent,jdbcType=BOOLEAN}, + + + #{description,jdbcType=VARCHAR}, + + + #{bankState,jdbcType=VARCHAR}, + + + #{businessState,jdbcType=TINYINT}, + + + #{message,jdbcType=VARCHAR}, + + + #{scheduleDate,jdbcType=VARCHAR}, + + + #{creatTime,jdbcType=TIMESTAMP}, + + + #{updateTime,jdbcType=TIMESTAMP}, + + + on duplicate key update + + + id = #{id,jdbcType=BIGINT}, + + + pay_no = #{payNo,jdbcType=VARCHAR}, + + + pay_bill_no = #{payBillNo,jdbcType=VARCHAR}, + + + `type` = #{type,jdbcType=BOOLEAN}, + + + company = #{company,jdbcType=VARCHAR}, + + + pay_acc = #{payAcc,jdbcType=VARCHAR}, + + + pay_name = #{payName,jdbcType=VARCHAR}, + + + pay_amount = #{payAmount,jdbcType=DECIMAL}, + + + payee_bank_name = #{payeeBankName,jdbcType=VARCHAR}, + + + payee_bank_no = #{payeeBankNo,jdbcType=VARCHAR}, + + + payee_acc = #{payeeAcc,jdbcType=VARCHAR}, + + + payee_name = #{payeeName,jdbcType=VARCHAR}, + + + payee_acc_type = #{businessState,jdbcType=TINYINT}, + + + urgent = #{urgent,jdbcType=BOOLEAN}, + + + description = #{description,jdbcType=VARCHAR}, + + + bank_state = #{bankState,jdbcType=VARCHAR}, + + + business_state = #{businessState,jdbcType=TINYINT}, + + + message = #{message,jdbcType=VARCHAR}, + + + schedule_date = #{scheduleDate,jdbcType=VARCHAR}, + + + creat_time = #{creatTime,jdbcType=TIMESTAMP}, + + + update_time = #{updateTime,jdbcType=TIMESTAMP}, + + + + + + \ No newline at end of file Index: src/main/java/com/novaone/dao/TradingBillRecordMapper.java =================================================================== --- src/main/java/com/novaone/dao/TradingBillRecordMapper.java (不存在的) +++ src/main/java/com/novaone/dao/TradingBillRecordMapper.java (版本 31414) @@ -0,0 +1,64 @@ +package com.novaone.dao; + +import com.novaone.entity.TradingBillRecord; +import java.util.List; +import org.apache.ibatis.annotations.Param; + +public interface TradingBillRecordMapper { + /** + * delete by primary key + * @param id primaryKey + * @return deleteCount + */ + int deleteByPrimaryKey(Long id); + + /** + * insert record to table + * @param record the record + * @return insert count + */ + int insert(TradingBillRecord record); + + int insertOrUpdate(TradingBillRecord record); + + int insertOrUpdateSelective(TradingBillRecord record); + + /** + * insert record to table selective + * @param record the record + * @return insert count + */ + int insertSelective(TradingBillRecord record); + + /** + * select by primary key + * @param id primary key + * @return object by primary key + */ + TradingBillRecord selectByPrimaryKey(Long id); + + List selectByStatus(@Param("status") List status); + + /** + * update record selective + * @param record the updated record + * @return update count + */ + int updateByPrimaryKeySelective(TradingBillRecord record); + + int updateByPayNoSelective(TradingBillRecord record); + + /** + * update record + * @param record the updated record + * @return update count + */ + int updateByPrimaryKey(TradingBillRecord record); + + int updateBatch(List list); + + int updateBatchSelective(List list); + + int batchInsert(@Param("list") List list); + +} \ No newline at end of file Index: src/main/java/com/novaone/dao/TradingHistoryMapper.java =================================================================== --- src/main/java/com/novaone/dao/TradingHistoryMapper.java (不存在的) +++ src/main/java/com/novaone/dao/TradingHistoryMapper.java (版本 31414) @@ -0,0 +1,42 @@ +package com.novaone.dao; + +import com.novaone.entity.TradingHistory; +import java.util.List; +import org.apache.ibatis.annotations.Param; + +public interface TradingHistoryMapper { + /** + * delete by primary key + * @param id primaryKey + * @return deleteCount + */ + int deleteByPrimaryKey(Long id); + + /** + * insert record to table + * @param record the record + * @return insert count + */ + int insert(TradingHistory record); + + /** + * insert record to table selective + * @param record the record + * @return insert count + */ + int insertSelective(TradingHistory record); + + /** + * select by primary key + * @param id primary key + * @return object by primary key + */ + TradingHistory selectByPrimaryKey(Long id); + + /** + * update record selective + * @param record the updated record + * @return update count + */ + int updateByPrimaryKeySelective(TradingHistory record); +} \ No newline at end of file Index: src/main/java/com/novaone/dao/TradingLogMapper.java =================================================================== --- src/main/java/com/novaone/dao/TradingLogMapper.java (不存在的) +++ src/main/java/com/novaone/dao/TradingLogMapper.java (版本 31414) @@ -0,0 +1,62 @@ +package com.novaone.dao; + +import com.novaone.entity.TradingLog; +import java.util.List; +import org.apache.ibatis.annotations.Param; +import org.springframework.transaction.annotation.Propagation; +import org.springframework.transaction.annotation.Transactional; + +@Transactional(propagation = Propagation.REQUIRES_NEW) +public interface TradingLogMapper { + /** + * delete by primary key + * @param id primaryKey + * @return deleteCount + */ + int deleteByPrimaryKey(Long id); + + /** + * insert record to table + * @param record the record + * @return insert count + */ + int insert(TradingLog record); + + int insertOrUpdate(TradingLog record); + + int insertOrUpdateSelective(TradingLog record); + + /** + * insert record to table selective + * @param record the record + * @return insert count + */ + int insertSelective(TradingLog record); + + /** + * select by primary key + * @param id primary key + * @return object by primary key + */ + TradingLog selectByPrimaryKey(Long id); + + /** + * update record selective + * @param record the updated record + * @return update count + */ + int updateByPrimaryKeySelective(TradingLog record); + + /** + * update record + * @param record the updated record + * @return update count + */ + int updateByPrimaryKey(TradingLog record); + + int updateBatch(List list); + + int updateBatchSelective(List list); + + int batchInsert(@Param("list") List list); +} \ No newline at end of file Index: src/main/java/com/novaone/dao/TradingRecordCodeDao.java =================================================================== --- src/main/java/com/novaone/dao/TradingRecordCodeDao.java (不存在的) +++ src/main/java/com/novaone/dao/TradingRecordCodeDao.java (版本 31414) @@ -0,0 +1,45 @@ +package com.novaone.dao; +import lombok.Data; +import org.apache.ibatis.annotations.Insert; +import org.apache.ibatis.annotations.Options; +import org.apache.ibatis.annotations.SelectKey; +import org.springframework.transaction.annotation.Transactional; + +/* + * @program: BankEnterprise + * @description: + * @author: Ma.ChengJian + * @create: 2022-05-12 23:11 + */ +public interface TradingRecordCodeDao { + + + public static class Code{ + + private String prefix; + + private String maxSerial; + + public String getPrefix() { + return prefix; + } + + public void setPrefix(String prefix) { + this.prefix = prefix; + } + + public String getMaxSerial() { + return maxSerial; + } + + public void setMaxSerial(String maxSerial) { + this.maxSerial = maxSerial; + } + } + + + @Transactional + @Insert("INSERT INTO trading_record_code (prefix, max_serial) VALUES (#{prefix}, CONCAT(1)) ON DUPLICATE KEY UPDATE prefix = #{prefix} ,max_serial = CONCAT(max_serial + 1)") + @SelectKey(before = false,keyProperty = "maxSerial", keyColumn = "max_serial", statement = "SELECT LPAD(max_serial,4,0) FROM trading_record_code WHERE prefix = #{prefix}", resultType = String.class) + public int insert(Code code); +} Index: src/main/java/com/novaone/dao/TradingRecordMapper.java =================================================================== --- src/main/java/com/novaone/dao/TradingRecordMapper.java (不存在的) +++ src/main/java/com/novaone/dao/TradingRecordMapper.java (版本 31414) @@ -0,0 +1,74 @@ +package com.novaone.dao; + +import com.novaone.entity.TradingRecord; + +import java.util.Date; +import java.util.List; +import org.apache.ibatis.annotations.Param; +import org.apache.ibatis.annotations.Select; + +public interface TradingRecordMapper { + /** + * delete by primary key + * @param id primaryKey + * @return deleteCount + */ + int deleteByPrimaryKey(Long id); + + /** + * insert record to table + * @param record the record + * @return insert count + */ + int insert(TradingRecord record); + + int insertOrUpdate(TradingRecord record); + + int insertOrUpdateSelective(TradingRecord record); + + /** + * insert record to table selective + * @param record the record + * @return insert count + */ + int insertSelective(TradingRecord record); + + /** + * select by primary key + * @param id primary key + * @return object by primary key + */ + TradingRecord selectByPrimaryKey(Long id); + + /** + * update record selective + * @param record the updated record + * @return update count + */ + int updateByPrimaryKeySelective(TradingRecord record); + + /** + * update record + * @param record the updated record + * @return update count + */ + int updateByPrimaryKey(TradingRecord record); + + int updateBatch(List list); + + int updateBatchSelective(List list); + + int batchInsert(@Param("list") List list); + + List selectByBusinessState(@Param("status")List status); + + + List selectByBillState(@Param("status")List status); + + List selectByScheduleDate(Date date); + + + int countByBusinessState(@Param("status")List status); + + +} \ No newline at end of file Index: src/main/java/com/novaone/payment/BOCClientImpl.java =================================================================== --- src/main/java/com/novaone/payment/BOCClientImpl.java (版本 31413) +++ src/main/java/com/novaone/payment/BOCClientImpl.java (版本 31414) @@ -343,9 +343,9 @@ private ConfigBocVO getConfigBocVO(){ //正式环境信息 - return configService.queryConfigOne(); +// return configService.queryConfigOne(); //测试环境信息 -// return configService.queryConfigTest(); + return configService.queryConfigTest(); }