eccs/eccs-biz/src/main/java/com/emato/biz/service/impl/SalesDetaiServicelImpl.java

package com.emato.biz.service.impl;

import com.alibaba.fastjson.JSON;
import com.alibaba.fastjson.JSONObject;
import com.emato.biz.domain.OmsUtils;
import com.emato.biz.domain.OperateLogDTO;
import com.emato.biz.domain.OutRequest;
import com.emato.biz.domain.mall.*;
import com.emato.biz.domain.merchant.MerchantSecret;
import com.emato.biz.exception.Assert;
import com.emato.biz.mapper.mall.InventoryDataMapper;
import com.emato.biz.mapper.mall.MallMngChangeMapper;
import com.emato.biz.mapper.mall.SalesDetailMapper;
import com.emato.biz.mapper.merchant.MerchantSecretMapper;
import com.emato.biz.service.SignService;
import com.emato.biz.service.mall.ISalesDetaiServicel;
import com.emato.biz.util.DateUtil;
import com.emato.biz.util.MatchUtil;
import com.emato.common.core.Result;
import com.emato.common.exception.CustomException;
import com.emato.common.exception.ServiceException;
import com.emato.common.utils.DateUtils;
import com.emato.common.utils.StringUtils;
import com.emato.common.utils.oms.response.ResultCodeEnum;
import com.emato.common.utils.sign.Md5Utils;
import com.emato.system.mapper.SysConfigMapper;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.beans.BeanUtils;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;

import javax.annotation.Resource;
import javax.servlet.http.HttpServletRequest;
import java.sql.*;
import java.util.ArrayList;
import java.util.Date;
import java.util.HashMap;
import java.util.List;
import java.util.Map;
import java.util.stream.Collectors;

/**
 * CW推送数据接口
 */
@Service
public class SalesDetaiServicelImpl implements ISalesDetaiServicel {


    private final Logger logger = LoggerFactory.getLogger(SalesDetaiServicelImpl.class);

    @Resource
    private InventoryDataMapper inventoryDataMapper;
    @Resource
    private MallMngChangeMapper mallMngChangeMapper;
    @Autowired
    private SysConfigMapper configMapper;
    @Resource
    private MerchantSecretMapper merchantSecretMapper;
    @Autowired
    private OmsUtils omsUtils;

    @Resource
    private SalesDetailMapper salesDetailMapper;

    @Autowired
    private SignService signService;

    /**
     * 记录请求日志
     *
     * @param reqData
     * @param merchantSn
     */
    @Override
    public void insertReqLog(String reqData, String merchantSn) {
        try {
            OperateLogDTO operateLogDTO = new OperateLogDTO();
            operateLogDTO.setReqData(reqData);
            operateLogDTO.setMerchSn(merchantSn);
            salesDetailMapper.insertSalesDataReqLog(operateLogDTO);
        } catch (Exception e) {
            logger.error("记录商户请求日志异常", e);
            throw new ServiceException("系统异常，请稍后再试!");
        }
    }

