soc/soc-modules/soc-modules-sms/src/main/java/com/xunmei/sms/vo/SmsInfoVo.java

package com.xunmei.sms.vo;

import com.dc.eai.data.CompositeData;
import com.dc.eai.data.Field;
import com.dc.eai.data.FieldAttr;
import com.dc.eai.data.FieldType;
import lombok.Data;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;

/**
 * @author wubiyu[2024/03/18]
 */
@Data
public class SmsInfoVo {
    private static Logger logger = LoggerFactory.getLogger(SmsInfoVo.class);
    /**
     * 交易类型
     */
    private String tranType;
    /**
     * 机构号
     */
    private String branchId;
    /**
     * 消费者系统流水号
     */
    private String consumerSeqNo;
    /**
     * 客户号
     */
    private String custNo;
    /**
     * 客户姓名
     */
    private String custName;

    /**
     * 性别
     */
    private String sex;

    /**
     * 手机号
     */
    private String mobile;

    /**
     * 帐号
     */
    private String acctNo;
    /**
     * 发生日期 格式：yyyy-MM-dd
     */
    private String occurDate;
    /**
     * 发生时间：格式：Hh:mm:ss
     */
    private String occurTime;
    /**
     * 交易金额1
     */
    private String tranAmt1;
    /**
     * 交易金额1
     */
    private String tranAmt2;
    /**
     * 交易金额1
     */
    private String tranAmt3;

    /**
     * 支出/存入位1
     */
    private String payoutStoreBit1;
    /**
     * 支出/存入位2
     */
    private String payoutStoreBit2;
    /**
     * 支出/存入位1
     */
    private String payoutStoreBit3;

    /**
     * 交易摘要
     */
    private String tranRemark;
    /**
     * 帐户状态
     */
    private String acctStatus;
    /**
     * 渠道类型
     */
    private String channelType;
    /**
     * 备用1
     */
    private String bak1;
    /**
     * 备用2
     */
    private String bak2;
    /**
     * 备用3
     */
    private String bak3;

