src/main/java/com/xcong/excoin/modules/yunding/entity/YdOrderEntity.java
@@ -96,4 +96,9 @@ @TableField(exist = false) private YdProductEntity ydProductEntity; private Integer type; public static final Integer AGENT_ORDER = 2; public static final Integer PRODUCT_ORDER = 1; } src/main/java/com/xcong/excoin/modules/yunding/service/Impl/YunDingServiceImpl.java
@@ -230,6 +230,7 @@ ydOrderEntity.setTotalProfit(BigDecimal.ZERO); ydOrderEntity.setTodayProfit(BigDecimal.ZERO); ydOrderEntity.setState(YdOrderEntity.ORDER_STATE_READY); ydOrderEntity.setType(YdOrderEntity.PRODUCT_ORDER); Date date = DateUtil.date(); ydOrderEntity.setBuyTime(date); //上架天数 @@ -537,12 +538,19 @@ //更新用户的代理级别 ydOrderDao.updateAgentLevel(memberId,Integer.parseInt(id.toString())); YdOrderEntity orderEntity = new YdOrderEntity(); orderEntity.setType(YdOrderEntity.AGENT_ORDER); orderEntity.setMemberId(memberId); orderEntity.setAmount(salePrice); ydOrderDao.insert(orderEntity); LogRecordUtils.insertMemberAccountMoneyChangeWithId(memberId, "购买代理", salePrice, "USDT", 1, 8, memberId); memberEntity.setAgentLevel(id.intValue()); LoginUserUtils.resetAppLoginUser(memberEntity); yunDingProducter.sendYunDingAutoAgent(memberId); yunDingProducter.sendYunDingUsdtProfit(orderEntity.getId()); return Result.ok("购买成功"); } src/main/resources/mapper/yunding/YdOrderDao.xml
@@ -9,10 +9,11 @@ * FROM yd_order a left join yd_product b on b.id = a.product_id inner join yd_product b on b.id = a.product_id <if test="record != null"> <where> and a.member_id = #{record.memberId} and a.type=1 <if test="record.state != null" > and a.state=#{record.state} </if> @@ -67,7 +68,7 @@ * FROM yd_order a left join yd_product b on b.id = a.product_id inner join yd_product b on b.id = a.product_id where a.member_id = #{memberId} and a.id = #{id} </select> @@ -91,6 +92,6 @@ select a.*, c.id p_id, c.pro_unit from yd_order a inner join (select * from member a where find_in_set(#{inviteId}, a.referer_ids) or invite_id=#{inviteId}) b on a.member_id=b.id left join yd_product c on c.id = a.product_id inner join yd_product c on c.id = a.product_id </select> </mapper> src/test/java/com/xcong/excoin/XchTest.java
@@ -3,11 +3,15 @@ import cn.hutool.core.date.DateUnit; import cn.hutool.core.date.DateUtil; import com.xcong.excoin.modules.yunding.dao.YdOrderDao; import com.xcong.excoin.modules.yunding.entity.YdOrderEntity; import com.xcong.excoin.modules.yunding.service.XchProfitService; import com.xcong.excoin.quartz.job.YdPowerJob; import org.junit.jupiter.api.Test; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.boot.test.context.SpringBootTest; import java.math.BigDecimal; @SpringBootTest public class XchTest { @@ -36,12 +40,24 @@ public void orderUsdtProfitTest() { xchProfitService.usdtProfitDistributorByOrderId(7L); } // // @Autowired // private YdPowerJob ydPowerJob; // // @Test // public void ydPowerTest() { // ydPowerJob.orderWork(); // } @Autowired private YdPowerJob ydPowerJob; private YdOrderDao ydOrderDao; @Test public void ydPowerTest() { ydPowerJob.orderWork(); public void orderTest() { YdOrderEntity orderEntity = new YdOrderEntity(); orderEntity.setType(YdOrderEntity.AGENT_ORDER); orderEntity.setMemberId(40L); orderEntity.setAmount(BigDecimal.TEN); ydOrderDao.insert(orderEntity); } }