    /**
     * 获取销售数据
     *
     * @param outRequest
     * @return
     */
    @Override
    public Result getSalesDetailData(OutRequest outRequest) {
        try {
            logger.info("---------- 查询销售数据开始 ----------");
            logger.info("========== 电商请求 eccs 报文 =========> {}", outRequest);
            // 验签
            Assert.notTrue(!signService.verifySign(outRequest), ResultCodeEnum.SIGN_ERROR);
            // 转为请求类
            SalesDataReqVO reqVO = JSON.parseObject(outRequest.getData(), SalesDataReqVO.class);
            logger.debug("========== 解析后的请求数据 ==========> 【{}】", reqVO);
            // 分页页码
            String pageIndexStr = reqVO.getPageIndex();
            // 分页大小
            String pageSizeStr = reqVO.getPageSize();
            // 起始时间戳
            String startTimeTimeStamp = reqVO.getStarTime();
            // 起始时间戳
            String endTimeTimeStamp = reqVO.getEndTime();

            // 参数校验
            Assert.notNull(pageIndexStr, ResultCodeEnum.PARAM_ERROR_PAGE_INDEX_NOT_NULL);
            Assert.notNull(pageSizeStr, ResultCodeEnum.PARAM_ERROR_PAGE_SIZE_NOT_NULL);
            Assert.notTrue(!MatchUtil.isPositiveInteger(pageIndexStr), ResultCodeEnum.PARAM_ERROR_PAGE_INDEX_NOT_POS_INT);
            Assert.notTrue(!MatchUtil.isPositiveInteger(pageSizeStr), ResultCodeEnum.PARAM_ERROR_PAGE_SIZE_NOT_POS_INT);
            Assert.notTrue(!MatchUtil.isTimestamp(reqVO.getStarTime()), ResultCodeEnum.PARAM_ERROR_START_TIME_NOT_TIMES_STAMP);
            Assert.notTrue(!MatchUtil.isTimestamp(reqVO.getEndTime()), ResultCodeEnum.PARAM_ERROR_END_TIME_NOT_TIMES_STAMP);

            // 计算起始时间和结束时间相差多少小时,
            long hourBetweenTimesStamp = DateUtil.getHourBetweenTimesStamp(startTimeTimeStamp, endTimeTimeStamp);
            Assert.notTrue(hourBetweenTimesStamp > 24, ResultCodeEnum.TIME_INTERVAL_TOO_LARGE);

            // 分页大小
            int pageSize = Integer.parseInt(pageSizeStr);
            // 大于500就取500，否则取 pageSize
            pageSize = Math.min(pageSize, 500);

            int pageIndex = Integer.parseInt(pageIndexStr);
            // 小于1就取1，否则取 pageIndex
            pageIndex = Math.max(pageIndex, 1);
            pageIndex = (pageIndex - 1) * pageSize;

            // 格式化起始时间
            String startTime = DateUtil.dateFormat(startTimeTimeStamp, "yyyy-MM-dd HH:mm:ss");
            // 格式化结束时间
            String endTime = DateUtil.dateFormat(endTimeTimeStamp, "yyyy-MM-dd HH:mm:ss");

            // 设置查询条件
            reqVO.setOffset(pageIndex);
            reqVO.setLimit(pageSize);
            reqVO.setStarTime(startTime);
            reqVO.setEndTime(endTime);

            // 查询销售数据
            List<NewSystemFormatEntiy> salesDataList = salesDetailMapper.selectSalesDetailData(reqVO);
            Assert.notTrue(salesDataList.isEmpty(), ResultCodeEnum.NO_DATA);

            // 记录查询日志
            insertReqLog(JSON.toJSONString(outRequest), outRequest.getMerchId());


            // 将数据库数据转换为接口输出的数据格式
            List<SalesDataResVO> salesDataVOList = salesDataList.stream().map(salesData -> {
                SalesDataResVO resVO = new SalesDataResVO();
                BeanUtils.copyProperties(salesData, resVO);
                return resVO;
            }).collect(Collectors.toList());

            // 查询总记录数
            int total = salesDetailMapper.selectSalesDetailDataTotal(reqVO);

            // 组装返回数据
            Map<String, Object> resultMap = new HashMap<>();
            resultMap.put("rows", salesDataVOList);
            resultMap.put("total", total);

            logger.info("---------- 查询销售数据结束 ----------");
            return Result.success(resultMap);
        } catch (ServiceException se) {
            throw se;
        } catch (Exception e) {
            logger.error("外部商户获取销售数据异常 => ", e);
            throw new ServiceException("获取销售数据异常，请稍后再试!");
        }
    }

    /**
     * kmall向eccs系统推送数据
     * @param newSystemFormatEntiy
     * @return
     */
    @Override
    public int pushSalesDetaiServicel(NewSystemFormatEntiy newSystemFormatEntiy) {
        logger.debug("---------- Eccs 接收 Kmall 销售数据开始 ----------");
        int rows = 0;
        try {
            // 查询订单查看是否存在
            SalesDataReqVO reqVO = new SalesDataReqVO();
            reqVO.setOrderNo(newSystemFormatEntiy.getReceiptNo());
            List<NewSystemFormatEntiy> salesDataList = salesDetailMapper.selectSalesDetailData(reqVO);

            if (salesDataList.isEmpty()) {
                // 如果不存在, 新增
                // 设置创建人和创建时间
                newSystemFormatEntiy.setCreateSn("admin");
                newSystemFormatEntiy.setCreateTime(new Date());

                rows = salesDetailMapper.insertSalesDetaiDate(newSystemFormatEntiy);
            }else {
                // 如果存在则修改
                // 设置修改人和修改时间
                newSystemFormatEntiy.setModerSn("admin");
                newSystemFormatEntiy.setModTime(new Date());
                rows = salesDetailMapper.updateSalesDetailData(newSystemFormatEntiy);
            }
        } catch (Exception e) {
            logger.error("Eccs 接收 Kmall 销售数据异常 => ", e);
            throw new ServiceException("Eccs 接收 Kmall 销售数据异常!");
        }

        logger.debug("---------- Eccs 接收 Kmall 销售数据结束 ----------");
        return rows;
    }

