From 3537032d2b9313c8f108675f19cae079054d872b Mon Sep 17 00:00:00 2001
From: doum <doum>
Date: 星期一, 09 二月 2026 10:25:41 +0800
Subject: [PATCH] 代码初始化

---
 server/services/src/main/java/com/doumee/service/business/impl/OrdersServiceImpl.java |  332 ++++++++++++++++++++++++++++++++++++++++++++++---------
 1 files changed, 276 insertions(+), 56 deletions(-)

diff --git a/server/services/src/main/java/com/doumee/service/business/impl/OrdersServiceImpl.java b/server/services/src/main/java/com/doumee/service/business/impl/OrdersServiceImpl.java
index beb566a..9bea96e 100644
--- a/server/services/src/main/java/com/doumee/service/business/impl/OrdersServiceImpl.java
+++ b/server/services/src/main/java/com/doumee/service/business/impl/OrdersServiceImpl.java
@@ -3,8 +3,11 @@
 import com.alibaba.fastjson.JSON;
 import com.alibaba.fastjson.JSONObject;
 import com.alibaba.fastjson.TypeReference;
+import com.allinpay.syb.lib.DoumeeTLUtil;
 import com.allinpay.syb.lib.SybConstants;
 import com.allinpay.syb.lib.SybUtil;
+import com.allinpay.syb.model.PayPublicModel;
+import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
 import com.doumee.biz.system.SystemDictDataBiz;
 import com.doumee.core.constants.Constants;
 import com.doumee.core.constants.ResponseStatus;
@@ -12,20 +15,25 @@
 import com.doumee.core.model.PageData;
 import com.doumee.core.model.PageWrap;
 import com.doumee.core.utils.DateUtil;
-import com.doumee.dao.business.dto.PayOrderNotifyParam;
-import com.doumee.dao.business.dto.PayOrderParam;
-import com.doumee.dao.business.dto.PayOrderResponse;
+import com.doumee.core.utils.HttpsUtil;
+import com.allinpay.syb.model.PayOrderNotifyParam;
+import com.allinpay.syb.model.PayOrderParam;
+import com.allinpay.syb.model.PayOrderResponse;
+import com.doumee.dao.business.RefundMapper;
 import com.doumee.dao.business.model.Orders;
 import com.doumee.core.utils.Utils;
 import com.doumee.dao.business.OrdersMapper;
+import com.doumee.dao.business.model.Refund;
 import com.doumee.dao.system.SystemUserMapper;
 import com.doumee.dao.system.model.SystemUser;
+import com.doumee.dao.vo.IndexOrderCountVO;
 import com.doumee.service.business.OrdersService;
 import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
 import com.baomidou.mybatisplus.core.conditions.update.UpdateWrapper;
 import com.baomidou.mybatisplus.core.metadata.IPage;
 import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
 import com.github.yulichang.wrapper.MPJLambdaWrapper;
+import io.swagger.models.auth.In;
 import lombok.extern.slf4j.Slf4j;
 import org.apache.commons.lang3.StringUtils;
 import org.springframework.beans.factory.annotation.Autowired;
@@ -37,6 +45,7 @@
 import javax.servlet.http.HttpServletResponse;
 import java.io.IOException;
 import java.math.BigDecimal;
