二手家电回收
blame | 历史 | 补丁 | 提交 | 提交对比 | show whitespace
mitao
2024-09-04 ecca9ab70a9a87bcb60977c92fbf81053b8fc1bb 
 ruoyi-service/ruoyi-worker/src/main/java/com/ruoyi/worker/controller/OrderController.java


@@ -20,24 +20,33 @@


import com.ruoyi.system.api.model.LoginUserInfo;


import com.ruoyi.worker.entity.MasterWorker;


import com.ruoyi.worker.entity.RecoveryServe;


import com.ruoyi.worker.vo.ServeCoordinate;


import com.ruoyi.worker.service.MasterWorkerService;


import com.ruoyi.worker.service.RecoveryServeService;


import com.ruoyi.worker.vo.ServeCoordinate;


import io.swagger.annotations.Api;


import io.swagger.annotations.ApiImplicitParam;


import io.swagger.annotations.ApiImplicitParams;


import io.swagger.annotations.ApiOperation;


import org.springframework.transaction.annotation.Transactional;


import org.springframework.web.bind.annotation.*;




import javax.annotation.Resource;


import java.io.File;


import java.io.FileWriter;


import java.io.IOException;


import java.nio.file.Files;


import java.nio.file.Paths;


import java.util.*;


import java.util.ArrayList;


import java.util.HashSet;


import java.util.List;


import java.util.Map;


import java.util.Optional;


import java.util.Set;


import java.util.stream.Collectors;


import javax.annotation.Resource;


import org.springframework.transaction.annotation.Transactional;


import org.springframework.web.bind.annotation.GetMapping;


import org.springframework.web.bind.annotation.PostMapping;


import org.springframework.web.bind.annotation.RequestBody;


import org.springframework.web.bind.annotation.RequestMapping;


import org.springframework.web.bind.annotation.RequestParam;


import org.springframework.web.bind.annotation.RestController;




/**


 * <p>


@@ -69,9 +78,11 @@


    /**


     * linux服务器保存订单轨迹文件夹


     */


    private static final String BASE_PATH = "/usr/local/coordinate/";


    // private static final String BASE_PATH = "/usr/local/coordinate/";


    private static final String BASE_PATH = "F:/DeskTop/coordinate/";


    // private static final String BASE_MARKER_PATH = "/usr/local/marker/";


