1291 lines
66 KiB
Java
1291 lines
66 KiB
Java
package cn.van.business.util;
|
||
|
||
|
||
import cn.van.business.model.jd.OrderRow;
|
||
import cn.van.business.model.jd.ProductOrder;
|
||
import cn.van.business.repository.OrderRowRepository;
|
||
import cn.van.business.repository.ProductOrderRepository;
|
||
import com.alibaba.fastjson2.util.DateUtils;
|
||
import com.fasterxml.jackson.databind.ObjectMapper;
|
||
import com.jd.open.api.sdk.DefaultJdClient;
|
||
import com.jd.open.api.sdk.JdClient;
|
||
import com.jd.open.api.sdk.domain.kplunion.OrderService.request.query.OrderRowReq;
|
||
import com.jd.open.api.sdk.domain.kplunion.OrderService.response.query.OrderRowResp;
|
||
import com.jd.open.api.sdk.domain.kplunion.promotionbysubunioni.PromotionService.request.get.PromotionCodeReq;
|
||
import com.jd.open.api.sdk.request.kplunion.UnionOpenOrderRowQueryRequest;
|
||
import com.jd.open.api.sdk.request.kplunion.UnionOpenPromotionBysubunionidGetRequest;
|
||
import com.jd.open.api.sdk.response.kplunion.UnionOpenOrderRowQueryResponse;
|
||
import com.jd.open.api.sdk.response.kplunion.UnionOpenPromotionBysubunionidGetResponse;
|
||
import lombok.Getter;
|
||
import lombok.Setter;
|
||
import org.slf4j.Logger;
|
||
import org.slf4j.LoggerFactory;
|
||
import org.springframework.beans.factory.annotation.Autowired;
|
||
import org.springframework.data.redis.core.HashOperations;
|
||
import org.springframework.data.redis.core.StringRedisTemplate;
|
||
import org.springframework.scheduling.annotation.Scheduled;
|
||
import org.springframework.stereotype.Component;
|
||
|
||
import java.text.SimpleDateFormat;
|
||
import java.time.LocalDate;
|
||
import java.time.LocalDateTime;
|
||
import java.time.ZoneId;
|
||
import java.time.format.DateTimeFormatter;
|
||
import java.time.temporal.ChronoUnit;
|
||
import java.util.*;
|
||
import java.util.concurrent.TimeUnit;
|
||
import java.util.stream.Collectors;
|
||
import java.util.stream.Stream;
|
||
|
||
import static cn.van.business.util.WXUtil.super_admins;
|
||
|
||
/**
|
||
* @author Leo
|
||
* @version 1.0
|
||
* @create 2024/11/5 17:40
|
||
* @description：
|
||
*/
|
||
@Component
|
||
public class JDUtil {
|
||
/**
|
||
* 密钥配置
|
||
*/
|
||
|
||
// van论坛
|
||
private static final String LPF_APP_KEY_WZ = "98e21c89ae5610240ec3f5f575f86a59";
|
||
private static final String LPF_SECRET_KEY_WZ = "3dcb6b23a1104639ac433fd07adb6dfb";
|
||
// 导购的
|
||
private static final String LPF_APP_KEY_DG = "faf410cb9587dc80dc7b31e321d7d322";
|
||
private static final String LPF_SECRET_KEY_DG = "a4fb15d7bedd4316b97b4e96e4effc1c";
|
||
|
||
private static final String LL_APP_KEY_DG = "9c2011409f0fc906b73432dd3687599d";
|
||
private static final String LL_SECRET_KEY_DG = "3ceddff403e544a8a2eacc727cf05dab";
|
||
|
||
|
||
/**
|
||
* 实际业务处理
|
||
*/
|
||
// 标记是否拉取过小时的订单，空订单会set 一个 tag，避免重复拉取
|
||
private static final String JD_REFRESH_TAG = "jd:refresh:tag:";
|
||
private static final String SERVER_URL = "https://api.jd.com/routerjson";
|
||
//accessToken
|
||
private static final String ACCESS_TOKEN = "";
|
||
|
||
private static final Logger logger = LoggerFactory.getLogger(JDUtil.class);
|
||
|
||
private static final DateTimeFormatter DATE_TIME_FORMATTER = DateTimeFormatter.ofPattern("yyyy-MM-dd HH:mm:ss");
|
||
private final StringRedisTemplate redisTemplate;
|
||
private final OrderRowRepository orderRowRepository;
|
||
private final ProductOrderRepository productOrderRepository;
|
||
private final WXUtil wxUtil;
|
||
private final OrderUtil orderUtil;
|
||
private static final String INTERACTION_STATE_PREFIX = "interaction_state:";
|
||
private static final long TIMEOUT_MINUTES = 1;
|
||
|
||
// 构造函数中注入StringRedisTemplate
|
||
@Autowired
|
||
public JDUtil(StringRedisTemplate redisTemplate,
|
||
ProductOrderRepository productOrderRepository,OrderRowRepository orderRowRepository, WXUtil wxUtil, OrderUtil orderUtil) {
|
||
this.redisTemplate = redisTemplate;
|
||
this.orderRowRepository = orderRowRepository;
|
||
this.productOrderRepository = productOrderRepository;
|
||
this.wxUtil = wxUtil;
|
||
this.orderUtil = orderUtil;
|
||
}
|
||
|
||
// 定义一个内部类来存储用户交互状态
|
||
@Getter
|
||
@Setter
|
||
private static class UserInteractionState {
|
||
private String lastInteractionTime;
|
||
private String currentState;
|
||
private Map<String, String> collectedFields; // 用于存储收集到的字段值
|
||
private String currentField; // 当前正在询问的字段
|
||
|
||
public UserInteractionState() {
|
||
this.lastInteractionTime = LocalDateTime.now().format(DATE_TIME_FORMATTER);
|
||
this.currentState = "INIT";
|
||
this.collectedFields = new HashMap<>();
|
||
this.currentField = null;
|
||
}
|
||
|
||
public void updateLastInteractionTime() {
|
||
this.lastInteractionTime = LocalDateTime.now().format(DATE_TIME_FORMATTER);
|
||
}
|
||
}
|
||
|
||
|
||
// 添加ObjectMapper来序列化和反序列化UserInteractionState
|
||
private final ObjectMapper objectMapper = new ObjectMapper();
|
||
|
||
|
||
/**
|
||
* 将 响应参数转化为 OrderRow，并返回
|
||
*/
|
||
private static OrderRow createOrderRow(OrderRowResp orderRowResp) {
|
||
OrderRow orderRow = new OrderRow();
|
||
orderRow.setOrderId(orderRowResp.getOrderId());
|
||
orderRow.setSkuId(orderRowResp.getSkuId());
|
||
orderRow.setSkuName(orderRowResp.getSkuName());
|
||
orderRow.setItemId(orderRowResp.getItemId());
|
||
orderRow.setSkuNum(orderRowResp.getSkuNum());
|
||
orderRow.setPrice(orderRowResp.getPrice());
|
||
orderRow.setActualCosPrice(orderRowResp.getActualCosPrice());
|
||
orderRow.setActualFee(orderRowResp.getActualFee());
|
||
orderRow.setEstimateCosPrice(orderRowResp.getEstimateCosPrice());
|
||
orderRow.setEstimateFee(orderRowResp.getEstimateFee());
|
||
orderRow.setSubSideRate(orderRowResp.getSubSideRate());
|
||
orderRow.setSubsidyRate(orderRowResp.getSubsidyRate());
|
||
orderRow.setCommissionRate(orderRowResp.getCommissionRate());
|
||
orderRow.setFinalRate(orderRowResp.getFinalRate());
|
||
|
||
orderRow.setOrderTime(DateUtils.parseDate(orderRowResp.getOrderTime()));
|
||
orderRow.setFinishTime(DateUtils.parseDate(orderRowResp.getFinishTime()));
|
||
orderRow.setOrderTag(orderRowResp.getOrderTag());
|
||
orderRow.setOrderEmt(orderRowResp.getOrderEmt());
|
||
orderRow.setUnionId(orderRowResp.getUnionId());
|
||
orderRow.setUnionRole(orderRowResp.getUnionRole());
|
||
orderRow.setUnionAlias(orderRowResp.getUnionAlias());
|
||
orderRow.setUnionTag(orderRowResp.getUnionTag());
|
||
orderRow.setTraceType(orderRowResp.getTraceType());
|
||
orderRow.setValidCode(orderRowResp.getValidCode());
|
||
orderRow.setPayMonth(orderRowResp.getPayMonth());
|
||
orderRow.setSiteId(orderRowResp.getSiteId());
|
||
orderRow.setParentId(orderRowResp.getParentId());
|
||
//GoodsInfo goodsInfo = orderRowResp.getGoodsInfo();
|
||
//GoodsInfoVO goodsInfoVO = new GoodsInfoVO();
|
||
//goodsInfoVO.setShopId(String.valueOf(goodsInfo.getShopId()));
|
||
//goodsInfoVO.setShopName(goodsInfo.getShopName());
|
||
//goodsInfoVO.setOwner(goodsInfo.getOwner());
|
||
//goodsInfoVO.setProductId(String.valueOf(goodsInfo.getProductId()));
|
||
//goodsInfoVO.setImageUrl(goodsInfo.getImageUrl());
|
||
//orderRow.setGoodsInfo(goodsInfoVO);
|
||
orderRow.setCallerItemId(orderRowResp.getCallerItemId());
|
||
orderRow.setPid(orderRowResp.getPid());
|
||
orderRow.setCid1(orderRowResp.getCid1());
|
||
orderRow.setCid2(orderRowResp.getCid2());
|
||
orderRow.setCid3(orderRowResp.getCid3());
|
||
orderRow.setChannelId(orderRowResp.getChannelId());
|
||
orderRow.setProPriceAmount(orderRowResp.getProPriceAmount());
|
||
orderRow.setSkuFrozenNum(orderRowResp.getSkuFrozenNum());
|
||
orderRow.setSkuReturnNum(orderRowResp.getSkuReturnNum());
|
||
orderRow.setSkuTag(orderRowResp.getSkuTag());
|
||
orderRow.setPositionId(orderRowResp.getPositionId());
|
||
orderRow.setPopId(orderRowResp.getPopId());
|
||
orderRow.setRid(orderRowResp.getRid());
|
||
orderRow.setPlus(orderRowResp.getPlus());
|
||
orderRow.setCpActId(orderRowResp.getCpActId());
|
||
orderRow.setGiftCouponKey(orderRowResp.getGiftCouponKey());
|
||
|
||
orderRow.setModifyTime(new Date());
|
||
orderRow.setSign(orderRowResp.getSign());
|
||
orderRow.setBalanceExt(orderRowResp.getBalanceExt());
|
||
orderRow.setExpressStatus(orderRowResp.getExpressStatus());
|
||
orderRow.setExt1(orderRowResp.getExt1());
|
||
orderRow.setSubUnionId(orderRowResp.getSubUnionId());
|
||
orderRow.setGiftCouponOcsAmount(orderRowResp.getGiftCouponOcsAmount());
|
||
orderRow.setTraceType(orderRowResp.getTraceType());
|
||
orderRow.setExpressStatus(orderRowResp.getExpressStatus());
|
||
orderRow.setTraceType(orderRowResp.getTraceType());
|
||
orderRow.setId(orderRowResp.getId());
|
||
orderRow.setValidCode(orderRowResp.getValidCode());
|
||
orderRow.setExpressStatus(orderRowResp.getExpressStatus());
|
||
orderRow.setTraceType(orderRowResp.getTraceType());
|
||
return orderRow;
|
||
}
|
||
|
||
private static List<OrderRow> filterOrdersByDate(List<OrderRow> orderRows, int daysBack) {
|
||
LocalDate now = LocalDate.now();
|
||
|
||
return orderRows.stream().filter(order -> {
|
||
// 将 Date 转换为 LocalDate
|
||
LocalDate orderDate = order.getOrderTime().toInstant().atZone(ZoneId.systemDefault()).toLocalDate();
|
||
|
||
// 计算是否在给定的天数内
|
||
return !orderDate.isBefore(now.minusDays(daysBack)) && !orderDate.isAfter(now);
|
||
}).collect(Collectors.toList());
|
||
}
|
||
|
||
private static Stream<OrderRow> getStreamForWeiGui(List<OrderRow> todayOrders) {
|
||
return todayOrders.stream().filter(orderRow -> orderRow.getValidCode() == 13 || orderRow.getValidCode() == 25 || orderRow.getValidCode() == 26 || orderRow.getValidCode() == 27 || orderRow.getValidCode() == 28 || orderRow.getValidCode() == 29);
|
||
}
|
||
|
||
/**
|
||
* 实时刷新最近10分钟的订单
|
||
*/
|
||
@Scheduled(cron = "0 * * * * ?")
|
||
public void fetchLatestOrder() {
|
||
LocalDateTime now = LocalDateTime.now();
|
||
LocalDateTime lastMinute = now.minusMinutes(10).withSecond(0).withNano(0);
|
||
|
||
|
||
/**临时代码*/
|
||
|
||
|
||
/**下面是原先的代码*/
|
||
for (Map.Entry<String, WXUtil.SuperAdmin> entry : super_admins.entrySet()) {
|
||
//String wxid = entry.getKey();
|
||
WXUtil.SuperAdmin admin = entry.getValue();
|
||
String appKey = admin.getAppKey();
|
||
String secretKey = admin.getSecretKey();
|
||
if (Util.isAnyEmpty(appKey, secretKey)) {
|
||
continue;
|
||
}
|
||
logger.info("实时订单 {} ", appKey.substring(appKey.length() - 4));
|
||
UnionOpenOrderRowQueryResponse response = fetchOrdersForDateTime(lastMinute, true, 1, true, appKey, secretKey); // 真实代表实时订单
|
||
if (response != null) {
|
||
|
||
int code = response.getQueryResult().getCode();
|
||
if (code == 200) {
|
||
if (response.getQueryResult().getCode() == 200) {
|
||
OrderRowResp[] orderRowResps = response.getQueryResult().getData();
|
||
if (orderRowResps == null) {
|
||
continue;
|
||
}
|
||
for (OrderRowResp orderRowResp : orderRowResps) {
|
||
// 固化到数据库
|
||
OrderRow orderRow = createOrderRow(orderRowResp);
|
||
// 订单号不存在就保存，存在就更新订单状态
|
||
orderRowRepository.save(orderRow);
|
||
}
|
||
}
|
||
}
|
||
}
|
||
}
|
||
|
||
}
|
||
|
||
public void test01() {
|
||
|
||
for (Map.Entry<String, WXUtil.SuperAdmin> entry : super_admins.entrySet()) {
|
||
//String wxid = entry.getKey();
|
||
WXUtil.SuperAdmin admin = entry.getValue();
|
||
String appKey = admin.getAppKey();
|
||
String secretKey = admin.getSecretKey();
|
||
if (Util.isAnyEmpty(appKey, secretKey)) {
|
||
continue;
|
||
}
|
||
LocalDateTime now = LocalDateTime.now();
|
||
//logger.info("拉取历史订单---> , {} 点,{} 分", now.getHour(), now.getMinute());
|
||
|
||
LocalDateTime lastHour = now.truncatedTo(ChronoUnit.HOURS);
|
||
LocalDateTime startDate = lastHour.minusMonths(12);
|
||
|
||
logger.info("{} - {}", startDate, lastHour);
|
||
|
||
while (!startDate.isEqual(lastHour)) {
|
||
|
||
test(startDate, appKey);
|
||
logger.info("test {}", startDate);
|
||
|
||
|
||
startDate = startDate.plusHours(1);
|
||
}
|
||
}
|
||
}
|
||
|
||
|
||
/**
|
||
* 扫描订单发送到微信
|
||
* 每分钟的30秒执行一次
|
||
*/
|
||
@Scheduled(cron = "10 * * * * ?")
|
||
public void sendOrderToWx() {
|
||
long start = System.currentTimeMillis();
|
||
int[] validCodes = {-1};
|
||
// 只要三个月的,更多的也刷新不出来的
|
||
Date threeMonthsAgo = Date.from(LocalDateTime.now().minusMonths(3).atZone(ZoneId.systemDefault()).toInstant());
|
||
List<OrderRow> orderRows = orderRowRepository.findByValidCodeNotInAndOrderTimeGreaterThanOrderByOrderTimeDesc(validCodes, threeMonthsAgo);
|
||
|
||
for (OrderRow orderRow : orderRows) {
|
||
|
||
orderUtil.orderToWx(orderRow, true);
|
||
|
||
}
|
||
|
||
logger.info("扫描订单发送到微信耗时：{} ms, 订单数：{} ", System.currentTimeMillis() - start, orderRows.size());
|
||
|
||
}
|
||
|
||
/**
|
||
* 一天拉取三次 30天到60天前的订单
|
||
*/
|
||
@Scheduled(cron = "0 0 */4 * * ?")
|
||
public void fetchHistoricalOrders3090() {
|
||
|
||
try {
|
||
for (Map.Entry<String, WXUtil.SuperAdmin> entry : super_admins.entrySet()) {
|
||
//String wxid = entry.getKey();
|
||
WXUtil.SuperAdmin admin = entry.getValue();
|
||
String appKey = admin.getAppKey();
|
||
String secretKey = admin.getSecretKey();
|
||
if (Util.isAnyEmpty(appKey, secretKey)) {
|
||
continue;
|
||
}
|
||
fetchHistoricalOrders3090Do(appKey, secretKey);
|
||
}
|
||
} catch (Exception e) {
|
||
logger.error("拉取历史订单3090异常", e);
|
||
}
|
||
|
||
}
|
||
|
||
private int fetchHistoricalOrders3090Do(String appKey, String secretKey) {
|
||
|
||
int count = 0;
|
||
LocalDateTime now = LocalDateTime.now();
|
||
//logger.info("拉取历史订单---> , {} 点,{} 分", now.getHour(), now.getMinute());
|
||
|
||
LocalDateTime lastHour = now.truncatedTo(ChronoUnit.HOURS).minusMonths(1);
|
||
LocalDateTime startDate = lastHour.minusMonths(3).truncatedTo(ChronoUnit.HOURS);
|
||
|
||
|
||
while (!startDate.isEqual(lastHour)) {
|
||
Integer pageIndex = 1;
|
||
boolean hasMore = true;
|
||
|
||
while (hasMore) {
|
||
try {
|
||
// 30-60 天 ，非实时，非分钟
|
||
UnionOpenOrderRowQueryResponse response = fetchOrdersForDateTime(startDate, false, pageIndex, false, appKey, secretKey);
|
||
if (response != null && response.getQueryResult() != null) {
|
||
if (response.getQueryResult().getCode() == 200) {
|
||
OrderRowResp[] orderRowResps = response.getQueryResult().getData();
|
||
if (orderRowResps != null) {
|
||
for (OrderRowResp orderRowResp : orderRowResps) {
|
||
if (orderRowResp != null) { // Check each orderRowResp is not null
|
||
OrderRow orderRow = createOrderRow(orderRowResp);
|
||
if (orderRow != null) { // Ensure orderRow is not null after creation
|
||
orderRowRepository.save(orderRow);
|
||
count++;
|
||
}
|
||
}
|
||
}
|
||
}
|
||
hasMore = Boolean.TRUE.equals(response.getQueryResult().getHasMore());
|
||
} else {
|
||
hasMore = false;
|
||
}
|
||
} else {
|
||
hasMore = false;
|
||
}
|
||
} catch (Exception e) {
|
||
hasMore = false; // Optionally break out of the while loop if required
|
||
}
|
||
if (hasMore) pageIndex++;
|
||
}
|
||
startDate = startDate.plusHours(1);
|
||
}
|
||
return count;
|
||
}
|
||
|
||
/**
|
||
* 一天拉取6次 14天到30天前的订单
|
||
*/
|
||
@Scheduled(cron = "0 0 * * * ?")
|
||
public void fetchHistoricalOrders1430() {
|
||
try {
|
||
for (Map.Entry<String, WXUtil.SuperAdmin> entry : super_admins.entrySet()) {
|
||
//String wxid = entry.getKey();
|
||
WXUtil.SuperAdmin admin = entry.getValue();
|
||
String appKey = admin.getAppKey();
|
||
String secretKey = admin.getSecretKey();
|
||
if (Util.isAnyEmpty(appKey, secretKey)) {
|
||
continue;
|
||
}
|
||
fetchHistoricalOrders1430Do(appKey, secretKey);
|
||
}
|
||
}catch (Exception e){
|
||
logger.error("拉取历史订单1430异常", e);
|
||
}
|
||
|
||
}
|
||
|
||
private int fetchHistoricalOrders1430Do(String appKey, String secretKey) {
|
||
int count = 0;
|
||
LocalDateTime now = LocalDateTime.now();
|
||
//logger.info("拉取历史订单---> , {} 点,{} 分", now.getHour(), now.getMinute());
|
||
|
||
LocalDateTime lastHour = now.truncatedTo(ChronoUnit.HOURS).minusDays(14);
|
||
LocalDateTime startDate = lastHour.minusMonths(1).truncatedTo(ChronoUnit.HOURS);
|
||
|
||
while (!startDate.isEqual(lastHour)) {
|
||
Integer pageIndex = 1;
|
||
boolean hasMore = true;
|
||
|
||
while (hasMore) {
|
||
try {
|
||
// 14 - 30 天 ，非实时，非分钟
|
||
UnionOpenOrderRowQueryResponse response = fetchOrdersForDateTime(startDate, false, pageIndex, false, appKey, secretKey);
|
||
if (response != null && response.getQueryResult() != null) {
|
||
if (response.getQueryResult().getCode() == 200) {
|
||
OrderRowResp[] orderRowResps = response.getQueryResult().getData();
|
||
if (orderRowResps != null) {
|
||
for (OrderRowResp orderRowResp : orderRowResps) {
|
||
if (orderRowResp != null) { // Check each orderRowResp is not null
|
||
OrderRow orderRow = createOrderRow(orderRowResp);
|
||
if (orderRow != null) { // Ensure orderRow is not null after creation
|
||
orderRowRepository.save(orderRow);
|
||
count++;
|
||
}
|
||
}
|
||
}
|
||
}
|
||
hasMore = Boolean.TRUE.equals(response.getQueryResult().getHasMore());
|
||
} else {
|
||
hasMore = false;
|
||
}
|
||
} else {
|
||
hasMore = false;
|
||
}
|
||
} catch (Exception e) {
|
||
hasMore = false; // Optionally break out of the while loop if required
|
||
}
|
||
if (hasMore) pageIndex++;
|
||
}
|
||
startDate = startDate.plusHours(1);
|
||
}
|
||
return count;
|
||
}
|
||
|
||
/**
|
||
* 每10分钟拉取07-14天的订单
|
||
*/
|
||
@Scheduled(cron = "0 0 * * * ?")
|
||
public void fetchHistoricalOrders0714() {
|
||
try {
|
||
for (Map.Entry<String, WXUtil.SuperAdmin> entry : super_admins.entrySet()) {
|
||
//String wxid = entry.getKey();
|
||
WXUtil.SuperAdmin admin = entry.getValue();
|
||
String appKey = admin.getAppKey();
|
||
String secretKey = admin.getSecretKey();
|
||
if (Util.isAnyEmpty(appKey, secretKey)) {
|
||
continue;
|
||
}
|
||
fetchHistoricalOrders0714Do(appKey, secretKey);
|
||
}
|
||
}catch (Exception e){
|
||
logger.error("拉取历史订单0714异常", e);
|
||
}
|
||
|
||
}
|
||
|
||
private int fetchHistoricalOrders0714Do(String appKey, String secretKey) {
|
||
int count = 0;
|
||
LocalDateTime now = LocalDateTime.now();
|
||
//logger.info("拉取历史订单---> , {} 点,{} 分", now.getHour(), now.getMinute());
|
||
LocalDateTime lastHour = now.truncatedTo(ChronoUnit.HOURS).minusDays(7);
|
||
LocalDateTime startDate = lastHour.minusDays(14).truncatedTo(ChronoUnit.HOURS);
|
||
|
||
while (!startDate.isEqual(lastHour)) {
|
||
Integer pageIndex = 1;
|
||
boolean hasMore = true;
|
||
|
||
while (hasMore) {
|
||
try {
|
||
// 7 - 14 天 ，非实时，非分钟
|
||
UnionOpenOrderRowQueryResponse response = fetchOrdersForDateTime(startDate, false, pageIndex, false, appKey, secretKey);
|
||
if (response != null && response.getQueryResult() != null) {
|
||
if (response.getQueryResult().getCode() == 200) {
|
||
OrderRowResp[] orderRowResps = response.getQueryResult().getData();
|
||
if (orderRowResps != null) {
|
||
for (OrderRowResp orderRowResp : orderRowResps) {
|
||
if (orderRowResp != null) { // Check each orderRowResp is not null
|
||
OrderRow orderRow = createOrderRow(orderRowResp);
|
||
if (orderRow != null) { // Ensure orderRow is not null after creation
|
||
orderRowRepository.save(orderRow);
|
||
count++;
|
||
}
|
||
}
|
||
}
|
||
}
|
||
hasMore = Boolean.TRUE.equals(response.getQueryResult().getHasMore());
|
||
} else {
|
||
hasMore = false;
|
||
}
|
||
} else {
|
||
hasMore = false;
|
||
}
|
||
} catch (Exception e) {
|
||
hasMore = false; // Optionally break out of the while loop if required
|
||
}
|
||
if (hasMore) pageIndex++;
|
||
}
|
||
startDate = startDate.plusHours(1);
|
||
}
|
||
return count;
|
||
}
|
||
|
||
@Scheduled(cron = "0 */5 * * * ?")
|
||
public void fetchHistoricalOrders0007() {
|
||
try {
|
||
for (Map.Entry<String, WXUtil.SuperAdmin> entry : super_admins.entrySet()) {
|
||
//String wxid = entry.getKey();
|
||
WXUtil.SuperAdmin admin = entry.getValue();
|
||
String appKey = admin.getAppKey();
|
||
String secretKey = admin.getSecretKey();
|
||
if (Util.isAnyEmpty(appKey, secretKey)) {
|
||
continue;
|
||
}
|
||
fetchHistoricalOrders0007Do(appKey, secretKey);
|
||
}
|
||
}catch (Exception e){
|
||
logger.error("拉取历史订单0007异常", e);
|
||
}
|
||
|
||
}
|
||
|
||
private int fetchHistoricalOrders0007Do(String appKey, String secretKey) {
|
||
|
||
int count = 0;
|
||
LocalDateTime now = LocalDateTime.now();
|
||
//logger.info("拉取历史订单---> , {} 点,{} 分", now.getHour(), now.getMinute());
|
||
LocalDateTime lastHour = now.truncatedTo(ChronoUnit.HOURS);
|
||
LocalDateTime startDate = lastHour.minusDays(7).truncatedTo(ChronoUnit.HOURS);
|
||
|
||
while (!startDate.isEqual(lastHour)) {
|
||
Integer pageIndex = 1;
|
||
boolean hasMore = true;
|
||
|
||
while (hasMore) {
|
||
try {
|
||
// 0 - 7 天 ，非实时，非分钟
|
||
UnionOpenOrderRowQueryResponse response = fetchOrdersForDateTime(startDate, false, pageIndex, false, appKey, secretKey);
|
||
if (response != null && response.getQueryResult() != null) {
|
||
if (response.getQueryResult().getCode() == 200) {
|
||
OrderRowResp[] orderRowResps = response.getQueryResult().getData();
|
||
if (orderRowResps != null) {
|
||
for (OrderRowResp orderRowResp : orderRowResps) {
|
||
if (orderRowResp != null) { // Check each orderRowResp is not null
|
||
OrderRow orderRow = createOrderRow(orderRowResp);
|
||
if (orderRow != null) { // Ensure orderRow is not null after creation
|
||
orderRowRepository.save(orderRow);
|
||
count++;
|
||
}
|
||
}
|
||
}
|
||
}
|
||
hasMore = Boolean.TRUE.equals(response.getQueryResult().getHasMore());
|
||
} else {
|
||
hasMore = false;
|
||
}
|
||
} else {
|
||
hasMore = false;
|
||
}
|
||
} catch (Exception e) {
|
||
hasMore = false; // Optionally break out of the while loop if required
|
||
}
|
||
if (hasMore) pageIndex++;
|
||
}
|
||
startDate = startDate.plusHours(1);
|
||
}
|
||
return count;
|
||
}
|
||
|
||
/**
|
||
* 根据指定的日期时间拉取订单
|
||
*
|
||
* @param startTime 开始时间
|
||
* isRealTime 是否是实时订单 是的话不会判断是否拉取过
|
||
* page 分页页码
|
||
* isMinutes 是否是分钟级订单 分钟的每次加10分钟，小时每小时加1小时
|
||
*/
|
||
public UnionOpenOrderRowQueryResponse fetchOrdersForDateTime(LocalDateTime startTime, boolean isRealTime, Integer page, boolean isMinutes, String appKey, String secretKey) {
|
||
|
||
LocalDateTime endTime = isMinutes ? startTime.plusMinutes(10) : startTime.plusHours(1);
|
||
String hourMinuteTag = isRealTime ? "minute" : "hour";
|
||
//String oldTimeTag = JD_REFRESH_TAG + startTime.format(DATE_TIME_FORMATTER);
|
||
|
||
String newTimeTag = JD_REFRESH_TAG + appKey + ":" + startTime.format(DATE_TIME_FORMATTER);
|
||
|
||
HashOperations<String, String, String> hashOps = redisTemplate.opsForHash();
|
||
|
||
// 检查这个小时或分钟是否已经被处理过
|
||
if (hashOps.hasKey(newTimeTag, hourMinuteTag)) {
|
||
if (!isMinutes) {
|
||
return null;
|
||
}
|
||
}
|
||
|
||
// 调用 API 以拉取订单
|
||
try {
|
||
UnionOpenOrderRowQueryResponse unionOpenOrderRowQueryResponse = getUnionOpenOrderRowQueryResponse(startTime, endTime, page, appKey, secretKey);
|
||
// 历史的订单才进行标记为已拉取,小时分钟的都进行拉取并且标记
|
||
if (!isRealTime) {
|
||
// 只有没有订单的才进行标记为已拉取
|
||
if (unionOpenOrderRowQueryResponse != null && unionOpenOrderRowQueryResponse.getQueryResult() != null && unionOpenOrderRowQueryResponse.getQueryResult().getData() == null) {
|
||
hashOps.put(newTimeTag, hourMinuteTag, "done");
|
||
}
|
||
|
||
}
|
||
|
||
// 打印方法调用和开始结束时间
|
||
if (isRealTime) {
|
||
logger.info(" {} --- 拉取订单, 分钟还是秒 {} , 开始时间：{} --- 结束时间：{}", appKey.substring(appKey.length() - 4), hourMinuteTag, startTime.format(DATE_TIME_FORMATTER), endTime.format(DATE_TIME_FORMATTER));
|
||
}
|
||
|
||
return unionOpenOrderRowQueryResponse;
|
||
} catch (Exception e) {
|
||
return null;
|
||
}
|
||
|
||
|
||
}
|
||
|
||
public synchronized void test(LocalDateTime startTime, String appKey) {
|
||
String oldTimeTag = JD_REFRESH_TAG + startTime.format(DATE_TIME_FORMATTER);
|
||
String newTimeTag = JD_REFRESH_TAG + appKey + ":" + startTime.format(DATE_TIME_FORMATTER);
|
||
|
||
|
||
HashOperations<String, String, String> hashOps = redisTemplate.opsForHash();
|
||
|
||
// get all entries from the old hash
|
||
Map<String, String> entries = hashOps.entries(oldTimeTag);
|
||
|
||
// put all entries into the new hash
|
||
hashOps.putAll(newTimeTag, entries);
|
||
|
||
logger.info("oldTimeTag {} 复制 到 newTimeTag {} ", oldTimeTag, newTimeTag);
|
||
// delete the old hash
|
||
// redisTemplate.delete(oldTimeTag);
|
||
}
|
||
public void sendOrderToWxByOrderDefault(String order, String fromWxid) {
|
||
logger.info("执行 sendOrderToWxByOrderDefault 方法，order: {}, fromWxid: {}", order, fromWxid);
|
||
handleUserInteraction(fromWxid, order);
|
||
// 具体逻辑
|
||
}
|
||
|
||
/**
|
||
* 接收京粉指令指令
|
||
*/
|
||
public void sendOrderToWxByOrderJD(String order, String fromWxid) {
|
||
|
||
int[] param = {-1};
|
||
WXUtil.SuperAdmin superAdmin = super_admins.get(fromWxid);
|
||
String unionId = superAdmin.getUnionId();
|
||
List<OrderRow> orderRows = orderRowRepository.findByValidCodeNotInOrderByOrderTimeDescAndUnionId(param, Long.valueOf(unionId));
|
||
/**
|
||
* 菜单：
|
||
* 今日统计
|
||
* 昨日统计
|
||
* 最近七天统计
|
||
* 最近一个月统计
|
||
* 今天订单
|
||
* 昨天订单
|
||
* */
|
||
StringBuilder content = new StringBuilder();
|
||
switch (order) {
|
||
case "菜单":
|
||
content.append("菜单：京+命令 \n 如： 京今日统计\r");
|
||
content.append("今日统计\r");
|
||
content.append("昨天统计\r");
|
||
content.append("七日统计\r");
|
||
content.append("一个月统计\r");
|
||
content.append("两个月统计\r");
|
||
content.append("三个月统计\r");
|
||
content.append("总统计\r");
|
||
content.append("这个月统计\r");
|
||
content.append("上个月统计\r");
|
||
content.append("今日订单\r");
|
||
content.append("昨日订单\r");
|
||
content.append("刷新7天\r");
|
||
content.append("刷新3090\r");
|
||
content.append("刷新1430\r");
|
||
content.append("刷新0714\r");
|
||
|
||
content.append("\n");
|
||
content.append(":::高级菜单:::\r");
|
||
content.append("菜单：京+高级+命令 \n 如： 京高级违规30\r");
|
||
content.append("京高级违规+整数\r");
|
||
content.append("京高级+订单号\r\"");
|
||
content.append("京高级SKU+sku\\r\"");
|
||
content.append("京高级搜索+搜索标题，只返回最近10条\r\"");
|
||
break;
|
||
case "测试指令": {
|
||
//test01();
|
||
break;
|
||
}
|
||
case "今日统计": {
|
||
List<OrderRow> todayOrders = filterOrdersByDate(orderRows, 0);
|
||
// 订单总数，已付款，已取消，佣金总计
|
||
content.append("今日统计：\n");
|
||
content.append("订单总数：").append(todayOrders.size()).append("\r");
|
||
content.append("已付款：").append(todayOrders.stream().filter(orderRow -> orderRow.getValidCode() == 16).count()).append("\r");
|
||
content.append("已取消：").append(todayOrders.stream().filter(orderRow -> orderRow.getValidCode() != 16 && orderRow.getValidCode() != 17).count()).append("\r");
|
||
content.append("已完成：").append(todayOrders.stream().filter(orderRow -> orderRow.getValidCode() == 17).count()).append("\r");
|
||
content.append("违规：").append(getStreamForWeiGui(todayOrders).count()).append("\r");
|
||
content.append("已付款佣金：").append(todayOrders.stream().filter(orderRow -> orderRow.getValidCode() == 16).mapToDouble(OrderRow::getEstimateFee).sum()).append("\r");
|
||
content.append("已完成佣金：").append(todayOrders.stream().filter(orderRow -> orderRow.getValidCode() == 17).mapToDouble(OrderRow::getEstimateFee).sum());
|
||
content.append("\r" + "违规佣金：").append(getStreamForWeiGui(todayOrders).mapToDouble(orderRow -> orderRow.getEstimateCosPrice() * orderRow.getCommissionRate() * 0.01).sum());
|
||
|
||
break;
|
||
}
|
||
case "已付款": {
|
||
List<OrderRow> yfkOrders = orderRows.stream().filter(orderRow -> orderRow.getValidCode() == 16).collect(Collectors.toList());
|
||
content.append("已付款：\n");
|
||
content.append("订单总数：").append(yfkOrders.size()).append("\r");
|
||
content.append("佣金总数：").append(yfkOrders.stream().mapToDouble(OrderRow::getEstimateFee).sum());
|
||
for (OrderRow orderRow : yfkOrders) {
|
||
orderUtil.orderToWx(orderRow, false);
|
||
}
|
||
break;
|
||
}
|
||
case "昨日统计": {
|
||
|
||
}
|
||
case "三日统计": {
|
||
List<OrderRow> last3DaysOrders = filterOrdersByDate(orderRows, 3);
|
||
content.append("三日统计：\n");
|
||
content.append("订单总数：").append(last3DaysOrders.size()).append("\r");
|
||
content.append("已付款：").append(last3DaysOrders.stream().filter(orderRow -> orderRow.getValidCode() == 16).count()).append("\r");
|
||
content.append("已取消：").append(last3DaysOrders.stream().filter(orderRow -> orderRow.getValidCode() != 16 && orderRow.getValidCode() != 17).count()).append("\r");
|
||
content.append("已完成：").append(last3DaysOrders.stream().filter(orderRow -> orderRow.getValidCode() == 17).count()).append("\r");
|
||
content.append("违规：").append(getStreamForWeiGui(last3DaysOrders).count()).append("\r");
|
||
content.append("已付款佣金：").append(last3DaysOrders.stream().filter(orderRow -> orderRow.getValidCode() == 16).mapToDouble(OrderRow::getEstimateFee).sum()).append("\r");
|
||
content.append("已完成佣金：").append(last3DaysOrders.stream().filter(orderRow -> orderRow.getValidCode() == 17).mapToDouble(OrderRow::getEstimateFee).sum());
|
||
content.append("\r" + "违规佣金：").append(getStreamForWeiGui(last3DaysOrders).mapToDouble(orderRow -> orderRow.getEstimateCosPrice() * orderRow.getCommissionRate() * 0.01).sum());
|
||
break;
|
||
}
|
||
case "七日统计": {
|
||
List<OrderRow> last7DaysOrders = filterOrdersByDate(orderRows, 7);
|
||
content.append("七日统计：\n");
|
||
content.append("订单总数：").append(last7DaysOrders.size()).append("\r");
|
||
content.append("已付款：").append(last7DaysOrders.stream().filter(orderRow -> orderRow.getValidCode() == 16).count()).append("\r");
|
||
content.append("已取消：").append(last7DaysOrders.stream().filter(orderRow -> orderRow.getValidCode() != 16 && orderRow.getValidCode() != 17).count()).append("\r");
|
||
content.append("已完成：").append(last7DaysOrders.stream().filter(orderRow -> orderRow.getValidCode() == 17).count()).append("\r");
|
||
content.append("违规：").append(getStreamForWeiGui(last7DaysOrders).count()).append("\r");
|
||
content.append("已付款佣金：").append(last7DaysOrders.stream().filter(orderRow -> orderRow.getValidCode() == 16).mapToDouble(OrderRow::getEstimateFee).sum()).append("\r");
|
||
content.append("已完成佣金：").append(last7DaysOrders.stream().filter(orderRow -> orderRow.getValidCode() == 17).mapToDouble(OrderRow::getEstimateFee).sum());
|
||
content.append("\r" + "违规佣金：").append(getStreamForWeiGui(last7DaysOrders).mapToDouble(orderRow -> orderRow.getEstimateCosPrice() * orderRow.getCommissionRate() * 0.01).sum());
|
||
break;
|
||
}
|
||
case "一个月统计": {
|
||
List<OrderRow> last30DaysOrders = filterOrdersByDate(orderRows, 30);
|
||
content.append("一个月统计：\n");
|
||
content.append("订单总数：").append(last30DaysOrders.size()).append("\r");
|
||
content.append("已付款：").append(last30DaysOrders.stream().filter(orderRow -> orderRow.getValidCode() == 16).count()).append("\r");
|
||
content.append("已取消：").append(last30DaysOrders.stream().filter(orderRow -> orderRow.getValidCode() != 16 && orderRow.getValidCode() != 17).count()).append("\r");
|
||
content.append("已完成：").append(last30DaysOrders.stream().filter(orderRow -> orderRow.getValidCode() == 17).count()).append("\r");
|
||
content.append("违规：").append(getStreamForWeiGui(last30DaysOrders).count()).append("\r");
|
||
content.append("已付款佣金：").append(last30DaysOrders.stream().filter(orderRow -> orderRow.getValidCode() == 16).mapToDouble(OrderRow::getEstimateFee).sum()).append("\r");
|
||
content.append("已完成佣金：").append(last30DaysOrders.stream().filter(orderRow -> orderRow.getValidCode() == 17).mapToDouble(OrderRow::getEstimateFee).sum());
|
||
content.append("\r" + "违规佣金：").append(getStreamForWeiGui(last30DaysOrders).mapToDouble(orderRow -> orderRow.getEstimateCosPrice() * orderRow.getCommissionRate() * 0.01).sum());
|
||
break;
|
||
}
|
||
case "两个月统计": {
|
||
List<OrderRow> last60DaysOrders = filterOrdersByDate(orderRows, 60);
|
||
content.append("两个月统计：\n");
|
||
content.append("订单总数：").append(last60DaysOrders.size()).append("\r");
|
||
content.append("已付款：").append(last60DaysOrders.stream().filter(orderRow -> orderRow.getValidCode() == 16).count()).append("\r");
|
||
content.append("已取消：").append(last60DaysOrders.stream().filter(orderRow -> orderRow.getValidCode() != 16 && orderRow.getValidCode() != 17).count()).append("\r");
|
||
content.append("已完成：").append(last60DaysOrders.stream().filter(orderRow -> orderRow.getValidCode() == 17).count()).append("\r");
|
||
content.append("违规：").append(getStreamForWeiGui(last60DaysOrders).count()).append("\r");
|
||
content.append("已付款佣金：").append(last60DaysOrders.stream().filter(orderRow -> orderRow.getValidCode() == 16).mapToDouble(OrderRow::getEstimateFee).sum()).append("\r");
|
||
content.append("已完成佣金：").append(last60DaysOrders.stream().filter(orderRow -> orderRow.getValidCode() == 17).mapToDouble(OrderRow::getEstimateFee).sum());
|
||
content.append("\r" + "违规佣金：").append(getStreamForWeiGui(last60DaysOrders).mapToDouble(orderRow -> orderRow.getEstimateCosPrice() * orderRow.getCommissionRate() * 0.01).sum());
|
||
break;
|
||
}
|
||
case "三个月统计": {
|
||
List<OrderRow> last90DaysOrders = filterOrdersByDate(orderRows, 90);
|
||
content.append("订单总数：").append(last90DaysOrders.size()).append("\r");
|
||
content.append("已付款：").append(last90DaysOrders.stream().filter(orderRow -> orderRow.getValidCode() == 16).count()).append("\r");
|
||
content.append("已取消：").append(last90DaysOrders.stream().filter(orderRow -> orderRow.getValidCode() != 16 && orderRow.getValidCode() != 17).count()).append("\r");
|
||
content.append("已完成：").append(last90DaysOrders.stream().filter(orderRow -> orderRow.getValidCode() == 17).count()).append("\r");
|
||
content.append("违规：").append(getStreamForWeiGui(last90DaysOrders).count()).append("\r");
|
||
content.append("已付款佣金：").append(last90DaysOrders.stream().filter(orderRow -> orderRow.getValidCode() == 16).mapToDouble(OrderRow::getEstimateFee).sum()).append("\r");
|
||
content.append("已完成佣金：").append(last90DaysOrders.stream().filter(orderRow -> orderRow.getValidCode() == 17).mapToDouble(OrderRow::getEstimateFee).sum());
|
||
content.append("\r" + "违规佣金：").append(getStreamForWeiGui(last90DaysOrders).mapToDouble(orderRow -> orderRow.getEstimateCosPrice() * orderRow.getCommissionRate() * 0.01).sum());
|
||
break;
|
||
}
|
||
case "这个月统计": {
|
||
// 计算出距离1号有几天
|
||
int days = LocalDate.now().getDayOfMonth();
|
||
List<OrderRow> thisMonthOrders = filterOrdersByDate(orderRows, days);
|
||
|
||
content.append("本月统计：\n");
|
||
content.append("订单总数：").append(thisMonthOrders.size()).append("\r");
|
||
content.append("已付款：").append(thisMonthOrders.stream().filter(orderRow -> orderRow.getValidCode() == 16).count()).append("\r");
|
||
content.append("已取消：").append(thisMonthOrders.stream().filter(orderRow -> orderRow.getValidCode() != 16 && orderRow.getValidCode() != 17).count()).append("\r");
|
||
content.append("已完成：").append(thisMonthOrders.stream().filter(orderRow -> orderRow.getValidCode() == 17).count()).append("\r");
|
||
content.append("违规：").append(getStreamForWeiGui(thisMonthOrders).count()).append("\r");
|
||
content.append("已付款佣金：").append(thisMonthOrders.stream().filter(orderRow -> orderRow.getValidCode() == 16).mapToDouble(OrderRow::getEstimateFee).sum()).append("\r");
|
||
content.append("已完成佣金：").append(thisMonthOrders.stream().filter(orderRow -> orderRow.getValidCode() == 17).mapToDouble(OrderRow::getEstimateFee).sum());
|
||
content.append("\r" + "违规佣金：").append(getStreamForWeiGui(thisMonthOrders).mapToDouble(orderRow -> orderRow.getEstimateCosPrice() * orderRow.getCommissionRate() * 0.01).sum());
|
||
break;
|
||
}
|
||
case "上个月统计": {
|
||
LocalDate lastMonth = LocalDate.now().minusMonths(1);
|
||
int days = LocalDate.now().getDayOfMonth();
|
||
|
||
List<OrderRow> lastMonthOrders = filterOrdersByDate(orderRows, lastMonth.lengthOfMonth() + days);
|
||
List<OrderRow> thisMonthOrders = filterOrdersByDate(orderRows, days);
|
||
lastMonthOrders = lastMonthOrders.stream().filter(orderRow -> !thisMonthOrders.contains(orderRow)).collect(Collectors.toList());
|
||
|
||
content.append("上个月统计：\n");
|
||
content.append("订单总数：").append(lastMonthOrders.size()).append("\r");
|
||
content.append("已付款：").append(lastMonthOrders.stream().filter(orderRow -> orderRow.getValidCode() == 16).count()).append("\r");
|
||
content.append("已取消：").append(lastMonthOrders.stream().filter(orderRow -> orderRow.getValidCode() != 16 && orderRow.getValidCode() != 17).count()).append("\r");
|
||
content.append("已完成：").append(lastMonthOrders.stream().filter(orderRow -> orderRow.getValidCode() == 17).count()).append("\r");
|
||
content.append("违规：").append(getStreamForWeiGui(lastMonthOrders).count()).append("\r");
|
||
content.append("已付款佣金：").append(lastMonthOrders.stream().filter(orderRow -> orderRow.getValidCode() == 16).mapToDouble(OrderRow::getEstimateFee).sum()).append("\r");
|
||
content.append("已完成佣金：").append(lastMonthOrders.stream().filter(orderRow -> orderRow.getValidCode() == 17).mapToDouble(OrderRow::getEstimateFee).sum());
|
||
content.append("\r" + "违规佣金：").append(getStreamForWeiGui(lastMonthOrders).mapToDouble(orderRow -> orderRow.getEstimateCosPrice() * orderRow.getCommissionRate() * 0.01).sum());
|
||
break;
|
||
|
||
}
|
||
//总统计
|
||
|
||
case "总统计": {
|
||
content.append("总统计：\n");
|
||
content.append("订单总数：").append(orderRows.size()).append("\r");
|
||
content.append("已付款：").append(orderRows.stream().filter(orderRow -> orderRow.getValidCode() == 16).count()).append("\r");
|
||
content.append("已取消：").append(orderRows.stream().filter(orderRow -> orderRow.getValidCode() != 16 && orderRow.getValidCode() != 17).count()).append("\r");
|
||
content.append("已完成：").append(orderRows.stream().filter(orderRow -> orderRow.getValidCode() == 17).count()).append("\r");
|
||
content.append("违规：").append(getStreamForWeiGui(orderRows).count()).append("\r");
|
||
content.append("已付款佣金：").append(orderRows.stream().filter(orderRow -> orderRow.getValidCode() == 16).mapToDouble(OrderRow::getEstimateFee).sum()).append("\r");
|
||
content.append("已完成佣金：").append(orderRows.stream().filter(orderRow -> orderRow.getValidCode() == 17).mapToDouble(OrderRow::getEstimateFee).sum());
|
||
content.append("\r" + "违规佣金：").append(getStreamForWeiGui(orderRows).mapToDouble(orderRow -> orderRow.getEstimateCosPrice() * orderRow.getCommissionRate() * 0.01).sum());
|
||
break;
|
||
}
|
||
|
||
|
||
case "今日订单": {
|
||
List<OrderRow> todayOrders = filterOrdersByDate(orderRows, 0);
|
||
// 订单总数，已付款，已取消，佣金总计
|
||
content.append("今日统计：\n");
|
||
content.append("订单总数：").append(todayOrders.size()).append("\r");
|
||
content.append("已付款：").append(todayOrders.stream().filter(orderRow -> orderRow.getValidCode() == 16).count()).append("\r");
|
||
content.append("已取消：").append(todayOrders.stream().filter(orderRow -> orderRow.getValidCode() != 16 && orderRow.getValidCode() != 17).count()).append("\r");
|
||
content.append("已完成：").append(todayOrders.stream().filter(orderRow -> orderRow.getValidCode() == 17).count()).append("\r");
|
||
content.append("违规：").append(getStreamForWeiGui(todayOrders).count()).append("\r");
|
||
content.append("已付款佣金：").append(todayOrders.stream().filter(orderRow -> orderRow.getValidCode() == 16).mapToDouble(OrderRow::getEstimateFee).sum()).append("\r");
|
||
content.append("已完成佣金：").append(todayOrders.stream().filter(orderRow -> orderRow.getValidCode() == 17).mapToDouble(OrderRow::getEstimateFee).sum());
|
||
content.append("\r" + "违规佣金：").append(getStreamForWeiGui(todayOrders).mapToDouble(orderRow -> orderRow.getEstimateCosPrice() * orderRow.getCommissionRate() * 0.01).sum());
|
||
|
||
for (OrderRow orderRow : todayOrders) {
|
||
orderUtil.orderToWx(orderRow, false);
|
||
}
|
||
|
||
break;
|
||
}
|
||
case "昨日订单": {
|
||
List<OrderRow> yesterdayOrders = filterOrdersByDate(orderRows, 1);
|
||
List<OrderRow> todayOrders = filterOrdersByDate(orderRows, 0);
|
||
yesterdayOrders.removeAll(todayOrders);
|
||
content.append("昨日统计：\n");
|
||
content.append("订单总数：").append(yesterdayOrders.size()).append("\r");
|
||
content.append("已付款：").append(yesterdayOrders.stream().filter(orderRow -> orderRow.getValidCode() == 16).count()).append("\r");
|
||
content.append("已取消：").append(yesterdayOrders.stream().filter(orderRow -> orderRow.getValidCode() != 16 && orderRow.getValidCode() != 17).count()).append("\r");
|
||
content.append("已完成：").append(yesterdayOrders.stream().filter(orderRow -> orderRow.getValidCode() == 17).count()).append("\r");
|
||
content.append("违规：").append(getStreamForWeiGui(yesterdayOrders).count()).append("\r");
|
||
content.append("已付款佣金：").append(yesterdayOrders.stream().filter(orderRow -> orderRow.getValidCode() == 16).mapToDouble(OrderRow::getEstimateFee).sum()).append("\r");
|
||
content.append("已完成佣金：").append(yesterdayOrders.stream().filter(orderRow -> orderRow.getValidCode() == 17).mapToDouble(OrderRow::getEstimateFee).sum());
|
||
content.append("\r" + "违规佣金：").append(getStreamForWeiGui(yesterdayOrders).mapToDouble(orderRow -> orderRow.getEstimateCosPrice() * orderRow.getCommissionRate() * 0.01).sum());
|
||
for (OrderRow orderRow : yesterdayOrders) {
|
||
orderUtil.orderToWx(orderRow, false);
|
||
}
|
||
break;
|
||
}
|
||
case "刷新7天": {
|
||
long start = System.currentTimeMillis();
|
||
int count = 0;
|
||
LocalDateTime startDate = LocalDateTime.now().minusDays(7).withMinute(0).withSecond(0).withNano(0);
|
||
LocalDateTime lastHour = LocalDateTime.now().minusHours(1).withMinute(0).withSecond(0).withNano(0);
|
||
String appKey = superAdmin.getAppKey();
|
||
String secretKey = superAdmin.getSecretKey();
|
||
if (Util.isAnyEmpty(appKey, secretKey)) {
|
||
return;
|
||
}
|
||
while (!startDate.isEqual(lastHour)) {
|
||
startDate = startDate.plusHours(1);
|
||
UnionOpenOrderRowQueryResponse response = fetchOrdersForDateTime(startDate, false, 1, false, appKey, secretKey);
|
||
if (response != null) {
|
||
|
||
int code = response.getQueryResult().getCode();
|
||
if (code == 200) {
|
||
if (response.getQueryResult().getCode() == 200) {
|
||
OrderRowResp[] orderRowResps = response.getQueryResult().getData();
|
||
if (orderRowResps == null) {
|
||
continue;
|
||
}
|
||
for (OrderRowResp orderRowResp : orderRowResps) {
|
||
// 固化到数据库
|
||
OrderRow orderRow = createOrderRow(orderRowResp);
|
||
// 订单号不存在就保存，存在就更新订单状态
|
||
orderRowRepository.save(orderRow);
|
||
count++;
|
||
}
|
||
}
|
||
}
|
||
}
|
||
}
|
||
content.append("刷新7天成功,耗时").append((System.currentTimeMillis() - start) / 1000).append("秒\r").append("刷新订单数：").append(count);
|
||
break;
|
||
|
||
}
|
||
case "刷新3090": {
|
||
String appKey = superAdmin.getAppKey();
|
||
String secretKey = superAdmin.getSecretKey();
|
||
if (Util.isAnyEmpty(appKey, secretKey)) {
|
||
return;
|
||
}
|
||
long start = System.currentTimeMillis();
|
||
int count = fetchHistoricalOrders3090Do(appKey, secretKey);
|
||
long time = System.currentTimeMillis() - start;
|
||
content.append("订单行：").append(count).append(",耗时: ").append(time).append("ms, ").append((time) / 1000).append(" s\r");
|
||
break;
|
||
|
||
}
|
||
case "刷新1430": {
|
||
String appKey = superAdmin.getAppKey();
|
||
String secretKey = superAdmin.getSecretKey();
|
||
if (Util.isAnyEmpty(appKey, secretKey)) {
|
||
return;
|
||
}
|
||
long start = System.currentTimeMillis();
|
||
int count = fetchHistoricalOrders1430Do(appKey, secretKey);
|
||
long time = System.currentTimeMillis() - start;
|
||
content.append("订单行：").append(count).append(",耗时: ").append(time).append("ms, ").append((time) / 1000).append(" s\r");
|
||
|
||
break;
|
||
}
|
||
case "刷新0714": {
|
||
String appKey = superAdmin.getAppKey();
|
||
String secretKey = superAdmin.getSecretKey();
|
||
if (Util.isAnyEmpty(appKey, secretKey)) {
|
||
return;
|
||
}
|
||
long start = System.currentTimeMillis();
|
||
int count = fetchHistoricalOrders0714Do(appKey, secretKey);
|
||
long time = System.currentTimeMillis() - start;
|
||
content.append("订单行：").append(count).append(",耗时: ").append(time).append("ms, ").append((time) / 1000).append(" s\r");
|
||
break;
|
||
}
|
||
|
||
default:
|
||
sendOrderToWxByOrderJDAdvanced(order, fromWxid);
|
||
}
|
||
if (content.length() > 0) {
|
||
wxUtil.sendTextMessage(fromWxid, content.toString(), 1, fromWxid);
|
||
}
|
||
|
||
}
|
||
|
||
/**
|
||
* 接收京粉指令指令
|
||
* 高级菜单
|
||
*/
|
||
public void sendOrderToWxByOrderJDAdvanced(String order, String fromWxid) {
|
||
int[] param = {-1};
|
||
WXUtil.SuperAdmin superAdmin = super_admins.get(fromWxid);
|
||
String unionId = superAdmin.getUnionId();
|
||
List<OrderRow> orderRows = orderRowRepository.findByValidCodeNotInOrderByOrderTimeDescAndUnionId(param, Long.valueOf(unionId));
|
||
|
||
|
||
StringBuilder content = new StringBuilder();
|
||
if (order.startsWith("高级")) {
|
||
order = order.replace("高级", "");
|
||
if (order.startsWith("违规")) {
|
||
String days = order.replace("违规", "");
|
||
Integer daysInt = 365;
|
||
if (Util.isNotEmpty(days)) {
|
||
daysInt = Integer.parseInt(days);
|
||
}
|
||
List<OrderRow> filterOrdersByDays = filterOrdersByDate(orderRows, daysInt);
|
||
|
||
content.append("违规排行：");
|
||
content.append(daysInt).append("天").append("\r\n");
|
||
|
||
|
||
Map<String, Long> skuIdViolationCountMap = filterOrdersByDays.stream().filter(orderRow -> orderRow.getValidCode() == 27 || orderRow.getValidCode() == 28).filter(orderRow -> orderRow.getSkuName() != null).collect(Collectors.groupingBy(OrderRow::getSkuName, Collectors.counting()));
|
||
|
||
Map<String, List<OrderInfo>> orderInfoMap = filterOrdersByDays.stream().filter(orderRow -> orderRow.getValidCode() == 27 || orderRow.getValidCode() == 28).filter(orderRow -> orderRow.getSkuName() != null).map(orderRow -> {
|
||
OrderInfo info = new OrderInfo();
|
||
info.setSkuName(orderRow.getSkuName());
|
||
info.setOrderId(orderRow.getOrderId());
|
||
info.setOrderDate(orderRow.getOrderTime());
|
||
return info;
|
||
}).collect(Collectors.groupingBy(OrderInfo::getSkuName));
|
||
|
||
List<Map.Entry<String, Long>> sortedViolationCounts = skuIdViolationCountMap.entrySet().stream().sorted(Map.Entry.comparingByValue(Comparator.reverseOrder())).collect(Collectors.toList());
|
||
|
||
Integer num = 0;
|
||
for (Map.Entry<String, Long> entry : sortedViolationCounts) {
|
||
num++;
|
||
String skuName = entry.getKey();
|
||
Long count = entry.getValue();
|
||
content.append("\n").append(num).append(",商品：").append(skuName).append("\r\r").append(" 违规次数：").append(count).append("\r");
|
||
List<OrderInfo> infos = orderInfoMap.get(skuName);
|
||
if (infos != null) {
|
||
for (OrderInfo info : infos) {
|
||
content.append("\n 订单：").append(info.getOrderId()).append("\r 下单：").append(info.getOrderDate()).append("\r");
|
||
}
|
||
}
|
||
}
|
||
}
|
||
// 订单状态查询
|
||
if (order.startsWith("3") || order.startsWith("2")) {
|
||
List<OrderRow> orderRowList = orderRowRepository.findByOrderId(Long.parseLong(order));
|
||
if (!orderRowList.isEmpty()) {
|
||
OrderRow orderRow = orderRowList.get(0);
|
||
content.append(orderUtil.getFormattedOrderInfo(orderRow, orderRow.getValidCode()));
|
||
} else {
|
||
content.append("订单不存在");
|
||
}
|
||
}
|
||
if (order.startsWith("SKU")) {
|
||
order = order.replace("SKU", "");
|
||
String[] split = order.split("\r\n");
|
||
content.append("电脑端").append("\r\n");
|
||
for (String s : split) {
|
||
content.append("https://item.jd.com/").append(s.trim()).append(".html").append("\r\n");
|
||
}
|
||
wxUtil.sendTextMessage(fromWxid, content.toString(), 1, fromWxid);
|
||
content = new StringBuilder();
|
||
content.append("手机端").append("\r\n");
|
||
for (String s : split) {
|
||
content.append("https://item.m.jd.com/product/").append(s.trim()).append(".html").append("\r\n");
|
||
}
|
||
wxUtil.sendTextMessage(fromWxid, content.toString(), 1, fromWxid);
|
||
content = new StringBuilder();
|
||
|
||
|
||
}
|
||
// 转链
|
||
if (order.startsWith("转链")) {
|
||
order = order.replace("转链", "");
|
||
String[] split = order.split("\r\n");
|
||
for (String s : split) {
|
||
content.append("https://item.jd.com/").append(s.trim()).append(".html").append("\r\n");
|
||
}
|
||
}
|
||
} else {
|
||
try {
|
||
sendOrderToWxByOrderJD("菜单", fromWxid);
|
||
} catch (Exception e) {
|
||
throw new RuntimeException(e);
|
||
}
|
||
}
|
||
if (content.length() > 0) {
|
||
wxUtil.sendTextMessage(fromWxid, content.toString(), 1, fromWxid);
|
||
}
|
||
}
|
||
//public UnionOpenGoodsBigfieldQueryResponse getUnionOpenGoodsBigfieldQueryResponse(){
|
||
// JdClient client = new DefaultJdClient(SERVER_URL, ACCESS_TOKEN, APP_KEY, SECRET_KEY);
|
||
//
|
||
// UnionOpenGoodsBigfieldQueryRequest request=new UnionOpenGoodsBigfieldQueryRequest();
|
||
// BigFieldGoodsReq goodsReq=new BigFieldGoodsReq();
|
||
// goodsReq.setSkuIds();
|
||
// request.setGoodsReq(goodsReq);
|
||
// request.setVersion("1.0");
|
||
// UnionOpenGoodsBigfieldQueryResponse response= null;
|
||
// try {
|
||
// response = client.execute(request);
|
||
// } catch (Exception e) {
|
||
// throw new RuntimeException(e);
|
||
// }
|
||
// return response;
|
||
//}
|
||
|
||
|
||
/**
|
||
* 获取订单列表
|
||
*
|
||
* @param start 开始时间
|
||
* @param end 结束时间
|
||
* @return
|
||
* @throws Exception
|
||
*/
|
||
public UnionOpenOrderRowQueryResponse getUnionOpenOrderRowQueryResponse(LocalDateTime start, LocalDateTime end, Integer pageIndex, String appKey, String secretKey) throws Exception {
|
||
String startTime = start.format(DATE_TIME_FORMATTER);
|
||
String endTime = end.format(DATE_TIME_FORMATTER);
|
||
// 模拟 API 调用
|
||
//System.out.println("调用API - 从 " + startTime
|
||
// + " 到 " + endTime);
|
||
// 实际的 API 调用逻辑应在这里进行
|
||
JdClient client = new DefaultJdClient(SERVER_URL, ACCESS_TOKEN, appKey, secretKey);
|
||
UnionOpenOrderRowQueryRequest request = new UnionOpenOrderRowQueryRequest();
|
||
OrderRowReq orderReq = new OrderRowReq();
|
||
orderReq.setPageIndex(pageIndex);
|
||
orderReq.setPageSize(200);
|
||
orderReq.setStartTime(startTime);
|
||
orderReq.setEndTime(endTime);
|
||
orderReq.setType(1);
|
||
|
||
|
||
request.setOrderReq(orderReq);
|
||
request.setVersion("1.0");
|
||
request.setSignmethod("md5");
|
||
// 时间戳，格式为yyyy-MM-dd HH:mm:ss，时区为GMT+8。API服务端允许客户端请求最大时间误差为10分钟
|
||
Date date = new Date();
|
||
SimpleDateFormat simpleDateFormat = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
|
||
request.setTimestamp(simpleDateFormat.format(date));
|
||
|
||
|
||
return client.execute(request);
|
||
}
|
||
|
||
/**
|
||
* 接口描述：通过商品链接、领券链接、活动链接获取普通推广链接或优惠券二合一推广链接
|
||
* jd.union.open.promotion.bysubunionid.get
|
||
*/
|
||
String transfer(String url) throws Exception {
|
||
JdClient client = new DefaultJdClient(SERVER_URL, ACCESS_TOKEN, LPF_APP_KEY_DG, LPF_SECRET_KEY_DG);
|
||
|
||
UnionOpenPromotionBysubunionidGetRequest request = new UnionOpenPromotionBysubunionidGetRequest();
|
||
PromotionCodeReq promotionCodeReq = new PromotionCodeReq();
|
||
request.setPromotionCodeReq(promotionCodeReq);
|
||
request.setVersion("1.0");
|
||
UnionOpenPromotionBysubunionidGetResponse response = client.execute(request);
|
||
|
||
/**
|
||
* {
|
||
* "jd_union_open_promotion_bysubunionid_get_responce": {
|
||
* "getResult": {
|
||
* "code": "200",
|
||
* "data": {
|
||
* "clickURL": "https://union-click.jd.com/jdc?e=XXXXXX p=XXXXXXXXXXX",
|
||
* "weChatShortLink": "#小程序://京小街/****",
|
||
* "jShortCommand": "短口令",
|
||
* "shortURL": "https://u.jd.com/XXXXX",
|
||
* "jCommand": "6.0复制整段话 http://JhT7V5wlKygHDK京口令内容#J6UFE5iMn***"
|
||
* },
|
||
* "message": "success"
|
||
* }
|
||
* }
|
||
* }
|
||
* */
|
||
String result = "";
|
||
if (Util.isNotEmpty(response)) {
|
||
if (response.getCode().equals("200")) {
|
||
result = response.getGetResult().getData().getShortURL();
|
||
}
|
||
} else {
|
||
result = null;
|
||
}
|
||
|
||
return result;
|
||
}
|
||
|
||
@Setter
|
||
@Getter
|
||
public static class OrderInfo {
|
||
private String skuName;
|
||
private Long count;
|
||
private Long orderId;
|
||
private Date orderDate;
|
||
}
|
||
|
||
/**
|
||
*
|
||
* 消毒柜部分的业务逻辑
|
||
*
|
||
*
|
||
* */
|
||
@Scheduled(fixedRate = 60000) // 每分钟执行一次
|
||
public void cleanUpTimeoutStates() {
|
||
LocalDateTime now = LocalDateTime.now();
|
||
redisTemplate.keys(INTERACTION_STATE_PREFIX + "*").forEach(key -> {
|
||
String stateJson = redisTemplate.opsForValue().get(key);
|
||
try {
|
||
UserInteractionState state = objectMapper.readValue(stateJson, UserInteractionState.class);
|
||
LocalDateTime lastInteractionTime = LocalDateTime.parse(state.getLastInteractionTime(), DATE_TIME_FORMATTER);
|
||
if (ChronoUnit.MINUTES.between(lastInteractionTime, now) > TIMEOUT_MINUTES) {
|
||
redisTemplate.delete(key);
|
||
logger.debug("Deleted timeout state for key: {}", key);
|
||
}
|
||
} catch (Exception e) {
|
||
logger.error("Error parsing interaction state: {}", e.getMessage());
|
||
}
|
||
});
|
||
}
|
||
|
||
|
||
public void handleUserInteraction(String fromWxid, String message) {
|
||
String key = INTERACTION_STATE_PREFIX + fromWxid;
|
||
String stateJson = redisTemplate.opsForValue().get(key);
|
||
UserInteractionState state;
|
||
if (stateJson == null) {
|
||
state = new UserInteractionState();
|
||
logger.debug("New interaction state created for user: {}", fromWxid);
|
||
} else {
|
||
try {
|
||
state = objectMapper.readValue(stateJson, UserInteractionState.class);
|
||
// 检查是否超时
|
||
LocalDateTime now = LocalDateTime.now();
|
||
LocalDateTime lastInteractionTime = LocalDateTime.parse(state.getLastInteractionTime(), DATE_TIME_FORMATTER);
|
||
if (ChronoUnit.MINUTES.between(lastInteractionTime, now) > TIMEOUT_MINUTES) {
|
||
redisTemplate.delete(key);
|
||
logger.debug("Deleted timeout state for user: {}", fromWxid);
|
||
state = new UserInteractionState();
|
||
}
|
||
} catch (Exception e) {
|
||
logger.error("Error parsing interaction state: {}", e.getMessage());
|
||
state = new UserInteractionState();
|
||
}
|
||
}
|
||
state.updateLastInteractionTime();
|
||
|
||
switch (state.getCurrentState()) {
|
||
case "INIT":
|
||
if ("登记".equals(message)) {
|
||
// 开始登记新的订单
|
||
state.setCurrentState("DISINFECTANT_CABINET");
|
||
state.setCurrentField("orderId");
|
||
wxUtil.sendTextMessage(fromWxid, "请输入订单号：", 1, fromWxid);
|
||
logger.debug("User {} entered DISINFECTANT_CABINET state", fromWxid);
|
||
}
|
||
break;
|
||
case "DISINFECTANT_CABINET":
|
||
if ("退出".equals(message)) {
|
||
state.setCurrentState("INIT");
|
||
wxUtil.sendTextMessage(fromWxid, "退出登记", 1, fromWxid);
|
||
logger.debug("User {} exited DISINFECTANT_CABINET state", fromWxid);
|
||
} else {
|
||
state.getCollectedFields().put(state.getCurrentField(), message);
|
||
if (state.getCurrentField().equals("orderId")) {
|
||
state.setCurrentField("recipientName");
|
||
wxUtil.sendTextMessage(fromWxid, "请输入收件人姓名：", 1, fromWxid);
|
||
} else if (state.getCurrentField().equals("recipientName")) {
|
||
state.setCurrentField("recipientPhone");
|
||
wxUtil.sendTextMessage(fromWxid, "请输入收件人电话：", 1, fromWxid);
|
||
} else if (state.getCurrentField().equals("recipientPhone")) {
|
||
// 所有字段收集完毕，保存订单
|
||
saveProductOrder(state.getCollectedFields());
|
||
state.setCurrentState("INIT");
|
||
wxUtil.sendTextMessage(fromWxid, "订单已登记", 1, fromWxid);
|
||
logger.debug("User {} completed order registration", fromWxid);
|
||
}
|
||
}
|
||
break;
|
||
default:
|
||
wxUtil.sendTextMessage(fromWxid, "无效的状态，请重新开始对话", 1, fromWxid);
|
||
state.setCurrentState("INIT");
|
||
logger.debug("User {} reset to INIT state due to invalid state", fromWxid);
|
||
break;
|
||
}
|
||
|
||
try {
|
||
redisTemplate.opsForValue().set(key, objectMapper.writeValueAsString(state), TIMEOUT_MINUTES, TimeUnit.MINUTES);
|
||
logger.debug("Saved interaction state for user {}: {}", fromWxid, state);
|
||
} catch (Exception e) {
|
||
logger.error("Error saving interaction state: {}", e.getMessage());
|
||
}
|
||
}
|
||
private void saveProductOrder(Map<String, String> fields) {
|
||
// 创建 ProductOrder 对象并保存到数据库
|
||
ProductOrder productOrder = new ProductOrder();
|
||
productOrder.setOrderId(fields.get("orderId"));
|
||
productOrder.setOrderTime(new Date());
|
||
productOrder.setRecipientName(fields.get("recipientName"));
|
||
// 设置其他字段...
|
||
|
||
// 保存到数据库
|
||
productOrderRepository.save(productOrder);
|
||
logger.debug("Saved product order: {}", productOrder);
|
||
}
|
||
|
||
|
||
|
||
}
|