Merge branch 'pre' into sxf

schedule/src/main/java/com/hfkj/schedule/TradeOrderSchedule.java

@@ -258,7 +258,7 @@ public class TradeOrderSchedule {
     @Scheduled(cron="0 0/1 * * * ?")
     public void tradeOrderSettle() {
         Map<String, Object> param = new HashMap<>();
-        param.put("status", "3");
+        param.put("statusList", "3,6");
         param.put("settleAmountIsNull", true);
 
         Calendar calendar = Calendar.getInstance();
@@ -329,6 +329,9 @@ public class TradeOrderSchedule {
 
         for (BsTradeOrderRefund tradeOrderRefund : tradeOrderRefundList) {
             try {
+                // 查询交易
+                BsTradeOrder tradeOrder = tradeOrderService.getOrderByOutTradeNo(tradeOrderRefund.getOutTradeNo());
+                if (tradeOrder != null && tradeOrder.getSettleAmount() != null) {
                     // 查询手续费
                     JSONObject queryTrans = laKaLaTradeService.queryTradeOrderRefundTrans(tradeOrderRefund.getRefundNo());
                     if (queryTrans != null) {
@@ -337,25 +340,6 @@ public class TradeOrderSchedule {
                         tradeOrderRefund.setSettleDate(queryTrans.getDate("clear_date"));
                         tradeOrderRefundService.editOrderRefund(tradeOrderRefund);
 
-                    // 查询交易
-                    BsTradeOrder tradeOrder = tradeOrderService.getOrderByOutTradeNo(tradeOrderRefund.getOutTradeNo());
-                    if (tradeOrder != null) {
-                        if (tradeOrder.getSettleAmount() == null) {
-                            // 查询手续费
-                            JSONObject tradeOrderTrans = laKaLaTradeService.queryTradeOrderTrans(tradeOrder.getOutTradeNo());
-                            if (tradeOrderTrans != null && tradeOrderTrans.getString("trade_state").equals("03")) {
-                                tradeOrder.setShdFeeAmt(tradeOrderTrans.getBigDecimal("fee_amount"));
-                                tradeOrder.setSettleAmount(new BigDecimal(tradeOrderTrans.getString("settle_amount").replace(",","")));
-                                tradeOrder.setSettleDate(tradeOrderTrans.getDate("clear_date"));
-                                tradeOrder.setFeeRate(new BigDecimal(tradeOrderTrans.getString("fee_rate").split(",")[0]));
-                                tradeOrderService.editOrder(tradeOrder);
-                            }
-                        }
-                        tradeOrder.setShdFeeAmt(tradeOrder.getShdFeeAmt().subtract(tradeOrderRefund.getShdFeeAmt()));
-                        tradeOrder.setSettleAmount(tradeOrder.getSettleAmount().subtract(tradeOrderRefund.getSettleAmount()));
-                        tradeOrderService.editOrder(tradeOrder);
-
-
                         BsTradeSettle tradeSettle = new BsTradeSettle();
                         tradeSettle.setCompanyId(tradeOrder.getCompanyId());
                         tradeSettle.setAgentId(tradeOrder.getAgentId());
@@ -383,6 +367,10 @@ public class TradeOrderSchedule {
                         tradeSettle.setFeeRate(tradeOrder.getFeeRate());
                         tradeSettle.setOrgOutTradeNo(tradeOrder.getOutTradeNo());
                         tradeSettleService.editData(tradeSettle);
+
+                        tradeOrder.setShdFeeAmt(tradeOrder.getShdFeeAmt().subtract(tradeOrderRefund.getShdFeeAmt()));
+                        tradeOrder.setSettleAmount(tradeOrder.getSettleAmount().subtract(tradeOrderRefund.getSettleAmount()));
+                        tradeOrderService.editOrder(tradeOrder);
                     }
                 }
             } catch (Exception e) {

service/src/main/java/com/hfkj/service/impl/BsTradeOrderServiceImpl.java

@@ -24,10 +24,7 @@ import org.springframework.stereotype.Service;
 import javax.annotation.Resource;
 import javax.servlet.http.HttpServletRequest;
 import java.math.BigDecimal;
-import java.util.Date;
+import java.util.*;
-import java.util.HashMap;
-import java.util.List;
-import java.util.Map;
 
 @Service("tradeOrderService")
 public class BsTradeOrderServiceImpl implements BsTradeOrderService {
@@ -405,6 +402,15 @@ public class BsTradeOrderServiceImpl implements BsTradeOrderService {
             criteria.andStatusEqualTo(MapUtils.getInteger(param, "status"));
         }
 
+        if (StringUtils.isNotBlank(MapUtils.getString(param, "statusList"))) {
+            String[] statusLists = MapUtils.getString(param, "statusList").split(",");
+            List<Integer> statusList = new ArrayList<>();
+            for (String s : statusLists) {
+                statusList.add(Integer.parseInt(s));
+            }
+            criteria.andStatusIn(statusList);
+        }
+
         if (StringUtils.isNotBlank(MapUtils.getString(param, "settleAmountIsNull"))) {
             criteria.andSettleAmountIsNull();
         }