    /**
     * 外部商户系统查询订单销售数据
     * @param msg
     * @return
     */
    @Override
    public Result getSalesDetaiData(JSONObject msg, HttpServletRequest httpServletRequest) {
        try {
            logger.debug("---------- 处理商户获取销售明细::开始 ----------");
            //校验签名
            Map<String, Object> weChatMapSalesMsg = JSONObject.toJavaObject(msg, Map.class);
            //签名验证
            String strSign = weChatMapSalesMsg.get("sign").toString().trim();
            String merchId = weChatMapSalesMsg.get("merchId").toString().trim()==null?"":weChatMapSalesMsg.get("merchId").toString().trim();
            String timestamp = weChatMapSalesMsg.get("timestamp").toString().trim()==null?"":weChatMapSalesMsg.get("timestamp").toString().trim();

            // String str = configMapper.getConfigValue("salesdetai").trim();

            if(StringUtils.isEmpty(merchId)){
                return Result.error("900051","merchId为空");
            }

            // 改为使用密钥配置
            MerchantSecret merchantSecret = new MerchantSecret();
            merchantSecret.setMerchSn(merchId);

            List<MerchantSecret> merchantSecrets = merchantSecretMapper.selectMerchantSecretList(merchantSecret);
            if (null == merchantSecrets || merchantSecrets.isEmpty()) {
                return Result.error("900051","merchId参数错误");
            }

            MerchantSecret MerchantSecret_2 = merchantSecrets.get(0);
            String str = MerchantSecret_2.getMd5Salt();

            if(StringUtils.isEmpty(timestamp)){
                return Result.error("900051","timestamp为空");
            }

            String md5CheckCode = checkType(weChatMapSalesMsg.get("data").toString(), timestamp, str);
            logger.debug("--- getSalesDetaiData md5CheckCode：", md5CheckCode);

            if (!strSign.trim().equals(md5CheckCode)) {
                return Result.error("900052", "签名错误");
            }

            Map<String, Object> weSalesMsg =  JSONObject.toJavaObject(JSON.parseObject(weChatMapSalesMsg.get("data").toString()), Map.class);

            String starTime = (String) weSalesMsg.get("starTime");
            String endTime = (String) weSalesMsg.get("endTime");
            Integer pageIndex = Integer.parseInt(weSalesMsg.get("pageIndex")+"");
            pageIndex = pageIndex <= 1 ? 1 : pageIndex;

            Integer pageSize = Integer.parseInt(weSalesMsg.get("pageSize")+"");
            pageSize = pageSize <= 0 ? 1 : pageSize;
            pageSize = pageSize >= 500 ? 500 : pageSize;

            weSalesMsg.put("starTime", DateUtils.getStrDate((String) weSalesMsg.get("starTime")));
            weSalesMsg.put("endTime",DateUtils.getStrDate((String)weSalesMsg.get("endTime")));

            if(pageIndex>500){
                return Result.error("900053","请求总数或时间区间过大");
            }
            pageIndex = (pageIndex - 1) * pageSize;
            weSalesMsg.put("offset", pageIndex);
            weSalesMsg.put("limit", pageSize);
                //记录调用参数接口日志
            long diff=(Long.parseLong(endTime) - Long.parseLong(starTime))/1000/60/60;
            if(diff<=24){
                pullQueryData(weChatMapSalesMsg);
                List<NewSystemFormatEntiy> list = mallMngChangeMapper.getSalesDetaiData(weSalesMsg);
                Integer total = mallMngChangeMapper.getTotalRecord(weSalesMsg);
                //desList = DesUtils.encode(JSON.toJSONString(list));
                if(list.size()==0){
                    return Result.error("900054","该条件下无数据");
                }else{
                    Map<String,Object> map = new HashMap<>();
                    map.put("total",total);
                    map.put("rows",list);

                    logger.debug("---------- 处理商户获取销售明细::结束，处理成功 ----------");
                    return Result.success(map);
                }
            }else{
                logger.debug("---------- 处理商户获取销售明细::结束，【900053】请求总数或时间区间过大 ----------");
                return Result.error("900053","请求总数或时间区间过大");
            }

        }catch (Exception e){
            logger.error("外部系统查询订单销售数据错误="+ JSON.toJSONString(msg),e);
            return Result.error("900051","参数错误");
        }

    }

