fix: Handle zombie processes and update docs

- Add 'init: true' to docker-compose and '--init' to README to reap zombie processes.
- Refactor 'sgcc_client.py' to ensure driver cleanup via try-finally block.
- Update README with detailed 'SLIDER_OFFSET' guidance and schedule info.

Author: goxofy

README.md

@@ -33,6 +33,7 @@
 
 ```bash
 docker run -d \
+  --init \
   --name 95598-mqtt \
   --restart unless-stopped \
   -v $(pwd)/data:/data \
@@ -96,8 +97,10 @@ python3 startup.py
 | `MQTT_PORT` | MQTT 端口 | `1883` |
 | `MQTT_USER` | MQTT 用户名 | (空) |
 | `MQTT_PASSWORD` | MQTT 密码 | (空) |
-| `JOB_START_TIME` | 每天定时运行时间 | `07:00` |
-| `SLIDER_OFFSET` | 验证码滑块偏移微调（-2 ~ 20） | `5` |
+| `JOB_START_TIME` | 每天定时运行时间(12小时循环) | `07:00` |
+| `SLIDER_OFFSET` | 验证码滑块偏移微调（-2 ~ 20） | `8` |
 | `IGNORE_USER_ID` | 忽略的户号(逗号分隔) | (空) |
 
-*SLIDER_OFFSET 这个参数非常重要！如果持续登录报错，请观看 errors 文件夹内的失败视频，酌情调整此参数*
+*SLIDER_OFFSET 这个参数非常重要！*
+*如果持续登录报错，请观看 errors 文件夹内的失败视频，酌情调整此参数*
+*此参数在不同设备不同架构不同环境内的值不完全相同，但只要设置合理成功登录后，基本不会发生变化*

docker-compose.yml

@@ -1,5 +1,6 @@
 services:
   95598-mqtt:
+    init: true
     image: ghcr.io/goxofy/95598-mqtt:main
     container_name: 95598-mqtt
     restart: unless-stopped

example.env

@@ -22,7 +22,7 @@ DB_NAME=95598.db
 DRIVER_IMPLICITY_WAIT_TIME=60
 LOGIN_EXPECTED_TIME=10
 RETRY_WAIT_TIME_OFFSET_UNIT=10
-SLIDER_OFFSET=2
+SLIDER_OFFSET=8
 CHROME_BINARY_PATH=
 CHROMEDRIVER_PATH=
 DATA_RETENTION_DAYS=7

sgcc_client.py

@@ -387,74 +387,82 @@ def perform_login(self, driver):
 
     def run(self):
         driver = self.init_driver()
-        ScreenshotOnFailure.set_driver(driver)
-        
-        # Force window size for headless mode
-        driver.set_window_size(1920, 1080)
-        size = driver.get_window_size()
-        pixel_ratio = driver.execute_script("return window.devicePixelRatio;")
-        logging.info(f"Driver initialized. Window size: {size}, DevicePixelRatio: {pixel_ratio}")
-        
-        # Start Screen Recording
-        from recorder import ScreenRecorder
-        timestamp = time.strftime("%Y%m%d_%H%M%S")
-        video_path = f"./errors/record_{timestamp}.avi"
-        recorder = ScreenRecorder(driver, video_path, fps=3.0)
-        recorder.start()
-        
-        publisher = MQTTPublisher()
-        
         try:
-            if self.perform_login(driver):
-                logging.info("Login successful!")
-                # Stop recording immediately after success
+            ScreenshotOnFailure.set_driver(driver)
+            
+            # Force window size for headless mode
+            driver.set_window_size(1920, 1080)
+            size = driver.get_window_size()
+            pixel_ratio = driver.execute_script("return window.devicePixelRatio;")
+            logging.info(f"Driver initialized. Window size: {size}, DevicePixelRatio: {pixel_ratio}")
+            
+            # Start Screen Recording
+            from recorder import ScreenRecorder
+            timestamp = time.strftime("%Y%m%d_%H%M%S")
+            video_path = f"./errors/record_{timestamp}.avi"
+            recorder = ScreenRecorder(driver, video_path, fps=3.0)
+            recorder.start()
+            
+            publisher = MQTTPublisher()
+            
+            try:
+                if self.perform_login(driver):
+                    logging.info("Login successful!")
+                    # Stop recording immediately after success
+                    recorder.stop()
+                    
+                    # Delete video if successful (User request)
+                    try:
+                        if os.path.exists(video_path):
+                            os.remove(video_path)
+                            logging.info(f"Login successful, deleted recording: {video_path}")
+                    except Exception as e:
+                        logging.warning(f"Failed to delete recording: {e}")
+                else:
+                    logging.error("Login failed!")
+                    recorder.stop()
+                    return
+            except Exception as e:
+                logging.error(f"Login exception: {e}")
                 recorder.stop()
-                
-                # Delete video if successful (User request)
+                return
+    
+            time.sleep(self.retry_delay)
+            user_ids = self.get_user_ids(driver)
+            logging.info(f"Found users: {user_ids}")
+    
+            for index, user_id in enumerate(user_ids):
+                if user_id in self.ignored_users:
+                    logging.info(f"Skipping ignored user: {user_id}")
+                    continue
+    
                 try:
-                    if os.path.exists(video_path):
-                        os.remove(video_path)
-                        logging.info(f"Login successful, deleted recording: {video_path}")
+                    driver.get(URL_BALANCE)
+                    time.sleep(self.retry_delay)
+                    self.select_user(driver, index)
+                    time.sleep(self.retry_delay)
+                    
+                    data = self.collect_data(driver, user_id, index)
+                    publisher.publish_user_data(user_id, *data)
+                    
+                    time.sleep(self.retry_delay)
                 except Exception as e:
-                    logging.warning(f"Failed to delete recording: {e}")
-            else:
-                logging.error("Login failed!")
-                recorder.stop()
-                driver.quit()
-                return
-        except Exception as e:
-            logging.error(f"Login exception: {e}")
+                    logging.error(f"Failed to process user {user_id}: {e}")
+                    continue
+    
+            logging.info("All tasks completed successfully.")
+            self.cleanup_debug_images()
             recorder.stop()
-            driver.quit()
-            return
-
-        time.sleep(self.retry_delay)
-        user_ids = self.get_user_ids(driver)
-        logging.info(f"Found users: {user_ids}")
-
-        for index, user_id in enumerate(user_ids):
-            if user_id in self.ignored_users:
-                logging.info(f"Skipping ignored user: {user_id}")
-                continue
-
-            try:
-                driver.get(URL_BALANCE)
-                time.sleep(self.retry_delay)
-                self.select_user(driver, index)
-                time.sleep(self.retry_delay)
-                
-                data = self.collect_data(driver, user_id, index)
-                publisher.publish_user_data(user_id, *data)
-                
-                time.sleep(self.retry_delay)
-            except Exception as e:
-                logging.error(f"Failed to process user {user_id}: {e}")
-                continue
-
-        logging.info("All tasks completed successfully.")
-        self.cleanup_debug_images()
-        recorder.stop()
-        driver.quit()
+            
+        except Exception as e:
+            logging.error(f"Unexpected error in run: {e}")
+        finally:
+            if driver:
+                logging.info("Quitting driver...")
+                try:
+                    driver.quit()
+                except Exception as e:
+                    logging.error(f"Error quitting driver: {e}")
 
     def cleanup_debug_images(self):
         try: