OrderServiceImpl.java

package cn.wisenergy.service.app.impl;

import cn.hutool.json.JSONUtil;
import cn.wisenergy.common.constant.CommonAttributes;
import cn.wisenergy.common.utils.R;
import cn.wisenergy.mapper.OrderMapper;
import cn.wisenergy.mapper.RecommendUserMapper;
import cn.wisenergy.mapper.UsersMapper;
import cn.wisenergy.model.app.OrderInfo;
import cn.wisenergy.model.app.RecommendUser;
import cn.wisenergy.model.dto.OrderInfoQuery;
import cn.wisenergy.service.app.OrderService;
import com.alibaba.fastjson.JSON;
import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
import com.github.pagehelper.PageInfo;
import com.google.common.collect.Ordering;
import com.xxl.job.core.handler.annotation.XxlJob;
import com.youzan.cloud.open.sdk.common.exception.SDKException;
import com.youzan.cloud.open.sdk.core.client.auth.Token;
import com.youzan.cloud.open.sdk.core.client.core.DefaultYZClient;
import com.youzan.cloud.open.sdk.core.oauth.model.OAuthToken;
import com.youzan.cloud.open.sdk.core.oauth.token.TokenParameter;
import com.youzan.cloud.open.sdk.gen.v4_0_0.model.YouzanTradesSoldGetResult;
import com.youzan.cloud.open.sdk.gen.v4_0_1.api.YouzanTradesSoldGet;
import com.youzan.cloud.open.sdk.gen.v4_0_1.model.YouzanTradesSoldGetParams;
import lombok.extern.slf4j.Slf4j;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;

import java.io.*;
import java.math.BigDecimal;
import java.text.ParseException;
import java.text.SimpleDateFormat;
import java.util.ArrayList;
import java.util.Date;
import java.util.HashMap;
import java.util.List;

/**
 * @author zw
 * @ Description: 定期获取有赞订单数据及更新订单状态
 * @ Author     : zw
 * @ Date       : 2021/2/22 17:06
 */

@Service
@Slf4j
public class OrderServiceImpl extends ServiceImpl<OrderMapper, OrderInfo> implements OrderService {

    @Autowired
    private OrderMapper orderMapper;

    @Autowired
    private UsersMapper usersMapper;

    @Autowired
    private RecommendUserMapper recommendUserMapper;
    //有赞客户端
    DefaultYZClient yzClient = new DefaultYZClient();
    SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
    Date startCreatedDate = null;
    Date endCreatedDate = null;
    Date startUpdateDate = null;
    Date endUpdateDate = null;
//    Date date = new Date();