    /**
     * 记录外部调用接口参数，时间和调用方
     * @param msg
     */
    private void pullQueryData(Map msg) {
        Map<String,Object> map = new HashMap<>();
        map.put("tranDirection",msg.get("merchId"));
        map.put("msg",msg.toString());
        mallMngChangeMapper.pullQueryData(map);

    }


    /**
     * 插入来源于oms的库存数据
     * @param inventoryDataVo
     */
    @Override
    public Result inserInventory(InventoryDataVo inventoryDataVo) {
        try{
            logger.error("插入来源于oms的库存数据");
            //查询是否存在该库存信息
            Integer checkStuts = inventoryDataMapper.queryOneInventory(inventoryDataVo);
            if(checkStuts>0){
                inventoryDataMapper.updateInventory(inventoryDataVo);
            }else{
                inventoryDataMapper.inserInventory(inventoryDataVo);
            }
            return Result.success();
        }catch (Exception e){
            logger.error("插入来源于oms的库存数据"+JSON.toJSONString(inventoryDataVo),e);
            return Result.error("1001","数据插入出错");
        }
    }

    /**
     * 查询库存数据提供给外部系统
     * @param msg
     * @param httpServletRequest
     * @return
     */
    @Override
    public Result queryInventory(JSONObject msg, HttpServletRequest httpServletRequest) {
        try{
            logger.debug("---------- 处理商户获取库存数据::开始 ----------");

            //校验签名
            Map<String, Object> weChatMapMsg = JSONObject.toJavaObject(msg, Map.class);
            //签名验证
            String strSign = weChatMapMsg.get("sign").toString().trim();
            String merchId = weChatMapMsg.get("merchId").toString().trim()==null?"":weChatMapMsg.get("merchId").toString().trim();
            String timestamp = weChatMapMsg.get("timestamp").toString().trim()==null?"":weChatMapMsg.get("timestamp").toString().trim();


            // String str = configMapper.getConfigValue("inventory");

            if(StringUtils.isEmpty(merchId)){
                return Result.error("900051","merchId为空");
            }

            // 改为使用密钥配置
            MerchantSecret merchantSecret = new MerchantSecret();
            merchantSecret.setMerchSn(merchId);

            List<MerchantSecret> merchantSecrets = merchantSecretMapper.selectMerchantSecretList(merchantSecret);
            if (null == merchantSecrets || merchantSecrets.isEmpty()) {
                return Result.error("900051","merchId参数错误");
            }

            MerchantSecret MerchantSecret_2 = merchantSecrets.get(0);
            String str = MerchantSecret_2.getMd5Salt();

            if(StringUtils.isEmpty(timestamp)){
                return Result.error("900051","timestamp为空");
            }

            String md5CheckCode = checkType(weChatMapMsg.get("data").toString(), timestamp, str);
            logger.debug("--- queryInventory md5CheckCode：", md5CheckCode);

            if (!strSign.trim().equals(md5CheckCode)) {
                return Result.error("900002", "签名错误");
            }

            Map<String, Object> weDtilMsg =  JSONObject.toJavaObject(JSON.parseObject(weChatMapMsg.get("data").toString()), Map.class);

            Integer pageIndex = Integer.parseInt(weDtilMsg.get("pageIndex")+"");
            pageIndex = pageIndex <= 1 ? 1 : pageIndex;

            Integer pageSize = Integer.parseInt(weDtilMsg.get("pageSize")+"");
            pageSize = pageSize <= 0 ? 1 : pageSize;
            pageSize = pageSize >= 500 ? 500 : pageSize;

            pageIndex = (pageIndex-1)*pageSize;

            weChatMapMsg.put("offset", pageIndex);
            weChatMapMsg.put("limit", pageSize);
            weChatMapMsg.put("merchId", merchId);
            weChatMapMsg.put("sign", strSign);

            String merchSn = weDtilMsg.get("merchSn").toString().trim()==null?"":weDtilMsg.get("merchSn").toString().trim();
            if(merchSn.equals("")){
                return Result.error("900001","参数错误");
            }
            if(pageSize>3000){
                return Result.error("900003","请求数量过大");
            }

            pullQueryData(weChatMapMsg);
            //  数据查询
            //List<InventoryDataPushVo> list = inventoryDataMapper.getInventoryData(weChatMapMsg);
            // todo bug_2023-03-21 此处直接拉取的oms库，需要重新设计
            // todo bug_2023-03-21 虽然拉取数据存疑，但此处拉取出的数据向商户返回，其返回的字段与对外接口已经保持一致
            List<InventoryDataPushVo> list = getOmsData(weDtilMsg,weChatMapMsg);
            // todo bug_2023-03-21 total不正确
            Integer total = inventoryDataMapper.getInventoryTotal();
            if(list.size()==0){
                return Result.error("900004","该条件下无数据");
            }else{
                Map<String,Object> map = new HashMap<>();
                map.put("total",total);
                map.put("invTime",DateUtils.dateToStrLong(new Date()));
                map.put("rows",list);

                logger.debug("---------- 处理商户获取库存数据::结束，处理成功 ----------");
                return Result.success(map);
            }
        }catch (Exception e){
            logger.error("外部系统查询库存系统条件="+JSON.toJSONString(msg),e);
            return Result.error("900001","参数错误");
        }

    }


