公会-土耳其-公会水晶结算-myApi

accompany-admin/accompany-admin-service/src/main/java/com/accompany/admin/service/api/MyApiService.java

@@ -15,23 +15,21 @@ import com.accompany.business.service.*;
 import com.accompany.business.service.activity.WeekStarService;
 import com.accompany.business.service.apple.IOSRefundV2Service;
 import com.accompany.business.service.guild.*;
+import com.accompany.business.service.guildpolicy2.GuildCrystalSettlementService;
 import com.accompany.business.service.level.LevelService;
 import com.accompany.business.service.lucky.BravoRecordService;
 import com.accompany.business.service.lucky.Lucky24RecordService;
 import com.accompany.business.service.relation.impl.RelationUserServiceImpl;
-import com.accompany.business.service.room.RoomManageService;
-import com.accompany.business.service.room.RoomReciveRankingService;
-import com.accompany.business.service.room.RoomSendRankingService;
-import com.accompany.business.service.room.RoomService;
+import com.accompany.business.service.room.*;
 import com.accompany.business.service.user.UsersService;
 import com.accompany.business.vo.RoomVo;
-import com.accompany.common.netease.ErBanNetEaseService;
+import com.accompany.common.config.SystemConfig;
+import com.accompany.common.constant.Constant;
 import com.accompany.common.netease.neteaseacc.result.RoomMemberRet;
+import com.accompany.common.netease.neteaseacc.result.RoomRet;
 import com.accompany.common.redis.RedisKey;
 import com.accompany.common.status.BusiStatus;
-import com.accompany.common.utils.CommonUtil;
-import com.accompany.common.utils.DateTimeUtil;
-import com.accompany.common.utils.StringUtils;
+import com.accompany.common.utils.*;
 import com.accompany.core.base.SpringContextHolder;
 import com.accompany.core.enumeration.PartitionEnum;
 import com.accompany.core.exception.AdminServiceException;
@@ -58,7 +56,6 @@ import com.baomidou.mybatisplus.core.toolkit.Wrappers;
 import com.google.common.collect.Lists;
 import lombok.SneakyThrows;
 import lombok.extern.slf4j.Slf4j;
-import org.redisson.api.RedissonClient;
 import org.springframework.beans.BeanUtils;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.stereotype.Service;
@@ -805,4 +802,49 @@ public class MyApiService {
         }
     }
 
+    @SneakyThrows
+    public void createPublicRoom(Integer partitionId) {
+        Long uid = Long.parseLong(SystemConfig.secretaryUid);
+        Users u = usersService.getNotNullUsersByUid(uid);
+
+        Room room = new Room();
+        room.setUid(uid);
+        room.setTitle("public chat");
+        room.setPartitionId(partitionId);
+
+        Date now = new Date();
+        room.setValid(true);
+        room.setIsPermitRoom(Constant.PermitType.NO_PERMIT_ROOM); // 非牌照房
+        room.setMeetingName(UUIDUtil.get());
+        room.setOperatorStatus(Constant.RoomOptStatus.in);
+        room.setOpenTime(now);
+        room.setOnlineNum(0);
+        room.setCreateTime(now);
+        room.setUpdateTime(now);
+        room.setIsExceptionClose(false);
+        room.setAvatar(u.getAvatar());
+        room.setHasAnimationEffect(true);
+        room.setAudioQuality((byte) Constant.Yes1No0.YES);
+        room.setIsCloseScreen(false);
+        //默认开启魔力值
+        room.setShowGiftValue(true);
+        Byte roomType = room.getType();
+        if (roomType != null) {
+            RoomServiceFactory.getServiceByType(roomType).wrapRoom(room);
+        }
+        // 通知云信服务器创建聊天室
+        log.info("创建房间 : {}", GsonUtil.getDefGson().toJson(room));
+        RoomRet roomRet = roomService.createNetEaseRoomInfo(room);
+        if (!roomRet.isSuccess()) {
+            throw new Exception("createRoom error, code=" + roomRet.getCode() + "&uid=" + room.getUid() + "json=" + JSON.toJSONString(roomRet));
+        }
+    }
+
+    @Autowired
+    private GuildCrystalSettlementService guildCrystalSettlementService;
+
+    public void guildCrystalSettlement(String cycleDate, Integer waitSecond) {
+        Date cycleDateTime = StringUtils.isNotBlank(cycleDate) ? DateTimeUtil.convertStrToDate(cycleDate, DateTimeUtil.DEFAULT_DATE_PATTERN): null;
+        guildCrystalSettlementService.settlement(PartitionEnum.TURKEY.getId(), cycleDateTime, waitSecond);
+    }
 }

accompany-admin/accompany-admin-web/src/main/java/com/accompany/admin/controller/api/MyApiController.java

@@ -334,6 +334,15 @@ public class MyApiController {
         return BusiResult.success();
     }
 
+    @RequestMapping("/createPublicRoom")
+    @ResponseBody
+    public BusiResult<Void> createPublicRoom(Long roomId, Integer partitionId) {
+        if (null == roomId || !roomId.equals(603L) || null == partitionId) {
+            throw new AdminServiceException(BusiStatus.PARAMERROR);
+        }
+        myApiService.createPublicRoom(partitionId);
+        return BusiResult.success();
+    }
 
     @Autowired
     private GoogleTokenVerifier googleTokenVerifier;
@@ -358,4 +367,13 @@ public class MyApiController {
         miniGameWeekJackpotRankService.settlement(partitionId, DateUtil.parseDateTime(monday), true);
         return BusiResult.success();
     }
+
+    @GetMapping("/guildCrystalSettlement")
+    public BusiResult<Void> guildCrystalSettlement(Long roomId, String cycleDate, Integer waitSecond) {
+        if (null == roomId || !roomId.equals(603L)) {
+            throw new AdminServiceException(BusiStatus.PARAMERROR);
+        }
+        myApiService.guildCrystalSettlement(cycleDate, waitSecond);
+        return BusiResult.success();
+    }
 }