TDMQ兼容

admin

2022-03-28 2f5935ed11672046c37f733d855214f6147b4b58

TDMQ兼容

 facade-goods/pom.xml

@@ -22,7 +22,7 @@
        <dependency>
            <groupId>com.yeshi</groupId>
            <artifactId>utils</artifactId>
            <version>0.0.1-SNAPSHOT</version>
            <version>0.0.2-SNAPSHOT</version>
        </dependency>
        <dependency>
            <groupId>com.dataoke</groupId>

 facade-goods/src/main/java/com/yeshi/goods/facade/entity/taobao/TaoBaoGoodsBrief.java

@@ -11,6 +11,8 @@
import org.springframework.data.mongodb.core.mapping.Field;

import com.google.gson.annotations.Expose;
import org.yeshi.utils.generater.mybatis.Column;
import org.yeshi.utils.generater.mybatis.Table;

/**
 * 淘宝商品信息
@@ -18,7 +20,7 @@
 * @author Administrator
 *
 */
@org.yeshi.utils.mybatis.Table("yeshi_ec_taobao_goods")
@Table("yeshi_ec_taobao_goods")
@Document(collection="taoBaoGoodsCache")
public class TaoBaoGoodsBrief extends TaoBaoGoodsYuShouInfo implements Serializable {
    
@@ -28,252 +30,252 @@
     */
    private static final long serialVersionUID = 1L;

    @org.yeshi.utils.mybatis.Column(name = "id")
    @Column(name = "id")
    @Expose
    private Long id;

    @Field
    @org.yeshi.utils.mybatis.Column(name = "rootCatId")
    @Column(name = "rootCatId")
    private Integer rootCatId;// 0,  一级类目ID

    @org.yeshi.utils.mybatis.Column(name = "eventCreatorId")
    @Column(name = "eventCreatorId")
    private Integer eventCreatorId;// 0,

    @Field
    @org.yeshi.utils.mybatis.Column(name = "leafCatId")
    @Column(name = "leafCatId")
    private Integer leafCatId;// 50011277, 子类目id

    @org.yeshi.utils.mybatis.Column(name = "debugInfo")
    @Column(name = "debugInfo")
    private String debugInfo;// null,

    @org.yeshi.utils.mybatis.Column(name = "rootCatScore")
    @Column(name = "rootCatScore")
    private Integer rootCatScore;// 0,

    @Field
    @org.yeshi.utils.mybatis.Column(name = "sellerId")
    @Column(name = "sellerId")
    private Long sellerId;// 卖家Id

    @Field
    @Expose
    @org.yeshi.utils.mybatis.Column(name = "userType")
    @Column(name = "userType")
    private Integer userType;// 0,

    @Field
    @Expose
    @org.yeshi.utils.mybatis.Column(name = "shopTitle")
    @Column(name = "shopTitle")
    private String shopTitle;// 店铺名称

    @Field
    @org.yeshi.utils.mybatis.Column(name = "pictUrl")
    @Column(name = "pictUrl")
    @Expose
    private String pictUrl;// 主图链接

    @Field
    @org.yeshi.utils.mybatis.Column(name = "pictUrlWhite")
    @Column(name = "pictUrlWhite")
    @Expose
    private String pictUrlWhite;// 白底色图片链接
    
    @Field
    @org.yeshi.utils.mybatis.Column(name = "title")
    @Column(name = "title")
    @Expose
    private String title;// 商品标题

    @Field
    @Indexed
    @org.yeshi.utils.mybatis.Column(name = "auctionId")
    @Column(name = "auctionId")
    @Expose
    private Long auctionId;// 商品ID

    @Field
    @org.yeshi.utils.mybatis.Column(name = "couponLink")
    @Column(name = "couponLink")
    @Expose
    private String couponLink;// 优惠券链�?

    @Field
    @org.yeshi.utils.mybatis.Column(name = "couponLinkTaoToken")
    @Column(name = "couponLinkTaoToken")
    @Expose
    private String couponLinkTaoToken;//

    @Field
    @org.yeshi.utils.mybatis.Column(name = "couponActivityId")
    @Column(name = "couponActivityId")
    @Expose
    private String couponActivityId;//

    @Field
    @org.yeshi.utils.mybatis.Column(name = "biz30day")
    @Column(name = "biz30day")
    @Expose
    private Integer biz30day;// 月销量

    @Field
    @org.yeshi.utils.mybatis.Column(name = "tkRate")
    @Column(name = "tkRate")
    @Expose
    private BigDecimal tkRate;// 佣金比例 �?��100

    @Field
    @org.yeshi.utils.mybatis.Column(name = "nick")
    @Column(name = "nick")
    @Expose
    private String nick;// "yoyo_808611", 店铺名称

    @org.yeshi.utils.mybatis.Column(name = "includeDxjh")
    @Column(name = "includeDxjh")
    @Expose
    private Integer includeDxjh;// 1：定向计划

    @Field
    @org.yeshi.utils.mybatis.Column(name = "reservePrice")
    @Column(name = "reservePrice")
    @Expose
    private BigDecimal reservePrice;// 588,

    @Field
    @org.yeshi.utils.mybatis.Column(name = "tkCommFee")
    @Column(name = "tkCommFee")
    @Expose
    private BigDecimal tkCommFee;// 32.04,

    @Field
    @org.yeshi.utils.mybatis.Column(name = "totalFee")
    @Column(name = "totalFee")
    @Expose
    private BigDecimal totalFee;// 4814.43,

    @Field
    @org.yeshi.utils.mybatis.Column(name = "totalNum")
    @Column(name = "totalNum")
    @Expose
    private Integer totalNum;// 229, 库存数量

    @Field
    @org.yeshi.utils.mybatis.Column(name = "zkPrice")
    @Column(name = "zkPrice")
    @Expose
    private BigDecimal zkPrice;// 无线价格,在售价

    @Field
    @org.yeshi.utils.mybatis.Column(name = "dayLeft")
    @Column(name = "dayLeft")
    @Expose
    private Integer dayLeft;// -17228,

    @Field
    @org.yeshi.utils.mybatis.Column(name = "tk3rdRate")
    @Column(name = "tk3rdRate")
    @Expose
    private String tk3rdRate;// null,

    @Field
    @org.yeshi.utils.mybatis.Column(name = "auctionUrl")
    @Column(name = "auctionUrl")
    @Expose
    private String auctionUrl;// 商品链接

    @Field
    @org.yeshi.utils.mybatis.Column(name = "rlRate")
    @Column(name = "rlRate")
    @Expose
    private Double rlRate;// 69.72,

    @org.yeshi.utils.mybatis.Column(name = "hasRecommended")
    @Column(name = "hasRecommended")
    @Expose
    private Integer hasRecommended;// 0,

    @org.yeshi.utils.mybatis.Column(name = "hasSame")
    @Column(name = "hasSame")
    @Expose
    private Integer hasSame;// 0,

    @org.yeshi.utils.mybatis.Column(name = "sameItemPid")
    @Column(name = "sameItemPid")
    @Expose
    private Long sameItemPid;// "-232381821",

    @Field
    @org.yeshi.utils.mybatis.Column(name = "couponTotalCount")
    @Column(name = "couponTotalCount")
    @Expose
    private Integer couponTotalCount;// 优惠券�?�?

    @Field
    @org.yeshi.utils.mybatis.Column(name = "couponLeftCount")
    @Column(name = "couponLeftCount")
    @Expose
    private Integer couponLeftCount;// 优惠券剩余数�?

    @Field
    @org.yeshi.utils.mybatis.Column(name = "couponAmount")
    @Column(name = "couponAmount")
    @Expose
    private BigDecimal couponAmount;// 优惠金额

    @Field
    @org.yeshi.utils.mybatis.Column(name = "eventRate")
    @Column(name = "eventRate")
    @Expose
    private String eventRate;// null,

    @Field
    @org.yeshi.utils.mybatis.Column(name = "couponShortLink")
    @Column(name = "couponShortLink")
    @Expose
    private String couponShortLink;// 优惠券短�?

    @Field
    @org.yeshi.utils.mybatis.Column(name = "couponInfo")
    @Column(name = "couponInfo")
    @Expose
    private String couponInfo;// 优惠券信�?

    @Field
    @org.yeshi.utils.mybatis.Column(name = "couponStartFee")
    @Column(name = "couponStartFee")
    @Expose
    private BigDecimal couponStartFee;// 优惠券起始优�?

    @Field
    @org.yeshi.utils.mybatis.Column(name = "couponEffectiveStartTime")
    @Column(name = "couponEffectiveStartTime")
    @Expose
    private String couponEffectiveStartTime;// "2017-02-04",优惠券开始时�?

    @Field
    @org.yeshi.utils.mybatis.Column(name = "couponEffectiveEndTime")
    @Column(name = "couponEffectiveEndTime")
    @Expose
    private String couponEffectiveEndTime;// 优惠券结束时�?

    @org.yeshi.utils.mybatis.Column(name = "hasUmpBonus")
    @Column(name = "hasUmpBonus")
    @Expose
    private String hasUmpBonus;// null,

    @org.yeshi.utils.mybatis.Column(name = "isBizActivity")
    @Column(name = "isBizActivity")
    @Expose
    private String isBizActivity;// null,

    @org.yeshi.utils.mybatis.Column(name = "umpBonus")
    @Column(name = "umpBonus")
    @Expose
    private String umpBonus;// null,

    @Field
    @org.yeshi.utils.mybatis.Column(name = "rootCategoryName")
    @Column(name = "rootCategoryName")
    @Expose
    private String rootCategoryName;//  一级分类名称

    @Field
    @org.yeshi.utils.mybatis.Column(name = "couponOriLink")
    @Column(name = "couponOriLink")
    @Expose
    private String couponOriLink;// 优惠券原始链�?

    @Field
    @org.yeshi.utils.mybatis.Column(name = "userTypeName")
    @Column(name = "userTypeName")
    @Expose
    private String userTypeName;// 用户类型

    @Field
    @org.yeshi.utils.mybatis.Column(name = "tkMktStatus")
    @Column(name = "tkMktStatus")
    @Expose
    private String tkMktStatus; // 1：营销返利
    
    @Field
    @org.yeshi.utils.mybatis.Column(name = "totalSales")
    @Column(name = "totalSales")
    @Expose
    private Integer totalSales;// 229, 淘客30天月推广量
    
    // 入库时间
    @org.yeshi.utils.mybatis.Column(name = "createtime")
    @Column(name = "createtime")
    @Expose
    private Date createtime;
    // 更新时间

    @Field
    @org.yeshi.utils.mybatis.Column(name = "updatetime")
    @Column(name = "updatetime")
    @Expose
    private Date updatetime;

    @org.yeshi.utils.mybatis.Column(name = "state")
    @Column(name = "state")
    @Expose
    private Integer state;// 0-正常 1-商品下架
    
    @Field
    @org.yeshi.utils.mybatis.Column(name = "material_lib_type")
    @Column(name = "material_lib_type")
    private Integer materialLibType;//物料库类型

    private String materialLibTypes;//物料库类型
@@ -304,29 +306,29 @@
        this.materialLibType = materialLibType;
    }

    // @org.yeshi.utils.mybatis.Column(name = "catLeafName")
    // @Column(name = "catLeafName")
    private String leafName; // 子类目名称

    
    // @org.yeshi.utils.mybatis.Column(name = "isPrepay")
    // @Column(name = "isPrepay")
    private Integer isPrepay; // 是否加入消费者保障 1：是 0 否

    // @org.yeshi.utils.mybatis.Column(name = "shopDsr")
    // @Column(name = "shopDsr")
    private Integer shopDsr; // 店铺评分

    // @org.yeshi.utils.mybatis.Column(name = "ratesum")
    // @Column(name = "ratesum")
    private Integer ratesum; // 卖家等级

    // @org.yeshi.utils.mybatis.Column(name = "rfdRate")
    // @Column(name = "rfdRate")
    private Integer rfdRate; // 退款率是否低于行业均值

    // @org.yeshi.utils.mybatis.Column(name = "goodRate")
    // @Column(name = "goodRate")
    private Integer goodRate; // 好评率是否高于行业均值

    // @org.yeshi.utils.mybatis.Column(name = "payRate30")
    // @Column(name = "payRate30")
    private Integer payRate30; // 成交转化是否高于行业均值

    // @org.yeshi.utils.mybatis.Column(name = "freeShipment")
    // @Column(name = "freeShipment")
    private Integer freeShipment; // 是否包邮

    @Expose

 facede-common/pom.xml

@@ -16,7 +16,7 @@
        <dependency>
            <groupId>com.yeshi</groupId>
            <artifactId>utils</artifactId>
            <version>0.0.1-SNAPSHOT</version>
            <version>0.0.2-SNAPSHOT</version>
        </dependency>
    </dependencies>


 facede-common/src/main/java/com/yeshi/common/entity/taobao/TaoBaoShop.java

@@ -6,8 +6,9 @@


import com.google.gson.annotations.Expose;
import org.yeshi.utils.mybatis.Column;
import org.yeshi.utils.mybatis.Table;
import org.yeshi.utils.generater.mybatis.Column;
import org.yeshi.utils.generater.mybatis.Table;


/**
 * 淘宝店铺信息（新版）

 fanli/pom.xml

@@ -24,7 +24,7 @@
        <dependency>
            <groupId>com.yeshi</groupId>
            <artifactId>utils</artifactId>
            <version>0.0.1-SNAPSHOT</version>
            <version>0.0.2-SNAPSHOT</version>
        </dependency>

        <dependency>
@@ -151,7 +151,6 @@
            <scope>system</scope>
            <systemPath>${basedir}/libs/sun.misc.BASE64Decoder.jar</systemPath>
        </dependency>



        <dependency>
@@ -312,7 +311,6 @@
                </exclusion>
            </exclusions>
        </dependency>



    </dependencies>

 fanli/src/main/java/com/yeshi/fanli/aspect/AdminLoginAspect.java

@@ -17,6 +17,8 @@
import org.aspectj.lang.annotation.Around;
import org.aspectj.lang.annotation.Aspect;
import org.aspectj.lang.reflect.MethodSignature;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.stereotype.Component;
import org.springframework.web.context.request.RequestContextHolder;
import org.springframework.web.context.request.ServletRequestAttributes;
@@ -35,6 +37,8 @@
@Component
@Aspect
public class AdminLoginAspect {

    private Logger logger = LoggerFactory.getLogger(AdminLoginAspect.class);

    @Resource
    private AdminUserService adminUserService;
@@ -73,19 +77,22 @@
                    signAES = URLDecoder.decode(request.getParameter("sign"), "UTF-8");
                String sign = AESUtil.decrypt(signAES, Constant.ADMINH5_AESKEY);
                if (!StringUtil.isNullOrEmpty(sign)) {
                    LogHelper.error("H5审核签名:" + sign);
                    logger.debug("H5审核签名:" + sign);
                    JSONObject json = JSONObject.fromObject(sign);
                    long time = json.optLong("timeStamp");
                    long adminId = json.optLong("adminId");
                    AdminUser adminUser = adminUserService.selectByPrimaryKey(adminId);
                    // 1个小时链接失效
                    if (System.currentTimeMillis() - time > 1000 * 60 * 60 || adminUser == null) {
                        logger.debug("H5审核链接失效");
                        servletContainer.getResponse().getWriter()
                                .print(callback + "(" + JsonUtil.loadFalseResult(2, "链接失效") + ")");
                        return null;
                    } else {
                        logger.debug("H5审核设置Session开始");
                        request.getSession().setAttribute(Constant.SESSION_ADMIN, adminUser);
                        request.getSession().setAttribute(Constant.SESSION_EXTRACT_VERIFY_RESULT, "1");
                        logger.debug("H5审核设置Session结束");
                    }
                } else {
                    servletContainer.getResponse().getWriter()

 fanli/src/main/java/com/yeshi/fanli/controller/TestController.java

@@ -47,6 +47,8 @@
import org.quartz.JobExecutionContext;
import org.quartz.Scheduler;
import org.quartz.SchedulerException;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.cache.ehcache.EhCacheCacheManager;
import org.springframework.stereotype.Controller;
import org.springframework.web.bind.annotation.RequestMapping;
@@ -433,9 +435,14 @@
        out.print(data.toString());
    }

    @RequestMapping("log")
    public void log(PrintWriter out) {
    Logger testLogger= LoggerFactory.getLogger("testLog");

    @RequestMapping("wx")
    public void log(HttpServletRequest request, PrintWriter out) {
        LogManager.getLogger(LogType.taobaoAuth).info("123123123");
        String content = WXUtil.getContent(request);
        testLogger.info("wx: "+content);

    }



 fanli/src/main/java/com/yeshi/fanli/controller/client/lijin/GoodsControllerLijin.java

@@ -274,7 +274,18 @@
                break;
        }

        ThreadUtil.run(new Runnable() {


            @Override
            public void run() {
                try {
        userGoodsScanLogger.info("{}", new Gson().toJson(UserGoodsScanLog.UserGoodsScanLogFactory.create(goodsDetailVO.getGoods(), uid, acceptData.getUtdid(), acceptData.getDevice())));
                }catch(Exception e){

                }
            }
        });


        //是否收藏

 fanli/src/main/java/com/yeshi/fanli/entity/AppVersionInfo.java

@@ -2,8 +2,8 @@

import java.util.Date;

import org.yeshi.utils.mybatis.Column;
import org.yeshi.utils.mybatis.Table;
import org.yeshi.utils.generater.mybatis.Column;
import org.yeshi.utils.generater.mybatis.Table;

/**
 * APP端版本号记录

 fanli/src/main/java/com/yeshi/fanli/entity/brand/BrandClass.java

@@ -3,8 +3,8 @@
import java.io.Serializable;
import java.util.Date;

import org.yeshi.utils.mybatis.Column;
import org.yeshi.utils.mybatis.Table;
import org.yeshi.utils.generater.mybatis.Column;
import org.yeshi.utils.generater.mybatis.Table;

import com.google.gson.annotations.Expose;
import com.yeshi.fanli.entity.bus.clazz.GoodsClass;

 fanli/src/main/java/com/yeshi/fanli/entity/brand/BrandClassShop.java

@@ -2,8 +2,8 @@

import java.util.Date;

import org.yeshi.utils.mybatis.Column;
import org.yeshi.utils.mybatis.Table;
import org.yeshi.utils.generater.mybatis.Column;
import org.yeshi.utils.generater.mybatis.Table;

import com.google.gson.annotations.Expose;
import com.yeshi.common.entity.taobao.TaoBaoShop;

 fanli/src/main/java/com/yeshi/fanli/entity/brand/BrandClassSystemMap.java

@@ -1,8 +1,8 @@
package com.yeshi.fanli.entity.brand;

import com.yeshi.fanli.entity.SystemEnum;
import org.yeshi.utils.mybatis.Column;
import org.yeshi.utils.mybatis.Table;
import org.yeshi.utils.generater.mybatis.Column;
import org.yeshi.utils.generater.mybatis.Table;

import java.util.Date;


 fanli/src/main/java/com/yeshi/fanli/entity/brand/BrandInfo.java

@@ -3,8 +3,8 @@
import java.io.Serializable;
import java.util.Date;

import org.yeshi.utils.mybatis.Column;
import org.yeshi.utils.mybatis.Table;
import org.yeshi.utils.generater.mybatis.Column;
import org.yeshi.utils.generater.mybatis.Table;

import com.google.gson.annotations.Expose;


 fanli/src/main/java/com/yeshi/fanli/entity/brand/BrandInfoRecord.java

@@ -2,8 +2,8 @@

import java.util.Date;

import org.yeshi.utils.mybatis.Column;
import org.yeshi.utils.mybatis.Table;
import org.yeshi.utils.generater.mybatis.Column;
import org.yeshi.utils.generater.mybatis.Table;

/**
 * 品牌信息浏览记录

 fanli/src/main/java/com/yeshi/fanli/entity/brand/TaoBaoShopHistory.java

@@ -2,8 +2,8 @@

import java.util.Date;

import org.yeshi.utils.mybatis.Column;
import org.yeshi.utils.mybatis.Table;
import org.yeshi.utils.generater.mybatis.Column;
import org.yeshi.utils.generater.mybatis.Table;

import com.yeshi.common.entity.taobao.TaoBaoShop;


 fanli/src/main/java/com/yeshi/fanli/entity/bus/activity/ActivityRuleUser.java

@@ -2,8 +2,8 @@

import java.util.Date;

import org.yeshi.utils.mybatis.Column;
import org.yeshi.utils.mybatis.Table;
import org.yeshi.utils.generater.mybatis.Column;
import org.yeshi.utils.generater.mybatis.Table;

import com.yeshi.fanli.dto.dynamic.ActivityUserRule;


 fanli/src/main/java/com/yeshi/fanli/entity/bus/activity/ActivityUser.java

@@ -4,8 +4,8 @@
import java.util.Date;

import com.google.gson.annotations.Expose;
import org.yeshi.utils.mybatis.Column;
import org.yeshi.utils.mybatis.Table;
import org.yeshi.utils.generater.mybatis.Column;
import org.yeshi.utils.generater.mybatis.Table;

/**
 * 活动用户

 fanli/src/main/java/com/yeshi/fanli/entity/bus/activity/RecommendActivity.java

@@ -6,8 +6,8 @@

import com.google.gson.annotations.Expose;
import com.google.gson.annotations.SerializedName;
import org.yeshi.utils.mybatis.Column;
import org.yeshi.utils.mybatis.Table;
import org.yeshi.utils.generater.mybatis.Column;
import org.yeshi.utils.generater.mybatis.Table;

/**
 * 推荐活动

 fanli/src/main/java/com/yeshi/fanli/entity/bus/activity/RecommendActivityImg.java

@@ -1,7 +1,7 @@
package com.yeshi.fanli.entity.bus.activity;

import org.yeshi.utils.mybatis.Column;
import org.yeshi.utils.mybatis.Table;
import org.yeshi.utils.generater.mybatis.Column;
import org.yeshi.utils.generater.mybatis.Table;

/**
 * 动态图片

 fanli/src/main/java/com/yeshi/fanli/entity/bus/activity/RecommendActivityInviteInfo.java

@@ -1,7 +1,7 @@
package com.yeshi.fanli.entity.bus.activity;

import org.yeshi.utils.mybatis.Column;
import org.yeshi.utils.mybatis.Table;
import org.yeshi.utils.generater.mybatis.Column;
import org.yeshi.utils.generater.mybatis.Table;

/**
 * 动态图片

 fanli/src/main/java/com/yeshi/fanli/entity/bus/activity/RecommendActivityTaoBaoGoods.java

@@ -6,8 +6,8 @@

import com.google.gson.annotations.Expose;
import com.yeshi.goods.facade.entity.taobao.TaoBaoGoodsBrief;
import org.yeshi.utils.mybatis.Column;
import org.yeshi.utils.mybatis.Table;
import org.yeshi.utils.generater.mybatis.Column;
import org.yeshi.utils.generater.mybatis.Table;

/**
 * 动态淘宝商品

 fanli/src/main/java/com/yeshi/fanli/entity/bus/clazz/GoodsClass.java

@@ -3,8 +3,8 @@
import java.io.Serializable;
import java.util.List;

import org.yeshi.utils.mybatis.Column;
import org.yeshi.utils.mybatis.Table;
import org.yeshi.utils.generater.mybatis.Column;
import org.yeshi.utils.generater.mybatis.Table;

import com.google.gson.annotations.Expose;


 fanli/src/main/java/com/yeshi/fanli/entity/bus/clazz/GoodsSecondClass.java

@@ -1,7 +1,7 @@
package com.yeshi.fanli.entity.bus.clazz;

import org.yeshi.utils.mybatis.Column;
import org.yeshi.utils.mybatis.Table;
import org.yeshi.utils.generater.mybatis.Column;
import org.yeshi.utils.generater.mybatis.Table;

import com.google.gson.annotations.Expose;


 fanli/src/main/java/com/yeshi/fanli/entity/bus/clazz/GoodsSubClass.java

@@ -3,8 +3,8 @@
import java.io.Serializable;
import java.util.Date;

import org.yeshi.utils.mybatis.Column;
import org.yeshi.utils.mybatis.Table;
import org.yeshi.utils.generater.mybatis.Column;
import org.yeshi.utils.generater.mybatis.Table;

import com.google.gson.annotations.Expose;


 fanli/src/main/java/com/yeshi/fanli/entity/bus/clazz/GoodsSubClassLabel.java

@@ -2,8 +2,8 @@

import java.util.Date;

import org.yeshi.utils.mybatis.Column;
import org.yeshi.utils.mybatis.Table;
import org.yeshi.utils.generater.mybatis.Column;
import org.yeshi.utils.generater.mybatis.Table;

import com.google.gson.annotations.Expose;


 fanli/src/main/java/com/yeshi/fanli/entity/bus/clazz/GoodsSubClassLabelMap.java

@@ -2,8 +2,8 @@

import java.util.Date;

import org.yeshi.utils.mybatis.Column;
import org.yeshi.utils.mybatis.Table;
import org.yeshi.utils.generater.mybatis.Column;
import org.yeshi.utils.generater.mybatis.Table;

/**
 * 二级分类标签

 fanli/src/main/java/com/yeshi/fanli/entity/bus/clazz/TaoBaoClass.java

@@ -2,8 +2,8 @@

import java.util.Date;

import org.yeshi.utils.mybatis.Column;
import org.yeshi.utils.mybatis.Table;
import org.yeshi.utils.generater.mybatis.Column;
import org.yeshi.utils.generater.mybatis.Table;

import com.google.gson.annotations.Expose;


 fanli/src/main/java/com/yeshi/fanli/entity/bus/clazz/TaoBaoClassRelation.java

@@ -2,8 +2,8 @@

import java.util.Date;

import org.yeshi.utils.mybatis.Column;
import org.yeshi.utils.mybatis.Table;
import org.yeshi.utils.generater.mybatis.Column;
import org.yeshi.utils.generater.mybatis.Table;

import com.google.gson.annotations.Expose;


 fanli/src/main/java/com/yeshi/fanli/entity/bus/help/AppPageNotification.java

@@ -3,8 +3,8 @@
import com.google.gson.annotations.Expose;
import com.yeshi.fanli.entity.SystemEnum;
import org.springframework.data.annotation.Transient;
import org.yeshi.utils.mybatis.Column;
import org.yeshi.utils.mybatis.Table;
import org.yeshi.utils.generater.mybatis.Column;
import org.yeshi.utils.generater.mybatis.Table;

import java.io.Serializable;
import java.util.Date;

 fanli/src/main/java/com/yeshi/fanli/entity/bus/help/HelpCenter.java

@@ -5,7 +5,7 @@

import com.yeshi.fanli.entity.SystemEnum;
import org.springframework.format.annotation.DateTimeFormat;
import org.yeshi.utils.mybatis.Column;
import org.yeshi.utils.generater.mybatis.Column;

import com.google.gson.annotations.Expose;

@@ -16,7 +16,7 @@
 *
 * @date 2018年8月14日
 */