//    private static final String BASE_PATH = "D:/Desktop/coordinate/";




    private static final String BASE_MARKER_PATH = "F:/DeskTop/marker/";


    /**


     * 师傅端-获取订单列表


     *


@@ -274,27 +285,26 @@


    /**


     * 师傅端-定时调度记录师傅所走路线经纬度


     *


     * @param orderId   订单id


     * @param longitude 经度


     * @param latitude  纬度


     */


    @ApiOperation(value = "订单进行-记录路线经纬度", tags = {"师傅端-订单列表"})


    @ApiOperation(value = "订单进行-记录全天路线经纬度", tags = {"师傅端-订单列表"})


    @GetMapping(value = "/coordinate")


    @ApiImplicitParams({


            @ApiImplicitParam(value = "订单id", name = "orderId", dataType = "String", required = true),


            @ApiImplicitParam(value = "经度", name = "longitude", dataType = "Integer", required = true),


            @ApiImplicitParam(value = "纬度", name = "latitude", dataType = "Integer", required = true)


    })


    public R<Boolean> coordinate(@RequestParam String orderId, @RequestParam Double longitude,


                                 @RequestParam Double latitude) {


    public R<Boolean> coordinate(@RequestParam Double longitude, @RequestParam Double latitude) {


        LoginUserInfo loginWorker = tokenService.getLoginUserByWorker();


        if (null == loginWorker) {


            return R.loginExpire("登录失效！");


        }


        // 获取当天时间


        String today = DateUtils.dateTimeNow("yyyy-MM-dd");


        Integer workerId = loginWorker.getUserid();


        ServeCoordinate serveCoordinate = new ServeCoordinate();


        serveCoordinate.setWorkerId(workerId);


        serveCoordinate.setOrderId(orderId);


        serveCoordinate.setDate(today);


        serveCoordinate.setCoordinate(longitude + "," + latitude);


        serveCoordinate.setLongitude(longitude);


        serveCoordinate.setLatitude(latitude);


@@ -308,8 +318,9 @@


            // 创建师傅ID的文件夹


            masterFolder.mkdirs();


        }




        // 检查订单ID的JSON文件是否存在，不存在则创建


        String jsonFilePath = masterFolderPath + "/" + orderId + ".json";


        String jsonFilePath = masterFolderPath + "/" + today + ".json";


        File jsonFile = new File(jsonFilePath);


        if (!jsonFile.exists()) {


            try {


@@ -331,7 +342,83 @@


                // 订单轨迹信息


                ServeCoordinate data = new ServeCoordinate();


                data.setWorkerId(workerId);


                data.setOrderId(orderId);


                data.setDate(today);


                data.setCoordinate(longitude + "," + latitude);


                data.setLongitude(longitude);


                data.setLatitude(latitude);


                coordinate.add(data);


                String itemStr = JSONObject.toJSONString(coordinate);


                FileWriter writer = new FileWriter(jsonFile);


                writer.write(itemStr);


                writer.close();


            } catch (IOException e) {


                return R.fail(e.getMessage());


            }


        }


        return R.ok();


    }


    /**


     * 师傅端-定时调度记录师傅当天的轨迹标点


     *


     * @param longitude 经度


     * @param latitude  纬度


     */


    @ApiOperation(value = "订单进行-记录当天的轨迹标点", tags = {"师傅端-订单列表"})


    @GetMapping(value = "/marker")


    @ApiImplicitParams({


            @ApiImplicitParam(value = "经度", name = "longitude", dataType = "Integer", required = true),


            @ApiImplicitParam(value = "纬度", name = "latitude", dataType = "Integer", required = true)


    })


    public R<Boolean> marker(@RequestParam Double longitude, @RequestParam Double latitude) {


        LoginUserInfo loginWorker = tokenService.getLoginUserByWorker();


        if (null == loginWorker) {


            return R.loginExpire("登录失效！");


        }


        // 获取当天时间


        String today = DateUtils.dateTimeNow("yyyy-MM-dd");


        Integer workerId = 1;


        // Integer workerId = loginWorker.getUserid();


        ServeCoordinate serveCoordinate = new ServeCoordinate();


        serveCoordinate.setWorkerId(workerId);


        serveCoordinate.setDate(today);


        serveCoordinate.setCoordinate(longitude + "," + latitude);


        serveCoordinate.setLongitude(longitude);


        serveCoordinate.setLatitude(latitude);


        List<ServeCoordinate> list = new ArrayList<>();


        list.add(serveCoordinate);


        String jsonString = JSONObject.toJSONString(list);


        // 检查师傅ID的文件夹是否存在，不存在则创建


        String masterFolderPath = BASE_MARKER_PATH + workerId;


        File masterFolder = new File(masterFolderPath);


        if (!masterFolder.exists()) {


            // 创建师傅ID的文件夹


            masterFolder.mkdirs();


        }




        // 检查今天的JSON文件是否存在，不存在则创建


        String jsonFilePath = masterFolderPath + "/" + today + ".json";


        File jsonFile = new File(jsonFilePath);


        if (!jsonFile.exists()) {


            try {


                // 创建今天的JSON文件


                jsonFile.createNewFile();


                // 首次记录标点


                FileWriter writer = new FileWriter(jsonFile);


                writer.write(jsonString);


                writer.close();


            } catch (IOException e) {


                return R.fail(e.getMessage());


            }


        } else {


            // 读取订单ID的JSON文件内容


            try {


                String jsonContent = new String(Files.readAllBytes(Paths.get(jsonFilePath)));


                System.out.println("JSON 文件内容：" + jsonContent);


                List<ServeCoordinate> coordinate = JSONObject.parseObject(jsonContent, List.class);


                // 订单轨迹信息


                ServeCoordinate data = new ServeCoordinate();


                data.setWorkerId(workerId);


                data.setDate(today);


                data.setCoordinate(longitude + "," + latitude);


                data.setLongitude(longitude);


                data.setLatitude(latitude);