diff --git a/jeecg-boot/jeecg-module-tms/pom.xml b/jeecg-boot/jeecg-module-tms/pom.xml
index c01cf82..67b782f 100644
--- a/jeecg-boot/jeecg-module-tms/pom.xml
+++ b/jeecg-boot/jeecg-module-tms/pom.xml
@@ -27,6 +27,11 @@
             <artifactId>hutool-crypto</artifactId>
             <version>${hutool.version}</version>
         </dependency>
+        <dependency>
+            <groupId>org.json</groupId>
+            <artifactId>json</artifactId>
+            <version>20180813</version>
+        </dependency>
     </dependencies>
 
 </project>
diff --git a/jeecg-boot/jeecg-module-tms/src/main/java/org/jeecg/modules/tms/basicdata/iogisticsprice/mapper/TmsIogisticsPriceMapper.java b/jeecg-boot/jeecg-module-tms/src/main/java/org/jeecg/modules/tms/basicdata/iogisticsprice/mapper/TmsIogisticsPriceMapper.java
index 6681fbb..949bdec 100644
--- a/jeecg-boot/jeecg-module-tms/src/main/java/org/jeecg/modules/tms/basicdata/iogisticsprice/mapper/TmsIogisticsPriceMapper.java
+++ b/jeecg-boot/jeecg-module-tms/src/main/java/org/jeecg/modules/tms/basicdata/iogisticsprice/mapper/TmsIogisticsPriceMapper.java
@@ -21,5 +21,6 @@ public interface TmsIogisticsPriceMapper extends BaseMapper<TmsIogisticsPrice> {
      * @return
      */
     List<TmsIogisticsPrice> getIogisticsPrice(@Param("pickUpHub") String pickUpHub,
-                                              @Param("deliveryAddress") String deliveryAddress);
+                                              @Param("deliveryAddress") String deliveryAddress,
+                                              @Param("shipType") String shipType);
 }
diff --git a/jeecg-boot/jeecg-module-tms/src/main/java/org/jeecg/modules/tms/basicdata/iogisticsprice/mapper/xml/TmsIogisticsPriceMapper.xml b/jeecg-boot/jeecg-module-tms/src/main/java/org/jeecg/modules/tms/basicdata/iogisticsprice/mapper/xml/TmsIogisticsPriceMapper.xml
index f0af57a..a87a9d3 100644
--- a/jeecg-boot/jeecg-module-tms/src/main/java/org/jeecg/modules/tms/basicdata/iogisticsprice/mapper/xml/TmsIogisticsPriceMapper.xml
+++ b/jeecg-boot/jeecg-module-tms/src/main/java/org/jeecg/modules/tms/basicdata/iogisticsprice/mapper/xml/TmsIogisticsPriceMapper.xml
@@ -8,6 +8,7 @@
         and a.car_long = b.car_long
         where a.start_city = #{pickUpHub}
         and a.target_city = #{deliveryAddress}
+        and a.ship_type = #{shipType}
         and a.failure_time >= TRUNC(SYSDATE)
     </select>
 </mapper>
diff --git a/jeecg-boot/jeecg-module-tms/src/main/java/org/jeecg/modules/tms/basicdata/vehiclepallet/entity/VehiclePallet.java b/jeecg-boot/jeecg-module-tms/src/main/java/org/jeecg/modules/tms/basicdata/vehiclepallet/entity/VehiclePallet.java
index d2526e7..2579c02 100644
--- a/jeecg-boot/jeecg-module-tms/src/main/java/org/jeecg/modules/tms/basicdata/vehiclepallet/entity/VehiclePallet.java
+++ b/jeecg-boot/jeecg-module-tms/src/main/java/org/jeecg/modules/tms/basicdata/vehiclepallet/entity/VehiclePallet.java
@@ -4,10 +4,8 @@ import java.io.Serializable;
 import java.io.UnsupportedEncodingException;
 import java.util.Date;
 import java.math.BigDecimal;