    public static CompositeData convertTo(SmsInfoVo source) {
        try {
            /***********************************************************************
             * *********构造请求数据，定义相关结构体*******
             **********************************************************************/
            CompositeData reqData = new CompositeData();
            CompositeData sysData = new CompositeData();
            CompositeData appData = new CompositeData();
            CompositeData body = new CompositeData();

            reqData.addStruct("SYS_HEAD", sysData);
            reqData.addStruct("APP_HEAD", appData);
            reqData.addStruct("BODY", body);

            /***********************************************************************
             * ********* 系统头 ******************
             **********************************************************************/
            if (source.getConsumerSeqNo() != null) {
                Field field = new Field(new FieldAttr(FieldType.FIELD_STRING, 15, 0));
                field.setValue(source.getConsumerSeqNo());
                sysData.addField("CONSUMER_SEQ_NO", field);
            }

            /***********************************************************************
             * ********** 应用头 ***************
             **********************************************************************/
            if (source.getBranchId() != null) {
                Field field = new Field(new FieldAttr(FieldType.FIELD_STRING, 9, 0));
                field.setValue(source.getBranchId());
                appData.addField("BRANCH_ID", field);
            }

            // 应用头其他需要上送的数据。。。

            /***********************************************************************
             * ************* 报文体 ************ 服务代码为11003000002，场景为07定义的输入数据
             **********************************************************************/

            if (source.getTranType() != null) {
                Field field = new Field(new FieldAttr(FieldType.FIELD_STRING, 6, 0));
                field.setValue(source.getTranType());
                body.addField("TRAN_TYPE", field);
            }
            if (source.getCustNo() != null) {
                Field field = new Field(new FieldAttr(FieldType.FIELD_STRING, 22, 0));
                field.setValue(source.getCustNo());
                body.addField("CUST_NO", field);
            }

            if (source.getCustName() != null) {
                Field field = new Field(new FieldAttr(FieldType.FIELD_STRING, 50, 0));
                field.setValue(source.getCustNo());
                body.addField("CUST_NAME", field);
            }
            if (source.getSex() != null) {
                Field field = new Field(new FieldAttr(FieldType.FIELD_STRING, 2, 0));
                field.setValue(source.getSex());
                body.addField("SEX", field);
            }
            if (source.getMobile() != null) {
                Field field = new Field(new FieldAttr(FieldType.FIELD_STRING, 20, 0));
                field.setValue(source.getMobile());
                body.addField("MOBILE", field);
            }
            if (source.getAcctNo() != null) {
                Field field = new Field(new FieldAttr(FieldType.FIELD_STRING, 32, 0));
                field.setValue(source.getAcctNo());
                body.addField("ACCT_NO", field);
            }

            if (source.getOccurDate() != null) {
                Field field = new Field(new FieldAttr(FieldType.FIELD_STRING, 10, 0));
                field.setValue(source.getOccurDate());
                body.addField("OCCUR_DATE", field);
            }

            if (source.getOccurTime() != null) {
                Field field = new Field(new FieldAttr(FieldType.FIELD_STRING, 10, 0));
                field.setValue(source.getOccurTime());
                body.addField("OCCUR_TIME", field);
            }

            if (source.getTranAmt1() != null) {
                Field field = new Field(new FieldAttr(FieldType.FIELD_STRING, 17, 0));
                field.setValue(source.getTranAmt1());
                body.addField("TRAN_AMT1", field);
            }

            if (source.getTranAmt2() != null) {
                Field field = new Field(new FieldAttr(FieldType.FIELD_STRING, 17, 0));
                field.setValue(source.getTranAmt2());
                body.addField("TRAN_AMT2", field);
            }

            if (source.getTranAmt3() != null) {
                Field field = new Field(new FieldAttr(FieldType.FIELD_STRING, 17, 0));
                field.setValue(source.getTranAmt3());
                body.addField("TRAN_AMT3", field);
            }

            if (source.getPayoutStoreBit1() != null) {
                Field field = new Field(new FieldAttr(FieldType.FIELD_STRING, 1, 0));
                field.setValue(source.getPayoutStoreBit1());
                body.addField("PAYOUT_STORE_BIT1", field);
            }
            if (source.getPayoutStoreBit2() != null) {
                Field field = new Field(new FieldAttr(FieldType.FIELD_STRING, 1, 0));
                field.setValue(source.getPayoutStoreBit2());
                body.addField("PAYOUT_STORE_BIT2", field);
            }
            if (source.getPayoutStoreBit3() != null) {
                Field field = new Field(new FieldAttr(FieldType.FIELD_STRING, 1, 0));
                field.setValue(source.getPayoutStoreBit3());
                body.addField("PAYOUT_STORE_BIT3", field);
            }
            if (source.getTranRemark() != null) {
                Field field = new Field(new FieldAttr(FieldType.FIELD_STRING, 30, 0));
                field.setValue(source.getTranRemark());
                body.addField("TRAN_REMARK", field);
            }
            if (source.getAcctStatus() != null) {
                Field field = new Field(new FieldAttr(FieldType.FIELD_STRING, 100, 0));
                field.setValue(source.getAcctStatus());
                body.addField("ACCT_STATUS", field);
            }
            if (source.getChannelType() != null) {
                Field field = new Field(new FieldAttr(FieldType.FIELD_STRING, 2, 0));
                field.setValue(source.getChannelType());
                body.addField("CHANNEL_TYPE", field);
            }
            if (source.getBak1() != null) {
                Field field = new Field(new FieldAttr(FieldType.FIELD_STRING, 50, 0));
                field.setValue(source.getBak1());
                body.addField("BAK1", field);
            }
            if (source.getBak2() != null) {
                Field field = new Field(new FieldAttr(FieldType.FIELD_STRING, 50, 0));
                field.setValue(source.getBak2());
                body.addField("BAK2", field);
            }
            if (source.getBak3() != null) {
                Field field = new Field(new FieldAttr(FieldType.FIELD_STRING, 50, 0));
                field.setValue(source.getBak3());
                body.addField("BAK3", field);
            }
            return reqData;
        } catch (Exception ex) {
            logger.error("【发送短信】转换数据异常", ex);
            return null;
        }
    }
}