写的代码小有成就+今日总结--购买产品---20200508

今日经验：
1、transPurchase.setDueRate(new BigDecimal(transPurchase2.getDueRate()));//将string转换为BigDecimal

2、Date formatBankTradeTime = DateUtil.strConvertToDate(transPurchase2.getBankTradeTime());//  string转换为Date，引用DateUtil.工具类

3、DateUtil.工具类

package com.qinjia.finance.base.util;

import org.apache.commons.lang.StringUtils;

import java.text.DateFormat;
import java.text.ParseException;
import java.text.SimpleDateFormat;
import java.util.Calendar;
import java.util.Date;
import java.util.HashMap;
import java.util.Map;


/**
 * 日期相关操作
 */
public class DateUtil {


    private static DateFormat sdf = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");

    public final static String STYLE_1 = "yyyy-MM-dd HH:mm:ss";

    public final static String STYLE_2 = "yyyy-MM-dd";

    public final static String STYLE_3 = "yyyyMMdd";

    public final static String STYLE_4 = "yyyyMMddhh";

    public final static String STYLE_5 = "yyyyMMddhhmmss";

    public final static String STYLE_6 = "yyyy年MM月dd日HH时mm分ss秒";

    public final static String STYLE_7 = "yyyy年MM月dd日HH时mm分";

    public final static String STYLE_8 = "yyyy年MM月dd日";

    public final static String STYLE_9 = "hhmmss";

    public final static String STYLE_10 = "yyyyMMddHHmmss";

    //ISO8601格式时间 例如2019-12-17T10:34:00+0800
    public final static String STYLE_11="yyyy-MM-dd'T'HH:mm:ssZZ";

    //ISO8601格式时间 例如2019-12-17T10:34:00+08:00
    public final static String STYLE_12="yyyy-MM-dd'T'HH:mm:ssXXX";

    private static Map<String, SimpleDateFormat> sdfMap=new HashMap<String, SimpleDateFormat>();

    static{
        sdfMap.put(STYLE_1, new SimpleDateFormat(STYLE_1));
        sdfMap.put(STYLE_2, new SimpleDateFormat(STYLE_2));
        sdfMap.put(STYLE_3, new SimpleDateFormat(STYLE_3));
        sdfMap.put(STYLE_4, new SimpleDateFormat(STYLE_4));
        sdfMap.put(STYLE_5, new SimpleDateFormat(STYLE_5));
        sdfMap.put(STYLE_6, new SimpleDateFormat(STYLE_6));
        sdfMap.put(STYLE_7, new SimpleDateFormat(STYLE_7));
        sdfMap.put(STYLE_8, new SimpleDateFormat(STYLE_8));
        sdfMap.put(STYLE_9, new SimpleDateFormat(STYLE_9));
        sdfMap.put(STYLE_10, new SimpleDateFormat(STYLE_10));
    }

    public static String getCurrentTime() {
        return sdfMap.get(STYLE_5).format(new Date());
    }

    /**
     *获取当前时间字符串yyyyMMddhhmmss
     */
    public static String getNowString() {
        return sdfMap.get(STYLE_10).format(new Date());
    }
    public static String getCurrentTime(String str) {
        return sdfMap.get(str).format(new Date());
    }

    public static String getCurrentTime(String str,String date) {
        return sdfMap.get(str).format(strConvertToDate(date));
    }

    /**
     * 获取当前时间
     * 方法描述
     * @return
     */
    public static String getNowDate(){
        return sdf.format(new Date());
    }

    /**
     * 字符串类型转化为日期类型
     * @param str
     * @return
     */
    public static Date strConvertToDate(String str){
        if(StringUtils.isNotEmpty(str)){
            try {
                return sdf.parse(str);
            } catch (ParseException e) {
                // TODO Auto-generated catch block
                e.printStackTrace();
            }
        }
        return null;
    }

