commit

liquidnet-bus-client/liquidnet-client-admin/liquidnet-client-admin-zhengzai/src/main/java/com/liquidnet/client/admin/zhengzai/kylin/service/impl/KylinDamaiServiceImpl.java

@@ -11,7 +11,6 @@ import com.liquidnet.service.kylin.entity.*;
 import com.liquidnet.service.kylin.mapper.*;
 import com.liquidnet.service.kylin.service.other.DamaiService;
 import com.liquidnet.service.merchant.dto.vo.MerchantFieldsVo;
-import com.liquidnet.service.merchant.dto.vo.MerchantFieldsVo;
 import com.taobao.api.TaobaoClient;
 import com.taobao.api.internal.util.StringUtils;
 import com.taobao.api.request.*;
@@ -64,10 +63,13 @@ public class KylinDamaiServiceImpl extends ServiceImpl<KylinRoadShowsMapper, Kyl
 
     private ArrayList<Long> empty = new ArrayList();
 
+    int orderCountAll = 0;
+
     @Override
     public Boolean sycPerformance(String performanceId) {
         try {
             empty.clear();
+            orderCountAll = 0;
             TaobaoClient client = taobaoTicketUtils.initTaobaoClient();
             AlibabaDamaiMevOpenPushprojectRequest req = new AlibabaDamaiMevOpenPushprojectRequest();
             ThirdProjectPushOpenParam obj1 = new ThirdProjectPushOpenParam();
@@ -229,7 +231,7 @@ public class KylinDamaiServiceImpl extends ServiceImpl<KylinRoadShowsMapper, Kyl
                 log.info("[同步票种] 票种名称 = " + ticketsData.getTitle() + "-登登登VIP 大麦票种id =" + ticketIdKey + " 票种价格 = " + ticketsData.getPrice());
                 AlibabaDamaiMevOpenPushitemResponse rsp2 = client2.execute(req2);
                 if (rsp2.getResult().getSuccess()) {
-                    return sycOrder(timemId, ticketsData.getTicketsId(), ticketIdKey,ticketIdKey2);
+                    return sycOrder(timemId, ticketsData.getTicketsId(), ticketIdKey, ticketIdKey2);
                 } else {
                     return false;
                 }
@@ -243,7 +245,7 @@ public class KylinDamaiServiceImpl extends ServiceImpl<KylinRoadShowsMapper, Kyl
     }
 
     @Override
-    public Boolean sycOrder(long timemId, String ticketsId, long ticketsmId,long ticketIdMemberKey) {
+    public Boolean sycOrder(long timemId, String ticketsId, long ticketsmId, long ticketIdMemberKey) {
         try {
             TaobaoClient client = taobaoTicketUtils.initTaobaoClient();
             AlibabaDamaiMevOpenBatchpushticketRequest req = new AlibabaDamaiMevOpenBatchpushticketRequest();
@@ -283,6 +285,14 @@ public class KylinDamaiServiceImpl extends ServiceImpl<KylinRoadShowsMapper, Kyl
                         empty.add(orderTicketEntitiesKey);
                         orderCount+=1;
 
+                        if (empty.contains(orderTicketEntitiesKey)) {
+                            log.info("[ ORDER COPY ] orderId = " + orderTicketEntitiesKey);
+                            orderTicketEntitiesKey = Long.parseLong(orderTicketEntitiesKey + "1");
+                        }
+                        empty.add(orderTicketEntitiesKey);
+                        orderCount += 1;
+                        orderCountAll += 1;
+
                         list2.add(obj3);
                         obj3.setUserName(item.getEnterName());//用户名 入场人姓名
                         obj3.setCertificateNo(item.getEnterIdCode());//证件号 入场人身份证
@@ -290,14 +300,14 @@ public class KylinDamaiServiceImpl extends ServiceImpl<KylinRoadShowsMapper, Kyl
                         obj3.setCertificateType(item.getEnterType().longValue());//证件内容 入场人证件type
                         obj3.setPayTime(DateUtils.parseDate(item.getTimePay()));//支付时间
                         obj3.setPerformId(timemId);//场次id
-                        if(item.getIsMember()==1){
+                        if (item.getIsMember() == 1) {
                             obj3.setExt("登登登VIP");
                             obj3.setTicketItemId(ticketIdMemberKey);
-                        }else{
+                        } else {
                             obj3.setExt("登登登VIP");
                             obj3.setTicketItemId(ticketsmId);
                         }
-                        obj3.setQrCode("http://m.zhengzai.tv?c="+IDGenerator.ticketQrCode(item.getOrderTicketEntitiesId()));
+                        obj3.setQrCode("http://m.zhengzai.tv?c=" + IDGenerator.ticketQrCode(item.getOrderTicketEntitiesId()));
                         obj3.setVoucherId(orderTicketEntitiesKey);//票单号 入场人id
                         obj3.setOrderId(orderIdKey);//订单id orderId
                         obj3.setMediumType(item.getGetTicketType().equals("express") ? 1L : 2L);//票类型 快递 电子
@@ -319,6 +329,7 @@ public class KylinDamaiServiceImpl extends ServiceImpl<KylinRoadShowsMapper, Kyl
                 }
             }
             log.info("[ ORDER COUNT ] orderCount = " + orderCount);
+            log.info("[ ORDER COUNT ALL ] orderCount = " + orderCountAll);
             return true;
         } catch (Exception e) {
             e.printStackTrace();
@@ -327,7 +338,10 @@ public class KylinDamaiServiceImpl extends ServiceImpl<KylinRoadShowsMapper, Kyl
     }
 
     public static void main(String[] args) {
-        Long a=IDGenerator.getDamaiCode("397341627879178278349754");
+        Long a=IDGenerator.getDamaiCode("385930697698099233332997");
+        Long b=IDGenerator.getDamaiCode("385931515691868195803932");
+
         System.out.println(a);
+        System.out.println(b);
     }
 }

liquidnet-bus-service/liquidnet-service-platform/liquidnet-service-platform-impl/src/main/java/com/liquidnet/service/platform/service/impl/kylin/DataImpl.java

@@ -487,8 +487,8 @@ public class DataImpl {
             //数据迁移
             while (row.next()) {
                 String mobile = row.getString("mobile");
-                String merchantId =row.getString("merchant_id");
-                if(mobile==null){
+                String merchantId = row.getString("merchant_id");
+                if (mobile == null) {
                     continue;
                 }
                 //获取java用户id
@@ -505,8 +505,8 @@ public class DataImpl {
                 kylinPerformanceRelationsMapper.update(kylinPerformanceRelations,
                         Wrappers.lambdaUpdate(KylinPerformanceRelations.class).eq(KylinPerformanceRelations::getMerchantId, merchantId));
 
-                HashMap<String,Object> map = CollectionUtil.mapStringObject();
-                map.put("merchantId",merchantId);
+                HashMap<String, Object> map = CollectionUtil.mapStringObject();
+                map.put("merchantId", merchantId);
                 //修改vo
                 Query voQuery = Query.query(Criteria.where("merchantId").is(merchantId));
                 BasicDBObject objectVo = ObjectUtil.cloneBasicDBObject().append("$set", mongoConverter.convertToMongoType(map));
@@ -530,60 +530,45 @@ public class DataImpl {
     }
 
     //演出主办
-//    public void sponsor() {
-//        try {
-//            String sql = "select sponsor_id,sponsor_type from kylin_performances kp\n" +
-//                    "inner join kylin_performance_status kps on kps.performance_id = kp.performances_id\n" +
-//                    "where status >=3 and sponsor_id != ''\n" +
-//                    "group by sponsor_id,sponsor_type;";
-//            Connection connection = DriverManager.getConnection(SQL_URL, SQL_USER, SQL_PWD);
-//            //查询数据
-//            PreparedStatement preparedStatement = connection.prepareStatement(sql);
-//            ResultSetImpl row = (ResultSetImpl) preparedStatement.executeQuery();
-//            //数据迁移
-//            while (row.next()) {
-//                String sponsorId = row.getString("sponsor_id");
-//                String sponsorType =row.getString("sponsor_type");
-//                if(mobile==null){
-//                    continue;
-//                }
-//                //获取java用户id
-//                MultiValueMap<String, String> params = CollectionUtil.linkedMultiValueMapStringString();
-//                params.add("mobile", mobile);
-//                MultiValueMap<String, String> headers = CollectionUtil.linkedMultiValueMapStringString();
-//                headers.add("Accept", "application/json;charset=UTF-8");
-//                String returnData = HttpUtil.post(adamUrl.concat("/adam/rsc/reg/mobile"), params, headers);
-//                AdamUserInfoVo adamUserInfoVo = JsonUtils.fromJson(returnData, new TypeReference<ResponseDto<AdamUserInfoVo>>() {
-//                }).getData();
-//                String uid = adamUserInfoVo.getUid();
-//                KylinPerformanceRelations kylinPerformanceRelations = KylinPerformanceRelations.getNew();
-//                kylinPerformanceRelations.setMerchantId(uid);
-//                kylinPerformanceRelationsMapper.update(kylinPerformanceRelations,
-//                        Wrappers.lambdaUpdate(KylinPerformanceRelations.class).eq(KylinPerformanceRelations::getMerchantId, merchantId));
-//
-//                HashMap<String,Object> map = CollectionUtil.mapStringObject();
-//                map.put("merchantId",merchantId);
-//                //修改vo
-//                Query voQuery = Query.query(Criteria.where("merchantId").is(merchantId));
-//                BasicDBObject objectVo = ObjectUtil.cloneBasicDBObject().append("$set", mongoConverter.convertToMongoType(map));
-//                mongoTemplate.getCollection(KylinPerformanceVo.class.getSimpleName()).updateOne(
-//                        voQuery.getQueryObject(),
-//                        objectVo
-//                );
-//                //修改partnerVo
-//                Query partnerVoQuery = Query.query(Criteria.where("merchantId").is(merchantId));
-//                BasicDBObject objectPartnerVo = ObjectUtil.cloneBasicDBObject().append("$set", mongoConverter.convertToMongoType(map));
-//                mongoTemplate.getCollection(PerformancePartnerVo.class.getSimpleName()).updateOne(
-//                        partnerVoQuery.getQueryObject(),
-//                        objectPartnerVo
-//                );
-//            }
-//            row.close();
-//            preparedStatement.close();
-//        } catch (Exception e) {
-//            e.printStackTrace();
-//        }
-//    }
+    public void sponsor() {
+        try {
+            String sql = "select sponsor_id,sponsor_type from kylin_performances kp\n" +
+                    "inner join kylin_performance_status kps on kps.performance_id = kp.performances_id\n" +
+                    "where status >=3 and sponsor_id != ''\n" +
+                    "group by sponsor_id,sponsor_type;";
+            Connection connection = DriverManager.getConnection(SQL_URL, SQL_USER, SQL_PWD);
+            //查询数据
+            PreparedStatement preparedStatement = connection.prepareStatement(sql);
+            ResultSetImpl row = (ResultSetImpl) preparedStatement.executeQuery();
+            //数据迁移
+            while (row.next()) {
+                String sponsorId = row.getString("sponsor_id");
+                String sponsorType = row.getString("sponsor_type");
+                String sponsorSql = "";
+                if (sponsorType.equals("brand")) {
+                    sponsorSql="select b.name, m.id, m.mobile from mall.brands b inner join mall.merchants m on m.id = b.admin_id where b.id = "+sponsorId;
+                } else if (sponsorType.equals("field")) {
+                    sponsorSql=" select mu.name, m.id, m.mobile from mall.musicians mu inner join mall.merchants m on m.id = mu.admin_id where m.id = "+sponsorId;
+                } else if (sponsorType.equals("musician")) {
+                    sponsorSql="select f.name, m.id, m.mobile from mall.fields f inner join mall.merchants m on m.id = f.admin_id where f.id = "+sponsorId;
+                }
+                if (sponsorSql.equals("")) {
+                    continue;
+                }
+                PreparedStatement preparedStatementSponsor = connection.prepareStatement(sql);
+                ResultSetImpl rowSponsor = (ResultSetImpl) preparedStatementSponsor.executeQuery();
+                while (rowSponsor.next()) {
+
+                }
+                rowSponsor.close();
+                preparedStatementSponsor.close();
+            }
+            row.close();
+            preparedStatement.close();
+        } catch (Exception e) {
+            e.printStackTrace();
+        }
+    }
 
     //相关权限迁移