/* package com.ruoyi.admin.controller; import com.ruoyi.admin.entity.*; import com.ruoyi.admin.service.*; import com.ruoyi.common.core.constant.Constants; import com.ruoyi.common.core.domain.R; 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.RestController; import javax.annotation.Resource; import java.math.BigDecimal; import java.text.SimpleDateFormat; import java.util.ArrayList; import java.util.Date; import java.util.List; */ /** * @author HJL * @version 1.0 * @since 2024-07-02 14:57 *//* @RestController @RequestMapping("/data") @Api(tags = {"数据迁移"}) public class OldDataController { @Resource private DataOrderService dataOrderService; @Resource private OrderService orderService; @Resource private EvaluateService evaluateService; @Resource private ServeRecordService serveRecordService; @Resource private DataUserService userService; @Resource private UserService newUserService; @Resource private DataTechnicianService technicianService; @Resource private MasterWorkerService masterWorkerService; @Resource private WorkerProcessService workerProcessService; @Resource private DataAddressService addressService; @Resource private UserRecipientService userRecipientService; @Resource private DataCateService cateService; @Resource private DataGoodsService goodsService; @Resource private RecoveryClassifyService classifyService; @GetMapping("/order") @ApiOperation(value = "订单数据迁移", tags = {"数据迁移"}) public R oldData(Integer index) { if (null != index && index.equals(8080)) { List orderList = new ArrayList<>(); List evaluateList = new ArrayList<>(); List serveRecordList = new ArrayList<>(); List list = dataOrderService.list(); 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 province = data.getProvince(); String city = data.getCity(); String area = data.getArea(); String address = data.getAddress(); String xxAddress = data.getXxAddress(); 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 reason = data.getReason(); Date completeTime = data.getCompleteTime(); String yhqrtp = data.getYhqrtp(); String jjmptp = data.getJjmptp(); String njtp = data.getNjtp(); String wjhqttp = data.getWjhqttp(); Integer drawnum = data.getDrawnum(); Integer status = data.getStatus(); Boolean jdStatus = data.getJdStatus(); String ztServerUid = data.getZtServerUid(); Boolean pjStatus = data.getPjStatus(); Boolean timeStatus = data.getTimeStatus(); Date createAt = data.getCreateAt(); Integer serverSendnum = data.getServerSendnum(); Integer userSendnum = data.getUserSendnum(); Integer print = data.getPrint(); // 新订单信息 Order order = new Order(); order.setId(id.intValue()); order.setCity(city); order.setOrderNumber(orderNo); order.setServeId(serverUid.intValue()); // 回收服务信息 DataGoods dataGoods = goodsService.getById(productId); order.setServeName(dataGoods.getName()); order.setServePrice(new BigDecimal(dataGoods.getPgPrice())); // order.setUserId(); order.setReservationName(username); order.setReservationPhone(phone); order.setReservationAddress(address + xxAddress); // 时间格式化 SimpleDateFormat simpleDateFormat = new SimpleDateFormat("yyyy-MM-dd HH:ss"); order.setTime(simpleDateFormat.format(smTime)); DataTechnician technician = technicianService.getById(serverUid); order.setServerId(serverUid.intValue()); order.setServerName(technician.getUsername()); order.setServerPhone(technician.getPhone()); order.setReservationRemark(remark); order.setOrderMoney(price.add(btPrice)); 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()); order.setCompleteTime(completeTime); 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(BigDecimal.valueOf(pjLevel)); evaluate.setCreateTime(new Date()); evaluate.setUpdateTime(new Date()); evaluate.setIsDelete(Constants.ZERO); evaluateList.add(evaluate); } // 服务记录信息(回收拍照) if (Constants.FOUR.equals(status)) { ServeRecord serveRecord = new ServeRecord(); serveRecord.setOrderId(order.getId()); serveRecord.setPhoto(yhqrtp + "," + jjmptp + "," + njtp + "," + wjhqttp); serveRecord.setCreateTime(new Date()); serveRecord.setUpdateTime(new Date()); serveRecord.setIsDelete(Constants.ZERO); serveRecordList.add(serveRecord); } } if (!orderList.isEmpty()) { orderService.saveOrUpdateBatch(orderList); } if (!evaluateList.isEmpty()) { evaluateService.saveOrUpdateBatch(evaluateList); } if (!serveRecordList.isEmpty()) { serveRecordService.saveOrUpdateBatch(serveRecordList); } } return R.ok(); } @GetMapping("/user") @ApiOperation(value = "用户数据迁移", tags = {"数据迁移"}) public R> user() { */ /*List list = userService.list(); List userList = new ArrayList<>(); for (DataUser dataUser : list) { Long id = dataUser.getId(); String openid = dataUser.getOpenid(); String avatar = dataUser.getAvatar(); String nickname = dataUser.getNickname(); Date createAt = dataUser.getCreateAt(); // 新数据封装 User user = new User(); user.setId(id.intValue()); user.setUserNo(String.format(Constants.USER_NO_PRE, RandomUtil.randomNumbers(Constants.EIGHT))); user.setNickname(nickname); user.setProfilePicture(avatar); // todo 用户手机号无法拿到,后续验证码登录也无法登录 // user.setPhone(""); user.setState(Constants.ONE); user.setOpenId(openid); user.setCreateTime(createAt); user.setUpdateTime(createAt); user.setIsDelete(Constants.ZERO); userList.add(user); // 旧收货地址信息 List addressList = addressService.lambdaQuery() .eq(DataAddress::getUid, id).list(); if (!addressList.isEmpty()) { List recipientList = new ArrayList<>(); for (DataAddress dataAddress : addressList) { Long uid = dataAddress.getUid(); Boolean type = dataAddress.getType(); String username = dataAddress.getUsername(); String phone = dataAddress.getPhone(); String address = dataAddress.getAddress(); BigDecimal latitude = dataAddress.getLatitude(); BigDecimal longitude = dataAddress.getLongitude(); String xxdz = dataAddress.getXxdz(); Date addressCreateAt = dataAddress.getCreateAt(); // 新地址 UserRecipient userRecipient = new UserRecipient(); userRecipient.setUserId(uid.intValue()); userRecipient.setRecipient(username); userRecipient.setRecipientPhone(phone); userRecipient.setAddress(address); userRecipient.setAddressDetail(xxdz); if (type) { userRecipient.setIsDefault(Constants.ONE); } else { userRecipient.setIsDefault(Constants.ZERO); } userRecipient.setLongitude(longitude); userRecipient.setLatitude(latitude); userRecipient.setCreateTime(addressCreateAt); userRecipient.setUpdateTime(addressCreateAt); userRecipient.setIsDelete(Constants.ZERO); recipientList.add(userRecipient); } userRecipientService.saveBatch(recipientList); } } newUserService.saveBatch(userList); return R.ok(userList);*//* return R.ok(); } @GetMapping("/worker") @ApiOperation(value = "师傅数据迁移", tags = {"数据迁移"}) public R worker() { */ /*List list = technicianService.list(); List workerList = new ArrayList<>(); List processList = new ArrayList<>(); for (DataTechnician data : list) { Long id = data.getId(); String city = data.getCity(); String username = data.getUsername(); String phone = data.getPhone(); String carType = data.getCarType(); String carNumber = data.getCarNumber(); String idcard = data.getIdcard(); String idcardZ = data.getIdcardZ(); String idcardF = data.getIdcardF(); String xsz = data.getXsz(); // 新师傅数据封装 MasterWorker masterWorker = new MasterWorker(); masterWorker.setId(id.intValue()); masterWorker.setCity(city); masterWorker.setUserNumber(username); masterWorker.setRealName(username); masterWorker.setIdNumber(idcard); masterWorker.setVehicleType(carType); masterWorker.setVehicleNumber(carNumber); masterWorker.setPhone(phone); // 默认密码 BCryptPasswordEncoder passwordEncoder = new BCryptPasswordEncoder(); String md5Password = passwordEncoder.encode(Constants.DEFAULT_PASSWORD); masterWorker.setPassword(md5Password); masterWorker.setIdentityPhoto(idcardZ + "," + idcardF); masterWorker.setDrivingLicense(xsz); masterWorker.setIsEnable(Constants.ONE); masterWorker.setCreateTime(new Date()); masterWorker.setUpdateTime(new Date()); masterWorker.setIsDelete(Constants.ZERO); workerList.add(masterWorker); // 师傅入驻申请信息 WorkerProcess workerProcess = new WorkerProcess(); workerProcess.setCity(city); workerProcess.setRealName(username); workerProcess.setIdNumber(idcard); workerProcess.setVehicleType(carType); workerProcess.setVehicleNumber(carNumber); workerProcess.setPhone(phone); workerProcess.setIdentityPhoto(idcardZ + "," + idcardF); workerProcess.setDrivingLicense(xsz); workerProcess.setState(Constants.ONE); workerProcess.setCreateTime(new Date()); workerProcess.setUpdateTime(new Date()); workerProcess.setIsDelete(Constants.ZERO); processList.add(workerProcess); } boolean one = masterWorkerService.saveBatch(workerList); boolean two = workerProcessService.saveBatch(processList); return R.ok(one && two);*//* return R.ok(); } @GetMapping("/serve") @ApiOperation(value = "回收服务数据迁移", tags = {"数据迁移"}) public R serve() { */ /*List list = cateService.list(); Map collect = list.stream().collect(Collectors.toMap(DataCate::getId, data -> data)); List goodList = goodsService.list(); List serveList = new ArrayList<>(); for (DataGoods dataGoods : goodList) { DataCate dataCate = collect.get(Long.parseLong(dataGoods.getCateids())); String cover = dataCate.getCover(); String remark = dataCate.getRemark(); String remarkJj = dataCate.getRemarkJj(); Long sort = dataCate.getSort(); Integer indexStatus = dataCate.getIndexStatus(); // 新分类 RecoveryClassify classify = new RecoveryClassify(); classify.setId(dataGoods.getId().intValue()); String item; if (1L == dataCate.getPid()) { item = "预约上门回收"; }else { item = "家电以旧换新"; } classify.setSupClassify(item); classify.setSubClassify(dataGoods.getName()); classify.setHomePageName(dataCate.getIndexName()); classify.setClassificationPicture(cover); classify.setTypeDescribe(remark); classify.setSort(sort.intValue()); classify.setBriefIntroduction(remarkJj); classify.setIsRecommend(indexStatus); classify.setCreateTime(new Date()); classify.setUpdateTime(new Date()); classify.setIsDelete(Constants.ZERO); serveList.add(classify); } return R.ok(classifyService.saveBatch(serveList));*//* return R.ok(); } } */