    //签名加密校验
    public String checkType(String data,String timestamp,String sekey) {
        String sign = sekey+"data" + data + "timestamp" + timestamp;
        return Md5Utils.encryption(sign);
    }



    public List<InventoryDataPushVo> getOmsData(Map<String, Object> weDtilMsg,Map<String, Object> weChatMapMsg){
        String driver=omsUtils.getOmsDriver();
        String user=omsUtils.getOmsUser();
        String password=omsUtils.getOmsPassword();
        String url=omsUtils.getOmsUrl();
        List<InventoryDataPushVo> inventoryDataPushVos = null;
        try{
            //加载数据库驱动
            Class.forName(driver);
            //连接数据库
            Connection conn = DriverManager.getConnection(url,user,password);
            //创建Statement对象
            Statement stmt = conn.createStatement();
            String sql = "SELECT wmsi.merch_sn,ppr.prod_barcode,ppr.prod_name,wmsi.shop_sn,wim.valid_num,wmsi.shop_inve FROM wb_inve_mng wim LEFT JOIN pd_product_record ppr ON wim.sku = ppr.sku LEFT JOIN wb_merch_shop_inve wmsi ON wim.sku = wmsi.sku WHERE ppr.is_record = 1 AND ppr.is_valid = 0 AND wim.inve_status = 0 AND wim.is_valid = 0 AND wmsi.is_valid = 0 AND wim.merch_sn='"+weDtilMsg.get("merchSn")+"' limit "+weChatMapMsg.get("offset")+","+weChatMapMsg.get("limit")+"";
            //建立结果集
            ResultSet rs = stmt.executeQuery(sql);
            inventoryDataPushVos =convertList(rs);
            //关闭结果集
            rs.close();
            //关闭Statement对象
            stmt.close();
            //关闭数据库
            conn.close();

        }catch(Exception e){
          logger.error("查询oms库存数据出错");
        }
        return inventoryDataPushVos;
    }



    private static List<InventoryDataPushVo> convertList(ResultSet rs) throws SQLException {
        List<InventoryDataPushVo> list = new ArrayList();
        while (rs.next()) {
            InventoryDataPushVo inventoryDataPushVo = new InventoryDataPushVo();
            inventoryDataPushVo.setBarcode(rs.getString("prod_barcode"));
            inventoryDataPushVo.setProductName(rs.getString("prod_name"));
            inventoryDataPushVo.setShopSn(rs.getString("shop_sn"));
            inventoryDataPushVo.setShopInvent(rs.getInt("shop_inve"));
            inventoryDataPushVo.seteMatou(rs.getInt("valid_num"));
            list.add(inventoryDataPushVo);
        }
        return list;
    }

}