From ef270bd1855b5ce3f398c5df024840a498e33a8f Mon Sep 17 00:00:00 2001
From: MercuryZ <zdmisif@126.com>
Date: 星期四, 31 三月 2022 14:09:17 +0800
Subject: [PATCH] Merge remote-tracking branch 'origin/master'

---
 ximon-admin/src/main/java/com/sandu/ximon/admin/pay/alipay/UsrAlipayConfigService.java |  133 ++++++++++++++++++++++++++++++++++++++++++++
 1 files changed, 133 insertions(+), 0 deletions(-)

diff --git a/ximon-admin/src/main/java/com/sandu/ximon/admin/pay/alipay/UsrAlipayConfigService.java b/ximon-admin/src/main/java/com/sandu/ximon/admin/pay/alipay/UsrAlipayConfigService.java
new file mode 100644
index 0000000..c3bd4ff
--- /dev/null
+++ b/ximon-admin/src/main/java/com/sandu/ximon/admin/pay/alipay/UsrAlipayConfigService.java
@@ -0,0 +1,133 @@
+package com.sandu.ximon.admin.pay.alipay;
+
+import cn.hutool.core.bean.BeanUtil;
+import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
+import com.baomidou.mybatisplus.core.toolkit.Wrappers;
+import com.github.pagehelper.PageHelper;
+import com.sandu.common.execption.BusinessException;
+import com.sandu.common.object.BaseConditionVO;
+import com.sandu.common.service.impl.BaseServiceImpl;
+import com.sandu.ximon.admin.param.AlipayConfigParam;
+import com.sandu.ximon.admin.security.SecurityUtils;
+import com.sandu.ximon.admin.service.ClientService;
+import com.sandu.ximon.admin.service.PoleService;
+import com.sandu.ximon.admin.utils.SpringContextUtil;
+import com.sandu.ximon.dao.domain.AliConfigEntity;
+import com.sandu.ximon.dao.domain.Pole;
+import com.sandu.ximon.dao.domain.WxConfigEntity;
+import com.sandu.ximon.dao.mapper.UsrAlipayConfigMapper;
+import lombok.AllArgsConstructor;
+import org.springframework.stereotype.Service;
+
+import java.util.List;
+
+/**
+ * @Author liuhaonan
+ * @Date 2022/3/15
+ * @Version 1.0
+ */
+@Service
+@AllArgsConstructor
+public class UsrAlipayConfigService extends BaseServiceImpl<UsrAlipayConfigMapper, AliConfigEntity> {
+
+    private final UsrAlipayConfigMapper usrAlipayConfigMapper;
+    private final ClientService clientService;
+    private final PoleService poleService;
+
+    public AliConfigEntity getConfigByPoleId(Long poleId) {
+        Pole pole = poleService.getById(poleId);
+        if (pole == null) {
+            throw new BusinessException("鐏潌id閿欒鎴栫伅鏉嗕笉瀛樺湪");
+        }
+        AliConfigEntity config;
+        if (pole.getClientId() == null) {
+            config = getById(0);
+        }
+        config = getOne(Wrappers.lambdaQuery(AliConfigEntity.class).eq(AliConfigEntity::getCreateUserId, SecurityUtils.getUserId()));
+        if(config==null){
+            throw new BusinessException("鐢ㄦ埛鏈厤缃敮浠橀厤缃�,璇烽厤缃悗閲嶈瘯");
+        }
+        return config;
+    }
+
+
+    public static UsrAlipayConfigService getBean(){
+        return (UsrAlipayConfigService) SpringContextUtil.getBean("UsrAlipayConfigService");
+    }
+
+
+    public boolean addAliPayConfig(AlipayConfigParam configParam){
+        AliConfigEntity config =new AliConfigEntity();
+        BeanUtil.copyProperties(configParam,config);
+        if(SecurityUtils.getClientId()!=null){
+            config.setCreateUserId(SecurityUtils.getUserId());
+            if(clientService.findClientId()){
+                config.setClientId(clientService.getClientId());
+            }
+        }
+        return save(config);
+    }
+
+    public boolean updateAliPayConfig(Integer id,AlipayConfigParam configParam){
+        AliConfigEntity byId = getById(id);
+        if(byId==null){
+            throw new BusinessException("閰嶇疆id閿欒鎴栭厤缃笉瀛樺湪");
+        }
+        AliConfigEntity config =new AliConfigEntity();
+        BeanUtil.copyProperties(configParam,config);
+        config.setConfigId(id);
+        return updateById(config);
+    }
+
+    public boolean deleteAliPayConfig(Integer id){
+        AliConfigEntity byId = getById(id);
+        if(byId==null){
+            throw new BusinessException("閰嶇疆id閿欒鎴栭厤缃笉瀛樺湪");
+        }
+        return removeById(id);
+    }
+
+
+
+    public List<AliConfigEntity> configList(BaseConditionVO baseConditionVO,String keyword){
+        LambdaQueryWrapper<AliConfigEntity> wrapper =new LambdaQueryWrapper<>();
+        System.out.println("----------------------------"+clientService.findClientId());
+        PageHelper.startPage(baseConditionVO.getPageNo(), baseConditionVO.getPageSize());
+        if(SecurityUtils.getClientId()!=null){//瀹㈡埛
+            if(clientService.findClientId()){//浜岀骇瀹㈡埛
+                PageHelper.startPage(baseConditionVO.getPageNo(), baseConditionVO.getPageSize());
+                wrapper= Wrappers.lambdaQuery(AliConfigEntity.class).eq(AliConfigEntity::getCreateUserId,SecurityUtils.getUserId());
+            }else if(!clientService.findClientId()){//涓�绾у鎴�
+                PageHelper.startPage(baseConditionVO.getPageNo(), baseConditionVO.getPageSize());
+                wrapper= Wrappers.lambdaQuery(AliConfigEntity.class).eq(AliConfigEntity::getClientId,SecurityUtils.getUserId());
+            }
+        } else {//绠$悊
+            PageHelper.startPage(baseConditionVO.getPageNo(), baseConditionVO.getPageSize());
+            wrapper= Wrappers.lambdaQuery(AliConfigEntity.class);
+        }
+
+        if(!keyword.isEmpty()){
+            wrapper= wrapper.like(AliConfigEntity::getConfigId,keyword).or(
+                    getAppId->{
+                        getAppId.like(AliConfigEntity::getAppId,keyword);
+                    }
+            ).or(
+                    getPid->{
+                        getPid.like(AliConfigEntity::getPid,keyword);
+                    }
+            ).or(
+                    getPublicKey->{
+                        getPublicKey.like(AliConfigEntity::getPublicKey,keyword);
+                    }
+            ).or(
+                    getPrivateKey->{
+                        getPrivateKey.like(AliConfigEntity::getPrivateKey,keyword);
+                    }
+            );
+        }
+        return list(wrapper);
+    }
+
+
+
+}

--
Gitblit v1.9.3