-import com.baomidou.mybatisplus.annotation.IdType;
-import com.baomidou.mybatisplus.annotation.TableId;
-import com.baomidou.mybatisplus.annotation.TableName;
-import com.baomidou.mybatisplus.annotation.TableLogic;
+
+import com.baomidou.mybatisplus.annotation.*;
 import lombok.Data;
 import com.fasterxml.jackson.annotation.JsonFormat;
 import org.springframework.format.annotation.DateTimeFormat;
@@ -71,4 +69,6 @@ public class VehiclePallet implements Serializable {
 	/**更新人*/
     @ApiModelProperty(value = "更新人")
     private java.lang.String updateBy;
+    @TableField(exist = false)
+    private String supplierCode;
 }
diff --git a/jeecg-boot/jeecg-module-tms/src/main/java/org/jeecg/modules/tms/basicdata/vehiclepallet/mapper/VehiclePalletMapper.java b/jeecg-boot/jeecg-module-tms/src/main/java/org/jeecg/modules/tms/basicdata/vehiclepallet/mapper/VehiclePalletMapper.java
index 6e54c7f..2d51237 100644
--- a/jeecg-boot/jeecg-module-tms/src/main/java/org/jeecg/modules/tms/basicdata/vehiclepallet/mapper/VehiclePalletMapper.java
+++ b/jeecg-boot/jeecg-module-tms/src/main/java/org/jeecg/modules/tms/basicdata/vehiclepallet/mapper/VehiclePalletMapper.java
@@ -15,4 +15,8 @@ import com.baomidou.mybatisplus.core.mapper.BaseMapper;
 public interface VehiclePalletMapper extends BaseMapper<VehiclePallet> {
 
     List<String> getCarType();
+
+    List<VehiclePallet> getCarInfo(@Param("shipType") String shipType,
+                                   @Param("pickUpHub") String pickUpHub,
+                                   @Param("deliveryAddress") String deliveryAddress);
 }
diff --git a/jeecg-boot/jeecg-module-tms/src/main/java/org/jeecg/modules/tms/basicdata/vehiclepallet/mapper/xml/VehiclePalletMapper.xml b/jeecg-boot/jeecg-module-tms/src/main/java/org/jeecg/modules/tms/basicdata/vehiclepallet/mapper/xml/VehiclePalletMapper.xml
index 0ac6c84..9f5cc7c 100644
--- a/jeecg-boot/jeecg-module-tms/src/main/java/org/jeecg/modules/tms/basicdata/vehiclepallet/mapper/xml/VehiclePalletMapper.xml
+++ b/jeecg-boot/jeecg-module-tms/src/main/java/org/jeecg/modules/tms/basicdata/vehiclepallet/mapper/xml/VehiclePalletMapper.xml
@@ -6,4 +6,13 @@
         select car_type from tms_vehicle_pallet
         group by car_type
     </select>
+
+    <select id="getCarInfo" resultType="org.jeecg.modules.tms.basicdata.vehiclepallet.entity.VehiclePallet">
+        select b.*,a.supplier_code from tms_iogistics_price a inner JOIN tms_vehicle_pallet b
+        on a.CAR_TYPE = b.CAR_TYPE AND a.CAR_LONG = b.CAR_LONG
+        WHERE a.CAR_TYPE = #{shipType}
+        AND a.START_CITY = #{pickUpHub}
+        AND a.TARGET_CITY = #{deliveryAddress}
+        ORDER BY b.MAX_PALLETS DESC
+    </select>
 </mapper>
\ No newline at end of file
diff --git a/jeecg-boot/jeecg-module-tms/src/main/java/org/jeecg/modules/tms/carinout/vehicleinout/controller/VehicleInOutController.java b/jeecg-boot/jeecg-module-tms/src/main/java/org/jeecg/modules/tms/carinout/vehicleinout/controller/VehicleInOutController.java
index 61e2b47..840179c 100644
--- a/jeecg-boot/jeecg-module-tms/src/main/java/org/jeecg/modules/tms/carinout/vehicleinout/controller/VehicleInOutController.java
+++ b/jeecg-boot/jeecg-module-tms/src/main/java/org/jeecg/modules/tms/carinout/vehicleinout/controller/VehicleInOutController.java
@@ -33,6 +33,7 @@ import org.jeecgframework.poi.excel.entity.ImportParams;
 import org.jeecgframework.poi.excel.view.JeecgEntityExcelView;
 import org.jeecg.common.system.base.controller.JeecgController;
 import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.transaction.annotation.Transactional;
 import org.springframework.web.bind.annotation.*;
 import org.springframework.web.multipart.MultipartFile;
 import org.springframework.web.multipart.MultipartHttpServletRequest;
