ym-ipos/src/main/java/com/poteviohealth/ym/ipos/service/impl/MerchantServiceImpl.java

package com.poteviohealth.ym.ipos.service.impl;

import com.alibaba.fastjson.JSON;
import com.alibaba.fastjson.JSONObject;
import com.alibaba.fastjson.TypeReference;
import com.poteviohealth.cgp.common.filter.TokenContext;
import com.poteviohealth.cgp.common.integrated.OperatorIdParams;
import com.poteviohealth.cgp.common.integrated.customer.CustomerFeignClient;
import com.poteviohealth.cgp.common.integrated.partner.PartnerFeignClient;
import com.poteviohealth.cgp.common.model.VaultsResponse;
import com.poteviohealth.ym.ipos.model.back.BaseBack;
import com.poteviohealth.ym.ipos.model.merchant.*;
import com.poteviohealth.ym.ipos.model.merchant.back.ImageListBack;
import com.poteviohealth.ym.ipos.model.merchant.back.PictureBack;
import com.poteviohealth.ym.ipos.model.merchant.back.UserBack;
import com.poteviohealth.ym.ipos.model.merchant.back.UserSearchBack;
import com.poteviohealth.ym.ipos.model.merchant.detail.*;
import com.poteviohealth.ym.ipos.model.merchant.dto.ImageDto;
import com.poteviohealth.ym.ipos.model.merchant.dto.ImageListDto;
import com.poteviohealth.ym.ipos.model.merchant.dto.UserDto;
import com.poteviohealth.ym.ipos.model.payment.dto.BindDto;
import com.poteviohealth.ym.ipos.service.IAreaService;
import com.poteviohealth.ym.ipos.service.IMerchantService;
import com.poteviohealth.ym.ipos.service.IPaymentService;
import com.poteviohealth.ym.ipos.utils.YmUtil;
import lombok.extern.log4j.Log4j2;
import org.apache.commons.lang3.StringUtils;
import org.springframework.beans.factory.annotation.Value;
import org.springframework.stereotype.Service;

import javax.annotation.Resource;
import java.util.List;
import java.util.stream.Collectors;

/**
 * 商户入驻接口实现
 * @author Qin
 */
@Service
@Log4j2
public class MerchantServiceImpl implements IMerchantService {

    @Resource
    private PartnerFeignClient partnerFeignClient;
    @Resource
    private CustomerFeignClient customerFeignClient;
    @Resource
    private IAreaService areaService;
    @Resource
    private IPaymentService paymentService;

    @Value("${pay.field.code}")
    private String code;

    /**
     * 上传图片
     * @param dto
     * @return
     */
    @Override
    public VaultsResponse<String> merchantPicture(ImageDto dto){
        Picture p = new Picture();
        PictureDetail detail = new PictureDetail();
        detail.setType(dto.getType());
        detail.setImage_name(dto.getName());
        detail.setImage_content(dto.getBase64Str());
        p.setMerchant_picture_request(detail);

        PictureBack back = null;
        try {
            back = (PictureBack) YmUtil.resultBack(p,new PictureBack());
        } catch (IllegalAccessException e) {
            e.printStackTrace();
            return VaultsResponse.failed(e.getMessage());
        }

        if(YmUtil.SUCCESS.equals(back.getResult().getId())){
            return VaultsResponse.success(back.getId());
        }

        return VaultsResponse.failed(back.getResult().getComment());
    }

