package cn.lili.job;


import cn.lili.modules.member.entity.dos.Member;
import cn.lili.modules.member.entity.dos.MemberAddress;
import cn.lili.modules.member.mapper.MemberAddressMapper;
import cn.lili.modules.member.mapper.MemberMapper;
import cn.lili.modules.member.service.MemberService;
import com.baomidou.mybatisplus.extension.conditions.query.LambdaQueryChainWrapper;
import com.xxl.job.core.context.XxlJobHelper;
import com.xxl.job.core.handler.annotation.XxlJob;
import lombok.RequiredArgsConstructor;
import org.apache.commons.collections.CollectionUtils;
import org.springframework.stereotype.Component;

import java.util.ArrayList;
import java.util.List;
import java.util.Map;
import java.util.stream.Collectors;

/**
 * lmk-shop-java
 * 会员相关任务
 * @author : zxl
 * @date : 2025-09-04 16:49
 **/

@Component
@RequiredArgsConstructor
public class MemberJob {

    private final MemberMapper memberMapper;
    private final MemberService memberService;

    private final MemberAddressMapper memberAddressMapper;
    /**
     * 每日任务同步用户地址
     *
     * @throws Exception
     */
    @XxlJob("everyDayExecuteJobHandlerAsyncMemberAddress")
    public void everyDayExecuteJobHandlerAsyncMemberAddress() throws Exception {
        XxlJobHelper.log("开始执行每日任务：会员地址同步");
        List<Member> updateList = new ArrayList<>();
        List<Member> list = new LambdaQueryChainWrapper<>(memberMapper)
                // 查询region为空的记录
                .and(wrapper -> wrapper
                        .isNull(Member::getRegion)  // region 为 NULL
                        .or()                       // 或者
                        .eq(Member::getRegion, "")  // region 为空字符串
                )
                .and(wrapper -> wrapper
                        .isNull(Member::getRegionId)  // region_id 为 NULL
                        .or()                         // 或者
                        .eq(Member::getRegionId, "")  // region_id 为空字符串
                )
                .eq(Member::getDeleteFlag,Boolean.FALSE)
                .list();
        if (CollectionUtils.isNotEmpty(list)) {
            List<String> memberIds = list.stream().map(Member::getId).collect(Collectors.toList());
            if (CollectionUtils.isNotEmpty(memberIds)) {
                List<MemberAddress> addresses = new LambdaQueryChainWrapper<>(memberAddressMapper)
                        .in(MemberAddress::getMemberId, memberIds) // 查询指定 memberIds 的地址
                        .eq(MemberAddress::getDeleteFlag, Boolean.FALSE) // 逻辑删除字段，假设 0 表示未删除
                        .orderByDesc(MemberAddress::getIsDefault) // 优先返回默认地址（is_default=1 的排在前面）
                        .orderByDesc(MemberAddress::getCreateTime) // 然后按时间降序排列
                        .list();
                Map<String, MemberAddress> firstAddressByMember = addresses.stream()
                        .collect(Collectors.toMap(
                                MemberAddress::getMemberId,
                                address -> address,
                                (existing, replacement) -> existing // 如果已有该 member 的地址，保留第一个（由于排序，第一个就是优先级最高的）
                        ));
                for (Member member : list) {
                    MemberAddress address = firstAddressByMember.get(member.getId());
                    if (address != null) {
                        member.setRegion(address.getConsigneeAddressPath());
                        member.setRegionId(address.getConsigneeAddressIdPath());
                        updateList.add(member);
                    } else {
                        // 可选：处理无地址的情况（如日志记录、跳过更新等）
                        XxlJobHelper.log("会员{}没有对应的地址记录，不更新region信息", member.getId());
                    }
                }
                System.out.println("打印需要修改的集合--------------------");
                System.out.println(updateList);
                memberService.updateBatchById(list);

            }


        }

        // 修改
        XxlJobHelper.log("执行完成：会员地址同步完成");
    }

}