修改快递票订单收货地址

liquidnet-bus-service/liquidnet-service-platform/liquidnet-service-platform-impl/src/main/java/com/liquidnet/service/platform/controller/A_fskfsfs/JxlDataKylinOrderController.java

 package com.liquidnet.service.platform.controller.A_fskfsfs;
 
 
+import com.alibaba.excel.EasyExcel;
+import com.alibaba.excel.read.listener.PageReadListener;
 import com.baomidou.mybatisplus.core.toolkit.Wrappers;
 import com.liquidnet.common.cache.redis.util.RedisDataSourceUtil;
 import com.liquidnet.service.base.ResponseDto;
 import com.liquidnet.service.kylin.constant.KylinRedisConst;
+import com.liquidnet.service.kylin.dto.param.AddressVo;
+import com.liquidnet.service.kylin.dto.vo.mongo.KylinOrderTicketVo;
 import com.liquidnet.service.kylin.dto.vo.returns.KylinOrderRefundsVo;
 import com.liquidnet.service.kylin.entity.KylinOrderRefunds;
+import com.liquidnet.service.kylin.entity.KylinOrderTickets;
 import com.liquidnet.service.kylin.mapper.KylinOrderRefundsMapper;
+import com.liquidnet.service.kylin.mapper.KylinOrderTicketsMapper;
 import com.mysql.cj.jdbc.result.ResultSetImpl;
 import io.swagger.annotations.Api;
 import io.swagger.annotations.ApiImplicitParam;
@@ -20,11 +26,10 @@ import org.springframework.beans.factory.annotation.Value;
 import org.springframework.data.mongodb.core.MongoTemplate;
 import org.springframework.data.mongodb.core.query.Criteria;
 import org.springframework.data.mongodb.core.query.Query;
-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 org.springframework.web.bind.annotation.*;
+import org.springframework.web.multipart.MultipartFile;
 
+import java.io.File;
 import java.math.BigDecimal;
 import java.sql.Connection;
 import java.sql.DriverManager;
@@ -51,6 +56,8 @@ public class JxlDataKylinOrderController {
     @Autowired
     private KylinOrderRefundsMapper kylinOrderRefundsMapper;
     @Autowired
+    private KylinOrderTicketsMapper kylinOrderTicketsMapper;
+    @Autowired
     private MongoTemplate mongoTemplate;
     @Autowired
     private RedisDataSourceUtil redisDataSourceUtil;
@@ -60,7 +67,7 @@ public class JxlDataKylinOrderController {
     @ApiImplicitParams({
             @ApiImplicitParam(type = "query", dataType = "String", name = "performancesId", value = "演出id", required = true),
     })
-    public ResponseDto P001(
+    public ResponseDto KO001(
             @RequestParam("performancesId") String performancesId
     ) {
         try {
@@ -104,4 +111,60 @@ public class JxlDataKylinOrderController {
         return ResponseDto.success();
     }
 
+    @PostMapping("KO002")
+    @ApiOperation("修改快递票订单收货地址")
+    @ApiImplicitParams({
+            @ApiImplicitParam(type = "form", dataType = "File", name = "file", value = "文件", required = true)
+    })
+    public ResponseDto KO002(
+            @RequestParam MultipartFile file
+    ) {
+        try {
+            EasyExcel.read("/Users/jiangxiulong/Desktop" + File.separator + file.getOriginalFilename(), AddressVo.class, new PageReadListener<AddressVo>(dataList -> {
+                for (AddressVo demoData : dataList) {
+                    String userName = demoData.getProvince();
+                    String address = demoData.getCity();
+                    String phone = demoData.getCounty();
+                    String orderCode = demoData.getName();
+                    log.info("orderCode:{}，phone:{}，address:{}，userName:{}，", orderCode, phone, address, userName);
+
+                    // 获取订单 id
+                    KylinOrderTickets kylinOrderTickets = kylinOrderTicketsMapper.selectOne(
+                            Wrappers.lambdaQuery(KylinOrderTickets.class)
+                                    .eq(KylinOrderTickets::getOrderCode, orderCode)
+                    );
+                    String orderTicketsId = kylinOrderTickets.getOrderTicketsId();
+                    if (null == userName || userName.isEmpty()) {
+                        userName = kylinOrderTickets.getExpressContacts();
+                    }
+
+                    // mysql
+                    KylinOrderTickets aNew = KylinOrderTickets.getNew();
+                    aNew.setExpressContacts(userName);
+                    aNew.setExpressAddress(address);
+                    aNew.setExpressPhone(phone);
+                    kylinOrderTicketsMapper.update(aNew,
+                            Wrappers.lambdaUpdate(KylinOrderTickets.class)
+                                    .eq(KylinOrderTickets::getOrderTicketsId, orderTicketsId)
+                    );
+
+                    // mongodb
+                    mongoTemplate.getCollection(KylinOrderTicketVo.class.getSimpleName()).updateOne(
+                            Query.query(Criteria.where("orderTicketsId").is(orderTicketsId)).getQueryObject(),
+                            new Document("$set", new Document("expressContacts", userName)
+                                    .append("expressAddress", address)
+                                    .append("expressPhone", phone)
+                            )
+                    );
+
+                    //redis
+                    redisDataSourceUtil.getRedisKylinUtil().del(KylinRedisConst.ORDER + orderTicketsId);
+                }
+            })).sheet().doRead();
+        } catch (Exception e) {
+            e.printStackTrace();
+        }
+        return ResponseDto.success();
+    }
+
 }