    /**
     * 日期类型转化为制定的日期格式
     * @param date
     * @return
     */
    public static Date dateConvertToDate(Date date){
        String str= sdf.format(date);
        try {
            return sdf.parse(str);
        } catch (ParseException e) {
            // TODO Auto-generated catch block
            e.printStackTrace();
        }
        return date;
    }
    /**
     * 比较时间大小
     *
     * @param beginDate 开始时间
     * @param endDate   结束时间
     * @return true begin大于end
     */
    public static boolean datecompare(Date beginDate,Date endDate){
        try{
            if(beginDate==null || endDate==null){
                return false;
            }
            if(beginDate.getTime()>=endDate.getTime()){
                return true;
            }

        }catch(Exception e){
            e.printStackTrace();
        }
        return false;
    }
    /**
     * 判断number是不是在两者之间
     * @author wu.yy
     *
     * @param number
     * @param start
     * @param end
     * @return
     */
    public static boolean during(int number,int start,int end){
        if(number>=start && number<end){
            return true;
        }
        return false;
    }
    /**
     * 根据不同的类别获取相应的统计格式
     * @param lb 类别 kk_day 天 kk_month月 kk_jd季度 kk_year年kk_kk 卡口
     * @param code 类别相应的编码值
     * @param beginDate 开始时间
     * @param endDate 结束时间
     * @return map对象
     */
    public static Map<String, Object> getTimeByLb(String lb,String code,String beginDate,String endDate){
        Map<String, Object> map = new HashMap<String, Object>();
        if(StringUtils.isBlank(lb)){
            map.put("code", "to_char(t.pass_time,'yyyy-mm-dd')");
            map.put("beginDate", "trunc(sysdate-7)");
            map.put("endDate", "trunc(sysdate-1)");
        }else if("kk_day".equalsIgnoreCase(lb)){
            map.put("code", "to_char(t.pass_time,'yyyy-mm-dd')");
            if("0".equalsIgnoreCase(code)){
                map.put("beginDate", "trunc(sysdate-7)");
                map.put("endDate", "trunc(sysdate-1)");
            }else if("1".equalsIgnoreCase(code)){
                map.put("beginDate", "trunc(add_months(sysdate,-1))");
                map.put("endDate", "trunc(sysdate-1)");
            }else if("2".equalsIgnoreCase(code)){
                if(StringUtils.isNotBlank(beginDate)){
                    map.put("beginDate","to_date('"+beginDate+"','yyyy-mm-dd')");
                }
                if(StringUtils.isNotBlank(endDate)){
                    map.put("endDate", "to_date('"+endDate+"','yyyy-mm-dd')");
                }
            }
            return map;
        }else if("kk_month".equalsIgnoreCase(lb)){
            map.put("code", "to_char(t.pass_time,'yyyy-mm')");
            if("0".equalsIgnoreCase(code)){
                map.put("beginDate", "trunc(add_months(sysdate,-3))");
                map.put("endDate", "trunc(sysdate-1)");
            }else if("1".equalsIgnoreCase(code)){
                map.put("beginDate", "trunc(add_months(sysdate,-6))");
                map.put("endDate", "trunc(sysdate-1)");
            }else if("2".equalsIgnoreCase(code)){
                map.put("beginDate", "trunc(add_months(sysdate,-12))");
                map.put("endDate", "trunc(sysdate-1)");
            }else if("3".equalsIgnoreCase(code)){
                if(StringUtils.isNotBlank(beginDate)){
                    map.put("beginDate","to_date('"+beginDate+"-01-01','yyyy-mm-dd')");
                    map.put("endDate", "to_date('"+beginDate+"-12-31','yyyy-mm-dd')");
                }
            }
            return map;
        }else if("kk_jd".equalsIgnoreCase(lb)){
            map.put("code", "to_char(t.pass_time,'Q')");
            map.put("bswq", beginDate);
            if("0".equalsIgnoreCase(code)){
                if(StringUtils.isNotBlank(beginDate)){
                    map.put("beginDate","to_date('"+beginDate+"-01-01','yyyy-mm-dd')");
                    map.put("endDate", "to_date('"+beginDate+"-12-31','yyyy-mm-dd')");
                }
            }
            return map;
        }else if("kk_year".equalsIgnoreCase(lb)){
            map.put("code", "to_char(t.pass_time,'yyyy')");
            map.put("bswy", beginDate);
            if("0".equalsIgnoreCase(code)){
                if(StringUtils.isNotBlank(beginDate)){
                    map.put("beginDate","to_date('"+beginDate+"-01-01','yyyy-mm-dd')");
                }
                if(StringUtils.isNotBlank(endDate)){
                    map.put("endDate", "to_date('"+endDate+"-12-31','yyyy-mm-dd')");
                }
            }
            return map;
        }else if("kk_kk".equalsIgnoreCase(lb)){
            map.put("code", "pass_port_name");
            if("0".equalsIgnoreCase(code)){
                map.put("beginDate", "trunc(sysdate-7)");
                map.put("endDate", "trunc(sysdate-1)");
            }else if("1".equalsIgnoreCase(code)){
                map.put("beginDate", "trunc(add_months(sysdate,-1))");
                map.put("endDate", "trunc(sysdate-1)");
            }else if("2".equalsIgnoreCase(code)){
                map.put("beginDate", "trunc(add_months(sysdate,-3))");
                map.put("endDate", "trunc(sysdate-1)");
            }else if("3".equalsIgnoreCase(code)){
                map.put("beginDate", "trunc(add_months(sysdate,-6))");
                map.put("endDate", "trunc(sysdate-1)");
            }else if("4".equalsIgnoreCase(code)){
                map.put("beginDate", "trunc(add_months(sysdate,-12))");
                map.put("endDate", "trunc(sysdate-1)");
            }else if("5".equalsIgnoreCase(code)){
                if(StringUtils.isNotBlank(beginDate)){
                    map.put("beginDate","to_date('"+beginDate+"-01-01','yyyy-mm-dd')");
                }
                if(StringUtils.isNotBlank(endDate)){
                    map.put("endDate", "to_date('"+endDate+"-12-31','yyyy-mm-dd')");
                }
            }else if("6".equalsIgnoreCase(code)){
                map.put("beginDate","to_date('"+beginDate+"-"+((Integer.parseInt(endDate)-1)*3+1)+"-01','yyyy-mm-dd')");
                map.put("endDate", "to_date('"+beginDate+"-"+(Integer.parseInt(endDate)*3)+"-"+getDayByMonth(String.valueOf(Integer.parseInt(endDate)*3))+"','yyyy-mm-dd')");
            }else if("7".equalsIgnoreCase(code)){
                map.put("beginDate","to_date('"+beginDate+"-"+endDate+"-01','yyyy-mm-dd')");
                map.put("endDate", "to_date('"+beginDate+"-"+endDate+"-"+getDayByMonth(endDate)+"','yyyy-mm-dd')");
            }else if("8".equalsIgnoreCase(code)){
                if(StringUtils.isNotBlank(beginDate)){
                    map.put("beginDate","to_date('"+beginDate+"','yyyy-mm-dd')");
                }
                if(StringUtils.isNotBlank(endDate)){
                    map.put("endDate", "to_date('"+endDate+"','yyyy-mm-dd')");
                }
            }
            return map;
        }
        return map;
    }
    /**
     * 根据当前月份获取该月最后一天日期
     * @param month 月份
     * @return 该月最后一天日期
     */
    private static String getDayByMonth(String month){
        if("2".equalsIgnoreCase(month)){
            return "28";
        }else if("1".equalsIgnoreCase(month) || "3".equalsIgnoreCase(month) || "5".equalsIgnoreCase(month) || "7".equalsIgnoreCase(month) || "8".equalsIgnoreCase(month) || "10".equalsIgnoreCase(month) || "12".equalsIgnoreCase(month)){
            return "31";
        }else{
            return "30";
        }
    }