@org.yeshi.utils.mybatis.Table("yeshi_ec_help_center")
@org.yeshi.utils.generater.mybatis.Table("yeshi_ec_help_center")
public class HelpCenter implements Serializable{

    /**

 fanli/src/main/java/com/yeshi/fanli/entity/bus/help/HelpClass.java

@@ -4,8 +4,8 @@
import java.util.Date;

import com.yeshi.fanli.entity.SystemEnum;
import org.yeshi.utils.mybatis.Column;
import org.yeshi.utils.mybatis.Table;
import org.yeshi.utils.generater.mybatis.Column;
import org.yeshi.utils.generater.mybatis.Table;

import com.google.gson.annotations.Expose;


 fanli/src/main/java/com/yeshi/fanli/entity/bus/homemodule/AdActivityVersionControl.java

@@ -2,8 +2,8 @@

import java.util.Date;

import org.yeshi.utils.mybatis.Column;
import org.yeshi.utils.mybatis.Table;
import org.yeshi.utils.generater.mybatis.Column;
import org.yeshi.utils.generater.mybatis.Table;

import com.yeshi.fanli.entity.AppVersionInfo;


 fanli/src/main/java/com/yeshi/fanli/entity/bus/homemodule/CommonShareInfo.java

@@ -2,8 +2,8 @@

import java.util.Date;

import org.yeshi.utils.mybatis.Column;
import org.yeshi.utils.mybatis.Table;
import org.yeshi.utils.generater.mybatis.Column;
import org.yeshi.utils.generater.mybatis.Table;

/**
 * 分享信息

 fanli/src/main/java/com/yeshi/fanli/entity/bus/homemodule/FloatAD.java

@@ -5,8 +5,8 @@

import com.yeshi.fanli.entity.SystemEnum;
import org.springframework.format.annotation.DateTimeFormat;
import org.yeshi.utils.mybatis.Column;
import org.yeshi.utils.mybatis.Table;
import org.yeshi.utils.generater.mybatis.Column;
import org.yeshi.utils.generater.mybatis.Table;

import com.google.gson.annotations.Expose;
import com.yeshi.fanli.entity.common.JumpDetailV2;

 fanli/src/main/java/com/yeshi/fanli/entity/bus/homemodule/HomeNavbar.java

@@ -4,8 +4,8 @@
import java.util.Date;

import com.yeshi.fanli.entity.SystemEnum;
import org.yeshi.utils.mybatis.Column;
import org.yeshi.utils.mybatis.Table;
import org.yeshi.utils.generater.mybatis.Column;
import org.yeshi.utils.generater.mybatis.Table;

import com.google.gson.annotations.Expose;


 fanli/src/main/java/com/yeshi/fanli/entity/bus/homemodule/HomeNavbarUser.java

@@ -2,8 +2,8 @@

import java.util.Date;

import org.yeshi.utils.mybatis.Column;
import org.yeshi.utils.mybatis.Table;
import org.yeshi.utils.generater.mybatis.Column;
import org.yeshi.utils.generater.mybatis.Table;

/**
 * 用户自定义导航

 fanli/src/main/java/com/yeshi/fanli/entity/bus/homemodule/Special.java

@@ -5,8 +5,8 @@
import java.util.List;

import com.yeshi.fanli.entity.SystemEnum;
import org.yeshi.utils.mybatis.Column;
import org.yeshi.utils.mybatis.Table;
import org.yeshi.utils.generater.mybatis.Column;
import org.yeshi.utils.generater.mybatis.Table;

import com.google.gson.annotations.Expose;
import com.yeshi.fanli.entity.common.JumpDetailV2;

 fanli/src/main/java/com/yeshi/fanli/entity/bus/homemodule/SpecialCard.java

@@ -4,8 +4,8 @@
import java.util.Date;

import com.yeshi.fanli.entity.SystemEnum;
import org.yeshi.utils.mybatis.Column;
import org.yeshi.utils.mybatis.Table;
import org.yeshi.utils.generater.mybatis.Column;
import org.yeshi.utils.generater.mybatis.Table;

/**
 * 专题标识管理

 fanli/src/main/java/com/yeshi/fanli/entity/bus/homemodule/SpecialLabel.java

@@ -3,8 +3,8 @@
import java.io.Serializable;
import java.util.Date;

import org.yeshi.utils.mybatis.Column;
import org.yeshi.utils.mybatis.Table;
import org.yeshi.utils.generater.mybatis.Column;
import org.yeshi.utils.generater.mybatis.Table;

/**
 * 专题标签

 fanli/src/main/java/com/yeshi/fanli/entity/bus/homemodule/SpecialLabelMap.java

@@ -3,8 +3,8 @@
import java.io.Serializable;
import java.util.Date;

import org.yeshi.utils.mybatis.Column;
import org.yeshi.utils.mybatis.Table;
import org.yeshi.utils.generater.mybatis.Column;
import org.yeshi.utils.generater.mybatis.Table;

/**
 *    专题标签映射

 fanli/src/main/java/com/yeshi/fanli/entity/bus/homemodule/SpecialPlace.java

@@ -2,8 +2,8 @@

import java.util.Date;

import org.yeshi.utils.mybatis.Column;
import org.yeshi.utils.mybatis.Table;
import org.yeshi.utils.generater.mybatis.Column;
import org.yeshi.utils.generater.mybatis.Table;

/**
 *  首页专题位置管理

 fanli/src/main/java/com/yeshi/fanli/entity/bus/homemodule/SuperHomeNavbar.java

@@ -2,8 +2,8 @@

import java.io.Serializable;

import org.yeshi.utils.mybatis.Column;
import org.yeshi.utils.mybatis.Table;
import org.yeshi.utils.generater.mybatis.Column;
import org.yeshi.utils.generater.mybatis.Table;

import com.yeshi.fanli.entity.system.BusinessSystem;


 fanli/src/main/java/com/yeshi/fanli/entity/bus/homemodule/SuperSpecial.java

@@ -2,8 +2,8 @@

import java.io.Serializable;

import org.yeshi.utils.mybatis.Column;
import org.yeshi.utils.mybatis.Table;
import org.yeshi.utils.generater.mybatis.Column;
import org.yeshi.utils.generater.mybatis.Table;

import com.yeshi.fanli.entity.system.BusinessSystem;


 fanli/src/main/java/com/yeshi/fanli/entity/bus/homemodule/SuperSpecialCard.java

@@ -2,8 +2,8 @@

import java.io.Serializable;

import org.yeshi.utils.mybatis.Column;
import org.yeshi.utils.mybatis.Table;
import org.yeshi.utils.generater.mybatis.Column;
import org.yeshi.utils.generater.mybatis.Table;

import com.yeshi.fanli.entity.system.BusinessSystem;


 fanli/src/main/java/com/yeshi/fanli/entity/bus/homemodule/SwiperBanner.java

@@ -4,8 +4,8 @@
import java.util.Date;

import com.yeshi.fanli.entity.SystemEnum;
import org.yeshi.utils.mybatis.Column;
import org.yeshi.utils.mybatis.Table;
import org.yeshi.utils.generater.mybatis.Column;
import org.yeshi.utils.generater.mybatis.Table;

/**
 * 轮播图管理

 fanli/src/main/java/com/yeshi/fanli/entity/bus/homemodule/SwiperPicture.java

@@ -5,8 +5,8 @@

import com.yeshi.fanli.entity.SystemEnum;
import org.springframework.format.annotation.DateTimeFormat;
import org.yeshi.utils.mybatis.Column;
import org.yeshi.utils.mybatis.Table;
import org.yeshi.utils.generater.mybatis.Column;
import org.yeshi.utils.generater.mybatis.Table;

import com.google.gson.annotations.Expose;
import com.yeshi.fanli.entity.common.JumpDetailV2;

 fanli/src/main/java/com/yeshi/fanli/entity/bus/invite/SpreadImg.java

@@ -4,8 +4,8 @@


import org.springframework.data.annotation.Transient;
import org.yeshi.utils.mybatis.Column;
import org.yeshi.utils.mybatis.Table;
import org.yeshi.utils.generater.mybatis.Column;
import org.yeshi.utils.generater.mybatis.Table;

import com.google.gson.annotations.Expose;


 fanli/src/main/java/com/yeshi/fanli/entity/bus/invite/SpreadUserImg.java

@@ -2,8 +2,8 @@

import com.google.gson.annotations.Expose;
import org.springframework.data.annotation.Transient;
import org.yeshi.utils.mybatis.Column;
import org.yeshi.utils.mybatis.Table;
import org.yeshi.utils.generater.mybatis.Column;
import org.yeshi.utils.generater.mybatis.Table;

import java.util.Date;


 fanli/src/main/java/com/yeshi/fanli/entity/bus/lable/BoutiqueAutoRule.java

@@ -5,8 +5,8 @@
import java.util.Date;

import org.springframework.format.annotation.DateTimeFormat;
import org.yeshi.utils.mybatis.Column;
import org.yeshi.utils.mybatis.Table;
import org.yeshi.utils.generater.mybatis.Column;
import org.yeshi.utils.generater.mybatis.Table;

import com.yeshi.fanli.entity.common.AdminUser;


 fanli/src/main/java/com/yeshi/fanli/entity/bus/lable/Label.java

@@ -3,8 +3,8 @@
import java.io.Serializable;
import java.util.Date;

import org.yeshi.utils.mybatis.Column;
import org.yeshi.utils.mybatis.Table;
import org.yeshi.utils.generater.mybatis.Column;
import org.yeshi.utils.generater.mybatis.Table;

import com.yeshi.fanli.entity.common.AdminUser;


 fanli/src/main/java/com/yeshi/fanli/entity/bus/lable/LabelClass.java

@@ -2,8 +2,8 @@

import java.util.Date;

import org.yeshi.utils.mybatis.Column;
import org.yeshi.utils.mybatis.Table;
import org.yeshi.utils.generater.mybatis.Column;
import org.yeshi.utils.generater.mybatis.Table;

import com.yeshi.fanli.entity.bus.clazz.GoodsClass;
import com.yeshi.fanli.entity.bus.clazz.GoodsSubClass;

 fanli/src/main/java/com/yeshi/fanli/entity/bus/lable/LabelGoods.java

@@ -2,8 +2,8 @@

import java.util.Date;

import org.yeshi.utils.mybatis.Column;
import org.yeshi.utils.mybatis.Table;
import org.yeshi.utils.generater.mybatis.Column;
import org.yeshi.utils.generater.mybatis.Table;

import com.yeshi.fanli.entity.common.AdminUser;
import com.yeshi.goods.facade.entity.taobao.TaoBaoGoodsBrief;

 fanli/src/main/java/com/yeshi/fanli/entity/bus/lable/MergeClass.java

@@ -2,8 +2,8 @@

import java.util.Date;

import org.yeshi.utils.mybatis.Column;
import org.yeshi.utils.mybatis.Table;
import org.yeshi.utils.generater.mybatis.Column;
import org.yeshi.utils.generater.mybatis.Table;

/**
 * 9k9组合类

 fanli/src/main/java/com/yeshi/fanli/entity/bus/lable/QualityFactory.java

@@ -3,8 +3,8 @@
import java.io.Serializable;
import java.util.Date;

import org.yeshi.utils.mybatis.Column;
import org.yeshi.utils.mybatis.Table;
import org.yeshi.utils.generater.mybatis.Column;
import org.yeshi.utils.generater.mybatis.Table;

import com.yeshi.fanli.entity.common.AdminUser;
import com.yeshi.goods.facade.entity.taobao.TaoBaoGoodsBrief;

 fanli/src/main/java/com/yeshi/fanli/entity/bus/lable/QualityFlashSale.java

@@ -2,8 +2,8 @@

import java.util.Date;

import org.yeshi.utils.mybatis.Column;
import org.yeshi.utils.mybatis.Table;
import org.yeshi.utils.generater.mybatis.Column;
import org.yeshi.utils.generater.mybatis.Table;

import com.yeshi.goods.facade.entity.taobao.TaoBaoGoodsBrief;


 fanli/src/main/java/com/yeshi/fanli/entity/bus/msg/MsgAccountDetail.java

@@ -2,8 +2,8 @@

import java.util.Date;

import org.yeshi.utils.mybatis.Column;
import org.yeshi.utils.mybatis.Table;
import org.yeshi.utils.generater.mybatis.Column;
import org.yeshi.utils.generater.mybatis.Table;

import com.yeshi.fanli.entity.bus.user.UserInfo;


 fanli/src/main/java/com/yeshi/fanli/entity/bus/msg/MsgDeviceReadState.java

@@ -2,8 +2,8 @@

import java.util.Date;

import org.yeshi.utils.mybatis.Column;
import org.yeshi.utils.mybatis.Table;
import org.yeshi.utils.generater.mybatis.Column;
import org.yeshi.utils.generater.mybatis.Table;

/*
 *设备消息状态存储

 fanli/src/main/java/com/yeshi/fanli/entity/bus/msg/MsgExtra.java

@@ -2,8 +2,8 @@

import java.util.Date;

import org.yeshi.utils.mybatis.Column;
import org.yeshi.utils.mybatis.Table;
import org.yeshi.utils.generater.mybatis.Column;
import org.yeshi.utils.generater.mybatis.Table;

/***
 * 消息内容新版

 fanli/src/main/java/com/yeshi/fanli/entity/bus/msg/MsgInviteDetail.java

@@ -2,8 +2,8 @@

import java.util.Date;

import org.yeshi.utils.mybatis.Column;
import org.yeshi.utils.mybatis.Table;
import org.yeshi.utils.generater.mybatis.Column;
import org.yeshi.utils.generater.mybatis.Table;

import com.yeshi.fanli.entity.bus.user.ThreeSale;
import com.yeshi.fanli.entity.bus.user.UserInfo;

 fanli/src/main/java/com/yeshi/fanli/entity/bus/msg/MsgMoneyDetail.java

@@ -3,8 +3,8 @@
import java.math.BigDecimal;
import java.util.Date;

import org.yeshi.utils.mybatis.Column;
import org.yeshi.utils.mybatis.Table;
import org.yeshi.utils.generater.mybatis.Column;
import org.yeshi.utils.generater.mybatis.Table;

import com.yeshi.fanli.entity.bus.user.AlipayAccountValidNormalHistory;
import com.yeshi.fanli.entity.bus.user.Extract;

 fanli/src/main/java/com/yeshi/fanli/entity/bus/msg/MsgOrderDetail.java

@@ -3,8 +3,8 @@
import java.math.BigDecimal;
import java.util.Date;

import org.yeshi.utils.mybatis.Column;
import org.yeshi.utils.mybatis.Table;
import org.yeshi.utils.generater.mybatis.Column;
import org.yeshi.utils.generater.mybatis.Table;

import com.yeshi.fanli.entity.bus.user.UserInfo;


 fanli/src/main/java/com/yeshi/fanli/entity/bus/msg/MsgOtherDetail.java

@@ -2,8 +2,8 @@

import java.util.Date;

import org.yeshi.utils.mybatis.Column;
import org.yeshi.utils.mybatis.Table;
import org.yeshi.utils.generater.mybatis.Column;
import org.yeshi.utils.generater.mybatis.Table;

import com.yeshi.fanli.dto.msg.MsgOtherCouponContentDTO;
import com.yeshi.fanli.dto.msg.MsgOtherExchangeContentDTO;

 fanli/src/main/java/com/yeshi/fanli/entity/bus/msg/UserMsgUnReadNum.java

@@ -2,8 +2,8 @@

import java.util.Date;

import org.yeshi.utils.mybatis.Column;
import org.yeshi.utils.mybatis.Table;
import org.yeshi.utils.generater.mybatis.Column;
import org.yeshi.utils.generater.mybatis.Table;

import com.google.gson.annotations.Expose;
import com.yeshi.fanli.entity.bus.user.UserInfo;

 fanli/src/main/java/com/yeshi/fanli/entity/bus/msg/UserSystemMsg.java

@@ -2,8 +2,8 @@

import java.util.Date;

import org.yeshi.utils.mybatis.Column;
import org.yeshi.utils.mybatis.Table;
import org.yeshi.utils.generater.mybatis.Column;
import org.yeshi.utils.generater.mybatis.Table;

import com.google.gson.annotations.Expose;
import com.yeshi.fanli.entity.bus.user.UserInfo;

 fanli/src/main/java/com/yeshi/fanli/entity/bus/recommend/MaskKey.java

@@ -1,7 +1,7 @@
package com.yeshi.fanli.entity.bus.recommend;

import org.yeshi.utils.mybatis.Column;
import org.yeshi.utils.mybatis.Table;
import org.yeshi.utils.generater.mybatis.Column;
import org.yeshi.utils.generater.mybatis.Table;

/**
 * 铭感词库

 fanli/src/main/java/com/yeshi/fanli/entity/bus/recommend/RecommendBanner.java

@@ -2,8 +2,8 @@

import java.io.Serializable;

import org.yeshi.utils.mybatis.Column;
import org.yeshi.utils.mybatis.Table;
import org.yeshi.utils.generater.mybatis.Column;
import org.yeshi.utils.generater.mybatis.Table;

import com.yeshi.fanli.entity.common.JumpDetail;


 fanli/src/main/java/com/yeshi/fanli/entity/bus/recommend/RecommendBannerV2.java

@@ -2,8 +2,8 @@

import java.io.Serializable;

import org.yeshi.utils.mybatis.Column;
import org.yeshi.utils.mybatis.Table;
import org.yeshi.utils.generater.mybatis.Column;
import org.yeshi.utils.generater.mybatis.Table;

import com.yeshi.fanli.entity.common.JumpDetailV2;


 fanli/src/main/java/com/yeshi/fanli/entity/bus/recommend/RecommendSpecial.java

@@ -2,8 +2,8 @@

import java.io.Serializable;

import org.yeshi.utils.mybatis.Column;
import org.yeshi.utils.mybatis.Table;
import org.yeshi.utils.generater.mybatis.Column;
import org.yeshi.utils.generater.mybatis.Table;

import com.yeshi.fanli.entity.common.JumpDetail;


 fanli/src/main/java/com/yeshi/fanli/entity/bus/search/HistorySearch.java

@@ -5,8 +5,8 @@
import com.yeshi.fanli.entity.SystemEnum;
import org.springframework.data.annotation.Id;
import org.springframework.data.mongodb.core.mapping.Document;
import org.yeshi.utils.mybatis.Column;
import org.yeshi.utils.mybatis.Table;
import org.yeshi.utils.generater.mybatis.Column;
import org.yeshi.utils.generater.mybatis.Table;

import com.google.gson.annotations.Expose;


 fanli/src/main/java/com/yeshi/fanli/entity/bus/search/HotSearch.java

@@ -4,8 +4,8 @@
import java.util.List;

import com.yeshi.fanli.entity.SystemEnum;
import org.yeshi.utils.mybatis.Column;
import org.yeshi.utils.mybatis.Table;
import org.yeshi.utils.generater.mybatis.Column;
import org.yeshi.utils.generater.mybatis.Table;

import com.yeshi.fanli.entity.system.BusinessSystem;


 fanli/src/main/java/com/yeshi/fanli/entity/bus/share/UserShareGoodsGroup.java

@@ -3,8 +3,8 @@
import java.math.BigDecimal;
import java.util.Date;

import org.yeshi.utils.mybatis.Column;
import org.yeshi.utils.mybatis.Table;
import org.yeshi.utils.generater.mybatis.Column;
import org.yeshi.utils.generater.mybatis.Table;

import com.google.gson.annotations.Expose;
import com.yeshi.fanli.entity.goods.CommonGoods;

 fanli/src/main/java/com/yeshi/fanli/entity/bus/share/UserShareGoodsHistory.java

@@ -6,8 +6,8 @@

import com.yeshi.fanli.entity.bus.user.UserInfo;
import org.springframework.data.annotation.Transient;
import org.yeshi.utils.mybatis.Column;
import org.yeshi.utils.mybatis.Table;
import org.yeshi.utils.generater.mybatis.Column;
import org.yeshi.utils.generater.mybatis.Table;

/**
 * 用户分享商品记录

 fanli/src/main/java/com/yeshi/fanli/entity/bus/share/UserShareGoodsRecord.java

@@ -3,8 +3,8 @@
import java.math.BigDecimal;
import java.util.Date;

import org.yeshi.utils.mybatis.Column;
import org.yeshi.utils.mybatis.Table;
import org.yeshi.utils.generater.mybatis.Column;
import org.yeshi.utils.generater.mybatis.Table;

import com.google.gson.annotations.Expose;


 fanli/src/main/java/com/yeshi/fanli/entity/bus/su/clazz/SuperGoodsClass.java

@@ -1,7 +1,7 @@
package com.yeshi.fanli.entity.bus.su.clazz;

import org.yeshi.utils.mybatis.Column;
import org.yeshi.utils.mybatis.Table;
import org.yeshi.utils.generater.mybatis.Column;
import org.yeshi.utils.generater.mybatis.Table;

import com.yeshi.fanli.entity.bus.clazz.GoodsClass;
import com.yeshi.fanli.entity.system.BusinessSystem;

 fanli/src/main/java/com/yeshi/fanli/entity/bus/su/recommend/SuperRecommendBanner.java

@@ -2,8 +2,8 @@

import java.io.Serializable;

import org.yeshi.utils.mybatis.Column;
import org.yeshi.utils.mybatis.Table;
import org.yeshi.utils.generater.mybatis.Column;
import org.yeshi.utils.generater.mybatis.Table;

import com.yeshi.fanli.entity.bus.recommend.RecommendBanner;
import com.yeshi.fanli.entity.system.BusinessSystem;

 fanli/src/main/java/com/yeshi/fanli/entity/bus/su/recommend/SuperRecommendBannerV2.java

@@ -2,8 +2,8 @@

import java.io.Serializable;

import org.yeshi.utils.mybatis.Column;
import org.yeshi.utils.mybatis.Table;
import org.yeshi.utils.generater.mybatis.Column;
import org.yeshi.utils.generater.mybatis.Table;

import com.yeshi.fanli.entity.bus.recommend.RecommendBannerV2;
import com.yeshi.fanli.entity.system.BusinessSystem;

 fanli/src/main/java/com/yeshi/fanli/entity/bus/su/recommend/SuperRecommendSpecial.java

@@ -2,8 +2,8 @@

import java.io.Serializable;

import org.yeshi.utils.mybatis.Column;
import org.yeshi.utils.mybatis.Table;
import org.yeshi.utils.generater.mybatis.Column;
import org.yeshi.utils.generater.mybatis.Table;

import com.yeshi.fanli.entity.bus.recommend.RecommendSpecial;
import com.yeshi.fanli.entity.system.BusinessSystem;

 fanli/src/main/java/com/yeshi/fanli/entity/bus/su/search/SuperHotSearch.java

@@ -2,8 +2,8 @@

import java.io.Serializable;

import org.yeshi.utils.mybatis.Column;
import org.yeshi.utils.mybatis.Table;
import org.yeshi.utils.generater.mybatis.Column;
import org.yeshi.utils.generater.mybatis.Table;

import com.yeshi.fanli.entity.bus.search.HotSearch;
import com.yeshi.fanli.entity.system.BusinessSystem;

 fanli/src/main/java/com/yeshi/fanli/entity/bus/tlj/ConfigTaoLiJin.java

@@ -2,8 +2,8 @@

import java.util.Date;

import org.yeshi.utils.mybatis.Column;
import org.yeshi.utils.mybatis.Table;
import org.yeshi.utils.generater.mybatis.Column;
import org.yeshi.utils.generater.mybatis.Table;

/**
 *    淘礼金参数

 fanli/src/main/java/com/yeshi/fanli/entity/bus/tlj/UserTaoLiJinDetail.java

@@ -3,8 +3,8 @@
import java.math.BigDecimal;
import java.util.Date;

import org.yeshi.utils.mybatis.Column;
import org.yeshi.utils.mybatis.Table;
import org.yeshi.utils.generater.mybatis.Column;
import org.yeshi.utils.generater.mybatis.Table;

import com.google.gson.annotations.Expose;


 fanli/src/main/java/com/yeshi/fanli/entity/bus/tlj/UserTaoLiJinGiveRecord.java

@@ -3,8 +3,8 @@
import java.math.BigDecimal;
import java.util.Date;

import org.yeshi.utils.mybatis.Column;
import org.yeshi.utils.mybatis.Table;
import org.yeshi.utils.generater.mybatis.Column;
import org.yeshi.utils.generater.mybatis.Table;

/**
 * 淘礼金赠送记录

 fanli/src/main/java/com/yeshi/fanli/entity/bus/tlj/UserTaoLiJinNewbies.java

@@ -3,8 +3,8 @@
import java.math.BigDecimal;
import java.util.Date;

import org.yeshi.utils.mybatis.Column;
import org.yeshi.utils.mybatis.Table;
import org.yeshi.utils.generater.mybatis.Column;
import org.yeshi.utils.generater.mybatis.Table;

/**
 * 淘礼金-新人相关

 fanli/src/main/java/com/yeshi/fanli/entity/bus/tlj/UserTaoLiJinOrigin.java

@@ -3,8 +3,8 @@
import java.math.BigDecimal;
import java.util.Date;

import org.yeshi.utils.mybatis.Column;
import org.yeshi.utils.mybatis.Table;
import org.yeshi.utils.generater.mybatis.Column;
import org.yeshi.utils.generater.mybatis.Table;

/**
 *   用户淘礼金获得记录

 fanli/src/main/java/com/yeshi/fanli/entity/bus/tlj/UserTaoLiJinRecord.java

@@ -3,8 +3,8 @@
import java.math.BigDecimal;
import java.util.Date;

import org.yeshi.utils.mybatis.Column;
import org.yeshi.utils.mybatis.Table;
import org.yeshi.utils.generater.mybatis.Column;
import org.yeshi.utils.generater.mybatis.Table;

/**
 * 用户创建淘礼金记录

 fanli/src/main/java/com/yeshi/fanli/entity/bus/tlj/UserTaoLiJinReport.java

@@ -3,8 +3,8 @@
import java.math.BigDecimal;
import java.util.Date;

import org.yeshi.utils.mybatis.Column;
import org.yeshi.utils.mybatis.Table;
import org.yeshi.utils.generater.mybatis.Column;
import org.yeshi.utils.generater.mybatis.Table;

/**
 * 用户创建淘礼金记录

 fanli/src/main/java/com/yeshi/fanli/entity/bus/user/AccountMessage.java

@@ -1,7 +1,7 @@
package com.yeshi.fanli.entity.bus.user;

import org.yeshi.utils.mybatis.Column;
import org.yeshi.utils.mybatis.Table;
import org.yeshi.utils.generater.mybatis.Column;
import org.yeshi.utils.generater.mybatis.Table;

import com.google.gson.annotations.Expose;


 fanli/src/main/java/com/yeshi/fanli/entity/bus/user/AlipayAccountValidNormalHistory.java

@@ -2,8 +2,8 @@

import java.util.Date;

import org.yeshi.utils.mybatis.Column;
import org.yeshi.utils.mybatis.Table;
import org.yeshi.utils.generater.mybatis.Column;
import org.yeshi.utils.generater.mybatis.Table;

/**
 * 支付宝账号验证转账成功记录

 fanli/src/main/java/com/yeshi/fanli/entity/bus/user/BindingAccount.java

@@ -1,8 +1,8 @@
package com.yeshi.fanli.entity.bus.user;


import org.yeshi.utils.mybatis.Column;
import org.yeshi.utils.mybatis.Table;
import org.yeshi.utils.generater.mybatis.Column;
import org.yeshi.utils.generater.mybatis.Table;

import com.google.gson.annotations.Expose;


 fanli/src/main/java/com/yeshi/fanli/entity/bus/user/DeviceLotteryRecord.java

@@ -2,8 +2,8 @@

import java.util.Date;

import org.yeshi.utils.mybatis.Column;
import org.yeshi.utils.mybatis.Table;
import org.yeshi.utils.generater.mybatis.Column;
import org.yeshi.utils.generater.mybatis.Table;

import com.google.gson.annotations.Expose;


 fanli/src/main/java/com/yeshi/fanli/entity/bus/user/Extract.java

@@ -3,8 +3,8 @@
import java.math.BigDecimal;
import java.util.Date;

import org.yeshi.utils.mybatis.Column;
import org.yeshi.utils.mybatis.Table;
import org.yeshi.utils.generater.mybatis.Column;
import org.yeshi.utils.generater.mybatis.Table;

import com.google.gson.annotations.Expose;
import com.yeshi.fanli.entity.system.BusinessSystem;

 fanli/src/main/java/com/yeshi/fanli/entity/bus/user/ExtractAuditRecord.java

@@ -3,8 +3,8 @@
import java.math.BigDecimal;

import org.springframework.data.annotation.Transient;
import org.yeshi.utils.mybatis.Column;
import org.yeshi.utils.mybatis.Table;
import org.yeshi.utils.generater.mybatis.Column;
import org.yeshi.utils.generater.mybatis.Table;

import com.google.gson.annotations.Expose;
import com.yeshi.fanli.dto.money.ExtractOrderStatisticDTO;

 fanli/src/main/java/com/yeshi/fanli/entity/bus/user/ExtractRecord.java

@@ -2,8 +2,8 @@

import java.math.BigDecimal;

import org.yeshi.utils.mybatis.Column;
import org.yeshi.utils.mybatis.Table;
import org.yeshi.utils.generater.mybatis.Column;
import org.yeshi.utils.generater.mybatis.Table;
/**
 * 每日的提现记录
 * @author cxx

 fanli/src/main/java/com/yeshi/fanli/entity/bus/user/ExtractWeiXinRecord.java

@@ -3,8 +3,8 @@
import java.math.BigDecimal;
import java.util.Date;

import org.yeshi.utils.mybatis.Column;
import org.yeshi.utils.mybatis.Table;
import org.yeshi.utils.generater.mybatis.Column;
import org.yeshi.utils.generater.mybatis.Table;

import com.google.gson.annotations.Expose;


 fanli/src/main/java/com/yeshi/fanli/entity/bus/user/ForbiddenUserIdentifyCode.java

@@ -2,8 +2,8 @@

import java.util.Date;

import org.yeshi.utils.mybatis.Column;
import org.yeshi.utils.mybatis.Table;
import org.yeshi.utils.generater.mybatis.Column;
import org.yeshi.utils.generater.mybatis.Table;

/**
 * 禁止用户的标识

 fanli/src/main/java/com/yeshi/fanli/entity/bus/user/HongBaoManage.java

@@ -1,8 +1,8 @@
package com.yeshi.fanli.entity.bus.user;

import com.yeshi.fanli.entity.SystemEnum;
import org.yeshi.utils.mybatis.Column;
import org.yeshi.utils.mybatis.Table;
import org.yeshi.utils.generater.mybatis.Column;
import org.yeshi.utils.generater.mybatis.Table;

/**
 * 红包相关参数设置

 fanli/src/main/java/com/yeshi/fanli/entity/bus/user/HongBaoV2.java

@@ -4,8 +4,8 @@
import java.math.BigDecimal;
import java.util.Date;

import org.yeshi.utils.mybatis.Column;
import org.yeshi.utils.mybatis.Table;
import org.yeshi.utils.generater.mybatis.Column;
import org.yeshi.utils.generater.mybatis.Table;

/**
 * 订单-简版

 fanli/src/main/java/com/yeshi/fanli/entity/bus/user/LostOrder.java

@@ -2,8 +2,8 @@


import org.springframework.data.annotation.Transient;
import org.yeshi.utils.mybatis.Column;
import org.yeshi.utils.mybatis.Table;
import org.yeshi.utils.generater.mybatis.Column;
import org.yeshi.utils.generater.mybatis.Table;

import com.google.gson.annotations.Expose;


 fanli/src/main/java/com/yeshi/fanli/entity/bus/user/Order.java

@@ -10,7 +10,7 @@
 *
 * @author Administrator
 */
@org.yeshi.utils.mybatis.Table("yeshi_ec_order")
@org.yeshi.utils.generater.mybatis.Table("yeshi_ec_order")
public class Order {
    // 订单状状态 -1：失效 0-未支付 1-已支付
    public final static int STATE_SHIXIAO = -1;
@@ -21,53 +21,53 @@
    public final static int ORDER_TYPE_JINGDONG = 2;// 京东
    public final static int ORDER_TYPE_PDD = 3;// 拼多多