+import java.net.URLEncoder;
 import java.util.*;
 
 /**
@@ -50,6 +59,8 @@
 
     @Autowired
     private OrdersMapper ordersMapper;
+    @Autowired
+    private RefundMapper refundMapper;
     @Autowired
     private SystemUserMapper systemUserMapper;
     @Autowired
@@ -95,14 +106,21 @@
             param.setCusid(systemDictDataBiz.queryByCode(Constants.SYSTEM,Constants.PAY_SYB_CUSID).getCode());
             param.setVersion(systemDictDataBiz.queryByCode(Constants.SYSTEM,Constants.PAY_VERSION).getCode());
             param.setCharset("utf-8");
-            param.setTrxamt("1");//鍗曚綅鍒�
+            param.setTrxamt(orders.getMoney().intValue()+"");//鍗曚綅鍒�
             param.setRandomstr(UUID.randomUUID().toString().replace("-",""));
             param.setReqsn(""+orders.getId());
             param.setReturl(systemDictDataBiz.queryByCode(Constants.SYSTEM,Constants.PAY_RETURN_URL).getCode());
             param.setNotify_url( systemDictDataBiz.queryByCode(Constants.SYSTEM,Constants.PAY_NOTIFY_URL).getCode());
-            param.setBody(StringUtils.defaultString(orders.getName(),"") +"-"
-                    + StringUtils.defaultString(orders.getPhone(),"")+ "-"
-                    +StringUtils.defaultString(orders.getRemark(),""));
+            String remark = (Constants.equalsInteger(orders.getType(),Constants.ZERO)?"杞︽":"寤舵湡娆�")
+                    +"-"+ StringUtils.defaultString(orders.getName(),"") +"-"
+                    + StringUtils.defaultString(orders.getPhone(),"");
+            if(StringUtils.isNotBlank(orders.getRemark())){
+                remark += "-"+StringUtils.defaultString(orders.getRemark(),"");
+            }
+            if(remark.length()>300){
+                remark = remark.substring(0,300);
+            }
+            param.setBody(remark);
             param.setValidtime(  systemDictDataBiz.queryByCode(Constants.SYSTEM,Constants.PAY_VALID_TIME).getCode());
             param.setSigntype(  systemDictDataBiz.queryByCode(Constants.SYSTEM,Constants.PAY_SIGN_TYPE).getCode());
 
@@ -194,6 +212,7 @@
         IPage<Orders> page = new Page<>(pageWrap.getPage(), pageWrap.getCapacity());
         MPJLambdaWrapper<Orders> queryWrapper = new MPJLambdaWrapper<>();
         queryWrapper.selectAll(Orders.class)
+                .select("(select sum(r.money) from refund r where r.deleted=0 and r.status in(0,1) and r.order_id=t.id)",Orders::getRefundMoney)
                 .selectAs(SystemUser::getRealname,Orders::getUserRealname)
                 .selectAs(SystemUser::getUsername,Orders::getUsername)
                 .leftJoin(SystemUser.class,SystemUser::getId,Orders::getUserId);
@@ -218,7 +237,7 @@
         queryWrapper.eq(pageWrap.getModel().getPayMethod() != null,Orders::getPayMethod, pageWrap.getModel().getPayMethod());
         queryWrapper.eq(pageWrap.getModel().getPayOrderId() != null,Orders::getPayOrderId, pageWrap.getModel().getPayOrderId());
         queryWrapper.ge(pageWrap.getModel().getStarttime()!=null,Orders::getCreateTime , pageWrap.getModel().getStarttime());
-        queryWrapper.ne(pageWrap.getModel().getEndtime()!=null,Orders::getCreateTime , pageWrap.getModel().getEndtime());
+        queryWrapper.le(pageWrap.getModel().getEndtime()!=null,Orders::getCreateTime , pageWrap.getModel().getEndtime());
         queryWrapper.eq(pageWrap.getModel().getCancelWay() != null,Orders::getCancelWay, pageWrap.getModel().getCancelWay());
         queryWrapper.eq(pageWrap.getModel().getCancelInfo() != null,Orders::getCancelInfo, pageWrap.getModel().getCancelInfo());
         queryWrapper.eq(pageWrap.getModel().getCancelUserId() != null,Orders::getCancelUserId, pageWrap.getModel().getCancelUserId());
@@ -227,6 +246,123 @@
         queryWrapper.orderByDesc(Orders::getId);
         return PageData.from(ordersMapper.selectJoinPage(page,Orders.class, queryWrapper));
     }
+    @Override
+    public IndexOrderCountVO getIndexData(Orders pageWrap) {
+        IndexOrderCountVO data = initIndexOrderCountMoel();
+        List<Orders> list = ordersMapper.selectList(new QueryWrapper<Orders>()
+                .select("status,type,count(id) as num,sum(money) as money")
+                .lambda()
+                .eq(Orders::getDeleted,Constants.ZERO )
+                .apply("to_days(create_time) =to_days(now())")
+                .groupBy(Orders::getType,Orders::getStatus));//鎸夌被鍨嬪拰鐘舵�佸垎缁�
+        if(list!=null){
+            for(Orders model:list){
+                data.setTodayNum(data.getTodayNum()+Constants.formatLongNum(model.getNum()));
+                data.setTodayMoney(data.getTodayMoney().add(Constants.formatBigDecimal(model.getMoney())));
+                if(Constants.equalsInteger(model.getType(),Constants.ONE)){
+                    data.setTodayNum1(data.getTodayNum1()+Constants.formatLongNum(model.getNum()));
+                    data.setTodayMoney1(data.getTodayMoney1().add(Constants.formatBigDecimal(model.getMoney())));
+                    //寤舵湡娆�
+                    if(Constants.equalsInteger(model.getStatus(),Constants.ONE)){
+                        //浜ゆ槗鎴愬姛
+                        data.setTodayDoneNum(data.getTodayDoneNum()+Constants.formatLongNum(model.getNum()));
+                        data.setTodayDoneMoney(data.getTodayDoneMoney().add(Constants.formatBigDecimal(model.getMoney())));
+                        data.setTodayDoneNum1(data.getTodayDoneNum1()+Constants.formatLongNum(model.getNum()));
+                        data.setTodayDoneMoney1(data.getTodayDoneMoney1().add(Constants.formatBigDecimal(model.getMoney())));
+                    }else  if(Constants.equalsInteger(model.getStatus(),Constants.ZERO)){
+                        //浜ゆ槗涓�
+                        data.setTodayWaitNum(data.getTodayWaitNum()+Constants.formatLongNum(model.getNum()));
+                        data.setTodayWaitMoney(data.getTodayWaitMoney().add(Constants.formatBigDecimal(model.getMoney())));
+                        data.setTodayWaitNum1(data.getTodayWaitNum1()+Constants.formatLongNum(model.getNum()));
+                        data.setTodayWaitMoney1(data.getTodayWaitMoney1().add(Constants.formatBigDecimal(model.getMoney())));
+                    }else {
+                        //浜ゆ槗澶辫触
+                        data.setTodayFailNum1(data.getTodayFailNum1()+Constants.formatLongNum(model.getNum()));
+                        data.setTodayFailMoney1(data.getTodayFailMoney1().add(Constants.formatBigDecimal(model.getMoney())));
+                        data.setTodayFailNum(data.getTodayFailNum()+Constants.formatLongNum(model.getNum()));
+                        data.setTodayFailMoney(data.getTodayFailMoney().add(Constants.formatBigDecimal(model.getMoney())));
+                    }
+                }else{
+                    //杞︽
+                    data.setTodayNum0(data.getTodayNum0()+Constants.formatLongNum(model.getNum()));
+                    data.setTodayMoney0(data.getTodayMoney0().add(Constants.formatBigDecimal(model.getMoney())));
+                    //寤舵湡娆�
+                    if(Constants.equalsInteger(model.getStatus(),Constants.ONE)){
+                        //浜ゆ槗鎴愬姛
+                        data.setTodayDoneNum(data.getTodayDoneNum()+Constants.formatLongNum(model.getNum()));
+                        data.setTodayDoneMoney(data.getTodayDoneMoney().add(Constants.formatBigDecimal(model.getMoney())));
+                        data.setTodayDoneNum0(data.getTodayDoneNum0()+Constants.formatLongNum(model.getNum()));
+                        data.setTodayDoneMoney0(data.getTodayDoneMoney0().add(Constants.formatBigDecimal(model.getMoney())));
+                    }else  if(Constants.equalsInteger(model.getStatus(),Constants.ZERO)){
+                        //浜ゆ槗涓�
+                        data.setTodayWaitNum(data.getTodayWaitNum()+Constants.formatLongNum(model.getNum()));
+                        data.setTodayWaitMoney(data.getTodayWaitMoney().add(Constants.formatBigDecimal(model.getMoney())));
+                        data.setTodayWaitNum0(data.getTodayWaitNum0()+Constants.formatLongNum(model.getNum()));
+                        data.setTodayWaitMoney0(data.getTodayWaitMoney0().add(Constants.formatBigDecimal(model.getMoney())));
+                    }else {
+                        //浜ゆ槗澶辫触
+                        data.setTodayFailNum(data.getTodayFailNum()+Constants.formatLongNum(model.getNum()));
+                        data.setTodayFailMoney(data.getTodayFailMoney().add(Constants.formatBigDecimal(model.getMoney())));
+                        data.setTodayFailNum0(data.getTodayFailNum0()+Constants.formatLongNum(model.getNum()));
+                        data.setTodayFailMoney0(data.getTodayFailMoney0().add(Constants.formatBigDecimal(model.getMoney())));
+                    }
+                }
+            }
+        }
+
+         Refund  refund = refundMapper.selectJoinOne(Refund.class,new MPJLambdaWrapper<Refund>()
+                .select("count(distinct(order_id)) as orderNum,count(id) as num,sum(money) as money")
+                .eq(Orders::getDeleted,Constants.ZERO )
+                .eq(Orders::getStatus,Constants.ONE)
+                .apply("to_days(create_time) =to_days(now())")
+                .last("limit 1"));
+
+        if(refund!=null){
+            data.setTodayRefundMoney(Constants.getFormatMoney(refund.getMoney()));
+            data.setTodayRefundOrderNum(Constants.formatLongNum(refund.getOrderNum()));
+            data.setTodayRefundNum(Constants.formatLongNum(refund.getNum()));
+        }
+        return  data;
+    }
+
+    private IndexOrderCountVO initIndexOrderCountMoel() {
+        IndexOrderCountVO data = new IndexOrderCountVO();
+        data.setTodayMoney(new BigDecimal(0));
+        data.setTodayMoney0(new BigDecimal(0));
+        data.setTodayMoney1(new BigDecimal(0));
+        data.setTodayNum(0l);
+        data.setTodayNum0(0l);
+        data.setTodayNum1(0l);
+
+        data.setTodayDoneMoney(new BigDecimal(0));
+        data.setTodayDoneMoney0(new BigDecimal(0));
+        data.setTodayDoneMoney1(new BigDecimal(0));
+        data.setTodayDoneNum(0l);
+        data.setTodayDoneNum0(0l);
+        data.setTodayDoneNum1(0l);
+
+        data.setTodayWaitMoney(new BigDecimal(0));
+        data.setTodayWaitMoney0(new BigDecimal(0));
+        data.setTodayWaitMoney1(new BigDecimal(0));
+        data.setTodayWaitNum(0l);
+        data.setTodayWaitNum0(0l);
+        data.setTodayWaitNum1(0l);
+
+        data.setTodayFailMoney(new BigDecimal(0));
+        data.setTodayFailMoney0(new BigDecimal(0));
+        data.setTodayFailMoney1(new BigDecimal(0));
+        data.setTodayFailNum(0l);
+        data.setTodayFailNum0(0l);
+        data.setTodayFailNum1(0l);
+
+        data.setTodayRefundMoney(new BigDecimal(0));
+        data.setTodayRefundOrderNum(0l);
+        data.setTodayRefundNum(0l);
+
+        return data;
+
+    }
+
     @Override
     public long count(Orders orders) {
         QueryWrapper<Orders> wrapper = new QueryWrapper<>(orders);
@@ -238,18 +374,74 @@
         try {
             time = Integer.parseInt(systemDictDataBiz.queryByCode(Constants.SYSTEM,Constants.PAY_VALID_TIME).getCode());
         }catch (Exception e){
-
         }
-        Date date = new Date();
-        ordersMapper.update(null,new UpdateWrapper<Orders>().lambda()
-                .set(Orders::getStatus,Constants.TWO)
-                .set(Orders::getCancelInfo,"瓒呮椂鏈敮浠橈紝鑷姩鍙栨秷")
-                .set(Orders::getCancelWay,Constants.ZERO)
-                .set(Orders::getCancelDate,date)
-                .set(Orders::getUpdateTime,date)
+        List<Orders> orderList =  ordersMapper.selectList(new QueryWrapper<Orders>().lambda()
                 .eq(Orders::getStatus,Constants.ZERO)
                 .apply("TIMESTAMPDIFF(MINUTE, create_time ,now()) > "+time));
+        if(orderList !=null && orderList.size()>0){
+            PayPublicModel publicModel =systemDictDataBiz.initPayPublicModel();
+            Date date = new Date();
+            for(Orders model : orderList){
+                queryPayOrderDetailBiz(model,publicModel,date,time);
+            }
+        }
     }
+    @Override
+    public  void updateByPayStatus(Orders param) {
+        int time = 30;
+        try {
+            time = Integer.parseInt(systemDictDataBiz.queryByCode(Constants.SYSTEM,Constants.PAY_VALID_TIME).getCode());
+        }catch (Exception e){
+        }
+        Orders  model =  ordersMapper.selectById(param.getId());
+        if(model !=null ){
+            PayPublicModel publicModel =systemDictDataBiz.initPayPublicModel();
+            Date date = new Date();
+            queryPayOrderDetailBiz(model,publicModel,date,time);
+        }
+    }
+
+    private void queryPayOrderDetailBiz(Orders model, PayPublicModel publicModel, Date date,int time) {
+        DoumeeTLUtil doumeeTLUtil = new DoumeeTLUtil(publicModel);
+        PayOrderNotifyParam map = doumeeTLUtil.sendQueryOrder(model.getId()+"");
+        int status = Constants.TWO;
+        if(map!=null){
+            String info = SybUtil.getPayInfoByStatus(map);
+            if(StringUtils.equals(map.getTrxcode(),"VSP501")
+                    ||StringUtils.equals(map.getTrxcode(),"VSP511")
+                    ||StringUtils.equals(map.getTrxcode(),"VSP551")){
+                //浜ゆ槗绫诲瀷鏄� 寰俊鏀粯 銆佹敮浠樺疂鏀粯鎴栬�呴摱鑱旀壂鐮佹敮浠橈紝璁板綍鏀粯鐘舵��
+                if(StringUtils.equals(map.getTrxstatus(),"0000")){
+                    //浜ゆ槗鎴愬姛
+                    model.setPayStatus(Constants.ONE);
+                    status = Constants.ONE;
+                } else if (StringUtils.equals(map.getTrxstatus(),"2000") || StringUtils.equals(map.getTrxstatus(),"2008")) {
+                    //濡傛灉浜ゆ槗鏈敮浠橈紝骞朵笖鏈秴杩囧崐灏忔椂锛屼笉澶勭悊
+                    if(date.getTime() - model.getCreateTime().getTime() < time*60*1000){
+                        return;
+                    }
+                }
+            }
+            model.setPayFee(map.getFee());
+            model.setStatus(status);
+            model.setPayDate(DateUtil.fromStringToDate("yyyyMMddHHmmss",map.getPaytime()));
+            model.setPayOrderId(map.getSrctrxid());//閫氳仈璁㈠崟鍙�
+            model.setPayThirdOrderId(map.getChnltrxid());//鏀粯瀹濆井淇¤鍗曞彿
+            model.setPayThirdOrderData(map.getChnldata());//涓夋柟浜ゆ槗娓犻亾鏁版嵁
+            model.setPayInfo(info);
+            model.setPayCode(map.getTrxcode());
+        }else{
+            model.setCancelDate(date);
+            model.setCancelInfo("瓒呮椂鏈敮浠橈紝鑷姩鍙栨秷");
+            model.setCancelWay(Constants.ZERO);
+            model.setStatus(Constants.TWO);
+        }
+        model.setUpdateTime(date);
+        ordersMapper.updateById(model) ;
+    }
+
+
+
     @Override
     public void returnPage(PayOrderParam param, HttpServletResponse response) throws IOException {
 //        String url =systemDictDataBiz.queryByCode(Constants.SYSTEM,Constants.PAY_RETURN_WEB_URL).getCode();
@@ -273,46 +465,24 @@
                     r ="鏀粯缁撴灉寮傚父锛屽鏈夌枒闂鑱旂郴瀹㈡湇浜哄憳";
                     return;
                 }
-                Orders model = ordersMapper.selectOne(new QueryWrapper<Orders>().lambda()
-                        .eq(Orders::getId,Integer.parseInt(map.getCusorderid()))
-                );
-                if(model ==null){
-                    log.error("鏀粯澶勭悊澶辫触======鏈壘鍒颁氦鏄撹鍗�"+map.getCusorderid());
-                    r ="鏀粯缁撴灉寮傚父锛岃鍗曟煡璇㈠け璐ワ紝濡傛湁鐤戦棶璇疯仈绯诲鏈嶄汉鍛�";
-                    return;
-                }
-                if(Constants.equalsInteger(model.getPayStatus(),Constants.ONE)){
-                    log.error("鏀粯澶勭悊======璁㈠崟宸叉敮浠�"+map.getCusorderid());
-                    return;
-                }
                 String info = SybUtil.getPayInfoByStatus(map);
                 if(StringUtils.equals(map.getTrxcode(),"VSP501")
                     ||StringUtils.equals(map.getTrxcode(),"VSP511")
                     ||StringUtils.equals(map.getTrxcode(),"VSP551")){
                     //浜ゆ槗绫诲瀷鏄� 寰俊鏀粯 銆佹敮浠樺疂鏀粯鎴栬�呴摱鑱旀壂鐮佹敮浠橈紝璁板綍鏀粯鐘舵��
-                    if(StringUtils.equals(map.getTrxstatus(),"0000")){
-                        //浜ゆ槗鎴愬姛
-                        model.setPayStatus(Constants.ONE);
-                        model.setStatus(Constants.ONE);
-                    }else{
-                        //浜ゆ槗澶辫触
-                        model.setStatus(Constants.TWO);
-                    }
-                }else{
-                    model.setStatus(Constants.TWO);
+                    dealOrdersResultBiz(info,map,r);
+                }else  if(StringUtils.equals(map.getTrxcode(),"VSP503")
+                        ||StringUtils.equals(map.getTrxcode(),"VSP513")
+                        ||StringUtils.equals(map.getTrxcode(),"VSP553")){
+                    //浜ゆ槗绫诲瀷鏄� 寰俊t閫�娆� 銆佹敮浠樺疂鏀粯閫�娆炬垨鑰呴摱鑱旀壂鐮侀��璐э紝璁板綍鏀粯鐘舵��
+                    dealRefunResultBiz(info,map,r);//澶勭悊閫�娆�
+                }else {
+                  //鍏朵粬绫诲瀷涓嶉�氱煡
                 }
-                model.setPayFee(map.getFee());
-                model.setPayDate(DateUtil.fromStringToDate("yyyyMMddHHmmss",map.getPaytime()));
-                model.setPayOrderId(map.getSrctrxid());//閫氳仈璁㈠崟鍙�
-                model.setPayThirdOrderId(map.getChnltrxid());//鏀粯瀹濆井淇¤鍗曞彿
-                model.setPayThirdOrderData(map.getChnldata());//涓夋柟浜ゆ槗娓犻亾鏁版嵁
-                model.setPayInfo(info);
-                model.setPayCode(map.getTrxcode());
-                ordersMapper.updateById(model);
+
             }else{
                 log.error("鏀粯楠岀澶辫触======");
                 r ="鏀粯澶辫触锛屽鏈夌枒闂鑱旂郴瀹㈡湇浜哄憳";
-                return;
             }
             //楠岀瀹屾瘯杩涜涓氬姟澶勭悊
         } catch (Exception e) {//澶勭悊寮傚父
@@ -326,16 +496,66 @@
         }
     }
 
-
-    public   TreeMap<String, String> getParams(HttpServletRequest request){
-        TreeMap<String, String> map = new TreeMap<String, String>();
-        Map reqMap = request.getParameterMap();
-        for(Object key:reqMap.keySet()){
-            String value = ((String[])reqMap.get(key))[0];
-            System.out.println(key+";"+value);
-            map.put(key.toString(),value);
+    private String dealRefunResultBiz(String info, PayOrderNotifyParam map, String r) {
+        Refund model = refundMapper.selectOne(new QueryWrapper<Refund>().lambda()
+                .eq(Refund::getId,Integer.parseInt(map.getCusorderid().replace(DoumeeTLUtil.REFUND_SN_PREFIX,"")))
+        );
+        if(model ==null){
+            log.error("鏀粯澶勭悊澶辫触======鏈壘鍒颁氦鏄撹鍗�"+map.getCusorderid());
+            return "鏀粯缁撴灉寮傚父锛岃鍗曟煡璇㈠け璐ワ紝濡傛湁鐤戦棶璇疯仈绯诲鏈嶄汉鍛�";
         }
-        return map;
+        if(Constants.equalsInteger(model.getStatus(),Constants.ONE)){
+            log.error("鏀粯澶勭悊======璁㈠崟宸叉敮浠�"+map.getCusorderid());
+            return  "璁㈠崟宸叉敮浠�";
+        }
+        if(StringUtils.equals(map.getTrxstatus(),"0000")){
+            //浜ゆ槗鎴愬姛
+            model.setStatus(Constants.ONE);
+        }else{
+            //浜ゆ槗澶辫触
+            model.setStatus(Constants.TWO);
+        }
+        model.setPayFee(map.getFee());
+        model.setPayDate(DateUtil.fromStringToDate("yyyyMMddHHmmss",map.getPaytime()));
+        model.setPayOrderId(map.getTrxid());//閫氳仈璁㈠崟鍙�
+        model.setPayThirdOrderId(map.getChnltrxid());//鏀粯瀹濆井淇¤鍗曞彿
+        model.setPayThirdOrderData(map.getChnldata());//涓夋柟浜ゆ槗娓犻亾鏁版嵁
+        model.setPayInfo(info);
+        model.setPayCode(map.getTrxcode());
+        refundMapper.updateById(model);
+        return  r;
     }
 
+    private String dealOrdersResultBiz(String info, PayOrderNotifyParam map,String r) {
+        Orders model = ordersMapper.selectOne(new QueryWrapper<Orders>().lambda()
+                .eq(Orders::getId,Integer.parseInt(map.getCusorderid()))
+        );
+        if(model ==null){
+            log.error("鏀粯澶勭悊澶辫触======鏈壘鍒颁氦鏄撹鍗�"+map.getCusorderid());
+            return "鏀粯缁撴灉寮傚父锛岃鍗曟煡璇㈠け璐ワ紝濡傛湁鐤戦棶璇疯仈绯诲鏈嶄汉鍛�";
+        }
+        if(Constants.equalsInteger(model.getPayStatus(),Constants.ONE)){
+            log.error("鏀粯澶勭悊======璁㈠崟宸叉敮浠�"+map.getCusorderid());
+            return  "璁㈠崟宸叉敮浠�";
+        }
+        if(StringUtils.equals(map.getTrxstatus(),"0000")){
+            //浜ゆ槗鎴愬姛
+            model.setPayStatus(Constants.ONE);
+            model.setStatus(Constants.ONE);
+        }else{
+            //浜ゆ槗澶辫触
+            model.setStatus(Constants.TWO);
+        }
+        model.setPayFee(map.getFee());
+        model.setPayDate(DateUtil.fromStringToDate("yyyyMMddHHmmss",map.getPaytime()));
+        model.setPayOrderId(map.getTrxid());//閫氳仈璁㈠崟鍙�
+        model.setPayThirdOrderId(map.getChnltrxid());//鏀粯瀹濆井淇¤鍗曞彿
+        model.setPayThirdOrderData(map.getChnldata());//涓夋柟浜ゆ槗娓犻亾鏁版嵁
+        model.setPayInfo(info);
+        model.setPayCode(map.getTrxcode());
+        ordersMapper.updateById(model);
+        return  r;
+    }
+
+
 }

--
Gitblit v1.9.3