    /**
     * 获取当前日期前一天
     * @return date
     */
    public static Date getLastDay(){
        Calendar calendar = Calendar.getInstance();
        calendar.add(Calendar.DATE, -1);    //得到前一天
        Date date = calendar.getTime();
        return date;
    }

    /**
     * 获取当前日期前两天
     * @return date
     */
    public static Date getLastTwoDay(){
        Calendar calendar = Calendar.getInstance();
        calendar.add(Calendar.DATE, -2);    //得到前一天
        Date date = calendar.getTime();
        return date;
    }
    
    
    /**
     * 获取当前日期前n天
     * @return date
     */
    public static Date getLast(int day){
        Calendar calendar = Calendar.getInstance();
        calendar.add(Calendar.DATE, -day);    //得到前一天
        Date date = calendar.getTime();
        return date;
    }

    /**
     * 获取当前日期后n天
     * @return date
     */
    public static Date getLastDay(Date date1 ,int days){
        Calendar calendar = Calendar.getInstance();
        calendar.setTime(date1);
        calendar.add(Calendar.DATE, -days);    //得到前一天
        Date date = calendar.getTime();
        return date;
    }

    /**
     * 格式化日期
     * @param format
     * @return
     */
    public static String formatDate(String format){
        SimpleDateFormat sFormat = new SimpleDateFormat(format);
        return sFormat.format(new Date());
    }

