package com.ruoyi.order.controller;

import com.alibaba.fastjson2.JSONObject;
import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
import com.ruoyi.common.core.constant.Constants;
import com.ruoyi.common.core.domain.R;
import com.ruoyi.order.entity.*;
import com.ruoyi.order.service.*;
import com.ruoyi.order.vo.OldDataPhotoVO;
import io.swagger.annotations.Api;
import io.swagger.annotations.ApiOperation;
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RequestParam;
import org.springframework.web.bind.annotation.RestController;

import javax.annotation.Resource;
import java.math.BigDecimal;
import java.text.ParseException;
import java.text.SimpleDateFormat;
import java.util.ArrayList;
import java.util.Date;
import java.util.List;

/**
 * @author hjl
 * @since 2024-07-18 16:34
 */
@RestController
@RequestMapping("/oldData")
@Api(tags = {"数据迁移"})
public class OldDataController {

    @Resource
    private DataOrderService dataOrderService;
    @Resource
    private OrderService orderService;
    @Resource
    private EvaluateService evaluateService;
    @Resource
    private ServeRecordService serveRecordService;
    @Resource
    private DataTechnicianService technicianService;
    @Resource
    private DataGoodsService goodsService;

    @GetMapping("/order")
    @ApiOperation(value = "订单数据迁移", tags = {"数据迁移"})
    public R<String> oldData(@RequestParam("index") Integer index,
                             @RequestParam("pageNum") Integer pageNum,
                             @RequestParam("pageSize") Integer pageSize) {
        if (null != index && index.equals(8080)) {
            try {
                List<Order> orderList = new ArrayList<>();
                List<Evaluate> evaluateList = new ArrayList<>();
                List<ServeRecord> serveRecordList = new ArrayList<>();
                List<DataOrder> list = dataOrderService.page(Page.of(pageNum, pageSize)).getRecords();
                for (DataOrder data : list) {
                    Long id = data.getId();
                    Boolean orderType = data.getOrderType();
                    String orderNo = data.getOrderNo();
                    Long productId = data.getProductId();
                    Long uid = data.getUid();
                    Long serverUid = data.getServerUid();
                    BigDecimal price = data.getPrice();
                    BigDecimal btPrice = data.getBtPrice();
                    String username = data.getUsername();
                    String phone = data.getPhone();
                    String city = data.getCity();
                    String address = data.getAddress();
                    BigDecimal latitude = data.getLatitude();
                    BigDecimal longitude = data.getLongitude();
                    Date smTime = data.getSmTime();
                    String remark = data.getRemark();
                    String cancelRemark = data.getCancelRemark();
                    Integer pjLevel = data.getPjLevel();
                    String pjRemark = data.getPjRemark();
                    String completeTime = data.getCompleteTime();
                    String yhqrtp = data.getYhqrtp();
                    String jjmptp = data.getJjmptp();
                    String njtp = data.getNjtp();
                    String wjhqttp = data.getWjhqttp();
                    Integer status = data.getStatus();
                    Boolean pjStatus = data.getPjStatus();
                    // 新订单信息
                    Order order = new Order();
                    order.setId(String.valueOf(id));
                    order.setCity(city);
                    order.setOrderNumber(orderNo);
                    order.setServeId(serverUid.intValue());
                    // 回收服务信息
                    DataGoods dataGoods = goodsService.getById(productId);
                    if (null != dataGoods) {
                        order.setServeName(dataGoods.getName());
                        order.setServePrice(new BigDecimal(dataGoods.getPgPrice()));
                    }
                    order.setReservationName(username);
                    order.setReservationPhone(phone);
                    order.setReservationAddress(address);
                    // 时间格式化
                    SimpleDateFormat simpleDateFormat = new SimpleDateFormat("yyyy-MM-dd HH:ss");
                    order.setTime(simpleDateFormat.format(smTime));
                    DataTechnician technician = technicianService.getById(serverUid);
                    order.setServerId(serverUid.intValue());
                    if (null != technician) {
                        order.setServerName(technician.getUsername());
                        order.setServerPhone(technician.getPhone());
                    }
                    order.setReservationRemark(remark);
                    if (null != btPrice) {
                        order.setOrderMoney(price.add(btPrice));
                    } else {
                        order.setOrderMoney(price);
                    }
                    if (Constants.ONE.equals(status)) {
                        order.setState(Constants.ZERO);
                    } else if (Constants.TWO.equals(status)) {
                        order.setState(Constants.ONE);
                    } else if (Constants.THREE.equals(status)) {
                        order.setState(Constants.TWO);
                    } else if (Constants.FOUR.equals(status)) {
                        order.setState(Constants.THREE);
                    } else if (Constants.FIVE.equals(status)) {
                        order.setState(Constants.FOUR);
                        order.setCancelReason(cancelRemark);
                    }
                    order.setAcceptTime(new Date());
                    if (orderType) {
                        order.setType(Constants.ZERO);
                    } else {
                        order.setType(Constants.ONE);
                    }
                    order.setLongitude(longitude.doubleValue());
                    order.setLatitude(latitude.doubleValue());
                    order.setArriveTime(new Date());
                    // 时间转换
                    SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
                    try {
                        Date date = sdf.parse(completeTime);
                        order.setCompleteTime(date);
                    } catch (ParseException e) {
                        order.setCompleteTime(null);
                    }
                    order.setIsWithdrawal(Constants.ONE);
                    order.setSubsidy(btPrice);
                    order.setCreateTime(new Date());
                    order.setUpdateTime(new Date());
                    order.setIsDelete(Constants.ZERO);
                    orderList.add(order);
                    // 评价信息
                    if (pjStatus) {
                        Evaluate evaluate = new Evaluate();
                        evaluate.setUserId(uid.intValue());
                        evaluate.setUserPhone(phone);
                        evaluate.setOrderId(order.getId());
                        evaluate.setContent(pjRemark);
                        evaluate.setWorkerId(serverUid.intValue());
                        evaluate.setStarRating(Double.valueOf(pjLevel));
                        evaluate.setCreateTime(new Date());
                        evaluate.setUpdateTime(new Date());
                        evaluate.setIsDelete(Constants.ZERO);
                        evaluateList.add(evaluate);
                    }
                    // 服务记录信息(回收拍照)
                    if (Constants.FOUR.equals(status)) {
                        // json数据转换
                        String photo;
                        try {
                            OldDataPhotoVO photo1 = JSONObject.parseObject(yhqrtp, OldDataPhotoVO.class);
                            OldDataPhotoVO photo2 = JSONObject.parseObject(jjmptp, OldDataPhotoVO.class);
                            OldDataPhotoVO photo3 = JSONObject.parseObject(njtp, OldDataPhotoVO.class);
                            OldDataPhotoVO photo4 = JSONObject.parseObject(wjhqttp, OldDataPhotoVO.class);
                            photo = photo1.getUrl() + "," + photo2.getUrl() + "," + photo3.getUrl() + "," + photo4.getUrl();
                        } catch (Exception e) {
                            photo = null;
                        }
                        ServeRecord serveRecord = new ServeRecord();
                        serveRecord.setOrderId(order.getId());
                        serveRecord.setPhoto(photo);
                        serveRecord.setCreateTime(new Date());
                        serveRecord.setUpdateTime(new Date());
                        serveRecord.setIsDelete(Constants.ZERO);
                        serveRecordList.add(serveRecord);
                    }
                }
                if (!orderList.isEmpty()) {
                    orderService.saveBatch(orderList);
                }
                if (!evaluateList.isEmpty()) {
                    evaluateService.saveBatch(evaluateList);
                }
                if (!serveRecordList.isEmpty()) {
                    serveRecordService.saveBatch(serveRecordList);
                }
            } catch (Exception e) {
                return R.fail(e.getMessage());
            }
        }
        return R.ok();
    }


}