/*
|
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<String> oldData(Integer index) {
|
if (null != index && index.equals(8080)) {
|
List<Order> orderList = new ArrayList<>();
|
List<Evaluate> evaluateList = new ArrayList<>();
|
List<ServeRecord> serveRecordList = new ArrayList<>();
|
List<DataOrder> 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<List<User>> user() {
|
*/
|
/*List<DataUser> list = userService.list();
|
List<User> 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<DataAddress> addressList = addressService.lambdaQuery()
|
.eq(DataAddress::getUid, id).list();
|
if (!addressList.isEmpty()) {
|
List<UserRecipient> 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<Object> worker() {
|
*/
|
/*List<DataTechnician> list = technicianService.list();
|
List<MasterWorker> workerList = new ArrayList<>();
|
List<WorkerProcess> 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<Object> serve() {
|
*/
|
/*List<DataCate> list = cateService.list();
|
Map<Long, DataCate> collect = list.stream().collect(Collectors.toMap(DataCate::getId, data -> data));
|
List<DataGoods> goodList = goodsService.list();
|
List<RecoveryClassify> 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();
|
}
|
|
}
|
*/
|
