From bbe4a841ea43255ca71b41541d3054cf3c1ec157 Mon Sep 17 00:00:00 2001
From: weidong <weidong@im-droid.com>
Date: Tue, 2 Jan 2024 12:05:32 +0800
Subject: [PATCH] =?UTF-8?q?1=E3=80=81=E5=A2=9E=E5=8A=A0=E7=99=BB=E5=BD=95?=
 =?UTF-8?q?=E7=94=A8=E6=88=B7=E5=AF=86=E7=A0=81=E4=BF=AE=E6=94=B9=E5=8A=9F?=
 =?UTF-8?q?=E8=83=BD=202=E3=80=81=E5=A2=9E=E5=8A=A0debug=E6=89=93=E5=8D=B0?=
 =?UTF-8?q?d331=E6=B6=88=E6=81=AF=E5=BA=8F=E5=8F=B7=E5=92=8C=E9=95=BF?=
 =?UTF-8?q?=E5=BA=A6=EF=BC=8C=E7=94=A8=E6=9D=A5=E5=AE=9A=E4=BD=8Dd331?=
 =?UTF-8?q?=E5=AD=97=E8=8A=82=E6=95=B0=E7=BB=9F=E8=AE=A1=E9=94=99=E8=AF=AF?=
 =?UTF-8?q?=E7=9A=84=E9=97=AE=E9=A2=98?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../executor/D331RtcmMessageExecutor.java     |  2 +-
 .../D3F0SelfCheckMessageExecutor.java         |  8 +++
 .../D3F2StopIndicationMessageExecutor.java    |  7 +-
 .../beidou/controller/UserController.java     | 70 +++++++++++++++++++
 .../java/com/imdroid/beidou/entity/User.java  |  3 +-
 sec-beidou/src/main/resources/db/schema.sql   |  2 +-
 .../src/main/resources/templates/index.html   |  2 +-
 .../resources/templates/page/user_pwd.html    | 64 +++++++++++++++++
 8 files changed, 153 insertions(+), 5 deletions(-)
 create mode 100644 sec-beidou/src/main/java/com/imdroid/beidou/controller/UserController.java
 create mode 100644 sec-beidou/src/main/resources/templates/page/user_pwd.html