    /**
     * 商户新增/修改开户入驻
     * @param dto
     * @return
     */
    @Override
    public VaultsResponse merchantCreateOpen(UserDto dto) {
        VaultsResponse<UserSearchBack> vaultsResponse = this.merchantQuery(dto.getPhone(),null);
        if(!vaultsResponse.validate()){
            log.info("UserSearchBack==="+vaultsResponse);
            return vaultsResponse;
        }
        UserSearchBack searchBack = vaultsResponse.getData();
        Integer status = 0;
        if(searchBack != null){
             status = Integer.parseInt(searchBack.getIncoming_status());
        }

        if(StringUtils.isEmpty(dto.getIncoming_status())){
            dto.setIncoming_status(status.toString());
        }

        if(StringUtils.isEmpty(dto.getMerchant_id())){
            if(searchBack != null){
                dto.setMerchant_id(searchBack.getMerchant_id());
                //return VaultsResponse.failed("手机号码已被注册");
            }
            //添加商户
            VaultsResponse<String> createVault = this.merchantCreate(dto);
            if(!createVault.validate()){
                log.info("createVault==="+createVault);
                return createVault;
            }
            dto.setMerchant_id(createVault.getData());
        }else{
            if(searchBack != null && !searchBack.getMerchant_id().equals(dto.getMerchant_id())){
                return VaultsResponse.failed("手机号码已被注册");
            }
        }

        if(dto.getIncoming_status().equals("2")){
            //修改开户/入驻信息
            VaultsResponse<String> indvmodifyVault = this.modifyVault(dto);
            if(!indvmodifyVault.validate()){
                log.info("indvmodifyVault==="+indvmodifyVault);
                return indvmodifyVault;
            }
            VaultsResponse<String> openModifyVault = this.merchantOpenModify(dto);

            VaultsResponse<String> stringVault = updateMerchantId(dto.getId(), dto.getSourceId(), dto.getMerchant_id(),2,dto.getRemained_amt());
            if(!stringVault.validate()){
                log.info("stringVault==="+stringVault);
                return stringVault;
            }
            if(dto.getSourceId().equals(1)){
                //终端绑定交易
                BindDto bd = new BindDto();
                bd.setAppId(stringVault.getData());
                bd.setPosId(code);
                bd.setStoreId(dto.getId().toString());
                bd.setName("("+code+")"+dto.getMerchant_short_name());
                return paymentService.bindPos(bd);
            }
            log.info("openModifyVault==="+openModifyVault);
            return openModifyVault;
        }else{
            if(dto.getIncoming_status().equals("0") || dto.getIncoming_status().equals("-1")){
                //未开户或开户失败时
                if(dto.getType().equals("3")){
                    //个人
                    VaultsResponse<String> indvregisterVault = this.merchantIndvregister(dto);
                    if(!indvregisterVault.validate()){
                        log.info("indvregisterVault==="+indvregisterVault);
                        return indvregisterVault;
                    }
                }else{
                    //商户
                    VaultsResponse<String> entregisterVault = this.merchantEntregister(dto);
                    if(!entregisterVault.validate()){
                        log.info("entregisterVault==="+entregisterVault);
                        return entregisterVault;
                    }
                }
                updateMerchantId(dto.getId(), dto.getSourceId(), dto.getMerchant_id(),3,dto.getRemained_amt());
            }else{
                VaultsResponse<String> indvmodifyVault = this.modifyVault(dto);
                if(!indvmodifyVault.validate()){
                    log.info("indvmodifyVault==="+indvmodifyVault);
                    return indvmodifyVault;
                }
            }

            //入驻
            VaultsResponse<String> openVault = this.merchantOpen(dto);
            if(!openVault.validate()){
                log.info("openVault==="+openVault);
                return openVault;
            }
           // if(status != 2){
                VaultsResponse<String> stringVault = updateMerchantId(dto.getId(), dto.getSourceId(), dto.getMerchant_id(),2,dto.getRemained_amt());

                if(!stringVault.validate()){
                    log.info("stringVault==="+stringVault);
                    return stringVault;
                }
               if(dto.getSourceId().equals(1)){
                   //终端绑定交易
                   BindDto bd = new BindDto();
                   bd.setAppId(stringVault.getData());
                   bd.setPosId(code);
                   bd.setStoreId(dto.getId().toString());
                   bd.setName("("+code+")"+dto.getMerchant_short_name());
                   return paymentService.bindPos(bd);
               }
           // }
        }
        return VaultsResponse.success();
    }

    private VaultsResponse<String> modifyVault(UserDto dto) {
        //修改开户信息
        if(dto.getType().equals("3")){
            //个人
            VaultsResponse<String> indvmodifyVault = this.merchantIndvmodify(dto);
            if(!indvmodifyVault.validate()){
                return indvmodifyVault;
            }
        }else{
            //商户
            VaultsResponse<String> entmodifyVault = this.merchantEntmodify(dto);
            if(!entmodifyVault.validate()){
                return entmodifyVault;
            }
        }
        return VaultsResponse.success();
    }