    /**
     * 格式化日期
     * @param format
     * @return
     */
    public static String formatDate(Date date,String format){
        SimpleDateFormat sFormat = new SimpleDateFormat(format);
        return sFormat.format(date);
    }
    /**
     * 时间格式化为：yyyyMMddHHmmss
     * @param date
     * @return 返回已格式化的字符串
     */
    public static String getDateString(Date date){
        SimpleDateFormat s = new SimpleDateFormat("yyyyMMddHHmmss");
        return s.format(date);
    }
    /**
     * 判断验证码是否失效
     * @param date1 ： 数据库中的时间
     * @param code：数据字典中的子健code
     * @return false 失效  true 未失效
     * @throws HsException
     */
    public static Boolean isDateBig(String date1,String errortime) throws Exception{
        SimpleDateFormat s = new SimpleDateFormat("yyyyMMddHHmmss");
        Date date = s.parse(date1);//将已格式化的时间字符串转成时间格式
        long dataBaseTame = date.getTime();//将具体时间转成毫秒数
        //将修改时间加上数据字典中配置的参数
        long secon =  Integer.parseInt(errortime)*1000 + dataBaseTame;
        Date nowDate = new Date();//获取当前时间
        long nowDateTime = nowDate.getTime();//将具体时间转成毫秒数
        if(secon < nowDateTime){ //判断验证码是否已失效
            return false;
        }
        return true;
    }
    /**
     * 将yyyy年MM月dd天格式的时间字符串转为yyyymmdd格式
     * @param date
     * @return 返回已格式化的字符串
     * @throws HsException
     */
    public static String changeDate(String str) throws Exception{
        SimpleDateFormat s = new SimpleDateFormat("yyyy年MM月dd日");
        Date date = s.parse(str);
        return getDateString(date);
    }
    /**
     * 将yyyy年MM月dd天格式的时间字符串转为yyyymmdd格式
     * @param date
     * @return 返回已格式化的字符串
     * @throws HsException
     */
    public static String changeDates(String str) throws Exception{
        SimpleDateFormat s = new SimpleDateFormat("yyyyMMdd");
        SimpleDateFormat s1 = new SimpleDateFormat("yyyy年MM月dd日 ");
        str = str.substring(0, 8);
        Date date = s.parse(str);
        return s1.format(date);
    }

    /**
     * 将yyyy-MM-dd HH:mm:ss 时间格式转换为 yyyyMMddHHmmss格式
     * @param str 时间格式字符串，格式为yyyy-MM-dd HH:mm:ss
     * @return
     * @throws Exception
     */
    public static String changeDatesString(String str) throws Exception{
        SimpleDateFormat sdfStyle1 = sdfMap.get(STYLE_1);
        SimpleDateFormat sdfStyle10 = sdfMap.get(STYLE_10);
        return sdfStyle10.format(sdfStyle1.parse(str));

    }
    /**
     * 判断用户输入密码错误不能登录时间是否已过
     * @param date1 ： 数据库中用户密码输入错误时间
     * @param code：数据字典中的子健code
     * @return false 锁定时间内 true 锁定时间外
     * @throws HsException
     */
    public static Boolean isErrorTime(String date1,String code,String limtime) throws Exception{
        SimpleDateFormat s = new SimpleDateFormat("yyyyMMddHHmmss");
        Date date = s.parse(date1);//将已格式化的时间字符串转成时间格式
        long dataBaseTame = date.getTime();//将具体时间转成毫秒数
        //将修改时间加上数据字典中配置的参数
        long secon =  Integer.parseInt(limtime)*1000 + dataBaseTame;
        Date nowDate = new Date();//获取当前时间
        long nowDateTime = nowDate.getTime();//将具体时间转成毫秒数
        if(secon > nowDateTime){ //判断用户是否在锁定时间内
            return false;
        }
        return true;
    }


    /**
     * 获取当前日期前两天
     * @return date
     */
    public static Date getLastMouth(Date date1 ,int mouth){
        Calendar calendar = Calendar.getInstance();
        calendar.setTime(date1);
        calendar.add(Calendar.MONTH, mouth);    //得到前一天
        Date date = calendar.getTime();
        return date;
    }

