From 4228cb0f9ff33e4baa4be0ac904eb927f8d84a19 Mon Sep 17 00:00:00 2001
From: Pu Zhibing <393733352@qq.com>
Date: 星期六, 11 十月 2025 14:28:27 +0800
Subject: [PATCH] 提交代码

---
 driver/guns-admin/src/main/java/com/supersavedriving/driver/modular/system/api/DriverController.java |   72 ++++++++++++++++++++++++++++++++++-
 1 files changed, 69 insertions(+), 3 deletions(-)

diff --git a/driver/guns-admin/src/main/java/com/supersavedriving/driver/modular/system/api/DriverController.java b/driver/guns-admin/src/main/java/com/supersavedriving/driver/modular/system/api/DriverController.java
index 7254f10..6c0994e 100644
--- a/driver/guns-admin/src/main/java/com/supersavedriving/driver/modular/system/api/DriverController.java
+++ b/driver/guns-admin/src/main/java/com/supersavedriving/driver/modular/system/api/DriverController.java
@@ -9,6 +9,7 @@
 import com.baomidou.mybatisplus.mapper.EntityWrapper;
 import com.baomidou.mybatisplus.mapper.Wrapper;
 import com.supersavedriving.driver.modular.system.dao.MonthOrderMapper;
+import com.supersavedriving.driver.modular.system.dao.TCompanyMapper;
 import com.supersavedriving.driver.modular.system.model.*;
 import com.supersavedriving.driver.modular.system.service.*;
 import com.supersavedriving.driver.modular.system.util.ALiSendSms;
@@ -16,9 +17,14 @@
 import com.supersavedriving.driver.modular.system.util.MiniPay.MiniAppPay;
 import com.supersavedriving.driver.modular.system.util.juhe.OCRUtil;
 import com.supersavedriving.driver.modular.system.util.qianyuntong.SMSUtil;
+import com.supersavedriving.driver.modular.system.util.qianyuntong.UserUtil;
+import com.supersavedriving.driver.modular.system.util.qianyuntong.model.QYTUserInfo;
 import com.supersavedriving.driver.modular.system.util.qianyuntong.model.SendSmsRequest;
 import com.supersavedriving.driver.modular.system.util.separateAccounts.StrUtil;
 import com.supersavedriving.driver.modular.system.util.separateAccounts.TransferUtil;
+import com.supersavedriving.driver.modular.system.util.zhenglian.TokenUtil;
+import com.supersavedriving.driver.modular.system.util.zhenglian.model.TokenRequest;
+import com.supersavedriving.driver.modular.system.util.zhenglian.model.TradeTerminalInfo;
 import com.supersavedriving.driver.modular.system.warpper.*;
 import com.supersavedriving.driver.core.util.ToolUtil;
 import com.supersavedriving.driver.modular.system.util.RedisUtil;
@@ -105,6 +111,9 @@
 
     @Value("${qyt.admin_url}")
     private String adminUrl;
+
+    @Autowired
+    private TCompanyMapper companyMapper;
 
 
 
@@ -221,7 +230,7 @@
                     return ResponseWarpper.success(ResultUtil.error("账号已冻结"));
                 }
             }
-            String numberRandom = UUIDUtil.getNumberRandom(4);
+            String numberRandom = UUIDUtil.getNumberRandom(5);
             SendSmsRequest request = new SendSmsRequest();
             request.setDestAddress(phone);
             request.setTemplateId("TPL202410290001");
@@ -1076,6 +1085,13 @@
             if(null == uid){
                 return ResponseWarpper.tokenErr();
             }
