blame | history | patch | commit | commitdiff | ignore whitespace
KKSU
2024-07-26 902c816330e250333065cb0d50e21585b43e539b 
 src/main/java/cc/mrbird/febs/mall/service/impl/ApiMallMemberServiceImpl.java


@@ -5,8 +5,7 @@


import cc.mrbird.febs.common.exception.FebsException;


import cc.mrbird.febs.common.properties.XcxProperties;


import cc.mrbird.febs.common.utils.*;


import cc.mrbird.febs.mall.conversion.MallMemberConversion;


import cc.mrbird.febs.mall.conversion.MallShopApplyConversion;


import cc.mrbird.febs.mall.conversion.*;


import cc.mrbird.febs.mall.dto.*;


import cc.mrbird.febs.mall.entity.*;


import cc.mrbird.febs.mall.mapper.*;


@@ -14,6 +13,8 @@


import cc.mrbird.febs.mall.vo.*;


import cc.mrbird.febs.pay.model.BrandWCPayRequestData;


import cc.mrbird.febs.pay.service.IXcxPayService;


import cc.mrbird.febs.pay.util.MD5;


import cc.mrbird.febs.pay.util.Util;


import cc.mrbird.febs.vip.VipSettingUnAliveSettingBo;


import cc.mrbird.febs.vip.entity.MallVipConfig;


import cc.mrbird.febs.vip.mapper.MallVipConfigMapper;


@@ -27,6 +28,7 @@


import cn.hutool.crypto.SecureUtil;


import cn.hutool.crypto.asymmetric.KeyType;


import cn.hutool.crypto.asymmetric.RSA;


import cn.hutool.json.JSONArray;


import cn.hutool.json.JSONUtil;


import com.alibaba.fastjson.JSONObject;


import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;


@@ -36,6 +38,16 @@


import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;


import lombok.RequiredArgsConstructor;


import lombok.extern.slf4j.Slf4j;


import org.apache.http.HttpEntity;


import org.apache.http.HttpResponse;


import org.apache.http.client.methods.HttpGet;


import org.apache.http.client.methods.HttpPost;


import org.apache.http.client.protocol.HttpClientContext;


import org.apache.http.entity.ByteArrayEntity;


import org.apache.http.impl.client.CloseableHttpClient;


import org.apache.http.impl.client.HttpClients;


import org.apache.http.message.BasicNameValuePair;


import org.apache.http.util.EntityUtils;


import org.springframework.beans.factory.annotation.Value;


import org.springframework.boot.autoconfigure.security.SecurityProperties;


import org.springframework.http.HttpStatus;


@@ -80,6 +92,9 @@


    private final MallGoodsMapper mallGoodsMapper;




    private final MallVipConfigMapper mallVipConfigMapper;


    private final MallStoreMapper mallStoreMapper;


    private final MallStoreItemMapper mallStoreItemMapper;


    private final MallStoreMemberMapper mallStoreMemberMapper;






    @Value("${spring.profiles.active}")


