aidlab/sora_back
7
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

TASK:mixi;

Browse Source
This commit is contained in:
shahaibo
2024-08-12 12:47:39 +08:00
parent 432292a559
commit 8f1d8c7b0f
2 changed files with 30 additions and 27 deletions
Download Patch File Download Diff File Expand all files Collapse all files

53
src/main/java/com/mixi/common/tasks/MiTuExportScheduledTask.java
View File

@@ -73,7 +73,7 @@ public class MiTuExportScheduledTask {
// customerTypeAnalysis(); // customerTypeAnalysis();
// getBestSell(); // getBestSell();
// getData(); // getData();
// dailySalesIncentiveStatistics(); // runDailySalesIncentiveStatisticsForPast30Days();
// updateProductStock(); // updateProductStock();
} }
@@ -101,7 +101,7 @@ public class MiTuExportScheduledTask {
// bestSellIsNotNull.lambda().isNotNull(TProduct::getBestSell); // bestSellIsNotNull.lambda().isNotNull(TProduct::getBestSell);
List<TProduct> productListAll = productMapper.selectList(bestSellIsNotNull); List<TProduct> productListAll = productMapper.selectList(bestSellIsNotNull);
LocalDate today = LocalDate.now(); LocalDate today = LocalDate.now();
for (int i = 0; i < 1; i++) { for (int i = 0; i < 30; i++) {
// 将这一天的商品销售数量入库 // 将这一天的商品销售数量入库
miTuProductSellNumEntry(today, productListAll); miTuProductSellNumEntry(today, productListAll);
today = today.minusDays(1); today = today.minusDays(1);
@@ -2391,11 +2391,18 @@ public class MiTuExportScheduledTask {
@Resource @Resource
private SalesRecordMapper salesRecordMapper; private SalesRecordMapper salesRecordMapper;
public void dailySalesIncentiveStatistics() { private void runDailySalesIncentiveStatisticsForPast30Days() {
LocalDate today = LocalDate.now();
for (int i = 0; i < 30; i++) {
dailySalesIncentiveStatistics(today);
today = today.minusDays(1); // 日期向前移动一天
}
}
public void dailySalesIncentiveStatistics(LocalDate localDate) {
// 获取前一日所有商品销售记录 // 获取前一日所有商品销售记录
// 全日最高個人生意額 (每日計) // 全日最高個人生意額 (每日計)
List<Transaction> saleRecordList = getSales(); List<Transaction> saleRecordList = getSales(localDate);
if (!CollectionUtils.isEmpty(saleRecordList)) { if (!CollectionUtils.isEmpty(saleRecordList)) {
Transaction transaction = saleRecordList.get(0); Transaction transaction = saleRecordList.get(0);
SalesRecord salesRecord = new SalesRecord(); SalesRecord salesRecord = new SalesRecord();
@@ -2406,7 +2413,7 @@ public class MiTuExportScheduledTask {
} }
// 全日最高個人銷售件數 (每日計) // 全日最高個人銷售件數 (每日計)
List<Transaction> saleRecordList1 = getSalesNumTop(); List<Transaction> saleRecordList1 = getSalesNumTop(localDate);
if (!CollectionUtils.isEmpty(saleRecordList1)) { if (!CollectionUtils.isEmpty(saleRecordList1)) {
int i = 0; int i = 0;
Transaction transaction = saleRecordList1.get(0); Transaction transaction = saleRecordList1.get(0);
@@ -2429,7 +2436,7 @@ public class MiTuExportScheduledTask {
} }
} }
List<Transaction> saleRecordList2 = getSalesByCategory(); List<Transaction> saleRecordList2 = getSalesByCategory(localDate);
if (!CollectionUtils.isEmpty(saleRecordList2)) { if (!CollectionUtils.isEmpty(saleRecordList2)) {
for (Transaction transaction : saleRecordList2) { for (Transaction transaction : saleRecordList2) {
SalesRecord salesRecord = new SalesRecord(); SalesRecord salesRecord = new SalesRecord();
@@ -2440,7 +2447,7 @@ public class MiTuExportScheduledTask {
} }
} }
List<Transaction> saleRecordList3 = getSalesByMultiSelling(); List<Transaction> saleRecordList3 = getSalesByMultiSelling(localDate);
if (!CollectionUtils.isEmpty(saleRecordList3)) { if (!CollectionUtils.isEmpty(saleRecordList3)) {
for (Transaction transaction : saleRecordList3) { for (Transaction transaction : saleRecordList3) {
SalesRecord salesRecord = new SalesRecord(); SalesRecord salesRecord = new SalesRecord();
@@ -2451,7 +2458,7 @@ public class MiTuExportScheduledTask {
} }
} }
List<Transaction> saleRecordList4 = getSalesByPluCode(); List<Transaction> saleRecordList4 = getSalesByPluCode(localDate);
if (!CollectionUtils.isEmpty(saleRecordList4)) { if (!CollectionUtils.isEmpty(saleRecordList4)) {
for (Transaction transaction : saleRecordList4) { for (Transaction transaction : saleRecordList4) {
SalesRecord salesRecord = new SalesRecord(); SalesRecord salesRecord = new SalesRecord();
@@ -2468,9 +2475,9 @@ public class MiTuExportScheduledTask {
} }
private List<Transaction> getSalesByPluCode() { private List<Transaction> getSalesByPluCode(LocalDate localDate) {
// 获取今日日期 // 获取今日日期
LocalDate today = LocalDate.now(); LocalDate today = localDate;
// 获取昨日日期 // 获取昨日日期
LocalDate yesterday = today.minusDays(1); LocalDate yesterday = today.minusDays(1);
@@ -2525,9 +2532,9 @@ public class MiTuExportScheduledTask {
return result; return result;
} }
private List<Transaction> getSalesByMultiSelling() { private List<Transaction> getSalesByMultiSelling(LocalDate localDate) {
// 获取今日日期 // 获取今日日期
LocalDate today = LocalDate.now(); LocalDate today = localDate;
// 获取昨日日期 // 获取昨日日期
LocalDate yesterday = today.minusDays(1); LocalDate yesterday = today.minusDays(1);
@@ -2589,16 +2596,13 @@ public class MiTuExportScheduledTask {
return result; return result;
} }
private List<Transaction> getSales() { private List<Transaction> getSales(LocalDate date) {
// 获取今日日期
LocalDate today = LocalDate.now();
// 获取昨日日期 // 获取昨日日期
LocalDate yesterday = today.minusDays(1); LocalDate yesterday = date.minusDays(1);
// 格式化日期 // 格式化日期
DateTimeFormatter formatter = DateTimeFormatter.ofPattern("yyyy-MM-dd"); DateTimeFormatter formatter = DateTimeFormatter.ofPattern("yyyy-MM-dd");
String todayStr = today.format(formatter); String todayStr = date.format(formatter);
String yesterdayStr = yesterday.format(formatter); String yesterdayStr = yesterday.format(formatter);
List<Transaction> result = new ArrayList<>(); List<Transaction> result = new ArrayList<>();
Connection conn = null; Connection conn = null;
@@ -2614,8 +2618,7 @@ public class MiTuExportScheduledTask {
// 执行查询 // 执行查询
System.out.println("创建声明..."); System.out.println("创建声明...");
stmt = conn.createStatement(); stmt = conn.createStatement();
String sql; String sql = "SELECT\n" +
sql = "SELECT\n" +
"saleman_name,\n" + "saleman_name,\n" +
"SUM(net_amt) AS total_net_amt\n" + "SUM(net_amt) AS total_net_amt\n" +
"FROM v_MZG016A\n" + "FROM v_MZG016A\n" +
@@ -2646,12 +2649,12 @@ public class MiTuExportScheduledTask {
} }
System.out.println("查询执行完成！"); System.out.println("查询执行完成！");
return result; return result;
} }
private List<Transaction> getSalesNumTop() {
private List<Transaction> getSalesNumTop(LocalDate localDate) {
// 获取今日日期 // 获取今日日期
LocalDate today = LocalDate.now(); LocalDate today = localDate;
// 获取昨日日期 // 获取昨日日期
LocalDate yesterday = today.minusDays(1); LocalDate yesterday = today.minusDays(1);
@@ -2708,9 +2711,9 @@ public class MiTuExportScheduledTask {
} }
private List<Transaction> getSalesByCategory() { private List<Transaction> getSalesByCategory(LocalDate localDate) {
// 获取今日日期 // 获取今日日期
LocalDate today = LocalDate.now(); LocalDate today = localDate;
// 获取昨日日期 // 获取昨日日期
LocalDate yesterday = today.minusDays(1); LocalDate yesterday = today.minusDays(1);

4
src/main/java/com/mixi/service/TAppProductService.java
View File

@@ -383,8 +383,8 @@ public class TAppProductService extends ServiceImpl<TProductMapper, TProduct> {
.ge("sell_date", LocalDate.parse(startDate)) .ge("sell_date", LocalDate.parse(startDate))
.lt("sell_date", LocalDate.parse(endDate)) .lt("sell_date", LocalDate.parse(endDate))
.groupBy("product_id") .groupBy("product_id")
.orderByDesc("sell_num") .orderByDesc("sell_num");
.last("LIMIT 10"); // .last("LIMIT 10");
if (byId != null) { if (byId != null) {
qw.eq("sh_code", byId.getName()); qw.eq("sh_code", byId.getName());