    /**
     * 根据订单的创建时间获取有赞的订单数据 插入本地数据库
     *
     * @return
     * @throws SDKException
     */
    @XxlJob(value = "YouZanOrdersjobhandler")
    @Override
    public void getYouZanOrdersForCreateTime() throws SDKException {
        Date date = new Date();
        Token token = youzanToken();
        YouzanTradesSoldGet youzanTradesSoldGet = new YouzanTradesSoldGet();
        //创建参数对象,并设置参数
        YouzanTradesSoldGetParams youzanTradesSoldGetParams = new YouzanTradesSoldGetParams();
        OrderInfo orderInfo = new OrderInfo();
        try {
//            startCreatedDate = sdf.parse("2021-01-28 11:04:01");
//            endCreatedDate = sdf.parse("2021-03-1 16:39:59");
            //当前时间的前1分钟
            startCreatedDate = sdf.parse(sdf.format(new Date(date.getTime() - (long) 5 * 60 * 1000)));
            log.info("订单创建开始时间" + sdf.format(startCreatedDate));
            endCreatedDate = sdf.parse(sdf.format(date));

            String format = sdf.format(date);
            log.info("订单创建结束时间" + sdf.format(endCreatedDate));
        } catch (ParseException e) {
            e.printStackTrace();
        }
        //设置查询条件 --> 根据订单创建时间获取
        youzanTradesSoldGetParams.setStartCreated(startCreatedDate);
        youzanTradesSoldGetParams.setEndCreated(endCreatedDate);
        youzanTradesSoldGet.setAPIParams(youzanTradesSoldGetParams);
        //执行查询
        YouzanTradesSoldGetResult result = yzClient.invoke(youzanTradesSoldGet, token, YouzanTradesSoldGetResult.class);
        List<YouzanTradesSoldGetResult.YouzanTradesSoldGetResultFullorderinfolist> fullOrderInfoList = result.getData().getFullOrderInfoList();
        //遍历订单数据
        for (YouzanTradesSoldGetResult.YouzanTradesSoldGetResultFullorderinfolist youzanTradesSoldGetResultFullorderinfolist : fullOrderInfoList) {

            YouzanTradesSoldGetResult.YouzanTradesSoldGetResultBuyerinfo buyerInfo = youzanTradesSoldGetResultFullorderinfolist.getFullOrderInfo().getBuyerInfo();
            List<YouzanTradesSoldGetResult.YouzanTradesSoldGetResultOrders> orders = youzanTradesSoldGetResultFullorderinfolist.getFullOrderInfo().getOrders();
            YouzanTradesSoldGetResult.YouzanTradesSoldGetResultOrderinfo youzanOrderInfo = youzanTradesSoldGetResultFullorderinfolist.getFullOrderInfo().getOrderInfo();
            YouzanTradesSoldGetResult.YouzanTradesSoldGetResultPayinfo payInfo = youzanTradesSoldGetResultFullorderinfolist.getFullOrderInfo().getPayInfo();

            //item_id 字段 处理
            List<String> itemList = new ArrayList<>();
            for (YouzanTradesSoldGetResult.YouzanTradesSoldGetResultOrders order : orders) {
                String itemId = order.getItemId().toString();
                itemList.add(itemId);
            }

            orderInfo.setItemId(itemList.toString());
            //有赞的outer_user_id 与有赞的对应关系是邀请码 邀请码唯一
            String outerUserId = buyerInfo.getOuterUserId();
            log.info("有赞返回OutUserId------------" + outerUserId);
            String userId = usersMapper.getUserIdByIntiveCode(outerUserId);
            log.info("对应西田森系统中的用户Id--------" + userId);
            orderInfo.setUserId(userId);
            //支付方式
            orderInfo.setPayType(youzanOrderInfo.getPayType().toString());
            //有赞update_time
            orderInfo.setYouzanUpdateTime(youzanOrderInfo.getUpdateTime());
            //tid
            orderInfo.setTid(youzanOrderInfo.getTid());
            //created 订单创建时间
            orderInfo.setCreated(youzanOrderInfo.getCreated());
            //team_type  店铺类型
            orderInfo.setTeamType(youzanOrderInfo.getTeamType());
            //pay_time
            orderInfo.setPayTime(youzanOrderInfo.getPayTime());
            //pay_type_str 支付渠道
            orderInfo.setPayTypeStr(youzanOrderInfo.getPayTypeStr());
            //close_type
            orderInfo.setCloseType(youzanOrderInfo.getCloseType().intValue());
            //refund_state 退款状态
            orderInfo.setRefundState(youzanOrderInfo.getRefundState());
            //success_time
            orderInfo.setSuccessTime(youzanOrderInfo.getSuccessTime());
            //payment
            orderInfo.setPayment(new BigDecimal(payInfo.getPayment()));
            //当前订单所对应的用户直推表当月消费  累计消费字段累加
            RecommendUser recommendUserMapperByUserId = recommendUserMapper.getByUserId(userId);
            if (null != recommendUserMapperByUserId){
                //历史消费
                BigDecimal historyCount = recommendUserMapperByUserId.getHistoryCount();

                //当月消费
                BigDecimal monthyCount = recommendUserMapperByUserId.getMonthyCount();

                recommendUserMapperByUserId.setHistoryCount(historyCount.add(new BigDecimal(payInfo.getPayment())));
                recommendUserMapperByUserId.setMonthyCount(monthyCount.add(new BigDecimal(payInfo.getPayment())));

                recommendUserMapper.updateById(recommendUserMapperByUserId);
            }
            //rebate_status  返佣状态
            orderInfo.setRebateStatus(0);
            //level_status  升级状态
            orderInfo.setLevelStatus(0);
            //month_order_status  //当月订单处理状态
            orderInfo.setMonthOrderStatus(0);
            //monthly_task_status  //月度任务处理状态
            orderInfo.setMonthlyTaskStatus(0);
            log.info("根据创建时间获取有赞订单号：" + youzanOrderInfo.getTid());
            orderMapper.insertYouZanOrders(orderInfo);
        }
    }