@@ -201,25 +202,25 @@ public class VehicleInOutController extends JeecgController<VehicleInOut, IVehic
 	  * @return
 	  */
 	 @PostMapping(value = "/take")
+	 @Transactional(rollbackFor = Exception.class)
 	 public Result<String> take(@RequestBody VehicleInOut vehicleInOut) {
 		 LambdaQueryWrapper<VehicleInOut> lambdaQueryWrapper = new LambdaQueryWrapper<>();
 		 lambdaQueryWrapper.eq(VehicleInOut::getVehicleDemandCountId, vehicleInOut.getId());
-		 List<VehicleInOut> list = vehicleInOutService.list(lambdaQueryWrapper);
-		 if (list != null && list.size() > 0) {
-			 if ("1".equals(vehicleInOut.getEfType())) {
-				 return Result.error("已经进行过提货了！");
-			 } else {
-				 return Result.error("已经进行过送货了！");
-			 }
+		 lambdaQueryWrapper.ne(VehicleInOut::getCurrentStatus, TmsConstants.currentStatus_1);
+		 VehicleInOut vi = vehicleInOutService.getOne(lambdaQueryWrapper);
+		 if (vi != null) {
+			 return Result.error("已经操作过了！");
 		 }
-		 vehicleInOut.setId(null)
-				 .setCreateTime(null)
-				 .setCreateBy(null)
+		 LambdaQueryWrapper<VehicleInOut> lam = new LambdaQueryWrapper<>();
+		 lam.eq(VehicleInOut::getVehicleDemandCountId, vehicleInOut.getId());
+		 vehicleInOutService.remove(lam);
+		 vehicleInOut.setVehicleDemandCountId(vehicleInOut.getId())
 				 .setCurrentStatus(TmsConstants.currentStatus_1)
-				 .setPo(vehicleInOut.getPo())
-				 .setVehicleDemandCountId(vehicleInOut.getId());
+				 .setId(null)
+				 .setCreateTime(null)
+				 .setCreateBy(null);
 		 vehicleInOutService.save(vehicleInOut);
-		 return Result.OK("提货成功！");
+		 return Result.OK("操作成功！");
 	 }
 
 	 /**
diff --git a/jeecg-boot/jeecg-module-tms/src/main/java/org/jeecg/modules/tms/constant/TmsConstants.java b/jeecg-boot/jeecg-module-tms/src/main/java/org/jeecg/modules/tms/constant/TmsConstants.java
index 85a1d00..5a76503 100644
--- a/jeecg-boot/jeecg-module-tms/src/main/java/org/jeecg/modules/tms/constant/TmsConstants.java
+++ b/jeecg-boot/jeecg-module-tms/src/main/java/org/jeecg/modules/tms/constant/TmsConstants.java
@@ -14,5 +14,5 @@ public class TmsConstants {
 
     public static String shipType_0 = "0";
     public static String shipType_1 = "1";
-    public static String shipType_2 = "2";
+    public static String shipType_2 = "快递";
 }
diff --git a/jeecg-boot/jeecg-module-tms/src/main/java/org/jeecg/modules/tms/outbound/deliverydemand/service/impl/DeliveryDemandServiceImpl.java b/jeecg-boot/jeecg-module-tms/src/main/java/org/jeecg/modules/tms/outbound/deliverydemand/service/impl/DeliveryDemandServiceImpl.java
index 9b87288..c372e5f 100644
--- a/jeecg-boot/jeecg-module-tms/src/main/java/org/jeecg/modules/tms/outbound/deliverydemand/service/impl/DeliveryDemandServiceImpl.java
+++ b/jeecg-boot/jeecg-module-tms/src/main/java/org/jeecg/modules/tms/outbound/deliverydemand/service/impl/DeliveryDemandServiceImpl.java
@@ -78,6 +78,10 @@ public class DeliveryDemandServiceImpl extends ServiceImpl<DeliveryDemandMapper,
                         (merged1.getTotalPallets() == null ? 0 : merged1.getTotalPallets()) +
                         (merged2.getTotalPallets() == null ? 0 : merged2.getTotalPallets())
                     );
+                    merged1.setPreTotalPallets(
+                        (merged1.getPreTotalPallets() == null ? 0 : merged1.getPreTotalPallets()) +
+                        (merged2.getPreTotalPallets() == null ? 0 : merged2.getPreTotalPallets())
+                    );
                     merged1.setTotalShips(
                         /*(merged1.getTotalShips() == null ? 0 : merged1.getTotalShips()) +
                         (merged2.getTotalShips() == null ? 0 : merged2.getTotalShips())*/
@@ -119,37 +123,41 @@ public class DeliveryDemandServiceImpl extends ServiceImpl<DeliveryDemandMapper,
         List<DeliveryDemand> deliveryDemands = deliveryDemandMapper.selectList(lambdaQueryWrapper);
         // 将需要合并的数据进行分组，以 shipType, deliveryAddress, pickUpHub, shipDate 为key
         Map<String, VehicleDemand> mergedMap = deliveryDemands.stream()
-                .collect(Collectors.toMap(
-                        demand -> String.format("%s|%s|%s|%s",
-                                demand.getShipType(),
-                                demand.getDeliveryAddress(),
-                                demand.getPickUpHub(),
-                                demand.getShipDate()),
-                        demand -> {
-                            VehicleDemand merged = new VehicleDemand();
-                            merged.setShipType(demand.getShipType());
-                            merged.setDeliveryAddress(demand.getDeliveryAddress());
-                            merged.setPickUpHub(demand.getPickUpHub());
-                            merged.setShipDate(demand.getShipDate());
-                            merged.setTotalPallets(demand.getPalletsNum());
-                            merged.setPreTotalPallets(demand.getPalletsNum());
-                            merged.setTotalShips(demand.getShipNumber());
-                            merged.setDeliveryDate(demand.getDeliveryDate());
-                            return merged;
-                        }, (merged1, merged2) -> {
-                            merged1.setTotalPallets(
-                                    (merged1.getTotalPallets() == null ? 0 : merged1.getTotalPallets()) +
-                                            (merged2.getTotalPallets() == null ? 0 : merged2.getTotalPallets())
-                            );
-                            merged1.setTotalShips(
-                                    /*(merged1.getTotalShips() == null ? 0 : merged1.getTotalShips()) +
-                                            (merged2.getTotalShips() == null ? 0 : merged2.getTotalShips())*/
-                                    Optional.ofNullable(merged1.getTotalShips()).orElse(BigDecimal.ZERO)
-                                            .add(Optional.ofNullable(merged2.getTotalShips()).orElse(BigDecimal.ZERO))
-                            );
-                            return merged1;
-                        }
-                ));
+            .collect(Collectors.toMap(
+                demand -> String.format("%s|%s|%s|%s",
+                    demand.getShipType(),
+                    demand.getDeliveryAddress(),
+                    demand.getPickUpHub(),
+                    demand.getShipDate()),
+                demand -> {
+                    VehicleDemand merged = new VehicleDemand();
+                    merged.setShipType(demand.getShipType());
+                    merged.setDeliveryAddress(demand.getDeliveryAddress());
+                    merged.setPickUpHub(demand.getPickUpHub());
+                    merged.setShipDate(demand.getShipDate());
+                    merged.setTotalPallets(demand.getPalletsNum());
+                    merged.setPreTotalPallets(demand.getPalletsNum());
+                    merged.setTotalShips(demand.getShipNumber());
+                    merged.setDeliveryDate(demand.getDeliveryDate());
+                    return merged;
+                }, (merged1, merged2) -> {
+                    merged1.setTotalPallets(
+                        (merged1.getTotalPallets() == null ? 0 : merged1.getTotalPallets()) +
+                        (merged2.getTotalPallets() == null ? 0 : merged2.getTotalPallets())
+                    );
+                    merged1.setPreTotalPallets(
+                        (merged1.getPreTotalPallets() == null ? 0 : merged1.getPreTotalPallets()) +
+                        (merged2.getPreTotalPallets() == null ? 0 : merged2.getPreTotalPallets())
+                    );
+                    merged1.setTotalShips(
+                            /*(merged1.getTotalShips() == null ? 0 : merged1.getTotalShips()) +
+                                    (merged2.getTotalShips() == null ? 0 : merged2.getTotalShips())*/
+                            Optional.ofNullable(merged1.getTotalShips()).orElse(BigDecimal.ZERO)
+                                    .add(Optional.ofNullable(merged2.getTotalShips()).orElse(BigDecimal.ZERO))
+                    );
+                    return merged1;
+                }
+            ));
         List<VehicleDemand> vehicleDemands = new ArrayList<>();
         for (Map.Entry<String, VehicleDemand> entry : mergedMap.entrySet()) {
             String key = entry.getKey(); // 拼接的键
diff --git a/jeecg-boot/jeecg-module-tms/src/main/java/org/jeecg/modules/tms/outbound/vehicledemand/service/impl/VehicleDemandServiceImpl.java b/jeecg-boot/jeecg-module-tms/src/main/java/org/jeecg/modules/tms/outbound/vehicledemand/service/impl/VehicleDemandServiceImpl.java
index 16b5e26..f614fe7 100644
--- a/jeecg-boot/jeecg-module-tms/src/main/java/org/jeecg/modules/tms/outbound/vehicledemand/service/impl/VehicleDemandServiceImpl.java
+++ b/jeecg-boot/jeecg-module-tms/src/main/java/org/jeecg/modules/tms/outbound/vehicledemand/service/impl/VehicleDemandServiceImpl.java
@@ -46,9 +46,10 @@ public class VehicleDemandServiceImpl extends ServiceImpl<VehicleDemandMapper, V
     private final IVehicleDemandCountService vehicleDemandCountService;
     private final TmsIogisticsPriceMapper iogisticsPriceMapper;
     private final DeliveryDemandMapper deliveryDemandMapper;
+    private final VehicleDemandMapper vehicleDemandMapper;
 
-    /*//用车计算方法,根据价格选择车（tms_iogistics_price表）
-    @Override
+    //用车计算方法,根据价格选择车（tms_iogistics_price表）
+    /*@Override
     @Transactional(rollbackFor = Exception.class)
     public Result<?> carCount(VehicleDemand vehicleDemand) {
         // 1.判断是否进行过用车计算
@@ -62,7 +63,8 @@ public class VehicleDemandServiceImpl extends ServiceImpl<VehicleDemandMapper, V
         // 2.查询物流价格信息(从起始城市到目标城市各种车型的价格)
         List<TmsIogisticsPrice> iogisticsPriceList = iogisticsPriceMapper.getIogisticsPrice(
                 vehicleDemand.getPickUpHub(),
-                vehicleDemand.getDeliveryAddress());
+                vehicleDemand.getDeliveryAddress(),
+                vehicleDemand.getShipType());
         if (iogisticsPriceList == null || iogisticsPriceList.size() <= 0) {
             return Result.error("没有符合的物流价格基础信息，请维护！");
         }
@@ -72,15 +74,18 @@ public class VehicleDemandServiceImpl extends ServiceImpl<VehicleDemandMapper, V
         // Integer: 该种车型与车长选择的数量
         Solution solution = findCheapestSolution(iogisticsPriceList, vehicleDemand.getTotalPallets());
         // 打印，方便查看，开发时可以打开
-        *//*for (Map.Entry<String, Integer> entry : solution.getVehicleCounts().entrySet()) {
+        for (Map.Entry<String, Integer> entry : solution.getVehicleCounts().entrySet()) {
             System.out.println(entry.getKey() + " 车: " + entry.getValue() + " 辆");
-        }*//*
+        }
         // 4.转化集合
         List<VehicleDemandCount> vehicleDemandCounts = convertToVehicleDemandCountList(solution.getVehicleCounts(), vehicleDemand);
         // 5.新增
         vehicleDemandCountService.saveBatch(vehicleDemandCounts);
         // 6.更新发货需求当前状态
         deliveryDemandMapper.updateByVdNo(vehicleDemand.getVdNo(), TmsConstants.currentStatus_2);
+        // 7.更新用车需求当前状态
+        vehicleDemand.setCurrentStatus(TmsConstants.currentStatus_2);
+        vehicleDemandMapper.updateById(vehicleDemand);
         log.info("用车需求计算，用车需求编号：{}，方案：{}，费用：{}",vehicleDemand.getVdNo(),
                 solution.getVehicleCounts(),solution.getTotalCost());
         return Result.OK("用车计算成功！");
@@ -188,7 +193,8 @@ public class VehicleDemandServiceImpl extends ServiceImpl<VehicleDemandMapper, V
                 .setCarType(vehiclePallet.getCarType())
                 .setSystemCarType(vehiclePallet.getCarType())
                 .setCarLong(vehiclePallet.getCarLong())
-                .setSystemCarLong(vehiclePallet.getCarLong());
+                .setSystemCarLong(vehiclePallet.getCarLong())
+                .setSupplierCode(vehiclePallet.getSupplierCode());
         vehicleDemandCounts.add(vehicleDemandCount);
     }
 
@@ -206,9 +212,15 @@ public class VehicleDemandServiceImpl extends ServiceImpl<VehicleDemandMapper, V
             return Result.error("已经进行过用车计算了！");
         }
         // 2.查询车型可装托数（倒序）
-        LambdaQueryWrapper<VehiclePallet> lambdaQueryWrapper = new LambdaQueryWrapper<>();
+        /*LambdaQueryWrapper<VehiclePallet> lambdaQueryWrapper = new LambdaQueryWrapper<>();
         lambdaQueryWrapper.orderByDesc(VehiclePallet::getMaxPallets);
-        List<VehiclePallet> vehiclePallets = vehiclePalletMapper.selectList(lambdaQueryWrapper);
+        lambdaQueryWrapper.eq(VehiclePallet::getCarType, vehicleDemand.getShipType());
+        List<VehiclePallet> vehiclePallets = vehiclePalletMapper.selectList(lambdaQueryWrapper);*/
+        List<VehiclePallet> vehiclePallets = vehiclePalletMapper.getCarInfo(vehicleDemand.getShipType(),
+                vehicleDemand.getPickUpHub(), vehicleDemand.getDeliveryAddress());
+        if (vehiclePallets == null || vehiclePallets.size() == 0) {
+            return Result.error("没有符合的物流价格基础信息，请维护！");
+        }
         // 3.进行车辆选择
         // 3.1.获取需要装车总托数
         Integer totalPallets = vehicleDemand.getTotalPallets();
@@ -235,7 +247,9 @@ public class VehicleDemandServiceImpl extends ServiceImpl<VehicleDemandMapper, V
         vehicleDemandCountService.saveBatch(vehicleDemandCounts);
         // 更新发货需求当前状态
         deliveryDemandMapper.updateByVdNo(vehicleDemand.getVdNo(), TmsConstants.currentStatus_2);
-        System.out.println(ids);
+        // 更新用车需求当前状态
+        vehicleDemand.setCurrentStatus(TmsConstants.currentStatus_2);
+        vehicleDemandMapper.updateById(vehicleDemand);
         return Result.OK("用车计算成功！");
     }
 }