    /**
     * 添加分账商户
     * @param dto
     * @return
     */
    private VaultsResponse merchantCreate(UserDto dto) {

        User user = new User();
        UserDetail detail = new UserDetail();
        detail.setType(dto.getType());
        detail.setMerchant_short_name(dto.getMerchant_short_name());
        detail.setMerchant_name(dto.getMerchant_name());
        detail.setPhone(dto.getPhone());
        user.setMerchant_create_request(detail);
        UserBack back = null;
        try {
            back = (UserBack) YmUtil.resultBack(user,new UserBack());
        } catch (IllegalAccessException e) {
            e.printStackTrace();
            return VaultsResponse.failed(e.getMessage());
        }

        if(YmUtil.SUCCESS.equals(back.getResult().getId())){
           VaultsResponse vaultsResponse = updateMerchantId(dto.getId(), dto.getSourceId(), back.getMerchant_id(),0,dto.getRemained_amt());
           if(!vaultsResponse.validate()){
               return vaultsResponse;
           }
           return VaultsResponse.success(back.getMerchant_id());
        }
        return VaultsResponse.failed(back.getResult().getComment());
    }

    private VaultsResponse updateMerchantId(Integer id, Integer source, String merchantId,Integer status,Long remainedAmt) {
        VaultsResponse vaultsResponse;
        OperatorIdParams operatorIdParams = new OperatorIdParams();
        operatorIdParams.setOperatorId(TokenContext.cureOperatorId());
        operatorIdParams.setId(id.toString());
        operatorIdParams.setMerchantId(merchantId);
        operatorIdParams.setSource(source);
        operatorIdParams.setStatus(status);
        operatorIdParams.setCode(code);
        operatorIdParams.setRemainedAmt(remainedAmt);
        if(source.equals(3)){
            vaultsResponse =  customerFeignClient.updateMerchantId(operatorIdParams);
        }else{
            vaultsResponse =  partnerFeignClient.updateMerchantId(operatorIdParams);
        }

        return vaultsResponse;
    }

    /**
     * 个人分账商户开户
     * @param dto
     * @return
     */
    private VaultsResponse merchantIndvregister(UserDto dto){

        IndvregisterAdd iAdd = new IndvregisterAdd();
        IndvregisterAddDetail detail = new IndvregisterAddDetail();
        detail.setMerchant_id(dto.getMerchant_id());
        detail.setIdentity_begin_date(dto.getIdentity_begin_date());
        if(StringUtils.isNotEmpty(dto.getIdentity_end_date())){
            detail.setIdentity_end_date(dto.getIdentity_end_date());
        }
        detail.setIdentity_validity_type(dto.getIdentity_validity_type());
        detail.setContact_phone(dto.getContact_phone());
        detail.setCert_photo_a(this.merchantPicture(dto.getCert_photo_a()).getData());
        detail.setCert_photo_b(this.merchantPicture(dto.getCert_photo_b()).getData());
        detail.setLegal_name(dto.getLegal_name());
        detail.setIdentity_no(dto.getIdentity_no());
        detail.setMerchant_name(dto.getMerchant_name());
        //detail.setIdentity_type(dto.getIdentity_type());
        iAdd.setMerchant_indvregister_request(detail);
        BaseBack back = null;
        try {
            back = (BaseBack) YmUtil.resultBack(iAdd,new BaseBack());
        } catch (IllegalAccessException e) {
            e.printStackTrace();
            return VaultsResponse.failed(e.getMessage());
        }

        if(YmUtil.SUCCESS.equals(back.getResult().getId())){
            return VaultsResponse.success();
        }
        return VaultsResponse.failed(back.getResult().getComment());
    }