diff --git a/sec-beidou-rtcm/src/main/java/com/imdroid/sideslope/executor/D331RtcmMessageExecutor.java b/sec-beidou-rtcm/src/main/java/com/imdroid/sideslope/executor/D331RtcmMessageExecutor.java
index 84b68235..f751f7fe 100644
--- a/sec-beidou-rtcm/src/main/java/com/imdroid/sideslope/executor/D331RtcmMessageExecutor.java
+++ b/sec-beidou-rtcm/src/main/java/com/imdroid/sideslope/executor/D331RtcmMessageExecutor.java
@@ -29,7 +29,7 @@ public class D331RtcmMessageExecutor implements Executor<D331RtcmMessage, Void>
     @Override
     public Void execute(D331RtcmMessage message) {
         if (logger.isDebugEnabled()) {
-            logger.debug("receive d331 rtcm message of device:{}", message.getId());
+            logger.debug("receive d331 rtcm message of device: "+message.getId()+", seq:"+message.getSeq()+", len:"+message.getLen());
         }
         // 补齐tenantId
         Device device1 = deviceService.findByDeviceId(message.getId());
diff --git a/sec-beidou-rtcm/src/main/java/com/imdroid/sideslope/executor/D3F0SelfCheckMessageExecutor.java b/sec-beidou-rtcm/src/main/java/com/imdroid/sideslope/executor/D3F0SelfCheckMessageExecutor.java
index c94bab68..ac29b727 100644
--- a/sec-beidou-rtcm/src/main/java/com/imdroid/sideslope/executor/D3F0SelfCheckMessageExecutor.java
+++ b/sec-beidou-rtcm/src/main/java/com/imdroid/sideslope/executor/D3F0SelfCheckMessageExecutor.java
@@ -7,6 +7,8 @@ import com.imdroid.sideslope.sal.DeviceService;
 import com.imdroid.sideslope.sal.Device;
 import com.imdroid.sideslope.service.DataPersistService;
 import com.imdroid.common.util.ThreadManager;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.stereotype.Component;
 
@@ -18,6 +20,8 @@ import javax.annotation.Resource;
  */
 @Component
 public class D3F0SelfCheckMessageExecutor implements Executor<D3F0SelfCheckMessage, Void> {
+    private final Logger logger = LoggerFactory.getLogger(this.getClass());
+
     @Autowired
     private DataPersistService dataPersistService;
     @Autowired
@@ -28,10 +32,14 @@ public class D3F0SelfCheckMessageExecutor implements Executor<D3F0SelfCheckMessa
 
     @Override
     public Void execute(D3F0SelfCheckMessage message) {
+        if (logger.isDebugEnabled()) {
+            logger.debug("receive d3f0 message of device: "+message.getId());
+        }
         // 补齐tenantId
         Device device = deviceService.findByDeviceId(message.getId());
         if(device == null) return null;
         message.setTenantId(device.getTenantId());
+        device.clearStat();
 
         ThreadManager.getFixedThreadPool().submit(() -> {
             GnssStatus lastGnssStatus = dataPersistService.getDeviceState(message.getId());
diff --git a/sec-beidou-rtcm/src/main/java/com/imdroid/sideslope/executor/D3F2StopIndicationMessageExecutor.java b/sec-beidou-rtcm/src/main/java/com/imdroid/sideslope/executor/D3F2StopIndicationMessageExecutor.java
index 68abe8cf..454f788b 100644
--- a/sec-beidou-rtcm/src/main/java/com/imdroid/sideslope/executor/D3F2StopIndicationMessageExecutor.java
+++ b/sec-beidou-rtcm/src/main/java/com/imdroid/sideslope/executor/D3F2StopIndicationMessageExecutor.java
@@ -8,6 +8,8 @@ import com.imdroid.sideslope.sal.Device;
 import com.imdroid.sideslope.sal.DeviceService;
 import com.imdroid.sideslope.service.DataPersistService;
 import com.imdroid.common.util.ThreadManager;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.stereotype.Component;
 
@@ -21,6 +23,7 @@ import java.time.LocalDateTime;
  */
 @Component
 public class D3F2StopIndicationMessageExecutor implements Executor<D3F2StopIndicationMessage, Void> {
+    private final Logger logger = LoggerFactory.getLogger(this.getClass());
 
     @Autowired
     private DataPersistService dataPersistService;
@@ -34,6 +37,9 @@ public class D3F2StopIndicationMessageExecutor implements Executor<D3F2StopIndic
 
     @Override
     public Void execute(D3F2StopIndicationMessage message) {
+        if (logger.isDebugEnabled()) {
+            logger.debug("receive d3f2 message of device: "+message.getId());
+        }
         // 补齐tenantId
         String deviceId = message.getId();
         Device device = deviceService.findByDeviceId(deviceId);
@@ -42,7 +48,6 @@ public class D3F2StopIndicationMessageExecutor implements Executor<D3F2StopIndic
         GnssTrxMsg gnssTrxMsg = message.getTrxMsg();
         gnssTrxMsg.setD3xxbytes(device.getD3xxbytes());
         gnssTrxMsg.setB562bytes(device.getB562bytes());
-        device.clearStat();
 
         LocalDateTime uploadTime = multiLineGNSSCalcService.getUploadTime(device.getDeviceId());
 
diff --git a/sec-beidou/src/main/java/com/imdroid/beidou/controller/UserController.java b/sec-beidou/src/main/java/com/imdroid/beidou/controller/UserController.java
new file mode 100644
index 00000000..af7c63a2
--- /dev/null
+++ b/sec-beidou/src/main/java/com/imdroid/beidou/controller/UserController.java
@@ -0,0 +1,70 @@
+package com.imdroid.beidou.controller;
+
+import com.alibaba.fastjson.JSONObject;
+import com.imdroid.beidou.common.HttpResult;
+import com.imdroid.beidou.entity.User;
+import com.imdroid.beidou.entity.UserMapper;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.security.crypto.bcrypt.BCryptPasswordEncoder;
+import org.springframework.stereotype.Controller;
+import org.springframework.web.bind.annotation.*;
+
+import javax.servlet.http.HttpSession;
+
+@Controller
+public class UserController extends BasicController {
+
+    @Autowired
+    UserMapper userMapper;
+
+    /**** 推送页面  *****/
+    @RequestMapping("/page/user_pwd")
+    public String warning() throws Exception {
+        return "/page/user_pwd";
+    }
+
+    /**** 推送数据  *****/
+    @PostMapping("/personal/update_pwd")
+    @ResponseBody
+    public String updatePwd(HttpSession session, @RequestBody JSONObject object) throws Exception {
+        String result = "修改成功";
+        boolean flag = false;
+        String name = (String) session.getAttribute("login_user");
+        User user = userMapper.queryByName(name);
+        if (user != null) {
+            String old_pwd = object.getString("old_pwd");
+            String new_pwd = object.getString("new_pwd");
+            String re_pwd = object.getString("re_pwd");
+            BCryptPasswordEncoder pwdEncoder = new BCryptPasswordEncoder();
+            if (!pwdEncoder.matches(old_pwd, user.getPwd())) {
+                result = "原密码错误";
+            } else if (!new_pwd.equals(re_pwd)) {
+                result = "新密码输入不一致";
+            }
+            else if(IsSimplePassword(new_pwd)){
+                result = "密码过于简单，必须是数字和字母的组合";
+            }
+            else{
+                flag = true;
+                user.setPwd(pwdEncoder.encode(new_pwd));
+                user.setInit_pwd(false);
+                userMapper.updateById(user);
+
+            }
+        }
+        return HttpResult.result(flag?HttpResult.HTTP_RSP_OK:HttpResult.HTTP_RSP_FAILED,result);
+    }
+
+    boolean IsSimplePassword(String pwd){
+        if(pwd.length()<8) return true;
+
+        boolean hasNum = false;
+        boolean hasNotNum = false;
+        for(int i=0; i<pwd.length(); i++){
+            char ch = pwd.charAt(i);
+            if(ch >='0' && ch <='9') hasNum = true;
+            else hasNotNum = true;
+        }
+        return !(hasNum && hasNotNum);
+    }
+}
diff --git a/sec-beidou/src/main/java/com/imdroid/beidou/entity/User.java b/sec-beidou/src/main/java/com/imdroid/beidou/entity/User.java
index 95e04c73..0fa21b9a 100644
--- a/sec-beidou/src/main/java/com/imdroid/beidou/entity/User.java
+++ b/sec-beidou/src/main/java/com/imdroid/beidou/entity/User.java
@@ -1,5 +1,6 @@
 package com.imdroid.beidou.entity;
 
+import com.baomidou.mybatisplus.annotation.IdType;
 import com.baomidou.mybatisplus.annotation.TableId;
 import com.baomidou.mybatisplus.annotation.TableName;
 import lombok.AllArgsConstructor;
@@ -12,7 +13,7 @@ import lombok.NoArgsConstructor;
 @TableName(value = "UserCfg")
 public class User {
 
-    @TableId
+    @TableId(value = "id", type = IdType.AUTO)
     private Long id;
 
     int tenant_id;
diff --git a/sec-beidou/src/main/resources/db/schema.sql b/sec-beidou/src/main/resources/db/schema.sql
index 9fca9417..f534b682 100644
--- a/sec-beidou/src/main/resources/db/schema.sql
+++ b/sec-beidou/src/main/resources/db/schema.sql
@@ -1,5 +1,5 @@
 CREATE TABLE IF NOT EXISTS `UserCfg` (
-    `id` bigint(20),
+    `id` bigint(20) AUTO_INCREMENT,
     `tenant_id` int DEFAULT 0,
     `name` varchar(20) NOT NULL,
     `pwd` varchar(64) NOT NULL,
diff --git a/sec-beidou/src/main/resources/templates/index.html b/sec-beidou/src/main/resources/templates/index.html
index 5137b07e..67011383 100644
--- a/sec-beidou/src/main/resources/templates/index.html
+++ b/sec-beidou/src/main/resources/templates/index.html
@@ -67,7 +67,7 @@
                             <a href="javascript:;" layuimini-content-href="page/user-setting.html" data-title="基本资料" data-icon="fa fa-gears">基本资料<span class="layui-badge-dot"></span></a>
                         </dd>
                         <dd>
-                            <a href="javascript:;" layuimini-content-href="page/user-password.html" data-title="修改密码" data-icon="fa fa-gears">修改密码</a>
+                            <a href="javascript:;" layuimini-content-href="page/user_pwd" data-title="修改密码" data-icon="fa fa-gears">修改密码</a>
                         </dd>
                         <dd>
                             <hr>
diff --git a/sec-beidou/src/main/resources/templates/page/user_pwd.html b/sec-beidou/src/main/resources/templates/page/user_pwd.html
new file mode 100644
index 00000000..3193de26
--- /dev/null
+++ b/sec-beidou/src/main/resources/templates/page/user_pwd.html
@@ -0,0 +1,64 @@
+<div class="layuimini-container layuimini-page-anim">
+    <div class="layuimini-main">
+        <div class="layui-card top-panel">
+            <div class="layui-card-body">
+            <form class="layui-form" >
+                <div class="layui-form" lay-filter="changePassword">
+                    <div class="layui-form-item">
+                        <label class="layui-form-label">当前密码</label>
+                        <div class="layui-input-inline">
+                            <input type="password" name="old_pwd" lay-verify="required" lay-verType="tips" class="layui-input">
+                        </div>
+                    </div>
+                    <div class="layui-form-item">
+                        <label class="layui-form-label">新密码</label>
+                        <div class="layui-input-inline">
+                            <input type="password" name="new_pwd" lay-verify="pass" lay-verType="tips" autocomplete="off" id="LAY_password" class="layui-input">
+                        </div>
+                        <div class="layui-form-mid layui-word-aux">8个以上字符，包含数字和非数字</div>
+                    </div>
+                    <div class="layui-form-item">
+                        <label class="layui-form-label">确认新密码</label>
+                        <div class="layui-input-inline">
+                            <input type="password" name="re_pwd" lay-verify="repass" lay-verType="tips" autocomplete="off" class="layui-input">
+                        </div>
+                    </div>
+                    <div class="layui-form-item">
+                        <div class="layui-input-block">
+                            <button class="layui-btn layui-btn-normal" lay-submit lay-filter="saveBtn">确认修改</button>
+                        </div>
+                    </div>
+                </div>
+            </form>
+
+        </div>
+        </div>
+    </div>
+</div>
+
+<script>
+    layui.use(['form'], function () {
+        var form = layui.form,
+            $ = layui.$;
+
+        //监听提交
+        form.on('submit(saveBtn)', function (data) {
+            console.log(JSON.stringify(data.field));
+            $.ajax({
+                type:"POST",
+                url:"/personal/update_pwd",
+                contentType: "application/json;charset=UTF-8",
+                data: JSON.stringify(data.field),
+                success: function (result) {
+                    var obj = JSON.parse(result);
+                    layer.alert(obj.msg);
+                },
+                error: function () {
+                    console.log("ajax error");
+                }
+            });
+            return false;
+        });
+
+    });
+</script>