    /**
     * 根据订单的修改时间获取有赞的订单数据 修改本地数据库的相关订单数据
     *
     * @return
     * @throws SDKException
     */
    @XxlJob(value = "YouZanOrdersForUpdateTimejobhandler")
    @Override
    public void getYouZanOrdersForUpdateTime() throws SDKException {
        Date date = new Date();
        Token token = youzanToken();
        YouzanTradesSoldGet youzanTradesSoldGet = new YouzanTradesSoldGet();
        //创建参数对象,并设置参数
        YouzanTradesSoldGetParams youzanTradesSoldGetParams = new YouzanTradesSoldGetParams();
        OrderInfo orderInfo = new OrderInfo();
        try {
//            startUpdateDate = sdf.parse("2021-02-28 11:04:01");
//            endUpdateDate = sdf.parse("2021-03-2 16:39:59");
            startUpdateDate = sdf.parse(sdf.format(new Date(date.getTime() - (long) 5 * 60 * 1000)));
            log.info("订单修改开始时间" + sdf.format(startUpdateDate));
            endUpdateDate = sdf.parse(sdf.format(date));
            log.info("订单修改结束时间" + sdf.format(endUpdateDate));
        } catch (ParseException e) {
            e.printStackTrace();
        }
        //设置查询条件 --> 根据订单修改时间获取
        youzanTradesSoldGetParams.setStartUpdate(startUpdateDate);
        youzanTradesSoldGetParams.setEndUpdate(endUpdateDate);
        youzanTradesSoldGet.setAPIParams(youzanTradesSoldGetParams);
        //调用有赞客户端进行查询
        YouzanTradesSoldGetResult result = yzClient.invoke(youzanTradesSoldGet, token, YouzanTradesSoldGetResult.class);
        List<YouzanTradesSoldGetResult.YouzanTradesSoldGetResultFullorderinfolist> fullOrderInfoList = result.getData().getFullOrderInfoList();
        //遍历订单数据
        for (YouzanTradesSoldGetResult.YouzanTradesSoldGetResultFullorderinfolist youzanTradesSoldGetResultFullorderinfolist : fullOrderInfoList) {
            YouzanTradesSoldGetResult.YouzanTradesSoldGetResultOrderinfo youzanOrderInfo = youzanTradesSoldGetResultFullorderinfolist.getFullOrderInfo().getOrderInfo();
            YouzanTradesSoldGetResult.YouzanTradesSoldGetResultPayinfo payInfo = youzanTradesSoldGetResultFullorderinfolist.getFullOrderInfo().getPayInfo();

            //根据修改时间获取到的有赞订单数据的Tid
            String tid = youzanOrderInfo.getTid();
            OrderInfo orderByTid = orderMapper.getByTid(tid);

            //确保是同一笔订单且订单的success_time=null是进行订单success_time状态修改
            if (orderByTid != null && orderByTid.getSuccessTime() == null) {
                //支付方式
                orderInfo.setPayType(youzanOrderInfo.getPayType().toString());
                //有赞update_time
                orderInfo.setYouzanUpdateTime(youzanOrderInfo.getUpdateTime());
                //tid
                orderInfo.setTid(youzanOrderInfo.getTid());
                //pay_time
                orderInfo.setPayTime(youzanOrderInfo.getPayTime());
                //pay_type_str 支付渠道
                orderInfo.setPayTypeStr(youzanOrderInfo.getPayTypeStr());
                //close_type
                orderInfo.setCloseType(youzanOrderInfo.getCloseType().intValue());
                //refund_state 退款状态
                orderInfo.setRefundState(youzanOrderInfo.getRefundState());
                //success_time
                orderInfo.setSuccessTime(youzanOrderInfo.getSuccessTime());
                //payment
                orderInfo.setPayment(new BigDecimal(payInfo.getPayment()));

                log.info("根据修改时间获取有赞订单号：" + youzanOrderInfo.getTid());
                //修改订单数据
                orderMapper.updateById(orderInfo);
            }
        }
    }

