From a3304721c2e45e0f2ebd3139fdd623353f2ac72a Mon Sep 17 00:00:00 2001
From: admin <weikou2014>
Date: 星期三, 30 六月 2021 19:08:14 +0800
Subject: [PATCH] 礼金领取，礼金余额
---
service-lijin/src/main/java/com/ks/lijin/service/manager/LijinOrderManager.java | 81 ++++++++++++++++++++++++++++++++++++++++
1 files changed, 81 insertions(+), 0 deletions(-)
diff --git a/service-lijin/src/main/java/com/ks/lijin/service/manager/LijinOrderManager.java b/service-lijin/src/main/java/com/ks/lijin/service/manager/LijinOrderManager.java
index 436be88..cb2dfcf 100644
--- a/service-lijin/src/main/java/com/ks/lijin/service/manager/LijinOrderManager.java
+++ b/service-lijin/src/main/java/com/ks/lijin/service/manager/LijinOrderManager.java
@@ -1,11 +1,26 @@
package com.ks.lijin.service.manager;
import com.ks.lijin.dao.TaoBaoOrderRecordDao;
+import com.ks.lijin.mapper.LiJinExpendRecordMapper;
+import com.ks.lijin.mapper.LiJinProviderAccountMapper;
+import com.ks.lijin.pojo.DO.LiJinExpendRecord;
+import com.ks.lijin.pojo.DO.LiJinProviderTaoKeAccount;
import com.ks.lijin.pojo.DO.TaoBaoOrderRecord;
+import com.ks.lijin.pojo.DTO.taobao.TaoKeAppInfo;
+import com.ks.lijin.pojo.DTO.taobao.TaoLiJinReportDTO;
+import com.ks.lijin.service.LiJinProviderAccountService;
+import com.ks.lijin.utils.taobao.TaoKeApiUtil;
+import com.ks.vip.exception.LijinBalanceException;
+import com.ks.vip.pojo.DO.UserLijinRecord;
+import com.ks.vip.service.LijinBalanceService;
+import com.ks.vip.service.LijinRecordService;
+import org.apache.dubbo.config.annotation.Reference;
import org.springframework.stereotype.Component;
+import org.yeshi.utils.TimeUtil;
import javax.annotation.Resource;
import java.util.Date;
+import java.util.List;
/**
* 绀奸噾璁㈠崟绠＄悊
@@ -18,6 +33,18 @@
@Resource
private LijinDangerGoodsManager lijinDangerGoodsManager;
+
+ @Resource
+ private LiJinExpendRecordMapper liJinExpendRecordMapper;
+
+ @Resource
+ private LiJinProviderAccountMapper liJinProviderAccountMapper;
+
+ @Reference(version = "1.0", check = false)
+ private LijinBalanceService lijinBalanceService;
+
+ @Reference(version = "1.0", check = false)
+ private LijinRecordService lijinRecordService;
/**
* 淇濆瓨娣樺疂璁㈠崟
@@ -44,4 +71,58 @@
}
+ public void syncOnGoingLijin() {
+ long now = System.currentTimeMillis();
+ Date maxCreateTime = new Date(now - 1000 * 60 * 2);
+ Date minCreateTime = new Date(maxCreateTime.getTime() - 1000 * 60 * 60 * 24L);
+ long count = liJinExpendRecordMapper.countOnGoingLijin(minCreateTime, maxCreateTime);
+ int page = (int) (count % 100 == 0 ? count / 100 : count / 100 + 1);
+ for (int i = 0; i < page; i++) {
+ List<LiJinExpendRecord> recordList = liJinExpendRecordMapper.listOnGoingLijin(minCreateTime, maxCreateTime, 100 * i, 100);
+ if (recordList != null) {
+ for (LiJinExpendRecord record : recordList) {
+ LiJinProviderTaoKeAccount account = liJinProviderAccountMapper.selectByPrimaryKey(record.getAccountId());
+ TaoLiJinReportDTO reportDTO = TaoKeApiUtil.taolijinReport(record.getRightsId(), new TaoKeAppInfo(account.getAppKey(), account.getAppSecret(), account.getPid()));
+ if (reportDTO != null) {
+ //鏈夋暟鎹�
+ if (reportDTO.getFp_refund_num() != null || reportDTO.getRefund_num() != null || reportDTO.getUnfreeze_num() != null || reportDTO.getUse_num() != null || reportDTO.getWin_num() != null) {
+ LiJinExpendRecord update = new LiJinExpendRecord(record.getId());
+ update.setRefundAmount(reportDTO.getRefund_amount());
+ update.setRefundNum(reportDTO.getRefund_num());
+ update.setUnfreezeAmount(reportDTO.getUnfreeze_amount());
+ update.setUnfreezeNum(reportDTO.getUnfreeze_num());
+ update.setUseAmount(reportDTO.getUse_amount());
+ update.setUseNum(reportDTO.getUse_num());
+ update.setWinAmount(reportDTO.getUse_amount());
+ update.setWinNum(reportDTO.getWin_num());
+ update.setUpdateTime(new Date());
+ update.setPreCommissionAmount(reportDTO.getPre_commission_amount());
+ liJinExpendRecordMapper.updateByPrimaryKeySelective(update);
+ }
+ //鍒ゆ柇鏄惁涓哄綋澶╁垱寤�
+ if (!TimeUtil.getGernalTime(now, "yyyyMMdd").equalsIgnoreCase(TimeUtil.getGernalTime(record.getCreateTime().getTime(), "yyyyMMdd"))) {
+ //涓嶆槸褰撳ぉ鍒涘缓鐨勶紝鑰屼笖娌℃湁浣跨敤
+ if (reportDTO.getUse_num() == null || reportDTO.getUse_num() == 0) {
+ UserLijinRecord record1 = lijinRecordService.getRecord(record.getUid(), UserLijinRecord.TYPE_ADD, UserLijinRecord.Category.createGoodsLijin.name(), record.getId() + "");
+ if (record1 != null) {
+ continue;
+ }
+
+ try {
+ lijinBalanceService.addLijin(record.getUid(), record.getMoney(), "鏈姷閫�鍥�", UserLijinRecord.Category.createGoodsLijin.name(), record.getId() + "");
+ } catch (LijinBalanceException e) {
+ e.printStackTrace();
+ }
+ }
+ }
+
+ }
+ }
+ }
+ }
+
+
+ }
+
+
}
--
Gitblit v1.8.0