    /**
     * 个人分账商户修改
     * @param dto
     * @return
     */
    private VaultsResponse merchantIndvmodify(UserDto dto){
        IndvregisterUpdate iUpdate = new IndvregisterUpdate();
        IndvregisterUpdateDetail iUpdateDetail = new IndvregisterUpdateDetail();
        iUpdateDetail.setMerchant_id(dto.getMerchant_id());
        iUpdateDetail.setIdentity_begin_date(dto.getIdentity_begin_date());
        if(StringUtils.isNotEmpty(dto.getIdentity_end_date())){
            iUpdateDetail.setIdentity_end_date(dto.getIdentity_end_date());
        }
        iUpdateDetail.setIdentity_validity_type(dto.getIdentity_validity_type());
        iUpdateDetail.setContact_phone(dto.getContact_phone());
        if(StringUtils.isEmpty(dto.getCert_photo_a().getBase64Str())){
            for (ImageListDto imageListDto : dto.getImage_list()) {
                if(imageListDto.getFile_type().equals("01")){
                    iUpdateDetail.setCert_photo_a(imageListDto.getFile_id());
                    break;
                }
            }
        }else{
            iUpdateDetail.setCert_photo_a(this.merchantPicture(dto.getCert_photo_a()).getData());
        }

        if(StringUtils.isEmpty(dto.getCert_photo_b().getBase64Str())){
            for (ImageListDto imageListDto : dto.getImage_list()) {
                if(imageListDto.getFile_type().equals("02")){
                    iUpdateDetail.setCert_photo_b(imageListDto.getFile_id());
                    break;
                }
            }
        }else{
            iUpdateDetail.setCert_photo_b(this.merchantPicture(dto.getCert_photo_b()).getData());
        }


        iUpdate.setMerchant_indvmodify_request(iUpdateDetail);
        BaseBack back = null;
        try {
            back = (BaseBack) YmUtil.resultBack(iUpdate,new BaseBack());
        } catch (IllegalAccessException e) {
            e.printStackTrace();
            return VaultsResponse.failed(e.getMessage());
        }

        if(YmUtil.SUCCESS.equals(back.getResult().getId())){
            return VaultsResponse.success();
        }
        return VaultsResponse.failed(back.getResult().getComment());
    }

    /**
     * 企业分账商户开户
     * @param dto
     * @return
     */
    private VaultsResponse merchantEntregister(UserDto dto){
        EntregisterAdd iAdd = new EntregisterAdd();
        EntregisterAddDetail detail = new EntregisterAddDetail();
        detail.setMerchant_id(dto.getMerchant_id());
        detail.setLicense_begin_date(dto.getLicense_begin_date());
        if(StringUtils.isNotEmpty(dto.getLicense_end_date())){
            detail.setLicense_end_date(dto.getLicense_end_date());
        }
        detail.setLicense_validity_type(dto.getLicense_validity_type());
        List<String> areaList = areaService.getAreaCode(dto.getLicense_area());
        detail.setLicense_province_code(areaList.get(0));
        detail.setLicense_city_code(areaList.get(1));
        detail.setLicense_area_code(areaList.get(2));
        detail.setLicense_address(dto.getLicense_address());
        detail.setLegal_name(dto.getLegal_name());
        detail.setIdentity_no(dto.getIdentity_no());
        detail.setIdentity_begin_date(dto.getIdentity_begin_date());
        if(StringUtils.isNotEmpty(dto.getIdentity_end_date())){
            detail.setIdentity_end_date(dto.getIdentity_end_date());
        }
        detail.setIdentity_validity_type(dto.getIdentity_validity_type());
        detail.setContact_name(dto.getContact_name());
        detail.setContact_phone(dto.getContact_phone());
        detail.setLicense_photo(this.merchantPicture(dto.getLicense_photo()).getData());
        detail.setCert_photo_a(this.merchantPicture(dto.getCert_photo_a()).getData());
        detail.setCert_photo_b(this.merchantPicture(dto.getCert_photo_b()).getData());
        detail.setMerchant_name(dto.getMerchant_name());
        detail.setLicense_code(dto.getLicense_code());
        //detail.setIdentity_type(dto.getIdentity_type());
        iAdd.setMerchant_entregister_request(detail);
        BaseBack back = null;
        try {
            back = (BaseBack) YmUtil.resultBack(iAdd,new BaseBack());
        } catch (IllegalAccessException e) {
            e.printStackTrace();
            return VaultsResponse.failed(e.getMessage());
        }

        if(YmUtil.SUCCESS.equals(back.getResult().getId())){
            return VaultsResponse.success();
        }
        return VaultsResponse.failed(back.getResult().getComment());
    }

