统计所有分红订单数

admin

2020-05-26 7dca711e2f7ae7ef4a941191de620ecdfef4dbb3

统计所有分红订单数

 fanli/src/main/java/com/yeshi/fanli/dao/order/OrderMoneyDailyCountDao.java

@@ -424,6 +424,7 @@
        map.put("totalRewardNum", 0);

        map.put("totalSubsidy", 0);

        map.put("totalSubsidyNum", 0);

        map.put("totalNum", 0);

        BasicDBObject initial = new BasicDBObject(map);



        // 进行按天、周、月分组

@@ -455,6 +456,7 @@
                    dailyCount.setTeamRewardNum(new BigDecimal(dbObject.get("totalRewardNum").toString()).intValue());

                    dailyCount.setTeamSubsidy(new BigDecimal(dbObject.get("totalSubsidy").toString()).intValue());

                    dailyCount.setTeamSubsidyNum(new BigDecimal(dbObject.get("totalSubsidyNum").toString()).intValue());

                    dailyCount.setTeamDividentsOrderNum(new BigDecimal(dbObject.get("totalNum").toString()).intValue());

                    results.add(dailyCount);

                } catch (ParseException e) {

                    e.printStackTrace();


 fanli/src/main/java/com/yeshi/fanli/mapping/order/dividents/TeamDividentsSourceOrderUserMapMapper.xml

@@ -234,7 +234,7 @@
    </select>
    
    <select id="sumByDateAndTargetUid" resultMap="TeamDividentsVOMap">
        SELECT SUM(IF(d.`sou_type` = 1, d.`sou_money`,0)) AS subsidy, SUM(IF(d.`sou_type` = 2, d.`sou_money`,0)) AS dividents  FROM  yeshi_ec_team_dividents_source_order_user d
        SELECT SUM(IF(d.`sou_type` = 1,TRUNCATE( d.`sou_money`,2),0)) AS subsidy, SUM(IF(d.`sou_type` = 2,TRUNCATE( d.`sou_money`,2),0)) AS dividents  FROM  yeshi_ec_team_dividents_source_order_user d
        LEFT JOIN yeshi_ec_team_dividents_source_order t ON d.`sou_source_order_id` = t.`tdo_id`
        WHERE d.`sou_target_uid` = #{targetUid} AND d.`sou_state` <![CDATA[<>]]>4 
            AND t.`tdo_create_time` >= #{minTime} AND t.`tdo_create_time` <![CDATA[<=]]>#{maxTime}

 fanli/src/main/java/com/yeshi/fanli/util/rocketmq/consumer/user/UserTeamMessageListener.java

@@ -20,6 +20,7 @@
import com.yeshi.fanli.dto.mq.user.body.UserLevelChangedMQMsg;

import com.yeshi.fanli.dto.mq.user.body.UserMoneyChangeMQMsg;

import com.yeshi.fanli.dto.mq.user.body.UserPhoneOpenMQMsg;

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

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

import com.yeshi.fanli.log.LogHelper;

import com.yeshi.fanli.service.inter.user.invite.TeamFansInfoService;

@@ -96,6 +97,10 @@
                JSONObject json = JSONObject.fromObject(new String(message.getBody()));

                UserInviteMQMsg mqMsg = new Gson().fromJson(json.toString(), UserInviteMQMsg.class);

                if (mqMsg != null) {

                    ThreeSale ts = threeSaleSerivce.selectByWorkerId(mqMsg.getWorkerId());

                    if (ts == null)

                        return Action.ReconsumeLater;



                    // 更新上级的粉丝数量

                    teamFansInfoService.updateFansNum(mqMsg.getBossId());




 fanli/src/main/resource/env-dev/mongo.properties

@@ -1,13 +1,13 @@
mongo.dbname=flq

mongo.port=27017

mongo.port=27016

#开发环境

mongo.host=192.168.1.253

mongo.username=admin

mongo.password=123456



#mongo.host=193.112.35.168

#mongo.username=yeshi

#mongo.password=Yeshi2016@

#mongo.host=192.168.1.253

#mongo.username=admin

#mongo.password=123456

#

mongo.host=193.112.35.168

mongo.username=yeshi

mongo.password=Yeshi2016@



mongo.connectionsPerHost=8

mongo.threadsAllowedToBlockForConnectionMultiplier=4


 fanli/src/test/java/org/fanli/MyBatisProduce.java

@@ -5,14 +5,18 @@
import org.yeshi.utils.mybatis.MyBatisMapperUtil;



import com.yeshi.fanli.entity.bus.homemodule.SwiperPicture;

import com.yeshi.fanli.entity.money.TeamEincomeRecord;

import com.yeshi.fanli.entity.vipshop.VipShopAfterSaleDetailInfo;

import com.yeshi.fanli.entity.vipshop.VipShopOrder;

import com.yeshi.fanli.entity.vipshop.VipShopOrderDetail;



//@Ignore

public class MyBatisProduce {



    @Test

    public void test3() {

        MyBatisMapperUtil.createMapper(TeamEincomeRecord.class);

        MyBatisMapperUtil.createMapper(VipShopOrder.class);

        MyBatisMapperUtil.createMapper(VipShopOrderDetail.class);

        MyBatisMapperUtil.createMapper(VipShopAfterSaleDetailInfo.class);

    }



    @Test