新增添加乘客接口

src/main/java/com/sqx/modules/passenger/controller/PassengerController.java

@@ -0,0 +1,89 @@
+package com.sqx.modules.passenger.controller;
+
+import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
+import com.sqx.common.utils.Result;
+import com.sqx.modules.app.annotation.Login;
+import com.sqx.modules.common.service.CommonInfoService;
+import com.sqx.modules.passenger.entity.Passenger;
+import com.sqx.modules.passenger.service.PassengerService;
+import com.sqx.modules.userRealnameInfo.service.UserRealnameInfoService;
+import com.sqx.modules.utils.AESCBCWithRandomIV;
+import io.swagger.annotations.Api;
+import io.swagger.annotations.ApiOperation;
+import org.springframework.web.bind.annotation.*;
+
+import javax.annotation.Resource;
+import java.util.List;
+
+@RestController
+@Api(value = "乘客-用户端", tags = {"乘客-用户端"})
+@RequestMapping("/app/passenger")
+public class PassengerController {
+
+    @Resource
+    private PassengerService passengerService;
+    @Resource
+    private CommonInfoService commonInfoService;
+    @Resource
+    private UserRealnameInfoService userRealnameInfoService;
+
+    @Login
+    @GetMapping("/selectList")
+    @ApiOperation("查询乘客")
+    public Result selectList(@RequestAttribute("userId")Long userId){
+        String key = commonInfoService.findOne(819).getValue();
+        List<Passenger> list = passengerService.list(new QueryWrapper<Passenger>().eq("user_id", userId));
+        if (list.size() > 0 ){
+            for (Passenger l:list){
+                //解密身份证号
+                String decrypt = null;
+                try {
+                    decrypt = AESCBCWithRandomIV.decrypt(l.getIdCard(), key);
+                } catch (Exception e) {
+                    e.printStackTrace();
+                }
+                l.setIdCard(userRealnameInfoService.maskIdKeepFront(decrypt));
+            }
+        }
+        return Result.success().put("data",list);
+    }
+
+    @Login
+    @PostMapping("/insert")
+    @ApiOperation("新增乘客")
+    public Result insert(@RequestAttribute("userId")Long userId,Passenger passenger){
+        String key = commonInfoService.findOne(819).getValue();
+        String encrypt = null;
+        try {
+            encrypt = AESCBCWithRandomIV.encrypt(passenger.getIdCard(), key);
+        } catch (Exception e) {
+            e.printStackTrace();
+        }
+        passenger.setUserId(userId);
+        passenger.setIdCard(encrypt);
+        passengerService.insert(passenger);
+        return Result.success();
+    }
+
+    @PostMapping("/update")
+    @ApiOperation("修改乘客")
+    public Result update(Passenger passenger){
+        String key = commonInfoService.findOne(819).getValue();
+        if (null != passenger.getIdCard() && passenger.getIdCard() != ""){
+            String encrypt = null;
+            try {
+                encrypt = AESCBCWithRandomIV.encrypt(passenger.getIdCard(), key);
+            } catch (Exception e) {
+                e.printStackTrace();
+            }
+            passenger.setIdCard(encrypt);
+        }
+        return Result.success().put("data",passengerService.updateById(passenger));
+    }
+
+    @PostMapping("/delete")
+    @ApiOperation("删除乘客")
+    public Result delete(Long id){
+        return Result.success().put("data",passengerService.removeById(id));
+    }
+}

src/main/java/com/sqx/modules/passenger/dao/PassengerDao.java

@@ -0,0 +1,9 @@
+package com.sqx.modules.passenger.dao;
+
+import com.baomidou.mybatisplus.core.mapper.BaseMapper;
+import com.sqx.modules.passenger.entity.Passenger;
+import org.apache.ibatis.annotations.Mapper;
+
+@Mapper
+public interface PassengerDao extends BaseMapper<Passenger> {
+}

src/main/java/com/sqx/modules/passenger/entity/Passenger.java

@@ -0,0 +1,34 @@
+package com.sqx.modules.passenger.entity;
+
+import com.baomidou.mybatisplus.annotation.IdType;
+import com.baomidou.mybatisplus.annotation.TableId;
+import lombok.Data;
+
+import java.io.Serializable;
+import java.util.Date;
+
+@Data
+public class Passenger implements Serializable {
+
+    private static final long serialVersionUID = 1L;
+
+    @TableId(type = IdType.AUTO)
+    /**
+     * 订单id
+     */
+    private Long id;
+
+    private String name;
+
+    private String idCard;
+
+    /**
+     * 1-成人 2-儿童
+     */
+    private Integer type;
+
+    private Date createTime;
+
+    private Long userId;
+
+}

src/main/java/com/sqx/modules/passenger/service/PassengerService.java

@@ -0,0 +1,8 @@
+package com.sqx.modules.passenger.service;
+
+import com.baomidou.mybatisplus.extension.service.IService;
+import com.sqx.modules.passenger.entity.Passenger;
+
+public interface PassengerService extends IService<Passenger> {
+    void insert(Passenger passenger);
+}

src/main/java/com/sqx/modules/passenger/service/impl/PassengerServiceImpl.java

@@ -0,0 +1,17 @@
+package com.sqx.modules.passenger.service.impl;
+
+import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
+import com.sqx.modules.passenger.dao.PassengerDao;
+import com.sqx.modules.passenger.entity.Passenger;
+import com.sqx.modules.passenger.service.PassengerService;
+import lombok.extern.slf4j.Slf4j;
+import org.springframework.stereotype.Service;
+
+@Slf4j
+@Service
+public class PassengerServiceImpl extends ServiceImpl<PassengerDao, Passenger> implements PassengerService {
+    @Override
+    public void insert(Passenger passenger) {
+        baseMapper.insert(passenger);
+    }
+}