    /**
     * 企业分账商户修改
     * @param dto
     * @return
     */
    private VaultsResponse merchantEntmodify(UserDto dto){
        EntregisterUpdate iUpdate = new EntregisterUpdate();
        EntregisterUpdateDetail iUpdateDetail = new EntregisterUpdateDetail();
        iUpdateDetail.setMerchant_id(dto.getMerchant_id());
        iUpdateDetail.setLicense_begin_date(dto.getLicense_begin_date());
        if(StringUtils.isNotEmpty(dto.getLicense_end_date())){
            iUpdateDetail.setLicense_end_date(dto.getLicense_end_date());
        }
        iUpdateDetail.setLicense_validity_type(dto.getLicense_validity_type());
        List<String> areaList = areaService.getAreaCode(dto.getLicense_area());
        iUpdateDetail.setLicense_province_code(areaList.get(0));
        iUpdateDetail.setLicense_city_code(areaList.get(1));
        iUpdateDetail.setLicense_area_code(areaList.get(2));
        iUpdateDetail.setLicense_address(dto.getLicense_address());
        iUpdateDetail.setLegal_name(dto.getLegal_name());
        iUpdateDetail.setIdentity_no(dto.getIdentity_no());
        iUpdateDetail.setIdentity_begin_date(dto.getIdentity_begin_date());
        if(StringUtils.isNotEmpty(dto.getIdentity_end_date())){
            iUpdateDetail.setIdentity_end_date(dto.getIdentity_end_date());
        }
        iUpdateDetail.setIdentity_validity_type(dto.getIdentity_validity_type());
        iUpdateDetail.setContact_name(dto.getContact_name());
        iUpdateDetail.setContact_phone(dto.getContact_phone());
        if(StringUtils.isEmpty(dto.getLicense_photo().getBase64Str())){
            for (ImageListDto imageListDto : dto.getImage_list()) {
                if(imageListDto.getFile_type().equals("03")){
                    iUpdateDetail.setLicense_photo(imageListDto.getFile_id());
                    break;
                }
            }
        }else{
            iUpdateDetail.setLicense_photo(this.merchantPicture(dto.getLicense_photo()).getData());
        }
        if(StringUtils.isEmpty(dto.getCert_photo_a().getBase64Str())){
            for (ImageListDto imageListDto : dto.getImage_list()) {
                if(imageListDto.getFile_type().equals("01")){
                    iUpdateDetail.setCert_photo_a(imageListDto.getFile_id());
                    break;
                }
            }
        }else{
            iUpdateDetail.setCert_photo_a(this.merchantPicture(dto.getCert_photo_a()).getData());
        }

        if(StringUtils.isEmpty(dto.getCert_photo_b().getBase64Str())){
            for (ImageListDto imageListDto : dto.getImage_list()) {
                if(imageListDto.getFile_type().equals("02")){
                    iUpdateDetail.setCert_photo_b(imageListDto.getFile_id());
                    break;
                }
            }
        }else{
            iUpdateDetail.setCert_photo_b(this.merchantPicture(dto.getCert_photo_b()).getData());
        }

        iUpdate.setMerchant_entmodify_request(iUpdateDetail);
        BaseBack back = null;
        try {
            back = (BaseBack) YmUtil.resultBack(iUpdate,new BaseBack());
        } catch (IllegalAccessException e) {
            e.printStackTrace();
            return VaultsResponse.failed(e.getMessage());
        }

        if(YmUtil.SUCCESS.equals(back.getResult().getId())){
            return VaultsResponse.success();
        }
        return VaultsResponse.failed(back.getResult().getComment());
    }

    /**
     * 分账商户业务入驻
     * @param dto
     * @return
     */
    private VaultsResponse merchantOpen(UserDto dto){
        OpenAdd openAdd = new OpenAdd();
        openAdd.setMerchant_open_request(this.fill(dto));
        BaseBack back = null;
        try {
            back = (BaseBack) YmUtil.resultBack(openAdd,new BaseBack());
        } catch (IllegalAccessException e) {
            e.printStackTrace();
            return VaultsResponse.failed(e.getMessage());
        }

        if(YmUtil.SUCCESS.equals(back.getResult().getId())){
            return VaultsResponse.success(back);
        }
        return VaultsResponse.failed();
    }

