bug fix

wangzhibo

2026-07-16 9f6e099c39b61027cc96df77200b98388d48d348

 src/modules/push/controller/app/open.ts

@@ -3,16 +3,13 @@
import { PushOpenService } from '../../service/open';
import { WeightUploadDto } from '../../dto/weight.dto';
import * as crypto from 'crypto';
import { BaseSysParamService } from '../../../base/service/sys/param';

const CLIENT_ID = '10001';
const SECRET = '9001ac9676b8';


/**
 * 开放无需验证的上报数据接口
 */


@CoolController({
  prefix: '/open/push',
})
@@ -20,17 +17,26 @@
  @Inject()
  pushOpenService: PushOpenService;

  @Inject()
  baseSysParamService: BaseSysParamService;


  @Post('/weight', { summary: '原始称重上报接口' })
  async uploadWeight(
    @Headers() headers: any,
    @Body() data: WeightUploadDto,
  ) {

    const CLIENT_ID = String(await this.baseSysParamService.dataByKey('YAOHUA.WEIGHT.CLIENTID')); //'10001';
    const SECRET = String(await this.baseSysParamService.dataByKey('YAOHUA.WEIGHT.SECRET')); '9001ac9676b8';


    const clientId = headers['clientid'];
    const sign = headers['sign'];

    // 1. clientId 校验
    if (clientId !== CLIENT_ID) {
      await this.pushOpenService.writePushAuditLog("weight",{ "deviceNo": clientId, "requestContent": data, "errorMessage": "非法 clientId" });
      await this.pushOpenService.writePushAuditLog("weight", { "deviceNo": clientId, "requestContent": data, "errorMessage": "非法 clientId" });
      return {
        code: 1001,
        msg: '非法 clientId',
@@ -56,7 +62,7 @@
      .toLowerCase();

    if (realSign !== sign?.toLowerCase()) {
      await this.pushOpenService.writePushAuditLog("weight",{ "deviceNo": data.deviceNo, "requestContent": data, "errorMessage": "签名验证失败" });
      await this.pushOpenService.writePushAuditLog("weight", { "deviceNo": data.deviceNo, "requestContent": data, "errorMessage": "签名验证失败" });

      return {
        code: 1002,
@@ -72,7 +78,7 @@
        data: 'success',
      };
    } catch (err) {
      await this.pushOpenService.writePushAuditLog("weight",{ "deviceNo": data.deviceNo, "requestContent": data, "errorMessage": "系统异常,写入失败." });
      await this.pushOpenService.writePushAuditLog("weight", { "deviceNo": data.deviceNo, "requestContent": data, "errorMessage": "系统异常,写入失败." });

      return {
        code: 500,
@@ -91,7 +97,7 @@
    const result = await this.pushOpenService.receiveCameraGpsMessage(body);
    //return this.ok(result);

    return {"messageId":result}
    return { "messageId": result }

  }
}