Commit 393a1eef authored by Allen Chen's avatar Allen Chen

Merge branch 'master' of http://gitlab.tradeany.com/zhouzongshun/multiplesourcesecurity

# Conflicts:
#	PddServer/src/main/resources/application.yaml
#	PddServer/src/test/java/org/ta/pddserver/CommonTest.java
parents b0e8ef95 b8ae944f
...@@ -3,25 +3,25 @@ package org.ta.pddserver.config; ...@@ -3,25 +3,25 @@ package org.ta.pddserver.config;
public class PddAPIConfig { public class PddAPIConfig {
// 临沂海际韩国集运 生产环境参数 // 临沂海际韩国集运 生产环境参数
// 应用基础参数 // 应用基础参数
public static final String CLIENT_ID = "8f5f3f9c92e847b2894fc9c0afce3d61"; // public static final String CLIENT_ID = "8f5f3f9c92e847b2894fc9c0afce3d61";
public static final String CLIENT_SECRET = "281d79ad5117d20a51efb9e7b0d5f7ee336399b0"; // public static final String CLIENT_SECRET = "281d79ad5117d20a51efb9e7b0d5f7ee336399b0";
// 基础API地址 // // 基础API地址
public static final String URL = "https://ark-api.pinduoduo.com/ark/router"; // public static final String URL = "https://ark-api.pinduoduo.com/ark/router";
// 工单API地址 // // 工单API地址
public static final String URL_GD = "https://gw-api.pinduoduo.com/api/router"; // public static final String URL_GD = "https://gw-api.pinduoduo.com/api/router";
//
// 基础API地址 // 基础API地址
public static final String BASE_URL = "https://gw-api.pinduoduo.com/api/router"; public static final String BASE_URL = "https://gw-api.pinduoduo.com/api/router";
// 临沂海际韩国集运 测试环境参数 // 临沂海际韩国集运 测试环境参数
// 应用基础参数 // 应用基础参数
// public static final String CLIENT_ID = "d0217707e1194c46b57e696ac7619a06"; public static final String CLIENT_ID = "d0217707e1194c46b57e696ac7619a06";
// public static final String CLIENT_SECRET = "a5aba84483d8387030899f01276b06a194942470"; public static final String CLIENT_SECRET = "a5aba84483d8387030899f01276b06a194942470";
// // 基础API地址 // 基础API地址
// public static final String URL = "https://opengw-api.hutaojie.com/ark/router"; public static final String URL = "https://opengw-api.hutaojie.com/ark/router";
// // 工单API地址 // 工单API地址
// public static final String URL_GD = "https://opengw-api.hutaojie.com/api/router"; public static final String URL_GD = "https://opengw-api.hutaojie.com/api/router";
......
...@@ -119,7 +119,7 @@ public class DataGetController { ...@@ -119,7 +119,7 @@ public class DataGetController {
/*待拣货列表*/ /*待拣货列表*/
@PostMapping("/outboundList") @PostMapping("/outboundList")
public JSONObject outboundList(HttpServletRequest request, @RequestBody CollectOrderListRequest collectOrderListRequest) { public JSONObject outboundList(HttpServletRequest request, @RequestBody CollectOrderListRequest collectOrderListRequest) {
collectOrderListRequest.setStatus(StatusEnum.FINISHOUTBOUND.getCode()); collectOrderListRequest.setStatus("" + StatusEnum.FINISHOUTBOUND.getCode());
if (collectOrderListRequest.getSize() > 100) { if (collectOrderListRequest.getSize() > 100) {
collectOrderListRequest.setSize(100); collectOrderListRequest.setSize(100);
} }
......
package org.ta.pddserver.entity;
import com.baomidou.mybatisplus.annotation.TableField;
import com.baomidou.mybatisplus.annotation.TableId;
import com.baomidou.mybatisplus.annotation.TableName;
import lombok.Data;
@TableName("user")
@Data
public class UserEntity {
@TableId(value = "uid")
private String uid;
@TableField(value = "created")
private String created;
@TableField(value = "updated")
private String updated;
@TableField(value = "state")
private Integer state;
@TableField(value = "remarks")
private String remarks;
@TableField(value = "status")
private Integer status;
@TableField(value = "name")
private String name;
@TableField(value = "account")
private String account;
@TableField(value = "password")
private String password;
}
...@@ -2,10 +2,12 @@ package org.ta.pddserver.mapper; ...@@ -2,10 +2,12 @@ package org.ta.pddserver.mapper;
import com.baomidou.mybatisplus.core.mapper.BaseMapper; import com.baomidou.mybatisplus.core.mapper.BaseMapper;
import org.apache.ibatis.annotations.Mapper; import org.apache.ibatis.annotations.Mapper;
import org.apache.ibatis.annotations.Param;
import org.apache.ibatis.annotations.Select; import org.apache.ibatis.annotations.Select;
import org.ta.pddserver.entity.LogOrderMailDetailIoEntity; import org.ta.pddserver.entity.LogOrderMailDetailIoEntity;
import org.ta.pddserver.model.api.request.LogOrderMailDetailIoRequest; import org.ta.pddserver.model.api.request.LogOrderMailDetailIoRequest;
import org.ta.pddserver.model.api.response.LogOrderMailDetailIoListResponse; import org.ta.pddserver.model.api.response.LogOrderMailDetailIoListResponse;
import org.ta.pddserver.model.api.response.MailDetailIoSelectResponse;
import java.util.List; import java.util.List;
...@@ -23,4 +25,7 @@ public interface LogOrderMailDetailIoMapper extends BaseMapper<LogOrderMailDetai ...@@ -23,4 +25,7 @@ public interface LogOrderMailDetailIoMapper extends BaseMapper<LogOrderMailDetai
@Select("SELECT `uid`, `created`,`status`, `logisticsOrderCode`, `expressCode`, `mailNo`, `action` FROM `log_order_mail_detail_io` WHERE `mailNo` = #{mailNo} AND `status` = 60 AND `action` = 'FINISHOUTBOUND';") @Select("SELECT `uid`, `created`,`status`, `logisticsOrderCode`, `expressCode`, `mailNo`, `action` FROM `log_order_mail_detail_io` WHERE `mailNo` = #{mailNo} AND `status` = 60 AND `action` = 'FINISHOUTBOUND';")
LogOrderMailDetailIoEntity findOutboundByMailNo(String mailNo); LogOrderMailDetailIoEntity findOutboundByMailNo(String mailNo);
@Select("SELECT `uid`, `created`, `updated`, `logisticsOrderCode`, `expressCode`, `action` FROM `log_order_mail_detail_io` WHERE `mailNo` = #{mailNo} AND `action` = #{action}")
MailDetailIoSelectResponse findInfoByMailNoAction(@Param("mailNo") String mailNo, @Param("action") String action);
} }
package org.ta.pddserver.mapper;
import com.baomidou.mybatisplus.core.mapper.BaseMapper;
import org.apache.ibatis.annotations.Mapper;
import org.apache.ibatis.annotations.Param;
import org.apache.ibatis.annotations.Select;
import org.ta.pddserver.entity.AreaEntity;
import org.ta.pddserver.entity.UserEntity;
import org.ta.pddserver.model.api.request.AreaListRequest;
import org.ta.pddserver.model.api.request.UserRequest;
import org.ta.pddserver.model.api.response.LogOrderListResponse;
import org.ta.pddserver.model.api.response.UserListResponse;
import java.util.List;
@Mapper
public interface UserMapper extends BaseMapper<UserEntity> {
@Select("SELECT * FROM `user` WHERE `account` = #{account}")
UserEntity getInfoByAccount(String account);
@Select("SELECT `uid` , `name` ,`status`, `account`, `created` FROM `user` WHERE `state` > 0 AND `account` LIKE '%${account}%' AND `status` LIKE '%${status}%' ORDER BY uid DESC LIMIT #{offset}, #{size};")
List<UserListResponse> getListByRequest(UserRequest param);
@Select("SELECT COUNT(`uid`) FROM `user` WHERE `state` > 0 AND `account` LIKE '%${account}%' AND `status` LIKE '%${status}%' ")
Integer countUsable(UserRequest param);
}
...@@ -24,7 +24,7 @@ public class CollectOrderListRequest extends PageTool { ...@@ -24,7 +24,7 @@ public class CollectOrderListRequest extends PageTool {
defaultValue = "", defaultValue = "",
requiredMode = Schema.RequiredMode.REQUIRED // 必填 requiredMode = Schema.RequiredMode.REQUIRED // 必填
) )
private int status; private String status;
private int num; private int num;
......
package org.ta.pddserver.model.api.request;
import io.swagger.v3.oas.annotations.media.Schema;
import lombok.Data;
@Data
public class MailDetailIoSelectRequest {
@Schema(
description = "搜索运单号,模糊搜索",
example = "PC123456",
defaultValue = "",
requiredMode = Schema.RequiredMode.REQUIRED // 必填
)
private String mailNo;
}
package org.ta.pddserver.model.api.request;
import io.swagger.v3.oas.annotations.media.Schema;
import lombok.Data;
import org.ta.pddserver.model.common.PageTool;
@Data
public class UnpackNoticeSelectRequest{
private String orderCode;
}
package org.ta.pddserver.model.api.request;
import io.swagger.v3.oas.annotations.media.Schema;
import lombok.Data;
import org.ta.pddserver.model.common.PageTool;
@Data
public class UserListRequest extends PageTool {
private String name;
private String status;
}
package org.ta.pddserver.model.api.request;
import lombok.Data;
import org.ta.pddserver.model.common.PageTool;
@Data
public class UserRequest extends PageTool {
private String account;
private String password;
private String name;
}
package org.ta.pddserver.model.api.response;
import lombok.Data;
@Data
public class MailDetailIoSelectResponse {
private String uid;
private String created;
private String updated;
private String logisticsOrderCode;
private String expressCode;
private String mailNo;
private String action;
}
package org.ta.pddserver.model.api.response;
import lombok.Data;
@Data
public class UnpackNoticeSelectResponse {
private String uid;
private String created;
private String updated;
private String buyerCode;
private String consoType;
private String consoWarehouseCode;
private String deliveryType;
private String providerCode;
private String orderCode;
}
package org.ta.pddserver.model.api.response;
import lombok.Data;
@Data
public class UserListResponse {
private String uid;
private String orderCode;
private String orderSn;
private String logisticsOrderCode;
private String itemId;
private String itemName;
private String categoryName;
private int itemQuantity;
private int weightTotal;
private int actualAmount;
private String productName;
private int exportDecAmount;
}
package org.ta.pddserver.service;
import com.baomidou.mybatisplus.extension.service.IService;
import org.ta.pddserver.entity.AreaEntity;
import org.ta.pddserver.entity.UserEntity;
public interface UserService extends IService<UserEntity> {
}
...@@ -6,7 +6,9 @@ import org.springframework.stereotype.Service; ...@@ -6,7 +6,9 @@ import org.springframework.stereotype.Service;
import org.ta.pddserver.entity.LogOrderMailDetailIoEntity; import org.ta.pddserver.entity.LogOrderMailDetailIoEntity;
import org.ta.pddserver.mapper.LogOrderMailDetailIoMapper; import org.ta.pddserver.mapper.LogOrderMailDetailIoMapper;
import org.ta.pddserver.model.api.request.LogOrderMailDetailIoRequest; import org.ta.pddserver.model.api.request.LogOrderMailDetailIoRequest;
import org.ta.pddserver.model.api.request.MailDetailIoSelectRequest;
import org.ta.pddserver.model.api.response.LogOrderMailDetailIoListResponse; import org.ta.pddserver.model.api.response.LogOrderMailDetailIoListResponse;
import org.ta.pddserver.model.api.response.MailDetailIoSelectResponse;
import org.ta.pddserver.service.LogOrderMailDetailIoService; import org.ta.pddserver.service.LogOrderMailDetailIoService;
import java.util.HashMap; import java.util.HashMap;
...@@ -36,4 +38,8 @@ public class LogOrderMailDetailIoImpl extends ServiceImpl<LogOrderMailDetailIoMa ...@@ -36,4 +38,8 @@ public class LogOrderMailDetailIoImpl extends ServiceImpl<LogOrderMailDetailIoMa
public LogOrderMailDetailIoEntity getOutboundByMailNo(String mailNo) { public LogOrderMailDetailIoEntity getOutboundByMailNo(String mailNo) {
return this.baseMapper.findOutboundByMailNo(mailNo); return this.baseMapper.findOutboundByMailNo(mailNo);
} }
public MailDetailIoSelectResponse findInfoByMailNoAction(String mailNo, String action) {
return baseMapper.findInfoByMailNoAction(mailNo, action);
}
} }
\ No newline at end of file
package org.ta.pddserver.service.impl;
import com.alibaba.fastjson.JSONObject;
import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
import jakarta.servlet.http.HttpServletRequest;
import org.springframework.stereotype.Service;
import org.ta.commoncore.model.User;
import org.ta.pddserver.entity.UserEntity;
import org.ta.pddserver.mapper.UserMapper;
import org.ta.pddserver.model.api.request.LogOrderListRequest;
import org.ta.pddserver.model.api.request.UserRequest;
import org.ta.pddserver.model.api.response.LogOrderListResponse;
import org.ta.pddserver.model.api.response.UserListResponse;
import org.ta.pddserver.service.UserService;
import org.ta.pddserver.utils.JsonResponse;
import org.ta.pddserver.utils.OnlineUserData;
import java.util.HashMap;
import java.util.List;
import java.util.Map;
@Service
public class UserImpl extends ServiceImpl<UserMapper, UserEntity> implements UserService {
public UserEntity getInfoByAccount(String account) {
return baseMapper.getInfoByAccount(account);
}
public Map<String, Object> getListByRequest(UserRequest param) {
Integer count = baseMapper.countUsable(param);
param.checkPage(count,20);
List<UserListResponse> list = baseMapper.getListByRequest(param);
Map<String, Object> map = new HashMap<>();
map.put("total", count);
map.put("list", list);
map.put("page", param.getPage());
return map;
}
public JSONObject checkUser(HttpServletRequest request) {
UserEntity userEntity=baseMapper.selectById(this.getUserIDFromOnlineData(request));
Map<String, Object> result = new HashMap<>();
result.put("user",userEntity);
return JsonResponse.generateLocalCommonSuccessResponse(result,"");
}
protected String getUserIDFromOnlineData(HttpServletRequest request) {
OnlineUserData onlineUserData = (OnlineUserData) request.getSession().getAttribute(OnlineUserData.ONLINE_CLIENT_DATA);
if (onlineUserData == null) {
return null;
}
return onlineUserData.getUserId();
}
}
\ No newline at end of file
package org.ta.pddserver.utils;
import java.io.Serializable;
public class OnlineUserData implements Serializable {
public static final String ONLINE_CLIENT_DATA = "REGISTER-COMPANY-DATA";
private String userId; // 操作用户父级id
private String account; // 操作用户父级id
private String name; // 操作用户父级id
public String getUserId() {
return userId;
}
public void setUserId(String userId) {
this.userId = userId;
}
public String getAccount() {
return account;
}
public void setAccount(String account) {
this.account = account;
}
public String getName() {
return name;
}
public void setName(String name) {
this.name = name;
}
}
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment