igo出行
blame | 历史 | 补丁 | 提交 | 提交对比 | ignore whitespace
zhibing.pu
2024-08-10 b0923c5e054f33283e0cea737e871e55caa6f7ef 
 DriverIGOTravel/guns-admin/src/main/java/com/stylefeng/guns/modular/api/DriverController.java


@@ -2,6 +2,7 @@




import com.alibaba.fastjson.JSON;


import com.baomidou.mybatisplus.mapper.EntityWrapper;


import com.mchange.util.FailSuppressedMessageLogger;


import com.stylefeng.guns.core.util.ToolUtil;


import com.stylefeng.guns.modular.crossCity.model.OrderCrossCity;


import com.stylefeng.guns.modular.crossCity.server.IOrderCrossCityService;


@@ -22,6 +23,8 @@


import io.swagger.annotations.ApiImplicitParam;


import io.swagger.annotations.ApiImplicitParams;


import io.swagger.annotations.ApiOperation;


import org.slf4j.Logger;


import org.slf4j.LoggerFactory;


import org.springframework.beans.BeanUtils;


import org.springframework.beans.factory.annotation.Autowired;


import org.springframework.beans.factory.annotation.Value;


@@ -30,7 +33,10 @@




import javax.annotation.Resource;


import javax.servlet.http.HttpServletRequest;


import java.io.BufferedReader;


import java.io.IOException;


import java.io.InputStream;


import java.io.InputStreamReader;


import java.text.SimpleDateFormat;


import java.util.*;




@@ -42,6 +48,8 @@


@RestController


@RequestMapping("")


public class DriverController {


    


    private Logger log = LoggerFactory.getLogger(DriverController.class);




    @Autowired


    private IDriverService driverService;


@@ -1821,4 +1829,29 @@


            throw new RuntimeException(e);


        }


    }


    


    


    


    /**


     * 短信回调通知


     * @param request


     */


    @ResponseBody


    @PostMapping("/base/sendCellulantMessageCallback")


    public void sendCellulantMessageCallback(HttpServletRequest request){


        try {


            StringBuilder sb = new StringBuilder();


            InputStream inputStream = request.getInputStream();


            String s;


            BufferedReader in = new BufferedReader(new InputStreamReader(inputStream, "UTF-8"));


            while ((s = in.readLine()) != null) {


                sb.append(s);


            }


            in.close();


            inputStream.close();


            log.info("短信通知回调：" + sb.toString());


        }catch (Exception e){


            e.printStackTrace();


        }


    }


}