    /**
     * 有赞token获取
     *
     * @return
     * @throws SDKException
     */
    public static Token youzanToken() throws SDKException {
        DefaultYZClient yzClient = new DefaultYZClient();
        TokenParameter tokenParameter = TokenParameter.self()
                .clientId("92bc1c500ce7c248f3")
                .clientSecret("3d65e88f5106e8ee78dbc5cf5ff45526")
                .grantId("92488799")
                .refresh(true)
                .build();
        OAuthToken oAuthToken = yzClient.getOAuthToken(tokenParameter);
        String accessToken = oAuthToken.getAccessToken();
        log.info("调用有赞接口获取到的有赞Token" + accessToken);

        Token youzanToken = new Token(accessToken);
        return youzanToken;
    }

    /**
     * 分页查询订单数据
     *
     * @return
     */
    @Override
    public R<PageInfo<OrderInfo>> findByPage(OrderInfoQuery query) {
        log.info("shop-mall[]OrderServiceImpl[]findByPage[]input.param.query:" + query);
        if (null == query){
            return R.error("入参不能为空");
        }
        pageHandle(query);
        HashMap<String, Object> map = new HashMap<>();
        int total = orderMapper.count();


        map.put("startNum", query.getStartNum());
        map.put("endNum", query.getEndNum());
        if(null != query.getUserId()){
            map.put("userId",query.getUserId());
        }
        List<OrderInfo> list = orderMapper.findByPage(map);
        PageInfo<OrderInfo> info = new PageInfo<>();
        info.setPageSize(query.getPageSize());
        info.setPageNum(query.getPageNo());
        info.setTotal(total);
        info.setList(list);
        return R.ok(info);
    }

