新增明细查询

common/src/main/ets/bean/dto/WzcrkMxRefWzDto.ts

+/**
+ * 物资出入库明细关联物资信息的数据对象
+ */
+export interface WzcrkMxRefWzDto {
+  guid: string,
+  xh: string,
+  hxmc: string,
+  pmdmsix: string,
+  pmdmten: string,
+  wzpm: string,
+  pzmxguid: string,
+  wzcrkguid: string,
+  pzsl: number,
+  hwh: string,
+  crksl: number
+}
\ No newline at end of file

common/src/main/ets/db/dao/WzcrkmxDao.ets

@@ -3,6 +3,8 @@ import { Wzcrkmx } from '../../entity/Wzcrkmx';
 import BaseTable, { ValueType } from '../BaseTable';
 import { Table } from '../decorator/Decorators';
 import { Logger } from '../../utils/Logger';
+import { NativeSql } from '../sql/NativeSql';
+import { WzcrkMxRefWzDto } from '../../bean/dto/WzcrkMxRefWzDto';
 
 
 /**
@@ -54,7 +56,7 @@ export class WzcrkmxDao extends BaseTable<Wzcrkmx> {
    * 验证物资明细是否扫描过
    * "select count(1) crksl from TAB_BZGL_KNZY_APP_WZCRKMX mx where mx.WZCRKGUID = 'wzcrkguid' and ISFULL(crksl,0) <> 0"
    */
-  async hasScanWz(wzcrkguid:string): Promise<number>{
+  async hasScanWz(wzcrkguid: string): Promise<number> {
     let db = await super.futureDb;
     let resultSet = await db.querySql("select crksl from TAB_BZGL_KNZY_APP_WZCRKMX mx where mx.WZCRKGUID = 'wzcrkguid' and ISFULL(crksl,0) <> 0")
     return resultSet.rowCount
@@ -63,7 +65,7 @@ export class WzcrkmxDao extends BaseTable<Wzcrkmx> {
   /**
    * 验证调号合计同品种号型是否等于0
    */
-  async checkThTest(wzcrkguid:string): Promise<Wzcrkmx[]>{
+  async checkThTest(wzcrkguid: string): Promise<Wzcrkmx[]> {
     let db = await super.futureDb;
     let resultSet = await db.querySql("select substr(pmdmcode,0,7) pmdmcode,max(hx.WZPM) wzpm,sum(ifnull(crksl,0)) crksl from TAB_BZGL_KNZY_APP_WZCRKMX mx" +
     " left join TAB_XTWH_JCSJ_BZHX hx on hx.PMDMSIX = substr(pmdmcode,0,7) where mx.WZCRKGUID = 'wzcrkguid' group by substr(pmdmcode,0,7) having sum(isfull(crksl,0)) <>0")
@@ -81,7 +83,7 @@ export class WzcrkmxDao extends BaseTable<Wzcrkmx> {
   /**
    * 验证倒库合计同品种号型是否等于0
    */
-  async checkDKTest(wzcrkguid:string): Promise<Wzcrkmx[]>{
+  async checkDKTest(wzcrkguid: string): Promise<Wzcrkmx[]> {
     let db = await super.futureDb;
     let resultSet = await db.querySql("select pmdmcode,max(hx.WZPM) wzpm,sum(isfull(crksl,0)) crksl from TAB_BZGL_KNZY_APP_WZCRKMX mx" +
     " left join TAB_XTWH_JCSJ_BZHX hx on hx.PMDMTEN = pmdmcode where mx.WZCRKGUID = 'wzcrkguid' group by pmdmcode having sum(isfull(crksl,0)) <>0")
@@ -99,7 +101,7 @@ export class WzcrkmxDao extends BaseTable<Wzcrkmx> {
   /**
    * 删除物资明细
    */
-  async deleteWzmx(wzcrkguid:string): Promise<number>{
+  async deleteWzmx(wzcrkguid: string): Promise<number> {
     let predicates = this.getPredicates()
     predicates.equalTo("wzcrkguid", "wzcrkguid")
     return this.deleteAll(predicates);
@@ -125,7 +127,7 @@ export class WzcrkmxDao extends BaseTable<Wzcrkmx> {
 
   async getWzcrkmx(wzcrkguid: string): Promise<Wzcrkmx[]> {
     let wp = this.getPredicates();
-      wp.equalTo('WZCRKGUID', wzcrkguid)
+    wp.equalTo('WZCRKGUID', wzcrkguid)
     return this.query(wp, this.getTableColumns());
   }
 
@@ -144,4 +146,40 @@ export class WzcrkmxDao extends BaseTable<Wzcrkmx> {
     wp.equalTo('guid', guid)
     return this.updateData(valueBucket, wp)
   }
+
+  async queryByCrkGuid(wzcrkguid: string, wzpm?: string): Promise<WzcrkMxRefWzDto[]> {
+    let val_sql = NativeSql.getSqlByCrkmx(wzcrkguid, wzpm);
+    let db = await super.futureDb;
+    let rs = await db.querySql(val_sql);
+
+    let items = []
+    if (rs.goToFirstRow()) {
+      do {
+        items.push(this.toWzcrkRefWz(rs))
+      } while (rs.goToNextRow())
+    }
+    Logger.info(this, 'queryAll items=' + JSON.stringify(items))
+    return items;
+  }
+
+
+  /**
+   * 物资出入库明细转换
+   */
+  toWzcrkRefWz(cursor: relationalStore.ResultSet): WzcrkMxRefWzDto {
+    let info: WzcrkMxRefWzDto = {
+      guid: cursor.getString(cursor.getColumnIndex('guid')),
+      hxmc: cursor.getString(cursor.getColumnIndex('hxmc')),
+      xh: cursor.getString(cursor.getColumnIndex('xh')),
+      pmdmsix: cursor.getString(cursor.getColumnIndex('pmdmsix')),
+      pmdmten: cursor.getString(cursor.getColumnIndex('pmdmten')),
+      wzpm: cursor.getString(cursor.getColumnIndex('wzpm')),
+      pzmxguid: cursor.getString(cursor.getColumnIndex('pzmxguid')),
+      wzcrkguid: cursor.getString(cursor.getColumnIndex('wzcrkguid')),
+      pzsl: cursor.getLong(cursor.getColumnIndex('pzsl')),
+      crksl: cursor.getLong(cursor.getColumnIndex('crksl')),
+      hwh: cursor.getString(cursor.getColumnIndex('hwh'))
+    };
+    return info;
+  }
 }
\ No newline at end of file

common/src/main/ets/db/sql/NativeSql.ets

+export class NativeSql {
+  /**
+   * 构建出入库明细查询语句
+   * @param wzcrkguid 出入库主键
+   * @param wzpm      按品名查询
+   */
+  static getSqlByCrkmx(wzcrkguid: string, wzpm?: string): string {
+    let sql_val = `SELECT
+     s2.GUID, s2.XH, s2.HXMC,  s2.PMDMSIX,s2.PMDMTEN, s2.WZPM, s1.PZMXGUID,
+     s1.WZCRKGUID,s1.PZSL,s1.HWH,s1.CRKSL FROM TAB_BZGL_KNZY_APP_WZCRKMX s1
+     LEFT JOIN TAB_XTWH_JCSJ_BZHX s2 on s1.PMDMCODE = s2.PMDMTEN where s1.WZCRKGUID='${wzcrkguid}'`;
+    if (wzpm) {
+      sql_val += ` and s2.WZPM like '%${wzpm}%`;
+    }
+    return sql_val;
+  }
+}
\ No newline at end of file