添加会员充值退款

src/main/java/com/chaozhanggui/system/cashierservice/service/MemberService.java

@@ -729,6 +729,74 @@ public class MemberService {
     }
 
 
+    public Result returnAccount(String flowId,String remark){
+        if(ObjectUtil.isEmpty(flowId)||ObjectUtil.isNull(flowId)){
+            return Result.fail(CodeEnum.PARAM);
+        }
+        TbShopUserFlow flow= tbShopUserFlowMapper.selectByPrimaryKey(Integer.valueOf(flowId));
+        if(ObjectUtil.isNull(flow)||ObjectUtil.isEmpty(flow)){
+            return Result.fail(CodeEnum.USERSHOPFLOWNOEXIST);
+        }
+
+
+        TbShopUser user=tbShopUserMapper.selectByPrimaryKey(flow.getShopUserId());
+
+        if(ObjectUtil.isEmpty(user)||ObjectUtil.isNull(user)){
+            return Result.fail(CodeEnum.ACCOUNTEIXST);
+        }
+
+        if(N.gt(flow.getAmount(),user.getAmount())){
+            return Result.fail(CodeEnum.ACCOUNTAMOUNT);
+        }
+
+        TbShopInfo shopInfo=tbShopInfoMapper.selectByPrimaryKey(Integer.valueOf(user.getShopId()));
+        if(ObjectUtil.isEmpty(shopInfo)||ObjectUtil.isNull(shopInfo)){
+            return Result.fail(CodeEnum.MERCHANTEIXST);
+        }
+
+
+        TbMerchantThirdApply thirdApply = tbMerchantThirdApplyMapper.selectByPrimaryKey(Integer.valueOf(shopInfo.getMerchantId()));
+        if (ObjectUtil.isEmpty(thirdApply) || ObjectUtil.isNull(thirdApply)) {
+            return Result.fail(CodeEnum.NOCUSTOMER);
+        }
+
+
+        if("scanMemberIn".equals(flow.getBizCode())){
+            PublicResp<OrderStatusQueryResp> orderstatus = thirdPayService.queryOrder(url, thirdApply.getAppId(),flow.getAmount().toPlainString(), null, thirdApply.getAppToken());
+            if (ObjectUtil.isNotNull(orderstatus) && ObjectUtil.isNotEmpty(orderstatus)) {
+                if ("000000".equals(orderstatus.getCode())) {
+                    if ("TRADE_SUCCESS".equals(orderstatus.getObjData().getState())) {
+                        user.setAmount(user.getAmount().subtract(flow.getAmount()));
+                        user.setUpdatedAt(System.currentTimeMillis());
+                        tbShopUserMapper.updateByPrimaryKey(user);
+
+                        flow.setIsReturn("1");
+                        flow.setRemark(remark);
+                        tbShopUserFlowMapper.updateByPrimaryKey(flow);
+                        return Result.success(CodeEnum.SUCCESS);
+                    }
+                }
+            }
+        }else if("cashMemberIn".equals(flow.getBizCode())){
+
+            user.setAmount(user.getAmount().subtract(flow.getAmount()));
+            user.setUpdatedAt(System.currentTimeMillis());
+            tbShopUserMapper.updateByPrimaryKey(user);
+
+            flow.setIsReturn("1");
+            flow.setRemark(remark);
+            tbShopUserFlowMapper.updateByPrimaryKey(flow);
+            return Result.success(CodeEnum.SUCCESS);
+
+        }else {
+            return Result.fail(CodeEnum.OPARETIONERROR);
+        }
+        return Result.fail(CodeEnum.FAIL);
+
+
+    }
+
+
 
 
 

src/main/java/com/chaozhanggui/system/cashierservice/service/PayService.java

@@ -1275,7 +1275,13 @@ public class PayService {
 //        jsonObject.put("data",new ReturnWTZInfo(orderId+"",newOrderInfo.getPayAmount(),details));
         producer.putOrderCollect(jsonObject.toJSONString());
 
-        producer.printMechine(String.valueOf(orderId));
+
+
+        producer.printMechine(newOrderInfo.getId().toString());
+
+
+
+
 
         //修改耗材数据
         JSONObject jsonObject1 = new JSONObject();