refined private server source code

This commit is contained in:
strawmanbobi
2025-10-28 09:03:00 +08:00
parent d866fe89f3
commit 8c11d328ad
78 changed files with 415 additions and 351 deletions

View File

@@ -54,7 +54,7 @@
<dependency>
<groupId>mysql</groupId>
<artifactId>mysql-connector-java</artifactId>
<version>8.0.16</version>
<version>8.0.28</version>
</dependency>
<dependency>
<groupId>org.mybatis.spring.boot</groupId>
@@ -64,7 +64,7 @@
<dependency>
<groupId>commons-io</groupId>
<artifactId>commons-io</artifactId>
<version>2.6</version>
<version>2.14.0</version>
</dependency>
<dependency>
<groupId>redis.clients</groupId>
@@ -78,12 +78,12 @@
<dependency>
<groupId>com.squareup.okio</groupId>
<artifactId>okio</artifactId>
<version>2.2.2</version>
<version>3.4.0</version>
</dependency>
<dependency>
<groupId>com.google.code.gson</groupId>
<artifactId>gson</artifactId>
<version>2.6.2</version>
<version>2.8.9</version>
</dependency>
<dependency>
<groupId>javax.ws.rs</groupId>

View File

@@ -3,7 +3,7 @@ package net.irext.decode.sdk;
import net.irext.decode.sdk.bean.ACStatus;
import net.irext.decode.sdk.bean.TemperatureRange;
import net.irext.decode.sdk.utils.Constants;
import net.irext.server.service.utils.LoggerUtil;
import net.irext.server.utils.LoggerUtil;
/**
* Filename: IRDecode.java

View File

@@ -1,4 +1,4 @@
package net.irext.server.service;
package net.irext.server;
import org.mybatis.spring.annotation.MapperScan;
import org.springframework.boot.SpringApplication;
@@ -15,7 +15,7 @@ import org.springframework.boot.autoconfigure.SpringBootApplication;
* 2019-06-10: created by strawmanbobi
*/
@MapperScan("net.irext.server.service.mapper")
@MapperScan("net.irext.server.mapper")
@SpringBootApplication
public class IRPrivateServerApplication {
public static void main(String[] args) {

View File

@@ -1,8 +1,8 @@
package net.irext.server.service;
package net.irext.server;
import net.irext.server.service.queue.MessagePublisher;
import net.irext.server.service.queue.MessagePublisherImpl;
import net.irext.server.service.queue.MessageSubscriber;
import net.irext.server.queue.MessagePublisher;
import net.irext.server.queue.MessagePublisherImpl;
import net.irext.server.queue.MessageSubscriber;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.ComponentScan;
import org.springframework.context.annotation.Configuration;

View File

@@ -1,6 +1,6 @@
package net.irext.server.service.aspect;
package net.irext.server.aspect;
import net.irext.server.service.response.ServiceResponse;
import net.irext.server.response.ServiceResponse;
/**
* Filename: TokenValidation.java

View File

@@ -1,10 +1,11 @@
package net.irext.server.service.businesslogic;
package net.irext.server.businesslogic;
import com.google.gson.Gson;
import com.squareup.okhttp.*;
import net.irext.server.service.Constants;
import net.irext.server.service.mapper.*;
import net.irext.server.service.model.*;
import net.irext.server.request.CreateRemoteReferenceRequest;
import net.irext.server.utils.Constants;
import net.irext.server.mapper.*;
import net.irext.server.model.*;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Controller;
@@ -159,43 +160,60 @@ public class IndexingLogic {
return remoteIndexList;
}
public String statRemoteRef(int remoteIndexId) {
public String statRemoteRef(int remoteIndexId, int id, String token) {
List<RemoteIndex> remoteIndexList = remoteIndexMapper.getRemoteIndexById(remoteIndexId);
if (null != remoteIndexList && remoteIndexList.size() > 0) {
return statRemoteRef(remoteIndexList.get(0));
return statRemoteRef(remoteIndexList.get(0), id, token);
}
return null;
}
public String statRemoteRef(RemoteIndex remoteIndex) {
public String statRemoteRef(RemoteIndex remoteIndex, int id, String token) {
try {
String url = "http://site.irext.net:8300/irext/stat/stat_remotes";
String url = Constants.REMOTE_REF_URL;
MediaType JSON
= MediaType.parse("application/json; charset=utf-8");
OkHttpClient client = new OkHttpClient();
List<Category> categoryList;
List<Brand> brandList;
String categoryName = null;
String brandName = null;
categoryList = categoryMapper.getCategoryById(remoteIndex.getCategoryId());
if (null == categoryList || categoryList.size() <= 0) {
return null;
}
categoryName = categoryList.get(0).getName();
brandList = brandMapper.getBrandById(remoteIndex.getBrandId());
if (null == brandList || brandList.size() <= 0) {
return null;
}
brandName = brandList.get(0).getName();
RemoteRef remoteRef = new RemoteRef();
remoteRef.setCategory_id(remoteIndex.getCategoryId());
remoteRef.setCategory_name(remoteIndex.getCategoryName());
remoteRef.setBrand_id(remoteIndex.getBrandId());
remoteRef.setBrand_name(remoteIndex.getBrandName());
remoteRef.setCity_code(remoteIndex.getCityCode());
remoteRef.setOperator_id(remoteIndex.getOperatorId());
remoteRef.setRemote_code(remoteIndex.getId().toString());
remoteRef.setCategoryId(remoteIndex.getCategoryId());
remoteRef.setCategoryName(categoryName);
remoteRef.setBrandId(remoteIndex.getBrandId());
remoteRef.setBrandName(brandName);
remoteRef.setCityCode(remoteIndex.getCityCode());
remoteRef.setOperatorId(remoteIndex.getOperatorId());
remoteRef.setRemoteCode(remoteIndex.getId().toString());
remoteRef.setRemote(remoteIndex.getRemote());
remoteRef.setProtocol(remoteIndex.getProtocol());
remoteRef.setRemote_map(remoteIndex.getRemoteMap());
remoteRef.setStatus(1);
remoteRef.setSub_cate(remoteIndex.getSubCate());
if (remoteRef.getCategory_id() != Constants.CategoryID.STB.getValue()) {
remoteRef.setName(remoteIndex.getCategoryName() + remoteIndex.getBrandName());
remoteRef.setRemoteMap(remoteIndex.getRemoteMap());
remoteRef.setStatus((byte) Constants.STATUS_VALID);
remoteRef.setSubCate(remoteIndex.getSubCate());
if (remoteRef.getCategoryId() != Constants.CategoryID.STB.getValue()) {
remoteRef.setName(remoteIndex.getBrandName() + categoryName);
} else {
remoteRef.setName(remoteIndex.getCategoryName() + remoteIndex.getOperatorName());
remoteRef.setName(remoteIndex.getOperatorName() + categoryName);
}
remoteRef.setCreate_type(1);
remoteRef.setCreateType((byte) Constants.CREATE_TYPE_SOURCE);
CreateRemoteReferenceRequest createRemoteRefRequest = new CreateRemoteReferenceRequest(id, token, remoteRef);
String remoteRefBody = new Gson().toJson(remoteRef);
String remoteRefBody = new Gson().toJson(createRemoteRefRequest);
RequestBody body = RequestBody.create(JSON, remoteRefBody);
Request request = new Request.Builder()
@@ -209,167 +227,4 @@ public class IndexingLogic {
}
return null;
}
private static class RemoteRef {
String name;
int category_id;
String category_name;
int brand_id;
String brand_name;
String city_code;
String operator_id;
int status;
String remote_code;
int create_type;
String update_time;
int sub_cate;
String protocol;
String remote;
String remote_map;
public void remoteRef() {
}
public void remoteRef(String name,
int category_id, String category_name, int brand_id, String brand_name,
String city_code, String operator_id,
int status, String remote_code, int create_type, String update_time,
int sub_cate, String protocol, String remote, String remote_map) {
this.name = name;
this.category_id = category_id;
this.category_name = category_name;
this.brand_id = brand_id;
this.brand_name = brand_name;
this.city_code = city_code;
this.operator_id = operator_id;
this.status = status;
this.remote_code = remote_code;
this.create_type = create_type;
this.update_time = update_time;
this.sub_cate = sub_cate;
this.protocol = protocol;
this.remote = remote;
this.remote_map = remote_map;
}
public String getName() {
return name;
}
public void setName(String name) {
this.name = name;
}
public int getCategory_id() {
return category_id;
}
public void setCategory_id(int category_id) {
this.category_id = category_id;
}
public String getCategory_name() {
return category_name;
}
public void setCategory_name(String category_name) {
this.category_name = category_name;
}
public int getBrand_id() {
return brand_id;
}
public void setBrand_id(int brand_id) {
this.brand_id = brand_id;
}
public String getBrand_name() {
return brand_name;
}
public void setBrand_name(String brand_name) {
this.brand_name = brand_name;
}
public String getCity_code() {
return city_code;
}
public void setCity_code(String city_code) {
this.city_code = city_code;
}
public String getOperator_id() {
return operator_id;
}
public void setOperator_id(String operator_id) {
this.operator_id = operator_id;
}
public int getStatus() {
return status;
}
public void setStatus(int status) {
this.status = status;
}
public String getRemote_code() {
return remote_code;
}
public void setRemote_code(String remote_code) {
this.remote_code = remote_code;
}
public int getCreate_type() {
return create_type;
}
public void setCreate_type(int create_type) {
this.create_type = create_type;
}
public String getUpdate_time() {
return update_time;
}
public void setUpdate_time(String update_time) {
this.update_time = update_time;
}
public int getSub_cate() {
return sub_cate;
}
public void setSub_cate(int sub_cate) {
this.sub_cate = sub_cate;
}
public String getProtocol() {
return protocol;
}
public void setProtocol(String protocol) {
this.protocol = protocol;
}
public String getRemote() {
return remote;
}
public void setRemote(String remote) {
this.remote = remote;
}
public String getRemote_map() {
return remote_map;
}
public void setRemote_map(String remote_map) {
this.remote_map = remote_map;
}
}
}

View File

@@ -1,18 +1,18 @@
package net.irext.server.service.businesslogic;
package net.irext.server.businesslogic;
import com.squareup.okhttp.*;
import jakarta.servlet.ServletContext;
import net.irext.decode.sdk.bean.TemperatureRange;
import net.irext.server.service.mapper.CollectKeyMapper;
import net.irext.server.service.mapper.DecodeRemoteMapper;
import net.irext.server.service.mapper.RemoteIndexMapper;
import net.irext.server.service.model.ACParameters;
import net.irext.server.service.model.CollectKey;
import net.irext.server.service.model.DecodeRemote;
import net.irext.server.service.model.RemoteIndex;
import net.irext.server.service.utils.FileUtil;
import net.irext.server.service.utils.LoggerUtil;
import net.irext.server.service.utils.MD5Util;
import net.irext.server.mapper.CollectKeyMapper;
import net.irext.server.mapper.DecodeRemoteMapper;
import net.irext.server.mapper.RemoteIndexMapper;
import net.irext.server.model.ACParameters;
import net.irext.server.model.CollectKey;
import net.irext.server.model.DecodeRemote;
import net.irext.server.model.RemoteIndex;
import net.irext.server.utils.FileUtil;
import net.irext.server.utils.LoggerUtil;
import net.irext.server.utils.MD5Util;
import net.irext.decode.sdk.IRDecode;
import net.irext.decode.sdk.bean.ACStatus;
import org.apache.commons.io.IOUtils;
@@ -46,7 +46,7 @@ public class OperationLogic {
private static final String IR_BIN_FILE_PREFIX = "irda_";
private static final String IR_BIN_FILE_SUFFIX = ".bin";
private static final String IR_BIN_DOWNLOAD_PREFIX = "http://irext-debug.oss-cn-hangzhou.aliyuncs.com/";
private static final String IR_BIN_DOWNLOAD_PREFIX = "https://irext-release.oss-cn-hangzhou.aliyuncs.com/";
private static OperationLogic operationLogic;

View File

@@ -1,10 +1,10 @@
package net.irext.server.service.businesslogic;
package net.irext.server.businesslogic;
import com.google.gson.Gson;
import com.squareup.okhttp.*;
import net.irext.server.service.model.UserApp;
import net.irext.server.service.request.AppSignInRequest;
import net.irext.server.service.response.LoginResponse;
import net.irext.server.model.UserApp;
import net.irext.server.request.AppSignInRequest;
import net.irext.server.response.LoginResponse;
import org.springframework.stereotype.Controller;
/**

View File

@@ -1,4 +1,4 @@
package net.irext.server.service.cache;
package net.irext.server.cache;
import java.util.Map;

View File

@@ -1,6 +1,6 @@
package net.irext.server.service.cache;
package net.irext.server.cache;
import net.irext.server.service.model.RemoteIndex;
import net.irext.server.model.RemoteIndex;
import java.util.Map;

View File

@@ -1,4 +1,4 @@
package net.irext.server.service.cache;
package net.irext.server.cache;
/**
* Filename: IUserAppRepository.java

View File

@@ -1,7 +1,7 @@
package net.irext.server.service.cache.impl;
package net.irext.server.cache.impl;
import jakarta.annotation.PostConstruct;
import net.irext.server.service.cache.IDecodeSessionRepository;
import net.irext.server.cache.IDecodeSessionRepository;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.data.redis.core.HashOperations;
import org.springframework.data.redis.core.RedisTemplate;

View File

@@ -1,9 +1,9 @@
package net.irext.server.service.cache.impl;
package net.irext.server.cache.impl;
import jakarta.annotation.PostConstruct;
import jakarta.annotation.Resource;
import net.irext.server.service.cache.IIRBinaryRepository;
import net.irext.server.service.model.RemoteIndex;
import net.irext.server.cache.IIRBinaryRepository;
import net.irext.server.model.RemoteIndex;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.data.redis.core.HashOperations;
import org.springframework.data.redis.core.RedisTemplate;

View File

@@ -1,8 +1,8 @@
package net.irext.server.service.cache.impl;
package net.irext.server.cache.impl;
import jakarta.annotation.PostConstruct;
import jakarta.annotation.Resource;
import net.irext.server.service.cache.IUserAppRepository;
import net.irext.server.cache.IUserAppRepository;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.data.redis.core.HashOperations;
import org.springframework.data.redis.core.RedisTemplate;

View File

@@ -1,6 +1,6 @@
package net.irext.server.service.mapper;
package net.irext.server.mapper;
import net.irext.server.service.model.Brand;
import net.irext.server.model.Brand;
import org.apache.ibatis.annotations.Mapper;
import org.apache.ibatis.annotations.ResultMap;
import org.apache.ibatis.annotations.Select;
@@ -24,4 +24,8 @@ public interface BrandMapper {
@Select("SELECT * FROM brand WHERE status = 1 AND category_id = #{categoryId} ORDER BY priority LIMIT #{from}, #{count}")
@ResultMap("BaseResultMap")
List<Brand> listBrands(int categoryId, int from, int count);
@Select("SELECT * FROM brand WHERE id = #{id} AND status = 1")
@ResultMap("BaseResultMap")
List<Brand> getBrandById(int id);
}

View File

@@ -1,6 +1,6 @@
package net.irext.server.service.mapper;
package net.irext.server.mapper;
import net.irext.server.service.model.Category;
import net.irext.server.model.Category;
import org.apache.ibatis.annotations.Mapper;
import org.apache.ibatis.annotations.ResultMap;
import org.apache.ibatis.annotations.Select;
@@ -24,4 +24,8 @@ public interface CategoryMapper {
@Select("SELECT * FROM category WHERE status = 1 ORDER BY id LIMIT #{from}, #{count}")
@ResultMap("BaseResultMap")
List<Category> listCategories(int from, int count);
@Select("SELECT * FROM category WHERE id = #{id} AND status = 1")
@ResultMap("BaseResultMap")
List<Category> getCategoryById(int id);
}

View File

@@ -1,6 +1,6 @@
package net.irext.server.service.mapper;
package net.irext.server.mapper;
import net.irext.server.service.model.City;
import net.irext.server.model.City;
import org.apache.ibatis.annotations.Mapper;
import org.apache.ibatis.annotations.ResultMap;
import org.apache.ibatis.annotations.Select;

View File

@@ -1,6 +1,6 @@
package net.irext.server.service.mapper;
package net.irext.server.mapper;
import net.irext.server.service.model.CollectKey;
import net.irext.server.model.CollectKey;
import org.apache.ibatis.annotations.Mapper;
import org.apache.ibatis.annotations.ResultMap;
import org.apache.ibatis.annotations.Select;

View File

@@ -1,6 +1,6 @@
package net.irext.server.service.mapper;
package net.irext.server.mapper;
import net.irext.server.service.model.CollectRemote;
import net.irext.server.model.CollectRemote;
import org.apache.ibatis.annotations.*;
import org.springframework.stereotype.Controller;

View File

@@ -1,6 +1,6 @@
package net.irext.server.service.mapper;
package net.irext.server.mapper;
import net.irext.server.service.model.DecodeRemote;
import net.irext.server.model.DecodeRemote;
import org.apache.ibatis.annotations.Mapper;
import org.apache.ibatis.annotations.ResultMap;
import org.apache.ibatis.annotations.Select;

View File

@@ -1,6 +1,6 @@
package net.irext.server.service.mapper;
package net.irext.server.mapper;
import net.irext.server.service.model.RemoteIndex;
import net.irext.server.model.RemoteIndex;
import org.apache.ibatis.annotations.Mapper;
import org.apache.ibatis.annotations.ResultMap;
import org.apache.ibatis.annotations.Select;

View File

@@ -1,6 +1,6 @@
package net.irext.server.service.mapper;
package net.irext.server.mapper;
import net.irext.server.service.model.StbOperator;
import net.irext.server.model.StbOperator;
import org.apache.ibatis.annotations.Mapper;
import org.apache.ibatis.annotations.ResultMap;
import org.apache.ibatis.annotations.Select;

View File

@@ -1,4 +1,4 @@
package net.irext.server.service.model;
package net.irext.server.model;
/**
* Filename: ACParameters.java

View File

@@ -1,4 +1,4 @@
package net.irext.server.service.model;
package net.irext.server.model;
public class Brand {
private Integer id;

View File

@@ -1,4 +1,4 @@
package net.irext.server.service.model;
package net.irext.server.model;
public class Category {
private Integer id;

View File

@@ -1,4 +1,4 @@
package net.irext.server.service.model;
package net.irext.server.model;
public class City {
private Integer id;

View File

@@ -1,4 +1,4 @@
package net.irext.server.service.model;
package net.irext.server.model;
/**
* Filename: CollectKey.java

View File

@@ -1,4 +1,4 @@
package net.irext.server.service.model;
package net.irext.server.model;
public class CollectRemote {

View File

@@ -1,4 +1,4 @@
package net.irext.server.service.model;
package net.irext.server.model;
public class DecodeRemote {

View File

@@ -1,4 +1,4 @@
package net.irext.server.service.model;
package net.irext.server.model;
import java.io.Serializable;

View File

@@ -0,0 +1,163 @@
package net.irext.server.model;
public class RemoteRef {
private Integer id;
private String name;
private Integer categoryId;
private String categoryName;
private Integer brandId;
private String brandName;
private String cityCode;
private String operatorId;
private Byte status;
private Byte createType;
private String updateTime;
private Byte subCate;
private String protocol;
private String remote;
private String remoteMap;
private String remoteCode;
public Integer getId() {
return id;
}
public void setId(Integer id) {
this.id = id;
}
public String getName() {
return name;
}
public void setName(String name) {
this.name = name;
}
public Integer getCategoryId() {
return categoryId;
}
public void setCategoryId(Integer categoryId) {
this.categoryId = categoryId;
}
public String getCategoryName() {
return categoryName;
}
public void setCategoryName(String categoryName) {
this.categoryName = categoryName;
}
public Integer getBrandId() {
return brandId;
}
public void setBrandId(Integer brandId) {
this.brandId = brandId;
}
public String getBrandName() {
return brandName;
}
public void setBrandName(String brandName) {
this.brandName = brandName;
}
public String getCityCode() {
return cityCode;
}
public void setCityCode(String cityCode) {
this.cityCode = cityCode;
}
public String getOperatorId() {
return operatorId;
}
public void setOperatorId(String operatorId) {
this.operatorId = operatorId;
}
public Byte getStatus() {
return status;
}
public void setStatus(Byte status) {
this.status = status;
}
public Byte getCreateType() {
return createType;
}
public void setCreateType(Byte createType) {
this.createType = createType;
}
public String getUpdateTime() {
return updateTime;
}
public void setUpdateTime(String updateTime) {
this.updateTime = updateTime;
}
public Byte getSubCate() {
return subCate;
}
public void setSubCate(Byte subCate) {
this.subCate = subCate;
}
public String getProtocol() {
return protocol;
}
public void setProtocol(String protocol) {
this.protocol = protocol;
}
public String getRemote() {
return remote;
}
public void setRemote(String remote) {
this.remote = remote;
}
public String getRemoteMap() {
return remoteMap;
}
public void setRemoteMap(String remoteMap) {
this.remoteMap = remoteMap;
}
public String getRemoteCode() {
return remoteCode;
}
public void setRemoteCode(String remoteCode) {
this.remoteCode = remoteCode;
}
}

View File

@@ -1,4 +1,4 @@
package net.irext.server.service.model;
package net.irext.server.model;
public class StbOperator {
private Integer id;

View File

@@ -1,4 +1,4 @@
package net.irext.server.service.model;
package net.irext.server.model;
public class UserApp {

View File

@@ -1,4 +1,4 @@
package net.irext.server.service.queue;
package net.irext.server.queue;
/**
* Filename: MessagePublisher.java

View File

@@ -1,4 +1,4 @@
package net.irext.server.service.queue;
package net.irext.server.queue;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.data.redis.core.RedisTemplate;

View File

@@ -1,4 +1,4 @@
package net.irext.server.service.queue;
package net.irext.server.queue;
import org.springframework.data.redis.connection.Message;
import org.springframework.data.redis.connection.MessageListener;

View File

@@ -1,4 +1,4 @@
package net.irext.server.service.request;
package net.irext.server.request;
/**
* Filename: AppSignInRequest.java

View File

@@ -1,4 +1,4 @@
package net.irext.server.service.request;
package net.irext.server.request;
import com.google.gson.Gson;

View File

@@ -1,4 +1,4 @@
package net.irext.server.service.request;
package net.irext.server.request;
/**
* Filename: CloseRequest.java

View File

@@ -0,0 +1,31 @@
package net.irext.server.request;
import net.irext.server.model.RemoteRef;
/**
* Filename: CreateRemoteReferenceRequest.java
* Revised: Date: 2025-10-24
* Revision: Revision: 1.0
* <p>
* Description: HTTP API for adding remote reference
* <p>
* Revision log:
* 2025-10-24: created by strawmanbobi
*/
public class CreateRemoteReferenceRequest extends BaseRequest {
RemoteRef remoteRef;
public CreateRemoteReferenceRequest(int id, String token, RemoteRef remoteRef) {
super(id, token);
this.remoteRef = remoteRef;
}
public CreateRemoteReferenceRequest() {
}
public void setRemoteRef(RemoteRef remoteRef) {
this.remoteRef = remoteRef;
}
}

View File

@@ -1,4 +1,4 @@
package net.irext.server.service.request;
package net.irext.server.request;
import net.irext.decode.sdk.bean.ACStatus;

View File

@@ -1,4 +1,4 @@
package net.irext.server.service.request;
package net.irext.server.request;
/**
* Filename: DownloadBinaryRequest.java

View File

@@ -1,4 +1,4 @@
package net.irext.server.service.request;
package net.irext.server.request;
/**
* Filename: GetACParametersRequest.java

View File

@@ -1,4 +1,4 @@
package net.irext.server.service.request;
package net.irext.server.request;
/**
* Filename: ListBrandsRequest.java

View File

@@ -1,4 +1,4 @@
package net.irext.server.service.request;
package net.irext.server.request;
/**
* Filename: ListCategoriesRequest.java

View File

@@ -1,4 +1,4 @@
package net.irext.server.service.request;
package net.irext.server.request;
/**
* Filename: ListCitiesRequest.java

View File

@@ -1,4 +1,4 @@
package net.irext.server.service.request;
package net.irext.server.request;
/**
* Filename: ListIndexesRequest.java

View File

@@ -1,4 +1,4 @@
package net.irext.server.service.request;
package net.irext.server.request;
/**
* Filename: ListOperatorsRequest.java

View File

@@ -1,4 +1,4 @@
package net.irext.server.service.request;
package net.irext.server.request;
/**
* Filename: OpenRequest.java

View File

@@ -1,6 +1,6 @@
package net.irext.server.service.response;
package net.irext.server.response;
import net.irext.server.service.model.ACParameters;
import net.irext.server.model.ACParameters;
/**
* Filename: ACParametersResponse.java

View File

@@ -1,6 +1,6 @@
package net.irext.server.service.response;
package net.irext.server.response;
import net.irext.server.service.model.Brand;
import net.irext.server.model.Brand;
import java.util.List;

View File

@@ -1,6 +1,6 @@
package net.irext.server.service.response;
package net.irext.server.response;
import net.irext.server.service.model.Category;
import net.irext.server.model.Category;
import java.util.List;

View File

@@ -1,6 +1,6 @@
package net.irext.server.service.response;
package net.irext.server.response;
import net.irext.server.service.model.City;
import net.irext.server.model.City;
import java.util.List;

View File

@@ -1,4 +1,4 @@
package net.irext.server.service.response;
package net.irext.server.response;
/**
* Filename: DecodeResponse.java

View File

@@ -1,6 +1,6 @@
package net.irext.server.service.response;
package net.irext.server.response;
import net.irext.server.service.model.RemoteIndex;
import net.irext.server.model.RemoteIndex;
import java.util.List;

View File

@@ -1,6 +1,6 @@
package net.irext.server.service.response;
package net.irext.server.response;
import net.irext.server.service.model.UserApp;
import net.irext.server.model.UserApp;
/**
* Filename: LoginResponse.java

View File

@@ -1,6 +1,6 @@
package net.irext.server.service.response;
package net.irext.server.response;
import net.irext.server.service.model.StbOperator;
import net.irext.server.model.StbOperator;
import java.util.List;

View File

@@ -1,4 +1,4 @@
package net.irext.server.service.response;
package net.irext.server.response;
/**
* Filename: ServiceResponse.java

View File

@@ -1,6 +1,6 @@
package net.irext.server.service.response;
package net.irext.server.response;
import net.irext.server.service.Constants;
import net.irext.server.utils.Constants;
/**
* Filename: Status.java

View File

@@ -1,4 +1,4 @@
package net.irext.server.service.response;
package net.irext.server.response;
/**
* Filename: StringResponse.java

View File

@@ -1,13 +1,13 @@
package net.irext.server.service.restapi;
package net.irext.server.restapi;
import jakarta.servlet.ServletContext;
import jakarta.servlet.http.HttpServletRequest;
import net.irext.server.service.Constants;
import net.irext.server.service.businesslogic.IndexingLogic;
import net.irext.server.service.model.*;
import net.irext.server.service.request.*;
import net.irext.server.service.response.*;
import net.irext.server.service.restapi.base.AbstractBaseService;
import net.irext.server.utils.Constants;
import net.irext.server.businesslogic.IndexingLogic;
import net.irext.server.model.*;
import net.irext.server.request.*;
import net.irext.server.response.*;
import net.irext.server.restapi.base.AbstractBaseService;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;
import org.springframework.web.bind.annotation.PostMapping;
@@ -23,7 +23,7 @@ import java.util.List;
* Revised: Date: 2019-06-08
* Revision: Revision: 1.0
* <p>
* Description: IRext indexing service
* Description: IRext indexing server
* <p>
* Revision log:
* 2019-06-08: created by strawmanbobi

View File

@@ -1,17 +1,17 @@
package net.irext.server.service.restapi;
package net.irext.server.restapi;
import com.google.gson.Gson;
import jakarta.servlet.ServletContext;
import net.irext.server.service.businesslogic.OperationLogic;
import net.irext.server.service.cache.IDecodeSessionRepository;
import net.irext.server.service.cache.IIRBinaryRepository;
import net.irext.server.service.model.ACParameters;
import net.irext.server.service.model.RemoteIndex;
import net.irext.server.service.request.*;
import net.irext.server.service.response.*;
import net.irext.server.service.utils.LoggerUtil;
import net.irext.server.service.businesslogic.IndexingLogic;
import net.irext.server.service.restapi.base.AbstractBaseService;
import net.irext.server.businesslogic.OperationLogic;
import net.irext.server.cache.IDecodeSessionRepository;
import net.irext.server.cache.IIRBinaryRepository;
import net.irext.server.model.ACParameters;
import net.irext.server.model.RemoteIndex;
import net.irext.server.request.*;
import net.irext.server.response.*;
import net.irext.server.utils.LoggerUtil;
import net.irext.server.businesslogic.IndexingLogic;
import net.irext.server.restapi.base.AbstractBaseService;
import net.irext.decode.sdk.bean.ACStatus;
import net.irext.decode.sdk.utils.Constants;
import org.springframework.beans.factory.annotation.Autowired;
@@ -33,7 +33,7 @@ import java.io.IOException;
* Revised: Date: 2018-12-16
* Revision: Revision: 1.0
* <p>
* Description: IRext operation service
* Description: IRext operation server
* <p>
* Revision log:
* 2018-12-16: created by strawmanbobi
@@ -91,7 +91,7 @@ public class IROperationService extends AbstractBaseService {
File downloadFile = operationLogic.getDownloadFile(context, indexId);
ServiceResponse response = validateToken(id, token, ServiceResponse.class);
if (response.getStatus().getCode() == net.irext.server.service.Constants.ERROR_CODE_AUTH_FAILURE) {
if (response.getStatus().getCode() == net.irext.server.utils.Constants.ERROR_CODE_AUTH_FAILURE) {
return null;
}
if (null == downloadFile) {
@@ -101,7 +101,7 @@ public class IROperationService extends AbstractBaseService {
InputStreamResource resource = new InputStreamResource(new FileInputStream(downloadFile));
String fileName = downloadFile.getName();
long fileLength = downloadFile.length();
indexingLogic.statRemoteRef(indexId);
indexingLogic.statRemoteRef(indexId, id, token);
return ResponseEntity.ok()
// Content-Disposition
.header(HttpHeaders.CONTENT_DISPOSITION, "attachment;filename=" + fileName)
@@ -115,7 +115,7 @@ public class IROperationService extends AbstractBaseService {
int id = getACParametersRequest.getId();
String token = getACParametersRequest.getToken();
ACParametersResponse response = validateToken(id, token, ACParametersResponse.class);
if (response.getStatus().getCode() == net.irext.server.service.Constants.ERROR_CODE_AUTH_FAILURE) {
if (response.getStatus().getCode() == net.irext.server.utils.Constants.ERROR_CODE_AUTH_FAILURE) {
return response;
}
@@ -140,7 +140,7 @@ public class IROperationService extends AbstractBaseService {
int id = decodeRequest.getId();
String token = decodeRequest.getToken();
DecodeResponse response = validateToken(id, token, DecodeResponse.class);
if (response.getStatus().getCode() == net.irext.server.service.Constants.ERROR_CODE_AUTH_FAILURE) {
if (response.getStatus().getCode() == net.irext.server.utils.Constants.ERROR_CODE_AUTH_FAILURE) {
return response;
}
try {
@@ -192,7 +192,7 @@ public class IROperationService extends AbstractBaseService {
}
response.setEntity(decoded);
if (null != remoteIndex) {
indexingLogic.statRemoteRef(remoteIndex);
indexingLogic.statRemoteRef(remoteIndex, id, token);
}
return response;
} catch (Exception e) {

View File

@@ -1,16 +1,16 @@
package net.irext.server.service.restapi;
package net.irext.server.restapi;
import jakarta.servlet.http.HttpServletRequest;
import net.irext.server.service.Constants;
import net.irext.server.service.businesslogic.UserLoginLogic;
import net.irext.server.service.cache.IUserAppRepository;
import net.irext.server.service.model.UserApp;
import net.irext.server.service.request.AppSignInRequest;
import net.irext.server.service.response.LoginResponse;
import net.irext.server.service.response.Status;
import net.irext.server.service.restapi.base.AbstractBaseService;
import net.irext.server.service.utils.MD5Util;
import net.irext.server.service.utils.VeDate;
import net.irext.server.utils.Constants;
import net.irext.server.businesslogic.UserLoginLogic;
import net.irext.server.cache.IUserAppRepository;
import net.irext.server.model.UserApp;
import net.irext.server.request.AppSignInRequest;
import net.irext.server.response.LoginResponse;
import net.irext.server.response.Status;
import net.irext.server.restapi.base.AbstractBaseService;
import net.irext.server.utils.MD5Util;
import net.irext.server.utils.VeDate;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;
import org.springframework.util.StringUtils;
@@ -24,7 +24,7 @@ import org.springframework.web.bind.annotation.RestController;
* Revised: Date: 2017-04-27
* Revision: Revision: 1.0
* <p>
* Description: User app login service
* Description: User app login server
* <p>
* Revision log:
* 2017-04-27: created by strawmanbobi

View File

@@ -1,10 +1,10 @@
package net.irext.server.service.restapi.base;
package net.irext.server.restapi.base;
import net.irext.server.service.Constants;
import net.irext.server.service.aspect.TokenValidation;
import net.irext.server.service.cache.IUserAppRepository;
import net.irext.server.service.response.ServiceResponse;
import net.irext.server.service.response.Status;
import net.irext.server.utils.Constants;
import net.irext.server.aspect.TokenValidation;
import net.irext.server.cache.IUserAppRepository;
import net.irext.server.response.ServiceResponse;
import net.irext.server.response.Status;
import org.apache.commons.logging.Log;
import org.apache.commons.logging.LogFactory;
import org.springframework.beans.factory.annotation.Autowired;

View File

@@ -1,4 +1,4 @@
package net.irext.server.service;
package net.irext.server.utils;
/**
* Filename: Constants.java
@@ -12,6 +12,11 @@ package net.irext.server.service;
*/
public class Constants {
public static final int CREATE_TYPE_LEGACY = 0;
public static final int CREATE_TYPE_DOWNLOAD = 1;
public static final int CREATE_TYPE_COLLECT = 2;
public static final int CREATE_TYPE_SOURCE = 3;
public static final int ERROR_CODE_SUCCESS = 0;
public static final int ERROR_CODE_NETWORK_ERROR = -1;
public static final int ERROR_CODE_AUTH_FAILURE = 1;
@@ -27,6 +32,8 @@ public class Constants {
public static final int STATUS_INVALID = 0;
public static final int STATUS_PARA_DATA = 15;
public static final String REMOTE_REF_URL = "http://192.168.75.128:8083/irext-server/remote_ref/create_remote_ref";
public enum CategoryID {
AIR_CONDITIONER(1),
TV(2),

View File

@@ -1,4 +1,4 @@
package net.irext.server.service.utils;
package net.irext.server.utils;
import java.io.*;

View File

@@ -1,4 +1,4 @@
package net.irext.server.service.utils;
package net.irext.server.utils;
import org.apache.logging.log4j.LogManager;
import org.apache.logging.log4j.Logger;

View File

@@ -1,4 +1,4 @@
package net.irext.server.service.utils;
package net.irext.server.utils;
import java.security.MessageDigest;

View File

@@ -1,4 +1,4 @@
package net.irext.server.service.utils;
package net.irext.server.utils;
import org.apache.commons.logging.Log;
import org.apache.commons.logging.LogFactory;

View File

@@ -7,6 +7,6 @@ spring.redis.port=6379
spring.datasource.url=jdbc:mysql://localhost:3306/irext?useUnicode=true&useJDBCCompliantTimezoneShift=true&useLegacyDatetimeCode=false&serverTimezone=UTC
spring.datasource.username=root
spring.datasource.password=root
spring.datasource.password=421aWill.
user.data.basedir=/data/

View File

@@ -1,7 +1,7 @@
<?xml version="1.0" encoding="UTF-8" ?>
<!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" "http://mybatis.org/dtd/mybatis-3-mapper.dtd" >
<mapper namespace="net.irext.server.service.mapper.BrandMapper">
<resultMap id="BaseResultMap" type="net.irext.server.service.model.Brand">
<mapper namespace="net.irext.server.mapper.BrandMapper">
<resultMap id="BaseResultMap" type="net.irext.server.model.Brand">
<!--
WARNING - @mbggenerated
This element is automatically generated by MyBatis Generator, do not modify.

View File

@@ -1,7 +1,7 @@
<?xml version="1.0" encoding="UTF-8" ?>
<!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" "http://mybatis.org/dtd/mybatis-3-mapper.dtd" >
<mapper namespace="net.irext.server.service.mapper.CategoryMapper">
<resultMap id="BaseResultMap" type="net.irext.server.service.model.Category">
<mapper namespace="net.irext.server.mapper.CategoryMapper">
<resultMap id="BaseResultMap" type="net.irext.server.model.Category">
<!--
WARNING - @mbggenerated
This element is automatically generated by MyBatis Generator, do not modify.

View File

@@ -1,7 +1,7 @@
<?xml version="1.0" encoding="UTF-8" ?>
<!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" "http://mybatis.org/dtd/mybatis-3-mapper.dtd" >
<mapper namespace="net.irext.server.service.mapper.CityMapper">
<resultMap id="BaseResultMap" type="net.irext.server.service.model.City">
<mapper namespace="net.irext.server.mapper.CityMapper">
<resultMap id="BaseResultMap" type="net.irext.server.model.City">
<!--
WARNING - @mbggenerated
This element is automatically generated by MyBatis Generator, do not modify.

View File

@@ -1,7 +1,7 @@
<?xml version="1.0" encoding="UTF-8" ?>
<!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" "http://mybatis.org/dtd/mybatis-3-mapper.dtd" >
<mapper namespace="net.irext.server.service.mapper.CollectKeyMapper">
<resultMap id="BaseResultMap" type="net.irext.server.service.model.CollectKey">
<mapper namespace="net.irext.server.mapper.CollectKeyMapper">
<resultMap id="BaseResultMap" type="net.irext.server.model.CollectKey">
<!--
WARNING - @mbggenerated
This element is automatically generated by MyBatis Generator, do not modify.

View File

@@ -1,7 +1,7 @@
<?xml version="1.0" encoding="UTF-8" ?>
<!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" "http://mybatis.org/dtd/mybatis-3-mapper.dtd" >
<mapper namespace="net.irext.server.service.mapper.CollectRemoteMapper">
<resultMap id="BaseResultMap" type="net.irext.server.service.model.CollectRemote">
<mapper namespace="net.irext.server.mapper.CollectRemoteMapper">
<resultMap id="BaseResultMap" type="net.irext.server.model.CollectRemote">
<!--
WARNING - @mbggenerated
This element is automatically generated by MyBatis Generator, do not modify.

View File

@@ -1,7 +1,7 @@
<?xml version="1.0" encoding="UTF-8" ?>
<!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" "http://mybatis.org/dtd/mybatis-3-mapper.dtd" >
<mapper namespace="net.irext.server.service.mapper.DecodeRemoteMapper">
<resultMap id="BaseResultMap" type="net.irext.server.service.model.DecodeRemote">
<mapper namespace="net.irext.server.mapper.DecodeRemoteMapper">
<resultMap id="BaseResultMap" type="net.irext.server.model.DecodeRemote">
<!--
WARNING - @mbggenerated
This element is automatically generated by MyBatis Generator, do not modify.

View File

@@ -1,7 +1,7 @@
<?xml version="1.0" encoding="UTF-8" ?>
<!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" "http://mybatis.org/dtd/mybatis-3-mapper.dtd" >
<mapper namespace="net.irext.server.service.mapper.RemoteIndexMapper">
<resultMap id="BaseResultMap" type="net.irext.server.service.model.RemoteIndex">
<mapper namespace="net.irext.server.mapper.RemoteIndexMapper">
<resultMap id="BaseResultMap" type="net.irext.server.model.RemoteIndex">
<!--
WARNING - @mbggenerated
This element is automatically generated by MyBatis Generator, do not modify.

View File

@@ -1,7 +1,7 @@
<?xml version="1.0" encoding="UTF-8" ?>
<!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" "http://mybatis.org/dtd/mybatis-3-mapper.dtd" >
<mapper namespace="net.irext.server.service.mapper.StbOperatorMapper">
<resultMap id="BaseResultMap" type="net.irext.server.service.model.StbOperator">
<mapper namespace="net.irext.server.mapper.StbOperatorMapper">
<resultMap id="BaseResultMap" type="net.irext.server.model.StbOperator">
<!--
WARNING - @mbggenerated
This element is automatically generated by MyBatis Generator, do not modify.