dev 契约锁

P15GEN2\59518

2024-05-29 d4210c7c4b04abde20037ea8aa0f54ef8a2649aa

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
package grand;
 
import foundation.action.ActionProvider;
import foundation.data.entity.Entity;
import foundation.data.entity.EntitySet;
import foundation.data.object.DataObject;
import foundation.data.object.EntitySaver;
import foundation.icall.ICall;
import foundation.icall.ICallCenter;
import foundation.persist.NamedSQL;
import foundation.persist.SQLRunner;
 
public class HospitalHandler extends ActionProvider {
    
    private DataObject hospiatlObject;
    
    public HospitalHandler() {
        hospiatlObject = DataObject.getInstance("md_hospital");
    }
    @Override
    protected void publishMethod() {
        //1. 同步医院
        addMethod("syncHospital");
        
        //2.同步DMS医院
        addMethod("syncDmsHospital");
        
        //3. 辖区医院更新渠道关系
        addMethod("updateChannelStructure");
    }
    
    public void syncHospital() throws Exception {
        ICallCenter iCallCenter = ICallCenter.getInstance();
                
        //1.1 获取OA-医院
        logger.debug("1.1 获取OA-医院---------->>");
        ICall iCall = ICall.getInstance("oa_v_dms_hospital");
        iCallCenter.callRemote(context, iCall);
        
        //2.1 同步DMS医院
        logger.debug("2.1 同步DMS医院---------->>");
        syncDmsHospital();
        
        logger.debug("医院同步完成");
    }
    
    public void syncDmsHospital() throws Exception {
        //1. 拿到需要更新的OA医院
        NamedSQL namedSQL = NamedSQL.getInstance("getUpdateHospital");
        EntitySet entitySet = SQLRunner.getEntitySet(namedSQL);
        
        //2. 遍历OA医院，更新医院（包含血缘关系表）
        for (Entity entity: entitySet) {
            String hospitalId = entity.getId();
            EntitySaver saver = hospiatlObject.createEntitySaver(hospitalId);
            saver.set("code", entity.getString("YYBM"));
            saver.set("name", entity.getString("YYMC"));
            saver.set("province", entity.getString("SF"));
            saver.set("city", entity.getString("DQ"));
            saver.set("county", entity.getString("XS"));
            saver.set("address", entity.getString("DD"));
            saver.update();
        }
        
        //3.插入新增医院
        namedSQL = NamedSQL.getInstance("getAppendHospital");
        entitySet = SQLRunner.getEntitySet(namedSQL);
        hospiatlObject.batchInsertEntitySet(entitySet);
        
    }
 
    public void updateChannelStructure() throws Exception {
        NamedSQL namedSQL = NamedSQL.getInstance("updateChannelStructurePosition");
        namedSQL.execute();
    }
}