jiujian / client-customer-order-api

Go to a project
Toggle navigation Toggle navigation pinning
zhuyifan
b657f154 1 parent 744608a8

农信点餐小程序

Expand all
Inline Side-by-side
Showing 60 changed files with 1397 additions and 97 deletions
......@@ -48,6 +48,7 @@ dependencies {
implementation 'com.aliyun:aliyun-java-sdk-core:4.6.4' //阿里云SDK核心库
implementation 'com.aliyun:aliyun-java-sdk-dysmsapi:2.2.1'//阿里云短信服务SDK
implementation 'com.aliyun:aliyun-java-sdk-dm:3.3.2'//阿里云邮件服务SDK
implementation "com.aliyun.oss:aliyun-sdk-oss:3.11.1"//阿里云OSS服务
implementation "io.zipkin.brave:brave:5.12.5"
implementation "io.zipkin.brave:brave-context-slf4j:5.12.5"
......@@ -61,8 +62,8 @@ dependencies {
// compileOnly 'org.projectlombok:lombok'
// annotationProcessor 'org.projectlombok:lombok'
compileOnly 'org.projectlombok:lombok:1.18.20'
annotationProcessor 'org.projectlombok:lombok:1.18.20'
compileOnly 'org.projectlombok:lombok:1.18.24'
annotationProcessor 'org.projectlombok:lombok:1.18.24'
testImplementation 'org.springframework.boot:spring-boot-starter-test'
}
......@@ -113,5 +114,6 @@ sourceSets {
}
test {
enabled = false
useJUnitPlatform()
}
\ No newline at end of file
......
......@@ -58,7 +58,6 @@ public class RepeatSubmitAspect {
* 获取LockKey
*
* @param joinPoint 切入点
* @return
*/
public static String getLockKey(ProceedingJoinPoint joinPoint) {
//获取连接点的方法签名对象
......@@ -79,13 +78,13 @@ public class RepeatSubmitAspect {
continue;
}
//如果属性是RequestKeyParam注解，则拼接 连接符 "& + RequestKeyParam"
if (sb.length() > 0) {
if (!sb.isEmpty()) {
sb.append(requestLock.delimiter());
}
sb.append(args[i]);
}
//如果方法上没有加RequestKeyParam注解
if (StringUtils.isEmpty(sb.toString())) {
if (!StringUtils.hasText((sb.toString()))) {
//获取方法上的多个注解（为什么是两层数组：因为第二层数组是只有一个元素的数组）
final var parameterAnnotations = method.getParameterAnnotations();
//循环注解
......@@ -103,7 +102,7 @@ public class RepeatSubmitAspect {
//如果有，设置Accessible为true（为true时可以使用反射访问私有变量，否则不能访问私有变量）
field.setAccessible(true);
//如果属性是RequestKeyParam注解，则拼接 连接符" & + RequestKeyParam"
if (sb.length() > 0) {
if (!sb.isEmpty()) {
sb.append(requestLock.delimiter());
}
sb.append(ReflectionUtils.getField(field, object));
......@@ -112,9 +111,9 @@ public class RepeatSubmitAspect {
}
if (requestLock.isLockByLoginUser()) {
final var operatorId = LoginContextHolder.hasLogin() ? LoginContextHolder.getId() : null;
return requestLock.prefix() + (operatorId != null ? CommonConstants.COLON + operatorId : "") + (sb.length() > 0 ? CommonConstants.UNDERLINE + sb : "");
return requestLock.prefix() + (operatorId != null ? CommonConstants.COLON + operatorId : "") + (!sb.isEmpty() ? CommonConstants.UNDERLINE + sb : "");
} else {
return requestLock.prefix() + (sb.length() > 0 ? CommonConstants.UNDERLINE + sb : "");
return requestLock.prefix() + (!sb.isEmpty() ? CommonConstants.UNDERLINE + sb : "");
}
}
}
......
......@@ -3,16 +3,22 @@ package com.infoloop.tianting.config;
import com.aliyuncs.DefaultAcsClient;
import com.aliyuncs.profile.DefaultProfile;
import com.fasterxml.jackson.dataformat.xml.XmlMapper;
import com.infoloop.tianting.server.StorageService;
import com.infoloop.tianting.server.StorageServiceFactory;
import com.infoloop.tianting.store.LoginCodeStore;
import com.infoloop.tianting.store.WeeklyTaskStore;
import com.infoloop.tianting.utils.SmsUtil;
import io.lettuce.core.api.StatefulRedisConnection;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.beans.factory.annotation.Qualifier;
import org.springframework.boot.autoconfigure.condition.ConditionalOnProperty;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import org.springframework.context.annotation.Import;
import org.springframework.http.converter.xml.MappingJackson2XmlHttpMessageConverter;
import java.time.Duration;
import static com.infoloop.tianting.constant.ConfigConstants.REDIS_CONNECTION;
@Configuration
......@@ -26,6 +32,13 @@ public class AppConfig {
return new LoginCodeStore(commands, 300);
}
@Bean
public WeeklyTaskStore weeklyTaskStore(@Autowired @Qualifier(REDIS_CONNECTION) final StatefulRedisConnection<String, String> connection) {
final var commands = connection.sync();
final var expireSeconds = Duration.ofDays(7).getSeconds();
return new WeeklyTaskStore(commands, expireSeconds);
}
// init bean
@Bean
public SmsUtil smsUtil(@Autowired SmsConfig smsConfig) {
......@@ -35,6 +48,12 @@ public class AppConfig {
}
@Bean
@ConditionalOnProperty(name = "aliyun.oss.endpoint")
public StorageService storageService(@Autowired OssConfig ossConfig) {
return StorageServiceFactory.createStorageService(ossConfig.getEndpoint(), ossConfig.getAccessKeyId(), ossConfig.getAccessKeySecret());
}
@Bean
public MappingJackson2XmlHttpMessageConverter mappingJackson2XmlHttpMessageConverter() {
return new MappingJackson2XmlHttpMessageConverter(new XmlMapper());
}
......
......@@ -11,6 +11,7 @@ import com.infoloop.tianting.clientinventoryservice.TiantingClientInventoryServi
import com.infoloop.tianting.clientresourcetagservice.ClientResourceTagServiceRpcGrpc;
import com.infoloop.tianting.deliveryruleservice.TiantingDeliveryRuleServiceRpcGrpc;
import com.infoloop.tianting.enterpriseresourcetagservice.EnterpriseResourceTagServiceRpcGrpc;
import com.infoloop.tianting.mealorderservice.MealOrderServiceRpcGrpc;
import com.infoloop.tianting.menuservice.MenuServiceRpcGrpc;
import com.infoloop.tianting.setmealscheduleservice.SetMealScheduleServiceRpcGrpc;
import io.grpc.ClientInterceptor;
......@@ -86,6 +87,11 @@ public class GrpcConfig {
return ClientCustomerOrderServiceRpcGrpc.newBlockingStub(channel);
}
@Bean
public MealOrderServiceRpcGrpc.MealOrderServiceRpcBlockingStub mealOrderServiceRpcBlockingStub(@Autowired @Qualifier(ORDER_SERVICE_CHANNEL) final ManagedChannel channel) {
return MealOrderServiceRpcGrpc.newBlockingStub(channel);
}
@Bean(MENU_SERVICE_CHANNEL)
public ManagedChannel menuServiceChannel(@Value(MENU_SERVICE_RPC_URL) final String url,
@Value(MENU_SERVICE_RPC_PORT) final int port,
......
package com.infoloop.tianting.config;
import lombok.Data;
import org.springframework.boot.context.properties.ConfigurationProperties;
import org.springframework.context.annotation.PropertySource;
import org.springframework.stereotype.Component;
@Component
@ConfigurationProperties(prefix = "aliyun.oss")
@Data
@PropertySource(encoding = "UTF-8", value = "classpath:application.properties", ignoreResourceNotFound = true)
public class OssConfig {
private String accessKeyId;
private String accessKeySecret;
private String endpoint;
private String host;
private String bucket;
}
package com.infoloop.tianting.config;
import com.infoloop.tianting.intercepter.ResourceInjector;
import com.infoloop.tianting.service.client.ClientInventoryServiceRpcClient;
import com.infoloop.tianting.service.client.MealOrderServiceRpcClient;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
......@@ -8,9 +10,9 @@ import org.springframework.context.annotation.Configuration;
public class ResourceInjectorConfig {
@Bean
public ResourceInjector resourceInjector(
public ResourceInjector resourceInjector(final MealOrderServiceRpcClient mealOrderServiceRpcClient,
final ClientInventoryServiceRpcClient clientInventoryServiceRpcClient
) {
return new ResourceInjector();
return new ResourceInjector(mealOrderServiceRpcClient, clientInventoryServiceRpcClient);
}
}
......
......@@ -7,6 +7,8 @@ import com.infoloop.tianting.intercepter.LoginInterceptor;
import com.infoloop.tianting.intercepter.RequestMonitor;
import com.infoloop.tianting.intercepter.ResourceInjector;
import com.infoloop.tianting.service.client.ClientCustomerServiceRpcClient;
import com.infoloop.tianting.service.client.ClientInventoryServiceRpcClient;
import com.infoloop.tianting.service.client.MealOrderServiceRpcClient;
import com.infoloop.tianting.service.client.MeiZhongYiHeServiceClient;
import com.infoloop.tianting.service.client.OperatorServiceRpcClient;
import com.infoloop.tianting.service.client.WOperatorServiceRpcClient;
......@@ -38,12 +40,15 @@ public class WebMvcConfig implements WebMvcConfigurer {
final ClientCustomerServiceRpcClient clientCustomerServiceRpcClient,
final OperatorServiceRpcClient operatorServiceRpcClient,
final WOperatorServiceRpcClient wOperatorServiceRpcClient,
final MeiZhongYiHeServiceClient meiZhongYiHeServiceClient) {
final MeiZhongYiHeServiceClient meiZhongYiHeServiceClient,
final MealOrderServiceRpcClient mealOrderServiceRpcClient,
final ClientInventoryServiceRpcClient clientInventoryServiceRpcClient) {
this.httpInterceptors = new ArrayList<>();
this.httpInterceptors.add(new HttpTracingInterceptor(tracing));
this.httpInterceptors.add(new RequestMonitor());
this.httpInterceptors.add(new ApiSignInterceptor());
this.httpInterceptors.add(new LoginInterceptor(clientCustomerServiceRpcClient, meiZhongYiHeServiceClient, operatorServiceRpcClient, wOperatorServiceRpcClient));
this.httpInterceptors.add(new ResourceInjector(mealOrderServiceRpcClient, clientInventoryServiceRpcClient));
this.httpInterceptors.add(resourceInjector);
}
......
......@@ -24,10 +24,6 @@ public interface ConfigConstants {
String ENTERPRISE_REDIS_PASSWORD = "${enterprise.redis.password}";
String ENTERPRISE_REDIS_DATABASE = "${enterprise.redis.database}";
String EXAMPLE_SERVICE_RPC_URL = "${grpc.example-service.url}";
String EXAMPLE_SERVICE_RPC_PORT = "${grpc.example-service.port}";
String EXAMPLE_SERVICE_CHANNEL = "example-service-channel";
String ORDER_SERVICE_RPC_URL = "${grpc.order-service.url}";
String ORDER_SERVICE_RPC_PORT = "${grpc.order-service.port}";
String ORDER_SERVICE_CHANNEL = "order-service-channel";
......
......@@ -2,9 +2,21 @@ package com.infoloop.tianting.constant;
public interface PathVariableResourceConstants {
String INJECTED_TEST_EXAMPLE_DB = "testExampleDb";
String TEST_EXAMPLE_DB_ID_PATH_VARIABLE = "testExampleDbId";
String INJECTED_MP_ACCOUNT = "mpAccount";
String MP_ACCOUNT_ID_PATH_VARIABLE = "mpAccountId";
String INJECTED_CLIENT = "client";
String CLIENT_ID_PATH_VARIABLE = "clientId";
String INJECTED_DINER = "diner";
String DINER_ID_PATH_VARIABLE = "dinerId";
String INJECTED_GRADE_CLASS = "gradeClass";
String GRADE_CLASS_ID_PATH_VARIABLE = "gradeClassId";
String INJECTED_MEAL_ORDER = "mealOrder";
String MEAL_ORDER_ID_PATH_VARIABLE = "mealOrderId";
}
......
......@@ -16,7 +16,7 @@ import org.springframework.web.bind.annotation.RestController;
import java.util.List;
@Api(tags = "Category")
@Api(tags = "品类")
@ApiSupport(order = -1)
@Slf4j
@Validated
......
......@@ -2,10 +2,10 @@ package com.infoloop.tianting.controller;
import cn.dev33.satoken.annotation.SaIgnore;
import com.github.xiaoymin.knife4j.annotations.ApiSupport;
import com.infoloop.tianting.model.dto.InventoryDbDTO.ClientDto;
import com.infoloop.tianting.model.dto.InventoryDbDTO.ClientTableCodeDto;
import com.infoloop.tianting.model.dto.InventoryDbDTO.TableCodeQueryConditionDto;
import com.infoloop.tianting.service.InventoryService;
import com.infoloop.tianting.model.dto.ClientInventoryDbDTO.ClientDto;
import com.infoloop.tianting.model.dto.ClientInventoryDbDTO.ClientTableCodeDto;
import com.infoloop.tianting.model.dto.ClientInventoryDbDTO.TableCodeQueryConditionDto;
import com.infoloop.tianting.service.ClientInventoryService;
import io.swagger.annotations.Api;
import io.swagger.annotations.ApiOperation;
import lombok.RequiredArgsConstructor;
......@@ -17,40 +17,48 @@ import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.PathVariable;
import org.springframework.web.bind.annotation.PostMapping;
import org.springframework.web.bind.annotation.RequestBody;
import org.springframework.web.bind.annotation.RequestParam;
import org.springframework.web.bind.annotation.ResponseStatus;
import org.springframework.web.bind.annotation.RestController;
import javax.validation.Valid;
import java.util.List;
@Api(tags = "院区")
@Api(tags = "项目点")
@ApiSupport(order = -1)
@Slf4j
@Validated
@RestController
@RequiredArgsConstructor(onConstructor = @__(@Autowired))
public class InventoryController {
private final InventoryService inventoryService;
public class ClientController {
private final ClientInventoryService clientInventoryService;
@SaIgnore
@ApiOperation(value = "根据Id获取Client")
@GetMapping("/enterprises/{enterpriseId}/clients/{clientId}")
@ResponseStatus(HttpStatus.OK)
public ClientDto getClientById(@PathVariable Integer enterpriseId, @PathVariable Integer clientId) {
return inventoryService.getClientById(enterpriseId, clientId);
return clientInventoryService.getClientById(enterpriseId, clientId);
}
@ApiOperation(value = "根据Codes获取Clients")
@GetMapping("/clients/bycodes")
@ResponseStatus(HttpStatus.OK)
public List<ClientDto> getClientsByCodes(@RequestParam List<String> codes) {
return clientInventoryService.getClientsByCodes(codes);
}
@ApiOperation(value = "根据ClientId获取Stalls")
@GetMapping("/enterprises/{enterpriseId}/clients/{clientId}/stalls")
@ResponseStatus(HttpStatus.OK)
public List<ClientDto> getStallsByClientId(@PathVariable Integer enterpriseId, @PathVariable Integer clientId) {
return inventoryService.getStallsByClientId(enterpriseId, clientId);
return clientInventoryService.getStallsByClientId(enterpriseId, clientId);
}
@ApiOperation(value = "获取桌号")
@PostMapping("/tableCodes")
@ResponseStatus(HttpStatus.OK)
public List<ClientTableCodeDto> getTableCodes(@Valid @RequestBody TableCodeQueryConditionDto tableCodeQueryConditionDto) {
return inventoryService.queryClientTableCodesByCondition(tableCodeQueryConditionDto);
return clientInventoryService.queryClientTableCodesByCondition(tableCodeQueryConditionDto);
}
}
......
......@@ -22,7 +22,7 @@ import org.springframework.web.bind.annotation.RestController;
import java.io.IOException;
import java.util.List;
@Api(tags = "客户")
@Api(tags = "项目点客户")
@ApiSupport(order = -1)
@Slf4j
@Validated
......
package com.infoloop.tianting.controller;
import com.github.xiaoymin.knife4j.annotations.ApiSupport;
import com.infoloop.tianting.clientinventoryservice.SingleClientRpcResponse;
import com.infoloop.tianting.mealorderservice.SingleDinerRpcResponse;
import com.infoloop.tianting.mealorderservice.SingleGradeClassRpcResponse;
import com.infoloop.tianting.model.common.CreatedResult;
import com.infoloop.tianting.model.dto.DinerDTO;
import com.infoloop.tianting.model.vo.DinerVO;
import com.infoloop.tianting.model.vo.GradeClassVO;
import com.infoloop.tianting.service.DinerService;
import io.swagger.annotations.Api;
import io.swagger.annotations.ApiOperation;
import lombok.RequiredArgsConstructor;
import lombok.extern.slf4j.Slf4j;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.http.HttpStatus;
import org.springframework.validation.annotation.Validated;
import org.springframework.web.bind.annotation.DeleteMapping;
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.PatchMapping;
import org.springframework.web.bind.annotation.PutMapping;
import org.springframework.web.bind.annotation.RequestAttribute;
import org.springframework.web.bind.annotation.RequestBody;
import org.springframework.web.bind.annotation.ResponseStatus;
import org.springframework.web.bind.annotation.RestController;
import javax.validation.Valid;
import java.util.List;
import static com.infoloop.tianting.constant.PathVariableResourceConstants.INJECTED_CLIENT;
import static com.infoloop.tianting.constant.PathVariableResourceConstants.INJECTED_DINER;
import static com.infoloop.tianting.constant.PathVariableResourceConstants.INJECTED_GRADE_CLASS;
@Api(tags = "就餐人")
@ApiSupport(order = -1)
@Slf4j
@Validated
@RestController
@RequiredArgsConstructor(onConstructor = @__(@Autowired))
public class DinerController {
private final DinerService dinerService;
@ApiOperation(value = "用户就餐人列表")
@GetMapping("/mpaccount/diners")
@ResponseStatus(HttpStatus.OK)
public List<DinerVO> getMpAccountDiners() {
return dinerService.getMpAccountDiners();
}
@ApiOperation(value = "添加就餐人")
@PutMapping("/mpaccount/diner")
@ResponseStatus(HttpStatus.CREATED)
public CreatedResult<DinerVO> createMpAccountDiner(@RequestBody @Valid final DinerDTO.CreateDinerDTO createDinerDTO) {
return dinerService.createMpAccountDiner(createDinerDTO);
}
@ApiOperation(value = "学校年级班级列表")
@GetMapping("/client/{clientId}/gradeclasses")
@ResponseStatus(HttpStatus.OK)
public List<GradeClassVO> getClientGradeClasses(@RequestAttribute(INJECTED_CLIENT) final SingleClientRpcResponse client) {
return dinerService.getClientGradeClasses(client);
}
@ApiOperation(value = "根据学校，班级和学号查询就餐人")
@GetMapping("/client/{clientId}/gradeclass/{gradeClassId}/diner")
@ResponseStatus(HttpStatus.OK)
public DinerVO getClientClassDiner(@RequestAttribute(INJECTED_CLIENT) final SingleClientRpcResponse client,
@RequestAttribute(INJECTED_GRADE_CLASS) final SingleGradeClassRpcResponse gradeClass,
@RequestBody @Valid final DinerDTO.QueryUniqueDinerDTO queryUniqueDinerDTO) {
return dinerService.getClientClassDiner(client, gradeClass, queryUniqueDinerDTO.getStudentNo());
}
@ApiOperation(value = "修改就餐人")
@PatchMapping("/mpaccount/diner/{dinerId}")
@ResponseStatus(HttpStatus.NO_CONTENT)
public void updateMpAccountDiner(@RequestAttribute(INJECTED_DINER) final SingleDinerRpcResponse diner,
@RequestBody @Valid final DinerDTO.UpdateDinerDTO updateDinerDTO) {
dinerService.updateMpAccountDiner(diner, updateDinerDTO);
}
@ApiOperation(value = "删除就餐人")
@DeleteMapping("/mpaccount/diner/{dinerId}")
@ResponseStatus(HttpStatus.NO_CONTENT)
public void deleteMpAccountDiner(@RequestAttribute(INJECTED_DINER) final SingleDinerRpcResponse diner) {
dinerService.deleteMpAccountDiner(diner);
}
}
......@@ -3,7 +3,10 @@ package com.infoloop.tianting.controller;
import cn.dev33.satoken.annotation.SaIgnore;
import cn.dev33.satoken.stp.SaTokenInfo;
import com.github.xiaoymin.knife4j.annotations.ApiSupport;
import com.infoloop.tianting.mealorderservice.SingleMpAccountRpcResponse;
import com.infoloop.tianting.model.dto.MpAccountDTO;
import com.infoloop.tianting.model.dto.PermissionDTO;
import com.infoloop.tianting.model.vo.MpAccountVO;
import com.infoloop.tianting.service.LoginService;
import io.swagger.annotations.Api;
import io.swagger.annotations.ApiOperation;
......@@ -12,7 +15,11 @@ import lombok.extern.slf4j.Slf4j;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.http.HttpStatus;
import org.springframework.validation.annotation.Validated;
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.PatchMapping;
import org.springframework.web.bind.annotation.PathVariable;
import org.springframework.web.bind.annotation.PostMapping;
import org.springframework.web.bind.annotation.RequestAttribute;
import org.springframework.web.bind.annotation.RequestBody;
import org.springframework.web.bind.annotation.ResponseStatus;
import org.springframework.web.bind.annotation.RestController;
......@@ -20,6 +27,8 @@ import org.springframework.web.bind.annotation.RestController;
import javax.validation.Valid;
import java.security.NoSuchAlgorithmException;
import static com.infoloop.tianting.constant.PathVariableResourceConstants.INJECTED_MP_ACCOUNT;
@Api(tags = "登陆")
@ApiSupport(order = -1)
@Slf4j
......@@ -36,4 +45,20 @@ public class LoginController {
public SaTokenInfo login(@Valid @RequestBody PermissionDTO.LoginDto loginDto) throws NoSuchAlgorithmException {
return loginService.login(loginDto);
}
@SaIgnore
@ApiOperation(value = "根据openId获取小程序用户")
@GetMapping("/mpaccount/{openId}")
@ResponseStatus(HttpStatus.OK)
public MpAccountVO getMpAccountByOpenId(@PathVariable("openId") String openId) {
return loginService.getMpAccountByOpenId(openId);
}
@ApiOperation(value = "修改小程序用户")
@PatchMapping("/mpaccount/{mpAccountId}")
@ResponseStatus(HttpStatus.NO_CONTENT)
public void updateMpAccount(@RequestAttribute(INJECTED_MP_ACCOUNT) final SingleMpAccountRpcResponse mpAccount,
@RequestBody @Valid MpAccountDTO.ModifyMpAccountDTO modifyMpAccountDTO) {
loginService.updateMpAccount(mpAccount, modifyMpAccountDTO);
}
}
......
package com.infoloop.tianting.controller;
import com.github.xiaoymin.knife4j.annotations.ApiSupport;
import com.infoloop.tianting.annotation.RepeatSubmit;
import com.infoloop.tianting.mealorderservice.SingleMealOrderRpcResponse;
import com.infoloop.tianting.model.common.CreatedResult;
import com.infoloop.tianting.model.dto.MealOrderDTO;
import com.infoloop.tianting.model.vo.DeliveryRuleVO;
import com.infoloop.tianting.model.vo.MealOrderVO;
import com.infoloop.tianting.service.MealOrderService;
import io.swagger.annotations.Api;
import io.swagger.annotations.ApiOperation;
import lombok.RequiredArgsConstructor;
import lombok.extern.slf4j.Slf4j;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.http.HttpStatus;
import org.springframework.validation.annotation.Validated;
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.PostMapping;
import org.springframework.web.bind.annotation.PutMapping;
import org.springframework.web.bind.annotation.RequestAttribute;
import org.springframework.web.bind.annotation.RequestBody;
import org.springframework.web.bind.annotation.ResponseStatus;
import org.springframework.web.bind.annotation.RestController;
import javax.validation.Valid;
import java.util.List;
import static com.infoloop.tianting.constant.PathVariableResourceConstants.INJECTED_MEAL_ORDER;
@Api(tags = "订餐")
@ApiSupport(order = -1)
@Slf4j
@Validated
@RestController
@RequiredArgsConstructor(onConstructor = @__(@Autowired))
public class MealOrderController {
private final MealOrderService mealOrderService;
@ApiOperation(value = "订餐记录")
@PostMapping("/mealorders")
@ResponseStatus(HttpStatus.OK)
public List<MealOrderVO> queryMealOrders(@RequestBody @Valid final MealOrderDTO.QueryMealOrderDTO queryMealOrderDTO) {
return mealOrderService.queryMealOrders(queryMealOrderDTO);
}
@ApiOperation(value = "立即订餐")
@PutMapping("/mealorder")
@RepeatSubmit(prefix = "create.meal.order", isLockByLoginUser = false)
@ResponseStatus(HttpStatus.CREATED)
public CreatedResult<MealOrderVO> createMealOrder(@RequestBody @Valid final MealOrderDTO.CreateMealOrderDTO createMealOrderDTO) {
return mealOrderService.createMealOrder(createMealOrderDTO);
}
@ApiOperation(value = "订餐记录详情")
@GetMapping("/mealorder/{mealOrderId}")
@ResponseStatus(HttpStatus.OK)
public MealOrderVO getMealOrderById(@RequestAttribute(INJECTED_MEAL_ORDER) final SingleMealOrderRpcResponse mealOrder) {
return mealOrderService.getMealOrderById(mealOrder);
}
@ApiOperation(value = "订餐规则")
@GetMapping("/deliveryrule")
@ResponseStatus(HttpStatus.OK)
public DeliveryRuleVO getDeliveryRule() {
return mealOrderService.getDeliveryRule();
}
}
package com.infoloop.tianting.controller;
import com.github.xiaoymin.knife4j.annotations.ApiSupport;
import com.infoloop.tianting.clientinventoryservice.SingleClientRpcResponse;
import com.infoloop.tianting.model.dto.MenuDbDTO;
import com.infoloop.tianting.model.dto.MenuDbDTO.BatchCreateMenuRefsDto;
import com.infoloop.tianting.model.dto.MenuDbDTO.BatchCreateMenuRefsResponseDto;
......@@ -18,6 +19,7 @@ import org.springframework.validation.annotation.Validated;
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.PathVariable;
import org.springframework.web.bind.annotation.PostMapping;
import org.springframework.web.bind.annotation.RequestAttribute;
import org.springframework.web.bind.annotation.RequestBody;
import org.springframework.web.bind.annotation.ResponseStatus;
import org.springframework.web.bind.annotation.RestController;
......@@ -25,6 +27,8 @@ import org.springframework.web.bind.annotation.RestController;
import javax.validation.Valid;
import java.util.List;
import static com.infoloop.tianting.constant.PathVariableResourceConstants.INJECTED_CLIENT;
@Api(tags = "餐单")
@ApiSupport(order = -1)
@Slf4j
......@@ -76,4 +80,11 @@ public class MenuController {
return menuService.batchCreateMenuRefs(batchCreateMenuRefsDto);
}
@ApiOperation(value = "查询学校最新餐单")
@GetMapping("/client/{clientId}/mealmenurecord")
@ResponseStatus(HttpStatus.OK)
public String queryClientLatestMealMenuRecord(@RequestAttribute(INJECTED_CLIENT) final SingleClientRpcResponse client) {
return menuService.queryClientLatestMealMenuRecord(client);
}
}
......
......@@ -27,6 +27,7 @@ public class MiniProgramController {
private final WxMiniProgramService wxMiniProgramService;
@SaIgnore
@ApiOperation(value = "小程序：根据code获取openId")
@GetMapping("/wx/miniprogram/customers/openid/{code}")
@ResponseStatus(HttpStatus.OK)
......
package com.infoloop.tianting.controller;
import cn.dev33.satoken.annotation.SaIgnore;
import cn.hutool.core.io.IoUtil;
import cn.hutool.core.io.file.FileNameUtil;
import cn.hutool.core.util.IdUtil;
import com.github.xiaoymin.knife4j.annotations.ApiSupport;
import com.infoloop.tianting.config.OssConfig;
import com.infoloop.tianting.server.StorageService;
import io.swagger.annotations.Api;
import io.swagger.annotations.ApiOperation;
import lombok.extern.slf4j.Slf4j;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.http.HttpStatus;
import org.springframework.http.MediaType;
import org.springframework.util.Assert;
import org.springframework.validation.annotation.Validated;
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.PostMapping;
import org.springframework.web.bind.annotation.RequestParam;
import org.springframework.web.bind.annotation.ResponseStatus;
import org.springframework.web.bind.annotation.RestController;
import org.springframework.web.multipart.MultipartFile;
import javax.annotation.Nullable;
import javax.servlet.ServletOutputStream;
import javax.servlet.http.HttpServletResponse;
import java.io.File;
import java.io.InputStream;
import java.net.URLEncoder;
import java.nio.charset.StandardCharsets;
import java.time.LocalDateTime;
import java.time.format.DateTimeFormatter;
@Api(tags = "上传、下载管理")
@ApiSupport(order = 99)
@Slf4j
@Validated
@RestController
public class UploadController {
private final OssConfig ossConfig;
private final StorageService storageService;
@Autowired(required = false)
public UploadController(OssConfig ossConfig, @Nullable StorageService storageService) {
this.ossConfig = ossConfig;
this.storageService = storageService;
}
@SaIgnore
@ApiOperation("上传")
@PostMapping(value = "/upload", consumes = MediaType.MULTIPART_FORM_DATA_VALUE, produces = MediaType.APPLICATION_JSON_VALUE)
@ResponseStatus(HttpStatus.OK)
public String upload(@RequestParam("file") MultipartFile file,
@RequestParam(value = "folder", defaultValue = "upload") String folder) throws Exception {
Assert.notNull(storageService, "存储服务未初始化，请检查配置 aliyun.oss.endpoint");
String extension = FileNameUtil.getSuffix(file.getOriginalFilename());
String path = generateUploadPath(folder, extension);
File tempFile = File.createTempFile(IdUtil.fastSimpleUUID(), null);
try {
file.transferTo(tempFile);
storageService.putObject(ossConfig.getBucket(), path, tempFile);
} catch (Exception e) {
log.error("上传失败: {}", file.getOriginalFilename(), e);
throw new RuntimeException("文件上传失败，请稍后重试");
} finally {
tempFile.delete();
}
return String.format("%s/%s", ossConfig.getHost(), path);
}
@SaIgnore
@ApiOperation("下载")
@GetMapping(value = "/download", produces = MediaType.APPLICATION_OCTET_STREAM_VALUE)
@ResponseStatus(HttpStatus.OK)
public void download(@RequestParam("path") String path, HttpServletResponse response) {
Assert.notNull(storageService, "存储服务未初始化，请检查配置 aliyun.oss.endpoint");
try (InputStream inputStream = storageService.getObjectInputStream(ossConfig.getBucket(), path);
ServletOutputStream outputStream = response.getOutputStream()) {
String fileName = path.substring(path.lastIndexOf("/") + 1);
response.setContentType(MediaType.APPLICATION_OCTET_STREAM_VALUE);
response.setHeader("Content-Disposition", "attachment; filename=\"" + URLEncoder.encode(fileName, StandardCharsets.UTF_8) + "\"");
IoUtil.copy(inputStream, outputStream);
} catch (Exception e) {
log.error("下载失败: {}", path, e);
throw new RuntimeException("文件下载失败，请稍后重试");
}
}
private String generateUploadPath(String folder, String extension) {
String datePath = LocalDateTime.now().format(DateTimeFormatter.ofPattern("yyyy-MM-dd"));
return String.format("nutri-api/%s/%s/%s.%s", folder, datePath, IdUtil.fastSimpleUUID(), extension);
}
}
package com.infoloop.tianting.enums;
import lombok.AllArgsConstructor;
import lombok.Getter;
@Getter
@AllArgsConstructor
public enum QueryMealOrderStatusEnum {
BE_BOOKED,UNDER_WAY,COMPLETED
}
......@@ -42,7 +42,26 @@ public enum ErrorCodeEnum implements BaseEnum {
ORDER_NOT_ONLINE_PAY(406000012, "该订单不是在线支付"),
ORDER_NOT_SUCCESS(406000013, "该订单未支付成功")
ORDER_NOT_SUCCESS(406000013, "该订单未支付成功"),
CLIENT_CODE_NOT_EXISTS(406000014, "学校编码不正确"),
DINER_ALREADY_EXISTS(406000015, "该就餐人已存在"),
DINER_ALREADY_RESERVED(406000016, "该就餐人已订餐"),
DINER_NOT_FOUND(406000017, "该就餐人不存在"),
MEAL_MENU_NOT_FOUND(406000018, "预定餐单不存在"),
CLIENT_NOT_FOUND(406000019, "学校不存在"),
CLIENT_NOT_ENABLED(406000020, "学校未启用"),
GRADE_CLASS_NOT_FOUND(406000021, "班级不存在"),
MEAL_ORDER_TIME_NOT_IN_RANGE(406000022, "当前时间不在选餐时间内")
;
private final int code;
......
......@@ -70,6 +70,7 @@ public class LoginInterceptor implements HandlerInterceptor {
StpUtil.checkLogin();
final var enterpriseId = Convert.toInt(StpUtil.getExtra(CommonConstants.ENTERPRISE_ID));
final var loginSource = Convert.toInt(StpUtil.getExtra(CommonConstants.LOGIN_SOURCE));
final var userId = StpUtil.getExtra(CommonConstants.USER_ID);
if (loginSource.equals(LoginSourceEnum.CUSTOMER.getValue())) {
final var openId = Convert.toStr(StpUtil.getExtra(CommonConstants.OPEN_ID));
final var loginId = StpUtil.getLoginIdAsInt();
......@@ -115,8 +116,7 @@ public class LoginInterceptor implements HandlerInterceptor {
builder.id(loginId).enterpriseId(enterpriseId).name(operator.getName()).loginSource(LoginSourceEnum.KDS);
return true;
} else {
final var loginId = StpUtil.getLoginIdAsString();
builder.openId(loginId).enterpriseId(enterpriseId).loginSource(LoginSourceEnum.MINI_PROGRAM);
builder.id(userId == null ? null : Convert.toInt(userId)).openId(StpUtil.getLoginIdAsString()).enterpriseId(enterpriseId).loginSource(LoginSourceEnum.MINI_PROGRAM);
return true;
}
}
......
......@@ -2,6 +2,12 @@ package com.infoloop.tianting.intercepter;
import cn.dev33.satoken.annotation.SaIgnore;
import cn.dev33.satoken.strategy.SaStrategy;
import cn.hutool.core.convert.Convert;
import com.infoloop.tianting.constant.PathVariableResourceConstants;
import com.infoloop.tianting.context.LoginContextHolder;
import com.infoloop.tianting.exception.ClientEndExceptions;
import com.infoloop.tianting.service.client.ClientInventoryServiceRpcClient;
import com.infoloop.tianting.service.client.MealOrderServiceRpcClient;
import lombok.RequiredArgsConstructor;
import lombok.extern.slf4j.Slf4j;
import org.springframework.beans.factory.annotation.Autowired;
......@@ -18,6 +24,10 @@ import java.util.Map;
@RequiredArgsConstructor(onConstructor = @__(@Autowired))
public class ResourceInjector implements HandlerInterceptor {
private final MealOrderServiceRpcClient mealOrderServiceRpcClient;
private final ClientInventoryServiceRpcClient clientInventoryServiceRpcClient;
@Override
@SuppressWarnings("unchecked")
public boolean preHandle(@NonNull final HttpServletRequest httpServletRequest, @NonNull final HttpServletResponse httpServletResponse, @NonNull final Object handler) {
......@@ -33,6 +43,91 @@ public class ResourceInjector implements HandlerInterceptor {
if (pathVariables == null) {
return true;
}
/*
注入MpAccount
*/
if (pathVariables.containsKey(PathVariableResourceConstants.MP_ACCOUNT_ID_PATH_VARIABLE)) {
final var idStr = pathVariables.get(PathVariableResourceConstants.MP_ACCOUNT_ID_PATH_VARIABLE);
final var id = Convert.toInt(idStr, 0);
if (id <= 0) {
throw ClientEndExceptions.ResourceNotFound.build("小程序用户不存在");
}
final var response = mealOrderServiceRpcClient.getMpAccountById(LoginContextHolder.getEnterpriseId(), id);
if (response == null) {
log.info("Resource not found; id:{}", id);
throw ClientEndExceptions.ResourceNotFound.build("小程序用户不存在");
}
httpServletRequest.setAttribute(PathVariableResourceConstants.INJECTED_MP_ACCOUNT, response);
}
/*
注入Client
*/
if (pathVariables.containsKey(PathVariableResourceConstants.CLIENT_ID_PATH_VARIABLE)) {
final var idStr = pathVariables.get(PathVariableResourceConstants.CLIENT_ID_PATH_VARIABLE);
final var id = Convert.toInt(idStr, 0);
if (id <= 0) {
throw ClientEndExceptions.ResourceNotFound.build("项目点不存在");
}
final var response = clientInventoryServiceRpcClient.getClientById(LoginContextHolder.getEnterpriseId(), id);
if (response == null) {
log.info("Resource not found; id:{}", id);
throw ClientEndExceptions.ResourceNotFound.build("项目点不存在");
}
httpServletRequest.setAttribute(PathVariableResourceConstants.INJECTED_CLIENT, response.getClient());
}
/*
注入Diner
*/
if (pathVariables.containsKey(PathVariableResourceConstants.DINER_ID_PATH_VARIABLE)) {
final var idStr = pathVariables.get(PathVariableResourceConstants.DINER_ID_PATH_VARIABLE);
final var id = Convert.toInt(idStr, 0);
if (id <= 0) {
throw ClientEndExceptions.ResourceNotFound.build("就餐人不存在");
}
final var response = mealOrderServiceRpcClient.getDinerById(LoginContextHolder.getEnterpriseId(), id);
if (response == null) {
log.info("Resource not found; id:{}", id);
throw ClientEndExceptions.ResourceNotFound.build("就餐人不存在");
}
httpServletRequest.setAttribute(PathVariableResourceConstants.INJECTED_DINER, response);
}
/*
注入GradeClass
*/
if (pathVariables.containsKey(PathVariableResourceConstants.GRADE_CLASS_ID_PATH_VARIABLE)) {
final var idStr = pathVariables.get(PathVariableResourceConstants.GRADE_CLASS_ID_PATH_VARIABLE);
final var id = Convert.toInt(idStr, 0);
if (id <= 0) {
throw ClientEndExceptions.ResourceNotFound.build("年级班级不存在");
}
final var response = mealOrderServiceRpcClient.getGradeClassById(LoginContextHolder.getEnterpriseId(), id);
if (response == null) {
log.info("Resource not found; id:{}", id);
throw ClientEndExceptions.ResourceNotFound.build("年级班级不存在");
}
httpServletRequest.setAttribute(PathVariableResourceConstants.INJECTED_GRADE_CLASS, response);
}
/*
注入MealOrder
*/
if (pathVariables.containsKey(PathVariableResourceConstants.MEAL_ORDER_ID_PATH_VARIABLE)) {
final var idStr = pathVariables.get(PathVariableResourceConstants.MEAL_ORDER_ID_PATH_VARIABLE);
final var id = Convert.toInt(idStr, 0);
if (id <= 0) {
throw ClientEndExceptions.ResourceNotFound.build("订餐记录不存在");
}
final var response = mealOrderServiceRpcClient.getMealOrderById(LoginContextHolder.getEnterpriseId(), id);
if (response == null) {
log.info("Resource not found; id:{}", id);
throw ClientEndExceptions.ResourceNotFound.build("订餐记录不存在");
}
httpServletRequest.setAttribute(PathVariableResourceConstants.INJECTED_MEAL_ORDER, response);
}
return true;
}
}
......
......@@ -21,8 +21,8 @@ import com.infoloop.tianting.server.message.data.CustomerAlterRoomNoData;
import com.infoloop.tianting.server.session.UserSessionKey;
import com.infoloop.tianting.server.session.UserTypeEnum;
import com.infoloop.tianting.service.client.ClientCustomerServiceRpcClient;
import com.infoloop.tianting.service.client.ClientInventoryServiceRpcClient;
import com.infoloop.tianting.service.client.ClientResourceTagServiceRpcClient;
import com.infoloop.tianting.service.client.InventoryServiceRpcClient;
import com.infoloop.tianting.service.client.MeiZhongYiHeServiceClient;
import com.infoloop.tianting.service.client.OperatorServiceRpcClient;
import com.infoloop.tianting.service.client.OrderServiceRpcClient;
......@@ -48,7 +48,7 @@ public class HisCustomerRoomNoTask {
private final ClientResourceTagServiceRpcClient clientResourceTagServiceRpcClient;
private final InventoryServiceRpcClient inventoryServiceRpcClient;
private final ClientInventoryServiceRpcClient clientInventoryServiceRpcClient;
private final MeiZhongYiHeServiceClient meiZhongYiHeServiceClient;
......@@ -62,7 +62,7 @@ public class HisCustomerRoomNoTask {
final var stallIdsList = clientResourceTagServiceRpcClient.getUserResources(cOperatorById.getEnterpriseId(), cOperatorById.getClientId(), cOperatorById.getId()).getStallIdsList();
final var stalls = inventoryServiceRpcClient.getStallsByIds(cOperatorById.getEnterpriseId(), stallIdsList).getClientsList();
final var stalls = clientInventoryServiceRpcClient.getStallsByIds(cOperatorById.getEnterpriseId(), stallIdsList).getClientsList();
final var queryOrderDto = OrderDbDTO.QueryOrderByConditionDto.builder()
.enterpriseId(loginInfo.getEnterpriseId())
......
package com.infoloop.tianting.logic.task;
import com.infoloop.tianting.clientinventoryservice.SingleClientRpcResponse;
import com.infoloop.tianting.context.LoginContextHolder;
import com.infoloop.tianting.enums.LoginSourceEnum;
import com.infoloop.tianting.mealorderservice.MealOrderCreation;
import com.infoloop.tianting.mealorderservice.MealOrderOrderMethodEnum;
import com.infoloop.tianting.mealorderservice.MenuSchedule;
import com.infoloop.tianting.mealorderservice.SingleDinerRpcResponse;
import com.infoloop.tianting.mealorderservice.SingleGradeClassRpcResponse;
import com.infoloop.tianting.mealorderservice.SingleMealMenuRecordRpcResponse;
import com.infoloop.tianting.mealorderservice.SingleMealOrderRpcResponse;
import com.infoloop.tianting.mealorderservice.SingleMpAccountDinerRefRpcResponse;
import com.infoloop.tianting.service.client.ClientInventoryServiceRpcClient;
import com.infoloop.tianting.service.client.DeliveryRuleServiceRpcClient;
import com.infoloop.tianting.service.client.MealOrderServiceRpcClient;
import com.infoloop.tianting.store.WeeklyTaskStore;
import com.infoloop.tianting.utils.DateUtil;
import lombok.RequiredArgsConstructor;
import lombok.extern.slf4j.Slf4j;
import org.springframework.scheduling.annotation.Scheduled;
import org.springframework.stereotype.Component;
import java.time.DayOfWeek;
import java.time.Instant;
import java.time.LocalDate;
import java.time.LocalDateTime;
import java.time.LocalTime;
import java.time.ZonedDateTime;
import java.time.temporal.TemporalAdjusters;
import java.util.ArrayList;
import java.util.Collections;
import java.util.List;
import java.util.Map;
import java.util.Objects;
import java.util.function.Function;
import java.util.stream.Collectors;
import java.util.stream.IntStream;
@Slf4j
@Component
@RequiredArgsConstructor
public class AutoCreateMealOrderTask {
private final MealOrderServiceRpcClient mealOrderServiceRpcClient;
private final ClientInventoryServiceRpcClient clientInventoryServiceRpcClient;
private final DeliveryRuleServiceRpcClient deliveryRuleServiceRpcClient;
private final WeeklyTaskStore weeklyTaskStore;
@Scheduled(cron = "0 * * ? * *")
public void executeTask() {
final int enterpriseId = 449;
final var now = LocalDateTime.now();
final var today = now.toLocalDate();
// 判断是否本周已执行
final var keyPrefix = "create-meal-order-task";
if (weeklyTaskStore.isExecutedThisWeek(keyPrefix, enterpriseId, today)) return;
final var rules = deliveryRuleServiceRpcClient.getDefaultDeliveryTemplateAndRule(enterpriseId).getRule();
if (rules.getConfigJson().getRulesList().isEmpty()) {
return;
}
final var rule = rules.getConfigJson().getRules(0);
final var endTime = LocalTime.parse(rule.getEndTime(), DateUtil.HH_MM_SS);
final var enabledDays = new ArrayList<DayOfWeek>();
if (Boolean.TRUE.equals(rule.getMonday())) enabledDays.add(DayOfWeek.MONDAY);
if (Boolean.TRUE.equals(rule.getTuesday())) enabledDays.add(DayOfWeek.TUESDAY);
if (Boolean.TRUE.equals(rule.getWednesday())) enabledDays.add(DayOfWeek.WEDNESDAY);
if (Boolean.TRUE.equals(rule.getThursday())) enabledDays.add(DayOfWeek.THURSDAY);
if (Boolean.TRUE.equals(rule.getFriday())) enabledDays.add(DayOfWeek.FRIDAY);
if (Boolean.TRUE.equals(rule.getSaturday())) enabledDays.add(DayOfWeek.SATURDAY);
if (Boolean.TRUE.equals(rule.getSunday())) enabledDays.add(DayOfWeek.SUNDAY);
if (enabledDays.isEmpty()) {
return;
}
final var maxDay = Collections.max(enabledDays);
final var endDateTime = getThisWeekDay(today, maxDay).atTime(endTime);
if (now.isBefore(endDateTime)) {
log.info("当前时间小于订餐结束时间:{}，跳过自动订餐任务", endDateTime);
return;
}
final var thisWeekStart = today.with(DayOfWeek.MONDAY).atStartOfDay().atZone(DateUtil.CHINA_ZONE);
final var thisWeekEnd = today.with(DayOfWeek.SUNDAY).atTime(LocalTime.MAX).atZone(DateUtil.CHINA_ZONE);
final var nextWeekStart = today.with(TemporalAdjusters.next(DayOfWeek.MONDAY)).atStartOfDay().atZone(DateUtil.CHINA_ZONE);
// 查询本周已订餐学生 ID
final var mealOrders = mealOrderServiceRpcClient.queryMealOrdersByCondition(enterpriseId, null, thisWeekStart.toInstant().toEpochMilli(), thisWeekEnd.toInstant().toEpochMilli());
final var dinerIds = mealOrders.stream().map(SingleMealOrderRpcResponse::getDinerId).collect(Collectors.toSet());
// 所有学生 & 未订餐学生
final var allDiners = mealOrderServiceRpcClient.queryDinersByCondition(enterpriseId, null, null, null);
final var notReservedDiners = allDiners.stream().filter(diner -> !dinerIds.contains(diner.getId())).toList();
if (notReservedDiners.isEmpty()) {
log.info("无未订餐学生，跳过自动订餐任务");
return;
}
final var mpAccountDinerRefMap = mealOrderServiceRpcClient.queryMpAccountDinerRefsByCondition(enterpriseId, Collections.emptyList(), notReservedDiners.stream().map(SingleDinerRpcResponse::getId).toList()).stream().collect(Collectors.toMap(SingleMpAccountDinerRefRpcResponse::getDinerId, Function.identity(), (v1, v2) -> v1));
// 所需关联数据查询
final var clientIds = notReservedDiners.stream().map(SingleDinerRpcResponse::getClientId).distinct().toList();
final var classIds = notReservedDiners.stream().map(SingleDinerRpcResponse::getClassId).distinct().toList();
final var clientMap = clientInventoryServiceRpcClient.getClientsByIds(enterpriseId, clientIds).getClientsList().stream().collect(Collectors.toMap(SingleClientRpcResponse::getId, Function.identity()));
final var gradeClassMap = mealOrderServiceRpcClient.getGradeClassesByIds(enterpriseId, classIds).stream().collect(Collectors.toMap(SingleGradeClassRpcResponse::getId, Function.identity()));
final var latestMealMenuRecordMap = mealOrderServiceRpcClient.queryLatestMealMenuRecordsByClientIds(enterpriseId, clientIds).stream().collect(Collectors.toMap(SingleMealMenuRecordRpcResponse::getClientId, Function.identity()));
// 构建创建请求
final var creations = notReservedDiners.stream().map(diner -> toMealOrderCreation(diner, clientMap, gradeClassMap, latestMealMenuRecordMap, mpAccountDinerRefMap, nextWeekStart)).filter(Objects::nonNull).toList();
if (creations.isEmpty()) {
log.info("无可创建自动订餐项，跳过任务");
return;
}
final var loginInfo = LoginContextHolder.LoginInfo.builder()
.id(0)
.enterpriseId(enterpriseId)
.loginSource(LoginSourceEnum.MINI_PROGRAM)
.build();
mealOrderServiceRpcClient.batchCreateMealOrders(loginInfo, creations);
log.info("本周未订餐学生已自动补单 {} 条", creations.size());
// 标记本周已执行
weeklyTaskStore.markExecuted(keyPrefix, enterpriseId, today);
}
private MealOrderCreation toMealOrderCreation(SingleDinerRpcResponse diner,
Map<Integer, SingleClientRpcResponse> clientMap,
Map<Integer, SingleGradeClassRpcResponse> classMap,
Map<Integer, SingleMealMenuRecordRpcResponse> menuMap,
Map<Integer, SingleMpAccountDinerRefRpcResponse> mpAccountDinerRefMap,
ZonedDateTime startOfNextWeek) {
final var menu = menuMap.get(diner.getClientId());
final var client = clientMap.get(diner.getClientId());
final var gradeClass = classMap.get(diner.getClassId());
final var mpAccountDinerRef = mpAccountDinerRefMap.get(diner.getId());
if (menu == null || client == null || gradeClass == null || mpAccountDinerRef == null) return null;
return MealOrderCreation.newBuilder()
.setClientId(diner.getClientId())
.setMenuId(menu.getId())
.setAccountId(mpAccountDinerRef.getId())
.setOrderMethod(MealOrderOrderMethodEnum.MEAL_ORDER_METHOD_SYSTEM)
.setDinerId(diner.getId())
.setDinerName(diner.getName())
.setClientName(client.getName())
.setGradeName(gradeClass.getGradeName())
.setClassName(gradeClass.getClassName())
.setStudentNo(diner.getStudentNo())
.setReserveDate(Instant.now().toEpochMilli())
.addAllMeals(buildNextWeekMeals(startOfNextWeek))
.build();
}
private LocalDate getThisWeekDay(LocalDate now, DayOfWeek target) {
LocalDate monday = now.with(DayOfWeek.MONDAY);
return monday.plusDays(target.getValue() - 1L);
}
private List<MenuSchedule> buildNextWeekMeals(ZonedDateTime nextWeekStart) {
return IntStream.range(0, 5)
.mapToObj(i -> MenuSchedule.newBuilder()
.setDate(nextWeekStart.plusDays(i).format(DateUtil.YYYY_MM_DD_LEFT_SYMBOL))
.setMenu("A")
.build())
.toList();
}
}
......@@ -10,7 +10,7 @@ import java.util.List;
@Data
@ApiModel(description = "院区DTO")
public class InventoryDbDTO {
public class ClientInventoryDbDTO {
@Data
@Builder
......@@ -30,7 +30,7 @@ public class InventoryDbDTO {
private Integer allowedPaid;
private Integer regionId;
private ClientType type;
CustomerSource customerSource;
private CustomerSource customerSource;
private boolean isDelivery;
}
......
package com.infoloop.tianting.model.dto;
import io.swagger.annotations.ApiModel;
import io.swagger.annotations.ApiModelProperty;
import lombok.Data;
import javax.validation.constraints.NotEmpty;
import javax.validation.constraints.NotNull;
@Data
@ApiModel(description = "就餐人DTO")
public class DinerDTO {
@Data
@ApiModel(description = "查询唯一就餐人")
public static class QueryUniqueDinerDTO {
@ApiModelProperty(value = "学号")
@NotEmpty(message = "学号不能为空")
private String studentNo;
}
@Data
@ApiModel(description = "添加就餐人")
public static class CreateDinerDTO {
@ApiModelProperty(value = "学校编码")
@NotEmpty(message = "学校编码不能为空")
private String clientCode;
@ApiModelProperty(value = "班级")
@NotNull(message = "班级不能为空")
private Integer classId;
@ApiModelProperty(value = "学号")
@NotEmpty(message = "学号不能为空")
private String studentNo;
@ApiModelProperty(value = "姓名")
@NotEmpty(message = "姓名不能为空")
private String name;
}
@Data
@ApiModel(description = "修改就餐人")
public static class UpdateDinerDTO {
@ApiModelProperty(value = "学校编码")
@NotEmpty(message = "学校编码不能为空")
private String clientCode;
@ApiModelProperty(value = "班级")
@NotNull(message = "班级不能为空")
private Integer classId;
@ApiModelProperty(value = "学号")
private String studentNo;
@ApiModelProperty(value = "姓名")
private String name;
}
}
......@@ -2,7 +2,7 @@ package com.infoloop.tianting.model.dto;
import com.infoloop.tianting.clientcustomerorderservice.OrderStatusEnum;
import com.infoloop.tianting.clientcustomerorderservice.ServeStatusEnum;
import com.infoloop.tianting.model.dto.InventoryDbDTO.ClientDto;
import com.infoloop.tianting.model.dto.ClientInventoryDbDTO.ClientDto;
import com.infoloop.tianting.model.dto.OrderDbDTO.CustomerDetailDto;
import com.infoloop.tianting.model.dto.OrderDbDTO.CustomerNotice;
import io.swagger.annotations.ApiModel;
......
package com.infoloop.tianting.model.dto;
import com.infoloop.tianting.annotation.RequestKeyParam;
import com.infoloop.tianting.enums.QueryMealOrderStatusEnum;
import io.swagger.annotations.ApiModel;
import lombok.Data;
import javax.validation.Valid;
import javax.validation.constraints.NotEmpty;
import javax.validation.constraints.NotNull;
import java.util.List;
@Data
@ApiModel(description = "订餐DTO")
public class MealOrderDTO {
@Data
@ApiModel(description = "查询订餐记录")
public static class QueryMealOrderDTO {
@NotNull(message = "status不能为空")
private QueryMealOrderStatusEnum status;
}
@Data
@ApiModel(description = "创建订餐记录")
public static class CreateMealOrderDTO {
@NotNull(message = "就餐人 ID 不能为空")
@RequestKeyParam
private Integer dinerId;
@NotEmpty(message = "订餐详情不能为空")
@NotNull(message = "订餐详情不能为空")
@Valid
private List<CreateMeals> meals;
}
@Data
@ApiModel(description = "创建订餐记录详情")
public static class CreateMeals {
@NotEmpty(message = "日期不能为空")
private String date;
@NotEmpty(message = "菜单不能为空")
private String menu;
}
}
package com.infoloop.tianting.model.dto;
import com.infoloop.tianting.mealorderservice.MpAccountGenderEnum;
import io.swagger.annotations.ApiModel;
import io.swagger.annotations.ApiModelProperty;
import lombok.Data;
@Data
@ApiModel(description = "小程序用户DTO")
public class MpAccountDTO {
@Data
@ApiModel(description = "修改小程序用户")
public static class ModifyMpAccountDTO {
@ApiModelProperty(value = "昵称")
private String nickName;
@ApiModelProperty(value = "头像")
private String avatarUrl;
@ApiModelProperty(value = "性别")
private MpAccountGenderEnum gender;
}
}
......@@ -27,6 +27,10 @@ public class PermissionDTO {
@Builder.Default
private String openCode = "";
@Builder.Default
private boolean shouldLoginWithOpenId = false;
@Builder.Default
private String openId = "";
@Builder.Default
private boolean shouldLoginWithKdsEmail = false;
@Builder.Default
private String email = "";
......
package com.infoloop.tianting.model.vo;
import io.swagger.annotations.ApiModel;
import io.swagger.annotations.ApiModelProperty;
import lombok.Builder;
import lombok.Data;
@Data
@ApiModel(value = "订餐规则")
@Builder
public class DeliveryRuleVO {
@ApiModelProperty(value = "订餐开始时间")
private String startTime;
@ApiModelProperty(value = "订餐结束时间")
private String endTime;
private Boolean monday;
private Boolean tuesday;
private Boolean wednesday;
private Boolean thursday;
private Boolean friday;
private Boolean saturday;
private Boolean sunday;
}
package com.infoloop.tianting.model.vo;
import io.swagger.annotations.ApiModel;
import io.swagger.annotations.ApiModelProperty;
import lombok.Builder;
import lombok.Data;
@Data
@ApiModel(value = "就餐人信息")
@Builder
public class DinerVO {
@ApiModelProperty(value = "就餐人 ID")
private int id;
@ApiModelProperty(value = "企业 ID")
private int enterpriseId;
@ApiModelProperty(value = "就餐人学校 ID")
private int clientId;
@ApiModelProperty(value = "就餐人学校代码")
private String clientCode;
@ApiModelProperty(value = "就餐人学校名称")
private String clientName;
@ApiModelProperty(value = "就餐人班级 ID")
private int classId;
@ApiModelProperty(value = "就餐人年级名称")
private String gradeName;
@ApiModelProperty(value = "就餐人班级名称")
private String className;
@ApiModelProperty(value = "就餐人学号")
private String studentNo;
@ApiModelProperty(value = "就餐人姓名")
private String name;
@ApiModelProperty(value = "是否已预定")
private boolean isReserve;
}
package com.infoloop.tianting.model.vo;
import io.swagger.annotations.ApiModel;
import io.swagger.annotations.ApiModelProperty;
import lombok.Builder;
import lombok.Data;
@Data
@ApiModel(value = "班级年级信息")
@Builder
public class GradeClassVO {
@ApiModelProperty("ID")
private Integer id;
@ApiModelProperty("企业 ID")
private Integer enterpriseId;
@ApiModelProperty("年级")
private String gradeName;
@ApiModelProperty("班级")
private String className;
}
package com.infoloop.tianting.model.vo;
import com.infoloop.tianting.mealorderservice.MealOrderOrderMethodEnum;
import io.swagger.annotations.ApiModel;
import io.swagger.annotations.ApiModelProperty;
import lombok.Builder;
import lombok.Data;
import java.util.List;
@Data
@Builder
@ApiModel(value = "订餐记录信息")
public class MealOrderVO {
@ApiModelProperty("ID")
private int id;
@ApiModelProperty("项目点ID")
private int clientId;
@ApiModelProperty("餐单ID")
private int menuId;
@ApiModelProperty("用户ID")
private int accountId;
@ApiModelProperty("订餐方式")
private MealOrderOrderMethodEnum orderMethod;
@ApiModelProperty("就餐人 id")
private int dinerId;
@ApiModelProperty("就餐人名称")
private String dinerName;
@ApiModelProperty("项目点名称")
private String clientName;
@ApiModelProperty("年级名称")
private String gradeName;
@ApiModelProperty("班级名称")
private String className;
@ApiModelProperty("学生学号")
private String studentNo;
@ApiModelProperty("订餐时间")
private String reserveDate;
@ApiModelProperty("订餐餐单")
private List<Meals> meals;
@Data
@Builder
@ApiModel(description = "订餐信息")
public static class Meals {
@ApiModelProperty("订餐日期")
private String date;
@ApiModelProperty("订餐餐单")
private String menu;
}
}
package com.infoloop.tianting.model.vo;
import com.infoloop.tianting.mealorderservice.MpAccountGenderEnum;
import io.swagger.annotations.ApiModel;
import io.swagger.annotations.ApiModelProperty;
import lombok.Builder;
import lombok.Data;
@Data
@ApiModel(value = "小程序账号信息")
@Builder
public class MpAccountVO {
@ApiModelProperty("ID")
private Integer id;
@ApiModelProperty("企业 ID")
private Integer enterpriseId;
@ApiModelProperty("openId")
private String openId;
@ApiModelProperty("unionId")
private String unionId;
@ApiModelProperty("昵称")
private String nickname;
@ApiModelProperty("头像地址")
private String avatarUrl;
@ApiModelProperty("性别")
private MpAccountGenderEnum gender;
@ApiModelProperty("手机号")
private String phoneNumber;
}
package com.infoloop.tianting.server;
import com.aliyun.oss.OSS;
import com.aliyun.oss.OSSClientBuilder;
import com.aliyun.oss.model.GetObjectRequest;
import java.io.ByteArrayInputStream;
import java.io.File;
import java.io.InputStream;
public class OssStorageService implements StorageService{
private final OSS ossClient;
public OssStorageService(String endpoint, String accessKeyId, String accessKeySecret) {
this.ossClient = new OSSClientBuilder().build(endpoint, accessKeyId, accessKeySecret);
}
@Override
public void putObject(String bucketName, String key, byte[] data) {
ossClient.putObject(bucketName, key, new ByteArrayInputStream(data));
}
@Override
public void putObject(String bucketName, String key, File file) {
ossClient.putObject(bucketName, key, file);
}
@Override
public void putObject(String bucketName, String key, InputStream stream) {
ossClient.putObject(bucketName, key, stream);
}
@Override
public InputStream getObjectInputStream(String bucketName, String key) {
return ossClient.getObject(new GetObjectRequest(bucketName, key)).getObjectContent();
}
@Override
public void close() throws Exception {
ossClient.shutdown();
}
}
package com.infoloop.tianting.server;
import java.io.File;
import java.io.InputStream;
public interface StorageService extends AutoCloseable {
void putObject(String bucketName, String key, byte[] data) throws Exception;
void putObject(String bucketName, String key, File file) throws Exception;
void putObject(String bucketName, String key, InputStream stream) throws Exception;
InputStream getObjectInputStream(String bucketName, String key);
}
\ No newline at end of file
package com.infoloop.tianting.server;
public class StorageServiceFactory {
public static StorageService createStorageService(String endpoint, String accessKey, String accessSecret) {
if (endpoint.contains("aliyuncs.com")) {
return new OssStorageService(endpoint, accessKey, accessSecret);
} else {
throw new IllegalArgumentException("Unsupported storage type: " + endpoint);
}
}
}
\ No newline at end of file
package com.infoloop.tianting.service;
import com.infoloop.tianting.model.dto.ClientInventoryDbDTO.ClientDto;
import com.infoloop.tianting.model.dto.ClientInventoryDbDTO.ClientTableCodeDto;
import com.infoloop.tianting.model.dto.ClientInventoryDbDTO.TableCodeQueryConditionDto;
import java.util.List;
public interface ClientInventoryService {
ClientDto getClientById(Integer enterpriseId, Integer clientId);
List<ClientDto> getStallsByClientId(Integer enterpriseId, Integer clientId);
List<ClientTableCodeDto> queryClientTableCodesByCondition(TableCodeQueryConditionDto tableCodeQueryConditionDto);
List<ClientDto> getClientsByCodes(List<String> codes);
}
package com.infoloop.tianting.service;
import com.infoloop.tianting.clientinventoryservice.SingleClientRpcResponse;
import com.infoloop.tianting.mealorderservice.SingleDinerRpcResponse;
import com.infoloop.tianting.mealorderservice.SingleGradeClassRpcResponse;
import com.infoloop.tianting.model.common.CreatedResult;
import com.infoloop.tianting.model.dto.DinerDTO;
import com.infoloop.tianting.model.vo.DinerVO;
import com.infoloop.tianting.model.vo.GradeClassVO;
import java.util.List;
public interface DinerService {
List<DinerVO> getMpAccountDiners();
CreatedResult<DinerVO> createMpAccountDiner(DinerDTO.CreateDinerDTO createDinerDTO);
List<GradeClassVO> getClientGradeClasses(SingleClientRpcResponse client);
void updateMpAccountDiner(SingleDinerRpcResponse diner, DinerDTO.UpdateDinerDTO updateDinerDTO);
void deleteMpAccountDiner(SingleDinerRpcResponse diner);
DinerVO getClientClassDiner(SingleClientRpcResponse client, SingleGradeClassRpcResponse gradeClass, String studentNo);
}
package com.infoloop.tianting.service;
import com.infoloop.tianting.model.dto.InventoryDbDTO.ClientDto;
import com.infoloop.tianting.model.dto.InventoryDbDTO.ClientTableCodeDto;
import com.infoloop.tianting.model.dto.InventoryDbDTO.TableCodeQueryConditionDto;
import java.util.List;
public interface InventoryService {
ClientDto getClientById(Integer enterpriseId, Integer clientId);
List<ClientDto> getStallsByClientId(Integer enterpriseId, Integer clientId);
List<ClientTableCodeDto> queryClientTableCodesByCondition(
TableCodeQueryConditionDto tableCodeQueryConditionDto);
}
package com.infoloop.tianting.service;
import cn.dev33.satoken.stp.SaTokenInfo;
import com.infoloop.tianting.mealorderservice.SingleMpAccountRpcResponse;
import com.infoloop.tianting.model.dto.MpAccountDTO;
import com.infoloop.tianting.model.dto.PermissionDTO.LoginDto;
import com.infoloop.tianting.model.vo.MpAccountVO;
import java.security.NoSuchAlgorithmException;
public interface LoginService {
SaTokenInfo login(LoginDto loginDto) throws NoSuchAlgorithmException;
MpAccountVO getMpAccountByOpenId(String openId);
void updateMpAccount(SingleMpAccountRpcResponse mpAccount, MpAccountDTO.ModifyMpAccountDTO modifyMpAccountDTO);
}
......
package com.infoloop.tianting.service;
import com.infoloop.tianting.mealorderservice.SingleMealOrderRpcResponse;
import com.infoloop.tianting.model.common.CreatedResult;
import com.infoloop.tianting.model.dto.MealOrderDTO;
import com.infoloop.tianting.model.vo.DeliveryRuleVO;
import com.infoloop.tianting.model.vo.MealOrderVO;
import java.util.List;
public interface MealOrderService {
List<MealOrderVO> queryMealOrders(MealOrderDTO.QueryMealOrderDTO queryMealOrderDTO);
CreatedResult<MealOrderVO> createMealOrder(MealOrderDTO.CreateMealOrderDTO createMealOrderDTO);
MealOrderVO getMealOrderById(SingleMealOrderRpcResponse mealOrder);
DeliveryRuleVO getDeliveryRule();
}
package com.infoloop.tianting.service;
import com.infoloop.tianting.clientinventoryservice.SingleClientRpcResponse;
import com.infoloop.tianting.model.dto.MenuDbDTO.BatchCreateMenuRefsDto;
import com.infoloop.tianting.model.dto.MenuDbDTO.BatchCreateMenuRefsResponseDto;
import com.infoloop.tianting.model.dto.MenuDbDTO.MenuDetailDto;
......@@ -24,4 +25,6 @@ public interface MenuService {
BatchCreateMenuRefsResponseDto batchCreateMenuRefs(BatchCreateMenuRefsDto batchCreateMenuRefsDto);
List<Integer> queryMenuSkuIdsByStallId(int enterpriseId, int stallId);
String queryClientLatestMealMenuRecord(SingleClientRpcResponse client);
}
......
......@@ -2,6 +2,7 @@ package com.infoloop.tianting.service.client;
import com.infoloop.tianting.clientinventoryservice.GetClientByIdRpcRequest;
import com.infoloop.tianting.clientinventoryservice.GetClientByIdRpcResponse;
import com.infoloop.tianting.clientinventoryservice.GetClientsByCodesRpcRequest;
import com.infoloop.tianting.clientinventoryservice.GetClientsByIdsRpcRequest;
import com.infoloop.tianting.clientinventoryservice.GetClientsByIdsRpcResponse;
import com.infoloop.tianting.clientinventoryservice.GetStallsByClientIdRpcRequest;
......@@ -10,8 +11,9 @@ import com.infoloop.tianting.clientinventoryservice.GetStallsByIdsRpcRequest;
import com.infoloop.tianting.clientinventoryservice.GetStallsByIdsRpcResponse;
import com.infoloop.tianting.clientinventoryservice.QueryClientTableCodesByConditionRpcRequest;
import com.infoloop.tianting.clientinventoryservice.QueryClientTableCodesByConditionRpcResponse;
import com.infoloop.tianting.clientinventoryservice.SingleClientRpcResponse;
import com.infoloop.tianting.clientinventoryservice.TiantingClientInventoryServiceRpcGrpc;
import com.infoloop.tianting.model.dto.InventoryDbDTO.TableCodeQueryConditionDto;
import com.infoloop.tianting.model.dto.ClientInventoryDbDTO.TableCodeQueryConditionDto;
import lombok.RequiredArgsConstructor;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;
......@@ -20,7 +22,7 @@ import java.util.List;
@Service
@RequiredArgsConstructor(onConstructor = @__(@Autowired))
public class InventoryServiceRpcClient {
public class ClientInventoryServiceRpcClient {
private final TiantingClientInventoryServiceRpcGrpc.TiantingClientInventoryServiceRpcBlockingStub
inventoryServiceRpcBlockingStub;
......@@ -43,6 +45,15 @@ public class InventoryServiceRpcClient {
return inventoryServiceRpcBlockingStub.getClientsByIds(request);
}
public List<SingleClientRpcResponse> getClientsByCodes(Integer enterpriseId, List<String> codes) {
final var request = GetClientsByCodesRpcRequest.newBuilder()
.setEnterpriseId(enterpriseId)
.addAllCodes(codes)
.setIncludeDeleted(false)
.build();
return inventoryServiceRpcBlockingStub.getClientsByCodes(request).getClientsList();
}
public GetStallsByIdsRpcResponse getStallsByIds(Integer enterpriseId, List<Integer> stallIds) {
final var request = GetStallsByIdsRpcRequest.newBuilder()
.setEnterpriseId(enterpriseId)
......
package com.infoloop.tianting.service.client;
import com.infoloop.tianting.deliveryruleservice.DeliveryTemplateTypeEnum;
import com.infoloop.tianting.deliveryruleservice.GetClientLabelsByIdsRpcRequest;
import com.infoloop.tianting.deliveryruleservice.GetClientLabelsByIdsRpcResponse;
import com.infoloop.tianting.deliveryruleservice.GetDefaultDeliveryTemplateAndRuleRpcRequest;
import com.infoloop.tianting.deliveryruleservice.GetDefaultDeliveryTemplateAndRuleRpcResponse;
import com.infoloop.tianting.deliveryruleservice.QueryClientLabelsByConditionRpcRequest;
import com.infoloop.tianting.deliveryruleservice.QueryClientLabelsByConditionRpcResponse;
import com.infoloop.tianting.deliveryruleservice.TiantingDeliveryRuleServiceRpcGrpc;
......@@ -40,5 +43,14 @@ public class DeliveryRuleServiceRpcClient {
return deliveryRuleServiceRpcBlockingStub.getClientLabelsByIds(request);
}
public GetDefaultDeliveryTemplateAndRuleRpcResponse getDefaultDeliveryTemplateAndRule(int enterpriseId) {
final var request = GetDefaultDeliveryTemplateAndRuleRpcRequest
.newBuilder()
.setEnterpriseId(enterpriseId)
.setType(DeliveryTemplateTypeEnum.DELIVERY_TEMPLATE_TYPE_DELIVERY)
.build();
return deliveryRuleServiceRpcBlockingStub.getDefaultDeliveryTemplateAndRule(request);
}
}
......
package com.infoloop.tianting.service.impl;
import com.infoloop.tianting.model.dto.InventoryDbDTO.ClientDto;
import com.infoloop.tianting.model.dto.InventoryDbDTO.ClientTableCodeDto;
import com.infoloop.tianting.model.dto.InventoryDbDTO.TableCodeQueryConditionDto;
import com.infoloop.tianting.service.InventoryService;
import com.infoloop.tianting.service.client.InventoryServiceRpcClient;
import com.infoloop.tianting.context.LoginContextHolder;
import com.infoloop.tianting.model.dto.ClientInventoryDbDTO.ClientDto;
import com.infoloop.tianting.model.dto.ClientInventoryDbDTO.ClientTableCodeDto;
import com.infoloop.tianting.model.dto.ClientInventoryDbDTO.TableCodeQueryConditionDto;
import com.infoloop.tianting.service.ClientInventoryService;
import com.infoloop.tianting.service.client.ClientInventoryServiceRpcClient;
import com.infoloop.tianting.utils.DateUtil;
import lombok.RequiredArgsConstructor;
import lombok.extern.slf4j.Slf4j;
......@@ -17,13 +18,13 @@ import java.util.stream.Collectors;
@Slf4j
@Service
@RequiredArgsConstructor(onConstructor = @__(@Autowired))
public class InventoryServiceImpl implements InventoryService {
public class ClientClientInventoryServiceImpl implements ClientInventoryService {
private final InventoryServiceRpcClient inventoryServiceRpcClient;
private final ClientInventoryServiceRpcClient clientInventoryServiceRpcClient;
@Override
public ClientDto getClientById(Integer enterpriseId, Integer clientId) {
final var response = inventoryServiceRpcClient.getClientById(enterpriseId, clientId);
final var response = clientInventoryServiceRpcClient.getClientById(enterpriseId, clientId);
return ClientDto.builder()
.id(response.getClient().getId())
.address(response.getClient().getAddress())
......@@ -46,7 +47,7 @@ public class InventoryServiceImpl implements InventoryService {
@Override
public List<ClientDto> getStallsByClientId(Integer enterpriseId, Integer clientId) {
final var response = inventoryServiceRpcClient.getStallsByClientId(enterpriseId, clientId);
final var response = clientInventoryServiceRpcClient.getStallsByClientId(enterpriseId, clientId);
return response.getStallsList().stream().map(stall ->
ClientDto.builder()
.id(stall.getId())
......@@ -69,7 +70,7 @@ public class InventoryServiceImpl implements InventoryService {
@Override
public List<ClientTableCodeDto> queryClientTableCodesByCondition(TableCodeQueryConditionDto tableCodeQueryConditionDto) {
final var response = inventoryServiceRpcClient.queryClientTableCodesByCondition(tableCodeQueryConditionDto);
final var response = clientInventoryServiceRpcClient.queryClientTableCodesByCondition(tableCodeQueryConditionDto);
return response.getResponsesList().stream().map(tableCode ->
ClientTableCodeDto.builder()
.id(tableCode.getId())
......@@ -87,4 +88,28 @@ public class InventoryServiceImpl implements InventoryService {
.updateSource(tableCode.getUpdateSource())
.build()).collect(Collectors.toList());
}
@Override
public List<ClientDto> getClientsByCodes(List<String> codes) {
final var response = clientInventoryServiceRpcClient.getClientsByCodes(LoginContextHolder.getEnterpriseId(), codes);
return response.stream().map(client ->
ClientDto.builder()
.id(client.getId())
.address(client.getAddress())
.area(client.getArea())
.province(client.getProvince())
.city(client.getCity())
.code(client.getCode())
.customerSource(client.getCustomerSource())
.enterpriseId(client.getEnterpriseId())
.operatorName(client.getOperatorName())
.parentId(client.getParentId())
.status(client.getStatus())
.regionId(client.getRegionId())
.type(client.getType())
.name(client.getName())
.isDelivery(client.getIsDelivery())
.build()).collect(Collectors.toList());
}
}
......
......@@ -6,7 +6,7 @@ import com.infoloop.tianting.clientcustomerorderservice.ServeStatusEnum;
import com.infoloop.tianting.clientcustomerorderservice.SingleClientCustomerOrderDetailRpcResponse;
import com.infoloop.tianting.clientcustomerorderservice.SingleClientCustomerOrderRpcResponse;
import com.infoloop.tianting.context.LoginContextHolder;
import com.infoloop.tianting.model.dto.InventoryDbDTO.ClientDto;
import com.infoloop.tianting.model.dto.ClientInventoryDbDTO.ClientDto;
import com.infoloop.tianting.model.dto.KdsDTO.KdsMealDetailDto;
import com.infoloop.tianting.model.dto.KdsDTO.KdsOrderLocationDetailDto;
import com.infoloop.tianting.model.dto.KdsDTO.KdsOrderLocationDto;
......@@ -19,8 +19,8 @@ import com.infoloop.tianting.model.dto.OrderDbDTO.CustomerNotice;
import com.infoloop.tianting.model.dto.OrderDbDTO.QueryOrderByConditionDto;
import com.infoloop.tianting.service.KdsService;
import com.infoloop.tianting.service.client.ClientCustomerServiceRpcClient;
import com.infoloop.tianting.service.client.ClientInventoryServiceRpcClient;
import com.infoloop.tianting.service.client.EnterpriseResourceServiceRpcClient;
import com.infoloop.tianting.service.client.InventoryServiceRpcClient;
import com.infoloop.tianting.service.client.MealServiceRpcClient;
import com.infoloop.tianting.service.client.OrderServiceRpcClient;
import com.infoloop.tianting.service.client.SkuServiceRpcClient;
......@@ -47,7 +47,7 @@ public class KdsServiceImpl implements KdsService {
private final WOperatorServiceRpcClient wOperatorServiceRpcClient;
private final MealServiceRpcClient mealServiceRpcClient;
private final SkuServiceRpcClient skuServiceRpcClient;
private final InventoryServiceRpcClient inventoryServiceRpcClient;
private final ClientInventoryServiceRpcClient clientInventoryServiceRpcClient;
private final ClientCustomerServiceRpcClient clientCustomerServiceRpcClient;
@Override
......@@ -87,14 +87,14 @@ public class KdsServiceImpl implements KdsService {
.map(SingleClientCustomerOrderRpcResponse::getClientId)
.distinct()
.collect(Collectors.toList());
final var clients = inventoryServiceRpcClient.getClientsByIds(
final var clients = clientInventoryServiceRpcClient.getClientsByIds(
operator.getEnterpriseId(), clientIds);
final var orderStallIds = orderList.stream()
.map(SingleClientCustomerOrderRpcResponse::getStallId)
.distinct()
.collect(Collectors.toList());
final var stalls = inventoryServiceRpcClient.getStallsByIds(
final var stalls = clientInventoryServiceRpcClient.getStallsByIds(
operator.getEnterpriseId(), orderStallIds);
final var customerIds = orderList.stream().map(SingleClientCustomerOrderRpcResponse::getCustomerId).collect(Collectors.toList());
......@@ -321,14 +321,14 @@ public class KdsServiceImpl implements KdsService {
.map(SingleClientCustomerOrderRpcResponse::getClientId)
.distinct()
.collect(Collectors.toList());
final var clients = inventoryServiceRpcClient.getClientsByIds(
final var clients = clientInventoryServiceRpcClient.getClientsByIds(
operator.getEnterpriseId(), clientIds);
final var orderStallIds = orderList.stream()
.map(SingleClientCustomerOrderRpcResponse::getStallId)
.distinct()
.collect(Collectors.toList());
final var stalls = inventoryServiceRpcClient.getStallsByIds(
final var stalls = clientInventoryServiceRpcClient.getStallsByIds(
operator.getEnterpriseId(), orderStallIds);
final var customerIds = orderList.stream().map(SingleClientCustomerOrderRpcResponse::getCustomerId).collect(Collectors.toList());
......
......@@ -7,11 +7,19 @@ import com.infoloop.rpc.meizhongyiheservice.HospitalStatus;
import com.infoloop.tianting.WOperatorStatus;
import com.infoloop.tianting.clientcustomerservice.ClientCustomerHospitalRecordHospitalStatusEnum;
import com.infoloop.tianting.constant.CommonConstants;
import com.infoloop.tianting.context.LoginContextHolder;
import com.infoloop.tianting.exception.ClientEndExceptions;
import com.infoloop.tianting.exception.ErrorCodeEnum;
import com.infoloop.tianting.mealorderservice.MpAccountCreation;
import com.infoloop.tianting.mealorderservice.MpAccountModification;
import com.infoloop.tianting.mealorderservice.MpAccountStatusEnum;
import com.infoloop.tianting.mealorderservice.SingleMpAccountRpcResponse;
import com.infoloop.tianting.model.dto.MpAccountDTO;
import com.infoloop.tianting.model.dto.PermissionDTO.LoginDto;
import com.infoloop.tianting.model.vo.MpAccountVO;
import com.infoloop.tianting.service.LoginService;
import com.infoloop.tianting.service.client.ClientCustomerServiceRpcClient;
import com.infoloop.tianting.service.client.MealOrderServiceRpcClient;
import com.infoloop.tianting.service.client.MeiZhongYiHeServiceClient;
import com.infoloop.tianting.service.client.OperatorServiceRpcClient;
import com.infoloop.tianting.service.client.WOperatorServiceRpcClient;
......@@ -20,6 +28,7 @@ import lombok.RequiredArgsConstructor;
import lombok.extern.slf4j.Slf4j;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;
import org.springframework.util.Assert;
import java.security.MessageDigest;
import java.security.NoSuchAlgorithmException;
......@@ -30,6 +39,7 @@ import java.security.NoSuchAlgorithmException;
public class LoginServiceImpl implements LoginService {
private final ClientCustomerServiceRpcClient clientCustomerServiceRpcClient;
private final MealOrderServiceRpcClient mealOrderServiceRpcClient;
private final OperatorServiceRpcClient operatorServiceRpcClient;
private final WxMiniProgramHttpClient wxMiniProgramHttpClient;
private final WOperatorServiceRpcClient wOperatorServiceRpcClient;
......@@ -44,6 +54,25 @@ public class LoginServiceImpl implements LoginService {
.setExtra(CommonConstants.LOGIN_SOURCE, loginDto.getLoginSourceEnum().getValue())
.build());
return StpUtil.getTokenInfo();
} else if (loginDto.isShouldLoginWithOpenId()){
final var mpAccountByOpenId = mealOrderServiceRpcClient.getMpAccountByOpenId(loginDto.getOpenId());
int mpAccountId;
if (mpAccountByOpenId == null) {
mpAccountId = mealOrderServiceRpcClient.createMpAccount(loginDto.getEnterpriseId(), MpAccountCreation.newBuilder()
.setOpenId(loginDto.getOpenId())
.setStatus(MpAccountStatusEnum.MP_ACCOUNT_STATUS_ENABLE)
.setPhoneNumber(loginDto.getOperatorPhone() != null ? loginDto.getOperatorPhone() : "")
.build()).getId();
} else {
mpAccountId = mpAccountByOpenId.getId();
}
Assert.isTrue(mpAccountId != 0, "创建小程序账号失败");
StpUtil.login(loginDto.getOpenId(), SaLoginModel.create()
.setExtra(CommonConstants.ENTERPRISE_ID, loginDto.getEnterpriseId())
.setExtra(CommonConstants.USER_ID, mpAccountId)
.setExtra(CommonConstants.LOGIN_SOURCE, loginDto.getLoginSourceEnum().getValue())
.build());
return StpUtil.getTokenInfo();
} else if (loginDto.isShouldLoginWithHisCustomerNo()) {
var customer = clientCustomerServiceRpcClient.getClientCustomerByHISCustomerNo(loginDto.getHisCustomerNo()).getResponse();
if (customer.getId() == 0) {
......@@ -110,6 +139,37 @@ public class LoginServiceImpl implements LoginService {
}
}
@Override
public MpAccountVO getMpAccountByOpenId(String openId) {
final var mpAccountByOpenId = mealOrderServiceRpcClient.getMpAccountByOpenId(openId);
if (mpAccountByOpenId == null) {
return null;
}
return MpAccountVO.builder()
.id(mpAccountByOpenId.getId())
.enterpriseId(mpAccountByOpenId.getEnterpriseId())
.openId(mpAccountByOpenId.getOpenId())
.unionId(mpAccountByOpenId.getUnionId())
.nickname(mpAccountByOpenId.getNickname())
.avatarUrl(mpAccountByOpenId.getAvatarUrl())
.gender(mpAccountByOpenId.getGender())
.phoneNumber(mpAccountByOpenId.getPhoneNumber())
.build();
}
@Override
public void updateMpAccount(SingleMpAccountRpcResponse mpAccount, MpAccountDTO.ModifyMpAccountDTO modifyMpAccountDTO) {
mealOrderServiceRpcClient.updateMpAccount(LoginContextHolder.getLoginInfo(), MpAccountModification.newBuilder()
.setId(mpAccount.getId())
.setShouldUpdateNickname(modifyMpAccountDTO.getNickName() != null)
.setNickname(modifyMpAccountDTO.getNickName() != null ? modifyMpAccountDTO.getNickName() : mpAccount.getNickname())
.setShouldUpdateAvatarUrl(modifyMpAccountDTO.getAvatarUrl() != null)
.setAvatarUrl(modifyMpAccountDTO.getAvatarUrl() != null ? modifyMpAccountDTO.getAvatarUrl() : mpAccount.getAvatarUrl())
.setShouldUpdateGender(modifyMpAccountDTO.getGender() != null)
.setGender(modifyMpAccountDTO.getGender() != null ? modifyMpAccountDTO.getGender() : mpAccount.getGender())
.build());
}
public static String sha1Hash(String input) throws NoSuchAlgorithmException {
MessageDigest md = MessageDigest.getInstance("SHA-1");
md.update(input.getBytes());
......
package com.infoloop.tianting.service.impl;
import com.infoloop.tianting.clientinventoryservice.SingleClientRpcResponse;
import com.infoloop.tianting.context.LoginContextHolder;
import com.infoloop.tianting.menuservice.SingleMenuDetailRpcResponse;
import com.infoloop.tianting.menuservice.SingleMenuRpcResponse;
......@@ -11,6 +12,7 @@ import com.infoloop.tianting.model.dto.MenuDbDTO.MenuDto;
import com.infoloop.tianting.model.dto.MenuDbDTO.MenuRefDto;
import com.infoloop.tianting.model.dto.MenuDbDTO.OrderRuleJson;
import com.infoloop.tianting.service.MenuService;
import com.infoloop.tianting.service.client.MealOrderServiceRpcClient;
import com.infoloop.tianting.service.client.MenuServiceRpcClient;
import com.infoloop.tianting.utils.DateUtil;
import lombok.RequiredArgsConstructor;
......@@ -29,6 +31,8 @@ public class MenuServiceImpl implements MenuService {
private final MenuServiceRpcClient menuServiceRpcClient;
private final MealOrderServiceRpcClient mealOrderServiceRpcClient;
@Override
public List<MenuDto> queryMiniProgramPublishedMenusByStallId(Integer enterpriseId, Integer stallId) {
final var response = menuServiceRpcClient.queryMiniProgramPublishedMenusByStallId(enterpriseId, stallId);
......@@ -209,4 +213,11 @@ public class MenuServiceImpl implements MenuService {
return menuServiceRpcClient.queryMenuDetailsByMenuIds(LoginContextHolder.getEnterpriseId(), menuIds).getResponsesList().stream().map(SingleMenuDetailRpcResponse::getSkuId).distinct().collect(Collectors.toList());
}
@Override
public String queryClientLatestMealMenuRecord(SingleClientRpcResponse client) {
final var singleMealMenuRecordRpcResponses = mealOrderServiceRpcClient.queryLatestMealMenuRecordsByClientIds(LoginContextHolder.getEnterpriseId(), List.of(client.getId()));
return singleMealMenuRecordRpcResponses.isEmpty() ? "" : singleMealMenuRecordRpcResponses.get(0).getImageUrl();
}
}
......
......@@ -18,7 +18,7 @@ import com.infoloop.tianting.model.dto.SettlementDTO.SettlementMenuMealDto;
import com.infoloop.tianting.model.dto.SettlementDTO.SettlementMenuSkuDto;
import com.infoloop.tianting.model.dto.SettlementDTO.SettlementRequestDto;
import com.infoloop.tianting.service.SettlementService;
import com.infoloop.tianting.service.client.InventoryServiceRpcClient;
import com.infoloop.tianting.service.client.ClientInventoryServiceRpcClient;
import com.infoloop.tianting.service.client.MealServiceRpcClient;
import com.infoloop.tianting.service.client.MenuServiceRpcClient;
import com.infoloop.tianting.service.client.OrderServiceRpcClient;
......@@ -55,7 +55,7 @@ public class SettlementServiceImpl implements SettlementService {
private final OrderServiceRpcClient orderServiceRpcClient;
private final MenuServiceRpcClient menuServiceRpcClient;
private final SkuServiceRpcClient skuServiceRpcClient;
private final InventoryServiceRpcClient inventoryServiceRpcClient;
private final ClientInventoryServiceRpcClient clientInventoryServiceRpcClient;
private final MealServiceRpcClient mealServiceRpcClient;
public static ByteArrayOutputStream writeToExcelBySku(SettlementDataDto settlementDataDto)
......@@ -403,7 +403,7 @@ public class SettlementServiceImpl implements SettlementService {
}
}
final var stalls = inventoryServiceRpcClient.getStallsByIds(enterpriseId, settlementRequest.getStallIds()).getClientsList();
final var stalls = clientInventoryServiceRpcClient.getStallsByIds(enterpriseId, settlementRequest.getStallIds()).getClientsList();
final var stallNames = stalls.stream()
.filter(s -> settlementRequest.getStallIds().contains(s.getId()))
.map(SingleClientRpcResponse::getName).collect(Collectors.toList());
......@@ -525,7 +525,7 @@ public class SettlementServiceImpl implements SettlementService {
}
}
final var client = inventoryServiceRpcClient.getClientById(enterpriseId,
final var client = clientInventoryServiceRpcClient.getClientById(enterpriseId,
settlementRequest.getClientId()).getClient();
final var settlementDataByMealDto = SettlementDataByMealDto.builder()
.classifyOrders(classifyOrders)
......
......@@ -115,14 +115,12 @@ public class SkuServiceImpl implements SkuService {
if (querySkuSellQuantityDTO.getStatus() != SkuSellQuantityStatus.ALL) {
responses = responses.stream()
.filter(e -> {
switch (querySkuSellQuantityDTO.getStatus()) {
case SOLD_OUT:
return e.getMaxSellQuantity() == e.getTodaySellQuantity();
case ON_SALE:
return e.getMaxSellQuantity() != e.getTodaySellQuantity();
default:
return true;
if (querySkuSellQuantityDTO.getStatus() == SkuSellQuantityStatus.SOLD_OUT) {
return e.getMaxSellQuantity() == e.getTodaySellQuantity();
} else if (querySkuSellQuantityDTO.getStatus() == SkuSellQuantityStatus.ON_SALE) {
return e.getMaxSellQuantity() != e.getTodaySellQuantity();
}
return true;
})
.collect(Collectors.toList());
}
......
package com.infoloop.tianting.store;
import io.lettuce.core.SetArgs;
import io.lettuce.core.api.sync.RedisCommands;
import java.time.DayOfWeek;
import java.time.LocalDate;
import java.time.temporal.WeekFields;
public class WeeklyTaskStore {
private final RedisCommands<String, String> commands;
private final long expire; // 过期时间（秒）
public WeeklyTaskStore(final RedisCommands<String, String> commands, final long expire) {
this.commands = commands;
this.expire = expire;
}
public boolean isExecutedThisWeek(String keyPrefix, int enterpriseId, LocalDate date) {
String key = getWeeklyKey(keyPrefix, enterpriseId, date);
return commands.exists(key) > 0;
}
public void markExecuted(String keyPrefix, int enterpriseId, LocalDate date) {
String key = getWeeklyKey(keyPrefix, enterpriseId, date);
commands.set(key, "1", new SetArgs().ex(expire));
}
private String getWeeklyKey(String keyPrefix, int enterpriseId, LocalDate date) {
WeekFields weekFields = WeekFields.of(DayOfWeek.MONDAY, 1);
int year = date.getYear();
int week = date.get(weekFields.weekOfWeekBasedYear());
return String.format("%s:%d:%d-W%d", keyPrefix, enterpriseId, year, week);
}
}
......@@ -4,11 +4,22 @@ import com.infoloop.tianting.model.common.OrderPageResult;
import com.infoloop.tianting.model.common.PageResult;
import com.infoloop.tianting.model.dto.OrderDbDTO.OrderCountByStatusDto;
import java.lang.reflect.InvocationTargetException;
import java.util.LinkedList;
import java.util.List;
public class PageUtil {
public static <T> PageResult<T> buildEmpty(Class<T> clazz) {
T instance;
try {
instance = clazz.getDeclaredConstructor().newInstance();
} catch (InstantiationException | IllegalAccessException | InvocationTargetException | NoSuchMethodException e) {
throw new RuntimeException(e);
}
return buildEmpty(instance);
}
public static <T> PageResult<T> buildEmpty(T t) {
PageResult<T> pageRet = new PageResult<>();
pageRet.setTotalCount(0);
......
This diff is collapsed. Click to expand it.
......@@ -34,8 +34,8 @@ okhttp.max-idle-connections=10
okhttp.keep-alive-duration=300
##GRPC\u914D\u7F6E
grpc.order-service.url=localhost
grpc.order-service.port=4096
grpc.order-service.url=47.101.193.136
grpc.order-service.port=4065
grpc.menu-service.url=47.101.193.136
grpc.menu-service.port=3017
......@@ -76,10 +76,10 @@ grpc.meizhongyihe-service.port=3040
miniprogram.appId=wx40ec496d73b58ec6
miniprogram.appSecret=5b309517bf918abf760b2195e91b99f3
business-config.hisCustomerQueryUrl = https://nutri.amcare.com.cn/v3/hiscustomers/current/query
business-config.clientCustomerQueryUrl = https://nutri.amcare.com.cn/v3/clientcustomers/current/query
business-config.payUrl = http://10.2.5.162:21051/API/Microapp/CreateOrder?appid={0}
business-config.payClientId = Order
business-config.hisCustomerQueryUrl = http://localhost:8903/hiscustomers/current/query
business-config.clientCustomerQueryUrl = http://localhost:8903/clientcustomers/current/query
business-config.payUrl = http://36.110.128.86:21051/API/Microapp/CreateOrder?appid={0}
business-config.payClientId = Order00001
business-config.cancelPayUrl = http://10.2.5.162:21051/frame/requestbase64
business-config.refundSecurityKey = 0987654321
......@@ -104,6 +104,12 @@ sa-token.sign.secret-key=4Jk2giMQw8D7lHJcU8fv8CXjSOhjp5Ee
##\u65E5\u5FD7\u914D\u7F6E
logging.config=classpath:logback-spring.xml
aliyun.oss.endPoint=oss-cn-shanghai.aliyuncs.com
aliyun.oss.host=infoloop-public-qa.oss-cn-shanghai.aliyuncs.com
aliyun.oss.accessKeyId=LTAIo9gcY5sjIZdN
aliyun.oss.accessKeySecret=gOOkVY4Euj3MSbPyg1tZvPbZbUssj5
aliyun.oss.bucket=infoloop-public-qa
##\u77ED\u4FE1\u914D\u7F6E
sms-config.accessKeyId=
sms-config.accessKeySecret=
......
package com.infoloop.tianting;
import org.junit.runner.RunWith;
import org.junit.jupiter.api.Test;
import org.junit.jupiter.api.extension.ExtendWith;
import org.springframework.boot.test.context.SpringBootTest;
import org.springframework.test.context.junit4.SpringRunner;
import org.springframework.test.context.junit.jupiter.SpringExtension;
@SpringBootTest(classes = App.class)
@RunWith(SpringRunner.class)
@ExtendWith(SpringExtension.class)
@SpringBootTest
public class AppTest {
@Test
void testSomething() {
System.out.println("test");
}
}
......