diff --git a/jeecg-boot/jeecg-module-tms/src/main/java/org/jeecg/modules/tms/utils/DingTalkUtils.java b/jeecg-boot/jeecg-module-tms/src/main/java/org/jeecg/modules/tms/utils/DingTalkUtils.java
new file mode 100644
index 0000000..fcee002
--- /dev/null
+++ b/jeecg-boot/jeecg-module-tms/src/main/java/org/jeecg/modules/tms/utils/DingTalkUtils.java
@@ -0,0 +1,94 @@
+package org.jeecg.modules.tms.utils;
+
+import okhttp3.*;
+import org.json.JSONObject;
+
+import java.io.IOException;
+
+public class DingTalkUtils {  
+  
+    private static final String APP_KEY = "dingdz6no5d2igfucd8h";   //AppKey
+    private static final String APP_SECRET = "YB0ieklneXHEUZ0dyRxu36w9AKSbjqVpS7z6iPE1_3YzTvS3yeQ-jieeP4Al0sIW";
+    private static final MediaType JSON = MediaType.parse("application/json; charset=utf-8");
+
+    public static String getAccessToken() throws IOException {  
+        OkHttpClient client = new OkHttpClient();  
+        String url = "https://oapi.dingtalk.com/gettoken?appkey=" + APP_KEY + "&appsecret=" + APP_SECRET;  
+  
+        Request request = new Request.Builder()  
+                .url(url)  
+                .build();  
+  
+        try (Response response = client.newCall(request).execute()) {  
+            if (!response.isSuccessful()) throw new IOException("Failed to retrieve access token");  
+  
+            String responseBody = response.body().string();  
+            JSONObject jsonObject = new JSONObject(responseBody);
+            return jsonObject.getString("access_token");
+        }  
+    }
+
+    /**
+     * 发送消息
+     * @param accessToken 调用接口的身份凭证
+     * @param agentId 应用的 AgentId
+     * @param userId 用户id
+     * @param chatId 群聊id
+     * @param message 消息
+     * @throws IOException
+     */
+    public static void sendTextMessage(String accessToken, String agentId, String userId, String chatId, String message) throws IOException {
+        OkHttpClient client = new OkHttpClient();
+        String json = "{\"agent_id\":\"" + agentId + "\",\"userid_list\":\"" + userId + "\",\"deptid_list\":[\"" + userId + "\"],\"chatid\":\"" + chatId + "\",\"msg\":{\"msgtype\": \"text\",\"text\": {\"content\": \"" + message + "\"}}}";
+
+        RequestBody body = RequestBody.create(json, JSON);
+        Request request = new Request.Builder()
+                .url("https://oapi.dingtalk.com/topapi/message/corpconversation/asyncsend_v2?access_token=" + accessToken)
+                .post(body)
+                .build();
+        try (Response response = client.newCall(request).execute()) {
+            if (!response.isSuccessful()) throw new IOException("Unexpected code " + response);
+            System.out.println(response.body().string());
+        }
+    }
+
+    /**
+     * 通过手机号获取用户的 userId
+     * @param accessToken 调用接口的身份凭证
+     * @param mobile 手机号
+     * @return
+     * @throws IOException
+     */
+    public static JSONObject getUserByMobile(String accessToken, String mobile) throws IOException {
+        OkHttpClient client = new OkHttpClient();
+        HttpUrl url = HttpUrl.parse("https://oapi.dingtalk.com/user/get_by_mobile")
+                .newBuilder()
+                .addQueryParameter("access_token", accessToken)
+                .addQueryParameter("mobile", mobile)
+                .build();
+
+        Request request = new Request.Builder()
+                .url(url)
+                .build();
+
+        try (Response response = client.newCall(request).execute()) {
+            if (!response.isSuccessful()) throw new IOException("Unexpected code " + response);
+
+            String responseBody = response.body().string();
+            return new JSONObject(responseBody);
+        }
+    }
+
+    public static void main(String[] args) {
+        try {
+            String accessToken = DingTalkUtils.getAccessToken();
+            String agentId = "3206304704"; // 如果API调用不需要，则忽略此参数
+//            String chatId = "095452471826097763,02000826241189265";    // 账号
+            String chatId = "620665223329579";    // 账号
+            String message = "Hello, this is a test message from Java!";   //发送内容
+            sendTextMessage(accessToken, agentId, chatId, chatId,message);
+        } catch (IOException e) {
+            e.printStackTrace();
+        }
+    }
+}