联讯物业系统后台
blame | 历史 | 补丁 | 提交 | 提交对比 | ignore whitespace
java110
2022-03-15 9027f39fbef8cbcefd48f017701e791712becac5 
 service-api/src/main/java/com/java110/api/smo/payment/impl/ToPaySMOImpl.java


@@ -2,26 +2,26 @@




import com.alibaba.fastjson.JSONArray;


import com.alibaba.fastjson.JSONObject;


import com.java110.core.context.IPageData;


import com.java110.core.context.PageData;


import com.java110.dto.app.AppDto;


import com.java110.dto.owner.OwnerAppUserDto;


import com.java110.dto.smallWeChat.SmallWeChatDto;


import com.java110.api.properties.WechatAuthProperties;


import com.java110.api.smo.AppAbstractComponentSMO;


import com.java110.api.smo.payment.IToPaySMO;


import com.java110.api.smo.payment.adapt.IPayAdapt;


import com.java110.core.context.IPageData;


import com.java110.core.context.PageData;


import com.java110.core.log.LoggerFactory;


import com.java110.dto.app.AppDto;


import com.java110.dto.owner.OwnerAppUserDto;


import com.java110.dto.smallWeChat.SmallWeChatDto;


import com.java110.utils.cache.MappingCache;


import com.java110.utils.constant.CommonConstant;


import com.java110.utils.constant.ServiceConstant;


import com.java110.utils.constant.WechatConstant;


import com.java110.utils.factory.ApplicationContextFactory;


import com.java110.utils.util.Assert;


import com.java110.utils.util.BeanConvertUtil;


import com.java110.utils.util.DateUtil;


import com.java110.utils.util.StringUtil;


import com.java110.vo.ResultVo;


import org.slf4j.Logger;


import org.slf4j.LoggerFactory;


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


import org.springframework.http.HttpMethod;


import org.springframework.http.HttpStatus;


@@ -69,7 +69,7 @@


    @Override


    protected ResponseEntity<String> doBusinessProcess(IPageData pd, JSONObject paramIn) throws Exception {




        ResponseEntity responseEntity = null;


        ResponseEntity<String> responseEntity = null;




        SmallWeChatDto smallWeChatDto = getSmallWechat(pd, paramIn);




@@ -91,22 +91,26 @@


        }


        JSONObject orderInfo = JSONObject.parseObject(responseEntity.getBody().toString());


        String orderId = orderInfo.getString("oId");


        String feeName = orderInfo.getString("feeName");


        double money = Double.parseDouble(orderInfo.getString("receivedAmount"));


        //需要判断金额是否 == 0 等于0 直接掉缴费通知接口


        if (money <= 0) {




            JSONObject paramOut = new JSONObject();


            paramOut.put("oId", orderId);


            String urlOut = "fee.payFeeConfirm";


            responseEntity = this.callCenterService(getHeaders("-1",pd.getAppId()), paramOut.toJSONString(), urlOut, HttpMethod.POST);


            responseEntity = this.callCenterService(getHeaders("-1", pd.getAppId()), paramOut.toJSONString(), urlOut, HttpMethod.POST);


            JSONObject param = new JSONObject();


            if (responseEntity.getStatusCode() != HttpStatus.OK) {


                param.put("code","101");


                param.put("msg","扣费为0回调失败");


                param.put("code", "101");


                param.put("msg", "扣费为0回调失败");


                return new ResponseEntity(JSONObject.toJSONString(param), HttpStatus.OK);


            }


            param.put("code","100");


            param.put("msg","扣费为0回调成功");


            JSONObject result = JSONObject.parseObject(responseEntity.getBody());


            if (ResultVo.CODE_OK != result.getInteger("code")) {


                return responseEntity;


            }


            param.put("code", "100");


            param.put("msg", "扣费为0回调成功");


            return new ResponseEntity(JSONObject.toJSONString(param), HttpStatus.OK);


        }


        String appType = OwnerAppUserDto.APP_TYPE_WECHAT_MINA;


@@ -139,13 +143,13 @@


        payAdapt = StringUtil.isEmpty(payAdapt) ? DEFAULT_PAY_ADAPT : payAdapt;


        //支付适配器


        IPayAdapt tPayAdapt = ApplicationContextFactory.getBean(payAdapt, IPayAdapt.class);


        Map result = tPayAdapt.java110Payment(outRestTemplate, paramIn.getString("feeName"), paramIn.getString("tradeType"), orderId, money, openId, smallWeChatDto);


        Map result = tPayAdapt.java110Payment(outRestTemplate, feeName, paramIn.getString("tradeType"), orderId, money, openId, smallWeChatDto);


        responseEntity = new ResponseEntity(JSONObject.toJSONString(result), HttpStatus.OK);




        return responseEntity;


    }




    private Map<String, String> getHeaders(String userId,String appId) {


    private Map<String, String> getHeaders(String userId, String appId) {


        Map<String, String> headers = new HashMap<>();


        headers.put(CommonConstant.HTTP_APP_ID.toLowerCase(), appId);


        headers.put(CommonConstant.HTTP_USER_ID.toLowerCase(), userId);


@@ -154,6 +158,7 @@


        headers.put(CommonConstant.HTTP_SIGN.toLowerCase(), "");


        return headers;


    }




    private SmallWeChatDto getSmallWechat(IPageData pd, JSONObject paramIn) {




        ResponseEntity responseEntity = null;