    @org.yeshi.utils.mybatis.Column(name = "id")
    @org.yeshi.utils.generater.mybatis.Column(name = "id")
    @Expose
    private Long id;

    @org.yeshi.utils.mybatis.Column(name = "orderid")
    @org.yeshi.utils.generater.mybatis.Column(name = "orderid")
    @Expose
    private String orderId;// 订单编号

    @org.yeshi.utils.mybatis.Column(name = "order_type")
    @org.yeshi.utils.generater.mybatis.Column(name = "order_type")
    @Expose
    private Integer orderType;// 订单类型 1-淘宝 2-京东

    @org.yeshi.utils.mybatis.Column(name = "state")
    @org.yeshi.utils.generater.mybatis.Column(name = "state")
    @Expose
    private Integer state;// 订单状态 -1：失效0-未支付?1-已支负

    @org.yeshi.utils.mybatis.Column(name = "state_desc")
    @org.yeshi.utils.generater.mybatis.Column(name = "state_desc")
    @Expose
    private String stateDesc;//订单描述

    @org.yeshi.utils.mybatis.Column(name = "drawback_time")
    @org.yeshi.utils.generater.mybatis.Column(name = "drawback_time")
    @Expose
    private Long drawbackTime;// 退款时间

    @org.yeshi.utils.mybatis.Column(name = "createtime")
    @org.yeshi.utils.generater.mybatis.Column(name = "createtime")
    @Expose
    private Long createtime;// 创建时间 付款时间

    @org.yeshi.utils.mybatis.Column(name = "uid")
    @org.yeshi.utils.generater.mybatis.Column(name = "uid")
    @Expose
    private UserInfo userInfo;

    @org.yeshi.utils.mybatis.Column(name = "beizhu")
    @org.yeshi.utils.generater.mybatis.Column(name = "beizhu")
    @Expose
    private String beizhu;

    @org.yeshi.utils.mybatis.Column(name = "money")
    @org.yeshi.utils.generater.mybatis.Column(name = "money")
    @Expose
    private BigDecimal money;

    // 第三方订单创建时间
    @org.yeshi.utils.mybatis.Column(name = "third_createtime")
    @org.yeshi.utils.generater.mybatis.Column(name = "third_createtime")
    @Expose
    private Date thirdCreateTime;

    // 第三方订单状态
    @org.yeshi.utils.mybatis.Column(name = "third_state")
    @org.yeshi.utils.generater.mybatis.Column(name = "third_state")
    @Expose
    private String thirdState;

@@ -90,7 +90,7 @@
    /**
     * 版本： 1（1.2.3v之前）2:之后
     */
    @org.yeshi.utils.mybatis.Column(name = "version")
    @org.yeshi.utils.generater.mybatis.Column(name = "version")
    private Integer version;

