From ccefd07a68bcf22a4240a62440c39e646de5aa8b Mon Sep 17 00:00:00 2001
From: puzhibing <393733352@qq.com>
Date: 星期二, 16 五月 2023 10:39:55 +0800
Subject: [PATCH] 更新reids配置

---
 management/guns-admin/src/main/java/com/stylefeng/guns/modular/system/controller/general/TBranchOfficeController.java |   45 +++++++++++++++++++++++++++++++++++++--------
 1 files changed, 37 insertions(+), 8 deletions(-)

diff --git a/management/guns-admin/src/main/java/com/stylefeng/guns/modular/system/controller/general/TBranchOfficeController.java b/management/guns-admin/src/main/java/com/stylefeng/guns/modular/system/controller/general/TBranchOfficeController.java
index a4b60b0..ad11034 100644
--- a/management/guns-admin/src/main/java/com/stylefeng/guns/modular/system/controller/general/TBranchOfficeController.java
+++ b/management/guns-admin/src/main/java/com/stylefeng/guns/modular/system/controller/general/TBranchOfficeController.java
@@ -7,9 +7,10 @@
 import com.stylefeng.guns.core.shiro.ShiroKit;
 import com.stylefeng.guns.modular.system.controller.resp.TBranchOfficeResp;
 import com.stylefeng.guns.modular.system.controller.resp.TDriverResp;
+import com.stylefeng.guns.modular.system.enums.StatusEnum;
 import com.stylefeng.guns.modular.system.model.*;
-import com.stylefeng.guns.modular.system.service.ITRegionService;
-import com.stylefeng.guns.modular.system.service.ITSystemConfigService;
+import com.stylefeng.guns.modular.system.service.*;
+import com.stylefeng.guns.modular.system.util.RedisUtil;
 import io.swagger.annotations.ApiOperation;
 import org.springframework.beans.BeanUtils;
 import org.springframework.stereotype.Controller;
@@ -22,8 +23,8 @@
 import org.springframework.beans.factory.annotation.Autowired;
 import com.stylefeng.guns.core.log.LogObjectHolder;
 import org.springframework.web.bind.annotation.RequestParam;
-import com.stylefeng.guns.modular.system.service.ITBranchOfficeService;
 
+import java.util.Date;
 import java.util.List;
 import java.util.Objects;
 import java.util.stream.Collectors;
@@ -47,12 +48,19 @@
 
     @Autowired
     private ITRegionService tRegionService;
+    @Autowired
+    private ITDriverService tDriverService;
+    @Autowired
+    private ITDriverWorkService tDriverWorkService;
+    @Autowired
+    private RedisUtil redisUtil;
 
     /**
      * 跳转到首页
      */
     @RequestMapping("")
-    public String index() {
+    public String index(Model model) {
+        model.addAttribute("userType", Objects.requireNonNull(ShiroKit.getUser()).getRoleType());
         return PREFIX + "tBranchOffice.html";
     }
 
@@ -231,7 +239,7 @@
     @ResponseBody
     public Object start(Integer id) {
         TBranchOffice tBranchOffice = tBranchOfficeService.selectById(id);
-        tBranchOffice.setStatus(1);
+        tBranchOffice.setStatus(StatusEnum.NORMAL.getCode());
         tBranchOfficeService.updateById(tBranchOffice);
         return SUCCESS_TIP;
     }
@@ -243,8 +251,25 @@
     @ResponseBody
     public Object updateStatus(Integer id) {
         TBranchOffice tBranchOffice = tBranchOfficeService.selectById(id);
-        tBranchOffice.setStatus(2);
+        tBranchOffice.setStatus(StatusEnum.FREEZE.getCode());
         tBranchOfficeService.updateById(tBranchOffice);
+        List<TDriver> list = tDriverService.selectList(new EntityWrapper<TDriver>()
+                .eq("branchOfficeId", tBranchOffice.getId()));
+        for (TDriver tDriver : list) {
+            String value = redisUtil.getValue("DRIVER_" + tDriver.getPhone());
+            redisUtil.remove(value);
+            redisUtil.remove("DRIVER_" + tDriver.getPhone());
+            TDriverWork tDriverWork = tDriverWorkService.selectOne(new EntityWrapper<TDriverWork>()
+                    .eq("driverId", tDriver.getId())
+                    .eq("status", 1)
+                    .orderBy("workTime", false)
+                    .last("LIMIT 1"));
+            if(Objects.nonNull(tDriverWork)){
+                tDriverWork.setStatus(2);
+                tDriverWork.setOffWorkTime(new Date());
+                tDriverWorkService.updateById(tDriverWork);
+            }
+        }
         return SUCCESS_TIP;
     }
 
@@ -272,7 +297,8 @@
         if(Objects.nonNull(o)){
             return o;
         }
-        tBranchOffice.setStatus(1);
+        tBranchOffice.setPrincipal(tBranchOffice.getPrincipal().replace(" ",""));
+        tBranchOffice.setStatus(StatusEnum.NORMAL.getCode());
 
         tBranchOfficeService.insert(tBranchOffice);
         return SUCCESS_TIP;
@@ -284,7 +310,9 @@
     @RequestMapping(value = "/delete")
     @ResponseBody
     public Object delete(@RequestParam Integer tBranchOfficeId) {
-        tBranchOfficeService.deleteById(tBranchOfficeId);
+        TBranchOffice tBranchOffice = tBranchOfficeService.selectById(tBranchOfficeId);
+        tBranchOffice.setStatus(StatusEnum.DELETE.getCode());
+        tBranchOfficeService.updateById(tBranchOffice);
         return SUCCESS_TIP;
     }
 
@@ -305,6 +333,7 @@
         if(Objects.nonNull(o)){
             return o;
         }
+        tBranchOffice.setPrincipal(tBranchOffice.getPrincipal().replace(" ",""));
         tBranchOfficeService.updateById(tBranchOffice);
         return SUCCESS_TIP;
     }

--
Gitblit v1.7.1