    /**
     * 字符串类型转化为日期类型
     * @param str
     * @return
     */
    public static Date strConvertToDate2(String str1,String str){
        if(StringUtils.isNotEmpty(str)){
            try {
                return sdfMap.get(str1).parse(str);
            } catch (ParseException e) {
                // TODO Auto-generated catch block
                e.printStackTrace();
            }
        }
        return null;
    }

    /**
     * 将时间戳转换成时间格式
     * example：1499137275926 to 20170704110115
     * @param timeStamp
     * @return
     */
    public static String timestampToDateStr(long timeStamp){
        SimpleDateFormat sdf = sdfMap.get(STYLE_10);
        Date date = new Date(timeStamp);
        return sdf.format(date);
    }

    /**
     * 将 yyyyMMddHHmmss 时间格式转换为yyyy-MM-dd HH:mm:ss格式
     * @param str 时间格式字符串，格式为yyyyMMddHHmmss
     * @return
     * @throws Exception
     */
    public static String dateFormat(String str) throws Exception{
        SimpleDateFormat sdfStyle1 = sdfMap.get(STYLE_1);
        SimpleDateFormat sdfStyle10 = sdfMap.get(STYLE_10);
        return sdfStyle1.format(sdfStyle10.parse(str));
    }

    /**
     * 日期增加月份部分
     *
     * @param date
     * @param amount
     * @return
     */
    public static Date addMonth(Date date, int amount) {
        return add(date, Calendar.MONTH, amount);
    }

    /**
     * 日期增加分钟部分
     *
     * @param date
     * @param amount
     * @return
     */
    public static Date addMiunte(Date date, int amount) {
        return add(date, Calendar.MINUTE, amount);
    }

    public static Date add(Date date, int field, int amount) {
        if (date == null) {
            date = new Date();
        }

        Calendar cal = Calendar.getInstance();
        cal.setTime(date);
        cal.add(field, amount);

        return cal.getTime();
    }
    
    
    /**
     * 判断当前时间是否在[startTime, endTime]区间，注意时间格式要一致
     *
     * @param nowTime
     *            当前时间
     * @param startTime
     *            开始时间
     * @param endTime
     *            结束时间
     * @return
     */
    public static boolean isEffectiveDate(Date nowTime, Date startTime, Date endTime) {
        if (nowTime.getTime() == startTime.getTime() || nowTime.getTime() == endTime.getTime()) {
            return true;
        }

        Calendar date = Calendar.getInstance();
        date.setTime(nowTime);

        Calendar begin = Calendar.getInstance();
        begin.setTime(startTime);

        Calendar end = Calendar.getInstance();
        end.setTime(endTime);

        if (date.after(begin) && date.before(end)) {
            return true;
        } else {
            return false;
        }
    }

    /**
     * 返回两个日期的相隔天数
     * @param startDate
     * @param endDate
     * @return
     */
    public static Long getDaysBetween(Date startDate, Date endDate) {
        Calendar fromCalendar = Calendar.getInstance();
        fromCalendar.setTime(startDate);
        fromCalendar.set(Calendar.HOUR_OF_DAY, 0);
        fromCalendar.set(Calendar.MINUTE, 0);
        fromCalendar.set(Calendar.SECOND, 0);
        fromCalendar.set(Calendar.MILLISECOND, 0);

        Calendar toCalendar = Calendar.getInstance();
        toCalendar.setTime(endDate);
        toCalendar.set(Calendar.HOUR_OF_DAY, 0);
        toCalendar.set(Calendar.MINUTE, 0);
        toCalendar.set(Calendar.SECOND, 0);
        toCalendar.set(Calendar.MILLISECOND, 0);

        return (toCalendar.getTime().getTime() - fromCalendar.getTime().getTime()) / (1000 * 60 * 60 * 24);
    }