+            Driver driver1 = driverService.selectById(uid);
+            TCompany company = companyMapper.selectById(driver1.getBranchOfficeId());
+            List<QYTUserInfo> userInfoByPhone = UserUtil.getUserInfoByPhone(driver1.getPhone(), company.getEnterCode());
+            if (null == userInfoByPhone || userInfoByPhone.size() == 0) {
+                return new ResponseWarpper(500, "账号未注册");
+            }
+
             ResultUtil resultUtil = driverService.updatePassword(uid, oldPass, newPass);
             return ResponseWarpper.success(resultUtil);
         }catch (Exception e){
@@ -1101,6 +1117,12 @@
             Integer uid = driverService.getUserByRequest();
             if(null == uid){
                 return ResponseWarpper.tokenErr();
+            }
+            Driver driver1 = driverService.selectById(uid);
+            TCompany company = companyMapper.selectById(driver1.getBranchOfficeId());
+            List<QYTUserInfo> userInfoByPhone = UserUtil.getUserInfoByPhone(driver1.getPhone(), company.getEnterCode());
+            if (null == userInfoByPhone || userInfoByPhone.size() == 0) {
+                return new ResponseWarpper(500, "账号未注册");
             }
             ResultUtil resultUtil = driverService.recoverPassword(uid, password);
             return ResponseWarpper.success(resultUtil);
@@ -1185,8 +1207,8 @@
             name = UUIDUtil.getRandomCode() + name.substring(name.lastIndexOf("."));
             File file1 = FileUtil.writeFromStream(inputStream, new File(filePath + name));
             HttpRequest post = HttpUtil.createPost(adminUrl + "/upload/image");
-            HttpRequest form = post.form("file", file1);
-            HttpResponse execute = form.execute();
+            post.form("file", file1);
+            HttpResponse execute = post.execute();
             int status = execute.getStatus();
             if(200 != status){
                 throw new RuntimeException("上传图片异常");
@@ -1398,4 +1420,48 @@
             e.printStackTrace();
         }
     }
+
+
+
+
+    @ResponseBody
+    @PostMapping("/api/driver/getZLToken")
+    @ApiOperation(value = "获取证联token(黔云通)", tags = {"司机端-首页"}, notes = "")
+    @ApiImplicitParams({
+            @ApiImplicitParam(name = "Authorization", value = "Bearer +token", required = true, dataType = "String", paramType = "header", defaultValue = "Bearer eyJhbGciOiJIUzUxMiJ9....."),
+            @ApiImplicitParam(value = "当前设备IP地址", name = "ip", required = true, dataType = "String"),
+            @ApiImplicitParam(value = "当前设备mac地址", name = "mac", required = true, dataType = "String"),
+            @ApiImplicitParam(value = "01 证联收银台支付\n" +
+                    "\t 04 HOME 页\n" +
+                    "\t 06 申请免密签约\n" +
+                    "\t 07 商户收银台支付\n" +
+                    "\t 08 开户(绑卡)\n" +
+                    "\t 09 开通支付账户\n" +
+                    "\t 10 打开付款码", name = "type", required = true, dataType = "String"),
+    })
+    public ResponseWarpper<String> getZLToken(String ip, String mac, String type, HttpServletRequest request){
+        try {
+            Integer uid = driverService.getUserByRequest();
+            if(null == uid){
+                return ResponseWarpper.tokenErr();
+            }
+            Driver driver = driverService.selectById(uid);
+            TokenRequest tokenRequest = new TokenRequest();
+            tokenRequest.setAppUserId(driver.getEmpId().toString());
+            tokenRequest.setUserName(driver.getName());
+            tokenRequest.setCertNo(driver.getIdcard());
+            tokenRequest.setPhone(driver.getPhone());
+            TradeTerminalInfo tradeTerminalInfo = new TradeTerminalInfo();
+            tradeTerminalInfo.setIp(ip);
+            tradeTerminalInfo.setTerminal("1");
+            tradeTerminalInfo.setMac(mac);
+            tokenRequest.setTradeTerminalInfo(tradeTerminalInfo);
+            tokenRequest.setType(type);
+            String token = TokenUtil.getToken(tokenRequest);
+            return ResponseWarpper.success(token);
+        }catch (Exception e){
+            e.printStackTrace();
+            return new ResponseWarpper(500, e.getMessage());
+        }
+    }
 }

--
Gitblit v1.7.1