@@ -1155,5 +1170,181 @@


        return result;


    }




    @Override


    public FebsResponse storeList(MallStoreDto mallStoreDto) {


        QueryWrapper<MallStore> mallStoreQueryWrapper = new QueryWrapper<>();


        if(StrUtil.isNotEmpty(mallStoreDto.getName())){


            mallStoreQueryWrapper.like("name",mallStoreQueryWrapper);


        }


        List<MallStore> mallStores = mallStoreMapper.selectList(mallStoreQueryWrapper);


        List<MallStoreVo> mallStoreVos = MallStoreConversion.INSTANCE.entitysToVos(mallStores);


        return new FebsResponse().success().data(mallStoreVos);


    }




    @Override


    public FebsResponse storeItemList(MallStoreItemDto mallStoreItemDto) {


        QueryWrapper<MallStoreItem> mallStoreQueryWrapper = new QueryWrapper<>();


        mallStoreQueryWrapper.like("store_id",mallStoreItemDto.getStoreId());


        List<MallStoreItem> mallStores = mallStoreItemMapper.selectList(mallStoreQueryWrapper);


        return new FebsResponse().success().data(mallStores);


    }




    @Override


    public FebsResponse bindStoreMember(BindStoreMemberDto bindStoreMemberDto) {


        Long memberId = LoginUserUtil.getLoginUser().getId();


        Long storeItemId = bindStoreMemberDto.getStoreItemId();




        QueryWrapper<MallStoreMember> objectQueryWrapper = new QueryWrapper<>();


        objectQueryWrapper.eq("member_id",memberId);


        List<MallStoreMember> mallStoreMembers = mallStoreMemberMapper.selectList(objectQueryWrapper);


        if(CollUtil.isNotEmpty(mallStoreMembers)){


            mallStoreMemberMapper.delete(objectQueryWrapper);


        }




        MallMember mallMember = this.baseMapper.selectById(memberId);


        Integer sex = "女".equals(mallMember.getSex()) ? 3 : 2;




        MallStoreItem mallStoreItem = mallStoreItemMapper.selectById(storeItemId);


        HashMap<String, String> objectObjectHashMap = new HashMap<>();


        String shopAccount = mallStoreItem.getAccount();


        String shopPwd = mallStoreItem.getPassword();


        String name = bindStoreMemberDto.getName();


        String address = bindStoreMemberDto.getAddress();


        Integer age = bindStoreMemberDto.getAge();


        String phoneNumber = bindStoreMemberDto.getPhone();




        objectObjectHashMap.put("shopAccount",shopAccount);


        objectObjectHashMap.put("shopPwd",shopPwd);


        objectObjectHashMap.put("name",name);


        objectObjectHashMap.put("address",address);


        objectObjectHashMap.put("age",age.toString());


        objectObjectHashMap.put("phoneNumber",phoneNumber);


        objectObjectHashMap.put("sex",sex.toString());




        //sign= MD5(address+age+name+phoneNumber+shopAccount+shopPwd)


        StringBuffer stringBuffer = new StringBuffer();


        stringBuffer.append(address);


        stringBuffer.append(age);


        stringBuffer.append(name);


        stringBuffer.append(phoneNumber);


        stringBuffer.append(sex);


        stringBuffer.append(shopAccount);


        stringBuffer.append(shopPwd);


        String sign = MD5.MD5Encode(stringBuffer.toString());


        objectObjectHashMap.put("sign",sign);


        String url = "https://data.muchun.co/api/bindCustomer";


        String result = HttpCurlUtil.sendPost(url, objectObjectHashMap);


        Integer retCode = JSONUtil.parseObj(result).getInt("retCode");


        String message = JSONUtil.parseObj(result).getStr("message");


        if(0 != retCode || !"绑定成功".equals(message)){


            return new FebsResponse().fail().message(message);


        }


        Long bindId = JSONUtil.parseObj(result).getJSONObject("data").getLong("userId");




        MallStoreMember mallStoreMember = new MallStoreMember();


        mallStoreMember.setMemberId(memberId);


        mallStoreMember.setBindId(bindId);


        mallStoreMember.setStoreId(mallStoreItem.getStoreId());


        mallStoreMember.setStoreItemId(mallStoreItem.getId());




        mallStoreMember.setAccount(shopAccount);


        mallStoreMember.setPassword(shopPwd);




        mallStoreMember.setName(name);


        mallStoreMember.setAddress(address);


        mallStoreMember.setAge(age);


        mallStoreMember.setPhone(phoneNumber);


        mallStoreMemberMapper.insert(mallStoreMember);


        return new FebsResponse().success().message("绑定成功");


    }




    @Override


    public FebsResponse bindList() {


        Long memberId = LoginUserUtil.getLoginUser().getId();


        QueryWrapper<MallStoreMember> objectQueryWrapper = new QueryWrapper<>();


        objectQueryWrapper.eq("member_id",memberId);


        List<MallStoreMember> mallStoreMembers = mallStoreMemberMapper.selectList(objectQueryWrapper);




        ArrayList<MallStoreMemberVo> mallStoreMemberVos = new ArrayList<>();


        for(MallStoreMember mallStoreMember : mallStoreMembers){


            MallStoreMemberVo mallStoreMemberVo = new MallStoreMemberVo();


            Long storeId = mallStoreMember.getStoreId();


            Long storeItemId = mallStoreMember.getStoreItemId();


            MallStore mallStore = mallStoreMapper.selectById(storeId);


            MallStoreItem mallStoreItem = mallStoreItemMapper.selectById(storeItemId);


            mallStoreMemberVo.setId(mallStoreMember.getId());


            mallStoreMemberVo.setBindInfo(mallStore.getName()+"-"+mallStoreItem.getCode());


            mallStoreMemberVos.add(mallStoreMemberVo);


        }


        return new FebsResponse().success().data(mallStoreMemberVos);


    }




    @Override


    public FebsResponse bindResult(BindResultDto bindResultDto) {


        Long memberId = LoginUserUtil.getLoginUser().getId();


        MallStoreMember mallStoreMember = mallStoreMemberMapper.selectById(bindResultDto.getBindId());


        Long userld = mallStoreMember.getBindId();


        String shopAccount = mallStoreMember.getAccount();


        String shopPwd = mallStoreMember.getPassword();




        HashMap<String, String> objectObjectHashMap = new HashMap<>();




        objectObjectHashMap.put("shopAccount",shopAccount);


        objectObjectHashMap.put("shopPwd",shopPwd);


        objectObjectHashMap.put("userId",userld.toString());




        //sign= MD5(shopAccount+shopPwd+userId)


        StringBuffer stringBuffer = new StringBuffer();


        stringBuffer.append(shopAccount);


        stringBuffer.append(shopPwd);


        stringBuffer.append(userld);


        String sign = MD5.MD5Encode(stringBuffer.toString());


        objectObjectHashMap.put("sign",sign);




        String url = "https://data.muchun.co/api/getCustomerCheckRecords";


        String result = HttpCurlUtil.sendPost(url, objectObjectHashMap);


        Integer retCode = JSONUtil.parseObj(result).getInt("retCode");


        String message = JSONUtil.parseObj(result).getStr("message");


        if(0 != retCode){


            return new FebsResponse().fail().message(message);


        }


        JSONArray data = JSONUtil.parseObj(result).getJSONArray("data");


        return new FebsResponse().success().data(data);


    }




    public static void main(String[] args) {


        Long userld = 173L;


        String shopAccount = "luohu";


        String shopPwd = "123456";




        HashMap<String, String> objectObjectHashMap = new HashMap<>();




        objectObjectHashMap.put("shopAccount",shopAccount);


        objectObjectHashMap.put("shopPwd",shopPwd);


        objectObjectHashMap.put("userId",userld.toString());




        //sign= MD5(shopAccount+shopPwd+userId)


        StringBuffer stringBuffer = new StringBuffer();


        stringBuffer.append(shopAccount);


        stringBuffer.append(shopPwd);


        stringBuffer.append(userld);


        String sign = MD5.MD5Encode(stringBuffer.toString());


        objectObjectHashMap.put("sign",sign);




        System.out.println(sign);




        System.out.println(objectObjectHashMap);


        String url = "https://data.muchun.co/api/getCustomerCheckRecords";


        String result = HttpCurlUtil.sendPost(url, objectObjectHashMap);


        Integer retCode = JSONUtil.parseObj(result).getInt("retCode");


        String message = JSONUtil.parseObj(result).getStr("message");


        if(0 != retCode){


            System.out.println(message);


        }




        JSONArray data = JSONUtil.parseObj(result).getJSONArray("data");


        System.out.println(data);


    }






}