    /**
     * 获取某月的最后一天
     *
     */
    public static Date getLastDayOfMonth(int year,int month)
    {
        Calendar cal = Calendar.getInstance();
        //设置年份
        cal.set(Calendar.YEAR,year);
        //设置月份
        cal.set(Calendar.MONTH, month-1);
        //获取某月最大天数
        int lastDay = cal.getActualMaximum(Calendar.DAY_OF_MONTH);
        //设置日历中月份的最大天数
        cal.set(Calendar.DAY_OF_MONTH, lastDay);
        return cal.getTime();
    }
}

 package com.qinjia.finance.service.impl;
  2 
  3 import com.alibaba.fastjson.JSON;
  4 import com.alibaba.fastjson.JSONObject;
  5 import com.qinjia.finance.base.util.DateUtil;
  6 import com.qinjia.finance.base.util.IdGenerator;
  7 import com.qinjia.finance.common.constant.CommonConstant;
  8 import com.qinjia.finance.common.util.BaoShengUtil;
  9 import com.qinjia.finance.dto.ProductBuyRes;
 10 import com.qinjia.finance.dto.ResponseDto;
 11 import com.qinjia.finance.entity.*;
 12 import com.qinjia.finance.enums.UriEnums;
 13 import com.qinjia.finance.mapper.*;
 14 import com.qinjia.finance.service.BsEventHandleService;
 15 import com.qinjia.finance.service.ProductService;
 16 import lombok.extern.log4j.Log4j2;
 17 import org.springframework.beans.BeanUtils;
 18 import org.springframework.beans.factory.annotation.Autowired;
 19 import org.springframework.stereotype.Service;
 20 import org.springframework.transaction.annotation.Transactional;
 21 import tk.mybatis.mapper.entity.Example;
 22 import javax.annotation.Resource;
 23 import java.math.BigDecimal;
 24 import java.util.Date;
 25 import java.util.List;
 26 
 27 /**
 28  * 5.3购买产品接口
 29  */
 30 @Service("productBuyService")
 31 @Log4j2
 32 public class ProductBuyServiceImpl implements ProductService, BsEventHandleService {
 33 
 34    @Autowired
 35    BaoShengUtil baoShengUtil;
 36    @Resource
 37    TransPurchaseMapper transPurchaseMapper;
 38    @Resource
 39    AcctMainMapper acctMainMapper;
 40    @Resource
 41     CustBaseInfoMapper custBaseInfoMapper;
 42    @Resource
 43     AcctSubMapper acctSubMapper;
 44    @Resource
 45     AcctEntryMapper acctEntryMapper;
 46 
 47 
 48 
 49    @Override
 50    public Object call(String serviceName, Object... object) throws Exception {
 51       //组装请求报文
 52       //发送宝生接口
 53       //组装mq消息，发送
 54       ResponseDto responseDto = baoShengUtil.messageSend(UriEnums.DBANKAPI_PROD_BUY.getUrl(),object[0]);
 55       responseDto.configData(ProductBuyRes.class);
 56       return responseDto;
 57    }
 58 
 59    @Override
 60    @Transactional(rollbackFor = Exception.class)
 61    public boolean handleMsg(JSONObject jsonObject) throws Exception {
 62        /** ###############  整体逻辑  #####################
 63          * 1、t_trans_purchase 表增加一条购买记录（无论交易成功还是失败）
 64          * 2、如果1交易成功，判断是否存在产品账户 t_acct_sub；同时定义全局全局变量:产品账户交易前金额（目的：交易流水记录用到）
 65          * 2.1.1、存在：修改产品账户金额：交易前金额+交易金额；同时赋值全局变量:产品账户交易前金额
 66         * 2.1.2、不存在：新增产品账户，产品账户金额：交易金额；全局变量:产品账户交易前金额（0.00）
 67          * 2.2、获取存管账户 t_acct_sub，更改相关交易金额
 68          * 3.1、t_acct_entry 增加记录：产品购买记录（余额+）
 69          * 3.2、t_acct_entry 增加记录：账户购买记录（余额-）
 70        */
 71       log.info("====处理产品购买信息====");
 72       //1、新增购买记录
 73       //新增交易流水信息
 74       String inParam = jsonObject.getString("inParam");
 75       String outParam = jsonObject.getString("outParam");
 76       TransPurchase transPurchase1 = JSON.parseObject(inParam, TransPurchase.class);
 77       ProductBuyRes transPurchase2 = JSON.parseObject(outParam, ProductBuyRes.class);
 78       //保存出参信息
 79       TransPurchase transPurchase = new TransPurchase();
 80       BeanUtils.copyProperties(transPurchase2,transPurchase);
 81         transPurchase.setId(Long.parseLong(IdGenerator.generateId()));
 82       transPurchase.setFundCode(CommonConstant.FUND_NO);   //资金方编号
 83       transPurchase.setAssetNo(CommonConstant.ASSET_NO);//资产方编号
 84       transPurchase.setTelephone(transPurchase1.getTelephone());
 85       transPurchase.setProductCode(transPurchase1.getProductCode());
 86       transPurchase.setTradeAmount(transPurchase1.getTradeAmount());
 87       transPurchase.setCreateTime(new Date());
 88       transPurchase.setUpdateTime(new Date());
 89         Date formatBankTradeTime = DateUtil.strConvertToDate(transPurchase2.getBankTradeTime());
 90         Date formatInterestBeginDate = DateUtil.strConvertToDate(transPurchase2.getInterestBeginDate());
 91         Date formatRedeemableDate = DateUtil.strConvertToDate(transPurchase2.getRedeemableDate());
 92         Date formatNextValueDate = DateUtil.strConvertToDate(transPurchase2.getNextValueDate());
 93         transPurchase.setRedeemableDate(formatRedeemableDate);
 94         transPurchase.setInterestBeginDate(formatInterestBeginDate);
 95         transPurchase.setInterestEndDate(transPurchase2.getInterestDueEndDate());
 96         transPurchase.setDueRate(new BigDecimal(transPurchase2.getDueRate()));
 97         transPurchase.setDueInterestAmount(new BigDecimal(transPurchase2.getDueInterestAmount()));
 98         transPurchase.setNextValueDate(formatNextValueDate);
 99         transPurchase.setBankTradeTime(formatBankTradeTime);
100       transPurchaseMapper.insertSelective(transPurchase);
101       //购买成功数据落库
102         if("FAIL".equals(transPurchase2.getTradeStatus())){
103             log.info("购买产品失败...");
104         }
105         if("PROCESSING".equals(transPurchase2.getTradeStatus())){
106             log.info("购买产品处理中...");
107         }
108         if ("SUCCESS".equals(transPurchase2.getTradeStatus())) {
109             //2.1
110             //2.1.1、根据thirdUserId获取主账号cust_id
111             Example example1 = new Example(CustBaseInfo.class);
112             example1.createCriteria().andEqualTo("thirdUserId", transPurchase1.getThirdUserId());
113             List<CustBaseInfo> custBaseInfoList = custBaseInfoMapper.selectByExample(example1);
114             CustBaseInfo custBaseInfo = new CustBaseInfo();
115             if (!custBaseInfoList.isEmpty()) {
116                 custBaseInfo = custBaseInfoList.get(0);
117             }
118 
119             //2.1.2 根据cust_id和产品代码查询t_acct_sub 获取产品账户
120             Example example5 = new Example(AccSub.class);
121             example5.createCriteria().andEqualTo("custId", custBaseInfo.getId())
122                     .andEqualTo("acctNo", transPurchase1.getProductCode());
123             List<AccSub> accSubListForProductPanDuan = acctSubMapper.selectByExample(example5);
124             AccSub accSubForNewOrUpdate = new AccSub();
125             //2.1.3、根据thirdUserId获取主账号id 和UserName
126             Example example = new Example(AcctMain.class);
127             example.createCriteria().andEqualTo("acctNo", transPurchase1.getThirdUserId());
128             List<AcctMain> acctMainList = acctMainMapper.selectByExample(example);
129             AcctMain acctMain = new AcctMain();
130             if (!acctMainList.isEmpty()) {
131                 acctMain = acctMainList.get(0);
132             }
133             BigDecimal productAccBalancePre = new BigDecimal(0);//定义变量：产品账户交易前余额
134             if (!accSubListForProductPanDuan.isEmpty()) {
135                 // 存在,修改金额:当前金额加交易金额
136                 accSubForNewOrUpdate = accSubListForProductPanDuan.get(0);
137                 //2.1.4、获取交易前产品账户余额
138                 productAccBalancePre = accSubForNewOrUpdate.getBalance();
139                 accSubForNewOrUpdate.setBalance(accSubForNewOrUpdate.getBalance().add(transPurchase1.getTradeAmount()));
140                 accSubForNewOrUpdate.setUpdateTime(new Date());
141                 //   2.1 、或修改产品账户
142                 acctSubMapper.updateByPrimaryKey(accSubForNewOrUpdate);
143             } else {
144                 //不存在,新增产品账户 当前金额为交易金额
145                 accSubForNewOrUpdate.setId(Long.parseLong(IdGenerator.generateId()));
146                 accSubForNewOrUpdate.setParentId(acctMain.getId());
147                 accSubForNewOrUpdate.setAcctType("20"); //指定产品账户
148                 accSubForNewOrUpdate.setAcctNo(transPurchase.getProductCode());//产品代码
149                 accSubForNewOrUpdate.setCustId(custBaseInfo.getId());
150                 accSubForNewOrUpdate.setUserName(acctMain.getUserName());
151                 accSubForNewOrUpdate.setFundCode(CommonConstant.FUND_NO);
152                 accSubForNewOrUpdate.setAssetNo(CommonConstant.ASSET_NO);
153                 accSubForNewOrUpdate.setBalance(transPurchase1.getTradeAmount());//当前金额为交易金额
154                 accSubForNewOrUpdate.setCreateTime(new Date());
155                 accSubForNewOrUpdate.setUpdateTime(new Date());
156                 // 2.1、或新增产品账户
157                 acctSubMapper.insertSelective(accSubForNewOrUpdate);
158             }
159             // 2.2、t_acct_sub 存管户余额减少
160             // 2.2.1 设置查询条件：thirdUserId，10存管账户 查找存管账户   条件为：example3，结果为accSub2
161             Example example3 = new Example(AccSub.class);
162             example3.createCriteria().andEqualTo("custId", custBaseInfo.getId())
163                     .andEqualTo("acctType", "10");//设置查询条件：thirdUserId，10存管账户
164             List<AccSub> accSubList = acctSubMapper.selectByExample(example3);
165             AccSub accSub2 = new AccSub();
166             BigDecimal accBalancePre = new BigDecimal(0);  //定义变量：存管账户交易前余额
167             if (!accSubList.isEmpty()) {
168                 accSub2 = accSubList.get(0);
169                 accBalancePre = accSub2.getBalance();
170                 accSub2.setBalance(accSub2.getBalance().subtract(transPurchase1.getTradeAmount()));//存管账户余额为当前余额减交易金额
171                 accSub2.setUpdateTime(new Date());
172                 // 2.2、t_acct_sub 存管户余额减少
173                 acctSubMapper.updateByPrimaryKey(accSub2);
174             }
175             //3 t_acct_entry账户金额变动日志表增加两条流水
176             //3.1、新增一条产品账户金额增加记录
177             AcctEntry acctEntry = new AcctEntry();
178             acctEntry.setId(Long.parseLong(IdGenerator.generateId()));
179             acctEntry.setSubAcctId(accSubForNewOrUpdate.getId());
180             acctEntry.setOppAcctId(Long.valueOf(2));//本账户是充值，则对手方为购买（提现）
181             acctEntry.setPreAmt(productAccBalancePre);//产品账户交易前金额
182             acctEntry.setTransAmt(transPurchase1.getTradeAmount());//交易金额
183             acctEntry.setPostAmt(acctEntry.getPreAmt().add(acctEntry.getTransAmt()));//交易后金额=交易前金额+交易金额
184             acctEntry.setTransType("CZ");//
185             acctEntry.setTransId(transPurchase.getId());
186             acctEntry.setBalance(acctEntry.getPostAmt());
187             acctEntry.setCreateTime(new Date());
188             acctEntry.setUpdateTime(new Date());
189             acctEntryMapper.insertSelective(acctEntry);
190 
191             AcctEntry acctEntry2 = new AcctEntry();
192             acctEntry2.setId(Long.parseLong(IdGenerator.generateId()));
193             acctEntry2.setSubAcctId(accSubForNewOrUpdate.getId());
194             acctEntry2.setOppAcctId(Long.valueOf(1));//本账户是购买，则对手方为充值
195             acctEntry2.setPreAmt(accBalancePre);
196             acctEntry2.setTransAmt(transPurchase1.getTradeAmount());
197             acctEntry2.setPostAmt(acctEntry2.getPreAmt().subtract(acctEntry2.getTransAmt()));//交易后金额=交易前金额-交易金额
198             acctEntry2.setTransType("SG");//交易类型 :SG申购
199             acctEntry2.setTransId(transPurchase.getId());
200             acctEntry2.setBalance(acctEntry2.getPostAmt());
201             acctEntry2.setCreateTime(new Date());
202             acctEntry2.setUpdateTime(new Date());
203             acctEntryMapper.insertSelective(acctEntry2);
204         }
205         return false;
206    }
207 
208    @Override
209    public UriEnums get() {
210       return UriEnums.DBANKAPI_PROD_BUY;
211    }
212 
213 }
214 
215 
216 ============================