From 1bdff9832607635798325325207caa76e4e02daf Mon Sep 17 00:00:00 2001
From: =?UTF-8?q?=E5=B1=B1=E4=B8=9C=E4=BA=91=E5=88=99?= <fae@5iot.cn>
Date: Mon, 19 Feb 2024 14:16:05 +0800
Subject: [PATCH] =?UTF-8?q?=E8=A1=A5=E5=85=85=E8=BD=AE=E8=AF=A2=E4=B8=9A?=
 =?UTF-8?q?=E5=8A=A1?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../yunze/card/YzCardController.java          | 19 +++++++++++++++++++
 .../common/mapper/yunze/YzCardMapper.java     |  3 ++-
 .../mapper/quartz/yunze/YzCardMapper.xml      |  6 ++++++
 .../service/impl/yunze/YzCardServiceImpl.java | 16 ++++++++++++++++
 4 files changed, 43 insertions(+), 1 deletion(-)

diff --git a/yunze-admin/src/main/java/com/yunze/web/controller/yunze/card/YzCardController.java b/yunze-admin/src/main/java/com/yunze/web/controller/yunze/card/YzCardController.java
index 81cc922..d730636 100644
--- a/yunze-admin/src/main/java/com/yunze/web/controller/yunze/card/YzCardController.java
+++ b/yunze-admin/src/main/java/com/yunze/web/controller/yunze/card/YzCardController.java
@@ -1360,7 +1360,26 @@ public class YzCardController extends MyBaseController {
         return Myerr("物联卡 公开查询简要信息 操作失败！");
     }
 
+    @Log(title = "添加卡至自动轮训", businessType = BusinessType.UPDATE)
+    @PreAuthorize("@ss.hasPermi('yunze:card:showhistoryUsed')")
+    @PostMapping(value = "/addAutoPolling", produces = {"application/json;charset=utf-8"})
+    public String  addAutoPolling(@RequestBody String Pstr) {
+        HashMap<String, Object> Parammap = new HashMap<String, Object>();
+        if (Pstr != null) {
+            Pstr = Pstr.replace("%2F", "/");//转义 /
+        }
+        try {
+            Pstr = AesEncryptUtil.desEncrypt(Pstr);
+            Parammap.putAll(JSON.parseObject(Pstr));
+            return  MyRetunSuccess(null, yzCardServiceImpl.addAutoPolling(Parammap));
 
+
+        } catch (Exception e) {
+            String ip = IpUtils.getIpAddr(ServletUtils.getRequest());
+            logger.error("<br/> updPwd  <br/> Pstr = " + Pstr + " <br/> ip =  " + ip + " <br/> ", e.getCause().toString());
+        }
+        return Myerr("添加卡至自动轮训 操作失败！");
+    }
     /**
      * 获取 上游单卡订购套餐列表
      *
diff --git a/yunze-common/src/main/java/com/yunze/common/mapper/yunze/YzCardMapper.java b/yunze-common/src/main/java/com/yunze/common/mapper/yunze/YzCardMapper.java
index 5973fe3..1a1692b 100644
--- a/yunze-common/src/main/java/com/yunze/common/mapper/yunze/YzCardMapper.java
+++ b/yunze-common/src/main/java/com/yunze/common/mapper/yunze/YzCardMapper.java
@@ -582,7 +582,8 @@ public interface YzCardMapper
      * @return
      */
     public List<Map<String,Object>> findSynIsExist(Map map);
-
+    void addAutoPolling(Map<String,Object> map);
+    String selCardIsInAuto(Map<String,Object> map);
 }
 
 
diff --git a/yunze-common/src/main/resources/mapper/quartz/yunze/YzCardMapper.xml b/yunze-common/src/main/resources/mapper/quartz/yunze/YzCardMapper.xml
index 9c7d360..6175bfa 100644
--- a/yunze-common/src/main/resources/mapper/quartz/yunze/YzCardMapper.xml
+++ b/yunze-common/src/main/resources/mapper/quartz/yunze/YzCardMapper.xml
@@ -2244,7 +2244,13 @@
 	</select>
 
 
+	<insert id="addAutoPolling" parameterType="java.util.Map">
+		insert into yz_auto_polling(iccid,route_id)values(#{iccid},#{channel_id})
+	</insert>
 
+	<select id="selCardIsInAuto" parameterType="java.util.Map" resultType="java.lang.String">
+		select iccid from yz_auto_polling where iccid =#{iccid}
+	</select>
 
 
 
diff --git a/yunze-system/src/main/java/com/yunze/system/service/impl/yunze/YzCardServiceImpl.java b/yunze-system/src/main/java/com/yunze/system/service/impl/yunze/YzCardServiceImpl.java
index f787f6c..c2ee09e 100644
--- a/yunze-system/src/main/java/com/yunze/system/service/impl/yunze/YzCardServiceImpl.java
+++ b/yunze-system/src/main/java/com/yunze/system/service/impl/yunze/YzCardServiceImpl.java
@@ -1279,8 +1279,24 @@ public class YzCardServiceImpl implements IYzCardService {
         return retMap;
     }
 
+    public String addAutoPolling(HashMap<String, Object> parammap) {
+        try{
+            String iccid = yzCardMapper.selCardIsInAuto(parammap);
+            if (iccid == null) {
+                yzCardMapper.addAutoPolling(parammap);
+                return "添加成功!";
+            }else{
+                return "卡已添加至自动轮训!请勿重复操作!";
+            }
 
 
+        }catch (Exception e){
+            return "添加失败!:"+e.getMessage();
+        }
+
+
+    }
+
     public boolean isClose(String ip, String method, int times) {
         String key = ip + "_api" + method;
         Long count = redisCache.increment(key, 1);