";
return $html;
}
/**
* Notes:获取推送配置
* User: wsc
* Time: 2020/11/11 9:40
* @param bool $db
* @return array
*/
public function getPushConf($db=false){
$tb = otable::fasebasePushConf();
$key = okeys::fasebasePushConf();
$key2 = okeys::fasebasePushConfByKey();//根据类型缓存
$cache =oo::commonOprRedis('games')->hGetAll($key);
if(empty($cache)||$db){
oo::commonOprDb('slavedb')->query("set names utf8mb4");
$sql = "SELECT * FROM {$tb}";
$arr = oo::commonOprDb('slavedb')->getAll($sql,1);
if(!empty($arr)){
foreach ($arr as $v){
$cache2[$v['type']] = $v['conf'];
$v['conf'] = json_decode($v['conf'],true);
$cache[$v['id']] = json_encode($v,256);
}
oo::commonOprRedis('games')->hMset($key,$cache);
oo::commonOprRedis('games')->hMset($key2,$cache2);
}
}
$cache = $cache?funs::getArrFromJsonArr($cache):[];
if(!empty($cache)){
// array_multisort(array_column($cache,'id'),SORT_ASC,$cache);
// array_column($cache,null,'id');
}
return $cache;
}
/**
* Notes:推送nsq队列
* User: xwy
* Time: 2022/04/08
* @param string $topic 消息队列topic
* @param array $body 消息队列 body 数据
* @return bool 推送状态
*/
public function sendNsqMsg($topic, $body){
//目前只在测试条件下开启
if(!class_exists('Nsq')){
oo::logs()->debug3(['nsq 扩展不存在'],"publishNsq.log");
return false;
}
$nsqdAddrs = $this->config->item('nsqAddress');
$body = json_encode($body);
$data =array_values( unpack("C*", $body));
$nsq = new Nsq();
$isTrue = false;
foreach ($nsqdAddrs as $nsqdAddr){
$isTrue = $nsq->connectNsqd([$nsqdAddr]);
if($isTrue)break;
}
// echo "Is connect:".$isTrue;
if($isTrue){
$res = $nsq->publish($topic,json_encode($data));
if(!$res)
oo::logs()->debug3(['nsqdAddrs' => $nsqdAddrs, "msg"=>"publish failed","topic"=>$topic,"info"=>$body],"publishNsq.log");
else
oo::logs()->debug3(['nsqdAddrs' => $nsqdAddrs, "msg"=>"publish successed","topic"=>$topic,"info"=>$body],"publishNsq.log");
$nsq->closeNsqdConnection();
}else{
$res = false;
oo::logs()->debug3(['nsqdAddrs' => $nsqdAddrs, "msg"=>"lose connect...","topic"=>$topic,"info"=>$body],"publishNsq.log");
}
return $res;
}
# 获取导入的sheet 数组
public function getExcelSheetsArray(){
$file = $this->uploader->getFileInfo();
$extensionType = $this->getExtensionType($file['originalName']);
$xlsReader = IOFactory::createReader($extensionType);
$xlsReader->setReadDataOnly(true);
$xlsReader->setLoadSheetsOnly(true);
$Sheets = $xlsReader->load($file['url']);
$sheetsCnt = $Sheets->getSheetCount();
$dataArray = [];
for($i=0 ; $i< $sheetsCnt; $i++){
$tmpData = $Sheets->getSheet($i)->toArray() ?? [];
foreach ($tmpData as $k => $item){
foreach ($item as $k1 => $value){
$item[$k1] = trim($value);
}
$line = array_filter($item);
if(empty($line))unset($tmpData[$k]);
}
$dataArray[$i] = $tmpData;
}
return $dataArray;
}
# 获取文件扩展对应的excel类型
public function getExtensionType($fileName){
$pathinfo = pathinfo($fileName);
$extensionType = NULL;
switch (strtolower($pathinfo['extension'])) {
case 'xlsx': // Excel (OfficeOpenXML) Spreadsheet
case 'xlsm': // Excel (OfficeOpenXML) Macro Spreadsheet (macros will be discarded)
case 'xltx': // Excel (OfficeOpenXML) Template
case 'xltm': // Excel (OfficeOpenXML) Macro Template (macros will be discarded)
$extensionType = 'Excel2007';
break;
case 'xls': // Excel (BIFF) Spreadsheet
case 'xlt': // Excel (BIFF) Template
$extensionType = 'Excel5';
break;
case 'ods': // Open/Libre Offic Calc
case 'ots': // Open/Libre Offic Calc Template
$extensionType = 'OOCalc';
break;
case 'slk':
$extensionType = 'SYLK';
break;
case 'xml': // Excel 2003 SpreadSheetML
$extensionType = 'Excel2003XML';
break;
case 'gnumeric':
$extensionType = 'Gnumeric';
break;
case 'htm':
case 'html':
$extensionType = 'HTML';
break;
case 'csv':
$extensionType = 'CSV';
break;
default:
$this->response(-1, '文件格式异常');
break;
}
return $extensionType;
}
# 通过奖励名 解析奖励类型以及皮肤id
public function parseRewardTypeAndSkinId($rewardName, $line = 0){
#常规奖励 无皮肤
if(!empty($this->rewardNames[$rewardName])){
return [$this->rewardNames[$rewardName], ''];
}
$prizeList = oo::commonOprModel('config')->getPropsConfigFromLocal();
foreach ($prizeList as $item){
if(empty($item['skinList']))continue;
foreach ($item['skinList'] as $skinItem){
if($skinItem['name'] == $rewardName ){
return [$item['id'], $skinItem['id']];
}
}
}
#判断奖励是否存在
$this->response(-1, "第{$line}行,奖励或皮肤不存在:'{$rewardName}'", $prizeList);
}
# 通过分组名，解析分组id
public function parseShushuGroups($shushuGroups,$line = 0){
if(empty($shushuGroups))$this->response(-1, $line.'行，数数分组为空');
if(is_string($shushuGroups)){
$shushuGroups = strtr($shushuGroups,['，' => ',']);
$shushuGroups = explode(',', $shushuGroups);
}
$allGroups = array_column(oo::commonOprModel('config')->getUserGroupConfigByCid(5),'name','id');
$shushuGroupIds = [];
foreach ($shushuGroups as $shushuGroup){
if(!in_array($shushuGroup, $allGroups))$this->response(-1, "第{$line}行,数数分组不存在:'{$shushuGroup}'");
$shushuGroupIds[] = array_search( $shushuGroup, $allGroups);
}
return $shushuGroupIds;
}
# 解析分层映射的每层idx
public function getGroupMappingIdx($type, $val, $parentsKey = 0){
$this->actGroupMapping[$type] = $this->actGroupMapping[$type] ?? [];
$this->actGroupMapping[$type][$parentsKey] = $this->actGroupMapping[$type][$parentsKey] ?? [];
if(empty($this->actGroupMapping[$type][$parentsKey][$val])){
$this->actGroupMapping[$type][$parentsKey][$val] = count($this->actGroupMapping[$type][$parentsKey]) + 1;
}
return intval($this->actGroupMapping[$type][$parentsKey][$val]);
}
public function parseLineRewards(array $rewards, $line = 0){
$rewardsTemp = [];
$i = 0;
while($i < count($rewards)){
$reward = $rewards[$i++];
$isFixNum = $rewards[$i++];
$rewardNum = intval($rewards[$i++]);
if(!empty($reward)){
if(!in_array($reward, $this->multiNumTypeReward))$isFixNum = '是'; #非金币奖励，全部固定值奖励
$isFixNum = ($isFixNum == '是') ? 1 : 2;#固定值奖励 1 按等级取值 2
if(empty($rewardNum))self::response(-1, "第{$line}行,奖励数为空", $rewards);
list($type, $skin) = $this->parseRewardTypeAndSkinId($reward, $line);
$currentId = count($rewardsTemp)+1;
$rewardsTemp[] = [
'id' => $currentId,
"num" => $rewardNum,
"type" => $type,
"rtype" => $isFixNum,
"skin" => $skin
];
}
}
return $rewardsTemp;
}
public function prizesShowHtml( array $prizes): string
{
$htmlStr = '';
foreach ($prizes as $prize) {
$prizeStr = $this->singlePrizeHtml($prize);
$htmlStr .= '
';
}
$htmlStr .= '
';
return $htmlStr;
}
public function singlePrizeHtml( array $prizes): string
{
$this->propsConfig = $this->propsConfig ?? oo::commonOprModel('config')->getPropsConfigFromLocal() ;
$name = '';
$prizeTypeInfo = [];
foreach ($this->propsConfig as $oneProp) {
if ($oneProp['id'] == $prizes['propsId']) {
$prizeTypeInfo = $oneProp;
if (empty($prizes['skin'])) {
$name = $oneProp['name'];
break;
}
foreach ($oneProp['skinList'] as $oneSkin) {
if ($prizes['skin'] == $oneSkin['id']) {
$name = $oneSkin['name'];
break;
}
}
}
}
$name .= '：' . $prizes['num'] ;
if($prizeTypeInfo['type'] == 'act'){
$name .= '分钟';
}else if($prizes['rtype'] == 2){
$name .= '倍';
}
return $name ;
}
}