Merge branch 'dev/pegawai/presensi/compreface' into prod/base

jasamedika-bridging/src/main/java/com/jasamedika/medifirst2000/controller/BridgingController.java

@@ -19,126 +19,139 @@ import java.util.Map;
 
 import javax.servlet.http.HttpServletResponse;
 
+import com.jasamedika.medifirst2000.service.PegawaiService;
 import org.springframework.beans.factory.annotation.Autowired;
-import org.springframework.http.MediaType;
+import org.springframework.http.ResponseEntity;
-import org.springframework.web.bind.annotation.RequestMapping;
+import org.springframework.web.bind.annotation.*;
-import org.springframework.web.bind.annotation.RequestMethod;
-import org.springframework.web.bind.annotation.RequestParam;
-import org.springframework.web.bind.annotation.RestController;
 
 import com.jasamedika.medifirst2000.dao.BridgingDao;
 import com.jasamedika.medifirst2000.vo.custom.BridgeBUKBorVO;
+
+import static org.springframework.http.HttpStatus.INTERNAL_SERVER_ERROR;
+import static org.springframework.http.HttpStatus.OK;
+import static org.springframework.http.MediaType.APPLICATION_JSON_VALUE;
+import static org.springframework.web.bind.annotation.RequestMethod.GET;
+
 @RestController
 @RequestMapping("/bridging")
 public class BridgingController {
-	@Autowired 
+
+	@Autowired
+	private PegawaiService pegawaiService;
+
+	@Autowired
 	BridgingDao myDao;
-	
+
-	//@Value("${reportDirectory}")
+	// @Value("${reportDirectory}")
-	//String reportDirectory;
+	// String reportDirectory;
-	
+
-	@RequestMapping(value = "/testbor", method = RequestMethod.GET, produces = { MediaType.APPLICATION_JSON_VALUE })
+	@RequestMapping(value = "/testbor", method = GET, produces = { APPLICATION_JSON_VALUE })
-	public BridgeBUKBorVO test(@RequestParam(value = "bulan", required = true) String bulanTahun) throws ParseException  {
+	public BridgeBUKBorVO test(@RequestParam(value = "bulan", required = true) String bulanTahun)
-		//String ret = "";
+			throws ParseException {
+		// String ret = "";
 		SimpleDateFormat sdf = new SimpleDateFormat("dd/MM/yyyy");
 
 		List<Object[]> bed = myDao.getQtyBed();
-		Integer totalBed =0;
+		Integer totalBed = 0;
-		ArrayList<Integer> ruanganId= new ArrayList<Integer>();
+		ArrayList<Integer> ruanganId = new ArrayList<Integer>();
-		for(int i = 0; i<bed.size();i++){
+		for (int i = 0; i < bed.size(); i++) {
-			totalBed = totalBed + ((Byte)bed.get(i)[1]).intValue();
+			totalBed = totalBed + ((Byte) bed.get(i)[1]).intValue();
-			if(ruanganId.size()==0){
+			if (ruanganId.size() == 0) {
-				ruanganId.add((Integer)bed.get(i)[0]);
+				ruanganId.add((Integer) bed.get(i)[0]);
-			}else{
+			} else {
-				boolean found=false;
+				boolean found = false;
-				for(int j = 0;j<ruanganId.size();j++){
+				for (int j = 0; j < ruanganId.size(); j++) {
-					if(ruanganId.get(j)==(Integer)bed.get(i)[0]){
+					if (ruanganId.get(j) == (Integer) bed.get(i)[0]) {
 						found = true;
 						break;
 					}
 				}
-				if(!found){
+				if (!found) {
-					ruanganId.add((Integer)bed.get(i)[0]);
+					ruanganId.add((Integer) bed.get(i)[0]);
 				}
 			}
 		}
-		System.out.println("totalBed"+ String.valueOf(totalBed));
+		System.out.println("totalBed" + String.valueOf(totalBed));
-		String bb[]= bulanTahun.split("-");
+		String bb[] = bulanTahun.split("-");
 		String bulan = bb[0].trim();
 		String tahun = bb[1].trim();
 
-		int month = Integer.parseInt(bulan);		
+		int month = Integer.parseInt(bulan);
 		int year = Integer.parseInt(tahun);
-		
+
-		GregorianCalendar mycal = new GregorianCalendar(year,month, 1);
+		GregorianCalendar mycal = new GregorianCalendar(year, month, 1);
-		int daysInMonth= mycal.getActualMaximum(Calendar.DAY_OF_MONTH);
+		int daysInMonth = mycal.getActualMaximum(Calendar.DAY_OF_MONTH);
-		
+
-		Date d1 = (Date) sdf.parse("01"+"/"+bulan+"/"+tahun);		
+		Date d1 = (Date) sdf.parse("01" + "/" + bulan + "/" + tahun);
-		Date d2 = (Date) sdf.parse(String.valueOf(daysInMonth)+"/"+bulan+"/"+tahun);
+		Date d2 = (Date) sdf.parse(String.valueOf(daysInMonth) + "/" + bulan + "/" + tahun);
-		
+
-		List<Object[]>  x = myDao.getListPasienRanap(d1,d2);
+		List<Object[]> x = myDao.getListPasienRanap(d1, d2);
-		System.out.println( "Jumlah Pasien total" + String.valueOf(x.size()) );
+		System.out.println("Jumlah Pasien total" + String.valueOf(x.size()));
-		
+
 		int cnt[] = new int[daysInMonth];
-		for(int i  = 0;i<x.size();i++){
+		for (int i = 0; i < x.size(); i++) {
-			for(int j  = 0;j<daysInMonth;j++){
+			for (int j = 0; j < daysInMonth; j++) {
-				Date tgl1 = (Date)x.get(i)[0];			
+				Date tgl1 = (Date) x.get(i)[0];
-				Date tgl2 = (Date)x.get(i)[1];
+				Date tgl2 = (Date) x.get(i)[1];
-				String tgl1s[],tgl2s[];
+				String tgl1s[], tgl2s[];
-				try{
+				try {
-					tgl1s= sdf.format(tgl1).split("/");
+					tgl1s = sdf.format(tgl1).split("/");
-					String tmp1[] =tgl1s;
+					String tmp1[] = tgl1s;
-					if(Integer.valueOf(tmp1[0])==j){
+					if (Integer.valueOf(tmp1[0]) == j) {
-						
+
 					}
-				}catch(Exception ex){
+				} catch (Exception ex) {
-					tgl1s= new String[0];
+					tgl1s = new String[0];
 				}
-				try{
+				try {
-					tgl2s= sdf.format(tgl2).split("/");
+					tgl2s = sdf.format(tgl2).split("/");
-				}catch(Exception ex){
+				} catch (Exception ex) {
-					tgl2s= (String.valueOf(daysInMonth)+"/"+bulan+"/"+tahun).split("/");
+					tgl2s = (String.valueOf(daysInMonth) + "/" + bulan + "/" + tahun).split("/");
 				}
-				
+
-				if((j>=Integer.valueOf(tgl1s[0])+1)&(j<=Integer.valueOf(tgl2s[0])+1)){
+				if ((j >= Integer.valueOf(tgl1s[0]) + 1) & (j <= Integer.valueOf(tgl2s[0]) + 1)) {
 					cnt[j]++;
 				}
-			}			
+			}
 		}
 		int totalCnt = 0;
-		for(int i=0;i<cnt.length;i++){
+		for (int i = 0; i < cnt.length; i++) {
-			totalCnt=totalCnt+cnt[i];
+			totalCnt = totalCnt + cnt[i];
 		}
 		BridgeBUKBorVO returnvalue = new BridgeBUKBorVO();
-		NumberFormat formatter = new DecimalFormat("#0.00"); 
+		NumberFormat formatter = new DecimalFormat("#0.00");
-		
+
-		returnvalue.setBOR(Double.valueOf(formatter.format((double)(totalCnt*100)/(double)(totalBed*daysInMonth))));
+		returnvalue.setBOR(
-		
+				Double.valueOf(formatter.format((double) (totalCnt * 100) / (double) (totalBed * daysInMonth))));
-		return returnvalue ;
+
+		return returnvalue;
 	}
-	
+
 	// download:
-	@RequestMapping(value = "/test", method = RequestMethod.GET, produces = { MediaType.APPLICATION_JSON_VALUE })
+	@RequestMapping(value = "/test", method = GET, produces = { APPLICATION_JSON_VALUE })
-	public Map<String, Object> testFile(@RequestParam(value = "param", required = false) String param1,HttpServletResponse response) throws IOException {
+	public Map<String, Object> testFile(@RequestParam(value = "param", required = false) String param1,
-		
+			HttpServletResponse response) throws IOException {
-		String isiFile="halo";
+
-		//String fileName=reportDirectory+ UUID.randomUUID().toString().replaceAll("-", "")+".txt";
+		String isiFile = "halo";
-		//String fileName="d:/"+ UUID.randomUUID().toString().replaceAll("-", "")+".txt";
+		// String fileName=reportDirectory+
-		String fileName="d:/testfile.txt";
+		// UUID.randomUUID().toString().replaceAll("-", "")+".txt";
+		// String fileName="d:/"+ UUID.randomUUID().toString().replaceAll("-",
+		// "")+".txt";
+		String fileName = "d:/testfile.txt";
 		FileWriter fw = new FileWriter(fileName);
 		BufferedWriter bw = new BufferedWriter(fw);
-		bw.write(isiFile);	
+		bw.write(isiFile);
 		bw.flush();
 		bw.close();
-		
+
-		//FileOutputStream out = new FileOutputStream(fileName);
+		// FileOutputStream out = new FileOutputStream(fileName);
 
 		String fileType = "application/text";
 
 		response.setContentType(fileType);
 
 		// Make sure to show the download dialog
-		response.setHeader("Content-disposition", "attachment; filename="+fileName);
+		response.setHeader("Content-disposition", "attachment; filename=" + fileName);
 
 		File my_file = new File(fileName);
 		// This should send the file to browser
@@ -154,5 +167,15 @@ public class BridgingController {
 
 		return null;
 	}
-		
+
+	@RequestMapping(value = "/compreface/subjects", method = GET, produces = APPLICATION_JSON_VALUE)
+	public ResponseEntity<Object> addAllSubject() {
+		try {
+			pegawaiService.addCompreFaceSubject();
+			return new ResponseEntity<>(null, OK);
+		} catch (Exception e) {
+			return new ResponseEntity<>(null, INTERNAL_SERVER_ERROR);
+		}
+	}
+
 }

jasamedika-business/src/main/java/com/jasamedika/medifirst2000/dao/PegawaiDao.java

@@ -1006,4 +1006,9 @@ public interface PegawaiDao extends JpaRepository<Pegawai, Integer>, JpaSpecific
 	@Query("select pg from Pegawai pg " + "where pg.statusEnabled is true "
 			+ "and (pg.email = :email or pg.emailAlternatif = :email)")
 	Optional<Pegawai> findByEmailOrEmailAlternatif(@Param("email") String email);
+
+	@Query(value = "select pg.idfinger || '_' || pg.nama from pegawai_m pg " + "where pg.statusenabled is true "
+			+ "and pg.objectjenispegawaifk = 1 " + "and pg.idfinger is not null " + "and pg.idfinger <> '9999999' "
+			+ "and pg.idfinger <> '' " + "order by cast(pg.idfinger as int)", nativeQuery = true)
+	List<String> findLabelFaceByJenisPegawaiDokter();
 }

jasamedika-business/src/main/java/com/jasamedika/medifirst2000/service/PegawaiService.java

@@ -180,4 +180,8 @@ public interface PegawaiService extends BaseVoService<Pegawai, PegawaiVO, Intege
 	String findAvatar(Integer idPegawai);
 
 	void completeDataPegawai(PegawaiDto dto);
+
+	void addCompreFaceSubject();
+
+	void uploadImageExampleOfCompreFaceSubject();
 }

jasamedika-business/src/main/java/com/jasamedika/medifirst2000/service/impl/PegawaiServiceImpl.java

@@ -1,10 +1,14 @@
 package com.jasamedika.medifirst2000.service.impl;
 
+import com.fasterxml.jackson.core.JsonProcessingException;
+import com.fasterxml.jackson.databind.ObjectMapper;
 import com.jasamedika.medifirst2000.constants.Master;
 import com.jasamedika.medifirst2000.converter.PegawaiConverter;
 import com.jasamedika.medifirst2000.dao.*;
 import com.jasamedika.medifirst2000.dao.custom.PegawaiDaoCustom;
+import com.jasamedika.medifirst2000.dto.compreface.request.FaceSubjectReq;
 import com.jasamedika.medifirst2000.dto.PegawaiDto;
+import com.jasamedika.medifirst2000.dto.compreface.response.FaceSubjectRes;
 import com.jasamedika.medifirst2000.entities.*;
 import com.jasamedika.medifirst2000.exception.ServiceVOException;
 import com.jasamedika.medifirst2000.paging.Comparison;
@@ -22,16 +26,22 @@ import org.joda.time.Chronology;
 import org.joda.time.LocalDate;
 import org.joda.time.chrono.ISOChronology;
 import org.joda.time.chrono.IslamicChronology;
+import org.json.JSONException;
+import org.json.JSONObject;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.beans.factory.annotation.Value;
 import org.springframework.data.domain.Page;
 import org.springframework.data.domain.PageRequest;
 import org.springframework.data.domain.Pageable;
 import org.springframework.data.domain.Sort;
+import org.springframework.http.*;
 import org.springframework.orm.jpa.JpaSystemException;
 import org.springframework.stereotype.Service;
 import org.springframework.transaction.annotation.Propagation;
 import org.springframework.transaction.annotation.Transactional;
+import org.springframework.web.client.RestTemplate;
 
 import java.io.File;
 import java.text.DateFormat;
@@ -39,6 +49,12 @@ import java.text.ParseException;
 import java.text.SimpleDateFormat;
 import java.util.*;
 
+import static org.springframework.http.HttpMethod.GET;
+import static org.springframework.http.HttpMethod.POST;
+import static org.springframework.http.HttpStatus.CREATED;
+import static org.springframework.http.HttpStatus.OK;
+import static org.springframework.http.MediaType.APPLICATION_JSON;
+
 /**
  * Implement class for PasienService
  * 
@@ -46,6 +62,12 @@ import java.util.*;
  */
 @Service("pegawaiService")
 public class PegawaiServiceImpl extends BaseVoServiceImpl implements PegawaiService {
+
+	private static final Logger log = LoggerFactory.getLogger(PegawaiServiceImpl.class);
+
+	@Autowired
+	private ObjectMapper objectMapper;
+
 	@Value("${systemDirectory}")
 	String systemDirectory;
 
@@ -2364,4 +2386,56 @@ public class PegawaiServiceImpl extends BaseVoServiceImpl implements PegawaiServ
 		}
 	}
 
+	@Override
+	@Transactional
+	public void addCompreFaceSubject() {
+		final String uri = "http://172.16.44.34:9999/api/v1/recognition/subjects";
+		RestTemplate template = new RestTemplate();
+		HttpHeaders headers = new HttpHeaders();
+		headers.setContentType(APPLICATION_JSON);
+		headers.set("x-api-key", "2759e013-2e89-4a0e-83e1-5b57bb76f06f");
+		List<String> listLabelDokter = pegawaiDao.findLabelFaceByJenisPegawaiDokter();
+		listLabelDokter.forEach(s -> {
+			try {
+				FaceSubjectReq dto = FaceSubjectReq.builder().subject(s).build();
+				JSONObject jsonObject = new JSONObject(objectMapper.writeValueAsString(dto));
+				HttpEntity<Object> httpEntity = new HttpEntity<>(jsonObject.toString(), headers);
+				ResponseEntity<FaceSubjectReq> exchange = template.exchange(uri, POST, httpEntity,
+						FaceSubjectReq.class);
+
+				log.info("Try add subject ke server compreface {}", exchange.getBody().toString());
+			} catch (JsonProcessingException | JSONException e) {
+				throw new ServiceVOException(e.getMessage());
+			}
+		});
+	}
+
+	@Override
+	@Transactional
+	public void uploadImageExampleOfCompreFaceSubject() {
+
+	}
+
+	@Transactional
+	private FaceSubjectRes listSubjects() {
+		final String uri = "http://172.16.44.34:9999/api/v1/recognition/subjects/";
+		RestTemplate template = new RestTemplate();
+		HttpHeaders headers = new HttpHeaders();
+		headers.setContentType(APPLICATION_JSON);
+		headers.set("x-api-key", "2759e013-2e89-4a0e-83e1-5b57bb76f06f");
+		HttpEntity<Object> httpEntity = new HttpEntity<>(headers);
+		ResponseEntity<Object> response = template.exchange(uri, GET, httpEntity, Object.class);
+		if (CommonUtil.isNotNullOrEmpty(response.getBody())) {
+			if (OK.equals(response.getStatusCode())) {
+				return objectMapper.convertValue(response.getBody(), FaceSubjectRes.class);
+			} else {
+				log.error(response.getBody().toString());
+				return null;
+			}
+		} else {
+			log.error(response.getStatusCode().getReasonPhrase());
+			return null;
+		}
+	}
+
 }

jasamedika-domain/src/main/java/com/jasamedika/medifirst2000/dto/compreface/request/FaceSubjectReq.java

@@ -0,0 +1,19 @@
+package com.jasamedika.medifirst2000.dto.compreface.request;
+
+import lombok.*;
+
+/**
+ * @author salmanoe
+ * @version 1.0.0
+ * @since 24/10/2024
+ */
+@Getter
+@Setter
+@AllArgsConstructor
+@NoArgsConstructor
+@Builder
+public class FaceSubjectReq {
+
+	private String subject;
+
+}

jasamedika-domain/src/main/java/com/jasamedika/medifirst2000/dto/compreface/response/FaceSubjectRes.java

@@ -0,0 +1,21 @@
+package com.jasamedika.medifirst2000.dto.compreface.response;
+
+import lombok.*;
+
+import java.util.List;
+
+/**
+ * @author Salman
+ * @version 1.0.0
+ * @since 29/10/2024
+ */
+@Getter
+@Setter
+@AllArgsConstructor
+@NoArgsConstructor
+@Builder
+public class FaceSubjectRes {
+
+    List<String> subjects;
+
+}