    /**
     * 分页处理方法
     *
     * @param schemeVo 参数
     */
    private void pageHandle(OrderInfoQuery schemeVo) {
        Integer pageNum = schemeVo.getPageNo();
        Integer pageSize = schemeVo.getPageSize();
        if (null == pageSize || pageSize == 0) {
            pageSize = 10;
        }
        if (null == pageNum || pageNum == 0) {
            pageNum = 1;
        }
        Integer endNum = pageSize;
        Integer startNum = (pageNum - CommonAttributes.NUM_ONE) * pageSize;
        schemeVo.setEndNum(endNum);
        schemeVo.setStartNum(startNum);
        schemeVo.setPageNo(pageNum);
        schemeVo.setPageSize(pageSize);
    }

//    //获取本地json文件进行测试
//    @Override
//    public void orderJSON() {
//
//        String path = "G:\\workmms\\shop-mall\\wisenergy-web-admin\\src\\main\\resources\\templates\\orderJson.json";
////        String path = JSONUtil.class.getClassLoader().getResource("G:\\workmms\\shop-mall\\wisenergy-web-admin\\src\\main\\resources\\templates\\orderJson.json").getPath();
//        String orderJSON = readJsonFile(path);
//
//        YouzanTradesSoldGetResult youzanTradesSoldGetResult = JSON.parseObject(orderJSON, YouzanTradesSoldGetResult.class);
//        List<YouzanTradesSoldGetResult.YouzanTradesSoldGetResultFullorderinfolist> fullOrderInfoList = youzanTradesSoldGetResult.getData().getFullOrderInfoList();
//
//        OrderInfo orderInfo = new OrderInfo();
//        for (YouzanTradesSoldGetResult.YouzanTradesSoldGetResultFullorderinfolist youzanTradesSoldGetResultFullorderinfolist : fullOrderInfoList) {
//
//            YouzanTradesSoldGetResult.YouzanTradesSoldGetResultBuyerinfo buyerInfo = youzanTradesSoldGetResultFullorderinfolist.getFullOrderInfo().getBuyerInfo();
//            List<YouzanTradesSoldGetResult.YouzanTradesSoldGetResultOrders> orders = youzanTradesSoldGetResultFullorderinfolist.getFullOrderInfo().getOrders();
//            YouzanTradesSoldGetResult.YouzanTradesSoldGetResultOrderinfo youzanOrderInfo = youzanTradesSoldGetResultFullorderinfolist.getFullOrderInfo().getOrderInfo();
//            YouzanTradesSoldGetResult.YouzanTradesSoldGetResultPayinfo payInfo = youzanTradesSoldGetResultFullorderinfolist.getFullOrderInfo().getPayInfo();
//
//            //item_id 字段 处理
//            List<String> itemList = new ArrayList<>();
//            for (YouzanTradesSoldGetResult.YouzanTradesSoldGetResultOrders order : orders) {
//                String itemId = order.getItemId().toString();
//                itemList.add(itemId);
//            }
//
//            orderInfo.setItemId(itemList.toString());
//            //有赞的outer_user_id 与有赞的对应关系是邀请码 邀请码唯一
//            String outerUserId = buyerInfo.getOuterUserId();
//            log.info("有赞返回OutUserId------------" + outerUserId);
//            String userId = usersMapper.getUserIdByIntiveCode(outerUserId);
//            log.info("对应西田森系统中的用户Id--------" + userId);
//            orderInfo.setUserId(userId);
//            //支付方式
//            orderInfo.setPayType(youzanOrderInfo.getPayType().toString());
//            //有赞update_time
//            orderInfo.setYouzanUpdateTime(youzanOrderInfo.getUpdateTime());
//            //tid
//            orderInfo.setTid(youzanOrderInfo.getTid());
//            //created 订单创建时间
//            orderInfo.setCreated(youzanOrderInfo.getCreated());
//            //team_type  店铺类型
//            orderInfo.setTeamType(youzanOrderInfo.getTeamType());
//            //pay_time
//            orderInfo.setPayTime(youzanOrderInfo.getPayTime());
//            //pay_type_str 支付渠道
//            orderInfo.setPayTypeStr(youzanOrderInfo.getPayTypeStr());
//            //close_type
//            orderInfo.setCloseType(youzanOrderInfo.getCloseType().intValue());
//            //refund_state 退款状态
//            orderInfo.setRefundState(youzanOrderInfo.getRefundState());
//            //success_time
//            orderInfo.setSuccessTime(youzanOrderInfo.getSuccessTime());
//            //payment
//            orderInfo.setPayment(new BigDecimal(payInfo.getPayment()));
//            //当前订单所对应的用户直推表当月消费  累计消费字段累加
//            RecommendUser recommendUserMapperByUserId = recommendUserMapper.getByUserId(userId);
//            if (null != recommendUserMapperByUserId){
//                //历史消费
//                BigDecimal historyCount = recommendUserMapperByUserId.getHistoryCount();
//
//                //当月消费
//                BigDecimal monthyCount = recommendUserMapperByUserId.getMonthyCount();
//
//                recommendUserMapperByUserId.setHistoryCount(historyCount.add(new BigDecimal(payInfo.getPayment())));
//                recommendUserMapperByUserId.setMonthyCount(monthyCount.add(new BigDecimal(payInfo.getPayment())));
//
//                recommendUserMapper.updateById(recommendUserMapperByUserId);
//            }
//            //rebate_status  返佣状态
//            orderInfo.setRebateStatus(0);
//            //level_status  升级状态
//            orderInfo.setLevelStatus(0);
//            //month_order_status  //当月订单处理状态
//            orderInfo.setMonthOrderStatus(0);
//            //monthly_task_status  //月度任务处理状态
//            orderInfo.setMonthlyTaskStatus(0);
//            log.info("根据创建时间获取有赞订单号：" + youzanOrderInfo.getTid());
//            orderMapper.insertYouZanOrders(orderInfo);
//        }
//    }
//
//
//    /**
//     * 读取json文件，返回json串
//     * @param fileName
//     * @return
//     */
//    public static String readJsonFile(String fileName) {
//        String jsonStr = "";
//        try {
//            File jsonFile = new File(fileName);
//            FileReader fileReader = new FileReader(jsonFile);
//
//            Reader reader = new InputStreamReader(new FileInputStream(jsonFile),"utf-8");
//            int ch = 0;
//            StringBuffer sb = new StringBuffer();
//            while ((ch = reader.read()) != -1) {
//                sb.append((char) ch);
//            }
//            fileReader.close();
//            reader.close();
//            jsonStr = sb.toString();
//            return jsonStr;
//        } catch (IOException e) {
//            e.printStackTrace();
//            return null;
//        }
//    }

}