    /**
     * 入驻数据填充
     * @param dto
     * @return
     */
    private OpenDetail fill(UserDto dto){
        OpenDetail detail = new OpenDetail();
        detail.setMerchant_id(dto.getMerchant_id());
        detail.setSettle_type(dto.getSettle_type());
       /* detail.setSettlement_way(dto.getSettlement_way());
        detail.setWithdraw_way(dto.getWithdraw_way());*/
        detail.setCard_no(dto.getCard_no());
        detail.setParent_bank_name(dto.getParent_bank_name());
        detail.setParent_bank_code(dto.getParent_bank_code());
        List<String> areaList = areaService.getAreaCode(dto.getBank_area());
        detail.setProvince(areaList.get(0));
        detail.setCity(areaList.get(1));
        detail.setBranch_bank_code(dto.getBranch_bank_code());
        detail.setBranch_bank_name(dto.getBranch_bank_name());
        if(StringUtils.isEmpty(dto.getSettle_photo_a().getBase64Str())){
            for (ImageListDto imageListDto : dto.getImage_list()) {
                if(imageListDto.getFile_type().equals("13")){
                    detail.setSettle_photo_a(imageListDto.getFile_id());
                    break;
                }
            }
        }else{
            detail.setSettle_photo_a(this.merchantPicture(dto.getSettle_photo_a()).getData());
        }
        if(StringUtils.isEmpty(dto.getSettle_photo_b().getBase64Str())){
            for (ImageListDto imageListDto : dto.getImage_list()) {
                if(imageListDto.getFile_type().equals("14")){
                    detail.setSettle_photo_b(imageListDto.getFile_id());
                    break;
                }
            }
        }else{
            detail.setSettle_photo_b(this.merchantPicture(dto.getSettle_photo_b()).getData());
        }
        detail.setRemained_amt(dto.getRemained_amt());
        detail.setSettle_abstract(dto.getSettle_abstract());
        return detail;
    }

    /**
     * 分账商户业务入驻修改
     * @param dto
     * @return
     */
    private VaultsResponse merchantOpenModify(UserDto dto){
        OpenUpdate openUpdate = new OpenUpdate();
        openUpdate.setMerchant_openmodify_request(this.fill(dto));
        BaseBack back = null;
        try {
            back = (BaseBack) YmUtil.resultBack(openUpdate,new BaseBack());
        } catch (IllegalAccessException e) {
            e.printStackTrace();
            return VaultsResponse.failed(e.getMessage());
        }

        if(YmUtil.SUCCESS.equals(back.getResult().getId())){
            return VaultsResponse.success(back);
        }
        return VaultsResponse.failed();
    }

    /**
     * 分账商户查询
     * @param phone
     * @param merchantId
     * @return
     */
    @Override
    public VaultsResponse<UserSearchBack> merchantQuery(String phone, String merchantId){
        UserSearch userSearch = new UserSearch();
        UserSearchDetail detail = new UserSearchDetail();
        detail.setPhone(phone);
        detail.setMerchant_id(merchantId);
        userSearch.setMerchant_query_request(detail);
        UserSearchBack back = null;
        try {
            String val = (String) YmUtil.resultBack(userSearch,new UserSearchBack());
            JSONObject jsonObject = new JSONObject(JSON.parseObject(val));
            if(val.contains("image_list")){
                List<ImageListBack> list = jsonObject.getJSONArray("image_list").stream().map(item -> JSON.parseObject(item.toString(), new TypeReference<ImageListBack>() {})).collect(Collectors.toList());
                jsonObject.put("image_list",list);
            }
            back = JSONObject.toJavaObject(jsonObject, UserSearchBack.class);

        } catch (IllegalAccessException e) {
            e.printStackTrace();
            return VaultsResponse.failed(e.getMessage());
        }

        if(YmUtil.SUCCESS.equals(back.getResult().getId())){
            return VaultsResponse.success(back);
        }else if("9990".equals(back.getResult().getId())){
            return VaultsResponse.success(null);
        }
        return VaultsResponse.failed();
    }

}