    public Order() {

 fanli/src/main/java/com/yeshi/fanli/entity/bus/user/PayInfo.java

@@ -2,8 +2,8 @@

import java.util.Date;

import org.yeshi.utils.mybatis.Column;
import org.yeshi.utils.mybatis.Table;
import org.yeshi.utils.generater.mybatis.Column;
import org.yeshi.utils.generater.mybatis.Table;
/**
 * 支付宝转账结果记录
 * @author Administrator

 fanli/src/main/java/com/yeshi/fanli/entity/bus/user/SMSHistory.java

@@ -3,8 +3,8 @@

import java.util.Date;

import org.yeshi.utils.mybatis.Column;
import org.yeshi.utils.mybatis.Table;
import org.yeshi.utils.generater.mybatis.Column;
import org.yeshi.utils.generater.mybatis.Table;

/**
 * 短信验证码发送历史记录

 fanli/src/main/java/com/yeshi/fanli/entity/bus/user/ShamUser.java

@@ -2,10 +2,10 @@

import com.google.gson.annotations.Expose;
import org.springframework.data.annotation.Transient;
import org.yeshi.utils.mybatis.Column;
import org.yeshi.utils.generater.mybatis.Column;

//假用户
@org.yeshi.utils.mybatis.Table("yeshi_ec_sham_user")
@org.yeshi.utils.generater.mybatis.Table("yeshi_ec_sham_user")
public class ShamUser {
    @Column(name = "`id`")
    private long id;

 fanli/src/main/java/com/yeshi/fanli/entity/bus/user/ThreeSale.java

@@ -1,7 +1,7 @@
package com.yeshi.fanli.entity.bus.user;

import org.springframework.data.annotation.Transient;
import org.yeshi.utils.mybatis.Column;
import org.yeshi.utils.generater.mybatis.Column;

/**
 * 分销关系
@@ -10,7 +10,7 @@
 *
 * @date 2018年1月29日
 */
@org.yeshi.utils.mybatis.Table("yeshi_ec_threeSale")
@org.yeshi.utils.generater.mybatis.Table("yeshi_ec_threeSale")
public class ThreeSale {
    // 邀请状态
    public static int STATE_SUCCESS = 1;// 成功

 fanli/src/main/java/com/yeshi/fanli/entity/bus/user/ThreeSaleExtraInfo.java

@@ -7,37 +7,37 @@
 *
 * @date 2018年11月20日
 */
@org.yeshi.utils.mybatis.Table("yeshi_ec_threesale_extra_info")
@org.yeshi.utils.generater.mybatis.Table("yeshi_ec_threesale_extra_info")
public class ThreeSaleExtraInfo {
    
    @org.yeshi.utils.mybatis.Column(name = "tf_id")
    @org.yeshi.utils.generater.mybatis.Column(name = "tf_id")
    private Long id;
    
    @org.yeshi.utils.mybatis.Column(name = "tf_boss_id")
    @org.yeshi.utils.generater.mybatis.Column(name = "tf_boss_id")
    private UserInfo boss;//邀请者

    @org.yeshi.utils.mybatis.Column(name = "tf_worker_id")
    @org.yeshi.utils.generater.mybatis.Column(name = "tf_worker_id")
    private UserInfo worker; //被邀请者
    
    @org.yeshi.utils.mybatis.Column(name = "tf_nickname")
    @org.yeshi.utils.generater.mybatis.Column(name = "tf_nickname")
    private String nickname; // 备注名
    
    @org.yeshi.utils.mybatis.Column(name = "tf_remind_boss")
    @org.yeshi.utils.generater.mybatis.Column(name = "tf_remind_boss")
    private Integer remindBoss; // 提示boss绑定微信   1 已提醒
    
    @org.yeshi.utils.mybatis.Column(name = "tf_remind_worker")
    @org.yeshi.utils.generater.mybatis.Column(name = "tf_remind_worker")
    private Integer remindWorker; // 提示worker绑定微信  1 已提醒
    
    @org.yeshi.utils.mybatis.Column(name = "tf_type")
    @org.yeshi.utils.generater.mybatis.Column(name = "tf_type")
    private Integer type; // 1-一级  2二级
    
    @org.yeshi.utils.mybatis.Column(name = "tf_tags")
    @org.yeshi.utils.generater.mybatis.Column(name = "tf_tags")
    private String tags; // 标签
    
    @org.yeshi.utils.mybatis.Column(name = "tf_createtime")
    @org.yeshi.utils.generater.mybatis.Column(name = "tf_createtime")
    private Date createTime; // 创建时间

    @org.yeshi.utils.mybatis.Column(name = "tf_updatetime")
    @org.yeshi.utils.generater.mybatis.Column(name = "tf_updatetime")
    private Date updateTime; // 更新时间

    public Long getId() {

 fanli/src/main/java/com/yeshi/fanli/entity/bus/user/ThreeSaleRank.java

@@ -1,7 +1,7 @@
package com.yeshi.fanli.entity.bus.user;


import org.yeshi.utils.mybatis.Table;
import org.yeshi.utils.generater.mybatis.Table;

/**
 * 页面上那些假的用户数据

 fanli/src/main/java/com/yeshi/fanli/entity/bus/user/TokenRecord.java

@@ -2,8 +2,8 @@

import java.util.Date;

import org.yeshi.utils.mybatis.Column;
import org.yeshi.utils.mybatis.Table;
import org.yeshi.utils.generater.mybatis.Column;
import org.yeshi.utils.generater.mybatis.Table;

import com.google.gson.annotations.Expose;


 fanli/src/main/java/com/yeshi/fanli/entity/bus/user/UserAccountBindingHistory.java

@@ -2,8 +2,8 @@

import java.util.Date;

import org.yeshi.utils.mybatis.Column;
import org.yeshi.utils.mybatis.Table;
import org.yeshi.utils.generater.mybatis.Column;
import org.yeshi.utils.generater.mybatis.Table;

/**
 * 用户账户绑定记录

 fanli/src/main/java/com/yeshi/fanli/entity/bus/user/UserActiveLog.java

@@ -2,8 +2,8 @@

import java.util.Date;

import org.yeshi.utils.mybatis.Column;
import org.yeshi.utils.mybatis.Table;
import org.yeshi.utils.generater.mybatis.Column;
import org.yeshi.utils.generater.mybatis.Table;

/**
 * 用户活跃日志

 fanli/src/main/java/com/yeshi/fanli/entity/bus/user/UserComplaint.java

@@ -2,8 +2,8 @@

import java.util.Date;

import org.yeshi.utils.mybatis.Column;
import org.yeshi.utils.mybatis.Table;
import org.yeshi.utils.generater.mybatis.Column;
import org.yeshi.utils.generater.mybatis.Table;

/**
 * 用户 吐槽内容

 fanli/src/main/java/com/yeshi/fanli/entity/bus/user/UserConnectHistory.java

@@ -2,8 +2,8 @@

import java.util.Date;

import org.yeshi.utils.mybatis.Column;
import org.yeshi.utils.mybatis.Table;
import org.yeshi.utils.generater.mybatis.Column;
import org.yeshi.utils.generater.mybatis.Table;

/**
 * 用户账号打通记录

 fanli/src/main/java/com/yeshi/fanli/entity/bus/user/UserCustomSettings.java

@@ -2,8 +2,8 @@

import java.util.Date;

import org.yeshi.utils.mybatis.Column;
import org.yeshi.utils.mybatis.Table;
import org.yeshi.utils.generater.mybatis.Column;
import org.yeshi.utils.generater.mybatis.Table;

/**
 * 用户app界面个性化设置

 fanli/src/main/java/com/yeshi/fanli/entity/bus/user/UserExtraTaoBaoInfo.java

@@ -2,8 +2,8 @@

import java.util.Date;

import org.yeshi.utils.mybatis.Column;
import org.yeshi.utils.mybatis.Table;
import org.yeshi.utils.generater.mybatis.Column;
import org.yeshi.utils.generater.mybatis.Table;

@Table("yeshi_ec_user_info_extra_taobao")
public class UserExtraTaoBaoInfo {

 fanli/src/main/java/com/yeshi/fanli/entity/bus/user/UserGoodsStorage.java

@@ -2,8 +2,8 @@

import java.util.Date;

import org.yeshi.utils.mybatis.Column;
import org.yeshi.utils.mybatis.Table;
import org.yeshi.utils.generater.mybatis.Column;
import org.yeshi.utils.generater.mybatis.Table;

import com.yeshi.fanli.entity.goods.CommonGoods;


 fanli/src/main/java/com/yeshi/fanli/entity/bus/user/UserInfo.java

@@ -6,8 +6,8 @@

import com.yeshi.fanli.entity.SystemEnum;
import org.springframework.data.annotation.Transient;
import org.yeshi.utils.mybatis.Column;
import org.yeshi.utils.mybatis.Table;
import org.yeshi.utils.generater.mybatis.Column;
import org.yeshi.utils.generater.mybatis.Table;

import com.google.gson.annotations.Expose;


 fanli/src/main/java/com/yeshi/fanli/entity/bus/user/UserInfoDeleteRecord.java

@@ -2,8 +2,8 @@

import java.util.Date;

import org.yeshi.utils.mybatis.Column;
import org.yeshi.utils.mybatis.Table;
import org.yeshi.utils.generater.mybatis.Column;
import org.yeshi.utils.generater.mybatis.Table;

/**
 * 用户删除、封禁记录

 fanli/src/main/java/com/yeshi/fanli/entity/bus/user/UserInfoExtra.java

@@ -2,8 +2,8 @@

import java.util.Date;

import org.yeshi.utils.mybatis.Column;
import org.yeshi.utils.mybatis.Table;
import org.yeshi.utils.generater.mybatis.Column;
import org.yeshi.utils.generater.mybatis.Table;

import com.google.gson.annotations.Expose;


 fanli/src/main/java/com/yeshi/fanli/entity/bus/user/UserInfoModifyRecord.java

@@ -3,8 +3,8 @@
import java.io.Serializable;
import java.util.Date;

import org.yeshi.utils.mybatis.Column;
import org.yeshi.utils.mybatis.Table;
import org.yeshi.utils.generater.mybatis.Column;
import org.yeshi.utils.generater.mybatis.Table;

/**
 * 修改记录

 fanli/src/main/java/com/yeshi/fanli/entity/bus/user/UserInfoRegister.java

@@ -2,8 +2,8 @@

import java.util.Date;

import org.yeshi.utils.mybatis.Column;
import org.yeshi.utils.mybatis.Table;
import org.yeshi.utils.generater.mybatis.Column;
import org.yeshi.utils.generater.mybatis.Table;

/**
 * 首次注册信息

 fanli/src/main/java/com/yeshi/fanli/entity/bus/user/UserInviteRecord.java

@@ -2,8 +2,8 @@

import java.util.Date;

import org.yeshi.utils.mybatis.Column;
import org.yeshi.utils.mybatis.Table;
import org.yeshi.utils.generater.mybatis.Column;
import org.yeshi.utils.generater.mybatis.Table;

/**
 * 用户邀请记录

 fanli/src/main/java/com/yeshi/fanli/entity/bus/user/UserInviteValidNum.java

@@ -2,8 +2,8 @@

import java.util.Date;

import org.yeshi.utils.mybatis.Column;
import org.yeshi.utils.mybatis.Table;
import org.yeshi.utils.generater.mybatis.Column;
import org.yeshi.utils.generater.mybatis.Table;

/**
 * 有效粉丝数量

 fanli/src/main/java/com/yeshi/fanli/entity/bus/user/UserInviteValidRecord.java

@@ -2,8 +2,8 @@

import java.util.Date;

import org.yeshi.utils.mybatis.Column;
import org.yeshi.utils.mybatis.Table;
import org.yeshi.utils.generater.mybatis.Column;
import org.yeshi.utils.generater.mybatis.Table;

/**
 * 有效粉丝记录表

 fanli/src/main/java/com/yeshi/fanli/entity/bus/user/UserLotteryRecord.java

@@ -2,8 +2,8 @@

import java.util.Date;

import org.yeshi.utils.mybatis.Column;
import org.yeshi.utils.mybatis.Table;
import org.yeshi.utils.generater.mybatis.Column;
import org.yeshi.utils.generater.mybatis.Table;

/**
 *    抽奖次数记录

 fanli/src/main/java/com/yeshi/fanli/entity/bus/user/UserMoneyExtra.java

@@ -3,8 +3,8 @@
import java.math.BigDecimal;
import java.util.Date;

import org.yeshi.utils.mybatis.Column;
import org.yeshi.utils.mybatis.Table;
import org.yeshi.utils.generater.mybatis.Column;
import org.yeshi.utils.generater.mybatis.Table;

/**
 *   用户其他金额类型

 fanli/src/main/java/com/yeshi/fanli/entity/bus/user/UserRank.java

@@ -2,8 +2,8 @@

import java.util.Date;

import org.yeshi.utils.mybatis.Column;
import org.yeshi.utils.mybatis.Table;
import org.yeshi.utils.generater.mybatis.Column;
import org.yeshi.utils.generater.mybatis.Table;

import com.google.gson.annotations.Expose;


 fanli/src/main/java/com/yeshi/fanli/entity/bus/user/UserRankRecord.java

@@ -2,8 +2,8 @@

import java.util.Date;

import org.yeshi.utils.mybatis.Column;
import org.yeshi.utils.mybatis.Table;
import org.yeshi.utils.generater.mybatis.Column;
import org.yeshi.utils.generater.mybatis.Table;

/**
 * 用户等级记录

 fanli/src/main/java/com/yeshi/fanli/entity/bus/user/UserRankings.java

@@ -10,41 +10,41 @@
 *
 * @date 2018年7月27日
 */
@org.yeshi.utils.mybatis.Table("yeshi_ec_rankings_record")
@org.yeshi.utils.generater.mybatis.Table("yeshi_ec_rankings_record")
public class UserRankings {


    @org.yeshi.utils.mybatis.Column(name = "r_id")
    @org.yeshi.utils.generater.mybatis.Column(name = "r_id")
    private Long id;

    @org.yeshi.utils.mybatis.Column(name = "r_show_id")
    @org.yeshi.utils.generater.mybatis.Column(name = "r_show_id")
    private String showId; // 显示id
    
    @org.yeshi.utils.mybatis.Column(name = "r_nick_name")
    @org.yeshi.utils.generater.mybatis.Column(name = "r_nick_name")
    private String nickName;// 名称

    @org.yeshi.utils.mybatis.Column(name = "r_portrait")
    @org.yeshi.utils.generater.mybatis.Column(name = "r_portrait")
    private String portrait;  //头像url
    
    @org.yeshi.utils.mybatis.Column(name = "r_trade_reward")
    @org.yeshi.utils.generater.mybatis.Column(name = "r_trade_reward")
    private BigDecimal tradeReward; // 自购奖励

    @org.yeshi.utils.mybatis.Column(name = "r_share_reward")
    @org.yeshi.utils.generater.mybatis.Column(name = "r_share_reward")
    private BigDecimal shareReward; // 分享奖励
    
    @org.yeshi.utils.mybatis.Column(name = "r_trade_state")
    @org.yeshi.utils.generater.mybatis.Column(name = "r_trade_state")
    private Integer tradeState; // 自购在线状态

    @org.yeshi.utils.mybatis.Column(name = "r_share_state")
    @org.yeshi.utils.generater.mybatis.Column(name = "r_share_state")
    private Integer shareState; // 分享在线状态

    @org.yeshi.utils.mybatis.Column(name = "r_trade_time")
    @org.yeshi.utils.generater.mybatis.Column(name = "r_trade_time")
    private Date tradeTime; // 自购榜 最后入榜时间

    @org.yeshi.utils.mybatis.Column(name = "r_share_time")
    @org.yeshi.utils.generater.mybatis.Column(name = "r_share_time")
    private Date shareTime; // 分享榜 最后入榜时间

    @org.yeshi.utils.mybatis.Column(name = "r_createtime")
    @org.yeshi.utils.generater.mybatis.Column(name = "r_createtime")
    private Date createtime; // 创建时间

    public Long getId() {

 fanli/src/main/java/com/yeshi/fanli/entity/bus/user/UserSystemCoupon.java

@@ -2,8 +2,8 @@

import java.util.Date;

import org.yeshi.utils.mybatis.Column;
import org.yeshi.utils.mybatis.Table;
import org.yeshi.utils.generater.mybatis.Column;
import org.yeshi.utils.generater.mybatis.Table;

import com.google.gson.annotations.Expose;
import com.yeshi.fanli.entity.system.SystemCoupon;

 fanli/src/main/java/com/yeshi/fanli/entity/bus/user/UserSystemCouponActivate.java

@@ -2,8 +2,8 @@

import java.util.Date;

import org.yeshi.utils.mybatis.Column;
import org.yeshi.utils.mybatis.Table;
import org.yeshi.utils.generater.mybatis.Column;
import org.yeshi.utils.generater.mybatis.Table;


/**

 fanli/src/main/java/com/yeshi/fanli/entity/bus/user/UserSystemCouponGiveRecord.java

@@ -2,8 +2,8 @@

import java.util.Date;

import org.yeshi.utils.mybatis.Column;
import org.yeshi.utils.mybatis.Table;
import org.yeshi.utils.generater.mybatis.Column;
import org.yeshi.utils.generater.mybatis.Table;

/**
 * 券赠送记录

 fanli/src/main/java/com/yeshi/fanli/entity/bus/user/UserSystemCouponRecord.java

@@ -2,8 +2,8 @@

import java.util.Date;

import org.yeshi.utils.mybatis.Column;
import org.yeshi.utils.mybatis.Table;
import org.yeshi.utils.generater.mybatis.Column;
import org.yeshi.utils.generater.mybatis.Table;

/**
 * 用户券使用记录

 fanli/src/main/java/com/yeshi/fanli/entity/bus/user/cloud/UserCloud.java

@@ -2,8 +2,8 @@

import java.util.Date;

import org.yeshi.utils.mybatis.Column;
import org.yeshi.utils.mybatis.Table;
import org.yeshi.utils.generater.mybatis.Column;
import org.yeshi.utils.generater.mybatis.Table;

/**
 * 用户云发单

 fanli/src/main/java/com/yeshi/fanli/entity/bus/user/cloud/UserCloudGoods.java

@@ -2,8 +2,8 @@

import java.util.Date;

import org.yeshi.utils.mybatis.Column;
import org.yeshi.utils.mybatis.Table;
import org.yeshi.utils.generater.mybatis.Column;
import org.yeshi.utils.generater.mybatis.Table;

import com.google.gson.annotations.Expose;
import com.yeshi.fanli.entity.goods.CommonGoods;

 fanli/src/main/java/com/yeshi/fanli/entity/bus/user/cloud/UserCloudGroup.java

@@ -2,8 +2,8 @@

import java.util.Date;

import org.yeshi.utils.mybatis.Column;
import org.yeshi.utils.mybatis.Table;
import org.yeshi.utils.generater.mybatis.Column;
import org.yeshi.utils.generater.mybatis.Table;

/**
 * 用户云发单-群

 fanli/src/main/java/com/yeshi/fanli/entity/bus/user/cloud/UserCloudManage.java

@@ -2,8 +2,8 @@

import java.util.Date;

import org.yeshi.utils.mybatis.Column;
import org.yeshi.utils.mybatis.Table;
import org.yeshi.utils.generater.mybatis.Column;
import org.yeshi.utils.generater.mybatis.Table;

/**
 * 发单商品库

 fanli/src/main/java/com/yeshi/fanli/entity/bus/user/cloud/UserCloudOrder.java

@@ -3,8 +3,8 @@
import java.math.BigDecimal;
import java.util.Date;

import org.yeshi.utils.mybatis.Column;
import org.yeshi.utils.mybatis.Table;
import org.yeshi.utils.generater.mybatis.Column;
import org.yeshi.utils.generater.mybatis.Table;

import com.google.gson.annotations.Expose;


 fanli/src/main/java/com/yeshi/fanli/entity/bus/user/vip/TeamUserLevelStatistic.java

@@ -2,8 +2,8 @@

import java.util.Date;

import org.yeshi.utils.mybatis.Column;
import org.yeshi.utils.mybatis.Table;
import org.yeshi.utils.generater.mybatis.Column;
import org.yeshi.utils.generater.mybatis.Table;

/**
 * 团队成员等级统计 -有效粉丝

 fanli/src/main/java/com/yeshi/fanli/entity/bus/user/vip/UserVIPInfo.java

@@ -2,8 +2,8 @@

import java.util.Date;

import org.yeshi.utils.mybatis.Column;
import org.yeshi.utils.mybatis.Table;
import org.yeshi.utils.generater.mybatis.Column;
import org.yeshi.utils.generater.mybatis.Table;

import com.yeshi.fanli.entity.bus.user.UserInfo;


 fanli/src/main/java/com/yeshi/fanli/entity/bus/user/vip/UserVIPPreInfo.java

@@ -2,8 +2,8 @@

import java.util.Date;

import org.yeshi.utils.mybatis.Column;
import org.yeshi.utils.mybatis.Table;
import org.yeshi.utils.generater.mybatis.Column;
import org.yeshi.utils.generater.mybatis.Table;

/**
 * 分阶段超级会员

 fanli/src/main/java/com/yeshi/fanli/entity/bus/user/vip/UserVipConfig.java

@@ -2,8 +2,8 @@

import java.util.Date;

import org.yeshi.utils.mybatis.Column;
import org.yeshi.utils.mybatis.Table;
import org.yeshi.utils.generater.mybatis.Column;
import org.yeshi.utils.generater.mybatis.Table;

/**
 * 配置信息

 fanli/src/main/java/com/yeshi/fanli/entity/common/AdminUser.java

@@ -2,8 +2,8 @@

import java.io.Serializable;

import org.yeshi.utils.mybatis.Column;
import org.yeshi.utils.mybatis.Table;
import org.yeshi.utils.generater.mybatis.Column;
import org.yeshi.utils.generater.mybatis.Table;

import com.google.gson.annotations.Expose;


 fanli/src/main/java/com/yeshi/fanli/entity/common/Config.java

@@ -4,8 +4,8 @@


import com.yeshi.fanli.entity.SystemEnum;
import org.yeshi.utils.mybatis.Column;
import org.yeshi.utils.mybatis.Table;
import org.yeshi.utils.generater.mybatis.Column;
import org.yeshi.utils.generater.mybatis.Table;

@Table("yeshi_ec_config")
public class Config implements Serializable {

 fanli/src/main/java/com/yeshi/fanli/entity/common/DataMonitor.java

@@ -10,7 +10,7 @@
 * @author Administrator
 *
 */
@org.yeshi.utils.mybatis.Table("yeshi_ec_monitor_data")
@org.yeshi.utils.generater.mybatis.Table("yeshi_ec_monitor_data")
public class DataMonitor {
    public DataMonitor() {
    }
@@ -27,19 +27,19 @@
        this.updateTime = updateTime;
    }

    @org.yeshi.utils.mybatis.Column(name = "md_id")
    @org.yeshi.utils.generater.mybatis.Column(name = "md_id")
    private Long id;

    @org.yeshi.utils.mybatis.Column(name = "md_name")
    @org.yeshi.utils.generater.mybatis.Column(name = "md_name")
    @Expose
    private String name;
    @org.yeshi.utils.mybatis.Column(name = "md_key")
    @org.yeshi.utils.generater.mybatis.Column(name = "md_key")
    private String key;
    @org.yeshi.utils.mybatis.Column(name = "md_value")
    @org.yeshi.utils.generater.mybatis.Column(name = "md_value")
    private String value;
    @org.yeshi.utils.mybatis.Column(name = "md_createtime")
    @org.yeshi.utils.generater.mybatis.Column(name = "md_createtime")
    private Date createTime;
    @org.yeshi.utils.mybatis.Column(name = "md_updatetime")
    @org.yeshi.utils.generater.mybatis.Column(name = "md_updatetime")
    private Date updateTime;

    public Long getId() {

 fanli/src/main/java/com/yeshi/fanli/entity/common/JumpDetail.java

@@ -2,8 +2,8 @@

import java.io.Serializable;

import org.yeshi.utils.mybatis.Column;
import org.yeshi.utils.mybatis.Table;
import org.yeshi.utils.generater.mybatis.Column;
import org.yeshi.utils.generater.mybatis.Table;

/**
 * 前端跳转详情

 fanli/src/main/java/com/yeshi/fanli/entity/common/JumpDetailV2.java

@@ -2,8 +2,8 @@

import com.google.gson.annotations.Expose;
import com.yeshi.fanli.entity.SystemEnum;
import org.yeshi.utils.mybatis.Column;
import org.yeshi.utils.mybatis.Table;
import org.yeshi.utils.generater.mybatis.Column;
import org.yeshi.utils.generater.mybatis.Table;

import java.io.Serializable;

@@ -13,49 +13,49 @@
 * @author Administrator
 * @date 2018年10月23日
 */
@org.yeshi.utils.mybatis.Table("yeshi_ec_action_jumpdetail_v2")
@org.yeshi.utils.generater.mybatis.Table("yeshi_ec_action_jumpdetail_v2")
public class JumpDetailV2 implements Serializable {

    private static final long serialVersionUID = 1L;

    @org.yeshi.utils.mybatis.Column(name = "jp_id")
    @org.yeshi.utils.generater.mybatis.Column(name = "jp_id")
    private Long id;

    // 名称

    @org.yeshi.utils.mybatis.Column(name = "jp_name")
    @org.yeshi.utils.generater.mybatis.Column(name = "jp_name")
    private String name;

    // Android链接
    @Expose
    @org.yeshi.utils.mybatis.Column(name = "jp_activity")
    @org.yeshi.utils.generater.mybatis.Column(name = "jp_activity")
    private String activity;

    // IOS跳转链接
    @Expose

    @org.yeshi.utils.mybatis.Column(name = "jp_controller")
    @org.yeshi.utils.generater.mybatis.Column(name = "jp_controller")
    private String controller;

    @Expose
    @org.yeshi.utils.mybatis.Column(name = "jp_path")
    @org.yeshi.utils.generater.mybatis.Column(name = "jp_path")
    private String path;//小程序路径

    // 跳转类型
    @Expose
    @org.yeshi.utils.mybatis.Column(name = "jp_type")
    @org.yeshi.utils.generater.mybatis.Column(name = "jp_type")
    private String type;

    @Expose
    @org.yeshi.utils.mybatis.Column(name = "jp_need_login")
    @org.yeshi.utils.generater.mybatis.Column(name = "jp_need_login")
    private Boolean needLogin;
    @org.yeshi.utils.mybatis.Column(name = "jp_min_android_version")
    @org.yeshi.utils.generater.mybatis.Column(name = "jp_min_android_version")
    private Integer minAndroidAppVersion;// 最小Android版本
    @org.yeshi.utils.mybatis.Column(name = "jp_min_ios_version")
    @org.yeshi.utils.generater.mybatis.Column(name = "jp_min_ios_version")
    private Integer minIOSAppVersion;// 最小ios版本


    @org.yeshi.utils.mybatis.Column(name = "jp_system")
    @org.yeshi.utils.generater.mybatis.Column(name = "jp_system")
    private SystemEnum system;

    public String getPath() {

 fanli/src/main/java/com/yeshi/fanli/entity/config/CommonConfig.java

@@ -1,7 +1,7 @@
package com.yeshi.fanli.entity.config;

import org.yeshi.utils.mybatis.Column;
import org.yeshi.utils.mybatis.Table;
import org.yeshi.utils.generater.mybatis.Column;
import org.yeshi.utils.generater.mybatis.Table;

/**
 * 通用配置

 fanli/src/main/java/com/yeshi/fanli/entity/customerservice/CustomerServiceCommonQuestion.java

@@ -3,8 +3,8 @@
import java.util.Date;

import com.google.gson.annotations.Expose;
import org.yeshi.utils.mybatis.Column;
import org.yeshi.utils.mybatis.Table;
import org.yeshi.utils.generater.mybatis.Column;
import org.yeshi.utils.generater.mybatis.Table;

/**
 * 客服系统中的常见消息

 fanli/src/main/java/com/yeshi/fanli/entity/customerservice/CustomerServiceHistory.java

@@ -4,8 +4,8 @@

import com.yeshi.fanli.entity.AppInfo;
import com.yeshi.fanli.entity.DeviceInfo;
import org.yeshi.utils.mybatis.Column;
import org.yeshi.utils.mybatis.Table;
import org.yeshi.utils.generater.mybatis.Column;
import org.yeshi.utils.generater.mybatis.Table;

/**
 * 用户咨询的历史消息

 fanli/src/main/java/com/yeshi/fanli/entity/customerservice/CustomerServiceWXXCXHistory.java

@@ -2,8 +2,8 @@

import java.util.Date;

import org.yeshi.utils.mybatis.Column;
import org.yeshi.utils.mybatis.Table;
import org.yeshi.utils.generater.mybatis.Column;
import org.yeshi.utils.generater.mybatis.Table;

/**
 * 小程序客服咨询记录

 fanli/src/main/java/com/yeshi/fanli/entity/elme/ElmeHongBaoOrderMap.java

@@ -2,8 +2,8 @@

import java.util.Date;

import org.yeshi.utils.mybatis.Column;
import org.yeshi.utils.mybatis.Table;
import org.yeshi.utils.generater.mybatis.Column;
import org.yeshi.utils.generater.mybatis.Table;

import com.yeshi.fanli.entity.bus.user.HongBaoV2;


 fanli/src/main/java/com/yeshi/fanli/entity/elme/ElmeOrder.java

@@ -4,8 +4,8 @@
import java.math.BigDecimal;
import java.util.Date;

import org.yeshi.utils.mybatis.Column;
import org.yeshi.utils.mybatis.Table;
import org.yeshi.utils.generater.mybatis.Column;
import org.yeshi.utils.generater.mybatis.Table;

/**
 * 饿了么订单

 fanli/src/main/java/com/yeshi/fanli/entity/goods/CollectionGoodsV2.java

@@ -2,8 +2,8 @@

import java.util.Date;

import org.yeshi.utils.mybatis.Column;
import org.yeshi.utils.mybatis.Table;
import org.yeshi.utils.generater.mybatis.Column;
import org.yeshi.utils.generater.mybatis.Table;

import com.yeshi.fanli.entity.bus.user.UserInfo;


 fanli/src/main/java/com/yeshi/fanli/entity/goods/CommonGoods.java

@@ -4,8 +4,8 @@
import java.math.BigDecimal;
import java.util.Date;

import org.yeshi.utils.mybatis.Column;
import org.yeshi.utils.mybatis.Table;
import org.yeshi.utils.generater.mybatis.Column;
import org.yeshi.utils.generater.mybatis.Table;

@Table("yeshi_ec_common_goods")
public class CommonGoods extends BaseGoodsInfo implements Serializable {

 fanli/src/main/java/com/yeshi/fanli/entity/goods/RecommendUserGoods.java

@@ -3,8 +3,8 @@
import java.util.Date;
import java.util.List;

import org.yeshi.utils.mybatis.Column;
import org.yeshi.utils.mybatis.Table;
import org.yeshi.utils.generater.mybatis.Column;
import org.yeshi.utils.generater.mybatis.Table;

import com.yeshi.fanli.entity.bus.user.UserInfo;


 fanli/src/main/java/com/yeshi/fanli/entity/goods/RecommendUserGoodsMap.java

@@ -2,8 +2,8 @@

import java.util.Date;

import org.yeshi.utils.mybatis.Column;
import org.yeshi.utils.mybatis.Table;
import org.yeshi.utils.generater.mybatis.Column;
import org.yeshi.utils.generater.mybatis.Table;

/*
 * 用户商品推荐

 fanli/src/main/java/com/yeshi/fanli/entity/goods/ScanHistoryV2.java

@@ -2,8 +2,8 @@

import java.util.Date;

import org.yeshi.utils.mybatis.Column;
import org.yeshi.utils.mybatis.Table;
import org.yeshi.utils.generater.mybatis.Column;
import org.yeshi.utils.generater.mybatis.Table;

import com.yeshi.fanli.entity.bus.user.UserInfo;


 fanli/src/main/java/com/yeshi/fanli/entity/goods/ShareGoodsTextTemplate.java

@@ -2,8 +2,8 @@

import java.util.Date;

import org.yeshi.utils.mybatis.Column;
import org.yeshi.utils.mybatis.Table;
import org.yeshi.utils.generater.mybatis.Column;
import org.yeshi.utils.generater.mybatis.Table;

/**
 * 分享商品的话语模板

 fanli/src/main/java/com/yeshi/fanli/entity/goods/recommend/RecommendGoodsDeleteHistory.java

@@ -2,8 +2,8 @@

import java.util.Date;

import org.yeshi.utils.mybatis.Column;
import org.yeshi.utils.mybatis.Table;
import org.yeshi.utils.generater.mybatis.Column;
import org.yeshi.utils.generater.mybatis.Table;

@Table("yeshi_ec_recommend_goods_user_delete")
public class RecommendGoodsDeleteHistory {

 fanli/src/main/java/com/yeshi/fanli/entity/integral/CodePublishRecord.java

@@ -3,8 +3,8 @@
import java.io.Serializable;
import java.util.Date;

import org.yeshi.utils.mybatis.Column;
import org.yeshi.utils.mybatis.Table;
import org.yeshi.utils.generater.mybatis.Column;
import org.yeshi.utils.generater.mybatis.Table;

import com.google.gson.annotations.Expose;


 fanli/src/main/java/com/yeshi/fanli/entity/integral/IntegralDetail.java

@@ -2,8 +2,8 @@

import java.util.Date;

import org.yeshi.utils.mybatis.Column;
import org.yeshi.utils.mybatis.Table;
import org.yeshi.utils.generater.mybatis.Column;
import org.yeshi.utils.generater.mybatis.Table;

import com.google.gson.annotations.Expose;


 fanli/src/main/java/com/yeshi/fanli/entity/integral/IntegralExchange.java

@@ -4,8 +4,8 @@
import java.math.BigDecimal;
import java.util.Date;

import org.yeshi.utils.mybatis.Column;
import org.yeshi.utils.mybatis.Table;
import org.yeshi.utils.generater.mybatis.Column;
import org.yeshi.utils.generater.mybatis.Table;

import com.google.gson.annotations.Expose;


 fanli/src/main/java/com/yeshi/fanli/entity/integral/IntegralExchangeRecord.java

@@ -3,8 +3,8 @@
import java.io.Serializable;
import java.util.Date;

import org.yeshi.utils.mybatis.Column;
import org.yeshi.utils.mybatis.Table;
import org.yeshi.utils.generater.mybatis.Column;
import org.yeshi.utils.generater.mybatis.Table;

/**
 * 积分兑换记录

 fanli/src/main/java/com/yeshi/fanli/entity/integral/IntegralTask.java

@@ -3,8 +3,8 @@
import java.io.Serializable;
import java.util.Date;

import org.yeshi.utils.mybatis.Column;
import org.yeshi.utils.mybatis.Table;
import org.yeshi.utils.generater.mybatis.Column;
import org.yeshi.utils.generater.mybatis.Table;

/**
 * 积分任务

 fanli/src/main/java/com/yeshi/fanli/entity/integral/IntegralTaskClass.java

@@ -3,8 +3,8 @@
import java.io.Serializable;
import java.util.Date;

import org.yeshi.utils.mybatis.Column;
import org.yeshi.utils.mybatis.Table;
import org.yeshi.utils.generater.mybatis.Column;
import org.yeshi.utils.generater.mybatis.Table;

import com.google.gson.annotations.Expose;
import com.yeshi.fanli.entity.common.JumpDetailV2;

 fanli/src/main/java/com/yeshi/fanli/entity/integral/IntegralTaskRank.java

@@ -3,8 +3,8 @@
import java.io.Serializable;
import java.util.Date;

import org.yeshi.utils.mybatis.Column;
import org.yeshi.utils.mybatis.Table;
import org.yeshi.utils.generater.mybatis.Column;
import org.yeshi.utils.generater.mybatis.Table;

/**
 * 积分等级奖励

 fanli/src/main/java/com/yeshi/fanli/entity/integral/IntegralTaskRecord.java

@@ -3,8 +3,8 @@
import java.io.Serializable;
import java.util.Date;

import org.yeshi.utils.mybatis.Column;
import org.yeshi.utils.mybatis.Table;
import org.yeshi.utils.generater.mybatis.Column;
import org.yeshi.utils.generater.mybatis.Table;

import com.google.gson.annotations.Expose;


 fanli/src/main/java/com/yeshi/fanli/entity/integral/UserGetIntegralFromOrderRecord.java

@@ -2,8 +2,8 @@

import java.util.Date;

import org.yeshi.utils.mybatis.Column;
import org.yeshi.utils.mybatis.Table;
import org.yeshi.utils.generater.mybatis.Column;
import org.yeshi.utils.generater.mybatis.Table;

/**
 * 用户因为订单获取到金币

 fanli/src/main/java/com/yeshi/fanli/entity/jd/JDGoodsClass.java

@@ -3,8 +3,8 @@
import java.math.BigDecimal;
import java.util.Date;

import org.yeshi.utils.mybatis.Column;
import org.yeshi.utils.mybatis.Table;
import org.yeshi.utils.generater.mybatis.Column;
import org.yeshi.utils.generater.mybatis.Table;

/**
 * 商品分类

 fanli/src/main/java/com/yeshi/fanli/entity/jd/JDOrder.java

@@ -3,8 +3,8 @@
import java.util.Date;
import java.util.List;

import org.yeshi.utils.mybatis.Column;
import org.yeshi.utils.mybatis.Table;
import org.yeshi.utils.generater.mybatis.Column;
import org.yeshi.utils.generater.mybatis.Table;

import com.google.gson.annotations.SerializedName;


 fanli/src/main/java/com/yeshi/fanli/entity/jd/JDOrderItem.java

@@ -3,8 +3,8 @@
import java.math.BigDecimal;
import java.util.Date;

import org.yeshi.utils.mybatis.Column;
import org.yeshi.utils.mybatis.Table;
import org.yeshi.utils.generater.mybatis.Column;
import org.yeshi.utils.generater.mybatis.Table;

@Table("yeshi_ec_jd_order_item")
public class JDOrderItem {

 fanli/src/main/java/com/yeshi/fanli/entity/money/AccountDetailHongBaoMap.java

@@ -2,8 +2,8 @@

import java.util.Date;

import org.yeshi.utils.mybatis.Column;
import org.yeshi.utils.mybatis.Table;
import org.yeshi.utils.generater.mybatis.Column;
import org.yeshi.utils.generater.mybatis.Table;

import com.yeshi.fanli.dto.HongBao;


 fanli/src/main/java/com/yeshi/fanli/entity/money/ExtractCheckCompensate.java

@@ -3,8 +3,8 @@
import java.math.BigDecimal;
import java.util.Date;

import org.yeshi.utils.mybatis.Column;
import org.yeshi.utils.mybatis.Table;
import org.yeshi.utils.generater.mybatis.Column;
import org.yeshi.utils.generater.mybatis.Table;

import com.yeshi.fanli.entity.bus.user.UserInfo;


 fanli/src/main/java/com/yeshi/fanli/entity/money/OrderTeamRewardDebt.java

@@ -3,8 +3,8 @@
import java.math.BigDecimal;
import java.util.Date;

import org.yeshi.utils.mybatis.Column;
import org.yeshi.utils.mybatis.Table;
import org.yeshi.utils.generater.mybatis.Column;
import org.yeshi.utils.generater.mybatis.Table;

/**
 * 团队订单奖励欠账

 fanli/src/main/java/com/yeshi/fanli/entity/money/OrderTeamRewardDebtRepayHistory.java

@@ -3,8 +3,8 @@
import java.math.BigDecimal;
import java.util.Date;

import org.yeshi.utils.mybatis.Column;
import org.yeshi.utils.mybatis.Table;
import org.yeshi.utils.generater.mybatis.Column;
import org.yeshi.utils.generater.mybatis.Table;

/**
 * 团队奖励欠账返款记录

 fanli/src/main/java/com/yeshi/fanli/entity/money/TeamEincomeRecord.java

@@ -3,8 +3,8 @@
import java.math.BigDecimal;
import java.util.Date;

import org.yeshi.utils.mybatis.Column;
import org.yeshi.utils.mybatis.Table;
import org.yeshi.utils.generater.mybatis.Column;
import org.yeshi.utils.generater.mybatis.Table;

/**
 * 团队收益记录表

 fanli/src/main/java/com/yeshi/fanli/entity/money/TeamRewardDebt.java

@@ -3,8 +3,8 @@
import java.math.BigDecimal;
import java.util.Date;

import org.yeshi.utils.mybatis.Column;
import org.yeshi.utils.mybatis.Table;
import org.yeshi.utils.generater.mybatis.Column;
import org.yeshi.utils.generater.mybatis.Table;

/**
 * 团队奖金欠账

 fanli/src/main/java/com/yeshi/fanli/entity/money/TeamRewardDebtRepayHistory.java

@@ -3,8 +3,8 @@
import java.math.BigDecimal;
import java.util.Date;

import org.yeshi.utils.mybatis.Column;
import org.yeshi.utils.mybatis.Table;
import org.yeshi.utils.generater.mybatis.Column;
import org.yeshi.utils.generater.mybatis.Table;

/**
 * 订单补贴欠账还款记录

 fanli/src/main/java/com/yeshi/fanli/entity/money/UserBalance.java

@@ -3,8 +3,8 @@
import java.math.BigDecimal;
import java.util.Date;

import org.yeshi.utils.mybatis.Column;
import org.yeshi.utils.mybatis.Table;
import org.yeshi.utils.generater.mybatis.Column;
import org.yeshi.utils.generater.mybatis.Table;

/**
 * 用户余额

 fanli/src/main/java/com/yeshi/fanli/entity/money/UserMoneyDebt.java

@@ -3,8 +3,8 @@
import java.math.BigDecimal;
import java.util.Date;

import org.yeshi.utils.mybatis.Column;
import org.yeshi.utils.mybatis.Table;
import org.yeshi.utils.generater.mybatis.Column;
import org.yeshi.utils.generater.mybatis.Table;

/**
 * 用户欠款

 fanli/src/main/java/com/yeshi/fanli/entity/money/UserMoneyDebtReturnHistory.java

@@ -3,8 +3,8 @@
import java.math.BigDecimal;
import java.util.Date;

import org.yeshi.utils.mybatis.Column;
import org.yeshi.utils.mybatis.Table;
import org.yeshi.utils.generater.mybatis.Column;
import org.yeshi.utils.generater.mybatis.Table;

/**
 * 用户欠款偿还记录

 fanli/src/main/java/com/yeshi/fanli/entity/money/UserMoneyDetail.java

@@ -3,8 +3,8 @@
import java.math.BigDecimal;
import java.util.Date;

import org.yeshi.utils.mybatis.Column;
import org.yeshi.utils.mybatis.Table;
import org.yeshi.utils.generater.mybatis.Column;
import org.yeshi.utils.generater.mybatis.Table;

import com.google.gson.annotations.Expose;
import com.yeshi.fanli.entity.bus.user.UserInfo;

 fanli/src/main/java/com/yeshi/fanli/entity/monitor/ClientAPIMonitor.java

@@ -2,8 +2,8 @@

import java.util.Date;

import org.yeshi.utils.mybatis.Column;
import org.yeshi.utils.mybatis.Table;
import org.yeshi.utils.generater.mybatis.Column;
import org.yeshi.utils.generater.mybatis.Table;

@Table("yeshi_ec_monitor_client_api")
public class ClientAPIMonitor {

 fanli/src/main/java/com/yeshi/fanli/entity/mq/MQUnSendInfo.java

@@ -2,8 +2,8 @@

import java.util.Date;

import org.yeshi.utils.mybatis.Column;
import org.yeshi.utils.mybatis.Table;
import org.yeshi.utils.generater.mybatis.Column;
import org.yeshi.utils.generater.mybatis.Table;

/**
 * 消息发送失败的缓存表

 fanli/src/main/java/com/yeshi/fanli/entity/order/CommonOrder.java

@@ -3,8 +3,8 @@
import java.math.BigDecimal;
import java.util.Date;

import org.yeshi.utils.mybatis.Column;
import org.yeshi.utils.mybatis.Table;
import org.yeshi.utils.generater.mybatis.Column;
import org.yeshi.utils.generater.mybatis.Table;

import com.google.gson.annotations.Expose;
import com.yeshi.fanli.entity.bus.user.UserInfo;

 fanli/src/main/java/com/yeshi/fanli/entity/order/CommonOrderGoods.java

@@ -4,8 +4,8 @@
import java.math.BigDecimal;
import java.util.Date;

import org.yeshi.utils.mybatis.Column;
import org.yeshi.utils.mybatis.Table;
import org.yeshi.utils.generater.mybatis.Column;
import org.yeshi.utils.generater.mybatis.Table;

import com.google.gson.annotations.Expose;


 fanli/src/main/java/com/yeshi/fanli/entity/order/CommonOrderTradeIdMap.java

@@ -2,8 +2,8 @@

import java.util.Date;

import org.yeshi.utils.mybatis.Column;
import org.yeshi.utils.mybatis.Table;
import org.yeshi.utils.generater.mybatis.Column;
import org.yeshi.utils.generater.mybatis.Table;

@Table("yeshi_ec_common_order_tradeid_map")
public class CommonOrderTradeIdMap {

 fanli/src/main/java/com/yeshi/fanli/entity/order/HongBaoOrder.java

@@ -3,8 +3,8 @@
import java.io.Serializable;
import java.util.Date;

import org.yeshi.utils.mybatis.Column;
import org.yeshi.utils.mybatis.Table;
import org.yeshi.utils.generater.mybatis.Column;
import org.yeshi.utils.generater.mybatis.Table;

import com.yeshi.fanli.entity.bus.user.HongBaoV2;


 fanli/src/main/java/com/yeshi/fanli/entity/order/HongBaoV2SettleTemp.java

@@ -2,8 +2,8 @@

import java.util.Date;

import org.yeshi.utils.mybatis.Column;
import org.yeshi.utils.mybatis.Table;
import org.yeshi.utils.generater.mybatis.Column;
import org.yeshi.utils.generater.mybatis.Table;

@Table("yeshi_ec_hongbao_v2_settle_temp")
public class HongBaoV2SettleTemp {

 fanli/src/main/java/com/yeshi/fanli/entity/order/InviteOrderSubsidy.java

@@ -3,8 +3,8 @@
import java.math.BigDecimal;
import java.util.Date;

import org.yeshi.utils.mybatis.Column;
import org.yeshi.utils.mybatis.Table;
import org.yeshi.utils.generater.mybatis.Column;
import org.yeshi.utils.generater.mybatis.Table;

/**
 * 邀请订单补贴

 fanli/src/main/java/com/yeshi/fanli/entity/order/OrderHongBaoMap.java

@@ -2,8 +2,8 @@

import java.util.Date;

import org.yeshi.utils.mybatis.Column;
import org.yeshi.utils.mybatis.Table;
import org.yeshi.utils.generater.mybatis.Column;
import org.yeshi.utils.generater.mybatis.Table;

import com.yeshi.fanli.entity.bus.user.HongBaoV2;
import com.yeshi.fanli.entity.bus.user.Order;

 fanli/src/main/java/com/yeshi/fanli/entity/order/OrderRepairHistory.java

@@ -3,8 +3,8 @@
import java.math.BigDecimal;
import java.util.Date;

import org.yeshi.utils.mybatis.Column;
import org.yeshi.utils.mybatis.Table;
import org.yeshi.utils.generater.mybatis.Column;
import org.yeshi.utils.generater.mybatis.Table;

@Table("yeshi_ec_order_repair_history")
public class OrderRepairHistory {

 fanli/src/main/java/com/yeshi/fanli/entity/order/ShareGoodsActivityOrder.java

@@ -3,8 +3,8 @@
import java.math.BigDecimal;
import java.util.Date;

import org.yeshi.utils.mybatis.Column;
import org.yeshi.utils.mybatis.Table;
import org.yeshi.utils.generater.mybatis.Column;
import org.yeshi.utils.generater.mybatis.Table;

import com.yeshi.fanli.entity.bus.user.UserInfo;


 fanli/src/main/java/com/yeshi/fanli/entity/order/UserOrderWeiQuanRecord.java

@@ -3,8 +3,8 @@
import java.math.BigDecimal;
import java.util.Date;

import org.yeshi.utils.mybatis.Column;
import org.yeshi.utils.mybatis.Table;
import org.yeshi.utils.generater.mybatis.Column;
import org.yeshi.utils.generater.mybatis.Table;

/**
 * 用户订单维权记录（包含返利,分享,邀请）

 fanli/src/main/java/com/yeshi/fanli/entity/order/dividents/TeamDividentsDebt.java

@@ -3,8 +3,8 @@
import java.math.BigDecimal;
import java.util.Date;

import org.yeshi.utils.mybatis.Column;
import org.yeshi.utils.mybatis.Table;
import org.yeshi.utils.generater.mybatis.Column;
import org.yeshi.utils.generater.mybatis.Table;

@Table("yeshi_ec_order_team_dividents_debt")
public class TeamDividentsDebt {

 fanli/src/main/java/com/yeshi/fanli/entity/order/dividents/TeamDividentsDebtRepayHistory.java

@@ -3,8 +3,8 @@
import java.math.BigDecimal;
import java.util.Date;

import org.yeshi.utils.mybatis.Column;
import org.yeshi.utils.mybatis.Table;
import org.yeshi.utils.generater.mybatis.Column;
import org.yeshi.utils.generater.mybatis.Table;

@Table("yeshi_ec_order_team_dividents_debt_repay_history")
public class TeamDividentsDebtRepayHistory {

 fanli/src/main/java/com/yeshi/fanli/entity/order/dividents/TeamDividentsRecord.java

@@ -3,8 +3,8 @@
import java.math.BigDecimal;
import java.util.Date;

import org.yeshi.utils.mybatis.Column;
import org.yeshi.utils.mybatis.Table;
import org.yeshi.utils.generater.mybatis.Column;
import org.yeshi.utils.generater.mybatis.Table;

/**
 * 分红记录

 fanli/src/main/java/com/yeshi/fanli/entity/order/dividents/TeamDividentsSourceOrder.java

@@ -3,8 +3,8 @@
import java.math.BigDecimal;
import java.util.Date;

import org.yeshi.utils.mybatis.Column;
import org.yeshi.utils.mybatis.Table;
import org.yeshi.utils.generater.mybatis.Column;
import org.yeshi.utils.generater.mybatis.Table;

/**
 * 分红源订单

 fanli/src/main/java/com/yeshi/fanli/entity/order/dividents/TeamDividentsSourceOrderUserMap.java

@@ -3,8 +3,8 @@
import java.math.BigDecimal;
import java.util.Date;

import org.yeshi.utils.mybatis.Column;
import org.yeshi.utils.mybatis.Table;
import org.yeshi.utils.generater.mybatis.Column;
import org.yeshi.utils.generater.mybatis.Table;

/**
 * 分红源订单对应用户ID

 fanli/src/main/java/com/yeshi/fanli/entity/order/dividents/TeamDividentsSourceUser.java

@@ -3,8 +3,8 @@
import java.math.BigDecimal;
import java.util.Date;

import org.yeshi.utils.mybatis.Column;
import org.yeshi.utils.mybatis.Table;
import org.yeshi.utils.generater.mybatis.Column;
import org.yeshi.utils.generater.mybatis.Table;

/**
 *分红源用户 

 fanli/src/main/java/com/yeshi/fanli/entity/pdd/PDDOrder.java

@@ -2,8 +2,8 @@

import java.util.Date;

import org.yeshi.utils.mybatis.Column;
import org.yeshi.utils.mybatis.Table;
import org.yeshi.utils.generater.mybatis.Column;
import org.yeshi.utils.generater.mybatis.Table;

import com.google.gson.annotations.SerializedName;


 fanli/src/main/java/com/yeshi/fanli/entity/push/DeviceActive.java

@@ -2,8 +2,8 @@

import java.util.Date;

import org.yeshi.utils.mybatis.Column;
import org.yeshi.utils.mybatis.Table;
import org.yeshi.utils.generater.mybatis.Column;
import org.yeshi.utils.generater.mybatis.Table;

@Table("yeshi_ec_device_active")
public class DeviceActive {

 fanli/src/main/java/com/yeshi/fanli/entity/push/DeviceTokenHW.java

@@ -3,8 +3,8 @@
import java.util.Date;

import com.yeshi.fanli.entity.bus.user.UserInfo;
import org.yeshi.utils.mybatis.Column;
import org.yeshi.utils.mybatis.Table;
import org.yeshi.utils.generater.mybatis.Column;
import org.yeshi.utils.generater.mybatis.Table;

/**
 * 华为deviceToken

 fanli/src/main/java/com/yeshi/fanli/entity/push/DeviceTokenIOS.java

@@ -2,8 +2,8 @@

import java.util.Date;

import org.yeshi.utils.mybatis.Column;
import org.yeshi.utils.mybatis.Table;
import org.yeshi.utils.generater.mybatis.Column;
import org.yeshi.utils.generater.mybatis.Table;

@Table("yeshi_ec_uid_devicetoken_ios")
public class DeviceTokenIOS {

 fanli/src/main/java/com/yeshi/fanli/entity/push/DeviceTokenOPPO.java

@@ -2,8 +2,8 @@

import java.util.Date;

import org.yeshi.utils.mybatis.Column;
import org.yeshi.utils.mybatis.Table;
import org.yeshi.utils.generater.mybatis.Column;
import org.yeshi.utils.generater.mybatis.Table;

/**
 * oppo推送

 fanli/src/main/java/com/yeshi/fanli/entity/push/DeviceTokenVIVO.java

@@ -2,8 +2,8 @@

import java.util.Date;

import org.yeshi.utils.mybatis.Column;
import org.yeshi.utils.mybatis.Table;
import org.yeshi.utils.generater.mybatis.Column;
import org.yeshi.utils.generater.mybatis.Table;

/**
 * oppo推送

 fanli/src/main/java/com/yeshi/fanli/entity/push/PushCoupon.java

@@ -5,8 +5,8 @@

import com.yeshi.fanli.entity.SystemEnum;
import org.springframework.format.annotation.DateTimeFormat;
import org.yeshi.utils.mybatis.Column;
import org.yeshi.utils.mybatis.Table;
import org.yeshi.utils.generater.mybatis.Column;
import org.yeshi.utils.generater.mybatis.Table;

@Table("yeshi_ec_push_coupon")
public class PushCoupon {

 fanli/src/main/java/com/yeshi/fanli/entity/push/PushCouponRecord.java

@@ -2,8 +2,8 @@

import java.util.Date;

import org.yeshi.utils.mybatis.Column;
import org.yeshi.utils.mybatis.Table;
import org.yeshi.utils.generater.mybatis.Column;
import org.yeshi.utils.generater.mybatis.Table;

@Table("yeshi_ec_push_coupon_record")
public class PushCouponRecord {

 fanli/src/main/java/com/yeshi/fanli/entity/push/PushGoods.java

@@ -4,8 +4,8 @@
import java.util.List;

import com.yeshi.fanli.entity.SystemEnum;
import org.yeshi.utils.mybatis.Column;
import org.yeshi.utils.mybatis.Table;
import org.yeshi.utils.generater.mybatis.Column;
import org.yeshi.utils.generater.mybatis.Table;

@Table("yeshi_ec_push_goods")
public class PushGoods {

 fanli/src/main/java/com/yeshi/fanli/entity/push/PushGoodsGroup.java

@@ -1,7 +1,7 @@
package com.yeshi.fanli.entity.push;

import org.yeshi.utils.mybatis.Column;
import org.yeshi.utils.mybatis.Table;
import org.yeshi.utils.generater.mybatis.Column;
import org.yeshi.utils.generater.mybatis.Table;

import com.yeshi.fanli.entity.goods.CommonGoods;


 fanli/src/main/java/com/yeshi/fanli/entity/push/PushGoodsRecord.java

@@ -2,8 +2,8 @@

import java.util.Date;

import org.yeshi.utils.mybatis.Column;
import org.yeshi.utils.mybatis.Table;
import org.yeshi.utils.generater.mybatis.Column;
import org.yeshi.utils.generater.mybatis.Table;

/**
 * 推送商品记录

 fanli/src/main/java/com/yeshi/fanli/entity/push/PushInfo.java

@@ -4,8 +4,8 @@
import java.util.List;

import com.yeshi.fanli.entity.SystemEnum;
import org.yeshi.utils.mybatis.Column;
import org.yeshi.utils.mybatis.Table;
import org.yeshi.utils.generater.mybatis.Column;
import org.yeshi.utils.generater.mybatis.Table;

@Table("yeshi_ec_push_info")
public class PushInfo {

 fanli/src/main/java/com/yeshi/fanli/entity/push/PushQueueRecord.java

@@ -5,53 +5,53 @@
import java.util.Date;


@org.yeshi.utils.mybatis.Table("yeshi_ec_push_queue")
@org.yeshi.utils.generater.mybatis.Table("yeshi_ec_push_queue")
public class PushQueueRecord {
    @org.yeshi.utils.mybatis.Column(name = "qe_id")
    @org.yeshi.utils.generater.mybatis.Column(name = "qe_id")
    private Long id;
    
    /* 1.IOS 2.华为 3.小米  */
    @org.yeshi.utils.mybatis.Column(name = "qe_type")
    @org.yeshi.utils.generater.mybatis.Column(name = "qe_type")
    private Integer type; 
    
    /* 推送内容 */
    @org.yeshi.utils.mybatis.Column(name = "qe_content")
    @org.yeshi.utils.generater.mybatis.Column(name = "qe_content")
    private String jsonContent;
    
    /* 游标起始位置 */
    @org.yeshi.utils.mybatis.Column(name = "qe_start_cursor")
    @org.yeshi.utils.generater.mybatis.Column(name = "qe_start_cursor")
    private Long startCursor;
    
    /* 游标结束位置 */
    @org.yeshi.utils.mybatis.Column(name = "qe_end_cursor")
    @org.yeshi.utils.generater.mybatis.Column(name = "qe_end_cursor")
    private Long endCursor;
    
    /* 游标执行记录位置 */
    @org.yeshi.utils.mybatis.Column(name = "qe_record_cursor")
    @org.yeshi.utils.generater.mybatis.Column(name = "qe_record_cursor")
    private Long recordCursor;
    
    /* 游标偏移位置 （每次推送总条数） */
    @org.yeshi.utils.mybatis.Column(name = "qe_push_num")
    @org.yeshi.utils.generater.mybatis.Column(name = "qe_push_num")
    private Integer pushNum;
    
    /* 推送的版本号 */ 
    @org.yeshi.utils.mybatis.Column(name = "qe_versions")
    @org.yeshi.utils.generater.mybatis.Column(name = "qe_versions")
    private String versions;
    
    /* 状态： 执行状态 ：0 未执行   1执行完成   2执行失败 */
    @org.yeshi.utils.mybatis.Column(name = "qe_state")
    @org.yeshi.utils.generater.mybatis.Column(name = "qe_state")
    private Integer state; 
    
    /* 创建时间 */
    @org.yeshi.utils.mybatis.Column(name = "qe_createtime")
    @org.yeshi.utils.generater.mybatis.Column(name = "qe_createtime")
    private Date createtime;
    
    /* 结束时间 */
    @org.yeshi.utils.mybatis.Column(name = "qe_endtime")
    @org.yeshi.utils.generater.mybatis.Column(name = "qe_endtime")
    private Date endtime;


    @org.yeshi.utils.mybatis.Column(name = "qe_system")
    @org.yeshi.utils.generater.mybatis.Column(name = "qe_system")
    private SystemEnum system;

    

 fanli/src/main/java/com/yeshi/fanli/entity/redpack/RedPackBalance.java

@@ -3,8 +3,8 @@
import java.math.BigDecimal;
import java.util.Date;

import org.yeshi.utils.mybatis.Column;
import org.yeshi.utils.mybatis.Table;
import org.yeshi.utils.generater.mybatis.Column;
import org.yeshi.utils.generater.mybatis.Table;

/**
 * 红包余额

 fanli/src/main/java/com/yeshi/fanli/entity/redpack/RedPackConfig.java

@@ -2,8 +2,8 @@

import java.util.Date;

import org.yeshi.utils.mybatis.Column;
import org.yeshi.utils.mybatis.Table;
import org.yeshi.utils.generater.mybatis.Column;
import org.yeshi.utils.generater.mybatis.Table;

/**
 * 红包配置信息

 fanli/src/main/java/com/yeshi/fanli/entity/redpack/RedPackDetail.java

@@ -3,8 +3,8 @@
import java.math.BigDecimal;
import java.util.Date;

import org.yeshi.utils.mybatis.Column;
import org.yeshi.utils.mybatis.Table;
import org.yeshi.utils.generater.mybatis.Column;
import org.yeshi.utils.generater.mybatis.Table;

import com.google.gson.annotations.Expose;


 fanli/src/main/java/com/yeshi/fanli/entity/redpack/RedPackExchange.java

@@ -3,8 +3,8 @@
import java.math.BigDecimal;
import java.util.Date;

import org.yeshi.utils.mybatis.Column;
import org.yeshi.utils.mybatis.Table;
import org.yeshi.utils.generater.mybatis.Column;
import org.yeshi.utils.generater.mybatis.Table;

/**
 * 红包转换现金

 fanli/src/main/java/com/yeshi/fanli/entity/redpack/RedPackForbid.java

@@ -2,8 +2,8 @@

import java.util.Date;

import org.yeshi.utils.mybatis.Column;
import org.yeshi.utils.mybatis.Table;
import org.yeshi.utils.generater.mybatis.Column;
import org.yeshi.utils.generater.mybatis.Table;

/**
 * 红包封禁

 fanli/src/main/java/com/yeshi/fanli/entity/redpack/RedPackForbidRecord.java

@@ -3,8 +3,8 @@
import java.math.BigDecimal;
import java.util.Date;

import org.yeshi.utils.mybatis.Column;
import org.yeshi.utils.mybatis.Table;
import org.yeshi.utils.generater.mybatis.Column;
import org.yeshi.utils.generater.mybatis.Table;

/**
 * 红包封禁记录

 fanli/src/main/java/com/yeshi/fanli/entity/redpack/RedPackGiveRecord.java

@@ -3,8 +3,8 @@
import java.math.BigDecimal;
import java.util.Date;

import org.yeshi.utils.mybatis.Column;
import org.yeshi.utils.mybatis.Table;
import org.yeshi.utils.generater.mybatis.Column;
import org.yeshi.utils.generater.mybatis.Table;

import com.google.gson.annotations.Expose;


 fanli/src/main/java/com/yeshi/fanli/entity/redpack/RedPackWinInvite.java

@@ -3,8 +3,8 @@
import java.math.BigDecimal;
import java.util.Date;

import org.yeshi.utils.mybatis.Column;
import org.yeshi.utils.mybatis.Table;
import org.yeshi.utils.generater.mybatis.Column;
import org.yeshi.utils.generater.mybatis.Table;

import com.yeshi.fanli.entity.bus.user.UserInfo;


 fanli/src/main/java/com/yeshi/fanli/entity/shop/BanLiShopGoods.java

@@ -3,8 +3,8 @@
import java.util.Date;
import java.util.List;

import org.yeshi.utils.mybatis.Column;
import org.yeshi.utils.mybatis.Table;
import org.yeshi.utils.generater.mybatis.Column;
import org.yeshi.utils.generater.mybatis.Table;

/**
 * 板栗商城商品

 fanli/src/main/java/com/yeshi/fanli/entity/shop/BanLiShopGoodsClass.java

@@ -2,8 +2,8 @@

import java.util.Date;

import org.yeshi.utils.mybatis.Column;
import org.yeshi.utils.mybatis.Table;
import org.yeshi.utils.generater.mybatis.Column;
import org.yeshi.utils.generater.mybatis.Table;

/**
 * 商品分类

 fanli/src/main/java/com/yeshi/fanli/entity/shop/BanLiShopGoodsImg.java

@@ -2,8 +2,8 @@

import java.util.Date;

import org.yeshi.utils.mybatis.Column;
import org.yeshi.utils.mybatis.Table;
import org.yeshi.utils.generater.mybatis.Column;
import org.yeshi.utils.generater.mybatis.Table;

@Table("yeshi_ec_shop_goods_imgs")
public class BanLiShopGoodsImg {

 fanli/src/main/java/com/yeshi/fanli/entity/shop/BanLiShopGoodsSets.java

@@ -4,8 +4,8 @@
import java.util.Date;
import java.util.List;

import org.yeshi.utils.mybatis.Column;
import org.yeshi.utils.mybatis.Table;
import org.yeshi.utils.generater.mybatis.Column;
import org.yeshi.utils.generater.mybatis.Table;

/**
 * 商品套餐

 fanli/src/main/java/com/yeshi/fanli/entity/shop/BanLiShopGoodsSetsPay.java

@@ -3,8 +3,8 @@
import java.math.BigDecimal;
import java.util.Date;

import org.yeshi.utils.mybatis.Column;
import org.yeshi.utils.mybatis.Table;
import org.yeshi.utils.generater.mybatis.Column;
import org.yeshi.utils.generater.mybatis.Table;

/**
 * 套餐支付方式配置

 fanli/src/main/java/com/yeshi/fanli/entity/shop/BanLiShopOrder.java

@@ -3,8 +3,8 @@
import java.math.BigDecimal;
import java.util.Date;

import org.yeshi.utils.mybatis.Column;
import org.yeshi.utils.mybatis.Table;
import org.yeshi.utils.generater.mybatis.Column;
import org.yeshi.utils.generater.mybatis.Table;

/**
 * 订单

 fanli/src/main/java/com/yeshi/fanli/entity/shop/BanLiShopOrderGoods.java

@@ -3,8 +3,8 @@
import java.math.BigDecimal;
import java.util.Date;

import org.yeshi.utils.mybatis.Column;
import org.yeshi.utils.mybatis.Table;
import org.yeshi.utils.generater.mybatis.Column;
import org.yeshi.utils.generater.mybatis.Table;

/**
 * 订单

 fanli/src/main/java/com/yeshi/fanli/entity/suning/SuningOrderInfo.java

@@ -2,8 +2,8 @@

import java.util.Date;

import org.yeshi.utils.mybatis.Column;
import org.yeshi.utils.mybatis.Table;
import org.yeshi.utils.generater.mybatis.Column;
import org.yeshi.utils.generater.mybatis.Table;

@Table("yeshi_ec_suning_order")
public class SuningOrderInfo {

 fanli/src/main/java/com/yeshi/fanli/entity/system/BusinessSystem.java

@@ -10,38 +10,38 @@
 *
 * @author Administrator
 */
@org.yeshi.utils.mybatis.Table("yeshi_ec_system")
@org.yeshi.utils.generater.mybatis.Table("yeshi_ec_system")
public class BusinessSystem implements Serializable {
    private static final long serialVersionUID = 2735576110255715412L;

    @org.yeshi.utils.mybatis.Column(name = "id")
    @org.yeshi.utils.generater.mybatis.Column(name = "id")
    private Long id;

    @org.yeshi.utils.mybatis.Column(name = "name")
    @org.yeshi.utils.generater.mybatis.Column(name = "name")
    private String name;

    @org.yeshi.utils.mybatis.Column(name = "platform")
    @org.yeshi.utils.generater.mybatis.Column(name = "platform")
    private Integer platform;// 1-Android 2-IOS 3-web

    @org.yeshi.utils.mybatis.Column(name = "createtime")
    @org.yeshi.utils.generater.mybatis.Column(name = "createtime")
    private Long createtime;

    @org.yeshi.utils.mybatis.Column(name = "beizhu")
    @org.yeshi.utils.generater.mybatis.Column(name = "beizhu")
    private String beizhu;

    @org.yeshi.utils.mybatis.Column(name = "package_name")
    @org.yeshi.utils.generater.mybatis.Column(name = "package_name")
    private String packageName;// Android包名或IOS bundleid

    @org.yeshi.utils.mybatis.Column(name = "appid")
    @org.yeshi.utils.generater.mybatis.Column(name = "appid")
    private String appid;

    @org.yeshi.utils.mybatis.Column(name = "system")
    @org.yeshi.utils.generater.mybatis.Column(name = "system")
    private SystemEnum system;//系统

    @org.yeshi.utils.mybatis.Column(name = "wx_app_id")
    @org.yeshi.utils.generater.mybatis.Column(name = "wx_app_id")
    private String wxAppId;

    @org.yeshi.utils.mybatis.Column(name = "wx_app_secret")
    @org.yeshi.utils.generater.mybatis.Column(name = "wx_app_secret")
    private String wxAppSecret;

    public String getWxAppId() {

 fanli/src/main/java/com/yeshi/fanli/entity/system/CustomerContent.java

@@ -2,8 +2,8 @@

import java.util.Date;

import org.yeshi.utils.mybatis.Column;
import org.yeshi.utils.mybatis.Table;
import org.yeshi.utils.generater.mybatis.Column;
import org.yeshi.utils.generater.mybatis.Table;

import com.google.gson.annotations.Expose;


 fanli/src/main/java/com/yeshi/fanli/entity/system/CustomerName.java

@@ -3,8 +3,8 @@
import java.util.Date;
import java.util.List;

import org.yeshi.utils.mybatis.Column;
import org.yeshi.utils.mybatis.Table;
import org.yeshi.utils.generater.mybatis.Column;
import org.yeshi.utils.generater.mybatis.Table;

import com.google.gson.annotations.Expose;


 fanli/src/main/java/com/yeshi/fanli/entity/system/SystemClientParams.java

@@ -3,8 +3,8 @@
import java.io.Serializable;

import com.yeshi.fanli.entity.SystemEnum;
import org.yeshi.utils.mybatis.Column;
import org.yeshi.utils.mybatis.Table;
import org.yeshi.utils.generater.mybatis.Column;
import org.yeshi.utils.generater.mybatis.Table;

import com.google.gson.annotations.Expose;


 fanli/src/main/java/com/yeshi/fanli/entity/system/SystemConfig.java

@@ -4,8 +4,8 @@
import java.util.Set;

import com.yeshi.fanli.entity.SystemEnum;
import org.yeshi.utils.mybatis.Column;
import org.yeshi.utils.mybatis.Table;
import org.yeshi.utils.generater.mybatis.Column;
import org.yeshi.utils.generater.mybatis.Table;

/**
 * 系统配置参数

 fanli/src/main/java/com/yeshi/fanli/entity/system/SystemCoupon.java

@@ -4,8 +4,8 @@
import java.math.BigDecimal;
import java.util.Date;

import org.yeshi.utils.mybatis.Column;
import org.yeshi.utils.mybatis.Table;
import org.yeshi.utils.generater.mybatis.Column;
import org.yeshi.utils.generater.mybatis.Table;

/**
 * 本地自定义券信息

 fanli/src/main/java/com/yeshi/fanli/entity/system/SystemZnx.java

@@ -1,7 +1,7 @@
package com.yeshi.fanli.entity.system;

import org.yeshi.utils.mybatis.Column;
import org.yeshi.utils.mybatis.Table;
import org.yeshi.utils.generater.mybatis.Column;
import org.yeshi.utils.generater.mybatis.Table;


@Table("yeshi_ec_system_msg")

 fanli/src/main/java/com/yeshi/fanli/entity/taobao/PidUser.java

@@ -1,7 +1,7 @@
package com.yeshi.fanli.entity.taobao;

import org.yeshi.utils.mybatis.Column;
import org.yeshi.utils.mybatis.Table;
import org.yeshi.utils.generater.mybatis.Column;
import org.yeshi.utils.generater.mybatis.Table;

@Table("yeshi_ec_pid_user")
public class PidUser {

 fanli/src/main/java/com/yeshi/fanli/entity/taobao/TBPid.java

@@ -1,8 +1,8 @@
package com.yeshi.fanli.entity.taobao;

import org.yeshi.utils.mybatis.Column;
import org.yeshi.utils.generater.mybatis.Column;

@org.yeshi.utils.mybatis.Table("yeshi_ec_pid")
@org.yeshi.utils.generater.mybatis.Table("yeshi_ec_pid")
public class TBPid {
    @Column(name = "id")
    private Long id;

 fanli/src/main/java/com/yeshi/fanli/entity/taobao/TaoBaoBuyRelationMap.java

@@ -2,8 +2,8 @@

import java.util.Date;

import org.yeshi.utils.mybatis.Column;
import org.yeshi.utils.mybatis.Table;
import org.yeshi.utils.generater.mybatis.Column;
import org.yeshi.utils.generater.mybatis.Table;

@Table("yeshi_ec_taobao_buy_relation")
public class TaoBaoBuyRelationMap {

 fanli/src/main/java/com/yeshi/fanli/entity/taobao/TaoBaoCoupon.java

@@ -4,8 +4,8 @@


import org.springframework.data.annotation.Transient;
import org.yeshi.utils.mybatis.Column;
import org.yeshi.utils.mybatis.Table;
import org.yeshi.utils.generater.mybatis.Column;
import org.yeshi.utils.generater.mybatis.Table;

import com.google.gson.annotations.Expose;


 fanli/src/main/java/com/yeshi/fanli/entity/taobao/TaoBaoLink.java

@@ -1,8 +1,8 @@
package com.yeshi.fanli.entity.taobao;

import com.yeshi.goods.facade.entity.taobao.TaoBaoGoodsBrief;
import org.yeshi.utils.mybatis.Column;
import org.yeshi.utils.mybatis.Table;
import org.yeshi.utils.generater.mybatis.Column;
import org.yeshi.utils.generater.mybatis.Table;

import com.yeshi.fanli.entity.system.BusinessSystem;


 fanli/src/main/java/com/yeshi/fanli/entity/taobao/TaoBaoOrder.java

@@ -6,8 +6,8 @@


import org.springframework.data.annotation.Transient;
import org.yeshi.utils.mybatis.Column;
import org.yeshi.utils.mybatis.Table;
import org.yeshi.utils.generater.mybatis.Column;
import org.yeshi.utils.generater.mybatis.Table;

@Table("yeshi_ec_taobao_order")
public class TaoBaoOrder implements Serializable {

 fanli/src/main/java/com/yeshi/fanli/entity/taobao/TaoBaoOrderGoods.java

@@ -2,8 +2,8 @@

import java.util.Date;

import org.yeshi.utils.mybatis.Column;
import org.yeshi.utils.mybatis.Table;
import org.yeshi.utils.generater.mybatis.Column;
import org.yeshi.utils.generater.mybatis.Table;

/**
 * 淘宝订单商品信息补充表

 fanli/src/main/java/com/yeshi/fanli/entity/taobao/TaoBaoOrderTradeMap.java

@@ -2,8 +2,8 @@

import java.util.Date;

import org.yeshi.utils.mybatis.Column;
import org.yeshi.utils.mybatis.Table;
import org.yeshi.utils.generater.mybatis.Column;
import org.yeshi.utils.generater.mybatis.Table;

/**
 * 淘宝订单交易ID映射

 fanli/src/main/java/com/yeshi/fanli/entity/taobao/TaoBaoPunishOrder.java

@@ -2,8 +2,8 @@

import java.util.Date;

import org.yeshi.utils.mybatis.Column;
import org.yeshi.utils.mybatis.Table;
import org.yeshi.utils.generater.mybatis.Column;
import org.yeshi.utils.generater.mybatis.Table;

//淘宝处罚订单
@Table("yeshi_ec_taobao_punish_order")

 fanli/src/main/java/com/yeshi/fanli/entity/taobao/TaoBaoToken.java

@@ -2,8 +2,8 @@

import java.util.Date;

import org.yeshi.utils.mybatis.Column;
import org.yeshi.utils.mybatis.Table;
import org.yeshi.utils.generater.mybatis.Column;
import org.yeshi.utils.generater.mybatis.Table;

/**
 * 淘口令

 fanli/src/main/java/com/yeshi/fanli/entity/taobao/TaoBaoUnionAuthRecord.java

@@ -2,8 +2,8 @@

import java.util.Date;

import org.yeshi.utils.mybatis.Column;
import org.yeshi.utils.mybatis.Table;
import org.yeshi.utils.generater.mybatis.Column;
import org.yeshi.utils.generater.mybatis.Table;

import com.yeshi.fanli.entity.bus.user.UserInfo;


 fanli/src/main/java/com/yeshi/fanli/entity/taobao/TaoBaoUnionConfig.java

@@ -2,8 +2,8 @@

import java.io.Serializable;

import org.yeshi.utils.mybatis.Column;
import org.yeshi.utils.mybatis.Table;
import org.yeshi.utils.generater.mybatis.Column;
import org.yeshi.utils.generater.mybatis.Table;

/**
 * 淘宝联盟的参数配置

 fanli/src/main/java/com/yeshi/fanli/entity/taobao/TaoBaoWeiQuanDrawBack.java

@@ -4,8 +4,8 @@
import java.util.Date;

import com.yeshi.fanli.entity.bus.user.UserInfo;
import org.yeshi.utils.mybatis.Column;
import org.yeshi.utils.mybatis.Table;
import org.yeshi.utils.generater.mybatis.Column;
import org.yeshi.utils.generater.mybatis.Table;

/**
 * 淘宝维权订单退款

 fanli/src/main/java/com/yeshi/fanli/entity/taobao/TaoBaoWeiQuanOrder.java

@@ -1,8 +1,8 @@
package com.yeshi.fanli.entity.taobao;

import org.springframework.data.annotation.Transient;
import org.yeshi.utils.mybatis.Column;
import org.yeshi.utils.mybatis.Table;
import org.yeshi.utils.generater.mybatis.Column;
import org.yeshi.utils.generater.mybatis.Table;

import java.math.BigDecimal;
import java.util.Date;

 fanli/src/main/java/com/yeshi/fanli/entity/taobao/TaobaoMeterial.java

@@ -10,7 +10,7 @@
 *
 * @date 2018年8月24日
 */
@org.yeshi.utils.mybatis.Table("yeshi_ec_taobao_meterial")
@org.yeshi.utils.generater.mybatis.Table("yeshi_ec_taobao_meterial")
public class TaobaoMeterial implements Serializable{

    
@@ -19,23 +19,23 @@
     */
    private static final long serialVersionUID = 1L;

    @org.yeshi.utils.mybatis.Column(name = "tm_id")
    @org.yeshi.utils.generater.mybatis.Column(name = "tm_id")
    private Long id;

    @org.yeshi.utils.mybatis.Column(name = "tm_class_name")
    @org.yeshi.utils.generater.mybatis.Column(name = "tm_class_name")
    private String className;// 名称

    @org.yeshi.utils.mybatis.Column(name = "tm_super_name")
    @org.yeshi.utils.generater.mybatis.Column(name = "tm_super_name")
    private String superName; // 上级类目

    @org.yeshi.utils.mybatis.Column(name = "tm_material_id")
    @org.yeshi.utils.generater.mybatis.Column(name = "tm_material_id")
    private Integer materialId; // 通用物料id


    @org.yeshi.utils.mybatis.Column(name = "tm_createtime")
    @org.yeshi.utils.generater.mybatis.Column(name = "tm_createtime")
    private Date createtime; // 创建时间

    @org.yeshi.utils.mybatis.Column(name = "tm_updatetime")
    @org.yeshi.utils.generater.mybatis.Column(name = "tm_updatetime")
    private Date updatetime; // 更新时间（修改时间）

    public Long getId() {

 fanli/src/main/java/com/yeshi/fanli/entity/vipshop/VipShopAfterSaleDetailInfo.java

@@ -2,8 +2,8 @@

import java.util.Date;

import org.yeshi.utils.mybatis.Column;
import org.yeshi.utils.mybatis.Table;
import org.yeshi.utils.generater.mybatis.Column;
import org.yeshi.utils.generater.mybatis.Table;

/**
 * 唯品会订单售后信息

 fanli/src/main/java/com/yeshi/fanli/entity/vipshop/VipShopOrder.java

@@ -4,8 +4,8 @@
import java.util.Date;
import java.util.List;

import org.yeshi.utils.mybatis.Column;
import org.yeshi.utils.mybatis.Table;
import org.yeshi.utils.generater.mybatis.Column;
import org.yeshi.utils.generater.mybatis.Table;

/**
 * 唯品会订单

 fanli/src/main/java/com/yeshi/fanli/entity/vipshop/VipShopOrderDetail.java

@@ -4,8 +4,8 @@
import java.util.Date;
import java.util.List;

import org.yeshi.utils.mybatis.Column;
import org.yeshi.utils.mybatis.Table;
import org.yeshi.utils.generater.mybatis.Column;
import org.yeshi.utils.generater.mybatis.Table;

/**
 * 唯品会订单详情

 fanli/src/main/java/com/yeshi/fanli/entity/xcx/StrategyPicture.java

@@ -1,8 +1,8 @@
package com.yeshi.fanli.entity.xcx;

import com.google.gson.annotations.Expose;
import org.yeshi.utils.mybatis.Column;
import org.yeshi.utils.mybatis.Table;
import org.yeshi.utils.generater.mybatis.Column;
import org.yeshi.utils.generater.mybatis.Table;

@Table("ye_yeshi_strategy_picture")
public class StrategyPicture {

 fanli/src/main/java/com/yeshi/fanli/entity/xinge/PushRecord.java

@@ -1,7 +1,7 @@
package com.yeshi.fanli.entity.xinge;

import org.yeshi.utils.mybatis.Column;
import org.yeshi.utils.mybatis.Table;
import org.yeshi.utils.generater.mybatis.Column;
import org.yeshi.utils.generater.mybatis.Table;

@Table("yeshi_ec_push_record")
public class PushRecord {

 fanli/src/main/java/com/yeshi/fanli/lijin/entity/MsgLijinVIPDetail.java

@@ -2,8 +2,8 @@

import com.yeshi.fanli.entity.bus.user.UserInfo;
import org.springframework.data.annotation.Transient;
import org.yeshi.utils.mybatis.Column;
import org.yeshi.utils.mybatis.Table;
import org.yeshi.utils.generater.mybatis.Column;
import org.yeshi.utils.generater.mybatis.Table;

import java.io.Serializable;
import java.util.Date;

 fanli/src/main/java/com/yeshi/fanli/lijin/manager/GoodsLijinMnager.java

 fanli/src/main/java/com/yeshi/fanli/lijin/manager/UserLijinMnager.java

@@ -35,8 +35,8 @@
public class UserLijinMnager {

    //@Reference(version = "1.0", check = false, url = "dubbo://193.112.35.168:20904/com.ks.lijin.service.LijinCreateService")
    @Reference(version = "1.0", check = false, timeout = 30000)
    private LijinCreateService lijinCreateService;
//    @Reference(version = "1.0", check = false, timeout = 30000)
//    private LijinCreateService lijinCreateService;

    //@Reference(version = "1.0", check = false, url = "dubbo://193.112.35.168:20902/com.ks.vip.service.VipCenterService")
    @Reference(version = "1.0", check = false)

 fanli/src/main/java/com/yeshi/fanli/util/CMQManager.java

@@ -1,13 +1,5 @@
package com.yeshi.fanli.util;

import java.util.ArrayList;
import java.util.HashMap;
import java.util.List;
import java.util.Map;

import org.yeshi.utils.CMQUtil;

import com.alipay.api.response.AlipayFundTransToaccountTransferResponse;
import com.alipay.api.response.AlipayFundTransUniTransferResponse;
import com.google.gson.Gson;
import com.google.gson.GsonBuilder;
@@ -20,12 +12,20 @@
import com.yeshi.fanli.entity.common.AdminUser;
import com.yeshi.fanli.entity.push.PushQueueRecord;
import com.yeshi.fanli.entity.taobao.TaoBaoWeiQuanOrder;
import com.yeshi.fanli.util.mq.cmq.TDMQUtil;
import org.yeshi.utils.CMQUtil;

import java.util.ArrayList;
import java.util.HashMap;
import java.util.List;
import java.util.Map;

public class CMQManager {
    private static String secretId = "AKIDTlpgJhLjOozvd6QI2XnpfGbgV4NQJk25";
    private static String secretKey = "xhCSUHo55oHUQ6XicFcmfIgspX0EEzWo";
    private static CMQManager cmqManager;
    private static CMQUtil cmqUtil;
    private static TDMQUtil tdmqUtil;
    // 订单处理队列
    public static String QUEUENAME_ORDER = "fanli-orders";

@@ -86,20 +86,22 @@
        TEJIA_VIP += "-" + Constant.systemCommonConfig.getProjectName();

        cmqUtil = CMQUtil.getInstance(secretId, secretKey);
        TDMQUtil.getInstance().init(secretId, secretKey, Constant.TDMQ_PUBLIC);
        tdmqUtil = TDMQUtil.getInstance();
        // 最大消息为1M
        cmqUtil.createQueue(QUEUENAME_ORDER, 1024 * 1024);
        cmqUtil.createQueue(QUEUENAME_NEW_ORDER, 1024 * 1024);
        cmqUtil.createQueue(EXTRACT_RESULT);
        cmqUtil.createQueue(PUSH_IOS);
        cmqUtil.createQueue(FANLI_ORDER);
        cmqUtil.createQueue(FANLI_ORDER_NEW);
        tdmqUtil.createQueue(QUEUENAME_ORDER, 1024 * 1024);
        tdmqUtil.createQueue(QUEUENAME_NEW_ORDER, 1024 * 1024);
        tdmqUtil.createQueue(EXTRACT_RESULT);
        tdmqUtil.createQueue(PUSH_IOS);
        tdmqUtil.createQueue(FANLI_ORDER);
        tdmqUtil.createQueue(FANLI_ORDER_NEW);

        cmqUtil.createQueue(ORDER_WEIQUAN);
        cmqUtil.createQueue(GOODS_UPDATE);
        cmqUtil.createQueue(IMPORTANT_GOODS_UPDATE);
        tdmqUtil.createQueue(ORDER_WEIQUAN);
        tdmqUtil.createQueue(GOODS_UPDATE);
        tdmqUtil.createQueue(IMPORTANT_GOODS_UPDATE);

        cmqUtil.createQueue(FANLI_SHARE_ORDER);
        cmqUtil.createQueue(TEJIA_VIP);
        tdmqUtil.createQueue(FANLI_SHARE_ORDER);
        tdmqUtil.createQueue(TEJIA_VIP);
    }

    public static CMQManager getInstance() {
@@ -111,11 +113,11 @@
    /**
     * 发送订单消息
     *
     * @param orderMap
     * @param orderId
     */
    public void addTaoBaoOrderMsg(String orderId) {
        if (!StringUtil.isNullOrEmpty(orderId)) {
            cmqUtil.sendMsg(QUEUENAME_ORDER, orderId);
            tdmqUtil.sendMsg(QUEUENAME_ORDER, orderId);
        }
    }

@@ -126,14 +128,18 @@
     */
    public List<String> consumeTaoBaoOrderMsg(int count) {
        List<String> resultList = new ArrayList<>();
        List<Message> list = cmqUtil.recieveMsg(count, QUEUENAME_ORDER);
        List<Message> list = Constant.TDMQ_CONSUMER ? tdmqUtil.recieveMsg(count, QUEUENAME_ORDER) : cmqUtil.recieveMsg(count, QUEUENAME_ORDER);

        if (list != null)
            for (Message msg : list) {
                String result = msg.msgBody;
                resultList.add(result);
                // 删除消息
                if (Constant.TDMQ_CONSUMER) {
                    tdmqUtil.deleteMsg(QUEUENAME_ORDER, msg.receiptHandle);
                } else {
                cmqUtil.deleteMsg(QUEUENAME_ORDER, msg.receiptHandle);
                }
            }
        return resultList;
    }
@@ -144,17 +150,21 @@
     * @param receiptHandle
     */
    public void deleteTaoBaoOrderMsg(String receiptHandle) {
        if (Constant.TDMQ_CONSUMER) {
            tdmqUtil.deleteMsg(QUEUENAME_ORDER, receiptHandle);
        } else {
        cmqUtil.deleteMsg(QUEUENAME_ORDER, receiptHandle);
        }
    }

    /**
     * 发送订单消息（刚刚产生的订单）
     *
     * @param orderMap
     * @param orderId
     */
    public void addTaoBaoNewOrderMsg(String orderId) {
        if (!StringUtil.isNullOrEmpty(orderId)) {
            cmqUtil.sendMsg(QUEUENAME_NEW_ORDER, orderId);
            tdmqUtil.sendMsg(QUEUENAME_NEW_ORDER, orderId);
        }
    }

@@ -165,17 +175,22 @@
     */
    public List<String> consumeTaoBaoNewOrderMsg(int count) {
        List<String> resultList = new ArrayList<>();
        List<Message> list = cmqUtil.recieveMsg(count, QUEUENAME_NEW_ORDER);
        List<Message> list = Constant.TDMQ_CONSUMER ? tdmqUtil.recieveMsg(count, QUEUENAME_NEW_ORDER) : cmqUtil.recieveMsg(count, QUEUENAME_NEW_ORDER);

        if (list != null)
            for (Message msg : list) {
                String result = msg.msgBody;
                resultList.add(result);
                // 删除消息
                if (Constant.TDMQ_CONSUMER) {
                    tdmqUtil.deleteMsg(QUEUENAME_NEW_ORDER, msg.receiptHandle);
                } else {
                cmqUtil.deleteMsg(QUEUENAME_NEW_ORDER, msg.receiptHandle);
                }
            }
        return resultList;
    }


    /**
     * 删除淘宝订单消息（刚刚产生的订单）
@@ -183,7 +198,11 @@
     * @param receiptHandle
     */
    public void deleteTaoBaoNewOrderMsg(String receiptHandle) {
        if (Constant.TDMQ_CONSUMER) {
            tdmqUtil.deleteMsg(QUEUENAME_NEW_ORDER, receiptHandle);
        } else {
        cmqUtil.deleteMsg(QUEUENAME_NEW_ORDER, receiptHandle);
        }
    }

    /**
@@ -195,7 +214,7 @@
    public void addExtractResultMsg(Extract extract, AlipayFundTransUniTransferResponse response,
                                    AdminUser adminUser) {
        String content = new Gson().toJson(new AlipayTransferResultInfo(extract, response, adminUser));
        cmqUtil.sendMsg(EXTRACT_RESULT, content);
        tdmqUtil.sendMsg(EXTRACT_RESULT, content);
    }

    /**
@@ -205,7 +224,7 @@
     * @return
     */
    public Map<String, AlipayTransferResultInfo> consumeExtractResultMsg(int count) {
        List<Message> list = cmqUtil.recieveMsg(count, EXTRACT_RESULT);
        List<Message> list = Constant.TDMQ_CONSUMER ? tdmqUtil.recieveMsg(count, EXTRACT_RESULT) : cmqUtil.recieveMsg(count, EXTRACT_RESULT);
        Map<String, AlipayTransferResultInfo> map = new HashMap<>();

        if (list != null)
@@ -226,23 +245,27 @@
     * @param receiptHandle
     */
    public void deleteExtractResultMsg(String receiptHandle) {
        if (Constant.TDMQ_CONSUMER) {
            tdmqUtil.deleteMsg(EXTRACT_RESULT, receiptHandle);
        } else {
        cmqUtil.deleteMsg(EXTRACT_RESULT, receiptHandle);
        }
    }

    // 订单返利
    public void addFanLiMsg(HongBao hongBao) {
        String content = new Gson().toJson(hongBao);
        cmqUtil.sendMsg(FANLI_ORDER, content);
        tdmqUtil.sendMsg(FANLI_ORDER, content);
    }

    // 新版订单返利
    public void addFanLiMsgNew(HongBaoV2 hongBao) {
        String content = new Gson().toJson(hongBao);
        cmqUtil.sendMsg(FANLI_ORDER_NEW, content);
        tdmqUtil.sendMsg(FANLI_ORDER_NEW, content);
    }

    public Map<String, HongBao> consumeFanLiMsg(int count) {
        List<Message> list = cmqUtil.recieveMsg(count, FANLI_ORDER);
        List<Message> list = Constant.TDMQ_CONSUMER ? tdmqUtil.recieveMsg(count, FANLI_ORDER) : cmqUtil.recieveMsg(count, FANLI_ORDER);
        Map<String, HongBao> map = new HashMap<>();
        if (list != null)
            for (Message msg : list) {
@@ -256,7 +279,7 @@
    }

    public Map<String, HongBaoV2> consumeFanLiMsgNew(int count) {
        List<Message> list = cmqUtil.recieveMsg(count, FANLI_ORDER_NEW);
        List<Message> list = Constant.TDMQ_CONSUMER ? tdmqUtil.recieveMsg(count, FANLI_ORDER_NEW) : cmqUtil.recieveMsg(count, FANLI_ORDER_NEW);
        Map<String, HongBaoV2> map = new HashMap<>();
        if (list != null)
            for (Message msg : list) {
@@ -270,21 +293,29 @@
    }

    public void deleteFanLiMsg(String receiptHandle) {
        if (Constant.TDMQ_CONSUMER) {
            tdmqUtil.deleteMsg(FANLI_ORDER, receiptHandle);
        } else {
        cmqUtil.deleteMsg(FANLI_ORDER, receiptHandle);
        }
    }

    public void deleteFanLiMsgNew(String receiptHandle) {
        if (Constant.TDMQ_CONSUMER) {
            tdmqUtil.deleteMsg(FANLI_ORDER_NEW, receiptHandle);
        } else {
        cmqUtil.deleteMsg(FANLI_ORDER_NEW, receiptHandle);
        }
    }


    // 分享订单收益
    public void addFanLiShareMsg(UidDateDTO dto) {
        cmqUtil.sendMsg(FANLI_SHARE_ORDER, new Gson().toJson(dto));
        tdmqUtil.sendMsg(FANLI_SHARE_ORDER, new Gson().toJson(dto));
    }

    public Map<String, UidDateDTO> consumeFanLiShareMsg(int count) {
        List<Message> list = cmqUtil.recieveMsg(count, FANLI_SHARE_ORDER);
        List<Message> list = Constant.TDMQ_CONSUMER ? tdmqUtil.recieveMsg(count, FANLI_SHARE_ORDER) : cmqUtil.recieveMsg(count, FANLI_SHARE_ORDER);
        Map<String, UidDateDTO> map = new HashMap<>();
        if (list != null)
            for (Message msg : list) {
@@ -298,16 +329,20 @@
    }

    public void deleteFanLiShareMsg(String receiptHandle) {
        if (Constant.TDMQ_CONSUMER) {
            tdmqUtil.deleteMsg(FANLI_SHARE_ORDER, receiptHandle);
        } else {
        cmqUtil.deleteMsg(FANLI_SHARE_ORDER, receiptHandle);
        }
    }

    // 维权订单
    public void addWeiQuanOrderMsg(TaoBaoWeiQuanOrder order) {
        cmqUtil.sendMsg(ORDER_WEIQUAN, new Gson().toJson(order));
        tdmqUtil.sendMsg(ORDER_WEIQUAN, new Gson().toJson(order));
    }

    public Map<String, TaoBaoWeiQuanOrder> consumeWeiQuanOrderMsg(int count) {
        List<Message> list = cmqUtil.recieveMsg(count, ORDER_WEIQUAN);
        List<Message> list = Constant.TDMQ_CONSUMER ? tdmqUtil.recieveMsg(count, ORDER_WEIQUAN) : cmqUtil.recieveMsg(count, ORDER_WEIQUAN);
        Map<String, TaoBaoWeiQuanOrder> map = new HashMap<>();
        Gson gson = new Gson();
        if (list != null)
@@ -321,18 +356,22 @@
    }

    public void deleteWeiQuanOrderMsg(String receiptHandle) {
        if (Constant.TDMQ_CONSUMER) {
            tdmqUtil.deleteMsg(ORDER_WEIQUAN, receiptHandle);
        } else {
        cmqUtil.deleteMsg(ORDER_WEIQUAN, receiptHandle);
        }
    }

    /**
     * 添加IOS推送消息
     *
     * @param count
     * @param pushQueueRecord
     */
    public void addIOSPushMsg(PushQueueRecord pushQueueRecord) {

        String content = new GsonBuilder().create().toJson(pushQueueRecord);
        cmqUtil.sendMsg(PUSH_IOS, content);
        tdmqUtil.sendMsg(PUSH_IOS, content);
    }

    /**
@@ -341,7 +380,7 @@
     * @param count
     */
    public Map<String, PushQueueRecord> consumeIOSPushMsg(int count) {
        List<Message> list = cmqUtil.recieveMsg(count, PUSH_IOS);
        List<Message> list = Constant.TDMQ_CONSUMER ? tdmqUtil.recieveMsg(count, PUSH_IOS) : cmqUtil.recieveMsg(count, PUSH_IOS);
        if (list == null) {
            return null;
        }
@@ -366,16 +405,20 @@
     * @param receiptHandle
     */
    public void deleteIOSPushMsg(String receiptHandle) {
        if (Constant.TDMQ_CONSUMER) {
            tdmqUtil.deleteMsg(PUSH_IOS, receiptHandle);
        } else {
        cmqUtil.deleteMsg(PUSH_IOS, receiptHandle);
        }
    }

    /**
     * 添加需要更新的商品ID
     *
     * @param count
     * @param goodsId
     */
    public void addNeedUpdateTaoBaoGoodsId(Long goodsId) {
        cmqUtil.sendMsg(GOODS_UPDATE, goodsId + "");
        tdmqUtil.sendMsg(GOODS_UPDATE, goodsId + "");
    }

    /**
@@ -384,7 +427,7 @@
     * @param count
     */
    public Map<String, Long> consumeNeedUpdateTaoBaoGoodsIdMsg(int count) {
        List<Message> list = cmqUtil.recieveMsg(count, GOODS_UPDATE);
        List<Message> list = Constant.TDMQ_CONSUMER ? tdmqUtil.recieveMsg(count, GOODS_UPDATE) : cmqUtil.recieveMsg(count, GOODS_UPDATE);
        if (list == null) {
            return null;
        }
@@ -407,7 +450,11 @@
     * @param receiptHandle
     */
    public void deleteNeedUpdateTaoBaoGoodsIdMsg(String receiptHandle) {
        if (Constant.TDMQ_CONSUMER) {
            tdmqUtil.deleteMsg(GOODS_UPDATE, receiptHandle);
        } else {
        cmqUtil.deleteMsg(GOODS_UPDATE, receiptHandle);
        }
    }

    /**
@@ -416,7 +463,7 @@
     * @param actionId
     */
    public void addTBImpGoodsUpdate(Long actionId) {
        cmqUtil.sendMsg(IMPORTANT_GOODS_UPDATE, actionId + "");
        tdmqUtil.sendMsg(IMPORTANT_GOODS_UPDATE, actionId + "");
    }

    /**
@@ -426,7 +473,7 @@
     * @return
     */
    public Map<String, Long> consumeTBImpGoodsUpdateMsg(int count) {
        List<Message> list = cmqUtil.recieveMsg(count, IMPORTANT_GOODS_UPDATE);
        List<Message> list = Constant.TDMQ_CONSUMER ? tdmqUtil.recieveMsg(count, IMPORTANT_GOODS_UPDATE) : cmqUtil.recieveMsg(count, IMPORTANT_GOODS_UPDATE);
        if (list == null) {
            return null;
        }
@@ -447,7 +494,11 @@
     * @param receiptHandle
     */
    public void deleteTBImpGoodsUpdateMsg(String receiptHandle) {
        if (Constant.TDMQ_CONSUMER) {
            tdmqUtil.deleteMsg(IMPORTANT_GOODS_UPDATE, receiptHandle);
        } else {
        cmqUtil.deleteMsg(IMPORTANT_GOODS_UPDATE, receiptHandle);
    }
    }

}

 fanli/src/main/java/com/yeshi/fanli/util/Constant.java

@@ -30,6 +30,12 @@

    public static int PAGE_SIZE = 20;
    
    //是否为TDMQ消息消费
    public final static boolean TDMQ_CONSUMER = true;

    //TDMQ是否为公网
    public final static boolean TDMQ_PUBLIC = false;

    // 新的规则生效时间
    public static final long NEW_ORDER_FANLI_RULE_TIME = TimeUtil.convertToTimeTemp("2020-04-28 16:00:00", "yyyy-MM-dd HH:mm:ss");

@@ -64,7 +70,6 @@
    public static final String SESSION_EXTRACT_CODE = "ADMIN_EXTRACT_CODE"; // 提现码
    public static final String SESSION_EXTRACT_VERIFY_RESULT = "SESSION_EXTRACT_VERIFY_RESULT"; // 提现码验证结果
    public static final int DAYMS = 86400000;



    public static final String TAOBAO_AUTH_APPKEY = "24980167";
@@ -254,8 +259,6 @@
    
    
    public static final Long[] NO_UPGRADE_UIDS=new Long[]{1700696L};
	
	
    

    // 线程等待数量

 fanli/src/main/java/com/yeshi/fanli/util/mq/cmq/DouYinDeviceActiveCMQManager.java

@@ -23,8 +23,10 @@

    static {
        cmqUtil = CMQUtil.getInstance(secretId, secretKey);
        TDMQUtil.getInstance().init(secretId, secretKey, Constant.TDMQ_PUBLIC);

        DOUYIN_DEVICE_ACTIVE += "-" + Constant.systemCommonConfig.getProjectName();
        cmqUtil.createQueue(DOUYIN_DEVICE_ACTIVE);
        TDMQUtil.getInstance().createQueue(DOUYIN_DEVICE_ACTIVE);
    }

    public static DouYinDeviceActiveCMQManager getInstance() {
@@ -38,18 +40,18 @@
            return;
        DouYinDeviceActiveQueueDTO dto = new DouYinDeviceActiveQueueDTO(DouYinDeviceActiveQueueDTO.TYPE_DEVICE, device,
                platform);
        cmqUtil.sendMsg(DOUYIN_DEVICE_ACTIVE, new Gson().toJson(dto));
        TDMQUtil.getInstance().sendMsg(DOUYIN_DEVICE_ACTIVE, new Gson().toJson(dto));
    }

    public void addAdActive(String callback) {
        if (StringUtil.isNullOrEmpty(callback))
            return;
        DouYinDeviceActiveQueueDTO dto = new DouYinDeviceActiveQueueDTO(DouYinDeviceActiveQueueDTO.TYPE_AD, callback);
        cmqUtil.sendMsg(DOUYIN_DEVICE_ACTIVE, new Gson().toJson(dto));
        TDMQUtil.getInstance().sendMsg(DOUYIN_DEVICE_ACTIVE, new Gson().toJson(dto));
    }

    public Map<String, DouYinDeviceActiveQueueDTO> consume(int count) {
        List<Message> list = cmqUtil.recieveMsg(count, DOUYIN_DEVICE_ACTIVE);
        List<Message> list = Constant.TDMQ_CONSUMER ? TDMQUtil.getInstance().recieveMsg(count, DOUYIN_DEVICE_ACTIVE) : cmqUtil.recieveMsg(count, DOUYIN_DEVICE_ACTIVE);
        Map<String, DouYinDeviceActiveQueueDTO> map = new HashMap<>();
        if (list != null)
            for (Message msg : list) {
@@ -60,7 +62,11 @@
    }

    public void delete(String receiptHandle) {
        if (Constant.TDMQ_CONSUMER) {
            TDMQUtil.getInstance().deleteMsg(DOUYIN_DEVICE_ACTIVE, receiptHandle);
        } else {
        cmqUtil.deleteMsg(DOUYIN_DEVICE_ACTIVE, receiptHandle);
    }
    }

}

 fanli/src/main/java/com/yeshi/fanli/util/mq/cmq/HongBaoRecieveCMQManager.java

@@ -4,6 +4,7 @@
import java.util.List;
import java.util.Map;

import com.yeshi.fanli.util.Constant;
import org.yeshi.utils.CMQUtil;

import com.qcloud.cmq.Message;
@@ -24,8 +25,11 @@

    static {
        cmqUtil = CMQUtil.getInstance(secretId, secretKey);

        TDMQUtil.getInstance().init(secretId, secretKey, Constant.TDMQ_PUBLIC);

        // 创建主题，添加订阅
        cmqUtil.createTopic(TOPIC_NAME);
        TDMQUtil.getInstance().createTopic(TOPIC_NAME);
        // 用户券订阅
        String[] subscripts = new String[] { SUBSCRIBE_INTEGRAL };
        String[] queues = new String[] { QUEUE_INTEGRAL };
@@ -33,11 +37,11 @@
        for (int i = 0; i < subscripts.length; i++) {
            String queueName = queues[i];
            try {
                cmqUtil.createQueue(queueName);
                TDMQUtil.getInstance().createQueue(queueName);
            } catch (Exception e) {
            }
            try {
                cmqUtil.subscribeTopic(TOPIC_NAME, subscripts[i], queueName);
                TDMQUtil.getInstance().subscribeTopic(TOPIC_NAME, subscripts[i], queueName);
            } catch (Exception e) {

            }
@@ -58,7 +62,7 @@
    public void addHongBaoRecieveMsg(Long hongBaoId) {
        if (hongBaoId == null)
            return;
        cmqUtil.publishTopicMessage(TOPIC_NAME, hongBaoId + "");
        TDMQUtil.getInstance().publishTopicMessage(TOPIC_NAME, hongBaoId + "");
        LogHelper.test("红包消息投递成功");
    }

@@ -70,7 +74,7 @@
     * @return
     */
    public Map<String, Long> consumeQueueMsg(String queueName, int count) {
        List<Message> list = cmqUtil.recieveMsg(count, queueName);
        List<Message> list = Constant.TDMQ_CONSUMER ? TDMQUtil.getInstance().recieveMsg(count, queueName) : cmqUtil.recieveMsg(count, queueName);
        Map<String, Long> map = new HashMap<>();

        if (list != null)
@@ -82,7 +86,11 @@
    }

    public void deleteQueueMsg(String queueName, String receiptHandle) {
        if (Constant.TDMQ_CONSUMER) {
            TDMQUtil.getInstance().deleteMsg(queueName, receiptHandle);
        } else {
        cmqUtil.deleteMsg(queueName, receiptHandle);
    }
    }

}

 fanli/src/main/java/com/yeshi/fanli/util/mq/cmq/PushCMQManager.java

@@ -2,12 +2,8 @@

import com.google.gson.Gson;
import com.qcloud.cmq.Message;
import com.yeshi.fanli.dto.money.UserMoneyChangeDTO;
import com.yeshi.fanli.dto.push.PushContentDetailDTO;
import com.yeshi.fanli.log.LogHelper;
import com.yeshi.fanli.util.Constant;
import com.yeshi.fanli.util.StringUtil;
import com.yeshi.fanli.util.mq.cmq.order.JDOrderCMQManager;
import org.yeshi.utils.CMQUtil;

import java.util.HashMap;
@@ -25,8 +21,10 @@

    static {
        cmqUtil = CMQUtil.getInstance(secretId, secretKey);
        TDMQUtil.getInstance().init(secretId, secretKey, Constant.TDMQ_PUBLIC);

        PUSH_HW += "-" + Constant.systemCommonConfig.getProjectName();
        cmqUtil.createQueue(PUSH_HW);
        TDMQUtil.getInstance().createQueue(PUSH_HW);
    }

    public static PushCMQManager getInstance() {
@@ -42,7 +40,7 @@
        if (dto == null)
            return;
        String json = new Gson().toJson(dto);
        cmqUtil.sendMsg(PUSH_HW, json);
        TDMQUtil.getInstance().sendMsg(PUSH_HW, json);
    }

    /**
@@ -52,7 +50,7 @@
     * @return
     */
    public Map<String, PushContentDetailDTO> consumeHWPush(int count) {
        List<Message> list = cmqUtil.recieveMsg(count, PUSH_HW);
        List<Message> list = Constant.TDMQ_CONSUMER ? TDMQUtil.getInstance().recieveMsg(count, PUSH_HW) : cmqUtil.recieveMsg(count, PUSH_HW);
        Map<String, PushContentDetailDTO> map = new HashMap<>();
        if (list != null)
            for (Message msg : list) {
@@ -69,6 +67,10 @@
     * @param receiptHandle
     */
    public void deleteHWPush(String receiptHandle) {
        if (Constant.TDMQ_CONSUMER) {
            TDMQUtil.getInstance().deleteMsg(PUSH_HW, receiptHandle);
        } else {
        cmqUtil.deleteMsg(PUSH_HW, receiptHandle);
    }
}
}

 fanli/src/main/java/com/yeshi/fanli/util/mq/cmq/TDMQUtil.java

New file
@@ -0,0 +1,450 @@
package com.yeshi.fanli.util.mq.cmq;

import com.qcloud.cmq.Account;
import com.qcloud.cmq.Message;
import com.tencentcloudapi.common.Credential;
import com.tencentcloudapi.common.exception.TencentCloudSDKException;
import com.tencentcloudapi.common.profile.ClientProfile;
import com.tencentcloudapi.common.profile.HttpProfile;
import com.tencentcloudapi.tdmq.v20200217.TdmqClient;
import com.tencentcloudapi.tdmq.v20200217.models.*;

import java.util.Arrays;
import java.util.List;

//腾讯CMQ消息
public class TDMQUtil {

    private static TDMQUtil cmqUtil;

    public static TDMQUtil getInstance() {
        if (cmqUtil == null) {
            cmqUtil = new TDMQUtil();
        }
        return cmqUtil;
    }

    private String secretId = "";
    private String secretKey = "";
    private String region = "ap-guangzhou";
    // 内网 http://gz.mqadapter.cmq.tencentyun.com
    // 公网 https://cmq-gz.public.tencenttdmq.com
    private static String endpoint = "http://gz.mqadapter.cmq.tencentyun.com";
    // private static String endpoint =
    // "http://cmq-queue-gz.api.tencentyun.com";

    private Account account;

    /**
     * @return void
     * @author hxh
     * @description 初始化
     * @date 17:00 2022/3/21
     * @param: secretId
     * @param: secretKey
     * @param: region 区域，如: ap-guangzhou
     * @param: apiRegion 接口区域，如: gz
     * @param: isPub 是否为公网
     **/
    public void init(String secretId, String secretKey, String region, String apiRegion, boolean isPub) {
        this.secretId = secretId;
        this.secretKey = secretKey;
        this.region = region;
        String ep;
        if (isPub) {
            ep = String.format("https://cmq-%s.public.tencenttdmq.com", apiRegion);
        } else {
            ep = String.format("http://%s.mqadapter.cmq.tencentyun.com", apiRegion);
        }
        endpoint = ep;
        account = new Account(endpoint, this.secretId, this.secretKey);
    }


    public void init(String secretId, String secretKey, boolean isPub) {
        this.secretId = secretId;
        this.secretKey = secretKey;
        String ep;
        if (isPub) {
            ep = String.format("https://cmq-%s.public.tencenttdmq.com", "gz");
        } else {
            ep = String.format("http://%s.mqadapter.cmq.tencentyun.com", "gz");
        }
        endpoint = ep;
        account = new Account(endpoint, this.secretId, this.secretKey);
    }

    private TdmqClient getClient() {
        return getClient(this.region);
    }

    private TdmqClient getClient(String region) {
        Credential cred = new Credential(secretId, secretKey);
        // 实例化一个 http 选项，可选的，没有特殊需求可以跳过
        HttpProfile httpProfile = new HttpProfile();
        httpProfile.setEndpoint("tdmq.tencentcloudapi.com");
        // 实例化一个client选项，可选的，没有特殊需求可以跳过
        ClientProfile clientProfile = new ClientProfile();
        clientProfile.setHttpProfile(httpProfile);
        // 实例化要请求产品的 client 对象,clientProfile 是可选的
        TdmqClient client = new TdmqClient(cred, region, clientProfile);
        return client;
    }

    private TdmqClient getMsgClient() {
        return getClient(this.region);
    }


    public boolean existQueue(String queueName) {
        if (getQueue(queueName) != null) {
            return true;
        }
        return false;
    }


    // 创建队列
    public boolean createQueue(String queueName) {
        return this.createQueue(queueName, 10L, 5 * 60L, 65536L);
    }

    // 创建队列
    public boolean createQueue(String queueName, int maxMsgSize) {
        return this.createQueue(queueName, 10L, 5 * 60L, maxMsgSize);
    }

    /**
     * 指定参数创建队列
     *
     * @param queueName
     * @param pollingWaitSeconds -长轮训等待时间
     * @param visibilityTimeout  -消息消费后再次可见的时间
     * @return
     */
    public boolean createQueue(String queueName, long pollingWaitSeconds, long visibilityTimeout, long maxMsgSize) {

        if (existQueue(queueName)) {
            return true;
        }
        CreateCmqQueueRequest request = new CreateCmqQueueRequest();
        request.setQueueName(queueName);
        request.setPollingWaitSeconds(pollingWaitSeconds);
        request.setVisibilityTimeout(visibilityTimeout);
        request.setMaxMsgSize(maxMsgSize);
        request.setMsgRetentionSeconds(345600L);
        try {
            getClient().CreateCmqQueue(request);
            return true;
        } catch (TencentCloudSDKException e) {
            e.printStackTrace();
        }

        return false;


    }

    // 删除队列
    public boolean deleteQueue(String queueName) {
        DeleteCmqQueueRequest request = new DeleteCmqQueueRequest();
        request.setQueueName(queueName);
        try {
            getClient().DeleteCmqQueue(request);
            return true;
        } catch (TencentCloudSDKException e) {
            e.printStackTrace();
        }
        return false;
    }

    // 获取队列列表
    public List<CmqQueue> getQueueNameList(String key) {
        DescribeCmqQueuesRequest request = new DescribeCmqQueuesRequest();
        request.setOffset(0L);
        request.setLimit(1000L);
        try {
            DescribeCmqQueuesResponse response = getClient().DescribeCmqQueues(request);
            CmqQueue[] queues = response.getQueueList();
            return Arrays.asList(queues);
        } catch (TencentCloudSDKException e) {
            e.printStackTrace();
        }
        return null;
    }

    // 获取队列
    public CmqQueue getQueue(String queueName) {
        DescribeCmqQueueDetailRequest req = new DescribeCmqQueueDetailRequest();
        req.setQueueName(queueName);
        // 返回的 resp 是一个 CreateCmqQueueResponse 的实例，与请求对象对应
        try {
            DescribeCmqQueueDetailResponse resp = getClient().DescribeCmqQueueDetail(req);
            return resp.getQueueDescribe();
        } catch (TencentCloudSDKException e) {
        }
        return null;
    }


    // 发送消息
    public String sendMsg(String queueName, String msg, long delaySeconds) {
        SendCmqMsgRequest request = new SendCmqMsgRequest();
        request.setQueueName(queueName);
        request.setMsgContent(msg);
        request.setDelaySeconds(delaySeconds);
        try {
            SendCmqMsgResponse response = getMsgClient().SendCmqMsg(request);
            return response.getMsgId();
        } catch (TencentCloudSDKException e) {
            e.printStackTrace();
        }
        return null;
    }

    public String sendMsg(String queueName, String msg) {
        return this.sendMsg(queueName, msg, 0L);
    }


    // 消费消息
    public Message recieveMsg(String queueName) throws Exception {
        com.qcloud.cmq.Queue queue = account.getQueue(queueName);
        return queue.receiveMessage();
    }

    /**
     * 消费消息
     *
     * @param count     1-16
     * @param queueName 队列名字
     * @return
     */
    public List<Message> recieveMsg(int count, String queueName) {
        com.qcloud.cmq.Queue queue = account.getQueue(queueName);

        if (queue == null) {
            return null;
        }

        List<Message> msgList = null;
        try {
            msgList = queue.batchReceiveMessage(count);
            return msgList;
        } catch (Exception e) {
            if (e.getMessage() != null && !e.getMessage().contains("no message"))
                e.printStackTrace();
        }
        return null;
    }

    // 删除消息
    public boolean deleteMsg(String queueName, String receiptHandle) {
        try {
            com.qcloud.cmq.Queue queue = account.getQueue(queueName);
            queue.deleteMessage(receiptHandle);
            return true;
        } catch (Exception e) {
            e.printStackTrace();
        }
        return false;
    }

    /**
     * 订阅消息相关
     */


    /**
     * 主题名称是否已经存在
     *
     * @param topicName
     * @return
     */
    private boolean topicNameExist(String topicName) {
        DescribeCmqTopicDetailRequest req = new DescribeCmqTopicDetailRequest();
        req.setTopicName(topicName);
        try {
            getClient().DescribeCmqTopicDetail(req);
            return true;
        } catch (TencentCloudSDKException e) {
            return false;
        }
    }

    /**
     * 创建订阅主题
     *
     * @param topicName-主题名称
     * @param maxMsgSize-消息最大长度
     * @param filterType-过滤类型
     * @return
     */
    public boolean createTopic(String topicName, Long maxMsgSize, Long filterType) {
        if (topicNameExist(topicName)) {
            return true;
        }
        CreateCmqTopicRequest req = new CreateCmqTopicRequest();
        if (filterType != null) {
            req.setFilterType(filterType);
        }

        if (maxMsgSize != null) {
            req.setMaxMsgSize(maxMsgSize);
        }
        req.setTopicName(topicName);
        try {
            getClient().CreateCmqTopic(req);
            return true;
        } catch (TencentCloudSDKException e) {
            e.printStackTrace();
        }
        return false;
    }

    //刪除主題
    public boolean deleteTopic(String topicName) {
        DeleteCmqTopicRequest req = new DeleteCmqTopicRequest();
        req.setTopicName(topicName);
        try {
            getClient().DeleteCmqTopic(req);
            return true;
        } catch (TencentCloudSDKException e) {
            e.printStackTrace();
        }
        return false;
    }

    /**
     * 创建默认参数的主题
     *
     * @param topicName
     * @return
     */
    public boolean createTopic(String topicName) {
        return createTopic(topicName, null, null);
    }


    /**
     * 是否已经订阅
     *
     * @param topicName
     * @param subscriptionName
     * @return
     */
    private boolean isAlreadySubscribe(String topicName, String subscriptionName) {
        DescribeCmqSubscriptionDetailRequest req = new DescribeCmqSubscriptionDetailRequest();
        req.setSubscriptionName(subscriptionName);
        req.setTopicName(topicName);
        req.setLimit(1L);
        req.setOffset(0L);
        try {
            DescribeCmqSubscriptionDetailResponse response = getClient().DescribeCmqSubscriptionDetail(req);
            if (response.getTotalCount() > 0)
                return true;
        } catch (TencentCloudSDKException e) {
            e.printStackTrace();
        }
        return false;
    }

    /**
     * 订阅主题
     *
     * @param topicName-主题名称
     * @param subscriptionName-订阅名称
     * @param queueName-接受消息的队列名称
     * @return
     */
    public boolean subscribeTopic(String topicName, String subscriptionName, String queueName) {
        return subscribeTopic(topicName, subscriptionName, queueName, null);
    }

    public boolean subscribeTopic(String topicName, String subscriptionName, String queueName, List<String> filterTags) {

        try {
            if (isAlreadySubscribe(topicName, subscriptionName)) {
                return true;
            }
        } catch (Exception e) {
        }
        CreateCmqSubscribeRequest req = new CreateCmqSubscribeRequest();
        req.setTopicName(topicName);
        req.setEndpoint(queueName);
        req.setSubscriptionName(subscriptionName);
        req.setProtocol("queue");
        req.setNotifyContentFormat("SIMPLIFIED");
        if (filterTags != null && filterTags.size() > 0) {
            String[] tags = new String[filterTags.size()];
            filterTags.toArray(tags);
            req.setFilterTag(tags);
        }
        try {
            getClient().CreateCmqSubscribe(req);
            return true;
        } catch (TencentCloudSDKException e) {
            e.printStackTrace();
            return false;
        }
    }

    /**
     * 删除订阅
     *
     * @param topicName
     * @param subscriptionName
     * @return
     */
    public boolean deleteSubscribeTopic(String topicName, String subscriptionName) {
        DeleteCmqSubscribeRequest req = new DeleteCmqSubscribeRequest();
        req.setSubscriptionName(subscriptionName);
        req.setTopicName(topicName);
        try {
            getClient().DeleteCmqSubscribe(req);
            return true;
        } catch (TencentCloudSDKException e) {
            e.printStackTrace();
        }
        return false;
    }

    /**
     * 发布订阅消息
     *
     * @param topicName
     * @param message
     * @return
     */
    public String publishTopicMessage(String topicName, String message) {

        return publishTopicMessage(topicName, null, message);
    }

    /**
     * 发布订阅消息
     *
     * @param topicName
     * @param tagList   -标签
     * @param message
     * @return
     */
    public String publishTopicMessage(String topicName, List<String> tagList, String message) {
        PublishCmqMsgRequest req = new PublishCmqMsgRequest();
        req.setMsgContent(message);
        req.setTopicName(topicName);
        if (tagList != null && tagList.size() > 0) {
            String[] tags = new String[tagList.size()];
            tagList.toArray(tags);
            req.setMsgTag(tags);
        }
        try {
            PublishCmqMsgResponse response = getMsgClient().PublishCmqMsg(req);
            return response.getMsgId();
        } catch (TencentCloudSDKException e) {
            e.printStackTrace();
        }
        return null;
    }

}

 fanli/src/main/java/com/yeshi/fanli/util/mq/cmq/UserMoneyChangeCMQManager.java

@@ -4,6 +4,7 @@
import java.util.List;
import java.util.Map;

import com.yeshi.fanli.util.Constant;
import org.yeshi.utils.CMQUtil;

import com.google.gson.Gson;
@@ -17,6 +18,7 @@
    private static String secretKey = "xhCSUHo55oHUQ6XicFcmfIgspX0EEzWo";
    private static UserMoneyChangeCMQManager userMoneyChangeCMQManager;
    private static CMQUtil cmqUtil;
    private static TDMQUtil tdmqUtil;

    private final static String TOPIC_NAME = "topic_user_money";

@@ -26,8 +28,10 @@

    static {
        cmqUtil = CMQUtil.getInstance(secretId, secretKey);
        TDMQUtil.getInstance().init(secretId, secretKey, Constant.TDMQ_PUBLIC);
        tdmqUtil = TDMQUtil.getInstance();
        // 创建主题，添加订阅
        cmqUtil.createTopic(TOPIC_NAME);
        tdmqUtil.createTopic(TOPIC_NAME);
        // 用户券订阅
        String[] subscripts = new String[] { SUBSCRIBE_DEBT };
        String[] queues = new String[] { QUEUE_DEBT };
@@ -35,11 +39,11 @@
        for (int i = 0; i < subscripts.length; i++) {
            String queueName = queues[i];
            try {
                cmqUtil.createQueue(queueName);
                tdmqUtil.createQueue(queueName);
            } catch (Exception e) {
            }
            try {
                cmqUtil.subscribeTopic(TOPIC_NAME, subscripts[i], queueName);
                tdmqUtil.subscribeTopic(TOPIC_NAME, subscripts[i], queueName);
            } catch (Exception e) {

            }
@@ -55,12 +59,12 @@
    /**
     * 发布
     * 
     * @param history
     * @param dto
     */
    public void addUserMoneyChangeMsg(UserMoneyChangeDTO dto) {
        if (dto == null)
            return;
        cmqUtil.publishTopicMessage(TOPIC_NAME, new Gson().toJson(dto));
        tdmqUtil.publishTopicMessage(TOPIC_NAME, new Gson().toJson(dto));
        LogHelper.test("资金消息投递成功");
    }

@@ -72,7 +76,7 @@
     * @return
     */
    public Map<String, UserMoneyChangeDTO> consumeQueueMsg(String queueName, int count) {
        List<Message> list = cmqUtil.recieveMsg(count, queueName);
        List<Message> list = Constant.TDMQ_CONSUMER ? tdmqUtil.recieveMsg(count, queueName) : cmqUtil.recieveMsg(count, queueName);
        Map<String, UserMoneyChangeDTO> map = new HashMap<>();

        if (list != null)
@@ -85,7 +89,11 @@
    }

    public void deleteQueueMsg(String queueName, String receiptHandle) {
        if (Constant.TDMQ_CONSUMER) {
            tdmqUtil.deleteMsg(queueName, receiptHandle);
        } else {
        cmqUtil.deleteMsg(queueName, receiptHandle);
    }
    }

}

 fanli/src/main/java/com/yeshi/fanli/util/mq/cmq/order/JDOrderCMQManager.java

@@ -4,6 +4,7 @@
import java.util.List;
import java.util.Map;

import com.yeshi.fanli.util.mq.cmq.TDMQUtil;
import org.yeshi.utils.CMQUtil;

import com.qcloud.cmq.Message;
@@ -21,8 +22,10 @@

    static {
        cmqUtil = CMQUtil.getInstance(secretId, secretKey);
        TDMQUtil.getInstance().init(secretId, secretKey, Constant.TDMQ_PUBLIC);

        JD_ORDER += "-" + Constant.systemCommonConfig.getProjectName();
        cmqUtil.createQueue(JD_ORDER);
        TDMQUtil.getInstance().createQueue(JD_ORDER);
    }

    public static JDOrderCMQManager getInstance() {
@@ -39,7 +42,7 @@
    public void addJDOrder(String orderId) {
        if (StringUtil.isNullOrEmpty(orderId))
            return;
        cmqUtil.sendMsg(JD_ORDER, orderId);
        TDMQUtil.getInstance().sendMsg(JD_ORDER, orderId);
    }

    /**
@@ -49,7 +52,7 @@
     * @return
     */
    public Map<String, String> consumeJDOrder(int count) {
        List<Message> list = cmqUtil.recieveMsg(count, JD_ORDER);
        List<Message> list = Constant.TDMQ_CONSUMER ? TDMQUtil.getInstance().recieveMsg(count, JD_ORDER) : cmqUtil.recieveMsg(count, JD_ORDER);
        Map<String, String> map = new HashMap<>();
        if (list != null)
            for (Message msg : list) {
@@ -65,7 +68,11 @@
     * @param receiptHandle
     */
    public void deleteJDOrder(String receiptHandle) {
        if (Constant.TDMQ_CONSUMER) {
            TDMQUtil.getInstance().deleteMsg(JD_ORDER, receiptHandle);
        } else {
        cmqUtil.deleteMsg(JD_ORDER, receiptHandle);
    }
    }

}

 fanli/src/main/java/com/yeshi/fanli/util/mq/cmq/order/PDDOrderCMQManager.java

@@ -4,6 +4,7 @@
import java.util.List;
import java.util.Map;

import com.yeshi.fanli.util.mq.cmq.TDMQUtil;
import org.yeshi.utils.CMQUtil;

import com.qcloud.cmq.Message;
@@ -21,8 +22,9 @@

    static {
        cmqUtil = CMQUtil.getInstance(secretId, secretKey);
        TDMQUtil.getInstance().init(secretId, secretKey, Constant.TDMQ_PUBLIC);
        PDD_ORDER += "-" + Constant.systemCommonConfig.getProjectName();
        cmqUtil.createQueue(PDD_ORDER);
        TDMQUtil.getInstance().createQueue(PDD_ORDER);
    }

    public static PDDOrderCMQManager getInstance() {
@@ -39,7 +41,7 @@
    public void addPDDOrder(String orderId) {
        if (StringUtil.isNullOrEmpty(orderId))
            return;
        cmqUtil.sendMsg(PDD_ORDER, orderId);
        TDMQUtil.getInstance().sendMsg(PDD_ORDER, orderId);
    }

    /**
@@ -49,7 +51,7 @@
     * @return
     */
    public Map<String, String> consumePDDOrder(int count) {
        List<Message> list = cmqUtil.recieveMsg(count, PDD_ORDER);
        List<Message> list = Constant.TDMQ_CONSUMER ? TDMQUtil.getInstance().recieveMsg(count, PDD_ORDER) : cmqUtil.recieveMsg(count, PDD_ORDER);
        Map<String, String> map = new HashMap<>();
        if (list != null)
            for (Message msg : list) {
@@ -65,7 +67,11 @@
     * @param receiptHandle
     */
    public void deletePDDOrder(String receiptHandle) {
        if (Constant.TDMQ_CONSUMER) {
            TDMQUtil.getInstance().deleteMsg(PDD_ORDER, receiptHandle);
        } else {
        cmqUtil.deleteMsg(PDD_ORDER, receiptHandle);
    }
    }

}

 fanli/src/main/java/com/yeshi/fanli/util/mq/cmq/order/PlaceOrderCMQManager.java

@@ -1,15 +1,15 @@
package com.yeshi.fanli.util.mq.cmq.order;

import java.util.HashMap;
import java.util.List;
import java.util.Map;

import org.yeshi.utils.CMQUtil;

import com.google.gson.Gson;
import com.qcloud.cmq.Message;
import com.yeshi.fanli.entity.bus.user.Order;
import com.yeshi.fanli.entity.order.CommonOrder;
import com.yeshi.fanli.util.Constant;
import com.yeshi.fanli.util.mq.cmq.TDMQUtil;
import org.yeshi.utils.CMQUtil;

import java.util.HashMap;
import java.util.List;
import java.util.Map;

public class PlaceOrderCMQManager {

@@ -28,8 +28,10 @@

    static {
        cmqUtil = CMQUtil.getInstance(secretId, secretKey);
        TDMQUtil.getInstance().init(secretId, secretKey, Constant.TDMQ_PUBLIC);

        // 创建主题，添加订阅
        cmqUtil.createTopic(TOPIC_NAME);
        TDMQUtil.getInstance().createTopic(TOPIC_NAME);
        // 用户券订阅
        String[] subscripts = new String[] { SUBSCRIBE_AD, SUBSCRIBE_INTEGRAL };
        String[] queues = new String[] { QUEUE_AD, QUEUE_INTEGRAL };
@@ -37,11 +39,11 @@
        for (int i = 0; i < subscripts.length; i++) {
            String queueName = queues[i];
            try {
                cmqUtil.createQueue(queueName);
                TDMQUtil.getInstance().createQueue(queueName);
            } catch (Exception e) {
            }
            try {
                cmqUtil.subscribeTopic(TOPIC_NAME, subscripts[i], queueName);
                TDMQUtil.getInstance().subscribeTopic(TOPIC_NAME, subscripts[i], queueName);
            } catch (Exception e) {

            }
@@ -62,7 +64,7 @@
    public void addPlaceOrderMsg(Order order) {
        if (order == null)
            return;
        cmqUtil.publishTopicMessage(TOPIC_NAME, new Gson().toJson(order));
        TDMQUtil.getInstance().publishTopicMessage(TOPIC_NAME, new Gson().toJson(order));
    }

    /**
@@ -73,7 +75,7 @@
     * @return
     */
    public Map<String, Order> consumeQueueMsg(String queueName, int count) {
        List<Message> list = cmqUtil.recieveMsg(count, queueName);
        List<Message> list = Constant.TDMQ_CONSUMER ? TDMQUtil.getInstance().recieveMsg(count, queueName) : cmqUtil.recieveMsg(count, queueName);
        Map<String, Order> map = new HashMap<>();

        if (list != null)
@@ -86,7 +88,11 @@
    }

    public void deleteQueueMsg(String queueName, String receiptHandle) {
        if (Constant.TDMQ_CONSUMER) {
            TDMQUtil.getInstance().deleteMsg(queueName, receiptHandle);
        } else {
        cmqUtil.deleteMsg(queueName, receiptHandle);
    }
    }

}

 fanli/src/main/java/com/yeshi/fanli/util/mq/cmq/order/SuningOrderCMQManager.java

@@ -4,11 +4,13 @@
import java.util.List;
import java.util.Map;

import com.yeshi.fanli.util.mq.cmq.TDMQUtil;
import org.yeshi.utils.CMQUtil;

import com.qcloud.cmq.Message;
import com.yeshi.fanli.util.Constant;
import com.yeshi.fanli.util.StringUtil;
import scala.collection.immutable.Stream;

public class SuningOrderCMQManager {

@@ -21,8 +23,10 @@

    static {
        cmqUtil = CMQUtil.getInstance(secretId, secretKey);
        TDMQUtil.getInstance().init(secretId, secretKey, Constant.TDMQ_PUBLIC);

        SUNING_ORDER += "-" + Constant.systemCommonConfig.getProjectName();
        cmqUtil.createQueue(SUNING_ORDER);
        TDMQUtil.getInstance().createQueue(SUNING_ORDER);
    }

    public static SuningOrderCMQManager getInstance() {
@@ -39,7 +43,7 @@
    public void addSuningOrder(String orderId) {
        if (StringUtil.isNullOrEmpty(orderId))
            return;
        cmqUtil.sendMsg(SUNING_ORDER, orderId);
        TDMQUtil.getInstance().sendMsg(SUNING_ORDER, orderId);
    }

    /**
@@ -49,7 +53,7 @@
     * @return
     */
    public Map<String, String> consumeSuningOrder(int count) {
        List<Message> list = cmqUtil.recieveMsg(count, SUNING_ORDER);
        List<Message> list = Constant.TDMQ_CONSUMER ? TDMQUtil.getInstance().recieveMsg(count, SUNING_ORDER) : cmqUtil.recieveMsg(count, SUNING_ORDER);
        Map<String, String> map = new HashMap<>();
        if (list != null)
            for (Message msg : list) {
@@ -65,7 +69,12 @@
     * @param receiptHandle
     */
    public void deleteSuningOrder(String receiptHandle) {

        if (Constant.TDMQ_CONSUMER) {
            TDMQUtil.getInstance().deleteMsg(SUNING_ORDER, receiptHandle);
        } else {
        cmqUtil.deleteMsg(SUNING_ORDER, receiptHandle);
    }
    }

}

 fanli/src/main/java/com/yeshi/fanli/util/mq/cmq/order/TeamOrderCMQManager.java

@@ -4,6 +4,7 @@
import java.util.List;
import java.util.Map;

import com.yeshi.fanli.util.mq.cmq.TDMQUtil;
import org.yeshi.utils.CMQUtil;

import com.google.gson.Gson;
@@ -31,6 +32,8 @@

    static {
        cmqUtil = CMQUtil.getInstance(secretId, secretKey);
        TDMQUtil.getInstance().init(secretId, secretKey, Constant.TDMQ_PUBLIC);

        if (Constant.IS_TEST) {
            TEAM_DIVIDENTS_PRE = "test-" + TEAM_DIVIDENTS_PRE;
            FANLI_TEAM_INCOME_ORDER_PRE = "test-" + FANLI_TEAM_INCOME_ORDER_PRE;
@@ -42,10 +45,10 @@
        FANLI_TEAM_INCOME_ORDER_PRE += "-" + Constant.systemCommonConfig.getProjectName();
        TEAM_DIVIDENTS += "-" + Constant.systemCommonConfig.getProjectName();
        FANLI_TEAM_INCOME_ORDER += "-" + Constant.systemCommonConfig.getProjectName();
        cmqUtil.createQueue(TEAM_DIVIDENTS_PRE);
        cmqUtil.createQueue(FANLI_TEAM_INCOME_ORDER_PRE);
        cmqUtil.createQueue(TEAM_DIVIDENTS);
        cmqUtil.createQueue(FANLI_TEAM_INCOME_ORDER);
        TDMQUtil.getInstance().createQueue(TEAM_DIVIDENTS_PRE);
        TDMQUtil.getInstance().createQueue(FANLI_TEAM_INCOME_ORDER_PRE);
        TDMQUtil.getInstance().createQueue(TEAM_DIVIDENTS);
        TDMQUtil.getInstance().createQueue(FANLI_TEAM_INCOME_ORDER);
    }

    public static TeamOrderCMQManager getInstance() {
@@ -56,12 +59,12 @@

    // 团队分红预到账
    public void addTeamDividentsPreMsg(UidDateDTO dto) {
        cmqUtil.sendMsg(TEAM_DIVIDENTS_PRE, new Gson().toJson(dto));
        TDMQUtil.getInstance().sendMsg(TEAM_DIVIDENTS_PRE, new Gson().toJson(dto));
    }

    public Map<String, UidDateDTO> consumeTeamDividentsPreMsg(int count) {
        Gson gson = new Gson();
        List<Message> list = cmqUtil.recieveMsg(count, TEAM_DIVIDENTS_PRE);
        List<Message> list = Constant.TDMQ_CONSUMER ? TDMQUtil.getInstance().recieveMsg(count, TEAM_DIVIDENTS_PRE) : cmqUtil.recieveMsg(count, TEAM_DIVIDENTS_PRE);
        Map<String, UidDateDTO> map = new HashMap<>();
        if (list != null)
            for (Message msg : list) {
@@ -74,16 +77,20 @@
    }

    public void deleteTeamDividentsPreMsg(String receiptHandle) {
        if (Constant.TDMQ_CONSUMER) {
            TDMQUtil.getInstance().deleteMsg(TEAM_DIVIDENTS_PRE, receiptHandle);
        } else {
        cmqUtil.deleteMsg(TEAM_DIVIDENTS_PRE, receiptHandle);
        }
    }

    // 团队收益预到账
    public void addFanLiTeamIncomePreMsg(UidDateDTO dto) {
        cmqUtil.sendMsg(FANLI_TEAM_INCOME_ORDER_PRE, new Gson().toJson(dto) + "");
        TDMQUtil.getInstance().sendMsg(FANLI_TEAM_INCOME_ORDER_PRE, new Gson().toJson(dto) + "");
    }

    public Map<String, UidDateDTO> consumeFanLiTeamIncomePreMsg(int count) {
        List<Message> list = cmqUtil.recieveMsg(count, FANLI_TEAM_INCOME_ORDER_PRE);
        List<Message> list = Constant.TDMQ_CONSUMER ? TDMQUtil.getInstance().recieveMsg(count, FANLI_TEAM_INCOME_ORDER_PRE) : cmqUtil.recieveMsg(count, FANLI_TEAM_INCOME_ORDER_PRE);
        Map<String, UidDateDTO> map = new HashMap<>();
        if (list != null)
            for (Message msg : list) {
@@ -97,17 +104,21 @@
    }

    public void deleteTeamIncomePreMsg(String receiptHandle) {
        if (Constant.TDMQ_CONSUMER) {
            TDMQUtil.getInstance().deleteMsg(FANLI_TEAM_INCOME_ORDER_PRE, receiptHandle);
        } else {
        cmqUtil.deleteMsg(FANLI_TEAM_INCOME_ORDER_PRE, receiptHandle);
        }
    }

    // 团队分红到账
    public void addTeamDividentsMsg(UidDateDTO dto) {
        cmqUtil.sendMsg(TEAM_DIVIDENTS, new Gson().toJson(dto));
        TDMQUtil.getInstance().sendMsg(TEAM_DIVIDENTS, new Gson().toJson(dto));
    }

    public Map<String, UidDateDTO> consumeTeamDividentsMsg(int count) {
        Gson gson = new Gson();
        List<Message> list = cmqUtil.recieveMsg(count, TEAM_DIVIDENTS);
        List<Message> list = Constant.TDMQ_CONSUMER ? TDMQUtil.getInstance().recieveMsg(count, TEAM_DIVIDENTS) : cmqUtil.recieveMsg(count, TEAM_DIVIDENTS);
        Map<String, UidDateDTO> map = new HashMap<>();
        if (list != null)
            for (Message msg : list) {
@@ -120,16 +131,20 @@
    }

    public void deleteTeamDividentsMsg(String receiptHandle) {
        if (Constant.TDMQ_CONSUMER) {
            TDMQUtil.getInstance().deleteMsg(TEAM_DIVIDENTS, receiptHandle);
        } else {
        cmqUtil.deleteMsg(TEAM_DIVIDENTS, receiptHandle);
        }
    }

    // 团队收益到账
    public void addFanLiTeamIncomeMsg(UidDateDTO dto) {
        cmqUtil.sendMsg(FANLI_TEAM_INCOME_ORDER, new Gson().toJson(dto) + "");
        TDMQUtil.getInstance().sendMsg(FANLI_TEAM_INCOME_ORDER, new Gson().toJson(dto) + "");
    }

    public Map<String, UidDateDTO> consumeFanLiTeamIncomeMsg(int count) {
        List<Message> list = cmqUtil.recieveMsg(count, FANLI_TEAM_INCOME_ORDER);
        List<Message> list = Constant.TDMQ_CONSUMER ? TDMQUtil.getInstance().recieveMsg(count, FANLI_TEAM_INCOME_ORDER) : cmqUtil.recieveMsg(count, FANLI_TEAM_INCOME_ORDER);
        Map<String, UidDateDTO> map = new HashMap<>();
        if (list != null)
            for (Message msg : list) {
@@ -143,6 +158,10 @@
    }

    public void deleteTeamIncomeMsg(String receiptHandle) {
        if (Constant.TDMQ_CONSUMER) {
            TDMQUtil.getInstance().deleteMsg(FANLI_TEAM_INCOME_ORDER, receiptHandle);
        } else {
        cmqUtil.deleteMsg(FANLI_TEAM_INCOME_ORDER, receiptHandle);
    }
}
}

 fanli/src/main/java/com/yeshi/fanli/util/vipshop/DingDanXiaApiUtil.java

@@ -151,21 +151,19 @@
//        convertLinkByUrl("6918302458239328477", "123");
//        convertLinkByUrl("https://t.vip.com/T7RyKKCJLj9", "437032");


        VipShopOrderQueryModel queryModel = new VipShopOrderQueryModel();
        queryModel.setPage(1);
        queryModel.setPageSize(20);
        queryModel.setOrderTimeEnd(System.currentTimeMillis());
        queryModel.setOrderTimeStart(System.currentTimeMillis() - 1000 * 60 * 60 * 48L);
        VipShopQueryOrderResultDTO resultDTO = getOrderList(queryModel);
        System.out.println(resultDTO);
//
//        VipShopOrderQueryModel queryModel = new VipShopOrderQueryModel();
//        queryModel.setPage(1);
//        queryModel.setPageSize(20);
//        queryModel.setOrderTimeEnd(System.currentTimeMillis());
//        queryModel.setOrderTimeStart(System.currentTimeMillis() - 1000 * 60 * 60 * 48L);
//        VipShopQueryOrderResultDTO resultDTO = getOrderList(queryModel);
//        System.out.println(resultDTO);

//        String result = getAcessTokenInfo("576a51ae7b9b4db1bbfc921cf381ac0c", "1234");
//        System.out.println(result);
        VipShopOrder order = getOrderDetail("20071472613828");


//        System.out.println(order);
        VipShopOrder order = getOrderDetail("21110371888533");
        System.out.println(order);
    }

}

 fanli/src/main/java/com/yeshi/fanli/util/wx/BanLiShopWXPayUtil.java

@@ -38,7 +38,7 @@
        WXPlaceOrderParams params = new WXPlaceOrderParams();
        params.setBody(goodsName);
        params.setFee(money);
        params.setInfo(new WXAPPInfo(Constant.getWXAccount(null, null).getGzAppId(),
        params.setApp(new WXAPPInfo(Constant.getWXAccount(null, null).getGzAppId(),
                Constant.getWXAccount(null, null).getGzAppSecret(), MCH_ID, MCH_KEY));
        params.setIp(ip);
        params.setNotifyUrl("http://api.flqapp.com/fanli/client/v1/callback/banlishop/pay");

 fanli/src/main/java/com/yeshi/fanli/vo/msg/UserMsgUnReadNumVO.java

@@ -1,6 +1,6 @@
package com.yeshi.fanli.vo.msg;

import org.yeshi.utils.mybatis.Table;
import org.yeshi.utils.generater.mybatis.Table;

import com.yeshi.fanli.entity.bus.msg.UserMsgUnReadNum;


 pom.xml

@@ -550,6 +550,38 @@
        </dependency>


        <dependency>
            <groupId>com.tencentcloudapi</groupId>
            <artifactId>tencentcloud-sdk-java</artifactId>
            <!-- go to https://search.maven.org/search?q=tencentcloud-sdk-java and get the latest version. -->
            <!-- 请到https://search.maven.org/search?q=tencentcloud-sdk-java查询所有版本，最新版本如下 -->
            <version>3.1.472</version>
            <exclusions>
                <exclusion>
                    <groupId>io.netty</groupId>
                    <artifactId>*</artifactId>
                </exclusion>
                <exclusion>
                    <groupId>commons-logging</groupId>
                    <artifactId>*</artifactId>
                </exclusion>
                <exclusion>
                    <groupId>com.google.code.gson</groupId>
                    <artifactId>*</artifactId>
                </exclusion>
                <exclusion>
                    <groupId>javax.xml.bind</groupId>
                    <artifactId>*</artifactId>
                </exclusion>
                <exclusion>
                    <groupId>org.ini4j</groupId>
                    <artifactId>*</artifactId>
                </exclusion>
            </exclusions>

        </dependency>






 utils/pom.xml

@@ -57,6 +57,13 @@
            <groupId>com.qcloud</groupId>
            <artifactId>cmq-http-client</artifactId>
            <version>1.0.7</version>
            <exclusions>
                <exclusion>
                    <groupId>org.slf4j</groupId>
                    <artifactId>slf4j-log4j12</artifactId>
                </exclusion>
            </exclusions>

        </dependency>

        <dependency>

 utils/src/main/java/org/yeshi/utils/CMQUtil.java

@@ -1,10 +1,9 @@
package org.yeshi.utils;

import com.qcloud.cmq.*;

import java.util.ArrayList;
import java.util.List;

import com.qcloud.cmq.*;
import org.springframework.data.annotation.Transient;

//腾讯CMQ消息
public class CMQUtil {